ShopCart.php 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365
  1. <?php namespace App\Http\Controllers\Api;
  2. use App\Http\Controllers\Api\Api;
  3. use App\Http\Requests\Api\ShopCart as Request;
  4. use App\Models\Product\Skus as ProductSkus;
  5. use App\Models\PromoRebate;
  6. use App\Models\ShopCart as Model;
  7. use App\Models\PromoProduct as PromoProduct;
  8. use App\Models\Custom as Custom;
  9. use App\Models\WeiBan\Tags as WeiBanTags;
  10. /**
  11. * 购物车接口
  12. *
  13. * @author 刘相欣
  14. *
  15. * */
  16. class ShopCart extends Api{
  17. /**
  18. * 添加 /api/shop_cart/add
  19. *
  20. * @param int $product_id 产品ID
  21. * @param int $buy_num 添加数量
  22. *
  23. * */
  24. public function add(Request $request,Model $Model){
  25. // 接口验签
  26. // $this->verify_sign();
  27. // 验证参数
  28. $request->scene('add')->validate();
  29. // 检查登录
  30. $uid = $this->checkLogin();
  31. // 接收参数
  32. $data['product_id'] = request('product_id',0);
  33. $data['skuid'] = request('skuid',0);
  34. $data['buy_num'] = request('buy_num',1);
  35. $data['custom_uid'] = $uid;
  36. // 查询
  37. $id = $Model->query()->where([['custom_uid','=',$uid],['product_id','=',$data['product_id']],['skuid','=',$data['skuid']]])->value('id');
  38. // 如果存在id,更新数量
  39. $result = $id ? $Model->incrBuyNum($id,$uid,$data['buy_num']) : $Model->add($data);
  40. // 提交结果
  41. if( !$result ) return json_send(['code'=>'success','msg'=>'加入购物车失败','data'=>['error'=>'加入购物车失败']]);
  42. // 返回结果
  43. return json_send(['code'=>'success','msg'=>'添加成功','data'=>$data]);
  44. }
  45. /**
  46. * 更新 /api/shop_cart/edit
  47. *
  48. * @param int $id 购物车id
  49. *
  50. * */
  51. public function edit(Request $request,Model $Model){
  52. // 接口验签
  53. // $this->verify_sign();
  54. // 验证参数
  55. $request->scene('edit')->validate();
  56. // 检查登录
  57. $uid = $this->checkLogin();
  58. // 接收参数
  59. $id = request('id',0);
  60. $data['buy_num'] = request('buy_num',1);
  61. // 如果存在id,更新数量
  62. $result = $Model->edit($id,$uid,$data);
  63. // 提交结果
  64. if( !$result ) return json_send(['code'=>'success','msg'=>'更新失败','data'=>['error'=>'更新购物车失败']]);
  65. // 返回结果
  66. return json_send(['code'=>'success','msg'=>'更新成功','data'=>$data]);
  67. }
  68. /**
  69. * 更新 /api/shop_cart/del
  70. *
  71. * @param int $id 购物车id
  72. *
  73. * */
  74. public function del(Request $request,Model $Model){
  75. // 接口验签
  76. // $this->verify_sign();
  77. // 验证参数
  78. $request->scene('del')->validate();
  79. // 检查登录
  80. $uid = $this->checkLogin();
  81. // 接收参数
  82. $id = request('id',0);
  83. // 如果存在id,更新数量
  84. $result = $Model->del($id,$uid);
  85. // 提交结果
  86. if( !$result ) return json_send(['code'=>'success','msg'=>'删除失败','data'=>['error'=>'删除购物车失败']]);
  87. // 返回结果
  88. return json_send(['code'=>'success','msg'=>'删除成功','data'=>['id'=>$id]]);
  89. }
  90. /**
  91. * 获取列表 /api/shop_cart/get_list
  92. *
  93. * @param int $id 购物车id
  94. *
  95. * */
  96. public function get_list(Request $request,Model $Model,ProductSkus $ProductSkus,PromoProduct $PromoProduct,Custom $Custom,WeiBanTags $WeiBanTags){
  97. // 接口验签
  98. // $this->verify_sign();
  99. // 验证参数
  100. $request->scene('get_list')->validate();
  101. // 检查登录
  102. $uid = $this->checkLogin();
  103. // 获取客户信息
  104. $custom = $uid ? $Custom->getOne($uid) : [];
  105. // 显示
  106. $map = [['shop_cart.custom_uid','=',$uid]];
  107. // 查询
  108. $list = $Model->query()->join('product','shop_cart.product_id','=','product.id')->where($map)->get(['shop_cart.id','shop_cart.checked','shop_cart.product_id','shop_cart.skuid','shop_cart.buy_num','product.stock','product.spec','product.thumb','product.name','product.price','product.market_price','product.status as product_status'])->toArray();
  109. // 判断结果
  110. $skusList = $ProductSkus->getListByIds(array_column($list,'skuid'));
  111. //查询产品活动
  112. $promoList = $PromoProduct->getListByIds(array_column($list,'product_id'));
  113. // 查询用户标签
  114. $tags = [];
  115. $cityId = '';
  116. if ($custom){
  117. $tags = $WeiBanTags->getListByWeibanExtid($custom['weiban_extid']);
  118. $cityId = $custom['city_id'];
  119. }
  120. // 循环处理数据
  121. foreach ($list as $key => $value) {
  122. // 如果有sku
  123. if( $value['skuid'] ) {
  124. // 是否存在
  125. $isExist = false;
  126. // 循环SKU
  127. foreach ($skusList as $sku) {
  128. // 如果SKU存在的话
  129. if( $sku['sku_id'] == $value['skuid'] ) {
  130. $value['price'] = $sku['price'];
  131. $value['spec'] = $sku['sku_attr_names'];
  132. $value['stock'] = $sku['stock'];
  133. $isExist = true;
  134. }
  135. }
  136. // 如果不存在,状态变动
  137. if( !$isExist ) $value['product_status'] = 4;
  138. }
  139. if ($promoList && $cityId){
  140. if (isset($promoList[$value['product_id']])){
  141. $promoInfo = $promoList[$value['product_id']];
  142. $promoTitle = "满". $promoInfo['std_pay']. "元";
  143. if ($promoInfo['rebate_type'] == 1){
  144. $promoTitle .= "减". $promoInfo['rebate']. "元";
  145. }elseif ($promoInfo['rebate_type'] == 2){
  146. $promoTitle .= "打". $promoInfo['rebate']. "折";
  147. }elseif ($promoInfo['rebate_type'] == 3){
  148. $rebate = (string) PromoRebate::query()->join('product','promo_rebate.product_id','=','product.id')->where([['promo_id','=',$promoInfo['id']]])->value('product.name');
  149. $promoTitle .= "赠送". $rebate;
  150. }
  151. $promoInfoCity = explode(',',$promoInfo['city_ids']);
  152. // 判断是不是可以参与
  153. if (in_array($cityId,$promoInfoCity)){
  154. if( $promoInfo['tag_scope']) {
  155. // 解析数组
  156. $promoInfo['tag_scope'] = explode(',',$promoInfo['tag_scope']);
  157. // 标签范围限定时,默认不能参与
  158. $allowJoin = 0;
  159. // 判断标签是不是存在
  160. if ($tags){
  161. foreach ($tags as $v) {
  162. // 标签范围内,允许参加
  163. if( in_array($v['name'],$promoInfo['tag_scope']) ) $allowJoin = 1;
  164. }
  165. // 在范围
  166. if( $allowJoin ) {
  167. $value['promo_title'] = $promoTitle;
  168. }
  169. }
  170. }else{
  171. $value['promo_title'] = $promoTitle;
  172. }
  173. }
  174. }
  175. }
  176. // 产品图路径
  177. $value['thumb'] = path_compat($value['thumb']);
  178. // 库存超出的时候
  179. if($value['buy_num'] > $value['stock'] ) $value['buy_num'] = $value['stock'];
  180. // 重组
  181. $list[$key] = $value;
  182. }
  183. // 返回结果
  184. return json_send(['code'=>'success','msg'=>'获取成功','data'=>$list]);
  185. }
  186. /**
  187. * 结算列表 /api/shop_cart/check_list
  188. *
  189. * @param int $id 购物车id
  190. *
  191. * */
  192. public function check_list(Request $request,Model $Model,ProductSkus $ProductSkus,PromoProduct $PromoProduct,Custom $Custom,WeiBanTags $WeiBanTags){
  193. // 接口验签
  194. // $this->verify_sign();
  195. // 验证参数
  196. $request->scene('check_list')->validate();
  197. // 检查登录
  198. $uid = $this->checkLogin();
  199. // 获取客户信息
  200. $custom = $uid ? $Custom->getOne($uid) : [];
  201. // 接收参数
  202. $cartIds = request('cart_ids','');
  203. // 转成数组
  204. $cartIds = explode(',',$cartIds);
  205. // 循环处理
  206. foreach ($cartIds as $key => $value) {
  207. // 如果不是数值
  208. if( $value < 1 ) unset($cartIds[$key]);
  209. }
  210. // 如果不存在的话
  211. if( !$cartIds ) return json_send(['code'=>'error','msg'=>'请选择可用产品','data'=>['error'=>request('cart_ids','')]]);
  212. // 显示
  213. $map = [['shop_cart.custom_uid','=',$uid],['product.status','=',0]];
  214. // 查询
  215. $list = $Model->query()->join('product','shop_cart.product_id','=','product.id')->whereIn('shop_cart.id',$cartIds)->where($map)->get(['shop_cart.id','shop_cart.checked','shop_cart.product_id','shop_cart.skuid','shop_cart.buy_num','product.stock','product.spec','product.thumb','product.name','product.price','product.market_price','product.status as product_status'])->toArray();
  216. // 判断结果
  217. $skusList = $ProductSkus->getListByIds(array_column($list,'skuid'));
  218. //查询产品活动
  219. $promoList = $PromoProduct->getListByIds(array_column($list,'product_id'));
  220. // 查询用户标签
  221. $tags = [];
  222. $cityId = '';
  223. if ($custom){
  224. $tags = $WeiBanTags->getListByWeibanExtid($custom['weiban_extid']);
  225. $cityId = $custom['city_id'];
  226. }
  227. $promoProductList = [];
  228. // 循环处理数据
  229. foreach ($list as $key => $value) {
  230. // 如果有sku
  231. if( $value['skuid'] ) {
  232. // 是否存在
  233. $isExist = false;
  234. // 循环SKU
  235. foreach ($skusList as $sku) {
  236. // 如果SKU存在的话
  237. if( $sku['sku_id'] == $value['skuid'] ) {
  238. $value['price'] = $sku['price'];
  239. $value['spec'] = $sku['sku_attr_names'];
  240. $value['stock'] = $sku['stock'];
  241. $isExist = true;
  242. }
  243. }
  244. // 如果不存在,状态变动
  245. if( !$isExist ) {
  246. unset($list[$key]);
  247. continue;
  248. }
  249. }
  250. // 如果不存在,状态变动
  251. if( $value['stock'] <= 0 ) {
  252. unset($list[$key]);
  253. continue;
  254. }
  255. if ($promoList && $cityId){
  256. if (isset($promoList[$value['product_id']])){
  257. $promoInfo = $promoList[$value['product_id']];
  258. $promoInfo['price'] = $value['price'] * $value['buy_num'];
  259. $promoTitle = "满". $promoInfo['std_pay']. "元";
  260. if ($promoInfo['rebate_type'] == 1){
  261. $promoTitle .= "减". $promoInfo['rebate']. "元";
  262. }elseif ($promoInfo['rebate_type'] == 2){
  263. $promoTitle .= "打". $promoInfo['rebate']. "折";
  264. }elseif ($promoInfo['rebate_type'] == 3){
  265. $rebate = (string) PromoRebate::query()->join('product','promo_rebate.product_id','=','product.id')->where([['promo_id','=',$promoInfo['id']]])->value('product.name');
  266. $promoTitle .= "赠送". $rebate;
  267. }
  268. $promoInfoCity = explode(',',$promoInfo['city_ids']);
  269. // 判断是不是可以参与
  270. if (in_array($cityId,$promoInfoCity)){
  271. if( $promoInfo['tag_scope']) {
  272. // 解析数组
  273. $promoInfo['tag_scope'] = explode(',',$promoInfo['tag_scope']);
  274. // 标签范围限定时,默认不能参与
  275. $allowJoin = 0;
  276. // 判断标签是不是存在
  277. if ($tags){
  278. foreach ($tags as $v) {
  279. // 标签范围内,允许参加
  280. if( in_array($v['name'],$promoInfo['tag_scope']) ) $allowJoin = 1;
  281. }
  282. // 在范围
  283. if( $allowJoin ) {
  284. $value['promo_title'] = $promoTitle;
  285. $promoProductList[$promoInfo['id']][] = $promoInfo;
  286. }
  287. }
  288. }else{
  289. $value['promo_title'] = $promoTitle;
  290. $promoProductList[$promoInfo['id']][] = $promoInfo;
  291. }
  292. }
  293. }
  294. }
  295. // 产品图路径
  296. $value['thumb'] = path_compat($value['thumb']);
  297. // 库存超出的时候
  298. if($value['buy_num'] > $value['stock'] ) $value['buy_num'] = $value['stock'];
  299. // 重组
  300. $list[$key] = $value;
  301. }
  302. $promoRebateIds = [];
  303. //满折扣
  304. $discount = 0;
  305. //满减
  306. $reduction = 0;
  307. //计算产品促销活动优惠价格
  308. if ($promoProductList){
  309. foreach ($promoProductList as $key => $value){
  310. $priceSum = array_sum(array_column($value,'price'));
  311. if ($priceSum >= $value[0]['std_pay']) {
  312. switch ($value[0]['rebate_type']){
  313. case 1:
  314. $reduction += $value[0]['rebate'];
  315. break;
  316. case 2:
  317. $discount += $priceSum - number_format($priceSum * $value[0]['rebate']/10,2);
  318. break;
  319. case 3:
  320. $promoRebateIds[] = $key;
  321. }
  322. }
  323. }
  324. }
  325. $promoRebateList = [];
  326. //如果有赠品
  327. if ($promoRebateIds){
  328. $promoRebateList = PromoRebate::query()
  329. ->join('product','promo_rebate.product_id','=','product.id')
  330. ->where('status','=',0)
  331. ->whereIn('promo_id',$promoRebateIds)
  332. ->select(['promo_rebate.id as promo_rebate_id','promo_rebate.rebate_num as buy_num','product.stock','product.spec','product.thumb','product.name','product.price','product.market_price','product.status as product_status'])
  333. ->get()
  334. ->toArray();
  335. if ($promoRebateList){
  336. foreach ($promoRebateList as &$value){
  337. // 产品图路径
  338. $value['thumb'] = path_compat($value['thumb']);
  339. // 库存超出的时候
  340. if($value['buy_num'] > $value['stock'] && $value['stock'] > 0) $value['buy_num'] = $value['stock'];
  341. }
  342. }
  343. }
  344. // 重组数组
  345. $list = array_values($list);
  346. // 返回结果
  347. return json_send(['code'=>'success','msg'=>'获取成功','data'=>$list,'discount'=>$discount,'reduction'=>$reduction,'promoRebateList'=>$promoRebateList]);
  348. }
  349. }