梅州增加按jzh查任务视图补偿接口

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({

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);
 }

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());
+        }
+    }
+
     /**
      * 完整性同步方法
      */