gx

-<?php
-/**
- * @remark :
- * @name   :CopyProject.php
- * @author :lyh
- * @method :post
- * @time   :2024/1/9 16:01
- */
-
-namespace App\Events;
-
-use Illuminate\Broadcasting\InteractsWithSockets;
-use Illuminate\Foundation\Events\Dispatchable;
-use Illuminate\Queue\SerializesModels;
-class CopyImageFile
-{
-    use Dispatchable, InteractsWithSockets, SerializesModels;
-    public $data;
-    /**
-     * 监听更新HTML静态页
-     */
-    public function __construct($data)
-    {
-        $this->data = $data;
-    }
-}

-<?php
-
-namespace App\Listeners;
-
-use App\Events\CopyProject;
-use App\Events\UpdateHtml;
-use App\Jobs\updateHtmlJob;
-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\Contracts\Queue\ShouldQueue;
-use Illuminate\Support\Facades\DB;
-use Illuminate\Support\Facades\Schema;
-
-class CopyProjectListener implements ShouldQueue
-{
-    public function __construct()
-    {
-        //
-    }
-
-    /**
-     * Handle the event.
-     *
-     * @param  UpdateHtml  $event
-     * @return void
-     */
-    public function handle(CopyProject $event)
-    {
-        $this->param = $event->data;
-        $this->model = new Project();
-        DB::beginTransaction();
-        try {
-            //复制初始项目
-            $data = $this->model::where('id', $this->param['project_id'])->first();
-            $data = $data->getAttributes();
-            $type = $data['type'];
-            $data['type'] = 0;
-            $data['title'] = $data['title'].'-copy';
-            unset($data['id']);
-            $project_id = $this->model->insertGetId($data);
-            //复制部署表
-            $buildModel = new DeployBuild();
-            $buildData = $buildModel::where('project_id', $this->param['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);
-            }
-            //复制优化表
-            $optimizeModel = new DeployOptimize();
-            $optimizeData = $optimizeModel::where('project_id', $this->param['project_id'])->first();
-            if(!empty($optimizeData)){
-                $optimizeData = $optimizeData->getAttributes();
-                unset($optimizeData['id'],$optimizeData['domain']);
-                $optimizeData['project_id'] = $project_id;
-                $optimizeModel->insert($optimizeData);
-            }
-            //复制付费表
-            $paymentModel = new Payment();
-            $paymentData = $paymentModel::where('project_id', $this->param['project_id'])->first();
-            if(!empty($paymentData)){
-                $paymentData = $paymentData->getAttributes();
-                unset($paymentData['id']);
-                $paymentData['project_id'] = $project_id;
-                $paymentModel->insert($paymentData);
-            }
-            //复制售后表
-            $afterModel = new After();
-            $afterData = $afterModel::where('project_id', $this->param['project_id'])->first();
-            if(!empty($afterData)){
-                $afterData = $afterData->getAttributes();
-                unset($afterData['id']);
-                $afterData['project_id'] = $project_id;
-                $afterModel->insert($afterData);
-            }
-            //复制用户
-            $userModel = new UserModel();
-            $userData = $userModel::where('project_id', $this->param['project_id'])->where('role_id',0)->first();
-            if(!empty($userData)){
-                $userData = $userData->getAttributes();
-                unset($userData['id']);
-                $userData['project_id'] = $project_id;
-                $userModel->insert($userData);
-            }
-            //复制设置的模版
-            $settingTemplateModel = new Setting();
-            $settingData = $settingTemplateModel::where('project_id', $this->param['project_id'])->first();
-            if(!empty($settingData)){
-                $settingData = $settingData->getAttributes();
-                unset($settingData['id']);
-                $settingData['project_id'] = $project_id;
-                $settingTemplateModel->insert($settingData);
-            }
-            DB::commit();
-        }catch (\Exception $e){
-            DB::rollBack();
-            $this->fail('error');
-        }
-        if($type != 0){
-            $this->copyMysql($this->param['project_id'],$project_id);
-        }
-        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);
-    }
-
-    /**
-     * @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) {
-            $has_table = Schema::connection('custom_mysql')->hasTable($table);
-            if (!$has_table) {
-                $sql = DB::connection('custom_tmp_mysql_copy')->select("SHOW CREATE TABLE {$table}");
-                DB::connection('custom_mysql')->statement(get_object_vars($sql[0])['Create Table']);
-            }
-            DB::connection('custom_mysql')->table($table)->truncate(); // 清空目标表数据
-            DB::connection('custom_mysql')->table($table)->insertUsing(
-                [], // 列名数组，留空表示插入所有列
-                function ($query) use ($table,$project_id) {
-                    $name = 'gl_data_'.$project_id.'.'.$table;
-                    $query->select('*')->from("{$name}");
-                }
-            );
-            if (Schema::connection('custom_mysql')->hasColumn($table, 'project_id')) {
-                DB::connection('custom_mysql')->table($table)->update(['project_id' => $news_project_id]);
-            }
-        }
-        return true;
-    }
-}