eventespresso / event-espresso-core

core/data_migration_scripts/EE_DMS_Core_4_2_0.dms.php

Indentation +167 added lines, -167 removed lines

@@ -10,11 +10,11 @@ 
 $stages            = glob(EE_CORE . 'data_migration_scripts/4_2_0_stages/*');
 $class_to_filepath = [];
 if (! empty($stages)) {
-    foreach ($stages as $filepath) {
-        $matches = [];
-        preg_match('~4_2_0_stages/(.*).dmsstage.php~', $filepath, $matches);
-        $class_to_filepath[ $matches[1] ] = $filepath;
-    }
+	foreach ($stages as $filepath) {
+		$matches = [];
+		preg_match('~4_2_0_stages/(.*).dmsstage.php~', $filepath, $matches);
+		$class_to_filepath[ $matches[1] ] = $filepath;
+	}
 }
 // give addons a chance to autoload their stages too
 $class_to_filepath = apply_filters('FHEE__EE_DMS_4_2_0__autoloaded_stages', $class_to_filepath);
@@ -32,64 +32,64 @@ 
  */
 class EE_DMS_Core_4_2_0 extends EE_Data_Migration_Script_Base
 {
-    /**
-     * EE_DMS_Core_4_2_0 constructor.
-     *
-     * @param TableManager|null  $table_manager
-     * @param TableAnalysis|null $table_analysis
-     */
-    public function __construct(TableManager $table_manager = null, TableAnalysis $table_analysis = null)
-    {
-        $this->_pretty_name      = esc_html__("Data Update to Event Espresso 4.2.0", "event_espresso");
-        $this->_priority         = 10;
-        $this->_migration_stages = [
-            new EE_DMS_4_2_0_question_group_questions(),
-            new EE_DMS_4_2_0_datetime_fields(),
-        ];
-        parent::__construct($table_manager, $table_analysis);
-    }
-
-
-    public function can_migrate_from_version($version_array)
-    {
-        $version_string = $version_array['Core'];
-        if (
-            version_compare($version_string, '4.2.0.decaf', '<') &&
-            version_compare($version_string, '4.1.0.decaf', '>=')
-        ) {
-            //          echo "$version_string can be migrated fro";
-            return true;
-        } elseif (! $version_string) {
-            //          echo "no version string provided: $version_string";
-            // no version string provided... this must be pre 4.1
-            // because since 4.1 we're
-            return false;// changed mind. dont want people thinking they should migrate yet because they cant
-        } else {
-            //          echo "$version_string doesnt apply";
-            return false;
-        }
-    }
-
-
-    /**
-     * @throws EE_Error
-     * @throws ReflectionException
-     */
-    public function schema_changes_before_migration()
-    {
-        // relies on 4.1's EEH_Activation::create_table
-        require_once(EE_HELPERS . 'EEH_Activation.helper.php');
-
-        $table_name = 'esp_answer';
-        $sql        = "ANS_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
+	/**
+	 * EE_DMS_Core_4_2_0 constructor.
+	 *
+	 * @param TableManager|null  $table_manager
+	 * @param TableAnalysis|null $table_analysis
+	 */
+	public function __construct(TableManager $table_manager = null, TableAnalysis $table_analysis = null)
+	{
+		$this->_pretty_name      = esc_html__("Data Update to Event Espresso 4.2.0", "event_espresso");
+		$this->_priority         = 10;
+		$this->_migration_stages = [
+			new EE_DMS_4_2_0_question_group_questions(),
+			new EE_DMS_4_2_0_datetime_fields(),
+		];
+		parent::__construct($table_manager, $table_analysis);
+	}
+
+
+	public function can_migrate_from_version($version_array)
+	{
+		$version_string = $version_array['Core'];
+		if (
+			version_compare($version_string, '4.2.0.decaf', '<') &&
+			version_compare($version_string, '4.1.0.decaf', '>=')
+		) {
+			//          echo "$version_string can be migrated fro";
+			return true;
+		} elseif (! $version_string) {
+			//          echo "no version string provided: $version_string";
+			// no version string provided... this must be pre 4.1
+			// because since 4.1 we're
+			return false;// changed mind. dont want people thinking they should migrate yet because they cant
+		} else {
+			//          echo "$version_string doesnt apply";
+			return false;
+		}
+	}
+
+
+	/**
+	 * @throws EE_Error
+	 * @throws ReflectionException
+	 */
+	public function schema_changes_before_migration()
+	{
+		// relies on 4.1's EEH_Activation::create_table
+		require_once(EE_HELPERS . 'EEH_Activation.helper.php');
+
+		$table_name = 'esp_answer';
+		$sql        = "ANS_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
 					REG_ID int(10) unsigned NOT NULL,
 					QST_ID int(10) unsigned NOT NULL,
 					ANS_value text NOT NULL,
 					PRIMARY KEY  (ANS_ID)";
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = 'esp_attendee_meta';
-        $sql        = "ATTM_ID int(10) unsigned NOT	NULL AUTO_INCREMENT,
+		$table_name = 'esp_attendee_meta';
+		$sql        = "ATTM_ID int(10) unsigned NOT	NULL AUTO_INCREMENT,
 						ATT_ID bigint(20) unsigned NOT NULL,
 						ATT_fname varchar(45) NOT NULL,
 						ATT_lname varchar(45) NOT	NULL,
@@ -105,10 +105,10 @@ 
 								KEY ATT_fname (ATT_fname),
 								KEY ATT_lname (ATT_lname),
 								KEY ATT_email (ATT_email(191))";
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
 
-        $table_name = 'esp_country';
-        $sql        = "CNT_ISO varchar(2) COLLATE utf8_bin NOT NULL,
+		$table_name = 'esp_country';
+		$sql        = "CNT_ISO varchar(2) COLLATE utf8_bin NOT NULL,
 					  CNT_ISO3 varchar(3) COLLATE utf8_bin NOT NULL,
 					  RGN_ID tinyint(3) unsigned DEFAULT NULL,
 					  CNT_name varchar(45) COLLATE utf8_bin NOT NULL,
@@ -124,10 +124,10 @@ 
 					  CNT_is_EU tinyint(1) DEFAULT '0',
 					  CNT_active tinyint(1) DEFAULT '0',
 					  PRIMARY KEY  (CNT_ISO)";
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = 'esp_datetime';
-        $sql        = "DTT_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
+		$table_name = 'esp_datetime';
+		$sql        = "DTT_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
 				  EVT_ID bigint(20) unsigned NOT NULL,
 				  DTT_name varchar(255) NOT NULL DEFAULT '',
 				  DTT_description text NOT NULL,
@@ -142,10 +142,10 @@ 
 						PRIMARY KEY  (DTT_ID),
 						KEY EVT_ID (EVT_ID),
 						KEY DTT_is_primary (DTT_is_primary)";
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = 'esp_event_meta';
-        $sql        = "
+		$table_name = 'esp_event_meta';
+		$sql        = "
 			EVTM_ID int(10) NOT NULL AUTO_INCREMENT,
 			EVT_ID bigint(20) unsigned NOT NULL,
 			EVT_display_desc tinyint(1) unsigned NOT NULL DEFAULT 1,
@@ -160,35 +160,35 @@ 
 			EVT_external_URL varchar(200) NULL,
 			EVT_donations tinyint(1) NULL,
 			PRIMARY KEY  (EVTM_ID)";
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = 'esp_event_question_group';
-        $sql        = "EQG_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
+		$table_name = 'esp_event_question_group';
+		$sql        = "EQG_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
 					EVT_ID bigint(20) unsigned NOT NULL,
 					QSG_ID int(10) unsigned NOT NULL,
 					EQG_primary tinyint(1) unsigned NOT NULL DEFAULT 0,
 					PRIMARY KEY  (EQG_ID)";
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = 'esp_event_venue';
-        $sql        = "EVV_ID int(11) NOT NULL AUTO_INCREMENT,
+		$table_name = 'esp_event_venue';
+		$sql        = "EVV_ID int(11) NOT NULL AUTO_INCREMENT,
 				EVT_ID bigint(20) unsigned NOT NULL,
 				VNU_ID bigint(20) unsigned NOT NULL,
 				EVV_primary tinyint(1) unsigned NOT NULL DEFAULT 0,
 				PRIMARY KEY  (EVV_ID)";
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = 'esp_extra_meta';
-        $sql        = "EXM_ID int(11) NOT NULL AUTO_INCREMENT,
+		$table_name = 'esp_extra_meta';
+		$sql        = "EXM_ID int(11) NOT NULL AUTO_INCREMENT,
 				OBJ_ID int(11) DEFAULT NULL,
 				EXM_type varchar(45) DEFAULT NULL,
 				EXM_key varchar(45) DEFAULT NULL,
 				EXM_value text,
 				PRIMARY KEY  (EXM_ID)";
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = 'esp_line_item';
-        $sql        = "LIN_ID int(11) NOT NULL AUTO_INCREMENT,
+		$table_name = 'esp_line_item';
+		$sql        = "LIN_ID int(11) NOT NULL AUTO_INCREMENT,
 				LIN_code varchar(245) NOT NULL DEFAULT '',
 				TXN_ID int(11) DEFAULT NULL,
 				LIN_name varchar(245) NOT NULL DEFAULT '',
@@ -204,20 +204,20 @@ 
 				OBJ_ID int(11) DEFAULT NULL,
 				OBJ_type varchar(45)DEFAULT NULL,
 				PRIMARY KEY  (LIN_ID)";
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = 'esp_message_template';
-        $sql        = "MTP_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
+		$table_name = 'esp_message_template';
+		$sql        = "MTP_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
 					GRP_ID int(10) unsigned NOT NULL,
 					MTP_context varchar(50) NOT NULL,
 					MTP_template_field varchar(30) NOT NULL,
 					MTP_content text NOT NULL,
 					PRIMARY KEY  (MTP_ID),
 					KEY GRP_ID (GRP_ID)";
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = 'esp_message_template_group';
-        $sql        = "GRP_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
+		$table_name = 'esp_message_template_group';
+		$sql        = "GRP_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
 					EVT_ID bigint(20) unsigned DEFAULT NULL,
 					MTP_user_id int(10) NOT NULL DEFAULT '1',
 					MTP_messenger varchar(30) NOT NULL,
@@ -229,10 +229,10 @@ 
 					PRIMARY KEY  (GRP_ID),
 					KEY EVT_ID (EVT_ID),
 					KEY MTP_user_id (MTP_user_id)";
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = 'esp_payment';
-        $sql        = "PAY_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
+		$table_name = 'esp_payment';
+		$sql        = "PAY_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
 					TXN_ID int(10) unsigned DEFAULT NULL,
 					STS_ID varchar(3) COLLATE utf8_bin DEFAULT NULL,
 					PAY_timestamp datetime NOT NULL DEFAULT '0000-00-00 00:00:00',
@@ -248,10 +248,10 @@ 
 					PRIMARY KEY  (PAY_ID),
 					KEY TXN_ID (TXN_ID),
 					KEY PAY_timestamp (PAY_timestamp)";
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
 
-        $table_name = "esp_ticket";
-        $sql        = "TKT_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
+		$table_name = "esp_ticket";
+		$sql        = "TKT_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
 					  TTM_ID int(10) unsigned NOT NULL,
 					  TKT_name varchar(245) NOT NULL DEFAULT '',
 					  TKT_description text NOT NULL,
@@ -270,32 +270,32 @@ 
 					  TKT_parent int(10) unsigned DEFAULT '0',
 					  TKT_deleted tinyint(1) NOT NULL DEFAULT '0',
 					  PRIMARY KEY  (TKT_ID)";
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = "esp_ticket_price";
-        $sql        = "TKP_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
+		$table_name = "esp_ticket_price";
+		$sql        = "TKP_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
 					  TKT_ID int(10) unsigned NOT NULL,
 					  PRC_ID int(10) unsigned NOT NULL,
 					  PRIMARY KEY  (TKP_ID)";
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = "esp_datetime_ticket";
-        $sql        = "DTK_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
+		$table_name = "esp_datetime_ticket";
+		$sql        = "DTK_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
 					  DTT_ID int(10) unsigned NOT NULL,
 					  TKT_ID int(10) unsigned NOT NULL,
 					  PRIMARY KEY  (DTK_ID)";
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = "esp_ticket_template";
-        $sql        = "TTM_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
+		$table_name = "esp_ticket_template";
+		$sql        = "TTM_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
 					  TTM_name varchar(45) NOT NULL,
 					  TTM_description text,
 					  TTM_file varchar(45),
 					  PRIMARY KEY  (TTM_ID)";
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = "esp_price";
-        $sql        = "PRC_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
+		$table_name = "esp_price";
+		$sql        = "PRC_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
 					  PRT_ID tinyint(3) unsigned NOT NULL,
 					  PRC_amount decimal(10,3) NOT NULL DEFAULT '0.00',
 					  PRC_name varchar(245) NOT NULL,
@@ -306,10 +306,10 @@ 
 					  PRC_order tinyint(3) unsigned NOT NULL DEFAULT '0',
 					  PRC_parent int(10) unsigned DEFAULT 0,
 					  PRIMARY KEY  (PRC_ID)";
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = "esp_price_type";
-        $sql        = "PRT_ID tinyint(3) unsigned NOT NULL AUTO_INCREMENT,
+		$table_name = "esp_price_type";
+		$sql        = "PRT_ID tinyint(3) unsigned NOT NULL AUTO_INCREMENT,
 				  PRT_name varchar(45) NOT NULL,
 				  PBT_ID tinyint(3) unsigned NOT NULL DEFAULT '1',
 				  PRT_is_percent tinyint(1) NOT NULL DEFAULT '0',
@@ -317,10 +317,10 @@ 
 				  PRT_deleted tinyint(1) NOT NULL DEFAULT '0',
 				  UNIQUE KEY PRT_name_UNIQUE (PRT_name),
 				  PRIMARY KEY  (PRT_ID)";
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = 'esp_question';
-        $sql        = 'QST_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
+		$table_name = 'esp_question';
+		$sql        = 'QST_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
 					QST_display_text text NOT NULL,
 					QST_admin_label varchar(255) NOT NULL,
 					QST_system varchar(25) DEFAULT NULL,
@@ -332,11 +332,11 @@ 
 					QST_wp_user bigint(20) unsigned NULL,
 					QST_deleted tinyint(1) unsigned NOT NULL DEFAULT 0,
 					PRIMARY KEY  (QST_ID)';
-        $this->_table_should_exist_previously($table_name, $sql);
-        $this->_get_table_manager()->dropIndex('esp_question_group', 'QSG_identifier_UNIQUE');
+		$this->_table_should_exist_previously($table_name, $sql);
+		$this->_get_table_manager()->dropIndex('esp_question_group', 'QSG_identifier_UNIQUE');
 
-        $table_name = 'esp_question_group';
-        $sql        = 'QSG_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
+		$table_name = 'esp_question_group';
+		$sql        = 'QSG_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
 					QSG_name varchar(255) NOT NULL,
 					QSG_identifier varchar(100) NOT NULL,
 					QSG_desc text NULL,
@@ -347,27 +347,27 @@ 
 					QSG_deleted tinyint(1) unsigned NOT NULL DEFAULT 0,
 					PRIMARY KEY  (QSG_ID),
 					UNIQUE KEY QSG_identifier_UNIQUE (QSG_identifier ASC)';
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = 'esp_question_group_question';
-        $sql        = "QGQ_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
+		$table_name = 'esp_question_group_question';
+		$sql        = "QGQ_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
 					QSG_ID int(10) unsigned NOT NULL,
 					QST_ID int(10) unsigned NOT NULL,
 					QGQ_order int(10) unsigned NOT NULL DEFAULT 0,
 					PRIMARY KEY  (QGQ_ID) ";
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = 'esp_question_option';
-        $sql        = "QSO_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
+		$table_name = 'esp_question_option';
+		$sql        = "QSO_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
 					QSO_value varchar(255) NOT NULL,
 					QSO_desc text NOT NULL,
 					QST_ID int(10) unsigned NOT NULL,
 					QSO_deleted tinyint(1) unsigned NOT NULL DEFAULT 0,
 					PRIMARY KEY  (QSO_ID)";
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = 'esp_registration';
-        $sql        = "REG_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
+		$table_name = 'esp_registration';
+		$sql        = "REG_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
 					  EVT_ID bigint(20) unsigned NOT NULL,
 					  ATT_ID bigint(20) unsigned NOT NULL,
 					  TXN_ID int(10) unsigned NOT NULL,
@@ -390,28 +390,28 @@ 
 					  KEY STS_ID (STS_ID),
 					  KEY REG_url_link (REG_url_link),
 					  KEY REG_code (REG_code)";
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
 
-        $table_name = 'esp_checkin';
-        $sql        = "CHK_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
+		$table_name = 'esp_checkin';
+		$sql        = "CHK_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
 					REG_ID int(10) unsigned NOT NULL,
 					DTT_ID int(10) unsigned NOT NULL,
 					CHK_in tinyint(1) unsigned NOT NULL DEFAULT 1,
 					CHK_timestamp datetime NOT NULL DEFAULT '0000-00-00 00:00:00',
 					PRIMARY KEY  (CHK_ID)";
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = 'esp_state';
-        $sql        = "STA_ID smallint(5) unsigned NOT NULL AUTO_INCREMENT,
+		$table_name = 'esp_state';
+		$sql        = "STA_ID smallint(5) unsigned NOT NULL AUTO_INCREMENT,
 					  CNT_ISO varchar(2) COLLATE utf8_bin NOT NULL,
 					  STA_abbrev varchar(6) COLLATE utf8_bin NOT NULL,
 					  STA_name varchar(100) COLLATE utf8_bin NOT NULL,
 					  STA_active tinyint(1) DEFAULT '1',
 					  PRIMARY KEY  (STA_ID)";
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = 'esp_status';
-        $sql        = "STS_ID varchar(3) COLLATE utf8_bin NOT NULL,
+		$table_name = 'esp_status';
+		$sql        = "STS_ID varchar(3) COLLATE utf8_bin NOT NULL,
 					  STS_code varchar(45) COLLATE utf8_bin NOT NULL,
 					  STS_type set('event','registration','transaction','payment','email') COLLATE utf8_bin NOT NULL,
 					  STS_can_edit tinyint(1) NOT NULL DEFAULT 0,
@@ -419,10 +419,10 @@ 
 					  STS_open tinyint(1) NOT NULL DEFAULT 1,
 					  UNIQUE KEY STS_ID_UNIQUE (STS_ID),
 					  KEY STS_type (STS_type)";
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = 'esp_transaction';
-        $sql        = "TXN_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
+		$table_name = 'esp_transaction';
+		$sql        = "TXN_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
 					  TXN_timestamp datetime NOT NULL DEFAULT '0000-00-00 00:00:00',
 					  TXN_total decimal(10,3) DEFAULT '0.00',
 					  TXN_paid decimal(10,3) NOT NULL DEFAULT '0.00',
@@ -432,10 +432,10 @@ 
 					  PRIMARY KEY  (TXN_ID),
 					  KEY TXN_timestamp (TXN_timestamp),
 					  KEY STS_ID (STS_ID)";
-        $this->_table_should_exist_previously($table_name, $sql);
+		$this->_table_should_exist_previously($table_name, $sql);
 
-        $table_name = 'esp_venue_meta';
-        $sql        = "VNUM_ID int(11) NOT NULL AUTO_INCREMENT,
+		$table_name = 'esp_venue_meta';
+		$sql        = "VNUM_ID int(11) NOT NULL AUTO_INCREMENT,
 			VNU_ID bigint(20) unsigned NOT NULL DEFAULT 0,
 			VNU_address varchar(255) DEFAULT NULL,
 			VNU_address2 varchar(255) DEFAULT NULL,
@@ -453,34 +453,34 @@ 
 			PRIMARY KEY  (VNUM_ID),
 			KEY STA_ID (STA_ID),
 			KEY CNT_ISO (CNT_ISO)";
-        $this->_table_should_exist_previously($table_name, $sql);
-        $script_with_defaults = EE_Registry::instance()->load_dms('Core_4_1_0');
-        // setting up the DEFAULT stats and countries is also essential for the data migrations to run
-        // (because many need to convert old string states to foreign keys into the states table)
-        $script_with_defaults->insert_default_states();
-        $script_with_defaults->insert_default_countries();
-        // setting up DEFAULT prices, price types, and tickets is also essential for the price migrations
-        $script_with_defaults->insert_default_price_types();
-        $script_with_defaults->insert_default_prices();
-        $script_with_defaults->insert_default_tickets();
-        // setting up the config wp option pretty well counts as a 'schema change', or at least should happen here
-        EE_Config::instance()->update_espresso_config();
-        return true;
-    }
-
-
-    /**
-     * We COULD clean up the esp_question.QST_order field here. We'll leave it for now
-     *
-     * @return boolean
-     */
-    public function schema_changes_after_migration()
-    {
-        return true;
-    }
-
-
-    public function migration_page_hooks()
-    {
-    }
+		$this->_table_should_exist_previously($table_name, $sql);
+		$script_with_defaults = EE_Registry::instance()->load_dms('Core_4_1_0');
+		// setting up the DEFAULT stats and countries is also essential for the data migrations to run
+		// (because many need to convert old string states to foreign keys into the states table)
+		$script_with_defaults->insert_default_states();
+		$script_with_defaults->insert_default_countries();
+		// setting up DEFAULT prices, price types, and tickets is also essential for the price migrations
+		$script_with_defaults->insert_default_price_types();
+		$script_with_defaults->insert_default_prices();
+		$script_with_defaults->insert_default_tickets();
+		// setting up the config wp option pretty well counts as a 'schema change', or at least should happen here
+		EE_Config::instance()->update_espresso_config();
+		return true;
+	}
+
+
+	/**
+	 * We COULD clean up the esp_question.QST_order field here. We'll leave it for now
+	 *
+	 * @return boolean
+	 */
+	public function schema_changes_after_migration()
+	{
+		return true;
+	}
+
+
+	public function migration_page_hooks()
+	{
+	}
 }

core/data_migration_scripts/4_8_0_stages/EE_DMS_4_8_0_event_subtotals.dmsstage.php

Indentation +97 added lines, -97 removed lines

@@ -9,104 +9,104 @@
  */
 class EE_DMS_4_8_0_event_subtotals extends EE_Data_Migration_Script_Stage_Table
 {
-    public function __construct()
-    {
-        global $wpdb;
-        $this->_old_table       = $wpdb->prefix . 'esp_line_item';
-        $this->_extra_where_sql = ' WHERE LIN_type="sub-total" AND LIN_code="pre-tax-subtotal"';
-        $this->_pretty_name     = esc_html__('Event Sub-total line items', 'event_espresso');
-        parent::__construct();
-    }
+	public function __construct()
+	{
+		global $wpdb;
+		$this->_old_table       = $wpdb->prefix . 'esp_line_item';
+		$this->_extra_where_sql = ' WHERE LIN_type="sub-total" AND LIN_code="pre-tax-subtotal"';
+		$this->_pretty_name     = esc_html__('Event Sub-total line items', 'event_espresso');
+		parent::__construct();
+	}
 
 
-    /**
-     * @throws EE_Error
-     */
-    protected function _migrate_old_row($old_row)
-    {
-        global $wpdb;
-        // what event is this line item for? this can be found by looking at its transaction's registration's EVT_ID
-        $event_id = $wpdb->get_var(
-            $wpdb->prepare(
-                'SELECT EVT_ID FROM ' . $wpdb->prefix . 'esp_registration WHERE TXN_ID=%d LIMIT 1',
-                $old_row['TXN_ID']
-            )
-        );
+	/**
+	 * @throws EE_Error
+	 */
+	protected function _migrate_old_row($old_row)
+	{
+		global $wpdb;
+		// what event is this line item for? this can be found by looking at its transaction's registration's EVT_ID
+		$event_id = $wpdb->get_var(
+			$wpdb->prepare(
+				'SELECT EVT_ID FROM ' . $wpdb->prefix . 'esp_registration WHERE TXN_ID=%d LIMIT 1',
+				$old_row['TXN_ID']
+			)
+		);
 
-        $new_line_item_data       = [
-            'LIN_code'       => 'event-' . $event_id,
-            'TXN_ID'         => $old_row['TXN_ID'],
-            'LIN_name'       => esc_html__('Event', 'event_espresso'),
-            'LIN_desc'       => $old_row['LIN_desc'],
-            'LIN_unit_price' => $old_row['LIN_unit_price'],
-            'LIN_percent'    => $old_row['LIN_percent'],
-            'LIN_is_taxable' => $old_row['LIN_is_taxable'],
-            'LIN_order'      => $old_row['LIN_order'],
-            'LIN_total'      => $old_row['LIN_total'],
-            'LIN_quantity'   => $old_row['LIN_quantity'],
-            'LIN_parent'     => $old_row['LIN_ID'],
-            'LIN_type'       => 'sub-total',
-            'OBJ_type'       => 'Event',
-            'OBJ_ID'         => $event_id,
-        ];
-        $new_line_item_data_types = [
-            '%s',// LIN_code
-            '%d',// TXN_ID
-            '%s',// LIN_name
-            '%s',// LIN_desc
-            '%f',// LIN_unit_price
-            '%f',// LIN_percent
-            '%d',// LIN_is_taxable
-            '%d',// LIN_order
-            '%f',// LIN_total
-            '%d',// LIN_quantity
-            '%d',// LIN_parent
-            '%s',// LIN_type
-            '%s',// OBJ_type
-            '%d',// OBJ_ID
-        ];
-        // insert the new event subtotal line item, pointing to this line item
-        $success = $wpdb->insert($this->_old_table, $new_line_item_data, $new_line_item_data_types);
-        if (! $success) {
-            $this->add_error(
-                $this->_create_error_message_for_db_insertion(
-                    $this->_old_table,
-                    $old_row,
-                    $this->_old_table,
-                    $new_line_item_data,
-                    $new_line_item_data_types
-                )
-            );
-        }
-        $new_line_item_id = $wpdb->insert_id;
-        $this->get_migration_script()->set_mapping(
-            $this->_old_table,
-            $old_row['LIN_ID'],
-            $this->_old_table,
-            $new_line_item_id
-        );
-        $query   = $wpdb->prepare(
-            "UPDATE $this->_old_table SET LIN_parent=%d WHERE LIN_parent = %d AND LIN_ID != %d LIMIT 100",
-            $new_line_item_id,
-            $old_row['LIN_ID'],
-            $new_line_item_id
-        );
-        $success = $wpdb->query($query);
-        if ($success === false) {
-            $this->add_error(
-                sprintf(
-                    esc_html__(
-                        'Error updating rows to new event subtotal %1$s from %2$s. Error was: %3$s, while using query %4$s which had a result of %5$s',
-                        'event_espresso'
-                    ),
-                    $new_line_item_id,
-                    $old_row['LIN_ID'],
-                    $wpdb->last_error,
-                    $query,
-                    false
-                )
-            );
-        }
-        return 1;
-    }
+		$new_line_item_data       = [
+			'LIN_code'       => 'event-' . $event_id,
+			'TXN_ID'         => $old_row['TXN_ID'],
+			'LIN_name'       => esc_html__('Event', 'event_espresso'),
+			'LIN_desc'       => $old_row['LIN_desc'],
+			'LIN_unit_price' => $old_row['LIN_unit_price'],
+			'LIN_percent'    => $old_row['LIN_percent'],
+			'LIN_is_taxable' => $old_row['LIN_is_taxable'],
+			'LIN_order'      => $old_row['LIN_order'],
+			'LIN_total'      => $old_row['LIN_total'],
+			'LIN_quantity'   => $old_row['LIN_quantity'],
+			'LIN_parent'     => $old_row['LIN_ID'],
+			'LIN_type'       => 'sub-total',
+			'OBJ_type'       => 'Event',
+			'OBJ_ID'         => $event_id,
+		];
+		$new_line_item_data_types = [
+			'%s',// LIN_code
+			'%d',// TXN_ID
+			'%s',// LIN_name
+			'%s',// LIN_desc
+			'%f',// LIN_unit_price
+			'%f',// LIN_percent
+			'%d',// LIN_is_taxable
+			'%d',// LIN_order
+			'%f',// LIN_total
+			'%d',// LIN_quantity
+			'%d',// LIN_parent
+			'%s',// LIN_type
+			'%s',// OBJ_type
+			'%d',// OBJ_ID
+		];
+		// insert the new event subtotal line item, pointing to this line item
+		$success = $wpdb->insert($this->_old_table, $new_line_item_data, $new_line_item_data_types);
+		if (! $success) {
+			$this->add_error(
+				$this->_create_error_message_for_db_insertion(
+					$this->_old_table,
+					$old_row,
+					$this->_old_table,
+					$new_line_item_data,
+					$new_line_item_data_types
+				)
+			);
+		}
+		$new_line_item_id = $wpdb->insert_id;
+		$this->get_migration_script()->set_mapping(
+			$this->_old_table,
+			$old_row['LIN_ID'],
+			$this->_old_table,
+			$new_line_item_id
+		);
+		$query   = $wpdb->prepare(
+			"UPDATE $this->_old_table SET LIN_parent=%d WHERE LIN_parent = %d AND LIN_ID != %d LIMIT 100",
+			$new_line_item_id,
+			$old_row['LIN_ID'],
+			$new_line_item_id
+		);
+		$success = $wpdb->query($query);
+		if ($success === false) {
+			$this->add_error(
+				sprintf(
+					esc_html__(
+						'Error updating rows to new event subtotal %1$s from %2$s. Error was: %3$s, while using query %4$s which had a result of %5$s',
+						'event_espresso'
+					),
+					$new_line_item_id,
+					$old_row['LIN_ID'],
+					$wpdb->last_error,
+					$query,
+					false
+				)
+			);
+		}
+		return 1;
+	}
 }

core/data_migration_scripts/EE_Data_Migration_Script_Stage.core.php

Indentation +90 added lines, -90 removed lines

@@ -29,108 +29,108 @@
  */
 abstract class EE_Data_Migration_Script_Stage extends EE_Data_Migration_Class_Base
 {
-    /**
-     * The migration script this is a stage of
-     *
-     * @var EE_Data_Migration_Script_Base
-     */
-    protected EE_Data_Migration_Script_Base $_migration_script;
+	/**
+	 * The migration script this is a stage of
+	 *
+	 * @var EE_Data_Migration_Script_Base
+	 */
+	protected EE_Data_Migration_Script_Base $_migration_script;
 
 
-    /**
-     * This should eb called to essentially 'finalize' construction of the stage.
-     * This isn't done on the main constructor in order to avoid repetitive code. Instead, this is
-     * called by EE_Data_Migration_Script_Base's __construct() method so children don't have to
-     *
-     * @param EE_Data_Migration_Script_Base $migration_script
-     */
-    public function _construct_finalize(EE_Data_Migration_Script_Base $migration_script)
-    {
-        $this->_migration_script = $migration_script;
-    }
+	/**
+	 * This should eb called to essentially 'finalize' construction of the stage.
+	 * This isn't done on the main constructor in order to avoid repetitive code. Instead, this is
+	 * called by EE_Data_Migration_Script_Base's __construct() method so children don't have to
+	 *
+	 * @param EE_Data_Migration_Script_Base $migration_script
+	 */
+	public function _construct_finalize(EE_Data_Migration_Script_Base $migration_script)
+	{
+		$this->_migration_script = $migration_script;
+	}
 
 
-    /**
-     * Migrates X old records to the new format. If a fatal error is encountered it is NOT caught here,
-     * but is propagated upwards for catching. So basically, the _migration_step() function implemented by children
-     * needs to catch exceptions and decide what's a fatal error and what isn't.
-     *
-     * @param int $num_items_to_migrate
-     * @return int
-     */
-    public function migration_step($num_items_to_migrate = 50)
-    {
-        // before we run the migration step, we want ot take note of warnings that get outputted
-        ob_start();
-        $items_migrated = $this->_migration_step($num_items_to_migrate);
-        $output         = ob_get_contents();
-        ob_end_clean();
-        if ($output) {
-            $this->add_error($output);
-        }
-        $this->_records_migrated += $items_migrated;
-        return $items_migrated;
-    }
+	/**
+	 * Migrates X old records to the new format. If a fatal error is encountered it is NOT caught here,
+	 * but is propagated upwards for catching. So basically, the _migration_step() function implemented by children
+	 * needs to catch exceptions and decide what's a fatal error and what isn't.
+	 *
+	 * @param int $num_items_to_migrate
+	 * @return int
+	 */
+	public function migration_step($num_items_to_migrate = 50)
+	{
+		// before we run the migration step, we want ot take note of warnings that get outputted
+		ob_start();
+		$items_migrated = $this->_migration_step($num_items_to_migrate);
+		$output         = ob_get_contents();
+		ob_end_clean();
+		if ($output) {
+			$this->add_error($output);
+		}
+		$this->_records_migrated += $items_migrated;
+		return $items_migrated;
+	}
 
 
-    /**
-     * IMPORTANT: if an error is encountered, or everything is finished, this stage should update its status property
-     * accordingly. Note: it should not alter the count of items migrated. That is done in the public function that
-     * calls this. IMPORTANT: The count of items migrated should ONLY be less than $num_items_to_migrate when it's the
-     * last migration step, otherwise it should always return $num_items_to_migrate. (Eg, if we're migrating attendees
-     * rows from the database, and $num_items_to_migrate is set to 50, then we SHOULD actually migrate 50 rows,but at
-     * very least we MUST report/return 50 items migrated)
-     *
-     * @param int $num_items_to_migrate
-     * @return int number of items ACTUALLY migrated
-     */
-    abstract protected function _migration_step($num_items_to_migrate = 50);
+	/**
+	 * IMPORTANT: if an error is encountered, or everything is finished, this stage should update its status property
+	 * accordingly. Note: it should not alter the count of items migrated. That is done in the public function that
+	 * calls this. IMPORTANT: The count of items migrated should ONLY be less than $num_items_to_migrate when it's the
+	 * last migration step, otherwise it should always return $num_items_to_migrate. (Eg, if we're migrating attendees
+	 * rows from the database, and $num_items_to_migrate is set to 50, then we SHOULD actually migrate 50 rows,but at
+	 * very least we MUST report/return 50 items migrated)
+	 *
+	 * @param int $num_items_to_migrate
+	 * @return int number of items ACTUALLY migrated
+	 */
+	abstract protected function _migration_step($num_items_to_migrate = 50);
 
 
-    /**
-     * Counts the records that have been migrated so far
-     *
-     * @return int
-     */
-    public function count_records_migrated(): int
-    {
-        return $this->_records_migrated;
-    }
+	/**
+	 * Counts the records that have been migrated so far
+	 *
+	 * @return int
+	 */
+	public function count_records_migrated(): int
+	{
+		return $this->_records_migrated;
+	}
 
 
-    /**
-     * returns an array of strings describing errors
-     *
-     * @return array
-     */
-    public function get_errors(): array
-    {
-        return $this->_errors;
-    }
+	/**
+	 * returns an array of strings describing errors
+	 *
+	 * @return array
+	 */
+	public function get_errors(): array
+	{
+		return $this->_errors;
+	}
 
 
-    /**
-     * Sets all the properties of this script stage to match what's in the array, which is assumed
-     * to have been made from the properties_as_array() function.
-     *
-     * @param array $array_of_properties like what's produced from properties_as_array() method
-     */
-    public function instantiate_from_array_of_properties($array_of_properties)
-    {
-        unset($array_of_properties['class']);
-        foreach ($array_of_properties as $property_name => $property_value) {
-            $this->{$property_name} = $property_value;
-        }
-    }
+	/**
+	 * Sets all the properties of this script stage to match what's in the array, which is assumed
+	 * to have been made from the properties_as_array() function.
+	 *
+	 * @param array $array_of_properties like what's produced from properties_as_array() method
+	 */
+	public function instantiate_from_array_of_properties($array_of_properties)
+	{
+		unset($array_of_properties['class']);
+		foreach ($array_of_properties as $property_name => $property_value) {
+			$this->{$property_name} = $property_value;
+		}
+	}
 
 
-    /**
-     * Gets the script this is a stage of
-     *
-     * @return EE_Data_Migration_Script_Base
-     */
-    protected function get_migration_script(): EE_Data_Migration_Script_Base
-    {
-        return $this->_migration_script;
-    }
+	/**
+	 * Gets the script this is a stage of
+	 *
+	 * @return EE_Data_Migration_Script_Base
+	 */
+	protected function get_migration_script(): EE_Data_Migration_Script_Base
+	{
+		return $this->_migration_script;
+	}
 }

core/data_migration_scripts/4_3_0_stages/EE_DMS_4_3_0_event_message_templates.dmsstage.php

Indentation +68 added lines, -68 removed lines

@@ -12,80 +12,80 @@
  */
 class EE_DMS_4_3_0_event_message_templates extends EE_Data_Migration_Script_Stage_Table
 {
-    /**
-     * This property will hold the table name for event_message_templates
-     *
-     * @var string
-     */
-    private string $_emt_table;
+	/**
+	 * This property will hold the table name for event_message_templates
+	 *
+	 * @var string
+	 */
+	private string $_emt_table;
 
 
-    public function __construct()
-    {
-        global $wpdb;
-        $this->_pretty_name = esc_html__('Event Message Templates', 'event_espresso');
-        $this->_old_table   = $wpdb->prefix . "esp_message_template_group";
-        $this->_emt_table   = $wpdb->prefix . "esp_event_message_template";
-        parent::__construct();
-    }
+	public function __construct()
+	{
+		global $wpdb;
+		$this->_pretty_name = esc_html__('Event Message Templates', 'event_espresso');
+		$this->_old_table   = $wpdb->prefix . "esp_message_template_group";
+		$this->_emt_table   = $wpdb->prefix . "esp_event_message_template";
+		parent::__construct();
+	}
 
 
-    protected function _migrate_old_row($old_row)
-    {
-        // foreach row that has an evt_id ..let's create an equivalent entry in the new event_messages_template table to link the message template to the event (since EVT_ID is no longer referenced in esp_message_template_groups )
-        global $wpdb;
-        if ($old_row['EVT_ID'] > 0) {
-            // let's get the EVT for this id so we can update the custom name on the old row.
-            $event_name = 'Custom Template for ' . $wpdb->get_var(
-                $wpdb->prepare(
-                    "SELECT post_title from $wpdb->posts WHERE ID = %d",
-                    absint(
-                        $old_row['EVT_ID']
-                    )
-                )
-            );
+	protected function _migrate_old_row($old_row)
+	{
+		// foreach row that has an evt_id ..let's create an equivalent entry in the new event_messages_template table to link the message template to the event (since EVT_ID is no longer referenced in esp_message_template_groups )
+		global $wpdb;
+		if ($old_row['EVT_ID'] > 0) {
+			// let's get the EVT for this id so we can update the custom name on the old row.
+			$event_name = 'Custom Template for ' . $wpdb->get_var(
+				$wpdb->prepare(
+					"SELECT post_title from $wpdb->posts WHERE ID = %d",
+					absint(
+						$old_row['EVT_ID']
+					)
+				)
+			);
 
-            // update name
-            $updated = $wpdb->update(
-                $this->_old_table,
-                ['MTP_name' => $event_name],
-                ['GRP_ID' => (int) $old_row['GRP_ID']],
-                ['%s'],
-                ['%d']
-            );
+			// update name
+			$updated = $wpdb->update(
+				$this->_old_table,
+				['MTP_name' => $event_name],
+				['GRP_ID' => (int) $old_row['GRP_ID']],
+				['%s'],
+				['%d']
+			);
 
-            $inserted = $wpdb->insert(
-                $this->_emt_table,
-                [
-                    'EVT_ID' => (int) $old_row['EVT_ID'],
-                    'GRP_ID' => (int) $old_row['GRP_ID'],
-                ],
-                ['%d', '%d']
-            );
+			$inserted = $wpdb->insert(
+				$this->_emt_table,
+				[
+					'EVT_ID' => (int) $old_row['EVT_ID'],
+					'GRP_ID' => (int) $old_row['GRP_ID'],
+				],
+				['%d', '%d']
+			);
 
-            if (false === $updated) {
-                $this->add_error(
-                    sprintf(
-                        esc_html__("Error in updating the row in %s setting 'MTP_name = %s", 'event_espresso'),
-                        $this->_old_table,
-                        $event_name
-                    )
-                );
-            }
+			if (false === $updated) {
+				$this->add_error(
+					sprintf(
+						esc_html__("Error in updating the row in %s setting 'MTP_name = %s", 'event_espresso'),
+						$this->_old_table,
+						$event_name
+					)
+				);
+			}
 
-            if (false === $inserted) {
-                $this->add_error(
-                    sprintf(
-                        esc_html__(
-                            "Error in inserting a row into  setting EVT_ID = %d and GRP_ID = %d",
-                            "event_espresso"
-                        ),
-                        $this->_emt_table,
-                        $old_row['EVT_ID'],
-                        $old_row['GRP_ID']
-                    )
-                );
-            }
-        }
-    }
+			if (false === $inserted) {
+				$this->add_error(
+					sprintf(
+						esc_html__(
+							"Error in inserting a row into  setting EVT_ID = %d and GRP_ID = %d",
+							"event_espresso"
+						),
+						$this->_emt_table,
+						$old_row['EVT_ID'],
+						$old_row['GRP_ID']
+					)
+				);
+			}
+		}
+	}
 }

Spacing +3 added lines, -3 removed lines

@@ -24,8 +24,8 @@ 
     {
         global $wpdb;
         $this->_pretty_name = esc_html__('Event Message Templates', 'event_espresso');
-        $this->_old_table   = $wpdb->prefix . "esp_message_template_group";
-        $this->_emt_table   = $wpdb->prefix . "esp_event_message_template";
+        $this->_old_table   = $wpdb->prefix."esp_message_template_group";
+        $this->_emt_table   = $wpdb->prefix."esp_event_message_template";
         parent::__construct();
     }
 
@@ -36,7 +36,7 @@ 
         global $wpdb;
         if ($old_row['EVT_ID'] > 0) {
             // let's get the EVT for this id so we can update the custom name on the old row.
-            $event_name = 'Custom Template for ' . $wpdb->get_var(
+            $event_name = 'Custom Template for '.$wpdb->get_var(
                 $wpdb->prepare(
                     "SELECT post_title from $wpdb->posts WHERE ID = %d",
                     absint(

core/data_migration_scripts/4_1_0_stages/EE_DMS_4_1_0_event_venue.dmsstage.php

Indentation +114 added lines, -114 removed lines

@@ -26,128 +26,128 @@
  */
 class EE_DMS_4_1_0_event_venue extends EE_Data_Migration_Script_Stage
 {
-    /**
-     * @throws EE_Error
-     */
-    public function _migration_step($num_items_to_migrate = 50)
-    {
-        global $wpdb;
-        $start_at_record         = $this->count_records_migrated();
-        $rows                    = $wpdb->get_results(
-            $wpdb->prepare(
-                "SELECT * FROM $this->_old_table AS ev
+	/**
+	 * @throws EE_Error
+	 */
+	public function _migration_step($num_items_to_migrate = 50)
+	{
+		global $wpdb;
+		$start_at_record         = $this->count_records_migrated();
+		$rows                    = $wpdb->get_results(
+			$wpdb->prepare(
+				"SELECT * FROM $this->_old_table AS ev
                     INNER JOIN " . $wpdb->prefix . "events_detail AS e ON ev.event_id=e.id
                     WHERE e.event_status!='D' LIMIT %d,%d",
-                $start_at_record,
-                $num_items_to_migrate
-            ),
-            ARRAY_A
-        );
-        $items_actually_migrated = 0;
-        foreach ($rows as $event_venue_rel) {
-            $this->_insert_new_event_to_venue_rel($event_venue_rel);
-            $items_actually_migrated++;
-        }
-        if ($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()) {
-            $this->set_completed();
-        }
-        return $items_actually_migrated;
-    }
+				$start_at_record,
+				$num_items_to_migrate
+			),
+			ARRAY_A
+		);
+		$items_actually_migrated = 0;
+		foreach ($rows as $event_venue_rel) {
+			$this->_insert_new_event_to_venue_rel($event_venue_rel);
+			$items_actually_migrated++;
+		}
+		if ($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()) {
+			$this->set_completed();
+		}
+		return $items_actually_migrated;
+	}
 
 
-    public function _count_records_to_migrate()
-    {
-        global $wpdb;
-        return $wpdb->get_var(
-            "SELECT COUNT(ev.id) FROM " . $this->_old_table . " AS ev
+	public function _count_records_to_migrate()
+	{
+		global $wpdb;
+		return $wpdb->get_var(
+			"SELECT COUNT(ev.id) FROM " . $this->_old_table . " AS ev
             INNER JOIN " . $wpdb->prefix . 'events_detail AS e ON ev.event_id=e.id
             WHERE e.event_status!="D"'
-        );
-    }
+		);
+	}
 
 
-    public function __construct()
-    {
-        global $wpdb;
-        $this->_old_table   = $wpdb->prefix . "events_venue_rel";
-        $this->_new_table   = $wpdb->prefix . "esp_event_venue";
-        $this->_pretty_name = esc_html__("Event to Venue Relations", "event_espresso");
-        parent::__construct();
-    }
+	public function __construct()
+	{
+		global $wpdb;
+		$this->_old_table   = $wpdb->prefix . "events_venue_rel";
+		$this->_new_table   = $wpdb->prefix . "esp_event_venue";
+		$this->_pretty_name = esc_html__("Event to Venue Relations", "event_espresso");
+		parent::__construct();
+	}
 
 
-    /**
-     * Attempts to insert a new question group in the new format given an old one
-     *
-     * @param array $old_event_venue_rel
-     * @return void
-     * @throws EE_Error
-     * @global wpdb $wpdb
-     */
-    private function _insert_new_event_to_venue_rel(array $old_event_venue_rel): void
-    {
-        global $wpdb;
-        $new_event_id = $this->get_migration_script()->get_mapping_new_pk(
-            $wpdb->prefix . "events_detail",
-            $old_event_venue_rel['event_id'],
-            $wpdb->prefix . "posts"
-        );
-        $new_venue_id = $this->get_migration_script()->get_mapping_new_pk(
-            $wpdb->prefix . "events_venue",
-            $old_event_venue_rel['venue_id'],
-            $wpdb->prefix . "posts"
-        );
-        if (! $new_event_id) {
-            $this->add_error(
-                sprintf(
-                    esc_html__("Could not find 4.1 event id for 3.1 event #%d.", "event_espresso"),
-                    $old_event_venue_rel['event_id']
-                )
-            );
-            return;
-        }
-        if (! $new_venue_id) {
-            $this->add_error(
-                sprintf(
-                    esc_html__("Could not find 4.1 venue id for 3.1 venue #%d.", "event_espresso"),
-                    $old_event_venue_rel['venue_id']
-                )
-            );
-            return;
-        }
-        // first ensure there are no other relation entries for this event
-        // because although EE4 supports it, EE3 didn't really
-        $wpdb->delete(
-            $this->_new_table,
-            [
-                'EVT_ID' => $new_event_id,
-            ],
-            [
-                '%d',// EVT_ID
-            ]
-        );
-        //      echo "last query". $wpdb->last_query;die;
-        $cols_n_values = [
-            'EVT_ID'      => $new_event_id,
-            'VNU_ID'      => $new_venue_id,
-            'EVV_primary' => true,
-        ];
-        $data_types    = [
-            '%d',// EVT_ID
-            '%d',// VNU_ID
-            '%d',// EVT_primary
-        ];
-        $success       = $wpdb->insert($this->_new_table, $cols_n_values, $data_types);
-        if (! $success) {
-            $this->add_error(
-                $this->get_migration_script()->_create_error_message_for_db_insertion(
-                    $this->_old_table,
-                    $old_event_venue_rel,
-                    $this->_new_table,
-                    $cols_n_values,
-                    $data_types
-                )
-            );
-        }
-    }
+	/**
+	 * Attempts to insert a new question group in the new format given an old one
+	 *
+	 * @param array $old_event_venue_rel
+	 * @return void
+	 * @throws EE_Error
+	 * @global wpdb $wpdb
+	 */
+	private function _insert_new_event_to_venue_rel(array $old_event_venue_rel): void
+	{
+		global $wpdb;
+		$new_event_id = $this->get_migration_script()->get_mapping_new_pk(
+			$wpdb->prefix . "events_detail",
+			$old_event_venue_rel['event_id'],
+			$wpdb->prefix . "posts"
+		);
+		$new_venue_id = $this->get_migration_script()->get_mapping_new_pk(
+			$wpdb->prefix . "events_venue",
+			$old_event_venue_rel['venue_id'],
+			$wpdb->prefix . "posts"
+		);
+		if (! $new_event_id) {
+			$this->add_error(
+				sprintf(
+					esc_html__("Could not find 4.1 event id for 3.1 event #%d.", "event_espresso"),
+					$old_event_venue_rel['event_id']
+				)
+			);
+			return;
+		}
+		if (! $new_venue_id) {
+			$this->add_error(
+				sprintf(
+					esc_html__("Could not find 4.1 venue id for 3.1 venue #%d.", "event_espresso"),
+					$old_event_venue_rel['venue_id']
+				)
+			);
+			return;
+		}
+		// first ensure there are no other relation entries for this event
+		// because although EE4 supports it, EE3 didn't really
+		$wpdb->delete(
+			$this->_new_table,
+			[
+				'EVT_ID' => $new_event_id,
+			],
+			[
+				'%d',// EVT_ID
+			]
+		);
+		//      echo "last query". $wpdb->last_query;die;
+		$cols_n_values = [
+			'EVT_ID'      => $new_event_id,
+			'VNU_ID'      => $new_venue_id,
+			'EVV_primary' => true,
+		];
+		$data_types    = [
+			'%d',// EVT_ID
+			'%d',// VNU_ID
+			'%d',// EVT_primary
+		];
+		$success       = $wpdb->insert($this->_new_table, $cols_n_values, $data_types);
+		if (! $success) {
+			$this->add_error(
+				$this->get_migration_script()->_create_error_message_for_db_insertion(
+					$this->_old_table,
+					$old_event_venue_rel,
+					$this->_new_table,
+					$cols_n_values,
+					$data_types
+				)
+			);
+		}
+	}
 }

core/data_migration_scripts/4_1_0_stages/EE_DMS_4_1_0_event_category.dmsstage.php

Indentation +126 added lines, -126 removed lines

@@ -26,136 +26,136 @@
  */
 class EE_DMS_4_1_0_event_category extends EE_Data_Migration_Script_Stage
 {
-    /**
-     * @throws EE_Error
-     */
-    public function _migration_step($num_items_to_migrate = 50)
-    {
-        global $wpdb;
-        $start_at_record         = $this->count_records_migrated();
-        $rows                    =
-            $wpdb->get_results(
-                $wpdb->prepare("SELECT * FROM $this->_old_table LIMIT %d,%d", $start_at_record, $num_items_to_migrate),
-                ARRAY_A
-            );
-        $items_actually_migrated = 0;
-        foreach ($rows as $event_venue_rel) {
-            $term_relation_id = $this->_add_relation_from_event_to_term_taxonomy($event_venue_rel);
-            if ($term_relation_id) {
-                $this->get_migration_script()->set_mapping(
-                    $this->_old_table,
-                    $event_venue_rel['id'],
-                    $this->_new_table,
-                    $term_relation_id
-                );
-            }
-            $items_actually_migrated++;
-        }
-        if ($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()) {
-            $this->set_completed();
-        }
-        return $items_actually_migrated;
-    }
+	/**
+	 * @throws EE_Error
+	 */
+	public function _migration_step($num_items_to_migrate = 50)
+	{
+		global $wpdb;
+		$start_at_record         = $this->count_records_migrated();
+		$rows                    =
+			$wpdb->get_results(
+				$wpdb->prepare("SELECT * FROM $this->_old_table LIMIT %d,%d", $start_at_record, $num_items_to_migrate),
+				ARRAY_A
+			);
+		$items_actually_migrated = 0;
+		foreach ($rows as $event_venue_rel) {
+			$term_relation_id = $this->_add_relation_from_event_to_term_taxonomy($event_venue_rel);
+			if ($term_relation_id) {
+				$this->get_migration_script()->set_mapping(
+					$this->_old_table,
+					$event_venue_rel['id'],
+					$this->_new_table,
+					$term_relation_id
+				);
+			}
+			$items_actually_migrated++;
+		}
+		if ($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()) {
+			$this->set_completed();
+		}
+		return $items_actually_migrated;
+	}
 
 
-    public function _count_records_to_migrate()
-    {
-        global $wpdb;
-        return $wpdb->get_var("SELECT COUNT(id) FROM " . $this->_old_table);
-    }
+	public function _count_records_to_migrate()
+	{
+		global $wpdb;
+		return $wpdb->get_var("SELECT COUNT(id) FROM " . $this->_old_table);
+	}
 
 
-    public function __construct()
-    {
-        global $wpdb;
-        $this->_old_table   = $wpdb->prefix . "events_category_rel";
-        $this->_new_table   = $wpdb->prefix . "term_relationships";
-        $this->_pretty_name = esc_html__("Event to Category (4.1 Term Relationships)", "event_espresso");
-        parent::__construct();
-    }
+	public function __construct()
+	{
+		global $wpdb;
+		$this->_old_table   = $wpdb->prefix . "events_category_rel";
+		$this->_new_table   = $wpdb->prefix . "term_relationships";
+		$this->_pretty_name = esc_html__("Event to Category (4.1 Term Relationships)", "event_espresso");
+		parent::__construct();
+	}
 
 
-    /**
-     * Attempts to insert a new question group in the new format given an old one
-     *
-     * @param array $old_event_cat_relation
-     * @return int
-     * @throws EE_Error
-     * @global wpdb $wpdb
-     */
-    private function _add_relation_from_event_to_term_taxonomy(array $old_event_cat_relation): int
-    {
-        global $wpdb;
-        $new_event_id         =
-            $this->get_migration_script()->get_mapping_new_pk(
-                $wpdb->prefix . "events_detail",
-                intval($old_event_cat_relation['event_id']),
-                $wpdb->prefix . "posts"
-            );
-        $new_term_taxonomy_id =
-            $this->get_migration_script()->get_mapping_new_pk(
-                $wpdb->prefix . "events_category_detail",
-                intval($old_event_cat_relation['cat_id']),
-                $wpdb->prefix . "term_taxonomy"
-            );
-        if (! $new_event_id) {
-            $this->add_error(
-                sprintf(
-                    esc_html__("Could not find 4.1 event id for 3.1 event #%d.", "event_espresso"),
-                    $old_event_cat_relation['event_id']
-                )
-            );
-            return 0;
-        }
-        if (! $new_term_taxonomy_id) {
-            $this->add_error(
-                sprintf(
-                    esc_html__("Could not find 4.1 term-taxonomy id for 3.1 category #%d.", "event_espresso"),
-                    $old_event_cat_relation['cat_id']
-                )
-            );
-            return 0;
-        }
-        $cols_n_values = [
-            'object_id'        => $new_event_id,
-            'term_taxonomy_id' => $new_term_taxonomy_id,
-            'term_order'       => 0,
-        ];
-        $data_types    = [
-            '%d',// object_id
-            '%d',// term_taxonomy_id
-            '%d',// term_order
-        ];
-        $success       = $wpdb->insert($this->_new_table, $cols_n_values, $data_types);
-        if (! $success) {
-            $this->add_error(
-                $this->get_migration_script()->_create_error_message_for_db_insertion(
-                    $this->_old_table,
-                    $old_event_cat_relation,
-                    $this->_new_table,
-                    $cols_n_values,
-                    $data_types
-                )
-            );
-            return 0;
-        } else {
-            // increment the term-taxonomies count
-            $success =
-                $wpdb->query(
-                    $wpdb->prepare(
-                        "UPDATE $wpdb->term_taxonomy SET count = count +1 WHERE term_taxonomy_id=%d",
-                        $new_term_taxonomy_id
-                    )
-                );
-            if (! $success) {
-                $this->add_error(
-                    sprintf(
-                        esc_html__('Could not increment term_taxonomy\'s count because %s', 'event_espresso'),
-                        $wpdb->last_error
-                    )
-                );
-            }
-        }
-        return $wpdb->insert_id;
-    }
+	/**
+	 * Attempts to insert a new question group in the new format given an old one
+	 *
+	 * @param array $old_event_cat_relation
+	 * @return int
+	 * @throws EE_Error
+	 * @global wpdb $wpdb
+	 */
+	private function _add_relation_from_event_to_term_taxonomy(array $old_event_cat_relation): int
+	{
+		global $wpdb;
+		$new_event_id         =
+			$this->get_migration_script()->get_mapping_new_pk(
+				$wpdb->prefix . "events_detail",
+				intval($old_event_cat_relation['event_id']),
+				$wpdb->prefix . "posts"
+			);
+		$new_term_taxonomy_id =
+			$this->get_migration_script()->get_mapping_new_pk(
+				$wpdb->prefix . "events_category_detail",
+				intval($old_event_cat_relation['cat_id']),
+				$wpdb->prefix . "term_taxonomy"
+			);
+		if (! $new_event_id) {
+			$this->add_error(
+				sprintf(
+					esc_html__("Could not find 4.1 event id for 3.1 event #%d.", "event_espresso"),
+					$old_event_cat_relation['event_id']
+				)
+			);
+			return 0;
+		}
+		if (! $new_term_taxonomy_id) {
+			$this->add_error(
+				sprintf(
+					esc_html__("Could not find 4.1 term-taxonomy id for 3.1 category #%d.", "event_espresso"),
+					$old_event_cat_relation['cat_id']
+				)
+			);
+			return 0;
+		}
+		$cols_n_values = [
+			'object_id'        => $new_event_id,
+			'term_taxonomy_id' => $new_term_taxonomy_id,
+			'term_order'       => 0,
+		];
+		$data_types    = [
+			'%d',// object_id
+			'%d',// term_taxonomy_id
+			'%d',// term_order
+		];
+		$success       = $wpdb->insert($this->_new_table, $cols_n_values, $data_types);
+		if (! $success) {
+			$this->add_error(
+				$this->get_migration_script()->_create_error_message_for_db_insertion(
+					$this->_old_table,
+					$old_event_cat_relation,
+					$this->_new_table,
+					$cols_n_values,
+					$data_types
+				)
+			);
+			return 0;
+		} else {
+			// increment the term-taxonomies count
+			$success =
+				$wpdb->query(
+					$wpdb->prepare(
+						"UPDATE $wpdb->term_taxonomy SET count = count +1 WHERE term_taxonomy_id=%d",
+						$new_term_taxonomy_id
+					)
+				);
+			if (! $success) {
+				$this->add_error(
+					sprintf(
+						esc_html__('Could not increment term_taxonomy\'s count because %s', 'event_espresso'),
+						$wpdb->last_error
+					)
+				);
+			}
+		}
+		return $wpdb->insert_id;
+	}
 }

core/data_migration_scripts/4_1_0_stages/EE_DMS_4_1_0_line_items.dmsstage.php

Indentation +226 added lines, -226 removed lines

@@ -44,251 +44,251 @@
  */
 class EE_DMS_4_1_0_line_items extends EE_Data_Migration_Script_Stage_Table
 {
-    private string $_new_line_table;
+	private string $_new_line_table;
 
-    private string $_new_transaction_table;
+	private string $_new_transaction_table;
 
-    private string $_new_reg_table;
+	private string $_new_reg_table;
 
 
-    public function __construct()
-    {
-        global $wpdb;
-        $this->_pretty_name           = esc_html__("Line Items", "event_espresso");
-        $this->_old_table             = $wpdb->prefix . "events_attendee";
-        $this->select_expression      = 'att.*, e.event_status';
-        $this->_extra_where_sql       = ' AS att
+	public function __construct()
+	{
+		global $wpdb;
+		$this->_pretty_name           = esc_html__("Line Items", "event_espresso");
+		$this->_old_table             = $wpdb->prefix . "events_attendee";
+		$this->select_expression      = 'att.*, e.event_status';
+		$this->_extra_where_sql       = ' AS att
             INNER JOIN ' . $wpdb->prefix . 'events_detail AS e ON att.event_id=e.id
             WHERE e.event_status!="D"';
-        $this->_new_transaction_table = $wpdb->prefix . "esp_transaction";
-        $this->_new_line_table        = $wpdb->prefix . "esp_line_item";
-        $this->_new_reg_table         = $wpdb->prefix . "esp_registration";
-        parent::__construct();
-    }
+		$this->_new_transaction_table = $wpdb->prefix . "esp_transaction";
+		$this->_new_line_table        = $wpdb->prefix . "esp_line_item";
+		$this->_new_reg_table         = $wpdb->prefix . "esp_registration";
+		parent::__construct();
+	}
 
 
-    /**
-     * @throws EE_Error
-     */
-    protected function _migrate_old_row($old_row)
-    {
-        // insert line items if its a primary id
-        if ((int) $old_row['is_primary']) {
-            $txn_id = (int) $this->get_migration_script()->get_mapping_new_pk(
-                $this->_old_table,
-                $old_row['id'],
-                $this->_new_transaction_table
-            );
-            if (! $txn_id) {
-                $this->add_error(
-                    sprintf(
-                        esc_html__(
-                            "Could not find the transaction for the 3.1 attendee %d from row %s",
-                            "event_espresso"
-                        ),
-                        $old_row['id'],
-                        $this->_json_encode($old_row)
-                    )
-                );
-                return;
-            }
-            $txn            = $this->_get_txn($txn_id);
-            $new_line_items = $this->_insert_new_line_items($txn, $old_row);
-            $this->get_migration_script()->set_mapping(
-                $this->_old_table,
-                $old_row['id'],
-                $this->_new_line_table,
-                $new_line_items
-            );
-        }
-    }
+	/**
+	 * @throws EE_Error
+	 */
+	protected function _migrate_old_row($old_row)
+	{
+		// insert line items if its a primary id
+		if ((int) $old_row['is_primary']) {
+			$txn_id = (int) $this->get_migration_script()->get_mapping_new_pk(
+				$this->_old_table,
+				$old_row['id'],
+				$this->_new_transaction_table
+			);
+			if (! $txn_id) {
+				$this->add_error(
+					sprintf(
+						esc_html__(
+							"Could not find the transaction for the 3.1 attendee %d from row %s",
+							"event_espresso"
+						),
+						$old_row['id'],
+						$this->_json_encode($old_row)
+					)
+				);
+				return;
+			}
+			$txn            = $this->_get_txn($txn_id);
+			$new_line_items = $this->_insert_new_line_items($txn, $old_row);
+			$this->get_migration_script()->set_mapping(
+				$this->_old_table,
+				$old_row['id'],
+				$this->_new_line_table,
+				$new_line_items
+			);
+		}
+	}
 
 
-    private function _get_txn(int $txn_id)
-    {
-        global $wpdb;
-        return $wpdb->get_row(
-            $wpdb->prepare(
-                "SELECT * FROM $this->_new_transaction_table WHERE TXN_ID=%d",
-                $txn_id
-            ),
-            ARRAY_A
-        );
-    }
+	private function _get_txn(int $txn_id)
+	{
+		global $wpdb;
+		return $wpdb->get_row(
+			$wpdb->prepare(
+				"SELECT * FROM $this->_new_transaction_table WHERE TXN_ID=%d",
+				$txn_id
+			),
+			ARRAY_A
+		);
+	}
 
 
-    /**
-     * In 4.1, we'd normally need more info than just the registrations to make the line items. Ie, we'd need
-     * the transaction, and tax prices at the time of registration. (And probably promotions and other price factors).
-     * But seeing how these are REGs created from 3.1 attendee data, which have
-     *
-     * @param array $transaction
-     * @param array $old_attendee
-     * @return array new line item ids
-     */
-    private function _insert_new_line_items(array $transaction, array $old_attendee): array
-    {
-        global $wpdb;
-        $regs_on_this_transaction = $wpdb->get_results(
-            $wpdb->prepare(
-                "SELECT * FROM $this->_new_reg_table WHERE TXN_ID=%d",
-                $transaction['TXN_ID']
-            ),
-            ARRAY_A
-        );
-        $new_line_item_ids        = [];
-        // create a total ine item
-        $total_line_item_id  = $this->_insert_new_line_item(
-            [
-                'LIN_code'  => 'total',
-                'TXN_ID'    => $transaction['TXN_ID'],
-                'LIN_name'  => esc_html__(
-                    "Total",
-                    "event_espresso"
-                ),
-                'LIN_total' => $transaction['TXN_total'],
-                'LIN_type'  => 'total',
-                'OBJ_ID'    => $transaction['TXN_ID'],
-                'OBJ_type'  => 'Transaction',
-            ],
-            $old_attendee
-        );
-        $new_line_item_ids[] = $total_line_item_id;
-        // create a subtotal line item
-        $reg_total = 0;
-        foreach ($regs_on_this_transaction as $new_reg) {
-            $reg_total += floatval($new_reg['REG_final_price']);
-        }
-        $subtotal_line_item_id = $this->_insert_new_line_item(
-            [
-                'LIN_code'   => 'sub-total',
-                'TXN_ID'     => $transaction['TXN_ID'],
-                'LIN_name'   => esc_html__(
-                    "Subtotal",
-                    "event_espresso"
-                ),
-                'LIN_total'  => $reg_total,
-                'LIN_parent' => $total_line_item_id,
-                'LIN_type'   => 'sub-total',
-            ],
-            $old_attendee
-        );
-        $new_line_item_ids[]   = $subtotal_line_item_id;
-        // group REGs by TKT_ID
-        $regs_by_tkt = [];
-        foreach ($regs_on_this_transaction as $new_reg) {
-            $regs_by_tkt[ $new_reg['TKT_ID'] ][] = $new_reg;
-        }
+	/**
+	 * In 4.1, we'd normally need more info than just the registrations to make the line items. Ie, we'd need
+	 * the transaction, and tax prices at the time of registration. (And probably promotions and other price factors).
+	 * But seeing how these are REGs created from 3.1 attendee data, which have
+	 *
+	 * @param array $transaction
+	 * @param array $old_attendee
+	 * @return array new line item ids
+	 */
+	private function _insert_new_line_items(array $transaction, array $old_attendee): array
+	{
+		global $wpdb;
+		$regs_on_this_transaction = $wpdb->get_results(
+			$wpdb->prepare(
+				"SELECT * FROM $this->_new_reg_table WHERE TXN_ID=%d",
+				$transaction['TXN_ID']
+			),
+			ARRAY_A
+		);
+		$new_line_item_ids        = [];
+		// create a total ine item
+		$total_line_item_id  = $this->_insert_new_line_item(
+			[
+				'LIN_code'  => 'total',
+				'TXN_ID'    => $transaction['TXN_ID'],
+				'LIN_name'  => esc_html__(
+					"Total",
+					"event_espresso"
+				),
+				'LIN_total' => $transaction['TXN_total'],
+				'LIN_type'  => 'total',
+				'OBJ_ID'    => $transaction['TXN_ID'],
+				'OBJ_type'  => 'Transaction',
+			],
+			$old_attendee
+		);
+		$new_line_item_ids[] = $total_line_item_id;
+		// create a subtotal line item
+		$reg_total = 0;
+		foreach ($regs_on_this_transaction as $new_reg) {
+			$reg_total += floatval($new_reg['REG_final_price']);
+		}
+		$subtotal_line_item_id = $this->_insert_new_line_item(
+			[
+				'LIN_code'   => 'sub-total',
+				'TXN_ID'     => $transaction['TXN_ID'],
+				'LIN_name'   => esc_html__(
+					"Subtotal",
+					"event_espresso"
+				),
+				'LIN_total'  => $reg_total,
+				'LIN_parent' => $total_line_item_id,
+				'LIN_type'   => 'sub-total',
+			],
+			$old_attendee
+		);
+		$new_line_item_ids[]   = $subtotal_line_item_id;
+		// group REGs by TKT_ID
+		$regs_by_tkt = [];
+		foreach ($regs_on_this_transaction as $new_reg) {
+			$regs_by_tkt[ $new_reg['TKT_ID'] ][] = $new_reg;
+		}
 
-        // create individual line items
+		// create individual line items
 
-        foreach ($regs_by_tkt as $ticket_id => $regs) {
-            $count      = count($regs);
-            $line_total = 0;
-            foreach ($regs as $new_reg) {
-                $line_total += $new_reg['REG_final_price'];
-            }
-            $a_reg               = reset($regs);
-            $new_ticket          = $this->_get_new_ticket_row($a_reg['TKT_ID']);
-            $reg_line_item_id    = $this->_insert_new_line_item(
-                [
-                    'LIN_code'       => md5(
-                        'Ticket' . $ticket_id . time()
-                    ),
-                    'TXN_ID'         => $transaction['TXN_ID'],
-                    'LIN_name'       => $new_ticket['TKT_name'],
-                    'LIN_unit_price' => $a_reg['REG_final_price'],
-                    'LIN_is_taxable' => false,
-                    'LIN_total'      => $line_total,
-                    'LIN_quantity'   => $count,
-                    'LIN_parent'     => $subtotal_line_item_id,
-                    'OBJ_ID'         => $ticket_id,
-                    'OBJ_type'       => 'Ticket',
-                ],
-                $old_attendee
-            );
-            $new_line_item_ids[] = $reg_line_item_id;
-        }
+		foreach ($regs_by_tkt as $ticket_id => $regs) {
+			$count      = count($regs);
+			$line_total = 0;
+			foreach ($regs as $new_reg) {
+				$line_total += $new_reg['REG_final_price'];
+			}
+			$a_reg               = reset($regs);
+			$new_ticket          = $this->_get_new_ticket_row($a_reg['TKT_ID']);
+			$reg_line_item_id    = $this->_insert_new_line_item(
+				[
+					'LIN_code'       => md5(
+						'Ticket' . $ticket_id . time()
+					),
+					'TXN_ID'         => $transaction['TXN_ID'],
+					'LIN_name'       => $new_ticket['TKT_name'],
+					'LIN_unit_price' => $a_reg['REG_final_price'],
+					'LIN_is_taxable' => false,
+					'LIN_total'      => $line_total,
+					'LIN_quantity'   => $count,
+					'LIN_parent'     => $subtotal_line_item_id,
+					'OBJ_ID'         => $ticket_id,
+					'OBJ_type'       => 'Ticket',
+				],
+				$old_attendee
+			);
+			$new_line_item_ids[] = $reg_line_item_id;
+		}
 
 
-        return $new_line_item_ids;
-    }
+		return $new_line_item_ids;
+	}
 
 
-    /**
-     * Gets the full ticket by ID
-     *
-     * @param int   $new_ticket_id
-     * @return array
-     * @global wpdb $wpdb
-     */
-    private function _get_new_ticket_row(int $new_ticket_id): array
-    {
-        global $wpdb;
-        return $wpdb->get_row(
-            $wpdb->prepare(
-                "SELECT * FROM {$wpdb->prefix}esp_ticket WHERE TKT_ID=%d",
-                $new_ticket_id
-            ),
-            ARRAY_A
-        );
-    }
+	/**
+	 * Gets the full ticket by ID
+	 *
+	 * @param int   $new_ticket_id
+	 * @return array
+	 * @global wpdb $wpdb
+	 */
+	private function _get_new_ticket_row(int $new_ticket_id): array
+	{
+		global $wpdb;
+		return $wpdb->get_row(
+			$wpdb->prepare(
+				"SELECT * FROM {$wpdb->prefix}esp_ticket WHERE TKT_ID=%d",
+				$new_ticket_id
+			),
+			ARRAY_A
+		);
+	}
 
 
-    private function _insert_new_line_item(array $cols_n_values, array $old_attendee): int
-    {
-        global $wpdb;
-        $default_cols_n_values = [
-            'LIN_code'       => '',
-            'TXN_ID'         => 0,
-            'LIN_name'       => '',
-            'LIN_desc'       => '',
-            'LIN_unit_price' => 0,
-            'LIN_percent'    => 0,
-            'LIN_is_taxable' => false,
-            'LIN_order'      => 0,
-            'LIN_total'      => 0,
-            'LIN_quantity'   => null,
-            'LIN_parent'     => 0,
-            'LIN_type'       => 'line-item',
-            'OBJ_ID'         => null,
-            'OBJ_type'       => null,
-        ];
-        $cols_n_values         = array_merge($default_cols_n_values, $cols_n_values);
-        $data_types            = [
-            '%s',// LIN_code
-            '%d',// TXN_ID
-            '%s',// LIN_name
-            '%s',// LIN_desc
-            '%f',// LIN_unit_price
-            '%f',// LIN_percent
-            '%d',// LIN_is_taxable
-            '%d',// LIN_order
-            '%f',// LIN_total
-            '%d',// LIN_quantity
-            '%d',// LIN_parent
-            '%s',// LIN_type
-            '%d',// OBJ_ID
-            '%s',// OBJ_type
-        ];
+	private function _insert_new_line_item(array $cols_n_values, array $old_attendee): int
+	{
+		global $wpdb;
+		$default_cols_n_values = [
+			'LIN_code'       => '',
+			'TXN_ID'         => 0,
+			'LIN_name'       => '',
+			'LIN_desc'       => '',
+			'LIN_unit_price' => 0,
+			'LIN_percent'    => 0,
+			'LIN_is_taxable' => false,
+			'LIN_order'      => 0,
+			'LIN_total'      => 0,
+			'LIN_quantity'   => null,
+			'LIN_parent'     => 0,
+			'LIN_type'       => 'line-item',
+			'OBJ_ID'         => null,
+			'OBJ_type'       => null,
+		];
+		$cols_n_values         = array_merge($default_cols_n_values, $cols_n_values);
+		$data_types            = [
+			'%s',// LIN_code
+			'%d',// TXN_ID
+			'%s',// LIN_name
+			'%s',// LIN_desc
+			'%f',// LIN_unit_price
+			'%f',// LIN_percent
+			'%d',// LIN_is_taxable
+			'%d',// LIN_order
+			'%f',// LIN_total
+			'%d',// LIN_quantity
+			'%d',// LIN_parent
+			'%s',// LIN_type
+			'%d',// OBJ_ID
+			'%s',// OBJ_type
+		];
 
-        $success = $wpdb->insert(
-            $this->_new_line_table,
-            $cols_n_values,
-            $data_types
-        );
-        if (! $success) {
-            $this->add_error(
-                $this->get_migration_script()->_create_error_message_for_db_insertion(
-                    $this->_old_table,
-                    $old_attendee,
-                    $this->_new_reg_table,
-                    $cols_n_values,
-                    $data_types
-                )
-            );
-            return 0;
-        }
-        return $wpdb->insert_id;
-    }
+		$success = $wpdb->insert(
+			$this->_new_line_table,
+			$cols_n_values,
+			$data_types
+		);
+		if (! $success) {
+			$this->add_error(
+				$this->get_migration_script()->_create_error_message_for_db_insertion(
+					$this->_old_table,
+					$old_attendee,
+					$this->_new_reg_table,
+					$cols_n_values,
+					$data_types
+				)
+			);
+			return 0;
+		}
+		return $wpdb->insert_id;
+	}
 }

core/data_migration_scripts/4_1_0_stages/EE_DMS_4_1_0_prices.dmsstage.php

Indentation +416 added lines, -416 removed lines

@@ -107,454 +107,454 @@
  */
 class EE_DMS_4_1_0_prices extends EE_Data_Migration_Script_Stage_Table
 {
-    const price_type_base = 1;
+	const price_type_base = 1;
 
-    const price_type_member_discount = 3;
+	const price_type_member_discount = 3;
 
-    const price_type_percent_surcharge = 4;
+	const price_type_percent_surcharge = 4;
 
-    const price_type_flat_surcharge = 5;
+	const price_type_flat_surcharge = 5;
 
-    private string $_new_price_table;
+	private string $_new_price_table;
 
-    private string $_new_ticket_table;
+	private string $_new_ticket_table;
 
-    private string $_new_ticket_price_table;
+	private string $_new_ticket_price_table;
 
-    private string $_new_datetime_ticket_table;
+	private string $_new_datetime_ticket_table;
 
-    /**
-     * A count of all the different tickets created, used for setting the new ones' TKT_Order
-     *
-     * @var int
-     */
-    private int $_ticket_count = 0;
+	/**
+	 * A count of all the different tickets created, used for setting the new ones' TKT_Order
+	 *
+	 * @var int
+	 */
+	private int $_ticket_count = 0;
 
-    private array $price_data_types = [
-        '%d',// PRT_ID
-        '%f',// PRT_amount
-        '%s',// PRC_name
-        '%d',// PRC_is_default
-        '%d',// PRC_overrides
-        '%d',// PRC_order
-        '%d',// PRC_deleted
-        '%d',// PRC_parent
-    ];
+	private array $price_data_types = [
+		'%d',// PRT_ID
+		'%f',// PRT_amount
+		'%s',// PRC_name
+		'%d',// PRC_is_default
+		'%d',// PRC_overrides
+		'%d',// PRC_order
+		'%d',// PRC_deleted
+		'%d',// PRC_parent
+	];
 
 
-    public function __construct()
-    {
-        global $wpdb;
-        $this->_pretty_name               = esc_html__("Prices", "event_espresso");
-        $this->_old_table                 = $wpdb->prefix . "events_prices";
-        $this->select_expression          = 'p.*, e.event_status';
-        $this->_extra_where_sql           = ' AS p
+	public function __construct()
+	{
+		global $wpdb;
+		$this->_pretty_name               = esc_html__("Prices", "event_espresso");
+		$this->_old_table                 = $wpdb->prefix . "events_prices";
+		$this->select_expression          = 'p.*, e.event_status';
+		$this->_extra_where_sql           = ' AS p
             INNER JOIN ' . $wpdb->prefix . 'events_detail AS e ON p.event_id=e.id
             WHERE e.event_status!="D"';
-        $this->_new_price_table           = $wpdb->prefix . "esp_price";
-        $this->_new_ticket_table          = $wpdb->prefix . "esp_ticket";
-        $this->_new_ticket_price_table    = $wpdb->prefix . "esp_ticket_price";
-        $this->_new_datetime_ticket_table = $wpdb->prefix . "esp_datetime_ticket";
-        parent::__construct();
-    }
+		$this->_new_price_table           = $wpdb->prefix . "esp_price";
+		$this->_new_ticket_table          = $wpdb->prefix . "esp_ticket";
+		$this->_new_ticket_price_table    = $wpdb->prefix . "esp_ticket_price";
+		$this->_new_datetime_ticket_table = $wpdb->prefix . "esp_datetime_ticket";
+		parent::__construct();
+	}
 
 
-    /**
-     * @throws EE_Error
-     */
-    protected function _migrate_old_row($old_row)
-    {
-        // create the base price
-        $new_price_id = $this->_insert_new_price($old_row);
-        // create the member discount if there is any
-        // commented-out because we may actually NOT be supporting this in 4.1
-        //      if($old_row['event_cost'] != $old_row['member_price']){
-        //          $member_price_discount_id = $this->_insert_new_member_price($old_row);
-        //      }else{
-        //          $member_price_discount_id = 0;
-        //      }
-        // create the surcharge if there is any
-        if (floatval($old_row['surcharge']) >= 0.01) {
-            $surcharge_price_id = $this->_insert_new_surcharge_price($old_row);
-            $this->get_migration_script()->set_mapping(
-                $this->_old_table,
-                $old_row['id'],
-                $this->_new_price_table,
-                [$new_price_id, $surcharge_price_id]
-            );
-        } else {
-            $surcharge_price_id = 0;
-            $this->get_migration_script()->set_mapping(
-                $this->_old_table,
-                $old_row['id'],
-                $this->_new_price_table,
-                [$new_price_id]
-            );
-        }
-        // associate the ticket to all datetimes for event (ie, this ONE ticket grants access to ALL datetimes, not just one of the attendee's choice.
-        // if the latter were the case, then we'd create a separate ticket for each datetime and have their
-        // association be one-to-one)
-        // create ticket
-        //      $ticket_id = $this->_insert_new_ticket($old_row);
-        //      if($ticket_id){
-        //          $this->get_migration_script()->set_mapping($this->_old_table, $old_row['id'], $this->_new_ticket_table, $ticket_id);
-        //          //associate to the prices
-        //          $this->_insert_ticket_price_relation($ticket_id, $new_price_id);
-        //          $this->_insert_ticket_price_relation($ticket_id, $surcharge_price_id);
-        //          //associate to datetimes for the event
-        //          foreach($this->_get_datetime_ids_for_old_event_id($old_row['event_id']) as $new_datetime_id){
-        //              $this->_insert_datetime_ticket_relation($new_datetime_id, $ticket_id);
-        //          }
-        //      }
-        // create a ticket for each old price -old datetime combo
-        $tickets_for_old_price = [];
-        foreach ($this->_get_datetime_ids_for_old_event_id($old_row['event_id']) as $new_datetime_id) {
-            $ticket_id               = $this->_insert_new_ticket($old_row);
-            $tickets_for_old_price[] = $ticket_id;
-            // associate to old prices
-            $this->_insert_ticket_price_relation($ticket_id, $new_price_id);
-            $this->_insert_ticket_price_relation($ticket_id, $surcharge_price_id);
-            $this->_insert_datetime_ticket_relation($new_datetime_id, $ticket_id);
-        }
-        $this->get_migration_script()->set_mapping(
-            $this->_old_table,
-            $old_row['id'],
-            $this->_new_ticket_table,
-            $tickets_for_old_price
-        );
-    }
+	/**
+	 * @throws EE_Error
+	 */
+	protected function _migrate_old_row($old_row)
+	{
+		// create the base price
+		$new_price_id = $this->_insert_new_price($old_row);
+		// create the member discount if there is any
+		// commented-out because we may actually NOT be supporting this in 4.1
+		//      if($old_row['event_cost'] != $old_row['member_price']){
+		//          $member_price_discount_id = $this->_insert_new_member_price($old_row);
+		//      }else{
+		//          $member_price_discount_id = 0;
+		//      }
+		// create the surcharge if there is any
+		if (floatval($old_row['surcharge']) >= 0.01) {
+			$surcharge_price_id = $this->_insert_new_surcharge_price($old_row);
+			$this->get_migration_script()->set_mapping(
+				$this->_old_table,
+				$old_row['id'],
+				$this->_new_price_table,
+				[$new_price_id, $surcharge_price_id]
+			);
+		} else {
+			$surcharge_price_id = 0;
+			$this->get_migration_script()->set_mapping(
+				$this->_old_table,
+				$old_row['id'],
+				$this->_new_price_table,
+				[$new_price_id]
+			);
+		}
+		// associate the ticket to all datetimes for event (ie, this ONE ticket grants access to ALL datetimes, not just one of the attendee's choice.
+		// if the latter were the case, then we'd create a separate ticket for each datetime and have their
+		// association be one-to-one)
+		// create ticket
+		//      $ticket_id = $this->_insert_new_ticket($old_row);
+		//      if($ticket_id){
+		//          $this->get_migration_script()->set_mapping($this->_old_table, $old_row['id'], $this->_new_ticket_table, $ticket_id);
+		//          //associate to the prices
+		//          $this->_insert_ticket_price_relation($ticket_id, $new_price_id);
+		//          $this->_insert_ticket_price_relation($ticket_id, $surcharge_price_id);
+		//          //associate to datetimes for the event
+		//          foreach($this->_get_datetime_ids_for_old_event_id($old_row['event_id']) as $new_datetime_id){
+		//              $this->_insert_datetime_ticket_relation($new_datetime_id, $ticket_id);
+		//          }
+		//      }
+		// create a ticket for each old price -old datetime combo
+		$tickets_for_old_price = [];
+		foreach ($this->_get_datetime_ids_for_old_event_id($old_row['event_id']) as $new_datetime_id) {
+			$ticket_id               = $this->_insert_new_ticket($old_row);
+			$tickets_for_old_price[] = $ticket_id;
+			// associate to old prices
+			$this->_insert_ticket_price_relation($ticket_id, $new_price_id);
+			$this->_insert_ticket_price_relation($ticket_id, $surcharge_price_id);
+			$this->_insert_datetime_ticket_relation($new_datetime_id, $ticket_id);
+		}
+		$this->get_migration_script()->set_mapping(
+			$this->_old_table,
+			$old_row['id'],
+			$this->_new_ticket_table,
+			$tickets_for_old_price
+		);
+	}
 
 
-    /**
-     * Creates a 4.1 price base type
-     *
-     * @param array $old_price
-     * @return int
-     * @global wpdb $wpdb
-     */
-    private function _insert_new_price(array $old_price): int
-    {
-        global $wpdb;
-        $cols_n_values = [
-            'PRT_ID'         => self::price_type_base,
-            'PRC_amount'     => floatval($old_price['event_cost']),
-            'PRC_name'       => $old_price['price_type'],
-            'PRC_is_default' => false,
-            'PRC_overrides'  => false,
-            'PRC_order'      => 0,
-            'PRC_deleted'    => false,
-            'PRC_parent'     => null,
+	/**
+	 * Creates a 4.1 price base type
+	 *
+	 * @param array $old_price
+	 * @return int
+	 * @global wpdb $wpdb
+	 */
+	private function _insert_new_price(array $old_price): int
+	{
+		global $wpdb;
+		$cols_n_values = [
+			'PRT_ID'         => self::price_type_base,
+			'PRC_amount'     => floatval($old_price['event_cost']),
+			'PRC_name'       => $old_price['price_type'],
+			'PRC_is_default' => false,
+			'PRC_overrides'  => false,
+			'PRC_order'      => 0,
+			'PRC_deleted'    => false,
+			'PRC_parent'     => null,
 
-        ];
-        $success       = $wpdb->insert($this->_new_price_table, $cols_n_values, $this->price_data_types);
-        if (! $success) {
-            $this->add_error(
-                $this->get_migration_script()->_create_error_message_for_db_insertion(
-                    $this->_old_table,
-                    $old_price,
-                    $this->_new_price_table,
-                    $cols_n_values,
-                    $this->price_data_types
-                )
-            );
-            return 0;
-        }
-        return $wpdb->insert_id;
-    }
-    /**
-     * Creates a 4.1 member price discount
-     *
-     * @param array $old_price
-     * @return int
-     * @global wpdb $wpdb
-     */
-    //  private function _insert_new_member_price($old_price){
-    //      $discount_amount = floatval($old_price['event_cost']) - floatval($old_price['member_price']);
-    //      global $wpdb;
-    //      $cols_n_values = array(
-    //          'PRT_ID'=>self::price_type_member_discount,
-    //          'PRC_amount'=>$discount_amount,
-    //          'PRC_name'=>$old_price['member_price_type'],
-    //          'PRC_is_default'=>false,
-    //          'PRC_overrides'=>false,
-    //          'PRC_order'=>10,
-    //          'PRC_deleted'=>false,
-    //          'PRC_parent'=>null
-    //
-    //      );
-    //      $data_types = array(
-    //          '%d',//PRT_ID
-    //          '%f',//PRT_amount
-    //          '%s',//PRC_name
-    //          '%d',//PRC_is_default
-    //          '%d',//PRC_overrides
-    //          '%d',//PRC_order
-    //          '%d',//PRC_deleted
-    //          '%d',//PRC_parent
-    //      );
-    //      $success = $wpdb->insert($this->_new_price_table,$cols_n_values,$data_types);
-    //      if ( ! $success){
-    //          $this->add_error($this->get_migration_script()->_create_error_message_for_db_insertion($this->_old_table, $old_price, $this->_new_price_table, $cols_n_values, $data_types));
-    //          return 0;
-    //      }
-    //      $new_id = $wpdb->insert_id;
-    //      return $new_id;
-    //  }
-    /**
-     * Creates a 4.1 member price discount
-     *
-     * @param array $old_price
-     * @return int
-     * @global wpdb $wpdb
-     */
-    private function _insert_new_surcharge_price(array $old_price): int
-    {
-        if ($old_price['surcharge_type'] == 'flat_rate') {
-            $price_type = self::price_type_flat_surcharge;
-        } else {
-            $price_type = self::price_type_percent_surcharge;
-        }
-        global $wpdb;
-        $cols_n_values = [
-            'PRT_ID'         => $price_type,
-            'PRC_amount'     => floatval($old_price['surcharge']),
-            'PRC_name'       => esc_html__("Surcharge", "event_espresso"),
-            'PRC_is_default' => false,
-            'PRC_overrides'  => false,
-            'PRC_order'      => 20,
-            'PRC_deleted'    => false,
-            'PRC_parent'     => null,
+		];
+		$success       = $wpdb->insert($this->_new_price_table, $cols_n_values, $this->price_data_types);
+		if (! $success) {
+			$this->add_error(
+				$this->get_migration_script()->_create_error_message_for_db_insertion(
+					$this->_old_table,
+					$old_price,
+					$this->_new_price_table,
+					$cols_n_values,
+					$this->price_data_types
+				)
+			);
+			return 0;
+		}
+		return $wpdb->insert_id;
+	}
+	/**
+	 * Creates a 4.1 member price discount
+	 *
+	 * @param array $old_price
+	 * @return int
+	 * @global wpdb $wpdb
+	 */
+	//  private function _insert_new_member_price($old_price){
+	//      $discount_amount = floatval($old_price['event_cost']) - floatval($old_price['member_price']);
+	//      global $wpdb;
+	//      $cols_n_values = array(
+	//          'PRT_ID'=>self::price_type_member_discount,
+	//          'PRC_amount'=>$discount_amount,
+	//          'PRC_name'=>$old_price['member_price_type'],
+	//          'PRC_is_default'=>false,
+	//          'PRC_overrides'=>false,
+	//          'PRC_order'=>10,
+	//          'PRC_deleted'=>false,
+	//          'PRC_parent'=>null
+	//
+	//      );
+	//      $data_types = array(
+	//          '%d',//PRT_ID
+	//          '%f',//PRT_amount
+	//          '%s',//PRC_name
+	//          '%d',//PRC_is_default
+	//          '%d',//PRC_overrides
+	//          '%d',//PRC_order
+	//          '%d',//PRC_deleted
+	//          '%d',//PRC_parent
+	//      );
+	//      $success = $wpdb->insert($this->_new_price_table,$cols_n_values,$data_types);
+	//      if ( ! $success){
+	//          $this->add_error($this->get_migration_script()->_create_error_message_for_db_insertion($this->_old_table, $old_price, $this->_new_price_table, $cols_n_values, $data_types));
+	//          return 0;
+	//      }
+	//      $new_id = $wpdb->insert_id;
+	//      return $new_id;
+	//  }
+	/**
+	 * Creates a 4.1 member price discount
+	 *
+	 * @param array $old_price
+	 * @return int
+	 * @global wpdb $wpdb
+	 */
+	private function _insert_new_surcharge_price(array $old_price): int
+	{
+		if ($old_price['surcharge_type'] == 'flat_rate') {
+			$price_type = self::price_type_flat_surcharge;
+		} else {
+			$price_type = self::price_type_percent_surcharge;
+		}
+		global $wpdb;
+		$cols_n_values = [
+			'PRT_ID'         => $price_type,
+			'PRC_amount'     => floatval($old_price['surcharge']),
+			'PRC_name'       => esc_html__("Surcharge", "event_espresso"),
+			'PRC_is_default' => false,
+			'PRC_overrides'  => false,
+			'PRC_order'      => 20,
+			'PRC_deleted'    => false,
+			'PRC_parent'     => null,
 
-        ];
-        $success       = $wpdb->insert($this->_new_price_table, $cols_n_values, $this->price_data_types);
-        if (! $success) {
-            $this->add_error(
-                $this->get_migration_script()->_create_error_message_for_db_insertion(
-                    $this->_old_table,
-                    $old_price,
-                    $this->_new_price_table,
-                    $cols_n_values,
-                    $this->price_data_types
-                )
-            );
-            return 0;
-        }
-        return $wpdb->insert_id;
-    }
+		];
+		$success       = $wpdb->insert($this->_new_price_table, $cols_n_values, $this->price_data_types);
+		if (! $success) {
+			$this->add_error(
+				$this->get_migration_script()->_create_error_message_for_db_insertion(
+					$this->_old_table,
+					$old_price,
+					$this->_new_price_table,
+					$cols_n_values,
+					$this->price_data_types
+				)
+			);
+			return 0;
+		}
+		return $wpdb->insert_id;
+	}
 
 
-    /**
-     * Inserts a 4.1 ticket based off the 3.1 price, and the price IDs we've already made from the 3.1 price
-     *
-     * @param array $old_price_row array where keys are columns
-     * @return int new ticket id
-     */
-    private function _insert_new_ticket(array $old_price_row): int
-    {
-        global $wpdb;
-        $event_row = $this->_get_event_row($old_price_row['event_id']);
-        if ($old_price_row['surcharge_type'] == 'flat_rate') {
-            $final_ticket_price = floatval($old_price_row['event_cost']) + floatval($old_price_row['surcharge']);
-        } else {// percent surcharge
-            $final_ticket_price =
-                floatval($old_price_row['event_cost']) * (1 + floatval($old_price_row['surcharge']) / 100);
-        }
-        $start_date     =
-            $event_row['registration_start'] .
-            " " .
-            $this->get_migration_script()->convertTimeFromAMPM($event_row['registration_startT']);
-        $start_date_utc = $this->get_migration_script()->convert_date_string_to_utc(
-            $this,
-            $old_price_row,
-            $start_date,
-            $event_row['timezone_string']
-        );
-        $end_date       =
-            $event_row['registration_end'] .
-            " " .
-            $this->get_migration_script()->convertTimeFromAMPM($event_row['registration_endT']);
-        $end_date_utc   = $this->get_migration_script()->convert_date_string_to_utc(
-            $this,
-            $old_price_row,
-            $end_date,
-            $event_row['timezone_string']
-        );
-        $cols_n_values  = [
-            'TTM_ID'          => 0,
-            'TKT_name'        => $old_price_row['price_type'],
-            'TKT_description' => '',
-            'TKT_start_date'  => $start_date_utc,
-            'TKT_end_date'    => $end_date_utc,
-            'TKT_min'         => 0,
-            'TKT_max'         => -1,
-            'TKT_price'       => $final_ticket_price,
-            'TKT_sold'        => 0,
-            // note: this will get calculated as we actually add registrations during the migration
-            'TKT_qty'         => -1,
-            'TKT_uses'        => 1,
-            'TKT_taxable'     => false,
-            // so by default, old prices are NOT taxable. This way they don't suddenly have a sudden spike in prices
-            'TKT_is_default'  => false,
-            'TKT_order'       => $this->_get_ticket_count(),
-            'TKT_row'         => 0,
-            // doesn't matter because UI reset this on first save anyways
-            'TKT_deleted'     => false,
-            'TKT_parent'      => 0,
+	/**
+	 * Inserts a 4.1 ticket based off the 3.1 price, and the price IDs we've already made from the 3.1 price
+	 *
+	 * @param array $old_price_row array where keys are columns
+	 * @return int new ticket id
+	 */
+	private function _insert_new_ticket(array $old_price_row): int
+	{
+		global $wpdb;
+		$event_row = $this->_get_event_row($old_price_row['event_id']);
+		if ($old_price_row['surcharge_type'] == 'flat_rate') {
+			$final_ticket_price = floatval($old_price_row['event_cost']) + floatval($old_price_row['surcharge']);
+		} else {// percent surcharge
+			$final_ticket_price =
+				floatval($old_price_row['event_cost']) * (1 + floatval($old_price_row['surcharge']) / 100);
+		}
+		$start_date     =
+			$event_row['registration_start'] .
+			" " .
+			$this->get_migration_script()->convertTimeFromAMPM($event_row['registration_startT']);
+		$start_date_utc = $this->get_migration_script()->convert_date_string_to_utc(
+			$this,
+			$old_price_row,
+			$start_date,
+			$event_row['timezone_string']
+		);
+		$end_date       =
+			$event_row['registration_end'] .
+			" " .
+			$this->get_migration_script()->convertTimeFromAMPM($event_row['registration_endT']);
+		$end_date_utc   = $this->get_migration_script()->convert_date_string_to_utc(
+			$this,
+			$old_price_row,
+			$end_date,
+			$event_row['timezone_string']
+		);
+		$cols_n_values  = [
+			'TTM_ID'          => 0,
+			'TKT_name'        => $old_price_row['price_type'],
+			'TKT_description' => '',
+			'TKT_start_date'  => $start_date_utc,
+			'TKT_end_date'    => $end_date_utc,
+			'TKT_min'         => 0,
+			'TKT_max'         => -1,
+			'TKT_price'       => $final_ticket_price,
+			'TKT_sold'        => 0,
+			// note: this will get calculated as we actually add registrations during the migration
+			'TKT_qty'         => -1,
+			'TKT_uses'        => 1,
+			'TKT_taxable'     => false,
+			// so by default, old prices are NOT taxable. This way they don't suddenly have a sudden spike in prices
+			'TKT_is_default'  => false,
+			'TKT_order'       => $this->_get_ticket_count(),
+			'TKT_row'         => 0,
+			// doesn't matter because UI reset this on first save anyways
+			'TKT_deleted'     => false,
+			'TKT_parent'      => 0,
 
-        ];
-        $data_types     = [
-            '%d',// TTM_ID
-            '%s',// TKT_name
-            '%s',// TKT_description
-            '%s',// TKT_start_date
-            '%s',// TKT_end_date
-            '%d',// TKT_min
-            '%d',// TKT_max
-            '%f',// TKT_price
-            '%d',// TKT_sold
-            '%d',// TKT_qty
-            '%d',// TKT_uses
-            '%d',// TKT_taxable
-            '%d',// TKT_is_default
-            '%d',// TKT_order
-            '%d',// TKT_row
-            '%d',// TKT_deleted
-            '%d',// TKT_parent
-        ];
-        $success        = $wpdb->insert($this->_new_ticket_table, $cols_n_values, $data_types);
-        if (! $success) {
-            $this->add_error(
-                $this->get_migration_script()->_create_error_message_for_db_insertion(
-                    $this->_old_table,
-                    $old_price_row,
-                    $this->_new_ticket_table,
-                    $cols_n_values,
-                    $data_types
-                )
-            );
-            return 0;
-        }
-        return $wpdb->insert_id;
-    }
+		];
+		$data_types     = [
+			'%d',// TTM_ID
+			'%s',// TKT_name
+			'%s',// TKT_description
+			'%s',// TKT_start_date
+			'%s',// TKT_end_date
+			'%d',// TKT_min
+			'%d',// TKT_max
+			'%f',// TKT_price
+			'%d',// TKT_sold
+			'%d',// TKT_qty
+			'%d',// TKT_uses
+			'%d',// TKT_taxable
+			'%d',// TKT_is_default
+			'%d',// TKT_order
+			'%d',// TKT_row
+			'%d',// TKT_deleted
+			'%d',// TKT_parent
+		];
+		$success        = $wpdb->insert($this->_new_ticket_table, $cols_n_values, $data_types);
+		if (! $success) {
+			$this->add_error(
+				$this->get_migration_script()->_create_error_message_for_db_insertion(
+					$this->_old_table,
+					$old_price_row,
+					$this->_new_ticket_table,
+					$cols_n_values,
+					$data_types
+				)
+			);
+			return 0;
+		}
+		return $wpdb->insert_id;
+	}
 
 
-    /**
-     * Adds a join between a ticket and a price
-     *
-     * @param int   $new_ticket_id
-     * @param int   $new_price_id
-     * @return void
-     * @global wpdb $wpdb
-     */
-    private function _insert_ticket_price_relation(int $new_ticket_id, int $new_price_id): void
-    {
-        global $wpdb;
-        $cols_n_values = [
-            'TKT_ID' => $new_ticket_id,
-            'PRC_ID' => $new_price_id,
-        ];
-        $data_types    = [
-            '%d',// TKT_ID
-            '%d',// PRC_ID
-        ];
-        $success       = $wpdb->insert($this->_new_ticket_price_table, $cols_n_values, $data_types);
-        if (! $success) {
-            $this->add_error(
-                $this->get_migration_script()->_create_error_message_for_db_insertion(
-                    $this->_old_table,
-                    ['ticket id' => $new_ticket_id, 'price id' => $new_price_id],
-                    $this->_new_ticket_price_table,
-                    $cols_n_values,
-                    $data_types
-                )
-            );
-        }
-    }
+	/**
+	 * Adds a join between a ticket and a price
+	 *
+	 * @param int   $new_ticket_id
+	 * @param int   $new_price_id
+	 * @return void
+	 * @global wpdb $wpdb
+	 */
+	private function _insert_ticket_price_relation(int $new_ticket_id, int $new_price_id): void
+	{
+		global $wpdb;
+		$cols_n_values = [
+			'TKT_ID' => $new_ticket_id,
+			'PRC_ID' => $new_price_id,
+		];
+		$data_types    = [
+			'%d',// TKT_ID
+			'%d',// PRC_ID
+		];
+		$success       = $wpdb->insert($this->_new_ticket_price_table, $cols_n_values, $data_types);
+		if (! $success) {
+			$this->add_error(
+				$this->get_migration_script()->_create_error_message_for_db_insertion(
+					$this->_old_table,
+					['ticket id' => $new_ticket_id, 'price id' => $new_price_id],
+					$this->_new_ticket_price_table,
+					$cols_n_values,
+					$data_types
+				)
+			);
+		}
+	}
 
 
-    /**
-     * Adds a join between a ticket and a datetime
-     *
-     * @param int   $new_datetime_id
-     * @param int   $new_ticket_id
-     * @return void
-     * @global wpdb $wpdb
-     */
-    private function _insert_datetime_ticket_relation(int $new_datetime_id, int $new_ticket_id)
-    {
-        global $wpdb;
-        $cols_n_values = [
-            'TKT_ID' => $new_ticket_id,
-            'DTT_ID' => $new_datetime_id,
-        ];
-        $data_types    = [
-            '%d',// TKT_ID
-            '%d',// DTT_ID
-        ];
-        $success       = $wpdb->insert($this->_new_datetime_ticket_table, $cols_n_values, $data_types);
-        if (! $success) {
-            $this->add_error(
-                $this->get_migration_script()->_create_error_message_for_db_insertion(
-                    $this->_old_table,
-                    ['ticket id' => $new_ticket_id, 'datetime id' => $new_datetime_id],
-                    $this->_new_datetime_ticket_table,
-                    $cols_n_values,
-                    $data_types
-                )
-            );
-        }
-    }
+	/**
+	 * Adds a join between a ticket and a datetime
+	 *
+	 * @param int   $new_datetime_id
+	 * @param int   $new_ticket_id
+	 * @return void
+	 * @global wpdb $wpdb
+	 */
+	private function _insert_datetime_ticket_relation(int $new_datetime_id, int $new_ticket_id)
+	{
+		global $wpdb;
+		$cols_n_values = [
+			'TKT_ID' => $new_ticket_id,
+			'DTT_ID' => $new_datetime_id,
+		];
+		$data_types    = [
+			'%d',// TKT_ID
+			'%d',// DTT_ID
+		];
+		$success       = $wpdb->insert($this->_new_datetime_ticket_table, $cols_n_values, $data_types);
+		if (! $success) {
+			$this->add_error(
+				$this->get_migration_script()->_create_error_message_for_db_insertion(
+					$this->_old_table,
+					['ticket id' => $new_ticket_id, 'datetime id' => $new_datetime_id],
+					$this->_new_datetime_ticket_table,
+					$cols_n_values,
+					$data_types
+				)
+			);
+		}
+	}
 
 
-    /**
-     * Simply gets the 3.1 event row data
-     *
-     * @param int   $event_id
-     * @return array
-     * @global wpdb $wpdb
-     */
-    private function _get_event_row(int $event_id): array
-    {
-        global $wpdb;
-        $old_event_table = $wpdb->prefix . "events_detail";
-        return $wpdb->get_row($wpdb->prepare("SELECT * FROM $old_event_table WHERE id=%d", $event_id), ARRAY_A);
-    }
+	/**
+	 * Simply gets the 3.1 event row data
+	 *
+	 * @param int   $event_id
+	 * @return array
+	 * @global wpdb $wpdb
+	 */
+	private function _get_event_row(int $event_id): array
+	{
+		global $wpdb;
+		$old_event_table = $wpdb->prefix . "events_detail";
+		return $wpdb->get_row($wpdb->prepare("SELECT * FROM $old_event_table WHERE id=%d", $event_id), ARRAY_A);
+	}
 
 
-    /**
-     * Gets a higher ticket count than last time it was called (and is persisted between HTTP requests).
-     * Yes we COULD run a query joining events->datetimes->ticket_datetimes->tickets, but this should work fine too
-     *
-     * @return int
-     */
-    private function _get_ticket_count(): int
-    {
-        return $this->_ticket_count++;
-    }
+	/**
+	 * Gets a higher ticket count than last time it was called (and is persisted between HTTP requests).
+	 * Yes we COULD run a query joining events->datetimes->ticket_datetimes->tickets, but this should work fine too
+	 *
+	 * @return int
+	 */
+	private function _get_ticket_count(): int
+	{
+		return $this->_ticket_count++;
+	}
 
 
-    /**
-     * Using the 3.1 event id, gets the 4.1 datetimes for it
-     *
-     * @param int $old_event_id
-     * @return array where values are datetime ids
-     * @throws EE_Error
-     */
-    private function _get_datetime_ids_for_old_event_id(int $old_event_id): array
-    {
-        global $wpdb;
-        $new_cpt_id = $this->get_migration_script()->get_mapping_new_pk(
-            $wpdb->prefix . "events_detail",
-            $old_event_id,
-            $wpdb->posts
-        );
-        return $wpdb->get_col(
-            $wpdb->prepare(
-                "SELECT DTT_ID FROM {$wpdb->prefix}esp_datetime WHERE EVT_ID=%d",
-                $new_cpt_id
-            )
-        );
-    }
+	/**
+	 * Using the 3.1 event id, gets the 4.1 datetimes for it
+	 *
+	 * @param int $old_event_id
+	 * @return array where values are datetime ids
+	 * @throws EE_Error
+	 */
+	private function _get_datetime_ids_for_old_event_id(int $old_event_id): array
+	{
+		global $wpdb;
+		$new_cpt_id = $this->get_migration_script()->get_mapping_new_pk(
+			$wpdb->prefix . "events_detail",
+			$old_event_id,
+			$wpdb->posts
+		);
+		return $wpdb->get_col(
+			$wpdb->prepare(
+				"SELECT DTT_ID FROM {$wpdb->prefix}esp_datetime WHERE EVT_ID=%d",
+				$new_cpt_id
+			)
+		);
+	}
 }
 // @todo: tell users that in 3.1 the limit was on registration PER event,in 4.1 it's limit PER TICKET... SO, if they sell 2 different types of tickets
 //

core/data_migration_scripts/4_1_0_stages/EE_DMS_4_1_0_org_options.dmsstage.php

Indentation +305 added lines, -305 removed lines

@@ -89,322 +89,322 @@
  */
 class EE_DMS_4_1_0_org_options extends EE_Data_Migration_Script_Stage
 {
-    public function __construct()
-    {
-        $this->_pretty_name                        = esc_html__("Organization Options/Config", "event_espresso");
-        $this->_org_options_we_know_how_to_migrate = apply_filters(
-            'FHEE__EE_DMS_4_1_0_org_options__org_options_we_know_how_to_migrate',
-            $this->_org_options_we_know_how_to_migrate
-        );
-        parent::__construct();
-    }
+	public function __construct()
+	{
+		$this->_pretty_name                        = esc_html__("Organization Options/Config", "event_espresso");
+		$this->_org_options_we_know_how_to_migrate = apply_filters(
+			'FHEE__EE_DMS_4_1_0_org_options__org_options_we_know_how_to_migrate',
+			$this->_org_options_we_know_how_to_migrate
+		);
+		parent::__construct();
+	}
 
 
-    public function _migration_step($num_items_to_migrate = 50)
-    {
-        $items_actually_migrated = 0;
-        $old_org_options         = get_option('events_organization_settings');
-        foreach ($this->_org_options_we_know_how_to_migrate as $option_name) {
-            // only bother migrating if there's a setting to migrate. Otherwise we'll just use the default
-            if (isset($old_org_options[ $option_name ])) {
-                $this->_handle_org_option($option_name, $old_org_options[ $option_name ]);
-            }
-            if ($option_name == 'surcharge') {
-                $this->_insert_new_global_surcharge_price($old_org_options);
-            }
-            $items_actually_migrated++;
-        }
+	public function _migration_step($num_items_to_migrate = 50)
+	{
+		$items_actually_migrated = 0;
+		$old_org_options         = get_option('events_organization_settings');
+		foreach ($this->_org_options_we_know_how_to_migrate as $option_name) {
+			// only bother migrating if there's a setting to migrate. Otherwise we'll just use the default
+			if (isset($old_org_options[ $option_name ])) {
+				$this->_handle_org_option($option_name, $old_org_options[ $option_name ]);
+			}
+			if ($option_name == 'surcharge') {
+				$this->_insert_new_global_surcharge_price($old_org_options);
+			}
+			$items_actually_migrated++;
+		}
 
-        $success = EE_Config::instance()->update_espresso_config();
-        if (! $success) {
-            $this->add_error(
-                sprintf(
-                    esc_html__('Could not save EE Config during org options stage. Reason: %s', 'event_espresso'),
-                    EE_Error::get_notices(false)
-                )
-            );
-            EE_Error::overwrite_errors();
-        }
-        EE_Network_Config::instance()->update_config(false, false);
-        if ($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()) {
-            // we may have added new pages and this might be necessary
-            flush_rewrite_rules();
-            $this->set_completed();
-        }
-        return $items_actually_migrated;
-    }
+		$success = EE_Config::instance()->update_espresso_config();
+		if (! $success) {
+			$this->add_error(
+				sprintf(
+					esc_html__('Could not save EE Config during org options stage. Reason: %s', 'event_espresso'),
+					EE_Error::get_notices(false)
+				)
+			);
+			EE_Error::overwrite_errors();
+		}
+		EE_Network_Config::instance()->update_config(false, false);
+		if ($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()) {
+			// we may have added new pages and this might be necessary
+			flush_rewrite_rules();
+			$this->set_completed();
+		}
+		return $items_actually_migrated;
+	}
 
 
-    public function _count_records_to_migrate(): int
-    {
-        return (int) count($this->_org_options_we_know_how_to_migrate);
-    }
+	public function _count_records_to_migrate(): int
+	{
+		return (int) count($this->_org_options_we_know_how_to_migrate);
+	}
 
 
-    private function _handle_org_option($option_name, $value)
-    {
-        $c  = EE_Config::instance();
-        $cn = EE_Network_Config::instance();
-        switch ($option_name) {
-            case 'organization':
-                $c->organization->name = $value;
-                break;
-            case 'organization_street1':
-                $c->organization->address_1 = $value;
-                break;
-            case 'organization_street2':
-                $c->organization->address_2 = $value;
-                break;
-            case 'organization_city':
-                $c->organization->city = $value;
-                break;
-            case 'organization_state':
-                try {
-                    $state                   = $this->get_migration_script()->get_or_create_state($value);
-                    $state_id                = $state['STA_ID'];
-                    $c->organization->STA_ID = $state_id;
-                } catch (EE_Error $e) {
-                }
-                break;
-            case 'organization_zip':
-                $c->organization->zip = $value;
-                break;
-            case 'contact_email':
-                $c->organization->email = $value;
-                break;
-            case 'default_payment_status':
-                $c->registration->default_STS_ID =
-                    $this->get_migration_script()->convert_3_1_payment_status_to_4_1_STS_ID($value);
-                break;
-            case 'organization_country':
-                $iso                      = $this->get_migration_script()->get_iso_from_3_1_country_id($value);
-                $c->organization->CNT_ISO = $iso;
-                $country_row              = $this->get_migration_script()->get_or_create_country($iso);
-                if (! $country_row) {
-                    $this->add_error(
-                        sprintf(
-                            esc_html__(
-                                "Could not set country's currency config because no country exists for ISO %s",
-                                "event_espresso"
-                            ),
-                            $iso
-                        )
-                    );
-                }
-                // can't use EE_Currency_Config's handy constructor because the models are off-limits right now (and it uses them)
-                $c->currency->code    = $country_row['CNT_cur_code'];             // currency code: USD, CAD, EUR
-                $c->currency->name    = $country_row['CNT_cur_single'];           // Dollar
-                $c->currency->plural  = $country_row['CNT_cur_plural'];           // Dollars
-                $c->currency->sign    = $country_row['CNT_cur_sign'];             // currency sign: $
-                $c->currency->sign_b4 = filter_var(
-                    $country_row['CNT_cur_sign_b4'],
-                    FILTER_VALIDATE_BOOLEAN
-                );                                                                // currency sign before or after: $TRUE  or  FALSE$
-                $c->currency->dec_plc = (int) $country_row['CNT_cur_dec_plc'];    // decimal places: 2 = 0.00  3 = 0.000
-                $c->currency->dec_mrk =
-                    $country_row['CNT_cur_dec_mrk'];                              // decimal mark: (comma) ',' = 0,01   or (decimal) '.' = 0.01
-                $c->currency->thsnds  = $country_row['CNT_cur_thsnds'];
-                break;  // thousands separator: (comma) ',' = 1,000   or (decimal) '.' = 1.000
-            //            $c->currency = new EE_Currency_Config($c->organization->CNT_ISO);break;
-            //        case 'currency_symbol': ignore the currency symbol. we'll just go by their country.
-            //            $c->currency->sign = $value;break;
-            case 'show_pending_payment_options':
-                $c->registration->show_pending_payment_options = ($value == 'Y');
-                break;
-            case 'display_address_in_regform':
-                $c->template_settings->display_address_in_regform = ($value == 'Y');
-                break;
-            case 'default_logo_url':
-                $c->organization->logo_url = $value;
-                break;
-            case 'event_page_id':
-                // also, find that post, and changes the shortcode in it from ESPRESSO_PAYMENTS
-                // to ESPRESSO_THANK_YOU
-                $reg_page_post               = get_post($value);
-                $reg_page_post->post_content = str_replace(
-                    "[ESPRESSO_EVENTS]",
-                    "[ESPRESSO_CHECKOUT]",
-                    $reg_page_post->post_content
-                );
-                wp_update_post($reg_page_post);
-                $c->core->reg_page_id = $value;
-                break;
-            case 'return_url':
-                // also, find that post, and changes the shortcode in it from ESPRESSO_PAYMENTS
-                // to ESPRESSO_THANK_YOU
-                $thank_you_page_post               = get_post($value);
-                $thank_you_page_post->post_content = str_replace(
-                    "[ESPRESSO_PAYMENTS]",
-                    "[ESPRESSO_THANK_YOU]",
-                    $thank_you_page_post->post_content
-                );
-                wp_update_post($thank_you_page_post);
-                $c->core->thank_you_page_id = $value;
-                break;
-            case 'cancel_return':
-                $c->core->cancel_page_id = $value;
+	private function _handle_org_option($option_name, $value)
+	{
+		$c  = EE_Config::instance();
+		$cn = EE_Network_Config::instance();
+		switch ($option_name) {
+			case 'organization':
+				$c->organization->name = $value;
+				break;
+			case 'organization_street1':
+				$c->organization->address_1 = $value;
+				break;
+			case 'organization_street2':
+				$c->organization->address_2 = $value;
+				break;
+			case 'organization_city':
+				$c->organization->city = $value;
+				break;
+			case 'organization_state':
+				try {
+					$state                   = $this->get_migration_script()->get_or_create_state($value);
+					$state_id                = $state['STA_ID'];
+					$c->organization->STA_ID = $state_id;
+				} catch (EE_Error $e) {
+				}
+				break;
+			case 'organization_zip':
+				$c->organization->zip = $value;
+				break;
+			case 'contact_email':
+				$c->organization->email = $value;
+				break;
+			case 'default_payment_status':
+				$c->registration->default_STS_ID =
+					$this->get_migration_script()->convert_3_1_payment_status_to_4_1_STS_ID($value);
+				break;
+			case 'organization_country':
+				$iso                      = $this->get_migration_script()->get_iso_from_3_1_country_id($value);
+				$c->organization->CNT_ISO = $iso;
+				$country_row              = $this->get_migration_script()->get_or_create_country($iso);
+				if (! $country_row) {
+					$this->add_error(
+						sprintf(
+							esc_html__(
+								"Could not set country's currency config because no country exists for ISO %s",
+								"event_espresso"
+							),
+							$iso
+						)
+					);
+				}
+				// can't use EE_Currency_Config's handy constructor because the models are off-limits right now (and it uses them)
+				$c->currency->code    = $country_row['CNT_cur_code'];             // currency code: USD, CAD, EUR
+				$c->currency->name    = $country_row['CNT_cur_single'];           // Dollar
+				$c->currency->plural  = $country_row['CNT_cur_plural'];           // Dollars
+				$c->currency->sign    = $country_row['CNT_cur_sign'];             // currency sign: $
+				$c->currency->sign_b4 = filter_var(
+					$country_row['CNT_cur_sign_b4'],
+					FILTER_VALIDATE_BOOLEAN
+				);                                                                // currency sign before or after: $TRUE  or  FALSE$
+				$c->currency->dec_plc = (int) $country_row['CNT_cur_dec_plc'];    // decimal places: 2 = 0.00  3 = 0.000
+				$c->currency->dec_mrk =
+					$country_row['CNT_cur_dec_mrk'];                              // decimal mark: (comma) ',' = 0,01   or (decimal) '.' = 0.01
+				$c->currency->thsnds  = $country_row['CNT_cur_thsnds'];
+				break;  // thousands separator: (comma) ',' = 1,000   or (decimal) '.' = 1.000
+			//            $c->currency = new EE_Currency_Config($c->organization->CNT_ISO);break;
+			//        case 'currency_symbol': ignore the currency symbol. we'll just go by their country.
+			//            $c->currency->sign = $value;break;
+			case 'show_pending_payment_options':
+				$c->registration->show_pending_payment_options = ($value == 'Y');
+				break;
+			case 'display_address_in_regform':
+				$c->template_settings->display_address_in_regform = ($value == 'Y');
+				break;
+			case 'default_logo_url':
+				$c->organization->logo_url = $value;
+				break;
+			case 'event_page_id':
+				// also, find that post, and changes the shortcode in it from ESPRESSO_PAYMENTS
+				// to ESPRESSO_THANK_YOU
+				$reg_page_post               = get_post($value);
+				$reg_page_post->post_content = str_replace(
+					"[ESPRESSO_EVENTS]",
+					"[ESPRESSO_CHECKOUT]",
+					$reg_page_post->post_content
+				);
+				wp_update_post($reg_page_post);
+				$c->core->reg_page_id = $value;
+				break;
+			case 'return_url':
+				// also, find that post, and changes the shortcode in it from ESPRESSO_PAYMENTS
+				// to ESPRESSO_THANK_YOU
+				$thank_you_page_post               = get_post($value);
+				$thank_you_page_post->post_content = str_replace(
+					"[ESPRESSO_PAYMENTS]",
+					"[ESPRESSO_THANK_YOU]",
+					$thank_you_page_post->post_content
+				);
+				wp_update_post($thank_you_page_post);
+				$c->core->thank_you_page_id = $value;
+				break;
+			case 'cancel_return':
+				$c->core->cancel_page_id = $value;
 
-                break;
-            case 'notify_url':
-                $c->core->txn_page_id = $value;
-                break;
-            case 'use_captcha':
-                $c->registration->use_captcha = ($value == 'Y');
-                break;
-            case 'recaptcha_publickey':
-                $c->registration->recaptcha_publickey = $value;
-                break;
-            case 'recaptcha_privatekey':
-                $c->registration->recaptcha_privatekey = $value;
-                break;
-            case 'recaptcha_theme':
-                $c->registration->recaptcha_theme = $value;
-                break;
-            case 'recaptcha_width':
-                $c->registration->recaptcha_width = $value;
-                break;
-            case 'recaptcha_language':
-                $c->registration->recaptcha_language = $value;
-                break;
-            case 'espresso_dashboard_widget':
-                $c->admin->use_dashboard_widget = ($value == 'Y');
-                break;
-            case 'use_personnel_manager':
-                $c->admin->use_personnel_manager = ($value == 'Y');
-                break;
-            case 'use_event_timezones':
-                $c->admin->use_event_timezones = ($value == 'Y');
-                break;
-            case 'affiliate_id':
-                $c->admin->affiliate_id = $value;
-                break;
-            case 'site_license_key':
-                $cn->core->site_license_key = $value;
-                break;
-            default:
-                do_action('AHEE__EE_DMS_4_1_0__handle_org_option', $option_name, $value);
-        }
-    }
+				break;
+			case 'notify_url':
+				$c->core->txn_page_id = $value;
+				break;
+			case 'use_captcha':
+				$c->registration->use_captcha = ($value == 'Y');
+				break;
+			case 'recaptcha_publickey':
+				$c->registration->recaptcha_publickey = $value;
+				break;
+			case 'recaptcha_privatekey':
+				$c->registration->recaptcha_privatekey = $value;
+				break;
+			case 'recaptcha_theme':
+				$c->registration->recaptcha_theme = $value;
+				break;
+			case 'recaptcha_width':
+				$c->registration->recaptcha_width = $value;
+				break;
+			case 'recaptcha_language':
+				$c->registration->recaptcha_language = $value;
+				break;
+			case 'espresso_dashboard_widget':
+				$c->admin->use_dashboard_widget = ($value == 'Y');
+				break;
+			case 'use_personnel_manager':
+				$c->admin->use_personnel_manager = ($value == 'Y');
+				break;
+			case 'use_event_timezones':
+				$c->admin->use_event_timezones = ($value == 'Y');
+				break;
+			case 'affiliate_id':
+				$c->admin->affiliate_id = $value;
+				break;
+			case 'site_license_key':
+				$cn->core->site_license_key = $value;
+				break;
+			default:
+				do_action('AHEE__EE_DMS_4_1_0__handle_org_option', $option_name, $value);
+		}
+	}
 
 
-    /**
-     * Creates a 4.1 member price discount
-     *
-     * @param array $org_options
-     * @return void
-     * @global wpdb $wpdb
-     */
-    private function _insert_new_global_surcharge_price(array $org_options): void
-    {
-        $amount = (float) $org_options['surcharge'];
-        // dont create a price if the surcharge is 0
-        if ($amount <= .01) {
-            return;
-        }
-        if ($org_options['surcharge_type'] == 'flat_rate') {
-            $price_type = EE_DMS_4_1_0_prices::price_type_flat_surcharge;
-        } else {
-            $price_type = EE_DMS_4_1_0_prices::price_type_percent_surcharge;
-        }
-        global $wpdb;
-        $cols_n_values = [
-            'PRT_ID'         => $price_type,
-            'PRC_amount'     => $amount,
-            'PRC_name'       => $org_options['surcharge_text'],
-            'PRC_is_default' => true,
-            'PRC_overrides'  => false,
-            'PRC_order'      => 100,
-            'PRC_deleted'    => false,
-            'PRC_parent'     => null,
+	/**
+	 * Creates a 4.1 member price discount
+	 *
+	 * @param array $org_options
+	 * @return void
+	 * @global wpdb $wpdb
+	 */
+	private function _insert_new_global_surcharge_price(array $org_options): void
+	{
+		$amount = (float) $org_options['surcharge'];
+		// dont create a price if the surcharge is 0
+		if ($amount <= .01) {
+			return;
+		}
+		if ($org_options['surcharge_type'] == 'flat_rate') {
+			$price_type = EE_DMS_4_1_0_prices::price_type_flat_surcharge;
+		} else {
+			$price_type = EE_DMS_4_1_0_prices::price_type_percent_surcharge;
+		}
+		global $wpdb;
+		$cols_n_values = [
+			'PRT_ID'         => $price_type,
+			'PRC_amount'     => $amount,
+			'PRC_name'       => $org_options['surcharge_text'],
+			'PRC_is_default' => true,
+			'PRC_overrides'  => false,
+			'PRC_order'      => 100,
+			'PRC_deleted'    => false,
+			'PRC_parent'     => null,
 
-        ];
-        $data_types    = [
-            '%d',// PRT_ID
-            '%f',// PRT_amount
-            '%s',// PRC_name
-            '%d',// PRC_is_default
-            '%d',// PRC_overrides
-            '%d',// PRC_order
-            '%d',// PRC_deleted
-            '%d',// PRC_parent
-        ];
-        $price_table   = $wpdb->prefix . "esp_price";
-        $success       = $wpdb->insert($price_table, $cols_n_values, $data_types);
-        if (! $success) {
-            $this->add_error(
-                $this->get_migration_script()->_create_error_message_for_db_insertion(
-                    'org_options',
-                    [
-                        'surcharge'      => $org_options['surcharge'],
-                        'surcharge_type' => $org_options['surcharge_type'],
-                        'surcharge_text' => $org_options['surcharge_text'],
-                    ],
-                    $price_table,
-                    $cols_n_values,
-                    $data_types
-                )
-            );
-        }
-    }
+		];
+		$data_types    = [
+			'%d',// PRT_ID
+			'%f',// PRT_amount
+			'%s',// PRC_name
+			'%d',// PRC_is_default
+			'%d',// PRC_overrides
+			'%d',// PRC_order
+			'%d',// PRC_deleted
+			'%d',// PRC_parent
+		];
+		$price_table   = $wpdb->prefix . "esp_price";
+		$success       = $wpdb->insert($price_table, $cols_n_values, $data_types);
+		if (! $success) {
+			$this->add_error(
+				$this->get_migration_script()->_create_error_message_for_db_insertion(
+					'org_options',
+					[
+						'surcharge'      => $org_options['surcharge'],
+						'surcharge_type' => $org_options['surcharge_type'],
+						'surcharge_text' => $org_options['surcharge_text'],
+					],
+					$price_table,
+					$cols_n_values,
+					$data_types
+				)
+			);
+		}
+	}
 
 
-    protected $_org_options_we_know_how_to_migrate = [
-        'organization',
-        'organization_street1',
-        'organization_street2',
-        'organization_city',
-        'organization_state',
-        'organization_zip',
-        'contact_email',
-        'default_mail',
-        'payment_subject',
-        'payment_message',
-        'message',
-        'default_payment_status',
-        'surcharge',// unused?
-        'country_id',// unused?
-        'organization_country',
-        //    'currency_symbol',
-        'expire_on_registration_end',
-        'email_before_payment',
-        'email_fancy_headers',
-        'enable_default_style',
-        'event_ssl_active',
-        'selected_style',
-        'show_pending_payment_options',
-        'show_reg_footer',
-        'skip_confirmation_page',
-        'allow_mer_discounts',// no equiv
-        'allow_mer_vouchers',// no equiv
-        'display_short_description_in_event_list',
-        'display_description_on_multi_reg_page',
-        'display_address_in_event_list',
-        'display_address_in_regform',
-        'use_custom_post_types',// no equiv
-        'display_ical_download',
-        'display_featured_image',
-        'themeroller',
-        'default_logo_url',
-        'event_page_id',
-        'return_url',
-        'cancel_return',
-        'notify_url',
-        'events_in_dashboard',
-        'use_captcha',
-        'recaptcha_publickey',
-        'recaptcha_privatekey',
-        'recaptcha_theme',
-        'recaptcha_width',
-        'recaptcha_language',
-        'espresso_dashboard_widget',
-        'time_reg_limit',
-        //    'use_attendee_pre_approval', removed in 4.1- instead this is factored into the default reg status
-        'use_personnel_manager',// no equiv
-        'use_event_timezones',
-        'full_logging',
-        'surcharge_type',// unused
-        'surcharge_text',// unused
-        'affiliate_id',
-        'site_license_key',
-    ];
+	protected $_org_options_we_know_how_to_migrate = [
+		'organization',
+		'organization_street1',
+		'organization_street2',
+		'organization_city',
+		'organization_state',
+		'organization_zip',
+		'contact_email',
+		'default_mail',
+		'payment_subject',
+		'payment_message',
+		'message',
+		'default_payment_status',
+		'surcharge',// unused?
+		'country_id',// unused?
+		'organization_country',
+		//    'currency_symbol',
+		'expire_on_registration_end',
+		'email_before_payment',
+		'email_fancy_headers',
+		'enable_default_style',
+		'event_ssl_active',
+		'selected_style',
+		'show_pending_payment_options',
+		'show_reg_footer',
+		'skip_confirmation_page',
+		'allow_mer_discounts',// no equiv
+		'allow_mer_vouchers',// no equiv
+		'display_short_description_in_event_list',
+		'display_description_on_multi_reg_page',
+		'display_address_in_event_list',
+		'display_address_in_regform',
+		'use_custom_post_types',// no equiv
+		'display_ical_download',
+		'display_featured_image',
+		'themeroller',
+		'default_logo_url',
+		'event_page_id',
+		'return_url',
+		'cancel_return',
+		'notify_url',
+		'events_in_dashboard',
+		'use_captcha',
+		'recaptcha_publickey',
+		'recaptcha_privatekey',
+		'recaptcha_theme',
+		'recaptcha_width',
+		'recaptcha_language',
+		'espresso_dashboard_widget',
+		'time_reg_limit',
+		//    'use_attendee_pre_approval', removed in 4.1- instead this is factored into the default reg status
+		'use_personnel_manager',// no equiv
+		'use_event_timezones',
+		'full_logging',
+		'surcharge_type',// unused
+		'surcharge_text',// unused
+		'affiliate_id',
+		'site_license_key',
+	];
 }