• Модуль: sender
  • Путь к файлу: ~/bitrix/modules/sender/lib/service/groupqueueservice.php
  • Класс: Bitrix\Sender\Service\GroupQueueService
  • Вызов: GroupQueueService::addToDB
public function addToDB(int $type, int $entityId, int $groupId)
{
	if (!in_array($type, GroupQueueTable::TYPE))
	{
		return;
	}
	if (!Locker::lock(self::LOCK_KEY, $entityId))
	{
		return;
	}
	
	$current = $this->getCurrentRow($type, $entityId, $groupId);
	if (isset($current['ID']) || isset($current[0]['ID']))
	{
		Locker::unlock(self::LOCK_KEY, $entityId);
		return;
	}
	
	GroupQueueTable::add([
		'TYPE' => $type,
		'ENTITY_ID' => $entityId,
		'GROUP_ID' => $groupId,
	]);
	Locker::unlock(self::LOCK_KEY, $entityId);
}