BossBey File Manager
PHP:
8.2.30
OS:
Linux
User:
imagivibe
Root
/
home
/
imagivibe
/
www
/
app.imagivibe.com
/
app
/
Listeners
📤 Upload
📝 New File
📁 New Folder
Close
Editing: StripeWebhookListener.php
<?php namespace App\Listeners; use App\Events\StripeWebhookEvent; use App\Models\Plan; use App\Models\Setting; use App\Models\User; use App\Models\UserOrder; use App\Models\WebhookHistory; use App\Services\GatewaySelector; use App\Services\PaymentGateways\Contracts\CreditUpdater; use Carbon\Carbon; use Exception; use Illuminate\Contracts\Queue\ShouldQueue; use Illuminate\Queue\InteractsWithQueue; use Illuminate\Support\Facades\Log; use JsonException; use Laravel\Cashier\Subscription as Subscriptions; use Throwable; class StripeWebhookListener implements ShouldQueue { use CreditUpdater; use InteractsWithQueue; /** * Create the event listener. */ public function __construct() { // } public bool $afterCommit = true; public ?string $queue = 'default'; public int $delay = 0; /** * Handle the event. */ public function handle(StripeWebhookEvent $event): void { try { $settings = Setting::getCache(); $incomingJson = json_decode($event->payload, false, 512, JSON_THROW_ON_ERROR); // Incoming data is verified at StripeController handleWebhook function, which fires this event. $event_type = $incomingJson->type; // $resource_id = $incomingJson->data->object->lines->data[0]->price->id; //Price id if ($event_type === 'invoice.paid') { $resource_id = $incomingJson->data->object->subscription; // Subscription id $resource_type = $incomingJson->data->object->lines->data[0]->type; // Subscription / prepaid $summary = $incomingJson->data->object->lines->data[0]->description; $resource_state = $incomingJson->data->object->status; } elseif ($event_type === 'customer.subscription.deleted') { $resource_id = $incomingJson->data->object->items->data[0]->subscription; // Subscription id $resource_type = $incomingJson->data->object->object; // Subscription / prepaid $summary = $incomingJson->data->object->cancellation_details->reason; $resource_state = 'cancelled'; // $incomingJson->data->object->items->status; } // save incoming data $newData = new WebhookHistory; $newData->gatewaycode = 'stripe'; $newData->webhook_id = $incomingJson->id; $newData->create_time = $incomingJson->created; $newData->resource_type = $resource_type; // Subscription / prepaid $newData->event_type = $event_type; $newData->summary = $summary; $newData->resource_id = $resource_id; $newData->resource_state = $resource_state; if ($event_type === 'invoice.paid') { $newData->parent_payment = $incomingJson->data->object->payment_intent; $newData->amount_total = $incomingJson->data->object->lines->data[0]->amount; $newData->amount_currency = $incomingJson->data->object->lines->data[0]->currency; } $newData->incoming_json = json_encode($incomingJson, JSON_THROW_ON_ERROR); $newData->status = 'check'; $newData->save(); // switch/check event type if ($event_type === 'customer.subscription.deleted') { // $resource_id is subscription id in this event. $currentSubscription = Subscriptions::where('stripe_id', $resource_id)->first(); if ($currentSubscription->stripe_status !== 'cancelled') { $currentSubscription->stripe_status = 'cancelled'; $currentSubscription->ends_at = Carbon::now(); $currentSubscription->save(); $newData->status = 'checked'; $newData->save(); } } elseif ($event_type === 'invoice.paid') { // $resource_id is subscription id in this event. $activeSub = Subscriptions::where('stripe_id', $resource_id)->first(); if (isset($activeSub->plan_id) === true) { // Plan may be deleted and null at database. // Get plan $plan = Plan::where('id', $activeSub->plan_id)->first(); if ($plan !== null) { $currentStripeStatus = GatewaySelector::selectGateway('stripe')::getSubscriptionStatus($activeSub->user_id); if ($currentStripeStatus) { // active or trial at stripe side // check for duplication $duplicate = false; // check for first payment in subscription if (Carbon::parse($activeSub->created_at)->diffInMinutes(Carbon::parse($incomingJson->created)) < 5) { $duplicate = true; } if (! $duplicate) { // if it is trial then convert it to active // if it is active and/or converted to active add plan word/image amount to the user // if($activeSub->stripe_status == 'trialing'){} // it may be cancelled so in any case its going to be active $activeSub->stripe_status = 'active'; $activeSub->save(); $payment = new UserOrder; $payment->order_id = $incomingJson->id; $payment->plan_id = $plan->id; $payment->user_id = $activeSub->user_id; $payment->payment_type = 'Stripe Recurring Payment'; $payment->price = $plan->price; $payment->affiliate_earnings = ($plan->price * $settings->affiliate_commission_percentage) / 100; $payment->status = 'Success'; $payment->country = $user->country ?? 'Unknown'; $payment->save(); $user = User::where('id', $activeSub->user_id)->first(); self::creditIncreaseSubscribePlan($user, $plan); $newData->status = 'checked'; $newData->save(); } } } } else { // plan id is null at subscription database table. if ($activeSub->stripe_status !== 'cancelled') { $activeSub->stripe_status = 'cancelled'; $activeSub->ends_at = Carbon::now(); $activeSub->save(); $newData->status = 'checked'; $newData->save(); } Log::error('Payment on a deleted plan. Please check: ' . $resource_id . ' with incoming webhook : ' . json_encode($incomingJson, JSON_THROW_ON_ERROR)); } } // save new order if required // on cancel we do not delete anything. just check if subs cancelled } catch (Exception $ex) { Log::error("StripeWebhookListener::handle()\n" . $ex->getMessage()); } } /** * Handle a job failure. * * @throws JsonException */ public function failed(StripeWebhookEvent $event, Throwable $exception): void { $space = '*****'; $msg = '\n' . $space . '\n' . $space; $msg .= json_encode($event->payload, JSON_THROW_ON_ERROR); $msg .= '\n' . $space . '\n'; $msg .= '\n' . $exception . '\n'; $msg .= '\n' . $space . '\n' . $space; Log::error($msg); } }
Save
Cancel