From b34727ebd73a4f346d53730865e83fd5b3e5a0ef Mon Sep 17 00:00:00 2001
From: feiyu02 <risaku@163.com>
Date: 星期四, 26 十月 2023 16:36:37 +0800
Subject: [PATCH] 1. 新增定时任务和定时任务日志数据库表映射； 2. 修改异常分析和日、月统计分析定时任务的执行逻辑
---
src/main/java/com/flightfeather/monitor/scheduledtasks/TaskController.kt | 22 +++++++++++-----------
1 files changed, 11 insertions(+), 11 deletions(-)
diff --git a/src/main/java/com/flightfeather/monitor/scheduledtasks/TaskController.kt b/src/main/java/com/flightfeather/monitor/scheduledtasks/TaskController.kt
index 02f5d16..0970b24 100644
--- a/src/main/java/com/flightfeather/monitor/scheduledtasks/TaskController.kt
+++ b/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 {
--
Gitblit v1.9.3