src/EventSubscriber/Payment/OrderPaymentCompletedSubscriber.php line 38

  1. <?php
  3. declare(strict_types=1);
  5. namespace App\EventSubscriber\Payment;
  7. use App\Entity\Geographical\Address;
  8. use App\Entity\Payment\Payment;
  9. use App\Message\CompleteOrderRequest;
  10. use App\OrderStates;
  11. use App\Processor\Order\CompleteOrderProcessorInterface;
  12. use App\Repository\CustomerRepository;
  13. use App\Repository\Order\OrderRepository;
  14. use ApiPlatform\Api\IriConverterInterface;
  15. use Doctrine\ORM\EntityManagerInterface;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use Symfony\Component\Workflow\Event\Event;
  18. use Symfony\Component\Workflow\Registry;
  19. use Webmozart\Assert\Assert;
  21. /**
  22.  * When a Stripe payment completes for an order (direct or complement),
  23.  * transition the order to in_production and debit credits for complement.
  24.  * If the payment was created via direct-intent (no order yet), create the order from payload first.
  25.  */
  26. final class OrderPaymentCompletedSubscriber implements EventSubscriberInterface
  27. {
  28.     public function __construct(
  29.         private Registry $workflowRegistry,
  30.         private OrderRepository $orderRepository,
  31.         private CustomerRepository $customerRepository,
  32.         private CompleteOrderProcessorInterface $completeOrderProcessor,
  33.         private IriConverterInterface $iriConverter,
  34.         private EntityManagerInterface $entityManager,
  35.     ) {
  36.     }
  38.     public function onPaymentCompleted(Event $event): void
  39.     {
  40.         /** @var Payment $payment */
  41.         $payment = $event->getSubject();
  42.         Assert::isInstanceOf($payment, Payment::class);
  44.         if (!$payment->isOrderPayment()) {
  45.             return;
  46.         }
  48.         $order = $payment->getOrder();
  50.         if ($order === null) {
  51.             $details = $payment->getDetails();
  52.             $payload = $details['order_payload'] ?? null;
  53.             if (!\is_array($payload)) {
  54.                 return;
  55.             }
  56.             $address = $this->iriConverter->getResourceFromIri((string) $payload['address']);
  57.             Assert::isInstanceOf($address, Address::class);
  58.             $completeOrderRequest = new CompleteOrderRequest(
  59.                 name: $payload['name'] ?? '',
  60.                 address: $address,
  61.                 quantity: $payload['quantity'] ?? 1,
  62.                 photosCount: $payload['photosCount'] ?? 0,
  63.                 mattePaper: $payload['mattePaper'] ?? false,
  64.                 withFrame: $payload['withFrame'] ?? false,
  65.                 isFromCode: $payload['isFromCode'] ?? false,
  66.                 paymentMode: $payload['paymentMode'] ?? 'direct',
  67.                 sharedEventCode: isset($payload['sharedEventCode']) ? (string) $payload['sharedEventCode'] : null,
  68.             );
  69.             $order = $this->completeOrderProcessor->processOrderAfterPayment($completeOrderRequest);
  70.             $payment->setOrder($order);
  71.             $this->entityManager->flush();
  72.         }
  74.         if ($payment->getPaymentType() === 'order_complement' && $payment->getCreditsToDebit() > 0) {
  75.             $customer = $order->getCustomer();
  76.             if ($customer !== null) {
  77.                 $customer->setCredits($customer->getCredits() - $payment->getCreditsToDebit());
  78.                 $this->customerRepository->add($customer);
  79.             }
  80.         }
  82.         $orderWorkflow = $this->workflowRegistry->get($order, 'order');
  83.         if ($orderWorkflow->can($order, OrderStates::TRANSITION_PAYMENT_CONFIRMED)) {
  84.             $orderWorkflow->apply($order, OrderStates::TRANSITION_PAYMENT_CONFIRMED);
  85.             $this->orderRepository->add($order);
  86.         }
  87.     }
  89.     public static function getSubscribedEvents(): array
  90.     {
  91.         return [
  92.             'workflow.payment.enter.completed' => ['onPaymentCompleted', -10], // after PaymentAddCreditsSubscriber
  93.         ];
  94.     }
  95. }