From ec829452c10cb83844ae538ee7829949b332859b Mon Sep 17 00:00:00 2001 From: Tension Date: Sun, 28 Dec 2025 21:52:29 +0800 Subject: [PATCH] feat(traffic): add debug logging for current time traffic multiplier --- queue/logic/traffic/trafficStatisticsLogic.go | 1 + 1 file changed, 1 insertion(+) diff --git a/queue/logic/traffic/trafficStatisticsLogic.go b/queue/logic/traffic/trafficStatisticsLogic.go index ed98cd1..37614cb 100644 --- a/queue/logic/traffic/trafficStatisticsLogic.go +++ b/queue/logic/traffic/trafficStatisticsLogic.go @@ -79,6 +79,7 @@ func (l *TrafficStatisticsLogic) ProcessTask(ctx context.Context, task *asynq.Ta now := time.Now() realTimeMultiplier := l.svc.NodeMultiplierManager.GetMultiplier(now) + logger.Debugf("[TrafficStatisticsLogic] Current time traffic multiplier: %.2f", realTimeMultiplier) for _, log := range payload.Logs { // query user Subscribe Info sub, err := l.svc.UserModel.FindOneSubscribe(ctx, log.SID)