[Помогите] Помогите подправить Скрипт импорта в И-маг на Opencart Version 1.5.1.3.

MIV14 · 27 апр 2014

Нужно, чтобы скрипт не трогал в атрибутах у категорий и производителей все поля, кроме поля с наименованием категории,
производителя. Поля (описание, url, теги и т.д.) будут постоянны и заполняться и корректироваться из админки (для СЕО).
Данные по товарам формирует 1С и записывает в файл CSV. В админке Система- синхронизация запускается Скрипт, которому указывается CSV файл. По кнопке Импорт скрипт заполняет магазин. При изменениях по товару (приход, продажа) процесс повторяется вручную, в одну сторону: из 1С опять формируется новый файл CSV и база магазина перезаписывается полностью, по-новой.
Скрипт

Спойлер

<?php
//чтобы скрипт работал - снять у брендов и мануфактуреров autoincrement
static $config = NULL;
static $log = NULL;

// Error Handler
function error_handler_for_export($errno, $errstr, $errfile, $errline) {
global $config;
global $log;

switch ($errno) {
case E_NOTICE:
case E_USER_NOTICE:
$errors = "Notice";
break;
case E_WARNING:
case E_USER_WARNING:
$errors = "Warning";
break;
case E_ERROR:
case E_USER_ERROR:
$errors = "Fatal Error";
break;
default:
$errors = "Unknown";
break;
}

if (($errors=='Warning') || ($errors=='Unknown')) {
return true;
}

if ($config->get('config_error_display')) {
echo '' . $errors . ': ' . $errstr . ' in ' . $errfile . ' on line ' . $errline . '';
}

if ($config->get('config_error_log')) {
$log->write('PHP ' . $errors . ': ' . $errstr . ' in ' . $errfile . ' on line ' . $errline);
}

return true;
}

function fatal_error_shutdown_handler_for_export()
{
$last_error = error_get_last();
if ($last_error['type'] === E_ERROR) {
// fatal error
error_handler_for_export(E_ERROR, $last_error['message'], $last_error['file'], $last_error['line']);
}
}

class ModelToolExport extends Model {
function img($img) {
//return 'data/' . strtolower($img);
return 'data/' . $img;
}

function stoc($floati)
{
if($floati == '1') {
return '7';

} elseif ($floati == '2') {
return '8';
} elseif ($floati == '3') {
return '6';
} else {
return '5';
}
}

//очистить от обычного мусора и пробелов и html
function clean( &$str, $allowBlanks=FALSE, $htmlClean=FALSE ) {
if (strlen($str)<=0) {
return '';
}
$result = str_replace("\xC2xA0"," ",$str);

$result=preg_replace("/(\\n \\t \\r' )/u","",$result);

$result=preg_replace("/(\n \t \r \x0B' )/u","",$result);

//$meta_in = preg_replace('/\p{Zs}+/u',' ',$meta_in);

if (!$allowBlanks) {
$result=preg_replace("/(\p{Z} \p{Mc}' )/u","",$result);
}
if ($htmlClean) {
$result=strip_tags($result);
$result=preg_replace("/(\" \' \\ )/u","",$result);
$result=htmlspecialchars($result);
}

return $result;
}

//очистить от обычного мусора опасного для бд
function dbclean ( &$str) {

$result=preg_replace("/(\n \t \' \\\\ )/u","",$str);
return $result;
}

//выполнить запрос в Скуль
function import( &$database, $sql ) {
foreach (explode(";\n", $sql) as $sql) {
$sql = trim($sql);
if ($sql) {
$database->query($sql);
}
}
}

protected function getDefaultLanguageId( &$database ) {
$code = $this->config->get('config_language');
$sql = "SELECT language_id FROM `".DB_PREFIX."language` WHERE code = '$code'";
$result = $database->query( $sql );
$languageId = 1;
if ($result->rows) {
foreach ($result->rows as $row) {
$languageId = $row['language_id'];
break;
}
}
return $languageId;
}

protected function getDefaultStoreId( &$database ) {
return '0';
}
// == ==== === == = = = = == = = == = == = = === = = = = == = = == = == == == === == == = =

function storeProductsIntoDatabase( &$database, &$products )
{
// find the default language id
$languageId = $this->getDefaultLanguageId($database);
$storeId = $this->getDefaultStoreId($database);

// start transaction, remove products
$sql = "START TRANSACTION;\n";
$sql .= "DELETE FROM `".DB_PREFIX."product`;\n";
$sql .= "DELETE FROM `".DB_PREFIX."product_description`;\n";
$sql .= "DELETE FROM `".DB_PREFIX."product_to_category`;\n";
$sql .= "DELETE FROM `".DB_PREFIX."product_to_store`;\n";
$sql .= "DELETE FROM `".DB_PREFIX."url_alias` WHERE `query` LIKE 'product_id=%';\n";
$sql .= "DELETE FROM `".DB_PREFIX."product_related`;\n";
$sql .= "DELETE FROM `".DB_PREFIX."product_tag`;\n";
$sql .= "DELETE FROM `".DB_PREFIX."product_to_layout`;\n";
$this->import( $database, $sql );

// generate and execute SQL for storing the products
foreach ($products as $product) {
$productId = $product['product_id'];
$sku = $product['sku'];
$productName = $this->dbclean($product['name']);
$maincategory=$product['maincategory'];
$categories = $product['categories'];
$manufacturerId = $product['manufacturer'];
$brandId=$product['brand'];

$quantity = $product['quantity'];
$model = $this->dbclean($product['model']);
$imageName = $product['image'];
$shipping = $product['shipping'];
$price = trim($product['price']);
$cost = trim($product['cost']);

$hit=$product['hit'];
$new=$product['new'];
$spec=$product['spec'];

$dateAdded = $product['date_added'];
$dateModified = $product['date_modified'];
$dateAvailable = $product['date_available'];
$status = $product['status'];
$viewed = $product['viewed'];

$taxClassId = $product['tax_class_id'];
$productDescription = $this->dbclean($product['description']);

$stockStatusId = $product['stock_status_id'];
$meta_description = $this->dbclean($product['meta_description']);
$title=$product['title'];
$seo_title=$product['seo_title'];
$seo_h1=$product['seo_h1'];

$lengthClassId = $product['length_class_id'];
$weightClassId = $product['weight_class_id'];
$weight = ($product['weight']=="") ? 0 : $product['weight'];
$length = $product['length'];
$width = $product['width'];
$height = $product['height'];

$meta_keyword = $this->dbclean($product['meta_keyword']);

$tags = array();
foreach ($product['tags'] as $tag) {
$tags[] = $this->dbclean($tag);
}

$location = $this->dbclean($product['location']);
$minimum = $product['minimum'];
$sort_order = $product['sort_order'];

// product_id quantity sku location
// stock_status_id model manufacturer_id image shipping price date_added
// date_modified date_available weight weight_class_id status
// tax_class_id viewed length width height length_class_id sort_order minimum
// cost hit new spec main_category_id brand_id
$sql = "INSERT INTO `".DB_PREFIX."product` (`product_id`,`quantity`,`sku`,`location`,";
$sql .= "`stock_status_id`,`model`,`manufacturer_id`,`image`,`shipping`,`price`, `date_added`,";
$sql .= "`date_modified`,`date_available`,`weight`,`weight_class_id`,`status`,";
$sql .= "`tax_class_id`,`viewed`,`length`,`width`,`height`,`length_class_id`,`sort_order`,`minimum`,";
$sql .= "`cost`, `hit`,`new`,`spec`, `main_category_id`, `brand_id`) VALUES ";
$sql .= "($productId,$quantity,'$sku','$location',";
$sql .= "'$stockStatusId','$model','$manufacturerId','$imageName','$shipping','$price',";
$sql .= ($dateAdded=='NOW()') ? "$dateAdded," : "'$dateAdded',";
$sql .= ($dateModified=='NOW()') ? "$dateModified," : "'$dateModified',";
$sql .= ($dateAvailable=='NOW()') ? "$dateAvailable," : "'$dateAvailable',";
$sql .= "'$weight','$weightClassId','$status',";
$sql .= "'$taxClassId', '$viewed', '$length', '$width', '$height','$lengthClassId','$sort_order','$minimum', ";
$sql .= "'$cost','$hit','$new','$spec','$maincategory','$brandId' );";

//descr
//product_id language_id name description meta_description meta_keyword title h1
$sql2 = "INSERT INTO `".DB_PREFIX."product_description` (`product_id`,`language_id`,`name`,`description`,`meta_description`,`meta_keyword`,";
$sql2.= "`title`,`h1`,`seo_title`,`seo_h1` ) VALUES ";
$sql2.= "($productId,$languageId,'$productName','$productDescription','$meta_description','$meta_keyword',";
$sql2.= "'$title','$seo_h1','$seo_title','$seo_h1' );\n ";
$database->query($sql);
$database->query($sql2);

if ($maincategory) {
$sql3 = "INSERT INTO `".DB_PREFIX."product_to_category` (`product_id`,`category_id`,`main_category`) VALUES ";
$sql3 .= "($productId,$maincategory,1)";
$sql3 .= ";";
$database->query($sql3);
}

if (count($categories) > 0) {
$sql4 = "INSERT INTO `".DB_PREFIX."product_to_category` (`product_id`,`category_id`) VALUES ";
$first = TRUE;
foreach ($categories as $categoryId) {
$sql4 .= ($first) ? "\n" : ",\n";
$first = FALSE;
$sql4 .= "($productId,$categoryId)";
}
$sql4 .= ";";
$database->query($sql4);
}
/* потом для
if ($keyword) {
$sql5 = "INSERT INTO `".DB_PREFIX."url_alias` (`query`,`keyword`) VALUES ('product_id=$productId','$keyword');";
$database->query($sql5);
}

*/
$sql6 = "INSERT INTO `".DB_PREFIX."product_to_store` (`product_id`,`store_id`) VALUES ($productId,$storeId);";
$database->query($sql6);
if (count($tags) > 0) {
$sql7 = "INSERT INTO `".DB_PREFIX."product_tag` (`product_id`,`tag`,`language_id`) VALUES ";
$first = TRUE;
$inserted_tags = array();
foreach ($tags as $tag) {
if ($tag == '') {
continue;
}
if (in_array($tag,$inserted_tags)) {
continue;
}
$sql7 .= ($first) ? "\n" : ",\n";
$first = FALSE;
$sql7 .= "($productId,'".$database->escape($tag)."',$languageId)";
$inserted_tags[] = $tag;
}
$sql7 .= ";";
if (count($inserted_tags)>0) {
$database->query($sql7);
}
}
}

// final commit
$database->query("COMMIT;");
return TRUE;
}

function storeCategoriesIntoDatabase( &$database, &$categories )
{
// find the default language and store
$languageId = $this->getDefaultLanguageId($database);
$storeId = $this->getDefaultStoreId($database);

// start transaction, remove categories
$sql = "START TRANSACTION;\n";
$sql .= "DELETE FROM `".DB_PREFIX."category`;\n";
$sql .= "DELETE FROM `".DB_PREFIX."category_description` WHERE language_id=$languageId;\n";
$sql .= "DELETE FROM `".DB_PREFIX."category_to_store`;\n";

$sql .= "TRUNCATE TABLE `".DB_PREFIX."category`;\n";
$sql .= "TRUNCATE TABLE `".DB_PREFIX."category_description`;\n";
$sql .= "TRUNCATE TABLE `".DB_PREFIX."category_to_store`;\n";

$sql .= "DELETE FROM `".DB_PREFIX."url_alias` WHERE `query` LIKE 'category_id=%';\n";
$sql .= "DELETE FROM `".DB_PREFIX."category_to_layout`;\n";
$this->import( $database, $sql );

// generate and execute SQL for inserting the categories
foreach ($categories as $category) {
$categoryId = $category['category_id'];

$imageName = $category['image'];
$parentId = $category['parent_id'];
$sortOrder = $category['sort_order'];
$dateAdded = $category['date_added'];
$dateModified = $category['date_modified'];
$name = $this->dbclean($category['name']);
$meta_keyword = $this->dbclean($category['meta_keyword']);
$seo_title=$category['seo_title'];
$seo_h1=$category['seo_h1'];
$status = $category['status'];

$sql2 = "INSERT INTO `".DB_PREFIX."category` (`category_id`, `image`, `parent_id`, `sort_order`, `date_added`, `date_modified`, `status`) VALUES ";
$sql2 .= "( $categoryId, '$imageName', $parentId, $sortOrder, ";
$sql2 .= ($dateAdded=='NOW()') ? "$dateAdded," : "'$dateAdded',";
$sql2 .= ($dateModified=='NOW()') ? "$dateModified," : "'$dateModified',";
$sql2 .= " $status);";

$database->query( $sql2 );

$sql3 = "INSERT INTO `".DB_PREFIX."category_description` (`category_id`, `language_id`, `name`, `meta_keyword`,`seo_title`,`seo_h1`) VALUES ";
$sql3 .= "( $categoryId, $languageId, '$name', '$meta_keyword','$seo_title','$seo_h1' );";
$database->query( $sql3 );

//потом для сео
// if ($keyword) {
// $sql5 = "INSERT INTO `".DB_PREFIX."url_alias` (`query`,`keyword`) VALUES ('category_id=$categoryId','$keyword');";
// $database->query($sql5);
// }

$sql6 = "INSERT INTO `".DB_PREFIX."category_to_store` (`category_id`,`store_id`) VALUES ($categoryId,$storeId);";
$database->query($sql6);

}

// final commit
$database->query( "COMMIT;" );
return TRUE;
}

function storeManufacturersIntoDatabase( &$database, &$manufacturers )
{
// find the default language and store
$languageId = $this->getDefaultLanguageId($database);
$storeId = $this->getDefaultStoreId($database);

// start transaction, remove manufacturers
$sql = "START TRANSACTION;\n";
// $sql .= "DELETE FROM `".DB_PREFIX."manufacturer`;\n";
// $sql .= "DELETE FROM `".DB_PREFIX."manufacturer_description` WHERE language_id=$languageId;\n";
$sql .= "DELETE FROM `".DB_PREFIX."manufacturer_to_store`;\n";
$sql .= "TRUNCATE TABLE `".DB_PREFIX."manufacturer`;\n";
$sql .= "TRUNCATE TABLE `".DB_PREFIX."manufacturer_description`;\n";
$sql .= "TRUNCATE TABLE `".DB_PREFIX."manufacturer_to_store`;\n";

$sql .= "DELETE FROM `".DB_PREFIX."url_alias` WHERE `query` LIKE 'manufacturer_id=%';\n";
$this->import( $database, $sql );

// generate and execute SQL for inserting the manufacturers
foreach ($manufacturers as $manufacturer) {
$manufacturerId = $manufacturer['manufacturer_id'];
$imageName = $manufacturer['image'];
$sortOrder = $manufacturer['sort_order'];
$name = $this->dbclean($manufacturer['name']);

$sql2 = "INSERT INTO `".DB_PREFIX."manufacturer` (`manufacturer_id`, `image`, `name`, `sort_order` ) VALUES ";
$sql2 .= "( $manufacturerId, '$imageName', '$name', $sortOrder ";
$sql2 .= " );";

$database->query( $sql2 );

$sql3 = "INSERT INTO `".DB_PREFIX."manufacturer_description` (`manufacturer_id`, `language_id`, `seo_title`, `seo_h1`, `meta_keyword`) VALUES ";
$sql3 .= "( $manufacturerId, $languageId, '$name', '$name', '$name' );";
$database->query( $sql3 );

//потом для сео
// if ($keyword) {
// $sql5 = "INSERT INTO `".DB_PREFIX."url_alias` (`query`,`keyword`) VALUES ('manufacturer_id=$manufacturerId','$keyword');";
// $database->query($sql5);
// }

$sql6 = "INSERT INTO `".DB_PREFIX."manufacturer_to_store` (`manufacturer_id`,`store_id`) VALUES ( '$manufacturerId', '$storeId' );\n";
$database->query( $sql6 );
// error_log($sql6."\n",3,DIR_LOGS."error.txt");
// error_log($sql3."\nn",3,DIR_LOGS."error.txt");
}

// final commit
$database->query( "COMMIT;" );
return TRUE;
}

function storeBrandsIntoDatabase( &$database, &$brands )
{
// find the default language and store
$languageId = $this->getDefaultLanguageId($database);
$storeId = $this->getDefaultStoreId($database);

// start transaction, remove brands
$sql = "START TRANSACTION;\n";
//$sql .= "DELETE FROM `".DB_PREFIX."brand_description` WHERE language_id=$languageId;\n";
// $sql .= "DELETE FROM `".DB_PREFIX."brand`;\n";
// $sql .= "DELETE FROM `".DB_PREFIX."brand_to_store`;\n";

$sql.="TRUNCATE TABLE `".DB_PREFIX."brand`;\n";
$sql.="TRUNCATE TABLE `".DB_PREFIX."brand_to_store`;\n";

$sql .= "DELETE FROM `".DB_PREFIX."url_alias` WHERE `query` LIKE 'brand_id=%';\n";
$this->import( $database, $sql );

// generate and execute SQL for inserting the brands
foreach ($brands as $brand) {
$brandId = $brand['brand_id'];
$imageName = $brand['image'];
$sortOrder = $brand['sort_order'];
$name = $this->dbclean($brand['name']);

$sql2 = "INSERT INTO `".DB_PREFIX."brand` (`brand_id`, `image`, `name`, `sort_order` ) VALUES ";
$sql2 .= "( $brandId, '$imageName', '$name', $sortOrder ";
$sql2 .= " );";

$database->query( $sql2 );

// $sql3 = "INSERT INTO `".DB_PREFIX."brand_description` (`brand_id`, `language_id`, `seo_title`, `seo_h1`, `meta_keyword`) VALUES ";
// $sql3 .= "( $brandId, $languageId, '$name', '$name', '$name' );";
// $database->query( $sql3 );

//потом для сео
// if ($keyword) {
// $sql5 = "INSERT INTO `".DB_PREFIX."url_alias` (`query`,`keyword`) VALUES ('brand_id=$brandId','$keyword');";
// $database->query($sql5);
// }

$sql6 = "INSERT INTO `".DB_PREFIX."brand_to_store` (`brand_id`,`store_id`) VALUES ($brandId,$storeId);";
$database->query($sql6);
}
// final commit
$database->query( "COMMIT;" );
return TRUE;
}

//-------****----***
function anixuploadProducts( &$handler, &$database ) {
$languageId = $this->getDefaultLanguageId($database);
$storeId = $this->getDefaultLanguageId($database);

$p_count=0; $products = array();
$c_count=0; $categories = array(); $c_name_id=array();
$m_count=0; $manufacturers = array(); $m_name_id=array();
$b_count=0; $brands = array(); $b_name_id=array();

header('Content-type: text/html; charset=utf-8');
//echo('test for ru_RU.utf8=');
//echo(setlocale(LC_ALL, 'ru_RU.utf8'));
setlocale(LC_ALL, 'ru_RU.utf8');
// if(!setlocale(LC_ALL, 'ru_RU.utf8')) setlocale(LC_ALL, 'en_US.utf8');
// if(setlocale(LC_ALL, 0) == 'C') {
// error_log(date('Y-m-d H:i:s - ', time()).' fgetcsv: не поддерживается ни одна из перечисленных локалей (ru_RU.utf8, en_US.utf8)'."\n",3,DIR_LOGS."error-o.txt"); // i
// die ('Не поддерживается ни одна из перечисленных локалей (ru_RU.utf8, en_US.utf8)');
// }

while (($dat = fgetcsv($handler, 0, ";")) !== false) {
$data = $dat;
// error_log(date('Y-m-d H:i:s - ', time()).' fgetcsv:data [0]='.$data[0].', [1]= '.$data[1].', [2]= '.$data[2]. ', [3]= '.$data[3]. ', [4]= '.$data[4]."\n",3,DIR_LOGS."error-o.txt"); // i

//добавляем категорию ----------------------------------------------------------------------------------------- категория!
if ($data[0] == "Да") {
//[0] - категория это? -- да/нет
//[1] - id категории
//[2] - id родителя
//[3] - name
//[4] - image

$category = array();
$categoryId=(int)trim( $this->clean($data[1], FALSE) );

$category['category_id'] =$categoryId;
$category['parent_id'] = (int)trim( $this->clean($data[2], FALSE) );
$categoryName=trim( $this->clean($data[3], TRUE,TRUE) );
$category['name'] = $categoryName;
$category['image'] = $this->img(trim( $this->clean($data[4], FALSE, TRUE) ));

$category['sort_order'] = $c_count;
$category['date_added'] = "NOW()";
$category['date_modified'] = "NOW()";
$category['language_id'] = $languageId;
$category['store_id'] = $languageId;

$category['meta_keyword'] = implode(',',explode(' ', trim( $this->clean($data[3], TRUE,TRUE))));
$category['seo_title'] = trim( $this->clean($data[3], TRUE,TRUE) );
$category['seo_h1'] = trim( $this->clean($data[3], TRUE,TRUE) );

$category['status'] = '1';
if ($categoryId > 0) {
$categories[$categoryId] = $category;
$c_name_id[$categoryName] = $categoryId;
$c_count++;
}

//*** error_log(date('Y-m-d H:i:s - ', time()).', $c_count= '.$c_count. ', Kodcategory: '.$category['parent_id']. ', name: '.$category['name']."\n",3,DIR_LOGS."error-o.txt"); // i

} elseif ($data[0] == "Нет") {
// product_id model sku location quantity stock_status_id image manufacturer_id price tax_class_id date_available length
// $data[1] $data[7] $data[1] склад $data[6] $st $img $mf $data[4] 0 $datenow $length

// width height length_class_id status viewed minimum cost weight_class_id date_added hit new spec main_category_id brand_id
// $width $height 1 1 1 $data[10] $data[5] 1 $datenow $hit $new $spec $data[2] $tm

//descr
//product_id language_id name meta_keyword meta_description description title h1
// $data[1] 1 $data[3] $data[3] $data[3] $ds $data[3] $data[3]";

$product=array();
$productId=(int)trim( $this->clean($data[1], FALSE) );
$product['product_id'] = $productId;
$product['sku'] = $productId;
$productName=trim( $this->clean($data[3], TRUE,TRUE) );
$product['name'] = $productName;

$maincat=(int)trim( $this->clean($data[2], FALSE) );
$product['maincategory'] =$maincat;
//добавить доп категории!!!
$categs = trim( $this->clean($data[25], FALSE) );
$categoriess = ($categs=="") ? array() : explode( "/", $categs );

if ($categoriess===FALSE) {
$categoriess = array();
} else {
$categoriess=array_unique($categoriess);
if(($key = array_search($maincat,$categoriess)) !== FALSE){
unset($categoriess[$key]);
}
}

$product['categories']=$categoriess;

//создаем или ищем manufacturer -----------------
$productManName=trim($this->clean($data[13], TRUE,TRUE));
$productManImg=$this->clean($data[15], TRUE);

$productManId=0;
if ( !(array_key_exists($productManName, $m_name_id)) ) {
$productManId=$m_count;

$manufacturer['manufacturer_id']=$productManId;
$manufacturer['name']=$productManName;
$manufacturer['image']=$this->img($productManImg);
$manufacturer['sort_order']='0';

$m_name_id[$productManName]=$productManId;
$manufacturers[$productManId]=$manufacturer;

$m_count++;
} else {
$productManId=$m_name_id[$productManName];
}
//----------
$product['manufacturer'] = $productManId;

//создаем или ищем brand -----------------
$productBrandName=$this->clean($data[14], TRUE,TRUE);
$productBrandImg=$this->clean($data[15], TRUE);

$productBrandId=0;
if ( !(array_key_exists($productBrandName, $b_name_id)) ) {
$productBrandId=$b_count;

$brand['brand_id']=$productBrandId;
$brand['name']=$productBrandName;
$brand['image']=$this->img($productBrandImg);
$brand['sort_order']='0';

$b_name_id[$productBrandName]=$productBrandId;
$brands[$productBrandId]=$brand;

$b_count++;
} else {
$productBrandId=$b_name_id[$productBrandName];
}
//----------
$product['brand'] = $productBrandId;

$product['quantity'] = (int)trim($data[6]);
$model=trim( $this->clean($data[7], FALSE) );
$product['model'] = $model;
$product['image'] = $this->img(trim( $this->clean($data[9], FALSE) ));
$product['shipping'] = '1';
$product['price'] = trim( $this->clean($data[5], FALSE) );
$product['cost'] = trim( $this->clean($data[4], FALSE) );

$product['hit'] = (int)trim($data[19]);
$product['new'] = (int)trim($data[20]);
$product['spec'] = (int)trim($data[21]);

$product['date_added'] = "NOW()";
$product['date_modified'] = "NOW()";
$product['date_available'] ="NOW()";
$product['status'] = '1';
$product['viewed'] = '1';

$product['tax_class_id'] = '0';

$longdesc=$this->clean($data[22], TRUE);
if (utf8_strlen($longdesc) <= 5) {
$longdesc='';
}

$description= ' В упаковке: '.$this->clean($data[11], FALSE).'шт. ';
$description.= ' Сертификат: '.$this->clean($data[12], TRUE).' ';
$description.= ' Страна производитель: '.$this->clean($data[16], TRUE) .' ';
$description.= ' Материал: '.$this->clean($data[17], TRUE).' '. $longdesc;

$product['description'] = $description;

$product['stock_status_id'] = $this->stoc($data[18]);

if (strlen($longdesc) <= 1) {
$metadescr=$this->clean($description,TRUE,TRUE);
$meta_in_tmp=$this->clean($data[12], TRUE).' '.$this->clean($data[16], TRUE).' '.$this->clean($data[17], TRUE);
} else {
$metadescr=$this->clean($longdesc,TRUE,TRUE);
$meta_in_tmp=$metadescr;
}

$product['meta_description'] = $metadescr;
$product['title'] = $productName;
$product['seo_title'] = $productName;
$product['seo_h1'] = $productName;

$meta_in=$meta_in_tmp.' '.$productName. ' '.$this->clean($data[16], TRUE,TRUE).' '.$model.' '.$productBrandName.' '.$productManName;

//Удаляем пунктуацию
$meta_in = preg_replace('/\p{P}/u',' ',$meta_in);

// Удаляем все слова меньше 5-х символов
$meta_in = preg_replace("/\p{Z}\p{L}{0,5}\p{Z}/u", " " ,$meta_in);
$meta_in = preg_replace("/\p{Z}\p{N}{0,5}\p{Z}/u", " " ,$meta_in);
$meta_in = preg_replace("/\p{Z}\p{S}{0,5}\p{Z}/u", " " ,$meta_in);

// Удаляем лишние пробельные символы
$meta_in = preg_replace('/\p{Z}+/u',' ',$meta_in);
$meta_in = preg_replace('/\p{Zs}+/u',' ',$meta_in);
$meta_in = preg_replace('/\p{Mc}+/u',' ',$meta_in);

$meta_out=explode(' ', $meta_in);

$meta=implode(',',$meta_out);
$product['meta_keyword'] = $meta;

$meta=mb_strtolower($meta,'utf-8');
$product['tags'] = explode(',', $meta );
$product['tags']=array_unique($product['tags']);
$stop_words=array('для','так','него','нее','зао','ооо','quot','amp','себе','себя','ведь','того','который','вам','вашему',
'сам','вами','самому','это','даже','например','эта','эту','этот','кор','своим','своими','старше','детей',
'лет','года','его','дает','или','что','где','когда','несмотря','будет','только','они','потом','можно',
'росс','пак');
$product['tags']=array_diff($product['tags'], $stop_words);

// $product['tags']=sort($product['tags']);

if ($product['tags']===FALSE) {
$product['tags'] = array();
}

$razm_er=0;
$razm=$this->clean($data[8],FALSE);
$razm_old=$razm;
$razm=preg_replace("/[x]/u","*",$razm);
$razm=preg_replace("/[X]/u","*",$razm);
$razm=preg_replace("/[х]/u","*",$razm);

$razm=preg_replace("/[\,]/",'.',$razm);
//$razm=preg_replace("/[^\*\.0-9\s]/","",$razm);
$razm=preg_replace('/[^\*\.0-9]+/i', '',$razm);

//if ($product['product_id']=='58383') {
// echo $razm.'-'.$razm_old.'-'.strlen($razm);
// die;
//}

if (strlen($razm)<=1) {
$razm_er++;
$length=0;
$width=0;
$height=0;
} else {

//list($length,$width,$height)=split('\*',$razm);
$razmer=explode('*', $razm);

if ((count($razmer) > 0) and ($razmer[0]>0)) {
$length=$razmer[0];
} else {
$length=0;
}
if ((count($razmer) > 1) and ($razmer[1]>0)) {
$width =$razmer[1];
} else {
$width=0;
}
if ((count($razmer) > 2) and ($razmer[2]>0)) {
$height =$razmer[2];
} else {
$height=0;
}
}

$product['length_class_id'] = '1';
$product['weight_class_id'] = '1';
$product['weight'] = '0';
$product['length'] = $length;
$product['width'] = $width;
$product['height'] = $height;

$product['location'] = 'склад';
$product['minimum'] = (int)trim( $this->clean($data[10], FALSE) );
$product['sort_order'] = $p_count;

$products[$productId]=$product;

$p_count++;

}
//*** error_log(date('Y-m-d H:i:s - ', time()).' $p_count= '.$p_count. ', Kodproduct= '.$product['product_id'].', name= '.$product['name']."\n",3,DIR_LOGS."error-o.txt"); // i

}

//есть что лить?
if ($p_count <= 0) {
error_log(date('Y-m-d H:i:s - ', time()).'anixuploadProducts -- no products in file.'."\n",3,DIR_LOGS."error.txt");
return FALSE;
};

//если все распарсилось и продуктов >0 то льем в базу
if (($c_count > 0) and ($p_count > 0)){
$ok=$this->storeCategoriesIntoDatabase( $database, $categories );
if (!$ok) {
error_log(date('Y-m-d H:i:s - ', time()).'storeCategoriesIntoDatabase terminated with exception.'. "\n",3,DIR_LOGS."error.txt");
return FALSE;
}
}
if (($m_count > 0) and ($p_count > 0)) {
$ok=$this->storeManufacturersIntoDatabase( $database, $manufacturers );
if (!$ok) {
error_log(date('Y-m-d H:i:s - ', time()).'storeManufacturersIntoDatabase terminated with exception.'. "\n",3,DIR_LOGS."error.txt");
return FALSE;
}
}
if (($b_count > 0) and ($p_count > 0)) {
$ok=$this->storeBrandsIntoDatabase( $database, $brands );
if (!$ok) {
error_log(date('Y-m-d H:i:s - ', time()).'storeBrandsIntoDatabase terminated with exception.'. "\n",3,DIR_LOGS."error.txt");
return FALSE;
}
}
if ($p_count > 0){
$ok=$this->storeProductsIntoDatabase( $database, $products );
if (!$ok) {
error_log(date('Y-m-d H:i:s - ', time()).'storeProductsIntoDatabase terminated with exception.'. "\n",3,DIR_LOGS."error.txt");
return FALSE;
}
}

//лог запусков
$this->setlastRun($c_count, $p_count, $database);
return TRUE;

}
//-------****----***

//проверка файла?
function validateUpload( $filev )
{
if (empty($filev)) {
error_log(date('Y-m-d H:i:s - ', time()).'File not found.'."\n",3,DIR_LOGS."error.txt");
return FALSE;
}
$tmp_handle = fopen($filev, 'r+');
if(!$tmp_handle) {
error_log(date('Y-m-d H:i:s - ', time()).'Cant open file.'."\n",3,DIR_LOGS."error.txt");
return FALSE;
}
fclose($tmp_handle);

return TRUE;
}

//превращаем в утф8
function openUpload( $file )
{
$content = iconv('windows-1251', 'UTF-8', file_get_contents($file));
$ram_handle = fopen('php://memory', 'r+');
fputs($ram_handle, $content);
rewind($ram_handle);

return $ram_handle;
}

//Чистим кэш
function clearCache() {
$this->cache->delete('category');
$this->cache->delete('category_description');
$this->cache->delete('manufacturer');
$this->cache->delete('brand');
$this->cache->delete('product');
$this->cache->delete('product_image');
$this->cache->delete('product_option');
$this->cache->delete('product_option_description');
$this->cache->delete('product_option_value');
$this->cache->delete('product_option_value_description');
$this->cache->delete('product_to_category');
$this->cache->delete('url_alias');
$this->cache->delete('product_special');
$this->cache->delete('product_discount');
}

function upload( $filename ) {
global $config;
global $log;
$config = $this->config;
$log = $this->log;
set_error_handler('error_handler_for_export',E_ALL);
register_shutdown_function('fatal_error_shutdown_handler_for_export');
$database =& $this->db;
//ini_set("memory_limit","512M");
//ini_set("max_execution_time",180);
//set_time_limit( 60 );

//проверяем файл
$ok = $this->validateUpload( $filename );
if (!$ok) {
error_log(date('Y-m-d H:i:s - ', time()).'validateUpload terminated with exception.'."\n",3,DIR_LOGS."error.txt");
return FALSE;
}
//файл в утф и в память
$handler = $this->openUpload( $filename );

$this->clearCache();

$ok = $this->anixuploadProducts( $handler, $database );
if (!$ok) {
error_log(date('Y-m-d H:i:s - ', time()).'anixuploadProducts terminated with exception.'."\n",3,DIR_LOGS."error.txt");
return FALSE;
}
//сохраним, что запускались
//$this->wasRun();
fclose($handler);
return $ok;
}

//инфа о последнем запуске
function getlastRun() {
$query = $this->db->query("SELECT * FROM " . DB_PREFIX . "import_stamp ORDER BY id DESC LIMIT 1");
$lastdate = $query->row;
$ret='В прошлый раз скрипт запускали: '.$lastdate['date']. ', и тогда он добавил: '.$lastdate['countins'].' товаров и '.$lastdate['countup'].' категорий. ';
//*** error_log(date('Y-m-d H:i:s - ', time()).'Прошлый запуск скрипта: '.$lastdate['date']. ', добавлено: '.$lastdate['countins'].' товаров и '.$lastdate['countup'].' категорий.'."\n",3,DIR_LOGS."error.txt"); // i
return $ret;
}

function setlastRun( $cat, $tov, &$database ) {
$sql="INSERT INTO ".DB_PREFIX."import_stamp (countup,countins) VALUES (".$cat.",".$tov.")";
$database->query($sql);
}
}
?>

Структура и описание полей CSV файла.

Спойлер

Вид строки CSV -файла о товаре:
Да; 022; 0; Китай;
Да; 02567; 022; Куклы и аксессуары;

Нет; 06922; 014; Кукла в пак.; 44,00; 52,00; 12шт; 328C; 30 см; 06922.jpg; 150шт; 1шт;7844119; РОСС CN.АВ04.В00115; ООО « сертификация» г.Пермь ;ASIANCENTURYTRADINGLIMITED; LEGO; LEGO.jpg ; Китай; ПВХ-пластизоль; 1;0; 0; 3; комментарий из 1С; 44,00+10%; 52,00+10%; 00123/01334; http://www.youtube.com/watch?feature=play; ;1;

1. Type_str – тип строки Да- для категории, Нет- для товара
Если Да - код подчиненной категории; код верхней категории, наименование категории
2. ID_ Name_ktg - код категории (уникальный), 123456 ,
3. ID_ Name_subktg1 - наименование подкатегории2 товара,
код Name_subktg1 ; код Name_ktg ; Name_ktg
4. Name_subktg1 - наименование подкатегории1 товара,

1. Если Нет - код товара, код самой нижней категории с товаром и дальше как описано ниже
2. ID_kod- код товара (уникальный), 123456 ,
3. ID_ Name_subktg - наименование подкатегории товара,
4. Name_tov - наименование товара, лопата
5. Cost_OLD- цена старая оптовая, 99900,99 рубл.
6. Cost_ - цена оптовая, 99999,99 рубл.,
7. Ost- количество товара на складе - остаток, 9999 шт,
8. Art- артикул, 59814/89069-596 ,
9. Size- размеры товара, 100,5 х 80 х 60,5 см,
10. Image_tov – фото товара: 0-нет, имя=код товара – ссылка на фото, 123456.jpg
11. Kol_min- кратное количество для продажи, 4 шт,
12. Kol_upack - количество в упаковке, 480 шт,
13. Sertificat- описание сертификата, номер 7844119; серия РОСС CN.АВ04.В00115; кем выдан
ООО «Управление недвижимостью, информация, сертификация» г.Пермь,
14. Name_Izgot- изготовитель (наименование фирмы) , Огонек
15. Name_Brend – (брэнд) торговая марка товара, LEGO,
16. Image_Brend – фото логотипа: 0-нет, имя=код логотипа – ссылка на его фото, B12.jpg
17. Country- страна происхождения, Китай
18. Material - материал, из чего изготовлен товар, ПВХ-пластизоль
19. Buy- 0 – нет и отображать в ИМ не нужно, 1-есть в наличии,
2 – нет на складе, но можно купить под заказ, 3 – нет на складе, но товар в пути.
20. Hit - 0 - обычный товар, 1- хит, хорошо продаваемый товар за выбранный период времени,
21. New- 0 – уже есть, был - сбросить признак NEW
1 - новый (поступил относительно Date_1С_to_IM– приход, перемещение с другого
склада на основной, возврат) отобразить, высветить NEW).
22. Spec - 0 -.товар продается на общих условиях, в СпецПредложение не попадает,
1 – АКЦИЯ цена стала ниже внутри периода от указанной до текущей даты,
2 – цена текущая, только товар продается без скидки,
3 – на товар снижена цена и он продается без скидки,
4 - товар участвует в СпецПредлож., не зависит от измен. цен и дат, возможны скидки и без.
23. Large- развернутое описание товара (комментарий из 1С, возможна разметка HTML)
Признак *к* означает начало текста Комплектации и до конца ???.
24. Cost_R- цена розничная, 99999,99 рубл.,
25. Cost_R_OLD- цена старая розничная, 99900,99 рубл.,
26. Name_subktg – список кодов наименований дополнительных категорий товара (разделитель / )
27. Adrr_Video– адрес видео о товаре на Youtube
28. TTX - Характеристика товара (из 1С, возможна разметка HTML) у разных товаров свои ТТХ параметры
29. Dop_Usl –дополнительные услуги по товару:
0 или пусто – нет услуг, 1- услуга по настройке и проверке, 2- по сборке, 3- подъем на этаж.

Мои попытки переделки успеха не принесли - лезут ошибки. Но спецам думаю будет легко подправить 3-4 оператора.
Заранее благодарен !

[Помогите] Помогите подправить Скрипт импорта в И-маг на Opencart Version 1.5.1.3.

MIV14