<?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,
				)
			);
		}
	}
}