|
@@ -0,0 +1,253 @@
|
|
|
+<?php
|
|
|
+// +----------------------------------------------------------------------
|
|
|
+// | 萤火商城系统 [ 致力于通过产品和服务,帮助商家高效化开拓市场 ]
|
|
|
+// +----------------------------------------------------------------------
|
|
|
+// | Copyright (c) 2017~2021 https://www.yiovo.com All rights reserved.
|
|
|
+// +----------------------------------------------------------------------
|
|
|
+// | Licensed 这不是一个自由软件,不允许对程序代码以任何形式任何目的的再发行
|
|
|
+// +----------------------------------------------------------------------
|
|
|
+// | Author: 萤火科技 <admin@yiovo.com>
|
|
|
+// +----------------------------------------------------------------------
|
|
|
+declare (strict_types=1);
|
|
|
+
|
|
|
+namespace app\index\controller;
|
|
|
+
|
|
|
+use app\api\controller\Controller;
|
|
|
+use app\api\model\Order as OrderModel;
|
|
|
+use app\api\service\order\PaySuccess;
|
|
|
+use app\api\service\User as UserService;
|
|
|
+use app\api\service\Cart as CartService;
|
|
|
+use app\api\service\order\Checkout as CheckoutService;
|
|
|
+use app\api\validate\order\Checkout as CheckoutValidate;
|
|
|
+use app\common\enum\order\PayType as OrderPayTypeEnum;
|
|
|
+use app\common\library\paypal\PayPal;
|
|
|
+use cores\exception\BaseException;
|
|
|
+use think\facade\Cache;
|
|
|
+use think\facade\Session;
|
|
|
+use think\response\Json;
|
|
|
+use think\View;
|
|
|
+
|
|
|
+/**
|
|
|
+ * 订单结算控制器
|
|
|
+ * Class Checkout
|
|
|
+ * @package app\api\controller
|
|
|
+ */
|
|
|
+class Checkout extends Controller
|
|
|
+{
|
|
|
+ // 结算台验证器
|
|
|
+ /* @var CheckoutValidate $validate */
|
|
|
+ private $validate;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 结算台订单信息
|
|
|
+ * @param string $mode
|
|
|
+ * @return Json
|
|
|
+ * @throws BaseException
|
|
|
+ * @throws \think\db\exception\DataNotFoundException
|
|
|
+ * @throws \think\db\exception\DbException
|
|
|
+ * @throws \think\db\exception\ModelNotFoundException
|
|
|
+ */
|
|
|
+ public function order(string $mode = 'buyNow'): Json
|
|
|
+ {
|
|
|
+ if ($mode === 'buyNow') {
|
|
|
+ return $this->buyNow();
|
|
|
+ } elseif ($mode === 'cart') {
|
|
|
+ return $this->cart();
|
|
|
+ }
|
|
|
+ return $this->renderError('结算模式不合法');
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 订单提交
|
|
|
+ * @param string $mode
|
|
|
+ * @return Json|\think\response\View
|
|
|
+ * @throws BaseException
|
|
|
+ * @throws \think\db\exception\DataNotFoundException
|
|
|
+ * @throws \think\db\exception\DbException
|
|
|
+ * @throws \think\db\exception\ModelNotFoundException
|
|
|
+ */
|
|
|
+ public function submit(string $mode = 'buyNow'): Json
|
|
|
+ {
|
|
|
+ $userId = Session::get('user_id');
|
|
|
+ if (empty($userId)){
|
|
|
+ return view('passport/login');
|
|
|
+ }
|
|
|
+
|
|
|
+ return $this->order($mode);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 订单确认-立即购买
|
|
|
+ * @return Json
|
|
|
+ * @throws BaseException
|
|
|
+ * @throws \think\db\exception\DataNotFoundException
|
|
|
+ * @throws \think\db\exception\DbException
|
|
|
+ * @throws \think\db\exception\ModelNotFoundException
|
|
|
+ */
|
|
|
+ private function buyNow(): Json
|
|
|
+ {
|
|
|
+ // 实例化结算台服务
|
|
|
+ $Checkout = new CheckoutService;
|
|
|
+ // 订单结算api参数
|
|
|
+ $params = $Checkout->setParam($this->getParam([
|
|
|
+ 'goodsId' => 0,
|
|
|
+ 'goodsSkuId' => '',
|
|
|
+ 'goodsNum' => 0,
|
|
|
+ ]));
|
|
|
+ // 表单验证
|
|
|
+ if (!$this->getValidate()->scene('buyNow')->check($params)) {
|
|
|
+ return $this->renderError($this->getValidate()->getError(), ['isCreated' => false]);
|
|
|
+ }
|
|
|
+ // 立即购买:获取订单商品列表
|
|
|
+ $model = new OrderModel;
|
|
|
+ $goodsList = $model->getOrderGoodsListByNow(
|
|
|
+ (int)$params['goodsId'],
|
|
|
+ (string)$params['goodsSkuId'],
|
|
|
+ (int)$params['goodsNum']
|
|
|
+ );
|
|
|
+ // 获取订单确认信息
|
|
|
+ $orderInfo = $Checkout->onCheckout($goodsList);
|
|
|
+ if ($this->request->isGet()) {
|
|
|
+ return $this->renderSuccess([
|
|
|
+ 'order' => $orderInfo,
|
|
|
+ 'personal' => $Checkout->getPersonal(),
|
|
|
+ 'setting' => $Checkout->getSetting(),
|
|
|
+ ]);
|
|
|
+ }
|
|
|
+ // 验证订单是否存在错误
|
|
|
+ if ($Checkout->hasError()) {
|
|
|
+ return $this->renderError($Checkout->getError(), ['is_created' => false]);
|
|
|
+ }
|
|
|
+ // 创建订单
|
|
|
+ if (!$Checkout->createOrder($orderInfo)) {
|
|
|
+ return $this->renderError($Checkout->getError() ?: '订单创建失败', ['is_created' => false]);
|
|
|
+ }
|
|
|
+ // 构建微信支付请求
|
|
|
+ $payment = $model->onOrderPayment($Checkout->model, $params['payType']);
|
|
|
+ // 返回结算信息
|
|
|
+ return $this->renderSuccess([
|
|
|
+ 'orderId' => $Checkout->model['order_id'], // 订单id
|
|
|
+ 'payType' => $params['payType'], // 支付方式
|
|
|
+ 'payment' => $payment // 微信支付参数
|
|
|
+ ]);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 订单确认-购物车结算
|
|
|
+ * @return Json
|
|
|
+ * @throws BaseException
|
|
|
+ * @throws \think\db\exception\DataNotFoundException
|
|
|
+ * @throws \think\db\exception\DbException
|
|
|
+ * @throws \think\db\exception\ModelNotFoundException
|
|
|
+ */
|
|
|
+ private function cart(): Json
|
|
|
+ {
|
|
|
+ // 实例化结算台服务
|
|
|
+ $Checkout = new CheckoutService;
|
|
|
+ // 订单结算api参数
|
|
|
+ $params = $Checkout->setParam($this->getParam());
|
|
|
+ // 购物车ID集
|
|
|
+ //$cartIds = $this->getCartIds();//不需要接口传过来
|
|
|
+ $CartModel = new CartService;
|
|
|
+ $cartIds = $this->getCartIds();
|
|
|
+ // 商品结算信息
|
|
|
+ // 购物车商品列表
|
|
|
+ $goodsList = $CartModel->getOrderGoodsList($cartIds);
|
|
|
+ if (empty($goodsList)) {
|
|
|
+ return $this->renderError('请选择商品结算');
|
|
|
+ }
|
|
|
+ // 获取订单结算信息
|
|
|
+ $orderInfo = $Checkout->onCheckout($goodsList);
|
|
|
+ if ($this->request->isGet()) {
|
|
|
+ return $this->renderSuccess([
|
|
|
+ 'order' => $orderInfo,
|
|
|
+ 'personal' => $Checkout->getPersonal(),
|
|
|
+ 'setting' => $Checkout->getSetting(),
|
|
|
+ ]);
|
|
|
+ }
|
|
|
+ // 验证订单是否存在错误
|
|
|
+ if ($Checkout->hasError()) {
|
|
|
+ return $this->renderError($Checkout->getError(), ['is_created' => false]);
|
|
|
+ }
|
|
|
+ // 创建订单
|
|
|
+ if (!$Checkout->createOrder($orderInfo)) {
|
|
|
+ return $this->renderError($Checkout->getError() ?: '订单创建失败');
|
|
|
+ }
|
|
|
+ // 移出购物车中已下单的商品
|
|
|
+ $CartModel->clear($cartIds);
|
|
|
+ // 构建微信支付请求
|
|
|
+ $payment = $Checkout->onOrderPayment();
|
|
|
+ // 返回状态,如果是paypal支付,需要给用户跳转页面之外,还需要轮训查询订单的支付情况,如果支付成功,则弹窗提示,超过一分钟的话,提示支付超时,请重试
|
|
|
+ return $this->renderSuccess([
|
|
|
+ 'orderId' => $Checkout->model['order_id'], // 订单id
|
|
|
+ 'payType' => $params['payType'], // 支付方式
|
|
|
+ 'payment' => $payment // 微信支付参数
|
|
|
+ ]);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @return \think\response\View
|
|
|
+ */
|
|
|
+ public function payPayExecutePay($orderNo, $token)
|
|
|
+ {
|
|
|
+ if (empty($orderNo) || empty($token)){
|
|
|
+ return view('payError',['notice'=>lang('login success')]);
|
|
|
+ }
|
|
|
+
|
|
|
+ $oriToken = Cache::get(PayPal::PRE_STR . $orderNo);
|
|
|
+ if ($token != $oriToken){
|
|
|
+ return view('payError',['notice'=>lang('login success')]);
|
|
|
+ }
|
|
|
+
|
|
|
+ //dd($orderNo);
|
|
|
+ //$paymentId = 'PAYID-MXUYFIQ9KF846046B114514M';
|
|
|
+ $paymentId = $this->request->param('paymentId');
|
|
|
+ //$token = $this->request->param('token');
|
|
|
+ //$PayerID = $this->request->param('PayerID');
|
|
|
+ $conf = config('paypal');
|
|
|
+ //$orderNo = '';
|
|
|
+ $pp = new PayPal($conf);
|
|
|
+ $flag = $pp->executePayment($paymentId);
|
|
|
+ if ($flag) {
|
|
|
+ $orderModel = new PaySuccess($orderNo);
|
|
|
+ $status = $orderModel->onPaySuccess(OrderPayTypeEnum::PAYPAL, ['transaction_id' => $paymentId]);
|
|
|
+ if (!$status) {
|
|
|
+ return view('payError',['notice'=>lang('login success')]);
|
|
|
+ }
|
|
|
+ Cache::delete(PayPal::PRE_STR . $orderNo);
|
|
|
+ }
|
|
|
+ return view('paySuccessful',['notice'=>lang('login success')]);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取结算台验证器
|
|
|
+ * @return CheckoutValidate
|
|
|
+ */
|
|
|
+ private function getValidate(): CheckoutValidate
|
|
|
+ {
|
|
|
+ if (!$this->validate) {
|
|
|
+ $this->validate = new CheckoutValidate;
|
|
|
+ }
|
|
|
+ return $this->validate;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取购物车ID集
|
|
|
+ * @return false|string[]
|
|
|
+ */
|
|
|
+ private function getCartIds()
|
|
|
+ {
|
|
|
+ $cartIds = $this->request->param('cartIds');
|
|
|
+ return explode(',', $cartIds);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 订单结算提交的参数
|
|
|
+ * @param array $define
|
|
|
+ * @return array
|
|
|
+ */
|
|
|
+ private function getParam(array $define = []): array
|
|
|
+ {
|
|
|
+ return array_merge($define, $this->request->param());
|
|
|
+ }
|
|
|
+}
|