公会援助刷新回滚

back_recharge
duhui 2021-09-10 18:28:52 +08:00
parent aa040195e0
commit 59b4e12b17
3 changed files with 39 additions and 20 deletions

View File

@ -432,7 +432,7 @@ public class GlobalDataManaager implements IManager {
// 助战清理
HelpHeroLogic.getInstance().clearHelpInfo(user);
// 公会援助刷新
GuildLogic.getInstance().everyDayFlushHelpLog(user);
// GuildLogic.getInstance().everyDayFlushHelpLog(user);
// GuildChallengeLogic.getInstance().resetBossDamage(user);
if(TimeUtils.isSpanTime(user.getPlayerInfoManager().getLoginTime(),TimeUtils.now(),1,0)){

View File

@ -1664,25 +1664,25 @@ public class GuildLogic {
}
/**
*
* @param user
*/
public void everyDayFlushHelpLog(User user){
try {
GuildLogic.sendGuildHelpRewardEmail(user);
GuildMyInfo guildMyInfo = user.getGuildMyInfo();
guildMyInfo.setGuidHelpInfo(new HashMap<>());
guildMyInfo.setGuidHelpHadTakeInfo(new HashMap<>());
guildMyInfo.setGuildHelpSendTime(0);
guildMyInfo.setGuildHelpReward(false);
guildMyInfo.setGuildHelpTime(0);
LOGGER.info("公会援助刷新uid=>{}",user.getId());
} catch (Exception e) {
LOGGER.error("公会援助报错uid=>{}",user.getId());
e.printStackTrace();
}
}
// /**
// * 每天刷新公会援助
// * @param user
// */
// public void everyDayFlushHelpLog(User user){
// try {
// GuildLogic.sendGuildHelpRewardEmail(user);
// GuildMyInfo guildMyInfo = user.getGuildMyInfo();
// guildMyInfo.setGuidHelpInfo(new HashMap<>());
// guildMyInfo.setGuidHelpHadTakeInfo(new HashMap<>());
// guildMyInfo.setGuildHelpSendTime(0);
// guildMyInfo.setGuildHelpReward(false);
// guildMyInfo.setGuildHelpTime(0);
// LOGGER.info("公会援助刷新uid=>{}",user.getId());
// } catch (Exception e) {
// LOGGER.error("公会援助报错uid=>{}",user.getId());
// e.printStackTrace();
// }
// }
//sendGuildHelpRewardEmail
public static void sendGuildHelpRewardEmail(User user)throws Exception{

View File

@ -227,6 +227,25 @@ public class MinuteTask extends Thread {
GuildInfo guildInfo = guildInfoEntry.getValue();
// 公会援助日志
guildInfo.clearGuildHelpLog();
// 公会援助刷新
Set<Integer> sendUids = new HashSet<>();
for (Set<Integer> items : guildInfo.getMembers().values()) {
sendUids.addAll(items);
}
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);
LOGGER.info("公会援助刷新uid=>{}", sendUid);
});
ProtocolsManager.getInstance().updateAyncWorker(ayyncWorker);
}
//入库
MongoUtil.getInstence().lastUpdate();
}