From 43f782b6cefd59001ef1114378fdde0e0da1de18 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Mon, 12 Jun 2023 20:43:09 +0800 Subject: [PATCH] isread --- internal/rpc/msg/as_read.go | 2 +- pkg/common/db/unrelation/msg.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/rpc/msg/as_read.go b/internal/rpc/msg/as_read.go index 1fa6f9346..54e372fa2 100644 --- a/internal/rpc/msg/as_read.go +++ b/internal/rpc/msg/as_read.go @@ -51,7 +51,7 @@ func (m *msgServer) MarkMsgsAsRead(ctx context.Context, req *msg.MarkMsgsAsReadR if err != nil { return } - err = m.MsgDatabase.MarkSingleChatMsgsAsRead(ctx, req.ConversationID, req.UserID, req.Seqs) + err = m.MsgDatabase.MarkSingleChatMsgsAsRead(ctx, req.UserID, req.ConversationID, req.Seqs) if err != nil { return } diff --git a/pkg/common/db/unrelation/msg.go b/pkg/common/db/unrelation/msg.go index 2d256693e..e98e0477b 100644 --- a/pkg/common/db/unrelation/msg.go +++ b/pkg/common/db/unrelation/msg.go @@ -291,7 +291,7 @@ func (m *MsgMongoDriver) MarkSingleChatMsgsAsRead(ctx context.Context, userID st } update := bson.M{ "$set": bson.M{ - fmt.Sprintf("msgs.%d.msg.is_read", index): true, + fmt.Sprintf("msgs.%d.is_read", index): true, }, } updateModel := mongo.NewUpdateManyModel().