From 81d31a0f9449943dcd78c1d0358443366a998201 Mon Sep 17 00:00:00 2001 From: jinpengyong <jpy123456> Date: Mon, 11 Oct 2021 17:30:10 +0800 Subject: [PATCH] 接入城市气象数据定时任务 --- screen-job/src/main/java/com/moral/api/task/WeatherTask.java | 15 ++++++++------- 1 files changed, 8 insertions(+), 7 deletions(-) diff --git a/screen-job/src/main/java/com/moral/api/task/HistoryAqiInsertTask.java b/screen-job/src/main/java/com/moral/api/task/WeatherTask.java similarity index 60% rename from screen-job/src/main/java/com/moral/api/task/HistoryAqiInsertTask.java rename to screen-job/src/main/java/com/moral/api/task/WeatherTask.java index b4b1bff..0dc6cf4 100644 --- a/screen-job/src/main/java/com/moral/api/task/HistoryAqiInsertTask.java +++ b/screen-job/src/main/java/com/moral/api/task/WeatherTask.java @@ -3,22 +3,23 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; -import com.moral.api.service.HistoryAqiService; +import com.moral.api.service.CityConfigService; +import com.moral.api.service.CityWeatherService; import com.xxl.job.core.biz.model.ReturnT; import com.xxl.job.core.context.XxlJobHelper; import com.xxl.job.core.handler.annotation.XxlJob; @Component -public class HistoryAqiInsertTask { +public class WeatherTask { @Autowired - private HistoryAqiService historyAqiService; + private CityWeatherService cityWeatherService; - //������������aqi������������ - @XxlJob("insertHistoryAqi") - public ReturnT insertHistoryAqi() { + //������������������������insert + @XxlJob("insertCityWeather") + public ReturnT insertCityWeather(){ try { - historyAqiService.insertHistoryAqi(); + cityWeatherService.insertCityWeather(); } catch (Exception e) { XxlJobHelper.log(e.getMessage()); return new ReturnT(ReturnT.FAIL_CODE, e.getMessage()); -- Gitblit v1.8.0