vendor/shopware/core/Checkout/Customer/Subscriber/CustomerFlowEventsSubscriber.php line 39

Open in your IDE?
  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\Validation\DataBag\RequestDataBag;
  11. use Shopware\Core\System\SalesChannel\Context\SalesChannelContextRestorer;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  15. class CustomerFlowEventsSubscriber implements EventSubscriberInterface
  16. {
  17.     private EventDispatcherInterface $dispatcher;
  19.     private SalesChannelContextRestorer $restorer;
  21.     public function __construct(
  22.         EventDispatcherInterface $dispatcher,
  23.         SalesChannelContextRestorer $restorer
  24.     ) {
  25.         $this->dispatcher = $dispatcher;
  26.         $this->restorer = $restorer;
  27.     }
  29.     /**
  30.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  31.      */
  32.     public static function getSubscribedEvents()
  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. }