From 6a43ca8302495acde46f1a457b8f000f681bb002 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Wed, 7 Jun 2023 20:08:45 +0800 Subject: [PATCH] pull msg bug --- pkg/common/db/controller/msg.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/pkg/common/db/controller/msg.go b/pkg/common/db/controller/msg.go index 415e69e32..9a59e9030 100644 --- 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