diff --git a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/mapper/mapping/CsEventUserPOMapper.xml b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/mapper/mapping/CsEventUserPOMapper.xml index e96183b..ba46498 100644 --- a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/mapper/mapping/CsEventUserPOMapper.xml +++ b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/mapper/mapping/CsEventUserPOMapper.xml @@ -277,7 +277,6 @@ AND b.tag = #{csEventUserQueryPage.eventType} - AND b.location = #{csEventUserQueryPage.location} diff --git a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/CsEventPOServiceImpl.java b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/CsEventPOServiceImpl.java index befa182..b45dca9 100644 --- a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/CsEventPOServiceImpl.java +++ b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/CsEventPOServiceImpl.java @@ -884,8 +884,11 @@ public class CsEventPOServiceImpl extends ServiceImpl deviceRtData = commonService.getDeviceRtDataByTime(commonQueryParams); if (CollectionUtil.isNotEmpty(deviceRtData)) { Map > map = deviceRtData.stream().collect(Collectors.groupingBy(StatisticalDataDTO::getLineId)); - map.forEach((key, value) -> { - if (!Objects.isNull(loadSideLine) && Objects.equals(key, loadSideLine.getLineId())) { - List collect1 = value.stream().map(temp -> { - ThdDataVO vo = new ThdDataVO(); - vo.setLineId(temp.getLineId()); - vo.setPhase(temp.getPhaseType()); - vo.setPosition(loadSideLine.getPosition()); - vo.setTime(temp.getTime()); - vo.setStatMethod(temp.getValueType()); - vo.setStatisticalData(Double.valueOf(df.format(temp.getValue()))); - vo.setStatisticalIndex(epdPqd.getId()); - vo.setUnit(epdPqd.getUnit()); - vo.setStatisticalName(epdPqd.getName()); - vo.setAnotherName("治理前"); - return vo; - }).collect(Collectors.toList()); - result.addAll(collect1); - } - if (!Objects.isNull(gridSideLine) && Objects.equals(key, gridSideLine.getLineId())) { - List collect1 = value.stream().map(temp -> { - ThdDataVO vo = new ThdDataVO(); - vo.setLineId(temp.getLineId()); - vo.setPhase(temp.getPhaseType()); - vo.setPosition(gridSideLine.getPosition()); - vo.setTime(temp.getTime()); - vo.setStatMethod(temp.getValueType()); - vo.setStatisticalData(Double.valueOf(df.format(temp.getValue()))); - vo.setStatisticalIndex(epdPqd.getId()); - vo.setUnit(epdPqd.getUnit()); - vo.setStatisticalName(epdPqd.getName()); - vo.setAnotherName("治理后"); - return vo; - }).collect(Collectors.toList()); - result.addAll(collect1); - } - }); + + List loadSideData = map.get(loadSideLine.getLineId()); + if (CollectionUtil.isNotEmpty(loadSideData)) { + List collect1 = loadSideData.stream().map(temp -> { + ThdDataVO vo = new ThdDataVO(); + vo.setLineId(temp.getLineId()); + vo.setPhase(temp.getPhaseType()); + vo.setPosition(loadSideLine.getPosition()); + vo.setTime(temp.getTime()); + vo.setStatMethod(temp.getValueType()); + vo.setStatisticalData(Double.valueOf(df.format(temp.getValue()))); + vo.setStatisticalIndex(epdPqd.getId()); + vo.setUnit(epdPqd.getUnit()); + vo.setStatisticalName(epdPqd.getName()); + vo.setAnotherName("治理前"); + return vo; + }).collect(Collectors.toList()); + result.addAll(collect1); + } + + List gridSideData = map.get(gridSideLine.getLineId()); + if (CollectionUtil.isNotEmpty(gridSideData)) { + List collect2 = gridSideData.stream().map(temp -> { + ThdDataVO vo = new ThdDataVO(); + vo.setLineId(temp.getLineId()); + vo.setPhase(temp.getPhaseType()); + vo.setPosition(gridSideLine.getPosition()); + vo.setTime(temp.getTime()); + vo.setStatMethod(temp.getValueType()); + vo.setStatisticalData(Double.valueOf(df.format(temp.getValue()))); + vo.setStatisticalIndex(epdPqd.getId()); + vo.setUnit(epdPqd.getUnit()); + vo.setStatisticalName(epdPqd.getName()); + vo.setAnotherName("治理后"); + return vo; + }).collect(Collectors.toList()); + result.addAll(collect2); + } + +// map.forEach((key, value) -> { +// if (!Objects.isNull(loadSideLine) && Objects.equals(key, loadSideLine.getLineId())) { +// List collect1 = value.stream().map(temp -> { +// ThdDataVO vo = new ThdDataVO(); +// vo.setLineId(temp.getLineId()); +// vo.setPhase(temp.getPhaseType()); +// vo.setPosition(loadSideLine.getPosition()); +// vo.setTime(temp.getTime()); +// vo.setStatMethod(temp.getValueType()); +// vo.setStatisticalData(Double.valueOf(df.format(temp.getValue()))); +// vo.setStatisticalIndex(epdPqd.getId()); +// vo.setUnit(epdPqd.getUnit()); +// vo.setStatisticalName(epdPqd.getName()); +// vo.setAnotherName("治理前"); +// return vo; +// }).collect(Collectors.toList()); +// result.addAll(collect1); +// } +// if (!Objects.isNull(gridSideLine) && Objects.equals(key, gridSideLine.getLineId())) { +// List collect1 = value.stream().map(temp -> { +// ThdDataVO vo = new ThdDataVO(); +// vo.setLineId(temp.getLineId()); +// vo.setPhase(temp.getPhaseType()); +// vo.setPosition(gridSideLine.getPosition()); +// vo.setTime(temp.getTime()); +// vo.setStatMethod(temp.getValueType()); +// vo.setStatisticalData(Double.valueOf(df.format(temp.getValue()))); +// vo.setStatisticalIndex(epdPqd.getId()); +// vo.setUnit(epdPqd.getUnit()); +// vo.setStatisticalName(epdPqd.getName()); +// vo.setAnotherName("治理后"); +// return vo; +// }).collect(Collectors.toList()); +// result.addAll(collect1); +// } +// }); } }); }