diff --git a/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/po/RMpMonitorAlarmCountM.java b/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/po/RMpMonitorAlarmCountM.java index 9d3ed6aff..43f6c9f0c 100644 --- a/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/po/RMpMonitorAlarmCountM.java +++ b/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/po/RMpMonitorAlarmCountM.java @@ -32,6 +32,7 @@ public class RMpMonitorAlarmCountM implements Serializable { /** * 数据类型(0:主网 1:配网) */ + @TableField(exist = false) private String dataType; /** 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 703cee5c2..9e9056d62 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 @@ -109,8 +109,7 @@ implements RMpMonitorAlarmCountMService { LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); lambdaQueryWrapper.in(RMpMonitorAlarmCountM::getMeasurementPointId, monitorIdList) .ge(RMpMonitorAlarmCountM::getDataDate, startTime) - .le(RMpMonitorAlarmCountM::getDataDate, endTime) - .eq(RMpMonitorAlarmCountM::getDataType, dataType); + .le(RMpMonitorAlarmCountM::getDataDate, endTime); List alarmCountMList = this.list(lambdaQueryWrapper); List resultList; if (CollUtil.isNotEmpty(alarmCountMList)) { @@ -119,7 +118,7 @@ implements RMpMonitorAlarmCountMService { RMpMonitorAlarmCountMVO rMpMonitorAlarmCountMVO = new RMpMonitorAlarmCountMVO(); BeanUtils.copyProperties(item, rMpMonitorAlarmCountMVO); //单位信息 - rMpMonitorAlarmCountMVO.setOrgName(deptDTOMap.get(item.getOrgNo()).getName()); //所属单位名称 + rMpMonitorAlarmCountMVO.setOrgName(deptDTOMap.get(monitorMap.get(item.getMeasurementPointId()).getOrgId()).getName()); //所属单位名称 //监测点信息 rMpMonitorAlarmCountMVO.setMeasurementPointName(monitorMap.get(item.getMeasurementPointId()).getName());//监测点名称 rMpMonitorAlarmCountMVO.setMonitorTypeName(monitorTypeMap.get(monitorMap.get(item.getMeasurementPointId()).getMonitorType()));//监测点类型名称 diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/RStatZwAlarmCountWServiceImpl.java b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/RStatZwAlarmCountWServiceImpl.java index 5c293c9a0..d70106f4c 100644 --- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/RStatZwAlarmCountWServiceImpl.java +++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/RStatZwAlarmCountWServiceImpl.java @@ -99,17 +99,20 @@ implements RStatZwAlarmCountWService { BeanUtils.copyProperties(item, rStatZwAlarmCountWVO); //单位名称 rStatZwAlarmCountWVO.setOrgName(deptDTOMap.get(rStatZwAlarmCountWVO.getOrgNo()).getName()); - DecimalFormat df = new DecimalFormat("###.00"); +// DecimalFormat df = new DecimalFormat("###.00"); //获取有效监测点数量 Integer monitorEffectiveCount = item.getMonitorEffectiveCount(); - if (monitorEffectiveCount == null || monitorEffectiveCount <= 0) { - throw new BusinessException(CommonResponseEnum.NO_DATA, "有效监测点数量异常"); - } + //todo 有效监测点数量在实际环境中是可能为0的,不需要做异常处理 +// if (monitorEffectiveCount == null || monitorEffectiveCount <= 0) { +// throw new BusinessException(CommonResponseEnum.NO_DATA, "有效监测点数量异常"); +// } //计算告警四次及以上监测点占比( * 100 是直接取到百分比) - Double warnMonitorRate = Double.parseDouble(df.format(item.getWarnMonitorCount() / (monitorEffectiveCount * 1.0) * 100)); +// Double warnMonitorRate = Double.parseDouble(df.format(item.getWarnMonitorCount() / (monitorEffectiveCount * 1.0) * 100)); + Double warnMonitorRate = monitorEffectiveCount<=0 ? 0.0 : Double.parseDouble(String.format("%.2f",item.getWarnMonitorCount() / (monitorEffectiveCount * 1.0) * 100)); rStatZwAlarmCountWVO.setWarnMonitorRate(warnMonitorRate); //级别'较差'监测点占比( * 100 是直接取到百分比) - Double monitorGradeRate = Double.parseDouble(df.format(item.getMonitorGradeCount() / (monitorEffectiveCount * 1.0) * 100)); +// Double monitorGradeRate = Double.parseDouble(df.format(item.getMonitorGradeCount() / (monitorEffectiveCount * 1.0) * 100)); + Double monitorGradeRate = monitorEffectiveCount<=0 ? 0.0 : Double.parseDouble(String.format("%.2f",item.getMonitorGradeCount() / (monitorEffectiveCount * 1.0) * 100)); rStatZwAlarmCountWVO.setMonitorGradeRate(monitorGradeRate); return rStatZwAlarmCountWVO; diff --git a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/mapper/majornetwork/mapping/RStatLoadTypeMMapper.xml b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/mapper/majornetwork/mapping/RStatLoadTypeMMapper.xml index 12e193a70..7eb455f96 100644 --- a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/mapper/majornetwork/mapping/RStatLoadTypeMMapper.xml +++ b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/mapper/majornetwork/mapping/RStatLoadTypeMMapper.xml @@ -24,15 +24,15 @@ org_no, load_type, v_average, - ROUND( v_count / effective_measurement, 2 ) AS vAccrued, + (case when effective_measurement = 0 then 0 else ROUND( v_count / effective_measurement, 2 ) end) as vAccrued, i_average, - ROUND( i_count / effective_measurement, 2 ) AS iAccrued, + (case when effective_measurement = 0 then 0 else ROUND( i_count / effective_measurement, 2 ) end) as iAccrued, unbalance_average, - ROUND( unbalance_count / effective_measurement, 2 ) AS unbalanceAccrued, + (case when effective_measurement = 0 then 0 else ROUND( unbalance_count / effective_measurement, 2 ) end) as unbalanceAccrued, i_neg_average, - ROUND( i_neg_count / effective_measurement, 2 ) AS iNegAccrued, + (case when effective_measurement = 0 then 0 else ROUND( i_neg_count / effective_measurement, 2 ) end) as iNegAccrued, flicker_average, - ROUND( flicker_count / effective_measurement, 2 ) AS flickerAccrued + (case when effective_measurement = 0 then 0 else ROUND( flicker_count / effective_measurement, 2 ) end) as flickerAccrued from r_stat_load_type_m diff --git a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/majornetwork/impl/RStatHarmonicMServiceImpl.java b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/majornetwork/impl/RStatHarmonicMServiceImpl.java index 92029afe2..330a30cf5 100644 --- a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/majornetwork/impl/RStatHarmonicMServiceImpl.java +++ b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/majornetwork/impl/RStatHarmonicMServiceImpl.java @@ -224,10 +224,11 @@ public class RStatHarmonicMServiceImpl extends ServiceImpl