custom/plugins/NewsletterSendinblue/src/Subscriber/AbandonedCartSubscriber.php line 77

Open in your IDE?
  1. <?php
  3. namespace NewsletterSendinblue\Subscriber;
  5. use NewsletterSendinblue\Service\Cart\CartEventProducer;
  6. use NewsletterSendinblue\Service\ConfigService;
  7. use NewsletterSendinblue\Service\Cart\SendinblueCartProcessorService;
  8. use Shopware\Core\Checkout\Cart\Event\BeforeLineItemAddedEvent;
  9. use Shopware\Core\Checkout\Cart\Event\BeforeLineItemQuantityChangedEvent;
  10. use Shopware\Core\Checkout\Cart\Event\BeforeLineItemRemovedEvent;
  11. use Shopware\Core\Checkout\Cart\Event\LineItemAddedEVent;
  12. use Shopware\Core\Checkout\Cart\Event\LineItemQuantityChangedEvent;
  13. use Shopware\Core\Checkout\Cart\Event\LineItemRemovedEvent;
  14. use Shopware\Core\Checkout\Cart\Order\CartConvertedEvent;
  15. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. class AbandonedCartSubscriber implements EventSubscriberInterface
  20. {
  21.     /**
  22.      * @var CartEventProducer
  23.      */
  24.     private $cartEventProducer;
  26.     /**
  27.      * @var SendinblueCartProcessorService
  28.      */
  29.     private $cartProcessorService;
  31.     /**
  32.      * @var ConfigService
  33.      */
  34.     private $configService;
  36.     /**
  37.      * AbandonedCartSubscriber constructor.
  38.      *
  39.      * @param CartEventProducer $cartEventProducer
  40.      * @param SendinblueCartProcessorService $cartProcessorService
  41.      * @param ConfigService $configService
  42.      */
  43.     public function __construct(
  44.         CartEventProducer $cartEventProducer,
  45.         SendinblueCartProcessorService $cartProcessorService,
  46.         ConfigService $configService
  47.     ) {
  48.         $this->cartEventProducer = $cartEventProducer;
  49.         $this->cartProcessorService = $cartProcessorService;
  50.         $this->configService = $configService;
  51.     }
  53.     /**
  54.      * @return array
  55.      */
  56.     public static function getSubscribedEvents(): array
  57.     {
  58.         $events = [];
  59.         $events[CartConvertedEvent::class] = 'onCartConvertedEvent';
  60.         if (class_exists('\Shopware\Core\Checkout\Cart\Event\BeforeLineItemAddedEvent')) {
  61.             // for newer shopware versions
  62.             $events[BeforeLineItemAddedEvent::class] = 'onCartUpdatedEvent';
  63.             $events[BeforeLineItemQuantityChangedEvent::class] = 'onCartUpdatedEvent';
  64.             $events[BeforeLineItemRemovedEvent::class] = 'onCartUpdatedEvent';
  65.         } else if (class_exists('\Shopware\Core\Checkout\Cart\Event\LineItemAddedEvent')) {
  66.             // for older shopware versions
  67.             $events[LineItemAddedEvent::class] = 'onCartUpdatedEvent';
  68.             $events[LineItemQuantityChangedEvent::class] = 'onCartUpdatedEvent';
  69.             $events[LineItemRemovedEvent::class] = 'onCartUpdatedEvent';
  70.         }
  71.         return $events;
  72.     }
  74.     /**
  75.      * @param CartConvertedEvent $event
  76.      */
  77.     public function onCartConvertedEvent(CartConvertedEvent $event): void
  78.     {
  79.         $this->configService->setSalesChannelId($event->getSalesChannelContext()->getSalesChannelId());
  80.         if ($this->configService->isAbandonedCartTrackingEnabled()) {
  81.             $this->cartEventProducer->processOrder(
  82.                 $event->getOriginalConvertedCart(),
  83.                 $event->getCart(),
  84.                 $event->getSalesChannelContext()
  85.             );
  86.         }
  87.     }
  89.     /**
  90.      * @param $event
  91.      */
  92.     public function onCartUpdatedEvent($event): void
  93.     {
  94.         if (method_exists($event, 'getSalesChannelContext') && $event->getSalesChannelContext() instanceof SalesChannelContext) {
  95.             $salesChannelId = $event->getSalesChannelContext()->getSalesChannelId();
  96.         } else if (method_exists($event, 'getContext') && $event->getContext() instanceof SalesChannelContext) {
  97.             $salesChannelId = $event->getContext()->getSalesChannelId();
  98.         } else {
  99.             return;
  100.         }
  101.         $this->configService->setSalesChannelId($salesChannelId);
  102.         if ($this->configService->isAbandonedCartTrackingEnabled()) {
  103.             $this->cartProcessorService->setShouldCollectData(true);
  104.         }
  105.     }
  106. }