www.git - Gitblit

<?php
set_time_limit(180);
include_once "/Common/Logging.php";
include_once "/Common/CommFunc.php";
include_once "/Account/User.php";
include_once "/language/lang.php";
include_once "/Account/userlogcomm.php";
include_once "/Common/GMTRetCode.php";
 
header("Content-type: text/html; charset=utf-8");
// 本脚本用于发送GMT命令到游戏服务器，可能的行为包括
// 1. 常规页面post请求，可能是查询、插入、更新数据等，需要展示详细结果页面
// 2. 命令发送post请求，一般是插入、更新数据，不需要展示详细结果页面，但是要返回操作结果，包含结果码、结果信息数据； （如审核、补发等）
 
$processType = $_POST['processType']; // 请求处理类型，可不传，默认常规页面请求； 
// CheckOK-日志动态审核通过；
// JustRet-直接返回处理结果，由提交的页面自身决定处理逻辑
if (!$processType) {
    echo "<Title>" . \Lang\gettext("执行结果") . "</Title>";
}
 
$pack_type = $_POST['pack_type'];
if (!isset($pack_type)) {
    ProcessRet(-1, "not pack_type");
    exit;
}
\CommFunc\SessionStart();
\Logging\CreateLogging("GMCmd_" . $pack_type);
\Logging\LogInfo("_SESSION:" . print_r($_SESSION, true));
\Logging\LogInfo("_POST:" . print_r($_POST, true));
 
$Permission = $_POST['Permission']; // 后台权限
$SPID = $_SESSION['spid'];
$UserAccount = $_SESSION['UserAccount'];
$user = new \User\User($UserAccount);
if (!$user->HavePermission($Permission)) {
    ProcessRet(-1, "not permission");
    exit;
}
$GMTLogGUID = "";
$PerInfo = \User\GetPermissionInfo($Permission);
$logPermission = $Permission;
$logPerInfo = $PerInfo;
if ($processType == "CheckOK") {
    $GMTLogGUID = $_POST['GMTLogGUID'];
    if (!$GMTLogGUID) {
        ProcessRet(-1, "not check GMTLogGUID");
        exit;
    }
    $checkPermission = $PerInfo["Check"];
    if (!$user->HavePermission($checkPermission)) {
        ProcessRet(-1, "not check Permission");
        exit;
    }
    $logPermission = $checkPermission;
    $logPerInfo = \User\GetPermissionInfo($logPermission);
}
 
//验证 后台权限对应的 GMT_xxx 及 授权码key
$superGMT = false;
$keyCfg = "";
$key = $_POST['key'];
if (array_key_exists("GMTKey1", $PerInfo) && in_array($pack_type, $PerInfo["GMTKey1"])) {
    \CommFunc\GetConfig("Config", "GMKey", $keyCfg, "");
} elseif (array_key_exists("GMTKey2", $PerInfo) && in_array($pack_type, $PerInfo["GMTKey2"])) {
    \CommFunc\GetConfig("Config", "GMKey2", $keyCfg, "");
    $superGMT = true;
} else {
    \Logging\LogError("GMTKey not found.");
    ProcessRet(-1, \Lang\gettext("您没有该权限") . " GMTKey not found.");
    exit;
}
if (!$key) {
    if (!$processType && $user->NeedCheckKey()) {
        \Logging\LogInfo("请输入命令key!" . $pack_type);
        ProcessRet(-1, \Lang\gettext("请输入命令key"));
        exit;
    }
    $key = $keyCfg; // 没有输入key，且不需要验证key的情况下，直接使用配置的key
} elseif ($key == $keyCfg) {
    $updCheckKeyTime = $user->UpdCheckKeyTime();
    \Logging\LogInfo("updCheckKeyTime:" . $updCheckKeyTime);
} else {
    \Logging\LogInfo("授权码错误 key:" . $key . " != keyCfg:" . $keyCfg);
    ProcessRet(-1, \Lang\gettext("授权码错误"));
    exit;
}
\Logging\LogInfo($Permission . " -> GMTKey:" . $pack_type . " superGMT:" . $superGMT . " key:" . $key);
 
// ============================== 以上验证权限结束 =====================================
 
$pack_data = $_POST;
 
//去除多余参数
unset($pack_data['submit']);
unset($pack_data['Permission']);
unset($pack_data['MultiServer']);
 
//组合开始时间、结束时间
if (
    array_key_exists('StartDate', $pack_data) && array_key_exists('StartHour', $pack_data)
    && array_key_exists('StartMinute', $pack_data) && array_key_exists('StartSecond', $pack_data)
    && !$pack_data['StartDate'] == ""
) {
    $pack_data['StartTime'] = $pack_data['StartDate'] . " " . $pack_data['StartHour'] . ":" . $pack_data['StartMinute'] . ":" . $pack_data['StartSecond'];
    unset($pack_data['StartDate'], $pack_data['StartHour'], $pack_data['StartMinute'], $pack_data['StartSecond']);
};
if (
    array_key_exists('EndDate', $pack_data) && array_key_exists('EndHour', $pack_data)
    && array_key_exists('EndMinute', $pack_data) && array_key_exists('EndSecond', $pack_data)
    && !$pack_data['EndDate'] == ""
) {
    $pack_data['EndTime'] = $pack_data['EndDate'] . " " . $pack_data['EndHour'] . ":" . $pack_data['EndMinute'] . ":" . $pack_data['EndSecond'];
    unset($pack_data['EndDate'], $pack_data['EndHour'], $pack_data['EndMinute'], $pack_data['EndSecond']);
};
 
//增加编码类型
$pack_data['coding'] = "utf8";
$pack_data['key'] = $key;
 
$SuccessMsg = array();
$ErrorMsg = array();
 
// 多服选择的
if ($_POST["MultiServer"] == 1) {
 
    $onlyServerID = $_POST['OnlyServerID'];
 
    $sendServers = array();
    $serversArray = $user->GetServers();
    foreach ($serversArray as $serverName => $serverInfo) {
        $postServerName = urlencode($serverName);
        if (!array_key_exists($postServerName, $_POST)) {
            continue;
        }
        if (!$_POST[$postServerName] == 'on') {
            continue;
        }
 
        if ($serverInfo['MainServer'] && !$onlyServerID && $serverInfo['MainServer'] != $serverInfo['ServerID']) {
            # 有主服的代表是合服的，只允许主服发送, 除非标明了只往某个服发送
            # 单服发送消息，如混（合）服情况下只给其中一个服务器玩家发邮件
            continue;
        }
 
        if ($onlyServerID && $serverInfo['ServerID']) {
            # 单服发送消息，如混（合）服情况下只给其中一个服务器玩家发邮件
            $pack_data["OnlyServerID"] = $serverInfo['ServerID'];
        } else {
            unset($pack_data['OnlyServerID']);
        }
 
        //使用key加密
        $pack_data_dict = json_encode($pack_data);
        $sign = md5('' . $pack_data_dict . $key);
        $post = array();
        $post['pack'] = $pack_data_dict;
        $post['sign'] = $sign;
        $post['toServerID'] = $serverInfo['ServerID'];
 
        $sendServers[] = array($serverName, $serverInfo['Page'], $post);
    }
 
    if (!$sendServers) {
        \Logging\LogInfo("not sendServers.");
        ProcessRet(-1, "Error. " . \Lang\gettext("请先选择服务器"));
        return;
    }
 
    //有配置面审权限的，玩家没有对应面审权限时，无法直接发送
    if (array_key_exists("NOCheck", $logPerInfo) && !$user->HavePermission($logPerInfo["NOCheck"], false)) {
        if (AddGMTLog($SPID, $UserAccount, $logPermission, $_POST, \User\GMTCheckState::UnCheck)) {
            echo \Lang\gettext("请求成功，请联系管理员进行审核");
        } else {
            echo \Lang\gettext("请求失败");
        }
        exit;
    }
 
    \Logging\LogInfo("待发送的服务器信息: " . print_r($sendServers, true));
 
    // 单服发送的话，由于多个子服可能是同一个主服，所以不采用多线程批量发送，还是单个单个处理，不然可能导致远程服务器链接异常
    if ($onlyServerID) {
        $retList = array();
        foreach ($sendServers as $value) {
            $server_url = $value[1];
            $post = $value[2];
            $retList[] = \CommFunc\DoPost($server_url, $post);
        }
    }
    // 非单服发送的话，由于都是不同的服务器机子，
    else {
        $retList = \CommFunc\DoPostMulti($sendServers);
    }
 
    //\Logging\LogInfo("结果".print_r($retList, true));
 
    $retCount = count($retList);
 
    foreach ($retList as $i => $retStr) {
        $ret = json_decode($retStr, true);
        if (!isset($ret)) {
            $retStr = iconv("GB2312", "UTF-8", $retStr);
            \Logging\LogInfo("GB2312 to UTF-8 retStr : " . $retStr);
            $ret = json_decode($retStr, true);
        }
        $retList[$i] = $ret;
        $server_name = $sendServers[$i][0];
        $server_url = $sendServers[$i][1];
        $msg = array("ServerUrl" => $server_url);
        if (isset($ret)) {
            $msg = array_merge($msg, $ret);
            if (array_key_exists("ResultType", $ret) && $ret["ResultType"] == 0) {
                $SuccessMsg[$server_name] = $msg;
            } else if (array_key_exists("ResultType", $ret) && $ret["ResultType"] != 0) {
                $ErrorMsg[$server_name] = $msg;
            } else {
                $ErrorMsg[$server_name] = $msg;
            }
        } else {
            $ErrorMsg[$server_name] = $msg;
        }
    }
}
// 单服发送的，默认当前选择的服务器
else {
 
    $tool_page = $_POST['tool_page']; // 有指定地址直接取指定的，没有则取默认
    if ($tool_page) {
        \Logging\LogInfo("get tool_page from post.");
    } else {
        $tool_page = $_SESSION['tool_page'];
        \Logging\LogInfo("get tool_page from session.");
    }
    if ($tool_page == "") {
        \Logging\LogError("tool_page is null.");
        ProcessRet(-1, "Error. " . \Lang\gettext("请先选择服务器"));
        return;
    }
    $toServerID = $_POST['toServerID']; // 有指定serverID直接取指定的，没有则取默认
    if ($toServerID) {
        \Logging\LogInfo("get toServerID from post.");
    } else {
        $toServerID = $_SESSION['serverID'];
        \Logging\LogInfo("get toServerID from session.");
    }
    if (!isset($toServerID) || $toServerID <= 0) {
        \Logging\LogError("toServerID is null.");
        ProcessRet(-1, "Error. " . \Lang\gettext("没有目标服务器ID"));
        return;
    }
 
    //有配置面审权限的，玩家没有对应面审权限时，无法直接发送
    if (array_key_exists("NOCheck", $logPerInfo) && !$user->HavePermission($logPerInfo["NOCheck"], false)) {
        $_POST["tool_page"] = $tool_page;
        $_POST["toServerID"] = $toServerID; // 防止和旧参数可能已经存在serverID了，这里直接用 toServerID
        if (AddGMTLog($SPID, $UserAccount, $logPermission, $_POST, \User\GMTCheckState::UnCheck)) {
            echo \Lang\gettext("请求成功，请联系管理员进行审核");
        } else {
            echo \Lang\gettext("请求失败");
        }
        exit;
    }
 
    //使用key加密
    $pack_data_dict = json_encode($pack_data);
    $sign = md5('' . $pack_data_dict . $key);
    $post = array();
    $post['pack'] = $pack_data_dict;
    $post['sign'] = $sign;
    $post['toServerID'] = $toServerID;
 
    \Logging\LogInfo("post tool_page : " . $tool_page . " toServerID:" . $toServerID);
    \Logging\LogInfo("post data : " . print_r($post, true));
    $retStr = \CommFunc\DoPost($tool_page, $post);
    \Logging\LogInfo("retStr : " . $retStr);
    $ret = json_decode($retStr, true);
    if (!isset($ret)) {
        $retStr = iconv("GB2312", "UTF-8", $retStr);
        \Logging\LogInfo("GB2312 to UTF-8 retStr : " . $retStr);
        $ret = json_decode($retStr, true);
    }
    $server_name = $_SESSION["server_id"];
    $msg = array("ServerUrl" => $tool_page);
    if (isset($ret)) {
        $msg = array_merge($msg, $ret);
        if (array_key_exists("ResultType", $ret) && $ret["ResultType"] == 0) {
            $SuccessMsg[$server_name] = $msg;
        } else if (array_key_exists("ResultType", $ret) && $ret["ResultType"] != 0) {
            $ErrorMsg[$server_name] = $msg;
        } else {
            $ErrorMsg[$server_name] = $msg;
        }
    } else {
        $ErrorMsg[$server_name] = $msg;
    }
}
 
// 插入动态日志
if (array_key_exists("Log", $logPerInfo) && in_array($pack_type, $logPerInfo["Log"])) {
    AddGMTLog($SPID, $UserAccount, $logPermission, $_POST, \User\GMTCheckState::OK, $SuccessMsg, $ErrorMsg);
}
 
if ($processType) {
    ProcessRet(0, "OK", $SuccessMsg, $ErrorMsg);
    exit;
}
 
// 先展示失败的
foreach ($ErrorMsg as $server_name => $ret) {
    if (array_key_exists("ResultType", $ret)) {
        Ret_ResultType($server_name, $ret);
    } else if (array_key_exists("ErrorNo", $ret)) {
        Ret_ErrorNO($server_name, $ret);
    } else {
        Ret_NotRet($server_name);
    }
}
 
// 再展示成功的
foreach ($SuccessMsg as $server_name => $ret) {
    Ret_ResultType($server_name, $ret);
}
 
if ($_POST["MultiServer"] == 1) {
    $failCount = count($ErrorMsg);
    $succCount = $retCount - $failCount;
    echo \Lang\gettext("发送服务器总数") . ": " . $retCount . "<br/>" .
        "  " . \Lang\gettext("成功") . ": " . $succCount . "<br/>" .
        "  " . \Lang\gettext("失败") . ": " . $failCount . "<br/>";
    echo "<hr/>";
    \Logging\LogInfo($pack_type . " 发送服务器总数: " . $retCount . "  成功: " . $succCount . "  失败: " . $failCount);
}
 
// =============================================================================
 
function Ret_ResultType($server_name, $ret)
{
    $ResultType = $ret["ResultType"];
    if ($ResultType != 0) {
        echo "<font color=\"#FF0000\">";
    }
    echo \Lang\gettext("发送服务器") . "【 " . $server_name . " 】: ";
    echo GetResultTypeMsg($ResultType), "<br/>";
    if ($ResultType != 0) {
        if (array_key_exists("ResultMsg", $ret) && $ret["ResultMsg"] != "") {
            echo "&nbsp;&nbsp;ResultMsg: ", \CommFunc\MyJson_encode($ret["ResultMsg"]), "<br/>";
        }
        echo "</font>";
    } else {
        Ret_Detail($ret);
    }
    echo "<hr/>";
}
 
function Ret_Detail($ret)
{
    global $pack_type, $superGMT;
    $fileName = $superGMT ? "SuperGMToolClient" : "GMToolClient";
    $poPath = $_SERVER['DOCUMENT_ROOT'] . "/" . $fileName . "/GMTManage/" . $pack_type . ".php";
    // 结果明细页文件不存在使用默认输出
    if (!file_exists($poPath)) {
        if (array_key_exists("ResultMsg", $ret) && $ret["ResultMsg"] != "") {
            echo "&nbsp;&nbsp;ResultMsg: ", \CommFunc\MyJson_encode($ret["ResultMsg"]), "<br/>";
        }
        return;
    }
    $retdetailUrl = 'http://' . $_SERVER['HTTP_HOST'] . "/" . $fileName . "/GMTManage/" . $pack_type . ".php";
    \Logging\LogInfo(" post to ret detail Url: " . $retdetailUrl);
    echo \CommFunc\DoPost($retdetailUrl, $ret, true); //这里需要传递session
}
 
function Ret_ErrorNO($server_name, $ret)
{
    $ErrorNo = $ret["ErrorNo"];
    echo "<font color=\"#FF0000\">";
    echo \Lang\gettext("发送服务器") . "【 " . $server_name . " 】: ";
    echo GetErrorNoMsg($ErrorNo), "<br/>";
    if (array_key_exists("ErrorStr", $ret) && $ret["ErrorStr"] != "") {
        echo "&nbsp;&nbsp;ErrorStr: ", \CommFunc\MyJson_encode($ret["ErrorStr"]), "<br/>";
    }
    echo "</font>";
    echo "<hr/>";
}
 
function Ret_NotRet($server_name)
{
    \Logging\LogError("请求异常，没有返回结果 server_name:" . $server_name);
    echo "<font color=\"#FF0000\">";
    echo \Lang\gettext("发送服务器") . "【 " . $server_name . " 】: ";
    echo \Lang\gettext("请求异常，没有返回结果"), "<br/>";
    echo "</font>";
    echo "<hr/>";
}
 
function ProcessRet($retCode, $retMsg, $SuccessMsg = array(), $ErrorMsg = array())
{
    global $processType;
    if (!$processType) {
        echo $retMsg;
        return;
    }
    echo \CommFunc\MyJson_encode(array(
        "ProcessRetCode" => $retCode,
        "ProcessRetMsg" => $retMsg,
        "SuccessMsg" => $SuccessMsg,
        "ErrorMsg" => $ErrorMsg,
    ));
    return;
}