<?php
namespace Bitrix\Im;

use Bitrix\Im\V2\Message\CounterServiceLegacy;
use Bitrix\Main\EventResult;
use Bitrix\Main\Localization\Loc;

class Counter
{
	const CACHE_TTL = 86400; // 1 month
	const CACHE_NAME = 'counter_v3'; // 1 month
	const CACHE_PATH = '/bx/im/counter/';

	const TYPE_MESSENGER = 'messenger';
	const TYPE_NOTIFY = 'notify';
	const MODULE_ID = 'im';

	public static function get($userId = null, $options = [])
	{
		if (isset($options['JSON']))
		{
			return \Bitrix\Im\Common::toJson((new CounterServiceLegacy($userId))->get());
		}
		return (new CounterServiceLegacy($userId))->get();
		/*
		$result = [
			'TYPE' => [
				'ALL' => 0,
				'NOTIFY' => 0,
				'DIALOG' => 0,
				'CHAT' => 0,
				'LINES' => 0,
			],
			'DIALOG' => [],
			'DIALOG_UNREAD' => [],
			'CHAT' => [],
			'CHAT_MUTED' => [],
			'CHAT_UNREAD' => [],
			'LINES' => [],
		];

		$userId = Common::getUserId($userId);
		if ($userId <= 0)
		{
			return $result;
		}

		$cache = \Bitrix\Main\Data\Cache::createInstance();
		if ($cache->initCache(self::CACHE_TTL, self::CACHE_NAME.'_'.$userId, self::CACHE_PATH))
		{
			$result = $cache->getVars();
			if (isset($options['JSON']))
			{
				$result = \Bitrix\Im\Common::toJson($result);
			}
			return $result;
		}

		$query = "
			SELECT
				R1.CHAT_ID,
				R1.MESSAGE_TYPE, 
				CASE WHEN RC.ITEM_TYPE = '".IM_MESSAGE_PRIVATE."' THEN RC.ITEM_ID ELSE 0 END AS PRIVATE_USER_ID,
				U.ACTIVE AS PRIVATE_USER_ACTIVE,
				R1.COUNTER,
				R1.NOTIFY_BLOCK MUTED,
				CASE WHEN RC.USER_ID > 0 THEN 'Y' ELSE 'N' END AS IN_RECENT,
				RC.UNREAD
			FROM b_im_relation R1 
			LEFT JOIN b_im_recent RC ON RC.ITEM_RID = R1.ID
			LEFT JOIN b_user U ON RC.ITEM_TYPE = '".IM_MESSAGE_PRIVATE."' AND U.ID = RC.ITEM_ID
			WHERE R1.USER_ID = ".intval($userId)." AND (R1.STATUS <> ".IM_STATUS_READ." OR RC.UNREAD = 'Y')
		";
		$counters = \Bitrix\Main\Application::getInstance()->getConnection()->query($query)->fetchAll();

		foreach ($counters as $entity)
		{
			if ($entity['MESSAGE_TYPE'] == IM_MESSAGE_SYSTEM)
			{
				$result['TYPE']['ALL'] += (int)$entity['COUNTER'];
				$result['TYPE']['NOTIFY'] += (int)$entity['COUNTER'];
			}
			else
			{
				if ($entity['IN_RECENT'] == 'N')
				{
					continue;
				}
				if ($entity['MESSAGE_TYPE'] == IM_MESSAGE_PRIVATE)
				{
					if ($entity['PRIVATE_USER_ACTIVE'] === 'N')
					{
						continue;
					}

					if ($entity['COUNTER'] > 0)
					{
						$result['TYPE']['ALL'] += (int)$entity['COUNTER'];
						$result['TYPE']['DIALOG'] += (int)$entity['COUNTER'];
						$result['DIALOG'][$entity['PRIVATE_USER_ID']] = (int)$entity['COUNTER'];
					}
					else if ($entity['UNREAD'] === 'Y')
					{
						$result['TYPE']['ALL']++;
						$result['TYPE']['DIALOG']++;
						$result['DIALOG_UNREAD'][] = (int)$entity['PRIVATE_USER_ID'];
					}
				}
				else if ($entity['MESSAGE_TYPE'] == IM_MESSAGE_OPEN_LINE)
				{
					$result['TYPE']['ALL'] += (int)$entity['COUNTER'];
					$result['TYPE']['LINES'] += (int)$entity['COUNTER'];
					$result['LINES'][$entity['CHAT_ID']] = (int)$entity['COUNTER'];
				}
				else
				{
					if ($entity['COUNTER'] > 0)
					{
						if ($entity['MUTED'] === 'N')
						{
							$result['TYPE']['ALL'] += (int)$entity['COUNTER'];
							$result['TYPE']['CHAT'] += (int)$entity['COUNTER'];
							$result['CHAT'][$entity['CHAT_ID']] = (int)$entity['COUNTER'];
						}
						else
						{
							$result['CHAT_MUTED'][$entity['CHAT_ID']] = (int)$entity['COUNTER'];
						}
					}
					else if ($entity['UNREAD'] === 'Y')
					{
						if ($entity['MUTED'] === 'N')
						{
							$result['TYPE']['ALL']++;
							$result['TYPE']['CHAT']++;
						}
						$result['CHAT_UNREAD'][] = (int)$entity['CHAT_ID'];
					}

				}
			}
		}

		$cache->startDataCache();
		$cache->endDataCache($result);

		if (isset($options['JSON']))
		{
			$result = \Bitrix\Im\Common::toJson($result);
		}

		return $result;
		*/
	}

	public static function clearCache($userId = null)
	{
		$cache = \Bitrix\Main\Data\Cache::createInstance();
		if ($userId)
		{
			$cache->clean(self::CACHE_NAME.'_'.$userId, self::CACHE_PATH);
		}
		else
		{
			$cache->cleanDir(self::CACHE_PATH);
		}

		return true;
	}

	public static function getChatCounter($chatId, $userId = null)
	{
		$chatId = intval($chatId);
		$userId = Common::getUserId($userId);

		if ($chatId <= 0 || $userId <= 0)
		{
			return false;
		}

		$counters = self::get($userId);

		return intval($counters['CHAT'][$chatId]);
	}

	public static function getDialogCounter($opponentUserId, $userId = null)
	{
		$userId = Common::getUserId($userId);
		$opponentUserId = intval($opponentUserId);
		if ($userId <= 0 || $opponentUserId <= 0)
		{
			return false;
		}

		$counters = self::get($userId);

		return intval($counters['DIALOG'][$opponentUserId]);
	}

	public static function getNotifyCounter($userId = null)
	{
		$userId = Common::getUserId($userId);
		if ($userId <= 0)
		{
			return false;
		}

		$counters = self::get($userId);

		return intval($counters['TYPE']['NOTIFY']);
	}

	public static function countingLostCountersAgent($notifyRelationId = 0, $chatRelationId = 0)
	{
		return '';

		/*
		$foundNotify = false;
		$foundChat = false;

		$notifyStartId = intval($notifyRelationId);

		if ($notifyStartId >= 0)
		{
			$query = "
				SELECT COUNT(1) CNT, R.ID, R.USER_ID
				FROM b_im_message M
				INNER JOIN b_im_relation R ON R.CHAT_ID = M.CHAT_ID AND R.MESSAGE_TYPE = '".IM_MESSAGE_SYSTEM."' AND R.COUNTER = 0
				WHERE M.NOTIFY_READ <> 'Y' AND R.ID > ".$notifyStartId."
				GROUP BY R.ID, R.USER_ID
				HAVING CNT > 0
			";
			$cursor = \Bitrix\Main\Application::getInstance()->getConnection()->query($query);

			$count = 0;
			while ($row = $cursor->fetch())
			{
				$notifyRelationId = $row['ID'];
				$foundNotify = true;

				\Bitrix\Im\Model\RelationTable::update($row['ID'], Array(
					'STATUS' => IM_STATUS_UNREAD,
					"MESSAGE_STATUS" => IM_MESSAGE_STATUS_RECEIVED,
					'COUNTER' => $row['CNT'],
				));

				$count++;
				if ($count > 100)
				{
					break;
				}
			}
		}

		$chatRelationId = intval($chatRelationId);

		if ($chatRelationId >= 0)
		{
			$query = "
				SELECT R.ID, R.COUNTER PREVIOUS_COUNTER, (
					SELECT COUNT(1) FROM b_im_message M WHERE M.CHAT_ID = R.CHAT_ID AND M.ID > R.LAST_ID
				) COUNTER
				FROM b_im_relation R
				WHERE R.STATUS <> ".IM_STATUS_READ." AND R.COUNTER = 0 AND R.ID > ".$chatRelationId."
				ORDER BY R.ID ASC
				LIMIT 0, 100;
			";
			$cursor = \Bitrix\Main\Application::getInstance()->getConnection()->query($query);

			while ($row = $cursor->fetch())
			{
				$chatRelationId = $row['ID'];
				$foundChat = true;

				if ($row['COUNTER'] == 0)
				{
					$update = Array(
						'STATUS' => IM_STATUS_READ,
						"MESSAGE_STATUS" => IM_MESSAGE_STATUS_RECEIVED,
					);
				}
				else if ($row['PREVIOUS_COUNTER'] == $row['COUNTER'])
				{
					continue;
				}
				else
				{
					$update = Array(
						'COUNTER' => $row['COUNTER']
					);
				}
				\Bitrix\Im\Model\RelationTable::update($row['ID'], $update);
			}
		}

		if ($foundNotify || $foundChat)
		{
			return '\Bitrix\Im\Counter::countingLostCountersAgent('.($foundNotify? $notifyRelationId: -1).', '.($foundChat? $chatRelationId: -1).');';
		}
		else
		{
			return '';
		}
		*/
	}

	public static function onGetMobileCounterTypes(\Bitrix\Main\Event $event)
	{
		return new EventResult(
			EventResult::SUCCESS,
			[
				self::TYPE_MESSENGER => [
					'NAME' => Loc::getMessage('IM_COUNTER_TYPE_MESSENGER'),
					'DEFAULT' => true
				],
				self::TYPE_NOTIFY => [
					'NAME' => Loc::getMessage('IM_COUNTER_TYPE_NOTIFY'),
					'DEFAULT' => false
				],
			],
			self::MODULE_ID
		);
	}

	public static function onGetMobileCounter(\Bitrix\Main\Event $event)
	{
		$params = $event->getParameters();

		$counters = self::get($params['USER_ID']);

		$messengerCounter = $counters['TYPE']['MESSENGER'] ?? $counters['TYPE']['ALL'];
		$notifyCounter = isset($counters['TYPE']['MESSENGER']) ? $counters['TYPE']['NOTIFY'] : 0;

		$mobileCounters = [
			[
				'TYPE' => self::TYPE_MESSENGER,
				'COUNTER' => $messengerCounter,
			],
			[
				'TYPE' => self::TYPE_NOTIFY,
				'COUNTER' => $notifyCounter,
			],
		];

		return new EventResult(EventResult::SUCCESS, $mobileCounters, self::MODULE_ID);
	}
}