diff --git a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/controller/leaflet/WarningLeafletController.java b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/controller/leaflet/WarningLeafletController.java index 791f1b002..3166852e8 100644 --- a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/controller/leaflet/WarningLeafletController.java +++ b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/controller/leaflet/WarningLeafletController.java @@ -66,6 +66,16 @@ public class WarningLeafletController extends BaseController { return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, out, methodDescribe); } + @OperateInfo(info = LogEnum.BUSINESS_COMMON) + @PostMapping("/allPageData") + @ApiOperation("分页查询告警单全部数据") + @ApiImplicitParam(name = "warningLeafletQueryParam", value = "参数", required = true) + public HttpResult> allPageData(@RequestBody @Validated WarningLeafletParam.WarningLeafletQueryParam warningLeafletQueryParam) { + String methodDescribe = getMethodDescribe("alarmPageData"); + Page out = warningLeafletService.allPageData(warningLeafletQueryParam); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, out, methodDescribe); + } + @OperateInfo(info = LogEnum.BUSINESS_COMMON) @PostMapping("/addLineOverLimitData") @ApiOperation("监测点超标预警单/告警单新增") diff --git a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/leaflet/IWarningLeafletService.java b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/leaflet/IWarningLeafletService.java index a66841548..61314126d 100644 --- a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/leaflet/IWarningLeafletService.java +++ b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/leaflet/IWarningLeafletService.java @@ -47,5 +47,11 @@ public interface IWarningLeafletService extends IBpmService { String cancelWarningLeaflet(BpmProcessInstanceCancelParam cancelReqVO); + /** + * 查询告警单信息,包含预警单和告警单 + * @param warningLeafletQueryParam + * @return + */ + Page allPageData(WarningLeafletParam.WarningLeafletQueryParam warningLeafletQueryParam); } diff --git a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/leaflet/impl/WarningLeafletServiceImpl.java b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/leaflet/impl/WarningLeafletServiceImpl.java index 1aa2c1b2b..aa4741eba 100644 --- a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/leaflet/impl/WarningLeafletServiceImpl.java +++ b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/leaflet/impl/WarningLeafletServiceImpl.java @@ -48,10 +48,7 @@ import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.time.LocalDate; -import java.util.HashMap; -import java.util.List; -import java.util.Map; -import java.util.Objects; +import java.util.*; import java.util.stream.Collectors; /** @@ -347,6 +344,54 @@ public class WarningLeafletServiceImpl extends ServiceImpl allPageData(WarningLeafletParam.WarningLeafletQueryParam warningLeafletQueryParam) { + QueryWrapper warningLeafletVOQueryWrapper = new QueryWrapper<>(); + if (Objects.nonNull(warningLeafletQueryParam)) { + //添加上时间范围 + warningLeafletVOQueryWrapper.between("supervision_warning_leaflet.Create_Time", + DateUtil.beginOfDay(DateUtil.parse(warningLeafletQueryParam.getSearchBeginTime())), + DateUtil.endOfDay(DateUtil.parse(warningLeafletQueryParam.getSearchEndTime()))); + } + + //筛选负责单位 + if (StrUtil.isNotBlank(warningLeafletQueryParam.getDeptIndex())) { + List deptIds = deptFeignClient.getDepSonIdtByDeptId(warningLeafletQueryParam.getDeptIndex()).getData(); + warningLeafletVOQueryWrapper.in("supervision_warning_leaflet.dept_id", deptIds); + } + warningLeafletVOQueryWrapper + .eq("supervision_warning_leaflet.state", DataStateEnum.ENABLE.getCode()) + .in("supervision_warning_leaflet.status", Arrays.asList(3,4,5)) + .orderByDesc("supervision_warning_leaflet.Update_Time"); + Page warningLeafletVOPage = this.baseMapper.alarmPageData(new Page<>(PageFactory.getPageNum(warningLeafletQueryParam), PageFactory.getPageSize(warningLeafletQueryParam)), warningLeafletVOQueryWrapper); + //目前仅知道现场测试超标会有附件 + List records = warningLeafletVOPage.getRecords(); + if (CollectionUtil.isNotEmpty(records)) { + List deptIds = records.stream().distinct().map(WarningLeafletVO::getDutyOrgId).collect(Collectors.toList()); + Map deptMap = new HashMap<>(); + if (CollUtil.isNotEmpty(deptIds)) { + List data = deptFeignClient.getDeptInfoListByIds(deptIds).getData(); + deptMap.putAll(data.stream().collect(Collectors.toMap(Dept::getId, Dept::getName))); + } + for (WarningLeafletVO record : records) { + if (record.getProblemType().equals(ProblemTypeEnum.SITE_TEST.getCode()) && StrUtil.isNotBlank(record.getProblemId())) { + //查询到现场测试超标附件地址 + TempLineRunTestWarning byId = lineRunTestWarningService.getById(record.getProblemId()); + if(Objects.nonNull(byId)){ + record.setProblemPath(byId.getTestRunReport()); + } + } + if (deptMap.containsKey(record.getDutyOrgId())) { + record.setDutyOrgName(deptMap.get(record.getDutyOrgId())); + } + if (!Objects.isNull(record.getFilePath())){ + record.setFilePath(fileStorageUtil.getFileUrl(record.getFilePath())); + } + } + } + return warningLeafletVOPage; + } + private String assembleOverLimitInfo(RMpPartHarmonicDetailDTO rMpPartHarmonicDetailDTO) { String info = "";