platform/src/Core/Checkout/Customer/Subscriber/CustomerFlowEventsSubscriber.php line 43

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.     public static function getSubscribedEvents()
  37.     {
  38.         return [
  39.             CustomerEvents::CUSTOMER_WRITTEN_EVENT => 'onCustomerWritten',
  40.         ];
  41.     }
  43.     public function onCustomerWritten(EntityWrittenEvent $event): void
  44.     {
  45.         if ($event->getContext()->getSource() instanceof SalesChannelApiSource) {
  46.             return;
  47.         }
  49.         $payloads = $event->getPayloads();
  51.         foreach ($payloads as $payload) {
  52.             if (!empty($payload['defaultPaymentMethodId']) && empty($payload['createdAt'])) {
  53.                 $this->dispatchCustomerChangePaymentMethodEvent($payload['id'], $event);
  55.                 continue;
  56.             }
  58.             if (!empty($payload['createdAt'])) {
  59.                 $this->dispatchCustomerRegisterEvent($payload['id'], $event);
  60.             }
  61.         }
  62.     }
  64.     private function getSalesChannelId(string $customerId): string
  65.     {
  66.         $salesChannelId = $this->connection->createQueryBuilder()
  67.             ->select('sales_channel_id')
  68.             ->from('customer')
  69.             ->where('id = :id')
  70.             ->setParameter(':id', Uuid::fromHexToBytes($customerId))
  71.             ->execute()
  72.             ->fetchColumn();
  74.         return $salesChannelId ? Uuid::fromBytesToHex($salesChannelId) : '';
  75.     }
  77.     private function dispatchCustomerRegisterEvent(string $customerId, EntityWrittenEvent $event): void
  78.     {
  79.         $context = $event->getContext();
  80.         $salesChannelContext = $this->salesChannelContextService->get(
  81.             new SalesChannelContextServiceParameters(
  82.                 $this->getSalesChannelId($customerId),
  83.                 Uuid::randomHex(),
  84.                 $context->getLanguageId(),
  85.                 null,
  86.                 null,
  87.                 $context,
  88.                 $customerId
  89.             )
  90.         );
  92.         if (!$customer = $salesChannelContext->getCustomer()) {
  93.             return;
  94.         }
  96.         $customerCreated = new CustomerRegisterEvent(
  97.             $salesChannelContext,
  98.             $customer
  99.         );
  101.         $this->dispatcher->dispatch($customerCreated);
  102.     }
  104.     private function dispatchCustomerChangePaymentMethodEvent(string $customerId, EntityWrittenEvent $event): void
  105.     {
  106.         $context = $event->getContext();
  107.         $salesChannelContext = $this->salesChannelContextService->get(
  108.             new SalesChannelContextServiceParameters(
  109.                 $this->getSalesChannelId($customerId),
  110.                 Uuid::randomHex(),
  111.                 $context->getLanguageId(),
  112.                 null,
  113.                 null,
  114.                 $context,
  115.                 $customerId
  116.             )
  117.         );
  119.         if (!$customer = $salesChannelContext->getCustomer()) {
  120.             return;
  121.         }
  123.         $customerChangePaymentMethodEvent = new CustomerChangedPaymentMethodEvent(
  124.             $salesChannelContext,
  125.             $customer,
  126.             new RequestDataBag()
  127.         );
  129.         $this->dispatcher->dispatch($customerChangePaymentMethodEvent);
  130.     }
  131. }