diff --git a/internal/polling/scheduler.go b/internal/polling/scheduler.go index 6e07577..386043d 100644 --- a/internal/polling/scheduler.go +++ b/internal/polling/scheduler.go @@ -243,11 +243,13 @@ func (s *Scheduler) processSchedule(ctx context.Context) { s.processManualQueue(ctx, constants.TaskTypePollingRealname) s.processManualQueue(ctx, constants.TaskTypePollingCarddata) s.processManualQueue(ctx, constants.TaskTypePollingPackage) + s.processManualQueue(ctx, constants.TaskTypePollingProtect) // 2. 处理定时队列 s.processTimedQueue(ctx, constants.RedisPollingQueueRealnameKey(), constants.TaskTypePollingRealname, now) s.processTimedQueue(ctx, constants.RedisPollingQueueCarddataKey(), constants.TaskTypePollingCarddata, now) s.processTimedQueue(ctx, constants.RedisPollingQueuePackageKey(), constants.TaskTypePollingPackage, now) + s.processTimedQueue(ctx, constants.RedisPollingQueueProtectKey(), constants.TaskTypePollingProtect, now) // 任务 19.6: 套餐激活检查(每次调度都执行,内部会限流) if s.packageActivationHandler != nil {