From ff123c680d1fa61ced0f8c0a08989280397df6d1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=9B=A8=E6=9C=A8c?= <857448963@qq.com> Date: Fri, 20 Oct 2023 09:01:06 +0800 Subject: [PATCH] =?UTF-8?q?influxdb=E6=96=B0=E5=A2=9E=E5=AE=9E=E4=BD=93?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../influx/imapper/day/DayFlickerMapper.java | 18 ++ .../influx/imapper/day/DayFlucMapper.java | 13 + .../imapper/day/DayHarmPhasicIMapper.java | 13 + .../imapper/day/DayHarmPhasicVMapper.java | 13 + .../imapper/day/DayHarmPowerPMapper.java | 17 ++ .../imapper/day/DayHarmPowerQMapper.java | 14 ++ .../imapper/day/DayHarmPowerSMapper.java | 14 ++ .../imapper/day/DayHarmRateIMapper.java | 14 ++ .../imapper/day/DayHarmRateVMapper.java | 18 ++ .../njcn/influx/imapper/day/DayIMapper.java | 19 ++ .../imapper/day/DayInHarmIRateMapper.java | 14 ++ .../imapper/day/DayInHarmVRateMapper.java | 14 ++ .../njcn/influx/imapper/day/DayPltMapper.java | 13 + .../njcn/influx/imapper/day/DayVMapper.java | 21 ++ .../njcn/influx/pojo/po/day/DayFlicker.java | 59 +++++ .../com/njcn/influx/pojo/po/day/DayFluc.java | 45 ++++ .../influx/pojo/po/day/DayHarmPhasicI.java | 189 ++++++++++++++ .../influx/pojo/po/day/DayHarmPhasicV.java | 190 ++++++++++++++ .../influx/pojo/po/day/DayHarmPowerP.java | 198 +++++++++++++++ .../influx/pojo/po/day/DayHarmPowerQ.java | 193 ++++++++++++++ .../influx/pojo/po/day/DayHarmPowerS.java | 193 ++++++++++++++ .../njcn/influx/pojo/po/day/DayHarmRateI.java | 18 ++ .../njcn/influx/pojo/po/day/DayHarmRateV.java | 18 ++ .../com/njcn/influx/pojo/po/day/DayI.java | 208 ++++++++++++++++ .../njcn/influx/pojo/po/day/DayInHarmI.java | 20 ++ .../influx/pojo/po/day/DayInHarmRateI.java | 187 ++++++++++++++ .../influx/pojo/po/day/DayInHarmRateV.java | 185 ++++++++++++++ .../njcn/influx/pojo/po/day/DayInHarmV.java | 187 ++++++++++++++ .../com/njcn/influx/pojo/po/day/DayPlt.java | 43 ++++ .../com/njcn/influx/pojo/po/day/DayV.java | 235 ++++++++++++++++++ .../com/njcn/system/enums/DicDataEnum.java | 1 - 31 files changed, 2383 insertions(+), 1 deletion(-) create mode 100644 pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayFlickerMapper.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayFlucMapper.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmPhasicIMapper.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmPhasicVMapper.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmPowerPMapper.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmPowerQMapper.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmPowerSMapper.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmRateIMapper.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmRateVMapper.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayIMapper.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayInHarmIRateMapper.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayInHarmVRateMapper.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayPltMapper.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayVMapper.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayFlicker.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayFluc.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmPhasicI.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmPhasicV.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmPowerP.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmPowerQ.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmPowerS.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmRateI.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmRateV.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayI.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayInHarmI.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayInHarmRateI.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayInHarmRateV.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayInHarmV.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayPlt.java create mode 100644 pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayV.java diff --git a/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayFlickerMapper.java b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayFlickerMapper.java new file mode 100644 index 000000000..b5ca4193b --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayFlickerMapper.java @@ -0,0 +1,18 @@ +package com.njcn.influx.imapper.day; + +import com.njcn.influx.base.InfluxDbBaseMapper; +import com.njcn.influx.pojo.dto.DataFlickerDTO; +import com.njcn.influx.pojo.po.DataFlicker; +import com.njcn.influx.pojo.po.day.DayFlicker; +import com.njcn.influx.query.InfluxQueryWrapper; + +import java.util.List; + +/** + * @author hongawen + * @version 1.0.0 + * @date 2023年05月05日 08:55 + */ +public interface DayFlickerMapper extends InfluxDbBaseMapper { + +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayFlucMapper.java b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayFlucMapper.java new file mode 100644 index 000000000..89c2995ce --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayFlucMapper.java @@ -0,0 +1,13 @@ +package com.njcn.influx.imapper.day; + +import com.njcn.influx.base.InfluxDbBaseMapper; +import com.njcn.influx.pojo.po.DataFluc; +import com.njcn.influx.pojo.po.day.DayFluc; + +/** + * @author hongawen + * @version 1.0.0 + * @date 2023年05月05日 08:56 + */ +public interface DayFlucMapper extends InfluxDbBaseMapper { +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmPhasicIMapper.java b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmPhasicIMapper.java new file mode 100644 index 000000000..c55addc38 --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmPhasicIMapper.java @@ -0,0 +1,13 @@ +package com.njcn.influx.imapper.day; + +import com.njcn.influx.base.InfluxDbBaseMapper; +import com.njcn.influx.pojo.po.DataHarmPhasicI; +import com.njcn.influx.pojo.po.day.DayHarmPhasicI; + +/** + * @author hongawen + * @version 1.0.0 + * @date 2023年05月05日 08:56 + */ +public interface DayHarmPhasicIMapper extends InfluxDbBaseMapper { +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmPhasicVMapper.java b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmPhasicVMapper.java new file mode 100644 index 000000000..2577cf47a --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmPhasicVMapper.java @@ -0,0 +1,13 @@ +package com.njcn.influx.imapper.day; + +import com.njcn.influx.base.InfluxDbBaseMapper; +import com.njcn.influx.pojo.po.DataHarmPhasicV; +import com.njcn.influx.pojo.po.day.DayHarmPhasicV; + +/** + * @author hongawen + * @version 1.0.0 + * @date 2023年05月05日 08:56 + */ +public interface DayHarmPhasicVMapper extends InfluxDbBaseMapper { +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmPowerPMapper.java b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmPowerPMapper.java new file mode 100644 index 000000000..a8f937d65 --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmPowerPMapper.java @@ -0,0 +1,17 @@ +package com.njcn.influx.imapper.day; + +import com.njcn.influx.base.InfluxDbBaseMapper; +import com.njcn.influx.pojo.po.DataHarmPowerP; +import com.njcn.influx.pojo.po.day.DayHarmPowerP; +import com.njcn.influx.query.InfluxQueryWrapper; + +import java.util.List; + +/** + * @author hongawen + * @version 1.0.0 + * @date 2023年05月05日 09:00 + */ +public interface DayHarmPowerPMapper extends InfluxDbBaseMapper { + +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmPowerQMapper.java b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmPowerQMapper.java new file mode 100644 index 000000000..e67750c4a --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmPowerQMapper.java @@ -0,0 +1,14 @@ +package com.njcn.influx.imapper.day; + +import com.njcn.influx.base.InfluxDbBaseMapper; +import com.njcn.influx.pojo.po.DataHarmPowerQ; +import com.njcn.influx.pojo.po.day.DayHarmPowerQ; + +/** + * @author hongawen + * @version 1.0.0 + * @date 2023年05月05日 09:00 + */ +public interface DayHarmPowerQMapper extends InfluxDbBaseMapper { + +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmPowerSMapper.java b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmPowerSMapper.java new file mode 100644 index 000000000..93a09d072 --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmPowerSMapper.java @@ -0,0 +1,14 @@ +package com.njcn.influx.imapper.day; + +import com.njcn.influx.base.InfluxDbBaseMapper; +import com.njcn.influx.pojo.po.DataHarmPowerS; +import com.njcn.influx.pojo.po.day.DayHarmPowerS; + +/** + * @author hongawen + * @version 1.0.0 + * @date 2023年05月05日 09:00 + */ +public interface DayHarmPowerSMapper extends InfluxDbBaseMapper { + +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmRateIMapper.java b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmRateIMapper.java new file mode 100644 index 000000000..b3b8d479b --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmRateIMapper.java @@ -0,0 +1,14 @@ +package com.njcn.influx.imapper.day; + +import com.njcn.influx.base.InfluxDbBaseMapper; +import com.njcn.influx.pojo.po.day.DayHarmRateI; +import com.njcn.influx.pojo.po.day.DayHarmRateV; + +/** + * @author hongawen + * @version 1.0.0 + * @date 2023年07月17日 11:03 + */ +public interface DayHarmRateIMapper extends InfluxDbBaseMapper { + +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmRateVMapper.java b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmRateVMapper.java new file mode 100644 index 000000000..3e2758807 --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayHarmRateVMapper.java @@ -0,0 +1,18 @@ +package com.njcn.influx.imapper.day; + +import com.njcn.influx.base.InfluxDbBaseMapper; +import com.njcn.influx.pojo.dto.HarmData; +import com.njcn.influx.pojo.po.DataHarmRateV; +import com.njcn.influx.pojo.po.day.DayHarmRateV; +import com.njcn.influx.query.InfluxQueryWrapper; + +import java.util.List; + +/** + * @author hongawen + * @version 1.0.0 + * @date 2023年07月17日 11:03 + */ +public interface DayHarmRateVMapper extends InfluxDbBaseMapper { + +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayIMapper.java b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayIMapper.java new file mode 100644 index 000000000..2ef3ebbce --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayIMapper.java @@ -0,0 +1,19 @@ +package com.njcn.influx.imapper.day; + +import com.njcn.influx.base.InfluxDbBaseMapper; +import com.njcn.influx.pojo.dto.HarmData; +import com.njcn.influx.pojo.po.DataI; +import com.njcn.influx.pojo.po.day.DayI; +import com.njcn.influx.query.InfluxQueryWrapper; + +import java.util.List; + +/** + * @author hongawen + * @version 1.0.0 + * @date 2023年07月17日 11:05 + */ +public interface DayIMapper extends InfluxDbBaseMapper { + + +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayInHarmIRateMapper.java b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayInHarmIRateMapper.java new file mode 100644 index 000000000..7f76693db --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayInHarmIRateMapper.java @@ -0,0 +1,14 @@ +package com.njcn.influx.imapper.day; + +import com.njcn.influx.base.InfluxDbBaseMapper; +import com.njcn.influx.pojo.po.day.DayInHarmI; +import com.njcn.influx.pojo.po.day.DayInHarmV; + +/** + * @author hongawen + * @version 1.0.0 + * @date 2023年05月05日 09:00 + */ +public interface DayInHarmIRateMapper extends InfluxDbBaseMapper { + +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayInHarmVRateMapper.java b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayInHarmVRateMapper.java new file mode 100644 index 000000000..ffb580584 --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayInHarmVRateMapper.java @@ -0,0 +1,14 @@ +package com.njcn.influx.imapper.day; + +import com.njcn.influx.base.InfluxDbBaseMapper; +import com.njcn.influx.pojo.po.DataInHarmV; +import com.njcn.influx.pojo.po.day.DayInHarmV; + +/** + * @author hongawen + * @version 1.0.0 + * @date 2023年05月05日 09:00 + */ +public interface DayInHarmVRateMapper extends InfluxDbBaseMapper { + +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayPltMapper.java b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayPltMapper.java new file mode 100644 index 000000000..93cf6625f --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayPltMapper.java @@ -0,0 +1,13 @@ +package com.njcn.influx.imapper.day; + +import com.njcn.influx.base.InfluxDbBaseMapper; +import com.njcn.influx.pojo.po.day.DayFluc; +import com.njcn.influx.pojo.po.day.DayPlt; + +/** + * @author hongawen + * @version 1.0.0 + * @date 2023年05月05日 08:56 + */ +public interface DayPltMapper extends InfluxDbBaseMapper { +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayVMapper.java b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayVMapper.java new file mode 100644 index 000000000..f9e99c1a4 --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/imapper/day/DayVMapper.java @@ -0,0 +1,21 @@ +package com.njcn.influx.imapper.day; + +import com.njcn.influx.base.InfluxDbBaseMapper; +import com.njcn.influx.pojo.po.DataV; +import com.njcn.influx.pojo.po.day.DayV; +import com.njcn.influx.query.InfluxQueryWrapper; + +import java.util.List; + +/** + * 类的介绍： + * + * @author xuyang + * @version 1.0.0 + * @createTime 2023/5/5 14:39 + */ + +public interface DayVMapper extends InfluxDbBaseMapper { + + +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayFlicker.java b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayFlicker.java new file mode 100644 index 000000000..1c2df87b4 --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayFlicker.java @@ -0,0 +1,59 @@ +package com.njcn.influx.pojo.po.day; + +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.njcn.common.utils.serializer.InstantDateSerializer; +import lombok.Data; +import org.influxdb.annotation.Column; +import org.influxdb.annotation.Measurement; +import org.influxdb.annotation.TimeColumn; + +import java.time.Instant; + +/** + * 类的介绍： + * + * @author xuyang + * @version 1.0.0 + */ +@Data +@Measurement(name = "day_flicker") +public class DayFlicker { + + @TimeColumn + @Column(name = "time") + @JsonSerialize(using = InstantDateSerializer.class) + private Instant time; + + @Column(name = "fluc") + private Double fluc; + + @Column(name = "line_id",tag = true) + private String lineId; + + @Column(name = "phasic_type",tag = true) + private String phaseType; + + @Column(name = "plt") + private Double plt; + + @Column(name = "pst") + private Double pst; + + @Column(name = "quality_flag",tag = true) + private String qualityFlag; + + + //自定义字段 + @Column(name = "value_type",tag = true) + private String valueType; + + @Column(name = "count") + private Integer count; + + @Column(name = "pst_count") + private Integer pstCount; + + @Column(name = "plt_count") + private Integer pltCount; + +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayFluc.java b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayFluc.java new file mode 100644 index 000000000..955af5f14 --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayFluc.java @@ -0,0 +1,45 @@ +package com.njcn.influx.pojo.po.day; + +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.njcn.common.utils.serializer.InstantDateSerializer; +import lombok.Data; +import org.influxdb.annotation.Column; +import org.influxdb.annotation.Measurement; +import org.influxdb.annotation.TimeColumn; + +import java.time.Instant; + +/** + * 类的介绍： + * + * @author xuyang + * @version 1.0.0 + */ +@Data +@Measurement(name = "day_fluc") +public class DayFluc { + + @Column(name = "time") + @TimeColumn + @JsonSerialize(using = InstantDateSerializer.class) + private Instant time; + + @Column(name = "fluc") + private Double fluc; + + @Column(name = "fluccf") + private Double fluccf; + + @Column(name = "line_id",tag = true) + private String lineId; + + @Column(name = "phasic_type",tag = true) + private String phaseType; + + @Column(name = "quality_flag",tag = true) + private String qualityFlag; + + @Column(name = "value_type",tag = true) + private String valueType; + +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmPhasicI.java b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmPhasicI.java new file mode 100644 index 000000000..1c4b98ed6 --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmPhasicI.java @@ -0,0 +1,189 @@ +package com.njcn.influx.pojo.po.day; + +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.njcn.common.utils.serializer.InstantDateSerializer; +import lombok.Data; +import org.influxdb.annotation.Column; +import org.influxdb.annotation.Measurement; +import org.influxdb.annotation.TimeColumn; + +import java.time.Instant; + +/** + * 类的介绍： + * + * @author xuyang + * @version 1.0.0 + */ +@Data +@Measurement(name = "day_harmphasic_i") +public class DayHarmPhasicI { + + @Column(name = "time") + @TimeColumn + @JsonSerialize(using = InstantDateSerializer.class) + private Instant time; + + @Column(name = "line_id",tag = true) + private String lineId; + + @Column(name = "phasic_type",tag = true) + private String phaseType; + + @Column(name = "quality_flag",tag = true) + private String qualityFlag; + + @Column(name = "value_type",tag = true) + private String valueType; + + @Column(name = "i_1") + private Double i1; + + @Column(name = "i_2") + private Double i2; + + @Column(name = "i_3") + private Double i3; + + @Column(name = "i_4") + private Double i4; + + @Column(name = "i_5") + private Double i5; + + @Column(name = "i_6") + private Double i6; + + @Column(name = "i_7") + private Double i7; + + @Column(name = "i_8") + private Double i8; + + @Column(name = "i_9") + private Double i9; + + @Column(name = "i_10") + private Double i10; + + @Column(name = "i_11") + private Double i11; + + @Column(name = "i_12") + private Double i12; + + @Column(name = "i_13") + private Double i13; + + @Column(name = "i_14") + private Double i14; + + @Column(name = "i_15") + private Double i15; + + @Column(name = "i_16") + private Double i16; + + @Column(name = "i_17") + private Double i17; + + @Column(name = "i_18") + private Double i18; + + @Column(name = "i_19") + private Double i19; + + @Column(name = "i_20") + private Double i20; + + @Column(name = "i_21") + private Double i21; + + @Column(name = "i_22") + private Double i22; + + @Column(name = "i_23") + private Double i23; + + @Column(name = "i_24") + private Double i24; + + @Column(name = "i_25") + private Double i25; + + @Column(name = "i_26") + private Double i26; + + @Column(name = "i_27") + private Double i27; + + @Column(name = "i_28") + private Double i28; + + @Column(name = "i_29") + private Double i29; + + @Column(name = "i_30") + private Double i30; + + @Column(name = "i_31") + private Double i31; + + @Column(name = "i_32") + private Double i32; + + @Column(name = "i_33") + private Double i33; + + @Column(name = "i_34") + private Double i34; + + @Column(name = "i_35") + private Double i35; + + @Column(name = "i_36") + private Double i36; + + @Column(name = "i_37") + private Double i37; + + @Column(name = "i_38") + private Double i38; + + @Column(name = "i_39") + private Double i39; + + @Column(name = "i_40") + private Double i40; + + @Column(name = "i_41") + private Double i41; + + @Column(name = "i_42") + private Double i42; + + @Column(name = "i_43") + private Double i43; + + @Column(name = "i_44") + private Double i44; + + @Column(name = "i_45") + private Double i45; + + @Column(name = "i_46") + private Double i46; + + @Column(name = "i_47") + private Double i47; + + @Column(name = "i_48") + private Double i48; + + @Column(name = "i_49") + private Double i49; + + @Column(name = "i_50") + private Double i50; + +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmPhasicV.java b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmPhasicV.java new file mode 100644 index 000000000..70b648952 --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmPhasicV.java @@ -0,0 +1,190 @@ +package com.njcn.influx.pojo.po.day; + +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.njcn.common.utils.serializer.InstantDateSerializer; +import lombok.Data; +import org.influxdb.annotation.Column; +import org.influxdb.annotation.Measurement; +import org.influxdb.annotation.TimeColumn; + +import java.time.Instant; + +/** + * 类的介绍： + * + * @author xuyang + * @version 1.0.0 + * @createTime 2022/5/12 9:13 + */ +@Data +@Measurement(name = "day_harmphasic_v") +public class DayHarmPhasicV { + + @Column(name = "time") + @TimeColumn + @JsonSerialize(using = InstantDateSerializer.class) + private Instant time; + + @Column(name = "line_id",tag = true) + private String lineId; + + @Column(name = "phasic_type",tag = true) + private String phaseType; + + @Column(name = "quality_flag",tag = true) + private String qualityFlag; + + @Column(name = "value_type",tag = true) + private String valueType; + + @Column(name = "v_1") + private Double v1; + + @Column(name = "v_2") + private Double v2; + + @Column(name = "v_3") + private Double v3; + + @Column(name = "v_4") + private Double v4; + + @Column(name = "v_5") + private Double v5; + + @Column(name = "v_6") + private Double v6; + + @Column(name = "v_7") + private Double v7; + + @Column(name = "v_8") + private Double v8; + + @Column(name = "v_9") + private Double v9; + + @Column(name = "v_10") + private Double v10; + + @Column(name = "v_11") + private Double v11; + + @Column(name = "v_12") + private Double v12; + + @Column(name = "v_13") + private Double v13; + + @Column(name = "v_14") + private Double v14; + + @Column(name = "v_15") + private Double v15; + + @Column(name = "v_16") + private Double v16; + + @Column(name = "v_17") + private Double v17; + + @Column(name = "v_18") + private Double v18; + + @Column(name = "v_19") + private Double v19; + + @Column(name = "v_20") + private Double v20; + + @Column(name = "v_21") + private Double v21; + + @Column(name = "v_22") + private Double v22; + + @Column(name = "v_23") + private Double v23; + + @Column(name = "v_24") + private Double v24; + + @Column(name = "v_25") + private Double v25; + + @Column(name = "v_26") + private Double v26; + + @Column(name = "v_27") + private Double v27; + + @Column(name = "v_28") + private Double v28; + + @Column(name = "v_29") + private Double v29; + + @Column(name = "v_30") + private Double v30; + + @Column(name = "v_31") + private Double v31; + + @Column(name = "v_32") + private Double v32; + + @Column(name = "v_33") + private Double v33; + + @Column(name = "v_34") + private Double v34; + + @Column(name = "v_35") + private Double v35; + + @Column(name = "v_36") + private Double v36; + + @Column(name = "v_37") + private Double v37; + + @Column(name = "v_38") + private Double v38; + + @Column(name = "v_39") + private Double v39; + + @Column(name = "v_40") + private Double v40; + + @Column(name = "v_41") + private Double v41; + + @Column(name = "v_42") + private Double v42; + + @Column(name = "v_43") + private Double v43; + + @Column(name = "v_44") + private Double v44; + + @Column(name = "v_45") + private Double v45; + + @Column(name = "v_46") + private Double v46; + + @Column(name = "v_47") + private Double v47; + + @Column(name = "v_48") + private Double v48; + + @Column(name = "v_49") + private Double v49; + + @Column(name = "v_50") + private Double v50; + +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmPowerP.java b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmPowerP.java new file mode 100644 index 000000000..db9197aa0 --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmPowerP.java @@ -0,0 +1,198 @@ +package com.njcn.influx.pojo.po.day; + +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.njcn.common.utils.serializer.InstantDateSerializer; +import lombok.Data; +import org.influxdb.annotation.Column; +import org.influxdb.annotation.Measurement; +import org.influxdb.annotation.TimeColumn; + +import java.time.Instant; + +/** + * 类的介绍： + * + * @author xuyang + * @version 1.0.0 + * @createTime 2022/5/12 9:13 + */ +@Data +@Measurement(name = "day_harmpower_p") +public class DayHarmPowerP { + + @Column(name = "time") + @TimeColumn + @JsonSerialize(using = InstantDateSerializer.class) + private Instant time; + + @Column(name = "line_id",tag = true) + private String lineId; + + @Column(name = "phasic_type",tag = true) + private String phaseType; + + @Column(name = "quality_flag",tag = true) + private String qualityFlag; + + @Column(name = "value_type",tag = true) + private String valueType; + + @Column(name = "df") + private Double df; + + @Column(name = "pf") + private Double pf; + + @Column(name = "p") + private Double p; + + @Column(name = "p_1") + private Double p1; + + @Column(name = "p_2") + private Double p2; + + @Column(name = "p_3") + private Double p3; + + @Column(name = "p_4") + private Double p4; + + @Column(name = "p_5") + private Double p5; + + @Column(name = "p_6") + private Double p6; + + @Column(name = "p_7") + private Double p7; + + @Column(name = "p_8") + private Double p8; + + @Column(name = "p_9") + private Double p9; + + @Column(name = "p_10") + private Double p10; + + @Column(name = "p_11") + private Double p11; + + @Column(name = "p_12") + private Double p12; + + @Column(name = "p_13") + private Double p13; + + @Column(name = "p_14") + private Double p14; + + @Column(name = "p_15") + private Double p15; + + @Column(name = "p_16") + private Double p16; + + @Column(name = "p_17") + private Double p17; + + @Column(name = "p_18") + private Double p18; + + @Column(name = "p_19") + private Double p19; + + @Column(name = "p_20") + private Double p20; + + @Column(name = "p_21") + private Double p21; + + @Column(name = "p_22") + private Double p22; + + @Column(name = "p_23") + private Double p23; + + @Column(name = "p_24") + private Double p24; + + @Column(name = "p_25") + private Double p25; + + @Column(name = "p_26") + private Double p26; + + @Column(name = "p_27") + private Double p27; + + @Column(name = "p_28") + private Double p28; + + @Column(name = "p_29") + private Double p29; + + @Column(name = "p_30") + private Double p30; + + @Column(name = "p_31") + private Double p31; + + @Column(name = "p_32") + private Double p32; + + @Column(name = "p_33") + private Double p33; + + @Column(name = "p_34") + private Double p34; + + @Column(name = "p_35") + private Double p35; + + @Column(name = "p_36") + private Double p36; + + @Column(name = "p_37") + private Double p37; + + @Column(name = "p_38") + private Double p38; + + @Column(name = "p_39") + private Double p39; + + @Column(name = "p_40") + private Double p40; + + @Column(name = "p_41") + private Double p41; + + @Column(name = "p_42") + private Double p42; + + @Column(name = "p_43") + private Double p43; + + @Column(name = "p_44") + private Double p44; + + @Column(name = "p_45") + private Double p45; + + @Column(name = "p_46") + private Double p46; + + @Column(name = "p_47") + private Double p47; + + @Column(name = "p_48") + private Double p48; + + @Column(name = "p_49") + private Double p49; + + @Column(name = "p_50") + private Double p50; +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmPowerQ.java b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmPowerQ.java new file mode 100644 index 000000000..ee1a3aecd --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmPowerQ.java @@ -0,0 +1,193 @@ +package com.njcn.influx.pojo.po.day; + +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.njcn.common.utils.serializer.InstantDateSerializer; +import lombok.Data; +import org.influxdb.annotation.Column; +import org.influxdb.annotation.Measurement; +import org.influxdb.annotation.TimeColumn; + +import java.time.Instant; + +/** + * 类的介绍： + * + * @author xuyang + * @version 1.0.0 + * @createTime 2022/5/12 9:13 + */ +@Data +@Measurement(name = "day_harmpower_q") +public class DayHarmPowerQ { + + @Column(name = "time") + @TimeColumn + @JsonSerialize(using = InstantDateSerializer.class) + private Instant time; + + @Column(name = "line_id",tag = true) + private String lineId; + + @Column(name = "phasic_type",tag = true) + private String phaseType; + + @Column(name = "quality_flag",tag = true) + private String qualityFlag; + + @Column(name = "value_type",tag = true) + private String valueType; + + @Column(name = "q") + private Double q; + + @Column(name = "q_1") + private Double q1; + + @Column(name = "q_2") + private Double q2; + + @Column(name = "q_3") + private Double q3; + + @Column(name = "q_4") + private Double q4; + + @Column(name = "q_5") + private Double q5; + + @Column(name = "q_6") + private Double q6; + + @Column(name = "q_7") + private Double q7; + + @Column(name = "q_8") + private Double q8; + + @Column(name = "q_9") + private Double q9; + + @Column(name = "q_10") + private Double q10; + + @Column(name = "q_11") + private Double q11; + + @Column(name = "q_12") + private Double q12; + + @Column(name = "q_13") + private Double q13; + + @Column(name = "q_14") + private Double q14; + + @Column(name = "q_15") + private Double q15; + + @Column(name = "q_16") + private Double q16; + + @Column(name = "q_17") + private Double q17; + + @Column(name = "q_18") + private Double q18; + + @Column(name = "q_19") + private Double q19; + + @Column(name = "q_20") + private Double q20; + + @Column(name = "q_21") + private Double q21; + + @Column(name = "q_22") + private Double q22; + + @Column(name = "q_23") + private Double q23; + + @Column(name = "q_24") + private Double q24; + + @Column(name = "q_25") + private Double q25; + + @Column(name = "q_26") + private Double q26; + + @Column(name = "q_27") + private Double q27; + + @Column(name = "q_28") + private Double q28; + + @Column(name = "q_29") + private Double q29; + + @Column(name = "q_30") + private Double q30; + + @Column(name = "q_31") + private Double q31; + + @Column(name = "q_32") + private Double q32; + + @Column(name = "q_33") + private Double q33; + + @Column(name = "q_34") + private Double q34; + + @Column(name = "q_35") + private Double q35; + + @Column(name = "q_36") + private Double q36; + + @Column(name = "q_37") + private Double q37; + + @Column(name = "q_38") + private Double q38; + + @Column(name = "q_39") + private Double q39; + + @Column(name = "q_40") + private Double q40; + + @Column(name = "q_41") + private Double q41; + + @Column(name = "q_42") + private Double q42; + + @Column(name = "q_43") + private Double q43; + + @Column(name = "q_44") + private Double q44; + + @Column(name = "q_45") + private Double q45; + + @Column(name = "q_46") + private Double q46; + + @Column(name = "q_47") + private Double q47; + + @Column(name = "q_48") + private Double q48; + + @Column(name = "q_49") + private Double q49; + + @Column(name = "q_50") + private Double q50; + +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmPowerS.java b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmPowerS.java new file mode 100644 index 000000000..f926a3078 --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmPowerS.java @@ -0,0 +1,193 @@ +package com.njcn.influx.pojo.po.day; + +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.njcn.common.utils.serializer.InstantDateSerializer; +import lombok.Data; +import org.influxdb.annotation.Column; +import org.influxdb.annotation.Measurement; +import org.influxdb.annotation.TimeColumn; + +import java.time.Instant; + +/** + * 类的介绍： + * + * @author xuyang + * @version 1.0.0 + * @createTime 2022/5/12 9:13 + */ +@Data +@Measurement(name = "day_harmpower_s") +public class DayHarmPowerS { + + @Column(name = "time") + @TimeColumn + @JsonSerialize(using = InstantDateSerializer.class) + private Instant time; + + @Column(name = "line_id",tag = true) + private String lineId; + + @Column(name = "phasic_type",tag = true) + private String phaseType; + + @Column(name = "quality_flag",tag = true) + private String qualityFlag; + + @Column(name = "value_type",tag = true) + private String valueType; + + @Column(name = "s") + private Double s; + + @Column(name = "s_1") + private Double s1; + + @Column(name = "s_2") + private Double s2; + + @Column(name = "s_3") + private Double s3; + + @Column(name = "s_4") + private Double s4; + + @Column(name = "s_5") + private Double s5; + + @Column(name = "s_6") + private Double s6; + + @Column(name = "s_7") + private Double s7; + + @Column(name = "s_8") + private Double s8; + + @Column(name = "s_9") + private Double s9; + + @Column(name = "s_10") + private Double s10; + + @Column(name = "s_11") + private Double s11; + + @Column(name = "s_12") + private Double s12; + + @Column(name = "s_13") + private Double s13; + + @Column(name = "s_14") + private Double s14; + + @Column(name = "s_15") + private Double s15; + + @Column(name = "s_16") + private Double s16; + + @Column(name = "s_17") + private Double s17; + + @Column(name = "s_18") + private Double s18; + + @Column(name = "s_19") + private Double s19; + + @Column(name = "s_20") + private Double s20; + + @Column(name = "s_21") + private Double s21; + + @Column(name = "s_22") + private Double s22; + + @Column(name = "s_23") + private Double s23; + + @Column(name = "s_24") + private Double s24; + + @Column(name = "s_25") + private Double s25; + + @Column(name = "s_26") + private Double s26; + + @Column(name = "s_27") + private Double s27; + + @Column(name = "s_28") + private Double s28; + + @Column(name = "s_29") + private Double s29; + + @Column(name = "s_30") + private Double s30; + + @Column(name = "s_31") + private Double s31; + + @Column(name = "s_32") + private Double s32; + + @Column(name = "s_33") + private Double s33; + + @Column(name = "s_34") + private Double s34; + + @Column(name = "s_35") + private Double s35; + + @Column(name = "s_36") + private Double s36; + + @Column(name = "s_37") + private Double s37; + + @Column(name = "s_38") + private Double s38; + + @Column(name = "s_39") + private Double s39; + + @Column(name = "s_40") + private Double s40; + + @Column(name = "s_41") + private Double s41; + + @Column(name = "s_42") + private Double s42; + + @Column(name = "s_43") + private Double s43; + + @Column(name = "s_44") + private Double s44; + + @Column(name = "s_45") + private Double s45; + + @Column(name = "s_46") + private Double s46; + + @Column(name = "s_47") + private Double s47; + + @Column(name = "s_48") + private Double s48; + + @Column(name = "s_49") + private Double s49; + + @Column(name = "s_50") + private Double s50; + +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmRateI.java b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmRateI.java new file mode 100644 index 000000000..d3598e66a --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmRateI.java @@ -0,0 +1,18 @@ +package com.njcn.influx.pojo.po.day; + +import lombok.Data; +import lombok.EqualsAndHashCode; +import org.influxdb.annotation.Measurement; + +/** + * 类的介绍： + * + * @author xuyang + * @version 1.0.0 + * @createTime 2022/5/12 11:27 + */ +@EqualsAndHashCode(callSuper = true) +@Data +@Measurement(name = "day_harmrate_i") +public class DayHarmRateI extends DayHarmPhasicI { +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmRateV.java b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmRateV.java new file mode 100644 index 000000000..7f2dfb699 --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayHarmRateV.java @@ -0,0 +1,18 @@ +package com.njcn.influx.pojo.po.day; + +import lombok.Data; +import lombok.EqualsAndHashCode; +import org.influxdb.annotation.Measurement; + +/** + * 类的介绍： + * + * @author xuyang + * @version 1.0.0 + * @createTime 2022/5/12 11:27 + */ +@EqualsAndHashCode(callSuper = true) +@Data +@Measurement(name = "day_harmrate_v") +public class DayHarmRateV extends DayHarmPhasicV { +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayI.java b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayI.java new file mode 100644 index 000000000..a8299d40a --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayI.java @@ -0,0 +1,208 @@ +package com.njcn.influx.pojo.po.day; + +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.njcn.common.utils.serializer.InstantDateSerializer; +import lombok.Data; +import org.influxdb.annotation.Column; +import org.influxdb.annotation.Measurement; +import org.influxdb.annotation.TimeColumn; + +import java.time.Instant; + +/** + * 类的介绍： + * + * @author xuyang + * @version 1.0.0 + * @createTime 2022/5/11 15:13 + */ +@Data +@Measurement(name = "day_i") +public class DayI { + + @Column(name = "time",tag = true) + @TimeColumn + @JsonSerialize(using = InstantDateSerializer.class) + private Instant time; + + @Column(name = "line_id",tag = true) + private String lineId; + + @Column(name = "phasic_type",tag = true) + private String phaseType; + + @Column(name = "quality_flag",tag = true) + private String qualityFlag; + + @Column(name = "value_type",tag = true) + private String valueType; + + @Column(name = "i_neg") + private Double iNeg; + + @Column(name = "i_pos") + private Double iPos; + + @Column(name = "i_thd") + private Double iThd; + + @Column(name = "i_unbalance") + private Double iUnbalance; + + @Column(name = "i_zero") + private Double iZero; + + @Column(name = "rms") + private Double rms; + + @Column(name = "i_1") + private Double i1; + + @Column(name = "i_2") + private Double i2; + + @Column(name = "i_3") + private Double i3; + + @Column(name = "i_4") + private Double i4; + + @Column(name = "i_5") + private Double i5; + + @Column(name = "i_6") + private Double i6; + + @Column(name = "i_7") + private Double i7; + + @Column(name = "i_8") + private Double i8; + + @Column(name = "i_9") + private Double i9; + + @Column(name = "i_10") + private Double i10; + + @Column(name = "i_11") + private Double i11; + + @Column(name = "i_12") + private Double i12; + + @Column(name = "i_13") + private Double i13; + + @Column(name = "i_14") + private Double i14; + + @Column(name = "i_15") + private Double i15; + + @Column(name = "i_16") + private Double i16; + + @Column(name = "i_17") + private Double i17; + + @Column(name = "i_18") + private Double i18; + + @Column(name = "i_19") + private Double i19; + + @Column(name = "i_20") + private Double i20; + + @Column(name = "i_21") + private Double i21; + + @Column(name = "i_22") + private Double i22; + + @Column(name = "i_23") + private Double i23; + + @Column(name = "i_24") + private Double i24; + + @Column(name = "i_25") + private Double i25; + + @Column(name = "i_26") + private Double i26; + + @Column(name = "i_27") + private Double i27; + + @Column(name = "i_28") + private Double i28; + + @Column(name = "i_29") + private Double i29; + + @Column(name = "i_30") + private Double i30; + + @Column(name = "i_31") + private Double i31; + + @Column(name = "i_32") + private Double i32; + + @Column(name = "i_33") + private Double i33; + + @Column(name = "i_34") + private Double i34; + + @Column(name = "i_35") + private Double i35; + + @Column(name = "i_36") + private Double i36; + + @Column(name = "i_37") + private Double i37; + + @Column(name = "i_38") + private Double i38; + + @Column(name = "i_39") + private Double i39; + + @Column(name = "i_40") + private Double i40; + + @Column(name = "i_41") + private Double i41; + + @Column(name = "i_42") + private Double i42; + + @Column(name = "i_43") + private Double i43; + + @Column(name = "i_44") + private Double i44; + + @Column(name = "i_45") + private Double i45; + + @Column(name = "i_46") + private Double i46; + + @Column(name = "i_47") + private Double i47; + + @Column(name = "i_48") + private Double i48; + + @Column(name = "i_49") + private Double i49; + + @Column(name = "i_50") + private Double i50; + +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayInHarmI.java b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayInHarmI.java new file mode 100644 index 000000000..e3992fb12 --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayInHarmI.java @@ -0,0 +1,20 @@ +package com.njcn.influx.pojo.po.day; + +import lombok.Data; +import lombok.EqualsAndHashCode; +import org.influxdb.annotation.Measurement; + +/** + * 类的介绍： + * + * @author xuyang + * @version 1.0.0 + * @createTime 2022/5/12 11:27 + */ +@EqualsAndHashCode(callSuper = true) +@Data +@Measurement(name = "day_inharm_i") +public class DayInHarmI extends DayHarmPhasicI { + + +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayInHarmRateI.java b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayInHarmRateI.java new file mode 100644 index 000000000..40993e1dc --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayInHarmRateI.java @@ -0,0 +1,187 @@ +package com.njcn.influx.pojo.po.day; + +import lombok.Data; +import org.influxdb.annotation.Column; +import org.influxdb.annotation.Measurement; +import org.influxdb.annotation.TimeColumn; + +import java.time.Instant; + +/** + * 类的介绍： + * + * @author xuyang + * @version 1.0.0 + * @createTime 2022/5/12 9:13 + */ +@Data +@Measurement(name = "day_inharmrate_i") +public class DayInHarmRateI { + + @Column(name = "time") + @TimeColumn + private Instant time; + + @Column(name = "line_id",tag = true) + private String lineId; + + @Column(name = "phasic_type",tag = true) + private String phaseType; + + @Column(name = "quality_flag",tag = true) + private String qualityFlag; + + @Column(name = "value_type",tag = true) + private String valueType; + + @Column(name = "i_1") + private Double i1; + + @Column(name = "i_2") + private Double i2; + + @Column(name = "i_3") + private Double i3; + + @Column(name = "i_4") + private Double i4; + + @Column(name = "i_5") + private Double i5; + + @Column(name = "i_6") + private Double i6; + + @Column(name = "i_7") + private Double i7; + + @Column(name = "i_8") + private Double i8; + + @Column(name = "i_9") + private Double i9; + + @Column(name = "i_10") + private Double i10; + + @Column(name = "i_11") + private Double i11; + + @Column(name = "i_12") + private Double i12; + + @Column(name = "i_13") + private Double i13; + + @Column(name = "i_14") + private Double i14; + + @Column(name = "i_15") + private Double i15; + + @Column(name = "i_16") + private Double i16; + + @Column(name = "i_17") + private Double i17; + + @Column(name = "i_18") + private Double i18; + + @Column(name = "i_19") + private Double i19; + + @Column(name = "i_20") + private Double i20; + + @Column(name = "i_21") + private Double i21; + + @Column(name = "i_22") + private Double i22; + + @Column(name = "i_23") + private Double i23; + + @Column(name = "i_24") + private Double i24; + + @Column(name = "i_25") + private Double i25; + + @Column(name = "i_26") + private Double i26; + + @Column(name = "i_27") + private Double i27; + + @Column(name = "i_28") + private Double i28; + + @Column(name = "i_29") + private Double i29; + + @Column(name = "i_30") + private Double i30; + + @Column(name = "i_31") + private Double i31; + + @Column(name = "i_32") + private Double i32; + + @Column(name = "i_33") + private Double i33; + + @Column(name = "i_34") + private Double i34; + + @Column(name = "i_35") + private Double i35; + + @Column(name = "i_36") + private Double i36; + + @Column(name = "i_37") + private Double i37; + + @Column(name = "i_38") + private Double i38; + + @Column(name = "i_39") + private Double i39; + + @Column(name = "i_40") + private Double i40; + + @Column(name = "i_41") + private Double i41; + + @Column(name = "i_42") + private Double i42; + + @Column(name = "i_43") + private Double i43; + + @Column(name = "i_44") + private Double i44; + + @Column(name = "i_45") + private Double i45; + + @Column(name = "i_46") + private Double i46; + + @Column(name = "i_47") + private Double i47; + + @Column(name = "i_48") + private Double i48; + + @Column(name = "i_49") + private Double i49; + + @Column(name = "i_50") + private Double i50; + +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayInHarmRateV.java b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayInHarmRateV.java new file mode 100644 index 000000000..56dd0953b --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayInHarmRateV.java @@ -0,0 +1,185 @@ +package com.njcn.influx.pojo.po.day; + +import lombok.Data; +import org.influxdb.annotation.Column; +import org.influxdb.annotation.Measurement; + +import java.time.Instant; + +/** + * 类的介绍： + * + * @author xuyang + * @version 1.0.0 + * @createTime 2022/5/12 9:13 + */ +@Data +@Measurement(name = "day_inharmrate_v") +public class DayInHarmRateV { + + @Column(name = "time") + private Instant time; + + @Column(name = "line_id",tag = true) + private String lineId; + + @Column(name = "phasic_type",tag = true) + private String phaseType; + + @Column(name = "quality_flag",tag = true) + private String qualityFlag; + + @Column(name = "value_type",tag = true) + private String valueType; + + @Column(name = "v_1") + private Double v1; + + @Column(name = "v_2") + private Double v2; + + @Column(name = "v_3") + private Double v3; + + @Column(name = "v_4") + private Double v4; + + @Column(name = "v_5") + private Double v5; + + @Column(name = "v_6") + private Double v6; + + @Column(name = "v_7") + private Double v7; + + @Column(name = "v_8") + private Double v8; + + @Column(name = "v_9") + private Double v9; + + @Column(name = "v_10") + private Double v10; + + @Column(name = "v_11") + private Double v11; + + @Column(name = "v_12") + private Double v12; + + @Column(name = "v_13") + private Double v13; + + @Column(name = "v_14") + private Double v14; + + @Column(name = "v_15") + private Double v15; + + @Column(name = "v_16") + private Double v16; + + @Column(name = "v_17") + private Double v17; + + @Column(name = "v_18") + private Double v18; + + @Column(name = "v_19") + private Double v19; + + @Column(name = "v_20") + private Double v20; + + @Column(name = "v_21") + private Double v21; + + @Column(name = "v_22") + private Double v22; + + @Column(name = "v_23") + private Double v23; + + @Column(name = "v_24") + private Double v24; + + @Column(name = "v_25") + private Double v25; + + @Column(name = "v_26") + private Double v26; + + @Column(name = "v_27") + private Double v27; + + @Column(name = "v_28") + private Double v28; + + @Column(name = "v_29") + private Double v29; + + @Column(name = "v_30") + private Double v30; + + @Column(name = "v_31") + private Double v31; + + @Column(name = "v_32") + private Double v32; + + @Column(name = "v_33") + private Double v33; + + @Column(name = "v_34") + private Double v34; + + @Column(name = "v_35") + private Double v35; + + @Column(name = "v_36") + private Double v36; + + @Column(name = "v_37") + private Double v37; + + @Column(name = "v_38") + private Double v38; + + @Column(name = "v_39") + private Double v39; + + @Column(name = "v_40") + private Double v40; + + @Column(name = "v_41") + private Double v41; + + @Column(name = "v_42") + private Double v42; + + @Column(name = "v_43") + private Double v43; + + @Column(name = "v_44") + private Double v44; + + @Column(name = "v_45") + private Double v45; + + @Column(name = "v_46") + private Double v46; + + @Column(name = "v_47") + private Double v47; + + @Column(name = "v_48") + private Double v48; + + @Column(name = "v_49") + private Double v49; + + @Column(name = "v_50") + private Double v50; + +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayInHarmV.java b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayInHarmV.java new file mode 100644 index 000000000..10410a24f --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayInHarmV.java @@ -0,0 +1,187 @@ +package com.njcn.influx.pojo.po.day; + +import lombok.Data; +import org.influxdb.annotation.Column; +import org.influxdb.annotation.Measurement; +import org.influxdb.annotation.TimeColumn; + +import java.time.Instant; + +/** + * 类的介绍： + * + * @author xuyang + * @version 1.0.0 + * @createTime 2022/5/12 11:27 + */ +@Data +@Measurement(name = "day_inharm_v") +public class DayInHarmV { + + @Column(name = "time") + @TimeColumn + private Instant time; + + @Column(name = "line_id",tag = true) + private String lineId; + + @Column(name = "phasic_type",tag = true) + private String phaseType; + + @Column(name = "quality_flag",tag = true) + private String qualityFlag; + + @Column(name = "value_type",tag = true) + private String valueType; + + @Column(name = "v_1") + private Double v1; + + @Column(name = "v_2") + private Double v2; + + @Column(name = "v_3") + private Double v3; + + @Column(name = "v_4") + private Double v4; + + @Column(name = "v_5") + private Double v5; + + @Column(name = "v_6") + private Double v6; + + @Column(name = "v_7") + private Double v7; + + @Column(name = "v_8") + private Double v8; + + @Column(name = "v_9") + private Double v9; + + @Column(name = "v_10") + private Double v10; + + @Column(name = "v_11") + private Double v11; + + @Column(name = "v_12") + private Double v12; + + @Column(name = "v_13") + private Double v13; + + @Column(name = "v_14") + private Double v14; + + @Column(name = "v_15") + private Double v15; + + @Column(name = "v_16") + private Double v16; + + @Column(name = "v_17") + private Double v17; + + @Column(name = "v_18") + private Double v18; + + @Column(name = "v_19") + private Double v19; + + @Column(name = "v_20") + private Double v20; + + @Column(name = "v_21") + private Double v21; + + @Column(name = "v_22") + private Double v22; + + @Column(name = "v_23") + private Double v23; + + @Column(name = "v_24") + private Double v24; + + @Column(name = "v_25") + private Double v25; + + @Column(name = "v_26") + private Double v26; + + @Column(name = "v_27") + private Double v27; + + @Column(name = "v_28") + private Double v28; + + @Column(name = "v_29") + private Double v29; + + @Column(name = "v_30") + private Double v30; + + @Column(name = "v_31") + private Double v31; + + @Column(name = "v_32") + private Double v32; + + @Column(name = "v_33") + private Double v33; + + @Column(name = "v_34") + private Double v34; + + @Column(name = "v_35") + private Double v35; + + @Column(name = "v_36") + private Double v36; + + @Column(name = "v_37") + private Double v37; + + @Column(name = "v_38") + private Double v38; + + @Column(name = "v_39") + private Double v39; + + @Column(name = "v_40") + private Double v40; + + @Column(name = "v_41") + private Double v41; + + @Column(name = "v_42") + private Double v42; + + @Column(name = "v_43") + private Double v43; + + @Column(name = "v_44") + private Double v44; + + @Column(name = "v_45") + private Double v45; + + @Column(name = "v_46") + private Double v46; + + @Column(name = "v_47") + private Double v47; + + @Column(name = "v_48") + private Double v48; + + @Column(name = "v_49") + private Double v49; + + @Column(name = "v_50") + private Double v50; + +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayPlt.java b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayPlt.java new file mode 100644 index 000000000..cff9f5024 --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayPlt.java @@ -0,0 +1,43 @@ +package com.njcn.influx.pojo.po.day; + +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.njcn.common.utils.serializer.InstantDateSerializer; +import lombok.Data; +import org.influxdb.annotation.Column; +import org.influxdb.annotation.Measurement; +import org.influxdb.annotation.TimeColumn; + +import java.time.Instant; + +/** + * 类的介绍： + * + * @author xuyang + * @version 1.0.0 + * @createTime 2022/4/12 16:01 + */ +@Data +@Measurement(name = "day_plt") +public class DayPlt { + + @Column(name = "time") + @TimeColumn + @JsonSerialize(using = InstantDateSerializer.class) + private Instant time; + + @Column(name = "line_id",tag = true) + private String lineId; + + @Column(name = "phasic_type",tag = true) + private String phaseType; + + @Column(name = "value_type",tag = true) + private String valueType; + + @Column(name = "quality_flag",tag = true) + private String qualityFlag; + + @Column(name = "plt") + private Double plt; + +} diff --git a/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayV.java b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayV.java new file mode 100644 index 000000000..3bb6cdba8 --- /dev/null +++ b/pqs-influx/src/main/java/com/njcn/influx/pojo/po/day/DayV.java @@ -0,0 +1,235 @@ +package com.njcn.influx.pojo.po.day; + +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.njcn.common.utils.serializer.InstantDateSerializer; +import lombok.Data; +import org.influxdb.annotation.Column; +import org.influxdb.annotation.Measurement; +import org.influxdb.annotation.TimeColumn; + +import java.time.Instant; + +/** + * 类的介绍： + * + * @author xuyang + * @version 1.0.0 + * @createTime 2022/4/7 10:00 + */ +@Data +@Measurement(name = "day_v") +public class DayV { + + @Column(name = "time",tag = true) + @TimeColumn + @JsonSerialize(using = InstantDateSerializer.class) + private Instant time; + + @Column(name = "freq") + private Double freq; + + @Column(name = "freq_dev") + private Double freqDev; + + @Column(name = "quality_flag",tag = true) + private String qualityFlag; + + @Column(name = "rms") + private Double rms; + + @Column(name = "rms_lvr") + private Double rmsLvr; + + @Column(name = "vl_dev") + private Double vlDev; + + @Column(name = "vu_dev") + private Double vuDev; + + @Column(name = "v_1") + private Double v1; + + @Column(name = "v_2") + private Double v2; + + @Column(name = "v_3") + private Double v3; + + @Column(name = "v_4") + private Double v4; + + @Column(name = "v_5") + private Double v5; + + @Column(name = "v_6") + private Double v6; + + @Column(name = "v_7") + private Double v7; + + @Column(name = "v_8") + private Double v8; + + @Column(name = "v_9") + private Double v9; + + @Column(name = "v_10") + private Double v10; + + @Column(name = "v_11") + private Double v11; + + @Column(name = "v_12") + private Double v12; + + @Column(name = "v_13") + private Double v13; + + @Column(name = "v_14") + private Double v14; + + @Column(name = "v_15") + private Double v15; + + @Column(name = "v_16") + private Double v16; + + @Column(name = "v_17") + private Double v17; + + @Column(name = "v_18") + private Double v18; + + @Column(name = "v_19") + private Double v19; + + @Column(name = "v_20") + private Double v20; + + @Column(name = "v_21") + private Double v21; + + @Column(name = "v_22") + private Double v22; + + @Column(name = "v_23") + private Double v23; + + @Column(name = "v_24") + private Double v24; + + @Column(name = "v_25") + private Double v25; + + @Column(name = "v_26") + private Double v26; + + @Column(name = "v_27") + private Double v27; + + @Column(name = "v_28") + private Double v28; + + @Column(name = "v_29") + private Double v29; + + @Column(name = "v_30") + private Double v30; + + @Column(name = "v_31") + private Double v31; + + @Column(name = "v_32") + private Double v32; + + @Column(name = "v_33") + private Double v33; + + @Column(name = "v_34") + private Double v34; + + @Column(name = "v_35") + private Double v35; + + @Column(name = "v_36") + private Double v36; + + @Column(name = "v_37") + private Double v37; + + @Column(name = "v_38") + private Double v38; + + @Column(name = "v_39") + private Double v39; + + @Column(name = "v_40") + private Double v40; + + @Column(name = "v_41") + private Double v41; + + @Column(name = "v_42") + private Double v42; + + @Column(name = "v_43") + private Double v43; + + @Column(name = "v_44") + private Double v44; + + @Column(name = "v_45") + private Double v45; + + @Column(name = "v_46") + private Double v46; + + @Column(name = "v_47") + private Double v47; + + @Column(name = "v_48") + private Double v48; + + @Column(name = "v_49") + private Double v49; + + @Column(name = "v_50") + private Double v50; + + @Column(name = "v_neg") + private Double vNeg; + + @Column(name = "v_pos") + private Double vPos; + + @Column(name = "v_thd") + private Double vThd; + + @Column(name = "v_unbalance") + private Double vUnbalance; + + @Column(name = "v_zero") + private Double vZero; + + @Column(name = "line_id",tag = true) + private String lineId; + + @Column(name = "phasic_type",tag = true) + private String phasicType; + + @Column(name = "value_type",tag = true) + private String valueType; + + + //自定义字段-总计算次数 + @Column(name = "all_time") + private Integer allTime; + + //自定义字段 + @Column(name = "mean") + private Double mean; + + //自定义字段 + @Column(name = "count") + private Integer count; +} diff --git a/pqs-system/system-api/src/main/java/com/njcn/system/enums/DicDataEnum.java b/pqs-system/system-api/src/main/java/com/njcn/system/enums/DicDataEnum.java index 29337a138..a2b74e3d9 100644 --- a/pqs-system/system-api/src/main/java/com/njcn/system/enums/DicDataEnum.java +++ b/pqs-system/system-api/src/main/java/com/njcn/system/enums/DicDataEnum.java @@ -395,7 +395,6 @@ public enum DicDataEnum { SET("定值","Set"), INSET("内部定值","InSet"), CTRL("控制","Ctrl"), - TARGET_LIMIT("指标越限判断模板","target_limit"), /** * 暂降原因 */