<?php
include_once '/Common/CommFunc.php';
include_once "/Common/Logging.php";
include_once "/db/DBOper.php";
include_once "/Common/ServerOPS.php";
include_once "/Common/Commtox7.php";
include_once "/serverrep/report.php";

\Logging\CreateLogging("task.minuteLoop.php");

$curyweek = date("W", time());
$curDate = getdate();
$dateStr = $curDate['year'] . "-" . $curDate['mon'] . "-" . $curDate['mday'];
$hourStr = $dateStr . " " . $curDate['hours'];
$minuteStr = $hourStr . ":" . $curDate['minutes'];
\Logging\LogInfo("curweek:" . $curyweek . " curDate:" . $dateStr . " curHour:" . $hourStr . " curMinute:" . $minuteStr);

$eventKey = 'serverLoopInfo';
if (!\DBOper\FindOne("ServerEvent", array("Key" => $eventKey), $ret, null, false)) {
    exit;
}
$serverLoopInfo = $ret["Value"] ? $ret["Value"] : array();
\Logging\LogInfo("dbValue:" . json_encode($serverLoopInfo));

if ($serverLoopInfo['yweek'] != $curyweek) {
    OnWeek($curyweek);
    $serverLoopInfo['yweek'] = $curyweek;
}

if ($serverLoopInfo['date'] != $dateStr) {
    OnDay($dateStr);
    $serverLoopInfo['date'] = $dateStr;
}

if ($serverLoopInfo['hour'] != $hourStr) {
    OnHour($hourStr);
    $serverLoopInfo['hour'] = $hourStr;
}

if ($serverLoopInfo['minute'] != $minuteStr) {
    OnMinute($minuteStr);
    $serverLoopInfo['minute'] = $minuteStr;
}

\DBOper\Update("ServerEvent", array("Key" => $eventKey), array("Value" => $serverLoopInfo), false, true);
exit;

function OnWeek($yweek)
{
    \Logging\LogInfo("Todo OnWeek: " . $yweek);
}

function OnDay($dateStr)
{
    \Logging\LogInfo("Todo OnDay: " . $dateStr);
}

function OnHour($hourStr)
{
    \Logging\LogInfo("Todo OnHour: " . $hourStr);
    \Report\OnExportRep();
}

function OnMinute($minuteStr)
{
    \Logging\LogInfo("Todo OnMinute: " . $minuteStr);
    checkAutoOpenServer();
    checkPreOpenServer();
    checkOpenServerTime();
}

//==========================================================================================================
/**
 * 检查自动服务器信息，每分钟处理一次
 */
function checkAutoOpenServer()
{
    $curDate = getdate();
    $dateStr = $curDate['year'] . "-" . $curDate['mon'] . "-" . $curDate['mday'];
    \Logging\LogInfo("=== Do checkAutoOpenServer ===");
    // 设定时间范围 如21-24点 不会自动开服
    CommFunc\GetConfig("ServerInfo", "AutoOpenServerLimitTimeRange", $AutoOpenServerLimitTimeRange);
    $limitTimeList = json_decode($AutoOpenServerLimitTimeRange);
    \Logging\LogInfo("AutoOpenServerLimitTimeRange" . $AutoOpenServerLimitTimeRange);
    $curTime = strtotime(date("Y-m-d H:i:s", time()));
    for ($i = 0; $i < count($limitTimeList); $i++) {
        $limitTimeFrom = strtotime(date("Y-m-d H:i:s", strtotime($dateStr . " " . $limitTimeList[$i][0] . ":00")));
        $limitTimeTo = strtotime(date("Y-m-d H:i:s", strtotime($dateStr . " " . $limitTimeList[$i][1] . ":00")));
        // 跨天了
        if ($limitTimeFrom > $limitTimeTo) {
            $limitTimeTo += 3600 * 24;
        }
        \Logging\LogInfo("limitTimeRange: " . $limitTimeFrom . " ~ " . $limitTimeTo . " curTime:" . $curTime);
        if ($curTime >= $limitTimeFrom && $curTime <= $limitTimeTo) {
            \Logging\LogInfo("time is not allow to auto open server. curTime:" . $curTime);
            return;
        }
    }

    // 找出所有预开服服务器
    \DBOper\Find("GameServers", array(
        "RunningStatus" => \ServerOPS\ServerRunningStatus::PreOpen,
        "OpenServerWay" => 1,
        "RelationServerOK" => 0,
    ), $serverList);

    if (!$serverList) {
        \Logging\LogInfo("Can not found preopen and auto open servers by RelationServer.");
        return;
    }

    // 达到条件后多少分钟后入口开放，分钟，需要预留清档缓冲时间，需大于提前清档时间，目前是提前15分钟清档
    $setStartDate = \CommFunc\TimeToStrDateTime(strtotime("+20 minutes"));
    \Logging\LogInfo("setStartDate." . $setStartDate);

    $serverCreateRoleInfo = array();
    \DBOper\Find("GameServerInfo", array(), $serverInfoList);
    if (isset($serverInfoList)) {
        foreach ($serverInfoList as $serverInfo) {
            $Channel = $serverInfo["Channel"];
            $ServerID = $serverInfo["ServerID"];
            $key = $Channel . "_" . $ServerID;
            $serverCreateRoleInfo[$key] = $serverInfo["CreateRoleCount"];
        }
    }
    // \Logging\LogInfo("serverCreateRoleInfo" . print_r($serverCreateRoleInfo, true));

    foreach ($serverList as $serverInfo) {
        $Channel = $serverInfo["Channel"];
        $ServerID = $serverInfo["ServerID"];
        $RelationServerID = $serverInfo["RelationServerID"];
        $RelationCreateRoles = $serverInfo["RelationCreateRoles"];

        if (!$RelationServerID || !$RelationCreateRoles) {
            \Logging\LogError("RelationServer option error. Channel:" . $Channel . " ServerID:" . $ServerID .
                " RelationServerID:" . $RelationServerID . " RelationCreateRoles:" . $RelationCreateRoles);
            continue;
        }

        $createRoleCount = 0;
        $key = $Channel . "_" . $RelationServerID;
        if (array_key_exists($key, $serverCreateRoleInfo)) {
            $createRoleCount = $serverCreateRoleInfo[$key];
        }
        if ($createRoleCount < $RelationCreateRoles) {
            \Logging\LogInfo("Channel:" . $Channel . " ServerID:" . $ServerID . " RelationServerID:" . $RelationServerID .
                " createRoleCount:" . $createRoleCount . " < " . $RelationCreateRoles);
            continue;
        }

        $find = array("Channel" => $Channel, "ServerID" => $ServerID);
        $set = array(
            "RelationServerOK" => 1,
            "StartDate" => $setStartDate,
        );

        if (\DBOper\Update("GameServers", $find, $set)) {
            \Logging\LogInfo("set server auto open time ok. setStartDate:" . $setStartDate .
                " Channel:" . $Channel . " ServerID:" . $ServerID . " RelationServerID:" . $RelationServerID . " RelationCreateRoles:" . $RelationCreateRoles);
        } else {
            \Logging\LogError("set server auto open time error. setStartDate:" . $setStartDate . print_r($serverInfo, true));
        }
    }
}

/**
 * 检查预开服服务器信息，每分钟处理一次
 */
function checkPreOpenServer()
{
    \Logging\LogInfo("=== Do checkPreOpenServer ===");
    // 找出所有预开服服务器
    \DBOper\Find("GameServers", array(
        "RunningStatus" => \ServerOPS\ServerRunningStatus::PreOpen
    ), $serverList);

    if (!$serverList) {
        \Logging\LogInfo("Can not found preopen and internalopen servers.");
        return;
    }

    $x7notifyserverInfo = array();
    $refrshJsonBranchArray = array();

    $curTime = strtotime(date("Y-m-d H:i:s", time()));
    foreach ($serverList as $serverInfo) {
        $Channel = $serverInfo["Channel"];
        $ServerID = $serverInfo["ServerID"];
        $OpenServerWay = $serverInfo["OpenServerWay"];
        if ($OpenServerWay == 1) {
            if ($serverInfo["RelationServerOK"] != 1) {
                \Logging\LogInfo("根据创角人数自动开服的还未达到条件，不处理入口开放. Channel:" . $Channel . " ServerID:" . $ServerID);
                continue;
            }
        }
        $StartDateStr = $serverInfo["StartDate"];
        if (!$StartDateStr) {
            \Logging\LogError("not StartDate." . print_r($serverInfo, true));
            continue;
        }
        $startTime = strtotime(date("Y-m-d H:i:s", strtotime($StartDateStr)));
        if ($curTime < $startTime) {
            \Logging\LogInfo("time has not arrived. Channel:" . $Channel . " ServerID:" . $ServerID . " StartDate:" . $StartDateStr);
            continue;
        }
        if ($serverInfo["ClearState"] != 1) {
            \Logging\LogError("game server clearState error." . print_r($serverInfo, true));
            continue;
        }

        // 进一步检查最新服务器开服状态是否正常
        $checkUrl = "http://127.0.0.1/serverops/checkOpenServer.php";
        $retStr = \CommFunc\DoGet($checkUrl, array("channel" => $Channel, "serverID" => $ServerID));
        $checkRet = json_decode($retStr, true);
        if (!isset($checkRet) || !array_key_exists("errMsg", $checkRet) || $checkRet["errMsg"] != "OK") {
            \Logging\LogError("checkOpenServer error. Channel:" . $Channel . " ServerID:" . $ServerID . " ret:" . print_r($checkRet, true));
            continue;
        }
        $JsonBranch = $serverInfo["JsonBranch"];

        $find = array("Channel" => $Channel, "ServerID" => $ServerID);
        $set = array(
            "RunningStatus" => \ServerOPS\ServerRunningStatus::Light,
            "Statue" => \ServerOPS\ServerStatue::Open,
            "Recommend" => 1, // 新开放入口服默认推荐
        );
        if (\DBOper\Update("GameServers", $find, $set)) {
            \Logging\LogInfo("set server open ok." . print_r($serverInfo, true));
            // 其他服设置为不推荐
            \DBOper\Update("GameServers", array(
                "Channel" => $Channel,
                "ServerID" => array('$nin' => array($ServerID))
            ), array("Recommend" => 0), false, false, true);
            // 通知sp服务器开放
            \CommFunc\DoPost("http://127.0.0.1/serverops/hy/report_server.php", array("channel" => $Channel, "server_id" => $ServerID));
        } else {
            \Logging\LogError("set server open error." . print_r($serverInfo, true));
        }

        $refreshBranch = array("Channel" => $Channel, "JsonBranch" => $JsonBranch);
        if (!in_array($refreshBranch, $refrshJsonBranchArray)) {
            array_push($refrshJsonBranchArray, $refreshBranch);
        }

        if (\CommFunc\GetConfig("x7", "JsonBranch_" . $Channel, $branch) && $branch == $JsonBranch) {
            if (!array_key_exists($Channel, $x7notifyserverInfo)) {
                $x7notifyserverInfo[$Channel] = array();
            }
            $x7notifyserverList = $x7notifyserverInfo[$Channel];
            array_push($x7notifyserverList, $serverInfo);
            $x7notifyserverInfo[$Channel] = $x7notifyserverList;
        }
    }

    \Logging\LogInfo("refrshJsonBranchArray." . print_r($refrshJsonBranchArray, true));
    foreach ($refrshJsonBranchArray as $refreshBranch) {
        \ServerOPS\RefreshCommonServerlistJson($refreshBranch["Channel"], $refreshBranch["JsonBranch"], "System");
    }

    foreach ($x7notifyserverInfo as $Channel => $x7notifyserverList) {
        x7_common_serverNotify($Channel, $x7notifyserverList);
    }
}

function x7_common_serverNotify($appid, $notifyserverList)
{
    \Logging\LogInfo("x7_common_serverNotify " . $appid . " notifyserverList:" . print_r($notifyserverList, true));
    if (
        !\CommFunc\GetConfig("x7", "serverNotifyUrl", $serverNotifyUrl)
        || !\CommFunc\GetConfig("x7", "Appkey_" . $appid, $appkey)
        || !\CommFunc\GetConfig("x7", "Pubkey_" . $appid, $pubkey)
        || !\CommFunc\GetConfig("sign", "Prikey_" . $appid, $prikey)
    ) {
        return;
    }

    // bizParams字段	类型	必选	说明
    // serverList	Server[]	是	开服数据
    //
    // Server字段	类型	必选	说明
    // serverId	    String	是	区服ID（区服编号）
    // serverTime	String	是	开服时间，格式使用ISO8601规范，示例：2022-06-29T15:08:44+0800
    // serverName	String	否	区服名称，可为空
    // apiServer	String	否	api区服，如不为空，角色信息查询等接口会优先使用此值作为serverId进行调用查询

    $serverList = array();
    foreach ($notifyserverList as $serverInfo) {
        array_push(
            $serverList,
            array(
                "serverId" => $serverInfo["ServerID"] . "",
                "serverTime" => \CommFunc\StrDateTimeFormatConver($serverInfo["StartDate"], DATE_ISO8601),
                "serverName" => $serverInfo["ServerName"] . "",
                "apiServer" => "",
            )
        );
    }

    $apiMethod = "common.serverNotify";
    $bizParams = array(
        "serverList" => $serverList
    );
    send_common_to_x7($serverNotifyUrl, $bizParams, $appkey, $prikey, $pubkey, $apiMethod);
}

function checkOpenServerTime()
{
    \Logging\LogInfo("=== Do checkOpenServerTime ===");
    // 找出所有未清档服务器
    \DBOper\Find("GameServers", array("ClearState" => 0), $serverList);

    if (!$serverList) {
        return;
    }

    $aheadClearMin = 15; // 提前清档时间，分钟，0点~0点x分钟，统一0点清档，不然可能导致清档后0点又过天的问题；x=提前清档时间
    $aheadSyncMin = 15; // 相对清档时间提前同步设置清档时间，分钟

    $curTime = strtotime(date("Y-m-d H:i:s", time()));
    foreach ($serverList as $serverInfo) {
        $Channel = $serverInfo["Channel"];
        $ServerID = $serverInfo["ServerID"];
        $OpenServerWay = $serverInfo["OpenServerWay"];
        if ($OpenServerWay == 1) {
            if ($serverInfo["RelationServerOK"] != 1) {
                \Logging\LogInfo("根据创角人数自动开服的还未达到条件，不处理清档同步. Channel:" . $Channel . " ServerID:" . $ServerID);
                continue;
            }
        }
        $StartDate = $serverInfo["StartDate"];
        if ($serverInfo["ClearState"] == 1 || !$StartDate) {
            continue;
        }

        $startTime = \CommFunc\StrDateTimeToTime($StartDate);
        $zeroTimeA = \CommFunc\StrDateTimeToTime(substr($StartDate, 0, 10) . " 00:00:00");
        $zeroTimeB = \CommFunc\StrDateTimeToTime(substr($StartDate, 0, 10) . " 00:" . $aheadClearMin . ":00");
        if ($startTime >= $zeroTimeA && $startTime <= $zeroTimeB) {
            // 0点~0点x分之间默认0点清档
            $clearOpenServerDate = substr($StartDate, 0, 10) . " 00:00:00";
            // \Logging\LogInfo("特殊开服时间点默认0点清档 ServerID:" . $ServerID . " StartDate:" . $StartDate . " clearOpenServerDate:" . $clearOpenServerDate);
            $clearOpenServerTime = \CommFunc\StrDateTimeToTime($clearOpenServerDate);
        } else {
            $clearOpenServerTime = strtotime("-" . $aheadClearMin . " minutes", \CommFunc\StrDateTimeToTime($StartDate)); # 提前清档时间
            $clearOpenServerDate = \CommFunc\TimeToStrDateTime($clearOpenServerTime);
            // \Logging\LogInfo("开服清档时间 ServerID:" . $ServerID . " StartDate:" . $StartDate . " clearOpenServerDate:" . $clearOpenServerDate);
        }

        $syncTime = strtotime("-" . $aheadSyncMin . " minutes", $clearOpenServerTime); # 提前开始同步清档时间
        if ($curTime < $syncTime) {
            // \Logging\LogInfo("未到同步清档时间 ServerID:" . $ServerID . " StartDate:" . $StartDate . " clearOpenServerDate:" . $clearOpenServerDate .
            //     " syncTime:" . \CommFunc\TimeToStrDateTime($syncTime));
            continue;
        }

        $packData = array(
            "OpenServerDate" => substr($clearOpenServerDate, 0, 10),
            "OpenServerHour" => substr($clearOpenServerDate, 11, 2),
            "OpenServerMinute" => substr($clearOpenServerDate, 14, 2),
        );
        $serverIDArray = array($ServerID);

        \Logging\LogInfo("同步清档时间 Channel:" . $Channel . " ServerID:" . $ServerID . " StartDate:" . $StartDate
            . " clearOpenServerDate:" . $clearOpenServerDate . " packData:" . print_r($packData, true));

        $retList = \CommFunc\SendGMTToGameServers(True, "GMT_SetOpenServerTime", $packData, $Channel, $serverIDArray);
        \Logging\LogInfo("retList:" . print_r($retList, true));
        if (!is_array($retList)) {
            continue;
        }
        $ret = json_decode($retList[$ServerID], true);
        if (!$ret || !array_key_exists("ResultType", $ret) || $ret["ResultType"] != 0) {
            \Logging\LogError("同步清档失败 ServerID:" . $ServerID . " ResultMsg:" . $ret["ResultMsg"]);
            continue;
        }
        if (!DBOper\Update("GameServers", array("Channel" => $Channel, "ServerID" => $ServerID), array("ClearState" => 1))) {
            continue;
        }
        \Logging\LogInfo("GMT_SetOpenServerTime OK. ServerID:" . $ServerID . " packData:" . print_r($packData, true));
    }
}