合并代码

2022-11-25 09:21:27 +08:00
parent 9b2759f71e
commit bc14540181
4 changed files with 489 additions and 0 deletions
--- 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
@@ -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;
+
+
+}
+
--- 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
@@ -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;
+
+/**
+ * <p>
+ * 前端控制器
+ * </p>
+ *
+ * @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<List<RArrayVO>> getAllRStatEvent(StatisticsBizBaseParam param) {
+        String methodDescribe = getMethodDescribe("getAllRStatHarmonic");
+        List<RArrayVO> 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<List<RStatEventMVO>> getRStatHarmonicIconVoltage(REventMParam param) {
+        String methodDescribe = getMethodDescribe("getRStatHarmonicIconVoltage");
+        List<RStatEventMVO> rStatHarmonicIcon = rStatEventMService.getRStatHarmonicIcon(param);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, rStatHarmonicIcon, methodDescribe);
+    }
+
+
+    /**
+     * 暂态电铁-频率偏差-电压统计图
+     */
+    @GetMapping("/getRStatHarmonicIconDate")
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @ApiOperation("暂态电铁-频率偏差-越线日期统计图")
+    public HttpResult<List<REventPolylineVO>> getRStatHarmonicIconDate(REventMParam param) {
+        String methodDescribe = getMethodDescribe("getRStatHarmonicIconDate");
+        List<REventPolylineVO> rStatHarmonicIcon = rStatEventMService.getRStatHarmonicIcon2(param);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, rStatHarmonicIcon, methodDescribe);
+    }
+
+
+}
+
--- 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
@@ -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;
+
+/**
+ * <p>
+ * 前端控制器
+ * </p>
+ *
+ * @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<List<RArrayVO>> getAllRStatEventOrg(StatisticsBizBaseParam param) {
+        String methodDescribe = getMethodDescribe("getAllRStatEventOrg");
+        List<RArrayVO> 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<List<RStatEventMVO>> getAllRStatEventOrgIcon(REventMParam param) {
+        String methodDescribe = getMethodDescribe("getAllRStatEventOrgIcon");
+        List<RStatEventMVO> 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);
+    }
+
+
+}
+
--- 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
@@ -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;
+
+
+/**
+ * <p>
+ * 前端控制器
+ * </p>
+ *
+ * @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<RSubstationIconVO> 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<List<RVoltageIconVO>> getAllRStatSubstationIcon2(StatisticsBizBaseParam param) {
+        String methodDescribe = getMethodDescribe("getStatSubstationIconVoltage");
+        List<RVoltageIconVO> statSubstationIcon = rStatSubstationVoltageMService.getStatSubstationIcon(param);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, statSubstationIcon, methodDescribe);
+    }
+
+
+    /**
+     * 变电站暂态指标发生频次
+     */
+    @GetMapping("/getStatSubstationIconIndex")
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @ApiOperation("变电站暂态指标发生频次")
+    public HttpResult<List<RSubstationIcon2VO>> getAllRStatSubstationIcon3(StatisticsBizBaseParam param) {
+        String methodDescribe = getMethodDescribe("getStatSubstationIconIndex");
+        List<RSubstationIcon2VO> statSubstationIcon = rStatSubstationMService.getStatSubstationIcon2(param);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, statSubstationIcon, methodDescribe);
+    }
+}
+