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

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

Browse Source 
Closes #169
This commit is contained in:
Charles7c
2025-06-15 18:00:30 +08:00
parent 7bed5a51be
commit f44e0b0605
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
continew-module-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<MessageDO> list = baseMapper.selectUnreadListByUserId(userId);
List<Long> unreadIds = list.stream().map(MessageDO::getId).toList(); 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 WebSocketUtils.sendMessage(StpUtil.getTokenValueByLoginId(userId), String.valueOf(baseMapper
.selectUnreadListByUserId(userId) .selectUnreadListByUserId(userId)
.size())); .size()));