From 85f0775c970ea9693c9e1eb2bd7504d71e5e669f Mon Sep 17 00:00:00 2001 From: xy <748613696@qq.com> Date: Wed, 10 Jun 2026 10:51:59 +0800 Subject: [PATCH] =?UTF-8?q?feat(harmonic):=20=E4=BC=98=E5=8C=96=E4=BA=8B?= =?UTF-8?q?=E4=BB=B6=E7=AE=A1=E7=90=86=E5=8A=9F=E8=83=BD=E5=B9=B6=E8=B0=83?= =?UTF-8?q?=E6=95=B4=E6=97=A5=E5=BF=97=E7=BA=A7=E5=88=AB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 将多个模块的根日志级别从info调整为warn - 在CldEventParam中为幅值和持续时间字段添加更明确的描述 - 为CommonStatisticalQueryParam添加持续时间、特征幅值、严重度等范围验证参数 - 在CsEngineeringServiceImpl中添加排序功能支持 - 为设备交付相关参数和实体类添加治理方法、敏感用户、治理类型等新字段 - 在事件服务中实现持续时间、幅值、严重度等多维度筛选查询功能 - 为CsEventPO添加严重度字段并实现相关计算逻辑 - 优化事件列表查询性能,添加波形文件存在性过滤条件 - 更新XML映射文件以支持新的查询参数和字段映射 - 重构台账树构建逻辑,提升数据加载效率 - 修复数据查询中的大小写匹配问题 --- .../param/CsEquipmentDeliveryAddParm.java | 9 + .../param/CsEquipmentDeliveryAuditParm.java | 9 + .../pojo/po/CsEquipmentDeliveryPO.java | 24 + .../csdevice/pojo/vo/DataGroupEventVO.java | 9 +- .../csdevice/pojo/vo/RecordAllDevTreeVo.java | 4 + .../ledger/CsCommTerminalController.java | 22 +- .../mapper/mapping/WlRecordMapper.xml | 4 +- .../impl/CsEngineeringServiceImpl.java | 1 + .../service/impl/CsGroupServiceImpl.java | 26 +- .../service/impl/CsLedgerServiceImpl.java | 132 +- .../csdevice/service/impl/IcdServiceImpl.java | 11 +- .../src/main/resources/bootstrap.yml | 2 +- .../njcn/csharmonic/param/CldEventParam.java | 4 +- .../param/CommonStatisticalQueryParam.java | 32 + .../param/CsEventUserQueryPage.java | 30 + .../param/CsEventUserQueryParam.java | 1 + .../com/njcn/csharmonic/param/ItemParam.java | 50 + .../njcn/csharmonic/pojo/po/CsEventPO.java | 6 + .../csharmonic/pojo/vo/EventDetailVO.java | 18 + .../njcn/csharmonic/utils/DataChangeUtil.java | 33 + .../csharmonic/controller/DataController.java | 12 +- .../controller/PqSensitiveUserController.java | 15 + .../mapper/mapping/CsEventUserPOMapper.xml | 32 +- .../csharmonic/service/CsEventPOService.java | 8 +- .../njcn/csharmonic/service/IDataService.java | 5 +- .../service/IPqSensitiveUserService.java | 4 + .../service/impl/CsEventPOServiceImpl.java | 106 +- .../impl/CsEventUserPOServiceImpl.java | 24 +- .../service/impl/DataServiceImpl.java | 1410 ++++++++++++----- .../impl/PqSensitiveUserServiceImpl.java | 30 +- .../service/impl/RealDataServiceImpl.java | 33 +- .../service/impl/StableDataServiceImpl.java | 13 - .../src/main/resources/bootstrap.yml | 2 +- .../src/main/resources/bootstrap.yml | 2 +- .../src/main/resources/bootstrap.yml | 2 +- 35 files changed, 1546 insertions(+), 579 deletions(-) create mode 100644 cs-harmonic/cs-harmonic-api/src/main/java/com/njcn/csharmonic/param/ItemParam.java diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsEquipmentDeliveryAddParm.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsEquipmentDeliveryAddParm.java index 2c211e8..ae00027 100644 --- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsEquipmentDeliveryAddParm.java +++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsEquipmentDeliveryAddParm.java @@ -111,4 +111,13 @@ public class CsEquipmentDeliveryAddParm implements Serializable { @ApiModelProperty(value="是否支持升级(0:否 1:是)") private Integer upgrade; + + @ApiModelProperty(value="治理方法") + private String governMethod; + + @ApiModelProperty(value="敏感用户id") + private String monitorUser; + + @ApiModelProperty(value="治理类型(稳态:harmonic 暂态:event)") + private String governType; } \ No newline at end of file diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsEquipmentDeliveryAuditParm.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsEquipmentDeliveryAuditParm.java index 3216740..db07a14 100644 --- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsEquipmentDeliveryAuditParm.java +++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsEquipmentDeliveryAuditParm.java @@ -116,4 +116,13 @@ public class CsEquipmentDeliveryAuditParm { @ApiModelProperty(value="是否支持升级(0:否 1:是)") private Integer upgrade; + + @ApiModelProperty(value="治理方法") + private String governMethod; + + @ApiModelProperty(value="敏感用户id") + private String monitorUser; + + @ApiModelProperty(value="治理类型(稳态:harmonic 暂态:event)") + private String governType; } \ No newline at end of file diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/po/CsEquipmentDeliveryPO.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/po/CsEquipmentDeliveryPO.java index ac92fe9..77fa813 100644 --- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/po/CsEquipmentDeliveryPO.java +++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/po/CsEquipmentDeliveryPO.java @@ -158,4 +158,28 @@ public class CsEquipmentDeliveryPO extends BaseEntity { * 是否支持升级(0:否 1:是) */ private Integer upgrade; + + /** + * 治理方法 + */ + @TableField(value = "govern_method") + private String governMethod; + + /** + * 敏感用户id + */ + @TableField(value = "monitor_user") + private String monitorUser; + + /** + * 治理类型(稳态:harmonic 暂态:event) + */ + @TableField(value = "govern_type") + private String governType; + + /** + * 治理报告文件路径 + */ + @TableField(value = "report_file_path") + private String reportFilePath; } \ No newline at end of file diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/vo/DataGroupEventVO.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/vo/DataGroupEventVO.java index 5d78e3e..bb2c9cb 100644 --- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/vo/DataGroupEventVO.java +++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/vo/DataGroupEventVO.java @@ -5,7 +5,6 @@ import io.swagger.annotations.ApiModelProperty; import lombok.Data; import org.springframework.format.annotation.DateTimeFormat; -import java.math.BigDecimal; import java.time.LocalDateTime; /** @@ -31,6 +30,9 @@ public class DataGroupEventVO { @ApiModelProperty("装置ID") private String deviceId; + @ApiModelProperty("设备网络码") + private String nDid; + @ApiModelProperty("装置名称") private String devName; @@ -65,7 +67,7 @@ public class DataGroupEventVO { private Double amplitude; @ApiModelProperty("严重度") - private String severity; + private Double severity; @ApiModelProperty("波形路径") private String wavePath; @@ -82,4 +84,7 @@ public class DataGroupEventVO { @ApiModelProperty("暂降源与监测位置关系 0-未知、1-上游、2-下游") private String sagSource; + @ApiModelProperty("监测点电压等级") + private Double lineVoltage; + } diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/vo/RecordAllDevTreeVo.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/vo/RecordAllDevTreeVo.java index 766bb8d..2aeaae2 100644 --- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/vo/RecordAllDevTreeVo.java +++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/vo/RecordAllDevTreeVo.java @@ -2,6 +2,7 @@ package com.njcn.csdevice.pojo.vo; import io.swagger.annotations.ApiModelProperty; import lombok.Data; + import java.util.List; /** @@ -20,6 +21,9 @@ public class RecordAllDevTreeVo { @ApiModelProperty("设备名称") private String name; + @ApiModelProperty("设备状态") + private Integer runStatus; + @ApiModelProperty("线路") private List children; diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/ledger/CsCommTerminalController.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/ledger/CsCommTerminalController.java index fcf531c..f4b6704 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/ledger/CsCommTerminalController.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/ledger/CsCommTerminalController.java @@ -1,39 +1,25 @@ package com.njcn.csdevice.controller.ledger; -import cn.hutool.core.collection.CollUtil; import com.njcn.common.pojo.annotation.OperateInfo; -import com.njcn.common.pojo.enums.common.DataStateEnum; 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.csdevice.mapper.PqsDeviceUnitMapper; -import com.njcn.csdevice.pojo.po.CsDeviceUserPO; -import com.njcn.csdevice.pojo.po.CsEquipmentDeliveryPO; -import com.njcn.csdevice.pojo.po.CsLinePO; import com.njcn.csdevice.service.CsCommTerminalService; -import com.njcn.csdevice.service.CsDeviceUserPOService; -import com.njcn.csdevice.service.CsEquipmentDeliveryService; -import com.njcn.csdevice.service.CsLinePOService; import com.njcn.device.biz.pojo.po.PqsDeviceUnit; -import com.njcn.user.api.UserFeignClient; -import com.njcn.user.pojo.constant.UserType; -import com.njcn.user.pojo.vo.UserVO; 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.GetMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestParam; +import org.springframework.web.bind.annotation.RestController; -import org.springframework.web.bind.annotation.*; - -import java.util.ArrayList; -import java.util.Collections; import java.util.List; -import java.util.Objects; -import java.util.stream.Collectors; /** diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/mapper/mapping/WlRecordMapper.xml b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/mapper/mapping/WlRecordMapper.xml index 46319a4..be26eb2 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/mapper/mapping/WlRecordMapper.xml +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/mapper/mapping/WlRecordMapper.xml @@ -21,7 +21,7 @@