Zaktualizowałem produkt: ' . $product_id . '
'; + } + elseif (empty($this->settings['import_api_settings']['only_update'])) + { + $frm_product = $this->convertor->convertToFrmProduct($original_product, $file_id); + $product_id = $frm_product->id; + Db::getInstance()->execute("INSERT INTO " . _DB_PREFIX_ . "ia_products SET product_id = '" . $product_id . "', indx = '" . pSQL($original_product['unique']) . "', product = '" . pSQL(json_encode($original_product)) . "', shop = 'default', source = 'admin', date_added = '" . time() . "', queue_id = '" . (int)$queue_id . "', file_id = '" . (int)$file_id . "'"); + + $products_created++; + + if ( $action == 'cron' ) + echo 'Dodałem nowy produkt: ' . $product_id . '
'; + } + + if ( ( ( $products_created + $products_updated ) >= self::$update_limit ) or ( $limit and ( $products_created + $products_updated ) >= $limit ) ) + { + $json['notice'] = 'time_out'; + break; + } + } + + if (!$json['notice']) + { + $json['notice'] = 'missing'; + Db::getInstance()->execute("UPDATE " . _DB_PREFIX_ . "ia_queues SET source = 'admin', status = '3', date_processed = '" . time() . "' WHERE queue_id = '" . (int)$queue_id . "'"); + } + + if ($action != 'cron') + { + $json['products_created'] = $products_created; + $json['products_updated'] = $products_updated; + $this->ajaxDie(Tools::jsonEncode($json)); + } + + exit; + } + + function importSelected($file_id) + { + $products = array(); + $selected = Tools::getValue('indx') ? Tools::getValue('indx') : array(); + + foreach ($selected as $indx) + { + $products[] = $this->queue->getQueuedProduct($indx, $file_id); + } + $queue_id = isset($products[0]) ? $products[0]['queue_id'] : 0; + + $products_created = 0; + $products_updated = 0; + + $json['notice'] = ''; + $json['total'] = count($products); + $json['processed'] = array(); + + foreach ($products as $product) + { + $original_product = json_decode($product['product'], true); + + $json['processed'][] = $product['product_id']; + + $product_id = 0; + + if ($this->settings['unique_equivalent'] == 'id_product') + { + $product_id = (int)$original_product['unique']; + } + else + { + $equivalent = $this->settings['unique_equivalent']; + + $query = ($equivalent == 'name') ? $original_product['name'] : $original_product['unique']; + + $product_id = $this->creator->getProductId($query, $this->settings['table_equivalent'], $equivalent); + } + + $this->queue->deleteQueuedProduct($product['product_id']); + + if ($product_id) + { + $this->creator->editProduct($product_id, $original_product); + Db::getInstance()->execute("UPDATE " . _DB_PREFIX_ . "ia_products SET indx = '" . pSQL($indx) . "', product = '" . pSQL(json_encode($original_product)) . "', source = 'selected', date_edited = '" . time() . "', queue_id = '" . (int)$queue_id . "', file_id = '" . (int)$file_id . "' WHERE product_id = '" . (int)$product_id . "' AND shop = 'default'"); + + $products_updated++; + } + elseif (empty($this->settings['import_api_settings']['only_update'])) + { + $frm_product = $this->convertor->convertToFrmProduct($original_product, $file_id); + $product_id = $frm_product->id; + Db::getInstance()->execute("INSERT INTO " . _DB_PREFIX_ . "ia_products SET product_id = '" . (int)$product_id . "', indx = '" . pSQL($indx) . "', product = '" . pSQL(json_encode($original_product)) . "', shop = 'default', source = 'selected', date_added = '" . time() . "', queue_id = '" . (int)$queue_id . "', file_id = '" . (int)$file_id . "'"); + + $products_created++; + } + + if ( ( $products_created + $products_updated ) >= self::$update_limit ) + { + $json['notice'] = 'time_out'; + break; + } + } + $json['products_created'] = $products_created; + $json['products_updated'] = $products_updated; + $this->ajaxDie(Tools::jsonEncode($json)); + + exit; + } + + function importOne($file_id, $indx) + { + $product = $this->queue->getQueuedProduct($indx, $file_id); + + if (!$product) + { + echo 'Product not found in queue'; + exit; + } + $queue_id = isset($product[0]) ? $product['queue_id'] : 0; + + + $original_product = json_decode($product['product'], true); + + $equivalent = $this->settings['unique_equivalent']; + + $query = ($equivalent == 'name') ? $original_product['name'] : $original_product['unique']; + + $product_id = $this->creator->getProductId($query, $this->settings['table_equivalent'], $equivalent); + $link = new Link(); + if ($product_id) + { + $exising = $this->creator->editProduct($product_id, $original_product); + Db::getInstance()->execute("UPDATE " . _DB_PREFIX_ . "ia_products SET indx = '" . pSQL($indx) . "', product = '" . pSQL(json_encode($original_product)) . "', source = 'selected', date_edited = '" . time() . "', queue_id = '" . (int)$queue_id . "', file_id = '" . (int)$file_id . "' WHERE product_id = '" . (int)$product_id . "' AND shop = 'default'"); + echo 'Product is updated'; + //echo 'link to product ' . $link->getproductlink($product_id) . ''; + } + else + { + $frm_product = $this->convertor->convertToFrmProduct($original_product, $file_id); + if ($frm_product) + { + $product_id = $frm_product->id; + Db::getInstance()->execute("INSERT INTO " . _DB_PREFIX_ . "ia_products SET product_id = '" . (int)$product_id . "', indx = '" . pSQL($indx) . "', product = '" . pSQL(json_encode($original_product)) . "', shop = 'default', source = 'selected', date_added = '" . time() . "', queue_id = '" . (int)$queue_id . "', file_id = '" . (int)$file_id . "'"); + echo 'Product is inserted'; + //echo 'Link to product ' . $link->getProductLink($product_id) . ''; + + } + } + + exit; + } + + function viewOne($file_id, $indx) + { + $product = $this->queue->getQueuedProduct($indx, $file_id); + + if (!$product) + { + echo 'Product not found in queue'; + exit; + } + + $queue_id = isset($product[0]) ? $product['queue_id'] : 0; + + $original_product = json_decode($product['product'], true); + + $equivalent = $this->settings['unique_equivalent']; + + $query = ($equivalent == 'name') ? $original_product['name'] : $original_product['unique']; + + $product_id = $this->creator->getProductId($query, $this->settings['table_equivalent'], $equivalent); + $link = new Link(); + if ($product_id) + { + echo 'Product exists ' . $product_id; + //echo 'link to product ' . $link->getproductlink($exising) . ''; + } + else + { + + echo 'Product is not inserted in Prestashop site '; + } + + foreach ($original_product as $key => $value) + { + if (!is_array($value)) + { + echo $key . ':' . $value . ', '; + } + } + + if (isset($original_product['cover'])) + { + if (!$this->UR_exists($original_product['cover'])) + { + echo 'image is not found. If you need to add server name go to Modifications and add https://servername/[[cover]]'; + } + else + { + echo 'image: ' . $original_product['cover']; + } + } + exit; + } + + private function printTestJsonData($view) + { + $json = array(); + + foreach ($this->product_links as $link) + { + $json[] = $this->importer->getAllData($link, $view); + } + + $this->ajaxDie(Tools::jsonEncode($json)); + } + + private function getProductLinks($action = 'import') + { + $begin_character = 'FEED'; + + $shop = 'default'; + + $file_id = Tools::getValue('file_id'); + + $settings = $this->getModuleSettings($file_id); + + $query_file = Db::getInstance()->executeS("SELECT * FROM " . _DB_PREFIX_ . "ia_files WHERE file_id = '" . (int)$file_id . "' AND shop = '" . pSQL($shop) . "' LIMIT 1"); + + $file = $query_file[0]; + + $FileReader = new FileReader(); + + list($tmp_array, $error) = $FileReader->getArrayFromLink($file); + + if ( is_array( $tmp_array) and count($tmp_array) > 10 && !empty(array_key_first($tmp_array))) + { // if is not 0 + $new_array = array(); + foreach ($tmp_array as $key => $value) + { + $value['GENERATED_UNIQUE'] = $key; + $new_array[] = $value; + } + $tmp_array = $new_array; + unset($new_array); + } + + $php_array[$begin_character] = $tmp_array; + + $parts = explode('->', $settings['unique_field']); + + $identifier_field = $parts[count($parts) - 1]; + + + $importer = new Import($settings); + + $importer->setJsonArray($php_array); + $importer->findUniqueProductsIdentifier($php_array, $parts, $identifier_field); + + + $product_links = $importer->getProductLinks(); + + //var_dump($product_links); exit; + + $this->importer = $importer; + + $start = $limit = 0; + + if ($action == 'test') + { + $start = $settings['start']; + $limit = 20; + } + + if (Tools::getValue('start')) + { + $start = Tools::getValue('start'); + } + + if (Tools::getValue('limit')) + { + $limit = Tools::getValue('limit'); + } + + if ($start && !$limit) + { + $limit = count($product_links) - $start; + } + + if ($limit) + { + $product_links = array_slice($product_links, $start, $limit); + } + return $product_links; + } + + function getModuleSettings($file_id = 0) + { + + if (!$file_id) + { + $file_id = Tools::getValue('file_id'); + } + + $shop = 'default'; + + $settings_fields = array('link', 'attribute_group', 'default_brand', 'default_category', 'top_category', 'weight_class_id', 'stock_status_id', 'tax', 'default_option', 'category_path', 'multiplier', 'id_tax_rules_group'); + + if (Tools::getValue('import_api_field')) + { + + $settings = array( + 'import_api_field' => Tools::getValue('import_api_field'), + 'import_api_modification' => Tools::getValue('import_api_modification'), + 'import_api_combination' => Tools::getValue('import_api_combination'), + 'import_api_settings' => Tools::getValue('import_api_settings'), + 'import_api_link' => Tools::getValue('import_api_link'), + 'import_api_type' => Tools::getValue('import_api_type'), + ); + } + else + { + $query_file_settings = Db::getInstance()->executeS("SELECT fs.* FROM " . _DB_PREFIX_ . "ia_file_settings fs WHERE fs.file_id = '" . (int)$file_id . "' LIMIT 1"); + if ($query_file_settings) + { + $file_settings = $query_file_settings[0]; + $filters = array(); + $replaces = array(); + if ($file_settings['filter']) + { + $text_areas = json_decode($file_settings['filter'], true); + foreach ($text_areas as $key => $textarea_value) + { + if ($textarea_value) + { + $filters[$key] = array_map('trim', explode("\n", $textarea_value)); + } + } + } + if ($file_settings['replace']) + { + $text_areas = json_decode($file_settings['replace'], true); + foreach ($text_areas as $key => $textarea_value) + { + $lines = array_map('trim', explode("\n", $textarea_value)); + foreach ($lines as $line) + { + if ($line) + { + $replaces[$key][] = explode('##', $line); + } + } + } + } + + $settings = array( + 'import_api_field' => json_decode($file_settings['mapping'], true), + 'import_api_modification' => json_decode($file_settings['modification'], true), + 'import_api_combination' => json_decode($file_settings['split'], true), + 'import_api_filter' => $filters, + 'import_api_replace' => $replaces, + 'import_api_filter_options' => json_decode($file_settings['filter_options'], true), + 'import_api_settings' => json_decode($file_settings['settings'], true), + ); + } + } + + if (!empty($settings['import_api_field']['unique'])) + { + $settings['unique_field'] = html_entity_decode($settings['import_api_field']['unique'], ENT_QUOTES, 'UTF-8'); + } + else + { + $json['error'] = 'you need to set unique field'; + $this->ajaxDie(Tools::jsonEncode($json)); + } + + if (Tools::getValue('start')) + { + $settings['start'] = Tools::getValue('start'); + } + else + { + $settings['start'] = 0; + } + + if ($settings['import_api_settings']['top_category']) + { + $settings['top_category_id'] = $this->creator->getCategoryId($settings['import_api_settings']['top_category']); + } + else + { + $settings['top_category_id'] = Configuration::get('PS_HOME_CATEGORY'); + } + + if ($settings['import_api_settings']['default_category']) + { + $settings['default_category_id'] = $this->creator->getCategoryId($settings['import_api_settings']['default_category']); + } + else + { + $settings['default_category_id'] = 0; + } + + if ($settings['import_api_settings']['default_brand']) + { + $settings['default_manufacturer_id'] = $this->creator->getManufacturerId($settings['import_api_settings']['default_brand']); + } + else + { + $settings['default_manufacturer_id'] = 0; + } + + $settings['id_tax_rules_group'] = isset($settings['import_api_settings']['id_tax_rules_group']) ? $settings['import_api_settings']['id_tax_rules_group'] : -1; + + $settings['unique_equivalent'] = 'name'; + $settings['table_equivalent'] = 'product_lang'; + if (isset($settings['import_api_settings']['synchronize_field']) && $settings['import_api_settings']['synchronize_field'] != 'automatic') + { + $settings['unique_equivalent'] = $settings['import_api_settings']['synchronize_field']; + } + else + { + $possible_eq = ['reference', 'sku', 'ean13', 'upc']; + + foreach ($possible_eq as $f) + { + if (!empty($settings['import_api_field'][$f]) && $settings['import_api_field'][$f] == $settings['import_api_field']['unique']) + { + $settings['unique_equivalent'] = $f; + break; + } + } + } + if ($settings['unique_equivalent'] != 'name') + { + $settings['table_equivalent'] = 'product'; + } + + $this->settings = $settings; + + return $settings; + } + + function deleteProducts($file_id) + { + $query_file = Db::getInstance()->executeS("SELECT * FROM " . _DB_PREFIX_ . "ia_files WHERE file_id = '" . (int)$file_id . "' LIMIT 1"); + if (empty($query_file)) + { + $json['notice'] = 'File not found'; + $this->ajaxDie(Tools::jsonEncode($json)); + exit; + } + else + { + $file = $query_file[0]; + } + if ($file['mask'] . $file['date_added'] != Tools::getValue('token')) + { + $json['notice'] = 'File not found.....'; + $this->ajaxDie(Tools::jsonEncode($json)); + exit; + } + + $max_execution_time = 50; + + $products = $this->queue->getProducts($file_id); + + $products_deleted = 0; + + $json['notice'] = ''; + + foreach ($products as $product) + { + $p = new Product($product['product_id']); + $p->delete(); + $this->queue->deleteProduct($product['product_id']); + $products_deleted++; + + if ( ( $products_created + $products_updated ) >= self::$update_limit ) + { + $json['notice'] = 'time_out'; + break; + } + } + + $json['products_deleted'] = $products_deleted; + $this->ajaxDie(Tools::jsonEncode($json)); + + exit; + } + + + function UR_exists($url) + { + $headers = @get_headers($url); + return stripos($headers[0], "200 OK") ? true : false; + } +} diff --git a/modules/import_api/controllers/front/index.php b/modules/import_api/controllers/front/index.php new file mode 100644 index 00000000..8761a003 --- /dev/null +++ b/modules/import_api/controllers/front/index.php @@ -0,0 +1,35 @@ + +* @copyright 2007-2016 PrestaShop SA +* @license http://opensource.org/licenses/afl-3.0.php Academic Free License (AFL 3.0) +* International Registered Trademark & Property of PrestaShop SA +*/ + +header('Expires: Mon, 26 Jul 1997 05:00:00 GMT'); +header('Last-Modified: '.gmdate('D, d M Y H:i:s').' GMT'); + +header('Cache-Control: no-store, no-cache, must-revalidate'); +header('Cache-Control: post-check=0, pre-check=0', false); +header('Pragma: no-cache'); + +header('Location: ../'); +exit; \ No newline at end of file diff --git a/modules/import_api/controllers/index.php b/modules/import_api/controllers/index.php new file mode 100644 index 00000000..8761a003 --- /dev/null +++ b/modules/import_api/controllers/index.php @@ -0,0 +1,35 @@ + +* @copyright 2007-2016 PrestaShop SA +* @license http://opensource.org/licenses/afl-3.0.php Academic Free License (AFL 3.0) +* International Registered Trademark & Property of PrestaShop SA +*/ + +header('Expires: Mon, 26 Jul 1997 05:00:00 GMT'); +header('Last-Modified: '.gmdate('D, d M Y H:i:s').' GMT'); + +header('Cache-Control: no-store, no-cache, must-revalidate'); +header('Cache-Control: post-check=0, pre-check=0', false); +header('Pragma: no-cache'); + +header('Location: ../'); +exit; \ No newline at end of file diff --git a/modules/import_api/import_api.php b/modules/import_api/import_api.php new file mode 100644 index 00000000..fe55dddb --- /dev/null +++ b/modules/import_api/import_api.php @@ -0,0 +1,102 @@ + + * @copyright 2019 Dalibor Stojcevski + * @license Dalibor Stojcevski + */ + +if (!defined('_PS_VERSION_')) { + exit; +} + +class import_api extends Module +{ + protected $config_form = false; + + protected $_postErrors = array(); + + protected $fmr_fields; + + + public function __construct() + { + $this->name = 'import_api'; + $this->tab = 'front_office_features'; + $this->version = '3.1.5.9'; + $this->author = 'Dalibor Stojcevski'; + $this->need_instance = 1; + $this->bootstrap = true; + $this->module_key = '3711c016ea39f2f2aa38850e48aa7455'; + parent::__construct(); + $this->displayName = $this->l('Import Api'); + $this->description = $this->l('Import and update products from external source'); + $this->ps_versions_compliancy = array('min' => '1.6', 'max' => _PS_VERSION_); + + $this->frm_fields = ['unique', 'reference', 'name', 'description', 'price', 'quantity', 'images', 'cover', 'brand', 'category', 'category_parent', 'ean13', 'upc', 'condition', 'weight', 'feature', 'feature_value']; + $this->frm_settings = array('top_category' => '', 'default_category' => '', 'default_brand' => '', 'price_multiplier' => '', 'category_path' => 0); + } + + public function install() + { + $class = 'AdminImport_Api'; + $tab = new Tab(); + $tab->class_name = $class; + $tab->module = $this->name; + $tab->id_parent = 0; + $langs = Language::getLanguages(false); + foreach ($langs as $l) { + $tab->name[$l['id_lang']] = $this->l('Import Products'); + } + $tab->save(); + return $this->installDb() && parent::install(); + } + + public function uninstall() + { + return parent::uninstall(); + } + + public function installDb() + { + $return = true; + require_once(_PS_MODULE_DIR_ . 'import_api/sql_install.php'); + + foreach ($sql as $s) { + Db::getInstance()->execute($s); + } + + $res = Db::getInstance()->executeS("SHOW columns FROM `"._DB_PREFIX_."ia_files` LIKE 'status'"); + if (!$res) { + Db::getInstance()->execute('ALTER TABLE `'._DB_PREFIX_.'ia_files` ADD `status` SMALLINT(2) NOT NULL DEFAULT \'1\''); + } + + $res_1 = Db::getInstance()->executeS("SHOW columns FROM `"._DB_PREFIX_."ia_file_settings` LIKE 'replace' "); + if (!$res_1) { + Db::getInstance()->execute('ALTER TABLE `'._DB_PREFIX_.'ia_file_settings` ADD `replace` text NOT NULL'); + } + + $res_2 = Db::getInstance()->executeS("SHOW columns FROM `"._DB_PREFIX_."ia_file_settings` LIKE 'filter' "); + if (!$res_2) { + Db::getInstance()->execute('ALTER TABLE `'._DB_PREFIX_.'ia_file_settings` ADD `filter` text NOT NULL'); + } + + $res_3 = Db::getInstance()->executeS("SHOW columns FROM `"._DB_PREFIX_."ia_file_settings` LIKE 'filter_options' "); + + if (!$res_3) { + Db::getInstance()->execute('ALTER TABLE `'._DB_PREFIX_.'ia_file_settings` ADD `filter_options` text NOT NULL'); + } + return $return; + } + + public function getContent() + { + Tools::redirectAdmin($this->context->link->getAdminLink('AdminImport_Api')); + } + +} \ No newline at end of file diff --git a/modules/import_api/index.php b/modules/import_api/index.php new file mode 100644 index 00000000..907720c1 --- /dev/null +++ b/modules/import_api/index.php @@ -0,0 +1,35 @@ + +* @copyright 2007-2018 PrestaShop SA +* @license http://opensource.org/licenses/afl-3.0.php Academic Free License (AFL 3.0) +* International Registered Trademark & Property of PrestaShop SA +*/ + +header('Expires: Mon, 26 Jul 1997 05:00:00 GMT'); +header('Last-Modified: '.gmdate('D, d M Y H:i:s').' GMT'); + +header('Cache-Control: no-store, no-cache, must-revalidate'); +header('Cache-Control: post-check=0, pre-check=0', false); +header('Pragma: no-cache'); + +header('Location: ../'); +exit; diff --git a/modules/import_api/lib/SimpleXLS.php b/modules/import_api/lib/SimpleXLS.php new file mode 100644 index 00000000..f6d8c20b --- /dev/null +++ b/modules/import_api/lib/SimpleXLS.php @@ -0,0 +1,1224 @@ +'; + +if ( $xls = SimpleXLS::parse('excel5book.xls')) { + print_r( $xls->rows() ); // dump first sheet + print_r( $xls->rows(1)); /// dump second sheet +} else { + echo SimpleXLSX::parseError(); +} + +echo ''; + */ + +/** + * A class for reading Microsoft Excel Spreadsheets. + * + * SimpleXLS version 2016-2020 packaged by Sergey Shuchkin| ' . ( $c === '' ? ' ' : htmlspecialchars( $c, ENT_QUOTES ) ) . ' | '; + } + $s .= "
| ",{valign:"top",colSpan:W(a),"class":a.oClasses.sRowEmpty}).html(c))[0];t(a,"aoHeaderCallback","header",[h(a.nTHead).children("tr")[0],Ma(a),g,l,i]);t(a,"aoFooterCallback","footer",[h(a.nTFoot).children("tr")[0], +Ma(a),g,l,i]);d=h(a.nTBody);d.children().detach();d.append(h(b));t(a,"aoDrawCallback","draw",[a]);a.bSorted=!1;a.bFiltered=!1;a.bDrawing=!1}}function T(a,b){var c=a.oFeatures,d=c.bFilter;c.bSort&&ob(a);d?ha(a,a.oPreviousSearch):a.aiDisplay=a.aiDisplayMaster.slice();!0!==b&&(a._iDisplayStart=0);a._drawHold=b;P(a);a._drawHold=!1}function pb(a){var b=a.oClasses,c=h(a.nTable),c=h("").insertBefore(c),d=a.oFeatures,e=h("",{id:a.sTableId+"_wrapper","class":b.sWrapper+(a.nTFoot?"":" "+b.sNoFooter)}); +a.nHolding=c[0];a.nTableWrapper=e[0];a.nTableReinsertBefore=a.nTable.nextSibling;for(var f=a.sDom.split(""),g,j,i,l,m,q,k=0;k | ").html(B(a,c,b,"display"))[0]:d.anCells[b]}function Ib(a,b){for(var c,d=-1,e=-1,f=0,g=a.aoData.length;f | ").addClass(b),h("td",c).addClass(b).html(a)[0].colSpan=W(d),e.push(c[0]))};f(a,b);c._details&&c._details.detach();c._details=h(e);c._detailsShow&&c._details.insertAfter(c.nTr)}return this});o(["row().child.show()","row().child().show()"],function(){Vb(this,!0);return this});o(["row().child.hide()","row().child().hide()"],function(){Vb(this,!1);return this});o(["row().child.remove()","row().child().remove()"],function(){eb(this);return this});o("row().child.isShown()",function(){var a= +this.context;return a.length&&this.length?a[0].aoData[this[0]]._detailsShow||!1:!1});var cc=/^([^:]+):(name|visIdx|visible)$/,Wb=function(a,b,c,d,e){for(var c=[],d=0,f=e.length;d |
| Name | +Action | +Enable / Disbale | +
|---|---|---|
| {$file.name} | +View | +{$file.other_status_text} | +
You don't have queued products. It is good to make this process for better testing and view before import. But you can skip and press Start import
+ + + {/if} + + {if $products} + + + + {if $limit} +There is limit ({$limit}) for queued products for better performance. If you want to show all press on link Show all
+ {/if} + {/if} +