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

09-10-netty修复消除未读消息，修改列表赋值

Browse Source
This commit is contained in:
青云
2025-09-11 19:36:36 +08:00
parent 542c4e91ac
commit 8e84195e98
2 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -303,11 +303,11 @@ public class ChatServerHandler extends SimpleChannelInboundHandler<TextWebSocket
}else if ("1".equals(type)){ }else if ("1".equals(type)){
log.info("收到客户端确认消息：{}", jsonObject); log.info("收到客户端确认消息：{}", jsonObject);
//前端接收方收到消息返回1 说明此时处于聊天框内 可以清空该房间的所有未读消息 将此房间聊天记录全部已读 //前端接收方收到消息返回1 说明此时处于聊天框内 可以清空该房间的所有未读消息 将此房间聊天记录全部已读
//现在是用户发送消息 ctx为接收方用户
LambdaQueryWrapper<ChatHistory> lambdaQueryWrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<ChatHistory> lambdaQueryWrapper = new LambdaQueryWrapper<>();
lambdaQueryWrapper lambdaQueryWrapper
.eq(ChatHistory::getSenderId,jsonObject.get("from")) .ne(ChatHistory::getSenderId,sysUserVo.getUserId().toString())
.eq(ChatHistory::getGeterId,jsonObject.get("roomId")) .eq(ChatHistory::getGeterId,jsonObject.get("roomId"))
// .eq(ChatHistory::getMessage,jsonObject.get("message"))
.eq(ChatHistory::getIsRead,"1"); .eq(ChatHistory::getIsRead,"1");
List<ChatHistory> list = chatHistoryService.list(lambdaQueryWrapper); List<ChatHistory> list = chatHistoryService.list(lambdaQueryWrapper);
if (list != null && !list.isEmpty()){ if (list != null && !list.isEmpty()){

9
xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/websocket/controller/ChatGroupController.java
View File

@ -159,14 +159,15 @@ public class ChatGroupController {
if (sysUserVo != null) { if (sysUserVo != null) {
byId.setName(sysUserVo.getNickName()); byId.setName(sysUserVo.getNickName());
byId.setAvatar(sysUserVo.getAvatar()); byId.setAvatar(sysUserVo.getAvatar());
}else if (list.getFirst().equals(99L)){
byId.setName("系统消息");
byId.setAvatar(null);
}else{ }else{
byId.setName("此用户已注销"); byId.setName("此用户已注销");
byId.setAvatar(null); byId.setAvatar(null);
} }
}else { }else if (byId.getType().equals("2")){
//消息通知
byId.setName("系统消息");
byId.setAvatar(null);
} else {
//群聊 则只需要将群主头像赋值给群聊头像 //群聊 则只需要将群主头像赋值给群聊头像
SysUserVo sysUserVo = sysUserService.selectUserById(byId.getOwerId()); SysUserVo sysUserVo = sysUserService.selectUserById(byId.getOwerId());
if (sysUserVo != null){ if (sysUserVo != null){