custom/plugins/TTechEmailReplyTo/src/Subscriber/ContactFormMailBeforeSentEventSubscriber.php line 48

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace TTechEmailReplyTo\Subscriber;
  5. use Shopware\Core\Content\MailTemplate\Service\Event\MailBeforeSentEvent;
  6. use Shopware\Core\Content\MailTemplate\Service\Event\MailBeforeValidateEvent;
  7. use Shopware\Core\Framework\Api\Context\SalesChannelApiSource;
  8. use Shopware\Core\Framework\Context;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  12. use Shopware\Core\System\SystemConfig\SystemConfigService;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Component\Mime\Address;
  16. class ContactFormMailBeforeSentEventSubscriber implements EventSubscriberInterface
  17. {
  18.     /**
  19.      * @var SystemConfigService
  20.      */
  21.     private $systemConfigService;
  22.     /**
  23.      * @var EntityRepositoryInterface
  24.      */
  25.     private $mailTemplateRepository;
  27.     private ?string $customerEmail = null;
  28.     private ?string $customerName = null;
  31.     public function __construct(
  32.         SystemConfigService $systemConfigService,
  33.         EntityRepositoryInterface $mailTemplateRepository
  34.     )
  35.     {
  36.         $this->systemConfigService = $systemConfigService;
  37.         $this->mailTemplateRepository = $mailTemplateRepository;
  38.     }
  40.     public static function getSubscribedEvents(): array
  41.     {
  42.         return [
  43.             MailBeforeValidateEvent::class => 'onBeforeMailValidateEvent',
  44.             MailBeforeSentEvent::class => 'onMailBeforeSentEvent',
  45.         ];
  46.     }
  48.     public function onBeforeMailValidateEvent(MailBeforeValidateEvent $event) {
  49.         if(!($event->getContext()->getSource() instanceof SalesChannelApiSource)) {
  50.             return;
  51.         }
  53.         /** @var SalesChannelApiSource $source */
  54.         $source = $event->getContext()->getSource();
  56.         if($this->systemConfigService->get('TTechEmailReplyTo.config.setReplyToForContactForm', $source->getSalesChannelId()) !== true) {
  57.             return;
  58.         }
  60.         if(
  61.             !array_key_exists('templateId', $event->getData())
  62.             || !$this->isCorrectMailTemplate($event->getData()['templateId'], $event->getContext())
  63.         ) {
  64.             $this->customerEmail = null;
  65.             $this->customerName = null;
  66.             return;
  67.         }
  69.         $this->customerEmail = $event->getTemplateData()['contactFormData']['email'];
  70.         $this->customerName = $event->getTemplateData()['contactFormData']['firstName'] . ' ' . $event->getTemplateData()['contactFormData']['lastName'];
  71.     }
  73.     public function onMailBeforeSentEvent(MailBeforeSentEvent $event) {
  74.         if(!($event->getContext()->getSource() instanceof SalesChannelApiSource)) {
  75.             return;
  76.         }
  78.         /** @var SalesChannelApiSource $source */
  79.         $source = $event->getContext()->getSource();
  81.         if($this->systemConfigService->get('TTechEmailReplyTo.config.setReplyToForContactForm', $source->getSalesChannelId()) !== true) {
  82.             return;
  83.         }
  85.         if(
  86.             !array_key_exists('templateId', $event->getData())
  87.             || !$this->isCorrectMailTemplate($event->getData()['templateId'], $event->getContext())
  88.         ) {
  89.             return;
  90.         }
  92.         if($this->customerEmail === null) {
  93.             return;
  94.         }
  96.         $event->getMessage()->replyTo(new Address($this->customerEmail, $this->customerName));
  97.     }
  99.     private function isCorrectMailTemplate(string $templateId, Context $context): bool
  100.     {
  101.         $criteria = new Criteria();
  102.         $criteria->addAssociation('mailTemplateType');
  103.         $criteria->addFilter(
  104.             new EqualsFilter('id', $templateId),
  105.             new EqualsFilter('mailTemplateType.technicalName', 'contact_form')
  106.         );
  107.         $result = $this->mailTemplateRepository->search($criteria, $context);
  109.         if($result->getTotal() < 1) {
  110.             return false;
  111.         }
  113.         return true;
  114.     }
  115. }