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

fix(influx): 修正查询条件中的值类型并添加SQL调试输出

Browse Source 
- 将VALUE_TYPE从"avg"改为"AVG"以匹配数据库中的实际数据格式
- 添加SQL语句打印用于调试目的
- 保持其他查询条件不变包括时间范围、生产线ID和工艺参数
This commit is contained in:
xy
2026-07-03 09:31:53 +08:00
parent e4187f8a59
commit 9d393c5076
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -209,9 +209,10 @@ public class CommonServiceImpl implements CommonService {
.select("Apf_Temp_Env","minValue") .select("Apf_Temp_Env","minValue")
.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.VALUE_TYPE,"avg") .eq(InfluxDBTableConstant.VALUE_TYPE,"AVG")
.eq(InfluxDBTableConstant.PROCESS,param.getProcess()) .eq(InfluxDBTableConstant.PROCESS,param.getProcess())
.eq(InfluxDBTableConstant.CL_DID,param.getClDid()); .eq(InfluxDBTableConstant.CL_DID,param.getClDid());
System.out.println("sql===:" + influxQueryWrapper.generateSql());
return commonMapper.getDeviceRtDataByTime(influxQueryWrapper); return commonMapper.getDeviceRtDataByTime(influxQueryWrapper);
} }