custom/plugins/WbfkOffer/src/Subscriber/AddOrderDetailsToOfferAndMarkAsOrdered.php line 35

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Wbfk\Offer\Subscriber;
  7. use Shopware\Core\Checkout\Order\OrderEntity;
  8. use Shopware\Core\Checkout\Order\OrderEvents;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  10. use Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Wbfk\Offer\Core\Entity\Offer\OfferCollection;
  15. use Wbfk\Offer\Core\Entity\Offer\OfferEntity;
  16. use Wbfk\Offer\Core\Offer\Storefront\OfferService;
  17. use Wbfk\Offer\Service\OfferLineItemHandler;
  19. class AddOrderDetailsToOfferAndMarkAsOrdered implements EventSubscriberInterface
  20. {
  22.     public function __construct(
  23.         private readonly OfferService $offerService,
  24.         private readonly EntityRepository $orderRepository,
  25.     ) {
  26.     }
  28.     public static function getSubscribedEvents(): array
  29.     {
  30.         return [
  31.             OrderEvents::ORDER_WRITTEN_EVENT => 'addOrderDetailsToOfferAndMarkAsOrdered',
  32.         ];
  33.     }
  35.     public function addOrderDetailsToOfferAndMarkAsOrdered(EntityWrittenEvent $event): void
  36.     {
  37.         foreach ($event->getWriteResults() as $result) {
  38.             $orderId = $result->getPayload()['id'] ?? null;
  39.             if (!$orderId) {
  40.                 continue;
  41.             }
  42.             $criteria = new Criteria([$orderId]);
  43.             $criteria->addAssociation('lineItems');
  44.             /** @var ?OrderEntity $order */
  45.             $order = $this->orderRepository->search($criteria, $event->getContext())->first();
  46.             if (!$order) {
  47.                 return;
  48.             }
  51.             $offerLineItems = $order->getLineItems()->filterByType(OfferLineItemHandler::TYPE_OFFER);
  52.             if ($offerLineItems->count() === 0) {
  53.                 return;
  54.             }
  56.             $offerIds = $offerLineItems->fmap(function ($offerLineItem) {
  57.                 return $offerLineItem->getReferencedId();
  58.             });
  60.             /** @var OfferCollection|OfferEntity[] $offers */
  61.             $offers = $this->offerService->getOffersByIds($offerIds, $event->getContext());
  63.             foreach ($offers as $offer) {
  64.                 if ($offer->isRunning() || $offer->isOrdered()) {
  65.                     // Do not update offer with order details if offer is running or already ordered
  66.                     // When an existing order is edited and saved again, this event is triggered again,
  67.                     // so already ordered offers would be updated again.
  68.                     continue;
  69.                 }
  70.                 $offerContext = $this->offerService->createScContextForOffer($offer);
  71.                 $this->offerService->addOrderDetailsAndMarkAsOrdered($offer, $order->getId(), $order->getVersionId(), $offerContext);
  72.             }
  73.         }
  74.     }
  75. }