From 979c3104c707d78b20f999f9f3c22d135d0ccefa Mon Sep 17 00:00:00 2001
From: withchao <993506633@qq.com>
Date: Wed, 12 Feb 2025 17:30:52 +0800
Subject: [PATCH] fix: msg cache

---
 internal/msgtransfer/online_msg_to_mongo_handler.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/internal/msgtransfer/online_msg_to_mongo_handler.go b/internal/msgtransfer/online_msg_to_mongo_handler.go
index d8836d54e..279ec70c6 100644
--- a/internal/msgtransfer/online_msg_to_mongo_handler.go
+++ b/internal/msgtransfer/online_msg_to_mongo_handler.go
@@ -77,6 +77,10 @@ func (mc *OnlineHistoryMongoConsumerHandler) handleChatWs2Mongo(ctx context.Cont
 	for _, msg := range msgFromMQ.MsgData {
 		seqs = append(seqs, msg.Seq)
 	}
+	if err := mc.msgTransferDatabase.DeleteMessagesFromCache(ctx, msgFromMQ.ConversationID, seqs); err != nil {
+		log.ZError(ctx, "remove cache msg from redis err", err, "msg",
+			msgFromMQ.MsgData, "conversationID", msgFromMQ.ConversationID)
+	}
 }
 
 func (*OnlineHistoryMongoConsumerHandler) Setup(_ sarama.ConsumerGroupSession) error { return nil }