变更数据

@@ -85,6 +85,7 @@ class TicketUploadDataLogic extends BaseLogic
         }
         //审核成功执行
         if($this->param['status'] == 1){
+            ProjectServer::useProject($info['project_id']);
             if($info['type'] == 1){
                 $this->saveProductData($info);
             }elseif ($info['type'] == 2){
@@ -92,6 +93,7 @@ class TicketUploadDataLogic extends BaseLogic
             }else{
                 $this->saveNewsData($info);
             }
+            DB::disconnect('custom_mysql');
         }
         $data = $this->model->edit(['status'=>$this->param['status'],'remark'=>$this->param['remark'] ?? ''],['id'=>$this->param['id']]);
         return $this->success($data);
@@ -121,7 +123,6 @@ class TicketUploadDataLogic extends BaseLogic
             $info['text']['image'] = Arr::a2s([]);
         }
         try {
-            ProjectServer::useProject($info['project_id']);
             $productModel = new Product();
             $data = [
                 'project_id' => $info['project_id'],
@@ -138,7 +139,6 @@ class TicketUploadDataLogic extends BaseLogic
             KeywordRelated::saveRelated($id,$info['text']['keyword_id'] ?? []);//关键字关联
             $route = RouteMap::setRoute($data['title'],RouteMap::SOURCE_PRODUCT,$id,$info['project_id']);
             $this->model->edit(['route'=>$route],['id'=>$id]);
-            DB::disconnect('custom_mysql');
         }catch (\Exception $e){
             $this->fail('保存失败，请联系管理员');
         }
@@ -169,12 +169,10 @@ class TicketUploadDataLogic extends BaseLogic
             'status'=>0,
         ];
         try {
-            ProjectServer::useProject($info['project_id']);
             $newsModel = new News();
             $id = $newsModel->addReturnId($data);
             $route = RouteMap::setRoute($data['name'],RouteMap::SOURCE_BLOG,$id,$info['project_id']);
             $this->model->edit(['url'=>$route],['id'=>$id]);
-            DB::disconnect('custom_mysql');
         }catch (\Exception $e){
             $this->fail('保存失败，请联系管理员');
         }
@@ -205,12 +203,10 @@ class TicketUploadDataLogic extends BaseLogic
             'status'=>0,
         ];
         try {
-            ProjectServer::useProject($info['project_id']);
             $newsModel = new News();
             $id = $newsModel->addReturnId($data);
             $route = RouteMap::setRoute($data['name'],RouteMap::SOURCE_NEWS,$id,$info['project_id']);
             $this->model->edit(['route'=>$route],['id'=>$id]);
-            DB::disconnect('custom_mysql');
         }catch (\Exception $e){
             $this->fail('保存失败，请联系管理员');
         }