app/mix/dao/mongo.go

@@ -1581,9 +1581,9 @@ func (m *Mongo) GetLastHourNewUserFromH5Count(ctx *gin.Context, req *accountprot
 	return count, err
 }
 
-func (m *Mongo) GetStreamerAccountMids(ctx *gin.Context) ([]int64, error) {
+func (m *Mongo) GetStreamerAccountMids(ctx *gin.Context) ([]*dbstruct.AcctId, error) {
 	col := m.getColAccount()
-	list := make([]int64, 0)
+	list := make([]*dbstruct.AcctId, 0)
 
 	query := qmgo.M{
 		"role": qmgo.M{
@@ -1591,7 +1591,7 @@ func (m *Mongo) GetStreamerAccountMids(ctx *gin.Context) ([]int64, error) {
 		},
 	}
 
-	err := col.Find(ctx, query).Sort("_id").Select("_id").All(&list)
+	err := col.Find(ctx, query).Select(qmgo.M{"_id": 1}).All(&list)
 	if err == qmgo.ErrNoSuchDocuments {
 		err = nil
 		return nil, err

app/mix/service/logic/account.go

@@ -274,5 +274,10 @@ func (p *Account) GetStreamerAccountMids(ctx *gin.Context) ([]int64, error) {
 		logger.Error("GetStreamerAccountMids fail, err: %v", err)
 		return make([]int64, 0), err
 	}
-	return list, nil
+
+	mids := make([]int64, 0)
+	for _, v := range list {
+		mids = append(mids, v.Mid)
+	}
+	return mids, nil
 }

dbstruct/account.go

@@ -104,3 +104,7 @@ type StreamerAcct struct {
 	Ut           *int64  `json:"ut" bson:"ut"`                         // 更新时间
 	DelFlag      *int64  `json:"del_flag" bson:"del_flag"`             // 删除标记，0-否，1-是
 }
+
+type AcctId struct {
+	Mid int64 `json:"mid" bson:"_id"` // 用户表Id
+}