neiyou_user_web/app/Console/Commands/NodeBlockedDetection.php

<?php

namespace App\Console\Commands;

use App\Components\NetworkDetection;
use App\Models\Node;
use App\Models\User;
use App\Notifications\NodeBlocked;
use Cache;
use Illuminate\Console\Command;
use Log;
use Notification;

class NodeBlockedDetection extends Command
{
    protected $signature = 'nodeBlockedDetection';
    protected $description = '节点阻断检测';

    public function handle(): void
    {
        $jobStartTime = microtime(true);
        if (sysConfig('nodes_detection')) {
            if (! Cache::has('LastCheckTime')) {
                $this->checkNodes();
            } elseif (Cache::get('LastCheckTime') <= time()) {
                $this->checkNodes();
            } else {
                Log::info('下次节点阻断检测时间：'.date('Y-m-d H:i:s', Cache::get('LastCheckTime')));
            }
        }

        $jobEndTime = microtime(true);
        $jobUsedTime = round(($jobEndTime - $jobStartTime), 4);

        Log::info("---【{$this->description}】完成---，耗时 {$jobUsedTime} 秒");
    }

    // 监测节点状态
    private function checkNodes(): void
    {
        $detectionCheckTimes = sysConfig('detection_check_times');
        $sendText = false;
        $message = "| 线路 | 协议 | 状态 |\r\n| ------ | ------ | ------ |\r\n";
        $additionalMessage = '';
        foreach (Node::whereIsRelay(0)->whereStatus(1)->where('detection_type', '>', 0)->get() as $node) {
            $info = false;
            if ($node->detection_type === 0) {
                continue;
            }
            // 使用DDNS的node先通过gethostbyname获取ipv4地址
            if ($node->is_ddns) {
                $ip = gethostbyname($node->server);
                if (strcmp($ip, $node->server) !== 0) {
                    $node->ip = $ip;
                } else {
                    Log::warning('【节点阻断检测】检测'.$node->server.'时，IP获取失败'.$ip.' | '.$node->server);
                }
            }
            if ($node->detection_type !== 1) {
                $icmpCheck = (new NetworkDetection)->networkCheck($node->ip, true);
                if ($icmpCheck !== false && $icmpCheck !== '通讯正常') {
                    $message .= '| '.$node->name.' | ICMP | '.$icmpCheck." |\r\n";
                    $sendText = true;
                    $info = true;
                }
            }
            if ($node->detection_type !== 2) {
                $tcpCheck = (new NetworkDetection)->networkCheck($node->ip, false, $node->single ? $node->port : 22);
                if ($tcpCheck !== false && $tcpCheck !== '通讯正常') {
                    $message .= '| '.$node->name.' | TCP | '.$tcpCheck." |\r\n";
                    $sendText = true;
                    $info = true;
                }
            }
            sleep(5);

            // 节点检测次数
            if ($info && $detectionCheckTimes) {
                // 已通知次数
                $cacheKey = 'detection_check_times'.$node->id;
                if (Cache::has($cacheKey)) {
                    $times = Cache::get($cacheKey);
                } else {
                    // 键将保留12小时，多10分钟防意外
                    Cache::put($cacheKey, 1, 43800);
                    $times = 1;
                }

                if ($times < $detectionCheckTimes) {
                    Cache::increment($cacheKey);
                } else {
                    Cache::forget($cacheKey);
                    $node->update(['status' => 0]);
                    $additionalMessage .= "\r\n节点【{$node->name}】自动进入维护状态\r\n";
                }
            }
        }

        //只有在出现阻断线路时，才会发出警报
        if ($sendText) {
            Notification::send(User::permission('admin.node.edit,update')->orWhere(function ($query) {
                return $query->role('Super Admin');
            })->get(), new NodeBlocked($message.$additionalMessage));

            Log::info("阻断日志: \r\n".$message.$additionalMessage);
        }

        // 随机生成下次检测时间
        Cache::put('LastCheckTime', time() + random_int(3000, Hour), 3700);
    }
}