src/WebBundle/Repository/PublicationRepository.php line 295

Open in your IDE?
  1. <?php
  3. namespace WebBundle\Repository;
  5. use DateTime;
  6. use Doctrine\ORM\QueryBuilder;
  7. use Exception;
  8. use FlexApp\Classes\CommentableEntityTypes;
  9. use FlexApp\Constant\TimeConstant;
  10. use WebBundle\Helper\App;
  11. use WebBundle\Helper\ArrHelper;
  12. use WebBundle\Helper\LocaleHelper;
  13. use WebBundle\Helper\TranslitHelper;
  15. /**
  16.  * PublicationRepository
  17.  */
  18. class PublicationRepository extends ExtendEntityRepository
  19. {
  20.     /**
  21.      * Получаем публикации с учетом локали, где есть хотя бы один коммент
  22.      * @param $locale
  23.      * @return array
  24.      */
  25.     public function getActivePagesArrays($locale): array
  26.     {
  27.         $query = $this->getEntityManager()->createQuery("
  28.             SELECT
  29.                 DISTINCT p.unid as portalThemeUnid
  30.             FROM WebBundle\Entity\Publication p
  31.             JOIN FlexApp\Entity\CommentEntity c
  32.                 WITH COLLATE(p.unid,utf8mb4_unicode_ci) = COLLATE(c.commentableUnid,utf8mb4_unicode_ci)
  33.                 AND c.locale = :locale
  34.         ");
  36.         $query->setParameter('locale', $locale);
  37.         $result = $query->getResult();
  39.         foreach ($result as &$row) {
  40.             $row['locale'] = $locale;
  41.             $row['type'] = CommentableEntityTypes::PUBLICATION;
  42.         }
  44.         return $result;
  45.     }
  47.     /**
  48.      * Это надо для админки в основном
  49.      * @param string $alias
  50.      * @return QueryBuilder
  51.      */
  52.     public function joinQuery($alias = 'b')
  53.     {
  54.         $q = $this->createQueryBuilder($alias);
  56.         $q->select("{$alias}, url, body, title, description, keywords, statusShow, statusTranslate, hideSingle, preview, likes, author")
  57.             ->leftJoin("{$alias}.url", 'url')
  58.             ->leftJoin("{$alias}.body", 'body')
  59.             ->leftJoin("{$alias}.title", 'title')
  60.             ->leftJoin("{$alias}.description", 'description')
  61.             ->leftJoin("{$alias}.keywords", 'keywords')
  62.             ->leftJoin("{$alias}.statusShow", 'statusShow')
  63.             ->leftJoin("{$alias}.statusTranslate", 'statusTranslate')
  64.             ->leftJoin("{$alias}.preview", 'preview')
  65.             ->leftJoin("{$alias}.likes", 'likes')
  66.             ->leftJoin("{$alias}.author", 'author')
  67.             ->leftJoin("{$alias}.hideSingle", 'hideSingle');
  69.         return $q;
  70.     }
  72.     /**
  73.      * @param array $param
  74.      * @return array
  75.      * @throws Exception
  76.      * Фильтрация должна быть одинаковая с
  77.      * @see PublicationRepository::getPublicationsCount
  78.      */
  79.     public function getIdsForShortShow(array $param = []): array
  80.     {
  81.         $locale = !empty($param['locale']) ? $param['locale'] : App::getCurLocale();
  82.         $cc = !empty($param['country']) ? $param['country'] : App::getCurCountry();
  84.         $hideSingle = !isset($param['hideSingle']) || boolval($param['hideSingle']);
  86.         $s = $this
  87.             ->createQueryBuilder('b')
  88.             ->select('b.id, b.publishDate, b.hideCountries')
  89.             ->leftJoin('b.body', 'body')
  90.             ->leftJoin('b.statusShow', 'statusShow')
  91.             ->leftJoin('b.hideSingle', 'hideSingle')
  92.             ->andWhere('b.enable = true')
  93.             ->andWhere("statusShow.{$locale} = true")
  94.             ->andWhere("body.{$locale} != ''")
  95.             ->andWhere("hideSingle.{$locale} = :hideSingle")
  96.             ->setParameter('hideSingle', $hideSingle)
  97.             ->orderBy('b.publishDate', 'ASC');
  99.         //блог по снижению ват показываем только для Германии
  100.         if (App::getCurCountry() != 'de') {
  101.             $s->andWhere('b.id <> :idDe')
  102.                 ->setParameter('idDe', 2235);
  103.         }
  105.         $q = $s->getQuery()->setQueryCacheLifetime(300);
  106.         $data = $q->getArrayResult();
  108.         $data = array_filter($data, static fn(array $item) => !in_array($cc, $item['hideCountries'] ?? []));
  110.         return array_map(function (array $item) {
  111.             $item['t'] = 'blog';
  113.             /**  @var DateTime $date */
  114.             $date = $item['publishDate'];
  115.             $item['date'] = $date->getTimestamp();
  116.             return $item;
  117.         }, $data);
  118.     }
  120.     /**
  121.      * @param $ids
  122.      * @param array $param
  123.      * @return array
  124.      * @throws Exception
  125.      */
  126.     public function getByIdsForShortShow($ids, $param = [])
  127.     {
  128.         $ids = is_array($ids) ? $ids : [$ids];
  129.         $lc = !empty($param['locale']) ? $param['locale'] : App::getCurLocale();
  130.         $cn = App::getCurCountry();
  132.         // блог по снижению ват показываем только для Германии
  133.         if ($cn != 'de') {
  134.             if ($idsx = array_search(2235, $ids)) {
  135.                 unset($ids[$idsx]);
  136.             }
  137.         }
  139.         $idss = implode(',', $ids);
  141.         $sql = "SELECT
  142.                 p.id,
  143.                 p.enable,
  144.                 p.unid,
  145.                 p.view,
  146.                 p.publish_date AS `publishDate`,
  147.                 p.hide_countries AS `hideCountries`,
  148.                 lcurl.{$lc} AS `url`,
  149.                 lctitle.{$lc} AS `title`,
  150.                 lchtml.{$lc} AS `body`,
  151.                 lcssShow.{$lc} AS `statusShow`,
  152.                 lchs.{$lc} AS `hideSingle`,
  153.                 lcpw.def AS `preview.def`,
  154.                 lcpw.en AS `preview.en`,
  155.                 lcpw.{$lc} AS `preview.lc`,
  156.                 COUNT(DISTINCT cmt.id) AS `commentCnt`
  157.             FROM
  158.                 publication p
  159.             LEFT JOIN `publication_like` `plike` ON plike.publication_id = p.id
  160.             LEFT JOIN `locale_url` `lcurl` ON lcurl.publication_id = p.id
  161.             LEFT JOIN `locale_title` `lctitle` ON lctitle.publication_id = p.id
  162.             LEFT JOIN `locale_html` `lchtml` ON lchtml.publication_body_id = p.id
  163.             LEFT JOIN `locale_bool` `lcssShow` ON lcssShow.blog_show_id = p.id
  164.             LEFT JOIN `locale_bool` `lchs` ON lchs.blog_hide_single_id = p.id
  165.             LEFT JOIN `locale_preview` `lcpw` ON lcpw.publication_id = p.id
  166.             LEFT JOIN `comment_refact` `cmt` ON cmt.commentable_unid = p.unid AND cmt.locale = '{$lc}'
  168.             WHERE p.id IN ({$idss})
  169.             GROUP BY p.id;";
  170.         $conn = $this->_em->getConnection();
  171.         $rows = $conn->fetchAllAssociative($sql);
  173.         $res = [];
  174.         foreach ($rows as $row) {
  175.             if (!$row['url'] and !$row['title'] and !$row['body']) {
  176.                 continue;
  177.             }
  179.             $preview = $row['preview.lc'];
  180.             if (!$preview) {
  181.                 $preview = !empty($row['preview.def']) ? $row['preview.def'] : null;
  182.                 if (!$preview) {
  183.                     $preview = !empty($row['preview.en']) ? $row['preview.en'] : null;
  184.                 }
  185.             }
  188.             $hideCountries = $row['hideCountries'];
  189.             if ($hideCountries) {
  190.                 $hideCountries = json_decode($hideCountries, true);
  191.             } else {
  192.                 $hideCountries = [];
  193.             }
  195.             $item = [
  196.                 't'             => 'blog',
  197.                 'id'            => $row['id'],
  198.                 'unid'          => $row['unid'],
  199.                 'url'           => $row['url'],
  200.                 'title'         => html_entity_decode($row['title']),
  201.                 'body'          => html_entity_decode(LocaleHelper::modifeLinkForLocales($row['body'])),
  202.                 'preview'       => $preview,
  203.                 'enable'        => boolval($row['enable']),
  204.                 'statusShow'    => boolval($row['statusShow']),
  205.                 'hideSingle'    => boolval($row['hideSingle']),
  206.                 'hideCountries' => $hideCountries,
  207.                 'commentCnt'    => intval($row['commentCnt']),
  208.                 'view'          => intval($row['view']),
  209.                 'publishDate'   => DateTime::createFROMFormat('Y-m-d H:i:s', $row['publishDate']),
  210.             ];
  212.             $res[$row['id']] = $item;
  213.         }
  215.         return $res;
  216.     }
  218.     /**
  219.      * Получение блогов для карты сайта
  220.      * @param string $lc
  221.      * @param string|null $cc
  222.      * @return array
  223.      * @throws Exception
  224.      */
  225.     public function getPublicationsSEO(string $lc, ?string $cc = null)
  226.     {
  227.         $oMemcache = App::getMemcache();
  228.         $keyCache = $this->buildCacheId(__METHOD__, "blog.seo.{$lc}.{$cc}", $lc . $cc);
  229.         $rows = $oMemcache->get($keyCache);
  231.         if (!$rows) {
  232.             $hideIds = '2235';
  233.             if ($lc == 'ru') {
  234.                 $hideIds .= ',2232';
  235.             }
  237.             $sql = "SELECT
  238.                 p.id,
  239.                 lcTitle.{$lc} AS title,
  240.                    lcUrl.{$lc} AS url,
  241.                    p.hide_countries AS hideCountries
  242.             FROM
  243.                 publication p
  244.             LEFT JOIN `locale_title` `lcTitle` ON lcTitle.publication_id = p.id
  245.             LEFT JOIN `locale_url` `lcUrl` ON lcUrl.publication_id = p.id
  246.             LEFT JOIN `locale_bool` `lcShow` ON lcShow.blog_show_id = p.id
  247.             LEFT JOIN `locale_bool` `lcSingle` ON lcSingle.blog_hide_single_id = p.id
  248.             WHERE p.enable = 1
  249.               AND p.author IS NOT NULL
  250.               AND lcUrl.{$lc} IS NOT NULL
  251.               AND lcShow.{$lc} = 1
  252.               AND lcSingle.{$lc} != 1
  253.               AND p.id NOT IN ({$hideIds})
  254.             ;
  255.             ";
  257.             $conn = $this->_em->getConnection();
  258.             $rows = $conn->fetchAllAssociative($sql);
  260.             foreach ($rows as $i => $row) {
  261.                 if ($row['hideCountries']) {
  262.                     if ($c = json_decode($row['hideCountries'], true)) {
  263.                         if ($cc) {
  264.                             if (in_array($cc, $c)) {
  265.                                 unset($rows[$i]);
  266.                                 }
  267.                         } else {
  268.                             if (in_array($lc, $c)) {
  269.                                 unset($rows[$i]);
  270.                             }
  271.                         }
  272.                     }
  273.                 }
  274.             }
  277.             // кеш на неделю
  278.             $oMemcache->set($keyCache, $rows, MEMCACHE_COMPRESSED, (int) TimeConstant::WEEK);
  279.         }
  281.         return $rows;
  282.     }
  284.     /**
  285.      * Обновление статистики просмотров
  286.      * @param $id
  287.      * @throws \Doctrine\DBAL\Exception
  288.      */
  289.     public function updView($id)
  290.     {
  291.         $conn = $this->getEntityManager()->getConnection();
  292.         $conn->executeStatement("UPDATE `publication` SET `view` = `view` + 1  WHERE `id` = {$id};");
  293.     }
  295.     public function getKey($id, $locale)
  296.     {
  297.         $q = $this->createQueryBuilder('p')
  298.             ->select('u.' . $locale . ' url')
  299.             ->leftJoin('p.url', 'u')
  300.             ->andWhere('p.id = :id')
  301.             ->setParameter('id', $id);
  303.         $r = $q->getQuery()
  304.             ->useQueryCache(true)
  305.             ->enableResultCache(3600);
  306.         $item = $r->getArrayResult();
  308.         return count($item) > 0 ? $item[0]['url'] : null;
  309.     }
  311.     /**
  312.      * @param      $url
  313.      * @param null $locale
  314.      * @return array|null
  315.      */
  316.     public function getBlogByUrlForDTO($url, $locale = null)
  317.     {
  318.         $q = $this->createQueryBuilder('p')
  319.             ->select('p, url, body, title, description, keywords, statusShow, hideSingle, preview, likes, author')
  320.             ->leftJoin('p.url', 'url')
  321.             ->leftJoin('p.body', 'body')
  322.             ->leftJoin('p.title', 'title')
  323.             ->leftJoin('p.description', 'description')
  324.             ->leftJoin('p.keywords', 'keywords')
  325.             ->leftJoin('p.statusShow', 'statusShow')
  326.             ->leftJoin('p.preview', 'preview')
  327.             ->leftJoin('p.likes', 'likes')
  328.             ->leftJoin('p.author', 'author')
  329.             ->leftJoin('p.hideSingle', 'hideSingle');
  331.         if ($locale) {
  332.             $q->andWhere("url.{$locale} = :url")->setParameter('url', $url);
  333.         } else {
  334.             foreach (LocaleHelper::getList() as $lc => $item) {
  335.                 $key = "url{$lc}";
  336.                 $q->orWhere("url.{$lc} = :{$key}")->setParameter($key, $url);
  337.             }
  338.         }
  340.         $r = $q->getQuery();
  341.         $item = $r->getArrayResult();
  343.         if (count($item) == 1) {
  344.             $item = $item[0];
  345.         } else {
  346.             $item = null;
  347.         }
  349.         return $item;
  350.     }
  352.     /**
  353.      * @param      $id
  354.      * @param null $locale
  355.      * @param bool $preview
  356.      * @return mixed|null
  357.      * @throws Exception
  358.      */
  359.     public function getPublication($id, $locale = null, $preview = false)
  360.     {
  361.         $locale = $locale ? $locale : App::getCurLocale();
  362.         $oMemcache = App::getMemcache();
  363.         $keyCache = $this->buildCacheId(__METHOD__, $id, $locale);
  364.         $data = $oMemcache->get($keyCache);
  366.         // если $preview, то кеш не используем
  367.         if (!$preview) {
  368.             $data = null;
  369.         }
  371.         if (!$data) {
  372.             $s = $this
  373.                 ->joinQuery()
  374.                 ->setMaxResults(1);
  376.             if (App::isInt($id)) {
  377.                 $s->andWhere('b.id = :id')->setParameters(['id' => $id]);
  378.             } else {
  379.                 // если не ID, то значит urlKey и ведем поиск по нему
  380.                 $s->andWhere("url.{$locale} = :id")->setParameter('id', $id);
  381.             }
  383.             if (!$preview) {
  384.                 $s->andWhere('b.enable = true');
  385.             }
  387.             $q = $s->getQuery()->useQueryCache(true);
  389.             $data = ArrHelper::get($q->getArrayResult(), '0');
  391.             if (!$data) {
  392.                 return null;
  393.             }
  395.             $url = ArrHelper::get($data, "url.{$locale}");
  396.             $title = ArrHelper::get($data, "title.{$locale}");
  397.             $body = ArrHelper::get($data, "body.{$locale}");
  398.             $description = ArrHelper::get($data, "description.{$locale}");
  399.             $keywords = ArrHelper::get($data, "keywords.{$locale}");
  400.             $statusShow = ArrHelper::get($data, "statusShow.{$locale}");
  401.             $statusTranslate = ArrHelper::get($data, "statusTranslate.{$locale}");
  402.             $icon = ArrHelper::get($data, "preview.{$locale}");
  404.             // если показ закрыт, либо не зватает переводов, то проводим дополнительные проверки
  405.             if (!$statusShow or !$body or !$title) {
  406.                 $localeDef = LocaleHelper::getDefault();
  407.                 if ($locale == $localeDef) {
  408.                     // если локаль совпалает с дефолтной, то сразу выдаем NULL
  409.                     return null;
  410.                 } else {
  411.                     // получаем тексты для дефолтной локали
  412.                     $title = ArrHelper::get($data, "title.{$localeDef}");
  413.                     $body = ArrHelper::get($data, "body.{$localeDef}");
  414.                     $description = ArrHelper::get($data, "description.{$localeDef}");
  415.                     $keywords = ArrHelper::get($data, "keywords.{$localeDef}");
  416.                     $statusShow = ArrHelper::get($data, "statusShow.{$localeDef}");
  417.                     $statusTranslate = ArrHelper::get($data, "statusTranslate.{$localeDef}");
  418.                     $icon = ArrHelper::get($data, "preview.{$localeDef}");
  419.                 }
  420.             }
  421.             if (!$icon) {
  422.                 $icon = ArrHelper::get($data, "preview.default");
  423.             }
  424.             // дополнительная проверка
  425.             if (!$statusShow or !$body or !$title) {
  426.                 return null;
  427.             }
  429.             $data['url'] = $url;
  430.             $data['title'] = html_entity_decode($title);
  431.             $data['body'] = html_entity_decode(LocaleHelper::modifeLinkForLocales($body));
  432.             $data['description'] = $description;
  433.             $data['keywords'] = $keywords;
  434.             $data['statusShow'] = $statusShow;
  435.             $data['statusTranslate'] = $statusTranslate;
  436.             $data['preview'] = $icon;
  437.         }
  439.         return $data;
  441.     }
  443.     /**
  444.      * Количество активных блогов по локали
  445.      * @param array $param
  446.      * @return int
  447.      * @throws Exception фильтрация должна быть одинаковая с
  448.      * @see PublicationRepository::getIdsForShortShow
  449.      */
  450.     public function getPublicationsCount(array $param): int
  451.     {
  452.         $cc = App::getCurCountry();
  453.         $oMemcache = App::getMemcache();
  454.         $keyCache = $this->buildCacheId(__METHOD__, $cc, $param['locale']);
  455.         $cnt = $oMemcache->get($keyCache);
  457.         if (!$cnt) {
  458.             unset($param['offset'], $param['limit']);
  459.             $cnt = count($this->getIdsForShortShow($param));
  461.             // кеш на неделю
  462.             $oMemcache->set($keyCache, $cnt, MEMCACHE_COMPRESSED, (int) TimeConstant::WEEK);
  463.         }
  465.         return intval($cnt);
  466.     }
  468.     /**
  469.      * @param null $ids
  470.      * @param null $limit
  471.      * @return array|null
  472.      */
  473.     public function getPublicationsParticipant($ids = null, $limit = null)
  474.     {
  475.         $q = $this
  476.             ->createQueryBuilder('p');
  477.         if ($ids) {
  478.             $ids = TranslitHelper::replaceSpace($ids);
  479.             $IDS = explode(',', $ids);
  480.             $q->andWhere('p.id in (:ids)')
  481.                 ->setParameter('ids', $IDS);
  482.         }
  483.         if ($limit) {
  484.             $q->setMaxResults($limit);
  485.         }
  486.         $r = $q->getQuery();
  488.         return $r->getResult();
  489.     }
  491.     /**
  492.      * Получение списка для проверки на наличие кириллических символов
  493.      * @return array
  494.      */
  495.     public function getCollectionsAdmForCheckCyrillic()
  496.     {
  497.         $q = $this->createQueryBuilder('p')
  498.             ->select('p, body, title')
  499.             ->leftJoin('p.body', 'body')
  500.             ->leftJoin('p.title', 'title')
  501.             ->andWhere("p.enable = true");
  503.         return $q->getQuery()->getArrayResult();
  504.     }
  506.     /**
  507.      * Получение списка для проверки на наличие кириллических символов
  508.      * @return array
  509.      * @throws \Doctrine\DBAL\Exception
  510.      */
  511.     public function admGetListForLiMenuSelect()
  512.     {
  513.         $sql = "SELECT
  514.                 p.id,
  515.                    lc.ru AS name
  516.             FROM
  517.                 publication p
  518.             LEFT JOIN `locale_title` `lc` ON `lc`.publication_id = `p`.id
  519.             ORDER BY lc.ru ;
  520.             ";
  522.         $conn = $this->_em->getConnection();
  523.         $rows = $conn->fetchAllAssociative($sql);
  524.         $items = [];
  525.         foreach ($rows as $row) {
  526.             $items[$row['id']] = $row['name'];
  527.         }
  529.         return $items;
  530.     }
  532.     /**
  533.      * отдаем сразу URL или NULL
  534.      * @param bool|null $forPage
  535.      * @return string|null
  536.      * @throws \Doctrine\DBAL\Driver\Exception
  537.      * @throws \Doctrine\DBAL\Exception
  538.      * @throws Exception
  539.      */
  540.     public function getUrlBlogExpressSamples(?bool $forPage = false)
  541.     {
  542.         $lc = App::getCurLocale();
  543.         $cc = App::getCurCountry();
  545.         // для РФ блог не показываем
  546.         if (!$forPage and $cc == 'ru') {
  547.             return null;
  548.         }
  550.         $sql = "SELECT
  551.                    lu.{$lc} AS slug
  552.             FROM
  553.                 publication p
  554.             LEFT JOIN `locale_url` `lu` ON `lu`.publication_id = `p`.id
  555.             LEFT JOIN `locale_bool` `lp` ON `lp`.blog_show_id = `p`.id
  556.             LEFT JOIN `locale_status_translate` `lst` ON `lst`.publication_id = `p`.id
  557.             WHERE p.id = 2232 AND lp.{$lc} = 1 AND lst.{$lc} = 1;
  558.             ";
  559.         $conn = $this->_em->getConnection();
  560.         $slug = $conn->executeQuery($sql)->fetchOne();
  562.         if ($slug) {
  563.             $url = App::generateUrl('app_publication_single', ['id' => $slug]);
  564.         } else {
  565.             $url = null;
  566.         }
  568.         return $url;
  569.     }
  570. }