src/EventSubscriber/Shop/BeforeOrderCreateSubscriber.php line 46

  1. <?php
  3. declare(strict_types=1);
  5. namespace App\EventSubscriber\Shop;
  7. use ApiPlatform\Core\EventListener\EventPriorities;
  8. use App\Entity\Ledger\Account;
  9. use App\Entity\Shop\Order;
  10. use App\Exceptions\Shop\BuyerAlreadyHasAnyItemsException;
  11. use App\Services\Shop\OrderItemValidator;
  12. use App\Services\Transaction\CreateService;
  13. use App\Services\Transaction\Types\TypeCreatorInterface;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. use Symfony\Component\HttpFoundation\Request;
  16. use Symfony\Component\HttpKernel\Event\ViewEvent;
  17. use Symfony\Component\HttpKernel\KernelEvents;
  18. use Symfony\Component\Workflow\WorkflowInterface;
  20. class BeforeOrderCreateSubscriber implements EventSubscriberInterface
  21. {
  22.     protected const COMMENT = 'Checkout order #%s';
  24.     public function __construct(
  25.         private readonly TypeCreatorInterface $payTypeCreator,
  26.         private readonly OrderItemValidator $orderItemValidator,
  27.         private readonly WorkflowInterface $orderStateMachine,
  28.         private readonly CreateService $transactionService,
  29.         private readonly Account $bankAccount,
  30.     ) {
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             KernelEvents::VIEW => [
  37.                 ['validate', EventPriorities::PRE_WRITE + 1],
  38.                 ['checkout', EventPriorities::PRE_WRITE],
  39.             ],
  40.         ];
  41.     }
  43.     /**
  44.      * @throws BuyerAlreadyHasAnyItemsException
  45.      */
  46.     public function validate(ViewEvent $event): void
  47.     {
  48.         if (!$this->support($event)) {
  49.             return;
  50.         }
  52.         $this->orderItemValidator->validate($this->getOrder($event));
  53.     }
  55.     /**
  56.      * @throws \Throwable
  57.      */
  58.     public function checkout(ViewEvent $event): void
  59.     {
  60.         if (!$this->support($event)) {
  61.             return;
  62.         }
  64.         $order = $this->getOrder($event);
  66.         $payType = $this->payTypeCreator->createType(
  67.             $order->getBuyer()->getMainAccount(),
  68.             $this->bankAccount,
  69.             $order->getTotal(),
  70.             sprintf(self::COMMENT, $order->getId()),
  71.         );
  73.         try {
  74.             $this->transactionService->perform($payType);
  75.             $this->orderStateMachine->apply($order, 'pay');
  76.         } catch (\Throwable $e) {
  77.             $this->orderStateMachine->apply($order, 'reject');
  78.             throw $e;
  79.         }
  80.     }
  82.     private function support(ViewEvent $event): bool
  83.     {
  84.         $method = $event->getRequest()->getMethod();
  85.         $order = $event->getControllerResult();
  87.         return $order instanceof Order && Request::METHOD_POST === $method;
  88.     }
  90.     private function getOrder(ViewEvent $event): Order
  91.     {
  92.         return $event->getControllerResult();
  93.     }
  94. }