From 922a3d0b4948c650037afc0d9fe9213f377b0621 Mon Sep 17 00:00:00 2001 From: huang Date: Sat, 28 Mar 2026 10:39:18 +0800 Subject: [PATCH] =?UTF-8?q?fix(poll):=20polling:protect=20=E6=8E=A5?= =?UTF-8?q?=E5=85=A5=E8=B0=83=E5=BA=A6=E5=99=A8=20POLL-01?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - processSchedule 中新增 TaskTypePollingProtect 的 processManualQueue 和 processTimedQueue 调用 - 保护期一致性检查任务现在会被定期调度处理 --- internal/polling/scheduler.go | 2 ++ 1 file changed, 2 insertions(+) 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 {