<?php
include_once "/Common/Logging.php";
include_once "/Common/CommFunc.php";
include_once "/Account/User.php";
include_once '/db/RedisOper.php';

\Logging\CreateLogging("chatmonitorserver2.php");
\Logging\LogInfo("_POST:" . print_r($_POST, true));
$spid = $_POST["spid"];

$interfaceConfig = parse_ini_file("/InterfaceConfig.php", true);
$GameName = $interfaceConfig["ServerInfo"]["GameName"];
$CacheChatCount = $interfaceConfig["Chatmonitor"]["CacheChatCount"];

$redisKey = \RedisOper\GetFCRedisKey($GameName, "Chatmonitor", $spid);

$retArray = array();
if ($_POST["AccountID"]) {
    $chat["Time"];
    $doCountMax = 12; // 执行取数据次数
    $perCountSleep = 5; // 每次执行后休眠x秒
    $sleepTime = $doCountMax * $perCountSleep;
    if ($sleepTime >= 30) {
        set_time_limit($sleepTime + 30); // 限制执行时长秒 30秒 + 休眠时长
    }

    // 直到取到有新数据
    $doCount = 0;
    while ($doCount < $doCountMax && count($retArray) <= 0) {
        $doCount += 1;
        if ($doCount > 1) {
            sleep($perCountSleep);
        }
        // 取最后一条之后的数据
        $startIndex = 0;
        $stopIndex = -1;
        $perGetCount = 10; // 每次一次性取几条数据
        $loopCount = $CacheChatCount / $perGetCount;
        // \Logging\LogInfo("doCount:" . $doCount . " CacheChatCount :" . $CacheChatCount . " loopCount:" . $loopCount);
        $isEnd = false;
        while (!$isEnd && $loopCount >= 0) {
            $loopCount -= 1;
            $startIndex -= $perGetCount;
            // \Logging\LogInfo("i :" . $i . " index:" . $startIndex . " ~ " . $stopIndex);
            // 从后往前读
            if (!\RedisOper\ListRange($redisKey, $ret, $startIndex, $stopIndex)) {
                break;
            }
            if (isset($ret) && count($ret) > 0) {
                // \Logging\LogInfo("retCount:" . count($ret));
                // 倒序遍历
                for ($j = count($ret) - 1; $j >= 0; $j--) {
                    $chat = $ret[$j];
                    if ($chat["Time"] < $_POST["Time"] && $_POST["Time"] && $_POST["Time"] != "undefined") {
                        $isEnd = true;
                        break;
                    }
                    if ($chat["AccountID"] == $_POST['AccountID'] && $chat["Time"] == $_POST['Time'] && $chat["Content"] == $_POST['Content']) {
                        $isEnd = true;
                        break;
                    }
                    array_splice($retArray, 0, 0, array($chat));
                    // \Logging\LogInfo("array_splice count:" . count($retArray) . print_r($chat, true));
                }
            } else {
                $isEnd = true;
            }
            $stopIndex = $startIndex - 1;
        }
    }
} else {
    // 全部
    if (!\RedisOper\ListRange($redisKey, $retArray, 0, -1)) {
        exit;
    }
}
if (!isset($retArray) || count($retArray) <= 0) {
    exit;
}

$msg = array("MsgType" => "CHAT", "Msg" => $retArray);
echo json_encode($msg);