base.php

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

<?
namespace Sale\Handlers\Delivery\Additional\DeliveryRequests\RusPost\Requests;
 
use Bitrix\Main\Error;
use Bitrix\Main\Web\Json;
use Bitrix\Sale\Delivery;
use Bitrix\Main\Web\HttpClient;
use Bitrix\Main\Localization\Loc;
use Bitrix\Sale\Delivery\Requests;
use Sale\Handlers\Delivery\AdditionalHandler;
 
Loc::loadMessages(__FILE__);

abstract class Base
{
    protected $httpClient = null;
    protected $url = "https://otpravka-api.pochta.ru";
 
    protected $path = "";
    protected $type = "";

    protected $deliveryService = null;

    public function __construct(Delivery\Services\Base $deliveryService, HttpClient $httpClient)
    {
        $this->deliveryService = $deliveryService;
        $deliveryConfig = $deliveryService->getConfigValues();
 
        $this->httpClient = $httpClient;
 
        $this->httpClient->setHeader("Authorization", "AccessToken ".$deliveryConfig['MAIN']['OTPRAVKA_AUTH_TOKEN']);
        $this->httpClient->setHeader("X-User-Authorization", "Basic ".$deliveryConfig['MAIN']['OTPRAVKA_AUTH_KEY']);
        $this->httpClient->setHeader("Content-Type", "application/json;charset=UTF-8");
    }

    protected function getUrl()
    {
        return $this->url.$this->path;
    }

    protected function convertResponse($rawData, $requestData)
    {
        $result = new Requests\Result();
        $result->setData($rawData);
        return $result;
    }

    public function process(array $shipmentIds, array $additional = array())
    {
        $bodyResult = $this->createBody($shipmentIds, $additional);
 
        if(!$bodyResult->isSuccess())
            return $bodyResult;
 
        $result = $this->send($bodyResult->getData(), $additional);
        $result->addResults($bodyResult->getResults());
        return $result;
    }

    public function createBody(array $shipmentIds, array $additional = array())
    {
        return new Requests\Result();
    }

    public function send(array $requestData = array(), array $additional = array())
    {
        $result = new Requests\Result();
        $jsonData = !empty($requestData) ? Json::encode($requestData) : null;
        $httpRes = false;
 
        if(@$this->httpClient->query($this->type, $this->getUrl(), $jsonData))
        {
            $httpRes = $this->httpClient->getResult();
        }
 
        $errors = $this->httpClient->getError();
 
        if(!$httpRes && !empty($errors))
        {
            foreach($errors as $errorCode => $errMes)
            {
                if($errMes == 'Socket connection error.')
                {
                    $errMes =  Loc::getMessage(
                        'SALE_DLVRS_ADD_DREQ_RBASE_SEND_ERROR',
                        array('#URL#' => $this->url)
                    );
                }
 
                $result->addError(new Error($errMes, $errorCode));
            }
        }
        else
        {
            $response = array();
 
            try
            {
                $response = Json::decode($httpRes);
            }
            catch(\Exception $e)
            {
                $result->addError(new Error($e->getMessage()));
            }
 
            $status = $this->httpClient->getStatus();
 
            if ($status != 200)
            {
                $message = '';
 
                if($status == 404)
                {
                    $message = Loc::getMessage('SALE_DLVRS_ADD_DREQ_RBASE_01');
 
                    if(!empty($response))
                        if($response['code'] == '1001' && $response['sub-code'] == 'RESOURCE_NOT_FOUND')
                            $message = Loc::getMessage('SALE_DLVRS_ADD_DREQ_RBASE_02');
                }
                elseif($status == 401)
                {
                    $message = Loc::getMessage('SALE_DLVRS_ADD_DREQ_RBASE_03');;
                }
                elseif($status == 500)
                {
                    $message = Loc::getMessage('SALE_DLVRS_ADD_DREQ_RBASE_INTERNAL_ERROR');;
                }
 
                if($message == '')
                    $message = $message.' ('.Loc::getMessage('SALE_DLVRS_ADD_DREQ_RBASE_HTTP_STATUS').' '.$status.')';
 
                $result->addError(new Error($message,'STATUS_'.$status));
            }
            else
            {
                $convertResult = $this->convertResponse($response, $requestData);
 
                if(!$convertResult->isSuccess())
                    $result->addErrors($convertResult->getErrors());
 
                $result->addResults($convertResult->getResults());
                $result->setData($convertResult->getData());
            }
        }
 
        return $result;
    }

    public function getFormFields(array $entityIds)
    {
        return array();
    }
}