app/Plugin/ProductOption/Doctrine/EventSubscriber/CartItemLogSubscriberEvent.php line 58

Open in your IDE?
  1. <?php
  3. namespace Plugin\ProductOption\Doctrine\EventSubscriber;
  5. use Doctrine\ORM\EntityManagerInterface;
  6. use Eccube\Entity\CartItemLog;
  7. use Eccube\Event\CartItemChangedEvent;
  8. use Eccube\Repository\CartRepository;
  9. use Eccube\Service\CartService;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. class CartItemLogSubscriberEvent implements EventSubscriberInterface
  13. {
  14.     protected $entityManager;
  15.     protected $cartRepository;
  16.     protected $cartService;
  18.     public function __construct(EntityManagerInterface $entityManager, CartRepository $cartRepository, CartService $cartService)
  19.     {
  20.         $this->entityManager = $entityManager;
  21.         $this->cartRepository = $cartRepository;
  22.         $this->cartService = $cartService;
  23.     }
  25.     public static function getSubscribedEvents()
  26.     {
  27.         return [
  28.             CartItemChangedEvent::ADDED => 'onCartItemAdded',
  29.             CartItemChangedEvent::REMOVED => 'onCartItemRemoved',
  30.         ];
  31.     }
  33.     public function onCartItemAdded(CartItemChangedEvent $event)
  34.     {
  35.         $CartItem = $event->getCartItem();
  36.         $Customer = $event->getCustomer();
  37.         $ProductClass = $CartItem->getProductClass();
  39.         if (!$Customer || !$ProductClass) {
  40.             return;
  41.         }
  43.         $repo = $this->entityManager->getRepository(CartItemLog::class);
  44.         $exists = $repo->findOneBy([
  45.             'Customer' => $Customer,
  46.             'ProductClass' => $ProductClass,
  47.         ]);
  49.         if (!$exists) {
  50.             $Log = new CartItemLog();
  51.             $Log->setCustomer($Customer);
  52.             $Log->setProductClass($ProductClass);
  53.             $this->entityManager->persist($Log);
  54.             $this->entityManager->flush($Log);
  55.         }
  56.     }
  58.     public function onCartItemRemoved(CartItemChangedEvent $event)
  59.     {
  60.         $CartItem = $event->getCartItem();
  61.         $Customer = $event->getCustomer();
  62.         $ProductClass = $CartItem->getProductClass();
  64.         if (!$Customer || !$ProductClass) {
  65.             return;
  66.         }
  68.         $carts = $this->cartService->getCarts($Customer);
  69.         foreach ($carts as $cart) {
  70.             foreach ($cart->getCartItems() as $item) {
  71.                 if (
  72.                     $item->getProductClass()
  73.                     && $item->getProductClass()->getId() === $ProductClass->getId()
  74.                 ) {
  75.                     return;
  76.                 }
  77.             }
  78.         }
  80.         $repo = $this->entityManager->getRepository(CartItemLog::class);
  81.         $Log = $repo->findOneBy([
  82.             'Customer' => $Customer,
  83.             'ProductClass' => $ProductClass,
  84.         ]);
  86.         if ($Log) {
  87.             $this->entityManager->remove($Log);
  88.             $this->entityManager->flush($Log);
  89.         }
  90.     }
  91. }