wesmiler

app/Console/Commands/SwooleTask.php

@@ -313,23 +313,25 @@ class SwooleTask extends Command
             }
             $time++;
             $cateIds = GoodsCategoryService::make()->getCateIds();
-            foreach($cateIds as $pid){
-                if(!RedisService::get("caches:task:lock:goods_category_sub_loaded_{$pid}")){
-                    $taskData = [
-                        'taskName' => 'UpdateGoodsCategorySub',
-                        'name' => "更新商品分类【{$pid}】的子分类数据",
-                        'pid'=> $pid,
-                        'date' => date('Y-m-d'),
-                    ];
-                    $res = $serv->task($taskData);
-                    RedisService::set("caches:task:lock:goods_category_sub_loaded_{$pid}", true, rand(3,5));
-                    echo "[Task UpdateGoodsCategorySub {$date}] 更新商品分类【{$pid}】的子分类数据：{$res}\n";
-                }else{
-                    echo "[Task UpdateGoodsCategorySub {$date}] 间隔时间调用\n";
+            if($cateIds){
+                foreach($cateIds as $pid){
+                    if(!RedisService::get("caches:task:lock:goods_category_sub_loaded_{$pid}")){
+                        $taskData = [
+                            'taskName' => 'UpdateGoodsCategorySub',
+                            'name' => "更新商品分类【{$pid}】的子分类数据",
+                            'pid'=> $pid,
+                            'date' => date('Y-m-d'),
+                        ];
+                        $res = $serv->task($taskData);
+                        RedisService::set("caches:task:lock:goods_category_sub_loaded_{$pid}", true, rand(3,5));
+                        echo "[Task UpdateGoodsCategorySub {$date}] 更新商品分类【{$pid}】的子分类数据：{$res}\n";
+                    }else{
+                        echo "[Task UpdateGoodsCategorySub {$date}] 间隔时间调用\n";
+                    }
                 }
+            }else{
+                echo "[Task UpdateGoodsCategorySub {$date}] 没有父级数据\n";
             }
-
-
         });
 
         // TODO 更新商品SKU数据