ball/app/common/logic/PaymentLogic.php

<?php
// +----------------------------------------------------------------------
// | likeadmin快速开发前后端分离管理后台（PHP版）
// +----------------------------------------------------------------------
// | 欢迎阅读学习系统程序代码，建议反馈是我们前进的动力
// | 开源版本可自由商用，可去除界面版权logo
// | gitee下载：https://gitee.com/likeshop_gitee/likeadmin
// | github下载：https://github.com/likeshop-github/likeadmin
// | 访问官网：https://www.likeadmin.cn
// | likeadmin团队 版权所有 拥有最终解释权
// +----------------------------------------------------------------------
// | author: likeadminTeam
// +----------------------------------------------------------------------

namespace app\common\logic;


use app\common\cache\MasterWokerTokenCache;
use app\common\enum\PayEnum;
use app\common\enum\YesNoEnum;
use app\common\model\effective\EffectiveCategory;
use app\common\model\group_activity\GroupOrder;
use app\common\model\master_worker\MappingMworkerSession;
use app\common\model\pay\PayWay;
use app\common\model\recharge\RechargeOrder;
use app\common\model\shops\ShopOrders;
use app\common\model\group_activity\GroupUserOrder;
use app\common\model\user\User;
use app\common\service\pay\AliPayService;
use app\common\service\pay\WeChatPayService;
use app\common\service\pay\WorkerWeChatPayService;
use think\Exception;


/**
 * 支付逻辑
 * Class PaymentLogic
 * @package app\common\logic
 */
class PaymentLogic extends BaseLogic
{

    /**
     * @notes 支付方式
     * @param $userId
     * @param $terminal
     * @param $params
     * @return array|false
     * @author 段誉
     * @date 2023/2/24 17:53
     */
    public static function getPayWay($userId, $terminal, $params)
    {
        try {
            $order = RechargeOrder::findOrEmpty($params['order_id'])->toArray();
            if (empty($order)) {
                throw new \Exception('待支付订单不存在');
            }

            //获取支付场景
            $pay_way = PayWay::alias('pw')
                ->join('dev_pay_config dp', 'pw.pay_config_id = dp.id')
                ->where(['pw.scene' => $terminal, 'pw.status' => YesNoEnum::YES])
                ->field('dp.id,dp.name,dp.pay_way,dp.icon,dp.sort,dp.remark,pw.is_default')
                ->order('pw.is_default desc,dp.sort desc,id asc')
                ->select()
                ->toArray();

            foreach ($pay_way as $k => &$item) {
                if ($item['pay_way'] == PayEnum::WECHAT_PAY) {
                    $item['extra'] = '微信快捷支付';
                }
                if ($item['pay_way'] == PayEnum::ALI_PAY) {
                    $item['extra'] = '支付宝快捷支付';
                }
                if ($item['pay_way'] == PayEnum::BALANCE_PAY) {
                    $user_money = User::where(['id' => $userId])->value('user_money');
                    $item['extra'] = '可用余额:' . $user_money;
                }
                // 充值时去除余额支付
                if ($params['from'] == 'recharge' && $item['pay_way'] == PayEnum::BALANCE_PAY) {
                    unset($pay_way[$k]);
                }
            }

            return [
                'lists' => array_values($pay_way),
                'order_amount' => $order['order_amount'],
            ];

        } catch (\Exception $e) {
            self::setError($e->getMessage());
            return false;
        }
    }


    /**
     * @notes 获取支付状态
     * @param $params
     * @return array|false
     * @author 段誉
     * @date 2023/3/1 16:23
     */
    public static function getPayStatus($params)
    {
        try {
            switch ($params['from']) {
                case 'recharge':
                    $order = RechargeOrder::where(['user_id' => $params['user_id'], 'id' => $params['order_id']])
                        ->findOrEmpty();
                    break;
                case 'goods':
                    $order = RechargeOrder::where(['user_id' => $params['user_id'], 'id' => $params['order_id']])
                        ->findOrEmpty();
                    break;
                case 'group':
                    $order = GroupUserOrder::where(['user_id' => $params['user_id'], 'id' => $params['order_id']])
                        ->findOrEmpty();
                    break;
                default:
                    throw new \Exception('订单不存在');
                    break;
            }
            
            $payTime = empty($order['pay_time']) ? '' : date('Y-m-d H:i:s', strtotime($order['pay_time']));
            $orderInfo = [
                'order_id' => $order['id'],
                'order_sn' => $order['sn'],
                'order_amount' => $order['order_amount'],
                'pay_way' => PayEnum::getPayDesc($order['pay_way']),
                'pay_status' => PayEnum::getPayStatusDesc($order['pay_status']),
                'pay_time' => $payTime,
            ];

            if (empty($order)) {
                throw new \Exception('订单不存在');
            }

            return [
                'pay_status' => $order['pay_status'],
                'pay_way' => $order['pay_way'],
                'order' => $orderInfo
            ];
        } catch (\Exception $e) {
            self::setError($e->getMessage());
            return false;
        }
    }

    /**
     * @notes 获取预支付订单信息
     * @param $params
     * @return RechargeOrder|array|false|\think\Model
     */
    public static function getPayOrderInfo($params)
    {
        try {
            
            $order = RechargeOrder::findOrEmpty($params['order_id']);
            if ($order->isEmpty()) {
                throw new Exception('订单不存在');
            }
            //判断订单类型.服务订单尾款处理
            if($order['order_type'] == 0 and $order['pay_status'] == PayEnum::ISPAID)//服务工单
            {
                $order = RechargeOrder::where(['work_id'=>$order['work_id'],'pay_status'=>0])->findOrEmpty();
                if($order->isEmpty()){
                    throw new Exception('订单已支付');
                }
            }

            if ($order['pay_status'] == PayEnum::ISPAID) {
                throw new Exception('订单已支付');
            }
            return $order;
        } catch (\Exception $e) {
            self::$error = $e->getMessage();
            return false;
        }
    }

    /**
     * @notes 获取电子商城预支付订单信息
     * @param $params
     * @return RechargeOrder|array|false|\think\Model
     */
    public static function getPayShopOrderInfo($params)
    {
        try {
            $order = ShopOrders::findOrEmpty($params['order_id']);
            if ($order->isEmpty()) {
                throw new Exception('订单不存在');
            }
            if ($order['pay_status'] == PayEnum::ISPAID) {
                throw new Exception('订单已支付');
            }
            return $order;
        } catch (\Exception $e) {
            self::$error = $e->getMessage();
            return false;
        }
    }

     /**
     * @notes 获取拼团预支付订单信息
     * @param $params
     * @return RechargeOrder|array|false|\think\Model
     */
    public static function getPayGroupOrderInfo($params)
    {
        try {
            $order = GroupUserOrder::findOrEmpty($params['order_id']);
            if ($order->isEmpty()) {
                throw new Exception('订单不存在');
            }
            
            if ($order['pay_status'] == PayEnum::ISPAID) {
                throw new Exception('订单已支付');
            }

            $group_order = GroupOrder::where(['id'=>$order['group_order_id']])->findOrEmpty();
            if ($group_order['num'] >= 100) {
                throw new Exception('拼团人数已满！');
            }
            if ($group_order['status'] == 1 ) {
                throw new Exception('订单已支付！');
            }
            if ($group_order['status'] >= 1 ) {
                throw new Exception('订单已取消！');
            }
            if ($group_order['end_time'] < time()) {
                throw new Exception('拼团活动已结束！');
            }
            return $order;
        } catch (\Exception $e) {
            self::$error = $e->getMessage();
            return false;
        }
    }

    /**
     * @notes 支付
     * @param $payWay
     * @param $from
     * @param $order
     * @param $terminal
     * @param $redirectUrl
     * @return array|false|mixed|string|string[]
     * @throws \Exception
     * @author mjf
     * @date 2024/3/18 16:49
     */
    public static function pay($payWay, $from, $order, $terminal, $redirectUrl)
    {
        // 支付编号-仅为微信支付预置(同一商户号下不同客户端支付需使用唯一订单号)
        $paySn = $order['sn'];
        if ($payWay == PayEnum::WECHAT_PAY) {
            $paySn = self::formatOrderSn($order['sn'], $terminal);
        }
        //更新支付方式
        switch ($from) {
            case 'recharge':
                RechargeOrder::update(['pay_way' => $payWay, 'pay_sn' => $paySn], ['id' => $order['id']]);
                break;
            case 'goods':
                RechargeOrder::update(['pay_way' => $payWay, 'pay_sn' => $paySn], ['id' => $order['id']]);
                break;
            case 'group':
                GroupUserOrder::update(['pay_way' => $payWay, 'pay_sn' => $paySn], ['id' => $order['id']]);
                break;
        }

        if ($order['order_amount'] == 0) {
            PayNotifyLogic::handle($from, $order['sn']);
            return ['sn' => $order['sn'],'need_pay'=>0];
        }

        //todo 测试订单
    //    if($order['id']==11){
    //        PayNotifyLogic::handle($from, $order['sn']);
    //        return ['sn' => $order['sn'],'need_pay'=>0];
    //    }

        $payService = null;
        switch ($payWay) {
            case PayEnum::WECHAT_PAY:
                $payService = (new WeChatPayService($terminal, $order['user_id'] ?? null));
                $order['pay_sn'] = $paySn;
                $order['redirect_url'] = $redirectUrl;
                $result = $payService->pay($from, $order);
                break;
            case PayEnum::ALI_PAY:
                $payService = (new AliPayService($terminal));
                $order['redirect_url'] = $redirectUrl;
                $result = $payService->pay($from, $order);
                break;
            default:
                self::$error = '订单异常';
                $result = false;
        }

        if (false === $result && !self::hasError()) {
            self::setError($payService->getError());
        }
        $result['need_pay'] = 1;
        return $result;
    }

    /**
     * @notes 支付
     * @param $payWay
     * @param $from
     * @param $order
     * @param $terminal
     * @param $redirectUrl
     * @return array|false|mixed|string|string[]
     * @throws \Exception
     * @author mjf
     * @date 2024/3/18 16:49
     */
    public static function workerPay($payWay, $from, $order, $userInfo, $redirectUrl)
    {
        $terminal = $userInfo['terminal'];
        // 支付编号-仅为微信支付预置(同一商户号下不同客户端支付需使用唯一订单号)
        $paySn = $order['sn'];
        if ($payWay == PayEnum::WECHAT_PAY) {
            $paySn = self::formatOrderSn($order['sn'], $terminal);
        }
        //更新支付方式
        switch ($from) {
            case 'recharge':
                RechargeOrder::update(['pay_way' => $payWay, 'pay_sn' => $paySn], ['id' => $order['id']]);
                break;
            case 'goods':
                RechargeOrder::update(['pay_way' => $payWay, 'pay_sn' => $paySn], ['id' => $order['id']]);
                break;
        }

        if ($order['order_amount'] == 0) {
            PayNotifyLogic::handle($from, $order['sn']);
            return ['sn' => $order['sn'],'need_pay'=>0];
        }

        $mapSession = MappingMworkerSession::where([['type', '=', 1],['map_token', '=', $userInfo['token']], ['expire_time', '>', time()]])->findOrEmpty();
        if(!$mapSession->isEmpty()) {
            $token = '';
            $mapSession->token && $token = $mapSession->token;
            $token && $userInfo = (new MasterWokerTokenCache())->getUserInfo($token);
        }

        $payService = null;
        switch ($payWay) {
            case PayEnum::WECHAT_PAY:
                $payService = (new WorkerWeChatPayService($terminal, $userInfo['user_id'] ?? null));
                $order['pay_sn'] = $paySn;
                $order['redirect_url'] = $redirectUrl;
                $result = $payService->pay($from, $order);
                break;
            default:
                self::$error = '订单异常';
                $result = false;
        }

        if (false === $result && !self::hasError()) {
            self::setError($payService->getError());
        }
        $result['need_pay'] = 1;
        return $result;
    }

    /**
     * @notes 电子商城支付
     * @param $payWay
     * @param $from
     * @param $order
     * @param $terminal
     * @param $redirectUrl
     * @return array|false|mixed|string|string[]
     * @throws \Exception
     */
    public static function shopPay($payWay, $from, $order, $userInfo, $redirectUrl)
    {
        $terminal = $userInfo['terminal'];
        // 支付编号-仅为微信支付预置(同一商户号下不同客户端支付需使用唯一订单号)
        $paySn = $order['sn'];
        if ($payWay == PayEnum::WECHAT_PAY) {
            $paySn = self::formatOrderSn($order['sn'], $terminal);
        }
        //更新支付方式
        switch ($from) {
            case 'shop_goods':
                ShopOrders::update(['pay_way' => $payWay, 'pay_sn' => $paySn], ['id' => $order['id']]);
                break;
        }

        if ($order['order_amount'] == 0) {
            PayNotifyLogic::handle($from, $order['sn']);
            return ['sn' => $order['sn'],'need_pay'=>0];
        }

        $payService = null;
        switch ($payWay) {
            case PayEnum::WECHAT_PAY:
                $payService = (new WorkerWeChatPayService($terminal, $userInfo['user_id'] ?? null));
                $order['pay_sn'] = $paySn;
                $order['redirect_url'] = $redirectUrl;
                $result = $payService->pay($from, $order);
                break;
            default:
                self::$error = '订单异常';
                $result = false;
        }

        if (false === $result && !self::hasError()) {
            self::setError($payService->getError());
        }
//        $result['need_pay'] = 1;
        return $result;
    }

    /**
     * @notes 设置订单号 支付回调时截取前面的单号 18个
     * @param $orderSn
     * @param $terminal
     * @return string
     * @author 段誉
     * @date 2023/3/1 16:31
     * @remark 回调时使用了不同的回调地址,导致跨客户端支付时(例如小程序,公众号)可能出现201,商户订单号重复错误
     */
    public static function formatOrderSn($orderSn, $terminal)
    {
        $suffix = mb_substr(time(), -4);
        return $orderSn . $terminal . $suffix;
    }

}