master
duhui 2023-05-19 15:59:11 +08:00
parent bebb3b648f
commit e20aa9d4db
1 changed files with 7 additions and 5 deletions

View File

@ -93,6 +93,7 @@ public class HeFuManager {
dealRedis(masterId,slaveId);
}
// 处理从服的gm服务器信息
ArrayList<Integer> list = new ArrayList<>();
for (String s : strings) {
int slaveId = Integer.parseInt(s);
@ -192,12 +193,12 @@ public class HeFuManager {
public void upsertServerIpAndPort(int masterSID, int slowSID) throws Exception {
LOGGER.info("开始处理IP和端口===========a{}b:{}",masterSID,slowSID);
ServerInfo masterServer = serverInfoDao.getServerInfo(String.valueOf(masterSID));
String ip = masterServer.getIp();
String port = masterServer.getPort();
ServerInfo slaveServer = serverInfoDao.getServerInfo(String.valueOf(slowSID));
slaveServer.setIp(ip);
slaveServer.setPort(port);
slaveServer.setIp(masterServer.getIp());
slaveServer.setPort(masterServer.getPort());
slaveServer.setCoreName(masterServer.getCoreName());
serverInfoDao.updateServerInfo(slaveServer);
LOGGER.info("处理IP和端口完成:{}",slaveServer.toString());
}
public static final String colon = ":";
@ -212,7 +213,7 @@ public class HeFuManager {
public static final String ARENA_RANK = "ARENA_RANK";//竞技场排行榜
public boolean dealRedis(int masterSID, int slowSID){
LOGGER.info("开始处理排行榜===========a{}b:{}",masterSID,slowSID);
LOGGER.info("开始处理redis排行榜===========a{}b:{}",masterSID,slowSID);
// 战力排行榜处理
defaultRankOfRedis(FORCE_CURR_RANK,masterSID,slowSID);
// 心魔试炼排行榜处理
@ -231,6 +232,7 @@ public class HeFuManager {
deleteRankOfRedis(GUILD_CHALLENGE_RANK,masterSID);
// 竞技场排行榜处理
deleteRankOfRedis(ARENA_RANK,masterSID);
LOGGER.info("处理redis排行榜完成");
return true;
}