custom/plugins/WebkulAbandonedCart/src/Subscriber/AbandonedCartEventSubscriber.php line 39

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Webkul\Abandoned\Subscriber;
  5. use Shopware\Core\Checkout\Order\OrderEvents;
  6. use Shopware\Core\Framework\Context;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  14. class AbandonedCartEventSubscriber implements EventSubscriberInterface
  15. {
  16.     /**
  17.      * @var EntityRepositoryInterface
  18.      */
  19.     protected $cartNotificationRepository;
  21.     /**
  22.      * @var EntityRepositoryInterface
  23.      */
  24.     protected $orderCustomerRepository;
  26.     public function __construct(EntityRepositoryInterface $cartNotificationRepository, EntityRepositoryInterface $orderCustomerRepository)
  27.     {
  28.         $this->cartNotificationRepository = $cartNotificationRepository;
  29.         $this->orderCustomerRepository = $orderCustomerRepository;
  30.     }
  32.     public static function getSubscribedEvents(): array
  33.     {
  34.         return [
  35.             OrderEvents::ORDER_WRITTEN_EVENT => 'updateAbandonedCart'
  36.         ];
  37.     }
  39.     public function updateAbandonedCart(EntityWrittenEvent $event)
  40.     {
  41.         $results = $event->getWriteResults();
  42.         if ($results) {
  43.             foreach ($results as $result) {
  44.                 $payload = $result->getPayload();
  45.                 $this->removeLastNotified($payload['id']);
  46.             }
  47.         }
  48.     }
  50.     private function removeLastNotified($orderId): void
  51.     {
  52.         $orderCustomerEntitites = $this->orderCustomerRepository->search(
  53.             (new Criteria())->addFilter(new EqualsFilter('orderId', $orderId)),
  54.             Context::createDefaultContext()
  55.         );
  57.         if ($orderCustomerEntitites->getTotal()) {
  58.             $customerId = $orderCustomerEntitites->first()->getCustomerId();
  60.             $notificationEntities = $this->cartNotificationRepository->search(
  61.                 (new Criteria())->addFilter(new EqualsFilter('customerId', $customerId)),
  62.                 Context::createDefaultContext()
  63.             );
  65.             if ($notificationEntities->getTotal() > 0) {
  66.                 $id = $notificationEntities->first()->getId();
  68.                 $this->cartNotificationRepository->delete([['id' => $id]], Context::createDefaultContext());
  69.             }
  70.         }
  71.     }
  72. }