| | |
| | | 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; |
| | |
| | | @Autowired |
| | | private CityWeatherService cityWeatherService; |
| | | |
| | | //城市气象实测数据insert |
| | | @Autowired |
| | | private CityWeatherForecastService cityWeatherForecastService; |
| | | |
| | | //城市逐小时气象实测数据insert |
| | | @XxlJob("insertCityWeather") |
| | | public ReturnT insertCityWeather(){ |
| | | public ReturnT insertCityWeather() { |
| | | try { |
| | | cityWeatherService.insertCityWeather(); |
| | | } catch (Exception e) { |
| | |
| | | } |
| | | 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; |
| | | } |
| | | } |