<?php
/**
 * NOTICE OF LICENSE
 * With the purchase or the installation of the software in your application
 * you accept the license agreement.
 *
 * You can not resell and redistribute this file.
 *
 * @author    Dalibor Stojcevski <dal_sto@yahoo.com>
 * @copyright 2019 Dalibor Stojcevski
 * @license   Dalibor Stojcevski
 */
class AdminImport_ApiController extends ModuleAdminController
{
    public $bootstrap = true;

    protected $_postErrors = array();
    
    protected $fmr_fields;

    public function __construct()
    {
		if ($this->context == null) {
            $this->context = Context::getContext();
        }
		$this->toolbar_title = 'Sources';
		$this->meta_title = 'Import api';
        parent::__construct();
		require_once(_PS_MODULE_DIR_ . 'import_api/classes/queue.php');
		$this->queue = new Queue();
        $this->frm_fields = ['unique', 'reference', 'name', 'description', 'short_description', 'price', 'wholesale_price', 'quantity', 'images', 'cover', 'brand', 'category', 'category_parent', 'ean13', 'upc', 'condition', 'location', 'additional_shipping_cost', 'width', 'height', 'depth', 'weight', 'active', 'feature', 'feature_value', 'attribute1', 'attribute_value1', 'attribute2', 'attribute_value2', 'attribute3', 'attribute_value3', 'attribute_price', 'attribute_quantity', 'attribute_ean', 'attribute_weight', 'minimal_quantity'];
        $this->replace_fields = ['reference', 'name', 'description', 'short_description', 'price', 'wholesale_price', 'quantity', 'images', 'cover', 'brand', 'category', 'ean13', 'upc', 'condition', 'location', 'width', 'height', 'depth', 'weight', 'feature', 'feature_value', 'attribute1', 'attribute_value1', 'attribute2', 'attribute_value2', 'attribute3', 'attribute_value3', 'minimal_quantity'];
        $this->frm_settings = array('top_category' => '', 'default_category' => '', 'default_brand' => '', 'price_multiplier' => '', 'combination_price_multiplier' => '', 'add_combination_price' => 0, 'category_path' => 0, 'id_tax_rules_group' => -1, 'same_update' => 0, 'not_existing' => 0, 'only_update' => 0, 'synchronize_field' => 'automatic');
        $this->frm_update_settings = array('quantity' => 1, 'price' => 0, 'wholesale_price' => 0, 'manufacturer' => 0, 'category' => 0, 'cover' => 0, 'images' => 0, 'name' => 0, 'description' => 0, 'short_description' => 0,'reference' => 0, 'ean13' => 0, 'ups' => 0, 'condition' => 0, 'location'=> 0, 'additional_shipping_cost'=> 0, 'width' => 0 , 'height' => 0 , 'depth' => 0 , 'weight' => 0, 'features' => 0, 'attributes' => 0, 'active' => 0, 'id_tax_rules_group' => 0, 'minimal_quantity' => 0);
        $this->filter_fields = ['reference', 'name', 'price', 'wholesale_price', 'quantity', 'images', 'cover', 'brand', 'category', 'ean13', 'upc', 'condition', 'location', 'width', 'height', 'depth', 'weight', 'feature', 'feature_value', 'attribute1', 'attribute_value1', 'attribute2', 'attribute_value2', 'attribute3', 'attribute_value3', 'minimal_quantity'];


		if (Tools::getValue('add_source')) {
			$this->addSource();
		} elseif (Tools::getValue('delete') && Tools::getValue('file_id')) {
			$this->deleteProducts(Tools::getValue('file_id'));
		} elseif (Tools::getValue('file_id')) {
			if (((bool)Tools::isSubmit('submitImportSettings')) == true) {
				$this->_postSettingsValidation();
				$message = '';
				if (!count($this->_postErrors)) {
						$this->_saveSettings(Tools::getValue('file_id'));
				} else {
					foreach ($this->_postErrors as $err) {
						$this->errors[] = $err;
					}
				}
				
			}
			$this->processFile(Tools::getValue('file_id'), Tools::getValue('type'));
		} else {
			$this->getSourceList();
		}
		//return;
    }
	

	public function addSource()
	{
		if (Tools::isSubmit('submitAddSource')) {
			$this->postFileProcess();
		}
	    $this->context->smarty->assign('form_link', $this->context->link->getAdminLink('AdminImport_Api&add_source=1&token=' . Tools::getAdminTokenLite('AdminImport_Api'), false));
		$file_tpl = $this->context->smarty->fetch(_PS_MODULE_DIR_ . 'import_api/views/templates/admin/file_upload.tpl');
		$this->content .= $file_tpl;
	}
	
	public 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)) {
			$this->errors[] =  $this->my_translation('File not found');
			return;
		} else {
			$file = $query_file[0];
		}
		
		$this->toolbar_title = 'Delete';
		
		$query_total = Db::getInstance()->executeS("SELECT COUNT(*) as total FROM ". _DB_PREFIX_ . "ia_products  WHERE file_id = '" . (int)$file_id . "'");

		$total = $query_total ? $query_total[0]['total'] : 0;
		
		$file_name = $file['name'] ? $file['name'] : $file['link'];
	    $this->context->smarty->assign('token',  $file['mask'] . $file['date_added']);
		$this->context->smarty->assign('get_import_link', $this->context->link->getModuleLink('import_api', 'import', array('file_id' => $file_id)));

	    $this->context->smarty->assign('file_name',  $file_name);
	    $this->context->smarty->assign('total',  $total);
		$delete_tpl = $this->context->smarty->fetch(_PS_MODULE_DIR_ . 'import_api/views/templates/admin/delete.tpl');
		$this->content .= $delete_tpl;
	}
	
	public function getSourceList()
	{
		if (Tools::getValue('status_file_id') && Tools::getValue('change_status') !== false) {
			Db::getInstance()->execute("UPDATE ". _DB_PREFIX_ . "ia_files SET status = '" . (int)Tools::getValue('change_status') ."' WHERE file_id = " . (int)Tools::getValue('status_file_id'));
		}

		$query_files = Db::getInstance()->executeS("SELECT f.* FROM ". _DB_PREFIX_ . "ia_files f ORDER BY date_edited DESC, file_id DESC");

		$files = array();
		if ($query_files) {
			foreach ($query_files as $file) {
				$other_status = $file['status'] ?  0 : 1;
				$other_status_text = $file['status'] ?  'Disable' : 'Enable';
				if (!Tools::getValue('show_disabled') && !$file['status']) {
					continue;
				}
				$files[] = array(
					'file_id' => $file['file_id'],
					'name' => $file['name'] ? $file['name'] : $file['link'],
					'date_added' => date('F j, Y', $file['date_added']),
					'process_link' => $this->context->link->getAdminLink('AdminImport_Api&file_id=' . $file['file_id'] . '&token=' . Tools::getAdminTokenLite('AdminImport_Api'), false),
					'change_status_link' => $this->context->link->getAdminLink('AdminImport_Api&change_status=' . $other_status . '&status_file_id=' . $file['file_id'] . '&token=' . Tools::getAdminTokenLite('AdminImport_Api'), false),
					'other_status_text' => $other_status_text
				);
			}
			
			$this->context->smarty->assign('files', $files);
			$this->context->smarty->assign('show_disabled_link', $this->context->link->getAdminLink('AdminImport_Api&show_disabled=1&token=' . Tools::getAdminTokenLite('AdminImport_Api'), false));
			
			$list_tpl = $this->context->smarty->fetch(_PS_MODULE_DIR_ . 'import_api/views/templates/admin/list.tpl');
			$this->content .= $list_tpl;
		} else {
			$this->addSource();
		}
	}
	
    public function processFile($file_id, $type = 'import')
	{
		$this->addJquery();
		$this->addJS(_MODULE_DIR_. 'import_api/views/js/dataTables.js');
		$this->addJS(_MODULE_DIR_. 'import_api/views/js/dataTables.bootstrap4.js');
		$this->addCSS(_MODULE_DIR_. 'import_api/views/css/dataTables.bootstrap4.css');
		$query_file_settings = Db::getInstance()->executeS("SELECT f.*, fs.mapping FROM ". _DB_PREFIX_ . "ia_files f LEFT JOIN ". _DB_PREFIX_ . "ia_file_settings fs ON(fs.file_id = f.file_id) WHERE f.file_id = '" . (int)$file_id . "'  LIMIT 1");
		if (empty($query_file_settings)) {
			$this->errors[] =  $this->my_translation('File not found');
		} else {
			$file_settings = $query_file_settings[0];
			$file_name = $file_settings['name'] ? $file_settings['name'] : $file_settings['link'];
			if ($file_settings['mapping'] && $type == 'import') {
			
				$this->toolbar_title = 'Import';
			    $this->context->smarty->assign('get_import_link', $this->context->link->getModuleLink('import_api', 'import', array('file_id'=> $file_id)));
			    $this->context->smarty->assign('show_all_link', $this->context->link->getAdminLink('AdminImport_Api&type=import&showall=1&file_id=' . $file_id . '&token=' . Tools::getAdminTokenLite('AdminImport_Api'), false));
			    $this->context->smarty->assign('delete_link', $this->context->link->getAdminLink('AdminImport_Api&delete=1&file_id=' . $file_id . '&token=' . Tools::getAdminTokenLite('AdminImport_Api'), false));
				
				if (Tools::getValue('showall')) {
					$limit = 0;
				} else {
					$limit = 600;
				}
				
				$products = $this->queue->getQueuedForTable($file_id, $limit);
				$this->context->smarty->assign('settings_link', $this->context->link->getAdminLink('AdminImport_Api&type=settings&file_id=' . $file_id . '&token=' . Tools::getAdminTokenLite('AdminImport_Api'), false));

				$this->context->smarty->assign('products', $products);
				$this->context->smarty->assign('limit', $limit);
				$this->context->smarty->assign('auto_queue', 0);
				$this->context->smarty->assign('file_name', $file_name);
				$output = $this->context->smarty->fetch(_PS_MODULE_DIR_ . 'import_api/views/templates/admin/import.tpl');
				$queue_tpl = $this->context->smarty->fetch(_PS_MODULE_DIR_ . 'import_api/views/templates/admin/temp.tpl');
				$this->content .= $queue_tpl;
				$this->content .= $output;
			} else {
				$this->toolbar_title = 'Settings';
				$this->context->smarty->assign('file_settings', $file_settings);
				$this->context->smarty->assign('file_id', $file_id);
				$this->context->smarty->assign('file_name', $file_name);
				$this->context->smarty->assign('import_link', $this->context->link->getAdminLink('AdminImport_Api&type=import&file_id=' . $file_id . '&token=' . Tools::getAdminTokenLite('AdminImport_Api'), false));
				$this->context->smarty->assign('get_fields_link', $this->context->link->getModuleLink('import_api', 'ajax', array('file_id'=> $file_id)));
				$output = $this->context->smarty->fetch(_PS_MODULE_DIR_ . 'import_api/views/templates/admin/configure.tpl');
				//$import_html = $this->context->smarty->fetch(_PS_MODULE_DIR_ . 'import_api/views/templates/admin/import.tpl');

				$this->content .= $output. $this->renderSettingsForm($file_settings);
				//$this->content .= $output;
			}
		}
	}
    public static function displayHumanReadableSize($size)
    {
        return Tools::formatBytes($size);
    }

    public function initPageHeaderToolbar()
    {
		$this->page_header_toolbar_btn['new_attachment'] = array(
			'href' => self::$currentIndex . '&add_source=1&token=' . $this->token,
			'desc' => $this->my_translation('Add new source'),
			'icon' => 'process-icon-new',
		);
		$this->page_header_toolbar_btn['view_list'] = array(
			'href' => self::$currentIndex . '&token=' . $this->token,
			'desc' => $this->my_translation('View list'),
			'icon' => 'process-icon-list',
		);
        parent::initPageHeaderToolbar();
    }

    public function postFileProcess()
    {
		$shop = 'default';
		$source = !empty($_POST['import_api_type']) ? $_POST['import_api_type'] : '';
		$headers = !empty($_POST['import_api_headers']) ? $_POST['import_api_headers'] : '';
		$delimiter = !empty($_POST['import_api_delimiter']) ? $_POST['import_api_delimiter'] : '';
		$mask = uniqid();
		if (!empty($_POST['import_api_link'])) {

			$query_file = Db::getInstance()->executeS("SELECT * FROM ". _DB_PREFIX_ . "ia_files WHERE link = '" . pSQL($_POST['import_api_link']) . "' AND shop = '" . pSQL($shop) . "' AND status = 1 LIMIT 1");

			if ($query_file) {
				$file_id = $query_file[0]['file_id'];
				Db::getInstance()->execute("UPDATE ". _DB_PREFIX_ . "ia_files SET link = '" . pSQL($_POST['import_api_link'])  . "', delimiter = '" . pSQL($delimiter) . "', headers = '" . pSQL($headers) . "', source = '" . pSQL($source) . "', date_edited = '" . time() . "' WHERE file_id = " . (int)$file_id  ."  AND shop = '" . pSQL($shop) . "'");

			} else {					
				Db::getInstance()->execute("INSERT INTO ". _DB_PREFIX_ . "ia_files SET link = '" . pSQL($_POST['import_api_link'])  . "', shop = '" . pSQL($shop) . "', delimiter = '" . pSQL($delimiter) . "', headers = '" . pSQL($headers) . "', source = '" . pSQL($source) . "', mask = '" . pSQL($mask)  ."', date_added = '" . time() . "'");		
			}
		} elseif (!empty($_FILES['doc']['tmp_name'])) {

			$name = $_FILES['doc']['name'];
			$tmp_name = $_FILES['doc']['tmp_name'];
			$type = $_FILES['doc']['type'];
			
			$file_ext = pathinfo($name, PATHINFO_EXTENSION);
			
			if (in_array($file_ext, ['zip'])) {
				$this->errors[] = $this->my_translation("Sorry, app can't read zip files. Extract zip and upload content from inside");
			} else {				
				$target_file = _PS_MODULE_DIR_ . 'import_api/views/img/' . $mask . '_' . $name;
				$base_link = Tools::getHttpHost(true).__PS_BASE_URI__;
				$target_url = $base_link. 'modules/import_api/views/img/' . $mask . '_' . $name;;
				if (move_uploaded_file($tmp_name, $target_file)) {
					Db::getInstance()->execute("INSERT INTO ". _DB_PREFIX_ . "ia_files SET link = '" . pSQL($target_url)  ."', mime_type = '" . pSQL($type)  ."', source = '" . pSQL($source)  ."', delimiter = '" . pSQL($delimiter) . "', headers = '" . pSQL($headers) . "', name = '" . pSQL($name)  ."', mask = '" . pSQL($mask)  ."', shop = '" . pSQL($shop) . "', date_added = '" . time() . "'");
				} else {
					$this->errors[] = $this->my_translation("Sorry, there was an error uploading your file.");
				}
			}			
		} else {
			$this->errors[] = $this->my_translation("Enter link or upload file.");
		}	
		if (!$this->errors) {			
			if (!isset($file_id)) {
				$file_id = Db::getInstance()->Insert_ID();
			}
			if (!empty($_POST['import_api_link'])) {
				if( strpos($_POST['import_api_link'], 'convert') !== false) {
					$fields_file_path = _PS_MODULE_DIR_ . 'import_api/fields.txt';
					$file_settings_file_path = _PS_MODULE_DIR_ . 'import_api/file_settings.txt';
					if (file_exists($fields_file_path)) {
						$f = file_get_contents($fields_file_path);					
						Db::getInstance()->execute("UPDATE ". _DB_PREFIX_ . "ia_files SET fields = '" . pSQL($f)  . "', date_edited = '" . time() . "' WHERE file_id = " . (int)$file_id);
					}
					if (file_exists($file_settings_file_path)) {
						$sql_raw = file_get_contents($file_settings_file_path);
						$sql = sprintf($sql_raw, _DB_PREFIX_, $file_id);

						Db::getInstance()->execute($sql);	
				
					}
				}
			}			
			Tools::redirectAdmin($this->context->link->getAdminLink('AdminImport_Api&type=settings&file_id=' . $file_id . '&token=' . Tools::getAdminTokenLite('AdminImport_Api'), false));
		}
    }
	
	protected function renderSettingsForm($settings, $tab = 'general')
    {
        $helper = new HelperForm();
		$this->tab = $tab;
        $helper->show_toolbar = false;
        $helper->table = $this->table;
        //$helper->module = $this;
        $helper->default_form_language = $this->context->language->id;
        $helper->allow_employee_form_lang = Configuration::get('PS_BO_ALLOW_EMPLOYEE_FORM_LANG', 0);

        $helper->identifier = $this->identifier;
        $helper->submit_action = 'submitImportSettings';
        $helper->currentIndex = $this->context->link->getAdminLink('AdminImport_Api', false)
            .'&type=settings&file_id='. $settings['file_id'];
        $helper->token = Tools::getAdminTokenLite('AdminImport_Api');

        $helper->tpl_vars = array(
            'fields_value' => $this->getConfigFormValues(),
            'languages' => $this->context->controller->getLanguages(),
            'id_language' => $this->context->language->id,
        );

        return $helper->generateForm(array($this->getConfigForm($settings)));
    }

    protected function getConfigForm($settings)
    {       

	    $import_api_fields = $settings['fields'] ?  html_entity_decode($settings['fields'], ENT_QUOTES, 'UTF-8') : '';
        
        $source_fields = explode('##', $import_api_fields);
		
		
        $options_not_existing[] =  array(
            'id_option' => 0, 
            'name' => $this->my_translation('Keep it'),
        );
		
		$options_not_existing[] =  array(
            'id_option' => 1, 
            'name' => $this->my_translation('Set quantity 0'),
        );
		
		$options_not_existing[] =  array(
            'id_option' => 2, 
            'name' => $this->my_translation('Set status disabled'),
        );
		
		$options_not_existing[] =  array(
            'id_option' => 3, 
            'name' => $this->my_translation('Delete'),
        );
				
		$options_synchronize_field[] =  array(
            'id_option' => 'automatic', 
            'name' => $this->my_translation('From unique field')
        );
		
		$options_synchronize_field[] =  array(
            'id_option' => 'reference', 
            'name' => $this->my_translation('Reference')
        );
		
		$options_synchronize_field[] =  array(
            'id_option' => 'ean13', 
            'name' => $this->my_translation('Ean13')
        );
		
		$options_synchronize_field[] =  array(
            'id_option' => 'upc', 
            'name' => $this->my_translation('Upc')
        );
		
		$options_synchronize_field[] =  array(
            'id_option' => 'name', 
            'name' => $this->my_translation('Product name')
        );
		
		$options_synchronize_field[] =  array(
            'id_option' => 'id_product', 
            'name' => $this->my_translation('Prestashop product id')
        );

        
        $options_yes_no[] =  array(
            'id_option' => 0, 
            'name' => $this->my_translation('No'),
        );
        $options_yes_no[] =  array(
            'id_option' => 1, 
            'name' => $this->my_translation('Yes'),
        );
        
        $options[] =  array(
            'id_option' => 0, 
            'name' => $this->my_translation('--Please select--'),
        );
		
		$filter_options[] =  array(
            'id_option' => 'equal', 
            'name' => $this->my_translation('Equal'),
        );
		
		$filter_options[] =  array(
            'id_option' => 'not_equal', 
            'name' => $this->my_translation('Not equal'),
        );
		
		$filter_options[] =  array(
            'id_option' => 'greater', 
            'name' => $this->my_translation('Greater'),
        );
		
		$filter_options[] =  array(
            'id_option' => 'less', 
            'name' => $this->my_translation('Less'),
        );
		
		$filter_options[] =  array(
            'id_option' => 'not_empty', 
            'name' => $this->my_translation('Not empty'),
        );
		
		$filter_options[] =  array(
            'id_option' => 'regexp', 
            'name' => $this->my_translation('REGEXP'),
        );
        
        if($import_api_fields){
            foreach($source_fields as $field){
                $options[] =  array(
                    'id_option' => $field, 
                    'name' => $field,
                );
            }
        }
		
		$def_tax[] = array('id_tax_rules_group' => -1, 'name' => 'Default');
		$def_tax[] = array('id_tax_rules_group' => 0, 'name' => 'No tax');
		
		$taxes = array_merge($def_tax, TaxRulesGroup::getTaxRulesGroups());

        $fields[] = array(
            'type' => 'hidden',
            'id' => 'fields',
            'name' => 'import_api_fields',
        );
        
        $fields[] = array(
            'type' => 'hidden',
            'id' => 'import_api_link',
            'name' => 'import_api_link',
        );
        
        $fields[] = array(
            'type' => 'hidden',
            'id' => 'import_api_type',
            'name' => 'import_api_type',
        );
        
        foreach($this->frm_fields as $fmr_field){
            $fields[] = array(
                'type' => 'select',
                'class' => 'api_field',
                'tab' => 'general',
                'required' => in_array($fmr_field, ['unique', 'name']) ? true : false,
                'label' => $this->my_translation($fmr_field),
                'name' => 'import_api_field['. $fmr_field .']',
                'options' => array(
                  'query' => $options,
                  'id' => 'id_option', 
                  'name' => 'name'
                )      
            );
        }
        
        foreach($this->frm_fields as $fmr_field){
            $fields[] = array(
                'type' => 'text',
                'tab' => 'modifications',
                'label' => $this->my_translation($fmr_field),
                'name' => 'import_api_modification['. $fmr_field .']',     
            );
            
            $fields[] = array(
                'type' => 'text',
                'tab' => 'combinations',
                'label' => $this->my_translation($fmr_field),
                'name' => 'import_api_split['. $fmr_field .']',     
            );
        }
		
		foreach($this->filter_fields as $f_field) {
			$fields[] = array(
                'type' => 'textarea',
				'tab' => 'filter',
                'rows' => 10,
                'hint' => 'Enter each value in new line',
                'label' => $this->my_translation($f_field),
                'name' => 'import_api_filter['. $f_field .']',     
                'description' => 'Enter values, each in new line',     
            );
			
			$fields[] = array(
                'type' => 'select',
				'tab' => 'filter',
                'label' => $this->my_translation('Filter options for ' . $f_field),
                'name' => 'import_api_filter_options['. $f_field .']',     
				'options' => array(
				  'query' => $filter_options,
				  'id' => 'id_option', 
				  'name' => 'name'
				)
            );
		}
		
		foreach($this->replace_fields as $r_field) {
			$fields[] = array(
                'type' => 'textarea',
				'tab' => 'replace',
                'rows' => 10,
				'hint' => 'Enter each value in new line in format OLD_TEXT##NEW_TEXT',
                'label' => $this->my_translation($r_field),
                'name' => 'import_api_replace['. $r_field .']',     
                'description' => 'Enter values in format old_word##new_word',     
            );
		}
        
        // Settings fields
        
        $fields[] = array(
            'type' => 'text',
            'tab' => 'settings',
            'label' => $this->my_translation('Top category'),
            'name' => 'import_api_settings[top_category]',     
        );
        
        $fields[] = array(
            'type' => 'text',
            'tab' => 'settings',
            'label' => $this->my_translation('Default category'),
            'name' => 'import_api_settings[default_category]',     
        );
        
        $fields[] = array(
            'type' => 'text',
            'tab' => 'settings',
            'label' => $this->my_translation('Default brand'),
            'name' => 'import_api_settings[default_brand]',     
        );
        
        $fields[] = array(
            'type' => 'text',
            'tab' => 'settings',
            'label' => $this->my_translation('Price multiplier'),
            'name' => 'import_api_settings[price_multiplier]',     
        );
		
		$fields[] = array(
            'type' => 'text',
            'tab' => 'settings',
            'label' => $this->my_translation('Combination price multiplier'),
            'name' => 'import_api_settings[combination_price_multiplier]',     
        );

		$fields[] = array(
			'type' => 'select',
			'tab' => 'settings',
			'label' => $this->my_translation('Add combination price to product price'),
			'name' => 'import_api_settings[add_combination_price]',
			'options' => array(
			  'query' => $options_yes_no,
			  'id' => 'id_option', 
			  'name' => 'name'
			)
		);
        
        $fields[] = array(
			'type' => 'select',
			'tab' => 'settings',
			'label' => $this->my_translation('Create category path from array'),
			'name' => 'import_api_settings[category_path]',
			'options' => array(
			  'query' => $options_yes_no,
			  'id' => 'id_option', 
			  'name' => 'name'
			)
		); 
		
		$fields[] = array(
            'type' => 'select',
            'tab' => 'settings',
            'label' => $this->my_translation('Tax rules group'),
            'name' => 'import_api_settings[id_tax_rules_group]',
			'options' => array(
			  'query' => $taxes,
			  'id' => 'id_tax_rules_group', 
			  'name' => 'name'
			)     
        );
		
		
		$fields[] = array(
			'type' => 'select',
			'tab' => 'settings',
			'label' => $this->my_translation('Update even if file is not changed'),
			'name' => 'import_api_settings[same_update]',
			'options' => array(
			  'query' => $options_yes_no,
			  'id' => 'id_option', 
			  'name' => 'name'
			)
		);
		
		$fields[] = array(
			'type' => 'select',
			'tab' => 'settings',
			'label' => $this->my_translation('If product not exist in file anymore'),
			'name' => 'import_api_settings[not_existing]',
			'options' => array(
			  'query' => $options_not_existing,
			  'id' => 'id_option', 
			  'name' => 'name'
			)
		);
		
		$fields[] = array(
			'type' => 'select',
			'tab' => 'settings',
			'label' => $this->my_translation('Update only'),
			'name' => 'import_api_settings[only_update]',
			'options' => array(
			  'query' => $options_yes_no,
			  'id' => 'id_option', 
			  'name' => 'name'
			)
		);
		
		$fields[] = array(
			'type' => 'select',
			'tab' => 'settings',
			'label' => $this->my_translation('Update field'),
			'name' => 'import_api_settings[synchronize_field]',
			'options' => array(
			  'query' => $options_synchronize_field,
			  'id' => 'id_option', 
			  'name' => 'name'
			)
		);
		
		foreach($this->frm_update_settings as $key => $setting) {
			$fields[] = array(
				'type' => 'select',
				'tab' => 'update',
				'label' => $this->my_translation('Update '. $key),
				'name' => 'import_api_settings[update_' . $key .']',
				'options' => array(
				  'query' => $options_yes_no,
				  'id' => 'id_option', 
				  'name' => 'name'
				)
			);
		}

        return array(
            'form' => array(
                'legend' => array(
                'title' => $this->my_translation('Configuration'),
                'icon' => 'icon-cogs',
                ),
                'input' => $fields,
                'submit' => array(
                    'title' => $this->my_translation('Save'),
                ),
                'tabs' => array(
                    'general' => $this->my_translation('Assign'),                    
                    'combinations' => $this->my_translation('Split'),
                    'modifications' => $this->my_translation('Modifications'),
                    'filter' => $this->my_translation('Filter'),
                    'replace' => $this->my_translation('Replace'),
                    'settings' => $this->my_translation('Settings'),
                    'update' => $this->my_translation('Update fields'),
                    'test' => $this->my_translation('Test'),
                ),
            ),
        );
    }
	
	protected function getConfigFormValues()
    {       
        $file_id = Tools::getValue('file_id');
		$return_settings = array();
        if (((bool)Tools::isSubmit('submitImportSettings')) == true) {
            $config_fields = Tools::getValue('import_api_field');
            $config_modification = Tools::getValue('import_api_modification');
            $config_split = Tools::getValue('import_api_split');
            $config_replace = Tools::getValue('import_api_replace');
            $config_filter = Tools::getValue('import_api_filter');
            $config_filter_options = Tools::getValue('import_api_filter_options');
            
            $config_settings = Tools::getValue('import_api_settings');
            
            $return_settings['import_api_fields'] = Tools::getValue('import_api_fields');
            $return_settings['import_api_link'] = Tools::getValue('import_api_link');
            $return_settings['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];
				$config_fields = json_decode($file_settings['mapping'], true);
				$config_modification = json_decode($file_settings['modification'], true);
				$config_split = json_decode($file_settings['split'], true);
				$config_replace = json_decode($file_settings['replace'], true);
				$config_filter = json_decode($file_settings['filter'], true);
				$config_filter_options = json_decode($file_settings['filter_options'], true);
				$config_settings = json_decode($file_settings['settings'], true);
			}
            
            $return_settings['import_api_fields'] = '';
            $return_settings['import_api_link'] = '';
            $return_settings['import_api_type'] = '';
        }
        
        foreach($this->frm_fields as $fmr_field){
            $return_settings['import_api_field[' . $fmr_field . ']'] = !empty($config_fields[$fmr_field]) ? html_entity_decode($config_fields[$fmr_field], ENT_QUOTES, 'UTF-8') : '';
            $return_settings['import_api_modification[' . $fmr_field . ']'] = !empty($config_modification[$fmr_field]) ? html_entity_decode($config_modification[$fmr_field], ENT_QUOTES, 'UTF-8') : '';
            $return_settings['import_api_split[' . $fmr_field . ']'] = !empty($config_split[$fmr_field]) ? html_entity_decode($config_split[$fmr_field], ENT_QUOTES, 'UTF-8') : '';
        }
		
		foreach($this->replace_fields as $r_field){
			$return_settings['import_api_replace[' . $r_field . ']'] = !empty($config_replace[$r_field]) ? html_entity_decode($config_replace[$r_field], ENT_QUOTES, 'UTF-8') : '';
		}
		
		foreach($this->filter_fields as $f_field){
			$return_settings['import_api_filter[' . $f_field . ']'] = !empty($config_filter[$f_field]) ? html_entity_decode($config_filter[$f_field], ENT_QUOTES, 'UTF-8') : '';
			$return_settings['import_api_filter_options[' . $f_field . ']'] = !empty($config_filter_options[$f_field]) ? html_entity_decode($config_filter_options[$f_field], ENT_QUOTES, 'UTF-8') : '';
		}
    
        for($i = 1; $i <= 3; $i++){
            $return_settings['import_api_field[field' . $i. ']'] = !empty($config_fields['field' . $i]) ? html_entity_decode($config_fields['field' . $i], ENT_QUOTES, 'UTF-8') : '';
        }
              
        for($i = 1; $i <= 3; $i++){
            $return_settings['import_api_modification[modification' . $i . ']'] = !empty($config_modification['modification' . $i]) ? html_entity_decode($config_modification['modification' . $i], ENT_QUOTES, 'UTF-8') : '';
        }
        
        foreach($this->frm_settings as $setting => $value){
            $return_settings['import_api_settings[' . $setting . ']'] = isset($config_settings[$setting]) ? $config_settings[$setting] : $value;
        }

		foreach($this->frm_update_settings as $setting => $value){
            $return_settings['import_api_settings[update_' . $setting . ']'] = isset($config_settings['update_' . $setting]) ? $config_settings['update_' . $setting] : $value;
        }


        return $return_settings;
    }
	
	protected function _postSettingsValidation()
    {
        
        if (!Tools::getValue('import_api_field')) {
            $this->_postErrors[] = $this->my_translation('You must assign unique field and name field.');
        } else {
            $fields = Tools::getValue('import_api_field');
            if(empty($fields['unique'])){
                $this->_postErrors[] = $this->my_translation('You must assign unique field');
            }
            if(empty($fields['name'])){
                //$this->_postErrors[] = $this->my_translation('You must assign name field');
            }
        }
    }
	protected function _saveSettings($file_id, $shop = 'default')
    {
        
		$mapping = '';
		$modification = '';
		$split = '';
		$replace = '';
		$filter = '';
		$filter_options = '';
		$settings = '';
		$update = false;
		
		$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];
			$mapping = $file_settings['mapping'];
			$modification = $file_settings['modification'];
			$split = $file_settings['split'];
			$replace = $file_settings['replace'];
			$filter = $file_settings['filter'];
			$filter_options = $file_settings['filter_options'];
			$settings = $file_settings['settings'];
			$update = true;
		}
		
		$implode = array();
		
		$new_mapping = json_encode(Tools::getValue('import_api_field'));
		$new_modification = json_encode(Tools::getValue('import_api_modification'));
		$new_split = json_encode(Tools::getValue('import_api_split'));
		$new_replace = json_encode(Tools::getValue('import_api_replace'));
		$new_filter = json_encode(Tools::getValue('import_api_filter'));
		$new_filter_options = json_encode(Tools::getValue('import_api_filter_options'));
		$new_settings = json_encode(Tools::getValue('import_api_settings'));

		if (Tools::getValue('import_api_field') && $new_mapping != $mapping) {
			$implode[]  = "mapping='" . pSQL($new_mapping). "'";
		}
		
		if (Tools::getValue('import_api_modification') && $new_modification != $modification) {
			$implode[]  = "modification='" . pSQL($new_modification). "'";
		}
		
		if (Tools::getValue('import_api_split') && $new_split != $split) {
			$implode[]  = "split='" . pSQL($new_split). "'";
		}
		
		if (Tools::getValue('import_api_replace') && $new_replace != $replace) {
			$implode[]  = "`replace`='" . pSQL($new_replace). "'";
		}
		
		if (Tools::getValue('import_api_filter') && $new_filter != $filter) {
			$implode[]  = "`filter`='" . pSQL($new_filter). "'";
		}
		
		if (Tools::getValue('import_api_filter_options') && $new_filter_options != $filter_options) {
			$implode[]  = "filter_options='" . pSQL($new_filter_options). "'";
		}

		if (Tools::getValue('import_api_settings') && $new_settings != $settings) {
			$implode[]  = "settings='" . pSQL($new_settings). "'";
		}

		if ($implode) {
			$implode[] = "date_updated = '" . time() ."'";
			$implode_string = implode(',', $implode);
			
			if ($update) {
				Db::getInstance()->execute("UPDATE ". _DB_PREFIX_ . "ia_file_settings SET " .$implode_string. " WHERE file_id = '" .(int)$file_id . "' AND shop = '" . pSQL($shop) . "'");
			} else {
				Db::getInstance()->execute("INSERT INTO ". _DB_PREFIX_ . "ia_file_settings SET " .$implode_string. ", file_id = '" .(int)$file_id . "', shop = '" . pSQL($shop) . "'");
			}
			//print_r("UPDATE ". _DB_PREFIX_ . "ia_file_settings SET " .$implode_string. " WHERE file_id = '" .(int)$file_id . "' AND shop = '" . $shop . "'"); 
			$this->queue->deleteUnnecessary($file_id, $shop);
			Tools::redirectAdmin($this->context->link->getAdminLink('AdminImport_Api&type=import&file_id=' . $file_id . '&token=' . Tools::getAdminTokenLite('AdminImport_Api'), false));

		}

        
    }
	
	public function my_translation($string) {
		return $this->module->l($string);
	}
}