gx

@@ -7,6 +7,7 @@ use App\Events\CopyImageFile;
 use App\Events\CopyProject;
 use App\Events\CopyProject;
 use App\Exceptions\AsideGlobalException;
 use App\Exceptions\AsideGlobalException;
 use App\Jobs\CopyImageFileJob;
 use App\Jobs\CopyImageFileJob;
+use App\Jobs\CopyProjectJob;
 use App\Models\Com\NoticeLog;
 use App\Models\Com\NoticeLog;
 use App\Models\Com\UpdateLog;
 use App\Models\Com\UpdateLog;
 use App\Models\Devops\ServerConfig;
 use App\Models\Devops\ServerConfig;
@@ -612,7 +613,7 @@ class ProjectLogic extends BaseLogic
      * @time   :2023/11/8 14:23
      * @time   :2023/11/8 14:23
      */
      */
     public function copyProject(){
     public function copyProject(){
-        CopyProject::dispatch(['project_id'=>$this->param['project_id']]);
+        CopyProjectJob::dispatch(['project_id'=>$this->param['project_id']]);
         return $this->success();
         return $this->success();
     }
     }
 
 

+<?php
+
+namespace App\Jobs;
+
+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\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Queue\SerializesModels;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Schema;
+
+class CopyProjectJob implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+    public $tries = 3; // 可配置任务重试次数
+
+    protected $param;
+
+    /**
+     * Create a new job instance.
+     *
+     * @param  CopyImageFile  $event
+     * @return void
+     */
+    public function __construct($data)
+    {
+        $this->param = $data;
+    }
+
+
+    /**
+     * Handle the event.
+     *
+     * @param  UpdateHtml  $event
+     * @return void
+     */
+    public function handle(CopyProject $event)
+    {
+        @file_put_contents(storage_path('logs/lyh_error.log'), var_export('复制项目测试进入：', true) . PHP_EOL, FILE_APPEND);
+        $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;
+    }
+}

@@ -25,7 +25,7 @@ class EventServiceProvider extends ServiceProvider
         'Illuminate\Database\Events\QueryExecuted' => [
         'Illuminate\Database\Events\QueryExecuted' => [
             'App\Listeners\QueryListener',
             'App\Listeners\QueryListener',
         ],
         ],
-        CopyProject::class => [CopyProjectListener::class],
+//        CopyProject::class => [CopyProjectListener::class],
     ];
     ];
 
 
     /**
     /**