src/Core/Subscriber/BusinessEventSubscriber.php line 45

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Bodymed\Webshop\Core\Subscriber;
  7. use Bodymed\Webshop\Core\Config\PluginConfig;
  8. use Shopware\Core\Checkout\Order\Aggregate\OrderCustomer\OrderCustomerEntity;
  9. use Shopware\Core\Checkout\Order\OrderEntity;
  10. use Shopware\Core\Content\MailTemplate\Service\Event\MailBeforeSentEvent;
  11. use Shopware\Core\Content\MailTemplate\Service\Event\MailBeforeValidateEvent;
  12. use Shopware\Core\Framework\Context;
  13. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. class BusinessEventSubscriber implements EventSubscriberInterface
  19. {
  20.     private EntityRepositoryInterface $orderRepository;
  22.     private EntityRepositoryInterface $orderCustomerRepository;
  24.     private PluginConfig $pluginConfig;
  26.     public function __construct(
  27.         EntityRepositoryInterface $orderRepository,
  28.         EntityRepositoryInterface $orderCustomerRepository,
  29.         PluginConfig $pluginConfig
  30.     ) {
  31.         $this->orderRepository = $orderRepository;
  32.         $this->orderCustomerRepository = $orderCustomerRepository;
  33.         $this->pluginConfig = $pluginConfig;
  34.     }
  37.     public static function getSubscribedEvents(): array
  38.     {
  39.         return [
  40.             MailBeforeValidateEvent::class => 'onMailBeforeValidate',
  41.             MailBeforeSentEvent::class => 'onMailBeforeSentEvent'
  42.         ];
  43.     }
  45.     public function onMailBeforeValidate(MailBeforeValidateEvent $mailBeforeValidateEvent): void
  46.     {
  47.         $templateData = $mailBeforeValidateEvent->getTemplateData();
  48.         $context = $mailBeforeValidateEvent->getContext();
  50.         $data = $mailBeforeValidateEvent->getData();
  52.         if (isset($templateData['order'])
  53.             && $templateData['order'] instanceof OrderEntity
  54.         ) {
  55.             $orderId = $templateData['order']->getId();
  57.             $criteria = new Criteria([$orderId]);
  58.             $criteria
  59.                 ->addAssociation('deliveries.shippingMethod')
  60.                 ->addAssociation('deliveries.shippingOrderAddress.country')
  61.                 ->addAssociation('transactions.paymentMethod')
  62.                 ->addAssociation('lineItems')
  63.                 ->addAssociation('currency')
  64.                 ->addAssociation('addresses.country');
  66.             /** @var OrderEntity|null $orderEntity */
  67.             $orderEntity = $this->orderRepository->search($criteria, $context)->first();
  71.             if ($orderEntity) {
  73.                 // todo@dr: can be merged with above criteria after NEXT-4466
  74.                 $orderEntity->setOrderCustomer(
  75.                     $this->fetchCustomer($orderEntity->getId(), $context)
  76.                 );
  78.                 $mailBeforeValidateEvent->addTemplateData('order', $orderEntity);
  80.                 /**
  81.                  * https://madcode.atlassian.net/browse/BODYMED-864
  82.                  *
  83.                  * Der Absendername bei der Shopbetreiber-Benachrichtigung soll geändert werden zur E-Mail des Kunden
  84.                  */
  85.                 if (isset($data['templateId']) && isset($data['salesChannelId'])) {
  86.                     if ($data['templateId'] === $this->pluginConfig->getShopOwnerOrderNotificationTemplateId($data['salesChannelId'])) {
  87.                         $data['senderName'] = $orderEntity->getOrderCustomer()->getEmail();
  89.                         $mailBeforeValidateEvent->setData($data);
  90.                     }
  91.                 }
  92.             }
  93.         }
  94.     }
  97.     public function onMailBeforeSentEvent(MailBeforeSentEvent $event): void
  98.     {
  99.         /* Shopowner Mail set ReplyTo */
  100.         $eventData = $event->getData();
  102.         if (isset($eventData['templateId']) && isset($eventData['salesChannelId']) && isset($eventData['senderName'])) {
  103.             if ($eventData['templateId'] === $this->pluginConfig->getShopOwnerOrderNotificationTemplateId($eventData['salesChannelId'])) {
  104.                 $event->getMessage()->addReplyTo($eventData['senderName']);
  105.             }
  106.         }
  107.     }
  109.     private function fetchCustomer(string $orderId, Context $context): OrderCustomerEntity
  110.     {
  111.         $criteria = new Criteria();
  112.         $criteria->addFilter(new EqualsFilter('orderId', $orderId));
  113.         $criteria->addAssociation('customer');
  114.         $criteria->addAssociation('salutation');
  116.         return $this->orderCustomerRepository
  117.             ->search($criteria, $context)
  118.             ->first();
  119.     }
  120. }