<?php

IncludeModuleLangFile(__FILE__);

class CWorkflowStatus
{
	//Despite this function is not documented it should be version compatible
	public static function GetList($by = 's_c_sort', $order = 'asc', $arFilter = [], $is_filtered = null, $arSelect = [])
	{
		global $DB;

		$obQueryWhere = new CSQLWhere();
		static $arWhereFields = [
			'ID' => [
				'TABLE_ALIAS' => 'S',
				'FIELD_NAME' => 'S.ID',
				'FIELD_TYPE' => 'int', //int, double, file, enum, int, string, date, datetime
				'JOIN' => false,
			],
		];
		$obQueryWhere->SetFields($arWhereFields);

		if (!is_array($arSelect) || !$arSelect)
		{
			$arSelect = ['ID', 'C_SORT', 'ACTIVE', 'TITLE', 'DESCRIPTION', 'IS_FINAL', 'TIMESTAMP_X', 'DOCUMENTS', 'NOTIFY'];
		}

		if ($by === 's_id')
		{
			$strSqlOrder = 'ORDER BY S.ID';
			$arSelect[] = 'ID';
		}
		elseif ($by === 's_timestamp')
		{
			$strSqlOrder = 'ORDER BY S.TIMESTAMP_X';
			$arSelect[] = 'TIMESTAMP_X';
		}
		elseif ($by === 's_active')
		{
			$strSqlOrder = 'ORDER BY S.ACTIVE';
			$arSelect[] = 'ACTIVE';
		}
		elseif ($by === 's_c_sort')
		{
			$strSqlOrder = 'ORDER BY S.C_SORT';
			$arSelect[] = 'C_SORT';
		}
		elseif ($by === 's_title')
		{
			$strSqlOrder = 'ORDER BY S.TITLE ';
			$arSelect[] = 'TITLE';
		}
		elseif ($by === 's_description')
		{
			$strSqlOrder = 'ORDER BY S.DESCRIPTION';
			$arSelect[] = 'DESCRIPTION';
		}
		elseif ($by === 's_documents')
		{
			$strSqlOrder = 'ORDER BY DOCUMENTS';
			$arSelect[] = 'DOCUMENTS';
		}
		else
		{
			$strSqlOrder = 'ORDER BY S.C_SORT';
			$arSelect[] = 'C_SORT';
		}

		if ($order != 'desc')
		{
			$order = 'asc';
		}

		$strSqlOrder .= ' ' . $order . ' ';

		$arSelectFields = [
			'ID' => 'S.ID',
			'C_SORT' => 'S.C_SORT',
			'ACTIVE' => 'S.ACTIVE',
			'NOTIFY' => 'S.NOTIFY',
			'TITLE' => 'S.TITLE',
			'DESCRIPTION' => 'S.DESCRIPTION',
			'IS_FINAL' => 'S.IS_FINAL',
			'TIMESTAMP_X' => 'S.TIMESTAMP_X TIMESTAMP_X_TEMP, ' . $DB->DateToCharFunction('S.TIMESTAMP_X'),
			'DOCUMENTS' => 'count(DISTINCT D.ID)',
			'REFERENCE_ID' => 'S.ID',
			'REFERENCE' => $DB->Concat("'['", 'S.ID' , "'] '", 'S.TITLE'),
		];
		$arSqlSelect = [];
		foreach ($arSelect as $field)
		{
			if (array_key_exists($field, $arSelectFields))
			{
				$arSqlSelect[$field] = $arSelectFields[$field] . ' as ' . $field;
			}
		}

		$bGroup = false;
		$arGroupFields = [
			'ID' => 'S.ID',
			'C_SORT' => 'S.C_SORT',
			'ACTIVE' => 'S.ACTIVE',
			'NOTIFY' => 'S.NOTIFY',
			'TITLE' => 'S.TITLE',
			'DESCRIPTION' => 'S.DESCRIPTION',
			'IS_FINAL' => 'S.IS_FINAL',
			'TIMESTAMP_X' => 'S.TIMESTAMP_X',
			'REFERENCE_ID' => 'S.ID',
			'REFERENCE' => $DB->Concat("'['", 'S.ID' , "'] '", 'S.TITLE'),
		];
		$arSqlGroup = [];
		foreach ($arSelect as $field)
		{
			if (array_key_exists($field, $arGroupFields))
			{
				$arSqlGroup[$field] = $arGroupFields[$field];
			}
			elseif (array_key_exists($field, $arSelectFields))
			{
				$arSqlGroup['ID'] = 'S.ID';
				$bGroup = true;
			}
		}

		$arSqlSearch = $arSqlSearch_h = $arSqlSearch_g = [];

		if (is_array($arFilter))
		{
			foreach ($arFilter as $key => $val)
			{
				if (is_array($val))
				{
					if (!$val)
					{
						continue;
					}
				}
				else
				{
					if ((string)$val === '' || (string)$val === 'NOT_REF')
					{
						continue;
					}
				}

				$match_value_set = array_key_exists($key . '_EXACT_MATCH', $arFilter);
				$key = strtoupper($key);
				$predicate = '';
				switch ($key)
				{
					case 'ID':
						$arSqlSearch[] = $obQueryWhere->GetQuery([$key => $val]);

						break;
					case 'ACTIVE':
						$predicate = ($val == 'Y') ? "S.ACTIVE='Y'" : "S.ACTIVE='N'";

						break;
					case '!=ACTIVE':
						if ($val === 'Y' || $val === 'N')
						{
							$arSqlSearch[] = "S.ACTIVE <> '" . $val . "'";
						}

						break;
					case 'TITLE':
						$match = ($match_value_set && $arFilter[$key . '_EXACT_MATCH'] == 'Y') ? 'N' : 'Y';
						$predicate = GetFilterQuery('S.TITLE', $val, $match);

						break;
					case 'DESCRIPTION':
						$match = ($match_value_set && $arFilter[$key . '_EXACT_MATCH'] == 'Y') ? 'N' : 'Y';
						$predicate = GetFilterQuery('S.DESCRIPTION', $val, $match);

						break;
					case 'DOCUMENTS_1':
						$arSqlSearch_h[] = 'count(D.ID) >= ' . intval($val);
						$bGroup = true;

						break;
					case 'DOCUMENTS_2':
						$arSqlSearch_h[] = 'count(D.ID) <= ' . intval($val);
						$bGroup = true;

						break;
					case 'GROUP_ID':
						if (!is_array($val))
						{
							$val = [$val];
						}
						$groups = [];
						foreach ($val as $i => $v)
						{
							$v = intval($v);
							if ($v > 0)
							{
								$groups[$v] = $v;
							}
						}
						if (count($groups) > 0)
						{
							$arSqlSearch_g[] = 'G.GROUP_ID in (' . implode(', ', $groups) . ')';
							$bGroup = true;
						}

						break;
					case 'PERMISSION_TYPE_1':
						$val = intval($val);
						if ($val > 0)
						{
							$arSqlSearch_g[] = 'G.PERMISSION_TYPE >= ' . $val;
							$bGroup = true;
						}

						break;
					case 'PERMISSION_TYPE_2':
						$val = intval($val);
						if ($val > 0)
						{
							$arSqlSearch_g[] = 'G.PERMISSION_TYPE <= ' . $val;
							$bGroup = true;
						}

						break;
				}
				if ($predicate <> '' && $predicate != '0')
				{
					$arSqlSearch[] = $predicate;
				}
			}
		}

		if (count($arSqlSearch) > 0)
		{
			$strSqlSearch = GetFilterSqlSearch($arSqlSearch);
		}
		else
		{
			$strSqlSearch = '';
		}

		if (count($arSqlSearch_h) > 0)
		{
			$strSqlSearch_h = '(' . implode(') and (', $arSqlSearch_h) . ') ';
		}
		else
		{
			$strSqlSearch_h = '';
		}

		if (count($arSqlSearch_g) > 0)
		{
			if ($strSqlSearch <> '')
			{
				$strSqlSearch .= ' AND ';
			}
			$strSqlSearch .= '(' . implode(') and (', $arSqlSearch_g) . ') ';
		}

		$strSql = '
			SELECT
				' . implode(', ', $arSqlSelect) . '
			FROM
				b_workflow_status S
			' . ($strSqlSearch_h <> '' || array_key_exists('DOCUMENTS', $arSqlSelect) ? 'LEFT JOIN b_workflow_document D ON (D.STATUS_ID = S.ID)' : '') . '
			' . (count($arSqlSearch_g) > 0 ? 'LEFT JOIN b_workflow_status2group G ON (G.STATUS_ID = S.ID)' : '') . '
			' . ($strSqlSearch <> '' ? 'WHERE ' . $strSqlSearch : '') . '
			' . ($bGroup ? 'GROUP BY ' . implode(', ', $arSqlGroup) : '') . '
			' . ($strSqlSearch_h <> '' ? 'HAVING ' . $strSqlSearch_h : '') . '
			' . $strSqlOrder . '
			';

		$res = $DB->Query($strSql);

		return $res;
	}

	public static function GetByID($ID)
	{
		return self::GetList('', '', ['ID' => $ID, 'ID_EXACT_MATCH' => 'Y']);
	}

	public static function GetDropDownList($SHOW_ALL='N', $strOrder = 'desc', $arFilter = [])
	{
		global $USER;

		if (strtolower($strOrder) != 'asc')
		{
			$strOrder = 'desc';
		}
		else
		{
			$strOrder = 'asc';
		}

		$arFilter['!=ACTIVE'] = 'N';
		if (!(CWorkflow::IsAdmin() || $SHOW_ALL == 'Y'))
		{
			$arGroups = $USER->GetUserGroupArray();
			if (!is_array($arGroups))
			{
				$arGroups = [2];
			}
			$arFilter['GROUP_ID'] = $arGroups;
			$arFilter['PERMISSION_TYPE_1'] = 1;
		}

		return self::GetList('s_c_sort', $strOrder, $arFilter, null, ['REFERENCE_ID', 'REFERENCE', 'IS_FINAL', 'C_SORT']);
	}

	public static function GetNextSort()
	{
		global $DB;

		$strSql = 'SELECT max(C_SORT) MAX_SORT FROM b_workflow_status';
		$z = $DB->Query($strSql);
		$zr = $z->Fetch();

		return intval($zr['MAX_SORT']) + 100;
	}

	//check fields before writing
	public function CheckFields($ID, $arFields)
	{
		$aMsg = [];

		$ID = intval($ID);

		if (
			(
				!$ID
				&& (
					!array_key_exists('TITLE', $arFields)
					|| trim($arFields['TITLE']) == ''
				)
			)
			|| (
				$ID
				&& array_key_exists('TITLE', $arFields)
				&& trim($arFields['TITLE']) == ''
			)
		)
		{
			$aMsg[] = ['id' => 'TITLE', 'text' => GetMessage('FLOW_FORGOT_TITLE')];
		}

		if (!empty($aMsg))
		{
			$e = new CAdminException($aMsg);
			$GLOBALS['APPLICATION']->ThrowException($e);

			return false;
		}

		return true;
	}

	//add
	public function Add($arFields)
	{
		global $DB;

		if (!$this->CheckFields(0, $arFields))
		{
			return false;
		}

		$ID = $DB->Add('b_workflow_status', $arFields);

		if (($ID == 1) && ($arFields['ACTIVE'] != 'Y'))
		{
			$this->Update($ID, ['ACTIVE' => 'Y']);
		}

		return $ID;
	}

	//update
	public function Update($ID, $arFields)
	{
		global $DB;
		$ID = intval($ID);

		if (($ID == 1) && array_key_exists('ACTIVE', $arFields))
		{
			$arFields['ACTIVE'] = 'Y';
		}

		if (!$this->CheckFields($ID, $arFields))
		{
			return false;
		}

		$strUpdate = $DB->PrepareUpdate('b_workflow_status', $arFields);
		if ($strUpdate != '')
		{
			$strSql = 'UPDATE b_workflow_status SET ' . $strUpdate . ' WHERE ID = ' . $ID;
			$DB->Query($strSql);
		}

		return true;
	}

	public function SetPermissions($STATUS_ID, $arGroups, $PERMISSION_TYPE = 1)
	{
		global $DB;

		$STATUS_ID = intval($STATUS_ID);
		$PERMISSION_TYPE = intval($PERMISSION_TYPE);

		$DB->Query('DELETE FROM b_workflow_status2group WHERE STATUS_ID = ' . $STATUS_ID . ' AND PERMISSION_TYPE = ' . $PERMISSION_TYPE);
		if (is_array($arGroups) && ($PERMISSION_TYPE == 1 || $PERMISSION_TYPE == 2))
		{
			foreach ($arGroups as $GROUP_ID)
			{
				$GROUP_ID = intval($GROUP_ID);
				$arFields = [
					'STATUS_ID' => $STATUS_ID,
					'GROUP_ID' => $GROUP_ID,
					'PERMISSION_TYPE' => $PERMISSION_TYPE,
				];
				$DB->Insert('b_workflow_status2group', $arFields);
			}
		}
	}
}