diff --git a/pkg/cron/task.go b/pkg/cron/task.go index f99ca42..914d1f1 100644 --- a/pkg/cron/task.go +++ b/pkg/cron/task.go @@ -59,8 +59,6 @@ func RefreshWorkApprovalStatusTask() { // AutoManuallyConfirmWorkTaskWithRandomInterval 以随机间隔(3-7分钟)执行自动确认任务 func AutoManuallyConfirmWorkTaskWithRandomInterval() { - // 初始化随机数种子 - rand.Seed(time.Now().UnixNano()) for { // 执行任务 @@ -127,6 +125,7 @@ func AutoManuallyConfirmWorkTask() { var addBalanceReq bundle.AddBundleBalanceReq addBalanceReq.UserId = int32(artistId) + zap.L().Warn("开始确认作品uuid:" + req.WorkUuid) switch workCategory { case 1: { @@ -137,6 +136,7 @@ func AutoManuallyConfirmWorkTask() { ConfirmRemark: req.ConfirmRemark, ConfirmStatus: 3, }) + zap.L().Warn("图文余量不足,作品uuid:"+req.WorkUuid, zap.Error(err)) continue } addBalanceReq.ImageConsumptionNumber = 1 @@ -150,6 +150,7 @@ func AutoManuallyConfirmWorkTask() { ConfirmRemark: req.ConfirmRemark, ConfirmStatus: 3, }) + zap.L().Warn("视频余量不足,作品uuid:"+req.WorkUuid, zap.Error(err)) continue } addBalanceReq.VideoConsumptionNumber = 1 @@ -162,6 +163,7 @@ func AutoManuallyConfirmWorkTask() { zap.L().Error("扣除余额失败,作品uuid:"+req.WorkUuid, zap.Error(err)) continue } + zap.L().Warn("扣除余额成功,作品uuid:" + req.WorkUuid) _, err = service.CastProvider.UpdateStatus(context.Background(), &cast.UpdateStatusReq{ WorkAction: cast.WorkActionENUM_CONFIRM, WorkUuid: req.WorkUuid,