hierarchytable.php

<?php
namespace Bitrix\Location\Model;
 
use Bitrix\Main,
    Bitrix\Main\ORM\Fields;
use Bitrix\Main\Application;
use Bitrix\Main\ORM\Fields\Relations\Reference;
use Bitrix\Main\ORM\Query\Join;
 
 
class HierarchyTable extends Main\Entity\DataManager
{
    public static function getTableName()
    {
        return 'b_location_hierarchy';
    }
 
    public static function getMap()
    {
        return array(
 
            (new Fields\IntegerField('ANCESTOR_ID'))
                ->configurePrimary(true),
 
            (new Fields\IntegerField('DESCENDANT_ID'))
                ->configurePrimary(true),
 
            (new Fields\IntegerField('LEVEL'))
                ->configureRequired(true),
 
            // References
 
            (new Reference('ANCESTOR', LocationTable::class,
                Join::on('this.ANCESTOR_ID', 'ref.ID')))
                ->configureJoinType('inner'),
 
            (new Reference('DESCENDANT', LocationTable::class,
                Join::on('this.DESCENDANT_ID', 'ref.ID')))
                ->configureJoinType('inner')
        );
    }
 
    public static function insertBatch(array $data)
    {
        $values = [];
 
        foreach ($data as $row)
        {
            if((int)$row['ANCESTOR_ID'] <= 0 || (int)$row['DESCENDANT_ID'] <= 0)
            {
                continue;
            }
 
            $values[] = (int)$row['ANCESTOR_ID'].', '.(int)$row['DESCENDANT_ID'].', '.(int)$row['LEVEL'];
        }
 
        if(!empty($values))
        {
            $values = '(' . implode('), (', $values) . ')';
            $sql = "INSERT IGNORE INTO " . static::getTableName() . " (ANCESTOR_ID, DESCENDANT_ID, LEVEL) VALUES " . $values;
            Application::getConnection()->queryExecute($sql);
        }
    }
 
    public static function deleteByLocationId(int $locationId)
    {
        $locationId = (int)$locationId;
 
        Application::getConnection()->queryExecute("
            DELETE 
                FROM ".self::getTableName()." 
            WHERE ANCESTOR_ID=".$locationId."
                OR DESCENDANT_ID = ".$locationId
        );
    }
}