【维普】软件工程-基于SpringBoot的轻小说阅读平台-“轻文户缔”

目录附录聊天室：@ServicepublicclassWebSocketServiceImplimplementsWebSocketService{@AutowiredprivateChatServicechatService;@AutowiredprivateChatMapperchatMapper;@AutowiredprivateSysUserServicesysUserService;@OverridepublicvoidaddUser(StringaccountName,StringnovelId,StringchapterId,Sessionsession){//1、获取当前用户信息SysUsersysUser=sysUserService.getOne(newQueryWrapper<SysUser>().eq(SqlConstant.ACCOUNT_NAME,accountName));//1、保存当前用户信息WebSocketUserInfowebSocketUserInfo=newWebSocketUserInfo();webSocketUserInfo.setUserId(sysUser.getId());webSocketUserInfo.setUsername(sysUser.getUserName());webSocketUserInfo.setAccountName(accountName);webSocketUserInfo.setNovelId(novelId);webSocketUserInfo.setChapterId(chapterId);webSocketUserInfo.setSession(session);WebSocketUtils.addSession(accountName,webSocketUserInfo);//2、给当前的用户从数据库捞出最新的10条聊天数据List<Chat>chats=this.chatMapper.selectList(newQueryWrapper<Chat>().eq(SqlConstant.NOVEL_ID,novelId).eq(SqlConstant.CHAPTER_ID,chapterId).in(SqlConstant.MSG_TYPE,MessageType.NOTICT_MSG,MessageType.CHAT_MSG.getCode(),MessageType.USER_MSG.getCode()).orderByDesc(SqlConstant.SEND_TIME).last("limit10"));//取出的数据再按照正序排if(!chats.isEmpty()){chats=chats.stream().sorted(Cparing(Chat::getSendTime)).collect(Collectors.toList());}for(Chatchat:chats){if(chat.getMsgType().equals(MessageType.NOTICT_MSG.getCode())){this.sendMessageForNovelIdAndChapterId(chat.getNovelId(),chat.getChapterId(),chat.getMessage(),chat.getMsgType());}elseif(chat.getSendUserId().equals(sysUser.getId())){this.sendMessageForNovelIdAndChapterId(chat.getNovelId(),chat.getChapterId(),chat.getMessage(),MessageType.USER_MSG.getCode());}else{this.sendMessageForNovelIdAndChapterId(chat.getNovelId(),chat.getChapterId(),chat.getMessage(),MessageType.CHAT_MSG.getCode());}}//3、通知当前章节的用户当前用户已经上线StringuserUpMsg=accountName+"用户已上线";this.sendMessageForNovelIdAndChapterId(novelId,chapterId,userUpMsg,MessageType.NOTICT_MSG.getCode());//保存上线提示信息Chatchat=newChat(StringUtils.getUuid(),userUpMsg,sysUser.getId(),newDate(),novelId,chapterId,MessageType.NOTICT_MSG.getCode());this.chatService.save(chat);//4、当前在线人数+1this.sendMessageOnlineNum(novelId,chapterId);}@OverridepublicvoidexitChat(StringaccountName,StringnovelId,StringchapterId,Sessionsession){WebSocketUserInfouserInfo=WebSocketUtils.getUserInfo(accountName);//1、移除当前人的信息WebSocketUtils.removeSession(accountName);//2、通知当前章节用户已下线StringexitMsg=accountName+"用户已下线";this.sendMessageForNovelIdAndChapterId(novelId,chapterId,exitMsg,MessageType.NOTICT_MSG.getCode());//保存下线提示信息Chatchat=newChat(StringUtils.getUuid(),exitMsg,userInfo.getUserId(),newDate(),novelId,chapterId,MessageType.NOTICT_MSG.getCode());this.chatService.save(chat);//3、当前在线人数减一this.sendMessageOnlineNum(novelId,chapterId);}@OverridepublicvoidsendMessage(StringaccountName,StringnovelId,StringchapterId,Sessionsession,Stringmessage){//1、群发Map<String,WebSocketUserInfo>onlineSession=WebSocketUtils.getOnlineSession();WebSocketUserInfosendUserInfo=WebSocketUtils.getUserInfo(accountName);for(Map.Entry<String,WebSocketUserInfo>entry:onlineSession.entrySet()){WebSocketUserInfouserInfo=entry.getValue();//发送消息WebSocketPojowebSocketPojo=newWebSocketPojo();webSocketPojo.setAccountName(accountName);webSocketPojo.setUsername(userInfo.getUsername());webSocketPojo.setMessageTime(newDate());webSocketPojo.setMessage(message);if(accountName.equals(userInfo.getAccountName())){webSocketPojo.setMsgType(MessageType.USER_MSG.getCode());}elseif(userInfo.getNovelId().equals(novelId)&&userInfo.getChapterId().equals(chapterId)){//发送消息webSocketPojo.setMsgType(MessageType.CHAT_MSG.getCode());}WebSocketUtils.sendMessage(userInfo.ge