No Description

GoodsController.php 51KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232
  1. <?php
  2. /**
  3. * Created by Sublime.
  4. * User: hao
  5. * Date: 19/08/30
  6. * Time: 上午11:20
  7. */
  8. namespace App\Http\Controllers\Admin;
  9. use App\Http\Controllers\Controller;
  10. use App\Log;
  11. use App\Goods;
  12. use App\GoodsSkus;
  13. use App\Order;
  14. use App\Oplog;
  15. use App\Services\OssServices as oss;
  16. use Illuminate\Http\Request;
  17. use Illuminate\Support\Facades\DB;
  18. use PHPExcel_Reader_Excel2007;
  19. use PHPExcel_Reader_Excel5;
  20. use PHPExcel_Reader_CSV;
  21. class GoodsController extends Controller
  22. {
  23. public function index(Request $request){
  24. $page = (int)$request->input('page');
  25. $pageSize = 20;
  26. if($page<=0){
  27. $page = 1;
  28. }
  29. $offset = ($page-1) * $pageSize;
  30. $stime = $request->input('stime');
  31. $etime = $request->input('etime');
  32. $name = $request->input('name');
  33. $cate_name = trim($request->input('cate_name'));
  34. $count = Goods::where(function($query) use($name, $stime, $etime, $cate_name){
  35. if($name) $query->where('name', 'like', '%'.$name.'%');
  36. if($cate_name) $query->where('goodsCategoryName', '=', $cate_name);
  37. if($stime) $query->where('createTime', '>=', $stime);
  38. if($etime) $query->where('createTime', '<=', $etime);
  39. })->where('is_del', '<', 2)->count();
  40. if ($count > 1) {
  41. // 总页数
  42. $pages = ceil($count/$pageSize);
  43. }else{
  44. // 总页数
  45. $pages = 1;
  46. }
  47. $result = Goods::where(function($query) use($name, $stime, $etime, $cate_name){
  48. if($name) $query->where('name', 'like', '%'.$name.'%');
  49. if($cate_name) $query->where('goodsCategoryName', '=', $cate_name);
  50. if($stime) $query->where('createTime', '>=', $stime);
  51. if($etime) $query->where('createTime', '<=', $etime);
  52. })->where('is_del', '<', 2)->orderBy('id', 'desc')->offset($offset)->limit($pageSize)->get();
  53. $result = json_decode(json_encode($result),true);
  54. foreach($result as $k=>&$v){
  55. # 获取sku
  56. $skuList = GoodsSkus::where('goodsCode', $v['id'])->where('is_del', 0)->get();
  57. foreach($skuList as $k=>&$item){
  58. $quantity = GoodsSkus::actualQuantityByRedis($item->id);
  59. $item->quantity = $quantity['quantity'];
  60. $item->w_num = $quantity['w_num'];
  61. }
  62. $v['sku_list'] = $skuList;
  63. }
  64. //获取分类
  65. $cates = DB::table('categorys')->lists('name', 'id');
  66. return view('goods/index', ['result' =>$result,
  67. 'page' =>$page,
  68. 'count' =>$count,
  69. 'pages' =>$pages,
  70. 'stime' =>$stime,
  71. 'etime' =>$etime,
  72. 'name' =>$name,
  73. 'cate_name' =>$cate_name,
  74. 'cates' =>$cates,
  75. ]);
  76. }
  77. /**
  78. * 添加商品
  79. * @return \Illuminate\View\View
  80. */
  81. public function create(Request $request)
  82. {
  83. //获取分类
  84. $cates = DB::table('categorys')->lists('name', 'id');
  85. return view('goods/create', ['cates'=>$cates]);
  86. }
  87. /**
  88. * 分组管理-进行添加操作
  89. * @param Request $request
  90. * @return \Illuminate\Http\RedirectResponse
  91. */
  92. public function store(Request $request)
  93. {
  94. $cateVali = '';
  95. $goodsCategoryName = trim($request->input('goodsCategoryName'));
  96. $goodsCategoryName2 = trim($request->input('goodsCategoryName2'));
  97. if( empty($goodsCategoryName) && empty($goodsCategoryName2) ){
  98. $cateVali = 'required';
  99. }
  100. $this->validate($request, [
  101. 'name' => 'required|unique:goods',
  102. 'productCode' => 'required|unique:goods,productCode,1,is_del',
  103. 'sku' => 'required',
  104. 'goodsCategoryName2' => $cateVali,
  105. ], [
  106. 'name.required' => '商品名不能为空',
  107. 'name.unique' => '该商品已存在',
  108. 'productCode.required' => '商品货号不能为空',
  109. 'productCode.unique' => '该商品货号已经存在',
  110. 'sku.required' => '必须添加商品规格',
  111. 'goodsCategoryName2.required' => '商品分类必填',
  112. ]);
  113. //数据库-新增数据
  114. $goods = array();
  115. $goods['name'] = trim($request->input('name'));
  116. $goods['description'] = trim($request->input('description')); //非必填
  117. $goods['eshopCode'] = config('constants.ESHOP_CODE');
  118. $goods['productCode'] = trim($request->input('productCode'));
  119. DB::beginTransaction();
  120. try{
  121. if( !empty($goodsCategoryName2) ){
  122. //增加分类
  123. $cates = array();
  124. $cates['name'] = $goodsCategoryName2;
  125. DB::table('categorys')->insert($cates);
  126. $goodsCategoryName = $goodsCategoryName2;
  127. }
  128. $goods['goodsCategoryName'] = $goodsCategoryName;
  129. //图片上传 阿里云oss
  130. if ($request->hasFile('img') && $request->file('img')->isValid()) {
  131. $file = $request->file('img');
  132. $ossClient=new oss();
  133. // 上传阿里云
  134. $file = $ossClient->upload($file->getClientOriginalExtension(), $file->getRealPath(), 'upload/seafoodPic'.date("Y-m-d",time()).'/'.date('His'));
  135. $img=$file['oss-request-url'];
  136. $goods['picUrl']=str_replace("kx-youhuiquan.oss-cn-beijing.aliyuncs.com","imgs.726p.com",$img);
  137. }
  138. if( !isset($goods['picUrl']) ) $goods['picUrl'] = 'http://imgs.726p.com/tbk/upload/seafoodPic2019-10-14/151513/kx-5da4208175314.jpg';
  139. $res = DB::table('goods')->insertGetId($goods);
  140. if($res){
  141. //卖家云必要参数拼接转化
  142. $mjArr = $goods;
  143. $mjArr['outerCode'] = $res;
  144. //sku
  145. $sku = $request->input('sku');
  146. if(!empty($sku)){
  147. foreach($sku as $key=>$item){
  148. $sku_data = explode('@@', $item);
  149. if(!$sku_data[2]) $sku_data[2] = null;
  150. if(!$sku_data[3]) $sku_data[3] = null;
  151. if(!$sku_data[4]) $sku_data[4] = null;
  152. $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')];
  153. $skuProductCode = $goods['productCode'].'-0'.($key+1);
  154. $sku_insert_data['code'] = $mjArr['skuList'][$key]['skuProductCode'] = $skuProductCode;
  155. $sku_insert_data['goodsCode'] = $res;
  156. $sku_insert_data['eshopCode'] = config('constants.ESHOP_CODE');
  157. $sku_ids = DB::table('goods_skus')->insertGetId($sku_insert_data);
  158. $mjArr['skuList'][$key]['outerCode'] = $sku_ids;
  159. }
  160. }
  161. //对接卖家云
  162. //1.erp添加
  163. $erpArr = array();
  164. $erpArr['goodsCode'] = $goods['productCode']; //商品货号
  165. $erpArr['goodsName'] = $goods['name'];
  166. $erpArr['goodsCategoryName'] = $goods['goodsCategoryName'];
  167. $erpArr['picUrl'] = $goods['picUrl'];
  168. foreach($mjArr['skuList'] as $k=>&$v){
  169. $erpArr['code'] = $v['skuProductCode'];
  170. $is_weigh = $v['is_weigh'];
  171. $erpArr['propsName'] = $is_weigh==1 ? $v['propsName'].'【按半斤称重】' : $v['propsName'];
  172. $erpArr['price'] = $v['price'] = $is_weigh==1 ? round( $v['price']/2, 2 ) : $v['price'];
  173. $erpArr['tagPrice'] = $is_weigh==1 ? round( $v['tagPrice']/2, 2 ) : $v['tagPrice'];
  174. $erpArr['referenceCost'] = $is_weigh==1 ? round( $v['referenceCost']/2, 2 ) : $v['referenceCost'];
  175. $erp = Order::mjErpGoodsAdd($erpArr);
  176. if($erp == false){
  177. throw new Exception("添加erp商品失败,对接卖家云出错");
  178. }
  179. unset($mjArr['skuList'][$k]['tagPrice']);
  180. unset($mjArr['skuList'][$k]['referenceCost']);
  181. unset($mjArr['skuList'][$k]['is_weigh']);
  182. unset($mjArr['skuList'][$k]['outPrice']);
  183. //更新erp信息到sku
  184. $params = array();
  185. $params['erpSkuId'] = $erp['skuId'];
  186. $params['erpGoodsId'] = $erp['goodsId'];
  187. $uperp = DB::table('goods_skus')->where('id', $v['outerCode'])->update($params);
  188. }
  189. //2.商品同步
  190. $mj = Order::mjGoodsAdd($mjArr);
  191. if($mj == false){
  192. throw new Exception("添加店铺商品失败,对接卖家云出错");
  193. }
  194. /* 同步卖家云商品code等信息 */
  195. $mjGood = array();
  196. $mjGood['code'] = $mj['goods']['code'];
  197. Goods::where('id', $res)->update($mjGood);
  198. /* end */
  199. #记录操作日志
  200. $self_id = session('admin_id');
  201. $self_name = session('real_name');
  202. $context = "新增商品数据";
  203. $type = 0;
  204. $tables = 'goods,goods_skus';
  205. $data_id = $res;
  206. Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);
  207. }
  208. DB::commit();
  209. }catch (Exception $e){
  210. Log::errorLog($request,['error'=>$e->getMessage()],"goods/store",0,'');
  211. DB::rollback();
  212. return redirect('/admin/goods/index')->with('info', $e->getMessage());
  213. }
  214. return redirect('/admin/goods/index')->with('info', '添加成功');
  215. }
  216. /**
  217. * 分组管理-编辑分组界面
  218. * @param $id
  219. * @return \Illuminate\View\View
  220. */
  221. public function edit($id,Request $request)
  222. {
  223. $page = $request->input('page');
  224. $data = Goods::where('id', $id)->first();
  225. $sku = GoodsSkus::where('goodsCode', $id)->where('is_del', 0)->get();
  226. return view('goods/edit', [
  227. 'goods' => $data,
  228. 'sku_list' => $sku,
  229. 'id' => $id,
  230. 'page' => $page,
  231. ]);
  232. }
  233. /**
  234. * 分组管理-进行编辑操作
  235. * @param Request $request
  236. * @return \Illuminate\Http\RedirectResponse
  237. */
  238. public function update(Request $request)
  239. {
  240. $id = (int)$request->input('id');
  241. $page = (int)$request->input('page');
  242. $this->validate($request, [
  243. 'id' => 'required',
  244. 'name' => 'required',
  245. //'productCode' => 'required|unique:goods,productCode,'.$id.',id',
  246. ], [
  247. 'id' => '非法操作',
  248. 'name.required' => '商品名不能为空',
  249. //'productCode.required' => '商品货号不能为空',
  250. ]);
  251. $del_sku_ids = trim($request->input('del_sku_ids'),',');
  252. $sku = $request->input('sku');
  253. //数据库-修改数据
  254. $goods = array();
  255. $goods['name'] = trim($request->input('name'));
  256. $goods['description'] = trim($request->input('description')); //非必填
  257. //$goods['productCode'] = trim($request->input('productCode'));
  258. //$goods['goodsCategoryName'] = trim($request->input('goodsCategoryName'));
  259. //图片上传 阿里云oss
  260. if ($request->hasFile('img') && $request->file('img')->isValid()) {
  261. $file = $request->file('img');
  262. $ossClient=new oss();
  263. // 上传阿里云
  264. $file = $ossClient->upload($file->getClientOriginalExtension(), $file->getRealPath(), 'upload/seafoodPic'.date("Y-m-d",time()).'/'.date('His'));
  265. $img=$file['oss-request-url'];
  266. $goods['picUrl']=str_replace("kx-youhuiquan.oss-cn-beijing.aliyuncs.com","imgs.726p.com",$img);
  267. }
  268. DB::beginTransaction();
  269. try{
  270. $res = DB::table('goods')->where('id', $id)->update($goods);
  271. if($res){
  272. //卖家云必要参数拼接转化
  273. $mjArr = array();
  274. $mjArr['eshopCode'] = config('constants.ESHOP_CODE');
  275. $mjArr['outerCode'] = $id;
  276. $mjArr['name'] = $goods['name'];
  277. $mjArr['description'] = $goods['description'];
  278. $mj = Order::mjGoodsUpdate($mjArr);
  279. //更新erp
  280. $erpArr = array();
  281. $goodsId = GoodsSkus::where('goodsCode', $id)->where('erpGoodsId','>',0)->first();
  282. if(!empty($goodsId)){
  283. $erpArr['goodsId'] = $goodsId->erpGoodsId;
  284. $erpArr['goodsName'] = $goods['name'];
  285. $mj = Order::mjErpGoodsUpdate($erpArr);
  286. }
  287. #记录操作日志
  288. $self_id = session('admin_id');
  289. $self_name = session('real_name');
  290. $context = "修改商品数据";
  291. $type = 0;
  292. $tables = 'goods,goods_skus';
  293. $data_id = $id;
  294. Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);
  295. }else{
  296. DB::rollback();
  297. return redirect('/admin/goods/index?page='.$page)->with('info', '未做任何修改');
  298. }
  299. DB::commit();
  300. }catch (Exception $e){
  301. DB::rollback();
  302. Log::errorLog($request,['error'=>$e->getMessage()],"goods/update",0,'');
  303. }
  304. return redirect('/admin/goods/index?page='.$page)->with('info', '更新成功');
  305. }
  306. /**
  307. * 下架操作
  308. * @param Request $request
  309. * @return \Illuminate\Http\RedirectResponse
  310. */
  311. public function down($id)
  312. {
  313. $goods = Goods::find($id);
  314. $goods->is_del = 1;
  315. if ($goods ->save()){
  316. GoodsSkus::where('goodsCode', $id)->update(['is_del'=>1]);
  317. #记录操作日志
  318. $self_id = session('admin_id');
  319. $self_name = session('real_name');
  320. $context = "下架商品";
  321. $type = 0;
  322. $tables = 'goods';
  323. $data_id = $id;
  324. Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);
  325. exit('1');
  326. }
  327. exit('0');
  328. }
  329. /**
  330. * 上架操作
  331. * @param Request $request
  332. * @return \Illuminate\Http\RedirectResponse
  333. */
  334. public function up($id)
  335. {
  336. $goods = Goods::find($id);
  337. $goods->is_del = 0;
  338. if ($goods ->save()){
  339. #记录操作日志
  340. $self_id = session('admin_id');
  341. $self_name = session('real_name');
  342. $context = "上架商品";
  343. $type = 0;
  344. $tables = 'goods';
  345. $data_id = $id;
  346. Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);
  347. exit('1');
  348. }
  349. exit('0');
  350. }
  351. /**
  352. * 下架操作
  353. * @param Request $request
  354. * @return \Illuminate\Http\RedirectResponse
  355. */
  356. public function delete($id)
  357. {
  358. $goods = Goods::find($id);
  359. $goods->is_del = 2;
  360. if ($goods ->save()){
  361. GoodsSkus::where('goodsCode', $id)->update(['is_del'=>2]);
  362. #记录操作日志
  363. $self_id = session('admin_id');
  364. $self_name = session('real_name');
  365. $context = "删除商品";
  366. $type = 0;
  367. $tables = 'goods';
  368. $data_id = $id;
  369. Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);
  370. exit('1');
  371. }
  372. exit('0');
  373. }
  374. /**
  375. * 搜索商品
  376. */
  377. public function searchSkus(Request $request){
  378. $name = trim($request->input('name'));
  379. if(!$name){
  380. exit('0');
  381. }
  382. $is_fx = env('IS_FX');
  383. $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();
  384. $result = json_decode(json_encode($result), true);
  385. foreach($result as $k=>&$v){
  386. //计算实际库存 -还未到卖家云的量
  387. $quantity_redis = GoodsSkus::actualQuantityByRedis($v['sku_id']);
  388. $v['quantity'] = $quantity_redis['quantity'];
  389. if($is_fx>0){
  390. //如果是分销,不展示没有库存的和白名单的
  391. if($v['quantity'] <= 0 || $v['is_white'] == 1){
  392. unset($result[$k]);
  393. }
  394. }
  395. }
  396. $result = array_values($result);
  397. if(empty($result)) exit('0');
  398. exit(json_encode($result));
  399. }
  400. /**
  401. * 单个商品sku列表
  402. */
  403. public function skuList(Request $request){
  404. $goods_id = $request->input('goods_id');
  405. $result = GoodsSkus::where('goodsCode', $goods_id)->where('is_del','<',2)->orderBy('id', 'desc')->get();
  406. foreach($result as $k=>&$item){
  407. $quantity_redis = GoodsSkus::actualQuantityByRedis($item->id);
  408. $item->quantity = $quantity_redis['quantity'];
  409. }
  410. return view('/goods/skulist', ['result'=>$result, 'goods_id' => $goods_id]);
  411. }
  412. /**
  413. * @return \Illuminate\View\View
  414. */
  415. public function skuCreate(Request $request)
  416. {
  417. $goods_id = $request->input('goods_id');
  418. return view('goods/skucreate', ['goods_id'=>$goods_id]);
  419. }
  420. /**
  421. * @param Request $request
  422. * @return \Illuminate\Http\RedirectResponse
  423. */
  424. public function skuStore(Request $request)
  425. {
  426. $this->validate($request, [
  427. 'propsName' => 'required',
  428. 'price' => 'required',
  429. 'referenceCost' => 'required',
  430. 'outPrice' => 'required',
  431. ], [
  432. 'propsName.required' => '规格不能为空',
  433. 'price.required' => '建议零售价不能为空',
  434. 'referenceCost.required' => '成本价不能为空',
  435. 'outPrice.required' => '分销商价格不能为空',
  436. ]);
  437. $goods_id = (int)$request->input('goods_id');
  438. $data = array();
  439. $data['goodsCode'] = $goods_id;
  440. $data['eshopCode'] = config('constants.ESHOP_CODE');
  441. $data['propsName'] = $request->input('propsName');
  442. $data['price'] = $request->input('price');
  443. $data['tagPrice'] = $data['price'];
  444. $data['referenceCost'] = $request->input('referenceCost');
  445. $data['is_weigh'] = (int)$request->input('is_weigh');
  446. $data['outPrice'] = $request->input('outPrice');
  447. //获取code
  448. //获取最大skucode
  449. $lastSku = DB::table('goods_skus')->select('code', 'erpGoodsId', 'eshopCode', 'goodsCode')->where('goodsCode', $goods_id)->orderBy('id', 'desc')->first();
  450. $code_arr = explode('-', $lastSku->code);
  451. $code_auto_num = (int)$code_arr[1];
  452. $pro_code = $code_arr[0];
  453. $data['code'] = $pro_code. '-0'. ($code_auto_num+1);
  454. DB::beginTransaction();
  455. try{
  456. $res = DB::table('goods_skus')->insertGetId($data);
  457. if($res){
  458. //增加erp sku
  459. $erpArr = array();
  460. $erpArr['goodsId'] = $lastSku->erpGoodsId; //erp商品id
  461. $erpArr['code'] = $data['code'];
  462. if($data['is_weigh'] == 1){
  463. $erpArr['propsName'] = $data['propsName'].'【按半斤称重】';
  464. $erpArr['price'] = round( $data['price']/2, 2 );
  465. $erpArr['tagPrice'] = round( $data['tagPrice']/2, 2 );
  466. $erpArr['referenceCost'] = round( $data['referenceCost']/2, 2 );
  467. }else{
  468. $erpArr['propsName'] = $data['propsName'];
  469. $erpArr['price'] = $data['price'];
  470. $erpArr['tagPrice'] = $data['tagPrice'];
  471. $erpArr['referenceCost'] = $data['referenceCost'];
  472. }
  473. $erp = Order::mjErpGoodsAdd($erpArr);
  474. if( $erp == false ){
  475. throw new Exception("erpSku同步到卖家云失败");
  476. }
  477. //更新erp信息到sku
  478. $params = array();
  479. $params['erpSkuId'] = $erp['skuId'];
  480. $params['erpGoodsId'] = $erp['goodsId'];
  481. $uperp = DB::table('goods_skus')->where('id', $res)->update($params);
  482. //增加shop sku
  483. $shopArr = array();
  484. $shopArr['outerCode'] = $res;
  485. $shopArr['eshopCode'] = $lastSku->eshopCode;
  486. $shopArr['goodsCode'] = $lastSku->goodsCode;
  487. $shopArr['propsName'] = $data['propsName'];
  488. $shopArr['price'] = $erpArr['price'];
  489. $shopArr['skuProductCode'] = $data['code'];
  490. $shopArr['createTime'] = date('Y-m-d H:i:s');
  491. $shopArr['modifyTime'] = $shopArr['createTime'];
  492. $sku_add = Order::mjSkuAdd($shopArr);
  493. if( $sku_add == false ){
  494. throw new Exception("店铺商品Sku同步到卖家云失败");
  495. }
  496. }
  497. DB::commit();
  498. }catch (Exception $e){
  499. DB::rollback();
  500. Log::errorLog($request,['error'=>$e->getMessage()],"sku/store",0,'');
  501. return redirect('/admin/goods/skulist?goods_id='.$goods_id)->with('info', $e->getMessage());
  502. }
  503. return redirect('/admin/goods/skulist?goods_id='.$goods_id)->with('info', '添加成功');
  504. }
  505. /**
  506. * @param $id
  507. * @return \Illuminate\View\View
  508. */
  509. public function skuEdit($id, Request $request)
  510. {
  511. $sku = DB::table('goods_skus')->where('id', $id)->first();
  512. $sku = json_decode(json_encode($sku),true);
  513. return view('goods/skuedit', ['sku' => $sku, 'goods_id' => $sku['goodsCode']]);
  514. }
  515. /**
  516. * @param Request $request
  517. * @return \Illuminate\Http\RedirectResponse
  518. */
  519. public function skuUpdate(Request $request)
  520. {
  521. $this->validate($request, [
  522. 'propsName' => 'required',
  523. 'price' => 'required',
  524. 'referenceCost' => 'required',
  525. 'outPrice' => 'required',
  526. ], [
  527. 'propsName.required' => '规格不能为空',
  528. 'price.required' => '建议零售价不能为空',
  529. 'referenceCost.required' => '成本价不能为空',
  530. 'outPrice.required' => '分销商价格不能为空',
  531. ]);
  532. $id = (int)$request->input('id');
  533. $goods_id = (int)$request->input('goods_id');
  534. $data = array();
  535. $data['propsName'] = $request->input('propsName');
  536. if($request->input('price') > 0) $data['price'] = $request->input('price');
  537. if($request->input('price') > 0) $data['tagPrice'] = $request->input('price');
  538. if($request->input('referenceCost') > 0) $data['referenceCost'] = $request->input('referenceCost');
  539. $data['is_weigh'] = (int)$request->input('is_weigh');
  540. if($request->input('outPrice') > 0) $data['outPrice'] = $request->input('outPrice');
  541. DB::beginTransaction();
  542. try{
  543. $res = DB::table('goods_skus')->where('id', $id)->update($data);
  544. if($res){
  545. # erp sku更新
  546. $sku = DB::table('goods_skus')->where('id', $id)->first();
  547. $erpArr = array();
  548. $erpArr['skuId'] = $sku->erpSkuId;
  549. if($data['is_weigh'] == 1){
  550. $erpArr['propsName'] = str_replace('【按半斤称重】', '', $sku->propsName).'【按半斤称重】';
  551. if($request->input('price') > 0) $erpArr['price'] = round( $sku->price/2, 2 );
  552. if($request->input('price') > 0) $erpArr['tagPrice'] = round( $sku->tagPrice/2, 2 );
  553. if($request->input('referenceCost') > 0) $erpArr['referenceCost'] = round( $sku->referenceCost/2, 2 );
  554. }else{
  555. $erpArr['propsName'] = str_replace('【按半斤称重】', '', $sku->propsName);
  556. if($request->input('price') > 0) $erpArr['price'] = $sku->price;
  557. if($request->input('price') > 0) $erpArr['tagPrice'] = $sku->tagPrice;
  558. if($request->input('referenceCost') > 0) $erpArr['referenceCost'] = $sku->referenceCost;
  559. }
  560. $erp_up = Order::mjErpSkuUpdate($erpArr);
  561. if( $erp_up == false ){
  562. throw new Exception("erpSku更新同步到卖家云失败");
  563. }
  564. # eshop sku更新
  565. $shopArr = array();
  566. $shopArr['eshopCode'] = $sku->eshopCode;
  567. $shopArr['goodsCode'] = $sku->goodsCode;
  568. $shopArr['outerCode'] = $sku->id;
  569. $shopArr['propsName'] = $sku->propsName;
  570. if($request->input('price') > 0) $shopArr['price'] = $erpArr['price'];
  571. $sku_up = Order::mjSkuUpdate($shopArr);
  572. if( $sku_up == false ){
  573. throw new Exception("店铺商品Sku更新同步到卖家云失败");
  574. }
  575. }
  576. DB::commit();
  577. }catch (Exception $e){
  578. DB::rollback();
  579. Log::errorLog($request,['error'=>$e->getMessage()],"sku/update",0,'');
  580. return redirect('/admin/goods/skulist?goods_id='.$goods_id)->with('info', $e->getMessage());
  581. }
  582. return redirect('/admin/goods/skulist?goods_id='.$goods_id)->with('info', '修改成功');
  583. }
  584. /**
  585. * 进行下架操作
  586. * @param Request $request
  587. * @return \Illuminate\Http\RedirectResponse
  588. */
  589. public function skuDel($id)
  590. {
  591. $goods = GoodsSkus::find($id);
  592. $goods->is_del = 1;
  593. if ($goods ->save()){
  594. #记录操作日志
  595. $self_id = session('admin_id');
  596. $self_name = session('real_name');
  597. $context = "下架sku";
  598. $type = 0;
  599. $tables = 'goods_skus';
  600. $data_id = $id;
  601. Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);
  602. exit('1');
  603. }
  604. exit('0');
  605. }
  606. /**
  607. * 进行上架操作
  608. * @param Request $request
  609. * @return \Illuminate\Http\RedirectResponse
  610. */
  611. public function skuUp($id)
  612. {
  613. $goods = GoodsSkus::find($id);
  614. $goods->is_del = 0;
  615. if ($goods ->save()){
  616. #记录操作日志
  617. $self_id = session('admin_id');
  618. $self_name = session('real_name');
  619. $context = "上架sku";
  620. $type = 0;
  621. $tables = 'goods_skus';
  622. $data_id = $id;
  623. Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);
  624. exit('1');
  625. }
  626. exit('0');
  627. }
  628. /**
  629. * 进行删除操作
  630. * @param Request $request
  631. * @return \Illuminate\Http\RedirectResponse
  632. */
  633. public function skuDelete($id)
  634. {
  635. $goods = GoodsSkus::find($id);
  636. $goods->is_del = 2;
  637. if ($goods ->save()){
  638. #记录操作日志
  639. $self_id = session('admin_id');
  640. $self_name = session('real_name');
  641. $context = "删除sku";
  642. $type = 0;
  643. $tables = 'goods_skus';
  644. $data_id = $id;
  645. Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);
  646. exit('1');
  647. }
  648. exit('0');
  649. }
  650. /**
  651. * 分销商商品列表
  652. * @param Request $request
  653. * @return \Illuminate\View\View
  654. */
  655. public function indexCopy(Request $request){
  656. //获取分类
  657. $cates = DB::table('categorys')->lists('name', 'id');
  658. //获取请求参数
  659. $name = trim($request->input('name',''));
  660. $cate_name = trim($request->input('cate_name',''));
  661. $status = $request->input('status','-1');
  662. $realQuantity = $request->input('quantity','-1');
  663. $outPrice = $request->input('outPrice','-1');
  664. $page = (int)$request->input('page','1');
  665. $pageSize = 20;
  666. //若有请求参数,初步查询处理
  667. $goodsIds = array();
  668. if($name || $cate_name || ($status != '-1')){
  669. $goodsIds = Goods::where(function($query) use($name, $cate_name, $status){
  670. if($name) $query->where('name', 'like', '%'.$name.'%');
  671. if($cate_name) $query->where('goodsCategoryName', '=', $cate_name);
  672. #先筛选商品的状态
  673. if($status != '-1') {
  674. $query->where('is_del',$status);
  675. } else {
  676. $query->whereIn('is_del',array(0,1));
  677. }
  678. })->lists('id');
  679. //TODO 无搜索结果,直接返回空,添加检索框以后不要忘了修改这里
  680. if(count($goodsIds) == 0){
  681. return view('goods/indexcopy', ['result' =>[],
  682. 'page' =>$page,
  683. 'count' =>0,
  684. 'pages' =>1,
  685. 'name' =>$name,
  686. 'cate_name' =>$cate_name,
  687. 'cates' =>$cates,
  688. 'status' =>$status,
  689. 'quantity' =>$realQuantity,
  690. 'outPrice' =>$outPrice,
  691. ]);
  692. }
  693. }
  694. //筛选所有可用库存大于0的规格id
  695. $actualSkuList = array();
  696. if($realQuantity != '-1'){
  697. $actualSkuList = GoodsSkus::actualQuantityNotNull();
  698. }
  699. //获取数据总条数
  700. $count = GoodsSkus::where(function($query) use ($goodsIds,$status,$realQuantity,$outPrice,$actualSkuList){
  701. if(count($goodsIds) > 1){
  702. $query->whereIn('goodsCode',$goodsIds);
  703. }else if(count($goodsIds) == 1){
  704. $query->where('goodsCode',$goodsIds);
  705. }
  706. if($status != '-1') {
  707. if($status != 1){
  708. //筛选上架商品,先筛选出上架的商品id,这些商品id对应的规格有些事上架状态,有些是下架状态,然后再筛选这些上架商品规格当中上架的规格
  709. $query->where('is_del',0);
  710. } else {
  711. //筛选下架商品,先筛选出下架的商品id,这些商品id对应的规格一定都是下架状态,但是上架的商品当中也有部分规格是下架状态,所有用or把这些规格加进来
  712. $query->orWhere('is_del',1);
  713. }
  714. } else {
  715. $query->whereIn('is_del',array(0,1));
  716. }
  717. if($realQuantity != '-1') $query->whereIn('id',$actualSkuList);
  718. if($outPrice != '-1') $query->where('outPrice','>','0');
  719. })->count();
  720. //分页数据处理
  721. if ($count > 1) {
  722. // 总页数
  723. $pages = ceil($count/$pageSize);
  724. }else{
  725. // 总页数
  726. $pages = 1;
  727. }
  728. //获取数据项
  729. $offset = ($page-1) * $pageSize;
  730. $result = GoodsSkus::where(function($query) use ($goodsIds,$status,$realQuantity,$outPrice,$actualSkuList){
  731. if(count($goodsIds) > 1){
  732. $query->whereIn('goodsCode',$goodsIds);
  733. } else if(count($goodsIds) == 1){
  734. $query->where('goodsCode',$goodsIds);
  735. }
  736. if($status != '-1') {
  737. if($status != 1){
  738. //筛选上架商品,先筛选出上架的商品id,这些商品id对应的规格有些事上架状态,有些是下架状态,然后再筛选这些上架商品规格当中上架的规格
  739. $query->where('is_del',0);
  740. } else {
  741. //筛选下架商品,先筛选出下架的商品id,这些商品id对应的规格一定都是下架状态,但是上架的商品当中也有部分规格是下架状态,所有用or把这些规格加进来
  742. $query->orWhere('is_del',1);
  743. }
  744. } else {
  745. $query->whereIn('is_del',array(0,1));
  746. }
  747. if($realQuantity != '-1') $query->whereIn('id',$actualSkuList);
  748. if($outPrice != '-1') $query->where('outPrice','>','0');
  749. })->orderBy('goodsCode', 'desc')->offset($offset)->limit($pageSize)->get();
  750. $result = json_decode(json_encode($result),true);
  751. //对数据项进行处理
  752. foreach($result as $k=>&$v){
  753. # 获取goods信息
  754. $goodsInfo = Goods::where('id', $v['goodsCode'])->first();
  755. $quantity = GoodsSkus::actualQuantityByRedis($v['id']);
  756. $v['real_quantity'] = $quantity['quantity'];
  757. $v['pre_quantity'] = $quantity['w_num'];
  758. $v['total_quantity'] = $v['quantity'];
  759. $v['name'] = $goodsInfo->name;
  760. $v['goodsCategoryName'] = $goodsInfo->goodsCategoryName;
  761. if($goodsInfo->is_del == 1){
  762. $v['is_del'] = 1;
  763. }
  764. }
  765. //返回给页面
  766. return view('goods/indexcopy', [
  767. 'result' =>$result,
  768. 'page' =>$page,
  769. 'count' =>$count,
  770. 'pages' =>$pages,
  771. 'name' =>$name,
  772. 'cate_name' =>$cate_name,
  773. 'cates' =>$cates,
  774. 'status' =>$status,
  775. 'quantity' =>$realQuantity,
  776. 'outPrice' =>$outPrice,
  777. ]);
  778. }
  779. /**
  780. * 分销商品列表导出
  781. * @param Request $request
  782. * @return bool|\Illuminate\Http\RedirectResponse
  783. */
  784. public function indexCopyExport(Request $request){
  785. //获取请求参数
  786. $name = trim($request->input('name',''));
  787. $cate_name = trim($request->input('cate_name',''));
  788. $status = $request->input('status','-1');
  789. $realQuantity = $request->input('quantity','-1');
  790. $outPrice = $request->input('outPrice','-1');
  791. //若有请求参数,初步获取查询结果
  792. $goodsIds = array();
  793. if($name || $cate_name || ($status != '-1')){
  794. $goodsIds = Goods::where(function($query) use($name, $cate_name, $status){
  795. if($name) $query->where('name', 'like', '%'.$name.'%');
  796. if($cate_name) $query->where('goodsCategoryName', '=', $cate_name);
  797. if($status != '-1') {
  798. $query->where('is_del',$status);
  799. } else {
  800. $query->whereIn('is_del',array(0,1));
  801. }
  802. })->lists('id');
  803. //无查询结果,直接返回空
  804. if(count($goodsIds) == 0){
  805. return back()->with('info','没有商品可导出');
  806. }
  807. }
  808. //筛选所有可用库存大于0的规格id
  809. $actualSkuList = array();
  810. if($realQuantity != '-1'){
  811. $actualSkuList = GoodsSkus::actualQuantityNotNull();
  812. }
  813. //进一步获取数据查询结果
  814. $result = GoodsSkus::where(function($query) use ($goodsIds,$status,$realQuantity,$outPrice,$actualSkuList){
  815. if(count($goodsIds) > 1){
  816. $query->whereIn('goodsCode',$goodsIds);
  817. }else if(count($goodsIds) == 1){
  818. $query->where('goodsCode',$goodsIds);
  819. }
  820. if($status != '-1') {
  821. if($status != 1){
  822. //筛选上架商品,先筛选出上架的商品id,这些商品id对应的规格有些事上架状态,有些是下架状态,然后再筛选这些上架商品规格当中上架的规格
  823. $query->where('is_del',0);
  824. } else {
  825. //筛选下架商品,先筛选出下架的商品id,这些商品id对应的规格一定都是下架状态,但是上架的商品当中也有部分规格是下架状态,所有用or把这些规格加进来
  826. $query->orWhere('is_del',1);
  827. }
  828. } else {
  829. $query->whereIn('is_del',array(0,1));
  830. }
  831. if($realQuantity != '-1') $query->whereIn('id',$actualSkuList);
  832. if($outPrice != '-1') $query->where('outPrice','>','0');
  833. })->orderBy('goodsCode', 'desc')->get();
  834. $result = json_decode(json_encode($result),true);
  835. //对数据查询结果处理
  836. foreach($result as $k=>&$v){
  837. # 获取goods信息
  838. $goodsInfo = Goods::where('id', $v['goodsCode'])->first();
  839. $quantity = GoodsSkus::actualQuantityByRedis($v['id']);
  840. $v['real_quantity'] = $quantity['quantity'];
  841. $v['pre_quantity'] = $quantity['w_num'];
  842. $v['total_quantity'] = $v['quantity'];
  843. $v['name'] = $goodsInfo->name;
  844. $v['goodsCategoryName'] = $goodsInfo->goodsCategoryName;
  845. if($goodsInfo->is_del == 1){
  846. $v['is_del'] = 1;
  847. }
  848. if($v['is_del'] == 1){
  849. $v['status'] = '已下架';
  850. } else {
  851. $v['status'] = '已上架';
  852. }
  853. }
  854. //将数据查询结果通过导出excel方法导出到浏览器
  855. $indexKey = ['goodsCategoryName','name','propsName','code','referenceCost','outPrice','price','status','createTime','real_quantity','total_quantity','pre_quantity'];
  856. $title = ['商品分类', '商品名称', '商品规格', '规格编码','成本价','分销商价格','建议零售价','上架状态','上架时间','可用库存','总库存','预占用库存'];
  857. $filename = 'goods_sku_export_'.date('Y-m-d_H').'.xlsx';
  858. return Order::export_excel($result, $filename, $indexKey, $title);
  859. }
  860. /**
  861. * 编辑建议零售价或者分销商价格
  862. * @param Request $request
  863. */
  864. public function editGoodsSku(Request $request){
  865. $id = $request->input('id');
  866. $outPrice = trim($request->input('outPrice'));
  867. $price = trim($request->input('price'));
  868. $referenceCost = trim($request->input('referenceCost'));
  869. if($outPrice){
  870. $res = GoodsSkus::where('id',$id)->update(['outPrice'=>$outPrice]);
  871. if($res) return 0;
  872. }
  873. $skus = GoodsSkus::find($id);
  874. if($price){
  875. $res = GoodsSkus::where('id',$id)->update(['price'=>$price]);
  876. //更新erp系统sku
  877. $erpArr['skuId'] = $skus->erpSkuId;
  878. $erpArr['price'] = $price;
  879. $erp_up = Order::mjErpSkuUpdate($erpArr);
  880. // if( $erp_up == false ){
  881. //// $flag[] = 'erpSku更新同步到卖家云失败';
  882. // throw new \Exception("erpSku更新同步到卖家云失败");
  883. // }
  884. //更新店铺中sku
  885. $shopArr['eshopCode'] = config('constants.ESHOP_CODE');
  886. $shopArr['goodsCode'] = $skus->goodsCode;
  887. $shopArr['outerCode'] = $skus->id;
  888. $shopArr['price'] = $price;
  889. $sku_up = Order::mjSkuUpdate($shopArr);
  890. // if( $sku_up == false ){
  891. //// $flag[] = '店铺商品Sku更新同步到卖家云失败';
  892. // throw new \Exception("店铺商品Sku更新同步到卖家云失败");
  893. // }
  894. if($res) return 0;
  895. }
  896. if($referenceCost){
  897. $res = GoodsSkus::where('id',$id)->update(['referenceCost'=>$referenceCost]);
  898. //更新erp系统sku
  899. $erpArr['skuId'] = $skus->erpSkuId;
  900. $erpArr['referenceCost'] = $referenceCost;
  901. $erp_up = Order::mjErpSkuUpdate($erpArr);
  902. // if( $erp_up == false ){
  903. //// $flag[] = 'erpSku更新同步到卖家云失败';
  904. // throw new \Exception("erpSku更新同步到卖家云失败");
  905. // }
  906. if($res) return 0;
  907. }
  908. return 1;
  909. }
  910. /**
  911. * 分销商商品列表
  912. * @param Request $request
  913. * @return \Illuminate\View\View
  914. */
  915. public function goodsIndex(Request $request){
  916. //获取分类
  917. $cates = DB::table('categorys')->lists('name', 'id');
  918. //获取请求参数
  919. $name = trim($request->input('name',''));
  920. $cate_name = trim($request->input('cate_name',''));
  921. $status = $request->input('status','-1');
  922. $realQuantity = $request->input('quantity','-1');
  923. $outPrice = $request->input('outPrice','-1');
  924. $page = (int)$request->input('page','1');
  925. $pageSize = 20;
  926. //若有请求参数,初步查询处理
  927. $goodsIds = array();
  928. if($name || $cate_name || ($status != '-1')){
  929. $goodsIds = Goods::where(function($query) use($name, $cate_name, $status){
  930. if($name) $query->where('name', 'like', '%'.$name.'%');
  931. if($cate_name) $query->where('goodsCategoryName', '=', $cate_name);
  932. #先筛选商品的状态
  933. if($status != '-1') {
  934. $query->where('is_del',$status);
  935. } else {
  936. $query->whereIn('is_del',array(0,1));
  937. }
  938. })->lists('id');
  939. //TODO 无搜索结果,直接返回空,添加检索框以后不要忘了修改这里
  940. if(count($goodsIds) == 0){
  941. return view('goods/indexcopy', ['result' =>[],
  942. 'page' =>$page,
  943. 'count' =>0,
  944. 'pages' =>1,
  945. 'name' =>$name,
  946. 'cate_name' =>$cate_name,
  947. 'cates' =>$cates,
  948. 'status' =>$status,
  949. 'quantity' =>$realQuantity,
  950. 'outPrice' =>$outPrice,
  951. ]);
  952. }
  953. }
  954. //筛选所有可用库存大于0的规格id
  955. $actualSkuList = array();
  956. if($realQuantity != '-1'){
  957. $actualSkuList = GoodsSkus::actualQuantityNotNull();
  958. }
  959. //获取数据总条数
  960. $count = GoodsSkus::where(function($query) use ($goodsIds,$status,$realQuantity,$outPrice,$actualSkuList){
  961. if(count($goodsIds) > 1){
  962. $query->whereIn('goodsCode',$goodsIds);
  963. }else if(count($goodsIds) == 1){
  964. $query->where('goodsCode',$goodsIds);
  965. }
  966. if($status != '-1') {
  967. if($status != 1){
  968. //筛选上架商品,先筛选出上架的商品id,这些商品id对应的规格有些事上架状态,有些是下架状态,然后再筛选这些上架商品规格当中上架的规格
  969. $query->where('is_del',0);
  970. } else {
  971. //筛选下架商品,先筛选出下架的商品id,这些商品id对应的规格一定都是下架状态,但是上架的商品当中也有部分规格是下架状态,所有用or把这些规格加进来
  972. $query->orWhere('is_del',1);
  973. }
  974. } else {
  975. $query->whereIn('is_del',array(0,1));
  976. }
  977. if($realQuantity != '-1') $query->whereIn('id',$actualSkuList);
  978. if($outPrice != '-1') $query->where('outPrice','>','0');
  979. })->count();
  980. //分页数据处理
  981. if ($count > 1) {
  982. // 总页数
  983. $pages = ceil($count/$pageSize);
  984. }else{
  985. // 总页数
  986. $pages = 1;
  987. }
  988. //获取数据项
  989. $offset = ($page-1) * $pageSize;
  990. $result = GoodsSkus::where(function($query) use ($goodsIds,$status,$realQuantity,$outPrice,$actualSkuList){
  991. if(count($goodsIds) > 1){
  992. $query->whereIn('goodsCode',$goodsIds);
  993. } else if(count($goodsIds) == 1){
  994. $query->where('goodsCode',$goodsIds);
  995. }
  996. if($status != '-1') {
  997. if($status != 1){
  998. //筛选上架商品,先筛选出上架的商品id,这些商品id对应的规格有些事上架状态,有些是下架状态,然后再筛选这些上架商品规格当中上架的规格
  999. $query->where('is_del',0);
  1000. } else {
  1001. //筛选下架商品,先筛选出下架的商品id,这些商品id对应的规格一定都是下架状态,但是上架的商品当中也有部分规格是下架状态,所有用or把这些规格加进来
  1002. $query->orWhere('is_del',1);
  1003. }
  1004. } else {
  1005. $query->whereIn('is_del',array(0,1));
  1006. }
  1007. if($realQuantity != '-1') $query->whereIn('id',$actualSkuList);
  1008. if($outPrice != '-1') $query->where('outPrice','>','0');
  1009. })->orderBy('goodsCode', 'desc')->offset($offset)->limit($pageSize)->get();
  1010. $result = json_decode(json_encode($result),true);
  1011. //对数据项进行处理
  1012. foreach($result as $k=>&$v){
  1013. # 获取goods信息
  1014. $goodsInfo = Goods::where('id', $v['goodsCode'])->first();
  1015. $quantity = GoodsSkus::actualQuantityByRedis($v['id']);
  1016. $v['real_quantity'] = $quantity['quantity'];
  1017. $v['pre_quantity'] = $quantity['w_num'];
  1018. $v['total_quantity'] = $v['quantity'];
  1019. $v['name'] = $goodsInfo->name;
  1020. $v['goodsCategoryName'] = $goodsInfo->goodsCategoryName;
  1021. if($goodsInfo->is_del == 1){
  1022. $v['is_del'] = 1;
  1023. }
  1024. }
  1025. //返回给页面
  1026. return view('goods/goodsindex', [
  1027. 'result' =>$result,
  1028. 'page' =>$page,
  1029. 'count' =>$count,
  1030. 'pages' =>$pages,
  1031. 'name' =>$name,
  1032. 'cate_name' =>$cate_name,
  1033. 'cates' =>$cates,
  1034. 'status' =>$status,
  1035. 'quantity' =>$realQuantity,
  1036. 'outPrice' =>$outPrice,
  1037. ]);
  1038. }
  1039. /**
  1040. * 分销商品列表导出
  1041. * @param Request $request
  1042. * @return bool|\Illuminate\Http\RedirectResponse
  1043. */
  1044. public function goodsIndexExport(Request $request){
  1045. //获取请求参数
  1046. $name = trim($request->input('name',''));
  1047. $cate_name = trim($request->input('cate_name',''));
  1048. $status = $request->input('status','-1');
  1049. $realQuantity = $request->input('quantity','-1');
  1050. $outPrice = $request->input('outPrice','-1');
  1051. //若有请求参数,初步获取查询结果
  1052. $goodsIds = array();
  1053. if($name || $cate_name || ($status != '-1')){
  1054. $goodsIds = Goods::where(function($query) use($name, $cate_name, $status){
  1055. if($name) $query->where('name', 'like', '%'.$name.'%');
  1056. if($cate_name) $query->where('goodsCategoryName', '=', $cate_name);
  1057. if($status != '-1') {
  1058. $query->where('is_del',$status);
  1059. } else {
  1060. $query->whereIn('is_del',array(0,1));
  1061. }
  1062. })->lists('id');
  1063. //无查询结果,直接返回空
  1064. if(count($goodsIds) == 0){
  1065. return back()->with('info','没有商品可导出');
  1066. }
  1067. }
  1068. //筛选所有可用库存大于0的规格id
  1069. $actualSkuList = array();
  1070. if($realQuantity != '-1'){
  1071. $actualSkuList = GoodsSkus::actualQuantityNotNull();
  1072. }
  1073. //进一步获取数据查询结果
  1074. $result = GoodsSkus::where(function($query) use ($goodsIds,$status,$realQuantity,$outPrice,$actualSkuList){
  1075. if(count($goodsIds) > 1){
  1076. $query->whereIn('goodsCode',$goodsIds);
  1077. }else if(count($goodsIds) == 1){
  1078. $query->where('goodsCode',$goodsIds);
  1079. }
  1080. if($status != '-1') {
  1081. if($status != 1){
  1082. //筛选上架商品,先筛选出上架的商品id,这些商品id对应的规格有些事上架状态,有些是下架状态,然后再筛选这些上架商品规格当中上架的规格
  1083. $query->where('is_del',0);
  1084. } else {
  1085. //筛选下架商品,先筛选出下架的商品id,这些商品id对应的规格一定都是下架状态,但是上架的商品当中也有部分规格是下架状态,所有用or把这些规格加进来
  1086. $query->orWhere('is_del',1);
  1087. }
  1088. } else {
  1089. $query->whereIn('is_del',array(0,1));
  1090. }
  1091. if($realQuantity != '-1') $query->whereIn('id',$actualSkuList);
  1092. if($outPrice != '-1') $query->where('outPrice','>','0');
  1093. })->orderBy('goodsCode', 'desc')->get();
  1094. $result = json_decode(json_encode($result),true);
  1095. //对数据查询结果处理
  1096. foreach($result as $k=>&$v){
  1097. # 获取goods信息
  1098. $goodsInfo = Goods::where('id', $v['goodsCode'])->first();
  1099. $quantity = GoodsSkus::actualQuantityByRedis($v['id']);
  1100. $v['real_quantity'] = $quantity['quantity'];
  1101. $v['pre_quantity'] = $quantity['w_num'];
  1102. $v['total_quantity'] = $v['quantity'];
  1103. $v['name'] = $goodsInfo->name;
  1104. $v['goodsCategoryName'] = $goodsInfo->goodsCategoryName;
  1105. if($goodsInfo->is_del == 1){
  1106. $v['is_del'] = 1;
  1107. }
  1108. if($v['is_del'] == 1){
  1109. $v['status'] = '已下架';
  1110. } else {
  1111. $v['status'] = '已上架';
  1112. }
  1113. }
  1114. //将数据查询结果通过导出excel方法导出到浏览器
  1115. $indexKey = ['goodsCategoryName','name','propsName','code','price','outPrice','status','createTime','real_quantity','total_quantity','pre_quantity'];
  1116. $title = ['商品分类', '商品名称', '商品规格', '规格编码','建议零售价','分销商价格','上架状态','上架时间','可用库存','总库存','预占用库存'];
  1117. $filename = 'goods_sku_export_'.date('Y-m-d_H').'.xlsx';
  1118. return Order::export_excel($result, $filename, $indexKey, $title);
  1119. }
  1120. }