<?php
/**
 * @remark :
 * @name   :ReplaceHtml.php
 * @author :lyh
 * @method :post
 * @time   :2024/5/10 17:20
 */

namespace App\Console\Commands\ReplaceHtml;

use App\Models\Blog\Blog;
use App\Models\Blog\BlogCategory;
use App\Models\CustomModule\CustomModule;
use App\Models\CustomModule\CustomModuleCategory;
use App\Models\CustomModule\CustomModuleContent;
use App\Models\News\News;
use App\Models\News\NewsCategory;
use App\Models\Product\Category;
use App\Models\Product\Product;
use App\Models\RouteMap\RouteMap;
use App\Models\Template\BCustomTemplate;
use App\Models\Template\BTemplate;
use App\Models\Template\TemplateReplaceHtmlLog;
use App\Services\ProjectServer;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use App\Models\Template\TemplateReplaceHtml;

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

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = '替换html代码生成子任务';

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

    /**
     * @return bool
     */
    public function handle()
    {
        while (true){
            $replaceHtmlModel = new TemplateReplaceHtml();
            $replaceHtmlList = $replaceHtmlModel->list(['status'=>$replaceHtmlModel::STATUS]);
            if(empty($replaceHtmlList)){
                sleep(20);
                continue;
            }
            foreach ($replaceHtmlList as $v){
                ProjectServer::useProject($v['project_id']);
                echo '开始,任务id:'.$v['id'].PHP_EOL;
                if(($v['source'] == 9) && ($v['is_custom'] == 0)){//单页面
                    $count = $this->createReplacePageHtmlLog($v);
                }else{
                    $count = $this->createReplaceHtmlLog($v);
                }
                //修改当前主任务状态为待执行
                $replaceHtmlModel->edit(['status'=>$replaceHtmlModel::STATUS_START,'total_num'=>$count],['id'=>$v['id']]);
                echo '结束'.PHP_EOL;
                DB::disconnect('custom_mysql');
            }
            sleep(10);
        }
    }

    /**
     * @remark :生成单页面记录
     * @name   :createReplacePageHtmlLog
     * @author :lyh
     * @method :post
     * @time   :2024/5/13 11:40
     */
    public function createReplacePageHtmlLog($info){
        $saveData = [];
        $customTemplateModel = new BCustomTemplate();
        $list = $customTemplateModel->list(['status'=>BCustomTemplate::STATUS_ACTIVE]);
        foreach ($list as $v){
            $saveData[] = [
                'replace_id'=>$info['id'],
                'project_id'=>$info['project_id'],
                'status'=>0,
                'old_html'=>$info['old_html'],
                'html'=>$info['html'],
                'source'=>9,
                'source_id'=>$v['id'],
                'is_rollback'=>$info['is_rollback'],
                'template_id'=>$info['template_id'],
                'source_name'=>$v['name'],
                'created_at'=>date('Y-m-d H:i:s'),
                'updated_at'=>date('Y-m-d H:i:s')
            ];
        }
        if(!empty($saveData)){
            $templateHtmlLogModel = new TemplateReplaceHtmlLog();
            $templateHtmlLogModel->insert($saveData);
        }
        return count($saveData);
    }

    /**
     * @remark :生成子任务
     * @name   :createReplaceHtmlLog
     * @author :lyh
     * @method :post
     * @time   :2024/5/10 17:26
     */
    public function createReplaceHtmlLog($info){
        if($info['is_rollback'] != 0){
            $saveData = [];
            $templateHtmlLogModel = new TemplateReplaceHtmlLog();
            $list = $templateHtmlLogModel->list(['replace_id'=>$info['rollback_id']]);
            foreach ($list as $value){
                unset($value['id']);
                $value['replace_id'] = $info['id'];
                $value['is_rollback'] = $info['is_rollback'];
                $value['old_html'] = $info['old_html'];
                $value['html'] = $info['html'];
                $value['created_at'] = date('Y-m-d H:i:s');
                $value['updated_at'] = date('Y-m-d H:i:s');
                $saveData[] = $value;
            }
        }else{
            $bTemplateModel = new BTemplate();
            $condition = ['is_custom'=>$info['is_custom'], 'is_list'=>$info['is_list'], 'template_id'=>$info['template_id']];
            if($info['source'] != 0){
                $condition['source'] = $info['source'];
            }
            if($info['template_id'] != 0){
                $condition['main_html'] = ['like','%'.trim($info['old_html']).'%'];
            }else{
                $condition['html'] = ['like','%'.trim($info['old_html']).'%'];
            }
            $bTemplateList = $bTemplateModel->list($condition);
            $saveData = [];
            foreach ($bTemplateList as $v){
                $source_id = $v['source'] == 1 ? 0 : $v['source_id'];
                $name_route = $this->getSourceName($v['source'],$source_id,$v['is_list'],$v['is_custom']);
                if($name_route !== false){
                    $saveData[] = $this->saveData($info,$v,$source_id,$name_route);
                }
            }
        }
        if(!empty($saveData)){
            $templateHtmlLogModel = new TemplateReplaceHtmlLog();
            $templateHtmlLogModel->insert($saveData);
        }
        return count($saveData);
    }

    /**
     * @remark :组装数据
     * @name   :saveData
     * @author :lyh
     * @method :post
     * @time   :2024/5/13 11:29
     */
    public function saveData($info,$v,$source_id,$name_route){
        return [
            'replace_id'=>$info['id'],
            'project_id'=>$info['project_id'],
            'status'=>0,
            'old_html'=>$info['old_html'],
            'html'=>$info['html'],
            'source'=>$v['source'],
            'source_id'=>$source_id,
            'is_custom'=>$v['is_custom'],
            'is_list'=>$v['is_list'],
            'is_rollback'=>$info['is_rollback'],
            'template_id'=>$info['template_id'],
            'source_name'=>$name_route['name'],
            'route'=>$name_route['route'],
            'created_at'=>date('Y-m-d H:i:s'),
            'updated_at'=>date('Y-m-d H:i:s')
        ];
    }

    /**
     * @remark :生成子任务获取对应数据id名称
     * @name   :getSourceName
     * @author :lyh
     * @method :post
     * @time   :2024/5/13 10:47
     */
    public function getSourceName($source,$source_id,$is_list,$is_custom){
        if($is_custom == 1){//扩展模块
            return $this->getCustomName($source,$source_id,$is_list);
        }
        if($source == BTemplate::SOURCE_HOME){
            return ['name'=>'','route'=>''];
        }elseif ($source == BTemplate::SOURCE_PRODUCT){
            return $this->getProductName($source_id,$is_list);
        }elseif ($source == BTemplate::SOURCE_BLOG){
            return $this->getBlogName($source_id,$is_list);
        }elseif ($source == BTemplate::SOURCE_NEWS){
            return $this->getNewsName($source_id,$is_list);
        }else {//单页面管理
            return $this->getPageName($source_id);
        }
        return false;
    }

    /**
     * @remark :获取单页面名称
     * @name   :getPageName
     * @author :lyh
     * @method :post
     * @time   :2024/5/13 11:10
     */
    public function getPageName($source_id){
        $customTemplateModel = new BCustomTemplate();
        $info = $customTemplateModel->read(['id'=>$source_id]);
        if($info === false){
            return false;
        }
        return  $info['name'];
    }

    /**
     * @remark :获取新闻名称
     * @name   :getNewsName
     * @author :lyh
     * @method :post
     * @time   :2024/5/13 11:07
     */
    public function getNewsName($source_id,$is_list){
        if($is_list == BTemplate::IS_LIST){
            $cateModel = new NewsCategory();
            $cateInfo = $cateModel->read(['id'=>$source_id]);
            if($cateInfo === false){
                return false;
            }
            $name = $cateInfo['name'];
            $route = $cateInfo['alias'];
        }else{
            $newsModel = new News();
            $newsInfo = $newsModel->read(['id'=>$source_id]);
            if($newsInfo === false){
                return false;
            }
            $name = $newsInfo['name'];
            $route = $newsInfo['url'];
        }
        return ['name'=>$name,'route'=>$route];
    }

    /**
     * @remark :获取blog名称
     * @name   :getBlogName
     * @author :lyh
     * @method :post
     * @time   :2024/5/13 11:05
     */
    public function getBlogName($source_id,$is_list){
        if($is_list == BTemplate::IS_LIST){
            $cateModel = new BlogCategory();
            $cateInfo = $cateModel->read(['id'=>$source_id]);
            if($cateInfo === false){
                return false;
            }
            $name = $cateInfo['name'];
            $route = $cateInfo['alias'];
        }else{
            $blogModel = new Blog();
            $productInfo = $blogModel->read(['id'=>$source_id]);
            if($productInfo === false){
                return false;
            }
            $name = $productInfo['name'];
            $route = $productInfo['url'];
        }
        return ['name'=>$name,'route'=>$route];
    }

    /**
     * @remark :获取产品名称
     * @name   :getProductName
     * @author :lyh
     * @method :post
     * @time   :2024/5/13 11:00
     */
    public function getProductName($source_id,$is_list){
        if($is_list == BTemplate::IS_LIST){
            $cateModel = new Category();
            $cateInfo = $cateModel->read(['id'=>$source_id]);
            if($cateInfo === false){
                return false;
            }
            $name = $cateInfo['title'];
            $route = $cateInfo['route'];
        }else{
            $productModel = new Product();
            $productInfo = $productModel->read(['id'=>$source_id]);
            if($productInfo === false){
                return false;
            }
            $name = $productInfo['title'];
            $route = $productInfo['route'];
        }
        return ['name'=>$name,'route'=>$route];
    }

    /**
     * @remark :获取扩展模块名称
     * @name   :getCustomName
     * @author :lyh
     * @method :post
     * @time   :2024/5/13 10:55
     */
    public function getCustomName($source,$source_id,$is_list){
        $customModuleModel = new CustomModule();
        $moduleInfo = $customModuleModel->read(['id'=>$source]);
        if($moduleInfo === false){
            return false;
        }
        if($is_list == BTemplate::IS_LIST){
            $categoryModel = new CustomModuleCategory();
            $cateInfo = $categoryModel->read(['id'=>$source_id],['id','name','route']);
            if($cateInfo === false){
                return false;
            }
            $name = $cateInfo['name'];
            $route = $cateInfo['route'];
        }else{
            $contentModel = new CustomModuleContent();
            $contentInfo = $contentModel->read(['id'=>$source_id],['id','name','route']);
            if($contentInfo === false){
                return false;
            }
            $name = $contentInfo['name'];
            $route = $contentInfo['route'];
        }
        return ['name'=>$name,'route'=>$route];
    }
}