| | |
| | | @Autowired |
| | | private CityAqiService cityAqiService; |
| | | |
| | | //aqi数据按国控站接入 |
| | | //国控站aqi小时数据接入 |
| | | @XxlJob("insertHistoryAqi") |
| | | public ReturnT insertHistoryAqi() { |
| | | try { |
| | |
| | | return ReturnT.SUCCESS; |
| | | } |
| | | |
| | | //aqi数据按城市接入 |
| | | //城市aqi小时数据接入 |
| | | @XxlJob("insertCityAqi") |
| | | public ReturnT insertCityAqi() { |
| | | try { |
| | |
| | | } |
| | | return ReturnT.SUCCESS; |
| | | } |
| | | |
| | | //撑城市aqi日数据统计 |
| | | @XxlJob("insertCityAqiDaily") |
| | | public ReturnT insertCityAqiDaily(){ |
| | | try { |
| | | cityAqiService.insertCityAqiDaily(); |
| | | } catch (Exception e) { |
| | | XxlJobHelper.log(e.getMessage()); |
| | | return new ReturnT(ReturnT.FAIL_CODE, e.getMessage()); |
| | | } |
| | | return ReturnT.SUCCESS; |
| | | } |
| | | } |