src/WebBundle/Repository/CollectionRepository.php line 603

Open in your IDE?
  1. <?php
  3. namespace WebBundle\Repository;
  5. use Doctrine\DBAL\Connection;
  6. use Doctrine\DBAL\DBALException;
  7. use Doctrine\DBAL\Driver\Exception as DriverException;
  8. use Doctrine\DBAL\Exception as DoctrineDBALException;
  9. use Doctrine\DBAL\Exception\LockWaitTimeoutException;
  10. use Doctrine\ORM\NonUniqueResultException;
  11. use Doctrine\ORM\NoResultException;
  12. use Doctrine\ORM\Query\ResultSetMapping;
  13. use Doctrine\ORM\QueryBuilder;
  14. use Exception;
  15. use FlexApp\Classes\CommentableEntityTypes;
  16. use FlexApp\Constant\TimeConstant;
  17. use FlexApp\Entity\CommentEntity;
  18. use FlexApp\Repository\CommentRepository;
  19. use FlexApp\Service\RedisCachePool;
  20. use Import1CBundle\Helper\v3\BiConst;
  21. use Import1CBundle\Helper\v3\ConnectionHelper;
  22. use PDO;
  23. use WebBundle\Entity\Collection;
  24. use WebBundle\Entity\ProductReviewsCache;
  25. use WebBundle\Entity\SampleEntity;
  26. use WebBundle\Entity\User;
  27. use WebBundle\Helper\App;
  28. use WebBundle\Helper\ArrHelper;
  29. use WebBundle\Helper\HideFactoryCountriesHelper;
  30. use WebBundle\Helper\LocaleHelper;
  31. use WebBundle\Helper\PathHelper;
  33. class CollectionRepository extends ExtendEntityRepository
  34. {
  35.     private const COLLECTION_QUERY_FILTER_MAPPING = [
  36.         'collection'   => ['alias' => 'c', 'field' => 'id'],
  37.         'country'      => ['join' => ['path' => 'c.factory'], 'alias' => 'f', 'field' => 'country'],
  38.         'rewards'      => ['alias' => 'c', 'field' => 'awards'],
  39.         'reviews'      => ['join' => ['path' => ProductReviewsCache::class], 'alias' => 'reviews', 'field' => 'star'],
  40.     ];
  42.     /**
  43.      * Получаем коллекции с учетом локали, где есть хотя бы один коммент
  44.      * @param $locale
  45.      * @return array
  46.      */
  47.     public function getActivePagesArrays($locale): array
  48.     {
  49.         $query = $this->getEntityManager()->createQuery(
  50.             "
  51.             SELECT
  52.                 DISTINCT coll.unid as portalThemeUnid
  53.             FROM WebBundle\Entity\Collection coll
  54.             JOIN FlexApp\Entity\CommentEntity comm
  55.                 WITH COLLATE(coll.unid,utf8mb4_unicode_ci) = COLLATE(comm.commentableUnid,utf8mb4_unicode_ci)
  56.                 AND comm.locale = :locale
  57.         "
  58.         );
  60.         $query->setParameter('locale', $locale);
  61.         $result = $query->getResult();
  63.         foreach ($result as &$row) {
  64.             $row['locale'] = $locale;
  65.             $row['type'] = CommentableEntityTypes::COLLECTION;
  66.         }
  68.         return $result;
  69.     }
  71.     /**
  72.      * @param string $alias
  73.      * @return QueryBuilder
  74.      */
  75.     public function joinQuery($alias = 'c')
  76.     {
  77.         return $this->createQueryBuilder($alias)
  78.             ->select("{$alias}, body, metaDescription, metaKeywords")
  79.             ->leftJoin("{$alias}.body", 'body')
  80.             ->leftJoin("{$alias}.metaDescription", 'metaDescription')
  81.             ->leftJoin("{$alias}.metaKeywords", 'metaKeywords')
  82.             ->leftJoin("{$alias}.factory", 'factory')
  83.             ->leftJoin('factory.user', 'user');
  84.     }
  86.     public function getCollectionsProcess()
  87.     {
  88.         $q = $this->createQueryBuilder('c')
  89.             ->select('c, f')
  90.             ->innerJoin('c.factory', 'f')
  91.             ->leftJoin('c.interiors', 'i')
  92.             ->andWhere('c.status = :status')
  93.             ->andWhere('f.status = :status')
  94.             ->andWhere('i.status = 1')
  95.             ->andWhere('i.file IS NOT NULL')
  96.             ->andWhere('c.process IS NULL')
  97.             ->groupBy('i.id')
  98.             ->setParameter('status', BiConst::STATE_PUBLISHED);
  100.         return $q->getQuery()->getResult();
  101.     }
  103.     /**
  104.      * НЕ ИЗМЕНЯТЬ специальный запрос для API
  105.      * @param null $factoryId
  106.      * @return array|null
  107.      */
  108.     public function getCollectionsArrayAPI($factoryId = null)
  109.     {
  110.         $q = $this->createQueryBuilder('c')
  111.             ->select('c.id,c.name,c.alternateName,c.code')
  112.             ->leftJoin('c.factory', 'f')
  113.             ->andWhere('c.status = :status')
  114.             ->setParameter('status', BiConst::STATE_PUBLISHED);
  116.         if (!empty($factoryId)) {
  117.             $q->andWhere('f.id = :factory OR f.unid  = :factory')
  118.                 ->setParameter('factory', $factoryId);
  119.         }
  121.         return $q->getQuery()->getArrayResult();
  122.     }
  124.     /**
  125.      * @param null $factoryId
  126.      * @param null $status
  127.      * @return array
  128.      * @throws Exception
  129.      */
  130.     public function getCollectionsStatusArrayAPI($factoryId = null, $status = null)
  131.     {
  132.         $q = $this->createQueryBuilder('c')
  133.             ->select('c.id,c.name,c.alternateName,c.code')
  134.             ->leftJoin('c.factory', 'f');
  136.         if (!App::isRole('ROLE_TEST')) {
  137.             $q->andWhere('c.testAccess IS NULL OR c.testAccess = 0');
  138.             $q->andWhere('f.testAccess IS NULL OR f.testAccess = 0');
  139.         }
  141.         if (!empty($factoryId) and $factoryId != 'all') {
  142.             $q->andWhere('f.id = :factory OR f.unid  = :factory')
  143.                 ->setParameter('factory', $factoryId);
  144.         }
  146.         $states = BiConst::listStateAll();
  147.         if ($status !== null and in_array($status, $states)) {
  148.             $q->andWhere('c.status = :status')
  149.                 ->setParameter('status', $status);
  150.         }
  152.         $r = $q->getQuery();
  153.         $result = $r->getArrayResult();
  155.         return $result;
  156.     }
  158.     /**
  159.      * @param $cId
  160.      * @return mixed
  161.      * @throws NonUniqueResultException
  162.      * @throws NoResultException
  163.      */
  164.     public function collectionCountInteriors($cId)
  165.     {
  166.         return $this->createQueryBuilder('c')
  167.             ->select('count(i.id)')
  168.             ->leftJoin('c.interiors', 'i')
  169.             ->where('i.status = 1')
  170.             ->andWhere('c.id = :id')
  171.             ->setParameter('id', $cId)
  172.             ->getQuery()
  173.             ->enableResultCache()
  174.             ->getSingleScalarResult();
  175.     }
  177.     /**
  178.      * @return QueryBuilder
  179.      * @throws Exception
  180.      */
  181.     private function queryForCommandHeader()
  182.     {
  183.         $q = $this->createQueryBuilder('c')
  184.             ->select('c.id, m.id material, t.id type')
  185.             ->leftJoin('c.factory', 'f')
  186.             ->leftJoin('c.articles', 'a')
  187.             ->leftJoin('a.type', 't')
  188.             ->leftJoin('a.material', 'm')
  189.             ->andWhere('f.status IN (1,2,3)')
  190.             ->andWhere('f.unid IS NOT null')
  191.             ->andWhere('c.status != 0')
  192.             ->andWhere('a.delivery != 6 OR a.delivery = 6 AND (f.status IN (2,3) OR c.status IN (2,3))')
  193.             ->orderBy('f.name');
  195.         if (!App::isRole('ROLE_TEST')) {
  196.             $q->andWhere('c.testAccess IS NULL OR c.testAccess = 0');
  197.             $q->andWhere('f.testAccess IS NULL OR f.testAccess = 0');
  198.         }
  200.         return $q;
  201.     }
  203.     /**
  204.      * @param array $params
  205.      * @return array
  206.      * @throws Exception
  207.      */
  208.     public function getCollectionsForCommandHeader($params = [])
  209.     {
  210.         $q = $this->queryForCommandHeader();
  211.         if (!empty($params['id'])) {
  212.             $q->andWhere('c.id = :id')
  213.                 ->setParameter('id', $params['id']);
  214.         }
  216.         $r = $q->getQuery()
  217.             ->useQueryCache(true)
  218.             ->enableResultCache(3600);
  220.         $res = [];
  221.         $items = $r->getArrayResult();
  222.         foreach ($items as $item) {
  223.             $res[$item['id']]['articles'][] = [
  224.                 'type' => $item['type'],
  225.                 'material' => $item['material'],
  226.             ];
  227.         }
  229.         return $res;
  230.     }
  232.     /**
  233.      * @param $id
  234.      * @return null
  235.      * @throws Exception
  236.      */
  237.     public function getCollForAlsoById($id)
  238.     {
  239.         $q = $this->createQueryBuilder('c')
  240.             ->select('c, fc')
  241.             ->leftJoin('c.factory', 'fc')
  242.             ->andWhere('c.id = :id')
  243.             ->setParameter('id', $id);
  245.         if (!App::isRole('ROLE_TEST')) {
  246.             $q->andWhere('c.testAccess IS NULL OR c.testAccess = 0');
  247.             $q->andWhere('fc.testAccess IS NULL OR fc.testAccess = 0');
  248.         }
  250.         $r = $q->getQuery()
  251.             ->useQueryCache(true)
  252.             ->enableResultCache(3600 * 24 * 30);
  254.         $result = $r->getResult();
  255.         $item = count($result) > 0 ? $result[0] : null;
  257.         return $item;
  258.     }
  260.     /**
  261.      * @param $id
  262.      * @return null
  263.      * @throws Exception
  264.      */
  265.     public function getCollAuthor($id)
  266.     {
  267.         $q = $this->createQueryBuilder('c')
  268.             ->select('c.author')
  269.             ->andWhere('c.id = :id')
  270.             ->setParameter('id', $id);
  272.         if (!App::isRole('ROLE_TEST')) {
  273.             $q->andWhere('c.testAccess IS NULL OR c.testAccess = 0');
  274.         }
  276.         $r = $q->getQuery()
  277.             ->useQueryCache(true)
  278.             ->enableResultCache(3600 * 24 * 30);
  280.         $result = $r->getArrayResult();
  281.         $item = count($result) > 0 ? $result[0]['author'] : null;
  283.         return $item;
  284.     }
  286.     /**
  287.      * @param null $c_name
  288.      * @param null $f_name
  289.      * @return array
  290.      * @throws Exception
  291.      */
  292.     public function getCollectionsF($c_name = null, $f_name = null)
  293.     {
  294.         $q = $this->createQueryBuilder('c')
  295.             ->select('c.url c_url, c.code c_code, c.name c_name, f.url f_url, f.id f_id, c.publishDate publishDate ,c.updateDate updateDate')
  296.             ->leftJoin('c.factory', 'f')
  297.             ->leftJoin('c.interiors', 'i')
  298.             ->andWhere('c.status = :c_status')
  299.             ->andWhere('f.status = :f_status')
  300.             ->andWhere('i.status < :i_status OR i.status is null')
  301.             ->setParameter('c_status', BiConst::STATE_PUBLISHED)
  302.             ->setParameter('f_status', BiConst::STATE_PUBLISHED)
  303.             ->setParameter('i_status', BiConst::STATE_DISCONTINUED)
  304.             ->groupBy('c.id');
  306.         if (!App::isRole('ROLE_TEST')) {
  307.             $q->andWhere('c.testAccess IS NULL OR c.testAccess = 0');
  308.             $q->andWhere('f.testAccess IS NULL OR f.testAccess = 0');
  309.         }
  310.         if (!empty($c_name) && !empty($f_name)) {
  311.             $q->andWhere('c.name LIKE :c_name')
  312.                 ->andWhere('f.name LIKE :f_name')
  313.                 ->setParameter('c_name', $c_name)
  314.                 ->setParameter('f_name', $f_name);
  315.         }
  316.         $r = $q->getQuery()
  317.             ->useQueryCache(true);
  318.         return $r->getArrayResult();
  319.     }
  321.     /**
  322.      * @param $code
  323.      * @return null
  324.      * @throws Exception
  325.      */
  326.     public function getCollBM($code)
  327.     {
  328.         $q = $this->createQueryBuilder('c')
  329.             ->select('c.code c_code, c.name c_name, c.url c_url, f.url f_url, f.name f_name, u.username')
  330.             ->leftJoin('c.factory', 'f')
  331.             ->leftJoin('f.user', 'u')
  332.             ->andWhere('c.code=:code')
  333.             ->setParameter('code', $code)
  334.             ->setMaxResults(1);
  336.         if (!App::isRole('ROLE_TEST')) {
  337.             $q->andWhere('c.testAccess IS NULL OR c.testAccess = 0');
  338.             $q->andWhere('f.testAccess IS NULL OR f.testAccess = 0');
  339.         }
  341.         $r = $q->getQuery()->useQueryCache(false);
  343.         $items = $r->getArrayResult();
  345.         return empty($items[0]) ? null : $items[0];
  346.     }
  348.     /**
  349.      * @param $ides
  350.      * @param $limit
  351.      * @param string $sign
  352.      * @return array
  353.      * @throws Exception
  354.      */
  355.     public function getCollectionAlsoViewedNative($ides, $limit, $sign = 'IN')
  356.     {
  357.         // на случай если в массиве один элемент чтобы работало FIELD
  358.         $ides = array_merge([0], $ides);
  360.         $rsm = new ResultSetMapping();
  361.         $rsm->addEntityResult('WebBundle\Entity\Collection', 'c');
  362.         $rsm->addFieldResult('c', 'id', 'id');
  363.         $rsm->addFieldResult('c', 'name', 'name');
  364.         $rsm->addFieldResult('c', 'alternate_name', 'alternateName');
  365.         $rsm->addFieldResult('c', 'url', 'url');
  366.         $rsm->addFieldResult('c', 'awards', 'awards');
  367.         $rsm->addFieldResult('c', 'publish_date', 'publishDate');
  368.         $rsm->addFieldResult('c', 'rating', 'rating');
  369.         $rsm->addJoinedEntityResult('WebBundle\Entity\Factory', 'f', 'c', 'factory');
  370.         $rsm->addFieldResult('f', 'f_id', 'id');
  371.         $rsm->addFieldResult('f', 'f_name', 'name');
  372.         $rsm->addFieldResult('f', 'f_alternate_name', 'alternateName');
  373.         $rsm->addFieldResult('f', 'f_url', 'url');
  374.         $rsm->addJoinedEntityResult('WebBundle\Entity\ListCountry', 'lc', 'f', 'country');
  375.         $rsm->addFieldResult('lc', 'lc_id', 'id');
  376.         $rsm->addFieldResult('lc', 'lc_alias', 'alias');
  377.         $rsm->addFieldResult('lc', 'lc_code', 'code');
  378.         $rsm->addJoinedEntityResult('WebBundle\Entity\Interior', 'i', 'c', 'interiors');
  379.         $rsm->addEntityResult('WebBundle\Entity\Interior', 'i');
  380.         $rsm->addFieldResult('i', 'i_id', 'id');
  382.         $ides = join(',', $ides);
  383.         $sort = $sign == 'IN' ? "FIELD({$ides})" : 'c.id';
  385.         $where = '';
  386.         if (!App::isRole('ROLE_TEST')) {
  387.             $where = ' AND (c.test_access IS NULL OR c.test_access = 0) AND f.test_access IS NULL AND (c.accessible IS NULL OR c.accessible = 0)';
  388.         }
  390.         $query = $this->_em->createNativeQuery(
  391.             "SELECT
  392.               c.id,
  393.               c.name,
  394.               c.alternate_name,
  395.               c.url,
  396.               c.awards,
  397.               c.publish_date,
  398.               c.rating,
  399.               f.id AS f_id,
  400.               f.name AS f_name,
  401.               f.alternate_name AS f_alternate_name,
  402.               f.url AS f_url,
  403.               lc.id AS lc_id,
  404.               lc.alias AS lc_alias,
  405.               lc.code AS lc_code,
  406.               i.id AS i_id
  407.             FROM
  408.               collection c
  409.             LEFT JOIN factory f ON f.id = c.factory
  410.             LEFT JOIN list_country lc ON lc.id = f.country
  411.             LEFT JOIN interior i ON c.id = i.collection
  412.             WHERE i.is_main = 1{$where} AND c.id {$sign} ({$ides}) AND c.status = 1 AND f.status = 1
  413.             GROUP BY c.id
  414.             ORDER BY {$sort} DESC, i.is_main DESC, i.is_head DESC LIMIT {$limit}",
  415.             $rsm
  416.         );
  418.         return $query->getArrayResult();
  419.     }
  421.     /**
  422.      * @param $id
  423.      * @return array
  424.      * @throws Exception
  425.      */
  426.     public function getCollectionForInformer(int $id): array
  427.     {
  428.         $q = $this->createQueryBuilder('c')
  429.             ->select('c,f,a,measure,measurementSize')
  430.             ->leftJoin('c.factory', 'f')
  431.             ->leftJoin('c.articles', 'a')
  432.             ->leftJoin('a.measure', 'measure')
  433.             ->leftJoin('a.measurementSize', 'measurementSize')
  434.             ->andWhere('c.id = :id')
  435.             ->setParameter('id', $id);
  437.         if (!App::isRole('ROLE_TEST')) {
  438.             $q->andWhere('c.testAccess IS NULL OR c.testAccess = 0');
  439.         }
  441.         $r = $q->getQuery()
  442.             ->useQueryCache(true);
  444.         $items = $r->getArrayResult();
  445.         if (count($items) > 0) {
  446.             return $items[0];
  447.         }
  448.         return [];
  449.     }
  451.     /**
  452.      * @param $factoryUrl
  453.      * @param $collectionUrl
  454.      * @return array|mixed|null
  455.      * @throws Exception
  456.      */
  457.     public function getSlideCollection($factoryUrl, $collectionUrl)
  458.     {
  459.         $q = $this->createQueryBuilder('c')
  460.             ->addSelect('f, ct')
  461.             ->innerJoin('c.factory', 'f')
  462.             ->innerJoin('f.country', 'ct')
  463.             ->andWhere('f.url = :factory')
  464.             ->andWhere('c.url = :collection')
  465.             ->andWhere('c.status IN (:cStatus)')
  466.             ->setParameters([
  467.                 'factory' => $factoryUrl,
  468.                 'collection' => $collectionUrl,
  469.                 'cStatus' => [
  470.                     BiConst::STATE_PUBLISHED,
  471.                     BiConst::STATE_DISCONTINUED,
  472.                     BiConst::STATE_WORK_CONTINUED,
  473.                     BiConst::STATE_CHECKING,
  474.                     BiConst::STATE_PROCESSING,
  475.                 ],
  476.             ]);
  478.         if (!App::isRole('ROLE_TEST')) {
  479.             $q->andWhere('c.testAccess IS NULL OR c.testAccess = 0');
  480.             $q->andWhere('f.testAccess IS NULL OR f.testAccess = 0');
  481.         }
  483.         $item = $q->setMaxResults(1)
  484.             ->getQuery()
  485.             ->enableResultCache(TimeConstant::HOUR)
  486.             ->getArrayResult();
  488.         if (empty($item[0])) {
  489.             return null;
  490.         }
  492.         $res = $item[0];
  493.         // закрываем некоторые фабрики для некоторых стран
  494.         if (in_array($res['factory']['id'], HideFactoryCountriesHelper::codes())) {
  495.             $res['factory']['status'] = 3;
  496.             $res['status'] = 3;
  497.         }
  499.         if (!empty($res['status']) && $res['status'] > 3) {
  500.             $res['status'] = 3;
  501.         }
  503.         return $res;
  504.     }
  506.     /**
  507.      * @param array $param
  508.      * @return mixed
  509.      * @throws Exception
  510.      */
  511.     public function getCollectionsForMenuFilters($param = [])
  512.     {
  513.         $q = $this->createQueryBuilder('c')
  514.             ->select('c, f')
  515.             ->leftJoin('c.factory', 'f')
  516.             ->andWhere('c.factory != \'\'')
  517.             ->andWhere('f.status = :f_status')
  518.             ->andWhere('c.status = :c_status')
  519.             ->setParameter('f_status', BiConst::STATE_PUBLISHED)
  520.             ->setParameter('c_status', BiConst::STATE_PUBLISHED)
  521.             ->orderBy('c.name, c.publishDate DESC, c.id');
  523.         if (!App::isRole('ROLE_TEST')) {
  524.             $q->andWhere('c.testAccess IS NULL OR c.testAccess = 0');
  525.             $q->andWhere('f.testAccess IS NULL OR f.testAccess = 0');
  526.         }
  528.         if (!empty($param['factoryId'])) {
  529.             $q->andWhere('f.id IN (' . join(', ', $param['factoryId']) . ')');
  530.         }
  532.         if (!empty($param['id'])) {
  533.             $q->andWhere('c.id = :collId');
  534.             $q->setParameter('collId', $param['id']);
  535.         }
  537.         $r = $q->getQuery();
  538.         // todo для кеша места не хвататет, надо выборку уменьшить.
  539.         //$r->useQueryCache(true)->useResultCache(true, 60 * 60 * 4, $this->buildCacheName('getCollectionsForFilters', $param));
  541.         $items = $r->getResult();
  543.         return $items;
  544.     }
  546.     /**
  547.      * @param int $page
  548.      * @param int $limit
  549.      * @param string $orderBy
  550.      * @return array
  551.      * @throws Exception
  552.      */
  553.     public function getCollectionIdes(
  554.         int $page = 1,
  555.         int $limit = 20,
  556.         string $orderBy = 'c.publishDate DESC, c.id'
  557.     ): array {
  558.         $q = $this->createQueryBuilder('c')
  559.             ->select('c.id')
  560.             ->leftJoin('c.factory', 'f')
  561.             ->leftJoin('f.filter', 'b')// это сущность из базы фильтров
  562.             ->andWhere('c.status = :status')
  563.             ->andWhere('c.showMain = :showMain')
  564.             ->andWhere('c.accessible != :accessible OR c.accessible is null')
  565.             ->andWhere('f.filter IS NOT null')
  566.             ->andWhere('f.status = :status')
  567.             ->andWhere('c.factory != :factory')
  568.             ->setParameters([
  569.                 'status' => BiConst::STATE_PUBLISHED,
  570.                 'showMain' => true,
  571.                 'accessible' => true,
  572.                 'factory' => ''
  573.             ])
  574.             ->orderBy($orderBy)
  575.             ->setMaxResults($limit)
  576.             ->setFirstResult($limit * $page - $limit);
  578.         if (!App::isRole('ROLE_TEST')) {
  579.             $q->andWhere('c.testAccess IS NULL OR c.testAccess = 0');
  580.             $q->andWhere('f.testAccess IS NULL OR f.testAccess = 0');
  581.         }
  583.         $res = $q->getQuery()
  584.             ->enableResultCache(600)
  585.             ->getArrayResult();
  586.         return $res ? array_column($res, 'id') : [];
  587.     }
  589.     /**
  590.      * @param array $param
  591.      * @param bool $wTest
  592.      * @return array
  593.      * @throws Exception
  594.      */
  595.     public function getCollections(array $param = [], bool $wTest = false): array
  596.     {
  597.         $redisCachePool = App::getContainer()->get(RedisCachePool::class)->getPool();
  598.         $memKey = md5(
  599.             json_encode($param) . $wTest . '2' . App::getCurLocale() . LocaleHelper::getCur(
  600.             ) . LocaleHelper::getUserMeasure()
  601.         );
  603.         $cacheItem = $redisCachePool->getItem('getCollections.' . $memKey);
  604.         $cacheItem->expiresAfter(600);
  606.         $cacheCreatedAtItem = $redisCachePool->getItem('createdCollectionAt.' . $memKey);
  607.         $cacheCreatedAtItem->expiresAfter(600);
  609.         $cacheUpdatedAtItem = $redisCachePool->getItem('updateCollections');
  610.         $cacheUpdatedAtItem->expiresAfter(600);
  612.         $createdAt = $cacheCreatedAtItem->get() ?? false;
  613.         $updatedAt = $cacheUpdatedAtItem->get() ?? false;
  614.         $expired = $createdAt && $updatedAt && ($updatedAt > $createdAt);
  616.         if (!$cacheItem->isHit() || $expired) {
  617.             $q = $this->createQueryBuilder('c')
  618.                 ->innerJoin('c.factory', 'f')
  619.                 ->innerJoin('f.filter', 'b')// это сущность из базы фильтров
  620.                 ->innerJoin('f.country', 'ct')
  621.                 ->andWhere('f.filter IS NOT null')
  622.                 ->andWhere('c.factory != \'\'')
  623.                 ->andWhere('f.status = :f_status')
  624.                 ->setParameter('f_status', BiConst::STATE_PUBLISHED);
  627.             if (HideFactoryCountriesHelper::length() > 0) {
  628.                 $q->andWhere('f.id NOT IN (:hide_factories)')
  629.                     ->setParameter('hide_factories', HideFactoryCountriesHelper::codes());
  630.             }
  632.             if (!App::isRole('ROLE_TEST') && !$wTest) {
  633.                 $q->andWhere('c.testAccess IS NULL OR c.testAccess = 0');
  634.                 $q->andWhere('f.testAccess IS NULL OR f.testAccess = 0');
  635.             }
  637.             if (isset($param['collectionId'])) {
  638.                 $cid = $param['collectionId'];
  639.                 if (is_array($cid)) {
  640.                     $cid = implode(' ,', $cid);
  641.                     $q->andWhere('c.status = :c_status and c.id IN (:collectionId)');
  642.                     $q->setParameter('collectionId', $cid);
  643.                 } else {
  644.                     $q->andWhere('c.status = :c_status and c.id = :collectionId');
  645.                     $q->setParameter('collectionId', $param['collectionId']);
  646.                 }
  648.                 $q->setParameter('c_status', BiConst::STATE_PUBLISHED);
  649.             } else {
  650.                 $q->andWhere('c.status = :c_status')
  651.                     ->setParameter('c_status', BiConst::STATE_PUBLISHED);
  652.             }
  654.             if (!empty($param['leftCollectionCount']) && $param['leftCollectionCount']) {
  655.                 $q->andWhere('c.status = :c_status');
  656.                 $q->andWhere('f.status = :f_status');
  657.                 $q->setParameter('c_status', BiConst::STATE_PUBLISHED)
  658.                     ->setParameter('f_status', BiConst::STATE_PUBLISHED);
  659.             }
  661.             if (!empty($param['onlyId'])) {
  662.                 $q->select('c.id');
  663.             } elseif (empty($param['onlyCF'])) {
  664.                 $q->select('c,f,ct,i,id')
  665.                     ->leftJoin('c.interiors', 'i')
  666.                     ->leftJoin('i.ideas', 'id')
  667.                     ->groupBy('c.id');
  668.             } else {
  669.                 $q->select('c.id,c.url,c.code,c.name,c.alternateName,c.nameFull,f.id fId,f.url fUrl,f.unid fUnid');
  670.                 if (!empty($param['locale'])) {
  671.                     $q->leftJoin('b.url', 'burl');
  672.                     $q->leftJoin('b.page', 'bpage');
  673.                     $q->addSELECT("b.id brandId, f.url brandUrl, f.name brandName");
  674.                 }
  675.             }
  677.             if (!empty($param['factoryId'])) {
  678.                 $q->andWhere('f.id IN (' . join(', ', $param['factoryId']) . ')');
  679.             }
  681.             if (!empty($param['order'])) {
  682.                 $q->orderBy($param['order']);
  683.             } else {
  684.                 $q->orderBy('c.publishDate DESC, c.id');
  685.             }
  687.             if (!empty($param['ides'])) {
  688.                 $q->andWhere('c.id IN (' . join(', ', $param['ides']) . ')');
  689.             }
  691.             if (!empty($param['noIdes'])) {
  692.                 $q->andWhere('c.id NOT IN (' . join(', ', $param['noIdes']) . ')');
  693.             }
  695.             if (!empty($param['limit'])) {
  696.                 $q->setMaxResults($param['limit']);
  697.             }
  699.             if (!empty($param['start_with'])) {
  700.                 $q->setFirstResult($param['start_with']);
  701.             }
  703.             if (!empty($param['archive'])) {
  704.                 $q->andWhere('c.archive = ' . $param['archive']);
  705.             }
  707.             if (!empty($param['code'])) {
  708.                 $code = ArrHelper::get($param, 'code');
  709.                 $code = is_array($code) ? $code[0] : $code;
  710.                 foreach ($code as $i => $item) {
  711.                     $code[$i] = "'{$item}'";
  712.                 }
  713.                 $code = implode(', ', $code);
  714.                 $q->andWhere("c.code in ({$code})");
  715.             }
  717.             if (empty($param['noReviewCount'])) {
  718.                 // специальные подзапросы для отзывов по коллекциям
  719.                 $q->addSELECT(
  720.                     '(SELECT COUNT(prc.star) FROM WebBundle\Entity\ProductReviewsCache prc Where prc.sku = c.code) prc_count'
  721.                 );
  722.                 $q->addSELECT(
  723.                     '(SELECT SUM(prc2.star) FROM WebBundle\Entity\ProductReviewsCache prc2 Where prc2.sku = c.code) prc_vote'
  724.                 );
  725.             }
  727.             $r = $q->getQuery()->useQueryCache(true);
  729.             $items = $r->getArrayResult();
  730.             foreach ($items as $key => $item) {
  731.                 if (!empty($item[0])) {
  732.                     $items[$key] = array_merge($item[0], $item);
  733.                     unset($items[$key][0]);
  734.                 }
  735.             }
  737.             $cacheItem->set($items);
  738.             $cacheCreatedAtItem->set(time());
  739.             $redisCachePool->save($cacheItem);
  740.         }
  742.         $collections = $cacheItem->get();
  744.         if (isset($collections[0]['rating'])) {
  745.             $ids = [];
  747.             foreach ($collections as $collection) {
  748.                 $ids[] = $collection['id'] ?? 0;
  749.             }
  751.             //Делаем один дополнительный sql запрос на получение пачки коллекций
  752.             $actualData = $this->findBy(['id' => $ids]);
  754.             foreach ($collections as &$collection) {
  755.                 $collection['rating'] = $this->getRating($collection['id'], $actualData);
  756.             }
  757.         }
  759.         return $collections;
  760.     }
  762.     public function getListForMenu(array $param): array
  763.     {
  764.         $status = BiConst::STATE_PUBLISHED . ', ' . BiConst::STATE_WORK_CONTINUED;
  766.         $whereCid = '';
  767.         if (!empty($param['collectionId'])) {
  768.             $cid = $param['collectionId'];
  769.             if (is_array($cid)) {
  770.                 $cid = implode(' ,', $cid);
  771.             }
  772.             $whereCid = "AND c.id IN ({$cid})";
  773.         }
  775.         $whereFid = '';
  776.         if (!empty($param['factoryId'])) {
  777.             $fid = implode(' ,', $param['factoryId']);
  778.             $whereCid = "AND b.id IN ({$fid})";
  779.         }
  781.         // доработал запрос чтобы не попадали коллекции у которых нет выборки для каталога
  782.         // https://te.remote.team/#/discus/E82653AE-437D-D61C-AE0D-F985799FE15E/
  783.         $sql = "SELECT
  784.                 c.id AS `id`,
  785.                 c.status AS `status`,
  786.                 c.url AS `slug`,
  787.                 c.name AS `name`,
  788.                 c.name_full AS `nameFull`,
  789.                 b.id AS `b.id`,
  790.                 b.name AS `b.name`,
  791.                 b.url AS `b.slug`
  792.             FROM
  793.                 collection c
  794.             INNER JOIN factory b ON b.id = c.factory
  795.             INNER JOIN article a ON a.collection = c.id AND a.delivery <> 6 AND a.file IS NOT NULL AND a.file <> '' AND a.price_euro > 0
  796.             WHERE c.factory IS NOT NULL
  797.                 AND c.factory != ''
  798.                 AND c.url IS NOT NULL
  799.                 AND c.url != ''
  800.                 AND b.url IS NOT NULL
  801.                 AND b.url != ''
  802.                 AND b.filter IS NOT null
  803.                 AND b.status IN ({$status})
  804.                 AND c.status IN ({$status})
  805.                 {$whereCid} {$whereFid}
  806.             GROUP BY c.id
  807.             ORDER BY c.name, b.name
  808.             ";
  810.         $rows = $this
  811.             ->_em
  812.             ->getConnection()
  813.             ->fetchAllAssociative($sql);
  815.         foreach ($rows as $i => $row) {
  816.             $name = $row['nameFull'] ? $row['nameFull'] : $row['name'];
  817.             $item = [
  818.                 'fId' => intval($row['b.id']),
  819.                 'id' => intval($row['id']),
  820.                 'status' => intval($row['status']),
  821.                 'slug' => $row['slug'],
  822.                 'name' => html_entity_decode($name),
  823.                 'factory' => [
  824.                     'id' => intval($row['b.id']),
  825.                     'slug' => $row['b.slug'],
  826.                     'name' => html_entity_decode($row['b.name']),
  827.                 ],
  828.             ];
  830.             $rows[$i] = $item;
  831.         }
  833.         return $rows;
  834.     }
  836.     /**
  837.      * @param array $param
  838.      * @return int
  839.      * @throws Exception
  840.      */
  841.     public function countCollections($param = [])
  842.     {
  843.         $q = $this->createQueryBuilder('c')
  844.             ->select('COUNT(c.id)')
  845.             ->leftJoin('c.factory', 'f')
  846.             ->leftJoin('c.articles', 'a')
  847.             ->andWhere('c.factory != \'\'')
  848.             ->andWhere('f.id != 99')
  849.             ->andWhere('f.status = :f_status')
  850.             ->andWhere('c.status = :c_status')
  851.             ->andWhere('c.archive != 1')
  852.             ->andWhere('a.priceEuro IS NOT null')
  853.             ->setParameter('c_status', BiConst::STATE_PUBLISHED)
  854.             ->setParameter('f_status', BiConst::STATE_PUBLISHED)
  855.             ->orderBy('c.name, c.publishDate')
  856.             ->groupBy('c.id');
  858.         if (!App::isRole('ROLE_TEST')) {
  859.             $q->andWhere('c.testAccess IS NULL OR c.testAccess = 0');
  860.             $q->andWhere('f.testAccess IS NULL OR f.testAccess = 0');
  861.         }
  863.         if (!empty($param['factoryId'])) {
  864.             $param['factoryId'] = is_array($param['factoryId']) ? $param['factoryId'] : [$param['factoryId']];
  865.             $q->andWhere('f.id IN (' . join(', ', $param['factoryId']) . ')');
  866.         }
  868.         $r = $q->getQuery()->useQueryCache(true);
  870.         $items = count($r->getArrayResult());
  872.         return $items;
  873.     }
  875.     /**
  876.      * @param $factoryUnid
  877.      * @return array|null
  878.      */
  879.     public function getCollectionsByFactoryUnid($factoryUnid)
  880.     {
  881.         $r = $this->createQueryBuilder('c')
  882.             ->select('c,f')
  883.             ->leftJoin('c.factory', 'f')
  884.             ->andWhere('f.unid = :unid')
  885.             ->setParameters(['unid' => $factoryUnid])
  886.             ->getQuery();
  888.         return $r->getResult();
  889.     }
  891.     /**
  892.      * получить коллекции для установки тем и участников из админки
  893.      * @param null $ids
  894.      * @param null $limit
  895.      * @return array|null
  896.      */
  897.     public function getCollectionsParticipant($ids = null, $limit = null)
  898.     {
  899.         $q = $this
  900.             ->createQueryBuilder('c')
  901.             ->andWhere('c.status =:c_status')
  902.             ->setParameter('c_status', BiConst::STATE_PUBLISHED);
  903.         if ($ids) {
  904.             $ids = preg_replace('#[\s]+#i', '', trim($ids));
  905.             $IDS = explode(',', $ids);
  906.             $q->andWhere('c.id in (:ids)')
  907.                 ->setParameter('ids', $IDS);
  908.         }
  909.         if ($limit) {
  910.             $q->setMaxResults($limit);
  911.         }
  912.         $r = $q->getQuery();
  914.         return $r->getResult();
  915.     }
  917.     /**
  918.      * @param int $p
  919.      * @param int $l
  920.      * @param null $id
  921.      * @return array|null
  922.      */
  923.     public function getCollCheck($p, $l = 10000, $id = null)
  924.     {
  925.         $offset = $l * $p - $l;
  927.         $rsm = new ResultSetMapping();
  928.         $rsm->addEntityResult('WebBundle\Entity\Factory', 'f');
  929.         $rsm->addFieldResult('f', 'f_id', 'id');
  930.         $rsm->addFieldResult('f', 'f_url', 'url');
  931.         $rsm->addJoinedEntityResult('WebBundle\Entity\User', 'u', 'f', 'user');
  932.         $rsm->addFieldResult('u', 'u_id', 'id');
  933.         $rsm->addFieldResult('u', 'username', 'username');
  934.         $rsm->addJoinedEntityResult('WebBundle\Entity\Article', 'a', 'c', 'articles');
  935.         $rsm->addFieldResult('a', 'id', 'id');
  936.         $rsm->addFieldResult('a', 'file', 'file');
  937.         $rsm->addJoinedEntityResult('WebBundle\Entity\Collection', 'c', 'f', 'collection');
  938.         $rsm->addFieldResult('c', 'c_id', 'id');
  939.         $rsm->addFieldResult('c', 'c_url', 'url');
  940.         $rsm->addJoinedEntityResult('WebBundle\Entity\Interior', 'i', 'c', 'interiors');
  941.         $rsm->addFieldResult('i', 'i_id', 'id');
  942.         $rsm->addFieldResult('i', 'i_name', 'name');
  943.         $rsm->addFieldResult('i', 'i_file', 'file');
  945.         $ID = $id != null ? ('c.id=' . $id . ' AND ') : '';
  946.         $query = $this->_em->createNativeQuery(
  947.             'SELECT
  948.                 f.id AS f_id,
  949.                 f.url AS f_url,
  950.                 u.id AS u_id,
  951.                 u.username,
  952.                 c.id AS c_id,
  953.                 c.url AS c_url,
  954.                 a.id,
  955.                 a.file,
  956.                 i.id AS i_id,
  957.                 i.name AS i_name,
  958.                 i.file AS i_file
  959.             FROM factory f
  960.             LEFT JOIN user u ON f.user_id = u.id
  961.             LEFT JOIN collection c ON c.factory = f.id
  962.             LEFT JOIN article a ON a.collection = c.id
  963.             LEFT JOIN interior i ON i.collection = c.id
  964.             WHERE ' . $ID . 'c.status IN (' . BiConst::STATE_PUBLISHED . ', ' . BiConst::STATE_DISCONTINUED . ') AND f.status > ' . BiConst::STATE_DISCONTINUED . ' AND a.file IS NOT NULL AND a.delivery <> 6 LIMIT ' . $l . ' OFFSET ' . $offset . ';',
  965.             $rsm
  966.         );
  968.         $result = $query->getArrayResult();
  969.         return $result;
  970.     }
  972.     /**
  973.      * @return int|mixed
  974.      * @throws NoResultException
  975.      * @throws NonUniqueResultException
  976.      */
  977.     public function countAllCollection()
  978.     {
  979.         $q = $this->createQueryBuilder('q');
  980.         $q->select('count(q.id)')
  981.             ->andWhere('q.status = :status')
  982.             ->setParameter('status', BiConst::STATE_PUBLISHED);
  984.         $count = $q->getQuery()->getSingleScalarResult();
  986.         return $count;
  987.     }
  989.     /**
  990.      * Получаем рейтинги для коллекций отдельно, чтобы не чистить из-за них кеш
  991.      * @param array $id
  992.      * @return array|null
  993.      */
  994.     public function getRatings(array $id)
  995.     {
  996.         if (count($id) == 0) {
  997.             return [];
  998.         }
  1000.         if (is_array($id)) {
  1001.             $id = implode(', ', $id);
  1002.             $id = "($id)";
  1003.         }
  1005.         $q = $this->createQueryBuilder('c')
  1006.             ->select('c.id, c.rating')
  1007.             ->andWhere("c.id IN {$id}");
  1009.         $r = $q->getQuery()->useQueryCache(true);
  1011.         $items = $r->getArrayResult();
  1012.         $res = [];
  1013.         foreach ($items as $item) {
  1014.             $res[$item['id']] = $item['rating'];
  1015.         }
  1017.         return $res;
  1018.     }
  1020.     /**
  1021.      * todo remove from bi
  1022.      * @return array|null
  1023.      */
  1024.     public function _getOutputLastCollectionsInteriorImg()
  1025.     {
  1026.         $limit = 55;
  1027.         $q = $this
  1028.             ->createQueryBuilder('c')
  1029.             ->andWhere('(SELECT count(i.id) FROM WebBundle\Entity\Interior i Where c.id=i.collection) > :count')
  1030.             ->setParameter('count', 5)
  1031.             ->orderBy('c.rating', 'desc')
  1032.             ->setMaxResults($limit)
  1033.             ->getQuery();
  1035.         $items = $q->getResult();
  1036.         $oui = [];
  1037.         /** @var Collection $item */
  1038.         foreach ($items as $k => $item) {
  1039.             foreach ($item->getInteriors() as $key => $interior) {
  1040.                 if ($key < 3) {
  1041.                     $oui[] = [
  1042.                         'collection' => $item,
  1043.                         'interior' => $interior,
  1044.                     ];
  1045.                 } else {
  1046.                     break;
  1047.                 }
  1048.             }
  1049.         }
  1051.         return $oui;
  1052.     }
  1054.     /**
  1055.      * Список БМов, которые задействованы в коллекциях
  1056.      * @return array
  1057.      * @throws Exception
  1058.      */
  1059.     public function getListActiveBM()
  1060.     {
  1061.         $q = $this->createQueryBuilder('c')
  1062.             ->select('DISTINCT(user) AS uid, user.alias, user.username')
  1063.             ->leftJoin('c.factory', 'factory')
  1064.             ->leftJoin('factory.user', 'user')
  1065.             ->andWhere('c.factory is not null')
  1066.             ->andWhere('factory.status != 2')
  1067.             ->andWhere('factory.status != 3')
  1068.             ->andWhere('factory.status != 0')
  1069.             ->getQuery();
  1071.         $list = [];
  1072.         $oServiceUser = App::getContainer()->get('adm.service.users');
  1074.         foreach ($q->getArrayResult() as $item) {
  1075.             if (!empty($item['uid'])) {
  1076.                 $name = $item['alias'] ? $item['alias'] : $item['username'];
  1077.                 $list[$item['uid']] = $oServiceUser->buildEasyName($name);
  1078.             }
  1079.         }
  1081.         return $list;
  1082.     }
  1084.     /**
  1085.      * @return array
  1086.      */
  1087.     public function getCollForVideo()
  1088.     {
  1089.         $q = $this->createQueryBuilder('c')
  1090.             ->select('c, b')
  1091.             ->leftJoin('c.body', 'b')
  1092.             ->andWhere('b.en LIKE \'%youtube%\'')
  1093.             ->getQuery();
  1095.         return $q->getResult();
  1096.     }
  1098.     /**
  1099.      * todo remove from bi
  1100.      * получить набор коллекций для загрузки оброаботанных дизайнером изображений
  1101.      * @param Collection|null $collection
  1102.      * @return array|null
  1103.      */
  1104.     public function _getCollectionsByCollection(Collection $collection = null)
  1105.     {
  1106.         $q = $this->createQueryBuilder('c')
  1107.             ->andWhere('c.status = :status1 or c.status = :status4')
  1108.             ->setParameter('status1', BiConst::STATE_PUBLISHED)
  1109.             ->setParameter('status4', BiConst::STATE_PROCESSING);
  1111.         if ($collection) {
  1112.             $id = $collection->getId();
  1113.             $q
  1114.                 ->andWhere('c.id = :id')
  1115.                 ->setParameter('id', $id);
  1116.         }
  1118.         $r = $q->getQuery()
  1119.             ->useQueryCache(true)
  1120.             ->enableResultCache(3600 * 24 * 30);
  1122.         return $r->getResult();
  1123.     }
  1125.     /**
  1126.      * todo remove from bi
  1127.      * @param User $user
  1128.      * @return array|null
  1129.      */
  1130.     public function _getCollectionsForBm(User $user)
  1131.     {
  1132.         $q = $this->createQueryBuilder('c')
  1133.             ->leftJoin('c.factory', 'f')
  1134.             ->leftJoin('f.user', 'u');
  1136.         if ($user->hasRole('ROLE_BM')) {
  1137.             $q
  1138.                 ->andWhere('u.id = :user')
  1139.                 ->setParameter('user', $user->getId());
  1140.         }
  1142.         $r = $q
  1143.             ->andWhere('f.status = :fstatus')
  1144.             ->andWhere('c.status = :cstatus1 or c.status = :cstatus4')
  1145.             ->setParameter('fstatus', BiConst::STATE_PUBLISHED)
  1146.             ->setParameter('cstatus1', BiConst::STATE_PUBLISHED)
  1147.             ->setParameter('cstatus4', BiConst::STATE_PROCESSING)
  1148.             ->orderBy('f.url, c.url')
  1149.             ->getQuery();
  1151.         return $r->getResult();
  1152.     }
  1154.     /**
  1155.      * Получение списка для проверки на наличие кириллических символов
  1156.      * @return array
  1157.      */
  1158.     public function getCollectionsAdmForCheckCyrillic()
  1159.     {
  1160.         $q = $this->createQueryBuilder('c')
  1161.             ->select('c, body')
  1162.             ->leftJoin('c.body', 'body')
  1163.             ->andWhere('c.status = :status')
  1164.             ->setParameter('status', BiConst::STATE_PUBLISHED);
  1166.         return $q->getQuery()->getArrayResult();
  1167.     }
  1170.     /**
  1171.      * Получение списка блогов с которыми связана коллекция
  1172.      * @param        $collectionId
  1173.      * @param string $lc
  1174.      * @return array
  1175.      * @throws Exception
  1176.      */
  1177.     public function getPublications($collectionId, $lc)
  1178.     {
  1179.         // получаем полную локаль, для формирования ссылки
  1180.         $lcFull = $lc;
  1181.         if ($lcFull != ($cc = App::getCurCountry())) {
  1182.             $lcFull = "$lc-$cc";
  1183.         }
  1185.         $unid = 'unid';
  1187.         $q = $this->createQueryBuilder('c')
  1188.             ->select(
  1189.                 "c.id cId, c.code cCode, c.{$unid} unid, p.view view, p.publishDate publishDate, p.unid pUnid, p.id pId, title.{$lc} pTitle, body.{$lc} pBody, url.{$lc} pUrl, pr.default preview"
  1190.             )
  1191.             ->leftJoin('c.publications', 'p')
  1192.             ->leftJoin('p.url', 'url')
  1193.             ->leftJoin('p.title', 'title')
  1194.             ->leftJoin('p.body', 'body')
  1195.             ->leftJoin('p.preview', 'pr')
  1196.             ->andWhere('p.enable = true OR p.id IS NULL')
  1197.             ->andWhere('c.id = :id')
  1198.             ->setParameter('id', $collectionId);
  1200.         $res = [
  1201.             'publications' => [],
  1202.         ];
  1204.         /** @var CommentRepository $repoComment */
  1205.         $repoComment = App::getRepository(CommentEntity::class);
  1207.         foreach ($q->getQuery()->getArrayResult() as $row) {
  1208.             if (empty($res['id'])) {
  1209.                 $res['id'] = $row['cId'];
  1210.             }
  1212.             if (empty($res['code'])) {
  1213.                 $res['code'] = $row['cCode'];
  1214.             }
  1216.             if (empty($res['unid'])) {
  1217.                 $res['unid'] = $row['unid'];
  1218.             }
  1220.             if (!empty($row['pUrl']) && !empty($row['pTitle'])) {
  1221.                 $res['publications'][] = [
  1222.                     'link' => App::generateUrl('app_publication_single', ['id' => $row['pUrl'], '_locale' => $lcFull]),
  1223.                     'title' => $row['pTitle'],
  1224.                     'body' => $row['pBody'],
  1225.                     'publishDate' => $row['publishDate'],
  1226.                     'view' => $row['view'],
  1227.                     'preview' => PathHelper::pathGenerate(
  1228.                         'publication',
  1229.                         [
  1230.                             'id' => $row['pId'],
  1231.                             'preview' => $row['preview'],
  1232.                         ]
  1233.                     ),
  1234.                     'commentCnt' => !empty($row['pUnid'])
  1235.                         ? $repoComment->getCountPublicationsByUnid($lc, $row['pUnid'])
  1236.                         : 0
  1237.                 ];
  1238.             }
  1239.         }
  1241.         return $res;
  1242.     }
  1244.     /**
  1245.      * Установка парамтеров к запросу для выборки коллекции на главной
  1246.      * @param $factory
  1247.      * @param $collection
  1248.      * @return mixed|null
  1249.      */
  1250.     public function getMainBaseCollectionLight($factory, $collection)
  1251.     {
  1252.         $query = $this->createQueryBuilder('c')
  1253.             ->select('c, f, country, body, metaKeywords, metaDescription')
  1254.             ->leftJoin('c.factory', 'f')
  1255.             ->leftJoin('f.country', 'country')
  1256.             ->leftJoin('c.body', 'body')
  1257.             ->leftJoin('c.metaKeywords', 'metaKeywords')
  1258.             ->leftJoin('c.metaDescription', 'metaDescription')
  1259.             ->andWhere('f.status > :f_status')
  1260.             ->andWhere('f.url = :factory')
  1261.             ->andWhere('c.url = :collection')
  1262.             ->setParameters([
  1263.                 'f_status' => BiConst::STATE_NOT_PUBLISHED,
  1264.                 'factory' => $factory,
  1265.                 'collection' => $collection,
  1266.             ])
  1267.             ->getQuery()
  1268.             ->setQueryCacheLifetime(TimeConstant::HOUR)
  1269.             ->useQueryCache(true);
  1271.         $item = $query->getArrayResult();
  1273.         $res = current($item);
  1275.         // закрываем некоторые фабрики для некоторых стран
  1276.         if ($res && in_array($res['factory']['id'], HideFactoryCountriesHelper::codes())) {
  1277.             $res['factory']['status'] = 3;
  1278.             $res['status'] = 3;
  1279.         }
  1281.         return $res;
  1282.     }
  1284.     /**
  1285.      * формирование запроса для выборки данных коллекции и связанных интерьеров для главной и для слайдера
  1286.      * @return QueryBuilder
  1287.      */
  1288.     public function createQuerySliderBaseCollection()
  1289.     {
  1290.         $q = $this->createQueryBuilder('c');
  1291.         $q
  1292.             ->select('c, f, i, idea, applies, styles, textures, country, body, metaKeywords, metaDescription')
  1293.             ->leftJoin('c.factory', 'f')
  1294.             ->leftJoin('f.country', 'country')
  1295.             ->leftJoin('c.body', 'body')
  1296.             ->leftJoin('c.metaKeywords', 'metaKeywords')
  1297.             ->leftJoin('c.metaDescription', 'metaDescription');
  1299.         $where = 'f.status > :f_status';
  1300.         $q
  1301.             ->andWhere($where)
  1302.             ->orderBy('i.isMain', 'DESC')
  1303.             ->setParameter('f_status', BiConst::STATE_NOT_PUBLISHED);
  1305.         return $q;
  1306.     }
  1308.     /**
  1309.      * @param $code
  1310.      * @return mixed
  1311.      * @throws NoResultException
  1312.      * @throws NonUniqueResultException
  1313.      */
  1314.     public function getCollectionByCode($code)
  1315.     {
  1316.         $q = $this->createQueryBuilder('c')
  1317.             ->select('c,f,u')
  1318.             ->leftJoin('c.factory', 'f')
  1319.             ->leftJoin('f.user', 'u')
  1320.             ->andWhere('c.code = :code')
  1321.             ->setParameter('code', $code);
  1322.         return $q->getQuery()->getSingleResult();
  1323.     }
  1325.     /**
  1326.      * @param $codes
  1327.      * @return mixed
  1328.      */
  1329.     public function getCollectionByCodes($codes)
  1330.     {
  1331.         $q = $this->createQueryBuilder('c')
  1332.             ->andWhere('c.code in (:code)')
  1333.             ->setParameter('code', $codes);
  1334.         return $q->getQuery()->getResult();
  1335.     }
  1337.     /**
  1338.      * @param null $fid
  1339.      * @param array $onlyIds
  1340.      * @return array
  1341.      */
  1342.     public function admGetForJsTree($fid = null, array $onlyIds = [])
  1343.     {
  1344.         $q = $this->createQueryBuilder('c');
  1345.         $q->select('c.id, c.name, f.name as fname')
  1346.             ->leftJoin('c.factory', 'f')
  1347.             ->andWhere('c.status = :statusPub')
  1348.             ->orWhere('c.status = :statusCheck')
  1349.             ->addOrderBy('c.name', 'ASC')
  1350.             ->setParameter('statusPub', BiConst::STATE_PUBLISHED)
  1351.             ->setParameter('statusCheck', BiConst::STATE_CHECKING);
  1353.         if ($onlyIds) {
  1354.             $onlyIds = implode(',', $onlyIds);
  1355.             $q->andWhere("c.id IN ({$onlyIds})");
  1356.         }
  1358.         if ($fid) {
  1359.             $q->andWhere('f.id = :fid')
  1360.                 ->setParameter('fid', $fid);
  1361.         }
  1363.         $items = $q->getQuery()->getArrayResult();
  1364.         $res = [];
  1365.         foreach ($items as $i => $item) {
  1366.             $res[$item['id']] = $item;
  1367.         }
  1369.         // сортироуем по имени
  1370.         $resSort = array_column($res, 'name');
  1371.         array_multisort($resSort, SORT_ASC, $res);
  1373.         return $res;
  1374.     }
  1376.     /**
  1377.      * @param $cid
  1378.      * @return Collection|null
  1379.      */
  1380.     public function getByIdForParseAttr($cid)
  1381.     {
  1382.         $q = $this->createQueryBuilder('c')
  1383.             ->select('c,f')
  1384.             ->leftJoin('c.factory', 'f')
  1385.             ->andWhere('c.id = :id')
  1386.             ->setParameter('id', $cid);
  1387.         try {
  1388.             $item = $q->getQuery()->getOneOrNullResult();
  1389.         } catch (NonUniqueResultException $e) {
  1390.             $item = null;
  1391.         }
  1392.         return $item;
  1393.     }
  1395.     /**
  1396.      * Получаем список ID коллекция для парсига их свойств
  1397.      * @param bool $onlyNull
  1398.      * @return array
  1399.      */
  1400.     public function getIdsForParseAttr($onlyNull = false)
  1401.     {
  1402.         $q = $this->createQueryBuilder('c')->select('c.id');
  1403.         if ($onlyNull) {
  1404.             $q->andWhere('c.fids IS NULL');
  1405.         }
  1407.         $ids = $q->getQuery()->getArrayResult();
  1408.         if ($ids) {
  1409.             $ids = array_column($ids, 'id');
  1410.         }
  1411.         return $ids;
  1412.     }
  1414.     /**
  1415.      * @param int $id
  1416.      * @return mixed
  1417.      * @throws NoResultException
  1418.      * @throws NonUniqueResultException
  1419.      * @todo remove from bi
  1420.      */
  1421.     public function _getCollectionsForFeed($id)
  1422.     {
  1423.         $q = $this->createQueryBuilder('c')
  1424.             ->select('c,f')
  1425.             ->leftJoin('c.factory', 'f')
  1426.             ->leftJoin('c.articles', 'articles')
  1427.             ->leftJoin('c.interiors', 'interiors')
  1428.             ->andWhere('c.id = :id')
  1429.             ->setParameter('id', $id);
  1430.         $r = $q->getQuery();
  1431.         $item = $r->getSingleResult();
  1433.         return $item;
  1434.     }
  1436.     /**
  1437.      * @param array $params
  1438.      * @return array
  1439.      * @todo remove from bi
  1440.      */
  1441.     public function _getItemsForFeed($params = [])
  1442.     {
  1443.         $id = isset($params['code']) ? $params['code'] : null;
  1444.         $brand = isset($params['brand']) ? $params['brand'] : null;
  1445.         $limit = isset($params['limit']) ? $params['limit'] : null;
  1447.         $q = $this->createQueryBuilder('c')
  1448.             ->select('c.id,c.code,c.name, f.name fname, fl.leftMenu, fc.alias')
  1449.             ->leftJoin('c.factory', 'f')
  1450.             ->leftJoin('f.filter', 'fl')
  1451.             ->leftJoin('f.country', 'fc')
  1452.             ->andWhere('c.status = :status1')
  1453.             ->setParameter('status1', BiConst::STATE_PUBLISHED)
  1454.             ->andWhere('f.status = :status')
  1455.             ->setParameter('status', BiConst::STATE_PUBLISHED);
  1456.         if ($id) {
  1457.             if ($id == 'test') {
  1458.                 $limit = $limit ? $limit : 50;
  1459.                 $q
  1460.                     ->setMaxResults($limit);
  1461.             } else {
  1462.                 $q
  1463.                     ->andWhere('c.id = :id')
  1464.                     ->setParameter('id', $id);
  1465.             }
  1466.         }
  1467.         if ($brand) {
  1468.             $q
  1469.                 ->andWhere('f.id = :brand')
  1470.                 ->setParameter('brand', $brand);
  1471.         }
  1472.         $q->addOrderBy('f.name', 'ASC');
  1473.         $q->addOrderBy('c.name', 'ASC');
  1474.         $r = $q->getQuery();
  1476.         return $r->getArrayResult();
  1477.     }
  1479.     /**
  1480.      * Получение имени для графика статистик в админке
  1481.      * @param array $fids
  1482.      * @return array
  1483.      */
  1484.     public function getNamesForStatChartAdmin(array $fids)
  1485.     {
  1486.         $fidsStr = implode(',', $fids);
  1488.         $sql = "SELECT
  1489.                 c.id,
  1490.                 c.name AS `name`,
  1491.                 f.name AS `fname`
  1492.             FROM
  1493.                 collection c
  1494.             LEFT JOIN factory f ON c.factory = f.id
  1495.             WHERE c.id IN ({$fidsStr})
  1496.             ORDER BY c.name ";
  1498.         $items = $this->_em->getConnection()->fetchAll($sql);
  1500.         $r = [];
  1502.         foreach ($items as $item) {
  1503.             $id = $item['id'];
  1504.             $r[$id] = [
  1505.                 'name' => "{$item['name']} ({$item['fname']})",
  1506.                 'data' => [],
  1507.             ];
  1508.         }
  1510.         return $r;
  1511.     }
  1513.     /**
  1514.      * @param $params
  1515.      * @return float|int|mixed|string
  1516.      * @todo remove from bi
  1517.      */
  1518.     public function _getItemsForCalculationImages($params = [])
  1519.     {
  1520.         $id = isset($params['code']) ? $params['code'] : null;
  1521.         $q = $this->createQueryBuilder('c')
  1522.             ->andWhere('c.status = :status1')
  1523.             ->setParameter('status1', BiConst::STATE_PUBLISHED);
  1524.         if ($id) {
  1525.             if ($id == 'test') {
  1526.                 $limit = 5;
  1527.                 $q
  1528.                     ->setMaxResults($limit);
  1529.             } else {
  1530.                 $q
  1531.                     ->andWhere('c.id = :id')
  1532.                     ->setParameter('id', $id);
  1533.             }
  1534.         }
  1535.         $r = $q->getQuery();
  1537.         return $r->getResult();
  1538.     }
  1540.     /**
  1541.      * @param $param
  1542.      * @return mixed
  1543.      * @todo remove from bi
  1544.      */
  1545.     public function _getCollectionsForJpegtran($param)
  1546.     {
  1547.         $q = $this->createQueryBuilder('c');
  1548.         if ($param['ides'] != 'all') {
  1549.             $q->andWhere('c.id IN (' . join(', ', $param['ides']) . ')');
  1550.         } else {
  1551.             if ($param['brand']) {
  1552.                 $q
  1553.                     ->leftJoin('c.factory', 'f')
  1554.                     ->andWhere('f.id IN (' . join(', ', $param['brand']) . ')');
  1555.             }
  1556.         }
  1557.         if (!empty($param['states'])) {
  1558.             $q->andWhere('c.status IN (' . join(', ', $param['states']) . ')');
  1559.         }
  1560.         $r = $q->getQuery();
  1562.         return $r->getResult();
  1563.     }
  1565.     /**
  1566.      * @param null $code
  1567.      * @return array
  1568.      * @todo remove from bi
  1569.      */
  1570.     public function _getItemsForRenameAdblock($code = null)
  1571.     {
  1572.         $q = $this->createQueryBuilder('c')
  1573.             ->select('c.id, c.name, f.name fname')
  1574.             ->leftJoin('c.factory', 'f')
  1575.             ->andWhere('c.status = :status1')
  1576.             ->setParameter('status1', BiConst::STATE_PUBLISHED)
  1577.             ->andWhere('f.suspended <> :suspended')
  1578.             ->setParameter('suspended', BiConst::STATE_PUBLISHED);
  1579.         if ($code) {
  1580.             if ($code == 'test') {
  1581.                 $limit = 50;
  1582.                 $q
  1583.                     ->setMaxResults($limit);
  1584.             } else {
  1585.                 $q
  1586.                     ->andWhere('c.id = :id')
  1587.                     ->setParameter('id', $code);
  1588.             }
  1589.         }
  1590.         $r = $q->getQuery();
  1592.         return $r->getArrayResult();
  1593.     }
  1595.     /**
  1596.      * Ищем коллекцию для проставления связи с коллекцией выставки
  1597.      * @param string $cName
  1598.      * @param int $bid
  1599.      * @return array|null
  1600.      */
  1601.     public function getCollByNameForExh(string $cName, int $bid)
  1602.     {
  1603.         $conn = $this->_em->getConnection();
  1604.         $cName = $conn->quote($cName);
  1605.         $sql = "SELECT
  1606.                 `c`.id AS `id`,
  1607.                 `c`.name AS `name`,
  1608.                 `c`.name_full AS `nameFull`,
  1609.                 `c`.alternate_name AS `nameAlt`,
  1610.                 `brand`.id AS `brandId`,
  1611.                 `brand`.name AS `brandName`
  1612.             FROM
  1613.                 collection c
  1614.             LEFT JOIN factory `brand` ON `brand`.id = `c`.factory
  1615.             WHERE (`c`.`name` LIKE {$cName} OR  `c`.`name_full` LIKE {$cName}  OR  `c`.`alternate_name` LIKE {$cName}) AND `c`.factory = {$bid}
  1616.             ";
  1618.         $items = $conn->fetchAll($sql);
  1620.         return $items ? $items[0] : null;
  1621.     }
  1623.     public function getCollectionsForSliderNative($id)
  1624.     {
  1625.         $rsm = new ResultSetMapping();
  1626.         $rsm->addEntityResult('WebBundle\Entity\Collection', 'c');
  1627.         $rsm->addFieldResult('c', 'id', 'id');
  1628.         $rsm->addFieldResult('c', 'name', 'name');
  1629.         $rsm->addFieldResult('c', 'alternate_name', 'alternateName');
  1630.         $rsm->addFieldResult('c', 'url', 'url');
  1631.         $rsm->addFieldResult('c', 'header', 'header');
  1632.         $rsm->addFieldResult('c', 'settings', 'settings');
  1633.         $rsm->addFieldResult('c', 'rating', 'rating');
  1634.         $rsm->addFieldResult('c', 'status', 'status');
  1635.         $rsm->addJoinedEntityResult('WebBundle\Entity\Factory', 'f', 'c', 'factory');
  1636.         $rsm->addFieldResult('f', 'f_id', 'id');
  1637.         $rsm->addFieldResult('f', 'f_name', 'name');
  1638.         $rsm->addFieldResult('f', 'f_url', 'url');
  1639.         $rsm->addFieldResult('f', 'f_stated_at', 'statedAt');
  1640.         $rsm->addFieldResult('f', 'f_status', 'status');
  1641.         $rsm->addJoinedEntityResult('WebBundle\Entity\FilterEntity', 'fl', 'f', 'filter');
  1642.         $rsm->addFieldResult('fl', 'fl_id', 'id');
  1643.         $rsm->addJoinedEntityResult('WebBundle\Entity\FilterParamEntity', 'flp', 'fl', 'param');
  1644.         $rsm->addFieldResult('flp', 'flp_id', 'id');
  1645.         $rsm->addFieldResult('flp', 'flp_code', 'code');
  1646.         $rsm->addJoinedEntityResult('WebBundle\Entity\FilterEntity', 'flc', 'fl', 'country');
  1647.         $rsm->addFieldResult('flc', 'flc_id', 'id');
  1648.         $rsm->addFieldResult('flc', 'flc_left_menu', 'leftMenu');
  1650.         $query = $this->_em->createNativeQuery(
  1651.             "SELECT
  1652.               c.id,
  1653.               c.name,
  1654.               c.alternate_name,
  1655.               c.url,
  1656.               c.header,
  1657.               c.settings,
  1658.               c.rating,
  1659.               c.status,
  1660.               f.id AS f_id,
  1661.               f.name AS f_name,
  1662.               f.url AS f_url,
  1663.               f.stated_at AS f_stated_at,
  1664.               f.status AS f_status,
  1665.               fl.id AS fl_id,
  1666.               fl.country_id AS fl_country_id,
  1667.               flc.id AS flc_id,
  1668.               flc.left_menu AS flc_left_menu,
  1669.               flp.id AS flp_id,
  1670.               flp.code AS flp_code
  1674.             FROM
  1675.               collection c
  1676.             LEFT JOIN factory f ON f.id = c.factory
  1677.             LEFT JOIN filters fl ON fl.id = f.filter
  1678.             LEFT JOIN filters flc ON flc.id = fl.country_id
  1680.             LEFT JOIN filter_params flp ON flp.id = flc.param_id
  1682.             WHERE c.id ={$id} ",
  1683.             $rsm
  1684.         );
  1685.         $result = $query->getArrayResult();
  1687.         return array_shift($result);
  1688.     }
  1690.     /**
  1691.      * @param int $cid
  1692.      * @return false|string
  1693.      * @throws DBALException
  1694.      */
  1695.     public function getNameForFilterHistorySearch(int $cid)
  1696.     {
  1697.         $sql = "SELECT
  1698.                 c.name AS `name`
  1699.             FROM
  1700.                 collection c
  1701.             WHERE
  1702.                 c.id = '{$cid}'";
  1704.         $items = $this->_em
  1705.             ->getConnection()
  1706.             ->executeQuery($sql)
  1707.             ->fetchColumn(0);
  1709.         return $items;
  1710.     }
  1713.     /**
  1714.      * Получение ID для сбора рекомендаций в админку для теста
  1715.      * @param string $fUrl
  1716.      * @param string $cUrl
  1717.      * @return int|null
  1718.      */
  1719.     public function getCollIdForNeyronAdmin(string $fUrl, string $cUrl)
  1720.     {
  1721.         $conn = $this->_em->getConnection();
  1722.         $fUrl = $str = mb_strtolower($fUrl, 'UTF-8');
  1723.         $cUrl = $str = mb_strtolower($cUrl, 'UTF-8');
  1725.         $sql = "SELECT
  1726.                 c.id
  1727.             FROM
  1728.                 collection c
  1729.             LEFT JOIN factory f ON f.id = c.factory
  1730.             WHERE c.url = '{$cUrl}' AND f.url = '{$fUrl}'
  1731.             ";
  1733.         $id = $conn->fetchAll($sql);
  1734.         if ($id) {
  1735.             $id = $id[0]['id'];
  1736.         } else {
  1737.             $id = null;
  1738.         }
  1739.         return $id;
  1740.     }
  1742.     /**
  1743.      * Получение списка ID фильтров для сбора рекомендаций в админку для теста
  1744.      * @param array $cids
  1745.      * @return array
  1746.      */
  1747.     public function getCollFidsdForNeyronAdmin(array $cids)
  1748.     {
  1749.         $conn = $this->_em->getConnection();
  1750.         $cids = implode(', ', $cids);
  1751.         $sql = "SELECT
  1752.                 c.id,
  1753.                 c.fids
  1754.             FROM
  1755.                 collection c
  1756.             WHERE c.id IN ({$cids})
  1757.             ";
  1759.         $rows = $conn->fetchAll($sql);
  1761.         $items = [];
  1762.         foreach ($rows as $row) {
  1763.             $items[$row['id']] = json_decode($row['fids']);
  1764.         }
  1766.         return $items;
  1767.     }
  1769.     /**
  1770.      * @param $params
  1771.      * @return float|int|mixed[]|string
  1772.      * @todo remove from bi
  1773.      */
  1774.     public function _getItemsForInteriorCyrilic($params = [])
  1775.     {
  1776.         $id = isset($params['code']) ? $params['code'] : null;
  1777.         $brand = isset($params['brand']) ? $params['brand'] : null;
  1778.         $limit = isset($params['limit']) ? $params['limit'] : null;
  1779.         $q = $this->createQueryBuilder('c')
  1780.             ->select('c.id, c.name, c.url curl, f.name fname, f.url furl')
  1781.             ->leftJoin('c.factory', 'f')
  1782.             ->andWhere('c.status = :status1')
  1783.             ->setParameter('status1', BiConst::STATE_PUBLISHED)
  1784.             ->andWhere('f.suspended <> :suspended')
  1785.             ->setParameter('suspended', BiConst::STATE_PUBLISHED);
  1786.         if ($id) {
  1787.             if ($id == 'test') {
  1788.                 $limit = $limit ? $limit : 50;
  1789.                 $q
  1790.                     ->setMaxResults($limit);
  1791.             } else {
  1792.                 $q
  1793.                     ->andWhere('c.id = :id')
  1794.                     ->setParameter('id', $id);
  1795.             }
  1796.         }
  1797.         if ($brand) {
  1798.             $q
  1799.                 ->andWhere('f.id = :brand')
  1800.                 ->setParameter('brand', $brand);
  1801.         }
  1802.         $r = $q->getQuery();
  1803.         return $r->getArrayResult();
  1804.     }
  1806.     /**
  1807.      * @param $params
  1808.      * @return array
  1809.      * @throws Exception
  1810.      * @todo remove from bi
  1811.      */
  1812.     public function _getCollectionsIDSForCheckList($params)
  1813.     {
  1814.         $page = isset($params['page']) ? $params['page'] : 1;
  1815.         $limit = isset($params['limit']) ? $params['limit'] : BiConst::SEARCH_RESULT_ON_PAGE;
  1816.         $offset = $limit * ($page - 1);
  1817.         $states = !empty($params['states']) ? $params['states'] : null;
  1818.         $checkId = isset($params['check_id']) ? $params['check_id'] : 'all';
  1820.         $isCheckAll = $checkId == 'all';
  1821.         $suspended = !empty($params['suspended']) ? $params['suspended'] : null;
  1822.         $manager = isset($params['manager']) ? $params['manager'] : 'all';
  1823.         $brand = isset($params['brand']) ? $params['brand'] : 'all';
  1825.         $sqlWhereUser = '';
  1827.         if ($manager == 'all') {
  1828.             $sqlWhereManager = '';
  1829.         } else {
  1830.             $sqlWhereManager = "AND u.id = '{$manager}'";
  1831.         }
  1833.         if ($brand == 'all') {
  1834.             $sqlWhereBrand = '';
  1835.         } else {
  1836.             $sqlWhereBrand = "AND f.unid = '{$brand}'";
  1837.         }
  1839.         if ($isCheckAll) {
  1840.             $user = App::getCurUser();
  1841.             $sqlWhereCheckId = '';
  1842.             if ($user->hasRole('ROLE_BM')) {
  1843.                 $sqlWhereManager = "AND u.id = '{$user->getId()}'";
  1844.                 if ($suspended) {
  1845.                     $sqlWhereCheckId = "AND chl.code IN ('has_suspended_article', 'has_suspended_collection')";
  1846.                 }
  1847.             }
  1848.         } else {
  1849.             $sqlWhereCheckId = "AND chl.code = '{$checkId}'";
  1850.         }
  1851.         $sql = "
  1852.             SELECT
  1853.                 c.id
  1854.             FROM
  1855.                 collection c
  1856.             LEFT JOIN `factory` f ON f.id = c.factory
  1857.             LEFT JOIN `user` u ON u.id = f.user_id
  1858.             LEFT JOIN `check_list` chl ON chl.collection = c.id AND chl.showed = 1 {$sqlWhereCheckId}
  1859.             WHERE c.status = {$states}
  1860.                 AND c.factory > '0'
  1861.                 {$sqlWhereManager}
  1862.                 {$sqlWhereUser}
  1863.                 {$sqlWhereBrand}
  1864.             GROUP BY c.id
  1865.             HAVING COUNT(DISTINCT chl.id) > 0
  1866.             ORDER BY u.alias, f.url, c.url";
  1867.         $idsAll = ConnectionHelper::getInstance()->executeFetchAllSql($sql, PDO::FETCH_COLUMN);
  1868.         $all = count($idsAll);
  1870.         $sql = $sql . "    LIMIT {$limit} OFFSET {$offset};";
  1871.         $ids = ConnectionHelper::getInstance()->executeFetchAllSql($sql, PDO::FETCH_COLUMN);
  1872.         return [
  1873.             'ids' => $ids,
  1874.             'allItems' => $all,
  1875.         ];
  1876.     }
  1878.     /**
  1879.      * @param $code
  1880.      * @return float|int|mixed|string
  1881.      * @todo remove from bi
  1882.      */
  1883.     public function _getCollectionByDesigner($code = null)
  1884.     {
  1885.         $q = $this->createQueryBuilder('c')
  1886.             ->leftJoin('c.factory', 'f')
  1887.             ->orWhere('c.status = :status1')
  1888.             ->orWhere('c.status = :status4')
  1889.             ->setParameter('status1', BiConst::STATE_PUBLISHED)
  1890.             ->setParameter('status4', BiConst::STATE_PROCESSING);
  1891.         if ($code) {
  1892.             $q
  1893.                 ->andWhere('c.id = :id')
  1894.                 ->setParameter('id', $code);
  1895.         }
  1896.         $q
  1897.             ->addOrderBy('f.name', 'ASC')
  1898.             ->addOrderBy('c.name', 'ASC');
  1899.         $r = $q->getQuery();
  1901.         return $r->getResult();
  1902.     }
  1904.     /**
  1905.      * @param array $params
  1906.      * @return array|int|string
  1907.      * @todo remove from bi
  1908.      */
  1909.     public function _getItemsMainInteriorCreate($params = [])
  1910.     {
  1911.         $id = isset($params['code']) ? $params['code'] : null;
  1912.         $brand = isset($params['brand']) ? $params['brand'] : null;
  1913.         $limit = isset($params['limit']) ? $params['limit'] : null;
  1914.         $q = $this->createQueryBuilder('c')
  1915.             ->select('c.id, c.name, c.url curl, f.name fname, f.url furl')
  1916.             ->leftJoin('c.factory', 'f')
  1917.             ->andWhere('c.status = :status1')
  1918.             ->setParameter('status1', BiConst::STATE_PUBLISHED)
  1919.             ->andWhere('f.suspended <> :suspended')
  1920.             ->setParameter('suspended', BiConst::STATE_PUBLISHED);
  1921.         if ($id) {
  1922.             if ($id == 'test') {
  1923.                 $limit = $limit ? $limit : 50;
  1924.                 $q
  1925.                     ->setMaxResults($limit);
  1926.             } else {
  1927.                 $q
  1928.                     ->andWhere('c.id = :id')
  1929.                     ->setParameter('id', $id);
  1930.             }
  1931.         }
  1932.         if ($brand) {
  1933.             if (is_numeric($brand)) {
  1934.                 $q->andWhere('f.id =:brand');
  1935.             } else {
  1936.                 $q->andWhere('f.name =:brand');
  1937.             }
  1938.             $q->setParameter('brand', $brand);
  1939.         }
  1940.         $r = $q->getQuery();
  1942.         $out = $r->getArrayResult();
  1944.         return $out;
  1945.     }
  1947.     /**
  1948.      * @param $param
  1949.      * @return float|int|mixed|string
  1950.      * @todo remove from bi
  1951.      */
  1952.     public function _getCollectionsForRecrop($param)
  1953.     {
  1954.         $q = $this->createQueryBuilder('c');
  1955.         if ($param['ides'] != 'all') {
  1956.             $q->andWhere('c.id IN (' . join(', ', $param['ides']) . ')');
  1957.         } else {
  1958.             if ($param['brand']) {
  1959.                 $q
  1960.                     ->leftJoin('c.factory', 'f')
  1961.                     ->andWhere('f.id IN (' . join(', ', $param['brand']) . ')');
  1962.             }
  1963.         }
  1964.         if (!empty($param['states'])) {
  1965.             $q->andWhere('c.status IN (' . join(', ', $param['states']) . ')');
  1966.         }
  1967.         $r = $q->getQuery();
  1969.         return $r->getResult();
  1970.     }
  1972.     /**
  1973.      * Получение коллекций для выгрузки в Google Recommendations AI
  1974.      *
  1975.      * @param integer $limit
  1976.      * @param integer $offset
  1977.      * @return array
  1978.      */
  1979.     public function getCollectionsForGoogleRecommendationAi($limit = 10, $offset = 0)
  1980.     {
  1981.         $builder = $this->createQueryBuilder('c');
  1982.         $builder->select('c.id', 'c.name')
  1983.             ->where('c.status IN (1,2,3,4,7)')
  1984.             ->where('c.archive = 0')
  1985.             ->andWhere('c.url IS NOT NULL AND c.url <> \'\'')
  1986.             ->setMaxResults($limit)
  1987.             ->setFirstResult($offset);
  1988.         $query = $builder->getQuery();
  1989.         $rows = $query->getResult();
  1991.         return $rows;
  1992.     }
  1994.     /**
  1995.      * @return array|bool
  1996.      * @throws Exception
  1997.      * @todo remove from bi
  1998.      */
  1999.     public function _getModalTempateDescriptionInsert()
  2000.     {
  2001.         $sql = "SELECT c.id, c.name, f.name fname,f.url furl FROM %s.collection c JOIN %s.factory f ON f.id=c.factory WHERE c.`status`=1 ORDER BY c.name;";
  2002.         $items = ConnectionHelper::getInstance()->executeFetchAllSql($sql);
  2004.         return $items;
  2005.     }
  2007.     /**
  2008.      * @return float|int|mixed|string
  2009.      * @todo remove from bi
  2010.      */
  2011.     public function _getCollectionForAddEventDescription()
  2012.     {
  2013.         $q = $this->createQueryBuilder('c')
  2014.             ->select('c,b')
  2015.             ->leftJoin('c.body', 'b')
  2016.             ->orWhere('b.ru like :simple')
  2017.             ->orWhere('b.ru like :multi')
  2018.             ->setParameter('simple', '%В интерьерах также использована плитка из коллекци%')
  2019.             ->setParameter('multi', '%В одном из интерьеров также использована плитка из коллекци%');
  2020.         $r = $q->getQuery();
  2021.         $items = $r->getResult();
  2023.         return $items;
  2024.     }
  2026.     /**
  2027.      * @param $furl
  2028.      * @param $curl
  2029.      * @return float|int|mixed|string|null
  2030.      * @throws NonUniqueResultException
  2031.      * @todo remove from bi
  2032.      */
  2033.     public function _getCollectionsByDescriptionCorrect($furl, $curl)
  2034.     {
  2035.         $r = $this->createQueryBuilder('c')
  2036.             ->select('c,f')
  2037.             ->leftJoin('c.factory', 'f')
  2038.             ->andWhere('f.url = :furl')
  2039.             ->andWhere('c.url = :curl')
  2040.             ->setParameter('furl', $furl)
  2041.             ->setParameter('curl', $curl)
  2042.             ->getQuery();
  2044.         return $r->getOneOrNullResult();
  2045.     }
  2047.     /**
  2048.      * @param $params
  2049.      * @return float|int|mixed|string
  2050.      * @todo remove from bi
  2051.      */
  2052.     public function _getItemsForConvertDesigner($params = [])
  2053.     {
  2054.         $id = isset($params['code']) ? $params['code'] : null;
  2055.         $brand = isset($params['brand']) ? $params['brand'] : null;
  2056.         $q = $this->createQueryBuilder('c')
  2057.             ->leftJoin('c.factory', 'f')
  2058.             ->andWhere('LENGTH(c.author)>0');
  2059.         if ($id) {
  2060.             $q
  2061.                 ->andWhere('c.id = :id')
  2062.                 ->setParameter('id', $id);
  2063.         } elseif ($brand) {
  2064.             $q
  2065.                 ->andWhere('f.id = :brand')
  2066.                 ->setParameter('brand', $brand);
  2067.         }
  2068.         $q->addOrderBy('f.name', 'ASC');
  2069.         $q->addOrderBy('c.name', 'ASC');
  2070.         $r = $q->getQuery();
  2072.         return $r->getResult();
  2073.     }
  2075.     public function getListForUpdate($full = false)
  2076.     {
  2077.         $q = $this
  2078.             ->createQueryBuilder('c')
  2079.             ->select('c.id, c.code, f.unid, c.status, c.url')
  2080.             ->leftJoin('c.factory', 'f')
  2081.             ->andWhere('c.status IN (:status_1, :status_4, :status_7)')
  2082.             ->setParameter('status_1', BiConst::STATE_PUBLISHED)
  2083.             ->setParameter('status_4', BiConst::STATE_PROCESSING)
  2084.             ->setParameter('status_7', BiConst::STATE_CHECKING);
  2086.         if (!App::isRole('ROLE_TEST')) {
  2087.             $q->andWhere('c.testAccess IS NULL OR c.testAccess = 0');
  2088.             $q->andWhere('f.testAccess IS NULL OR f.testAccess = 0');
  2089.         }
  2091.         $items = $q
  2092.             ->getQuery()
  2093.             ->useQueryCache($full)
  2094.             ->getArrayResult();
  2096.         return $items;
  2097.     }
  2100.     /**
  2101.      * @param array $ids
  2102.      * @return array
  2103.      */
  2104.     public function getCollAuthorIds(array $ids)
  2105.     {
  2106.         $ids = implode("','", $ids);
  2108.         $q = $this
  2109.             ->createQueryBuilder('c')
  2110.             ->select('c.authorId')
  2111.             ->andWhere("c.id IN ('{$ids}')")
  2112.             ->andWhere('c.status IN (:status_1, :status_4, :status_7)')
  2113.             ->setParameter('status_1', BiConst::STATE_PUBLISHED)
  2114.             ->setParameter('status_4', BiConst::STATE_PROCESSING)
  2115.             ->setParameter('status_7', BiConst::STATE_CHECKING);
  2117.         $items = $q->getQuery()->getArrayResult();
  2118.         $ids = [];
  2119.         if ($items) {
  2120.             foreach ($items as $item) {
  2121.                 if (is_array($item['authorId'])) {
  2122.                     $ids[] = $item['authorId'][0];
  2123.                 } else {
  2124.                     $ids[] = $item['authorId'];
  2125.                 }
  2126.             }
  2127.         }
  2128.         return $ids;
  2129.     }
  2131.     public function increaseViewByCollectionId(int $collId): void
  2132.     {
  2133.         try {
  2134.             $this
  2135.                 ->getEntityManager()
  2136.                 ->getConnection()
  2137.                 ->prepare('UPDATE `collection` SET `views` = `views` + \'1\' WHERE `id` = :id')
  2138.                 ->executeQuery(['id' => $collId]);
  2139.         } catch (DriverException | DoctrineDBALException | LockWaitTimeoutException $e) {
  2140.             return;
  2141.         }
  2142.     }
  2144.     private function getRating($id, $actualData): int
  2145.     {
  2146.         /** @var Collection $collection */
  2147.         foreach ($actualData as $collection) {
  2148.             if ($collection->getId() === $id) {
  2149.                 return $collection->getRating();
  2150.             }
  2151.         }
  2153.         return 0;
  2154.     }
  2156.     public function save(Collection $idea, bool $flush = false): void
  2157.     {
  2158.         $this->getEntityManager()->persist($idea);
  2159.         if ($flush) {
  2160.             $this->flush();
  2161.         }
  2162.     }
  2164.     public function flush(): void
  2165.     {
  2166.         $this->getEntityManager()->flush();
  2167.     }
  2169.     public function getFilteredCollectionIds(array $params, array $articleIds): array
  2170.     {
  2171.         $qb = $this->getEntityManager()->createQueryBuilder();
  2172.         $qb->select('c.id')
  2173.             ->from(Collection::class, 'c')
  2174.             ->innerJoin('c.articles', 'a')
  2175.             ->where('c.status = :status')
  2176.             ->setParameter('status', BiConst::STATE_PUBLISHED)
  2177.             ->distinct();
  2179.         $qb->andWhere($qb->expr()->in('a.id', ':ids'))
  2180.             ->setParameter('ids', $articleIds);
  2182.         if (isset($params['manufacturer'])) {
  2183.             $qb->andWhere($qb->expr()->in('c.factory', ':fids'))
  2184.                 ->setParameter('fids', $params['manufacturer']);
  2185.         }
  2187.         foreach ($params as $key => $value) {
  2188.             $this->buildQueryFromConfig($qb, $key, $value);
  2189.         }
  2191.         return $qb->getQuery()->getResult();
  2192.     }
  2194.     private function buildQueryFromConfig(QueryBuilder $qb, $key, array $value): void
  2195.     {
  2196.         if (!isset(self::COLLECTION_QUERY_FILTER_MAPPING[$key])) {
  2197.             return;
  2198.         }
  2200.         $config = self::COLLECTION_QUERY_FILTER_MAPPING[$key];
  2201.         $alias = $config['alias'];
  2202.         $field = $config['field'];
  2203.         if ($key === 'rewards') {
  2204.             $qb->andWhere($qb->expr()->isNotNull("$alias.$field"));
  2205.             return;
  2206.         }
  2208.         if (isset($config['join'])) {
  2209.             $path = $config['join']['path'];
  2210.             if ($key === 'reviews') {
  2211.                 $qb->innerJoin($path, $alias, 'WITH', 'c.id = ' . $alias . '.collection');
  2212.             } else {
  2213.                 $qb->innerJoin($path, $alias);
  2214.             }
  2215.         }
  2217.         $qb->andWhere($qb->expr()->in("$alias.$field", ":$key"))->setParameter($key, $value);
  2218.     }
  2219. }