Microservice/pqs
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

influx部分实体添加tag

Browse Source
This commit is contained in:
hongawen
2024-01-24 15:08:55 +08:00
parent 4fbf73af40
commit 2c8b6fd0f5
7 changed files with 54 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
pqs-influx/src/main/java/com/njcn/influx/pojo/po/DataFlicker.java
View File

@@ -20,17 +20,17 @@ import java.time.Instant;
public class DataFlicker { public class DataFlicker {
@TimeColumn @TimeColumn
@Column(name = "time") @Column(name = "time", tag = true)
@JsonSerialize(using = InstantDateSerializer.class) @JsonSerialize(using = InstantDateSerializer.class)
private Instant time; private Instant time;
@Column(name = "fluc") @Column(name = "fluc")
private Double fluc; private Double fluc;
@Column(name = "line_id") @Column(name = "line_id", tag = true)
private String lineId; private String lineId;
@Column(name = "phasic_type") @Column(name = "phasic_type", tag = true)
private String phaseType; private String phaseType;
@Column(name = "plt") @Column(name = "plt")
@@ -39,7 +39,7 @@ public class DataFlicker {
@Column(name = "pst") @Column(name = "pst")
private Double pst; private Double pst;
@Column(name = "quality_flag") @Column(name = "quality_flag", tag = true)
private String qualityFlag; private String qualityFlag;

12
pqs-influx/src/main/java/com/njcn/influx/pojo/po/DataHarmPhasicV.java
View File

@@ -5,6 +5,7 @@ import com.njcn.influx.utils.InstantDateSerializer;
import lombok.Data; import lombok.Data;
import org.influxdb.annotation.Column; import org.influxdb.annotation.Column;
import org.influxdb.annotation.Measurement; import org.influxdb.annotation.Measurement;
import org.influxdb.annotation.TimeColumn;
import java.time.Instant; import java.time.Instant;
@@ -19,20 +20,21 @@ import java.time.Instant;
@Measurement(name = "data_harmphasic_v") @Measurement(name = "data_harmphasic_v")
public class DataHarmPhasicV { public class DataHarmPhasicV {
@Column(name = "time") @TimeColumn
@Column(name = "time", tag = true)
@JsonSerialize(using = InstantDateSerializer.class) @JsonSerialize(using = InstantDateSerializer.class)
private Instant time; private Instant time;
@Column(name = "line_id") @Column(name = "line_id", tag = true)
private String lineId; private String lineId;
@Column(name = "phasic_type") @Column(name = "phasic_type", tag = true)
private String phaseType; private String phaseType;
@Column(name = "quality_flag") @Column(name = "quality_flag", tag = true)
private String qualityFlag; private String qualityFlag;
@Column(name = "value_type") @Column(name = "value_type", tag = true)
private String valueType; private String valueType;
@Column(name = "v_1") @Column(name = "v_1")

12
pqs-influx/src/main/java/com/njcn/influx/pojo/po/DataI.java
View File

@@ -5,6 +5,7 @@ import com.njcn.influx.utils.InstantDateSerializer;
import lombok.Data; import lombok.Data;
import org.influxdb.annotation.Column; import org.influxdb.annotation.Column;
import org.influxdb.annotation.Measurement; import org.influxdb.annotation.Measurement;
import org.influxdb.annotation.TimeColumn;
import java.time.Instant; import java.time.Instant;
@@ -19,20 +20,21 @@ import java.time.Instant;
@Measurement(name = "data_i") @Measurement(name = "data_i")
public class DataI { public class DataI {
@Column(name = "time") @TimeColumn
@Column(name = "time", tag = true)
@JsonSerialize(using = InstantDateSerializer.class) @JsonSerialize(using = InstantDateSerializer.class)
private Instant time; private Instant time;
@Column(name = "line_id") @Column(name = "line_id", tag = true)
private String lineId; private String lineId;
@Column(name = "phasic_type") @Column(name = "phasic_type", tag = true)
private String phaseType; private String phaseType;
@Column(name = "quality_flag") @Column(name = "quality_flag", tag = true)
private String qualityFlag; private String qualityFlag;
@Column(name = "value_type") @Column(name = "value_type", tag = true)
private String valueType; private String valueType;
@Column(name = "i_neg") @Column(name = "i_neg")

15
pqs-influx/src/main/java/com/njcn/influx/pojo/po/DataInHarmRateV.java
View File

@@ -1,8 +1,11 @@
package com.njcn.influx.pojo.po; package com.njcn.influx.pojo.po;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import com.njcn.influx.utils.InstantDateSerializer;
import lombok.Data; import lombok.Data;
import org.influxdb.annotation.Column; import org.influxdb.annotation.Column;
import org.influxdb.annotation.Measurement; import org.influxdb.annotation.Measurement;
import org.influxdb.annotation.TimeColumn;
import java.time.Instant; import java.time.Instant;
@@ -17,19 +20,21 @@ import java.time.Instant;
@Measurement(name = "data_inharmrate_v") @Measurement(name = "data_inharmrate_v")
public class DataInHarmRateV { public class DataInHarmRateV {
@Column(name = "time") @Column(name = "time", tag = true)
@TimeColumn
@JsonSerialize(using = InstantDateSerializer.class)
private Instant time; private Instant time;
@Column(name = "line_id") @Column(name = "line_id", tag = true)
private String lineId; private String lineId;
@Column(name = "phasic_type") @Column(name = "phasic_type", tag = true)
private String phaseType; private String phaseType;
@Column(name = "quality_flag") @Column(name = "quality_flag", tag = true)
private String qualityFlag; private String qualityFlag;
@Column(name = "value_type") @Column(name = "value_type", tag = true)
private String valueType; private String valueType;
@Column(name = "v_1") @Column(name = "v_1")

15
pqs-influx/src/main/java/com/njcn/influx/pojo/po/DataInHarmV.java
View File

@@ -1,8 +1,11 @@
package com.njcn.influx.pojo.po; package com.njcn.influx.pojo.po;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import com.njcn.influx.utils.InstantDateSerializer;
import lombok.Data; import lombok.Data;
import org.influxdb.annotation.Column; import org.influxdb.annotation.Column;
import org.influxdb.annotation.Measurement; import org.influxdb.annotation.Measurement;
import org.influxdb.annotation.TimeColumn;
import java.time.Instant; import java.time.Instant;
@@ -17,19 +20,21 @@ import java.time.Instant;
@Measurement(name = "data_inharm_v") @Measurement(name = "data_inharm_v")
public class DataInHarmV { public class DataInHarmV {
@Column(name = "time") @Column(name = "time", tag = true)
@TimeColumn
@JsonSerialize(using = InstantDateSerializer.class)
private Instant time; private Instant time;
@Column(name = "line_id") @Column(name = "line_id", tag = true)
private String lineId; private String lineId;
@Column(name = "phasic_type") @Column(name = "phasic_type", tag = true)
private String phaseType; private String phaseType;
@Column(name = "quality_flag") @Column(name = "quality_flag", tag = true)
private String qualityFlag; private String qualityFlag;
@Column(name = "value_type") @Column(name = "value_type", tag = true)
private String valueType; private String valueType;
@Column(name = "v_1") @Column(name = "v_1")

12
pqs-influx/src/main/java/com/njcn/influx/pojo/po/DataPlt.java
View File

@@ -5,6 +5,7 @@ import com.njcn.influx.utils.InstantDateSerializer;
import lombok.Data; import lombok.Data;
import org.influxdb.annotation.Column; import org.influxdb.annotation.Column;
import org.influxdb.annotation.Measurement; import org.influxdb.annotation.Measurement;
import org.influxdb.annotation.TimeColumn;
import java.time.Instant; import java.time.Instant;
@@ -19,20 +20,21 @@ import java.time.Instant;
@Measurement(name = "data_plt") @Measurement(name = "data_plt")
public class DataPlt { public class DataPlt {
@Column(name = "time") @TimeColumn
@Column(name = "time", tag = true)
@JsonSerialize(using = InstantDateSerializer.class) @JsonSerialize(using = InstantDateSerializer.class)
private Instant time; private Instant time;
@Column(name = "line_id") @Column(name = "line_id", tag = true)
private String lineId; private String lineId;
@Column(name = "phasic_type") @Column(name = "phasic_type", tag = true)
private String phaseType; private String phaseType;
@Column(name = "value_type") @Column(name = "value_type", tag = true)
private String valueType; private String valueType;
@Column(name = "quality_flag") @Column(name = "quality_flag", tag = true)
private String qualityFlag; private String qualityFlag;
@Column(name = "plt") @Column(name = "plt")

14
pqs-influx/src/main/java/com/njcn/influx/pojo/po/DataV.java
View File

@@ -5,6 +5,7 @@ import com.njcn.influx.utils.InstantDateSerializer;
import lombok.Data; import lombok.Data;
import org.influxdb.annotation.Column; import org.influxdb.annotation.Column;
import org.influxdb.annotation.Measurement; import org.influxdb.annotation.Measurement;
import org.influxdb.annotation.TimeColumn;
import java.time.Instant; import java.time.Instant;
@@ -17,9 +18,10 @@ import java.time.Instant;
*/ */
@Data @Data
@Measurement(name = "data_v") @Measurement(name = "data_v")
public class DataV{ public class DataV {
@Column(name = "time") @TimeColumn
@Column(name = "time", tag = true)
@JsonSerialize(using = InstantDateSerializer.class) @JsonSerialize(using = InstantDateSerializer.class)
private Instant time; private Instant time;
@@ -29,7 +31,7 @@ public class DataV{
@Column(name = "freq_dev") @Column(name = "freq_dev")
private Double freqDev; private Double freqDev;
@Column(name = "quality_flag") @Column(name = "quality_flag", tag = true)
private String qualityFlag; private String qualityFlag;
@Column(name = "rms") @Column(name = "rms")
@@ -209,13 +211,13 @@ public class DataV{
@Column(name = "v_zero") @Column(name = "v_zero")
private Double vZero; private Double vZero;
@Column(name = "line_id") @Column(name = "line_id", tag = true)
private String lineId; private String lineId;
@Column(name = "phasic_type") @Column(name = "phasic_type", tag = true)
private String phasicType; private String phasicType;
@Column(name = "value_type") @Column(name = "value_type", tag = true)
private String valueType; private String valueType;