back_recharge
duhui 2023-01-24 10:26:15 +08:00
parent f32826aa3e
commit 0c51449a16
1 changed files with 90 additions and 85 deletions

View File

@ -38,92 +38,97 @@ public class KtEventUtils {
public static void onKtEvent(User user, int eventType, Object... parm) { public static void onKtEvent(User user, int eventType, Object... parm) {
ParamEventBean paramEventBean = new ParamEventBean(eventType); try {
switch (eventType) { ParamEventBean paramEventBean = new ParamEventBean(eventType);
case ParamEventBean.UserActivityEvent: switch (eventType) {
int activityId = (int) parm[0]; case ParamEventBean.UserActivityEvent:
SGlobalActivity sGlobalActivity = SGlobalActivity.getsGlobalActivityMap().get(activityId); int activityId = (int) parm[0];
paramEventBean.add(sGlobalActivity.getSesc()); SGlobalActivity sGlobalActivity = SGlobalActivity.getsGlobalActivityMap().get(activityId);
paramEventBean.add(sGlobalActivity.getSesc()); paramEventBean.add(sGlobalActivity.getSesc());
paramEventBean.add(parm[1].toString()); paramEventBean.add(sGlobalActivity.getSesc());
paramEventBean.add("COMPLETE"); paramEventBean.add(parm[1].toString());
break; paramEventBean.add("COMPLETE");
case ParamEventBean.UserItemEvent: break;
case ParamEventBean.UserCurrencyEvent: case ParamEventBean.UserItemEvent:
int useReson = (int) parm[0]; case ParamEventBean.UserCurrencyEvent:
int useType = (int) parm[1]; int useReson = (int) parm[0];
int itemId = (int) parm[2]; int useType = (int) parm[1];
long itemNum = (long) parm[3]; int itemId = (int) parm[2];
long itemTotalNum = (long) parm[4]; long itemNum = (long) parm[3];
paramEventBean.add(itemUseType[useType]); long itemTotalNum = (long) parm[4];
paramEventBean.add(String.valueOf(useReson)); paramEventBean.add(itemUseType[useType]);
if (currencyMap.containsKey(itemId)) { paramEventBean.add(String.valueOf(useReson));
paramEventBean.add(currencyMap.get(itemId)); if (currencyMap.containsKey(itemId)) {
} else { paramEventBean.add(currencyMap.get(itemId));
paramEventBean.add(String.valueOf(itemId)); } else {
} paramEventBean.add(String.valueOf(itemId));
paramEventBean.add(String.valueOf(itemNum)); }
PlayerManager playerInfoManager = user.getPlayerInfoManager(); paramEventBean.add(String.valueOf(itemNum));
if (parm.length == 6) { PlayerManager playerInfoManager = user.getPlayerInfoManager();
String sbReson = String.valueOf(parm[5]); if (parm.length == 6) {
BILog.info("itemflow {}|{}|{}|{}|{}|{}|{}|{}|{}", user.getId(), playerInfoManager.getLevel(), playerInfoManager.getVipLevel(), useType, useReson, itemId, itemNum, itemTotalNum, sbReson); String sbReson = String.valueOf(parm[5]);
} else { BILog.info("itemflow {}|{}|{}|{}|{}|{}|{}|{}|{}", user.getId(), playerInfoManager.getLevel(), playerInfoManager.getVipLevel(), useType, useReson, itemId, itemNum, itemTotalNum, sbReson);
BILog.info("itemflow {}|{}|{}|{}|{}|{}|{}|{}", user.getId(), playerInfoManager.getLevel(), playerInfoManager.getVipLevel(), useType, useReson, itemId, itemNum, itemTotalNum); } else {
} BILog.info("itemflow {}|{}|{}|{}|{}|{}|{}|{}", user.getId(), playerInfoManager.getLevel(), playerInfoManager.getVipLevel(), useType, useReson, itemId, itemNum, itemTotalNum);
break; }
case ParamEventBean.UserLoginOutEvent: break;
case ParamEventBean.UserLogin: case ParamEventBean.UserLoginOutEvent:
int loginType = (int) parm[0]; case ParamEventBean.UserLogin:
paramEventBean.add(userloginType[loginType]); int loginType = (int) parm[0];
break; paramEventBean.add(userloginType[loginType]);
case ParamEventBean.UserStoreEvent: break;
int storeId = (int) parm[0]; case ParamEventBean.UserStoreEvent:
int buyItemId = (int) parm[1]; int storeId = (int) parm[0];
int goldType = (int) parm[2]; int buyItemId = (int) parm[1];
int buyTimes = (int) parm[3]; int goldType = (int) parm[2];
int costTotal = (int) parm[4]; int buyTimes = (int) parm[3];
paramEventBean.add(String.valueOf(storeId)); int costTotal = (int) parm[4];
paramEventBean.add(String.valueOf(buyItemId)); paramEventBean.add(String.valueOf(storeId));
if (currencyMap.containsKey(goldType)) { paramEventBean.add(String.valueOf(buyItemId));
paramEventBean.add(currencyMap.get(goldType)); if (currencyMap.containsKey(goldType)) {
} else { paramEventBean.add(currencyMap.get(goldType));
paramEventBean.add(Integer.toString(goldType)); } else {
} paramEventBean.add(Integer.toString(goldType));
paramEventBean.add(String.valueOf(buyTimes)); }
paramEventBean.add(String.valueOf(costTotal / buyTimes)); paramEventBean.add(String.valueOf(buyTimes));
paramEventBean.add(String.valueOf(costTotal)); paramEventBean.add(String.valueOf(costTotal / buyTimes));
break; paramEventBean.add(String.valueOf(costTotal));
case ParamEventBean.UserPayEvent: break;
int goodsId = (int) parm[0]; case ParamEventBean.UserPayEvent:
String orderId = (String) parm[1]; int goodsId = (int) parm[0];
String payValid = payResult[(int) parm[2]]; String orderId = (String) parm[1];
String amount = String.valueOf(((double) parm[3])); String payValid = payResult[(int) parm[2]];
SRechargeCommodityNewConfig sRechargeCommodityConfig = SRechargeCommodityNewConfig.configMap.get(goodsId); String amount = String.valueOf(((double) parm[3]));
paramEventBean.add(sRechargeCommodityConfig.getName()); SRechargeCommodityNewConfig sRechargeCommodityConfig = SRechargeCommodityNewConfig.configMap.get(goodsId);
paramEventBean.add(orderId); paramEventBean.add(sRechargeCommodityConfig.getName());
paramEventBean.add(payValid); paramEventBean.add(orderId);
paramEventBean.add(amount); paramEventBean.add(payValid);
break; paramEventBean.add(amount);
case ParamEventBean.UserRegister: break;
break; case ParamEventBean.UserRegister:
case ParamEventBean.UserTaskEvent: break;
int misionType = (int) parm[0]; case ParamEventBean.UserTaskEvent:
int misionId = (int) parm[1]; int misionType = (int) parm[0];
paramEventBean.add(misionType + "_" + misionId); int misionId = (int) parm[1];
paramEventBean.add("COMPLETE"); paramEventBean.add(misionType + "_" + misionId);
break; paramEventBean.add("COMPLETE");
case ParamEventBean.UserGameType: break;
paramEventBean.add("玩法"); case ParamEventBean.UserGameType:
String type = KTGameType.getName((int) parm[0]); paramEventBean.add("玩法");
paramEventBean.add(String.valueOf(type)); String type = KTGameType.getName((int) parm[0]);
paramEventBean.add(String.valueOf(parm[1])); paramEventBean.add(String.valueOf(type));
paramEventBean.add("COMPLETE"); paramEventBean.add(String.valueOf(parm[1]));
eventType = ParamEventBean.UserActivityEvent; paramEventBean.add("COMPLETE");
break; eventType = ParamEventBean.UserActivityEvent;
} break;
}
KTParam ktParam = ParamBuilder.paramBuild(user, eventType, paramEventBean); KTParam ktParam = ParamBuilder.paramBuild(user, eventType, paramEventBean);
DataMessageUtils.addLogQueue(ktParam); DataMessageUtils.addLogQueue(ktParam);
}catch (Exception e){
LOGGER.error("开天上报异常:{}",e.getMessage());
e.printStackTrace();
}
} }
public static ParamEnvironmentBean enviromentBuild(int uid) { public static ParamEnvironmentBean enviromentBuild(int uid) {