Пишем собственный модуль загрузки из CSV - [VM1] Импорт-экспорт данных

############################################################################
#Insert to DB
#
if($_POST['pageaction']=="load2db"){

//Подключаем класы:
require_once( CLASSPATH . "ps_product.php" );
require_once( CLASSPATH . "ps_product_category.php" );
require_once( CLASSPATH . "ps_database.php" );
$ps_product_category =& new  ps_product_category(); 
$ps_product =& new ps_product();
//$ps_product->
//$ps_product_category->


$handle = fopen ($upcsv_dir.$_POST['csvfilename'],"r");		
$count=1;

//--------------------------------------------------------------------------------------------------------|
// получение дефлойтовой группы покупателей
//--------------------------------------------------------------------------------------------------------|
$shopper_db = new ps_DB;
$q =  "SELECT shopper_group_id,shopper_group_name FROM #__{vm}_shopper_group WHERE `default`= '1' AND vendor_id='".$db->f("vendor_id")."'";
$shopper_db->query($q);
if ($shopper_db->num_rows()<1) {  // when there is no "default", take the first in the table
	$q =  "SELECT shopper_group_id,shopper_group_name from #__{vm}_shopper_group WHERE vendor_id='$ps_vendor_id'";
	$shopper_db->query($q);
}
$shopper_db->next_record();
$my_shopper_group_id = $shopper_db->f("shopper_group_id");
//--------------------------------------------------------------------------------------------------------|

		#Подготовим масив статических данных о товаре:
		#----------------------------------------------|
		$d['shopper_group_id'] 		= $my_shopper_group_id;
		$d['product_categories'] 		= Array();
		$d['product_categories']		= $_POST['product_categories'];
		$d['product_publish'] 		= 'Y';
		$d['product_available_date']	= '3000.01.01';
		#----------------------------------------------|

	while ($myrow = fgetcsv ($handle, 1000, $_POST['csvseparator'])) {
	
		#Подготовим масив данных о товаре:
		#----------------------------------------------|
		$d['product_sku'] 				= $myrow['0'];
		$d['product_name'] 			= $myrow['1'];
		$d['product_price']				= $myrow['3'];
		$d['product_s_desc'] 			= $myrow['4'];
		$d['product_desc'] 			= $myrow['5'];
		#----------------------------------------------|
		$ps_product->add($d);
		 
	
	
				$count++;   
				//if($count>$csvpreviewno){ break; }
	}
fclose($handle);


}
############################################################################