From fdbef2a3293e536be6b119e4e1e67cc8cc9842f0 Mon Sep 17 00:00:00 2001
From: jinpengyong <jpy123456>
Date: Fri, 08 Apr 2022 08:55:29 +0800
Subject: [PATCH] 空气质量排名报告

---
 screen-job/src/main/java/com/moral/api/service/impl/CityAqiYearlyServiceImpl.java |   22 ++++++++++++----------
 1 files changed, 12 insertions(+), 10 deletions(-)

diff --git a/screen-job/src/main/java/com/moral/api/service/impl/CityAqiYearlyServiceImpl.java b/screen-job/src/main/java/com/moral/api/service/impl/CityAqiYearlyServiceImpl.java
index 245369d..92736ee 100644
--- a/screen-job/src/main/java/com/moral/api/service/impl/CityAqiYearlyServiceImpl.java
+++ b/screen-job/src/main/java/com/moral/api/service/impl/CityAqiYearlyServiceImpl.java
@@ -77,8 +77,8 @@
         //������������������aqi���������
         QueryWrapper<CityAqiDaily> wrapper = new QueryWrapper<>();
         wrapper.select("city_code", "time", "value")
-                .ge("time", DateUtils.dateToDateString(start))
-                .lt("time", DateUtils.dateToDateString(end));
+                .ge("time", start)
+                .lt("time", end);
         List<Map<String, Object>> monthlyData = cityAqiDailyService.listMaps(wrapper);
 
         if (monthlyData.size() == 0) {
@@ -91,11 +91,14 @@
         //������������
         QueryWrapper<CityAqiYearly> queryWrapper = new QueryWrapper<>();
         queryWrapper.select("city_code", "value")
-                .eq("time", DateUtils.dateToDateString(lastLastYear));
+                .eq("time", lastLastYear);
         //������������������
-        List<CityAqiYearly> lastCityAqiYearly = cityAqiYearlyMapper.selectList(queryWrapper);
-        Map<Integer, List<CityAqiYearly>> lastYearData = lastCityAqiYearly.stream()
-                .collect(Collectors.groupingBy(CityAqiYearly::getCityCode));
+        List<CityAqiYearly> lastCityAqiYearlyList = cityAqiYearlyMapper.selectList(queryWrapper);
+        Map<Integer, CityAqiYearly> lastYearData = new HashMap<>();
+        for (CityAqiYearly cityAqiYearly : lastCityAqiYearlyList) {
+            lastYearData.put(cityAqiYearly.getCityCode(), cityAqiYearly);
+        }
+
 
         List<CityAqiYearly> cityAqiYearlyList = new ArrayList<>();
 
@@ -135,10 +138,9 @@
             jsonMap.put("compositeIndex", compositeIndex);
 
             //���������������������������
-            List<CityAqiYearly> cityAqiYearlies = lastYearData.get(Integer.parseInt(cityCode));
-            if (!ObjectUtils.isEmpty(cityAqiYearlies)) {
-                CityAqiYearly yearly = cityAqiYearlies.get(0);
-                Map<String, Object> map = JSONObject.parseObject(yearly.getValue(), Map.class);
+            CityAqiYearly lastCityAqiYearly = lastYearData.get(Integer.parseInt(cityCode));
+            if (lastCityAqiYearly != null) {
+                Map<String, Object> map = JSONObject.parseObject(lastCityAqiYearly.getValue(), Map.class);
                 double lastCompositeIndex = Double.parseDouble(map.get("compositeIndex").toString());
                 DecimalFormat decimalFormat = new DecimalFormat("0.00%");
                 String format = decimalFormat.format((compositeIndex - lastCompositeIndex) / lastCompositeIndex);

--
Gitblit v1.8.0