.-.-.-.-.-

<?php

namespace Bitrix\Voximplant;

use Bitrix\Main\ArgumentException;
use Bitrix\Main\DB\SqlExpression;
use Bitrix\Main\Event;
use Bitrix\Voximplant\Model\CallTable;

class CallQueue
{
	/**
	 * @param $userId
	 * @return Result|bool
	 * @throws ArgumentException
	 */
	public static function dequeueFirstUserCall($userId)
	{
		$call = static::getCallToDequeue($userId);
		if(!$call)
		{
			return false;
		}

return $call->dequeue($userId);
	}

/**
	 * Search for the call, that could be possibly routed to the user.
	 *
	 * @param int $userId Id of the user.
	 * @return Call|false Returns the found call or false if nothing is found.
	 * @throws ArgumentException
	 */
	public static function getCallToDequeue($userId)
	{
		$isDayOpen = \CVoxImplantUser::GetActiveStatusByTimeman($userId);

$query = CallTable::query()
			->setSelect(['CALL_ID'])
			->where('STATUS', CallTable::STATUS_ENQUEUED)
			->where('DATE_CREATE', '>', new SqlExpression("date_sub(now(), interval 1 hour)"))
			->where('QUEUE.\Bitrix\Voximplant\Model\QueueUserTable:QUEUE.USER_ID', $userId)
			->setOrder(['ID' => 'asc'])
			->setLimit(1);

if(!$isDayOpen)
		{
			$query->where('CONFIG.TIMEMAN', 'N');
		}

$cursor = $query->exec();
		$row = $cursor->fetch();
		if(!$row)
		{
			return false;
		}
		return Call::load($row['CALL_ID']);
	}

/**
	 * Returns call position in it's current queue.
	 * @param int $callId Id of the call
	 * @return int
	 * @throws ArgumentException
	 */
	public static function getCallPosition($callId)
	{
		$call = Call::load($callId);
		if(!$call)
		{
			throw new ArgumentException("Call " . $callId . " is not found");
		}

$row = Model\CallTable::getRow([
			'select' => [
				'CNT' => new \Bitrix\Main\Entity\ExpressionField('CNT', 'count(\'*\')')
			],
			'filter' => [
				'=STATUS' => Model\CallTable::STATUS_ENQUEUED,
				'=QUEUE_ID' => $call->getQueueId(),
				'>DATE_CREATE' => new SqlExpression("date_sub(now(), interval 1 hour)"),
				'<ID' => $call->getId()
			]
		]);

return $row['CNT'] + 1;
	}

/**
	 * OnUserSetLastActivityDate event handler.
	 * Checks for enqueued calls that could be assigned to this user.
	 * @param Event $event Event object.
	 * @return void
	 */
	public static function onUserSetLastActivityDate(Event $event)
	{
		global $USER;
		if(!isset($USER) || !($USER instanceof \CUser))
		{
			return;
		}

$users = $event->getParameter(0);
		foreach ($users as $userId)
		{
			if($userId == $USER->GetID())
			{
				if($USER->isJustBecameOnline())
				{
					static::dequeueFirstUserCall($USER->GetID());
				}
			}
		}
	}

/**
	 * OnAfterTMDayStart event handler.
	 * Checks for enqueued calls that could be assigned to this user.
	 * @param $event Event object.
	 * @throws ArgumentException
	 */
	public static function onAfterTMDayStart($event)
	{
		$userId = (int)$event['USER_ID'];
		static::dequeueFirstUserCall($userId);
	}

/**
	 * OnAfterTMDayContinue event handler.
	 * Checks for enqueued calls that could be assigned to this user.
	 * @param $event Event object.
	 * @throws ArgumentException
	 */
	public static function onAfterTMDayContinue($event)
	{
		$userId = (int)$event['USER_ID'];
		static::dequeueFirstUserCall($userId);
	}
}

/var/www/axolotl/data/www/yar.axolotls.ru/bitrix/js/../modules/voximplant/lib/callqueue.php