src/Trinity/WebshopBundle/Repository/ProductRepository.php line 1903

Open in your IDE?
  1. <?php
  2. namespace App\Trinity\WebshopBundle\Repository;
  4. use Doctrine\ORM\EntityRepository;
  5. use App\Trinity\WebshopBundle\Entity\Category;
  6. use App\CmsBundle\Classes\SqlFormatter;
  8. /**
  9.  * ProductRepository
  10.  */
  11. class ProductRepository extends EntityRepository
  12. {
  14.     public function filter($doCount = false, $Webshop = null, $offset = 0, $limit = 0, $filter = []){
  15.         $em = $this->getEntityManager();
  17.         $q          = (isset($filter['q']) && !empty($filter['q']) ? $filter['q'] : null);
  18.         $type       = (isset($filter['type']) && $filter['type'] != '' ? $filter['type'] : null);
  19.         $status     = (isset($filter['status']) && $filter['status'] != '' ? $filter['status'] : null);
  20.         $featured   = (isset($filter['featured']) && $filter['featured'] != '' ? $filter['featured'] : null);
  21.         $category   = (isset($filter['category']) && $filter['category'] != '' ? $filter['category'] : null);
  22.         $tax        = (isset($filter['tax']) &&!empty($filter['tax']) && $filter['tax'] != '' ? $filter['tax'] : null);
  23.         
  24.         $stock      = (isset($filter['stock']) && $filter['stock'] != '' ? $filter['stock'] : null);
  25.         $sale       = (isset($filter['sale']) && $filter['sale'] != '' ? $filter['sale'] : null);
  26.         $sales      = (isset($filter['sales']) && $filter['sales'] != '' ? $filter['sales'] : null);
  27.         $media      = (isset($filter['media']) && $filter['media'] != '' ? $filter['media'] : null);
  28.         $visibility = (isset($filter['visibility']) && $filter['visibility'] != '' ? $filter['visibility'] : null);
  29.         
  30.         $sort       = (!empty($filter['sort']) && $filter['sort'] != '' ? $filter['sort'] : 'p.label');
  31.         $order      = (!empty($filter['order']) && $filter['order'] == 'desc' ? 'desc' : 'asc');
  33.         // Force $q to array
  34.         if(!is_array($q)){
  35.             $q = [$q];
  36.         }
  38.         $partDone = [];
  39.         $queries = [];
  40.         foreach($q as $part){
  42.             // Cleanup
  43.             $part = preg_replace('/^(.*?)\'.*?$/', '$1', $part);
  44.             $part = str_replace('\'', '_', $part);
  46.             if(empty($part) || strlen($part) <= 1 || in_array($part, $partDone)) continue;
  48.             $partDone[] = $part;
  49.             $queries[] = "
  50.             (
  51.                 p.label LIKE '%" . $part . "%' OR
  52.                 p.ean LIKE '%" . $part . "%' OR
  53.                 p.sku LIKE '%" . $part . "%' OR
  54.                 p.number LIKE '%" . $part . "%'
  55.             )
  56.             ";
  57.         }
  59.         if($doCount && empty($category) && $stock == null && ($type == null) && $tax == null && $sale == null && $sales == null && $visibility == null && $status == null && $featured == null && $media == null && empty($queries)){
  60.             $sql = "
  61.             SELECT count(p.id)
  62.             FROM TrinityWebshopBundle:Product p
  63.             WHERE 1 = 1
  64.             " . ($Webshop ? "AND p.webshop = :webshopid" : "") . "
  65.             ";
  66.         }else{
  69.             if($category != null){
  70.                 $sql = "
  71.                 SELECT " . (!$doCount ? "wp" : "count(wp.id)") . "
  72.                 FROM TrinityWebshopBundle:WebshopProduct wp
  73.                 JOIN wp.product p
  74.                 WHERE 1 = 1
  75.                 " . ($Webshop ? "AND p.webshop = :webshopid" : "") . "
  77.                 " . ($category != null ? "
  78.                 AND wp.category  = " . $category . "
  79.                 " : "") . "
  81.                 " . ($stock != null ? ($stock == 1 ? 
  82.                         "AND (p.stock = 0 OR (p.stock = 1 AND (p.stock_amount - p.out_of_stock_quantity) > 0))"
  83.                         :
  84.                         "AND p.toggle_stock = 0 OR (p.stock = 1 AND ((p.stock_amount - p.out_of_stock_quantity) <= 0 or (p.child_stock_amount - p.out_of_stock_quantity) <= 0))"
  85.                         )
  86.                     :
  87.                 "") . "
  89.                 " . ($type != null ? "
  90.                 AND p.type = " . $type . "
  91.                 " : "") . "
  93.                 " . ($tax != null ? "
  94.                 AND p.tax = " . $tax . "
  95.                 " : "") . "
  97.                 " . ($sale != null ? "
  98.                     AND p.price_sale " . ($sale ? " > 0" : "<= 0") . "
  99.                     AND (p.price_sale < p.price_incl OR p.price_sale > p.price_incl)
  100.                 " : "") . "
  102.                 " . ($sales != null ? "
  103.                     AND (SELECT COUNT(op) FROM TrinityWebshopBundle:OrderProduct op WHERE op.product = p) >= " . $sales . "
  104.                 " : "") . "
  106.                 " . ($visibility === '1' ? "
  107.                 AND p.visible = 1
  108.                 AND p.enabled = 1
  109.                 " : "") . "
  111.                 " . ($visibility === '0' ? "
  112.                 AND (p.visible = 0
  113.                 OR p.enabled = 0)
  114.                 " : "") . "
  116.                 " . ($status != null ? "
  117.                 AND p.enabled = " . $status . "
  118.                 " : "") . "
  120.                 " . ($featured != null ? "
  121.                 AND p.featured = " . $featured . "
  122.                 " : "") . "
  124.                 " . (empty($media) && !is_null($media) ? "AND wp.has_media != 1" : "") . "
  126.                 " . (!empty($queries) ? " AND " . implode(" AND ", $queries) : "") . "
  128.                 " . (!$doCount ? "GROUP BY p.id" : "") . "
  129.             
  130.                 ORDER BY {$sort} {$order}
  131.                 ";
  132.             }else{
  133.                 $sql = "
  134.                 SELECT " . (!$doCount ? "p" : "count(p.id)") . "
  135.                 FROM TrinityWebshopBundle:Product p
  136.                 " . ($category != null ? " JOIN p.category cp JOIN cp.category c " : "") . "
  137.                 " . (empty($media) && !is_null($media) ? "LEFT JOIN p.media m" : "") . "
  138.                 WHERE 1 = 1
  139.                 " . ($Webshop ? "AND p.webshop = :webshopid" : "") . "
  141.                 " . ($category != null ? "
  142.                 AND c.id  = " . $category . "
  143.                 " : "") . "
  146.                 " . ($stock != null ? ($stock == 1 ? 
  147.                         "AND (p.stock = 0 OR (p.stock = 1 AND (p.stock_amount - p.out_of_stock_quantity) > 0))"
  148.                         :
  149.                         "AND p.toggle_stock = 0 OR (p.stock = 1 AND ((p.stock_amount - p.out_of_stock_quantity) <= 0))"
  150.                         )
  151.                     :
  152.                 "") . "
  154.                 " . ($type != null ? "
  155.                 AND p.type = " . $type . "
  156.                 " : "") . "
  158.                 " . ($tax != null ? "
  159.                 AND p.tax = " . $tax . "
  160.                 " : "") . "
  162.                 " . ($sale != null ? "
  163.                     AND p.price_sale " . ($sale ? " > 0" : "<= 0") . "
  164.                     AND (p.price_sale < p.price_incl OR p.price_sale > p.price_incl)
  165.                 " : "") . "
  167.                 " . ($sales != null ? "
  168.                     AND (SELECT COUNT(op) FROM TrinityWebshopBundle:OrderProduct op WHERE op.product = p) >= " . $sales . "
  169.                 " : "") . "
  171.                 " . ($visibility === '1' ? "
  172.                 AND p.visible = 1
  173.                 AND p.enabled = 1
  174.                 " : "") . "
  176.                 " . ($visibility === '0' ? "
  177.                 AND (p.visible = 0
  178.                 OR p.enabled = 0)
  179.                 " : "") . "
  181.                 " . ($status != null ? "
  182.                 AND p.enabled = " . $status . "
  183.                 " : "") . "
  185.                 " . ($featured != null ? "
  186.                 AND p.featured = " . $featured . "
  187.                 " : "") . "
  189.                 " . (empty($media) && !is_null($media) ? "AND p.has_media = 0" : "") . "
  191.                 " . (!empty($queries) ? " AND " . implode(" AND ", $queries) : "") . "
  192.             
  193.                 " . (!$doCount ? "GROUP BY p.id" : "") . "
  195.                 ORDER BY {$sort} {$order}
  196.                 ";
  197.             }
  203.             /*$sql = "
  204.             SELECT " . (!$doCount ? "p" : "count(p.id)") . "
  205.                 FROM TrinityWebshopBundle:Product p
  206.                 LEFT JOIN p.product_link pl
  207.             " . ($category != null ? " JOIN p.category cp JOIN cp.category c " : "") . "
  208.             " . (!empty($media) ? "JOIN p.media m" : "") . "
  209.             " . (empty($media) && !is_null($media) ? "LEFT JOIN p.media m" : "") . "
  210.             WHERE 1 = 1
  211.             " . ($Webshop ? "AND p.webshop = :webshopid" : "") . "
  213.             " . ($category != null ? "
  214.             AND c.id  = " . $category . "
  215.             " : "") . "
  217.             " . ($stock != null ? "
  218.             AND p.stock_amount " . ($stock ? " > 0" : "<= 0") . "
  219.             " : "") . "
  221.             " . ($type != null ? "
  222.             AND p.type = " . $type . "
  223.             " : "") . "
  225.             " . ($tax != null ? "
  226.             AND p.tax = " . $tax . "
  227.             " : "") . "
  229.             " . ($sale != null ? "
  230.                 AND p.price_sale " . ($sale ? " > 0" : "<= 0") . "
  231.                 AND (p.price_sale < p.price_incl OR p.price_sale > p.price_incl)
  232.             " : "") . "
  234.             " . ($sales != null ? "
  235.                 AND (SELECT COUNT(op) FROM TrinityWebshopBundle:OrderProduct op WHERE op.product = p) >= " . $sales . "
  236.             " : "") . "
  238.             " . ($visibility === '1' ? "
  239.             AND p.visible = 1
  240.             AND p.enabled = 1
  241.             " : "") . "
  243.             " . ($visibility === '0' ? "
  244.             AND (p.visible = 0
  245.             OR p.enabled = 0)
  246.             " : "") . "
  248.             " . ($status != null ? "
  249.             AND p.enabled = " . $status . "
  250.             " : "") . "
  252.             " . ($featured != null ? "
  253.             AND p.featured = " . $featured . "
  254.             " : "") . "
  256.             " . (empty($media) && !is_null($media) ? "AND m.id IS NULL" : "") . "
  258.             " . (!empty($queries) ? " AND " . implode(" AND ", $queries) : "") . "
  259.         
  260.             " . (!$doCount ? "GROUP BY p.id" : "") . "
  262.             ORDER BY {$sort} {$order}
  263.             ";*/
  264.         }
  266.         // dump($sql);die();
  268.         /*if(!$doCount){
  269.             dump($sql);
  270.             die();
  271.         }*/
  273.         $query = $em->createQuery($sql);
  275.         if ($Webshop) {
  276.             $query->setParameter('webshopid', (!empty($Webshop) ? $Webshop : 0));
  277.         }
  280.         if($doCount){
  281.             try{
  282.                 return $query->getSingleScalarResult();
  283.             }catch(\Exception $e){
  284.                 return 0;
  285.             }
  286.         }
  288.         if(!empty($limit)){
  289.             try{
  291.                 $all_results = $query->setFirstResult($offset)->setMaxResults($limit)->getResult();
  292.                 foreach($all_results as $i => $r){
  293.                     if($r instanceof \App\Trinity\WebshopBundle\Entity\WebshopProduct){
  294.                         $all_results[$i] = $r->getProduct();
  295.                     }
  296.                 }
  298.                 return $all_results;
  299.             }catch(\Exception $e){
  300.                 return [];
  301.             }
  302.         }
  304.         $all_results = $query->getResult();
  305.         foreach($all_results as $i => $r){
  306.             if($r instanceof \App\Trinity\WebshopBundle\Entity\WebshopProduct){
  307.                 $all_results[$i] = $r->getProduct();
  308.             }
  309.         }
  311.         return $all_results;
  312.     }
  314.     public function getPriceRange($Webshop = null, $Category = null){
  315.         $em = $this->getEntityManager();
  317.         $sql = "
  318.         SELECT MAX(p.sell_price_incl) as max_price, MIN(p.sell_price_incl) as min_price
  319.         FROM TrinityWebshopBundle:Product p
  320.         JOIN p.category cp
  321.         JOIN p.product_link wp
  322.         JOIN cp.category c
  323.         " . ($Webshop ? "JOIN c.webshop w" : "") . "
  324.         WHERE p.visible = 1
  325.         AND p.sell_price_incl >= 1
  326.         AND p.enabled = 1
  327.         AND (p.stock_amount > 0 or p.child_stock_amount > 0 or p.stock = 0 or p.visible_no_stock = 1)
  328.         " . ($Webshop ? "AND w.id LIKE :webshopid" : "") . "
  329.         " . ($Category && $Category instanceof Category ? "AND c.id LIKE :categoryid" : "") . "
  330.         " . ($Category && is_array($Category) ? "AND wp.category IN (:categoryids)" : ""). "
  331.         ";
  333.         $query = $em->createQuery($sql);
  335.         if ($Webshop) {
  336.             $query->setParameter('webshopid', (!empty($Webshop) ? $Webshop->getId() : 0));
  337.         }
  339.         if ($Category && $Category instanceof Category) {
  340.             $query->setParameter('categoryid', (!empty($Category) ? $Category->getId() : 0));
  341.         } elseif ($Category && is_array($Category)) {
  342.             $query->setParameter('categoryids', $Category, \Doctrine\DBAL\Connection::PARAM_INT_ARRAY);
  343.         }
  345.         return $query->getResult();
  346.     }
  348.     public function countBy($Webshop = null, $q = null, $type = null){
  349.         $em = $this->getEntityManager();
  350.         $query = $em->createQuery(
  351.             "SELECT count(p)
  352.             FROM TrinityWebshopBundle:Product p
  353.             JOIN p.category cp
  354.             JOIN cp.category c
  355.             " . ($Webshop ? "JOIN c.webshop w" : "") . "
  356.             WHERE 1 = 1
  357.             " . ($Webshop ? "AND w.id LIKE :webshopid" : "") . "
  359.             " . ($type ? "
  360.             AND p.type = " . $type . "
  361.             " : "") . "
  363.             " . ($q ? "
  364.             AND (
  365.                 p.label LIKE '%" . $q . "%' OR
  366.                 p.ean LIKE '%" . $q . "%' OR
  367.                 p.sku LIKE '%" . $q . "%' OR
  368.                 p.number LIKE '%" . $q . "%' OR
  369.                 c.label LIKE '%" . $q . "%'
  370.             )
  371.             " : "") . "
  372.             "
  373.         );
  375.         if ($Webshop) {
  376.             $query->setParameter('webshopid', (!empty($Webshop) ? $Webshop->getId() : 0));
  377.         }
  379.         return $query->getSingleScalarResult();
  380.     }
  382.     public function findOrders($id, $q = null, $doCount = false, $offset = null, $limit = null){
  383.         $em = $this->getEntityManager();
  385.         if(!empty($q)){
  386.             $sql = "SELECT " . ($doCount ? "count(o)" : "o") . "
  387.             FROM TrinityWebshopBundle:Order o
  388.             JOIN o.products p
  389.             JOIN p.product op
  390.             WHERE op.id = " . $id . "
  391.             AND (
  392.                 o.order_id LIKE '%" . $q . "%' OR 
  393.                 o.firstname LIKE '%" . $q . "%' OR 
  394.                 o.lastname LIKE '%" . $q . "%' OR 
  395.                 o.email LIKE '%" . $q . "%'
  396.             )
  397.             ORDER BY o.date DESC
  398.             ";
  399.         }else{
  400.             $sql = "SELECT " . ($doCount ? "count(o)" : "o") . "
  401.             FROM TrinityWebshopBundle:Order o
  402.             JOIN o.products p
  403.             JOIN p.product op
  404.             WHERE op.id = " . $id . "
  405.             ORDER BY o.date DESC
  406.             ";
  407.         }
  409.         
  410.         $query = $em->createQuery($sql);
  413.         if($doCount){
  414.             return (int)$query->getSingleScalarResult();
  415.         }
  417.         return $query->setFirstResult($offset)->setMaxResults($limit)->getResult();
  418.     }
  420.     public function getUsingSkuOtherShops($sku, $Product, $Webshop = null){
  421.         $em = $this->getEntityManager();
  422.         $query = $em->createQuery(
  423.             "SELECT p
  424.             FROM TrinityWebshopBundle:Product p
  425.             WHERE 1 = 1
  426.             AND p.sku = '$sku'
  427.             " . ($Product ? "AND p.id != " . $Product->getId() . "" : "") . "
  428.             " . ($Webshop ? "AND p.webshop = :webshopid" : "") . "
  429.             "
  430.         );
  432.         if ($Webshop) {
  433.             $query->setParameter('webshopid', (!empty($Webshop) ? $Webshop->getId() : 0));
  434.         }
  436.         $results = $query->getResult();
  438.         return $results;
  439.     }
  441.     public function getUsingEanOtherShops($sku, $Product, $Webshop = null){
  442.         $em = $this->getEntityManager();
  443.         $query = $em->createQuery(
  444.             "SELECT p
  445.             FROM TrinityWebshopBundle:Product p
  446.             WHERE 1 = 1
  447.             AND p.sku = '$sku'
  448.             " . ($Product ? "AND p.id != " . $Product->getId() . "" : "") . "
  449.             " . ($Webshop ? "AND p.webshop = :webshopid" : "") . "
  450.             "
  451.         );
  453.         if ($Webshop) {
  454.             $query->setParameter('webshopid', (!empty($Webshop) ? $Webshop->getId() : 0));
  455.         }
  457.         $results = $query->getResult();
  459.         return $results;
  460.     }
  462.     public function countWithImage($Webshop = null){
  463.         $em = $this->getEntityManager();
  464.         $query = $em->createQuery(
  465.             "SELECT count(p)
  466.             FROM TrinityWebshopBundle:Product p
  467.             JOIN p.category cp
  468.             JOIN cp.category c
  469.             JOIN p.media m
  470.             " . ($Webshop ? "JOIN c.webshop w" : "") . "
  471.             WHERE 1 = 1
  472.             " . ($Webshop ? "AND w.id LIKE :webshopid" : "") . "
  473.             
  474.             "
  475.         );
  477.         if ($Webshop) {
  478.             $query->setParameter('webshopid', (!empty($Webshop) ? $Webshop->getId() : 0));
  479.         }
  481.         return $query->getSingleScalarResult();
  482.     }
  484.     public function selector($Webshop, $q = '', $c = ''){
  485.         $em = $this->getEntityManager();
  486.         $query = $em->createQuery(
  487.             "SELECT p
  488.             FROM TrinityWebshopBundle:Product p
  489.             JOIN p.category cp
  490.             JOIN cp.category c
  491.             JOIN c.webshop w
  492.             WHERE w.id LIKE :webshopid
  494.             " . ($q ? "
  495.             AND (
  496.                 p.label LIKE '%" . $q . "%' OR
  497.                 p.ean LIKE '%" . $q . "%' OR
  498.                 p.sku LIKE '%" . $q . "%' OR
  499.                 p.number LIKE '%" . $q . "%' OR
  500.                 c.label LIKE '%" . $q . "%'
  501.             )
  502.             " : "") . "
  504.             " . ($c ? "
  505.             AND c.id = " . $c . "
  506.             " : "") . "
  507.             ORDER BY p.label ASC
  508.             "
  509.         );
  511.         $query->setParameter('webshopid', (!empty($Webshop) ? $Webshop->getId() : 0));
  513.         return $query->getResult();
  514.     }
  516.     public function getBy($Webshop, $offset, $limit, $q = null, $type = null){
  517.         $em = $this->getEntityManager();
  518.         $query = $em->createQuery(
  519.             "SELECT p
  520.             FROM TrinityWebshopBundle:Product p
  521.             JOIN p.category cp
  522.             JOIN cp.category c
  523.             " . ($Webshop ? "JOIN c.webshop w" : "") . "
  524.             WHERE 1 = 1
  525.             " . ($Webshop ? "AND w.id LIKE :webshopid" : "") . "
  527.             " . ($type ? "
  528.             AND p.type = " . $type . "
  529.             " : "") . "
  531.             " . ($q ? "
  532.             AND (
  533.                 p.label LIKE '%" . $q . "%' OR
  534.                 p.ean LIKE '%" . $q . "%' OR
  535.                 p.sku LIKE '%" . $q . "%' OR
  536.                 p.number LIKE '%" . $q . "%' OR
  537.                 c.label LIKE '%" . $q . "%'
  538.             )
  539.             " : "") . "
  541.             ORDER BY p.label"
  542.         );
  544.         if ($Webshop) {
  545.             $query->setParameter('webshopid', (!empty($Webshop) ? $Webshop->getId() : 0));
  546.         }
  548.         return $query->setFirstResult($offset)->setMaxResults($limit)->getResult();
  549.     }
  551.     public function findByCategoryAndSlug($category, $slug, $preview = false){
  552.         $em = $this->getEntityManager();
  553.         $sql = "
  554.         SELECT p
  555.         FROM TrinityWebshopBundle:Product p
  556.         JOIN p.category cp
  557.         JOIN cp.category c
  558.         JOIN p.language pl
  559.         JOIN c.webshop w
  560.         JOIN w.language l WITH l.id = pl.id
  561.         WHERE c.id = " . $category->getId() . "
  562.         AND p.slug = '" . $slug . "'
  563.         ";
  564.         $query = $em->createQuery($sql);
  566.         try {
  567.             return $query->getSingleResult();
  568.         } catch (\Exception $e) {}
  570.         return null;
  571.     }
  573.     public function findBySpecs($specs, $Product){
  574.         $em = $this->getEntityManager();
  576.         $joins = [];
  577.         $ands = [];
  578.         $orderbys = [];
  579.         if(!empty($specs['spec'])){
  580.             foreach($specs['spec'] as $specid => $value){
  581.                 $joins[] = " JOIN p.spec_values s" . $specid;
  582.                 $ands[] = " AND s" . $specid . ".spec = " . $specid . "";
  583.                 $ands[] = " AND s" . $specid . ".value = '" . $value . "'";
  584.                 $orderbys[] = "s" . $specid . ".position ASC";
  585.             }
  586.         }/*else{
  587.             $joins[] = " JOIN p.spec_values sx";
  588.             $orderbys[] = "sx.position ASC";
  589.         }*/
  591.         $sql = 'SELECT p
  592.             FROM TrinityWebshopBundle:Product p
  593.             JOIN p.linked_to l
  594.             ' . implode(' ', $joins) . '
  595.             WHERE l.id = :product
  596.             AND p.enabled = 1
  597.             ' . implode(' ', $ands) . '
  598.             ' . (!empty($orderbys) ? 'ORDER BY ' . implode(', ', $orderbys) : '') . '
  599.             ';
  601.         $query = $em->createQuery($sql)
  602.                 ->setParameter('product', $Product);
  604.         return $query->getResult();
  605.     }
  607.     public function findAnyBySpecs($specs, $price_range = []){
  608.         $em = $this->getEntityManager();
  610.         $joins = [];
  611.         $ands = [];
  612.         $orderbys = [];
  613.         if(!empty($specs['spec'])){
  614.             foreach($specs['spec'] as $specid => $value){
  615.                 $joins[] = " JOIN p.spec_values s" . $specid;
  616.                 $ands[] = " AND s" . $specid . ".spec = " . $specid . "";
  617.                 $ands[] = " AND s" . $specid . ".value = '" . $value . "'";
  618.                 $orderbys[] = "s" . $specid . ".position ASC";
  619.             }
  620.         }/*else{
  621.             $joins[] = " JOIN p.spec_values sx";
  622.             $orderbys[] = "sx.position ASC";
  623.         }*/
  625.         $sql = 'SELECT p
  626.             FROM TrinityWebshopBundle:Product p
  627.             ' . implode(' ', $joins) . '
  628.             WHERE 1 = 1
  629.             AND p.enabled = 1
  630.             ' . implode(' ', $ands) . '
  631.             ' . (!empty($price_range) ? 'AND ((p.sell_price_incl BETWEEN ' . $price_range[0] . ' AND ' . $price_range[1] . '))' : '') . '
  632.             ' . (!empty($orderbys) ? 'ORDER BY ' . implode(', ', $orderbys) : '') . '
  633.             ';
  635.         $query = $em->createQuery($sql);
  637.         return $query->getResult();
  638.     }
  640.     public function getFeatured($Webshop, $limit = 0, $offset = 0){
  641.         $em = $this->getEntityManager();
  642.         $query = $em->createQuery(
  643.             'SELECT p
  644.             FROM TrinityWebshopBundle:Product p
  645.             JOIN p.category cp
  646.             JOIN cp.category c
  647.             JOIN c.webshop w
  648.             WHERE w.id LIKE :webshopid
  649.             AND p.featured = 1
  650.             AND p.visible = 1
  651.             AND p.enabled = 1
  652.             GROUP BY p.id
  653.             ORDER BY p.label'
  654.         )->setParameter('webshopid', (!empty($Webshop) ? $Webshop->getId() : 0));
  656.         if($limit > 0){
  657.             return $query->setFirstResult($offset)->setMaxResults($limit)->getResult();
  658.         }else{
  659.             return $query->getResult();
  660.         }
  661.     }
  663.     public function getNew($Webshop, $limit = 0, $offset = 0){
  664.         $em = $this->getEntityManager();
  668.         /*$products = $this->createQueryBuilder('p')
  669.             ->select('p')
  670.             ->join('p.category', 'c')
  671.             ->join('c.webshop', 'w')
  672.             ->where('w = :webshop')
  674.             ->setParameter('webshop', $Webshop)
  676.             ->orderBy('p.id', 'desc')
  678.             ->setMaxResults($limit)
  679.             ->setFirstResult($offset)
  680.             ->getQuery()
  681.             ->getSql();
  683.             dump($products);die();*/
  685.         $query = $em->createQuery(
  686.             'SELECT p
  687.             FROM TrinityWebshopBundle:Product p
  688.             JOIN p.category cp
  689.             JOIN cp.category c
  690.             JOIN c.webshop w
  691.             WHERE w.id LIKE :webshopid
  692.             AND p.visible = 1
  693.             AND p.enabled = 1
  694.             GROUP BY p.id
  695.             ORDER BY p.id DESC'
  696.         )->setParameter('webshopid', (!empty($Webshop) ? $Webshop->getId() : 0));
  698.         if($limit > 0){
  699.             return $query->setFirstResult($offset)->setMaxResults($limit)->getResult();
  700.         }else{
  701.             return $query->getResult();
  702.         }
  703.     }
  705.     public function getBestViewed($Webshop, $limit = 0, $offset = 0){
  706.         $em = $this->getEntityManager();
  707.         $query = $em->createQuery(
  708.             'SELECT p
  709.             FROM TrinityWebshopBundle:Product p
  710.             JOIN p.category cp
  711.             JOIN cp.category c
  712.             JOIN c.webshop w
  713.             WHERE w.id LIKE :webshopid
  714.             AND p.visible = 1
  715.             AND p.enabled = 1
  716.             GROUP BY p.id
  717.             ORDER BY p.views DESC'
  718.         )->setParameter('webshopid', (!empty($Webshop) ? $Webshop->getId() : 0));
  720.         if($limit > 0){
  721.             return $query->setFirstResult($offset)->setMaxResults($limit)->getResult();
  722.         }else{
  723.             return $query->getResult();
  724.         }
  725.     }
  727.     public function findByCategoryFront($category_id, $sort, $limit = 0, $offset = 0){
  728.         $em = $this->getEntityManager();
  730.         $s = ['p.id desc'];
  731.         if(!empty($sort)){
  732.             $s = [];
  733.             foreach($sort as $k => $v){
  734.                 $s[] = "p.$k $v";
  735.             }
  736.         }
  738.         if(!is_array($category_id)){
  739.             $category_id = [$category_id];
  740.         }
  742.         $query = $em->createQuery(
  743.             'SELECT p
  744.             FROM TrinityWebshopBundle:Product p
  745.             JOIN p.category cp JOIN cp.category c WITH c.id IN (' . implode(',', $category_id) . ')
  746.             WHERE p.enabled = 1
  747.             AND p.visible = 1
  748.             GROUP BY p.id
  749.             ORDER BY ' . implode(',', $s)
  750.         );
  752.         if($limit > 0){
  753.             return $query->setFirstResult($offset)->setMaxResults($limit)->getResult();
  754.         }else{
  755.             return $query->getResult();
  756.         }
  757.     }
  759.     public function searchSimple($q = ''){
  760.         $em = $this->getEntityManager();
  761.         $query = $em->createQuery(
  762.             "
  763.             SELECT p
  764.             FROM TrinityWebshopBundle:Product p
  765.             WHERE p.label LIKE '%" . $q . "%'
  766.             OR p.sku LIKE '%" . $q . "%'
  767.             OR p.number LIKE '%" . $q . "%'
  768.             "
  769.         );
  771.         return $query->getResult();
  772.     }
  774.     public function getBestSold($Webshop, $limit = 0, $offset = 0){
  775.         $em = $this->getEntityManager();
  776.         $query = $em->createQuery(
  777.             'SELECT p as Product, COUNT(op.id) AS num
  778.             FROM TrinityWebshopBundle:Product p
  779.             JOIN p.category cp
  780.             JOIN cp.category c
  781.             JOIN c.webshop w
  782.             JOIN TrinityWebshopBundle:OrderProduct op WITH op.product = p
  783.             WHERE w.id LIKE :webshopid
  784.             AND p.enabled = 1
  785.             AND p.visible = 1
  786.             GROUP BY p.id
  787.             ORDER BY num DESC'
  788.         )->setParameter('webshopid', (!empty($Webshop) ? $Webshop->getId() : 0));
  790.         if($limit > 0){
  791.             return $query->setFirstResult($offset)->setMaxResults($limit)->getResult();
  792.         }else{
  793.             return $query->getResult();
  794.         }
  795.     }
  797.     public function getBestSoldAllowed($Webshop, $limit = 0, $offset = 0){
  798.         $em = $this->getEntityManager();
  799.         $query = $em->createQuery(
  800.             'SELECT p as Product, COUNT(op.id) AS num
  801.             FROM TrinityWebshopBundle:Product p
  802.             JOIN p.category cp
  803.             JOIN cp.category c
  804.             JOIN c.webshop w
  805.             JOIN TrinityWebshopBundle:OrderProduct op WITH op.product = p
  806.             WHERE w.id LIKE :webshopid
  807.             AND p.visible = 1
  808.             AND p.enabled = 1
  809.             GROUP BY p.id
  810.             ORDER BY num DESC'
  811.         )->setParameter('webshopid', (!empty($Webshop) ? $Webshop->getId() : 0));
  813.         if($limit > 0){
  814.             return $query->setFirstResult($offset)->setMaxResults($limit)->getResult();
  815.         }else{
  816.             return $query->getResult();
  817.         }
  818.     }
  819.     
  820.     public function countProducts(){
  821.         $em = $this->getEntityManager();
  822.         $qb = $em->createQueryBuilder();
  823.         $qb->select('count(product.id)');
  824.         $qb->from('TrinityWebshopBundle:Product','product');
  826.         $count = $qb->getQuery()->getSingleScalarResult();
  827.         
  828.         return $count;
  829.     }
  831.     public function search($Webshop, $filters = array(), $order = null, $orderDir = 'asc', $noLimit = false, $ignoreStock = false, $page = 1, $limit = 9, $offset = 0, $thisIsFilter = false){
  832.         $em = $this->getEntityManager();
  834.         if(isset($filters['q']) && is_array($filters['q'])){
  835.             $filters['q'] = implode(' ', $filters['q']);
  836.         }
  837.         if(isset($filters['q']) && strpos($filters['q'], 'linkableproducts') !== false){
  838.             $ignoreStock = true;
  839.         }
  841.         $featured = (!empty($filters['featured']) && $filters['featured'] === true);
  843.         $debug = false;
  844.         if(isset($filters['debug'])){
  845.             $debug = true;
  846.             unset($filters['debug']);
  847.         }
  850.         $join = [];
  851.         $joinNorForCount = [];
  852.         $and = [];
  853.         $or = [];
  855.         $start = 0;
  857.         if(empty($limit) || !is_numeric($limit)){
  858.             $limit = 9; // 9 is default, can be overridden in Trinity
  859.         }
  861.         // Check category
  862.         if(isset($filters['page']) && $page <= 1){
  863.             $page = (int)$filters['page'];
  864.         }
  866.         $webshop_id = (!empty($Webshop) ? $Webshop->getId() : 0);
  869.         $ignore_ids = [];
  870.         if(!empty($filters['ignore_ids'])){
  871.             $ignore_ids = $filters['ignore_ids'];
  872.             if(!is_array($ignore_ids)){
  873.                 $ignore_ids = [$ignore_ids];
  874.             }
  875.             unset($filters['ignore_ids']);
  876.         }
  881.         $showHidden = false;
  882.         if(!empty($filters['q'])){
  883.             if(preg_match('/linkableproducts=1/', $filters['q'])){
  884.                 $filters['q'] = preg_replace('/&linkableproducts=1/', '', $filters['q']);
  885.                 $showHidden = true;
  886.             }
  887.         }
  911.         $ranges       = [];
  912.         $ranges_joins = [];
  913.         $ranges_where = [];
  914.         $fn = 0;
  916.         if(!empty($filters['filters'])){
  917.             foreach($filters['filters'] as $spec_id => $value){
  918.                 if(is_array($value) && isset($value['range'])){
  919.                     foreach($value as $t => $v){
  920.                         if(!empty($v[0]) && !empty($v[1]) && $v[0] != 'undefined' && $v[1] != 'undefined'){
  921.                             $ranges_joins[] = "JOIN p.spec_values sv{$fn}x1 WITH sv{$fn}x1.spec = '" . $spec_id . "'";
  922.                             $ranges_where[] = "AND (sv{$fn}x1.value BETWEEN " . implode(' AND ', $v) . " OR sv{$fn}x1.value = '' OR sv{$fn}x1.value IS NULL)";
  923.                             $fn++;
  924.                         }
  925.                     }
  926.                 }
  927.             }
  928.         }
  935.         $sliders = (!empty($filters['sliders']) ? $filters['sliders'] : []);
  936.         $sliders_range = (!empty($filters['sliders_range']) ? $filters['sliders_range'] : []);
  939.         if(!empty($filters['filters'])){
  940.             foreach($filters['filters'] as $spec_id => $value){
  941.                 if(in_array($spec_id, $sliders) && (int)$value[0] > 0){
  942.                     $v = [0, (int)$value[0]];
  943.                     $ranges_joins[] = "JOIN p.spec_values sv{$fn}x1 WITH sv{$fn}x1.spec = '" . $spec_id . "'";
  944.                     $ranges_where[] = "AND (sv{$fn}x1.value BETWEEN " . implode(' AND ', $v) . ")";
  945.                     $fn++;
  946.                 }
  947.                 if(in_array($spec_id, $sliders_range)){
  948.                     $v = [(int)$value['min'], (int)$value['max']];
  949.                     $ranges_joins[] = "JOIN p.spec_values sv{$fn}x1 WITH sv{$fn}x1.spec = '" . $spec_id . "'";
  950.                     $ranges_where[] = "AND (sv{$fn}x1.value BETWEEN " . implode(' AND ', $v) . ")";
  951.                     $fn++;
  952.                 }
  953.                 /*if(is_array($value) && isset($value['range'])){
  954.                     foreach($value as $t => $v){
  955.                         if(!empty($v[0]) && !empty($v[1]) && $v[0] != 'undefined' && $v[1] != 'undefined'){
  956.                             $ranges_joins[] = "JOIN p.spec_values sv{$fn}x1 WITH sv{$fn}x1.spec = '" . $spec_id . "'";
  957.                             $ranges_where[] = "AND (sv{$fn}x1.value BETWEEN " . implode(' AND ', $v) . " OR sv{$fn}x1.value = '' OR sv{$fn}x1.value IS NULL)";
  958.                             $fn++;
  959.                         }
  960.                     }
  961.                 }*/
  962.             }
  963.         }
  966.         $linkableproducts = (!empty($_GET['linkableproducts']) ? true : false);
  969.         $search_raw = (!empty($filters['q']) ? (!is_array($filters['q']) ? [$filters['q']] : $filters['q']) : null);
  970.         $visible    = (!empty($filters['visible']) ? $filters['visible'] : null);
  971.         $featured   = (!empty($filters['featured']) ? $filters['featured'] : null);
  972.         $category   = (!empty($filters['category']) ? $filters['category'] : null);
  973.         $relation   = (!empty($filters['relation']) ? $filters['relation'] : null);
  974.         $newproducts = (!empty($filters['newproducts']) ? $filters['newproducts'] : null);
  976.         $search = [];
  977.         if(!empty($search_raw)){
  978.             foreach($search_raw as $sr){
  979.                 $sr = explode(' ', $sr);
  980.                 foreach($sr as $srp){
  981.                     $search[] = $srp;
  982.                 }
  983.             }
  984.         }
  986.         $typeFilter = "((p.type = 0 or p.type = 3 or p.type = 4) or ((p.type = 1 or p.type = 2) and p.child_stock_amount > 0))";
  987.         if(!empty($_GET['linkableproducts']) && (empty($_GET['link']) || $_GET['link'] != 'relations')){
  988.             $visible = false;
  989.             $typeFilter = "((p.type = 0 or p.type = 3 or p.type = 4))";
  990.         }
  994.         $tags = [];
  995.         if(!empty($filters['tags'])){
  996.             $tags = $filters['tags'];
  997.         }
  1000.         $sql = "
  1001.         SELECT p
  1002.         
  1003.         FROM TrinityWebshopBundle:Product p
  1004.         JOIN p.product_link wp
  1005.         " . (!empty($category) && ($category instanceof Category || is_array($category)) ? "LEFT JOIN p.category cp WITH (cp.category = wp.category)" : "") . "
  1006.         " . (!empty($relation) ? "JOIN p.relation_to cp WITH (cp.id = " . $relation->getId() . ")" : "") . "
  1007.         " . (!empty($tags) ? "JOIN p.tags pt WITH (pt.id IN (" . implode(', ', $tags) . "))" : "") . "
  1008.         " . (!empty($ranges_joins) ? implode("\n", $ranges_joins) : "") . "
  1009.         WHERE 1 = 1
  1010.         AND " . ($linkableproducts ? "1 = 1" : "((p.type = 0 and ((p.stock_amount - p.out_of_stock_quantity) > 0 or p.stock = 0 or p.visible_no_stock = 1)) or p.type > 0)") . "
  1011.         AND " . $typeFilter . "
  1012.         " . (!empty($ranges_where) ? implode("\n", $ranges_where) : "") . "
  1013.         ";
  1015.         if(!empty($ignore_ids)){
  1016.             $sql .= "\nAND p.id NOT IN (" . implode(',', $ignore_ids) . ")";
  1017.         }
  1019.         $sql .= "\nAND p.enabled = 1";
  1021.         $s = [];
  1022.         if($search){
  1023.             foreach($search as $q){
  1024.                 $q = str_replace('\'', '_', $q);
  1025.                 if($thisIsFilter){
  1026.                     $s[] = "((p.label LIKE '%" . $q . "%') OR (p.number LIKE '%" . $q . "%') OR (wp.specs LIKE '%" . $q . "%') OR (wp.child_specs LIKE '%" . $q . "%') OR p.extra_search_tags LIKE '%" . $q . "%')";
  1027.                 }else{
  1028.                     $s[] = "((wp.specs LIKE '%" . $q . "%' OR (
  1029.                                                                                 p.label LIKE '%" . $q . "%'
  1030.                                                                             OR
  1031.                                                                                 p.extra_search_tags LIKE '%" . $q . "%'
  1032.                                                                             OR
  1033.                                                                                 p.label_sub LIKE '%" . $q . "%'
  1034.                                                                             OR
  1035.                                                                                 p.compatibility LIKE '%" . $q . "%'
  1036.                                                                             OR
  1037.                                                                                 p.ean LIKE '%" . $q . "%'
  1038.                                                                             OR
  1039.                                                                                 p.number LIKE '%" . $q . "%'
  1040.                                                                             OR
  1041.                                                                                 p.sku LIKE '%" . $q . "%'
  1042.                                                                             )) OR (wp.child_specs LIKE '%" . $q . "%' OR (
  1043.                                                                                 p.label LIKE '%" . $q . "%'
  1044.                                                                             OR
  1045.                                                                                 p.extra_search_tags LIKE '%" . $q . "%'
  1046.                                                                             OR
  1047.                                                                                 p.label_sub LIKE '%" . $q . "%'
  1048.                                                                             OR
  1049.                                                                                 p.compatibility LIKE '%" . $q . "%'
  1050.                                                                             OR
  1051.                                                                                 p.ean LIKE '%" . $q . "%'
  1052.                                                                             OR
  1053.                                                                                 p.number LIKE '%" . $q . "%'
  1054.                                                                             OR
  1055.                                                                                 p.sku LIKE '%" . $q . "%'
  1056.                                                                             )))";
  1057.                 }
  1058.             }
  1059.             $sql .= "\nAND (" . implode(" AND ", $s) . ")";
  1060.         }
  1061.         if($visible){
  1062.             $sql .= "\nAND p.visible = 1";
  1063.         }
  1064.         if($featured){
  1065.             $sql .= "\nAND p.featured = 1";
  1066.         }
  1067.         if ($newproducts) {
  1068.             $sql .= "\nAND p.new = 1";
  1069.             $sql .= "\nAND (p.new_from is null OR p.new_from <= NOW())";
  1070.             $sql .= "\nAND (p.new_till is null OR p.new_till > NOW())";
  1071.         }
  1072.         if($category && $category instanceof Category){
  1073.             $sql .= "\nAND wp.category = " . $category->getId();
  1074.         }
  1075.         if($category && is_array($category)){
  1076.             $sql .= "\nAND wp.category IN (" . implode(', ', $category) . ")";
  1077.         }
  1078.         if($webshop_id && is_numeric($webshop_id)){
  1079.             $sql .= "\nAND wp.webshop = " . $webshop_id;
  1080.         }
  1081.         if(!empty($filters['price']) && is_array($filters['price']) && (!isset($filters['ignore_pricing']) || $filters['ignore_pricing'] == false)){
  1082.             // $sql .= "\nAND ((p.sell_price_incl BETWEEN " . $filters['price'][0] . " AND " . $filters['price'][1] . ") OR p.sell_price_incl < 1)";
  1083.             $sql .= "\nAND ((p.sell_price_incl BETWEEN " . $filters['price'][0] . " AND " . $filters['price'][1] . "))";
  1084.         }
  1086.         $strict_search = [265];
  1088.         if(!empty($filters['filters'])){
  1089.             foreach($filters['filters'] as $spec_id => $value){
  1090.                 if(in_array($spec_id, $sliders) || in_array($spec_id, $sliders_range)){
  1091.                     continue;
  1092.                 }
  1093.                 if(!isset($value['range']) && $spec_id != 'q'){
  1094.                     if(!is_array($value)) $value = [$value];
  1095.                     foreach($value as $t => $v){
  1097.                         $v = str_replace('\'', '_', $v);
  1099.                         $v = json_encode($v);
  1101.                         $v = str_replace('"', '', $v);
  1103.                         $v = str_replace('\\', '\\\\', $v);
  1105.                         if(in_array($spec_id, $strict_search) || $thisIsFilter){
  1106.                             $sql .= "\nAND (((wp.specs LIKE '%\"" . $spec_id . "\":%' AND (wp.specs LIKE '%\"" . $v . "\"%'))) OR ((wp.child_specs LIKE '%\"" . $spec_id . "\":%' AND (wp.child_specs LIKE '%\"" . $v . "\"%'))))";
  1107.                         }else{
  1108.                             $sql .= "\nAND (((wp.specs LIKE '%\"" . $spec_id . "\":%' AND (wp.specs LIKE '%\"%" . $v . "%\"%' OR wp.specs LIKE '%," . $v . "%' OR wp.specs LIKE '%" . $v . ",%')) OR (
  1109.                                                                         p.label LIKE '%" . $v . "%'
  1110.                                                                     OR
  1111.                                                                         p.extra_search_tags LIKE '%" . $v . "%'
  1112.                                                                     OR
  1113.                                                                         p.label_sub LIKE '%" . $v . "%'
  1114.                                                                     OR
  1115.                                                                         p.compatibility LIKE '%" . $v . "%'
  1116.                                                                     OR
  1117.                                                                         p.ean LIKE '%" . $v . "%'
  1118.                                                                     OR
  1119.                                                                         p.number LIKE '%" . $v . "%'
  1120.                                                                     OR
  1121.                                                                         p.sku LIKE '%" . $v . "%'
  1122.                                                                     )) OR ((wp.child_specs LIKE '%\"" . $spec_id . "\":%' AND (wp.child_specs LIKE '%\"%" . $v . "%\"%' OR wp.child_specs LIKE '%," . $v . "%' OR wp.child_specs LIKE '%" . $v . ",%')) OR (
  1123.                                                                         p.label LIKE '%" . $v . "%'
  1124.                                                                     OR
  1125.                                                                         p.extra_search_tags LIKE '%" . $v . "%'
  1126.                                                                     OR
  1127.                                                                         p.label_sub LIKE '%" . $v . "%'
  1128.                                                                     OR
  1129.                                                                         p.compatibility LIKE '%" . $v . "%'
  1130.                                                                     OR
  1131.                                                                         p.ean LIKE '%" . $v . "%'
  1132.                                                                     OR
  1133.                                                                         p.number LIKE '%" . $v . "%'
  1134.                                                                     OR
  1135.                                                                         p.sku LIKE '%" . $v . "%'
  1136.                                                                     )))";
  1137.                         }
  1138.                     }
  1139.                 }
  1140.             }
  1141.         }
  1144.         /*foreach($search as $v){
  1145.             $sql .= "\nAND ";
  1146.         }*/
  1149.         $sql_order = 'wp.pos asc'; // Default
  1150.         $custom_order = false;
  1151.         if(!empty($order)){
  1152.             if(substr($order, 0, 3) == 'pos'){
  1153.                 if(preg_match('/asc|desc/', strtolower($order))){
  1154.                     $sql_order = "cp." . $order;
  1155.                 }else{
  1156.                     $sql_order = "cp." . $order . " " . $orderDir;
  1157.                 }
  1158.                 if (!str_contains($order, 'price_incl')) {
  1159.                     $sql_order .= " , cp.id " . $orderDir;
  1160.                 }
  1161.             }else{
  1162.                 if(preg_match('/asc|desc/', strtolower($order))){
  1163.                     $sql_order = "p." . $order;
  1164.                 }else{
  1165.                     $sql_order = "p." . $order . " " . $orderDir;
  1166.                 }
  1167.                 if (!str_contains($order, 'price_incl')) {
  1168.                     $sql_order .= ", p.id " . $orderDir;
  1169.                 }
  1170.                 $custom_order = true;
  1171.             }
  1172.         }
  1174.         if(!$custom_order && empty($category)){
  1175.             $sql_order = "p.id desc";
  1176.         }
  1178.         $sql_order = str_replace('cp.pos', 'wp.pos', $sql_order);
  1180.         if(!empty($filters['q']) && $sql_order == 'cp.pos asc'){
  1181.             $fq = explode(' ', $filters['q']);
  1182.             $sql_order = "";
  1183.             foreach($fq as $fqp){
  1184.                 if(empty($sql_order)){
  1185.                     $sql_order .= "FIND_IN_SET('" . $fqp . "', p.label)";
  1186.                 }else{
  1187.                     $sql_order .= ",FIND_IN_SET('" . $fqp . "', p.label)";
  1188.                 }
  1189.             }
  1190.         }
  1192.         // $sql .= "\nGROUP BY p.id";
  1193.         $sql .= "\nORDER BY " . $sql_order;
  1194.         // dump($sql);die();
  1196. /*if(isset($filters['dev']) && $filters['dev'] == true){
  1197.     dump($sql);die();
  1198. }*/
  1200. // dump($sql);die();
  1202.         if (!empty($relation)) {
  1203.             /*dump($sql);die();
  1204.             $query = $em->createQuery($sql);
  1205.             echo ( '<pre>' . print_r( SqlFormatter::format($query->getSql()), 1 ) . '</pre>' );
  1206.             dump(count($query->getResult()));
  1207.             die();*/
  1208.         }
  1210.         // dump($sql);die();
  1211.         /*$query = $em->createQuery($sql);
  1212.         echo ( '<pre>' . print_r( SqlFormatter::format($query->getSql()), 1 ) . '</pre>' );
  1213.         dump(count($query->getResult()));
  1214.         die();*/
  1219. // dump($sql);die();
  1224.         $query = $em->createQuery($sql);
  1228. // die($query->getSql());
  1229.         if($debug){
  1230.             die($query->getSql());
  1231.         }
  1257.         // $em = $this->getEntityManager();
  1258.         /*$sql = "SELECT p
  1259.                 FROM TrinityWebshopBundle:Product p
  1260.                 " . implode("\n", $join) . "
  1261.                 " . implode("\n", $joinNorForCount) . "
  1262.                 " . ($Webshop ? "JOIN c.webshop w WITH w.id = " . $webshop_id : "") . "
  1263.                 WHERE p.id > 0
  1264.                 AND p.enabled = 1
  1265.                 AND 
  1266.                 (
  1267.                     (
  1268.                         (p.type = 1 OR p.type = 2)
  1269.                         " . implode("\n", $filterValuesLinked) . "
  1270.                     )
  1271.                     OR
  1272.                     (
  1273.                         (p.type != 1 AND p.type != 2)
  1274.                         " . implode("\n", $filterValuesSimple) . "
  1275.                     )
  1276.                 )
  1277.                 AND c.label != 'Ongesorteerd'
  1278.                 " . ($featured ? "AND p.featured = 1" : "") . "
  1279.                 " . (!$ignoreStock ? "
  1280.                 AND ((p.type = 0 and ((p.stock_amount - p.out_of_stock_quantity) > 0 or p.stock = 0 or p.visible_no_stock = 1)) or p.type > 0)
  1281.                 AND ((p.type = 0 or p.type = 3 or p.type = 4) or ((p.type = 1 or p.type = 2) and p.child_stock_amount > 0))
  1282.                 " : "") . 
  1283.                                 (!empty($and) ? "
  1284.                                 AND
  1285.                                 (
  1286.                                 " . implode("\nAND ", $and) . "
  1287.                                 )
  1288.                 " : '') .
  1289.                                 (!empty($or) ? "
  1290.                                 AND
  1291.                                 (
  1292.                                 " .  implode("\nOR ", $or) . "
  1293.                                 )
  1294.                 " : '') 
  1295.                                 . (!empty($specFilter) ? "AND (" . implode("\nOR ", $specFilter) . ")" : "") . "
  1296.                 ORDER BY " . (!empty($order) ? (substr($order, 0, 3) == 'pos' ? "cp." . $order : "p." . $order) : "cp.pos asc");
  1297.         $query = $em->createQuery($sql);*/
  1299.         if(!empty($page)){
  1300.             $start = (($page * $limit) - $limit);
  1301.         }else if(!empty($filters['limit'])){
  1302.             $start = (int)$filters['limit']['start'];
  1303.             $limit = (int)$filters['limit']['limit'];
  1304.         }
  1306.         if($offset > 0){
  1307.             $start = $offset;
  1308.         }
  1310.         if($noLimit == false){
  1311.             $query->setMaxResults($limit)->setFirstResult($start);
  1312.         }
  1316.         // Doctrine Paginator experiment
  1317.         $results = new \Doctrine\ORM\Tools\Pagination\Paginator($query, $fetchJoinCollection = true);
  1318.         // $results->setUseOutputWalkers(false);
  1319.         $total = count($results);
  1320.         $resultCount = count($results->getIterator()->getArrayCopy());
  1322.         $results = $results->getIterator()->getArrayCopy();
  1324.         
  1325.         if(!empty($filters['filters'])){
  1326.             // Walk through filtered results
  1327.             foreach($results as $k => $res){
  1328.                 // Only for grouped or configurable products
  1329.                 if($res->getType() > 0){
  1330.                     // Walk through linked products
  1331.                     foreach($res->getLinkedProducts() as $lp){
  1332.                         // See if spec values are given to product
  1333.                         if($lp->getSpecValues()->count() > 0){
  1334.                             // Walk through spec values
  1335.                             foreach($lp->getSpecValues() as $sv){
  1336.                                 $Spec = $sv->getSpec();
  1337.                                 if($Spec){
  1338.                                     try {
  1339.                                         // Limit product display on colors
  1340.                                         if($Spec->getType() == 'color' || $Spec->getCode() == 'color'){
  1341.                                             if(array_key_exists($Spec->getId(), $filters['filters'])){
  1342.                                                 // If color matches the filtered colors
  1343.                                                 if(in_array($sv->getValue(), $filters['filters'][$Spec->getId()])){
  1344.                                                     // Set linked product as display product
  1345.                                                     $results[$k]->setDisplayProduct($lp);
  1346.                                                     break(3);
  1347.                                                 }
  1348.                                             }
  1349.                                         }
  1350.                                     } catch (\Exception $ex) {
  1351.                                         //dump($ex);
  1352.                                     }
  1353.                                 }
  1354.                             }
  1355.                         }
  1356.                     }
  1357.                 }
  1358.             }
  1359.         }
  1361.         return [
  1362.             'total'   => $total,
  1363.             'current' => $resultCount,
  1364.             'start'   => $start,
  1365.             'limit'   => $limit,
  1366.             'pages'   => (int)ceil($total / $limit),
  1367.             'page'    => (int)$page,
  1368.             'results' => $results
  1369.         ];
  1370.     }
  1372.     public function searchInApi($Webshop, $filters = array(), $order = null, $orderDir = 'asc', $noLimit = false, $ignoreStock = false, $page = 1, $limit = 9, $offset = 0, $thisIsFilter = false){
  1373.         $em = $this->getEntityManager();
  1375.         if(isset($filters['q']) && is_array($filters['q'])){
  1376.             $filters['q'] = implode(' ', $filters['q']);
  1377.         }
  1378.         if(isset($filters['q']) && strpos($filters['q'], 'linkableproducts') !== false){
  1379.             $ignoreStock = true;
  1380.         }
  1382.         $featured = (!empty($filters['featured']) && $filters['featured'] === true);
  1384.         $debug = false;
  1385.         if(isset($filters['debug'])){
  1386.             $debug = true;
  1387.             unset($filters['debug']);
  1388.         }
  1391.         $join = [];
  1392.         $joinNorForCount = [];
  1393.         $and = [];
  1394.         $or = [];
  1396.         $start = 0;
  1398.         if(empty($limit) || !is_numeric($limit)){
  1399.             $limit = 9; // 9 is default, can be overridden in Trinity
  1400.         }
  1402.         // Check category
  1403.         if(isset($filters['page']) && $page <= 1){
  1404.             $page = (int)$filters['page'];
  1405.         }
  1407.         $webshop_id = (!empty($Webshop) ? $Webshop->getId() : 0);
  1410.         $ignore_ids = [];
  1411.         if(!empty($filters['ignore_ids'])){
  1412.             $ignore_ids = $filters['ignore_ids'];
  1413.             if(!is_array($ignore_ids)){
  1414.                 $ignore_ids = [$ignore_ids];
  1415.             }
  1416.             unset($filters['ignore_ids']);
  1417.         }
  1422.         $showHidden = false;
  1423.         if(!empty($filters['q'])){
  1424.             if(preg_match('/linkableproducts=1/', $filters['q'])){
  1425.                 $filters['q'] = preg_replace('/&linkableproducts=1/', '', $filters['q']);
  1426.                 $showHidden = true;
  1427.             }
  1428.         }
  1452.         $ranges       = [];
  1453.         $ranges_joins = [];
  1454.         $ranges_where = [];
  1455.         $fn = 0;
  1457.         if(!empty($filters['filters'])){
  1458.             foreach($filters['filters'] as $spec_id => $value){
  1459.                 if(is_array($value) && isset($value['range'])){
  1460.                     foreach($value as $t => $v){
  1461.                         if(!empty($v[0]) && !empty($v[1]) && $v[0] != 'undefined' && $v[1] != 'undefined'){
  1462.                             $ranges_joins[] = "JOIN p.spec_values sv{$fn}x1 WITH sv{$fn}x1.spec = '" . $spec_id . "'";
  1463.                             $ranges_where[] = "AND (sv{$fn}x1.value BETWEEN " . implode(' AND ', $v) . " OR sv{$fn}x1.value = '' OR sv{$fn}x1.value IS NULL)";
  1464.                             $fn++;
  1465.                         }
  1466.                     }
  1467.                 }
  1468.             }
  1469.         }
  1476.         $sliders = (!empty($filters['sliders']) ? $filters['sliders'] : []);
  1477.         $sliders_range = (!empty($filters['sliders_range']) ? $filters['sliders_range'] : []);
  1480.         if(!empty($filters['filters'])){
  1481.             foreach($filters['filters'] as $spec_id => $value){
  1482.                 if(in_array($spec_id, $sliders) && (int)$value[0] > 0){
  1483.                     $v = [0, (int)$value[0]];
  1484.                     $ranges_joins[] = "JOIN p.spec_values sv{$fn}x1 WITH sv{$fn}x1.spec = '" . $spec_id . "'";
  1485.                     $ranges_where[] = "AND (sv{$fn}x1.value BETWEEN " . implode(' AND ', $v) . ")";
  1486.                     $fn++;
  1487.                 }
  1488.                 if(in_array($spec_id, $sliders_range)){
  1489.                     $v = [(int)$value['min'], (int)$value['max']];
  1490.                     $ranges_joins[] = "JOIN p.spec_values sv{$fn}x1 WITH sv{$fn}x1.spec = '" . $spec_id . "'";
  1491.                     $ranges_where[] = "AND (sv{$fn}x1.value BETWEEN " . implode(' AND ', $v) . ")";
  1492.                     $fn++;
  1493.                 }
  1494.                 /*if(is_array($value) && isset($value['range'])){
  1495.                     foreach($value as $t => $v){
  1496.                         if(!empty($v[0]) && !empty($v[1]) && $v[0] != 'undefined' && $v[1] != 'undefined'){
  1497.                             $ranges_joins[] = "JOIN p.spec_values sv{$fn}x1 WITH sv{$fn}x1.spec = '" . $spec_id . "'";
  1498.                             $ranges_where[] = "AND (sv{$fn}x1.value BETWEEN " . implode(' AND ', $v) . " OR sv{$fn}x1.value = '' OR sv{$fn}x1.value IS NULL)";
  1499.                             $fn++;
  1500.                         }
  1501.                     }
  1502.                 }*/
  1503.             }
  1504.         }
  1507.         $linkableproducts = (!empty($_GET['linkableproducts']) ? true : false);
  1510.         $search_raw = (!empty($filters['q']) ? (!is_array($filters['q']) ? [$filters['q']] : $filters['q']) : null);
  1511.         $visible    = (!empty($filters['visible']) ? $filters['visible'] : null);
  1512.         $featured   = (!empty($filters['featured']) ? $filters['featured'] : null);
  1513.         $category   = (!empty($filters['category']) ? $filters['category'] : null);
  1514.         $relation   = (!empty($filters['relation']) ? $filters['relation'] : null);
  1515.         $newproducts = (!empty($filters['newproducts']) ? $filters['newproducts'] : null);
  1517.         $search = [];
  1518.         if(!empty($search_raw)){
  1519.             foreach($search_raw as $sr){
  1520.                 $sr = explode(' ', $sr);
  1521.                 foreach($sr as $srp){
  1522.                     $search[] = $srp;
  1523.                 }
  1524.             }
  1525.         }
  1527.         $typeFilter = "((p.type = 0 or p.type = 3 or p.type = 4) or ((p.type = 1 or p.type = 2) and p.child_stock_amount > 0))";
  1528.         if(!empty($_GET['linkableproducts']) && (empty($_GET['link']) || $_GET['link'] != 'relations')){
  1529.             $visible = false;
  1530.             $typeFilter = "((p.type = 0 or p.type = 3 or p.type = 4))";
  1531.         }
  1535.         $tags = [];
  1536.         if(!empty($filters['tags'])){
  1537.             $tags = $filters['tags'];
  1538.         }
  1541.         $sql = "
  1542.         SELECT p
  1543.         
  1544.         FROM TrinityWebshopBundle:Product p
  1545.         JOIN p.product_link wp
  1546.         " . (!empty($category) && ($category instanceof Category || is_array($category)) ? "JOIN p.category cp WITH (cp.category = wp.category)" : "") . "
  1547.         " . (!empty($relation) ? "JOIN p.relation_to cp WITH (cp.id = " . $relation->getId() . ")" : "") . "
  1548.         " . (!empty($tags) ? "JOIN p.tags pt WITH (pt.id IN (" . implode(', ', $tags) . "))" : "") . "
  1549.         " . (!empty($ranges_joins) ? implode("\n", $ranges_joins) : "") . "
  1550.         WHERE 1 = 1
  1551.         AND " . ($linkableproducts ? "1 = 1" : "((p.type = 0 and ((p.stock_amount - p.out_of_stock_quantity) > 0 or p.stock = 0 or p.visible_no_stock = 1)) or p.type > 0)") . "
  1552.         AND " . $typeFilter . "
  1553.         " . (!empty($ranges_where) ? implode("\n", $ranges_where) : "") . "
  1554.         ";
  1556.         if(!empty($ignore_ids)){
  1557.             $sql .= "\nAND p.id NOT IN (" . implode(',', $ignore_ids) . ")";
  1558.         }
  1560.         $s = [];
  1561.         if($search){
  1562.             foreach($search as $q){
  1563.                 $q = str_replace('\'', '_', $q);
  1564.                 if($thisIsFilter){
  1565.                     $s[] = "((p.label LIKE '%" . $q . "%') OR (p.number LIKE '%" . $q . "%') OR (wp.specs LIKE '%" . $q . "%') OR (wp.child_specs LIKE '%" . $q . "%') OR p.extra_search_tags LIKE '%" . $q . "%')";
  1566.                 }else{
  1567.                     $s[] = "((wp.specs LIKE '%" . $q . "%' OR (
  1568.                                                                                 p.label LIKE '%" . $q . "%'
  1569.                                                                             OR
  1570.                                                                                 p.extra_search_tags LIKE '%" . $q . "%'
  1571.                                                                             OR
  1572.                                                                                 p.label_sub LIKE '%" . $q . "%'
  1573.                                                                             OR
  1574.                                                                                 p.compatibility LIKE '%" . $q . "%'
  1575.                                                                             OR
  1576.                                                                                 p.ean LIKE '%" . $q . "%'
  1577.                                                                             OR
  1578.                                                                                 p.number LIKE '%" . $q . "%'
  1579.                                                                             OR
  1580.                                                                                 p.sku LIKE '%" . $q . "%'
  1581.                                                                             )) OR (wp.child_specs LIKE '%" . $q . "%' OR (
  1582.                                                                                 p.label LIKE '%" . $q . "%'
  1583.                                                                             OR
  1584.                                                                                 p.extra_search_tags LIKE '%" . $q . "%'
  1585.                                                                             OR
  1586.                                                                                 p.label_sub LIKE '%" . $q . "%'
  1587.                                                                             OR
  1588.                                                                                 p.compatibility LIKE '%" . $q . "%'
  1589.                                                                             OR
  1590.                                                                                 p.ean LIKE '%" . $q . "%'
  1591.                                                                             OR
  1592.                                                                                 p.number LIKE '%" . $q . "%'
  1593.                                                                             OR
  1594.                                                                                 p.sku LIKE '%" . $q . "%'
  1595.                                                                             )))";
  1596.                 }
  1597.             }
  1598.             $sql .= "\nAND (" . implode(" AND ", $s) . ")";
  1599.         }
  1600.         if($visible){
  1601.             $sql .= "\nAND p.visible = 1";
  1602.         }
  1603.         if($featured){
  1604.             $sql .= "\nAND p.featured = 1";
  1605.         }
  1606.         if ($newproducts) {
  1607.             $sql .= "\nAND p.new = 1";
  1608.             $sql .= "\nAND (p.new_from is null OR p.new_from <= NOW())";
  1609.             $sql .= "\nAND (p.new_till is null OR p.new_till > NOW())";
  1610.         }
  1611.         if($category && $category instanceof Category){
  1612.             $sql .= "\nAND wp.category = " . $category->getId();
  1613.         }
  1614.         if($category && is_array($category)){
  1615.             $sql .= "\nAND wp.category IN (" . implode(', ', $category) . ")";
  1616.         }
  1617.         if($webshop_id && is_numeric($webshop_id)){
  1618.             $sql .= "\nAND wp.webshop = " . $webshop_id;
  1619.         }
  1620.         if(!empty($filters['price']) && is_array($filters['price']) && (!isset($filters['ignore_pricing']) || $filters['ignore_pricing'] == false)){
  1621.             // $sql .= "\nAND ((p.sell_price_incl BETWEEN " . $filters['price'][0] . " AND " . $filters['price'][1] . ") OR p.sell_price_incl < 1)";
  1622.             $sql .= "\nAND ((p.sell_price_incl BETWEEN " . $filters['price'][0] . " AND " . $filters['price'][1] . "))";
  1623.         }
  1625.         $strict_search = [265];
  1627.         if(!empty($filters['filters'])){
  1628.             foreach($filters['filters'] as $spec_id => $value){
  1629.                 if(in_array($spec_id, $sliders) || in_array($spec_id, $sliders_range)){
  1630.                     continue;
  1631.                 }
  1632.                 if(!isset($value['range']) && $spec_id != 'q'){
  1633.                     if(!is_array($value)) $value = [$value];
  1634.                     foreach($value as $t => $v){
  1636.                         $v = str_replace('\'', '_', $v);
  1638.                         if(in_array($spec_id, $strict_search) || $thisIsFilter){
  1639.                             $sql .= "\nAND (((wp.specs LIKE '%\"" . $spec_id . "\":%' AND (wp.specs LIKE '%\"" . $v . "\"%'))) OR ((wp.child_specs LIKE '%\"" . $spec_id . "\":%' AND (wp.child_specs LIKE '%\"" . $v . "\"%'))))";
  1640.                         }else{
  1641.                             $sql .= "\nAND (((wp.specs LIKE '%\"" . $spec_id . "\":%' AND (wp.specs LIKE '%\"%" . $v . "%\"%' OR wp.specs LIKE '%," . $v . "%' OR wp.specs LIKE '%" . $v . ",%')) OR (
  1642.                                                                         p.label LIKE '%" . $v . "%'
  1643.                                                                     OR
  1644.                                                                         p.extra_search_tags LIKE '%" . $v . "%'
  1645.                                                                     OR
  1646.                                                                         p.label_sub LIKE '%" . $v . "%'
  1647.                                                                     OR
  1648.                                                                         p.compatibility LIKE '%" . $v . "%'
  1649.                                                                     OR
  1650.                                                                         p.ean LIKE '%" . $v . "%'
  1651.                                                                     OR
  1652.                                                                         p.number LIKE '%" . $v . "%'
  1653.                                                                     OR
  1654.                                                                         p.sku LIKE '%" . $v . "%'
  1655.                                                                     )) OR ((wp.child_specs LIKE '%\"" . $spec_id . "\":%' AND (wp.child_specs LIKE '%\"%" . $v . "%\"%' OR wp.child_specs LIKE '%," . $v . "%' OR wp.child_specs LIKE '%" . $v . ",%')) OR (
  1656.                                                                         p.label LIKE '%" . $v . "%'
  1657.                                                                     OR
  1658.                                                                         p.extra_search_tags LIKE '%" . $v . "%'
  1659.                                                                     OR
  1660.                                                                         p.label_sub LIKE '%" . $v . "%'
  1661.                                                                     OR
  1662.                                                                         p.compatibility LIKE '%" . $v . "%'
  1663.                                                                     OR
  1664.                                                                         p.ean LIKE '%" . $v . "%'
  1665.                                                                     OR
  1666.                                                                         p.number LIKE '%" . $v . "%'
  1667.                                                                     OR
  1668.                                                                         p.sku LIKE '%" . $v . "%'
  1669.                                                                     )))";
  1670.                         }
  1671.                     }
  1672.                 }
  1673.             }
  1674.         }
  1677.         /*foreach($search as $v){
  1678.             $sql .= "\nAND ";
  1679.         }*/
  1682.         $sql_order = 'cp.pos asc'; // Default
  1683.         $custom_order = false;
  1684.         if(!empty($order)){
  1685.             if(substr($order, 0, 3) == 'pos'){
  1686.                 if(preg_match('/asc|desc/', strtolower($order))){
  1687.                     $sql_order = "cp." . $order;
  1688.                 }else{
  1689.                     $sql_order = "cp." . $order . " " . $orderDir;
  1690.                 }
  1691.                 if (!str_contains($order, 'price_incl')) {
  1692.                     $sql_order .= " , cp.id " . $orderDir;
  1693.                 }
  1694.             }else{
  1695.                 if(preg_match('/asc|desc/', strtolower($order))){
  1696.                     $sql_order = "p." . $order;
  1697.                 }else{
  1698.                     $sql_order = "p." . $order . " " . $orderDir;
  1699.                 }
  1700.                 if (!str_contains($order, 'price_incl')) {
  1701.                     $sql_order .= ", p.id " . $orderDir;
  1702.                 }
  1703.                 $custom_order = true;
  1704.             }
  1705.         }
  1707.         if(!$custom_order && empty($category)){
  1708.             $sql_order = "p.id desc";
  1709.         }
  1711.         if(!empty($filters['q']) && $sql_order == 'cp.pos asc'){
  1712.             $fq = explode(' ', $filters['q']);
  1713.             $sql_order = "";
  1714.             foreach($fq as $fqp){
  1715.                 if(empty($sql_order)){
  1716.                     $sql_order .= "FIND_IN_SET('" . $fqp . "', p.label)";
  1717.                 }else{
  1718.                     $sql_order .= ",FIND_IN_SET('" . $fqp . "', p.label)";
  1719.                 }
  1720.             }
  1721.         }
  1723.         // $sql .= "\nGROUP BY p.id";
  1724.         $sql .= "\nORDER BY " . $sql_order;
  1725.         // dump($sql);die();
  1727. /*if(isset($filters['dev']) && $filters['dev'] == true){
  1728.     dump($sql);die();
  1729. }*/
  1731. // dump($sql);die();
  1733.         if (!empty($relation)) {
  1734.             /*dump($sql);die();
  1735.             $query = $em->createQuery($sql);
  1736.             echo ( '<pre>' . print_r( SqlFormatter::format($query->getSql()), 1 ) . '</pre>' );
  1737.             dump(count($query->getResult()));
  1738.             die();*/
  1739.         }
  1741.         // dump($sql);die();
  1742.         /*$query = $em->createQuery($sql);
  1743.         echo ( '<pre>' . print_r( SqlFormatter::format($query->getSql()), 1 ) . '</pre>' );
  1744.         dump(count($query->getResult()));
  1745.         die();*/
  1750. // dump($sql);die();
  1755.         $query = $em->createQuery($sql);
  1759. // die($query->getSql());
  1760.         if($debug){
  1761.             die($query->getSql());
  1762.         }
  1788.         // $em = $this->getEntityManager();
  1789.         /*$sql = "SELECT p
  1790.                 FROM TrinityWebshopBundle:Product p
  1791.                 " . implode("\n", $join) . "
  1792.                 " . implode("\n", $joinNorForCount) . "
  1793.                 " . ($Webshop ? "JOIN c.webshop w WITH w.id = " . $webshop_id : "") . "
  1794.                 WHERE p.id > 0
  1795.                 AND p.enabled = 1
  1796.                 AND 
  1797.                 (
  1798.                     (
  1799.                         (p.type = 1 OR p.type = 2)
  1800.                         " . implode("\n", $filterValuesLinked) . "
  1801.                     )
  1802.                     OR
  1803.                     (
  1804.                         (p.type != 1 AND p.type != 2)
  1805.                         " . implode("\n", $filterValuesSimple) . "
  1806.                     )
  1807.                 )
  1808.                 AND c.label != 'Ongesorteerd'
  1809.                 " . ($featured ? "AND p.featured = 1" : "") . "
  1810.                 " . (!$ignoreStock ? "
  1811.                 AND ((p.type = 0 and ((p.stock_amount - p.out_of_stock_quantity) > 0 or p.stock = 0 or p.visible_no_stock = 1)) or p.type > 0)
  1812.                 AND ((p.type = 0 or p.type = 3 or p.type = 4) or ((p.type = 1 or p.type = 2) and p.child_stock_amount > 0))
  1813.                 " : "") . 
  1814.                                 (!empty($and) ? "
  1815.                                 AND
  1816.                                 (
  1817.                                 " . implode("\nAND ", $and) . "
  1818.                                 )
  1819.                 " : '') .
  1820.                                 (!empty($or) ? "
  1821.                                 AND
  1822.                                 (
  1823.                                 " .  implode("\nOR ", $or) . "
  1824.                                 )
  1825.                 " : '') 
  1826.                                 . (!empty($specFilter) ? "AND (" . implode("\nOR ", $specFilter) . ")" : "") . "
  1827.                 ORDER BY " . (!empty($order) ? (substr($order, 0, 3) == 'pos' ? "cp." . $order : "p." . $order) : "cp.pos asc");
  1828.         $query = $em->createQuery($sql);*/
  1830.         if(!empty($page)){
  1831.             $start = (($page * $limit) - $limit);
  1832.         }else if(!empty($filters['limit'])){
  1833.             $start = (int)$filters['limit']['start'];
  1834.             $limit = (int)$filters['limit']['limit'];
  1835.         }
  1837.         if($offset > 0){
  1838.             $start = $offset;
  1839.         }
  1841.         if($noLimit == false){
  1842.             $query->setMaxResults($limit)->setFirstResult($start);
  1843.         }
  1847.         // Doctrine Paginator experiment
  1848.         $results = new \Doctrine\ORM\Tools\Pagination\Paginator($query, $fetchJoinCollection = true);
  1849.         // $results->setUseOutputWalkers(false);
  1850.         $total = count($results);
  1851.         $resultCount = count($results->getIterator()->getArrayCopy());
  1853.         $results = $results->getIterator()->getArrayCopy();
  1855.         
  1856.         if(!empty($filters['filters'])){
  1857.             // Walk through filtered results
  1858.             foreach($results as $k => $res){
  1859.                 // Only for grouped or configurable products
  1860.                 if($res->getType() > 0){
  1861.                     // Walk through linked products
  1862.                     foreach($res->getLinkedProducts() as $lp){
  1863.                         // See if spec values are given to product
  1864.                         if($lp->getSpecValues()->count() > 0){
  1865.                             // Walk through spec values
  1866.                             foreach($lp->getSpecValues() as $sv){
  1867.                                 $Spec = $sv->getSpec();
  1868.                                 if($Spec){
  1869.                                     try {
  1870.                                         // Limit product display on colors
  1871.                                         if($Spec->getType() == 'color' || $Spec->getCode() == 'color'){
  1872.                                             if(array_key_exists($Spec->getId(), $filters['filters'])){
  1873.                                                 // If color matches the filtered colors
  1874.                                                 if(in_array($sv->getValue(), $filters['filters'][$Spec->getId()])){
  1875.                                                     // Set linked product as display product
  1876.                                                     $results[$k]->setDisplayProduct($lp);
  1877.                                                     break(3);
  1878.                                                 }
  1879.                                             }
  1880.                                         }
  1881.                                     } catch (\Exception $ex) {
  1882.                                         //dump($ex);
  1883.                                     }
  1884.                                 }
  1885.                             }
  1886.                         }
  1887.                     }
  1888.                 }
  1889.             }
  1890.         }
  1892.         return [
  1893.             'total'   => $total,
  1894.             'current' => $resultCount,
  1895.             'start'   => $start,
  1896.             'limit'   => $limit,
  1897.             'pages'   => (int)ceil($total / $limit),
  1898.             'page'    => (int)$page,
  1899.             'results' => $results
  1900.         ];
  1901.     }
  1903.     public function getOneBy($slug = '', $Webshop, $Category = null){
  1904.         $em = $this->getEntityManager();
  1905.         $query = $this->createQueryBuilder('p')
  1906.             ->innerJoin('p.category', 'c')
  1907.             ->innerJoin('c.webshop', 'wp')
  1908.             ->where('wp.id = :webshopid')
  1909.             ->setParameter('webshopid', (!empty($Webshop) ? (!empty($Webshop) ? $Webshop->getId() : 0) : 0));
  1911.         if(!empty($slug)) $query->andWhere('p.slug = \'' . $slug . '\'');
  1913.         if($Category instanceof \App\Trinity\WebshopBundle\Entity\Category){
  1914.             $query->andWhere('c.id = :categoryid')
  1915.             ->setParameter('categoryid', $Category->getId());
  1916.         }
  1918.         return $query->getQuery()->getSingleResult();
  1919.     }
  1921.     public function gatherProducts($cats){
  1922.         $em = $this->getEntityManager();
  1923.         $sql = "SELECT    cp
  1924.                 FROM    TrinityWebshopBundle:CategoryProduct cp
  1925.                 JOIN     cp.category c
  1926.                 WHERE     c.id IN (" . implode(', ', $cats) . ")";
  1927.         $query = $em->createQuery($sql);
  1928.         return $query->getResult();
  1929.     }
  1931.     public function recentlyChanged($Webshop, $limit = 4){
  1932.         $em = $this->getEntityManager();
  1934.         // $query = $em->createQuery("SELECT ph.date,a as Product FROM TrinityWebshopBundle:ProductHistory ph JOIN TrinityWebshopBundle:Product a WITH ph.Product = a JOIN a.category cp JOIN cp.category c WHERE (ph.label LIKE '%gewijzigd%') AND c.webshop = " . (!empty($Webshop) ? $Webshop->getId() : 0) . " GROUP BY ph.Product ORDER BY ph.date DESC");
  1935.         $query = $em->createQuery("SELECT ph.date,a as Product FROM TrinityWebshopBundle:ProductHistory ph JOIN TrinityWebshopBundle:Product a WITH ph.Product = a JOIN a.category cp JOIN cp.category c WHERE (ph.label LIKE '%gewijzigd%') AND c.webshop = " . (!empty($Webshop) ? $Webshop->getId() : 0) . " ORDER BY ph.date DESC");
  1936.         return $query->setMaxResults($limit)->getResult();
  1937.     }
  1939.     public function recentlyAdded($Webshop, $limit = 4){
  1940.         $em = $this->getEntityManager();
  1942.         // $query = $em->createQuery("SELECT ph.date,a as Product FROM TrinityWebshopBundle:ProductHistory ph JOIN TrinityWebshopBundle:Product a WITH ph.Product = a JOIN a.category cp JOIN cp.category c WHERE (ph.label LIKE '%geïmporteerd%' OR ph.label LIKE '%toegevoegd%') AND c.webshop = " . (!empty($Webshop) ? $Webshop->getId() : 0) . " GROUP BY ph.Product ORDER BY ph.date DESC");
  1943.         $query = $em->createQuery("SELECT ph.date,a as Product FROM TrinityWebshopBundle:ProductHistory ph JOIN TrinityWebshopBundle:Product a WITH ph.Product = a JOIN a.category cp JOIN cp.category c WHERE (ph.label LIKE '%geïmporteerd%' OR ph.label LIKE '%toegevoegd%') AND c.webshop = " . (!empty($Webshop) ? $Webshop->getId() : 0) . " ORDER BY ph.date DESC");
  1944.         return $query->setMaxResults($limit)->getResult();
  1945.     }
  1947.     public function recentReviews($Webshop, $limit = 4){
  1948.         $em = $this->getEntityManager();
  1950.         $query = $em->createQuery("SELECT r FROM TrinityWebshopBundle:Review r JOIN r.product p JOIN p.category cp JOIN cp.category c WHERE c.webshop = " . (!empty($Webshop) ? $Webshop->getId() : 0) . " GROUP BY r.id ORDER BY r.date DESC");
  1951.         return $query->setMaxResults($limit)->getResult();
  1952.     }
  1954.     public function getReviewsByWebshop($Webshop){
  1955.         $em = $this->getEntityManager();
  1957.         $query = $em->createQuery("SELECT r FROM TrinityWebshopBundle:Review r JOIN r.product p JOIN p.category cp JOIN cp.category c WHERE c.webshop = " . (!empty($Webshop) ? $Webshop->getId() : 0) . " GROUP BY r.id ORDER BY r.date DESC");
  1958.         return $query->getResult();
  1959.     }
  1961.     public function bestSold($Webshop, $limit = 4){
  1962.         $em = $this->getEntityManager();
  1964.         $query = $em->createQuery("SELECT p as Product, COUNT(op.id) AS num FROM TrinityWebshopBundle:Product p JOIN TrinityWebshopBundle:OrderProduct op WITH op.product = p GROUP BY p.id ORDER BY num DESC");
  1965.         return $query->setMaxResults($limit)->getResult();
  1966.     }
  1968.     public function discounted($Webshop, $limit = 4){
  1969.         $list = [];
  1970.         $em = $this->getEntityManager();
  1971.         $sql = "SELECT        p
  1972.                 FROM        TrinityWebshopBundle:Product p
  1973.                 JOIN        p.promotions pm
  1974.                 WHERE        (
  1975.                                 pm.date_start IS NULL
  1976.                             OR
  1977.                                 pm.date_start <= '" . date('Y-m-d H:i:s') . "'
  1978.                             )
  1979.                 AND            (
  1980.                                 pm.date_end IS NULL
  1981.                             OR
  1982.                                 pm.date_end >= '" . date('Y-m-d H:i:s') . "'
  1983.                             )
  1984.                 GROUP BY    p.id
  1985.                 ";
  1986.         $query = $em->createQuery($sql);
  1987.         $list = $query->setMaxResults($limit)->getResult();
  1989.         if(count($list) < $limit){
  1990.             $sql = "SELECT        p
  1991.                     FROM        TrinityWebshopBundle:Product p
  1992.                     JOIN        p.category c
  1993.                     JOIN        c.promotions pm
  1994.                     WHERE        (
  1995.                                     pm.date_start IS NULL
  1996.                                 OR
  1997.                                     pm.date_start <= '" . date('Y-m-d H:i:s') . "'
  1998.                                 )
  1999.                     AND            (
  2000.                                     pm.date_end IS NULL
  2001.                                 OR
  2002.                                     pm.date_end >= '" . date('Y-m-d H:i:s') . "'
  2003.                                 )
  2004.                     AND c.webshop = " . (!empty($Webshop) ? $Webshop->getId() : 0) . "
  2005.                     GROUP BY    p.id
  2006.                     ";
  2007.             $query = $em->createQuery($sql);
  2008.             $list = array_merge($list, $query->setMaxResults($limit - count($list))->getResult());
  2009.         }
  2011.         return $list;
  2012.     }
  2014.     public function getByWebshop($Webshop){
  2015.         $em = $this->getEntityManager();
  2016.         $query = $em->createQuery(
  2017.             'SELECT p
  2018.             FROM TrinityWebshopBundle:Product p
  2019.             JOIN p.category cp
  2020.             JOIN cp.category c
  2021.             JOIN c.webshop w
  2022.             WHERE w.id LIKE :webshopid'
  2023.         )->setParameter('webshopid', (!empty($Webshop) ? $Webshop->getId() : 0));
  2025.         return $query->getResult();
  2026.     }
  2028.     public function getByDiscounted($Webshop, $limit = 9){
  2029.         $sql = "SELECT p
  2030.                 FROM TrinityWebshopBundle:Product p
  2031.                 JOIN p.category cp
  2032.                 JOIN cp.category c
  2033.                 JOIN c.webshop w
  2034.                 WHERE w.id LIKE :webshopid
  2035.                 AND p.enabled = 1
  2036.                 AND p.visible = 1
  2037.                 AND p.discount = 1
  2038.                 ORDER BY p.label ASC";
  2039.                 echo ( '<pre>' . print_r( $sql, 1 ) . '</pre>' );
  2040.         $em = $this->getEntityManager();
  2041.         $query = $em->createQuery($sql)
  2042.         ->setParameter('webshopid', (!empty($Webshop) ? $Webshop->getId() : 0));
  2043.         $query->setMaxResults($limit);
  2045.         return $query->getResult();
  2046.     }
  2048.     public function findLowStock(){
  2049.         $em = $this->getEntityManager();
  2050.         $query = $em->createQuery(
  2051.             "
  2052.             SELECT p
  2053.             FROM TrinityWebshopBundle:Product p
  2054.             WHERE p.stock = 1
  2055.             AND p.stock_amount < p.notify_on_stock_below
  2056.             "
  2057.         );
  2059.         return $query->getResult();
  2060.     }
  2062.     public function findSimpleForLinking($Webshop, $q){
  2063.         $em = $this->getEntityManager();
  2064.         $query = $em->createQuery(
  2065.             '
  2066.             SELECT p
  2067.             FROM TrinityWebshopBundle:Product p
  2068.             JOIN p.category cp
  2069.             JOIN cp.category c
  2070.             JOIN c.webshop w
  2071.             WHERE w.id LIKE :webshopid
  2072.             AND p.label LIKE \'%' . $q . '%\'
  2073.             AND p.type = 0
  2074.             '
  2075.         )->setParameter('webshopid', (!empty($Webshop) ? $Webshop->getId() : 0));
  2077.         return $query->getResult();
  2078.     }
  2080.     public function findByLabelInWebshop($Webshop, $label){
  2081.         $em = $this->getEntityManager();
  2082.         $query = $em->createQuery(
  2083.             'SELECT p
  2084.             FROM TrinityWebshopBundle:Product p
  2085.             JOIN p.category cp
  2086.             JOIN cp.category c
  2087.             JOIN c.webshop w
  2088.             WHERE w.id LIKE :webshopid
  2089.             AND p.label LIKE :label'
  2090.         )
  2091.         ->setParameter('webshopid', (!empty($Webshop) ? $Webshop->getId() : 0))
  2092.         ->setParameter('label', $label);
  2094.         return $query->getOneOrNullResult();
  2095.     }
  2097.     /**
  2098.      * Count unlinked products (likely after language value added to product)
  2099.      *
  2100.      * @return integer
  2101.      */
  2102.     public function countUnlinked(){
  2103.         $sql = "SELECT  COUNT(P)
  2104.                 FROM    TrinityWebshopBundle:Product AS P
  2105.                 WHERE   P.language IS NULL
  2106.                 ";
  2107.         return (int)$this->getEntityManager()->createQuery($sql)->getSingleScalarResult();
  2108.     }
  2110.     /**
  2111.      * Count unlinked products (likely after language value added to product)
  2112.      *
  2113.      * @return integer
  2114.      */
  2115.     public function countReviews($product_id, $page, $perpage, $moderate = false){
  2116.         $sql = "SELECT  COUNT(R)
  2117.                 FROM    TrinityWebshopBundle:Review AS R
  2118.                 WHERE   R.product = " . $product_id . "
  2119.                 AND     R.parent IS NULL
  2120.                 " . ($moderate ? "AND R.moderated = 1" : '') . "
  2121.                 ";
  2122.         return (int)$this->getEntityManager()->createQuery($sql)->getSingleScalarResult();
  2123.     }
  2125.     /**
  2126.      * Count unlinked products (likely after language value added to product)
  2127.      *
  2128.      * @return integer
  2129.      */
  2130.     public function fetchReviews($product_id, $page, $perpage, $moderate = false){
  2131.         $sql = "SELECT  R
  2132.                 FROM    TrinityWebshopBundle:Review AS R
  2133.                 WHERE   R.product = " . $product_id . "
  2134.                 AND     R.parent IS NULL
  2135.                 " . ($moderate ? "AND R.moderated = 1" : '') . "
  2136.                 ORDER BY R.date DESC
  2137.                 ";
  2138.         $query = $this->getEntityManager()->createQuery($sql);
  2139.         $query->setMaxResults($perpage);
  2140.         $query->setFirstResult(($page * $perpage) - $perpage);
  2142.         return $query->getResult();
  2143.     }
  2145.     /**
  2146.      * Get product labels based on base and optional parent ID
  2147.      *
  2148.      * @return array
  2149.      */
  2150.     public function findLabelsByBase($webshop_id, $base_id, $parent_id = null){
  2151.         $sql = "SELECT      GROUP_CONCAT(CONCAT(P.id,'|',P.label)) AS list,GROUP_CONCAT(CONCAT(P.id,'|',R.id)) AS relations
  2152.                 FROM        TrinityWebshopBundle:Product AS P
  2153.                 LEFT JOIN    P.relation_to R
  2154.                 WHERE       P.webshop = " . $webshop_id . "
  2155.                 AND         P.base = " . $base_id . "
  2156.                 ORDER BY    P.label ASC
  2157.                 ";
  2158. // dump($sql);
  2159.         $query = $this->getEntityManager()->createQuery($sql);
  2160.         $result = $query->getResult();
  2161. // dump($result);die();
  2162.         $return = [];
  2163.         if(!empty($result[0]['list'])){
  2164.             $return_raw = explode(',', $result[0]['list']);
  2165.             foreach($return_raw as $r){
  2166.                 $r = explode('|', $r);
  2167.                 $return[$r[0]] = ['label' => $r[1], 'relation' => null];
  2168.             }
  2169.         }
  2170.         if(!empty($result[0]['relations'])){
  2171.             $return_raw = explode(',', $result[0]['relations']);
  2172.             foreach($return_raw as $r){
  2173.                 $r = explode('|', $r);
  2174.                 if(!empty($return[$r[0]])){
  2175.                     $return[$r[0]]['relation'] = $r[1];
  2176.                 }
  2177.             }
  2178.         }
  2180.         // dump($return);die();
  2182.         return $return;
  2183.     }
  2185. }