<?php

namespace App\Console\Commands\WorkOrder;

use App\Models\Manage\Manage;
use App\Models\Manage\ManageHr;
use App\Models\Project\Project;
use App\Models\ProjectAssociation\ProjectAssociation;
use App\Models\WorkOrder\TicketProject;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\Http;
use Illuminate\Support\Str;

class FetchTicketProjects extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'workorder:fetch-Ticket-projects {action}';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = '同步V5,V6的项目到 gl_ticket_projects 表';

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

    /**
     * Execute the console command.
     *
     * @return int
     */
    public function handle()
    {
        $action = $this->argument('action');
        $this->$action();
        return 0;
    }


    /**
     * @return void
     * 请求：https://www.quanqiusou.cn/extend_api/webs/globalso_all.php
     */
    public function fetchV5()
    {
        $page = 1;
        $postids = [];

        while (true) {
            try {
                $maxRetries = 3;
                $retryCount = 0;

                while ($retryCount < $maxRetries) {
                    try {
                        $response = Http::get('https://www.quanqiusou.cn/extend_api/webs/globalso_all.php?page=' . $page);
                        break; // 如果请求成功，跳出重试循环
                    } catch (\Exception $e) {
                        $retryCount++;
                        if ($retryCount >= $maxRetries) {
                            // 如果达到最大重试次数，抛出异常
                            throw $e;
                        }
                        // 等待一段时间再重试
                        sleep(2);
                    }
                }
            }catch (\Exception $e){
                echo now() . " | ERROR | " . $e->getMessage() . "\n" . $e->getTraceAsString() . "\n";
                break;
            }

            if ($response->status() == 200) {
                $resp_json = $response->json();
                $items = $resp_json['data'] ?? [];
                if (empty($items))
                {
                    echo now() . " | INFO | V5: not found items on page $page \n";
                    break;
                }
                foreach ($items as $item) {
                    # V5: 版本号+postid
                    $uuid = md5("V5{$item['postid']}");
                    $project = TicketProject::where('uuid', $uuid)->first();

                    // 项目状态, 根据 $item['cate'] 判断，建站中，建站客户，推广
                    if (strpos($item['cate'], '推广') !== false)
                        $status=3; // 推广
                    elseif ($item['cate'] == "建站客户")
                        $status=2; // 建站客户
                    elseif ($item['cate'] == "建站中")
                        $status=1; // 建站中

                    $assm_id = ManageHr::where('name', $item['assm'])->where('status', 1)->value('manage_id') ?? ManageHr::where('name', '张鸿飞')->where('status', 1)->value('manage_id') ?? 0;  //售后服务经理
                    $seom_id = ManageHr::where('name', $item['yhs'])->where('status', 1)->value('manage_id') ?? ManageHr::where('name', '陶婵')->where('status', 1)->value('manage_id') ?? 0;  //优化师
                    $pm_id = ManageHr::where('name', $item['pm'])->where('status', 1)->value('manage_id') ?? ManageHr::where('name', '李洁玉')->where('status', 1)->value('manage_id') ?? 0; // 项目经理

                    /**
                     * 第一负责人逻即说明：
                     * 优化推广项目：找售后服务经理??鸿飞
                     * 建站中：项目经理
                     * 建站完成：杨长远
                     */

                    if ($status == 3)
                        $engineer_id = $assm_id; // 推广类项目找售后服务经理
                    elseif ($status == 2)
                        $engineer_id = Manage::where('name', '杨长远')->value('id') ?? 0;  //建站完成
                    elseif ($status == 1)
                        $engineer_id = $pm_id; // 建站中找项目经理

                    $team_names = [
                        $item['pm'],
                        $item['assm'],
                        $item['yhs'],
                        $item['team_leader'],
                        $item['technology'],
                        $item['designer'],
                        $item['yhszl'],
                    ];
                    // 过滤掉空值,去掉重复
                    $team_ids = ManageHr::whereIn('name', $team_names)->where('status', 1)->pluck('manage_id')
                        ->unique()
                        ->filter(fn($v) => !is_null($v) && $v !== 0)
                        ->values()
                        ->toArray();

                    $fields = [
                        'post_id' => $item['postid'],
                        'company_name' => $item['company'],
                        'title' => $item['title'] . " - V5",
                        'engineer_id' => $engineer_id,  // 第一负责人
                        'assm_id' => $assm_id,
                        'seom_id' => $seom_id,
                        'website' => $item['main_url'] ?? '',
                        'test_website' => $item['test_url'] ?? '',
                        'is_del' => 0,
                        'plan' => $item['plan'] ?? '',
                        'project_cate' => 1,
                        'pm_id' => $pm_id,
                        'status' => $status, // 项目状态
                        'wechat_group_id' => $item['wx_id'],
                        'team' => $team_ids ? json_encode($team_ids) : null,
                    ];
                    if (!$project) {
                        $new = new TicketProject();
                        $new->uuid = $uuid;
                        $new->version = 5;
                        $new->table_id = 0;
                        foreach ($fields as $k => $v) {
                            $new->$k = $v;
                        }
                        $new->save();
                    } else {
                        $changed = false;
                        foreach ($fields as $k => $v) {
                            if ($project->$k != $v) {
                                $project->$k = $v;
                                $changed = true;
                            }
                        }
                        if ($changed) {
                            $project->save();
                        }
                    }
                    echo now() . " | INFO | V5: {$item['postid']} {$item['company']} fetch ok \n";
                }
                $page++;
                $postids = array_merge($postids, collect($items)->pluck('postid')->toArray());
            }
        }
        if ($postids)
        {
            // 软删除 gl_ticket_projects 中不存在的项目
            TicketProject::where('version', 5)
                ->whereNotIn('post_id', $postids)
                ->update(['is_del' => 1]);
        }
    }

    /**
     * @return void
     * 1. 按照ID升序查询 gl_project 表 limit 10
     * 2。同步到 TicketProject 后，redis 缓存 ID
     */
    public function fetchV6()
    {
        $lastid = 0;
        while (true) {
            try {
                $items = Project::where('id', '>', intval($lastid))
//                    ->where('delete_status', 0)
//                    ->where('extend_type', '!=', 5) // 排除归档项目
//                    ->where('type', '!=', 8) // 排除归档项目
                    ->orderBy('id', 'asc')
                    ->limit(10)
                    ->get();
                if ($items->isEmpty()) {
                    echo "not found items \n";
                    break;
                }
                foreach ($items as $item) {
                    $uuid = md5("V6{$item->id}");
                    $project = TicketProject::where('uuid', $uuid)->first();
                    // 项目状态
                    if ($item->type == Project::TYPE_ONE)
                        $status = 1; // 建站中
                    elseif ($item->type == Project::TYPE_THREE)
                        $status = 2; // 建站完成
                    else
                        $status = 3; // 推广找售后服务经理

                    // 售后服务经理
                    $assm_id = collect([
                        ManageHr::where('status', 1)->find($item->deploy_optimize->manager_mid)->manage_id ?? 0,
                        ManageHr::where('status', 1)->find($item->deploy_optimize->tech_leader)->manage_id ?? 0,
                        8,  //张鸿飞
                    ])->first(fn($v) => $v !== null && $v !== 0, 0);
                    // 优化师
                    $seom_id = ManageHr::where('status', 1)->find($item->deploy_optimize->optimist_mid) ? ManageHr::where('status', 1)->find($item->deploy_optimize->optimist_mid)->manage_id : 0;
                    // 项目经理
                    $pm_id = ManageHr::where('status', 1)->find($item->deploy_build->manager_mid)->manage_id ?? ManageHr::where('status', 1)->where('name', '李洁玉')->value('manage_id') ?? 0;

                    // 第一负责人
                    /**单纯的5.0升级6.0的项目,自帽SE0，GE0的项目 部划给售后
                    其他:建站中找项目经理，建站完成找杨长远，推广找售后服务经理
                     */
                    //todo::建站或同时为v6版本+GEO的，建站中项目给项目经理
                    if(($status == 1) && ($item->deploy_build->plan > 0) && ($item->deploy_build->seo_plan > 0)){
                        $engineer_id = $pm_id; //找项目经理
                    }else{
                        if ($item->is_upgrade || $item->project_type == 1 || $item->deploy_build->seo_plan > 0)
                            $engineer_id = $assm_id; // V5升V6，白帽SEO，GEO,找售后服务经理
                        elseif ($status == 1)
                            $engineer_id = $pm_id; // 建站中找项目经理
                        elseif ($status == 2)
                            $engineer_id = Manage::where('status', 1)->where('name', '杨长远')->value('id') ?? 0; // 建站完成找杨长远
                        elseif ($status == 3)
                            $engineer_id = $assm_id; // 推广找售后服务经理
                        else
                            $engineer_id = $pm_id; //找项目经理
                    }
                    $is_del = (
                        $item->extend_type == 5
                        || $item->type == 8
                        || $item->delete_status == 1
                        || $item->site_status == 1
                    ) ? 1 : 0;

                    $team_ids_in = [
                        $item->deploy_build->leader_mid,
                        $item->deploy_build->manager_mid,
                        $item->deploy_build->designer_mid,
                        $item->deploy_build->tech_mid,
                        $item->deploy_optimize->manager_mid,
                        $item->deploy_optimize->optimist_mid,
                        $item->deploy_optimize->assist_mid,
                        $item->deploy_optimize->tech_mid,
                        $item->deploy_optimize->tech_leader,
                    ];

                    // $team_ids 去重复
                    $team_ids_in = array_unique($team_ids_in);
                    $team_ids_in = array_filter($team_ids_in);
                    // $team_ids 去掉下标
                    $team_ids_in = array_values($team_ids_in);

                    $team_ids = ManageHr::whereIn('id', $team_ids_in)->where('status', 1)->pluck('manage_id')
                        ->unique()
                        ->filter(fn($v) => !is_null($v) && $v !== 0)
                        ->values()
                        ->toArray();

                    $fields = [
                        'company_name' => $item->company,
                        'title' => $item->title . " - V" . empty($item->version) ? 6 : $item->version,
                        'assm_id' => $assm_id,
                        'seom_id' => $seom_id,
                        'engineer_id' => $engineer_id,
                        'is_del' => $is_del,
                        'website' => !empty($item->domainInfo->domain) ? 'https://'.$item->domainInfo->domain : '',
                        'test_website' => $item->deploy_build->test_domain ?? '',
                        'version' => empty($item->version) ? 6 : $item->version, // 版本号
                        'plan' => $item->planMap()[$item->deploy_build->plan] ?? '',
                        'project_cate' => 2,
                        'wechat_group_id' => ProjectAssociation::where('project_id', $item->id)
                            ->where('status', ProjectAssociation::STATUS_NORMAL)
                            ->where('binding_app', ProjectAssociation::ENTERPRISE_WECHAT)
                            ->value('friend_id'),
                        'pm_id' => $pm_id,
                        'status' => $status, // 项目状态
                        'team' => $team_ids ? json_encode($team_ids) : null,
                    ];
                    if (!$project) {
                        $project = new TicketProject();
                        $project->uuid = $uuid;
                        $project->post_id = $item->post_id;
                        $project->table_id = $item->id;
                        foreach ($fields as $k => $v) {
                            $project->$k = $v;
                        }
                        $project->save();
                    } else {
                        $changed = false;
                        foreach ($fields as $k => $v) {
                            if ($project->$k != $v) {
                                $project->$k = $v;
                                $changed = true;
                            }
                        }
                        if ($changed) {
                            $project->save();
                        }
                    }
                    $lastid = $item->id;
                    echo date('Y-m-d H:i:s') . " V6: $item->id {$item->company} fetch ok \n";
                }
            } catch (\Exception $exception) {
                echo $exception;
                break;
            }
        }
    }

    public function fetchAICC()
    {
        $lastid = 0;
        while (true) {
            try {
                $response = Http::withBasicAuth('bill', 'bill@ai.cc')
                    ->get('https://fob.ai.cc/api/tickets/projects', [
                        'lastid' => $lastid,
                    ]);
                $items = $response->json();
                if (empty($items))
                {
                    echo now() . " | INFO | not found items \n";
                    break;
                }

                foreach ($items as $item) {
                    foreach ($item['plans'] as $plan)
                    {
                        // 判断套餐是超迹还是域途, 如果 $item['plans'][0]['name'] 包含 '超迹' 则为超迹，否则为域途
                        $project_cate = Str::contains($plan['name'], '超迹') ? 3 : 4;
                        $uuid = md5("AICC{$item['id']}{$project_cate}");
                        $project = TicketProject::where('uuid', $uuid)->first();
                        if ($project_cate == 3)
                        {
                            // 售后服务经理
                            $assm_id = collect([
                                ManageHr::where('status', 1)->where('name', $item['cj_assm']['real_name'] ?? '')->first()->manage_id ?? 0,
                                20,  //徐莹
                            ])->first(fn($v) => $v !== null && $v !== 0, 0);
                        }else
                        {
                            // 域途
                            $assm_id = collect([
                                ManageHr::where('status', 1)->where('name', $item['yutu_assm']['real_name'] ?? '')->first()->manage_id ?? 0,
                                85,  //黄小玉
                            ])->first(fn($v) => $v !== null && $v !== 0, 0);
                        }

                        // 优化师
                        $seom_id = 0;
                        // 第一负责人
                        $engineer_id = $assm_id;
                        if ($project_cate == 3)
                            $is_del = empty($item["go_online"]);
                        else{
                            // 域途，以服务时间为准 $item['yutu_service_start_time'] 是开始时间 + 有效天数 yutu_planday
                            $is_del = !empty($item['yutu_service_start_time']) && !empty($item['yutu_planday'])
                                && (strtotime($item['yutu_service_start_time']) + $item['yutu_planday'] * 86400) < time();
                        }

                        $fields = [
                            'company_name' => $item['company'],
                            'title' => $item['company'] . " - " . $plan['name'],
                            'assm_id' => $assm_id,
                            'seom_id' => $seom_id,
                            'engineer_id' => $engineer_id,
                            'is_del' => $is_del,
                            'website' => '',
                            'test_website' => '',
                            'version' => 1, // 版本号
                            'plan' => $plan['name'] ?? '',
                            'project_cate' => $project_cate,
                            'wechat_group_id' => $item['chatroom_id'],
                        ];

                        if (!$project) {
                            $project = new TicketProject();
                            $project->uuid = $uuid;
                            $project->post_id = $item['postid'];
                            $project->table_id = $item['id'];
                            foreach ($fields as $k => $v) {
                                $project->$k = $v;
                            }
                            $project->save();
                        } else {
                            $changed = false;
                            foreach ($fields as $k => $v) {
                                if ($project->$k != $v) {
                                    $project->$k = $v;
                                    $changed = true;
                                }
                            }
                            if ($changed) {
                                $project->save();
                            }
                        }
                        $lastid = $item['id'];
                        echo now() . " | INFO | AICC: {$item['id']} {$item['company']} fetch ok \n";
                    }
                }
            }catch (\Exception $exception){
                echo now() . " | ERROR | " . $exception->getMessage() . "\n" . $exception->getTraceAsString() . "\n";
                break;
            }
        }
    }

    public function fetch_uuid()
    {
        $lastid = 0;
        while (true) {
            try {
                $items = TicketProject::where('id', '>', $lastid)
                    ->where('version', 6)
                    ->orderBy('id', 'asc')
                    ->limit(10)
                    ->get();
                if ($items->isEmpty()) {
                    echo "not found items \n";
                    break;
                }
                foreach ($items as $item) {
                    $uuid = md5("V6{$item->table_id}");
                    $item->uuid = $uuid;
                    $item->save();
                    $lastid = $item->id;
                    echo date('Y-m-d H:i:s') . " V6: $item->id fetch ok \n";
                }
            } catch (\Exception $exception) {
                echo $exception;
                break;
            }
        }
    }
}