feat(traffic): add debug logging for current time traffic multiplier
This commit is contained in:
@@ -79,6 +79,7 @@ func (l *TrafficStatisticsLogic) ProcessTask(ctx context.Context, task *asynq.Ta
|
|||||||
|
|
||||||
now := time.Now()
|
now := time.Now()
|
||||||
realTimeMultiplier := l.svc.NodeMultiplierManager.GetMultiplier(now)
|
realTimeMultiplier := l.svc.NodeMultiplierManager.GetMultiplier(now)
|
||||||
|
logger.Debugf("[TrafficStatisticsLogic] Current time traffic multiplier: %.2f", realTimeMultiplier)
|
||||||
for _, log := range payload.Logs {
|
for _, log := range payload.Logs {
|
||||||
// query user Subscribe Info
|
// query user Subscribe Info
|
||||||
sub, err := l.svc.UserModel.FindOneSubscribe(ctx, log.SID)
|
sub, err := l.svc.UserModel.FindOneSubscribe(ctx, log.SID)
|
||||||
|
|||||||
Reference in New Issue
Block a user