Checkout.php 9.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258
  1. <?php
  2. // +----------------------------------------------------------------------
  3. // | 萤火商城系统 [ 致力于通过产品和服务,帮助商家高效化开拓市场 ]
  4. // +----------------------------------------------------------------------
  5. // | Copyright (c) 2017~2021 https://www.yiovo.com All rights reserved.
  6. // +----------------------------------------------------------------------
  7. // | Licensed 这不是一个自由软件,不允许对程序代码以任何形式任何目的的再发行
  8. // +----------------------------------------------------------------------
  9. // | Author: 萤火科技 <admin@yiovo.com>
  10. // +----------------------------------------------------------------------
  11. declare (strict_types=1);
  12. namespace app\index\controller;
  13. use app\index\model\Order as OrderModel;
  14. use app\index\service\order\PaySuccess;
  15. use app\index\service\User as UserService;
  16. use app\index\service\Cart as CartService;
  17. use app\index\service\order\Checkout as CheckoutService;
  18. use app\index\validate\order\Checkout as CheckoutValidate;
  19. use app\common\enum\order\PayType as OrderPayTypeEnum;
  20. use app\common\library\paypal\PayPal;
  21. use cores\exception\BaseException;
  22. use think\facade\Cache;
  23. use think\facade\Session;
  24. use think\response\Json;
  25. /**
  26. * 订单结算控制器
  27. * Class Checkout
  28. * @package app\api\controller
  29. */
  30. class Checkout extends Controller
  31. {
  32. // 结算台验证器
  33. /* @var CheckoutValidate $validate */
  34. private $validate;
  35. /**
  36. * 结算台订单信息
  37. * @param string $mode
  38. * @return Json
  39. * @throws BaseException
  40. * @throws \think\db\exception\DataNotFoundException
  41. * @throws \think\db\exception\DbException
  42. * @throws \think\db\exception\ModelNotFoundException
  43. */
  44. public function order(string $mode = 'buyNow'): Json
  45. {
  46. if ($mode === 'buyNow') {
  47. return $this->buyNow();
  48. } elseif ($mode === 'cart') {
  49. return $this->cart();
  50. }
  51. return $this->renderError('结算模式不合法');
  52. }
  53. /**
  54. * 订单提交
  55. * @param string $mode
  56. * @return Json
  57. * @throws BaseException
  58. * @throws \think\db\exception\DataNotFoundException
  59. * @throws \think\db\exception\DbException
  60. * @throws \think\db\exception\ModelNotFoundException
  61. */
  62. public function submit(string $mode = 'buyNow'): Json
  63. {
  64. $userId = Session::get('user_id');
  65. \think\facade\Log::info('submit:'.$userId);
  66. if (empty($userId)) {
  67. return $this->renderJson(config('status.not_logged'), 'Log in please!');
  68. }
  69. return $this->order($mode);
  70. }
  71. /**
  72. * 订单确认-立即购买
  73. * @return Json
  74. * @throws BaseException
  75. * @throws \think\db\exception\DataNotFoundException
  76. * @throws \think\db\exception\DbException
  77. * @throws \think\db\exception\ModelNotFoundException
  78. */
  79. private function buyNow(): Json
  80. {
  81. // 实例化结算台服务
  82. $Checkout = new CheckoutService;
  83. // 订单结算api参数
  84. $params = $Checkout->setParam($this->getParam([
  85. 'goodsId' => 0,
  86. 'goodsSkuId' => '',
  87. 'goodsNum' => 0,
  88. ]));
  89. // 表单验证
  90. if (!$this->getValidate()->scene('buyNow')->check($params)) {
  91. return $this->renderError($this->getValidate()->getError(), ['isCreated' => false]);
  92. }
  93. // 立即购买:获取订单商品列表
  94. $model = new OrderModel;
  95. $goodsList = $model->getOrderGoodsListByNow(
  96. (int)$params['goodsId'],
  97. (string)$params['goodsSkuId'],
  98. (int)$params['goodsNum']
  99. );
  100. // 获取订单确认信息
  101. $orderInfo = $Checkout->onCheckout($goodsList);
  102. if ($this->request->isGet()) {
  103. return $this->renderSuccess([
  104. 'order' => $orderInfo,
  105. 'personal' => $Checkout->getPersonal(),
  106. 'setting' => $Checkout->getSetting(),
  107. ]);
  108. }
  109. // 验证订单是否存在错误
  110. if ($Checkout->hasError()) {
  111. return $this->renderError($Checkout->getError(), ['is_created' => false]);
  112. }
  113. // 创建订单
  114. if (!$Checkout->createOrder($orderInfo)) {
  115. return $this->renderError($Checkout->getError() ?: '订单创建失败', ['is_created' => false]);
  116. }
  117. // 构建微信支付请求
  118. $payment = $model->onOrderPayment($Checkout->model, $params['payType']);
  119. // 返回结算信息
  120. return $this->renderSuccess([
  121. 'orderId' => $Checkout->model['order_id'], // 订单id
  122. 'payType' => $params['payType'], // 支付方式
  123. 'payment' => $payment // 微信支付参数
  124. ]);
  125. }
  126. /**
  127. * 订单确认-购物车结算
  128. * @return Json
  129. * @throws BaseException
  130. * @throws \think\db\exception\DataNotFoundException
  131. * @throws \think\db\exception\DbException
  132. * @throws \think\db\exception\ModelNotFoundException
  133. */
  134. private function cart(): Json
  135. {
  136. // 实例化结算台服务
  137. $Checkout = new CheckoutService;
  138. // 订单结算api参数
  139. $params = $Checkout->setParam($this->getParam());
  140. // 购物车ID集
  141. //$cartIds = $this->getCartIds();//不需要接口传过来
  142. $CartModel = new CartService;
  143. $cartIds = $CartModel->getCartIds();
  144. // 商品结算信息
  145. // 购物车商品列表
  146. $goodsList = $CartModel->getOrderGoodsList($cartIds);
  147. if (empty($goodsList)) {
  148. return $this->renderError('请选择商品结算');
  149. }
  150. // 获取订单结算信息
  151. $orderInfo = $Checkout->onCheckout($goodsList);
  152. if ($this->request->isGet()) {
  153. return $this->renderSuccess([
  154. 'order' => $orderInfo,
  155. 'personal' => $Checkout->getPersonal(),
  156. 'setting' => $Checkout->getSetting(),
  157. ]);
  158. }
  159. // 验证订单是否存在错误
  160. if ($Checkout->hasError()) {
  161. return $this->renderError($Checkout->getError(), ['is_created' => false]);
  162. }
  163. // 创建订单
  164. if (!$Checkout->createOrder($orderInfo)) {
  165. return $this->renderError($Checkout->getError() ?: '订单创建失败');
  166. }
  167. // 移出购物车中已下单的商品
  168. $CartModel->clear($cartIds);
  169. // 构建微信支付请求
  170. $payment = $Checkout->onOrderPayment();
  171. if ($params['payType'] == OrderPayTypeEnum::POINTS){
  172. if (!$payment['flag']){
  173. return $this->renderError($payment['message'] ?? '兑换失败');
  174. }
  175. }
  176. // 返回状态,如果是paypal支付,需要给用户跳转页面之外,还需要轮训查询订单的支付情况,如果支付成功,则弹窗提示,超过一分钟的话,提示支付超时,请重试
  177. return $this->renderSuccess([
  178. 'orderId' => $Checkout->model['order_id'], // 订单id
  179. 'payType' => $params['payType'], // 支付方式
  180. 'payment' => $payment // 微信支付参数
  181. ]);
  182. }
  183. /**
  184. * @return \think\response\View
  185. */
  186. public function payPayExecutePay($orderNo, $token)
  187. {
  188. if (empty($orderNo) || empty($token)){
  189. return view('payError',['notice'=>lang('login success')]);
  190. }
  191. $oriToken = Cache::get(PayPal::PRE_STR . $orderNo);
  192. if ($token != $oriToken){
  193. return view('payError',['notice'=>lang('login success')]);
  194. }
  195. //dd($orderNo);
  196. //$paymentId = 'PAYID-MXUYFIQ9KF846046B114514M';
  197. $paymentId = $this->request->param('paymentId');
  198. //$token = $this->request->param('token');
  199. //$PayerID = $this->request->param('PayerID');
  200. $conf = config('paypal');
  201. //$orderNo = '';
  202. $pp = new PayPal($conf);
  203. $flag = $pp->executePayment($paymentId);
  204. if ($flag) {
  205. $orderModel = new PaySuccess($orderNo);
  206. $status = $orderModel->onPaySuccess(OrderPayTypeEnum::PAYPAL, ['transaction_id' => $paymentId]);
  207. if (!$status) {
  208. return view('payError',['notice'=>lang('login success')]);
  209. }
  210. Cache::delete(PayPal::PRE_STR . $orderNo);
  211. }
  212. return view('paySuccessful',['notice'=>lang('login success')]);
  213. }
  214. /**
  215. * 获取结算台验证器
  216. * @return CheckoutValidate
  217. */
  218. private function getValidate(): CheckoutValidate
  219. {
  220. if (!$this->validate) {
  221. $this->validate = new CheckoutValidate;
  222. }
  223. return $this->validate;
  224. }
  225. /**
  226. * 获取购物车ID集
  227. * @return false|string[]
  228. */
  229. private function getCartIds()
  230. {
  231. $cartIds = $this->request->param('cartIds');
  232. return explode(',', $cartIds);
  233. }
  234. /**
  235. * 订单结算提交的参数
  236. * @param array $define
  237. * @return array
  238. */
  239. private function getParam(array $define = []): array
  240. {
  241. return array_merge($define, $this->request->param());
  242. }
  243. }