custom/plugins/NewsletterSendinblue/src/Subscriber/NewsletterRecipientSubscriber.php line 67

Open in your IDE?
  1. <?php
  3. namespace NewsletterSendinblue\Subscriber;
  5. use NewsletterSendinblue\Service\ConfigService;
  6. use NewsletterSendinblue\Service\NewsletterRecipient\NewsletterRecipientProducer;
  7. use Shopware\Core\Content\MailTemplate\Service\Event\MailBeforeValidateEvent;
  8. use Shopware\Core\Content\Newsletter\Event\NewsletterConfirmEvent;
  9. use Shopware\Core\Content\Newsletter\Event\NewsletterRegisterEvent;
  10. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  13. use Shopware\Core\Framework\Context;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class NewsletterRecipientSubscriber implements EventSubscriberInterface
  17. {
  18.     /**
  19.      * @var NewsletterRecipientProducer
  20.      */
  21.     private $newsletterRecipientProducer;
  23.     /**
  24.      * @var ConfigService
  25.      */
  26.     private $configService;
  28.     /**
  29.      * @var EntityRepositoryInterface
  30.      */
  31.     private $mailTemplateRepository;
  33.     /**
  34.      * NewsletterRecipientSubscriber constructor.
  35.      *
  36.      * @param NewsletterRecipientProducer $newsletterRecipientProducer
  37.      * @param ConfigService $configService
  38.      * @param EntityRepositoryInterface $mailTemplateRepository
  39.      */
  40.     public function __construct(
  41.         NewsletterRecipientProducer $newsletterRecipientProducer,
  42.         ConfigService               $configService,
  43.         EntityRepositoryInterface   $mailTemplateRepository
  44.     )
  45.     {
  46.         $this->newsletterRecipientProducer = $newsletterRecipientProducer;
  47.         $this->configService = $configService;
  48.         $this->mailTemplateRepository = $mailTemplateRepository;
  49.     }
  51.     /**
  52.      * @return array
  53.      */
  54.     public static function getSubscribedEvents(): array
  55.     {
  56.         return [
  57.             NewsletterConfirmEvent::class => 'onNewsletterConfirmEvent',
  58.             NewsletterRegisterEvent::class => 'onNewsletterRegisterEvent',
  59.             EntityWrittenContainerEvent::class => 'onEntityWrittenContainerEvent',
  60.             MailBeforeValidateEvent::class => 'onMailBeforeValidateEvent',
  61.         ];
  62.     }
  64.     /**
  65.      * @param NewsletterConfirmEvent $event
  66.      */
  67.     public function onNewsletterConfirmEvent(NewsletterConfirmEvent $event): void
  68.     {
  69.         $this->newsletterRecipientProducer->confirmContact($event->getNewsletterRecipient(), $event->getSalesChannelId());
  70.     }
  72.     /**
  73.      * @param NewsletterRegisterEvent $event
  74.      */
  75.     public function onNewsletterRegisterEvent(NewsletterRegisterEvent $event): void
  76.     {
  77.         $this->configService->setSalesChannelId($event->getSalesChannelId());
  78.         if ($this->configService->getSubscriptionMailing()) {
  79.             $this->newsletterRecipientProducer->confirmContact($event->getNewsletterRecipient(), $event->getSalesChannelId());
  80.         }
  81.     }
  83.     /**
  84.      * @param EntityWrittenContainerEvent $event
  85.      */
  86.     public function onEntityWrittenContainerEvent(EntityWrittenContainerEvent $event): void
  87.     {
  88.         foreach ($event->getEvents()->getElements() as $eventElement) {
  89.             if ($eventElement->getName() === 'newsletter_recipient.written') {
  90.                 foreach ($eventElement->getWriteResults() as $writeResult) {
  91.                     if ($writeResult->getOperation() === 'update') {
  92.                         $payload = $writeResult->getPayload();
  93.                         $newsletterRecipientId = $writeResult->getPrimaryKey();
  94.                         $salesChannelId = $payload['salesChannelId'] ?? null;
  96.                         if (isset($payload['status']) && $payload['status'] == 'optOut') {
  97.                             $this->newsletterRecipientProducer->unsubscribeContact($newsletterRecipientId, $salesChannelId);
  98.                         } else {
  99.                             $this->newsletterRecipientProducer->updateContact($newsletterRecipientId, $salesChannelId);
  100.                         }
  101.                     }
  102.                 }
  103.             }
  104.         }
  105.     }
  107.     /**
  108.      * @param MailBeforeValidateEvent $event
  109.      */
  110.     public function onMailBeforeValidateEvent(MailBeforeValidateEvent $event): void
  111.     {
  112.         $data = $event->getData();
  113.         $templateData = $event->getTemplateData();
  114.         $context = $event->getContext();
  115.         if (!isset($templateData['newsletterRecipient']) || !isset($data['templateId'])) {
  116.             return;
  117.         }
  118.         if (!$this->isNewsletterMailTemplate($data['templateId'], $context)) {
  119.             return;
  120.         }
  121.         $salesChannelId = null;
  122.         if (!empty($data['salesChannelId'])) {
  123.             $salesChannelId = $data['salesChannelId'];
  124.         }
  125.         if (empty($salesChannelId) && method_exists($context->getSource(), 'getSalesChannelId')) {
  126.             $salesChannelId = $context->getSource()->getSalesChannelId();
  127.         }
  128.         if (!empty($salesChannelId)) {
  129.             $this->configService->setSalesChannelId($salesChannelId);
  130.         }
  131.         if (!$this->configService->getSubscriptionMailing()) {
  132.             return;
  133.         }
  134.         $event->stopPropagation();
  135.     }
  137.     /**
  138.      * @param string $templateId
  139.      * @param Context $context
  140.      * @return bool
  141.      */
  142.     private function isNewsletterMailTemplate(string $templateId, Context $context)
  143.     {
  144.         $criteria = new Criteria([$templateId]);
  145.         $criteria->addAssociation('mailTemplateType');
  146.         $mailTemplate = $this->mailTemplateRepository->search($criteria, $context)->first();
  147.         if (empty($mailTemplate)) {
  148.             return false;
  149.         }
  150.         return in_array($mailTemplate->getMailTemplateType()->getTechnicalName(), ['newsletterDoubleOptIn', 'newsletterRegister']);
  151.     }
  152. }