<?php

namespace App\Console\Commands;

use App\Helper\Common;
use App\Helper\Translate;
use App\Models\Ai\AiCommand as AiCommandModel;
use App\Models\Project\DeployOptimize;
use App\Models\Project\Project;
use App\Services\ProjectServer;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Redis;

/**
 * 初始化项目
 * Class InitProject
 * @package App\Console\Commands
 * @author zbj
 * @date 2023/10/8
 */
class UpdateSeoTdk extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'update_seo_tdk';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = '';

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

    /**
     * @return bool
     */
    public function handle()
    {
        while (true){
            $project_id = Redis::rpop('updateSeoTdk');
            if(!$project_id){
                sleep(2);
                continue;
            }
            echo date('Y-m-d H:i:s') . ' start: ' . $project_id . PHP_EOL;

            try {
                ProjectServer::useProject($project_id);
                $this->updateProduct($project_id);
                $this->updateProductCate($project_id);
                $this->updateBlogs($project_id);
                $this->updateBlogCate($project_id);
                $this->updateNews($project_id);
                $this->updateNewsCate($project_id);
                $this->updatePage($project_id);
                DB::disconnect('custom_mysql');
            }catch (\Exception $e){
                echo date('Y-m-d H:i:s') . ' error: ' . $project_id . '->' . $e->getMessage() . PHP_EOL;
            }
            echo date('Y-m-d H:i:s') . ' end: ' . $project_id . PHP_EOL;
        }
    }
    /**
     * @remark :更新产品tdk
     * @name   :updateProduct
     * @author :lyh
     * @method :post
     * @time   :2023/8/19 9:25
     */
    public function updateProduct($project_id){
        $list = DB::connection('custom_mysql')->table('gl_product')->where(['status'=>1,'project_id'=>$project_id])->get()->toArray();
        if(!empty($list)){
            foreach ($list as $v){
                $v = (array)$v;
                $seo_arr = json_decode($v['seo_mate'], true) ?: [];
                //更新seo_title
                if(!isset($seo_arr['title'])){
                    $setting = DB::connection('custom_mysql')->table('gl_web_setting_seo')->where(['project_id'=>$project_id])->first();
                    //生成seo_title
                    if(!empty($setting['product_prefix']) && !empty($setting['product_suffix'])){
                        $seo_arr['title'] = $setting['product_prefix'] . '-' . $seo_arr['title'] . '-' . $setting['product_suffix'];
                    }else{
                        $seo_arr['title'] = $this->ai_send('seo_title',$seo_arr['title']);
                    }
                }
                //更新seo_keyword
                if(!isset($seo_arr['keyword'])){
                    $seo_arr['keyword'] = $this->ai_send('seo_keywords',$v['title']);
                }
                //更新seo_keyword
                if(!isset($seo_arr['description'])){
                    $seo_arr['description'] = $this->ai_send('seo_meta_description',$v['title']);
                }
                $ser_str = json_encode($seo_arr,true);
                DB::connection('custom_mysql')->table('gl_product')->where(['id'=>$v['id']])->update(['seo_mate'=>$ser_str]);
            }

        }
        return true;
    }

    /**
     * @remark :更新产品tdk
     * @name   :updateProduct
     * @author :lyh
     * @method :post
     * @time   :2023/8/19 9:25
     */
    public function updateProductCate($project_id){
        $list = DB::connection('custom_mysql')->table('gl_product_category')->where(['status'=>1,'project_id'=>$project_id])->get()->toArray();
        if(!empty($list)){
            foreach ($list as $v){
                $v = (array)$v;
                $data = [];
                if(empty($v['seo_title'])){
                    $setting = DB::connection('custom_mysql')->table('gl_web_setting_seo')->where(['project_id'=>$project_id])->first();
                    //生成seo_title
                    if(!empty($setting['product_cate_prefix']) && !empty($setting['product_cate_suffix'])){
                        $data['seo_title'] = $setting['product_cate_prefix'] . '-' . $v['title'] . '-' . $setting['product_cate_suffix'];
                    }else{
                        $data['seo_title'] = $this->ai_send('seo_title',$v['title']);
                    }
                }
                if(empty($v['seo_keywords'])){
                    $data['seo_keywords'] = $this->ai_send('seo_keywords',$v['title']);
                }
                if(empty($v['seo_des'])){
                    $name = $this->companyName($project_id);
                    $data['seo_des'] = $this->ai_send('page_meta_description',$v['title'],$name);
                }
                if(!$data){
                    continue;
                }
                DB::connection('custom_mysql')->table('gl_product_category')->where(['id'=>$v['id']])->update($data);
            }
        }
        return true;
    }

    /**
     * @remark :更新新闻Tdk
     * @name   :updateNews
     * @author :lyh
     * @method :post
     * @time   :2023/8/19 10:06
     */
    public function updateNews($project_id){
        $list = DB::connection('custom_mysql')->table('gl_news')->where(['status'=>1,'project_id'=>$project_id])->get()->toArray();
        if(!empty($list)){
            foreach ($list as $k => $v){
                $v = (array)$v;
                $data = [];
                if(empty($v['seo_title'])){
                    $setting = DB::connection('custom_mysql')->table('gl_web_setting_seo')->where(['project_id'=>$project_id])->first();
                    //生成seo_title
                    if(!empty($setting['single_page_suffix'])){
                        $data['seo_title'] = $v['name'] . '-' . $setting['single_page_suffix'];
                    }else{
                        $data['seo_title'] = $this->ai_send('seo_title',$v['name']);
                    }
                }
                if(empty($v['seo_keywords'])){
                    $data['seo_keywords'] = $this->ai_send('seo_keywords',$v['name']);
                }
                if(empty($v['seo_description'])){
                    $data['seo_description'] = $this->ai_send('seo_meta_description',$v['name']);
                }
                if(!$data){
                    continue;
                }
                DB::connection('custom_mysql')->table('gl_news')->where(['id'=>$v['id']])->update($data);
            }
        }
        return true;
    }

    /**
     * @remark :更新新闻Tdk
     * @name   :updateNews
     * @author :lyh
     * @method :post
     * @time   :2023/8/19 10:06
     */
    public function updateNewsCate($project_id){
        $list = DB::connection('custom_mysql')->table('gl_news_category')->where(['status'=>1,'project_id'=>$project_id])->get()->toArray();
        if(!empty($list)){
            foreach ($list as $k => $v){
                $v = (array)$v;
                $data = [];
                if(empty($v['seo_title'])){
                    $setting = DB::connection('custom_mysql')->table('gl_web_setting_seo')->where(['project_id'=>$project_id])->first();
                    //生成seo_title
                    if(!empty($setting['single_page_suffix'])){
                        $data['seo_title'] = $v['name'] . '-' . $setting['single_page_suffix'];
                    }else{
                        $data['seo_title'] = $this->ai_send('seo_title',$v['name']);
                    }
                }
                if(empty($v['seo_keywords'])){
                    $data['seo_keywords'] = $this->ai_send('seo_keywords',$v['name']);
                }
                if(empty($v['seo_des'])){
                    $name = $this->companyName($project_id);
                    $data['seo_des'] = $this->ai_send('page_meta_description',$v['title'],$name);
                }
                if(!$data){
                    continue;
                }
                DB::connection('custom_mysql')->table('gl_news_category')->where(['id'=>$v['id']])->update($data);
            }
        }
        return true;
    }

    /**
     * @remark :更新blogTdk
     * @name   :updateBlogs
     * @author :lyh
     * @method :post
     * @time   :2023/8/19 10:07
     */
    public function updateBlogs($project_id){
        $list = DB::connection('custom_mysql')->table('gl_blog')->where(['status'=>1,'project_id'=>$project_id])->get()->toArray();
        if(!empty($list)){
            foreach ($list as $k => $v){
                $v = (array)$v;
                $data = [];
                if(empty($v['seo_title'])){
                    $setting = DB::connection('custom_mysql')->table('gl_web_setting_seo')->where(['project_id'=>$project_id])->first();
                    //生成seo_title
                    if(!empty($setting['single_page_suffix'])){
                        $data['seo_title'] = $v['name'] . '-' . $setting['single_page_suffix'];
                    }else{
                        $data['seo_title'] = $this->ai_send('seo_title',$v['name']);
                    }
                }
                if(empty($v['seo_keywords'])){
                    $data['seo_keywords'] = $this->ai_send('seo_keywords',$v['name']);
                }
                if(empty($v['seo_description'])){
                    $data['seo_description'] = $this->ai_send('seo_meta_description',$v['name']);
                }
                if(!$data){
                    continue;
                }
                DB::connection('custom_mysql')->table('gl_blog')->where(['id'=>$v['id']])->update($data);
            }
        }
        return true;
    }

    /**
     * @remark :更新新闻Tdk
     * @name   :updateNews
     * @author :lyh
     * @method :post
     * @time   :2023/8/19 10:06
     */
    public function updateBlogCate($project_id){
        $list = DB::connection('custom_mysql')->table('gl_blog_category')->where(['status'=>1,'project_id'=>$project_id])->get()->toArray();
        if(!empty($list)){
            foreach ($list as $k => $v){
                $v = (array)$v;
                $data = [];
                if(empty($v['seo_title'])){
                    $setting = DB::connection('custom_mysql')->table('gl_web_setting_seo')->where(['project_id'=>$project_id])->first();
                    //生成seo_title
                    if(!empty($setting['single_page_suffix'])){
                        $data['seo_title'] = $v['name'] . '-' . $setting['single_page_suffix'];
                    }else{
                        $data['seo_title'] = $this->ai_send('seo_title',$v['name']);
                    }
                }
                if(empty($v['seo_keywords'])){
                    $data['seo_keywords'] = $this->ai_send('seo_keywords',$v['name']);
                }
                if(empty($v['seo_des'])){
                    $name = $this->companyName($project_id);
                    $data['seo_des'] = $this->ai_send('page_meta_description',$v['title'],$name);
                }
                if(!$data){
                    continue;
                }
                DB::connection('custom_mysql')->table('gl_blog_category')->where(['id'=>$v['id']])->update($data);
            }
        }
        return true;
    }

    /**
     * @remark :单页面更新tdk
     * @name   :updatePage
     * @author :lyh
     * @method :post
     * @time   :2023/10/30 11:04
     */
    public function updatePage($project_id){
        $list = DB::connection('custom_mysql')->table('gl_web_custom_template')->select(['id','title','keywords','description','project_id'])->where(['project_id'=>$project_id])->get()->toArray();
        if(!empty($list)){
            foreach ($list as $v){
                $v = (array)$v;
                $data = [];
                if(empty($v['seo_title'])){
                    $setting = DB::connection('custom_mysql')->table('gl_web_setting_seo')->where(['project_id'=>$project_id])->first();
                    //生成seo_title
                    if(!empty($setting['single_page_suffix'])){
                        $data['title'] = $v['title'] . '-' . $setting['single_page_suffix'];
                    }else{
                        $data['title'] = $this->ai_send('seo_title',$v['title']);
                    }
                }
                if(empty($v['keywords'])){
                    //获取核心关键词
                    $main_keyword = $this->mainKeywords($project_id);
                    if(!empty($main_keyword)){
                        $data['keywords'] = $this->ai_send('seo_keywords',$main_keyword);
                    }else{
                        $data['keywords'] = $this->ai_send('seo_keywords',$v['title']);
                    }
                }
                if(empty($v['description'])){
                    $name = $this->companyName($project_id);
                    $data['description'] = $this->ai_send('page_meta_description',$v['title'],$name);
                }
                if(!$data){
                    continue;
                }
                DB::connection('custom_mysql')->table('gl_web_custom_template')->where(['id'=>$v['id']])->update($data);
            }
        }
    }

    /**
     * @remark :获取公司名称
     * @name   :companyName
     * @author :lyh
     * @method :post
     * @time   :2023/10/30 11:22
     */
    public function companyName($project_id){
        $projectOptimizeModel = new DeployOptimize();
        $info = $projectOptimizeModel->read(['project_id'=>$project_id],['id','company_en_name']);
        return $info['company_en_name'];
    }

    /**
     * @remark :获取公司核心关键词
     * @name   :mainKeywords
     * @author :lyh
     * @method :post
     * @time   :2023/10/30 11:22
     */
    public function mainKeywords($project_id){
        $str = '';
        $projectOptimizeModel = new DeployOptimize();
        $info = $projectOptimizeModel->read(['project_id'=>$project_id],['id','main_keywords']);
        if($info === false){
            $arr = explode(',',$info['main_keywords']);
            if(isset($arr[0])){
                $str = $arr[0];
            }
        }
        return $str;
    }

    /**
     * @remark :AI发送
     * @name   :ai_send
     * @author :lyh
     * @method :post
     * @time   :2023/8/19 10:40
     */
    public function ai_send($key,$keywords,$name = ''){
        $chat_url = 'v2/openai_chat_qqs';
        $param = [
            'key'=>$key,
            'keywords'=>$keywords,
        ];
        $data = Common::send_openai_msg($chat_url,$param,$name);
        $data['text'] = Common::deal_keywords($data['text']);
        $data['text'] = Common::deal_str($data['text']);
        return $data['text'];
    }

}