<?php

namespace App\Console\Commands\WorkOrder;

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

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()
    {
        # pm 项目经理  assm 售后服务经理
        $response = Http::get('https://www.quanqiusou.cn/extend_api/webs/globalso_all.php');
        if ($response->status() == 200) {
            $items = $response->json();
            foreach ($items as $item) {
                # V5: 版本号+postid
                $uuid = md5("V5{$item['postid']}");
                $project = TicketProject::where('uuid', $uuid)->first();
                $assm_id = Manage::where('name', $item['assm'])->value('id') ?? Manage::where('name', '张鸿飞')->value('id') ?? 0;  //售后服务经理
                $seom_id = Manage::where('name', $item['yhs'])->value('id') ?? Manage::where('name', '陶婵')->value('id') ?? 0;  //优化师
                // 如果 $item['cate'] 包含”推广“字符，则 $engineer_name = $item['assm']
                /**
                 * 第一负责人逻即说明：
                 * 优化推广项目：找售后服务经理??鸿飞
                 * 建站类项目： 找杨长远
                 */
                $engineer_id = (strpos($item['cate'], '推广') !== false) ? $assm_id : Manage::where('name', '杨长远')->value('id') ?? 0;

                $fields = [
                    'post_id' => $item['postid'],
                    'company_name' => $item['company'],
                    'title' => $item['title'],
                    'engineer_id' => $engineer_id,  // 第一负责人
                    'assm_id' => $assm_id,
                    'seom_id' => $seom_id,
                    'website' => $item['main_url'] ?? '',
                    'is_del' => 0,
                ];
                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();
                    }
                }
            }
            $postids = collect($items)->pluck('postid')->toArray();
            // 软删除 gl_ticket_projects 中不存在的项目
            TicketProject::where('version', 5)
                ->whereNotIn('post_id', $postids)
                ->update(['is_del' => 1]);
            echo date("Y-m-d H:i:s") . " V5: fetch completed, total " . count($items) . " items\n";
        }
    }

    /**
     * @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();
                    // 售后服务经理
                    $assm_id = collect([
                        ManageHr::find($item->deploy_optimize->manager_mid)->manage_id ?? 0,
                        ManageHr::find($item->deploy_optimize->tech_leader)->manage_id ?? 0,
                        8,  //张鸿飞
                    ])->first(fn($v) => $v !== null && $v !== 0, 0);
                    // 优化师
                    $optimist_mid = ManageHr::find($item->deploy_optimize->optimist_mid) ? ManageHr::find($item->deploy_optimize->optimist_mid)->manage_id : 0;
                    $seom_id = $optimist_mid ? $optimist_mid : $assm_id;
                    /**
                     * 第一负责人逻辑
                     * 建站类项目：找杨长远
                     * 推广类：找售后
                     */
                    if ($item->type == Project::TYPE_THREE) {
                        $engineer_id = Manage::where('name', '杨长远')->value('id') ?? 0; // 建站类项目找杨长远
                    }else {
                        // 其他找售后服务经理
                        $engineer_id = $assm_id;
                    }
                    $is_del = (
                        $item->extend_type == 5
                        || $item->type == 8
                        || $item->delete_status == 1
                        || $item->site_status == 1
                    ) ? 1 : 0;

                    $fields = [
                        'company_name' => $item->company,
                        'title' => $item->title,
                        'assm_id' => $assm_id,
                        'seom_id' => $seom_id,
                        'engineer_id' => $engineer_id,
                        'is_del' => $is_del
                    ];
                    if (!$project) {
                        $project = new TicketProject();
                        $project->uuid = $uuid;
                        $project->post_id = $item->post_id;
                        $project->version = 6;
                        $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 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;
            }
        }
    }
}