分销商

app/Console/Commands/SyncGoods.php

@@ -40,7 +40,7 @@ class SyncGoods extends Command {
     public function handleGoodsList($list) {
         foreach($list as $key=>$goods){
             //查询现在商品表中是否有该商品
-            $info = DB::table('seafood_fx.goods')->where('productCode',$goods['productCode'])->first();
+            $info = DB::table('seafood_te.goods')->where('productCode',$goods['productCode'])->first();
             if($info){
                 //有商品信息则更新店铺商品信息
                 //卖家云必要参数拼接转化
@@ -59,7 +59,7 @@ class SyncGoods extends Command {
                 $result = json_decode(json_encode($result),true);
                 foreach ($result as $sku){
                     //查询规格信息
-                    $skuInfo = DB::table('seafood_fx.goods_skus')->where('code',$sku['code'])->first();
+                    $skuInfo = DB::table('seafood_te.goods_skus')->where('code',$sku['code'])->first();
                     if(!$skuInfo){
                         //增加shop sku
                         $shopArr = array();
@@ -78,7 +78,7 @@ class SyncGoods extends Command {
                         }
                         //更新商品信息以及添加库存
                         $sku['goodsCode'] = $info->id;
-                        $skus_ad = DB::table('seafood_fx.goods_skus')->insert($sku);
+                        $skus_ad = DB::table('seafood_te.goods_skus')->insert($sku);
                     } else {
                         # eshop sku更新
                         $shopArr = array();
@@ -97,12 +97,12 @@ class SyncGoods extends Command {
                         unset($sku['id']);
                         unset($sku['code']);
                         unset($sku['goodsCode']);
-                        $sku_update = DB::table('seafood_fx.goods_skus')->where('code',$code)->update($sku);
+                        $sku_update = DB::table('seafood_te.goods_skus')->where('code',$code)->update($sku);
                     }
                     $productCode = $info->productCode;
                     unset($goods['id']);
                     unset($goods['productCode']);
-                    $goods_up = DB::table('seafood_fx.goods')->where('productCode',$productCode)->update($goods);
+                    $goods_up = DB::table('seafood_te.goods')->where('productCode',$productCode)->update($goods);
                 }
 
             } else {
@@ -136,11 +136,11 @@ class SyncGoods extends Command {
                 }
                 //数据表中插入商品信息以及规格信息
                 unset($goods['id']);
-                $goods_id = DB::table('seafood_fx.goods')->insertGetId($goods);
+                $goods_id = DB::table('seafood_te.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);
+                        $sku_ad = DB::table('seafood_te.goods_skus')->insert($skus);
                     }
 
                 }