wishpal_ironfan
/
service
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

by Robin at 20240719

This commit is contained in:
Leufolium 2024-07-19 18:11:32 +08:00
parent ea7d25b0a9
commit 8ac99776b2
3 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/mix/service/video_moderation_result_handler.go
View File

@ -119,6 +119,7 @@ func (handler *VideoModerationTaskResultHandler) generateZoneMomentMediaComponen
} }
} }
} }
task.BusinessOpinion = goproto.String(videoModerationOpinion.String())
err := _DefaultZoneMoment.OpUpdate(ctx, &zonemomentproto.OpUpdateReq{ err := _DefaultZoneMoment.OpUpdate(ctx, &zonemomentproto.OpUpdateReq{
ZoneMoment: &dbstruct.ZoneMoment{ ZoneMoment: &dbstruct.ZoneMoment{
@ -152,6 +153,7 @@ func tryToFinishVideoModerationTaskOfMoment(ctx *gin.Context, task *dbstruct.Vid
} }
// 机审完成，尝试触发moment_audit_task的人审 // 机审完成，尝试触发moment_audit_task的人审
task.BusinessOpinion = goproto.String(videoModerationOpinion.String())
isFinished, err := _DefaultMomentAuditTask.TryToFinishVideoModerationTask(ctx, task, videoModerationOpinion.String()) isFinished, err := _DefaultMomentAuditTask.TryToFinishVideoModerationTask(ctx, task, videoModerationOpinion.String())
if err != nil { if err != nil {
return err return err
@ -194,7 +196,7 @@ func getVideoUpdateInfo(task *dbstruct.VideoModerationTask, option int) (auditco
} }
auditcomp.AuditStatus = task.Status auditcomp.AuditStatus = task.Status
auditcomp.AuditOpinion = goproto.String(videoModerationOpinion.String()) auditcomp.AuditOpinion = goproto.String(videoModerationOpinion.String())
task.BusinessOpinion = goproto.String(videoModerationOpinion.String())
} }
// 人审通过后切面，执行更新 // 人审通过后切面，执行更新

1
dbstruct/video_moderation_task.go
View File

@ -21,6 +21,7 @@ type VideoModerationTask struct {
Ct *int64 `json:"ct" bson:"ct"` // 创建时间 Ct *int64 `json:"ct" bson:"ct"` // 创建时间
Ut *int64 `json:"ut" bson:"ut"` // 更新时间 Ut *int64 `json:"ut" bson:"ut"` // 更新时间
DelFlag *int64 `json:"del_flag" bson:"del_flag"` // 删除标记 DelFlag *int64 `json:"del_flag" bson:"del_flag"` // 删除标记
BusinessOpinion *string `json:"business_opinion" bson:"business_opinion"` // 业务意见
AuditedMediaResults []bool // 每个任务是否审核通过 AuditedMediaResults []bool // 每个任务是否审核通过
Description []string // 每个任务审核结果的描述 Description []string // 每个任务审核结果的描述

7
library/contentaudit/video_moderation/handler.go
View File

@ -348,9 +348,10 @@ func executeRollBack(lastValidTask *dbstruct.VideoModerationTask) (err error) {
logger.Error("Roll back taskId:%v fail:%v", lastValidTask.GetId(), err) logger.Error("Roll back taskId:%v fail:%v", lastValidTask.GetId(), err)
if err = _DefaultVideoModerationTask.OpUpdate(ctx, &video_moderation_task_proto.OpUpdateReq{ if err = _DefaultVideoModerationTask.OpUpdate(ctx, &video_moderation_task_proto.OpUpdateReq{
VideoModerationTask: &dbstruct.VideoModerationTask{ VideoModerationTask: &dbstruct.VideoModerationTask{
Id: lastValidTask.Id, Id: lastValidTask.Id,
Status: goproto.Int64(consts.VideoModeration_Failed), Status: goproto.Int64(consts.VideoModeration_Failed),
Remarks: goproto.String("任务审核失败，回退失败，请联系管理员排查"), Remarks: goproto.String("任务审核失败，回退失败，请联系管理员排查"),
BusinessOpinion: lastValidTask.BusinessOpinion,
}, },
}); err != nil { }); err != nil {
logger.Error("_DefaultVideoModeration OpUpdate fail: %v\n", err) logger.Error("_DefaultVideoModeration OpUpdate fail: %v\n", err)