数据上报

back_recharge
wangyuan 2019-07-05 20:44:18 +08:00
parent c333aade20
commit 002557fad1
8 changed files with 31 additions and 12 deletions

View File

@ -89,7 +89,7 @@ public class GameApplication {
MapLogic.getInstance().init(configurableApplicationContext);
SensitivewordFilter.init();
// HttpPool.init();
HttpPool.init();
// 加载lua文件
CheckFight.getInstance().init("luafight/BattleMain.lua");

View File

@ -99,4 +99,6 @@ public interface BIReason {
int MAP_CONSUME = 1025;
int TIME_REWARD=1026;
}

View File

@ -862,6 +862,10 @@ public class MapLogic {
crossInfo.getStars().clear();
crossInfo.getStars().addAll(mapManager.getStars());
mapManager.updateCrossInfoMap(mapManager.getCurMapId(), crossInfo);
if(crossInfo.getStars().contains(STAR_1)){
user.getUserMissionManager().onGameEvent(user, GameEvent.STORY_FIGHT, mapManager.getCurMapId(), 1,1);
}
}
}
resetMapInfo(user, needTemporaryItem);
@ -1342,7 +1346,6 @@ public class MapLogic {
stars = new HashSet<>();
}
stars.add(STAR_1);
user.getUserMissionManager().onGameEvent(user, GameEvent.STORY_FIGHT, mapManager.getCurMapId(), 1,1);
mapManager.setStars(stars);
//todo 死亡次数
SChallengeConfig sChallengeConfig = SChallengeConfig.sChallengeConfigs.get(mapManager.getCurMapId());
@ -1387,6 +1390,7 @@ public class MapLogic {
}
}
mapManager.updateCrossInfoMap(mapManager.getCurMapId(), crossInfo);
MapMissionManager.processPassMapEvent(user, useTime);
}
mapManager.setMission(mission);

View File

@ -4,8 +4,11 @@ package com.ljsd.jieling.handler.map;
import com.ljsd.common.mogodb.MongoBase;
import com.ljsd.jieling.config.SGameSetting;
import com.ljsd.jieling.core.GlobalsDef;
import com.ljsd.jieling.globals.BIReason;
import com.ljsd.jieling.globals.Global;
import com.ljsd.jieling.handler.mission.Mission;
import com.ljsd.jieling.ktbeans.KtEventUtils;
import com.ljsd.jieling.ktbeans.parmsBean.ParamEventBean;
import com.ljsd.jieling.logic.dao.Item;
import com.ljsd.jieling.logic.dao.PlayerManager;
import com.ljsd.jieling.logic.dao.root.User;
@ -239,6 +242,7 @@ public class MapManager extends MongoBase {
int addValue = MathUtils.setBetweenWithMax(itemNum+recoveryTimes,0,heroTimes);
if(addValue!=0){
item.setItemNum(addValue);
KtEventUtils.onKtEvent(user, ParamEventBean.UserItemEvent, BIReason.TIME_REWARD,GlobalsDef.subReason,item.getItemId(),addValue,item.getItemNum());
}
}
int time = lastUpdateEnergyTime + recoveryTimes*recoveryTime;
@ -261,6 +265,7 @@ public class MapManager extends MongoBase {
if (addValue != 0) {
int curEnergy = MathUtils.setBetweenWithMax(itemNum + addValue, 0, playerInfoManager.getMaxStamina());
item.setItemNum(curEnergy > playerInfoManager.getMaxStamina() ? playerInfoManager.getMaxStamina() : curEnergy);
KtEventUtils.onKtEvent(user, ParamEventBean.UserItemEvent, BIReason.TIME_REWARD,GlobalsDef.subReason,item.getItemId(),addValue,item.getItemNum());
}
setLastUpdateEnergyTime(item, updateTime, lastUpdateEnergyTime);
} else {

View File

@ -7,6 +7,7 @@ import com.ljsd.jieling.globals.Global;
import com.ljsd.jieling.ktbeans.BeanBuilder.ParamBuilder;
import com.ljsd.jieling.ktbeans.parmsBean.ParamEventBean;
import com.ljsd.jieling.ktbeans.parmsBean.*;
import com.ljsd.jieling.logic.dao.PlayerManager;
import com.ljsd.jieling.logic.dao.root.User;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@ -19,7 +20,7 @@ public class KtEventUtils {
private static String[] itemUseType = new String[]{"source","sink"}; //固定字符source 表示收入sink 表示支出
private static String[] userloginType = new String[]{"LOGIN","LOGOUT"}; //仅两种状态登录LOGIN、登出LOGOUT
private static String[] payResult = new String[]{"INVALID","VALID"}; //仅两种状态登录LOGIN、登出LOGOUT
public static final Logger BILog = LoggerFactory.getLogger("BILog");
private static Map<Integer,String> currencyMap = new HashMap<>();
@ -47,10 +48,13 @@ public class KtEventUtils {
int useType = (int)parm[1];
int itemId = (int)parm[2];
int itemNum = (int)parm[3];
int itemTotalNum = (int)parm[4];
paramEventBean.add(itemUseType[useType]);
paramEventBean.add(String.valueOf(useReson));
paramEventBean.add(String.valueOf(itemId));
paramEventBean.add(String.valueOf(itemNum));
// PlayerManager playerInfoManager = user.getPlayerInfoManager();
// BILog.info("itemflow {}|{}|{}|{}|{}|{}|{}|{}",user.getId(), playerInfoManager.getLevel(), playerInfoManager.getVipLevel(),useType,useReson,itemId,itemNum,itemTotalNum);
break;
case ParamEventBean.UserLoginOutEvent:
case ParamEventBean.UserLogin:
@ -94,7 +98,7 @@ public class KtEventUtils {
KTParam ktParam = ParamBuilder.paramBuild(user, eventType, paramEventBean);
DataMessageUtils.addLogQueue(ktParam);
LOGGER.info("ktparm -- > {}",gson.toJson(ktParam));
// LOGGER.info("ktparm -- > {}",gson.toJson(ktParam));
}
public static ParamEnvironmentBean enviromentBuild(int uid){
return KTEnvironmentUtil.getUserEnviromentInfoById(uid);

View File

@ -700,9 +700,11 @@ public class CombatLogic {
builder.setKillRewards(killReward);
user.getUserMissionManager().onGameEvent(user, GameEvent.KILLINVASIONBOSS);
RedisUtil.getInstence().removeMapEntrys(RedisKey.ADVENTRUEN_BOSS_INFO,"",bossId);
ISession findSession = OnlineUserManager.getSessionByUid(adventureBoss.getFindUserId());
if(findSession!=null){
MessageUtil.sendIndicationMessage(findSession,1, MessageTypeProto.MessageType.ADVENTURE_BOSS_REFRESH_INDICATION_VALUE,null,true);
if(adventureBoss.getFindUserId()!=uid){
ISession findSession = OnlineUserManager.getSessionByUid(adventureBoss.getFindUserId());
if(findSession!=null){
MessageUtil.sendIndicationMessage(findSession,1, MessageTypeProto.MessageType.ADVENTURE_BOSS_REFRESH_INDICATION_VALUE,null,true);
}
}
break;
}

View File

@ -436,7 +436,7 @@ public class ItemUtil {
if(currencyMap.contains(entry.getKey())){
eventType = ParamEventBean.UserCurrencyEvent;
}
KtEventUtils.onKtEvent(user, eventType,reason,GlobalsDef.addReason,entry.getKey(),itemNum);
KtEventUtils.onKtEvent(user, eventType,reason,GlobalsDef.addReason,entry.getKey(),itemNum,item.getItemNum());
if(sItem.getItemType() == GlobalItemType.POKENMON_COMONPENT){
String nickName = user.getPlayerInfoManager().getNickName();
String message = SErrorCodeEerverConfig.getI18NMessage("lamp_lottery_differ_content", new Object[]{nickName,sItem.getName()});
@ -604,11 +604,13 @@ public class ItemUtil {
if(currencyMap.contains(myItem.getItemId())){
eventType = ParamEventBean.UserCurrencyEvent;
}
KtEventUtils.onKtEvent(user, eventType,reason,GlobalsDef.subReason,myItem.getItemId(),needCount);
if (myItem.getItemNum() <= needCount && !notDelete.contains(userItem.getKey())) {
itemManager.removeItem(userItem.getKey());
KtEventUtils.onKtEvent(user, eventType,reason,GlobalsDef.subReason,myItem.getItemId(),needCount,0);
} else {
myItem.setItemNum(myItem.getItemNum() - needCount);
KtEventUtils.onKtEvent(user, eventType,reason,GlobalsDef.subReason,myItem.getItemId(),needCount,myItem.getItemNum());
}
}
user.getUserMissionManager().onGameEvent(user,GameEvent.CONSUMER_MATERIAL,useItemMap);
@ -674,7 +676,7 @@ public class ItemUtil {
continue;
}
addEquip(user, entry.getKey(), equipList);
KtEventUtils.onKtEvent(user, ParamEventBean.UserItemEvent,reason,GlobalsDef.addReason,entry.getKey(),1);
KtEventUtils.onKtEvent(user, ParamEventBean.UserItemEvent,reason,GlobalsDef.addReason,entry.getKey(),1,user.getEquipManager().getEquipMap().size());
}
}
@ -777,7 +779,7 @@ public class ItemUtil {
}
}
user.getUserMissionManager().onGameEvent(user,GameEvent.GET_HERO,heroStar[0],heroStar[1]);
KtEventUtils.onKtEvent(user, ParamEventBean.UserItemEvent,reason,GlobalsDef.addReason,cardId,1);
KtEventUtils.onKtEvent(user, ParamEventBean.UserItemEvent,reason,GlobalsDef.addReason,cardId,1,heroStar[1]);
}
/**

View File

@ -36,7 +36,7 @@ public class HttpPool {
}
public static void sendPost(String url, String info) {
LOGGER.info("the data={}",info);
// LOGGER.info("the data={}",info);
HttpPost httpPost = new HttpPost(url);
HttpResponse httpResponse;
int sendTimes = 0;