From 76deaeee71840b941c7ef6a15478fe7db31292cf Mon Sep 17 00:00:00 2001 From: wr <1754607820@qq.com> Date: Thu, 11 Dec 2025 15:06:55 +0800 Subject: [PATCH] =?UTF-8?q?1.=E8=B0=83=E6=95=B4influxdb=E6=8F=92=E5=85=A5?= =?UTF-8?q?=E6=95=B0=E9=87=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/influxdb/InfluxdbDataFlickerImpl.java | 3 +-- .../service/impl/influxdb/InfluxdbDataFlucImpl.java | 3 +-- .../service/impl/influxdb/InfluxdbDataHarmRateVImpl.java | 3 +-- .../service/impl/influxdb/InfluxdbDataHarmphasicIImpl.java | 3 +-- .../service/impl/influxdb/InfluxdbDataHarmphasicVImpl.java | 3 +-- .../service/impl/influxdb/InfluxdbDataHarmpowerPImpl.java | 3 +-- .../service/impl/influxdb/InfluxdbDataHarmpowerQImpl.java | 3 +-- .../service/impl/influxdb/InfluxdbDataHarmpowerSImpl.java | 3 +-- .../service/impl/influxdb/InfluxdbDataIImpl.java | 3 +-- .../service/impl/influxdb/InfluxdbDataInharmIImpl.java | 2 +- .../service/impl/influxdb/InfluxdbDataInharmVImpl.java | 3 +-- .../service/impl/influxdb/InfluxdbDataPltImpl.java | 3 +-- .../service/impl/influxdb/InfluxdbDataVImpl.java | 7 ++----- 13 files changed, 14 insertions(+), 28 deletions(-) diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataFlickerImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataFlickerImpl.java index 8239691..de218a7 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataFlickerImpl.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataFlickerImpl.java @@ -67,9 +67,8 @@ public class InfluxdbDataFlickerImpl extends MppServiceImpl collect = dataFlickerDTOList.stream().map(temp -> DataFlicker.relationToInfluxDB(temp)).collect(Collectors.toList()); - int minSize = Math.min(1200000, collect.size()); - List> partition = ListUtils.partition(collect, minSize); + List> partition = ListUtils.partition(collect, 20000); for (List dataFlickerList : partition) { List sublistAsOriginalListType = new ArrayList<>(dataFlickerList); diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataFlucImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataFlucImpl.java index 8ebfab5..b701ad3 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataFlucImpl.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataFlucImpl.java @@ -65,9 +65,8 @@ public class InfluxdbDataFlucImpl extends MppServiceImpl collect = dataFlucDTOList.stream().map(temp -> DataFluc.relationToInfluxDB(temp)).collect(Collectors.toList()); - int minSize = Math.min(1200000, collect.size()); - List> partition = ListUtils.partition(collect, minSize); + List> partition = ListUtils.partition(collect, 20000); for (List dataFlucList : partition) { List sublistAsOriginalListType = new ArrayList<>(dataFlucList); diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmRateVImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmRateVImpl.java index 5426f61..2ef58b4 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmRateVImpl.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmRateVImpl.java @@ -84,9 +84,8 @@ public class InfluxdbDataHarmRateVImpl extends MppServiceImpl collect = dataHarmrateVDTOList.stream().flatMap(temp -> DataHarmrateV.relationToInfluxDB(temp).stream()).collect(Collectors.toList()); - int minSize = Math.min(1200000, collect.size()); - List> partition = ListUtils.partition(collect, minSize); + List> partition = ListUtils.partition(collect, 20000); for (List dataHarmrateVList : partition) { List sublistAsOriginalListType = new ArrayList<>(dataHarmrateVList); diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmphasicIImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmphasicIImpl.java index 741437e..b42d322 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmphasicIImpl.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmphasicIImpl.java @@ -66,9 +66,8 @@ public class InfluxdbDataHarmphasicIImpl extends MppServiceImpl collect = dataHarmphasicIDTOList.stream().flatMap(temp -> DataHarmphasicI.relationToInfluxDB(temp).stream()).collect(Collectors.toList()); - int minSize = Math.min(1200000, collect.size()); - List> partition = ListUtils.partition(collect, minSize); + List> partition = ListUtils.partition(collect, 20000); for (List dataHarmphasicIList : partition) { List sublistAsOriginalListType = new ArrayList<>(dataHarmphasicIList); dataHarmphasicIMapper.insertBatch(sublistAsOriginalListType); diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmphasicVImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmphasicVImpl.java index 456c44d..5d9e2d0 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmphasicVImpl.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmphasicVImpl.java @@ -70,9 +70,8 @@ public class InfluxdbDataHarmphasicVImpl extends MppServiceImpl collect = dataHarmphasicVDTOList.stream().flatMap(temp -> DataHarmphasicV.relationToInfluxDB(temp).stream()).collect(Collectors.toList()); - int minSize = Math.min(1200000, collect.size()); - List> partition = ListUtils.partition(collect, minSize); + List> partition = ListUtils.partition(collect, 20000); for (List dataHarmphasicVList : partition) { List sublistAsOriginalListType = new ArrayList<>(dataHarmphasicVList); diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmpowerPImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmpowerPImpl.java index c0dc068..9eb19ed 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmpowerPImpl.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmpowerPImpl.java @@ -70,9 +70,8 @@ public class InfluxdbDataHarmpowerPImpl extends MppServiceImpl collect = dataHarmpowerPDTOList.stream().flatMap(temp -> DataHarmpowerP.relationToInfluxDB(temp).stream()).collect(Collectors.toList()); - int minSize = Math.min(1200000, collect.size()); - List> partition = ListUtils.partition(collect, minSize); + List> partition = ListUtils.partition(collect, 20000); for (List dataHarmpowerPList : partition) { List sublistAsOriginalListType = new ArrayList<>(dataHarmpowerPList); diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmpowerQImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmpowerQImpl.java index a59d3d9..f7c9c97 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmpowerQImpl.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmpowerQImpl.java @@ -66,9 +66,8 @@ public class InfluxdbDataHarmpowerQImpl extends MppServiceImpl collect = dataHarmpowerQDTOList.stream().flatMap(temp -> DataHarmpowerQ.relationToInfluxDB(temp).stream()).collect(Collectors.toList()); - int minSize = Math.min(1200000, collect.size()); - List> partition = ListUtils.partition(collect, minSize); + List> partition = ListUtils.partition(collect, 20000); for (List dataHarmpowerQList : partition) { List sublistAsOriginalListType = new ArrayList<>(dataHarmpowerQList); diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmpowerSImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmpowerSImpl.java index 2c4707d..0feac68 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmpowerSImpl.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmpowerSImpl.java @@ -66,9 +66,8 @@ public class InfluxdbDataHarmpowerSImpl extends MppServiceImpl collect = dataHarmpowerSDTOList.stream().flatMap(temp -> DataHarmpowerS.relationToInfluxDB(temp).stream()).collect(Collectors.toList()); - int minSize = Math.min(1200000, collect.size()); - List> partition = ListUtils.partition(collect, minSize); + List> partition = ListUtils.partition(collect, 20000); for (List dataHarmpowerSList : partition) { List sublistAsOriginalListType = new ArrayList<>(dataHarmpowerSList); diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataIImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataIImpl.java index bae4b58..e1dd2e9 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataIImpl.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataIImpl.java @@ -69,9 +69,8 @@ public class InfluxdbDataIImpl extends MppServiceImpl collect = dataIDTOList.stream().flatMap(temp -> DataI.relationToInfluxDB(temp).stream()).collect(Collectors.toList()); - int minSize = Math.min(1200000, collect.size()); - List> partition = ListUtils.partition(collect, minSize); + List> partition = ListUtils.partition(collect, 20000); for (List dataIList : partition) { List sublistAsOriginalListType = new ArrayList<>(dataIList); diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataInharmIImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataInharmIImpl.java index 87c5b15..42d3b40 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataInharmIImpl.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataInharmIImpl.java @@ -67,7 +67,7 @@ public class InfluxdbDataInharmIImpl extends MppServiceImpl collect = dataInharmIDTOList.stream().flatMap(temp -> DataInharmI.relationToInfluxDB(temp).stream()).collect(Collectors.toList()); int minSize = Math.min(1200000, collect.size()); - List> partition = ListUtils.partition(collect, minSize); + List> partition = ListUtils.partition(collect, 20000); for (List dataInharmIList : partition) { List sublistAsOriginalListType = new ArrayList<>(dataInharmIList); diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataInharmVImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataInharmVImpl.java index a7e0e3a..1eaa67c 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataInharmVImpl.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataInharmVImpl.java @@ -68,9 +68,8 @@ public class InfluxdbDataInharmVImpl extends MppServiceImpl collect = dataInharmVDTOList.stream().flatMap(temp -> DataInharmV.relationToInfluxDB(temp).stream()).collect(Collectors.toList()); - int minSize = Math.min(1200000, collect.size()); - List> partition = ListUtils.partition(collect, minSize); + List> partition = ListUtils.partition(collect, 20000); for (List dataInharmVList : partition) { List sublistAsOriginalListType = new ArrayList<>(dataInharmVList); diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataPltImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataPltImpl.java index a8e0423..848eac7 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataPltImpl.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataPltImpl.java @@ -66,9 +66,8 @@ public class InfluxdbDataPltImpl extends MppServiceImpl collect = dataPltDTOList.stream().map(temp -> DataPlt.relationToInfluxDB(temp)).collect(Collectors.toList()); - int minSize = Math.min(1200000, collect.size()); - List> partition = ListUtils.partition(collect, minSize); + List> partition = ListUtils.partition(collect, 20000); for (List dataPltList : partition) { List sublistAsOriginalListType = new ArrayList<>(dataPltList); diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataVImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataVImpl.java index 2cf3a23..48cbc1b 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataVImpl.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataVImpl.java @@ -111,9 +111,8 @@ public class InfluxdbDataVImpl extends MppServiceImpl collect = dataVDTOList.stream().flatMap(temp -> DataV.relationToInfluxDB(temp).stream()).collect(Collectors.toList()); - int minSize = Math.min(1200000, collect.size()); - List> partition = ListUtils.partition(collect, minSize); + List> partition = ListUtils.partition(collect, 20000); for (List dataVList : partition) { List sublistAsOriginalListType = new ArrayList<>(dataVList); @@ -370,12 +369,10 @@ public class InfluxdbDataVImpl extends MppServiceImpl> partition = ListUtils.partition(collect, minSize); + List> partition = ListUtils.partition(collect, 20000); for (List dataVList : partition) { List sublistAsOriginalListType = new ArrayList<>(dataVList); - dataVMapper.insertBatch(sublistAsOriginalListType); }