decode

2 years ago · 303e2c4ecc
parent 6b204c6066
commit 303e2c4ecc
1 changed files with 1 additions and 1 deletions
--- a/pkg/common/db/unrelation/msg.go
+++ b/pkg/common/db/unrelation/msg.go
@ -155,7 +155,7 @@ func (m *MsgMongoDriver) GetMsgBySeqIndexIn1Doc(ctx context.Context, docID strin
 	}
 	log.ZDebug(ctx, "info", "beginIndex", beginIndex, "num", num)
 	var msgInfos []*table.MsgInfoModel
-	if err := cursor.All(ctx, &msgInfos); err != nil {
+	if err := cursor.Decode(&msgInfos); err != nil {
 		return nil, nil, err
 	}
 	if len(msgInfos) < 1 {