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

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.     {
  49.         $this->cartEventProducer = $cartEventProducer;
  50.         $this->cartProcessorService = $cartProcessorService;
  51.         $this->configService = $configService;
  52.     }
  54.     /**
  55.      * @return array
  56.      */
  57.     public static function getSubscribedEvents(): array
  58.     {
  59.         $events = [];
  60.         $events[CartConvertedEvent::class] = 'onCartConvertedEvent';
  61.         if (class_exists('\Shopware\Core\Checkout\Cart\Event\BeforeLineItemAddedEvent')) {
  62.             // for newer shopware versions
  63.             $events[BeforeLineItemAddedEvent::class] = 'onCartUpdatedEvent';
  64.             $events[BeforeLineItemQuantityChangedEvent::class] = 'onCartUpdatedEvent';
  65.             $events[BeforeLineItemRemovedEvent::class] = 'onCartUpdatedEvent';
  66.         } else if (class_exists('\Shopware\Core\Checkout\Cart\Event\LineItemAddedEvent')) {
  67.             // for older shopware versions
  68.             $events[LineItemAddedEvent::class] = 'onCartUpdatedEvent';
  69.             $events[LineItemQuantityChangedEvent::class] = 'onCartUpdatedEvent';
  70.             $events[LineItemRemovedEvent::class] = 'onCartUpdatedEvent';
  71.         }
  72.         return $events;
  73.     }
  75.     /**
  76.      * @param CartConvertedEvent $event
  77.      */
  78.     public function onCartConvertedEvent(CartConvertedEvent $event): void
  79.     {
  80.         $this->configService->setSalesChannelId($event->getSalesChannelContext()->getSalesChannelId());
  81.         if ($this->configService->isAbandonedCartTrackingEnabled()) {
  82.             $this->cartEventProducer->processOrder(
  83.                 $event->getOriginalConvertedCart(),
  84.                 $event->getCart(),
  85.                 $event->getSalesChannelContext()
  86.             );
  87.         }
  88.     }
  90.     /**
  91.      * @param $event
  92.      */
  93.     public function onCartUpdatedEvent($event): void
  94.     {
  95.         if (method_exists($event, 'getSalesChannelContext') && $event->getSalesChannelContext() instanceof SalesChannelContext) {
  96.             $salesChannelId = $event->getSalesChannelContext()->getSalesChannelId();
  97.         } else if (method_exists($event, 'getContext') && $event->getContext() instanceof SalesChannelContext) {
  98.             $salesChannelId = $event->getContext()->getSalesChannelId();
  99.         } else {
  100.             return;
  101.         }
  102.         $this->configService->setSalesChannelId($salesChannelId);
  103.         if ($this->configService->isAbandonedCartTrackingEnabled()) {
  104.             $this->cartProcessorService->setShouldCollectData(true);
  105.         }
  106.     }
  107. }