<?php

class CSearchStatistic
{
	var $phrase_id = 0;

	var $_phrase = false;
	var $_tags = false;
	var $_session_id = '';
	var $_stat_sess_id = false;

	function __construct($phrase = '', $tags = '')
	{
		$phrase = mb_strtolower(trim($phrase, " \t\n\r"));
		if ($l = mb_strlen($phrase))
		{
			if ($l > 250)
			{
				$p = mb_strrpos($phrase, ' ');
				if ($p === false)
				{
					$this->_phrase = mb_substr($phrase, 0, 250);
				}
				else
				{
					$this->_phrase = mb_substr($phrase, 0, $p);
				}
			}
			else
			{
				$this->_phrase = $phrase;
			}
		}
		else
		{
			$this->_phrase = false;
		}

		$arTags = tags_prepare($tags);
		if (count($arTags))
		{
			asort($arTags);
			$this->_tags = implode(', ', $arTags);
		}
		else
		{
			$this->_tags = false;
		}

		$this->_session_id = bitrix_sessid();

		if (isset($_SESSION['SESS_SESSION_ID']))
		{
			$this->_stat_sess_id = intval($_SESSION['SESS_SESSION_ID']);
		}
	}

	function PhraseStat($result_count = 0, $page_num = 0)
	{
		$DB = CDatabase::GetModuleConnection('search');
		$DB->StartUsingMasterOnly();

		$result_count = intval($result_count);
		$page_num = intval($page_num);

		$strSql = "
			SELECT *
			FROM b_search_phrase
			WHERE SESSION_ID = '" . $DB->ForSQL($this->_session_id) . "'
			AND " . ($this->_phrase === false ? 'PHRASE IS NULL' : "PHRASE = '" . $DB->ForSQL($this->_phrase) . "'") . '
			AND ' . ($this->_tags === false ? 'TAGS IS NULL' : "TAGS = '" . $DB->ForSQL($this->_tags) . "'") . '
		';
		$rs = $DB->Query($strSql);
		if ($ar = $rs->Fetch())
		{
			$this->phrase_id = $ar['ID'];
			if ($page_num > $ar['PAGES'])
			{
				$DB->Query('UPDATE b_search_phrase SET PAGES = ' . $page_num . ' WHERE ID = ' . $ar['ID']);
			}
		}
		else
		{
			$this->phrase_id = $DB->Add('b_search_phrase',
				[
					'~TIMESTAMP_X' => $DB->CurrentTimeFunction(),
					'SITE_ID' => SITE_ID,
					'~RESULT_COUNT' => $result_count,
					'~PAGES' => $page_num,
					'SESSION_ID' => $this->_session_id,
					'PHRASE' => $this->_phrase,
					'TAGS' => $this->_tags,
					'STAT_SESS_ID' => $this->_stat_sess_id,
				]
			);
		}
		$DB->StopUsingMasterOnly();
	}

	public static function GetList($arOrder = false, $arFilter = false, $arSelect = false, $bGroup = false)
	{
		$DB = CDatabase::GetModuleConnection('search');

		static $arDefSelect = [
			'ID',
			'TIMESTAMP_X',
			'SITE_ID',
			'RESULT_COUNT',
			'PAGES',
			'PHRASE',
			'TAGS',
			'URL_TO',
			'URL_TO_404',
			'URL_TO_SITE_ID',
			'STAT_SESS_ID',
		];

		if (!is_array($arSelect))
		{
			$arSelect = [];
		}
		if (count($arSelect) < 1)
		{
			$arSelect = $arDefSelect;
		}

		if (!is_array($arOrder))
		{
			$arOrder = [];
		}
		if (count($arOrder) < 1)
		{
			$arOrder = [
				'ID' => 'DESC',
			];
		}

		$arQueryOrder = [];
		foreach ($arOrder as $strColumn => $strDirection)
		{
			$strColumn = mb_strtoupper($strColumn);
			$strDirection = mb_strtoupper($strDirection) == 'ASC' ? 'ASC' : 'DESC';
			if (in_array($strColumn, $arDefSelect))
			{
				$arSelect[] = $strColumn;
				if ($strColumn == 'TIMESTAMP_X')
				{
					$arQueryOrder[$strColumn] = 'TMP_TS ' . $strDirection;
				}
				else
				{
					$arQueryOrder[$strColumn] = $strColumn . ' ' . $strDirection;
				}
			}
			elseif ($strColumn == 'COUNT' && $bGroup)
			{
				$arSelect[] = $strColumn;
				$arQueryOrder[$strColumn] = $strColumn . ' ' . $strDirection;
			}
		}

		$arQueryGroup = [];
		$arQuerySelect = [];
		foreach ($arSelect as $strColumn)
		{
			$strColumn = mb_strtoupper($strColumn);
			if (in_array($strColumn, $arDefSelect))
			{
				if ($strColumn == 'TIMESTAMP_X')
				{
					$arQuerySelect['TMP_TS'] = 'sph.' . $strColumn . ' TMP_TS';
					$arQuerySelect[$strColumn] = $DB->DateToCharFunction('sph.' . $strColumn, 'FULL') . ' ' . $strColumn;
				}
				else
				{
					$arQuerySelect[$strColumn] = 'sph.' . $strColumn;
				}

				if ($bGroup)
				{
					$arQueryGroup[$strColumn] = 'sph.' . $strColumn;
				}
			}
			elseif ($strColumn == 'COUNT' && $bGroup)
			{
				$arQuerySelect[$strColumn] = 'count(*) ' . $strColumn;
			}
		}

		$obQueryWhere = new CSQLWhere;
		$obQueryWhere->SetFields([
			'ID' => [
				'TABLE_ALIAS' => 'sph',
				'FIELD_NAME' => 'sph.ID',
				'FIELD_TYPE' => 'int', //int, double, file, enum, int, string, date, datetime
				'JOIN' => false,
			],
			'PHRASE' => [
				'TABLE_ALIAS' => 'sph',
				'FIELD_NAME' => 'sph.PHRASE',
				'FIELD_TYPE' => 'string',
				'JOIN' => false,
			],
			'TAGS' => [
				'TABLE_ALIAS' => 'sph',
				'FIELD_NAME' => 'sph.TAGS',
				'FIELD_TYPE' => 'string',
				'JOIN' => false,
			],
			'TIMESTAMP_X' => [
				'TABLE_ALIAS' => 'sph',
				'FIELD_NAME' => 'sph.TIMESTAMP_X',
				'FIELD_TYPE' => 'datetime',
				'JOIN' => false,
			],
			'SITE_ID' => [
				'TABLE_ALIAS' => 'sph',
				'FIELD_NAME' => 'sph.SITE_ID',
				'FIELD_TYPE' => 'string',
				'JOIN' => false,
			],
			'URL_TO' => [
				'TABLE_ALIAS' => 'sph',
				'FIELD_NAME' => 'sph.URL_TO',
				'FIELD_TYPE' => 'string',
				'JOIN' => false,
			],
			'URL_TO_404' => [
				'TABLE_ALIAS' => 'sph',
				'FIELD_NAME' => 'sph.URL_TO_404',
				'FIELD_TYPE' => 'string',
				'JOIN' => false,
			],
			'STAT_SESS_ID' => [
				'TABLE_ALIAS' => 'sph',
				'FIELD_NAME' => 'sph.STAT_SESS_ID',
				'FIELD_TYPE' => 'int',
				'JOIN' => false,
			],
			'RESULT_COUNT' => [
				'TABLE_ALIAS' => 'sph',
				'FIELD_NAME' => 'sph.RESULT_COUNT',
				'FIELD_TYPE' => 'int',
				'JOIN' => false,
			],
		]);

		if (count($arQuerySelect) < 1)
		{
			$arQuerySelect = ['ID' => 'sph.ID'];
		}

		$strSql = '
			SELECT
			' . implode(', ', $arQuerySelect) . '
			FROM
				b_search_phrase sph
		';

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

		if ($bGroup && count($arQueryGroup) > 0)
		{
			$strSql .= '
				GROUP BY
				' . implode(', ', $arQueryGroup) . '
			';
		}

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

		return $DB->Query($strSql);
	}

	public static function CleanUpAgent()
	{
		$DB = CDatabase::GetModuleConnection('search');
		$cleanup_days = COption::GetOptionInt('search', 'stat_phrase_save_days');
		if ($cleanup_days > 0)
		{
			$arDate = localtime(time());
			$date = mktime(0, 0, 0, $arDate[4] + 1, $arDate[3] - $cleanup_days, 1900 + $arDate[5]);
			$DB->Query('DELETE FROM b_search_phrase WHERE TIMESTAMP_X <= ' . $DB->CharToDateFunction(ConvertTimeStamp($date, 'FULL')));
		}
		return 'CSearchStatistic::CleanUpAgent();';
	}

	public static function IsActive()
	{
		$bActive = false;
		foreach (GetModuleEvents('main', 'OnEpilog', true) as $arEvent)
		{
			if (
				$arEvent['TO_MODULE_ID'] == 'search'
				&& $arEvent['TO_CLASS'] == 'CSearchStatistic'
			)
			{
				$bActive = true;
				break;
			}
		}
		return $bActive;
	}

	public static function SetActive($bActive = false)
	{
		if ($bActive)
		{
			if (!CSearchStatistic::IsActive())
			{
				RegisterModuleDependences('main', 'OnEpilog', 'search', 'CSearchStatistic', 'OnEpilog', '90');
			}
		}
		else
		{
			if (CSearchStatistic::IsActive())
			{
				UnRegisterModuleDependences('main', 'OnEpilog', 'search', 'CSearchStatistic', 'OnEpilog');
			}
		}
	}

	public static function GetCurrentURL()
	{
		$res = (CMain::IsHTTPS() ? 'https' : 'http') . '://';

		$host = $_SERVER['HTTP_HOST'];
		$res .= $host;

		$port = intval($_SERVER['SERVER_PORT']);
		if ($port > 0 && $port != 80 && $port != 443 && mb_strpos($host, ':') === false)
		{
			$res .= ':' . $port;
		}

		$url = preg_replace('/\\?sphrase_id=\\d+&/', '?', $_SERVER['REQUEST_URI']);
		$url = preg_replace('/\\?sphrase_id=\\d+/', '', $url);
		$url = preg_replace('/&sphrase_id=\\d+/', '', $url);

		$res .= $url;

		return $res;
	}

	public static function OnEpilog()
	{
		if (isset($_REQUEST['sphrase_id']))
		{
			$phrase_id = intval($_REQUEST['sphrase_id']);
			if ($phrase_id)
			{
				$DB = CDatabase::GetModuleConnection('search');
				$DB->StartUsingMasterOnly();
				$rs = $DB->Query('
					SELECT *
					FROM b_search_phrase
					WHERE ID = ' . $phrase_id . "
					AND SESSION_ID = '" . $DB->ForSQL(bitrix_sessid()) . "'
					AND URL_TO IS NULL
				");
				if ($ar = $rs->Fetch())
				{
					$URL_TO = $DB->ForSQL(CSearchStatistic::GetCurrentURL(), 2000);
					$DB->Query("
						UPDATE b_search_phrase
						SET URL_TO = '" . $URL_TO . "'
							,URL_TO_404 = '" . (defined('ERROR_404') ? 'Y' : 'N') . "'
							,URL_TO_SITE_ID = " . (defined('SITE_ID') ? "'" . $DB->ForSQL(SITE_ID, 2) . "'" : 'null') . '
						WHERE ID = ' . $phrase_id . '
					');
				}
				$DB->StopUsingMasterOnly();
			}
		}
	}
}