fiee/fonchain-fiee
10
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'feat-hjj-AutoManuallyConfirmWorkTask' into dev

Browse Source
This commit is contained in:
jiaji.H 2025-12-17 10:06:54 +08:00
commit 6817a5bdf3
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
pkg/cron/task.go
View File

@ -145,7 +145,7 @@ func AutoManuallyConfirmWorkTask() {
var addBalanceReq bundle.AddBundleBalanceReq var addBalanceReq bundle.AddBundleBalanceReq
addBalanceReq.UserId = int32(artistId) addBalanceReq.UserId = int32(artistId)
zap.L().Warn("开始确认作品uuid:" + req.WorkUuid) log.Printf("开始确认作品uuid:" + req.WorkUuid)
switch workCategory { switch workCategory {
case 1: case 1:
{ {
@ -156,7 +156,7 @@ func AutoManuallyConfirmWorkTask() {
ConfirmRemark: req.ConfirmRemark, ConfirmRemark: req.ConfirmRemark,
ConfirmStatus: 3, ConfirmStatus: 3,
}) })
zap.L().Warn("图文余量不足,作品uuid:"+req.WorkUuid, zap.Error(err)) log.Printf("图文余量不足,作品uuid:"+req.WorkUuid, zap.Error(err))
continue continue
} }
addBalanceReq.ImageConsumptionNumber = 1 addBalanceReq.ImageConsumptionNumber = 1
@ -170,7 +170,7 @@ func AutoManuallyConfirmWorkTask() {
ConfirmRemark: req.ConfirmRemark, ConfirmRemark: req.ConfirmRemark,
ConfirmStatus: 3, ConfirmStatus: 3,
}) })
zap.L().Warn("视频余量不足,作品uuid:"+req.WorkUuid, zap.Error(err)) log.Printf("视频余量不足,作品uuid:"+req.WorkUuid, zap.Error(err))
continue continue
} }
addBalanceReq.VideoConsumptionNumber = 1 addBalanceReq.VideoConsumptionNumber = 1
@ -180,10 +180,10 @@ func AutoManuallyConfirmWorkTask() {
} }
resp, err := service.BundleProvider.AddBundleBalance(context.Background(), &addBalanceReq) resp, err := service.BundleProvider.AddBundleBalance(context.Background(), &addBalanceReq)
if err != nil { if err != nil {
zap.L().Error("扣除余额失败,作品uuid:"+req.WorkUuid, zap.Error(err)) log.Printf("扣除余额失败,作品uuid:"+req.WorkUuid, zap.Error(err))
continue continue
} }
zap.L().Warn("扣除余额成功,作品uuid:" + req.WorkUuid) log.Printf("扣除余额成功,作品uuid:" + req.WorkUuid)
_, err = service.CastProvider.UpdateStatus(context.Background(), &cast.UpdateStatusReq{ _, err = service.CastProvider.UpdateStatus(context.Background(), &cast.UpdateStatusReq{
WorkAction: cast.WorkActionENUM_CONFIRM, WorkAction: cast.WorkActionENUM_CONFIRM,
WorkUuid: req.WorkUuid, WorkUuid: req.WorkUuid,
@ -192,7 +192,7 @@ func AutoManuallyConfirmWorkTask() {
ConfirmStatus: 1, ConfirmStatus: 1,
}) })
if err != nil { if err != nil {
zap.L().Error("更新作品状态失败,作品uuid:"+req.WorkUuid, zap.Error(err)) log.Printf("更新作品状态失败,作品uuid:"+req.WorkUuid, zap.Error(err))
return return
} }
} }