batchorderadd.php

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

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

class BatchOrderAdd extends Base
{
    protected $path = "/1.0/batch/{name}/shipment";
    protected $type = HttpClient::HTTP_PUT;
    protected $name = '';
    protected $internalRequestId = 0;

    protected function convertResponse($rawData, $requestData)
    {
        $result = new Requests\Result();
        $reqRes = new Requests\RequestResult();
        $reqRes->setExternalId($this->name);
        $reqRes->setInternalId($this->internalRequestId);

        $shpResults = array();
        $errorPositions = array();
 
        if(is_array($rawData['errors']))
        {
            foreach($rawData['errors'] as $error)
            {
                if(!isset($requestData[$error['position']]))
                    continue;
 
                $internalId = $requestData[$error['position']]['order-num'];
                $errorPositions[$error['position']] = true;
 
                if(!isset($shpResults[$internalId]))
                    $shpResults[$internalId] = new Requests\ShipmentResult($internalId);
 
                if(is_array($error['error-codes']))
                {
                    $message = '';
 
                    foreach($error['error-codes'] as $errorCode)
                    {
                        $message = Reference::getErrorDescription($errorCode['code'], 'POST /1.0/user/shipment');
 
                        if(!empty($errorCode['details']) && $message.'.' != $errorCode['details'])
                        {
                            if($errorCode['code'] == 'ILLEGAL_MAIL_CATEGORY')
                                $message = str_replace('%s', Reference::getRpoCategory($errorCode['details']), $message);
                            else
                                $message .= ' ('.$errorCode['details'].')';
                        }
                    }
 
                    if($message <> '')
                        $shpResults[$internalId]->addError(new Error($message));
                }
            }
        }
 
        if(is_array($rawData['result-ids']) && is_array($requestData))
        {
            $resultIdsPosition = 0;
            $deliveryRequest = $this->deliveryService->getDeliveryRequestHandler();

            $res = $deliveryRequest->getRequestObject('BATCH')->process(array('BATCH_NAME' => $this->name));
            $listNumber = '';
            $listDate = '';
 
            if($res->isSuccess())
            {
                $batchData = $res->getData();
 
                if(!empty($batchData['list-number']))
                    $listNumber = $batchData['list-number'];
 
                if(!empty($batchData['list-number-date']))
                    $listDate = $batchData['list-number-date'];
            }

            $res =  $deliveryRequest->send('BATCH_ORDERS', array('BATCH_NAME' => $this->name));
            $batchOrders = array();
 
            if($res->isSuccess())
                $batchOrders = $res->getData();
 
            for($i = 0, $l = count($requestData); $i < $l; $i++)
            {
                if(isset($errorPositions[$i]))
                    continue;
 
                $internalId = $requestData[$i]['order-num'];
                $externalId = $rawData['result-ids'][$resultIdsPosition];
                $resultIdsPosition++;
 
                if(!isset($shpResults[$internalId]))
                {
                    $shpResults[$internalId] = new Requests\ShipmentResult($internalId, $externalId);
 
                    foreach($batchOrders as $order)
                    {
                        if($order['order-num'] == $internalId)
                        {
                            $shpResults[$internalId]->setTrackingNumber($order['barcode']);
                            break;
                        }
                    }
 
                    $shpResults[$internalId]->setDeliveryDocNum($listNumber);
                    $shpResults[$internalId]->setDeliveryDocDate($listDate);
                }
            }
        }
 
        if(!empty($shpResults))
        {
            $reqRes->addResults(array_values($shpResults));
            $result->addResult($reqRes);
        }
 
        return $result;
    }

    public function createBody(array $shipmentIds, array $additional = array())
    {
        $deliveryRequest = $this->deliveryService->getDeliveryRequestHandler();
        $orderCreateRequest = $deliveryRequest->getRequestObject('ORDER_CREATE');
        $result = $orderCreateRequest->createBody($shipmentIds, $additional);
 
        if(!$result->isSuccess())
            return $result;
 
        $data = $result->getData();
 
        if(empty($data))
            $result->addError(new Error(Loc::getMessage('SALE_DLVRS_ADD_DREQ_BOA_DATA_EMPTY')));
 
        return $result;
 
    }

    public function process(array $shipmentIds, array $additional = array())
    {
        if(empty($additional['BATCH_NAME']))
        {
            $result = new Requests\Result();
            $result->addError(new Error(Loc::getMessage('SALE_DLVRS_ADD_DREQ_BOA_BNAME_EMPTY')));
        }
        $this->path = str_replace('{name}', $additional['BATCH_NAME'], $this->path);
        $this->name = $additional['BATCH_NAME'];
        $this->internalRequestId = $additional['REQUEST_ID'];
        return parent::process($shipmentIds, $additional);
    }
}