.-.-.-.-.-

<?php
namespace Bitrix\ImOpenLines;

use \Bitrix\Main,
	\Bitrix\Main\Loader,
	\Bitrix\Main\Application,
	\Bitrix\Main\Type\DateTime,
	\Bitrix\Main\Localization\Loc,
	\Bitrix\Main\DB\SqlExpression;

use \Bitrix\ImOpenLines\Log\Library,
	\Bitrix\Imopenlines\Im\Messages,
	\Bitrix\ImOpenLines\Log\EventLog,
	\Bitrix\ImOpenLines\Session\Agent,
	\Bitrix\ImOpenLines\Model\SessionTable,
	\Bitrix\ImOpenLines\Model\SessionCheckTable,
	\Bitrix\Imopenlines\Model\SessionIndexTable;

Loc::loadMessages(__FILE__);

class Session
{
	private $config = [];
	private $session = [];
	private $user = [];
	private $connectorId = '';

/* @var \Bitrix\ImOpenLines\Chat */
	public $chat = null;

private $action = 'none';
	public $joinUserId = 0;
	public $joinUserList = [];
	private $isCreated = false;

const RULE_TEXT = 'text';
	const RULE_FORM = 'form';
	const RULE_NONE = 'none';

const ACTION_NO_ANSWER = 'no_answer';
	const ACTION_CLOSED = 'closed';
	const ACTION_NONE = 'none';

const MODE_INPUT = 'input';
	const MODE_OUTPUT = 'output';

const CACHE_QUEUE = 'queue';
	const CACHE_CLOSE = 'close';
	const CACHE_MAIL = 'mail';
	const CACHE_INIT = 'init';
	const CACHE_NO_ANSWER = 'no_answer';

/** New dialog opens. */
	const STATUS_NEW = 0;
	/** The operator sent the dialog to the queue. */
	const STATUS_SKIP = 5;
	/** The operator took the dialogue to work. */
	const STATUS_ANSWER = 10;
	/** The client is waiting for the operator's response. */
	const STATUS_CLIENT = 20;
	/** The client is waiting for the operator's answer (new question after answer). */
	const STATUS_CLIENT_AFTER_OPERATOR = 25;
	/** The operator responded to the client. */
	const STATUS_OPERATOR = 40;
	/** The dialogue in the mode of closing (pending the vote or after auto-answer). */
	const STATUS_WAIT_CLIENT = 50;
	/** The conversation has ended. */
	const STATUS_CLOSE = 60;
	/** Spam / forced termination. */
	const STATUS_SPAM = 65;
	/** Duplicate session. The session is considered closed. */
	const STATUS_DUPLICATE = 69;
	/** Closed without sending special messages and notifications. */
	const STATUS_SILENTLY_CLOSE = 75;

const ORM_SAVE = 'save';
	const ORM_GET = 'get';

const VOTE_LIKE = 5;
	const VOTE_DISLIKE = 1;

/**
	 * Session constructor.
	 * @param array $config
	 * @throws Main\LoaderException
	 */
	public function __construct($config = [])
	{
		$this->config = $config;

Loader::includeModule('im');
	}

/**
	 * Initialization of the session by the given data.
	 *
	 * @param array $session Array describing the session.
	 * @param array $config An array describing the setting of an open line.
	 * @param array $chat An array describing the chat.
	 */
	public function loadByArray($session, $config, $chat)
	{
		$this->session = $session;
		$this->config = $config;
		$this->chat = $chat;
		$this->connectorId = $session['SOURCE'];

Debug::addSession($this, __METHOD__);
	}

/**
	 * Session load method.
	 *
	 * @param array $params
	 * @return bool
	 * @throws Main\ArgumentException
	 * @throws Main\LoaderException
	 * @throws Main\ObjectException
	 * @throws Main\ObjectPropertyException
	 * @throws Main\SystemException
	 */
	public function load(array $params)
	{
		$result = false;

$parsedUserCode = Session\Common::parseUserCode($params['USER_CODE']);
		$parsedUserCodeFail = $parsedUserCode;

if (empty($params['CONFIG_ID']))
		{
			$params['CONFIG_ID'] = $parsedUserCode['CONFIG_ID'];
		}
		$params['USER_ID'] = $parsedUserCode['CONNECTOR_USER_ID'];
		$params['SOURCE'] = $parsedUserCode['CONNECTOR_ID'];
		$params['CHAT_ID'] = $parsedUserCode['EXTERNAL_CHAT_ID'];

if(Connector::isEnableGroupByChat($parsedUserCode['CONNECTOR_ID']))
		{
			$parsedUserCode['CONNECTOR_USER_ID'] = 0;

if(!empty($params['USER_ID']))
			{
				$params['USER_CODE_FAIL'] = $params['USER_CODE'];
			}

$params['USER_CODE'] = Session\Common::combineUserCode($parsedUserCode);
		}
		else
		{
			//Handles the situation where the group chat feature or not has been changed.
			$parsedUserCodeFail['CONNECTOR_USER_ID'] = 0;
			$params['USER_CODE_FAIL'] = Session\Common::combineUserCode($parsedUserCodeFail);
		}

$resultStart = $this->start($params);

if($resultStart->isSuccess() && $resultStart->getResult() == true)
		{
			$result = true;
		}

return $result;
	}

/**
	 * @param $params
	 * @return Result
	 * @throws Main\ArgumentException
	 * @throws Main\LoaderException
	 * @throws Main\ObjectException
	 * @throws Main\ObjectPropertyException
	 * @throws Main\SystemException
	 */
	public function start($params)
	{
		Debug::addSession($this, 'begin ' . __METHOD__, $params);
		$result = new Result();

$result->setResult(false);

//params
		$this->connectorId = $params['SOURCE'];

$fields['PARENT_ID'] = intval($params['PARENT_ID']);
		$fields['USER_CODE'] = $params['USER_CODE'];

$fields['USER_CODE_FAIL'] = $params['USER_CODE_FAIL'];

$fields['CONFIG_ID'] = intval($params['CONFIG_ID']);
		$fields['USER_ID'] = intval($params['USER_ID']);
		$fields['OPERATOR_ID'] = intval($params['OPERATOR_ID']);
		$params['CRM_TRACE_DATA'] = (string)$params['CRM_TRACE_DATA'];
		$fields['SOURCE'] = $params['SOURCE'];
		$fields['MODE'] =  $params['MODE'] == self::MODE_OUTPUT? self::MODE_OUTPUT: self::MODE_INPUT;
		$params['DEFERRED_JOIN'] =  $params['DEFERRED_JOIN'] == 'Y'? 'Y': 'N';
		$params['SKIP_CREATE'] =  $params['SKIP_CREATE'] == 'Y'? 'Y': 'N';
		$params['REOPEN'] =  $params['REOPEN'] == 'Y'? 'Y': 'N';

$configManager = new Config();
		//Check open line configuration load
		if (empty($this->config) && !empty($fields['CONFIG_ID']))
		{
			$this->config = $configManager->get($fields['CONFIG_ID']);
		}
		if (empty($this->config))
		{
			$result->addError(new Error(Loc::getMessage('IMOL_SESSION_ERROR_NO_IMOL_CONFIGURATION'), 'NO IMOL CONFIGURATION', __METHOD__, $params));
		}

if($result->isSuccess())
		{
			if($this->prepareUserChat($params) !== true || empty($this->chat))
			{
				$result->addError(new Error(Loc::getMessage('IMOL_SESSION_ERROR_NO_CHAT'), 'NO CHAT', __METHOD__, $params));
			}
		}
		//END params

if($result->isSuccess())
		{
			//Load session
			$resultReading = $this->readingSession($fields, $params);

if($resultReading->isSuccess())
			{
				if($resultReading->getResult() == true)
				{
					$result->setResult(true);
				}
				//If you do create a session
				else if ($params['SKIP_CREATE'] != 'Y')
				{
					//Creating a new session
					$resultCreate = $this->createSession($fields, $params);

if($resultCreate->isSuccess())
					{
						$result->setResult(true);
					}
					else
					{
						$result->addErrors($resultCreate->getErrors());
					}
					//END Creating a new session
				}
			}
			else
			{
				$result->addErrors($resultReading->getErrors());
			}
		}

Debug::addSession($this, 'end ' . __METHOD__, ['SUCCESS' => $result->isSuccess(), 'ERRORS' => $result->getErrorMessages()]);

return $result;
	}

/**
	 * @param $fields
	 * @param $params
	 * @return Result
	 * @throws Main\ArgumentException
	 * @throws Main\LoaderException
	 * @throws Main\ObjectException
	 * @throws Main\ObjectPropertyException
	 * @throws Main\SystemException
	 */
	protected function createSession($fields, $params)
	{
		Debug::addSession($this, 'begin ' . __METHOD__, ['fields' => $fields, '$params' => $params]);

$result = new Result();

/* CRM BLOCK */
		$crmManager = new Crm($this);
		if($crmManager->isLoaded())
		{
			$crmFieldsManager = $crmManager->getFields();
			$crmFieldsManager->setDataFromUser($fields['USER_ID']);
			if($this->config['CRM_CREATE'] != Config::CRM_CREATE_LEAD)
			{
				$crmManager->setSkipCreate();
			}

if(Connector::isNeedCRMTracker($fields['SOURCE']))
			{
				$crmManager->setSkipCreate();
				$crmManager->setIgnoreSearchPerson();
			}

$fields['CRM_TRACE_DATA'] = Crm\Tracker::getTraceData($params['CRM_TRACE_DATA']);
		}
		/* END CRM BLOCK */

if ($fields['MODE'] === self::MODE_OUTPUT)
		{
			$previousSessionBlock = ReplyBlock::getBlockFromPreviousSession($fields);
		}

$fields['CHAT_ID'] = $this->chat->getData('ID');

if ($this->chat->isNowCreated())
		{
			$fields['START_ID'] = 0;
			$fields['IS_FIRST'] = 'Y';
		}
		else
		{
			$fields['START_ID'] = $this->chat->getData('LAST_MESSAGE_ID')+1;
			$fields['IS_FIRST'] = 'N';

$this->chat->join($fields['USER_ID']);
		}

if ($fields['MODE'] == self::MODE_OUTPUT)
		{
			$fields['STATUS'] = self::STATUS_ANSWER;
		}

$resultAdd = Model\SessionTable::add($fields);
		if ($resultAdd->isSuccess())
		{
			$this->isCreated = true;
			$fields['SESSION_ID'] = $resultAdd->getId();

$resultAddSessionCheck = Model\SessionCheckTable::add([
				'SESSION_ID' => $fields['SESSION_ID'],
				'DATE_CLOSE' => (new DateTime())->add('180 SECONDS'),
				'DATE_QUEUE' => (new DateTime())->add('180 SECONDS'),
			]);

if($resultAddSessionCheck->isSuccess())
			{
				$this->session = $fields;
				$this->session['ID'] = $this->session['SESSION_ID'] = $fields['SESSION_ID'];

$dateNoAnswer = null;

$queueManager = Queue::initialization($this);

$resultQueue = $queueManager->createSession($fields['OPERATOR_ID'], $crmManager, Connector::isEnableGroupByChat($fields['SOURCE']));

$this->session['JOIN_BOT'] = $resultQueue['JOIN_BOT'];
				$this->session['OPERATOR_ID'] = $fields['OPERATOR_ID'] = $params['OPERATOR_ID'] = $resultQueue['OPERATOR_ID'];
				$fields['DATE_OPERATOR'] = $resultQueue['DATE_OPERATOR'];
				$fields['QUEUE_HISTORY'] = $this->session['QUEUE_HISTORY'] = $resultQueue['QUEUE_HISTORY'];
				$dateNoAnswer = $resultQueue['DATE_NO_ANSWER'];
				$undistributed = $resultQueue['UNDISTRIBUTED'] == true? 'Y' : 'N';
				$dateQueue = $resultQueue['DATE_QUEUE'];
				$this->joinUserList = $resultQueue['OPERATOR_LIST'];
				$fields['OPERATOR_FROM_CRM'] = $resultQueue['OPERATOR_CRM'] == true? 'Y' : 'N';

//Send message
				if ($fields['PARENT_ID'] > 0)
				{
					$messageId = Messages\Session::sendMessageStartSessionByMessage($fields['CHAT_ID'], $fields['SESSION_ID'], $fields['PARENT_ID']);
				}
				else
				{
					$messageId = Messages\Session::sendMessageStartSession($fields['CHAT_ID'], $fields['SESSION_ID']);
				}
				//END Send message

if ($this->chat->isNowCreated())
				{
					if(intval($messageId) < 0)
					{
						$messageId = 0;
					}

$fields['START_ID'] = $messageId;
				}

$this->chat->updateFieldData([Chat::FIELD_SESSION => [
					'ID' => $fields['SESSION_ID'],
					'DATE_CREATE' => new DateTime()
				]]);

if ($fields['MODE'] == self::MODE_INPUT)
				{
					/* CLOSED LINE */
					if ($this->config['ACTIVE'] == 'N')
					{
						$this->action = self::ACTION_CLOSED;
						$fields['WORKTIME'] = 'N';
						$fields['WAIT_ACTION'] = 'Y';
					}
					else if(!(new AutomaticAction\WorkTime($this))->isWorkTimeLine())
					{
						$fields['WORKTIME'] = 'N';
						if ($this->session['JOIN_BOT'])
						{
							$this->resetActionAll();
						}
						else
						{
							$fields['WAIT_ACTION'] = 'Y';
						}
					}
				}
				elseif ($fields['MODE'] == self::MODE_OUTPUT)
				{
					if ($this->config['ACTIVE'] == 'N')
					{
						$this->action = self::ACTION_CLOSED;
						$fields['WORKTIME'] = 'N';
						$fields['WAIT_ACTION'] = 'Y';
					}
					if ($fields['OPERATOR_ID'])
					{
						if ($this->chat->getData('AUTHOR_ID') == 0)
						{
							$this->chat->answer($fields['OPERATOR_ID'], true);
							$this->chat->join($fields['OPERATOR_ID']);
						}
					}
					$fields['WAIT_ANSWER'] = 'N';
				}

$sessionId = $fields['SESSION_ID'];
				unset($fields['SESSION_ID']);
				Model\SessionTable::update($sessionId, $fields);
				$fields['SESSION_ID'] = $sessionId;

if (
					$fields['MODE'] == self::MODE_INPUT &&
					!empty($this->joinUserList) &&
					$params['DEFERRED_JOIN'] == 'N'
				)
				{
					$this->chat->sendJoinMessage($this->joinUserList, $fields['OPERATOR_FROM_CRM']);
					$this->chat->join($this->joinUserList);
					$this->joinUserList = [];
				}

$dateClose = new DateTime();

if ($fields['MODE'] == self::MODE_INPUT)
				{
					$dateClose->add('1 MONTH');
				}
				else
				{
					$dateClose->add($this->config['AUTO_CLOSE_TIME'] . ' SECONDS');
				}

Model\SessionCheckTable::update($fields['SESSION_ID'], [
					'DATE_CLOSE' => $dateClose,
					'DATE_QUEUE' => $dateQueue,
					'DATE_NO_ANSWER' => $dateNoAnswer,
					'UNDISTRIBUTED' => $undistributed,
				]);

$sessionManager = Model\SessionTable::getByIdPerformance($fields['SESSION_ID']);
				$this->session = $sessionManager->fetch();
				$this->session['SESSION_ID'] = $this->session['ID'];

$this->session['CHECK_DATE_CLOSE'] = $dateClose;
				$this->session['CHECK_DATE_QUEUE'] = $dateQueue;

if (!empty($previousSessionBlock['BLOCK_DATE']) && !empty($previousSessionBlock['BLOCK_REASON']))
				{
					ReplyBlock::add($fields['SESSION_ID'], $this->chat, $previousSessionBlock);
				}
				elseif (Loader::includeModule('imconnector'))
				{
					$limit = \Bitrix\ImConnector\Connector::getReplyLimit($fields['SOURCE']);
					if ($limit)
					{
						$limit['BLOCK_DATE'] = (new DateTime())->add($limit['BLOCK_DATE'].' SECONDS');

ReplyBlock::add($fields['SESSION_ID'], $this->chat, $limit);
						Messages\Session::sendMessageTimeLimit($fields['CHAT_ID'], $limit['BLOCK_REASON']);
					}
				}

/* BLOCK STATISTIC*/
				ConfigStatistic::getInstance($fields['CONFIG_ID'])->addInWork()->addSession();
				/* END BLOCK STATISTIC*/

/* CRM BLOCK */
				if ($fields['MODE'] == self::MODE_INPUT)
				{
					if (!Connector::isEnableGroupByChat($fields['SOURCE']) && $this->config['CRM'] == 'Y' && $crmManager->isLoaded())
					{
						$crmFieldsManager->setTitle($this->chat->getData('TITLE'));

$crmManager->setDefaultFlags();
						$crmManager->registrationChanges();
						$crmManager->sendCrmImMessages();
					}
					else
					{
						$crmManager->setDefaultFlags();
					}

}
				elseif ($fields['MODE'] == self::MODE_OUTPUT)
				{
					if($this->config['CRM'] == 'Y' && $crmManager->isLoaded())
					{
						$crmFieldsManager->setTitle($this->chat->getData('TITLE'));

$crmManager->registrationChanges();
						$crmManager->sendCrmImMessages();
					}
				}
				/* END CRM BLOCK */

/* Event */
				$eventData['SESSION'] = $this->session;
				$eventData['RUNTIME_SESSION'] = $this;
				$eventData['CONFIG'] = $this->config;

$event = new \Bitrix\Main\Event("imopenlines", "OnSessionStart", $eventData);
				$event->send();
				/* END Event */

if (Connector::isLiveChat($this->session['SOURCE']))
				{
					$parsedUserCode = Session\Common::parseUserCode($this->session['USER_CODE']);

\Bitrix\Pull\Event::add($this->session['USER_ID'], [
						'module_id' => 'imopenlines',
						'command' => 'sessionStart',
						'params' => [
							'chatId' => (int)$parsedUserCode['EXTERNAL_CHAT_ID'],
							'sessionId' => (int)$this->session['ID'],
						]
					]);
				}
			}
			else
			{
				$result->addErrors($resultAddSessionCheck->getErrors());
			}

}
		else
		{
			$result->addErrors($resultAdd->getErrors());
		}

Debug::addSession($this, 'end ' . __METHOD__, ['SUCCESS' => $result->isSuccess(), 'ERRORS' => $result->getErrorMessages()]);

return $result;
	}

/**
	 * @param array $params
	 * @return Result
	 * @throws Main\ArgumentException
	 * @throws Main\LoaderException
	 * @throws Main\ObjectPropertyException
	 * @throws Main\SystemException
	 */
	public function getLast(array $params): Result
	{
		$result = new Result();

if (empty($params['USER_CODE']))
		{
			$result->addError(new Error(Loc::getMessage('IMOL_SESSION_ERROR_NO_USER_CODE'), 'NO IMOL CONFIGURATION', __METHOD__));
		}

$select = Model\SessionTable::getSelectFieldsPerformance();

$orm = Model\SessionTable::getList([
			'select' => $select,
			'filter' => [
				'=USER_CODE' => $params['USER_CODE'],
			],
			'order' => ['ID' => 'DESC'],
			'limit' => 1
		]);
		$loadSession = $orm->fetch();

if (!empty($loadSession))
		{
			$loadSession['SESSION_ID'] = $loadSession['ID'];
			$this->session = $loadSession;
			$this->chat = new Chat($this->session['CHAT_ID']);

$configManager = new Config();
			$this->config = $configManager->get($loadSession['CONFIG_ID']);
		}
		else
		{
			$result->addError(new Error(Loc::getMessage('IMOL_SESSION_ERROR_NO_LAST_SESSION'), 'NO LAST SESSION', __METHOD__));
		}

return $result;
	}

/**
	 * @param $fields
	 * @param $params
	 * @return Result
	 * @throws Main\ArgumentException
	 * @throws Main\LoaderException
	 * @throws Main\ObjectException
	 * @throws Main\ObjectPropertyException
	 * @throws Main\SystemException
	 */
	protected function readingSession($fields, $params)
	{
		Debug::addSession($this, 'begin ' . __METHOD__, ['fields' => $fields, '$params' => $params]);

$result = new Result();

$result->setResult(false);
		$configManager = new Config();

$loadSession = false;

$select = Model\SessionTable::getSelectFieldsPerformance();
		$select['CHECK_DATE_CLOSE'] = 'CHECK.DATE_CLOSE';
		$select['CHECK_DATE_QUEUE'] = 'CHECK.DATE_QUEUE';

$userCode = $fields['USER_CODE'];

if(!empty($fields['USER_CODE_FAIL']))
		{
			$userCode = [$fields['USER_CODE'], $fields['USER_CODE_FAIL']];
		}

$orm = Model\SessionTable::getList([
			'select' => $select,
			'filter' => [
				'=USER_CODE' => $userCode,
				'=CLOSED' => 'N'
			],
			'order' => ['ID' => 'DESC']
		]);
		while($row = $orm->fetch())
		{
			if (
				$row['USER_CODE'] == $fields['USER_CODE'] &&
				empty($loadSession)
			)
			{
				$loadSession = $row;
			}
			//Closes non-closed sessions
			else
			{
				try
				{
					self::closeDuplicate(
						[
							'ID' => $row['ID'],
							'CHAT_ID' => $row['CHAT_ID'],
							'OPERATOR_ID' => $row['OPERATOR_ID'],
						],
						[
							'CHAT_ID' => $loadSession['CHAT_ID'],
							'OPERATOR_ID' => $loadSession['OPERATOR_ID'],
						]
					);
				}
				catch (\Exception $e)
				{
				}
			}
		}

//There is no open session, but the session voting
		if (
			empty($loadSession) &&
			(
				$params['VOTE_SESSION'] == 'Y' ||
				$params['REOPEN'] == 'Y'
			)
		)
		{
			$select = Model\SessionTable::getSelectFieldsPerformance();
			$select['CHECK_DATE_CLOSE'] = 'CHECK.DATE_CLOSE';
			$select['CHECK_DATE_QUEUE'] = 'CHECK.DATE_QUEUE';

$orm = Model\SessionTable::getList([
				'select' => $select,
				'filter' => [
					'=USER_CODE' => $fields['USER_CODE'],
					'=CLOSED' => 'Y',
				],
				'order' => ['ID' => 'DESC']
			]);
			$loadSession = $orm->fetch();

if (empty($loadSession) || $loadSession['WAIT_VOTE'] != 'Y')
			{
				$loadSession = false;
			}
		}

if ($loadSession)
		{
			$loadSession['SESSION_ID'] = $loadSession['ID'];
			$this->session = $loadSession;

if($params['VOTE_SESSION'] == 'Y')
			{
				$this->session['VOTE_SESSION'] = true;
			}

if ($fields['CONFIG_ID'] != $this->session['CONFIG_ID'])
			{
				$this->config = $configManager->get($this->session['CONFIG_ID']);
				if (!empty($this->config))
				{
					$fields['CONFIG_ID'] = $this->session['CONFIG_ID'];
				}
				else
				{
					$result->addError(new Error(Loc::getMessage('IMOL_SESSION_ERROR_NO_IMOL_CONFIGURATION'), 'NO IMOL CONFIGURATION', __METHOD__, $params));
				}
			}

if($result->isSuccess())
			{
				$this->chat = new Chat($this->session['CHAT_ID']);

//If the session is closed and voting
				if ($params['VOTE_SESSION'] == 'Y' && $loadSession['CLOSED'] == 'Y')
				{
					Messages\Session::sendMessageReopenSession($this->session['CHAT_ID'], $this->session['SESSION_ID']);

//statistics
					ConfigStatistic::getInstance($this->session['CONFIG_ID'])->deleteClosed()->addInWork();
					//statistics END

$dateClose = new DateTime();

$fullCloseTime = $this->config['FULL_CLOSE_TIME'];
					if(!empty($fullCloseTime))
					{
						$dateClose->add($fullCloseTime . ' MINUTES');
					}

$this->session['END_ID'] = 0;
					$this->session['CLOSED'] = 'N';
					$this->session['WAIT_ANSWER'] = 'N';
					$this->session['WAIT_ACTION'] = 'Y';
					$this->session['PAUSE'] = 'N';

Model\SessionTable::update($loadSession['ID'], [
						'END_ID' => 0,
						'CLOSED' => 'N',
						'WAIT_ANSWER' => 'N',
						'WAIT_ACTION' => 'Y',
						'PAUSE' => 'N',
						//'STATUS' => self::STATUS_WAIT_CLIENT
					]);
					Model\SessionCheckTable::add([
						'SESSION_ID' => $this->session['SESSION_ID'],
						'DATE_CLOSE' => $dateClose
					]);

$this->chat->sendJoinMessage($this->joinUserList);
					$this->chat->join($this->session['OPERATOR_ID'], true, true);
					$this->chat->update(['AUTHOR_ID' => $this->session['OPERATOR_ID']]);

$this->chat->updateFieldData([
						Chat::FIELD_SESSION => [
							'ID' => $this->session['SESSION_ID'],
							'PAUSE' => 'N',
							'WAIT_ANSWER' => 'N',
							'DATE_CREATE' => $this->session['DATE_CREATE']->getTimestamp()
						],
					]);
				}
				else if (!$this->chat->isNowCreated())
				{
					$this->chat->join($fields['USER_ID']);
				}

$result->setResult(true);
			}
		}

Debug::addSession($this, 'end ' . __METHOD__, ['SUCCESS' => $result->isSuccess(), 'ERRORS' => $result->getErrorMessages()]);

return $result;
	}

/**
	 * @param $params
	 * @param int $count
	 * @return bool
	 * @throws Main\ArgumentException
	 * @throws Main\ObjectPropertyException
	 * @throws Main\SystemException
	 */
	private function prepareUserChat($params, $count = 0)
	{
		$result = false;

$resultUserRelation = \Bitrix\Imopenlines\Model\UserRelationTable::getByPrimary($params['USER_CODE'])->fetch();
		if ($resultUserRelation)
		{
			if ($resultUserRelation['CHAT_ID'])
			{
				$this->chat = new Chat($resultUserRelation['CHAT_ID'], $params);
				if ($this->chat->isDataLoaded())
				{
					$this->user = $resultUserRelation;

$result = true;
				}
			}
			else if ($count <= 20)
			{
				usleep(500);
				$result = $this->prepareUserChat($params, ++$count);
			}
		}
		else if ($params['SKIP_CREATE'] != 'Y')
		{
			$params['USER_ID'] = intval($params['USER_ID']);
			\Bitrix\Imopenlines\Model\UserRelationTable::add([
				'USER_CODE' => $params['USER_CODE'],
				'USER_ID' => $params['USER_ID']
			]);

$this->chat = new Chat();
			$this->chat->load([
				'USER_CODE' => $params['USER_CODE'],
				'USER_ID' => $params['USER_ID'],
				'LINE_NAME' => $this->config['LINE_NAME'],
				'CONNECTOR' => $params['CONNECTOR'],
			]);
			if ($this->chat->isDataLoaded())
			{
				\Bitrix\Imopenlines\Model\UserRelationTable::update($params['USER_CODE'], ['CHAT_ID' => $this->chat->getData('ID')]);

$resultUserRelation = [
					'USER_CODE' => $params['USER_CODE'],
					'USER_ID' => $params['USER_ID'],
					'CHAT_ID' => $this->chat->getData('ID'),
					'AGREES' => 'N',
				];
				$this->user = $resultUserRelation;

$result = true;
			}
			else
			{
				\Bitrix\Imopenlines\Model\UserRelationTable::delete($params['USER_CODE']);
			}
		}

return $result;
	}

/**
	 * @param bool $active
	 * @return bool
	 * @throws Main\ArgumentException
	 * @throws Main\LoaderException
	 * @throws Main\ObjectException
	 * @throws Main\ObjectPropertyException
	 * @throws Main\SystemException
	 */
	public function pause($active = true)
	{
		$update = [
			'PAUSE' => $active? 'Y': 'N',
		];
		if ($active == 'Y')
		{
			$update['WAIT_ACTION'] = 'N';
		}
		$this->update($update);

Debug::addSession($this,  __METHOD__);
		$this->addEventToLog(Library::EVENT_SESSION_PAUSE);

return true;
	}

/**
	 * @return bool
	 * @throws Main\ArgumentException
	 * @throws Main\LoaderException
	 * @throws Main\ObjectException
	 * @throws Main\ObjectPropertyException
	 * @throws Main\SystemException
	 */
	public function markSpam()
	{
		$this->update([
			'SPAM' => 'Y',
			'WAIT_ANSWER' => 'N',
			'DATE_MODIFY' => new DateTime(),
		]);

Debug::addSession($this,  __METHOD__);
		$this->addEventToLog(Library::EVENT_SESSION_SPAM);

return true;
	}

/**
	 * End of dialog.
	 *
	 * @param bool $auto
	 * @param bool $force
	 * @param bool $hideChat
	 * @return bool
	 * @throws Main\ArgumentException
	 * @throws Main\LoaderException
	 * @throws Main\ObjectException
	 * @throws Main\ObjectPropertyException
	 * @throws Main\SystemException
	 */
	public function finish($auto = false, $force = false, $hideChat = true)
	{
		$result = false;

Debug::addSession($this, __METHOD__, ['auto' => $auto, 'force' => $force, 'hideChat' => $hideChat]);
		if (!empty($this->session))
		{
			KpiManager::setSessionLastKpiMessageAnswered($this->session['ID']);

$update = [];

if ($force)
			{
				$this->session['CLOSED'] = 'Y';
				$update['FORCE_CLOSE'] = 'Y';
			}

$currentDate = new DateTime();

if ($this->session['CHAT_ID'])
			{
				$chatData = \Bitrix\Im\Model\ChatTable::getById($this->session['CHAT_ID'])->fetch();
				$lastMessageId = $chatData['LAST_MESSAGE_ID'];
			}
			else
			{
				$lastMessageId = 0;
			}

if ($auto && $lastMessageId > 0)
			{
				$messageData = \Bitrix\Im\Model\MessageTable::getById($lastMessageId)->fetch();
				if ($messageData)
				{
					$currentDate = clone $messageData['DATE_CREATE'];
				}
			}

$userViewChat = \CIMContactList::InRecent($this->session['OPERATOR_ID'], IM_MESSAGE_OPEN_LINE, $this->session['CHAT_ID']);

if (
				$this->session['CLOSED'] == 'Y'
				|| $this->session['SPAM'] == 'Y'
				|| $this->session['WAIT_ACTION'] == 'Y' && $this->session['WAIT_ANSWER'] == 'N'
			)
			{
				$update['WAIT_ACTION'] = 'N';
				$update['WAIT_ANSWER'] = 'N';
				$update['CLOSED'] = 'Y';

$addMessageId = Im::addMessage([
						"TO_CHAT_ID" => $this->session['CHAT_ID'],
						"FROM_USER_ID" => $this->session['OPERATOR_ID'],
						"MESSAGE" => Loc::getMessage('IMOL_SESSION_CLOSE_FINAL'),
						"SYSTEM" => 'Y',
						"RECENT_ADD" => $userViewChat? 'Y': 'N',
						"PARAMS" => $params
					]);

if(!empty($addMessageId))
					{
						$lastMessageId = $addMessageId;
					}
				}

}
			else
			{
				$enableSystemMessage = $this->isEnableSendSystemMessage();
				if ($this->config['ACTIVE'] == 'N')
				{
					$update['WAIT_ACTION'] = 'N';
					$update['WAIT_ANSWER'] = 'N';
					$update['CLOSED'] = 'Y';

$addMessageId = Im::addMessage([
							"TO_CHAT_ID" => $this->session['CHAT_ID'],
							"FROM_USER_ID" => $this->session['OPERATOR_ID'],
							"RECENT_ADD" => $userViewChat? 'Y': 'N',
							"MESSAGE" => Loc::getMessage('IMOL_SESSION_CLOSE_FINAL'),
							"SYSTEM" => 'Y',
							"PARAMS" => $params
						]);

if(!empty($addMessageId))
						{
							$lastMessageId = $addMessageId;
						}
					}
				}
				else if ($auto)
				{
					$waitAction = false;
					if ($enableSystemMessage && $this->config['AUTO_CLOSE_RULE'] == self::RULE_TEXT)
					{
						$this->chat->update([
							Chat::getFieldName(Chat::FIELD_SILENT_MODE) => 'N'
						]);

$addMessageId = Im::addMessage([
							"TO_CHAT_ID" => $this->session['CHAT_ID'],
							"FROM_USER_ID" => $this->session['OPERATOR_ID'],
							"MESSAGE" => $this->config['AUTO_CLOSE_TEXT'],
							"SYSTEM" => 'Y',
							"RECENT_ADD" => $userViewChat? 'Y': 'N',
							"IMPORTANT_CONNECTOR" => 'Y',
							"PARAMS" => [
								"CLASS" => "bx-messenger-content-item-ol-output",
								"IMOL_FORM" => "history",
								"TYPE" => "lines",
								"COMPONENT_ID" => "bx-imopenlines-message",
							]
						]);