From 03791ab057f15d102bc20b83c687f8a8028a4b8f Mon Sep 17 00:00:00 2001
From: jinpengyong <jpy123456>
Date: Tue, 28 Dec 2021 13:47:38 +0800
Subject: [PATCH] 行业贡献率update

---
 screen-api/src/main/java/com/moral/api/service/impl/ProfessionServiceImpl.java |   27 +++++++++++++++------------
 1 files changed, 15 insertions(+), 12 deletions(-)

diff --git a/screen-api/src/main/java/com/moral/api/service/impl/ProfessionServiceImpl.java b/screen-api/src/main/java/com/moral/api/service/impl/ProfessionServiceImpl.java
index 1bad56a..104c9f0 100644
--- a/screen-api/src/main/java/com/moral/api/service/impl/ProfessionServiceImpl.java
+++ b/screen-api/src/main/java/com/moral/api/service/impl/ProfessionServiceImpl.java
@@ -187,7 +187,7 @@
 
         List<String> timeLag = DateUtils.getTimeLag(time);
 
-        //������������������������
+        //���������������������������
         QueryWrapper<CityAqiMonthly> cityAqiMonthlyQueryWrapper = new QueryWrapper<>();
         cityAqiMonthlyQueryWrapper.select("time", "value")
                 .eq("city_code", locationLevelCode)
@@ -201,7 +201,7 @@
         }
 
 
-        //���������������������������������
+        //���������������������������������
         List<HistoryMonthly> allDeviceData = historyMonthlyService.getValueByMacs(allMacs, time);
         //���time������
         Map<String, List<HistoryMonthly>> allDeviceDataMap = allDeviceData.stream()
@@ -249,7 +249,7 @@
             List<String> professionMacs = professionDevices.stream().map(Device::getMac).collect(Collectors.toList());
 
 
-            //���������������������������������
+            //������������������������������������
             List<HistoryMonthly> professionDeviceData = historyMonthlyService.getValueByMacs(professionMacs, time);
             //���time������
             Map<String, List<HistoryMonthly>> professionDataMap = professionDeviceData.stream()
@@ -257,7 +257,7 @@
 
 
             for (Map<String, Object> map : result) {
-                Object allDeviceSum = map.remove("allDeviceSum");
+                Object allDeviceSum = map.get("allDeviceSum");
                 String resultTime = map.get("time").toString();
                 List<HistoryMonthly> historyMonthlyList = professionDataMap.get(resultTime);
                 //���������
@@ -280,6 +280,7 @@
                 map.put(profession, professionMap);
             }
         }
+        result.forEach(map -> map.remove("allDeviceSum"));
         return result;
     }
 
@@ -300,7 +301,7 @@
         List<String> timeLag = DateUtils.getTimeLag(time);
 
 
-        //������������������������
+        //���������������������������
         QueryWrapper<CityAqiDaily> cityAqiDailyQueryWrapper = new QueryWrapper<>();
         cityAqiDailyQueryWrapper.select("time", "value")
                 .eq("city_code", locationLevelCode)
@@ -314,7 +315,7 @@
         }
 
 
-        //������������������������
+        //���������������������������������
         List<HistoryDaily> allDeviceData = historyDailyService.getValueByMacs(allMacs, time);
         //���time������
         Map<String, List<HistoryDaily>> allDeviceDataMap = allDeviceData.stream()
@@ -361,7 +362,7 @@
             List<String> professionMacs = professionDevices.stream().map(Device::getMac).collect(Collectors.toList());
 
 
-            //���������������������������������
+            //������������������������������������
             List<HistoryDaily> professionDeviceData = historyDailyService.getValueByMacs(professionMacs, time);
             //���time������
             Map<String, List<HistoryDaily>> professionDataMap = professionDeviceData.stream()
@@ -369,7 +370,7 @@
 
 
             for (Map<String, Object> map : result) {
-                Object allDeviceSum = map.remove("allDeviceSum");
+                Object allDeviceSum = map.get("allDeviceSum");
                 String resultTime = map.get("time").toString();
                 List<HistoryDaily> historyDailyList = professionDataMap.get(resultTime);
                 //���������
@@ -392,6 +393,7 @@
                 map.put(profession, professionMap);
             }
         }
+        result.forEach(map -> map.remove("allDeviceSum"));
         return result;
     }
 
@@ -411,7 +413,7 @@
         List<String> timeLag = DateUtils.getTimeLag(time);
 
 
-        //������������������������������
+        //������������������������������
         QueryWrapper<CityAqi> cityAqiQueryWrapper = new QueryWrapper<>();
         cityAqiQueryWrapper.select("time", "value")
                 .eq("city_code", locationLevelCode)
@@ -425,7 +427,7 @@
         }
 
 
-        //������������������������������
+        //������������������������������������
         List<HistoryHourly> allDeviceData = historyHourlyService.getValueByMacs(allMacs, time);
         //���time������
         Map<String, List<HistoryHourly>> allDeviceDataMap = allDeviceData.stream()
@@ -473,7 +475,7 @@
             List<String> professionMacs = professionDevices.stream().map(Device::getMac).collect(Collectors.toList());
 
 
-            //���������������������������������
+            //���������������������������������������
             List<HistoryHourly> professionDeviceData = historyHourlyService.getValueByMacs(professionMacs, time);
             //���time������
             Map<String, List<HistoryHourly>> professionDataMap = professionDeviceData.stream()
@@ -481,7 +483,7 @@
 
 
             for (Map<String, Object> map : result) {
-                Object allDeviceSum = map.remove("allDeviceSum");
+                Object allDeviceSum = map.get("allDeviceSum");
                 String resultTime = map.get("time").toString();
                 List<HistoryHourly> historyHourlyList = professionDataMap.get(resultTime);
                 //���������
@@ -504,6 +506,7 @@
                 map.put(profession, professionMap);
             }
         }
+        result.forEach(map -> map.remove("allDeviceSum"));
         return result;
     }
 

--
Gitblit v1.8.0