<?php
|
include_once '/Common/CommFunc.php';
|
include_once '/Common/Logging.php';
|
include_once "/db/DBOper.php";
|
|
header("Content-type: text/html; charset=utf-8");
|
|
\Logging\CreateLogging("eventreport.eventreport.php");
|
|
// 2022-05-09T19:17:47 DEBUG Version=
|
// 2022-05-09T19:17:47 DEBUG DeviceFlag=
|
// 2022-05-09T19:17:47 DEBUG SessionID=c8b996d5ffdc71139b1d4bc22874b2f8
|
// 2022-05-09T19:17:47 DEBUG EventID=1100
|
// 2022-05-09T19:17:47 DEBUG ProductID=xbqy
|
// 2022-05-09T19:17:47 DEBUG OperatorID=test
|
// 2022-05-09T19:17:47 DEBUG RegionName=s86
|
// 2022-05-09T19:17:47 DEBUG Time=2022-05-09 19:17:47
|
// 2022-05-09T19:17:47 DEBUG AccountID=yn1233
|
// 2022-05-09T19:17:47 DEBUG PlayerID=280104
|
// 2022-05-09T19:17:47 DEBUG RoleID=ĐạmDiệuHải
|
// 2022-05-09T19:17:47 DEBUG Level=400
|
// 2022-05-09T19:17:47 DEBUG Job=1
|
// 2022-05-09T19:17:47 DEBUG IP=192.168.1.1
|
|
$EventID = $_GET["EventID"];
|
$GameName = $_GET["ProductID"];
|
$Channel = $_GET["OperatorID"];
|
$RegionName = $_GET["RegionName"];
|
$Time = $_GET["Time"];
|
|
\Logging\LogInfo(" _GET:" . print_r($_GET, true));
|
|
if (
|
!$EventID || !$Channel || !$RegionName || !$Time || !$GameName || $GameName != \CommFunc\GetGameName()
|
) {
|
Response(1000, "param error");
|
exit;
|
}
|
|
$ok = false;
|
switch ($EventID) {
|
case 1100:
|
$ok = EventReport_UpdateRole("Login");
|
break;
|
|
case 1101:
|
$ok = EventReport_UpdateRole("Logoff");
|
break;
|
|
case 9001:
|
$Flag = $_GET["Flag"];
|
// 流失模型中，Flag 1000 为首登成功
|
if ($Flag == 1000) {
|
$ok = EventReport_CreateRole();
|
}
|
break;
|
|
case "CouponCode":
|
$ok = RecordCoupontypeGroup();
|
break;
|
|
default:
|
Response(1001, "unknown eventID -> " . $EventID);
|
exit;
|
}
|
if ($ok) {
|
Response();
|
}
|
exit;
|
|
function Response($errorcode = 0, $errormsg = "ok")
|
{
|
$ret = array("errorcode" => $errorcode, "errormsg" => $errormsg);
|
if ($errorcode != 0) {
|
\Logging\LogError($errormsg . " _GET:" . print_r($_GET, true) . " ret:" . print_r($ret, true));
|
}
|
echo \CommFunc\MyJson_encode($ret);
|
}
|
|
function EventReport_UpdateRole($eventType)
|
{
|
global $Channel, $RegionName, $Time;
|
|
$AccountID = $_GET["AccountID"];
|
$PlayerID = intval($_GET["PlayerID"]);
|
$PlayerName = $_GET["RoleID"];
|
$LV = intval($_GET["Level"]);
|
$Job = intval($_GET["Job"]);
|
$IP = $_GET["IP"];
|
$FamilyName = array_key_exists("FamilyName", $_GET) ? $_GET["FamilyName"] : "";
|
$FightPower = $_GET["FightPower"];
|
settype($FightPower, "float");
|
$AllCoinTotal = intval($_GET["AllCoinTotal"]);
|
|
if (!$AccountID || !$PlayerID || !$PlayerName || !$LV || !$Job || !$IP) {
|
Response(1003, "role param error");
|
return;
|
}
|
|
$find = array("Channel" => $Channel, "AccountID" => $AccountID);
|
// 只找对应服的数据更新即可
|
if (!\DBOper\FindOne("GameRoles", $find, $findData, array($RegionName => 1))) {
|
Response(2000, "db find error");
|
return;
|
}
|
$newAccount = false;
|
if (!isset($findData)) {
|
$newAccount = true;
|
}
|
\Logging\LogInfo("newAccount:" . $newAccount . " findData:" . print_r($findData, true));
|
|
$roleInfo = array();
|
if (isset($findData) && array_key_exists($RegionName, $findData)) {
|
$regionRole = $findData[$RegionName];
|
// 如果是redis取出来的是json字符串
|
if (is_string($regionRole)) {
|
$regionRole = json_decode($regionRole, true);
|
// \Logging\LogInfo("json_decode regionRole:" . print_r($regionRole, true));
|
}
|
foreach ($regionRole as $key => $value) {
|
$roleInfo[$key] = $value;
|
}
|
}
|
|
$roleInfo["PlayerID"] = $PlayerID;
|
$roleInfo["PlayerName"] = $PlayerName;
|
$roleInfo["LV"] = $LV;
|
$roleInfo["Job"] = $Job;
|
$roleInfo["IP"] = $IP;
|
$roleInfo["FamilyName"] = $FamilyName;
|
$roleInfo["FightPower"] = $FightPower;
|
$roleInfo["AllCoinTotal"] = $AllCoinTotal;
|
if (array_key_exists("CreateRoleTime", $_GET)) {
|
$roleInfo["CreateRoleTime"] = $_GET["CreateRoleTime"];
|
}
|
if ($eventType == "Login") {
|
$roleInfo["LoginTime"] = $Time;
|
} elseif ($eventType == "Logoff") {
|
$roleInfo["LogoffTime"] = $Time;
|
}
|
|
if ($newAccount) {
|
$insArray = array(
|
"Channel" => $Channel,
|
"AccountID" => $AccountID,
|
"CreateTime" => date("Y-m-d H:i:s"),
|
$RegionName => $roleInfo
|
);
|
if (!\DBOper\Insert("GameRoles", $insArray, $find)) {
|
Response(2001, "db Insert error");
|
return;
|
}
|
} else {
|
$setRole = array($RegionName => $roleInfo);
|
if (!\DBOper\Update("GameRoles", $find, $setRole, true)) {
|
Response(2002, "db Update error");
|
return;
|
}
|
}
|
$ServerID = \CommFunc\GetServerIDBySid($RegionName);
|
AddAccountFirstLogin($ServerID, $roleInfo);
|
AddAccountDayActive($ServerID, $roleInfo);
|
|
// 附带更新服务器角色表，之后会替换 GameRoles 表
|
$find = array("Channel" => $Channel, "AccountID" => $AccountID, "ServerID" => $ServerID);
|
if (\DBOper\Count("ServerRoles", $find) <= 0) {
|
$insArray = array(
|
"Channel" => $Channel,
|
"AccountID" => $AccountID,
|
"ServerID" => $ServerID,
|
"CreateYMD" => date("Y-m-d"),
|
);
|
if ($roleInfo["CreateRoleTime"]) {
|
$insArray["CreateYMD"] = substr($roleInfo["CreateRoleTime"], 0, 10);
|
}
|
$insArray["RollCount"] = \DBOper\Count("ServerRoles", array("Channel" => $Channel, "AccountID" => $AccountID));
|
$insArray = array_merge($insArray, $roleInfo);
|
\DBOper\Insert("ServerRoles", $insArray, $find);
|
} else {
|
\DBOper\Update("ServerRoles", $find, $roleInfo, true);
|
}
|
return true;
|
}
|
|
function EventReport_CreateRole()
|
{
|
global $Channel, $RegionName;
|
|
$ServerID = \CommFunc\GetServerIDBySid($RegionName);
|
if (!$ServerID) {
|
return;
|
}
|
$find = array("Channel" => $Channel, "ServerID" => $ServerID);
|
if (!\DBOper\FindOne("GameServerInfo", $find, $findData, null, false)) {
|
Response(2000, "db find error");
|
return;
|
}
|
\Logging\LogInfo(" findData:" . print_r($findData, true));
|
|
if (!isset($findData)) {
|
$insArray = array(
|
"Channel" => $Channel,
|
"ServerID" => $ServerID,
|
"CreateRoleCount" => 1,
|
);
|
if (!\DBOper\Insert("GameServerInfo", $insArray, $find)) {
|
Response(2001, "db Insert error");
|
return;
|
}
|
\Logging\LogInfo(" insert ServerID:" . $ServerID . " CreateRoleCount:" . 1);
|
} else {
|
$CreateRoleCount = $findData["CreateRoleCount"] + 1;
|
$setArray = array("CreateRoleCount" => $CreateRoleCount);
|
if (!\DBOper\Update("GameServerInfo", $find, $setArray)) {
|
Response(2002, "db Update error");
|
return;
|
}
|
\Logging\LogInfo(" update ServerID:" . $ServerID . " CreateRoleCount:" . $CreateRoleCount);
|
}
|
return true;
|
}
|
|
/**添加平台账号首登 */
|
function AddAccountFirstLogin($ServerID, $roleInfo)
|
{
|
global $Channel, $Time;
|
$AccountID = $_GET["AccountID"];
|
|
$find = array("Channel" => $Channel, "AccountID" => $AccountID);
|
if (!\DBOper\FindOne("AccountFirstLogin", $find, $findData, null, false)) {
|
return;
|
}
|
if (isset($findData)) {
|
// 已存在，不再重复添加
|
return;
|
}
|
$CreateRoleTime = $Time;
|
if (array_key_exists("CreateRoleTime", $roleInfo)) {
|
$CreateRoleTime = $roleInfo["CreateRoleTime"];
|
}
|
$insArray = array(
|
"Channel" => $Channel,
|
"AccountID" => $AccountID,
|
"CreateYMD" => substr($CreateRoleTime, 0, 10),
|
"CreateTime" => $CreateRoleTime,
|
"ServerID" => $ServerID,
|
"PlayerID" => $roleInfo["PlayerID"],
|
"PlayerName" => $roleInfo["PlayerName"],
|
"Job" => $roleInfo["Job"],
|
"IP" => $roleInfo["IP"],
|
);
|
\DBOper\Insert("AccountFirstLogin", $insArray);
|
}
|
|
/**添加平台账号日活 */
|
function AddAccountDayActive($ServerID, $roleInfo)
|
{
|
global $Channel, $Time;
|
$AccountID = $_GET["AccountID"];
|
$curYMD = substr($Time, 0, 10);
|
$find = array("Channel" => $Channel, "AccountID" => $AccountID, "ActiveYMD" => $curYMD);
|
$roleInfo["ServerID"] = $ServerID;
|
// 直接更新
|
$actInfo = array(
|
"Channel" => $Channel,
|
"AccountID" => $AccountID,
|
"ActiveYMD" => $curYMD,
|
"ServerID" => $ServerID,
|
"IP" => $roleInfo["IP"],
|
);
|
if (array_key_exists("LoginTime", $roleInfo)) {
|
$actInfo["LoginTime"] = $roleInfo["LoginTime"];
|
}
|
if (array_key_exists("LogoffTime", $roleInfo)) {
|
$actInfo["LogoffTime"] = $roleInfo["LogoffTime"];
|
}
|
\DBOper\Update("AccountDayActive", $find, $actInfo, false, true);
|
}
|
|
/**记录媒体卡账号分组 */
|
function RecordCoupontypeGroup()
|
{
|
global $Channel, $RegionName;
|
|
$ServerID = \CommFunc\GetServerIDBySid($RegionName);
|
if (!$ServerID) {
|
return;
|
}
|
|
CommFunc\GetConfig("ServerInfo", "CoupontypeGroup", $CoupontypeGroup);
|
if (!$CoupontypeGroup) {
|
// \Logging\LogInfo("CoupontypeGroup 不需要");
|
return;
|
}
|
|
$AccountID = $_GET["accid"];
|
$code = $_GET["code"];
|
$coupontype = $_GET["coupontype"];
|
$CoupontypeGroup = json_decode($CoupontypeGroup);
|
if (!array_key_exists($coupontype, $CoupontypeGroup)) {
|
// \Logging\LogInfo("CoupontypeGroup 不需要记录的组:" . $coupontype);
|
return;
|
}
|
|
$find = array("Channel" => $Channel, "AccountID" => $AccountID, "ServerID" => $ServerID);
|
if (!\DBOper\FindOne("CoupontypeGroup", $find, $findData)) {
|
return;
|
}
|
if (isset($findData)) {
|
// \Logging\LogInfo("已存在，不再重复添加: " . print_r($findData, true));
|
return true;
|
}
|
|
$insArray = array(
|
"Channel" => $Channel,
|
"AccountID" => $AccountID,
|
"ServerID" => $ServerID,
|
"CreateTime" => date("Y-m-d H:i:s"),
|
"Coupontype" => $coupontype,
|
"Code" => $code,
|
);
|
if (\DBOper\Insert("CoupontypeGroup", $insArray, $find)) {
|
\Logging\LogInfo("记录使用媒体卡首次分组: " . print_r($insArray, true));
|
return true;
|
}
|
}
|
