From f3f04ae66eff4ccb44e85e62e2adb0df6882ba42 Mon Sep 17 00:00:00 2001
From: wurui <wurui@163.com>
Date: Mon, 6 Mar 2023 11:40:04 +0800
Subject: [PATCH] =?UTF-8?q?1.=E5=8F=B0=E8=B4=A6=E6=9F=A5=E8=AF=A2bug?=
 =?UTF-8?q?=E6=8F=90=E4=BA=A4=202.=E6=B1=A1=E5=8C=BA=E5=9B=BE=E4=BB=A3?=
 =?UTF-8?q?=E7=A0=81=E6=9B=B4=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mapping/DistributionMonitorMapper.xml     |   2 +-
 .../impl/PmsGeneralDeviceServiceImpl.java     |   1 +
 .../impl/PmsSummaryStatisticsServiceImpl.java |  54 ++----
 .../impl/PollutionSubstationServiceImpl.java  | 154 +++++++++++-------
 4 files changed, 113 insertions(+), 98 deletions(-)

diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/mapping/DistributionMonitorMapper.xml b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/mapping/DistributionMonitorMapper.xml
index ce2f0b39c..cb1bc2d02 100644
--- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/mapping/DistributionMonitorMapper.xml
+++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/mapping/DistributionMonitorMapper.xml
@@ -5,7 +5,7 @@
 
     <select id="getIdByOrgId" resultType="com.njcn.device.pms.pojo.dto.PmsMonitorBaseDTO">
         SELECT
-            t.Operation_Id operationId,t.Power_Station_Id powerrId,t.Line_Id lineId,t.id monitorId
+            t.Operation_Id operationId,t.Power_Station_Id powerrId,t.Line_Id lineId,t.id monitorId,b.Terminal_Id terminalId
         FROM
             (
                 ( SELECT id, Operation_Id, Power_Station_Id, Line_Id FROM pms_power_client WHERE org_id IN
diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/PmsGeneralDeviceServiceImpl.java b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/PmsGeneralDeviceServiceImpl.java
index bb41fa85f..95ceba17d 100644
--- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/PmsGeneralDeviceServiceImpl.java
+++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/PmsGeneralDeviceServiceImpl.java
@@ -146,6 +146,7 @@ public class PmsGeneralDeviceServiceImpl implements IPmsGeneralDeviceService {
         //获取monitor详细数据
         List<PmsMonitorBaseDTO> monitorList = iDistributionMonitorService.getMonitorByCondition(deptIdList,pmsDeviceInfoParam);
         pmsGeneralDeviceDTO.setPowerrIdList(monitorList.stream().map(PmsMonitorBaseDTO::getPowerrId).distinct().collect(Collectors.toList()));
+        pmsGeneralDeviceDTO.setTerminalIdList(monitorList.stream().map(PmsMonitorBaseDTO::getTerminalId).distinct().collect(Collectors.toList()));
         pmsGeneralDeviceDTO.setLineIdList(monitorList.stream().map(PmsMonitorBaseDTO::getLineId).distinct().collect(Collectors.toList()));
         pmsGeneralDeviceDTO.setMonitorIdList(monitorList.stream().map(PmsMonitorBaseDTO::getMonitorId).distinct().collect(Collectors.toList()));
         return pmsGeneralDeviceDTO;
diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/PmsSummaryStatisticsServiceImpl.java b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/PmsSummaryStatisticsServiceImpl.java
index 663539565..9e84c4953 100644
--- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/PmsSummaryStatisticsServiceImpl.java
+++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/PmsSummaryStatisticsServiceImpl.java
@@ -4,16 +4,13 @@ import cn.hutool.core.collection.CollectionUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.njcn.common.pojo.dto.SimpleDTO;
 import com.njcn.common.pojo.enums.common.DataStateEnum;
-import com.njcn.device.pms.api.PmsGeneralDeviceInfoClient;
 import com.njcn.device.pms.mapper.majornetwork.MonitorMapper;
 import com.njcn.device.pms.pojo.dto.PmsGeneralDeviceDTO;
-import com.njcn.device.pms.pojo.dto.PwPmsMonitorDTO;
 import com.njcn.device.pms.pojo.param.PmsDeviceInfoParam;
 import com.njcn.device.pms.pojo.param.PmsSummaryStatisticsParam;
-import com.njcn.device.pms.pojo.param.PwPmsMonitorParam;
 import com.njcn.device.pms.pojo.po.Monitor;
 import com.njcn.device.pms.pojo.vo.PmsSummaryStatisticsVO;
-import com.njcn.device.pms.service.distribution.IPwMonitorService;
+import com.njcn.device.pms.service.majornetwork.IPmsGeneralDeviceService;
 import com.njcn.device.pms.service.majornetwork.PmsSummaryStatisticsService;
 import com.njcn.user.api.DeptFeignClient;
 import com.njcn.user.pojo.dto.DeptDTO;
@@ -37,8 +34,8 @@ public class PmsSummaryStatisticsServiceImpl implements PmsSummaryStatisticsServ
 
     private final DeptFeignClient deptFeignClient;
     private final MonitorMapper monitorMapper;
-    private final IPwMonitorService iPwMonitorService;
-    private final PmsGeneralDeviceInfoClient pmsGeneralDeviceInfoClient;
+    private final IPmsGeneralDeviceService generalPmsDeviceService;;
+
 
     @Override
     public List<PmsSummaryStatisticsVO.SummaryVO> getSeparate(PmsSummaryStatisticsParam param) {
@@ -49,7 +46,7 @@ public class PmsSummaryStatisticsServiceImpl implements PmsSummaryStatisticsServ
             PmsDeviceInfoParam pmsDeviceInfoParam = new PmsDeviceInfoParam();
             pmsDeviceInfoParam.setDeptIndex(param.getOrgId());
             pmsDeviceInfoParam.setStatisticalType(new SimpleDTO());
-            List<PmsGeneralDeviceDTO> deptData = pmsGeneralDeviceInfoClient.getPmsDeviceInfoWithInOrg(pmsDeviceInfoParam).getData();
+            List<PmsGeneralDeviceDTO> deptData = generalPmsDeviceService.getPmsDeviceInfoWithInOrg(pmsDeviceInfoParam);
             deptData.forEach(item -> {
                 PmsSummaryStatisticsVO.SummaryVO vo = new PmsSummaryStatisticsVO.SummaryVO();
                 vo.setName(item.getName());
@@ -59,7 +56,7 @@ public class PmsSummaryStatisticsServiceImpl implements PmsSummaryStatisticsServ
             });
         } else {
             //获取当前部门下的子部门
-            List<DeptDTO> data = deptFeignClient.getDepSonDetailByDeptId(param.getOrgId()).getData();
+            List<DeptDTO> data = deptFeignClient.getDeptDescendantIndexes(param.getOrgId(), WebUtil.filterDeptType()).getData();
 
             List<String> deptIds = data.stream().map(DeptDTO::getCode).collect(Collectors.toList());
 
@@ -190,41 +187,18 @@ public class PmsSummaryStatisticsServiceImpl implements PmsSummaryStatisticsServ
     public List<PmsSummaryStatisticsVO.SummaryVO> getDistributionPoint(PmsSummaryStatisticsParam.PwSummaryStatisticsParam param) {
         List<PmsSummaryStatisticsVO.SummaryVO> vos = new ArrayList<>();
 
-        PwPmsMonitorParam pwParam = new PwPmsMonitorParam();
-        pwParam.setOrgId(param.getOrgId());
-        List<PwPmsMonitorDTO> pwSubsetMonitorList = iPwMonitorService.getPwSubsetMonitorList(pwParam);
-        //获取配网监测点,统计配网有多少监测点
-        Map<String, List<PwPmsMonitorDTO>> pwMonitor = pwSubsetMonitorList.stream().collect(Collectors.groupingBy(PwPmsMonitorDTO::getOrgId));
-
-        //获取当前部门下的子部门
-        List<DeptDTO> data = deptFeignClient.getDepSonDetailByDeptId(param.getOrgId()).getData();
-        Map<String, String> deptMap = data.stream().collect(Collectors.toMap(DeptDTO::getCode, DeptDTO::getName));
-
-        ArrayList<PwPmsMonitorDTO> monitorsCounts = pwSubsetMonitorList.stream().collect(Collectors.collectingAndThen
-                (Collectors.toCollection(() ->
-                        new TreeSet<>(Comparator.comparing(o -> o.getOrgId() + ";" + o.getTerminalId()))), ArrayList::new));
-
-        //根据部门统计有多少终端（终端数量）
-        Map<String, Long> monitorsTerminalCount = monitorsCounts.stream()
-                .collect(Collectors.groupingBy(PwPmsMonitorDTO::getOrgId, Collectors.counting()));
-
-
-        deptMap.forEach((key, value) -> {
+        PmsDeviceInfoParam pmsDeviceInfoParam = new PmsDeviceInfoParam();
+        pmsDeviceInfoParam.setDeptIndex(param.getOrgId());
+        pmsDeviceInfoParam.setStatisticalType(new SimpleDTO());
+        List<PmsGeneralDeviceDTO> deptData = generalPmsDeviceService.getPmsDeviceInfoByOrgId(pmsDeviceInfoParam);
+        deptData.forEach(item -> {
             PmsSummaryStatisticsVO.SummaryVO vo = new PmsSummaryStatisticsVO.SummaryVO();
-            if (pwMonitor.containsKey(key)) {
-                vo.setName(value);
-                vo.setMonitorCount(pwMonitor.get(key).size());
-                vo.setTerminalCount(Math.toIntExact(monitorsTerminalCount.get(key)));
-
-            } else {
-                vo.setName(value);
-                //监测点数量
-                vo.setMonitorCount(0);
-                //设备数量
-                vo.setTerminalCount(0);
-            }
+            vo.setName(item.getName());
+            vo.setMonitorCount(item.getMonitorIdList().size());
+            vo.setTerminalCount(item.getTerminalIdList().size());
             vos.add(vo);
         });
+
         return vos;
     }
 
diff --git a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/PollutionSubstationServiceImpl.java b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/PollutionSubstationServiceImpl.java
index 335e2b4f2..995aa2856 100644
--- a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/PollutionSubstationServiceImpl.java
+++ b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/PollutionSubstationServiceImpl.java
@@ -1,11 +1,11 @@
 package com.njcn.harmonic.service.impl;
 
 import cn.hutool.core.collection.CollectionUtil;
+import cn.hutool.core.util.ObjectUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.njcn.common.config.GeneralInfo;
 import com.njcn.common.pojo.constant.BizParamConstant;
-import com.njcn.common.pojo.dto.SimpleDTO;
 import com.njcn.common.pojo.enums.response.CommonResponseEnum;
 import com.njcn.common.pojo.exception.BusinessException;
 import com.njcn.device.pms.api.MonitorClient;
@@ -28,6 +28,8 @@ import com.njcn.harmonic.pojo.po.*;
 import com.njcn.harmonic.pojo.vo.PollutionSubstationVO;
 import com.njcn.harmonic.pojo.vo.PollutionVO;
 import com.njcn.harmonic.service.PollutionSubstationService;
+import com.njcn.user.api.DeptFeignClient;
+import com.njcn.user.pojo.po.Dept;
 import com.njcn.web.utils.RequestUtil;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -37,6 +39,7 @@ import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
 import java.util.*;
+import java.util.function.Function;
 import java.util.stream.Collectors;
 
 /**
@@ -59,6 +62,7 @@ public class PollutionSubstationServiceImpl extends ServiceImpl<RStatPollutionSu
     private final PmsGeneralDeviceInfoClient pmsGeneralDeviceInfoClient;
     private final StatationStatClient statationStatClient;
     private final MonitorClient monitorClient;
+    private final DeptFeignClient deptFeignClient;
 
     private final RStatPollutionSubstationMMapper pollutionSubstationMMapper;
     private final RStatPollutionSubstationYPOMapper pollutionSubstationYPOMapper;
@@ -170,7 +174,7 @@ public class PollutionSubstationServiceImpl extends ServiceImpl<RStatPollutionSu
             return list;
         }
 
-        if (harmonicPublicParam.getType() == 0) {
+        if (harmonicPublicParam.getType() != 0) {
             PmsDeviceInfoParam pmsDeviceInfoParam = new PmsDeviceInfoParam();
             pmsDeviceInfoParam.setDeptIndex(harmonicPublicParam.getDeptIndex());
             //获取统计类型
@@ -187,29 +191,34 @@ public class PollutionSubstationServiceImpl extends ServiceImpl<RStatPollutionSu
                 pollutionVO.setData (-1.0);
                 setData(harmonicPublicParam, pollutionType, searchBeginTime, pollutionVO, detpid);
 
-                //子集变电站
-                List<PollutionVO> powersVO = new ArrayList<>();
-                PmsStatationStatInfoParam param=new PmsStatationStatInfoParam();
-                param.setPowerIds(powers);
-                List<PmsStatationStatInfoDTO> data = statationStatClient.getStatationStatInfo(param).getData();
-                //去重解决重复数据
-                ArrayList<PmsStatationStatInfoDTO> dsData = data.stream().collect(Collectors.collectingAndThen
-                        (Collectors.toCollection(() ->
-                                new TreeSet<>(Comparator.comparing(o -> o.getPowerId()))), ArrayList::new));
-                Map<String, Double> stringDoubleMap = setPmsSubData(harmonicPublicParam, pollutionType, searchBeginTime, powers);
-                if(CollectionUtil.isNotEmpty(data)){
-                    dsData.forEach(power->{
-                        PollutionVO pollutionsubVO = new PollutionVO ();
-                        pollutionsubVO.setId (power.getPowerId());
-                        pollutionsubVO.setName ( power.getPowerName ());
-                        pollutionsubVO.setPid (temp.getIndex ());
-                        if(stringDoubleMap.containsKey(power.getPowerId())){
-                            pollutionsubVO.setData(stringDoubleMap.get(power.getPowerId()));
-                        }
-                        powersVO.add (pollutionsubVO) ;
-                    });
+                if(CollectionUtil.isNotEmpty(powers)){
+                    //子集变电站
+                    List<PollutionVO> powersVO = new ArrayList<>();
+                    PmsStatationStatInfoParam param=new PmsStatationStatInfoParam();
+                    param.setPowerIds(powers);
+                    List<PmsStatationStatInfoDTO> data = statationStatClient.getStatationStatInfo(param).getData();
+                    //去重解决重复数据
+                    ArrayList<PmsStatationStatInfoDTO> dsData = data.stream().collect(Collectors.collectingAndThen
+                            (Collectors.toCollection(() ->
+                                    new TreeSet<>(Comparator.comparing(o -> o.getPowerId()))), ArrayList::new));
+                    Map<String, Double> stringDoubleMap = setPmsSubData(harmonicPublicParam, pollutionType, searchBeginTime, powers);
+                    if(CollectionUtil.isNotEmpty(data)){
+                        dsData.forEach(power->{
+                            PollutionVO pollutionsubVO = new PollutionVO ();
+                            pollutionsubVO.setId (power.getPowerId());
+                            pollutionsubVO.setName ( power.getPowerName ());
+                            pollutionsubVO.setPid (temp.getIndex ());
+                            if(CollectionUtil.isNotEmpty(stringDoubleMap)){
+                                if(stringDoubleMap.containsKey(power.getPowerId())){
+                                    pollutionsubVO.setData(stringDoubleMap.get(power.getPowerId()));
+                                }
+                            }
+                            powersVO.add (pollutionsubVO) ;
+                        });
+                    }
+                    powersVO.sort((item1, item2) -> item2.getData().compareTo(item1.getData()));
+                    pollutionVO.setChildren (powersVO);
                 }
-                pollutionVO.setChildren (powersVO);
                 list.add (pollutionVO);
             });
 
@@ -378,35 +387,46 @@ public class PollutionSubstationServiceImpl extends ServiceImpl<RStatPollutionSu
         String searchBeginTime = deptParam.getSearchBeginTime ( ).substring (0,10);
         List<PollutionSubstationDTO> list = new ArrayList<>();
 
-        if (deptParam.getType() == 0) {
+        if (deptParam.getType() != 0) {
             PmsDeviceInfoParam pmsDeviceInfoParam = new PmsDeviceInfoParam();
-            pmsDeviceInfoParam.setDeptIndex(deptParam.getDeptIndex());
+            //根据部门code获取部门id
+            Dept dept = deptFeignClient.getDeptByCode(deptParam.getDeptIndex()).getData();
+            if(ObjectUtil.isNull(dept)){
+                return list;
+            }
+            pmsDeviceInfoParam.setDeptIndex(dept.getId());
             //获取统计类型
             pmsDeviceInfoParam.setStatisticalType(deptParam.getStatisticalType());
             //获取主网台账信息
             List<PmsGeneralDeviceDTO> deviceList = pmsGeneralDeviceInfoClient.getPmsDeviceInfoWithInOrg(pmsDeviceInfoParam).getData();
             deviceList.forEach(temp->{
                 List<String> powers = temp.getPowerrIdList ( );
-                PmsStatationStatInfoParam param=new PmsStatationStatInfoParam();
-                param.setPowerIds(powers);
-                List<PmsStatationStatInfoDTO> data = statationStatClient.getStatationStatInfo(param).getData();
-                //去重解决重复数据
-                ArrayList<PmsStatationStatInfoDTO> dsData = data.stream().collect(Collectors.collectingAndThen
-                        (Collectors.toCollection(() ->
-                                new TreeSet<>(Comparator.comparing(o -> o.getPowerId()))), ArrayList::new));
-                Map<String, Double> stringDoubleMap = setPmsSubData(deptParam, pollutionType, searchBeginTime, powers);
-                if(CollectionUtil.isNotEmpty(data)){
-                    dsData.forEach(power->{
-                        PollutionSubstationDTO dto=new PollutionSubstationDTO();
-                        dto.setId(power.getPowerId());
-                        dto.setName(power.getPowerName());
-                        dto.setVoltageLevel(power.getPowerVoltageLevel());
-                        if(stringDoubleMap.containsKey(power.getPowerId())){
-                            dto.setData(stringDoubleMap.get(power.getPowerId()));
-                        }
-                        list.add (dto) ;
-                    });
+                //变电站不为空
+                if(CollectionUtil.isNotEmpty(powers)){
+                    PmsStatationStatInfoParam param=new PmsStatationStatInfoParam();
+                    param.setPowerIds(powers);
+                    List<PmsStatationStatInfoDTO> data = statationStatClient.getStatationStatInfo(param).getData();
+                    //去重解决重复数据
+                    ArrayList<PmsStatationStatInfoDTO> dsData = data.stream().collect(Collectors.collectingAndThen
+                            (Collectors.toCollection(() ->
+                                    new TreeSet<>(Comparator.comparing(o -> o.getPowerId()))), ArrayList::new));
+                    Map<String, Double> stringDoubleMap = setPmsSubData(deptParam, pollutionType, searchBeginTime, powers);
+                    if(CollectionUtil.isNotEmpty(data)){
+                        dsData.forEach(power->{
+                            PollutionSubstationDTO dto=new PollutionSubstationDTO();
+                            dto.setId(power.getPowerId());
+                            dto.setName(power.getPowerName());
+                            dto.setVoltageLevel(power.getPowerVoltageLevel());
+                            if(CollectionUtil.isNotEmpty(stringDoubleMap)){
+                                if(stringDoubleMap.containsKey(power.getPowerId())){
+                                    dto.setData(stringDoubleMap.get(power.getPowerId()));
+                                }
+                            }
+                            list.add (dto) ;
+                        });
+                    }
                 }
+
             });
         }else{
             deptParam.setServerName(generalInfo.getMicroServiceName());
@@ -487,9 +507,10 @@ public class PollutionSubstationServiceImpl extends ServiceImpl<RStatPollutionSu
         if (StringUtils.isBlank(RequestUtil.getDeptIndex())){
             return list;
         }
-        if (harmonicPublicParam.getType() == 0) {
+        if (harmonicPublicParam.getType() != 0) {
             PmsStatationStatInfoParam param=new PmsStatationStatInfoParam();
             param.setPowerIds(Arrays.asList(harmonicPublicParam.getId()));
+            //获取变电站详情
             List<PmsStatationStatInfoDTO> data = statationStatClient.getStatationStatInfo(param).getData();
             if(CollectionUtil.isNotEmpty(data)){
                 List<String> monitorId = data.stream().map(PmsStatationStatInfoDTO::getMonitorId).collect(Collectors.toList());
@@ -504,8 +525,10 @@ public class PollutionSubstationServiceImpl extends ServiceImpl<RStatPollutionSu
                     dto.setSubstation(power.getPowerName());
                     dto.setSubstationId(power.getPowerId());
                     dto.setBusBar(power.getGeneratrixName());
-                    if(lineMap.containsKey(power.getMonitorId())){
-                        dto.setData(lineMap.get(power.getMonitorId()));
+                    if(CollectionUtil.isNotEmpty(lineMap)){
+                        if(lineMap.containsKey(power.getMonitorId())){
+                            dto.setData(lineMap.get(power.getMonitorId()));
+                        }
                     }
                     list.add (dto) ;
                 }
@@ -539,6 +562,7 @@ public class PollutionSubstationServiceImpl extends ServiceImpl<RStatPollutionSu
 
     @Override
     public List<PollutionLineDTO> getLineRank(HarmonicPublicParam param) {
+        List<PollutionLineDTO> list=  new ArrayList<>();
         String pollutionType = param.getStatisticalType ( ).getId ();
         String searchBeginTime = "";
         if(Objects.equals (param.getReportFlag (),BizParamConstant.STAT_BIZ_YEAR) ){
@@ -564,22 +588,38 @@ public class PollutionSubstationServiceImpl extends ServiceImpl<RStatPollutionSu
         });
 
         if(CollectionUtil.isNotEmpty(monitorIdList)){
+            //获取监测点数据
             List<RMpPollutionDPO> lineData = rMpPollutionDPOMapper.selectMaxList ( monitorIdList,pollutionType,searchBeginTime);
+
+            if(CollectionUtil.isEmpty(lineData)){
+                return list;
+            }
+
+            //获取主网监测点信息
+            List<Monitor> data = monitorClient.getMonitorList(monitorIdList).getData();
+            Map<String, Monitor> monitorMap = data.stream().collect(Collectors.toMap(Monitor::getId, Function.identity(), (key1, kye2) -> key1));
             lineData.sort((item1, item2) -> item2.getValue().compareTo(item1.getValue()));
             if (lineData.size() > Param.UP_LIMIT) {
                 lineData = lineData.subList(Param.DOWN_LIMIT, Param.UP_LIMIT);
             }
 
-            List<Monitor> data = monitorClient.getMonitorList(monitorIdList).getData();
+            PollutionLineDTO dto;
+            for (RMpPollutionDPO lineDatum : lineData) {
+                if(monitorMap.containsKey(lineDatum.getLineId())){
+                    Monitor monitor = monitorMap.get(lineDatum.getLineId());
+                    dto=new PollutionLineDTO();
+                    dto.setId(monitor.getId());
+                    dto.setName(monitor.getName());
+                    dto.setPowerCompany(monitor.getOrgName());
+                    dto.setSubstation(monitor.getPowerrId());
+                    dto.setSubstationId(monitor.getPowerrName());
+                    dto.setBusBar(monitor.getLineName());
+                    dto.setData(lineDatum.getValue());
+                    list.add(dto);
+                }
+            }
         }
-
-
-        deviceList.forEach(temp->{
-
-            });
-
-
-        return null;
+        return list;
     }