diff --git a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/websocket/ChatServerHandler.java b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/websocket/ChatServerHandler.java index 3448c186..2233e94a 100644 --- a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/websocket/ChatServerHandler.java +++ b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/websocket/ChatServerHandler.java @@ -356,22 +356,7 @@ public class ChatServerHandler extends SimpleChannelInboundHandler channelHandlerContexts = userChannelMap.get(userId.toString()); - if (channelHandlerContexts != null && !channelHandlerContexts.isEmpty()) { - //给每个通道发送对应消息 - for (ChannelHandlerContext handlerContext : channelHandlerContexts) { - //同时发送所有未读消息给前端进行渲染 - HashMap temp = new HashMap<>(); - userRoomCountMap.forEachKey(0, (value) -> { - if (value.contains(userId.toString())){ - temp.put(value,userRoomCountMap.get(value)); - } - }); - jsonObject.put("countValue", temp); - sendMessage(handlerContext, jsonObject.toString()); - } - } + //生成系统消息的聊天记录 LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); lambdaQueryWrapper.eq(ChatGroup::getMembers,"[system, "+userId+"]"); @@ -401,6 +386,23 @@ public class ChatServerHandler extends SimpleChannelInboundHandler channelHandlerContexts = userChannelMap.get(userId.toString()); + if (channelHandlerContexts != null && !channelHandlerContexts.isEmpty()) { + //给每个通道发送对应消息 + for (ChannelHandlerContext handlerContext : channelHandlerContexts) { + //同时发送所有未读消息给前端进行渲染 + HashMap temp = new HashMap<>(); + userRoomCountMap.forEachKey(0, (value) -> { + if (value.contains(userId.toString())){ + temp.put(value,userRoomCountMap.get(value)); + } + }); + jsonObject.put("countValue", temp); + sendMessage(handlerContext, jsonObject.toString()); + } + } + }