diff --git a/src/main/java/com/njcn/influx/pojo/po/DataFlicker.java b/src/main/java/com/njcn/influx/pojo/po/DataFlicker.java
index 5bb6008..fd9cf91 100644
--- a/src/main/java/com/njcn/influx/pojo/po/DataFlicker.java
+++ b/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;
 }
diff --git a/src/main/java/com/njcn/influx/pojo/po/DataFluc.java b/src/main/java/com/njcn/influx/pojo/po/DataFluc.java
index 8831447..44b1ebc 100644
--- a/src/main/java/com/njcn/influx/pojo/po/DataFluc.java
+++ b/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;
 }
diff --git a/src/main/java/com/njcn/influx/pojo/po/DataHarmPhasicI.java b/src/main/java/com/njcn/influx/pojo/po/DataHarmPhasicI.java
index b6070d4..d8371b4 100644
--- a/src/main/java/com/njcn/influx/pojo/po/DataHarmPhasicI.java
+++ b/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;
 }
diff --git a/src/main/java/com/njcn/influx/pojo/po/DataHarmPhasicV.java b/src/main/java/com/njcn/influx/pojo/po/DataHarmPhasicV.java
index 05f6165..b151691 100644
--- a/src/main/java/com/njcn/influx/pojo/po/DataHarmPhasicV.java
+++ b/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;
 }
diff --git a/src/main/java/com/njcn/influx/pojo/po/DataHarmPowerP.java b/src/main/java/com/njcn/influx/pojo/po/DataHarmPowerP.java
index 078eb5c..7458b6f 100644
--- a/src/main/java/com/njcn/influx/pojo/po/DataHarmPowerP.java
+++ b/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;
 }
diff --git a/src/main/java/com/njcn/influx/pojo/po/DataHarmPowerQ.java b/src/main/java/com/njcn/influx/pojo/po/DataHarmPowerQ.java
index fd3b270..1b2f1e7 100644
--- a/src/main/java/com/njcn/influx/pojo/po/DataHarmPowerQ.java
+++ b/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;
+
 }
diff --git a/src/main/java/com/njcn/influx/pojo/po/DataHarmPowerS.java b/src/main/java/com/njcn/influx/pojo/po/DataHarmPowerS.java
index 904d3dc..c6b738a 100644
--- a/src/main/java/com/njcn/influx/pojo/po/DataHarmPowerS.java
+++ b/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;
+
 }
diff --git a/src/main/java/com/njcn/influx/pojo/po/DataHarmRateV.java b/src/main/java/com/njcn/influx/pojo/po/DataHarmRateV.java
index 4eed999..3777544 100644
--- a/src/main/java/com/njcn/influx/pojo/po/DataHarmRateV.java
+++ b/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;
 }
diff --git a/src/main/java/com/njcn/influx/pojo/po/DataI.java b/src/main/java/com/njcn/influx/pojo/po/DataI.java
index 83a2782..a0034dc 100644
--- a/src/main/java/com/njcn/influx/pojo/po/DataI.java
+++ b/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;
+
 }
diff --git a/src/main/java/com/njcn/influx/pojo/po/DataInHarmRateI.java b/src/main/java/com/njcn/influx/pojo/po/DataInHarmRateI.java
index 472473f..5d694eb 100644
--- a/src/main/java/com/njcn/influx/pojo/po/DataInHarmRateI.java
+++ b/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;
+
 }
diff --git a/src/main/java/com/njcn/influx/pojo/po/DataInHarmRateV.java b/src/main/java/com/njcn/influx/pojo/po/DataInHarmRateV.java
index 8ffc45d..39355cb 100644
--- a/src/main/java/com/njcn/influx/pojo/po/DataInHarmRateV.java
+++ b/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;
+
 }
diff --git a/src/main/java/com/njcn/influx/pojo/po/DataInHarmV.java b/src/main/java/com/njcn/influx/pojo/po/DataInHarmV.java
index 726c0d9..61e8768 100644
--- a/src/main/java/com/njcn/influx/pojo/po/DataInHarmV.java
+++ b/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;
 }
diff --git a/src/main/java/com/njcn/influx/pojo/po/DataPlt.java b/src/main/java/com/njcn/influx/pojo/po/DataPlt.java
index f0acd33..d33af69 100644
--- a/src/main/java/com/njcn/influx/pojo/po/DataPlt.java
+++ b/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;
+
 }
diff --git a/src/main/java/com/njcn/influx/pojo/po/DataV.java b/src/main/java/com/njcn/influx/pojo/po/DataV.java
index 90ae044..324e861 100644
--- a/src/main/java/com/njcn/influx/pojo/po/DataV.java
+++ b/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;
 }
diff --git a/src/main/java/com/njcn/influx/pojo/po/cs/PqdData.java b/src/main/java/com/njcn/influx/pojo/po/cs/PqdData.java
index dca3e38..5e5a767 100644
--- a/src/main/java/com/njcn/influx/pojo/po/cs/PqdData.java
+++ b/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;