From 30492cffa1c6215998e7382ed6e3e3e16918b613 Mon Sep 17 00:00:00 2001
From: xy <748613696@qq.com>
Date: Thu, 21 May 2026 15:54:52 +0800
Subject: [PATCH] =?UTF-8?q?fix(influx):=20=E4=BF=AE=E6=AD=A3=E7=9B=B8?=
 =?UTF-8?q?=E4=BD=8D=E7=B1=BB=E5=9E=8B=E5=92=8C=E5=80=BC=E7=B1=BB=E5=9E=8B?=
 =?UTF-8?q?=E6=9F=A5=E8=AF=A2=E6=9D=A1=E4=BB=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 将 PHASIC_TYPE 从 "M" 修改为 "T"
- 将 VALUE_TYPE 从 "avg" 修改为 "AVG"
- 统一查询条件的数据类型匹配规则
---
 .../com/njcn/influx/service/impl/CommonServiceImpl.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/njcn/influx/service/impl/CommonServiceImpl.java b/src/main/java/com/njcn/influx/service/impl/CommonServiceImpl.java
index ec1f810..4ea0e29 100644
--- a/src/main/java/com/njcn/influx/service/impl/CommonServiceImpl.java
+++ b/src/main/java/com/njcn/influx/service/impl/CommonServiceImpl.java
@@ -145,7 +145,7 @@ public class CommonServiceImpl implements CommonService {
                 .select(StatisticalDataDTO::getClDid)
                 .last(columnName,InfluxDBTableConstant.VALUE)
                 .eq(InfluxDBTableConstant.LINE_ID,lineId)
-                .eq(InfluxDBTableConstant.PHASIC_TYPE, "M")
+                .eq(InfluxDBTableConstant.PHASIC_TYPE, "T")
                 .eq(InfluxDBTableConstant.PROCESS,process)
                 .groupBy(InfluxDBTableConstant.CL_DID);
         return commonMapper.getTopTemperature(influxQueryWrapper);
@@ -171,8 +171,8 @@ public class CommonServiceImpl implements CommonService {
         influxQueryWrapper.select(param.getColumnName(),param.getResultName())
                 .between(InfluxDBTableConstant.TIME, param.getStartTime(), param.getEndTime())
                 .eq(InfluxDBTableConstant.LINE_ID,param.getLineId())
-                .eq(InfluxDBTableConstant.PHASIC_TYPE, "M")
-                .eq(InfluxDBTableConstant.VALUE_TYPE,"avg")
+                .eq(InfluxDBTableConstant.PHASIC_TYPE, "T")
+                .eq(InfluxDBTableConstant.VALUE_TYPE,"AVG")
                 .eq(param.getDataType(),0)
                 .eq(InfluxDBTableConstant.PROCESS,param.getProcess())
                 .eq(InfluxDBTableConstant.CL_DID,param.getClDid());