objectnormalizer.php

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

<?php
 
 
namespace Bitrix\Sale\Rest\Normalizer;
 
use Bitrix\Sale\BasketItem;
use Bitrix\Sale\Payment;
use Bitrix\Sale\PropertyValue;
use Bitrix\Sale\Shipment;
use Bitrix\Sale\ShipmentItem;
use Bitrix\Sale\ShipmentItemStore;

class ObjectNormalizer
{
    protected $externalFields;
    protected $fields;
    protected $order;
 
    public function __construct(array $data=[])
    {
        $this->externalFields = $data;
    }
 
    public function init(\Bitrix\Sale\Order $order)
    {
        $this->order = $order;
        return $this;
    }
 
    public function orderNormalize()
    {
        $externalFields = isset($this->externalFields['ORDER'][$this->getOrder()->getInternalId()])?
            $this->externalFields['ORDER'][$this->getOrder()->getInternalId()]:[];
 
        $this->fields['ORDER'] = array_merge(
            $externalFields,
            $this->getOrder()->getFieldValues()
        );
        return $this;
    }
 
    public function basketNormalize()
    {
        $r=[];

        foreach ($this->getOrder()->getBasket() as $item)
        {
            $fields = $item->getFieldValues();
            $externalFields = $this->externalFields['BASKET']['ITEMS'][$item->getInternalIndex()] ?? [];
 
            $props = [];
            foreach ($item->getPropertyCollection() as $property)
            {
                $props[] = $property->getFieldValues();
            }
 
            $reservations = [];
            $reserveQuantityCollection = $item->getReserveQuantityCollection();
            if ($reserveQuantityCollection !== null)
            {
                foreach ($item->getReserveQuantityCollection() as $reserveQuantityCollectionItem)
                {
                    $reservations[] = $reserveQuantityCollectionItem->getFieldValues();
                }
            }
            unset($reserveQuantityCollection);
 
            $r[$item->getInternalIndex()] = array_merge(
                $externalFields,
                $fields,
                [
                    'PROPERTIES' => $props,
                    'RESERVATIONS' => $reservations,
                ]
            );
        }
 
        $this->fields['ORDER']['BASKET_ITEMS']=$r;
 
        return $this;
    }
 
    public function propertiesValueNormalize()
    {
        $r=[];
        $propertyCollection = $this->getOrder()->getPropertyCollection();
        foreach ($propertyCollection as $property)
        {
            $externalFields = isset($this->externalFields['PROPERTIES'][$property->getInternalIndex()])?
                $this->externalFields['PROPERTIES'][$property->getInternalIndex()]:[];
 
            $r[$property->getInternalIndex()] = array_merge(
                    $externalFields,
                    $property->getFieldValues()
            );
        }
        $this->fields['ORDER']['PROPERTY_VALUES']=$r;
        return $this;
    }
    public function paymentsNormalize()
    {
        $r=[];
        foreach($this->getOrder()->getPaymentCollection() as $payment)
        {
            $externalFields = isset($this->externalFields['PAYMENTS'][$payment->getInternalIndex()])?
                $this->externalFields['PAYMENTS'][$payment->getInternalIndex()]:[];
 
            $r[$payment->getInternalIndex()] = array_merge(
                    $externalFields,
                    $payment->getFieldValues()
            );
        }
        $this->fields['ORDER']['PAYMENTS']=$r;
        return $this;
    }
    public function shipmentsNormalize()
    {
        $r=[];
        foreach ($this->getOrder()->getShipmentCollection() as $shipment)
        {
            // рест магазина не оперирует системными отгрузками
            if($shipment->isSystem())
                continue;
 
            $shipmentIndex = $shipment->getInternalIndex();
 
            $basketItems = [];
            foreach ($shipment->getShipmentItemCollection() as $shipmentItem)
            {
                $itemIndex = $shipmentItem->getInternalIndex();
                $stores=[];
                $storeCollection = $shipmentItem->getShipmentItemStoreCollection();
                if ($storeCollection !== null)
                {
                    foreach ($shipmentItem->getShipmentItemStoreCollection() as $shipmentItemStore)
                    {
                        $externalFieldsSIS = $this->externalFields['SHIPMENTS'][$shipmentIndex]['SHIPMENT_ITEMS'][$itemIndex]['STORE'][$shipmentItemStore->getInternalIndex()] ?? [];
 
                        $stores[] = array_merge(
                            $externalFieldsSIS,
                            $shipmentItemStore->getFieldValues()
                        );
                    }
                }
 
                $externalFieldsSI = $this->externalFields['SHIPMENTS'][$shipmentIndex]['SHIPMENT_ITEMS'][$itemIndex] ?? [];
 
                $basketItems[] = array_merge(
                        $externalFieldsSI,
                        $shipmentItem->getFieldValues(),
                        ['STORES'=>$stores]
                );
 
            }
 
            $externalFields = $this->externalFields['SHIPMENTS'][$shipmentIndex] ?? [];
 
            $r[$shipmentIndex] = array_merge(
                    $externalFields,
                    $shipment->getFieldValues(),
                    ['SHIPMENT_ITEMS'=>$basketItems]
            );
        }
        $this->fields['ORDER']['SHIPMENTS']= $r;
 
        return $this;
    }
    public function applyDiscountNormalize()
    {
        $list = $this->getOrder()
            ->getDiscount()
            ->getApplyResult(true);
        if(is_array($list) && !empty($list))
        {
            $this->fields['ORDER']['DISCOUNTS'] = $list;
        }
        return $this;
    }
    public function taxNormalize()
    {
        $list = $this->getOrder()
            ->getTax()
            ->getTaxList();
        if(is_array($list) && !empty($list))
        {
            foreach ($list as $tax)
                $this->fields['ORDER']['TAXES'][] = $tax;
        }
        return $this;
    }
    public function tradeBindingsNormalize()
    {
        $r=[];
        foreach($this->getOrder()->getTradeBindingCollection() as $item)
        {
            $externalFields = isset($this->externalFields['TRADE_BINDINGS'][$item->getInternalIndex()])?
                $this->externalFields['TRADE_BINDINGS'][$item->getInternalIndex()]:[];
 
            $r[] = array_merge(
                $externalFields,
                $item->getFieldValues()
            );
        }
 
        $this->fields['ORDER']['TRADE_BINDINGS']=$r;
        return $this;
    }
 
    public function getFields()
    {
        return $this->fields;
    }

    protected function getOrder()
    {
        return $this->order;
    }
}