开天日志关闭

zhangshanxue 2020-07-28 21:01:57 +08:00
parent 93020b9205
commit 5b576dac17
2 changed files with 135 additions and 135 deletions

View File

@ -48,40 +48,40 @@ public class LoginRequestHandler extends BaseHandler<PlayerInfoProto.LoginReques
return; return;
} }
ReportUtil.saveBaseInfo(userId,loginRequest); ReportUtil.saveBaseInfo(userId,loginRequest);
ParamEnvironmentBean paramEnvironmentBean = new ParamEnvironmentBean(); // ParamEnvironmentBean paramEnvironmentBean = new ParamEnvironmentBean();
paramEnvironmentBean.setDevice_id_s(loginRequest.getDeviceIdS()); // paramEnvironmentBean.setDevice_id_s(loginRequest.getDeviceIdS());
paramEnvironmentBean.setIp_s(loginRequest.getIpS()); // paramEnvironmentBean.setIp_s(loginRequest.getIpS());
ParamEnvironmentSimpleBean paramEnvironmentSimpleBean = new ParamEnvironmentSimpleBean("", // ParamEnvironmentSimpleBean paramEnvironmentSimpleBean = new ParamEnvironmentSimpleBean("",
"", // "",
loginRequest.getDeviceIdS(), // loginRequest.getDeviceIdS(),
loginRequest.getBrandS(), // loginRequest.getBrandS(),
loginRequest.getDpiS(), // loginRequest.getDpiS(),
loginRequest.getOperatorS(), // loginRequest.getOperatorS(),
loginRequest.getOsVersionS(), // loginRequest.getOsVersionS(),
LoginParamType.NETWORK_WIFI.equals(loginRequest.getNetworkS())); // LoginParamType.NETWORK_WIFI.equals(loginRequest.getNetworkS()));
switch (loginRequest.getPlatformS()){ // switch (loginRequest.getPlatformS()){
case LoginParamType.PLATFORM_ANDRIOD: // case LoginParamType.PLATFORM_ANDRIOD:
paramEnvironmentSimpleBean.setImei_s(loginRequest.getIdfaSOrImeiS()); // paramEnvironmentSimpleBean.setImei_s(loginRequest.getIdfaSOrImeiS());
break; // break;
case LoginParamType.PLATFORM_IOS: // case LoginParamType.PLATFORM_IOS:
paramEnvironmentSimpleBean.setIdfa_s(loginRequest.getIdfaSOrImeiS()); // paramEnvironmentSimpleBean.setIdfa_s(loginRequest.getIdfaSOrImeiS());
break; // break;
case LoginParamType.PLATFORM_IOS_YY: // case LoginParamType.PLATFORM_IOS_YY:
paramEnvironmentSimpleBean.setIdfa_s(loginRequest.getIdfaSOrImeiS()); // paramEnvironmentSimpleBean.setIdfa_s(loginRequest.getIdfaSOrImeiS());
break; // break;
case LoginParamType.PLATFORM_PC: // case LoginParamType.PLATFORM_PC:
break; // break;
default: // default:
break; // break;
//
} // }
ParamDataBean paramDataBean = new ParamDataBean(); // ParamDataBean paramDataBean = new ParamDataBean();
paramDataBean.setChannel_s(loginRequest.getChannelS()); // paramDataBean.setChannel_s(loginRequest.getChannelS());
KTDataUtil.addUserDataInfo(userId,paramDataBean); // KTDataUtil.addUserDataInfo(userId,paramDataBean);
//
//// KTEnvironmentUtil.addUserEnviromentInfo(userId,paramEnvironmentBean);
// KTEnvironmentUtil.addUserSimpleEnviromentInfo(userId,paramEnvironmentSimpleBean);
// KTEnvironmentUtil.addUserEnviromentInfo(userId,paramEnvironmentBean); // KTEnvironmentUtil.addUserEnviromentInfo(userId,paramEnvironmentBean);
KTEnvironmentUtil.addUserSimpleEnviromentInfo(userId,paramEnvironmentSimpleBean);
KTEnvironmentUtil.addUserEnviromentInfo(userId,paramEnvironmentBean);
int pid = 0; int pid = 0;
int gid = 0; int gid = 0;
@ -101,19 +101,19 @@ public class LoginRequestHandler extends BaseHandler<PlayerInfoProto.LoginReques
} }
//临时代码 等前端出新包后删除2019 11 29 //临时代码 等前端出新包后删除2019 11 29
if(gid==0){ // if(gid==0){
try { // try {
String value =( (String) RedisUtil.getInstence().get(RedisUtil.getInstence().getKey(RedisKey.PIDGIDTEMP, Integer.toString(userId)))).replace("\"", ""); // String value =( (String) RedisUtil.getInstence().get(RedisUtil.getInstence().getKey(RedisKey.PIDGIDTEMP, Integer.toString(userId)))).replace("\"", "");
LOGGER.info("the value={}",value); // LOGGER.info("the value={}",value);
String[] splitvalue = value.split("#"); // String[] splitvalue = value.split("#");
if (splitvalue.length==2){ // if (splitvalue.length==2){
pid = Integer.valueOf(splitvalue[0]); // pid = Integer.valueOf(splitvalue[0]);
gid = Integer.valueOf(splitvalue[1]); // gid = Integer.valueOf(splitvalue[1]);
} // }
}catch (Exception e){ // }catch (Exception e){
e.getMessage(); // e.getMessage();
} // }
} // }
LOGGER.info("the uid={},the pid={},the gid={},",userId,pid,gid); LOGGER.info("the uid={},the pid={},the gid={},",userId,pid,gid);
//登陆注册入内存 //登陆注册入内存

View File

@ -41,95 +41,95 @@ 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); // ParamEventBean paramEventBean = new ParamEventBean(eventType);
switch (eventType){ // switch (eventType){
case ParamEventBean.UserActivityEvent: // case ParamEventBean.UserActivityEvent:
int activityId = (int)parm[0]; // int activityId = (int)parm[0];
SGlobalActivity sGlobalActivity = SGlobalActivity.getsGlobalActivityMap().get(activityId); // SGlobalActivity sGlobalActivity = SGlobalActivity.getsGlobalActivityMap().get(activityId);
paramEventBean.add(sGlobalActivity.getSesc()); // paramEventBean.add(sGlobalActivity.getSesc());
paramEventBean.add(sGlobalActivity.getSesc()); // paramEventBean.add(sGlobalActivity.getSesc());
paramEventBean.add(parm[1].toString()); // paramEventBean.add(parm[1].toString());
paramEventBean.add("COMPLETE"); // paramEventBean.add("COMPLETE");
break; // break;
case ParamEventBean.UserItemEvent: // case ParamEventBean.UserItemEvent:
case ParamEventBean.UserCurrencyEvent: // case ParamEventBean.UserCurrencyEvent:
int useReson = (int)parm[0]; // int useReson = (int)parm[0];
int useType = (int)parm[1]; // int useType = (int)parm[1];
int itemId = (int)parm[2]; // int itemId = (int)parm[2];
int itemNum = (int)parm[3]; // int itemNum = (int)parm[3];
int itemTotalNum = (int)parm[4]; // int itemTotalNum = (int)parm[4];
paramEventBean.add(itemUseType[useType]); // paramEventBean.add(itemUseType[useType]);
paramEventBean.add(String.valueOf(useReson)); // paramEventBean.add(String.valueOf(useReson));
if(currencyMap.containsKey(itemId)){ // if(currencyMap.containsKey(itemId)){
paramEventBean.add(currencyMap.get(itemId)); // paramEventBean.add(currencyMap.get(itemId));
}else{ // }else{
paramEventBean.add(String.valueOf(itemId)); // paramEventBean.add(String.valueOf(itemId));
} // }
paramEventBean.add(String.valueOf(itemNum)); // paramEventBean.add(String.valueOf(itemNum));
PlayerManager playerInfoManager = user.getPlayerInfoManager(); // PlayerManager playerInfoManager = user.getPlayerInfoManager();
ItemLogic.getInstance().addItemLog(new ItemLog(user.getId(),useType,String.valueOf(TimeUtils.now()),useReson,itemId,itemNum,itemTotalNum)); // ItemLogic.getInstance().addItemLog(new ItemLog(user.getId(),useType,String.valueOf(TimeUtils.now()),useReson,itemId,itemNum,itemTotalNum));
//
if(parm.length==6){ // if(parm.length==6){
String sbReson = String.valueOf(parm[5]); // String sbReson = String.valueOf(parm[5]);
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,sbReson);
}else { // }else {
BILog.info("itemflow {}|{}|{}|{}|{}|{}|{}|{}",user.getId(), playerInfoManager.getLevel(), playerInfoManager.getVipLevel(),useType,useReson,itemId,itemNum,itemTotalNum); // BILog.info("itemflow {}|{}|{}|{}|{}|{}|{}|{}",user.getId(), playerInfoManager.getLevel(), playerInfoManager.getVipLevel(),useType,useReson,itemId,itemNum,itemTotalNum);
} // }
//
break; // break;
case ParamEventBean.UserLoginOutEvent: // case ParamEventBean.UserLoginOutEvent:
case ParamEventBean.UserLogin: // case ParamEventBean.UserLogin:
int loginType = (int)parm[0]; // int loginType = (int)parm[0];
paramEventBean.add(userloginType[loginType]); // paramEventBean.add(userloginType[loginType]);
break; // break;
case ParamEventBean.UserStoreEvent: // case ParamEventBean.UserStoreEvent:
int storeId = (int)parm[0]; // int storeId = (int)parm[0];
int buyItemId = (int)parm[1]; // int buyItemId = (int)parm[1];
int goldType = (int)parm[2]; // int goldType = (int)parm[2];
int buyTimes = (int)parm[3]; // int buyTimes = (int)parm[3];
int costTotal = (int)parm[4]; // int costTotal = (int)parm[4];
paramEventBean.add(String.valueOf(storeId)); // paramEventBean.add(String.valueOf(storeId));
paramEventBean.add(String.valueOf(buyItemId)); // paramEventBean.add(String.valueOf(buyItemId));
if(currencyMap.containsKey(goldType)){ // if(currencyMap.containsKey(goldType)){
paramEventBean.add(currencyMap.get(goldType)); // paramEventBean.add(currencyMap.get(goldType));
}else{ // }else{
paramEventBean.add(Integer.toString(goldType)); // paramEventBean.add(Integer.toString(goldType));
} // }
paramEventBean.add(String.valueOf(buyTimes)); // paramEventBean.add(String.valueOf(buyTimes));
paramEventBean.add(String.valueOf(costTotal/buyTimes)); // paramEventBean.add(String.valueOf(costTotal/buyTimes));
paramEventBean.add(String.valueOf(costTotal)); // paramEventBean.add(String.valueOf(costTotal));
break; // break;
case ParamEventBean.UserPayEvent: // case ParamEventBean.UserPayEvent:
int goodsId = (int)parm[0]; // int goodsId = (int)parm[0];
String orderId = (String)parm[1]; // String orderId = (String)parm[1];
String payValid = payResult[(int)parm[2]]; // String payValid = payResult[(int)parm[2]];
String amount = String.valueOf( ((int)parm[3])); // String amount = String.valueOf( ((int)parm[3]));
SRechargeCommodityConfig sRechargeCommodityConfig = SRechargeCommodityConfig.rechargeCommodityConfigMap.get(goodsId); // SRechargeCommodityConfig sRechargeCommodityConfig = SRechargeCommodityConfig.rechargeCommodityConfigMap.get(goodsId);
paramEventBean.add(sRechargeCommodityConfig.getName()); // paramEventBean.add(sRechargeCommodityConfig.getName());
paramEventBean.add(orderId); // paramEventBean.add(orderId);
paramEventBean.add(payValid); // paramEventBean.add(payValid);
paramEventBean.add(amount); // paramEventBean.add(amount);
break; // break;
case ParamEventBean.UserRegister: // case ParamEventBean.UserRegister:
break; // break;
case ParamEventBean.UserTaskEvent: // case ParamEventBean.UserTaskEvent:
int misionType = (int)parm[0]; // int misionType = (int)parm[0];
int misionId = (int)parm[1]; // int misionId = (int)parm[1];
paramEventBean.add(misionType+"_"+misionId); // paramEventBean.add(misionType+"_"+misionId);
paramEventBean.add("COMPLETE"); // paramEventBean.add("COMPLETE");
break; // break;
case ParamEventBean.UserGameType: // case ParamEventBean.UserGameType:
paramEventBean.add("玩法"); // paramEventBean.add("玩法");
String type = KTGameType.getName((int) parm[0]); // String type = KTGameType.getName((int) parm[0]);
paramEventBean.add(String.valueOf(type)); // paramEventBean.add(String.valueOf(type));
paramEventBean.add(String.valueOf(parm[1])); // paramEventBean.add(String.valueOf(parm[1]));
paramEventBean.add("COMPLETE"); // paramEventBean.add("COMPLETE");
eventType = ParamEventBean.UserActivityEvent; // eventType = ParamEventBean.UserActivityEvent;
break; // break;
} // }
//
KTParam ktParam = ParamBuilder.paramBuild(user, eventType, paramEventBean); // KTParam ktParam = ParamBuilder.paramBuild(user, eventType, paramEventBean);
DataMessageUtils.addLogQueue(ktParam); // DataMessageUtils.addLogQueue(ktParam);
// LOGGER.info("ktparm -- > {}",gson.toJson(ktParam)); // LOGGER.info("ktparm -- > {}",gson.toJson(ktParam));
} }
public static ParamEnvironmentBean enviromentBuild(int uid){ public static ParamEnvironmentBean enviromentBuild(int uid){