From 1a320ae74056c99a439e0608a7243953cdef8ddd Mon Sep 17 00:00:00 2001 From: liyj <1003249715@qq.com> Date: Wed, 18 Sep 2024 10:09:26 +0800 Subject: [PATCH] 1、联合处置流程优化2 --- dyh-service/dyh-mediate/src/main/java/cn/huge/module/client/api/impl/CustClientImpl.java | 66 +++++++++++++++++++++++++++++++++ 1 files changed, 66 insertions(+), 0 deletions(-) diff --git a/dyh-service/dyh-mediate/src/main/java/cn/huge/module/client/api/impl/CustClientImpl.java b/dyh-service/dyh-mediate/src/main/java/cn/huge/module/client/api/impl/CustClientImpl.java index c46758a..1b708f4 100644 --- a/dyh-service/dyh-mediate/src/main/java/cn/huge/module/client/api/impl/CustClientImpl.java +++ b/dyh-service/dyh-mediate/src/main/java/cn/huge/module/client/api/impl/CustClientImpl.java @@ -6,13 +6,16 @@ import cn.huge.base.common.exception.ClientException; import cn.huge.base.common.exception.ServiceException; import cn.huge.module.client.api.CustClient; +import cn.huge.module.cust.dto.CtUnitDTO; import cn.huge.module.cust.dto.CtUserDTO; import cn.huge.module.cust.dto.PaUserDTO; +import cn.huge.module.mediate.dto.WechatBindCaseDTO; 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 org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestParam; import java.util.ArrayList; @@ -106,4 +109,67 @@ } } + /** + * pc端提交案件后-获取相关当事人用户编号 + * @param wechatBindCaseDTO 实体对象 + * @return ReturnBO + */ + public String bindGetUserId(WechatBindCaseDTO wechatBindCaseDTO){ + String userId = null; + try{ + ReturnBO returnBo = custClient.bindGetUserId(wechatBindCaseDTO); + if (ReturnConsts.OK == returnBo.getCode()){ + userId = (String) returnBo.getData(); + }else{ + log.error("Client外服务接口[CustClientImpl.bindGetUserId]请求异常:" + returnBo.getMsg(), returnBo.getMsg()); + } + }catch (Exception e){ + log.error("service方法[CustClientImpl.bindGetUserId]调用异常:"+e, e); + } + return userId; + } + + /** + * 根据id查询组织信息 + * @url {ctx}/api/client/ctUnit/getUnitById + * @param unitId 组织编号 + * @return Object + */ + public CtUnitDTO getUnitById(String unitId){ + try{ + ReturnBO returnBo = custClient.getUnitById(unitId); + if (ReturnConsts.OK == returnBo.getCode()){ + CtUnitDTO ctUnitDTO = objectMapper.convertValue(returnBo.getData(), CtUnitDTO.class); + return ctUnitDTO; + }else{ + log.error("Client外服务接口[CustClientImpl.getUnitById]请求异常:" + returnBo.getMsg(), returnBo.getMsg()); + throw new ClientException("CustClientImpl.getUnitById", returnBo.getMsg()); + } + }catch (Exception e){ + log.error("service方法[CustClientImpl.getUnitById]调用异常:"+e, e); + throw new ServiceException("CustClientImpl.getUnitById", e); + } + } + + /** + * 获取上级综治中心 + * @url {ctx}/api/client/ctUnit/getParentZzzxUnit + * @param unitId 组织编号 + * @return Object + */ + public CtUnitDTO getParentZzzxUnit(String unitId){ + try{ + ReturnBO returnBo = custClient.getParentZzzxUnit(unitId); + if (ReturnConsts.OK == returnBo.getCode()){ + CtUnitDTO ctUnitDTO = objectMapper.convertValue(returnBo.getData(), CtUnitDTO.class); + return ctUnitDTO; + }else{ + log.error("Client外服务接口[CustClientImpl.getParentZzzxUnit]请求异常:" + returnBo.getMsg(), returnBo.getMsg()); + throw new ClientException("CustClientImpl.getParentZzzxUnit", returnBo.getMsg()); + } + }catch (Exception e){ + log.error("service方法[CustClientImpl.getParentZzzxUnit]请求成功,处理异常:"+e, e); + throw new ServiceException("CustClientImpl.getParentZzzxUnit", e); + } + } } -- Gitblit v1.8.0