diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/area/RStatHarmonicVoltageServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/area/RStatHarmonicVoltageServiceImpl.java index 59e138fdc..8c09c3630 100644 --- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/area/RStatHarmonicVoltageServiceImpl.java +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/area/RStatHarmonicVoltageServiceImpl.java @@ -250,18 +250,20 @@ public class RStatHarmonicVoltageServiceImpl implements RStatHarmonicVoltageServ List lineBaseList = deptGetChildrenMoreDTO.getLineBaseList(); Map> collect = lineBaseList.stream().collect(Collectors.groupingBy(LineDevGetDTO::getLineTag)); collect.forEach((k, v) -> { - List collect1 = v.stream().map(LineDevGetDTO::getPointId).collect(Collectors.toList()); Map> collect2 = v.stream().collect(Collectors.groupingBy(LineDevGetDTO::getVoltageLevel)); collect2.forEach((k1, v1) -> { + + List collect3 = v1.stream().map(LineDevGetDTO::getPointId).collect(Collectors.toList()); + queryWrapper.clear(); queryWrapper.select("freq_over_day", "v_dev_over_day", "v_over_day", "i_over_day", "unbalance_over_day", "i_neg_over_day"). - in("measurement_point_id", collect1). + in("measurement_point_id", collect3). between("data_date",begin,end); List rMpPartHarmonicDetailMS = rMpPartHarmonicDetailMMapper.selectList(queryWrapper); rMpSurplusHarmonicDetailMQueryWrapper.clear(); rMpSurplusHarmonicDetailMQueryWrapper.select("flicker_over_day", "inuharm_over_day"). - in("measurement_point_id", collect1). + in("measurement_point_id", collect3). between("data_date",begin,end); List rMpSurplusHarmonicDetailMS = rMpSurplusHarmonicDetailMMapper.selectList(rMpSurplusHarmonicDetailMQueryWrapper); @@ -303,7 +305,7 @@ public class RStatHarmonicVoltageServiceImpl implements RStatHarmonicVoltageServ rStatHarmonicVoltageMPO.setOverLimitMeasurementAverage(asDouble); double asDouble1 = list.stream().mapToDouble(RStatHarmonicVoltageDPO::getOverLimitMeasurementRatioAverage).average().getAsDouble(); asDouble1 = BigDecimal.valueOf(asDouble1).setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue(); - rStatHarmonicVoltageMPO.setOverLimitMeasurementRatioAccrued(asDouble); + rStatHarmonicVoltageMPO.setOverLimitMeasurementRatioAccrued(asDouble1); int sum = list.stream().mapToInt(RStatHarmonicVoltageDPO::getOverLimitMeasurementAverage).sum(); rStatHarmonicVoltageMPO.setOverDay(sum);