src/Controller/Shop/ProductsVisitedController.php line 74

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\Controller\Shop;
  7. use App\Entity\Customer\Customer;
  8. use App\Repository\Parameter\ParameterRepository;
  9. use App\Repository\Product\ProductRepository;
  10. use Doctrine\ORM\EntityManagerInterface;
  11. use Sylius\Bundle\CoreBundle\Doctrine\ORM\CustomerRepository;
  12. use Sylius\Component\Channel\Context\ChannelContextInterface;
  13. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  14. use Symfony\Component\HttpFoundation\JsonResponse;
  15. use Symfony\Component\HttpFoundation\Request;
  16. use Symfony\Component\HttpFoundation\Response;
  18. final class ProductsVisitedController extends AbstractController
  19. {
  21.     public function __construct(private CustomerRepository $customerRepository,
  22.                                 private ProductRepository $productRepository,
  23.                                 private ParameterRepository $parameterRepository,
  24.                                 private EntityManagerInterface $em,
  25.                                 private ChannelContextInterface $channelContext){}
  27.     public function addProductAjaxAction(Request $request): JsonResponse {
  28.         $customerId = $request->request->get('customerId');
  29.         $productId = $request->request->get('productId');
  30.         if (!$productId)
  31.             return new JsonResponse(null, Response::HTTP_BAD_REQUEST);
  33.         if ($customerId && $customerId !== 0) {
  34.             /** @var Customer $customer */
  35.             $customer = $this->customerRepository->find($customerId);
  37.             if (!$customer)
  38.                 return new JsonResponse(null, Response::HTTP_BAD_REQUEST);
  40.             $productsVisited = $this->updateProductsVisited($customer->getProductsVisited(), $productId);
  42.             $customer->setProductsVisited($productsVisited);
  43.             $this->em->persist($customer);
  44.             $this->em->flush();
  45.         }
  46.         else {
  47.             //mettre simplement le produit en session
  48.             $productsVisited = $request->getSession()->get('productsVisited');
  49.             if (!$productsVisited || count($productsVisited) < 1) {
  50.                 $productsVisited = [];
  51.             }
  52.             $productsVisited = $this->updateProductsVisited($productsVisited, $productId);
  53.         }
  54.         //mettre le tableau en session
  55.         $request->getSession()->set('productsVisited', $productsVisited);
  57.         return new JsonResponse(null, Response::HTTP_OK);
  58.     }
  60.     public function getCustomerProductsVisitedAction(Request $request) {
  62.         $customer = null;
  63.         $customerId = $request->query->get('customerId');
  65.         if ($customerId) {
  66.             /** @var Customer $customer */
  67.             $customer = $this->customerRepository->find($customerId);
  68.         }
  69.         // récupérer le nombre de produits à mettre dans le tableau
  70.         $nbProduct = $this->parameterRepository->findByCodeAndChannelCode('nb_product_visited', $this->channelContext->getChannel()->getCode());
  71.         if (!$nbProduct)
  72.             $nbProduct = 8;
  73.         // récupérer les produits visités, et les trier dans l'ordre où ils ont été consultés
  74.         $productsIdVisited = $request->getSession()->get('productsVisited');
  75.         $productsVisitedSorted = [];
  76.         if ($productsIdVisited && count($productsIdVisited) > 0) {
  77.             $productsVisited = $this->productRepository->findProductsVisited($productsIdVisited, (int)$nbProduct);
  78.             foreach ($productsIdVisited as $productid) {
  79.                 foreach ($productsVisited as $product) {
  80.                     if ($product->getId() === (int)$productid) {
  81.                         $productsVisitedSorted[] = $product;
  82.                     }
  83.                 }
  84.             }
  85.         }
  87.         return $this->render('@SyliusShop/Product/_horizontalListWithHeader.html.twig', ['products' => $productsVisitedSorted, 'header' => 'app.product.products_visited', 'trans' => true]);
  88.     }
  90.     private function updateProductsVisited($productsVisited, $productId) {
  91.         //supprimer d'abord l'id du tableau correspondant s'il existe, pour le mettre ensuite en dernière position
  92.         if (in_array($productId, $productsVisited)) {
  93.             $index = array_search($productId, $productsVisited);
  94.             unset($productsVisited[$index]);
  95.         }
  96.         // on garde que les 15 derniers produits consultés
  97.         if (count($productsVisited) > 15)
  98.             array_shift($productsVisited);
  100.         $productsVisited[] = $productId;
  102.         return $productsVisited;
  103.     }
  104. }