diff --git a/app/mix/dao/mongo.go b/app/mix/dao/mongo.go index b8712491..44701104 100644 --- a/app/mix/dao/mongo.go +++ b/app/mix/dao/mongo.go @@ -3869,9 +3869,6 @@ func (m *Mongo) GetTextAuditTaskList(ctx *gin.Context, req *textaudittaskproto.O if req.Status != nil { query["status"] = util.DerefInt64(req.Status) } - if req.Role != nil { - query["role"] = util.DerefInt64(req.Role) - } if req.NotAlignedOpt != 0 { query["is_aligned"] = qmgo.M{ "$ne": consts.TextAuditIsAligned_Yes, @@ -3905,10 +3902,6 @@ func (m *Mongo) GetTextAuditTaskListByCollectionInfos(ctx *gin.Context, database "del_flag": 0, } - if role != nil { - query["role"] = util.DerefInt64(role) - } - orClause := make([]qmgo.M, 0) for i := range databases { orClause = append(orClause, qmgo.M{ diff --git a/app/mix/service/service.go b/app/mix/service/service.go index 1e02ef0a..8d91c9ec 100644 --- a/app/mix/service/service.go +++ b/app/mix/service/service.go @@ -3337,6 +3337,18 @@ func (s *Service) OpGetTextAuditTaskVOList(ctx *gin.Context, req *textaudittaskp return } + // 主播昵称审核 + if util.DerefInt64(req.Role) == consts.Streamer { + filterVoList := make([]*textaudittaskproto.TextAuditTaskVO, 0) + for _, vo := range volist { + account := acctMp[vo.GetMid()] + if account != nil && account.GetRole() == consts.Streamer { + filterVoList = append(filterVoList, vo) + } + } + volist = filterVoList + } + for _, vo := range volist { vo.Account = &accountproto.OpListVO{} vo.Account.CopyAccount(acctMp[vo.GetMid()])