From 9b0e1b1e0fd546176e81faf37432d51adf55caf1 Mon Sep 17 00:00:00 2001 From: Chang lue Tsen Date: Thu, 11 Sep 2025 11:42:20 -0400 Subject: [PATCH] doc(log): rename function for clarity and add cache cleanup comment --- internal/logic/admin/log/filterTrafficLogDetailsLogic.go | 2 +- queue/logic/task/quotaLogic.go | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/internal/logic/admin/log/filterTrafficLogDetailsLogic.go b/internal/logic/admin/log/filterTrafficLogDetailsLogic.go index 5d2b488..0dea661 100644 --- a/internal/logic/admin/log/filterTrafficLogDetailsLogic.go +++ b/internal/logic/admin/log/filterTrafficLogDetailsLogic.go @@ -18,7 +18,7 @@ type FilterTrafficLogDetailsLogic struct { svcCtx *svc.ServiceContext } -// Filter traffic log details +// NewFilterTrafficLogDetailsLogic Filter traffic log details func NewFilterTrafficLogDetailsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *FilterTrafficLogDetailsLogic { return &FilterTrafficLogDetailsLogic{ Logger: logger.WithContext(ctx), diff --git a/queue/logic/task/quotaLogic.go b/queue/logic/task/quotaLogic.go index a103193..becdbeb 100644 --- a/queue/logic/task/quotaLogic.go +++ b/queue/logic/task/quotaLogic.go @@ -75,6 +75,7 @@ func (l *QuotaTaskLogic) ProcessTask(ctx context.Context, t *asynq.Task) error { if err = l.processSubscribes(ctx, subscribes, content, taskInfo); err != nil { return err } + // 清理用户缓存(仅在有赠送金时清理) if content.GiftValue != 0 { var userIds []int64 for _, sub := range subscribes {