name = 'shopimporter'; $this->tab = 'migration_tools'; $this->version = '1.0'; $this->author = 'PrestaShop'; $this->need_instance = 0; parent::__construct (); $this->displayName = $this->l('Shop Importer'); $this->description = $this->l('This module allows you to import your shop from another system into Prestashop.'); $this->supportedImports = array( 'language' => array('methodName' => 'getLangagues', 'name' => $this->l('Language'), 'className' => 'Language', 'label' => $this->l('Import Languages'), 'table' => 'lang', 'identifier' => 'id_lang', 'alterTable' => array('id_lang' => 'int(10)'), 'info' => $this->l('New languages will automatically add translations.'), 'defaultId' => 'PS_LANG_DEFAULT' ), 'currency' => array('methodName' => 'getCurrencies', 'name' => $this->l('Currency'), 'className' => 'Currency', 'label' => $this->l('Import Currencies'), 'table' => 'currency', 'identifier' => 'id_currency', 'alterTable' => array('id_currency' => 'int(10)'), 'delete' => true, 'defaultId' => 'PS_CURRENCY_DEFAULT' ), /* 'tax' => array('methodName' => 'getTaxes', 'name' => $this->l('Taxes'), 'className' => 'Tax', 'label' => $this->l('Import Taxes'), 'table' => 'tax', 'identifier' => 'id_tax', 'alterTable' => array('id_tax' => 'int(10)'), 'delete' => true ), 'tax_rule' => array('methodName' => 'getTaxes rules', 'name' => $this->l('Taxes rules'), 'className' => 'TaxRule', 'label' => $this->l('Import Taxes Rules'), 'table' => 'tax_rules_group', 'identifier' => 'id_tax', 'alterTable' => array('id_tax_rules_group' => 'int(10)'), 'delete' => true ), */ 'zone' => array('methodName' => 'getZones', 'name' => $this->l('Zone'), 'className' => 'Zone', 'label' => $this->l('Import Zones'), 'table' => 'zone', 'identifier' => 'id_zone', 'alterTable' => array('id_zone' => 'int(10)'), 'delete' => true ), 'country' => array('methodName' => 'getCountries', 'name' => $this->l('Country'), 'className' => 'Country', 'label' => $this->l('Import Countries'), 'table' => 'country', 'identifier' => 'id_country', 'foreign_key' => array('id_zone', 'id_currency'), 'alterTable' => array('id_country' => 'int(10)'), 'delete' => true, 'defaultId' => 'PS_COUNTRY_DEFAULT' ), 'state' => array('methodName' => 'getStates', 'name' => $this->l('State'), 'className' => 'State', 'label' => $this->l('Import States'), 'table' => 'state', 'identifier' => 'id_state', 'foreign_key' => array('id_zone', 'id_country'), 'alterTable' => array('id_state' => 'int(10)'), 'delete' => true ), 'group' => array('methodName' => 'getGroups', 'name' => $this->l('Group'), 'className' => 'Group', 'label' => $this->l('Import Groups'), 'table' => 'group', 'identifier' => 'id_group', 'alterTable' => array('id_group' => 'int(10)'), 'delete' => true, ), 'customer' => array('methodName' => 'getCustomers', 'name' => $this->l('Customer'), 'className' => 'Customer', 'label' => $this->l('Import Customers'), 'table' => 'customer', 'identifier' => 'id_customer', 'foreign_key' => array('id_group'), 'alterTable' => array('id_customer' => 'int(10)', 'passwd' => 'varchar(100)'), 'delete' => true, 'association' => array( array( 'table' => 'customer_group', 'fields' => array('id_customer', 'id_group'), 'matchTable' => array('customer', 'group'), ) ) ), 'address' => array('methodName' => 'getAddresses', 'name' => $this->l('Address'), 'className' => 'Address', 'label' => $this->l('Import Addresses'), 'table' => 'address', 'identifier' => 'id_address', 'foreign_key' => array('id_country', 'id_state', 'id_customer'), 'alterTable' => array('id_address' => 'int(10)'), 'delete' => true ), 'manufacturer' => array('methodName' => 'getManufacturers', 'name' => $this->l('Manufacturer'), 'className' => 'Manufacturer', 'label' => $this->l('Import Manufacturers'), 'table' => 'manufacturer', 'identifier' => 'id_manufacturer', 'delete' => true, 'alterTable' => array('id_manufacturer' => 'int(10)'), 'hasImage' => true ), 'supplier' => array('methodName' => 'getSuppliers', 'name' => $this->l('Supplier'), 'className' => 'Supplier', 'label' => $this->l('Import Suppliers'), 'table' => 'supplier', 'identifier' => 'id_supplier', 'delete' => true, 'alterTable' => array('id_supplier' => 'int(10)'), 'hasImage' => true ), 'category' => array('methodName' => 'getCategories', 'name' => $this->l('Category'), 'className' => 'Category', 'label' => $this->l('Import Categories'), 'table' => 'category', 'identifier' => 'id_category', 'alterTable' => array('id_category' => 'int(10)'), 'delete' => true, 'hasImage' => true, ), 'attributegroup' => array('methodName' => 'getAttributesGroups', 'name' => $this->l('AttributeGroup'), 'className' => 'AttributeGroup', 'label' => $this->l('Import Attributes Groups'), 'table' => 'attribute_group', 'identifier' => 'id_attribute_group', 'alterTable' => array('id_attribute_group' => 'int(10)'), 'delete' => true ), 'attribute' => array('methodName' => 'getAttributes', 'name' => $this->l('Attribute'), 'className' => 'Attribute', 'label' => $this->l('Import Attributes'), 'table' => 'attribute', 'identifier' => 'id_attribute', 'alterTable' => array('id_attribute' => 'int(10)'), 'foreign_key' => array('id_attribute_group'), 'delete' => true ), 'product' => array('methodName' => 'getProducts', 'name' => $this->l('Product'), 'className' => 'Product', 'label' => $this->l('Import Products'), 'table' => 'product', 'identifier' => 'id_product', 'alterTable' => array('id_product' => 'int(10)'), 'foreign_key' => array('id_category'), 'delete' => true, 'association' => array( array( 'table' => 'category_product', 'fields' => array('id_category', 'id_product'), 'matchTable' => array('category', 'product') ) ), 'hasImage' => true ), 'combination' => array('methodName' => 'getProductsCombination', 'name' => $this->l('Combination'), 'className' => 'Combination', 'label' => $this->l('Import Products Combinations'), 'table' => 'product_attribute', 'identifier' => 'id_product_attribute', 'alterTable' => array('id_product_attribute' => 'int(10)', 'id_product' => 'int(10)'), 'foreign_key' => array('id_product'), 'delete' => false, 'association' => array( array( 'table' => 'product_attribute_combination', 'fields' => array('id_attribute', 'id_product_attribute'), 'matchTable' => array('attribute', 'product_attribute') ) ) ), 'orderstate' => array('methodName' => 'getOrdersStates', 'name' => $this->l('Orders States'), 'className' => 'OrderState', 'label' => $this->l('Import Orders States'), 'table' => 'order_state', 'identifier' => 'id_order_state', 'alterTable' => array('id_order_state' => 'int(10)') ), 'cart' => array('methodName' => 'getOrders', 'name' => $this->l('Order'), 'className' => 'Cart', 'label' => $this->l('Import Orders'), 'table' => 'cart', 'identifier' => 'id_cart', 'foreign_key' => array('id_address_delivery', 'id_address_invoice', 'id_customer'), 'alterTable' => array('id_cart' => 'int(10)') ), 'orderhistory' => array('methodName' => 'getOrdersHistory', 'name' => $this->l('Order history'), 'className' => 'Order history', 'label' => $this->l('Import Order History'), 'table' => 'order_history', 'identifier' => 'id_order_history', 'foreign_key' => array('id_order', 'id_order_state'), 'alterTable' => array('id_order_history' => 'int(10)'), 'hidden' => true ), 'order' => array('methodName' => 'getOrders', 'name' => $this->l('Order'), 'className' => 'Order', 'label' => $this->l('Import Order History'), 'table' => 'orders', 'identifier' => 'id_order', 'alterTable' => array('id_order' => 'int(10)'), 'hidden' => true ) ); } public function install() { return parent::install(); } public function uninstall() { return parent::uninstall(); } public function getContent() { global $cookie; $exportModules = parent::getImportModulesOnDisk(); //get installed module only foreach($exportModules as $key => $module) if ($module->name == $this->name OR !(bool)$module->id) unset($exportModules[$key]); $html = '
'.$this->l('Import from another system').'
'.$this->l('Before starting the import please backup your database. ').' '.$this->l(' Click here to backup').'

'; if (sizeof($exportModules)) { $html .= '
'; } else $html .= '
'.$this->l('No import module installed').'
'; $html .= '
'; return $html; } public function generiqueImport($className, $fields, $save = false) { $return = ''; $json = array(); $errors = array(); $json['hasError'] = false; $json['datas'] = array_values($fields); $languages = array(); $defaultLanguage = ''; $table = $this->supportedImports[strtolower($className)]['table']; $object = new $className(); $rules = call_user_func(array($className, 'getValidationRules'), $className); if ((sizeof($rules['requiredLang']) OR sizeof($rules['sizeLang']) OR sizeof($rules['validateLang']) OR Tools::isSubmit('syncLang') OR Tools::isSubmit('syncCurrency'))) { $moduleName = Tools::getValue('moduleName'); if (file_exists('../../modules/'.$moduleName.'/'.$moduleName.'.php')) { require_once('../../modules/'.$moduleName.'/'.$moduleName.'.php'); $importModule = new $moduleName(); $importModule->server = Tools::getValue('server'); $importModule->user = Tools::getValue('user'); $importModule->passwd = Tools::getValue('password'); $importModule->database = Tools::getValue('database'); $importModule->prefix = Tools::getValue('prefix'); $defaultLanguage = new Language((int)Configuration::get('PS_LANG_DEFAULT')); $languages = $importModule->getLangagues(0); if (Tools::isSubmit('syncLang')) { $defaultIdLand = $importModule->getDefaultIdLang(); $defaultLanguageImport = new Language(Language::getIdByIso($languages[$defaultIdLand]['iso_code'])); if ($defaultLanguage->iso_code != $defaultLanguageImport->iso_code) $errors[] = $this->l('Default language doesn\'t match : ').'
'.Configuration::get('PS_SHOP_NAME').' : '.$defaultLanguage->name.' ≠ '.$importModule->displayName.' : '.$defaultLanguageImport->name.'
'.$this->l('Please change default language in your configuration'); } if (Tools::isSubmit('syncCurrency')) { $defaultIdCurrency = $importModule->getDefaultIdCurrency(); $currencies = $importModule->getCurrencies(0); if (!empty($currencies[$defaultIdCurrency]['iso_code'])) $defaultCurrencyImport = new Currency((int)Currency::getIdByIsoCode($currencies[$defaultIdCurrency]['iso_code'])); else $defaultCurrencyImport = new Currency((int)Currency::getIdByIsoCodeNum($currencies[$defaultIdCurrency]['iso_code_num'])); $defaultCurrency = new Currency((int)Configuration::get('PS_CURRENCY_DEFAULT')); if ($defaultCurrency->iso_code != $defaultCurrencyImport->iso_code) $errors[] = $this->l('Default currency doesn\'t match : ').'
'.Configuration::get('PS_SHOP_NAME').' : '.$defaultCurrency->name.' ≠ '.$importModule->displayName.' : '.$defaultCurrencyImport->name.'
'.$this->l('Please change default currency in your configuration'); } if (!empty($errors)) die('{"hasError" : true, "error" : '.Tools::jsonEncode($errors).'}'); } else die('{"hasError" : true, "error" : ["FATAL ERROR"], "datas" : []}'); } foreach($fields as $key => $field) { $id = $this->supportedImports[strtolower($className)]['identifier']; //remove wrong fields (ex : id_toto in Customer) foreach($field as $name => $value) if (!array_key_exists($name, get_object_vars($object)) AND ($name != $id) AND ($name != 'association') AND ($name != 'images') AND (strtolower($className) != 'cart')) unset($field[$name]); $return = $this->validateRules($rules, $field, $className, $languages, $defaultLanguage); $fields[$key] = $field; if (!empty($return)) { //skip mode if (Tools::getValue('hasErrors') == 1) unset($fields[$key]); $errors[] = $return; array_unshift($errors[sizeof($errors)-1], $field[$id]); } } if (sizeof($errors) > 0) { $json['hasError'] = true; $json['error'] = $errors; } if ($save OR Tools::isSubmit('syncLang')) { //add language if not exist in prestashop if ($className == 'Language') { if (Tools::isSubmit('syncLang')) $add = true; else $add = false; $errors = $this->checkAndAddLang($fields, $add); } elseif ($className == 'Cart') { $this->saveOrders($fields); } else { $return = $this->saveObject($className, $fields); $this->cleanPositions($table); //insert association if (array_key_exists('association', $this->supportedImports[strtolower($className)])) $this->insertAssociation(strtolower($className), $fields); if (!empty($return)) { $json['hasError'] = true; $json['error'] = $return; } } if ($className == 'Category' AND (sizeof($fields) != (int)Tools::getValue('nbr_import'))) $this->updateCat(); } if (sizeof($errors) > 0 AND is_array($errors)) { $json['hasError'] = true; $json['error'] = $errors; } die(Tools::jsonEncode($json)); } private function saveObject($className, $items) { $return = array(); $table = $this->supportedImports[strtolower($className)]['table']; //creating temporary fields for identifiers matching and password if (array_key_exists('alterTable', $this->supportedImports[strtolower($className)])) $this->alterTable(strtolower($className)); foreach($items as $item) { $object = new $className; $id = $item[$this->supportedImports[strtolower($className)]['identifier']]; if (array_key_exists('foreign_key', $this->supportedImports[strtolower($className)])) $this->replaceForeignKey($item, $table); $matchIdLang = $this->getMatchIdLang(1); foreach($item as $key => $val) { if ($key == 'passwd') { $password = $val; $val = substr($val,0,29); } if (is_array($val) AND $key != 'images') { foreach($matchIdLang as $k => $v) if ($k != $v) { $item[$key][$v] = $val[$k]; unset($item[$key][$k]); } $object->$key = $item[$key]; } else $object->$key = $val; } if (!$object->save(false, false)) $return[] = array($item[$this->supportedImports[strtolower($className)]['identifier']], $this->l('An error occurred when adding the object')); else { $this->saveMatchId(strtolower($className), (int)$object->id, (int)$id); if ($className == 'Customer') Db::getInstance()->Execute('UPDATE '._DB_PREFIX_.'customer SET passwd_'.Tools::getValue('moduleName').' = \''.$password.'\' WHERE id_customer = '.(int)$object->id); if (array_key_exists('hasImage', $this->supportedImports[strtolower($className)]) AND Tools::isSubmit('images_'.$className)) $this->copyImg($item, $className); } } return $return; } private function saveOrders($items) { $this->saveObject('cart', $items); //import cart product $foreignKey = $this->getForeignKey('Cart', array('id_cart', 'id_product', 'id_product_attribute', 'id_customer','id_address_invoice', 'id_address_delivery')); foreach($items as &$item) { foreach($item['cart_products'] as $k => $cart_products) { foreach($cart_products as $key => $val) if (array_key_exists($key, $foreignKey)) if (array_key_exists($val, $foreignKey[$key])) $item['cart_products'][$k][$key] = $foreignKey[$key][$val]; else $item['cart_products'][$k][$key] = 0; Db::getInstance()->autoExecute(_DB_PREFIX_.'cart_product', $item['cart_products'][$k],'INSERT'); } foreach($item['order_products'] as $k => $order_products) { foreach($order_products as $key => $val) if (array_key_exists($key, $foreignKey)) if (array_key_exists($val, $foreignKey[$key])) $item['order_products'][$k][$key] = $foreignKey[$key][$val]; else $item['order_products'][$k][$key] = 0; } } //cart to order $this->cartToOrder($items, $foreignKey); $foreignKey = array_merge($this->getForeignKey('Cart', array('id_order', 'id_order_state')), $foreignKey); foreach($items as &$item) { //insert product in order detail foreach($item['order_products'] as $k => $order_products) { foreach($order_products as $key => $val) if (array_key_exists($key, $foreignKey)) if (array_key_exists($val, $foreignKey[$key])) $item['order_products'][$k][$key] = $foreignKey[$key][$val]; else $item['order_products'][$k][$key] = 0; Db::getInstance()->autoExecute(_DB_PREFIX_.'order_detail', $item['order_products'][$k],'INSERT'); } //save order history foreach($item['order_history'] as $k => $order_history) { foreach($order_history as $key => $val) if (array_key_exists($key, $foreignKey)) if (array_key_exists($val, $foreignKey[$key])) $item['order_history'][$k][$key] = $foreignKey[$key][$val]; else $item['order_history'][$k][$key] = 0; Db::getInstance()->autoExecute(_DB_PREFIX_.'order_history', $item['order_history'][$k],'INSERT'); } } } private function insertAssociation($table, $items) { foreach($this->supportedImports[$table]['association'] AS $association) { $associatFields = ''; $associatFieldsName = implode('`, `', $association['fields']); $tableAssociation = $association['table']; $matchTable = $association['matchTable']; if (!empty($items)) { $match = array(); foreach($matchTable as $mTable) { $tmp = $this->getForeignKey($mTable, array('id_'.$mTable)); if (array_key_exists('id_'.$mTable, $tmp)) $match['id_'.$mTable] = $tmp['id_'.$mTable]; else $match['id_'.$mTable] = $this->getDefaultId($table); } foreach($items AS $item) foreach($item AS $key => $val) if ($key == 'association' AND !empty($key)) foreach($val[$tableAssociation] AS $k => $v) { $associatFields .= ' ('.((array_key_exists($k, $match[$association['fields'][0]])) ? (int)$match[$association['fields'][0]][$k] : '1').', '; $associatFields .= (int)$match[$association['fields'][1]][$v].'), '; } if ($associatFields != '') Db::getInstance()->Execute('INSERT INTO `'._DB_PREFIX_.pSQL($tableAssociation).'` (`'.$associatFieldsName.'`) VALUES '.rtrim($associatFields, ', ')); } } } private function saveMatchId($className, $psId, $matchId) { $table = $this->supportedImports[$className]['table']; $moduleName = Tools::getValue('moduleName'); $identifier = $this->supportedImports[$className]['identifier']; Db::getInstance()->Execute('UPDATE '._DB_PREFIX_.pSQL($table).' SET `'.pSQL($identifier).'_'.pSQL($moduleName).'` = '.(int)$matchId.' WHERE `'.pSQL($identifier).'` = '.(int)$psId); } private function getMatchId($className) { $table = $this->supportedImports[$className]['table']; $moduleName = Tools::getValue('moduleName'); $identifier = $this->supportedImports[$className]['identifier']; $returns = Db::getInstance()->ExecuteS('SELECT `'.pSQL($identifier).'_'.pSQL($moduleName).'`, `'.pSQL($identifier).'` FROM '._DB_PREFIX_.pSQL($table).' WHERE `'.pSQL($identifier).'_'.pSQL($moduleName).'` != 0 '); $match = array(); foreach($returns as $return) $match[$return[$identifier.'_'.$moduleName]] = $return[$identifier]; return $match; } private function getDefaultId($table) { $defaultId = 1; if (array_key_exists('defaultId', $this->supportedImports[strtolower($table)])) $defaultId = Configuration::get($this->supportedImports[strtolower($table)]['defaultId']); return $defaultId; } private function copyImg($item, $className) { require_once('../../images.inc.php'); $identifier = $this->supportedImports[strtolower($className)]['identifier']; $matchId = $this->getMatchId(strtolower($className)); $matchIdLang = $this->getMatchIdLang(); switch($className) { default: case 'Product': $path = _PS_PROD_IMG_DIR_; $type = 'products'; break; case 'Category': $path = _PS_CAT_IMG_DIR_; $type = 'categories'; break; case 'Manufacturer': $path = _PS_MANU_IMG_DIR_; $type = 'manufacturers'; break; case 'Supplier': $path = _PS_SUPP_IMG_DIR_; $type = 'suppliers'; break; } $cover = 1; if (array_key_exists($item[$identifier], $matchId)) foreach($item['images'] as $key => $image) { $tmpfile = tempnam(_PS_TMP_IMG_DIR_, 'import'); if (@copy($image, $tmpfile)) { $imagesTypes = ImageType::getImagesTypes($type); imageResize($tmpfile, $path.(int)$matchId[$item[$identifier]].'.jpg'); if ($className == 'Product') { $image = new Image(); $image->id_product = (int)($matchId[$item[$identifier]]); $image->cover = $cover; $image->position = Image::getHighestPosition((int)$matchId[$item[$identifier]]) + 1; $legend = array(); foreach($item['name'] as $key => $val) if (array_key_exists($key, $matchIdLang)) $legend[$matchIdLang[$key]] = Tools::link_rewrite($val); else $legend[Configuration::get('PS_LANG_DEFAULT')] = Tools::link_rewrite($val); $image->legend = $legend; $image->add(); imageResize($tmpfile, $path.(int)$matchId[$item[$identifier]].'-'.(int)$image->id.'.jpg'); foreach ($imagesTypes AS $k => $imageType) imageResize($tmpfile, $path.(int)$matchId[$item[$identifier]].'-'.(int)$image->id.'-'.stripslashes($imageType['name']).'.jpg', $imageType['width'], $imageType['height']); } else foreach ($imagesTypes AS $k => $imageType) imageResize($tmpfile, $path.(int)$matchId[$item[$identifier]].'-'.stripslashes($imageType['name']).'.jpg', $imageType['width'], $imageType['height']); } else @unlink($tmpfile); @unlink($tmpfile); $cover = 0; } } private function replaceForeignKey(&$item, $table) { if ($table == 'product_attribute') $table2 = 'combination'; else $table2 = $table; $foreingKey = $this->supportedImports[$table2]['foreign_key']; $foreingKeyValue = $this->getForeignKey($table, $foreingKey); foreach($foreingKey as $key) { if ($table == 'product' AND $key == 'id_category') $key2 = 'id_category_default'; elseif ($table == 'customer' AND $key == 'id_group') $key2 = 'id_default_group'; else $key2 = $key; if (array_key_exists($key, $foreingKeyValue) && $item[$key2] != 0) $item[$key2] = (array_key_exists($item[$key2], $foreingKeyValue[$key]) ? $item[$key2] = $foreingKeyValue[$key][$item[$key2]] : $item[$key2] = 0); else $item[$key2] = $this->getDefaultId($table); } } private function alterTable($className) { $query =''; $queryTmp = ''; $from = $this->supportedImports[$className]['table']; $result = array(); $result = Db::getInstance()->getRow('SELECT * FROM `'._DB_PREFIX_.pSQL($from).'`'); if (!$result) $result = array(); foreach ($this->supportedImports[$className]['alterTable'] AS $name => $type) { $moduleName = Tools::getValue('moduleName'); if (!array_key_exists($name.'_'.$moduleName, $result)) $queryTmp .= ' ADD `'.$name.'_'.$moduleName.'` '.$type.' NOT NULL,'; } if (!empty($queryTmp)) { $query = 'ALTER TABLE `'._DB_PREFIX_.pSQL($from).'` '; $query .= rtrim($queryTmp, ','); Db::getInstance()->Execute($query); } } private function updateCat() { $moduleName = Tools::getValue('moduleName'); Db::getInstance()->Execute('UPDATE '._DB_PREFIX_.'category c INNER JOIN '._DB_PREFIX_.'category c2 ON c.id_parent = c2.id_category_'.pSQL($moduleName).' SET c.id_parent = c2.id_category WHERE c.id_category_'.pSQL($moduleName).' != 0'); $category = new Category(); $cats = $category->getSimpleCategories((int)Configuration::get('PS_LANG_DEFAULT')); foreach($cats as $cat) { $cat = new Category((int)$cat['id_category']); $cat->level_depth = $cat->calcLevelDepth(); $cat->update(); } } private function getForeignKey($className, $foreign_key = null) { $moduleName = Tools::getValue('moduleName'); if (is_null($foreign_key)) $foreign_key = $this->supportedImports[$className]['foreign_key']; $match = array(); foreach($foreign_key AS $key) { if (in_array($key , array('id_address_invoice', 'id_address_delivery'))) $key2 = 'id_address'; elseif (in_array($key , array('id_category_default'))) $key2 = 'id_category'; else $key2 = $key; foreach($this->supportedImports AS $table => $conf) if ($conf['identifier'] == $key2) $from = $this->supportedImports[$table]['table']; $return = Db::getInstance()->ExecuteS('SELECT `'.pSQL($key2).'_'.pSQL($moduleName).'`, `'.pSQL($key2).'` FROM `'._DB_PREFIX_.pSQL($from).'` WHERE `'.pSQL($key2).'_'.pSQL($moduleName).'` != 0'); if (!empty($return)) foreach($return AS $name => $val) $match[$key][$val[$key2.'_'.$moduleName]] = $val[$key2]; } return $match; } private function getForeignKeyLang($table) { $id = $this->supportedImports[$table]['identifier']; $moduleName = Tools::getValue('moduleName'); $return = Db::getInstance()->ExecuteS('SELECT `'.pSQL($id).'_'.pSQL($moduleName).'`, `'.pSQL($id).'` FROM `'._DB_PREFIX_.pSQL($table).'` WHERE `'.pSQL($id).'_'.pSQL($moduleName).'` != 0'); $match = array(); foreach($return AS $name => $val) $match[$val[$id.'_'.$moduleName]] = $val[$id]; return $match; } private function getMatchIdLang($order = 1) { $moduleName = Tools::getValue('moduleName'); $return = Db::getInstance()->ExecuteS('SELECT `id_lang`, `id_lang_'.pSQL($moduleName).'` FROM `'._DB_PREFIX_.'lang'.'` WHERE `id_lang_'.pSQL($moduleName).'` != 0'); $match = array(); foreach($return AS $name => $val) if ((bool)$order) $match[$val['id_lang_'.$moduleName]] = $val['id_lang']; else $match[$val['id_lang']] = $val['id_lang_'.$moduleName]; return $match; } private function validateRules($rules, &$fields, $className, $languages, $defaultLanguage) { $returnErrors = array(); $hasErrors = Tools::getValue('hasErrors'); /* Checking for required fields */ foreach ($rules['required'] AS $field) if (($value = $fields[$field]) == false AND (string)$value != '0') if ($hasErrors == 2) { if (array_key_exists($field, $rules['size'])) $size = $rules['size'][$field]; else $size = 1; $fields[$field] = $this->generateData($size, $rules['validate'][$field]); } else $returnErrors[] = $this->l('the field').' '.call_user_func(array($className, 'displayFieldName'), $field, $className).' '.$this->l('is required'); /* Checking for maximum fields sizes */ foreach ($rules['size'] AS $field => $maxLength) if (array_key_exists($field, $fields) AND $field != 'passwd') if ($fields[$field] !== false AND Tools::strlen($fields[$field]) > $maxLength) if ($hasErrors == 2) $fields[$field] = substr($fields[$field], 0, $maxLength); else $returnErrors[] = $this->l('the field').' '.call_user_func(array($className, 'displayFieldName'), $field, $className).''.$this->l('is too long').' ('.$maxLength.' '.$this->l('chars max').')'; /* Checking for fields validity */ foreach ($rules['validate'] AS $field => $function) if (array_key_exists($field, $fields)) if (($value = $fields[$field]) !== false AND ($field != 'passwd')) if (!Validate::$function($value)) if ($hasErrors == 2) { if (array_key_exists($field, $rules['size'])) $size = $rules['size'][$field]; else $size = 1; $fields[$field] = $this->generateData($size, $rules['validate'][$field]); } else $returnErrors[] = $this->l('the field').' '.call_user_func(array($className, 'displayFieldName'), $field, $className).' '.$this->l('is invalid'); if ((sizeof($rules['requiredLang']) OR sizeof($rules['sizeLang']) OR sizeof($rules['validateLang']))) { $matchIdLang = $this->getMatchIdLang(0); /* Checking for multilingual required fields */ foreach ($rules['requiredLang'] AS $fieldLang) { if (($empty = $fields[$fieldLang][$matchIdLang[$defaultLanguage->id]]) === false OR empty($empty)) if ($hasErrors == 2) { if (array_key_exists($fieldLang, $rules['sizeLang'])) $size = $rules['sizeLang'][$fieldLang]; else $size = 1; $fields[$fieldLang][$matchIdLang[$defaultLanguage->id]] = $this->generateData($size, $rules['validateLang'][$fieldLang]); } else $returnErrors[] = $this->l('the field').' '.call_user_func(array($className, 'displayFieldName'), $fieldLang, $className).' '.$this->l('is required at least in').' '.$defaultLanguage->name; } /* Checking for maximum multilingual fields size */ foreach ($rules['sizeLang'] AS $fieldLang => $maxLength) foreach ($languages AS $language) if (isset($fields[$fieldLang][$language['id_lang']]) && $fields[$fieldLang] !== false AND Tools::strlen($fields[$fieldLang][$language['id_lang']]) > $maxLength) if ($hasErrors == 2) $fields[$fieldLang] = substr($fields[$fieldLang], 0, $maxLength); else $returnErrors[] = $this->l('the field').' '.call_user_func(array($className, 'displayFieldName'), $fieldLang, $className).' ('.$language['name'].') '.$this->l('is too long').' ('.$maxLength.' '.$this->l('chars max').')'; /* Checking for multilingual fields validity */ foreach ($rules['validateLang'] AS $fieldLang => $function) foreach ($languages AS $language) { if (array_key_exists($fieldLang, $fields) AND ($value = $fields[$fieldLang][$language['id_lang']]) !== false AND !empty($value)) { if (!Validate::$function($value)) if ($hasErrors == 2) { if (array_key_exists($fieldLang, $rules['sizeLang'])) $size = $rules['sizeLang'][$fieldLang]; else $size = 1; $fields[$fieldLang][$language['id_lang']] = $this->generateData($size, $rules['validateLang'][$fieldLang]); } else $returnErrors[] = $this->l('the field').' '.call_user_func(array($className, 'displayFieldName'), $fieldLang, $className).' ('.$language['name'].') '.$this->l('is invalid'); } } } return $returnErrors; } public function checkAndAddLang ($languages, $add = true) { $errors = ''; $moduleName = Tools::getValue('moduleName'); $this->alterTable('language'); foreach($languages as $language) { $iso = $language['iso_code']; if (!Language::isInstalled($iso)) { if ($add) { if (@fsockopen('www.prestashop.com', 80)) { if ($lang_pack = Tools::jsonDecode(Tools::file_get_contents('http://www.prestashop.com/download/lang_packs/get_language_pack.php?version='._PS_VERSION_.'&iso_lang='.$iso))) { if ($content = Tools::file_get_contents('http://www.prestashop.com/download/lang_packs/gzip/'.$lang_pack->version.'/'.$iso.'.gzip')) { $file = _PS_TRANSLATIONS_DIR_.$iso.'.gzip'; if (file_put_contents($file, $content)) { require_once('../../tools/tar/Archive_Tar.php'); $gz = new Archive_Tar($file, true); if ($gz->extract(_PS_TRANSLATIONS_DIR_.'../', false)) { if (!Language::checkAndAddLanguage($iso)) $errors[] = Tools::displayError('Archive cannot be extracted.'); else { $newId = Language::getIdByIso($iso); Db::getInstance()->Execute('UPDATE `'._DB_PREFIX_.'lang` SET `id_lang_'.pSQL($moduleName).'` = '.(int)$language['id_lang'].' WHERE `id_lang` = '.(int)$newId); } } $errors[] = Tools::displayError('Archive cannot be extracted.'); } else $errors[] = Tools::displayError('Server does not have permissions for writing.'); } else $errors[] = Tools::displayError('Language not found'); } else $errors[] = Tools::displayError('archive cannot be downloaded from prestashop.com.'); } else $errors[] = Tools::displayError('archive cannot be downloaded from prestashop.com.'); } } else { $newId = Language::getIdByIso($iso); Db::getInstance()->Execute('UPDATE `'._DB_PREFIX_.'lang` SET `id_lang_'.pSQL($moduleName).'` = '.(int)$language['id_lang'].' WHERE `id_lang` = '.(int)$newId); } } } public function truncateTable($table) { switch ($table) { case 'customer' : Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.'customer'); Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.'customer_group'); break; case 'address' : Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.'address'); break; case 'category' : Db::getInstance()->Execute('DELETE FROM `'._DB_PREFIX_.'category` WHERE id_category != 1'); Db::getInstance()->Execute('DELETE FROM `'._DB_PREFIX_.'category_lang` WHERE id_category != 1'); Db::getInstance()->Execute('ALTER TABLE `'._DB_PREFIX_.'category` AUTO_INCREMENT = 2 '); foreach (scandir(_PS_CAT_IMG_DIR_) AS $d) if (preg_match('/^[0-9]+(\-(.*))?\.jpg$/', $d)) unlink(_PS_CAT_IMG_DIR_.$d); Image::clearTmpDir(); break; case 'product' : Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.'product'); Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.'feature_product'); Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.'product_lang'); Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.'category_product'); Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.'product_tag'); Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.'image'); Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.'image_lang'); Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.'product_attribute'); Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.'product_attribute_combination'); Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.'specific_price'); Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.'specific_price_priority'); Image::deleteAllImages(_PS_PROD_IMG_DIR_); Image::clearTmpDir(); break; case 'Manufacturers' : Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.'manufacturer'); Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.'manufacturer_lang'); foreach (scandir(_PS_MANU_IMG_DIR_) AS $d) if (preg_match('/^[0-9]+(\-(.*))?\.jpg$/', $d)) unlink(_PS_MANU_IMG_DIR_.$d); Image::clearTmpDir(); break; case 'Suppliers' : Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.'supplier'); Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.'supplier_lang'); foreach (scandir(_PS_SUPP_IMG_DIR_) AS $d) if (preg_match('/^[0-9]+(\-(.*))?\.jpg$/', $d)) unlink(_PS_SUPP_IMG_DIR_.$d); Image::clearTmpDir(); break; case 'attribute' : Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.'attribute'); Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.'attribute_lang'); break; case 'attributegroup' : Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.'attribute_group'); Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.'attribute_group_lang'); break; case 'currency' : case 'customer' : case 'zone' : case 'state' : case 'group' : Db::getInstance()->Execute('TRUNCATE TABLE `'._DB_PREFIX_.pSQL($table)); break; } return true; } public function cleanPositions($table) { if ($table == 'category') { //clean category position $cat = Category::getCategories(1, false, false); foreach($cat AS $i => $categ) Category::cleanPositions((int)($categ['id_category'])); } if ($table == 'product') { //clean products position $cat = Category::getCategories(1, false, false); foreach($cat AS $i => $categ) Product::cleanPositions((int)($categ['id_category'])); } } public function getDefaultIdLang() { return; } private function generateData($size = 1, $type) { $type = str_replace('is', '', $type); $dom = array('com', 'net', 'org', 'biz', 'info'); $alphaNum = '0123456789abcdefghijklmnopqrstuvwxyz'; $alpha = 'abcdefghijklmnopqrstuvwxyz'; $num = '0123456789'; $return = ''; switch($type) { case 'CityName': case 'Name': case 'GenericName': case 'CatalogName': case 'Address': case 'LinkRewrite': case 'String': $a = mt_rand($size/2, $size); for ($i = 1; $i <= $a; $i++) $return .= substr($alpha, mt_rand(0, strlen($alpha)), 1); break; case 'LanguageIsoCode': for ($i = 1; $i <= 2; $i++) $return .= substr($alpha, mt_rand(0, strlen($alpha)), 1); break; case 'LanguageCode': for ($i = 1; $i <= 2; $i++) $return .= substr($alphaNum, mt_rand(0, strlen($alphaNum)), 1); $return .= '-'; for ($i = 1; $i <= 2; $i++) $return .= substr($alphaNum, mt_rand(0, strlen($alphaNum)), 1); break; case 'Bool': $return .= mt_rand(0,1); break; case 'Int': case 'UnsignedId': case 'NumericIsoCode': case 'PhoneNumber': case 'PostCode': $a = mt_rand($size/2, $size); for ($i = 1; $i <= $a; $i++) $return .= substr($num, mt_rand(0, strlen($num)), 1); break; case 'Price': case 'Float': $a = mt_rand(4, 10); $b = mt_rand(4, 10); for ($i = 1; $i <= $a; $i++) $return .= substr($alphaNum, mt_rand(0, strlen($alphaNum)), 1); $return .= '-'; for ($i = 1; $i <= $b; $i++) $return .= substr($alphaNum, mt_rand(0, strlen($alphaNum)), 1); $return .= '.'.$dom[mt_rand(0, (sizeof($dom)-1))]; break; case 'ZipCodeFormat'; $str = 'NLC -'; $a = mt_rand($size/2, $size); for ($i = 1; $i <= $a; $i++) $return .= substr($str, mt_rand(0, strlen($str)), 1); break; case 'StateIsoCode'; break; case 'Email': $a = mt_rand(4, 10); $b = mt_rand(4, 10); for ($i = 1; $i <= $a; $i++) $return .= substr($alphaNum, mt_rand(0, strlen($alphaNum)), 1); $return .= '@'; for ($i = 1; $i <= $b; $i++) $return .= substr($alphaNum, mt_rand(0, strlen($alphaNum)), 1); $return .= '.'.$dom[mt_rand(0, (sizeof($dom)-1))]; break; case 'Passwd': $a = mt_rand($size/2, $size); for ($i = 1; $i <= $a; $i++) $return .= substr($alphaNum, mt_rand(0, strlen($alphaNum)), 1); break; case 'BirthDate': $return .= '1970-01-01 00:00:00'; break; } return $return; } private function cartToOrder($items, $foreignKey) { $this->alterTable('order'); foreach($items as $item) { $order = new Order(); $order->id_carrier = (int)$item['id_carrier']; $order->id_customer = (int)$foreignKey['id_customer'][$item['id_customer']]; $order->id_address_invoice = (int)$foreignKey['id_address_invoice'][$item['id_address_invoice']]; $order->id_address_delivery = (int)$foreignKey['id_address_delivery'][$item['id_address_delivery']]; $vat_address = new Address((int)$foreignKey['id_address_delivery'][$item['id_address_delivery']]); $id_zone = Address::getZoneById((int)$vat_address->id); $order->id_currency = (int)$item['id_currency']; $order->id_lang = (int)$item['id_lang']; $order->id_cart = (int)$foreignKey['id_cart'][$item['id_cart']]; $customer = new Customer((int)$order->id_customer); $order->secure_key = pSQL($customer->secure_key); if (!strlen(trim($item['payment']))) $order->payment = 'payment'.Tools::getValue('moduleName'); else $order->payment = utf8_encode(html_entity_decode(strip_tags(Tools::substr($item['payment'], 0, 32)))); if (isset($this->name)) $order->module = $this->name; $currency = new Currency($order->id_currency); $order->conversion_rate = $currency->conversion_rate; $order->total_products = (float)$item['total_products']; $order->total_products_wt = (float)$item['total_products_wt']; $order->total_discounts = (float)$item['total_discounts']; $order->total_shipping = (float)$item['total_shipping']; $order->carrier_tax_rate = (float)Tax::getCarrierTaxRate((int)$item['id_carrier'], (int)$item[Configuration::get('PS_TAX_ADDRESS_TYPE')]); $order->total_wrapping = (float)$item['total_wrapping']; $order->total_paid = (float)$item['total_paid']; $order->total_paid_real = (float)$item['total_paid_real']; $order->invoice_date = '0000-00-00 00:00:00'; $order->delivery_date = '0000-00-00 00:00:00'; $order->save(false, false); $this->saveMatchId('order', (int)$order->id, (int)$item['id_cart']); } } } ?>