From 271e2d8681e213dca0acb4573e11d9949101796c Mon Sep 17 00:00:00 2001
From: Charles7c <charles7c@126.com>
Date: Sun, 15 Jun 2025 17:58:08 +0800
Subject: [PATCH] =?UTF-8?q?fix(system/message):=20=E4=BF=AE=E5=A4=8D?=
 =?UTF-8?q?=E5=85=A8=E9=83=A8=E5=B7=B2=E8=AF=BB=E6=97=A0=E6=95=88?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

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

diff --git a/continew-system/src/main/java/top/continew/admin/system/service/impl/MessageServiceImpl.java b/continew-system/src/main/java/top/continew/admin/system/service/impl/MessageServiceImpl.java
index c7cd8b2b..dd699e59 100644
--- a/continew-system/src/main/java/top/continew/admin/system/service/impl/MessageServiceImpl.java
+++ b/continew-system/src/main/java/top/continew/admin/system/service/impl/MessageServiceImpl.java
@@ -76,7 +76,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);
+        messageLogService.addWithUserId(CollUtil.isNotEmpty(ids)
+            ? CollUtil.intersection(unreadIds, ids).stream().toList()
+            : unreadIds, userId);
         WebSocketUtils.sendMessage(StpUtil.getTokenValueByLoginId(userId), String.valueOf(baseMapper
             .selectUnreadListByUserId(userId)
             .size()));