<?php

namespace App\Console\Commands\Domain;

use App\Models\Com\Notify;
use App\Models\Devops\ServersIp;
use App\Models\Domain\DomainCreateTask;
use App\Models\Project\Project;
use App\Models\Project\ProjectServerBackup;
use App\Models\Domain\DomainInfo;
use Illuminate\Console\Command;
use Symfony\Component\Process\Process;

class EmergencyRenewSite extends Command
{
    protected $signature = 'emergency_renew_site {server_id}';
    protected $description = '紧急重建站点';

    public function handle()
    {
        //目标服务器
        $target_server_id = 1;
        $server_ip_model = new ServersIp();
        $target_server = $server_ip_model->select(['id', 'ip', 'domain'])->where('servers_id', $target_server_id)->first()->toArray();

        //受灾服务器
        $server_id = $this->argument('server_id');;
        $server_ip_ids = $server_ip_model->where('servers_id', $server_id)->get()->pluck('id')->toArray();

        //获取所有受灾项目
        $project_list = Project::select(['id', 'serve_id', 'title'])->whereIn('serve_id', $server_ip_ids)->get();
        $domain_model = new DomainInfo();
        $create_model = new DomainCreateTask();
        $notify_model = new Notify();
        $backup_model = new ProjectServerBackup();
        if ($project_list->count() > 0) {
            foreach ($project_list as $value) {
                $domain_info = $domain_model->read(['project_id' => $value->id, 'status' => 1], ['id', 'domain']);
                if (!$domain_info) {
                    //过滤未绑定正式域名的项目
                    continue;
                }

                //判断域名是否已经解析到目标服务器
                if (!check_domain_record($domain_info['domain'], $target_server)) {
                    $this->output($domain_info['domain'] . ' | 未解析到目标服务器');
                    continue;
                }

                //创建目标服务器建站任务
                $map_create = [
                    'type' => DomainCreateTask::TYPE_MAIN,
                    'server_id' => $target_server_id,
                    'project_id' => $value->id,
                    'domain_id' => $domain_info['id'],
                    'status' => DomainCreateTask::STATUS_UN,
                ];
                $task_info = $create_model->read($map_create, ['id']);
                if (!$task_info) {
                    $create_model->add($map_create);
                }

                //创建目标服务器站点页面生成任务
                $map_notify = [
                    'type' => Notify::TYPE_MASTER,
                    'server_id' => $target_server_id,
                    'project_id' => $value->id,
                    'status' => Notify::STATUS_INIT,
                    'route' => Notify::ROUTE_ALL,
                ];
                $notify_info = $notify_model->read($map_notify);
                if (!$notify_info) {
                    $map_notify['data'] = json_encode(['domain' => $domain_info['domain'], 'url' => [], 'language' => []]);
                    $map_notify['sort'] = 9;
                    $notify_model->add($map_notify);
                }

                //备份项目原始服务器
                $backup_info = $backup_model->read(['project_id' => $value->id, 'status' => ProjectServerBackup::STATUS_NO], ['id']);
                if ($backup_info) {
                    $backup_model->edit(['server_id' => $server_id, 'server_ip_id' => $value->serve_id], ['id' => $backup_info['id']]);
                } else {
                    $backup_model->add(['project_id' => $value->id, 'server_id' => $server_id, 'server_ip_id' => $value->serve_id]);
                }

                //更改项目服务器
                $value->serve_id = $target_server_id;
                $value->save();

                $this->output($domain_info['domain'] . ' | success');
            }
        }
    }

    /**
     * 输出处理日志
     * @param $message
     */
    public function output($message)
    {
        echo date('Y-m-d H:i:s') . ' | ' . $message . PHP_EOL;
    }
}