@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();
        }
    }
 
    //用戶注冊
 
    //更新排名
    updateInviteRank(inviterId);
    
 
	//其他邏輯
}

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

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

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

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