<?php
/**
 * @remark :
 * @name   :RecommendedSuppliers.php
 * @author :lyh
 * @method :post
 * @time   :2024/3/5 11:27
 */

namespace App\Console\Commands\Suppliers;

use App\Models\Product\Keyword;
use App\Models\Project\DeployBuild;
use App\Models\Project\Project;
use App\Models\Purchaser\Purchaser;
use App\Models\Purchaser\PurchaserInfo;
use App\Services\ProjectServer;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\DB;

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

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = '推荐供应商';

    public $deployBuildModel;

    public $projectModel;

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        $this->deployBuildModel = new DeployBuild();
        parent::__construct(); // 确保调用父类构造函数
    }


    /**
     * @return bool
     */
    public function handle()
    {
        $projectModel = new Project();
        $projectArr = $projectModel->selectField(['delete_status'=>0,'type'=>['in',[2,3,4]]],'id');
        $project_list =  $this->deployBuildModel->list(['is_supplier'=>1,'project_id'=>['in',$projectArr]]);//TODO::已开启推荐供应商
        foreach ($project_list as $v){
            try {
                echo date('Y-m-d H:i:s') . '推荐供应商执行的project_id:'.$v['project_id'] . PHP_EOL;
                $result = $this->countPurchaser($v);
                if($result !== false){
                    ProjectServer::useProject($v['project_id']);
                    $title = $this->getKeywords($v['project_id']);
                    if(!empty($title)){
                        $this->savePurchaser($v['project_id'],$title);
                    }else{
                        $this->deployBuildModel->edit(['is_supplier'=>0],['project_id'=>$v['project_id']]);
                        echo '关键词已取完'.PHP_EOL;
                    }
                    DB::disconnect('custom_mysql');
                }
            }catch (\Exception $e){
                echo date('Y-m-d H:i:s').'当前项目执行错误：'.$e->getMessage().PHP_EOL;
                continue;
            }
        }
        return true;
    }

    /**
     * @remark :当前项目拥有的
     * @name   :countPurchaser
     * @author :lyh
     * @method :post
     * @time   :2025/3/10 16:29
     * @param  :is_purchaser_count；1->开启后已达到上线关闭过 0->未关闭过
     * @param  :plan（1->专业版 2->标准版 3->商务版 10->旗舰版）
     */
    public function countPurchaser($v){
        if($v['is_purchaser_count'] == 0){
            $purchaserInfoModel = new PurchaserInfo();
            $count = $purchaserInfoModel->counts(['project_id'=>$v['project_id']]);
            //获取项目版本
            $plan = ['专业版'=>300, '标准版'=>500, '商务版'=>800, '旗舰版'=>1200];
            $typePlan = Project::planMap();
            $version = $typePlan[$v['plan']] ?? '专业版';
            $total_number = $plan[$version] ?? 300;
            if($count > $total_number){
                echo date('Y-m-d H:i:s') . '达到数量上线关闭的项目:'.$v['project_id'] . PHP_EOL;
                //更新数量上限字段,并关闭推荐供应商
                $this->deployBuildModel->edit(['is_purchaser_count'=>1,'is_supplier'=>0],['project_id'=>$v['project_id']]);
                return false;
            }
        }
        return true;
    }

    /**
     * @remark :获取关键词数据
     * @name   :getPurchaser
     * @author :lyh
     * @method :post
     * @time   :2025/4/15 17:55
     */
    public function getPurchaser($keyword,$project_id){
        $purchaserModel = new Purchaser();
        return $purchaserModel->read(['keyword'=>$keyword,'project_id'=>$project_id]);
    }

    /**
     * @remark :获取已经处理过的关键词
     * @name   :getPurchaserList
     * @author :lyh
     * @method :post
     * @time   :2025/4/15 17:55
     */
    public function getPurchaserList($project_id){
        $purchaserModel = new Purchaser();
        return $purchaserModel->selectField(['project_id'=>$project_id],'keyword');
    }

    /**
     * @remark :保存供应商
     * @name   :getPurchaser
     * @author :lyh
     * @method :post
     * @time   :2024/3/5 11:38
     */
    public function savePurchaser($project_id,$keyword,$row = 10){
        //项目还没有关键词
        if(!$keyword){
            echo '项目还没有关键词'.PHP_EOL;
            return true;
        }
        $url = 'https://fob.ai.cc/api/company_list';
        $data = [
            'prod_desc'=>$keyword,
            'total'=>$row ?? 10,
        ];
        ksort($data);
        $token = 'company_list+'.date('Y-m-d').'+'.http_build_query($data);
        $keyword = rtrim($keyword, "\r");
        $param = [
            'prod_desc'=>$keyword,
            'token'=>md5($token),
            'total'=>$this->param['row'] ?? 10,
        ];
        $res = http_post($url,json_encode($param));
        echo '请求返回状态'. ($res['code']?? '').PHP_EOL;
//        echo date('Y-m-d H:i:s') . json_encode($res) . PHP_EOL;
        //保存多条数据
        $saveData = [
            'project_id'=>$project_id,
            'keyword'=>$keyword,
            'data'=>json_encode($res['data'] ?? [])
        ];
        $purchaserModel = new Purchaser();
        $purchaserModel->add($saveData);
        if(isset($res['code']) && $res['code'] == 200 && !empty($res['data'])){
            $this->savePurchaserInfo($project_id,$keyword,$res['data']);
        }else{
            echo '未正常返回数据，跳过项目'.PHP_EOL;
        }
        return true;
    }

    /**
     * @remark :取关键词
     * @name   :getKeywords
     * @author :lyh
     * @method :post
     * @time   :2024/7/1 18:07
     */
    public function getKeywords($project_id){
        $keywordModel = new Keyword();
        $keyword_array = $this->getPurchaserList($project_id);
        $title = $keywordModel->whereNotIn('title', $keyword_array)->inRandomOrder()->limit(1)->value('title');
        if(empty($title)){
            return '';
        }
        return $title;
    }

    /**
     * @remark :保存供应商详情
     * @name   :savePurchaserInfo
     * @author :lyh
     * @method :post
     * @time   :2024/5/29 16:38
     */
    public function savePurchaserInfo($project_id,$keyword,$data){
        $purchaserInfoModel = new PurchaserInfo();
        foreach ($data as $k =>$v){
            if(empty($v['buyer_id'])){
                continue;
            }
            $v['project_id'] = $project_id;
            $v['keyword'] = $keyword;
            $v['email'] = json_encode($v['email']??[],JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE);
            $v['mobile'] = json_encode($v['mobile']??[],JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE);
            $v['social_media'] = json_encode($v['social_media']??[],JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE);
            $v['image'] = str_replace('admin.hagro.cn','fob.ai.cc',$v['image']??'');
            $param = $v;
            $info = $purchaserInfoModel->read(['keyword'=>$keyword,'buyer_id'=>$v['buyer_id']??0,'project_id'=>$project_id],['id']);
            if($info === false){
                $purchaserInfoModel->add($param);
            }
        }
        return true;
    }
}