From b24415be6aa39fd2a037adff153ab7c4149ae2ef Mon Sep 17 00:00:00 2001
From: zengwh <zengwh>
Date: Wed, 20 Apr 2022 13:41:16 +0800
Subject: [PATCH] =?UTF-8?q?=E6=A2=85=E5=B7=9E=E5=A2=9E=E5=8A=A0=E6=8C=89jz?=
 =?UTF-8?q?h=E6=9F=A5=E4=BB=BB=E5=8A=A1=E8=A7=86=E5=9B=BE=E8=A1=A5?=
 =?UTF-8?q?=E5=81=BF=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../docus/bgts/controller/BgtsController.java |  9 +++++++
 .../com/docus/bgts/facade/IMzSyncService.java |  2 ++
 .../com/docus/bgts/service/MzSyncService.java | 25 +++++++++++++------
 3 files changed, 29 insertions(+), 7 deletions(-)

diff --git a/src/main/java/com/docus/bgts/controller/BgtsController.java b/src/main/java/com/docus/bgts/controller/BgtsController.java
index 40e2ac5..5e870ef 100644
--- a/src/main/java/com/docus/bgts/controller/BgtsController.java
+++ b/src/main/java/com/docus/bgts/controller/BgtsController.java
@@ -55,6 +55,15 @@ public class BgtsController {
         mzSyncService.addSyncIntegrality(startDate,endDate);
     }
 
+    @GetMapping("/addSyncIntegralityByJzhs")
+    public CommonResult<String> addSyncIntegrality(@RequestParam("jzhs")String jzhs){
+        if(jzhs.split(",").length > 100){
+            return CommonResult.failed("jzh个数不能超过100个");
+        }
+        mzSyncService.addSyncIntegralityByJzhs(jzhs,0,100);
+        return CommonResult.success("完成");
+    }
+
 
     @ApiOperation("采集接口")
     @ApiImplicitParams({
diff --git a/src/main/java/com/docus/bgts/facade/IMzSyncService.java b/src/main/java/com/docus/bgts/facade/IMzSyncService.java
index d464ebc..539cb18 100644
--- a/src/main/java/com/docus/bgts/facade/IMzSyncService.java
+++ b/src/main/java/com/docus/bgts/facade/IMzSyncService.java
@@ -12,4 +12,6 @@ public interface IMzSyncService {
      * 增量采集
      */
     boolean addSyncIntegrality(String startDate, String endDate);
+
+    void addSyncIntegralityByJzhs(String jzhs,int front,int later);
 }
diff --git a/src/main/java/com/docus/bgts/service/MzSyncService.java b/src/main/java/com/docus/bgts/service/MzSyncService.java
index 31f6f5d..0ea5e72 100644
--- a/src/main/java/com/docus/bgts/service/MzSyncService.java
+++ b/src/main/java/com/docus/bgts/service/MzSyncService.java
@@ -1,5 +1,6 @@
 package com.docus.bgts.service;
 
+import cn.hutool.json.JSONUtil;
 import com.alibaba.fastjson.JSON;
 import com.docus.bgts.entity.*;
 import com.docus.bgts.enums.Codes;
@@ -93,7 +94,6 @@ public class MzSyncService implements IMzSyncService {
         List<String> jzhs;
         int front;
         int later;
-        List<MzSync> mzSyncs;
         for (int i = 0; ; i++) {
             front = i * pageSize;
             later = pageSize;
@@ -105,12 +105,7 @@ public class MzSyncService implements IMzSyncService {
                 }
                 break;
             } else {
-                mzSyncs = mzSyncMapper.listMzSync(jzhs, front, later, tableName, tableNamespaces);
-                //完整性检验写入
-                integralityBySyncs(mzSyncs,jzhs);
-            }
-            if (mzSyncs.size() != 0) {
-                log.info("本次成功同步数：" + mzSyncs.size());
+                addSyncIntegralityByJzhsMethod(jzhs,front,later);
             }
         }
         long endTime = System.currentTimeMillis();
@@ -118,6 +113,22 @@ public class MzSyncService implements IMzSyncService {
         return flag;
     }
 
+    @Override
+    public void addSyncIntegralityByJzhs(String jzhs,int front,int later) {
+        List<String> jzhList = Arrays.asList(jzhs.split(","));
+        addSyncIntegralityByJzhsMethod(jzhList,front,later);
+    }
+
+    public void addSyncIntegralityByJzhsMethod(List<String> jzhs,int front,int later) {
+        List<MzSync> mzSyncs;
+        mzSyncs = mzSyncMapper.listMzSync(jzhs, front, later, tableName, tableNamespaces);
+        //完整性检验写入
+        integralityBySyncs(mzSyncs,jzhs);
+        if (mzSyncs.size() != 0) {
+            log.info("本次成功同步数：" + mzSyncs.size());
+        }
+    }
+
     /**
      * 完整性同步方法
      */