transferprovider.php

<?php
 
namespace Bitrix\Sale\Internals;
 
use Bitrix\Catalog;
use Bitrix\Sale;
use Bitrix\Main;
 
 
class TransferProvider extends TransferProviderBase
{
 
    private function callProviderMethod($methodName, array $products = array())
    {
        $providerClass = $this->getProviderClass();
        if (!method_exists($providerClass, $methodName))
        {
            throw new Main\ArgumentOutOfRangeException('methodName');
        }
        return $providerClass->$methodName($products);
    }
 
    public function tryShip(array $products)
    {
        return $this->callProviderMethod('tryShip', $products);
    }
 
    public function isNeedShip(array $products)
    {
        return $this->callProviderMethod('isNeedShip', $products);
    }
 
    public function ship(array $products)
    {
        return $this->callProviderMethod('ship', $products);
    }
 
    public function checkBarcode(array $items)
    {
        return $this->callProviderMethod('checkBarcode', $items);
    }
 
 
    public function reserve(array $products)
    {
        return $this->callProviderMethod('reserve', $products);
    }
 
    public function deliver(array $products)
    {
        return $this->callProviderMethod('deliver', $products);
    }
 
    public function viewProduct(array $products)
    {
        return $this->callProviderMethod('viewProduct', $products);
    }
 
    public function recurring(array $products)
    {
        return $this->callProviderMethod('recurring', $products);
    }
 
    public function getProductListStores(array $products)
    {
        return $this->callProviderMethod('getProductListStores', $products);
    }
 
    public function setItemsResultAfterTryShip(PoolQuantity $pool, array $products, array $productTryList)
    {
        return static::setItemsResultAfterTryShipByCoefficient($pool, $products, $productTryList, 1);
    }
 
    public function setItemsResultAfterTryUnship(PoolQuantity $pool, array $products, array $productTryList)
    {
        return static::setItemsResultAfterTryShipByCoefficient($pool, $products, $productTryList, -1);
    }
 
    private function setItemsResultAfterTryShipByCoefficient(PoolQuantity $pool, array $products, array $productTryList, $coefficient)
    {
        foreach ($products as $productId => $productData)
        {
            if (!isset($productTryList[$productId]))
            {
                continue;
            }
 
            if (empty($productData['SHIPMENT_ITEM_DATA_LIST']))
                continue;
 
            foreach ($productData['SHIPMENT_ITEM_DATA_LIST'] as $shipmentItemIndex => $shipmentItemQuantity)
            {
                $quantity = $coefficient * $shipmentItemQuantity;
                $pool->add(PoolQuantity::POOL_QUANTITY_TYPE, $productId, $quantity);
            }
        }
 
        return new Sale\Result();
    }
 
    public function setItemsResultAfterGetData(array $products, Sale\Result $reserveResult)
    {
        return new Sale\Result();
    }
 
    public function getAvailableQuantity(array $products)
    {
        $result = $this->callProviderMethod('getAvailableQuantity', $products);
 
        $resultData = $result->getData();
        if (!array_key_exists('AVAILABLE_QUANTITY_LIST', $resultData))
        {
            return $result;
        }
 
        return $result->setData(['AVAILABLE_QUANTITY_LIST' => $resultData['AVAILABLE_QUANTITY_LIST']]);
    }
 
    public function getAvailableQuantityByStore(array $products)
    {
        $result = $this->callProviderMethod('getAvailableQuantityByStore', $products);
 
        $resultData = $result->getData();
        if (!array_key_exists('AVAILABLE_QUANTITY_LIST_BY_STORE', $resultData))
        {
            return $result;
        }
 
        return $result->setData(['AVAILABLE_QUANTITY_LIST_BY_STORE' => $resultData['AVAILABLE_QUANTITY_LIST_BY_STORE']]);
    }
 
    public function getAvailableQuantityAndPrice(array $products)
    {
        $result = $this->callProviderMethod('getAvailableQuantityAndPrice', $products);
 
        $resultData = $result->getData();
 
        return $result->setData([
            'PRODUCT_DATA_LIST' => [
                'PRICE_LIST' => $resultData['PRODUCT_DATA_LIST']['PRICE_LIST'],
                'AVAILABLE_QUANTITY_LIST' => $resultData['PRODUCT_DATA_LIST']['AVAILABLE_QUANTITY_LIST']
            ]
        ]);
    }
 
    public function getProductData(array $products)
    {
        return $this->callProviderMethod('getProductData', $products);
    }
 
    public function getBundleItems(array $products)
    {
        return $this->callProviderMethod('getBundleItems', $products);
    }
 
    public function getStoresCount()
    {
        return $this->callProviderMethod('getStoresCount');
    }
 
    public function writeOffProductBatches(array $products): Sale\Result
    {
        return $this->callProviderMethod('writeOffProductBatches', $products);
    }
 
    public function returnProductBatches(array $products): Sale\Result
    {
        return $this->callProviderMethod('returnProductBatches', $products);
    }
}