diff --git a/serverlogic/src/main/java/com/ljsd/jieling/chat/logic/ChatLogic.java b/serverlogic/src/main/java/com/ljsd/jieling/chat/logic/ChatLogic.java index 2bb46f0bb..2f7756f2f 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/chat/logic/ChatLogic.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/chat/logic/ChatLogic.java @@ -110,10 +110,11 @@ public class ChatLogic { char[] original = unSymbolWord.toCharArray(); char[] tmpChar = tmp.toCharArray(); int j=0; + int length = original.length; char[] result = new char[chars.length]; for(int i=0;i userList = MongoUtil.getInstence().getMyMongoTemplate().findAll(User.getCollectionName(), User.class); + userList.forEach(user -> { + try { + User userInMem = UserManager.getUser(user.getId()); + AyyncWorker ayyncWorker = new AyyncWorker(userInMem, true, new AyncWorkerRunnable() { + @Override + public void work(User user) throws Exception { + MongoUtil.getLjsdMongoTemplate().save(user); + } + }); + ProtocolsManager.getInstance().updateAyncWorker(ayyncWorker); + + } catch (Exception e) { + e.printStackTrace(); + } + }); + + return false; + } +} diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/activity/NewWelfareActivity.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/activity/NewWelfareActivity.java index 6697859f3..d31a500b4 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/activity/NewWelfareActivity.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/activity/NewWelfareActivity.java @@ -19,6 +19,7 @@ import com.ljsd.jieling.util.MessageUtil; import config.SActivityRewardConfig; import config.SGlobalActivity; +import java.util.HashMap; import java.util.List; import java.util.Map; @@ -79,9 +80,12 @@ public class NewWelfareActivity extends AbstractActivity { throw new ErrorCodeException(ErrorCode.SERVER_SELF_DEFINE); } } - for(ActivityProgressInfo activityProgressInfo : activityProgressInfoMap.values()){ - activityProgressInfo.setState(2); + for(Map.Entry item: activityProgressInfoMap.entrySet()){ + item.getValue().setState(2); + activityMission.updateProgressInfo(item.getKey(),item.getValue()); } + + sendActivityProgress(session, activityMission, null); List sActivityRewardConfigs = SActivityRewardConfig.getsActivityRewardConfigByActivityId(id); CommonProto.Drop.Builder drop = ItemUtil.drop(user, sActivityRewardConfigs.get(0).getReward(), BIReason.TAKE_ACTIVITY_REWARD); @@ -107,6 +111,12 @@ public class NewWelfareActivity extends AbstractActivity { for(ActivityProgressInfo activityProgressInfo : activityProgressInfoMap.values()){ activityProgressInfo.setState(2); } + + for(Map.Entry item: activityProgressInfoMap.entrySet()){ + item.getValue().setState(2); + activityMission.updateProgressInfo(item.getKey(),item.getValue()); + } + List sActivityRewardConfigs = SActivityRewardConfig.getsActivityRewardConfigByActivityId(id); itemAttrs.add(sActivityRewardConfigs.get(0).getReward()); }