seafood/app/Console/Commands/SyncMjOrderS...

<?php 
namespace App\Console\Commands;

use Illuminate\Console\Command;
use DB;
use App\Order;
use App\GoodsSkus;
use App\OrderGoodsSkus;
class SyncMjOrderStatus extends Command {

    protected $signature = 'SyncMjOrderStatus';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = '同步订单状态';


    public function handle()
    {
        $this->SyncMjOrderStatus();
    }
    public function SyncMjOrderStatus(){

        $orders = Order::select('id', 'outerCode')->where('orderCode','>',0)->where('status', '<', 3)->where('warehouse', 3)->orderBy('id', 'desc')->get();
        $orders = json_decode(json_encode($orders), true);
        foreach($orders as $k=>$order){
            $result = $this->getMjOrder($order['id'], $order['outerCode']);
           
            if( !empty($result) ){
                $data = array();
                $status = $result['status'];
                if($status == '已发货' || $status == '已完成'){
                    $data['status'] = 3;
                    $data['logistics_id'] = $result['expressCode'];
                    $data['send_time'] = date('Y-m-d');
                    $data['cost'] = 0;
                    #计算成本
                    //if($sku_info->referenceCost) $cost += $sku_info->referenceCost * $gnum[$k];
                    foreach($result['skuList'] as $key=>$sku){
                        $skuCode = $sku['skuCode'];
                        $code_arr = explode('|', $skuCode);
                        $sku_id = $code_arr[1];
                        $cost = GoodsSkus::where('id', $sku_id)->pluck('referenceCost'); //获取规格成本
                        $quantity = $sku['quantity']; //对应规格数量
                        $data['cost'] += $cost * $quantity; //对应规格总成本
                        #更新order_sku
                        OrderGoodsSkus::where('order_id', $order['id'])->where('sku_id', $sku_id)->update(['send_num'=>$quantity]);
                    }
                    Order::where('id', $order['id'])->update($data);
                }elseif($status == '已取消'){
                    $data['is_del'] = 1;
                    Order::where('id', $order['id'])->update($data);
                }
            }

        }

    }

    /**
     * 获取订单信息，可用来判断订单是否存在，同步订单状态
     */
    public function getMjOrder($id, $outerCode=''){
        $order = array();
        $order['eshopCode'] = config('constants.ESHOP_CODE');
        if(!$outerCode){
            $outerCode = Order::where('id', $id)->pluck('outerCode');
        }
        $order['outerCode'] = $outerCode;
        $mjOrder = Order::mjOrderGet($order);
        if(!isset($mjOrder['order']['code'])){
            return false;
        }
        return $mjOrder['order'];
    }

}