transferproviderbase.php

<?php
 
namespace Bitrix\Sale\Internals;
 
use Bitrix\Main;
use Bitrix\Sale;
 
abstract class TransferProviderBase
{
    protected $providerClass = null;
    protected $context = null;
 
    protected function __construct()
    {
 
    }
 
    protected function getProviderClass()
    {
        return $this->providerClass;
    }
 
    protected function getProviderName()
    {
        $providerName = null;
        $providerClass = $this->providerClass;
 
        if ($providerClass)
        {
            $reflect = new \ReflectionClass($providerClass);
            $providerName = $reflect->getName();
        }
 
        return $providerName;
    }
 
    protected function getContext()
    {
        return $this->context;
    }
 
    public static function create($providerClass, array $context)
    {
        $transferProvider = new static();
        if ($providerClass)
        {
            $transferProvider->providerClass = $providerClass;
        }
 
        $transferProvider->context = $context;
 
        return $transferProvider;
    }
 
    abstract public function getProductData(array $products);
 
    abstract public function tryShip(array $products);
 
    abstract public function isNeedShip(array $products);
 
    abstract public function ship(array $products);
 
    abstract public function reserve(array $products);
 
    abstract public function deliver(array $products);
 
    abstract public function viewProduct(array $products);
 
    abstract public function getProductListStores(array $products);
 
    abstract public function setItemsResultAfterTryShip(PoolQuantity $pool, array $products, array $productTryShipList);
 
    public function setItemsResultAfterShip(array $products, Sale\Result $resultAfterShip)
    {
        $result = new Sale\Result();
 
        $needReverse = false;
        $shippedProductList = array();
        $resultData = $resultAfterShip->getData();
        if (!empty($resultData['SHIPPED_PRODUCTS_LIST']))
        {
            $shippedProductList = $resultData['SHIPPED_PRODUCTS_LIST'];
 
            foreach ($shippedProductList as $isShipped)
            {
                if ($isShipped === false)
                {
                    $needReverse = true;
                    break;
                }
            }
        }
 
        $shipmentList = array();
        $productIndex = array();
 
        foreach ($products as $productId => $itemData)
        {
            if (!empty($itemData['SHIPMENT_ITEM_LIST']))
            {
                foreach ($itemData['SHIPMENT_ITEM_LIST'] as $shipmentItemIndex => $shipmentItem)
                {
                    $basketItem = $shipmentItem->getBasketItem();
                    $shipment = $shipmentItem->getCollection()->getShipment();
 
                    if (isset($itemData['NEED_RESERVE_BY_STORE_LIST'][$shipmentItemIndex]))
                    {
                        $needReverseByStore = $itemData['NEED_RESERVE_BY_STORE_LIST'][$shipmentItemIndex];
                        foreach ($needReverseByStore as $storeId => $isNeeded)
                        {
                            $reserveQuantityCollection = $basketItem->getReserveQuantityCollection();
 
                            if (
                                $isNeeded
                                && $reserveQuantityCollection
                                && $shipment->needShip() !== Catalog\Provider::SALE_TRANSFER_PROVIDER_SHIPMENT_NEED_NOT_SHIP)
                            {
                                foreach ($reserveQuantityCollection as $reserve)
                                {
                                    if ($reserve->getStoreId() !== $storeId)
                                    {
                                        continue;
                                    }
 
                                    if (isset($itemData['STORE_DATA_LIST'][$shipmentItemIndex][$storeId]))
                                    {
                                        $reserveQuantity = $itemData['STORE_DATA_LIST'][$shipmentItemIndex][$storeId]['RESERVED_QUANTITY'];
                                    }
                                    else
                                    {
                                        $reserveQuantity = $shipmentItem->getQuantity();
                                    }
 
                                    if ($reserve->getQuantity() > $reserveQuantity)
                                    {
                                        $reserve->setFieldNoDemand('QUANTITY', $reserve->getQuantity() - $reserveQuantity);
                                    }
                                    else
                                    {
                                        $reserve->deleteNoDemand();
                                    }
                                }
                            }
                        }
 
                        if ($shipment->needShip() !== Catalog\Provider::SALE_TRANSFER_PROVIDER_SHIPMENT_NEED_NOT_SHIP)
                        {
                            $shipmentItem->getFields()->set('RESERVED_QUANTITY', 0);
                        }
                    }
 
                    $shipmentIndex = $shipment->getInternalIndex();
                    if (!array_key_exists($shipmentIndex, $shipmentList))
                    {
                        $shipmentList[$shipmentIndex] = $shipment;
                    }
 
                    if (
                        !isset($productIndex[$shipmentIndex][$shipmentItemIndex])
                        || !in_array($productId, $productIndex[$shipmentIndex][$shipmentItemIndex])
                    )
                    {
                        $productIndex[$shipmentIndex][$shipmentItemIndex] = $productId;
                    }
                }
            }
        }
 
        $reverseProducts = array();
        if ($needReverse && !empty($productIndex))
        {
            foreach ($productIndex as $productList)
            {
                foreach ($productList as $productId)
                {
                    $isExistsProduct = array_key_exists($productId, $shippedProductList);
 
                    if (
                        $isExistsProduct
                        && $shippedProductList[$productId] === true
                        && empty($reverseProducts[$productId])
                    )
                    {
                        $reverseProducts[$productId] = $products[$productId];
                        $reverseProducts[$productId]['QUANTITY'] *= -1;
                    }
                }
            }
        }
 
        if ($needReverse && !empty($reverseProducts))
        {
            $r = $this->ship($reverseProducts);
        }
 
        return $result;
    }
 
    abstract public function getAvailableQuantity(array $products);
 
    abstract public function getAvailableQuantityByStore(array $products);
 
    abstract public function getAvailableQuantityAndPrice(array $products);
 
    abstract public function getBundleItems(array $products);
 
    abstract public function getStoresCount();
 
    public function writeOffProductBatches(array $products): Sale\Result
    {
        return new Sale\Result();
    }
 
    public function returnProductBatches(array $products): Sale\Result
    {
        return new Sale\Result();
    }
}