From 881974fbfa125d5a43ad815e3f697a06aff47b5f Mon Sep 17 00:00:00 2001
From: Charles7c <charles7c@126.com>
Date: Mon, 9 Jun 2025 21:56:51 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E5=B7=B2=E8=AF=BB=E6=B6=88=E6=81=AF?=
 =?UTF-8?q?=E5=90=8E=E5=A2=9E=E5=8A=A0=E6=B6=88=E6=81=AF=E6=8E=A8=E9=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../continew/admin/system/service/impl/MessageServiceImpl.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/continew-module-system/src/main/java/top/continew/admin/system/service/impl/MessageServiceImpl.java b/continew-module-system/src/main/java/top/continew/admin/system/service/impl/MessageServiceImpl.java
index 42d212aa..5279d69d 100644
--- a/continew-module-system/src/main/java/top/continew/admin/system/service/impl/MessageServiceImpl.java
+++ b/continew-module-system/src/main/java/top/continew/admin/system/service/impl/MessageServiceImpl.java
@@ -71,6 +71,9 @@ public class MessageServiceImpl implements MessageService {
         List<MessageDO> list = baseMapper.selectUnreadListByUserId(userId);
         List<Long> unreadIds = list.stream().map(MessageDO::getId).toList();
         messageLogService.addWithUserId(CollUtil.intersection(unreadIds, ids).stream().toList(), userId);
+        WebSocketUtils.sendMessage(StpUtil.getTokenValueByLoginId(userId), String.valueOf(baseMapper
+            .selectUnreadListByUserId(userId)
+            .size()));
     }
 
     @Override