gx

@@ -9,7 +9,18 @@
 
 
 namespace App\Events;
 namespace App\Events;
 
 
+use Illuminate\Broadcasting\InteractsWithSockets;
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
 class CopyProject
 class CopyProject
 {
 {
-
+    use Dispatchable, InteractsWithSockets, SerializesModels;
+    public $data;
+    /**
+     * 监听更新HTML静态页
+     */
+    public function __construct($data)
+    {
+        $this->data = $data;
+    }
 }
 }

@@ -3,6 +3,7 @@
 namespace App\Http\Logic\Aside\Project;
 namespace App\Http\Logic\Aside\Project;
 
 
 use App\Enums\Common\Code;
 use App\Enums\Common\Code;
+use App\Events\CopyProject;
 use App\Exceptions\AsideGlobalException;
 use App\Exceptions\AsideGlobalException;
 use App\Models\Com\NoticeLog;
 use App\Models\Com\NoticeLog;
 use App\Models\Com\UpdateLog;
 use App\Models\Com\UpdateLog;
@@ -567,128 +568,8 @@ class ProjectLogic extends BaseLogic
      * @time   :2023/11/8 14:23
      * @time   :2023/11/8 14:23
      */
      */
     public function copyProject(){
     public function copyProject(){
-        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 $this->success($data);
-    }
-
-    //复制数据库
-    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;
+        CopyProject::dispatch(['project_id'=>$this->param['project_id']]);
+        return $this->success();
     }
     }
 
 
     /**
     /**

@@ -5,14 +5,21 @@ namespace App\Listeners;
 use App\Events\CopyProject;
 use App\Events\CopyProject;
 use App\Events\UpdateHtml;
 use App\Events\UpdateHtml;
 use App\Jobs\updateHtmlJob;
 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\Contracts\Queue\ShouldQueue;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Schema;
 
 
 class CopyProjectListener implements ShouldQueue
 class CopyProjectListener implements ShouldQueue
 {
 {
-    /**
-     * 更新页面
-     * @return void
-     */
     public function __construct()
     public function __construct()
     {
     {
         //
         //
@@ -26,7 +33,127 @@ class CopyProjectListener implements ShouldQueue
      */
      */
     public function handle(CopyProject $event)
     public function handle(CopyProject $event)
     {
     {
-        $data = $event->data;
-        dump($data);
+        $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;
     }
     }
 }
 }

@@ -2,6 +2,8 @@
 
 
 namespace App\Providers;
 namespace App\Providers;
 
 
+use App\Events\CopyProject;
+use App\Listeners\CopyProjectListener;
 use Illuminate\Auth\Events\Registered;
 use Illuminate\Auth\Events\Registered;
 use Illuminate\Auth\Listeners\SendEmailVerificationNotification;
 use Illuminate\Auth\Listeners\SendEmailVerificationNotification;
 use Illuminate\Foundation\Support\Providers\EventServiceProvider as ServiceProvider;
 use Illuminate\Foundation\Support\Providers\EventServiceProvider as ServiceProvider;
@@ -22,6 +24,7 @@ class EventServiceProvider extends ServiceProvider
         'Illuminate\Database\Events\QueryExecuted' => [
         'Illuminate\Database\Events\QueryExecuted' => [
             'App\Listeners\QueryListener',
             'App\Listeners\QueryListener',
         ],
         ],
+        CopyProject::class => [CopyProjectListener::class],
     ];
     ];
 
 
     /**
     /**