分销商上线

app/Console/Commands/SyncGoods.php

@@ -41,7 +41,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(env('DB_DATABASE').'.goods')->where('productCode',$goods['productCode'])->first();
             if($info){
                 //有商品信息则更新店铺商品信息
                 //卖家云必要参数拼接转化
@@ -60,7 +60,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(env('DB_DATABASE').'.goods_skus')->where('code',$sku['code'])->first();
                     if(!$skuInfo){
                         //增加shop sku
                         $shopArr = array();
@@ -79,7 +79,7 @@ class SyncGoods extends Command {
                         }
                         //更新商品信息以及添加库存
                         $sku['goodsCode'] = $info->id;
-                        $skus_ad = DB::table('seafood_fx.goods_skus')->insert($sku);
+                        $skus_ad = DB::table(env('DB_DATABASE').'.goods_skus')->insert($sku);
                     } else {
                         # eshop sku更新
                         $shopArr = array();
@@ -98,12 +98,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(env('DB_DATABASE').'.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(env('DB_DATABASE').'.goods')->where('productCode',$productCode)->update($goods);
                 }
 
             } else {
@@ -138,11 +138,11 @@ class SyncGoods extends Command {
                 }
                 //数据表中插入商品信息以及规格信息
                 unset($goods['id']);
-                $goods_id = DB::table('seafood_fx.goods')->insertGetId($goods);
+                $goods_id = DB::table(env('DB_DATABASE').'.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(env('DB_DATABASE').'.goods_skus')->insert($skus);
                     }
 
                 }

app/Console/Commands/SyncMjWarehouse.php

@@ -75,8 +75,8 @@ class SyncMjWarehouse extends Command {
 //                    $up['realPrice'] = 0;
 //                    $up['outPrice'] = 0;
                 }
-                if(!$cost->outPrice){
-                    if(isset($up['realPrice'])){
+                if($cost->outPrice == 0){
+                    if($up['realPrice'] != 0){
                         $up['outPrice'] = ceil($up['realPrice']*1.15);
                     }
                 }