diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/arena/ArenaLogic.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/arena/ArenaLogic.java index 71daf0ae8..a3d391e1d 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/arena/ArenaLogic.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/arena/ArenaLogic.java @@ -774,7 +774,7 @@ public class ArenaLogic { if (crossGroup == -1) { return; } - String lockKey = "WORLD_ARENA_SEND_REWARD_RANK:" + crossGroup; + String lockKey = "WORLD_ARENA_SEND_REWARD_LOCK:" + crossGroup; boolean lock = RedisUtil.getInstence().lock(lockKey, TimeUtils.ONE_MINUTE * 5); if (!lock) { LOGGER.error("罗浮争锋,发奖退出,未获取到锁:{}",lockKey); @@ -902,14 +902,15 @@ public class ArenaLogic { return; } //分布式锁,保证一个组只有一个服进行初始化 - boolean lock = RedisUtil.getInstence().lock("WORLD_ARENA_INIT_RANK:" + crossGroup, TimeUtils.ONE_MINUTE * 5); + String lockKey = "WORLD_ARENA_INIT_LOCK:" + crossGroup; + boolean lock = RedisUtil.getInstence().lock(lockKey, TimeUtils.ONE_MINUTE * 5); if (!lock) { LOGGER.error("罗浮争锋,初始化排行榜退出,未获取到锁"); return; } - LOGGER.info("罗浮争锋,初始化排行榜开始..."); - RedisUtil.getInstence().expire2("WORLD_ARENA_INIT_RANK:" + crossGroup, TimeUtils.ONE_MINUTE * 5); + RedisUtil.getInstence().expire2(lockKey, TimeUtils.ONE_MINUTE * 5); + LOGGER.info("罗浮争锋,初始化排行榜开始..."); String key1 = RedisUtil.getInstence().getKey(RedisKey.CROSS_ARENA_ROBOT_INFO, String.valueOf(crossGroup)); String key2 = RedisUtil.getInstence().getKey(RedisKey.CROSS_SERVICE_ARENA, String.valueOf(crossGroup)); RedisUtil.getInstence().del(key1, key2);