EGroupware / egroupware

importexport/inc/class.importexport_import_csv.inc.php

Spacing +82 added lines, -82 removed lines

@@ -83,10 +83,10 @@ 
 	 * @param string $_resource resource containing data. May be each valid php-stream
 	 * @param array $_options options for the resource array with keys: charset and fieldsep
 	 */
-	public function __construct( $_resource,  array $_options ) {
+	public function __construct($_resource, array $_options) {
 		$this->resource = $_resource;
 		$this->csv_fieldsep = $_options['fieldsep'];
-		if($_options['charset'] == 'user') $_options['charset'] = $GLOBALS['egw_info']['user']['preferences']['common']['csv_charset'];
+		if ($_options['charset'] == 'user') $_options['charset'] = $GLOBALS['egw_info']['user']['preferences']['common']['csv_charset'];
 		$this->csv_charset = $_options['charset'];
 		return;
 	} // end of member function __construct
@@ -103,20 +103,20 @@ 
 	 * @param mixed _position may be: {current|first|last|next|previous|somenumber}
 	 * @return mixed array with data / false if no furtor records
 	 */
-	public function get_record( $_position = 'next' ) {
+	public function get_record($_position = 'next') {
 		
-		if ($this->get_raw_record( $_position ) === false) {
+		if ($this->get_raw_record($_position) === false) {
 			return false;
 		}
 		
 		// skip empty records
-		if( count( array_unique( $this->record ) ) < 2 ) return $this->get_record( $_position );
+		if (count(array_unique($this->record)) < 2) return $this->get_record($_position);
 		
-		if ( !empty( $this->conversion ) ) {
+		if (!empty($this->conversion)) {
 			$this->do_conversions();
 		}
 		
-		if ( !empty( $this->mapping ) ) {
+		if (!empty($this->mapping)) {
 			$this->do_fieldmapping();
 		}
 		
@@ -128,9 +128,9 @@ 
 	 *
 	 * @param int $_numToSkip
 	 */
-	public function skip_records( $_numToSkip ) {
-		while ( (int)$_numToSkip-- !== 0 ) {
-			fgetcsv( $this->resource, self::csv_max_linelength, $this->csv_fieldsep);
+	public function skip_records($_numToSkip) {
+		while ((int)$_numToSkip-- !== 0) {
+			fgetcsv($this->resource, self::csv_max_linelength, $this->csv_fieldsep);
 		}
 	}
 	
@@ -140,7 +140,7 @@ 
 	 * @param mixed $_position
 	 * @return bool
 	 */
-	private function get_raw_record( $_position = 'next' ) {
+	private function get_raw_record($_position = 'next') {
 		switch ($_position) {
 			case 'current' :
 				if ($this->current_position == 0) {
@@ -154,7 +154,7 @@ 
 				}
 				
 			case 'next' :
-				$csv_data = fgetcsv( $this->resource, self::csv_max_linelength, $this->csv_fieldsep);
+				$csv_data = fgetcsv($this->resource, self::csv_max_linelength, $this->csv_fieldsep);
 				if (!is_array($csv_data)) {
 					return false;
 				}
@@ -235,7 +235,7 @@ 
 		$this->record = array();
 		foreach ($this->mapping as $cvs_idx => $new_idx)
 		{
-			if( $new_idx == '' ) continue;
+			if ($new_idx == '') continue;
 			$this->record[$new_idx] = $record[$cvs_idx];
 		}
 		return true;
@@ -247,7 +247,7 @@ 
 	 * @return bool
 	 */
 	protected function do_conversions() {
-		if ( $record = importexport_helper_functions::conversion( $this->record, $this->conversion, $this->conversion_class )) {
+		if ($record = importexport_helper_functions::conversion($this->record, $this->conversion, $this->conversion_class)) {
 			$this->record = $record;
 			return;
 		}
@@ -264,25 +264,25 @@ 
 	 *
 	 * @return string warnings, if any
 	 */
-	public static function convert(Array &$record, Array $fields = array(), $appname = null, Array $selects = array(), $format=0) {
+	public static function convert(Array &$record, Array $fields = array(), $appname = null, Array $selects = array(), $format = 0) {
 		$warnings = array();
 
 		// Automatic conversions
-		if($appname) {
+		if ($appname) {
 
 			// Load translations
 			Api\Translation::add_app($appname);
 
-			if(!self::$cf_parse_cache[$appname]) {
+			if (!self::$cf_parse_cache[$appname]) {
 				$c_fields = importexport_export_csv::convert_parse_custom_fields($appname, $selects, $links, $methods);
 				self::$cf_parse_cache[$appname] = array($c_fields, $selects, $links, $methods);
 			}
 			list($c_fields, $c_selects, $links, $methods) = self::$cf_parse_cache[$appname];
 
 			// Add in any fields that are keys to another app
-			foreach((array)$fields['links'] as $link_field => $app)
+			foreach ((array)$fields['links'] as $link_field => $app)
 			{
-				if(is_numeric($link_field)) continue;
+				if (is_numeric($link_field)) continue;
 				$links[$link_field] = $app;
 				// Set it as a normal link field
 				$fields['links'][] = $link_field;
@@ -290,9 +290,9 @@ 
 			}
 
 			// Not quite a recursive merge, since only one level
-			foreach($fields as $type => &$list)
+			foreach ($fields as $type => &$list)
 			{
-				if($c_fields[$type]) {
+				if ($c_fields[$type]) {
 					$list = array_merge($c_fields[$type], $list);
 					unset($c_fields[$type]);
 				}
@@ -300,26 +300,26 @@ 
 			$fields += $c_fields;
 			$selects += $c_selects;
 		}
-		if($fields) {
-			foreach((array)$fields['select'] as $name) {
+		if ($fields) {
+			foreach ((array)$fields['select'] as $name) {
 				$record[$name] = static::find_select_key($record[$name], $selects[$name]);
 			}
 			
-			foreach((array)$fields['links'] as $name) {
-				if($record[$name] && $links[$name])
+			foreach ((array)$fields['links'] as $name) {
+				if ($record[$name] && $links[$name])
 				{
 					// Primary key to another app, not a link
 					// Text - search for a matching record
-					if(!is_numeric($record[$name]))
+					if (!is_numeric($record[$name]))
 					{
 						$results = Link::query($links[$name], $record[$name]);
-						if(count($results) >= 1)
+						if (count($results) >= 1)
 						{
 							// More than 1 result.  Check for exact match
 							$exact_count = 0;
-							foreach($results as $id => $title)
+							foreach ($results as $id => $title)
 							{
-								if($title == $record[$name])
+								if ($title == $record[$name])
 								{
 									$exact_count++;
 									$app_id = $id;
@@ -328,11 +328,11 @@ 
 								unset($results[$id]);
 							}
 							// Too many exact matches, or none good enough
-							if($exact_count > 1 || count($results) == 0)
+							if ($exact_count > 1 || count($results) == 0)
 							{
 								$warnings[] = lang('Unable to link to %1 "%2"',
 									lang($links[$name]), $record[$name]).
- 									' - ' .lang('too many matches');
+ 									' - '.lang('too many matches');
 								continue;
 							}
 							elseif ($exact_count == 1)
@@ -345,7 +345,7 @@ 
 						{
 							$warnings[] = lang('Unable to link to %1 "%2"',
 								lang($links[$name]), $record[$name]).
- 								' - ' . lang('no matches');
+ 								' - '.lang('no matches');
 							continue;
 						} else {
 							$record[$name] = key($results);
@@ -353,17 +353,17 @@ 
 					}
 				}
 			}
-			foreach((array)$fields['select-account'] as $name) {
+			foreach ((array)$fields['select-account'] as $name) {
 				// Compare against null to deal with empty arrays
 				if ($record[$name]) {
 					// Automatically handle text owner without explicit translation
 					$new_owner = importexport_helper_functions::account_name2id($record[$name]);
-					if(count($new_owner) != count(explode(',',$record[$name])))
+					if (count($new_owner) != count(explode(',', $record[$name])))
 					{
 						// Unable to parse value into account
-						$warnings[] = $name . ': ' .lang('%1 is not a known user or group', $record[$name]);
+						$warnings[] = $name.': '.lang('%1 is not a known user or group', $record[$name]);
 					}
-					if($new_owner != '') {
+					if ($new_owner != '') {
 						$record[$name] = $new_owner;
 					} else {
 						// Clear it to prevent trouble later on
@@ -371,24 +371,24 @@ 
 					}
 				}
 			}
-			foreach((array)$fields['select-bool'] as $name) {
-				if($record[$name] != null && $record[$name] != '') {
+			foreach ((array)$fields['select-bool'] as $name) {
+				if ($record[$name] != null && $record[$name] != '') {
 					$record[$name] = ($record[$name] == lang('Yes') || $record[$name] == '1' ? 1 : 0);
 				}
 			}
-			foreach((array)$fields['date-time'] as $name) {
+			foreach ((array)$fields['date-time'] as $name) {
 				if (isset($record[$name]) && !is_numeric($record[$name]) && strlen(trim($record[$name])) > 0)
 				{
 					// Need to handle format first
-					if($format == 1)
+					if ($format == 1)
 					{
 						$formatted = Api\DateTime::createFromFormat(
-							'!'.Api\DateTime::$user_dateformat . ' ' .Api\DateTime::$user_timeformat,
+							'!'.Api\DateTime::$user_dateformat.' '.Api\DateTime::$user_timeformat,
 							$record[$name],
 							Api\DateTime::$user_timezone
 						);
 
-						if(!$formatted && $errors = Api\DateTime::getLastErrors())
+						if (!$formatted && $errors = Api\DateTime::getLastErrors())
 						{
 							// Try again, without time
 							$formatted = Api\DateTime::createFromFormat(
@@ -397,70 +397,70 @@ 
 								Api\DateTime::$user_timezone
 							);
 							
-							if(!$formatted && $errors = Api\DateTime::getLastErrors())
+							if (!$formatted && $errors = Api\DateTime::getLastErrors())
 							{
 								// Try again, anything goes
 								try {
 									$formatted = new Api\DateTime($record[$name]);
 								} catch (Exception $e) {
-									$warnings[] = $name.': ' . $e->getMessage() . "\n" .
-										'Format: '.'!'.Api\DateTime::$user_dateformat . ' ' .Api\DateTime::$user_timeformat;
+									$warnings[] = $name.': '.$e->getMessage()."\n".
+										'Format: '.'!'.Api\DateTime::$user_dateformat.' '.Api\DateTime::$user_timeformat;
 									continue;
 								}
 								$errors = Api\DateTime::getLastErrors();
-								foreach($errors['errors'] as $char => $msg)
+								foreach ($errors['errors'] as $char => $msg)
 								{
 									$warnings[] = "$name: [$char] $msg\n".
-										'Format: '.'!'.Api\DateTime::$user_dateformat . ' ' .Api\DateTime::$user_timeformat;
+										'Format: '.'!'.Api\DateTime::$user_dateformat.' '.Api\DateTime::$user_timeformat;
 								}
 							}
 						}
-						if($formatted)
+						if ($formatted)
 						{
 							$record[$name] = $formatted->getTimestamp();
 							// Timestamp is apparently in server time, but apps will do the same conversion
-							$record[$name] = Api\DateTime::server2user($record[$name],'ts');
+							$record[$name] = Api\DateTime::server2user($record[$name], 'ts');
 						}
 					}
 					
-					if(is_array(self::$cf_parse_cache[$appname][0]['date-time']) &&
+					if (is_array(self::$cf_parse_cache[$appname][0]['date-time']) &&
 							in_array($name, self::$cf_parse_cache[$appname][0]['date-time'])) {
 						// Custom fields stored in a particular format (from customfields_widget)
 						$record[$name] = date('Y-m-d H:i:s', $record[$name]);
 					}
 				}
-				if(array_key_exists($name, $record) && strlen(trim($record[$name])) == 0)
+				if (array_key_exists($name, $record) && strlen(trim($record[$name])) == 0)
 				{
 					$record[$name] = null;
 				}
 			}
-			foreach((array)$fields['date'] as $name) {
+			foreach ((array)$fields['date'] as $name) {
 				if (isset($record[$name]) && !is_numeric($record[$name]) && strlen(trim($record[$name])) > 0)
 				{
 					// Need to handle format first
-					if($format == 1)
+					if ($format == 1)
 					{
 						$formatted = Api\DateTime::createFromFormat('!'.Api\DateTime::$user_dateformat, $record[$name]);
-						if($formatted && $errors = Api\DateTime::getLastErrors() && $errors['error_count'] == 0)
+						if ($formatted && $errors = Api\DateTime::getLastErrors() && $errors['error_count'] == 0)
 						{
 							$record[$name] = $formatted->getTimestamp();
 						}
 					}
-					$record[$name] = Api\DateTime::server2user($record[$name],'ts');
-					if(is_array(self::$cf_parse_cache[$appname][0]['date']) &&
+					$record[$name] = Api\DateTime::server2user($record[$name], 'ts');
+					if (is_array(self::$cf_parse_cache[$appname][0]['date']) &&
 							in_array($name, self::$cf_parse_cache[$appname][0]['date'])) {
 						// Custom fields stored in a particular format (from customfields_widget)
 						$record[$name] = date('Y-m-d', $record[$name]);
 					}
 				}
-				if(array_key_exists($name, $record) && strlen(trim($record[$name])) == 0)
+				if (array_key_exists($name, $record) && strlen(trim($record[$name])) == 0)
 				{
 					$record[$name] = null;
 				}
 			}
-			foreach((array)$fields['float'] as $name)
+			foreach ((array)$fields['float'] as $name)
 			{
-				if($record[$name] != null && $record[$name] != '') {
+				if ($record[$name] != null && $record[$name] != '') {
 					$dec_point = $GLOBALS['egw_info']['user']['preferences']['common']['number_format'][0];
 					if (empty($dec_point)) $dec_point = '.';
 					$record[$name] = floatval(str_replace($dec_point, '.', preg_replace('/[^\d'.preg_quote($dec_point).']/', '', $record[$name])));
@@ -468,23 +468,23 @@ 
 			}
 
 			// Some custom methods for conversion
-			foreach((array)$methods as $name => $method) {
-				if($record[$name]) $record[$name] = ExecMethod($method, $record[$name]);
+			foreach ((array)$methods as $name => $method) {
+				if ($record[$name]) $record[$name] = ExecMethod($method, $record[$name]);
 			}
 
 			// cat_name2id will use currentapp to create new categories
 			$current_app = $GLOBALS['egw_info']['flags']['currentapp'];
-			if($appname) {
+			if ($appname) {
 				$GLOBALS['egw_info']['flags']['currentapp'] = $appname;
 			}
-			$categories = new Api\Categories('',$appname);
-			foreach((array)$fields['select-cat'] as $name) {
-				if($record[$name]) {
+			$categories = new Api\Categories('', $appname);
+			foreach ((array)$fields['select-cat'] as $name) {
+				if ($record[$name]) {
 					// Only parse name if it needs it
-					if($format == 1)
+					if ($format == 1)
 					{
-						$existing_cat = $categories->exists('all',$record[$name]);
-						if($existing_cat)
+						$existing_cat = $categories->exists('all', $record[$name]);
+						if ($existing_cat)
 						{
 							$cat_id = $existing_cat;
 						}
@@ -493,14 +493,14 @@ 
 							$cat_id = importexport_helper_functions::cat_name2id($record[$name]);
 						}
 						// Don't clear it if it wasn't found
-						if($cat_id) $record[$name] = $cat_id;
+						if ($cat_id) $record[$name] = $cat_id;
 					}
 				}
 			}
 			$GLOBALS['egw_info']['flags']['currentapp'] = $current_app;
 		}
 
-		return implode("\n",$warnings);
+		return implode("\n", $warnings);
 	}
 
 	/**
@@ -514,36 +514,36 @@ 
 	 */
 	protected static function find_select_key($record_value, $selects)
 	{
-		if($record_value != null && is_array($selects)) {
-			if(is_array($record_value) || is_string($record_value) && strpos($record_value, ',') !== FALSE)
+		if ($record_value != null && is_array($selects)) {
+			if (is_array($record_value) || is_string($record_value) && strpos($record_value, ',') !== FALSE)
 			{
 				// Array, or CSV
 				$key = array();
-				$subs = explode(',',$record_value);
-				for($sub_index = 0; $sub_index < count($subs); $sub_index++)
+				$subs = explode(',', $record_value);
+				for ($sub_index = 0; $sub_index < count($subs); $sub_index++)
 				{
 					$sub_key = static::find_select_key(trim($subs[$sub_index]), $selects);
-					if(!$sub_key)
+					if (!$sub_key)
 					{
-						$sub_key = static::find_select_key(trim($subs[$sub_index]).','.trim($subs[$sub_index+1]), $selects);
-						if($sub_key) $sub_index++;
+						$sub_key = static::find_select_key(trim($subs[$sub_index]).','.trim($subs[$sub_index + 1]), $selects);
+						if ($sub_key) $sub_index++;
 					}
-					if($sub_key)
+					if ($sub_key)
 					{
 						$key[] = $sub_key;
 					}
 				}
 				return $key;
 			}
-			$key = array_search(strtolower($record_value), array_map('strtolower',$selects));
-			if($key !== false)
+			$key = array_search(strtolower($record_value), array_map('strtolower', $selects));
+			if ($key !== false)
 			{
 				$record_value = $key;
 			}
 			else
 			{
-				$key = array_search(strtolower($record_value), array_map('strtolower',array_map('lang',$selects)));
-				if($key !== false) $record_value = $key;
+				$key = array_search(strtolower($record_value), array_map('strtolower', array_map('lang', $selects)));
+				if ($key !== false) $record_value = $key;
 			}
 		}