基于SpringBoot+Vue开发的个人博客系统全栈个人博客系统

package com.aurora.service.impl; import com.alibaba.fastjson.JSON; import com.aurora.model.dto.*; import com.aurora.entity.Article; import com.aurora.entity.ArticleTag; import com.aurora.entity.Category; import com.aurora.entity.Tag; import com.aurora.enums.FileExtEnum; import com.aurora.enums.FilePathEnum; import com.aurora.exception.BizException; import com.aurora.mapper.ArticleMapper; import com.aurora.mapper.ArticleTagMapper; import com.aurora.mapper.CategoryMapper; import com.aurora.mapper.TagMapper; import com.aurora.service.ArticleService; import com.aurora.service.ArticleTagService; import com.aurora.service.RedisService; import com.aurora.service.TagService; import com.aurora.strategy.context.SearchStrategyContext; import com.aurora.strategy.context.UploadStrategyContext; import com.aurora.util.BeanCopyUtil; import com.aurora.util.PageUtil; import com.aurora.util.UserUtil; import com.aurora.model.vo.*; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import lombok.SneakyThrows; import org.springframework.amqp.core.Message; import org.springframework.amqp.core.MessageProperties; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.io.ByteArrayInputStream; import java.time.LocalDateTime; import java.util.*; import java.util.concurrent.CompletableFuture; import java.util.stream.Collectors; import static com.aurora.constant.RabbitMQConstant.SUBSCRIBE_EXCHANGE; import static com.aurora.constant.RedisConstant.*; import static com.aurora.enums.ArticleStatusEnum.*; import static com.aurora.enums.StatusCodeEnum.ARTICLE_ACCESS_FAIL; @Service public class ArticleServiceImpl extends ServiceImpl<ArticleMapper, Article> implements ArticleService { @Autowired private ArticleMapper articleMapper; @Autowired private ArticleTagMapper articleTagMapper; @Autowired private CategoryMapper categoryMapper; @Autowired private TagMapper tagMapper; @Autowired private TagService tagService; @Autowired private ArticleTagService articleTagService; @Autowired private RedisService redisService; @Autowired private RabbitTemplate rabbitTemplate; @Autowired private UploadStrategyContext uploadStrategyContext; @Autowired private SearchStrategyContext searchStrategyContext; @SneakyThrows @Override public TopAndFeaturedArticlesDTO listTopAndFeaturedArticles() { List<ArticleCardDTO> articleCardDTOs = articleMapper.listTopAndFeaturedArticles(); if (articleCardDTOs.size() == 0) { return new TopAndFeaturedArticlesDTO(); } else if (articleCardDTOs.size() > 3) { articleCardDTOs = articleCardDTOs.subList(0, 3); } TopAndFeaturedArticlesDTO topAndFeaturedArticlesDTO = new TopAndFeaturedArticlesDTO(); topAndFeaturedArticlesDTO.setTopArticle(articleCardDTOs.get(0)); articleCardDTOs.remove(0); topAndFeaturedArticlesDTO.setFeaturedArticles(articleCardDTOs); return topAndFeaturedArticlesDTO; } @SneakyThrows @Override public PageResultDTO<ArticleCardDTO> listArticles() { LambdaQueryWrapper<Article> queryWrapper = new LambdaQueryWrapper<Article>() .eq(Article::getIsDelete, 0) .in(Article::getStatus, 1, 2); CompletableFuture<Integer> asyncCount = CompletableFuture.supplyAsync(() -> articleMapper.selectCount(queryWrapper)); List<ArticleCardDTO> articles = articleMapper.listArticles(PageUtil.getLimitCurrent(), PageUtil.getSize()); return new PageResultDTO<>(articles, asyncCount.get()); } @SneakyThrows @Override public PageResultDTO<ArticleCardDTO> listArticlesByCategoryId(Integer categoryId) { LambdaQueryWrapper<Article> queryWrapper = new LambdaQueryWrapper<Article>().eq(Article::getCategoryId, categoryId); CompletableFuture<Integer> asyncCount = CompletableFuture.supplyAsync(() -> articleMapper.selectCount(queryWrapper)); List<ArticleCardDTO> articles = articleMapper.getArticlesByCategoryId(PageUtil.getLimitCurrent(), PageUtil.getSize(), categoryId); return new PageResultDTO<>(articles, asyncCount.get()); } @SneakyThrows @Override public ArticleDTO getArticleById(Integer articleId) { Article articleForCheck = articleMapper.selectOne(new LambdaQueryWrapper<Article>().eq(Article::getId, articleId)); if (Objects.isNull(articleForCheck)) { return null; } if (articleForCheck.getStatus().equals(2)) { Boolean isAccess; try { isAccess = redisService.sIsMember(ARTICLE_ACCESS + UserUtil.getUserDetailsDTO().getId(), articleId); } catch (Exception exception) { throw new BizException(ARTICLE_ACCESS_FAIL); } if (isAccess.equals(false)) { throw new BizException(ARTICLE_ACCESS_FAIL); } } updateArticleViewsCount(articleId); CompletableFuture<ArticleDTO> asyncArticle = CompletableFuture.supplyAsync(() -> articleMapper.getArticleById(articleId)); CompletableFuture<ArticleCardDTO> asyncPreArticle = CompletableFuture.supplyAsync(() -> { ArticleCardDTO preArticle = articleMapper.getPreArticleById(articleId); if (Objects.isNull(preArticle)) { preArticle = articleMapper.getLastArticle(); } return preArticle; }); CompletableFuture<ArticleCardDTO> asyncNextArticle = CompletableFuture.supplyAsync(() -> { ArticleCardDTO nextArticle = articleMapper.getNextArticleById(articleId); if (Objects.isNull(nextArticle)) { nextArticle = articleMapper.getFirstArticle(); } return nextArticle; }); ArticleDTO article = asyncArticle.get(); if (Objects.isNull(article)) { return null; } Double score = redisService.zScore(ARTICLE_VIEWS_COUNT, articleId); if (Objects.nonNull(score)) { article.setViewCount(score.intValue()); } article.setPreArticleCard(asyncPreArticle.get()); article.setNextArticleCard(asyncNextArticle.get()); return article; } @Override public void accessArticle(ArticlePasswordVO articlePasswordVO) { Article article = articleMapper.selectOne(new LambdaQueryWrapper<Article>().eq(Article::getId, articlePasswordVO.getArticleId())); if (Objects.isNull(article)) { throw new BizException("文章不存在"); } if (article.getPassword().equals(articlePasswordVO.getArticlePassword())) { redisService.sAdd(ARTICLE_ACCESS + UserUtil.getUserDetailsDTO().getId(), articlePasswordVO.getArticleId()); } else { throw new BizException("密码错误"); } } @SneakyThrows @Override public PageResultDTO<ArticleCardDTO> listArticlesByTagId(Integer tagId) { LambdaQueryWrapper<ArticleTag> queryWrapper = new LambdaQueryWrapper<ArticleTag>().eq(ArticleTag::getTagId, tagId); CompletableFuture<Integer> asyncCount = CompletableFuture.supplyAsync(() -> articleTagMapper.selectCount(queryWrapper)); List<ArticleCardDTO> articles = articleMapper.listArticlesByTagId(PageUtil.getLimitCurrent(), PageUtil.getSize(), tagId); return new PageResultDTO<>(articles, asyncCount.get()); } @SneakyThrows @Override public PageResultDTO<ArchiveDTO> listArchives() { LambdaQueryWrapper<Article> queryWrapper = new LambdaQueryWrapper<Article>().eq(Article::getIsDelete, 0).eq(Article::getStatu