添加异常标志字段，修改规范字段名,类名

pom.xml

@@ -10,6 +10,7 @@
     </parent>
     <groupId>com.njcn</groupId>
     <artifactId>pqs-influx</artifactId>
+    <version>1.0.0</version>
     <name>influx公共模块</name>
     <description>pqs-influx</description>
 

src/main/java/com/njcn/influx/imapper/DataIMapper.java

@@ -14,7 +14,7 @@ import java.util.List;
  * @version 1.0.0
  * @date 2023年07月17日 11:05
  */
-public interface IDataIMapper extends InfluxDbBaseMapper<DataI> {
+public interface DataIMapper extends InfluxDbBaseMapper<DataI> {
 
     DataI getMeanAllTimesData(InfluxQueryWrapper influxQueryWrapper);
 

src/main/java/com/njcn/influx/pojo/po/DataFlicker.java

@@ -55,5 +55,7 @@ public class DataFlicker {
 
     @Column(name = "plt_count")
     private Integer pltCount;
-
+    //是否是异常指标数据，0否1是
+    @Column(name = "abnormal_flag")
+    private Integer abnormalFlag;
 }

src/main/java/com/njcn/influx/pojo/po/DataFluc.java

@@ -39,5 +39,7 @@ public class DataFluc {
 
     @Column(name = "value_type",tag = true)
     private String valueType;
-
+    //是否是异常指标数据，0否1是
+    @Column(name = "abnormal_flag")
+    private Integer abnormalFlag;
 }

src/main/java/com/njcn/influx/pojo/po/DataHarmPhasicI.java

@@ -183,5 +183,7 @@ public class DataHarmPhasicI {
 
     @Column(name = "i_50")
     private Double i50;
-
+    //是否是异常指标数据，0否1是
+    @Column(name = "abnormal_flag")
+    private Integer abnormalFlag;
 }

src/main/java/com/njcn/influx/pojo/po/DataHarmPhasicV.java

@@ -186,5 +186,7 @@ public class DataHarmPhasicV {
 
     @Column(name = "v_50")
     private Double v50;
-
+    //是否是异常指标数据，0否1是
+    @Column(name = "abnormal_flag")
+    private Integer abnormalFlag;
 }

src/main/java/com/njcn/influx/pojo/po/DataHarmPowerP.java

@@ -193,4 +193,8 @@ public class DataHarmPowerP {
 
     @Column(name = "p_50")
     private Double p50;
+
+    //是否是异常指标数据，0否1是
+    @Column(name = "abnormal_flag")
+    private Integer abnormalFlag;
 }

src/main/java/com/njcn/influx/pojo/po/DataHarmPowerQ.java

@@ -189,4 +189,8 @@ public class DataHarmPowerQ {
     @Column(name = "q_50")
     private Double q50;
 
+    //是否是异常指标数据，0否1是
+    @Column(name = "abnormal_flag")
+    private Integer abnormalFlag;
+
 }

src/main/java/com/njcn/influx/pojo/po/DataHarmPowerS.java

@@ -188,4 +188,8 @@ public class DataHarmPowerS {
     @Column(name = "s_50")
     private Double s50;
 
+    //是否是异常指标数据，0否1是
+    @Column(name = "abnormal_flag")
+    private Integer abnormalFlag;
+
 }

src/main/java/com/njcn/influx/pojo/po/DataI.java

@@ -205,4 +205,8 @@ public class DataI {
     @Column(name = "i_50")
     private Double i50;
 
+    //是否是异常指标数据，0否1是
+    @Column(name = "abnormal_flag")
+    private Integer abnormalFlag;
+
 }

src/main/java/com/njcn/influx/pojo/po/DataInHarmRateI.java

@@ -181,5 +181,8 @@ public class DataInHarmRateI {
 
     @Column(name = "i_50")
     private Double i50;
+    //是否是异常指标数据，0否1是
+    @Column(name = "abnormal_flag")
+    private Integer abnormalFlag;
 
 }

src/main/java/com/njcn/influx/pojo/po/DataInHarmRateV.java

@@ -187,4 +187,8 @@ public class DataInHarmRateV {
     @Column(name = "v_50")
     private Double v50;
 
+    //是否是异常指标数据，0否1是
+    @Column(name = "abnormal_flag")
+    private Integer abnormalFlag;
+
 }

src/main/java/com/njcn/influx/pojo/po/DataInHarmV.java

@@ -186,5 +186,7 @@ public class DataInHarmV {
 
     @Column(name = "v_50")
     private Double v50;
-
+    //是否是异常指标数据，0否1是
+    @Column(name = "abnormal_flag")
+    private Integer abnormalFlag;
 }

src/main/java/com/njcn/influx/pojo/po/DataPlt.java

@@ -47,5 +47,8 @@ public class DataPlt {
     //自定义字段
     @Column(name = "mean")
     private Double mean;
+    //是否是异常指标数据，0否1是
+    @Column(name = "abnormal_flag")
+    private Integer abnormalFlag;
 
 }

src/main/java/com/njcn/influx/pojo/po/DataV.java

@@ -215,7 +215,7 @@ public class DataV {
     private String lineId;
 
     @Column(name = "phasic_type", tag = true)
-    private String phasicType;
+    private String phaseType;
 
     @Column(name = "value_type", tag = true)
     private String valueType;
@@ -232,4 +232,7 @@ public class DataV {
     //自定义字段
     @Column(name = "count")
     private Integer count;
+    //是否是异常指标数据，0否1是
+    @Column(name = "abnormal_flag")
+    private Integer abnormalFlag;
 }

src/main/java/com/njcn/influx/service/impl/DataVServiceImpl.java

@@ -42,7 +42,7 @@ public class DataVServiceImpl implements IDataVService {
                 .min(DataV::getVZero)
                 .min(DataV::getVlDev)
                 .min(DataV::getVuDev)
-                .groupBy(DataV::getLineId,DataV::getPhasicType,DataV::getQualityFlag,DataV::getValueType)
+                .groupBy(DataV::getLineId,DataV::getPhaseType,DataV::getQualityFlag,DataV::getValueType)
                 .between(DataV::getTime, startTime, endTime);
         result1 = dataVMapper.getStatisticsByWraper(influxQueryWrapper);
         System.out.println("result1==:" + result1);
@@ -55,7 +55,7 @@ public class DataVServiceImpl implements IDataVService {
         InfluxQueryWrapper influxQueryWrapper = new InfluxQueryWrapper(DataV.class);
         influxQueryWrapper.eq(DataV::getLineId, lineIndex)
                 .eq(DataV::getValueType, "CP95")
-                .ne(DataV::getPhasicType, "T")
+                .ne(DataV::getPhaseType, "T")
                 .between(DataV::getTime, startTime, endTime);;
         result1 = dataVMapper.getStatisticsByWraper(influxQueryWrapper);
         return result1;

src/main/java/com/njcn/influx/service/impl/IDataIServiceImpl.java

@@ -1,6 +1,6 @@
 package com.njcn.influx.service.impl;
 
-import com.njcn.influx.imapper.IDataIMapper;
+import com.njcn.influx.imapper.DataIMapper;
 import com.njcn.influx.pojo.po.DataI;
 import com.njcn.influx.query.InfluxQueryWrapper;
 import com.njcn.influx.service.IDataIService;
@@ -18,7 +18,7 @@ import java.util.List;
 @RequiredArgsConstructor
 public class IDataIServiceImpl implements IDataIService {
 
-    private final IDataIMapper dataIMapper;
+    private final DataIMapper dataIMapper;
 
     @Override
     public DataI getMeanAllTimesData(InfluxQueryWrapper influxQueryWrapper) {