break
a0de08d789
All checks were successful
构建并部署到测试环境（无 SSH） / build-and-deploy (push) Successful in 8m6s
线上保持现有纯 Asynq 架构，以公平孤儿扫描和提交后投递消除永久饥饿及事务可见性竞态。 Constraint: 线上保持现有纯 Asynq 架构，不引入 Outbox、迁移或新任务基础设施。 Rejected: 事务内投递或扩大扫描 LIMIT | 无法消除竞态和永久饥饿。 Confidence: high Scope-risk: narrow Directive: 后续分支整合时按目标分支的套餐接续架构独立处理，不混用本热修实现。 Tested: go build ./...（退出码 0）；git diff --check；openspec validate fix-main-package-activation-starvation --strict。 Not-tested: 按用户要求未新增、修改或运行自动化测试；线上 SQL、查询计划和日志待部署后核验。
1.9 KiB
1.9 KiB
Main 分支套餐接续饥饿热修
修复边界
本热修仅适用于 main 的纯 Asynq 套餐接续链路，不引入 Outbox、数据库迁移、新任务类型或新依赖。
- 孤儿扫描先在 PostgreSQL 中按卡或设备选择队首套餐，并排除仍有
status IN (1,2)占位主套餐的载体，最后取 100 个真实孤儿。 - 旧主套餐及加油包状态事务提交后，再投递现有
package:queue:activation任务。 - Redis 激活锁冲突返回套餐激活冲突错误，由现有
MaxRetry(3)重试。 - 只有套餐实际从待生效推进为生效中时，Handler 才记录“套餐激活成功”。
部署观察
部署 Worker 后至少观察两个套餐轮询周期：
孤儿套餐扫描完成的orphan_count应能覆盖真实无占位套餐，不再固定被同一批占位载体挡住。已提交套餐激活任务后应出现实际激活、明确跳过或可重试错误，不再出现未改状态却打印成功。- Redis 锁冲突应进入 Asynq 重试，不应确认任务成功。
可使用以下只读 SQL 检查仍未恢复的真实孤儿数量：
SELECT COUNT(*) AS orphan_pending_count
FROM tb_package_usage AS pending
WHERE pending.status = 0
AND pending.master_usage_id IS NULL
AND pending.deleted_at IS NULL
AND (COALESCE(pending.iot_card_id, 0) > 0 OR COALESCE(pending.device_id, 0) > 0)
AND NOT EXISTS (
SELECT 1
FROM tb_package_usage AS occupied
WHERE occupied.status IN (1, 2)
AND occupied.master_usage_id IS NULL
AND occupied.deleted_at IS NULL
AND (
(COALESCE(pending.iot_card_id, 0) > 0 AND occupied.iot_card_id = pending.iot_card_id)
OR (COALESCE(pending.iot_card_id, 0) = 0 AND pending.device_id > 0 AND occupied.device_id = pending.device_id)
)
);
回滚
本次无数据库迁移。回滚热修提交并重新部署 Worker 即可；已经正确激活的套餐属于有效业务事实，不执行反向 SQL。