| package com.moral.api.task; | 
|   | 
| import org.springframework.beans.factory.annotation.Autowired; | 
| import org.springframework.stereotype.Component; | 
|   | 
| import com.moral.api.service.HistoryDailyService; | 
| import com.moral.api.service.HistoryFiveMinutelyService; | 
| import com.moral.api.service.HistoryHourlyService; | 
| import com.moral.api.service.HistoryMonthlyService; | 
| import com.moral.api.service.HistoryWeeklyService; | 
| 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 HistoryTableInsertTask { | 
|   | 
|     @Autowired | 
|     private HistoryFiveMinutelyService historyFiveMinutelyService; | 
|   | 
|     @Autowired | 
|     private HistoryHourlyService historyHourlyService; | 
|   | 
|     @Autowired | 
|     private HistoryDailyService historyDailyService; | 
|   | 
|     @Autowired | 
|     private HistoryWeeklyService historyWeeklyService; | 
|   | 
|     @Autowired | 
|     private HistoryMonthlyService historyMonthlyService; | 
|   | 
|     //5分钟数据统计 | 
|     @XxlJob("insertHistoryFiveMinutely") | 
|     public ReturnT insertHistoryFiveMinutely() { | 
|         try { | 
|             historyFiveMinutelyService.insertHistoryFiveMinutely(); | 
|         } catch (Exception e) { | 
|             XxlJobHelper.log(e.getMessage()); | 
|             return new ReturnT(ReturnT.FAIL_CODE, e.getMessage()); | 
|         } | 
|         return ReturnT.SUCCESS; | 
|     } | 
|   | 
|     //天数据统计 | 
|     @XxlJob("insertHistoryDaily") | 
|     public ReturnT insertHistoryDaily() { | 
|         try { | 
|             historyDailyService.insertHistoryDaily(); | 
|         } catch (Exception e) { | 
|             XxlJobHelper.log(e.getMessage()); | 
|             return ReturnT.FAIL; | 
|         } | 
|         return ReturnT.SUCCESS; | 
|     } | 
|   | 
|     //周数据统计 | 
|     @XxlJob("insertHistoryWeekly") | 
|     public ReturnT insertHistoryWeekly() { | 
|         try { | 
|             historyWeeklyService.insertHistoryWeekly(); | 
|         } catch (Exception e) { | 
|             XxlJobHelper.log(e.getMessage()); | 
|             return new ReturnT(ReturnT.FAIL_CODE, e.getMessage()); | 
|         } | 
|         return ReturnT.SUCCESS; | 
|     } | 
|   | 
|     //月数据统计 | 
|     @XxlJob("insertHistoryMonthly") | 
|     public ReturnT insertHistoryMonthly() { | 
|         try { | 
|             historyMonthlyService.insertHistoryMonthly(); | 
|         } catch (Exception e) { | 
|             XxlJobHelper.log(e.getMessage()); | 
|             return new ReturnT(ReturnT.FAIL_CODE, e.getMessage()); | 
|         } | 
|         return ReturnT.SUCCESS; | 
|     } | 
|   | 
|     //缺失小时数据补充 | 
|     @XxlJob("historyHourlySupplement") | 
|     public ReturnT historyHourlySupplement() { | 
|         try { | 
|             historyHourlyService.insertHistoryHourly(); | 
|         } catch (Exception e) { | 
|             XxlJobHelper.log(e.getMessage()); | 
|             return new ReturnT(ReturnT.FAIL_CODE, e.getMessage()); | 
|         } | 
|         return ReturnT.SUCCESS; | 
|     } | 
|   | 
|     //设备小时数据,最大值,最小值,均值统计任务 | 
|     @XxlJob("insertHistoryHourlyComplete") | 
|     public ReturnT insertHistoryHourlyComplete(){ | 
|         try { | 
|             historyHourlyService.insertHistoryHourlyComplete(); | 
|         } catch (Exception e) { | 
|             e.printStackTrace(); | 
|             return new ReturnT(ReturnT.FAIL_CODE, e.getMessage()); | 
|         } | 
|         return ReturnT.SUCCESS; | 
|     } | 
| } |