From f052b63c0428d4f3f723e9c729f19a62bfe3172e Mon Sep 17 00:00:00 2001 From: jinpengyong <jpy123456> Date: Thu, 20 Jan 2022 09:38:31 +0800 Subject: [PATCH] job定时任务修改入库逻辑 --- screen-job/src/main/java/com/moral/api/service/impl/ForecastServiceImpl.java | 7 ++++--- 1 files changed, 4 insertions(+), 3 deletions(-) diff --git a/screen-job/src/main/java/com/moral/api/service/impl/ForecastServiceImpl.java b/screen-job/src/main/java/com/moral/api/service/impl/ForecastServiceImpl.java index 4ffd928..2615ac9 100644 --- a/screen-job/src/main/java/com/moral/api/service/impl/ForecastServiceImpl.java +++ b/screen-job/src/main/java/com/moral/api/service/impl/ForecastServiceImpl.java @@ -57,7 +57,7 @@ private CityAqiService cityAqiService; @Autowired - private ForecastService forecastService; + private ForecastMapper forecastMapper; private static final Map<String, Integer> weatherScore = new HashMap<>(); @@ -129,6 +129,7 @@ //���������������������map Map<Date, List<Integer>> hours = DateUtils.getBeforeAndAfterHourDate(nextDay); + List<Forecast> forecastList = new ArrayList<>(); Forecast forecast = new Forecast(); Map<String, Object> forecastMap = new HashMap<>(); for (Object obj : cityCodes) { @@ -205,11 +206,11 @@ if (!Double.isNaN(o3Forecast)) { forecastMap.put("O3", AmendUtils.sciCal(o3Forecast, 0)); forecast.setValue(JSONObject.toJSONString(forecastMap)); - forecastService.save(forecast); + forecastList.add(forecast); } } - } + forecastMapper.insertForecast(forecastList); } private Double calculateAvg(List<Map<String, Object>> list, String param) { -- Gitblit v1.8.0