root
/
miduo_server
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

跨服十绝阵

back_recharge
duhui 2021-09-13 11:37:48 +08:00
parent 884e3b1276
commit 045e1ce82f
2 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
serverlogic/src/main/java/com/ljsd/jieling/logic/family/CrossDeathPathLogic.java
View File

@ -206,7 +206,7 @@ public class CrossDeathPathLogic {
}
RedisUtil.getInstence().hdel(RedisKey.DEATH_PATH_EVERY_OVER_HASH,String.valueOf(serverId));
boolean lock = RedisUtil.getInstence().lock(RedisKey.DEATH_PATH_DELETE_CROSS, TimeUtils.ONE_MINUTE * 2);
boolean lock = RedisUtil.getInstence().lock(RedisKey.DEATH_PATH_DELETE_CROSS+":"+groupId, TimeUtils.ONE_MINUTE * 2);
// 拿到锁的操作删除
if (lock){
// 删除rediskey

7
serverlogic/src/main/java/com/ljsd/jieling/thread/task/MinuteTask.java
View File

@ -101,8 +101,8 @@ public class MinuteTask extends Thread {
LOGGER.error("Exception::=>{}",e.toString());
}
try {
if (TimeUtils.getHourOfDay() == 0 && TimeUtils.getMiunte() == 0){
// 竞技场，每日九点刷新
if (TimeUtils.getHourOfDay() == 21 && TimeUtils.getMiunte() == 0){
// 竞技场，每日晚九点刷新
ArenaLogic.getInstance().sendReward(GlobalsDef.ARENA_DAILY_REWARD);
}
}catch (Exception e){
@ -214,7 +214,6 @@ public class MinuteTask extends Thread {
Calendar calendar = Calendar.getInstance();
int hour = calendar.get(Calendar.HOUR_OF_DAY);
int minute = calendar.get(Calendar.MINUTE);
LOGGER.info("********竞技场每日邮件和公会零点刷新时间*******:{}",TimeUtils.getTimeStamp2(TimeUtils.now()));
if(hour == 0 && minute ==0){
//保证每分钟线程
try {
@ -233,7 +232,7 @@ public class MinuteTask extends Thread {
sendUids.addAll(items);
}
for (Integer sendUid : sendUids) {
User target = UserManager.getUser(sendUid);
User target = UserManager.getUserInMem(sendUid);
AyyncWorker ayyncWorker = new AyyncWorker(target, true, user -> {
GuildLogic.sendGuildHelpRewardEmail(target);
GuildMyInfo guildMyInfo = target.getGuildMyInfo();