openapi 震坤行

server/app/Services/ZhenKhService.php

@@ -83,7 +83,6 @@ class ZhenKhService
                     }
                 }
             }
-
             $this->rhawnService->updateSyncRunTime($goods);
 
         }catch (\Throwable $exception) {
@@ -119,7 +118,7 @@ class ZhenKhService
                         'consumer' => __CLASS__,
                         'method' => 'consumerBatchUpdateGoodsList'
                     ];
-                    SimpleKafka::produerSend($sendContent);
+                    SimpleKafka::produerSend($sendContent,'zkh');
                 }
 
                 $page ++;
@@ -213,7 +212,7 @@ class ZhenKhService
                         'params' => ['goods' => $result],
                         'consumer' => __CLASS__,
                         'method' => 'consumerUpdateReportPriceAndStock'
-                    ]);
+                    ],'zkh');
                 }
 
             } catch (\Throwable $exception) {