尝试修改公会援助

lvxinran 2021-06-17 02:45:46 +08:00
parent 45b5757a1d
commit be62050c52
1 changed files with 28 additions and 27 deletions

View File

@ -34,6 +34,7 @@ import com.ljsd.jieling.logic.store.BuyGoodsNewLogic;
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.AyyncWorker;
import com.ljsd.jieling.util.MessageUtil;
import manager.STableManager;
import org.slf4j.Logger;
@ -189,43 +190,43 @@ public class MinuteTask extends Thread {
RedisUtil.getInstence().del(RedisKey.getKey(RedisKey.GUILD_RED_PACKAGE_RANK,String.valueOf(guildInfoEntry.getKey()),false));
guildInfoEntry.getValue().reSetFete();
LOGGER.info("{}更新公会祭祀完毕",guildInfoEntry.getValue().getName());
SimpleTransaction transaction = SimpleTransaction.current();
// SimpleTransaction transaction = SimpleTransaction.current();
GuildInfo guildInfo = guildInfoEntry.getValue();
Set<Integer> sendUids = new HashSet<>();
for (Set<Integer> items : guildInfo.getMembers().values()) {
sendUids.addAll(items);
}
Lockeys.getLockeys().lock("guild",sendUids);
// 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<>());
guildMyInfo.setGuidHelpHadTakeInfo(new HashMap<>());
guildMyInfo.setGuildHelpSendTime(0);
guildMyInfo.setGuildHelpReward(false);
guildMyInfo.setGuildHelpTime(0);
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);
LOGGER.info("公会援助刷新uid=>{}",sendUid);
});
ProtocolsManager.getInstance().updateAyncWorker(ayyncWorker);
}
LOGGER.info("{}更新公会援助完毕",guildInfoEntry.getValue().getName());
// LOGGER.info("{}更新公会援助完毕",guildInfoEntry.getValue().getName());
SimpleTransaction.remove();
// //统一清除
// for (Integer sendUid : sendUids) {
// User target = UserManager.getUser(sendUid);
// GuildLogic.sendGuildHelpRewardEmail(target);
// GuildMyInfo guildMyInfo = target.getGuildMyInfo();
// guildMyInfo.setGuidHelpInfo(new HashMap<>());
// guildMyInfo.setGuidHelpHadTakeInfo(new HashMap<>());
// guildMyInfo.setGuildHelpSendTime(0);
// guildMyInfo.setGuildHelpReward(false);
// guildMyInfo.setGuildHelpTime(0);
// }
// SimpleTransaction.remove();
//处理公会援助信息
//入库