shenying/app/services/pay/OrderPayServices.php

<?php
// +----------------------------------------------------------------------
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2016~2020 https://www.crmeb.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
// +----------------------------------------------------------------------
// | Author: CRMEB Team <admin@crmeb.com>
// +----------------------------------------------------------------------

namespace app\services\pay;


use app\model\order\StoreOrder;
use app\services\order\StoreOrderCartInfoServices;
use app\services\wechat\WechatUserServices;
use think\exception\ValidateException;

/**
 * 订单发起支付
 * Class OrderPayServices
 * @package app\services\pay
 */
class OrderPayServices
{
    /**
     * 支付
     * @var PayServices
     */
    protected $payServices;

    public function __construct(PayServices $services)
    {
        $this->payServices = $services;
    }

    /**
     * 订单发起支付
     * @param array $orderInfo
     * @return array|string
     */
    public function orderPay(array $orderInfo, string $payType, $yue_pay_price = 0)
    {
        if ($orderInfo['paid']) {
            throw new ValidateException('订单已支付!');
        }
        if ($orderInfo['pay_price'] <= 0) {
            throw new ValidateException('该支付无需支付!');
        }
        if ($orderInfo['pay_price'] - $yue_pay_price <= 0) {
            throw new ValidateException('该支付无需支付!');
        }
        $openid = '';
        if (!in_array($payType, ['weixinh5', 'pc', 'store']) && !request()->isApp()) {
            if ($payType === 'weixin') {
                $userType = 'wechat';
            } else {
                $userType = $payType;
            }
            /** @var WechatUserServices $services */
            $services = app()->make(WechatUserServices::class);
            $openid = $services->uidToOpenid($orderInfo['uid'], $userType);
            if (!$openid) {
                throw new ValidateException('获取用户openid失败,无法支付');
            }
        }
        $site_name = sys_config('site_name');
        if (isset($orderInfo['member_type'])) {
            $body = substrUTf8($site_name . '--' . $orderInfo['member_type'], 30);
            $successAction = "member";
        } else {
            /** @var StoreOrderCartInfoServices $orderInfoServices */
            $orderInfoServices = app()->make(StoreOrderCartInfoServices::class);
            $body = $orderInfoServices->getCarIdByProductTitle((int)$orderInfo['id']);
            $body = substrUTf8($site_name . '--' . $body, 30);
            $successAction = "product";
        }

        if (!$body) {
            throw new ValidateException('支付参数缺少：请前往后台设置->系统设置-> 填写 网站名称');
        }
        StoreOrder::where('id', $orderInfo['id'])->update(['yue_pay' => $yue_pay_price]);
        return $this->payServices->pay($payType, $openid, $orderInfo['order_id'], $orderInfo['pay_price'] - $yue_pay_price, $successAction, $body);
    }

    /**
     * 支付宝支付
     * @param array $orderInfo
     * @param string $quitUrl
     * @return array|string
     */
    public function alipayOrder(array $orderInfo, string $quitUrl, bool $isCode = false, $yue_pay_price = 0)
    {
        if ($orderInfo['paid']) {
            throw new ValidateException('订单已支付!');
        }
        if ($orderInfo['pay_price'] <= 0) {
            throw new ValidateException('该支付无需支付!');
        }
        if ($orderInfo['pay_price'] - $yue_pay_price <= 0) {
            throw new ValidateException('该支付无需支付!');
        }
        $site_name = sys_config('site_name');
        if (isset($orderInfo['member_type'])) {
            $body = substrUTf8($site_name . '--' . $orderInfo['member_type'], 30);
            $successAction = "member";
        } else {
            /** @var StoreOrderCartInfoServices $orderInfoServices */
            $orderInfoServices = app()->make(StoreOrderCartInfoServices::class);
            $body = $orderInfoServices->getCarIdByProductTitle((int)$orderInfo['id']);
            $body = substrUTf8($site_name . '--' . $body, 30);
            $successAction = "product";
        }

        if (!$body) {
            throw new ValidateException('支付参数缺少：请前往后台设置->系统设置-> 填写 网站名称');
        }
        StoreOrder::where('id', $orderInfo['id'])->update(['yue_pay' => $yue_pay_price]);
        return $this->payServices->pay('alipay', $quitUrl, $orderInfo['order_id'], $orderInfo['pay_price'] - $yue_pay_price, $successAction, $body, $isCode);
    }

    /**
     * 积分商品订单发起支付
     * @param array $orderInfo
     * @return array|string
     */
    public function orderIntegralPay(array $orderInfo, string $payType)
    {
        if ($orderInfo['paid']) {
            throw new ValidateException('订单已支付!');
        }
        if ($orderInfo['total_price'] <= 0) {
            throw new ValidateException('该支付无需支付!');
        }
        $openid = '';
        if (!in_array($payType, ['weixinh5', 'pc', 'store']) && !request()->isApp()) {
            if ($payType === 'weixin') {
                $userType = 'wechat';
            } else {
                $userType = $payType;
            }
            /** @var WechatUserServices $services */
            $services = app()->make(WechatUserServices::class);
            $openid = $services->uidToOpenid($orderInfo['uid'], $userType);
            if (!$openid) {
                throw new ValidateException('获取用户openid失败,无法支付');
            }
        }
        $site_name = sys_config('site_name');
        $body = $orderInfo['store_name'];
        $body = substrUTf8($site_name . '--' . $body, 30);
        $successAction = "integral";

        if (!$body) {
            throw new ValidateException('支付参数缺少：请前往后台设置->系统设置-> 填写 网站名称');
        }
        return $this->payServices->pay($payType, $openid, $orderInfo['order_id'], $orderInfo['total_price'], $successAction, $body);
    }

    /**
     * 积分商品支付宝支付
     * @param array $orderInfo
     * @param string $quitUrl
     * @return array|string
     */
    public function alipayIntegralOrder(array $orderInfo, string $quitUrl, bool $isCode = false)
    {
        if ($orderInfo['paid']) {
            throw new ValidateException('订单已支付!');
        }
        if ($orderInfo['total_price'] <= 0) {
            throw new ValidateException('该支付无需支付!');
        }
        $site_name = sys_config('site_name');
        $body = $orderInfo['store_name'];
        $body = substrUTf8($site_name . '--' . $body, 30);
        $successAction = "integral";

        if (!$body) {
            throw new ValidateException('支付参数缺少：请前往后台设置->系统设置-> 填写 网站名称');
        }
        return $this->payServices->pay('alipay', $quitUrl, $orderInfo['order_id'], $orderInfo['total_price'], $successAction, $body, $isCode);
    }

    /**收银台会员充值
     * @param array $orderInfo
     * @param string $payType
     * @param string $authCode
     * @return array|string
     */
    public function otherRecharge(array $orderInfo, string $payType, string $authCode = '')
    {
        if (!$orderInfo) {
            throw new ValidateException('订单失效或者不存在');
        }
        if ($orderInfo['paid'] == 1) {
            throw new ValidateException('订单已支付');
        }
        $openid = '';
        //没有付款码，不是微信H5支付，门店支付，PC支付，不再APP端，需要判断用户openid
        if (!$authCode && !in_array($payType, ['weixinh5', 'store', 'pc', 'alipay']) && !request()->isApp()) {
            $userType = '';
            switch ($payType) {
                case 'weixin':
                case 'weixinh5':
                    $userType = 'wechat';
                    break;
                case 'routine':
                    $userType = 'routine';
                    break;
            }
            if (!$userType) {
                throw new ValidateException('不支持该类型方式');
            }
            /** @var WechatUserServices $wechatUser */
            $wechatUser = app()->make(WechatUserServices::class);
            $openid = $wechatUser->uidToOpenid((int)$orderInfo['uid'], $userType);
            if (!$openid) {
                throw new ValidateException('获取用户openid失败,无法支付');
            }
        }
        $site_name = sys_config('site_name');
        if (isset($orderInfo['member_type'])) {
            $body = substrUTf8($site_name . '--' . $orderInfo['member_type'], 30);
            $successAction = "member_recharge";
        }

        if (!$body) {
            throw new ValidateException('支付参数缺少：请前往后台设置->系统设置-> 填写 网站名称');
        }
        return $this->payServices->setAuthCode($authCode)->pay($payType, $openid, $orderInfo['order_id'], $orderInfo['pay_price'], $successAction, $body);
    }
}