应该是重连上的session

back_recharge
zhangshanxue 2020-05-23 00:33:06 +08:00
parent eda4141f3b
commit f91f204848
2 changed files with 9 additions and 1 deletions

View File

@ -295,7 +295,7 @@ public class BuyGoodsLogic {
resultRes.setResultCode(1); resultRes.setResultCode(1);
KtEventUtils.onKtEvent(user, ParamEventBean.UserPayEvent,goodsId,orderId,resultRes.getResultCode(),price); KtEventUtils.onKtEvent(user, ParamEventBean.UserPayEvent,goodsId,orderId,resultRes.getResultCode(),price);
notifyPaySuccessFul(uid,goodsId,amount != -999); notifyPaySuccessFul(uid,goodsId,amount != -999);
Poster.getPoster().dispatchEvent(new NewWelfareEvent(user, NewWelfareTypeEnum.RECHARGE_BUY.getType(),goodsId)); // Poster.getPoster().dispatchEvent(new NewWelfareEvent(user, NewWelfareTypeEnum.RECHARGE_BUY.getType(),goodsId));
MongoUtil.getLjsdMongoTemplate().lastUpdate(); MongoUtil.getLjsdMongoTemplate().lastUpdate();
sendGiftGooodsIndication(uid); sendGiftGooodsIndication(uid);
return resultRes; return resultRes;

View File

@ -88,6 +88,10 @@ public class StoreLogic implements IEventHandler {
for(ISession session : OnlineUserManager.sessionMap.values()){ for(ISession session : OnlineUserManager.sessionMap.values()){
if(session.getFiveReady() == 1){ if(session.getFiveReady() == 1){
User user = UserManager.getUser(session.getUid()); User user = UserManager.getUser(session.getUid());
if(user==null){
OnlineUserManager.sessionMap.remove(session.getUid());
continue;
}
long userCreateTime = user.getPlayerInfoManager().getCreateTime(); long userCreateTime = user.getPlayerInfoManager().getCreateTime();
long startTime = ToolsUtil.getTimeLong(sStoreTypeConfig.getStartTimeLong(), sStoreTypeConfig.getEndTimeLong(),ActivityType.OPEN_TYPE_ROLE,userCreateTime, 1); long startTime = ToolsUtil.getTimeLong(sStoreTypeConfig.getStartTimeLong(), sStoreTypeConfig.getEndTimeLong(),ActivityType.OPEN_TYPE_ROLE,userCreateTime, 1);
long endTime = ToolsUtil.getTimeLong(sStoreTypeConfig.getStartTimeLong(),sStoreTypeConfig.getEndTimeLong(), ActivityType.OPEN_TYPE_ROLE,userCreateTime, 2); long endTime = ToolsUtil.getTimeLong(sStoreTypeConfig.getStartTimeLong(),sStoreTypeConfig.getEndTimeLong(), ActivityType.OPEN_TYPE_ROLE,userCreateTime, 2);
@ -111,6 +115,10 @@ public class StoreLogic implements IEventHandler {
for(ISession session : OnlineUserManager.sessionMap.values()){ for(ISession session : OnlineUserManager.sessionMap.values()){
if(session.getFiveReady() == 1){ if(session.getFiveReady() == 1){
User user = UserManager.getUser(session.getUid()); User user = UserManager.getUser(session.getUid());
if(user==null){
OnlineUserManager.sessionMap.remove(session.getUid());
continue;
}
if(!user.getStoreManager().getStoreInfoMap().containsKey(sStoreTypeConfig.getId())){ if(!user.getStoreManager().getStoreInfoMap().containsKey(sStoreTypeConfig.getId())){
updateUsersStoreAyync(UserManager.getUser(session.getUid()),user1 -> { updateUsersStoreAyync(UserManager.getUser(session.getUid()),user1 -> {
initOneStore(user1,sStoreTypeConfig.getId()); initOneStore(user1,sStoreTypeConfig.getId());