src/Services/CartService.php line 87

Open in your IDE?
  1. <?php
  3. namespace App\Services;
  5. use App\Entity\Cart;
  6. use App\Entity\CartProduct;
  7. use App\Entity\CartProductEquipment;
  8. use App\Entity\CartProductParameterValue;
  9. use App\Entity\Currency;
  10. use App\Entity\Language;
  11. use App\Entity\Product;
  12. use App\Entity\ProductEquipment;
  13. use App\Entity\ProductLangParam;
  14. use App\Entity\ProductParameterValue;
  15. use App\Entity\ProductPriceVariants;
  16. use App\Entity\RebateCode;
  17. use App\Entity\SubProduct;
  18. use App\Repository\CartRepository;
  19. use App\Repository\DeliveryCountryRepository;
  20. use App\Repository\DeliveryMethodRepository;
  21. use App\Repository\PaymentMethodRepository;
  22. use App\Exception\CartException;
  23. use Doctrine\Common\Collections\ArrayCollection;
  24. use Doctrine\ORM\EntityManagerInterface;
  25. use Symfony\Component\HttpFoundation\JsonResponse;
  26. use Symfony\Component\HttpFoundation\Request;
  27. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  28. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorage;
  29. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  30. use Symfony\Contracts\Translation\TranslatorInterface;
  32. class CartService
  33. {
  34.     private $em;
  35.     private $translator;
  36.     private $cartRepository;
  37.     private $tokenStorage;
  38.     private $session;
  39.     private $deliveryCountryRepository;
  40.     private $productManager;
  42.     /**
  43.      * CartService constructor.
  44.      * @param EntityManagerInterface $em
  45.      * @param TranslatorInterface $translator
  46.      * @param CartRepository $cartRepository
  47.      */
  48.     public function __construct(PaymentMethodRepository $paymentMethodRepository, DeliveryMethodRepository $deliveryMethodRepository, DeliveryCountryRepository $deliveryCountryRepository, EntityManagerInterface $em, TranslatorInterface $translator, CartRepository $cartRepository, TokenStorageInterface $tokenStorage, SessionInterface $session, ProductManager $productManager) {
  49.         $this->em = $em;
  50.         $this->translator = $translator;
  51.         $this->deliveryCountryRepository = $deliveryCountryRepository;
  52.         $this->cartRepository = $cartRepository;
  53.         $this->tokenStorage = $tokenStorage;
  54.         $this->session = $session;
  55.         $this->deliveryMethodRepository = $deliveryMethodRepository;
  56.         $this->paymentMethodRepository = $paymentMethodRepository;
  57.         $this->productManager = $productManager;
  58.     }
  60.     /**
  61.      * Get cart session
  62.      * @return mixed
  63.      */
  64.     public function getCartSession() {
  65.         return $this->session->get('cart_session');
  66.     }
  68.     /**
  69.      * @return string locale
  70.      */
  71.     public function getLocale() {
  72.         return $this->session->get('_locale');
  73.     }
  75.     /**
  76.      * @return Currency
  77.      */
  78.     public function getCurrency() {
  79.         return $this->session->get('currency');
  80.     }
  82.     /**
  83.      * @return Cart
  84.      * @throws CartException
  85.      */
  86.     public function getCart() {
  87.         $cart = $this->em->getRepository(Cart::class)->findOneBy(['session'=>$this->session->get('cart_session')]);
  88.         if ($cart instanceof Cart) {
  89.             return $cart;
  90.         }
  91.         $create = $this->getOrCreateCart();
  92.         if ($create instanceof Cart) {
  93.             return $create;
  94.         }
  95.         throw new CartException("Cart did not found");
  96.     }
  98.     /**
  99.      * * Get Sum of products in the cart
  100.      * @param bool $withRebate - whether with rebate code (RebateCode entity) or not
  101.      * @return array
  102.      */
  103.     public function getSum($withRebate = false, $withVat = true) {
  104.         $sum = 0;
  106.         $rebate = ($withRebate && is_object($this->getCart()->getRebateCode()) && $this->getCart()->getRebateCode()->getCodeType() == RebateCode::CODE_TYPE_PERCENT) ? true : false;
  108.         /** @var $cart CartProduct */
  109.         foreach ($this->getCartProducts() as $cart) {
  110.             $sum = $sum + ($this->calculateProductSinglePrice($cart, $rebate, $withVat) * $cart->getQuantity());
  111.         }
  113.         if ($withRebate and is_object($this->getCart()->getRebateCode()) and $this->getCart()->getRebateCode()->getCodeType() == RebateCode::CODE_TYPE_AMOUNT and $this->getCart()->isCartApplicableForAmountDiscount()) {
  114.             $sum = $sum - $this->getCart()->getRebateCode()->getPrice();
  115.         }
  117.         if ($sum < 0) {
  118.             $sum = 0;
  119.         }
  121.         return ['sum'=>$sum, 'currency'=>$this->getCurrency()];
  122.     }
  124.     public function getSumWithVat(Cart $cart) {
  125.         $sum = 0;
  127.         /** @var $cartProduct CartProduct */
  128.         foreach ($cart->getProducts() as $cartProduct) {
  129.             $price = $cartProduct->getProduct()->getPrice($cartProduct->getCurrency(), $cartProduct->getVat());
  130.             $sum = $sum + ($cartProduct->getQuantity() * $price['price']);
  131.         }
  133.         return $sum;
  134.     }
  136.     /**
  137.      * Calculate price of single record product from cart
  138.      *
  139.      * @param CartProduct $cartProduct
  140.      * @param bool $withRebate
  141.      * @return mixed
  142.      * @throws CartException
  143.      */
  144.     public function calculateProductSinglePrice(CartProduct $cartProduct, $withRebate = false, $withVat = true) {
  145.         $currencyDefault = $this->em->getRepository(Currency::class)->findOneBy(['isDefault'=>true, 'deletedBy'=>false]);
  146.         $currency = $this->session->get('currency', $currencyDefault);
  148.         //brutto!
  149.         if ($withVat) {
  150.             if ($cartProduct->getCart()->getLanguage()->getLocaleShort() == 'ro') {
  151.                 $params = $cartProduct->getProduct()->getLangParams();
  152.                 foreach ($params as $param) {
  153.                     if ($param->getLanguage()->getLocaleShort() == 'ro') {
  154.                         $vat = $param->getVat();
  155.                         $vatRate = ($vat->getValue()+100)/100;
  156.                         if ($withRebate === false) {
  157.                             return $cartProduct->getPriceNet() * $vatRate;
  158.                         } else {
  159.                             $rebateCode = $this->getCart()->getRebateCode();
  160.                             if ($rebateCode && $rebateCode->getCodeType() == RebateCode::CODE_TYPE_PERCENT && $this->getCart()->isProductApplicableForRebate($cartProduct->getProduct())) {
  161.                                 $discount = $cartProduct->getPriceNet() * $vatRate * ($rebateCode->getPercent() / 100);
  162.                                 return $cartProduct->getPriceNet() * $vatRate - $discount;
  163.                             } else {
  164.                                 return $cartProduct->getPriceNet() * $vatRate;
  165.                             }
  166.                         }
  167.                     }
  168.                 }
  170.             }
  171.             $price['price'] = $cartProduct->getPrice();
  172.         }
  174.         if (!isset($price['price'])) {
  175.             throw new CartException('Price of product not found');
  176.         }
  178.         if (is_object($this->getCart()->getRebateCode()) and $cartProduct->getSubProduct() == null and $this->getCart()->isProductApplicableForRebate($cartProduct->getProduct()) and $withRebate) {
  180.             /** @var $rebateCode RebateCode */
  181.             $rebateCode = $this->getCart()->getRebateCode();
  182.             if ($rebateCode->getCodeType() == RebateCode::CODE_TYPE_PERCENT) {
  183.                 $priceForDiscount = $cartProduct->getProduct()->getPrice($currency, $cartProduct->getVat());
  184.                 $priceForDiscount['price'] = $cartProduct->getPrice();
  185.                 $discount = $priceForDiscount['price'] * ($rebateCode->getPercent() / 100);
  186.                 $newVatPrice = $priceForDiscount['price'] - $discount;
  187.                 return $newVatPrice;
  188.                 //$vatRate = ($cartProduct->getVat()->getValue()+100)/100;
  189.                 //return round($newVatPrice/$vatRate,2);
  190.             } else {
  191.                 return $price['price'];
  192.             }
  193.         } else {
  194.             return $price['price'];
  195.         }
  196.     }
  198.     /**
  199.      * Dynamically calculate total cost with shipping when user change delivery and payment method
  200.      *
  201.      * @param null $deliveryMethodId
  202.      * @param null $paymentMethodId
  203.      * @return array
  204.      */
  205.     public function ajaxCalculateSum($deliveryMethodId = null, $paymentMethodId = null) {
  206.         $calculate = $this->getSum(false, true);
  207.         $calculateWithRebate = $this->getSum($withRebate = true, true);
  208.         //dump($calculateWithRebate);
  209.         //dump($calculate);
  210.         //exit();
  211.         $cartSum = $calculateWithRebate['sum'];
  213.         $sum = $calculate['sum'];
  214.         $sumWithRebate = $calculateWithRebate['sum'];
  215.         if ($deliveryMethodId) {
  216.             $deliveryPrice = $this->deliveryMethodRepository->getPrice($deliveryMethodId, $this->getCurrency());
  217.             $sum = $sum + $deliveryPrice;
  218.             $sumWithRebate = $sumWithRebate + $deliveryPrice;
  219.         }
  220.         if ($paymentMethodId) {
  221.             $paymentPrice = $this->paymentMethodRepository->getPrice($paymentMethodId, $this->getCurrency());
  222.             $sum = $sum + $paymentPrice;
  223.             $sumWithRebate = $sumWithRebate + $paymentPrice;
  224.         }
  226.         $shippingCost = $sumWithRebate - $cartSum;
  228.         if ($this->getCurrency()->getId() == 4) {
  229.             //return ['savings'=>$sumWithRebate-$sum, 'sum'=>(int)$sum, 'sumWithRebate'=>(int)$sumWithRebate, 'shippingCost'=>(int)$shippingCost];
  230.         }
  232.         return ['savings'=>$sumWithRebate-$sum, 'sum'=>$sum, 'sumWithRebate'=>$sumWithRebate, 'shippingCost'=>$shippingCost];
  233.     }
  235.     /**
  236.      * Todo - dorobić tutaj sprawdzanie czy produkt jest widoczny dla danej wersji językowej
  237.      * @return ArrayCollection
  238.      * @throws CartException
  239.      */
  240.     public function getCartProducts() {
  241.         $collection = new ArrayCollection();
  242.         /** @var $cart CartProduct */
  243.         foreach ($this->getCart()->getProducts() as $cart) {
  244.             /** @var $langParamEntity ProductLangParam */
  245.             $langParamEntity = $this->em->getRepository(ProductLangParam::class)->findOneBy(['language'=>$cart->getCart()->getLanguage(), 'product'=>$cart->getProduct()]);
  246.             if ($langParamEntity->getVisible()) {
  247.                 $collection->add($cart);
  248.             }
  249.         }
  250.         return $collection;
  251.     }
  253.     /**
  254.      * Simple counter of products in cart
  255.      *
  256.      * @return int
  257.      * @throws CartException
  258.      */
  259.     public function countProducts() {
  260.         $count = 0;
  261.         foreach ($this->getCartProducts() as $cartProduct) {
  262.             $count = $count+$cartProduct->getQuantity();
  263.         }
  264.         return $count;
  265.     }
  267.     /**
  268.      * Recalculate cart (when currency changed for example)
  269.      */
  270.     public function cartRecalculate(Language $language) {
  271.         /** @var $cart CartProduct */
  272.         foreach ($this->getCartProducts() as $cart) {
  273.             $priceData = ['price'=>$this->productManager->getPrice($cart->getProduct(), $language, $cart->getVariant(), $cart), 'currency'=>$language->getCurrency()];
  274.             if ($cart->getSubProduct()) {
  275.                 $priceData['price'] = $cart->getSubProduct()->getPrice();
  276.             }
  277.             if (isset($priceData['price'])) {
  278.                 $cart->setPrice($priceData['price']);
  279.                 $cart->setCurrency($priceData['currency']);
  280.             }
  281.             $this->em->persist($cart);
  282.         }
  283.         $this->em->flush();
  284.     }
  286.     /**
  287.      * * Check if record with given parameter, product and session exists
  288.      * @param Request $request
  289.      * @return \App\Entity\CartProduct|bool|null|object
  290.      */
  291.     public function checkDoubleRecord(Request $request) {
  292.         $record = $this->em->getRepository(CartProduct::class)->findOneBy([
  293.             'session' => $this->session->get('cart_session'),
  294.             'product' => $this->getProductEntity($request->request->get('product_id')),
  295.             'subProduct' => $request->request->get('sub'),
  296.             'code' => $this->recordCode($request->request->get('parameters'), $request->request->get('product_id'), $request->request->get('equipments')),
  297.         ]);
  298.         if (is_object($record)) {
  299.             return $record;
  300.         }
  301.         return false;
  302.     }
  304.     /**
  305.      * @param $variant
  306.      * @return null|ProductPriceVariants
  307.      */
  308.     public function getVariantEntity($variant) {
  309.         if ($variant) {
  310.             return $this->em->getRepository(ProductPriceVariants::class)->find($variant);
  311.         }
  312.         return null;
  313.     }
  315.     /**
  316.      * @return \App\Entity\Currency|null|object
  317.      */
  318.     public function getDefaultCurrency() {
  319.         return $this->em->getRepository(Currency::class)->findOneBy(['isDefault'=>true, 'deletedBy'=>null]);
  320.     }
  322.     /**
  323.      * @param $id
  324.      * @return \App\Entity\Product|null
  325.      */
  326.     public function getProductEntity($id) {
  327.         return $this->em->getRepository(Product::class)->findOneBy(['id'=>$id, 'deletedBy'=>null]);
  328.     }
  330.     public function removeInvisible(Cart $cart) {
  331.         /** @var $cartProduct CartProduct */
  332.         foreach ($cart->getProducts() as $cartProduct) {
  333.             $langParamEntity = $this->em->getRepository(ProductLangParam::class)->findOneBy(['language'=>$cart->getLanguage(), 'product'=>$cartProduct->getProduct()]);
  334.             if (!$langParamEntity->getVisible()) {
  335.                 foreach ($cartProduct->getEquipments() as $equipment) {
  336.                     $this->em->remove($equipment);
  337.                 }
  338.                 foreach ($cartProduct->getParameterValues() as $parameterValue) {
  339.                     $this->em->remove($parameterValue);
  340.                 }
  341.                 $this->em->remove($cartProduct);
  342.             }
  343.         }
  345.         if ($cart->getRebateCode() && $cart->getRebateCode()->getValidTo()) {
  346.             $now = new \DateTime();
  347.             $validTo = $cart->getRebateCode()->getValidTo();
  348.             if ($validTo->getTimestamp() > $now->getTimestamp()) {
  349.                 #OK!
  350.             } else {
  351.                 $cart->setRebateCode(null);
  352.                 $cart->setRebateCodeContent(null);
  353.                 $this->em->persist($cart);
  354.                 $this->em->flush();
  355.             }
  357.         }
  358.         $this->em->flush();
  359.     }
  361.     /**
  362.      * @return Cart
  363.      */
  364.     public function getOrCreateCart() {
  365.         $cart = $this->em->getRepository(Cart::class)->findOneBy(['session'=>$this->session->get('cart_session')]);
  366.         if (is_object($cart)) {
  367.             return $cart;
  368.         }
  369.         return $this->create();
  370.     }
  372.     public function recordCode($parameters, $productId, $equipments = null) {
  373.         if (!is_array($parameters) && $equipments === null) {
  374.             return md5($productId);
  375.         }
  376.         $code = $productId;
  377.         if (!$parameters && !$equipments) {
  378.             $code = md5($productId);
  379.         } else {
  380.             $string = '';
  381.             if (is_array($parameters)) {
  382.                 foreach ($parameters as $parameter) {
  383.                     $string .= $string.$parameter['value'];
  384.                 }
  385.                 $code = md5($string);
  386.             }
  387.         }
  388.         if ($equipments && is_array($equipments)) {
  389.             foreach ($equipments as $equipment) {
  390.                 $code = 'eq'.$code.$equipment;
  391.             }
  392.         }
  393.         return $code;
  394.     }
  396.     public function updateQuantityCart(Request $request) {
  397.         $product = $this->getProductEntity($request->request->get('product_id'));
  398.         /** @var $record CartProduct */
  399.         $record = $this->em->getRepository(CartProduct::class)->findOneBy(
  400.             [
  401.                 'id'=>$request->request->get('record_id'),
  402.                 'product'=>$product,
  403.                 'session' => $this->session->get('cart_session'),
  404.             ]
  405.         );
  406.         if ($record) {
  407.             $record->setQuantity($request->request->get('quantity'));
  408.             $this->em->persist($record);
  409.             $this->em->flush();
  410.         }
  411.         return new JsonResponse(['message'=>'success']);
  412.     }
  414.     public function isSubProductInCart(Request $request) {
  415.         $product = $this->getProductEntity($request->request->get('product_id'));
  416.         /** @var $record CartProduct */
  417.         $record = $this->em->getRepository(CartProduct::class)->findOneBy(
  418.             [
  419.                 'id'=>$request->request->get('record_id'),
  420.                 'product'=>$product,
  421.                 'session' => $this->session->get('cart_session'),
  422.             ]
  423.         );
  424.         if ($record->getSubProduct()) {
  425.             return true;
  426.         }
  427.         return false;
  428.     }
  430.     public function removeFromCart(Request $request) {
  431.         $product = $this->getProductEntity($request->request->get('product_id'));
  432.         $record = $this->em->getRepository(CartProduct::class)->findOneBy(
  433.             [
  434.                 'id'=>$request->request->get('record_id'),
  435.                 'product'=>$product,
  436.                 'session' => $this->session->get('cart_session'),
  437.             ]
  438.         );
  439.         if ($record) {
  440.             $this->em->remove($record);
  441.             $this->em->flush();
  442.         }
  443.         return new JsonResponse(['message'=>'success']);
  444.     }
  446.     public function isMaxQuantityExceeded(Product $product, $quantity) {
  447.         if (!$product->getMaxQuantity()) {
  448.             return false;
  449.         }
  450.         return $quantity > $product->getMaxQuantity();
  451.     }
  453.     private function subProductAddedNotification(SubProduct $product) {
  455.         $html = 'Dodano do koszyka produkt "Kup taniej": '.$product->getName();
  457.         $content = [
  458.             'fromField'=>['fromFieldId'=>'f'],
  459.             'subject'=>'Dodano do koszyka produkt z sekcji "Kup taniej"',
  460.             'content'=>['html'=>$html, 'plain'=>$html],
  461.             'recipients'=>['to'=>['email'=>'marketing@centrumkrzesel.pl']],
  462.         ];
  464.         $body = json_encode($content);
  466.         $ch = curl_init();
  468.         curl_setopt($ch, CURLOPT_URL, "https://api3.getresponse360.pl/v3/transactional-emails");
  469.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  470.         curl_setopt($ch, CURLOPT_POSTFIELDS, $body);
  471.         curl_setopt($ch, CURLOPT_POST, 1);
  473.         $headers = array();
  474.         $headers[] = "Content-Type: application/json";
  475.         $headers[] = "X-Auth-Token: api-key gs478s9uv59n5ekulmpmgn5p0uqpepbn";
  476.         $headers[] = "X-Domain: centrumkrzesel.com";
  477.         curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
  479.         $result = curl_exec($ch);
  480.         curl_close ($ch);
  481.         return $result;
  482.     }
  484.     private function getUserDetails(Request $request): array
  485.     {
  486.         // Get the user's IP address
  487.         $userIp = $request->getClientIp();
  489.         // Get the user's browser information
  490.         $browserInfo = $request->headers->get('User-Agent');
  492.         // Return the details as an array
  493.         return [
  494.             'ip' => $userIp,
  495.             'browser' => $browserInfo,
  496.         ];
  497.     }
  499.     /**
  500.      * @param Request $request
  501.      * @return CartProduct|bool|null|object
  502.      * @throws CartException
  503.      * @throws \Doctrine\ORM\ORMException
  504.      */
  505.     public function addToCart(Request $request) {
  506.         $product = $this->getProductEntity($request->request->get('product_id'));
  507.         $variant = $request->request->get('variant');
  509.         $code = $this->recordCode($request->request->get('parameters'), $request->request->get('product_id'), $request->request->get('equipments'));
  511.         /** @var $language Language */
  512.         $language = $this->em->getRepository(Language::class)->findOneBy(['deletedBy'=>null, 'locale'=>$request->getLocale()]);
  514.         /** @var $langParam ProductLangParam */
  515.         $langParam = $this->em->getRepository(ProductLangParam::class)->findOneBy(['product'=>$product, 'language'=>$language]);
  517.         $cart = $this->getOrCreateCart();
  518.         $this->em->persist($cart);
  520.         $sub = null;
  521.         if ($request->request->get('sub')) {
  522.             /** @var $sub SubProduct */
  523.             $sub = $this->em->getRepository(SubProduct::class)->find($request->request->get('sub'));
  524.             $sub->setActive(false);
  525.             $sub->setAddToCartTime(new \DateTime());
  526.             $this->em->persist($sub);
  527.             $this->subProductAddedNotification($sub);
  528.             $priceData['price'] = $sub->getPrice();
  529.             $priceData['currency'] = $language->getCurrency();
  530.         } else {
  531.             $priceData = ['price'=>$this->productManager->getPrice($product, $language, $variant), 'currency'=>$language->getCurrency()];
  532.         }
  534.         if (isset($priceData['price'])) {
  535.             $productPrice = $priceData['price'];
  537.             $double = $this->checkDoubleRecord($request);
  539.             $quantity = $request->request->get('quantity');
  540.             if (!is_numeric($quantity)) {
  541.                 $quantity = 1;
  542.             }
  544.             if (!$this->session->get('cart_session')) {
  545.                 $data = serialize($request->request->all());
  546.                 throw new CartException("Brak sesji - odśwież przeglądarkę: ".$data.' DATA: '.serialize($this->getUserDetails($request)));
  547.             }
  549.             $cartRecord = (is_object($double)) ? $double : new CartProduct();
  550.             $cartRecord->setProduct($product);
  551.             if ($variant) {
  552.                 $cartRecord->setVariant($this->getVariantEntity($variant));
  554.                 $net = $cartRecord->getVariant()->getProductPrice()->getPrice();
  556.                 if ($request->request->get('equipments')) {
  557.                     foreach ($request->request->get('equipments') as $equipmentId) {
  558.                         /** @var $equipmentEntity ProductEquipment */
  559.                         $equipmentEntity = $this->em->getReference(ProductEquipment::class, $equipmentId);
  560.                         $net = $net + $equipmentEntity->getPriceNet();
  561.                     }
  562.                 }
  564.                 $cartRecord->setPriceNet($net);
  565.             } else {
  566.                 $net = $this->productManager->getPriceNet($product, $language);
  567.                 if ($request->request->get('equipments')) {
  568.                     foreach ($request->request->get('equipments') as $equipmentId) {
  569.                         /** @var $equipmentEntity ProductEquipment */
  570.                         $equipmentEntity = $this->em->getReference(ProductEquipment::class, $equipmentId);
  571.                         $net = $net + $equipmentEntity->getPriceNet();
  572.                     }
  573.                 }
  574.                 $cartRecord->setPriceNet($net);
  575.             }
  576.             $cartRecord->setCart($cart);
  577.             $cartRecord->setCode($code);
  578.             $cartRecord->setSubProduct($sub);
  579.             $cartRecord->setVat($langParam->getVat());
  580.             $cartRecord->setSession($this->session->get('cart_session'));
  581.             $cartRecord->setPrice($productPrice);
  582.             $cartRecord->setCurrency($priceData['currency']);
  583.             if ($sub) {
  584.                 $cartRecord->setQuantity(1);
  585.             } else {
  586.                 if (!$this->isMaxQuantityExceeded($product, $cartRecord->getQuantity() + $quantity)) {
  587.                     $cartRecord->setQuantity($cartRecord->getQuantity() + $quantity);
  588.                 }
  589.             }
  590.             $cartRecord->setPriceInitial($productPrice);
  591.             if (!is_object($double) and $request->request->get('parameters') and $sub === null) {
  592.                 foreach ($request->request->get('parameters') as $parameter) {
  593.                     $valueEntity = $this->em->getReference(ProductParameterValue::class, $parameter['value']);
  594.                     $parameterEntity = $valueEntity->getParameter();
  595.                     $value = new CartProductParameterValue();
  596.                     $checkDouble = $this->em->getRepository(CartProductParameterValue::class)->findOneBy(['cartProduct'=>$cartRecord, 'parameter'=>$parameterEntity, 'parameterValue'=>$valueEntity]);
  597.                     if (!is_object($checkDouble)) {
  598.                         $value->setCartProduct($cartRecord);
  599.                         $value->setParameterValue($valueEntity);
  600.                         $value->setParameter($parameterEntity);
  601.                         $this->em->persist($value);
  602.                     }
  603.                 }
  604.             }
  606.             if (!is_object($double) and $request->request->get('equipments')) {
  607.                 foreach ($request->request->get('equipments') as $equipmentId) {
  608.                     $equipmentEntity = $this->em->getReference(ProductEquipment::class, $equipmentId);
  609.                     $newEquipment = new CartProductEquipment();
  610.                     $newEquipment->setQuantity(1);
  611.                     $newEquipment->setEquipment($equipmentEntity);
  612.                     $newEquipment->setProduct($cartRecord->getProduct());
  613.                     $newEquipment->setCartProduct($cartRecord);
  614.                     $newEquipment->setSession($this->session->get('cart_session'));
  615.                     $newEquipment->setPrice($equipmentEntity->getPrice());
  616.                     $this->em->persist($newEquipment);
  617.                 }
  618.             }
  620.             $this->em->persist($cartRecord);
  621.             $this->em->flush();
  623.             $this->cartRecalculate($language);
  625.             return $cartRecord;
  627.         } else {
  628.             throw new CartException("Product price not found");
  629.         }
  630.     }
  632.     /**
  633.      * @return Cart
  634.      * @throws CartException
  635.      */
  636.     public function create() {
  637.         $cart = new Cart();
  638.         $cart->setSession($this->session->get('cart_session'));
  639.         /** @var $language Language */
  640.         $language = $this->em->getRepository(Language::class)->findOneBy(['locale'=>$this->session->get('_locale'), 'deletedBy'=>null]);
  641.         if (!is_object($language)) {
  642.             throw new CartException("Language session not found in cart");
  643.         }
  644.         $cart->setIp($_SERVER['REMOTE_ADDR']);
  645.         $cart->setLanguage($language);
  646.         $cart->setUserAgent($_SERVER['HTTP_USER_AGENT']);
  647.         return $cart;
  648.     }
  650.     /**
  651.      * @param $session
  652.      */
  653.     public function delete($session) {
  654.         $cart = $this->getRepository()->find($session);
  655.         $this->em->remove($cart);
  656.         $this->em->flush();
  657.     }
  659.     /**
  660.      * @return CartRepository
  661.      */
  662.     public function getRepository() {
  663.         return $this->cartRepository;
  664.     }
  666.     /**
  667.      * Discard rebate code - set to null in cart
  668.      */
  669.     public function discardRebateCode() {
  670.         $cart = $this->getCart();
  671.         $cart->setRebateCodeContent('');
  672.         $rebateCode = $this->getCart()->getRebateCode();
  673.         if (!is_object($rebateCode)) {
  674.             return;
  675.         }
  676.         if ($rebateCode->getMultiple() !== true) {
  677.             $rebateCode->setUsed(false);
  678.             $this->em->persist($rebateCode);
  679.         }
  680.         $cart->setRebateCode(null);
  681.         $this->em->persist($cart);
  682.         $this->em->flush();
  683.     }
  685.     /**
  686.      * @param $countryId
  687.      * @param $deliveryId
  688.      * @param $paymentId
  689.      * @return Cart
  690.      * @throws CartException
  691.      */
  692.     public function prepareToCheckout($deliveryId, $paymentId) {
  693.         $deliveryMethod = $this->deliveryMethodRepository->getRepository()->find($deliveryId);
  694.         $paymentMethod = $this->paymentMethodRepository->getRepository()->find($paymentId);
  696.         if (!is_object($deliveryMethod) or !is_object($paymentMethod)) {
  697.             throw new CartException("Delivery, Payment or Country not an object");
  698.         }
  700.         $cart = $this->getCart();
  701.         $cart->setDeliveryMethod($deliveryMethod);
  702.         $cart->setPaymentMethod($paymentMethod);
  703.         $this->em->persist($cart);
  704.         $this->em->flush();
  705.         return $cart;
  706.     }
  708.     public function getSpecialDeliveryMethodsIds(Cart $cart) {
  709.         $special = [];
  710.         /** @var $cartProduct CartProduct */
  711.         foreach ($cart->getProducts() as $cartProduct) {
  712.             $product = $cartProduct->getProduct();
  713.             foreach ($product->getSpecialDeliveryMethods() as $deliveryMethod) {
  714.                 if (!in_array($deliveryMethod->getId(), $special)) {
  715.                     $special[] = $deliveryMethod->getId();
  716.                 }
  717.             }
  718.         }
  719.         return $special;
  720.     }
  722.     public function getCrossSellingProducts(Cart $cart) {
  724.         $crossSell = new ArrayCollection();
  726.         /** @var $cartProduct CartProduct */
  727.         foreach ($this->getCartProducts() as $cartProduct) {
  728.             $product = $cartProduct->getProduct();
  729.             $crossSelling = $product->getCrossSelling();
  730.             foreach ($crossSelling as $crossSellingRow) {
  731.                 if ($crossSellingRow->getDeletedBy()) {
  732.                     continue;
  733.                 }
  734.                 if ($crossSellingRow->getCrossSellingProduct()->getDeletedBy()) {
  735.                     continue;
  736.                 }
  738.                 $langParamEntity = $this->em->getRepository(ProductLangParam::class)->findOneBy(['language'=>$cart->getLanguage(), 'product'=>$crossSellingRow->getCrossSellingProduct()]);
  739.                 if ($langParamEntity and $langParamEntity->getVisible()) {
  740.                     $crossSell->add($crossSellingRow->getCrossSellingProduct());
  741.                 }
  742.             }
  743.         }
  744.         return $crossSell;
  745.     }
  747. }