Init

2026-02-14 19:34:54 +03:00
commit 5c3329238b
867 changed files with 214778 additions and 0 deletions
--- a/simpla/ajax/import.php
+++ b/simpla/ajax/import.php
@@ -0,0 +1,396 @@
+<?php
+
+chdir('../..');
+require_once('api/Simpla.php');
+
+class ImportAjax extends Simpla
+{	
+	// Соответствие полей в базе и имён колонок в файле
+	private $columns_names = array(
+			'name'=>             array('product', 'name', 'товар', 'название', 'наименование'),
+			'url'=>              array('url', 'адрес'),
+			'visible'=>          array('visible', 'published', 'видим'),
+			'featured'=>         array('featured', 'hit', 'хит', 'рекомендуемый'),
+			'category'=>         array('category', 'категория'),
+			'brand'=>            array('brand', 'бренд'),
+			'variant'=>          array('variant', 'вариант'),
+			'price'=>            array('price', 'цена'),
+			'compare_price'=>    array('compare price', 'старая цена'),
+			'sku'=>              array('sku', 'артикул'),
+			'stock'=>            array('stock', 'склад', 'на складе'),
+			'meta_title'=>       array('meta title', 'заголовок страницы'),
+			'meta_keywords'=>    array('meta keywords', 'ключевые слова'),
+			'meta_description'=> array('meta description', 'описание страницы'),
+			'annotation'=>       array('annotation', 'аннотация', 'краткое описание'),
+			'description'=>      array('description', 'описание'),
+			'images'=>           array('images', 'изображения')
+			);
+	
+	// Соответствие имени колонки и поля в базе
+	private $internal_columns_names = array();
+
+	private $import_files_dir      = 'simpla/files/import/'; // Временная папка		
+	private $import_file           = 'import.csv';           // Временный файл
+	private $category_delimiter = ',';                       // Разделитель каегорий в файле
+	private $subcategory_delimiter = '/';                    // Разделитель подкаегорий в файле
+	private $column_delimiter      = ';';
+	private $products_count        = 10;
+	private $columns               = array();
+
+	public function import()
+	{
+		if(!$this->managers->access('import'))
+			return false;
+
+		// Для корректной работы установим локаль UTF-8
+		setlocale(LC_ALL, 'ru_RU.UTF-8');
+		
+		// Определяем колонки из первой строки файла
+		$f = fopen($this->import_files_dir.$this->import_file, 'r');
+		$this->columns = fgetcsv($f, null, $this->column_delimiter);
+
+		// Заменяем имена колонок из файла на внутренние имена колонок
+		foreach($this->columns as &$column)
+		{ 
+			if($internal_name = $this->internal_column_name($column))
+			{
+				$this->internal_columns_names[$column] = $internal_name;
+				$column = $internal_name;
+			}
+		}
+
+		// Если нет названия товара - не будем импортировать
+		if(!in_array('name', $this->columns) && !in_array('sku', $this->columns))
+			return false;
+	 	
+		// Переходим на заданную позицию, если импортируем не сначала
+		if($from = $this->request->get('from'))
+			fseek($f, $from);
+		
+		// Массив импортированных товаров
+		$imported_items = array();	
+		
+		// Проходимся по строкам, пока не конец файла
+		// или пока не импортировано достаточно строк для одного запроса
+		for($k=0; !feof($f) && $k<$this->products_count; $k++)
+		{ 
+			// Читаем строку
+			$line = fgetcsv($f, 0, $this->column_delimiter);
+
+			$product = null;			
+
+			if(is_array($line))			
+			// Проходимся по колонкам строки
+			foreach($this->columns as $i=>$col)
+			{
+				// Создаем массив item[название_колонки]=значение
+ 				if(isset($line[$i]) && !empty($line) && !empty($col))
+					$product[$col] = $line[$i];
+			}
+			
+			// Импортируем этот товар
+	 		if($imported_item = $this->import_item($product))
+				$imported_items[] = $imported_item;
+		}
+
+		/*
+		if(count($variants_ids)>0)
+		{
+			// Для отчета выбираем импортированные товары
+	 		$variants = (array)$this->variants->get_variants(array('id'=>$variants_ids));
+	 		$products_ids = array();
+
+	 		foreach($variants as $v)
+	 			$products_ids[] = $v->product_id;
+	 		
+	 		$products = array();	
+	 		foreach($this->products->get_products(array('id'=>$products_ids)) as $p)
+	 			$products[$p->id] = $p;
+	 		
+
+	 		foreach($variants as $v)
+	 		{
+	 			$imported_items[$v->id]->variant_id = $v->id;
+	 			$imported_items[$v->id]->product_id = $v->product_id;
+	 			$imported_items[$v->id]->variant_name = $v->name;
+	 			$imported_items[$v->id]->product_name = $products[$v->product_id]->name;
+	 		}
+ 		}
+ 		else
+ 		{
+ 			$imported_items = null;
+ 		}
+		*/
+		
+		// Запоминаем на каком месте закончили импорт
+ 		$from = ftell($f);
+ 		
+ 		// И закончили ли полностью весь файл
+ 		$result->end = feof($f);
+
+		fclose($f);
+		$size = filesize($this->import_files_dir.$this->import_file);
+		
+		// Создаем объект результата
+		$result->from = $from;          // На каком месте остановились
+		$result->totalsize = $size;     // Размер всего файла
+		$result->items = $imported_items;   // Импортированные товары
+	
+		return $result;
+	}
+	
+	// Импорт одного товара $item[column_name] = value;
+	private function import_item($item)
+	{
+		// Проверим не пустое ли название и артинкул (должно быть хоть что-то из них)
+		if(empty($item['name']) && empty($item['sku']))
+			return false;
+
+		// Подготовим товар для добавления в базу
+		if(isset($item['name']))
+			$product['name'] = trim($item['name']);
+
+		if(isset($item['meta_title']))
+			$product['meta_title'] = trim($item['meta_title']);
+
+		if(isset($item['meta_keywords']))
+			$product['meta_keywords'] = trim($item['meta_keywords']);
+
+		if(isset($item['meta_description']))
+			$product['meta_description'] = trim($item['meta_description']);
+
+		if(isset($item['annotation']))
+			$product['annotation'] = trim($item['annotation']);
+
+		if(isset($item['description']))
+			$product['body'] = trim($item['description']);
+	
+		if(isset($item['visible']))
+			$product['visible'] = intval($item['visible']);
+
+		if(isset($item['featured']))
+			$product['featured'] = intval($item['featured']);
+	
+		if(isset($item['url']))
+			$product['url'] = trim($item['url']);
+		elseif(isset($item['name']))
+			$product['url'] = $this->translit($item['name']);
+	
+		// Если задан бренд
+		if(!empty($item['brand']))
+		{
+			$item['brand'] = trim($item['brand']);
+			// Найдем его по имени
+			$this->db->query('SELECT id FROM __brands WHERE name=?', $item['brand']);
+			if(!$product['brand_id'] = $this->db->result('id'))
+				// Создадим, если не найден
+				$product['brand_id'] = $this->brands->add_brand(array('name'=>$item['brand'], 'meta_title'=>$item['brand'], 'meta_keywords'=>$item['brand'], 'meta_description'=>$item['brand']));
+		}
+		
+		// Если задана категория
+		$category_id = null;
+		$categories_ids = array();
+		if(isset($item['category']))
+		{
+			foreach(explode($this->category_delimiter, $item['category']) as $c)
+				$categories_ids[] = $this->import_category($c);
+			$category_id = reset($categories_ids);
+		}
+	
+		// Подготовим вариант товара
+		if(isset($item['variant']))
+			$variant['name'] = trim($item['variant']);
+			
+		if(isset($item['price']))
+			$variant['price'] = str_replace(',', '.', trim($item['price']));
+			
+		if(isset($item['compare_price']))
+			$variant['compare_price'] = trim($item['compare_price']);
+			
+		if(isset($item['stock']))
+			if($item['stock'] == '')
+				$variant['stock'] = null;
+			else
+				$variant['stock'] = trim($item['stock']);
+			
+		if(isset($item['sku']))
+			$variant['sku'] = trim($item['sku']);
+		
+		// Если задан артикул варианта, найдем этот вариант и соответствующий товар
+		if(!empty($variant['sku']))
+		{ 
+			$this->db->query('SELECT id as variant_id, product_id FROM __variants WHERE sku=? LIMIT 1', $variant['sku']);
+			$result = $this->db->result();
+			if($result)
+			{
+				// и обновим товар
+				if(!empty($product))
+					$this->products->update_product($result->product_id, $product);
+				// и вариант
+				if(!empty($variant))
+					$this->variants->update_variant($result->variant_id, $variant);
+				
+				$product_id = $result->product_id;
+				$variant_id = $result->variant_id;
+				// Обновлен
+				$imported_item->status = 'updated';
+			}
+		}
+		
+		// Если на прошлом шаге товар не нашелся, и задано хотя бы название товара
+		if((empty($product_id) || empty($variant_id)) && isset($item['name']))
+		{
+			if(!empty($variant['sku']) && empty($variant['name']))
+				$this->db->query('SELECT v.id as variant_id, p.id as product_id FROM __products p LEFT JOIN __variants v ON v.product_id=p.id WHERE v.sku=? LIMIT 1', $variant['sku']);			
+			elseif(isset($item['variant']))
+				$this->db->query('SELECT v.id as variant_id, p.id as product_id FROM __products p LEFT JOIN __variants v ON v.product_id=p.id AND v.name=? WHERE p.name=? LIMIT 1', $item['variant'], $item['name']);
+			else
+				$this->db->query('SELECT v.id as variant_id, p.id as product_id FROM __products p LEFT JOIN __variants v ON v.product_id=p.id WHERE p.name=? LIMIT 1', $item['name']);			
+			
+			$r =  $this->db->result();
+			if($r)
+			{
+				$product_id = $r->product_id;
+				$variant_id = $r->variant_id;
+			}
+			// Если товар найден - обноаляем,
+			if(!empty($variant_id))
+			{
+				$this->variants->update_variant($variant_id, $variant);
+				$this->products->update_product($product_id, $product);				
+				$imported_item->status = 'updated';		
+			}
+			// Иначе - добавляем
+			elseif(empty($variant_id))
+			{
+				if(empty($product_id))
+					$product_id = $this->products->add_product($product);
+				$variant['product_id'] = $product_id;
+				$variant_id = $this->variants->add_variant($variant);
+				$imported_item->status = 'added';		
+			}
+		}
+		
+		// Нужно вернуть обновленный товар
+		$imported_item->variant = $this->variants->get_variant(intval($variant_id));			
+		$imported_item->product = $this->products->get_product(intval($product_id));						
+
+		// Добавляем категории к товару
+		if(!empty($categories_ids))
+			foreach($categories_ids as $c_id)
+				$this->categories->add_product_category($product_id, $c_id);
+
+ 		// Изображения товаров
+ 		if(isset($item['images']))
+ 		{
+ 			// Изображений может быть несколько, через запятую
+ 			$images = explode(',', $item['images']);
+ 			foreach($images as $image)
+ 			{
+ 				$image = trim($image);
+ 				if(!empty($image))
+ 				{
+	 				// Имя файла
+					$image_filename = pathinfo($image, PATHINFO_BASENAME);
+	 				
+	 				// Добавляем изображение только если такого еще нет в этом товаре
+					$this->db->query('SELECT filename FROM __images WHERE product_id=? AND (filename=? OR filename=?) LIMIT 1', $product_id, $image_filename, $image);
+					if(!$this->db->result('filename'))
+					{
+						$this->products->add_image($product_id, $image);
+					}
+				}
+ 			}
+ 		}
+ 		// Характеристики товаров
+ 		foreach($item as $feature_name=>$feature_value)
+ 		{
+ 			// Если нет такого названия колонки, значит это название свойства
+ 			if(!in_array($feature_name, $this->internal_columns_names))
+ 			{ 
+ 				// Свойство добавляем только если для товара указана категория
+				if($category_id)
+				{
+					$this->db->query('SELECT f.id FROM __features f WHERE f.name=? LIMIT 1', $feature_name);
+					if(!$feature_id = $this->db->result('id'))
+						$feature_id = $this->features->add_feature(array('name'=>$feature_name));
+						
+					$this->features->add_feature_category($feature_id, $category_id);				
+					$this->features->update_option($product_id, $feature_id, $feature_value);
+				}
+				
+ 			}
+ 		} 		
+ 		return $imported_item;
+	}
+	
+	
+	// Отдельная функция для импорта категории
+	private function import_category($category)
+	{			
+		// Поле "категория" может состоять из нескольких имен, разделенных subcategory_delimiter-ом
+		// Только неэкранированный subcategory_delimiter может разделять категории
+		$delimiter = $this->subcategory_delimiter;
+		$regex = "/\\DELIMITER((?:[^\\\\\DELIMITER]|\\\\.)*)/";
+		$regex = str_replace('DELIMITER', $delimiter, $regex);
+		$names = preg_split($regex, $category, 0, PREG_SPLIT_DELIM_CAPTURE);
+		$id = null;   
+		$parent = 0; 
+		
+		// Для каждой категории
+		foreach($names as $name)
+		{
+			// Заменяем \/ на /
+			$name = trim(str_replace("\\$delimiter", $delimiter, $name));
+			if(!empty($name))
+			{
+				// Найдем категорию по имени
+				$this->db->query('SELECT id FROM __categories WHERE name=? AND parent_id=?', $name, $parent);
+				$id = $this->db->result('id');
+				
+				// Если не найдена - добавим ее
+				if(empty($id))
+					$id = $this->categories->add_category(array('name'=>$name, 'parent_id'=>$parent, 'meta_title'=>$name,  'meta_keywords'=>$name,  'meta_description'=>$name, 'url'=>$this->translit($name)));
+
+				$parent = $id;
+			}	
+		}
+		return $id;
+	}
+
+	private function translit($text)
+	{
+		$ru = explode('-', "А-а-Б-б-В-в-Ґ-ґ-Г-г-Д-д-Е-е-Ё-ё-Є-є-Ж-ж-З-з-И-и-І-і-Ї-ї-Й-й-К-к-Л-л-М-м-Н-н-О-о-П-п-Р-р-С-с-Т-т-У-у-Ф-ф-Х-х-Ц-ц-Ч-ч-Ш-ш-Щ-щ-Ъ-ъ-Ы-ы-Ь-ь-Э-э-Ю-ю-Я-я"); 
+		$en = explode('-', "A-a-B-b-V-v-G-g-G-g-D-d-E-e-E-e-E-e-ZH-zh-Z-z-I-i-I-i-I-i-J-j-K-k-L-l-M-m-N-n-O-o-P-p-R-r-S-s-T-t-U-u-F-f-H-h-TS-ts-CH-ch-SH-sh-SCH-sch---Y-y---E-e-YU-yu-YA-ya");
+
+	 	$res = str_replace($ru, $en, $text);
+		$res = preg_replace("/[\s]+/ui", '-', $res);
+		$res = preg_replace('/[^\p{L}\p{Nd}\d-]/ui', '', $res);
+	 	$res = strtolower($res);
+	    return $res;  
+	}
+	
+	// Фозвращает внутреннее название колонки по названию колонки в файле
+	private function internal_column_name($name)
+	{
+ 		$name = trim($name);
+ 		$name = str_replace('/', '', $name);
+ 		$name = str_replace('\/', '', $name);
+		foreach($this->columns_names as $i=>$names)
+		{
+			foreach($names as $n)
+				if(!empty($name) && preg_match("/^".preg_quote($name)."$/ui", $n))
+					return $i;
+		}
+		return false;				
+	}
+}
+
+$import_ajax = new ImportAjax();
+header("Content-type: application/json; charset=UTF-8");
+header("Cache-Control: must-revalidate");
+header("Pragma: no-cache");
+header("Expires: -1");		
+		
+$json = json_encode($import_ajax->import());
+print $json;