<?php
/**
 * @remark :
 * @name   :CopyProject.php
 * @author :lyh
 * @method :post
 * @time   :2025/1/15 14:40
 */

namespace App\Console\Commands\Project;

use App\Models\Com\NoticeLog;
use App\Models\Project\After;
use App\Models\Project\DeployBuild;
use App\Models\Project\DeployOptimize;
use App\Models\Project\Payment;
use App\Models\Project\Project;
use App\Models\Template\Setting;
use App\Models\User\User as UserModel;
use App\Services\ProjectServer;
use Hashids\Hashids;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\Artisan;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Schema;

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

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'copy--复制项目';

    public function handle()
    {
        while (true) {
            $projectModel = new Project();
            $list = NoticeLog::where('type', NoticeLog::TYPE_COPY_PROJECT)->where('status', NoticeLog::STATUS_PENDING)->get();
            if(empty($list)){
                sleep(30);
                continue;
            }
            foreach ($list as $item){
                try {
                    $old_project_id = $item['data']['project_id'];
                    $this->output('CopyProjectJob start, project_id: ' . $old_project_id);
                    $data = $this->copyProject($old_project_id);
                    $project_id = $data['project_id'];
                    $this->copyDeployBuild($old_project_id,$project_id);
                    $this->copyDeployOptimize($old_project_id,$project_id);
                    $this->copyPayment($old_project_id,$project_id);
                    $this->copyAfter($old_project_id,$project_id);
                    $this->copyUser($old_project_id,$project_id);
                    $item->status = NoticeLog::STATUS_SUCCESS;
                    $item->save();
                }catch (\Exception $e){
                    echo 'error:' . $item['id'] . $e->getMessage() . PHP_EOL . date('Y-m-d H:i:s');
                    errorLog('项目初始化失败', $item, $e);
                    $item->status = NoticeLog::STATUS_FAIL;
                    $item->save();
                }
                sleep(60);
                try {
                    $this->copyMysql($old_project_id,$project_id);
                    $this->output('CopyProjectJob end, old project_id: ' . $old_project_id . ', new project_id: ' . $project_id);
                }catch (\Exception $e){
                    echo $e->getMessage().PHP_EOL;
                    echo '复制数据库失败：'.$old_project_id . '<->'.$project_id;
                }
                //修改项目状态
                $projectModel->edit(['delete_status'=>0],['id'=>$project_id]);
            }
        }
        return true;
    }

    public function copyProject($old_project_id){
        $projectModel = new Project();
        $data = $projectModel::where('id', $old_project_id)->first();
        $data = $data->getAttributes();
        $type = $data['type'];
        $data['type'] = 0;
        $data['status'] = 0;
        $data['finish_remain_day'] = 0;
        $data['title'] = $data['title'].'-copy';
        $data['delete_status'] = 1;
        $data['is_ai_blog'] = 0;
        unset($data['id'],$data['exclusive_aicc_day'],$data['aicc'],$data['robots'],$data['is_translate_tag'],$data['is_translate'],$data['is_minor_languages'],$data['uptime']);
        $project_id = $projectModel->insertGetId($data);
        $hashids = new Hashids($data['from_order_id'], 13, 'abcdefghjkmnpqrstuvwxyz1234567890');
        $projectModel->edit(['from_order_id'=>$hashids->encode($project_id)],['id'=>$project_id]);
        //复制设置的模版
        $settingTemplateModel = new Setting();
        $settingData = $settingTemplateModel::where('project_id', $old_project_id)->first();
        if(!empty($settingData)){
            $data = [
                'template_id' =>$settingData['template_id'],
                'project_id' => $project_id
            ];
            $settingTemplateModel->add($data);
        }
        return ['project_id'=>$project_id,'type'=>$type];
    }

    /**
     * @remark :复制部署表
     * @name   :copyDeployBuild
     * @author :lyh
     * @method :post
     * @time   :2025/1/15 14:59
     */
    public function copyDeployBuild($old_project_id,$project_id){
        //复制部署表
        $buildModel = new DeployBuild();
        $buildData = $buildModel::where('project_id', $old_project_id)->first();
        if(!empty($buildData)){
            $buildData = $buildData->getAttributes();
            $buildData['project_id'] = $project_id;
            $hashids = new Hashids('test_domain', 5, 'abcdefghjkmnpqrstuvwxyz1234567890');
            $code = $hashids->encode($project_id);
            $buildData['test_domain'] = 'https://v6-' . $code . '.globalso.site/';
            unset($buildData['id']);
            $buildModel->insert($buildData);
        }
        return true;
    }

    /**
     * @remark :复制优化表
     * @name   :copyDeployOptimize
     * @author :lyh
     * @method :post
     * @time   :2025/1/15 15:02
     */
    public function copyDeployOptimize($old_project_id,$project_id){
        //复制优化表
        $optimizeModel = new DeployOptimize();
        $optimizeData = $optimizeModel::where('project_id', $old_project_id)->first();
        if(!empty($optimizeData)){
            $optimizeData = $optimizeData->getAttributes();
            unset($optimizeData['id'],$optimizeData['domain'],$optimizeData['backlink'],$optimizeData['ai_video'],$optimizeData['is_ai_blog_send']);
            $optimizeData['project_id'] = $project_id;
            $optimizeData['api_no'] = 0;
            $optimizeModel->insert($optimizeData);
        }
        return true;
    }

    /**
     * @remark :复制付费表
     * @name   :copyPayment
     * @author :lyh
     * @method :post
     * @time   :2025/1/15 15:03
     */
    public function copyPayment($old_project_id,$project_id){
        //复制付费表
        $paymentModel = new Payment();
        $paymentData = $paymentModel::where('project_id', $old_project_id)->first();
        if(!empty($paymentData)){
            $paymentData = $paymentData->getAttributes();
            unset($paymentData['id']);
            $paymentData['project_id'] = $project_id;
            $paymentModel->insert($paymentData);
        }
        return true;
    }

    public function copyAfter($old_project_id,$project_id){
        //复制售后表
        $afterModel = new After();
        $afterData = $afterModel::where('project_id',$old_project_id)->first();
        if(!empty($afterData)){
            $afterData = $afterData->getAttributes();
            unset($afterData['id']);
            $afterData['project_id'] = $project_id;
            $afterModel->insert($afterData);
        }
        return true;
    }

    /**
     * @remark :复制user
     * @name   :copyUser
     * @author :lyh
     * @method :post
     * @time   :2025/1/15 15:04
     */
    public function copyUser($old_project_id,$project_id){
        //复制用户
        $userModel = new UserModel();
        $userData = $userModel::where('project_id', $old_project_id)->where('role_id',0)->first();
        if(!empty($userData)){
            $userData = $userData->getAttributes();
            unset($userData['id']);
            $userData['project_id'] = $project_id;
            $userModel->insert($userData);
        }
        return true;
    }
    //复制数据库
    public function copyMysql($project_id,$new_project_id){
        //切换数据库配置
        $project = ProjectServer::useProject($new_project_id);
        //创建数据库
        ProjectServer::createDatabase($project);
        //创建表
        $this->initTable($project_id,$new_project_id);
        //修改项目状态
        $projectModel = new Project();
        $projectModel->edit(['delete_status'=>0],['id'=>$new_project_id]);
    }

    /**
     * @remark :创建数据库
     * @name   :initTable
     * @author :lyh
     * @method :post
     * @time   :2023/12/11 10:09
     */
    public function initTable($project_id, $news_project_id)
    {
        // 设置源数据库
        config(['database.connections.custom_tmp_mysql_copy.database' => 'gl_data_' . $project_id]);
        $database_name = DB::connection('custom_tmp_mysql_copy')->getDatabaseName();
        // 获取源数据库的所有表
        $tables = Schema::connection('custom_tmp_mysql_copy')->getAllTables();
        $tables = array_column($tables, 'Tables_in_' . $database_name);
        foreach ($tables as $table) {
            // 1. 删除目标数据库中的表
            DB::connection('custom_mysql')->statement("DROP TABLE IF EXISTS {$table}");
            // 2. 重新创建表
            $sql = DB::connection('custom_tmp_mysql_copy')->select("SHOW CREATE TABLE {$table}");
            DB::connection('custom_mysql')->statement(get_object_vars($sql[0])['Create Table']);
            // 3. 跳过指定的表
            if (in_array($table, ['gl_customer_visit', 'gl_customer_visit_item', 'gl_inquiry_other', 'gl_inquiry_form_data', 'gl_inquiry_form'])) {
                continue;
            }
            try {
                // 4. 重新插入数据
                DB::connection('custom_mysql')->table($table)->insertUsing(
                    [], // 插入所有列
                    function ($query) use ($table, $project_id) {
                        $name = 'gl_data_' . $project_id . '.' . $table;
                        $query->select('*')->from("{$name}");
                    }
                );
            }catch (\Exception $e){
                continue;
            }
            // 5. 更新 project_id（如果存在）
            if (Schema::connection('custom_mysql')->hasColumn($table, 'project_id')) {
                DB::connection('custom_mysql')->table($table)->update(['project_id' => $news_project_id]);
            }
        }
        return true;
    }
    /**
     * @param $message
     * @return bool
     */
    public function output($message)
    {
        $date = date('Y-m-d H:i:s');
        $output = $date . ', ' . $message . PHP_EOL;
        echo $output;
        Log::info($output);
        return true;
    }

}