diff --git a/serverlogic/src/main/java/com/ljsd/jieling/thread/task/MinuteTask.java b/serverlogic/src/main/java/com/ljsd/jieling/thread/task/MinuteTask.java index 07c41a14f..a359164f1 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/thread/task/MinuteTask.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/thread/task/MinuteTask.java @@ -2,7 +2,6 @@ package com.ljsd.jieling.thread.task; import com.ljsd.GameApplication; import com.ljsd.fight.CheckFight; -import com.ljsd.jieling.config.reportData.DataMessageUtils; import com.ljsd.jieling.core.CoreLogic; import com.ljsd.jieling.core.GlobalsDef; import com.ljsd.jieling.core.Lockeys; @@ -13,10 +12,6 @@ import com.ljsd.jieling.db.redis.RedisKey; import com.ljsd.jieling.db.redis.RedisUtil; import com.ljsd.jieling.handler.map.MapLogic; import com.ljsd.jieling.hotfix.HotfixUtil; -import com.ljsd.jieling.ktbeans.BeanBuilder.KtBeanBuilderUtils; -import com.ljsd.jieling.ktbeans.KTRequestBeans.LoginParamType; -import com.ljsd.jieling.ktbeans.parmsBean.ParamEventBean; -import com.ljsd.jieling.ktbeans.sendbeans.KTAppOnline; import com.ljsd.jieling.logic.GlobalDataManaager; import com.ljsd.jieling.logic.OnlineUserManager; import com.ljsd.jieling.logic.SituationLogic; @@ -40,15 +35,11 @@ import com.ljsd.jieling.logic.store.StoreLogic; import com.ljsd.jieling.network.server.ProtocolsManager; import com.ljsd.jieling.thread.ThreadManager; import com.ljsd.jieling.util.MessageUtil; -import io.netty.util.internal.PlatformDependent; import manager.STableManager; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.springframework.util.ReflectionUtils; -import java.lang.reflect.Field; import java.util.*; -import java.util.concurrent.atomic.AtomicLong; public class MinuteTask extends Thread { private static final Logger LOGGER = LoggerFactory.getLogger(MinuteTask.class); @@ -206,10 +197,24 @@ public class MinuteTask extends Thread { } Lockeys.getLockeys().lock("guild",sendUids); guildInfo.clearGuildHelpLog(); +// for (Integer sendUid : sendUids) { +// User target = UserManager.getUser(sendUid); +// AyyncWorker ayyncWorker = new AyyncWorker(target, true, user -> { +// GuildLogic.sendGuildHelpRewardEmail(target); +// GuildMyInfo guildMyInfo = target.getGuildMyInfo(); +// guildMyInfo.setGuidHelpInfo(new HashMap<>()); +// guildMyInfo.setGuidHelpHadTakeInfo(new HashMap<>()); +// guildMyInfo.setGuildHelpSendTime(0); +// guildMyInfo.setGuildHelpReward(false); +// guildMyInfo.setGuildHelpTime(0); +// }); +// ProtocolsManager.getInstance().updateAyncWorker(ayyncWorker); +// } //统一清除 for (Integer sendUid : sendUids) { User target = UserManager.getUser(sendUid); + LOGGER.info("公会援助刷新uid=>",sendUid); GuildLogic.sendGuildHelpRewardEmail(target); GuildMyInfo guildMyInfo = target.getGuildMyInfo(); guildMyInfo.setGuidHelpInfo(new HashMap<>());