微调

algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/DataCleanServiceImpl.java

@@ -318,8 +318,9 @@ public class DataCleanServiceImpl implements IDataCleanService {
         LineCountEvaluateParam lineParam = new LineCountEvaluateParam();
         lineParam.setStartTime(TimeUtils.getBeginOfDay(calculatedParam.getDataDate()));
         lineParam.setEndTime(TimeUtils.getEndOfDay(calculatedParam.getDataDate()));
-        lineDetail.forEach(item -> {
-
+        for (int i = 0; i < lineDetail.size(); i++) {
+            logger.info("总数据：" + lineDetail.size() + "=====》当前第"+(i + 1));
+            LineDetailVO.Detail item = lineDetail.get(i);
             List<Map<String, Object>> resultData = new ArrayList<>();
             Set<String> allTimeSet = new HashSet<>();
             PqDataVerifyBak bak = new PqDataVerifyBak();
@@ -638,7 +639,7 @@ public class DataCleanServiceImpl implements IDataCleanService {
                 bak.setFilePath(fileName);
             }
             pqDataVerifyNewFeignClient.insertData(bak);
-        });
+        }
         System.gc();
     }