main.php

<?php

require __DIR__ . '/vendor/autoload.php';
require __DIR__ . '/config.php';
require __DIR__ . '/KaiheilaBot/commandInterpreter/TaskProcessor.php';

use kaiheila\api\base\WebsocketSession;
use Kaiheila\httpAPI\SendMessage;
use KaiheilaBot\commandInterpreter\TaskProcessor;

$statusServer = Swlib\Saber::create([
    'base_uri' => 'http://bot.gekj.net',
    'timeout' => 30,
    'headers' => [
        'uuid' => UUID
    ]
]);

//向BotMarket发送机器人在线状态
function sendStatus(): void
{
    global $statusServer;
    try {
        $result = $statusServer->post('/api/v1/online.bot');
    } catch (\Swlib\Http\Exception\ClientException $e) {
        echo date('[Y-m-d H:i:s]') . " [ERROR] 错误URL访问，请确认链接是否正确\n";
    } catch (\Swlib\Http\Exception\ConnectException $e) {
        echo date('[Y-m-d H:i:s]') . " [ERROR] 无法与服务器取得响应\n";
    } catch (\Swlib\Http\Exception\ServerException $e) {
        echo date('[Y-m-d H:i:s]') . " [ERROR] 目标服务器无响应\n";
    }
    echo date('[Y-m-d H:i:s]') . " [SUCCESS] 成功向服务器发送在线状态\n";
}

function mainWork(): void
{
    $loop = false;

    // 构造数据库链接参数
    if (DbType === 'PostgreSQL') {
        $dbConn_opts = 'host=' . DbHost . ' port=' . DbPort . ' dbname=' . DbName . ' user=' . DbUsername . ' password=' . DbPassword;
        $dbSetting = array(DbType, $dbConn_opts);
    }
    if (DbType === 'MySQL') {
        $dbConn_opts = array(DbHost, DbUsername, DbPassword, DbName, DbPort);
        $dbSetting = array(DbType, $dbConn_opts);
    }

    // 构造 http 通讯对象
    $httpAPI = new SendMessage(TOKEN);
    $processor = new TaskProcessor($dbSetting, $httpAPI, XIVAPIPrivateKey);

    // 构造 Websocket 通讯对象
    $session = new WebsocketSession(TOKEN, BASE_URL, __DIR__ . '/session.pid');

    //修改 log 文件位置 （BaseObject内容）
    $session->logFile = __DIR__ . '/FF14BotMsg.log';

    // Websocket 消息监听
    $session->on('GROUP*', function ($frame) use ($session, $processor) {
        $session->log('receiveGroup', '收到频道消息');
        $messageData = $frame->d['content'];

        //预留，未来可能做私聊消息
        $type = $frame->d['channel_type'];

        //非系统消息提醒（用户在频道内加入语音等会产生系统消息）
        if ($frame->d['author_id'] !== '1') {
            $messageInfo = array(
                'channelID' => $frame->d['target_id'],
                'messageID' => $frame->d['msg_id'],
                'senderID' => $frame->d['author_id'],
                'serverID' => $frame->d['extra']['guild_id'],
                'channelName' => $frame->d['extra']['channel_name'],
                'senderName' => $frame->d['extra']['author']['username']
            );
            if (str_starts_with($messageData, '/')) {
                $processor->run($messageData, $messageInfo);
            }
        }
    });

    $session->start();
}

\Co\run(function () {
    sendStatus();
    $timer = swoole_timer_tick(1800000, 'sendStatus');
    mainWork();
});