zkh工具类

server/app/Console/Commands/ZhenkhJobCommand.php

@@ -82,6 +82,9 @@ class ZhenkhJobCommand extends Command
                 case 'hMUpdateOrdersList' :
                     $service->hMUpdateOrdersList();
                     break;
+                case 'batchUpdateDeliveryOrder' :
+                    $service->batchUpdateDeliveryOrder();
+                    break;
                 case 'sendMail' :
                     $service->sendMail('订单确认邮件', '订单号:未确认成功');
                 case 'orderConfirm' :

server/app/Services/ThirdPlatform/ZhenKhService.php

@@ -322,6 +322,27 @@ class ZhenKhService
         }
     }
 
+    /**
+     * 批量更新zkh发货单
+     */
+    public function batchUpdateDeliveryOrder($params)
+    {
+        $path = config('filesystems.disks.local.root').'/upload/'.$params;
+        $generator = Helpers::yieldLoadCsv($path);
+
+        // yield 循环逐行读取csv内容
+        while ($generator->valid()) {
+            $content = $generator->current();
+            $this->apiService->pushQueue([
+                'params' => current($content),
+                'consumer' => __CLASS__,
+                'method' => 'sendDeliveryOrder'
+
+            ],'zkh_updateDeliveryOrder');
+            $generator->next();
+        }
+    }
+
     /**
      * @订单发货
      * @param $deliveryCode