basestorequantityaction.php

<?php
 
namespace Bitrix\Catalog\Document\Action\Store;
 
use Bitrix\Catalog\Document\Action\ProductAndStoreInfo;
use Bitrix\Catalog\StoreProductTable;
use Bitrix\Main\Application;
use Bitrix\Main\Error;
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\ORM\Fields\ExpressionField;
use Bitrix\Main\Result;
use CCatalogProduct;
use CCatalogStoreProduct;
 
Loc::loadMessages(
    Application::getDocumentRoot() .'/bitrix/modules/catalog/general/store_docs_type.php'
);
 
trait BaseStoreQuantityAction
{
    use ProductAndStoreInfo;
 
    protected $storeId;
 
    protected $productId;
 
    protected $amount;
 
    public function __construct(int $storeId, int $productId, float $amount)
    {
        $this->storeId = $storeId;
        $this->productId = $productId;
        $this->amount = $amount;
    }
 
    protected function updateProductQuantity(): bool
    {
        $row = StoreProductTable::getRow([
            'select' => [
                'SUM_AMOUNT',
            ],
            'filter' => [
                '=STORE.ACTIVE' => 'Y',
                '=PRODUCT_ID' => $this->productId,
            ],
            'runtime' => [
                new ExpressionField('SUM_AMOUNT', 'SUM(%s)', 'AMOUNT'),
            ],
            'group' => [
                'PRODUCT_ID',
            ],
        ]);
        if (!$row)
        {
            return false;
        }
 
        return CCatalogProduct::Update($this->productId, [
            'QUANTITY' => (float)$row['SUM_AMOUNT'] - $this->getProductTotalReservedQuantity()
        ]);
    }
 
    abstract protected function getProductAmountNew(): float;
 
    public function execute(): Result
    {
        $result = new Result();
 
        $ret = CCatalogStoreProduct::UpdateFromForm([
            'STORE_ID' => $this->storeId,
            'PRODUCT_ID' => $this->productId,
            'AMOUNT' => $this->getProductAmountNew(),
        ]);
        if (!$ret)
        {
            $result->addError(
                new Error(Loc::getMessage('CATALOG_STORE_DOCS_ERR_CANT_UPDATE_STORE_PRODUCT'))
            );
        }
 
        if (!$this->updateProductQuantity())
        {
            $result->addError(
                new Error(Loc::getMessage("CATALOG_STORE_DOCS_ERR_PURCHASING_INFO_ERROR"))
            );
        }
 
        return $result;
    }
}