diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/activity/SheJiActivity.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/activity/SheJiActivity.java index e51de2901..66987f54d 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/activity/SheJiActivity.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/activity/SheJiActivity.java @@ -1,7 +1,10 @@ package com.ljsd.jieling.logic.activity; import com.ljsd.jieling.core.Lockeys; +import com.ljsd.jieling.core.SimpleTransaction; import com.ljsd.jieling.db.mongo.MongoUtil; +import com.ljsd.jieling.db.redis.RedisKey; +import com.ljsd.jieling.db.redis.RedisUtil; import com.ljsd.jieling.exception.ErrorCode; import com.ljsd.jieling.exception.ErrorCodeException; import com.ljsd.jieling.globals.BIReason; @@ -13,10 +16,12 @@ import com.ljsd.jieling.logic.activity.event.CommitSheJiEvent; import com.ljsd.jieling.logic.activity.event.IEvent; import com.ljsd.jieling.logic.activity.event.Poster; import com.ljsd.jieling.logic.activity.event.SignInEvent; +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.root.GuildInfo; import com.ljsd.jieling.logic.dao.root.User; +import com.ljsd.jieling.logic.family.GuildLogic; import com.ljsd.jieling.logic.mail.MailLogic; import com.ljsd.jieling.logic.rank.RankContext; import com.ljsd.jieling.logic.rank.RankEnum; @@ -46,7 +51,26 @@ class SheJiActivity extends AbstractActivity { @Override public void onActivityStart() throws Exception { - super.onActivityStart(); + + Map guildInfoMap = GuilidManager.guildInfoMap; + for(Map.Entry guildInfoEntry:guildInfoMap.entrySet()){ + try { + SimpleTransaction transaction = SimpleTransaction.current(); + GuildInfo guildInfo = guildInfoEntry.getValue(); + Set sendUids = new HashSet<>(); + for (Set items : guildInfo.getMembers().values()) { + sendUids.addAll(items); + } + Lockeys.getLockeys().lock("guild",sendUids); + guildInfo.setGuildSheJiScore(0); + }catch (Exception e){ + LOGGER.error("Exception resetGuildInfo err"); + }finally { + SimpleTransaction.remove(); + MongoUtil.getInstence().lastUpdate(); + } + + } } @Override @@ -62,6 +86,8 @@ class SheJiActivity extends AbstractActivity { } } } + + } @Override