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 f491898..6c56c97 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 @@ -149,7 +149,6 @@ public class DataCleanServiceImpl implements IDataCleanService { lineParam.setLineId(list); List partList = dataIFeignClient.getRawData(lineParam).getData(); if (CollUtil.isNotEmpty(partList)) { - logger.info("{}数据清洗dataI集合大小为>>>>>>>>>>>>{}",lineParam.getStartTime(), MemorySizeUtil.getObjectSize(partList)); partList.forEach(item->{ //数据清洗 List pqDataVerifies = judgeDataI(map, lineMap.get(item.getLineId()),item); @@ -216,8 +215,6 @@ public class DataCleanServiceImpl implements IDataCleanService { lineParam.setLineId(list); List partList = dataInharmVFeignClient.getRawData(lineParam).getData(); if (CollUtil.isNotEmpty(partList)) { - logger.info("{}数据清洗dataInharmV集合大小为>>>>>>>>>>>>{}",lineParam.getStartTime(), MemorySizeUtil.getObjectSize(partList)); - partList.forEach(item->{ //数据清洗 List pqDataVerifies = judgeDataInHarmV(map,item); @@ -251,8 +248,6 @@ public class DataCleanServiceImpl implements IDataCleanService { lineParam.setLineId(list); List partList = dataHarmRateVFeignClient.getRawData(lineParam).getData(); if (CollUtil.isNotEmpty(partList)) { - logger.info("{}数据清洗dataHarmRateV集合大小为>>>>>>>>>>>>{}",lineParam.getStartTime(), MemorySizeUtil.getObjectSize(partList)); - partList.forEach(item->{ //数据清洗 List pqDataVerifies = judgeDataHarmRateV(map,item); @@ -286,8 +281,6 @@ public class DataCleanServiceImpl implements IDataCleanService { lineParam.setLineId(list); List partList = dataHarmpowerPFeignClient.getRawData(lineParam).getData(); if (CollUtil.isNotEmpty(partList)) { - logger.info("{}数据清洗dataHarmPowerP集合大小为>>>>>>>>>>>>{}",lineParam.getStartTime(), MemorySizeUtil.getObjectSize(partList)); - partList.forEach(item->{ //数据清洗 List pqDataVerifies = judgeDataHarmPowerP(map,item); @@ -321,8 +314,6 @@ public class DataCleanServiceImpl implements IDataCleanService { lineParam.setLineId(list); List partList = dataHarmphasicVFeignClient.getRawData(lineParam).getData(); if (CollUtil.isNotEmpty(partList)) { - logger.info("{}数据清洗dataHarmPhasicV集合大小为>>>>>>>>>>>>{}",lineParam.getStartTime(), MemorySizeUtil.getObjectSize(partList)); - partList.forEach(item->{ //数据清洗 List pqDataVerifies = judgeDataHarmPhasicV(map,item); @@ -356,8 +347,6 @@ public class DataCleanServiceImpl implements IDataCleanService { lineParam.setLineId(list); List partList = dataFlucFeignClient.getRawData(lineParam).getData(); if (CollUtil.isNotEmpty(partList)) { - logger.info("{}数据清洗dataFluc集合大小为>>>>>>>>>>>>{}",lineParam.getStartTime(), MemorySizeUtil.getObjectSize(partList)); - partList.forEach(item->{ //数据清洗 List pqDataVerifies = judgeDataFluc(map,item);