vendor/abap/payment-bundle/src/Handler/NotifyRequest/PayByNetNotifyRequestHandler.php line 25

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Abap\PaymentBundle\Handler\NotifyRequest;
  7. use Abap\PaymentBundle\Model\PaymentInterface;
  8. use Aspello\Payum\PayByNet\Handler\NotifyRequestHandler;
  9. use Aspello\Payum\PayByNet\Request\AssertNotifyRequestData;
  10. use Doctrine\Persistence\ManagerRegistry;
  11. use Payum\Core\Payum;
  12. use Payum\Core\Request\GetHttpRequest;
  13. use Payum\Core\Request\Notify;
  15. final class PayByNetNotifyRequestHandler implements NotifyRequestHandlerInterface
  16. {
  17.     private Payum $payum;
  19.     public function __construct(
  20.         Payum $payum
  21.     ) {
  22.         $this->payum = $payum;
  23.     }
  25.     public function handle(string $gatewayName, string $paymentClass = null): void
  26.     {
  27.         if (null === $paymentClass) {
  28.             throw new \InvalidArgumentException('Payment class must be provided.');
  29.         }
  31.         $reflectionClass = new \ReflectionClass($paymentClass);
  32.         if (!$reflectionClass->implementsInterface(PaymentInterface::class)) {
  33.             throw new \InvalidArgumentException("Payment class {$paymentClass} is not supported");
  34.         }
  36.         $storage = $this->payum->getStorage($paymentClass);
  37.         $gateway = $this->payum->getGateway($gatewayName);
  39.         $gateway->execute($httpRequest = new GetHttpRequest());
  40.         $gateway->execute(new AssertNotifyRequestData($httpRequest));
  42.         $result = $storage->findBy(['transactionId' => $httpRequest->request['paymentId']]);
  43.         if (empty($result) || !is_array($result)) {
  44.             throw new \InvalidArgumentException('Payment not found');
  45.         }
  47.         /** @var PaymentInterface $payment */
  48.         $payment = reset($result);
  50.         $previousStatus = $payment->getStatus();
  52.         try {
  53.             $gateway->execute(new Notify($payment));
  54.         } finally {
  55.             $newStatus = $payment->getStatus();
  56.             if ($previousStatus !== $newStatus) {
  57.                 $storage->update($payment);
  58.             }
  59.         }
  60.     }
  61. }