src/Repository/ProduitDeclinationValueRepository.php line 204

Open in your IDE?
  1. <?php
  3. namespace App\Repository;
  5. use App\Entity\ProduitDeclinationValue;
  6. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  7. use Doctrine\Persistence\ManagerRegistry;
  8. use App\Entity\ValueDeclination;
  10. /**
  11.  * @method ProduitDeclinationValue|null find($id, $lockMode = null, $lockVersion = null)
  12.  * @method ProduitDeclinationValue|null findOneBy(array $criteria, array $orderBy = null)
  13.  * @method ProduitDeclinationValue[]    findAll()
  14.  * @method ProduitDeclinationValue[]    findBy(array $criteria, array $orderBy = null, $limit = null, $offset = null)
  15.  */
  16. class ProduitDeclinationValueRepository extends ServiceEntityRepository
  17. {
  18.     public function __construct(ManagerRegistry $registry)
  19.     {
  20.         parent::__construct($registry, ProduitDeclinationValue::class);
  21.     }
  23.     
  24. public function findProduitGroup(
  25.         $page,
  26.         $limit,
  27.         int $idProduit,
  28.         ?string $reference,
  29.         array $declinations = [],   // [declinationId => valueId|valueId[]]
  30.         bool $withDeleted = false
  31.     ) {
  32.         $qb = $this->createQueryBuilder('p')
  33.             ->leftJoin('p.produit', 'pp')
  34.             ->andWhere('pp.id = :produit')->setParameter('produit', $idProduit);
  36.         if ($reference) {
  37.             $qb->andWhere('UPPER(p.reference) LIKE :reference')
  38.             ->setParameter('reference', '%'.mb_strtoupper($reference).'%');
  39.         }
  41.         // AND entre chaque declination
  42.         $i = 0;
  43.         foreach ($declinations as $declId => $val) {
  44.             if ($val === null || $val === '' || $val === [] ) { continue; }
  45.             $i++;
  46.             $alias = 'gdv'.$i;
  47.             $paramDecl = 'd'.$i;
  48.             $paramVal  = 'v'.$i;
  50.             $vals = is_array($val) ? array_values(array_unique($val)) : [ (int)$val ];
  52.             // innerJoin = critĂšre obligatoire
  53.             $qb->innerJoin('p.groupDeclinationValues', $alias, 'WITH',
  54.                 $alias.'.declination = :'.$paramDecl.' AND '.$alias.'.value IN (:'.$paramVal.')'
  55.             )
  56.             ->setParameter($paramDecl, (int)$declId)
  57.             ->setParameter($paramVal, $vals);
  58.         }
  60.         if (!$withDeleted) {
  61.             $qb->andWhere('pp.deletedAt IS NULL');
  62.         }
  64.         $qb->orderBy('p.reference', 'ASC');
  66.         if ($page !== false) {
  67.             $qb->setMaxResults($limit)
  68.             ->setFirstResult($page * $limit);
  69.         }
  71.         return $qb->getQuery()->getResult();
  72.     }
  74.     public function countProduitGroup(
  75.         int $idProduit,
  76.         ?string $reference,
  77.         array $declinations = [],   // [declinationId => valueId|valueId[]]
  78.         bool $withDeleted = false
  79.     ) {
  80.         $qb = $this->createQueryBuilder('p')
  81.             ->select('COUNT(p)')
  82.             ->leftJoin('p.produit', 'pp')
  83.             ->andWhere('pp.id = :produit')->setParameter('produit', $idProduit);
  85.         if ($reference) {
  86.             $qb->andWhere('UPPER(p.reference) LIKE :reference')
  87.             ->setParameter('reference', '%'.mb_strtoupper($reference).'%');
  88.         }
  90.         $i = 0;
  91.         foreach ($declinations as $declId => $val) {
  92.             if ($val === null || $val === '' || $val === [] ) { continue; }
  93.             $i++;
  94.             $alias = 'gdv'.$i;
  95.             $paramDecl = 'd'.$i;
  96.             $paramVal  = 'v'.$i;
  98.             $vals = is_array($val) ? array_values(array_unique($val)) : [ (int)$val ];
  100.             $qb->innerJoin('p.groupDeclinationValues', $alias, 'WITH',
  101.                 $alias.'.declination = :'.$paramDecl.' AND '.$alias.'.value IN (:'.$paramVal.')'
  102.             )
  103.             ->setParameter($paramDecl, (int)$declId)
  104.             ->setParameter($paramVal, $vals);
  105.         }
  107.         if (!$withDeleted) {
  108.             $qb->andWhere('pp.deletedAt IS NULL');
  109.         }
  111.         return (int)$qb->getQuery()->getSingleScalarResult();
  112.     }
  114.     public function searchItem($query,$isAvailable=false,$maxResult=5,$withDeleted=false) {
  116.         $qb = $this->createQueryBuilder('p');
  117.         $qb->select('p.id, p.name, p.reference, p.description, p.price_ht, p.buyingPriceTtc')
  118.                 ->innerJoin("p.produit", "pp")
  119.                 ->addSelect("pp.unit As unit")
  120.                 ->leftJoin("pp.tva", "pptva")
  121.                 ->addSelect("pptva.id As tva_id")
  122.                 ->addSelect("pptva.number As tva")
  123.                 ->where('UPPER(p.name) LIKE :name')->setParameter('name', '%' . strtoupper($query) . '%')
  124.                 ->orWhere('UPPER(p.reference) LIKE :reference')->setParameter('reference', '%' . strtoupper($query) . '%')
  125.                 ->andWhere('pp.deletedAt IS NULL');
  126.         $qb->leftJoin('p.stocks','s');
  127.         if($isAvailable) $qb->andWhere('(s.qtStock - s.qtReserved) >= 1');
  128.         $qb->orderBy('p.createdAt', 'DESC');
  129.         $qb->setMaxResults($maxResult);
  130.         return $qb->getQuery()->getResult();
  131.     }
  132.     
  133.   
  134.     public function searchAndCountProduitDeclinations(
  135.         int $page,
  136.         int $limit,
  137.         $reference,
  138.         $name,
  139.         $categories,
  140.         array $declinationFilters = [],
  141.         $isAvailable,
  142.         $inPromo,
  143.         $qtMin = null,
  144.         $qtMax = null,
  145.         $buyingPriceMin = null,
  146.         $buyingPriceMax = null,
  147.         $priceMin = null,
  148.         $priceMax = null,
  149.         string $sortField = 'createdAt',
  150.         string $sortType = 'DESC',
  151.         bool $withDeleted = false
  152.     ): array {
  154.         /* ===============================
  155.         1) QueryBuilder de base
  156.         =============================== */
  157.         $qb = $this->createQueryBuilder('p');
  159.         $this->QueryBuilderSearch(
  160.             $qb,
  161.             $reference,
  162.             $name,
  163.             $categories,
  164.             $declinationFilters,
  165.             $isAvailable,
  166.             $inPromo,
  167.             $qtMin,
  168.             $qtMax,
  169.             $buyingPriceMin,
  170.             $buyingPriceMax,
  171.             $priceMin,
  172.             $priceMax,
  173.             $withDeleted
  174.         );
  176.         /* ===============================
  177.         2) COUNT (clone)
  178.         =============================== */
  179.         $qbCount = clone $qb;
  180.         $total = (int) $qbCount
  181.             ->select('COUNT(DISTINCT p.id)')
  182.             ->resetDQLPart('orderBy')
  183.             ->getQuery()
  184.             ->getSingleScalarResult();
  186.         /* ===============================
  187.         3) RESULTS (clone)
  188.         =============================== */
  189.         $qbResult = clone $qb;
  191.         $qbResult
  192.             ->orderBy(($sortField === 'qtStock' ? '' : 'p.') . $sortField, $sortType)
  193.             ->setFirstResult($page * $limit)
  194.             ->setMaxResults($limit);
  196.         $data = $qbResult->getQuery()->getResult();
  198.         return [
  199.             'data'  => $data,
  200.             'total' => $total,
  201.         ];
  202.     }
  204.     public function searchProduitDeclinations(
  205.         $page, 
  206.         $limit, 
  207.         $reference, 
  208.         $name, 
  209.         $categories, 
  210.         array $declinationFilters = [],
  211.         $isAvailable, 
  212.         $inPromo, 
  213.         $qtMin = null, 
  214.         $qtMax = null, 
  215.         $buyingPriceMin = null, 
  216.         $buyingPriceMax = null, 
  217.         $priceMin = null, 
  218.         $priceMax = null, 
  219.         $sortField = 'createdAt', 
  220.         $sortType = 'DESC', 
  221.         $withDeleted = false
  222.     ) {
  223.         $qb = $this->createQueryBuilder('p');
  224.         $qb = $this->QueryBuilderSearch(
  225.             $qb, 
  226.             $reference, 
  227.             $name, 
  228.             $categories, 
  229.             $declinationFilters, 
  230.             $isAvailable, 
  231.             $inPromo, 
  232.             $qtMin, 
  233.             $qtMax, 
  234.             $buyingPriceMin, 
  235.             $buyingPriceMax, 
  236.             $priceMin, 
  237.             $priceMax, 
  238.             $withDeleted
  239.         );
  241.         $qb->orderBy(($sortField === 'qtStock' ? '' : 'p.') . $sortField, $sortType);
  243.         if ($page !== false) $qb->setMaxResults($limit)->setFirstResult($page * $limit);
  245.         return $qb->getQuery()->getResult();
  246.     }
  248.     public function countProduitDeclinations(
  249.             $reference, 
  250.             $name, 
  251.             $categories, 
  252.             array $declinationFilters = [],
  253.             $isAvailable, 
  254.             $inPromo, 
  255.             $qtMin = null, 
  256.             $qtMax = null, 
  257.             $buyingPriceMin = null, 
  258.             $buyingPriceMax = null, 
  259.             $priceMin = null, 
  260.             $priceMax = null, 
  261.             $withDeleted = false
  262.         ) {
  263.             $qb = $this->createQueryBuilder('p');
  264.             $qb->select('COUNT(p)');
  266.             $qb = $this->QueryBuilderSearch($qb,  $reference, $name, $categories, $declinationFilters,$isAvailable, $inPromo, $qtMin, $qtMax, $buyingPriceMin, $buyingPriceMax, $priceMin, $priceMax, $withDeleted );
  268.             return $qb->getQuery()->getSingleScalarResult();
  269.         }
  271.     
  272.     /*--Filtre liste declinaisons--*/
  273.     
  275.     private function QueryBuilderSearch($qb,$reference, $name, $categories, array $declinationFilters = [], $isAvailable, $inPromo, $qtMin = null, $qtMax = null,$buyingPriceMin = null, $buyingPriceMax = null, $priceMin = null, $priceMax = null, $withDeleted = false) {
  276.         if ($name) {
  277.             $qb->andWhere('UPPER(p.name) LIKE :name')
  278.             ->setParameter('name', '%' . strtoupper($name) . '%');
  279.         }
  281.         if ($reference) {
  282.             $qb->andWhere('UPPER(p.reference) LIKE :reference')
  283.             ->setParameter('reference', strtoupper($reference) . '%');
  284.         }
  286.         // đŸ” Filtres dynamiques sur les dĂ©clinaisons
  287.                
  288.         foreach ($declinationFilters as $declinationId => $valueId) {
  290.             if (empty($valueId)) {
  291.                 continue;
  292.             }
  294.             $alias = 'gdv_' . (int)$declinationId;
  296.             $qb
  297.                 ->innerJoin('p.groupDeclinationValues', $alias)
  298.                 ->andWhere($alias . '.declination = :decl_' . $declinationId)
  299.                 ->andWhere($alias . '.value = :val_' . $declinationId)
  300.                 ->setParameter('decl_' . $declinationId, (int)$declinationId)
  301.                 ->setParameter('val_' . $declinationId, (int)$valueId);
  302.         }
  305.         // đŸ” Stock
  306.         $qb->leftJoin('p.stocks', 's');
  307.         if ($isAvailable !== "") {
  308.             if ($isAvailable) {
  309.                 $qb->andWhere('(s.qtStock - s.qtReserved) >= 1');
  310.             } else {
  311.                 $qb->andWhere('(s.qtStock - s.qtReserved) <= 0');
  312.             }
  313.         }
  315.         // đŸ” Produit
  316.         $qb->leftJoin('p.produit', 'pp');
  318.         if ($categories) {
  319.             $qb->leftJoin('pp.categories', 'ppc')
  320.             ->andWhere('ppc.id = :categories')
  321.             ->setParameter('categories', $categories);
  322.         }
  324.         if ($inPromo !== "") {
  325.             if ($inPromo == '1') {
  326.                 $qb->join('pp.promotion', 'promo')
  327.                 ->andWhere(':now >= promo.startAt')
  328.                 ->andWhere(':now <= promo.endAt')
  329.                 ->setParameter('now', new \DateTime('now'));
  330.             } elseif ($inPromo == '0') {
  331.                 $qb->andWhere('pp.promotion IS NULL');
  332.             }
  333.         }
  335.         // đŸ” Prix
  336.         if ($buyingPriceMin) $qb->andWhere('pp.buyingPriceTtc >= :buyingPriceMin')->setParameter('buyingPriceMin', $buyingPriceMin);
  337.         if ($buyingPriceMax) $qb->andWhere('pp.buyingPriceTtc <= :buyingPriceMax')->setParameter('buyingPriceMax', $buyingPriceMax);
  338.         if ($priceMin)       $qb->andWhere('pp.price_ttc >= :priceMin')->setParameter('priceMin', $priceMin);
  339.         if ($priceMax)       $qb->andWhere('pp.price_ttc <= :priceMax')->setParameter('priceMax', $priceMax);
  341.         // đŸ” QuantitĂ©
  342.         if ($qtMin) $qb->andWhere('s.qtStock >= :qtMin')->setParameter('qtMin', $qtMin);
  343.         if ($qtMax) $qb->andWhere('s.qtStock <= :qtMax')->setParameter('qtMax', $qtMax);
  345.         // đŸ” Suppression
  346.         $qb->andWhere('pp.deletedAt IS ' . ($withDeleted ? 'NOT' : '') . ' NULL');
  348.         return $qb;
  349.     }
  351.     public function findDeclinationValueWithDeclination($idDeclination, $idProduit) {
  352.         $qb = $this->createQueryBuilder('p');
  353.         $qb->leftJoin('p.produit', 'pp')->andWhere('pp.deletedAt IS NULL')
  354.                 ->andWhere('pp.id = :produit')->setParameter('produit', $idProduit);
  355.         $qb->leftJoin('p.groupDeclinationValues', 'pgc')
  356.                ->leftJoin('pgc.declination', 'pgcd')
  357.                ->leftJoin('pgc.value', 'pgcv')
  358.                ->andWhere('pgcv.id = :idDeclination')->setParameter('idDeclination', $idDeclination );
  359.         $qb->orderBy('p.reference', 'ASC');
  360.         return $qb->getQuery()->getResult();
  361.     }
  363.     
  365.     public function qtyAvailable($prdDec)
  366.     {
  367.         $qb = $this->createQueryBuilder('p');
  368.         $qb->leftJoin('p.stocks','s')
  369.             ->Select('(s.qtStock - s.qtReserved) as qtAvailable')
  370.             ->where('p.id = :id')
  371.             ->setParameter('id', $prdDec->getId());
  372.         dd($qb->getQuery()->getSingleScalarResult());
  374.     }
  375.     public function qtyReserved($prdDec)
  376.     {
  377.         $qb = $this->createQueryBuilder('p');
  378.         $qb->leftJoin('p.stocks','s')
  379.             ->Select('s.qtReserved as qtReserved')
  380.             ->where('p.id = :id')
  381.             ->setParameter('id', $prdDec->getId());
  382.         dd($qb->getQuery()->getSingleScalarResult());
  384.     }
  386.     //fonction et requĂȘte pour dĂ©clinaion 1 (Exemple : Couleur)
  387.    public function getStatsByDeclinationPosition($idProduit, ?string $dateBefore, ?string $dateAfter): array
  388.     {
  389.         $conn = $this->getEntityManager()->getConnection();
  391.         $sql = "
  392.             SELECT 
  393.                 dcl.name AS declinaison_label,
  394.                 v.name AS valeur,
  396.                 (
  397.                     SELECT f.image_name
  398.                     FROM produit_declination_value_file pdf
  399.                     JOIN file f ON f.id = pdf.file_id
  400.                     WHERE pdf.produit_declination_value_id = pdv.id
  401.                     LIMIT 1
  402.                 ) AS decli_image,
  404.                 SUM(ddp.quantity) AS qtTotal,
  405.                 SUM(CASE WHEN d.status NOT IN ('annule', 'retourne', 'retour-en-cours') THEN ddp.quantity ELSE 0 END) AS qtVendu,
  406.                 SUM(CASE WHEN d.status = 'annule' THEN ddp.quantity ELSE 0 END) AS qtAnnulee,
  407.                 SUM(CASE WHEN d.status IN ('retourne', 'retour-en-cours') THEN ddp.quantity ELSE 0 END) AS qtRetour,
  408.                 SUM(ddp.total_amount_ttc) AS montantTotal
  410.             FROM document_declination_produit ddp
  411.             JOIN produit_declination_value pdv ON ddp.produit_declination_value_id = pdv.id
  412.             JOIN group_declination_value gdv ON gdv.produit_declination_id = pdv.id
  413.             JOIN value_declination v ON v.id = gdv.value_id
  414.             JOIN declination dcl ON dcl.id = v.declination_id AND dcl.position = 1
  415.             JOIN document d ON d.id = ddp.document_id
  417.             WHERE pdv.produit_id = :idProduit
  418.             AND d.type = 'commande'
  419.             AND d.category = 'client'
  420.         ";
  422.         $params = ['idProduit' => $idProduit];
  424.         if ($dateBefore && $dateAfter) {
  425.             $sql .= " AND d.created_at BETWEEN :dateBefore AND :dateAfter";
  426.             $params['dateBefore'] = $dateBefore;
  427.             $params['dateAfter']  = $dateAfter;
  428.         } elseif ($dateBefore) {
  429.             $sql .= " AND d.created_at >= :dateBefore";
  430.             $params['dateBefore'] = $dateBefore;
  431.         } elseif ($dateAfter) {
  432.             $sql .= " AND d.created_at <= :dateAfter";
  433.             $params['dateAfter'] = $dateAfter;
  434.         }
  436.         $sql .= "
  437.             GROUP BY dcl.name, v.name
  438.             ORDER BY qtTotal DESC
  439.         ";
  441.         $stmt = $conn->prepare($sql);
  442.         $result = $stmt->executeQuery($params);
  444.         return $result->fetchAllAssociative();
  445.     }
  448.     //fonction et requĂȘte pour toutes les dĂ©clinaisons
  449.     public function getAllDeclinationsStats($idProduit, ?string $dateBefore, ?string $dateAfter): array
  450. {
  451.     $conn = $this->getEntityManager()->getConnection();
  453.     $sql = "
  454.         SELECT 
  455.             dcl1.name AS declinaison1_label,
  456.             v1.name   AS declinaison1_valeur,
  457.             pdv.id    AS decli_id,
  459.             -- DĂ©clinaison 2 (ex : Taille)
  460.             dcl2.name AS declinaison2_label,
  461.             v2.name   AS declinaison2_valeur,
  463.             -- Totaux
  464.             SUM(ddp.quantity) AS qtTotal,
  465.             SUM(
  466.                 CASE 
  467.                     WHEN d.status NOT IN ('annule', 'retourne', 'retour-en-cours') 
  468.                     THEN ddp.quantity 
  469.                     ELSE 0 
  470.                 END
  471.             ) AS qtVendu,
  472.             SUM(
  473.                 CASE 
  474.                     WHEN d.status = 'annule' 
  475.                     THEN ddp.quantity 
  476.                     ELSE 0 
  477.                 END
  478.             ) AS qtAnnulee,
  479.             SUM(
  480.                 CASE 
  481.                     WHEN d.status IN ('retourne', 'retour-en-cours') 
  482.                     THEN ddp.quantity 
  483.                     ELSE 0 
  484.                 END
  485.             ) AS qtRetour,
  486.             SUM(ddp.total_amount_ttc) AS montantTotal
  488.         FROM document_declination_produit ddp
  489.         JOIN produit_declination_value pdv 
  490.             ON ddp.produit_declination_value_id = pdv.id
  492.         -- DĂ©clinaison 1 (ex : Couleur)
  493.         JOIN group_declination_value gdv1 
  494.             ON gdv1.produit_declination_id = pdv.id
  495.         JOIN value_declination v1 
  496.             ON v1.id = gdv1.value_id
  497.         JOIN declination dcl1 
  498.             ON dcl1.id = v1.declination_id 
  499.            AND dcl1.position = 1
  501.         -- DĂ©clinaison 2 (ex : Taille)
  502.         JOIN group_declination_value gdv2 
  503.             ON gdv2.produit_declination_id = pdv.id
  504.         JOIN value_declination v2 
  505.             ON v2.id = gdv2.value_id
  506.         JOIN declination dcl2 
  507.             ON dcl2.id = v2.declination_id
  508.            AND dcl2.position = 2
  510.         JOIN document d 
  511.             ON d.id = ddp.document_id
  513.         WHERE pdv.produit_id = :idProduit
  514.           AND d.type = 'commande'
  515.           AND d.category = 'client'
  516.     ";
  518.     $params = ['idProduit' => $idProduit];
  520.     /* Gestion dynamique des dates */
  521.     if ($dateBefore !== null && $dateAfter !== null) {
  522.         $sql .= " AND d.created_at BETWEEN :dateBefore AND :dateAfter";
  523.         $params['dateBefore'] = $dateBefore;
  524.         $params['dateAfter']  = $dateAfter;
  525.     } elseif ($dateBefore !== null) {
  526.         $sql .= " AND d.created_at >= :dateBefore";
  527.         $params['dateBefore'] = $dateBefore;
  528.     } elseif ($dateAfter !== null) {
  529.         $sql .= " AND d.created_at <= :dateAfter";
  530.         $params['dateAfter'] = $dateAfter;
  531.     }
  533.     $sql .= "
  534.         GROUP BY dcl1.name, v1.name, v2.name, pdv.id
  535.         ORDER BY v1.name ASC, v2.name ASC
  536.     ";
  538.     $stmt   = $conn->prepare($sql);
  539.     $result = $stmt->executeQuery($params);
  541.     return $result->fetchAllAssociative();
  542. }
  546.     public function countByValue(ValueDeclination $value): int
  547.     {
  548.         return $this->createQueryBuilder('gdv')
  549.             ->select('COUNT(gdv.id)')
  550.             ->where('gdv.value = :val')
  551.             ->setParameter('val', $value)
  552.             ->getQuery()
  553.             ->getSingleScalarResult();
  554.     }
  558. }