mirror of
				https://github.com/v2board/v2board.git
				synced 2025-11-04 19:31:45 +08:00 
			
		
		
		
	
		
			
				
	
	
		
			115 lines
		
	
	
		
			3.5 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
			
		
		
	
	
			115 lines
		
	
	
		
			3.5 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
<?php
 | 
						||
 | 
						||
/**
 | 
						||
 * 自己写别抄,抄NMB抄
 | 
						||
 */
 | 
						||
namespace App\Payments;
 | 
						||
 | 
						||
use Stripe\Source;
 | 
						||
use Stripe\Stripe;
 | 
						||
 | 
						||
class StripeAlipay {
 | 
						||
    public function __construct($config)
 | 
						||
    {
 | 
						||
        $this->config = $config;
 | 
						||
    }
 | 
						||
 | 
						||
    public function form()
 | 
						||
    {
 | 
						||
        return [
 | 
						||
            'currency' => [
 | 
						||
                'label' => '货币单位',
 | 
						||
                'description' => '',
 | 
						||
                'type' => 'input',
 | 
						||
            ],
 | 
						||
            'stripe_sk_live' => [
 | 
						||
                'label' => 'SK_LIVE',
 | 
						||
                'description' => '',
 | 
						||
                'type' => 'input',
 | 
						||
            ],
 | 
						||
            'stripe_webhook_key' => [
 | 
						||
                'label' => 'WebHook密钥签名',
 | 
						||
                'description' => '',
 | 
						||
                'type' => 'input',
 | 
						||
            ]
 | 
						||
        ];
 | 
						||
    }
 | 
						||
 | 
						||
    public function pay($order)
 | 
						||
    {
 | 
						||
        $currency = $this->config['currency'];
 | 
						||
        $exchange = $this->exchange('CNY', strtoupper($currency));
 | 
						||
        if (!$exchange) {
 | 
						||
            abort(500, __('user.order.stripeAlipay.currency_convert_timeout'));
 | 
						||
        }
 | 
						||
        Stripe::setApiKey($this->config['stripe_sk_live']);
 | 
						||
        $source = Source::create([
 | 
						||
            'amount' => floor($order['total_amount'] * $exchange),
 | 
						||
            'currency' => $currency,
 | 
						||
            'type' => 'alipay',
 | 
						||
            'statement_descriptor' => $order['trade_no'],
 | 
						||
            'metadata' => [
 | 
						||
                'user_id' => $order['user_id'],
 | 
						||
                'out_trade_no' => $order['trade_no'],
 | 
						||
                'identifier' => ''
 | 
						||
            ],
 | 
						||
            'redirect' => [
 | 
						||
                'return_url' => $order['return_url']
 | 
						||
            ]
 | 
						||
        ]);
 | 
						||
        if (!$source['redirect']['url']) {
 | 
						||
            abort(500, __('user.order.stripeAlipay.gateway_request_failed'));
 | 
						||
        }
 | 
						||
        return [
 | 
						||
            'type' => 1,
 | 
						||
            'data' => $source['redirect']['url']
 | 
						||
        ];
 | 
						||
    }
 | 
						||
 | 
						||
    public function notify($params)
 | 
						||
    {
 | 
						||
        \Stripe\Stripe::setApiKey($this->config['stripe_sk_live']);
 | 
						||
        try {
 | 
						||
            $event = \Stripe\Webhook::constructEvent(
 | 
						||
                file_get_contents('php://input'),
 | 
						||
                $_SERVER['HTTP_STRIPE_SIGNATURE'],
 | 
						||
                $this->config['stripe_webhook_key']
 | 
						||
            );
 | 
						||
        } catch (\Stripe\Error\SignatureVerification $e) {
 | 
						||
            abort(400);
 | 
						||
        }
 | 
						||
        switch ($event->type) {
 | 
						||
            case 'source.chargeable':
 | 
						||
                $object = $event->data->object;
 | 
						||
                \Stripe\Charge::create([
 | 
						||
                    'amount' => $object->amount,
 | 
						||
                    'currency' => $object->currency,
 | 
						||
                    'source' => $object->id,
 | 
						||
                    'metadata' => json_decode($object->metadata, true)
 | 
						||
                ]);
 | 
						||
                break;
 | 
						||
            case 'charge.succeeded':
 | 
						||
                $object = $event->data->object;
 | 
						||
                if ($object->status === 'succeeded') {
 | 
						||
                    $metaData = isset($object->metadata->out_trade_no) ? $object->metadata : $object->source->metadata;
 | 
						||
                    $tradeNo = $metaData->out_trade_no;
 | 
						||
                    return [
 | 
						||
                        'trade_no' => $tradeNo,
 | 
						||
                        'callback_no' => $object->balance_transaction
 | 
						||
                    ];
 | 
						||
                }
 | 
						||
                break;
 | 
						||
            default:
 | 
						||
                abort(500, 'event is not support');
 | 
						||
        }
 | 
						||
        die('success');
 | 
						||
    }
 | 
						||
 | 
						||
    private function exchange($from, $to)
 | 
						||
    {
 | 
						||
        $result = file_get_contents('https://api.exchangerate.host/latest?symbols=' . $to . '&base=' . $from);
 | 
						||
        $result = json_decode($result, true);
 | 
						||
        return $result['rates'][$to];
 | 
						||
    }
 | 
						||
}
 |