GX生成白帽报表脚本

@@ -21,7 +21,9 @@ use App\Models\Product\Keyword;
 use App\Models\Product\Product;
 use App\Models\Product\Product;
 use App\Models\Project\Project;
 use App\Models\Project\Project;
 use App\Models\RouteMap\RouteMap;
 use App\Models\RouteMap\RouteMap;
+use App\Services\ProjectServer;
 use Illuminate\Console\Command;
 use Illuminate\Console\Command;
+use Illuminate\Support\Facades\DB;
 use Illuminate\Support\Facades\Redis;
 use Illuminate\Support\Facades\Redis;
 use PhpOffice\PhpSpreadsheet\IOFactory;
 use PhpOffice\PhpSpreadsheet\IOFactory;
 use function Aws\default_http_handler;
 use function Aws\default_http_handler;
@@ -60,11 +62,13 @@ class UpdateProjectTdk extends Command
                     $noticeLogModel->edit(['status'=>$noticeLogModel::STATUS_FAIL],['id'=>$task_id]);
                     $noticeLogModel->edit(['status'=>$noticeLogModel::STATUS_FAIL],['id'=>$task_id]);
                     continue;
                     continue;
                 }
                 }
+                ProjectServer::useProject($project_id);
                 $url = $info['data']['url'] ?? '';
                 $url = $info['data']['url'] ?? '';
                 if(empty($url)){
                 if(empty($url)){
                     echo date('Y-m-d H:i:s').'未获取到项目更新文件.项目id为：'.$project_id.PHP_EOL;
                     echo date('Y-m-d H:i:s').'未获取到项目更新文件.项目id为：'.$project_id.PHP_EOL;
                     //未获取到文件，跳过
                     //未获取到文件，跳过
                     $noticeLogModel->edit(['status'=>$noticeLogModel::STATUS_SUCCESS],['id'=>$task_id]);
                     $noticeLogModel->edit(['status'=>$noticeLogModel::STATUS_SUCCESS],['id'=>$task_id]);
+                    DB::disconnect('custom_mysql');
                     continue;
                     continue;
                 }
                 }
                 // 下载到 Laravel storage 的临时路径
                 // 下载到 Laravel storage 的临时路径
@@ -79,9 +83,9 @@ class UpdateProjectTdk extends Command
                 }catch (\Exception $e){
                 }catch (\Exception $e){
                     echo '文件打不开'.PHP_EOL;
                     echo '文件打不开'.PHP_EOL;
                     $noticeLogModel->edit(['status'=>$noticeLogModel::STATUS_FAIL],['id'=>$task_id]);
                     $noticeLogModel->edit(['status'=>$noticeLogModel::STATUS_FAIL],['id'=>$task_id]);
+                    DB::disconnect('custom_mysql');
                     continue;
                     continue;
                 }
                 }
-                // 假设第一行是表头
                 $dataRows = array_slice($rows, 1);
                 $dataRows = array_slice($rows, 1);
                 foreach ($dataRows as $item){
                 foreach ($dataRows as $item){
                     //获取路由
                     //获取路由
@@ -89,7 +93,7 @@ class UpdateProjectTdk extends Command
                     $route = basename($route);
                     $route = basename($route);
                     $this->updateTdk($route,$item);
                     $this->updateTdk($route,$item);
                 }
                 }
-                dd($dataRows);
+                DB::disconnect('custom_mysql');
             }
             }
         }
         }
         return true;
         return true;