seafood/app/Console/Commands/SyncMjWareho...

<?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;
    }

}