updatebasketitemaction.php

<?php
 
namespace Bitrix\Sale\Controller\Action\Entity;
 
use Bitrix\Main;
use Bitrix\Sale;
use Bitrix\Catalog;
 
final class UpdateBasketItemAction extends Sale\Controller\Action\BaseAction
{
    public function run(int $id, array $fields)
    {
        $result = [];
 
        $updateBasketItemResult = $this->updateBasketItem($id, $fields);
        if (!$updateBasketItemResult->isSuccess())
        {
            $this->addErrors($updateBasketItemResult->getErrors());
            return $result;
        }
 
        $updateBasketItemData = $updateBasketItemResult->getData();
        $basketItem = $updateBasketItemData['basketItem'];
        return Sale\Helpers\Controller\Action\Entity\Order::getOrderProductByBasketItem($basketItem);
    }
 
    public function updateBasketItem(int $id, array $fields): Sale\Result
    {
        $result = new Sale\Result();
 
        $registry = Sale\Registry::getInstance(Sale\Registry::REGISTRY_TYPE_ORDER);
 
        $basketClass = $registry->getBasketClassName();
 
        $basketIterator = $basketClass::getList([
            'select' => ['ORDER_ID', 'FUSER_ID', 'LID'],
            'filter' => [
                '=ID' => $id
            ]
        ]);
 
        $fields = $this->prepareBasketFields($fields);
 
        if ($basketItemData = $basketIterator->fetch())
        {
            if (empty($basketItemData['ORDER_ID']))
            {
                $basket = $this->getBasket($basketItemData['FUSER_ID'], $basketItemData['LID']);
                if ($basket && !$basket->isEmpty())
                {
                    $basketItem = $basket->getItemByBasketCode($id);
                    foreach ($fields as $fieldName => $fieldValue)
                    {
                        $setFieldResult = $basketItem->setField($fieldName, $fieldValue);
                        if (!$setFieldResult->isSuccess())
                        {
                            foreach ($setFieldResult->getErrors() as $error)
                            {
                                $result->addError(
                                    new Main\Error(
                                        $error->getMessage(),
                                        Sale\Controller\ErrorEnumeration::UPDATE_BASKET_ITEM_ACTION_SET_FIELD
                                    )
                                );
                            }
                        }
                    }
 
                    $checkQuantityResult = $this->checkQuantity($basket);
                    if (!$checkQuantityResult->isSuccess())
                    {
                        foreach ($checkQuantityResult->getErrors() as $error)
                        {
                            $result->addError(
                                new Main\Error(
                                    $error->getMessage(),
                                    Sale\Controller\ErrorEnumeration::UPDATE_BASKET_ITEM_ACTION_CHECK_QUANTITY
                                )
                            );
                        }
                    }
 
                    if ($result->isSuccess())
                    {
                        $saveResult = $basket->save();
                        if ($saveResult->isSuccess())
                        {
                            $result->setData([
                                'basket' => $basket,
                                'basketItem' => $basketItem,
                            ]);
                        }
                        else
                        {
                            foreach ($saveResult->getErrors() as $error)
                            {
                                $result->addError(
                                    new Main\Error(
                                        $error->getMessage(),
                                        Sale\Controller\ErrorEnumeration::UPDATE_BASKET_ITEM_ACTION_SAVE_BASKET
                                    )
                                );
                            }
                        }
                    }
                }
                else
                {
                    $result->addError(
                        new Main\Error(
                            'basket item load error',
                            Sale\Controller\ErrorEnumeration::UPDATE_BASKET_ITEM_ACTION_BASKET_LOAD
                        )
                    );
                }
            }
            else
            {
                $result->addError(
                    new Main\Error(
                        'there is order with this basket item',
                        Sale\Controller\ErrorEnumeration::UPDATE_BASKET_ITEM_ACTION_ORDER_EXIST
                    )
                );
            }
        }
        else
        {
            $result->addError(
                new Main\Error(
                    'basket item with id '.$id.' is not exists',
                    Sale\Controller\ErrorEnumeration::UPDATE_BASKET_ITEM_ACTION_BASKET_ITEM_NOT_EXIST
                )
            );
        }
 
        return $result;
    }
 
    private function getBasket(int $fuserId, string $siteId): Sale\Basket
    {
        $basketStorage = Sale\Basket\Storage::getInstance($fuserId, $siteId);
        return $basketStorage->getBasket();
    }
 
    private function checkQuantity(Sale\Basket $basket): Sale\Result
    {
        $result = new Sale\Result();
 
        $actualQuantityList = $this->getActualQuantityList($basket);
        Sale\BasketComponentHelper::correctQuantityRatio($basket);
 
        $updatedQuantityList = $this->getActualQuantityList($basket);
        foreach ($updatedQuantityList as $basketCode => $itemQuantity)
        {
            if (!isset($actualQuantityList[$basketCode]) || $itemQuantity !== $actualQuantityList[$basketCode])
            {
                $result->addError(new Main\Error('quantity is incorrect'));
            }
        }
 
        return $result;
    }
 
    private function getActualQuantityList(Sale\Basket $basket): array
    {
        $quantityList = [];
 
        if (!$basket->isEmpty())
        {
            foreach ($basket as $basketItem)
            {
                if ($basketItem->canBuy() && !$basketItem->isDelay())
                {
                    $quantityList[$basketItem->getBasketCode()] = $basketItem->getQuantity();
                }
            }
        }
 
        return $quantityList;
    }
 
    private function prepareBasketFields(array $fields): array
    {
        $fields = $this->filterBasketFieldsOnUpdate($fields);
 
        $fields['PRODUCT_PROVIDER_CLASS'] = Catalog\Product\Basket::getDefaultProviderName();
 
        $settableFields = Sale\BasketItemBase::getSettableFields();
        return array_filter(
            $fields,
            static function ($field) use ($settableFields) {
                return in_array($field, $settableFields, true);
            },
            ARRAY_FILTER_USE_KEY
        );
    }
 
    private function filterBasketFieldsOnUpdate(array $basketFields): array
    {
        return (new Sale\Rest\Entity\BasketItem())->internalizeFieldsUpdate($basketFields);
    }
}