<?php
/**
 * @remark :
 * @name   :DomainInfo.php
 * @author :lyh
 * @method :post
 * @time   :2023/9/11 14:37
 */

namespace App\Console\Commands\Domain;

use App\Models\Devops\ServerConfig;
use App\Models\Devops\ServersIp;
use App\Models\Domain\DomainCreateTask;
use App\Models\Project\CountryCustom;
use App\Models\Project\Project;
use Illuminate\Console\Command;
use App\Models\Domain\DomainInfo as DomainInfoModel;
use Symfony\Component\Process\Process;

class DomainInfo extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'domain_info';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = '域名相关';

    /**
     * @remark :更新证书+证书有效时间
     * @name   :handle
     * @author :lyh
     * @method :post
     * @time   :2023/9/11 15:09
     */
    public function handle()
    {
        //主站证书到期更新
        $this->startUpdateCert();

        //AMP站证书到期更新
        $this->startUpdateAmpCert();

        //创建的自定义小语种域名证书到期更新
        $this->startUpdateCustomCert();

        return true;
    }

    /**
     * 主站证书到期更新
     * @author Akun
     * @date 2024/02/26 10:26
     */
    public function startUpdateCert()
    {
        $domainModel = new DomainInfoModel();
        $projectModel = new Project();
        $serverIpModel = new ServersIp();
        $domainCreateTaskModel = new DomainCreateTask();
        $end_day = date('Y-m-d H:i:s', time() + 3 * 24 * 3600);//3天后到期
        $list = $domainModel->where('status', '=', 1)->where('type', '!=', 2)->where('certificate_end_time', '<', $end_day)->get()->toArray();
        foreach ($list as $v) {
            $project_info = $projectModel->read(['id' => $v['project_id']], ['serve_id']);
            if (!$project_info) {
                continue;
            }

            $servers_ip_info = $serverIpModel->read(['id' => $project_info['serve_id']], ['servers_id', 'ip', 'domain']);
            if (!$servers_ip_info) {
                continue;
            }

            //过滤自建站项目域名
            if ($servers_ip_info['servers_id'] == ServerConfig::SELF_SITE_ID) {
                continue;
            }

            //过滤已解析到别的ip的域名
            if (!$this->check_cname($v['domain'], $servers_ip_info)) {
                continue;
            }

            //创建更新站点证书任务
            $task_info = $domainCreateTaskModel->read(['type' => DomainCreateTask::TYPE_MAIN, 'domain_id' => $v['id'], 'status' => ['<', DomainCreateTask::STATUS_SUC]]);
            if (!$task_info) {
                $domainCreateTaskModel->add([
                    'server_id' => $servers_ip_info['servers_id'],
                    'project_id' => $v['project_id'],
                    'domain_id' => $v['id'],
                    'type' => DomainCreateTask::TYPE_MAIN
                ]);
            }
        }
    }

    /**
     * AMP站证书到期更新
     * @author Akun
     * @date 2024/02/26 10:26
     */
    public function startUpdateAmpCert()
    {
        $domainModel = new DomainInfoModel();
        $projectModel = new Project();
        $serverIpModel = new ServersIp();
        $domainCreateTaskModel = new DomainCreateTask();
        $end_day = date('Y-m-d H:i:s', time() + 3 * 24 * 3600);//3天后到期
        $list = $domainModel->where('status', '=', 1)->where('amp_status', 1)->where('amp_type', '!=', 2)->where('amp_certificate_end_time', '<', $end_day)->get()->toArray();
        foreach ($list as $v) {
            $domain_array = parse_url($v['domain']);
            $host = $domain_array['host'] ?? $domain_array['path'];
            $host_array = explode('.', $host);
            if (count($host_array) <= 2) {
                array_unshift($host_array, 'm');
            } else {
                $host_array[0] = 'm';
            }
            $amp_domain = implode('.', $host_array);

            $project_info = $projectModel->read(['id' => $v['project_id']], ['serve_id']);
            if (!$project_info) {
                continue;
            }

            $servers_ip_info = $serverIpModel->read(['id' => $project_info['serve_id']], ['servers_id', 'ip', 'domain']);
            if (!$servers_ip_info) {
                continue;
            }

            //过滤自建站项目域名
            if ($servers_ip_info['servers_id'] == ServerConfig::SELF_SITE_ID) {
                continue;
            }

            //过滤已解析到别的ip的域名
            if (!$this->check_cname($amp_domain, $servers_ip_info)) {
                continue;
            }

            //创建更新站点证书任务
            $task_info = $domainCreateTaskModel->read(['type' => DomainCreateTask::TYPE_AMP, 'domain_id' => $v['id'], 'status' => ['<', DomainCreateTask::STATUS_SUC]]);
            if (!$task_info) {
                $domainCreateTaskModel->add([
                    'server_id' => $servers_ip_info['servers_id'],
                    'project_id' => $v['project_id'],
                    'domain_id' => $v['id'],
                    'type' => DomainCreateTask::TYPE_AMP
                ]);
            }
        }
    }

    /**
     * 自定义小语种站证书到期更新
     * @author Akun
     * @date 2024/03/23 10:08
     */
    public function startUpdateCustomCert()
    {
        $customModel = new CountryCustom();
        $projectModel = new Project();
        $serverIpModel = new ServersIp();
        $domainCreateTaskModel = new DomainCreateTask();
        $end_day = date('Y-m-d H:i:s', time() + 3 * 24 * 3600);//3天后到期
        $list = $customModel->where('status', 1)->where('is_create', 1)->where('type', '!=', 2)->where('certificate_end_time', '<', $end_day)->get()->toArray();
        foreach ($list as $v) {
            $project_info = $projectModel->read(['id' => $v['project_id']], ['serve_id']);
            if (!$project_info) {
                continue;
            }

            $servers_ip_info = $serverIpModel->read(['id' => $project_info['serve_id']], ['servers_id', 'ip', 'domain']);
            if (!$servers_ip_info) {
                continue;
            }

            //过滤自建站项目域名
            if ($servers_ip_info['servers_id'] == ServerConfig::SELF_SITE_ID) {
                continue;
            }

            //过滤已解析到别的ip的域名
            if (!$this->check_cname($v['custom_domain'], $servers_ip_info)) {
                continue;
            }

            //创建更新站点证书任务
            $task_info = $domainCreateTaskModel->read(['type' => DomainCreateTask::TYPE_CUSTOM, 'domain_id' => $v['id'], 'status' => ['<', DomainCreateTask::STATUS_SUC]]);
            if (!$task_info) {
                $domainCreateTaskModel->add([
                    'server_id' => $servers_ip_info['servers_id'],
                    'project_id' => $v['project_id'],
                    'domain_id' => $v['id'],
                    'type' => DomainCreateTask::TYPE_CUSTOM
                ]);
            }
        }
    }

    /**
     * 验证是否cname或者A记录解析到目标服务器
     * @param $domain
     * @param $server_info
     * @return mixed
     * @author zbj
     * @date 2023/11/13
     */
    public function check_cname($domain, $server_info)
    {
        $process = new Process(['nslookup', '-qt=a', $domain]);
        $process->run();
        $output = explode(PHP_EOL, $process->getOutput());
        foreach ($output as $line) {
            if ($line) {
                $checkA = strpos($line, $server_info['ip']) !== false;
                if ($checkA) {
                    return $domain;
                }
            }
        }

        //是否cname
        $process = new Process(['nslookup', '-qt=cname', $domain]);
        $process->run();
        $output = explode(PHP_EOL, $process->getOutput());
        foreach ($output as $line) {
            if ($line) {
                $checkCname = (strpos($line, $server_info['domain']) !== false);
                if ($checkCname) {
                    return $domain;
                }
            }
        }
        return false;
    }
}