diff --git a/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/po/ResourceData.java b/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/po/ResourceData.java index 93934235f..cbaebdc13 100644 --- a/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/po/ResourceData.java +++ b/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/po/ResourceData.java @@ -75,4 +75,10 @@ public class ResourceData { */ @TableField(value = "file_name") private String fileName; + + /** + * 图片名称 + */ + @TableField(value = "img_name") + private String imgName; } diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/LineIntegrityDataServiceImpl.java b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/LineIntegrityDataServiceImpl.java index db66bb41f..2f49fbf98 100644 --- a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/LineIntegrityDataServiceImpl.java +++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/LineIntegrityDataServiceImpl.java @@ -203,7 +203,7 @@ public class LineIntegrityDataServiceImpl extends ServiceImpl integrityData = getCondition(lineIndexes, integrityIconParam.getSearchBeginTime(), integrityIconParam.getSearchEndTime()); outParam.setSingle(NumberUtil.round(integrityData.stream().mapToDouble(PublicDTO::getData).average().orElse(3.14159),2).doubleValue()); diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/ResourceServiceImpl.java b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/ResourceServiceImpl.java index 990052737..463710d22 100644 --- a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/ResourceServiceImpl.java +++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/ResourceServiceImpl.java @@ -40,17 +40,20 @@ public class ResourceServiceImpl extends ServiceImpl onlineRateList = getCondition(deviceIndexes, onlineRateCensusParam.getSearchBeginTime(), onlineRateCensusParam.getSearchEndTime()); single.add(onlineRateList.stream().mapToDouble(PublicDTO::getData).average().orElse(3.14159)); diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/influxdb/PqsEventDetailQuery.java b/pqs-event/event-boot/src/main/java/com/njcn/event/influxdb/PqsEventDetailQuery.java index fbd16ccf8..fdad098c0 100644 --- a/pqs-event/event-boot/src/main/java/com/njcn/event/influxdb/PqsEventDetailQuery.java +++ b/pqs-event/event-boot/src/main/java/com/njcn/event/influxdb/PqsEventDetailQuery.java @@ -3,6 +3,7 @@ package com.njcn.event.influxdb; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DateTime; import com.njcn.event.pojo.po.EventDetail; +import com.njcn.event.pojo.po.RmpEventDetailPO; import com.njcn.event.pojo.vo.EventDetailCount; import com.njcn.influxdb.config.InfluxDbConfig; import com.njcn.influxdb.utils.InfluxDbUtils; @@ -137,7 +138,7 @@ public class PqsEventDetailQuery extends QueryBuilder { * @param eventDetailList influxdb数据 * @return 个数 */ - public static Function, Long> countLineIndexes(List eventDetailList) { + public static Function, Long> countLineIndexes(List eventDetailList) { return lineIndexes -> eventDetailList.stream().filter(t -> lineIndexes.contains(t.getLineId())).count(); } @@ -146,7 +147,7 @@ public class PqsEventDetailQuery extends QueryBuilder { * * @return 个数 */ - public static Function, Long> countEventassIndexIsNoEmpty() { + public static Function, Long> countEventassIndexIsNoEmpty() { return eventDetails -> eventDetails.stream().filter(t -> StringUtils.isNotEmpty(t.getEventassIndex())).count(); } @@ -156,7 +157,7 @@ public class PqsEventDetailQuery extends QueryBuilder { * @param eventDetailList influxdb数据 * @return 数据 */ - public static BiFunction> getBetweenTimeEventDetailList(List eventDetailList) { + public static BiFunction> getBetweenTimeEventDetailList(List eventDetailList) { ZoneId zone = ZoneId.systemDefault(); return (beginTime, endTime) -> eventDetailList.stream().filter(eventDetail -> { Instant timeId = eventDetail.getStartTime().atZone(zone).toInstant(); diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaAnalysisServiceImpl.java b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaAnalysisServiceImpl.java index f97520b0c..52e3fb2a7 100644 --- a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaAnalysisServiceImpl.java +++ b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaAnalysisServiceImpl.java @@ -118,6 +118,9 @@ public class AreaAnalysisServiceImpl implements AreaAnalysisService { @Override public VoltageToleranceCurveVO getVoltageToleranceCurve(DeviceInfoParam.BusinessParam deviceInfoParam) { // 获取指定部门下的监测点集合 + if(CollUtil.isEmpty(deviceInfoParam.getScale())&&(CollUtil.isEmpty(deviceInfoParam.getLoadType()))){ + return VoltageToleranceCurveVO.empty(); + } List generalDeviceDTOList = generalDeviceInfoClient.getPracticalAllDeviceInfo(deviceInfoParam).getData(); if (CollUtil.isEmpty(generalDeviceDTOList)) { return VoltageToleranceCurveVO.empty(); diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaLineServiceImpl.java b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaLineServiceImpl.java index 9897d17b0..af96fd6b6 100644 --- a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaLineServiceImpl.java +++ b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaLineServiceImpl.java @@ -187,7 +187,7 @@ public class AreaLineServiceImpl implements AreaLineService { ); List eventdetailList = BeanUtil.copyToList(info, EventHeatDeatilVO.class); if (eventdetailList.size() > 0) { - List lineIds = eventdetailList.stream().map(EventHeatDeatilVO::getLineId).collect(Collectors.toList()); + List lineIds = eventdetailList.stream().map(EventHeatDeatilVO::getLineId).distinct().collect(Collectors.toList()); List areaAnalysisVOList = lineFeignClient.getBaseLineAreaInfo(lineIds).getData(); /* for (EventHeatDeatilVO eventHeat : eventdetailList) { diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaStatisticalServiceImpl.java b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaStatisticalServiceImpl.java index 88e8dafae..ceb016d36 100644 --- a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaStatisticalServiceImpl.java +++ b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaStatisticalServiceImpl.java @@ -66,7 +66,7 @@ public class AreaStatisticalServiceImpl implements AreaStatisticalService { @Override public AreaStatisticalVO getAreaCalculation(DeviceInfoParam.BusinessParam deviceInfoParam) { //获取录波字典信息 - DictData data = dicDataFeignClient.getDicDataByCode(DicDataEnum.RECORDING_WAVE.getCode()).getData(); + DictData data = dicDataFeignClient.getDicDataByCode(DicDataEnum.VOLTAGE_DIP.getCode()).getData(); // 获取指定部门下的监测点集合 List generalDeviceDTOList = generalDeviceInfoClient.getPracticalRunDeviceInfo(deviceInfoParam).getData(); @@ -81,23 +81,22 @@ public class AreaStatisticalServiceImpl implements AreaStatisticalService { List info = eventDetailService.list(new LambdaQueryWrapper() .in(RmpEventDetailPO::getMeasurementPointId, lineIds) //todo 是否缺少录波 - .ne(RmpEventDetailPO::getEventType, data.getId()) + .eq(RmpEventDetailPO::getEventType, data.getId()) .ge(StrUtil.isNotBlank(deviceInfoParam.getSearchBeginTime()), RmpEventDetailPO::getStartTime,DateUtil.beginOfDay(DateUtil.parse(deviceInfoParam.getSearchBeginTime()))) .le(StrUtil.isNotBlank(deviceInfoParam.getSearchEndTime()), RmpEventDetailPO::getStartTime, DateUtil.endOfDay(DateUtil.parse(deviceInfoParam.getSearchEndTime()))) ); - List eventDetailList = BeanUtil.copyToList(info,EventDetail.class); - if (CollUtil.isEmpty(eventDetailList)) { + if (CollUtil.isEmpty(info)) { return AreaStatisticalVO.empty(); } - AreaStatisticsVO areaStatisticsVO = statisticsAreaInfo(generalDeviceDTOList, eventDetailList); + AreaStatisticsVO areaStatisticsVO = statisticsAreaInfo(generalDeviceDTOList, info); - MonthlyStatisticsVO monthCalculationVOS = statisticsMonthInfo(deviceInfoParam, eventDetailList); + MonthlyStatisticsVO monthCalculationVOS = statisticsMonthInfo(deviceInfoParam, info); deviceInfoParam.getStatisticalType().setCode(StatisticsEnum.VOLTAGE_LEVEL.getCode()); List voltageLevelList = generalDeviceInfoClient.getPracticalRunDeviceInfo(deviceInfoParam).getData(); - VoltageStatisticsVO voltageStatisticsVO = statisticalVoltageLevelInfo(voltageLevelList, eventDetailList); + VoltageStatisticsVO voltageStatisticsVO = statisticalVoltageLevelInfo(voltageLevelList, info); return AreaStatisticalVO.buildVO(areaStatisticsVO, voltageStatisticsVO, monthCalculationVOS); } @@ -109,7 +108,7 @@ public class AreaStatisticalServiceImpl implements AreaStatisticalService { * @param eventDetailList influxdb数据 * @return 统计月份信息 */ - private MonthlyStatisticsVO statisticsMonthInfo(DeviceInfoParam.BusinessParam deviceInfoParam, List eventDetailList) { + private MonthlyStatisticsVO statisticsMonthInfo(DeviceInfoParam.BusinessParam deviceInfoParam, List eventDetailList) { List timeLimit = calculateTheTimePeriodRange(deviceInfoParam); List monthStartAndEnd = new ArrayList<>(); if(deviceInfoParam.getTimeFlag()==0){ @@ -127,7 +126,7 @@ public class AreaStatisticalServiceImpl implements AreaStatisticalService { DateTime beginMon = monthStartAndEnd.get(i); DateTime endMon = monthStartAndEnd.get(i + 1); - List eventDetails = getBetweenTimeEventDetailList(eventDetailList).apply(beginMon, endMon); + List eventDetails = getBetweenTimeEventDetailList(eventDetailList).apply(beginMon, endMon); // 时间段内总记录数 Long count = (long) eventDetails.size(); @@ -161,7 +160,7 @@ public class AreaStatisticalServiceImpl implements AreaStatisticalService { * @param eventDetailList influxdb数据 * @return 统计电压等级信息 */ - private VoltageStatisticsVO statisticalVoltageLevelInfo(List generalDeviceDTOList, List eventDetailList) { + private VoltageStatisticsVO statisticalVoltageLevelInfo(List generalDeviceDTOList, List eventDetailList) { List voltageLevelCalculation = generalDeviceDTOList.parallelStream().map(t -> { VoltageLevelCalculationVO voltageLevelCalculationVO = new VoltageLevelCalculationVO(); voltageLevelCalculationVO.setVoltageLevel(t.getName()); @@ -184,7 +183,7 @@ public class AreaStatisticalServiceImpl implements AreaStatisticalService { * @param eventDetailList influxdb数据 * @return 统计区域信息 */ - private AreaStatisticsVO statisticsAreaInfo(List generalDeviceDTOList, List eventDetailList) { + private AreaStatisticsVO statisticsAreaInfo(List generalDeviceDTOList, List eventDetailList) { List areaCalculation = generalDeviceDTOList.parallelStream().map(t -> { AreaCalculationVO calculationVO = new AreaCalculationVO(); calculationVO.setAreaName(t.getName()); diff --git a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/SteadyExceedRateServiceImpl.java b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/SteadyExceedRateServiceImpl.java index ef0ac4b7f..4629f090b 100644 --- a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/SteadyExceedRateServiceImpl.java +++ b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/SteadyExceedRateServiceImpl.java @@ -89,7 +89,7 @@ public class SteadyExceedRateServiceImpl implements SteadyExceedRateService { if (!CollectionUtils.isEmpty(deviceDataList)) { List> maps=new ArrayList<>(); for (GeneralDeviceDTO generalDeviceDTO: deviceDataList) { - type.add(generalDeviceDTO.getName()); + type.add("("+generalDeviceDTO.getDeviceIndexes().size()+")"+generalDeviceDTO.getName()); List lineIndexes = generalDeviceDTO.getLineIndexes(); Map collect=new HashMap<>(); diff --git a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/SteadyQualifyServiceImpl.java b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/SteadyQualifyServiceImpl.java index 37ca67e09..1a5956507 100644 --- a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/SteadyQualifyServiceImpl.java +++ b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/SteadyQualifyServiceImpl.java @@ -116,7 +116,7 @@ public class SteadyQualifyServiceImpl implements SteadyQualifyService { if (CollectionUtils.isEmpty(lineIndexes)) { continue; } - type.add(generalDeviceDTO.getName()); + type.add(generalDeviceDTO.getName()+"\n("+generalDeviceDTO.getDeviceIndexes().size()+")"); List qualifiesRate = getQualifiesRate(lineIndexes, steadyCensusParam.getSearchBeginTime(), steadyCensusParam.getSearchEndTime()); SteadyQualifyVO dataMoreMonitorMoreDay = getDataMoreMonitorMoreDay(qualifiesRate); harmonicVoltage.add(dataMoreMonitorMoreDay.getHarmonicVoltage()); diff --git a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/THDistortionServiceImpl.java b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/THDistortionServiceImpl.java index d4294834c..f602445d9 100644 --- a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/THDistortionServiceImpl.java +++ b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/THDistortionServiceImpl.java @@ -101,7 +101,7 @@ public class THDistortionServiceImpl implements THDistortionService { if (CollectionUtils.isEmpty(lineIndexes)) { continue; } - type.add(generalDeviceDTO.getName()); + type.add(generalDeviceDTO.getName()+"\n("+generalDeviceDTO.getDeviceIndexes().size()+")"); List condition = getCondition(lineIndexes, thDistortionCensusParam.getSearchBeginTime(), thDistortionCensusParam.getSearchEndTime()); single.add(roundHalfUp(condition.stream().mapToDouble(PublicDTO::getData).average().orElse(3.14159))); } diff --git a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/TerminalServiceImpl.java b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/TerminalServiceImpl.java index ab6959d04..e5e666ee1 100644 --- a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/TerminalServiceImpl.java +++ b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/TerminalServiceImpl.java @@ -88,7 +88,7 @@ public class TerminalServiceImpl implements TerminalService { if (CollectionUtils.isEmpty(generalDeviceDTO.getDeviceIndexes())) { continue; } - type.add(generalDeviceDTO.getName()); + type.add(generalDeviceDTO.getName()+"\n("+generalDeviceDTO.getDeviceIndexes().size()+")"); List deviceIndexes = generalDeviceDTO.getDeviceIndexes(); //根据终端查询在线率 List condition = getCondition(deviceIndexes, terminalCensusParam.getSearchBeginTime(), terminalCensusParam.getSearchEndTime());