clearfilteragent.php

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

<?php
 
namespace Bitrix\Bizproc\Worker\Workflow;
 
use Bitrix\Main;
use Bitrix\Main\Application;
 
class ClearFilterAgent
{
    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;
        $sqlInterval = $helper->addDaysToDateTime(-1 * $days);
 
        $strSql = "SELECT DISTINCT WORKFLOW_ID FROM b_bp_workflow_user "
            . "WHERE WORKFLOW_STATUS = 1 AND MODIFIED < {$sqlInterval} LIMIT {$limit}";
        $ids = $connection->query($strSql)->fetchAll();
 
        if (!$ids)
        {
            return;
        }
 
        while ($partIds = array_splice($ids, 0, $partLimit))
        {
            $inSql = "'" . implode("','", array_column($partIds, 'WORKFLOW_ID')) . "'";
            $connection->query(
                sprintf(
                    'DELETE from b_bp_workflow_filter WHERE WORKFLOW_ID IN(%s)',
                    $inSql,
                )
            );
        }
    }
}