diff --git a/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/vo/ROperatingIndexCommonVO.java b/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/vo/ROperatingIndexCommonVO.java index d0aacd7cf..041467ba6 100644 --- a/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/vo/ROperatingIndexCommonVO.java +++ b/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/vo/ROperatingIndexCommonVO.java @@ -1,5 +1,6 @@ package com.njcn.device.pms.pojo.vo; +import cn.hutool.core.util.NumberUtil; import com.fasterxml.jackson.annotation.JsonFormat; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @@ -85,4 +86,16 @@ public class ROperatingIndexCommonVO { */ @ApiModelProperty(name = " isUnusual", value = "数据是否异常(0:正常 1:异常)") private Integer isUnusual; + + public void setDataIntegrityRate(Double dataIntegrityRate) { + this.dataIntegrityRate = NumberUtil.round(dataIntegrityRate*100,2).doubleValue(); + } + + public void setDataRightRate(Double dataRightRate) { + this.dataRightRate = NumberUtil.round(dataRightRate*100,2).doubleValue();; + } + + public void setIndexIntegrityRate(Double indexIntegrityRate) { + this.indexIntegrityRate = NumberUtil.round(indexIntegrityRate*100,2).doubleValue();; + } } diff --git a/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/vo/ROperatingIndexVO.java b/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/vo/ROperatingIndexVO.java index 71674390c..357d61f10 100644 --- a/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/vo/ROperatingIndexVO.java +++ b/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/vo/ROperatingIndexVO.java @@ -1,5 +1,6 @@ package com.njcn.device.pms.pojo.vo; +import cn.hutool.core.util.NumberUtil; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @@ -66,6 +67,14 @@ public class ROperatingIndexVO implements Serializable { */ @ApiModelProperty(name = " isUnusual", value = "数据是否异常(0:正常 1:异常)") private Integer isUnusual; + + public void setDataIntegrityRate(Double dataIntegrityRate) { + this.dataIntegrityRate = NumberUtil.round(dataIntegrityRate*100,2).doubleValue();; + } + + public void setIndexIntegrityRate(Double indexIntegrityRate) { + this.indexIntegrityRate = NumberUtil.round(indexIntegrityRate*100,2).doubleValue();; + } } diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/RMpDevSolveDetailServiceImpl.java b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/RMpDevSolveDetailServiceImpl.java index ddd74c614..570f1b1af 100644 --- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/RMpDevSolveDetailServiceImpl.java +++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/RMpDevSolveDetailServiceImpl.java @@ -1,6 +1,7 @@ package com.njcn.device.pms.service.majornetwork.impl; import cn.hutool.core.collection.CollUtil; +import cn.hutool.core.util.ObjectUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.njcn.common.pojo.enums.response.CommonResponseEnum; @@ -59,9 +60,7 @@ public class RMpDevSolveDetailServiceImpl extends ServiceImpl deptDTOList = deptFeignClient.getDepSonDetailByDeptId(id).getData(); - /*获取下一级子部门信息*/ -// List deptDTOList = deptFeignClient.getDepSonDetailByDeptId (id).getData ( ); + List deptDTOList = deptFeignClient.getDeptDescendantIndexes(id, WebUtil.filterDeptType()).getData(); if (CollUtil.isEmpty(deptDTOList)) { throw new BusinessException(CommonResponseEnum.NO_DATA, "部门不存在"); } @@ -95,10 +94,11 @@ public class RMpDevSolveDetailServiceImpl extends ServiceImpl resultList = new ArrayList<>(); DecimalFormat df = new DecimalFormat("###.00"); + String time = time(startTime, rMpDevAbnormalManageParam.getType()); terminalListMapByOrgId.forEach((key, terminalListByOrg) -> { RMpDevSolveVO rMpDevSolveVO = new RMpDevSolveVO(); - rMpDevSolveVO.setDataDate(startTime); + rMpDevSolveVO.setDataDate(time); rMpDevSolveVO.setOrgId(key); //单位id rMpDevSolveVO.setOrgName(terminalListByOrg.get(0).getOrgName()); //单位名称 @@ -177,10 +177,11 @@ public class RMpDevSolveDetailServiceImpl extends ServiceImpl resultList = new ArrayList<>(); DecimalFormat df = new DecimalFormat("###.00"); + String time = time(startTime, rMpDevAbnormalManageParam.getType()); terminalListMapByManufacture.forEach((key, terminalListByOrg) -> { RMpDevSolveVO rMpDevSolveVO = new RMpDevSolveVO(); - rMpDevSolveVO.setDataDate(startTime); + rMpDevSolveVO.setDataDate(time); rMpDevSolveVO.setManufactureId(key); //厂商id rMpDevSolveVO.setTerminalCount(terminalListByOrg.size()); //终端数量 @@ -247,10 +248,11 @@ public class RMpDevSolveDetailServiceImpl extends ServiceImpl resultList = new ArrayList<>(); DecimalFormat df = new DecimalFormat("###.00"); + String time = time(startTime, rMpDevAbnormalManageParam.getType()); solveMap.forEach((key, RMpDevSolveDetailList) -> { RMpDevSolveVO rMpDevSolveVO = new RMpDevSolveVO(); - rMpDevSolveVO.setDataDate(startTime); + rMpDevSolveVO.setDataDate(time); rMpDevSolveVO.setBreakDownType(key); //故障类型 rMpDevSolveVO.setTerminalCount(null); //终端数量(故障类型的终端数量前端展示'/') @@ -344,6 +346,18 @@ public class RMpDevSolveDetailServiceImpl extends ServiceImpl