1

api/proto/imageaudittask/proto/imageaudittask_op.go

@@ -61,6 +61,7 @@ type OpListReq struct {
 	Limit                  int     `json:"limit"`
 	Sort                   string
 	NotAlignedOpt          int
+	IndexName              string
 }
 
 type OpListData struct {

app/mix/dao/mongo.go

@@ -3471,6 +3471,7 @@ func (m *Mongo) GetImageAuditTaskList(ctx *gin.Context, req *imageaudittaskproto
 	if req.Sort != "" {
 		sortClause = req.Sort
 	}
+	opt := options2.Find().SetHint(req.IndexName)
 	err := col.Find(ctx, query).Sort(sortClause).Skip(int64(req.Offset)).Limit(int64(req.Limit)).All(&list)
 	if err == qmgo.ErrNoSuchDocuments {
 		err = nil

app/mix/service/service.go

@@ -3163,7 +3163,7 @@ func (s *Service) OpGetImageAuditTaskVOList(ctx *gin.Context, req *imageaudittas
 
 	// 仅查询未对齐的任务
 	req.NotAlignedOpt = 1
-
+	req.IndexName = "idx_list" // 指定索引
 	list, err := _DefaultImageAuditTask.OpList(ctx, req)
 	if err != nil {
 		logger.Error("OpGetImageAuditTaskListByMid fail, req: %v, err: %v", util.ToJson(req), err)

library/contentaudit/imageaudit/imageaudit.go

@@ -36,6 +36,7 @@ func Run(batchId string) (successNum int, failNum int, err error) {
 		BatchId:   goproto.String(batchId),
 		Status:    goproto.Int64(consts.ImageAudit_Created),
 		Sort:      "ct",
+		IndexName: "idx_batch_id",
 	})
 	if err != nil {
 		logger.Info("_DefaultImageAuditTask OpList fail: %v", err)