storeproduct.php

<?php
namespace Bitrix\Catalog;
 
use Bitrix\Main;
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\ORM;
 
class StoreProductTable extends ORM\Data\DataManager
{
    public static function getTableName()
    {
        return 'b_catalog_store_product';
    }
 
    public static function getMap()
    {
        return [
            'ID' => new ORM\Fields\IntegerField(
                'ID',
                [
                    'primary' => true,
                    'autocomplete' => true,
                    'title' => Loc::getMessage('STORE_PRODUCT_ENTITY_ID_FIELD'),
                ]
            ),
            'STORE_ID' => new ORM\Fields\IntegerField(
                'STORE_ID',
                [
                    'required' => true,
                    'title' => Loc::getMessage('STORE_PRODUCT_ENTITY_STORE_ID_FIELD'),
                ]
            ),
            'PRODUCT_ID' => new ORM\Fields\IntegerField(
                'PRODUCT_ID',
                [
                    'required' => true,
                    'title' => Loc::getMessage('STORE_PRODUCT_ENTITY_PRODUCT_ID_FIELD'),
                ]
            ),
            'AMOUNT' => new ORM\Fields\FloatField(
                'AMOUNT',
                [
                    'title' => Loc::getMessage('STORE_PRODUCT_ENTITY_AMOUNT_FIELD'),
                ]
            ),
            'QUANTITY_RESERVED' => new ORM\Fields\FloatField(
                'QUANTITY_RESERVED',
                [
                    'title' => Loc::getMessage('STORE_PRODUCT_ENTITY_QUANTITY_RESERVED_FIELD'),
                ]
            ),
            'STORE' => new ORM\Fields\Relations\Reference(
                'STORE',
                StoreTable::class,
                ORM\Query\Join::on('this.STORE_ID', 'ref.ID')
            ),
            'PRODUCT' => new ORM\Fields\Relations\Reference(
                'PRODUCT',
                ProductTable::class,
                ORM\Query\Join::on('this.PRODUCT_ID', 'ref.ID')
            ),
        ];
    }
 
    public static function deleteByProduct(int $id): void
    {
        if ($id <= 0)
        {
            return;
        }
 
        $conn = Main\Application::getConnection();
        $helper = $conn->getSqlHelper();
        $conn->queryExecute(
            'delete from ' . $helper->quote(self::getTableName())
            . ' where ' . $helper->quote('PRODUCT_ID') . ' = ' . $id
        );
        unset($helper, $conn);
    }
}