公共查询方法新增谐波次数标识
This commit is contained in:
@@ -20,5 +20,5 @@ public class CommonQueryParam {
|
|||||||
private String dataType;
|
private String dataType;
|
||||||
private String process;
|
private String process;
|
||||||
private String clDid;
|
private String clDid;
|
||||||
|
private String frequency;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -36,6 +36,10 @@ public class StatisticalDataDTO {
|
|||||||
private String clDid;
|
private String clDid;
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 谐波次数
|
||||||
|
*/
|
||||||
|
private String frequency;
|
||||||
/**
|
/**
|
||||||
* 指标值
|
* 指标值
|
||||||
*/
|
*/
|
||||||
|
|||||||
@@ -108,6 +108,9 @@ public class CommonServiceImpl implements CommonService {
|
|||||||
influxQueryWrapper.eq(InfluxDBTableConstant.CL_DID, commonQueryParam.getClDid());
|
influxQueryWrapper.eq(InfluxDBTableConstant.CL_DID, commonQueryParam.getClDid());
|
||||||
}
|
}
|
||||||
List<StatisticalDataDTO> deviceRtData = commonMapper.getDeviceRtDataByTime(influxQueryWrapper);
|
List<StatisticalDataDTO> deviceRtData = commonMapper.getDeviceRtDataByTime(influxQueryWrapper);
|
||||||
|
for(StatisticalDataDTO statisticalDataDTO : deviceRtData){
|
||||||
|
statisticalDataDTO.setFrequency(commonQueryParam.getFrequency());
|
||||||
|
}
|
||||||
resultList.addAll(deviceRtData);
|
resultList.addAll(deviceRtData);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user