CartPurchase.php 5.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127
  1. <?php
  2. namespace addons\UpgradeGift\common\logic\order\purchase;
  3. use common\enums\AppEnum;
  4. use common\enums\GoodsTypeEnum;
  5. use common\enums\StatusEnum;
  6. use common\helpers\ArrayHelper;
  7. use common\helpers\BcHelper;
  8. use common\models\goods\GoodsAttr;
  9. use common\models\order\OrderDetail;
  10. use common\models\user\User;
  11. use common\models\user\UserSignAgreement;
  12. use Yii;
  13. use yii\helpers\Json;
  14. use Exception;
  15. // 购物车付款订单处理
  16. class CartPurchase extends BasePurchase {
  17. /**
  18. * 执行
  19. * @Author bing
  20. * @DateTime 2021-09-23 09:46:41
  21. * @copyright: Copyright (c) 2020 广东七件事集团
  22. * @param $form
  23. * @return
  24. */
  25. public function execute($form){
  26. $form->data = $data = is_array($form->data)?$form->data:Json::decode($form->data,true);
  27. $attr_ids = $data['attr_ids'];
  28. $redis = Yii::$app->redis;
  29. $result = $redis->hmget('cart_'.$form->user_id,...$attr_ids);
  30. $user = User::getOne([['id'=>$form->user_id,'mall_id'=>$form->mall_id]]);
  31. if(empty($user)) throw new Exception('下单用户不存在');
  32. $carts = array_map(function ($val){
  33. return $val?json_decode($val,true):[];
  34. },$result);
  35. $attr_id_arr = array_column($carts,'attr_id');
  36. if(empty($attr_id_arr)) throw new Exception('购物车为空');
  37. $num_arr = array_column($carts,'num','attr_id');
  38. $params['where'] = [['=','status',StatusEnum::ENABLED],['id'=>$attr_id_arr]];
  39. $params['with'] = ['goods','goods.extra'];
  40. $sku_arr = GoodsAttr::lists($params,true);
  41. $goods_type = [];
  42. foreach ($sku_arr as $sku){
  43. if(empty($sku['goods']['is_on_sale'])) throw new Exception('商品' . $sku['goods']['goods_name'] . '已下架! ');
  44. if(!in_array($sku['goods']['goods_type'],$goods_type)) $goods_type[] =$sku['goods']['goods_type'];
  45. }
  46. if(count($goods_type)>1) throw new Exception('不同类型的商品不能一起下单');
  47. if(!empty($goods_type)&&in_array($goods_type[0],[GoodsTypeEnum::GoodsTypePhysical])) {
  48. $data['mall_id'] = $form->mall_id;
  49. $this->checkAddress($form['action'],$data,$form->user_id);
  50. $form['is_address'] = 1;
  51. }
  52. $form['is_virtual'] = 0;
  53. if(!empty($goods_type)&&in_array($goods_type[0],[GoodsTypeEnum::GoodsTypeVirtual])) {
  54. $form['is_virtual'] = 1;
  55. }
  56. $tmp_order_goods = [];
  57. foreach ($sku_arr as $sku){
  58. if(empty($sku) || empty($sku['goods'])) throw new Exception('该下单的产品不存在或者已经删除');
  59. if(empty($num_arr[$sku['id']])) throw new Exception('请设置正确的下单数量');
  60. $buy_num = $num_arr[$sku['id']];
  61. if ($buy_num > $sku['stock']) throw new Exception('商品' . $sku['goods']['goods_name'] . '库存不足! ');
  62. $mch_id = $sku['goods']['mch_id'];
  63. // if ($form->action == AppEnum::ACTION_PREVIEW) {
  64. // 记录所属供应链
  65. if (empty($form->process_extra_data['supply_chain'][$sku['goods_id']])) {
  66. $form->process_extra_data['supply_chain'][$sku['goods_id']] = $sku['goods']['goods_source'];
  67. }
  68. if (!empty($sku['goods']['goods_source'])) $mch_id = $sku['goods']['goods_source'];
  69. // }
  70. $order_goods = new OrderDetail();
  71. $order_goods = $order_goods->loadDefaultValues();
  72. $order_goods->goods_id = $sku['goods_id'];
  73. $order_goods->goods_name = $sku['goods']['goods_name'];
  74. $order_goods->goods_attr_id = $sku['id'];
  75. $order_goods->sign_id = $sku['sign_id'];
  76. $order_goods->goods_attr_name = $sku['name'];
  77. $order_goods->num = $buy_num;
  78. $order_goods->cost_price = $sku['cost_price'];
  79. $order_goods->price = $sku['price'];
  80. $order_goods->goods_price = BcHelper::mul($order_goods->num, $order_goods->price);
  81. $order_goods->original_goods_price = $order_goods->goods_price;
  82. $order_goods->pic_url = !empty($sku['pic_url']) ? $sku['pic_url'] : $sku['goods']['cover_pic'];
  83. $order_goods->user_id = $form->user_id;
  84. $order_goods->mch_id = $mch_id;
  85. $order_goods->mall_id = $form->mall_id;
  86. $order_goods->is_virtual = $form->is_virtual;
  87. // 默认数据带下单数量方便计算
  88. $goods = $sku['goods'];
  89. $goods['number'] = $buy_num;
  90. $form->order_goods[] = $tmp_order_goods =ArrayHelper::toArray($order_goods);
  91. $form->sku[$sku['goods_id']] = $sku;
  92. $form->user = $user;
  93. }
  94. if (!empty($form->process_extra_data['supply_chain'])) {
  95. $t_supply_chain = array_unique(array_values($form->process_extra_data['supply_chain']));
  96. if (count($t_supply_chain) > 2) throw new Exception("单次只能选择一个供应链的商品");
  97. }
  98. // 签署升级协判断 0不需要签署,1需要签署
  99. $is_sign_agreement = UserSignAgreement::checkIsNeedSign($user['level'], array_column($tmp_order_goods, 'goods_id'), $form->mall_id, $form->user_id);
  100. $form->is_sign_agreement = $is_sign_agreement;
  101. return $form;
  102. }
  103. /**
  104. * 获取下单类型
  105. * @Author bing
  106. * @DateTime 2021-09-23 09:48:45
  107. * @copyright: Copyright (c) 2020 广东七件事集团
  108. * @return string
  109. */
  110. public static function getType(): string{
  111. return 'cart';
  112. }
  113. }