From 6e43f4936724de3a3efb0248700ff808b134de90 Mon Sep 17 00:00:00 2001 From: xy <748613696@qq.com> Date: Tue, 8 Apr 2025 12:25:58 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BC=82=E5=B8=B8=E6=95=B0=E6=8D=AE=E5=92=8C?= =?UTF-8?q?=E6=97=A5=E8=A1=A8=E8=BD=AC=E6=8D=A2=E7=AE=97=E6=B3=95=E5=AF=B9?= =?UTF-8?q?=E8=B1=A1=E8=A7=A3=E9=99=A4=E5=BC=95=E7=94=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../line/DataCleanServiceImpl.java | 27 ++++++++++++++++++ .../serviceimpl/line/DayDataServiceImpl.java | 28 +++++++++++++++++++ 2 files changed, 55 insertions(+) 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(); } }