| package com.moral.api.task; | 
|   | 
| import org.springframework.beans.factory.annotation.Autowired; | 
| import org.springframework.stereotype.Component; | 
|   | 
| import com.moral.api.service.CityWeatherForecastService; | 
| 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 WeatherTask { | 
|   | 
|     @Autowired | 
|     private CityWeatherService cityWeatherService; | 
|   | 
|     @Autowired | 
|     private CityWeatherForecastService cityWeatherForecastService; | 
|   | 
|     //城市逐小时气象实测数据insert | 
|     @XxlJob("insertCityWeather") | 
|     public ReturnT insertCityWeather() { | 
|         try { | 
|             cityWeatherService.insertCityWeather(); | 
|         } catch (Exception e) { | 
|             XxlJobHelper.log(e.getMessage()); | 
|             return new ReturnT(ReturnT.FAIL_CODE, e.getMessage()); | 
|         } | 
|         return ReturnT.SUCCESS; | 
|     } | 
|   | 
|     //城市明日逐小时预测气象预测数据insert | 
|     @XxlJob("insertCityWeatherForecast") | 
|     public ReturnT insertCityWeatherForecast() { | 
|         try { | 
|             cityWeatherForecastService.insertCityWeatherForecast(); | 
|         } catch (Exception e) { | 
|             XxlJobHelper.log(e.getMessage()); | 
|             return new ReturnT(ReturnT.FAIL_CODE, e.getMessage()); | 
|         } | 
|         return ReturnT.SUCCESS; | 
|     } | 
| } |