| | |
|---|
| | | // 判断今日爬取任务是否完成 |
|---|
| | | val task = requestTaskRep.findLatestTask(localtime) |
|---|
| | | task1Delay = isTaskDelay(task) |
|---|
| | | if (task1Delay) return |
|---|
| | | if (!task1Delay) { |
|---|
| | | log.info("异常分析执行") |
|---|
| | | exceptionAnalysisController.init() |
|---|
| | | exceptionAnalysisController.autoRun() |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | if (task2Delay || (localtime.hour == 9 && localtime.minute == 0)) { |
|---|
| | | val task = requestTaskRep.findLatestTask(localtime) |
|---|
| | | task2Delay = isTaskDelay(task) |
|---|
| | | if (task2Delay) return |
|---|
| | | if (!task2Delay) { |
|---|
| | | log.info("日分析执行") |
|---|
| | | statisticAnalysisController.autoRunDailyStatics() |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | if (task3Delay || (localtime.dayOfMonth == 1 && localtime.hour == 9 && localtime.minute == 0)) { |
|---|
| | | val task = requestTaskRep.findLatestTask(localtime) |
|---|
| | | task3Delay = isTaskDelay(task) |
|---|
| | | if (task3Delay) return |
|---|
| | | if (!task3Delay) { |
|---|
| | | log.info("月分析执行") |
|---|
| | | statisticAnalysisController.autoRunMonthlyStatics() |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 当任务开始执行时，判断任务状态，决定是否延迟执行 |
|---|
