<?php
IncludeModuleLangFile(__FILE__);

class CClusterGroup
{
	public function Add($arFields)
	{
		global $DB;

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

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

		return $ID;
	}

	public function Delete($ID)
	{
		global $DB, $APPLICATION;
		$aMsg = [];
		$ID = intval($ID);

		$rsWebNodes = CClusterWebNode::GetList([], ['=GROUP_ID' => $ID]);
		if ($rsWebNodes->Fetch())
		{
			$aMsg[] = ['text' => GetMessage('CLU_GROUP_HAS_WEBNODE')];
		}

		$rsDBNodes = CClusterDBNode::GetList([] ,['=GROUP_ID' => $ID]);
		if ($rsDBNodes->Fetch())
		{
			$aMsg[] = ['text' => GetMessage('CLU_GROUP_HAS_DBNODE')];
		}

		$cacheType = COption::GetOptionString('cluster', 'cache_type', 'memcache');
		if ($cacheType == 'memcache')
		{
			$cacheServers = CClusterMemcache::GetList();
		}
		else
		{
			$cacheServers = CClusterRedis::GetList();
		}

		while ($server = $cacheServers->Fetch())
		{
			if ($server['GROUP_ID'] == $ID)
			{
				$aMsg[] = ['text' => GetMessage('CLU_GROUP_HAS_CACHESERVER')];
				break;
			}
		}

		if (empty($aMsg))
		{
			$res = $DB->Query('DELETE FROM b_cluster_group WHERE ID = ' . $ID, false, '', ['fixed_connection' => true]);
		}
		else
		{
			$e = new CAdminException($aMsg);
			$APPLICATION->ThrowException($e);
			return false;
		}
		return $res;
	}

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

		if ($ID <= 0)
		{
			return false;
		}

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

		$strUpdate = $DB->PrepareUpdate('b_cluster_group', $arFields);
		if ($strUpdate <> '')
		{
			$strSql = '
				UPDATE b_cluster_group SET
				' . $strUpdate . '
				WHERE ID = ' . $ID . '
			';
			if (!$DB->Query($strSql, false, '', ['fixed_connection' => true]))
			{
				return false;
			}
		}

		return true;
	}

	public function CheckFields(&$arFields, $ID)
	{
		global $APPLICATION;
		$aMsg = [];

		unset($arFields['ID']);

		$arFields['NAME'] = trim($arFields['NAME']);
		if ($arFields['NAME'] === '')
		{
			$aMsg[] = ['id' => 'NAME', 'text' => GetMessage('CLU_GROUP_EMPTY_NAME')];
		}

		if (!empty($aMsg))
		{
			$e = new CAdminException($aMsg);
			$APPLICATION->ThrowException($e);
			return false;
		}
		return true;
	}

	public static function GetList($arOrder=false, $arFilter=false, $arSelect=false)
	{
		global $DB;

		if (!is_array($arSelect))
		{
			$arSelect = [];
		}
		if (count($arSelect) < 1)
		{
			$arSelect = [
				'ID',
				'NAME',
			];
		}

		if (!is_array($arOrder))
		{
			$arOrder = [];
		}

		$arQueryOrder = [];
		foreach ($arOrder as $strColumn => $strDirection)
		{
			$strColumn = mb_strtoupper($strColumn);
			$strDirection = mb_strtoupper($strDirection) === 'ASC' ? 'ASC' : 'DESC';
			switch ($strColumn)
			{
				case 'ID':
				case 'NAME':
					$arSelect[] = $strColumn;
					$arQueryOrder[$strColumn] = $strColumn . ' ' . $strDirection;
					break;
			}
		}

		$arQuerySelect = [];
		foreach ($arSelect as $strColumn)
		{
			$strColumn = mb_strtoupper($strColumn);
			switch ($strColumn)
			{
				case 'ID':
				case 'NAME':
					$arQuerySelect[$strColumn] = 'g.' . $strColumn;
					break;
			}
		}
		if (count($arQuerySelect) < 1)
		{
			$arQuerySelect = ['ID' => 'w.ID'];
		}

		$obQueryWhere = new CSQLWhere;
		$arFields = [
			'ID' => [
				'TABLE_ALIAS' => 'g',
				'FIELD_NAME' => 'g.ID',
				'FIELD_TYPE' => 'int',
				'JOIN' => false,
			],
		];
		$obQueryWhere->SetFields($arFields);

		if (!is_array($arFilter))
		{
			$arFilter = [];
		}
		$strQueryWhere = $obQueryWhere->GetQuery($arFilter);

		$bDistinct = $obQueryWhere->bDistinctReqired;

		$strSql = '
			SELECT ' . ($bDistinct ? 'DISTINCT' : '') . '
			' . implode(', ', $arQuerySelect) . '
			FROM
				b_cluster_group g
			' . $obQueryWhere->GetJoins() . '
		';

		if ($strQueryWhere)
		{
			$strSql .= '
				WHERE
				' . $strQueryWhere . '
			';
		}

		if (count($arQueryOrder) > 0)
		{
			$strSql .= '
				ORDER BY
				' . implode(', ', $arQueryOrder) . '
			';
		}

		return $DB->Query($strSql, false, '', ['fixed_connection' => true]);
	}

	public static function GetArrayByID($ID)
	{
		$rs = CClusterGroup::GetList([], ['=ID' => $ID]);
		return $rs->Fetch();
	}
}