diff --git a/serverlogic/src/main/java/com/ljsd/jieling/thread/task/MinuteTask.java b/serverlogic/src/main/java/com/ljsd/jieling/thread/task/MinuteTask.java index 7239a3dc5..fb4a56bd5 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/thread/task/MinuteTask.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/thread/task/MinuteTask.java @@ -36,6 +36,8 @@ 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 config.SChallengeMapConfig; +import config.SRechargeCommodityNewConfig; import manager.STableManager; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -141,6 +143,33 @@ public class MinuteTask extends Thread { try { ArenaLogic.getInstance().worldSendReward(); + if(STableManager.getConfig(SRechargeCommodityNewConfig.class).size()!= SRechargeCommodityNewConfig.configMap.size()){ + + Map config = STableManager.getConfig(SRechargeCommodityNewConfig.class); + Map tempConfigMap = new HashMap<>(); + Map tempSdkConfigMap = new HashMap<>(); + Map> tempConfigTypeMap = new HashMap<>(); + for(SRechargeCommodityNewConfig newConfig : config.values()){ + newConfig.setCondition(newConfig.initConditon(newConfig)); + tempConfigMap.put(newConfig.getId(),newConfig); + tempSdkConfigMap.put(newConfig.getRechargeId(),newConfig); + tempSdkConfigMap.put(newConfig.getRechargeId2(),newConfig); + tempSdkConfigMap.put(newConfig.getRechargeId3(),newConfig); + if(tempConfigTypeMap.containsKey(newConfig.getType())){ + tempConfigTypeMap.get(newConfig.getType()).add(newConfig.getId()); + }else{ + List list = new ArrayList<>(); + list.add(newConfig.getId()); + tempConfigTypeMap.put(newConfig.getType(),list); + } + } +// if(configMap == null){ + SRechargeCommodityNewConfig.configMap = tempConfigMap; + LOGGER.info("修复重新加载Recharge"); + SRechargeCommodityNewConfig.sdkconfigMap = tempSdkConfigMap; + SRechargeCommodityNewConfig.configTypeMap = tempConfigTypeMap; + + } }catch (Exception e){ e.printStackTrace(); LOGGER.error("Exception::=>{}",e.toString());