From bc1454018165ecc894b6e13755cac08baabcf124 Mon Sep 17 00:00:00 2001
From: hongawen <83944980@qq.com>
Date: Fri, 25 Nov 2022 09:21:27 +0800
Subject: [PATCH] =?UTF-8?q?=E5=90=88=E5=B9=B6=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../njcn/event/pojo/vo/PwRStatEventOrgVO.java | 202 ++++++++++++++++++
.../majornetwork/RStatEventController.java | 101 +++++++++
.../majornetwork/RStatEventOrgController.java | 106 +++++++++
.../RStatSubstationController.java | 80 +++++++
4 files changed, 489 insertions(+)
create mode 100644 pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/PwRStatEventOrgVO.java
create mode 100644 pqs-event/event-boot/src/main/java/com/njcn/event/controller/majornetwork/RStatEventController.java
create mode 100644 pqs-event/event-boot/src/main/java/com/njcn/event/controller/majornetwork/RStatEventOrgController.java
create mode 100644 pqs-event/event-boot/src/main/java/com/njcn/event/controller/majornetwork/RStatSubstationController.java
diff --git a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/PwRStatEventOrgVO.java b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/PwRStatEventOrgVO.java
new file mode 100644
index 000000000..e23c1b5bd
--- /dev/null
+++ b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/PwRStatEventOrgVO.java
@@ -0,0 +1,202 @@
+package com.njcn.event.pojo.vo;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 监测点暂态指标数据统计表(RStatEventOrg)实体类
+ *
+ * @author yzh
+ * @since 2022-10-12 18:15:26
+ */
+
+@Data
+@ApiModel("配网-监测点暂态指标数据统计表")
+public class PwRStatEventOrgVO implements Serializable {
+ private static final long serialVersionUID = -15971491825708754L;
+
+ /**
+ * 单位ID
+ */
+ @ApiModelProperty(name = "orgNo", value = "单位ID")
+ private String orgNo;
+
+ /**
+ * 单位名称
+ */
+ @ApiModelProperty(name = "orgName", value = "单位名称")
+ private String orgName;
+
+ /**
+ * 生成数据的时间,每年统计一次
+ */
+ @ApiModelProperty(name = "dataDate", value = "生成数据的时间,每年统计一次")
+ private Date dataDate;
+
+ /**
+ * 监测点类别
+ */
+ @ApiModelProperty(name = "measurementTypeClass",value = "监测点类别")
+ private String measurementTypeClass;
+
+ /**
+ * 日均有效接入监测点数
+ */
+ @ApiModelProperty(name = "effectiveMeasurementAverage", value = "日均有效接入监测点数")
+ private Integer effectiveMeasurementAverage;
+
+ /**
+ * 累计有效接入监测点数
+ */
+ @ApiModelProperty(name = "effectiveMeasurementAccrued", value = "累计有效接入监测点数")
+ private Integer effectiveMeasurementAccrued;
+
+ /**
+ * 日均监测到暂态指标的监测点数
+ */
+ @ApiModelProperty(name = "eventMeasurementAverage", value = "日均监测到暂态指标的监测点数")
+ private Integer eventMeasurementAverage;
+
+ /**
+ * 累计监测到暂态指标的监测点数
+ */
+ @ApiModelProperty(name = "eventMeasurementAccrued", value = "累计监测到暂态指标的监测点数")
+ private Integer eventMeasurementAccrued;
+
+ /**
+ * 日均暂态超标监测点数占比
+ */
+ @ApiModelProperty(name = "eventMeasurementRatioAverage", value = "日均暂态超标监测点数占比")
+ private Double eventMeasurementRatioAverage;
+
+ /**
+ * 累计暂态超标监测点数占比
+ */
+ @ApiModelProperty(name = "eventMeasurementRatioAccrued", value = "累计暂态超标监测点数占比")
+ private Double eventMeasurementRatioAccrued;
+
+ /**
+ * 暂态指标发生次数
+ */
+ @ApiModelProperty(name = "eventCount",value = "暂态指标发生次数")
+ private Integer eventCount;
+ /**
+ * 暂态指标发生频次
+ */
+ @ApiModelProperty(name = "eventFreq",value = "暂态指标发生频次")
+ private Double eventFreq;
+
+ /**
+ * 日均短时中断
+ */
+ @ApiModelProperty(name = "dayShortInterruptions", value = "日均短时中断")
+ private Integer dayShortInterruptions;
+ /**
+ * 累计短时中断
+ */
+ @ApiModelProperty(name = "cumulativeShortInterruptions", value = "累计短时中断")
+ private Integer cumulativeShortInterruptions;
+ /**
+ * 日均短时中断占比
+ */
+ @ApiModelProperty(name = "dayShortInterruptionsProportion", value = "日均短时中断占比")
+ private Double dayShortInterruptionsProportion;
+ /**
+ * 累计短时中断占比
+ */
+ @ApiModelProperty(name = "cumulativeShortInterruptionsProportion", value = "累计暂态指标占比")
+ private Double cumulativeShortInterruptionsProportion;
+ /**
+ * 短时中断频次
+ */
+ @ApiModelProperty(name = "shortInterruptionsFreq",value = "短时中断频次")
+ private Double shortInterruptionsFreq;
+ /**
+ * 短时中断次数
+ */
+ @ApiModelProperty(name = "shortInterruptionsCount",value = "短时中断次数")
+ private Integer shortInterruptionsCount;
+
+
+
+
+ /**
+ * 日均电压暂升
+ */
+ @ApiModelProperty(name = "dayVoltageRise", value = "日均电压暂升")
+ private Integer dayVoltageRise;
+ /**
+ * 累计电压暂升
+ */
+ @ApiModelProperty(name = "cumulativeVoltageRise", value = "累计电压暂升")
+ private Integer cumulativeVoltageRise;
+ /**
+ * 日均电压暂升占比
+ */
+ @ApiModelProperty(name = "dayVoltageRiseProportion", value = "日均电压暂升占比")
+ private Double dayVoltageRiseProportion;
+ /**
+ * 累计电压暂升占比
+ */
+ @ApiModelProperty(name = "cumulativeVoltageRiseProportion", value = "累计电压暂升占比")
+ private Double cumulativeVoltageRiseProportion;
+ /**
+ * 电压暂升频次
+ */
+ @ApiModelProperty(name = "voltageRiseFreq",value = "电压暂升频次")
+ private Double voltageRiseFreq;
+ /**
+ * 电压暂升次数
+ */
+ @ApiModelProperty(name = "voltageRiseCount",value = "电压暂升次数")
+ private Integer voltageRiseCount;
+
+
+
+
+
+ /**
+ * 日均电压暂降
+ */
+ @ApiModelProperty(name = "dayVoltageDip", value = "日均电压暂降")
+ private Integer dayVoltageDip;
+ /**
+ * 累计电压暂降
+ */
+ @ApiModelProperty(name = "cumulativeVoltageDip", value = "累计电压暂降")
+ private Integer cumulativeVoltageDip;
+ /**
+ * 日均电压暂降占比
+ */
+ @ApiModelProperty(name = "dayVoltageDipProportion", value = "日均电压暂降占比")
+ private Double dayVoltageDipProportion;
+ /**
+ * 累计电压暂降占比
+ */
+ @ApiModelProperty(name = "cumulativeVoltageDipProportion", value = "累计电压暂降占比")
+ private Double cumulativeVoltageDipProportion;
+ /**
+ * 电压暂降频次
+ */
+ @ApiModelProperty(name = "voltageDipFreq",value = "电压暂降频次")
+ private Double voltageDipFreq;
+ /**
+ * 电压暂降次数
+ */
+ @ApiModelProperty(name = "voltageDipCount",value = "电压暂降次数")
+ private Integer voltageDipCount;
+
+
+ /**
+ * 数据类型（01：主网测点 02：配网测点）
+ */
+ @ApiModelProperty(name = "dataType",value = "数据类型（01：主网测点 02：配网测点）")
+ private String dataType;
+
+
+}
+
diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/controller/majornetwork/RStatEventController.java b/pqs-event/event-boot/src/main/java/com/njcn/event/controller/majornetwork/RStatEventController.java
new file mode 100644
index 000000000..f0e2d0726
--- /dev/null
+++ b/pqs-event/event-boot/src/main/java/com/njcn/event/controller/majornetwork/RStatEventController.java
@@ -0,0 +1,101 @@
+package com.njcn.event.controller.majornetwork;
+
+
+import com.njcn.common.pojo.annotation.OperateInfo;
+import com.njcn.common.pojo.constant.BizParamConstant;
+import com.njcn.common.pojo.enums.common.LogEnum;
+import com.njcn.common.pojo.enums.response.CommonResponseEnum;
+import com.njcn.common.pojo.param.StatisticsBizBaseParam;
+import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.common.utils.HttpResultUtil;
+import com.njcn.event.pojo.param.REventMParam;
+import com.njcn.event.pojo.vo.*;
+import com.njcn.event.service.majornetwork.RStatEventMService;
+import com.njcn.event.service.majornetwork.RStatEventQService;
+import com.njcn.event.service.majornetwork.RStatEventYService;
+import com.njcn.web.controller.BaseController;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+/**
+ *
+ * 前端控制器
+ *
+ *
+ * @author rui.wu
+ * @since 2022-10-09
+ */
+@RestController
+@RequiredArgsConstructor
+@Api(tags = "主网指标分类概览-监测点分类总览")
+@RequestMapping("/event/rStatHarmonic")
+public class RStatEventController extends BaseController {
+
+ private final RStatEventYService rStatEventYService;
+ private final RStatEventQService rStatEventQService;
+ private final RStatEventMService rStatEventMService;
+
+
+ /**
+ * 查询查询监测点稳态指标 日/月点数
+ */
+ @GetMapping("/getAllRStatEvent")
+ @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+ @ApiOperation("查询暂态累计超标监测点数")
+ public HttpResult> getAllRStatEvent(StatisticsBizBaseParam param) {
+ String methodDescribe = getMethodDescribe("getAllRStatHarmonic");
+ List rStatHarmonicMAll = null;
+ String string = param.getType().toString();
+ switch (string) {
+ //查询超标监测点数-年数据
+ case BizParamConstant.STAT_BIZ_YEAR:
+ rStatHarmonicMAll = rStatEventYService.getRStatEventYAll(param);
+ break;
+ //查询超标监测点数-季数据
+ case BizParamConstant.STAT_BIZ_QUARTER:
+ rStatHarmonicMAll = rStatEventQService.getRStatEventQAll(param);
+ break;
+ //查询超标监测点数-月数据
+ case BizParamConstant.STAT_BIZ_MONTH:
+ rStatHarmonicMAll = rStatEventMService.getRStatEventMAll(param);
+ break;
+ default:
+ break;
+ }
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, rStatHarmonicMAll, methodDescribe);
+ }
+
+ /**
+ * 暂态按电压等级统计图
+ */
+ @GetMapping("/getRStatHarmonicIconVoltage")
+ @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+ @ApiOperation("暂态电铁-频率偏差-电压统计图")
+ public HttpResult> getRStatHarmonicIconVoltage(REventMParam param) {
+ String methodDescribe = getMethodDescribe("getRStatHarmonicIconVoltage");
+ List rStatHarmonicIcon = rStatEventMService.getRStatHarmonicIcon(param);
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, rStatHarmonicIcon, methodDescribe);
+ }
+
+
+ /**
+ * 暂态电铁-频率偏差-电压统计图
+ */
+ @GetMapping("/getRStatHarmonicIconDate")
+ @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+ @ApiOperation("暂态电铁-频率偏差-越线日期统计图")
+ public HttpResult> getRStatHarmonicIconDate(REventMParam param) {
+ String methodDescribe = getMethodDescribe("getRStatHarmonicIconDate");
+ List rStatHarmonicIcon = rStatEventMService.getRStatHarmonicIcon2(param);
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, rStatHarmonicIcon, methodDescribe);
+ }
+
+
+}
+
diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/controller/majornetwork/RStatEventOrgController.java b/pqs-event/event-boot/src/main/java/com/njcn/event/controller/majornetwork/RStatEventOrgController.java
new file mode 100644
index 000000000..02537c7d8
--- /dev/null
+++ b/pqs-event/event-boot/src/main/java/com/njcn/event/controller/majornetwork/RStatEventOrgController.java
@@ -0,0 +1,106 @@
+package com.njcn.event.controller.majornetwork;
+
+
+import com.njcn.common.pojo.annotation.OperateInfo;
+import com.njcn.common.pojo.constant.BizParamConstant;
+import com.njcn.common.pojo.enums.common.LogEnum;
+import com.njcn.common.pojo.enums.response.CommonResponseEnum;
+import com.njcn.common.pojo.param.StatisticsBizBaseParam;
+import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.common.utils.HttpResultUtil;
+import com.njcn.event.pojo.param.REventMParam;
+import com.njcn.event.pojo.vo.RArrayVO;
+import com.njcn.event.pojo.vo.RStatEventMVO;
+import com.njcn.event.service.majornetwork.RStatEventOrgMService;
+import com.njcn.event.service.majornetwork.RStatEventOrgQService;
+import com.njcn.event.service.majornetwork.RStatEventOrgYService;
+import com.njcn.web.controller.BaseController;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+/**
+ *
+ * 前端控制器
+ *
+ *
+ * @author rui.wu
+ * @since 2022-10-09
+ */
+@RestController
+@RequiredArgsConstructor
+@Api(tags = "主网指标分类概览-各单位分类总览")
+@RequestMapping("/event/rStatHarmonic")
+public class RStatEventOrgController extends BaseController {
+
+ private final RStatEventOrgYService rStatEventOrgYService;
+ private final RStatEventOrgQService rStatEventOrgQService;
+ private final RStatEventOrgMService rStatEventOrgMService;
+
+
+ /**
+ * 查询查询监测点暂态指标 日/月点数
+ */
+ @GetMapping("/getAllRStatEventOrg")
+ @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+ @ApiOperation("查询暂态累计超标监测点数")
+ public HttpResult> getAllRStatEventOrg(StatisticsBizBaseParam param) {
+ String methodDescribe = getMethodDescribe("getAllRStatEventOrg");
+ List rStatHarmonicOrgAll = null;
+ String string = param.getType().toString();
+ switch (string) {
+ //查询超标监测点数-年数据
+ case BizParamConstant.STAT_BIZ_YEAR:
+ rStatHarmonicOrgAll = rStatEventOrgYService.getRStatEventOrgYAll(param);
+ break;
+ //查询超标监测点数-季数据
+ case BizParamConstant.STAT_BIZ_QUARTER:
+ rStatHarmonicOrgAll = rStatEventOrgQService.getRStatEventOrgQAll(param);
+ break;
+ //查询超标监测点数-月数据
+ case BizParamConstant.STAT_BIZ_MONTH:
+ rStatHarmonicOrgAll = rStatEventOrgMService.getRStatEventOrgMAll(param);
+ break;
+ default:
+ break;
+ }
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, rStatHarmonicOrgAll, methodDescribe);
+ }
+
+ /**
+ * 查询查询监测点稳态指标 日/月点数
+ */
+ @GetMapping("/getAllRStatEventOrgIcon")
+ @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+ @ApiOperation("查询暂态各单位超标监测统计图")
+ public HttpResult> getAllRStatEventOrgIcon(REventMParam param) {
+ String methodDescribe = getMethodDescribe("getAllRStatEventOrgIcon");
+ List getAllRStatEventOrgIcon = null;
+ String string = param.getType().toString();
+ switch (string) {
+ //查询各单位累计超标监测点数统计图-年数据
+ case BizParamConstant.STAT_BIZ_YEAR:
+ getAllRStatEventOrgIcon = rStatEventOrgYService.getRStatHarmonicOrgYIcon(param);
+ break;
+ //查询各单位累计超标监测点数-季数据
+ case BizParamConstant.STAT_BIZ_QUARTER:
+ getAllRStatEventOrgIcon = rStatEventOrgQService.getRStatHarmonicOrgQIcon(param);
+ break;
+ //查询各单位累计超标监测点数-月数据
+ case BizParamConstant.STAT_BIZ_MONTH:
+ getAllRStatEventOrgIcon = rStatEventOrgMService.getRStatHarmonicOrgMIcon(param);
+ break;
+ default:
+ break;
+ }
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, getAllRStatEventOrgIcon, methodDescribe);
+ }
+
+
+}
+
diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/controller/majornetwork/RStatSubstationController.java b/pqs-event/event-boot/src/main/java/com/njcn/event/controller/majornetwork/RStatSubstationController.java
new file mode 100644
index 000000000..e4cde74c0
--- /dev/null
+++ b/pqs-event/event-boot/src/main/java/com/njcn/event/controller/majornetwork/RStatSubstationController.java
@@ -0,0 +1,80 @@
+package com.njcn.event.controller.majornetwork;
+
+
+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.param.StatisticsBizBaseParam;
+import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.common.utils.HttpResultUtil;
+import com.njcn.event.pojo.vo.RSubstationIcon2VO;
+import com.njcn.event.pojo.vo.RSubstationIconVO;
+import com.njcn.event.pojo.vo.RVoltageIconVO;
+import com.njcn.event.service.majornetwork.RStatSubstationMService;
+import com.njcn.event.service.majornetwork.RStatSubstationVoltageMService;
+import com.njcn.web.controller.BaseController;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+
+/**
+ *
+ * 前端控制器
+ *
+ *
+ * @author rui.wu
+ * @since 2022-10-18
+ */
+@RestController
+@RequiredArgsConstructor
+@Api(tags = "主网指标分类概览-变电站分类总览")
+@RequestMapping("/event/rStatSubstation")
+public class RStatSubstationController extends BaseController {
+
+ private final RStatSubstationMService rStatSubstationMService;
+ private final RStatSubstationVoltageMService rStatSubstationVoltageMService;
+
+ /**
+ * 变电站暂态指标超标分布（按发生频次）
+ */
+ @GetMapping("/getStatSubstationIconDistributed")
+ @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+ @ApiOperation("变电站暂态分布（按发生频次）")
+ public HttpResult getAllRStatSubstation(StatisticsBizBaseParam param) {
+ String methodDescribe = getMethodDescribe("getStatSubstationIconDistributed");
+ RSubstationIconVO statSubstationIcon = rStatSubstationMService.getStatSubstationIcon(param);
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, statSubstationIcon, methodDescribe);
+ }
+
+ /**
+ * 变电站暂态分布（按电压等级）
+ */
+ @GetMapping("/getStatSubstationIconVoltage")
+ @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+ @ApiOperation("变电站暂态分布（按电压等级）")
+ public HttpResult> getAllRStatSubstationIcon2(StatisticsBizBaseParam param) {
+ String methodDescribe = getMethodDescribe("getStatSubstationIconVoltage");
+ List statSubstationIcon = rStatSubstationVoltageMService.getStatSubstationIcon(param);
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, statSubstationIcon, methodDescribe);
+ }
+
+
+ /**
+ * 变电站暂态指标发生频次
+ */
+ @GetMapping("/getStatSubstationIconIndex")
+ @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+ @ApiOperation("变电站暂态指标发生频次")
+ public HttpResult> getAllRStatSubstationIcon3(StatisticsBizBaseParam param) {
+ String methodDescribe = getMethodDescribe("getStatSubstationIconIndex");
+ List statSubstationIcon = rStatSubstationMService.getStatSubstationIcon2(param);
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, statSubstationIcon, methodDescribe);
+ }
+}
+