Поиск по артикулу и производителю при импорте CSV-файла (HostCMS)

searchbyprodandvendor.php

<?php

// В импортируемом CSV-файле первым должен быть столбец с производителем, а вторым столбец с артикулом

/*
* В bootstrap.php:
*
// Поиск по артикулу и производителю при импорте CSV-файла
Core_Event::attach('ImportShopItems.onBeforeFindByMarking', array('Shop_Item_Import_Observer_SearchByProdAndVendor', 'onBeforeFindByMarking'));
Core_Event::attach('ImportShopItems.onAfterFindByMarking', array('Shop_Item_Import_Observer_SearchByProdAndVendor', 'onAfterFindByMarking'));
*
*/

defined('HOSTCMS') || exit('HostCMS: access denied.');

class Shop_Item_Import_Observer_SearchByProdAndVendor
{
	static public function onBeforeFindByMarking($object, $args)
	{
		// Запоминаем товар с производителем
		Core_Registry::instance()->set('shop_item_with_prod', clone $args[1]);
	}

	static public function onAfterFindByMarking($object, $args)
	{
		// Новый товар
		$oItemWithProd = Core_Registry::instance()->get('shop_item_with_prod');

		// Результат поиска по артикулу
		$oItemWithMarking = $args[1];

		$oShop_Item = Core_Entity::factory('shop_item');
		$oShop_Item->queryBuilder()
			->where('marking', '=', $oItemWithMarking->marking)
			->where('shop_producer_id', '=', $oItemWithProd->shop_producer_id)
			->limit(1)
		;
		$aoShop_Item = $oShop_Item->findAll();

		if (count($aoShop_Item) > 0)
		{
			$object->setCurrentItem($aoShop_Item[0]);
		}
		else
		{
			$oItemWithProd->marking = $oItemWithMarking->marking;
			$object->setCurrentItem($oItemWithProd);
		}
	}
}