custom/plugins/CrswCleverReachOfficial/src/Subscriber/Orders/OrderSubscriber.php line 72

Open in your IDE?
  1. <?php
  4. namespace Crsw\CleverReachOfficial\Subscriber\Orders;
  7. use Crsw\CleverReachOfficial\Components\EventHandlers\OrderHandler;
  8. use Crsw\CleverReachOfficial\Components\Utility\Bootstrap;
  9. use Crsw\CleverReachOfficial\Components\Utility\Initializer;
  10. use Crsw\CleverReachOfficial\Entity\Orders\Repositories\OrderItemsRepositoryInterface;
  11. use Shopware\Core\Checkout\Order\OrderEvents;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  16. /**
  17.  * Class OrderSubscriber
  18.  *
  19.  * @package Crsw\CleverReachOfficial\Subscriber\Orders
  20.  */
  21. class OrderSubscriber implements EventSubscriberInterface
  22. {
  23.     /**
  24.      * @var SessionInterface
  25.      */
  26.     private $session;
  27.     /**
  28.      * @var OrderHandler
  29.      */
  30.     private $orderHandler;
  31.     /**
  32.      * @var OrderItemsRepositoryInterface
  33.      */
  34.     private $orderItemsRepository;
  36.     /**
  37.      * OrderSubscriber constructor.
  38.      *
  39.      * @param SessionInterface $session
  40.      * @param OrderHandler $orderHandler
  41.      * @param OrderItemsRepositoryInterface $orderItemsRepository
  42.      * @param Initializer $initializer
  43.      */
  44.     public function __construct(
  45.         SessionInterface $session,
  46.         OrderHandler $orderHandler,
  47.         OrderItemsRepositoryInterface $orderItemsRepository,
  48.         Initializer $initializer
  49.     ) {
  50.         Bootstrap::init();
  51.         $initializer->registerServices();
  52.         $this->session = $session;
  53.         $this->orderHandler = $orderHandler;
  54.         $this->orderItemsRepository = $orderItemsRepository;
  55.     }
  57.     /**
  58.      * @return string[]
  59.      */
  60.     public static function getSubscribedEvents(): array
  61.     {
  62.         return [
  63.             OrderEvents::ORDER_WRITTEN_EVENT => 'onOrderSave'
  64.         ];
  65.     }
  67.     /**
  68.      * Handles order created event.
  69.      *
  70.      * @param EntityWrittenEvent $event
  71.      */
  72.     public function onOrderSave(EntityWrittenEvent $event): void
  73.     {
  74.         if (!$this->orderHandler->canHandle() || !$this->session->isStarted()) {
  75.             return;
  76.         }
  78.         $ids = $event->getIds();
  79.         $orderId = reset($ids);
  80.         $crMailing = $this->session->get('crMailing');
  81.         $email = $this->orderItemsRepository->getEmailByOrderId($orderId);
  83.         $this->orderHandler->orderCreated($email, $orderId, $crMailing ?: '');
  84.     }
  85. }