fix: 修复流量轮询 cache 未同步 last_gateway_reading_mb 导致假增量触发停机死循环

2026-03-31 19:00:26 +08:00
parent 619f029a5a
commit 302664404b
1 changed files with 2 additions and 1 deletions
--- a/internal/task/polling_handler.go
+++ b/internal/task/polling_handler.go
@@ -266,7 +266,8 @@ func (h *PollingHandler) HandleCarddataCheck(ctx context.Context, t *asynq.Task)

 	// 更新 Redis 缓存
 	h.updateCardCache(ctx, uint(cardID), map[string]any{
-		"current_month_usage_mb": updates["current_month_usage_mb"],
+		"current_month_usage_mb":  updates["current_month_usage_mb"],
+		"last_gateway_reading_mb": gatewayFlowMB,
 	})

 	// 任务 18.3: 调用 UsageService.DeductDataUsage 进行流量扣减