EE_Import::instance() - Code Metrics - Inspection of "Daily Inspection: [touch:9077]{t:45}throw an excep..." - eventespresso/event-espresso-core - Measure and Improve Code Quality continuously with Scrutinizer

Completed
Branch — BUG-9077-negative-payments (99f903)

unknown
created 2015-11-23 21:40 UTC
EE_Import::instance() A

↳ Parent: EE_Import
Complexity

Conditions	4
Paths	2
Size

Total Lines	7
Code Lines	4
Duplication

Lines	0
Ratio	0 %
Metric	Value
dl	0
loc	7
rs	9.2
cc	4
eloc	4
nc	2
nop	0
<?php if (!defined('EVENT_ESPRESSO_VERSION')) exit('No direct script access allowed');
do_action( 'AHEE_log', __FILE__, __FUNCTION__, '' );
/**
 * EE_Import class
 *
 * @package				Event Espresso
 * @subpackage		includes/functions
 * @author					Brent Christensen
 *
 * ------------------------------------------------------------------------
 */
 class EE_Import {

	const do_insert = 'insert';
	const do_update = 'update';
	const do_nothing = 'nothing';


  // instance of the EE_Import object
	private static $_instance = NULL;

	private static $_csv_array = array();


	/**
	 *
	 * @var array of model names
	 */
	private static $_model_list = array();


	private static $_columns_to_save = array();


	protected $_total_inserts = 0;
	protected $_total_updates = 0;
	protected $_total_insert_errors = 0;
	protected $_total_update_errors = 0;


	/**
	 *		private constructor to prevent direct creation
	 *		@Constructor
	 *		@access private
	 *		@return void

	 */
  private function __construct() {
		$this->_total_inserts = 0;
		$this->_total_updates = 0;
		$this->_total_insert_errors = 0;
		$this->_total_update_errors = 0;
	}


	/**
	 *	@ singleton method used to instantiate class object
	 *	@ access public
	 *	@return EE_Import
	 */
	public static function instance() {
		// check if class object is instantiated
		if ( self::$_instance === NULL  or ! is_object( self::$_instance ) or ! ( self::$_instance instanceof EE_Import )) {
			self::$_instance = new self();
		}
		return self::$_instance;
	}

	/**
	 * Resets the importer
	 * @return EE_Import
	 */
	public static function reset(){
		self::$_instance = null;
		return self::instance();
	}




	/**
	 *	@ generates HTML for a file upload input and form
	 *	@ access 	public
	 * 	@param 	string 		$title - heading for the form
	 * 	@param 	string 		$intro - additional text explaing what to do
	 * 	@param 	string 		$page - EE Admin page to direct form to - in the form "espresso_{pageslug}"
/**
 * @param array $germany
 * @param array $island
 * @param array $italy
 */
function finale($germany, $island) {
    return "2:1";
}
	 * 	@param 	string 		$action - EE Admin page route array "action" that form will direct to
	 * 	@param 	string 		$type - type of file to import
	 *	@ return 	string
	 */
	public function upload_form ( $title, $intro, $form_url, $action, $type  ) {

		$form_url = EE_Admin_Page::add_query_args_and_nonce( array( 'action' => $action ), $form_url );

		ob_start();
?>
	<div class="ee-upload-form-dv">
		<h3><?php echo $title;?></h3>
		<p><?php echo $intro;?></p>

		<form action="<?php echo $form_url?>" method="post" enctype="multipart/form-data">
			<input type="hidden" name="csv_submitted" value="TRUE" id="<?php echo time();?>">
			<input name="import" type="hidden" value="<?php echo $type;?>" />
			<input type="file" name="file[]" size="90" >
			<input class="button-primary" type="submit" value="<?php _e( 'Upload File', 'event_espresso' );?>">
		</form>

		<p class="ee-attention">
			<b><?php _e( 'Attention', 'event_espresso' );?></b><br/>
			<?php echo sprintf( __( 'Accepts .%s file types only.', 'event_espresso' ), $type ) ;?>
			<?php echo __( 'Please only import CSV files exported from Event Espresso, or compatible 3rd-party software.', 'event_espresso' );?>
		</p>

	</div>

<?php
		$uploader = ob_get_clean();
		return $uploader;
	}





	/**
	 *	@Import Event Espresso data - some code "borrowed" from event espresso csv_import.php
	 *	@access public
	 *	@return boolean success
	 */
	public function import() {

		require_once( EE_CLASSES . 'EE_CSV.class.php' );
		$this->EE_CSV = EE_CSV::instance();
class MyClass { }

$x = new MyClass();
$x->foo = true;

		if ( isset( $_REQUEST['import'] )) {
			if( isset( $_POST['csv_submitted'] )) {

			    switch ( $_FILES['file']['error'][0] ) {
			        case UPLOAD_ERR_OK:
			            $error_msg = FALSE;
			            break;
			        case UPLOAD_ERR_INI_SIZE:
			            $error_msg = __("'The uploaded file exceeds the upload_max_filesize directive in php.ini.'", "event_espresso");
			            break;
			        case UPLOAD_ERR_FORM_SIZE:
			            $error_msg = __('The uploaded file exceeds the MAX_FILE_SIZE directive that was specified in the HTML form.', "event_espresso");
			            break;
			        case UPLOAD_ERR_PARTIAL:
			            $error_msg = __('The uploaded file was only partially uploaded.', "event_espresso");
			            break;
			        case UPLOAD_ERR_NO_FILE:
			            $error_msg = __('No file was uploaded.', "event_espresso");
			            break;
			        case UPLOAD_ERR_NO_TMP_DIR:
			            $error_msg = __('Missing a temporary folder.', "event_espresso");
			            break;
			        case UPLOAD_ERR_CANT_WRITE:
			            $error_msg = __('Failed to write file to disk.', "event_espresso");
			            break;
			        case UPLOAD_ERR_EXTENSION:
			            $error_msg = __('File upload stopped by extension.', "event_espresso");
			            break;
			        default:
			            $error_msg = __('An unknown error occurred and the file could not be uploaded', "event_espresso");
			            break;
			    }

				if ( ! $error_msg ) {

				    $filename	= $_FILES['file']['name'][0];
					$file_ext 		= substr( strrchr( $filename, '.' ), 1 );
				    $file_type 	= $_FILES['file']['type'][0];
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
				    $temp_file	= $_FILES['file']['tmp_name'][0];
				    $filesize    	= $_FILES['file']['size'][0] / 1024;//convert from bytes to KB

					if ( $file_ext=='csv' ) {

						$max_upload = $this->EE_CSV->get_max_upload_size();//max upload size in KB
						if ( $filesize < $max_upload || true) {

							$wp_upload_dir = str_replace( array( '\\', '/' ), DS, wp_upload_dir());
							$path_to_file = $wp_upload_dir['basedir'] . DS . 'espresso' . DS . $filename;

							if( move_uploaded_file( $temp_file, $path_to_file )) {

								// convert csv to array
								$this->csv_array = $this->EE_CSV->import_csv_to_model_data_array( $path_to_file );


								// was data successfully stored in an array?
								if ( is_array( $this->csv_array ) ) {


									$import_what = str_replace( 'csv_import_', '', $_REQUEST['action'] );
									$import_what = str_replace( '_', ' ', ucwords( $import_what ));
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
									$processed_data = $this->csv_array;

									$this->columns_to_save = FALSE;


									// if any imports require funcky processing, we'll catch them in the switch
									switch ($_REQUEST['action']) {

										case "import_events";
										case "event_list";
												$import_what = 'Event Details';
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
										break;

										case 'groupon_import_csv':
											$import_what = 'Groupon Codes';
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
											$processed_data = $this->process_groupon_codes();

										break;

									}
									// save processed codes to db
									if ( $this->save_csv_data_array_to_db( $processed_data, $this->columns_to_save ) ) {

										return TRUE;

									}
								} else {
									// no array? must be an error
									EE_Error::add_error(sprintf(__("No file seems to have been uploaded", "event_espresso")), __FILE__, __FUNCTION__, __LINE__ );
									return FALSE;
								}

							} else {
								EE_Error::add_error(sprintf(__("%s was not successfully uploaded", "event_espresso"),$filename), __FILE__, __FUNCTION__, __LINE__ );
								return FALSE;
							}

						} else {
							EE_Error::add_error( sprintf(__("%s was too large of a file and could not be uploaded. The max filesize is %s' KB.", "event_espresso"),$filename,$max_upload), __FILE__, __FUNCTION__, __LINE__ );
							return FALSE;
						}

					} else {
						EE_Error::add_error( sprintf(__("%s  had an invalid file extension, not uploaded", "event_espresso"),$filename), __FILE__, __FUNCTION__, __LINE__ );
						return FALSE;
					}

				} else {
					EE_Error::add_error( $error_msg, __FILE__, __FUNCTION__, __LINE__ );
					return FALSE;
				}

			}
		}
		return;
	}

	/**
	 *	Given an array of data (usually from a CSV import) attempts to save that data to the db.
	 *	If $model_name ISN'T provided, assumes that this is a 3d array, with toplevel keys being model names,
	 *	next level being numeric indexes adn each value representing a model object, and the last layer down
	 *	being keys of model fields and their proposed values.
	 *	If $model_name IS provided, assumes a 2d array of the bottom two layers previously mentioned.
	 *	If the CSV data says (in the metadata row) that it's from the SAME database,
	 *	we treat the IDs in the CSV as the normal IDs, and try to update those records. However, if those
	 *	IDs DON'T exist in the database, they're treated as temporary IDs,
	 *	which can used elsewhere to refer to the same object. Once an item
	 *	with a temporary ID gets inserted, we record its mapping from temporary
	 *	ID to real ID, and use the real ID in place of the temporary ID
	 *	when that temporary ID was used as a foreign key.
	 *	If the CSV data says (in the metadata again) that it's from a DIFFERENT database,
	 *	we treat all the IDs in the CSV as temporary ID- eg, if the CSV specifies an event with
	 *	ID 1, and the database already has an event with ID 1, we assume that's just a coincidence,
	 *	and insert a new event, and map it's temporary ID of 1 over to its new real ID.
	 *	An important exception are non-auto-increment primary keys. If one entry in the
	 *	CSV file has the same ID as one in the DB, we assume they are meant to be
	 *	the same item, and instead update the item in the DB with that same ID.
	 *	Also note, we remember the mappings permanently. So the 2nd, 3rd, and 10000th
	 *	time you import a CSV from a different site, we remember their mappings, and
	 * will try to update the item in the DB instead of inserting another item (eg
	 * if we previously imported an event with temporary ID 1, and then it got a
	 * real ID of 123, we remember that. So the next time we import an event with
	 * temporary ID, from the same site, we know that it's real ID is 123, and will
	 * update that event, instead of adding a new event).
	 *		  @access public
	 *			@param array $csv_data_array - the array containing the csv data produced from EE_CSV::import_csv_to_model_data_array()
	 *			@param array $fields_to_save - an array containing the csv column names as keys with the corresponding db table fields they will be saved to
/**
 * @param array $germany
 * @param array $island
 * @param array $italy
 */
function finale($germany, $island) {
    return "2:1";
}
	 *			@return TRUE on success, FALSE on fail
	 */
	public function save_csv_data_array_to_db( $csv_data_array, $model_name = FALSE ) {


		$success = FALSE;
		$error = FALSE;
		//whther to treat this import as if it's data froma different database or not
		//ie, if it IS from a different database, ignore foreign keys whihf
		$export_from_site_a_to_b = true;
		// first level of array is not table information but a table name was passed to the function
		// array is only two levels deep, so let's fix that by adding a level, else the next steps will fail
		if($model_name){
			$csv_data_array = array($csv_data_array);
		}
		// begin looking through the $csv_data_array, expecting the toplevel key to be the model's name...
		$old_site_url = 'none-specified';

		//hanlde metadata
		if(isset($csv_data_array[EE_CSV::metadata_header]) ){
			$csv_metadata = array_shift($csv_data_array[EE_CSV::metadata_header]);
			//ok so its metadata, dont try to save it to ehte db obviously...
			if(isset($csv_metadata['site_url']) && $csv_metadata['site_url'] == site_url()){
				EE_Error::add_attention(sprintf(__("CSV Data appears to be from the same database, so attempting to update data", "event_espresso")));
				$export_from_site_a_to_b = false;
			}else{
				$old_site_url = isset( $csv_metadata['site_url']) ? $csv_metadata['site_url'] : $old_site_url;
				EE_Error::add_attention(sprintf(__("CSV Data appears to be from a different database (%s instead of %s), so we assume IDs in the CSV data DO NOT correspond to IDs in this database", "event_espresso"),$old_site_url,site_url()));
			};
			unset($csv_data_array[EE_CSV::metadata_header]);
		}
		/**
		* @var $old_db_to_new_db_mapping 2d array: toplevel keys being model names, bottom-level keys being the original key, and
		* the value will be the newly-inserted ID.
		* If we have already imported data from the same website via CSV, it shoudl be kept in this wp option
		*/
	   $old_db_to_new_db_mapping = get_option('ee_id_mapping_from'.sanitize_title($old_site_url),array());
	   if( $old_db_to_new_db_mapping){
		   EE_Error::add_attention(sprintf(__("We noticed you have imported data via CSV from %s before. Because of this, IDs in your CSV have been mapped to their new IDs in %s", "event_espresso"),$old_site_url,site_url()));
	   }
	   $old_db_to_new_db_mapping = $this->save_data_rows_to_db($csv_data_array, $export_from_site_a_to_b, $old_db_to_new_db_mapping);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);

		//save the mapping from old db to new db in case they try re-importing the same data from the same website again
		update_option('ee_id_mapping_from'.sanitize_title($old_site_url),$old_db_to_new_db_mapping);

		if ( $this->_total_updates > 0 ) {

			EE_Error::add_success( sprintf(__("%s existing records in the database were updated.", "event_espresso"),$this->_total_updates));
			$success = true;
		}
		if ( $this->_total_inserts > 0 ) {

			EE_Error::add_success(sprintf(__("%s new records were added to the database.", "event_espresso"),$this->_total_inserts));
			$success = true;
		}

		if ( $this->_total_update_errors > 0 ) {

			EE_Error::add_error(sprintf(__("'One or more errors occurred, and a total of %s existing records in the database were <strong>not</strong> updated.'", "event_espresso"),$this->_total_update_errors), __FILE__, __FUNCTION__, __LINE__ );
			$error = true;
		}
		if ( $this->_total_insert_errors > 0 ) {

			EE_Error::add_error(sprintf(__("One or more errors occurred, and a total of %s new records were <strong>not</strong> added to the database.'", "event_espresso"),$this->_total_insert_errors), __FILE__, __FUNCTION__, __LINE__ );
			$error = true;
		}

		//lastly, we need to update the datetime and ticket sold amounts
		//as those may ahve been affected by this
		EEM_Datetime::instance()->update_sold( EEM_Datetime::instance()->get_all() );
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
		EEM_Ticket::instance()->update_tickets_sold(EEM_Ticket::instance()->get_all());
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);

		// if there was at least one success and absolutely no errors
		if ( $success && ! $error ) {
			return TRUE;
		} else {
			return FALSE;
		}

	}


	/**
	 * Processes the array of data, given the knowledge that it's from the same database or a different one,
	 * and the mapping from temporary IDs to real IDs.
	 * If the data is from a different database, we treat the primary keys and their corresponding
	 * foreign keys as "temp Ids", basically identifiers that get mapped to real primary keys
	 * in the real target database. As items are inserted, their temporary primary keys
	 * are mapped to the real IDs in the target database. Also, before doing any update or
	 * insert, we replace all the temp ID which are foreign keys with their mapped real IDs.
	 * An exception: string primary keys are treated as real IDs, or else we'd need to
	 * dynamically generate new string primary keys which would be very awkard for the country table etc.
	 * Also, models with no primary key are strange too. We combine use their primar key INDEX (a
	 * combination of fields) to create a unique string identifying the row and store
	 * those in the mapping.
	 *
	 * If the data is from the same database, we usually treat primary keys as real IDs.
	 * An exception is if there is nothing in the database for that ID. If that's the case,
	 * we need to insert a new row for that ID, and then map from the non-existent ID
	 * to the newly-inserted real ID.
	 * @param type $csv_data_array
	 * @param type $export_from_site_a_to_b
	 * @param type $old_db_to_new_db_mapping
	 * @return array updated $old_db_to_new_db_mapping
	 */
	public function save_data_rows_to_db( $csv_data_array, $export_from_site_a_to_b, $old_db_to_new_db_mapping ) {
		foreach ( $csv_data_array as $model_name_in_csv_data => $model_data_from_import ) {
			//now check that assumption was correct. If
			if ( EE_Registry::instance()->is_model_name($model_name_in_csv_data)) {

				$model_name = $model_name_in_csv_data;
			}else {
				// no table info in the array and no table name passed to the function?? FAIL
				EE_Error::add_error( __('No table information was specified and/or found, therefore the import could not be completed','event_espresso'), __FILE__, __FUNCTION__, __LINE__ );
				return FALSE;
			}
			/* @var $model EEM_Base */
			$model = EE_Registry::instance()->load_model($model_name);

			//so without further ado, scanning all the data provided for primary keys and their inital values
			foreach ( $model_data_from_import as $model_object_data ) {
				//before we do ANYTHING, make sure the csv row wasn't just completely blank
				$row_is_completely_empty = true;
				foreach($model_object_data as $field){
					if($field){
						$row_is_completely_empty = false;
					}
				}
				if($row_is_completely_empty){
					continue;
				}
				//find the PK in the row of data (or a combined key if
				//there is no primary key)
				if($model->has_primary_key_field()){
					$id_in_csv =  $model_object_data[$model->primary_key_name()];
				}else{
					$id_in_csv = $model->get_index_primary_key_string($model_object_data);
				}


				$model_object_data = $this->_replace_temp_ids_with_mappings( $model_object_data, $model, $old_db_to_new_db_mapping, $export_from_site_a_to_b );
/**
 * @return array|string
 */
function returnsDifferentValues($x) {
    if ($x) {
        return 'foo';
    }

    return array();
}

$x = returnsDifferentValues($y);
if (is_array($x)) {
    // $x is an array.
}
				//now we need to decide if we're going to add a new model object given the $model_object_data,
				//or just update.
				if($export_from_site_a_to_b){
					$what_to_do = $this->_decide_whether_to_insert_or_update_given_data_from_other_db( $id_in_csv, $model_object_data, $model, $old_db_to_new_db_mapping );
				}else{//this is just a re-import
					$what_to_do = $this->_decide_whether_to_insert_or_update_given_data_from_same_db( $id_in_csv, $model_object_data, $model, $old_db_to_new_db_mapping );

				}
				if( $what_to_do == self::do_nothing ) {
					continue;
				}

				//double-check we actually want to insert, if that's what we're planning
				//based on whether this item would be unique in the DB or not
				if( $what_to_do == self::do_insert ) {
					//we're supposed to be inserting. But wait, will this thing
					//be acceptable if inserted?
					$conflicting = $model->get_one_conflicting( $model_object_data, false );
					if($conflicting){
						//ok, this item would conflict if inserted. Just update the item that it conflicts with.
						$what_to_do = self::do_update;
						//and if this model has a primary key, remember its mapping
						if($model->has_primary_key_field()){
							$old_db_to_new_db_mapping[$model_name][$id_in_csv] = $conflicting->ID();
							$model_object_data[$model->primary_key_name()] = $conflicting->ID();
						}else{
							//we want to update this conflicting item, instead of inserting a conflicting item
							//so we need to make sure they match entirely (its possible that they only conflicted on one field, but we need them to match on other fields
							//for the WHERE conditions in the update). At the time of this comment, there were no models like this
							foreach($model->get_combined_primary_key_fields() as $key_field){
								$model_object_data[$key_field->get_name()] = $conflicting->get($key_field->get_name());
							}
						}
					}
				}
				if( $what_to_do == self::do_insert ) {
					$old_db_to_new_db_mapping = $this->_insert_from_data_array( $id_in_csv, $model_object_data, $model, $old_db_to_new_db_mapping );
/**
 * @return array|string
 */
function returnsDifferentValues($x) {
    if ($x) {
        return 'foo';
    }

    return array();
}

$x = returnsDifferentValues($y);
if (is_array($x)) {
    // $x is an array.
}
				}elseif( $what_to_do == self::do_update ) {
					$old_db_to_new_db_mapping = $this->_update_from_data_array( $id_in_csv, $model_object_data, $model, $old_db_to_new_db_mapping );
				}else{
					throw new EE_Error( sprintf( __( 'Programming error. We shoudl be inserting or updating, but instead we are being told to "%s", whifh is invalid', 'event_espresso' ), $what_to_do ) );
				}
			}
		}
		return $old_db_to_new_db_mapping;
	}



	/**
	 * Decides whether or not to insert, given that this data is from another database.
	 * So, if the primary key of this $model_object_data already exists in the database,
	 * it's just a coincidence and we should still insert. The only time we should
	 * update is when we know what it maps to, or there's something that would
	 * conflict (and we should instead just update that conflicting thing)
	 * @param string $id_in_csv
	 * @param array $model_object_data by reference so it can be modified
	 * @param EEM_Base $model
	 * @param array $old_db_to_new_db_mapping by reference so it can be modified
	 * @return string one of the consts on this class that starts with do_*
	 */
	protected function _decide_whether_to_insert_or_update_given_data_from_other_db( $id_in_csv, $model_object_data, $model, $old_db_to_new_db_mapping ) {

		$model_name = $model->get_this_model_name();
		//if it's a site-to-site export-and-import, see if this modelobject's id
		//in the old data that we know of
		if( isset($old_db_to_new_db_mapping[$model_name][$id_in_csv]) ){
			return self::do_update;
		}else{
			return self::do_insert;
		}
	}

	/**
	 * If this thing basically already exists in the database, we want to update it;
	 * otherwise insert it (ie, someone tweaked the CSV file, or the item was
	 * deleted in the database so it should be re-inserted)
	 * @param type $id_in_csv
	 * @param type $model_object_data
	 * @param EEM_Base $model
	 * @param type $old_db_to_new_db_mapping
/**
 * @param array $germany
 * @param array $island
 * @param array $italy
 */
function finale($germany, $island) {
    return "2:1";
}
	 * @return
	 */
	protected function _decide_whether_to_insert_or_update_given_data_from_same_db( $id_in_csv, $model_object_data, $model ) {

		//in this case, check if this thing ACTUALLY exists in the database
		if( $model->get_one_conflicting( $model_object_data ) ){
			return self::do_update;
		}else{
			return self::do_insert;
		}
	}

	/**
	 * Using the $old_db_to_new_db_mapping array, replaces all the temporary IDs
	 * with their mapped real IDs. Eg, if importing from site A to B, the mapping
	 * file may indicate that the ID "my_event_id" maps to an actual event ID of 123.
	 * So this function searches for any event temp Ids called "my_event_id" and
	 * replaces them with 123.
	 * Also, if there is no temp ID for the INT foreign keys from another database,
	 * replaces them with 0 or the field's default.
	 * @param type $model_object_data
	 * @param EEM_Base $model
	 * @param type $old_db_to_new_db_mapping
	 * @param boolean $export_from_site_a_to_b
	 * @return array updated model object data with temp IDs removed
	 */
	protected function _replace_temp_ids_with_mappings( $model_object_data, $model, $old_db_to_new_db_mapping, $export_from_site_a_to_b ) {
		//if this model object's primary key is in the mapping, replace it
		if( $model->has_primary_key_field() &&
				$model->get_primary_key_field()->is_auto_increment() &&
				isset( $old_db_to_new_db_mapping[ $model->get_this_model_name() ] ) &&
				isset( $old_db_to_new_db_mapping[ $model->get_this_model_name() ][ $model_object_data[ $model->primary_key_name() ] ] ) ) {
			$model_object_data[ $model->primary_key_name() ] = $old_db_to_new_db_mapping[ $model->get_this_model_name() ][ $model_object_data[ $model->primary_key_name() ] ];
		}

		try{
			$model_name_field = $model->get_field_containing_related_model_name();
			$models_pointed_to_by_model_name_field = $model_name_field->get_model_names_pointed_to();
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
		}catch( EE_Error $e ){
			$model_name_field = NULL;
			$models_pointed_to_by_model_name_field = array();
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
		}
		foreach( $model->field_settings( true )  as $field_obj ){
			if( $field_obj instanceof EE_Foreign_Key_Int_Field ) {
				$models_pointed_to = $field_obj->get_model_names_pointed_to();
				$found_a_mapping = false;
				foreach( $models_pointed_to as $model_pointed_to_by_fk ) {

					if( $model_name_field ){
						$value_of_model_name_field = $model_object_data[ $model_name_field->get_name() ];
						if( $value_of_model_name_field == $model_pointed_to_by_fk ) {

							$model_object_data[ $field_obj->get_name() ] = $this->_find_mapping_in(
									$model_object_data[ $field_obj->get_name() ],
									$model_pointed_to_by_fk,
									$old_db_to_new_db_mapping,
									$export_from_site_a_to_b );
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
								$found_a_mapping = true;
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
								break;
						}
					}else{

						$model_object_data[ $field_obj->get_name() ] = $this->_find_mapping_in(
								$model_object_data[ $field_obj->get_name() ],
								$model_pointed_to_by_fk,
								$old_db_to_new_db_mapping,
								$export_from_site_a_to_b );
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
						$found_a_mapping = true;
					}
					//once we've found a mapping for this field no need to continue
					if( $found_a_mapping ) {
						break;
					}


				}
			}else{
if (rand(1, 6) > 3) {
print "Check failed";
} else {
    //print "Check succeeded";
}
				//it's a string foreign key (which we leave alone, because those are things
				//like country names, which we'd really rather not make 2 USAs etc (we'd actually
				//prefer to just update one)
				//or it's just a regular value that ought to be replaced
			}
		}
		//
		if( $model instanceof EEM_Term_Taxonomy ){
			$model_object_data = $this->_handle_split_term_ids( $model_object_data );
		}
		return $model_object_data;
	}

	/**
	 * If the data was exported PRE-4.2, but then imported POST-4.2, then the term_id
	 * this term-taxonomy refers to may be out-of-date so we need to update it.
	 * see https://make.wordpress.org/core/2015/02/16/taxonomy-term-splitting-in-4-2-a-developer-guide/
	 * @param type $model_object_data
	 * @return array new model object data
	 */
	protected function _handle_split_term_ids( $model_object_data ){
		if( isset( $model_object_data['term_id'] ) && isset( $model_object_data[ 'taxonomy' ]) && apply_filters( 'FHEE__EE_Import__handle_split_term_ids__function_exists', function_exists( 'wp_get_split_term' ), $model_object_data ) ) {
			$new_term_id = wp_get_split_term( $model_object_data[ 'term_id' ], $model_object_data[ 'taxonomy' ] );
			if( $new_term_id ){
				$model_object_data[ 'term_id' ] = $new_term_id;
			}
		}
		return $model_object_data;
	}
	/**
	 * Given the object's ID and its model's name, find it int he mapping data,
	 * bearing in mind where it came from
	 * @param type $object_id
	 * @param string $model_name
	 * @param array $old_db_to_new_db_mapping
	 * @param type $export_from_site_a_to_b
	 * @return int
	 */
	protected function _find_mapping_in( $object_id, $model_name, $old_db_to_new_db_mapping, $export_from_site_a_to_b) {
		if(	isset( $old_db_to_new_db_mapping[ $model_name ][ $object_id ] ) ){

				return $old_db_to_new_db_mapping[ $model_name ][ $object_id ];
			}elseif( $object_id == '0' || $object_id == '' ) {
				//leave as-is
				return $object_id;
class Author {
    private $name;

    public function __construct($name) {
        $this->name = $name;
    }

    public function getName() {
        return $this->name;
    }
}

abstract class Post {
    public function getAuthor() {
        return 'Johannes';
    }
}

class BlogPost extends Post {
    public function getAuthor() {
        return new Author('Johannes');
    }
}

class ForumPost extends Post { /* ... */ }

function my_function(Post $post) {
    echo strtoupper($post->getAuthor());
}
			}elseif( $export_from_site_a_to_b ){
				//we couldn't find a mapping for this, and it's from a different site,
				//so blank it out
				return NULL;
			}elseif( ! $export_from_site_a_to_b ) {
				//we coudln't find a mapping for this, but it's from thsi DB anyway
				//so let's just leave it as-is
				return $object_id;
class Author {
    private $name;

    public function __construct($name) {
        $this->name = $name;
    }

    public function getName() {
        return $this->name;
    }
}

abstract class Post {
    public function getAuthor() {
        return 'Johannes';
    }
}

class BlogPost extends Post {
    public function getAuthor() {
        return new Author('Johannes');
    }
}

class ForumPost extends Post { /* ... */ }

function my_function(Post $post) {
    echo strtoupper($post->getAuthor());
}
			}
	}

	/**
	 *
	 * @param type $id_in_csv
	 * @param type $model_object_data
	 * @param EEM_Base $model
	 * @param type $old_db_to_new_db_mapping
	 * @return array updated $old_db_to_new_db_mapping
	 */
	protected function _insert_from_data_array( $id_in_csv, $model_object_data, $model, $old_db_to_new_db_mapping ) {
		//remove the primary key, if there is one (we don't want it for inserts OR updates)
		//we'll put it back in if we need it
		if($model->has_primary_key_field() && $model->get_primary_key_field()->is_auto_increment()){
			$effective_id = $model_object_data[$model->primary_key_name()];
			unset($model_object_data[$model->primary_key_name()]);
		}else{
			$effective_id = $model->get_index_primary_key_string( $model_object_data );
		}
		//the model takes care of validating the CSV's input
		try{
			$new_id = $model->insert($model_object_data);
			if( $new_id ){
0   == false // true
0   == null  // true
123 == false // false
123 == null  // false

// It is often better to use strict comparison
0 === false // false
0 === null  // false
				$old_db_to_new_db_mapping[$model->get_this_model_name()][$id_in_csv] = $new_id;
				$this->_total_inserts++;
				EE_Error::add_success( sprintf(__("Successfully added new %s (with id %s) with csv data %s", "event_espresso"),$model->get_this_model_name(),$new_id, implode(",",$model_object_data)));
			}else{
				$this->_total_insert_errors++;
				//put the ID used back in there for the error message
				if($model->has_primary_key_field()){
					$model_object_data[$model->primary_key_name()] = $effective_id;
				}
				EE_Error::add_error( sprintf(__("Could not insert new %s with the csv data: %s", "event_espresso"),$model->get_this_model_name(),http_build_query($model_object_data)), __FILE__, __FUNCTION__, __LINE__ );
			}
		}catch(EE_Error $e){
			$this->_total_insert_errors++;
			if($model->has_primary_key_field()){
				$model_object_data[$model->primary_key_name()] = $effective_id;
			}
			EE_Error::add_error( sprintf(__("Could not insert new %s with the csv data: %s because %s", "event_espresso"),$model->get_this_model_name(),implode(",",$model_object_data),$e->getMessage()), __FILE__, __FUNCTION__, __LINE__ );
		}
		return $old_db_to_new_db_mapping;
	}

	/**
	 * Given the model object data, finds the row to update and updates it
	 * @param string|int $id_in_csv
	 * @param array $model_object_data
	 * @param EEM_Base $model
	 * @param array $old_db_to_new_db_mapping
	 * @return array updated $old_db_to_new_db_mapping
	 */
	protected function _update_from_data_array( $id_in_csv,  $model_object_data, $model, $old_db_to_new_db_mapping ) {
		try{
			//let's keep two copies of the model object data:
			//one for performing an update, one for everthing else
			$model_object_data_for_update = $model_object_data;
			if($model->has_primary_key_field()){
				$conditions = array($model->primary_key_name() => $model_object_data[$model->primary_key_name()]);
				//remove the primary key because we shouldn't use it for updating
				unset($model_object_data_for_update[$model->primary_key_name()]);
			}elseif($model->get_combined_primary_key_fields() > 1 ){
				$conditions = array();
				foreach($model->get_combined_primary_key_fields() as $key_field){
					$conditions[$key_field->get_name()] = $model_object_data[$key_field->get_name()];
				}
			}else{
				$model->primary_key_name();//this shoudl just throw an exception, explaining that we dont have a primary key (or a combine dkey)
			}

			$success = $model->update($model_object_data_for_update,array($conditions));
function myFunction($a) {
    switch ($a) {
        case 'foo':
            $x = 1;
            break;

        case 'bar':
            $x = 2;
            break;
    }

    // $x is potentially undefined here.
    echo $x;
}
			if($success){
				$this->_total_updates++;
				EE_Error::add_success( sprintf(__("Successfully updated %s with csv data %s", "event_espresso"),$model->get_this_model_name(),implode(",",$model_object_data_for_update)));
				//we should still record the mapping even though it was an update
				//because if we were going to insert somethign but it was going to conflict
				//we would have last-minute decided to update. So we'd like to know what we updated
				//and so we record what record ended up being updated using the mapping
				if( $model->has_primary_key_field() ){
					$new_key_for_mapping = $model_object_data[ $model->primary_key_name() ];
				}else{
					//no primary key just a combined key
					$new_key_for_mapping = $model->get_index_primary_key_string( $model_object_data );
				}
				$old_db_to_new_db_mapping[ $model->get_this_model_name() ][ $id_in_csv ] = $new_key_for_mapping;
			}else{
				$matched_items = $model->get_all(array($conditions));
				if( ! $matched_items){

					//no items were matched (so we shouldn't have updated)... but then we should have inserted? what the heck?
					$this->_total_update_errors++;
					EE_Error::add_error( sprintf(__("Could not update %s with the csv data: '%s' for an unknown reason (using WHERE conditions %s)", "event_espresso"),$model->get_this_model_name(),http_build_query($model_object_data),http_build_query($conditions)), __FILE__, __FUNCTION__, __LINE__ );
				}else{
					$this->_total_updates++;
					EE_Error::add_success( sprintf(__("%s with csv data '%s' was found in the database and didn't need updating because all the data is identical.", "event_espresso"),$model->get_this_model_name(),implode(",",$model_object_data)));
				}
			}
		}catch(EE_Error $e){
			$this->_total_update_errors++;
			$basic_message = sprintf(__("Could not update %s with the csv data: %s because %s", "event_espresso"),$model->get_this_model_name(),implode(",",$model_object_data),$e->getMessage());
			$debug_message = $basic_message . ' Stack trace: ' . $e->getTraceAsString();
			EE_Error::add_error( "$basic_message | $debug_message", __FILE__, __FUNCTION__, __LINE__ );
		}
		return $old_db_to_new_db_mapping;
	}

	/**
	 * Gets the number of inserts performed since importer was instantiated or reset
	 * @return int
	 */
	public function get_total_inserts(){
		return $this->_total_inserts;
	}
	/**
	 *  Gets the number of insert errors since importer was instantiated or reset
	 * @return int
	 */
	public function get_total_insert_errors(){
		return $this->_total_insert_errors;
	}
	/**
	 *  Gets the number of updates performed since importer was instantiated or reset
	 * @return int
	 */
	public function get_total_updates(){
		return $this->_total_updates;
	}
	/**
	 *  Gets the number of update errors since importer was instantiated or reset
	 * @return int
	 */
	public function get_total_update_errors(){
		return $this->_total_update_errors;
	}





}
/* End of file EE_Import.class.php */
/* Location: /includes/classes/EE_Import.class.php */
?>
eventespresso / event-espresso-core

Branch — BUG-9077-negative-payments (99f903)

EE_Import::instance() A

Complexity

Size

Duplication

Available Fixes

Duplication Side-by-Side

Filter issues like
