update:Set

daemon/Goods.php

@@ -6,9 +6,10 @@ namespace Daemon;
 
 use Api\PhpServices\Daemon\DaemonServiceInterface;
 use App\Models\goods\mysql\GoodsSku;
+use App\Services\goods\GoodsService;
 use Api\PhpUtils\Log\DaemonLog;
 class Goods implements DaemonServiceInterface
-{
+
     public function run()
     {
         sleep(2);
@@ -26,6 +27,9 @@ class Goods implements DaemonServiceInterface
                 'online_status' => 2,
             ];  
             GoodsSku::save($colums, $where);
+            //更新es
+            GoodsService::updateGoodsInfoToEs($where['goods_sku_id']);
+
         }
     }
 
@@ -45,6 +49,8 @@ class Goods implements DaemonServiceInterface
                 'online_status' => 2,
             ];  
             GoodsSku::save($colums, $where);
+            //更新es
+            GoodsService::updateGoodsInfoToEs($where['goods_sku_id']);
         }
     }
 }
\ No newline at end of file