in-portal
No OneTemporary
Actions

Subscribers

None

File Metadata

Created: Sun, Apr 20, 2:46 AM

in-portal
View Options

	Index: branches/RC/core/kernel/db/dbitem.php
	===================================================================
	--- branches/RC/core/kernel/db/dbitem.php (revision 12005)
	+++ branches/RC/core/kernel/db/dbitem.php (revision 12006)
	@@ -1,1291 +1,1291 @@
	<?php
	/**
	* @version $Id$
	* @package In-Portal
	* @copyright Copyright (C) 1997 - 2009 Intechnic. All rights reserved.
	* @license GNU/GPL
	* In-Portal is Open Source software.
	* This means that this software may have been modified pursuant
	* the GNU General Public License, and as distributed it includes
	* or is derivative of works licensed under the GNU General Public License
	* or other free or open source software licenses.
	* See http://www.in-portal.net/license/ for copyright notices and details.
	*/

	/**
	* DBItem
	*
	* Desciption
	* @package kernel4
	*/
	class kDBItem extends kDBBase {

	/**
	* Description
	*
	* @var array Associative array of current item' field values
	* @access public
	*/
	var $FieldValues;

	/**
	* Unformatted field values, before parse
	*
	* @var Array
	* @access private
	*/
	var $DirtyFieldValues = Array();

	/**
	* Holds item values after loading (not affected by submit)
	*
	* @var Array
	* @access private
	*/
	var $OriginalFieldValues = Array ();

	var $FieldErrors;

	var $ErrorMsgs = Array();

	/**
	* If set to true, Update will skip Validation before running
	*
	* @var array Associative array of current item' field values
	* @access public
	*/
	var $IgnoreValidation = false;

	var $Loaded = false;

	/**
	* Holds item' primary key value
	*
	* @var int Value of primary key field for current item
	* @access public
	*/
	var $ID;

	function kDBItem()
	{
	parent::kDBBase();
	$this->ErrorMsgs['required'] = '!la_err_required!'; //'Field is required';
	$this->ErrorMsgs['unique'] = '!la_err_unique!'; //'Field value must be unique';
	$this->ErrorMsgs['value_out_of_range'] = '!la_err_value_out_of_range!'; //'Field is out of range, possible values from %s to %s';
	$this->ErrorMsgs['length_out_of_range'] = '!la_err_length_out_of_range!'; //'Field is out of range';
	$this->ErrorMsgs['bad_type'] = '!la_err_bad_type!'; //'Incorrect data format, please use %s';
	$this->ErrorMsgs['invalid_format'] = '!la_err_invalid_format!'; //'Incorrect data format, please use %s';
	$this->ErrorMsgs['bad_date_format'] = '!la_err_bad_date_format!'; //'Incorrect date format, please use (%s) ex. (%s)';
	$this->ErrorMsgs['primary_lang_required'] = '!la_err_primary_lang_required!';
	}

	function SetDirtyField($field_name, $field_value)
	{
	$this->DirtyFieldValues[$field_name] = $field_value;
	}

	function GetDirtyField($field_name)
	{
	return $this->DirtyFieldValues[$field_name];
	}

	function GetOriginalField($field_name, $formatted = false, $format=null)
	{
	if (array_key_exists($field_name, $this->OriginalFieldValues)) {
	// item was loaded before
	$value = $this->OriginalFieldValues[$field_name];
	}
	else {
	// no original fields -> use default field value
	$value = $this->Fields[$field_name]['default'];
	}

	if (!$formatted) {
	return $value;
	}

	$options = $this->GetFieldOptions($field_name);
	$res = $value;
	if (array_key_exists('formatter', $options)) {
	$formatter =& $this->Application->recallObject($options['formatter']);
	/* @var $formatter kFormatter */

	$res = $formatter->Format($value, $field_name, $this, $format);
	}
	return $res;
	}

	/**
	* Sets original field value (useful for custom virtual fields)
	*
	* @param string $field_name
	*/
	function SetOriginalField($field_name, $field_value)
	{
	$this->OriginalFieldValues[$field_name] = $field_value;
	}

	/**
	* Set's default values for all fields
	*
	* @param bool $populate_ml_fields create all ml fields from db in config or not
	*
	* @access public
	*/
	function SetDefaultValues($populate_ml_fields = false)
	{
	parent::SetDefaultValues($populate_ml_fields);
	if ($populate_ml_fields) {
	$this->PopulateMultiLangFields();
	}

	foreach ($this->Fields as $field => $params) {
	if ( isset($params['default']) ) {
	$this->SetDBField($field, $params['default']);
	}
	else {
	$this->SetDBField($field, NULL);
	}
	}
	}

	/**
	* Sets current item field value
	* (applies formatting)
	*
	* @access public
	* @param string $name Name of the field
	* @param mixed $value Value to set the field to
	* @return void
	*/
	function SetField($name,$value)
	{
	$options = $this->GetFieldOptions($name);
	$parsed = $value;
	if ($value == '') {
	$parsed = NULL;
	}

	// kFormatter is always used, to make sure, that numeric value is converted to normal representation
	// according to regional format, even when formatter is not set (try seting format to 1.234,56 to understand why)
	$formatter =& $this->Application->recallObject(isset($options['formatter']) ? $options['formatter'] : 'kFormatter');
	$parsed = $formatter->Parse($value, $name, $this);

	$this->SetDBField($name,$parsed);
	}

	/**
	* Sets current item field value
	* (doesn't apply formatting)
	*
	* @access public
	* @param string $name Name of the field
	* @param mixed $value Value to set the field to
	* @return void
	*/
	function SetDBField($name,$value)
	{
	$this->FieldValues[$name] = $value;
	/*if (isset($this->Fields[$name]['formatter'])) {
	$formatter =& $this->Application->recallObject($this->Fields[$name]['formatter']);
	$formatter->UpdateSubFields($name, $value, $this->Fields[$name], $this);
	}*/
	}

	/**
	* Set's field error, if pseudo passed not found then create it with message text supplied.
	* Don't owerrite existing pseudo translation.
	*
	* @param string $field
	* @param string $pseudo
	* @param string $error_label
	*/
	function SetError($field, $pseudo, $error_label = null, $error_params = null)
	{
	$error_field = isset($this->Fields[$field]['error_field']) ? $this->Fields[$field]['error_field'] : $field;
	if (isset($this->FieldErrors[$error_field]['pseudo'])) {
	// don't set more then one error on field
	return ;
	}

	$this->FieldErrors[$error_field]['pseudo'] = $pseudo;

	if (isset($error_params)) {
	// additional params, that helps to determine error sources
	$this->FieldErrors[$error_field]['params'] = $error_params;
	}

	if (isset($error_label) && !isset($this->ErrorMsgs[$pseudo])) {
	// label for error (only when not already set)
	$this->ErrorMsgs[$pseudo] = (substr($error_label, 0, 1) == '+') ? substr($error_label, 1) : '!'.$error_label.'!';
	}
	}

	/**
	* Return current item' field value by field name
	* (doesn't apply formatter)
	*
	* @access public
	* @param string $name field name to return
	* @return mixed
	*/
	function GetDBField($name)
	{
	return $this->FieldValues[$name];
	}

	function HasField($name)
	{
	return isset($this->FieldValues[$name]);
	}

	function GetFieldValues()
	{
	return $this->FieldValues;
	}

	/**
	* Sets item' fields corresponding to elements in passed $hash values.
	*
	* The function sets current item fields to values passed in $hash, by matching $hash keys with field names
	* of current item. If current item' fields are unknown {@link kDBItem::PrepareFields()} is called before acutally setting the fields
	*
	* @access public
	* @param Array $hash
	* @param Array $set_fields Optional param, field names in target object to set, other fields will be skipped
	* @return void
	*/
	function SetFieldsFromHash($hash, $set_fields = null)
	{
	// used in formatter which work with multiple fields together
	foreach($hash as $field_name => $field_value) {
	if (is_numeric($field_name) \|\| !array_key_exists($field_name, $this->Fields)) {
	continue;
	}

	if (is_array($set_fields) && !in_array($field_name, $set_fields)) {
	continue;
	}

	$this->SetDirtyField($field_name, $field_value);
	}

	// formats all fields using associated formatters
	foreach ($hash as $field_name => $field_value)
	{
	if (is_numeric($field_name) \|\| !array_key_exists($field_name, $this->Fields)) {
	continue;
	}

	if (is_array($set_fields) && !in_array($field_name, $set_fields)) {
	continue;
	}

	$this->SetField($field_name,$field_value);
	}
	}

	function SetDBFieldsFromHash($hash, $set_fields = null)
	{
	foreach ($hash as $field_name => $field_value) {
	if (is_numeric($field_name) \|\| !array_key_exists($field_name, $this->Fields)) {
	continue;
	}

	if (is_array($set_fields) && !in_array($field_name, $set_fields)) {
	continue;
	}

	$this->SetDBField($field_name, $field_value);
	}
	}

	/**
	* Returns part of SQL WHERE clause identifing the record, ex. id = 25
	*
	* @access public
	* @param string $method Child class may want to know who called GetKeyClause, Load(), Update(), Delete() send its names as method
	* @param Array $keys_hash alternative, then item id, keys hash to load item by
	* @return void
	* @see kDBItem::Load()
	* @see kDBItem::Update()
	* @see kDBItem::Delete()
	*/
	function GetKeyClause($method=null, $keys_hash = null)
	{
	if( !isset($keys_hash) ) $keys_hash = Array($this->IDField => $this->ID);

	$ret = '';
	foreach($keys_hash as $field => $value)
	{
	if (!preg_match('/\./', $field)) {
	$ret .= '(`'.$this->TableName.'`.'.$field.' = '.$this->Conn->qstr($value).') AND ';
	}
	else {
	$ret .= '('.$field.' = '.$this->Conn->qstr($value).') AND ';
	}
	}

	return preg_replace('/(.*) AND $/', '\\1', $ret);
	}

	/**
	* Loads item from the database by given id
	*
	* @access public
	* @param mixed $id item id of keys->values hash to load item by
	* @param string $id_field_name Optional parameter to load item by given Id field
	* @return bool True if item has been loaded, false otherwise
	*/
	function Load($id, $id_field_name = null)
	{
	if ( isset($id_field_name) ) {
	$this->SetIDField($id_field_name); // set new IDField
	}

	$keys_sql = '';
	if (is_array($id)) {
	$keys_sql = $this->GetKeyClause('load', $id);
	}
	else {
	$this->setID($id);
	$keys_sql = $this->GetKeyClause('load');
	}

	if ( isset($id_field_name) ) {
	// restore original IDField from unit config
	$this->setIDField( $this->Application->getUnitOption($this->Prefix, 'IDField') );
	}

	if (($id === false) \|\| !$keys_sql) {
	return $this->Clear();
	}

	if (!$this->raiseEvent('OnBeforeItemLoad', $id)) {
	return false;
	}

	$q = $this->GetSelectSQL() . ' WHERE ' . $keys_sql;
	$field_values = $this->Conn->GetRow($q);

	if ($field_values) {
	$this->FieldValues = array_merge_recursive2($this->FieldValues, $field_values);
	$this->OriginalFieldValues = $this->FieldValues;
	}
	else {
	return $this->Clear();
	}

	if (is_array($id) \|\| isset($id_field_name)) {
	$this->setID($this->FieldValues[$this->IDField]);
	}

	$this->UpdateFormattersSubFields(); // used for updating separate virtual date/time fields from DB timestamp (for example)

	$this->raiseEvent('OnAfterItemLoad', $this->GetID());
	$this->Loaded = true;

	return true;
	}

	/**
	* Builds select sql, SELECT ... FROM parts only
	*
	* @access public
	* @return string
	*/
	function GetSelectSQL()
	{
	$sql = $this->addCalculatedFields($this->SelectClause);
	return parent::GetSelectSQL($sql);
	}

	function UpdateFormattersMasterFields()
	{
	foreach ($this->Fields as $field => $options) {
	if (isset($options['formatter'])) {
	$formatter =& $this->Application->recallObject($options['formatter']);
	$formatter->UpdateMasterFields($field, $this->GetDBField($field), $options, $this);
	}
	}
	}

	/**
	* Allows to skip certain fields from getting into sql queries
	*
	* @param string $field_name
	* @param mixed $force_id
	* @return bool
	*/
	- function _skipField($field_name, $force_id = false)
	+ function skipField($field_name, $force_id = false)
	{
	$skip = false;

	// 1. skipping 'virtual' field
	$skip = $skip \|\| array_key_exists($field_name, $this->VirtualFields);

	// 2. don't write empty field value to db, when "skip_empty" option is set
	$field_value = array_key_exists($field_name, $this->FieldValues) ? $this->FieldValues[$field_name] : false;
	$skip_empty = array_key_exists('skip_empty', $this->Fields[$field_name]) ? $this->Fields[$field_name]['skip_empty'] : false;
	$skip = $skip \|\| (!$field_value && $skip_empty);

	// 3. skipping field not in Fields (nor virtual, nor real)
	$skip = $skip \|\| !array_key_exists($field_name, $this->Fields);

	return $skip;
	}

	/**
	* Updates previously loaded record with current item' values
	*
	* @access public
	* @param int Primery Key Id to update
	* @return bool
	*/
	function Update($id = null, $system_update = false)
	{
	if (isset($id)) {
	$this->setID($id);
	}

	if (!$this->raiseEvent('OnBeforeItemUpdate')) {
	return false;
	}

	if (!isset($this->ID)) {
	// ID could be set inside OnBeforeItemUpdate event, so don't combine this check with previous one
	return false;
	}

	// validate before updating
	if (!$this->Validate()) {
	return false;
	}

	if (!$this->raiseEvent('OnAfterItemValidate')) {
	return false;
	}

	if (!$this->FieldValues) {
	// nothing to update
	return true;
	}

	$sql = '';

	foreach ($this->FieldValues as $field_name => $field_value) {
	- if ($this->_skipField($field_name)) {
	+ if ($this->skipField($field_name)) {
	continue;
	}

	if ( is_null($field_value) ) {
	if (array_key_exists('not_null', $this->Fields[$field_name]) && $this->Fields[$field_name]['not_null']) {
	// "kFormatter::Parse" methods converts empty values to NULL and for
	// not-null fields they are replaced with default value here
	$field_value = $this->Fields[$field_name]['default'];
	}
	}

	$sql .= '`' . $field_name . '` = ' . $this->Conn->qstr($field_value) . ', ';
	}

	$sql = 'UPDATE ' . $this->TableName . '
	SET ' . substr($sql, 0, -2) . '
	WHERE ' . $this->GetKeyClause('update');

	if ($this->Conn->ChangeQuery($sql) === false) {
	// there was and sql error
	return false;
	}

	$affected = $this->Conn->getAffectedRows();
	if (!$system_update && $affected == 1) {
	$this->setModifiedFlag(clUPDATE);
	}

	$this->saveCustomFields();
	$this->raiseEvent('OnAfterItemUpdate');
	$this->Loaded = true;

	if ($this->mode != 't') {
	$this->Application->resetCounters($this->TableName);
	}

	return true;
	}

	function ValidateField($field)
	{
	$options = $this->Fields[$field];

	/*if (isset($options['formatter'])) {
	$formatter =& $this->Application->recallObject($options['formatter']);
	$formatter->UpdateMasterFields($field, $this->GetDBField($field), $options, $this);
	}*/

	$error_field = isset($options['error_field']) ? $options['error_field'] : $field;
	$res = !isset($this->FieldErrors[$error_field]['pseudo']) \|\| !$this->FieldErrors[$error_field]['pseudo'];

	$res = $res && $this->ValidateRequired($field, $options);
	$res = $res && $this->ValidateType($field, $options);
	$res = $res && $this->ValidateRange($field, $options);
	$res = $res && $this->ValidateUnique($field, $options);
	$res = $res && $this->CustomValidation($field, $options);

	return $res;
	}

	/**
	* Validate all item fields based on
	* constraints set in each field options
	* in config
	*
	* @return bool
	* @access private
	*/
	function Validate()
	{
	$this->UpdateFormattersMasterFields(); //order is critical - should be called BEFORE checking errors

	if ($this->IgnoreValidation) {
	return true;
	}

	$global_res = true;
	foreach ($this->Fields as $field => $params) {
	$res = $this->ValidateField($field);


	$global_res = $global_res && $res;
	}

	if (!$global_res && $this->Application->isDebugMode()) {
	$error_msg = ' Validation failed in prefix <strong>'.$this->Prefix.'</strong>,
	FieldErrors follow (look at items with <strong>"pseudo"</strong> key set)<br />
	You may ignore this notice if submitted data really has a validation error';
	trigger_error(trim($error_msg), E_USER_NOTICE);
	$this->Application->Debugger->dumpVars($this->FieldErrors);
	}

	return $global_res;
	}

	/**
	* Check field value by user-defined alghoritm
	*
	* @param string $field field name
	* @param Array $params field options from config
	* @return bool
	*/
	function CustomValidation($field, $params)
	{
	return true;
	}

	/**
	* Check if item has errors
	*
	* @param Array $skip_fields fields to skip during error checking
	* @return bool
	*/
	function HasErrors($skip_fields)
	{
	$global_res = false;

	foreach ($this->Fields as $field => $field_params) {
	// If Formatter has set some error messages during values parsing
	if ( !( in_array($field, $skip_fields) ) &&
	isset($this->FieldErrors[$field]['pseudo']) && $this->FieldErrors[$field] != '') {
	$global_res = true;
	}
	}
	return $global_res;
	}

	/**
	* Check if value in field matches field type specified in config
	*
	* @param string $field field name
	* @param Array $params field options from config
	* @return bool
	*/
	function ValidateType($field, $params)
	{
	$res = true;
	$val = $this->FieldValues[$field];
	if ( $val != '' &&
	isset($params['type']) &&
	preg_match("#int\|integer\|double\|float\|real\|numeric\|string#", $params['type'])
	) {
	if ($params['type'] == 'numeric') {
	trigger_error('Invalid field type <strong>'.$params['type'].'</strong> (in ValidateType method), please use <strong>float</strong> instead', E_USER_NOTICE);
	$params['type'] = 'float';
	}
	$res = is_numeric($val);
	if ($params['type']=='string' \|\| $res) {
	$f = 'is_'.$params['type'];
	settype($val, $params['type']);
	$res = $f($val) && ($val == $this->FieldValues[$field]);
	}
	if (!$res) {
	$this->SetError($field, 'bad_type', null, $params['type']);
	}
	}
	return $res;
	}

	/**
	* Check if value is set for required field
	*
	* @param string $field field name
	* @param Array $params field options from config
	* @return bool
	* @access private
	*/
	function ValidateRequired($field, $params)
	{
	$res = true;
	if (isset($params['required']) && $params['required']) {
	$check_value = $this->FieldValues[$field];
	if ($this->Application->ConfigValue('TrimRequiredFields')) {
	$check_value = trim($check_value);
	}
	$res = ((string)$check_value != '');
	}

	if (!$res) {
	$this->SetError($field, 'required');
	}

	return $res;
	}

	/**
	* Validates that current record has unique field combination among other table records
	*
	* @param string $field field name
	* @param Array $params field options from config
	* @return bool
	* @access private
	*/
	function ValidateUnique($field, $params)
	{
	$res = true;
	$unique_fields = getArrayValue($params,'unique');
	if($unique_fields !== false)
	{
	$where = Array();
	array_push($unique_fields,$field);
	foreach($unique_fields as $unique_field)
	{
	// if field is not empty or if it is required - we add where condition
	if ((string)$this->GetDBField($unique_field) != '' \|\| (isset($this->Fields[$unique_field]['required']) && $this->Fields[$unique_field]['required'])) {
	$where[] = '`'.$unique_field.'` = '.$this->Conn->qstr( $this->GetDBField($unique_field) );
	}
	else {
	// not good if we check by less fields than indicated
	return true;
	}
	}
	// This can ONLY happen if all unique fields are empty and not required.
	// In such case we return true, because if unique field is not required there may be numerous empty values
	// if (!$where) return true;

	$sql = 'SELECT COUNT(*) FROM %s WHERE ('.implode(') AND (',$where).') AND ('.$this->IDField.' <> '.(int)$this->ID.')';

	$res_temp = $this->Conn->GetOne( str_replace('%s', $this->TableName, $sql) );

	$current_table_only = getArrayValue($params, 'current_table_only'); // check unique record only in current table
	$res_live = $current_table_only ? 0 : $this->Conn->GetOne( str_replace('%s', $this->Application->GetLiveName($this->TableName), $sql) );

	$res = ($res_temp == 0) && ($res_live == 0);

	if (!$res) {
	$this->SetError($field, 'unique');
	}
	}
	return $res;
	}

	/**
	* Check if field value is in range specified in config
	*
	* @param string $field field name
	* @param Array $params field options from config
	* @return bool
	* @access private
	*/
	function ValidateRange($field, $params)
	{
	$res = true;
	$val = $this->FieldValues[$field];

	if ( isset($params['type']) && preg_match("#int\|integer\|double\|float\|real#", $params['type']) && strlen($val) > 0 ) {
	if ( isset($params['max_value_inc'])) {
	$res = $res && $val <= $params['max_value_inc'];
	$max_val = $params['max_value_inc'].' (inclusive)';
	}
	if ( isset($params['min_value_inc'])) {
	$res = $res && $val >= $params['min_value_inc'];
	$min_val = $params['min_value_inc'].' (inclusive)';
	}
	if ( isset($params['max_value_exc'])) {
	$res = $res && $val < $params['max_value_exc'];
	$max_val = $params['max_value_exc'].' (exclusive)';
	}
	if ( isset($params['min_value_exc'])) {
	$res = $res && $val > $params['min_value_exc'];
	$min_val = $params['min_value_exc'].' (exclusive)';
	}
	}
	if (!$res) {
	if ( !isset($min_val) ) $min_val = '-∞';
	if ( !isset($max_val) ) $max_val = '∞';

	$this->SetError($field, 'value_out_of_range', null, Array ($min_val, $max_val));
	return $res;
	}
	if ( isset($params['max_len'])) {
	$res = $res && mb_strlen($val) <= $params['max_len'];
	}
	if ( isset($params['min_len'])) {
	$res = $res && mb_strlen($val) >= $params['min_len'];
	}
	if (!$res) {
	$error_params = Array (getArrayValue($params, 'min_len'), getArrayValue($params, 'max_len'));
	$this->SetError($field, 'length_out_of_range', null, $error_params);
	return $res;
	}
	return $res;
	}

	/**
	* Return error message for field
	*
	* @param string $field
	* @return string
	* @access public
	*/
	function GetErrorMsg($field, $force_escape = null)
	{
	if( !isset($this->FieldErrors[$field]) ) return '';

	$err = getArrayValue($this->FieldErrors[$field], 'pseudo');
	if (!$err) return '';
	// if special error msg defined in config
	if( isset($this->Fields[$field]['error_msgs'][$err]) )
	{
	$msg = $this->Fields[$field]['error_msgs'][$err];
	}
	else //fall back to defaults
	{
	if( !isset($this->ErrorMsgs[$err]) ) {
	trigger_error('No user message is defined for pseudo error <b>'.$err.'</b><br>', E_USER_WARNING);
	return $err; //return the pseudo itself
	}
	$msg = $this->ErrorMsgs[$err];
	}
	$msg = $this->Application->ReplaceLanguageTags($msg, $force_escape);

	if ( isset($this->FieldErrors[$field]['params']) )
	{
	return vsprintf($msg, $this->FieldErrors[$field]['params']);
	}
	return $msg;
	}

	/**
	* Creates a record in the database table with current item' values
	*
	* @param mixed $force_id Set to TRUE to force creating of item's own ID or to value to force creating of passed id. Do not pass 1 for true, pass exactly TRUE!
	* @access public
	* @return bool
	*/
	function Create($force_id = false, $system_create = false)
	{
	if (!$this->raiseEvent('OnBeforeItemCreate')) {
	return false;
	}

	// Validating fields before attempting to create record
	if (!$this->Validate()) {
	return false;
	}

	if (!$this->raiseEvent('OnAfterItemValidate')) {
	return false;
	}

	if (is_int($force_id)) {
	$this->FieldValues[$this->IDField] = $force_id;
	}
	elseif (!$force_id \|\| !is_bool($force_id)) {
	$this->FieldValues[$this->IDField] = $this->generateID();
	}

	$fields_sql = '';
	$values_sql = '';
	foreach ($this->FieldValues as $field_name => $field_value) {
	- if ($this->_skipField($field_name, $force_id)) {
	+ if ($this->skipField($field_name, $force_id)) {
	continue;
	}

	if (is_null($field_value)) {
	if (array_key_exists('not_null', $this->Fields[$field_name]) && $this->Fields[$field_name]['not_null']) {
	// "kFormatter::Parse" methods converts empty values to NULL and for
	// not-null fields they are replaced with default value here
	$values_sql .= $this->Conn->qstr($this->Fields[$field_name]['default']);
	}
	else {
	$values_sql .= $this->Conn->qstr($field_value);
	}
	}
	else {
	if (($field_name == $this->IDField) && ($field_value == 0)) {
	// don't skip IDField in INSERT statement, just use DEFAULT keyword as it's value
	$values_sql .= 'DEFAULT';
	}
	else {
	$values_sql .= $this->Conn->qstr($field_value);
	}
	}

	$fields_sql .= '`' . $field_name . '`, '; //Adding field name to fields block of Insert statement
	$values_sql .= ', ';
	}

	$sql = 'INSERT INTO ' . $this->TableName . ' (' . substr($fields_sql, 0, -2) . ')
	VALUES (' . substr($values_sql, 0, -2) . ')';

	//Executing the query and checking the result
	if ($this->Conn->ChangeQuery($sql) === false) {
	return false;
	}

	$insert_id = $this->Conn->getInsertID();
	if ($insert_id == 0) {
	// insert into temp table (id is not auto-increment field)
	$insert_id = $this->FieldValues[$this->IDField];
	}
	$this->setID($insert_id);

	if (!$system_create){
	$this->setModifiedFlag(clCREATE);
	}

	$this->saveCustomFields();
	if ($this->mode != 't') {
	$this->Application->resetCounters($this->TableName);
	}
	$this->raiseEvent('OnAfterItemCreate');
	$this->Loaded = true;

	return true;
	}

	/**
	* Deletes the record from databse
	*
	* @access public
	* @return bool
	*/
	function Delete($id = null)
	{
	if (isset($id)) {
	$this->setID($id);
	}

	if (!$this->raiseEvent('OnBeforeItemDelete')) {
	return false;
	}

	$sql = 'DELETE FROM ' . $this->TableName . '
	WHERE ' . $this->GetKeyClause('Delete');

	$ret = $this->Conn->ChangeQuery($sql);
	$affected_rows = $this->Conn->getAffectedRows();

	$this->setModifiedFlag(clDELETE); // will change affected rows, so get it before this line

	if ($affected_rows > 0) {
	// something was actually deleted
	$this->raiseEvent('OnAfterItemDelete');
	}

	if ($this->mode != 't') {
	$this->Application->resetCounters($this->TableName);
	}

	return $ret;
	}

	function PopulateMultiLangFields()
	{
	$ml_helper =& $this->Application->recallObject('kMultiLanguageHelper');
	/* @var $ml_helper kMultiLanguageHelper */

	$lang_count = $ml_helper->getLanguageCount();
	foreach ($this->Fields as $field => $options)
	{
	// master field is set only for CURRENT language
	if (isset($options['formatter']) && $options['formatter'] == 'kMultiLanguage' && isset($options['master_field'])) {
	if (preg_match('/^l([0-9]+)_(.*)/', $field, $regs)) {
	$l = $regs[1];
	$name = $regs[2];
	// MuliLanguage formatter sets error_field to master_field, but in PopulateMlFields mode, we display ML fields directly
	// so we set it back to itself, otherwise error will not be displayed
	$this->Fields['l' . $l . '_' . $name]['error_field'] = 'l' . $l . '_' . $name;
	for ($i = 1; $i <= $lang_count; $i++) {
	if ($i == $l \|\| !$ml_helper->LanguageFound($i)) continue;
	$f_options = $options;
	$f_options['error_field'] = 'l' . $i . '_' . $name; // set error field back to itself - see comment above
	if ($i != $this->Application->GetDefaultLanguageId()) {
	unset($f_options['required']); // all non-primary language field set to non-required
	}
	$this->Fields['l' . $i . '_' . $name] = $f_options;
	}
	}
	}
	}
	}

	/**
	* Sets new name for item in case if it is beeing copied
	* in same table
	*
	* @param array $master Table data from TempHandler
	* @param int $foreign_key ForeignKey value to filter name check query by
	* @param string $title_field FieldName to alter, by default - TitleField of the prefix
	* @param string $format sprintf-style format of renaming pattern, by default Copy %1$s of %2$s which makes it Copy [Number] of Original Name
	* @access private
	*/
	function NameCopy($master=null, $foreign_key=null, $title_field=null, $format='Copy %1$s of %2$s')
	{
	if (!isset($title_field)) {
	$title_field = $this->Application->getUnitOption($this->Prefix, 'TitleField');
	if (!$title_field \|\| isset($this->CalculatedFields[$title_field]) ) return;
	}

	$new_name = $this->GetDBField($title_field);
	$original_checked = false;
	do {
	if ( preg_match('/'.sprintf($format, '([0-9]) ', '(.*)').'/', $new_name, $regs) ) {
	$new_name = sprintf($format, ($regs[1]+1), $regs[2]);
	}
	elseif ($original_checked) {
	$new_name = sprintf($format, '', $new_name);
	}

	// if we are cloning in temp table this will look for names in temp table,
	// since object' TableName contains correct TableName (for temp also!)
	// if we are cloning live - look in live
	$query = 'SELECT '.$title_field.' FROM '.$this->TableName.'
	WHERE '.$title_field.' = '.$this->Conn->qstr($new_name);

	$foreign_key_field = getArrayValue($master, 'ForeignKey');
	$foreign_key_field = is_array($foreign_key_field) ? $foreign_key_field[ $master['ParentPrefix'] ] : $foreign_key_field;

	if ($foreign_key_field && isset($foreign_key)) {
	$query .= ' AND '.$foreign_key_field.' = '.$foreign_key;
	}

	$res = $this->Conn->GetOne($query);

	/*// if not found in live table, check in temp table if applicable
	if ($res === false && $object->Special == 'temp') {
	$query = 'SELECT '.$name_field.' FROM '.$this->GetTempName($master['TableName']).'
	WHERE '.$name_field.' = '.$this->Conn->qstr($new_name);
	$res = $this->Conn->GetOne($query);
	}*/

	$original_checked = true;
	} while ($res !== false);
	$this->SetDBField($title_field, $new_name);
	}

	function raiseEvent($name, $id = null, $additional_params = Array())
	{
	if( !isset($id) ) $id = $this->GetID();
	$event = new kEvent( Array('name'=>$name,'prefix'=>$this->Prefix,'special'=>$this->Special) );
	$event->setEventParam('id', $id);

	if ($additional_params) {
	foreach ($additional_params as $ap_name => $ap_value) {
	$event->setEventParam($ap_name, $ap_value);
	}
	}

	$this->Application->HandleEvent($event);
	return $event->status == erSUCCESS ? true : false;
	}

	/**
	* Set's new ID for item
	*
	* @param int $new_id
	* @access public
	*/
	function setID($new_id)
	{
	$this->ID = $new_id;
	$this->SetDBField($this->IDField, $new_id);
	}

	/**
	* Generate and set new temporary id
	*
	* @access private
	*/
	function setTempID()
	{
	$new_id = (int)$this->Conn->GetOne('SELECT MIN('.$this->IDField.') FROM '.$this->TableName);
	if($new_id > 0) $new_id = 0;
	--$new_id;

	$this->Conn->Query('UPDATE '.$this->TableName.' SET `'.$this->IDField.'` = '.$new_id.' WHERE `'.$this->IDField.'` = '.$this->GetID());

	if ($this->ShouldLogChanges()) {
	// Updating TempId in ChangesLog, if changes are disabled
	$ses_var_name = $this->Application->GetTopmostPrefix($this->Prefix).'_changes_'.$this->Application->GetTopmostWid($this->Prefix);
	$changes = $this->Application->RecallVar($ses_var_name);
	$changes = $changes ? unserialize($changes) : Array ();
	if ($changes) {
	foreach ($changes as $key => $rec) {
	if ($rec['Prefix'] == $this->Prefix && $rec['ItemId'] == $this->GetID()) {
	$changes[$key]['ItemId'] = $new_id;
	}
	}
	}
	$this->Application->StoreVar($ses_var_name, serialize($changes));
	}

	$this->SetID($new_id);
	}

	/**
	* Set's modification flag for main prefix of current prefix to true
	*
	* @access private
	* @author Alexey
	*/
	function setModifiedFlag($mode = null)
	{
	$main_prefix = $this->Application->GetTopmostPrefix($this->Prefix);
	$this->Application->StoreVar($main_prefix.'_modified', '1');

	if ($this->ShouldLogChanges()) {
	$this->LogChanges($main_prefix, $mode);
	if (!$this->IsTempTable()) {
	$handler =& $this->Application->recallObject($this->Prefix.'_EventHandler');
	$ses_var_name = $main_prefix.'_changes_'.$this->Application->GetTopmostWid($this->Prefix);
	$handler->SaveLoggedChanges($ses_var_name);
	}
	}
	}

	/**
	* Determines, that changes made to this item should be written to change log
	*
	* @return bool
	*/
	function ShouldLogChanges()
	{
	$log_changes = $this->Application->getUnitOption($this->Prefix, 'LogChanges') \|\| $this->Application->ConfigValue('UseChangeLog');

	return $log_changes && !$this->Application->getUnitOption($this->Prefix, 'ForceDontLogChanges');
	}

	function LogChanges($main_prefix, $mode)
	{
	if (!$mode) {
	return ;
	}

	$ses_var_name = $main_prefix.'_changes_'.$this->Application->GetTopmostWid($this->Prefix);
	$changes = $this->Application->RecallVar($ses_var_name);
	$changes = $changes ? unserialize($changes) : array();

	$general = array(
	'Prefix' => $this->Prefix,
	'ItemId' => $this->GetID(),
	'OccuredOn' => adodb_mktime(),
	'MasterPrefix' => $main_prefix,
	'MasterId' => $this->Prefix == $main_prefix ? $this->GetID() : $this->Application->GetVar($main_prefix.'_id'), // is that correct (Kostja)??
	'Action' => $mode,
	);
	switch ($mode) {
	case clUPDATE:
	$changes[] = array_merge($general, Array(
	'Changes' => serialize(array_merge($this->GetTitleField(), $this->GetChangedFields())),
	));
	break;
	case clCREATE:
	$changes[] = array_merge($general, Array(
	'Changes' => serialize($this->GetTitleField()),
	));
	break;
	case clDELETE:
	$changes[] = array_merge($general, Array(
	'Changes' => serialize(array_merge($this->GetTitleField(), $this->GetRealFields())),
	));
	}

	$this->Application->StoreVar($ses_var_name, serialize($changes));
	}

	function GetTitleField()
	{
	$title_field = $this->Application->getUnitOption($this->Prefix, 'TitleField');
	if ($title_field && $this->GetField($title_field)) {
	return Array($title_field => $this->GetField($title_field));
	}
	}

	function GetRealFields()
	{
	if (function_exists('array_diff_key')) {
	$db_fields = array_diff_key($this->FieldValues, $this->VirtualFields, $this->CalculatedFields);
	}
	else {
	$db_fields = array();
	foreach ($this->FieldValues as $key => $value) {
	if (array_key_exists($key, $this->VirtualFields) \|\| array_key_exists($key, $this->CalculatedFields)) continue;
	$db_fields[$key] = $value;
	}
	}
	return $db_fields;
	}

	function GetChangedFields()
	{
	$changes = array();

	$diff = array_diff_assoc($this->GetRealFields(), $this->OriginalFieldValues);
	foreach ($diff as $field => $new_value) {
	$changes[$field] = array('old' => $this->GetOriginalField($field, true), 'new' => $this->GetField($field));
	}
	return $changes;
	}

	/**
	* Returns ID of currently processed record
	*
	* @return int
	* @access public
	*/
	function GetID()
	{
	return $this->ID;
	}

	/**
	* Generates ID for new items before inserting into database
	*
	* @return int
	* @access private
	*/
	function generateID()
	{
	return 0;
	}

	/**
	* Returns true if item was loaded successfully by Load method
	*
	* @return bool
	*/
	function isLoaded()
	{
	return $this->Loaded;
	}

	/**
	* Checks if field is required
	*
	* @param string $field
	* @return bool
	*/
	function isRequired($field)
	{
	return getArrayValue( $this->Fields[$field], 'required' );
	}

	/**
	* Sets new required flag to field
	*
	* @param string $field
	* @param bool $is_required
	*/
	function setRequired($field, $is_required = true)
	{
	$this->Fields[$field]['required'] = $is_required;
	}

	function Clear($new_id = null)
	{
	$this->setID($new_id);
	$this->Loaded = false;
	$this->FieldValues = Array();
	$this->OriginalFieldValues = Array ();
	$this->SetDefaultValues();
	$this->FieldErrors = Array();
	return $this->Loaded;
	}

	function Query($force = false)
	{
	if( $this->Application->isDebugMode() )
	{
	$this->Application->Debugger->appendTrace();
	}
	trigger_error('<b>Query</b> method is called in class <b>'.get_class($this).'</b> for prefix <b>'.$this->getPrefixSpecial().'</b>', E_USER_ERROR);
	}

	function saveCustomFields()
	{
	if (!$this->customFields) {
	return true;
	}

	$cdata_key = rtrim($this->Prefix.'-cdata.'.$this->Special, '.');
	$cdata =& $this->Application->recallObject($cdata_key, null, Array('skip_autoload' => true, 'populate_ml_fields' => true));

	$resource_id = $this->GetDBField('ResourceId');
	$cdata->Load($resource_id, 'ResourceId');
	$cdata->SetDBField('ResourceId', $resource_id);

	$ml_formatter =& $this->Application->recallObject('kMultiLanguage');
	/* @var $ml_formatter kMultiLanguage */

	foreach ($this->customFields as $custom_id => $custom_name) {
	$force_primary = isset($cdata->Fields['cust_'.$custom_id]['force_primary']) && $cdata->Fields['cust_'.$custom_id]['force_primary'];
	$cdata->SetDBField($ml_formatter->LangFieldName('cust_'.$custom_id, $force_primary), $this->GetDBField('cust_'.$custom_name));
	}

	if ($cdata->isLoaded()) {
	$ret = $cdata->Update();
	}
	else {
	$ret = $cdata->Create();
	if ($cdata->mode == 't') $cdata->setTempID();
	}

	return $ret;
	}

	/**
	* Returns specified field value from all selected rows.
	* Don't affect current record index
	*
	* @param string $field
	* @return Array
	*/
	function GetCol($field)
	{
	return Array (0 => $this->GetDBField($field));
	}
	}



	?>
	\ No newline at end of file
	Index: branches/RC/core/units/general/cat_dbitem_export.php
	===================================================================
	--- branches/RC/core/units/general/cat_dbitem_export.php (revision 12005)
	+++ branches/RC/core/units/general/cat_dbitem_export.php (revision 12006)
	@@ -1,1444 +1,1444 @@
	<?php
	/**
	* @version $Id$
	* @package In-Portal
	* @copyright Copyright (C) 1997 - 2009 Intechnic. All rights reserved.
	* @license GNU/GPL
	* In-Portal is Open Source software.
	* This means that this software may have been modified pursuant
	* the GNU General Public License, and as distributed it includes
	* or is derivative of works licensed under the GNU General Public License
	* or other free or open source software licenses.
	* See http://www.in-portal.net/license/ for copyright notices and details.
	*/

	define('EXPORT_STEP', 100); // export by 200 items (e.g. links)
	define('IMPORT_STEP', 20); // export by 200 items (e.g. links)
	define('IMPORT_CHUNK', 10240); // 10240); //30720); //50120); // 5 KB

	define('IMPORT_TEMP', 1);
	define('IMPORT_LIVE', 2);

	class kCatDBItemExportHelper extends kHelper {

	var $false = false;

	var $cache = Array();

	/**
	* Allows to find out what items are new in cache
	*
	* @var Array
	*/
	var $cacheStatus = Array();

	var $cacheTable = '';

	var $exportFields = Array();

	/**
	* Export options
	*
	* @var Array
	*/
	var $exportOptions = Array();

	/**
	* Item beeing currenly exported
	*
	* @var kCatDBItem
	*/
	var $curItem = null;

	/**
	* Dummy category object
	*
	* @var CategoriesItem
	*/
	var $dummyCategory = null;

	/**
	* Pointer to opened file
	*
	* @var resource
	*/
	var $filePointer = null;

	/**
	* Custom fields definition of current item
	*
	* @var Array
	*/
	var $customFields = Array();

	function kCatDBItemExportHelper()
	{
	parent::kHelper();
	$this->cacheTable = TABLE_PREFIX.'ImportCache';
	}

	/**
	* Returns value from cache if found or false otherwise
	*
	* @param string $type
	* @param int $key
	* @return mixed
	*/
	function getFromCache($type, $key)
	{
	return getArrayValue($this->cache, $type, $key);
	}

	/**
	* Adds value to be cached
	*
	* @param string $type
	* @param int $key
	* @param mixed $value
	*/
	function addToCache($type, $key, $value, $is_new = true)
	{
	// if (!isset($this->cache[$type])) $this->cache[$type] = Array();
	$this->cache[$type][$key] = $value;
	if ($is_new) {
	$this->cacheStatus[$type][$key] = true;
	}
	}

	function storeCache($cache_types)
	{
	$cache_types = explode(',', $cache_types);

	$values_sql = '';
	foreach ($cache_types as $cache_type) {
	$sql_mask = '('.$this->Conn->qstr($cache_type).',%s,%s),';
	$cache = getArrayValue($this->cacheStatus, $cache_type);
	if (!$cache) $cache = Array();
	foreach ($cache as $var_name => $cache_status) {
	$var_value = $this->cache[$cache_type][$var_name];
	$values_sql .= sprintf($sql_mask, $this->Conn->qstr($var_name), $this->Conn->qstr($var_value) );
	}
	}
	$values_sql = preg_replace('/(.*),$/', '\\1', $values_sql);
	if ($values_sql) {
	$sql = 'INSERT INTO '.$this->cacheTable.'(`CacheName`,`VarName`,`VarValue`) VALUES '.$values_sql;
	$this->Conn->Query($sql);
	}

	}

	function loadCache()
	{
	$sql = 'SELECT * FROM '.$this->cacheTable;
	$records = $this->Conn->Query($sql);

	$this->cache = Array();
	foreach ($records as $record) {
	$this->addToCache($record['CacheName'], $record['VarName'], $record['VarValue'], false);
	}
	}

	/**
	* Fill required fields with dummy values
	*
	* @param kEvent $event
	*/
	function fillRequiredFields(&$event, &$object, $set_status = false)
	{
	if ($object == $this->false) {
	$object =& $event->getObject();
	}

	$has_empty = false;
	$fields = array_keys($object->Fields);
	foreach ($fields as $field_name)
	{
	$field_options =& $object->Fields[$field_name];
	if (isset($object->VirtualFields[$field_name]) \|\| !getArrayValue($field_options, 'required') ) continue;
	if ( $object->GetDBField($field_name) ) continue;

	$formatter_class = getArrayValue($field_options, 'formatter');
	if ($formatter_class) // not tested
	{
	$formatter =& $this->Application->recallObject($formatter_class);
	$sample_value = $formatter->GetSample($field_name, $field_options, $object);
	}

	$has_empty = true;
	$object->SetField($field_name, isset($sample_value) && $sample_value ? $sample_value : 'no value');
	}
	$object->UpdateFormattersSubFields();

	if ($set_status && $has_empty) {
	$object->SetDBField('Status', 0);
	}
	}

	/**
	* Verifies that all user entered export params are correct
	*
	* @param kEvent $event
	*/
	function verifyOptions(&$event)
	{
	if ($this->Application->RecallVar($event->getPrefixSpecial().'_ForceNotValid'))
	{
	$this->Application->StoreVar($event->getPrefixSpecial().'_ForceNotValid', 0);
	return false;
	}

	$this->fillRequiredFields($event, $this->false);

	$object =& $event->getObject();
	$cross_unique_fields = Array('FieldsSeparatedBy', 'FieldsEnclosedBy');
	if (($object->GetDBField('CategoryFormat') == 1) \|\| ($event->Special == 'import')) // in one field
	{
	$object->setRequired('CategorySeparator', true);
	$cross_unique_fields[] = 'CategorySeparator';
	}

	$ret = $object->Validate();

	// check if cross unique fields has no same values
	foreach ($cross_unique_fields as $field_index => $field_name)
	{
	if (getArrayValue($object->FieldErrors, $field_name, 'pseudo') == 'required') continue;

	$check_fields = $cross_unique_fields;
	unset($check_fields[$field_index]);

	foreach ($check_fields as $check_field)
	{
	if ($object->GetDBField($field_name) == $object->GetDBField($check_field))
	{
	$object->SetError($check_field, 'unique');
	}
	}
	}

	if ($event->Special == 'import')
	{
	$this->exportOptions = $this->loadOptions($event);

	$automatic_fields = ($object->GetDBField('FieldTitles') == 1);
	$object->setRequired('ExportColumns', !$automatic_fields);
	$category_prefix = '__CATEGORY__';
	if ( $automatic_fields && ($this->exportOptions['SkipFirstRow']) ) {
	$this->openFile($event);
	$this->exportOptions['ExportColumns'] = $this->readRecord();

	if (!$this->exportOptions['ExportColumns']) {
	$this->exportOptions['ExportColumns'] = Array ();
	}

	$this->closeFile();

	// remove additional (non-parseble columns)
	foreach ($this->exportOptions['ExportColumns'] as $field_index => $field_name) {
	if (!$this->validateField($field_name, $object)) {
	unset($this->exportOptions['ExportColumns'][$field_index]);
	}
	}
	$category_prefix = '';
	}

	// 1. check, that we have column definitions
	if (!$this->exportOptions['ExportColumns']) {
	$object->setError('ExportColumns', 'required');
	$ret = false;
	}
	else {
	// 1.1. check that all required fields are present in imported file
	$missing_columns = Array();
	foreach ($object->Fields as $field_name => $field_options) {
	- if ($object->SkipField($field_name)) continue;
	+ if ($object->skipField($field_name)) continue;
	if (getArrayValue($field_options, 'required') && !in_array($field_name, $this->exportOptions['ExportColumns']) ) {
	$missing_columns[] = $field_name;
	$object->setError('ExportColumns', 'required_fields_missing', 'la_error_RequiredColumnsMissing');
	$ret = false;
	}
	}

	if (!$ret && $this->Application->isDebugMode()) {
	$this->Application->Debugger->appendHTML('Missing required for import/export:');
	$this->Application->Debugger->dumpVars($missing_columns);
	}
	}


	// 2. check, that we have only mixed category field or only separated category fields
	$category_found['mixed'] = false;
	$category_found['separated'] = false;

	foreach ($this->exportOptions['ExportColumns'] as $import_field) {
	if (preg_match('/^'.$category_prefix.'Category(Path\|[0-9]+)/', $import_field, $rets)) {
	$category_found[$rets[1] == 'Path' ? 'mixed' : 'separated'] = true;
	}
	}
	if ($category_found['mixed'] && $category_found['separated']) {
	$object->SetError('ExportColumns', 'unique_category', 'la_error_unique_category_field');
	$ret = false;
	}

	// 3. check, that duplicates check fields are selected & present in imported fields
	if ($this->exportOptions['ReplaceDuplicates']) {
	if ($this->exportOptions['CheckDuplicatesMethod'] == 1) {
	$check_fields = Array($object->IDField);
	}
	else {
	$check_fields = $this->exportOptions['DuplicateCheckFields'] ? explode('\|', substr($this->exportOptions['DuplicateCheckFields'], 1, -1)) : Array();
	$object =& $event->getObject();

	$language_id = $this->Application->GetDefaultLanguageId();
	foreach ($check_fields as $index => $check_field) {
	foreach ($object->Fields as $field_name => $field_options) {
	if ($field_name == 'l'.$language_id.'_'.$check_field) {
	$check_fields[$index] = 'l'.$language_id.'_'.$check_field;
	break;
	}
	}
	}
	}
	$this->exportOptions['DuplicateCheckFields'] = $check_fields;

	if (!$check_fields) {
	$object->setError('CheckDuplicatesMethod', 'required');
	$ret = false;
	}
	else {
	foreach ($check_fields as $check_field) {
	$check_field = preg_replace('/^cust_(.*)/', 'Custom_\\1', $check_field);
	if (!in_array($check_field, $this->exportOptions['ExportColumns'])) {
	$object->setError('ExportColumns', 'required');
	$ret = false;
	break;
	}
	}
	}
	}
	$this->saveOptions($event);
	}

	return $ret;
	}

	/**
	* Returns filename to read import data from
	*
	* @return string
	*/
	function getImportFilename()
	{
	if ($this->exportOptions['ImportSource'] == 1)
	{
	$ret = $this->exportOptions['ImportFilename']; // ['name']; commented by Kostja
	}
	else {
	$ret = $this->exportOptions['ImportLocalFilename'];
	}
	return EXPORT_PATH.'/'.$ret;
	}

	/**
	* Returns filename to write export data to
	*
	* @return string
	*/
	function getExportFilename()
	{
	return EXPORT_PATH.'/'.$this->exportOptions['ExportFilename'].'.'.$this->getFileExtension();
	}

	/**
	* Opens file required for export/import operations
	*
	* @param kEvent $event
	*/
	function openFile(&$event)
	{
	if ($event->Special == 'export') {
	$write_mode = ($this->exportOptions['start_from'] == 0) ? 'w' : 'a';
	$this->filePointer = fopen($this->getExportFilename(), $write_mode);
	}
	else {
	$this->filePointer = fopen($this->getImportFilename(), 'r');
	}

	// skip UTF-8 BOM Modifier
	$first_chars = fread($this->filePointer, 3);
	if (bin2hex($first_chars) != 'efbbbf') {
	fseek($this->filePointer, 0);
	}
	}

	/**
	* Closes opened file
	*
	*/
	function closeFile()
	{
	fclose($this->filePointer);
	}

	function getCustomSQL()
	{
	$ml_formatter =& $this->Application->recallObject('kMultiLanguage');

	$custom_sql = '';
	foreach ($this->customFields as $custom_id => $custom_name) {
	$custom_sql .= 'custom_data.'.$ml_formatter->LangFieldName('cust_'.$custom_id).' AS cust_'.$custom_name.', ';
	}

	return preg_replace('/(.*), /', '\\1', $custom_sql);
	}

	function getPlainExportSQL($count_only = false) {
	if ($count_only && isset($this->exportOptions['ForceCountSQL'])) {
	$sql = $this->exportOptions['ForceCountSQL'];
	}
	elseif (!$count_only && isset($this->exportOptions['ForceSelectSQL'])) {
	$sql = $this->exportOptions['ForceSelectSQL'];
	}
	else {
	$items_list =& $this->Application->recallObject($this->curItem->Prefix.'.export-items-list', $this->curItem->Prefix.'_List');
	$items_list->SetPerPage(-1);

	if ($options['export_ids'] != '') {
	$items_list->AddFilter('export_ids', $items_list->TableName.'.'.$items_list->IDField.' IN ('.implode(',',$options['export_ids']).')');
	}

	if ($count_only) {
	$sql = $items_list->getCountSQL( $items_list->GetSelectSQL(true,false) );
	}
	else {
	$sql = $items_list->GetSelectSQL();
	}
	}

	if (!$count_only)
	{
	$sql .= ' LIMIT '.$this->exportOptions['start_from'].','.EXPORT_STEP;
	}
	// else {
	// $sql = preg_replace("/^.SELECT(.?)FROM(?!_)/is", "SELECT COUNT(*) AS count FROM ", $sql);
	// }

	return $sql;
	}

	function getExportSQL($count_only = false)
	{
	if (!$this->Application->getUnitOption($this->curItem->Prefix, 'CatalogItem')) {
	return $this->GetPlainExportSQL($count_only); // in case this is not a CategoryItem
	}

	if ($this->exportOptions['export_ids'] === false)
	{
	// get links from current category & all it's subcategories
	$join_clauses = Array();

	$custom_sql = $this->getCustomSQL();
	if ($custom_sql) {
	$custom_table = $this->Application->getUnitOption($this->curItem->Prefix.'-cdata', 'TableName');
	$join_clauses[$custom_table.' custom_data'] = 'custom_data.ResourceId = item_table.ResourceId';
	}

	$join_clauses[TABLE_PREFIX.'CategoryItems ci'] = 'ci.ItemResourceId = item_table.ResourceId';
	$join_clauses[TABLE_PREFIX.'Category c'] = 'c.CategoryId = ci.CategoryId';

	$sql = 'SELECT item_table.*, ci.CategoryId'.($custom_sql ? ', '.$custom_sql : '').'
	FROM '.$this->curItem->TableName.' item_table';

	foreach ($join_clauses as $table_name => $join_expression) {
	$sql .= ' LEFT JOIN '.$table_name.' ON '.$join_expression;
	}
	$sql .= ' WHERE ';

	if ($this->exportOptions['export_cats_ids'][0] == 0)
	{
	$sql .= '1';
	}
	else {
	foreach ($this->exportOptions['export_cats_ids'] as $category_id) {
	$sql .= '(c.ParentPath LIKE "%\|'.$category_id.'\|%") OR ';
	}
	$sql = preg_replace('/(.*) OR $/', '\\1', $sql);
	}

	$sql .= ' ORDER BY ci.PrimaryCat DESC'; // NEW
	}
	else {
	// get only selected links
	$sql = 'SELECT item_table.*, '.$this->exportOptions['export_cats_ids'][0].' AS CategoryId
	FROM '.$this->curItem->TableName.' item_table
	WHERE '.$this->curItem->IDField.' IN ('.implode(',', $this->exportOptions['export_ids']).')';
	}

	if (!$count_only)
	{
	$sql .= ' LIMIT '.$this->exportOptions['start_from'].','.EXPORT_STEP;
	}
	else {
	$sql = preg_replace("/^.SELECT(.?)FROM(?!_)/is", "SELECT COUNT(*) AS count FROM ", $sql);
	}

	return $sql;
	}

	/**
	* Enter description here...
	*
	* @param kEvent $event
	*/
	function performExport(&$event)
	{
	$this->exportOptions = $this->loadOptions($event);
	$this->exportFields = $this->exportOptions['ExportColumns'];
	$this->curItem =& $event->getObject( Array('skip_autoload' => true) );
	$this->customFields = $this->Application->getUnitOption($event->Prefix, 'CustomFields');
	$this->openFile($event);

	if ($this->exportOptions['start_from'] == 0) // first export step
	{
	if (!getArrayValue($this->exportOptions, 'IsBaseCategory')) {
	$this->exportOptions['IsBaseCategory'] = 0;
	}

	if ($this->exportOptions['IsBaseCategory'] ) {
	$sql = 'SELECT ParentPath
	FROM '.TABLE_PREFIX.'Category
	WHERE CategoryId = '.$this->Application->GetVar('m_cat_id');
	$parent_path = $this->Conn->GetOne($sql);
	$parent_path = explode('\|', substr($parent_path, 1, -1));
	if ($parent_path && $parent_path[0] == $this->Application->findModule('Name', 'Core', 'RootCat')) {
	array_shift($parent_path);
	}

	$this->exportOptions['BaseLevel'] = count($parent_path); // level to cut from other categories
	}

	// 1. export field titles if required
	if ($this->exportOptions['IncludeFieldTitles'])
	{
	$data_array = Array();
	foreach ($this->exportFields as $export_field)
	{
	$data_array = array_merge($data_array, $this->getFieldCaption($export_field));
	}
	$this->writeRecord($data_array);
	}
	$this->exportOptions['total_records'] = $this->Conn->GetOne( $this->getExportSQL(true) );
	}

	// 2. export data
	$records = $this->Conn->Query( $this->getExportSQL() );
	$records_exported = 0;
	foreach ($records as $record_info) {
	$this->curItem->Clear();
	$this->curItem->SetDBFieldsFromHash($record_info);
	$this->setCurrentID();
	$this->curItem->raiseEvent('OnAfterItemLoad', $this->curItem->GetID() );

	$data_array = Array();
	foreach ($this->exportFields as $export_field)
	{
	$data_array = array_merge($data_array, $this->getFieldValue($export_field) );
	}
	$this->writeRecord($data_array);
	$records_exported++;
	}
	$this->closeFile();

	$this->exportOptions['start_from'] += $records_exported;
	$this->saveOptions($event);

	return $this->exportOptions;
	}

	function getItemFields()
	{
	// just in case dummy user selected automtic mode & moved columns too :(
	return array_merge($this->curItem->Fields['AvailableColumns']['options'], $this->curItem->Fields['ExportColumns']['options']);
	}

	/**
	* Checks if field really belongs to importable field list
	*
	* @param string $field_name
	* @param kCatDBItem $object
	* @return bool
	*/
	function validateField($field_name, &$object)
	{
	// 1. convert custom field
	$field_name = preg_replace('/^Custom_(.*)/', '__CUSTOM__\\1', $field_name);

	// 2. convert category field (mixed version & serparated version)
	$field_name = preg_replace('/^Category(Path\|[0-9]+)/', '__CATEGORY__Category\\1', $field_name);

	$valid_fields = $object->getPossibleExportColumns();
	return isset($valid_fields[$field_name]) \|\| isset($valid_fields['__VIRTUAL__'.$field_name]);
	}

	/**
	* Enter description here...
	*
	* @param kEvent $event
	*/
	function performImport(&$event)
	{
	if (!$this->exportOptions) {
	// load import options in case if not previously loaded in verification function
	$this->exportOptions = $this->loadOptions($event);
	}

	$backup_category_id = $this->Application->GetVar('m_cat_id');
	$this->Application->SetVar('m_cat_id', (int)$this->Application->RecallVar('ImportCategory') );

	$this->openFile($event);

	$bytes_imported = 0;
	if ($this->exportOptions['start_from'] == 0) // first export step
	{
	// 1st time run
	if ($this->exportOptions['SkipFirstRow']) {
	$this->readRecord();
	$this->exportOptions['start_from'] = ftell($this->filePointer);
	$bytes_imported = ftell($this->filePointer);
	}

	$current_category_id = $this->Application->GetVar('m_cat_id');
	if ($current_category_id > 0) {
	$sql = 'SELECT ParentPath FROM '.TABLE_PREFIX.'Category WHERE CategoryId = '.$current_category_id;
	$this->exportOptions['ImportCategoryPath'] = $this->Conn->GetOne($sql);
	}
	else {
	$this->exportOptions['ImportCategoryPath'] = '';
	}
	$this->exportOptions['total_records'] = filesize($this->getImportFilename());
	}
	else {
	$this->loadCache();
	}

	$this->exportFields = $this->exportOptions['ExportColumns'];
	$this->addToCache('category_parent_path', $this->Application->GetVar('m_cat_id'), $this->exportOptions['ImportCategoryPath']);

	// 2. import data
	$this->dummyCategory =& $this->Application->recallObject('c.-tmpitem', 'c', Array('skip_autoload' => true));
	fseek($this->filePointer, $this->exportOptions['start_from']);

	$items_processed = 0;
	while (($bytes_imported < IMPORT_CHUNK && $items_processed < IMPORT_STEP) && !feof($this->filePointer)) {
	$data = $this->readRecord();
	if ($data) {
	if ($this->exportOptions['ReplaceDuplicates']) {
	// set fields used as keys for replace duplicates code
	$this->resetImportObject($event, IMPORT_TEMP, $data);
	}

	$this->processCurrentItem($event, $data);
	}
	$bytes_imported = ftell($this->filePointer) - $this->exportOptions['start_from'];
	$items_processed++;
	}

	$this->closeFile();
	$this->Application->SetVar('m_cat_id', $backup_category_id);

	$this->exportOptions['start_from'] += $bytes_imported;
	$this->storeCache('new_ids');

	$this->saveOptions($event);

	if ($this->exportOptions['start_from'] == $this->exportOptions['total_records']) {
	$this->Conn->Query('TRUNCATE TABLE '.$this->cacheTable);
	}

	return $this->exportOptions;
	}

	function setCurrentID()
	{
	$this->curItem->setID( $this->curItem->GetDBField($this->curItem->IDField) );
	}

	function setFieldValue($field_index, $value)
	{
	if (empty($value)) {
	$value = null;
	}

	$field_name = getArrayValue($this->exportFields, $field_index);
	if ($field_name == 'ResourceId') {
	return false;
	}

	if (substr($field_name, 0, 7) == 'Custom_') {
	$field_name = 'cust_'.substr($field_name, 7);
	$this->curItem->SetField($field_name, $value);
	}
	elseif ($field_name == 'CategoryPath' \|\| $field_name == '__CATEGORY__CategoryPath') {
	$this->curItem->CategoryPath = $value ? explode($this->exportOptions['CategorySeparator'], $value) : Array();
	}
	elseif (substr($field_name, 0, 8) == 'Category') {
	$this->curItem->CategoryPath[ (int)substr($field_name, 8) - 1 ] = $value;
	}
	elseif (substr($field_name, 0, 20) == '__CATEGORY__Category') {
	$this->curItem->CategoryPath[ (int)substr($field_name, 20) ] = $value;
	}
	elseif (substr($field_name, 0, 11) == '__VIRTUAL__') {
	$field_name = substr($field_name, 11);
	$this->curItem->SetField($field_name, $value);
	}
	else {
	$this->curItem->SetField($field_name, $value);
	}

	$pseudo_error = getArrayValue($this->curItem->FieldErrors, $field_name, 'pseudo');
	if ($pseudo_error) {
	$this->curItem->SetDBField($field_name, null);
	unset($this->curItem->FieldErrors[$field_name]);
	}
	}

	function resetImportObject(&$event, $object_type, $record_data = null)
	{
	switch ($object_type) {
	case IMPORT_TEMP:
	$this->curItem =& $event->getObject( Array('skip_autoload' => true) );
	break;

	case IMPORT_LIVE:
	$this->curItem =& $this->Application->recallObject($event->Prefix.'.-tmpitem'.$event->Special, $event->Prefix, Array('skip_autoload' => true));
	break;
	}
	$this->curItem->Clear();
	$this->customFields = $this->Application->getUnitOption($event->Prefix, 'CustomFields');

	if (isset($record_data)) {
	$this->setImportData($record_data);
	}
	}

	function setImportData($record_data)
	{
	foreach ($record_data as $field_index => $field_value) {
	$this->setFieldValue($field_index, $field_value);
	}
	$this->setCurrentID();
	}


	function getItemCategory()
	{
	static $lang_prefix = null;
	$backup_category_id = $this->Application->GetVar('m_cat_id');

	$category_id = $this->getFromCache('category_names', implode(':', $this->curItem->CategoryPath));
	if ($category_id) {
	$this->Application->SetVar('m_cat_id', $category_id);
	return $category_id;
	}

	if (is_null($lang_prefix)) {
	$lang_prefix = 'l'.$this->Application->GetVar('m_lang').'_';
	}

	foreach ($this->curItem->CategoryPath as $category_index => $category_name) {
	if (!$category_name) continue;
	$category_key = crc32( implode(':', array_slice($this->curItem->CategoryPath, 0, $category_index + 1) ) );

	$category_id = $this->getFromCache('category_names', $category_key);
	if ($category_id === false) {
	// get parent category path to search only in it
	$current_category_id = $this->Application->GetVar('m_cat_id');
	// $parent_path = $this->getParentPath($current_category_id);

	// get category id from database by name
	$sql = 'SELECT CategoryId
	FROM '.TABLE_PREFIX.'Category
	WHERE ('.$lang_prefix.'Name = '.$this->Conn->qstr($category_name).') AND (ParentId = '.$current_category_id.')';
	$category_id = $this->Conn->GetOne($sql);

	if ($category_id === false) {
	// category not in db -> create
	$category_fields = Array( $lang_prefix.'Name' => $category_name, $lang_prefix.'Description' => $category_name,
	'Status' => STATUS_ACTIVE, 'ParentId' => $current_category_id, 'AutomaticFilename' => 1
	);
	$this->dummyCategory->SetDBFieldsFromHash($category_fields);
	if ($this->dummyCategory->Create()) {
	$category_id = $this->dummyCategory->GetID();
	$this->addToCache('category_parent_path', $category_id, $this->dummyCategory->GetDBField('ParentPath'));
	$this->addToCache('category_names', $category_key, $category_id);
	}
	}
	else {
	$this->addToCache('category_names', $category_key, $category_id);
	}
	}

	if ($category_id) {
	$this->Application->SetVar('m_cat_id', $category_id);
	}
	}
	if (!$this->curItem->CategoryPath) {
	$category_id = $backup_category_id;
	}

	return $category_id;
	}

	/**
	* Enter description here...
	*
	* @param kEvent $event
	*/
	function processCurrentItem(&$event, $record_data)
	{
	$save_method = 'Create';
	$load_keys = Array();

	// create/update categories
	$backup_category_id = $this->Application->GetVar('m_cat_id');

	// perform replace duplicates code
	if ($this->exportOptions['ReplaceDuplicates']) {
	// get replace keys first, then reset current item to empty one
	$category_id = $this->getItemCategory();
	if ($this->exportOptions['CheckDuplicatesMethod'] == 1) {
	if ($this->curItem->GetID()) {
	$load_keys = Array($this->curItem->IDField => $this->curItem->GetID());
	}
	}
	else {
	$key_fields = $this->exportOptions['DuplicateCheckFields'];
	foreach ($key_fields as $key_field) {
	$load_keys[$key_field] = $this->curItem->GetDBField($key_field);
	}
	}

	$this->resetImportObject($event, IMPORT_LIVE);

	if (count($load_keys)) {
	$where_clause = '';
	foreach ($load_keys as $field_name => $field_value) {
	if (preg_match('/^cust_(.*)/', $field_name, $regs)) {
	$custom_id = array_search($regs[1], $this->customFields);
	$field_name = 'l'.$this->Application->GetVar('m_lang').'_cust_'.$custom_id;
	$where_clause .= '(custom_data.`'.$field_name.'` = '.$this->Conn->qstr($field_value).') AND ';
	}
	else {
	$where_clause .= '(item_table.`'.$field_name.'` = '.$this->Conn->qstr($field_value).') AND ';
	}

	}
	$where_clause = preg_replace('/(.*) AND $/', '\\1', $where_clause);

	$item_id = $this->getFromCache('new_ids', crc32($where_clause));
	if (!$item_id) {
	if ($this->exportOptions['CheckDuplicatesMethod'] == 2) {
	// by other fields
	$parent_path = $this->getParentPath($category_id);
	$where_clause = '(c.ParentPath LIKE "'.$parent_path.'%") AND '.$where_clause;
	}

	$cdata_table = $this->Application->getUnitOption($event->Prefix.'-cdata', 'TableName');
	$sql = 'SELECT '.$this->curItem->IDField.'
	FROM '.$this->curItem->TableName.' item_table
	LEFT JOIN '.$cdata_table.' custom_data ON custom_data.ResourceId = item_table.ResourceId
	LEFT JOIN '.TABLE_PREFIX.'CategoryItems ci ON ci.ItemResourceId = item_table.ResourceId
	LEFT JOIN '.TABLE_PREFIX.'Category c ON c.CategoryId = ci.CategoryId
	WHERE '.$where_clause;
	$item_id = $this->Conn->GetOne($sql);
	}
	$save_method = $item_id && $this->curItem->Load($item_id) ? 'Update' : 'Create';
	if ($save_method == 'Update') {
	// replace id from csv file with found id (only when ID is found in cvs file)
	if (in_array($this->curItem->IDField, $this->exportFields)) {
	$record_data[ array_search($this->curItem->IDField, $this->exportFields) ] = $item_id;
	}
	}
	}

	$this->setImportData($record_data);
	}
	else {
	$this->resetImportObject($event, IMPORT_LIVE, $record_data);
	$category_id = $this->getItemCategory();
	}

	// create main record
	if ($save_method == 'Create') {
	$this->fillRequiredFields($this->false, $this->curItem, true);
	}

	// $sql_start = getmicrotime();
	if (!$this->curItem->$save_method()) {
	$this->Application->SetVar('m_cat_id', $backup_category_id);
	return false;
	}
	// $sql_end = getmicrotime();
	// $this->saveLog('SQL ['.$save_method.'] Time: '.($sql_end - $sql_start).'s');

	if ($load_keys && ($save_method == 'Create') && $this->exportOptions['ReplaceDuplicates']) {
	// map new id to old id
	$this->addToCache('new_ids', crc32($where_clause), $this->curItem->GetID() );
	}

	// assign item to categories
	$this->curItem->assignToCategory($category_id, false);

	$this->Application->SetVar('m_cat_id', $backup_category_id);
	return true;
	}

	/*function saveLog($msg)
	{
	static $first_time = true;

	$fp = fopen(FULL_PATH.'/sqls.log', $first_time ? 'w' : 'a');
	fwrite($fp, $msg."\n");
	fclose($fp);

	$first_time = false;
	}*/

	/**
	* Returns category parent path, if possible, then from cache
	*
	* @param int $category_id
	* @return string
	*/
	function getParentPath($category_id)
	{
	$parent_path = $this->getFromCache('category_parent_path', $category_id);
	if ($parent_path === false) {
	$sql = 'SELECT ParentPath
	FROM '.TABLE_PREFIX.'Category
	WHERE CategoryId = '.$category_id;
	$parent_path = $this->Conn->GetOne($sql);
	$this->addToCache('category_parent_path', $category_id, $parent_path);
	}
	return $parent_path;
	}

	function getFileExtension()
	{
	return $this->exportOptions['ExportFormat'] == 1 ? 'csv' : 'xml';
	}

	function getLineSeparator($option = 'LineEndings')
	{
	return $this->exportOptions[$option] == 1 ? "\r\n" : "\n";
	}

	/**
	* Returns field caption for any exported field
	*
	* @param string $field
	* @return string
	*/
	function getFieldCaption($field)
	{
	if (substr($field, 0, 10) == '__CUSTOM__')
	{
	$ret = 'Custom_'.substr($field, 10, strlen($field) );
	}
	elseif (substr($field, 0, 12) == '__CATEGORY__')
	{
	return $this->getCategoryTitle();
	}
	elseif (substr($field, 0, 11) == '__VIRTUAL__') {
	$ret = substr($field, 11);
	}
	else
	{
	$ret = $field;
	}

	return Array($ret);
	}

	/**
	* Returns requested field value (including custom fields and category fields)
	*
	* @param string $field
	* @return string
	*/
	function getFieldValue($field)
	{
	if (substr($field, 0, 10) == '__CUSTOM__') {
	$field = 'cust_'.substr($field, 10, strlen($field));
	$ret = $this->curItem->GetField($field);
	}
	elseif (substr($field, 0, 12) == '__CATEGORY__') {
	return $this->getCategoryPath();
	}
	elseif (substr($field, 0, 11) == '__VIRTUAL__') {
	$field = substr($field, 11);
	$ret = $this->curItem->GetField($field);
	}
	else
	{
	$ret = $this->curItem->GetField($field);
	}

	$ret = str_replace("\r\n", $this->getLineSeparator('LineEndingsInside'), $ret);
	return Array($ret);
	}

	/**
	* Returns category field(-s) caption based on export mode
	*
	* @return string
	*/
	function getCategoryTitle()
	{
	// category path in separated fields
	$category_count = $this->getMaxCategoryLevel();
	if ($this->exportOptions['CategoryFormat'] == 1)
	{
	// category path in one field
	return $category_count ? Array('CategoryPath') : Array();
	}
	else
	{
	$i = 0;
	$ret = Array();
	while ($i < $category_count) {
	$ret[] = 'Category'.($i + 1);
	$i++;
	}
	return $ret;
	}
	}

	/**
	* Returns category path in required format for current link
	*
	* @return string
	*/
	function getCategoryPath()
	{
	$category_id = $this->curItem->GetDBField('CategoryId');
	$category_path = $this->getFromCache('category_path', $category_id);
	if (!$category_path)
	{
	$ml_formatter =& $this->Application->recallObject('kMultiLanguage');
	$sql = 'SELECT '.$ml_formatter->LangFieldName('CachedNavbar').'
	FROM '.TABLE_PREFIX.'Category
	WHERE CategoryId = '.$category_id;
	$category_path = $this->Conn->GetOne($sql);

	$category_path = $category_path ? explode('&\|&', $category_path) : Array();
	if ($category_path && strtolower($category_path[0]) == 'content') {
	array_shift($category_path);
	}

	if ($this->exportOptions['IsBaseCategory']) {
	$i = $this->exportOptions['BaseLevel'];
	while ($i > 0) {
	array_shift($category_path);
	$i--;
	}
	}

	$category_count = $this->getMaxCategoryLevel();
	if ($this->exportOptions['CategoryFormat'] == 1) {
	// category path in single field
	$category_path = $category_count ? Array( implode($this->exportOptions['CategorySeparator'], $category_path) ) : Array();
	}
	else {
	// category path in separated fields
	$levels_used = count($category_path);
	if ($levels_used < $category_count)
	{
	$i = 0;
	while ($i < $category_count - $levels_used) {
	$category_path[] = '';
	$i++;
	}
	}
	}
	$this->addToCache('category_path', $category_id, $category_path);
	}

	return $category_path;
	}

	/**
	* Get maximal category deep level from links beeing exported
	*
	* @return int
	*/
	function getMaxCategoryLevel()
	{
	static $max_level = -1;

	if ($max_level != -1)
	{
	return $max_level;
	}

	$sql = 'SELECT IF(c.CategoryId IS NULL, 0, MAX( LENGTH(c.ParentPath) - LENGTH( REPLACE(c.ParentPath, "\|", "") ) - 1 ))
	FROM '.$this->curItem->TableName.' item_table
	LEFT JOIN '.TABLE_PREFIX.'CategoryItems ci ON item_table.ResourceId = ci.ItemResourceId
	LEFT JOIN '.TABLE_PREFIX.'Category c ON c.CategoryId = ci.CategoryId
	WHERE (ci.PrimaryCat = 1) AND ';

	$where_clause = '';
	if ($this->exportOptions['export_ids'] === false) {
	// get links from current category & all it's subcategories
	if ($this->exportOptions['export_cats_ids'][0] == 0) {
	$where_clause = 1;
	}
	else {
	foreach ($this->exportOptions['export_cats_ids'] as $category_id) {
	$where_clause .= '(c.ParentPath LIKE "%\|'.$category_id.'\|%") OR ';
	}
	$where_clause = preg_replace('/(.*) OR $/', '\\1', $where_clause);
	}
	}
	else {
	// get only selected links
	$where_clause = $this->curItem->IDField.' IN ('.implode(',', $this->exportOptions['export_ids']).')';
	}

	$max_level = $this->Conn->GetOne($sql.'('.$where_clause.')');

	if ($this->exportOptions['IsBaseCategory'] ) {
	$max_level -= $this->exportOptions['BaseLevel'];
	}

	return $max_level;
	}

	/**
	* Saves one record to export file
	*
	* @param Array $fields_hash
	*/
	function writeRecord($fields_hash)
	{
	fputcsv2($this->filePointer, $fields_hash, $this->exportOptions['FieldsSeparatedBy'], $this->exportOptions['FieldsEnclosedBy'], $this->getLineSeparator() );
	}

	function readRecord()
	{
	return fgetcsv($this->filePointer, 10000, $this->exportOptions['FieldsSeparatedBy'], $this->exportOptions['FieldsEnclosedBy']);
	}

	function saveOptions(&$event, $options = null)
	{
	if (!isset($options)) {
	$options = $this->exportOptions;
	}
	$this->Application->StoreVar($event->getPrefixSpecial().'_options', serialize($options) );
	}

	function loadOptions(&$event)
	{
	return unserialize($this->Application->RecallVar($event->getPrefixSpecial().'_options'));
	}

	/**
	* Sets correct available & export fields
	*
	* @param kEvent $event
	*/
	function prepareExportColumns(&$event)
	{
	$object =& $event->getObject( Array('skip_autoload' => true) );

	if (!array_key_exists('ExportColumns', $object->Fields)) {
	// import/export prefix was used (see kDBEventHandler::prepareObject) but object don't plan to be imported/exported
	return ;
	}

	$available_columns = Array();

	if ($this->Application->getUnitOption($event->Prefix, 'CatalogItem')) {
	// category field (mixed)
	$available_columns['__CATEGORY__CategoryPath'] = 'CategoryPath';

	if ($event->Special == 'import') {
	// category field (separated fields)
	$max_level = $this->Application->ConfigValue('MaxImportCategoryLevels');
	$i = 0;
	while ($i < $max_level) {
	$available_columns['__CATEGORY__Category'.($i + 1)] = 'Category'.($i + 1);
	$i++;
	}
	}
	}

	// db fields
	foreach ($object->Fields as $field_name => $field_options)
	{
	- if (!$object->SkipField($field_name))
	+ if (!$object->skipField($field_name))
	{
	$available_columns[$field_name] = $field_name.(getArrayValue($field_options, 'required') ? '*' : '');
	}
	}

	$handler =& $this->Application->recallObject($event->Prefix.'_EventHandler');
	$available_columns = array_merge_recursive2($available_columns, $handler->getCustomExportColumns($event));

	// custom fields
	foreach ($object->customFields as $custom_id => $custom_name)
	{
	$available_columns['__CUSTOM__'.$custom_name] = $custom_name;
	}

	// columns already in use
	$items_info = $this->Application->GetVar( $event->getPrefixSpecial(true) );
	if ($items_info)
	{
	list($item_id, $field_values) = each($items_info);
	$export_keys = $field_values['ExportColumns'];
	$export_keys = $export_keys ? explode('\|', substr($export_keys, 1, -1) ) : Array();
	}
	else {
	$export_keys = Array();
	}

	$export_columns = Array();
	foreach ($export_keys as $field_key)
	{
	$field_name = $this->getExportField($field_key);
	$export_columns[$field_key] = $field_name;
	unset($available_columns[$field_key]);
	}

	$options = $object->GetFieldOptions('ExportColumns');
	$options['options'] = $export_columns;
	$object->SetFieldOptions('ExportColumns', $options);

	$options = $object->GetFieldOptions('AvailableColumns');
	$options['options'] = $available_columns;
	$object->SetFieldOptions('AvailableColumns', $options);

	$this->updateImportFiles($event);
	$this->PrepareExportPresets($event);
	}

	function PrepareExportPresets(&$event)
	{
	$object =& $event->getObject( Array('skip_autoload' => true) );
	$options = $object->GetFieldOptions('ExportPresets');

	$export_settings = $this->Application->RecallPersistentVar('export_settings');
	if (!$export_settings) return ;
	$export_settings = unserialize($export_settings);

	if (!isset($export_settings[$event->Prefix])) return ;


	$export_presets = array(''=>'');
	foreach ($export_settings[$event->Prefix] as $key => $val) {
	$export_presets[implode('\|', $val['ExportColumns'])] = $key;
	}

	$options['options'] = $export_presets;
	$object->SetFieldOptions('ExportPresets', $options);
	}

	function getExportField($field_key)
	{
	$prepends = Array('__CUSTOM__', '__CATEGORY__');
	foreach ($prepends as $prepend)
	{
	if (substr($field_key, 0, strlen($prepend) ) == $prepend)
	{
	$field_key = substr($field_key, strlen($prepend), strlen($field_key) );
	break;
	}
	}
	return $field_key;
	}

	/**
	* Updates uploaded files list
	*
	* @param kEvent $event
	*/
	function updateImportFiles(&$event)
	{
	if ($event->Special != 'import') {
	return false;
	}

	$object =& $event->getObject();

	$import_filenames = Array();

	if ($folder_handle = opendir(EXPORT_PATH)) {
	while (false !== ($file = readdir($folder_handle))) {
	if (is_dir(EXPORT_PATH.'/'.$file) \|\| substr($file, 0, 1) == '.' \|\| strtolower($file) == 'cvs' \|\| strtolower($file) == 'dummy' \|\| filesize(EXPORT_PATH.'/'.$file) == 0) continue;

	$file_size = formatSize( filesize(EXPORT_PATH.'/'.$file) );
	$import_filenames[$file] = $file.' ('.$file_size.')';
	}
	closedir($folder_handle);
	}

	$options = $object->GetFieldOptions('ImportLocalFilename');
	$options['options'] = $import_filenames;
	$object->SetFieldOptions('ImportLocalFilename', $options);
	}

	/**
	* Returns module folder
	*
	* @param kEvent $event
	* @return string
	*/
	function getModuleFolder(&$event)
	{
	return $this->Application->getUnitOption($event->Prefix, 'ModuleFolder');
	}

	/**
	* Export form validation & processing
	*
	* @param kEvent $event
	*/
	function OnExportBegin(&$event)
	{
	$items_info = $this->Application->GetVar( $event->getPrefixSpecial(true) );
	if (!$items_info)
	{
	$items_info = unserialize( $this->Application->RecallVar($event->getPrefixSpecial().'_ItemsInfo') );
	$this->Application->SetVar($event->getPrefixSpecial(true), $items_info);
	}

	list($item_id, $field_values) = each($items_info);

	$object =& $event->getObject( Array('skip_autoload' => true) );
	$object->SetFieldsFromHash($field_values);
	$field_values['ImportFilename'] = $object->GetDBField('ImportFilename'); //if upload formatter has renamed the file during moving !!!

	$object->setID($item_id);
	$this->setRequiredFields($event);

	$export_object =& $this->Application->recallObject('CatItemExportHelper');

	// save export/import options
	if ($event->Special == 'export')
	{
	$export_ids = $this->Application->RecallVar($event->Prefix.'_export_ids');
	$export_cats_ids = $this->Application->RecallVar($event->Prefix.'_export_cats_ids');

	// used for multistep export
	$field_values['export_ids'] = $export_ids ? explode(',', $export_ids) : false;
	$field_values['export_cats_ids'] = $export_cats_ids ? explode(',', $export_cats_ids) : Array( $this->Application->GetVar('m_cat_id') );
	}

	$field_values['ExportColumns'] = $field_values['ExportColumns'] ? explode('\|', substr($field_values['ExportColumns'], 1, -1) ) : Array();
	$field_values['start_from'] = 0;

	$this->Application->HandleEvent($nevent, $event->Prefix.':OnBeforeExportBegin', array('options'=>$field_values));
	$field_values = $nevent->getEventParam('options');

	$export_object->saveOptions($event, $field_values);

	if( $export_object->verifyOptions($event) )
	{
	if ($this->_getExportSavePreset($object)) {
	$name = $object->GetDBField('ExportPresetName');

	$export_settings = $this->Application->RecallPersistentVar('export_settings');
	$export_settings = $export_settings ? unserialize($export_settings) : array();
	$export_settings[$event->Prefix][$name] = $field_values;
	$this->Application->StorePersistentVar('export_settings', serialize($export_settings));
	}

	$progress_t = $this->Application->RecallVar('export_progress_t');
	if ($progress_t) {
	$this->Application->RemoveVar('export_progress_t');
	}
	else {
	$progress_t = $export_object->getModuleFolder($event).'/'.$event->Special.'_progress';
	}
	$event->redirect = $progress_t;

	if ($event->Special == 'import') {
	$import_category = (int)$this->Application->RecallVar('ImportCategory');

	// in future could use module root category if import category will be unavailable :)
	$event->SetRedirectParam('m_cat_id', $import_category); // for template permission checking
	$this->Application->StoreVar('m_cat_id', $import_category); // for event permission checking
	}
	}
	else
	{
	// make uploaded file local & change source selection
	$filename = getArrayValue($field_values, 'ImportFilename');
	if ($filename) {
	$export_object->updateImportFiles($event);
	$object->SetDBField('ImportSource', 2);
	$field_values['ImportSource'] = 2;
	$object->SetDBField('ImportLocalFilename', $filename);
	$field_values['ImportLocalFilename'] = $filename;
	$export_object->saveOptions($event, $field_values);
	}

	$event->status = erFAIL;
	$event->redirect = false;
	}
	}

	/**
	* Returns export save preset name, when used at all
	*
	* @param kDBItem $object
	* @return string
	*/
	function _getExportSavePreset(&$object)
	{
	if (!array_key_exists('ExportSavePreset', $object->Fields)) {
	return '';
	}

	return $object->GetDBField('ExportSavePreset');
	}

	/**
	* set required fields based on import or export params
	*
	* @param kEvent $event
	*/
	function setRequiredFields(&$event)
	{
	$required_fields['common'] = Array('FieldsSeparatedBy', 'LineEndings', 'CategoryFormat');

	$required_fields['export'] = Array('ExportFormat', 'ExportFilename','ExportColumns');

	$object =& $event->getObject();
	if ($this->_getExportSavePreset($object)) {
	$required_fields['export'][] = 'ExportPresetName';
	}

	$required_fields['import'] = Array('FieldTitles', 'ImportSource', 'CheckDuplicatesMethod'); // ImportFilename, ImportLocalFilename

	if ($event->Special == 'import')
	{
	$import_source = Array(1 => 'ImportFilename', 2 => 'ImportLocalFilename');
	$used_field = $import_source[ $object->GetDBField('ImportSource') ];

	$required_fields[$event->Special][] = $used_field;
	$object->Fields[$used_field]['error_field'] = 'ImportSource';

	if ($object->GetDBField('FieldTitles') == 2) $required_fields[$event->Special][] = 'ExportColumns'; // manual field titles
	}

	$required_fields = array_merge($required_fields['common'], $required_fields[$event->Special]);
	foreach ($required_fields as $required_field) {
	$object->setRequired($required_field, true);
	}
	}

	}

	?>

in-portalNo OneTemporaryActions

File Metadata

in-portalView Options

Event Timeline

in-portal
No OneTemporary
Actions

in-portal
View Options