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