PHP Dosya Yöneticisi

<?php

use Box\Spout\Reader\Common\Creator\ReaderEntityFactory;

use Box\Spout\Reader\ReaderFactory;

use Box\Spout\Common\Type;

class GkdSkipException extends Exception { }

function obuiErrorHandler($errno, $errstr, $errfile, $errline, array $errcontext) {

// error was suppressed with the @-operator

if (0 === error_reporting()) {

return false;

}

throw new ErrorException($errstr, $errno, 0, $errfile, $errline);

}

class ModelToolUniversalImport extends Model {

const benchmark = false;

private $simulation = true;

private $line_decay = 1;

private $processed = array(

'processed' => 0,

'inserted' => 0,

'updated' => 0,

'disabled' => 0,

'deleted' => 0,

'skipped' => 0,

'error' => 0,

);

private $pre_processed = false;

private $file;

private $fileHandle;

private $encoding;

private $handler;

private $filetype;

private $xml_node;

private $csv_separator;

private $processedIdArray;

private $processedIdFile;

private $xfn_multiple_separator = array();

private $token;

private $order_statuses = array();

private $currencyCodeToId = array();

private $storeIdToName = array();

private $ocCurrencyRates = array();

private $currencyRates = array();

public function pre_process($config) {

// extra function handling before populate

if ($this->pre_processed) return;

// disable config options

if (!empty($config['disable_cfg'])) {

$toDisable = explode(',', $config['disable_cfg']);

foreach ($toDisable as $cfgOption) {

$this->config->set(trim($cfgOption), false);

}

$type = str_replace('_update', '', $config['import_type']);

if (in_array($type, array('product', 'universal', 'category', 'information', 'manufacturer'))) {

$this->language->load('catalog/'.$type);

}

// extra functions

if (isset($config['extra_func'])) {

foreach ($config['extra_func'] as $extra_funcs) {

foreach ($extra_funcs as $func_name => $func_values) {

if ($func_name == 'multiple_separator') {

switch ($func_values['value']) {

case '[\n]': $func_values['value'] = "\n"; break;

case '[\t]': $func_values['value'] = "\t"; break;

default: break;

}

$this->xfn_multiple_separator[$func_values['field']] = $func_values['value'];

}

$this->pre_processed = true;

}

public function __construct($registry) {

parent::__construct($registry);

$this->load->model('gkd_import/tool');

$this->load->model('gkd_import/handler');

$this->tool = $this->model_gkd_import_tool->getObject();

$this->handler = $this->model_gkd_import_handler->getObject();

if (isset($this->session->data['user_token'])) {

$this->token = 'user_token='.$this->session->data['user_token'];

} else if (isset($this->session->data['token'])) {

$this->token = 'token='.$this->session->data['token'];

}

public function process($config, $limit = null) {

if (!$limit) {

$limit = 200;

if ((int) $this->config->get('gkd_impexp_batch_imp') > 0) {

$limit = (int) $this->config->get('gkd_impexp_batch_imp');

}

if (defined('GKD_CRON')) {

$this->simulation = $this->handler->simulation = false;

} else if ($this->user->hasPermission('modify', 'module/universal_import')) {

$this->simulation = $this->handler->simulation = !empty($config['simulation']);

} else {

$this->simulation = $this->handler->simulation = $config['simulation'] = true;

}

$simu_row = $this->simulation ? 'simu' : 'rows';

$this->language->load('module/universal_import');

set_error_handler('obuiErrorHandler');

//file_put_contents(DIR_SYSTEM . 'logs/import.log', $res . "\n", FILE_APPEND | LOCK_EX);

$this->filetype = !empty($config['import_filetype']) ? $config['import_filetype'] : strtolower(pathinfo($config['import_file'], PATHINFO_EXTENSION));

$this->handler->filetype = $this->filetype;

if (in_array($this->filetype, array('csv', 'txt', 'tsv'))) {

$this->csv_separator = !empty($config['csv_separator']) ? $config['csv_separator'] : ',';

if ($this->csv_separator == 'tab') {

$this->csv_separator = "\t";

}

$this->encoding = !empty($config['encoding']) ? $config['encoding'] : '';

} else if ($this->filetype == 'xml') {

$this->xml_node = $config['xml_node'];

if (true) {

if (substr($this->xml_node, 0, 1) != '/') {

$this->xml_node = '//'.$this->xml_node;

}

$type = $config['import_type'];

$subtype = !empty($config['import_subtype']) ? '_'.$config['import_subtype'] : '';

if (!in_array($type, array('product', 'universal', 'product_update', 'order', 'order_status_update', 'category', 'information', 'manufacturer', 'customer', 'attribute', 'filter', 'restore'))) {

//die('Invalid type');

}

if (in_array($type, array('product', 'universal', 'product_update', 'category', 'information', 'manufacturer'))) {

$this->load->model('catalog/'.str_replace('_update', '', $type));
      $this->load->model('tool/universal');

} else if ($type == 'customer') {

$this->load->model((version_compare(VERSION, '2.1', '>=') ? 'customer':'sale').'/customer');

} else if (in_array($type, array('order', 'order_status_update'))) {

$this->load->model('sale/order');

$this->load->model('gkd_import/order');

}

$this->session->data['obui_errors'] = array();

$this->session->data['obui_log'] = array();

if (!empty($this->session->data['univimport_temp_file'])) {

$config['import_file'] = $this->session->data['univimport_temp_file'];

} else if ($config['import_source'] == 'upload') {

$config['import_file'] = DIR_CACHE.'universal_import/'.str_replace(array('../', '..\\'), '', $config['import_file']);

} else if ($config['import_source'] == 'ftp') {

$config['import_file'] = $config['import_ftp'].$config['import_file'];

}

// init processedIdFile

if ($config['profile']) {

$processedIdFilename = $config['profile'];

} else {

$processedIdFilename = $config['import_file'];

}

$this->processedIdFile = DIR_CACHE.'universal_import/'.md5($processedIdFilename).'.proc';

// first init

if (empty($this->session->data['obui_current_line'])) {

$this->deleteIdentifierFile();

$this->session->data['obui_deleted_ids'] = array();

// delete all items or init id array

if (!empty($config['delete'])) {

if ($config['delete'] == 'all' || $config['delete'] == 'batch') {

$this->delete($config);

// do not return if in cron context

if (defined('GKD_CRON')) {

$this->session->data['obui_current_line'] = 0;

} else {

$this->session->data['obui_current_line'] = 'preproc';

return $this->tool->logs;

}

} else {

$this->session->data['obui_no_delete'] = array();

$this->session->data['obui_delete_brand'] = array();

}

// set current position for tail mode

if ($config['row_start'] < 0) {

$total_rows = $this->model_tool_universal_import->getTotalRows($config['import_file'], false, !empty($config['xml_node']) ? $config['xml_node'] : '', '', !empty($config['sheet']) ? (int) $config['sheet'] : 0, $config);

$config['row_start'] = $total_rows + $config['row_start'];

if ($config['row_start'] < 0) {

$config['row_start'] = 0;

}

} else if ($this->session->data['obui_current_line'] == 'preproc') {

$this->session->data['obui_current_line'] = 0;

// set current position for tail mode

if ($config['row_start'] < 0) {

$config['row_start'] = $total_rows + $config['row_start']+1;

if ($config['row_start'] < 0) {

$config['row_start'] = 0;

}

// load identifier file

$this->loadIdentifierFile();

// init import file

$this->file = $this->loadFile($config['import_file'], $config['import_filetype'], (!empty($config['sheet']) ? $config['sheet'] : 0), $config);

$first_row = $this->initFilePosition($this->file, $config);

$usleep = $this->config->get('gkd_impexp_sleep');

if (!empty($config['csv_header'])) {

$this->line_decay = 2;

}

if ($this->file) {

$i = 0;

while ($i < $limit && ($line = $this->getNextRow($this->file, $config)) !== false) {

if (!empty($config['row_end']) && $config['row_end']+1 <= $this->session->data['obui_current_line']) {

break;

}

$i++;

if ($first_row) {

$first_row = false;

continue;

}

// skip empty line

if (!count(array_filter((array) $line))) {

$this->session->data['obui_processed']['processed']++;

$this->session->data['obui_processed']['skipped']++;

$this->tool->log(array(

'row' => $this->session->data['obui_current_line'],

'status' => 'skipped',

'title' => $this->language->get('text_'.$simu_row.'_skipped'),

'msg' =>  $this->language->get('text_empty_line_skip'),

));

continue;

}

try {

if ($usleep) {

usleep((int) $usleep * 1000); // 1 000 000 = 1s

}

$resArray = $this->{'process_' . $type . $subtype}($config, $line);

if (empty($resArray['gkdIsResArray'])) {

$resArray = array($resArray);

} else {

unset($resArray['gkdIsResArray']);

}

foreach ($resArray as $res) {

$this->tool->log(array(

'row' => $this->session->data['obui_current_line'],

'status' => isset($res['row_status']) ? $res['row_status'] : 'unknown',

'title' => $this->language->get('text_'.$simu_row.'_'.$res['row_status']),

'msg' => !empty($res['row_msg']) ? $res['row_msg'] : '',

));

}

} catch (Exception $e) {

isset($this->session->data['obui_processed']['processed']) && $this->session->data['obui_processed']['processed']++;

isset($this->session->data['obui_processed']['processed']) && $this->session->data['obui_processed']['error']++;

//$this->session->data['obui_errors'][] = $e->getMessage() . ' - line: ' . $e->getLine() . ' - file: ' . $e->getFile();

$extraErrorInfo = '';

// extra info about error

if (strpos($e->getMessage(), '2147483647') !== false) {

$extraErrorInfo = '<br/>This error is because you have reached maximum number that can contain an id field in the database.<br/>To fix you would have to increase the INT number for this field in this table schema (and all other tables where it is used), you can do that in phpmyadmin, by default it is INT 11, so put INT 15 to have more possible values.';

}

if (strpos($e->getMessage(), 'Undefined index:') !== false) {

preg_match('/Undefined index: (.*)$/', $e->getMessage(), $forCustomField);

$extraErrorInfo = '<br/>This error is generally because you have some custom module that tries to insert some data into the database<br/>Try to set in Step 3 > Extra functions > Custom fields a custom field named "<b>'.$forCustomField[1].'</b>"';

}

if (strpos($e->getMessage(), 'real_escape_string()') !== false) {

$extraErrorInfo = '<br/>This error is because there is some array sent to insert in database, make sure that you do not assign an array of values in fields that expect a string.';

}

$this->tool->log(array(

'row' => $this->session->data['obui_current_line'],

'status' => 'error',

'title' => $this->language->get('text_simu_error'),

'msg' => $e->getMessage() . ' in file ' . $e->getFile() . ' on line ' . $e->getLine() . $extraErrorInfo,

));

}

// close file

if (in_array($this->filetype, array('csv', 'txt', 'tsv', 'ods', 'xlsx')) && isset($this->fileHandle)) {

$this->fileHandle->close();

}

if (in_array($this->filetype, array('csv_', 'sql'))) {

fclose($this->file);

}

if (empty($this->tool->logs) && $line === false) {

return false;

}

} else {

// error opening the file.

}

restore_error_handler();

return $this->tool->logs;

//return 1;

}

public function delete($config) {

if (isset($this->session->data['user_token'])) {

$this->token = 'user_token='.$this->session->data['user_token'];

} else if (isset($this->session->data['token'])) {

$this->token = 'token='.$this->session->data['token'];

}

$type = $this->db->escape(str_replace('_update', '', $config['import_type']));

$mode = $config['delete'];

$action = $config['delete_action'];

if ($type == 'car_shop') {

$type = ($config['item_identifier'] == 'carshop_list_id') ? 'carshop_list' : 'carshop_part';

}

if (defined('GKD_CRON')) {

$this->simulation = $this->handler->simulation = false;

} else if ($this->user->hasPermission('modify', 'module/universal_import')) {

$this->simulation = $this->handler->simulation = !empty($config['simulation']);

} else {

$this->simulation = $this->handler->simulation = true;

}

$simu_row = $this->simulation ? 'simu' : 'rows';

$deleted_array = array();

$where = '';

if (!$mode) {

return $this->tool->logs;

}

if ($mode == 'missing' && !empty($this->session->data['obui_no_delete'])) {

$where = " WHERE " . $type . "_id NOT IN ('" . implode("','", array_map('addslashes', $this->session->data['obui_no_delete'])) . "')";

} else if ($mode == 'batch') {

$where = " WHERE `import_batch` = '" . $this->db->escape($config['delete_batch']) . "'";

} else if ($mode == 'missing_brand') {

if (!empty($this->session->data['obui_no_delete']) && !empty($this->session->data['obui_delete_brand'])) {

$where = " WHERE " . $type . "_id NOT IN ('" . implode("','", array_map('addslashes', $this->session->data['obui_no_delete'])) . "') AND manufacturer_id IN ('" . implode("','", $this->session->data['obui_delete_brand']) . "')";

} else {

// no brands? do not run delete

return $this->tool->logs;

}

if (!empty($config['delete_batch'])) {

$where .= $where ? ' AND ' : ' WHERE ';

if ($config['delete_batch'] == 'defined') {

$where .= "`import_batch` <> ''";

} else if ($config['delete_batch'] == 'empty') {

$where .= "`import_batch` = ''";

} else {

$where .= "`import_batch` = '" . $this->db->escape($config['delete_batch']) . "'";

}

if (!empty($config['delete_condition']['db_field'])) {

$func_values = $config['delete_condition'];

$where .= $where ? ' AND ' : ' WHERE ';

if ($func_values['comparator'] == 'is_equal') {

$where .= "`".$this->db->escape($func_values['db_field'])."` = '".$this->db->escape($func_values['value'])."'";

} else if ($func_values['comparator'] == 'is_equal_list') {

$not_in = array();

foreach (explode('|', $func_values['value']) as $v) {

$not_in[] = $this->db->escape($v);

}

$where .= "`".$this->db->escape($func_values['db_field'])."` IN ('".implode( "', '" , array_map('addslashes', $not_in))."')";

} else if ($func_values['comparator'] == 'is_not_equal_list') {

$not_in = array();

foreach (explode('|', $func_values['value']) as $v) {

$not_in[] = $this->db->escape($v);

}

$where .= "`".$this->db->escape($func_values['db_field'])."` NOT IN ('".implode( "', '" , array_map('addslashes', $not_in))."')";

} else if ($func_values['comparator'] == 'is_not_equal') {

$where .= "`".$this->db->escape($func_values['db_field'])."` <> '".$this->db->escape($func_values['value'])."'";

} else if ($func_values['comparator'] == 'is_greater') {

$where .= "`".$this->db->escape($func_values['db_field'])."` > '".$this->db->escape($func_values['value'])."'";

} else if ($func_values['comparator'] == 'is_lower') {

$where .= "`".$this->db->escape($func_values['db_field'])."` < '".$this->db->escape($func_values['value'])."'";

} else if ($func_values['comparator'] == 'contain') {

$where .= "`".$this->db->escape($func_values['db_field'])."` LIKE '%".$this->db->escape($func_values['value'])."%'";

} else if ($func_values['comparator'] == 'not_contain') {

$where .= "`".$this->db->escape($func_values['db_field'])."` NOT LIKE '%".$this->db->escape($func_values['value'])."%'";

}

if (!empty($config['no_delete_skipped']) && isset($config['extra_func'])) {

foreach ($config['extra_func'] as $extra_funcs) {

foreach ($extra_funcs as $func_name => $func_values) {

if ($func_name == 'skip_db') {

if ($func_values['fieldval'] !== '') continue;

$where .= $where ? ' AND ' : ' WHERE ';

if ($func_values['comparator'] == 'is_equal') {

$where .= "`".$this->db->escape($func_values['db_field'])."` <> '".$this->db->escape($func_values['value'])."'";

} else if ($func_values['comparator'] == 'is_equal_list') {

$not_in = array();

foreach (explode('|', $func_values['value']) as $v) {

$not_in[] = $this->db->escape($v);

}

$where .= "`".$this->db->escape($func_values['db_field'])."` NOT IN ('".implode( "', '" , array_map('addslashes', $not_in))."')";

} else if ($func_values['comparator'] == 'is_not_equal') {

$where .= "`".$this->db->escape($func_values['db_field'])."` = '".$this->db->escape($func_values['value'])."'";

} else if ($func_values['comparator'] == 'is_greater') {

$where .= "`".$this->db->escape($func_values['db_field'])."` < '".$this->db->escape($func_values['value'])."'";

} else if ($func_values['comparator'] == 'is_lower') {

$where .= "`".$this->db->escape($func_values['db_field'])."` > '".$this->db->escape($func_values['value'])."'";

} else if ($func_values['comparator'] == 'contain') {

$where .= "`".$this->db->escape($func_values['db_field'])."` NOT LIKE '%".$this->db->escape($func_values['value'])."%'";

} else if ($func_values['comparator'] == 'not_contain') {

$where .= "`".$this->db->escape($func_values['db_field'])."` LIKE '%".$this->db->escape($func_values['value'])."%'";

}

// if simulation count total

if ($this->simulation) {

$count = $this->db->query("SELECT COUNT(" . $type . "_id) AS total FROM " . DB_PREFIX . $type . $where)->row;

if ($action == 'delete') {

$this->session->data['obui_processed']['deleted'] = $count['total'];

} else {

$this->session->data['obui_processed']['disabled'] = $count['total'];

}

if (!$this->simulation) {

if (!isset($this->session->data['obui_processed'])) {

$this->session->data['obui_processed'] = array();

}

if (!in_array($type, array('product', 'universal', 'category', 'information', 'manufacturer', 'customer', 'filter', 'attribute'))) {

//die('Invalid type');

}

if (in_array($type, array('product', 'universal', 'product_update', 'category', 'information', 'manufacturer', 'filter', 'review', 'attribute'))) {

$this->load->model('catalog/'.str_replace('_update', '', $type));
        $this->load->model('tool/universal');

$model = 'model_catalog_'.$type;

} else if ($type == 'customer') {

$this->load->model((version_compare(VERSION, '2.1', '>=') ? 'customer':'sale').'/customer');

$model = 'model_'.(version_compare(VERSION, '2.1', '>=') ? 'customer':'sale').'_customer';

}

$to_delete = $this->db->query("SELECT " . $type . "_id FROM " . DB_PREFIX . $type . $where)->rows;

if ($action == 'delete') {

foreach ($to_delete as $del) {

if (!$this->simulation) {

$this->{$model}->{'delete'.ucfirst($type)}($del[$type.'_id']);

}

$deleted_array[] = $del[$type.'_id'];

}

$this->session->data['obui_processed']['deleted'] += count($deleted_array);

} else if ($action == 'disable') {

foreach ($to_delete as $del) {

if (!$this->simulation) {

$this->db->query("UPDATE " . DB_PREFIX . $type . " SET status = 0 WHERE " . $type . "_id = '" . (int) $del[$type.'_id'] . "'");

}

$deleted_array[] = $del[$type.'_id'];

}

$this->session->data['obui_processed']['disabled'] += count($deleted_array);

} else if ($action == 'zero') {

foreach ($to_delete as $del) {

if (!$this->simulation) {

$this->db->query("UPDATE " . DB_PREFIX . $type . " SET quantity = 0 WHERE " . $type . "_id = '" . (int) $del[$type.'_id'] . "'");

}

$deleted_array[] = $del[$type.'_id'];

}

$this->session->data['obui_processed']['disabled'] += count($deleted_array);

}

$deleted_ids = '';

foreach ($deleted_array as $deleted) {

if (defined('GKD_CRON')) {

$deleted_ids .= $deleted.', ';

} else {

$deleted_ids .= '<a target="_blank" href="'.$this->url->link('catalog/'.$type.'/edit', $type.'_id='.$deleted.'&' . $this->token, 'SSL').'">'.$deleted.'</a>, ';

}

$deleted_ids = rtrim($deleted_ids, ', ');

if (!$deleted_ids) {

$deleted_ids = $this->language->get('text_nothing_deleted');

}

if ($action == 'delete') {

$this->tool->log(array(

'row' => '',

'status' => 'deleted',

'title' => $this->language->get('text_'.$simu_row.'_deleted'),

'msg' => ($mode == 'all' && empty($config['delete_batch'])) ? $this->language->get('text_delete_all') : $deleted_ids,

));

} else if ($action == 'zero') {

$this->tool->log(array(

'row' => '',

'status' => 'disabled',

'title' => $this->language->get('text_'.$simu_row.'_qtyzero'),

'msg' => ($mode == 'all' && empty($config['delete_batch'])) ? $this->language->get('text_delete_all') : $deleted_ids,

));

} else {

$this->tool->log(array(

'row' => '',

'status' => 'disabled',

'title' => $this->language->get('text_'.$simu_row.'_disabled'),

'msg' => ($mode == 'all' && empty($config['delete_batch'])) ? $this->language->get('text_delete_all') : $deleted_ids,

));

}

return $this->tool->logs;

}

public function process_restore($config, $line) {

if (!$this->simulation) {

$line = trim($line);

if ($line) {

$res = $this->db->query($line);

}

$data['row_status'] = 'inserted';

//$data['row_msg'] = $line;

$data['query'] = $line;

$this->session->data['obui_processed']['inserted']++;

$this->session->data['obui_processed']['processed']++;

return $data;

}

public function process_product($config, $line) {

$this->pre_process($config);

if (empty($this->filetype)) {

$this->filetype = !empty($config['import_filetype']) ? $config['import_filetype'] : strtolower(pathinfo($config['import_file'], PATHINFO_EXTENSION));

$this->handler->filetype = $this->filetype;

}

$config['columns_bindings'] = $config['columns'];

// get default value if array is empty

$config['columns']['product_category'] = array_filter($config['columns']['product_category'], array($this, 'array_filter_column'));

if (empty($config['columns']['product_category'])) {

$config['columns']['product_category'] = '';

}

$this->populate_fields($config, $line);

$this->populate_extra_func($config, $line);

$data = &$config['columns'];

// get default name for identifier

if (in_array($config['item_identifier'], array('name', 'description'))) {

$defaultLangDesc = reset($data['product_description']);

$data[$config['item_identifier']] = $defaultLangDesc[$config['item_identifier']];

unset($defaultLangDesc);

} else if ($config['item_identifier'] == 'image') {

$data['image'] = $this->handler->imageHandler('image', $config, false, false, true);

}

$item_id = $this->itemExists($config['import_type'], $config, $data);

if ($item_id && $config['item_exists'] == 'option') {

$is_option = true;

} else if ($config['item_exists'] == 'update_option') {

$saveIdentifier = true;

if (empty($config['option_insert_type'])) {

$config['option_insert_type'] = 'update'; // important to keep product_option_id

}

$config['reset_options'] = true;

if ($this->itemHasProcessed($config['import_type'], $config['item_identifier'], $data)) {

$is_option = true;

$config['item_exists'] = 'option';

} else {

$config['item_exists'] = 'soft_update';

}

// handle extra function before populated values (mainly for skip before inserting data)

if (isset($config['extra_func'])) {

foreach ($config['extra_func'] as $extra_funcs) {

foreach ($extra_funcs as $func_name => $func_values) {

if ($func_name == 'delete_item')  {

if (($func_values['comparator'] == 'is_equal' && $func_values['field'] == $func_values['value']) ||

($func_values['comparator'] == 'is_equal_list' && in_array($func_values['field'], explode('|', $func_values['value']))) ||

($func_values['comparator'] == 'is_not_equal' && $func_values['field'] != $func_values['value']) ||

($func_values['comparator'] == 'is_not_equal_list' && !in_array($func_values['field'], explode('|', $func_values['value']))) ||

($func_values['comparator'] == 'is_greater' && $func_values['field'] > $func_values['value']) ||

($func_values['comparator'] == 'is_lower' && $func_values['field'] < $func_values['value']) ||

($func_values['comparator'] == 'contain' && strpos($func_values['field'], $func_values['value']) !== false) ||

($func_values['comparator'] == 'not_contain' && strpos($func_values['field'], $func_values['value']) === false)) {

if ($item_id) {

if (isset($func_values['action']) && $func_values['action'] == 'disable') {

$data = array();

if (!$this->simulation) {

$this->db->query("UPDATE " . DB_PREFIX . "product SET status = 0 WHERE product_id = '" . (int) $item_id . "'");

$data['row_msg'] = $this->language->get('text_simu_disabled') . ' - ' . (isset($func_values['orig_field']) ? $func_values['orig_field'] : $func_values['field']) . ' ' . strtolower($this->language->get('xfn_'.$func_values['comparator'])) . ' ' . (isset($func_values['orig_fieldval']) ? $func_values['orig_fieldval'] : $func_values['value']);

} else {

$data['row_msg'] = $this->language->get('text_rows_disabled') . ' - ' . (isset($func_values['orig_field']) ? $func_values['orig_field'] : $func_values['field']) . ' ' . strtolower($this->language->get('xfn_'.$func_values['comparator'])) . ' ' . (isset($func_values['orig_fieldval']) ? $func_values['orig_fieldval'] : $func_values['value']);

}

$data['row_status'] = 'disabled';

$this->session->data['obui_processed']['disabled']++;

} else if (isset($func_values['action']) && $func_values['action'] == 'zero') {

$data = array();

if (!$this->simulation) {

$this->db->query("UPDATE " . DB_PREFIX . "product SET quantity = 0 WHERE product_id = '" . (int) $item_id . "'");

$data['row_msg'] = $this->language->get('text_simu_qtyzero') . ' - ' . (isset($func_values['orig_field']) ? $func_values['orig_field'] : $func_values['field']) . ' ' . strtolower($this->language->get('xfn_'.$func_values['comparator'])) . ' ' . (isset($func_values['orig_fieldval']) ? $func_values['orig_fieldval'] : $func_values['value']);

} else {

$data['row_msg'] = $this->language->get('text_rows_qtyzero') . ' - ' . (isset($func_values['orig_field']) ? $func_values['orig_field'] : $func_values['field']) . ' ' . strtolower($this->language->get('xfn_'.$func_values['comparator'])) . ' ' . (isset($func_values['orig_fieldval']) ? $func_values['orig_fieldval'] : $func_values['value']);

}

$data['row_status'] = 'disabled';

$this->session->data['obui_processed']['disabled']++;

} else {

if (!$this->simulation) {

$this->model_tool_universal->deleteProduct($item_id);

$data['row_msg'] = $this->language->get('text_simu_deleted') . ' - ' . (isset($func_values['orig_field']) ? $func_values['orig_field'] : $func_values['field']) . ' ' . strtolower($this->language->get('xfn_'.$func_values['comparator'])) . ' ' . (isset($func_values['orig_fieldval']) ? $func_values['orig_fieldval'] : $func_values['value']);

} else {

$data['row_msg'] = $this->language->get('text_rows_deleted') . ' - ' . (isset($func_values['orig_field']) ? $func_values['orig_field'] : $func_values['field']) . ' ' . strtolower($this->language->get('xfn_'.$func_values['comparator'])) . ' ' . (isset($func_values['orig_fieldval']) ? $func_values['orig_fieldval'] : $func_values['value']);

}

$data['row_status'] = 'deleted';

$this->session->data['obui_processed']['deleted']++;

}

$this->session->data['obui_processed']['processed']++;

return $data;

} else {

$data['row_status'] = 'skipped';

$data['row_msg'] = $this->language->get('text_skip_delete');

$this->session->data['obui_processed']['skipped']++;

$this->session->data['obui_processed']['processed']++;

return $data;

}

} else if ($func_name == 'skip')  {