Product.php 45 KB

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