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 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 jzhs; int front; int later; - List 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 jzhList = Arrays.asList(jzhs.split(",")); + addSyncIntegralityByJzhsMethod(jzhList,front,later); + } + + public void addSyncIntegralityByJzhsMethod(List jzhs,int front,int later) { + List mzSyncs; + mzSyncs = mzSyncMapper.listMzSync(jzhs, front, later, tableName, tableNamespaces); + //完整性检验写入 + integralityBySyncs(mzSyncs,jzhs); + if (mzSyncs.size() != 0) { + log.info("本次成功同步数:" + mzSyncs.size()); + } + } + /** * 完整性同步方法 */