custom/plugins/EcocodeTrustpilot/src/Frontend/Event/OrderPlacedSubscriber.php line 50

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Ecocode\Trustpilot\Frontend\Event;
  7. use Ecocode\Trustpilot\Model\Message\InitiateInvitationMessage;
  8. use Ecocode\Trustpilot\Service\TrustpilotConfigurationService;
  9. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  10. use Shopware\Core\Checkout\Order\Event\OrderStateMachineStateChangeEvent;
  11. use Shopware\Core\Checkout\Order\OrderEntity;
  12. use Shopware\Core\Framework\Context;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Component\Messenger\MessageBusInterface;
  15. use Symfony\Contracts\EventDispatcher\Event;
  17. class OrderPlacedSubscriber implements EventSubscriberInterface
  18. {
  19.     /**
  20.      * @var TrustpilotConfigurationService
  21.      */
  22.     protected $configurationService;
  24.     /**
  25.      * @var MessageBusInterface
  26.      */
  27.     private $messageBus;
  29.     public function __construct(MessageBusInterface $messageBus, TrustpilotConfigurationService $configurationService)
  30.     {
  31.         $this->messageBus           = $messageBus;
  32.         $this->configurationService = $configurationService;
  33.     }
  35.     /** @codeCoverageIgnore
  36.      * @return array<string,string>
  37.      */
  38.     public static function getSubscribedEvents(): array
  39.     {
  40.         return [
  41.             CheckoutOrderPlacedEvent::class            => 'orderEvent',
  42.             'state_enter.order_delivery.state.shipped' => 'orderEvent',
  43.             'state_enter.order.state.completed'        => 'orderEvent'
  44.         ];
  45.     }
  47.     /**
  48.      * @param CheckoutOrderPlacedEvent|OrderStateMachineStateChangeEvent $event
  49.      */
  50.     public function orderEvent(Event $event): void
  51.     {
  52.         $salesChannelId = $event->getSalesChannelId();
  54.         if (!$this->configurationService->isConfigured()) {
  55.             return;
  56.         }
  58.         if (!$this->configurationService->isInvitationSendingActive($salesChannelId)) {
  59.             return;
  60.         }
  62.         if ($event->getName() !== $this->configurationService->getSubscribedInvitationEvent($salesChannelId)) {
  63.             return;
  64.         }
  66.         $this->createOrderMessage($event->getOrder(), $event->getContext());
  67.     }
  69.     private function createOrderMessage(OrderEntity $order, Context $context): void
  70.     {
  71.         $evaluationInvitationMessage = new InitiateInvitationMessage();
  72.         $evaluationInvitationMessage
  73.             ->setOrderIds([$order->getId()])
  74.             ->withContext($context);
  76.         $this->messageBus->dispatch($evaluationInvitationMessage);
  77.     }
  78. }