From b9fd8e9f952cf07b4adabda01b3503eccf210cb5 Mon Sep 17 00:00:00 2001 From: hzj <826100833@qq.com> Date: Mon, 3 Mar 2025 09:15:16 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E5=86=B2=E7=AA=81=E8=A1=A5?= =?UTF-8?q?=E5=85=851?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/njcn/dataProcess/service/IDataHarmrateV.java | 2 +- .../service/impl/influxdb/InfluxdbDataHarmrateVImpl.java | 2 ++ .../service/impl/relation/RelationDataHarmrateVImpl.java | 2 ++ 3 files changed, 5 insertions(+), 1 deletion(-) diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/IDataHarmrateV.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/IDataHarmrateV.java index 24e54bf..541cf47 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/IDataHarmrateV.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/IDataHarmrateV.java @@ -19,5 +19,5 @@ IDataHarmRateV { */ List getRawData(LineCountEvaluateParam lineParam); - void batchInsertion(List dataHarmrateVDTOList); + void batchInsertion (List dataHarmrateVDTOList); } 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 6a3603d..b97ff46 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 @@ -100,6 +100,8 @@ public class InfluxdbDataHarmRateVImpl implements IDataHarmRateV { + + @Override public void batchInsertion(List dataHarmrateVDTOList) { int totalCount = dataHarmrateVDTOList.size(); diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationDataHarmrateVImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationDataHarmrateVImpl.java index 75fd647..5250b1b 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationDataHarmrateVImpl.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationDataHarmrateVImpl.java @@ -35,6 +35,8 @@ public class RelationDataHarmRateVImpl implements IDataHarmRateV { return Collections.emptyList(); } + + @Override public void batchInsertion(List dataHarmrateVDTOList) { int totalCount = dataHarmrateVDTOList.size();