custom/plugins/AbmAdjustments/src/Subscriber/OrderTriggerSubscriber.php line 31

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace AbmAdjustments\Subscriber;
  5. use Shopware\Core\Framework\Event\BusinessEventCollector;
  6. use Shopware\Core\Framework\Event\BusinessEventCollectorEvent;
  7. use AbmAdjustments\Flow\OrderDeliveryShippedEvent;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Shopware\Core\Framework\Event\MailRecipientStruct;
  10. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  13. class OrderTriggerSubscriber implements EventSubscriberInterface
  14. {
  15.     private BusinessEventCollector $businessEventCollector;
  16.     private EntityRepository $orderRepository;
  18.     public function __construct(BusinessEventCollector $businessEventCollector, EntityRepository $orderRepository) {
  19.         $this->businessEventCollector = $businessEventCollector;
  20.         $this->orderRepository = $orderRepository;
  21.     }
  23.     public static function getSubscribedEvents()
  24.     {
  25.         return [
  26.             BusinessEventCollectorEvent::NAME => ['onAddOrderDeliveryShippedEvent', 1000],
  27.             CheckoutOrderPlacedEvent::class  => 'onOrderPlaced'
  28.         ];
  29.     }
  31.     public function onAddOrderDeliveryShippedEvent(BusinessEventCollectorEvent $event): void
  32.     {
  33.         $collection = $event->getCollection();
  35.         $definition = $this->businessEventCollector->define(OrderDeliveryShippedEvent::class);
  37.         if (!$definition) {
  38.             return;
  39.         }
  41.         $collection->set($definition->getName(), $definition);
  42.     }
  44.     public function onOrderPlaced(CheckoutOrderPlacedEvent $event): void
  45.     {
  46.         $latestReleaseDate = null;
  47.         $hasPreorderItem = false;
  49.         foreach ($event->getOrder()->getLineItems() as $lineItem) {
  50.             $payload = $lineItem->getPayload();
  51.             if (isset($payload['releaseDate'])) {
  52.                 $releaseDate = new \DateTime($payload['releaseDate']);
  53.                 $now = new \DateTime();
  54.                 
  55.                 if ($releaseDate > $now) {
  56.                     $hasPreorderItem = true;
  57.                     if ($latestReleaseDate === null || $releaseDate > $latestReleaseDate) {
  58.                         $latestReleaseDate = $releaseDate;
  59.                     }
  60.                 }
  61.             }
  62.         }
  64.         if ($hasPreorderItem && $latestReleaseDate !== null) {
  65.             $formattedDate = $latestReleaseDate->format('d.m.Y');
  66.             $existingComment = $event->getOrder()->getCustomerComment() ?? '';
  67.             $newComment = trim($existingComment . "\n" . ' Vorbestellung mit Datum: ' . $formattedDate);
  69.             $this->orderRepository->update([
  70.                 [
  71.                     'id' => $event->getOrderId(),
  72.                     'customerComment' => $newComment
  73.                 ]
  74.             ], $event->getContext());
  75.         }
  76.     }
  78. }