diff --git a/app/mix/controller/moment_api.go b/app/mix/controller/moment_api.go index f914c95a..d6bf9542 100644 --- a/app/mix/controller/moment_api.go +++ b/app/mix/controller/moment_api.go @@ -14,13 +14,12 @@ import ( func ApiCreateMoment(ctx *gin.Context) { req := ctx.MustGet("client_req").(*momentproto.ApiCreateReq) - // ec, acctPunEndTime := service.DefaultService.ApiCreateMoment(ctx, req) - // if ec == errcode.ErrCodMomentBlockedFromCreatingMoment { - // logger.Error("ApiCreateMoment fail, req: %v, ec: %v", util.ToJson(req), ec) - // ReplyErrCodeMsgAndDetail(ctx, ec, acctPunEndTime) - // return - // } - ec := errcode.ErrCodeSuspend + ec, acctPunEndTime := service.DefaultService.ApiCreateMoment(ctx, req) + if ec == errcode.ErrCodMomentBlockedFromCreatingMoment { + logger.Error("ApiCreateMoment fail, req: %v, ec: %v", util.ToJson(req), ec) + ReplyErrCodeMsgAndDetail(ctx, ec, acctPunEndTime) + return + } if ec != errcode.ErrCodeMomentSrvOk { logger.Error("ApiCreateMoment fail, req: %v, ec: %v", util.ToJson(req), ec) ReplyErrCodeMsg(ctx, ec) diff --git a/app/mix/dao/mongo.go b/app/mix/dao/mongo.go index 59b126f0..9587638a 100644 --- a/app/mix/dao/mongo.go +++ b/app/mix/dao/mongo.go @@ -3268,22 +3268,13 @@ func (m *Mongo) GetMomentAuditTaskListWaitingForManuallyReview(ctx *gin.Context, list := make([]*dbstruct.MomentAuditTask, 0) col := m.getColMomentAuditTask() query := qmgo.M{ - "batch_id": batchId, - "del_flag": 0, - } - // 组装查询条件，查询状态均为机审通过，或其中有一个为机审失败的审核任务 - passedFilter := qmgo.M{ - "image_audit_task_status": consts.MomentAudit_Passed, - "text_audit_task_status": consts.MomentAudit_Passed, - } - svcFailedFilter := qmgo.M{ - "$or": []qmgo.M{ - {"image_audit_task_status": consts.MomentAudit_ServiceFailed}, - {"text_audit_task_status": consts.MomentAudit_ServiceFailed}, + "image_audit_task_status": qmgo.M{ + "$ne": consts.ImageAudit_Created, }, - } - query["$or"] = []qmgo.M{ - passedFilter, svcFailedFilter, + "text_audit_task_status": qmgo.M{ + "$ne": consts.TextAudit_Created, + }, + "del_flag": 0, } err := col.Find(ctx, query).All(&list) if err == qmgo.ErrNoSuchDocuments { diff --git a/app/mix/service/service.go b/app/mix/service/service.go index 27202055..d7b65903 100644 --- a/app/mix/service/service.go +++ b/app/mix/service/service.go @@ -1342,10 +1342,12 @@ func (s *Service) OpReviewMoment(ctx *gin.Context, req *momentproto.OpReviewReq) return } go func() { - err := redis.GetRedisClient().RPush(consts.RedisMomentPrefix+"recent_list", momentIds) - if err != nil { - logger.Error("Push newly-created moment to list failed : %v", err) - return + for _, id := range momentIds { + err := redis.GetRedisClient().RPush(consts.RedisMomentPrefix+"recent_list", id) + if err != nil { + logger.Error("Push newly-created moment to list failed : %v", err) + return + } } }() }() @@ -1383,7 +1385,8 @@ func (s *Service) OpReviewMoment(ctx *gin.Context, req *momentproto.OpReviewReq) // 更新动态审核表的状态 err = _DefaultMomentAuditTask.OpUpdateByMomentIdsAndStatus(ctx, &dbstruct.MomentAuditTask{ - Status: goproto.Int64(finalMomentAuditTaskStatus), + Status: goproto.Int64(finalMomentAuditTaskStatus), + ManuallyReviewOperator: goproto.Int64(req.BaseRequest.Mid), }, req.MomentIds, consts.MomentManuallyReview_Waiting) if err != nil { logger.Error("_DefaultMomentAuditTask OpUpdateByMomentIdsAndStatus fail, req: %v, err: %v", util.ToJson(req), err) diff --git a/app/mix/service/utilservice.go b/app/mix/service/utilservice.go index 27a08b69..5e416975 100644 --- a/app/mix/service/utilservice.go +++ b/app/mix/service/utilservice.go @@ -511,7 +511,6 @@ func (s *Service) utilSyncImageAuditTaskResultByBatchId(ctx *gin.Context, batchI AssociativeTableName: goproto.String(dao.COLMoment), AssociativeTableColumn: goproto.String("media_component"), BatchId: goproto.String(batchId), - Status: goproto.Int64(consts.MomentAudit_Created), }) if err != nil { logger.Error("_DefaultImageAuditTask OpList fail, err: %v", err) diff --git a/dbstruct/moment_audit_task.go b/dbstruct/moment_audit_task.go index 88d157d1..312b8595 100644 --- a/dbstruct/moment_audit_task.go +++ b/dbstruct/moment_audit_task.go @@ -1,21 +1,22 @@ package dbstruct type MomentAuditTask struct { - Id *string `json:"id" bson:"_id"` // 动态审核表id - AuditedMedia *MediaComponent `json:"audited_media" bson:"audited_media"` // 待审核媒体内容（图像） - FinalMedia *MediaComponent `json:"final_media" bson:"final_media"` // 终态媒体内容 - AuditedText *string `json:"audited_text" bson:"audited_text"` // 待审核文字内容 - FinalText *string `json:"final_text" bson:"final_text"` // 终态文字内容 - AssociativeTableId *string `json:"associative_table_id" bson:"associative_table_id"` // 关联表主键ID - ImageAuditTaskId *string `json:"image_audit_task_id" bson:"image_audit_task_id"` // 图像审核任务表id - TextAuditTaskId *string `json:"text_audit_task_id" bson:"text_audit_task_id"` // 文字审核任务表id - ImageAuditTaskStatus *int64 `json:"image_audit_task_status" bson:"image_audit_task_status"` // 图像审核任务审核状态 - TextAuditTaskStatus *int64 `json:"text_audit_task_status" bson:"text_audit_task_status"` // 文字审核任务审核状态 - Status *int64 `json:"status" bson:"status"` // 是否已过期 - ManuallyReviewStatus *int64 `json:"manually_review_status" bson:"manually_review_status"` // 人工复审状态 - Remarks *string `json:"remarks" bson:"remarks"` // 备注 - Ct *int64 `json:"ct" bson:"ct"` // 创建时间 - Ut *int64 `json:"ut" bson:"ut"` // 更新时间 - DelFlag *int64 `json:"del_flag" bson:"del_flag"` // 删除标记 + Id *string `json:"id" bson:"_id"` // 动态审核表id + AuditedMedia *MediaComponent `json:"audited_media" bson:"audited_media"` // 待审核媒体内容（图像） + FinalMedia *MediaComponent `json:"final_media" bson:"final_media"` // 终态媒体内容 + AuditedText *string `json:"audited_text" bson:"audited_text"` // 待审核文字内容 + FinalText *string `json:"final_text" bson:"final_text"` // 终态文字内容 + AssociativeTableId *string `json:"associative_table_id" bson:"associative_table_id"` // 关联表主键ID + ImageAuditTaskId *string `json:"image_audit_task_id" bson:"image_audit_task_id"` // 图像审核任务表id + TextAuditTaskId *string `json:"text_audit_task_id" bson:"text_audit_task_id"` // 文字审核任务表id + ImageAuditTaskStatus *int64 `json:"image_audit_task_status" bson:"image_audit_task_status"` // 图像审核任务审核状态 + TextAuditTaskStatus *int64 `json:"text_audit_task_status" bson:"text_audit_task_status"` // 文字审核任务审核状态 + Status *int64 `json:"status" bson:"status"` // 是否已过期 + ManuallyReviewStatus *int64 `json:"manually_review_status" bson:"manually_review_status"` // 人工复审状态 + ManuallyReviewOperator *int64 `json:"manually_review_operator" bson:"manually_review_operator"` // 人工复审操作人 + Remarks *string `json:"remarks" bson:"remarks"` // 备注 + Ct *int64 `json:"ct" bson:"ct"` // 创建时间 + Ut *int64 `json:"ut" bson:"ut"` // 更新时间 + DelFlag *int64 `json:"del_flag" bson:"del_flag"` // 删除标记 }