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

fix(action): fix unexpected scheduled action losing

Browse Source
This commit is contained in:
slhafzjw
2026-04-21 17:12:44 +08:00
parent de340029c6
commit 3d56966381
1 changed files with 26 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
Partner-Core/src/main/java/work/slhaf/partner/module/action/scheduler/ActionScheduler.kt
View File

@@ -201,8 +201,13 @@ class ActionScheduler : AbstractAgentModule.Standalone() {
val shouldBreak: Boolean
)
fun collectToTrigger(tick: Int, previousTick: Int, triggerHour: Int): Set<Schedulable>? {
if (tick > previousTick) {
fun collectToTrigger(
tick: Int,
previousTick: Int,
triggerHour: Int,
includeRemainingHour: Boolean = false
): Set<Schedulable>? {
if (tick >= previousTick) {
val toTrigger = mutableSetOf<Schedulable>()
for (i in previousTick..tick) {
val bucket = wheel[i]
@@ -213,6 +218,13 @@ class ActionScheduler : AbstractAgentModule.Standalone() {
bucket.clear() // 避免重复触发
}
}
if (includeRemainingHour) {
val remainingHourBucket = schedulableGroupByHour[triggerHour]
if (remainingHourBucket.isNotEmpty()) {
toTrigger.addAll(remainingHourBucket.filter { it.enabled })
remainingHourBucket.clear()
}
}
return toTrigger
}
return null
@@ -261,7 +273,12 @@ class ActionScheduler : AbstractAgentModule.Standalone() {
checkThenExecute(false) {
if (it.hour != launchingHour) {
shouldBreak = true
toTrigger = collectToTrigger(wheel.lastIndex, previousTick, launchingHour)
toTrigger = collectToTrigger(
wheel.lastIndex,
previousTick,
launchingHour,
includeRemainingHour = true
)
log.debug(
"Hour changed, previousTick: {}, tick: {}, toTriggerSize: {}",
previousTick,
@@ -270,7 +287,12 @@ class ActionScheduler : AbstractAgentModule.Standalone() {
)
return@checkThenExecute
}
toTrigger = collectToTrigger(tick, previousTick, launchingHour)
toTrigger = collectToTrigger(
tick,
previousTick,
launchingHour,
includeRemainingHour = tick >= wheel.lastIndex
)
if (tick >= wheel.lastIndex || schedulableGroupByHour[launchingHour].isEmpty()) {
state.value = WheelState.SLEEPING
shouldBreak = true