vendor/dvdw/platform-choice/src/Checkout/Customer/Subscriber/CustomerRegisterSubscriber.php line 87

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Dvdw\PlatformChoice\Checkout\Customer\Subscriber;
  5. use Dvdw\PlatformChoice\System\SalesChannel\Struct\PlatformChoiceExtension;
  6. use Shopware\Core\Checkout\Customer\Event\CustomerRegisterEvent;
  7. use Shopware\Core\Content\Newsletter\SalesChannel\NewsletterSubscribeRoute;
  8. use Shopware\Core\Framework\Context;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  12. use Shopware\Core\Framework\Uuid\Uuid;
  13. use Shopware\Core\System\SalesChannel\Context\SalesChannelContextPersister;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class CustomerRegisterSubscriber implements EventSubscriberInterface
  17. {
  18.     private EntityRepository $recipientRepo;
  20.     private SalesChannelContextPersister $contextPersister;
  22.     public function __construct(
  23.         EntityRepository $recipientRepo,
  24.         SalesChannelContextPersister $contextPersister
  25.     )
  26.     {
  27.         $this->recipientRepo = $recipientRepo;
  28.         $this->contextPersister = $contextPersister;
  29.     }
  31.     public static function getSubscribedEvents(): iterable
  32.     {
  33.         return [
  34.             CustomerRegisterEvent::class =>
  35.                 [
  36.                     ['extendCustomer', 100],
  37.                     ['subscribeNewsletter', 0],
  38.                     ['updateContext', 0]
  39.                 ]
  40.         ];
  41.     }
  43.     public function extendCustomer(CustomerRegisterEvent $event): void
  44.     {
  45.         $event->getCustomer()->setGroup($event->getSalesChannelContext()->getCurrentCustomerGroup());
  46.     }
  48.     public function subscribeNewsletter(CustomerRegisterEvent $event): void
  49.     {
  50.         $customer = $event->getCustomer();
  52.         if ($customer->getGroup()->getDisplayGross()) {
  53.             return;
  54.         }
  56.         $salesChannelContext = $event->getSalesChannelContext();
  57.         $context = $salesChannelContext->getContext();
  58.         $email = $customer->getEmail();
  60.         if ($this->alreadySubscribed($email, $context)) {
  61.             return;
  62.         }
  64.         $recipient = [
  65.             'email' => $email,
  66.             'title' => $customer->getTitle(),
  67.             'firstName' => $customer->getFirstName(),
  68.             'lastName' => $customer->getLastName(),
  69.             'salutationId' => $customer->getSalutationId(),
  70.             'languageId' => $customer->getLanguageId(),
  71.             'salesChannelId' => $salesChannelContext->getSalesChannelId(),
  72.             'status' => NewsletterSubscribeRoute::STATUS_DIRECT,
  73.             'hash' => Uuid::randomHex()
  74.         ];
  76.         $address = $customer->getDefaultBillingAddress();
  78.         if ($address !== null) {
  79.             $recipient['zipCode'] = $address->getZipcode();
  80.             $recipient['city'] = $address->getCity();
  81.             $recipient['street'] = $address->getStreet();
  82.         }
  84.         $this->recipientRepo->create([$recipient], $context);
  85.     }
  87.     public function updateContext(CustomerRegisterEvent $event): void
  88.     {
  89.         $choice = PlatformChoiceExtension::B2B;
  91.         if ($event->getCustomer()->getGroup()->getDisplayGross()) {
  92.             $choice = PlatformChoiceExtension::B2C;
  93.         }
  95.         $context = $event->getSalesChannelContext();
  97.         $this->contextPersister->save($context->getToken(), [PlatformChoiceExtension::KEY => $choice], '');
  98.     }
  100.     private function alreadySubscribed(string $email, Context $context): bool
  101.     {
  102.         $criteria = (new Criteria())->addFilter(new EqualsFilter('email', $email));
  104.         return $this->recipientRepo->searchIds($criteria, $context)->firstId() !== null;
  105.     }
  106. }