custom/static-plugins/SamsonCustomer/src/Subscriber/NE53NewsletterSubscriber.php line 70

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Samson\Subscriber;
  5. /***
  6.  *
  7.  * This file is part of the "SAMSON Shop" project.
  8.  *
  9.  * For the full copyright and license information, please read the
  10.  * LICENSE.txt file that was distributed with this source code.
  11.  *
  12.  *  (c) 2023
  13.  *
  14.  ***/
  16. use Samson\Api\C4C\Service\Ne53NewsletterService;
  17. use Samson\Entities\NE53NewsletterRecipient\NE53NewsletterRecipientEntity;
  18. use Samson\Event\NE53NewsletterChangeEvent;
  19. use Samson\Event\NE53NewsletterConfirmEvent;
  20. use Samson\Event\NE53NewsletterUnsubscribeEvent;
  21. use Shopware\Core\Framework\Context;
  22. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  23. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  24. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  26. class NE53NewsletterSubscriber implements EventSubscriberInterface
  27. {
  28.     private Ne53NewsletterService $ne53NewsletterService;
  29.     private EntityRepositoryInterface $ne53NewsletterRecipientRepository;
  30.     private bool $disableSendingNewsletterDataToC4C;
  32.     public function __construct(Ne53NewsletterService     $ne53NewsletterService,
  33.                                 EntityRepositoryInterface $ne53NewsletterRecipientRepository,
  34.                                 bool                      $disableSendingNewsletterDataToC4C)
  35.     {
  36.         $this->ne53NewsletterService = $ne53NewsletterService;
  37.         $this->ne53NewsletterRecipientRepository = $ne53NewsletterRecipientRepository;
  38.         $this->disableSendingNewsletterDataToC4C = $disableSendingNewsletterDataToC4C;
  39.     }
  41.     public static function getSubscribedEvents(): array
  42.     {
  43.         return [
  44.             NE53NewsletterConfirmEvent::EVENT_NAME => 'onNE53NewsletterConfirm',
  45.             NE53NewsletterUnsubscribeEvent::EVENT_NAME => 'onNE53NewsletterUnsubscribe',
  46.             NE53NewsletterChangeEvent::EVENT_NAME => 'onNE53NewsletterChange'
  47.         ];
  48.     }
  50.     public function onNE53NewsletterConfirm(NE53NewsletterConfirmEvent $event)
  51.     {
  52.         if ($this->disableSendingNewsletterDataToC4C) {
  53.             return;
  54.         }
  56.         $recipient = $this->loadRecipient($event->getNewsletterRecipient(), $event->getContext());
  57.         $this->ne53NewsletterService->createNewsletterRecipient($recipient);
  58.     }
  60.     public function onNE53NewsletterUnsubscribe(NE53NewsletterUnsubscribeEvent $event)
  61.     {
  62.         if ($this->disableSendingNewsletterDataToC4C) {
  63.             return;
  64.         }
  66.         $recipient = $this->loadRecipient($event->getNewsletterRecipient(), $event->getContext());
  67.         $this->ne53NewsletterService->deleteMarketingAttributesForRecipient($recipient);
  68.     }
  70.     public function onNE53NewsletterChange(NE53NewsletterChangeEvent $event)
  71.     {
  72.         if ($this->disableSendingNewsletterDataToC4C) {
  73.             return;
  74.         }
  76.         $recipient = $this->loadRecipient($event->getNewsletterRecipient(), $event->getContext());
  77.         $this->ne53NewsletterService->createNewsletterRecipient($recipient, true);
  78.     }
  80.     private function loadRecipient(NE53NewsletterRecipientEntity $NE53NewsletterRecipientEntity, Context $context): NE53NewsletterRecipientEntity
  81.     {
  82.         $criteria = new Criteria([$NE53NewsletterRecipientEntity->getId()]);
  83.         $criteria->addAssociations(['salutation', 'language.locale']);
  85.         return $this->ne53NewsletterRecipientRepository->search($criteria, $context)->first();
  86.     }
  87. }