update

@@ -46,7 +46,6 @@ class DevopsTask extends Command
      */
      */
     public function handle()
     public function handle()
     {
     {
-        while (true){
         $tasks = DevopsTaskModel::where('status', DevopsTaskModel::STATUS_PENDING)->get();
         $tasks = DevopsTaskModel::where('status', DevopsTaskModel::STATUS_PENDING)->get();
         foreach ($tasks as $task){
         foreach ($tasks as $task){
             echo "Start task " . $task->id;
             echo "Start task " . $task->id;
@@ -55,14 +54,12 @@ class DevopsTask extends Command
             }
             }
             echo "End task " . $task->id . PHP_EOL;
             echo "End task " . $task->id . PHP_EOL;
         }
         }
-            sleep(10);
-        }
     }
     }
 
 
     public function updateTable($task){
     public function updateTable($task){
         $projects = Project::all();
         $projects = Project::all();
         foreach ($projects as $project){
         foreach ($projects as $project){
-            echo "project " . $project->id .  PHP_EOL;
+            echo "project " . $project->id;
             $log = DevopsTaskLog::addLog($task->id, $project->id);
             $log = DevopsTaskLog::addLog($task->id, $project->id);
             if($log->status == DevopsTaskModel::STATUS_ACTIVE){
             if($log->status == DevopsTaskModel::STATUS_ACTIVE){
                 echo  'continue' . PHP_EOL;
                 echo  'continue' . PHP_EOL;

@@ -11,7 +11,9 @@ use App\Models\Project\Project;
 use App\Models\Devops\ServerConfig;
 use App\Models\Devops\ServerConfig;
 use App\Services\ProjectServer;
 use App\Services\ProjectServer;
 use App\Utils\EncryptUtils;
 use App\Utils\EncryptUtils;
+use Illuminate\Support\Facades\Artisan;
 use Illuminate\Support\Facades\DB;
 use Illuminate\Support\Facades\DB;
+use Symfony\Component\Process\Process;
 
 
 /**
 /**
  * Class ServerConfigLogic
  * Class ServerConfigLogic
@@ -174,6 +176,9 @@ class ServerConfigLogic extends BaseLogic
      */
      */
     public function updateAllTable($param){
     public function updateAllTable($param){
         DevopsTask::addTask($param['sql']);
         DevopsTask::addTask($param['sql']);
+        //执行命令行
+        $process = new Process(['php', 'artisan', 'devops_task']);
+        $process->start();
         return $this->success();
         return $this->success();
     }
     }
 }
 }