Checkout.php 8.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248
  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\api\controller;
  13. use app\api\model\Order as OrderModel;
  14. use app\api\service\order\PaySuccess;
  15. use app\api\service\User as UserService;
  16. use app\api\service\Cart as CartService;
  17. use app\api\service\order\Checkout as CheckoutService;
  18. use app\api\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\response\Json;
  24. /**
  25. * 订单结算控制器
  26. * Class Checkout
  27. * @package app\api\controller
  28. */
  29. class Checkout extends Controller
  30. {
  31. // 结算台验证器
  32. /* @var CheckoutValidate $validate */
  33. private $validate;
  34. /**
  35. * 结算台订单信息
  36. * @param string $mode
  37. * @return Json
  38. * @throws BaseException
  39. * @throws \think\db\exception\DataNotFoundException
  40. * @throws \think\db\exception\DbException
  41. * @throws \think\db\exception\ModelNotFoundException
  42. */
  43. public function order(string $mode = 'buyNow'): Json
  44. {
  45. if ($mode === 'buyNow') {
  46. return $this->buyNow();
  47. } elseif ($mode === 'cart') {
  48. return $this->cart();
  49. }
  50. return $this->renderError('结算模式不合法');
  51. }
  52. /**
  53. * 订单提交
  54. * @param string $mode
  55. * @return Json
  56. * @throws BaseException
  57. * @throws \think\db\exception\DataNotFoundException
  58. * @throws \think\db\exception\DbException
  59. * @throws \think\db\exception\ModelNotFoundException
  60. */
  61. public function submit(string $mode = 'buyNow'): Json
  62. {
  63. return $this->order($mode);
  64. }
  65. /**
  66. * 订单确认-立即购买
  67. * @return Json
  68. * @throws BaseException
  69. * @throws \think\db\exception\DataNotFoundException
  70. * @throws \think\db\exception\DbException
  71. * @throws \think\db\exception\ModelNotFoundException
  72. */
  73. private function buyNow(): Json
  74. {
  75. // 实例化结算台服务
  76. $Checkout = new CheckoutService;
  77. // 订单结算api参数
  78. $params = $Checkout->setParam($this->getParam([
  79. 'goodsId' => 0,
  80. 'goodsSkuId' => '',
  81. 'goodsNum' => 0,
  82. ]));
  83. // 表单验证
  84. if (!$this->getValidate()->scene('buyNow')->check($params)) {
  85. return $this->renderError($this->getValidate()->getError(), ['isCreated' => false]);
  86. }
  87. // 立即购买:获取订单商品列表
  88. $model = new OrderModel;
  89. $goodsList = $model->getOrderGoodsListByNow(
  90. (int)$params['goodsId'],
  91. (string)$params['goodsSkuId'],
  92. (int)$params['goodsNum']
  93. );
  94. // 获取订单确认信息
  95. $orderInfo = $Checkout->onCheckout($goodsList);
  96. if ($this->request->isGet()) {
  97. return $this->renderSuccess([
  98. 'order' => $orderInfo,
  99. 'personal' => $Checkout->getPersonal(),
  100. 'setting' => $Checkout->getSetting(),
  101. ]);
  102. }
  103. // 验证订单是否存在错误
  104. if ($Checkout->hasError()) {
  105. return $this->renderError($Checkout->getError(), ['is_created' => false]);
  106. }
  107. // 创建订单
  108. if (!$Checkout->createOrder($orderInfo)) {
  109. return $this->renderError($Checkout->getError() ?: '订单创建失败', ['is_created' => false]);
  110. }
  111. // 构建微信支付请求
  112. $payment = $model->onOrderPayment($Checkout->model, $params['payType']);
  113. // 返回结算信息
  114. return $this->renderSuccess([
  115. 'orderId' => $Checkout->model['order_id'], // 订单id
  116. 'payType' => $params['payType'], // 支付方式
  117. 'payment' => $payment // 微信支付参数
  118. ]);
  119. }
  120. /**
  121. * 订单确认-购物车结算
  122. * @return Json
  123. * @throws BaseException
  124. * @throws \think\db\exception\DataNotFoundException
  125. * @throws \think\db\exception\DbException
  126. * @throws \think\db\exception\ModelNotFoundException
  127. */
  128. private function cart(): Json
  129. {
  130. // 实例化结算台服务
  131. $Checkout = new CheckoutService;
  132. // 订单结算api参数
  133. $params = $Checkout->setParam($this->getParam());
  134. // 购物车ID集
  135. $cartIds = $this->getCartIds();
  136. // 商品结算信息
  137. $CartModel = new CartService;
  138. // 购物车商品列表
  139. $goodsList = $CartModel->getOrderGoodsList($cartIds);
  140. if (empty($goodsList)) {
  141. return $this->renderError('请选择商品结算');
  142. }
  143. // 获取订单结算信息
  144. $orderInfo = $Checkout->onCheckout($goodsList);
  145. if ($this->request->isGet()) {
  146. return $this->renderSuccess([
  147. 'order' => $orderInfo,
  148. 'personal' => $Checkout->getPersonal(),
  149. 'setting' => $Checkout->getSetting(),
  150. ]);
  151. }
  152. // 验证订单是否存在错误
  153. if ($Checkout->hasError()) {
  154. return $this->renderError($Checkout->getError(), ['is_created' => false]);
  155. }
  156. // 创建订单
  157. if (!$Checkout->createOrder($orderInfo)) {
  158. return $this->renderError($Checkout->getError() ?: '订单创建失败');
  159. }
  160. // 移出购物车中已下单的商品
  161. $CartModel->clear($cartIds);
  162. // 构建微信支付请求
  163. $payment = $Checkout->onOrderPayment();
  164. // 返回状态,如果是paypal支付,需要给用户跳转页面之外,还需要轮训查询订单的支付情况,如果支付成功,则弹窗提示,超过一分钟的话,提示支付超时,请重试
  165. return $this->renderSuccess([
  166. 'orderId' => $Checkout->model['order_id'], // 订单id
  167. 'payType' => $params['payType'], // 支付方式
  168. 'payment' => $payment // 微信支付参数
  169. ]);
  170. }
  171. /**
  172. * returnUrl回来时继续调用执行扣款接口paypal
  173. * @return Json
  174. */
  175. public function payPayExecutePay($orderNo, $token)
  176. {
  177. if (empty($orderNo) || empty($token)){
  178. return $this->renderError('something wrong!');
  179. }
  180. $oriToken = Cache::get(PayPal::PRE_STR . $orderNo);
  181. if ($token != $oriToken){
  182. return $this->renderError('something wrong!');
  183. }
  184. //dd($orderNo);
  185. //$paymentId = 'PAYID-MXUYFIQ9KF846046B114514M';
  186. $paymentId = $this->request->param('paymentId');
  187. //$token = $this->request->param('token');
  188. //$PayerID = $this->request->param('PayerID');
  189. $conf = config('paypal');
  190. //$orderNo = '';
  191. $pp = new PayPal($conf);
  192. $flag = $pp->executePayment($paymentId);
  193. if ($flag) {
  194. $orderModel = new PaySuccess($orderNo);
  195. $status = $orderModel->onPaySuccess(OrderPayTypeEnum::PAYPAL, ['transaction_id' => $paymentId]);
  196. if (!$status) {
  197. return $this->renderError('Something Wrong!');
  198. }
  199. Cache::delete(PayPal::PRE_STR . $orderNo);
  200. }
  201. return $this->renderSuccess([], 'Successful!');
  202. }
  203. public function paidSuccess(){
  204. return view('paySuccessful',['notice'=>lang('login success')]);
  205. }
  206. /**
  207. * 获取结算台验证器
  208. * @return CheckoutValidate
  209. */
  210. private function getValidate(): CheckoutValidate
  211. {
  212. if (!$this->validate) {
  213. $this->validate = new CheckoutValidate;
  214. }
  215. return $this->validate;
  216. }
  217. /**
  218. * 获取购物车ID集
  219. * @return false|string[]
  220. */
  221. private function getCartIds()
  222. {
  223. $cartIds = $this->request->param('cartIds');
  224. return explode(',', $cartIds);
  225. }
  226. /**
  227. * 订单结算提交的参数
  228. * @param array $define
  229. * @return array
  230. */
  231. private function getParam(array $define = []): array
  232. {
  233. return array_merge($define, $this->request->param());
  234. }
  235. }