custom/plugins/ImnxxCartRestorer/src/Storefront/Subscriber/CartRestorerSubscriber.php line 27

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace ImnxxCartRestorer\Storefront\Subscriber;
  5. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  6. use Shopware\Storefront\Page\GenericPageLoadedEvent;
  7. use Shopware\Core\Checkout\Cart\SalesChannel\CartService;
  8. use Shopware\Core\Checkout\Customer\Event\CustomerLoginEvent;
  9. use Doctrine\DBAL\Connection;
  11. class CartRestorerSubscriber implements EventSubscriberInterface {
  12.     private CartService $cartService;
  13.     private Connection $connection;
  15.     public function __construct(CartService $cartService, Connection $connection) {
  16.         $this->cartService = $cartService;
  17.         $this->connection = $connection;
  18.     }
  20.     public static function getSubscribedEvents(): array {
  21.         return [
  22.             GenericPageLoadedEvent::class => 'onPageLoaded',
  23.             CustomerLoginEvent::class => ['onCustomerLogin'],
  24.         ];
  25.     }
  27.     public function onPageLoaded(GenericPageLoadedEvent $event) {
  28.         if (isset($_GET['cartId']) && !empty($_GET['cartId'])) {
  29.             $cartOld = $this->cartService->getCart($_GET['cartId'], $event->getSalesChannelContext());
  30.             $cartCurrent = $this->cartService->getCart(
  31.                 $event->getSalesChannelContext()->getToken(),
  32.                 $event->getSalesChannelContext(),
  33.             );
  35.             foreach ($cartOld->getLineItems() as $lineItem) {
  36.                 $this->cartService->add($cartCurrent, $lineItem, $event->getSalesChannelContext());
  37.             }
  38.         }
  39.     }
  41.     public function onCustomerLogin(CustomerLoginEvent $event) {
  42.         $customerId = $event->getCustomerId();
  44.         $latestCartTokenFromCustomer =
  45.             $this->connection
  46.                 ->executeQuery(
  47.                     'SELECT token FROM cart WHERE customer_id = UNHEX(:customerId) ORDER BY created_at DESC LIMIT 1',
  48.                     [
  49.                         'customerId' => $customerId,
  50.                     ],
  51.                 )
  52.                 ->fetchAllAssociative()[0]['token'] ?? null;
  54.         if ($latestCartTokenFromCustomer != null) {
  55.             $currentCart = $this->cartService->getCart(
  56.                 $event->getSalesChannelContext()->getToken(),
  57.                 $event->getSalesChannelContext(),
  58.             );
  60.             $lastCart = $this->cartService->getCart(
  61.                 $latestCartTokenFromCustomer,
  62.                 $event->getSalesChannelContext(),
  63.             );
  65.             foreach ($lastCart->getLineItems() as $lineItem) {
  66.                 $this->cartService->add($currentCart, $lineItem, $event->getSalesChannelContext());
  67.             }
  68.         }
  70.         if (
  71.             isset($_COOKIE['DokumentenId_productnumber_for_login']) &&
  72.             $_COOKIE['DokumentenId_productnumber_for_login'] !== ''
  73.         ) {
  74.             setcookie('docoumentIdProductNumberAfterLogin', $_COOKIE['DokumentenId_productnumber_for_login']);
  75.             unset($_COOKIE['DokumentenId_productnumber_for_login']);
  76.         }
  78.         header('Location: ' . $_SERVER['REQUEST_URI']);
  79.         die();
  80.     }
  81. }