clearsearchcontentagent.php

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

<?php
 
namespace Bitrix\Bizproc\Worker\Task;
 
use Bitrix\Main;
use Bitrix\Main\Application;
 
class ClearSearchContentAgent
{
    protected const CLEAR_LOG_SELECT_LIMIT = 50000;
    protected const CLEAR_LOG_DELETE_LIMIT = 1000;
 
    public static function getName()
    {
        return static::class . '::execute();';
    }
 
    public static function execute()
    {
        $days = 180;
        if (!Main\ModuleManager::isModuleInstalled('bitrix24'))
        {
            $days = (int)Main\Config\Option::get('bizproc', 'search_cleanup_days', 180);
        }
 
        static::clear($days);
 
        return static::getName();
    }
 
    private static function clear(int $days): void
    {
        $connection = Application::getConnection();
        $helper = $connection->getSqlHelper();
        $limit = static::CLEAR_LOG_SELECT_LIMIT;
        $partLimit = static::CLEAR_LOG_DELETE_LIMIT;
        $sqlIntervalLt = $helper->addDaysToDateTime(-1 * $days);
        $sqlIntervalGt = $helper->addDaysToDateTime(-1 * ($days + 1));
 
        $strSql = "SELECT st.TASK_ID FROM b_bp_task_search_content st "
            . "INNER JOIN b_bp_task t ON (st.TASK_ID = t.ID) "
            . "WHERE t.MODIFIED < {$sqlIntervalLt} "
            . "AND t.MODIFIED > {$sqlIntervalGt} LIMIT {$limit}";
        $ids = $connection->query($strSql)->fetchAll();
 
        if (!$ids)
        {
            return;
        }
 
        while ($partIds = array_splice($ids, 0, $partLimit))
        {
            $inSql = implode(",", array_column($partIds, 'TASK_ID'));
            $connection->query(
                sprintf(
                    'DELETE from b_bp_task_search_content WHERE TASK_ID IN(%s)',
                    $inSql,
                )
            );
        }
    }
}