同步仓库

app/Console/Commands/SyncMjOrderStatus.php

@@ -13,7 +13,7 @@ class SyncMjOrderStatus extends Command {
      *
      * @var string
      */
-    protected $description = '地域7日roi';
+    protected $description = '同步订单状态';
 
 
     public function handle()

app/Console/Commands/SyncMjWarehouse.php

@@ -0,0 +1,64 @@
+<?php 
+namespace App\Console\Commands;
+
+use Illuminate\Console\Command;
+use DB;
+use App\Order;
+class SyncMjWarehouse extends Command {
+
+    protected $signature = 'SyncMjWarehouse';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = '同步库存';
+
+
+    public function handle()
+    {
+        $this->SyncMjWarehouse();
+    }
+    public function SyncMjWarehouse(){
+        $params = array();
+        $params['eshopCode'] = config('constants.ESHOP_CODE');
+        //$params['warehouseCode'] = config('constants.ESHOP_CODE'); //仓库编码
+        $params['pageIndex'] = '1';
+        $params['pageSize'] = '20';
+        $mjRes = Order::mjWarehouseSkuGet($params);
+
+        if($mjRes == false){
+            exit('获取卖家云数据出错');
+        }
+
+        //插入第一页：
+        $this->insertData( $mjRes['resultSet']['skuList'] );
+
+        $count = $mjRes['resultSet']['totalNum'];
+        $pages = ceil($count / 20);
+
+        //插入其他页面
+        for($i=2; $i<=$pages; $i++){
+            $params['pageIndex'] = $i;
+            $mjRes = Order::mjWarehouseSkuGet($params);
+            $this->insertData( $mjRes['resultSet']['skuList'] );
+        }
+
+    }
+
+    /**
+     * 获取订单信息，可用来判断订单是否存在，同步订单状态
+     */
+    public function insertData($data){
+        foreach($data as $k=>$sku){
+            $code = $sku['skuProductCode'];
+            $up = array();
+            $up['quantity'] = $sku['quantity'];
+            $up_re = DB::table('goods_skus')->where('code', $code)->update($up);
+        }
+
+        return true;
+    }
+
+}

app/Console/Kernel.php

@@ -24,6 +24,7 @@ class Kernel extends ConsoleKernel {
         'App\Console\Commands\DisRoiByDay30',
         'App\Console\Commands\SyncAdCost',
         'App\Console\Commands\SyncMjOrderStatus',
+        'App\Console\Commands\SyncMjWarehouse',
         
     ];
 

app/Order.php

@@ -138,6 +138,15 @@ class Order extends Model
       return $result;
     }
 
+    /**
+     * 获取 sku 库存
+     */
+    public static function mjWarehouseSkuGet($sku){
+      $sku["method"] = "maijiayun.warehouse.sku.list"; 
+      $result = self::mjApi($sku);
+      return $result;
+    }
+
    	public static function mjApi($params = array()){  		
    		$accessKey = "B1E69297B5DA44DAB35099A5F28F41D9"; //erp 生成的 accessKey
 		  $accessSecret = "4sN2LbylhOglelMP";