blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-10-29 15:30:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

update.

Browse Source
This commit is contained in:
Monet Lee 2024-08-13 19:19:41 +08:00
parent a2bbb6aff6
commit 850b7b2be7
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/common/storage/controller/msg.go
View File

@ -956,8 +956,10 @@ func (db *commonMsgDatabase) DeleteDocMsgBefore(ctx context.Context, ts int64, d
return index, err return index, err
} }
if len(index) == notNull { if len(index) == notNull {
log.ZDebug(ctx, "Delete db in Doc", "DocID", doc.DocID, "index", index, "maxSeq", maxSeq)
return index, db.msgDocDatabase.DeleteDoc(ctx, doc.DocID) return index, db.msgDocDatabase.DeleteDoc(ctx, doc.DocID)
} else { } else {
log.ZDebug(ctx, "delete db in index", "DocID", doc.DocID, "index", index, "maxSeq", maxSeq)
return index, db.msgDocDatabase.DeleteMsgByIndex(ctx, doc.DocID, index) return index, db.msgDocDatabase.DeleteMsgByIndex(ctx, doc.DocID, index)
} }
} }

2
pkg/common/storage/database/mgo/msg.go
View File

@ -1245,7 +1245,7 @@ func (m *MsgMgo) GetDocIDs(ctx context.Context) ([]string, error) {
skip = rand.Intn(int(count / int64(limit))) skip = rand.Intn(int(count / int64(limit)))
offset = skip * limit offset = skip * limit
} }
log.ZDebug(ctx, "offset", "skip", skip, "offset", offset)
res, err := mongoutil.Aggregate[*model.MsgDocModel](ctx, m.coll, []bson.M{ res, err := mongoutil.Aggregate[*model.MsgDocModel](ctx, m.coll, []bson.M{
{ {
"$project": bson.M{ "$project": bson.M{