vendor/store.shopware.com/zeobvabandonedcart/src/Core/Subscriber/OrderSubscriber.php line 52

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Zeobv\AbandonedCart\Core\Subscriber;
  5. use Shopware\Core\Checkout\Order\OrderDefinition;
  6. use Shopware\Core\Checkout\Order\OrderEntity;
  7. use Shopware\Core\Checkout\Order\OrderEvents;
  8. use Shopware\Core\Framework\Context;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  10. use Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. use Zeobv\AbandonedCart\Service\AbandonedCartService;
  17. class OrderSubscriber implements EventSubscriberInterface
  18. {
  19.     protected AbandonedCartService $abandonedCartService;
  20.     protected EntityRepositoryInterface $orderRepository;
  21.     protected EntityRepositoryInterface $abandonedCartRepository;
  23.     /**
  24.      * @param AbandonedCartService      $abandonedCartService
  25.      * @param EntityRepositoryInterface $orderRepository
  26.      * @param EntityRepositoryInterface $abandonedCartRepository
  27.      */
  28.     public function __construct(
  29.         AbandonedCartService $abandonedCartService,
  30.         EntityRepositoryInterface $orderRepository,
  31.         EntityRepositoryInterface $abandonedCartRepository
  32.     )
  33.     {
  34.         $this->abandonedCartService = $abandonedCartService;
  35.         $this->orderRepository = $orderRepository;
  36.         $this->abandonedCartRepository = $abandonedCartRepository;
  37.     }
  39.     /**
  40.      * @return array
  41.      */
  42.     public static function getSubscribedEvents(): array
  43.     {
  44.         return [
  45.             OrderEvents::ORDER_WRITTEN_EVENT => 'onOrderWritten',
  46.         ];
  47.     }
  49.     /**
  50.      * @param EntityWrittenEvent $event
  51.      */
  52.     public function onOrderWritten(EntityWrittenEvent $event): void
  53.     {
  54.         foreach ($event->getWriteResults() as $writeResult) {
  55.             if ($writeResult->getOperation() !== EntityWriteResult::OPERATION_INSERT
  56.                 || $writeResult->getEntityName() !== OrderDefinition::ENTITY_NAME
  57.             ) {
  58.                 continue;
  59.             }
  61.             if (is_array($writeResult->getPrimaryKey())) {
  62.                 foreach ($writeResult->getPrimaryKey() as $id) {
  63.                     $this->resolveAbandonedCartForOrderId($id, $event->getContext());
  64.                 }
  65.             } else {
  66.                 $this->resolveAbandonedCartForOrderId($writeResult->getPrimaryKey(), $event->getContext());
  67.             }
  68.         }
  69.     }
  71.     /**
  72.      * @param string  $orderId
  73.      * @param Context $context
  74.      */
  75.     protected function resolveAbandonedCartForOrderId(string $orderId, Context $context): void
  76.     {
  77.         $criteria = new Criteria([$orderId]);
  78.         $criteria->addAssociation('orderCustomer');
  80.         /** @var OrderEntity|null $order */
  81.         $order = $this->orderRepository->search($criteria, $context)->first();
  83.         if ($order === null || $order->getOrderCustomer() === null) {
  84.             return;
  85.         }
  87.         $criteria = new Criteria();
  88.         $criteria->addFilter(new EqualsFilter('email', $order->getOrderCustomer()->getEmail()));
  89.         $abandonedCart = $this->abandonedCartRepository->search($criteria, $context)->first();
  91.         if ($abandonedCart === null) {
  92.             return;
  93.         }
  94.         /* Here we are upsert the data on order table for displaying the recovered orders in dashboard */
  95.         if ($abandonedCart->getIsRecovered() == true) {
  96.             $writeData = [
  97.                 'id' => $orderId,
  98.                 'customFields' => ['ZeobvAbandonedCartMail' => 1],
  99.             ];
  100.             $this->orderRepository->upsert([$writeData], Context::createDefaultContext());
  101.         }
  103.         $this->abandonedCartService->resolveAbandonedCart($abandonedCart, $context);
  104.     }
  105. }