<?php
/**
 * Created by PhpStorm.
 * User: zhl
 * Date: 2025/2/17
 * Time: 11:24
 */
namespace App\Console\Commands\Inquiry;

use App\Models\Channel\Channel;
use App\Models\Domain\DomainInfo;
use App\Models\Inquiry\InquiryProject;
use App\Models\Inquiry\InquiryProjectRoute;
use App\Models\Product\Category;
use App\Models\Product\Product;
use App\Models\Project\OnlineCheck;
use App\Models\Project\Project;
use App\Services\ProjectServer;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;

/**
 * Class SyncInquiryProject
 * @package App\Console\Commands\Inquiry
 */
class SyncInquiryProject extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'sync_inquiry_project';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = '同步询盘信息：项目以及对应路由，';

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }

    /**
     * 同步优化项目及路由
     * TODO 同步v4 v5 v6项目以及路由， 删除过期项目及路由
     * @return bool
     */
    public function handle()
    {
        echo '开始同步v5' . PHP_EOL;
        $this->syncGloV5();
        echo '开始同步v6' . PHP_EOL;
        $this->syncGloV6();
        echo '删除过期数据' . PHP_EOL;
        $this->deleteExpire();
        return true;
    }

    /**
     * 同步v4 、 v5项目
     * @return bool
     */
    public function syncGloV5()
    {
        $result = http_get('https://www.quanqiusou.cn/extend_api/webs/globalso_v5_tg.php');
        $channel = Channel::pluck('contact_mobile', 'id')->toArray();
        foreach ($result as $key=>$val)
        {
            echo '同步项目：' . $val['postid'] . ' - ' . $val['company'] . PHP_EOL;
            // 记录渠道商, 如果渠道有问题， 记录日志， 跳过当前项目， 处理数据后， 第二天再重新同步
            $channel_flag = false;
            $channel_tmp = [];
            foreach ($val['agent'] as $v) {
                $channel_id = array_search($v, $channel);
                if (empty($channel_id)) {
                    $this->log('ERROR 代理商找不到不记录当前项目, 代理商手机号码：' . $v);
                    $channel_flag = true;
                    break;
                }
                array_push($channel_tmp, $channel_id);
            }

            if ($channel_flag || empty($channel_tmp)) {
                $this->log('ERROR 代理商找不到不记录当前项目, 项目ID：' . $val['postid']);
                continue;
            }

            // 保存项目 以及路由
            $project = InquiryProject::saveProject($val['v'], $val['postid'], $val['company'], implode(',', $channel_tmp), $val['main_url'], $val['is_split'], $val['test_url']);
            $route_domain = $val['is_split'] && $val['test_url'] ? $val['test_url'] : $val['main_url'];
            $this->syncGloV5Route($project->id, $route_domain);
        }
        return true;
    }

    /**
     * 同步v4 v5项目路由
     * @param $project_id
     * @param $route_domain
     * @return bool
     */
    public function syncGloV5Route($project_id, $route_domain)
    {
        try{
            $result = http_get($route_domain . 'k_u_api.php');
            if (empty($result)) {
                $this->log('syncGloV5Route 未获取到路由信息：' . $project_id . ', 路由获取地址：' . $route_domain . 'k_u_api.php');
                return false;
            }
        } catch (\Exception $e) {
            $this->log('syncGloV5Route 未获取到路由信息：' . $project_id . ', 路由获取地址：' . $route_domain . 'k_u_api.php' . ', 错误信息：' . $e->getMessage());
            echo 'syncGloV5Route 未获取到路由信息：' . $project_id . ', 路由获取地址：' . $route_domain . 'k_u_api.php' . ', 错误信息：' . $e->getMessage() . PHP_EOL;
            return false;
        }

        foreach ($result as $key=>$val) {
            try {
                $tmp = explode('|', $val);
                $url_tmp = parse_url($tmp[0]);
                $route = trim($url_tmp['path'], '/');
                $title = str_replace('+', ' ', $tmp[1]);
                if (strlen($title) > 200 || strlen($route) > 200) {
                    $this->log('syncGloV5Route 路由或标题过长，无效记录');
                    continue;
                }
                InquiryProjectRoute::saveProjectRoute($project_id, $title, $route);
            } catch (\Exception $e) {
                $this->log('syncGloV5Route 解析路径：' . $val . ', 错误信息：' . $e->getMessage());
                echo 'syncGloV5Route 解析路径：' . $val . ', 错误信息：' . $e->getMessage() . PHP_EOL;
            }
        }
        return true;
    }

    /**
     * 同步v6项目
     * @return bool
     */
    public function syncGloV6()
    {
        // 获取优化中台项目
        $project = Project::leftJoin('gl_project_online_check', 'gl_project.id', '=', 'gl_project_online_check.project_id')
            ->where('gl_project.type', Project::TYPE_TWO)
            ->where('gl_project.extend_type', '!=', 5)
            ->where(function ($query) {
                $query->orwhere('gl_project_online_check.qa_status', OnlineCheck::STATUS_ONLINE_TRUE)
                    ->orwhere('gl_project.is_upgrade', Project::IS_UPGRADE_TRUE);
            })
            ->limit(5)
            ->get(['gl_project.id', 'gl_project.title', 'gl_project.level', 'gl_project.channel']);
        // 获取所有项目域名
        $domains = DomainInfo::whereIn('project_id', $project->pluck('id')->toArray())->pluck('domain', 'project_id')->toArray();
        foreach ($project as $key=>$val) {
            echo '同步项目：' . $val->id . ' - ' . $val->title . PHP_EOL;
            // 过滤暂停优化项目, 映射类型2， model没有定义常量
            if (in_array(2, $val->level))
                continue;
            $project = InquiryProject::saveProject(InquiryProject::VERSION_SIX, $val->id, $val->title, $val->channel['channel_id'], $domains[$val->id]);
            $this->syncGloV6Route($project->id, $val->id);
        }
        return true;
    }

    /**
     * 同步v6项目路由
     * @param $project_id
     * @param $origin_project_id
     * @return bool
     */
    public function syncGloV6Route($project_id, $origin_project_id)
    {
        ProjectServer::useProject($origin_project_id);
        // TODO 产品分类标题、路由， 产品标题、路由， 同步到路由表
        $category = Category::where('status', Category::STATUS_ACTIVE)->get(['title', 'route']);
        foreach ($category as $key=>$val) {
            InquiryProjectRoute::saveProjectRoute($project_id, $val->title, $val->route);
        }

        // 产品数量会比较多， 所以使用分页 同步数据
        $id = 0;
        while (true) {
            echo '同步项目路由：' . $id . PHP_EOL;
            $product = Product::where('status', Product::STATUS_ON)->where('id', '>', $id)->orderBy('id', 'asc')->limit(1000)->get(['id', 'title', 'route']);
            if ($product->isEmpty())
                break;

            foreach ($product as $key=>$val) {
                $id = $val->id;
                InquiryProjectRoute::saveProjectRoute($project_id, $val->title, $val->route);
            }
        }

        DB::disconnect('custom_mysql');
        return true;
    }

    /**
     * 删除过期数据， 非当日更新数据， 都删除， 误删第二天再重新同步更新
     * @return bool
     */
    public function deleteExpire()
    {
        $date = intval(date('Ymd'));
        $project_num = InquiryProject::where('date', '<', $date)->delete();
        $project_route_num = InquiryProjectRoute::where('date', '<', $date)->delete();
        $this->log('删除过期项目数量：' . $project_num . ', 删除过期路由数量：' . $project_route_num);
        return true;
    }

    /**
     * 输出日志到特定的文件内， 这个文件需要定时排除内容
     * @param $message
     * @return bool
     */
    public function log($message)
    {
        $message = date('Y-m-d H:i:s') . ' ' . $message . PHP_EOL;
        file_put_contents(storage_path('logs/zhl/output') . date('Y-m-d') . '.log', $message, FILE_APPEND);
        return true;
    }
}