custom/plugins/AcrisMailerSalesChannelCS/src/Core/Content/Mail/Subscriber/MailSendSubscriber.php line 75

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Acris\MailerSalesChannel\Core\Content\Mail\Subscriber;
  5. use Acris\MailerSalesChannel\Core\Content\Mail\Acris_Esmtp\Acris_EsmtpTransport;
  6. use Acris\MailerSalesChannel\Core\Content\Mail\Service\AcrisMailerTransportDecorator;
  7. use Acris\MailerSalesChannel\Core\Content\Mail\Service\Mailer;
  8. use Acris\MailerSalesChannel\Core\Content\Mail\Service\Transport\Transports;
  9. use Shopware\Core\Content\MailTemplate\Exception\MailEventConfigurationException;
  10. use Shopware\Core\Content\MailTemplate\Exception\SalesChannelNotFoundException;
  11. use Shopware\Core\Content\MailTemplate\MailTemplateActions;
  12. use Shopware\Core\Content\MailTemplate\Service\Event\MailBeforeSentEvent;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Exception\InconsistentCriteriaIdsException;
  14. use Shopware\Core\Framework\Event\FlowEvent;
  15. use Shopware\Core\Framework\Event\MailActionInterface;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. class MailSendSubscriber implements EventSubscriberInterface
  19. {
  20.     public const ACTION_NAME = MailTemplateActions::MAIL_TEMPLATE_MAIL_SEND_ACTION;
  22.     /**
  23.      * @var Mailer
  24.      */
  25.     private $mailer;
  27.     public function __construct(
  28.         Mailer $mailer
  29.     ) {
  30.         $this->mailer = $mailer;
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             self::ACTION_NAME => [
  37.                 ['sendMail', 1000]
  38.             ],
  39.             MailBeforeSentEvent::class => 'beforeSendMail'
  40.         ];
  41.     }
  43.     /**
  44.      * @throws MailEventConfigurationException
  45.      * @throws SalesChannelNotFoundException
  46.      * @throws InconsistentCriteriaIdsException
  47.      */
  48.     public function sendMail($event): void
  49.     {
  50.         if ($event instanceof FlowEvent) {
  51.             $mailEvent = $event->getEvent();
  53.             if (!$mailEvent instanceof MailActionInterface) {
  54.                 throw new MailEventConfigurationException('Not a instance of MailActionInterface', get_class($mailEvent));
  55.             }
  57.             if (empty($mailEvent->getSalesChannelId()) === false && $this->mailer instanceof Mailer && $this->mailer->getTransport() instanceof Transports) {
  58.                 foreach ($this->mailer->getTransport()->getTransports() as $transport) {
  59.                     if ($transport instanceof AcrisMailerTransportDecorator) {
  60.                         $transport = $transport->getDecorated();
  61.                     }
  63.                     if ($transport instanceof Acris_EsmtpTransport) {
  64.                         $transport->recreateFromSwConfig($mailEvent->getSalesChannelId());
  65.                     }
  66.                 }
  67.             }
  68.         }
  69.     }
  71.     /**
  72.      * Event needed if mail is sent from state change from admin or api
  73.      * @param MailBeforeSentEvent $event
  74.      */
  75.     public function beforeSendMail(MailBeforeSentEvent $event)
  76.     {
  77.         $data = $event->getData();
  78.         if(array_key_exists('salesChannelId', $data) && $data['salesChannelId'] && $this->mailer instanceof Mailer && $this->mailer->getTransport() instanceof Transports) {
  79.             foreach ($this->mailer->getTransport()->getTransports() as $transport) {
  80.                 if ($transport instanceof AcrisMailerTransportDecorator) {
  81.                     $transport = $transport->getDecorated();
  82.                 }
  84.                 if ($transport instanceof Acris_EsmtpTransport && (empty($transport->getSalesChannelId()) === true || $transport->getSalesChannelId() !== $data['salesChannelId'])) {
  85.                     $transport->recreateFromSwConfig($data['salesChannelId']);
  86.                 }
  87.             }
  88.         }
  89.     }
  90. }