slhaf/Partner
1
0
Fork 0
mirror of https://github.com/slhaf/Partner.git synced 2026-05-12 08:43:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor(ActionScheduler): correct actions loading logic in hour/day updating

Browse Source
This commit is contained in:
slhafzjw
2026-02-09 20:03:10 +08:00
parent eab3d00fe8
commit 406b4250aa
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
Partner-Main/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/scheduler/ActionScheduler.kt
View File

@@ -235,12 +235,13 @@ class ActionScheduler : AgentRunningSubModule<Set<ScheduledActionData>, Void>()
suspend fun checkThenExecute(then: (currentTime: ZonedDateTime) -> Unit) = wheelActionsLock.withLock { suspend fun checkThenExecute(then: (currentTime: ZonedDateTime) -> Unit) = wheelActionsLock.withLock {
fun loadActions( fun loadActions(
source: Set<ScheduledActionData>,
now: ZonedDateTime, now: ZonedDateTime,
load: (latestExecutingTime: ZonedDateTime, actionData: ScheduledActionData) -> Unit, load: (latestExecutingTime: ZonedDateTime, actionData: ScheduledActionData) -> Unit,
repair: () -> Unit repair: () -> Unit
) { ) {
val runLoading = { val runLoading = {
for (actionData in listScheduledActions()) { for (actionData in source) {
val latestExecutingTime = val latestExecutingTime =
parseToZonedDateTime( parseToZonedDateTime(
actionData.scheduleType, actionData.scheduleType,
@@ -271,7 +272,7 @@ class ActionScheduler : AgentRunningSubModule<Set<ScheduledActionData>, Void>()
} }
} }
loadActions(currentTime, load, repair) loadActions(actionsGroupByHour[currentTime.hour], currentTime, load, repair)
} }
fun loadDayActions(currentTime: ZonedDateTime) { fun loadDayActions(currentTime: ZonedDateTime) {
@@ -285,7 +286,7 @@ class ActionScheduler : AgentRunningSubModule<Set<ScheduledActionData>, Void>()
} }
} }
loadActions(currentTime, load, repair) loadActions(listScheduledActions(), currentTime, load, repair)
} }
val currentTime = ZonedDateTime.now() val currentTime = ZonedDateTime.now()