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");