src/Eccube/Repository/ProductRepository.php line 107

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', 'price' => 'pc.price02',
  39.     // 'stock_sum' は在庫合計での並び替え専用キー（getQueryBuilderBySearchDataForAdmin内で個別処理）。
  40.     // ここでの値自体は使われないが、ProductController::index()のwrap-queries判定（COLUMNS[$sortKey]が空でないか）を満たすために定義が必要。
  41.     'stock_sum' => 'pc.stock',
  42.   ];
  44.   /**
  45.    * ProductRepository constructor.
  46.    *
  47.    * @param RegistryInterface $registry
  48.    * @param Queries $queries
  49.    * @param EccubeConfig $eccubeConfig
  50.    */
  51.   public function __construct(
  52.     RegistryInterface $registry,
  53.     Queries           $queries,
  54.     EccubeConfig      $eccubeConfig
  55.   )
  56.   {
  57.     parent::__construct($registry, Product::class);
  58.     $this->queries = $queries;
  59.     $this->eccubeConfig = $eccubeConfig;
  60.   }
  63.   /**
  64.    * 子カテゴリー一覧をハッシュで取得
  65.    * @param integer $p_id
  66.    * @return hash
  67.    */
  68.   public function getHashStatus()
  69.   {
  70.     $conn = $this->getEntityManager()->getConnection();
  71.     $sql = "SELECT id,product_status_id FROM dtb_product";
  72.     $stmt = $conn->prepare($sql);
  73.     $resultSet = $stmt->executeQuery();
  74.     $rows = $resultSet->fetchAllAssociative();
  75.     $hash = array();
  76.     foreach ($rows as $row) {
  77.       $hash[$row["id"]] = $row["product_status_id"];
  78.     }
  79.     return $hash;
  80.   }
  82.   /**
  83.    * Find the Product with sorted ClassCategories.
  84.    *
  85.    * @param integer $productId
  86.    *
  87.    * @return Product
  88.    */
  89.   public function findWithSortedClassCategories($productId)
  90.   {
  91.     $qb = $this->createQueryBuilder('p');
  92.     $qb->addSelect(['pc', 'cc1', 'cc2', 'pi', 'pt'])
  93.       ->innerJoin('p.ProductClasses', 'pc')
  94.       ->leftJoin('pc.ClassCategory1', 'cc1')
  95.       ->leftJoin('pc.ClassCategory2', 'cc2')
  96.       ->leftJoin('p.ProductImage', 'pi')
  97.       ->leftJoin('p.ProductTag', 'pt')
  98.       ->where('p.id = :id')
  99.       ->andWhere('pc.visible = :visible')
  100.       ->setParameter('id', $productId)
  101.       ->setParameter('visible', true)
  102.       ->orderBy('cc1.sort_no', 'DESC')
  103.       ->addOrderBy('cc2.sort_no', 'DESC');
  105.     $product = $qb
  106.       ->getQuery()
  107.       ->getSingleResult();
  109.     return $product;
  110.   }
  112.   /**
  113.    * Find the Products with sorted ClassCategories.
  114.    *
  115.    * @param array $ids Product in ids
  116.    * @param string $indexBy The index for the from.
  117.    *
  118.    * @return ArrayCollection|array
  119.    */
  120.   public function findProductsWithSortedClassCategories(array $ids, $indexBy = null)
  121.   {
  122.     if (count($ids) < 1) {
  123.       return [];
  124.     }
  125.     $qb = $this->createQueryBuilder('p', $indexBy);
  126.     $qb->addSelect(['pc', 'cc1', 'cc2', 'pi', 'pt', 'tr', 'ps'])
  127.       ->innerJoin('p.ProductClasses', 'pc')
  128.       // XXX Joined 'TaxRule' and 'ProductStock' to prevent lazy loading
  129.       ->leftJoin('pc.TaxRule', 'tr')
  130.       ->innerJoin('pc.ProductStock', 'ps')
  131.       ->leftJoin('pc.ClassCategory1', 'cc1')
  132.       ->leftJoin('pc.ClassCategory2', 'cc2')
  133.       ->leftJoin('p.ProductImage', 'pi')
  134.       ->leftJoin('p.ProductTag', 'pt')
  135.       ->where($qb->expr()->in('p.id', $ids))
  136.       ->andWhere('pc.visible = :visible')
  137.       ->setParameter('visible', true)
  138.       ->orderBy('cc1.sort_no', 'DESC')
  139.       ->addOrderBy('cc2.sort_no', 'DESC');
  141.     $products = $qb
  142.       ->getQuery()
  143.       ->useResultCache(true, $this->eccubeConfig['eccube_result_cache_lifetime_short'])
  144.       ->getResult();
  146.     return $products;
  147.   }
  149.   /**
  150.    * get query builder.
  151.    *
  152.    * @param array{
  153.    *         category_id?:Category,
  154.    *         name?:string,
  155.    *         pageno?:string,
  156.    *         disp_number?:ProductListMax,
  157.    *         orderby?:ProductListOrderBy
  158.    *     } $searchData
  159.    *
  160.    * @return \Doctrine\ORM\QueryBuilder
  161.    */
  162.   public function getQueryBuilderBySearchData($searchData)
  163.   {
  164.     $qb = $this->createQueryBuilder('p')
  165.       ->andWhere('((p.Status = 1) OR (p.Status = 6) OR (p.Status = 8))')
  166.       ->andWhere('p.del_flg = 0');
  168.     // category
  169.     $categoryJoin = false;
  170.     if (!empty($searchData['category_id']) && $searchData['category_id']) {
  171.       $Categories = $searchData['category_id']->getSelfAndDescendants();
  172.       if ($Categories) {
  173.         $qb
  174.           ->innerJoin('p.ProductCategories', 'pct')
  175.           ->innerJoin('pct.Category', 'c')
  176.           ->andWhere($qb->expr()->in('pct.Category', ':Categories'))
  177.           ->setParameter('Categories', $Categories);
  178.         $categoryJoin = true;
  179.       }
  180.     }
  182.     // 複数のカテゴリーに対応
  183.     if (!empty($searchData['c_id']) and is_array($searchData['c_id']) and count($searchData['c_id']) > 0) {
  184.       dump($searchData);exit;
  185.     }
  189.     // name
  190.     if (isset($searchData['name']) && StringUtil::isNotBlank($searchData['name'])) {
  191.       $keywords = preg_split('/[\s　]+/u', str_replace(['%', '_'], ['\\%', '\\_'], $searchData['name']), -1, PREG_SPLIT_NO_EMPTY);
  193.       foreach ($keywords as $index => $keyword) {
  194.         $key = sprintf('keyword%s', $index);
  195.         $qb
  196.           ->andWhere(sprintf('NORMALIZE(p.name) LIKE NORMALIZE(:%s) OR
  197.                         NORMALIZE(p.search_word) LIKE NORMALIZE(:%s) OR
  198.                         EXISTS (SELECT wpc%d FROM \Eccube\Entity\ProductClass wpc%d WHERE p = wpc%d.Product AND NORMALIZE(wpc%d.code) LIKE NORMALIZE(:%s))',
  199.             $key, $key, $index, $index, $index, $index, $key))
  200.           ->setParameter($key, '%' . $keyword . '%');
  201.       }
  202.     }
  204.     // ============================================================
  205.     // 限定商品の除外処理
  206.     // ============================================================
  208.     // 1. カテゴリーベースの限定商品除外（カテゴリーID: 218）
  209.     // 限定カテゴリーの子カテゴリーに属する商品は除外
  210.     // ただし、限定カテゴリーを直接指定した場合は表示
  211.     $genteiCategoryId = 218;
  212.     $isGenteiCategory = false;
  214.     if (!empty($searchData['category_id'])) {
  215.       // 指定カテゴリーが限定カテゴリー(218)またはその子孫かチェック
  216.       $category = $searchData['category_id'];
  217.       if ($category->getId() == $genteiCategoryId) {
  218.         $isGenteiCategory = true;
  219.       } else {
  220.         // 親をたどって限定カテゴリーかチェック
  221.         $parent = $category->getParent();
  222.         while ($parent) {
  223.           if ($parent->getId() == $genteiCategoryId) {
  224.             $isGenteiCategory = true;
  225.             break;
  226.           }
  227.           $parent = $parent->getParent();
  228.         }
  229.       }
  230.     }
  232.     if (!$isGenteiCategory) {
  233.       // 限定カテゴリー以外の場合、限定商品を除外
  234.       $genteiProductIds = $this->getGenteiProductIds($genteiCategoryId);
  235.       if (!empty($genteiProductIds)) {
  236.         $qb->andWhere($qb->expr()->notIn('p.id', ':genteiProductIds'))
  237.            ->setParameter('genteiProductIds', $genteiProductIds);
  238.       }
  239.     }
  241.     // 2. 拡張項目ベースの限定公開除外（column_id: 66）
  242.     // ProductPlusの限定公開URLに値がある商品は除外
  243.     $genteiUrlProductIds = $this->getGenteiUrlProductIds();
  244.     if (!empty($genteiUrlProductIds)) {
  245.       $qb->andWhere($qb->expr()->notIn('p.id', ':genteiUrlProductIds'))
  246.          ->setParameter('genteiUrlProductIds', $genteiUrlProductIds);
  247.     }
  249.     // Order By
  250.     // 価格低い順
  251.     $config = $this->eccubeConfig;
  252.     if (!empty($searchData['orderby']) && $searchData['orderby']->getId() == $config['eccube_product_order_price_lower']) {
  253.       // @see http://doctrine-orm.readthedocs.org/en/latest/reference/dql-doctrine-query-language.html
  254.       $qb->addSelect('MIN(pc.price02) as HIDDEN price02_min');
  255.       $qb->innerJoin('p.ProductClasses', 'pc');
  256.       $qb->andWhere('pc.visible = true');
  257.       $qb->groupBy('p.id');
  258.       $qb->orderBy('price02_min', 'ASC');
  259.       $qb->addOrderBy('p.id', 'DESC');
  260.       // 価格高い順
  261.     } elseif (!empty($searchData['orderby']) && $searchData['orderby']->getId() == $config['eccube_product_order_price_higher']) {
  262.       $qb->addSelect('MAX(pc.price02) as HIDDEN price02_max');
  263.       $qb->innerJoin('p.ProductClasses', 'pc');
  264.       $qb->andWhere('pc.visible = true');
  265.       $qb->groupBy('p.id');
  266.       $qb->orderBy('price02_max', 'DESC');
  267.       $qb->addOrderBy('p.id', 'DESC');
  268.       // 新着順
  269.     } elseif (!empty($searchData['orderby']) && $searchData['orderby']->getId() == $config['eccube_product_order_newer']) {
  270.       // 在庫切れ商品非表示の設定が有効時対応
  271.       // @see https://github.com/EC-CUBE/ec-cube/issues/1998
  272.       if ($this->getEntityManager()->getFilters()->isEnabled('option_nostock_hidden') == true) {
  273.         $qb->innerJoin('p.ProductClasses', 'pc');
  274.         $qb->andWhere('pc.visible = true');
  275.       }
  276.       $qb->orderBy('p.create_date', 'DESC');
  277.       $qb->addOrderBy('p.id', 'DESC');
  278.     } else {
  279.       if ($categoryJoin === false) {
  280.         $qb
  281.           ->leftJoin('p.ProductCategories', 'pct')
  282.           ->leftJoin('pct.Category', 'c');
  283.       }
  284.       $qb
  285.         ->addOrderBy('p.id', 'DESC');
  286.     }
  288.     //dump($qb->getQuery()->getSQL());exit;
  289.     //$all = $qb->getQuery()->getArrayResult();
  290.     //dump($all);exit;
  292.     return $this->queries->customize(QueryKey::PRODUCT_SEARCH, $qb, $searchData);
  293.   }
  295.   /**
  296.    * get query builder.
  297.    *
  298.    * @param array{
  299.    *         id?:string|int|null,
  300.    *         category_id?:Category,
  301.    *         status?:ProductStatus[],
  302.    *         link_status?:ProductStatus[],
  303.    *         stock_status?:int,
  304.    *         stock?:1|2|3|4,
  305.    *         tag_id?:Tag,
  306.    *         create_datetime_start?:\DateTime,
  307.    *         create_datetime_end?:\DateTime,
  308.    *         create_date_start?:\DateTime,
  309.    *         create_date_end?:\DateTime,
  310.    *         update_datetime_start?:\DateTime,
  311.    *         update_datetime_end?:\DateTime,
  312.    *         update_date_start?:\DateTime,
  313.    *         update_date_end?:\DateTime,
  314.    *         sortkey?:string,
  315.    *         sorttype?:string
  316.    *     } $searchData
  317.    *
  318.    * @return \Doctrine\ORM\QueryBuilder
  319.    */
  320.   public function getQueryBuilderBySearchDataForAdmin($searchData)
  321.   {
  323.     $qb = $this->createQueryBuilder('p')
  324.       ->addSelect('pc', 'pi', 'tr', 'ps')
  325.       ->innerJoin('p.ProductClasses', 'pc')
  326.       ->leftJoin('p.ProductImage', 'pi')
  327.       ->leftJoin('pc.TaxRule', 'tr')
  328.       ->leftJoin('pc.ProductStock', 'ps')
  329.       ->andWhere('pc.visible = :visible')
  330.       ->setParameter('visible', true)
  331.       ->andWhere('p.del_flg = 0');
  333.     // id（商品ID・商品名・商品コード・検索ワード・鑑定番号）
  334.     if (isset($searchData['id']) && StringUtil::isNotBlank($searchData['id'])) {
  335.       $id = preg_match('/^\d{0,10}$/', $searchData['id']) ? $searchData['id'] : null;
  336.       if ($id && $id > '2147483647' && $this->isPostgreSQL()) {
  337.         $id = null;
  338.       }
  339.       $qb
  340.         ->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)')
  341.         ->setParameter('id', $id)
  342.         ->setParameter('likeid', '%' . str_replace(['%', '_'], ['\\%', '\\_'], $searchData['id']) . '%');
  343.     }
  345.     // 在庫・お預かり・地金型コイン
  346.     // 1. 在庫    = コインパレスの在庫
  347.     // 2. お預かり = お客さまから預かっているコイン
  348.     // 3. 地金型コイン = カテゴリー地金型を含むコイン
  349.     if (!empty($searchData["custody_flg"]) and count($searchData["custody_flg"]) == 1) {
  350.       $custody_flg = $searchData["custody_flg"][0];
  351.       if ($custody_flg == 1) {
  352.         $ids = $this->getStorageCpIds();
  353.         $qb->andWhere($qb->expr()->in('p.id', $ids));
  354.       } elseif ($custody_flg == 2) {
  355.         $ids = $this->getStorageCustIds();
  356.         $qb->andWhere($qb->expr()->in('p.id', $ids));
  357.       }elseif($custody_flg == 3){
  358.         $Categories = array();
  359.         $categoryRepository = $this->getEntityManager()->getRepository(Category::class);
  360.         $Categories[] = $categoryRepository->find("5");
  361.         $qb->innerJoin('p.ProductCategories', 'pct2')
  362.           ->innerJoin('pct2.Category', 'c2')
  363.           ->andWhere($qb->expr()->in('pct2.Category', ':Categories2'))
  364.           ->setParameter('Categories2', $Categories);
  365.       }
  366.     }
  368.     // category
  369.     if (!empty($searchData['category_id']) && $searchData['category_id']) {
  370.       $Categories = $searchData['category_id']->getSelfAndDescendants();
  371.       if ($Categories) {
  372.         $qb
  373.           ->innerJoin('p.ProductCategories', 'pct')
  374.           ->innerJoin('pct.Category', 'c')
  375.           ->andWhere($qb->expr()->in('pct.Category', ':Categories'))
  376.           ->setParameter('Categories', $Categories);
  377.       }
  378.     }
  380.     // status
  381.     if (!empty($searchData['status']) && $searchData['status']) {
  382.       $qb
  383.         ->andWhere($qb->expr()->in('p.Status', ':Status'))
  384.         ->setParameter('Status', $searchData['status']);
  385.     }
  387.     // link_status
  388.     if (isset($searchData['link_status']) && !empty($searchData['link_status'])) {
  389.       $qb
  390.         ->andWhere($qb->expr()->in('p.Status', ':Status'))
  391.         ->setParameter('Status', $searchData['link_status']);
  392.     }
  394.     // stock status
  395.     if (isset($searchData['stock_status'])) {
  396.       $qb
  397.         ->andWhere('pc.stock_unlimited = :StockUnlimited AND pc.stock = 0')
  398.         ->setParameter('StockUnlimited', $searchData['stock_status']);
  399.     }
  401.     // stock status
  402.     // 1:在庫あり（無制限含む） 2:在庫なし 3:在庫あり（無制限以外） 4:無制限
  403.     if (isset($searchData['stock']) && !empty($searchData['stock'])) {
  404.       $stockFlg = is_array($searchData['stock']) ? reset($searchData['stock']) : $searchData['stock'];
  405.       switch ((int)$stockFlg) {
  406.         case ProductStock::IN_STOCK:
  407.           $qb->andWhere('pc.stock_unlimited = true OR pc.stock > 0');
  408.           break;
  409.         case ProductStock::OUT_OF_STOCK:
  410.           $qb->andWhere('pc.stock_unlimited = false AND pc.stock <= 0');
  411.           break;
  412.         case 3:
  413.           $qb->andWhere('pc.stock_unlimited = false AND pc.stock > 0');
  414.           break;
  415.         case 4:
  416.           $qb->andWhere('pc.stock_unlimited = true');
  417.           break;
  418.         default:
  419.           // 未定義の値は検索条件に含めない
  420.       }
  421.     }
  423.     // tag
  424.     if (!empty($searchData['tag_id']) && $searchData['tag_id']) {
  425.       $qb
  426.         ->innerJoin('p.ProductTag', 'pt')
  427.         ->andWhere('pt.Tag = :tag_id')
  428.         ->setParameter('tag_id', $searchData['tag_id']);
  429.     }
  431.     // crate_date
  432.     if (!empty($searchData['create_datetime_start']) && $searchData['create_datetime_start']) {
  433.       $date = $searchData['create_datetime_start'];
  434.       $qb
  435.         ->andWhere('p.create_date >= :create_date_start')
  436.         ->setParameter('create_date_start', $date);
  437.     } elseif (!empty($searchData['create_date_start']) && $searchData['create_date_start']) {
  438.       $date = $searchData['create_date_start'];
  439.       $qb
  440.         ->andWhere('p.create_date >= :create_date_start')
  441.         ->setParameter('create_date_start', $date);
  442.     }
  444.     if (!empty($searchData['create_datetime_end']) && $searchData['create_datetime_end']) {
  445.       $date = $searchData['create_datetime_end'];
  446.       $qb
  447.         ->andWhere('p.create_date < :create_date_end')
  448.         ->setParameter('create_date_end', $date);
  449.     } elseif (!empty($searchData['create_date_end']) && $searchData['create_date_end']) {
  450.       $date = clone $searchData['create_date_end'];
  451.       $date = $date
  452.         ->modify('+1 days');
  453.       $qb
  454.         ->andWhere('p.create_date < :create_date_end')
  455.         ->setParameter('create_date_end', $date);
  456.     }
  458.     // update_date
  459.     if (!empty($searchData['update_datetime_start']) && $searchData['update_datetime_start']) {
  460.       $date = $searchData['update_datetime_start'];
  461.       $qb
  462.         ->andWhere('p.update_date >= :update_date_start')
  463.         ->setParameter('update_date_start', $date);
  464.     } elseif (!empty($searchData['update_date_start']) && $searchData['update_date_start']) {
  465.       $date = $searchData['update_date_start'];
  466.       $qb
  467.         ->andWhere('p.update_date >= :update_date_start')
  468.         ->setParameter('update_date_start', $date);
  469.     }
  471.     if (!empty($searchData['update_datetime_end']) && $searchData['update_datetime_end']) {
  472.       $date = $searchData['update_datetime_end'];
  473.       $qb
  474.         ->andWhere('p.update_date < :update_date_end')
  475.         ->setParameter('update_date_end', $date);
  476.     } elseif (!empty($searchData['update_date_end']) && $searchData['update_date_end']) {
  477.       $date = clone $searchData['update_date_end'];
  478.       $date = $date
  479.         ->modify('+1 days');
  480.       $qb
  481.         ->andWhere('p.update_date < :update_date_end')
  482.         ->setParameter('update_date_end', $date);
  483.     }
  485.     // Order By
  486.     if (isset($searchData['sortkey']) && !empty($searchData['sortkey'])) {
  487.       $sortOrder = (isset($searchData['sorttype']) && $searchData['sorttype'] == 'a') ? 'ASC' : 'DESC';
  489.       if ($searchData['sortkey'] === 'stock_sum') {
  490.         // 在庫が多い順・少ない順（無制限は並び順に関わらず必ず最後にまとめる）
  491.         // 商品配下のいずれか1つの規格でも無制限であれば、商品全体を無制限グループとして扱う
  492.         // 商品配下の全規格（可視のみ）の在庫数を合計する
  493.         //
  494.         // 注意: ここで groupBy('p') は使わない。
  495.         // このクエリは addSelect('pc','pi','tr','ps') で商品規格・画像等をto-many joinしており、
  496.         // KnpPaginatorの内部実装（Doctrine\ORM\Tools\Pagination\Paginator）はページ内容の最終取得時も
  497.         // 同じクエリ（GROUP BYを含む）をそのまま使い回すため、groupBy('p')を付けると
  498.         // 商品規格が複数ある商品でProductClassesコレクションが1件に潰れてしまい、
  499.         // 価格表示（price02_min/max）等が壊れる。そのため相関サブクエリで集計する。
  500.         $qb->addSelect('(SELECT SUM(pc_stock_sum.stock) FROM Eccube\Entity\ProductClass pc_stock_sum WHERE pc_stock_sum.Product = p AND pc_stock_sum.visible = true) as HIDDEN stock_sum_value');
  501.         $qb->addSelect('(SELECT MAX(pc_stock_unlimited.stock_unlimited) FROM Eccube\Entity\ProductClass pc_stock_unlimited WHERE pc_stock_unlimited.Product = p AND pc_stock_unlimited.visible = true) as HIDDEN stock_unlimited_flag');
  502.         $qb->addOrderBy('stock_unlimited_flag', 'ASC');
  503.         $qb->addOrderBy('stock_sum_value', $sortOrder);
  504.         $qb->addOrderBy('p.id', 'DESC');
  505.       } else {
  506.         $qb->orderBy(self::COLUMNS[$searchData['sortkey']], $sortOrder);
  507.         $qb->addOrderBy('p.update_date', 'DESC');
  508.         $qb->addOrderBy('p.id', 'DESC');
  509.       }
  510.     } else {
  511.       $qb->orderBy('p.id', 'DESC');
  512.       //$qb->addOrderBy('p.update_date', 'DESC');
  513.     }
  515.     //dump($qb->getQuery()->getSQL());exit;
  516.     //$all = $qb->getQuery()->getArrayResult();
  517.     //dump($all);exit;
  519.     return $this->queries->customize(QueryKey::PRODUCT_SEARCH_ADMIN, $qb, $searchData);
  520.   }
  522.   /**
  523.    * 商品種別（クレジット可否）をハッシュで取得
  524.    * sale_type_id = 3 がクレジット不可商品
  525.    *
  526.    * @return array
  527.    */
  528.   public function getHashType()
  529.   {
  530.     $conn = $this->getEntityManager()->getConnection();
  531.     $sql = <<<SQL
  532. SELECT
  533.     product_id,
  534.     sale_type_id
  535. FROM
  536.     dtb_product_class
  537. WHERE
  538.     visible = 1
  539. SQL;
  540.     $stmt = $conn->prepare($sql);
  541.     $resultSet = $stmt->executeQuery();
  542.     $rows = $resultSet->fetchAllAssociative();
  544.     $hash = array();
  545.     foreach ($rows as $row) {
  546.       $hash[$row['product_id']] = $row['sale_type_id'];
  547.     }
  548.     return $hash;
  549.   }
  551.   /**
  552.    * 地金型コインカテゴリーに属する商品をハッシュで取得
  553.    *
  554.    * @return array
  555.    */
  556.   public function getHashJigane()
  557.   {
  558.     $conn = $this->getEntityManager()->getConnection();
  559.     $sql = <<<SQL
  560. SELECT
  561.     product_id,
  562.     category_id
  563. FROM
  564.     dtb_product_category
  565. WHERE
  566.     category_id = 5
  567. SQL;
  568.     $stmt = $conn->prepare($sql);
  569.     $resultSet = $stmt->executeQuery();
  570.     $rows = $resultSet->fetchAllAssociative();
  572.     $hash = array();
  573.     foreach ($rows as $row) {
  574.       $hash[$row['product_id']] = $row['category_id'];
  575.     }
  576.     return $hash;
  577.   }
  580.   /**
  581.    * コインパレスが販売中のコインID一覧を取得
  582.    * @return array
  583.    * @throws \Doctrine\DBAL\Exception
  584.    */
  585.   public function getStorageCpIds()
  586.   {
  587.     $sql = <<<SQL
  588. SELECT
  589.   A.id
  590. FROM
  591.   dtb_product AS A
  592.   INNER JOIN plg_productplus_dtb_product_data AS B ON A.id = B.product_id
  593.   INNER JOIN plg_productplus_dtb_product_data_detail AS C ON B.id = C.product_data_id
  594. WHERE
  595.   B.product_item_id = 6
  596.   AND (C.value = 1424 or C.value = 1427 or C.value = '')
  597. SQL;
  598.     return $this->getIdsFromSQL($sql);
  599.   }
  601.   /**
  602.    * お客さまからの預りコインID一覧を取得
  603.    * @return array
  604.    * @throws \Doctrine\DBAL\Exception
  605.    */
  606.   public function getStorageCustIds()
  607.   {
  608.     $sql = <<<SQL
  609. SELECT
  610.   A.id
  611. FROM
  612.   dtb_product AS A
  613.   INNER JOIN plg_productplus_dtb_product_data AS B ON A.id = B.product_id
  614.   INNER JOIN plg_productplus_dtb_product_data_detail AS C ON B.id = C.product_data_id
  615. WHERE
  616.   B.product_item_id = 6
  617.   AND (C.value != 1424 AND C.value != 1427 AND C.value != '')
  618. SQL;
  619.     return $this->getIdsFromSQL($sql);
  620.   }
  622.   /**
  623.    * SQL文からID一覧を取得
  624.    * @param $sql
  625.    * @return array
  626.    * @throws \Doctrine\DBAL\Exception
  627.    */
  628.   public function getIdsFromSQL($sql){
  629.     $conn = $this->getEntityManager()->getConnection();
  630.     $stmt = $conn->prepare($sql);
  631.     $resultSet = $stmt->executeQuery();
  632.     $rows = $resultSet->fetchAllAssociative();
  633.     $ids = array();
  634.     foreach ($rows as $row) {
  635.       $ids[] = $row['id'];
  636.     }
  637.     return $ids;
  638.   }
  640.   /**
  641.    * 限定カテゴリーに属する商品IDを取得
  642.    * @param int $genteiCategoryId 限定親カテゴリーID（デフォルト: 218）
  643.    * @return array 商品IDの配列
  644.    */
  645.   public function getGenteiProductIds(int $genteiCategoryId = 218): array
  646.   {
  647.     // 限定カテゴリー（218）とその子カテゴリーのIDを取得
  648.     $categoryIds = $this->getGenteiCategoryIds($genteiCategoryId);
  649.     if (empty($categoryIds)) {
  650.       return [];
  651.     }
  653.     // 限定カテゴリーに属する商品IDを取得
  654.     $sql = "SELECT DISTINCT product_id AS id FROM dtb_product_category WHERE category_id IN (" . implode(',', $categoryIds) . ")";
  655.     return $this->getIdsFromSQL($sql);
  656.   }
  658.   /**
  659.    * 限定カテゴリーとその子カテゴリーのIDを取得
  660.    * @param int $parentCategoryId 親カテゴリーID
  661.    * @return array カテゴリーIDの配列
  662.    */
  663.   public function getGenteiCategoryIds(int $parentCategoryId): array
  664.   {
  665.     $conn = $this->getEntityManager()->getConnection();
  667.     // 親カテゴリーと全ての子孫カテゴリーを取得（再帰的に）
  668.     $sql = <<<SQL
  669. SELECT id FROM dtb_category
  670. WHERE id = :parent_id
  671.    OR parent_category_id = :parent_id
  672.    OR parent_category_id IN (SELECT id FROM dtb_category WHERE parent_category_id = :parent_id)
  673.    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))
  674. SQL;
  676.     $stmt = $conn->prepare($sql);
  677.     $resultSet = $stmt->executeQuery(['parent_id' => $parentCategoryId]);
  678.     $rows = $resultSet->fetchAllAssociative();
  680.     $ids = [];
  681.     foreach ($rows as $row) {
  682.       $ids[] = $row['id'];
  683.     }
  684.     return $ids;
  685.   }
  687.   /**
  688.    * 限定公開URL（column_id=66）に値がある商品IDを取得
  689.    * @return array 商品IDの配列
  690.    */
  691.   public function getGenteiUrlProductIds(): array
  692.   {
  693.     $sql = <<<SQL
  694. SELECT DISTINCT
  695.   ppd.product_id AS id
  696. FROM
  697.   plg_productplus_dtb_product_data AS ppd
  698.   INNER JOIN plg_productplus_dtb_product_data_detail AS ppdd ON ppd.id = ppdd.product_data_id
  699. WHERE
  700.   ppd.product_item_id = 66
  701.   AND ppdd.value IS NOT NULL
  702.   AND ppdd.value != ''
  703. SQL;
  704.     return $this->getIdsFromSQL($sql);
  705.   }
  706. }