vendor/store.shopware.com/coewishlistsw6/src/Storefront/Controller/WishlistController.php line 102

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace CoeWishlistSw6\Storefront\Controller;
  5. use App\Product;
  6. use CoeWishlistSw6\Core\Content\Wishlist\Service\WishlistPriceQuantityService;
  7. use CoeWishlistSw6\Core\Content\Wishlist\Service\WishlistPriceQuantityServiceInterface;
  8. use CoeWishlistSw6\Core\Content\Wishlist\Service\WishlistService;
  9. use CoeWishlistSw6\Core\Content\Wishlist\Service\WishlistServiceInterface;
  10. use CoeWishlistSw6\Core\Content\Wishlist\WishlistCollection;
  11. use CoeWishlistSw6\Core\Content\Wishlist\WishlistEntity;
  12. use CoeWishlistSw6\Core\Content\Wishlist\Aggregate\WishlistNoteEntity;
  13. use CoeWishlistSw6\Storefront\Page\Wishlist\WishlistPage;
  14. use CoeWishlistSw6\Storefront\Page\Wishlist\WishlistPageLoader;
  15. use http\Exception\InvalidArgumentException;
  16. use Shopware\Core\Content\Product\Exception\ProductNotFoundException;
  17. use Shopware\Core\Content\Product\ProductCollection;
  18. use Shopware\Core\Content\Product\ProductEntity;
  19. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  20. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  21. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  22. use Shopware\Core\Framework\Routing\Exception\MissingRequestParameterException;
  23. use Shopware\Core\Framework\Validation\DataBag\RequestDataBag;
  24. use Shopware\Core\System\SalesChannel\Entity\SalesChannelRepositoryInterface;
  25. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  26. use Shopware\Storefront\Controller\StorefrontController;
  27. use Symfony\Component\HttpFoundation\JsonResponse;
  28. use Symfony\Component\HttpFoundation\RedirectResponse;
  29. use Symfony\Component\HttpFoundation\Response;
  30. use Symfony\Component\HttpFoundation\Request;
  31. use Symfony\Component\Routing\Annotation\Route;
  32. use Shopware\Core\Framework\Routing\Annotation\RouteScope;
  34. /**
  35.  * Class WishlistController
  36.  * @package CoeWishlistSw6\Storefront\Controller
  37.  * @author Jeffry Block <jeffry.block@codeenterprise.de>
  38.  */
  39. class WishlistController extends StorefrontController
  40. {
  41.     /**
  42.      * @var WishlistPageLoader
  43.      */
  44.     private $wishlistPageLoader;
  46.     /**
  47.      * @var WishlistServiceInterface
  48.      */
  49.     private $wishlistService;
  51.     /**
  52.      * @var EntityRepositoryInterface
  53.      */
  54.     private $wishlistRepository;
  56.     /**
  57.      * @var WishlistPriceQuantityServiceInterface
  58.      */
  59.     private $wishlistPriceQuantityService;
  61.     /**
  62.      * @var SalesChannelRepositoryInterface
  63.      */
  64.     private SalesChannelRepositoryInterface $productRepository;
  66.     /**
  67.      * WishlistController constructor.
  68.      * @param WishlistPageLoader $wishlistPageLoader
  69.      * @param WishlistServiceInterface $wishlistService
  70.      * @param EntityRepositoryInterface $wishlistRepository
  71.      * @param WishlistPriceQuantityServiceInterface $wishlistPriceQuantityService
  72.      * @param SalesChannelRepositoryInterface $productRepository
  73.      */
  74.     public function __construct(
  75.         WishlistPageLoader $wishlistPageLoader,
  76.         WishlistServiceInterface $wishlistService,
  77.         EntityRepositoryInterface $wishlistRepository,
  78.         WishlistPriceQuantityServiceInterface $wishlistPriceQuantityService,
  79.         SalesChannelRepositoryInterface $productRepository
  80.     ) {
  81.         $this->wishlistPageLoader = $wishlistPageLoader;
  82.         $this->wishlistService = $wishlistService;
  83.         $this->wishlistRepository = $wishlistRepository;
  84.         $this->wishlistPriceQuantityService = $wishlistPriceQuantityService;
  85.         $this->productRepository = $productRepository;
  86.     }
  88.     /**
  89.      * @RouteScope(scopes={"storefront"})
  90.      * @Route("/note", name="frontend.wishlist.page", methods={"GET"}, options={"seo"="false"})
  91.      * @Route("/note/{listId}", name="frontend.wishlist.page", methods={"GET"}, options={"seo"="false"}, requirements={"listId"=".{32}"}, defaults={"listId"=null})
  92.      * @param string|null $listId
  93.      * @param Request $request
  94.      * @param SalesChannelContext $context
  95.      * @return \Symfony\Component\HttpFoundation\Response
  96.      * @throws MissingRequestParameterException
  97.      * @throws \Shopware\Core\Content\Category\Exception\CategoryNotFoundException
  98.      * @throws \Shopware\Core\Framework\DataAbstractionLayer\Exception\InconsistentCriteriaIdsException
  99.      * @author Jeffry Block <jeffry.block@codeenterprise.de>
  100.      * @throws \Exception
  101.      */
  102.     public function index(?string $listId = null, Request $request, SalesChannelContext $context): Response
  103.     {
  104.         if ($listId) {
  105.             if (!$this->wishlistService->loadList($listId, $context->getContext())) {
  106.                 throw new \Exception(sprintf("Wishlist with ID %s does not exist", $listId));
  107.             }
  108.         }
  110.         try {
  111.             /** @var WishlistPage $page */
  112.             $page = $this->wishlistPageLoader->load($request, $context);
  113.         } catch (\Exception $e) {
  114.             $this->container->get("session")->getFlashBag()->add('warning', $e->getMessage());
  115.             $url = $this->container->get("router")->generate('frontend.wishlist.page');
  116.             return new RedirectResponse($url);
  117.         }
  119.         /** @var Response $response */
  120.         $response = $this->renderStorefront('@CoeWishlistSw6/storefront/page/wishlist/overview/index.html.twig', [
  121.             'page' => $page,
  122.         ]);
  123.         $response->headers->set("X-Robots", "noindex,nofollow");
  125.         return $response;
  126.     }
  128.     /**
  129.      * @RouteScope(scopes={"storefront"})
  130.      * @Route("/note/save/note", name="frontend.wishlist.save.note", methods={"POST"}, defaults={"XmlHttpRequest": true})
  131.      * @param RequestDataBag $dataBag
  132.      * @param Request $request
  133.      * @param SalesChannelContext $context
  134.      */
  135.     public function saveNote(RequestDataBag $dataBag, Request $request, SalesChannelContext $context): Response
  136.     {
  138.         /** @var string|null $sku */
  139.         $sku = $dataBag->get("sku");
  141.         // If parameter "useSKU" is set, get the product ID based on the SKU.
  142.         // Using SKU means, that the request came from the "add product manually"-form where users can enter the quantity
  143.         // manually as well. In this case we also need to make sure that the entered quantity is actually valid.
  144.         if ($sku) {
  145.             $criteria = new Criteria();
  146.             $criteria->addFilter(new EqualsFilter("productNumber", trim($sku)));
  147.             /** @var ProductCollection $products */
  148.             $products = $this->productRepository->search($criteria, $context);
  150.             if ($products->count() === 0) {
  151.                 throw new ProductNotFoundException($sku);
  152.             }
  153.             /** @var ProductEntity $product */
  154.             $product = $products->first();
  156.             /** @var int $quantity */
  157.             $quantity = $dataBag->getInt("quantity", 1);
  159.             if (!$this->wishlistService->isQuantityValidForProduct($product, $quantity)) {
  160.                 throw new \Exception(sprintf("Quantity %s not allowed for product %s", $quantity, $product->getProductNumber()));
  161.             }
  163.             $dataBag->set("productId", $product->getId());
  164.         }
  166.         /** @var string $productId */
  167.         $productId = $dataBag->get("productId");
  169.         if (!$productId) {
  170.             throw new MissingRequestParameterException('productId');
  171.         }
  173.         /** @var string $listId */
  174.         $listId = $dataBag->get("listId");
  176.         if ($dataBag->getBoolean("addNewList")) {
  177.             $listId = ($this -> wishlistService -> createList($dataBag, $context, ["notes","notes.product"]))->getId();
  178.         }
  180.         /** @var WishlistEntity $list */
  181.         $list = $this -> wishlistService -> loadList($listId, $context->getContext(), ["notes","notes.product"]);
  183.         if (!$list) {
  184.             throw new \Exception(sprintf("Wishlist with ID %s does not exist", $list));
  185.         }
  187.         /** @var WishlistNoteEntity $addedNote */
  188.         $addedNote = $this -> wishlistService -> addNote($dataBag, $list, $context);
  190.         return new JsonResponse([
  191.             "success" => true,
  192.             "data" => [
  193.                 "noteId" => $addedNote->getId(),
  194.                 "listId" => $list->getId(),
  195.             ],
  196.         ], 200);
  197.     }
  199.     /**
  200.      * @RouteScope(scopes={"storefront"})
  201.      * @Route("/note/save/list", name="frontend.wishlist.save.list", methods={"POST"}, defaults={"XmlHttpRequest": true})
  202.      * @param RequestDataBag $dataBag
  203.      * @param Request $request
  204.      * @param SalesChannelContext $context
  205.      */
  206.     public function saveList(RequestDataBag $dataBag, Request $request, SalesChannelContext $context): Response
  207.     {
  208.         $listId = ($this -> wishlistService -> createList($dataBag, $context, ["notes","notes.product"]))->getId();
  210.         return new JsonResponse([
  211.             "success" => true,
  212.             "data" => [
  213.                 "listId" => $listId,
  214.             ],
  215.         ], 200);
  216.     }
  218.     /**
  219.      * @RouteScope(scopes={"storefront"})
  220.      * @Route("/note/save/list/visibility", name="frontend.wishlist.save.list.visiblity", methods={"POST"}, defaults={"XmlHttpRequest": true})
  221.      * @param RequestDataBag $dataBag
  222.      * @param Request $request
  223.      * @param SalesChannelContext $context
  224.      */
  225.     public function saveListVisibility(RequestDataBag $dataBag, Request $request, SalesChannelContext $context): Response
  226.     {
  227.         $listId = $dataBag->get("listId");
  228.         $visibility = $dataBag->getBoolean("public", false);
  230.         if (!$listId) {
  231.             throw new MissingRequestParameterException('listId');
  232.         }
  234.         if (!$this->wishlistService->listBelongsToCurrentUser($listId, $context)) {
  235.             throw new \Exception(sprintf("Access to resource with ID %s denied", $listId));
  236.         }
  238.         $this->wishlistRepository->update([[
  239.             "id" => $listId,
  240.             "public" => $visibility,
  241.         ]], $context->getContext());
  244.         return new JsonResponse([
  245.             "success" => true,
  246.             "data" => [
  247.                 "listId" => $listId,
  248.             ],
  249.         ], 200);
  250.     }
  252.     /**
  253.      * @RouteScope(scopes={"storefront"})
  254.      * @Route("/note/save/list/name", name="frontend.wishlist.save.list.name", methods={"POST"}, defaults={"XmlHttpRequest": true})
  255.      * @param RequestDataBag $dataBag
  256.      * @param Request $request
  257.      * @param SalesChannelContext $context
  258.      */
  259.     public function saveListName(RequestDataBag $dataBag, Request $request, SalesChannelContext $context): Response
  260.     {
  261.         $listId = $dataBag->get("listId");
  262.         $name = $dataBag->get("listName", "No Name");
  264.         if (!$listId) {
  265.             throw new MissingRequestParameterException('listId');
  266.         }
  268.         if (!$this->wishlistService->listBelongsToCurrentUser($listId, $context)) {
  269.             throw new \Exception(sprintf("Access to resource with ID %s denied", $listId));
  270.         }
  272.         $this->wishlistRepository->update([[
  273.             "id" => $listId,
  274.             "name" => $name,
  275.         ]], $context->getContext());
  278.         return new JsonResponse([
  279.             "success" => true,
  280.         ], 200);
  281.     }
  283.     /**
  284.      * @RouteScope(scopes={"storefront"})
  285.      * @Route("/note/save/note/quantity", name="frontend.wishlist.save.note.quantity", methods={"POST"}, defaults={"XmlHttpRequest": true})
  286.      * @param RequestDataBag $dataBag
  287.      * @param Request $request
  288.      * @param SalesChannelContext $context
  289.      */
  290.     public function saveNoteQuantity(RequestDataBag $dataBag, Request $request, SalesChannelContext $context): Response
  291.     {
  292.         $quantity = $dataBag->getInt("quantity");
  293.         if (!$quantity || $quantity === 0) {
  294.             throw new MissingRequestParameterException('quantity');
  295.         }
  297.         $noteId = $dataBag->get("noteId");
  298.         if (!$noteId) {
  299.             throw new MissingRequestParameterException('noteId');
  300.         }
  302.         $productId = $dataBag->get("productId");
  303.         if (!$productId) {
  304.             throw new MissingRequestParameterException('productId');
  305.         }
  307.         // Update the Quantity
  308.         // @todo check if the list of the note belongs to the user. Currently the note qty can be changed by everyone
  309.         $this->wishlistService->updateNoteQuantity($noteId, $quantity, $context->getContext());
  311.         try {
  312.             // When updating the quantity, the price per piece may have changed. Recalculate the price to show in storefront.
  313.             $quantityPrice = $this->wishlistPriceQuantityService->buildPrices($productId, $quantity, $context);
  315.             return new JsonResponse([
  316.                 "success" => true,
  317.                 "data" => [
  318.                     "noteId" => $noteId,
  319.                     "priceQty" => $this->wishlistPriceQuantityService->format($quantityPrice, $context),
  320.                     "priceSum" => $this->wishlistPriceQuantityService->format($quantity * $quantityPrice, $context),
  321.                     "qty" => $quantity,
  322.                 ],
  323.             ], 200);
  324.         } catch (\Exception $e) {
  325.             // If an exception occured during price calculation, just return null as data and reload the storefront
  326.             // instead of replacing the elemens dynamically.
  327.             return new JsonResponse([
  328.                 "success" => true,
  329.                 "data" => [
  330.                     "qty" => $quantity,
  331.                     "noteId" => $noteId,
  332.                 ],
  333.             ]);
  334.         }
  335.     }
  337.     /**
  338.      * @RouteScope(scopes={"storefront"})
  339.      * @Route("/note/count", name="frontend.wishlist.count.snippet", methods={"GET"}, defaults={"XmlHttpRequest": true})
  340.      * @param RequestDataBag $dataBag
  341.      * @param Request $request
  342.      * @param SalesChannelContext $context
  343.      */
  344.     public function getNoteCount(RequestDataBag $dataBag, Request $request, SalesChannelContext $context): Response
  345.     {
  347.         /** @var WishlistCollection $lists */
  348.         $lists = $this->wishlistService->loadLists($context, ["notes"]);
  350.         $counter = $lists->getAccumulatedNoteCount();
  351.         return new Response((string)$counter);
  352.     }
  354.     /**
  355.      * @RouteScope(scopes={"storefront"})
  356.      * @Route("/note/productids", name="frontend.wishlist.productids.snippet", methods={"GET"}, defaults={"XmlHttpRequest": true})
  357.      * @param RequestDataBag $dataBag
  358.      * @param Request $request
  359.      * @param SalesChannelContext $context
  360.      */
  361.     public function getNoteProductIds(RequestDataBag $dataBag, Request $request, SalesChannelContext $context): Response
  362.     {
  364.         /** @var WishlistCollection $lists */
  365.         $lists = $this->wishlistService->loadLists($context, ["notes","notes.product"]);
  367.         $numbers = $lists->getAllProductsIds();
  369.         return new JsonResponse($numbers);
  370.     }
  372.     /**
  373.      * @RouteScope(scopes={"storefront"})
  374.      * @Route("/note/delete/list", name="frontend.wishlist.delete.list", methods={"POST"}, defaults={"XmlHttpRequest": true})
  375.      * @param RequestDataBag $dataBag
  376.      * @param Request $request
  377.      * @param SalesChannelContext $context
  378.      */
  379.     public function deleteList(RequestDataBag $dataBag, Request $request, SalesChannelContext $context): Response
  380.     {
  381.         $listId = $dataBag->get("listId");
  382.         if (!$listId) {
  383.             throw new MissingRequestParameterException('listId');
  384.         }
  386.         if (!$this->wishlistService->listBelongsToCurrentUser($listId, $context)) {
  387.             throw new \Exception(sprintf("Access to resource with ID %s denied", $listId));
  388.         }
  390.         $this->wishlistService->deleteList($listId, $context->getContext());
  391.         if ($context->getCustomer()) {
  392.             $this->wishlistService->resetDefault($context->getCustomer()->getId(), $context->getContext());
  393.         }
  395.         return new JsonResponse([
  396.             "success" => true,
  397.             "data" => [
  398.                 "listId" => $listId,
  399.             ],
  400.         ], 200);
  401.     }
  403.     /**
  404.      * @RouteScope(scopes={"storefront"})
  405.      * @Route("/note/delete/note", name="frontend.wishlist.delete.note", methods={"POST"}, defaults={"XmlHttpRequest": true})
  406.      * @param RequestDataBag $dataBag
  407.      * @param Request $request
  408.      * @param SalesChannelContext $context
  409.      */
  410.     public function deleteNote(RequestDataBag $dataBag, Request $request, SalesChannelContext $context): Response
  411.     {
  412.         $noteId = $dataBag->get("noteId");
  413.         if (!$noteId) {
  414.             throw new MissingRequestParameterException('noteId');
  415.         }
  417.         // @todo check if the list of the note belongs to the user. Currently notes can be deleted by everyone
  418.         $this->wishlistService->deleteNote($noteId, $context->getContext());
  420.         return new JsonResponse([
  421.             "success" => true,
  422.             "data" => [
  423.                 "noteId" => $noteId,
  424.             ],
  425.         ], 200);
  426.     }
  430.     /**
  431.      * @RouteScope(scopes={"storefront"})
  432.      * @Route("/note/debug", name="frontend.wishlist.debug.page", methods={"GET"})
  433.      * @param Request $request
  434.      * @param SalesChannelContext $context
  435.      * @return \Symfony\Component\HttpFoundation\Response
  436.      */
  437.     public function debug(Request $request, SalesChannelContext $context)
  438.     {
  439.         return new JsonResponse("[]");
  440.     }
  441. }