震坤行

server/app/Services/RhawnChemicalsService.php

@@ -101,10 +101,10 @@ class RhawnChemicalsService
         }
     }
 
-    public function updateSyncRunTime($goods)
+    public function updateSyncRunTime($zgId)
     {
         $dbConnect = DB::connection('rhawn_mysql');
-        return $dbConnect->table('zkh_goods')->where('zg_id',$goods['zg_id'])->update(['zg_sync_time' => time()]);
+        return $dbConnect->table('zkh_goods')->where('zg_id',$zgId)->update(['zg_sync_time' => time()]);
     }
 
     public function getRawProductsThroughPid($pId)

server/app/Services/ZhenKhService.php

@@ -56,13 +56,13 @@ class ZhenKhService
         $goods = $params['goods'];
 
         try{
-            $product = $this->rhawnService->getRawProductsThroughPid($goods['zg_r_pid']);
+            $product = $this->rhawnService->getRawProductsThroughPid($goods->zg_r_pid);
             if($product){
                 while(true){
                     $result = $this->apiService->updateReportProductPrice([
                         'price' => round(bcmul($product->p_price,0.5,2),1),
-                        'price_unit' => $goods['zg_unit'],
-                        'sku' => $goods['zg_sku']
+                        'price_unit' => $goods->zg_unit,
+                        'sku' => $goods->zg_sku
                     ],$this->getToken());
                     if(!isset($result['reset']) || $result['reset'] != true){
                        break;
@@ -75,9 +75,9 @@ class ZhenKhService
                 while(true){
                     $result = $this->apiService->updateReportProductStock([
                         'warehouse' => '上海货仓',
-                        'address' => ['0' => $goods['zg_addr']],
+                        'address' => ['0' => $goods->zg_addr],
                         'qty' => $product->p_stock,
-                        'sku' => $goods['zg_sku']
+                        'sku' => $goods->zg_sku
                     ],$this->getToken());
                     if(!isset($result['reset']) || $result['reset'] != true){
                         break;
@@ -87,7 +87,7 @@ class ZhenKhService
                     }
                 }
             }
-            $result = $this->rhawnService->updateSyncRunTime($goods);
+            $result = $this->rhawnService->updateSyncRunTime($goods->zg_id);
             if($result){
                 SimpleLogs::writeLog($goods['zg_sku'].'的价格和库存上报完成。完成时间：'.date('Y-m-d H:i:s',time()),__CLASS__.':consumerUpdateReportPriceAndStock');
             }