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