v2board/app/Http/Controllers/Guest/OrderController.php
2019-12-21 00:01:11 +08:00

105 lines
3.8 KiB
PHP

<?php
namespace App\Http\Controllers\Guest;
use Illuminate\Http\Request;
use App\Http\Controllers\Controller;
use App\Models\Order;
use Omnipay\Omnipay;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Redis;
class OrderController extends Controller
{
public function alipayNotify (Request $request) {
Log::info('alipayNotifyData: ' . json_encode($_POST));
$gateway = Omnipay::create('Alipay_AopF2F');
$gateway->setSignType('RSA2'); //RSA/RSA2
$gateway->setAppId(config('v2board.alipay_appid'));
$gateway->setPrivateKey(config('v2board.alipay_privkey')); // 可以是路径,也可以是密钥内容
$gateway->setAlipayPublicKey(config('v2board.alipay_pubkey')); // 可以是路径,也可以是密钥内容
$request = $gateway->completePurchase();
$request->setParams($_POST); //Optional
try {
/** @var \Omnipay\Alipay\Responses\AopCompletePurchaseResponse $response */
$response = $request->send();
if($response->isPaid()){
$order = Order::where('trade_no', $_POST['out_trade_no'])->first();
if (!$order) {
abort(500, 'fail');
}
if ($order->status == 1) {
die('success');
}
$order->status = 1;
$order->callback_no = $_POST['trade_no'];
if (!$order->save()) {
abort(500, 'fail');
}
/**
* Payment is successful
*/
die('success'); //The response should be 'success' only
}else{
/**
* Payment is not successful
*/
die('fail');
}
} catch (Exception $e) {
/**
* Payment is not successful
*/
die('fail');
}
}
public function stripeNotify (Request $request) {
Log::info('stripeNotifyData: ' . json_encode($request->input()));
\Stripe\Stripe::setApiKey(config('v2board.stripe_sk_live'));
try {
$event = \Stripe\Webhook::constructEvent(
file_get_contents('php://input'),
$_SERVER['HTTP_STRIPE_SIGNATURE'],
config('v2board.stripe_webhook_key')
);
} catch (\Stripe\Error\SignatureVerification $e) {
abort(400);
}
switch ($event->type) {
case 'source.chargeable':
$source = $event->data->object;
$charge = \Stripe\Charge::create([
'amount' => $source['amount'],
'currency' => $source['currency'],
'source' => $source['id'],
]);
if ($charge['status'] == 'succeeded') {
$trade_no = Redis::get($source['id']);
if (!$trade_no) {
abort(500, 'redis is not found trade no by stripe source id.');
}
$order = Order::where('trade_no', $trade_no)->first();
if (!$order) {
abort(500, 'order is not found');
}
if ($order->status !== 0) {
die('order is paid');
}
$order->status = 1;
$order->callback_no = $source['id'];
if (!$order->save()) {
abort(500, 'fail');
}
Redis::del($source['id']);
die('success');
}
break;
default:
abort(500, 'event is not support');
}
}
}