ContiNew/continew-admin
1
1
Fork 0
mirror of https://github.com/continew-org/continew-admin.git synced 2025-09-09 08:57:16 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(system/message): 修复全部已读无效

Browse Source
This commit is contained in:
Charles7c
2025-06-15 17:58:08 +08:00
parent 93bd70dc5c
commit 271e2d8681
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
continew-system/src/main/java/top/continew/admin/system/service/impl/MessageServiceImpl.java
View File

@@ -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()));