Bez popisu

GoodsController.php 34KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858
  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. })->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. })->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. $data = Goods::where('id', $id)->first();
  224. $sku = GoodsSkus::where('goodsCode', $id)->where('is_del', 0)->get();
  225. return view('goods/edit', [
  226. 'goods' => $data,
  227. 'sku_list' => $sku,
  228. 'id' => $id,
  229. ]);
  230. }
  231. /**
  232. * 分组管理-进行编辑操作
  233. * @param Request $request
  234. * @return \Illuminate\Http\RedirectResponse
  235. */
  236. public function update(Request $request)
  237. {
  238. $id = (int)$request->input('id');
  239. $this->validate($request, [
  240. 'id' => 'required',
  241. 'name' => 'required',
  242. //'productCode' => 'required|unique:goods,productCode,'.$id.',id',
  243. ], [
  244. 'id' => '非法操作',
  245. 'name.required' => '商品名不能为空',
  246. //'productCode.required' => '商品货号不能为空',
  247. ]);
  248. $del_sku_ids = trim($request->input('del_sku_ids'),',');
  249. $sku = $request->input('sku');
  250. //数据库-修改数据
  251. $goods = array();
  252. $goods['name'] = trim($request->input('name'));
  253. $goods['description'] = trim($request->input('description')); //非必填
  254. //$goods['productCode'] = trim($request->input('productCode'));
  255. //$goods['goodsCategoryName'] = trim($request->input('goodsCategoryName'));
  256. //图片上传 阿里云oss
  257. if ($request->hasFile('img') && $request->file('img')->isValid()) {
  258. $file = $request->file('img');
  259. $ossClient=new oss();
  260. // 上传阿里云
  261. $file = $ossClient->upload($file->getClientOriginalExtension(), $file->getRealPath(), 'upload/seafoodPic'.date("Y-m-d",time()).'/'.date('His'));
  262. $img=$file['oss-request-url'];
  263. $goods['picUrl']=str_replace("kx-youhuiquan.oss-cn-beijing.aliyuncs.com","imgs.726p.com",$img);
  264. }
  265. DB::beginTransaction();
  266. try{
  267. $res = DB::table('goods')->where('id', $id)->update($goods);
  268. if($res){
  269. //卖家云必要参数拼接转化
  270. $mjArr = array();
  271. $mjArr['eshopCode'] = config('constants.ESHOP_CODE');
  272. $mjArr['outerCode'] = $id;
  273. $mjArr['name'] = $goods['name'];
  274. $mjArr['description'] = $goods['description'];
  275. $mj = Order::mjGoodsUpdate($mjArr);
  276. //更新erp
  277. $erpArr = array();
  278. $goodsId = GoodsSkus::where('goodsCode', $id)->where('erpGoodsId','>',0)->first();
  279. if(!empty($goodsId)){
  280. $erpArr['goodsId'] = $goodsId->erpGoodsId;
  281. $erpArr['goodsName'] = $goods['name'];
  282. $mj = Order::mjErpGoodsUpdate($erpArr);
  283. }
  284. #记录操作日志
  285. $self_id = session('admin_id');
  286. $self_name = session('real_name');
  287. $context = "修改商品数据";
  288. $type = 0;
  289. $tables = 'goods,goods_skus';
  290. $data_id = $id;
  291. Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);
  292. }else{
  293. DB::rollback();
  294. return redirect('/admin/goods/index')->with('info', '未做任何修改');
  295. }
  296. DB::commit();
  297. }catch (Exception $e){
  298. DB::rollback();
  299. Log::errorLog($request,['error'=>$e->getMessage()],"goods/update",0,'');
  300. }
  301. return redirect('/admin/goods/index')->with('info', '更新成功');
  302. }
  303. /**
  304. * 下架操作
  305. * @param Request $request
  306. * @return \Illuminate\Http\RedirectResponse
  307. */
  308. public function delete($id)
  309. {
  310. $goods = Goods::find($id);
  311. $goods->is_del = 1;
  312. if ($goods ->save()){
  313. #记录操作日志
  314. $self_id = session('admin_id');
  315. $self_name = session('real_name');
  316. $context = "下架商品";
  317. $type = 0;
  318. $tables = 'goods';
  319. $data_id = $id;
  320. Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);
  321. exit('1');
  322. }
  323. exit('0');
  324. }
  325. /**
  326. * 上架操作
  327. * @param Request $request
  328. * @return \Illuminate\Http\RedirectResponse
  329. */
  330. public function up($id)
  331. {
  332. $goods = Goods::find($id);
  333. $goods->is_del = 0;
  334. if ($goods ->save()){
  335. #记录操作日志
  336. $self_id = session('admin_id');
  337. $self_name = session('real_name');
  338. $context = "上架商品";
  339. $type = 0;
  340. $tables = 'goods';
  341. $data_id = $id;
  342. Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);
  343. exit('1');
  344. }
  345. exit('0');
  346. }
  347. /**
  348. * 搜索商品
  349. */
  350. public function searchSkus(Request $request){
  351. $name = trim($request->input('name'));
  352. if(!$name){
  353. exit('0');
  354. }
  355. $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();
  356. $result = json_decode(json_encode($result), true);
  357. foreach($result as $k=>&$v){
  358. //计算实际库存 -还未到卖家云的量
  359. $quantity_redis = GoodsSkus::actualQuantityByRedis($v['sku_id']);
  360. $v['quantity'] = $quantity_redis['quantity'];
  361. }
  362. if(empty($result)) exit('0');
  363. exit(json_encode($result));
  364. }
  365. /**
  366. * 单个商品sku列表
  367. */
  368. public function skuList(Request $request){
  369. $goods_id = $request->input('goods_id');
  370. $result = GoodsSkus::where('goodsCode', $goods_id)->orderBy('id', 'desc')->get();
  371. foreach($result as $k=>&$item){
  372. $quantity_redis = GoodsSkus::actualQuantityByRedis($item->id);
  373. $item->quantity = $quantity_redis['quantity'];
  374. }
  375. return view('/goods/skulist', ['result'=>$result, 'goods_id' => $goods_id]);
  376. }
  377. /**
  378. * @return \Illuminate\View\View
  379. */
  380. public function skuCreate(Request $request)
  381. {
  382. $goods_id = $request->input('goods_id');
  383. return view('goods/skucreate', ['goods_id'=>$goods_id]);
  384. }
  385. /**
  386. * @param Request $request
  387. * @return \Illuminate\Http\RedirectResponse
  388. */
  389. public function skuStore(Request $request)
  390. {
  391. $this->validate($request, [
  392. 'propsName' => 'required',
  393. 'price' => 'required',
  394. ], [
  395. 'propsName.required' => '规格不能为空',
  396. 'price.required' => '价格不能为空',
  397. ]);
  398. $goods_id = (int)$request->input('goods_id');
  399. $data = array();
  400. $data['goodsCode'] = $goods_id;
  401. $data['eshopCode'] = config('constants.ESHOP_CODE');
  402. $data['propsName'] = $request->input('propsName');
  403. $data['price'] = $request->input('price');
  404. $data['tagPrice'] = $request->input('tagPrice');
  405. $data['referenceCost'] = $request->input('referenceCost');
  406. $data['is_weigh'] = (int)$request->input('is_weigh');
  407. $data['outPrice'] = $request->input('outPrice');
  408. //获取code
  409. //获取最大skucode
  410. $lastSku = DB::table('goods_skus')->select('code', 'erpGoodsId', 'eshopCode', 'goodsCode')->where('goodsCode', $goods_id)->orderBy('id', 'desc')->first();
  411. $code_arr = explode('-', $lastSku->code);
  412. $code_auto_num = (int)$code_arr[1];
  413. $pro_code = $code_arr[0];
  414. $data['code'] = $pro_code. '-0'. ($code_auto_num+1);
  415. DB::beginTransaction();
  416. try{
  417. $res = DB::table('goods_skus')->insertGetId($data);
  418. if($res){
  419. //增加erp sku
  420. $erpArr = array();
  421. $erpArr['goodsId'] = $lastSku->erpGoodsId; //erp商品id
  422. $erpArr['code'] = $data['code'];
  423. if($data['is_weigh'] == 1){
  424. $erpArr['propsName'] = $data['propsName'].'【按半斤称重】';
  425. $erpArr['price'] = round( $data['price']/2, 2 );
  426. $erpArr['tagPrice'] = round( $data['tagPrice']/2, 2 );
  427. $erpArr['referenceCost'] = round( $data['referenceCost']/2, 2 );
  428. }else{
  429. $erpArr['propsName'] = $data['propsName'];
  430. $erpArr['price'] = $data['price'];
  431. $erpArr['tagPrice'] = $data['tagPrice'];
  432. $erpArr['referenceCost'] = $data['referenceCost'];
  433. }
  434. $erp = Order::mjErpGoodsAdd($erpArr);
  435. if( $erp == false ){
  436. throw new Exception("erpSku同步到卖家云失败");
  437. }
  438. //更新erp信息到sku
  439. $params = array();
  440. $params['erpSkuId'] = $erp['skuId'];
  441. $params['erpGoodsId'] = $erp['goodsId'];
  442. $uperp = DB::table('goods_skus')->where('id', $res)->update($params);
  443. //增加shop sku
  444. $shopArr = array();
  445. $shopArr['outerCode'] = $res;
  446. $shopArr['eshopCode'] = $lastSku->eshopCode;
  447. $shopArr['goodsCode'] = $lastSku->goodsCode;
  448. $shopArr['propsName'] = $data['propsName'];
  449. $shopArr['price'] = $erpArr['price'];
  450. $shopArr['skuProductCode'] = $data['code'];
  451. $shopArr['createTime'] = date('Y-m-d H:i:s');
  452. $shopArr['modifyTime'] = $shopArr['createTime'];
  453. $sku_add = Order::mjSkuAdd($shopArr);
  454. if( $sku_add == false ){
  455. throw new Exception("店铺商品Sku同步到卖家云失败");
  456. }
  457. }
  458. DB::commit();
  459. }catch (Exception $e){
  460. DB::rollback();
  461. Log::errorLog($request,['error'=>$e->getMessage()],"sku/store",0,'');
  462. return redirect('/admin/goods/skulist?goods_id='.$goods_id)->with('info', $e->getMessage());
  463. }
  464. return redirect('/admin/goods/skulist?goods_id='.$goods_id)->with('info', '添加成功');
  465. }
  466. /**
  467. * @param $id
  468. * @return \Illuminate\View\View
  469. */
  470. public function skuEdit($id, Request $request)
  471. {
  472. $sku = DB::table('goods_skus')->where('id', $id)->first();
  473. $sku = json_decode(json_encode($sku),true);
  474. return view('goods/skuedit', ['sku' => $sku, 'goods_id' => $sku['goodsCode']]);
  475. }
  476. /**
  477. * @param Request $request
  478. * @return \Illuminate\Http\RedirectResponse
  479. */
  480. public function skuUpdate(Request $request)
  481. {
  482. $this->validate($request, [
  483. 'propsName' => 'required',
  484. //'price' => 'required',
  485. ], [
  486. 'propsName.required' => '规格不能为空',
  487. //'price.required' => '价格不能为空',
  488. ]);
  489. $id = (int)$request->input('id');
  490. $goods_id = (int)$request->input('goods_id');
  491. $data = array();
  492. $data['propsName'] = $request->input('propsName');
  493. if($request->input('price') > 0) $data['price'] = $request->input('price');
  494. if($request->input('tagPrice') > 0) $data['tagPrice'] = $request->input('tagPrice');
  495. if($request->input('referenceCost') > 0) $data['referenceCost'] = $request->input('referenceCost');
  496. $data['is_weigh'] = (int)$request->input('is_weigh');
  497. if($request->input('outPrice') > 0) $data['outPrice'] = $request->input('outPrice');
  498. DB::beginTransaction();
  499. try{
  500. $res = DB::table('goods_skus')->where('id', $id)->update($data);
  501. if($res){
  502. # erp sku更新
  503. $sku = DB::table('goods_skus')->where('id', $id)->first();
  504. $erpArr = array();
  505. $erpArr['skuId'] = $sku->erpSkuId;
  506. if($data['is_weigh'] == 1){
  507. $erpArr['propsName'] = str_replace('【按半斤称重】', '', $sku->propsName).'【按半斤称重】';
  508. if($request->input('price') > 0) $erpArr['price'] = round( $sku->price/2, 2 );
  509. if($request->input('tagPrice') > 0) $erpArr['tagPrice'] = round( $sku->tagPrice/2, 2 );
  510. if($request->input('referenceCost') > 0) $erpArr['referenceCost'] = round( $sku->referenceCost/2, 2 );
  511. }else{
  512. $erpArr['propsName'] = str_replace('【按半斤称重】', '', $sku->propsName);
  513. if($request->input('price') > 0) $erpArr['price'] = $sku->price;
  514. if($request->input('tagPrice') > 0) $erpArr['tagPrice'] = $sku->tagPrice;
  515. if($request->input('referenceCost') > 0) $erpArr['referenceCost'] = $sku->referenceCost;
  516. }
  517. $erp_up = Order::mjErpSkuUpdate($erpArr);
  518. if( $erp_up == false ){
  519. throw new Exception("erpSku更新同步到卖家云失败");
  520. }
  521. # eshop sku更新
  522. $shopArr = array();
  523. $shopArr['eshopCode'] = $sku->eshopCode;
  524. $shopArr['goodsCode'] = $sku->goodsCode;
  525. $shopArr['outerCode'] = $sku->id;
  526. $shopArr['propsName'] = $sku->propsName;
  527. if($request->input('price') > 0) $shopArr['price'] = $erpArr['price'];
  528. $sku_up = Order::mjSkuUpdate($shopArr);
  529. if( $sku_up == false ){
  530. throw new Exception("店铺商品Sku更新同步到卖家云失败");
  531. }
  532. }
  533. DB::commit();
  534. }catch (Exception $e){
  535. DB::rollback();
  536. Log::errorLog($request,['error'=>$e->getMessage()],"sku/update",0,'');
  537. return redirect('/admin/goods/skulist?goods_id='.$goods_id)->with('info', $e->getMessage());
  538. }
  539. return redirect('/admin/goods/skulist?goods_id='.$goods_id)->with('info', '修改成功');
  540. }
  541. /**
  542. * 进行下架操作
  543. * @param Request $request
  544. * @return \Illuminate\Http\RedirectResponse
  545. */
  546. public function skuDel($id)
  547. {
  548. $goods = GoodsSkus::find($id);
  549. $goods->is_del = 1;
  550. if ($goods ->save()){
  551. #记录操作日志
  552. $self_id = session('admin_id');
  553. $self_name = session('real_name');
  554. $context = "下架sku";
  555. $type = 0;
  556. $tables = 'goods_skus';
  557. $data_id = $id;
  558. Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);
  559. exit('1');
  560. }
  561. exit('0');
  562. }
  563. /**
  564. * 进行上架操作
  565. * @param Request $request
  566. * @return \Illuminate\Http\RedirectResponse
  567. */
  568. public function skuUp($id)
  569. {
  570. $goods = GoodsSkus::find($id);
  571. $goods->is_del = 0;
  572. if ($goods ->save()){
  573. #记录操作日志
  574. $self_id = session('admin_id');
  575. $self_name = session('real_name');
  576. $context = "上架sku";
  577. $type = 0;
  578. $tables = 'goods_skus';
  579. $data_id = $id;
  580. Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);
  581. exit('1');
  582. }
  583. exit('0');
  584. }
  585. /**
  586. * 分销商商品列表
  587. * @param Request $request
  588. * @return \Illuminate\View\View
  589. */
  590. public function indexCopy(Request $request){
  591. //获取分类
  592. $cates = DB::table('categorys')->lists('name', 'id');
  593. //获取请求参数
  594. $name = trim($request->input('name',''));
  595. $cate_name = trim($request->input('cate_name',''));
  596. $status = $request->input('status','-1');
  597. $realQuantity = $request->input('quantity','-1');
  598. $outPrice = $request->input('outPrice','-1');
  599. $page = (int)$request->input('page','1');
  600. $pageSize = 20;
  601. //若有请求参数,初步查询处理
  602. $goodsIds = array();
  603. if($name || $cate_name){
  604. $goodsIds = Goods::where(function($query) use($name, $cate_name){
  605. if($name) $query->where('name', 'like', '%'.$name.'%');
  606. if($cate_name) $query->where('goodsCategoryName', '=', $cate_name);
  607. })->lists('id');
  608. //TODO 无搜索结果,直接返回空,添加检索框以后不要忘了修改这里
  609. if(count($goodsIds) == 0){
  610. return view('goods/indexcopy', ['result' =>[],
  611. 'page' =>$page,
  612. 'count' =>0,
  613. 'pages' =>1,
  614. 'name' =>$name,
  615. 'cate_name' =>$cate_name,
  616. 'cates' =>$cates,
  617. 'status' =>$status,
  618. 'quantity' =>$realQuantity,
  619. 'outPrice' =>$outPrice,
  620. ]);
  621. }
  622. }
  623. //筛选所有可用库存大于0的规格id
  624. $actualSkuList = array();
  625. if($realQuantity != '-1'){
  626. $actualSkuList = GoodsSkus::actualQuantityNotNull();
  627. }
  628. //获取数据总条数
  629. $count = GoodsSkus::where(function($query) use ($goodsIds,$status,$realQuantity,$outPrice,$actualSkuList){
  630. if(count($goodsIds) > 1){
  631. $query->whereIn('goodsCode',$goodsIds);
  632. }else if(count($goodsIds) == 1){
  633. $query->where('goodsCode',$goodsIds);
  634. }
  635. if($status != '-1') $query->where('is_del',$status);
  636. if($realQuantity != '-1') $query->whereIn('id',$actualSkuList);
  637. if($outPrice != '-1') $query->where('outPrice','>','0');
  638. })->count();
  639. //分页数据处理
  640. if ($count > 1) {
  641. // 总页数
  642. $pages = ceil($count/$pageSize);
  643. }else{
  644. // 总页数
  645. $pages = 1;
  646. }
  647. //获取数据项
  648. $offset = ($page-1) * $pageSize;
  649. $result = GoodsSkus::where(function($query) use ($goodsIds,$status,$realQuantity,$outPrice,$actualSkuList){
  650. if(count($goodsIds) > 1){
  651. $query->whereIn('goodsCode',$goodsIds);
  652. } else if(count($goodsIds) == 1){
  653. $query->where('goodsCode',$goodsIds);
  654. }
  655. if($status != '-1') $query->where('is_del',$status);
  656. if($realQuantity != '-1') $query->whereIn('id',$actualSkuList);
  657. if($outPrice != '-1') $query->where('outPrice','>','0');
  658. })->orderBy('id', 'desc')->offset($offset)->limit($pageSize)->get();
  659. $result = json_decode(json_encode($result),true);
  660. //对数据项进行处理
  661. foreach($result as $k=>&$v){
  662. # 获取goods信息
  663. $goodsInfo = Goods::where('id', $v['goodsCode'])->first();
  664. $quantity = GoodsSkus::actualQuantityByRedis($v['id']);
  665. $v['real_quantity'] = $quantity['quantity'];
  666. $v['pre_quantity'] = $quantity['w_num'];
  667. $v['total_quantity'] = $v['quantity'];
  668. $v['name'] = $goodsInfo->name;
  669. $v['goodsCategoryName'] = $goodsInfo->goodsCategoryName;
  670. if($goodsInfo->is_del == 1){
  671. $v['is_del'] = 1;
  672. }
  673. }
  674. //返回给页面
  675. return view('goods/indexcopy', [
  676. 'result' =>$result,
  677. 'page' =>$page,
  678. 'count' =>$count,
  679. 'pages' =>$pages,
  680. 'name' =>$name,
  681. 'cate_name' =>$cate_name,
  682. 'cates' =>$cates,
  683. 'status' =>$status,
  684. 'quantity' =>$realQuantity,
  685. 'outPrice' =>$outPrice,
  686. ]);
  687. }
  688. /**
  689. * 分销商品列表导出
  690. * @param Request $request
  691. * @return bool|\Illuminate\Http\RedirectResponse
  692. */
  693. public function indexCopyExport(Request $request){
  694. //获取请求参数
  695. $name = trim($request->input('name',''));
  696. $cate_name = trim($request->input('cate_name',''));
  697. $status = $request->input('status','-1');
  698. $realQuantity = $request->input('quantity','-1');
  699. $outPrice = $request->input('outPrice','-1');
  700. //若有请求参数,初步获取查询结果
  701. $goodsIds = array();
  702. if($name || $cate_name){
  703. $goodsIds = Goods::where(function($query) use($name, $cate_name){
  704. if($name) $query->where('name', 'like', '%'.$name.'%');
  705. if($cate_name) $query->where('goodsCategoryName', '=', $cate_name);
  706. })->lists('id');
  707. //无查询结果,直接返回空
  708. if(count($goodsIds) == 0){
  709. return back()->with('info','没有商品可导出');
  710. }
  711. }
  712. //筛选所有可用库存大于0的规格id
  713. $actualSkuList = array();
  714. if($realQuantity != '-1'){
  715. $actualSkuList = GoodsSkus::actualQuantityNotNull();
  716. }
  717. //进一步获取数据查询结果
  718. $result = GoodsSkus::where(function($query) use ($goodsIds,$status,$realQuantity,$outPrice,$actualSkuList){
  719. if(count($goodsIds) > 1){
  720. $query->whereIn('goodsCode',$goodsIds);
  721. }else if(count($goodsIds) == 1){
  722. $query->where('goodsCode',$goodsIds);
  723. }
  724. if($status != '-1') $query->where('is_del',$status);
  725. if($realQuantity != '-1') $query->whereIn('id',$actualSkuList);
  726. if($outPrice != '-1') $query->where('outPrice','>','0');
  727. })->orderBy('id', 'desc')->get();
  728. $result = json_decode(json_encode($result),true);
  729. //对数据查询结果处理
  730. foreach($result as $k=>&$v){
  731. # 获取goods信息
  732. $goodsInfo = Goods::where('id', $v['goodsCode'])->first();
  733. $quantity = GoodsSkus::actualQuantityByRedis($v['id']);
  734. $v['real_quantity'] = $quantity['quantity'];
  735. $v['pre_quantity'] = $quantity['w_num'];
  736. $v['total_quantity'] = $v['quantity'];
  737. $v['name'] = $goodsInfo->name;
  738. $v['goodsCategoryName'] = $goodsInfo->goodsCategoryName;
  739. if($goodsInfo->is_del == 1){
  740. $v['is_del'] = 1;
  741. }
  742. if($v['is_del'] == 1){
  743. $v['status'] = '已下架';
  744. } else {
  745. $v['status'] = '已上架';
  746. }
  747. }
  748. //将数据查询结果通过导出excel方法导出到浏览器
  749. $indexKey = ['goodsCategoryName','name','propsName','code','realPrice','outPrice','price','status','createTime','real_quantity','total_quantity','pre_quantity'];
  750. $title = ['商品分类', '商品名称', '商品规格', '规格编码','成本价','分销商价格','建议零售价','上架状态','上架时间','可用库存','总库存','预占用库存'];
  751. $filename = 'goods_sku_export_'.date('Y-m-d_H').'.xlsx';
  752. return Order::export_excel($result, $filename, $indexKey, $title);
  753. }
  754. /**
  755. * 编辑建议零售价或者分销商价格
  756. * @param Request $request
  757. */
  758. public function editGoodsSku(Request $request){
  759. $id = $request->input('id');
  760. $outPrice = trim($request->input('outPrice'));
  761. $price = trim($request->input('price'));
  762. if($outPrice){
  763. $res = GoodsSkus::where('id',$id)->update(['outPrice'=>$outPrice]);
  764. if($res) return 0;
  765. }
  766. if($price){
  767. $res = GoodsSkus::where('id',$id)->update(['price'=>$price]);
  768. if($res) return 0;
  769. }
  770. return 1;
  771. }
  772. }