|  |  |  | 
|---|
|  |  |  | package com.moral.api.task; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.moral.api.service.AlarmInfoService; | 
|---|
|  |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
|---|
|  |  |  | import org.springframework.stereotype.Component; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private HistoryHourlyService historyHourlyService; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private AlarmInfoService alarmInfoService; | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //分钟表创建任务 | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return ReturnT.SUCCESS; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //包含最大值,最小值,平均值的小时表创建任务 | 
|---|
|  |  |  | @XxlJob("createHistoryHourlyCompleteTable") | 
|---|
|  |  |  | public ReturnT createHistoryHourlyCompleteTable(){ | 
|---|
|  |  |  | String timeUnits = DateUtils.getDateStringOfMon(1, DateUtils.yyyyMM_EN); | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | historyHourlyService.createTableComplete(timeUnits); | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | XxlJobHelper.log(e.getMessage()); | 
|---|
|  |  |  | return new ReturnT(ReturnT.FAIL_CODE, e.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return ReturnT.SUCCESS; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //小时表创建任务 | 
|---|
|  |  |  | @XxlJob("createAlarmInfoTable") | 
|---|
|  |  |  | public ReturnT createAlarmInfoTable() { | 
|---|
|  |  |  | String timeUnits = DateUtils.getDateStringOfMon(1, DateUtils.yyyyMM_EN); | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | alarmInfoService.createTable(timeUnits); | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | XxlJobHelper.log(e.getMessage()); | 
|---|
|  |  |  | return new ReturnT(ReturnT.FAIL_CODE, e.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return ReturnT.SUCCESS; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|