diff --git a/src/main/java/com/njcn/influx/pojo/po/cs/EntData.java b/src/main/java/com/njcn/influx/pojo/po/cs/EntData.java index 11c8710..d24a0a4 100644 --- a/src/main/java/com/njcn/influx/pojo/po/cs/EntData.java +++ b/src/main/java/com/njcn/influx/pojo/po/cs/EntData.java @@ -33,25 +33,25 @@ public class EntData { private String evtParamPosition; @Column(name = "Evt_Param_Con") - private Float evtParamCon; + private Double evtParamCon; @Column(name = "Evt_Param_Flk") - private Float evtParamFlk; + private Double evtParamFlk; @Column(name = "Evt_Param_Freq") - private Float evtParamFreq; + private Double evtParamFreq; @Column(name = "Evt_Param_ImbNg") - private Float evtParamImbNg; + private Double evtParamImbNg; @Column(name = "Evt_Param_Thd") - private Float evtParamThd; + private Double evtParamThd; @Column(name = "Evt_Param_Tm") - private Float evtParamTm; + private Double evtParamTm; @Column(name = "Evt_Param_VVaDepth") - private Float evtParamVVaDepth; + private Double evtParamVVaDepth; 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 306572d..dca3e38 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 @@ -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.io.Serializable; import java.time.Instant; @@ -18,6 +19,7 @@ import java.time.Instant; @Measurement(name = "pqd_data") public class PqdData implements Serializable { + @TimeColumn @Column(name = "time",tag = true) @JsonSerialize(using = InstantDateSerializer.class) private Instant time;