From 0f41a81a6b28e591bfe734ccd8327a936f9c29e0 Mon Sep 17 00:00:00 2001
From: kaiyu <404897439@qq.com>
Date: Mon, 01 Nov 2021 09:16:41 +0800
Subject: [PATCH] screen-api            增加获取一个城市24小时AQI接口

---
 screen-job/src/main/java/com/moral/api/service/impl/HistoryAqiServiceImpl.java |   14 ++++++++++++++
 1 files changed, 14 insertions(+), 0 deletions(-)

diff --git a/screen-job/src/main/java/com/moral/api/service/impl/HistoryAqiServiceImpl.java b/screen-job/src/main/java/com/moral/api/service/impl/HistoryAqiServiceImpl.java
index 312d895..5f96938 100644
--- a/screen-job/src/main/java/com/moral/api/service/impl/HistoryAqiServiceImpl.java
+++ b/screen-job/src/main/java/com/moral/api/service/impl/HistoryAqiServiceImpl.java
@@ -81,6 +81,9 @@
             String body = response.getBody();
             Map<String, Object> data = JSONObject.parseObject(body, Map.class);
             Map<String, Object> map = (Map<String, Object>) data.get("data");
+            if (ObjectUtils.isEmpty(map)) {
+                continue;
+            }
             HistoryAqi historyAqi = new HistoryAqi();
             historyAqi.setGuid(guid);
             historyAqi.setTime(time);
@@ -123,4 +126,15 @@
             redisTemplate.opsForHash().put(RedisConstants.AQI_DATA, guid, value);
         }
     }
+
+    @Override
+    public HistoryAqi getHistoryApiByTimeAndGuid(String guid, String time) {
+        QueryWrapper<HistoryAqi> wrapper_historyAqi = new QueryWrapper<>();
+        wrapper_historyAqi.eq("guid",guid).eq("time",time);
+        HistoryAqi historyAqi = new HistoryAqi();
+        if (historyAqiMapper.selectCount(wrapper_historyAqi)==1){
+            historyAqi = historyAqiMapper.selectOne(wrapper_historyAqi);
+        }
+        return historyAqi;
+    }
 }

--
Gitblit v1.8.0