From 28923b3d67c58b032bc4ff128aa1d5e62d73dba1 Mon Sep 17 00:00:00 2001
From: jinpengyong <jpy123456>
Date: Fri, 02 Feb 2024 10:07:58 +0800
Subject: [PATCH] fix:提交实时在线率接口

---
 screen-api/src/main/java/com/moral/api/service/impl/MonitorPointServiceImpl.java |  171 +++++++++++++++++++++++++++++++++++++++++++++++++--------
 1 files changed, 147 insertions(+), 24 deletions(-)

diff --git a/screen-api/src/main/java/com/moral/api/service/impl/MonitorPointServiceImpl.java b/screen-api/src/main/java/com/moral/api/service/impl/MonitorPointServiceImpl.java
index da9ea5e..6583cef 100644
--- a/screen-api/src/main/java/com/moral/api/service/impl/MonitorPointServiceImpl.java
+++ b/screen-api/src/main/java/com/moral/api/service/impl/MonitorPointServiceImpl.java
@@ -3,6 +3,7 @@
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
+import com.moral.api.config.Interceptor.UserHelper;
 import com.moral.api.dto.MonitoringStationDTO;
 import com.moral.api.entity.*;
 import com.moral.api.mapper.DeviceMapper;
@@ -10,6 +11,7 @@
 import com.moral.api.mapper.MonitorPointMapper;
 import com.moral.api.mapper.SensorMapper;
 import com.moral.api.pojo.form.device.MonitorPointQueryForm;
+import com.moral.api.pojo.vo.user.QxUser;
 import com.moral.api.service.DeviceService;
 import com.moral.api.service.HistoryDailyService;
 import com.moral.api.service.HistoryHourlyService;
@@ -24,6 +26,7 @@
 import org.apache.commons.collections4.CollectionUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.util.ObjectUtils;
 import springfox.documentation.schema.Entry;
 
 import java.math.BigDecimal;
@@ -78,18 +81,19 @@
 //            region = RegionCodeUtils.regionCodeConvertToName(regionCode);
 //        }
 
-        //���������������
+       /* //���������������
         List<Organization> childrenOrganization = organizationService.getChildrenOrganizationsById(organizationId);
-        List<Integer> organizationIds = new ArrayList<>();
+
         for (Organization organization : childrenOrganization) {
             organizationIds.add(organization.getId());
         }
-        organizationIds.add(organizationId);
+        organizationIds.add(organizationId);*/
         //������������
         QueryWrapper<MonitorPoint> queryMonitorPointsWrapper = new QueryWrapper<>();
 
         //������region������������������������������������������������������������������������������
         //������region���������������������������������������������������������
+        List<Integer> organizationIds = deviceMapper.deviceOrgIdList(organizationId);
         if (region != null){
             queryMonitorPointsWrapper.eq(region, regionCode);
         }
@@ -517,14 +521,71 @@
         return resultList;
     }
 
+    /**
+     * ������������������������
+     *
+     * @return
+     */
+    @Override
+    public List<MonitorPoint> getOrganizations() {
+        QueryWrapper<MonitorPoint> wrapper = new QueryWrapper<>();
+        wrapper.select("id","name");
+        QxUser user = UserHelper.getCurrentUser();
+        Integer organizationId = user.getOrganizationId();
+        List<Integer> monitorPointiIds = monitorPointMapper.getMonitorPointiId(organizationId);
+        if (organizationId!=24){
+            wrapper.in("id",monitorPointiIds);
+        }
+        wrapper.eq("is_delete",Constants.NOT_DELETE);
+        List<MonitorPoint> monitorPoints = monitorPointMapper.selectList(wrapper);
+        for (int i = 0; i < monitorPoints.size(); i++) {
+            List<Device> organizationDevice = deviceService.getOrganizationDevice(monitorPoints.get(i).getId());
+            if (ObjectUtils.isEmpty(organizationDevice)){
+                monitorPoints.remove(i);
+                i--;
+            }
+        }
+        return monitorPoints;
+    }
+
 
     private List<MonitoringStationDTO> resultList(List<HistoryDaily> historyDailyByMacAndTimeSlot){
         List<MonitoringStationDTO> list = new ArrayList<>();
         if(CollectionUtils.isEmpty(historyDailyByMacAndTimeSlot)){
             return list;
         }
+        //������������������  ������ p5dnd7a0000001 -������ p5dnd7a0000002 -������ p5dnd7a0000003
+        List<String> hzRoad = Arrays.asList("p5dnd7a0245491","p5dnd7a0392159","p5dnd7a0243605","p5dnd7a0392176");
+        List<String> xtRoad = Arrays.asList("p5dnd7a0243603","p5dnd7a0391986","p5dnd7a0392003","p5dnd7a0392144","p5dnd7a0392167","p5dnd7a0391990");
+        List<String> xhRoad = Arrays.asList("p5dnd7a0392158","p5dnd7a0392173","p5dnd7a0391975","p5dnd7a0392153","p5dnd7a0391961","p5dnd7a0243608","p5dnd7a0243618");
+        List<HistoryDaily> hcHz= new ArrayList<>();
+        List<HistoryDaily> xtHz= new ArrayList<>();
+        List<HistoryDaily> xhHz= new ArrayList<>();
+        for(HistoryDaily h : historyDailyByMacAndTimeSlot) {
+            HistoryDaily historyDaily = new HistoryDaily();
+            historyDaily.setTime( h.getTime());
+            historyDaily.setValue(h.getValue());
+            if(hzRoad.contains(h.getMac())){
+                historyDaily.setMac("p5dnd7a0000001");
+                hcHz.add(historyDaily);
+            }else if(xtRoad.contains(h.getMac())){
+                historyDaily.setMac("p5dnd7a0000002");
+                xtHz.add(historyDaily);
+            }else if(xhRoad.contains(h.getMac())){
+                historyDaily.setMac("p5dnd7a0000003");
+                xhHz.add(historyDaily);
+            }
+        }
+        if(CollectionUtils.isNotEmpty(hcHz)){
+            historyDailyByMacAndTimeSlot.addAll(hcHz);
+        }
+        if(CollectionUtils.isNotEmpty(xtHz)){
+            historyDailyByMacAndTimeSlot.addAll(xtHz);
+        }
+        if(CollectionUtils.isNotEmpty(xhHz)){
+            historyDailyByMacAndTimeSlot.addAll(xhHz);
+        }
         Map<String,Map<String,ArrayList<Double>>> resultMap = new HashMap<>();
-        int zz = 0;
         for(HistoryDaily h : historyDailyByMacAndTimeSlot) {
             JSONObject jsonObject = JSONObject.parseObject(h.getValue());
             Map<String, Object> map = jsonObject.getInnerMap();
@@ -555,8 +616,6 @@
                 maps.put("NO2",numResult);
             }
             if(Objects.nonNull(map.get("a21005"))){
-                System.out.println(">>>"+map.toString());
-                System.out.println(">>>"+map.get("a21005").toString());
                 ArrayList<Double> numResult = Objects.nonNull(maps.get("CO"))?maps.get("CO"):new ArrayList<>();
                 numResult.add(Double.parseDouble(map.get("a21005").toString()));
                 maps.put("CO",numResult);
@@ -567,9 +626,9 @@
                 maps.put("TVOC",numResult);
             }
             resultMap.put(h.getMac(),maps);
-            zz++;
         }
         for(Map.Entry entry : resultMap.entrySet()){
+            boolean dimension = false;
             String mapKey = (String) entry.getKey();
             Map<String,ArrayList<Double>> mapValue = (Map<String,ArrayList<Double>>)entry.getValue();
             Map<String, Object> data = new HashMap<>();
@@ -579,27 +638,31 @@
                 data.put("PM2_5",rsAvg);
             }else {
                 data.put("PM2_5",0);
+                dimension = true;
             }
             if(mapValue.containsKey("PM10")){
                 Double ListAvg = mapValue.get("PM10").stream().collect(Collectors.averagingDouble(Double::doubleValue));
-                double rsAvg = new BigDecimal(ListAvg).setScale(3, BigDecimal.ROUND_HALF_UP).doubleValue();
+                double rsAvg = new BigDecimal(ListAvg).setScale(0, BigDecimal.ROUND_HALF_UP).doubleValue();
                 data.put("PM10",rsAvg);
             }else {
                 data.put("PM10",0);
+                dimension = true;
             }
             if(mapValue.containsKey("SO2")){
                 Double ListAvg = mapValue.get("SO2").stream().collect(Collectors.averagingDouble(Double::doubleValue));
-                double rsAvg = new BigDecimal(ListAvg).setScale(3, BigDecimal.ROUND_HALF_UP).doubleValue();
+                double rsAvg = new BigDecimal(ListAvg).setScale(0, BigDecimal.ROUND_HALF_UP).doubleValue();
                 data.put("SO2",rsAvg);
             }else {
                 data.put("SO2",0);
+                dimension = true;
             }
             if(mapValue.containsKey("NO2")){
                 Double ListAvg = mapValue.get("NO2").stream().collect(Collectors.averagingDouble(Double::doubleValue));
-                double rsAvg = new BigDecimal(ListAvg).setScale(3, BigDecimal.ROUND_HALF_UP).doubleValue();
+                double rsAvg = new BigDecimal(ListAvg).setScale(0, BigDecimal.ROUND_HALF_UP).doubleValue();
                 data.put("NO2",rsAvg);
             }else {
                 data.put("NO2",0);
+                dimension = true;
             }
             if(mapValue.containsKey("CO")){
                 Double ListAvg = percentile(mapValue.get("CO"),95d);
@@ -607,6 +670,7 @@
                 data.put("CO",rsAvg);
             }else {
                 data.put("CO",0);
+                dimension = true;
             }
             if(mapValue.containsKey("O3")){
                 Double ListAvg = percentile(mapValue.get("O3"),90d);
@@ -614,6 +678,7 @@
                 data.put("O3",rsAvg);
             }else {
                 data.put("O3",0);
+                dimension = true;
             }
             if(mapValue.containsKey("TVOC")){
                 Double ListAvg = mapValue.get("TVOC").stream().collect(Collectors.averagingDouble(Double::doubleValue));
@@ -621,43 +686,71 @@
                 data.put("TVOC",rsAvg);
             }else {
                 data.put("TVOC",0);
+                dimension = true;
             }
             Double resultNum = ComprehensiveIndexUtils.dailyData(data);
+            if(dimension){
+                resultNum = 0d;
+            }
             MonitoringStationDTO monitoringStationDTO = new MonitoringStationDTO();
             monitoringStationDTO.setPM25(BigDecimal.valueOf(Double.parseDouble(data.get("PM2_5").toString())));
             monitoringStationDTO.setO3(BigDecimal.valueOf(Double.parseDouble(data.get("O3").toString())));
             monitoringStationDTO.setTovc(BigDecimal.valueOf(Double.parseDouble(data.get("TVOC").toString())));
             monitoringStationDTO.setComposite(BigDecimal.valueOf(resultNum));
+            monitoringStationDTO.setSO2(BigDecimal.valueOf(Double.parseDouble(data.get("SO2").toString())));
+            monitoringStationDTO.setNO2(BigDecimal.valueOf(Double.parseDouble(data.get("NO2").toString())));
+            monitoringStationDTO.setPM10(BigDecimal.valueOf(Double.parseDouble(data.get("PM10").toString())));
+            monitoringStationDTO.setCO(BigDecimal.valueOf(Double.parseDouble(data.get("CO").toString())));
             monitoringStationDTO.setMac(mapKey);
             list.add(monitoringStationDTO);
         }
+        List<MonitoringStationDTO> compositeListResult = fun3(list,0);
         List<MonitoringStationDTO> compositeList = fun3(list,1);
         List<MonitoringStationDTO> pM25List = fun3(list,2);
         List<MonitoringStationDTO> o3List = fun3(list,3);
         List<MonitoringStationDTO> tovcList = fun3(list,4);
+        List<MonitoringStationDTO> SO2List = fun3(list,5);
+        List<MonitoringStationDTO> NO2cList = fun3(list,6);
+        List<MonitoringStationDTO> PM10List = fun3(list,7);
+        List<MonitoringStationDTO> COList = fun3(list,8);
         List<MonitoringStationDTO> resultList = new ArrayList<>();
         LambdaQueryChainWrapper<Device> wrapper = deviceService.lambdaQuery();
         wrapper.eq(Device::getIsDelete,0);
         Map<String,String> deviceMap =  new HashMap<>();
         wrapper.list().forEach(it->deviceMap.put(it.getMac(),it.getName()));
-        int num = 1;
-        for (MonitoringStationDTO m :compositeList ){
+        deviceMap.put("p5dnd7a0000001","������������������");
+        deviceMap.put("p5dnd7a0000002","������������������");
+        deviceMap.put("p5dnd7a0000003","������������������");
+        for (MonitoringStationDTO m :compositeListResult ){
             MonitoringStationDTO monit = new MonitoringStationDTO();
             String mac = m.getMac();
             monit.setMac(mac);
             monit.setName(deviceMap.get(mac));
-            monit.setComposite(m.getComposite());
-            monit.setCompositeNum(m.getCompositeNum());
+            List<String> listComposite = compositeList.stream().map(MonitoringStationDTO::getMac).collect(Collectors.toList());
+            monit.setComposite(listComposite.indexOf(mac) == -1?BigDecimal.ZERO:compositeList.get(listComposite.indexOf(mac)).getComposite());
+            monit.setCompositeNum(listComposite.indexOf(mac) == -1?0:compositeList.get(listComposite.indexOf(mac)).getCompositeNum());
             List<String> listPM25 = pM25List.stream().map(MonitoringStationDTO::getMac).collect(Collectors.toList());
             List<String> listO3 = o3List.stream().map(MonitoringStationDTO::getMac).collect(Collectors.toList());
             List<String> listTovc = tovcList.stream().map(MonitoringStationDTO::getMac).collect(Collectors.toList());
-            monit.setO3(o3List.get(listO3.indexOf(mac)).getO3());
-            monit.setO3Num(o3List.get(listO3.indexOf(mac)).getO3Num());
-            monit.setPM25(pM25List.get(listPM25.indexOf(mac)).getPM25());
-            monit.setPM25Num(pM25List.get(listPM25.indexOf(mac)).getPM25Num());
-            monit.setTovc(tovcList.get(listTovc.indexOf(mac)).getTovc());
-            monit.setTOVCNum(tovcList.get(listTovc.indexOf(mac)).getTOVCNum());
-            //num++;
+            monit.setO3(listO3.indexOf(mac) == -1?BigDecimal.ZERO:o3List.get(listO3.indexOf(mac)).getO3());
+            monit.setO3Num(listO3.indexOf(mac) == -1?0:o3List.get(listO3.indexOf(mac)).getO3Num());
+            monit.setPM25(listPM25.indexOf(mac) == -1?BigDecimal.ZERO:pM25List.get(listPM25.indexOf(mac)).getPM25());
+            monit.setPM25Num(listPM25.indexOf(mac) == -1?0:pM25List.get(listPM25.indexOf(mac)).getPM25Num());
+            monit.setTovc(listTovc.indexOf(mac) == -1?BigDecimal.ZERO:tovcList.get(listTovc.indexOf(mac)).getTovc());
+            monit.setTOVCNum(listTovc.indexOf(mac) == -1?0:tovcList.get(listTovc.indexOf(mac)).getTOVCNum());
+            List<String> listSO2 = SO2List.stream().map(MonitoringStationDTO::getMac).collect(Collectors.toList());
+            monit.setSO2(listSO2.indexOf(mac) == -1?BigDecimal.ZERO:SO2List.get(listSO2.indexOf(mac)).getSO2());
+            monit.setSO2Num(listSO2.indexOf(mac) == -1?0:SO2List.get(listSO2.indexOf(mac)).getSO2Num());
+            List<String> listNO2 = NO2cList.stream().map(MonitoringStationDTO::getMac).collect(Collectors.toList());
+            monit.setNO2(listNO2.indexOf(mac) == -1?BigDecimal.ZERO:NO2cList.get(listNO2.indexOf(mac)).getNO2());
+            monit.setNO2Num(listNO2.indexOf(mac) == -1?0:NO2cList.get(listNO2.indexOf(mac)).getNO2Num());
+            List<String> listPM10 = PM10List.stream().map(MonitoringStationDTO::getMac).collect(Collectors.toList());
+            monit.setPM10(listPM10.indexOf(mac) == -1?BigDecimal.ZERO:PM10List.get(listPM10.indexOf(mac)).getPM10());
+            monit.setPM10Num(listPM10.indexOf(mac) == -1?0:PM10List.get(listPM10.indexOf(mac)).getPM10Num());
+            List<String> listCO = COList.stream().map(MonitoringStationDTO::getMac).collect(Collectors.toList());
+            monit.setCO(listCO.indexOf(mac) == -1?BigDecimal.ZERO:COList.get(listCO.indexOf(mac)).getCO());
+            monit.setCONum(listCO.indexOf(mac) == -1?0:COList.get(listCO.indexOf(mac)).getCONum());
+
             resultList.add(monit);
         }
         return resultList;
@@ -668,17 +761,32 @@
         List<MonitoringStationDTO> compositeList = new ArrayList<>();
         Map<BigDecimal,List<MonitoringStationDTO>> map1 = new HashMap<>();
         if(type == 1){
+            compositeList = monList.stream().filter(it->it.getComposite().compareTo(BigDecimal.ZERO)!=0).sorted(Comparator.comparing(MonitoringStationDTO::getComposite)).collect(Collectors.toList());
+            map1 = compositeList.stream().collect(Collectors.groupingBy(MonitoringStationDTO::getComposite,LinkedHashMap::new,Collectors.toList()));
+        }else if(type == 0){
             compositeList = monList.stream().sorted(Comparator.comparing(MonitoringStationDTO::getComposite)).collect(Collectors.toList());
             map1 = compositeList.stream().collect(Collectors.groupingBy(MonitoringStationDTO::getComposite,LinkedHashMap::new,Collectors.toList()));
         }else if(type == 2){
-            compositeList = monList.stream().sorted(Comparator.comparing(MonitoringStationDTO::getPM25)).collect(Collectors.toList());
+            compositeList = monList.stream().filter(it->it.getPM25().compareTo(BigDecimal.ZERO)!=0).sorted(Comparator.comparing(MonitoringStationDTO::getPM25)).collect(Collectors.toList());
             map1 = compositeList.stream().collect(Collectors.groupingBy(MonitoringStationDTO::getPM25,LinkedHashMap::new,Collectors.toList()));
         }else if(type == 3){
-            compositeList = monList.stream().sorted(Comparator.comparing(MonitoringStationDTO::getO3)).collect(Collectors.toList());
+            compositeList = monList.stream().filter(it->it.getO3().compareTo(BigDecimal.ZERO)!=0).sorted(Comparator.comparing(MonitoringStationDTO::getO3)).collect(Collectors.toList());
             map1 = compositeList.stream().collect(Collectors.groupingBy(MonitoringStationDTO::getO3,LinkedHashMap::new,Collectors.toList()));
         }else if(type == 4){
-            compositeList = monList.stream().sorted(Comparator.comparing(MonitoringStationDTO::getTovc)).collect(Collectors.toList());
+            compositeList = monList.stream().filter(it->it.getTovc().compareTo(BigDecimal.ZERO)!=0).sorted(Comparator.comparing(MonitoringStationDTO::getTovc)).collect(Collectors.toList());
             map1 = compositeList.stream().collect(Collectors.groupingBy(MonitoringStationDTO::getTovc,LinkedHashMap::new,Collectors.toList()));
+        }else if(type == 5){
+            compositeList = monList.stream().filter(it->it.getSO2().compareTo(BigDecimal.ZERO)!=0).sorted(Comparator.comparing(MonitoringStationDTO::getSO2)).collect(Collectors.toList());
+            map1 = compositeList.stream().collect(Collectors.groupingBy(MonitoringStationDTO::getSO2,LinkedHashMap::new,Collectors.toList()));
+        }else if(type == 6){
+            compositeList = monList.stream().filter(it->it.getNO2().compareTo(BigDecimal.ZERO)!=0).sorted(Comparator.comparing(MonitoringStationDTO::getNO2)).collect(Collectors.toList());
+            map1 = compositeList.stream().collect(Collectors.groupingBy(MonitoringStationDTO::getNO2,LinkedHashMap::new,Collectors.toList()));
+        }else if(type == 7){
+            compositeList = monList.stream().filter(it->it.getPM10().compareTo(BigDecimal.ZERO)!=0).sorted(Comparator.comparing(MonitoringStationDTO::getPM10)).collect(Collectors.toList());
+            map1 = compositeList.stream().collect(Collectors.groupingBy(MonitoringStationDTO::getPM10,LinkedHashMap::new,Collectors.toList()));
+        }else if(type == 8){
+            compositeList = monList.stream().filter(it->it.getCO().compareTo(BigDecimal.ZERO)!=0).sorted(Comparator.comparing(MonitoringStationDTO::getCO)).collect(Collectors.toList());
+            map1 = compositeList.stream().collect(Collectors.groupingBy(MonitoringStationDTO::getCO,LinkedHashMap::new,Collectors.toList()));
         }
         int index = 1;
         for (Map.Entry entry : map1.entrySet()) {
@@ -687,6 +795,9 @@
                 MonitoringStationDTO stationDTO = new MonitoringStationDTO();
                 stationDTO.setMac(m.getMac());
                 if(type == 1){
+                    stationDTO.setComposite(m.getComposite());
+                    stationDTO.setCompositeNum(index);
+                }else if(type == 0){
                     stationDTO.setComposite(m.getComposite());
                     stationDTO.setCompositeNum(index);
                 }else if(type == 2){
@@ -698,6 +809,18 @@
                 }else if(type == 4){
                     stationDTO.setTovc(m.getTovc());
                     stationDTO.setTOVCNum(index);
+                }else if(type == 5){
+                    stationDTO.setSO2(m.getSO2());
+                    stationDTO.setSO2Num(index);
+                }else if(type == 6){
+                    stationDTO.setNO2(m.getNO2());
+                    stationDTO.setNO2Num(index);
+                }else if(type == 7){
+                    stationDTO.setPM10(m.getPM10());
+                    stationDTO.setPM10Num(index);
+                }else if(type == 8){
+                    stationDTO.setCO(m.getCO());
+                    stationDTO.setCONum(index);
                 }
                 resultList.add(stationDTO);
             }

--
Gitblit v1.8.0