neiyou_user_web/app/Http/Controllers/Gateway/PayPal.php

<?php


namespace App\Http\Controllers\Gateway;

use App\Models\Payment;
use Auth;
use Exception;
use GuzzleHttp\Client;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
use Log;
use Response;
use Srmklive\PayPal\Services\ExpressCheckout;

class PayPal extends AbstractPayment {
	protected $provider;
	protected $exChange;

	public function __construct() {
		parent::__construct();
		$this->provider = new ExpressCheckout();
		$config = [
			'mode' => 'live',
			'live' => [
				'username'    => self::$sysConfig['paypal_username'],
				'password'    => self::$sysConfig['paypal_password'],
				'secret'      => self::$sysConfig['paypal_secret'],
				'certificate' => self::$sysConfig['paypal_certificate'],
				'app_id'      => self::$sysConfig['paypal_app_id'],
			],

			'payment_action' => 'Sale',
			'currency'       => 'USD',
			'billing_type'   => 'MerchantInitiatedBilling',
			'notify_url'     => (self::$sysConfig['website_callback_url']?: self::$sysConfig['website_url']).'/callback/notify?method=paypal',
			'locale'         => 'zh_CN',
			'validate_ssl'   => true,
		];
		$this->provider->setApiCredentials($config);
		$this->exChange = 7;
		$client = new Client(['timeout' => 15]);
		$exChangeRate = json_decode($client->get('http://api.k780.com/?app=finance.rate&scur=USD&tcur=CNY&appkey=10003&sign=b59bc3ef6191eb9f747dd4e83c99f2a4')
		                                   ->getBody(), true);

		if($exChangeRate && $exChangeRate['success']){
			$this->exChange = $exChangeRate['result']['rate'];
		}
	}

	public function purchase($request): JsonResponse {
		$payment = $this->creatNewPayment(Auth::id(), $request->input('id'), $request->input('amount'));

		$data = $this->getCheckoutData($payment->trade_no, $payment->amount);

		try{
			$response = $this->provider->setExpressCheckout($data);
			if(!$response['paypal_link']){
				Log::error('Paypal处理错误：'.var_export($response, true));

				return Response::json(['status' => 'fail', 'message' => '创建订单失败，请使用其他方式或通知管理员！']);
			}
			$payment->update(['url' => $response['paypal_link']]);

			return Response::json(['status' => 'success', 'url' => $response['paypal_link'], 'message' => '创建订单成功!']);
		}catch(Exception $e){
			Log::error("【PayPal】错误: ".$e->getMessage());
			exit;
		}
	}

	protected function getCheckoutData($trade_no, $amount): array {
		$amount = 0.3 + ceil($amount / $this->exChange * 100) / 100;

		return [
			'invoice_id'          => $trade_no,
			'items'               => [
				[
					'name'  => self::$sysConfig['subject_name']?: self::$sysConfig['website_name'],
					'price' => $amount,
					'desc'  => 'Description for'.(self::$sysConfig['subject_name']?: self::$sysConfig['website_name']),
					'qty'   => 1
				]
			],
			'invoice_description' => $trade_no,
			'return_url'          => self::$sysConfig['website_url'].'/callback/checkout',
			'cancel_url'          => self::$sysConfig['website_url'].'/invoices',
			'total'               => $amount,
		];
	}

	public function getCheckout(Request $request) {
		$token = $request->get('token');
		$PayerID = $request->get('PayerID');

		// Verify Express Checkout Token
		$response = $this->provider->getExpressCheckoutDetails($token);

		if(in_array(strtoupper($response['ACK']), ['SUCCESS', 'SUCCESSWITHWARNING'])){
			$payment = Payment::whereTradeNo($response['INVNUM'])->firstOrFail();
			$data = $this->getCheckoutData($payment->trade_no, $payment->amount);
			// Perform transaction on PayPal
			$payment_status = $this->provider->doExpressCheckoutPayment($data, $token, $PayerID);
			$status = $payment_status['PAYMENTINFO_0_PAYMENTSTATUS'];

			if(!strcasecmp($status, 'Completed') || !strcasecmp($status, 'Processed')){
				Log::info("Order $payment->order_id has been paid successfully!");
				$payment->order->update(['status' => 1]);
			}else{
				Log::error("Error processing PayPal payment for Order $payment->id!");
			}
		}

		return redirect('/invoices');
	}

	public function notify($request): void {
		$request->merge(['cmd' => '_notify-validate']);
		foreach($request->input() as $key => $value){
			if($value == null){
				$request->request->set($key, '');
			}
		}
		$post = $request->all();

		$response = (string) $this->provider->verifyIPN($post);

		if($response === 'VERIFIED' && $request['invoice']){
			$payment = Payment::whereTradeNo($request['invoice'])->first();
			if($payment && $payment->status == 0){
				$ret = $payment->order->update(['status' => 2]);
				if($ret){
					exit('success');
				}
			}
		}
		exit("fail");
	}
}