fix(jg):删除管道导入错误问题处理

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/service/impl/DataHandlerServiceImpl.java

@@ -2066,14 +2066,20 @@ public class DataHandlerServiceImpl {
         return map;
     }
 
-    public Integer deleteImportedPipelineData(String uscUnitCreditCode, String projectContraption, String dataSource, boolean isDelete) throws IOException {
+    public Integer deleteImportedPipelineData(String uscUnitCreditCode, String projectContraption,
+                                              String dataSource, boolean isDelete) throws IOException {
         List<String> records = this.queryImportedPipelineRecords(uscUnitCreditCode, projectContraption, dataSource);
         if (records.isEmpty()) {
             return 0;
         }
         if (isDelete) {
-            superviseInfoMapper.deleteDataAll(records);
-            deleteFromEs(records);
+            int batchSize = 1000;
+            for (int i = 0; i < records.size(); i += batchSize) {
+                int end = Math.min(i + batchSize, records.size());
+                List<String> batch = records.subList(i, end);
+                superviseInfoMapper.deleteDataAll(batch);
+                deleteFromEs(batch);
+            }
         }
         return records.size();
     }