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); })->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); })->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) { $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, ]); } /** * 分组管理-进行编辑操作 * @param Request $request * @return \Illuminate\Http\RedirectResponse */ public function update(Request $request) { $id = (int)$request->input('id'); $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')->with('info', '未做任何修改'); } DB::commit(); }catch (Exception $e){ DB::rollback(); Log::errorLog($request,['error'=>$e->getMessage()],"goods/update",0,''); } return redirect('/admin/goods/index')->with('info', '更新成功'); } /** * 下架操作 * @param Request $request * @return \Illuminate\Http\RedirectResponse */ public function delete($id) { $goods = Goods::find($id); $goods->is_del = 1; 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'); } exit('0'); } /** * 上架操作 * @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'); } exit('0'); } /** * 搜索商品 */ public function searchSkus(Request $request){ $name = trim($request->input('name')); if(!$name){ exit('0'); } $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')->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(empty($result)) exit('0'); exit(json_encode($result)); } /** * 单个商品sku列表 */ public function skuList(Request $request){ $goods_id = $request->input('goods_id'); $result = GoodsSkus::where('goodsCode', $goods_id)->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', ], [ 'propsName.required' => '规格不能为空', 'price.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'] = $request->input('tagPrice'); $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', ], [ 'propsName.required' => '规格不能为空', //'price.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('tagPrice') > 0) $data['tagPrice'] = $request->input('tagPrice'); 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('tagPrice') > 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('tagPrice') > 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'); } exit('0'); } /** * 进行上架操作 * @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'); } exit('0'); } /** * 分销商商品列表 * @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){ $goodsIds = Goods::where(function($query) use($name, $cate_name){ if($name) $query->where('name', 'like', '%'.$name.'%'); if($cate_name) $query->where('goodsCategoryName', '=', $cate_name); })->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') $query->where('is_del',$status); 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') $query->where('is_del',$status); if($realQuantity != '-1') $query->whereIn('id',$actualSkuList); if($outPrice != '-1') $query->where('outPrice','>','0'); })->orderBy('id', '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){ $goodsIds = Goods::where(function($query) use($name, $cate_name){ if($name) $query->where('name', 'like', '%'.$name.'%'); if($cate_name) $query->where('goodsCategoryName', '=', $cate_name); })->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') $query->where('is_del',$status); if($realQuantity != '-1') $query->whereIn('id',$actualSkuList); if($outPrice != '-1') $query->where('outPrice','>','0'); })->orderBy('id', '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','realPrice','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')); if($outPrice){ $res = GoodsSkus::where('id',$id)->update(['outPrice'=>$outPrice]); if($res) return 0; } if($price){ $res = GoodsSkus::where('id',$id)->update(['price'=>$price]); if($res) return 0; } return 1; } }