update

@@ -178,7 +178,7 @@ class UpdateSeoTdk extends Command
                     Cache::put($cache_key, 1, 120);
                     Cache::put($cache_key, 1, 120);
 
 
                     echo date('Y-m-d H:i:s') . '更新--' . $table . ': 项目id' . $project_id . ':id' . $v['id'] . PHP_EOL;
                     echo date('Y-m-d H:i:s') . '更新--' . $table . ': 项目id' . $project_id . ':id' . $v['id'] . PHP_EOL;
-                    
+
                     $data = [];
                     $data = [];
                     $json_field = '';
                     $json_field = '';
                     foreach ($map as $ai_key => $field) {
                     foreach ($map as $ai_key => $field) {
@@ -306,8 +306,6 @@ class UpdateSeoTdk extends Command
         }
         }
         $prompt .= '.Please answer in ' . ($lang ?: 'English');
         $prompt .= '.Please answer in ' . ($lang ?: 'English');
 
 
-        echo $prompt . PHP_EOL;
-
         return $prompt;
         return $prompt;
     }
     }
 
 

@@ -13,6 +13,7 @@ use App\Helper\Arr;
 use App\Models\Base;
 use App\Models\Base;
 use Illuminate\Support\Facades\DB;
 use Illuminate\Support\Facades\DB;
 use Illuminate\Support\Facades\Log;
 use Illuminate\Support\Facades\Log;
+use Illuminate\Support\Facades\Redis;
 
 
 class ProjectUpdateTdk extends Base
 class ProjectUpdateTdk extends Base
 {
 {
@@ -30,6 +31,7 @@ class ProjectUpdateTdk extends Base
      * @date 2023/11/9
      * @date 2023/11/9
      */
      */
     public static function add_task($project_id){
     public static function add_task($project_id){
+        Redis::lpush('updateSeoTdk', $project_id);
         $model = new self();
         $model = new self();
         $model->project_id = $project_id;
         $model->project_id = $project_id;
         $model->save();
         $model->save();
@@ -42,6 +44,15 @@ class ProjectUpdateTdk extends Base
      * @date 2023/11/9
      * @date 2023/11/9
      */
      */
     public static function getPendingTask(){
     public static function getPendingTask(){
+       //有其他任务 就取其他任务   没有其他任务运行未结束的任务
+       $project_id = Redis::rpop('updateSeoTdk');
+       $data = [];
+       if($project_id){
+           $data = self::find($project_id);
+       }
+       if($data){
+           return $data;
+       }
        return self::where('status', self::STATUS_PENDING)->orderBy('id', 'asc')->first();
        return self::where('status', self::STATUS_PENDING)->orderBy('id', 'asc')->first();
     }
     }