openapi 震坤行

server/app/Jobs/ZhenkhJob.php

@@ -51,6 +51,9 @@ class ZhenkhJob extends Job
             case 'createJwtToken' :
                 $service->createJwtToken();
                 break;
+            case 'hMUpdateOrdersList' :
+                $service->hMUpdateOrdersList();
+                break;
             default:
         }
     }

server/app/Services/ZhenKhService.php

@@ -256,6 +256,64 @@ class ZhenKhService
         }
     }
 
+    /**
+     * 手动执行订单更新
+     * @throws \Throwable
+     */
+    public function hMUpdateOrdersList()
+    {
+        try{
+            $page = 1;
+            $sendContent = [];
+            $postParams = [
+                'start_time' => date('Y-m-d H:i:s',(time() - 86400)),
+                'end_time' => date('Y-m-d H:i:s',strtotime(date('Y-m-d',time())." 23:59:59")),
+                'page_size' => 0,
+                'page_no' => 0,
+            ];
+            while(true){
+                $pageSize = $this->apiService->getPlatformInfo()['platform_params']['page_size'];
+                $postParams['page_size'] = $pageSize;
+                $postParams['page_no'] = $page;
+                while(true){
+                    $orderList = $this->apiService->getUpdateOrders($postParams,$this->getToken());
+                    if(!isset($orderList['reset']) || $orderList['reset'] != true){
+                        break;
+                    }
+                }
+                if($orderList && count($orderList['list']) > 0){
+                    foreach($orderList['list']['data'] as $order){
+                        if($order['orderStatus'] == 0){
+                            while(true){
+                                $orderDetail = $this->apiService->getUpdateOrdersDetail($order['purchaseOrderId'],$this->getToken());
+                                if(!isset($orderDetail['reset']) || $orderDetail['reset'] != true){
+                                    break;
+                                }
+                            }
+                            if($orderDetail){
+                                $result = $this->rhawnOrderService->updateZhenkhOrders($order,$orderDetail);
+                            }
+                        }
+                    }
+                }
+
+                $page ++;
+                if($page > $orderList['total_page']){
+                    break;
+                }
+            }
+
+        }catch(\Throwable $exception){
+            $this->apiService->throwableAfter([
+                'platform_name' => $this->apiService->getPlatformInfo('platform_name'),
+                'queue_params' => $sendContent,
+                'fail_content' => $exception->getMessage(),
+                'queue_reset' => time() + 86400 * 10
+            ]);
+            throw $exception;
+        }
+    }
+
     /**
      * @订单发货
      * @param $deliveryCode