vendor/store.shopware.com/spnonewsletterbusiness/src/Subscriber/NewsletterSubscribeSubscriber.php line 45

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /*
  3.  * (c) webpiloten. <kontakt@web-piloten.de>
  4.  * For the full copyright and license information, please view the LICENSE
  5.  * file that was distributed with this source code.
  6.  */
  8. namespace Spno\NewsletterBusiness\Subscriber;
  10. use Shopware\Core\Content\Newsletter\Event\NewsletterConfirmEvent;
  11. use Shopware\Core\Content\Newsletter\Event\NewsletterRegisterEvent;
  12. use Shopware\Core\Framework\Context;
  13. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. use Symfony\Component\HttpFoundation\Request;
  16. use Symfony\Component\HttpFoundation\RequestStack;
  18. class NewsletterSubscribeSubscriber implements EventSubscriberInterface
  19. {
  20.     private RequestStack $requestStack;
  22.     private EntityRepository $newsletterRecipientRepository;
  24.     public function __construct(
  25.         RequestStack $requestStack,
  26.         EntityRepository $newsletterRecipientRepository
  27.     ) {
  28.         $this->requestStack = $requestStack;
  29.         $this->newsletterRecipientRepository = $newsletterRecipientRepository;
  30.     }
  32.     public static function getSubscribedEvents(): array
  33.     {
  34.         return [
  35.             NewsletterRegisterEvent::class => 'onNewsletterRegister',
  36.             NewsletterConfirmEvent::class => 'onNewsletterConfirm',
  37.         ];
  38.     }
  40.     public function onNewsletterRegister(NewsletterRegisterEvent $event): void
  41.     {
  42.         $this->addNewsletterRecipientGroups($event->getNewsletterRecipient()->getId());
  43.     }
  45.     public function onNewsletterConfirm(NewsletterConfirmEvent $event): void
  46.     {
  47.         $this->addNewsletterRecipientGroups($event->getNewsletterRecipient()->getId());
  48.     }
  50.     private function addNewsletterRecipientGroups(string $newsletterRecipientId): void
  51.     {
  52.         $request = $this->requestStack->getMainRequest();
  54.         if (!$request instanceof Request) {
  55.             return;
  56.         }
  58.         if (!is_array($request->get('newsletterRecipientGroups'))) {
  59.             return;
  60.         }
  62.         $newsletterRecipientGroups = $request->get('newsletterRecipientGroups');
  64.         if (empty($newsletterRecipientGroups)) {
  65.             return;
  66.         }
  68.         $data['id'] = $newsletterRecipientId;
  69.         $data['newsletterRecipientGroups'] = array_map(function ($el) {
  70.             return [
  71.                 'id' => $el,
  72.             ];
  73.         }, $newsletterRecipientGroups);
  75.         $this->newsletterRecipientRepository->update([$data], Context::createDefaultContext());
  76.     }
  77. }