reservedproductcleaner.php

<?
namespace Bitrix\Sale\Helpers;
 
use Bitrix\Main\Config\Option;
use Bitrix\Main;
use Bitrix\Main\ORM;
use Bitrix\Main\Type\DateTime;
use Bitrix\Main\Update\Stepper;
use Bitrix\Sale;
use Bitrix\Sale\ReserveQuantityCollection;
 
class ReservedProductCleaner extends Stepper
{
    private const RECORD_LIMIT = 100;
 
    protected static $moduleId = "sale";
 
    public function execute(array &$result)
    {
        $processedRecords = 0;
 
        $registry = Sale\Registry::getInstance(Sale\Registry::REGISTRY_TYPE_ORDER);
        $orderClass = $registry->getOrderClassName();
 
        $days_ago = (int) Option::get("sale", "product_reserve_clear_period");
 
        if ($days_ago > 0)
        {
            global $USER;
 
            if (!is_object($USER))
            {
                $USER = new \CUser;
            }
 
            $date = new DateTime();
            $parameters = [
                'select' => [
                    'ORDER_ID' => 'ORDER.ID',
                    'ID',
                    'BASKET_ID'
                ],
                'filter' => [
                    '>QUANTITY' => 0,
                    '<=DATE_RESERVE_END' => $date,
                    '=ORDER.PAYED' => 'N',
                    '=ORDER.CANCELED' => 'N',
                ],
                'runtime' => [
                    new Main\Entity\ReferenceField(
                        'BASKET',
                        Sale\Internals\BasketTable::class,
                        [
                            '=this.BASKET_ID' => 'ref.ID',
                        ],
                        ['join_type' => 'inner']
                    ),
                    new Main\Entity\ReferenceField(
                        'ORDER',
                        Sale\Internals\OrderTable::class,
                        [
                            '=this.BASKET.ORDER_ID' => 'ref.ID',
                        ],
                        ['join_type' => 'inner']
                    ),
                ],
                'limit' => self::RECORD_LIMIT,
            ];
 
            $orderList = [];
            $res = Sale\ReserveQuantityCollection::getList($parameters);
            while ($data = $res->fetch())
            {
                if (!isset($orderList[$data['ORDER_ID']]))
                {
                    $orderList[$data['ORDER_ID']] = [];
                }
 
                if (!isset($orderList[$data['ORDER_ID']][$data['BASKET_ID']]))
                {
                    $orderList[$data['ORDER_ID']][$data['BASKET_ID']] = [];
                }
 
                $orderList[$data['ORDER_ID']][$data['BASKET_ID']][] = $data['ID'];
            }
 
            foreach ($orderList as $orderId => $basketItemIds)
            {
                $order = $orderClass::load($orderId);
                if (!$order)
                {
                    continue;
                }
 
                $basket = $order->getBasket();
                foreach ($basketItemIds as $basketItemId => $reserveIds)
                {
                    $basketItem = $basket->getItemById($basketItemId);
                    if (!$basketItem)
                    {
                        continue;
                    }
 
                    foreach ($reserveIds as $reserveId)
                    {
                        $reserveCollection = $basketItem->getReserveQuantityCollection();
                        if (!$reserveCollection)
                        {
                            continue;
                        }
 
                        $reserve = $reserveCollection->getItemById($reserveId);
                        if (!$reserve)
                        {
                            continue;
                        }
 
                        $reserve->delete();
 
                        $processedRecords++;
                    }
                }
 
                $r = $order->save();
                if (!$r->isSuccess())
                {
                    $errorText = (string)$order->getField('REASON_MARKED');
                    if ($errorText !== '')
                    {
                        $errorText .= "\n";
                    }
 
                    foreach($r->getErrorMessages() as $error)
                    {
                        if ((string)$error !== '')
                        {
                            $errorText .= $error."\n";
                        }
                    }
 
                    Sale\Internals\OrderTable::update($order->getId(), [
                        "MARKED" => "Y",
                        "REASON_MARKED" => $errorText
                    ]);
                }
            }
 
            // crutch for #120087
            if (!is_object($USER) || $USER->GetID() <= 0)
            {
                ORM\Entity::destroy(Sale\Internals\OrderTable::getEntity());
            }
        }
 
        if ($processedRecords < self::RECORD_LIMIT)
        {
            return self::FINISH_EXECUTION;
        }
 
        return self::CONTINUE_EXECUTION;
    }
}