diff --git a/pkg/common/db/controller/msg.go b/pkg/common/db/controller/msg.go index 37bb17b2e..0176c9475 100644 --- a/pkg/common/db/controller/msg.go +++ b/pkg/common/db/controller/msg.go @@ -445,6 +445,9 @@ func (db *commonMsgDatabase) getMsgBySeqsRange(ctx context.Context, userID strin return nil, err } for _, msg := range msgs { + if msg.IsRead { + msg.Msg.IsRead = true + } seqMsgs = append(seqMsgs, convert.MsgDB2Pb(msg.Msg)) } }