Действия перед началом импорта или как почистить остатки товаров перед импортом товаров

// init.php

use Bitrix\Main\Loader;
use Bitrix\Main\EventManager;
use Bitrix\Catalog\ProductTable;
use Bitrix\Catalog\StoreProductTable;

$eventManager = EventManager::getInstance();

$eventManager->addEventHandler('acrit.import', 'OnBeforeImportProfileRun',
	/**
	 * @param \Acrit\Import\Import $profile
	 */
	static function (\Acrit\Import\Import $profile) {
		$profileId = $profile->getArProfile()['ID'];

		// set quantity for all products to 0 because import file may contain no old goods
		if ($profileId == 6) {
			$iblockId = $profile->getArProfile()['IBLOCK_ID'];
			Loader::includeModule('iblock');
			Loader::includeModule('catalog');

			// drop quantity on product store ID = 2
			$rsStoreProduct = StoreProductTable::getList([
				'filter' => ['>AMOUNT' => 0, '=STORE_ID' => 2],
				'select' => ['ID', 'STORE_ID', 'PRODUCT_ID', 'AMOUNT', 'QUANTITY_RESERVED']
			]);
			while ($arStoreProduct = $rsStoreProduct->fetch()) {
				StoreProductTable::update($arStoreProduct['ID'], [
					'AMOUNT'            => 0,
					'QUANTITY_RESERVED' => 0
				]);
			}


			// drop main quantity field
			$arProductFields = [
				'QUANTITY' => 0
			];
			$arProductFields['AVAILABLE'] = ProductTable::calculateAvailable($arProductFields);

			$rs = CIBlockElement::GetList(['ID' => 'ASC'], [
				'IBLOCK_ID' => (int)$iblockId,
				'>QUANTITY' => 0
			], false, false, ['ID']);

			$cnt = 0;
			while ($arProduct = $rs->Fetch()) {
				$rsUpd = ProductTable::update($arProduct['ID'], $arProductFields);
				if (! $rsUpd->isSuccess()) {
					echo implode(PHP_EOL, $rsUpd->getErrors());
				}
				$cnt++;
			}
			// \Bitrix\Main\Diag\Debug::dump($cnt);
		}
	}
);

// params example run before each import step
$eventManager->addEventHandler('acrit.import', 'OnBeforeImportProfileRunStep',
	/**
	 * @param \Acrit\Import\Import $profile
	 * @param int $type internal type of run
	 * @param int $limit step count limit
	 * @param int $next_item start item in this limit step
	 */
	static function (\Acrit\Import\Import $profile, $type, $limit, $next_item) {
	}
);