提交

pqs-influx/src/main/java/com/njcn/influx/pojo/constant/InfluxDBTableConstant.java

@@ -120,6 +120,11 @@ public interface InfluxDBTableConstant {
      */
     String MIN_VALUE = "minValue";
 
+    /**
+     * 统计结果平均值
+     */
+    String AVG_VALUE = "avgValue";
+
     /**
      * 数据质量标志
      */

pqs-influx/src/main/java/com/njcn/influx/pojo/dto/StatisticalDataDTO.java

@@ -61,5 +61,10 @@ public class StatisticalDataDTO {
      */
     private Double minValue;
 
+    /**
+     * 指标平均值
+     */
+    private Double avgValue;
+
 
 }

pqs-influx/src/main/java/com/njcn/influx/service/impl/CommonServiceImpl.java

@@ -96,6 +96,7 @@ public class CommonServiceImpl implements CommonService {
         InfluxQueryWrapper influxQueryWrapper = new InfluxQueryWrapper(getTableNameByClassId(tableName),StatisticalDataDTO.class);
         influxQueryWrapper.max(columnName,InfluxDBTableConstant.MAX_VALUE)
                 .min(columnName,InfluxDBTableConstant.MIN_VALUE)
+                .mean(columnName)
                 .eq(InfluxDBTableConstant.LINE_ID,lineId)
                 .eq(InfluxDBTableConstant.CL_DID,clDid)
                 .between(InfluxDBTableConstant.TIME, startTime, endTime);