/home/sharedstore/public_html/prestashop.sharedstore.ma/src/Adapter
Edit: /home/sharedstore/public_html/prestashop.sharedstore.ma/src/Adapter/StockManager.php (7914B)
* @copyright Since 2007 PrestaShop SA and Contributors
* @license https://opensource.org/licenses/OSL-3.0 Open Software License (OSL 3.0)
*/
namespace PrestaShop\PrestaShop\Adapter;
use Db;
use PrestaShop\PrestaShop\Adapter\Configuration as ConfigurationAdapter;
use PrestaShop\PrestaShop\Adapter\Shop\Context as ShopAdapter;
use PrestaShopBundle\Service\DataProvider\StockInterface;
use StockAvailable;
/**
* Data provider for new Architecture, about Product stocks.
*
* This class will provide data from DB / ORM about Product stocks.
*/
class StockManager implements StockInterface
{
/**
* Gets available stock for a given product / combination / shop.
*
* @param object $product
* @param null $id_product_attribute
* @param int|null $id_shop
*
* @return StockAvailable
*/
public function getStockAvailableByProduct($product, $id_product_attribute = null, $id_shop = null)
{
$stockAvailable = $this->newStockAvailable($this->getStockAvailableIdByProductId($product->id, $id_product_attribute, $id_shop));
if (!$stockAvailable->id) {
$shopAdapter = new ShopAdapter();
$stockAvailable->id_product = (int) $product->id;
$stockAvailable->id_product_attribute = (int) $id_product_attribute;
$outOfStock = $this->outOfStock((int) $product->id, $id_shop);
$stockAvailable->out_of_stock = (int) $outOfStock;
if ($id_shop === null) {
$shop_group = $shopAdapter->getContextShopGroup();
} else {
$shop_group = $shopAdapter->ShopGroup((int) $shopAdapter->getGroupFromShop((int) $id_shop));
}
// if quantities are shared between shops of the group
if ($shop_group->share_stock) {
$stockAvailable->id_shop = 0;
$stockAvailable->id_shop_group = (int) $shop_group->id;
} else {
$stockAvailable->id_shop = (int) $id_shop;
$stockAvailable->id_shop_group = 0;
}
$stockAvailable->add();
}
return $stockAvailable;
}
/**
* Returns True if Stocks are managed by a module (or by legacy ASM).
*
* @return bool True if Stocks are managed by a module (or by legacy ASM)
*/
public function isAsmGloballyActivated()
{
return (bool) (new ConfigurationAdapter())->get('PS_ADVANCED_STOCK_MANAGEMENT');
}
/**
* @param int $shopId
* @param int $errorState
* @param int $cancellationState
* @param int|null $idProduct
* @param int|null $idOrder
*
* @return bool
*/
public function updatePhysicalProductQuantity($shopId, $errorState, $cancellationState, $idProduct = null, $idOrder = null)
{
$this->updateReservedProductQuantity($shopId, $errorState, $cancellationState, $idProduct, $idOrder);
$updatePhysicalQuantityQuery = '
UPDATE {table_prefix}stock_available sa
SET sa.physical_quantity = sa.quantity + sa.reserved_quantity
WHERE sa.id_shop = ' . (int) $shopId . '
';
if ($idProduct) {
$updatePhysicalQuantityQuery .= ' AND sa.id_product = ' . (int) $idProduct;
}
if ($idOrder) {
$updatePhysicalQuantityQuery .= ' AND sa.id_product IN (SELECT product_id FROM {table_prefix}order_detail WHERE id_order = ' . (int) $idOrder . ')';
}
$updatePhysicalQuantityQuery = str_replace('{table_prefix}', _DB_PREFIX_, $updatePhysicalQuantityQuery);
return Db::getInstance()->execute($updatePhysicalQuantityQuery);
}
/**
* @param int $shopId
* @param int $errorState
* @param int $cancellationState
* @param int|null $idProduct
* @param int|null $idOrder
*
* @return bool
*/
private function updateReservedProductQuantity($shopId, $errorState, $cancellationState, $idProduct = null, $idOrder = null)
{
$updateReservedQuantityQuery = '
UPDATE {table_prefix}stock_available sa
SET sa.reserved_quantity = (
SELECT SUM(od.product_quantity - od.product_quantity_refunded)
FROM {table_prefix}orders o
INNER JOIN {table_prefix}order_detail od ON od.id_order = o.id_order
INNER JOIN {table_prefix}order_state os ON os.id_order_state = o.current_state
WHERE o.id_shop = :shop_id AND
os.shipped != 1 AND (
o.valid = 1 OR (
os.id_order_state != :error_state AND
os.id_order_state != :cancellation_state
)
) AND sa.id_product = od.product_id AND
sa.id_product_attribute = od.product_attribute_id
GROUP BY od.product_id, od.product_attribute_id
)
WHERE sa.id_shop = :shop_id
';
$strParams = [
'{table_prefix}' => _DB_PREFIX_,
':shop_id' => (int) $shopId,
':error_state' => (int) $errorState,
':cancellation_state' => (int) $cancellationState,
];
if ($idProduct) {
$updateReservedQuantityQuery .= ' AND sa.id_product = :product_id';
$strParams[':product_id'] = (int) $idProduct;
}
if ($idOrder) {
$updateReservedQuantityQuery .= ' AND sa.id_product IN (SELECT product_id FROM {table_prefix}order_detail WHERE id_order = :order_id)';
$strParams[':order_id'] = (int) $idOrder;
}
$updateReservedQuantityQuery = strtr($updateReservedQuantityQuery, $strParams);
return Db::getInstance()->execute($updateReservedQuantityQuery);
}
/**
* Instance a new StockAvailable.
*
* @param bool|int|null $stockAvailableId
*
* @return StockAvailable
*/
public function newStockAvailable($stockAvailableId = null)
{
if (is_int($stockAvailableId)) {
return new StockAvailable($stockAvailableId);
}
return new StockAvailable();
}
/**
* Use legacy getStockAvailableIdByProductId.
*
* @param int $productId
* @param int|null $productAttributeId
* @param int|null $shopId
*
* @return bool|int
*/
public function getStockAvailableIdByProductId($productId, $productAttributeId = null, $shopId = null)
{
return StockAvailable::getStockAvailableIdByProductId($productId, $productAttributeId, $shopId);
}
/**
* For a given product, get its "out of stock" flag.
*
* @param int $productId
* @param int $shopId Optional : gets context if null @see Context::getContext()
*
* @return bool : depends on stock @see $depends_on_stock
*/
public function outOfStock($productId, $shopId = null)
{
return StockAvailable::outOfStock($productId, $shopId);
}
}