分销商

app/Console/Commands/SyncGoods.php

@@ -1,5 +1,6 @@
 <?php namespace App\Console\Commands;
 
+use App\Log;
 use App\Order;
 use Illuminate\Console\Command;
 use Illuminate\Support\Facades\DB;
@@ -32,32 +33,31 @@ class SyncGoods extends Command {
     }
 
     public function handleGoodsList($list) {
-        foreach($list as $goods){
+        foreach($list as $key=>$goods){
             //查询现在商品表中是否有该商品
-            $info = DB::table('seafood_fx.goods')->where('id',$goods['id'])->first();
+            $info = DB::table('seafood_fx.goods')->where('productCode',$goods['productCode'])->first();
             if($info){
                 //有商品信息则更新店铺商品信息
                 //卖家云必要参数拼接转化
                 $mjArr = array();
                 $mjArr['eshopCode'] = config('constants.ESHOP_CODE');
-                $mjArr['outerCode'] = $goods['id'];
+                $mjArr['outerCode'] = config('constants.GOODS_PREFIX').$goods['id'];
                 $mjArr['name'] = $goods['name'];
                 $mjArr['description'] = $goods['description'];
                 $mj = Order::mjGoodsUpdate($mjArr);
                 if($mj == false){
-                    echo 'goods_id:'.$goods['id']."\r\n";
-                    return false;
+                    Log::errorLog(json_encode($mjArr),[],"order/syncGoods",0,'');
                 }
                 //查询规格信息，更新规格信息
-                $result = DB::table('seafood.goods_skus')->where('goodsCode', $goods['id'])->orderBy('id', 'desc')->get();
+                $result = DB::table('seafood.goods_skus')->where('goodsCode', $goods['id'])->get();
                 $result = json_decode(json_encode($result),true);
                 foreach ($result as $sku){
                     //查询规格信息
-                    $skuInfo = DB::table('seafood_fx.goods_skus')->where('id',$sku['id'])->first();
+                    $skuInfo = DB::table('seafood_fx.goods_skus')->where('code',$sku['code'])->first();
                     if($skuInfo){
                         //增加shop sku
                         $shopArr = array();
-                        $shopArr['outerCode'] = $sku['id'];
+                        $shopArr['outerCode'] = config('constants.GOODS_PREFIX').$sku['id'];
                         $shopArr['eshopCode'] = config('constants.ESHOP_CODE');
                         $shopArr['goodsCode'] = $sku['goodsCode'];
                         $shopArr['propsName'] = $sku['propsName'];
@@ -67,39 +67,43 @@ class SyncGoods extends Command {
                         $shopArr['modifyTime'] = $sku['createTime'];
                         $sku_add = Order::mjSkuAdd($shopArr);
                         if($sku_add == false){
-                            echo 'sku_id:'.$sku['id']."\r\n";
-                            return false;
+                            Log::errorLog(json_encode($shopArr),[],"order/syncGoods",0,'');
                         }
                         //更新商品信息以及添加库存
-                        $goods_id = $goods['id'];
-                        unlink($goods['id']);
-                        $goods_up = DB::table('seafood_fx.goods')->where('id',$goods_id)->update($goods);
+                        $productCode = $goods['productCode'];
+                        unset($goods['productCode']);
+                        unset($goods['id']);
+                        $goods_up = DB::table('seafood_fx.goods')->where('productCode',$productCode)->update($goods);
+                        $sku['goodsCode'] = $skuInfo->id;
                         $skus_ad = DB::table('seafood_fx.goods_skus')->insert($sku);
                     } else {
                         # eshop sku更新
                         $shopArr = array();
                         $shopArr['eshopCode'] = config('constants.ESHOP_CODE');
                         $shopArr['goodsCode'] = $sku['goodsCode'];
-                        $shopArr['outerCode'] = $sku['id'];
+                        $shopArr['outerCode'] = config('constants.GOODS_PREFIX').$sku['id'];
                         $shopArr['propsName'] = $sku['propsName'];
                         $shopArr['price'] = $sku['price'];
                         $sku_up = Order::mjSkuUpdate($shopArr);
                         if($sku_up == false){
-                            echo 'sku_id:'.$sku['id']."\r\n";
-                            return false;
+                            Log::errorLog(json_encode($shopArr),[],"order/syncGoods",0,'');
                         }
-                        $goods_id = $goods['id'];
-                        unlink($goods['id']);
-                        $goods_up = DB::table('seafood_fx.goods')->where('id',$goods_id)->update($goods);
-                        $sku_id = $sku['id'];
-                        unlink($sku['id']);
-                        $sku_update = DB::table('seafood_fx.goods_skus')->where('id',$sku_id)->update($sku);
+
+                        $productCode = $goods['productCode'];
+                        unset($goods['id']);
+                        unset($goods['productCode']);
+                        $goods_up = DB::table('seafood_fx.goods')->where('productCode',$productCode)->update($goods);
+
+                        $code = $sku['code'];
+                        unset($sku['id']);
+                        unset($sku['code']);
+                        $sku_update = DB::table('seafood_fx.goods_skus')->where('code',$code)->update($sku);
                     }
                 }
 
             } else {
                 //没有商品，直接同步店铺商品信息以及库存信息
-                $result = DB::table('seafood.goods_skus')->where('goodsCode', $goods['id'])->orderBy('id', 'desc')->get();
+                $result = DB::table('seafood.goods_skus')->where('goodsCode', $goods['id'])->get();
                 $result = json_decode(json_encode($result),true);
                 $mjArr = array();
                 $skuArr = array();
@@ -108,8 +112,7 @@ class SyncGoods extends Command {
                         $skuArr[$k]['propsName'] = $sku['propsName'];
                         $skuArr[$k]['eShopCode'] = config('constants.ESHOP_CODE');
                         $skuArr[$k]['price'] = $sku['price'];
-                        $skuArr[$k]['outerCode'] = $sku['id'];
-                        $skuArr[$k]['skuProductCode'] = $sku['code'];
+                        $skuArr[$k]['outerCode'] = config('constants.GOODS_PREFIX').$sku['id'];
                         $skuArr[$k]['createTime'] = $sku['createTime'];
                         $skuArr[$k]['modifyTime'] = $sku['modifyTime'];
                     }
@@ -120,20 +123,25 @@ class SyncGoods extends Command {
                 $mjArr['productCode'] = $goods['productCode'];
                 $mjArr['goodsCategoryName'] = $goods['goodsCategoryName'];
                 $mjArr['picUrl'] = $goods['picUrl'];
-                $mjArr['outerCode'] = $goods['id'];
+                $mjArr['outerCode'] = config('constants.GOODS_PREFIX').$goods['id'];
                 $mjArr['skuList'] = $skuArr;
                 $mj = Order::mjGoodsAdd($mjArr);
                 if($mj == false){
-                    echo 'goods_id:'.$goods['id']."\r\n";
-                    return false;
+                    Log::errorLog(json_encode($mjArr),[],"order/syncGoods",0,'');
                 }
                 //数据表中插入商品信息以及规格信息
-                $goods_ad = DB::table('seafood_fx.goods')->insert($goods);
-                if(count($result)>0){
-                    $sku_ad = DB::table('seafood_fx.goods_skus')->insert($result);
+                unset($goods['id']);
+                $goods_id = DB::table('seafood_fx.goods')->insertGetId($goods);
+                if($goods_id > 0 && count($result)>0 ){
+                    foreach ($result as $skus){
+                        $skus['goodsCode'] = $goods_id;
+                        $sku_ad = DB::table('seafood_fx.goods_skus')->insert($skus);
+                    }
+
                 }
             }
         }
+        echo 'SUCCESS';die;
     }
 
 }

config/constants.php

@@ -6,7 +6,7 @@ return [
     'REDIS_PORT'=>'6379',
     'REDIS_PASSWORD'=>'Zhuaduoduo2017',
 
-//    'ESHOP_CODE' => '100|100|mrhx', //卖家云店铺code
+//    'ESHOP_CODE' => '100|csxd', //卖家云店铺code
 //    'ESHOP_CODE' => '100|hxas', //卖家云店铺code
     'ESHOP_CODE' => '100|xyxd', //卖家云店铺code
     'WAREHOUSE_CODE' => '28416',//卖家云仓库编码
@@ -14,4 +14,5 @@ return [
     'SKU_QUANTITY_TABLE' => 'seafood.sku_wmj_quantity',
 
     'ORDER_PREFIX' => '',//订单编号前缀
+    'GOODS_PREFIX' => 'f',//商品规格前缀
 ];