.-.-.-.-.-

<?php

namespace App\Listeners;

use App\Events\TwoCheckoutWebhookEvent;
use App\Models\GatewayProducts;
use App\Models\Plan;
use App\Models\User;
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 Laravel\Cashier\Subscription as Subscriptions;

class TwoCheckoutWebhookListener implements ShouldQueue
{
    use CreditUpdater;
    use InteractsWithQueue;

public bool $afterCommit = true;

public ?string $queue = 'default';

public int $delay = 0;

/**
     * Create the event listener.
     */
    public function __construct()
    {
        //
    }

/**
     * Handle the event.
     */
    public function handle(TwoCheckoutWebhookEvent $event): void
    {
        try {
            $incomingJson = $event->payload;
            $product_id = $incomingJson['IPN_PCODE'][0];
            if (str_contains($product_id, 'Prepaid')) {
                return;
            }
            $product = GatewayProducts::where('product_id', $product_id)->first();
            $plan = Plan::find($product->plan_id);
            $order_status = $incomingJson['ORDERSTATUS'];
            $customer_email = $incomingJson['CUSTOMEREMAIL'];
            $subscription_ref = $incomingJson['IPN_LICENSE_REF'][0];
            $user = User::where('email', $customer_email)->first();
            $user_id = $user->id;
            if ($order_status === 'COMPLETE') {
                $subscription = Subscriptions::where([['user_id', '=', $user_id], ['stripe_price', '=', $product_id], ['stripe_status', '=', 'active']])->first();
                if (! $subscription) {
                    return;
                }
                $subscription->stripe_id = $subscription_ref;
                $subscription->save();
                self::creditIncreaseSubscribePlan($user, $plan);
            } elseif ($order_status === 'CANCELED') {
                $subscription = Subscriptions::where([['user_id', '=', $user_id], ['stripe_price', '=', $product_id], ['stripe_status', '=', 'active']])->first();
                $subscription->stripe_status = 'cancelled';
                $subscription->ends_at = Carbon::now();
                $subscription->save();
            }

} catch (Exception $ex) {
            Log::error("TwoCheckoutWebhookListener::handle()\n" . $ex->getMessage());
        }
    }
}

/home/users/unlimited/www/ultimate-ai.codeskitter.site/app/Listeners/TwoCheckoutWebhookListener.php