<?php

namespace App\Components;

use Http;
use Log;

class NetworkDetection
{
    /**
     * 用外部API进行Ping检测.
     *
     * @param  string  $ip  被检测的IP或者域名
     * @return bool
     */
    public function ping(string $ip)
    {
        $round = 1;
        // 依次尝试接口
        while (true) {
            switch ($round) {
                case 0:
                    $ret = $this->oiowebPing($ip);
                    break;
                case 1:
                    $ret = $this->xiaoapiPing($ip);
                    break;
                case 2:
                    $ret = $this->yum6Ping($ip);
                    break;
                default:
                    return false;
            }
            if ($ret !== false) {
                return $ret;
            }
            $round++;
        }
    }

    private function oiowebPing(string $ip)
    {
        $msg = null;
        foreach ([1, 6, 14] as $line) {
            $url = "https://api.oioweb.cn/api/hostping.php?host={$ip}&node={$line}"; // https://api.iiwl.cc/api/ping.php?host=
            $response = Http::timeout(20)->get($url);

            // 发送成功
            if ($response->ok()) {
                $message = $response->json();
                if ($message && $message['code']) {
                    $msg .= "{$message['node']}：{$message['data']['Time']}<br>";
                }
            } else {
                return false;
            }
        }

        if ($msg) {
            return $msg;
        }
        Log::warning('【PING】检测'.$ip.'时，api.oioweb.cn无结果');

        // 发送错误
        return false;
    }

    private function xiaoapiPing(string $ip)
    { // 来源 https://xiaoapi.cn/?action=doc&id=3
        $msg = null;

        $url = "https://xiaoapi.cn/API/sping.php?url={$ip}";
        $response = Http::timeout(20)->get($url);

        // 发送成功
        if ($response->ok()) {
            return $response->body();
        }
        Log::warning('【PING】检测'.$ip.'时，xiaoapi.cn无结果');

        // 发送错误
        return false;
    }

    private function yum6Ping(string $ip)
    { // 来源 https://api.yum6.cn/ping.php?host=api.yum6.cn
        $url = "https://api.yum6.cn/ping.php?host={$ip}";
        $response = Http::timeout(20)->get($url);

        // 发送成功
        if ($response->ok()) {
            $msg = $response->json();
            if ($msg && $msg['state'] === '1000') {
                return "<h4>{$msg['ip']}</h4>线路【{$msg['node']}】<br> 最小值：{$msg['ping_time_min']}<br> 平均值：{$msg['ping_time_avg']}<br> 最大值：{$msg['ping_time_max']}";
            }
        }
        Log::warning('【PING】检测'.$ip.'时，api.yum6.cn无结果');

        // 发送错误
        return false;
    }

    /**
     * 通过众多API进行节点阻断检测.
     *
     * @param  string  $ip  被检测的IP
     * @param  bool  $is_icmp  TRUE 为ICMP,FALSE 为tcp
     * @param  int|null  $port  检测端口，默认为空
     * @return bool
     */
    public function networkCheck(string $ip, bool $is_icmp, int $port = null)
    {
        $round = 1;
        // 依次尝试接口
        while (true) {
            switch ($round) {
                case 0:
                    $ret = $this->idcWiki($ip, $is_icmp, $port);
                    break;
                case 1:
                    $ret = $this->flyzy2005($ip, $is_icmp, $port);
                    break;
                case 2:
                    $ret = $this->vps234($ip, $is_icmp);
                    break;
                case 3:
                    $ret = $this->idcoffer($ip, $is_icmp, $port);
                    break;
                case 4:
                    $ret = $this->gd($ip, $is_icmp, $port);
                    break;
                case 5:
                    $ret = $this->ip112($ip, $is_icmp, $port);
                    break;
                default:
                    return false;
            }
            if ($ret !== false) {
                return $ret;
            }
            $round++;
        }
    }

    private function idcWiki(string $ip, bool $is_icmp, int $port = null)
    {
        if ($is_icmp) {
            $type_string = 'icmp/';
            $checkName = 'ICMP';
        } else {
            $type_string = 'tcp_ack/';
            $checkName = 'TCP';
        }
        if ($port) {
            $port = '/'.$port;
            $type_string = 'tcp_port/';
        }

        $url = "https://api.50network.com/china-firewall/check/ip/{$type_string}{$ip}{$port}";

        $response = Http::timeout(20)->get($url);

        if ($response->ok()) {
            $message = $response->json();
            if (! $message) {
                Log::warning('【'.$checkName.'阻断检测】检测'.$ip.'时，接口返回异常访问链接：'.$url);

                return false;
            }

            if (! $message['success']) {
                if (isset($message['error']) && $message['error'] === 'execute timeout (3s)') {
                    return false;
                }

                Log::warning('【'.$checkName.'阻断检测】检测'.$ip.$port.'时，返回'.var_export($message, true));

                return false;
            }

            if ($message['firewall-enable'] && $message['firewall-disable']) {
                return 1; // 正常
            }

            if ($message['firewall-enable'] && ! $message['firewall-disable']) {
                return 2; // 国外访问异常
            }

            if (! $message['firewall-enable'] && $message['firewall-disable']) {
                return 3; // 被墙
            }

            return 4; // 服务器宕机
        }

        return false;
    }

    private function flyzy2005(string $ip, bool $is_icmp, int $port = null)
    {
        $cn = "https://mini.flyzy2005.cn/ip_check.php?ip={$ip}&port={$port}";
        $us = "https://mini.flyzy2005.cn/ip_check_outside.php?ip={$ip}&port={$port}";

        $checkName = $is_icmp ? 'icmp' : 'tcp';

        $response_cn = Http::timeout(20)->get($cn);
        $response_us = Http::timeout(20)->get($us);

        if ($response_cn->ok() && $response_us->ok()) {
            $cn = $response_cn->json();
            $us = $response_us->json();
            if (! $cn || ! $us) {
                Log::warning("【{$checkName}阻断检测】检测{$ip}时，接口返回异常访问链接：{$cn} | {$us}");

                return false;
            }

            if ($cn[$checkName] === 'success' && $us['outside_'.$checkName] === 'success') {
                return 1; // 正常
            }

            if ($cn[$checkName] === 'success' && $us['outside_'.$checkName] !== 'success') {
                return 2; // 国外访问异常
            }

            if ($cn[$checkName] !== 'success' && $us['outside_'.$checkName] === 'success') {
                return 3; // 被墙
            }

            return 4; // 服务器宕机
        }

        return false;
    }

    private function vps234(string $ip, bool $is_icmp)
    {
        $url = 'https://www.vps234.com/ipcheck/getdata/';

        $checkName = $is_icmp ? 'ICMP' : 'TCP';

        $response = Http::timeout(20)->withoutVerifying()->asForm()->post($url, ['ip' => $ip]);
        if ($response->ok()) {
            $message = $response->json();
            if (! $message) {
                Log::warning('【'.$checkName.'阻断检测】检测'.$ip.'时，接口返回异常访问链接：'.$url);

                return false;
            }

            if (! $message['data']['success']) {
                Log::warning('【'.$checkName.'阻断检测】检测'.$ip.'时，返回'.var_export($message, true));

                return false;
            }

            if ($message['data']['data']['inner'.$checkName] && $message['data']['data']['out'.$checkName]) {
                return 1; // 正常
            }

            if ($message['data']['data']['inner'.$checkName] && ! $message['data']['data']['out'.$checkName]) {
                return 2; // 国外访问异常
            }

            if (! $message['data']['data']['inner'.$checkName] && $message['data']['data']['out'.$checkName]) {
                return 3; // 被墙
            }

            return 4; // 服务器宕机
        }

        return false;
    }

    private function idcoffer(string $ip, bool $is_icmp, int $port = null)
    { // 来源：https://www.idcoffer.com/ipcheck
        $cn = "https://api.24kplus.com/ipcheck?host={$ip}&port={$port}";
        $us = "https://api.idcoffer.com/ipcheck?host={$ip}&port={$port}";
        $checkName = $is_icmp ? 'ping' : 'tcp';

        $response_cn = Http::timeout(20)->get($cn);
        $response_us = Http::timeout(20)->get($us);

        if ($response_cn->ok() && $response_us->ok()) {
            $cn = $response_cn->json();
            $us = $response_us->json();
            if (! $cn || ! $us) {
                Log::warning("【{$checkName}阻断检测】检测{$ip}时，接口返回异常访问链接：{$cn} | {$us}");

                return false;
            }

            if (! $cn['code'] || ! $us['code']) {
                Log::warning('【'.$checkName.'阻断检测】检测'.$ip.$port.'时，返回'.var_export($cn, true).var_export($us, true));

                return false;
            }

            if ($cn['data'][$checkName] && $us['data'][$checkName]) {
                return 1; // 正常
            }

            if ($cn['data'][$checkName] && ! $us['data'][$checkName]) {
                return 2; // 国外访问异常
            }

            if (! $cn['data'][$checkName] && $us['data'][$checkName]) {
                return 3; // 被墙
            }

            return 4; // 服务器宕机
        }

        return false;
    }

    private function gd(string $ip, bool $is_icmp, int $port = 443)
    { // 来源：https://ping.gd/
        $url = "https://ping.gd/api/ip-test/{$ip}:".($port ?? 443);

        $checkName = $is_icmp ? 'ping_alive' : 'telnet_alive';

        $response = Http::timeout(20)->get($url);

        if ($response->ok()) {
            $message = $response->json();
            if (! $message) {
                Log::warning("【{$checkName}阻断检测】检测{$ip}时，接口返回异常访问链接：{$url}");

                return false;
            }

            if ($message[0]['result'][$checkName] && $message[1]['result'][$checkName]) {
                return 1; // 正常
            }

            if ($message[0]['result'][$checkName] && ! $message[1]['result'][$checkName]) {
                return 2; // 国外访问异常
            }

            if (! $message[0]['result'][$checkName] && $message[1]['result'][$checkName]) {
                return 3; // 被墙
            }

            return 4; // 服务器宕机
        }

        return false;
    }

    private function ip112(string $ip, bool $is_icmp, int $port = 443)
    { // 来源：https://ip112.cn/
        $cn = 'https://api.zhujiquanzi.com/ipcheck/ipcheck.php';
        $us = 'https://api.52bwg.com/ipcheck/ipcheck.php';
        $checkName = $is_icmp ? 'icmp' : 'tcp';

        $response_cn = Http::asForm()->post($cn, ['ip' => $ip, 'port' => $port]);
        $response_us = Http::asForm()->post($us, ['ip' => $ip, 'port' => $port]);

        if ($response_cn->ok() && $response_us->ok()) {
            $cn = $response_cn->json();
            $us = $response_us->json();
            if (! $cn || ! $us) {
                Log::warning("【{$checkName}阻断检测】检测{$ip}时，接口返回异常访问链接：{$cn} | {$us}");

                return false;
            }

            if (str_contains($cn[$checkName], 'green') && str_contains($us[$checkName], 'green')) {
                return 1; // 正常
            }

            if (str_contains($cn[$checkName], 'green') && ! str_contains($us[$checkName], 'green')) {
                return 2; // 国外访问异常
            }

            if (! str_contains($cn[$checkName], 'green') && str_contains($us[$checkName], 'green')) {
                return 3; // 被墙
            }

            return 4; // 服务器宕机
        }

        return false;
    }
}