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

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Checkout\Customer\Subscriber;
  5. use Doctrine\DBAL\Connection;
  6. use Shopware\Core\Checkout\Customer\CustomerEvents;
  7. use Shopware\Core\Checkout\Customer\Event\CustomerChangedPaymentMethodEvent;
  8. use Shopware\Core\Checkout\Customer\Event\CustomerRegisterEvent;
  9. use Shopware\Core\Framework\Api\Context\SalesChannelApiSource;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  11. use Shopware\Core\Framework\Uuid\Uuid;
  12. use Shopware\Core\Framework\Validation\DataBag\RequestDataBag;
  13. use Shopware\Core\System\SalesChannel\Context\SalesChannelContextServiceInterface;
  14. use Shopware\Core\System\SalesChannel\Context\SalesChannelContextServiceParameters;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  18. class CustomerFlowEventsSubscriber implements EventSubscriberInterface
  19. {
  20.     private EventDispatcherInterface $dispatcher;
  22.     private Connection $connection;
  24.     private SalesChannelContextServiceInterface $salesChannelContextService;
  26.     public function __construct(
  27.         Connection $connection,
  28.         EventDispatcherInterface $dispatcher,
  29.         SalesChannelContextServiceInterface $salesChannelContextService
  30.     ) {
  31.         $this->connection = $connection;
  32.         $this->dispatcher = $dispatcher;
  33.         $this->salesChannelContextService = $salesChannelContextService;
  34.     }
  36.     /**
  37.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  38.      */
  39.     public static function getSubscribedEvents()
  40.     {
  41.         return [
  42.             CustomerEvents::CUSTOMER_WRITTEN_EVENT => 'onCustomerWritten',
  43.         ];
  44.     }
  46.     public function onCustomerWritten(EntityWrittenEvent $event): void
  47.     {
  48.         if ($event->getContext()->getSource() instanceof SalesChannelApiSource) {
  49.             return;
  50.         }
  52.         $payloads = $event->getPayloads();
  54.         foreach ($payloads as $payload) {
  55.             if (!empty($payload['defaultPaymentMethodId']) && empty($payload['createdAt'])) {
  56.                 $this->dispatchCustomerChangePaymentMethodEvent($payload['id'], $event);
  58.                 continue;
  59.             }
  61.             if (!empty($payload['createdAt'])) {
  62.                 $this->dispatchCustomerRegisterEvent($payload['id'], $event);
  63.             }
  64.         }
  65.     }
  67.     private function getSalesChannelId(string $customerId): string
  68.     {
  69.         $salesChannelId = $this->connection->createQueryBuilder()
  70.             ->select('sales_channel_id')
  71.             ->from('customer')
  72.             ->where('id = :id')
  73.             ->setParameter(':id', Uuid::fromHexToBytes($customerId))
  74.             ->execute()
  75.             ->fetchColumn();
  77.         return $salesChannelId ? Uuid::fromBytesToHex($salesChannelId) : '';
  78.     }
  80.     private function dispatchCustomerRegisterEvent(string $customerId, EntityWrittenEvent $event): void
  81.     {
  82.         $context = $event->getContext();
  83.         $salesChannelContext = $this->salesChannelContextService->get(
  84.             new SalesChannelContextServiceParameters(
  85.                 $this->getSalesChannelId($customerId),
  86.                 Uuid::randomHex(),
  87.                 $context->getLanguageId(),
  88.                 null,
  89.                 null,
  90.                 $context,
  91.                 $customerId
  92.             )
  93.         );
  95.         if (!$customer = $salesChannelContext->getCustomer()) {
  96.             return;
  97.         }
  99.         $customerCreated = new CustomerRegisterEvent(
  100.             $salesChannelContext,
  101.             $customer
  102.         );
  104.         $this->dispatcher->dispatch($customerCreated);
  105.     }
  107.     private function dispatchCustomerChangePaymentMethodEvent(string $customerId, EntityWrittenEvent $event): void
  108.     {
  109.         $context = $event->getContext();
  110.         $salesChannelContext = $this->salesChannelContextService->get(
  111.             new SalesChannelContextServiceParameters(
  112.                 $this->getSalesChannelId($customerId),
  113.                 Uuid::randomHex(),
  114.                 $context->getLanguageId(),
  115.                 null,
  116.                 null,
  117.                 $context,
  118.                 $customerId
  119.             )
  120.         );
  122.         if (!$customer = $salesChannelContext->getCustomer()) {
  123.             return;
  124.         }
  126.         $customerChangePaymentMethodEvent = new CustomerChangedPaymentMethodEvent(
  127.             $salesChannelContext,
  128.             $customer,
  129.             new RequestDataBag()
  130.         );
  132.         $this->dispatcher->dispatch($customerChangePaymentMethodEvent);
  133.     }
  134. }