<?php
/**
 * Bitrix Framework
 * @package bitrix
 * @subpackage sender
 * @copyright 2001-2012 Bitrix
 */

namespace Bitrix\Sender\Integration\Crm;

use Bitrix\Crm\Activity\BindingSelector;
use Bitrix\Crm\Integrity\ActualEntitySelector;
use Bitrix\Main\Application;
use Bitrix\Main\DB\SqlQueryException;
use Bitrix\Main\Loader;
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\Web\Json;
use Bitrix\Sender\Entity;
use Bitrix\Sender\Recipient;
use Bitrix\Sender\Runtime\TimeLineJob;
use Bitrix\Sender\TimeLineQueueTable;

Loc::loadMessages(__FILE__);

/**
 * Class EventHandler
 * @package Bitrix\Sender\Integration\Crm
 */
class EventHandler
{
	private const TIME_LINE_COUNT_LIMIT = 500;
	/**
	 * Handler of event sender/OnAfterPostingSendRecipient.
	 *
	 * @param array $eventData Event.
	 * @param Entity\Letter $letter Letter.
	 */
	public static function onAfterPostingSendRecipient(array $eventData, Entity\Letter $letter)
	{
		if (!$eventData['SEND_RESULT'])
		{
			return;
		}

		static $isModuleIncluded = null;
		if ($isModuleIncluded === null)
		{
			$isModuleIncluded = Loader::includeModule('crm');
		}

		if (!$isModuleIncluded)
		{
			return;
		}

		if ($letter->getMessage()->isReturnCustomer())
		{
			return;
		}

		$recipient = $eventData['RECIPIENT'];
		$fields = $eventData['RECIPIENT']['FIELDS'];

		$entityId = $fields['CRM_ENTITY_ID'] ?? $recipient['CONTACT_ID'];

		if (!$entityId)
		{
			return;
		}

		TimeLineQueueTable::add([
			'RECIPIENT_ID' => $recipient['ID'],
			'POSTING_ID' => $letter->getId(),
			'FIELDS' => Json::encode($fields),
			'ENTITY_ID' => $entityId,
			'CONTACT_TYPE_ID' => $recipient['CONTACT_TYPE_ID'],
			'CONTACT_CODE' => $recipient['CONTACT_CODE'],
		]);
	}
	/**
	 * Handler of event sender/onAfterPostingSendRecipientMultiple.
	 *
	 * @param array $eventDataArray Event[].
	 * @param Entity\Letter $letter Letter.
	 */
	public static function onAfterPostingSendRecipientMultiple(array $eventDataArray, Entity\Letter $letter)
	{
		static $isModuleIncluded = null;

		if ($isModuleIncluded === null)
		{
			$isModuleIncluded = Loader::includeModule('crm');
		}

		if (!$isModuleIncluded)
		{
			return;
		}

		if ($letter->getMessage()->isReturnCustomer())
		{
			return;
		}

		$dataToInsert = [];
		foreach($eventDataArray as $eventData)
		{
			$recipient = $eventData['RECIPIENT'];
			$fields = $eventData['RECIPIENT']['FIELDS'];

			$entityId = $fields['CRM_ENTITY_ID'] ?? $recipient['CONTACT_ID'];
			$contactCode = !empty($recipient['CONTACT_CODE']) ? $recipient['CONTACT_CODE'] : $entityId;

			if (empty($entityId) || empty($contactCode))
			{
				continue;
			}

			$dataToInsert[] = [
				'RECIPIENT_ID' => $recipient['ID'],
				'POSTING_ID' => $letter->getId(),
				'FIELDS' => Json::encode($fields),
				'ENTITY_ID' => $entityId,
				'CONTACT_TYPE_ID' => $recipient['CONTACT_TYPE_ID'],
				'CONTACT_CODE' => $contactCode,
			];
		}

		if($dataToInsert)
		{
			TimeLineQueueTable::addMulti($dataToInsert, true);
		}
	}

	/**
	 * @return string
	 * @throws \Bitrix\Main\ArgumentException
	 * @throws \Bitrix\Main\ObjectPropertyException
	 * @throws \Bitrix\Main\SystemException
	 */
	public static function handleTimeLineEvents($letterId)
	{
		static $isModuleIncluded = null;
		if ($isModuleIncluded === null)
		{
			$isModuleIncluded = Loader::includeModule('crm');
		}

		if (!$isModuleIncluded)
		{
			return "";
		}

		$entityTypeId = $entityId = null;
		$batchData = [];
		$idsToDelete = [];
		self::lockTimelineQueue($letterId);
		$letter = Entity\Letter::createInstanceById($letterId);

		try
		{
			$queuedRows = TimeLineQueueTable::getList([
				'filter' => [
					'=STATUS' => TimeLineQueueTable::STATUS_NEW,
					'=POSTING_ID' => $letterId
				],
				'limit' => self::TIME_LINE_COUNT_LIMIT
			])->fetchAll();

			if(empty($queuedRows))
			{
				return "";
			}

			foreach ($queuedRows as $row)
			{
				$idsToDelete[] = $row['ID'];
				if (!$letter)
				{
					continue;
				}

				$fields = Json::decode($row['FIELDS']);
				if (isset($fields['CRM_ENTITY_TYPE_ID']) && $fields['CRM_ENTITY_TYPE_ID'])
				{
					$entityTypeId = $fields['CRM_ENTITY_TYPE_ID'];
				}
				if (isset($fields['CRM_ENTITY_ID']) && $fields['CRM_ENTITY_ID'])
				{
					$entityId = $fields['CRM_ENTITY_ID'];
				}

				if (!$entityTypeId || !$entityId)
				{
					$selector = self::getEntitySelectorByRecipient(
						$row['CONTACT_TYPE_ID'],
						$row['CONTACT_CODE']
					);
				}
				else
				{
					$selector = self::getEntitySelectorById($entityTypeId, $entityId);
				}


				if (!$selector)
				{
					continue;
				}

				if (!$selector->search()->hasEntities())
				{
					continue;
				}

				$recipient = [
					'ID' => $row['RECIPIENT_ID'],
					'CONTACT_TYPE_ID' => $row['CONTACT_TYPE_ID'],
					'CONTACT_CODE' => $row['CONTACT_CODE'],
				];

				$batchData[] = static::buildTimeLineEvent($selector, $letter, $recipient);
			}

			if (!empty($batchData))
			{
				Timeline\RecipientEntry::createMulti($batchData);
			}

			TimeLineQueueTable::deleteList(['=ID' => $idsToDelete]);
		} catch (\Exception $e)
		{
		}

		self::unlockTimelineQueue($letterId);

		return TimeLineJob::getAgentName($letterId);
	}

	protected static function addTimeLineEvent(ActualEntitySelector $selector, Entity\Base $letter, $recipient)
	{
		$parameters = static::buildTimeLineEvent($selector, $letter, $recipient);

		if(!empty($parameters))
		{
			Timeline\RecipientEntry::create($parameters);
		}
	}

	protected static function buildTimeLineEvent(ActualEntitySelector $selector, Entity\Base $letter, $recipient)
	{
		$isAd = $letter instanceof Entity\Ad;
		$createdBy = $letter->get('CREATED_BY');
		if (!$createdBy)
		{
			return [];
		}

		// convert format to time line
		$bindings = [];
		$activityBindings = BindingSelector::findBindings($selector);
		foreach ($activityBindings as $binding)
		{
			$binding['ENTITY_ID'] = $binding['OWNER_ID'];
			$binding['ENTITY_TYPE_ID'] = $binding['OWNER_TYPE_ID'];
			$bindings[] = [
				'ENTITY_TYPE_ID' => $binding['OWNER_TYPE_ID'],
				'ENTITY_ID' => $binding['OWNER_ID'],
			];
		}

		return [
			'ENTITY_TYPE_ID' => $selector->getPrimaryTypeId(),
			'ENTITY_ID' => $selector->getPrimaryId(),
			'TYPE_CATEGORY_ID' => $letter->getMessage()->getCode(),
			'AUTHOR_ID' => $createdBy,
			'SETTINGS' => [
				'letterId' => $letter->getId(),
				'isAds' => $isAd,
				'recipient' => [
					'id' => $recipient['ID'],
					'typeId' => $recipient['CONTACT_TYPE_ID'],
					'code' => $recipient['CONTACT_ID'],
				],
			],
			'BINDINGS' => $bindings
		];
	}

	protected static function getEntitySelector()
	{
		/** @var ActualEntitySelector $selector */
		static $selector = null;
		if (!$selector)
		{
			$selector = new ActualEntitySelector();
		}
		else
		{
			$selector->clear();
		}

		return $selector;
	}

	protected static function getEntitySelectorById($entityTypeId, $entityId)
	{
		return self::getEntitySelector()->setEntity($entityTypeId, $entityId);
	}

	protected static function getEntitySelectorByRecipient($recipientTypeId, $recipientCode)
	{
		$selector = self::getEntitySelector();

		switch ($recipientTypeId)
		{
			case Recipient\Type::EMAIL:
				$selector->appendEmailCriterion($recipientCode);
				break;

			case Recipient\Type::PHONE:
				$selector->appendPhoneCriterion($recipientCode);
				break;

			default:
				return null;
		}

		return $selector;
	}

	/**
	 * Lock table from selecting of the other agents
	 *
	 * @param mixed $letterId LetterId
	 *
	 * @return bool
	 */
	protected static function lockTimelineQueue($letterId): bool
	{
		$connection = Application::getInstance()->getConnection();
		$lockName = self::getTimelineQueueLock((string)$letterId);

		return $connection->lock($lockName);
	}

	/**
	 * Unlock table for select
	 *
	 * @param mixed $letterId LetterId
	 *
	 * @return bool
	 */
	protected static function unlockTimelineQueue($letterId): bool
	{
		$connection = Application::getInstance()->getConnection();
		$lockName = self::getTimelineQueueLock((string)$letterId);

		return $connection->unlock($lockName);
	}

	/**
	 * Get timeline queue lock name
	 *
	 * @param string $letterId Letter Id
	 *
	 * @return string
	 */
	private static function getTimelineQueueLock(string $letterId): string
	{
		return "time_line_queue_$letterId";
	}
}