第八天排行榜功能

排行榜分析：

榜单分为两类：

实时榜单：也就是本赛季的榜单
历史榜单：也就是历史赛季的榜单

之前一个积分记录明细表

要知道，每个用户都可能会有数十甚至上百条积分记录，当用户规模达到百万规模，可能产生的积分记录就是数以亿计。

要在每次查询排行榜时，在内存中对这么多数据做分组、求和、排序，对内存和CPU的占用会非常恐怖，不太靠谱。

采用 redis的zset进行存储积分榜

添加积分代码实现

查询积分榜

在个人中心，学生可以查看指定赛季积分排行榜（只显示前100 ），还可以查看自己总积分和排名。而且排行榜分为本赛季榜单和历史赛季榜单。

首先我们分析一下请求参数：

榜单数据非常多，不可能一次性查询出来，因此这里一定是分页查询（滚动分页），需要分页参数。
由于要查询历史榜单需要知道赛季，因此参数中需要指定赛季id。当赛季id为空，我们认定是查询当前赛季。这样就可以把两个接口合二为一。

然后是返回值，无论是历史榜单还是当前榜单，结构都一样。分为两部分：

当前用户的积分和排名。当前用户不一定上榜，因此需要单独查询
榜单数据。就是N个用户的积分、排名形成的集合

把本赛季的存到redis中，其他赛季的持久化到数据库中，所以如果是本赛季的就去redis中查，其他赛季数据库中查

 public PointsBoardVO queryPointsBoardBySeason(PointsBoardQuery query) {
        // 获取 当前登录用户
        Long userId = UserContext.getUser();
        // 判断是当前赛季还是历史赛季 query.season 赛季id， 为null或者为0表示查当前赛季 为true表示查询当前赛季
        boolean isCurrent = query.getSeason() == null || query.getSeason() == 0;
        LocalDateTime now = LocalDateTime.now();
        String format = now.format(DateTimeFormatter.ofPattern("yyyyMM"));
        String key = RedisConstants.POINTS_BOARD_KEY_PREFIX + format;
        Long season = query.getSeason(); //历史赛季id
        // 查询我的排名和积分  根据query.getseason() 判断是查redis还是db
        PointsBoard board = isCurrent ? queryMyCurrentBoard(key) : queryMyHistoryBoard(season);

        // 分页查询赛季列表 根据query.season 判断是查redis还是db
        List<PointsBoard> list = isCurrent ? queryCurrentBoard(key,query.getPageNo(),query.getPageSize()) : queryHistoryBoard(key,query.getPageNo(),query.getPageSize());
        Set<Long> longSet = list.stream().map(PointsBoard::getUserId).collect(Collectors.toSet());
        List<UserDTO> userDTOS = userClient.queryUserByIds(longSet);
        Map<Long, String> map = userDTOS.stream().collect(Collectors.toMap(UserDTO::getId, c -> c.getName()));
        //封装vo
        PointsBoardVO vo = new PointsBoardVO();
        vo.setRank(board.getRank());
        vo.setPoints(board.getPoints());
        ArrayList<PointsBoardItemVO> voList = new ArrayList<>();
        for (PointsBoard pointsBoard : list) {
            PointsBoardItemVO pointsBoardItemVO = new PointsBoardItemVO();
            pointsBoardItemVO.setPoints(pointsBoard.getPoints());
            pointsBoardItemVO.setRank(pointsBoard.getRank());
            pointsBoardItemVO.setName(map.get(pointsBoard.getUserId()));
            voList.add(pointsBoardItemVO);
        }
        vo.setBoardList(voList);
        return vo;
    }

查找当前赛季的

private List<PointsBoard> queryCurrentBoard(String key, Integer pageNo, Integer pageSize) {
        int start = (pageNo - 1) * pageSize;
        int end = start + pageSize - 1;
        // 利用zrevrange 会按照分页 分数倒序（从大到小）
        int range = start + 1;
        Set<ZSetOperations.TypedTuple<String>> typedTuples = redisTemplate.opsForZSet().reverseRangeWithScores(key, start, end);
        if (CollUtils.isEmpty(typedTuples)){
            return CollUtils.emptyList();
        }
        List<PointsBoard> list = new ArrayList<>();
        for (ZSetOperations.TypedTuple<String> typedTuple : typedTuples) {
            Double score = typedTuple.getScore();
            String value = typedTuple.getValue();
            if (score == null || StringUtils.isBlank(value)){
                continue;
            }
            PointsBoard board = new PointsBoard();
            board.setPoints(score.intValue());
            board.setUserId(Long.valueOf(value));
            board.setRank(range++);
            list.add(board);
        }
        return list;
    }

查找我的排名（仅我自己的）

    private PointsBoard queryMyCurrentBoard(String key) {
        Long userId = UserContext.getUser();
        Double score = redisTemplate.opsForZSet().score(key, userId.toString());
        if (score == null){
            score = 0D;
        }
        // 获取排名
        Long rank = redisTemplate.opsForZSet().reverseRank(key, userId.toString());
        PointsBoard board = new PointsBoard();
        board.setRank(rank == null ? 0: rank.intValue()+1 );
        board.setPoints(score == null ? 0 :score.intValue());
        board.setUserId(userId);
        return board;
    }

查看排名从大到校