PhraseFtsIndexConverter.php

<?php
namespace Bitrix\Translate\Update;
 
use Bitrix\Main\Loader;
use Bitrix\Main\DB\SqlException;
use Bitrix\Main\Config\Option;
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\Localization\LanguageTable;
use Bitrix\Translate\Index;
 
 
final class PhraseFtsIndexConverter extends \Bitrix\Main\Update\Stepper
{
    const OPTION_NAME = 'fts_index_converter_stepper';
    protected static $moduleId = 'translate';
 
    public function execute(array &$result)
    {
        if (!Loader::includeModule(self::$moduleId))
        {
            return self::FINISH_EXECUTION;
        }
 
        global $pPERIOD;
        $pPERIOD = 30; 
        $connection = \Bitrix\Main\Application::getConnection();
        if (!$connection->isTableExists('b_translate_phrase'))
        {
            return self::FINISH_EXECUTION;
        }
 
        try
        {
            $connection->query("SELECT `PHRASE` FROM `b_translate_phrase` WHERE 1=0");
        }
        catch (SqlException $exception)
        {
            return self::FINISH_EXECUTION;
        }
 
        $startTime = time();
        $isCronRun =
            !\Bitrix\Main\ModuleManager::isModuleInstalled('bitrix24')
            && (php_sapi_name() === 'cli');
 
        $return = self::FINISH_EXECUTION;
 
        $params = Option::get(self::$moduleId, self::OPTION_NAME, '');
        $params = $params !== '' ? @unserialize($params, ['allowed_classes' => false]) : [];
        $params = is_array($params) ? $params : [];
 
        if (empty($params))
        {
            $params = [
                'languages' => [],
                'index' => false,
                'field' => false,
                'number' => 0,
                'count' => LanguageTable::getCount() + 2,
            ];
        }
 
        if ($params['count'] > 0)
        {
            $result['title'] = Loc::getMessage('IM_UPDATE_CHAT_DISK_ACCESS');
            $result['progress'] = 1;
            $result['steps'] = '';
            $result['count'] = $params['count'];
 
            $filter = [];
            if (!empty($params['languages']))
            {
                $filter['!=ID'] = $params['languages'];
            }
            $found = false;
            $langList = LanguageTable::getList([
                'select' => ['ID'],
                'filter' => $filter,
                'order' => ['SORT' => 'ASC'],
            ]);
            while ($row = $langList->fetch())
            {
                $langId = mb_strtolower($row['ID']);
                if (!preg_match("/[a-z0-9]{2}/i", $langId))
                {
                    continue;
                }
 
                try
                {
                    Index\Internals\PhraseFts::createTable($langId);
                    $partitionTable = Index\Internals\PhraseFts::getPartitionTableName($langId);
 
                    $connection->queryExecute("
                        INSERT IGNORE INTO `{$partitionTable}` 
                        SELECT `ID`, `FILE_ID`, `PATH_ID`, `CODE`, `PHRASE` FROM `b_translate_phrase` WHERE `LANG_ID` = '{$langId}'
                    ");
                }
                catch (SqlException $exception)
                {}
 
                $params['languages'][] = $langId;
                $params['number']++;
                $found = true;
                if (!$isCronRun && (time() - $startTime >= 30))
                {
                    break;
                }
            }
 
            if ($found === false)
            {
                if ($params['index'] === false)
                {
                    try
                    {
                        $connection->queryExecute("ALTER TABLE `b_translate_phrase` DROP INDEX `IXF_TRNSL_PHR`");
                    }
                    catch (SqlException $exception)
                    {}
                    $params['index'] = true;
                    $params['number']++;
                    $found = true;
                }
                elseif ($params['field'] === false)
                {
                    try
                    {
                        $connection->queryExecute("ALTER TABLE `b_translate_phrase` DROP COLUMN `PHRASE`");
                    }
                    catch (SqlException $exception)
                    {}
                    $params['field'] = true;
                    $params['number']++;
                    $found = true;
                }
            }
 
            if ($found)
            {
                Option::set(self::$moduleId, self::OPTION_NAME, serialize($params));
                $return = self::CONTINUE_EXECUTION;
            }
 
            $result['progress'] = floor($params['number'] * 100 / $params['count']);
            $result['steps'] = $params['number'];
 
            if ($found === false)
            {
                Option::delete(self::$moduleId, ['name' => self::OPTION_NAME]);
            }
        }
        
        return $return;
    }
}