custom/plugins/WbfkMultipleDeliveries/src/Subscriber/MailBeforeValidateEventSubscriber.php line 37

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Wbfk\MultipleDeliveries\Subscriber;
  7. use Shopware\Core\Checkout\Order\Aggregate\OrderDelivery\OrderDeliveryEntity;
  8. use Shopware\Core\Checkout\Order\Aggregate\OrderDelivery\OrderDeliveryStates;
  9. use Shopware\Core\Checkout\Order\Aggregate\OrderDeliveryPosition\OrderDeliveryPositionCollection;
  10. use Shopware\Core\Checkout\Order\OrderEntity;
  11. use Shopware\Core\Content\MailTemplate\Service\Event\MailBeforeValidateEvent;
  12. use Shopware\Core\Framework\Context;
  13. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. class MailBeforeValidateEventSubscriber implements EventSubscriberInterface
  20. {
  21.     public const OPEN_STATES = [OrderDeliveryStates::STATE_OPEN, OrderDeliveryStates::STATE_PARTIALLY_SHIPPED];
  23.     public function __construct(private readonly EntityRepository $deliveryPositionRepository)
  24.     {
  25.     }
  27.     /**
  28.      * @inheritDoc
  29.      */
  30.     public static function getSubscribedEvents(): array
  31.     {
  32.         return [
  33.             MailBeforeValidateEvent::class => 'addShippedDeliveryToTemplateData',
  34.         ];
  35.     }
  37.     public function addShippedDeliveryToTemplateData(MailBeforeValidateEvent $event): void
  38.     {
  39.         if (($event->getTemplateData()['eventName'] ?? null) !== 'state_enter.order_delivery.state.shipped') {
  40.             return;
  41.         }
  42.         $shippedDeliveryId = $event->getContext()->getExtension('deliveryInformation')?->get('deliveryId') ?? null;
  43.         /** @var OrderEntity $order */
  44.         $order = $event->getTemplateData()['order'];
  45.         $shippedDelivery = $shippedDeliveryId ? $order->getDeliveries()->get($shippedDeliveryId) : $order->getDeliveries()->first();
  46.         $this->addDeliveryPositions($shippedDelivery, $event->getContext());
  48.         $event->addTemplateData('shippedDelivery', $shippedDelivery);
  49.         $event->addTemplateData('isAllDeliveriesShipped', $this->isAllDeliveriesShipped($order));
  50.     }
  52.     private function addDeliveryPositions(OrderDeliveryEntity $delivery, Context $context): void
  53.     {
  54.         $criteria = new Criteria();
  55.         $criteria->addAssociation('orderLineItem.product');
  56.         $criteria->getAssociation('orderLineItem')->addAssociation('cover');
  57.         $criteria->addSorting(new FieldSorting('createdAt'));
  58.         $criteria->addFilter(new EqualsFilter('orderDeliveryId', $delivery->getId()));
  59.         /** @var OrderDeliveryPositionCollection $positions */
  60.         $positions = $this->deliveryPositionRepository->search($criteria, $context)->getEntities();
  61.         $delivery->setPositions($positions);
  62.     }
  64.     private function isAllDeliveriesShipped(OrderEntity $order): bool
  65.     {
  66.         /** @var OrderDeliveryEntity $delivery */
  67.         foreach ($order->getDeliveries() as $delivery) {
  68.             if (in_array($delivery->getStateMachineState()->getTechnicalName(), self::OPEN_STATES)) {
  69.                 return false;
  70.             }
  71.         }
  73.         return true;
  74.     }
  75. }