From d75cd820b0bc514ada6318a001ecced4fa0bf9b5 Mon Sep 17 00:00:00 2001 From: yangjianbo Date: Sat, 10 Jan 2026 23:14:20 +0800 Subject: [PATCH] =?UTF-8?q?fix(=E8=AE=A4=E8=AF=81):=20=E8=AE=A2=E9=98=85?= =?UTF-8?q?=E5=85=91=E6=8D=A2=E5=A4=B1=E6=95=88=E8=AE=A4=E8=AF=81=E7=BC=93?= =?UTF-8?q?=E5=AD=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 订阅兑换后同步失效认证缓存避免授权快照滞后 补充单测覆盖订阅兑换的失效场景 测试: go test ./... -tags=unit --- backend/internal/service/auth_cache_invalidation_test.go | 4 +++- backend/internal/service/redeem_service.go | 3 +++ 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/backend/internal/service/auth_cache_invalidation_test.go b/backend/internal/service/auth_cache_invalidation_test.go index 3b4217c6..b6e56177 100644 --- a/backend/internal/service/auth_cache_invalidation_test.go +++ b/backend/internal/service/auth_cache_invalidation_test.go @@ -26,6 +26,8 @@ func TestRedeemService_InvalidateRedeemCaches_AuthCache(t *testing.T) { svc.invalidateRedeemCaches(context.Background(), 11, &RedeemCode{Type: RedeemTypeBalance}) svc.invalidateRedeemCaches(context.Background(), 11, &RedeemCode{Type: RedeemTypeConcurrency}) + groupID := int64(3) + svc.invalidateRedeemCaches(context.Background(), 11, &RedeemCode{Type: RedeemTypeSubscription, GroupID: &groupID}) - require.Equal(t, []int64{11, 11}, invalidator.userIDs) + require.Equal(t, []int64{11, 11, 11}, invalidator.userIDs) } diff --git a/backend/internal/service/redeem_service.go b/backend/internal/service/redeem_service.go index 81767aa9..ff52dc47 100644 --- a/backend/internal/service/redeem_service.go +++ b/backend/internal/service/redeem_service.go @@ -348,6 +348,9 @@ func (s *RedeemService) invalidateRedeemCaches(ctx context.Context, userID int64 return } case RedeemTypeSubscription: + if s.authCacheInvalidator != nil { + s.authCacheInvalidator.InvalidateAuthCacheByUserID(ctx, userID) + } if s.billingCacheService == nil { return }