IndexTableTrait.php

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

<?php
 
namespace Bitrix\Im\V2\Common;
 
use Bitrix\Main\Application;
use Bitrix\Main\ORM\Data\DataManager;
use Bitrix\Main\ORM\Data\Internal\DeleteByFilterTrait;
use Bitrix\Main\ORM\Query\Filter\Helper;
use Bitrix\Main\ORM\Query\Query;
use Bitrix\Main\Search\Content;
 
trait IndexTableTrait
{
    use MultiplyInsertTrait;
    use DeleteByFilterTrait;
 
    private static bool $isAlreadyPlanned = false;
 
    public static function indexInBackground(): void
    {
        if (self::$isAlreadyPlanned)
        {
            return;
        }
 
        self::$isAlreadyPlanned = true;
 
        Application::getInstance()->addBackgroundJob(fn () => self::runIndex());
    }
 
    public static function prepareSearchString(string $searchString): string
    {
        $searchString = Content::prepareStringToken($searchString);
        $searchString = Helper::matchAgainstWildcard($searchString);
 
        return $searchString;
    }
 
    public static function deleteByParentFilter(array $filter): void
    {
        $baseTablePrimary = static::getBaseDataClass()::getEntity()->getPrimary();
        $indexTablePrimary = static::getEntity()->getPrimary();
        $rows = static::getBaseDataClass()::getList(['select' => [$baseTablePrimary], 'filter' => $filter])->fetchAll();
        $primaries = [];
 
        foreach ($rows as $row)
        {
            $primaries[] = (int)$row[$baseTablePrimary];
        }
 
        if (empty($primaries))
        {
            return;
        }
 
        sort($primaries);
 
        static::deleteByFilter(["={$indexTablePrimary}" => $primaries]);
    }
 
    public static function updateIndexStatus(array $ids, bool $status = true): void
    {
        if (empty($ids))
        {
            return;
        }
 
        $connection = Application::getConnection();
        $sqlHelper = $connection->getSqlHelper();
        $baseTable = $sqlHelper->quote(static::getBaseDataClass()::getTableName());
        $baseTablePrimary = $sqlHelper->quote(static::getBaseDataClass()::getEntity()->getPrimary());
        $implodeIds = implode(',', $ids);
        $statusString = $status ? 'Y' : 'N';
 
        $sql = "
            UPDATE {$baseTable}
            SET IS_INDEXED = '{$statusString}'
            WHERE {$baseTablePrimary} IN ({$implodeIds});
        ";
 
        $connection->queryExecute($sql);
    }
 
    private static function runIndex(): void
    {
        self::index();
        self::$isAlreadyPlanned = false;
    }

    abstract protected static function getBaseDataClass(): string;
 
    abstract public static function index(): void;
}