feat(influx): 添加数据实体类的时间列注解和新字段

- 为多个数据实体类添加 @TimeColumn 注解以标识时间列
- 在多个数据实体类中新增 cl_did 和 process 字段
- 为 PqdData 类添加 quality_flag 字段作为标签
- 更新 DataInHarmRateI 类的时间序列化配置
- 统一数据实体类中的异常标志字段定义

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

@@ -58,4 +58,10 @@ public class DataFlicker {
     //是否是异常指标数据，0否1是
     @Column(name = "abnormal_flag")
     private Integer abnormalFlag;
+
+    @Column(name = "cl_did")
+    private String clDid;
+
+    @Column(name = "process")
+    private String process;
 }

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

@@ -5,6 +5,7 @@ import com.njcn.influx.utils.InstantDateSerializer;
 import lombok.Data;
 import org.influxdb.annotation.Column;
 import org.influxdb.annotation.Measurement;
+import org.influxdb.annotation.TimeColumn;
 
 import java.time.Instant;
 
@@ -18,6 +19,7 @@ import java.time.Instant;
 @Measurement(name = "data_fluc")
 public class DataFluc {
 
+    @TimeColumn
     @Column(name = "time")
     @JsonSerialize(using = InstantDateSerializer.class)
     private Instant time;
@@ -39,7 +41,14 @@ public class DataFluc {
 
     @Column(name = "value_type",tag = true)
     private String valueType;
+
     //是否是异常指标数据，0否1是
     @Column(name = "abnormal_flag")
     private Integer abnormalFlag;
+
+    @Column(name = "cl_did")
+    private String clDid;
+
+    @Column(name = "process")
+    private String process;
 }

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

@@ -5,6 +5,7 @@ import com.njcn.influx.utils.InstantDateSerializer;
 import lombok.Data;
 import org.influxdb.annotation.Column;
 import org.influxdb.annotation.Measurement;
+import org.influxdb.annotation.TimeColumn;
 
 import java.time.Instant;
 
@@ -18,6 +19,7 @@ import java.time.Instant;
 @Measurement(name = "data_harmphasic_i")
 public class DataHarmPhasicI {
 
+    @TimeColumn
     @Column(name = "time")
     @JsonSerialize(using = InstantDateSerializer.class)
     private Instant time;
@@ -186,4 +188,10 @@ public class DataHarmPhasicI {
     //是否是异常指标数据，0否1是
     @Column(name = "abnormal_flag")
     private Integer abnormalFlag;
+
+    @Column(name = "cl_did")
+    private String clDid;
+
+    @Column(name = "process")
+    private String process;
 }

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

@@ -189,4 +189,10 @@ public class DataHarmPhasicV {
     //是否是异常指标数据，0否1是
     @Column(name = "abnormal_flag")
     private Integer abnormalFlag;
+
+    @Column(name = "cl_did")
+    private String clDid;
+
+    @Column(name = "process")
+    private String process;
 }

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

@@ -199,4 +199,10 @@ public class DataHarmPowerP {
     //是否是异常指标数据，0否1是
     @Column(name = "abnormal_flag")
     private Integer abnormalFlag;
+
+    @Column(name = "cl_did")
+    private String clDid;
+
+    @Column(name = "process")
+    private String process;
 }

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

@@ -5,6 +5,7 @@ import com.njcn.influx.utils.InstantDateSerializer;
 import lombok.Data;
 import org.influxdb.annotation.Column;
 import org.influxdb.annotation.Measurement;
+import org.influxdb.annotation.TimeColumn;
 
 import java.time.Instant;
 
@@ -19,6 +20,7 @@ import java.time.Instant;
 @Measurement(name = "data_harmpower_q")
 public class DataHarmPowerQ {
 
+    @TimeColumn
     @Column(name = "time")
     @JsonSerialize(using = InstantDateSerializer.class)
     private Instant time;
@@ -193,4 +195,10 @@ public class DataHarmPowerQ {
     @Column(name = "abnormal_flag")
     private Integer abnormalFlag;
 
+    @Column(name = "cl_did")
+    private String clDid;
+
+    @Column(name = "process")
+    private String process;
+
 }

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

@@ -5,6 +5,7 @@ import com.njcn.influx.utils.InstantDateSerializer;
 import lombok.Data;
 import org.influxdb.annotation.Column;
 import org.influxdb.annotation.Measurement;
+import org.influxdb.annotation.TimeColumn;
 
 import java.time.Instant;
 
@@ -19,6 +20,7 @@ import java.time.Instant;
 @Measurement(name = "data_harmpower_s")
 public class DataHarmPowerS {
 
+    @TimeColumn
     @Column(name = "time")
     @JsonSerialize(using = InstantDateSerializer.class)
     private Instant time;
@@ -192,4 +194,10 @@ public class DataHarmPowerS {
     @Column(name = "abnormal_flag")
     private Integer abnormalFlag;
 
+    @Column(name = "cl_did")
+    private String clDid;
+
+    @Column(name = "process")
+    private String process;
+
 }

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

@@ -189,4 +189,10 @@ public class DataHarmRateV{
     //是否是异常指标数据，0否1是
     @Column(name = "abnormal_flag")
     private Integer abnormalFlag;
+
+    @Column(name = "cl_did")
+    private String clDid;
+
+    @Column(name = "process")
+    private String process;
 }

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

@@ -209,4 +209,10 @@ public class DataI {
     @Column(name = "abnormal_flag")
     private Integer abnormalFlag;
 
+    @Column(name = "cl_did")
+    private String clDid;
+
+    @Column(name = "process")
+    private String process;
+
 }

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

@@ -1,8 +1,11 @@
 package com.njcn.influx.pojo.po;
 
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.njcn.influx.utils.InstantDateSerializer;
 import lombok.Data;
 import org.influxdb.annotation.Column;
 import org.influxdb.annotation.Measurement;
+import org.influxdb.annotation.TimeColumn;
 
 import java.time.Instant;
 
@@ -17,7 +20,9 @@ import java.time.Instant;
 @Measurement(name = "data_inharmrate_i")
 public class DataInHarmRateI {
 
+    @TimeColumn
     @Column(name = "time")
+    @JsonSerialize(using = InstantDateSerializer.class)
     private Instant time;
 
     @Column(name = "line_id",tag = true)
@@ -185,4 +190,10 @@ public class DataInHarmRateI {
     @Column(name = "abnormal_flag")
     private Integer abnormalFlag;
 
+    @Column(name = "cl_did")
+    private String clDid;
+
+    @Column(name = "process")
+    private String process;
+
 }

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

@@ -191,4 +191,10 @@ public class DataInHarmRateV {
     @Column(name = "abnormal_flag")
     private Integer abnormalFlag;
 
+    @Column(name = "cl_did")
+    private String clDid;
+
+    @Column(name = "process")
+    private String process;
+
 }

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

@@ -189,4 +189,10 @@ public class DataInHarmV {
     //是否是异常指标数据，0否1是
     @Column(name = "abnormal_flag")
     private Integer abnormalFlag;
+
+    @Column(name = "cl_did")
+    private String clDid;
+
+    @Column(name = "process")
+    private String process;
 }

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

@@ -51,4 +51,10 @@ public class DataPlt {
     @Column(name = "abnormal_flag")
     private Integer abnormalFlag;
 
+    @Column(name = "cl_did")
+    private String clDid;
+
+    @Column(name = "process")
+    private String process;
+
 }

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

@@ -232,7 +232,14 @@ public class DataV {
     //自定义字段
     @Column(name = "count")
     private Integer count;
+
     //是否是异常指标数据，0否1是
     @Column(name = "abnormal_flag")
     private Integer abnormalFlag;
+
+    @Column(name = "cl_did")
+    private String clDid;
+
+    @Column(name = "process")
+    private String process;
 }

src/main/java/com/njcn/influx/pojo/po/cs/PqdData.java

@@ -39,6 +39,9 @@ public class PqdData implements Serializable {
     @Column(name = "abnormal_flag")
     private Integer abnormalFlag;
 
+    @Column(name = "quality_flag",tag = true)
+    private String qualityFlag;
+
 
     @Column(name = "Pq_DF")
     private Double pq_DF;