EGroupware / egroupware

importexport/inc/class.importexport_import_csv.inc.php

Braces +147 added lines, -62 removed lines

@@ -22,7 +22,9 @@ 
  * @todo Throw away spechial chars and trim() entries ?
  * @todo Check for XSS like userinput! (see common_functions)
  */
-class importexport_import_csv implements importexport_iface_import_record { //, Iterator {
+class importexport_import_csv implements importexport_iface_import_record
+{
+//, Iterator {
 
 	const csv_max_linelength = 8000;
 	
@@ -83,10 +85,14 @@ 
 	 * @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
@@ -94,7 +100,8 @@ 
 	/**
 	 * cleanup
 	 */
-	public function __destruct( ) {
+	public function __destruct( )
+	{
 	} // end of member function __destruct
 
 	/**
@@ -103,20 +110,27 @@ 
 	 * @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,8 +142,10 @@ 
 	 *
 	 * @param int $_numToSkip
 	 */
-	public function skip_records( $_numToSkip ) {
-		while ( (int)$_numToSkip-- !== 0 ) {
+	public function skip_records( $_numToSkip )
+	{
+		while ( (int)$_numToSkip-- !== 0 )
+		{
 			fgetcsv( $this->resource, self::csv_max_linelength, $this->csv_fieldsep);
 		}
 	}
@@ -140,22 +156,27 @@ 
 	 * @param mixed $_position
 	 * @return bool
 	 */
-	private function get_raw_record( $_position = 'next' ) {
-		switch ($_position) {
+	private function get_raw_record( $_position = 'next' )
+	{
+		switch ($_position)
+		{
 			case 'current' :
-				if ($this->current_position == 0) {
+				if ($this->current_position == 0)
+				{
 					return;
 				}
 				break;
 			case 'first' :
-				if (!$this->current_position == 0) {
+				if (!$this->current_position == 0)
+				{
 					$this->current_position = 0;
 					rewind($this->resource);
 				}
 				
 			case 'next' :
 				$csv_data = fgetcsv( $this->resource, self::csv_max_linelength, $this->csv_fieldsep);
-				if (!is_array($csv_data)) {
+				if (!is_array($csv_data))
+				{
 					return false;
 				}
 				$this->current_position++;
@@ -163,33 +184,41 @@ 
 				break;
 				
 			case 'previous' :
-				if ($this->current_position < 2) {
+				if ($this->current_position < 2)
+				{
 					throw new Exception('Error: There is no previous record!');
 				}
 				$final_position = --$this->current_position;
 				$this->current_position = 0;
 				rewind($this->resource);
-				while ($this->current_position !== $final_position) {
+				while ($this->current_position !== $final_position)
+				{
 					$this->get_raw_record();
 				}
 				break;
 				
 			case 'last' :
-				while ($this->get_raw_record()) {}
+				while ($this->get_raw_record())
+				{
+}
 				break;
 				
 			default: //somenumber
-				if (!is_int($_position)) {
+				if (!is_int($_position))
+				{
 					throw new Exception('Error: $position must be one of {current|first|last|next|previous} or an integer value');
 				}
-				if ($_position == $this->current_position) {
+				if ($_position == $this->current_position)
+				{
 					break;
 				}
-				elseif ($_position < $this->current_position) {
+				elseif ($_position < $this->current_position)
+				{
 					$this->current_position = 0;
 					rewind($this->resource);
 				}
-				while ($this->current_position !== $_position) {
+				while ($this->current_position !== $_position)
+				{
 					$this->get_raw_record();
 				}
 				break;				
@@ -202,12 +231,16 @@ 
 	 *
 	 * @return int
 	 */
-	public function get_num_of_records( ) {
-		if ($this->num_of_records > 0) {
+	public function get_num_of_records( )
+	{
+		if ($this->num_of_records > 0)
+		{
 			return $this->num_of_records;
 		}
 		$current_position = $this->current_position;
-		while ($this->get_raw_record()) {}
+		while ($this->get_raw_record())
+		{
+}
 		$this->num_of_records = $this->current_position;
 		$this->get_record($current_position);
 		return $this->num_of_records;
@@ -218,7 +251,8 @@ 
 	 *
 	 * @return int
 	 */
-	public function get_current_position( ) {
+	public function get_current_position( )
+	{
 		
 		return $this->current_position;
 		
@@ -230,12 +264,16 @@ 
 	 *
 	 * @return
 	 */
-	protected function do_fieldmapping( ) {
+	protected function do_fieldmapping( )
+	{
 		$record = $this->record;
 		$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;
@@ -246,8 +284,10 @@ 
 	 *
 	 * @return bool
 	 */
-	protected function do_conversions() {
-		if ( $record = importexport_helper_functions::conversion( $this->record, $this->conversion, $this->conversion_class )) {
+	protected function do_conversions()
+	{
+		if ( $record = importexport_helper_functions::conversion( $this->record, $this->conversion, $this->conversion_class ))
+		{
 			$this->record = $record;
 			return;
 		}
@@ -264,16 +304,19 @@ 
 	 *
 	 * @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);
 			}
@@ -282,7 +325,10 @@ 
 			// Add in any fields that are keys to another 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;
@@ -292,7 +338,8 @@ 
 			// Not quite a recursive merge, since only one level
 			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,12 +347,15 @@ 
 			$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) {
+			foreach((array)$fields['links'] as $name)
+			{
 				if($record[$name] && $links[$name])
 				{
 					// Primary key to another app, not a link
@@ -347,15 +397,19 @@ 
 								lang($links[$name]), $record[$name]).
  								' - ' . lang('no matches');
 							continue;
-						} else {
+						}
+						else
+						{
 							$record[$name] = key($results);
 						}
 					}
 				}
 			}
-			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]) {
+				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])))
@@ -363,20 +417,26 @@ 
 						// Unable to parse value into account
 						$warnings[] = $name . ': ' .lang('%1 is not a known user or group', $record[$name]);
 					}
-					if($new_owner != '') {
+					if($new_owner != '')
+					{
 						$record[$name] = $new_owner;
-					} else {
+					}
+					else
+					{
 						// Clear it to prevent trouble later on
 						$record[$name] = '';
 					}
 				}
 			}
-			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
@@ -402,7 +462,8 @@ 
 								// Try again, anything goes
 								try {
 									$formatted = new Api\DateTime($record[$name]);
-								} catch (Exception $e) {
+								}
+								catch (Exception $e) {
 									$warnings[] = $name.': ' . $e->getMessage() . "\n" .
 										'Format: '.'!'.Api\DateTime::$user_dateformat . ' ' .Api\DateTime::$user_timeformat;
 									continue;
@@ -424,7 +485,8 @@ 
 					}
 					
 					if(is_array(self::$cf_parse_cache[$appname][0]['date-time']) &&
-							in_array($name, 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]);
 					}
@@ -434,7 +496,8 @@ 
 					$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
@@ -448,7 +511,8 @@ 
 					}
 					$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'])) {
+							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]);
 					}
@@ -460,26 +524,37 @@ 
 			}
 			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 = '.';
+					if (empty($dec_point))
+					{
+						$dec_point = '.';
+					}
 					$record[$name] = floatval(str_replace($dec_point, '.', preg_replace('/[^\d'.preg_quote($dec_point).']/', '', $record[$name])));
 				}
 			}
 
 			// 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]) {
+			foreach((array)$fields['select-cat'] as $name)
+			{
+				if($record[$name])
+				{
 					// Only parse name if it needs it
 					if($format == 1)
 					{
@@ -493,7 +568,10 @@ 
 							$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;
+						}
 					}
 				}
 			}
@@ -514,7 +592,8 @@ 
 	 */
 	protected static function find_select_key($record_value, $selects)
 	{
-		if($record_value != null && is_array($selects)) {
+		if($record_value != null && is_array($selects))
+		{
 			if(is_array($record_value) || is_string($record_value) && strpos($record_value, ',') !== FALSE)
 			{
 				// Array, or CSV
@@ -526,7 +605,10 @@ 
 					if(!$sub_key)
 					{
 						$sub_key = static::find_select_key($subs[$sub_index].','.$subs[$sub_index+1], $selects);
-						if($sub_key) $sub_index++;
+						if($sub_key)
+						{
+							$sub_index++;
+						}
 					}
 					if($sub_key)
 					{
@@ -543,7 +625,10 @@ 
 			else
 			{
 				$key = array_search(strtolower($record_value), array_map('strtolower',array_map('lang',$selects)));
-				if($key !== false) $record_value = $key;
+				if($key !== false)
+				{
+					$record_value = $key;
+				}
 			}
 		}