@DistributeLock(keyExpression = "#telephone", scene = "USER_REGISTER")
public UserOperatorResponse register(String telephone, String inviteCode) {
	//用戶名生成
 
    String inviterId = null;
    if (StringUtils.isNotBlank(inviteCode)) {
        User inviter = userMapper.findByInviteCode(inviteCode);
        if (inviter != null) {
            inviterId = inviter.getId().toString();
        }
    }
 
    //用戶注冊(cè)
 
    //更新排名
    updateInviteRank(inviterId);
    
 
	//其他邏輯
}

private void updateInviteRank(String inviterId) {
    // 如果邀請(qǐng)者ID為空，則直接返回，不進(jìn)行操作
    if (inviterId == null) {
        return;
    }
 
    // 獲取Redisson的鎖對(duì)象
    RLock rLock = redissonClient.getLock(inviterId);
    // 對(duì)邀請(qǐng)者ID對(duì)應(yīng)的鎖進(jìn)行加鎖操作，避免并發(fā)更新
    rLock.lock();
    try {
        // 獲取邀請(qǐng)者的當(dāng)前排名分?jǐn)?shù)
        Double score = inviteRank.getScore(inviterId);
        // 如果當(dāng)前分?jǐn)?shù)為空，則設(shè)置默認(rèn)為0.0
        if (score == null) {
            score = 0.0;
        }
        // 將邀請(qǐng)者的排名分?jǐn)?shù)增加100.0，并更新到排行榜中
        inviteRank.add(score + 100.0, inviterId);
    } finally {
        // 最終釋放邀請(qǐng)者ID對(duì)應(yīng)的鎖
        rLock.unlock();
    }
}
 

private RScoredSortedSet<String> inviteRank;
 
    @Override
    public void afterPropertiesSet() throws Exception {
        
        this.inviteRank = redissonClient.getScoredSortedSet("inviteRank");
    }

//獲取指定用戶的排名，按照分?jǐn)?shù)從高到低
public Integer getInviteRank(String userId) {
    Integer rank = inviteRank.revRank(userId);
    if (rank != null) {
        return rank + 1;
    }
    return null;
}

//按照分?jǐn)?shù)從高到低，獲取前N個(gè)用戶的排名信息
public List<InviteRankInfo> getTopN(Integer topN) {
    Collection<ScoredEntry<String>> rankInfos = inviteRank.entryRangeReversed(0, topN - 1);
    List<InviteRankInfo> inviteRankInfos = new ArrayList<>();
 
    if (rankInfos != null) {
        for (ScoredEntry<String> rankInfo : rankInfos) {
            InviteRankInfo inviteRankInfo = new InviteRankInfo();
            String userId = rankInfo.getValue();
            if (StringUtils.isNotBlank(userId)) {
                User user = findById(Long.valueOf(userId));
                if (user != null) {
                    inviteRankInfo.setNickName(user.getNickName());
                    inviteRankInfo.setInviteCode(user.getInviteCode());
                    inviteRankInfo.setInviteCount(rankInfo.getScore().intValue() / 100);
                    inviteRankInfos.add(inviteRankInfo);
                }
            }
        }
    }
 
    return inviteRankInfos;
}

private void updateInviteRank(String inviterId) {
    if (inviterId == null) {
        return;
    }
    //1、這里因?yàn)槭且粋€(gè)私有方法，無法通過注解方式實(shí)現(xiàn)分布式鎖。
    //2、register方法已經(jīng)加了鎖，這里需要二次加鎖的原因是register鎖的是注冊(cè)人，這里鎖的是邀請(qǐng)人
    RLock rLock = redissonClient.getLock(inviterId);
    rLock.lock();
    try {
        //獲取當(dāng)前用戶的積分
        Double score = inviteRank.getScore(inviterId);
        if (score == null) {
            score = 0.0;
        }
 
        //獲取最近一次上榜時(shí)間
        long currentTimeStamp = System.currentTimeMillis();
        //把上榜時(shí)間轉(zhuǎn)成小數(shù)(時(shí)間戳13位，所以除以10000000000000能轉(zhuǎn)成小數(shù))，并且倒序排列（用1減），即上榜時(shí)間越早，分?jǐn)?shù)越大（時(shí)間越晚，時(shí)間戳越大，用1減一下，就反過來了）
        double timePartScore = 1 - (double) currentTimeStamp / 10000000000000L;
 
        //1、當(dāng)前積分保留整數(shù)，即移除上一次的小數(shù)位
        //2、當(dāng)前積分加100，表示新邀請(qǐng)了一個(gè)用戶
        //3、加上“最近一次上榜時(shí)間的倒序小數(shù)位“作為score
        inviteRank.add(score.intValue() + 100.0 + timePartScore, inviterId);
    } finally {
        rLock.unlock();
    }
}