From 32b044aa78edf5d3e54c380a7ded17a266af6948 Mon Sep 17 00:00:00 2001
From: liyj <15602261488@163.com>
Date: Sat, 26 Oct 2024 12:01:01 +0800
Subject: [PATCH] 1、白云区矛盾纠纷多元化解平台数据割接脚本-同步在途工单

---
 dyh-service/dyh-mediate/src/main/java/cn/huge/module/syncbydyh/client/api/impl/SyncBydyhClientImpl.java |   53 ++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 52 insertions(+), 1 deletions(-)

diff --git a/dyh-service/dyh-mediate/src/main/java/cn/huge/module/syncbydyh/client/api/impl/SyncBydyhClientImpl.java b/dyh-service/dyh-mediate/src/main/java/cn/huge/module/syncbydyh/client/api/impl/SyncBydyhClientImpl.java
index daaaacf..2f2583c 100644
--- a/dyh-service/dyh-mediate/src/main/java/cn/huge/module/syncbydyh/client/api/impl/SyncBydyhClientImpl.java
+++ b/dyh-service/dyh-mediate/src/main/java/cn/huge/module/syncbydyh/client/api/impl/SyncBydyhClientImpl.java
@@ -44,7 +44,7 @@
 
     /**
      * 数据割接-已结束的纠纷案件信息
-     * @url {ctx}/api/client/syncCust/byToGzCtUnit
+     * @url {ctx}/api/client/syncCust/byToGzEndCase
      * @return Object
      */
     public List<GZCaseDTO> byToGzEndCase(int page, int size){
@@ -93,4 +93,55 @@
         return 0;
     }
 
+    /**
+     * 数据割接-进行中的纠纷案件信息
+     * @url {ctx}/api/client/syncCust/byToGzTodoCase
+     * @return Object
+     */
+    public List<GZCaseDTO> byToGzTodoCase(int page, int size){
+        List<GZCaseDTO> resultList = new ArrayList<>();
+        try{
+            ReturnBO returnBo = syncBydyhClient.byToGzTodoCase(page, size);
+            if (ReturnConsts.OK == returnBo.getCode()){
+                if (ObjectUtils.isNotEmpty(returnBo.getData())){
+                    List<LinkedHashMap> list = (List<LinkedHashMap>) returnBo.getData();
+                    for (LinkedHashMap map : list) {
+                        GZCaseDTO result = JSON.parseObject(JSON.toJSONString(map), GZCaseDTO.class);
+                        resultList.add(result);
+                    }
+                }
+            }else{
+                log.error("Client外服务接口[SyncBydyhClient.byToGzTodoCase]请求异常:" + returnBo.getMsg(), returnBo.getMsg());
+                throw new ClientException("SyncBydyhClient.byToGzTodoCase", returnBo.getMsg());
+            }
+        }catch (Exception e){
+            log.error("service方法[SyncBydyhClient.byToGzTodoCase]调用异常:"+e, e);
+        }
+        return resultList;
+    }
+
+    /**
+     * 数据割接-统计进行中的纠纷案件信息
+     * @url {ctx}/api/client/syncCust/countTodoCase
+     * @return Object
+     */
+    public int countTodoCase(){
+        try{
+            ReturnBO returnBo = syncBydyhClient.countTodoCase();
+            if (ReturnConsts.OK == returnBo.getCode()) {
+                if (ObjectUtils.isNotEmpty(returnBo.getData())){
+                    return (Integer) returnBo.getData();
+                }else {
+                    return 0;
+                }
+            } else {
+                log.error("Client外服务接口[SyncBydyhClient.countTodoCase]请求异常:" + returnBo.getMsg(), returnBo.getMsg());
+                throw new ClientException("SyncBydyhClient.countTodoCase", returnBo.getMsg());
+            }
+        }catch (Exception e){
+            log.error("service方法[SyncBydyhClient.countTodoCase]调用异常:"+e, e);
+        }
+        return 0;
+    }
+
 }

--
Gitblit v1.8.0