From f1d2d4321c71d6f6f21a995bd0bb4857ab997f9f Mon Sep 17 00:00:00 2001
From: withchao <993506633@qq.com>
Date: Fri, 26 May 2023 17:32:48 +0800
Subject: [PATCH] RevokeMsg

---
 internal/rpc/msg/revoke.go      | 2 +-
 pkg/common/db/controller/msg.go | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/internal/rpc/msg/revoke.go b/internal/rpc/msg/revoke.go
index a2b87aa3c..dfa5758dc 100644
--- a/internal/rpc/msg/revoke.go
+++ b/internal/rpc/msg/revoke.go
@@ -46,7 +46,7 @@ func (m *msgServer) RevokeMsg(ctx context.Context, req *msg.RevokeMsgReq) (*msg.
 		sessionType = constant.SuperGroupChatType
 		conversationID = utils.GenConversationUniqueKeyForGroup(req.GroupID)
 	}
-	msgs, err := m.MsgDatabase.GetMsgBySeqs(ctx, req.RecvID, conversationID, []int64{req.Seq})
+	msgs, err := m.MsgDatabase.GetMsgBySeqs(ctx, req.UserID, conversationID, []int64{req.Seq})
 	if err != nil {
 		return nil, err
 	}
diff --git a/pkg/common/db/controller/msg.go b/pkg/common/db/controller/msg.go
index 5d61add0b..c6a095780 100644
--- a/pkg/common/db/controller/msg.go
+++ b/pkg/common/db/controller/msg.go
@@ -506,6 +506,7 @@ func (db *commonMsgDatabase) GetMsgBySeqs(ctx context.Context, userID string, co
 			log.ZError(ctx, "get message from redis exception", err, "failedSeqs", failedSeqs, "conversationID", conversationID)
 		}
 	}
+	log.ZInfo(ctx, "db.cache.GetMessagesBySeq", "userID", userID, "conversationID", conversationID, "seqs", seqs, "successMsgs", len(successMsgs), "failedSeqs", failedSeqs, "conversationID", conversationID)
 	prome.Add(prome.MsgPullFromRedisSuccessCounter, len(successMsgs))
 	if len(failedSeqs) > 0 {
 		mongoMsgs, err := db.getMsgBySeqs(ctx, conversationID, failedSeqs)