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();