Middleware/pqs-influx
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(influx): 修正相位类型和值类型查询条件

Browse Source 
- 将 PHASIC_TYPE 从 "M" 修改为 "T"
- 将 VALUE_TYPE 从 "avg" 修改为 "AVG"
- 统一查询条件的数据类型匹配规则
This commit is contained in:
xy
2026-05-21 15:54:52 +08:00
parent df01e39a58
commit 30492cffa1
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/com/njcn/influx/service/impl/CommonServiceImpl.java
View File

@@ -145,7 +145,7 @@ public class CommonServiceImpl implements CommonService {
.select(StatisticalDataDTO::getClDid) .select(StatisticalDataDTO::getClDid)
.last(columnName,InfluxDBTableConstant.VALUE) .last(columnName,InfluxDBTableConstant.VALUE)
.eq(InfluxDBTableConstant.LINE_ID,lineId) .eq(InfluxDBTableConstant.LINE_ID,lineId)
.eq(InfluxDBTableConstant.PHASIC_TYPE, "M") .eq(InfluxDBTableConstant.PHASIC_TYPE, "T")
.eq(InfluxDBTableConstant.PROCESS,process) .eq(InfluxDBTableConstant.PROCESS,process)
.groupBy(InfluxDBTableConstant.CL_DID); .groupBy(InfluxDBTableConstant.CL_DID);
return commonMapper.getTopTemperature(influxQueryWrapper); return commonMapper.getTopTemperature(influxQueryWrapper);
@@ -171,8 +171,8 @@ public class CommonServiceImpl implements CommonService {
influxQueryWrapper.select(param.getColumnName(),param.getResultName()) influxQueryWrapper.select(param.getColumnName(),param.getResultName())
.between(InfluxDBTableConstant.TIME, param.getStartTime(), param.getEndTime()) .between(InfluxDBTableConstant.TIME, param.getStartTime(), param.getEndTime())
.eq(InfluxDBTableConstant.LINE_ID,param.getLineId()) .eq(InfluxDBTableConstant.LINE_ID,param.getLineId())
.eq(InfluxDBTableConstant.PHASIC_TYPE, "M") .eq(InfluxDBTableConstant.PHASIC_TYPE, "T")
.eq(InfluxDBTableConstant.VALUE_TYPE,"avg") .eq(InfluxDBTableConstant.VALUE_TYPE,"AVG")
.eq(param.getDataType(),0) .eq(param.getDataType(),0)
.eq(InfluxDBTableConstant.PROCESS,param.getProcess()) .eq(InfluxDBTableConstant.PROCESS,param.getProcess())
.eq(InfluxDBTableConstant.CL_DID,param.getClDid()); .eq(InfluxDBTableConstant.CL_DID,param.getClDid());