fastadmin_lottery/application/api/controller/Pay.php

<?php

namespace app\api\controller;

use think\Db;
use think\Log;
use think\Exception;
use think\exception\HttpResponseException;
use app\common\Service\Pay\PayService;
use app\common\Service\Pay\PayOperService;
use app\common\Enum\ChannelEnum;
use app\common\Service\OrderService;
use app\common\model\Third as ThirdOauth;
use app\common\model\Order;
/**
 * 支付接口
 */
class Pay extends Base
{
    protected $noNeedLogin = ['notify'];
    protected $noNeedRight = '*';

    public function _initialize()
    {
        parent::_initialize();
        set_addon_config('epay', ['version'=>'v3'], false);
    }
    /**
     * 
     * 支付回调
     * @return void
     */
    public function notify()
    {
        $type = $this->request->param('type');
        $paytype = $this->request->param('paytype');
        if ($type == 'notify') {
            $pay = \addons\epay\library\Service::checkNotify($paytype);
            if (!$pay) {
                echo '签名错误';
                \think\Log::write('签名错误', 'epay',);
                return;
            }
            $data = $pay->verify();
            // try {
                $payamount = $paytype == 'alipay' ? $data['total_amount'] : $data['total_fee'] / 100;
                PayOperService::settle($data['out_trade_no'], $payamount, $paytype == 'alipay' ? $data['trade_no'] : $data['transaction_id']);
            // } catch (\Exception $e) {
            //     \think\Log::write($e->getMessage(), 'epay');
            // }
            echo $pay->success();
        }//  pc 支付
         elseif ($type == 'return') {
            // $order_sn = $this->request->param('order_sn');
            // $this->redirect("index/shop.order/detail", ['orderid' => $order_sn]);
        }
        return;
    }

    /**
     * 预支付订单接口
     * @return void
     */
    public function prepay()
    {

        $orderId = $this->request->post('orderId');
        $payment = $this->request->post('payment');
        $openid = $this->request->post('openid', '');
        $money = $this->request->post('money', 0);
        $money = $money > 0 ? $money : 0;
        $platform = $this->request->header('platform');
        $userId = $this->auth->getUser()->id;
        // 获取订单实例
        $order = new Order();
        $order = $order->where('user_id', $userId)->where('id', $orderId)->find();
        
        if (!$order) {
            $this->error(__('No Results were found'));
        }

        // 验证订单状态
        if (!$order->canPayHandle()) {
            $this->error(__('订单状态不支持支付'));
        }


        // 验证支付类型
        if (!$payment || !in_array($payment, ['wechat', 'alipay', 'douyin'])) {
            $this->error('支付类型不能为空');
        }

        // 验证支付环境
        // if ($channel && !ChannelEnum::channelSupportsPayment($channel, $payment)) {
        //     $this->error('当前渠道不支持该支付方式');
        // }
       
        $payOper = new PayOperService($this->auth->getUser());
        $orderType = $order->type;
        $payModel = $payOper->{$payment}($order, $order->amount, $orderType);

        $order->save(['pay_type' =>$payment]);
        $order_data = [
            'order_id' => $order->id,
            'out_trade_no' => $payModel->pay_sn,
            'total_amount' => $payModel->pay_fee,      // 剩余支付金额
        ];
        // 微信公众号，小程序支付，必须有 openid
        if ($payment == 'wechat' || $payment == 'douyin'    ) {

            if (in_array($platform, ['WechatOfficialAccount', 'WechatMiniProgram','DouyinMiniProgram'])) {
                if (isset($openid) && $openid) {
                    // 如果传的有 openid
                    $order_data['payer']['openid'] = $openid;
                } else {
                    // 没有 openid 默认拿下单人的 openid
                    $oauth = ThirdOauth::where([
                        'user_id' => $order->user_id,
                        'platform' => $payment,
                        'apptype' => lcfirst(str_replace($payment, '', $platform))
                    ])->find();

                    $order_data['payer']['openid'] = $oauth ? $oauth->openid : '';
                }

                if (empty($order_data['payer']['openid'])) {
                    // 缺少 openid
                    $this->error('miss_openid', -1);
                }
            }

            $order_data['description'] = '商城订单支付';
        } else {
            $order_data['subject'] = '商城订单支付';
        }

        if($platform == ChannelEnum::CHANNEL_DOUYIN_MINI_PROGRAM){
            $order_data['out_order_no'] = $payModel->pay_sn;
        }
        // echo  "<pre>";
        // print_r(lcfirst(str_replace($payment, '', $platform)));
        // echo  "</pre>";die();

        try {
            $payService = new PayService($payment, $platform);

            
            $result = $payService->pay($order_data);
            
        } catch (\Yansongda\Pay\Exception\Exception $e) {
            $this->error('支付失败' . (config('app_debug') ? "：" . $e->getMessage() : '，请重试'));
        } catch (HttpResponseException $e) {
            $data = $e->getResponse()->getData();
            $message = $data ? ($data['msg'] ?? '') : $e->getMessage();
            $this->error('支付失败' . (config('app_debug') ? "：" . $message : '，请重试'));
        } catch (\Exception $e) {
            // 捕获构造函数错误和其他异常
            $errorMessage = $e->getMessage();
            Log::error('PayService创建失败: ' . $errorMessage);
            $this->error('支付服务初始化失败' . (config('app_debug') ? "：" . $errorMessage : '，请重试'));
        }
        
        $this->success('', [
            'pay_data' => $result,
        ]);

    }

   
    /**
     * 处理余额混合支付
     * @param PayOperService $payOper
     * @param mixed $order
     * @param string $order_type
     * @param float $money
     * @return mixed
     */
    protected function handleBalanceMixedPayment($payOper, $order, $order_type, $money)
    {
        return Db::transaction(function () use ($payOper, $order, $order_type, $money) {
            // 加锁读订单
            $order = $order->lock(true)->find($order->id);

            // 余额支付
            $order = $payOper->money($order, $money, $order_type);

            return $order;
        });
    }

    /**
     * 处理纯余额支付
     * @param PayOperService $payOper
     * @param mixed $order
     * @param string $order_type
     * @return mixed
     * @throws Exception
     */
    protected function handleBalancePayment($payOper, $order, $order_type)
    {
        $order = Db::transaction(function () use ($payOper, $order, $order_type) {
            // 加锁读订单
            $order = $order->lock(true)->find($order->id);

            $order = $payOper->money($order, $order->remain_pay_fee, $order_type);

            return $order;
        });

        if ($order->status != $order::STATUS_PAID) {
            throw new Exception('订单支付失败');
        }
        
        return $order;
    }

    /**
     * 处理货到付款
     * @param PayOperService $payOper
     * @param mixed $order
     * @param string $order_type
     * @return mixed
     * @throws Exception
     */
    protected function handleOfflinePayment($payOper, $order, $order_type)
    {
        if (!isset($order->ext['offline_status']) || $order->ext['offline_status'] != 'enable') {
            throw new Exception('订单不支持货到付款');
        }

        return Db::transaction(function () use ($payOper, $order, $order_type) {
            // 加锁读订单
            $order = $order->lock(true)->find($order->id);

            $order = $payOper->offline($order, 0, $order_type);     // 增加 0 记录

            return $order;
        });
    }

    /**
     * 处理第三方支付（微信、支付宝）
     * @param PayOperService $payOper
     * @param mixed $order
     * @param string $order_type
     * @param string $payment
     * @param string $platform
     * @param string $channel
     * @param string $openid
     * @return mixed
     * @throws Exception
     */
    protected function handleThirdPartyPayment($payModel, $order, $payment, $platform, $openid)
    {
        $order_data = [
            'order_id' => $order->id,
            'out_trade_no' => $payModel->pay_sn,
            'total_amount' => $payModel->pay_fee,      // 剩余支付金额
        ];

        // 微信支付需要 openid
        if ($payment == 'wechat') {
            $this->handleWechatPaymentData($order_data, $platform, $openid, $order);
            $order_data['description'] = '商城订单支付';
        } else {
            $order_data['subject'] = '商城订单支付';
        }

        // 创建支付服务
        $payService = new PayService($payment, $platform);

        try {
            $result = $payService->pay($order_data);
        } catch (\Yansongda\Pay\Exception\Exception $e) {
            throw new Exception('支付失败' . (config('app_debug') ? "：" . $e->getMessage() : '，请重试'));
        } catch (HttpResponseException $e) {
            $data = $e->getResponse()->getData();
            $message = $data ? ($data['msg'] ?? '') : $e->getMessage();
            throw new Exception('支付失败' . (config('app_debug') ? "：" . $message : '，请重试'));
        }

        // APP 平台特殊处理
        if ($platform == 'App') {
            if ($payment == 'wechat') {
                // Yansongda\Supports\Collection，可当数组，可当字符串，这里不用处理
            } else {
                // Guzzle
                $result = $result->getBody()->getContents();
            }
        }

        return $result;
    }

    /**
     * 处理微信支付数据
     * @param array &$order_data
     * @param string $platform
     * @param string $openid
     * @param mixed $order
     * @throws Exception
     */
    protected function handleWechatPaymentData(&$order_data, $platform, $openid, $order)
    {
        // 微信公众号，小程序支付，必须有 openid
        if (in_array($platform, ['WechatOfficialAccount', 'WechatMiniProgram'])) {
            if (isset($openid) && $openid) {
                // 如果传的有 openid
                $order_data['payer']['openid'] = $openid;
            } else {
                // 没有 openid 默认拿下单人的 openid
                // 需要根据实际的第三方授权模型调整
                try {
                    $oauthModel = '\\app\\common\\model\\Third';
                    if (class_exists($oauthModel)) {
                        $oauth = $oauthModel::where([
                            'user_id' => $order->user_id,
                            'platform' => 'wechat',
                            'apptype' => lcfirst(str_replace('wechat', '', $platform))
                        ])->find();
                        $order_data['payer']['openid'] = $oauth ? $oauth->openid : '';
                    } else {
                        $order_data['payer']['openid'] = '';
                    }
                } catch (\Exception $e) {
                    $order_data['payer']['openid'] = '';
                }
            }

            if (empty($order_data['payer']['openid'])) {
                // 缺少 openid
                throw new Exception('miss_openid', -1);
            }
        }
    }

    

  
   
}