跨服排行修改

duhui 2021-08-16 00:03:52 +08:00
parent d08086fe78
commit 69a15015de
3 changed files with 5 additions and 10 deletions

View File

@ -227,6 +227,9 @@ public class GlobleSystemLogic implements IEventHandler {
LOGGER.error("跨服分组,未获取到锁");
return;
}
// 跨服排行榜处理
CrossRankManager.getInstance().cleanCrossRank();
//这里为所有服务器的世界等级
Map<String,Integer> worldLevelMap = redisUtil.getMapValues(RedisKey.SERVER_WORLDLEVE_INFO,"",String.class,Integer.class);
LOGGER.info("跨服开始分组");
@ -266,10 +269,6 @@ public class GlobleSystemLogic implements IEventHandler {
redisUtil.del(RedisKey.CHAT_CROSS_MSG_ID+i);
}
// 跨服排行榜处理
CrossRankManager.getInstance().cleanCrossRank();
CrossRankManager.getInstance().crossRankHandle(true);
//释放分布式锁
redisUtil.del("SERVER_SPLIT_REDIS_LOCK");

View File

@ -48,7 +48,7 @@ public class CrossRankManager {
*/
public void crossRankHandle(boolean choice){
// 时间验证
if (choice || isTime()){
if (isTime()){
// 全部排行遍历
for (RankEnum value : RankEnum.values()) {
int type = value.getType();
@ -76,8 +76,6 @@ public class CrossRankManager {
}
}
}
// 更新时间
isTime();
}
}

View File

@ -252,7 +252,6 @@ public abstract class AbstractRank implements IRank {
}
private CommonProto.UserRank.Builder getOneUserRank(User everyUser,CommonProto.RankInfo.Builder everyRankInfo){
String serverName = CrossServiceLogic.getInstance().getServerNameByUId(everyUser.getId());
return CommonProto.UserRank.newBuilder()
.setUid(everyUser.getId())
.setUserName(everyUser.getPlayerInfoManager().getNickName())
@ -265,8 +264,7 @@ public abstract class AbstractRank implements IRank {
.setUserSkin(everyUser.getPlayerInfoManager().getUserSkin())
.setUserTitle(everyUser.getPlayerInfoManager().getUserTitle())
.setUserMount(everyUser.getPlayerInfoManager().getUserMount())
.setPracticeLevel(everyUser.getHeroManager().getPracticeLevel())
.setServerName(serverName);
.setPracticeLevel(everyUser.getHeroManager().getPracticeLevel());
}
public CommonProto.UserRank.Builder getCrossOneUserRank(ArenaOfUser query, CommonProto.RankInfo.Builder everyRankInfo){