diff --git a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/DataCleanServiceImpl.java b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/DataCleanServiceImpl.java index 9960a77..e351d0a 100644 --- a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/DataCleanServiceImpl.java +++ b/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> resultData = new ArrayList<>(); Set allTimeSet = new HashSet<>(); PqDataVerifyBak bak = new PqDataVerifyBak(); @@ -638,7 +639,7 @@ public class DataCleanServiceImpl implements IDataCleanService { bak.setFilePath(fileName); } pqDataVerifyNewFeignClient.insertData(bak); - }); + } System.gc(); }