src/Service/Wishlist/SessionWishlistManager.php line 69

Open in your IDE?
  1. <?php
  3. namespace App\Service\Wishlist;
  5. use Doctrine\DBAL\Query\QueryBuilder;
  6. use Pimcore\Model\DataObject\CoreShopProduct;
  7. use Psr\Log\LoggerInterface;
  8. use Symfony\Component\HttpFoundation\Session\Session;
  10. class SessionWishlistManager implements WishlistManagerInterface
  11. {
  12.     private const SESSION_ID = 'GUEST_WISHLIST_STORAGE';
  14.     public function __construct(
  15.         private readonly Session         $session,
  16.         private readonly LoggerInterface $logger,
  17.         private readonly bool            $wishlistLog = false,
  18.     )
  19.     {
  20.     }
  22.     public function addItem(CoreShopProduct $product): void
  23.     {
  24.         if (!$this->hasItem($product)) {
  25.             $storage = $this->getSessionStorage();
  26.             $storage[] = $product->getId();
  28.             $this->session->set(self::SESSION_ID, $storage);
  30.             $this->log($product, self::ACTION_ADD);
  31.         }
  32.     }
  34.     public function removeItem(CoreShopProduct $product): void
  35.     {
  36.         if ($this->hasItem($product)) {
  37.             $this->session->set(self::SESSION_ID, array_diff($this->getSessionStorage(), [$product->getId()]));
  39.             $this->log($product, self::ACTION_REMOVE);
  40.         }
  41.     }
  43.     public function hasItem(CoreShopProduct $product): bool
  44.     {
  45.         return in_array($product->getId(), $this->getSessionStorage(), true);
  46.     }
  48.     public function getList(): CoreShopProduct\Listing
  49.     {
  50.         $storage = $this->getSessionStorage();
  52.         $listing = new CoreShopProduct\Listing();
  53.         $listing->onCreateQueryBuilder(function (QueryBuilder $queryBuilder) use ($storage) {
  54.             $queryBuilder->andWhere($queryBuilder->expr()->in('oo_id', $storage));
  55.             $queryBuilder->orderBy(sprintf("FIELD(`oo_id`, %s)", implode(', ', $storage)));
  56.         });
  58.         return $listing;
  59.     }
  61.     public function count(): int
  62.     {
  63.         return count($this->getSessionStorage());
  64.     }
  66.     private function getSessionStorage(): array
  67.     {
  68.         if (!$this->session->has(self::SESSION_ID) || !is_array($this->session->get(self::SESSION_ID))) {
  69.             $this->session->set(self::SESSION_ID, []);
  70.             return [];
  71.         }
  73.         return $this->session->get(self::SESSION_ID);
  74.     }
  76.     public function truncateStorage(): void
  77.     {
  78.         $this->session->remove(self::SESSION_ID);
  79.     }
  81.     private function log(CoreShopProduct $product, string $action): void
  82.     {
  83.         if (!$this->wishlistLog) {
  84.             return;
  85.         }
  87.         $this->logger->info(sprintf("Guest\nAction: %s\nProduct: %s (%d)\nDatetime: %s",
  88.             $action,
  89.             $product->getSku(),
  90.             $product->getId(),
  91.             date('Y-m-d H:i:s')
  92.         ), ['component' => 'wishlist']);
  93.     }
  94. }