基于Springboot + Vue3 开发的前后端分离的个人博客系统源码+数据库

package com.ican.service.impl; import cn.dev33.satoken.stp.StpUtil; import cn.hutool.core.date.DateUtil; import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ican.entity.*; import com.ican.mapper.ArticleMapper; import com.ican.mapper.CommentMapper; import com.ican.mapper.TalkMapper; import com.ican.mapper.UserMapper; import com.ican.model.dto.CheckDTO; import com.ican.model.dto.CommentDTO; import com.ican.model.dto.ConditionDTO; import com.ican.model.dto.MailDTO; import com.ican.model.vo.*; import com.ican.service.CommentService; import com.ican.service.RedisService; import com.ican.service.SiteConfigService; import com.ican.utils.HTMLUtils; import com.ican.utils.PageUtils; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import org.springframework.util.StringUtils; import java.util.*; import java.util.concurrent.CompletableFuture; import java.util.stream.Collectors; import static com.ican.constant.CommonConstant.*; import static com.ican.constant.MqConstant.*; import static com.ican.constant.RedisConstant.COMMENT_LIKE_COUNT; import static com.ican.enums.CommentTypeEnum.*; /** * 评论业务接口实现类 * * @author ican */ @Service public class CommentServiceImpl extends ServiceImpl<CommentMapper, Comment> implements CommentService { @Value("${blog.url}") private String websiteUrl; @Autowired private ArticleMapper articleMapper; @Autowired private TalkMapper talkMapper; @Autowired private CommentMapper commentMapper; @Autowired private UserMapper userMapper; @Autowired private SiteConfigService siteConfigService; @Autowired private RedisService redisService; @Autowired private RabbitTemplate rabbitTemplate; @Override public PageResult<CommentBackVO> listCommentBackVO(ConditionDTO condition) { // 查询后台评论数量 Long count = commentMapper.countComment(condition); if (count == 0) { return new PageResult<>(); } // 查询后台评论集合 List<CommentBackVO> commentBackVOList = commentMapper.listCommentBackVO(PageUtils.getLimit(), PageUtils.getSize(), condition); return new PageResult<>(commentBackVOList, count); } @Override public void addComment(CommentDTO comment) { // 校验评论参数 verifyComment(comment); SiteConfig siteConfig = siteConfigService.getSiteConfig(); Integer commentCheck = siteConfig.getCommentCheck(); // 过滤标签 comment.setCommentContent(HTMLUtils.filter(comment.getCommentContent())); Comment newComment = Comment.builder() .fromUid(StpUtil.getLoginIdAsInt()) .toUid(comment.getToUid()) .typeId(comment.getTypeId()) .commentType(comment.getCommentType()) .parentId(comment.getParentId()) .replyId(comment.getReplyId()) .commentContent(comment.getCommentContent()) .isCheck(commentCheck.equals(FALSE) ? TRUE : FALSE) .build(); // 保存评论 commentMapper.insert(newComment); // 查询评论用户昵称 String fromNickname = userMapper.selectOne(new LambdaQueryWrapper<User>() .select(User::getNickname) .eq(User::getId, StpUtil.getLoginIdAsInt())) .getNickname(); // 通知用户 if (siteConfig.getEmailNotice().equals(TRUE)) { CompletableFuture.runAsync(() -> { System.out.println("你好"); notice(newComment, fromNickname); }); } } @Override public void updateCommentCheck(CheckDTO check) { // 修改评论审核状态 List<Comment> commentList = check.getIdList().stream().map(id -> Comment.builder().id(id).isCheck(check.getIsCheck()).build()).collect(Collectors.toList()); this.updateBatchById(commentList); } @Override public List<RecentCommentVO> listRecentCommentVO() { return commentMapper.selectRecentComment(); } @Override public PageResult<CommentVO> listCommentVO(ConditionDTO condition) { // 查询父评论数量 Long count = commentMapper.selectCount(new LambdaQueryWrapper<Comment>() .eq(Objects.nonNull(condition.getTypeId()), Comment::getTypeId, condition.getTypeId()) .eq(Comment::getCommentType, condition.getCommentType()) .eq(Comment::getIsCheck, TRUE).isNull(Comment::getParentId)); if (count == 0) { return new PageResult<>(); } // 分页查询父评论 List<CommentVO> commentVOList = commentMapper.selectParentComment(PageUtils.getLimit(), PageUtils.getSize(), condition); if (CollectionUtils.isEmpty(commentVOList)) { return new PageResult<>(); } // 评论点赞 Map<String, Integer> likeCountMap = redisService.getHashAll(COMMENT_LIKE_COUNT); // 父评论id集合 List<Integer> parentCommentIdList = commentVOList.stream().map(CommentVO::getId).collect(Collectors.toList()); // 分组查询每组父评论下的子评论前三条 List<ReplyVO> replyVOList = commentMapper.selectReplyByParentIdList(parentCommentIdList); // 封装子评论点赞量 replyVOList.forEach(item -> item.setLikeCount(Optional.ofNullable(likeCountMap.get(item.getId().toString())).orElse(0))); // 根据父评论id生成对应子评论的Map Map<Integer, List<ReplyVO>> replyMap = replyVOList.stream().collect(Collectors.groupingBy(ReplyVO::getParentId)); // 父评论的回复数量 List<ReplyCountVO> replyCountList = commentMapper.selectReplyCountByParentId(parentCommentIdList); // 转换Map Map<Integer, Integer> replyCountMap = replyCountList.stream().collect(Collectors.toMap(ReplyCountVO::getCommentId, ReplyCountVO::getReplyCount)); // 封装评论数据 commentVOList.forEach(item -> { item.setLikeCount(Optional.ofNullable(likeCountMap.get(item.getId().toString())).orElse(0)); item.setReplyVOList(replyMap.get(item.getId())); item.setReplyCount(Optional.ofNullable(replyCountMap.get(item.getId())).orElse(0)); }); return new PageResult<>(commentVOList, count); } @Override public List<ReplyVO> listReply(Integer commentId) { // 分页查询子评论 List<ReplyVO> replyVOList = commentMapper.selectReplyByParentId(PageUtils.getLimit(), PageUtils.getSize(), commentId); // 子评论点赞Map Map<String, Integer> likeCountMap = redisService.getHashAll(COMMENT_LIKE_COUNT); replyVOList.forEach(item -> item.setLikeCount(likeCountMap.get(item.getId().toString()))); return replyVOList; } private void verifyComment(CommentDTO comment) { if (comment.getCommentType().equals(ARTICLE.getType())) { Article article = articleMapper.selectOne(new LambdaQueryWrapper<Article>().select(Article::getId).eq(Article::getId, comment.getTypeId())); Assert.notNull(article, "文章不存在"); } if (comment.getCommentType().equals(TALK.getType())) { Talk talk = talkMapper.selectOne(new LambdaQueryWrapper<Talk>().select(Talk::getId).eq(Talk::getId, comment.getTypeId())); Assert.notNull(talk, "说说不存在"); } // 评论为子评论，判断回复的评论和用户是否存在 Optional.ofNullable(comment.getParentId()).i