ProxyPanel/app/Console/Commands/AutoCheckNodeStatusJob.php

<?php

namespace App\Console\Commands;

use App\Components\ServerChan;
use Illuminate\Console\Command;
use App\Http\Models\Config;
use App\Http\Models\SsNode;
use App\Http\Models\SsNodeInfo;
use App\Http\Models\EmailLog;
use App\Mail\nodeCrashWarning;
use Cache;
use Mail;
use Log;

class AutoCheckNodeStatusJob extends Command
{
    protected $signature = 'command:autoCheckNodeStatusJob';
    protected $description = '自动监测节点是否宕机';
    protected $cacheKey = 'node_shutdown_warning_';
    protected static $config;

    public function __construct()
    {
        parent::__construct();

        $config = Config::query()->get();
        $data = [];
        foreach ($config as $vo) {
            $data[$vo->name] = $vo->value;
        }

        self::$config = $data;
    }

    public function handle()
    {
        $nodeList = SsNode::query()->where('status', 1)->get();
        foreach ($nodeList as $node) {
            // 10分钟内无节点信息则认为是宕机，因为每个节点的负载信息最多保存10分钟
            $node_info = SsNodeInfo::query()->where('node_id', $node->id)->where('log_time', '>=', strtotime("-10 minutes"))->orderBy('id', 'desc')->first();
            if (empty($node_info) || empty($node_info->load)) {
                // 15分钟内已发警告，则不再发
                if (Cache::has($this->cacheKey . $node->id)) {
                    continue;
                }

                $title = "节点宕机警告";
                $content = "系统监测到节点【{$node->name}】({$node->server})可能宕机了，请及时检查。";

                // 发邮件通知管理员
                if (self::$config['is_node_crash_warning'] && self::$config['crash_warning_email']) {
                    try {
                        Mail::to(self::$config['crash_warning_email'])->send(new nodeCrashWarning(self::$config['website_name'], $node->name, $node->server));
                        $this->sendEmailLog(1, $title, $content);
                    } catch (\Exception $e) {
                        $this->sendEmailLog(1, $title, $content, 0, $e->getMessage());
                    }

                    // 写入发信缓存
                    Cache::put($this->cacheKey . $node->id, $node->name . '(' . $node->server . ')', 15);
                }

                // 通过ServerChan发微信消息提醒管理员
                if (self::$config['is_server_chan'] && self::$config['server_chan_key']) {
                    $serverChan = new ServerChan();
                    $result = $serverChan->send($title, $content, self::$config['server_chan_key']);
                    if ($result->errno > 0) {
                        $this->sendEmailLog(1, '[ServerChan]' . $title, $content);
                    } else {
                        $this->sendEmailLog(1, '[ServerChan]' . $title, $content, 0, $result->errmsg);
                    }

                    // 写入发信缓存
                    Cache::put($this->cacheKey . $node->id, $node->name . '(' . $node->server . ')', 15);
                }
            }
        }

        Log::info('定时任务：' . $this->description);
    }

    /**
     * 写入邮件发送日志
     * @param int $user_id 接收者用户ID
     * @param string $title 标题
     * @param string $content 内容
     * @param int $status 投递状态
     * @param string $error 投递失败时记录的异常信息
     */
    private function sendEmailLog($user_id, $title, $content, $status = 1, $error = '')
    {
        $emailLogObj = new EmailLog();
        $emailLogObj->user_id = $user_id;
        $emailLogObj->title = $title;
        $emailLogObj->content = $content;
        $emailLogObj->status = $status;
        $emailLogObj->error = $error;
        $emailLogObj->created_at = date('Y-m-d H:i:s');
        $emailLogObj->save();
    }
}