sphinx.php

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

<?php
IncludeModuleLangFile(__FILE__);
 
class CSearchSphinx extends CSearchFullText
{
    public $arForumTopics = [];
    public $db = false;
    private static $fields = [
        'title' => 'field',
        'body' => 'field',
        'module_id' => 'uint',
        'module' => 'string',
        'item_id' => 'uint',
        'item' => 'string',
        'param1_id' => 'uint',
        'param1' => 'string',
        'param2_id' => 'uint',
        'param2' => 'string',
        'date_change' => 'timestamp',
        'date_from' => 'timestamp',
        'date_to' => 'timestamp',
        'custom_rank' => 'uint',
        'tags' => 'mva',
        'right' => 'mva',
        'site' => 'mva',
        'param' => 'mva',
    ];
    private static $typesMap = [
        'timestamp' => 'rt_attr_timestamp',
        'string' => 'rt_attr_string',
        'bigint' => 'rt_attr_bigint',
        'uint' => 'rt_attr_uint',
        'field' => 'rt_field',
        'mva' => 'rt_attr_multi',
    ];
    private $errorText = '';
    private $errorNumber = 0;
    public $tags = '';
    public $query = '';
    public $SITE_ID = '';
    public $connectionIndex = '';
    public $indexName = '';
 
    public function connect($connectionIndex, $indexName = '', $ignoreErrors = false)
    {
        global $APPLICATION;
 
        if (!preg_match('/^[a-zA-Z0-9_]+$/', $indexName))
        {
            if ($ignoreErrors)
            {
                $APPLICATION->ThrowException(GetMessage('SEARCH_SPHINX_CONN_ERROR_INDEX_NAME'));
            }
            else
            {
                throw new \Bitrix\Main\Db\ConnectionException('Sphinx connect error', GetMessage('SEARCH_SPHINX_CONN_ERROR_INDEX_NAME'));
            }
            return false;
        }
 
        if (!$this->canConnect())
        {
            if ($ignoreErrors)
            {
                $APPLICATION->ThrowException(GetMessage('SEARCH_SPHINX_CONN_EXT_IS_MISSING'));
            }
            else
            {
                throw new \Bitrix\Main\Db\ConnectionException('Sphinx connect error', GetMessage('SEARCH_SPHINX_CONN_EXT_IS_MISSING'));
            }
            return false;
        }
 
        $error = '';
        $this->db = $this->internalConnect($connectionIndex, $error);
        if (!$this->db)
        {
            if ($ignoreErrors)
            {
                $APPLICATION->ThrowException(GetMessage('SEARCH_SPHINX_CONN_ERROR', ['#ERRSTR#' => $error]));
            }
            else
            {
                throw new \Bitrix\Main\Db\ConnectionException('Sphinx connect error', GetMessage('SEARCH_SPHINX_CONN_ERROR', ['#ERRSTR#' => $error]));
            }
            return false;
        }
 
        if ($ignoreErrors)
        {
            $result = $this->query('SHOW TABLES');
            if (!$result)
            {
                $APPLICATION->ThrowException(GetMessage('SEARCH_SPHINX_CONN_ERROR', ['#ERRSTR#' => $this->getError()]));
                return false;
            }
 
            if ($indexName == '')
            {
                $APPLICATION->ThrowException(GetMessage('SEARCH_SPHINX_CONN_NO_INDEX'));
                return false;
            }
 
            $indexType = '';
            while ($res = $this->fetch($result))
            {
                if ($indexName === $res['Index'])
                {
                    $indexType = $res['Type'];
                }
            }
 
            if ($indexType == '')
            {
                $APPLICATION->ThrowException(GetMessage('SEARCH_SPHINX_CONN_INDEX_NOT_FOUND'));
                return false;
            }
 
            if ($indexType != 'rt')
            {
                $APPLICATION->ThrowException(GetMessage('SEARCH_SPHINX_CONN_INDEX_WRONG_TYPE'));
                return false;
            }
 
            $indexColumns = [];
            $result = $this->query('DESCRIBE `' . $indexName . '`');
            if (!$result)
            {
                $APPLICATION->ThrowException(GetMessage('SEARCH_SPHINX_DESCR_ERROR', ['#ERRSTR#' => $this->getError()]));
                return false;
            }
 
            while ($res = $this->fetch($result))
            {
                $indexColumns[$res['Field']] = $res['Type'];
            }
 
            $missed = [];
            foreach (self::$fields as $name => $type)
            {
                if (!isset($indexColumns[$name]) || $indexColumns[$name] !== $type)
                {
                    $missed[] = self::$typesMap[$type] . ' = ' . $name;
                }
            }
 
            if (!empty($missed))
            {
                $APPLICATION->ThrowException(GetMessage('SEARCH_SPHINX_NO_FIELDS', ['#FIELD_LIST#' => implode(', ', $missed)]));
                return false;
            }
        }
 
        $this->indexName = $indexName;
        $this->connectionIndex = $connectionIndex;
 
        return true;
    }
 
    public function truncate()
    {
        $this->query('truncate rtindex ' . $this->indexName);
        $this->connect($this->connectionIndex, $this->indexName);
    }
 
    public function deleteById($ID)
    {
        $this->query('delete from ' . $this->indexName . ' where id = ' . intval($ID));
    }
 
    public function replace($ID, $arFields)
    {
        $DB = CDatabase::GetModuleConnection('search');
 
        if (array_key_exists('~DATE_CHANGE', $arFields))
        {
            $arFields['DATE_CHANGE'] = $arFields['~DATE_CHANGE'];
            unset($arFields['~DATE_CHANGE']);
        }
        elseif (array_key_exists('LAST_MODIFIED', $arFields))
        {
            $arFields['DATE_CHANGE'] = $arFields['LAST_MODIFIED'];
            unset($arFields['LAST_MODIFIED']);
        }
        elseif (array_key_exists('DATE_CHANGE', $arFields))
        {
            $arFields['DATE_CHANGE'] = $DB->FormatDate($arFields['DATE_CHANGE'], 'DD.MM.YYYY HH:MI:SS', CLang::GetDateFormat());
        }
 
        $DATE_FROM = intval(MakeTimeStamp($arFields['DATE_FROM']));
        if ($DATE_FROM > 0)
        {
            $DATE_FROM -= CTimeZone::GetOffset();
        }
        $DATE_TO = intval(MakeTimeStamp($arFields['DATE_TO']));
        if ($DATE_TO > 0)
        {
            $DATE_TO -= CTimeZone::GetOffset();
        }
        $DATE_CHANGE = intval(MakeTimeStamp($arFields['DATE_CHANGE']));
        if ($DATE_CHANGE > 0)
        {
            $DATE_CHANGE -= CTimeZone::GetOffset();
        }
 
        $BODY = CSearch::KillEntities($arFields['BODY']) . "\r\n" . $arFields['TAGS'];
 
        $sql = '
            REPLACE INTO ' . $this->indexName . ' (
                id
                ,module_id
                ,module
                ,item_id
                ,item
                ,param1_id
                ,param1
                ,param2_id
                ,param2
                ,date_change
                ,date_from
                ,date_to
                ,custom_rank
                ,tags
                ,right
                ,site
                ,param
                ,title
                ,body
            ) VALUES (
                ' . $ID . '
                ,' . sprintf('%u', crc32($arFields['MODULE_ID'])) . "
                ,'" . $this->Escape($arFields['MODULE_ID']) . "'
                ," . sprintf('%u', crc32($arFields['ITEM_ID'])) . "
                ,'" . $this->Escape($arFields['ITEM_ID']) . "'
                ," . sprintf('%u', crc32($arFields['PARAM1'])) . "
                ,'" . $this->Escape($arFields['PARAM1']) . "'
                ," . sprintf('%u', crc32($arFields['PARAM2'])) . "
                ,'" . $this->Escape($arFields['PARAM2']) . "'
                ," . $DATE_CHANGE . '
                ,' . $DATE_FROM . '
                ,' . $DATE_TO . '
                ,' . intval($arFields['CUSTOM_RANK']) . '
                ,(' . $this->tags($arFields['SITE_ID'], $arFields['TAGS']) . ')
                ,(' . $this->rights($arFields['PERMISSIONS']) . ')
                ,(' . $this->sites($arFields['SITE_ID']) . ')
                ,(' . $this->params($arFields['PARAMS']) . ")
                ,'" . $this->Escape($arFields['TITLE']) . "'
                ,'" . $this->Escape($BODY) . "'
            )
        ";
        $result = $this->query($sql);
        if ($result)
        {
            $this->tagsRegister($arFields['SITE_ID'], $arFields['TAGS']);
        }
        else
        {
            throw new \Bitrix\Main\Db\SqlQueryException('Sphinx select error', $this->getError(), $sql);
        }
    }
 
    public function update($ID, $arFields)
    {
        $DB = CDatabase::GetModuleConnection('search');
        $ID = intval($ID);
 
        $arUpdate = [];
        $bReplace = array_key_exists('TITLE', $arFields)
            || array_key_exists('BODY', $arFields)
            || array_key_exists('MODULE_ID', $arFields)
            || array_key_exists('ITEM_ID', $arFields)
            || array_key_exists('PARAM1', $arFields)
            || array_key_exists('PARAM2', $arFields)
        ;
 
        if (array_key_exists('~DATE_CHANGE', $arFields))
        {
            $arFields['DATE_CHANGE'] = $arFields['~DATE_CHANGE'];
            unset($arFields['~DATE_CHANGE']);
        }
        elseif (array_key_exists('LAST_MODIFIED', $arFields))
        {
            $arFields['DATE_CHANGE'] = $arFields['LAST_MODIFIED'];
            unset($arFields['LAST_MODIFIED']);
        }
        elseif (array_key_exists('DATE_CHANGE', $arFields))
        {
            $arFields['DATE_CHANGE'] = $DB->FormatDate($arFields['DATE_CHANGE'], 'DD.MM.YYYY HH:MI:SS', CLang::GetDateFormat());
        }
 
        if (array_key_exists('DATE_CHANGE', $arFields))
        {
            $DATE_CHANGE = intval(MakeTimeStamp($arFields['DATE_CHANGE']));
            if ($DATE_CHANGE > 0)
            {
                $DATE_CHANGE -= CTimeZone::GetOffset();
            }
            $arUpdate['date_change'] = $DATE_CHANGE;
        }
 
        if (array_key_exists('DATE_FROM', $arFields))
        {
            $DATE_FROM = intval(MakeTimeStamp($arFields['DATE_FROM']));
            if ($DATE_FROM > 0)
            {
                $DATE_FROM -= CTimeZone::GetOffset();
            }
            $arUpdate['date_from'] = $DATE_FROM;
        }
 
        if (array_key_exists('DATE_TO', $arFields))
        {
            $DATE_TO = intval(MakeTimeStamp($arFields['DATE_TO']));
            if ($DATE_TO > 0)
            {
                $DATE_TO -= CTimeZone::GetOffset();
            }
            $arUpdate['date_to'] = $DATE_TO;
        }
 
        if (array_key_exists('CUSTOM_RANK', $arFields))
        {
            $arUpdate['custom_rank'] = '' . intval($arFields['CUSTOM_RANK']) . '';
        }
 
        if (array_key_exists('TAGS', $arFields))
        {
            $arUpdate['tags'] = '(' . $this->tags($arFields['SITE_ID'], $arFields['TAGS']) . ')';
        }
 
        if (array_key_exists('PERMISSIONS', $arFields))
        {
            $arUpdate['right'] = '(' . $this->rights($arFields['PERMISSIONS']) . ')';
        }
 
        if (array_key_exists('SITE_ID', $arFields))
        {
            $arUpdate['site'] = '(' . $this->sites($arFields['SITE_ID']) . ')';
        }
 
        if (array_key_exists('PARAMS', $arFields))
        {
            $arUpdate['param'] = '(' . $this->params($arFields['PARAMS']) . ')';
        }
 
        if (!empty($arUpdate) && !$bReplace)
        {
            foreach ($arUpdate as $columnName => $sqlValue)
            {
                $arUpdate[$columnName] = $columnName . '=' . $sqlValue;
            }
 
            $this->query('
                UPDATE ' . $this->indexName . ' SET
                ' . implode(', ', $arUpdate) . '
                WHERE id = ' . $ID
            );
        }
        elseif ($bReplace)
        {
            $dbItem = $DB->Query('
                SELECT
                    *
                    ,' . $DB->DateToCharFunction('DATE_CHANGE') . ' as LAST_MODIFIED
                    ,' . $DB->DateToCharFunction('DATE_FROM') . ' as DATE_FROM
                    ,' . $DB->DateToCharFunction('DATE_TO') . ' as DATE_TO
                FROM b_search_content
                WHERE ID = ' . $ID
            );
            $searchItem = $dbItem->fetch();
            if ($searchItem)
            {
                $dbTags = $DB->Query('SELECT * from b_search_tags WHERE SEARCH_CONTENT_ID=' . $ID);
                while ($tag = $dbTags->fetch())
                {
                    $searchItem['TAGS'] .= $tag['NAME'] . ',';
                }
 
                $dbRights = $DB->Query('SELECT * from b_search_content_right WHERE SEARCH_CONTENT_ID=' . $ID);
                while ($right = $dbRights->fetch())
                {
                    $searchItem['PERMISSIONS'][] = $right['GROUP_CODE'];
                }
 
                $dbSites = $DB->Query('SELECT * from b_search_content_site WHERE SEARCH_CONTENT_ID=' . $ID);
                while ($site = $dbSites->fetch())
                {
                    $searchItem['SITE_ID'][$site['SITE_ID']] = $site['URL'];
                }
 
                $dbParams = $DB->Query('SELECT * from b_search_content_param WHERE SEARCH_CONTENT_ID=' . $ID);
                while ($param = $dbParams->fetch())
                {
                    $searchItem['PARAMS'][$param['PARAM_NAME']][] = $param['PARAM_VALUE'];
                }
 
                $this->replace($ID, $searchItem);
            }
        }
    }
 
    function tags($arLID, $sContent)
    {
        $tags = [];
        if (is_array($arLID))
        {
            foreach ($arLID as $site_id => $url)
            {
                $arTags = tags_prepare($sContent, $site_id);
                foreach ($arTags as $tag)
                {
                    $tags[] = sprintf('%u', crc32($tag));
                }
            }
        }
        return implode(',', $tags);
    }
 
    function tagsRegister($arLID, $sContent)
    {
        $DB = CDatabase::GetModuleConnection('search');
        static $tagMap = [];
 
        if (is_array($arLID))
        {
            foreach ($arLID as $site_id => $url)
            {
                $arTags = tags_prepare($sContent, $site_id);
                foreach ($arTags as $tag)
                {
                    $tag_id = sprintf('%u', crc32($tag));
                    if ($tag_id > 0x7FFFFFFF)
                    {
                        $tag_id = -(0xFFFFFFFF - $tag_id + 1);
                    }
 
                    if (!isset($tagMap[$tag_id]))
                    {
                        $rs = $DB->Query('select * from b_search_tags where SEARCH_CONTENT_ID=' . $tag_id . " AND SITE_ID='??'");
                        $tagMap[$tag_id] = $rs->fetch();
                        if (!$tagMap[$tag_id])
                        {
                            $DB->Query('insert into b_search_tags values (' . $tag_id . ", '??', '" . $DB->ForSql($tag) . "')");
                        }
                    }
                }
            }
        }
    }
 
    function tagsFromArray($arTags)
    {
        $tags = [];
        if (is_array($arTags))
        {
            foreach ($arTags as $tag)
            {
                $tags[] = sprintf('%u', crc32($tag));
            }
        }
        return implode(',', $tags);
    }
 
    function rights($arRights)
    {
        $rights = [];
        if (is_array($arRights))
        {
            foreach ($arRights as $group_id)
            {
                if (is_numeric($group_id))
                {
                    $rights[$group_id] = sprintf('%u', crc32('G' . intval($group_id)));
                }
                else
                {
                    $rights[$group_id] = sprintf('%u', crc32($group_id));
                }
            }
        }
        return implode(',', $rights);
    }
 
    function sites($arSites)
    {
        $sites = [];
        if (is_array($arSites))
        {
            foreach ($arSites as $site_id => $url)
            {
                $sites[$site_id] = sprintf('%u', crc32($site_id));
            }
        }
        else
        {
            $sites[$arSites] = sprintf('%u', crc32($arSites));
        }
        return implode(',', $sites);
    }
 
    function params($arParams)
    {
        $params = [];
        if (is_array($arParams))
        {
            foreach ($arParams as $k1 => $v1)
            {
                $name = trim($k1);
                if ($name != '')
                {
                    if (!is_array($v1))
                    {
                        $v1 = [$v1];
                    }
 
                    foreach ($v1 as $v2)
                    {
                        $value = trim($v2);
                        if ($value != '')
                        {
                            $params[] = sprintf('%u', crc32(urlencode($name) . '=' . urlencode($value)));
                        }
                    }
                }
            }
        }
        return implode(',', $params);
    }
 
    public function getErrorText()
    {
        return $this->errorText;
    }
 
    public function getErrorNumber()
    {
        return $this->errorNumber;
    }
 
    public function search($arParams, $aSort, $aParamsEx, $bTagsCloud)
    {
        $result = [];
        $this->errorText = '';
        $this->errorNumber = 0;
 
        $this->tags = trim($arParams['TAGS']);
 
        $limit = 0;
        if (is_array($aParamsEx) && isset($aParamsEx['LIMIT']))
        {
            $limit = intval($aParamsEx['LIMIT']);
            unset($aParamsEx['LIMIT']);
        }
 
        $offset = 0;
        if (is_array($aParamsEx) && isset($aParamsEx['OFFSET']))
        {
            $offset = intval($aParamsEx['OFFSET']);
            unset($aParamsEx['OFFSET']);
        }
 
        if (is_array($aParamsEx) && !empty($aParamsEx))
        {
            $aParamsEx['LOGIC'] = 'OR';
            $arParams[] = $aParamsEx;
        }
 
        $this->SITE_ID = $arParams['SITE_ID'];
 
        $arWhere = [];
        $cond1 = implode("\n\t\t\t\t\t\tand ", $this->prepareFilter($arParams, true));
 
        $rights = $this->CheckPermissions();
        if ($rights)
        {
            $arWhere[] = 'right in (' . $rights . ')';
        }
 
        $strQuery = trim($arParams['QUERY']);
        if ($strQuery != '')
        {
            $arWhere[] = "MATCH('" . $this->Escape($strQuery) . "')";
            $this->query = $strQuery;
        }
 
        if ($cond1 != '')
        {
            $arWhere[] = 'cond1 = 1';
        }
 
        if ($strQuery || $this->tags || $bTagsCloud)
        {
            if ($limit <= 0)
            {
                $limit = intval(COption::GetOptionInt('search', 'max_result_size'));
            }
 
            if ($limit <= 0)
            {
                $limit = 500;
            }
 
            $ts = time() - CTimeZone::GetOffset();
            if ($bTagsCloud)
            {
                $sql = '
                    select groupby() tag_id
                    ,count(*) cnt
                    ,max(date_change) dc_tmp
                    ,if(date_to, date_to, ' . $ts . ') date_to_nvl
                    ,if(date_from, date_from, ' . $ts . ') date_from_nvl
                    ' . ($cond1 != '' ? ',' . $cond1 . ' as cond1' : '') . '
                    from ' . $this->indexName . '
                    where ' . implode("\nand\t", $arWhere) . '
                    group by tags
                    order by cnt desc
                    limit 0, ' . $limit . '
                    option max_matches = ' . $limit . '
                ';
 
                $DB = CDatabase::GetModuleConnection('search');
                $startTime = microtime(true);
 
                $r = $this->query($sql);
 
                if ($DB->ShowSqlStat)
                {
                    $DB->addDebugQuery($sql, microtime(true) - $startTime);
                }
 
                if (!$r)
                {
                    throw new \Bitrix\Main\Db\SqlQueryException('Sphinx select error', $this->getError(), $sql);
                }
                else
                {
                    while ($res = $this->fetch($r))
                    {
                        $result[] = $res;
                    }
                }
            }
            else
            {
                $sql = '
                    select id
                    ,item
                    ,param1
                    ,param2
                    ,module_id
                    ,param2_id
                    ,date_change
                    ,custom_rank
                    ,weight() as rank
                    ' . ($cond1 != '' ? ',' . $cond1 . ' as cond1' : '') . '
                    ,if(date_to, date_to, ' . $ts . ') date_to_nvl
                    ,if(date_from, date_from, ' . $ts . ') date_from_nvl
                    from ' . $this->indexName . '
                    where ' . implode("\nand\t", $arWhere) . '
                    ' . $this->__PrepareSort($aSort) . '
                    limit ' . $offset . ', ' . $limit . '
                    option max_matches = ' . ($offset + $limit) . '
                ';
 
                $DB = CDatabase::GetModuleConnection('search');
                $startTime = microtime(true);
 
                $r = $this->query($sql);
 
                if ($DB->ShowSqlStat)
                {
                    $DB->addDebugQuery($sql, microtime(true) - $startTime);
                }
 
                if (!$r)
                {
                    throw new \Bitrix\Main\Db\SqlQueryException('Sphinx select error', $this->getError(), $sql);
                }
                else
                {
                    $forum = sprintf('%u', crc32('forum'));
                    while ($res = $this->fetch($r))
                    {
                        if ($res['module_id'] == $forum)
                        {
                            if (array_key_exists($res['param2_id'], $this->arForumTopics))
                            {
                                continue;
                            }
                            $this->arForumTopics[$res['param2_id']] = true;
                        }
                        $result[] = $res;
                    }
                }
            }
        }
        else
        {
            $this->errorText = GetMessage('SEARCH_ERROR3');
            $this->errorNumber = 3;
        }
 
        return $result;
    }
 
    function searchTitle($phrase = '', $arPhrase = [], $nTopCount = 5, $arParams = [], $bNotFilter = false, $order = '')
    {
        $sqlWords = [];
        foreach (array_reverse($arPhrase, true) as $word => $pos)
        {
            $word = $this->Escape($word);
            if (empty($sqlWords) && !preg_match("/[\\n\\r \\t]$/", $phrase))
            {
                $sqlWords[] = $word . '*';
            }
            else
            {
                $sqlWords[] = $word;
            }
        }
        $match = '@title ' . implode(' ', array_reverse($sqlWords));
 
        $checkDates = false;
        if (array_key_exists('CHECK_DATES', $arParams))
        {
            if ($arParams['CHECK_DATES'] == 'Y')
            {
                $checkDates = true;
            }
            unset($arParams['CHECK_DATES']);
        }
 
        $arWhere = $this->prepareFilter($arParams);
 
        $cond1 = '';
        if (isset($arWhere['cond1']))
        {
            $cond1 = $arWhere['cond1'];
            unset($arWhere['cond1']);
        }
 
        $ts = time() - CTimeZone::GetOffset();
        if ($checkDates)
        {
            $arWhere[] = 'date_from_nvl <= ' . $ts;
            $arWhere[] = 'date_to_nvl >= ' . $ts;
        }
 
        $rights = $this->CheckPermissions();
        if ($rights)
        {
            $arWhere[] = 'right in (' . $rights . ')';
        }
 
        $arWhere[] = 'site = ' . sprintf('%u', crc32(SITE_ID));
        $arWhere[] = "match('" . $match . "')";
 
        $sql = '
            select id
            ,weight() as rank
            ' . ($cond1 != '' ? ',' . $cond1 . ' as cond1' : '') . '
            ,if(date_to, date_to, ' . $ts . ') date_to_nvl
            ,if(date_from, date_from, ' . $ts . ') date_from_nvl
            from ' . $this->indexName . '
            where ' . implode("\nand\t", $arWhere) . '
            ' . ($cond1 != '' ? ' and cond1 = ' . intval(!$bNotFilter) : '') . '
            ' . $this->__PrepareSort($order) . '
            limit 0, ' . $nTopCount . '
            option max_matches = ' . $nTopCount . '
        ';
 
        $DB = CDatabase::GetModuleConnection('search');
        $startTime = microtime(true);
 
        $r = $this->query($sql);
 
        if ($DB->ShowSqlStat)
        {
            $DB->addDebugQuery($sql, microtime(true) - $startTime);
        }
 
        if (!$r)
        {
            throw new \Bitrix\Main\Db\SqlQueryException('Sphinx select error', $this->getError(), $sql);
        }
        else
        {
            $result = [];
            while ($res = $this->fetch($r))
            {
                $result[] = $res['id'];
            }
            return $result;
        }
    }
 
    function getRowFormatter()
    {
        return new CSearchSphinxFormatter($this);
    }
 
    function filterField($field, $value, $inSelect)
    {
        $arWhere = [];
        if (is_array($value))
        {
            if (!empty($value))
            {
                $s = '';
                if ($inSelect)
                {
                    foreach ($value as $i => $v)
                    {
                        $s .= ',' . sprintf('%u', crc32($v));
                    }
                    $arWhere[] = 'in(' . $field . ' ' . $s . ')';
                }
                else
                {
                    foreach ($value as $i => $v)
                    {
                        $s .= ($s ? ' or ' : '') . $field . ' = ' . sprintf('%u', crc32($v));
                    }
                    $arWhere[] = '(' . $s . ')';
                }
            }
        }
        else
        {
            if ($value !== false)
            {
                $arWhere[] = $field . ' = ' . sprintf('%u', crc32($value));
            }
        }
        return $arWhere;
    }
 
    function prepareFilter($arFilter, $inSelect = false)
    {
        $arWhere = [];
        if (!is_array($arFilter))
        {
            $arFilter = [];
        }
 
        $orLogic = false;
        if (array_key_exists('LOGIC', $arFilter))
        {
            $orLogic = ($arFilter['LOGIC'] == 'OR');
            unset($arFilter['LOGIC']);
        }
 
        foreach ($arFilter as $field => $val)
        {
            $field = mb_strtoupper($field);
            if (
                is_array($val)
                && count($val) == 1
                && $field !== 'URL'
                && $field !== 'PARAMS'
                && !is_numeric($field)
            )
            {
                $val = $val[0];
            }
 
            switch ($field)
            {
            case 'ITEM_ID':
            case '=ITEM_ID':
                $arWhere = array_merge($arWhere, $this->filterField('item_id', $val, $inSelect));
                break;
            case '!ITEM_ID':
                if ($val !== false)
                {
                    $arWhere[] = 'item_id <> ' . sprintf('%u', crc32($val));
                }
                break;
            case 'MODULE_ID':
            case '=MODULE_ID':
                if ($val !== false && $val !== 'no')
                {
                    $arWhere[] = 'module_id = ' . sprintf('%u', crc32($val));
                }
                break;
            case 'PARAM1':
            case '=PARAM1':
                $arWhere = array_merge($arWhere, $this->filterField('param1_id', $val, $inSelect));
                break;
            case '!PARAM1':
            case '!=PARAM1':
                if ($val !== false)
                {
                    $arWhere[] = 'param1_id <> ' . sprintf('%u', crc32($val));
                }
                break;
            case 'PARAM2':
            case '=PARAM2':
                $arWhere = array_merge($arWhere, $this->filterField('param2_id', $val, $inSelect));
                break;
            case '!PARAM2':
            case '!=PARAM2':
                if ($val !== false)
                {
                    $arWhere[] = 'param2_id <> ' . sprintf('%u', crc32($val));
                }
                break;
            case 'DATE_CHANGE':
                if ($val <> '')
                {
                    $arWhere[] = 'date_change >= ' . intval(MakeTimeStamp($val) - CTimeZone::GetOffset());
                }
                break;
            case '<=DATE_CHANGE':
                if ($val <> '')
                {
                    $arWhere[] = 'date_change <= ' . intval(MakeTimeStamp($val) - CTimeZone::GetOffset());
                }
                break;
            case '>=DATE_CHANGE':
                if ($val <> '')
                {
                    $arWhere[] = 'date_change >= ' . intval(MakeTimeStamp($val) - CTimeZone::GetOffset());
                }
                break;
            case 'SITE_ID':
                if ($val !== false)
                {
                    if ($inSelect)
                    {
                        $arWhere[] = 'in(site, ' . sprintf('%u', crc32($val)) . ')';
                    }
                    else
                    {
                        $arWhere[] = 'site = ' . sprintf('%u', crc32($val));
                    }
                }
                break;
            case 'CHECK_DATES':
                if ($val == 'Y')
                {
                    $ts = time() - CTimeZone::GetOffset();
                    if ($inSelect)
                    {
                        $arWhere[] = 'if(date_from, date_from, ' . $ts . ') <= ' . $ts;
                        $arWhere[] = 'if(date_to, date_to, ' . $ts . ') >= ' . $ts;
                    }
                    else
                    {
                        $arWhere[] = 'date_from_nvl <= ' . $ts;
                        $arWhere[] = 'date_to_nvl >= ' . $ts;
                    }
                }
                break;
            case 'TAGS':
                $arTags = explode(',', $val);
                foreach ($arTags as $i => &$strTag)
                {
                    $strTag = trim($strTag, " \n\r\t\"");
                    if ($strTag == '')
                    {
                        unset($arTags[$i]);
                    }
                }
                unset($strTag);
 
                $arWhere = array_merge($arWhere, $this->filterField('tags', $arTags, $inSelect));
                break;
            case 'PARAMS':
                if (is_array($val))
                {
                    $params = $this->params($val);
                    if ($params != '')
                    {
                        if ($inSelect)
                        {
                            $arWhere[] = 'in(param, ' . $params . ')';
                        }
                        else
                        {
                            foreach (explode(',', $params) as $param)
                            {
                                $arWhere[] = 'param = ' . $param;
                            }
                        }
                    }
                }
                break;
            case 'URL': //TODO
            case 'QUERY':
            case 'LIMIT':
            case 'USE_TF_FILTER':
                break;
            default:
                if (is_numeric($field) && is_array($val))
                {
                    $subFilter = $this->prepareFilter($val, true);
                    if (!empty($subFilter))
                    {
                        if (isset($subFilter['cond1']))
                        {
                            $arWhere['cond1'][] = '(' . implode(')and(', $subFilter) . ')';
                        }
                        else
                        {
                            $arWhere[] = '(' . implode(')and(', $subFilter) . ')';
                        }
                    }
                }
                else
                {
                    //AddMessage2Log("field: $field; val: ".print_r($val, 1));
                }
                break;
            }
        }
 
        if (isset($arWhere['cond1']))
        {
            $arWhere['cond1'] = '(' . implode(')and(', $arWhere['cond1']) . ')';
        }
 
        if ($orLogic && !empty($arWhere))
        {
            $arWhere = [
                'cond1' => '(' . implode(')or(', $arWhere) . ')'
            ];
        }
 
        return $arWhere;
    }
 
    function CheckPermissions()
    {
        global $USER;
        $DB = CDatabase::GetModuleConnection('search');
 
        $arResult = [];
 
        if (!$USER->IsAdmin())
        {
            if ($USER->GetID() > 0)
            {
                CSearchUser::CheckCurrentUserGroups();
                $rs = $DB->Query('SELECT GROUP_CODE FROM b_search_user_right WHERE USER_ID = ' . $USER->GetID());
                while ($ar = $rs->Fetch())
                {
                    $arResult[] = $ar['GROUP_CODE'];
                }
            }
            else
            {
                $arResult[] = 'G2';
            }
        }
 
        return $this->rights($arResult);
    }
 
    function __PrepareSort($aSort = [])
    {
        $arOrder = [];
        if (!is_array($aSort))
        {
            $aSort = [$aSort => 'ASC'];
        }
 
        $this->flagsUseRatingSort = 0;
        foreach ($aSort as $key => $ord)
        {
            $ord = mb_strtoupper($ord) <> 'ASC' ? 'DESC' : 'ASC';
            $key = mb_strtolower($key);
            switch ($key)
            {
                case 'date_change':
                case 'custom_rank':
                case 'id':
                case 'param1':
                case 'param2':
                case 'date_from':
                case 'date_to':
                    $arOrder[] = $key . ' ' . $ord;
                    break;
                case 'item_id':
                    $arOrder[] = 'item ' . $ord;
                    break;
                case 'module_id':
                    $arOrder[] = 'module ' . $ord;
                    break;
                case 'rank':
                    $arOrder[] = 'rank ' . $ord;
                    break;
            }
        }
 
        if (count($arOrder) == 0)
        {
            $arOrder[] = 'custom_rank DESC';
            $arOrder[] = 'rank DESC';
            $arOrder[] = 'date_change DESC';
        }
 
        return ' ORDER BY ' . implode(', ',$arOrder);
    }
 
    public function Escape($str)
    {
        static $search = [
            '\\',
            "'",
            '/',
            ')',
            '(',
            '$',
            '~',
            '!',
            '@',
            '^',
            '-',
            '|',
            '<',
            "\x0",
            '=',
        ];
        static $replace = [
            '\\\\',
            "\\'",
            '\\\\/',
            '\\\\)',
            '\\\\(',
            '\\\\$',
            '\\\\~',
            '\\\\!',
            '\\\\@',
            '\\\\^',
            '\\\\-',
            '\\\\|',
            '\\\\<',
            ' ',
            ' ',
        ];
 
        $str = str_replace($search, $replace, $str);
 
        $stat = count_chars($str, 1);
        if (isset($stat[ord('"')]) && $stat[ord('"')] % 2 === 1)
        {
            $str = str_replace('"', '\\\"', $str);
        }
 
        return $str;
    }
 
    public function Escape2($str)
    {
        static $search = [
            '\\',
            "'",
            '"',
            "\x0",
        ];
        static $replace = [
            '\\\\',
            "\\'",
            '\\\\"',
            ' ',
        ];
        return str_replace($search, $replace, $str);
    }
 
    protected function canConnect()
    {
        return function_exists('mysqli_connect');
    }
 
    protected function internalConnect($connectionIndex, &$error)
    {
        $error = '';
        if (function_exists('mysqli_connect'))
        {
            $result = mysqli_init();
 
            if (mb_strpos($connectionIndex, ':') !== false)
            {
                list($host, $port) = explode(':', $connectionIndex, 2);
                $port = intval($port);
            }
            else
            {
                $host = $connectionIndex;
                $port = 0;
            }
 
            if ($port > 0)
            {
                if (!$result->real_connect($host, '', '', '', $port))
                {
                    $error = mysqli_connect_error();
                    $result = false;
                }
            }
            else
            {
                if (!$result->real_connect($host, '', '', ''))
                {
                    $error = mysqli_connect_error();
                    $result = false;
                }
            }
        }
        else
        {
            $result = false;
            $error = 'No MySql connection function has been found.';
        }
 
        return $result;
    }
 
    public function query($query)
    {
        if (is_object($this->db))
        {
            $result = $this->db->query($query);
        }
        else
        {
            $result = false;
        }
        return $result;
    }
 
    public function fetch($queryResult)
    {
        if (is_object($this->db))
        {
            $result = mysqli_fetch_assoc($queryResult);
        }
        else
        {
            $result = false;
        }
        return $result;
    }
 
    public function getError()
    {
        if (is_object($this->db))
        {
            $result = '[' . $this->db->errno . '] ' . $this->db->error;
        }
        else
        {
            $result = '';
        }
        return $result;
    }
}
 
class CSearchSphinxFormatter extends CSearchFormatter
{
    private $sphinx = null;
 
    function __construct($sphinx)
    {
        $this->sphinx = $sphinx;
    }
 
    function format($r)
    {
        if ($r)
        {
            if (array_key_exists('tag_id', $r))
            {
                return $this->formatTagsRow($r);
            }
            elseif (array_key_exists('id', $r))
            {
                return $this->formatRow($r);
            }
        }
    }
 
    function formatTagsRow($r)
    {
        $DB = CDatabase::GetModuleConnection('search');
 
        $tag_id = $r['tag_id'];
        if ($tag_id > 0x7FFFFFFF)
        {
            $tag_id = -(0xFFFFFFFF - $tag_id + 1);
        }
 
        $rs = $DB->Query('
            select
                st.NAME
            from b_search_tags st
            where st.SEARCH_CONTENT_ID = ' . $tag_id . "
            and st.SITE_ID = '??'
        ");
 
        $rt = $rs->Fetch();
        if ($rt)
        {
            $rt['NAME'] = htmlspecialcharsex($rt['NAME']);
            $rt['CNT'] = $r['cnt'];
            $rt['FULL_DATE_CHANGE'] = ConvertTimeStamp($r['dc_tmp'] + CTimeZone::GetOffset(), 'FULL');
            $rt['DATE_CHANGE'] = ConvertTimeStamp($r['dc_tmp'] + CTimeZone::GetOffset(), 'SHORT');
        }
        return $rt;
    }
 
    function formatRow($r)
    {
        $DB = CDatabase::GetModuleConnection('search');
        if ($this->sphinx->SITE_ID)
        {
            $rs = $DB->Query('
                select
                    sc.ID
                    ,sc.MODULE_ID
                    ,sc.ITEM_ID
                    ,sc.TITLE
                    ,sc.TAGS
                    ,sc.BODY
                    ,sc.PARAM1
                    ,sc.PARAM2
                    ,sc.UPD
                    ,sc.DATE_FROM
                    ,sc.DATE_TO
                    ,sc.URL
                    ,sc.CUSTOM_RANK
                    ,' . $DB->DateToCharFunction('sc.DATE_CHANGE') . ' as FULL_DATE_CHANGE
                    ,' . $DB->DateToCharFunction('sc.DATE_CHANGE', 'SHORT') . ' as DATE_CHANGE
                    ,scsite.SITE_ID
                    ,scsite.URL SITE_URL
                    ,sc.USER_ID
                from b_search_content sc
                INNER JOIN b_search_content_site scsite ON sc.ID=scsite.SEARCH_CONTENT_ID
                where ID = ' . $r['id'] . "
                and scsite.SITE_ID = '" . $DB->ForSql($this->sphinx->SITE_ID) . "'
            ");
        }
        else
        {
            $rs = $DB->Query('
                select
                    sc.ID
                    ,sc.MODULE_ID
                    ,sc.ITEM_ID
                    ,sc.TITLE
                    ,sc.TAGS
                    ,sc.BODY
                    ,sc.PARAM1
                    ,sc.PARAM2
                    ,sc.UPD
                    ,sc.DATE_FROM
                    ,sc.DATE_TO
                    ,sc.URL
                    ,sc.CUSTOM_RANK
                    ,' . $DB->DateToCharFunction('sc.DATE_CHANGE') . ' as FULL_DATE_CHANGE
                    ,' . $DB->DateToCharFunction('sc.DATE_CHANGE', 'SHORT') . ' as DATE_CHANGE
                    ,\'\' as SITE_ID
                from b_search_content sc
                where ID = ' . $r['id'] . '
            ');
        }
        $r = $rs->Fetch();
        if ($r)
        {
            $r['TITLE_FORMATED'] = $this->buildExcerpts(htmlspecialcharsex($r['TITLE']));
            $r['TITLE_FORMATED_TYPE'] = 'html';
            $r['TAGS_FORMATED'] = tags_prepare($r['TAGS'], SITE_ID);
            $r['BODY_FORMATED'] = $this->buildExcerpts(htmlspecialcharsex($r['BODY']));
            $r['BODY_FORMATED_TYPE'] = 'html';
        }
        return $r;
    }
 
    public function buildExcerpts($str)
    {
        $sql = "CALL SNIPPETS(
            '" . $this->sphinx->Escape2($str) . "'
            ,'" . $this->sphinx->Escape($this->sphinx->indexName) . "'
            ,'" . $this->sphinx->Escape($this->sphinx->query . ' ' . $this->sphinx->tags) . "'
            ,500 as limit
            ,1 as query_mode
        )";
        $result = $this->sphinx->query($sql);
 
        if ($result)
        {
            $res = $this->sphinx->fetch($result);
            if ($res)
            {
                return $res['snippet'];
            }
            else
            {
                return '';
            }
        }
        else
        {
            throw new \Bitrix\Main\Db\SqlQueryException('Sphinx select error', $this->sphinx->getError(), $sql);
        }
    }
}