custom/plugins/MoorlProductPromo/src/Subscriber/StorefrontSubscriber.php line 62

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace MoorlProductPromo\Subscriber;
  5. use MoorlProductPromo\Core\Service\ProductPromoService;
  6. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  7. use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionStates;
  8. use Shopware\Core\Checkout\Order\Event\OrderStateMachineStateChangeEvent;
  9. use Shopware\Core\Checkout\Order\OrderStates;
  10. use Shopware\Core\Content\Product\SalesChannel\SalesChannelProductEntity;
  11. use Shopware\Core\Defaults;
  12. use Shopware\Core\Framework\Api\Context\SalesChannelApiSource;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  15. use Shopware\Core\System\SalesChannel\Entity\SalesChannelEntityLoadedEvent;
  16. use Shopware\Core\System\StateMachine\Event\StateMachineTransitionEvent;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. class StorefrontSubscriber implements EventSubscriberInterface
  20. {
  21.     private ProductPromoService $productPromoService;
  23.     public function __construct(
  24.         ProductPromoService $productPromoService
  25.     )
  26.     {
  27.         $this->productPromoService = $productPromoService;
  28.     }
  30.     public static function getSubscribedEvents(): array
  31.     {
  32.         return [
  33.             'sales_channel.product.loaded' => 'loaded',
  34.             CheckoutOrderPlacedEvent::class => 'onCheckoutOrderPlaced',
  35.             StateMachineTransitionEvent::class => 'stateChanged',
  36.             OrderStateMachineStateChangeEvent::class => 'orderStateChanged',
  37.             'moorl_pp.written' => 'onProductPromoWritten'
  38.         ];
  39.     }
  41.     public function onProductPromoWritten(EntityWrittenEvent $event): void
  42.     {
  43.         foreach ($event->getWriteResults() as $result) {
  44.             if (!$result->hasPayload('id')) {
  45.                 continue;
  46.             }
  48.             $payload = $result->getPayload();
  49.             $payload['id'];
  51.             $promo = $this->productPromoService->getProductPromotionById($payload['id']);
  53.             $this->productPromoService->invalidateProductIds([$promo->getProductId()]);
  54.         }
  55.     }
  57.     public function onCheckoutOrderPlaced(CheckoutOrderPlacedEvent $event) {
  58.         $this->productPromoService->setContext($event->getContext());
  59.         $this->productPromoService->addPurchased($event->getOrder(), 'orderPlaced');
  60.     }
  62.     public function orderStateChanged(OrderStateMachineStateChangeEvent $event): void
  63.     {
  64.         $order = $event->getOrder();
  66.         $transactions = $order->getTransactions();
  68.         if ($transactions === null) {
  69.             return;
  70.         }
  72.         $transaction = $transactions->last();
  73.         if ($transaction === null) {
  74.             return;
  75.         }
  77.         $stateMachineState = $transaction->getStateMachineState();
  78.         if ($stateMachineState === null) {
  79.             return;
  80.         }
  82.         if ($stateMachineState->getTechnicalName() === OrderTransactionStates::STATE_PAID) {
  83.             $this->productPromoService->setContext($event->getContext());
  84.             $this->productPromoService->addPurchased($order, 'orderStatePaid');
  85.         }
  86.     }
  88.     public function stateChanged(StateMachineTransitionEvent $event): void
  89.     {
  90.         if ($event->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  91.             return;
  92.         }
  94.         if ($event->getEntityName() === 'order_transaction' && $event->getToPlace()->getTechnicalName() === OrderTransactionStates::STATE_PAID) {
  95.             $this->productPromoService->setContext($event->getContext());
  96.             $this->productPromoService->addPurchasedOrderTransactionId($event->getEntityId(), 'orderTransactionStatePaid');
  97.         }
  99.         if ($event->getEntityName() === 'order' && $event->getToPlace()->getTechnicalName() === OrderStates::STATE_COMPLETED) {
  100.             $this->productPromoService->setContext($event->getContext());
  101.             $this->productPromoService->addPurchasedOrderId($event->getEntityId(), 'orderStateCompleted');
  102.         }
  103.     }
  105.     public function loaded(SalesChannelEntityLoadedEvent $event): void
  106.     {
  107.         $this->productPromoService->setSalesChannelContext($event->getSalesChannelContext());
  108.         $this->productPromoService->updateProductDiscounts(); // TODO: put in Cronjob
  110.         /** @var SalesChannelProductEntity $product */
  111.         foreach ($event->getEntities() as $product) {
  112.             $this->productPromoService->addExtensionToProduct($product);
  113.         }
  114.     }
  116.     public function onEntityLoaded(EntityLoadedEvent $event): void
  117.     {
  118.         $source = $event->getContext()->getSource();
  120.         if (!$source instanceof SalesChannelApiSource) {
  121.             return;
  122.         }
  124.         foreach ($event->getEntities() as $entity) {
  125.             if ($entity->getType() == 'moorl-product-promo') {
  126.                $this->productPromoService->setContext($event->getContext());
  127.                $this->productPromoService->initProductPromotions();
  128.                $entity->setData($this->productPromoService->getProductPromotions());
  129.             }
  130.         }
  131.     }
  132. }