package cn.huge.module.syncbydyh.client.api.impl;
|
|
import cn.huge.base.common.bo.ReturnBO;
|
import cn.huge.base.common.constant.ReturnConsts;
|
import cn.huge.base.common.exception.ClientException;
|
import cn.huge.base.common.utils.ObjectUtils;
|
import cn.huge.module.ctuser.domain.po.*;
|
import cn.huge.module.syncbydyh.client.api.SyncBydyhClient;
|
import cn.huge.module.sys.dto.FileIdTypeInfoBaseDTO;
|
import cn.huge.module.sys.dto.GridTokenBaseDTO;
|
import cn.huge.module.sys.dto.GridUserBaseDTO;
|
import com.alibaba.fastjson.JSON;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.ArrayList;
|
import java.util.LinkedHashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
|
/**
|
* @title: 白云区矛盾纠纷多元化解平台同步微服务调用接口
|
* @description: 白云区矛盾纠纷多元化解平台同步微服务调用接口
|
* @company: hugeinfo
|
* @author: liyj
|
* @time: 2021-11-05 16:51:48
|
* @version: 1.0.0
|
*/
|
@Slf4j
|
@Component
|
public class SyncBydyhClientImpl {
|
|
private SyncBydyhClient syncBydyhClient;
|
|
/**
|
* ObjectMapper工具类
|
*/
|
private ObjectMapper objectMapper = new ObjectMapper();
|
|
@Autowired
|
public SyncBydyhClientImpl(SyncBydyhClient syncBydyhClient) {
|
this.syncBydyhClient = syncBydyhClient;
|
}
|
|
/**
|
* 数据割接-组织信息
|
* @url {ctx}/api/client/syncCust/byToGzCtUnit
|
* @return Object
|
*/
|
public List<CtUnit> byToGzCtUnit(){
|
List<CtUnit> resultList = new ArrayList<>();
|
try{
|
ReturnBO returnBo = syncBydyhClient.byToGzCtUnit();
|
if (ReturnConsts.OK == returnBo.getCode()){
|
if (ObjectUtils.isNotEmpty(returnBo.getData())){
|
List<LinkedHashMap> list = (List<LinkedHashMap>) returnBo.getData();
|
for (LinkedHashMap map : list) {
|
CtUnit result = JSON.parseObject(JSON.toJSONString(map), CtUnit.class);
|
resultList.add(result);
|
}
|
}
|
}else{
|
log.error("Client外服务接口[SyncBydyhClient.byToGzCtUnit]请求异常：" + returnBo.getMsg(), returnBo.getMsg());
|
throw new ClientException("SyncBydyhClient.byToGzCtUnit", returnBo.getMsg());
|
}
|
}catch (Exception e){
|
log.error("service方法[SyncBydyhClient.byToGzCtUnit]调用异常："+e, e);
|
}
|
return resultList;
|
}
|
|
/**
|
* 数据割接-部门信息
|
* @url {ctx}/api/client/syncCust/byToGzCtDept
|
* @return Object
|
*/
|
public List<CtDept> byToGzCtDept(){
|
List<CtDept> resultList = new ArrayList<>();
|
try{
|
ReturnBO returnBo = syncBydyhClient.byToGzCtDept();
|
if (ReturnConsts.OK == returnBo.getCode()){
|
if (ObjectUtils.isNotEmpty(returnBo.getData())){
|
List<LinkedHashMap> list = (List<LinkedHashMap>) returnBo.getData();
|
for (LinkedHashMap map : list) {
|
CtDept result = JSON.parseObject(JSON.toJSONString(map), CtDept.class);
|
resultList.add(result);
|
}
|
}
|
}else{
|
log.error("Client外服务接口[SyncBydyhClient.byToGzCtDept]请求异常：" + returnBo.getMsg(), returnBo.getMsg());
|
throw new ClientException("SyncBydyhClient.byToGzCtDept", returnBo.getMsg());
|
}
|
}catch (Exception e){
|
log.error("service方法[SyncBydyhClient.byToGzCtDept]调用异常："+e, e);
|
}
|
return resultList;
|
}
|
|
/**
|
* 数据割接-用户信息
|
* @url {ctx}/api/client/syncCust/byToGzCtUser
|
* @return Object
|
*/
|
public List<CtUser> byToGzCtUser(){
|
List<CtUser> resultList = new ArrayList<>();
|
try{
|
ReturnBO returnBo = syncBydyhClient.byToGzCtUser();
|
if (ReturnConsts.OK == returnBo.getCode()){
|
if (ObjectUtils.isNotEmpty(returnBo.getData())){
|
List<LinkedHashMap> list = (List<LinkedHashMap>) returnBo.getData();
|
for (LinkedHashMap map : list) {
|
CtUser result = JSON.parseObject(JSON.toJSONString(map), CtUser.class);
|
resultList.add(result);
|
}
|
}
|
}else{
|
log.error("Client外服务接口[SyncBydyhClient.byToGzCtUser]请求异常：" + returnBo.getMsg(), returnBo.getMsg());
|
throw new ClientException("SyncBydyhClient.byToGzCtUser", returnBo.getMsg());
|
}
|
}catch (Exception e){
|
log.error("service方法[SyncBydyhClient.byToGzCtUser]调用异常："+e, e);
|
}
|
return resultList;
|
}
|
|
/**
|
* 数据割接-账号信息
|
* @url {ctx}/api/client/syncCust/byToGzCtAccount
|
* @return Object
|
*/
|
public List<CtAccount> byToGzCtAccount(){
|
List<CtAccount> resultList = new ArrayList<>();
|
try{
|
ReturnBO returnBo = syncBydyhClient.byToGzCtAccount();
|
if (ReturnConsts.OK == returnBo.getCode()){
|
if (ObjectUtils.isNotEmpty(returnBo.getData())){
|
List<LinkedHashMap> list = (List<LinkedHashMap>) returnBo.getData();
|
for (LinkedHashMap map : list) {
|
CtAccount result = JSON.parseObject(JSON.toJSONString(map), CtAccount.class);
|
resultList.add(result);
|
}
|
}
|
}else{
|
log.error("Client外服务接口[SyncBydyhClient.byToGzCtAccount]请求异常：" + returnBo.getMsg(), returnBo.getMsg());
|
throw new ClientException("SyncBydyhClient.byToGzCtAccount", returnBo.getMsg());
|
}
|
}catch (Exception e){
|
log.error("service方法[SyncBydyhClient.byToGzCtAccount]调用异常："+e, e);
|
}
|
return resultList;
|
}
|
|
/**
|
* 数据割接-用户角色关系信息
|
* @url {ctx}/api/client/syncCust/byToGzCtUserole
|
* @return Object
|
*/
|
public List<CtUserole> byToGzCtUserole(){
|
List<CtUserole> resultList = new ArrayList<>();
|
try{
|
ReturnBO returnBo = syncBydyhClient.byToGzCtUserole();
|
if (ReturnConsts.OK == returnBo.getCode()){
|
if (ObjectUtils.isNotEmpty(returnBo.getData())){
|
List<LinkedHashMap> list = (List<LinkedHashMap>) returnBo.getData();
|
for (LinkedHashMap map : list) {
|
CtUserole result = JSON.parseObject(JSON.toJSONString(map), CtUserole.class);
|
resultList.add(result);
|
}
|
}
|
}else{
|
log.error("Client外服务接口[SyncBydyhClient.byToGzCtUserole]请求异常：" + returnBo.getMsg(), returnBo.getMsg());
|
throw new ClientException("SyncBydyhClient.byToGzCtUserole", returnBo.getMsg());
|
}
|
}catch (Exception e){
|
log.error("service方法[SyncBydyhClient.byToGzCtUserole]调用异常："+e, e);
|
}
|
return resultList;
|
}
|
|
}
|
