• 仿牛客网项目---帖子详情功能的实现

    这篇文章主要讲讲帖子详情功能。其实帖子详情功能简单来说就是你点进去可以看到文章，这就叫帖子详情功能。那接下来我讲讲我的这个项目是如何实现这个功能的。

    首先写DAO层。

    1. @Mapper
    2. public interface DiscussPostMapper {
    3.  
    4.     List selectDiscussPosts(int userId, int offset, int limit, int orderMode);
    5.     //查询讨论帖子列表的方法，根据给定的用户ID、偏移量、限制数量和排序方式来查询讨论帖子
    6.  
    7.     int selectDiscussPostRows(@Param("userId") int userId);
    8.     //查询讨论帖子的总行数的方法，根据给定的用户ID来查询该用户发表的讨论帖子总数
    9.  
    10.     int insertDiscussPost(DiscussPost discussPost);
    11.     //插入一条讨论帖子记录的方法，将给定的讨论帖子对象插入到数据库中
    12.  
    13.     DiscussPost selectDiscussPostById(int id);
    14.     //根据给定的帖子ID查询讨论帖子的方法，返回对应ID的讨论帖子对象
    15.  
    16.     int updateCommentCount(int id, int commentCount);
    17.     //更新讨论帖子的评论数量的方法，根据给定的帖子ID更新评论数量
    18.  
    19.     int updateType(int id, int type);
    20.     //更新讨论帖子的类型的方法，根据给定的帖子ID更新类型
    21.  
    22.     int updateStatus(int id, int status);
    23.     //更新讨论帖子的状态的方法，根据给定的帖子ID更新状态
    24.  
    25.     int updateScore(int id, double score);
    26.     //更新讨论帖子的评分的方法，根据给定的帖子ID更新评分
    27.  
    28. }

    再来写Service层。

    1.     @PostConstruct
    2.     public List findDiscussPosts(int userId, int offset, int limit, int orderMode) {
    3.         if (userId == 0 && orderMode == 1) {
    4.             return postListCache.get(offset + ":" + limit);
    5.         }
    6.  
    7.         logger.debug("load post list from DB.");
    8.         return discussPostMapper.selectDiscussPosts(userId, offset, limit, orderMode);
    9.     }
    10.  
    11.     public int findDiscussPostRows(int userId) {
    12.         if (userId == 0) {
    13.             return postRowsCache.get(userId);
    14.         }
    15.  
    16.         logger.debug("load post rows from DB.");
    17.         return discussPostMapper.selectDiscussPostRows(userId);
    18.     }
    19.  
    20.     public int addDiscussPost(DiscussPost post) {
    21.         if (post == null) {
    22.             throw new IllegalArgumentException("参数不能为空!");
    23.         }
    24.  
    25.         // 转义HTML标记
    26.         post.setTitle(HtmlUtils.htmlEscape(post.getTitle()));
    27.         post.setContent(HtmlUtils.htmlEscape(post.getContent()));
    28.         // 过滤敏感词
    29.         post.setTitle(sensitiveFilter.filter(post.getTitle()));
    30.         post.setContent(sensitiveFilter.filter(post.getContent()));
    31.  
    32.         return discussPostMapper.insertDiscussPost(post);
    33.     }
    34.  
    35.     public DiscussPost findDiscussPostById(int id) {
    36.         return discussPostMapper.selectDiscussPostById(id);
    37.     }
    38.  
    39.     public int updateCommentCount(int id, int commentCount) {
    40.         return discussPostMapper.updateCommentCount(id, commentCount);
    41.     }
    42.  
    43.     public int updateType(int id, int type) {
    44.         return discussPostMapper.updateType(id, type);
    45.     }
    46.  
    47.     public int updateStatus(int id, int status) {
    48.         return discussPostMapper.updateStatus(id, status);
    49.     }
    50.  
    51.     public int updateScore(int id, double score) {
    52.         return discussPostMapper.updateScore(id, score);
    53.     }

    service层的代码是一个帖子（DiscussPost）的服务类，提供了一些操作帖子的方法，并使用了缓存来提高性能。这段代码有点长，所以读起来有点费力，我讲一下我对这些代码的理解吧。

    • findDiscussPosts() 方法用于查询帖子列表。如果传入的用户ID为0且排序方式为1（orderMode == 1），则直接从缓存中获取对应的结果；否则，调用数据库查询方法从数据库中获取结果。
    • findDiscussPostRows() 方法用于查询帖子总数。如果传入的用户ID为0，则直接从缓存中获取对应的结果；否则，调用数据库查询方法从数据库中获取结果。
    • addDiscussPost() 方法用于添加帖子。在添加之前，会对帖子的标题和内容进行转义HTML标记和敏感词过滤的处理，然后调用数据库操作方法将帖子插入到数据库中，并返回插入的结果。
    • 其他方法如 findDiscussPostById()、updateCommentCount()、updateType()、updateStatus()、updateScore() 都是调用数据库操作方法来更新或查询帖子的相关信息。

    service层大概就是这些，虽然说比较长，但是还是很容易懂的，controller层更加长。

    最后写controller层。

    1. @Controller
    2. @RequestMapping("/discuss")
    3. public class DiscussPostController implements CommunityConstant {
    4.  
    5.     @RequestMapping(path = "/add", method = RequestMethod.POST)
    6.     @ResponseBody
    7.     public String addDiscussPost(String title, String content) {
    8.         User user = hostHolder.getUser();
    9.         if (user == null) {
    10.             return CommunityUtil.getJSONString(403, "你还没有登录哦!");
    11.         }
    12.  
    13.         DiscussPost post = new DiscussPost();
    14.         post.setUserId(user.getId());
    15.         post.setTitle(title);
    16.         post.setContent(content);
    17.         post.setCreateTime(new Date());
    18.         discussPostService.addDiscussPost(post);
    19.  
    20.         // 触发发帖事件
    21.         Event event = new Event()
    22.                 .setTopic(TOPIC_PUBLISH)
    23.                 .setUserId(user.getId())
    24.                 .setEntityType(ENTITY_TYPE_POST)
    25.                 .setEntityId(post.getId());
    26.         eventProducer.fireEvent(event);
    27.  
    28.         // 计算帖子分数
    29.         String redisKey = RedisKeyUtil.getPostScoreKey();
    30.         redisTemplate.opsForSet().add(redisKey, post.getId());
    31.  
    32.         // 报错的情况,将来统一处理.
    33.         return CommunityUtil.getJSONString(0, "发布成功!");
    34.     }
    35.  
    36.     @RequestMapping(path = "/detail/{discussPostId}", method = RequestMethod.GET)
    37.     public String getDiscussPost(@PathVariable("discussPostId") int discussPostId, Model model, Page page) {
    38.         // 帖子
    39.         DiscussPost post = discussPostService.findDiscussPostById(discussPostId);
    40.         model.addAttribute("post", post);
    41.         // 作者
    42.         User user = userService.findUserById(post.getUserId());
    43.         model.addAttribute("user", user);
    44.         // 点赞数量
    45.         long likeCount = likeService.findEntityLikeCount(ENTITY_TYPE_POST, discussPostId);
    46.         model.addAttribute("likeCount", likeCount);
    47.         // 点赞状态
    48.         int likeStatus = hostHolder.getUser() == null ? 0 :
    49.                 likeService.findEntityLikeStatus(hostHolder.getUser().getId(), ENTITY_TYPE_POST, discussPostId);
    50.         model.addAttribute("likeStatus", likeStatus);
    51.  
    52.         // 评论分页信息
    53.         page.setLimit(5);
    54.         page.setPath("/discuss/detail/" + discussPostId);
    55.         page.setRows(post.getCommentCount());
    56.  
    57.         // 评论: 给帖子的评论
    58.         // 回复: 给评论的评论
    59.         // 评论列表
    60.         List commentList = commentService.findCommentsByEntity(
    61.                 ENTITY_TYPE_POST, post.getId(), page.getOffset(), page.getLimit());
    62.         // 评论VO列表
    63.         List> commentVoList = new ArrayList<>();
    64.         if (commentList != null) {
    65.             for (Comment comment : commentList) {
    66.                 // 评论VO
    67.                 Map commentVo = new HashMap<>();
    68.                 // 评论
    69.                 commentVo.put("comment", comment);
    70.                 // 作者
    71.                 commentVo.put("user", userService.findUserById(comment.getUserId()));
    72.                 // 点赞数量
    73.                 likeCount = likeService.findEntityLikeCount(ENTITY_TYPE_COMMENT, comment.getId());
    74.                 commentVo.put("likeCount", likeCount);
    75.                 // 点赞状态
    76.                 likeStatus = hostHolder.getUser() == null ? 0 :
    77.                         likeService.findEntityLikeStatus(hostHolder.getUser().getId(), ENTITY_TYPE_COMMENT, comment.getId());
    78.                 commentVo.put("likeStatus", likeStatus);
    79.  
    80.                 // 回复列表
    81.                 List replyList = commentService.findCommentsByEntity(
    82.                         ENTITY_TYPE_COMMENT, comment.getId(), 0, Integer.MAX_VALUE);
    83.                 // 回复VO列表
    84.                 List> replyVoList = new ArrayList<>();
    85.                 if (replyList != null) {
    86.                     for (Comment reply : replyList) {
    87.                         Map replyVo = new HashMap<>();
    88.                         // 回复
    89.                         replyVo.put("reply", reply);
    90.                         // 作者
    91.                         replyVo.put("user", userService.findUserById(reply.getUserId()));
    92.                         // 回复目标
    93.                         User target = reply.getTargetId() == 0 ? null : userService.findUserById(reply.getTargetId());
    94.                         replyVo.put("target", target);
    95.                         // 点赞数量
    96.                         likeCount = likeService.findEntityLikeCount(ENTITY_TYPE_COMMENT, reply.getId());
    97.                         replyVo.put("likeCount", likeCount);
    98.                         // 点赞状态
    99.                         likeStatus = hostHolder.getUser() == null ? 0 :
    100.                                 likeService.findEntityLikeStatus(hostHolder.getUser().getId(), ENTITY_TYPE_COMMENT, reply.getId());
    101.                         replyVo.put("likeStatus", likeStatus);
    102.  
    103.                         replyVoList.add(replyVo);
    104.                     }
    105.                 }
    106.                 commentVo.put("replys", replyVoList);
    107.  
    108.                 // 回复数量
    109.                 int replyCount = commentService.findCommentCount(ENTITY_TYPE_COMMENT, comment.getId());
    110.                 commentVo.put("replyCount", replyCount);
    111.  
    112.                 commentVoList.add(commentVo);
    113.             }
    114.         }
    115.  
    116.         model.addAttribute("comments", commentVoList);
    117.  
    118.         return "/site/discuss-detail";
    119.     }
    120.  
    121.     // 置顶
    122.     @RequestMapping(path = "/top", method = RequestMethod.POST)
    123.     @ResponseBody
    124.     public String setTop(int id) {
    125.         discussPostService.updateType(id, 1);
    126.  
    127.         // 触发发帖事件
    128.         Event event = new Event()
    129.                 .setTopic(TOPIC_PUBLISH)
    130.                 .setUserId(hostHolder.getUser().getId())
    131.                 .setEntityType(ENTITY_TYPE_POST)
    132.                 .setEntityId(id);
    133.         eventProducer.fireEvent(event);
    134.  
    135.         return CommunityUtil.getJSONString(0);
    136.     }
    137.  
    138.     // 加精
    139.     @RequestMapping(path = "/wonderful", method = RequestMethod.POST)
    140.     @ResponseBody
    141.     public String setWonderful(int id) {
    142.         discussPostService.updateStatus(id, 1);
    143.  
    144.         // 触发发帖事件
    145.         Event event = new Event()
    146.                 .setTopic(TOPIC_PUBLISH)
    147.                 .setUserId(hostHolder.getUser().getId())
    148.                 .setEntityType(ENTITY_TYPE_POST)
    149.                 .setEntityId(id);
    150.         eventProducer.fireEvent(event);
    151.  
    152.         // 计算帖子分数
    153.         String redisKey = RedisKeyUtil.getPostScoreKey();
    154.         redisTemplate.opsForSet().add(redisKey, id);
    155.  
    156.         return CommunityUtil.getJSONString(0);
    157.     }
    158.  
    159.     // 删除
    160.     @RequestMapping(path = "/delete", method = RequestMethod.POST)
    161.     @ResponseBody
    162.     public String setDelete(int id) {
    163.         discussPostService.updateStatus(id, 2);
    164.  
    165.         // 触发删帖事件
    166.         Event event = new Event()
    167.                 .setTopic(TOPIC_DELETE)
    168.                 .setUserId(hostHolder.getUser().getId())
    169.                 .setEntityType(ENTITY_TYPE_POST)
    170.                 .setEntityId(id);
    171.         eventProducer.fireEvent(event);
    172.  
    173.         return CommunityUtil.getJSONString(0);
    174.     }
    175.  
    176. }

    这段代码是一个控制器类，处理与帖子相关的请求。 

    首先是 addDiscussPost() 方法，用于处理发布帖子的请求。在方法中首先判断用户是否登录，如果未登录则返回相应的提示信息。然后根据传入的参数创建一个 DiscussPost 对象，并设置相应的属性。接下来调用 discussPostService.addDiscussPost(post) 方法将帖子插入到数据库中。之后触发一个发帖事件，并计算帖子的分数。最后返回一个 JSON 格式的发布成功信息。

    接下来是 getDiscussPost() 方法，用于获取帖子详情的请求。首先根据传入的帖子ID调用 discussPostService.findDiscussPostById(discussPostId) 方法获取帖子对象，并将帖子对象添加到 Model 中。然后获取帖子的作者、点赞数量和点赞状态，并将它们添加到 Model 中。接着设置评论的分页信息，并调用 commentService.findCommentsByEntity() 方法获取帖子的评论列表。通过遍历评论列表，将每个评论及其相关信息封装成一个评论VO（Map），并将评论VO添加到评论VO列表中。对于每个评论，还会获取其回复列表，并将每个回复及其相关信息封装成一个回复VO（Map），再将回复VO添加到回复VO列表中。最后将评论VO列表添加到 Model 中，并返回一个指向帖子详情页面的视图。

    接下来是 setTop() 方法，用于置顶帖子的请求。在方法中调用 discussPostService.updateType(id, 1) 方法将帖子的类型设置为置顶。然后触发一个发帖事件，并返回一个 JSON 格式的成功信息。

    最后是 setDelete() 方法，用于删除帖子的请求。在方法中调用 discussPostService.updateStatus(id, 2) 方法将帖子的状态设置为删除。然后触发一个删帖事件，并返回一个 JSON 格式的成功信息。

    其实对于帖子详情这里并不算太重要，我觉得好好看看，知道有这么一回事儿就行，不需要刻意的去背，背的话其实也用不到，但是你确实需要知道这么一回事儿。

  • 相关阅读:
    split() 函数实现多条件转为数据为数组类型
    linux批量杀进程命令
    C专家编程 第8章 为什么程序员无法分清万圣节和圣诞节 8.6 不需要按回车就能得到一个字符
    枚举--用枚举封装一个工具类
    Apache Hop Transforms Samples【持续完善中】
    用 Three.js 创建一个酷炫且真实的地球
    【HTTPS】HTTPS解决了什么问题、HTTPS的加密过程和方式、SSL/TLS、中间人攻击等重点知识汇总
    SLAM中的李群和李代数
    大数据学习：进程管理（2）
    C++ STL
  • 原文地址：https://blog.csdn.net/qq_54432917/article/details/136406168