fix

1 year ago · a2bbb6aff6
parent d467381b6f
commit a2bbb6aff6
1 changed files with 1 additions and 1 deletions
--- a/pkg/common/storage/database/mgo/msg.go
+++ b/pkg/common/storage/database/mgo/msg.go
@ -1243,7 +1243,7 @@ func (m *MsgMgo) GetDocIDs(ctx context.Context) ([]string, error) {
 	} else {
 		rand.Seed(uint64(time.Now().UnixMilli()))
 		skip = rand.Intn(int(count / int64(limit)))
-		offset = skip * (int(count) / limit)
+		offset = skip * limit
 	}

 	res, err := mongoutil.Aggregate[*model.MsgDocModel](ctx, m.coll, []bson.M{