Server : ApacheSystem : Linux host.digitalbabaji.in 4.18.0-513.11.1.el8_9.x86_64 #1 SMP Wed Jan 17 02:00:40 EST 2024 x86_64 User : addictionfreeind ( 1003) PHP Version : 7.2.34 Disable Function : exec,passthru,shell_exec,system Directory : /home/addictionfreeind/public_html/admin1/app/Http/Controllers/Payment/ |
Upload File : |
<?php
namespace App\Http\Controllers\Payment;
use App\Models\Company;
use App\Traits\MakePaymentTrait;
use Froiden\RestAPI\Exceptions\RelatedResourceNotFoundException;
use Illuminate\Http\JsonResponse;
use Stripe\Stripe;
use Stripe\Webhook;
use App\Models\Order;
use App\Models\Invoice;
use App\Models\Payment;
use Illuminate\Http\Request;
use Illuminate\Routing\Controller;
use App\Traits\MakeOrderInvoiceTrait;
use Stripe\Exception\SignatureVerificationException;
class StripeWebhookController extends Controller
{
use MakeOrderInvoiceTrait, MakePaymentTrait;
/**
* @param $companyHash
* @return JsonResponse
*/
public function getWebhook($companyHash = null)
{
if (!$companyHash) {
return response()->json([
'message' => 'The route has been moved to other route. Please check the stripe settings again'
]);
}
$company = Company::where('hash', $companyHash)->first();
if (!$company) {
return response()->json([
'message' => 'The webhook url provided is wrong'
]);
}
return response()->json([
'message' => 'This url should not be opened directly(GET Request). Only POST request is accepted. Add this url to your stripe webhook'
]);
}
/**
* @throws RelatedResourceNotFoundException
*/
public function verifyStripeWebhook(Request $request, $companyHash)
{
$company = Company::where('hash', $companyHash)->first();
if (!$company) {
return response()->json([
'message' => 'Please enter the correct webhook url. You have entered wrong webhook url'
]);
}
// This needs to be set according to company id
$stripeCredentials = $company->paymentGatewayCredentials;
$stripeSecret = $stripeCredentials->stripe_mode == 'test' ? $stripeCredentials->test_stripe_secret : $stripeCredentials->live_stripe_secret;
$webhookSecret = $stripeCredentials->stripe_mode == 'test' ? $stripeCredentials->test_stripe_webhook_secret : $stripeCredentials->live_stripe_webhook_secret;
Stripe::setApiKey($stripeSecret);
// You can find your endpoint's secret in your webhook settings
$endpoint_secret = $webhookSecret;
$payload = @file_get_contents('php://input');
$sig_header = $_SERVER['HTTP_STRIPE_SIGNATURE'];
try {
Webhook::constructEvent($payload, $sig_header, $endpoint_secret);
} catch (\UnexpectedValueException $e) {
// Invalid payload
return response(__('messages.invalidPayload'), 400);
} catch (SignatureVerificationException $e) {
// Invalid signature
return response(__('messages.invalidSignature'), 400);
}
$payload = json_decode($request->getContent(), true);
$eventId = $payload['id'];
$intentId = $payload['data']['object']['id'];
if ($payload['data']['object']['status'] != 'succeeded') {
$this->paymentFailed($payload);
return response(__('messages.paymentFailed'), 400);
}
// Do something with $event
if ($payload['type'] == 'payment_intent.succeeded') {
$prevClientPayment = Payment::where('payload_id', $intentId)
->whereNull('event_id')
->first();
if ($prevClientPayment) {
/* Found payment with same transaction id */
$prevClientPayment->event_id = $eventId;
$prevClientPayment->save();
}
else {
/* Found nothing on payment table with same transaction id */
/* If it is an invoice payment */
if (isset($payload['data']['object']['metadata']['invoice_id'])) {
$invoiceId = $payload['data']['object']['metadata']['invoice_id'];
$invoice = Invoice::findOrFail($invoiceId);
$currencyId = $invoice->currency_id;
}
/* If it is an order payment */
if (isset($payload['data']['object']['metadata']['order_id'])) {
$orderId = $payload['data']['object']['metadata']['order_id'];
$order = Order::findOrFail($orderId);
$invoice = $this->makeOrderInvoice($order);
$invoiceId = $invoice->id;
$currencyId = $order->currency_id;
}
/* Make payment */
if (isset($invoice) && isset($currencyId) && isset($invoiceId)) {
$this->makePayment('Stripe', $payload['data']['object']['amount'] / 100, $invoice, $payload['data']['object']['id'], 'complete');
}
/* Change invoice status */
if (isset($payload['data']['object']['metadata']['invoice_id']) && isset($invoice)) {
$invoice->status = 'paid';
$invoice->save();
}
/* Change order status */
if (isset($payload['data']['object']['metadata']['order_id']) && isset($order)) {
$order->status = 'completed';
$order->save();
}
}
}
return response(__('messages.webhookHandled'), 200);
}
/**
* @throws RelatedResourceNotFoundException
*/
public function paymentFailed($payload)
{
$intentId = $payload['data']['object']['id'];
$invoiceId = $payload['data']['object']['metadata']['invoice_id'] ?? null;
$orderId = $payload['data']['object']['metadata']['order_id'] ?? null;
$code = $payload['data']['object']['charges']['data'][0]['failure_code'];
$message = $payload['data']['object']['charges']['data'][0]['failure_message'];
$errorMessage = ['code' => $code, 'message' => $message];
/* Set status=unpaid in invoice table */
/* public and dashboard invoices */
if (isset($invoiceId) && $invoiceId != null) {
$invoice = Invoice::where('invoice_id', $invoiceId)->latest()->first();
}
/* Set status=unpaid in invoice table */
if (isset($orderId) && $orderId != null) {
$invoice = Invoice::where('order_id', $orderId)->latest()->first();
}
if (isset($invoice)) {
$invoice->status = 'unpaid';
$invoice->due_amount = $invoice->amount;
$invoice->save();
}
$payment = Payment::where('payload_id', $intentId)->first();
$payment->status = 'failed';
$payment->payment_gateway_response = $errorMessage;
$payment->save();
}
}