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 8bcf1c99..8de3421e 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 @@ -418,4 +418,21 @@ public class ChatServerHandler extends SimpleChannelInboundHandler channelHandlerContexts = userChannelMap.get(userId.toString()); + if (channelHandlerContexts == null||channelHandlerContexts.isEmpty()){ + return; + } + for (ChannelHandlerContext channelHandlerContext : channelHandlerContexts) { + JSONObject jsonObject = new JSONObject(); + jsonObject.put("type", "5"); + jsonObject.put("roomInfo", chatGroup); + sendMessage(channelHandlerContext, String.valueOf(jsonObject)); + log.info("发送房间创建确认消息:{}",jsonObject); + } + } + + } diff --git a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/websocket/controller/ChatGroupController.java b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/websocket/controller/ChatGroupController.java index faf6aee8..682ccf06 100644 --- a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/websocket/controller/ChatGroupController.java +++ b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/websocket/controller/ChatGroupController.java @@ -10,6 +10,7 @@ import org.dromara.common.mybatis.core.page.TableDataInfo; import org.dromara.common.satoken.utils.LoginHelper; import org.dromara.system.domain.vo.SysUserVo; import org.dromara.system.service.impl.SysUserServiceImpl; +import org.dromara.websocket.ChatServerHandler; import org.dromara.websocket.domain.ChatGroup; import org.dromara.websocket.domain.ChatHistory; import org.dromara.websocket.domain.vo.ChatHistoryVo; @@ -35,6 +36,8 @@ public class ChatGroupController { private ChatHistoryServiceImpl chatHistoryService; @Autowired private SysUserServiceImpl sysUserService; + @Autowired + private ChatServerHandler chatServerHandler; /*** * 新建聊天房间 不论单群 @@ -84,10 +87,13 @@ public class ChatGroupController { boolean save = chatGroupService.save(chatGroup); if (save) { + //最后发送聊天房间创建确认消息 + chatServerHandler.sendRoomInfo(userId,chatGroup); return R.ok(chatGroup); }else { return R.fail("创建群聊关系失败"); } + }