From 2c42977a1a38e4f079c5c44fe51a46c27b865f80 Mon Sep 17 00:00:00 2001
From: jinpengyong <jpy123456>
Date: Fri, 23 Oct 2020 10:29:27 +0800
Subject: [PATCH] 增加天气城市配置表，优化相关接口
---
src/main/java/com/moral/task/WeatherInsertTask.java | 22 ++++++++++++++++------
1 files changed, 16 insertions(+), 6 deletions(-)
diff --git a/src/main/java/com/moral/task/ForecastWeatherInsertTask.java b/src/main/java/com/moral/task/WeatherInsertTask.java
similarity index 61%
rename from src/main/java/com/moral/task/ForecastWeatherInsertTask.java
rename to src/main/java/com/moral/task/WeatherInsertTask.java
index c29ff9b..773975f 100644
--- a/src/main/java/com/moral/task/ForecastWeatherInsertTask.java
+++ b/src/main/java/com/moral/task/WeatherInsertTask.java
@@ -8,20 +8,30 @@
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
-import com.moral.service.ForecastWeatherService;
+import com.moral.service.WeatherService;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
@Component
-public class ForecastWeatherInsertTask {
- private static transient Logger logger = LoggerFactory.getLogger(ForecastWeatherInsertTask.class);
+public class WeatherInsertTask {
+ private static transient Logger logger = LoggerFactory.getLogger(WeatherInsertTask.class);
@Resource
- private ForecastWeatherService forecastWeatherService;
+ private WeatherService weatherService;
+
+ @XxlJob("realWeatherHour")
+ public ReturnT insertRealWeather(String param) throws ParseException {
+ int count = weatherService.insertRealWeather();
+ if (count > 0) {
+ return new ReturnT(200, "������������");
+ }else {
+ return new ReturnT(500, "������������");
+ }
+ }
@XxlJob("forecastWeatherHour")
public ReturnT insertForecastWeather(String param) throws ParseException {
- int count = forecastWeatherService.insertForecastWeather();
+ int count = weatherService.insertForecastWeather();
if (count > 0) {
return new ReturnT(200, "������������");
}else {
@@ -31,7 +41,7 @@
@XxlJob("forecastWeatherHourNew")
public ReturnT insertForecastWeatherNew(String param) throws ParseException {
- int count = forecastWeatherService.insertForecastWeatherNew();
+ int count = weatherService.insertForecastWeatherNew();
if (count > 0) {
return new ReturnT(200, "������������");
}else {
--
Gitblit v1.8.0