From 7ecdc67dfb92b63bdc742e5c95d62bf9774cbd7f Mon Sep 17 00:00:00 2001
From: feiyu02 <risaku@163.com>
Date: 星期一, 13 十一月 2023 16:06:24 +0800
Subject: [PATCH] 1. 新增风险值的计算逻辑；
---
src/main/java/com/flightfeather/monitor/scheduledtasks/TaskController.kt | 26 +++++++++++++-------------
1 files changed, 13 insertions(+), 13 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..e104113 100644
--- a/src/main/java/com/flightfeather/monitor/scheduledtasks/TaskController.kt
+++ b/src/main/java/com/flightfeather/monitor/scheduledtasks/TaskController.kt
@@ -1,6 +1,8 @@
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
@@ -14,17 +16,16 @@
/**
* 鏁版嵁鑾峰彇鎺у埗鍣�
*/
-@Slf4j
@Component
class TaskController(
dustExceptionAnalysisTask: DustExceptionAnalysisTask,
- dustDailyStatisticAnalysisTask: DustDailyStatisticAnalysisTask,
- dustMonthlyStatisticAnalysisTask: DustMonthlyStatisticAnalysisTask,
+ dustDailyAnalysisTask: DustDailyAnalysisTask,
+ dustMonthlyAnalysisTask: DustMonthlyAnalysisTask,
) {
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 +38,9 @@
init {
log.info("娣诲姞瀹氭椂浠诲姟")
timeTask.clear()
- /*鍋氱殑瀹氭椂浠诲姟鍔犺繘鏉�*/
timeTask.add(dustExceptionAnalysisTask)
- timeTask.add(dustDailyStatisticAnalysisTask)
- timeTask.add(dustMonthlyStatisticAnalysisTask)
+ timeTask.add(dustDailyAnalysisTask)
+ timeTask.add(dustMonthlyAnalysisTask)
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