From 0bb6fb99126d7d4a38f8423c0cca8e1a1c9609d4 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=9B=A8=E6=9C=A8c?= <857448963@qq.com>
Date: Wed, 22 Nov 2023 10:47:00 +0800
Subject: [PATCH] =?UTF-8?q?pms=E7=AE=97=E6=B3=95=E4=BB=A3=E7=A0=81?=
=?UTF-8?q?=E6=8F=90=E4=BA=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../harmonic/pojo/po/dim/RDimObjGlobalD.java | 50 +++++++++
.../harmonic/pojo/po/dim/RDimObjGlobalM.java | 50 +++++++++
.../harmonic/pojo/po/dim/RDimObjGlobalY.java | 50 +++++++++
.../harmonic/pojo/po/dim/RDimObjTargetD.java | 55 +++++++++
.../harmonic/pojo/po/dim/RDimObjTargetM.java | 55 +++++++++
.../harmonic/pojo/po/dim/RDimObjTargetY.java | 55 +++++++++
.../pojo/po/dim/RDimStationBaseD.java | 73 ++++++++++++
.../pojo/po/dim/RDimStationTargetD.java | 64 +++++++++++
.../pojo/po/dim/RDimStationTargetM.java | 64 +++++++++++
.../pojo/po/dim/RDimStationTargetY.java | 64 +++++++++++
.../com/njcn/prepare/ExecutionCenter.java | 22 ++--
.../njcn/prepare/executor/PmsDimExecutor.java | 33 ++++++
.../dim/IRDimBusGlobalDController.java | 51 +++++++++
.../mysql/dim/RDimObjGlobalDMapper.java | 16 +++
.../mysql/dim/RDimObjGlobalMMapper.java | 16 +++
.../mysql/dim/RDimObjGlobalYMapper.java | 16 +++
.../mysql/dim/RDimObjTargetDMapper.java | 16 +++
.../mysql/dim/RDimObjTargetMMapper.java | 16 +++
.../mysql/dim/RDimObjTargetYMapper.java | 16 +++
.../mysql/dim/RDimStationBaseDMapper.java | 16 +++
.../mysql/dim/RDimStationTargetDMapper.java | 16 +++
.../mysql/dim/RDimStationTargetMMapper.java | 16 +++
.../mysql/dim/RDimStationTargetYMapper.java | 16 +++
.../mysql/dim/IRDimBusGlobalDService.java | 9 +-
.../mysql/dim/IRDimObjGlobalDService.java | 16 +++
.../mysql/dim/IRDimObjGlobalMService.java | 16 +++
.../mysql/dim/IRDimObjGlobalYService.java | 16 +++
.../mysql/dim/IRDimObjTargetDService.java | 16 +++
.../mysql/dim/IRDimObjTargetMService.java | 16 +++
.../mysql/dim/IRDimObjTargetYService.java | 16 +++
.../mysql/dim/IRDimStationBaseDService.java | 26 +++++
.../mysql/dim/IRDimStationTargetDService.java | 26 +++++
.../mysql/dim/IRDimStationTargetMService.java | 26 +++++
.../mysql/dim/IRDimStationTargetYService.java | 16 +++
.../dim/impl/RDimBusGlobalDServiceImpl.java | 106 +++++++++++++-----
.../dim/impl/RDimObjGlobalDServiceImpl.java | 21 ++++
.../dim/impl/RDimObjGlobalMServiceImpl.java | 21 ++++
.../dim/impl/RDimObjGlobalYServiceImpl.java | 21 ++++
.../dim/impl/RDimObjTargetDServiceImpl.java | 21 ++++
.../dim/impl/RDimObjTargetMServiceImpl.java | 21 ++++
.../dim/impl/RDimObjTargetYServiceImpl.java | 21 ++++
.../dim/impl/RDimStationBaseDServiceImpl.java | 69 ++++++++++++
.../impl/RDimStationTargetDServiceImpl.java | 86 ++++++++++++++
.../impl/RDimStationTargetMServiceImpl.java | 95 ++++++++++++++++
.../impl/RDimStationTargetYServiceImpl.java | 21 ++++
45 files changed, 1504 insertions(+), 44 deletions(-)
create mode 100644 pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjGlobalD.java
create mode 100644 pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjGlobalM.java
create mode 100644 pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjGlobalY.java
create mode 100644 pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjTargetD.java
create mode 100644 pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjTargetM.java
create mode 100644 pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjTargetY.java
create mode 100644 pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimStationBaseD.java
create mode 100644 pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimStationTargetD.java
create mode 100644 pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimStationTargetM.java
create mode 100644 pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimStationTargetY.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/controller/dim/IRDimBusGlobalDController.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjGlobalDMapper.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjGlobalMMapper.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjGlobalYMapper.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjTargetDMapper.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjTargetMMapper.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjTargetYMapper.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimStationBaseDMapper.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimStationTargetDMapper.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimStationTargetMMapper.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimStationTargetYMapper.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjGlobalDService.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjGlobalMService.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjGlobalYService.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjTargetDService.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjTargetMService.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjTargetYService.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimStationBaseDService.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimStationTargetDService.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimStationTargetMService.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimStationTargetYService.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjGlobalDServiceImpl.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjGlobalMServiceImpl.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjGlobalYServiceImpl.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjTargetDServiceImpl.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjTargetMServiceImpl.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjTargetYServiceImpl.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimStationBaseDServiceImpl.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimStationTargetDServiceImpl.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimStationTargetMServiceImpl.java
create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimStationTargetYServiceImpl.java
diff --git a/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjGlobalD.java b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjGlobalD.java
new file mode 100644
index 000000000..c792273b7
--- /dev/null
+++ b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjGlobalD.java
@@ -0,0 +1,50 @@
+package com.njcn.harmonic.pojo.po.dim;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.njcn.db.bo.BaseEntity;
+import java.io.Serializable;
+import java.time.LocalDate;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ *
+ *
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+@Getter
+@Setter
+@TableName("r_dim_obj_global_d")
+public class RDimObjGlobalD extends BaseEntity {
+
+ private static final long serialVersionUID = 1L;
+
+ private String orgId;
+
+ private LocalDate statisDate;
+
+ /**
+ * 源荷对象类型
+ */
+ private String objectType;
+
+ /**
+ * **源荷对象监测率（%）
+ */
+ private Float monitorRate;
+
+ /**
+ * **源荷对象超标占比（%）
+ */
+ private Float limitRate;
+
+ /**
+ * **源荷对象平均超标占比（%）
+ */
+ private Float limitAvgRate;
+
+
+}
diff --git a/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjGlobalM.java b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjGlobalM.java
new file mode 100644
index 000000000..e118e2eb7
--- /dev/null
+++ b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjGlobalM.java
@@ -0,0 +1,50 @@
+package com.njcn.harmonic.pojo.po.dim;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.njcn.db.bo.BaseEntity;
+import java.io.Serializable;
+import java.time.LocalDate;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ *
+ *
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+@Getter
+@Setter
+@TableName("r_dim_obj_global_m")
+public class RDimObjGlobalM extends BaseEntity {
+
+ private static final long serialVersionUID = 1L;
+
+ private String orgId;
+
+ private LocalDate statisDate;
+
+ /**
+ * 源荷对象类型
+ */
+ private String objectType;
+
+ /**
+ * **源荷对象监测率（%）
+ */
+ private Float monitorRate;
+
+ /**
+ * **源荷对象超标占比（%）
+ */
+ private Float limitRate;
+
+ /**
+ * **源荷对象平均超标占比（%）
+ */
+ private Float limitAvgRate;
+
+
+}
diff --git a/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjGlobalY.java b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjGlobalY.java
new file mode 100644
index 000000000..b75f235e2
--- /dev/null
+++ b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjGlobalY.java
@@ -0,0 +1,50 @@
+package com.njcn.harmonic.pojo.po.dim;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.njcn.db.bo.BaseEntity;
+import java.io.Serializable;
+import java.time.LocalDate;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ *
+ *
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+@Getter
+@Setter
+@TableName("r_dim_obj_global_y")
+public class RDimObjGlobalY extends BaseEntity {
+
+ private static final long serialVersionUID = 1L;
+
+ private String orgId;
+
+ private LocalDate statisDate;
+
+ /**
+ * 源荷对象类型
+ */
+ private String objectType;
+
+ /**
+ * **源荷对象监测率（%）
+ */
+ private Float monitorRate;
+
+ /**
+ * **源荷对象超标占比（%）
+ */
+ private Float limitRate;
+
+ /**
+ * **源荷对象平均超标占比（%）
+ */
+ private Float limitAvgRate;
+
+
+}
diff --git a/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjTargetD.java b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjTargetD.java
new file mode 100644
index 000000000..8e56a3bb8
--- /dev/null
+++ b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjTargetD.java
@@ -0,0 +1,55 @@
+package com.njcn.harmonic.pojo.po.dim;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.njcn.db.bo.BaseEntity;
+import java.io.Serializable;
+import java.time.LocalDate;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ *
+ *
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+@Getter
+@Setter
+@TableName("r_dim_obj_target_d")
+public class RDimObjTargetD extends BaseEntity {
+
+ private static final long serialVersionUID = 1L;
+
+ private String orgId;
+
+ private LocalDate statisDate;
+
+ /**
+ * 源荷对象类型
+ */
+ private String objectType;
+
+ /**
+ * 稳态指标类型
+ */
+ private String targetType;
+
+ /**
+ * **源荷对象**指标超标占比（%）
+ */
+ private Float monitorRate;
+
+ /**
+ * **源荷对象**指标平均超标占比（%）
+ */
+ private Float limitRate;
+
+ /**
+ * **源荷对象**指标平均超标天数（天）
+ */
+ private Float limitAvgRate;
+
+
+}
diff --git a/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjTargetM.java b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjTargetM.java
new file mode 100644
index 000000000..6b66d973c
--- /dev/null
+++ b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjTargetM.java
@@ -0,0 +1,55 @@
+package com.njcn.harmonic.pojo.po.dim;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.njcn.db.bo.BaseEntity;
+import java.io.Serializable;
+import java.time.LocalDate;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ *
+ *
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+@Getter
+@Setter
+@TableName("r_dim_obj_target_m")
+public class RDimObjTargetM extends BaseEntity {
+
+ private static final long serialVersionUID = 1L;
+
+ private String orgId;
+
+ private LocalDate statisDate;
+
+ /**
+ * 源荷对象类型
+ */
+ private String objectType;
+
+ /**
+ * 稳态指标类型
+ */
+ private String targetType;
+
+ /**
+ * **源荷对象**指标超标占比（%）
+ */
+ private Float monitorRate;
+
+ /**
+ * **源荷对象**指标平均超标占比（%）
+ */
+ private Float limitRate;
+
+ /**
+ * **源荷对象**指标平均超标天数（天）
+ */
+ private Float limitAvgRate;
+
+
+}
diff --git a/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjTargetY.java b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjTargetY.java
new file mode 100644
index 000000000..1d447377b
--- /dev/null
+++ b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimObjTargetY.java
@@ -0,0 +1,55 @@
+package com.njcn.harmonic.pojo.po.dim;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.njcn.db.bo.BaseEntity;
+import java.io.Serializable;
+import java.time.LocalDate;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ *
+ *
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+@Getter
+@Setter
+@TableName("r_dim_obj_target_y")
+public class RDimObjTargetY extends BaseEntity {
+
+ private static final long serialVersionUID = 1L;
+
+ private String orgId;
+
+ private LocalDate statisDate;
+
+ /**
+ * 源荷对象类型
+ */
+ private String objectType;
+
+ /**
+ * 稳态指标类型
+ */
+ private String targetType;
+
+ /**
+ * **源荷对象**指标超标占比（%）
+ */
+ private Float monitorRate;
+
+ /**
+ * **源荷对象**指标平均超标占比（%）
+ */
+ private Float limitRate;
+
+ /**
+ * **源荷对象**指标平均超标天数（天）
+ */
+ private Float limitAvgRate;
+
+
+}
diff --git a/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimStationBaseD.java b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimStationBaseD.java
new file mode 100644
index 000000000..7eadcaad6
--- /dev/null
+++ b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimStationBaseD.java
@@ -0,0 +1,73 @@
+package com.njcn.harmonic.pojo.po.dim;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.njcn.db.bo.BaseEntity;
+import java.io.Serializable;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ *
+ *
+ *
+ *
+ * @author cdf
+ * @since 2023-11-21
+ */
+@Getter
+@Setter
+@TableName("r_dim_station_base_d")
+public class RDimStationBaseD extends BaseEntity {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 统计时间yyyy-mm-dd
+ */
+ private LocalDate statisDate;
+
+ /**
+ * 电站id
+ */
+ private String stationId;
+
+ /**
+ * 稳态,暂态指标类型（字典）
+ */
+ private String targetType;
+
+ /**
+ * 0.稳态指标 1.暂态指标
+ */
+ private Boolean level;
+
+ /**
+ * 电压等级（字典）
+ */
+ private String voltageLevel;
+
+ /**
+ * 单位code（sys_dept表）
+ */
+ private String orgId;
+
+ /**
+ * 稳态，暂态超标次数
+ */
+ private Integer limitCount;
+
+ /**
+ * 稳态指标统计总次数
+ */
+ private Integer statisCount;
+
+ /**
+ * 状态 0.删除 1.正常
+ */
+ private Boolean state;
+
+
+
+}
diff --git a/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimStationTargetD.java b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimStationTargetD.java
new file mode 100644
index 000000000..d6bfbb020
--- /dev/null
+++ b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimStationTargetD.java
@@ -0,0 +1,64 @@
+package com.njcn.harmonic.pojo.po.dim;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.njcn.db.bo.BaseEntity;
+import java.io.Serializable;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ *
+ *
+ *
+ *
+ * @author cdf
+ * @since 2023-11-21
+ */
+@Getter
+@Setter
+@TableName("r_dim_station_target_d")
+public class RDimStationTargetD extends BaseEntity {
+
+ private static final long serialVersionUID = 1L;
+
+ private String orgId;
+
+ private LocalDate statisDate;
+
+ /**
+ * 统计类型
+ */
+ private String targetType;
+
+ /**
+ * 电压等级
+ */
+ private String voltageLevel;
+
+ /**
+ * **kV变电站**指标超标占比（%）
+ */
+ private Double limitRate;
+
+ /**
+ * **kV变电站**指标合格率（%）
+ */
+ private Double passRate;
+
+ /**
+ * **kV变电站**指标平均超标占比（%）
+ */
+ private Double limitAvgRate;
+
+ /**
+ * **kV变电站**指标平均合格率（%）
+ */
+ private Double passAvgRate;
+
+ private Integer state;
+
+
+
+}
diff --git a/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimStationTargetM.java b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimStationTargetM.java
new file mode 100644
index 000000000..81434a5ac
--- /dev/null
+++ b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimStationTargetM.java
@@ -0,0 +1,64 @@
+package com.njcn.harmonic.pojo.po.dim;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.njcn.db.bo.BaseEntity;
+import java.io.Serializable;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ *
+ *
+ *
+ *
+ * @author cdf
+ * @since 2023-11-21
+ */
+@Getter
+@Setter
+@TableName("r_dim_station_target_m")
+public class RDimStationTargetM extends BaseEntity {
+
+ private static final long serialVersionUID = 1L;
+
+ private String orgId;
+
+ private LocalDate statisDate;
+
+ /**
+ * 统计类型
+ */
+ private String targetType;
+
+ /**
+ * 电压等级
+ */
+ private String voltageLevel;
+
+ /**
+ * **kV变电站**指标超标占比（%）
+ */
+ private Double limitRate;
+
+ /**
+ * **kV变电站**指标合格率（%）
+ */
+ private Double passRate;
+
+ /**
+ * **kV变电站**指标平均超标占比（%）
+ */
+ private Double limitAvgRate;
+
+ /**
+ * **kV变电站**指标平均合格率（%）
+ */
+ private Double passAvgRate;
+
+ private Integer state;
+
+
+
+}
diff --git a/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimStationTargetY.java b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimStationTargetY.java
new file mode 100644
index 000000000..7203c5d6d
--- /dev/null
+++ b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/dim/RDimStationTargetY.java
@@ -0,0 +1,64 @@
+package com.njcn.harmonic.pojo.po.dim;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.njcn.db.bo.BaseEntity;
+import java.io.Serializable;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ *
+ *
+ *
+ *
+ * @author cdf
+ * @since 2023-11-21
+ */
+@Getter
+@Setter
+@TableName("r_dim_station_target_y")
+public class RDimStationTargetY extends BaseEntity {
+
+ private static final long serialVersionUID = 1L;
+
+ private String orgId;
+
+ private LocalDate statisDate;
+
+ /**
+ * 统计类型
+ */
+ private String targetType;
+
+ /**
+ * 电压等级
+ */
+ private String voltageLevel;
+
+ /**
+ * **kV变电站**指标超标占比（%）
+ */
+ private Double limitRate;
+
+ /**
+ * **kV变电站**指标合格率（%）
+ */
+ private Double passRate;
+
+ /**
+ * **kV变电站**指标平均超标占比（%）
+ */
+ private Double limitAvgRate;
+
+ /**
+ * **kV变电站**指标平均合格率（%）
+ */
+ private Double passAvgRate;
+
+ private Integer state;
+
+
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/ExecutionCenter.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/ExecutionCenter.java
index 8f5b01cfa..5d89cac8a 100644
--- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/ExecutionCenter.java
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/ExecutionCenter.java
@@ -11,6 +11,7 @@ import com.njcn.common.pojo.annotation.OperateInfo;
import com.njcn.common.pojo.enums.common.LogEnum;
import com.njcn.common.pojo.exception.BusinessException;
import com.njcn.device.biz.commApi.CommTerminalGeneralClient;
+import com.njcn.device.biz.pojo.dto.DeptGetChildrenDTO;
import com.njcn.device.biz.pojo.dto.DeptGetChildrenMoreDTO;
import com.njcn.device.biz.pojo.dto.DeptGetSubStationDTO;
import com.njcn.device.biz.pojo.param.DeptGetLineParam;
@@ -236,28 +237,21 @@ public class ExecutionCenter extends BaseController {
* @date 2023/11/17
*/
@OperateInfo(info = LogEnum.BUSINESS_COMMON)
- @ApiOperation("变电站算法执行链")
+ @ApiOperation("pms变电站母线算法执行链")
@PostMapping("/pmsdimexecutor")
public void pmsDimExecutor(@RequestBody BaseParam baseParam) {
String methodDescribe = getMethodDescribe("pmsdimexecutor");
//手动判断参数是否合法,
- CalculatedParam calculatedParam = judgeExecuteParam(baseParam);
+ CalculatedParam calculatedParam = judgeExecuteParam(baseParam);
// 测点索引
DeptGetLineParam deptGetLineParam = new DeptGetLineParam();
if (CollectionUtils.isEmpty(calculatedParam.getIdList())) {
Dept data = deptFeignClient.getRootDept().getData();
deptGetLineParam.setDeptId(data.getId());
- List data1 = commTerminalGeneralClient.deptSubStation(deptGetLineParam).getData();
- List stationIds = new ArrayList<>();
- for (DeptGetSubStationDTO deptGetSubStationDTO : data1) {
- Collection union = CollectionUtils.union(Optional.ofNullable(deptGetSubStationDTO.getStationIds()).orElse(new ArrayList()),
- Optional.ofNullable(deptGetSubStationDTO.getStationIds()).orElse(new ArrayList()));
- List collect = union.stream().distinct().collect(Collectors.toList());
- stationIds.addAll(collect);
- }
- stationIds = stationIds.stream().distinct().collect(Collectors.toList());
- calculatedParam.setIdList(stationIds);
+ deptGetLineParam.setSystemType(0);
+ List dept = commTerminalGeneralClient.deptGetLineList(deptGetLineParam).getData();
+ calculatedParam.setIdList(dept);
}
LiteflowResponse liteflowResponse;
if (baseParam.isRepair()) {
@@ -271,12 +265,12 @@ public class ExecutionCenter extends BaseController {
startDate = DateUtil.offsetDay(startDate, 1);
}
calculatedParam.setDataDate(DateUtil.format(startDate, DatePattern.NORM_DATE_PATTERN));
- liteflowResponse = flowExecutor.execute2Resp("sub_station", calculatedParam);
+ liteflowResponse = flowExecutor.execute2Resp("dim_station_busbar", calculatedParam);
dealResponse(calculatedParam, liteflowResponse, methodDescribe);
}
} else {
//非补招
- liteflowResponse = flowExecutor.execute2Resp("sub_station", calculatedParam);
+ liteflowResponse = flowExecutor.execute2Resp("dim_station_busbar", calculatedParam);
dealResponse(calculatedParam, liteflowResponse, methodDescribe);
}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/executor/PmsDimExecutor.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/executor/PmsDimExecutor.java
index 8f67395e3..1c6be64e4 100644
--- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/executor/PmsDimExecutor.java
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/executor/PmsDimExecutor.java
@@ -1,6 +1,12 @@
package com.njcn.prepare.executor;
+import com.njcn.device.biz.commApi.CommTerminalGeneralClient;
+import com.njcn.device.biz.pojo.dto.DeptGetChildrenDTO;
+import com.njcn.device.biz.pojo.param.DeptGetLineParam;
+import com.njcn.prepare.harmonic.pojo.bo.CalculatedParam;
import com.njcn.prepare.harmonic.service.mysql.dim.IRDimBusGlobalDService;
+import com.njcn.user.api.DeptFeignClient;
+import com.njcn.user.pojo.po.Dept;
import com.yomahub.liteflow.annotation.LiteflowComponent;
import com.yomahub.liteflow.annotation.LiteflowMethod;
import com.yomahub.liteflow.core.NodeComponent;
@@ -8,6 +14,9 @@ import com.yomahub.liteflow.enums.LiteFlowMethodEnum;
import com.yomahub.liteflow.enums.NodeTypeEnum;
import lombok.RequiredArgsConstructor;
+import java.util.List;
+import java.util.Objects;
+
/**
* pqs
*
@@ -18,6 +27,12 @@ import lombok.RequiredArgsConstructor;
@RequiredArgsConstructor
public class PmsDimExecutor extends BaseExecutor{
+ private final DeptFeignClient deptFeignClient;
+
+ private final CommTerminalGeneralClient commTerminalGeneralClient;
+
+
+
private final IRDimBusGlobalDService irDimBusGlobalDService;
@LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "dimBusGlobalAccess", nodeType = NodeTypeEnum.COMMON)
@@ -26,6 +41,24 @@ public class PmsDimExecutor extends BaseExecutor{
}
@LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "dimBusGlobalAccess", nodeType = NodeTypeEnum.COMMON)
public void dimBusGlobalProcess(NodeComponent bindCmp) {
+ String tag = bindCmp.getTag();
+ CalculatedParam calculatedParam = bindCmp.getRequestData();
+ if (Objects.equals(tag,"r_dim_bus_global_d")){
+ //日表
+ irDimBusGlobalDService.globalCalBusBarDay(calculatedParam);
+ } else if (Objects.equals(tag,"r_dim_bus_global_m")) {
+ //数据补招不执行非日表算法
+ if (!calculatedParam.isRepair()) {
+ //月表
+ irDimBusGlobalDService.globalCalBusBarMonth(calculatedParam);
+ }
+ } else if (Objects.equals(tag,"r_dim_bus_global_y")) {
+ //数据补招不执行非日表算法
+ if (!calculatedParam.isRepair()) {
+ //季表
+ irDimBusGlobalDService.globalCalBusBarDay(calculatedParam);
+ }
+ }
irDimBusGlobalDService.globalCalBusBarDay(bindCmp.getRequestData());
}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/controller/dim/IRDimBusGlobalDController.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/controller/dim/IRDimBusGlobalDController.java
new file mode 100644
index 000000000..1655a92a7
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/controller/dim/IRDimBusGlobalDController.java
@@ -0,0 +1,51 @@
+package com.njcn.prepare.harmonic.controller.dim;
+
+import com.njcn.common.pojo.annotation.OperateInfo;
+import com.njcn.common.pojo.enums.common.LogEnum;
+import com.njcn.common.pojo.enums.response.CommonResponseEnum;
+import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.common.utils.HttpResultUtil;
+import com.njcn.device.biz.pojo.dto.DeptGetChildrenMoreDTO;
+import com.njcn.prepare.harmonic.pojo.bo.CalculatedParam;
+import com.njcn.prepare.harmonic.pojo.param.DeviceAbnormaStatisticsParam;
+import com.njcn.prepare.harmonic.service.mysql.dim.IRDimBusGlobalDService;
+import com.njcn.web.controller.BaseController;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiOperation;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * pqs
+ *
+ * @author cdf
+ * @date 2023/11/20
+ */
+
+@Slf4j
+@Api(tags = "母线变电站每日运行情况统计")
+@RestController
+@RequestMapping("/dimGlobal")
+@RequiredArgsConstructor
+public class IRDimBusGlobalDController extends BaseController {
+
+ private final IRDimBusGlobalDService irDimBusGlobalDService;
+
+ @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+ @PostMapping("/dayDimGlobal")
+ @ApiOperation("母线变电站每日运行情况统计")
+ @ApiImplicitParam(name = "calculatedParam", value = "参数", required = true)
+ public HttpResult dayDimGlobal(@RequestBody CalculatedParam calculatedParam) {
+ String methodDescribe = getMethodDescribe("dayDimGlobal");
+ irDimBusGlobalDService.globalCalBusBarDay(calculatedParam);
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
+ }
+
+
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjGlobalDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjGlobalDMapper.java
new file mode 100644
index 000000000..3b81078af
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjGlobalDMapper.java
@@ -0,0 +1,16 @@
+package com.njcn.prepare.harmonic.mapper.mysql.dim;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.harmonic.pojo.po.dim.RDimObjGlobalD;
+
+/**
+ *
+ * Mapper 接口
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+public interface RDimObjGlobalDMapper extends BaseMapper {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjGlobalMMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjGlobalMMapper.java
new file mode 100644
index 000000000..cc5ec23d1
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjGlobalMMapper.java
@@ -0,0 +1,16 @@
+package com.njcn.prepare.harmonic.mapper.mysql.dim;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.harmonic.pojo.po.dim.RDimObjGlobalM;
+
+/**
+ *
+ * Mapper 接口
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+public interface RDimObjGlobalMMapper extends BaseMapper {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjGlobalYMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjGlobalYMapper.java
new file mode 100644
index 000000000..565376da1
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjGlobalYMapper.java
@@ -0,0 +1,16 @@
+package com.njcn.prepare.harmonic.mapper.mysql.dim;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.harmonic.pojo.po.dim.RDimObjGlobalY;
+
+/**
+ *
+ * Mapper 接口
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+public interface RDimObjGlobalYMapper extends BaseMapper {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjTargetDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjTargetDMapper.java
new file mode 100644
index 000000000..931474416
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjTargetDMapper.java
@@ -0,0 +1,16 @@
+package com.njcn.prepare.harmonic.mapper.mysql.dim;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.harmonic.pojo.po.dim.RDimObjTargetD;
+
+/**
+ *
+ * Mapper 接口
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+public interface RDimObjTargetDMapper extends BaseMapper {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjTargetMMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjTargetMMapper.java
new file mode 100644
index 000000000..e56583ac2
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjTargetMMapper.java
@@ -0,0 +1,16 @@
+package com.njcn.prepare.harmonic.mapper.mysql.dim;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.harmonic.pojo.po.dim.RDimObjTargetM;
+
+/**
+ *
+ * Mapper 接口
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+public interface RDimObjTargetMMapper extends BaseMapper {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjTargetYMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjTargetYMapper.java
new file mode 100644
index 000000000..bec4b2e8e
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimObjTargetYMapper.java
@@ -0,0 +1,16 @@
+package com.njcn.prepare.harmonic.mapper.mysql.dim;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.harmonic.pojo.po.dim.RDimObjTargetY;
+
+/**
+ *
+ * Mapper 接口
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+public interface RDimObjTargetYMapper extends BaseMapper {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimStationBaseDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimStationBaseDMapper.java
new file mode 100644
index 000000000..6485e1166
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimStationBaseDMapper.java
@@ -0,0 +1,16 @@
+package com.njcn.prepare.harmonic.mapper.mysql.dim;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.harmonic.pojo.po.dim.RDimStationBaseD;
+
+/**
+ *
+ * Mapper 接口
+ *
+ *
+ * @author cdf
+ * @since 2023-11-21
+ */
+public interface RDimStationBaseDMapper extends BaseMapper {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimStationTargetDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimStationTargetDMapper.java
new file mode 100644
index 000000000..2e1854fce
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimStationTargetDMapper.java
@@ -0,0 +1,16 @@
+package com.njcn.prepare.harmonic.mapper.mysql.dim;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.harmonic.pojo.po.dim.RDimStationTargetD;
+
+/**
+ *
+ * Mapper 接口
+ *
+ *
+ * @author cdf
+ * @since 2023-11-21
+ */
+public interface RDimStationTargetDMapper extends BaseMapper {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimStationTargetMMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimStationTargetMMapper.java
new file mode 100644
index 000000000..d016b5bf5
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimStationTargetMMapper.java
@@ -0,0 +1,16 @@
+package com.njcn.prepare.harmonic.mapper.mysql.dim;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.harmonic.pojo.po.dim.RDimStationTargetM;
+
+/**
+ *
+ * Mapper 接口
+ *
+ *
+ * @author cdf
+ * @since 2023-11-21
+ */
+public interface RDimStationTargetMMapper extends BaseMapper {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimStationTargetYMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimStationTargetYMapper.java
new file mode 100644
index 000000000..b76d4bc63
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/dim/RDimStationTargetYMapper.java
@@ -0,0 +1,16 @@
+package com.njcn.prepare.harmonic.mapper.mysql.dim;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.harmonic.pojo.po.dim.RDimStationTargetY;
+
+/**
+ *
+ * Mapper 接口
+ *
+ *
+ * @author cdf
+ * @since 2023-11-21
+ */
+public interface RDimStationTargetYMapper extends BaseMapper {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimBusGlobalDService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimBusGlobalDService.java
index 3b71a2db1..5c7fb9645 100644
--- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimBusGlobalDService.java
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimBusGlobalDService.java
@@ -3,6 +3,7 @@ package com.njcn.prepare.harmonic.service.mysql.dim;
import com.baomidou.mybatisplus.extension.service.IService;
import com.github.jeffreyning.mybatisplus.service.IMppService;
+import com.njcn.device.biz.pojo.dto.DeptGetChildrenDTO;
import com.njcn.harmonic.pojo.po.dim.RDimBusGlobalD;
import com.njcn.prepare.harmonic.pojo.bo.CalculatedParam;
@@ -16,6 +17,12 @@ import com.njcn.prepare.harmonic.pojo.bo.CalculatedParam;
*/
public interface IRDimBusGlobalDService extends IMppService {
- public void globalCalBusBarDay(CalculatedParam calculatedParam);
+ void globalCalBusBarDay(CalculatedParam calculatedParam);
+
+
+ void globalCalBusBarMonth(CalculatedParam calculatedParam);
+
+
+ void globalCalBusBarYear(CalculatedParam calculatedParam);
}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjGlobalDService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjGlobalDService.java
new file mode 100644
index 000000000..cbd6b317c
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjGlobalDService.java
@@ -0,0 +1,16 @@
+package com.njcn.prepare.harmonic.service.mysql.dim;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.njcn.harmonic.pojo.po.dim.RDimObjGlobalD;
+
+/**
+ *
+ * 服务类
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+public interface IRDimObjGlobalDService extends IService {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjGlobalMService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjGlobalMService.java
new file mode 100644
index 000000000..cdffa0dd0
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjGlobalMService.java
@@ -0,0 +1,16 @@
+package com.njcn.prepare.harmonic.service.mysql.dim;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.njcn.harmonic.pojo.po.dim.RDimObjGlobalM;
+
+/**
+ *
+ * 服务类
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+public interface IRDimObjGlobalMService extends IService {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjGlobalYService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjGlobalYService.java
new file mode 100644
index 000000000..83d266b6b
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjGlobalYService.java
@@ -0,0 +1,16 @@
+package com.njcn.prepare.harmonic.service.mysql.dim;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.njcn.harmonic.pojo.po.dim.RDimObjGlobalY;
+
+/**
+ *
+ * 服务类
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+public interface IRDimObjGlobalYService extends IService {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjTargetDService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjTargetDService.java
new file mode 100644
index 000000000..da3ab89d5
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjTargetDService.java
@@ -0,0 +1,16 @@
+package com.njcn.prepare.harmonic.service.mysql.dim;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.njcn.harmonic.pojo.po.dim.RDimObjTargetD;
+
+/**
+ *
+ * 服务类
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+public interface IRDimObjTargetDService extends IService {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjTargetMService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjTargetMService.java
new file mode 100644
index 000000000..5ea63ef2a
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjTargetMService.java
@@ -0,0 +1,16 @@
+package com.njcn.prepare.harmonic.service.mysql.dim;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.njcn.harmonic.pojo.po.dim.RDimObjTargetM;
+
+/**
+ *
+ * 服务类
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+public interface IRDimObjTargetMService extends IService {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjTargetYService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjTargetYService.java
new file mode 100644
index 000000000..1e0f9613e
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimObjTargetYService.java
@@ -0,0 +1,16 @@
+package com.njcn.prepare.harmonic.service.mysql.dim;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.njcn.harmonic.pojo.po.dim.RDimObjTargetY;
+
+/**
+ *
+ * 服务类
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+public interface IRDimObjTargetYService extends IService {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimStationBaseDService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimStationBaseDService.java
new file mode 100644
index 000000000..274bfc48b
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimStationBaseDService.java
@@ -0,0 +1,26 @@
+package com.njcn.prepare.harmonic.service.mysql.dim;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.njcn.device.biz.pojo.dto.DeptGetChildrenDTO;
+import com.njcn.harmonic.pojo.po.dim.RDimStationBaseD;
+import com.njcn.prepare.harmonic.pojo.bo.CalculatedParam;
+
+/**
+ *
+ * 服务类
+ *
+ *
+ * @author cdf
+ * @since 2023-11-21
+ */
+public interface IRDimStationBaseDService extends IService {
+
+
+ /**
+ * 统计每天变电站运行情况
+ * @author cdf
+ * @date 2023/11/21
+ */
+ void stationStatisticDay(CalculatedParam calculatedParam);
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimStationTargetDService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimStationTargetDService.java
new file mode 100644
index 000000000..24b93b4f2
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimStationTargetDService.java
@@ -0,0 +1,26 @@
+package com.njcn.prepare.harmonic.service.mysql.dim;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.njcn.device.biz.pojo.dto.DeptGetBase;
+import com.njcn.harmonic.pojo.po.dim.RDimStationTargetD;
+import com.njcn.prepare.harmonic.pojo.bo.CalculatedParam;
+
+/**
+ *
+ * 服务类
+ *
+ *
+ * @author cdf
+ * @since 2023-11-21
+ */
+public interface IRDimStationTargetDService extends IService {
+
+
+
+ /**
+ * **kV变电站**指标超标占比（%）
+ * @author cdf
+ * @date 2023/11/21
+ */
+ void calDimStationTargetDay(CalculatedParam calculatedParam);
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimStationTargetMService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimStationTargetMService.java
new file mode 100644
index 000000000..d2935dfe0
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimStationTargetMService.java
@@ -0,0 +1,26 @@
+package com.njcn.prepare.harmonic.service.mysql.dim;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.njcn.device.biz.pojo.dto.DeptGetBase;
+import com.njcn.harmonic.pojo.po.dim.RDimStationTargetM;
+import com.njcn.prepare.harmonic.pojo.bo.CalculatedParam;
+
+/**
+ *
+ * 服务类
+ *
+ *
+ * @author cdf
+ * @since 2023-11-21
+ */
+public interface IRDimStationTargetMService extends IService {
+
+
+
+ /**
+ * **kV变电站**指标超标占比（%）
+ * @author cdf
+ * @date 2023/11/21
+ */
+ void calDimStationTargetMonth(CalculatedParam calculatedParam);
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimStationTargetYService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimStationTargetYService.java
new file mode 100644
index 000000000..32e2fabcb
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/IRDimStationTargetYService.java
@@ -0,0 +1,16 @@
+package com.njcn.prepare.harmonic.service.mysql.dim;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.njcn.harmonic.pojo.po.dim.RDimStationTargetY;
+
+/**
+ *
+ * 服务类
+ *
+ *
+ * @author cdf
+ * @since 2023-11-21
+ */
+public interface IRDimStationTargetYService extends IService {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimBusGlobalDServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimBusGlobalDServiceImpl.java
index 529ff044b..82ae1b983 100644
--- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimBusGlobalDServiceImpl.java
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimBusGlobalDServiceImpl.java
@@ -1,7 +1,11 @@
package com.njcn.prepare.harmonic.service.mysql.dim.impl;
+import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.collection.CollectionUtil;
+import cn.hutool.core.date.DatePattern;
+import cn.hutool.core.date.DateTime;
+import cn.hutool.core.date.DateUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
@@ -78,40 +82,35 @@ public class RDimBusGlobalDServiceImpl extends MppServiceImpl calculatedParam) {
List poList = new ArrayList<>();
LocalDate date = LocalDate.parse(calculatedParam.getDataDate());
List pmsMidLedgerList = pmsCountLedgerMapper.newDateData();
- Map map = pmsMidLedgerList.stream().collect(Collectors.toMap(PmsCountLedger::getSection, Function.identity()));
+ Map map = pmsMidLedgerList.stream().collect(Collectors.toMap(PmsCountLedger::getSection, Function.identity()));
- Dept dept = deptFeignClient.getRootDept().getData();
-
- //获取所有层级单位
- DeptGetLineParam deptGetLineParam = new DeptGetLineParam();
- deptGetLineParam.setDeptId(dept.getId());
- deptGetLineParam.setSystemType(0);
- List deptList = commTerminalGeneralClient.deptGetLineList(deptGetLineParam).getData();
+ List deptList = calculatedParam.getIdList();
for (DeptGetChildrenDTO dto : deptList) {
-
Integer stationNum;
Integer busBarNum;
- if(map.containsKey(dto.getDeptId())){
+ if (map.containsKey(dto.getDeptId())) {
PmsCountLedger pmsCountLedger = map.get(dto.getDeptId());
- stationNum = pmsCountLedger.getSubCount();
+ stationNum = pmsCountLedger.getSubCount();
busBarNum = pmsCountLedger.getSubvCount();
- }else {
+
+ if (stationNum == 0 || busBarNum == 0) {
+ continue;
+ }
+ } else {
continue;
}
-
- RDimBusGlobalD rDimBusGlobalD = new RDimBusGlobalD();
- rDimBusGlobalD.setOrgId(dto.getDeptId());
- rDimBusGlobalD.setStatisDate(date);
-
List monitorIds = dto.getLineIds();
if (CollectionUtil.isNotEmpty(monitorIds)) {
+ RDimBusGlobalD rDimBusGlobalD = new RDimBusGlobalD();
+ rDimBusGlobalD.setOrgId(dto.getDeptId());
+ rDimBusGlobalD.setStatisDate(date);
//先初步筛选出完整性大于95%的
LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>();
lambdaQueryWrapper.in(RStatIntegrityD::getLineIndex, monitorIds).eq(RStatIntegrityD::getTimeId, date);
@@ -121,8 +120,12 @@ public class RDimBusGlobalDServiceImpl extends MppServiceImpl goodMonitorIds = integrityDList.stream().map(RStatIntegrityD::getLineIndex).distinct().collect(Collectors.toList());
LambdaQueryWrapper monitorLambdaQueryWrapper = new LambdaQueryWrapper<>();
- monitorLambdaQueryWrapper.select(Monitor::getId, Monitor::getLineId,Monitor::getPowerrId).in(Monitor::getId, goodMonitorIds).eq(Monitor::getStatus, DataStateEnum.ENABLE.getCode());
+ monitorLambdaQueryWrapper.select(Monitor::getId, Monitor::getLineId, Monitor::getPowerrId).in(Monitor::getId, goodMonitorIds).eq(Monitor::getStatus, DataStateEnum.ENABLE.getCode());
List monitorList = pmsMonitorPOMapper.selectList(monitorLambdaQueryWrapper);
List goodLineIds = monitorList.stream().map(Monitor::getLineId).distinct().collect(Collectors.toList());
List goodStationIds = monitorList.stream().map(Monitor::getPowerrId).distinct().collect(Collectors.toList());
rDimBusGlobalD.setMonitorRate((float) goodLineIds.size() / busBarNum * 100);
- rDimBusGlobalD.setStationLimitRate((float) goodStationIds.size() / stationNum * 100);
+ rDimBusGlobalD.setStationMonitorRate((float) goodStationIds.size() / stationNum * 100);
LambdaQueryWrapper limitWrapper = new LambdaQueryWrapper<>();
limitWrapper.in(RStatLimitTargetDPO::getLineId, goodMonitorIds).eq(RStatLimitTargetDPO::getTime, date);
@@ -160,9 +167,12 @@ public class RDimBusGlobalDServiceImpl extends MppServiceImpl item.getAllTime() == 1).collect(Collectors.toList());
List dianOneIds = rStatLimitRateDPOList.stream().map(RStatLimitTargetDPO::getLineId).collect(Collectors.toList());
@@ -175,29 +185,67 @@ public class RDimBusGlobalDServiceImpl extends MppServiceImpl temMonitorList = pmsMonitorPOMapper.selectList(monitorLambdaQueryWrapper);
List targetLineIds = temMonitorList.stream().map(Monitor::getLineId).distinct().collect(Collectors.toList());
- float re = (float) targetLineIds.size() / goodLineIds.size();
+ float re = (float) targetLineIds.size() / goodLineIds.size() * 100;
rDimBusGlobalD.setLimitRate(re);
rDimBusGlobalD.setLimitAvgRate(re);
//反推电站
- List targetSubIds = temMonitorList.stream().map(Monitor::getPowerrId).distinct().collect(Collectors.toList());
- float reStation = (float) targetSubIds.size() / goodStationIds.size();
+ List targetSubIds = temMonitorList.stream().map(Monitor::getPowerrId).distinct().collect(Collectors.toList());
+ float reStation = (float) targetSubIds.size() / goodStationIds.size() * 100;
rDimBusGlobalD.setStationLimitRate(reStation);
rDimBusGlobalD.setStationLimitAvgRate(reStation);
}
}
}
+ poList.add(rDimBusGlobalD);
}
- poList.add(rDimBusGlobalD);
}
+ poList = poList.stream().peek(item -> item.setState(DataStateEnum.ENABLE.getCode())).collect(Collectors.toList());
this.saveOrUpdateBatchByMultiId(poList);
+
}
+
+ @Override
+ public void globalCalBusBarMonth(CalculatedParam calculatedParam) {
+ DateTime start = DateUtil.beginOfMonth(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMAT));
+ DateTime end = DateUtil.endOfMonth(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMAT));
+
+
+ LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>();
+ lambdaQueryWrapper.between(RDimBusGlobalD::getStatisDate, start, end)
+ .eq(RDimBusGlobalD::getState, DataStateEnum.ENABLE.getCode());
+ List dayDataList = this.list(lambdaQueryWrapper);
+
+ if (CollUtil.isNotEmpty(dayDataList)) {
+ Map deptMap = calculatedParam.getIdList().stream().collect(Collectors.toMap(DeptGetChildrenDTO::getDeptId,Function.identity()));
+ Map> map = dayDataList.stream().collect(Collectors.groupingBy(RDimBusGlobalD::getOrgId));
+
+ map.forEach((key, val) -> {
+ DeptGetChildrenDTO dto = deptMap.get(key);
+ List monitorIds = dto.getLineIds();
+
+ });
+
+ }
+
+
+ }
+
+ @Override
+ public void globalCalBusBarYear(CalculatedParam calculatedParam) {
+
+ }
+
+
}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjGlobalDServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjGlobalDServiceImpl.java
new file mode 100644
index 000000000..acd6c919d
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjGlobalDServiceImpl.java
@@ -0,0 +1,21 @@
+package com.njcn.prepare.harmonic.service.mysql.dim.impl;
+
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.njcn.harmonic.pojo.po.dim.RDimObjGlobalD;
+import com.njcn.prepare.harmonic.mapper.mysql.dim.RDimObjGlobalDMapper;
+import com.njcn.prepare.harmonic.service.mysql.dim.IRDimObjGlobalDService;
+import org.springframework.stereotype.Service;
+
+/**
+ *
+ * 服务实现类
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+@Service
+public class RDimObjGlobalDServiceImpl extends ServiceImpl implements IRDimObjGlobalDService {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjGlobalMServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjGlobalMServiceImpl.java
new file mode 100644
index 000000000..508260e70
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjGlobalMServiceImpl.java
@@ -0,0 +1,21 @@
+package com.njcn.prepare.harmonic.service.mysql.dim.impl;
+
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.njcn.harmonic.pojo.po.dim.RDimObjGlobalM;
+import com.njcn.prepare.harmonic.mapper.mysql.dim.RDimObjGlobalMMapper;
+import com.njcn.prepare.harmonic.service.mysql.dim.IRDimObjGlobalMService;
+import org.springframework.stereotype.Service;
+
+/**
+ *
+ * 服务实现类
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+@Service
+public class RDimObjGlobalMServiceImpl extends ServiceImpl implements IRDimObjGlobalMService {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjGlobalYServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjGlobalYServiceImpl.java
new file mode 100644
index 000000000..20f73ad5c
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjGlobalYServiceImpl.java
@@ -0,0 +1,21 @@
+package com.njcn.prepare.harmonic.service.mysql.dim.impl;
+
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.njcn.harmonic.pojo.po.dim.RDimObjGlobalY;
+import com.njcn.prepare.harmonic.mapper.mysql.dim.RDimObjGlobalYMapper;
+import com.njcn.prepare.harmonic.service.mysql.dim.IRDimObjGlobalYService;
+import org.springframework.stereotype.Service;
+
+/**
+ *
+ * 服务实现类
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+@Service
+public class RDimObjGlobalYServiceImpl extends ServiceImpl implements IRDimObjGlobalYService {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjTargetDServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjTargetDServiceImpl.java
new file mode 100644
index 000000000..bf255c899
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjTargetDServiceImpl.java
@@ -0,0 +1,21 @@
+package com.njcn.prepare.harmonic.service.mysql.dim.impl;
+
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.njcn.harmonic.pojo.po.dim.RDimObjTargetD;
+import com.njcn.prepare.harmonic.mapper.mysql.dim.RDimObjTargetDMapper;
+import com.njcn.prepare.harmonic.service.mysql.dim.IRDimObjTargetDService;
+import org.springframework.stereotype.Service;
+
+/**
+ *
+ * 服务实现类
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+@Service
+public class RDimObjTargetDServiceImpl extends ServiceImpl implements IRDimObjTargetDService {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjTargetMServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjTargetMServiceImpl.java
new file mode 100644
index 000000000..fb98bde29
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjTargetMServiceImpl.java
@@ -0,0 +1,21 @@
+package com.njcn.prepare.harmonic.service.mysql.dim.impl;
+
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.njcn.harmonic.pojo.po.dim.RDimObjTargetM;
+import com.njcn.prepare.harmonic.mapper.mysql.dim.RDimObjTargetMMapper;
+import com.njcn.prepare.harmonic.service.mysql.dim.IRDimObjTargetMService;
+import org.springframework.stereotype.Service;
+
+/**
+ *
+ * 服务实现类
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+@Service
+public class RDimObjTargetMServiceImpl extends ServiceImpl implements IRDimObjTargetMService {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjTargetYServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjTargetYServiceImpl.java
new file mode 100644
index 000000000..af14e6ba1
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimObjTargetYServiceImpl.java
@@ -0,0 +1,21 @@
+package com.njcn.prepare.harmonic.service.mysql.dim.impl;
+
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.njcn.harmonic.pojo.po.dim.RDimObjTargetY;
+import com.njcn.prepare.harmonic.mapper.mysql.dim.RDimObjTargetYMapper;
+import com.njcn.prepare.harmonic.service.mysql.dim.IRDimObjTargetYService;
+import org.springframework.stereotype.Service;
+
+/**
+ *
+ * 服务实现类
+ *
+ *
+ * @author cdf
+ * @since 2023-11-22
+ */
+@Service
+public class RDimObjTargetYServiceImpl extends ServiceImpl implements IRDimObjTargetYService {
+
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimStationBaseDServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimStationBaseDServiceImpl.java
new file mode 100644
index 000000000..dcf11bdd3
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimStationBaseDServiceImpl.java
@@ -0,0 +1,69 @@
+package com.njcn.prepare.harmonic.service.mysql.dim.impl;
+
+
+import cn.hutool.core.collection.CollUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.njcn.common.pojo.enums.common.DataStateEnum;
+import com.njcn.device.biz.commApi.CommTerminalGeneralClient;
+import com.njcn.device.biz.pojo.dto.DeptGetChildrenDTO;
+import com.njcn.device.biz.pojo.param.DeptGetLineParam;
+import com.njcn.device.pms.pojo.po.Monitor;
+import com.njcn.device.pms.pojo.po.ROperatingIndexM;
+import com.njcn.event.pojo.po.PmsMonitorPO;
+import com.njcn.harmonic.pojo.po.dim.RDimStationBaseD;
+import com.njcn.prepare.harmonic.mapper.mysql.dim.RDimStationBaseDMapper;
+import com.njcn.prepare.harmonic.mapper.mysql.line.PmsMonitorMapper;
+import com.njcn.prepare.harmonic.mapper.mysql.line.ROperatingMonitorDMapper;
+import com.njcn.prepare.harmonic.pojo.bo.CalculatedParam;
+import com.njcn.prepare.harmonic.pojo.mysql.ROperatingMonitorDPO;
+import com.njcn.prepare.harmonic.service.mysql.dim.IRDimStationBaseDService;
+import com.njcn.system.api.DicDataFeignClient;
+import com.njcn.system.enums.DicDataTypeEnum;
+import com.njcn.system.pojo.po.DictData;
+import com.njcn.user.api.DeptFeignClient;
+import com.njcn.user.pojo.po.Dept;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+import java.time.LocalDate;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+
+/**
+ *
+ * 服务实现类
+ *
+ *
+ * @author cdf
+ * @since 2023-11-21
+ */
+@Service
+@RequiredArgsConstructor
+public class RDimStationBaseDServiceImpl extends ServiceImpl implements IRDimStationBaseDService {
+
+ private final DeptFeignClient deptFeignClient;
+ private final CommTerminalGeneralClient commTerminalGeneralClient;
+
+ private final ROperatingMonitorDMapper rOperatingMonitorDMapper;
+
+ private final DicDataFeignClient dicDataFeignClient;
+
+ private final PmsMonitorMapper pmsMonitorMapper;
+
+ @Override
+ public void stationStatisticDay(CalculatedParam calculatedParam) {
+ List poList = new ArrayList<>();
+
+
+ LocalDate date = LocalDate.parse(calculatedParam.getDataDate());
+
+
+
+
+ }
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimStationTargetDServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimStationTargetDServiceImpl.java
new file mode 100644
index 000000000..aa08d0b07
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimStationTargetDServiceImpl.java
@@ -0,0 +1,86 @@
+package com.njcn.prepare.harmonic.service.mysql.dim.impl;
+
+
+import cn.hutool.core.collection.CollectionUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.njcn.common.pojo.enums.common.DataStateEnum;
+import com.njcn.device.biz.pojo.dto.DeptGetBase;
+import com.njcn.harmonic.pojo.po.dim.RDimStationBaseD;
+import com.njcn.harmonic.pojo.po.dim.RDimStationTargetD;
+import com.njcn.prepare.harmonic.mapper.mysql.dim.RDimStationTargetDMapper;
+import com.njcn.prepare.harmonic.pojo.bo.CalculatedParam;
+import com.njcn.prepare.harmonic.service.mysql.dim.IRDimStationBaseDService;
+import com.njcn.prepare.harmonic.service.mysql.dim.IRDimStationTargetDService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.time.LocalDate;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+/**
+ *
+ * 服务实现类
+ *
+ *
+ * @author cdf
+ * @since 2023-11-21
+ */
+@Service
+@RequiredArgsConstructor
+public class RDimStationTargetDServiceImpl extends ServiceImpl implements IRDimStationTargetDService {
+
+
+ private final IRDimStationBaseDService irDimStationBaseDService;
+
+ @Override
+ public void calDimStationTargetDay(CalculatedParam calculatedParam) {
+ List poList = new ArrayList<>();
+ LocalDate date = LocalDate.parse(calculatedParam.getDataDate());
+
+ List deptList = calculatedParam.getIdList();
+
+ for(DeptGetBase deptGetBase : deptList){
+ List deptCodes = deptGetBase.getUnitChildrenList();
+
+ LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>();
+ lambdaQueryWrapper.in(RDimStationBaseD::getOrgId,deptCodes)
+ .eq(RDimStationBaseD::getStatisDate,date).eq(RDimStationBaseD::getLevel,0);
+
+ List rDimStationBaseDList = irDimStationBaseDService.list(lambdaQueryWrapper);
+ if(CollectionUtil.isEmpty(rDimStationBaseDList)){
+ continue;
+ }
+
+
+ Map> voltageMap = rDimStationBaseDList.stream().collect(Collectors.groupingBy(RDimStationBaseD::getVoltageLevel));
+ voltageMap.forEach((voltageKey,voltageVal)->{
+ int stationNum = voltageVal.stream().map(RDimStationBaseD::getStationId).distinct().collect(Collectors.toList()).size();
+
+ Map> targetMap = voltageVal.stream().collect(Collectors.groupingBy(RDimStationBaseD::getTargetType));
+ targetMap.forEach((targetKey,targetVal)->{
+ RDimStationTargetD rDimStationTargetD = new RDimStationTargetD();
+ rDimStationTargetD.setOrgId(deptGetBase.getUnitId());
+ rDimStationTargetD.setStatisDate(LocalDate.parse(calculatedParam.getDataDate()));
+ rDimStationTargetD.setVoltageLevel(voltageKey);
+ rDimStationTargetD.setTargetType(targetKey);
+
+ List limitList = targetVal.stream().filter(targetItem->targetItem.getLimitCount()>0).map(RDimStationBaseD::getStationId).distinct().collect(Collectors.toList());
+ rDimStationTargetD.setLimitRate((double) (limitList.size() / stationNum));
+ rDimStationTargetD.setLimitAvgRate((double) (limitList.size() / stationNum));
+ //**kV变电站**指标合格率（%）
+ int limit = targetVal.stream().mapToInt(RDimStationBaseD::getLimitCount).sum();
+ int all = targetVal.stream().mapToInt(RDimStationBaseD::getStatisCount).sum();
+ rDimStationTargetD.setPassRate((double)(all-limit)/all);
+ rDimStationTargetD.setPassAvgRate((double)(all-limit)/all);
+ rDimStationTargetD.setState(DataStateEnum.ENABLE.getCode());
+ poList.add(rDimStationTargetD);
+ });
+ });
+ this.saveBatch(poList);
+ }
+ }
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimStationTargetMServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimStationTargetMServiceImpl.java
new file mode 100644
index 000000000..5e64617a2
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimStationTargetMServiceImpl.java
@@ -0,0 +1,95 @@
+package com.njcn.prepare.harmonic.service.mysql.dim.impl;
+
+
+import cn.hutool.core.collection.CollectionUtil;
+import cn.hutool.core.date.DatePattern;
+import cn.hutool.core.date.DateTime;
+import cn.hutool.core.date.DateUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.njcn.common.pojo.enums.common.DataStateEnum;
+import com.njcn.device.biz.pojo.dto.DeptGetBase;
+import com.njcn.harmonic.pojo.po.dim.RDimStationBaseD;
+import com.njcn.harmonic.pojo.po.dim.RDimStationTargetM;
+import com.njcn.prepare.harmonic.mapper.mysql.dim.RDimStationTargetMMapper;
+import com.njcn.prepare.harmonic.pojo.bo.CalculatedParam;
+import com.njcn.prepare.harmonic.service.mysql.dim.IRDimStationBaseDService;
+import com.njcn.prepare.harmonic.service.mysql.dim.IRDimStationTargetMService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.time.LocalDate;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+/**
+ *
+ * 服务实现类
+ *
+ *
+ * @author cdf
+ * @since 2023-11-21
+ */
+@Service
+@RequiredArgsConstructor
+public class RDimStationTargetMServiceImpl extends ServiceImpl implements IRDimStationTargetMService {
+
+ private final IRDimStationBaseDService irDimStationBaseDService;
+
+
+
+ @Override
+ public void calDimStationTargetMonth(CalculatedParam calculatedParam) {
+ List poList = new ArrayList<>();
+ DateTime start = DateUtil.beginOfMonth(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN));
+ DateTime end = DateUtil.endOfMonth(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN));
+
+ List deptList = calculatedParam.getIdList();
+
+ for(DeptGetBase deptGetBase : deptList){
+ List deptCodes = deptGetBase.getUnitChildrenList();
+
+ LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>();
+ lambdaQueryWrapper.in(RDimStationBaseD::getOrgId,deptCodes)
+ .between(RDimStationBaseD::getStatisDate,start,end).eq(RDimStationBaseD::getLevel,0);
+
+ List rDimStationBaseDList = irDimStationBaseDService.list(lambdaQueryWrapper);
+ if(CollectionUtil.isEmpty(rDimStationBaseDList)){
+ continue;
+ }
+
+
+ Map> voltageMap = rDimStationBaseDList.stream().collect(Collectors.groupingBy(RDimStationBaseD::getVoltageLevel));
+ voltageMap.forEach((voltageKey,voltageVal)->{
+ int stationNum = (int) voltageVal.stream().map(RDimStationBaseD::getStationId).distinct().count();
+ int stationAllNum = (int) voltageVal.stream().map(RDimStationBaseD::getStationId).count();
+
+ Map> targetMap = voltageVal.stream().collect(Collectors.groupingBy(RDimStationBaseD::getTargetType));
+ targetMap.forEach((targetKey,targetVal)->{
+ RDimStationTargetM rDimStationTargetD = new RDimStationTargetM();
+ rDimStationTargetD.setOrgId(deptGetBase.getUnitId());
+ rDimStationTargetD.setStatisDate(LocalDate.parse(calculatedParam.getDataDate()));
+ rDimStationTargetD.setVoltageLevel(voltageKey);
+ rDimStationTargetD.setTargetType(targetKey);
+
+ List limitList = targetVal.stream().filter(targetItem->targetItem.getLimitCount()>0).map(RDimStationBaseD::getStationId).distinct().collect(Collectors.toList());
+ rDimStationTargetD.setLimitRate((double) (limitList.size() / stationNum));
+
+ long limitAllList = targetVal.stream().filter(targetItem->targetItem.getLimitCount()>0).map(RDimStationBaseD::getStationId).count();
+ rDimStationTargetD.setLimitAvgRate((double) (limitAllList / stationAllNum));
+
+ //**kV变电站**指标合格率（%）
+ int limit = targetVal.stream().mapToInt(RDimStationBaseD::getLimitCount).sum();
+ int all = targetVal.stream().mapToInt(RDimStationBaseD::getStatisCount).sum();
+ rDimStationTargetD.setPassRate((double)(all-limit)/all);
+ rDimStationTargetD.setPassAvgRate((double)(all-limit)/all);
+ rDimStationTargetD.setState(DataStateEnum.ENABLE.getCode());
+ poList.add(rDimStationTargetD);
+ });
+ });
+ this.saveBatch(poList);
+ }
+ }
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimStationTargetYServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimStationTargetYServiceImpl.java
new file mode 100644
index 000000000..924cc77af
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/dim/impl/RDimStationTargetYServiceImpl.java
@@ -0,0 +1,21 @@
+package com.njcn.prepare.harmonic.service.mysql.dim.impl;
+
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.njcn.harmonic.pojo.po.dim.RDimStationTargetY;
+import com.njcn.prepare.harmonic.mapper.mysql.dim.RDimStationTargetYMapper;
+import com.njcn.prepare.harmonic.service.mysql.dim.IRDimStationTargetYService;
+import org.springframework.stereotype.Service;
+
+/**
+ *
+ * 服务实现类
+ *
+ *
+ * @author cdf
+ * @since 2023-11-21
+ */
+@Service
+public class RDimStationTargetYServiceImpl extends ServiceImpl implements IRDimStationTargetYService {
+
+}