src/WebBundle/Repository/PublicationRepository.php line 303

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