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