src/Eccube/Repository/ProductRepository.php line 104

Open in your IDE?
  1. <?php
  3. namespace Eccube\Repository;
  5. use Doctrine\Common\Collections\ArrayCollection;
  6. use Doctrine\Persistence\ManagerRegistry as RegistryInterface;
  7. use Eccube\Common\EccubeConfig;
  8. use Eccube\Doctrine\Query\Queries;
  9. use Eccube\Entity\Category;
  10. use Eccube\Entity\Master\ProductListMax;
  11. use Eccube\Entity\Master\ProductListOrderBy;
  12. use Eccube\Entity\Master\ProductStatus;
  13. use Eccube\Entity\Product;
  14. use Eccube\Entity\ProductStock;
  15. use Eccube\Entity\Tag;
  16. use Eccube\Util\StringUtil;
  17. use Plugin\Recommend42\Entity\RecommendProduct;
  19. /**
  20.  * ProductRepository
  21.  *
  22.  * This class was generated by the Doctrine ORM. Add your own custom
  23.  * repository methods below.
  24.  */
  25. class ProductRepository extends AbstractRepository
  26. {
  27.   /**
  28.    * @var Queries
  29.    */
  30.   protected $queries;
  32.   /**
  33.    * @var EccubeConfig
  34.    */
  35.   protected $eccubeConfig;
  37.   public const COLUMNS = [
  38.     'product_id' => 'p.id', 'name' => 'p.name', 'product_code' => 'pc.code', 'stock' => 'pc.stock', 'status' => 'p.Status', 'create_date' => 'p.create_date', 'update_date' => 'p.update_date',
  39.   ];
  41.   /**
  42.    * ProductRepository constructor.
  43.    *
  44.    * @param RegistryInterface $registry
  45.    * @param Queries $queries
  46.    * @param EccubeConfig $eccubeConfig
  47.    */
  48.   public function __construct(
  49.     RegistryInterface $registry,
  50.     Queries           $queries,
  51.     EccubeConfig      $eccubeConfig
  52.   )
  53.   {
  54.     parent::__construct($registry, Product::class);
  55.     $this->queries = $queries;
  56.     $this->eccubeConfig = $eccubeConfig;
  57.   }
  60.   /**
  61.    * 子カテゴリー一覧をハッシュで取得
  62.    * @param integer $p_id
  63.    * @return hash
  64.    */
  65.   public function getHashStatus()
  66.   {
  67.     $conn = $this->getEntityManager()->getConnection();
  68.     $sql = "SELECT id,product_status_id FROM dtb_product";
  69.     $stmt = $conn->prepare($sql);
  70.     $resultSet = $stmt->executeQuery();
  71.     $rows = $resultSet->fetchAllAssociative();
  72.     $hash = array();
  73.     foreach ($rows as $row) {
  74.       $hash[$row["id"]] = $row["product_status_id"];
  75.     }
  76.     return $hash;
  77.   }
  79.   /**
  80.    * Find the Product with sorted ClassCategories.
  81.    *
  82.    * @param integer $productId
  83.    *
  84.    * @return Product
  85.    */
  86.   public function findWithSortedClassCategories($productId)
  87.   {
  88.     $qb = $this->createQueryBuilder('p');
  89.     $qb->addSelect(['pc', 'cc1', 'cc2', 'pi', 'pt'])
  90.       ->innerJoin('p.ProductClasses', 'pc')
  91.       ->leftJoin('pc.ClassCategory1', 'cc1')
  92.       ->leftJoin('pc.ClassCategory2', 'cc2')
  93.       ->leftJoin('p.ProductImage', 'pi')
  94.       ->leftJoin('p.ProductTag', 'pt')
  95.       ->where('p.id = :id')
  96.       ->andWhere('pc.visible = :visible')
  97.       ->setParameter('id', $productId)
  98.       ->setParameter('visible', true)
  99.       ->orderBy('cc1.sort_no', 'DESC')
  100.       ->addOrderBy('cc2.sort_no', 'DESC');
  102.     $product = $qb
  103.       ->getQuery()
  104.       ->getSingleResult();
  106.     return $product;
  107.   }
  109.   /**
  110.    * Find the Products with sorted ClassCategories.
  111.    *
  112.    * @param array $ids Product in ids
  113.    * @param string $indexBy The index for the from.
  114.    *
  115.    * @return ArrayCollection|array
  116.    */
  117.   public function findProductsWithSortedClassCategories(array $ids, $indexBy = null)
  118.   {
  119.     if (count($ids) < 1) {
  120.       return [];
  121.     }
  122.     $qb = $this->createQueryBuilder('p', $indexBy);
  123.     $qb->addSelect(['pc', 'cc1', 'cc2', 'pi', 'pt', 'tr', 'ps'])
  124.       ->innerJoin('p.ProductClasses', 'pc')
  125.       // XXX Joined 'TaxRule' and 'ProductStock' to prevent lazy loading
  126.       ->leftJoin('pc.TaxRule', 'tr')
  127.       ->innerJoin('pc.ProductStock', 'ps')
  128.       ->leftJoin('pc.ClassCategory1', 'cc1')
  129.       ->leftJoin('pc.ClassCategory2', 'cc2')
  130.       ->leftJoin('p.ProductImage', 'pi')
  131.       ->leftJoin('p.ProductTag', 'pt')
  132.       ->where($qb->expr()->in('p.id', $ids))
  133.       ->andWhere('pc.visible = :visible')
  134.       ->setParameter('visible', true)
  135.       ->orderBy('cc1.sort_no', 'DESC')
  136.       ->addOrderBy('cc2.sort_no', 'DESC');
  138.     $products = $qb
  139.       ->getQuery()
  140.       ->useResultCache(true, $this->eccubeConfig['eccube_result_cache_lifetime_short'])
  141.       ->getResult();
  143.     return $products;
  144.   }
  146.   /**
  147.    * get query builder.
  148.    *
  149.    * @param array{
  150.    *         category_id?:Category,
  151.    *         name?:string,
  152.    *         pageno?:string,
  153.    *         disp_number?:ProductListMax,
  154.    *         orderby?:ProductListOrderBy
  155.    *     } $searchData
  156.    *
  157.    * @return \Doctrine\ORM\QueryBuilder
  158.    */
  159.   public function getQueryBuilderBySearchData($searchData)
  160.   {
  161.     $qb = $this->createQueryBuilder('p')
  162.       ->andWhere('((p.Status = 1) OR (p.Status = 6) OR (p.Status = 8))')
  163.       ->andWhere('p.del_flg = 0');
  165.     // category
  166.     $categoryJoin = false;
  167.     if (!empty($searchData['category_id']) && $searchData['category_id']) {
  168.       $Categories = $searchData['category_id']->getSelfAndDescendants();
  169.       if ($Categories) {
  170.         $qb
  171.           ->innerJoin('p.ProductCategories', 'pct')
  172.           ->innerJoin('pct.Category', 'c')
  173.           ->andWhere($qb->expr()->in('pct.Category', ':Categories'))
  174.           ->setParameter('Categories', $Categories);
  175.         $categoryJoin = true;
  176.       }
  177.     }
  179.     // 複数のカテゴリーに対応
  180.     if (!empty($searchData['c_id']) and is_array($searchData['c_id']) and count($searchData['c_id']) > 0) {
  181.       dump($searchData);exit;
  182.     }
  186.     // name
  187.     if (isset($searchData['name']) && StringUtil::isNotBlank($searchData['name'])) {
  188.       $keywords = preg_split('/[\s　]+/u', str_replace(['%', '_'], ['\\%', '\\_'], $searchData['name']), -1, PREG_SPLIT_NO_EMPTY);
  190.       foreach ($keywords as $index => $keyword) {
  191.         $key = sprintf('keyword%s', $index);
  192.         $qb
  193.           ->andWhere(sprintf('NORMALIZE(p.name) LIKE NORMALIZE(:%s) OR
  194.                         NORMALIZE(p.search_word) LIKE NORMALIZE(:%s) OR
  195.                         EXISTS (SELECT wpc%d FROM \Eccube\Entity\ProductClass wpc%d WHERE p = wpc%d.Product AND NORMALIZE(wpc%d.code) LIKE NORMALIZE(:%s))',
  196.             $key, $key, $index, $index, $index, $index, $key))
  197.           ->setParameter($key, '%' . $keyword . '%');
  198.       }
  199.     }
  201.     // ============================================================
  202.     // 限定商品の除外処理
  203.     // ============================================================
  205.     // 1. カテゴリーベースの限定商品除外（カテゴリーID: 218）
  206.     // 限定カテゴリーの子カテゴリーに属する商品は除外
  207.     // ただし、限定カテゴリーを直接指定した場合は表示
  208.     $genteiCategoryId = 218;
  209.     $isGenteiCategory = false;
  211.     if (!empty($searchData['category_id'])) {
  212.       // 指定カテゴリーが限定カテゴリー(218)またはその子孫かチェック
  213.       $category = $searchData['category_id'];
  214.       if ($category->getId() == $genteiCategoryId) {
  215.         $isGenteiCategory = true;
  216.       } else {
  217.         // 親をたどって限定カテゴリーかチェック
  218.         $parent = $category->getParent();
  219.         while ($parent) {
  220.           if ($parent->getId() == $genteiCategoryId) {
  221.             $isGenteiCategory = true;
  222.             break;
  223.           }
  224.           $parent = $parent->getParent();
  225.         }
  226.       }
  227.     }
  229.     if (!$isGenteiCategory) {
  230.       // 限定カテゴリー以外の場合、限定商品を除外
  231.       $genteiProductIds = $this->getGenteiProductIds($genteiCategoryId);
  232.       if (!empty($genteiProductIds)) {
  233.         $qb->andWhere($qb->expr()->notIn('p.id', ':genteiProductIds'))
  234.            ->setParameter('genteiProductIds', $genteiProductIds);
  235.       }
  236.     }
  238.     // 2. 拡張項目ベースの限定公開除外（column_id: 66）
  239.     // ProductPlusの限定公開URLに値がある商品は除外
  240.     $genteiUrlProductIds = $this->getGenteiUrlProductIds();
  241.     if (!empty($genteiUrlProductIds)) {
  242.       $qb->andWhere($qb->expr()->notIn('p.id', ':genteiUrlProductIds'))
  243.          ->setParameter('genteiUrlProductIds', $genteiUrlProductIds);
  244.     }
  246.     // Order By
  247.     // 価格低い順
  248.     $config = $this->eccubeConfig;
  249.     if (!empty($searchData['orderby']) && $searchData['orderby']->getId() == $config['eccube_product_order_price_lower']) {
  250.       // @see http://doctrine-orm.readthedocs.org/en/latest/reference/dql-doctrine-query-language.html
  251.       $qb->addSelect('MIN(pc.price02) as HIDDEN price02_min');
  252.       $qb->innerJoin('p.ProductClasses', 'pc');
  253.       $qb->andWhere('pc.visible = true');
  254.       $qb->groupBy('p.id');
  255.       $qb->orderBy('price02_min', 'ASC');
  256.       $qb->addOrderBy('p.id', 'DESC');
  257.       // 価格高い順
  258.     } elseif (!empty($searchData['orderby']) && $searchData['orderby']->getId() == $config['eccube_product_order_price_higher']) {
  259.       $qb->addSelect('MAX(pc.price02) as HIDDEN price02_max');
  260.       $qb->innerJoin('p.ProductClasses', 'pc');
  261.       $qb->andWhere('pc.visible = true');
  262.       $qb->groupBy('p.id');
  263.       $qb->orderBy('price02_max', 'DESC');
  264.       $qb->addOrderBy('p.id', 'DESC');
  265.       // 新着順
  266.     } elseif (!empty($searchData['orderby']) && $searchData['orderby']->getId() == $config['eccube_product_order_newer']) {
  267.       // 在庫切れ商品非表示の設定が有効時対応
  268.       // @see https://github.com/EC-CUBE/ec-cube/issues/1998
  269.       if ($this->getEntityManager()->getFilters()->isEnabled('option_nostock_hidden') == true) {
  270.         $qb->innerJoin('p.ProductClasses', 'pc');
  271.         $qb->andWhere('pc.visible = true');
  272.       }
  273.       $qb->orderBy('p.create_date', 'DESC');
  274.       $qb->addOrderBy('p.id', 'DESC');
  275.     } else {
  276.       if ($categoryJoin === false) {
  277.         $qb
  278.           ->leftJoin('p.ProductCategories', 'pct')
  279.           ->leftJoin('pct.Category', 'c');
  280.       }
  281.       $qb
  282.         ->addOrderBy('p.id', 'DESC');
  283.     }
  285.     //dump($qb->getQuery()->getSQL());exit;
  286.     //$all = $qb->getQuery()->getArrayResult();
  287.     //dump($all);exit;
  289.     return $this->queries->customize(QueryKey::PRODUCT_SEARCH, $qb, $searchData);
  290.   }
  292.   /**
  293.    * get query builder.
  294.    *
  295.    * @param array{
  296.    *         id?:string|int|null,
  297.    *         category_id?:Category,
  298.    *         status?:ProductStatus[],
  299.    *         link_status?:ProductStatus[],
  300.    *         stock_status?:int,
  301.    *         stock?:ProductStock::IN_STOCK|ProductStock::OUT_OF_STOCK,
  302.    *         tag_id?:Tag,
  303.    *         create_datetime_start?:\DateTime,
  304.    *         create_datetime_end?:\DateTime,
  305.    *         create_date_start?:\DateTime,
  306.    *         create_date_end?:\DateTime,
  307.    *         update_datetime_start?:\DateTime,
  308.    *         update_datetime_end?:\DateTime,
  309.    *         update_date_start?:\DateTime,
  310.    *         update_date_end?:\DateTime,
  311.    *         sortkey?:string,
  312.    *         sorttype?:string
  313.    *     } $searchData
  314.    *
  315.    * @return \Doctrine\ORM\QueryBuilder
  316.    */
  317.   public function getQueryBuilderBySearchDataForAdmin($searchData)
  318.   {
  320.     $qb = $this->createQueryBuilder('p')
  321.       ->addSelect('pc', 'pi', 'tr', 'ps')
  322.       ->innerJoin('p.ProductClasses', 'pc')
  323.       ->leftJoin('p.ProductImage', 'pi')
  324.       ->leftJoin('pc.TaxRule', 'tr')
  325.       ->leftJoin('pc.ProductStock', 'ps')
  326.       ->andWhere('pc.visible = :visible')
  327.       ->setParameter('visible', true)
  328.       ->andWhere('p.del_flg = 0');
  330.     // id（商品ID・商品名・商品コード・検索ワード・鑑定番号）
  331.     if (isset($searchData['id']) && StringUtil::isNotBlank($searchData['id'])) {
  332.       $id = preg_match('/^\d{0,10}$/', $searchData['id']) ? $searchData['id'] : null;
  333.       if ($id && $id > '2147483647' && $this->isPostgreSQL()) {
  334.         $id = null;
  335.       }
  336.       $qb
  337.         ->andWhere('p.id = :id OR p.name LIKE :likeid OR pc.code LIKE :likeid OR p.search_word LIKE :likeid OR EXISTS (SELECT ppd.id FROM Plugin\ProductPlus42\Entity\ProductData ppd INNER JOIN Plugin\ProductPlus42\Entity\ProductDataDetail ppdd WITH ppdd.ProductData = ppd WHERE ppd.Product = p AND ppd.ProductItem = 2 AND ppdd.value LIKE :likeid)')
  338.         ->setParameter('id', $id)
  339.         ->setParameter('likeid', '%' . str_replace(['%', '_'], ['\\%', '\\_'], $searchData['id']) . '%');
  340.     }
  342.     // 在庫・お預かり・地金型コイン
  343.     // 1. 在庫    = コインパレスの在庫
  344.     // 2. お預かり = お客さまから預かっているコイン
  345.     // 3. 地金型コイン = カテゴリー地金型を含むコイン
  346.     if (!empty($searchData["custody_flg"]) and count($searchData["custody_flg"]) == 1) {
  347.       $custody_flg = $searchData["custody_flg"][0];
  348.       if ($custody_flg == 1) {
  349.         $ids = $this->getStorageCpIds();
  350.         $qb->andWhere($qb->expr()->in('p.id', $ids));
  351.       } elseif ($custody_flg == 2) {
  352.         $ids = $this->getStorageCustIds();
  353.         $qb->andWhere($qb->expr()->in('p.id', $ids));
  354.       }elseif($custody_flg == 3){
  355.         $Categories = array();
  356.         $categoryRepository = $this->getEntityManager()->getRepository(Category::class);
  357.         $Categories[] = $categoryRepository->find("5");
  358.         $qb->innerJoin('p.ProductCategories', 'pct2')
  359.           ->innerJoin('pct2.Category', 'c2')
  360.           ->andWhere($qb->expr()->in('pct2.Category', ':Categories2'))
  361.           ->setParameter('Categories2', $Categories);
  362.       }
  363.     }
  365.     // category
  366.     if (!empty($searchData['category_id']) && $searchData['category_id']) {
  367.       $Categories = $searchData['category_id']->getSelfAndDescendants();
  368.       if ($Categories) {
  369.         $qb
  370.           ->innerJoin('p.ProductCategories', 'pct')
  371.           ->innerJoin('pct.Category', 'c')
  372.           ->andWhere($qb->expr()->in('pct.Category', ':Categories'))
  373.           ->setParameter('Categories', $Categories);
  374.       }
  375.     }
  377.     // status
  378.     if (!empty($searchData['status']) && $searchData['status']) {
  379.       $qb
  380.         ->andWhere($qb->expr()->in('p.Status', ':Status'))
  381.         ->setParameter('Status', $searchData['status']);
  382.     }
  384.     // link_status
  385.     if (isset($searchData['link_status']) && !empty($searchData['link_status'])) {
  386.       $qb
  387.         ->andWhere($qb->expr()->in('p.Status', ':Status'))
  388.         ->setParameter('Status', $searchData['link_status']);
  389.     }
  391.     // stock status
  392.     if (isset($searchData['stock_status'])) {
  393.       $qb
  394.         ->andWhere('pc.stock_unlimited = :StockUnlimited AND pc.stock = 0')
  395.         ->setParameter('StockUnlimited', $searchData['stock_status']);
  396.     }
  398.     // stock status
  399.     if (isset($searchData['stock']) && !empty($searchData['stock'])) {
  400.       switch ($searchData['stock']) {
  401.         case [ProductStock::IN_STOCK]:
  402.           $qb->andWhere('pc.stock_unlimited = true OR pc.stock > 0');
  403.           break;
  404.         case [ProductStock::OUT_OF_STOCK]:
  405.           $qb->andWhere('pc.stock_unlimited = false AND pc.stock <= 0');
  406.           break;
  407.         default:
  408.           // 共に選択された場合は全権該当するので検索条件に含めない
  409.       }
  410.     }
  412.     // tag
  413.     if (!empty($searchData['tag_id']) && $searchData['tag_id']) {
  414.       $qb
  415.         ->innerJoin('p.ProductTag', 'pt')
  416.         ->andWhere('pt.Tag = :tag_id')
  417.         ->setParameter('tag_id', $searchData['tag_id']);
  418.     }
  420.     // crate_date
  421.     if (!empty($searchData['create_datetime_start']) && $searchData['create_datetime_start']) {
  422.       $date = $searchData['create_datetime_start'];
  423.       $qb
  424.         ->andWhere('p.create_date >= :create_date_start')
  425.         ->setParameter('create_date_start', $date);
  426.     } elseif (!empty($searchData['create_date_start']) && $searchData['create_date_start']) {
  427.       $date = $searchData['create_date_start'];
  428.       $qb
  429.         ->andWhere('p.create_date >= :create_date_start')
  430.         ->setParameter('create_date_start', $date);
  431.     }
  433.     if (!empty($searchData['create_datetime_end']) && $searchData['create_datetime_end']) {
  434.       $date = $searchData['create_datetime_end'];
  435.       $qb
  436.         ->andWhere('p.create_date < :create_date_end')
  437.         ->setParameter('create_date_end', $date);
  438.     } elseif (!empty($searchData['create_date_end']) && $searchData['create_date_end']) {
  439.       $date = clone $searchData['create_date_end'];
  440.       $date = $date
  441.         ->modify('+1 days');
  442.       $qb
  443.         ->andWhere('p.create_date < :create_date_end')
  444.         ->setParameter('create_date_end', $date);
  445.     }
  447.     // update_date
  448.     if (!empty($searchData['update_datetime_start']) && $searchData['update_datetime_start']) {
  449.       $date = $searchData['update_datetime_start'];
  450.       $qb
  451.         ->andWhere('p.update_date >= :update_date_start')
  452.         ->setParameter('update_date_start', $date);
  453.     } elseif (!empty($searchData['update_date_start']) && $searchData['update_date_start']) {
  454.       $date = $searchData['update_date_start'];
  455.       $qb
  456.         ->andWhere('p.update_date >= :update_date_start')
  457.         ->setParameter('update_date_start', $date);
  458.     }
  460.     if (!empty($searchData['update_datetime_end']) && $searchData['update_datetime_end']) {
  461.       $date = $searchData['update_datetime_end'];
  462.       $qb
  463.         ->andWhere('p.update_date < :update_date_end')
  464.         ->setParameter('update_date_end', $date);
  465.     } elseif (!empty($searchData['update_date_end']) && $searchData['update_date_end']) {
  466.       $date = clone $searchData['update_date_end'];
  467.       $date = $date
  468.         ->modify('+1 days');
  469.       $qb
  470.         ->andWhere('p.update_date < :update_date_end')
  471.         ->setParameter('update_date_end', $date);
  472.     }
  474.     // Order By
  475.     if (isset($searchData['sortkey']) && !empty($searchData['sortkey'])) {
  476.       $sortOrder = (isset($searchData['sorttype']) && $searchData['sorttype'] == 'a') ? 'ASC' : 'DESC';
  478.       $qb->orderBy(self::COLUMNS[$searchData['sortkey']], $sortOrder);
  479.       $qb->addOrderBy('p.update_date', 'DESC');
  480.       $qb->addOrderBy('p.id', 'DESC');
  481.     } else {
  482.       $qb->orderBy('p.id', 'DESC');
  483.       //$qb->addOrderBy('p.update_date', 'DESC');
  484.     }
  486.     //dump($qb->getQuery()->getSQL());exit;
  487.     //$all = $qb->getQuery()->getArrayResult();
  488.     //dump($all);exit;
  490.     return $this->queries->customize(QueryKey::PRODUCT_SEARCH_ADMIN, $qb, $searchData);
  491.   }
  493.   /**
  494.    * 商品種別（クレジット可否）をハッシュで取得
  495.    * sale_type_id = 3 がクレジット不可商品
  496.    *
  497.    * @return array
  498.    */
  499.   public function getHashType()
  500.   {
  501.     $conn = $this->getEntityManager()->getConnection();
  502.     $sql = <<<SQL
  503. SELECT
  504.     product_id,
  505.     sale_type_id
  506. FROM
  507.     dtb_product_class
  508. WHERE
  509.     visible = 1
  510. SQL;
  511.     $stmt = $conn->prepare($sql);
  512.     $resultSet = $stmt->executeQuery();
  513.     $rows = $resultSet->fetchAllAssociative();
  515.     $hash = array();
  516.     foreach ($rows as $row) {
  517.       $hash[$row['product_id']] = $row['sale_type_id'];
  518.     }
  519.     return $hash;
  520.   }
  522.   /**
  523.    * 地金型コインカテゴリーに属する商品をハッシュで取得
  524.    *
  525.    * @return array
  526.    */
  527.   public function getHashJigane()
  528.   {
  529.     $conn = $this->getEntityManager()->getConnection();
  530.     $sql = <<<SQL
  531. SELECT
  532.     product_id,
  533.     category_id
  534. FROM
  535.     dtb_product_category
  536. WHERE
  537.     category_id = 5
  538. SQL;
  539.     $stmt = $conn->prepare($sql);
  540.     $resultSet = $stmt->executeQuery();
  541.     $rows = $resultSet->fetchAllAssociative();
  543.     $hash = array();
  544.     foreach ($rows as $row) {
  545.       $hash[$row['product_id']] = $row['category_id'];
  546.     }
  547.     return $hash;
  548.   }
  551.   /**
  552.    * コインパレスが販売中のコインID一覧を取得
  553.    * @return array
  554.    * @throws \Doctrine\DBAL\Exception
  555.    */
  556.   public function getStorageCpIds()
  557.   {
  558.     $sql = <<<SQL
  559. SELECT
  560.   A.id
  561. FROM
  562.   dtb_product AS A
  563.   INNER JOIN plg_productplus_dtb_product_data AS B ON A.id = B.product_id
  564.   INNER JOIN plg_productplus_dtb_product_data_detail AS C ON B.id = C.product_data_id
  565. WHERE
  566.   B.product_item_id = 6
  567.   AND (C.value = 1424 or C.value = 1427 or C.value = '')
  568. SQL;
  569.     return $this->getIdsFromSQL($sql);
  570.   }
  572.   /**
  573.    * お客さまからの預りコインID一覧を取得
  574.    * @return array
  575.    * @throws \Doctrine\DBAL\Exception
  576.    */
  577.   public function getStorageCustIds()
  578.   {
  579.     $sql = <<<SQL
  580. SELECT
  581.   A.id
  582. FROM
  583.   dtb_product AS A
  584.   INNER JOIN plg_productplus_dtb_product_data AS B ON A.id = B.product_id
  585.   INNER JOIN plg_productplus_dtb_product_data_detail AS C ON B.id = C.product_data_id
  586. WHERE
  587.   B.product_item_id = 6
  588.   AND (C.value != 1424 AND C.value != 1427 AND C.value != '')
  589. SQL;
  590.     return $this->getIdsFromSQL($sql);
  591.   }
  593.   /**
  594.    * SQL文からID一覧を取得
  595.    * @param $sql
  596.    * @return array
  597.    * @throws \Doctrine\DBAL\Exception
  598.    */
  599.   public function getIdsFromSQL($sql){
  600.     $conn = $this->getEntityManager()->getConnection();
  601.     $stmt = $conn->prepare($sql);
  602.     $resultSet = $stmt->executeQuery();
  603.     $rows = $resultSet->fetchAllAssociative();
  604.     $ids = array();
  605.     foreach ($rows as $row) {
  606.       $ids[] = $row['id'];
  607.     }
  608.     return $ids;
  609.   }
  611.   /**
  612.    * 限定カテゴリーに属する商品IDを取得
  613.    * @param int $genteiCategoryId 限定親カテゴリーID（デフォルト: 218）
  614.    * @return array 商品IDの配列
  615.    */
  616.   public function getGenteiProductIds(int $genteiCategoryId = 218): array
  617.   {
  618.     // 限定カテゴリー（218）とその子カテゴリーのIDを取得
  619.     $categoryIds = $this->getGenteiCategoryIds($genteiCategoryId);
  620.     if (empty($categoryIds)) {
  621.       return [];
  622.     }
  624.     // 限定カテゴリーに属する商品IDを取得
  625.     $sql = "SELECT DISTINCT product_id AS id FROM dtb_product_category WHERE category_id IN (" . implode(',', $categoryIds) . ")";
  626.     return $this->getIdsFromSQL($sql);
  627.   }
  629.   /**
  630.    * 限定カテゴリーとその子カテゴリーのIDを取得
  631.    * @param int $parentCategoryId 親カテゴリーID
  632.    * @return array カテゴリーIDの配列
  633.    */
  634.   public function getGenteiCategoryIds(int $parentCategoryId): array
  635.   {
  636.     $conn = $this->getEntityManager()->getConnection();
  638.     // 親カテゴリーと全ての子孫カテゴリーを取得（再帰的に）
  639.     $sql = <<<SQL
  640. SELECT id FROM dtb_category
  641. WHERE id = :parent_id
  642.    OR parent_category_id = :parent_id
  643.    OR parent_category_id IN (SELECT id FROM dtb_category WHERE parent_category_id = :parent_id)
  644.    OR parent_category_id IN (SELECT id FROM dtb_category WHERE parent_category_id IN (SELECT id FROM dtb_category WHERE parent_category_id = :parent_id))
  645. SQL;
  647.     $stmt = $conn->prepare($sql);
  648.     $resultSet = $stmt->executeQuery(['parent_id' => $parentCategoryId]);
  649.     $rows = $resultSet->fetchAllAssociative();
  651.     $ids = [];
  652.     foreach ($rows as $row) {
  653.       $ids[] = $row['id'];
  654.     }
  655.     return $ids;
  656.   }
  658.   /**
  659.    * 限定公開URL（column_id=66）に値がある商品IDを取得
  660.    * @return array 商品IDの配列
  661.    */
  662.   public function getGenteiUrlProductIds(): array
  663.   {
  664.     $sql = <<<SQL
  665. SELECT DISTINCT
  666.   ppd.product_id AS id
  667. FROM
  668.   plg_productplus_dtb_product_data AS ppd
  669.   INNER JOIN plg_productplus_dtb_product_data_detail AS ppdd ON ppd.id = ppdd.product_data_id
  670. WHERE
  671.   ppd.product_item_id = 66
  672.   AND ppdd.value IS NOT NULL
  673.   AND ppdd.value != ''
  674. SQL;
  675.     return $this->getIdsFromSQL($sql);
  676.   }
  677. }