ordercreate.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 Bitrix\Sale\Delivery\Packing\Packer;
use Sale\Handlers\Delivery\AdditionalHandler;
use Sale\Handlers\Delivery\Additional\DeliveryRequests\RusPost\Reference;
use Sale\Handlers\Delivery\Additional\DeliveryRequests\RusPost\Handler;
 
Loc::loadMessages(__FILE__);

class OrderCreate extends Base
{
    protected $path = "/1.0/user/backlog";
    protected $type = HttpClient::HTTP_PUT;
    protected $deliveryService = null;

    protected function convertResponse($rawData, $requestData)
    {
        $result = new Requests\Result();
        $errorPositions = array();
        $createResults = array();
 
        if(is_array($rawData['errors']))
        {
            foreach($rawData['errors'] as $error)
            {
                if(!isset($requestData[$error['position']]['order-num']))
                    continue;
 
                $internalId = $requestData[$error['position']]['order-num'];
 
                if(!isset($createResults[$internalId]))
                    $createResults[$internalId] = new Requests\ShipmentResult($internalId, '');
 
                $errorPositions[] = $error['position'];
 
                if(is_array($error['error-codes']))
                {
                    foreach($error['error-codes'] as $errorcode)
                    {
                        $message = Reference::getErrorDescription($errorcode['code'], 'PUT /1.0/user/backlog');
 
                        if(!empty($errorcode['details']))
                            $details = $errorcode['details'];
                        elseif(!empty($errorcode['description']))
                            $details = $errorcode['description'];
                        else
                            $details = '';
 
                        if(!empty($details))
                        {
                            if($errorcode['code'] == 'ILLEGAL_MAIL_CATEGORY')
                                $message = str_replace('%s', Reference::getRpoCategory($details), $message);
                            else
                                $message .= ' ('.$details.')';
                        }
 
                        $createResults[$internalId]->addError(new Error($message));
                    }
                }
            }
        }
 
        $idsMap = $this->getShipmentsMap($rawData['result-ids'], $errorPositions, $requestData);
        $idsMapFlipped = array_flip($idsMap);
 
        if(is_array($rawData['result-ids']))
        {
            foreach($rawData['result-ids'] as $externalId)
            {
                if(!isset($idsMapFlipped[$externalId]))
                    continue;
 
                $internalId = $idsMapFlipped[$externalId];
 
                if(!isset($createResults[$internalId]))
                    $createResults[$internalId] = new Requests\ShipmentResult($internalId, $externalId);
            }
        }
 
        $result->setResults($createResults);
        return $result;
    }

    protected function getShipmentsMap($successIds, $errorPositions, $requestData)
    {
        $idsMap = array();
 
        if(empty($successIds) || !is_array($successIds))
            return array();
 
        $shift = 0;
 
        foreach($requestData as $position => $request)
        {
            if(!empty($errorPositions) && in_array($position, $errorPositions))
            {
                $shift++;
                continue;
            }
 
            if(!empty($requestData[$position]['order-num']) && !empty($successIds[$position - $shift]))
                $idsMap[$request['order-num']] = $successIds[$position - $shift];
        }
 
        return $idsMap;
    }

    protected function normalizeAddresses(array $addresses)
    {
        $requestData = array();
 
        foreach($addresses as $id => $address)
        {
            $address = str_replace(["\n", "\t", "\r"], " ", $address);
 
            $requestData[] = array(
                'id' => $id,
                'original-address' => $address
            );
        }

        $deliveryRequest = $this->deliveryService->getDeliveryRequestHandler();
        return $deliveryRequest->send('CLEAN_ADDRESS', $requestData);
    }

    protected function normalizeFios(array $fios)
    {
        $requestData = array();
 
        foreach($fios as $id => $fio)
        {
            $requestData[] = array(
                'id' => $id,
                'original-fio' => $fio
            );
        }

        $deliveryRequest = $this->deliveryService->getDeliveryRequestHandler();
        return $deliveryRequest->send('NORMALIZE_FIO', $requestData);
    }

    protected function isAddressGood(array $address)
    {
        $quality = $address['quality-code'] == 'GOOD'
            || $address['quality-code'] == 'POSTAL_BOX'
            || $address['quality-code'] == 'ON_DEMAND'
            || $address['quality-code'] == 'UNDEF_05';
 
        $valid = $address['validation-code'] == 'VALIDATED'
            || $address['validation-code'] == 'OVERRIDDEN'
            || $address['validation-code'] == 'CONFIRMED_MANUALLY';
 
        return $quality && $valid;
    }

    public function createBody(array $shipmentIds, array $additional = array())
    {
        $result = new Requests\Result();
        $resultData = array();
        $shipments = Requests\Helper::getShipmentsByIds($shipmentIds);
        $rpoCategory = Reference::getRpoCategoriesMap();
        $qualityCodes = Reference::getQualityCodesList();
        $addresses = array();
        $fios = array();
        $notValidShipmentIds = array();

        foreach($shipments as $shipment)
        {
            $shipmentParams = AdditionalHandler::getShipmentParams($shipment, $this->deliveryService->getServiceType());
            $deliveryConfig = $shipment->getDelivery() ? $shipment->getDelivery()->getConfig() : [];
            $shipmentId = $shipment->getId();
 
            $mailType = $deliveryConfig['MAIN']['ITEMS']['OTPRAVKA_RPO']['VALUE'];
 
            if($mailType == '')
            {
                $shpResult = new Requests\ShipmentResult($shipmentId);
                $shpResult->addError(
                    new Error(
                        Loc::getMessage(
                            'SALE_DLVRS_ADD_DREQ_ROC_NOT_SUPPORTED',
                            array(
                                '#DELIVERY_PROFILE_LINK#' =>
                                    Requests\Helper::getDeliveryEditLink($shipment->getDeliveryId(), $shipmentParams['DELIVERY_SERVICE_CONFIG']['MAIN']['NAME']),
                            )
                )));
 
                $result->addResult($shpResult);
                continue;
            }
 
            $shpDim = array();
 
            foreach($shipmentParams['ITEMS'] as $item)
            {
                if(!empty($item['DIMENSIONS']) && is_array($item['DIMENSIONS']))
                {
                    if(intval($item['DIMENSIONS']['HEIGHT']) > 0
                        && intval($item['DIMENSIONS']['WIDTH']) > 0
                        && intval($item['DIMENSIONS']['LENGTH']) > 0)
                    {
                        for($i=0; $i < $item['QUANTITY']; $i++)
                        {
                            $shpDim[] = array(
                                intval($item['DIMENSIONS']['LENGTH']),
                                intval($item['DIMENSIONS']['WIDTH']),
                                intval($item['DIMENSIONS']['HEIGHT'])
                            );
                        }
                    }
                }
            }
 
            $mailCategory = $rpoCategory[$shipmentParams['DELIVERY_SERVICE_CONFIG']['MAIN']['CATEGORY']];
 
            if($mailCategory == '')
                $mailCategory = 'ORDINARY';
 
            $item = array(
                'address-type-to' => 'DEFAULT',
                //'brand-name' => ''
                //'envelope-type' =>
                'fragile' => isset($shipmentParams['EXTRA_SERVICES'][4]) && $shipmentParams['EXTRA_SERVICES'][4] =='Y', // 4 - code of extra service fragile
                'mail-category' => $mailCategory,
                'order-num' => strval($shipmentParams['SHIPMENT_ID']),
                'sms-notice-recipient' => isset($shipmentParams['EXTRA_SERVICES'][42]) && $shipmentParams['EXTRA_SERVICES'][4] == 'Y' ? 1 : 0,
                'mail-direct' => 643, //Russia
                'mail-type' => $mailType
            );
 
            $item['courier'] = isset($shipmentParams['EXTRA_SERVICES'][26]) && $shipmentParams['EXTRA_SERVICES'][26] == 'Y';
 
            if(isset($shipmentParams['EXTRA_SERVICES'][1]))
            {
                if($shipmentParams['EXTRA_SERVICES'][1] == "1")
                    $item['with-simple-notice'] = true;
                elseif($shipmentParams['EXTRA_SERVICES'][1] == "2")
                    $item['with-order-of-notice'] = true;
            }
 
            if(intval($shipmentParams['WEIGHT']) > 0)
            {
                $item['mass'] = intval($shipmentParams['WEIGHT']);
            }
            else
            {
                $dlvConfig = $this->deliveryService->getConfigValues();
 
                if(intval($dlvConfig['MAIN']['WEIGHT_DEFAULT']) > 0)
                    $item['mass'] = intval($dlvConfig['MAIN']['WEIGHT_DEFAULT']);
            }
 
            if(!empty($shpDim))
            {
                $dimensions = Packer::countMinContainerSize($shpDim);
 
                $item['dimension'] = array(
                    'length' => $dimensions[0]/10, //milimeters ->santimeters
                    'width' => $dimensions[1]/10,
                    'height' => $dimensions[2]/10
                );
            }
            else
            {
                $dlvConfig = $this->deliveryService->getConfigValues();
 
                if(intval($dlvConfig['MAIN']['LENGTH_DEFAULT']) > 0
                    && intval($dlvConfig['MAIN']['WIDTH_DEFAULT']) > 0
                    && intval($dlvConfig['MAIN']['HEIGHT_DEFAULT']) > 0)
                {
                    $item['dimension'] = array(
                        'length' => intval($dlvConfig['MAIN']['LENGTH_DEFAULT']/10), //milimeters ->santimeters
                        'width' => intval($dlvConfig['MAIN']['WIDTH_DEFAULT']/10),
                        'height' => intval($dlvConfig['MAIN']['HEIGHT_DEFAULT']/10)
                    );
                }
            }
 
            $OVERSIZED_DIM = 60;
            $OVERSIZED_DIM_SUM = 120;
 
            if($item['dimension']['length'] < $OVERSIZED_DIM
                && $item['dimension']['width'] < $OVERSIZED_DIM
                && $item['dimension']['height'] < $OVERSIZED_DIM
                && array_sum($item['dimension']) < $OVERSIZED_DIM_SUM
            )
            {
                unset($item['dimension']);
            }
 
            if(!empty($additional['OPS']))
                $item['postoffice-code'] = $additional['OPS'];
 
            if(!empty($shipmentParams['PHONE']))
                $item['tel-address'] = preg_replace('/[^\d]/','',$shipmentParams['PHONE']);
 
            $price = ($shipmentParams['PRICE'] + $shipmentParams['PRICE_DELIVERY']) * 100; //rubles -> kopeck
 
            if($shipmentParams['DELIVERY_SERVICE_CONFIG']['MAIN']['CATEGORY'] == 2 || $shipmentParams['DELIVERY_SERVICE_CONFIG']['MAIN']['CATEGORY'] == 4)
                $item['insr-value'] = $price; // https://www.pochta.ru/support/post-rules/valuable-departure
 
            if($shipmentParams['DELIVERY_SERVICE_CONFIG']['MAIN']['CATEGORY'] == 4)
                $item['payment'] = $price;
 
            if (!empty($shipmentParams['LOCATION_TO_TYPES']['REGION']))
            {
                $item['region-to'] = $this->convertLocationTypeToString($shipmentParams['LOCATION_TO_TYPES']['REGION']);
            }
 
            if (!empty($shipmentParams['LOCATION_TO_TYPES']['SUBREGION']))
            {
                $item['area-to'] = $this->convertLocationTypeToString($shipmentParams['LOCATION_TO_TYPES']['SUBREGION']);
            }
 
            if (!empty($shipmentParams['LOCATION_TO_TYPES']['STREET']))
            {
                $item['street-to'] = $this->convertLocationTypeToString($shipmentParams['LOCATION_TO_TYPES']['STREET']);
            }
 
            if (!empty($shipmentParams['LOCATION_TO_TYPES']['VILLAGE']))
            {
                $item['place-to'] = $this->convertLocationTypeToString($shipmentParams['LOCATION_TO_TYPES']['VILLAGE']);
            }
            elseif (!empty($shipmentParams['LOCATION_TO_TYPES']['CITY']))
            {
                $item['place-to'] = $this->convertLocationTypeToString($shipmentParams['LOCATION_TO_TYPES']['CITY']);
            }
 
            if (!empty($shipmentParams['ZIP_TO']))
            {
                $item['index-to'] = $shipmentParams['ZIP_TO'];
            }
 
            $address = '';
            $types = ['COUNTRY', 'REGION', 'SUBREGION', 'CITY', 'VILLAGE', 'STREET'];
 
            foreach($types as $type)
            {
                if (empty($shipmentParams['LOCATION_TO_TYPES'][$type]))
                {
                    continue;
                }
 
                if ($address <> '')
                {
                    $address .= ', ';
                }
 
                $address .= $this->convertLocationTypeToString($shipmentParams['LOCATION_TO_TYPES'][$type]);
            }
 
            if(!empty($shipmentParams['ADDRESS']))
            {
                if($address <> '')
                    $address .= ', ';
 
                $address .= $shipmentParams['ADDRESS'];
            }
 
            $addresses[$shipment->getId()] = $address;
            $fios[$shipment->getId()] = $shipmentParams['PAYER_NAME'];
            $resultData[$shipment->getId()] = $item;
        }
 
        if(!empty($resultData))
        {
            $normalizeResult = $this->normalizeAddresses($addresses);
 
            if(!$normalizeResult->isSuccess())
            {
                $result->addErrors($normalizeResult->getErrors());
                return $result;
            }
            else
            {
                foreach($normalizeResult->getData() as $address)
                {
                    $shipmentId = $address['id'];
 
                    if(!isset($resultData[$shipmentId]))
                        continue;
 
                    if(!$this->isAddressGood($address))
                    {
                        $shpResult = new Requests\ShipmentResult($shipmentId);
                        $shpResult->addError(new Error(
                            $qualityCodes[$address['quality-code']].'. '.Loc::getMessage('SALE_DLVRS_ADD_DREQ_ROC_02').'. "'.
                            print_r($address['original-address'], true).'"',
                            $shipmentId
                        ));
                        $result->addResult($shpResult);
                        $notValidShipmentIds[$shipmentId] = true;
                        continue;
                    }
 
                    if(!empty($address['area']) && empty($resultData[$shipmentId]['area-to']))
                        $resultData[$shipmentId]['area-to'] =  $address['area'];
 
                    if(!empty($address['house']))
                        $resultData[$shipmentId]['house-to'] =  $address['house'];
 
                    if(!empty($address['place']))
                        $resultData[$shipmentId]['place-to'] =  $address['place'];
 
                    if(!empty($address['region']) && empty($resultData[$shipmentId]['region-to']))
                        $resultData[$shipmentId]['region-to'] =  $address['region'];
 
                    if(!empty($address['room']))
                        $resultData[$shipmentId]['room-to'] =  $address['room'];
 
                    if(!empty($address['slash']))
                        $resultData[$shipmentId]['slash-to'] =  $address['slash'];
 
                    if(!empty($address['building']))
                        $resultData[$shipmentId]['building-to'] =  $address['building'];
 
                    if(!empty($address['corpus']))
                        $resultData[$shipmentId]['corpus-to'] =  $address['corpus'];
 
                    if(!empty($address['hotel']))
                        $resultData[$shipmentId]['hotel-to'] =  $address['hotel'];
 
                    if(!empty($address['letter']))
                        $resultData[$shipmentId]['letter-to'] =  $address['letter'];
 
                    if(!empty($address['location']))
                        $resultData[$shipmentId]['location-to'] =  $address['location'];
 
                    if(!empty($address['street']) && empty($resultData[$shipmentId]['street-to']))
                        $resultData[$shipmentId]['street-to'] =  $address['street'];
 
                    if(!empty($address['place']) && empty($resultData[$shipmentId]['place-to']))
                        $resultData[$shipmentId]['place-to'] =  $address['place'];
 
                    if(!empty($address['index']) && empty($resultData[$shipmentId]['index-to']))
                        $resultData[$shipmentId]['index-to'] =  $address['index'];
 
                    if(!empty($address['num-address-type']))
                        $resultData[$shipmentId]['num-address-type-to'] =  $address['num-address-type'];
                }
            }
 
            $normalizeResult = $this->normalizeFios($fios);
 
            if(!$normalizeResult->isSuccess())
            {
                $result->addErrors($normalizeResult->getErrors());
                return $result;
            }
 
            foreach($normalizeResult->getData() as $fio)
            {
                $shipmentId = $fio['id'];
 
                if(!isset($resultData[$shipmentId]) || $notValidShipmentIds[$shipmentId])
                    continue;
 
                if((!isset($fio["valid"]) || $fio["valid"] !== false) && $fio["quality-code"] != 'NOT_SURE' )
                {
                    if(!empty($fio['middle-name']))
                        $resultData[$shipmentId]['middle-name'] =  $fio['middle-name'];
 
                    if(!empty($fio['surname']))
                        $resultData[$shipmentId]['surname'] =  $fio['surname'];
 
                    if(!empty($fio['name']))
                        $resultData[$shipmentId]['given-name'] =  $fio['name'];
                }
 
                $resultData[$shipmentId]['recipient-name'] =  $fio['original-fio'];
            }
        }
 
        if(!empty($notValidShipmentIds))
            foreach($notValidShipmentIds as $shipmentId => $t)
                unset($resultData[$shipmentId]);
 
        if(!empty($resultData))
            $result->setData(array_values($resultData));
        else
            $result->addError(new Error(Loc::getMessage('SALE_DLVRS_ADD_DREQ_ROC_DATA_EMPTY')));
 
        return $result;
    }

    private function convertLocationTypeToString(array $locationTypeComponent): string
    {
        return implode(', ', $locationTypeComponent);
    }
}