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

feat-IRONFANS-76-Robin #222

Merged
chenhao merged 4 commits from feat-IRONFANS-76-Robin into main 2024-03-29 23:19:34 +08:00
Conversation 0 Commits 4 Files Changed 19 +9 -5
3 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit cd7a9275aa - Show all commits

4
app/mix/dao/mongo.go
View File

@ -3320,7 +3320,7 @@ func (m *Mongo) UpdateMomentAuditTaskByTextAuditTaskIds(ctx *gin.Context, moment
return err
}
func (m *Mongo) UpdateMomentAuditTaskByMomentIdsAndStatus(ctx *gin.Context, moment_audit_task *dbstruct.MomentAuditTask, momentIds []int64, status int64) error {
func (m *Mongo) UpdateMomentAuditTaskByMomentIdsAndStatus(ctx *gin.Context, moment_audit_task *dbstruct.MomentAuditTask, momentIds []string, status int64) error {
col := m.getColMomentAuditTask()
set := util.EntityToM(moment_audit_task)
set["ut"] = time.Now().Unix()
@ -3331,7 +3331,7 @@ func (m *Mongo) UpdateMomentAuditTaskByMomentIdsAndStatus(ctx *gin.Context, mome
"associative_table_id": qmgo.M{
"$in": momentIds,
},
"status": status,
"manually_review_status": status,
}
_, err := col.UpdateAll(ctx, filter, up)
return err

2
app/mix/service/logic/moment_audit_task.go
View File

@ -92,7 +92,7 @@ func (p *MomentAuditTask) OpUpdateByTextAuditTaskIds(ctx *gin.Context, moment_au
return nil
}
func (p *MomentAuditTask) OpUpdateByMomentIdsAndStatus(ctx *gin.Context, moment_audit_task *dbstruct.MomentAuditTask, momentIds []int64, status int64) error {
func (p *MomentAuditTask) OpUpdateByMomentIdsAndStatus(ctx *gin.Context, moment_audit_task *dbstruct.MomentAuditTask, momentIds []string, status int64) error {
err := p.store.UpdateMomentAuditTaskByMomentIdsAndStatus(ctx, moment_audit_task, momentIds, status)
if err != nil {
logger.Error("UpdateMomentAuditTaskByMomentIdAndStatus fail, err: %v", err)

8
app/mix/service/service.go
View File

@ -1384,10 +1384,14 @@ func (s *Service) OpReviewMoment(ctx *gin.Context, req *momentproto.OpReviewReq)
}
// 更新动态审核表的状态
momentStrIds := make([]string, 0)
for _, id := range req.MomentIds {
momentStrIds = append(momentStrIds, fmt.Sprint(id))
}
err = _DefaultMomentAuditTask.OpUpdateByMomentIdsAndStatus(ctx, &dbstruct.MomentAuditTask{
Status: goproto.Int64(finalMomentAuditTaskStatus),
ManuallyReviewStatus: goproto.Int64(finalMomentAuditTaskStatus),
ManuallyReviewOperator: goproto.Int64(req.BaseRequest.Mid),
}, req.MomentIds, consts.MomentManuallyReview_Waiting)
}, momentStrIds, consts.MomentManuallyReview_Waiting)
if err != nil {
logger.Error("_DefaultMomentAuditTask OpUpdateByMomentIdsAndStatus fail, req: %v, err: %v", util.ToJson(req), err)
ec = errcode.ErrCodeMomentSrvFail