src/Core/Checkout/Customer/Subscriber/CustomerFlowEventsSubscriber.php line 39

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Checkout\Customer\Subscriber;
  5. use Shopware\Core\Checkout\Customer\CustomerEvents;
  6. use Shopware\Core\Checkout\Customer\Event\CustomerChangedPaymentMethodEvent;
  7. use Shopware\Core\Checkout\Customer\Event\CustomerRegisterEvent;
  8. use Shopware\Core\Framework\Api\Context\SalesChannelApiSource;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  10. use Shopware\Core\Framework\Log\Package;
  11. use Shopware\Core\Framework\Validation\DataBag\RequestDataBag;
  12. use Shopware\Core\System\SalesChannel\Context\SalesChannelContextRestorer;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  16. /**
  17.  * @internal
  18.  */
  19. #[Package('business-ops')]
  20. class CustomerFlowEventsSubscriber implements EventSubscriberInterface
  21. {
  22.     /**
  23.      * @internal
  24.      */
  25.     public function __construct(private readonly EventDispatcherInterface $dispatcher, private readonly SalesChannelContextRestorer $restorer)
  26.     {
  27.     }
  29.     /**
  30.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  31.      */
  32.     public static function getSubscribedEvents(): array
  33.     {
  34.         return [
  35.             CustomerEvents::CUSTOMER_WRITTEN_EVENT => 'onCustomerWritten',
  36.         ];
  37.     }
  39.     public function onCustomerWritten(EntityWrittenEvent $event): void
  40.     {
  41.         if ($event->getContext()->getSource() instanceof SalesChannelApiSource) {
  42.             return;
  43.         }
  45.         $payloads = $event->getPayloads();
  47.         foreach ($payloads as $payload) {
  48.             if (!empty($payload['defaultPaymentMethodId']) && empty($payload['createdAt'])) {
  49.                 $this->dispatchCustomerChangePaymentMethodEvent($payload['id'], $event);
  51.                 continue;
  52.             }
  54.             if (!empty($payload['createdAt'])) {
  55.                 $this->dispatchCustomerRegisterEvent($payload['id'], $event);
  56.             }
  57.         }
  58.     }
  60.     private function dispatchCustomerRegisterEvent(string $customerId, EntityWrittenEvent $event): void
  61.     {
  62.         $context = $event->getContext();
  63.         $salesChannelContext = $this->restorer->restoreByCustomer($customerId, $context);
  65.         if (!$customer = $salesChannelContext->getCustomer()) {
  66.             return;
  67.         }
  69.         $customerCreated = new CustomerRegisterEvent(
  70.             $salesChannelContext,
  71.             $customer
  72.         );
  74.         $this->dispatcher->dispatch($customerCreated);
  75.     }
  77.     private function dispatchCustomerChangePaymentMethodEvent(string $customerId, EntityWrittenEvent $event): void
  78.     {
  79.         $context = $event->getContext();
  80.         $salesChannelContext = $this->restorer->restoreByCustomer($customerId, $context);
  82.         if (!$customer = $salesChannelContext->getCustomer()) {
  83.             return;
  84.         }
  86.         $customerChangePaymentMethodEvent = new CustomerChangedPaymentMethodEvent(
  87.             $salesChannelContext,
  88.             $customer,
  89.             new RequestDataBag()
  90.         );
  92.         $this->dispatcher->dispatch($customerChangePaymentMethodEvent);
  93.     }
  94. }