| | |
| | | package com.flightfeather.monitor.scheduledtasks |
| | | |
| | | import lombok.extern.slf4j.Slf4j |
| | | import com.flightfeather.monitor.scheduledtasks.dust.DustDailyAnalysisTask |
| | | import com.flightfeather.monitor.scheduledtasks.dust.DustExceptionAnalysisTask |
| | | import com.flightfeather.monitor.scheduledtasks.dust.DustMonthlyAnalysisTask |
| | | import org.slf4j.Logger |
| | | import org.slf4j.LoggerFactory |
| | | import org.springframework.stereotype.Component |
| | |
| | | @Component |
| | | class TaskController( |
| | | dustExceptionAnalysisTask: DustExceptionAnalysisTask, |
| | | dustDailyStatisticAnalysisTask: DustDailyStatisticAnalysisTask, |
| | | dustMonthlyStatisticAnalysisTask: DustMonthlyStatisticAnalysisTask, |
| | | dustAnalysisTask: DustAnalysisTask, |
| | | dustDailyAnalysisTask: DustDailyAnalysisTask, |
| | | dustMonthlyAnalysisTask: DustMonthlyAnalysisTask, |
| | | ) { |
| | | |
| | | companion object { |
| | |
| | | init { |
| | | log.info("添加定时任务") |
| | | timeTask.clear() |
| | | // timeTask.add(dustExceptionAnalysisTask) |
| | | // timeTask.add(dustDailyStatisticAnalysisTask) |
| | | // timeTask.add(dustMonthlyStatisticAnalysisTask) |
| | | timeTask.add(dustAnalysisTask) |
| | | timeTask.add(dustExceptionAnalysisTask) |
| | | timeTask.add(dustDailyAnalysisTask) |
| | | timeTask.add(dustMonthlyAnalysisTask) |
| | | log.info("添加定时任务完成,任务总计${timeTask.size}个") |
| | | } |
| | | |