tags.php

См. документацию.

<?php
 
class CSearchTags
{
    public static function GetList($arSelect = [], $arFilter = [], $arOrder = [], $limit = 100)
    {
        $DB = CDatabase::GetModuleConnection('search');
        static $arFilterEvents = false;
 
        $arQuerySelect = [];
        if (!is_array($arSelect))
        {
            $arSelect = [];
        }
        if (count($arSelect) < 1)
        {
            $arSelect = [
                'NAME',
                'CNT',
            ];
        }
        $bJoinSearchContent = false;
        foreach ($arSelect as $key => $value)
        {
            $value = mb_strtoupper($value);
            switch ($value)
            {
            case 'NAME':
                $arQuerySelect['NAME'] = 'stags.NAME';
                break;
            case 'CNT':
                $arQuerySelect['CNT'] = 'COUNT(DISTINCT stags.SEARCH_CONTENT_ID) as CNT';
                break;
            case 'DATE_CHANGE':
                $arQuerySelect['DC_TMP'] = 'MAX(sc.DATE_CHANGE) as DC_TMP';
                $arQuerySelect['FULL_DATE_CHANGE'] = $DB->DateToCharFunction('MAX(sc.DATE_CHANGE)', 'FULL') . ' as FULL_DATE_CHANGE';
                $arQuerySelect['DATE_CHANGE'] = $DB->DateToCharFunction('MAX(sc.DATE_CHANGE)', 'SHORT') . ' as DATE_CHANGE';
                $bJoinSearchContent = true;
                break;
            }
        }
 
        $arQueryWhere = [];
        if (!is_array($arFilter))
        {
            $arFilter = [
                'TAG' => $arFilter,
                'SITE_ID' => [SITE_ID],
            ];
        }
        if (empty($arFilter['SITE_ID']) && array_key_exists('TAG', $arFilter))
        {
            $arFilter['SITE_ID'] = [SITE_ID];
        }
        if (array_key_exists('SITE_ID', $arFilter) && !is_array($arFilter['SITE_ID']))
        {
            $arFilter['SITE_ID'] = [$arFilter['SITE_ID']];
        }
 
        $strTag = '';
        foreach ($arFilter as $key => $value)
        {
            $key = mb_strtoupper($key);
            switch ($key)
            {
            case 'SITE_ID':
                $arSites = [];
                foreach ($value as $site_id)
                {
                    $arSites[$DB->ForSql($site_id, 2)] = true;
                }
                $arSites = array_keys($arSites);
                if (count($arSites) == 1)
                {
                    $arQueryWhere[] = "stags.SITE_ID = '" . $arSites[0] . "'";
                }
                elseif (count($arSites) > 1)
                {
                    $arQueryWhere[] = "stags.SITE_ID in ('" . implode("', '", $arSites) . "')";
                }
                break;
            case 'TAG':
                $arTags = tags_prepare($value, $arFilter['SITE_ID'][0]);
                if (count($arTags) > 0)
                {
                    $strTag = array_pop($arTags);
                    $arQueryWhere[] = "UPPER(stags.NAME) LIKE '" . $DB->ForSql(mb_strtoupper($strTag)) . "%'";
                }
                break;
            case 'MODULE_ID':
            case 'PARAM1':
            case 'PARAM2':
                $arQueryWhere[] = 'sc.' . $key . " ='" . $DB->ForSql($value) . "'";
                $bJoinSearchContent = true;
                break;
            case 'PARAMS':
                if (is_array($value))
                {
                    foreach ($value as $p_key => $p_val)
                    {
                        if (is_array($p_val))
                        {
                            foreach ($p_val as $i => $val2)
                            {
                                $p_val[$i] = $DB->ForSQL($val2);
                            }
                            $p_where = " in ('" . implode("', '", $p_val) . "')";
                        }
                        else
                        {
                            $p_where = " = '" . $DB->ForSQL($p_val) . "'";
                        }
                        $arQueryWhere[] = "EXISTS (SELECT * FROM b_search_content_param WHERE SEARCH_CONTENT_ID = stags.SEARCH_CONTENT_ID AND PARAM_NAME = '" . $DB->ForSQL($p_key) . "' AND PARAM_VALUE " . $p_where . ')';
                    }
                }
                break;
            default:
                if (!is_array($arFilterEvents))
                {
                    $arFilterEvents = GetModuleEvents('search', 'OnSearchPrepareFilter', true);
                }
                //Try to get someone to make the filter sql
                foreach ($arFilterEvents as $arEvent)
                {
                    $sql = ExecuteModuleEventEx($arEvent, ['sc.', $key, $value]);
                    if ($sql <> '')
                    {
                        $arQueryWhere[] = '(' . $sql . ')';
                        $bJoinSearchContent = true;
                        break;
                    }
                }
            }
        }
 
        $arQueryOrder = [];
        if (!is_array($arOrder))
        {
            $arOrder = [];
        }
        if (count($arOrder) < 1)
        {
            $arOrder = [
                'NAME' => 'ASC',
            ];
        }
        foreach ($arOrder as $key => $value)
        {
            $key = mb_strtoupper($key);
            $value = mb_strtoupper($value) == 'DESC' ? 'DESC' : 'ASC';
            switch ($key)
            {
            case 'NAME':
            case 'CNT':
                $arQueryOrder[$key] = $key . ' ' . $value;
                break;
            case 'DATE_CHANGE':
                $arQueryOrder[$key] = 'DC_TMP ' . $value;
                $arQuerySelect['DC_TMP'] = 'MAX(sc.DATE_CHANGE) as DC_TMP';
                $arQuerySelect['FULL_DATE_CHANGE'] = $DB->DateToCharFunction('MAX(sc.DATE_CHANGE)', 'FULL') . ' as FULL_DATE_CHANGE';
                $arQuerySelect['DATE_CHANGE'] = $DB->DateToCharFunction('MAX(sc.DATE_CHANGE)', 'SHORT') . ' as DATE_CHANGE';
                $bJoinSearchContent = true;
                break;
            }
        }
        if (count($arQueryOrder) < 1)
        {
            $arQueryOrder = [
                'NAME' => 'NAME ASC',
            ];
        }
 
        $strSql = '
            SELECT
                ' . implode("\n,", $arQuerySelect) . '
            FROM b_search_tags stags
                ' . ($bJoinSearchContent ? 'INNER JOIN b_search_content sc ON sc.ID = stags.SEARCH_CONTENT_ID' : '') . '
            WHERE
                ' . CSearch::CheckPermissions('stags.SEARCH_CONTENT_ID') . '
                ' . (count($arQueryWhere) > 0 ? 'AND ' . implode("\nAND ", $arQueryWhere) : '') . '
            GROUP BY stags.NAME
            ORDER BY ' . implode(', ', $arQueryOrder) . '
        ';
 
        if ($limit !== false)
        {
            $limit = intval($limit);
            if ($limit <= 0 || ($limit > COption::GetOptionInt('search', 'max_result_size')))
            {
                $limit = COption::GetOptionInt('search', 'max_result_size');
            }
            if ($limit < 1)
            {
                $limit = 100;
            }
 
            $strSql = $DB->TopSql($strSql, $limit);
        }
 
        if ((CACHED_b_search_tags !== false) && ($limit !== false) && (mb_strlen($strTag) <= CACHED_b_search_tags_len))
        {
            global $CACHE_MANAGER;
            $path = 'b_search_tags';
            while ($strTag <> '')
            {
                $path .= '/_' . ord(mb_substr($strTag, 0, 1));
                $strTag = mb_substr($strTag, 1);
            }
            $cache_id = 'search_tags:' . md5($strSql);
            if ($CACHE_MANAGER->Read(CACHED_b_search_tags, $cache_id, $path))
            {
                $arTags = $CACHE_MANAGER->Get($cache_id);
            }
            else
            {
                $arTags = [];
                $res = $DB->Query($strSql);
                while ($ar = $res->Fetch())
                {
                    $arTags[] = $ar;
                }
                $CACHE_MANAGER->Set($cache_id, $arTags);
            }
            $res = new CDBResult;
            $res->InitFromArray($arTags);
            return $res;
        }
        else
        {
            return $DB->Query($strSql);
        }
    }
 
    public static function CleanCache($arTags = '', $content_id = false)
    {
        if (CACHED_b_search_tags !== false)
        {
            if ($content_id !== false)
            {
                $DB = CDatabase::GetModuleConnection('search');
                $rs = $DB->Query('SELECT NAME FROM b_search_tags WHERE SEARCH_CONTENT_ID = ' . intval($content_id));
                $arTags = [];
                while ($ar = $rs->Fetch())
                {
                    if ($ar['NAME'])
                    {
                        $arTags[] = $ar['NAME'];
                    }
                }
                CSearchTags::CleanCache($arTags);
            }
            else
            {
                if (!is_array($arTags))
                {
                    $arTags = [$arTags];
                }
                $arPath = [];
                foreach ($arTags as $tag)
                {
                    if ($tag <> '')
                    {
                        $path = 'b_search_tags/_' . ord(mb_substr($tag, 0, 1));
                    }
                    else
                    {
                        $path = 'b_search_tags';
                    }
                    $arPath[$path] = true;
                }
                global $CACHE_MANAGER;
                foreach ($arPath as $path => $value)
                {
                    $CACHE_MANAGER->CleanDir($path);
                }
            }
        }
    }
}