by Robin at 20240329
This commit is contained in:
parent
12549d2de5
commit
f08bd346c9
|
|
@ -14,13 +14,12 @@ import (
|
||||||
|
|
||||||
func ApiCreateMoment(ctx *gin.Context) {
|
func ApiCreateMoment(ctx *gin.Context) {
|
||||||
req := ctx.MustGet("client_req").(*momentproto.ApiCreateReq)
|
req := ctx.MustGet("client_req").(*momentproto.ApiCreateReq)
|
||||||
// ec, acctPunEndTime := service.DefaultService.ApiCreateMoment(ctx, req)
|
ec, acctPunEndTime := service.DefaultService.ApiCreateMoment(ctx, req)
|
||||||
// if ec == errcode.ErrCodMomentBlockedFromCreatingMoment {
|
if ec == errcode.ErrCodMomentBlockedFromCreatingMoment {
|
||||||
// logger.Error("ApiCreateMoment fail, req: %v, ec: %v", util.ToJson(req), ec)
|
logger.Error("ApiCreateMoment fail, req: %v, ec: %v", util.ToJson(req), ec)
|
||||||
// ReplyErrCodeMsgAndDetail(ctx, ec, acctPunEndTime)
|
ReplyErrCodeMsgAndDetail(ctx, ec, acctPunEndTime)
|
||||||
// return
|
return
|
||||||
// }
|
}
|
||||||
ec := errcode.ErrCodeSuspend
|
|
||||||
if ec != errcode.ErrCodeMomentSrvOk {
|
if ec != errcode.ErrCodeMomentSrvOk {
|
||||||
logger.Error("ApiCreateMoment fail, req: %v, ec: %v", util.ToJson(req), ec)
|
logger.Error("ApiCreateMoment fail, req: %v, ec: %v", util.ToJson(req), ec)
|
||||||
ReplyErrCodeMsg(ctx, ec)
|
ReplyErrCodeMsg(ctx, ec)
|
||||||
|
|
|
||||||
|
|
@ -3268,22 +3268,13 @@ func (m *Mongo) GetMomentAuditTaskListWaitingForManuallyReview(ctx *gin.Context,
|
||||||
list := make([]*dbstruct.MomentAuditTask, 0)
|
list := make([]*dbstruct.MomentAuditTask, 0)
|
||||||
col := m.getColMomentAuditTask()
|
col := m.getColMomentAuditTask()
|
||||||
query := qmgo.M{
|
query := qmgo.M{
|
||||||
"batch_id": batchId,
|
"image_audit_task_status": qmgo.M{
|
||||||
"del_flag": 0,
|
"$ne": consts.ImageAudit_Created,
|
||||||
}
|
|
||||||
// 组装查询条件，查询状态均为机审通过，或其中有一个为机审失败的审核任务
|
|
||||||
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},
|
|
||||||
},
|
},
|
||||||
}
|
"text_audit_task_status": qmgo.M{
|
||||||
query["$or"] = []qmgo.M{
|
"$ne": consts.TextAudit_Created,
|
||||||
passedFilter, svcFailedFilter,
|
},
|
||||||
|
"del_flag": 0,
|
||||||
}
|
}
|
||||||
err := col.Find(ctx, query).All(&list)
|
err := col.Find(ctx, query).All(&list)
|
||||||
if err == qmgo.ErrNoSuchDocuments {
|
if err == qmgo.ErrNoSuchDocuments {
|
||||||
|
|
|
||||||
|
|
@ -1342,10 +1342,12 @@ func (s *Service) OpReviewMoment(ctx *gin.Context, req *momentproto.OpReviewReq)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
go func() {
|
go func() {
|
||||||
err := redis.GetRedisClient().RPush(consts.RedisMomentPrefix+"recent_list", momentIds)
|
for _, id := range momentIds {
|
||||||
if err != nil {
|
err := redis.GetRedisClient().RPush(consts.RedisMomentPrefix+"recent_list", id)
|
||||||
logger.Error("Push newly-created moment to list failed : %v", err)
|
if err != nil {
|
||||||
return
|
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{
|
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)
|
}, req.MomentIds, consts.MomentManuallyReview_Waiting)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
logger.Error("_DefaultMomentAuditTask OpUpdateByMomentIdsAndStatus fail, req: %v, err: %v", util.ToJson(req), err)
|
logger.Error("_DefaultMomentAuditTask OpUpdateByMomentIdsAndStatus fail, req: %v, err: %v", util.ToJson(req), err)
|
||||||
|
|
|
||||||
|
|
@ -511,7 +511,6 @@ func (s *Service) utilSyncImageAuditTaskResultByBatchId(ctx *gin.Context, batchI
|
||||||
AssociativeTableName: goproto.String(dao.COLMoment),
|
AssociativeTableName: goproto.String(dao.COLMoment),
|
||||||
AssociativeTableColumn: goproto.String("media_component"),
|
AssociativeTableColumn: goproto.String("media_component"),
|
||||||
BatchId: goproto.String(batchId),
|
BatchId: goproto.String(batchId),
|
||||||
Status: goproto.Int64(consts.MomentAudit_Created),
|
|
||||||
})
|
})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
logger.Error("_DefaultImageAuditTask OpList fail, err: %v", err)
|
logger.Error("_DefaultImageAuditTask OpList fail, err: %v", err)
|
||||||
|
|
|
||||||
|
|
@ -1,21 +1,22 @@
|
||||||
package dbstruct
|
package dbstruct
|
||||||
|
|
||||||
type MomentAuditTask struct {
|
type MomentAuditTask struct {
|
||||||
Id *string `json:"id" bson:"_id"` // 动态审核表id
|
Id *string `json:"id" bson:"_id"` // 动态审核表id
|
||||||
AuditedMedia *MediaComponent `json:"audited_media" bson:"audited_media"` // 待审核媒体内容（图像）
|
AuditedMedia *MediaComponent `json:"audited_media" bson:"audited_media"` // 待审核媒体内容（图像）
|
||||||
FinalMedia *MediaComponent `json:"final_media" bson:"final_media"` // 终态媒体内容
|
FinalMedia *MediaComponent `json:"final_media" bson:"final_media"` // 终态媒体内容
|
||||||
AuditedText *string `json:"audited_text" bson:"audited_text"` // 待审核文字内容
|
AuditedText *string `json:"audited_text" bson:"audited_text"` // 待审核文字内容
|
||||||
FinalText *string `json:"final_text" bson:"final_text"` // 终态文字内容
|
FinalText *string `json:"final_text" bson:"final_text"` // 终态文字内容
|
||||||
AssociativeTableId *string `json:"associative_table_id" bson:"associative_table_id"` // 关联表主键ID
|
AssociativeTableId *string `json:"associative_table_id" bson:"associative_table_id"` // 关联表主键ID
|
||||||
ImageAuditTaskId *string `json:"image_audit_task_id" bson:"image_audit_task_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
|
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"` // 图像审核任务审核状态
|
ImageAuditTaskStatus *int64 `json:"image_audit_task_status" bson:"image_audit_task_status"` // 图像审核任务审核状态
|
||||||
TextAuditTaskStatus *int64 `json:"text_audit_task_status" bson:"text_audit_task_status"` // 文字审核任务审核状态
|
TextAuditTaskStatus *int64 `json:"text_audit_task_status" bson:"text_audit_task_status"` // 文字审核任务审核状态
|
||||||
Status *int64 `json:"status" bson:"status"` // 是否已过期
|
Status *int64 `json:"status" bson:"status"` // 是否已过期
|
||||||
ManuallyReviewStatus *int64 `json:"manually_review_status" bson:"manually_review_status"` // 人工复审状态
|
ManuallyReviewStatus *int64 `json:"manually_review_status" bson:"manually_review_status"` // 人工复审状态
|
||||||
Remarks *string `json:"remarks" bson:"remarks"` // 备注
|
ManuallyReviewOperator *int64 `json:"manually_review_operator" bson:"manually_review_operator"` // 人工复审操作人
|
||||||
Ct *int64 `json:"ct" bson:"ct"` // 创建时间
|
Remarks *string `json:"remarks" bson:"remarks"` // 备注
|
||||||
Ut *int64 `json:"ut" bson:"ut"` // 更新时间
|
Ct *int64 `json:"ct" bson:"ct"` // 创建时间
|
||||||
DelFlag *int64 `json:"del_flag" bson:"del_flag"` // 删除标记
|
Ut *int64 `json:"ut" bson:"ut"` // 更新时间
|
||||||
|
DelFlag *int64 `json:"del_flag" bson:"del_flag"` // 删除标记
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue