|
@@ -121,6 +121,7 @@ func (t gameShieldTask) CheckSoonExpiredGameShields(ctx context.Context) error {
|
|
|
zap.Int("ID", shield.Id),
|
|
|
zap.Int("用户ID", shield.Uid),
|
|
|
zap.String("商品", shield.AppName),
|
|
|
+ zap.Int("主机ID", shield.HostId),
|
|
|
zap.Time("过期时间", time.Unix(shield.ExpireTime, 0)))
|
|
|
currentTime := time.Now().Unix()
|
|
|
// 检查用户是否已续费(检查nextduedate字段)
|
|
@@ -148,11 +149,11 @@ func (t gameShieldTask) CheckSoonExpiredGameShields(ctx context.Context) error {
|
|
|
continue
|
|
|
}
|
|
|
|
|
|
- t.logger.Info("自动续期成功: 用户ID=%d, 商品=%s, 新过期时间=%v",
|
|
|
+ t.logger.Info("自动续期成功: ",
|
|
|
zap.Int("用户ID", shield.Uid), zap.String("商品", shield.AppName), zap.Time("新过期时间", time.Unix(shield.ExpireTime, 0)))
|
|
|
} else {
|
|
|
// 用户未续费,可以发送提醒通知
|
|
|
- t.logger.Info("用户未续费: 用户ID=%d, 商品=%s", zap.Int("用户ID", shield.Uid), zap.String("商品", shield.AppName))
|
|
|
+ t.logger.Info("用户未续费:", zap.Int("用户ID", shield.Uid), zap.String("商品", shield.AppName), zap.Int("hostid", shield.HostId))
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -173,11 +174,11 @@ func (t gameShieldTask) SyncAllExpireTimeFromHost(ctx context.Context) error {
|
|
|
// 同步每条记录的过期时间
|
|
|
for _, shield := range shields {
|
|
|
if err := t.gameShieldRepo.SyncExpireTimeFromHostNextDueDate(ctx, shield.Uid, shield.HostId); err != nil {
|
|
|
- t.logger.Error("同步记录 ID=%d 的过期时间失败: %v", zap.Int("ID", shield.Id), zap.Error(err))
|
|
|
+ t.logger.Error("同步记录过期时间失败: %v", zap.Int("ID", shield.Id), zap.Error(err))
|
|
|
continue
|
|
|
}
|
|
|
|
|
|
- t.logger.Info("同步记录 ID=%d 的过期时间成功", zap.Int("ID", shield.Id))
|
|
|
+ t.logger.Info("同步记录过期时间成功", zap.Int("ID", shield.Id))
|
|
|
}
|
|
|
|
|
|
return nil
|