requesthandler.php

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

<?php
 
namespace Sale\Handlers\Delivery\Rest;
 
use Bitrix\Main;
use Bitrix\Main\Localization\Loc;
use Bitrix\Sale\Delivery\Requests\HandlerBase;
use Bitrix\Sale\Delivery\Requests\RequestResult;
use Bitrix\Sale\Delivery\Requests\Result;
use Bitrix\Sale;
use Bitrix\Sale\Delivery\Requests\ShipmentResult;
use Sale\Handlers\Delivery\Rest\DataProviders;
 
Loc::loadMessages(__FILE__);
 
/***
 * Class RequestHandler
 * @package Sale\Handlers\Delivery
 */
class RequestHandler extends HandlerBase
{
    private $createRequestUrl;

    private $cancelRequestUrl;

    private $cancelActionName;

    private $deleteRequestUrl;

    private $hasCallbackTrackingSupport = false;

    public function setCreateRequestUrl(string $createRequestUrl): RequestHandler
    {
        $this->createRequestUrl = $createRequestUrl;
        return $this;
    }

    public function setCancelRequestUrl(string $cancelRequestUrl): RequestHandler
    {
        $this->cancelRequestUrl = $cancelRequestUrl;
        return $this;
    }

    public function setCancelActionName(string $cancelActionName): RequestHandler
    {
        $this->cancelActionName = $cancelActionName;
        return $this;
    }

    public function setDeleteRequestUrl(string $deleteRequestUrl): RequestHandler
    {
        $this->deleteRequestUrl = $deleteRequestUrl;
        return $this;
    }

    public function setHasCallbackTrackingSupport(bool $hasCallbackTrackingSupport): RequestHandler
    {
        $this->hasCallbackTrackingSupport = $hasCallbackTrackingSupport;
        return $this;
    }

    public function create(array $shipmentIds, array $additional = [])
    {
        $result = new Result();
 
        if (!$this->createRequestUrl)
        {
            return $result->addError(new Main\Error(
                Loc::getMessage('SALE_DELIVERY_REST_REQUEST_HANDLER_ACTION_NOT_SUPPORTED'))
            );
        }
 
        $shipments = Sale\Repository\ShipmentRepository::getInstance()->getByIds($shipmentIds);
        if (empty($shipments))
        {
            return $result->addError(new Main\Error(
                Loc::getMessage('SALE_DELIVERY_REST_REQUEST_SHIPMENTS_NOT_FOUND'))
            );
        }
 
        $responseResult = Sale\Helpers\Rest\Http::sendRequest(
            $this->createRequestUrl,
            [
                'SHIPMENTS' => array_map(
                    function ($shipment) { return DataProviders\Shipment::getData($shipment); },
                    $shipments
                ),
            ],
            [
                'JSON_REQUEST' => true,
            ]
        );
        if (!$responseResult->isSuccess())
        {
            return $result->addError(new Main\Error(Loc::getMessage('SALE_DELIVERY_REST_REQUEST_NETWORK_ERROR')));
        }
 
        $responseData = $responseResult->getData();
        self::preProcessResponse($responseData, $result);
 
        if (
            !isset($responseData['REQUEST_ID'])
            || !is_string($responseData['REQUEST_ID'])
            || empty($responseData['REQUEST_ID'])
        )
        {
            return $result->addError(
                new Main\Error(Loc::getMessage('SALE_DELIVERY_REST_REQUEST_REQUEST_ID_NOT_SPECIFIED'))
            );
        }
 
        $requestResult = new RequestResult();
        $requestResult->setExternalId($responseData['REQUEST_ID']);
        foreach ($shipments as $shipment)
        {
            $requestResult->addResult(new ShipmentResult($shipment->getId()));
        }
        $result->addResult($requestResult);
 
        return $result;
    }

    public function getActions($requestId)
    {
        return [
            $this->getCancelActionCode() => $this->getCancelActionName()
        ];
    }

    public function executeAction($requestId, $actionType, array $additional)
    {
        if ($actionType === $this->getCancelActionCode())
        {
            return $this->cancelRequest($requestId);
        }
 
        return parent::executeAction($requestId, $actionType, $additional);
    }

    private function cancelRequest($requestId): Result
    {
        $result = new Result();
 
        if (!$this->cancelRequestUrl)
        {
            return $result->addError(new Main\Error(
                Loc::getMessage('SALE_DELIVERY_REST_REQUEST_HANDLER_ACTION_NOT_SUPPORTED'))
            );
        }
 
        $request = Sale\Delivery\Requests\RequestTable::getById($requestId)->fetch();
        if (!$request)
        {
            return $result->addError(
                new Main\Error(Loc::getMessage('SALE_DELIVERY_REST_REQUEST_HANDLER_REQUEST_NOT_FOUND'))
            );
        }
 
        $responseResult = Sale\Helpers\Rest\Http::sendRequest(
            $this->cancelRequestUrl,
            [
                'DELIVERY_ID' => $request['DELIVERY_ID'],
                'REQUEST_ID' => $request['EXTERNAL_ID'],
            ],
            [
                'JSON_REQUEST' => true,
            ]
        );
        if (!$responseResult->isSuccess())
        {
            return $result->addError(new Main\Error(Loc::getMessage('SALE_DELIVERY_REST_REQUEST_NETWORK_ERROR')));
        }
 
        self::preProcessResponse($responseResult->getData(), $result);
 
        return $result;
    }

    public function delete($requestId)
    {
        $result = new Result();
 
        if (!$this->deleteRequestUrl)
        {
            return $result;
        }
 
        $request = Sale\Delivery\Requests\RequestTable::getById($requestId)->fetch();
        if (!$request)
        {
            return $result->addError(
                new Main\Error(Loc::getMessage('SALE_DELIVERY_REST_REQUEST_HANDLER_REQUEST_NOT_FOUND'))
            );
        }
 
        $responseResult = Sale\Helpers\Rest\Http::sendRequest(
            $this->deleteRequestUrl,
            [
                'DELIVERY_ID' => $request['DELIVERY_ID'],
                'REQUEST_ID' => $request['EXTERNAL_ID'],
            ],
            [
                'JSON_REQUEST' => true,
            ]
        );
        if (!$responseResult->isSuccess())
        {
            return $result->addError(new Main\Error(Loc::getMessage('SALE_DELIVERY_REST_REQUEST_NETWORK_ERROR')));
        }
 
        self::preProcessResponse($responseResult->getData(), $result);
 
        return $result;
    }

    private static function preProcessResponse(array $responseData, \Bitrix\Main\Result $result): void
    {
        if (!(isset($responseData['SUCCESS']) && $responseData['SUCCESS'] === 'Y'))
        {
            $errorText = (
                isset($responseData['REASON']['TEXT'])
                && is_string($responseData['REASON']['TEXT'])
                && !empty($responseData['REASON']['TEXT'])
            )
                ? $responseData['REASON']['TEXT']
                : Loc::getMessage('SALE_DELIVERY_REST_REQUEST_UNKNOWN_ERROR');
 
            $result->addError(new Main\Error($errorText));
        }
    }

    public function hasCallbackTrackingSupport(): bool
    {
        return $this->hasCallbackTrackingSupport;
    }
}