pull msg bug

2 years ago · 6a43ca8302
parent ec35cf5e49
commit 6a43ca8302
1 changed files with 4 additions and 2 deletions
--- a/pkg/common/db/controller/msg.go
+++ b/pkg/common/db/controller/msg.go
@ -455,8 +455,10 @@ func (db *commonMsgDatabase) GetMsgBySeqsRange(ctx context.Context, userID strin
 	if err != nil && errs.Unwrap(err) != redis.Nil {
 		return 0, 0, nil, err
 	}
-	if userMaxSeq < maxSeq {
-		maxSeq = userMaxSeq
+	if userMaxSeq != 0 {
+		if userMaxSeq < maxSeq {
+			maxSeq = userMaxSeq
+		}
 	}
 	if begin < minSeq {
 		begin = minSeq