<?php

use Bitrix\Main;
use Bitrix\Bizproc;

class CBPTaskService extends CBPRuntimeService
{
	const COUNTERS_CACHE_TAG_PREFIX = 'b_bp_tasks_cnt_';

	public function deleteTask($id)
	{
		self::Delete($id);
	}

	public function deleteAllWorkflowTasks($workflowId)
	{
		self::DeleteByWorkflow($workflowId);
	}

	public function markCompleted($taskId, $userId, $status = CBPTaskUserStatus::Ok)
	{
		$taskId = (int)$taskId;
		if ($taskId <= 0)
		{
			throw new Main\ArgumentOutOfRangeException('id', 1);
		}

		$userId = (int)$userId;
		if ($userId <= 0)
		{
			throw new Main\ArgumentOutOfRangeException('userId', 1);
		}

		$status = (int)$status;

		Bizproc\Workflow\Task\TaskUserTable::updateStatus($taskId, [$userId], $status);

		self::decrementUserTaskCounter($userId);
		self::onTaskChange(
			$taskId,
			[
				'USERS' => [$userId],
				'USERS_STATUSES' => [$userId => $status],
				'COUNTERS_DECREMENTED' => [$userId],
				'STATUS_NAME' => 'COMPLETED',
			],
			CBPTaskChangedStatus::Update
		);
		foreach (GetModuleEvents('bizproc', 'OnTaskMarkCompleted', true) as $arEvent)
		{
			ExecuteModuleEventEx($arEvent, [$taskId, $userId, $status]);
		}
	}

	/**
	 * @throws Main\ArgumentOutOfRangeException
	 * @throws Main\ArgumentNullException
	 */
	public function markUnCompleted(int $taskId, array $userIds)
	{
		if ($taskId <= 0)
		{
			throw new Main\ArgumentOutOfRangeException('taskId', 1);
		}

		Main\Type\Collection::normalizeArrayValuesByInt($userIds, false);
		if (empty($userIds))
		{
			throw new Main\ArgumentNullException('userIds');
		}

		$status = CBPTaskUserStatus::Waiting;

		Bizproc\Workflow\Task\TaskUserTable::updateStatus($taskId, $userIds, $status);

		$usersStatuses = [];
		foreach ($userIds as $userId)
		{
			self::incrementUserTaskCounter($userId);
			$usersStatuses[$userId] = $status;
		}
		self::onTaskChange(
			$taskId,
			[
				'USERS' => $userIds,
				'USERS_STATUSES' => $usersStatuses,
				'COUNTERS_INCREMENTED' => $userIds,
				'STATUS_NAME' => 'UNCOMPLETED',
			],
			CBPTaskChangedStatus::Update
		);
		foreach (GetModuleEvents('bizproc', 'OnTaskMarkUnCompleted', true) as $arEvent)
		{
			ExecuteModuleEventEx($arEvent, [$taskId, $userIds, $status]);
		}
	}

	public static function getTaskUsers($taskId)
	{
		global $DB;

		$taskId = (array)$taskId;
		$taskId = array_map('intval', $taskId);
		$taskId = array_filter($taskId);
		if (sizeof($taskId) < 1)
		{
			throw new Exception("taskId");
		}

		$where = '';
		foreach ($taskId as $id)
		{
			if ($where)
			{
				$where .= ' OR ';
			}
			$where .= ' TASK_ID = '.$id;
		}

		$dateUpdateSelect = $DB->DateToCharFunction('TU.DATE_UPDATE', 'FULL') . ' as DATE_UPDATE';

		$users = [];
		$iterator = $DB->Query(
			'SELECT'
			.' TU.ID, TU.USER_ID, TU.TASK_ID, TU.STATUS, TU.ORIGINAL_USER_ID, ' . $dateUpdateSelect . ','
			.' U.PERSONAL_PHOTO, U.NAME, U.LAST_NAME, U.SECOND_NAME, U.LOGIN, U.TITLE'
			.' FROM b_bp_task_user TU'
			.' INNER JOIN b_user U ON (U.ID = TU.USER_ID)'
			.' WHERE '.$where
			.' ORDER BY TU.DATE_UPDATE DESC'
		);

		while ($user = $iterator->fetch())
		{
			$users[$user['TASK_ID']][] = $user;
		}
		return $users;
	}

	public static function getTaskUserIds(int $taskId): array
	{
		$ids = [];
		$taskUsers = static::getTaskUsers($taskId);
		if (isset($taskUsers[$taskId]))
		{
			$ids = array_column($taskUsers[$taskId], 'USER_ID');
		}

		return array_map('intval', $ids);
	}

	/**
	 * @param string $workflowId - Internal workflow id.
	 * @param null|int $userStatus - Filter participants by status.
	 * @return array - User ids array (ex. array(1, 2, 3)).
	 * @throws Exception
	 */
	public static function getWorkflowParticipants($workflowId, $userStatus = null)
	{
		global $DB;

		if ($workflowId == '')
		{
			throw new Exception('workflowId');
		}

		$users = [];
		$iterator = $DB->Query('SELECT DISTINCT TU.USER_ID'
			.' FROM b_bp_task_user TU'
			.' INNER JOIN b_bp_task T ON (T.ID = TU.TASK_ID)'
			.' WHERE T.WORKFLOW_ID = \''.$DB->ForSql($workflowId).'\''
			.($userStatus !== null ? ' AND TU.STATUS = '.(int)$userStatus : '')
		);
		while ($user = $iterator->fetch())
		{
			$users[] = (int)$user['USER_ID'];
		}

		return $users;
	}

	public static function getWorkflowUsers(string $workflowId): array
	{
		global $DB;

		$users = [];
		$iteratorOverdueNull = $DB->Query('SELECT DISTINCT TU.USER_ID, TU.STATUS'
			. ' FROM b_bp_task_user TU'
			. ' INNER JOIN b_bp_task T ON (T.ID = TU.TASK_ID)'
			. ' WHERE T.WORKFLOW_ID = \''.$DB->ForSql($workflowId).'\''
			. ' AND T.OVERDUE_DATE IS NULL'
		);
		self::extractUsers($iteratorOverdueNull, $users);

		$connection = $DB->getConnection();
		$sqlHelper = $connection->getSqlHelper();
		$query = 'SELECT DISTINCT TU.USER_ID, TU.STATUS'
			. ' FROM b_bp_task_user TU'
			. ' INNER JOIN b_bp_task T ON (T.ID = TU.TASK_ID)'
			. ' WHERE T.WORKFLOW_ID = \''.$DB->ForSql($workflowId).'\''
			. ' AND T.OVERDUE_DATE > ' . $sqlHelper->getCurrentDateTimeFunction();
		$iteratorOverdueFuture = $DB->Query($query);
		self::extractUsers($iteratorOverdueFuture, $users);

		return $users;
	}

	public static function extractUsers(mixed $usersIterator, array &$users): void
	{
		while ($user = $usersIterator->fetch())
		{
			$userId = (int)$user['USER_ID'];
			$status = (int)$user['STATUS'];

			if (isset($users[$userId]))
			{
				$users[$userId] = min($users[$userId], $status);
				continue;
			}

			$users[$userId] = $status;
		}
	}

	public static function delegateTask($taskId, $fromUserId, $toUserId)
	{
		$taskId = (int)$taskId;
		$fromUserId = (int)$fromUserId;
		$toUserId = (int)$toUserId;

		if (!$taskId || !$fromUserId || !$toUserId)
		{
			return false;
		}

		// check USER_ID (USER_ID must be unique for task)
		$iterator =
			Bizproc\Workflow\Task\TaskUserTable::query()
				->setSelect(['USER_ID'])
				->where('TASK_ID', $taskId)
				->where('USER_ID', $toUserId)
				->exec()
		;
		$row = $iterator->fetch();
		if (!empty($row['USER_ID']))
		{
			return false;
		}

		Bizproc\Workflow\Task\TaskUserTable::delegateTask($taskId, $fromUserId, $toUserId);

		self::decrementUserTaskCounter($fromUserId);
		self::incrementUserTaskCounter($toUserId);
		self::onTaskChange(
			$taskId,
			[
				'USERS' => [$toUserId],
				'USERS_ADDED' => [$toUserId],
				'USERS_REMOVED' => [$fromUserId],
				'COUNTERS_DECREMENTED' => [$fromUserId],
				'COUNTERS_INCREMENTED' => [$toUserId],
			],
			CBPTaskChangedStatus::Delegate
		);
		foreach (GetModuleEvents('bizproc', 'OnTaskDelegate', true) as $arEvent)
		{
			ExecuteModuleEventEx($arEvent, [$taskId, $fromUserId, $toUserId]);
		}

		return true;
	}

	public static function getOriginalTaskUserId($taskId, $realUserId)
	{
		$taskId = (int)$taskId;
		$realUserId = (int)$realUserId;

		$originalUserId = Bizproc\Workflow\Task\TaskUserTable::getOriginalTaskUserId($taskId, $realUserId);
		if ($originalUserId !== null)
		{
			return $originalUserId > 0 ? $originalUserId : $realUserId;
		}

		return false;
	}

	public static function delete($id)
	{
		global $DB;

		$id = intval($id);
		if ($id <= 0)
		{
			throw new Exception("id");
		}

		$removedUsers = $decremented = [];
		$dbRes = $DB->Query("SELECT USER_ID, STATUS FROM b_bp_task_user WHERE TASK_ID = ".intval($id)." ");
		while ($arRes = $dbRes->Fetch())
		{
			if ($arRes['STATUS'] == CBPTaskUserStatus::Waiting)
			{
				self::decrementUserTaskCounter((int)$arRes['USER_ID']);
				$decremented[] = $arRes["USER_ID"];
			}
			$removedUsers[] = $arRes["USER_ID"];
		}
		$DB->Query("DELETE FROM b_bp_task_user WHERE TASK_ID = ".intval($id)." ",);

		self::onTaskChange(
			$id,
			[
				'USERS_REMOVED' => $removedUsers,
				'COUNTERS_DECREMENTED' => $decremented,
			],
			CBPTaskChangedStatus::Delete
		);
		foreach (GetModuleEvents("bizproc", "OnTaskDelete", true) as $arEvent)
		{
			ExecuteModuleEventEx($arEvent, [$id]);
		}

		$DB->Query('DELETE FROM b_bp_task WHERE ID = ' . (int)$id . ' ');
	}

	public static function deleteByWorkflow($workflowId, $taskStatus = null)
	{
		global $DB;

		$workflowId = trim($workflowId);
		if ($workflowId == '')
		{
			throw new Exception("workflowId");
		}

		$dbRes = $DB->Query(
			"SELECT ID ".
			"FROM b_bp_task ".
			"WHERE WORKFLOW_ID = '".$DB->ForSql($workflowId)."' "
			.($taskStatus !== null? 'AND STATUS = '.(int)$taskStatus : '')
		);
		$allUsers = [];
		while ($arRes = $dbRes->Fetch())
		{
			$taskId = intval($arRes["ID"]);
			$removedUsers = $decremented = [];
			$dbResUser = $DB->Query("SELECT USER_ID, STATUS FROM b_bp_task_user WHERE TASK_ID = ".$taskId." ");
			while ($arResUser = $dbResUser->Fetch())
			{
				if ($arResUser['STATUS'] == CBPTaskUserStatus::Waiting)
				{
					self::decrementUserTaskCounter((int)$arResUser['USER_ID']);
					$decremented[] = $arResUser["USER_ID"];
				}
				$removedUsers[] = $arResUser['USER_ID'];
				$allUsers[] = $arResUser['USER_ID'];
			}
			$DB->Query("DELETE FROM b_bp_task_user WHERE TASK_ID = ".$taskId." ");

			self::onTaskChange(
				$taskId,
				[
					'USERS_REMOVED' => $removedUsers,
					'COUNTERS_DECREMENTED' => $decremented,
				],
				CBPTaskChangedStatus::Delete
			);
			foreach (GetModuleEvents("bizproc", "OnTaskDelete", true) as $arEvent)
			{
				ExecuteModuleEventEx($arEvent, [$taskId]);
			}
		}

		$DB->Query(
			"DELETE FROM b_bp_task ".
			"WHERE WORKFLOW_ID = '".$DB->ForSql($workflowId)."' "
			.($taskStatus !== null? 'AND STATUS = '.(int)$taskStatus : '')
		);
	}

	public static function getCounters($userId)
	{
		global $DB;

		$counters = array('*' => 0);
		$cache = \Bitrix\Main\Application::getInstance()->getManagedCache();
		$cacheTag = self::COUNTERS_CACHE_TAG_PREFIX.$userId;
		if ($cache->read(3600*24*7, $cacheTag))
		{
			$counters = (array) $cache->get($cacheTag);
		}
		else
		{
			$query =
				"SELECT WI.MODULE_ID AS MODULE_ID, WI.ENTITY AS ENTITY, COUNT('x') AS CNT ".
				'FROM b_bp_task T '.
				'	INNER JOIN b_bp_task_user TU ON (T.ID = TU.TASK_ID) '.
				'	INNER JOIN b_bp_workflow_instance WI ON (T.WORKFLOW_ID = WI.ID) '.
				'WHERE TU.STATUS = '.(int)CBPTaskUserStatus::Waiting.' '.
				'	AND TU.USER_ID = '.(int)$userId.' '.
				'GROUP BY MODULE_ID, ENTITY';

			$iterator = $DB->Query($query);
			if ($iterator)
			{
				while ($row = $iterator->fetch())
				{
					$cnt = (int)$row['CNT'];
					$counters[$row['MODULE_ID']][$row['ENTITY']] = $cnt;
					if (!isset($counters[$row['MODULE_ID']]['*']))
						$counters[$row['MODULE_ID']]['*'] = 0;
					$counters[$row['MODULE_ID']]['*'] += $cnt;
					$counters['*'] += $cnt;
				}
				$cache->set($cacheTag, $counters);
			}
		}
		return $counters;
	}

	protected static function onTaskChange($taskId, $taskData, $status)
	{
		$workflowId = isset($taskData['WORKFLOW_ID']) ? $taskData['WORKFLOW_ID'] : null;
		if (!$workflowId)
		{
			$iterator = CBPTaskService::GetList(array('ID'=>'DESC'), array('ID' => $taskId), false, false, array('WORKFLOW_ID'));
			$row = $iterator->fetch();
			if (!$row)
			{
				return false;
			}
			$workflowId = $row['WORKFLOW_ID'];
			$taskData['WORKFLOW_ID'] = $workflowId;
		}

		//clean counters cache
		$users = array();
		if (!empty($taskData['USERS']))
		{
			$users = $taskData['USERS'];
		}
		if (!empty($taskData['USERS_REMOVED']))
		{
			$users = array_merge($users, $taskData['USERS_REMOVED']);
		}
		if (!empty($taskData['USERS_STATUSES']))
		{
			$users = array_merge($users, array_keys($taskData['USERS_STATUSES']));
		}
		self::cleanCountersCache($users);

		self::setSearchContent($status, $taskId, $taskData);

		//ping document
		$runtime = CBPRuntime::GetRuntime();
		$runtime->StartRuntime();
		$documentId = CBPStateService::GetStateDocumentId($workflowId);
		if ($documentId)
		{
			$documentService = $runtime->GetService('DocumentService');
			try
			{
				$documentService->onTaskChange($documentId, $taskId, $taskData, $status);
			}
			catch (Exception $e)
			{

			}
		}

		// currently out of usage
		//static::pushChanges($taskId, $taskData, $status);

		return true;
	}

	private static function pushChanges($taskId, $taskData, $status)
	{
		$eventName = Bizproc\Integration\Push\BasePush::EVENT_ADDED;
		$users = [];

		switch ($status)
		{
			case CBPTaskChangedStatus::Add:
				$users = $taskData['USERS'];
				break;
			case CBPTaskChangedStatus::Update:
			case CBPTaskChangedStatus::Delegate:
				$eventName = Bizproc\Integration\Push\BasePush::EVENT_UPDATED;
				$users = array_unique(
					array_merge(
						$taskData['USERS'] ?? [],
						$taskData['USERS_ADDED'] ?? [],
						$taskData['USERS_REMOVED'] ?? [],
						array_keys($taskData['USERS_STATUSES'] ?? []),
					)
				);
				break;
			case CBPTaskChangedStatus::Delete:
				$eventName = Bizproc\Integration\Push\BasePush::EVENT_DELETED;
				$users = $taskData['USERS_REMOVED'];
				break;
		}

		if (empty($users))
		{
			$users = static::getTaskUserIds($taskId);
		}

		Bizproc\Integration\Push\TaskPush::pushLastEvent($eventName, $taskId, $users);
	}

	protected static function cleanCountersCache($users)
	{
		$users = (array) $users;
		$users = array_unique($users);
		$cache = \Bitrix\Main\Application::getInstance()->getManagedCache();
		foreach ($users as $userId)
		{
			$cache->clean(self::COUNTERS_CACHE_TAG_PREFIX.$userId);
		}
	}

	protected static function parseFields(&$arFields, $id = 0)
	{
		global $DB;

		$id = intval($id);
		$updateMode = ($id > 0 ? true : false);
		$addMode = !$updateMode;

		if ($addMode && !is_set($arFields, "USERS"))
			throw new Exception("USERS");

		if (is_set($arFields, "USERS"))
		{
			$arUsers = $arFields["USERS"];
			if (!is_array($arUsers))
				$arUsers = array($arUsers);

			$arFields["USERS"] = array();
			foreach ($arUsers as $userId)
			{
				$userId = intval($userId);
				if ($userId > 0 && !in_array($userId, $arFields["USERS"]))
					$arFields["USERS"][] = $userId;
			}

			if (count($arFields["USERS"]) <= 0)
				throw new Exception(GetMessage("BPTS_AI_AR_USERS"));
		}

		if (is_set($arFields, "WORKFLOW_ID") || $addMode)
		{
			$arFields["WORKFLOW_ID"] = trim($arFields["WORKFLOW_ID"]);
			if ($arFields["WORKFLOW_ID"] == '')
				throw new Exception("WORKFLOW_ID");
		}

		if (is_set($arFields, "ACTIVITY") || $addMode)
		{
			$arFields["ACTIVITY"] = trim($arFields["ACTIVITY"]);
			if ($arFields["ACTIVITY"] == '')
				throw new Exception("ACTIVITY");
		}

		if (is_set($arFields, "ACTIVITY_NAME") || $addMode)
		{
			$arFields["ACTIVITY_NAME"] = trim($arFields["ACTIVITY_NAME"]);
			if ($arFields["ACTIVITY_NAME"] == '')
				throw new Exception("ACTIVITY_NAME");
		}

		if (is_set($arFields, "NAME") || $addMode)
		{
			$arFields["NAME"] = is_scalar($arFields["NAME"]) ? trim($arFields["NAME"]) : '';
			if ($arFields["NAME"] == '')
				throw new Exception("NAME");

			$arFields["NAME"] = htmlspecialcharsback($arFields["NAME"]);
		}

		if (is_set($arFields, "DESCRIPTION"))
		{
			$arFields["DESCRIPTION"] = htmlspecialcharsback(CBPHelper::stringify($arFields["DESCRIPTION"]));
		}

		if (is_set($arFields, "PARAMETERS"))
		{
			if ($arFields["PARAMETERS"] == null)
			{
				$arFields["PARAMETERS"] = false;
			}
			else
			{
				$arParameters = $arFields["PARAMETERS"];
				if (!is_array($arParameters))
					$arParameters = array($arParameters);
				if (count($arParameters) > 0)
					$arFields["PARAMETERS"] = serialize($arParameters);
			}
		}

		if (is_set($arFields, "OVERDUE_DATE"))
		{
			if ($arFields["OVERDUE_DATE"] == null)
			{
				$arFields["OVERDUE_DATE"] = false;
			}
			elseif (!$DB->IsDate($arFields["OVERDUE_DATE"], false, LANG, "FULL"))
			{
				throw new Exception("OVERDUE_DATE");
			}
		}

		if (isset($arFields['CREATED_DATE']) && !$DB->IsDate($arFields['CREATED_DATE']))
		{
			throw new Main\ArgumentException('Field CREATED_DATE must be datetime');
		}
	}

	public static function onAdminInformerInsertItems()
	{
		global $USER;

		if(!defined("BX_AUTH_FORM"))
		{
			$tasksCount = CUserCounter::GetValue($USER->GetID(), 'bp_tasks');

			if($tasksCount > 0)
			{
				$bpAIParams = array(
					"TITLE" => GetMessage("BPTS_AI_BIZ_PROC"),
					"HTML" => '<span class="adm-informer-strong-text">'.GetMessage("BPTS_AI_EX_TASKS").'</span><br>'.GetMessage("BPTS_AI_TASKS_NUM").' '.$tasksCount,
					"FOOTER" => '<a href="/bitrix/admin/bizproc_task_list.php?lang='.LANGUAGE_ID.'">'.GetMessage("BPTS_AI_TASKS_PERF").'</a>',
					"COLOR" => "red",
					"ALERT" => true,
				);

				CAdminInformer::AddItem($bpAIParams);
			}
		}
	}

	public function createTask($arFields)
	{
		return self::add($arFields);
	}

	public static function add($arFields): int
	{
		global $DB;

		$arFields['CREATED_DATE'] = new Main\Type\DateTime();

		self::ParseFields($arFields, 0);

		$arInsert = $DB->PrepareInsert("b_bp_task", $arFields);

		$strSql =
			"INSERT INTO b_bp_task (".$arInsert[0].", MODIFIED) ".
			"VALUES(".$arInsert[1].", ".$DB->CurrentTimeFunction().")";
		$DB->Query($strSql);

		$taskId = intval($DB->LastID());

		if ($taskId > 0)
		{
			$users = [];
			foreach ($arFields["USERS"] as $userId)
			{
				$userId = (int)($userId);
				if (in_array($userId, $users))
				{
					continue;
				}

				$DB->Query(
					"INSERT INTO b_bp_task_user (USER_ID, TASK_ID, ORIGINAL_USER_ID) ".
					"VALUES (".intval($userId).", ".intval($taskId).", ".intval($userId).") "
				);

				self::incrementUserTaskCounter($userId);
				$users[] = $userId;
			}

			$arFields['COUNTERS_INCREMENTED'] = $users;
			self::onTaskChange($taskId, $arFields, CBPTaskChangedStatus::Add);

			foreach (GetModuleEvents("bizproc", "OnTaskAdd", true) as $arEvent)
			{
				ExecuteModuleEventEx($arEvent, [$taskId, $arFields]);
			}
		}

		return $taskId;
	}

	public static function update($id, $arFields)
	{
		global $DB;

		$id = intval($id);
		if ($id <= 0)
		{
			throw new Exception("id");
		}

		self::ParseFields($arFields, $id);

		$strUpdate = $DB->PrepareUpdate("b_bp_task", $arFields);

		if ($strUpdate)
		{
			$strSql =
				"UPDATE b_bp_task SET ".
				"	".$strUpdate.", ".
				"	MODIFIED = ".$DB->CurrentTimeFunction()." ".
				"WHERE ID = ".intval($id)." ";
			$DB->Query($strSql);
		}

		$removedUsers = $addedUsers = $decremented = $incremented = [];

		if (is_set($arFields, 'USERS'))
		{
			$arFields['USERS'] = array_map('intval', array_unique($arFields['USERS']));
			$previousUserIds = static::getTaskUserIds($id);

			foreach ($arFields['USERS'] as $userId)
			{
				if (in_array($userId, $previousUserIds, true))
				{
					continue;
				}

				$DB->Query(
					"INSERT INTO b_bp_task_user (USER_ID, TASK_ID, ORIGINAL_USER_ID) ".
					"VALUES ({$userId}, {$id}, {$userId})"
				);

				$addedUsers[] = $userId;
				$incremented[] = $userId;
				self::incrementUserTaskCounter($userId);
			}

			$diff = array_diff($previousUserIds, $arFields['USERS']);
			foreach ($diff as $removedUserId)
			{
				$decremented[] = $removedUserId;
				self::decrementUserTaskCounter($removedUserId);
				$removedUsers[] = $removedUserId;
				$DB->Query("DELETE FROM b_bp_task_user WHERE TASK_ID = {$id} AND USER_ID = {$removedUserId}");
			}
		}

		$userStatuses = [];
		if (isset($arFields['STATUS']) && $arFields['STATUS'] > CBPTaskStatus::Running)
		{
			$dbResUser = $DB->Query("SELECT USER_ID FROM b_bp_task_user WHERE TASK_ID = ".$id." AND STATUS = ".CBPTaskUserStatus::Waiting);
			while ($userIterator = $dbResUser->Fetch())
			{
				$decremented[] = $userIterator["USER_ID"];
				self::decrementUserTaskCounter((int)$userIterator['USER_ID']);

				if ($arFields['STATUS'] == CBPTaskStatus::Timeout)
				{
					$userStatuses[$userIterator["USER_ID"]] = CBPTaskUserStatus::No;
				}
				else
				{
					$removedUsers[] = $userIterator["USER_ID"];
				}
			}
			if ($arFields['STATUS'] == CBPTaskStatus::Timeout)
			{
				$DB->Query("UPDATE b_bp_task_user SET STATUS = ".CBPTaskUserStatus::No.", DATE_UPDATE = ".$DB->CurrentTimeFunction()
					." WHERE TASK_ID = ".$id." AND STATUS = ".CBPTaskUserStatus::Waiting);
			}
			else
			{
				$DB->Query("DELETE FROM b_bp_task_user WHERE TASK_ID = " . $id . " AND STATUS = " . CBPTaskUserStatus::Waiting);
			}
		}

		foreach (GetModuleEvents("bizproc", "OnTaskUpdate", true) as $arEvent)
		{
			ExecuteModuleEventEx($arEvent, [$id, $arFields]);
		}

		if ($removedUsers)
		{
			$arFields['USERS_REMOVED'] = $removedUsers;
		}
		if ($addedUsers)
		{
			$arFields['USERS_ADDED'] = $addedUsers;
		}
		if ($userStatuses)
		{
			$arFields['USERS_STATUSES'] = $userStatuses;
		}

		$arFields['COUNTERS_INCREMENTED'] = $incremented;
		$arFields['COUNTERS_DECREMENTED'] = $decremented;

		self::onTaskChange($id, $arFields, CBPTaskChangedStatus::Update);

		return $id;
	}

	public static function getList($arOrder = array("ID" => "DESC"), $arFilter = array(), $arGroupBy = false, $arNavStartParams = false, $arSelectFields = array())
	{
		global $DB;

		if (count($arSelectFields) <= 0)
			$arSelectFields = array("ID", "WORKFLOW_ID", "ACTIVITY", "ACTIVITY_NAME", "MODIFIED", "OVERDUE_DATE", "NAME", "DESCRIPTION", "PARAMETERS");

		static $arFields = array(
			"ID" => array("FIELD" => "T.ID", "TYPE" => "int"),
			"WORKFLOW_ID" => array("FIELD" => "T.WORKFLOW_ID", "TYPE" => "string"),
			"ACTIVITY" => array("FIELD" => "T.ACTIVITY", "TYPE" => "string"),
			"ACTIVITY_NAME" => array("FIELD" => "T.ACTIVITY_NAME", "TYPE" => "string"),
			"MODIFIED" => array("FIELD" => "T.MODIFIED", "TYPE" => "datetime"),
			'CREATED_DATE' => ['FIELD' => 'T.CREATED_DATE', 'TYPE' => 'datetime'],
			"OVERDUE_DATE" => array("FIELD" => "T.OVERDUE_DATE", "TYPE" => "datetime"),
			"NAME" => array("FIELD" => "T.NAME", "TYPE" => "string"),
			"DESCRIPTION" => array("FIELD" => "T.DESCRIPTION", "TYPE" => "string"),
			"PARAMETERS" => array("FIELD" => "T.PARAMETERS", "TYPE" => "string"),
			"IS_INLINE" => array("FIELD" => "T.IS_INLINE", "TYPE" => "string"),
			"DELEGATION_TYPE" => array("FIELD" => "T.DELEGATION_TYPE", "TYPE" => "int"),
			"STATUS" => array("FIELD" => "T.STATUS", "TYPE" => "int"),
			'DOCUMENT_NAME' => array("FIELD" => "T.DOCUMENT_NAME", "TYPE" => "string"),
			"USER_ID" => array("FIELD" => "TU.USER_ID", "TYPE" => "int", "FROM" => "INNER JOIN b_bp_task_user TU ON (T.ID = TU.TASK_ID)"),
			"USER_STATUS" => array("FIELD" => "TU.STATUS", "TYPE" => "int", "FROM" => "INNER JOIN b_bp_task_user TU ON (T.ID = TU.TASK_ID)"),
			"WORKFLOW_TEMPLATE_ID" => array("FIELD" => "WS.WORKFLOW_TEMPLATE_ID", "TYPE" => "int", "FROM" => "INNER JOIN b_bp_workflow_state WS ON (T.WORKFLOW_ID = WS.ID)"),
			"MODULE_ID" => array("FIELD" => "WS.MODULE_ID", "TYPE" => "string", "FROM" => "INNER JOIN b_bp_workflow_state WS ON (T.WORKFLOW_ID = WS.ID)"),
			"ENTITY" => array("FIELD" => "WS.ENTITY", "TYPE" => "string", "FROM" => "INNER JOIN b_bp_workflow_state WS ON (T.WORKFLOW_ID = WS.ID)"),
			"DOCUMENT_ID" => array("FIELD" => "WS.DOCUMENT_ID", "TYPE" => "string", "FROM" => "INNER JOIN b_bp_workflow_state WS ON (T.WORKFLOW_ID = WS.ID)"),
			"WORKFLOW_TEMPLATE_NAME" => array("FIELD" => "WT.NAME", "TYPE" => "string",
											"FROM" => array("INNER JOIN b_bp_workflow_state WS ON (T.WORKFLOW_ID = WS.ID)",
											"INNER JOIN b_bp_workflow_template WT ON (WS.WORKFLOW_TEMPLATE_ID = WT.ID)")),
			"WORKFLOW_TEMPLATE_TEMPLATE_ID" => array("FIELD" => "WS.WORKFLOW_TEMPLATE_ID", "TYPE" => "int",
													"FROM" => array("INNER JOIN b_bp_workflow_state WS ON (T.WORKFLOW_ID = WS.ID)")),
			'WORKFLOW_STATE' => array("FIELD" => "WS.STATE_TITLE", "TYPE" => "string", "FROM" => "INNER JOIN b_bp_workflow_state WS ON (T.WORKFLOW_ID = WS.ID)"),
			'WORKFLOW_STARTED' => array("FIELD" => "WS.STARTED", "TYPE" => "datetime", "FROM" => "INNER JOIN b_bp_workflow_state WS ON (T.WORKFLOW_ID = WS.ID)"),
			'WORKFLOW_STARTED_BY' => array("FIELD" => "WS.STARTED_BY", "TYPE" => "int", "FROM" => "INNER JOIN b_bp_workflow_state WS ON (T.WORKFLOW_ID = WS.ID)"),
		);

		$arSqls = CBPHelper::PrepareSql($arFields, $arOrder, $arFilter, $arGroupBy, $arSelectFields);

		$arSqls["SELECT"] = str_replace("%%_DISTINCT_%%", "", $arSqls["SELECT"]);

		if (is_array($arGroupBy) && count($arGroupBy)==0)
		{
			$strSql =
				"SELECT ".$arSqls["SELECT"]." ".
				"FROM b_bp_task T ".
				"	".$arSqls["FROM"]." ";
			if ($arSqls["WHERE"] <> '')
				$strSql .= "WHERE ".$arSqls["WHERE"]." ";
			if ($arSqls["GROUPBY"] <> '')
				$strSql .= "GROUP BY ".$arSqls["GROUPBY"]." ";

			$dbRes = $DB->Query($strSql);
			if ($arRes = $dbRes->Fetch())
				return $arRes["CNT"];
			else
				return False;
		}

		$strSql =
			"SELECT ".$arSqls["SELECT"]." ".
			"FROM b_bp_task T ".
			"	".$arSqls["FROM"]." ";
		if ($arSqls["WHERE"] <> '')
			$strSql .= "WHERE ".$arSqls["WHERE"]." ";
		if ($arSqls["GROUPBY"] <> '')
			$strSql .= "GROUP BY ".$arSqls["GROUPBY"]." ";
		if ($arSqls["ORDERBY"] <> '')
			$strSql .= "ORDER BY ".$arSqls["ORDERBY"]." ";

		if (is_array($arNavStartParams) && empty($arNavStartParams["nTopCount"]))
		{
			$strSql_tmp =
				"SELECT COUNT('x') as CNT ".
				"FROM b_bp_task T ".
				"	".$arSqls["FROM"]." ";
			if ($arSqls["WHERE"] <> '')
				$strSql_tmp .= "WHERE ".$arSqls["WHERE"]." ";
			if ($arSqls["GROUPBY"] <> '')
				$strSql_tmp .= "GROUP BY ".$arSqls["GROUPBY"]." ";

			$dbRes = $DB->Query($strSql_tmp);
			$cnt = 0;
			if ($arSqls["GROUPBY"] == '')
			{
				if ($arRes = $dbRes->Fetch())
					$cnt = $arRes["CNT"];
			}
			else
			{
				$cnt = $dbRes->SelectedRowsCount();
			}

			$dbRes = new CDBResult();
			$dbRes->NavQuery($strSql, $cnt, $arNavStartParams);
		}
		else
		{
			if (is_array($arNavStartParams) && intval($arNavStartParams["nTopCount"]) > 0)
				$strSql .= "LIMIT ".intval($arNavStartParams["nTopCount"]);
			$dbRes = $DB->Query($strSql);
		}

		$dbRes = new CBPTaskResult($dbRes);
		return $dbRes;
	}

	public static function isLastTaskForUserByActivity(string $activityName, int $userId, int $templateId): bool
	{
		$previousTasks = static::getPreviousTasks($activityName, $userId, $templateId);
		$neededTask = static::getNeededTaskByActivityName($activityName, $previousTasks);

		foreach ($previousTasks as $task)
		{
			if (is_null($task['CREATED_DATE']) || is_null($neededTask['MODIFIED']))
			{
				continue;
			}

			$completedCreatedDiff = $task['CREATED_DATE']->getTimestamp() - $neededTask['MODIFIED']->getTimestamp();
			if ($completedCreatedDiff <= 2 && $completedCreatedDiff >= 0 && $task !== $neededTask)
			{
				return false;
			}
		}

		return true;
	}

	private static function getPreviousTasks(string $activityName, int $userId, int $templateId): array
	{
		$previousWorkflowIdSubquery =
			Bizproc\Workflow\Task\TaskTable::query()
				->setSelect(['WORKFLOW_ID'])
				->setFilter([
					'=ACTIVITY_NAME' => $activityName,
					'=TASK_USERS.USER_ID' => $userId,
					'=WORKFLOW_STATE.WORKFLOW_TEMPLATE_ID' => $templateId,
				])
				->whereNull('WORKFLOW_INSTANCE.ID')
				->setOrder(['ID' => 'DESC'])
				->setLimit(1)
				->getQuery()
		;

		$tasksQuery =
			Bizproc\Workflow\Task\TaskTable::query()
				->setSelect(['ID', 'CREATED_DATE', 'MODIFIED', 'ACTIVITY_NAME'])
				->setFilter([
					'=TASK_USERS.USER_ID' => $userId,
					'!=TASK_USERS.STATUS' => CBPTaskUserStatus::Waiting,
					'=WORKFLOW_ID' => new Main\DB\SqlExpression("($previousWorkflowIdSubquery)"),
				])
				->setOrder(['MODIFIED' => 'ASC'])
		;

		return $tasksQuery->fetchAll();
	}

	private static function getNeededTaskByActivityName(string $activityName, array $previousTasks): ?array
	{
		foreach ($previousTasks as $task)
		{
			if ($task["ACTIVITY_NAME"] === $activityName)
			{
				return static::getLastCompletedParallelTask($task, $previousTasks);
			}
		}

		return null;
	}

	private static function getLastCompletedParallelTask(array $neededTask, array $previousTasks): array
	{
		foreach ($previousTasks as $task)
		{
			if (
				(!is_null($task['CREATED_DATE']) && !is_null($neededTask['CREATED_DATE']))
				&& $task['CREATED_DATE']->getTimestamp() - $neededTask['CREATED_DATE']->getTimestamp() <= 2
				&& $task['MODIFIED'] > $neededTask['MODIFIED']
			)
			{
				$neededTask = $task;
			}
		}

		return $neededTask;
	}

	private static function setSearchContent($status, $taskId, $taskData): void
	{
		try
		{
			switch ($status)
			{
				case CBPTaskChangedStatus::Add:
					Bizproc\Workflow\Task\TaskSearchContentTable::add([
						'TASK_ID' => $taskId,
						'WORKFLOW_ID' => $taskData['WORKFLOW_ID'],
						'SEARCH_CONTENT' => $taskData['NAME'] . ' ' . ($taskData['DESCRIPTION'] ?? ''),
					]);
					break;
				case CBPTaskChangedStatus::Update:
					if (!empty($taskData['NAME']) && !empty($taskData['DESCRIPTION']))
					{
						Bizproc\Workflow\Task\TaskSearchContentTable::update(
							$taskId,
							[
								'SEARCH_CONTENT' => $taskData['NAME'] . ' ' . $taskData['DESCRIPTION'],
							]
						);
					}
					break;
				case CBPTaskChangedStatus::Delete:
					Bizproc\Workflow\Task\TaskSearchContentTable::delete($taskId);
					break;
			}
		}
		catch (Main\DB\SqlQueryException $e)
		{
			//skip operation, empty search content
		}
	}

	private static function incrementUserTaskCounter(int $userId): void
	{
		$userCounters = new Bizproc\Workflow\WorkflowUserCounters($userId);
		$userCounters->incrementTask();
	}

	private static function decrementUserTaskCounter(int $userId): void
	{
		$userCounters = new Bizproc\Workflow\WorkflowUserCounters($userId);
		$userCounters->decrementTask();
	}
}

class CBPTaskResult extends CDBResult
{
	private static $classesList = [
		Bizproc\BaseType\Value\Date::class,
		Bizproc\BaseType\Value\DateTime::class,
		Main\Type\Date::class,
		Main\Type\DateTime::class,
		\DateTime::class,
		\DateTimeZone::class,
		Main\Web\Uri::class,
	];

	function fetch()
	{
		$res = parent::Fetch();

		if ($res)
		{
			if (!empty($res["PARAMETERS"]))
			{
				$res["PARAMETERS"] = unserialize($res["PARAMETERS"], ['allowed_classes' => self::$classesList]);
			}
		}

		return $res;
	}

	function getNext($bTextHtmlAuto=true, $use_tilda=true)
	{
		$res = parent::GetNext($bTextHtmlAuto, $use_tilda);

		if ($res)
		{
			if (!empty($res["DESCRIPTION"]))
			{
				$res["DESCRIPTION"] = CBPHelper::convertBBtoText($res["DESCRIPTION"]);
			}
		}

		return $res;
	}

	/**
	 * @deprecated
	 * @param $text
	 * @return array|string|string[]|null
	 */
	function convertBBCode($text)
	{
		$text = preg_replace(
			"'(?<=^|[\s.,;:!?\#\-\*\|\[\(\)\{\}]|\s)((http|https|news|ftp|aim|mailto)://[\.\-\_\:a-z0-9\@]([^\"\s\'\[\]\{\}])*)'is",
			"[url]\\1[/url]",
			$text
		);

		$text = preg_replace_callback("#\[img\](.+?)\[/img\]#i", array($this, "ConvertBCodeImageTag"), $text);

		$text = preg_replace_callback(
			"/\[url\]([^\]]+?)\[\/url\]/iu",
			array($this, "ConvertBCodeAnchorTag"),
			$text
		);
		$text = preg_replace_callback(
			"/\[url\s*=\s*([^\]]+?)\s*\](.*?)\[\/url\]/iu",
			array($this, "ConvertBCodeAnchorTag"),
			$text
		);

		$text = preg_replace(
			array(
				"/\[b\](.+?)\[\/b\]/isu",
				"/\[i\](.+?)\[\/i\]/isu",
				"/\[s\](.+?)\[\/s\]/isu",
				"/\[u\](.+?)\[\/u\]/isu",
			),
			array(
				"<b>\\1</b>",
				"<i>\\1</i>",
				"<s>\\1</s>",
				"<u>\\1</u>",
			),
			$text
		);

		return $text;
	}

	/**
	 * @deprecated
	 * @param string $url
	 * @return string
	 */
	function convertBCodeImageTag($url = "")
	{
		if (is_array($url))
			$url = $url[1];
		$url = trim($url);
		if ($url == '')
			return "";

		$extension = preg_replace("/^.*\.(\S+)$/u", "\\1", $url);
		$extension = mb_strtolower($extension);
		$extension = preg_quote($extension, "/");

		$bErrorIMG = False;

		if (preg_match("/[?&;]/u", $url))
			$bErrorIMG = True;
		if (!$bErrorIMG && !preg_match("/$extension(\||\$)/u", "gif|jpg|jpeg|png"))
			$bErrorIMG = True;
		if (!$bErrorIMG && !preg_match("/^((http|https|ftp)\:\/\/[-_:.a-z0-9@]+)*(\/[-_+\/=:.a-z0-9@%]+)$/iu", $url))
			$bErrorIMG = True;

		if ($bErrorIMG)
			return "[img]".$url."[/img]";

		return '<img src="'.$url.'" border="0" />';
	}

	/**
	 * @deprecated
	 * @param $url
	 * @param string $text
	 * @return string
	 */
	function convertBCodeAnchorTag($url, $text = '')
	{
		if (is_array($url))
		{
			$text = isset($url[2]) ? $url[2] : $url[1];
			$url = $url[1];
		}

		$result = "";

		if ($url === $text)
		{
			$arUrl = explode(", ", $url);
			$arText = $arUrl;
		}
		else
		{
			$arUrl = array($url);
			$arText = array($text);
		}

		for ($i = 0, $n = count($arUrl); $i < $n; $i++)
		{
			$url = $arUrl[$i];
			$text = $arText[$i];

			$text = str_replace("\\\"", "\"", $text);
			$end = "";

			if (preg_match("/([\.,\?]|&#33;)$/u", $url, $match))
			{
				$end = $match[1];
				$url = preg_replace("/([\.,\?]|&#33;)$/u", "", $url);
				$text = preg_replace("/([\.,\?]|&#33;)$/u", "", $text);
			}

			$url = preg_replace(
				array("/&amp;/u", "/javascript:/iu"),
				array("&", "java script&#58; "),
				$url
			);
			if (mb_substr($url, 0, 1) != "/" && !preg_match("/^(http|news|https|ftp|aim|mailto)\:\/\//iu", $url))
				$url = 'http://'.$url;
			if (!preg_match("/^((http|https|news|ftp|aim):\/\/[-_:.a-z0-9@]+)*([^\"\'])+$/iu", $url))
				return $text." (".$url.")".$end;

			$text = preg_replace(
				array("/&amp;/iu", "/javascript:/iu"),
				array("&", "javascript&#58; "),
				$text
			);

			if ($result !== "")
				$result .= ", ";

			$result .= "<a href=\"".$url."\" target='_blank'>".$text."</a>".$end;
		}

		return $result;
	}

}