<?php

namespace Bitrix\Bizproc\Integration\Rest;

use Bitrix\Bizproc\Workflow\Template\Entity\WorkflowTemplateTable;
use Bitrix\Bizproc\Script;
use Bitrix\Bizproc\Script\Entity\ScriptTable;
use Bitrix\Crm\Automation\Trigger\Entity\TriggerTable;
use Bitrix\Main\Engine\CurrentUser;
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\SystemException;
use Bitrix\Main\Loader;
use Bitrix\Main\Event;
use Bitrix\Rest\Configuration\Helper;
use Bitrix\Rest\Configuration\Setting;
use CBPDocument;
use Exception;

class AppConfiguration
{
	const ENTITY_BIZPROC_MAIN = 'BIZPROC_MAIN';
	const ENTITY_BIZPROC_CRM_TRIGGER = 'BIZPROC_CRM_TRIGGER';
	const ENTITY_BIZPROC_SCRIPT = 'BIZPROC_SCRIPT';

	const OWNER_ENTITY_TYPE_BIZPROC = 'BIZPROC';
	const OWNER_ENTITY_TYPE_TRIGGER = 'TRIGGER';
	const OWNER_ENTITY_TYPE_BIZPROC_SCRIPT = 'BIZPROC_SCRIPT';

	private static $entityList = [
		self::ENTITY_BIZPROC_MAIN => 500,
		self::ENTITY_BIZPROC_CRM_TRIGGER => 600,
		self::ENTITY_BIZPROC_SCRIPT => 700,
	];
	private static $customDealMatch = '/^C([0-9]+):/';
	private static $accessModules = ['crm'];
	private static $context;
	private static $accessManifest = [
		'total',
		'bizproc_crm',
	];

	public static function getEntityList()
	{
		return static::$entityList;
	}

	public static function onEventExportController(Event $event)
	{
		$result = null;
		$code = $event->getParameter('CODE');
		$itemCode = $event->getParameter('ITEM_CODE');
		if (!static::$entityList[$code])
		{
			return $result;
		}

		$option = $event->getParameters();
		if ($code !== self::ENTITY_BIZPROC_SCRIPT && !Helper::checkAccessManifest($option, static::$accessManifest))
		{
			return $result;
		}

		if (
			$code === self::ENTITY_BIZPROC_SCRIPT
			&& !Helper::checkAccessManifest($option, ['bizproc_script'])
		)
		{
			return $result;
		}

		try
		{
			if (static::checkRequiredParams($code))
			{
				$step = $event->getParameter('STEP');
				switch ($code)
				{
					case self::ENTITY_BIZPROC_MAIN:
						$result = static::exportBizproc($step);
						break;
					case self::ENTITY_BIZPROC_CRM_TRIGGER:
						$result = static::exportCrmTrigger($step);
						break;
					case self::ENTITY_BIZPROC_SCRIPT:
						$result = static::exportScript($step, $event->getParameter('NEXT'), $itemCode);
						break;
				}
			}
		}
		catch (Exception $e)
		{
			$result['NEXT'] = false;
			$result['ERROR_ACTION'] = $e->getMessage();
			$result['ERROR_MESSAGES'] = Loc::getMessage(
				'BIZPROC_ERROR_CONFIGURATION_EXPORT_EXCEPTION',
				[
					'#CODE#' => $code,
				]
			);
		}

		return $result;
	}

	public static function onEventClearController(Event $event)
	{
		$code = $event->getParameter('CODE');
		if (!static::$entityList[$code])
		{
			return null;
		}
		$option = $event->getParameters();

		if ($code !== self::ENTITY_BIZPROC_SCRIPT && !Helper::checkAccessManifest($option, static::$accessManifest))
		{
			return null;
		}

		if (
			$code === self::ENTITY_BIZPROC_SCRIPT
			&& !Helper::checkAccessManifest($option, ['bizproc_script'])
		)
		{
			return null;
		}

		$result = null;

		try
		{
			if (static::checkRequiredParams($code))
			{
				switch ($code)
				{
					case self::ENTITY_BIZPROC_MAIN:
						$result = static::clearBizproc($option);
						break;
					case self::ENTITY_BIZPROC_CRM_TRIGGER:
						$result = static::clearCrmTrigger($option);
						break;
					case self::ENTITY_BIZPROC_SCRIPT:
						$result = static::clearScript($option);
						break;
				}
			}
		}
		catch (Exception $e)
		{
			$result['NEXT'] = false;
			$result['ERROR_ACTION'] = $e->getMessage();
			$result['ERROR_MESSAGES'] = Loc::getMessage(
				'BIZPROC_ERROR_CONFIGURATION_CLEAR_EXCEPTION',
				[
					'#CODE#' => $code,
				]
			);
		}

		return $result;
	}

	public static function onEventImportController(Event $event)
	{
		$code = $event->getParameter('CODE');
		if (!static::$entityList[$code])
		{
			return null;
		}
		$data = $event->getParameters();

		if ($code !== self::ENTITY_BIZPROC_SCRIPT && !Helper::checkAccessManifest($data, static::$accessManifest))
		{
			return null;
		}

		if (
			$code === self::ENTITY_BIZPROC_SCRIPT
			&& !Helper::checkAccessManifest($data, ['bizproc_script'])
		)
		{
			return null;
		}

		$result = null;
		$userId = (int)$event->getParameter('USER_ID');

		$contextUser = $event->getParameter('CONTEXT_USER');
		$setting = new Setting($contextUser);
		$app = $setting->get(Setting::SETTING_APP_INFO);
		$appId = (int)$app['ID'];

		try
		{
			if (static::checkRequiredParams($code))
			{
				switch ($code)
				{
					case self::ENTITY_BIZPROC_MAIN:
						$result = static::importBizproc($data);
						break;
					case self::ENTITY_BIZPROC_CRM_TRIGGER:
						$result = static::importCrmTrigger($data);
						break;
					case self::ENTITY_BIZPROC_SCRIPT:
						$result = static::importScript($data, $userId, $appId);
						break;
				}
			}
		}
		catch (Exception $e)
		{
			$result['NEXT'] = false;
			$result['ERROR_ACTION'] = $e->getMessage();
			$result['ERROR_MESSAGES'] = Loc::getMessage(
				'BIZPROC_ERROR_CONFIGURATION_IMPORT_EXCEPTION',
				[
					'#CODE#' => $code,
				]
			);
		}

		return $result;
	}

	/**
	 * @param $type string of event
	 * @return boolean
	 * @throws SystemException
	 */
	private static function checkRequiredParams($type)
	{
		$return = true;
		if ($type == self::ENTITY_BIZPROC_CRM_TRIGGER)
		{
			if (!Loader::IncludeModule('crm'))
			{
				throw new SystemException('need install module: crm');
			}
		}

		return $return;
	}

	//region bizproc
	private static function exportBizproc($step)
	{
		$result = [
			'FILE_NAME' => '',
			'CONTENT' => [],
			'NEXT' => false,
		];
		$res = WorkflowTemplateTable::getList(
			[
				'order' => [
					'ID' => 'ASC',
				],
				'filter' => [
					'=MODULE_ID' => static::$accessModules,
					'<AUTO_EXECUTE' => \CBPDocumentEventType::Script,
				],
				'limit' => 1,
				'offset' => $step,
			]
		);
		if ($tpl = $res->fetchObject())
		{
			$result['NEXT'] = $step;
			if (in_array($tpl->getModuleId(), static::$accessModules))
			{
				$result['FILE_NAME'] = $step;
				$packer = new \Bitrix\Bizproc\Workflow\Template\Packer\Bpt();
				$data = $packer->makePackageData($tpl);
				$result['CONTENT'] = [
					'ID' => $tpl->getId(),
					'MODULE_ID' => $tpl->getModuleId(),
					'ENTITY' => $tpl->getEntity(),
					'DOCUMENT_TYPE' => $tpl->getDocumentType(),
					'DOCUMENT_STATUS' => $tpl->getDocumentStatus(),
					'NAME' => $tpl->getName(),
					'AUTO_EXECUTE' => $tpl->getAutoExecute(),
					'DESCRIPTION' => $tpl->getDescription(),
					'SYSTEM_CODE' => $tpl->getSystemCode(),
					'ORIGINATOR_ID' => $tpl->getOriginatorId(),
					'ORIGIN_ID' => $tpl->getOriginId(),
					'TEMPLATE_DATA' => $data,
				];
			}
		}

		return $result;
	}

	private static function clearBizproc($option)
	{
		$result = [
			'NEXT' => false,
			'OWNER_DELETE' => [],
		];
		$clearFull = $option['CLEAR_FULL'];
		$prefix = $option['PREFIX_NAME'];
		$pattern = '/^\(' . $prefix . '\)/';

		$res = WorkflowTemplateTable::getList(
			[
				'order' => [
					'ID' => 'ASC',
				],
				'filter' => [
					'=MODULE_ID' => static::$accessModules,
					'>ID' => $option['NEXT'],
					'<AUTO_EXECUTE' => \CBPDocumentEventType::Script,
				],
				'select' => ['*'],
			]
		);
		$errorsTmp = [];
		while ($item = $res->Fetch())
		{
			$result['NEXT'] = $item['ID'];

			if (!$clearFull && $item['DOCUMENT_TYPE'] == 'DEAL')
			{
				//dont off old custom deal robot
				$matches = [];
				preg_match(static::$customDealMatch, $item['DOCUMENT_STATUS'], $matches, PREG_OFFSET_CAPTURE);
				if (!empty($matches))
				{
					continue;
				}
			}

			if ($clearFull || !empty($item['DOCUMENT_STATUS']))
			{
				CBPDocument::DeleteWorkflowTemplate(
					$item['ID'],
					[
						$item['MODULE_ID'],
						$item['ENTITY'],
						$item['DOCUMENT_TYPE'],
					],
					$errorsTmp
				);
				if (!$errorsTmp)
				{
					$result['OWNER_DELETE'][] = [
						'ENTITY_TYPE' => self::OWNER_ENTITY_TYPE_BIZPROC,
						'ENTITY' => $item['ID'],
					];
				}
			}
			else
			{
				$name = $item['NAME'];
				if ($prefix != '' && preg_match($pattern, $name) === 0)
				{
					$name = "($prefix) " . $name;
				}
				CBPDocument::UpdateWorkflowTemplate(
					$item['ID'],
					[
						$item['MODULE_ID'],
						$item['ENTITY'],
						$item['DOCUMENT_TYPE'],
					],
					[
						'ACTIVE' => 'N',
						'AUTO_EXECUTE' => \CBPDocumentEventType::None,
						'NAME' => $name,
					],
					$errorsTmp
				);
			}
		}

		return $result;
	}

	private static function importBizproc($importData)
	{
		$result = [];

		if (!isset($importData['CONTENT']['DATA']))
		{
			return false;
		}
		$item = $importData['CONTENT']['DATA'];
		if (
			in_array($item['MODULE_ID'], static::$accessModules)
			&& Loader::includeModule($item['MODULE_ID'])
			&& class_exists($item['ENTITY'])
		)
		{
			if (is_subclass_of($item['ENTITY'], '\\IBPWorkflowDocument'))
			{

				if (isset($importData['RATIO']['CRM_STATUS']))
				{
					if (is_array($item['TEMPLATE_DATA']))
					{
						$item['TEMPLATE_DATA'] = static::changeDealCategory($item['TEMPLATE_DATA'], $importData['RATIO']['CRM_STATUS']);
					}
					if ($item['DOCUMENT_TYPE'] == 'DEAL' && $item['DOCUMENT_STATUS'])
					{
						$item['DOCUMENT_STATUS'] = static::changeDealCategory($item['DOCUMENT_STATUS'], $importData['RATIO']['CRM_STATUS']);
					}
				}

				try
				{
					$code = static::$context . '_xml_' . intval($item['ID']);
					$id = \CBPWorkflowTemplateLoader::importTemplateFromArray(
						0,
						[
							$item['MODULE_ID'],
							$item['ENTITY'],
							$item['DOCUMENT_TYPE'],
						],
						$item['AUTO_EXECUTE'],
						$item['NAME'],
						isset($item['DESCRIPTION']) ? (string)$item['DESCRIPTION'] : '',
						$item['TEMPLATE_DATA'],
						$code
					);

					if ($id > 0)
					{
						$result['OWNER'] = [
							'ENTITY_TYPE' => self::OWNER_ENTITY_TYPE_BIZPROC,
							'ENTITY' => $id,
						];

						if ($item['DOCUMENT_STATUS'])
						{
							\CBPWorkflowTemplateLoader::update(
								$id,
								[
									'DOCUMENT_STATUS' => $item['DOCUMENT_STATUS'],
								]
							);
						}
					}
				}
				catch (\Exception $e)
				{
					$result['ERROR_ACTION'] = $e->getMessage();
					$result['ERROR_MESSAGES'] = Loc::getMessage(
						'BIZPROC_ERROR_CONFIGURATION_IMPORT_EXCEPTION_BP'
					);
				}
			}
		}

		return $result;
	}
	//end region bizproc

	//region trigger
	private static function exportCrmTrigger($step)
	{
		$result = [
			'FILE_NAME' => '',
			'CONTENT' => [],
			'NEXT' => false,
		];

		$res = TriggerTable::getList(
			[
				'order' => [
					'ID' => 'ASC',
				],
				'filter' => [],
				'select' => ['*'],
				'limit' => 1,
				'offset' => $step,
			]
		);
		if ($item = $res->Fetch())
		{
			$result['FILE_NAME'] = $step;
			$result['CONTENT'] = $item;
			$result['NEXT'] = $step;
		}

		return $result;
	}

	private static function clearCrmTrigger($option)
	{
		$result = [
			'NEXT' => false,
		];
		$clearFull = $option['CLEAR_FULL'];

		$res = TriggerTable::getList(
			[
				'order' => [
					'ID' => 'ASC',
				],
				'filter' => [
					'>ID' => $option['NEXT'],
				],
				'limit' => 10,
			]
		);
		while ($item = $res->Fetch())
		{
			$result['NEXT'] = $item['ID'];
			if (!$clearFull && $item['ENTITY_TYPE_ID'] == \CCrmOwnerType::Deal)
			{
				//dont off old custom deal trigger
				$matches = [];
				preg_match(static::$customDealMatch, $item['ENTITY_STATUS'], $matches, PREG_OFFSET_CAPTURE);
				if (!empty($matches))
				{
					continue;
				}
			}
			$delete = TriggerTable::delete($item['ID']);
			if ($delete->isSuccess())
			{
				$result['OWNER_DELETE'][] = [
					'ENTITY_TYPE' => self::OWNER_ENTITY_TYPE_TRIGGER,
					'ENTITY' => $item['ID'],
				];
			}
		}

		return $result;
	}

	private static function importCrmTrigger($importData)
	{
		$result = [];
		if (!isset($importData['CONTENT']['DATA']))
		{
			return false;
		}
		$item = $importData['CONTENT']['DATA'];

		if (
			isset($item['NAME'])
			&& isset($item['CODE'])
			&& isset($item['ENTITY_TYPE_ID'])
			&& isset($item['ENTITY_STATUS'])
		)
		{
			if (isset($importData['RATIO']['CRM_STATUS']))
			{
				if (is_array($item['APPLY_RULES']))
				{
					$item['APPLY_RULES'] = static::changeDealCategory(
						$item['APPLY_RULES'],
						$importData['RATIO']['CRM_STATUS']
					);
				}
				if ($item['ENTITY_TYPE_ID'] == \CCrmOwnerType::Deal)
				{
					$item['ENTITY_STATUS'] = static::changeDealCategory(
						$item['ENTITY_STATUS'],
						$importData['RATIO']['CRM_STATUS']
					);
				}
			}

			$saveData = [
				'NAME' => $item['NAME'],
				'CODE' => $item['CODE'],
				'ENTITY_TYPE_ID' => $item['ENTITY_TYPE_ID'],
				'ENTITY_STATUS' => $item['ENTITY_STATUS'],
				'APPLY_RULES' => is_array($item['APPLY_RULES']) ? $item['APPLY_RULES'] : null,
			];

			$res = TriggerTable::add($saveData);
			if ($res->isSuccess())
			{
				$result['OWNER'] = [
					'ENTITY_TYPE' => self::OWNER_ENTITY_TYPE_TRIGGER,
					'ENTITY' => $res->getId(),
				];
			}
		}

		return $result;
	}

	//end region trigger

	//region script
	private static function exportScript($step, $nextId, $docType)
	{
		$result = [
			'FILE_NAME' => '',
			'CONTENT' => [],
			'NEXT' => false,
		];

		$nextId = (int)$nextId;

		$filter = [
			'>ID' => $nextId,
			'=MODULE_ID' => static::$accessModules,
		];

		if ($docType)
		{
			$filter['=DOCUMENT_TYPE'] = $docType;
		}

		$res = ScriptTable::getList(
			[
				'order' => [
					'ID' => 'ASC',
				],
				'filter' => $filter,
				'limit' => 1,
				'select' => ['ID'],
			]
		);
		if ($tpl = $res->fetch())
		{
			$data = Script\Manager::exportScript($tpl['ID']);
			if ($data)
			{
				$result['NEXT'] = $tpl['ID'];
				$result['FILE_NAME'] = $step;
				$result['CONTENT'] = $data;
			}
		}

		return $result;
	}

	private static function clearScript($option)
	{
		$result = [
			'NEXT' => false,
			'OWNER_DELETE' => [],
		];

		if (!$option['CLEAR_FULL'])
		{
			return $result;
		}

		$res = ScriptTable::getList(
			[
				'order' => [
					'ID' => 'ASC',
				],
				'filter' => [
					'>ID' => (int)$option['NEXT'],
					'=MODULE_ID' => static::$accessModules,
				],
				'limit' => 1,
				'select' => ['ID'],
			]
		);

		while ($item = $res->Fetch())
		{
			$result['NEXT'] = $item['ID'];

			$deletionResult = Script\Manager::deleteScript($item['ID']);

			if ($deletionResult->isSuccess())
			{
				$result['OWNER_DELETE'][] = [
					'ENTITY_TYPE' => self::OWNER_ENTITY_TYPE_BIZPROC_SCRIPT,
					'ENTITY' => $item['ID'],
				];
			}
		}

		return $result;
	}

	private static function importScript($importData, int $userId, int $appId)
	{
		$result = [];

		if (!isset($importData['CONTENT']['DATA']))
		{
			return false;
		}
		$item = $importData['CONTENT']['DATA'];
		if (
			in_array($item['MODULE_ID'], static::$accessModules)
			&& Loader::includeModule($item['MODULE_ID'])
			&& class_exists($item['ENTITY'])
		)
		{
			if (is_subclass_of($item['ENTITY'], '\\IBPWorkflowDocument'))
			{
				if (isset($importData['RATIO']['CRM_STATUS']) && $item['DOCUMENT_TYPE'] === 'DEAL')
				{
					if (is_array($item['WORKFLOW_TEMPLATE']))
					{
						$item['WORKFLOW_TEMPLATE'] = static::changeDealCategory(
							$item['WORKFLOW_TEMPLATE'],
							$importData['RATIO']['CRM_STATUS']
						);
					}
				}

				if ($appId > 0)
				{
					$item['ORIGINATOR_ID'] = 'REST_APP';
					$item['ORIGIN_ID'] = $appId;
				}

				$importResult = Script\Manager::importScript($item, $userId);

				if ($importResult->isSuccess())
				{
					$result['OWNER'] = [
						'ENTITY_TYPE' => self::OWNER_ENTITY_TYPE_BIZPROC_SCRIPT,
						'ENTITY' => $importResult->getId(),
					];
				}
				else
				{
					$result['ERROR_ACTION'] = $result['ERROR_MESSAGES'] = current($importResult->getErrorMessages());
				}
			}
		}

		return $result;
	}
	//end region script

	private static function changeDealCategory($data, $ratio)
	{
		if (!empty($ratio))
		{
			$ratioRegEx = [];
			$ratioReplace = [];
			foreach ($ratio as $oldId => $newId)
			{
				$ratioRegEx[] = '/^C' . $oldId . ':/';
				$ratioReplace[] = 'C' . $newId . ':';
			}
			if (!empty($ratioRegEx))
			{
				$data = static::changeDealCategoryAction($data, $ratioRegEx, $ratioReplace, $ratio);
			}
		}

		return $data;
	}

	private static function changeDealCategoryAction($data, $ratioRegEx, $ratioReplace, $ratio)
	{
		if (is_string($data))
		{
			$data = preg_replace($ratioRegEx, $ratioReplace, $data);
		}
		elseif (is_array($data))
		{
			if (
				isset($data['field'])
				&& $data['field'] == 'CATEGORY_ID'
				&& $data['value'] > 0
				&& $ratio[$data['value']] > 0
			)
			{
				$data['value'] = $ratio[$data['value']];
			}

			foreach ($data as $key => $value)
			{
				$newKey = static::changeDealCategoryAction($key, $ratioRegEx, $ratioReplace, $ratio);
				if ($newKey != $key)
				{
					unset($data[$key]);
				}

				if ($newKey == 'CATEGORY_ID')
				{
					if (is_array($value))
					{
						if (isset($value['Options']) && is_array($value['Options']))
						{
							$data[$newKey]['Options'] = [];
							foreach ($value['Options'] as $dealId => $title)
							{
								if (isset($ratio[$dealId]))
								{
									$data[$newKey]['Options'][$ratio[$dealId]] = $title;
								}
							}
						}
						else
						{
							$data[$newKey] = static::changeDealCategoryAction(
								$value,
								$ratioRegEx,
								$ratioReplace,
								$ratio
							);
						}
					}
					elseif (is_string($value) && isset($ratio[$value]))
					{
						$data[$newKey] = $ratio[$value];
					}
					else
					{
						$data[$newKey] = static::changeDealCategoryAction(
							$value,
							$ratioRegEx,
							$ratioReplace,
							$ratio
						);
					}
				}
				elseif ($newKey == 'CategoryId' && intVal($value) > 0 && !empty($ratio[$value]))
				{
					$data[$newKey] = $ratio[$value];
				}
				else
				{
					$data[$newKey] = static::changeDealCategoryAction(
						$value,
						$ratioRegEx,
						$ratioReplace,
						$ratio
					);
				}
			}
		}

		return $data;
	}
}