修改同步订单脚本计算成本方式

app/Console/Commands/CleaningData.php

@@ -0,0 +1,88 @@
+<?php namespace App\Console\Commands;
+
+use Illuminate\Console\Command;
+use DB;
+use App\Order;
+use App\GoodsSkus;
+use App\OrderGoodsSkus;
+
+class CleaningData extends Command {
+    protected $signature = 'CleaningData';
+
+    /**
+     * 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)->where('is_del', 0)->orderBy('id', 'desc')->get();
+        $orders = json_decode(json_encode($orders), true);
+        foreach($orders as $k=>$order){
+            $result = $this->getMjOrder($order['id'], $order['outerCode']);
+//           print_r($result);die;
+            if( !empty($result) ){
+                $data = array();
+                if( isset($result['expressCode']) && !empty($result['expressCode']) ){
+                    $data['is_cannot_del'] = 1;
+                }
+                $status = $result['status'];
+                if($status == '已发货' || $status == '已完成'){
+                    $data['status'] = 3;
+                    $data['logistics_id'] = $result['expressCode'];
+                    $data['send_time'] = !empty($result['deliveryTime']) ? date('Y-m-d', substr($result['deliveryTime'], 0, 10) ) : 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::select('referenceCost', 'is_weigh')->where('id', $sku_id)->first(); //获取规格成本/是否称重
+                        $quantity = $cost->is_weigh == 1 ? $sku['quantity']/2 : $sku['quantity']; //对应规格数量
+                        if(isset($sku['cost'])) {
+                            $data['cost'] += $sku['cost']; //对应规格总成本
+                        } else {
+                            echo $order['id'].' ';
+                            $data['cost'] += $cost->referenceCost * $quantity; //对应规格总成本
+                        }
+//                        $data['cost'] += $cost->referenceCost * $quantity; //对应规格总成本
+                        #更新order_sku
+                        OrderGoodsSkus::where('order_id', $order['id'])->where('sku_id', $sku_id)->update(['send_num'=>$quantity]);
+                    }
+                }
+
+                if(!empty($data)){
+                    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'];
+    }
+
+}

app/Console/Commands/SyncMjOrderStatus.php

@@ -28,8 +28,7 @@ class SyncMjOrderStatus extends Command {
         $orders = json_decode(json_encode($orders), true);
         foreach($orders as $k=>$order){
             $result = $this->getMjOrder($order['id'], $order['outerCode']);
-//           print_r($result);die;
-            if( !empty($result) ){             
+            if( !empty($result) ){
                 $data = array();
                 if( isset($result['expressCode']) && !empty($result['expressCode']) ){
                     $data['is_cannot_del'] = 1;
@@ -48,7 +47,7 @@ class SyncMjOrderStatus extends Command {
                         $sku_id = $code_arr[1];
                         $cost = GoodsSkus::select('referenceCost', 'is_weigh')->where('id', $sku_id)->first(); //获取规格成本/是否称重
                         $quantity = $cost->is_weigh == 1 ? $sku['quantity']/2 : $sku['quantity']; //对应规格数量
-                        $data['cost'] += $sku['cost']; //对应规格总成本
+                        $data['cost'] += $sku['cost']*$sku['quantity']; //对应规格总成本
 //                        $data['cost'] += $cost->referenceCost * $quantity; //对应规格总成本
                         #更新order_sku
                         OrderGoodsSkus::where('order_id', $order['id'])->where('sku_id', $sku_id)->update(['send_num'=>$quantity]);

app/Console/Kernel.php

@@ -48,6 +48,7 @@ class Kernel extends ConsoleKernel {
         'App\Console\Commands\DayGrandSalerTotal',
         'App\Console\Commands\freightCost',
         'App\Console\Commands\CustomerOrder',
+        'App\Console\Commands\CleaningData',
     ];
 
 	/**