csxj2026/junhong_cmp_fiber
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects 1 Releases Wiki Activity

fix(poll): polling:protect 接入调度器 POLL-01

Browse Source 
- processSchedule 中新增 TaskTypePollingProtect 的 processManualQueue 和 processTimedQueue 调用
- 保护期一致性检查任务现在会被定期调度处理
This commit is contained in:
huang
2026-03-28 10:39:18 +08:00
parent 60b43bb29e
commit 922a3d0b49
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
internal/polling/scheduler.go
View File

@@ -243,11 +243,13 @@ func (s *Scheduler) processSchedule(ctx context.Context) {
s.processManualQueue(ctx, constants.TaskTypePollingRealname) s.processManualQueue(ctx, constants.TaskTypePollingRealname)
s.processManualQueue(ctx, constants.TaskTypePollingCarddata) s.processManualQueue(ctx, constants.TaskTypePollingCarddata)
s.processManualQueue(ctx, constants.TaskTypePollingPackage) s.processManualQueue(ctx, constants.TaskTypePollingPackage)
s.processManualQueue(ctx, constants.TaskTypePollingProtect)
// 2. 处理定时队列 // 2. 处理定时队列
s.processTimedQueue(ctx, constants.RedisPollingQueueRealnameKey(), constants.TaskTypePollingRealname, now) s.processTimedQueue(ctx, constants.RedisPollingQueueRealnameKey(), constants.TaskTypePollingRealname, now)
s.processTimedQueue(ctx, constants.RedisPollingQueueCarddataKey(), constants.TaskTypePollingCarddata, now) s.processTimedQueue(ctx, constants.RedisPollingQueueCarddataKey(), constants.TaskTypePollingCarddata, now)
s.processTimedQueue(ctx, constants.RedisPollingQueuePackageKey(), constants.TaskTypePollingPackage, now) s.processTimedQueue(ctx, constants.RedisPollingQueuePackageKey(), constants.TaskTypePollingPackage, now)
s.processTimedQueue(ctx, constants.RedisPollingQueueProtectKey(), constants.TaskTypePollingProtect, now)
// 任务 19.6: 套餐激活检查（每次调度都执行，内部会限流） // 任务 19.6: 套餐激活检查（每次调度都执行，内部会限流）
if s.packageActivationHandler != nil { if s.packageActivationHandler != nil {