1. 新增定时任务和定时任务日志数据库表映射； 2. 修改异常分析和日、月统计分析定时任务的执行逻辑

feiyu02

2023-10-26 b34727ebd73a4f346d53730865e83fd5b3e5a0ef

 src/main/java/com/flightfeather/monitor/scheduledtasks/TaskController.kt

@@ -14,17 +14,17 @@
/**
 * 数据获取控制器
 */
@Slf4j
@Component
class TaskController(
    dustExceptionAnalysisTask: DustExceptionAnalysisTask,
    dustDailyStatisticAnalysisTask: DustDailyStatisticAnalysisTask,
    dustMonthlyStatisticAnalysisTask: DustMonthlyStatisticAnalysisTask,
    dustAnalysisTask: DustAnalysisTask,
) {

    companion object {
        private const val FETCH_PERIOD_MIN = 1L * 60
        private const val MAINTAIN_PERIOD_MIN = 5L * 60
        private const val FETCH_PERIOD_MIN = 15L
        private const val MAINTAIN_PERIOD_MIN = 15L
        val log: Logger = LoggerFactory.getLogger(TaskController::class.java)
    }

@@ -37,10 +37,10 @@
    init {
        log.info("添加定时任务")
        timeTask.clear()
       /*做的定时任务加进来*/
        timeTask.add(dustExceptionAnalysisTask)
        timeTask.add(dustDailyStatisticAnalysisTask)
        timeTask.add(dustMonthlyStatisticAnalysisTask)
//        timeTask.add(dustExceptionAnalysisTask)
//        timeTask.add(dustDailyStatisticAnalysisTask)
//        timeTask.add(dustMonthlyStatisticAnalysisTask)
        timeTask.add(dustAnalysisTask)
        log.info("添加定时任务完成，任务总计${timeTask.size}个")
    }

@@ -51,8 +51,8 @@

    private fun fetchTask(isFirst: Boolean = false) {
        val time = LocalTime.now()
        val sec = time.second
        val delay = 60L - sec
        val min = time.minute
        val delay = FETCH_PERIOD_MIN - min % FETCH_PERIOD_MIN
//        var localtime = LocalDateTime.of(2021, 4, 16, 9, 0)
        if (!isFirst) {
            schedule = closeThread(schedule)
@@ -70,7 +70,7 @@
                it.execute(localtime)
            }
//            localtime = localtime.plusMinutes(1)
        }, delay, FETCH_PERIOD_MIN, TimeUnit.SECONDS)
        }, delay, FETCH_PERIOD_MIN, TimeUnit.MINUTES)
    }

    private fun maintainTask(isFirst: Boolean = false) {
@@ -82,7 +82,7 @@
            if (Date().time - taskTime.time > (FETCH_PERIOD_MIN + 1) * 60 * 1000) {
                fetchTask()
            }
        }, 0, MAINTAIN_PERIOD_MIN, TimeUnit.SECONDS)
        }, 0, MAINTAIN_PERIOD_MIN, TimeUnit.MINUTES)
    }

    private fun closeThread(s: ScheduledExecutorService): ScheduledExecutorService {