diff --git a/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/param/device/OnlineParam.java b/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/param/device/OnlineParam.java index 3bf6b544f..d3dbc788d 100644 --- a/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/param/device/OnlineParam.java +++ b/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/param/device/OnlineParam.java @@ -49,6 +49,9 @@ public class OnlineParam extends BaseParam implements Serializable { @ApiModelProperty(value = "数据类型") private Integer dataType; + @ApiModelProperty(value = "监测点类型 0:电网侧 1:非电网侧") + private String lineType; + @Data @EqualsAndHashCode(callSuper = true) public static class ReportParam extends OnlineParam { @@ -72,4 +75,12 @@ public class OnlineParam extends BaseParam implements Serializable { private List idList; } + @Data + @EqualsAndHashCode(callSuper = true) + public static class DetailParam extends OnlineParam { + + @ApiModelProperty(name = "lineId", value = "监测点id") + private String lineId; + } + } diff --git a/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/vo/device/OnlineVo.java b/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/vo/device/OnlineVo.java index dea24e5ed..e3ea0b9e9 100644 --- a/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/vo/device/OnlineVo.java +++ b/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/vo/device/OnlineVo.java @@ -1,9 +1,11 @@ package com.njcn.supervision.pojo.vo.device; +import com.fasterxml.jackson.annotation.JsonFormat; import io.swagger.annotations.ApiModelProperty; import lombok.Data; import java.io.Serializable; +import java.time.LocalDateTime; /** * 类的介绍: @@ -76,4 +78,8 @@ public class OnlineVo implements Serializable { @ApiModelProperty("当前流程(null:无流程 1:预警 2:告警)") private Integer step; + + @ApiModelProperty("最新数据时间") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone="GMT+8") + private LocalDateTime updateTime; } diff --git a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/controller/device/LineWarningController.java b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/controller/device/LineWarningController.java index 1ef6edf8a..67ca82f2a 100644 --- a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/controller/device/LineWarningController.java +++ b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/controller/device/LineWarningController.java @@ -83,5 +83,15 @@ public class LineWarningController extends BaseController { return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, "success", methodDescribe); } + @OperateInfo(info = LogEnum.BUSINESS_COMMON) + @PostMapping("/overLimitDetail") + @ApiOperation("查看越限详情") + @ApiImplicitParam(name = "param", value = "参数", required = true) + public HttpResult getOverLimitDetail(@RequestBody @Validated OnlineParam.DetailParam param) { + String methodDescribe = getMethodDescribe("getOverLimitDetail"); + lineWarningService.getOverLimitDetail(param); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, "success", methodDescribe); + } + } diff --git a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/mapper/device/mapping/LineWarningMapper.xml b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/mapper/device/mapping/LineWarningMapper.xml index ad72ecd94..cc50750dc 100644 --- a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/mapper/device/mapping/LineWarningMapper.xml +++ b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/mapper/device/mapping/LineWarningMapper.xml @@ -15,7 +15,8 @@ A.target_type targetType, A.over_limit_day overLimitDay, A.initiate_warning_flag dataResource, - A.step step + A.step step, + pd.Update_Time updateTime from supervision_line_warning A left join pq_line p1 on A.line_id = p1.Id @@ -26,6 +27,7 @@ left join pq_line_detail B on A.line_id = B.Id left join pq_dept_line C on A.line_id = C.Line_Id left join sys_dept D on C.Id = D.Id + left join pq_device pd on pd.Id = p3.Id and ${ew.sqlSegment} diff --git a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/ILineWarningService.java b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/ILineWarningService.java index c0dc0ef9b..018e505ce 100644 --- a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/ILineWarningService.java +++ b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/ILineWarningService.java @@ -42,4 +42,11 @@ public interface ILineWarningService extends IService { */ void startReport(OnlineParam.ReportParam param); + /** + * 按监测点id,指标id查看越限详情,具体展示每日超标的 + * @param param + * @return + */ + void getOverLimitDetail(OnlineParam.DetailParam param); + } diff --git a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/LineWarningServiceImpl.java b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/LineWarningServiceImpl.java index 1db4a03ea..238da451d 100644 --- a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/LineWarningServiceImpl.java +++ b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/LineWarningServiceImpl.java @@ -6,6 +6,7 @@ import cn.hutool.core.date.DateUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.toolkit.IdWorker; +import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.github.jeffreyning.mybatisplus.service.MppServiceImpl; import com.njcn.common.pojo.enums.common.ServerEnum; @@ -199,9 +200,14 @@ public class LineWarningServiceImpl extends MppServiceImpl queryWrapper = new QueryWrapper<>(); queryWrapper.between("A.alarm_time", param.getSearchBeginTime(),param.getSearchEndTime()); + //监测点id if (CollUtil.isNotEmpty(lineList)) { queryWrapper.in("A.line_id",lineList); } + //监测点类型 + if (StringUtils.isNotBlank(param.getLineType())) { + queryWrapper.eq("B.Power_Flag",Integer.parseInt(param.getLineType())); + } //查询无数据的监测点 if (Objects.equals(param.getDataType(),0)){ queryWrapper.eq("A.target_type", "0"); @@ -226,7 +232,8 @@ public class LineWarningServiceImpl extends MppServiceImpl list1 = getReportLineInfo(true,param.getIdList(),null,param.getSearchBeginTime(),param.getSearchEndTime(),param.getDeptId(),allLineWarnings); //获取谐波电压超标监测点集合 @@ -246,6 +253,7 @@ public class LineWarningServiceImpl extends MppServiceImpl dataList1 = new ArrayList(),dataList2 = new ArrayList(),dataList3 = new ArrayList(); if (CollUtil.isNotEmpty(list1)) { @@ -299,6 +307,15 @@ public class LineWarningServiceImpl extends MppServiceImpl getReportLineInfo(boolean type, List idList, String codeId, String startTime, String endTime, String deptId,List allLineWarnings) { diff --git a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/SupervisionTempLineDebugPOServiceImpl.java b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/SupervisionTempLineDebugPOServiceImpl.java index 06b7db8e4..324a75118 100644 --- a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/SupervisionTempLineDebugPOServiceImpl.java +++ b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/SupervisionTempLineDebugPOServiceImpl.java @@ -112,7 +112,8 @@ public class SupervisionTempLineDebugPOServiceImpl extends ServiceImpl