From 3d593b39648ff583a255765f76760768d6ba5f55 Mon Sep 17 00:00:00 2001
From: jinpengyong <jpy123456>
Date: Thu, 23 Dec 2021 14:32:14 +0800
Subject: [PATCH] 正式库city_aqi，city_weather,history_aqi第三方数据存入开发库
---
screen-job/src/main/java/com/moral/api/service/impl/HistoryAqiServiceImpl.java | 14 +++++++++++---
1 files changed, 11 insertions(+), 3 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 5f96938..062e655 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
@@ -86,7 +86,7 @@
}
HistoryAqi historyAqi = new HistoryAqi();
historyAqi.setGuid(guid);
- historyAqi.setTime(time);
+ historyAqi.setTime(DateUtils.addHours(time, -1));
//���������������
historyAqi.setValue(JSONObject.toJSONString(map));
historyAqiMapper.insert(historyAqi);
@@ -130,11 +130,19 @@
@Override
public HistoryAqi getHistoryApiByTimeAndGuid(String guid, String time) {
QueryWrapper<HistoryAqi> wrapper_historyAqi = new QueryWrapper<>();
- wrapper_historyAqi.eq("guid",guid).eq("time",time);
+ wrapper_historyAqi.eq("guid", guid).eq("time", time);
HistoryAqi historyAqi = new HistoryAqi();
- if (historyAqiMapper.selectCount(wrapper_historyAqi)==1){
+ if (historyAqiMapper.selectCount(wrapper_historyAqi) == 1) {
historyAqi = historyAqiMapper.selectOne(wrapper_historyAqi);
}
return historyAqi;
}
+
+ @Override
+ public List<HistoryAqi> getHistoryAqi() {
+ String time = DateUtils.getDateStringOfHour(-1, DateUtils.yyyy_MM_dd_HH_EN) + ":00:00";
+ QueryWrapper<HistoryAqi> queryWrapper = new QueryWrapper<>();
+ queryWrapper.eq("time", time);
+ return historyAqiMapper.selectList(queryWrapper);
+ }
}
--
Gitblit v1.8.0