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

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.     /**
  22.      * @internal
  23.      */
  24.     public function __construct(
  25.         EventDispatcherInterface $dispatcher,
  26.         SalesChannelContextRestorer $restorer
  27.     ) {
  28.         $this->dispatcher = $dispatcher;
  29.         $this->restorer = $restorer;
  30.     }
  32.     /**
  33.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  34.      */
  35.     public static function getSubscribedEvents()
  36.     {
  37.         return [
  38.             CustomerEvents::CUSTOMER_WRITTEN_EVENT => 'onCustomerWritten',
  39.         ];
  40.     }
  42.     public function onCustomerWritten(EntityWrittenEvent $event): void
  43.     {
  44.         if ($event->getContext()->getSource() instanceof SalesChannelApiSource) {
  45.             return;
  46.         }
  48.         $payloads = $event->getPayloads();
  50.         foreach ($payloads as $payload) {
  51.             if (!empty($payload['defaultPaymentMethodId']) && empty($payload['createdAt'])) {
  52.                 $this->dispatchCustomerChangePaymentMethodEvent($payload['id'], $event);
  54.                 continue;
  55.             }
  57.             if (!empty($payload['createdAt'])) {
  58.                 $this->dispatchCustomerRegisterEvent($payload['id'], $event);
  59.             }
  60.         }
  61.     }
  63.     private function dispatchCustomerRegisterEvent(string $customerId, EntityWrittenEvent $event): void
  64.     {
  65.         $context = $event->getContext();
  66.         $salesChannelContext = $this->restorer->restoreByCustomer($customerId, $context);
  68.         if (!$customer = $salesChannelContext->getCustomer()) {
  69.             return;
  70.         }
  72.         $customerCreated = new CustomerRegisterEvent(
  73.             $salesChannelContext,
  74.             $customer
  75.         );
  77.         $this->dispatcher->dispatch($customerCreated);
  78.     }
  80.     private function dispatchCustomerChangePaymentMethodEvent(string $customerId, EntityWrittenEvent $event): void
  81.     {
  82.         $context = $event->getContext();
  83.         $salesChannelContext = $this->restorer->restoreByCustomer($customerId, $context);
  85.         if (!$customer = $salesChannelContext->getCustomer()) {
  86.             return;
  87.         }
  89.         $customerChangePaymentMethodEvent = new CustomerChangedPaymentMethodEvent(
  90.             $salesChannelContext,
  91.             $customer,
  92.             new RequestDataBag()
  93.         );
  95.         $this->dispatcher->dispatch($customerChangePaymentMethodEvent);
  96.     }
  97. }