seafood/app/Http/Controllers/Admin/GoodsControl...

<?php
/**
 * Created by Sublime.
 * User: hao
 * Date: 19/08/30
 * Time: 上午11:20
 */
namespace App\Http\Controllers\Admin;

use App\Http\Controllers\Controller;
use App\Log;
use App\Goods;
use App\GoodsSkus;
use App\Order;
use App\Oplog;
use App\Services\OssServices as oss;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;

use PHPExcel_Reader_Excel2007;
use PHPExcel_Reader_Excel5;
use PHPExcel_Reader_CSV;

class GoodsController extends Controller
{
    protected $warehouse = [];

    public function __construct()
    {
        $this->warehouse = config('constants.WAREHOUSE');
        $is_fx = env('IS_FX');
        if($is_fx > 0) {
            unset($this->warehouse[1]);
            unset($this->warehouse[2]);
        }
    }

	public function index(Request $request){
        $page = (int)$request->input('page');
        $pageSize = 20;
        if($page<=0){
            $page = 1;
        }

        $offset = ($page-1) * $pageSize;
        $stime = $request->input('stime');
        $etime = $request->input('etime');
        $name = $request->input('name');
        $cate_name = trim($request->input('cate_name'));

        $count = Goods::where(function($query) use($name, $stime, $etime, $cate_name){
            if($name) $query->where('name', 'like', '%'.$name.'%');
            if($cate_name) $query->where('goodsCategoryName', '=', $cate_name);
            if($stime) $query->where('createTime', '>=', $stime);
            if($etime) $query->where('createTime', '<=', $etime);
        })->where('is_del', '<', 2)->count();
        if ($count > 1) {
            // 总页数
            $pages = ceil($count/$pageSize);
        }else{
            // 总页数
            $pages = 1;
        }

        $result = Goods::where(function($query) use($name, $stime, $etime, $cate_name){
            if($name) $query->where('name', 'like', '%'.$name.'%');
            if($cate_name) $query->where('goodsCategoryName', '=', $cate_name);
            if($stime) $query->where('createTime', '>=', $stime);
            if($etime) $query->where('createTime', '<=', $etime);
        })->where('is_del', '<', 2)->orderBy('id', 'desc')->offset($offset)->limit($pageSize)->get();
        $result = json_decode(json_encode($result),true);

        foreach($result as $k=>&$v){
            # 获取sku
            $skuList = GoodsSkus::where('goodsCode', $v['id'])->where('is_del', 0)->get();
            foreach($skuList as $k=>&$item){
                $quantity = GoodsSkus::actualQuantityByRedis($item->id);
                $item->quantity = $quantity['quantity'];
                $item->w_num = $quantity['w_num'];
            }
            $v['sku_list'] = $skuList;            
        }

        //获取分类
        $cates = DB::table('categorys')->lists('name', 'id');
        return view('goods/index', ['result' =>$result,
            'page'              =>$page,
            'count'             =>$count,
            'pages'             =>$pages,          
            'stime'             =>$stime,
            'etime'             =>$etime,
            'name'              =>$name,
            'cate_name'         =>$cate_name,
            'cates'             =>$cates,
            ]);
    }

    /**
     * 添加商品
     * @return \Illuminate\View\View
     */
    public function create(Request $request)
    {
        //获取分类
        $cates = DB::table('categorys')->lists('name', 'id');
        return view('goods/create', ['cates'=>$cates]);
    }
    /**
     * 分组管理-进行添加操作
     * @param Request $request
     * @return \Illuminate\Http\RedirectResponse
     */
    public function store(Request $request)
    {
        $cateVali = '';
        $goodsCategoryName = trim($request->input('goodsCategoryName'));
        $goodsCategoryName2 = trim($request->input('goodsCategoryName2'));
        if( empty($goodsCategoryName) && empty($goodsCategoryName2) ){
            $cateVali = 'required';
        }

        $this->validate($request, [  
            'name'           => 'required|unique:goods',   
            'productCode'           => 'required|unique:goods,productCode,1,is_del',     
            'sku'           => 'required',     
            'goodsCategoryName2'           => $cateVali,     
        ], [                                                              
            'name.required'           => '商品名不能为空',
            'name.unique'           => '该商品已存在',
            'productCode.required'           => '商品货号不能为空',          
            'productCode.unique'           => '该商品货号已经存在',          
            'sku.required'    => '必须添加商品规格',    
            'goodsCategoryName2.required' => '商品分类必填',     
        ]);

        //数据库-新增数据
        $goods = array();       
        $goods['name'] = trim($request->input('name')); 
        $goods['description'] = trim($request->input('description'));  //非必填
        $goods['eshopCode'] = config('constants.ESHOP_CODE'); 
        $goods['productCode'] = trim($request->input('productCode')); 

        DB::beginTransaction();
        try{
            if( !empty($goodsCategoryName2) ){
                //增加分类
                $cates = array();
                $cates['name'] = $goodsCategoryName2;
                DB::table('categorys')->insert($cates);
                $goodsCategoryName = $goodsCategoryName2;
            }
            $goods['goodsCategoryName'] = $goodsCategoryName; 

            //图片上传 阿里云oss       
            if ($request->hasFile('img') && $request->file('img')->isValid()) {
                $file = $request->file('img');
                $ossClient=new oss();
                // 上传阿里云
                $file = $ossClient->upload($file->getClientOriginalExtension(), $file->getRealPath(), 'upload/seafoodPic'.date("Y-m-d",time()).'/'.date('His'));
                $img=$file['oss-request-url'];
                $goods['picUrl']=str_replace("kx-youhuiquan.oss-cn-beijing.aliyuncs.com","imgs.726p.com",$img);
            }
            if( !isset($goods['picUrl']) ) $goods['picUrl'] = 'http://imgs.726p.com/tbk/upload/seafoodPic2019-10-14/151513/kx-5da4208175314.jpg'; 
            
            $res = DB::table('goods')->insertGetId($goods);

            if($res){
                //卖家云必要参数拼接转化
                $mjArr = $goods;
                $mjArr['outerCode'] = $res;

                //sku
                $sku = $request->input('sku');
                if(!empty($sku)){
                    foreach($sku as $key=>$item){
                        $sku_data = explode('@@', $item);  
                        if(!$sku_data[2]) $sku_data[2] = null;                      
                        if(!$sku_data[3]) $sku_data[3] = null;
                        if(!$sku_data[4]) $sku_data[4] = null;
                        $sku_insert_data = $mjArr['skuList'][$key] = ['propsName'=>$sku_data[0], 'price'=>$sku_data[1], 'tagPrice'=>$sku_data[2], 'referenceCost'=>$sku_data[3], 'is_weigh'=>$sku_data[5], 'outPrice'=>$sku_data[4], 'createTime'=>date('Y-m-d H:i:s'), 'modifyTime'=>date('Y-m-d H:i:s')];
                        $skuProductCode = $goods['productCode'].'-0'.($key+1);
                        $sku_insert_data['code'] = $mjArr['skuList'][$key]['skuProductCode'] = $skuProductCode;
                        $sku_insert_data['goodsCode'] = $res;
                        $sku_insert_data['eshopCode'] = config('constants.ESHOP_CODE');

                        $sku_ids = DB::table('goods_skus')->insertGetId($sku_insert_data);
                        $mjArr['skuList'][$key]['outerCode'] = $sku_ids;
                    }
                }

                //对接卖家云
                //1.erp添加
                $erpArr = array();
                $erpArr['goodsCode'] = $goods['productCode']; //商品货号
                $erpArr['goodsName'] = $goods['name'];
                $erpArr['goodsCategoryName'] = $goods['goodsCategoryName'];
                $erpArr['picUrl'] = $goods['picUrl'];
                foreach($mjArr['skuList'] as $k=>&$v){
                    $erpArr['code'] = $v['skuProductCode'];                   
                    $is_weigh = $v['is_weigh'];
                    $erpArr['propsName'] = $is_weigh==1 ? $v['propsName'].'【按半斤称重】' : $v['propsName'];
                    $erpArr['price'] = $v['price'] = $is_weigh==1 ? round( $v['price']/2, 2 ) : $v['price'];
                    $erpArr['tagPrice'] = $is_weigh==1 ? round( $v['tagPrice']/2, 2 ) : $v['tagPrice'];
                    $erpArr['referenceCost'] = $is_weigh==1 ? round( $v['referenceCost']/2, 2 ) : $v['referenceCost']; 

                    $erp = Order::mjErpGoodsAdd($erpArr);
                    if($erp == false){
                        throw new Exception("添加erp商品失败，对接卖家云出错");                                              
                    }
                    unset($mjArr['skuList'][$k]['tagPrice']);
                    unset($mjArr['skuList'][$k]['referenceCost']);
                    unset($mjArr['skuList'][$k]['is_weigh']);
                    unset($mjArr['skuList'][$k]['outPrice']);

                    //更新erp信息到sku
                    $params = array();
                    $params['erpSkuId'] = $erp['skuId'];
                    $params['erpGoodsId'] = $erp['goodsId'];
                    $uperp = DB::table('goods_skus')->where('id', $v['outerCode'])->update($params);
                }
                //2.商品同步
                $mj = Order::mjGoodsAdd($mjArr);
                if($mj == false){
                    throw new Exception("添加店铺商品失败，对接卖家云出错");
                }
                /* 同步卖家云商品code等信息 */
                $mjGood = array();
                $mjGood['code'] = $mj['goods']['code'];
                Goods::where('id', $res)->update($mjGood);
                /* end */
                #记录操作日志
                $self_id = session('admin_id');
                $self_name = session('real_name');
                $context = "新增商品数据";
                $type = 0; 
                $tables = 'goods,goods_skus';
                $data_id = $res;
                Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);
            } 
            DB::commit();

        }catch (Exception $e){
            Log::errorLog($request,['error'=>$e->getMessage()],"goods/store",0,'');
            DB::rollback();
            return redirect('/admin/goods/index')->with('info', $e->getMessage());
        }
        return redirect('/admin/goods/index')->with('info', '添加成功'); 
       
    }

    /**
     * 分组管理-编辑分组界面
     * @param $id
     * @return \Illuminate\View\View
     */
    public function edit($id,Request $request)
    {
        $page = $request->input('page');
        $data = Goods::where('id', $id)->first();
        $sku =  GoodsSkus::where('goodsCode', $id)->where('is_del', 0)->get();
        return view('goods/edit', [         
            'goods'     => $data,
            'sku_list'  => $sku,
            'id'        => $id,
            'page'      => $page,
        ]);

    }

    /**
     * 分组管理-进行编辑操作
     * @param Request $request
     * @return \Illuminate\Http\RedirectResponse
     */
    public function update(Request $request)
    {    
        $id = (int)$request->input('id');
        $page = (int)$request->input('page');
        $this->validate($request, [  
            'id'             => 'required',
            'name'           => 'required',   
            //'productCode'           => 'required|unique:goods,productCode,'.$id.',id',     
        ], [       
            'id'             => '非法操作',                                                       
            'name.required'           => '商品名不能为空',
            //'productCode.required'           => '商品货号不能为空',                                                                        
        ]);

        $del_sku_ids = trim($request->input('del_sku_ids'),',');
        $sku = $request->input('sku');
        //数据库-修改数据
        $goods = array();       
        $goods['name'] = trim($request->input('name')); 
        $goods['description'] = trim($request->input('description'));  //非必填
        //$goods['productCode'] = trim($request->input('productCode'));  
        //$goods['goodsCategoryName'] = trim($request->input('goodsCategoryName'));  
        //图片上传 阿里云oss       
        if ($request->hasFile('img') && $request->file('img')->isValid()) {
            $file = $request->file('img');
            $ossClient=new oss();
            // 上传阿里云
            $file = $ossClient->upload($file->getClientOriginalExtension(), $file->getRealPath(), 'upload/seafoodPic'.date("Y-m-d",time()).'/'.date('His'));
            $img=$file['oss-request-url'];
            $goods['picUrl']=str_replace("kx-youhuiquan.oss-cn-beijing.aliyuncs.com","imgs.726p.com",$img);
        } 

        DB::beginTransaction();
        try{
            $res = DB::table('goods')->where('id', $id)->update($goods); 
            if($res){
                //卖家云必要参数拼接转化
                $mjArr = array();
                $mjArr['eshopCode'] = config('constants.ESHOP_CODE');
                $mjArr['outerCode'] = $id;
                $mjArr['name'] = $goods['name'];
                $mjArr['description'] = $goods['description'];
                $mj = Order::mjGoodsUpdate($mjArr);

                
                //更新erp
                $erpArr = array();
                $goodsId = GoodsSkus::where('goodsCode', $id)->where('erpGoodsId','>',0)->first();
                if(!empty($goodsId)){
                    $erpArr['goodsId'] = $goodsId->erpGoodsId;
                    $erpArr['goodsName'] = $goods['name'];
                    $mj = Order::mjErpGoodsUpdate($erpArr);
                }
                

                #记录操作日志
                $self_id = session('admin_id');
                $self_name = session('real_name');
                $context = "修改商品数据";
                $type = 0; 
                $tables = 'goods,goods_skus';
                $data_id = $id;
                Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);

            }else{
                DB::rollback();
                return redirect('/admin/goods/index?page='.$page)->with('info', '未做任何修改');
            } 

            DB::commit();

        }catch (Exception $e){
            DB::rollback();
            Log::errorLog($request,['error'=>$e->getMessage()],"goods/update",0,'');
        }
      
        return redirect('/admin/goods/index?page='.$page)->with('info', '更新成功');
    }

    /**
     * 下架操作
     * @param Request $request
     * @return \Illuminate\Http\RedirectResponse
     */
    public function down($id)
    {
        $goods = Goods::find($id);
        $goods->is_del = 1;
        if ($goods ->save()){
            GoodsSkus::where('goodsCode', $id)->update(['is_del'=>1]);
            #记录操作日志
            $self_id = session('admin_id');
            $self_name = session('real_name');            
            $context = "下架商品";
            $type = 0; 
            $tables = 'goods';
            $data_id = $id;
            Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);
//            exit('1');
            echo '1';die;
        }
//        exit('0');
        echo '0';die;
    }

    /**
     * 上架操作
     * @param Request $request
     * @return \Illuminate\Http\RedirectResponse
     */
    public function up($id)
    {
        $goods = Goods::find($id);
        $goods->is_del = 0;
        if ($goods ->save()){
            #记录操作日志
            $self_id = session('admin_id');
            $self_name = session('real_name');            
            $context = "上架商品";
            $type = 0; 
            $tables = 'goods';
            $data_id = $id;
            Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);
//            exit('1');
            echo '1';die;
        }
//        exit('0');
        echo '0';die;
    }

    /**
     * 下架操作
     * @param Request $request
     * @return \Illuminate\Http\RedirectResponse
     */
    public function delete($id)
    {
        $goods = Goods::find($id);
        $goods->is_del = 2;
        if ($goods ->save()){
            GoodsSkus::where('goodsCode', $id)->update(['is_del'=>2]);
            #记录操作日志
            $self_id = session('admin_id');
            $self_name = session('real_name');            
            $context = "删除商品";
            $type = 0; 
            $tables = 'goods';
            $data_id = $id;
            Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);
//            exit('1');
            echo '1';die;
        }
//        exit('0');
        echo '0';die;
    }


    /**
     * 搜索商品
     */
    public function searchSkus(Request $request){
        $name = trim($request->input('name'));
        if(!$name){
            echo '0';die;
        }
        $is_fx = env('IS_FX');
        $result = Goods::select('gs.id as sku_id', 'goods.id as goods_id', 'goods.name', 'gs.propsName', 'gs.price',
            'gs.is_weigh', 'gs.quantity', 'gs.is_white', 'gs.is_not_fx', 'gs.warehouse')->leftJoin('goods_skus as gs',
            'gs.goodsCode', '=', 'goods.id')->where('goods.name', 'like', '%'.$name.'%')->where('goods.is_del', 0)
            ->where('gs.is_del', 0)->orderBy('goods.id', 'desc')->get();
        $result = json_decode(json_encode($result), true);
        foreach($result as $k=>&$v){
            //计算实际库存 -还未到卖家云的量
            $quantity_redis = GoodsSkus::actualQuantityByRedis($v['sku_id']);
            $v['quantity'] = $quantity_redis['quantity'];

            if($is_fx>0){
                //如果是分销，不展示没有库存的和白名单的
                if( $v['quantity'] <= 0 && $v['is_white'] != 1 ){
                    unset($result[$k]); 
                }
            }

            $v['warehouse_name'] = $this->warehouse[$v['warehouse']];
        }

        $result = array_values($result); 
        if(empty($result)) { echo '0';die; }
        echo json_encode($result);
    }

    /**
     * 单个商品sku列表
     */
    public function skuList(Request $request){
        $goods_id = $request->input('goods_id');
        $result = GoodsSkus::where('goodsCode', $goods_id)->where('is_del','<',2)->orderBy('id', 'desc')->get();
        foreach($result as $k=>&$item){           
            $quantity_redis = GoodsSkus::actualQuantityByRedis($item->id);
            $item->quantity = $quantity_redis['quantity'];
        }
        return view('/goods/skulist', ['result'=>$result, 'goods_id' => $goods_id]);
    }

    /**
     * @return \Illuminate\View\View
     */
    public function skuCreate(Request $request)
    {
        $goods_id = $request->input('goods_id');
        return view('goods/skucreate', ['goods_id'=>$goods_id]);
    }

    /**
     * @param Request $request
     * @return \Illuminate\Http\RedirectResponse
     */
    public function skuStore(Request $request)
    {
        $this->validate($request, [
            'propsName' => 'required',
            'price' => 'required',
            'referenceCost' => 'required',
            'outPrice' => 'required',
        ], [
            'propsName.required' => '规格不能为空',
            'price.required' => '建议零售价不能为空',
            'referenceCost.required' => '成本价不能为空',
            'outPrice.required' => '分销商价格不能为空',
        ]);
        $goods_id = (int)$request->input('goods_id');
        $data = array();
        $data['goodsCode'] = $goods_id;
        $data['eshopCode'] = config('constants.ESHOP_CODE');
        $data['propsName'] = $request->input('propsName');
        $data['price'] = $request->input('price');
        $data['tagPrice'] =  $data['price'];
        $data['referenceCost'] = $request->input('referenceCost');
        $data['is_weigh'] = (int)$request->input('is_weigh');
        $data['outPrice'] = $request->input('outPrice');
        //获取code
        //获取最大skucode
        $lastSku = DB::table('goods_skus')->select('code', 'erpGoodsId', 'eshopCode', 'goodsCode')->where('goodsCode', $goods_id)->orderBy('id', 'desc')->first();
       
        $code_arr = explode('-', $lastSku->code);
        $code_auto_num = (int)$code_arr[1];
        $pro_code = $code_arr[0];

        $data['code'] = $pro_code. '-0'. ($code_auto_num+1);

        DB::beginTransaction();
        try{
            $res = DB::table('goods_skus')->insertGetId($data);

            if($res){
                //增加erp sku
                $erpArr = array();
                $erpArr['goodsId'] = $lastSku->erpGoodsId; //erp商品id
                $erpArr['code'] = $data['code'];               
                if($data['is_weigh'] == 1){
                    $erpArr['propsName'] = $data['propsName'].'【按半斤称重】';
                    $erpArr['price'] = round( $data['price']/2, 2 );
                    $erpArr['tagPrice'] = round( $data['tagPrice']/2, 2 );
                    $erpArr['referenceCost'] = round( $data['referenceCost']/2, 2 );
                }else{
                    $erpArr['propsName'] = $data['propsName'];
                    $erpArr['price'] = $data['price'];
                    $erpArr['tagPrice'] = $data['tagPrice'];
                    $erpArr['referenceCost'] = $data['referenceCost'];
                }
                $erp = Order::mjErpGoodsAdd($erpArr);
                if( $erp == false ){
                    throw new Exception("erpSku同步到卖家云失败");
                }

                //更新erp信息到sku
                $params = array();
                $params['erpSkuId'] = $erp['skuId'];
                $params['erpGoodsId'] = $erp['goodsId'];
                $uperp = DB::table('goods_skus')->where('id', $res)->update($params);

                //增加shop sku
                $shopArr = array();
                $shopArr['outerCode'] = $res;
                $shopArr['eshopCode'] = $lastSku->eshopCode;
                $shopArr['goodsCode'] = $lastSku->goodsCode;
                $shopArr['propsName'] = $data['propsName'];
                $shopArr['price'] = $erpArr['price'];
                $shopArr['skuProductCode'] = $data['code'];
                $shopArr['createTime'] = date('Y-m-d H:i:s');
                $shopArr['modifyTime'] = $shopArr['createTime'];

                $sku_add = Order::mjSkuAdd($shopArr);
                if( $sku_add == false ){
                    throw new Exception("店铺商品Sku同步到卖家云失败");
                }

            }

            DB::commit();
        }catch (Exception $e){
            DB::rollback();
            Log::errorLog($request,['error'=>$e->getMessage()],"sku/store",0,'');
            return redirect('/admin/goods/skulist?goods_id='.$goods_id)->with('info', $e->getMessage());
        }

        return redirect('/admin/goods/skulist?goods_id='.$goods_id)->with('info', '添加成功');
    }

    /**
     * @param $id
     * @return \Illuminate\View\View
     */
    public function skuEdit($id, Request $request)
    {
        $sku = DB::table('goods_skus')->where('id', $id)->first();
        $sku = json_decode(json_encode($sku),true);
        return view('goods/skuedit', ['sku' => $sku, 'goods_id' => $sku['goodsCode']]);
    }

    /**
     * @param Request $request
     * @return \Illuminate\Http\RedirectResponse
     */
    public function skuUpdate(Request $request)
    {
        $this->validate($request, [
            'propsName' => 'required',
            'price' => 'required',
            'referenceCost' => 'required',
            'outPrice' => 'required',
        ], [
            'propsName.required' => '规格不能为空',
            'price.required' => '建议零售价不能为空',
            'referenceCost.required' => '成本价不能为空',
            'outPrice.required' => '分销商价格不能为空',
        ]);
        $id = (int)$request->input('id');
        $goods_id = (int)$request->input('goods_id');
        $data = array();
        $data['propsName'] = $request->input('propsName');
        if($request->input('price') > 0) $data['price'] = $request->input('price');
        if($request->input('price') > 0) $data['tagPrice'] = $request->input('price');
        if($request->input('referenceCost') > 0) $data['referenceCost'] = $request->input('referenceCost');       
        $data['is_weigh'] = (int)$request->input('is_weigh');
        if($request->input('outPrice') > 0) $data['outPrice'] = $request->input('outPrice');
       
        DB::beginTransaction();
        try{
            $res = DB::table('goods_skus')->where('id', $id)->update($data);

            if($res){
                # erp sku更新
                $sku = DB::table('goods_skus')->where('id', $id)->first();
                $erpArr = array();
                $erpArr['skuId'] = $sku->erpSkuId;               
                if($data['is_weigh'] == 1){
                    $erpArr['propsName'] = str_replace('【按半斤称重】', '', $sku->propsName).'【按半斤称重】';
                    if($request->input('price') > 0) $erpArr['price'] = round( $sku->price/2, 2 );
                    if($request->input('price') > 0) $erpArr['tagPrice'] = round( $sku->tagPrice/2, 2 );
                    if($request->input('referenceCost') > 0) $erpArr['referenceCost'] = round( $sku->referenceCost/2, 2 );
                }else{
                    $erpArr['propsName'] = str_replace('【按半斤称重】', '', $sku->propsName);
                    if($request->input('price') > 0) $erpArr['price'] = $sku->price;
                    if($request->input('price') > 0) $erpArr['tagPrice'] = $sku->tagPrice;
                    if($request->input('referenceCost') > 0) $erpArr['referenceCost'] = $sku->referenceCost;
                }
                
                $erp_up = Order::mjErpSkuUpdate($erpArr);
                if( $erp_up == false ){
                    throw new Exception("erpSku更新同步到卖家云失败");
                }

                # eshop sku更新
                $shopArr = array();
                $shopArr['eshopCode'] = $sku->eshopCode;
                $shopArr['goodsCode'] = $sku->goodsCode;
                $shopArr['outerCode'] = $sku->id;
                $shopArr['propsName'] = $sku->propsName;
                if($request->input('price') > 0) $shopArr['price'] = $erpArr['price'];

                $sku_up = Order::mjSkuUpdate($shopArr);
                if( $sku_up == false ){
                    throw new Exception("店铺商品Sku更新同步到卖家云失败");
                }
            }

            DB::commit();
        }catch (Exception $e){
            DB::rollback();
            Log::errorLog($request,['error'=>$e->getMessage()],"sku/update",0,'');
            return redirect('/admin/goods/skulist?goods_id='.$goods_id)->with('info', $e->getMessage());
        }
            
        return redirect('/admin/goods/skulist?goods_id='.$goods_id)->with('info', '修改成功');
    }

    /**
     * 进行下架操作
     * @param Request $request
     * @return \Illuminate\Http\RedirectResponse
     */
    public function skuDel($id)
    {
        $goods = GoodsSkus::find($id);
        $goods->is_del = 1;
        if ($goods ->save()){
            #记录操作日志
            $self_id = session('admin_id');
            $self_name = session('real_name');            
            $context = "下架sku";
            $type = 0; 
            $tables = 'goods_skus';
            $data_id = $id;
            Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);
//            exit('1');
            echo '1';die;
        }
//        exit('0');
        echo '0';die;
    }

    /**
     * 进行上架操作
     * @param Request $request
     * @return \Illuminate\Http\RedirectResponse
     */
    public function skuUp($id)
    {
        $goods = GoodsSkus::find($id);
        $goods->is_del = 0;
        if ($goods ->save()){
            #记录操作日志
            $self_id = session('admin_id');
            $self_name = session('real_name');            
            $context = "上架sku";
            $type = 0; 
            $tables = 'goods_skus';
            $data_id = $id;
            Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);
//            exit('1');
            echo '1';die;
        }
//        exit('0');
        echo '0';die;
    }

    /**
     * 进行删除操作
     * @param Request $request
     * @return \Illuminate\Http\RedirectResponse
     */
    public function skuDelete($id)
    {
        $goods = GoodsSkus::find($id);
        $goods->is_del = 2;
        if ($goods ->save()){
            #记录操作日志
            $self_id = session('admin_id');
            $self_name = session('real_name');            
            $context = "删除sku";
            $type = 0; 
            $tables = 'goods_skus';
            $data_id = $id;
            Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);
//            exit('1');
            echo '1';die;
        }
//        exit('0');
        echo '0';die;
    }

    /**
     * 分销商商品列表
     * @param Request $request
     * @return \Illuminate\View\View
     */
    public function indexCopy(Request $request){

        //获取分类
        $cates = DB::table('categorys')->lists('name', 'id');
        //获取请求参数
        $name = trim($request->input('name',''));
        $cate_name = trim($request->input('cate_name',''));
        $status = $request->input('status','-1');
        $realQuantity = $request->input('quantity','-1');
        $outPrice = $request->input('outPrice','-1');
        $page = (int)$request->input('page','1');
        $pageSize = 20;

        //若有请求参数，初步查询处理
        $goodsIds = array();
        if($name || $cate_name || ($status != '-1')){
            $goodsIds = Goods::where(function($query) use($name, $cate_name, $status){
                if($name) $query->where('name', 'like', '%'.$name.'%');
                if($cate_name) $query->where('goodsCategoryName', '=', $cate_name);
                #先筛选商品的状态
                if($status != '-1') {
                    $query->where('is_del',$status);
                } else {
                    $query->whereIn('is_del',array(0,1));
                }
            })->lists('id');

            //TODO 无搜索结果，直接返回空，添加检索框以后不要忘了修改这里
            if(count($goodsIds) == 0){
                return view('goods/indexcopy', ['result' =>[],
                    'page'              =>$page,
                    'count'             =>0,
                    'pages'             =>1,
                    'name'              =>$name,
                    'cate_name'         =>$cate_name,
                    'cates'             =>$cates,
                    'status'            =>$status,
                    'quantity'          =>$realQuantity,
                    'outPrice'          =>$outPrice,
                ]);
            }
        }

        //筛选所有可用库存大于0的规格id
        $actualSkuList = array();
        if($realQuantity != '-1'){
            $actualSkuList = GoodsSkus::actualQuantityNotNull();
        }

        //获取数据总条数
        $count = GoodsSkus::where(function($query) use ($goodsIds,$status,$realQuantity,$outPrice,$actualSkuList){
            if(count($goodsIds) > 1){
                $query->whereIn('goodsCode',$goodsIds);
            }else if(count($goodsIds) == 1){
                $query->where('goodsCode',$goodsIds);
            }
            if($status != '-1') {
                if($status != 1){
                    //筛选上架商品，先筛选出上架的商品id，这些商品id对应的规格有些事上架状态，有些是下架状态，然后再筛选这些上架商品规格当中上架的规格
                    $query->where('is_del',0);
                } else {
                    //筛选下架商品，先筛选出下架的商品id，这些商品id对应的规格一定都是下架状态，但是上架的商品当中也有部分规格是下架状态，所有用or把这些规格加进来
                    $query->orWhere('is_del',1);
                }
            } else {
                $query->whereIn('is_del',array(0,1));
            }
            if($realQuantity != '-1') $query->whereIn('id',$actualSkuList);
            if($outPrice != '-1') $query->where('outPrice','>','0');
        })->count();

        //分页数据处理
        if ($count > 1) {
            // 总页数
            $pages = ceil($count/$pageSize);
        }else{
            // 总页数
            $pages = 1;
        }

        //获取数据项
        $offset = ($page-1) * $pageSize;
        $result = GoodsSkus::where(function($query) use ($goodsIds,$status,$realQuantity,$outPrice,$actualSkuList){
            if(count($goodsIds) > 1){
                $query->whereIn('goodsCode',$goodsIds);
            } else if(count($goodsIds) == 1){
                $query->where('goodsCode',$goodsIds);
            }
            if($status != '-1') {
                if($status != 1){
                    //筛选上架商品，先筛选出上架的商品id，这些商品id对应的规格有些事上架状态，有些是下架状态，然后再筛选这些上架商品规格当中上架的规格
                    $query->where('is_del',0);
                } else {
                    //筛选下架商品，先筛选出下架的商品id，这些商品id对应的规格一定都是下架状态，但是上架的商品当中也有部分规格是下架状态，所有用or把这些规格加进来
                    $query->orWhere('is_del',1);
                }
            } else {
                $query->whereIn('is_del',array(0,1));
            }
            if($realQuantity != '-1') $query->whereIn('id',$actualSkuList);
            if($outPrice != '-1') $query->where('outPrice','>','0');
        })->orderBy('goodsCode', 'desc')->offset($offset)->limit($pageSize)->get();
        $result = json_decode(json_encode($result),true);

        //对数据项进行处理
        foreach($result as $k=>&$v){
            # 获取goods信息
            $goodsInfo = Goods::where('id', $v['goodsCode'])->first();
            $quantity = GoodsSkus::actualQuantityByRedis($v['id']);
            $v['real_quantity'] = $quantity['quantity'];
            $v['pre_quantity'] = $quantity['w_num'];
            $v['total_quantity'] = $v['quantity'];
            $v['name'] = $goodsInfo->name;
            $v['goodsCategoryName'] = $goodsInfo->goodsCategoryName;
            if($goodsInfo->is_del == 1){
                $v['is_del'] = 1;
            }
        }

        //返回给页面
        return view('goods/indexcopy', [
            'result'            =>$result,
            'page'              =>$page,
            'count'             =>$count,
            'pages'             =>$pages,
            'name'              =>$name,
            'cate_name'         =>$cate_name,
            'cates'             =>$cates,
            'status'            =>$status,
            'quantity'          =>$realQuantity,
            'outPrice'          =>$outPrice,
        ]);
    }

    /**
     * 分销商品列表导出
     * @param Request $request
     * @return bool|\Illuminate\Http\RedirectResponse
     */
    public function indexCopyExport(Request $request){
        //获取请求参数
        $name = trim($request->input('name',''));
        $cate_name = trim($request->input('cate_name',''));
        $status = $request->input('status','-1');
        $realQuantity = $request->input('quantity','-1');
        $outPrice = $request->input('outPrice','-1');

        //若有请求参数，初步获取查询结果
        $goodsIds = array();
        if($name || $cate_name || ($status != '-1')){
            $goodsIds = Goods::where(function($query) use($name, $cate_name, $status){
                if($name) $query->where('name', 'like', '%'.$name.'%');
                if($cate_name) $query->where('goodsCategoryName', '=', $cate_name);
                if($status != '-1') {
                    $query->where('is_del',$status);
                } else {
                    $query->whereIn('is_del',array(0,1));
                }
            })->lists('id');
            //无查询结果，直接返回空
            if(count($goodsIds) == 0){
                return back()->with('info','没有商品可导出');
            }
        }

        //筛选所有可用库存大于0的规格id
        $actualSkuList = array();
        if($realQuantity != '-1'){
            $actualSkuList = GoodsSkus::actualQuantityNotNull();
        }

        //进一步获取数据查询结果
        $result = GoodsSkus::where(function($query) use ($goodsIds,$status,$realQuantity,$outPrice,$actualSkuList){
            if(count($goodsIds) > 1){
                $query->whereIn('goodsCode',$goodsIds);
            }else if(count($goodsIds) == 1){
                $query->where('goodsCode',$goodsIds);
            }
            if($status != '-1') {
                if($status != 1){
                    //筛选上架商品，先筛选出上架的商品id，这些商品id对应的规格有些事上架状态，有些是下架状态，然后再筛选这些上架商品规格当中上架的规格
                    $query->where('is_del',0);
                } else {
                    //筛选下架商品，先筛选出下架的商品id，这些商品id对应的规格一定都是下架状态，但是上架的商品当中也有部分规格是下架状态，所有用or把这些规格加进来
                    $query->orWhere('is_del',1);
                }
            } else {
                $query->whereIn('is_del',array(0,1));
            }
            if($realQuantity != '-1') $query->whereIn('id',$actualSkuList);
            if($outPrice != '-1') $query->where('outPrice','>','0');
        })->orderBy('goodsCode', 'desc')->get();
        $result = json_decode(json_encode($result),true);

        //对数据查询结果处理
        foreach($result as $k=>&$v){
            # 获取goods信息
            $goodsInfo = Goods::where('id', $v['goodsCode'])->first();
            $quantity = GoodsSkus::actualQuantityByRedis($v['id']);
            $v['real_quantity'] = $quantity['quantity'];
            $v['pre_quantity'] = $quantity['w_num'];
            $v['total_quantity'] = $v['quantity'];
            $v['name'] = $goodsInfo->name;
            $v['goodsCategoryName'] = $goodsInfo->goodsCategoryName;
            if($goodsInfo->is_del == 1){
                $v['is_del'] = 1;
            }
            if($v['is_del'] == 1){
                $v['status'] = '已下架';
            } else {
                $v['status'] = '已上架';
            }
        }

        //将数据查询结果通过导出excel方法导出到浏览器
        $indexKey = ['goodsCategoryName','name','propsName','code','referenceCost','outPrice','price','status','createTime','real_quantity','total_quantity','pre_quantity'];
        $title = ['商品分类', '商品名称', '商品规格', '规格编码','成本价','分销商价格','建议零售价','上架状态','上架时间','可用库存','总库存','预占用库存'];
        $filename = 'goods_sku_export_'.date('Y-m-d_H').'.xlsx';
        return Order::export_excel($result, $filename, $indexKey, $title);
    }

    /**
     * 编辑建议零售价或者分销商价格
     * @param Request $request
     */
    public function editGoodsSku(Request $request){
        $id = $request->input('id');
        $outPrice = trim($request->input('outPrice'));
        $price = trim($request->input('price'));
        $referenceCost = trim($request->input('referenceCost'));

        if($outPrice){
            $res = GoodsSkus::where('id',$id)->update(['outPrice'=>$outPrice]);
            if($res) return 0;
        }

        $skus = GoodsSkus::find($id);

        if($price){
            $res = GoodsSkus::where('id',$id)->update(['price'=>$price]);

            //更新erp系统sku
            $erpArr['skuId'] = $skus->erpSkuId;
            $erpArr['price'] = $price;
            $erp_up = Order::mjErpSkuUpdate($erpArr);
//            if( $erp_up == false ){
////                $flag[] = 'erpSku更新同步到卖家云失败';
//                throw new \Exception("erpSku更新同步到卖家云失败");
//            }

            //更新店铺中sku
            $shopArr['eshopCode'] = config('constants.ESHOP_CODE');
            $shopArr['goodsCode'] = $skus->goodsCode;
            $shopArr['outerCode'] = $skus->id;
            $shopArr['price'] = $price;
            $sku_up = Order::mjSkuUpdate($shopArr);
//            if( $sku_up == false ){
////                $flag[] = '店铺商品Sku更新同步到卖家云失败';
//                throw new \Exception("店铺商品Sku更新同步到卖家云失败");
//            }

            if($res) return 0;
        }
        if($referenceCost){
            $res = GoodsSkus::where('id',$id)->update(['referenceCost'=>$referenceCost]);

            //更新erp系统sku
            $erpArr['skuId'] = $skus->erpSkuId;
            $erpArr['referenceCost'] = $referenceCost;
            $erp_up = Order::mjErpSkuUpdate($erpArr);
//            if( $erp_up == false ){
////                $flag[] = 'erpSku更新同步到卖家云失败';
//                throw new \Exception("erpSku更新同步到卖家云失败");
//            }

            if($res) return 0;
        }

        return 1;
    }

    /**
     * 分销商商品列表
     * @param Request $request
     * @return \Illuminate\View\View
     */
    public function goodsIndex(Request $request){

        //获取分类
        $cates = DB::table('categorys')->lists('name', 'id');
        //获取请求参数
        $name = trim($request->input('name',''));
        $cate_name = trim($request->input('cate_name',''));
        $status = $request->input('status','-1');
        $realQuantity = $request->input('quantity','-1');
        $outPrice = $request->input('outPrice','-1');
        $page = (int)$request->input('page','1');
        $pageSize = 20;

        //若有请求参数，初步查询处理
        $goodsIds = array();
        if($name || $cate_name || ($status != '-1')){
            $goodsIds = Goods::where(function($query) use($name, $cate_name, $status){
                if($name) $query->where('name', 'like', '%'.$name.'%');
                if($cate_name) $query->where('goodsCategoryName', '=', $cate_name);
                #先筛选商品的状态
                if($status != '-1') {
                    $query->where('is_del',$status);
                } else {
                    $query->whereIn('is_del',array(0,1));
                }
            })->lists('id');

            //TODO 无搜索结果，直接返回空，添加检索框以后不要忘了修改这里
            if(count($goodsIds) == 0){
                return view('goods/indexcopy', ['result' =>[],
                    'page'              =>$page,
                    'count'             =>0,
                    'pages'             =>1,
                    'name'              =>$name,
                    'cate_name'         =>$cate_name,
                    'cates'             =>$cates,
                    'status'            =>$status,
                    'quantity'          =>$realQuantity,
                    'outPrice'          =>$outPrice,
                ]);
            }
        }

        //筛选所有可用库存大于0的规格id
        $actualSkuList = array();
        if($realQuantity != '-1'){
            $actualSkuList = GoodsSkus::actualQuantityNotNull();
        }

        //获取数据总条数
        $count = GoodsSkus::where(function($query) use ($goodsIds,$status,$realQuantity,$outPrice,$actualSkuList){
            if(count($goodsIds) > 1){
                $query->whereIn('goodsCode',$goodsIds);
            }else if(count($goodsIds) == 1){
                $query->where('goodsCode',$goodsIds);
            }
            if($status != '-1') {
                if($status != 1){
                    //筛选上架商品，先筛选出上架的商品id，这些商品id对应的规格有些事上架状态，有些是下架状态，然后再筛选这些上架商品规格当中上架的规格
                    $query->where('is_del',0);
                } else {
                    //筛选下架商品，先筛选出下架的商品id，这些商品id对应的规格一定都是下架状态，但是上架的商品当中也有部分规格是下架状态，所有用or把这些规格加进来
                    $query->orWhere('is_del',1);
                }
            } else {
                $query->whereIn('is_del',array(0,1));
            }
            if($realQuantity != '-1') $query->whereIn('id',$actualSkuList);
            if($outPrice != '-1') $query->where('outPrice','>','0');
        })->count();

        //分页数据处理
        if ($count > 1) {
            // 总页数
            $pages = ceil($count/$pageSize);
        }else{
            // 总页数
            $pages = 1;
        }

        //获取数据项
        $offset = ($page-1) * $pageSize;
        $result = GoodsSkus::where(function($query) use ($goodsIds,$status,$realQuantity,$outPrice,$actualSkuList){
            if(count($goodsIds) > 1){
                $query->whereIn('goodsCode',$goodsIds);
            } else if(count($goodsIds) == 1){
                $query->where('goodsCode',$goodsIds);
            }
            if($status != '-1') {
                if($status != 1){
                    //筛选上架商品，先筛选出上架的商品id，这些商品id对应的规格有些事上架状态，有些是下架状态，然后再筛选这些上架商品规格当中上架的规格
                    $query->where('is_del',0);
                } else {
                    //筛选下架商品，先筛选出下架的商品id，这些商品id对应的规格一定都是下架状态，但是上架的商品当中也有部分规格是下架状态，所有用or把这些规格加进来
                    $query->orWhere('is_del',1);
                }
            } else {
                $query->whereIn('is_del',array(0,1));
            }
            if($realQuantity != '-1') $query->whereIn('id',$actualSkuList);
            if($outPrice != '-1') $query->where('outPrice','>','0');
        })->orderBy('goodsCode', 'desc')->offset($offset)->limit($pageSize)->get();
        $result = json_decode(json_encode($result),true);

        //对数据项进行处理
        foreach($result as $k=>&$v){
            # 获取goods信息
            $goodsInfo = Goods::where('id', $v['goodsCode'])->first();
            $quantity = GoodsSkus::actualQuantityByRedis($v['id']);
            $v['real_quantity'] = $quantity['quantity'];
            $v['pre_quantity'] = $quantity['w_num'];
            $v['total_quantity'] = $v['quantity'];
            $v['name'] = $goodsInfo->name;
            $v['goodsCategoryName'] = $goodsInfo->goodsCategoryName;
            if($goodsInfo->is_del == 1){
                $v['is_del'] = 1;
            }
        }

        //返回给页面
        return view('goods/goodsindex', [
            'result'            =>$result,
            'page'              =>$page,
            'count'             =>$count,
            'pages'             =>$pages,
            'name'              =>$name,
            'cate_name'         =>$cate_name,
            'cates'             =>$cates,
            'status'            =>$status,
            'quantity'          =>$realQuantity,
            'outPrice'          =>$outPrice,
        ]);
    }

    /**
     * 分销商品列表导出
     * @param Request $request
     * @return bool|\Illuminate\Http\RedirectResponse
     */
    public function goodsIndexExport(Request $request){
        //获取请求参数
        $name = trim($request->input('name',''));
        $cate_name = trim($request->input('cate_name',''));
        $status = $request->input('status','-1');
        $realQuantity = $request->input('quantity','-1');
        $outPrice = $request->input('outPrice','-1');

        //若有请求参数，初步获取查询结果
        $goodsIds = array();
        if($name || $cate_name || ($status != '-1')){
            $goodsIds = Goods::where(function($query) use($name, $cate_name, $status){
                if($name) $query->where('name', 'like', '%'.$name.'%');
                if($cate_name) $query->where('goodsCategoryName', '=', $cate_name);
                if($status != '-1') {
                    $query->where('is_del',$status);
                } else {
                    $query->whereIn('is_del',array(0,1));
                }
            })->lists('id');
            //无查询结果，直接返回空
            if(count($goodsIds) == 0){
                return back()->with('info','没有商品可导出');
            }
        }

        //筛选所有可用库存大于0的规格id
        $actualSkuList = array();
        if($realQuantity != '-1'){
            $actualSkuList = GoodsSkus::actualQuantityNotNull();
        }

        //进一步获取数据查询结果
        $result = GoodsSkus::where(function($query) use ($goodsIds,$status,$realQuantity,$outPrice,$actualSkuList){
            if(count($goodsIds) > 1){
                $query->whereIn('goodsCode',$goodsIds);
            }else if(count($goodsIds) == 1){
                $query->where('goodsCode',$goodsIds);
            }
            if($status != '-1') {
                if($status != 1){
                    //筛选上架商品，先筛选出上架的商品id，这些商品id对应的规格有些事上架状态，有些是下架状态，然后再筛选这些上架商品规格当中上架的规格
                    $query->where('is_del',0);
                } else {
                    //筛选下架商品，先筛选出下架的商品id，这些商品id对应的规格一定都是下架状态，但是上架的商品当中也有部分规格是下架状态，所有用or把这些规格加进来
                    $query->orWhere('is_del',1);
                }
            } else {
                $query->whereIn('is_del',array(0,1));
            }
            if($realQuantity != '-1') $query->whereIn('id',$actualSkuList);
            if($outPrice != '-1') $query->where('outPrice','>','0');
        })->orderBy('goodsCode', 'desc')->get();
        $result = json_decode(json_encode($result),true);

        //对数据查询结果处理
        foreach($result as $k=>&$v){
            # 获取goods信息
            $goodsInfo = Goods::where('id', $v['goodsCode'])->first();
            $quantity = GoodsSkus::actualQuantityByRedis($v['id']);
            $v['real_quantity'] = $quantity['quantity'];
            $v['pre_quantity'] = $quantity['w_num'];
            $v['total_quantity'] = $v['quantity'];
            $v['name'] = $goodsInfo->name;
            $v['goodsCategoryName'] = $goodsInfo->goodsCategoryName;
            if($goodsInfo->is_del == 1){
                $v['is_del'] = 1;
            }
            if($v['is_del'] == 1){
                $v['status'] = '已下架';
            } else {
                $v['status'] = '已上架';
            }
        }

        //将数据查询结果通过导出excel方法导出到浏览器
        $indexKey = ['goodsCategoryName','name','propsName','code','price','outPrice','status','createTime','real_quantity','total_quantity','pre_quantity'];
        $title = ['商品分类', '商品名称', '商品规格', '规格编码','建议零售价','分销商价格','上架状态','上架时间','可用库存','总库存','预占用库存'];
        $filename = 'goods_sku_export_'.date('Y-m-d_H').'.xlsx';
        return Order::export_excel($result, $filename, $indexKey, $title);
    }

}