From 660b4d49c08f8db83b31fb92d7301c5fc613f21e Mon Sep 17 00:00:00 2001 From: wr <1754607820@qq.com> Date: Thu, 31 Jul 2025 16:57:29 +0800 Subject: [PATCH] =?UTF-8?q?1.=E6=B1=A1=E6=9F=93=E5=80=BC=E7=AE=97=E6=B3=95?= =?UTF-8?q?=E5=BE=AE=E8=B0=83?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/influxdb/InfluxdbDataIImpl.java | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) 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 64acbae..c7363f0 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 @@ -206,14 +206,14 @@ public class InfluxdbDataIImpl extends MppServiceImpl getGroupByTimeDataI(LineCountEvaluateParam lineParam) { - InfluxQueryWrapper harmRateVQueryWrapper = new InfluxQueryWrapper(DataHarmrateV.class); - harmRateVQueryWrapper.maxSamePrefixAndSuffix(InfluxDbSqlConstant.I, "", HarmonicTimesUtil.harmonicTimesList(2, 50, 1)); - harmRateVQueryWrapper.regular(DataV::getLineId, lineParam.getLineId()) - .eq(DataHarmrateV::getValueType, InfluxDbSqlConstant.CP95) - .ne(DataHarmrateV::getPhasicType, InfluxDBTableConstant.PHASE_TYPE_T) + InfluxQueryWrapper influxQueryWrapper = new InfluxQueryWrapper(DataI.class); + influxQueryWrapper.maxSamePrefixAndSuffix(InfluxDbSqlConstant.I, "", HarmonicTimesUtil.harmonicTimesList(2, 50, 1)); + influxQueryWrapper.regular(DataI::getLineId, lineParam.getLineId()) + .eq(DataI::getValueType, InfluxDbSqlConstant.CP95) + .ne(DataI::getPhasicType, InfluxDBTableConstant.PHASE_TYPE_T) .groupBy("time(" + lineParam.getValueType().get(0) + "m)") - .between(DataHarmrateV::getTime, lineParam.getStartTime(), lineParam.getEndTime()); - List list = dataIMapper.selectByQueryWrapper(harmRateVQueryWrapper); + .between(DataI::getTime, lineParam.getStartTime(), lineParam.getEndTime()); + List list = dataIMapper.selectByQueryWrapper(influxQueryWrapper); List result = new ArrayList<>(); list.forEach(item -> { DataIDto dto = new DataIDto();