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

09-17-优化

Browse Source
This commit is contained in:
青云
2025-09-17 20:02:35 +08:00
parent 1d2ec60e68
commit 6224b42479
1 changed files with 8 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -485,10 +485,7 @@ public class ChatServerHandler extends SimpleChannelInboundHandler<TextWebSocket
chatHistory = new ChatHistory(); chatHistory = new ChatHistory();
//发送方设置为99 表示系统消息 //发送方设置为99 表示系统消息
chatHistory.setSenderId(99L); chatHistory.setSenderId(99L);
chatHistory.setMessage(jsonObject.toString()); jsonObject.put("nickName","系统消息");
chatHistory.setMessageDate(new Date());
chatHistory.setIsRead("1");//未读
} }
//2:考勤消息 //2:考勤消息
@ -509,9 +506,6 @@ public class ChatServerHandler extends SimpleChannelInboundHandler<TextWebSocket
chatHistory = new ChatHistory(); chatHistory = new ChatHistory();
//发送方设置为100 表示系统消息中的考勤消息 //发送方设置为100 表示系统消息中的考勤消息
chatHistory.setSenderId(100L); chatHistory.setSenderId(100L);
chatHistory.setMessage(jsonObject.toString());
chatHistory.setMessageDate(new Date());
chatHistory.setIsRead("1");//未读
jsonObject.put("nickName","考勤消息"); jsonObject.put("nickName","考勤消息");
} }
@ -533,9 +527,6 @@ public class ChatServerHandler extends SimpleChannelInboundHandler<TextWebSocket
chatHistory = new ChatHistory(); chatHistory = new ChatHistory();
//发送方设置为101 表示系统消息中的安全消息 //发送方设置为101 表示系统消息中的安全消息
chatHistory.setSenderId(101L); chatHistory.setSenderId(101L);
chatHistory.setMessage(jsonObject.toString());
chatHistory.setMessageDate(new Date());
chatHistory.setIsRead("1");//未读
jsonObject.put("nickName","安全消息"); jsonObject.put("nickName","安全消息");
} }
@ -557,21 +548,23 @@ public class ChatServerHandler extends SimpleChannelInboundHandler<TextWebSocket
chatHistory = new ChatHistory(); chatHistory = new ChatHistory();
//发送方设置为102 表示系统消息中的质量消息 //发送方设置为102 表示系统消息中的质量消息
chatHistory.setSenderId(102L); chatHistory.setSenderId(102L);
chatHistory.setMessage(jsonObject.toString());
chatHistory.setMessageDate(new Date());
chatHistory.setIsRead("1");//未读
jsonObject.put("nickName","质量消息"); jsonObject.put("nickName","质量消息");
} }
default -> { default -> {
throw new RuntimeException("未知的类型"); log.error("未知消息类型");
return;
} }
} }
chatGroupService.saveOrUpdate(groupServiceOne); chatGroupService.saveOrUpdate(groupServiceOne);
jsonObject.put("roomId", groupServiceOne.getId()); jsonObject.put("roomId", groupServiceOne.getId());
chatHistory.setMessageType(jsonObject.get("messageType").toString());
chatHistory.setMessage(jsonObject.toString());
chatHistory.setMessageType("txt");
chatHistory.setMessageDate(new Date());
chatHistory.setGeterId(groupServiceOne.getId()); chatHistory.setGeterId(groupServiceOne.getId());
chatHistory.setIsRead("1");//未读
chatHistoryService.save(chatHistory); chatHistoryService.save(chatHistory);
//发送消息后 将该房间未读消息数加1 //发送消息后 将该房间未读消息数加1