基于SpringBoot的API管理平台源代码+数据库，以项目的形式管理API文档，可以进行API的编辑、测试、Mock等操作

package top.wshape1.shiziapi.project.service.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.PageDTO; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import jakarta.annotation.Resource; import lombok.extern.slf4j.Slf4j; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.context.annotation.Lazy; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.StringUtils; import org.springframework.validation.annotation.Validated; import org.springframework.web.multipart.MultipartFile; import top.wshape1.shiziapi.common.constant.BizCodeEnum; import top.wshape1.shiziapi.common.constant.RedisConstant; import top.wshape1.shiziapi.common.domain.CommonUser; import top.wshape1.shiziapi.common.domain.ProjectSearch; import top.wshape1.shiziapi.common.domain.to.ProjectUserIdTo; import top.wshape1.shiziapi.common.domain.vo.PageVo; import top.wshape1.shiziapi.common.exception.CustomException; import top.wshape1.shiziapi.common.utils.R; import top.wshape1.shiziapi.project.config.RabbitMqConfig; import top.wshape1.shiziapi.project.domain.Member; import top.wshape1.shiziapi.project.domain.Project; import top.wshape1.shiziapi.project.domain.ProjectMembers; import top.wshape1.shiziapi.project.domain.vo.ProjectVo; import top.wshape1.shiziapi.project.feign.MessageFeignService; import top.wshape1.shiziapi.project.feign.ThirdPartyFeignService; import top.wshape1.shiziapi.project.feign.UaaFeignService; import top.wshape1.shiziapi.project.mapper.ProjectMapper; import top.wshape1.shiziapi.project.mapper.ProjectMembersMapper; import top.wshape1.shiziapi.project.service.DocumentService; import top.wshape1.shiziapi.project.service.LikeService; import top.wshape1.shiziapi.project.service.ProjectService; import top.wshape1.shiziapi.project.service.ReadService; import top.wshape1.shiziapi.project.util.HotProjectUtil; import java.util.*; import java.util.concurrent.CompletableFuture; import java.util.concurrent.ThreadPoolExecutor; /** * @author Wshape1 * @description 针对表【t_project】的数据库操作Service实现 * @since 2023-09-12 15:40:51 */ @Service @Slf4j public class ProjectServiceImpl extends ServiceImpl<ProjectMapper, Project> implements ProjectService { @Resource private ProjectMembersMapper projectMembersMapper; @Resource private ThirdPartyFeignService thirdPartyFeignService; @Resource private UaaFeignService uaaFeignService; @Resource private MessageFeignService messageFeignService; @Resource private ThreadPoolExecutor threadPoolExecutor; @Resource @Lazy private DocumentService documentService; @Resource private LikeService likeService; @Resource private ReadService readService; @Resource private RabbitTemplate rabbitTemplate; @Resource private RedisTemplate<String, Object> redisTemplate; @Override public PageVo projectListPageMy(Long id, Long page, Long limit, String keyword) { Page<Project> qPage = this.page(PageDTO.of(page, limit), new LambdaQueryWrapper<Project>() .eq(Project::getUserId, id) .like(StringUtils.hasText(keyword), Project::getName, keyword) .orderByDesc(Project::getCreateTime) ); return new PageVo(qPage); } @Override public PageVo projectListPageHis(Long id, Long page, Long limit, String keyword) { List<Long> ids = projectMembersMapper.selectParticipatingProjectIds(id); Page<Project> qPage = PageDTO.of(page, limit); if (ids != null && !ids.isEmpty()) { qPage = this.page(qPage, new LambdaQueryWrapper<Project>() .in(Project::getId, ids) .like(StringUtils.hasText(keyword), Project::getName, keyword) .orderByDesc(Project::getCreateTime) ); } return new PageVo(qPage); } @Transactional @Override public void createProject(Long userId, ProjectVo projectVo) { Project project = new Project(); project.setUserId(userId); project.setName(projectVo.getName()); project.setDescription(projectVo.getDescription()); project.setIsPrivate(projectVo.getIsPrivate()); Date date = new Date(); project.setCreateTime(date); project.setUpdateTime(date); int insert = getBaseMapper().insert(project); ProjectMembers projectMembers = new ProjectMembers(); projectMembers.setId(project.getId()); projectMembers.setUserId(userId); projectMembers.setMembers("{}"); int insert1 = projectMembersMapper.insert(projectMembers); if (insert > 0 && insert1 > 0) // 是公共的，存入elastic if (projectVo.getIsPrivate() == 0) { CompletableFuture.runAsync(() -> { ProjectSearch projectSearch = new ProjectSearch(); projectSearch.setId(project.getId()); projectSearch.setName(project.getName()); projectSearch.setDescription(project.getDescription()); projectSearch.setCoverUrl(project.getCoverUrl()); projectSearch.setCreateTime(project.getCreateTime()); projectSearch.setUpdateTime(project.getUpdateTime()); projectSearch.setLikeCount(0L); projectSearch.setReadCount(0L); R<String> userNameById = uaaFeignService.getUserNameById(userId); if (userNameById.isSuccessful()) { projectSearch.setUserName(userNameById.getData()); } // searchFeignService.save(projectSearch); // 发送rabbit消息给search服务 projectSearch.setOperate(1); rabbitTemplate.convertAndSend( RabbitMqConfig.SHIZIAPI_PROJECT_ELASTIC_EXCHANGE, RabbitMqConfig.SHIZIAPI_PROJECT_ELASTIC_BINDING, projectSearch ); }, threadPoolExecutor); } } @Override public void modifyProject(Long userId, @Validated ProjectVo projectVo, MultipartFile file) { Project one = this.getById(projectVo.getId()); if (one == null) { throw new CustomException(R.instance(BizCodeEnum.PROJECT_NOT_EXIST_ERROR)); } if (!one.getUserId().equals(userId)) { ProjectMembers projectMembers = projectMembersMapper.selectById(projectVo.getId()); if (projectMembers.getMember(userId) == null) { throw new CustomException(R.instance(BizCodeEnum.PROJECT_PERMISSION_ERROR)); } } LambdaUpdateWrapper<Project> updateWrapper = new LambdaUpdateWrapper<>(); Date updateTime = new Date(); updateWrapper .eq(Project::getId, projectVo.getId()) .set(Project::getName, projectVo.getName()) .set(Project::getDescription, projectVo.getDescription()) .set(Project::getIsPrivate, projectVo.getIsPrivate()) .set(Project::getUpdateTime, updateTime); String coverUrl = one.getCoverUrl(); if (file != null && !file.isEmpty()) { // TODO 上传头像应该异步 String[] split = Objects.requireNonNull(file.getOriginalFilename()).split("\\."); String suffix = split[sp