diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/controller/majornetwork/RMpMonitorAlarmCountMController.java b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/controller/majornetwork/RMpMonitorAlarmCountMController.java index 91d8d5ab3..7b516cdf6 100644 --- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/controller/majornetwork/RMpMonitorAlarmCountMController.java +++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/controller/majornetwork/RMpMonitorAlarmCountMController.java @@ -1,5 +1,6 @@ package com.njcn.device.pms.controller.majornetwork; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.njcn.common.pojo.annotation.OperateInfo; import com.njcn.common.pojo.enums.common.LogEnum; import com.njcn.common.pojo.enums.response.CommonResponseEnum; @@ -17,7 +18,6 @@ import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; -import java.util.List; /** * 监测点告警统计 @@ -45,9 +45,9 @@ public class RMpMonitorAlarmCountMController extends BaseController { @PostMapping("/getRMpMonitorAlarmCountMList") @OperateInfo(info = LogEnum.BUSINESS_COMMON) @ApiOperation("查询监测点告警统计(月)(主网)") - public HttpResult> getAllRStatAreaAlarmCountMList(@RequestBody RMpMonitorAlarmCountMParam rMpMonitorAlarmCountMParam) { + public HttpResult> getAllRStatAreaAlarmCountMList(@RequestBody RMpMonitorAlarmCountMParam rMpMonitorAlarmCountMParam) { String methodDescribe = getMethodDescribe("getAllRStatAreaAlarmCountMList"); - List list = rMpMonitorAlarmCountMService.getRMpMonitorAlarmCountMList(rMpMonitorAlarmCountMParam); + Page list = rMpMonitorAlarmCountMService.getRMpMonitorAlarmCountMList(rMpMonitorAlarmCountMParam); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, list, methodDescribe); } } diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/mapping/TerminalMapper.xml b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/mapping/TerminalMapper.xml index cde493236..2589336b3 100644 --- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/mapping/TerminalMapper.xml +++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/mapping/TerminalMapper.xml @@ -28,7 +28,7 @@ - and pms_terminal.id like concat('%',#{param.deviceName},'%') + and pms_terminal.NAME like concat('%',#{param.deviceName},'%') and pms_terminal.Terminal_State = #{param.deviceStatus} diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/RMpMonitorAlarmCountMService.java b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/RMpMonitorAlarmCountMService.java index ada82efea..9696ecc28 100644 --- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/RMpMonitorAlarmCountMService.java +++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/RMpMonitorAlarmCountMService.java @@ -1,11 +1,11 @@ package com.njcn.device.pms.service.majornetwork; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.IService; import com.njcn.device.pms.pojo.param.RMpMonitorAlarmCountMParam; import com.njcn.device.pms.pojo.po.RMpMonitorAlarmCountM; import com.njcn.device.pms.pojo.vo.RMpMonitorAlarmCountMVO; -import java.util.List; /** * @author jianghf @@ -22,6 +22,6 @@ public interface RMpMonitorAlarmCountMService extends IService> */ - List getRMpMonitorAlarmCountMList(RMpMonitorAlarmCountMParam rMpMonitorAlarmCountMParam); + Page getRMpMonitorAlarmCountMList(RMpMonitorAlarmCountMParam rMpMonitorAlarmCountMParam); } diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/RMpMonitorAlarmCountMServiceImpl.java b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/RMpMonitorAlarmCountMServiceImpl.java index 58bc841a5..8719864c4 100644 --- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/RMpMonitorAlarmCountMServiceImpl.java +++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/RMpMonitorAlarmCountMServiceImpl.java @@ -1,7 +1,9 @@ package com.njcn.device.pms.service.majornetwork.impl; +import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.collection.CollUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.njcn.common.pojo.enums.response.CommonResponseEnum; import com.njcn.common.pojo.exception.BusinessException; @@ -10,19 +12,15 @@ import com.njcn.device.biz.pojo.dto.LineDevGetDTO; import com.njcn.device.biz.pojo.param.DeptGetLineParam; import com.njcn.device.pms.mapper.majornetwork.RMpMonitorAlarmCountMMapper; import com.njcn.device.pms.pojo.param.RMpMonitorAlarmCountMParam; -import com.njcn.device.pms.pojo.po.Monitor; import com.njcn.device.pms.pojo.po.RMpMonitorAlarmCountM; import com.njcn.device.pms.pojo.vo.RMpMonitorAlarmCountMVO; import com.njcn.device.pms.service.ledgerManger.CommTerminalService; import com.njcn.device.pms.service.majornetwork.IMonitorService; import com.njcn.device.pms.service.majornetwork.RMpMonitorAlarmCountMService; import com.njcn.system.api.DicDataFeignClient; -import com.njcn.system.enums.DicDataEnum; import com.njcn.system.enums.DicDataTypeEnum; import com.njcn.system.pojo.po.DictData; import com.njcn.user.api.DeptFeignClient; -import com.njcn.user.pojo.dto.DeptDTO; -import com.njcn.web.utils.WebUtil; import lombok.RequiredArgsConstructor; import org.apache.commons.lang.StringUtils; import org.springframework.beans.BeanUtils; @@ -58,7 +56,8 @@ implements RMpMonitorAlarmCountMService { * @return java.util.List */ @Override - public List getRMpMonitorAlarmCountMList(RMpMonitorAlarmCountMParam rMpMonitorAlarmCountMParam) { + public Page getRMpMonitorAlarmCountMList(RMpMonitorAlarmCountMParam rMpMonitorAlarmCountMParam) { + Page resultPage = new Page<>(); List resultList = new ArrayList<>(); //提取查询条件 String id = rMpMonitorAlarmCountMParam.getId(); //单位id @@ -69,12 +68,12 @@ implements RMpMonitorAlarmCountMService { String endTime = rMpMonitorAlarmCountMParam.getEndTime(); //结束时间 //监测对象类型 if (StringUtils.isBlank(rMpMonitorAlarmCountMParam.getMonitorObjectType())){ - return resultList; + return resultPage; } List monitorObjectType = StringUtils.isNotBlank(rMpMonitorAlarmCountMParam.getMonitorObjectType()) ? Arrays.asList(rMpMonitorAlarmCountMParam.getMonitorObjectType().split(",")) : null; //电压等级 if (StringUtils.isBlank(rMpMonitorAlarmCountMParam.getVoltageLevel())){ - return resultList; + return resultPage; } List voltageLevelParamList = StringUtils.isNotBlank(rMpMonitorAlarmCountMParam.getVoltageLevel()) ? Arrays.asList(rMpMonitorAlarmCountMParam.getVoltageLevel().split(",")) : null; //电压等级 String monitorName = rMpMonitorAlarmCountMParam.getMeasurementPointName(); //监测点名称 @@ -112,27 +111,28 @@ implements RMpMonitorAlarmCountMService { lambdaQueryWrapper.in(RMpMonitorAlarmCountM::getMeasurementPointId, lineList) .ge(RMpMonitorAlarmCountM::getDataDate, startTime) .le(RMpMonitorAlarmCountM::getDataDate, endTime); - List alarmCountMList = this.list(lambdaQueryWrapper); - Map> map = alarmCountMList.stream().collect(Collectors.groupingBy(RMpMonitorAlarmCountM::getMeasurementPointId)); + Page page = this.page(new Page<>(rMpMonitorAlarmCountMParam.getPageNum(), rMpMonitorAlarmCountMParam.getPageSize()), lambdaQueryWrapper); + BeanUtil.copyProperties(page,resultPage); + Map> map = page.getRecords().stream().collect(Collectors.groupingBy(RMpMonitorAlarmCountM::getMeasurementPointId)); for (LineDevGetDTO item2 : lineDto) { RMpMonitorAlarmCountMVO vo = new RMpMonitorAlarmCountMVO(); - if (CollUtil.isNotEmpty(map.get(item2.getPointId()))){ + if (map.containsKey(item2.getPointId())){ BeanUtils.copyProperties(map.get(item2.getPointId()).get(0), vo); + //所属单位名称 + vo.setOrgName(item2.getUnitName()); + vo.setOrgNo(item2.getUnitId()); + vo.setMeasurementPointId(item2.getPointId()); + vo.setMeasurementPointName(item2.getPointName()); + //监测点类型id + vo.setMonitorType(item2.getLineTag()); + //监测点类型名称 + vo.setMonitorTypeName(monitorTypeMap.get(item2.getLineTag())); + //电压等级id + vo.setVoltageLevel(item2.getVoltageLevel()); + //电压等级 + vo.setVoltageLevelName(voltageLevelMap.get(item2.getVoltageLevel())); + resultList.add(vo); } - //所属单位名称 - vo.setOrgName(item2.getUnitName()); - vo.setOrgNo(item2.getUnitId()); - vo.setMeasurementPointId(item2.getPointId()); - vo.setMeasurementPointName(item2.getPointName()); - //监测点类型id - vo.setMonitorType(item2.getLineTag()); - //监测点类型名称 - vo.setMonitorTypeName(monitorTypeMap.get(item2.getLineTag())); - //电压等级id - vo.setVoltageLevel(item2.getVoltageLevel()); - //电压等级 - vo.setVoltageLevelName(voltageLevelMap.get(item2.getVoltageLevel())); - resultList.add(vo); } } } @@ -140,7 +140,8 @@ implements RMpMonitorAlarmCountMService { if (CollUtil.isNotEmpty(resultList)){ resultList = resultList.stream().sorted(Comparator.comparing(RMpMonitorAlarmCountMVO::getOrgName).reversed()).collect(Collectors.toList()); } - return resultList; + resultPage.setRecords(resultList); + return resultPage; } }