vape_shop/app/index/controller/Checkout.php

<?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\index\model\Order;
use app\index\model\Order as OrderModel;
use app\index\model\ShareKey;
use app\index\model\User as UserModel;
use app\index\service\order\PaySuccess;
use app\index\service\User;
use app\index\service\User as UserService;
use app\index\service\Cart as CartService;
use app\index\service\order\Checkout as CheckoutService;
use app\index\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;

/**
 * 订单结算控制器
 * 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
     * @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 $this->renderJson(config('status.not_logged'), 'Log in please!');
        }

        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 = $CartModel->getCartIds();
        // 商品结算信息
        // 购物车商品列表
        $goodsList = $CartModel->getOrderGoodsList($cartIds);
        if (empty($goodsList)) {
            return $this->renderError('Please add items to your shopping cart first');
        }
        // 获取订单结算信息
        $orderInfo = $Checkout->onCheckout($goodsList);
        if ($this->request->isGet()) {
            return $this->renderSuccess([
                'order' => $orderInfo,
                'personal' => $Checkout->getPersonal(),
                'setting' => $Checkout->getSetting(),
            ]);
        }
        $userInfo = User::getCurrentLoginUser();
        $points = $userInfo['points'];
        if ($params['payType'] == OrderPayTypeEnum::POINTS) {
            $payPoints = intval(bcmul(strval($orderInfo['orderPayPrice']), '100', 0));//订单所需积分
            if (intval($points) < $payPoints) {
                return $this->renderError('Not enough points');
            }
        }

        // 验证订单是否存在错误
        if ($Checkout->hasError()) {
            return $this->renderError($Checkout->getError(), ['is_created' => false]);
        }
        // 创建订单
        if (!$Checkout->createOrder($orderInfo)) {
            return $this->renderError($Checkout->getError() ?: 'Order creation failed, please try again later');
        }
        // 移出购物车中已下单的商品
        $CartModel->clear($cartIds);
        // 构建微信支付请求
        $payment = $Checkout->onOrderPayment();
        if ($params['payType'] == OrderPayTypeEnum::POINTS) {
            if (!$payment['flag']) {
                return $this->renderError($payment['message'] ?? 'Redemption failed, please try again later');
            }
        }

        // 返回状态，如果是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')]);
            return view('payError', ['notice' => 'Payment failed']);
        }

        $oriToken = Cache::get(PayPal::PRE_STR . $orderNo);
        if ($token != $oriToken) {
            return view('payError', ['notice' => 'Payment failed']);
        }

        $paymentId = $this->request->param('paymentId');
        $conf = config('paypal');
        $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' => 'Payment failed']);
            }
            Cache::delete(PayPal::PRE_STR . $orderNo);
        }
        //todo 等会测试
        $order = Order::detail(['order_no' => $orderNo]);
        //如果有分享人，给分享人送积分
        if (isset($order['user_id'])) {
            $key = Cache::get(UserModel::SHARE_PREFIX . $order['user_id']);
            if (!empty($key)) {
                $dbKey = ShareKey::getShareKey($key);
                //没使用过的key才发放积分
                if (!empty($dbKey) && $dbKey['is_delete'] == 0) {
                    $fromUserId = decrypt($key);
                    if ($fromUserId && $fromUserId != $order['user_id']) {
                        $describe = "Giveaway after successful sharing";
                        $payPoints = intval(bcmul($order['pay_price'], '100', 0));
                        UserModel::setIncPoints(intval($fromUserId), -$payPoints, $describe);
                        Cache::delete(UserModel::SHARE_PREFIX . $order['user_id']);
                        ShareKey::delKey($key);
                    }
                }

            }
        }

        return view('paySuccessful', ['notice' => 'Payment Successful']);
    }

    /**
     * 获取结算台验证器
     * @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());
    }
}