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 54381d0..7770336 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 @@ -114,10 +114,13 @@ public class DataCleanServiceImpl implements IDataCleanService { result.addAll(pqDataVerifies); }); } + partList = null; }); if (CollUtil.isNotEmpty(result)) { pqDataVerifyFeignClient.insertData(result); + result.clear(); } + lineDetail.clear(); } @Override @@ -149,10 +152,13 @@ public class DataCleanServiceImpl implements IDataCleanService { result.addAll(pqDataVerifies); }); } + partList = null; }); if (CollUtil.isNotEmpty(result)) { pqDataVerifyFeignClient.insertData(result); + result.clear(); } + lineDetail.clear(); } @Override @@ -178,10 +184,13 @@ public class DataCleanServiceImpl implements IDataCleanService { result.addAll(pqDataVerifies); }); } + partList = null; }); if (CollUtil.isNotEmpty(result)) { pqDataVerifyFeignClient.insertData(result); + result.clear(); } + lineList.clear(); } @Override @@ -207,10 +216,13 @@ public class DataCleanServiceImpl implements IDataCleanService { result.addAll(pqDataVerifies); }); } + partList = null; }); if (CollUtil.isNotEmpty(result)) { pqDataVerifyFeignClient.insertData(result); + result.clear(); } + lineList.clear(); } @Override @@ -236,10 +248,13 @@ public class DataCleanServiceImpl implements IDataCleanService { result.addAll(pqDataVerifies); }); } + partList = null; }); if (CollUtil.isNotEmpty(result)) { pqDataVerifyFeignClient.insertData(result); + result.clear(); } + lineList.clear(); } @Override @@ -265,10 +280,13 @@ public class DataCleanServiceImpl implements IDataCleanService { result.addAll(pqDataVerifies); }); } + partList = null; }); if (CollUtil.isNotEmpty(result)) { pqDataVerifyFeignClient.insertData(result); + result.clear(); } + lineList.clear(); } @Override @@ -294,10 +312,13 @@ public class DataCleanServiceImpl implements IDataCleanService { result.addAll(pqDataVerifies); }); } + partList.clear(); }); if (CollUtil.isNotEmpty(result)) { pqDataVerifyFeignClient.insertData(result); + result.clear(); } + lineList.clear(); } @Override @@ -323,10 +344,13 @@ public class DataCleanServiceImpl implements IDataCleanService { result.addAll(pqDataVerifies); }); } + partList = null; }); if (CollUtil.isNotEmpty(result)) { pqDataVerifyFeignClient.insertData(result); + result.clear(); } + lineList.clear(); } @Override @@ -352,10 +376,13 @@ public class DataCleanServiceImpl implements IDataCleanService { result.addAll(pqDataVerifies); }); } + partList = null; }); if (CollUtil.isNotEmpty(result)) { pqDataVerifyFeignClient.insertData(result); + result.clear(); } + lineList.clear(); } diff --git a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/DayDataServiceImpl.java b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/DayDataServiceImpl.java index 981b7a4..3952a4a 100644 --- a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/DayDataServiceImpl.java +++ b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/DayDataServiceImpl.java @@ -105,10 +105,12 @@ public class DayDataServiceImpl implements IDayDataService { }); }); } + partList = null; }); if (CollUtil.isNotEmpty(result)) { //存储数据 dataVFeignClient.addList(result); + result.clear(); } } @@ -150,10 +152,12 @@ public class DayDataServiceImpl implements IDayDataService { }); }); } + partList = null; }); if (CollUtil.isNotEmpty(result)) { //存储数据 dataIFeignClient.addList(result); + result.clear(); } } @@ -196,10 +200,12 @@ public class DayDataServiceImpl implements IDayDataService { }); }); } + partList = null; }); if (CollUtil.isNotEmpty(result)) { //存储数据 dataFlickerFeignClient.addList(result); + result.clear(); } } @@ -242,10 +248,12 @@ public class DayDataServiceImpl implements IDayDataService { }); }); } + partList = null; }); if (CollUtil.isNotEmpty(result)) { //存储数据 dataFlucFeignClient.addList(result); + result.clear(); } } @@ -287,10 +295,12 @@ public class DayDataServiceImpl implements IDayDataService { }); }); } + partList = null; }); if (CollUtil.isNotEmpty(result)) { //存储数据 dataHarmphasicIFeignClient.addList(result); + result.clear(); } } @@ -332,10 +342,12 @@ public class DayDataServiceImpl implements IDayDataService { }); }); } + partList = null; }); if (CollUtil.isNotEmpty(result)) { //存储数据 dataHarmphasicVFeignClient.addList(result); + result.clear(); } } @@ -377,10 +389,12 @@ public class DayDataServiceImpl implements IDayDataService { }); }); } + partList = null; }); if (CollUtil.isNotEmpty(result)) { //存储数据 dataHarmpowerPFeignClient.addList(result); + result.clear(); } } @@ -422,10 +436,12 @@ public class DayDataServiceImpl implements IDayDataService { }); }); } + partList = null; }); if (CollUtil.isNotEmpty(result)) { //存储数据 dataHarmpowerQFeignClient.addList(result); + result.clear(); } } @@ -467,10 +483,12 @@ public class DayDataServiceImpl implements IDayDataService { }); }); } + partList = null; }); if (CollUtil.isNotEmpty(result)) { //存储数据 dataHarmpowerSFeignClient.addList(result); + result.clear(); } } @@ -512,10 +530,12 @@ public class DayDataServiceImpl implements IDayDataService { }); }); } + partList = null; }); if (CollUtil.isNotEmpty(result)) { //存储数据 dataHarmRateIFeignClient.addList(result); + result.clear(); } } @@ -557,10 +577,12 @@ public class DayDataServiceImpl implements IDayDataService { }); }); } + partList = null; }); if (CollUtil.isNotEmpty(result)) { //存储数据 dataHarmRateVFeignClient.addList(result); + result.clear(); } } @@ -602,10 +624,12 @@ public class DayDataServiceImpl implements IDayDataService { }); }); } + partList = null; }); if (CollUtil.isNotEmpty(result)) { //存储数据 dataInharmIFeignClient.addList(result); + result.clear(); } } @@ -647,10 +671,12 @@ public class DayDataServiceImpl implements IDayDataService { }); }); } + partList = null; }); if (CollUtil.isNotEmpty(result)) { //存储数据 dataInharmVFeignClient.addList(result); + result.clear(); } } @@ -693,10 +719,12 @@ public class DayDataServiceImpl implements IDayDataService { }); }); } + partList = null; }); if (CollUtil.isNotEmpty(result)) { //存储数据 dataPltFeignClient.addList(result); + result.clear(); } }