<?php

namespace Bitrix\Conversion;

use Bitrix\Main;
use Bitrix\Main\SiteTable;
use Bitrix\Main\EventManager;
use Bitrix\Main\Web\Json;
use Bitrix\Main\Type\Date;
use Bitrix\Main\ArgumentException;
use Bitrix\Main\ArgumentTypeException;

final class DayContext extends Internals\BaseContext
{
	/**
	 * Add value to counter. If counter not exists set counter to value.
	 *
	 * @param Date $day Counter date.
	 * @param string $name Counter name.
	 * @param int|float $value Number to add.
	 * @return void
	 */
	public function addCounter($day, $name, $value = null)
	{
		if (func_num_args() == 2)
		{
			$value = $name;
			$name  = $day;
			$day   = new Date();
		}

		$instance = self::getInstance();

		if ($this->id === null && $this === $instance)
		{
			$pending =& self::$session['PENDING_COUNTERS'];

			if (empty($pending[$name]))
				$pending[$name] = 0;

			$pending[$name] += (float) $value;
		}
		else
		{
			parent::addCounter($day, $name, $value);
		}
	}

	/**
	 * Add value to counter (once a day per person). If counter not exists set counter to value.
	 *
	 * @param string $name Counter name.
	 * @param int|float $value Number to add.
	 * @return void
	 */
	public function addDayCounter($name, $value)
	{
		$instance = self::getInstance();
		$session =& self::$session;

		if ($this->id === null && $this === $instance)
		{
			$session['PENDING_DAY_COUNTERS'][$name] = (float) $value;
		}
		else
		{
			$unique =& $session['UNIQUE'];

			if (!in_array($name, $unique, true))
			{
				$unique[] = $name;

				$this->addCounter($name, $value);
				$this->setCookie();
			}
		}
	}
	
	/**
	 * Subtraction value from counter. If counter not exists does nothing.
	 *
	 * @param Date $day
	 * @param string $name
	 * @param int|float $value
	 * @return void
	 */
	public function subDayCounter($day, $name, $value)
	{
		$this->subCounter($day, $name, $value);
		
		// is today - clear session
		$isToday = $day instanceof Date ? $day->format('dmY') === date('dmY') : false;
		if ($isToday)
		{
			$unique =& self::$session['UNIQUE'];
			if (($i = array_search($name, $unique, true)) !== false)
			{
				unset($unique[$i]);
				$this->setCookie();
			}
		}
	}

	/**
	 * Add currency value to counter. If counter not exists set counter to value.
	 *
	 * @param string $name Counter name.
	 * @param int|float|string $value Numeric value.
	 * @param string $currency Currency code (eg: RUB).
	 * @return void
	 */
	public function addCurrencyCounter($name, $value, $currency)
	{
		$this->addCounter($name, Utils::convertToBaseCurrency($value, $currency));
	}

	/**
	 * Subtraction currency value from counter
	 *
	 * @param Date $day
	 * @param string $name
	 * @param int|float $value
	 * @param string $currency
	 * @return void
	 */
	public function subCurrencyCounter($day, $name, $value, $currency)
	{
		$this->subCounter($day, $name, Utils::convertToBaseCurrency($value, $currency));
	}

	/**
	 * Attach entity item to context.
	 *
	 * @param string $entity Entity type.
	 * @param string|int $item Entity item ID.
	 * @throws ArgumentTypeException
	 * @return void
	 */
	public function attachEntityItem($entity, $item)
	{
		if (! is_string($entity))
			throw new ArgumentTypeException('entity', 'string');

		if (! is_scalar($item))
			throw new ArgumentTypeException('item', 'scalar');

		$instance = self::getInstance();

		if ($this->id === null && $this === $instance)
		{
			self::$session['PENDING_ENTITY_ITEMS'][$entity.':'.$item] = array('ENTITY' => $entity, 'ITEM' => $item);
		}
		else
		{
			try
			{
				Internals\ContextEntityItemTable::add(array(
					'CONTEXT_ID' => $this->id,
					'ENTITY'     => $entity,
					'ITEM'       => $item,
				));
			}
			catch (\Bitrix\Main\DB\SqlQueryException $e)
			{
			}
		}
	}

	/**
	 * Get context of attached entity item.
	 *
	 * @param string $entity Entity type.
	 * @param string|int $item Entity item ID.
	 * @return self
	 */
	public static function getEntityItemInstance($entity, $item)
	{
		$instance = self::getInstance();

		$context = Internals\ContextEntityItemTable::getList(array(
			'select' => array('CONTEXT_ID'),
			'filter' => array('=ENTITY' => $entity, '=ITEM' => $item),
			'limit'  => 1,
		))->fetch();

		$contextId = !empty($context['CONTEXT_ID']) ? $context['CONTEXT_ID'] : self::EMPTY_CONTEXT_ID;
		if ($contextId !== $instance->id)
		{
			$instance = new self;
			$instance->id = $contextId;
		}

		return $instance;
	}

	/**
	 * Returns context for given Site
	 *
	 * @param string $siteId Site ID.
	 * @return self
	 */
	public static function getSiteInstance($siteId)
	{
		$instance = self::getInstance();

		if (preg_match('/[a-z0-9_]{2}/i', $siteId) && self::getSiteId() != $siteId && \CSite::getById($siteId)->fetch())
		{
			$instance = new self;

			foreach (EventManager::getInstance()->findEventHandlers('conversion', 'OnSetDayContextAttributes') as $handler)
				ExecuteModuleEventEx($handler, array($instance));

			$instance->setAttribute('conversion_site', $siteId);
			$instance->save();
		}

		return $instance;
	}

	/** @var self $instance */
	private static $instance;
	private static $session;

	/**
	 * Get day context singleton instance.
	 *
	 * @return self
	 */
	public static function getInstance()
	{
		if (! self::$instance)
		{
			$instance = new self;
			$varName  = self::getVarName();
			$session  =& $_SESSION[$varName];
			$expire   = strtotime('today 23:59');

			if (! (is_array($session) && is_int($session['ID']) && $session['EXPIRE'] === $expire))
			{
				$session = array('ID' => null, 'EXPIRE' => $expire, 'UNIQUE' => array());

				if ($cookie = $_COOKIE[$varName])
				{
					try
					{
						$cookie = Json::decode($cookie);
					}
					catch (ArgumentException $e)
					{
					}
				}

				// check if cookie is valid
				if (   is_array($cookie)
					&& is_array($cookie['UNIQUE'])
					&& $cookie['EXPIRE'] === $expire
					&& ($id = $cookie['ID']) !== null
					&& is_int($id)
					&& ($id === self::EMPTY_CONTEXT_ID || Internals\ContextTable::getByPrimary($id)->fetch())
				)
				{
					$session['ID'    ] = $id;
					$session['UNIQUE'] = $cookie['UNIQUE'];
				}
			}

			$instance->id = $session['ID'];
			self::$session =& $session;
			self::$instance = $instance;
		}

		return self::$instance;
	}

	/** @internal */
	private function setCookie()
	{
		$session = self::$session;

		$cookie = new Main\Web\Cookie(
			self::getVarName(),
			Json::encode(array(
				'ID' => $session['ID'],
				'EXPIRE' => $session['EXPIRE'],
				'UNIQUE' => $session['UNIQUE'],
			)),
			strtotime('+1 year'),
			false
		);
		$cookie->setHttpOnly(false);

		Main\Context::getCurrent()->getResponse()->addCookie($cookie);
	}

	/** @internal */
	public static function saveInstance()
	{
		$instance = self::getInstance();
		$session =& self::$session;

		if ($instance->id === null)
		{
			foreach (EventManager::getInstance()->findEventHandlers('conversion', 'OnSetDayContextAttributes') as $handler)
				ExecuteModuleEventEx($handler, array($instance));

			$instance->save();
		}

		$session['ID'] = $instance->id;
		$instance->setCookie();

		if (!empty($session['PENDING_COUNTERS']) && is_array($session['PENDING_COUNTERS']))
		{
			foreach ($session['PENDING_COUNTERS'] as $name => $value)
				$instance->addCounter($name, $value);
		}

		if (!empty($session['PENDING_DAY_COUNTERS']) && is_array($session['PENDING_DAY_COUNTERS']))
		{
			foreach ($session['PENDING_DAY_COUNTERS'] as $name => $value)
				$instance->addDayCounter($name, $value);
		}

		if (!empty($session['PENDING_ENTITY_ITEMS']) && is_array($session['PENDING_ENTITY_ITEMS']))
		{
			foreach ($session['PENDING_ENTITY_ITEMS'] as $i)
				$instance->attachEntityItem($i['ENTITY'], $i['ITEM']);
		}
	}

	/** @internal */
	public static function getVarName()
	{
		static $name;

		if (! $name)
		{
			$name = 'BITRIX_CONVERSION_CONTEXT_'.self::getSiteId();
		}

		return $name;
	}

	/** @internal */
	public static function getSiteId()
	{
		static $siteId = null;

		if ($siteId === null)
		{
			$siteId = '';

			if (defined('ADMIN_SECTION') && ADMIN_SECTION === true)
			{
				if ($row = SiteTable::getList(array(
					'select' => array('LID'),
					'order'  => array('DEF' => 'DESC', 'SORT' => 'ASC'),
					'limit'  => 1,
				))->fetch())
				{
					$siteId = $row['LID'];
				}
			}
			else
			{
				$siteId = SITE_ID;
			}
		}

		return $siteId;
	}
}