09-10-netty优化系统房间的创建
This commit is contained in:
@ -156,14 +156,13 @@ public class ChatServerHandler extends SimpleChannelInboundHandler<TextWebSocket
|
|||||||
message.put("unReadCount", roomCounts);
|
message.put("unReadCount", roomCounts);
|
||||||
log.info("发送所有未读消息:{}",message);
|
log.info("发送所有未读消息:{}",message);
|
||||||
sendMessage(ctx, message.toJSONString());
|
sendMessage(ctx, message.toJSONString());
|
||||||
|
}
|
||||||
//认证完成后开始构建系统消息房间 判断是否有系统消息房间 没有则增加
|
//认证完成后开始构建系统消息房间 判断是否有系统消息房间 没有则增加
|
||||||
if (!isHaveSystemRoom){
|
if (!isHaveSystemRoom){
|
||||||
ChatGroup chatGroup = new ChatGroup();
|
ChatGroup chatGroup = new ChatGroup();
|
||||||
chatGroup.setType(String.valueOf(2));
|
chatGroup.setType(String.valueOf(2));
|
||||||
chatGroup.setMembers("[99, "+loginUser.getUserId()+"]");
|
chatGroup.setMembers("[99, "+loginUser.getUserId()+"]");
|
||||||
chatGroupService.save(chatGroup);
|
chatGroupService.save(chatGroup);
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
super.userEventTriggered(ctx, evt);
|
super.userEventTriggered(ctx, evt);
|
||||||
|
|||||||
Reference in New Issue
Block a user