Procházet zdrojové kódy

风速数据同步

xiaodong před 5 dny
rodič
revize
f2e3b456dd
1 změnil soubory, kde provedl 29 přidání a 11 odebrání
  1. 29 11
      app/admin/command/FengSu.php

+ 29 - 11
app/admin/command/FengSu.php

@@ -153,22 +153,40 @@ class FengSu extends Command
         $endTime = date('Y-m-d H:i:s', $fengsu['endTime']);
         $pageNum=(int)$fengsu['pageNum'];
         
-        $body = [
-            'startTime'    => $startTime,//时间区间
-            'endTime'    => $endTime,
-            'sort'         => 'CONSIGN_TIME',
-            'sortAsc'      => false,
-            'current'      => $pageNum,//页数
-            'size'         => 50,//每页多少条
-            'tradeStatus'  => 2,
-            'fromAccountId' => [],
-            'goodType'     => 2,
-            'goodsFlag'    => 2
+        // $body = [
+        //     'startTime'    => $startTime,//时间区间
+        //     'endTime'    => $endTime,
+        //     'sort'         => 'CONSIGN_TIME',
+        //     'sortAsc'      => false,
+        //     'current'      => $pageNum,//页数
+        //     'size'         => 50,//每页多少条
+        //     'tradeStatus'  => 4,
+        //     'fromAccountId' => [],
+        //     'goodType'     => 2,
+        //     'goodsFlag'    => 2
+        // ];
+        $body=[
+            "goodType"=> 2,
+            "current"=> $pageNum,
+            "size"=>50,
+            "sort"=> "CONSIGN_TIME",
+            "sortAsc"=> false,
+            "tradeStatus"=> 4,
+            "timeType"=>2,
+            "skuOuterIdExact"=> false,
+            "skuPropExact"=> false,
+            "startTime"=>$startTime,
+            "endTime"=> $endTime,
+            "goodsFlag"=> 1,
+            "tradeSources"=> [],
+            "prepareShip"=>0
         ];
             // 'waybillNos'   => ['73589756512463']
         $body = json_encode($body);
         
         $request = new Request('POST', 'https://fsdy2.fengsutb.com/amount/ship-list-new', $headers, $body);
+        // $request = new Request('POST', 'https://fsdy2.fengsutb.com/trade/print-list', $headers, $body);
+        
         $res = $client->sendAsync($request)->wait();
         $json = [];
         if ($res->getStatusCode() == 200) {