day09-达人探店

宁睿  金牌会员 | 2023-5-2 20:21:04 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 943|帖子 943|积分 2839

功能04-达人探店

5.功能04-达人探店

5.1发布&查看探店笔记

5.1.1发布探店笔记

探店笔记类似点评网站的评价，往往是图文结合。对应的表有两个：

  • tb_blog：探店笔记表，包含笔记中的标题、文字、图片等
  • tb_blog_comments：其他用户对探店笔记的评价
  1. /*表： tb_blog*/
  2. CREATE TABLE `tb_blog` (
  3.   `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  4.   `shop_id` bigint(20) NOT NULL COMMENT '商户id',
  5.   `user_id` bigint(20) unsigned NOT NULL COMMENT '用户id',
  6.   `title` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '标题',
  7.   `images` varchar(2048) NOT NULL COMMENT '探店的照片，最多9张，多张以","隔开',
  8.   `content` varchar(2048) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '探店的文字描述',
  9.   `liked` int(8) unsigned DEFAULT '0' COMMENT '点赞数量',
  10.   `comments` int(8) unsigned DEFAULT NULL COMMENT '评论数量',
  11.   `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  12.   `update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
  13.   PRIMARY KEY (`id`) USING BTREE
  14. ) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8mb4 ROW_FORMAT=COMPACT
  16. /*表： tb_blog_comments*/
  17. CREATE TABLE `tb_blog_comments` (
  18.   `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  19.   `user_id` bigint(20) unsigned NOT NULL COMMENT '用户id',
  20.   `blog_id` bigint(20) unsigned NOT NULL COMMENT '探店id',
  21.   `parent_id` bigint(20) unsigned NOT NULL COMMENT '关联的1级评论id，如果是一级评论，则值为0',
  22.   `answer_id` bigint(20) unsigned NOT NULL COMMENT '回复的评论id',
  23.   `content` varchar(255) NOT NULL COMMENT '回复的内容',
  24.   `liked` int(8) unsigned DEFAULT NULL COMMENT '点赞数',
  25.   `status` tinyint(1) unsigned DEFAULT NULL COMMENT '状态，0：正常，1：被举报，2：禁止查看',
  26.   `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  27.   `update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
  28.   PRIMARY KEY (`id`) USING BTREE
  29. ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=COMPACT
复制代码
点击首页最下方菜单栏中的“+”按钮，即可发布探店图文：
需要注意的是：
发布照片和发布笔记这两个功能是分离的。因为上传照片的功能不仅仅是发布笔记时需要用到，其他业务也有需求，因此上传照片是一个独立功能。
我们在发布笔记时，点击上传照片，会先向服务端发出一个请求，实现图片上传。上传成功以后，服务端会返回图片的地址（即上传之后可访问的该图片地址），这个地址将来会作为表单的参数，在发布笔记的时候一起提交到后台（也就是说，在提交笔记的时候，我们提交的就不是照片本身了，而是上传成功后的图片地址）。
（1）上传图片功能
上传图片的功能已经提前实现了，详见UploadController.java及其接口
上传的图片其实是放在放在前端服务器中的，这里为了模拟，放在了D盘的前端项目（nginx-1.18.0）的目录下：
同时，需要将代码中保存的目录修改为对应的目录：
（2）发布笔记功能
发布笔记的功能也提前实现了，详见BlogController.java及其接口
（3）测试
点击+号进入如下页面，点击上传照片，一次可以上传多张图片：
每次上传图片成功，后端都会返回该图片可访问的图片地址：
点击发布后，可以在个人主页中看到发布的文章：
5.1.2查看探店笔记

实现查看笔记的接口。需求：点击首页的笔记，可以进入详情页面，实现该页面的查询接口。

笔记的详情页面需要显示：

  • 笔记信息
  • 发布的用户信息（用户id、用户昵称、用户头像）
代码实现
（1）Blog.java，笔记实体类
  1. package com.hmdp.entity;
  3. import com.baomidou.mybatisplus.annotation.IdType;
  4. import com.baomidou.mybatisplus.annotation.TableField;
  5. import com.baomidou.mybatisplus.annotation.TableId;
  6. import com.baomidou.mybatisplus.annotation.TableName;
  7. import lombok.Data;
  8. import lombok.EqualsAndHashCode;
  9. import lombok.experimental.Accessors;
  11. import java.io.Serializable;
  12. import java.time.LocalDateTime;
  14. /**
  15. * 笔记实体
  16. *
  17. * @author 李
  18. * @version 1.0
  19. */
  20. @Data
  21. @EqualsAndHashCode(callSuper = false)
  22. @Accessors(chain = true)
  23. @TableName("tb_blog")
  24. public class Blog implements Serializable {
  26.     private static final long serialVersionUID = 1L;
  27.    
  28.     //主键
  29.     @TableId(value = "id", type = IdType.AUTO)
  30.     private Long id;
  31.    
  32.     //商户id
  33.     private Long shopId;
  34.    
  35.     //用户id
  36.     private Long userId;
  37.    
  38.     //用户头像
  39.     @TableField(exist = false)
  40.     private String icon;
  41.    
  42.     //用户昵称
  43.     @TableField(exist = false)
  44.     private String name;
  45.    
  46.     //是否点赞过
  47.     @TableField(exist = false)
  48.     private Boolean isLike;
  49.    
  50.     //标题
  51.     private String title;
  52.    
  53.     //探店的照片，最多9张，使用","隔开
  54.     private String images;
  55.    
  56.     //探店的文字描述
  57.     private String content;
  58.    
  59.     //点赞数量
  60.     private Integer liked;
  61.    
  62.     //评论数量
  63.     private Integer comments;
  64.    
  65.     //创建时间
  66.     private LocalDateTime createTime;
  67.    
  68.     //更新时间
  69.     private LocalDateTime updateTime;
  70. }
复制代码
（2）BlogMapper.java
  1. package com.hmdp.mapper;
  3. import com.hmdp.entity.Blog;
  4. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  6. /**
  7. *  Mapper 接口
  8. *
  9. * @author 李
  10. * @version 1.0
  11. */
  12. public interface BlogMapper extends BaseMapper<Blog> {
  14. }
复制代码
（3）IBlogService.java
  1. package com.hmdp.service;
  3. import com.hmdp.dto.Result;
  4. import com.hmdp.entity.Blog;
  5. import com.baomidou.mybatisplus.extension.service.IService;
  7. /**
  8. * 服务类
  9. *
  10. * @author 李
  11. * @version 1.0
  12. */
  13. public interface IBlogService extends IService<Blog> {
  14.    
  15.     Result queryHotBlog(Integer current);//分页查询blog
  16.    
  17.     Result queryBlogById(Long id);//根据id查询blog
  18. }
复制代码
（4）BlogServiceImpl.java
  1. package com.hmdp.service.impl;
  3. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  4. import com.hmdp.dto.Result;
  5. import com.hmdp.entity.Blog;
  6. import com.hmdp.entity.User;
  7. import com.hmdp.mapper.BlogMapper;
  8. import com.hmdp.service.IBlogService;
  9. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  10. import com.hmdp.service.IUserService;
  11. import com.hmdp.utils.SystemConstants;
  12. import org.springframework.stereotype.Service;
  14. import javax.annotation.Resource;
  15. import java.util.List;
  17. /**
  18. * 服务实现类
  19. *
  20. * @author 李
  21. * @version 1.0
  22. */
  23. @Service
  24. public class BlogServiceImpl extends ServiceImpl<BlogMapper, Blog> implements IBlogService {
  26.     @Resource
  27.     private IUserService userService;
  28.    
  29.     @Override
  30.     public Result queryHotBlog(Integer current) {
  31.         // 根据用户查询
  32.         Page<Blog> page = query()
  33.                 .orderByDesc("liked")
  34.                 .page(new Page<>(current, SystemConstants.MAX_PAGE_SIZE));
  35.         // 获取当前页数据
  36.         List<Blog> records = page.getRecords();
  37.         // 查询用户
  38.         records.forEach(this::queryBlogUser);
  39.         return Result.ok(records);
  40.     }
  42.     @Override
  43.     public Result queryBlogById(Long id) {
  44.         //1.查询blog
  45.         Blog blog = getById(id);
  46.         //2.查询blog有关的用户
  47.         if (blog == null) {
  48.             return Result.fail("笔记不存在！");
  49.         }
  50.         queryBlogUser(blog);
  52.         return Result.ok(blog);
  53.     }
  55.     public void queryBlogUser(Blog blog) {
  56.         Long userId = blog.getUserId();
  57.         User user = userService.getById(userId);
  58.         blog.setName(user.getNickName());
  59.         blog.setIcon(user.getIcon());
  60.     }
  61. }
复制代码
（5）BlogController.java
  1. package com.hmdp.controller;
  3. import com.hmdp.dto.Result;
  4. import com.hmdp.service.IBlogService;
  5. import org.springframework.web.bind.annotation.*;
  7. import javax.annotation.Resource;
  9. /**
  10. * 前端控制器
  11. *
  12. * @author 李
  13. * @version 1.0
  14. */
  15. @RestController
  16. @RequestMapping("/blog")
  17. public class BlogController {
  19.     @Resource
  20.     private IBlogService blogService;
  21.    
  22.     @GetMapping("/hot")
  23.     public Result queryHotBlog(
  24.         @RequestParam(value = "current", defaultValue = "1") Integer current) {
  25.         return blogService.queryHotBlog(current);
  26.     }
  28.     @GetMapping("/{id}")
  29.     public Result queryBlogById(@PathVariable("id") Long id){
  30.         return blogService.queryBlogById(id);
  31.     }
  32. }
复制代码
（6）测试：重启项目，点击笔记，可以查看笔记详情
5.2点赞

5.2.1需求分析

在首页的探店笔记排行榜和探店图文详情页面都有点赞的功能：
需求：

  • 同一个用户只能点赞一次，再次点击则取消点赞
  • 如果当前用户已经点赞，则点赞按钮高亮显示（前端已实现，判断字段Blog类的isLike属性）
实现步骤：

  • 给Blog类中添加一个isLike字段，标识是否被当前用户点赞
  • 修改点赞功能，利用Redis的set集合判断是否点赞过，未点赞过则点赞数+1，已点赞过则再次点赞时点赞数-1
    blog的id作为key，点赞的用户id作为value

  • 修改根据id查询Blog的业务，判断当前用户是否点赞过，赋值给isLike字段
    用于blog详情的点赞显示

  • 修改分页查询Blog业务，判断当前登录用户是否点赞过，赋值给isLike字段
    用于一页blog时的所有点赞显示

5.2.2代码实现

（1）给Blog类中添加一个isLike字段，标识是否被当前用户点赞
（2）修改IBlogService，添加方法声明
  1. Result likeBlog(Long id);
复制代码
（3）修改BlogServiceImpl

  • 实现方法likeBlog()：修改点赞功能，利用Redis的set集合判断是否点赞过，未点赞过则点赞数+1，已点赞过则再次点赞时点赞数-1
  • 修改BlogServiceImpl的queryBlogById()方法和queryHotBlog()，在查询blog信息的同时，查询当前用户有没有点赞过该blog
注意判断当前用户有没有登录
  1. package com.hmdp.service.impl;
  3. import ...
  5. /**
  6. * 服务实现类
  7. *
  8. * @author 李
  9. * @version 1.0
  10. */
  11. @Service
  12. public class BlogServiceImpl extends ServiceImpl<BlogMapper, Blog> implements IBlogService {
  14.     @Resource
  15.     private IUserService userService;
  17.     @Resource
  18.     private StringRedisTemplate stringRedisTemplate;
  20.     @Override
  21.     public Result queryHotBlog(Integer current) {
  22.         // 根据用户查询
  23.         Page<Blog> page = query()
  24.                 .orderByDesc("liked")
  25.                 .page(new Page<>(current, SystemConstants.MAX_PAGE_SIZE));
  26.         // 获取当前页数据
  27.         List<Blog> records = page.getRecords();
  28.         // 查询用户
  29.         records.forEach(blog -> {
  30.             //查询发布blog的user
  31.             this.queryBlogUser(blog);
  32.             //查询当前用户有没有点赞过该blog
  33.             this.isBlogLiked(blog);
  34.         });
  35.         return Result.ok(records);
  36.     }
  38.     @Override
  39.     public Result queryBlogById(Long id) {
  40.         //1.查询blog
  41.         Blog blog = getById(id);
  42.         //2.查询blog有关的用户
  43.         if (blog == null) {
  44.             return Result.fail("笔记不存在！");
  45.         }
  46.         queryBlogUser(blog);
  47.         //3.查询blog是否被点赞了
  48.         isBlogLiked(blog);
  49.         return Result.ok(blog);
  50.     }
  52.     private void isBlogLiked(Blog blog) {
  53.         //1.获取当前登录用户
  54.         if (UserHolder.getUser() == null) {
  55.         return;//如果当前用户未登录
  56.         }
  57.         Long userId = UserHolder.getUser().getId();
  58.         //2.判断当前登录用户是否已经点赞了
  59.         // (去redis的set集合中判断 SISMEMBER key member)
  60.         String key = "blog:liked:" + blog.getId();
  61.         Boolean isMember =
  62.             stringRedisTemplate.opsForSet().isMember(key, userId.toString());
  63.         blog.setIsLike(BooleanUtil.isTrue(isMember));
  64.     }
  66.     @Override
  67.     public Result likeBlog(Long id) {
  68.         //1.获取当前登录用户
  69.         Long userId = UserHolder.getUser().getId();
  70.         if (userId == null) {
  71.             return Result.fail("用户未登录");
  72.         }
  73.         //2.判断当前登录用户是否已经点赞了
  74.         // (去redis的set集合中判断 SISMEMBER key member)
  75.         String key = "blog:liked:" + id;
  76.         Boolean isMember =
  77.             stringRedisTemplate.opsForSet().isMember(key, userId.toString());
  78.         //3.如果未点赞
  79.         if (BooleanUtil.isFalse(isMember)) {
  80.             //3.1数据库点赞数+1
  81.             boolean isSuccess = update().setSql("liked=liked+1").eq("id", id).update();
  82.             //3.2保存用户到redis的set集合
  83.             if (isSuccess) {
  84.                 stringRedisTemplate.opsForSet().add(key, userId.toString());
  85.             }
  86.         } else {//4.如果已经点赞，则取消点赞
  87.             //4.1数据库点赞数-1
  88.             boolean isSuccess = update().setSql("liked=liked-1").eq("id", id).update();
  89.             //4.2将用户从redis的set集合中移除
  90.             if (isSuccess) {
  91.                 stringRedisTemplate.opsForSet().remove(key, userId.toString());
  92.             }
  93.         }
  94.         return Result.ok();
  95.     }
  97.     public void queryBlogUser(Blog blog) {
  98.         Long userId = blog.getUserId();
  99.         User user = userService.getById(userId);
  100.         blog.setName(user.getNickName());
  101.         blog.setIcon(user.getIcon());
  102.     }
  103. }
复制代码
（4）修改BlogController，添加方法likeBlog()
  1. @PutMapping("/like/{id}")
  2. public Result likeBlog(@PathVariable("id") Long id) {
  3.     return blogService.likeBlog(id);
  4. }
复制代码
（5）测试：启动项目，已登录用户第一次点赞时，点赞数+1，图标高亮；第二次点赞时，点赞数-1，图标变回灰色。

redis中的数据：set结构，key为blogId，value为userId
如果用户未登录，点赞时则会自动跳转到登录页面：
5.3点赞排行榜

5.3.1需求分析

在探店笔记的详情页面，应该把笔记点赞的用户信息显示出来，比如最早点赞的TOP5，形成点赞排行榜：
实现查询点赞排行榜的接口：
需求：按照点赞时间先后排序，返回Top5的用户。
之前我们使用的是redis中的Set结构，对于点赞功能来说，要求数据唯一且可方便查找。在此基础上，点赞排行榜功能还要求对数据进行排序，因此我们选用SortedSet结构实现，并对之前的点赞功能进行改造。
zset的整体结构：key value score（key存储blogId，value存储点赞的userId，score可以存储当前点赞的时间戳）
zset结构没有判断元素是否存在的命令，但可以查找指定元素的score，根据这个命令，判断指定的元素的score，如果score不存在，则该元素不存在。
  1.   ZSCORE key member
  2.   summary: Get the score associated with the given member in a sorted set  
  3.   since: 1.2.0
复制代码
例如：
  1. 127.0.0.1:6379> ZADD z1 1 m1 2 m2 3 m3
  2. (integer) 3
  3. 127.0.0.1:6379> ZSCORE z1 m4 #侧面判断m4不存在
  4. (nil)
  5. 127.0.0.1:6379> ZSCORE z1 m1
  6. "1"
复制代码
查询排行(比较score)则使用 zrange 命令：
  1. 127.0.0.1:6379> ZRANGE z1 0 4 #查询排行前5名
  2. 1) "m1"
  3. 2) "m2"
  4. 3) "m3"
复制代码
5.3.2代码实现

（1）IBlogService增加方法声明queryBlogLikes
  1. public interface IBlogService extends IService<Blog> {
  2.     ...
  3.         
  4.     Result queryBlogLikes(Long id);
  5. }
复制代码
（2）修改BlogServiceImpl：

  • 修改之前的点赞功能，将其用到的set结构改为zset结构（修改isBlogLiked和likeBlog方法）
  • 实现点赞排行功能--queryBlogLikes()
  1. //判断当前用户是否点赞过该blog
  2. private void isBlogLiked(Blog blog) {
  3.     //1.获取当前登录用户
  4.     if (UserHolder.getUser() == null) {
  5.         return;//如果当前用户未登录
  6.     }
  7.     Long userId = UserHolder.getUser().getId();
  8.     //2.判断当前登录用户是否已经点赞了
  9.     String key = BLOG_LIKED_KEY + blog.getId();
  10.     Double score = stringRedisTemplate.opsForZSet().score(key, userId.toString());
  11.     blog.setIsLike(score != null);
  12. }
  14. //进行点赞操作
  15. @Override
  16. public Result likeBlog(Long id) {
  17.     //1.获取当前登录用户
  18.     Long userId = UserHolder.getUser().getId();
  19.     if (userId == null) {
  20.         return Result.fail("用户未登录");
  21.     }
  22.     //2.判断当前登录用户是否已经点赞了
  23.     String key = BLOG_LIKED_KEY + id;
  24.     Double score = stringRedisTemplate.opsForZSet().score(key, userId.toString());
  25.     //3.如果未点赞(score为null，证明该用户不存在zset中，即未点赞)
  26.     if (score == null) {
  27.         //3.1数据库点赞数+1
  28.         boolean isSuccess = update().setSql("liked=liked+1").eq("id", id).update();
  29.         //3.2保存用户到redis的zset集合 zadd key value score
  30.         if (isSuccess) {
  31.             stringRedisTemplate.opsForZSet().add(key, userId.toString(), System.currentTimeMillis());
  32.         }
  33.     } else {//4.如果已经点赞，则取消点赞
  34.         //4.1数据库点赞数-1
  35.         boolean isSuccess = update().setSql("liked=liked-1").eq("id", id).update();
  36.         //4.2将用户从redis的zset集合中移除
  37.         if (isSuccess) {
  38.             stringRedisTemplate.opsForZSet().remove(key, userId.toString());
  39.         }
  40.     }
  41.     return Result.ok();
  42. }
  44. //根据blogId返回点赞该blog的top5的用户信息
  45. @Override
  46. public Result queryBlogLikes(Long id) {
  47.     String key = BLOG_LIKED_KEY + id;
  48.     //1.查询top5的点赞用户 zrange key 0 4
  49.     Set<String> top5 = stringRedisTemplate.opsForZSet().range(key, 0, 4);
  50.     if (top5 == null || top5.isEmpty()) {
  51.         return Result.ok(Collections.emptyList());
  52.     }
  53.     //2.解析出其中的用户id
  54.     List<Long> ids = top5.stream().map(Long::valueOf).collect(Collectors.toList());
  55.     //3.根据用户id查询用户
  56.     List<UserDTO> userDTOS = userService.listByIds(ids)
  57.             .stream()
  58.             .map(user -> BeanUtil.copyProperties(user, UserDTO.class))
  59.             .collect(Collectors.toList());
  60.     //4.返回
  61.     return Result.ok(userDTOS);
  62. }
复制代码
（3）修改 BlogController，增加方法
  1. @GetMapping("/likes/{id}")
  2. public Result queryBlogLikes(@PathVariable("id") Long id) {
  3.      return blogService.queryBlogLikes(id);
  4. }
复制代码
（4）测试：使用不同的用户账号给同一篇探店blog点赞，成功显示点赞的用户信息：
但是显示的顺序出现了问题：如下所示，分别有三个用户。正确的点赞顺序如redis缓存所示：1033，1，2
但是从数据库中查找返回的用户顺序却是：1，2 ，1033，前端显示的用户头像id也是按照1，2，1033的顺序，这显然不符合我们要的顺序。
我们返回看之前的代码：
代码底层发出的sql语句如下：可以发现传入的参数顺序是正确的（1033，1，2），但是返回的数据顺序并不和我们的入参一致：
怎么保证使用IN子句的时候，返回的数据结果和参数的顺序一致呢？
解决方法：使用 order by 指定排序
（5）修改queryBlogLikes()方法，自定义查询语句：
（6）重新启动项目：可以看到之前的顺序已经变为真正的顺序了

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有账号？立即注册

x
回复

使用道具 举报

0 个回复

倒序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

宁睿

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

挺好的 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表