lcj/xinnengyuan
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

09-10-netty设置系统消息type为2

Browse Source
This commit is contained in:
青云
2025-09-10 16:11:30 +08:00
parent 0f3d1e38be
commit ab332c462f
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/websocket/ChatServerHandler.java
View File

@ -158,10 +158,9 @@ public class ChatServerHandler extends SimpleChannelInboundHandler<TextWebSocket
//认证完成后开始构建系统消息房间 判断是否有系统消息房间 没有则增加 //认证完成后开始构建系统消息房间 判断是否有系统消息房间 没有则增加
if (!isHaveSystemRoom){ if (!isHaveSystemRoom){
ChatGroup chatGroup = new ChatGroup(); ChatGroup chatGroup = new ChatGroup();
chatGroup.setType(String.valueOf(0)); chatGroup.setType(String.valueOf(2));
chatGroup.setMembers("[99, "+loginUser.getUserId()+"]"); chatGroup.setMembers("[99, "+loginUser.getUserId()+"]");
chatGroupService.save(chatGroup); chatGroupService.save(chatGroup);
} }
} }
} }
@ -367,7 +366,7 @@ public class ChatServerHandler extends SimpleChannelInboundHandler<TextWebSocket
//如果给成员发送系统消息 而该成员还没有建立过连接从而没有群聊房间 则创建该成员系统消息房间 //如果给成员发送系统消息 而该成员还没有建立过连接从而没有群聊房间 则创建该成员系统消息房间
if (groupServiceOne == null){ if (groupServiceOne == null){
groupServiceOne = new ChatGroup(); groupServiceOne = new ChatGroup();
groupServiceOne.setType(String.valueOf(0)); groupServiceOne.setType(String.valueOf(2));
groupServiceOne.setMembers("[99, "+userId+"]"); groupServiceOne.setMembers("[99, "+userId+"]");
chatGroupService.save(groupServiceOne); chatGroupService.save(groupServiceOne);
} }