seqs

2 years ago · 2c58335b9b
parent 482ea572c4
commit 2c58335b9b
2 changed files with 1 additions and 2 deletions
--- 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 {
--- 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},