src/Manager/CartManager.php line 318

Open in your IDE?
  1. <?php
  3. namespace App\Manager;
  5. use Doctrine\ORM\EntityManagerInterface;
  6. use App\Entity\Cart;
  7. use App\Service\Mailer;
  8. use App\Manager\CustomerManager;
  9. use App\Entity\Product;
  10. use App\Entity\Coupon;
  12. class CartManager {
  14. private $em;
  15. private $mailer;
  16. private $customerMgr;
  17. private $priceMgr;
  18. private $session;
  19. private $translator;
  21. public function __construct(\Symfony\Component\HttpFoundation\Session\SessionInterface $session, EntityManagerInterface $em, Mailer $mailer, CustomerManager $customerMgr, \Symfony\Contracts\Translation\TranslatorInterface $translator)
  22. {
  23. $this->em = $em;
  24. $this->mailer = $mailer;
  25. $this->customerMgr = $customerMgr;
  26. $this->session = $session;
  27. $this->translator = $translator;
  28. }
  30. public function getCustomer()
  31. {
  32. return $this->customerMgr->getCustomer();
  33. }
  35. public function isExpert()
  36. {
  37. return $this->customerMgr->isExpert();
  38. }
  40. public function getPriceContext()
  41. {
  42. return $this->customerMgr->getPriceContext();
  43. }
  45. public function getCartByCustomerId($cid)
  46. {
  47. $customer = $this->em->getRepository('App:Customer')->find($cid);
  48. if($customer){
  49. return $this->getCartByCustomer($customer);
  50. }
  51. return null;
  52. }
  54. public function getCartByCustomer($customer)
  55. {
  56. return $this->em->getRepository('App:Cart')->findOneByCustomer($customer);
  57. }
  59. public function remindCustomer(Cart $cart)
  60. {
  61. $this->markCartAsReminded($cart);
  62. return $this->mailer->remindCart($cart);
  63. }
  65. protected function markCartAsReminded(Cart $cart)
  66. {
  67. // $items = $cart->getItems();
  68. // if(!empty($items)){
  69. // foreach ($items as $item){
  70. // $item->setReminded(new \DateTime);
  71. // $this->em->persist($item);
  72. // }
  73. // $this->em->flush();
  74. // }
  75. return true;
  76. }
  78. public function getLastUnremindedCarts()
  79. {
  80. $carts = [];
  81. $customerIds = $this->getLastUnremindedCustomerIds();
  82. if(!empty($customerIds)){
  83. foreach ($customerIds as $cid){
  84. $cart = $this->getCartByCustomerId($cid);
  85. if($cart)
  86. $carts[] = $cart;
  87. }
  88. }
  89. return $carts;
  90. }
  92. public function getLastUnremindedCustomerIds() {
  93. $yesterday = new \DateTime();
  94. $yesterday->modify('-1 day');
  95. $conn = $this->em->getConnection();
  96. $stmt = $conn->prepare('SELECT distinct(customers_id) FROM customers_basket where customers_basket_reminded is null and `customers_basket_date_added`=\''.$yesterday->format('Ymd').'\'');
  97. $stmt->execute();
  98. $customerIds = [];
  99. $lines = $stmt->fetchAll();
  100. foreach($lines as $row){
  101. $customerIds[] = $row['customers_id'];
  102. }
  103. return $customerIds;
  104. }
  106. public function getLastCarts($sinceNbDays=180) {
  107. $yesterday = new \DateTime();
  108. $yesterday->modify('-'.$sinceNbDays.' day');
  109. $conn = $this->em->getConnection();
  110. $stmt = $conn->prepare('SELECT distinct(customers_id) FROM customers_basket where `customers_basket_date_added`>=\''.$yesterday->format('Ymd').'\'');
  111. $stmt->execute();
  112. $carts = [];
  113. $lines = $stmt->fetchAll();
  114. foreach($lines as $row){
  115. $cart = $this->getCartByCustomerId($row['customers_id']);
  116. if($cart)
  117. $carts[] = $cart;
  118. }
  119. return $carts;
  120. }
  121. public function getCartSession()
  122. {
  123. return $this->session->get('cart',$this->getEmptyCart());
  124. }
  126. private function getEmptyCart()
  127. {
  128. return ['products'=>[],'id'=>null,'createdAt'=>(new \DateTime())->format('Y-m-d H:i:s'),'updatedAt'=>'0000-00-00 00:00:00', 'coupons'=>[]];
  129. }
  131. public function getGifts()
  132. {
  133. return $this->em->getRepository('App:Product')->getGifts();
  134. }
  136. public function fillCartFromSession(&$cart)
  137. {
  138. $cart->setItems([]);
  139. $cartSession = $this->getCartSession();
  140. if(empty($cartSession['products']))
  141. return;
  142. foreach($cartSession['products'] as $item){
  143. $product = $this->em->getRepository('App:Product')->find($item['product']['id']);
  144. if(!empty($product))
  145. $cart->addItem(
  146. $product,
  147. $item['qty']
  148. );
  149. }
  150. }
  152. public function getCart($reload=false) : Cart
  153. {
  154. $customer = $this->customerMgr->getCustomer();
  155. $cartSession = $this->getCartSession();
  156. $cart = null;
  157. $fillFromSession = false;
  158. $priceGroup = $this->customerMgr->getPriceContext();
  159. if($customer){
  160. $cart = $this->em->getRepository('App:Cart')->findOneBy([
  161. 'customer' => $customer->getId(),
  162. 'priceGroup' => $priceGroup,
  163. ]);
  164. if($cart)
  165. $cart->setCustomer($customer);
  166. }else if(!empty($cartSession['id'])){
  167. $cart = $this->em->getRepository('App:Cart')->find($cartSession['id']);
  168. }
  169. if(empty($cart)){
  170. $cart = new Cart();
  171. $cart->setPriceGroup($priceGroup);
  172. if($customer){
  173. $cart->setCustomer($customer);
  174. }
  175. }
  176. if(!isset($cartSession['coupons'])){
  177. $cartSession['coupons'] = [];
  178. }
  179. foreach($cartSession['coupons'] as $c){
  180. $coupon = $this->em->getRepository(\App\Entity\Coupon::class)->find($c['id']);
  181. if(!empty($coupon))
  182. $cart->addCoupon($coupon);
  183. }
  184. $this->cart = $cart;
  185. return $this->cart;
  186. }
  188. public function add(Product $product,$qty,$actionType=null,$genericProductId=null,$categoryId=null,$force=false)
  189. {
  190. if(!$this->customerMgr->isLogged()){
  191. return [
  192. 'success'=>false,
  193. 'error'=>'',
  194. 'requestQty'=>$qty,
  195. 'totalQty'=>$qty
  196. ];
  197. }
  198. $cart = $this->getCart();
  199. if($cart->hasProduct($product)){
  200. $qtyUpdate = $cart->getItemQuantityByProduct($product)+$qty;
  201. if($qtyUpdate<=0){
  202. return $this->remove($product);
  203. }
  204. return $this->update($product, $qtyUpdate);
  205. }
  206. if($product->isGift()){
  207. $qty = 1;
  208. }
  209. $cart->addItem($product,$qty);
  210. $checkQuantity = $this->checkQuantityForProduct($product, $qty, $force);
  211. if($checkQuantity === true){
  212. return $this->save($cart);
  213. }else{
  214. return [
  215. 'success'=>false,
  216. 'error'=>$checkQuantity,
  217. 'requestQty'=>$qty,
  218. 'totalQty'=>$qty
  219. ];
  220. }
  221. return [
  222. 'success'=>false,
  223. 'error'=>'',
  224. 'requestQty'=>$qty,
  225. 'totalQty'=>$qty
  226. ];
  227. }
  229. public function update(Product $product,$qty)
  230. {
  231. $cart = $this->getCart();
  232. if(empty($cart)){
  233. $cart = [];
  234. }
  235. if(!$cart->hasProduct($product)){
  236. return $this->add($product, $qty, null, null, null, $force);
  237. }
  238. if($qty<=0){
  239. return $this->remove($product);
  240. }
  241. if($product->isGift()){
  242. $qty = 1;
  243. }
  244. $cart->updateItem($product,$qty);
  245. $cart = $this->save($cart);
  246. return $cart;
  247. }
  249. public function qtyInCart(Product $product)
  250. {
  251. $cart = $this->getCart();
  252. if(empty($cart))
  253. return 0;
  254. return $cart->getItemQuantityByProduct($product);
  255. }
  257. public function setAddress(\App\Entity\Address $address, $type) {
  258. $cart = $this->getCart();
  259. if($type == 'shipping'){
  260. $cart->setShippingAddress($address);
  261. }else if($type == 'billing'){
  262. $cart->setBillingAddress($address);
  263. }else{
  264. throw new \Exception("Type d'adresse inconnu (".$type.")");
  265. }
  266. return $this->save($cart);
  267. }
  269. public function setCarrier(\App\Entity\Carrier $carrier) {
  270. $cart = $this->getCart();
  271. $cart->setCarrier($carrier);
  272. return $this->save($cart);
  273. }
  275. public function checkQuantityForProduct(Product $product, $qty, $force){
  276. return $product->getQuantity()>=$qty;
  277. }
  279. public function checkCartDisponibility(Cart $cart) {
  280. // $output = [
  281. // 'products' => [],
  282. // 'message' => ''
  283. // ];
  284. // foreach($cart->getItems() as $item){
  285. // $product = $item->getProduct();
  286. // if(!$item->getProduct()->isAvailable()){
  287. // $cart->removeItem($product);
  288. // $output['products'][] = $product;
  289. // }
  290. // }
  291. // if(!empty($output['products'])){
  292. // $this->save($cart);
  293. // return false;
  294. // }
  295. return true;
  296. }
  298. public function remove(Product $product)
  299. {
  300. $cart = $this->getCart();
  301. if(empty($cart)){
  302. return false;
  303. }
  304. $item = $cart->getItemByProduct($product);
  305. if($item){
  306. $this->em->remove($item);
  307. $this->em->flush();
  308. $cart = $this->save($cart);
  309. }
  310. return $this->save($cart);
  311. }
  313. public function empty()
  314. {
  315. $cart = $this->getCart();
  316. $this->em->remove($cart);
  317. $this->em->flush();
  318. $this->session->remove('cart');
  319. }
  321. public function save(Cart $cart)
  322. {
  323. $customer = $this->customerMgr->getCustomer();
  324. $cartId = $cart->getId();
  325. $items = $cart->getItems();
  326. if($customer){
  327. if(empty($cartId))
  328. $cart->setCustomer($customer);
  329. }
  330. if(empty($items)){
  331. $this->em->remove($cart);
  332. }else{
  333. $this->em->persist($cart);
  334. }
  335. $this->em->flush();
  336. $this->session->set('cart',$cart->toArray());
  337. $this->cart = $cart;
  338. return $this->cart;
  339. }
  341. public function assignCartToCustomer($cartId, Customer $customer)
  342. {
  343. // utilisation d'une requête SQL pour empecher l'ecrasement de la date de mise à jour.
  344. $conn = $this->em->getConnection();
  345. $conn->executeQuery("update Cart set CustomerId=".$customer->getId()." where Id=:id",['id'=>$cartId]);
  346. }
  349. public function checkCartItems(Cart $cart) {
  350. // Available
  351. $refs = [];
  352. foreach($cart->getItems() as $item){
  353. $product = $item->getProduct();
  354. if(!$item->getProduct()->isAvailable() || $item->getProduct()->isStopped()){
  355. $cart->removeItem($product);
  356. $refs[] = $product->getReference();
  357. }
  358. }
  359. if(!empty($refs)){
  360. $this->session->getFlashBag()->add('error', $this->translator->trans('Les articles suivants ne sont plus disponibles à la vente : ') . ' ' . implode(', ',$refs));
  361. $this->save($cart);
  362. return false;
  363. }
  364. $refs = [];
  365. foreach($cart->getItems() as $item){
  366. $product = $item->getProduct();
  367. if($item->getProduct()->getQuantity() < $item->getQuantity()){
  368. $refs[] = $product->getReference();
  369. }
  370. }
  371. if(!empty($refs)){
  372. $this->session->getFlashBag()->add('error', $this->translator->trans('La quantité demandée pour les articles suivants n\'est pas disponible : ') . ' ' . implode(', ',$refs));
  373. $this->save($cart);
  374. return false;
  375. }
  376. $refs = [];
  377. $country = $this->customerMgr->getCustomerCountry();
  378. foreach($cart->getItems() as $item){
  379. $product = $item->getProduct();
  380. if(!$item->getProduct()->isAvailableForCountry($country)){
  381. $cart->removeItem($product);
  382. $refs[] = $product->getReference();
  383. }
  384. }
  385. if(!empty($refs)){
  386. $this->session->getFlashBag()->add('error', $this->translator->trans('Les articles suivants ne sont pas disponibles à la vente pour votre zone géographique : ') . ' ' . implode(', ',$refs));
  387. $this->save($cart);
  388. return false;
  389. }
  390. return true;
  391. }
  393. public function checkShippingRate(Cart $cart) {
  395. $shippingRate = $cart->getShippingRate();
  396. return empty($shippingRate) ? false : true;
  397. }
  399. public function checkDropShipping(Cart $cart) {
  400. if($cart->getCarrier()->getCode() != 'dropshipping')
  401. return true;
  402. return $cart->getBillingAddress()->getId() != $cart->getShippingAddress()->getId();
  403. }
  405. public function addCoupon(Coupon $coupon) {
  406. $cart = $this->getCart();
  407. $result = $cart->addCoupon($coupon);
  408. if($result === true){
  409. return $this->save($cart);
  410. }
  411. return $result;
  412. }
  414. }