custom/plugins/sw-asus/src/Subscriber/NewsletterSubscriptionSubscriber.php line 38

Open in your IDE?
  1. <?php
  3. namespace Onedot\Asus\Subscriber;
  5. use Shopware\Core\Checkout\Customer\Event\CustomerRegisterEvent;
  6. use NewsletterSendinblue\Service\Customer\CustomerProducer;
  7. use Shopware\Core\Framework\Context;
  8. use Symfony\Component\HttpFoundation\RequestStack;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Psr\Log\LoggerInterface;
  13. class NewsletterSubscriptionSubscriber implements EventSubscriberInterface
  14. {
  15.     private $logger;
  16.     private $requestStack;
  17.     /**
  18.      * @var CustomerProducer
  19.      */
  20.     private $customerProducer;
  21.     private EntityRepository $newsletterRecipientRepository;
  23.     public function __construct(EntityRepository $newsletterRecipientRepository, RequestStack $requestStack, CustomerProducer $customerProducer, LoggerInterface $logger)
  24.     {
  25.         $this->newsletterRecipientRepository = $newsletterRecipientRepository;
  26.         $this->customerProducer = $customerProducer;
  27.         $this->requestStack = $requestStack;
  28.         $this->logger = $logger;
  29.     }
  31.     public static function getSubscribedEvents(): array
  32.     {
  33.         return [
  34.             CustomerRegisterEvent::class => 'onCustomerRegister',
  35.         ];
  36.     }
  38.     public function onCustomerRegister(CustomerRegisterEvent $event): void
  39.     {
  40.         $customer = $event->getCustomer();
  41.         $customFields = $customer->getCustomFields() ?? [];
  42.         // $this->logger->error("Custom fields", $this->requestStack->getCurrentRequest()->request->all());
  43.         // Check if the newsletter checkbox is selected
  44.         if (!empty($this->requestStack->getCurrentRequest()->request->all()["newsletter_subscribed"] ?? "")) {
  45.             $email = $customer->getEmail();
  46.             $salesChannelId = $customer->getSalesChannelId();
  47.             $hash = bin2hex(random_bytes(16));
  48.             // Prepare the data for the newsletter recipient
  49.             $newsletterData = [
  50.                 'email' => $email,
  51.                 'salutationId' => $customer->getSalutationId(),
  52.                 'firstName' => $customer->getFirstName(),
  53.                 'lastName' => $customer->getLastName(),
  54.                 'salesChannelId' => $salesChannelId,
  55.                 'status' => "optIn",
  56.                 'hash' => $hash,
  57.             ];
  59.             // Save the newsletter subscription
  60.             $this->newsletterRecipientRepository->upsert([$newsletterData], Context::createDefaultContext());
  61.             $this->customerProducer->confirmContact($customer, $event->getContext(), $event->getSalesChannelId());
  62.         }
  63.     }
  64. }