geonametable.php

<?php
 
namespace Bitrix\Main\Service\GeoIp\Internal;
 
use Bitrix\Main\ORM\Data;
use Bitrix\Main\ORM\Fields;
use Bitrix\Main\Text\UtfConverter;
 
class GeonameTable extends Data\DataManager
{
    use Data\Internal\MergeTrait;
 
    public static function getTableName()
    {
        return 'b_geoname';
    }
 
    public static function getMap()
    {
        return [
            (new Fields\IntegerField('ID'))
                ->configurePrimary(),
            (new Fields\StringField('LANGUAGE_CODE'))
                ->configurePrimary(),
            (new Fields\StringField('NAME')),
        ];
    }
 
    public static function save(array $data): void
    {
        $existing = static::get(array_keys($data), false);
 
        foreach ($data as $geoid => $names)
        {
            if (is_array($names))
            {
                foreach ($names as $lang => $name)
                {
                    if (!isset($existing[$geoid][$lang]) || $existing[$geoid][$lang] != $name)
                    {
                        $insert = [
                            'ID' => $geoid,
                            'LANGUAGE_CODE' => $lang,
                            'NAME' => $name,
                        ];
                        $update = [
                            'NAME' => $name,
                        ];
                        static::merge($insert, $update);
                    }
                }
            }
        }
    }
 
    public static function get(array $ids, bool $decode = true): array
    {
        $existing = [];
 
        if (!empty($ids))
        {
            $query = static::query()
                ->setSelect(['*'])
                ->whereIn('ID', $ids)
                ->exec()
            ;
 
            $converter = ($decode? new UtfConverter(): null);
 
            while ($record = $query->fetch($converter))
            {
                $existing[$record['ID']][$record['LANGUAGE_CODE']] = $record['NAME'];
            }
        }
 
        return $existing;
    }
}