震坤行

server/app/Services/ZhenKhService.php

@@ -216,12 +216,13 @@ class ZhenKhService
         try {
             $result = $this->rhawnService->updateZhenkhGoods($goods);
             if(!is_null($result)){
+                $this->consumerUpdateReportPriceAndStock(['goods' => $result]);
                 //更新商品的价格和库存
-                SimpleKafka::produerSend([
+                /*SimpleKafka::produerSend([
                     'params' => ['goods' => $result],
                     'consumer' => __CLASS__,
                     'method' => 'consumerUpdateReportPriceAndStock'
-                ],'zkh');
+                ],'zkh');*/
             }
 
         } catch (\Throwable $exception) {