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 list = baseMapper.selectUnreadListByUserId(userId); List 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()));