From aab51ba39c013c9891f0c4b8e21157463e27cf77 Mon Sep 17 00:00:00 2001 From: zhangshanxue Date: Mon, 2 Dec 2019 18:32:40 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BA=94=E6=98=9F=E6=88=90=E9=95=BF=E7=A4=BC?= =?UTF-8?q?=E6=8C=89=E5=A4=A9=E5=88=B7=E6=96=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/ljsd/jieling/logic/GlobalDataManaager.java | 2 ++ .../com/ljsd/jieling/logic/dao/RechargeInfo.java | 2 +- .../com/ljsd/jieling/logic/store/BuyGoodsLogic.java | 13 +++++++++++++ 3 files changed, 16 insertions(+), 1 deletion(-) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/GlobalDataManaager.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/GlobalDataManaager.java index 6f343ca56..aa50b7c17 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/GlobalDataManaager.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/GlobalDataManaager.java @@ -25,6 +25,7 @@ import com.ljsd.jieling.logic.mission.GameMisionType; import com.ljsd.jieling.logic.mission.data.DataManagerDistributor; import com.ljsd.jieling.logic.mission.event.MissionEventDistributor; import com.ljsd.jieling.logic.player.PlayerLogic; +import com.ljsd.jieling.logic.store.BuyGoodsLogic; import com.ljsd.jieling.logic.store.StoreLogic; import com.ljsd.jieling.netty.cocdex.PacketNetData; import com.ljsd.jieling.netty.cocdex.Tea; @@ -302,6 +303,7 @@ public class GlobalDataManaager { ActivityLogic.getInstance().flushEveryDay(user,fBuilder); PlayerLogic.getInstance().vipflushEveryDay(user,fBuilder); PlayerLogic.getInstance().flushUserdataEvery(user,fBuilder); + BuyGoodsLogic.flushEveryDay(user); user.getUserMissionManager().onGameEvent(user, GameEvent.DAILY_REFRESH,0); user.getUserMissionManager().onGameEvent(user, GameEvent.BLOODY_REFRESH,0); FriendLogic.getInstance().refreshState(session); diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/dao/RechargeInfo.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/dao/RechargeInfo.java index 0949e62c5..15558663d 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/dao/RechargeInfo.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/dao/RechargeInfo.java @@ -18,7 +18,7 @@ public class RechargeInfo extends MongoBase{ @Transient - private Set cacheSendedIds = new ConcurrentSet<>(); + private volatile Set cacheSendedIds = new ConcurrentSet<>(); private Map levelBagMap = new HashMap<>(); private Map buyGoodsTimes = new HashMap<>(); diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/store/BuyGoodsLogic.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/store/BuyGoodsLogic.java index bad9bd6e2..b0198c162 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/store/BuyGoodsLogic.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/store/BuyGoodsLogic.java @@ -43,6 +43,19 @@ public class BuyGoodsLogic { private static final Logger LOGGER = LoggerFactory.getLogger(BuyGoodsLogic.class); + public static void flushEveryDay(User user) throws Exception { + //更新5星成长礼 + user.getPlayerInfoManager().getRechargeInfo().getBuyGoodsTimes().put(21,0); + List goodsBagInfo = new ArrayList<>(SRechargeCommodityConfig.rechargeCommodityConfigMap.size()); + BuyGoodsLogic.getGoodsBagInfo(user.getId(), goodsBagInfo,false); + ISession session = OnlineUserManager.getSessionByUid(user.getId()); + if(session!=null){ + PlayerInfoProto.AllGiftGoodsIndication build = PlayerInfoProto.AllGiftGoodsIndication.newBuilder().addAllGiftGoodsInfo(goodsBagInfo).build(); + MessageUtil.sendIndicationMessage(session,1, MessageTypeProto.MessageType.ALL_GIFTGOODS_INDICATION_VALUE,build,true); + } + } + + public static void testBuyGoods(ISession session,int goodsId) throws Exception { int uid = session.getUid(); SRechargeCommodityConfig sRechargeCommodityConfig = SRechargeCommodityConfig.rechargeCommodityConfigMap.get(goodsId);