extraservicesservice.php

<?php
 
namespace Bitrix\Sale\Delivery\Rest;
 
use Bitrix\Main;
use Bitrix\Sale;
use Bitrix\Rest\RestException;
use Bitrix\Rest\AccessException;
 
if (!Main\Loader::includeModule('rest'))
{
    return;
}
 
class ExtraServicesService extends BaseService
{
    private const ERROR_EXTRA_SERVICE_ADD = 'ERROR_EXTRA_SERVICE_ADD';
    private const ERROR_EXTRA_SERVICE_UPDATE = 'ERROR_EXTRA_SERVICE_UPDATE';
    private const ERROR_EXTRA_SERVICE_DELETE = 'ERROR_EXTRA_SERVICE_DELETE';
 
    private const ERROR_CHECK_FAILURE = 'ERROR_CHECK_FAILURE';
    private const ERROR_EXTRA_SERVICE_NOT_FOUND = 'ERROR_EXTRA_SERVICE_NOT_FOUND';
    private const ERROR_DELIVERY_NOT_FOUND = 'ERROR_DELIVERY_NOT_FOUND';
 
    private const ENUM_TYPE = 'enum';
    private const CHECKBOX_TYPE = 'checkbox';
    private const QUANTITY_TYPE = 'quantity';
 
    public static function addExtraServices($query, $n, \CRestServer $server)
    {
        self::checkDeliveryPermission();
        $params = self::prepareExtraServicesParams($query, $server);
 
        if (empty($params['DELIVERY_ID']))
        {
            throw new RestException('Parameter DELIVERY_ID is not defined', self::ERROR_CHECK_FAILURE);
        }
 
        if (empty($params['NAME']))
        {
            throw new RestException('Parameter NAME is not defined', self::ERROR_CHECK_FAILURE);
        }
 
        $extraServiceType = $params['TYPE'] ?? null;
        if (!$extraServiceType)
        {
            throw new RestException('Parameter TYPE is not defined', self::ERROR_CHECK_FAILURE);
        }
 
        $extraServicesTypeMap = self::getExtraServicesTypeMap();
        if (empty($extraServicesTypeMap[$extraServiceType]))
        {
            throw new RestException('Parameter TYPE is unknown', self::ERROR_CHECK_FAILURE);
        }
 
        if ($params['TYPE'] === self::ENUM_TYPE)
        {
            if (!isset($params['ITEMS']) || !is_array($params['ITEMS']) || empty($params['ITEMS']))
            {
                throw new RestException('Parameter ITEMS must be defined for enum type', self::ERROR_CHECK_FAILURE);
            }
        }
 
        $deliveryService = Sale\Delivery\Services\Manager::getById($params['DELIVERY_ID']);
        if ($deliveryService)
        {
            if (!self::hasAccessToDelivery($deliveryService, $params['APP_ID']))
            {
                throw new AccessException();
            }
        }
        else
        {
            throw new RestException('Delivery not found', self::ERROR_DELIVERY_NOT_FOUND);
        }
 
        if (!empty($params['CODE']))
        {
            $extraServiceData = Sale\Delivery\ExtraServices\Table::getList([
                'select' => ['ID'],
                'filter' => [
                    '=DELIVERY_ID' => $params['DELIVERY_ID'],
                    '=CODE' => $params['CODE'],
                ],
                'limit' => 1,
            ])->fetch();
            if ($extraServiceData)
            {
                throw new RestException(
                    'CODE "' . $params['CODE'] . '" already exists for this delivery',
                    self::ERROR_CHECK_FAILURE
                );
            }
        }
 
        $fields = Sale\Delivery\ExtraServices\Manager::prepareParamsToSave([
            'CLASS_NAME' => $extraServicesTypeMap[$params['TYPE']],
            'DELIVERY_ID' => $params['DELIVERY_ID'],
            'NAME' => $params['NAME'],
            'ACTIVE' => (!empty($params['ACTIVE']) && $params['ACTIVE'] === 'Y') ? 'Y' : 'N',
            'CODE' => $params['CODE'] ?? '',
            'DESCRIPTION' => $params['DESCRIPTION'] ?? '',
            'PARAMS' => self::makeInternalParams($params['TYPE'], $params),
            'SORT' => $params['SORT'] ? (int)$params['SORT'] : 100,
            'RIGHTS' => [
                Sale\Delivery\ExtraServices\Manager::RIGHTS_ADMIN_IDX => 'Y',
                Sale\Delivery\ExtraServices\Manager::RIGHTS_MANAGER_IDX => 'Y',
                Sale\Delivery\ExtraServices\Manager::RIGHTS_CLIENT_IDX => 'Y',
            ],
        ]);
        $result = Sale\Delivery\ExtraServices\Table::add($fields);
        if ($result->isSuccess())
        {
            return $result->getId();
        }
 
        $error = implode("\n", $result->getErrorMessages());
        throw new RestException($error, self::ERROR_EXTRA_SERVICE_ADD);
    }
 
    public static function updateExtraServices($query, $n, \CRestServer $server)
    {
        self::checkDeliveryPermission();
        $params = self::prepareExtraServicesParams($query, $server);
 
        if (empty($params['ID']))
        {
            throw new RestException('Parameter ID is not defined', self::ERROR_CHECK_FAILURE);
        }
 
        $extraService = Sale\Delivery\ExtraServices\Table::getList([
            'select' => ['ID', 'CODE', 'DELIVERY_ID', 'CLASS_NAME'],
            'filter' => [
                '=ID' => $params['ID'],
            ],
            'limit' => 1,
        ])->fetch();
        if ($extraService)
        {
            $deliveryService = Sale\Delivery\Services\Manager::getById($extraService['DELIVERY_ID']);
            if ($deliveryService && !self::hasAccessToDelivery($deliveryService, $params['APP_ID']))
            {
                throw new AccessException();
            }
 
            $newCode = $params['CODE'] ?? '';
            if ($newCode)
            {
                $existingExtraService = Sale\Delivery\ExtraServices\Table::getList([
                    'select' => ['ID'],
                    'filter' => [
                        '=DELIVERY_ID' => $extraService['DELIVERY_ID'],
                        '=CODE' => $newCode,
                    ],
                    'limit' => 1,
                ])->fetch();
                if ($existingExtraService && (int)$existingExtraService['ID'] !== (int)$params['ID'])
                {
                    throw new RestException(
                        'FIELDS[CODE] "' . $newCode . '" already exists for this delivery',
                        self::ERROR_CHECK_FAILURE
                    );
                }
            }
        }
        else
        {
            throw new RestException('Extra service not found', self::ERROR_EXTRA_SERVICE_NOT_FOUND);
        }
 
        $extraServicesTypeMap = array_flip(self::getExtraServicesTypeMap());
 
        if (!isset($extraServicesTypeMap[$extraService['CLASS_NAME']]))
        {
            throw new RestException('Unknown type', self::ERROR_CHECK_FAILURE);
        }
        $type = $extraServicesTypeMap[$extraService['CLASS_NAME']];
 
        $fields = [];
 
        if (!empty($params['NAME']))
        {
            $fields['NAME'] = $params['NAME'];
        }
 
        if (!empty($params['ACTIVE']))
        {
            $fields['ACTIVE'] = $params['ACTIVE'] === 'Y' ? 'Y' : 'N';
        }
 
        if (isset($params['DESCRIPTION']))
        {
            $fields['DESCRIPTION'] = $params['DESCRIPTION'];
        }
 
        if (!empty($params['SORT']))
        {
            $fields['SORT'] = (int)$params['SORT'];
        }
 
        if (isset($params['CODE']))
        {
            $fields['CODE'] = $params['CODE'];
        }
 
        $internalParams = self::makeInternalParams($type, $params);
        if (!is_null($internalParams))
        {
            $fields['PARAMS'] = $internalParams;
        }
 
        $fields = Sale\Delivery\ExtraServices\Manager::prepareParamsToSave($fields);
 
        $result = Sale\Delivery\ExtraServices\Table::update($params['ID'], $fields);
        if ($result->isSuccess())
        {
            return true;
        }
 
        $error = implode("\n", $result->getErrorMessages());
        throw new RestException($error, self::ERROR_EXTRA_SERVICE_UPDATE);
    }
 
    public static function deleteExtraServices($query, $n, \CRestServer $server)
    {
        self::checkDeliveryPermission();
        $params = self::prepareExtraServicesParams($query, $server);
 
        if (empty($params['ID']))
        {
            throw new RestException('Parameter ID is not defined', self::ERROR_CHECK_FAILURE);
        }
 
        $extraService = Sale\Delivery\ExtraServices\Table::getById($params['ID'])->fetch();
        if ($extraService)
        {
            $data = Sale\Delivery\Services\Manager::getById($extraService['DELIVERY_ID']);
            if ($data && !self::hasAccessToDelivery($data, $params['APP_ID']))
            {
                throw new AccessException();
            }
        }
        else
        {
            throw new RestException('Extra service not found', self::ERROR_EXTRA_SERVICE_NOT_FOUND);
        }
 
        $result = Sale\Delivery\ExtraServices\Table::delete($params['ID']);
        if ($result->isSuccess())
        {
            return true;
        }
 
        $error = implode("\n", $result->getErrorMessages());
        throw new RestException($error, self::ERROR_EXTRA_SERVICE_DELETE);
    }
 
    public static function get($query, $n, \CRestServer $server): array
    {
        self::checkDeliveryPermission();
        $params = self::prepareIncomingParams($query);
 
        if (empty($params['DELIVERY_ID']))
        {
            throw new RestException('Parameter DELIVERY_ID is not defined', self::ERROR_CHECK_FAILURE);
        }
 
        $data = Sale\Delivery\Services\Manager::getById($params['DELIVERY_ID']);
        if (!$data)
        {
            throw new RestException('Delivery not found', self::ERROR_DELIVERY_NOT_FOUND);
        }
 
        $esClasses = Sale\Delivery\ExtraServices\Manager::getClassesList();
 
        $extraServices = Sale\Delivery\ExtraServices\Table::getList([
            'filter' => [
                '=DELIVERY_ID' => $params['DELIVERY_ID'],
                '=CLASS_NAME' => $esClasses
            ],
            'select' => ['ID', 'CODE', 'NAME', 'DESCRIPTION', 'CLASS_NAME', 'ACTIVE', 'SORT', 'PARAMS'],
            'order' => [
                'SORT' => 'ASC',
            ],
        ])->fetchAll();
 
        $extraServicesTypeMap = array_flip(self::getExtraServicesTypeMap());
 
        foreach ($extraServices as $key => $extraService)
        {
            $type = $extraServicesTypeMap[$extraService['CLASS_NAME']];
            $extraServices[$key]['TYPE'] = $type;
            unset($extraServices[$key]['CLASS_NAME']);
 
            if ($type === self::ENUM_TYPE)
            {
                if (array_key_exists('PRICES', $extraServices[$key]['PARAMS']))
                {
                    if (is_array($extraServices[$key]['PARAMS']['PRICES']))
                    {
                        $extraServices[$key]['ITEMS'] = [];
                        foreach ($extraServices[$key]['PARAMS']['PRICES'] as $price)
                        {
                            $extraServices[$key]['ITEMS'][] = [
                                'TITLE' => $price['TITLE'],
                                'CODE' => $price['CODE'],
                                'PRICE' => $price['PRICE'] ?? null,
                            ];
                        }
                    }
                }
            }
            elseif (in_array($type, [self::CHECKBOX_TYPE, self::QUANTITY_TYPE]))
            {
                if (array_key_exists('PRICE', $extraServices[$key]['PARAMS']))
                {
                    $extraServices[$key]['PRICE'] = $extraServices[$key]['PARAMS']['PRICE'];
                }
            }
            unset($extraServices[$key]['PARAMS']);
        }
 
        return $extraServices ?: [];
    }
 
    private static function makeInternalParams(string $type, array $params): ?array
    {
        $result = null;
 
        if ($type === self::ENUM_TYPE)
        {
            if (is_array($params['ITEMS']))
            {
                $result = [
                    'PRICES' => [],
                ];
 
                foreach ($params['ITEMS'] as $item)
                {
                    if (!isset($item['TITLE']) || empty($item['TITLE']))
                    {
                        throw new RestException('Item title must be defined for enum item', self::ERROR_CHECK_FAILURE);
                    }
 
                    if (!isset($item['CODE']) || empty($item['CODE']))
                    {
                        throw new RestException('Item code must be defined for enum item', self::ERROR_CHECK_FAILURE);
                    }
 
                    $result['PRICES'][$item['CODE']] = [
                        'TITLE' => $item['TITLE'],
                        'CODE' => $item['CODE'],
                        'PRICE' => isset($item['PRICE']) ? (float)$item['PRICE'] : null,
                    ];
                }
            }
        }
        elseif (in_array($type, [self::CHECKBOX_TYPE, self::QUANTITY_TYPE]) && array_key_exists('PRICE', $params))
        {
            $result['PRICE'] = isset($params['PRICE']) ? (float)$params['PRICE'] : null;
        }
 
        return $result;
    }
 
    private static function getExtraServicesTypeMap(): array
    {
        $result = [];
 
        $allowedTypes = [
            self::ENUM_TYPE,
            self::CHECKBOX_TYPE,
            self::QUANTITY_TYPE,
        ];
        $esClasses = Sale\Delivery\ExtraServices\Manager::getClassesList();
        foreach ($esClasses as $className)
        {
            $classCode = (new \ReflectionClass($className))->getShortName();
            $type = mb_strtolower($classCode);
            if (!in_array($type, $allowedTypes, true))
            {
                continue;
            }
            $result[$type] = $className;
        }
 
        return $result;
    }
 
    private static function prepareExtraServicesParams(array $data, \CRestServer $server): array
    {
        $data = self::prepareIncomingParams($data);
        $data['APP_ID'] = $server->getClientId();
 
        return $data;
    }
}