custom/plugins/CioOrderExportPerMail/src/Subscriber/OrderSubscriber.php line 79

Open in your IDE?
  1. <?php
  3. namespace CioOrderExportPerMail\Subscriber;
  5. use CioPromotionalOfficeApi\Event\CreateSearchOrderSyncCriteriaEvent;
  6. use Shopware\Core\Checkout\Order\Aggregate\OrderLineItem\OrderLineItemEntity;
  7. use Shopware\Core\Checkout\Order\Event\OrderStateMachineStateChangeEvent;
  8. use Shopware\Core\Content\Mail\Service\AbstractMailService;
  9. use Shopware\Core\Content\MailTemplate\Aggregate\MailTemplateType\MailTemplateTypeEntity;
  10. use Shopware\Core\Content\MailTemplate\MailTemplateEntity;
  11. use Shopware\Core\Content\MailTemplate\MailTemplateTypes;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. use Symfony\Component\HttpFoundation\ParameterBag;
  18. class OrderSubscriber implements EventSubscriberInterface
  19. {
  20.     private AbstractMailService $mailService;
  21.     private EntityRepositoryInterface $mailTemplateRepository;
  22.     private EntityRepositoryInterface $mailTemplateTypeRepository;
  24.     public function __construct(
  25.         AbstractMailService       $mailService,
  26.         EntityRepositoryInterface $mailTemplateRepository,
  27.         EntityRepositoryInterface $mailTemplateTypeRepository
  28.     ){
  29.         $this->mailService = $mailService;
  30.         $this->mailTemplateRepository = $mailTemplateRepository;
  31.         $this->mailTemplateTypeRepository = $mailTemplateTypeRepository;
  32.     }
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [
  37.             'state_leave.order.state.waiting_for_release' => 'onCheckoutOrderPlacedEvent',
  38.             CreateSearchOrderSyncCriteriaEvent::class => 'onCreateSearchOrderSyncCriteriaEvent'
  39.         ];
  40.     }
  42.     public function onCheckoutOrderPlacedEvent(OrderStateMachineStateChangeEvent $event)
  43.     {
  44.         $order = $event->getOrder();
  45.         $manufacturerMails = [];
  47.         /** @var OrderLineItemEntity $lineItem */
  48.         foreach ($order->getLineItems() as $lineItem) {
  50.             if ($payload = $lineItem->getPayload()) {
  51.                 if (array_key_exists('exportMail', $payload)) {
  52.                     $exportMail = $payload['exportMail'];
  53.                     // valid email address?
  54.                     if (filter_var($exportMail, FILTER_VALIDATE_EMAIL)) {
  55.                         $manufacturerMails[$exportMail] = $exportMail;
  56.                     }
  57.                 }
  58.             }
  59.         }
  61.         if (count($manufacturerMails)) {
  62.             /** @var MailTemplateTypeEntity $mailTemplateType */
  63.             $mailTemplateType = $this->mailTemplateTypeRepository->search((new Criteria())->addFilter(new EqualsFilter('technicalName', MailTemplateTypes::MAILTYPE_ORDER_CONFIRM)), $event->getContext())->first();
  64.             /** @var MailTemplateEntity $mailTemplate */
  65.             $mailTemplate = $this->mailTemplateRepository->search((new Criteria())->addFilter(new EqualsFilter('mailTemplateTypeId', $mailTemplateType->getId())), $event->getContext())->first();
  67.             $mailData = new ParameterBag();
  68.             $mailData->set('salesChannelId', $order->getSalesChannelId());
  69.             $mailData->set('recipients', $manufacturerMails);
  70.             $mailData->set('senderName', $mailTemplate->getTranslation('senderName'));
  71.             $mailData->set('subject', $mailTemplate->getSubject());
  72.             $mailData->set('contentHtml', $mailTemplate->getContentHtml());
  73.             $mailData->set('contentPlain', $mailTemplate->getContentPlain());
  75.             $this->mailService->send($mailData->all(), $event->getContext(), ['order' => $order]);
  76.         }
  77.     }
  79.     public function onCreateSearchOrderSyncCriteriaEvent(CreateSearchOrderSyncCriteriaEvent $event)
  80.     {
  81.         $criteria = $event->getCriteria();
  82.         // filter payload
  83.         $criteria->addAssociation('lineItems');
  84.         $criteria->addFilter(new EqualsFilter('lineItems.payload.exportMail', null));
  86.         $event->setCriteria($criteria);
  87.     }
  88. }