From 6d31115d931190fe4780d5479981367705be37b7 Mon Sep 17 00:00:00 2001
From: wangwh <2397901735@qq.com>
Date: Sat, 31 Aug 2024 18:01:06 +0800
Subject: [PATCH] 服务调用方法
---
dyh-service/dyh-mediate/src/main/java/cn/huge/module/client/api/impl/CustClientImpl.java | 83 ----------------
dyh-service/dyh-mediate/src/main/java/cn/huge/module/client/api/impl/SysClientImpl.java | 95 +++++++++++++++++++
dyh-service/dyh-mediate/src/main/java/cn/huge/module/client/api/SysClient.java | 36 +++++++
dyh-service/dyh-mediate/src/main/java/cn/huge/module/client/api/CustClient.java | 44 +-------
4 files changed, 141 insertions(+), 117 deletions(-)
diff --git a/dyh-service/dyh-mediate/src/main/java/cn/huge/module/client/api/CustClient.java b/dyh-service/dyh-mediate/src/main/java/cn/huge/module/client/api/CustClient.java
index 4bc8525..e3380e9 100644
--- a/dyh-service/dyh-mediate/src/main/java/cn/huge/module/client/api/CustClient.java
+++ b/dyh-service/dyh-mediate/src/main/java/cn/huge/module/client/api/CustClient.java
@@ -18,57 +18,29 @@
/**
* 内部用户-获取登录用户
- * @url {ctx}/api/v1/ctUser/clientGetUser?userId=
+ * @url {ctx}/api/client/ctUser/clientGetUser?userId=
* @param userId 登录用户编号
* @return ReturnBO
*/
- @GetMapping("/api/v1/ctUser/clientGetUser")
+ @GetMapping("/api/client/ctUser/clientGetUser")
ReturnBO clientGetUser(@RequestParam("userId") String userId);
/**
- * 内部用户-获取登录用户
- * @url {ctx}/api/v1/ctUser/clientGetUserAll?userId=
+ * 内部用户-获取登录用户-所有信息
+ * @url {ctx}/api/client/ctUser/clientGetUserAll?userId=
* @param userId 登录用户编号
* @return
*/
- @GetMapping("/api/v1/ctUser/clientGetUserAll")
+ @GetMapping("/api/client/ctUser/clientGetUserAll")
ReturnBO clientGetUserAll(@RequestParam("userId") String userId);
/**
- * 当事人-获取登录用户
- * @url {ctx}/api/v1/paUser/clientGetUserAll?userId=
+ * 当事人-获取登录用户-所有信息
+ * @url {ctx}/api/client/paUser/clientGetUserAll?userId=
* @param userId 登录用户编号
* @return ReturnBO
*/
- @GetMapping("/api/v1/paUser/clientGetUserAll")
+ @GetMapping("/api/client/paUser/clientGetUserAll")
ReturnBO paclientGetUser(@RequestParam("userId") String userId);
- /**
- * 根据组织和角色查询
- * @url {ctx}/api/v1/ctUser/listUserByUnitRole
- * @return unitId 组织编号
- * @return roleCode 角色代码
- * @return ReturnBO
- */
- @GetMapping("/api/v1/ctUser/listUserByUnitRole")
- ReturnBO listUserByUnitRole(@RequestParam(value = "unitId") String unitId, @RequestParam(value = "roleCode") String roleCode);
-
- /**
- * 根据部门和角色查询
- * @url {ctx}/api/v1/ctUser/listUserByDeptRole
- * @return deptId 部门编号
- * @return roleCode 角色代码
- * @return ReturnBO
- */
- @GetMapping("/api/v1/ctUser/listUserByDeptRole")
- ReturnBO listUserByDeptRole(@RequestParam(value = "deptId") String deptId, @RequestParam(value = "roleCode") String roleCode);
-
- /**
- * 查询客户下的法院
- * @url {ctx}/api/v1/ctUnit/listCourt1
- * @param userId 用户编号
- * @return ReturnBO
- */
- @GetMapping("/api/v1/ctUnit/listCourt1")
- ReturnBO listCourt1(@RequestParam(value = "userId") String userId);
}
diff --git a/dyh-service/dyh-mediate/src/main/java/cn/huge/module/client/api/SysClient.java b/dyh-service/dyh-mediate/src/main/java/cn/huge/module/client/api/SysClient.java
new file mode 100644
index 0000000..748a91d
--- /dev/null
+++ b/dyh-service/dyh-mediate/src/main/java/cn/huge/module/client/api/SysClient.java
@@ -0,0 +1,36 @@
+package cn.huge.module.client.api;
+
+import cn.huge.base.common.bo.ReturnBO;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * @title: 系统公共服务微服务调用接口
+ * @description: 系统公共服务微服务调用接口
+ * @company: hugeinfo
+ * @author: liyj
+ * @time: 2021-11-05 16:51:48
+ * @version: 1.0.0
+ */
+@FeignClient(name = "dyh-sys")
+public interface SysClient {
+ /**
+ * 附件中心-根据多个所属编号查询附件并根据先根据ownerId再根据附件类型分组
+ * @url {ctx}/api/v1/fileInfo/listTypeInfoByOwnerIds?ownerIds=
+ * @param ownerIdList 所属业务编号
+ * @return ReturnBO
+ */
+ @GetMapping("/api/client/fileInfo/listIdTypeInfoByOwnerIdList")
+ ReturnBO listTypeInfoByOwnerIdList(@RequestParam(value = "ownerIdList") List<String> ownerIdList);
+
+ /**
+ * 附件中心-根据多个所属编号查询附件
+ * @url {ctx}/api/v1/fileInfo/listInfoByOwnerIdList?ownerIds=
+ * @param ownerIdList 所属业务编号
+ * @return ReturnBO
+ */
+ @GetMapping("/api/client/fileInfo/listInfoByOwnerIdList")
+ ReturnBO listInfoByOwnerIdList(@RequestParam(value = "ownerIdList") List<String> ownerIdList);
+}
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 cf056ca..c46758a 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
@@ -65,7 +65,7 @@
}
/**
- * 内部用户-获取登录用户
+ * 内部用户-获取登录用户-所有信息
* @param userId
* @return
*/
@@ -86,7 +86,7 @@
}
/**
- * 当事人-获取登录用户
+ * 当事人-获取登录用户-所有信息
* @param userId 用户编号
* @return
*/
@@ -106,83 +106,4 @@
}
}
- /**
- * 根据组织和角色查询
- * @return unitId 组织编号
- * @return roleCode 角色代码
- * @return Object
- */
- public List<CtUserDTO> listUserByUnitRole(@RequestParam(value = "unitId") String unitId, @RequestParam(value = "roleCode") String roleCode) {
- List<CtUserDTO> ctUserDTOList = new ArrayList<>();
- try{
- ReturnBO returnBo = custClient.listUserByUnitRole(unitId, roleCode);
- if (ReturnConsts.OK == returnBo.getCode()){
- List<LinkedHashMap> list = (List<LinkedHashMap>) returnBo.getData();
- for (LinkedHashMap map : list) {
- CtUserDTO ctUserDTO = JSON.parseObject(JSON.toJSONString(map), CtUserDTO.class);
- ctUserDTOList.add(ctUserDTO);
- }
- return ctUserDTOList;
- }else{
- log.error("Client外服务接口[CustClientImpl.listUserByUnitRole]请求异常：" + returnBo.getMsg(), returnBo.getMsg());
- throw new ClientException("CustClientImpl.listUserByUnitRole", returnBo.getMsg());
- }
- }catch (Exception e){
- log.error("service方法[CustClientImpl.listUserByUnitRole]调用异常："+e, e);
- throw new ServiceException("CustClientImpl.listUserByUnitRole", e);
- }
- }
-
- /**
- * 根据部门和角色查询
- * @return deptId 部门编号
- * @return roleCode 角色代码
- * @return Object
- */
- public List<CtUserDTO> listUserByDeptRole(@RequestParam(value = "deptId") String deptId, @RequestParam(value = "roleCode") String roleCode) {
- List<CtUserDTO> ctUserDTOList = new ArrayList<>();
- try{
- ReturnBO returnBo = custClient.listUserByDeptRole(deptId, roleCode);
- if (ReturnConsts.OK == returnBo.getCode()){
- List<LinkedHashMap> list = (List<LinkedHashMap>) returnBo.getData();
- for (LinkedHashMap map : list) {
- CtUserDTO ctUserDTO = JSON.parseObject(JSON.toJSONString(map), CtUserDTO.class);
- ctUserDTOList.add(ctUserDTO);
- }
- return ctUserDTOList;
- }else{
- log.error("Client外服务接口[CustClientImpl.listUserByDeptRole]请求异常：" + returnBo.getMsg(), returnBo.getMsg());
- throw new ClientException("CustClientImpl.listUserByDeptRole", returnBo.getMsg());
- }
- }catch (Exception e){
- log.error("service方法[CustClientImpl.listUserByDeptRole]调用异常："+e, e);
- throw new ServiceException("CustClientImpl.listUserByDeptRole", e);
- }
- }
-
- /**
- * 查询客户下的法院
- * @param userId
- * @return
- */
- public List<SelectTermDTO> listCourt1(String userId){
- List<SelectTermDTO> selectTermDTOList = new ArrayList<>();
- try{
- ReturnBO returnBo = custClient.listCourt1(userId);
- if (ReturnConsts.OK == returnBo.getCode()){
- List<LinkedHashMap> list = (List<LinkedHashMap>) returnBo.getData();
- for (LinkedHashMap map : list) {
- SelectTermDTO selectTermDTO = JSON.parseObject(JSON.toJSONString(map), SelectTermDTO.class);
- selectTermDTOList.add(selectTermDTO);
- }
- return selectTermDTOList;
- }else{
- log.error("Client外服务接口[CustClientImpl.listCourt1]请求异常：" + returnBo.getMsg(), returnBo.getMsg());
- throw new ClientException("CustClientImpl.listCourt1", returnBo.getMsg());
- }
- }catch (Exception e){
- log.error("service方法[CustClientImpl.listCourt1]调用异常："+e, e);
- throw new ServiceException("CustClientImpl.listCourt1", e);
- }
- }
}
diff --git a/dyh-service/dyh-mediate/src/main/java/cn/huge/module/client/api/impl/SysClientImpl.java b/dyh-service/dyh-mediate/src/main/java/cn/huge/module/client/api/impl/SysClientImpl.java
new file mode 100644
index 0000000..ab04871
--- /dev/null
+++ b/dyh-service/dyh-mediate/src/main/java/cn/huge/module/client/api/impl/SysClientImpl.java
@@ -0,0 +1,95 @@
+package cn.huge.module.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.exception.ServiceException;
+import cn.huge.base.common.utils.ObjectUtils;
+import cn.huge.module.client.api.SysClient;
+import cn.huge.module.sys.dto.FileIdInfoBaseDTO;
+import cn.huge.module.sys.dto.FileIdTypeInfoBaseDTO;
+import cn.huge.module.sys.dto.FileInfoBaseDTO;
+import cn.huge.module.sys.dto.FileTypeInfoBaseDTO;
+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.RequestBody;
+
+import java.util.ArrayList;
+import java.util.LinkedHashMap;
+import java.util.List;
+
+/**
+ * @title: 系统公共服务微服务调用接口
+ * @description: 系统公共服务微服务调用接口
+ * @company: hugeinfo
+ * @author: liyj
+ * @time: 2021-11-05 16:51:48
+ * @version: 1.0.0
+ */
+@Slf4j
+@Component
+public class SysClientImpl {
+
+ private SysClient sysClient;
+
+ @Autowired
+ public SysClientImpl(SysClient sysClient) {
+ this.sysClient = sysClient;
+ }
+
+ /**
+ * ObjectMapper工具类
+ */
+ private ObjectMapper objectMapper = new ObjectMapper();
+
+ /**
+ * 附件中心-根据多个所属编号查询附件并根据先根据ownerId再根据附件类型分组
+ * @param ownerIdList 所属业务编号
+ * @return List
+ */
+ public List<FileIdTypeInfoBaseDTO> listIdTypeInfoByOwnerIdList(List<String> ownerIdList){
+ List<FileIdTypeInfoBaseDTO> fileIdTypeInfoBaseDTOList = new ArrayList<>();
+ try{
+ ReturnBO returnBo = sysClient.listTypeInfoByOwnerIdList(ownerIdList);
+ if (ReturnConsts.OK == returnBo.getCode()){
+ if (ObjectUtils.isNotEmpty(returnBo.getData())){
+ List<LinkedHashMap> list = (List<LinkedHashMap>) returnBo.getData();
+ for (LinkedHashMap map : list) {
+ FileIdTypeInfoBaseDTO fileIdTypeInfoBaseDTO = JSON.parseObject(JSON.toJSONString(map), FileIdTypeInfoBaseDTO.class);
+ fileIdTypeInfoBaseDTOList.add(fileIdTypeInfoBaseDTO);
+ }
+ }
+ }
+ }catch (Exception e){
+ log.error("service方法[SysClientImpl.listIdTypeInfoByOwnerIdList]调用异常："+e, e);
+ }
+ return fileIdTypeInfoBaseDTOList;
+ }
+
+ /**
+ * 附件中心-根据业务编号查询固定格式所有附件
+ * @param ownerIdList 所属业务编号
+ * @return List
+ */
+ public List<FileIdInfoBaseDTO> listIdInfoByOwnerIdList(List<String> ownerIdList){
+ List<FileIdInfoBaseDTO> fileIdInfoBaseDTOList = new ArrayList<>();
+ try{
+ ReturnBO returnBo = sysClient.listInfoByOwnerIdList(ownerIdList);
+ if (ReturnConsts.OK == returnBo.getCode()){
+ if (ObjectUtils.isNotEmpty(returnBo.getData())){
+ List<LinkedHashMap> list = (List<LinkedHashMap>) returnBo.getData();
+ for (LinkedHashMap map : list) {
+ FileIdInfoBaseDTO fileIdInfoBaseDTO = JSON.parseObject(JSON.toJSONString(map), FileIdInfoBaseDTO.class);
+ fileIdInfoBaseDTOList.add(fileIdInfoBaseDTO);
+ }
+ }
+ }
+ }catch (Exception e){
+ log.error("service方法[SysClientImpl.listIdInfoByOwnerIdList]调用异常："+e, e);
+ }
+ return fileIdInfoBaseDTOList;
+ }
+}
--
Gitblit v1.8.0