| Server IP : 37.220.80.31 / Your IP : 3.141.201.106 Web Server : Apache/2.4.52 (Ubuntu) System : Linux 3051455-guretool.twc1.net 5.15.0-107-generic #117-Ubuntu SMP Fri Apr 26 12:26:49 UTC 2024 x86_64 User : www-root ( 1010) PHP Version : 7.4.33 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority, MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /var/www/www-root/data/www/dev.artlot24.ru/bitrix/modules/sale/lib/internals/ |
Upload File : |
<?php
namespace Bitrix\Sale\Internals;
use Bitrix\Main;
use Bitrix\Sale;
/**
* Class ProviderCreator
* @package Bitrix\Sale\Internals
*/
class ProviderCreator
{
private $context = array();
private $pool = array();
/**
* @param array $context
*
* @return static
*/
public static function create(array $context)
{
$creator = new static();
$creator->context = $context;
return $creator;
}
/**
* @param Sale\BasketItemBase $basketItem
*/
public function addBasketItem(Sale\BasketItemBase $basketItem)
{
$providerName = $basketItem->getProviderName();
if (empty($providerName))
{
$providerName = $basketItem->getCallbackFunction();
}
$builder = $this->createBuilder($providerName);
$builder->addProductByBasketItem($basketItem);
}
/**
* @param Sale\ShipmentItem $shipmentItem
*/
public function addShipmentItem(Sale\ShipmentItem $shipmentItem)
{
$basketItem = $shipmentItem->getBasketItem();
if (!$basketItem)
{
return;
}
$providerName = $basketItem->getProviderName();
if (empty($providerName))
{
$providerName = $basketItem->getCallbackFunction();
}
$builder = $this->createBuilder($providerName);
$builder->addProductByShipmentItem($shipmentItem);
}
/**
* @param array $shipmentProductData
*/
public function addShipmentProductData(array $shipmentProductData)
{
$builder = $this->createBuilder($shipmentProductData['PROVIDER_NAME']);
$builder->addProductByShipmentProductData($shipmentProductData);
}
/**
* @param array $productData
*
* @throws Main\ArgumentNullException
*/
public function addProductData(array $productData)
{
if (empty($productData['PRODUCT_ID']))
{
throw new Main\ArgumentNullException('PRODUCT_ID');
}
if (empty($productData['PROVIDER_NAME']))
{
throw new Main\ArgumentNullException('PROVIDER_NAME');
}
$builder = $this->createBuilder($productData['PROVIDER_NAME']);
$builder->addProductById($productData['PRODUCT_ID']);
}
/**
* @param Sale\BasketItem $basketItem
* @param array $barcodeParams
*/
public function addBasketItemBarcodeData(Sale\BasketItem $basketItem, array $barcodeParams)
{
$providerName = $basketItem->getProviderName();
if (empty($providerName))
{
$providerName = $basketItem->getCallbackFunction();
}
$builder = $this->createBuilder($providerName);
$builder->addBasketItemBarcodeData($barcodeParams);
}
/**
* @param Sale\ShipmentItem $shipmentItem
* @param array $needShipList
*
* @return array
* @throws Main\ObjectNotFoundException
*/
public function createItemForShip(Sale\ShipmentItem $shipmentItem, array $needShipList = [])
{
$basketItem = $shipmentItem->getBasketItem();
/** @var Sale\ShipmentItemCollection $shipmentItemCollection */
$shipmentItemCollection = $shipmentItem->getCollection();
if (!$shipmentItemCollection)
{
throw new Main\ObjectNotFoundException('Entity "ShipmentItemCollection" not found');
}
$shipment = $shipmentItemCollection->getShipment();
if (!$shipment)
{
throw new Main\ObjectNotFoundException('Entity "Shipment" not found');
}
$quantity = floatval($shipmentItem->getQuantity());
if ($shipment->needShip() == Sale\Internals\Catalog\Provider::SALE_TRANSFER_PROVIDER_SHIPMENT_NEED_SHIP)
{
if ($quantity > 0)
{
$quantity *= -1;
}
}
$providerName = $basketItem->getProviderName();
$providerName = static::clearProviderName($providerName);
if (empty($needShipList[$providerName]) && $shipmentItem->getReservedQuantity() > 0)
{
$quantity = 0;
}
return array(
'PROVIDER_NAME' => $basketItem->getProviderName(),
'SHIPMENT_ITEM' => $shipmentItem,
'QUANTITY' => $quantity,
'RESERVED_QUANTITY' => $shipmentItem->getReservedQuantity(),
'NEED_RESERVE' => $shipmentItem->needReserve(),
);
}
/**
* @param Sale\ShipmentItem $shipmentItem
*
* @return array
* @throws Main\ObjectNotFoundException
*/
public function createItemForReserve(Sale\ShipmentItem $shipmentItem)
{
return $this->createMapForReserve($shipmentItem);
}
/**
* @param Sale\ShipmentItem $shipmentItem
*
* @return array
* @throws Main\ObjectNotFoundException
*/
public function createItemForUnreserve(Sale\ShipmentItem $shipmentItem)
{
return $this->createMapForReserve($shipmentItem, false);
}
/**
* @param Sale\ShipmentItem $shipmentItem
* @param bool $reserve
*
* @return array
* @throws Main\ObjectNotFoundException
*/
private function createMapForReserve(Sale\ShipmentItem $shipmentItem, $reserve = true)
{
$basketItem = $shipmentItem->getBasketItem();
/** @var Sale\ShipmentItemCollection $shipmentItemCollection */
$shipmentItemCollection = $shipmentItem->getCollection();
if (!$shipmentItemCollection)
{
throw new Main\ObjectNotFoundException('Entity "ShipmentItemCollection" not found');
}
$shipment = $shipmentItemCollection->getShipment();
if (!$shipment)
{
throw new Main\ObjectNotFoundException('Entity "Shipment" not found');
}
$quantity = floatval($shipmentItem->getQuantity() - $shipmentItem->getReservedQuantity());
if (!$reserve)
{
$quantity = -1 * $shipmentItem->getReservedQuantity();
}
return array(
'PROVIDER_NAME' => $basketItem->getProviderName(),
'SHIPMENT_ITEM' => $shipmentItem,
'QUANTITY' => $quantity,
'RESERVED_QUANTITY' => $shipmentItem->getReservedQuantity(),
);
}
/**
* @return Sale\Result
*/
public function getProductData()
{
return $this->callBuilderMethod('getProductData', 'PRODUCT_DATA_LIST');
}
/**
* @return Sale\Result
*/
public function getAvailableQuantity()
{
return $this->callBuilderMethod('getAvailableQuantity', 'AVAILABLE_QUANTITY_LIST');
}
/**
* @return Sale\Result
*/
public function getAvailableQuantityAndPrice()
{
return $this->callBuilderMethod('getAvailableQuantityAndPrice', 'PRODUCT_DATA_LIST');
}
/**
* @param PoolQuantity $pool
* @param array $productTryShipList
*
* @return Sale\Result
*/
public function setItemsResultAfterTryShip(PoolQuantity $pool, array $productTryShipList)
{
$result = new Sale\Result();
/** @var ProviderBuilderBase $builder */
foreach ($this->pool as $builder)
{
$providerName = $builder->getProviderName();
if (!$productTryShipList[$providerName])
{
continue;
}
$r = $builder->setItemsResultAfterTryShip($pool, $productTryShipList[$providerName]);
if (!$r->isSuccess())
{
$result->addErrors($r->getErrors());
}
}
return $result;
}
/**
* @param Sale\Result $resultAfterReserve
*
* @return Sale\Result
*/
public function setItemsResultAfterReserve(Sale\Result $resultAfterReserve)
{
return $this->callBuilderMethod('setItemsResultAfterReserve', 'RESULT_AFTER_RESERVE_LIST', $resultAfterReserve);
}
/**
* @param Sale\Result $resultAfterShip
*
* @return Sale\Result
*/
public function setItemsResultAfterShip(Sale\Result $resultAfterShip)
{
return $this->callBuilderMethod('setItemsResultAfterShip', 'RESULT_AFTER_SHIP_LIST', $resultAfterShip);
}
/**
* @param Sale\Result $resultAfterDeliver
*
* @return Sale\Result
*/
public function createItemsResultAfterDeliver(Sale\Result $resultAfterDeliver)
{
return $this->callBuilderMethod('createItemsResultAfterDeliver', 'RESULT_AFTER_DELIVER_LIST', $resultAfterDeliver);
}
/**
* @return Sale\Result
*/
public function tryShip()
{
return $this->callBuilderMethod('tryShip', 'TRY_SHIP_PRODUCTS_LIST');
}
/**
* @return Sale\Result
*/
public function isNeedShip()
{
return $this->callBuilderMethod('isNeedShip', 'IS_NEED_SHIP');
}
/**
* @return Sale\Result
*/
public function checkBarcode()
{
return $this->callBuilderMethod('checkBarcode', 'BARCODE_CHECK_LIST');
}
/**
* @return Sale\Result
*/
public function reserve()
{
return $this->callBuilderMethod('reserve', 'RESERVED_PRODUCTS_LIST');
}
/**
* @return Sale\Result
*/
public function ship()
{
return $this->callBuilderMethod('ship', 'SHIPPED_PRODUCTS_LIST');
}
/**
* @return Sale\Result
*/
public function getBundleItems()
{
return $this->callBuilderMethod('getBundleItems', 'BUNDLE_LIST');
}
/**
* @return Sale\Result
*/
public function deliver()
{
return $this->callBuilderMethod('deliver', 'DELIVER_PRODUCTS_LIST');
}
/**
* @return Sale\Result
*/
public function viewProduct()
{
return $this->callBuilderMethod('viewProduct', 'VIEW_PRODUCTS_LIST');
}
/**
* @return Sale\Result
*/
public function getProductStores()
{
return $this->callBuilderMethod('getProductStores', 'PRODUCT_STORES_LIST');
}
/**
* @return Sale\Result
*/
public function recurring()
{
return $this->callBuilderMethod('recurring', 'RECURRING_PRODUCTS_LIST');
}
/**
* @param Sale\Result $resultAfterDeliver
*
* @return Sale\Result
*/
public function createItemsResultAfterRecurring(Sale\Result $resultAfterDeliver)
{
return $this->callBuilderMethod('createItemsResultAfterDeliver', 'RESULT_AFTER_DELIVER_LIST', $resultAfterDeliver);
}
/**
* @param $method
* @param $outputName
* @param null $methodParameters
*
* @return Sale\Result
* @throws Main\ArgumentOutOfRangeException
*/
private function callBuilderMethod($method, $outputName, $methodParameters = null)
{
$result = new Sale\Result();
$resultList = array();
/** @var ProviderBuilderBase $builder */
foreach ($this->pool as $builder)
{
if (!method_exists($builder, $method))
{
throw new Main\ArgumentOutOfRangeException('method');
}
if (!$methodParameters)
{
/** @var Sale\Result $r */
$r = $builder->$method($outputName);
}
else
{
/** @var Sale\Result $r */
$r = $builder->$method($methodParameters);
}
if (!$r->isSuccess())
{
$result->addErrors($r->getErrors());
}
if ($r->hasWarnings())
{
$result->addWarnings($r->getWarnings());
}
$data = $r->getData();
if (!empty($data))
{
$providerName = null;
$providerClass = $builder->getProviderClass();
if ($providerClass)
{
$reflect = new \ReflectionClass($providerClass);
$providerName = $this->clearProviderName($reflect->getName());
}
if (strval($providerName) == '')
{
$providerName = $builder->getCallbackFunction();
}
if (!empty($data[$outputName]))
{
$resultList[$providerName] = $data[$outputName];
}
}
}
if (!empty($resultList))
{
$result->setData(
array(
$outputName => $resultList
)
);
}
return $result;
}
/**
* @param $providerName
*
* @return ProviderBuilderBase
*/
private function createBuilder($providerName)
{
if (!$this->isExistsProvider($providerName))
{
$providerClass = null;
if (class_exists($providerName))
{
$providerClass = new $providerName($this->getContext());
}
if (!$providerClass)
{
$providerClass = $providerName;
}
$builder = ProviderBuilderBase::createBuilder($providerClass, $this->getContext());
$this->addBuilder($providerName, $builder);
}
else
{
$builder = $this->getBuilder($providerName);
}
return $builder;
}
/**
* @param string $providerName
* @param ProviderBuilderBase $builder
*/
private function addBuilder($providerName, ProviderBuilderBase $builder)
{
$providerName = $this->clearProviderName($providerName);
$this->pool[$providerName] = $builder;
}
/**
* @param $providerName
*
* @return ProviderBuilderBase|bool
*/
private function getBuilder($providerName)
{
$providerName = $this->clearProviderName($providerName);
if ($this->isExistsProvider($providerName))
{
return $this->pool[$providerName];
}
return false;
}
/**
* @param $providerName
*
* @return bool
*/
private function isExistsProvider($providerName)
{
$providerName = $this->clearProviderName($providerName);
return (isset($this->pool[$providerName]));
}
/**
* @return array
*/
private function getContext()
{
return $this->context;
}
/**
* @param $providerName
*
* @return string
*/
private function clearProviderName($providerName)
{
if (!empty($providerName) && $providerName[0] == "\\")
{
$providerName = ltrim($providerName, '\\');
}
return $providerName;
}
}