基于Spring Boot的Java+Shell开发soho管理后台设计源码

package work.soho.chat.biz.controller.client; import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.github.pagehelper.PageSerializable; import io.swagger.annotations.Api; import lombok.RequiredArgsConstructor; import lombok.extern.log4j.Log4j2; import org.springframework.security.core.annotation.AuthenticationPrincipal; import org.springframework.util.MimeType; import org.springframework.util.MimeTypeUtils; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; import work.soho.admin.common.security.userdetails.SohoUserDetails; import work.soho.api.admin.request.BetweenCreatedTimeRequest; import work.soho.chat.api.ChatMessage; import work.soho.chat.api.payload.RealTimeCmd; import work.soho.chat.api.payload.SystemMessage; import work.soho.chat.biz.domain.*; import work.soho.chat.biz.enums.ChatGroupUserEnums; import work.soho.chat.biz.enums.ChatSessionEnums; import work.soho.chat.biz.enums.ChatSessionUserEnums; import work.soho.chat.biz.req.*; import work.soho.chat.biz.service.*; import work.soho.chat.biz.vo.ChatGroupVO; import work.soho.chat.biz.vo.GroupQuestionsVo; import work.soho.chat.biz.vo.GroupVO; import work.soho.chat.biz.vo.MyGroupVO; import work.soho.common.core.result.R; import work.soho.common.core.util.BeanUtils; import work.soho.common.core.util.StringUtils; import work.soho.common.data.upload.utils.UploadUtils; import java.time.LocalDateTime; import java.util.ArrayList; import java.util.List; import java.util.Optional; import java.util.stream.Collectors; /** * 群组客户端控制器 */ @Api(tags = "客户端群组客户端控制器") @Log4j2 @RestController @RequiredArgsConstructor @RequestMapping("/chat/chat/chat-group") public class ClientChatGroupController { private final ChatUserService chatUserService; private final ChatGroupService chatGroupService; private final ChatGroupUserService chatGroupUserService; private final ChatGroupApplyService chatGroupApplyService; private final ChatUserNoticeService chatUserNoticeService; private final ChatSessionService chatSessionService; private final ChatSessionUserService chatSessionUserService; private final ChatService chatService; private final ChatGroupQuestionsService chatGroupQuestionsService; /** * 群组列表/群组搜索用接口 * * @param chatGroup * @param keyword * @param betweenCreatedTimeRequest * @param sohoUserDetails * @return */ @GetMapping("/list") public R<PageSerializable<GroupVO>> list(ChatGroup chatGroup,String keyword, BetweenCreatedTimeRequest betweenCreatedTimeRequest,@AuthenticationPrincipal SohoUserDetails sohoUserDetails) { LambdaQueryWrapper<ChatGroup> lqw = new LambdaQueryWrapper<ChatGroup>(); //关键字搜索 if(StringUtils.isNotBlank(keyword)) { lqw.like(ChatGroup::getTitle, keyword + "%"); lqw.or().like(ChatGroup::getId, keyword); } lqw.eq(chatGroup.getId() != null, ChatGroup::getId ,chatGroup.getId()); lqw.like(StringUtils.isNotBlank(chatGroup.getTitle()),ChatGroup::getTitle ,chatGroup.getTitle()); lqw.eq(chatGroup.getType() != null, ChatGroup::getType ,chatGroup.getType()); lqw.eq(chatGroup.getMasterChatUid() != null, ChatGroup::getMasterChatUid ,chatGroup.getMasterChatUid()); lqw.like(StringUtils.isNotBlank(chatGroup.getAvatar()),ChatGroup::getAvatar ,chatGroup.getAvatar()); lqw.like(StringUtils.isNotBlank(chatGroup.getIntroduction()),ChatGroup::getIntroduction ,chatGroup.getIntroduction()); lqw.like(StringUtils.isNotBlank(chatGroup.getProclamation()),ChatGroup::getProclamation ,chatGroup.getProclamation()); lqw.eq(chatGroup.getUpdatedTime() != null, ChatGroup::getUpdatedTime ,chatGroup.getUpdatedTime()); lqw.ge(betweenCreatedTimeRequest!=null && betweenCreatedTimeRequest.getStartTime() != null, ChatGroup::getCreatedTime, betweenCreatedTimeRequest.getStartTime()); lqw.lt(betweenCreatedTimeRequest!=null && betweenCreatedTimeRequest.getEndTime() != null, ChatGroup::getCreatedTime, betweenCreatedTimeRequest.getEndTime()); List<ChatGroup> list = chatGroupService.list(lqw); //计算已经加入的群 List<Long> resultGroupIds = list.stream().map(ChatGroup::getId).collect(Collectors.toList()); resultGroupIds.add(0l); LambdaQueryWrapper<ChatGroupUser> lambdaQueryWrapper1 = new LambdaQueryWrapper<>(); lambdaQueryWrapper1.in(ChatGroupUser::getGroupId, resultGroupIds) .eq(ChatGroupUser::getChatUid, sohoUserDetails.getId()); List<ChatGroupUser> groupUsers = chatGroupUserService.list(lambdaQueryWrapper1); List<GroupVO> result = new ArrayList<>(); list.forEach(item->{ GroupVO chatGroupVO = BeanUtils.copy(item, GroupVO.class); Optional<ChatGroupUser> optional = groupUsers.stream().filter(u->{return u.getGroupId().equals(item.getId());}).findFirst(); chatGroupVO.setInGroup(optional.isPresent()); result.add(chatGroupVO); }); return R.success(new PageSerializable<>(result)); } /** * 我的群列表 * * @param chatGroup * @param betweenCreatedTimeRequest * @return */ @GetMapping("/my-list") public R<PageSerializable<MyGroupVO>> myList(ChatGroup chatGroup, BetweenCreatedTimeRequest betweenCreatedTimeRequest,@AuthenticationPrincipal SohoUserDetails sohoUserDetails) { LambdaQueryWrapper<ChatGroupUser> lambdaQueryWrapper = new LambdaQueryWrapper<>(); lambdaQueryWrapper.eq(ChatGroupUser::getChatUid, sohoUserDetails.getId()); List<ChatGroupUser> groupUsers = chatGroupUserService.list(lambdaQueryWrapper); List<Long> groupIds = groupUsers.stream().map(ChatGroupUser::getGroupId).collect(Collectors.toList()); groupIds.add(0l); LambdaQueryWrapper<ChatGroup> lqw = new LambdaQueryWrapper<ChatGroup>(); lqw.in(ChatGroup::getId, groupIds); List<ChatGroup> list = chatGroupService.list(lqw); //计算已经加入的群 List<MyGroupVO> result = new ArrayList<>(); list.forEach(item->{ MyGroupVO chatGroupVO = BeanUtils.copy(item, MyGroupVO.class); Optional<ChatGroupUser> optional = groupUsers.stream().filter(u->{return u.getGroupId().equals(item.getId());}).findFirst(); if(optional.isPresent()) { chatGroupVO.setNotesName(optional.get().getNotesName()); chatGroupVO.setIsAdmin(optional.get().getIsAdmin()); if(chatGroupVO.getIsAdmin() == 0 && item.getMasterChatUid().equals(sohoUserDetails.getId())) { chatGroupVO.setIsAdmin(1); } } result.add(chatGroupVO); }); return R.success(new PageSerializable<>(result)); } /** * 创建群组 * * @param createGroupReq * @return */ @PostMapping("") public R<ChatSession> create(@RequestBody CreateGroupReq createGroupReq, @AuthenticationPrincipal SohoUserDetails sohoUserDetails) { ChatGroup chatGroup = new ChatGroup(); chatGroup.setTitle(createGroupReq.getTitle()); chatGroup.setMasterChatUid(sohoUserDetails.getId()); chatGroup.setUpdatedTime(LocalDateTime.now()); chatGroup.setCreatedTime(LocalDateTime.now()); List<Long> chatUserIds = createGroupReq.getChatUserIds(); chatGroupService.createGroup(chatGroup, chatUserIds); //同步群组数据到会话 LambdaQueryWrapper<ChatGroupUser> lambdaQueryWrapper = new LambdaQueryWrapper<>(); lambdaQueryWrapper.eq(ChatGroupUser::getGroupId, chatGroup.getId()); List<ChatGroupUser> chatGroupUsers = chatGroupUserService.list(lambdaQueryWrapper); //创建会话信息 ChatSession chat