handler.php

См. документацию.

<?php
 
namespace Sale\Handlers\Delivery;
 
use Bitrix\Main\Error;
use Bitrix\Main\Loader;
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\ModuleManager;
use Bitrix\Main\Result;
use Bitrix\Sale\Delivery\Services\Base;
use Bitrix\Sale\Delivery\Services\Manager;
use Bitrix\Sale\Delivery\Services\Table;
use Sale\Handlers\Delivery\YandexTaxi\Api\Tariffs\Repository;
use Sale\Handlers\Delivery\YandexTaxi\Common\TariffNameBuilder;
use Sale\Handlers\Delivery\YandexTaxi\EventJournal\JournalProcessor;
use Sale\Handlers\Delivery\YandexTaxi\Installer\Installer;
use Sale\Handlers\Delivery\YandexTaxi\ServiceContainer;
 
Loader::registerAutoLoadClasses(
    'sale',
    [
        __NAMESPACE__.'\YandextaxiProfile' => 'handlers/delivery/yandextaxi/profile.php',
    ]
);
 
Loc::loadMessages(__FILE__);

final class YandextaxiHandler extends Base
{
    protected $handlerCode = 'BITRIX_YANDEX_TAXI';
 
    // @TODO get rid of the constant
    public const SERVICE_CODE = 'YANDEX_TAXI';

    protected static $canHasProfiles = true;

    private $journalProcessor;

    private $installer;

    private $tariffsRepository;

    private $tariffNameBuilder;

    public function __construct(array $initParams)
    {
        parent::__construct($initParams);
 
        if (isset($initParams['CONFIG']['MAIN']['OAUTH_TOKEN']))
        {
            ServiceContainer::getOauthTokenProvider()->setToken($initParams['CONFIG']['MAIN']['OAUTH_TOKEN']);
        }
 
        $this->journalProcessor = ServiceContainer::getJournalProcessor();
        $this->installer = ServiceContainer::getInstaller();
        $this->tariffsRepository = ServiceContainer::getTariffsRepository();
        $this->tariffNameBuilder = ServiceContainer::getTariffNameBuilder();
    }

    public static function getClassTitle()
    {
        return Loc::getMessage('SALE_YANDEX_TAXI_TITLE');
    }

    public static function getClassDescription()
    {
        return Loc::getMessage('SALE_YANDEX_TAXI_TITLE');
    }

    public static function onBeforeAdd(array &$fields = array()): Result
    {
        $result = new Result();
 
        if (!ModuleManager::isModuleInstalled('location'))
        {
            return $result->addError(
                new Error(
                    Loc::getMessage('SALE_YANDEX_TAXI_LOCATION_MODULE_REQUIRED')
                )
            );
        }
 
        $fields['CODE'] = static::SERVICE_CODE;
 
        return $result;
    }

    public static function onAfterAdd($serviceId, array $fields = [])
    {
        $instance = Manager::getObjectById($serviceId);
        if (!$instance)
        {
            return false;
        }
 
        return $instance->installer->install($serviceId)->isSuccess();
    }

    public static function onBeforeUpdate($serviceId, array &$fields = array())
    {
        $service = Table::getList([
            'filter' => ['=ID' =>  $serviceId]
        ])->fetch();
 
        if (
            $service
            && isset($fields['CONFIG']['MAIN']['OAUTH_TOKEN'])
            && isset($service['CONFIG']['MAIN']['OAUTH_TOKEN'])
            && $fields['CONFIG']['MAIN']['OAUTH_TOKEN'] !== $service['CONFIG']['MAIN']['OAUTH_TOKEN']
        )
        {
            $fields['CONFIG']['MAIN']['CURSOR'] = '';
        }
 
        return true;
    }

    public static function onAfterDelete($serviceId)
    {
        $instance = Manager::getObjectById($serviceId);
        if (!$instance)
        {
            return false;
        }
 
        \CAgent::RemoveAgent(
            $instance->journalProcessor->getAgentName($serviceId),
            'sale'
        );
 
        return true;
    }

    public function getYandexTaxiJournalProcessor(): JournalProcessor
    {
        return $this->journalProcessor;
    }

    protected function getConfigStructure()
    {
        return [
            'MAIN' => [
                'TITLE' => Loc::getMessage('SALE_YANDEX_TAXI_AUTH'),
                'DESCRIPTION' => Loc::getMessage('SALE_YANDEX_TAXI_AUTH'),
                'ITEMS' => [
                    'OAUTH_TOKEN' => [
                        'TYPE' => 'STRING',
                        'NAME' => Loc::getMessage('SALE_YANDEX_TAXI_AUTH_TOKEN'),
                        "REQUIRED" => true,
                    ],
                    'CURSOR' => [
                        'TYPE' => 'STRING',
                        'NAME' => 'History Journal Cursor',
                        'REQUIRED' => false,
                        'HIDDEN' => true,
                    ]
                ]
            ]
        ];
    }

    public static function isHandlerCompatible()
    {
        return (
            in_array(ServiceContainer::getRegionFinder()->getCurrentRegion(), ['ru', 'kz', 'by'])
            && ModuleManager::isModuleInstalled('crm') && Loader::includeModule('crm')
        );
    }

    public static function canHasProfiles()
    {
        return self::$canHasProfiles;
    }

    public static function getChildrenClassNames(): array
    {
        return [
            '\Sale\Handlers\Delivery\YandextaxiProfile'
        ];
    }

    public function getProfilesList(): array
    {
        $result = [];
 
        $tariffs = $this->tariffsRepository->getTariffs();
        foreach ($tariffs as $tariff)
        {
            $result[$tariff['name']] = $this->tariffNameBuilder->getTariffName($tariff);
        }
 
        return $result;
    }
}