From 663186e9a4ce0eab2e9f937c62017f6e4405efee Mon Sep 17 00:00:00 2001
From: blue <825657193@qq.com>
Date: Mon, 15 Jan 2024 22:27:24 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=B6=88=E6=81=AF=E5=B7=B2?=
 =?UTF-8?q?=E8=AF=BB=E7=8A=B6=E6=80=81=E5=BC=82=E5=B8=B8=E7=9A=84bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/bx/implatform/listener/PrivateMessageListener.java     | 3 ---
 .../bx/implatform/service/impl/PrivateMessageServiceImpl.java  | 1 +
 2 files changed, 1 insertion(+), 3 deletions(-)

diff --git a/im-platform/src/main/java/com/bx/implatform/listener/PrivateMessageListener.java b/im-platform/src/main/java/com/bx/implatform/listener/PrivateMessageListener.java
index 8ff7d49..194f469 100644
--- a/im-platform/src/main/java/com/bx/implatform/listener/PrivateMessageListener.java
+++ b/im-platform/src/main/java/com/bx/implatform/listener/PrivateMessageListener.java
@@ -22,11 +22,9 @@ import java.util.Set;
 @Slf4j
 @IMListener(type = IMListenerType.PRIVATE_MESSAGE)
 public class PrivateMessageListener implements MessageListener<PrivateMessageVO> {
-
     @Lazy
     @Autowired
     private IPrivateMessageService privateMessageService;
-
     @Override
     public void process(List<IMSendResult<PrivateMessageVO>> results) {
         Set<Long> messageIds = new HashSet<>();
@@ -47,5 +45,4 @@ public class PrivateMessageListener implements MessageListener<PrivateMessageVO>
             privateMessageService.update(updateWrapper);
         }
     }
-
 }
diff --git a/im-platform/src/main/java/com/bx/implatform/service/impl/PrivateMessageServiceImpl.java b/im-platform/src/main/java/com/bx/implatform/service/impl/PrivateMessageServiceImpl.java
index 0ef663e..2e65510 100644
--- a/im-platform/src/main/java/com/bx/implatform/service/impl/PrivateMessageServiceImpl.java
+++ b/im-platform/src/main/java/com/bx/implatform/service/impl/PrivateMessageServiceImpl.java
@@ -207,6 +207,7 @@ public class PrivateMessageServiceImpl extends ServiceImpl<PrivateMessageMapper,
         LambdaQueryWrapper<PrivateMessage> wrapper = Wrappers.lambdaQuery();
         wrapper.eq(PrivateMessage::getSendId, session.getUserId())
                 .eq(PrivateMessage::getRecvId, friendId)
+                .eq(PrivateMessage::getStatus, MessageStatus.READED.code())
                 .orderByDesc(PrivateMessage::getId)
                 .select(PrivateMessage::getId)
                 .last("limit 1");