实战篇 - 达人探店 - 《JAVA》

发布探店笔记
查看探店笔记
点赞
点赞排行榜

发布探店笔记

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

tb_blog：探店笔记表，包含笔记中的标题、文字、图片等
tb_blog_comments：其他用户对探店笔记的评价

点击首页最下方菜单栏中的+按钮，即可发布探店图文：

文件上传的设置：

@PostMapping("blog")
public Result uploadImage(@RequestParam("file") MultipartFile image) {
    try {
        // 获取原始文件名称
        String originalFilename = image.getOriginalFilename();
        // 生成新文件名
        String fileName = createNewFileName(originalFilename);
        // 保存文件
        image.transferTo(new File(SystemConstants.IMAGE_UPLOAD_DIR, fileName));
        // 返回结果
        log.debug("文件上传成功，{}", fileName);
        return Result.ok(fileName);
    } catch (IOException e) {
        throw new RuntimeException("文件上传失败", e);
    }
}

@PostMapping
public Result saveBlog(@RequestBody Blog blog) {
    // 获取登录用户
    UserDTO user = UserHolder.getUser();
    blog.setUserId(user.getId());
    // 保存探店博文
    blogService.save(blog);
    // 返回id
    return Result.ok(blog.getId());
}

查看探店笔记

需求：点击首页的探店笔记，会进入详情页面，实现该页面的查询接口：

@GetMapping("/hot")
public Result queryHotBlog(@RequestParam(value = "current", defaultValue = "1") Integer current) {
    return blogService.queryHotBlog(current);
}
@GetMapping("/{id}")
public Result queryBlogById(@PathVariable("id")Long id){
    return blogService.queryBlogById(id);
}

@Service
public class BlogServiceImpl extends ServiceImpl<BlogMapper, Blog> implements IBlogService {
    @Resource
    private IUserService userService;

    @Override
    public Result queryBlogById(Long id) {
        //1.查询blog
        Blog blog = getById(id);
        if (blog == null) {
            return Result.fail("博客不存在！");
        }
        //2.查询blog有关的用户
        queryBlogUser(blog);
        return Result.ok(blog);
    }

    @Override
    public Result queryHotBlog(Integer current) {
        // 根据用户查询
        Page<Blog> page = query()
                .orderByDesc("liked")
                .page(new Page<>(current, SystemConstants.MAX_PAGE_SIZE));
        // 获取当前页数据
        List<Blog> records = page.getRecords();
        // 查询用户
        records.forEach(this::queryBlogUser);
        return Result.ok(records);
    }

    private void queryBlogUser(Blog blog) {
        Long userId = blog.getUserId();
        User user = userService.getById(userId);
        blog.setName(user.getNickName());
        blog.setIcon(user.getIcon());
    }
}

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

需求：

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

实现步骤：
① 给Blog类中添加一个isLike字段，标示是否被当前用户点赞
② 修改点赞功能，利用Redis的set集合判断是否点赞过，未点赞过则点赞数+1，已点赞过则点赞数-1
③ 修改根据id查询Blog的业务，判断当前登录用户是否点赞过，赋值给isLike字段
④ 修改分页查询Blog业务，判断当前登录用户是否点赞过，赋值给isLike字段

@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@TableName("tb_blog")
public class Blog implements Serializable {

    ...

    @TableField(exist = false)
    private Boolean isLiked;

}

@Override
public void likeBlog(Long id) {
    String userId = String.valueOf(UserHolder.getUser().getId());
    String key = "blog:liked:" + id;
    Boolean isMember = redisTemplate.opsForSet().isMember(key, userId);
    if (Boolean.FALSE.equals(isMember)) {
        boolean isSuccess = update().setSql("liked = liked + 1").eq("id", id).update();
        if (isSuccess) {
            redisTemplate.opsForSet().add(key, userId);
        }
    } else {
        boolean isSuccess = update().setSql("liked = liked - 1").eq("id", id).update();
        if (isSuccess) {
            redisTemplate.opsForSet().remove(key, userId);
        }
    }
}

private void isBlogLiked(Blog blog) {
    String userId = String.valueOf(UserHolder.getUser().getId());
    String key = "blog:liked:" + blog.getId();
    Boolean isMember = redisTemplate.opsForSet().isMember(key, userId);
    blog.setIsLiked(Boolean.TRUE.equals(isMember));
}

@Override
public Result queryBlogById(Long id) {
    Blog blog = getById(id);
    if (blog == null) {
        return Result.fail("博客不存在！");
    }
    queryBlogUser(blog);
    isBlogLiked(blog);
    return Result.ok(blog);
}

@Override
public Result queryHotBlog(Integer current) {
    // 根据用户查询
    Page<Blog> page = query()
        .orderByDesc("liked")
        .page(new Page<>(current, SystemConstants.MAX_PAGE_SIZE));
    // 获取当前页数据
    List<Blog> records = page.getRecords();
    // 查询用户
    records.stream().peek(this::queryBlogUser).forEach(this::isBlogLiked);
    return Result.ok(records);
}

点赞排行榜

在探店笔记的详情页面，应该把给该笔记点赞的人显示出来，比如最早点赞的TOP5，形成点赞排行榜：

需求：按照点赞时间先后排序，返回Top5的用户

对比后选择用SortedSet替代Set实现点赞排行榜功能

@Override
public void likeBlog(Long id) {
    // 1.获取登录用户
    Long userId = UserHolder.getUser().getId();
    // 2.判断当前用户是否点赞
    String key = "blog:liked:" + id;
    // Boolean isMember = stringRedisTemplate.opsForSet().isMember(key, userId.toString());
    Double score = stringRedisTemplate.opsForZSet().score(key, userId.toString());
    if(score == null){
        // 3.如果未点赞，可以点赞
        // 3.1数据库点赞数+1
        boolean isSuccess = update().setSql("liked = liked + 1").eq("id", id).update();
        //3.2保存用户到Redis的set集合
        if(isSuccess){
            // stringRedisTemplate.opsForSet().add(key, userId.toString());
            stringRedisTemplate.opsForZSet().add(key, userId.toString(), System.currentTimeMillis());
        }
    }else {
        // 4.如果已点赞，取消点赞
        // 4.1数据库点赞-1
        boolean isSuccess = update().setSql("liked = liked - 1").eq("id", id).update();
        // 4.2把用户从Redis的set集合移除
        if(isSuccess){
            // stringRedisTemplate.opsForSet().remove(key, userId.toString());
            stringRedisTemplate.opsForZSet().remove(key, userId.toString());
        }
    }
}

查询点赞Top5

@Override
public Result queryBlogLikes(Long id) {
    //1.查询top5点赞用户
    String key = BLOG_LIKED_KEY + id;
    Set<String> top5 = stringRedisTemplate.opsForZSet().range(key, 0, 4);
    if(top5 == null || top5.isEmpty()){
        return Result.ok(Collections.emptyList());
    }
    //2.解析其中用户id
    List<Long> ids = top5.stream().map(Long::valueOf).collect(Collectors.toList());

    //3.根据用户id查询用户
    List<UserDTO> userDTOS = userService.listByIds(ids).stream().map(user -> BeanUtil.copyProperties(user, UserDTO.class)).collect(Collectors.toList());
    //4.返回
    return Result.ok(userDTOS);
}

排序Bug：使用ORDER BY FIELD

@Override
public Result queryBlogLikes(Long id) {
    ...
    String idStr = StrUtil.join(",", ids);
    //3.根据用户id查询用户
    List<UserDTO> userDTOS = userService.query()
        .in("id", ids).last("ORDER BY FIELD(id," + idStr + ")").list()
        .stream().map(user -> BeanUtil.copyProperties(user, UserDTO.class)).collect(Collectors.toList());
    //4.返回
    return Result.ok(userDTOS);
}