公会援助修改

back_recharge
duhui 2023-03-06 17:33:43 +08:00
parent e80315ca22
commit 8c634d7df2
3 changed files with 46 additions and 21 deletions

View File

@ -439,6 +439,9 @@ public class GlobalDataManaager implements IManager {
SevenWorldLogic.getInstance().sevenWorldInfoIndication(session);
// 御剑行
RidingSwardLogic.getInstance().zeroClearRidingSwardByUser(user);
// 公会援助
GuildLogic.getInstance().guildHelpDayHandler(user);
WeekCardLogic.getInstance().weekCardInfoIndication(user,0,0);
ChallengeLogic.getInstance().ChallengeInfoIndication(session);
if(TimeUtils.isSpanTime(user.getPlayerInfoManager().getLoginTime(),TimeUtils.now(),1,0)){

View File

@ -1698,7 +1698,22 @@ public class GuildLogic {
}
String mailReward = ItemUtil.getMailReward(list);
MailLogic.getInstance().sendMail(user.getId(),title,content,mailReward,(int) (TimeUtils.now()/1000), Global.MAIL_EFFECTIVE_TIME);
MailLogic.getInstance().sendMail(user.getId(),title,content,mailReward,TimeUtils.nowInt(), Global.MAIL_EFFECTIVE_TIME);
}
public void guildHelpDayHandler(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);
} catch (Exception e) {
throw new RuntimeException(e);
}
LOGGER.info("公会援助刷新uid=>{}", user.getId());
}
//检测是否到了最大等级

View File

@ -14,6 +14,7 @@ import com.ljsd.jieling.logic.GlobleSystemLogic;
import com.ljsd.jieling.logic.OnlineUserManager;
import com.ljsd.jieling.logic.SituationLogic;
import com.ljsd.jieling.logic.activity.ActivityLogic;
import com.ljsd.jieling.logic.activity.crossService.CrossServiceLogic;
import com.ljsd.jieling.logic.activity.event.MinuteTaskEvent;
import com.ljsd.jieling.logic.activity.event.Poster;
import com.ljsd.jieling.logic.activity.fourChallenge.FourChallengeLogic;
@ -23,6 +24,7 @@ import com.ljsd.jieling.logic.arena.CrossYuxulundaoLogic;
import com.ljsd.jieling.logic.dao.GuildMyInfo;
import com.ljsd.jieling.logic.dao.GuilidManager;
import com.ljsd.jieling.logic.dao.UserManager;
import com.ljsd.jieling.logic.dao.cross.CSPlayer;
import com.ljsd.jieling.logic.dao.root.GuildInfo;
import com.ljsd.jieling.logic.dao.root.User;
import com.ljsd.jieling.logic.explorerMap.ExplorerMapLogic;
@ -261,26 +263,31 @@ public class MinuteTask extends Thread {
guildInfo.clearGuildHelpLog();
GuilidManager.saveOrUpdateGuildInfo(guildInfo);
LOGGER.info("{}更新公会援助日志完毕",guildInfoEntry.getValue().getName());
// 公会援助刷新
Set<Integer> sendUids = new HashSet<>();
guildInfo.getMembers().values().forEach(sendUids::addAll);
for (Integer sendUid : sendUids) {
User target = UserManager.getUserNotCache(sendUid);
if (target == null){
continue;
}
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);
}
// // 公会援助刷新
// Set<Integer> sendUids = new HashSet<>();
// guildInfo.getMembers().values().forEach(sendUids::addAll);
// for (Integer sendUid : sendUids) {
// CSPlayer player = CrossServiceLogic.getPlayerByRedis(sendUid);
// if (player == null || TimeUtils.now() > (player.getOffLineTime()+TimeUtils.WEEK)){
// LOGGER.error("公会援助刷新玩家未登陆时间超过七天不予发奖uid{}",sendUid);
// continue;
// }
// User target = UserManager.getUserNotCache(sendUid);
// if (target == null){
// continue;
// }
// 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);
// }
}catch (Exception e){
e.printStackTrace();
}