orderprocessing.php

См. документацию.

<?php
namespace Bitrix\Sale\Internals;
 
use Bitrix\Main;
use Bitrix\Main\Entity\DataManager;
use Bitrix\Main\Application;

class OrderProcessingTable extends DataManager
{
    protected array $orderProcessedCache = [];
 
    public static function getTableName(): string
    {
        return "b_sale_order_processing";
    }
 
    public static function getMap(): array
    {
        return [
            'ORDER_ID' => [
                'primary' => true,
                'data_type' => 'integer',
            ],
            'PRODUCTS_ADDED' => [
                'data_type' => 'boolean',
                'values' => ['N','Y'],
            ],
            'PRODUCTS_REMOVED' => [
                'data_type' => 'boolean',
                'values' => ['N','Y'],
            ],
            'ORDER' => [
                'data_type' => "Bitrix\\Sale\\OrderTable",
                'reference' => ['=this.ORDER_ID' => 'ref.ID'],
            ],
        ];
    }

    public static function hasAddedProducts($orderId = 0): bool
    {
        $orderId = (int)$orderId;
        $row = static::getRow([
            'filter' => [
                '=ORDER_ID' => $orderId,
            ],
        ]);
 
        return ($row['PRODUCTS_ADDED'] ?? null) === 'Y';
    }

    public static function hasRemovedProducts($orderId = 0): bool
    {
        $orderId = (int)$orderId;
        $row = static::getRow([
            'filter' => [
                '=ORDER_ID' => $orderId,
            ],
        ]);
 
        return ($row['PRODUCTS_REMOVED'] ?? null) === 'Y';
    }

    public static function markProductsAdded($orderId = 0): void
    {
        $orderId = (int)$orderId;
        if ($orderId <= 0)
        {
            return;
        }
        $row = static::getRow([
            'filter' => [
                '=ORDER_ID' => $orderId,
            ],
        ]);
        if ($row)
        {
            static::update($orderId, ['PRODUCTS_ADDED' => 'Y']);
        }
        else
        {
            static::add([
                'ORDER_ID' => $orderId,
                'PRODUCTS_ADDED' => 'Y',
            ]);
        }
    }

    public static function markProductsAddedByList(array $orderIds): void
    {
        Main\Type\Collection::normalizeArrayValuesByInt($orderIds);
        if (empty($orderIds))
        {
            return;
        }
 
        $connection = \Bitrix\Main\Application::getConnection();
        $sqlUpdate = "UPDATE ". static::getTableName() ." SET PRODUCTS_ADDED = 'Y' WHERE ORDER_ID IN (".implode(',', $orderIds).")";
        $connection->queryExecute($sqlUpdate);
    }

    public static function markProductsRemoved($orderId = 0): void
    {
        $orderId = (int)$orderId;
        if ($orderId <= 0)
        {
            return;
        }
        $row = static::getRow([
            'filter' => [
                '=ORDER_ID' => $orderId,
            ],
        ]);
        if ($row)
        {
            static::update($orderId, ['PRODUCTS_REMOVED' => 'Y']);
        }
        else
        {
            static::add([
                'ORDER_ID' => $orderId,
                'PRODUCTS_REMOVED' => 'Y',
            ]);
        }
    }

    public static function deleteByOrderId($orderId)
    {
        $orderId = (int)$orderId;
        if ($orderId <= 0)
        {
            return false;
        }
 
        $con = \Bitrix\Main\Application::getConnection();
        $con->queryExecute("DELETE FROM ". static::getTableName() ." WHERE ORDER_ID=".$orderId);
 
        return true;
    }

    public static function clear()
    {
        $connection = Application::getConnection();
        $sql = "DELETE FROM " . static::getTableName() . "
                WHERE ORDER_ID NOT IN (SELECT ID FROM b_sale_order)";
        $connection->queryExecute($sql);
    }
}