diff --git a/pkg/common/db/table/unrelation/msg.go b/pkg/common/db/table/unrelation/msg.go index 97b585913..431738b58 100644 --- a/pkg/common/db/table/unrelation/msg.go +++ b/pkg/common/db/table/unrelation/msg.go @@ -101,7 +101,7 @@ func (m MsgDocModel) GetSeqsBeginEnd(seqs []int64) (int64, int64) { if len(seqs) == 0 { return 0, 0 } - return seqs[0], seqs[len(seqs)-1] + return seqs[len(seqs)-1], seqs[0] } func (m MsgDocModel) GetMsgIndex(seq int64) int64 { diff --git a/pkg/common/db/unrelation/msg.go b/pkg/common/db/unrelation/msg.go index f3cc11db8..c9247f8ca 100644 --- a/pkg/common/db/unrelation/msg.go +++ b/pkg/common/db/unrelation/msg.go @@ -137,7 +137,6 @@ func (m *MsgMongoDriver) UpdateOneDoc(ctx context.Context, msg *table.MsgDocMode func (m *MsgMongoDriver) GetMsgBySeqIndexIn1Doc(ctx context.Context, docID string, beginSeq, endSeq int64) (msgs []*sdkws.MsgData, seqs []int64, err error) { beginIndex := m.msg.GetMsgIndex(beginSeq) num := endSeq - beginSeq + 1 - pipeline := bson.A{ bson.M{ "$match": bson.M{"doc_id": docID},