src/WebBundle/Repository/CollectionRepository.php line 589

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