- Модуль: tasks
- Путь к файлу: ~/bitrix/modules/tasks/lib/internals/counter/queue/queue.php
- Класс: BitrixTasksInternalsCounterQueueQueue
- Вызов: Queue::add
public function add(int $userId, string $type, array $tasks): void
{
$req = [];
foreach ($tasks as $taskId)
{
$req[] = $userId .',"'. $type .'",' . (int) $taskId;
}
$sql = "
INSERT INTO `". QueueTable::getTableName(). "`
(`USER_ID`, `TYPE`, `TASK_ID`)
VALUES
(". implode("),(", $req) .")
";
Application::getConnection()->query($sql);
self::$inQueue[$userId] = true;
}