Product.php 46 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202
  1. <?php namespace App\Http\Controllers\Admin;
  2. use App\Http\Requests\Admin\Product as Request;
  3. use App\Models\Business;
  4. use App\Models\City;
  5. use App\Models\OrdersProduct;
  6. use App\Models\Producer;
  7. use App\Models\Product as Model;
  8. use Illuminate\Support\Carbon;
  9. use App\Models\Product\Spec as ProductSpec;
  10. use App\Models\Product\Type as ProductType;
  11. use App\Models\Product\Attr as ProductAttr;
  12. use App\Models\Product\Skus as ProductSkus;
  13. use App\Models\Product\City as ProductCity;
  14. use App\Models\ProductPhoto;
  15. use Illuminate\Support\Facades\DB;
  16. use App\Models\WeiBan\Taglist as WeiBanTagList;
  17. use Intervention\Image\Facades\Image;
  18. use Intervention\Image\Gd\Font;
  19. use App\Facades\Servers\WechatMini\Mini;
  20. /**
  21. * 产品管理
  22. *
  23. * @author 刘相欣
  24. *
  25. */
  26. class Product extends Auth{
  27. protected function _initialize(){
  28. parent::_initialize();
  29. $this->assign('breadcrumb1','基础信息');
  30. $this->assign('breadcrumb2','产品管理');
  31. }
  32. /**
  33. * 首页列表
  34. *
  35. * */
  36. public function index(Model $Model,City $City,ProductCity $ProductCity,OrdersProduct $OrdersProduct,Business $Business){
  37. // 接受参数
  38. $code = request('product_code','');
  39. $name = request('name','');
  40. $status = request('status');
  41. $startTime = request('start_time','');
  42. $businessId = request('business_id','');
  43. $provinceId = request('province_id','');
  44. $cityIds = request('city_ids',[]);
  45. $cityList = $City->getCityList();
  46. // 如果存在省份ID
  47. if( $provinceId ) {
  48. // 循环城市列表
  49. foreach ($cityList as $key=>$group) {
  50. // 如果省份ID对的上
  51. if( $group['id'] == $provinceId){
  52. // 获取下面的城市ID
  53. $cityIds = array_merge($cityIds,array_column($group['city'],'id'));
  54. }else{
  55. unset($cityList[$key]);
  56. }
  57. }
  58. }
  59. // 编码转ID
  60. $id = $code ? $Model->codeToId($code) : 0;
  61. // 查询条件
  62. $map = [];
  63. // 编码ID
  64. if( $id ) $map[] = ['product.id','=',$id];
  65. if( $businessId ) $map[] = ['product.business_id','=',$businessId];
  66. if( $name ) $map[] = ['product.name','like','%'.$name.'%'];
  67. if( $startTime ) $map[] = ['product.insert_time','>=',Carbon::createFromFormat('Y-m-d',$startTime)->startOfDay()->getTimestamp()];
  68. if( $startTime ) $map[] = ['product.insert_time','<=',Carbon::createFromFormat('Y-m-d',$startTime)->endOfDay()->getTimestamp()];
  69. if( !is_null($status) ) $map[] = ['product.status','=',$status];
  70. // 当前登录的角色数据
  71. $session = session('userRule') ? session('userRule') : ['business_id'=>0,'menu_type'=>0,'data_type'=>0];
  72. // 是否存在对应的店铺ID
  73. if ( $session['business_id'] ) $map[] = ['product.business_id','=',$session['business_id']];
  74. // 数据类型
  75. $shopIds = ($session['menu_type'] == 1 && $session['data_type'] == 2) ? Business::query()->where('leader_uid',$session['admin_uid'])->pluck('id')->toArray() : [];
  76. // 查询数据
  77. $list = $Model->query();
  78. if( $cityIds ) $list = $list->join('product_city','product_city.product_id','=','product.id')->whereIn('product_city.city_id',$cityIds);
  79. if( $shopIds ) $list = $list->whereIn('product.business_id',$shopIds);
  80. $list = $list->groupBy('product.id')
  81. ->where($map)
  82. ->orderBy('product.sort')
  83. ->orderByDesc('product.id')
  84. ->select(['product.*'])
  85. ->paginate(request('limit',config('page_num',10)))->appends(request()->all());
  86. // 统计销量
  87. $salesList = $OrdersProduct->query()->where([['status','<>',4]])->whereIn('product_id',array_column($list->items(),'id'))->groupBy('product_id')->select([DB::raw('sum(`buy_num`) as sales_total'),'product_id'])->pluck('sales_total','product_id')->toArray();
  88. // 循环处理数据
  89. foreach ($list as $key => $value) {
  90. // id转编号
  91. $value['product_code'] = $Model->idToCode($value['id']);
  92. $value['business_name']= Business::query()->where('id',$value['business_id'])->value('name');
  93. // id转编号
  94. $cityName = [];
  95. // 获取城市列表
  96. $cityIds = $ProductCity->query()->where([['product_id','=',$value['id']]])->pluck('city_id');
  97. // 如果有的话
  98. if( $cityIds ) {
  99. // 返回结果
  100. foreach ($cityIds as $cityId) {
  101. // 城市ID
  102. if( $cityId == 1 ) continue;
  103. // 获取城市名
  104. $cityName[] = $City->getOne($cityId,'name');
  105. }
  106. }
  107. // 销量统计
  108. $value['sales_total'] = isset($salesList[$value['id']])?$salesList[$value['id']]:0;
  109. // 城市
  110. $value['city_name'] = implode('、',$cityName);
  111. // 重组
  112. $list[$key] = $value;
  113. }
  114. // 获取列表
  115. $businessList = $Business->getListByAdmin();
  116. // 分配数据
  117. $this->assign('empty', '<tr><td colspan="20">~~暂无数据</td></tr>');
  118. $this->assign('cityList',$cityList);
  119. $this->assign('businessList',$businessList);
  120. $this->assign('list', $list);
  121. // 加载模板
  122. return $this->fetch();
  123. }
  124. /**
  125. * 获取小程序海报
  126. *
  127. */
  128. public function get_poster(Model $Model){
  129. // 接收参数
  130. $id = request('id',0);
  131. // // 查询用户
  132. $oldData = $Model->where(['id'=>$id])->first();
  133. // // 错误告知
  134. if( !$oldData ) return $this->error('查无数据');
  135. // url有效期
  136. $urlLink = '';//$this->getUrlLink($id);
  137. // 获取分享海报图片
  138. $result = $this->getShareImage('id='.$id,$oldData);
  139. // 错误提示
  140. if( isset($result['error']) ) return $this->error($result['error']);
  141. // 分配数据
  142. $this->assign('image',$result);
  143. $this->assign('urlLink',$urlLink);
  144. $this->assign('oldData',$oldData);
  145. $this->assign('crumbs','海报');
  146. // 加载模板
  147. return $this->fetch();
  148. }
  149. /**
  150. * 获取小程序链接
  151. *
  152. */
  153. private function getUrlLink($id){
  154. // 结果数据
  155. $link = cache('admin:product:urllink:product_id'.$id);
  156. // 不存在数据
  157. if ( is_null($link) ) {
  158. // 从数据库获取数据
  159. $link = Mini::getUrlLink('pages/product/index','product_id='.$id);
  160. // 存起来
  161. cache(['admin:product:urllink:product_id'.$id=>$link],$link ? now()->addDays(23) : now()->addMinutes(3));
  162. }
  163. // 返回结果
  164. return $link;
  165. }
  166. /**
  167. * 获取分享海报图片
  168. * @param int $scene 场景值
  169. *
  170. */
  171. private function getShareImage($scene,$oldData){
  172. // 尝试执行
  173. try {
  174. // 加载图片
  175. $image = Image::make(public_path('uploads/images/poster/').'product.png');
  176. // 产品缩略图
  177. $thumb = Image::make(path_compat($oldData['thumb']))->resize(1000,1000);
  178. // 设置文字样式(字体、大小、颜色等)
  179. $fontPath = public_path().'/fonts/msyh14.ttf';// 指定字体文件路径
  180. // 生成小程序二维码
  181. $qrcode = Mini::getUnlimit($scene,['page'=>'pages/product/index','width'=>280,'is_hyaline'=>true]);
  182. // 错误提示
  183. if( isset($qrcode['error']) ) return $qrcode;
  184. // 加载图片
  185. $qrcode = Image::make($qrcode)->resize(250,250);
  186. // 插入图片
  187. $image->insert($thumb,'top-center',0,130);
  188. // 插入图片
  189. $image->insert($qrcode,'bottom-left',120,120);
  190. // 给图片写入文字
  191. $image->text('¥'.$oldData['price'], 360,1280,function (Font $font) use ($fontPath) {
  192. $font->file($fontPath); // 字体文件地址
  193. $font->size(88); // 字体大小
  194. $font->color('#333333');
  195. $font->align('left');
  196. });
  197. if( mb_strlen($oldData['name']) > 44 ) {
  198. // 显示截取后的文字
  199. $oldData['name'] = mb_substr($oldData['name'],0,22).PHP_EOL.mb_substr($oldData['name'],22,22).PHP_EOL.mb_substr($oldData['name'],44,8);
  200. // 给图片写入文字
  201. $image->text($oldData['name'], 80,1480,function (Font $font) use ($fontPath) {
  202. $font->file($fontPath); // 字体文件地址
  203. $font->size(48); // 字体大小
  204. $font->color('#333333');
  205. $font->align('left');
  206. });
  207. }else if( mb_strlen($oldData['name']) > 22 ) {
  208. // 显示截取后的文字
  209. $oldData['name'] = mb_substr($oldData['name'],0,22).PHP_EOL.mb_substr($oldData['name'],22,22);
  210. // 给图片写入文字
  211. $image->text($oldData['name'], 80,1450,function (Font $font) use ($fontPath) {
  212. $font->file($fontPath); // 字体文件地址
  213. $font->size(48); // 字体大小
  214. $font->color('#333333');
  215. $font->align('left');
  216. });
  217. }else{
  218. // 给图片写入文字
  219. $image->text($oldData['name'], 120,1380,function (Font $font) use ($fontPath) {
  220. $font->file($fontPath); // 字体文件地址
  221. $font->size(48); // 字体大小
  222. $font->color('#333333');
  223. $font->align('left');
  224. });
  225. }
  226. // 转码成字符串
  227. $image = $image->encode('jpg', 90)->__toString();
  228. // 转base64
  229. $base64 = 'data:image/jpg;base64,' . base64_encode($image);
  230. // 返回结果
  231. return $base64;
  232. } catch (\Throwable $th) {
  233. // 错误提示
  234. return ['error'=>$th->getMessage()];
  235. }
  236. }
  237. /**
  238. * 添加
  239. *
  240. * */
  241. public function add(Request $request, Model $Model, WeiBanTagList $WeiBanTagList, ProductPhoto $ProductPhoto, Producer $Producer, Business $Business, ProductType $ProductType, ProductSpec $ProductSpec, ProductAttr $ProductAttr, ProductSkus $ProductSkus, City $City, ProductCity $ProductCity){
  242. if( request()->isMethod('post') ){
  243. // 验证参数
  244. $request->scene('add')->validate();
  245. // 组合数据
  246. $data['name'] = request('name','');
  247. $data['thumb'] = request('thumb','');
  248. $data['poster'] = request('poster','');
  249. $data['spec'] = request('spec','');
  250. $data['price'] = request('price',0);
  251. $data['market_price'] = request('market_price',0);
  252. $data['producer_id'] = request('producer_id',0);
  253. $data['business_id'] = request('business_id',0);
  254. $data['quota'] = request('quota',0);
  255. $data['min_quota'] = request('min_quota',0);
  256. $data['hide_orderbtn'] = request('hide_orderbtn',0);
  257. $data['sku_min_quota_and'] = request('sku_min_quota_and',0);
  258. $data['quota_start'] = request('quota_start','');
  259. $data['quota_end'] = request('quota_end','');
  260. $data['puton_time'] = request('puton_time','');
  261. $data['putoff_time'] = request('putoff_time','');
  262. $data['stock'] = request('stock',0);
  263. $data['type_id'] = request('type_id',0);
  264. $data['status'] = 1;
  265. $data['admin_uid'] = admin('uid');
  266. $description = request('description','');
  267. $attr = request('attr',[]);
  268. $skuList = request('sku',[]);
  269. $cityIds = request('city_ids',[]);
  270. $photoList = request('photo_list',[]);
  271. $tagScope = request('tag_scope',[]);
  272. $data['tag_scope'] = implode(',',$tagScope);
  273. $tagExclude = request('tag_exclude',[]);
  274. $data['tag_exclude'] = implode(',',$tagExclude);
  275. // 循环
  276. foreach ($photoList as $key => $value) {
  277. if( !$value ) unset($photoList[$key]);
  278. }
  279. $photoList = array_values($photoList);
  280. // 如果没有选择,则意味着全部
  281. $cityIds = $cityIds ? $cityIds : [1];
  282. $data['quota_start'] = $data['quota_start'] ? strtotime($data['quota_start']) : 0;
  283. $data['quota_end'] = $data['quota_end'] ? strtotime($data['quota_end']) : 0;
  284. $data['puton_time'] = $data['puton_time'] ? strtotime($data['puton_time']) : 0;
  285. $data['putoff_time'] = $data['putoff_time'] ? strtotime($data['putoff_time']) : 0;
  286. // 限购提示
  287. if( !$data['thumb'] ) return json_send(['code'=>'error','msg'=>'请上传产品主图','data'=>['error'=>'请上传产品主图']]);
  288. // 限购提示
  289. if( $attr && !$skuList ) return json_send(['code'=>'error','msg'=>'规格属性存在时,请填写SKU','data'=>['error'=>'规格属性存在时,请填写SKU']]);
  290. // 限购提示
  291. if( $data['quota'] && ( !$data['quota_start'] || !$data['quota_end'] )) return json_send(['code'=>'error','msg'=>'限购必填限购时间','data'=>['error'=>'限购必填限购时间']]);
  292. // 限购提示
  293. if( $data['quota'] && $data['min_quota'] > $data['quota'] ) return json_send(['code'=>'error','msg'=>'起购数量请勿大于限购数量','data'=>['error'=>'起购数量请勿大于限购数量']]);
  294. // SKU存在的时候,判断限购数量
  295. if( $skuList ) {
  296. // 循环处理
  297. foreach ($skuList as $attrNames => $value) {
  298. // SKU限购,所以限购时间也必须填
  299. if( $value['quota'] && ( !$data['quota_start'] || !$data['quota_end'] )) return json_send(['code'=>'error','msg'=>'SKU限购时,请填限购时间','data'=>['error'=>'SKU限购时,请填限购时间']]);
  300. // 限购提示
  301. if( $value['quota'] && $value['min_quota'] > $value['quota'] ) return json_send(['code'=>'error','msg'=>$attrNames.'起购数量请勿大于限购数量','data'=>['error'=>$attrNames.'起购数量请勿大于限购数量']]);
  302. }
  303. // 限购数量
  304. $quota = array_sum(array_column($skuList,'quota'));
  305. // 提示限购数量异常
  306. if( $data['quota']&& $data['quota'] < $quota ) return json_send(['code'=>'error','msg'=>'总限购数量不能小于SKU的限购数量','data'=>['error'=>'总限购数量不能小于SKU的限购数量']]);
  307. }
  308. // 上下架
  309. if( $data['puton_time'] ) {
  310. // 下架时间必填
  311. if( !$data['putoff_time'] ) return json_send(['code'=>'error','msg'=>'请填写自动下架时间','data'=>['error'=>'自动上架请填写下架时间']]);
  312. // 下架时间必填
  313. if( $data['putoff_time'] <= $data['puton_time'] ) return json_send(['code'=>'error','msg'=>'下架时间请晚于上架时间','data'=>['error'=>'下架时间请晚于上架时间']]);
  314. }
  315. // 总库存
  316. if( $skuList ) $data['stock'] = array_sum(array_column($skuList,'stock'));
  317. // 总库存
  318. $data['stock_total'] = $data['stock'];
  319. // 总库存提醒
  320. if( $data['stock_total'] <= 0 ) return json_send(['code'=>'error','msg'=>'请设置库存','data'=>['error'=>'请设置库存']]);
  321. // 获取规格属性
  322. $specAttr = $this->getSpecAttr($attr,$ProductSpec,true);
  323. // 开启事务
  324. DB::beginTransaction();
  325. try {
  326. // 写入
  327. $id = $Model->add($data);
  328. // 提示新增失败
  329. if( !$id ) {
  330. // 回滚
  331. DB::rollBack();
  332. // 提示
  333. return json_send(['code'=>'error','msg'=>'新增失败']);
  334. }
  335. // 组合数据
  336. foreach ($specAttr as $key => $value) {
  337. // 查询结果
  338. $value['id'] = $ProductAttr->upsertByName($value,$id);
  339. // 提示新增失败
  340. if( !$value['id'] ) {
  341. // 回滚
  342. DB::rollBack();
  343. // 提示
  344. return json_send(['code'=>'error','msg'=>'商品属性新增失败']);
  345. }
  346. // 重组
  347. $specAttr[$key] = $value;
  348. }
  349. // 图册
  350. foreach ($photoList as $key => $value) {
  351. // 整理数据
  352. $value = ['sort'=>$key,'thumb'=>$value,'product_id'=>$id,'insert_time'=>time(),'update_time'=>time()];
  353. // 重新整理
  354. $photoList[$key] = $value;
  355. }
  356. // 存在图册
  357. if( $photoList ) {
  358. // 写入失败
  359. $result = $ProductPhoto->query()->insert($photoList);
  360. // 提示新增失败
  361. if( !$result ) {
  362. // 回滚
  363. DB::rollBack();
  364. // 提示
  365. return json_send(['code'=>'error','msg'=>'商品图册写入失败']);
  366. }
  367. }
  368. // 循环SKU
  369. foreach ($skuList as $attrNames => $value) {
  370. // 属性ID值
  371. $value['attr_ids'] = [];
  372. // 规格属性值组合
  373. $value['attr_names']= $attrNames;
  374. // 切割成数据
  375. $names = explode(',',$attrNames);
  376. // 循环处理
  377. foreach ($names as $name) {
  378. foreach ($specAttr as $vv) {
  379. if( $name == $vv['name'] ) {
  380. // 提示新增失败
  381. if( !$vv['id'] ) {
  382. // 回滚
  383. DB::rollBack();
  384. // 提示
  385. return json_send(['code'=>'error','msg'=>'属性SKU匹配失败']);
  386. }
  387. $value['attr_ids'][] = $vv['id'];
  388. }
  389. }
  390. }
  391. // 转成好存储的数据
  392. $value['attr_ids'] = implode(',',$value['attr_ids']);
  393. // 转成好存储的数据
  394. $value['product_id'] = $id;
  395. // 转成好存储的数据
  396. $value['sku_thumb'] = (string)$value['sku_thumb'];
  397. // 转成好存储的数据
  398. $value['stock_total']= $value['stock'];
  399. // 转成好存储的数据
  400. $value['insert_time']= time();
  401. // 转成好存储的数据
  402. $value['update_time']= time();
  403. // SKU结果
  404. $skuList[$attrNames] = $value;
  405. }
  406. // 循环城市范围
  407. foreach ($cityIds as $key => $value) {
  408. // 重组数据
  409. $cityIds[$key] = ['city_id'=>$value,'product_id'=>$id,'insert_time'=>time(),'update_time'=>time()];
  410. }
  411. // 写入城市范围
  412. $ProductCity->query()->insert($cityIds);
  413. // 返回结果
  414. $result = $ProductSkus->insert($skuList);
  415. // 提示新增失败
  416. if( !$result ) {
  417. // 回滚
  418. DB::rollBack();
  419. // 提示
  420. return json_send(['code'=>'error','msg'=>'SKU插入失败']);
  421. }
  422. // 更新内容
  423. $Model->updateDesc($id,$description);
  424. // 提交
  425. DB::commit();
  426. // 记录行为
  427. $this->addAdminHistory(admin('uid'),$Model->getTable(),$id,1,[],$data);
  428. // 告知结果
  429. return json_send(['code'=>'success','msg'=>'新增成功','action'=>'add']);
  430. } catch (\Throwable $th) {
  431. // 回滚
  432. DB::rollBack();
  433. // 提示
  434. return json_send(['code'=>'error','msg'=>'系统异常,写入失败','data'=>$th->getMessage()]);
  435. }
  436. }
  437. // 获取类型数据
  438. $typeList = $ProductType->getList();
  439. $cityList = $City->getCityList();
  440. $businessList = $Business->getListByAdmin();
  441. $producerList = $Producer->getList();
  442. // 标签列表
  443. $tagData = $WeiBanTagList->query()->get(['tag_group_name as group','tag_name as name'])->toArray();
  444. // 标签列表
  445. $tagList = [];
  446. // 循环数据
  447. foreach ($tagData as $value) {
  448. $tagList[$value['group']][] = $value['name'];
  449. }
  450. // 分配数据
  451. $this->assign('crumbs','新增');
  452. $this->assign('tagList',$tagList);
  453. $this->assign('typeList',$typeList);
  454. $this->assign('cityList',$cityList);
  455. $this->assign('businessList',$businessList);
  456. $this->assign('producerList',$producerList);
  457. // 加载模板
  458. return $this->fetch();
  459. }
  460. /**
  461. * 编辑
  462. *
  463. * */
  464. public function edit(Request $request, Model $Model, WeiBanTagList $WeiBanTagList, ProductPhoto $ProductPhoto, Producer $Producer, Business $Business, ProductType $ProductType, ProductSpec $ProductSpec, ProductAttr $ProductAttr, ProductSkus $ProductSkus, City $City, ProductCity $ProductCity){
  465. // 接收参数
  466. $id = request('id',0);
  467. // 查询数据
  468. $oldData = $Model->where(['id'=>$id])->first();
  469. // 修改
  470. if(request()->isMethod('post')){
  471. // 验证参数
  472. $request->scene('edit')->validate();
  473. // 组合数据
  474. $id = request('id',0);
  475. $data['name'] = request('name','');
  476. $data['thumb'] = request('thumb','');
  477. $data['poster'] = request('poster','');
  478. $data['spec'] = request('spec','');
  479. $data['price'] = request('price',0);
  480. $data['market_price'] = request('market_price',0);
  481. $data['quota'] = request('quota',0);
  482. $data['min_quota'] = request('min_quota',0);
  483. $data['hide_orderbtn'] = request('hide_orderbtn',0);
  484. $data['sku_min_quota_and'] = request('sku_min_quota_and',0);
  485. $data['quota_start'] = request('quota_start','');
  486. $data['quota_end'] = request('quota_end','');
  487. $data['puton_time'] = request('puton_time','');
  488. $data['putoff_time'] = request('putoff_time','');
  489. $data['producer_id'] = request('producer_id',0);
  490. $data['business_id'] = request('business_id',0);
  491. $data['type_id'] = request('type_id',0);
  492. $data['stock'] = request('stock',0);
  493. $data['status'] = 1;
  494. $description = request('description','');
  495. $attr = request('attr',[]);
  496. $skuList = request('sku',[]);
  497. $cityIds = request('city_ids',[]);
  498. $photoList = request('photo_list',[]);
  499. $tagScope = request('tag_scope',[]);
  500. $data['tag_scope'] = implode(',',$tagScope);
  501. $tagExclude = request('tag_exclude',[]);
  502. $data['tag_exclude'] = implode(',',$tagExclude);
  503. // 循环
  504. foreach ($photoList as $key => $value) {
  505. if( !$value ) unset($photoList[$key]);
  506. }
  507. $photoList = array_values($photoList);
  508. // 如果没有选择,则意味着全部
  509. $cityIds = $cityIds ? $cityIds : [1];
  510. $data['quota_start'] = $data['quota_start'] ? strtotime($data['quota_start']) : 0;
  511. $data['quota_end'] = $data['quota_end'] ? strtotime($data['quota_end']) : 0;
  512. $data['puton_time'] = $data['puton_time'] ? strtotime($data['puton_time']) : 0;
  513. $data['putoff_time'] = $data['putoff_time'] ? strtotime($data['putoff_time']) : 0;
  514. // 限购提示
  515. if( !$data['thumb'] ) return json_send(['code'=>'error','msg'=>'请上传产品主图','data'=>['error'=>'请上传产品主图']]);
  516. // 限购提示
  517. if( $attr && !$skuList ) return json_send(['code'=>'error','msg'=>'规格属性存在时,请填写SKU','data'=>['error'=>'规格属性存在时,请填写SKU']]);
  518. // 限购提示
  519. if( $data['quota'] && ( !$data['quota_start'] || !$data['quota_end'] )) return json_send(['code'=>'error','msg'=>'限购必填限购时间','data'=>['error'=>'限购必填限购时间']]);
  520. // 限购提示
  521. if( $data['quota'] && $data['min_quota'] > $data['quota'] ) return json_send(['code'=>'error','msg'=>'起购数量请勿大于限购数量','data'=>['error'=>'起购数量请勿大于限购数量']]);
  522. // SKU存在的时候,判断限购数量
  523. if( $skuList ) {
  524. // 循环处理
  525. foreach ($skuList as $attrNames => $value) {
  526. // SKU限购,所以限购时间也必须填
  527. if( $value['quota'] && ( !$data['quota_start'] || !$data['quota_end'] )) return json_send(['code'=>'error','msg'=>'SKU限购时,请填限购时间','data'=>['error'=>'SKU限购时,请填限购时间']]);
  528. // 限购提示
  529. if( $value['quota'] && $value['min_quota'] > $value['quota'] ) return json_send(['code'=>'error','msg'=>$attrNames.'起购数量请勿大于限购数量','data'=>['error'=>$attrNames.'起购数量请勿大于限购数量']]);
  530. }
  531. // 限购数量
  532. $quota = array_sum(array_column($skuList,'quota'));
  533. // 提示限购数量异常
  534. if( $data['quota']&& $data['quota'] < $quota ) return json_send(['code'=>'error','msg'=>'总限购数量不能小于SKU的限购数量','data'=>['error'=>'总限购数量不能小于SKU的限购数量']]);
  535. }
  536. // 上下架
  537. if( $data['puton_time'] ) {
  538. // 下架时间必填
  539. if( !$data['putoff_time'] ) return json_send(['code'=>'error','msg'=>'请填写自动下架时间','data'=>['error'=>'自动上架请填写下架时间']]);
  540. // 下架时间必填
  541. if( $data['putoff_time'] <= $data['puton_time'] ) return json_send(['code'=>'error','msg'=>'下架时间请晚于上架时间','data'=>['error'=>'下架时间请晚于上架时间']]);
  542. }
  543. // 总库存
  544. if( $skuList ) $data['stock'] = array_sum(array_column($skuList,'stock'));
  545. // 总库存
  546. $data['stock_total'] = $data['stock'];
  547. // 总库存提醒
  548. if( $data['stock_total'] <= 0 ) return json_send(['code'=>'error','msg'=>'请设置库存','data'=>['error'=>'请设置库存']]);
  549. // 获取规格属性
  550. $specAttr = $this->getSpecAttr($attr,$ProductSpec,true);
  551. // 开启事务
  552. DB::beginTransaction();
  553. try {
  554. // 写入
  555. $result = $Model->edit($id,$data);
  556. // 提示新增失败
  557. if( !$result ) {
  558. // 回滚
  559. DB::rollBack();
  560. // 提示
  561. return json_send(['code'=>'error','msg'=>'修改失败']);
  562. }
  563. // 获取旧图册
  564. $oldPhoto = $ProductPhoto->getListByProductId($id);
  565. // 循环个数
  566. for ($i=0; $i < 4; $i++) {
  567. // 如果存在旧数据与新数据,修改
  568. if( isset($oldPhoto[$i]) && isset($photoList[$i]) ) $ProductPhoto->query()->where([['product_id','=',$id],['sort','=',$i]])->update(['thumb'=>(string)$photoList[$i],'update_time'=>time()]);
  569. // 如果存在旧数据,不存在新数据,删除
  570. if( isset($oldPhoto[$i]) && !isset($photoList[$i]) ) $ProductPhoto->query()->where([['product_id','=',$id],['sort','=',$i]])->delete();
  571. // 如果不存在旧数据,存在新数据,新增
  572. if( !isset($oldPhoto[$i]) && isset($photoList[$i]) ) $ProductPhoto->add(['sort'=>$i,'product_id'=>$id,'thumb'=>(string)$photoList[$i],'insert_time'=>time(),'update_time'=>time()]);
  573. }
  574. // 组合数据
  575. foreach ($specAttr as $key => $value) {
  576. // 查询结果
  577. $value['id'] = $ProductAttr->upsertByName($value,$id);
  578. // 提示新增失败
  579. if( !$value['id'] ) {
  580. // 回滚
  581. DB::rollBack();
  582. // 提示
  583. return json_send(['code'=>'error','msg'=>'商品属性新增失败']);
  584. }
  585. // 重组
  586. $specAttr[$key] = $value;
  587. }
  588. // 如果不在这个属性列表中的数据删除
  589. $ProductAttr->query()->where([['product_id','=',$id]])->whereNotIn('id',array_column($specAttr,'id'))->delete();
  590. // 循环SKU
  591. foreach ($skuList as $attrNames => $value) {
  592. // 属性ID值
  593. $value['attr_ids'] = [];
  594. // 规格属性值组合
  595. $value['attr_names']= $attrNames;
  596. // 切割成数据
  597. $names = explode(',',$attrNames);
  598. // 循环处理
  599. foreach ($names as $name) {
  600. foreach ($specAttr as $vv) {
  601. if( $name == $vv['name'] ) {
  602. // 提示新增失败
  603. if( !$vv['id'] ) {
  604. // 回滚
  605. DB::rollBack();
  606. // 提示
  607. return json_send(['code'=>'error','msg'=>'属性SKU匹配失败']);
  608. }
  609. $value['attr_ids'][] = $vv['id'];
  610. }
  611. }
  612. }
  613. // 转成好存储的数据
  614. $value['attr_ids'] = implode(',',$value['attr_ids']);
  615. // 转成好存储的数据
  616. $value['sku_thumb'] = (string)$value['sku_thumb'];
  617. // 转成好存储的数据
  618. $value['stock_total']= $value['stock'];
  619. // 转成好存储的数据
  620. $value['product_id']= $id;
  621. // 查询
  622. $oldSkuId = $ProductSkus->query()->where([['product_id','=',$id],['attr_ids','=',$value['attr_ids']]])->value('id');
  623. // 判断是否存在ID
  624. $value['id'] = $oldSkuId ? $ProductSkus->edit($oldSkuId,$value) : $ProductSkus->add($value);
  625. // SKU结果
  626. $skuList[$attrNames]= $value;
  627. }
  628. // 如果不在这个属性列表中的数据删除
  629. $ProductSkus->query()->where([['product_id','=',$id]])->whereNotIn('id',array_column($skuList,'id'))->delete();
  630. // 获取之前的城市ID
  631. $oldCityIds = $ProductCity->getListByProductId($id);
  632. // 循环城市范围
  633. foreach ($cityIds as $key => $value) {
  634. // 不存在则新增
  635. if( !in_array($value,$oldCityIds) ) $ProductCity->add(['city_id'=>$value,'product_id'=>$id]);
  636. }
  637. // 不存在的城市删除
  638. $ProductCity->query()->where([['product_id','=',$id]])->whereNotIn('city_id',$cityIds)->delete();
  639. // 更新内容
  640. $Model->updateDesc($id,$description);
  641. // 提交
  642. DB::commit();
  643. // 记录行为
  644. $this->addAdminHistory(admin('uid'),$Model->getTable(),$id,2,$oldData,$data);
  645. // 告知结果
  646. return json_send(['code'=>'success','msg'=>'修改成功','action'=>'edit']);
  647. } catch (\Throwable $th) {
  648. // 回滚
  649. DB::rollBack();
  650. // 提示
  651. return json_send(['code'=>'error','msg'=>'系统异常,写入失败','data'=>$th->getMessage() .'=>'.$th->getLine()]);
  652. }
  653. }
  654. // 如果是没有数据
  655. if( !$oldData ) return $this->error('查无数据');
  656. // 产品信息转格式
  657. $oldData = $oldData->toArray();
  658. $oldData['description'] = $Model->getDesc($id);
  659. $oldData['city_ids'] = $ProductCity->getListByProductId($id);
  660. $oldData['tag_scope'] = explode(',',$oldData['tag_scope']);
  661. $oldData['tag_exclude'] = explode(',',$oldData['tag_exclude']);
  662. $photoList = $ProductPhoto->getListByProductId($id);
  663. // 获取产品属性
  664. $attrList = $ProductAttr->getListByProductId($id);
  665. // 规格属性
  666. $specList = [];
  667. // 获取数据
  668. foreach ($attrList as $value) {
  669. $value['active'] = 0;
  670. if( !isset($specList[$value['spec_id']]) ) $specList[$value['spec_id']] = $ProductSpec->getOne($value['spec_id']);
  671. $specList[$value['spec_id']]['attr_list'][] = $value;
  672. }
  673. // 产品类型
  674. $skuList = $ProductSkus->getListByProductId($id);
  675. // 循环处理
  676. foreach ($skuList as $key => $value) {
  677. // 数据解析
  678. $value['attr_ids'] = explode(',',$value['attr_ids']);
  679. // 循环处理
  680. foreach ( $value['attr_ids'] as $k=>$attrId ) {
  681. // 获取ids对应的name
  682. $value['attr_ids'][$k] = $ProductAttr->getValueById($attrId,'name');
  683. }
  684. // 数据合并
  685. $value['attr_ids'] = implode(',',$value['attr_ids']);
  686. // 重组
  687. $skuList[$key] = $value;
  688. }
  689. // 获取类型数据
  690. $typeList = $ProductType->getList();
  691. $cityList = $City->getCityList();
  692. $businessList = $Business->getListByAdmin();
  693. $producerList = $Producer->getList();
  694. // 标签列表
  695. $tagData = $WeiBanTagList->query()->get(['tag_group_name as group','tag_name as name'])->toArray();
  696. // 标签列表
  697. $tagList = [];
  698. // 循环数据
  699. foreach ($tagData as $value) {
  700. $tagList[$value['group']][] = $value['name'];
  701. }
  702. // 分配数据
  703. $this->assign('tagList',$tagList);
  704. $this->assign('typeList',$typeList);
  705. $this->assign('cityList',$cityList);
  706. $this->assign('businessList',$businessList);
  707. $this->assign('producerList',$producerList);
  708. $this->assign('oldData',$oldData);
  709. $this->assign('photoList',$photoList);
  710. $this->assign('skuList',$skuList);
  711. $this->assign('specList',$specList);
  712. $this->assign('crumbs','修改');
  713. // 加载模板
  714. return $this->fetch();
  715. }
  716. /**
  717. * 编辑
  718. *
  719. * */
  720. public function copy(Request $request, Model $Model, WeiBanTagList $WeiBanTagList, ProductPhoto $ProductPhoto, Producer $Producer, Business $Business, ProductType $ProductType, ProductSpec $ProductSpec, ProductAttr $ProductAttr, ProductSkus $ProductSkus, City $City, ProductCity $ProductCity){
  721. if( request()->isMethod('post') ){
  722. // 验证参数
  723. $request->scene('add')->validate();
  724. // 组合数据
  725. $data['name'] = request('name','');
  726. $data['thumb'] = request('thumb','');
  727. $data['poster'] = request('poster','');
  728. $data['spec'] = request('spec','');
  729. $data['price'] = request('price',0);
  730. $data['market_price'] = request('market_price',0);
  731. $data['producer_id'] = request('producer_id',0);
  732. $data['business_id'] = request('business_id',0);
  733. $data['quota'] = request('quota',0);
  734. $data['min_quota'] = request('min_quota',0);
  735. $data['hide_orderbtn'] = request('hide_orderbtn',0);
  736. $data['sku_min_quota_and'] = request('sku_min_quota_and',0);
  737. $data['quota_start'] = request('quota_start','');
  738. $data['quota_end'] = request('quota_end','');
  739. $data['puton_time'] = request('puton_time','');
  740. $data['putoff_time'] = request('putoff_time','');
  741. $data['stock'] = request('stock',0);
  742. $data['type_id'] = request('type_id',0);
  743. $data['status'] = 1;
  744. $data['admin_uid'] = admin('uid');
  745. $description = request('description','');
  746. $attr = request('attr',[]);
  747. $skuList = request('sku',[]);
  748. $cityIds = request('city_ids',[]);
  749. $photoList = request('photo_list',[]);
  750. $tagScope = request('tag_scope',[]);
  751. $data['tag_scope'] = implode(',',$tagScope);
  752. $tagExclude = request('tag_exclude',[]);
  753. $data['tag_exclude'] = implode(',',$tagExclude);
  754. // 循环
  755. foreach ($photoList as $key => $value) {
  756. if( !$value ) unset($photoList[$key]);
  757. }
  758. $photoList = array_values($photoList);
  759. // 如果没有选择,则意味着全部
  760. $cityIds = $cityIds ? $cityIds : [1];
  761. $data['quota_start'] = $data['quota_start'] ? strtotime($data['quota_start']) : 0;
  762. $data['quota_end'] = $data['quota_end'] ? strtotime($data['quota_end']) : 0;
  763. $data['puton_time'] = $data['puton_time'] ? strtotime($data['puton_time']) : 0;
  764. $data['putoff_time'] = $data['putoff_time'] ? strtotime($data['putoff_time']) : 0;
  765. // 限购提示
  766. if( !$data['thumb'] ) return json_send(['code'=>'error','msg'=>'请上传产品主图','data'=>['error'=>'请上传产品主图']]);
  767. // 限购提示
  768. if( $attr && !$skuList ) return json_send(['code'=>'error','msg'=>'规格属性存在时,请填写SKU','data'=>['error'=>'规格属性存在时,请填写SKU']]);
  769. // 限购提示
  770. if( $data['quota'] && ( !$data['quota_start'] || !$data['quota_end'] )) return json_send(['code'=>'error','msg'=>'限购必填限购时间','data'=>['error'=>'限购必填限购时间']]);
  771. // 限购提示
  772. if($data['quota'] && $data['min_quota'] > $data['quota'] ) return json_send(['code'=>'error','msg'=>'起购数量请勿大于限购数量','data'=>['error'=>'起购数量请勿大于限购数量']]);
  773. // 总库存
  774. if( $skuList ) $data['stock'] = array_sum(array_column($skuList,'stock'));
  775. // SKU存在的时候,判断限购数量
  776. if( $skuList ) {
  777. // 循环处理
  778. foreach ($skuList as $attrNames => $value) {
  779. // SKU限购,所以限购时间也必须填
  780. if( $value['quota'] && ( !$data['quota_start'] || !$data['quota_end'] )) return json_send(['code'=>'error','msg'=>'SKU限购时,请填限购时间','data'=>['error'=>'SKU限购时,请填限购时间']]);
  781. // 限购提示
  782. if( $value['quota'] && $value['min_quota'] > $value['quota'] ) return json_send(['code'=>'error','msg'=>$attrNames.'起购数量请勿大于限购数量','data'=>['error'=>$attrNames.'起购数量请勿大于限购数量']]);
  783. }
  784. // 限购数量
  785. $quota = array_sum(array_column($skuList,'quota'));
  786. // 提示限购数量异常
  787. if( $data['quota'] && $data['quota'] < $quota ) return json_send(['code'=>'error','msg'=>'总限购数量不能小于SKU的限购数量','data'=>['error'=>'总限购数量不能小于SKU的限购数量']]);
  788. }
  789. // 总库存
  790. $data['stock_total'] = $data['stock'];
  791. // 总库存提醒
  792. if( $data['stock_total'] <= 0 ) return json_send(['code'=>'error','msg'=>'请设置库存','data'=>['error'=>'请设置库存']]);
  793. // 获取规格属性
  794. $specAttr = $this->getSpecAttr($attr,$ProductSpec,true);
  795. // 开启事务
  796. DB::beginTransaction();
  797. try {
  798. // 写入
  799. $id = $Model->add($data);
  800. // 提示新增失败
  801. if( !$id ) {
  802. // 回滚
  803. DB::rollBack();
  804. // 提示
  805. return json_send(['code'=>'error','msg'=>'新增失败']);
  806. }
  807. // 图册
  808. foreach ($photoList as $key => $value) {
  809. // 整理数据
  810. $value = ['sort'=>$key,'thumb'=>$value,'product_id'=>$id,'insert_time'=>time(),'update_time'=>time()];
  811. // 重新整理
  812. $photoList[$key] = $value;
  813. }
  814. // 存在图册
  815. if( $photoList ) {
  816. // 写入失败
  817. $result = $ProductPhoto->query()->insert($photoList);
  818. // 提示新增失败
  819. if( !$result ) {
  820. // 回滚
  821. DB::rollBack();
  822. // 提示
  823. return json_send(['code'=>'error','msg'=>'商品图册写入失败']);
  824. }
  825. }
  826. // 组合数据
  827. foreach ($specAttr as $key => $value) {
  828. // 查询结果
  829. $value['id'] = $ProductAttr->upsertByName($value,$id);
  830. // 提示新增失败
  831. if( !$value['id'] ) {
  832. // 回滚
  833. DB::rollBack();
  834. // 提示
  835. return json_send(['code'=>'error','msg'=>'商品属性新增失败']);
  836. }
  837. // 重组
  838. $specAttr[$key] = $value;
  839. }
  840. // 循环SKU
  841. foreach ($skuList as $attrNames => $value) {
  842. // 属性ID值
  843. $value['attr_ids'] = [];
  844. // 规格属性值组合
  845. $value['attr_names']= $attrNames;
  846. // 切割成数据
  847. $names = explode(',',$attrNames);
  848. // 循环处理
  849. foreach ($names as $name) {
  850. foreach ($specAttr as $vv) {
  851. if( $name == $vv['name'] ) {
  852. // 提示新增失败
  853. if( !$vv['id'] ) {
  854. // 回滚
  855. DB::rollBack();
  856. // 提示
  857. return json_send(['code'=>'error','msg'=>'属性SKU匹配失败']);
  858. }
  859. $value['attr_ids'][] = $vv['id'];
  860. }
  861. }
  862. }
  863. // 转成好存储的数据
  864. $value['attr_ids'] = implode(',',$value['attr_ids']);
  865. // 转成好存储的数据
  866. $value['product_id']= $id;
  867. // 转成好存储的数据
  868. $value['sku_thumb'] = (string) $value['sku_thumb'];
  869. // 转成好存储的数据
  870. $value['stock_total']= $value['stock'];
  871. // 转成好存储的数据
  872. $value['insert_time']= time();
  873. // 转成好存储的数据
  874. $value['update_time']= time();
  875. // SKU结果
  876. $skuList[$attrNames] = $value;
  877. }
  878. // 循环城市范围
  879. foreach ($cityIds as $key => $value) {
  880. // 重组数据
  881. $cityIds[$key] = ['city_id'=>$value,'product_id'=>$id,'insert_time'=>time(),'update_time'=>time()];
  882. }
  883. // 写入城市范围
  884. $ProductCity->query()->insert($cityIds);
  885. // 返回结果
  886. $result = $ProductSkus->insert($skuList);
  887. // 提示新增失败
  888. if( !$result ) {
  889. // 回滚
  890. DB::rollBack();
  891. // 提示
  892. return json_send(['code'=>'error','msg'=>'SKU插入失败']);
  893. }
  894. // 更新内容
  895. $Model->updateDesc($id,$description);
  896. // 提交
  897. DB::commit();
  898. // 记录行为
  899. $this->addAdminHistory(admin('uid'),$Model->getTable(),$id,1,[],$data);
  900. // 告知结果
  901. return json_send(['code'=>'success','msg'=>'新增成功','action'=>'add']);
  902. } catch (\Throwable $th) {
  903. // 回滚
  904. DB::rollBack();
  905. // 提示
  906. return json_send(['code'=>'error','msg'=>'系统异常,写入失败','data'=>$th->getMessage()]);
  907. }
  908. }
  909. // 接收参数
  910. $id = request('id',0);
  911. // 查询数据
  912. $oldData = $Model->where(['id'=>$id])->first();
  913. // 如果是没有数据
  914. if( !$oldData ) return $this->error('查无数据');
  915. // 产品信息转格式
  916. $oldData = $oldData->toArray();
  917. $oldData['description'] = $Model->getDesc($id);
  918. $oldData['city_ids'] = $ProductCity->getListByProductId($id);
  919. $oldData['tag_scope'] = explode(',',$oldData['tag_scope']);
  920. $oldData['tag_exclude'] = explode(',',$oldData['tag_exclude']);
  921. $photoList = $ProductPhoto->getListByProductId($id);
  922. // 获取产品属性
  923. $attrList = $ProductAttr->getListByProductId($id);
  924. // 规格属性
  925. $specList = [];
  926. // 获取数据
  927. foreach ($attrList as $value) {
  928. $value['active'] = 0;
  929. if( !isset($specList[$value['spec_id']]) ) $specList[$value['spec_id']] = $ProductSpec->getOne($value['spec_id']);
  930. $specList[$value['spec_id']]['attr_list'][] = $value;
  931. }
  932. // 产品类型
  933. $skuList = $ProductSkus->getListByProductId($id);
  934. // 循环处理
  935. foreach ($skuList as $key => $value) {
  936. // 数据解析
  937. $value['attr_ids'] = explode(',',$value['attr_ids']);
  938. // 循环处理
  939. foreach ( $value['attr_ids'] as $k=>$attrId ) {
  940. // 获取ids对应的name
  941. $value['attr_ids'][$k] = $ProductAttr->getValueById($attrId,'name');
  942. }
  943. // 数据合并
  944. $value['attr_ids'] = implode(',',$value['attr_ids']);
  945. // 重组
  946. $skuList[$key] = $value;
  947. }
  948. // 标签列表
  949. $tagData = $WeiBanTagList->query()->get(['tag_group_name as group','tag_name as name'])->toArray();
  950. // 标签列表
  951. $tagList = [];
  952. // 循环数据
  953. foreach ($tagData as $value) {
  954. $tagList[$value['group']][] = $value['name'];
  955. }
  956. // 获取类型数据
  957. $typeList = $ProductType->getList();
  958. $cityList = $City->getCityList();
  959. $businessList = $Business->getListByAdmin();
  960. $producerList = $Producer->getList();
  961. // 分配数据
  962. $this->assign('tagList',$tagList);
  963. $this->assign('typeList',$typeList);
  964. $this->assign('cityList',$cityList);
  965. $this->assign('businessList',$businessList);
  966. $this->assign('producerList',$producerList);
  967. $this->assign('oldData',$oldData);
  968. $this->assign('photoList',$photoList);
  969. $this->assign('skuList',$skuList);
  970. $this->assign('specList',$specList);
  971. $this->assign('crumbs','复制');
  972. // 加载模板
  973. return $this->fetch();
  974. }
  975. /**
  976. * 状态
  977. *
  978. * */
  979. public function set_status( Request $request, Model $Model ){
  980. // 验证参数
  981. $request->scene('set_status')->validate();
  982. // 接收参数
  983. $id = request('id',0);
  984. $status = request('status',0);
  985. // 查询数据
  986. $result = $Model->edit($id,['status'=>$status]);
  987. // 提示新增失败
  988. if( !$result ) return json_send(['code'=>'error','msg'=>'设置失败']);
  989. // 记录行为
  990. $this->addAdminHistory(admin('uid'),$Model->getTable(),$id,2,[],['status'=>$status]);
  991. // 告知结果
  992. return json_send(['code'=>'success','msg'=>'设置成功','path'=>'']);
  993. }
  994. /**
  995. * 获取某个类目下的规格
  996. *
  997. */
  998. public function get_spec_html( ProductSpec $ProductSpec){
  999. // 接收参数
  1000. $typeId = request('type_id',0);
  1001. // 查询数据
  1002. $specList = $ProductSpec->getList();
  1003. // 循环处理
  1004. foreach ($specList as $key => $value) {
  1005. if( $value['type_id'] != $typeId ) unset($specList[$key]);
  1006. }
  1007. // 分配数据
  1008. $this->assign('specList',$specList);
  1009. // 加载模板
  1010. return $this->fetch();
  1011. }
  1012. /**
  1013. * 获取某个类目下的规格
  1014. *
  1015. */
  1016. public function get_sku_html( ProductSpec $ProductSpec,ProductSkus $ProductSkus){
  1017. // 接收参数
  1018. $attr = request('attr',[]);
  1019. $id = request('product_id',0);
  1020. // 产品类型
  1021. $oldSkus = $id ? $ProductSkus->getListByProductId($id) : [];
  1022. // 获取规格属性
  1023. $specAttr = $this->getSpecAttr($attr,$ProductSpec);
  1024. // 组合SKU
  1025. $brushList = [];
  1026. // 循环规格属性
  1027. foreach ($specAttr as $specId => $value) {
  1028. // 获取SKU组合
  1029. $brushList[$specId] = array_column($value['attr_list'],'name');
  1030. }
  1031. // sku列表
  1032. $skuList = $this->brush([],$brushList);
  1033. // 循环规格属性
  1034. foreach ($skuList as $newKey => $new) {
  1035. // 获取新数据
  1036. $new = ['attr_names'=>$new,'price'=>0,'market_price'=>0,'stock'=>0,'min_quota'=>0,'quota'=>0,'status'=>0,'sku_thumb'=>''];
  1037. // 循环旧的sku
  1038. foreach ($oldSkus as $old) {
  1039. // 如果有相等的规格
  1040. if( $old['attr_names'] == $new['attr_names']) {
  1041. $new['sku_thumb'] = $old['sku_thumb'];
  1042. $new['market_price']= $old['market_price'];
  1043. $new['price'] = $old['price'];
  1044. $new['stock'] = $old['stock'];
  1045. $new['status'] = $old['status'];
  1046. $new['min_quota'] = $old['min_quota'];
  1047. $new['quota'] = $old['quota'];
  1048. }
  1049. }
  1050. $skuList[$newKey] = $new;
  1051. }
  1052. // 分配数据
  1053. $this->assign('specAttr',$specAttr);
  1054. $this->assign('skuList',$skuList);
  1055. // 加载模板
  1056. return $this->fetch();
  1057. }
  1058. /**
  1059. * 获取规格属性
  1060. * @param ProductSpec $ProductSpec
  1061. *
  1062. */
  1063. private function getSpecAttr($attr,$ProductSpec,$onlyList=false){
  1064. // 组合参数
  1065. $specAttr = [];
  1066. // 循环处理数据
  1067. foreach ($attr as $specId => $value) {
  1068. $specAttr[$specId]['spec_id'] = $specId;
  1069. $specAttr[$specId]['spec_name'] = $ProductSpec->getOne($specId,'name');
  1070. $specAttr[$specId]['attr_list'] = [];
  1071. foreach ($value['name'] as $key => $name) {
  1072. // 如果没有名称的,跳过
  1073. if( !$name ) continue;
  1074. // 结果
  1075. $temp = ['id'=>0,'spec_id'=>$specId,'thumb'=>'','name'=>'','remark'=>''];
  1076. // 获取名称
  1077. $temp['name'] = str_ireplace(',','',$name);
  1078. // 获取对应的备注信息
  1079. if( !empty($value['remark'][$key]) ) $temp['remark'] = $value['remark'][$key];
  1080. if( !empty($value['thumb'][$key]) ) $temp['thumb'] = $value['thumb'][$key];
  1081. // 获取对应的数据
  1082. $specAttr[$specId]['attr_list'][]= $temp;
  1083. }
  1084. // 没有属性的规格,移除
  1085. if( !$specAttr[$specId]['attr_list'] ) unset($specAttr[$specId]);
  1086. }
  1087. // 仅获取属性列表
  1088. if( $onlyList ) {
  1089. // 属性列表
  1090. $attrList = [];
  1091. // 判断结果
  1092. foreach ($specAttr as $value) {
  1093. // 获取数据
  1094. array_push($attrList,...$value['attr_list']);
  1095. }
  1096. // 返回结果
  1097. $specAttr = $attrList;
  1098. }
  1099. // 返回结果
  1100. return $specAttr;
  1101. }
  1102. /**
  1103. * 组合SKU
  1104. *
  1105. */
  1106. private function brush($res = [], $arr = []){
  1107. // 获取第一个规格的属性
  1108. if (empty($res)) $res = (array) array_shift($arr);
  1109. // 如果只有一个规格,返回该规格的属性即可
  1110. if (empty($arr)) return $res;
  1111. // 接下来要参与计算的一组属性
  1112. $current = array_shift($arr);
  1113. // 计算的列表
  1114. $last = [];
  1115. // 循环上一次已经算出的集合
  1116. foreach ($res as $attr) {
  1117. foreach ($current as $col_val) {
  1118. $last[] = $attr . ',' . $col_val;
  1119. }
  1120. }
  1121. return $this->brush($last,$arr); # 递归处理, 直到$arr滚到最后一组属性
  1122. }
  1123. /**
  1124. * 排序
  1125. *
  1126. * */
  1127. public function set_sort( Request $request, Model $Model ){
  1128. // 验证参数
  1129. $request->scene('set_sort')->validate();
  1130. // 接收参数
  1131. $id = request('id',0);
  1132. $sort = request('sort',0);
  1133. // 查询数据
  1134. $result = $Model->edit($id,['sort'=>$sort]);
  1135. // 提示新增失败
  1136. if( !$result ) return json_send(['code'=>'error','msg'=>'设置失败']);
  1137. // 记录行为
  1138. $this->addAdminHistory(admin('uid'),$Model->getTable(),$id,2,[],['sort'=>$sort]);
  1139. // 告知结果
  1140. return json_send(['code'=>'success','msg'=>'设置成功','path'=>'']);
  1141. }
  1142. /**
  1143. * 排序
  1144. *
  1145. * */
  1146. public function batch_status( Request $request, Model $Model ){
  1147. // 验证参数
  1148. // $request->scene('batch_status')->validate();
  1149. // 接收参数
  1150. $idList = request('product_list',[]);
  1151. $status = request('status',0);
  1152. // 查询对应的数据
  1153. $oldList = $Model->query()->whereIn('status',$status ? [0,2] : [1,3,4])->whereIn('id',$idList)->get(['id','status','puton_time'])->toArray();
  1154. // 没有符合条件的数据
  1155. if( !$oldList ) return json_send(['code'=>'error','msg'=>'无可操作数据']);
  1156. // 开启事务
  1157. DB::beginTransaction();
  1158. // 循环数据
  1159. foreach ($oldList as $value) {
  1160. // 如果是上架操作,判断是不是要设置预上架;如果是下架动作,统一下架
  1161. $editStatus = $status == 0 ? ($value['puton_time'] ? 2 : 0) : 3;
  1162. // 如果是有上架时间, 预上架,否则直接上架
  1163. $result = $Model->edit($value['id'],['status'=>$editStatus]);
  1164. // 提示新增失败
  1165. if( !$result ) {
  1166. // 事务回滚
  1167. DB::rollBack();
  1168. // 返回提示
  1169. return json_send(['code'=>'error','msg'=>'设置失败']);
  1170. }
  1171. // 记录行为
  1172. $this->addAdminHistory(admin('uid'),$Model->getTable(),$value['id'],2,$value,['status'=>$editStatus]);
  1173. }
  1174. // 提交事务
  1175. DB::commit();
  1176. // 告知结果
  1177. return json_send(['code'=>'success','msg'=>'设置成功','path'=>'']);
  1178. }
  1179. }