gx复制项目

lyh
app/Console/Commands/Project/CopyProject.php
--- a/app/Console/Commands/Project/CopyProject.php
查看文件 @887da4e
+++ b/app/Console/Commands/Project/CopyProject.php
查看文件 @887da4e
@@ -9,6 +9,7 @@
 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;
@@ -42,11 +43,46 @@ class CopyProject extends Command
     public function handle()
     {
         $projectModel = new Project();
-        DB::beginTransaction();
-        try {
+        while (true) {
             $this->output('CopyProjectJob start, project_id: ' . $this->param['project_id']);
-            //复制初始项目
-            $data = $projectModel::where('id', $this->param['project_id'])->first();
+            $list = NoticeLog::where('type', NoticeLog::TYPE_COPY_PROJECT)->where('status', NoticeLog::STATUS_PENDING)->get();
+            if(empty($list)){
+                sleep(5);
+                continue;
+            }
+            foreach ($list as $item){
+                try {
+                    $data = $item['data']['project_id'];
+                    $old_project_id = $data['project_id'];
+                    $type = $data['type'];
+                    $project_id = $this->copyProject($old_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);
+                    if($type != 0){
+                        $this->copyMysql($old_project_id,$project_id);
+                    }
+                    //修改项目状态
+                    $projectModel->edit(['delete_status'=>0],['id'=>$project_id]);
+                    $this->output('CopyProjectJob end, old project_id: ' . $old_project_id . ', new 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();
+                }
+            }
+        }
+        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;
@@ -68,9 +104,20 @@ class CopyProject extends Command
             ];
             $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', $this->param['project_id'])->first();
+        $buildData = $buildModel::where('project_id', $old_project_id)->first();
         if(!empty($buildData)){
             $buildData = $buildData->getAttributes();
             $buildData['project_id'] = $project_id;
@@ -80,9 +127,20 @@ class CopyProject extends Command
             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', $this->param['project_id'])->first();
+        $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']);
@@ -90,45 +148,59 @@ class CopyProject extends Command
             $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', $this->param['project_id'])->first();
+        $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', $this->param['project_id'])->first();
+        $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', $this->param['project_id'])->where('role_id',0)->first();
+        $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);
         }
-            DB::commit();
-        }catch (\Exception $e){
-            DB::rollBack();
-            $this->output('CopyProjectJob error, error message: ' . $e->getMessage());
-            $this->fail('error');
-        }
-        if($type != 0){
-            $this->copyMysql($this->param['project_id'],$project_id);
-        }
-        //修改项目状态
-        $projectModel->edit(['delete_status'=>0],['id'=>$project_id]);
-        $this->output('CopyProjectJob end, old project_id: ' . $this->param['project_id'] . ', new project_id: ' . $project_id);
         return true;
     }
@@ -191,4 +263,5 @@ class CopyProject extends Command
         Log::info($output);
         return true;
     }
+    
 }