From 0c51449a16e8c380a3fca20e9fb75f9364fd17e6 Mon Sep 17 00:00:00 2001 From: duhui Date: Tue, 24 Jan 2023 10:26:15 +0800 Subject: [PATCH] 02 --- .../ljsd/jieling/ktbeans/KtEventUtils.java | 175 +++++++++--------- 1 file changed, 90 insertions(+), 85 deletions(-) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/ktbeans/KtEventUtils.java b/serverlogic/src/main/java/com/ljsd/jieling/ktbeans/KtEventUtils.java index 41862fc2c..83be8d2f3 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/ktbeans/KtEventUtils.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/ktbeans/KtEventUtils.java @@ -38,92 +38,97 @@ public class KtEventUtils { public static void onKtEvent(User user, int eventType, Object... parm) { - ParamEventBean paramEventBean = new ParamEventBean(eventType); - switch (eventType) { - case ParamEventBean.UserActivityEvent: - int activityId = (int) parm[0]; - SGlobalActivity sGlobalActivity = SGlobalActivity.getsGlobalActivityMap().get(activityId); - paramEventBean.add(sGlobalActivity.getSesc()); - paramEventBean.add(sGlobalActivity.getSesc()); - paramEventBean.add(parm[1].toString()); - paramEventBean.add("COMPLETE"); - break; - case ParamEventBean.UserItemEvent: - case ParamEventBean.UserCurrencyEvent: - int useReson = (int) parm[0]; - int useType = (int) parm[1]; - int itemId = (int) parm[2]; - long itemNum = (long) parm[3]; - long itemTotalNum = (long) parm[4]; - paramEventBean.add(itemUseType[useType]); - paramEventBean.add(String.valueOf(useReson)); - if (currencyMap.containsKey(itemId)) { - paramEventBean.add(currencyMap.get(itemId)); - } else { - paramEventBean.add(String.valueOf(itemId)); - } - paramEventBean.add(String.valueOf(itemNum)); - PlayerManager playerInfoManager = user.getPlayerInfoManager(); - if (parm.length == 6) { - String sbReson = String.valueOf(parm[5]); - BILog.info("itemflow {}|{}|{}|{}|{}|{}|{}|{}|{}", user.getId(), playerInfoManager.getLevel(), playerInfoManager.getVipLevel(), useType, useReson, itemId, itemNum, itemTotalNum, sbReson); - } else { - BILog.info("itemflow {}|{}|{}|{}|{}|{}|{}|{}", user.getId(), playerInfoManager.getLevel(), playerInfoManager.getVipLevel(), useType, useReson, itemId, itemNum, itemTotalNum); - } - break; - case ParamEventBean.UserLoginOutEvent: - case ParamEventBean.UserLogin: - int loginType = (int) parm[0]; - paramEventBean.add(userloginType[loginType]); - break; - case ParamEventBean.UserStoreEvent: - int storeId = (int) parm[0]; - int buyItemId = (int) parm[1]; - int goldType = (int) parm[2]; - int buyTimes = (int) parm[3]; - int costTotal = (int) parm[4]; - paramEventBean.add(String.valueOf(storeId)); - paramEventBean.add(String.valueOf(buyItemId)); - if (currencyMap.containsKey(goldType)) { - paramEventBean.add(currencyMap.get(goldType)); - } else { - paramEventBean.add(Integer.toString(goldType)); - } - paramEventBean.add(String.valueOf(buyTimes)); - paramEventBean.add(String.valueOf(costTotal / buyTimes)); - paramEventBean.add(String.valueOf(costTotal)); - break; - case ParamEventBean.UserPayEvent: - int goodsId = (int) parm[0]; - String orderId = (String) parm[1]; - String payValid = payResult[(int) parm[2]]; - String amount = String.valueOf(((double) parm[3])); - SRechargeCommodityNewConfig sRechargeCommodityConfig = SRechargeCommodityNewConfig.configMap.get(goodsId); - paramEventBean.add(sRechargeCommodityConfig.getName()); - paramEventBean.add(orderId); - paramEventBean.add(payValid); - paramEventBean.add(amount); - break; - case ParamEventBean.UserRegister: - break; - case ParamEventBean.UserTaskEvent: - int misionType = (int) parm[0]; - int misionId = (int) parm[1]; - paramEventBean.add(misionType + "_" + misionId); - paramEventBean.add("COMPLETE"); - break; - case ParamEventBean.UserGameType: - paramEventBean.add("玩法"); - String type = KTGameType.getName((int) parm[0]); - paramEventBean.add(String.valueOf(type)); - paramEventBean.add(String.valueOf(parm[1])); - paramEventBean.add("COMPLETE"); - eventType = ParamEventBean.UserActivityEvent; - break; - } + try { + ParamEventBean paramEventBean = new ParamEventBean(eventType); + switch (eventType) { + case ParamEventBean.UserActivityEvent: + int activityId = (int) parm[0]; + SGlobalActivity sGlobalActivity = SGlobalActivity.getsGlobalActivityMap().get(activityId); + paramEventBean.add(sGlobalActivity.getSesc()); + paramEventBean.add(sGlobalActivity.getSesc()); + paramEventBean.add(parm[1].toString()); + paramEventBean.add("COMPLETE"); + break; + case ParamEventBean.UserItemEvent: + case ParamEventBean.UserCurrencyEvent: + int useReson = (int) parm[0]; + int useType = (int) parm[1]; + int itemId = (int) parm[2]; + long itemNum = (long) parm[3]; + long itemTotalNum = (long) parm[4]; + paramEventBean.add(itemUseType[useType]); + paramEventBean.add(String.valueOf(useReson)); + if (currencyMap.containsKey(itemId)) { + paramEventBean.add(currencyMap.get(itemId)); + } else { + paramEventBean.add(String.valueOf(itemId)); + } + paramEventBean.add(String.valueOf(itemNum)); + PlayerManager playerInfoManager = user.getPlayerInfoManager(); + if (parm.length == 6) { + String sbReson = String.valueOf(parm[5]); + BILog.info("itemflow {}|{}|{}|{}|{}|{}|{}|{}|{}", user.getId(), playerInfoManager.getLevel(), playerInfoManager.getVipLevel(), useType, useReson, itemId, itemNum, itemTotalNum, sbReson); + } else { + BILog.info("itemflow {}|{}|{}|{}|{}|{}|{}|{}", user.getId(), playerInfoManager.getLevel(), playerInfoManager.getVipLevel(), useType, useReson, itemId, itemNum, itemTotalNum); + } + break; + case ParamEventBean.UserLoginOutEvent: + case ParamEventBean.UserLogin: + int loginType = (int) parm[0]; + paramEventBean.add(userloginType[loginType]); + break; + case ParamEventBean.UserStoreEvent: + int storeId = (int) parm[0]; + int buyItemId = (int) parm[1]; + int goldType = (int) parm[2]; + int buyTimes = (int) parm[3]; + int costTotal = (int) parm[4]; + paramEventBean.add(String.valueOf(storeId)); + paramEventBean.add(String.valueOf(buyItemId)); + if (currencyMap.containsKey(goldType)) { + paramEventBean.add(currencyMap.get(goldType)); + } else { + paramEventBean.add(Integer.toString(goldType)); + } + paramEventBean.add(String.valueOf(buyTimes)); + paramEventBean.add(String.valueOf(costTotal / buyTimes)); + paramEventBean.add(String.valueOf(costTotal)); + break; + case ParamEventBean.UserPayEvent: + int goodsId = (int) parm[0]; + String orderId = (String) parm[1]; + String payValid = payResult[(int) parm[2]]; + String amount = String.valueOf(((double) parm[3])); + SRechargeCommodityNewConfig sRechargeCommodityConfig = SRechargeCommodityNewConfig.configMap.get(goodsId); + paramEventBean.add(sRechargeCommodityConfig.getName()); + paramEventBean.add(orderId); + paramEventBean.add(payValid); + paramEventBean.add(amount); + break; + case ParamEventBean.UserRegister: + break; + case ParamEventBean.UserTaskEvent: + int misionType = (int) parm[0]; + int misionId = (int) parm[1]; + paramEventBean.add(misionType + "_" + misionId); + paramEventBean.add("COMPLETE"); + break; + case ParamEventBean.UserGameType: + paramEventBean.add("玩法"); + String type = KTGameType.getName((int) parm[0]); + paramEventBean.add(String.valueOf(type)); + paramEventBean.add(String.valueOf(parm[1])); + paramEventBean.add("COMPLETE"); + eventType = ParamEventBean.UserActivityEvent; + break; + } - KTParam ktParam = ParamBuilder.paramBuild(user, eventType, paramEventBean); - DataMessageUtils.addLogQueue(ktParam); + KTParam ktParam = ParamBuilder.paramBuild(user, eventType, paramEventBean); + DataMessageUtils.addLogQueue(ktParam); + }catch (Exception e){ + LOGGER.error("开天上报异常:{}",e.getMessage()); + e.printStackTrace(); + } } public static ParamEnvironmentBean enviromentBuild(int uid) {