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

09-10-netty发送时添加name字段

Browse Source
This commit is contained in:
青云
2025-09-11 11:14:22 +08:00
parent e8c78865cb
commit 0b29401112
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -246,7 +246,9 @@ public class ChatServerHandler extends SimpleChannelInboundHandler<TextWebSocket
if ("0".equals(type)) {
//来自哪个用户
jsonObject.put("from", channelUserMap.get(ctx));
SysUserVo sysUserVo = sysUserService.selectUserById(Long.valueOf(channelUserMap.get(ctx)));
jsonObject.put("from", sysUserVo.getUserId());
jsonObject.put("name", sysUserVo.getNickName());
log.info("收到客户端消息：{}", jsonObject);
String RoomId = jsonObject.get("roomId").toString();
//根据ID拿到房间实例
@ -255,7 +257,7 @@ public class ChatServerHandler extends SimpleChannelInboundHandler<TextWebSocket
List<Long> ids = JSONObject.parseArray(byId.getMembers(), Long.class);
if (ids != null && !ids.isEmpty()) {
//要从IDS中去掉自己ID防止发送自己消息
ids.remove(Long.valueOf(channelUserMap.get(ctx)));
ids.remove(sysUserVo.getUserId());
for (Long id : ids) {
//只要发送一条数据，就要给接收方推送所有未读消息
if (!userRoomCountMap.containsKey(id + "+" + RoomId)) {
@ -285,7 +287,7 @@ public class ChatServerHandler extends SimpleChannelInboundHandler<TextWebSocket
ChatHistory chatHistory = new ChatHistory();
chatHistory.setMessageDate(new Date());
chatHistory.setGeterId(Long.valueOf(RoomId));
chatHistory.setSenderId(Long.valueOf(channelUserMap.get(ctx)));
chatHistory.setSenderId(sysUserVo.getUserId());
chatHistory.setIsRead("1");
chatHistory.setMessage(String.valueOf(jsonObject));
chatHistoryService.save(chatHistory);