eventespresso / event-espresso-core

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

Indentation +148 added lines, -148 removed lines

@@ -27,162 +27,162 @@
  */
 class EE_DMS_4_1_0_question_group_question extends EE_Data_Migration_Script_Stage
 {
-    public function __construct()
-    {
-        global $wpdb;
-        $this->_old_table   = $wpdb->prefix . "events_qst_group_rel";
-        $this->_new_table   = $wpdb->prefix . "esp_question_group_question";
-        $this->_pretty_name = esc_html__("Question Group to Question Relations", "event_espresso");
-        parent::__construct();
-    }
+	public function __construct()
+	{
+		global $wpdb;
+		$this->_old_table   = $wpdb->prefix . "events_qst_group_rel";
+		$this->_new_table   = $wpdb->prefix . "esp_question_group_question";
+		$this->_pretty_name = esc_html__("Question Group to Question Relations", "event_espresso");
+		parent::__construct();
+	}
 
 
-    /**
-     * @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 $question_group_question) {
-            $this->_insert_new_question_group_question($question_group_question);
-            $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 $question_group_question) {
+			$this->_insert_new_question_group_question($question_group_question);
+			$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);
+	}
 
 
-    /**
-     * Attempts to insert a new question group in the new format given an old one
-     *
-     * @param array $old_question_group_question
-     * @return void
-     * @throws EE_Error
-     * @global wpdb $wpdb
-     */
-    private function _insert_new_question_group_question(array $old_question_group_question): void
-    {
-        global $wpdb;
-        $new_question_id       = $this->get_migration_script()->get_mapping_new_pk(
-            $wpdb->prefix . "events_question",
-            $old_question_group_question['question_id'],
-            $wpdb->prefix . "esp_question"
-        );
-        $new_question_group_id = $this->get_migration_script()->get_mapping_new_pk(
-            $wpdb->prefix . "events_qst_group",
-            $old_question_group_question['group_id'],
-            $wpdb->prefix . "esp_question_group"
-        );
-        if (! $new_question_id) {
-            $this->add_error(
-                sprintf(
-                    esc_html__("Could not find 4.1 question id for 3.1 question #%d.", "event_espresso"),
-                    $old_question_group_question['question_id']
-                )
-            );
-            return;
-        }
-        if (! $new_question_group_id) {
-            $this->add_error(
-                sprintf(
-                    esc_html__("Could not find 4.1 question group id for 3.1 question group #%d.", "event_espresso"),
-                    $old_question_group_question['group_id']
-                )
-            );
-            return;
-        }
-        // if it's a system question, it needs to be in the right system group. otherwise no dice!
-        if (
-            ($this->_is_system_question_group($new_question_group_id) ==
-             $this->_is_system_question_for_question_group($new_question_id)) ||
-            ! $this->_is_system_question_for_question_group($new_question_id)
-        ) {
-            $cols_n_values = [
-                'QSG_ID' => $new_question_group_id,
-                'QST_ID' => $new_question_id,
-            ];
-            $data_types    = [
-                '%d',// QSG_ID
-                '%d',// QST_ID
-            ];
-            $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_question_group_question,
-                        $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_question_group_question
+	 * @return void
+	 * @throws EE_Error
+	 * @global wpdb $wpdb
+	 */
+	private function _insert_new_question_group_question(array $old_question_group_question): void
+	{
+		global $wpdb;
+		$new_question_id       = $this->get_migration_script()->get_mapping_new_pk(
+			$wpdb->prefix . "events_question",
+			$old_question_group_question['question_id'],
+			$wpdb->prefix . "esp_question"
+		);
+		$new_question_group_id = $this->get_migration_script()->get_mapping_new_pk(
+			$wpdb->prefix . "events_qst_group",
+			$old_question_group_question['group_id'],
+			$wpdb->prefix . "esp_question_group"
+		);
+		if (! $new_question_id) {
+			$this->add_error(
+				sprintf(
+					esc_html__("Could not find 4.1 question id for 3.1 question #%d.", "event_espresso"),
+					$old_question_group_question['question_id']
+				)
+			);
+			return;
+		}
+		if (! $new_question_group_id) {
+			$this->add_error(
+				sprintf(
+					esc_html__("Could not find 4.1 question group id for 3.1 question group #%d.", "event_espresso"),
+					$old_question_group_question['group_id']
+				)
+			);
+			return;
+		}
+		// if it's a system question, it needs to be in the right system group. otherwise no dice!
+		if (
+			($this->_is_system_question_group($new_question_group_id) ==
+			 $this->_is_system_question_for_question_group($new_question_id)) ||
+			! $this->_is_system_question_for_question_group($new_question_id)
+		) {
+			$cols_n_values = [
+				'QSG_ID' => $new_question_group_id,
+				'QST_ID' => $new_question_id,
+			];
+			$data_types    = [
+				'%d',// QSG_ID
+				'%d',// QST_ID
+			];
+			$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_question_group_question,
+						$this->_new_table,
+						$cols_n_values,
+						$data_types
+					)
+				);
+			}
+		}
+	}
 
 
-    /**
-     * If this question is a system question, returns the QSG_system number that
-     * indicates the question group its permitted in.
-     *
-     * @param int   $new_question_id
-     * @return int
-     * @global wpdb $wpdb
-     */
-    private function _is_system_question_for_question_group(int $new_question_id): int
-    {
-        global $wpdb;
-        $system_id = $wpdb->get_var(
-            $wpdb->prepare(
-                "SELECT QST_system FROM " . $wpdb->prefix . "esp_question WHERE QST_ID=%d",
-                $new_question_id
-            )
-        );
-        if (in_array($system_id, ['fname', 'lname', 'email'])) {
-            return 1;
-        }
-        if ($system_id != '' && $system_id) {
-            return 2;
-        }
-        return 0;
-    }
+	/**
+	 * If this question is a system question, returns the QSG_system number that
+	 * indicates the question group its permitted in.
+	 *
+	 * @param int   $new_question_id
+	 * @return int
+	 * @global wpdb $wpdb
+	 */
+	private function _is_system_question_for_question_group(int $new_question_id): int
+	{
+		global $wpdb;
+		$system_id = $wpdb->get_var(
+			$wpdb->prepare(
+				"SELECT QST_system FROM " . $wpdb->prefix . "esp_question WHERE QST_ID=%d",
+				$new_question_id
+			)
+		);
+		if (in_array($system_id, ['fname', 'lname', 'email'])) {
+			return 1;
+		}
+		if ($system_id != '' && $system_id) {
+			return 2;
+		}
+		return 0;
+	}
 
 
-    /**
-     * Returns the question group's QSG_system value (1 meaning personal info, 2
-     * being address info, and 0 being neither)
-     *
-     * @param int   $new_question_group_id
-     * @return int
-     * @global wpdb $wpdb
-     */
-    private function _is_system_question_group(int $new_question_group_id): int
-    {
-        global $wpdb;
-        return (int) $wpdb->get_var(
-            $wpdb->prepare(
-                "SELECT QSG_system FROM " . $wpdb->prefix . "esp_question_group WHERE QSG_ID=%d",
-                $new_question_group_id
-            )
-        );
-    }
+	/**
+	 * Returns the question group's QSG_system value (1 meaning personal info, 2
+	 * being address info, and 0 being neither)
+	 *
+	 * @param int   $new_question_group_id
+	 * @return int
+	 * @global wpdb $wpdb
+	 */
+	private function _is_system_question_group(int $new_question_group_id): int
+	{
+		global $wpdb;
+		return (int) $wpdb->get_var(
+			$wpdb->prepare(
+				"SELECT QSG_system FROM " . $wpdb->prefix . "esp_question_group WHERE QSG_ID=%d",
+				$new_question_group_id
+			)
+		);
+	}
 }

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

Indentation +231 added lines, -231 removed lines

@@ -14,256 +14,256 @@
  */
 class EE_DMS_4_1_0_gateways extends EE_Data_Migration_Script_Stage
 {
-    private bool $_converted_active_gateways = false;
+	private bool $_converted_active_gateways = false;
 
-    protected array $_gateways_we_know_how_to_migrate = [
-        'aim'        => 'Aim',
-        'bank'       => 'Bank',
-        'check'      => 'Check',
-        'invoice'    => 'Invoice',
-        'paypal'     => 'Paypal_Standard',
-        'paypal_pro' => 'Paypal_Pro',
+	protected array $_gateways_we_know_how_to_migrate = [
+		'aim'        => 'Aim',
+		'bank'       => 'Bank',
+		'check'      => 'Check',
+		'invoice'    => 'Invoice',
+		'paypal'     => 'Paypal_Standard',
+		'paypal_pro' => 'Paypal_Pro',
 
-    ];
+	];
 
-    protected array $_gateways_we_leave_alone = [
-        '2checkout'        => '2checkout',
-        'anz'              => 'Anz',
-        'atos'             => 'Atos',
-        'authnet'          => 'Authnet',
-        'beanstream'       => 'Beanstream',
-        'evertec'          => 'Evertec',
-        'eway'             => 'Eway',
-        'eway_rapid3'      => 'Eway_Rapid3',
-        'exact'            => 'Exact',
-        'firstdata'        => 'Firstdata',
-        'firstdat_e4'      => 'Firstdata_E4',
-        'ideal'            => 'Ideal',
-        'infusion_payment' => 'InfusionSoft',
-        'luottokunta'      => 'Luottokunta',
-        'megasoft'         => 'Megasoft',
-        'moneris_hpp'      => 'Moneris_HPP',
-        'mwarrior'         => 'Mwarrior',
-        'nab'              => 'NAB',
-        'paychoice'        => 'Paychoice',
-        'paytrace'         => 'Paytrace',
-        'psigate'          => 'Psigate',
-        'purchase_order'   => 'Purchase_Order',
-        'qbms'             => 'QBMS',
-        'quickpay'         => 'Quickpay',
-        'realauth'         => 'Realauth',
-        'securepay_aus'    => 'Securepay_Aus',
-        'stripe'           => 'Stripe',
-        'usaepay_offsite'  => 'USAePay_Offsite',
-        'usaepay_onsite'   => 'USAePay_Onsite',
-        'wepay'            => 'Wepay',
-        'worldpay'         => 'Worldpay',
-    ];
+	protected array $_gateways_we_leave_alone = [
+		'2checkout'        => '2checkout',
+		'anz'              => 'Anz',
+		'atos'             => 'Atos',
+		'authnet'          => 'Authnet',
+		'beanstream'       => 'Beanstream',
+		'evertec'          => 'Evertec',
+		'eway'             => 'Eway',
+		'eway_rapid3'      => 'Eway_Rapid3',
+		'exact'            => 'Exact',
+		'firstdata'        => 'Firstdata',
+		'firstdat_e4'      => 'Firstdata_E4',
+		'ideal'            => 'Ideal',
+		'infusion_payment' => 'InfusionSoft',
+		'luottokunta'      => 'Luottokunta',
+		'megasoft'         => 'Megasoft',
+		'moneris_hpp'      => 'Moneris_HPP',
+		'mwarrior'         => 'Mwarrior',
+		'nab'              => 'NAB',
+		'paychoice'        => 'Paychoice',
+		'paytrace'         => 'Paytrace',
+		'psigate'          => 'Psigate',
+		'purchase_order'   => 'Purchase_Order',
+		'qbms'             => 'QBMS',
+		'quickpay'         => 'Quickpay',
+		'realauth'         => 'Realauth',
+		'securepay_aus'    => 'Securepay_Aus',
+		'stripe'           => 'Stripe',
+		'usaepay_offsite'  => 'USAePay_Offsite',
+		'usaepay_onsite'   => 'USAePay_Onsite',
+		'wepay'            => 'Wepay',
+		'worldpay'         => 'Worldpay',
+	];
 
 
-    public function __construct()
-    {
-        $this->_pretty_name = esc_html__("Gateways", "event_espresso");
-        parent::__construct();
-    }
+	public function __construct()
+	{
+		$this->_pretty_name = esc_html__("Gateways", "event_espresso");
+		parent::__construct();
+	}
 
 
-    public function _migration_step($num_items_to_migrate = 50)
-    {
-        // loads existing EE_Config from DB, if it exists
-        $new_gateway_config_obj  = EE_Config::instance()->gateway;
-        $items_actually_migrated = 0;
-        // convert settings
-        $gateways_to_deal_with = array_merge(
-            $this->_gateways_we_know_how_to_migrate,
-            $this->_gateways_we_leave_alone
-        );
-        // just do a part of them on this request
-        $gateways_to_deal_with = array_slice(
-            $gateways_to_deal_with,
-            $this->count_records_migrated(),
-            $num_items_to_migrate
-        );// $this->_gateways_we_know_how_to_migrate;
-        foreach ($gateways_to_deal_with as $old_gateway_slug => $new_gateway_slug) {
-            $old_gateway_wp_option_name = $this->_get_old_gateway_option_name($new_gateway_slug);
-            if (isset($this->_gateways_we_know_how_to_migrate[ $old_gateway_slug ])) {
-                // determine the old option's name
-                $old_gateway_settings = $this->_get_old_gateway_option($new_gateway_slug);
-                if (! $old_gateway_settings) {
-                    // no settings existed for this gateway anyways... weird...
-                    $items_actually_migrated++;
-                    continue;
-                }
-                // now prepare the settings to make sure they're in the 4.1 format
-                $new_gateway_settings = $this->_convert_gateway_settings(
-                    (array) $old_gateway_settings,
-                    $new_gateway_slug
-                );
+	public function _migration_step($num_items_to_migrate = 50)
+	{
+		// loads existing EE_Config from DB, if it exists
+		$new_gateway_config_obj  = EE_Config::instance()->gateway;
+		$items_actually_migrated = 0;
+		// convert settings
+		$gateways_to_deal_with = array_merge(
+			$this->_gateways_we_know_how_to_migrate,
+			$this->_gateways_we_leave_alone
+		);
+		// just do a part of them on this request
+		$gateways_to_deal_with = array_slice(
+			$gateways_to_deal_with,
+			$this->count_records_migrated(),
+			$num_items_to_migrate
+		);// $this->_gateways_we_know_how_to_migrate;
+		foreach ($gateways_to_deal_with as $old_gateway_slug => $new_gateway_slug) {
+			$old_gateway_wp_option_name = $this->_get_old_gateway_option_name($new_gateway_slug);
+			if (isset($this->_gateways_we_know_how_to_migrate[ $old_gateway_slug ])) {
+				// determine the old option's name
+				$old_gateway_settings = $this->_get_old_gateway_option($new_gateway_slug);
+				if (! $old_gateway_settings) {
+					// no settings existed for this gateway anyways... weird...
+					$items_actually_migrated++;
+					continue;
+				}
+				// now prepare the settings to make sure they're in the 4.1 format
+				$new_gateway_settings = $this->_convert_gateway_settings(
+					(array) $old_gateway_settings,
+					$new_gateway_slug
+				);
 
-                $new_gateway_config_obj->payment_settings[ $new_gateway_slug ] = $new_gateway_settings;
-                // and when we're done, remove the old option. Sometimes we'd prefer to do this in a different stage, but
-                // I think it's ok to do right away this time (we wont need gateway settings elsewhere)
-                delete_option($old_gateway_wp_option_name);
-            } else {// it must be one of the ones we mostly leave alone
-                global $wpdb;
-                // yeah we could do this all in one query... and if you're reading this and would like to, go ahead. Although you'll
-                // only be saving users 50 milliseconds the one time this runs...
-                $wpdb->query(
-                    $wpdb->prepare(
-                        "UPDATE " . $wpdb->options . " SET autoload='no' WHERE option_name=%s",
-                        $old_gateway_wp_option_name
-                    )
-                );
-            }
+				$new_gateway_config_obj->payment_settings[ $new_gateway_slug ] = $new_gateway_settings;
+				// and when we're done, remove the old option. Sometimes we'd prefer to do this in a different stage, but
+				// I think it's ok to do right away this time (we wont need gateway settings elsewhere)
+				delete_option($old_gateway_wp_option_name);
+			} else {// it must be one of the ones we mostly leave alone
+				global $wpdb;
+				// yeah we could do this all in one query... and if you're reading this and would like to, go ahead. Although you'll
+				// only be saving users 50 milliseconds the one time this runs...
+				$wpdb->query(
+					$wpdb->prepare(
+						"UPDATE " . $wpdb->options . " SET autoload='no' WHERE option_name=%s",
+						$old_gateway_wp_option_name
+					)
+				);
+			}
 
-            $items_actually_migrated++;
-        }
-        // if we can keep going, and it hasn't been done yet, convert active gateways
-        if ($items_actually_migrated < $num_items_to_migrate && ! $this->_converted_active_gateways) {
-            $this->_convert_active_gateways();
-            $this->_converted_active_gateways = true;
-            $items_actually_migrated++;
-        }
+			$items_actually_migrated++;
+		}
+		// if we can keep going, and it hasn't been done yet, convert active gateways
+		if ($items_actually_migrated < $num_items_to_migrate && ! $this->_converted_active_gateways) {
+			$this->_convert_active_gateways();
+			$this->_converted_active_gateways = true;
+			$items_actually_migrated++;
+		}
 
-        EE_Config::instance()->update_espresso_config(false, false);
-        if ($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()) {
-            $this->set_completed();
-        }
-        return $items_actually_migrated;
-    }
+		EE_Config::instance()->update_espresso_config(false, false);
+		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(): int
-    {
-        $count_of_gateways_to_convert     = (int) count($this->_gateways_we_know_how_to_migrate);
-        $step_of_setting_active_gateways  = 1;
-        $count_of_gateways_to_leave_alone = (int) count($this->_gateways_we_leave_alone);
-        //  $button_images_to_update =
-        return $count_of_gateways_to_convert + $step_of_setting_active_gateways + $count_of_gateways_to_leave_alone;
-    }
+	public function _count_records_to_migrate(): int
+	{
+		$count_of_gateways_to_convert     = (int) count($this->_gateways_we_know_how_to_migrate);
+		$step_of_setting_active_gateways  = 1;
+		$count_of_gateways_to_leave_alone = (int) count($this->_gateways_we_leave_alone);
+		//  $button_images_to_update =
+		return $count_of_gateways_to_convert + $step_of_setting_active_gateways + $count_of_gateways_to_leave_alone;
+	}
 
 
-    /**
-     * Takes the old array of 3.1 gateway settings for this gateway and converts it
-     * into an array with all the 4.1 gateway setting array keys (often the keys were
-     * changed from 3.1 to 4.1)
-     *
-     * @param array  $old_gateway_settings
-     * @param string $new_gateway_slug
-     * @return array
-     */
-    private function _convert_gateway_settings(array $old_gateway_settings, string $new_gateway_slug): array
-    {
-        $new_gateway_settings = $old_gateway_settings;
-        switch ($new_gateway_slug) {
-            case 'Bank':
-                $new_gateway_settings['account_number'] = $old_gateway_settings['bank_account'];
-                $new_gateway_settings['page_title']     = $old_gateway_settings['bank_title'];
-                break;
-            case 'Invoice':
-                $new_gateway_settings['invoice_logo_url'] = $old_gateway_settings['image_url'];
-                // Dont' migrate the old invoice payee address. It was usually given dummy data. And in EE4
-                // it gets used in the receipts which are available to everyone. So usually it's best to not
-                // migrate this.
-                unset($new_gateway_settings['payment_address']);
-                break;
-            case 'Paypal_Pro':
-                $new_gateway_settings['email']        = $old_gateway_settings['paypal_pro_email'];
-                $new_gateway_settings['username']     = $old_gateway_settings['paypal_api_username'];
-                $new_gateway_settings['password']     = $old_gateway_settings['paypal_api_password'];
-                $new_gateway_settings['signature']    = $old_gateway_settings['paypal_api_signature'];
-                $new_gateway_settings['credit_cards'] = explode(",", $old_gateway_settings['paypal_api_credit_cards']);
-                $new_gateway_settings['use_sandbox']  = $old_gateway_settings['paypal_pro_use_sandbox'];
-                break;
-        }
-        return $new_gateway_settings;
-    }
+	/**
+	 * Takes the old array of 3.1 gateway settings for this gateway and converts it
+	 * into an array with all the 4.1 gateway setting array keys (often the keys were
+	 * changed from 3.1 to 4.1)
+	 *
+	 * @param array  $old_gateway_settings
+	 * @param string $new_gateway_slug
+	 * @return array
+	 */
+	private function _convert_gateway_settings(array $old_gateway_settings, string $new_gateway_slug): array
+	{
+		$new_gateway_settings = $old_gateway_settings;
+		switch ($new_gateway_slug) {
+			case 'Bank':
+				$new_gateway_settings['account_number'] = $old_gateway_settings['bank_account'];
+				$new_gateway_settings['page_title']     = $old_gateway_settings['bank_title'];
+				break;
+			case 'Invoice':
+				$new_gateway_settings['invoice_logo_url'] = $old_gateway_settings['image_url'];
+				// Dont' migrate the old invoice payee address. It was usually given dummy data. And in EE4
+				// it gets used in the receipts which are available to everyone. So usually it's best to not
+				// migrate this.
+				unset($new_gateway_settings['payment_address']);
+				break;
+			case 'Paypal_Pro':
+				$new_gateway_settings['email']        = $old_gateway_settings['paypal_pro_email'];
+				$new_gateway_settings['username']     = $old_gateway_settings['paypal_api_username'];
+				$new_gateway_settings['password']     = $old_gateway_settings['paypal_api_password'];
+				$new_gateway_settings['signature']    = $old_gateway_settings['paypal_api_signature'];
+				$new_gateway_settings['credit_cards'] = explode(",", $old_gateway_settings['paypal_api_credit_cards']);
+				$new_gateway_settings['use_sandbox']  = $old_gateway_settings['paypal_pro_use_sandbox'];
+				break;
+		}
+		return $new_gateway_settings;
+	}
 
 
-    /**
-     * Returns the 3.1 gateway settings for the given 4.1 gateway
-     *
-     * @param string $new_gateway_slug
-     * @return null|array
-     */
-    private function _get_old_gateway_option(string $new_gateway_slug): ?array
-    {
-        return get_option(
-            $this->_get_old_gateway_option_name($new_gateway_slug),
-            null
-        );
-    }
+	/**
+	 * Returns the 3.1 gateway settings for the given 4.1 gateway
+	 *
+	 * @param string $new_gateway_slug
+	 * @return null|array
+	 */
+	private function _get_old_gateway_option(string $new_gateway_slug): ?array
+	{
+		return get_option(
+			$this->_get_old_gateway_option_name($new_gateway_slug),
+			null
+		);
+	}
 
 
-    /**
-     * Figures out the correct 3.1 gateway settings option name for the given 4.1 gateway
-     *
-     * @param string $new_gateway_slug
-     * @return string
-     */
-    private function _get_old_gateway_option_name(string $new_gateway_slug): string
-    {
-        $new_gateway_slugs_to_new = array_flip(
-            array_merge(
-                $this->_gateways_we_know_how_to_migrate,
-                $this->_gateways_we_leave_alone
-            )
-        );
-        $old_gateway_slug         = $new_gateway_slugs_to_new[ $new_gateway_slug ];
-        $normal_option_prefix     = 'event_espresso_';
-        $normal_option_postfix    = '_settings';
-        switch ($new_gateway_slug) {
-            case 'Bank':
-                $option_name = $normal_option_prefix . 'bank_deposit' . $normal_option_postfix;
-                break;
-            case 'Aim':
-                $option_name = $normal_option_prefix . 'authnet_aim' . $normal_option_postfix;
-                break;
-            case 'Check':
-                $option_name = $normal_option_prefix . 'check_payment' . $normal_option_postfix;
-                break;
-            case 'Ideal':
-                $option_name = $normal_option_prefix . 'ideal_mollie' . $normal_option_postfix;
-                break;
-            case 'Invoice':
-                $option_name = $normal_option_prefix . 'invoice_payment' . $normal_option_postfix;
-                break;
-            case 'Purchase_Order':
-                $option_name = $normal_option_prefix . 'purchase_order_payment' . $normal_option_postfix;
-                break;
-            case 'USAePay_Offsite':
-                $option_name = 'espresso_usaepay_offsite' . $normal_option_postfix;
-                break;
-            case 'USAePay_Onsite':
-                $option_name = 'espresso_usaepay_onsite' . $normal_option_postfix;
-                break;
-            default:
-                $option_name = apply_filters(
-                    'FHEE__EE_DMS_4_1_0_gateways__get_old_gateway_option',
-                    $normal_option_prefix . $old_gateway_slug . $normal_option_postfix
-                );
-        }
-        return $option_name;
-    }
+	/**
+	 * Figures out the correct 3.1 gateway settings option name for the given 4.1 gateway
+	 *
+	 * @param string $new_gateway_slug
+	 * @return string
+	 */
+	private function _get_old_gateway_option_name(string $new_gateway_slug): string
+	{
+		$new_gateway_slugs_to_new = array_flip(
+			array_merge(
+				$this->_gateways_we_know_how_to_migrate,
+				$this->_gateways_we_leave_alone
+			)
+		);
+		$old_gateway_slug         = $new_gateway_slugs_to_new[ $new_gateway_slug ];
+		$normal_option_prefix     = 'event_espresso_';
+		$normal_option_postfix    = '_settings';
+		switch ($new_gateway_slug) {
+			case 'Bank':
+				$option_name = $normal_option_prefix . 'bank_deposit' . $normal_option_postfix;
+				break;
+			case 'Aim':
+				$option_name = $normal_option_prefix . 'authnet_aim' . $normal_option_postfix;
+				break;
+			case 'Check':
+				$option_name = $normal_option_prefix . 'check_payment' . $normal_option_postfix;
+				break;
+			case 'Ideal':
+				$option_name = $normal_option_prefix . 'ideal_mollie' . $normal_option_postfix;
+				break;
+			case 'Invoice':
+				$option_name = $normal_option_prefix . 'invoice_payment' . $normal_option_postfix;
+				break;
+			case 'Purchase_Order':
+				$option_name = $normal_option_prefix . 'purchase_order_payment' . $normal_option_postfix;
+				break;
+			case 'USAePay_Offsite':
+				$option_name = 'espresso_usaepay_offsite' . $normal_option_postfix;
+				break;
+			case 'USAePay_Onsite':
+				$option_name = 'espresso_usaepay_onsite' . $normal_option_postfix;
+				break;
+			default:
+				$option_name = apply_filters(
+					'FHEE__EE_DMS_4_1_0_gateways__get_old_gateway_option',
+					$normal_option_prefix . $old_gateway_slug . $normal_option_postfix
+				);
+		}
+		return $option_name;
+	}
 
 
-    private function _convert_active_gateways()
-    {
-        // just does it all one big swoop
-        $old_active_gateways = get_option('event_espresso_active_gateways');
-        $new_active_gateways = EE_Config::instance()->gateway->active_gateways;
-        foreach ($old_active_gateways as $old_gateway_slug => $filepath) {
-            if (! isset($this->_gateways_we_know_how_to_migrate[ $old_gateway_slug ])) {
-                $this->add_error(
-                    sprintf(esc_html__("The %s gateway does not exist in EE 4.1", "event_espresso"), $old_gateway_slug)
-                );
-                continue;
-            }
-            $new_gateway_slug = $this->_gateways_we_know_how_to_migrate[ $old_gateway_slug ];
+	private function _convert_active_gateways()
+	{
+		// just does it all one big swoop
+		$old_active_gateways = get_option('event_espresso_active_gateways');
+		$new_active_gateways = EE_Config::instance()->gateway->active_gateways;
+		foreach ($old_active_gateways as $old_gateway_slug => $filepath) {
+			if (! isset($this->_gateways_we_know_how_to_migrate[ $old_gateway_slug ])) {
+				$this->add_error(
+					sprintf(esc_html__("The %s gateway does not exist in EE 4.1", "event_espresso"), $old_gateway_slug)
+				);
+				continue;
+			}
+			$new_gateway_slug = $this->_gateways_we_know_how_to_migrate[ $old_gateway_slug ];
 
-            // in the new format we can also upload gateways to the uploads directory and
-            $new_active_gateways[ $new_gateway_slug ] = false;
-        }
-        EE_Config::instance()->gateway->active_gateways = $new_active_gateways;
-    }
+			// in the new format we can also upload gateways to the uploads directory and
+			$new_active_gateways[ $new_gateway_slug ] = false;
+		}
+		EE_Config::instance()->gateway->active_gateways = $new_active_gateways;
+	}
 }

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

Indentation +817 added lines, -817 removed lines

@@ -176,825 +176,825 @@
  */
 class EE_DMS_4_1_0_events extends EE_Data_Migration_Script_Stage
 {
-    private string $_old_start_end_table;
-
-    private string $_new_meta_table;
-
-    private string $_new_datetime_table;
-
-
-    /**
-     * Just initializes the status of the migration
-     */
-    public function __construct()
-    {
-        global $wpdb;
-        $this->_old_table           = $wpdb->prefix . "events_detail";
-        $this->_old_start_end_table = $wpdb->prefix . "events_start_end";
-        $this->_new_table           = $wpdb->prefix . "posts";
-        $this->_new_meta_table      = $wpdb->prefix . "esp_event_meta";
-        $this->_new_datetime_table  = $wpdb->prefix . "esp_datetime";
-        $this->_pretty_name         = esc_html__("Events", "event_espresso");
-        parent::__construct();
-    }
-
-
-    /**
-     * Counts the records to migrate; the public version may cache it
-     *
-     * @return int
-     */
-    public function _count_records_to_migrate(): int
-    {
-        global $wpdb;
-        return (int) $wpdb->get_var("SELECT COUNT(*) FROM " . $this->_old_table . ' WHERE event_status !="D"');
-    }
-
-
-    /**
-     * 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
-     * @throws EE_Error
-     */
-    protected function _migration_step($num_items_to_migrate = 50)
-    {
-        global $wpdb;
-        // because the migration of each event can be a LOT more work, make each step smaller
-        $num_items_to_migrate     = max(1, $num_items_to_migrate / 5);
-        $events                   =
-            $wpdb->get_results(
-                $wpdb->prepare(
-                    "SELECT * FROM $this->_old_table WHERE event_status!='D' LIMIT %d,%d",
-                    $this->count_records_migrated(),
-                    $num_items_to_migrate
-                ),
-                ARRAY_A
-            );
-        $items_migrated_this_step = 0;
-
-        foreach ($events as $event_row) {
-            $guid = null;
-            // insert new 4.1 Attendee object using $wpdb
-            $post_id = $this->_insert_cpt($event_row);
-            if ($post_id) {
-                $this->get_migration_script()->set_mapping(
-                    $this->_old_table,
-                    $event_row['id'],
-                    $this->_new_table,
-                    $post_id
-                );
-                $meta_id = $this->_insert_event_meta($event_row, $post_id);
-                if ($meta_id) {
-                    $this->get_migration_script()->set_mapping(
-                        $this->_old_table,
-                        $event_row['id'],
-                        $this->_new_meta_table,
-                        $meta_id
-                    );
-                }
-                $this->_convert_start_end_times($event_row, $post_id);
-                $event_meta = maybe_unserialize($event_row['event_meta']);
-                $guid       = $event_meta['event_thumbnail_url'] ?? null;
-                if ($guid) {
-                    $this->get_migration_script()->convert_image_url_to_attachment_and_attach_to_post(
-                        $guid,
-                        $post_id,
-                        $this
-                    );
-                }
-                // maybe create a venue from info on the event?
-                $new_venue_id = $this->_maybe_create_venue($event_row);
-                if ($new_venue_id) {
-                    $this->_insert_new_venue_to_event($post_id, $new_venue_id);
-                }
-                $this->_add_post_metas($event_row, $post_id);
-            }
-            $items_migrated_this_step++;
-            if ($guid) {
-                // if we had to check for an image attachment
-                // then let's call it a day (avoid timing out, because this took a long time)
-                break;
-            }
-        }
-        if ($this->count_records_migrated() + $items_migrated_this_step >= $this->count_records_to_migrate()) {
-            $this->set_status(EE_Data_Migration_Manager::status_completed);
-        }
-        return $items_migrated_this_step;
-    }
-
-
-    /**
-     * Stores any extra 3.1 "event_meta" column things as post meta
-     *
-     * @param array $old_event
-     * @param int   $post_id
-     * @return void
-     */
-    private function _add_post_metas(array $old_event, int $post_id)
-    {
-        $event_meta = maybe_unserialize($old_event['event_meta']);
-        if (! $event_meta || ! is_array($event_meta)) {
-            return;
-        }
-        unset($event_meta['date_submitted']);              // factored into CPT
-        unset($event_meta['additional_attendee_reg_info']);// factored into event meta table
-        unset($event_meta['default_payment_status']);      // dido
-        unset($event_meta['event_thumbnail_url']);         // used to find post featured image
-        foreach ($event_meta as $meta_key => $meta_value) {
-            if ($meta_key) {// if the meta key is just an empty string, ignore it
-                $success = add_post_meta($post_id, $meta_key, $meta_value, true);
-                if (! $success) {
-                    $this->add_error(
-                        sprintf(
-                            esc_html__(
-                                "Could not add post meta for CPT with ID #%d. Meta key: '%s',meta value:'%d' for 3.1 event: %s",
-                                "event_espresso"
-                            ),
-                            $post_id,
-                            $meta_key,
-                            $meta_value,
-                            implode(",", $old_event)
-                        )
-                    );
-                }
-            }
-        }
-        if ($old_event['alt_email']) {
-            add_post_meta($post_id, 'alt_email', $old_event['alt_email']);
-        }
-        if ($old_event['recurrence_id']) {
-            add_post_meta($post_id, 'recurrence_id', $old_event['recurrence_id']);
-        }
-    }
-
-
-    /**
-     * Finds a unique slug for this event, given its name (we could have simply used
-     * the old unique_identifier column, but it added a long string of seemingly random characters onto the end
-     * and really wasn't that pretty for a slug, so we decided we'd make our own slug again)
-     *
-     * @param string $event_name      (the name of the event for reading by humans)
-     * @param string $old_identifier  the old EE3 identifier (a long unique string)
-     * @param string $new_post_status a post status
-     * @return string
-     */
-    private function _find_unique_slug(
-        string $event_name,
-        string $old_identifier = '',
-        string $new_post_status = 'publish'
-    ): string {
-        $original_name = $event_name ? sanitize_title($event_name) : $old_identifier;
-        return wp_unique_post_slug($original_name, 0, $new_post_status, EspressoPostType::EVENTS, 0);
-    }
-
-
-    /**
-     * returns whether there is a post that has this same slug (post_title)
-     *
-     * @param string $slug
-     * @return boolean
-     * @global wpdb  $wpdb
-     */
-    private function _other_post_exists_with_that_slug(string $slug): bool
-    {
-        global $wpdb;
-        $query =
-            $wpdb->prepare(
-                "SELECT COUNT(ID) FROM $this->_new_table WHERE event_status != 'D' AND post_name = %s",
-                $slug
-            );
-        $count = $wpdb->get_var($query);
-        return (bool) intval($count);
-    }
-
-
-    /**
-     * @param $old_event
-     * @return int
-     */
-    private function _insert_cpt($old_event): int
-    {
-        global $wpdb;
-        // convert 3.1 event status to 4.1 CPT status
-        // for reference, 3.1 event stati available for setting are:
-        //      $status = array(array('id' => 'A', 'text' => esc_html__('Public', 'event_espresso')), array('id' => 'S', 'text' => esc_html__('Waitlist', 'event_espresso')), array('id' => 'O', 'text' => esc_html__('Ongoing', 'event_espresso')), array('id' => 'R', 'text' => esc_html__('Draft', 'event_espresso')), array('id' => 'D', 'text' => esc_html__('Deleted', 'event_espresso')));
-        //      and the json api uses the following to convert from 3.1 to 4.0
-        //      'S'=>'secondary/waitlist',
-        //      'A'=>'active',
-        //      'X'=>'denied',
-        //      'IA'=>'inactive',
-        //      'O'=>'ongoing',
-        //      'P'=>'pending',
-        //      'R'=>'draft',
-        //      'D'=>'deleted');
-        //      4.1 Event Post stati are the normal post statis
-        //      (publish,future,draft,pending,private,trash,auto-draft,inherit)
-        //      and 3 custom ones: cancelled,postponed,sold_out
-        $status_conversions = [
-            'R'  => 'draft',
-            'X'  => 'draft',
-            // 4.1 doesn't have a "not approved for publishing" status. this is what posts are set to that aren't approved
-            'P'  => 'pending',
-            'IA' => 'draft',
-            // draft and in the past
-            // IA=inactive in 3.1: events were switched to this when they expired. in 4.1 that's just calculated
-            'O'  => 'publish',
-            // @todo: will be an event type later; if this is the status, set the end date WAAAY later; and add term for 'ongoing'
-            'A'  => 'publish',
-            'S'  => 'draft',
-            // @todo: is it ok to just mark secondary/waitlist events as DRAFTS?
-            'D'  => 'trash',
-        ];
-        $post_status        = $status_conversions[ $old_event['event_status'] ];
-        // check if we've sold out
-        if (intval($old_event['reg_limit']) <= self::count_registrations($old_event['id'])) {
-            $post_status = 'sold_out';
-        }
-        //      FYI postponed and cancelled don't exist in 3.1
-        $cols_n_values                      = [
-            'post_title'        => stripslashes($old_event['event_name']),// EVT_name
-            'post_content'      => stripslashes($old_event['event_desc']),// EVT_desc
-            'post_name'         => $this->_find_unique_slug(
-                $old_event['event_name'],
-                $old_event['event_identifier'],
-                $post_status
-            ),// EVT_slug
-            'post_date'         => $old_event['submitted'],// EVT_created NOT
-            'post_date_gmt'     => get_gmt_from_date($old_event['submitted']),
-            'post_excerpt'      => '',// EVT_short_desc
-            'post_modified'     => $old_event['submitted'],// EVT_modified
-            'post_modified_gmt' => get_gmt_from_date($old_event['submitted']),
-            'post_author'       => $old_event['wp_user'],// EVT_wp_user
-            'post_parent'       => 0,// parent maybe get this from some REM field?
-            'menu_order'        => 0,// EVT_order
-            'post_type'         => EspressoPostType::EVENTS,// post_type
-            'post_status'       => $post_status,// status
-        ];
-        $cols_n_values_with_no_invalid_text = [];
-        foreach ($cols_n_values as $col => $value) {
-            $value_sans_invalid_chars = $wpdb->strip_invalid_text_for_column($this->_new_table, $col, $value);
-            if (! is_wp_error($value_sans_invalid_chars)) {
-                $cols_n_values_with_no_invalid_text[ $col ] = $value_sans_invalid_chars;
-            } else {
-                // otherwise leave it as-is. It will blow everything up and stop the migration
-                $cols_n_values_with_no_invalid_text[ $col ] = $value;
-            }
-        }
-        $cols_n_values = $cols_n_values_with_no_invalid_text;
-        $data_types    = [
-            '%s',// EVT_name
-            '%s',// EVT_desc
-            '%s',// EVT_slug
-            '%s',// EVT_created
-            '%s',
-            '%s',// EVT_short_desc
-            '%s',// EVT_modified
-            '%s',
-            '%s',// EVT_wp_user
-            '%d',// post_parent
-            '%d',// EVT_order
-            '%s',// post_type
-            '%s',// status
-        ];
-        $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,
-                    $this->_new_table,
-                    $cols_n_values,
-                    $data_types
-                )
-            );
-            return 0;
-        }
-        return $wpdb->insert_id;
-    }
-
-
-    /**
-     * Counts all the registrations for the event in the 3.1 DB. (takes into account attendee rows which represent
-     * various registrations)
-     *
-     * @param int   $event_id
-     * @return int
-     * @global wpdb $wpdb
-     */
-    public static function count_registrations(int $event_id): int
-    {
-        global $wpdb;
-        return (int) $wpdb->get_var(
-            $wpdb->prepare("SELECT sum(quantity) FROM {$wpdb->prefix}events_attendee WHERE event_id=%d", $event_id)
-        );
-    }
-
-
-    /**
-     * @param $old_event
-     * @param $new_cpt_id
-     * @return int
-     */
-    private function _insert_event_meta($old_event, $new_cpt_id): int
-    {
-        global $wpdb;
-        $event_meta = maybe_unserialize($old_event['event_meta']);
-        //      for reference, 3.1 'default_payment_status' are: $default_payment_status = array(
-        //  array('id' => "", 'text' => 'No Change'),
-        //  array('id' => 'Incomplete', 'text' => 'Incomplete'),
-        //  array('id' => 'Pending', 'text' => 'Pending'),
-        //  //array('id' => 'Completed', 'text' => 'Completed')
-        // );
-        $default_reg_status =
-            $this->get_migration_script()->convert_3_1_payment_status_to_4_1_STS_ID(
-                $event_meta['default_payment_status'] ?? '',
-                intval($old_event['require_pre_approval'])
-            );
-        $cols_n_values      = [
-            'EVT_ID'                          => $new_cpt_id,// EVT_ID_fk
-            'EVT_display_desc'                => 'Y' == $old_event['display_desc'],
-            'EVT_display_ticket_selector'     => 'Y' == $old_event['display_reg_form'],
-            'EVT_visible_on'                  => $this->get_migration_script()->convert_date_string_to_utc(
-                $this,
-                $old_event,
-                current_time(
-                    'mysql'
-                ),
-                $old_event['timezone_string']
-            ),// don't use the old 'visible_on', as it wasn't ever used
-            'EVT_additional_limit'            => $old_event['allow_multiple'] == 'N' ? 1
-                : $old_event['additional_limit'],
-            'EVT_default_registration_status' => $default_reg_status,
-            'EVT_member_only'                 => $old_event['member_only'],
-            'EVT_phone'                       => $old_event['phone'],
-            'EVT_allow_overflow'              => 'Y' == $old_event['allow_overflow'],
-            'EVT_timezone_string'             => $old_event['timezone_string'],
-            'EVT_external_URL'                => $old_event['externalURL'],
-            'EVT_donations'                   => false,// doesn't exist in 3.1
-
-        ];
-        $data_types         = [
-            '%s',// EVT_ID
-            '%d',// EVT_display_desc
-            '%d',// EVT_display_ticket_selector
-            '%s',// EVT_visible_on
-            '%d',// EVT_additional_limit
-            '%s',// EVT_default_registration_status
-            '%d',// EVT_member_only
-            '%s',// EVT_phone
-            '%d',// EVT_allow_overflow
-            '%s',// EVT_timezone_string
-            '%s',// EVT_external_URL
-            '%d',// EVT_donations
-        ];
-        $success            = $wpdb->insert(
-            $this->_new_meta_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,
-                    $this->_new_meta_table,
-                    $cols_n_values,
-                    $data_types
-                )
-            );
-            return 0;
-        }
-        return $wpdb->insert_id;
-    }
-
-
-    /**
-     * @param $old_event
-     * @return int
-     */
-    private function _maybe_create_venue($old_event): int
-    {
-        if (
-            $old_event['address'] ||
-            $old_event['address2'] ||
-            $old_event['city'] ||
-            $old_event['state'] ||
-            $old_event['zip'] ||
-            $old_event['venue_title'] ||
-            $old_event['venue_url'] ||
-            $old_event['venue_image'] ||
-            $old_event['venue_phone'] ||
-            $old_event['virtual_url'] ||
-            $old_event['virtual_phone']
-        ) {
-            $old_id = $this->_duplicate_venue_exists($old_event);
-            if ($old_id) {
-                return $old_id;
-            }
-            $new_id = $this->_insert_venue_into_posts($old_event);
-            if ($new_id) {
-                $this->_insert_venue_into_meta_table($new_id, $old_event);
-                $guid = $old_event['venue_image'] ?? null;
-                if ($guid) {
-                    $this->get_migration_script()->convert_image_url_to_attachment_and_attach_to_post(
-                        $guid,
-                        $new_id,
-                        $this
-                    );
-                }
-            }
-            // we don't bother recording the conversion from old events to venues as that
-            // will complicate finding the conversion from old venues to new events
-            return $new_id;
-        }
-        return 0;
-    }
-
-
-    /**
-     * Assuming there is venue data on this event, check if there is a duplicate venue already in the system for it.
-     * If so, return it. Otherwise, return NULL.
-     *
-     * @param array $old_event
-     * @return int duplicate venue id
-     */
-    private function _duplicate_venue_exists(array $old_event): int
-    {
-        global $wpdb;
-        $conditions     = [
-            'VNU_address'       => $old_event ['address'],
-            'VNU_address2'      => $old_event['address2'],
-            'VNU_city'          => $old_event['city'],
-            'VNU_zip'           => $old_event['zip'],
-            'post_title'        => $this->_get_venue_title_for_event($old_event),
-            'VNU_phone'         => $old_event['venue_phone'],// VNU_phone
-            'VNU_url'           => $old_event['venue_url'],// VNU_url
-            'VNU_virtual_phone' => $old_event['virtual_phone'],// VNU_virtual_phone
-            'VNU_virtual_url'   => $old_event['virtual_url'],// VNU_virtual_url
-        ];
-        $sql_conditions = [];
-        foreach ($conditions as $column => $value) {
-            $sql_conditions [] = $wpdb->prepare("$column = %s", $value);
-        }
-        $query = "SELECT VNU_ID
+	private string $_old_start_end_table;
+
+	private string $_new_meta_table;
+
+	private string $_new_datetime_table;
+
+
+	/**
+	 * Just initializes the status of the migration
+	 */
+	public function __construct()
+	{
+		global $wpdb;
+		$this->_old_table           = $wpdb->prefix . "events_detail";
+		$this->_old_start_end_table = $wpdb->prefix . "events_start_end";
+		$this->_new_table           = $wpdb->prefix . "posts";
+		$this->_new_meta_table      = $wpdb->prefix . "esp_event_meta";
+		$this->_new_datetime_table  = $wpdb->prefix . "esp_datetime";
+		$this->_pretty_name         = esc_html__("Events", "event_espresso");
+		parent::__construct();
+	}
+
+
+	/**
+	 * Counts the records to migrate; the public version may cache it
+	 *
+	 * @return int
+	 */
+	public function _count_records_to_migrate(): int
+	{
+		global $wpdb;
+		return (int) $wpdb->get_var("SELECT COUNT(*) FROM " . $this->_old_table . ' WHERE event_status !="D"');
+	}
+
+
+	/**
+	 * 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
+	 * @throws EE_Error
+	 */
+	protected function _migration_step($num_items_to_migrate = 50)
+	{
+		global $wpdb;
+		// because the migration of each event can be a LOT more work, make each step smaller
+		$num_items_to_migrate     = max(1, $num_items_to_migrate / 5);
+		$events                   =
+			$wpdb->get_results(
+				$wpdb->prepare(
+					"SELECT * FROM $this->_old_table WHERE event_status!='D' LIMIT %d,%d",
+					$this->count_records_migrated(),
+					$num_items_to_migrate
+				),
+				ARRAY_A
+			);
+		$items_migrated_this_step = 0;
+
+		foreach ($events as $event_row) {
+			$guid = null;
+			// insert new 4.1 Attendee object using $wpdb
+			$post_id = $this->_insert_cpt($event_row);
+			if ($post_id) {
+				$this->get_migration_script()->set_mapping(
+					$this->_old_table,
+					$event_row['id'],
+					$this->_new_table,
+					$post_id
+				);
+				$meta_id = $this->_insert_event_meta($event_row, $post_id);
+				if ($meta_id) {
+					$this->get_migration_script()->set_mapping(
+						$this->_old_table,
+						$event_row['id'],
+						$this->_new_meta_table,
+						$meta_id
+					);
+				}
+				$this->_convert_start_end_times($event_row, $post_id);
+				$event_meta = maybe_unserialize($event_row['event_meta']);
+				$guid       = $event_meta['event_thumbnail_url'] ?? null;
+				if ($guid) {
+					$this->get_migration_script()->convert_image_url_to_attachment_and_attach_to_post(
+						$guid,
+						$post_id,
+						$this
+					);
+				}
+				// maybe create a venue from info on the event?
+				$new_venue_id = $this->_maybe_create_venue($event_row);
+				if ($new_venue_id) {
+					$this->_insert_new_venue_to_event($post_id, $new_venue_id);
+				}
+				$this->_add_post_metas($event_row, $post_id);
+			}
+			$items_migrated_this_step++;
+			if ($guid) {
+				// if we had to check for an image attachment
+				// then let's call it a day (avoid timing out, because this took a long time)
+				break;
+			}
+		}
+		if ($this->count_records_migrated() + $items_migrated_this_step >= $this->count_records_to_migrate()) {
+			$this->set_status(EE_Data_Migration_Manager::status_completed);
+		}
+		return $items_migrated_this_step;
+	}
+
+
+	/**
+	 * Stores any extra 3.1 "event_meta" column things as post meta
+	 *
+	 * @param array $old_event
+	 * @param int   $post_id
+	 * @return void
+	 */
+	private function _add_post_metas(array $old_event, int $post_id)
+	{
+		$event_meta = maybe_unserialize($old_event['event_meta']);
+		if (! $event_meta || ! is_array($event_meta)) {
+			return;
+		}
+		unset($event_meta['date_submitted']);              // factored into CPT
+		unset($event_meta['additional_attendee_reg_info']);// factored into event meta table
+		unset($event_meta['default_payment_status']);      // dido
+		unset($event_meta['event_thumbnail_url']);         // used to find post featured image
+		foreach ($event_meta as $meta_key => $meta_value) {
+			if ($meta_key) {// if the meta key is just an empty string, ignore it
+				$success = add_post_meta($post_id, $meta_key, $meta_value, true);
+				if (! $success) {
+					$this->add_error(
+						sprintf(
+							esc_html__(
+								"Could not add post meta for CPT with ID #%d. Meta key: '%s',meta value:'%d' for 3.1 event: %s",
+								"event_espresso"
+							),
+							$post_id,
+							$meta_key,
+							$meta_value,
+							implode(",", $old_event)
+						)
+					);
+				}
+			}
+		}
+		if ($old_event['alt_email']) {
+			add_post_meta($post_id, 'alt_email', $old_event['alt_email']);
+		}
+		if ($old_event['recurrence_id']) {
+			add_post_meta($post_id, 'recurrence_id', $old_event['recurrence_id']);
+		}
+	}
+
+
+	/**
+	 * Finds a unique slug for this event, given its name (we could have simply used
+	 * the old unique_identifier column, but it added a long string of seemingly random characters onto the end
+	 * and really wasn't that pretty for a slug, so we decided we'd make our own slug again)
+	 *
+	 * @param string $event_name      (the name of the event for reading by humans)
+	 * @param string $old_identifier  the old EE3 identifier (a long unique string)
+	 * @param string $new_post_status a post status
+	 * @return string
+	 */
+	private function _find_unique_slug(
+		string $event_name,
+		string $old_identifier = '',
+		string $new_post_status = 'publish'
+	): string {
+		$original_name = $event_name ? sanitize_title($event_name) : $old_identifier;
+		return wp_unique_post_slug($original_name, 0, $new_post_status, EspressoPostType::EVENTS, 0);
+	}
+
+
+	/**
+	 * returns whether there is a post that has this same slug (post_title)
+	 *
+	 * @param string $slug
+	 * @return boolean
+	 * @global wpdb  $wpdb
+	 */
+	private function _other_post_exists_with_that_slug(string $slug): bool
+	{
+		global $wpdb;
+		$query =
+			$wpdb->prepare(
+				"SELECT COUNT(ID) FROM $this->_new_table WHERE event_status != 'D' AND post_name = %s",
+				$slug
+			);
+		$count = $wpdb->get_var($query);
+		return (bool) intval($count);
+	}
+
+
+	/**
+	 * @param $old_event
+	 * @return int
+	 */
+	private function _insert_cpt($old_event): int
+	{
+		global $wpdb;
+		// convert 3.1 event status to 4.1 CPT status
+		// for reference, 3.1 event stati available for setting are:
+		//      $status = array(array('id' => 'A', 'text' => esc_html__('Public', 'event_espresso')), array('id' => 'S', 'text' => esc_html__('Waitlist', 'event_espresso')), array('id' => 'O', 'text' => esc_html__('Ongoing', 'event_espresso')), array('id' => 'R', 'text' => esc_html__('Draft', 'event_espresso')), array('id' => 'D', 'text' => esc_html__('Deleted', 'event_espresso')));
+		//      and the json api uses the following to convert from 3.1 to 4.0
+		//      'S'=>'secondary/waitlist',
+		//      'A'=>'active',
+		//      'X'=>'denied',
+		//      'IA'=>'inactive',
+		//      'O'=>'ongoing',
+		//      'P'=>'pending',
+		//      'R'=>'draft',
+		//      'D'=>'deleted');
+		//      4.1 Event Post stati are the normal post statis
+		//      (publish,future,draft,pending,private,trash,auto-draft,inherit)
+		//      and 3 custom ones: cancelled,postponed,sold_out
+		$status_conversions = [
+			'R'  => 'draft',
+			'X'  => 'draft',
+			// 4.1 doesn't have a "not approved for publishing" status. this is what posts are set to that aren't approved
+			'P'  => 'pending',
+			'IA' => 'draft',
+			// draft and in the past
+			// IA=inactive in 3.1: events were switched to this when they expired. in 4.1 that's just calculated
+			'O'  => 'publish',
+			// @todo: will be an event type later; if this is the status, set the end date WAAAY later; and add term for 'ongoing'
+			'A'  => 'publish',
+			'S'  => 'draft',
+			// @todo: is it ok to just mark secondary/waitlist events as DRAFTS?
+			'D'  => 'trash',
+		];
+		$post_status        = $status_conversions[ $old_event['event_status'] ];
+		// check if we've sold out
+		if (intval($old_event['reg_limit']) <= self::count_registrations($old_event['id'])) {
+			$post_status = 'sold_out';
+		}
+		//      FYI postponed and cancelled don't exist in 3.1
+		$cols_n_values                      = [
+			'post_title'        => stripslashes($old_event['event_name']),// EVT_name
+			'post_content'      => stripslashes($old_event['event_desc']),// EVT_desc
+			'post_name'         => $this->_find_unique_slug(
+				$old_event['event_name'],
+				$old_event['event_identifier'],
+				$post_status
+			),// EVT_slug
+			'post_date'         => $old_event['submitted'],// EVT_created NOT
+			'post_date_gmt'     => get_gmt_from_date($old_event['submitted']),
+			'post_excerpt'      => '',// EVT_short_desc
+			'post_modified'     => $old_event['submitted'],// EVT_modified
+			'post_modified_gmt' => get_gmt_from_date($old_event['submitted']),
+			'post_author'       => $old_event['wp_user'],// EVT_wp_user
+			'post_parent'       => 0,// parent maybe get this from some REM field?
+			'menu_order'        => 0,// EVT_order
+			'post_type'         => EspressoPostType::EVENTS,// post_type
+			'post_status'       => $post_status,// status
+		];
+		$cols_n_values_with_no_invalid_text = [];
+		foreach ($cols_n_values as $col => $value) {
+			$value_sans_invalid_chars = $wpdb->strip_invalid_text_for_column($this->_new_table, $col, $value);
+			if (! is_wp_error($value_sans_invalid_chars)) {
+				$cols_n_values_with_no_invalid_text[ $col ] = $value_sans_invalid_chars;
+			} else {
+				// otherwise leave it as-is. It will blow everything up and stop the migration
+				$cols_n_values_with_no_invalid_text[ $col ] = $value;
+			}
+		}
+		$cols_n_values = $cols_n_values_with_no_invalid_text;
+		$data_types    = [
+			'%s',// EVT_name
+			'%s',// EVT_desc
+			'%s',// EVT_slug
+			'%s',// EVT_created
+			'%s',
+			'%s',// EVT_short_desc
+			'%s',// EVT_modified
+			'%s',
+			'%s',// EVT_wp_user
+			'%d',// post_parent
+			'%d',// EVT_order
+			'%s',// post_type
+			'%s',// status
+		];
+		$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,
+					$this->_new_table,
+					$cols_n_values,
+					$data_types
+				)
+			);
+			return 0;
+		}
+		return $wpdb->insert_id;
+	}
+
+
+	/**
+	 * Counts all the registrations for the event in the 3.1 DB. (takes into account attendee rows which represent
+	 * various registrations)
+	 *
+	 * @param int   $event_id
+	 * @return int
+	 * @global wpdb $wpdb
+	 */
+	public static function count_registrations(int $event_id): int
+	{
+		global $wpdb;
+		return (int) $wpdb->get_var(
+			$wpdb->prepare("SELECT sum(quantity) FROM {$wpdb->prefix}events_attendee WHERE event_id=%d", $event_id)
+		);
+	}
+
+
+	/**
+	 * @param $old_event
+	 * @param $new_cpt_id
+	 * @return int
+	 */
+	private function _insert_event_meta($old_event, $new_cpt_id): int
+	{
+		global $wpdb;
+		$event_meta = maybe_unserialize($old_event['event_meta']);
+		//      for reference, 3.1 'default_payment_status' are: $default_payment_status = array(
+		//  array('id' => "", 'text' => 'No Change'),
+		//  array('id' => 'Incomplete', 'text' => 'Incomplete'),
+		//  array('id' => 'Pending', 'text' => 'Pending'),
+		//  //array('id' => 'Completed', 'text' => 'Completed')
+		// );
+		$default_reg_status =
+			$this->get_migration_script()->convert_3_1_payment_status_to_4_1_STS_ID(
+				$event_meta['default_payment_status'] ?? '',
+				intval($old_event['require_pre_approval'])
+			);
+		$cols_n_values      = [
+			'EVT_ID'                          => $new_cpt_id,// EVT_ID_fk
+			'EVT_display_desc'                => 'Y' == $old_event['display_desc'],
+			'EVT_display_ticket_selector'     => 'Y' == $old_event['display_reg_form'],
+			'EVT_visible_on'                  => $this->get_migration_script()->convert_date_string_to_utc(
+				$this,
+				$old_event,
+				current_time(
+					'mysql'
+				),
+				$old_event['timezone_string']
+			),// don't use the old 'visible_on', as it wasn't ever used
+			'EVT_additional_limit'            => $old_event['allow_multiple'] == 'N' ? 1
+				: $old_event['additional_limit'],
+			'EVT_default_registration_status' => $default_reg_status,
+			'EVT_member_only'                 => $old_event['member_only'],
+			'EVT_phone'                       => $old_event['phone'],
+			'EVT_allow_overflow'              => 'Y' == $old_event['allow_overflow'],
+			'EVT_timezone_string'             => $old_event['timezone_string'],
+			'EVT_external_URL'                => $old_event['externalURL'],
+			'EVT_donations'                   => false,// doesn't exist in 3.1
+
+		];
+		$data_types         = [
+			'%s',// EVT_ID
+			'%d',// EVT_display_desc
+			'%d',// EVT_display_ticket_selector
+			'%s',// EVT_visible_on
+			'%d',// EVT_additional_limit
+			'%s',// EVT_default_registration_status
+			'%d',// EVT_member_only
+			'%s',// EVT_phone
+			'%d',// EVT_allow_overflow
+			'%s',// EVT_timezone_string
+			'%s',// EVT_external_URL
+			'%d',// EVT_donations
+		];
+		$success            = $wpdb->insert(
+			$this->_new_meta_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,
+					$this->_new_meta_table,
+					$cols_n_values,
+					$data_types
+				)
+			);
+			return 0;
+		}
+		return $wpdb->insert_id;
+	}
+
+
+	/**
+	 * @param $old_event
+	 * @return int
+	 */
+	private function _maybe_create_venue($old_event): int
+	{
+		if (
+			$old_event['address'] ||
+			$old_event['address2'] ||
+			$old_event['city'] ||
+			$old_event['state'] ||
+			$old_event['zip'] ||
+			$old_event['venue_title'] ||
+			$old_event['venue_url'] ||
+			$old_event['venue_image'] ||
+			$old_event['venue_phone'] ||
+			$old_event['virtual_url'] ||
+			$old_event['virtual_phone']
+		) {
+			$old_id = $this->_duplicate_venue_exists($old_event);
+			if ($old_id) {
+				return $old_id;
+			}
+			$new_id = $this->_insert_venue_into_posts($old_event);
+			if ($new_id) {
+				$this->_insert_venue_into_meta_table($new_id, $old_event);
+				$guid = $old_event['venue_image'] ?? null;
+				if ($guid) {
+					$this->get_migration_script()->convert_image_url_to_attachment_and_attach_to_post(
+						$guid,
+						$new_id,
+						$this
+					);
+				}
+			}
+			// we don't bother recording the conversion from old events to venues as that
+			// will complicate finding the conversion from old venues to new events
+			return $new_id;
+		}
+		return 0;
+	}
+
+
+	/**
+	 * Assuming there is venue data on this event, check if there is a duplicate venue already in the system for it.
+	 * If so, return it. Otherwise, return NULL.
+	 *
+	 * @param array $old_event
+	 * @return int duplicate venue id
+	 */
+	private function _duplicate_venue_exists(array $old_event): int
+	{
+		global $wpdb;
+		$conditions     = [
+			'VNU_address'       => $old_event ['address'],
+			'VNU_address2'      => $old_event['address2'],
+			'VNU_city'          => $old_event['city'],
+			'VNU_zip'           => $old_event['zip'],
+			'post_title'        => $this->_get_venue_title_for_event($old_event),
+			'VNU_phone'         => $old_event['venue_phone'],// VNU_phone
+			'VNU_url'           => $old_event['venue_url'],// VNU_url
+			'VNU_virtual_phone' => $old_event['virtual_phone'],// VNU_virtual_phone
+			'VNU_virtual_url'   => $old_event['virtual_url'],// VNU_virtual_url
+		];
+		$sql_conditions = [];
+		foreach ($conditions as $column => $value) {
+			$sql_conditions [] = $wpdb->prepare("$column = %s", $value);
+		}
+		$query = "SELECT VNU_ID
 					FROM
 		$wpdb->posts as p INNER JOIN
 		{$wpdb->prefix}esp_venue_meta as v ON p.ID = v.VNU_ID
 			WHERE " . implode(" AND ", $sql_conditions) . " LIMIT 1";
-        return (int) $wpdb->get_var($query);
-    }
-
-
-    /**
-     * Gets teh venue's title or makes one up if there is none
-     *
-     * @param array $event_data_array keys are events_details columns and values are their values
-     * @return string
-     */
-    protected function _get_venue_title_for_event(array $event_data_array): string
-    {
-        return $event_data_array['venue_title']
-            ? stripslashes($event_data_array['venue_title'])
-            : stripslashes(
-                sprintf(
-                    esc_html__('Venue of %s', 'event_espresso'),
-                    $event_data_array['event_name']
-                )
-            );
-    }
-
-
-    /**
-     * Inserts the CPT
-     *
-     * @param array $old_event keys are cols, values are col values
-     * @return int
-     */
-    private function _insert_venue_into_posts(array $old_event): int
-    {
-        global $wpdb;
-        $insertion_array  = [
-            'post_title'        => $this->_get_venue_title_for_event($old_event),// VNU_name
-            'post_content'      => '',// VNU_desc
-            'post_name'         => $this->_find_unique_slug(
-                $old_event['venue_title'],
-                sanitize_title('venue-of-' . $old_event['event_name'])
-            ),// VNU_identifier
-            'post_date'         => current_time('mysql'),// VNU_created
-            'post_date_gmt'     => get_gmt_from_date(current_time('mysql')),
-            'post_excerpt'      => '',// VNU_short_desc arbitrary only 50 characters
-            'post_modified'     => current_time('mysql'),// VNU_modified
-            'post_modified_gmt' => get_gmt_from_date(current_time('mysql')),
-            'post_author'       => $old_event['wp_user'],// VNU_wp_user
-            'post_parent'       => 0,// parent
-            'menu_order'        => 0,// VNU_order
-            'post_type'         => EspressoPostType::VENUES,// post_type
-        ];
-        $data_types_array = [
-            '%s',// VNU_name
-            '%s',// VNU_desc
-            '%s',// VNU_identifier
-            '%s',// VNU_created
-            '%s',
-            '%s',// VNU_short_desc
-            '%s',// VNU_modified
-            '%s',
-            '%d',// VNU_wp_user
-            '%d',// parent
-            '%d',// VNU_order
-            '%s',// post_type
-        ];
-        $success          = $wpdb->insert(
-            $wpdb->posts,
-            $insertion_array,
-            $data_types_array
-        );
-        if (! $success) {
-            $this->add_error(
-                $this->get_migration_script()->_create_error_message_for_db_insertion(
-                    $this->_old_table,
-                    $old_event,
-                    $this->_new_table,
-                    $insertion_array,
-                    $data_types_array
-                )
-            );
-            return 0;
-        }
-        return $wpdb->insert_id;
-    }
-
-
-    /**
-     * Inserts into the venue_meta table
-     *
-     * @param int   $cpt_id
-     * @param array $old_event
-     * @return void
-     */
-    private function _insert_venue_into_meta_table(int $cpt_id, array $old_event): void
-    {
-        global $wpdb;
-
-        // assume the country is the same as the organization's old settings
-        $country_iso = $this->get_migration_script()->get_default_country_iso();
-        // find the state from the venue, or the organization, or just guess california
-        if (! $old_event['state']) {
-            $old_org_options = get_option('events_organization_settings');
-            $state_name      = stripslashes($old_org_options['organization_state']);
-        } else {
-            $state_name = $old_event['state'];
-        }
-        if (! $state_name) {
-            $state_name = 'CA';
-        }
-        // get a state ID with the same name, if possible
-        try {
-            $state    = $this->get_migration_script()->get_or_create_state($state_name, $country_iso);
-            $state_id = $state['STA_ID'];
-        } catch (EE_Error $e) {
-            $this->add_error($e->getMessage());
-            $state_id = 0;
-        }
-        // now insert into meta table
-        $insertion_array = [
-            'VNU_ID'              => $cpt_id,// VNU_ID_fk
-            'VNU_address'         => stripslashes($old_event['address']),// VNU_address
-            'VNU_address2'        => stripslashes($old_event['address2']),// VNU_address2
-            'VNU_city'            => stripslashes($old_event['city']),// VNU_city
-            'STA_ID'              => $state_id,// STA_ID
-            'CNT_ISO'             => $country_iso,// CNT_ISO
-            'VNU_zip'             => $old_event['zip'],// VNU_zip
-            'VNU_phone'           => $old_event['venue_phone'],// VNU_phone
-            'VNU_capacity'        => -1,// VNU_capacity
-            'VNU_url'             => $old_event['venue_url'],// VNU_url
-            'VNU_virtual_phone'   => $old_event['virtual_phone'],// VNU_virtual_phone
-            'VNU_virtual_url'     => $old_event['virtual_url'],// VNU_virtual_url
-            'VNU_google_map_link' => '',// VNU_google_map_link
-            'VNU_enable_for_gmap' => true, // VNU_enable_for_gmap
-        ];
-        $data_types      = [
-            '%d',// VNU_ID_fk
-            '%s',// VNU_address
-            '%s',// VNU_address2
-            '%s',// VNU_city
-            '%d',// STA_ID
-            '%s',// CNT_ISO
-            '%s',// VNU_zip
-            '%s',// VNU_phone
-            '%d',// VNU_capacity
-            '%s',// VNU_url
-            '%s',// VNU_virtual_phone
-            '%s',// VNU_virtual_url
-            '%s',// VNU_google_map_link
-            '%d',// VNU_enable_for_gmap
-        ];
-        $success         = $wpdb->insert($wpdb->prefix . "esp_venue_meta", $insertion_array, $data_types);
-        if (! $success) {
-            $this->add_error(
-                $this->get_migration_script()->_create_error_message_for_db_insertion(
-                    $this->_old_table,
-                    $old_event,
-                    $this->_new_meta_table,
-                    $insertion_array,
-                    $data_types
-                )
-            );
-        }
-    }
-
-
-    /**
-     * @param $new_event_id
-     * @param $new_venue_id
-     * @return void
-     */
-    private function _insert_new_venue_to_event($new_event_id, $new_venue_id): void
-    {
-        global $wpdb;
-        if (! $new_event_id) {
-            $this->add_error(
-                sprintf(esc_html__("Could not find 4.1 event id for 3.1 event #%d.", "event_espresso"), $new_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"), $new_venue_id)
-            );
-            return;
-        }
-        $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($wpdb->prefix . "esp_event_venue", $cols_n_values, $data_types);
-        if (! $success) {
-            $this->add_error(
-                $this->get_migration_script()->_create_error_message_for_db_insertion(
-                    $this->_old_table,
-                    [],
-                    $this->_new_table,
-                    $cols_n_values,
-                    $data_types
-                )
-            );
-        }
-    }
-
-
-    /**
-     * Converts all the 3.1 start-end times for the event to 4.1 datetimes
-     *
-     * @param array $old_event  results of get_results(...,ARRAY_A)
-     * @param int   $new_cpt_id new post ID
-     * @return void (if there are errors though, adds them to the stage's error list
-     * @throws EE_Error
-     * @global wpdb $wpdb
-     */
-    private function _convert_start_end_times(array $old_event, int $new_cpt_id)
-    {
-        $start_end_times = $this->_get_old_start_end_times($old_event['id']);
-        foreach ($start_end_times as $start_end_time) {
-            $datetime_id = $this->_insert_new_datetime($start_end_time, $old_event, $new_cpt_id);
-            if ($datetime_id) {
-                $this->get_migration_script()->set_mapping(
-                    $this->_old_start_end_table,
-                    $start_end_time['id'],
-                    $this->_new_datetime_table,
-                    $datetime_id
-                );
-            }
-        }
-    }
-
-
-    /**
-     * Queries the 3.1 wp_events_start_end table to get all the start and end times for the event
-     *
-     * @param int   $old_event_id
-     * @return array
-     * @global wpdb $wpdb
-     */
-    private function _get_old_start_end_times(int $old_event_id): array
-    {
-        global $wpdb;
-        return $wpdb->get_results(
-            $wpdb->prepare("SELECT * FROM $this->_old_start_end_table WHERE event_id=%d", $old_event_id),
-            ARRAY_A
-        );
-    }
-
-
-    /**
-     * Inserts a 4.1 datetime given the 3.1 start_end db row and event_details row
-     *
-     * @param array $start_end_time_row
-     * @param array $old_event_row
-     * @param int   $new_cpt_id
-     * @return int ID of new datetime
-     */
-    private function _insert_new_datetime(array $start_end_time_row, array $old_event_row, int $new_cpt_id): int
-    {
-        global $wpdb;
-        $start_date         = $old_event_row['start_date'];
-        $start_time         = $this->get_migration_script()->convertTimeFromAMPM($start_end_time_row['start_time']);
-        $end_date           = $old_event_row['end_date'];
-        $end_time           = $this->get_migration_script()->convertTimeFromAMPM($start_end_time_row['end_time']);
-        $existing_datetimes = $this->_count_other_datetimes_exist_for_new_event($new_cpt_id);
-        $start_datetime_utc =
-            $this->get_migration_script()->convert_date_string_to_utc(
-                $this,
-                $start_end_time_row,
-                "$start_date $start_time:00",
-                $old_event_row['timezone_string']
-            );
-        $end_datetime_utc   =
-            $this->get_migration_script()->convert_date_string_to_utc(
-                $this,
-                $start_end_time_row,
-                "$end_date $end_time:00",
-                $old_event_row['timezone_string']
-            );
-        $cols_n_values      = [
-            'EVT_ID'        => $new_cpt_id,
-            // EVT_ID
-            'DTT_EVT_start' => $start_datetime_utc,
-            // DTT_EVT_start
-            'DTT_EVT_end'   => $end_datetime_utc,
-            // DTT_EVT_end
-            'DTT_reg_limit' => intval($start_end_time_row['reg_limit']) ? $start_end_time_row['reg_limit']
-                : $old_event_row['reg_limit'],
-            // DTT_reg_limit
-            'DTT_sold'      => 0,
-            // note: we will increment this as registrations are added during the migration
-            //          'DTT_is_primary'=> 0 == $existing_datetimes ,//DTT_is_primary... if count==0, then we'll call it the 'primary'
-            'DTT_order'     => $existing_datetimes,
-            // DTT_order, just give it the same order as the count of how many datetimes already exist
-            'DTT_parent'    => 0,
-            'DTT_deleted'   => false,
-        ];
-        $data_types         = [
-            '%d',// EVT_Id
-            '%s',// DTT_EVT_start
-            '%s',// DTT_EVT_end
-            '%d',// DTT_reg_limit
-            '%d',// DTT_sold
-            //          '%d',//DTT_is_primary
-            '%d',// DTT_order
-            '%d',// DTT_parent
-            '%d',// DTT_deleted
-        ];
-        $success            = $wpdb->insert($this->_new_datetime_table, $cols_n_values, $data_types);
-        if (! $success) {
-            $this->add_error(
-                $this->get_migration_script()->_create_error_message_for_db_insertion(
-                    $this->_old_start_end_table,
-                    array_merge($old_event_row, $start_end_time_row),
-                    $this->_new_datetime_table,
-                    $cols_n_values,
-                    $data_types
-                )
-            );
-            return 0;
-        }
-        return $wpdb->insert_id;
-    }
-
-
-    /**
-     * Checks if there's a 4.1 datetime for this event already. This is mostly only handy
-     * when deciding whether a datetime we're about ot insert should be the 'primary' or not
-     *
-     * @param int   $cpt_event_id
-     * @return int
-     * @global wpdb $wpdb
-     */
-    private function _count_other_datetimes_exist_for_new_event(int $cpt_event_id): int
-    {
-        global $wpdb;
-        return (int) $wpdb->get_var(
-            $wpdb->prepare(
-                "SELECT COUNT(*) FROM $this->_new_datetime_table WHERE EVT_ID=%d",
-                $cpt_event_id
-            )
-        );
-    }
+		return (int) $wpdb->get_var($query);
+	}
+
+
+	/**
+	 * Gets teh venue's title or makes one up if there is none
+	 *
+	 * @param array $event_data_array keys are events_details columns and values are their values
+	 * @return string
+	 */
+	protected function _get_venue_title_for_event(array $event_data_array): string
+	{
+		return $event_data_array['venue_title']
+			? stripslashes($event_data_array['venue_title'])
+			: stripslashes(
+				sprintf(
+					esc_html__('Venue of %s', 'event_espresso'),
+					$event_data_array['event_name']
+				)
+			);
+	}
+
+
+	/**
+	 * Inserts the CPT
+	 *
+	 * @param array $old_event keys are cols, values are col values
+	 * @return int
+	 */
+	private function _insert_venue_into_posts(array $old_event): int
+	{
+		global $wpdb;
+		$insertion_array  = [
+			'post_title'        => $this->_get_venue_title_for_event($old_event),// VNU_name
+			'post_content'      => '',// VNU_desc
+			'post_name'         => $this->_find_unique_slug(
+				$old_event['venue_title'],
+				sanitize_title('venue-of-' . $old_event['event_name'])
+			),// VNU_identifier
+			'post_date'         => current_time('mysql'),// VNU_created
+			'post_date_gmt'     => get_gmt_from_date(current_time('mysql')),
+			'post_excerpt'      => '',// VNU_short_desc arbitrary only 50 characters
+			'post_modified'     => current_time('mysql'),// VNU_modified
+			'post_modified_gmt' => get_gmt_from_date(current_time('mysql')),
+			'post_author'       => $old_event['wp_user'],// VNU_wp_user
+			'post_parent'       => 0,// parent
+			'menu_order'        => 0,// VNU_order
+			'post_type'         => EspressoPostType::VENUES,// post_type
+		];
+		$data_types_array = [
+			'%s',// VNU_name
+			'%s',// VNU_desc
+			'%s',// VNU_identifier
+			'%s',// VNU_created
+			'%s',
+			'%s',// VNU_short_desc
+			'%s',// VNU_modified
+			'%s',
+			'%d',// VNU_wp_user
+			'%d',// parent
+			'%d',// VNU_order
+			'%s',// post_type
+		];
+		$success          = $wpdb->insert(
+			$wpdb->posts,
+			$insertion_array,
+			$data_types_array
+		);
+		if (! $success) {
+			$this->add_error(
+				$this->get_migration_script()->_create_error_message_for_db_insertion(
+					$this->_old_table,
+					$old_event,
+					$this->_new_table,
+					$insertion_array,
+					$data_types_array
+				)
+			);
+			return 0;
+		}
+		return $wpdb->insert_id;
+	}
+
+
+	/**
+	 * Inserts into the venue_meta table
+	 *
+	 * @param int   $cpt_id
+	 * @param array $old_event
+	 * @return void
+	 */
+	private function _insert_venue_into_meta_table(int $cpt_id, array $old_event): void
+	{
+		global $wpdb;
+
+		// assume the country is the same as the organization's old settings
+		$country_iso = $this->get_migration_script()->get_default_country_iso();
+		// find the state from the venue, or the organization, or just guess california
+		if (! $old_event['state']) {
+			$old_org_options = get_option('events_organization_settings');
+			$state_name      = stripslashes($old_org_options['organization_state']);
+		} else {
+			$state_name = $old_event['state'];
+		}
+		if (! $state_name) {
+			$state_name = 'CA';
+		}
+		// get a state ID with the same name, if possible
+		try {
+			$state    = $this->get_migration_script()->get_or_create_state($state_name, $country_iso);
+			$state_id = $state['STA_ID'];
+		} catch (EE_Error $e) {
+			$this->add_error($e->getMessage());
+			$state_id = 0;
+		}
+		// now insert into meta table
+		$insertion_array = [
+			'VNU_ID'              => $cpt_id,// VNU_ID_fk
+			'VNU_address'         => stripslashes($old_event['address']),// VNU_address
+			'VNU_address2'        => stripslashes($old_event['address2']),// VNU_address2
+			'VNU_city'            => stripslashes($old_event['city']),// VNU_city
+			'STA_ID'              => $state_id,// STA_ID
+			'CNT_ISO'             => $country_iso,// CNT_ISO
+			'VNU_zip'             => $old_event['zip'],// VNU_zip
+			'VNU_phone'           => $old_event['venue_phone'],// VNU_phone
+			'VNU_capacity'        => -1,// VNU_capacity
+			'VNU_url'             => $old_event['venue_url'],// VNU_url
+			'VNU_virtual_phone'   => $old_event['virtual_phone'],// VNU_virtual_phone
+			'VNU_virtual_url'     => $old_event['virtual_url'],// VNU_virtual_url
+			'VNU_google_map_link' => '',// VNU_google_map_link
+			'VNU_enable_for_gmap' => true, // VNU_enable_for_gmap
+		];
+		$data_types      = [
+			'%d',// VNU_ID_fk
+			'%s',// VNU_address
+			'%s',// VNU_address2
+			'%s',// VNU_city
+			'%d',// STA_ID
+			'%s',// CNT_ISO
+			'%s',// VNU_zip
+			'%s',// VNU_phone
+			'%d',// VNU_capacity
+			'%s',// VNU_url
+			'%s',// VNU_virtual_phone
+			'%s',// VNU_virtual_url
+			'%s',// VNU_google_map_link
+			'%d',// VNU_enable_for_gmap
+		];
+		$success         = $wpdb->insert($wpdb->prefix . "esp_venue_meta", $insertion_array, $data_types);
+		if (! $success) {
+			$this->add_error(
+				$this->get_migration_script()->_create_error_message_for_db_insertion(
+					$this->_old_table,
+					$old_event,
+					$this->_new_meta_table,
+					$insertion_array,
+					$data_types
+				)
+			);
+		}
+	}
+
+
+	/**
+	 * @param $new_event_id
+	 * @param $new_venue_id
+	 * @return void
+	 */
+	private function _insert_new_venue_to_event($new_event_id, $new_venue_id): void
+	{
+		global $wpdb;
+		if (! $new_event_id) {
+			$this->add_error(
+				sprintf(esc_html__("Could not find 4.1 event id for 3.1 event #%d.", "event_espresso"), $new_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"), $new_venue_id)
+			);
+			return;
+		}
+		$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($wpdb->prefix . "esp_event_venue", $cols_n_values, $data_types);
+		if (! $success) {
+			$this->add_error(
+				$this->get_migration_script()->_create_error_message_for_db_insertion(
+					$this->_old_table,
+					[],
+					$this->_new_table,
+					$cols_n_values,
+					$data_types
+				)
+			);
+		}
+	}
+
+
+	/**
+	 * Converts all the 3.1 start-end times for the event to 4.1 datetimes
+	 *
+	 * @param array $old_event  results of get_results(...,ARRAY_A)
+	 * @param int   $new_cpt_id new post ID
+	 * @return void (if there are errors though, adds them to the stage's error list
+	 * @throws EE_Error
+	 * @global wpdb $wpdb
+	 */
+	private function _convert_start_end_times(array $old_event, int $new_cpt_id)
+	{
+		$start_end_times = $this->_get_old_start_end_times($old_event['id']);
+		foreach ($start_end_times as $start_end_time) {
+			$datetime_id = $this->_insert_new_datetime($start_end_time, $old_event, $new_cpt_id);
+			if ($datetime_id) {
+				$this->get_migration_script()->set_mapping(
+					$this->_old_start_end_table,
+					$start_end_time['id'],
+					$this->_new_datetime_table,
+					$datetime_id
+				);
+			}
+		}
+	}
+
+
+	/**
+	 * Queries the 3.1 wp_events_start_end table to get all the start and end times for the event
+	 *
+	 * @param int   $old_event_id
+	 * @return array
+	 * @global wpdb $wpdb
+	 */
+	private function _get_old_start_end_times(int $old_event_id): array
+	{
+		global $wpdb;
+		return $wpdb->get_results(
+			$wpdb->prepare("SELECT * FROM $this->_old_start_end_table WHERE event_id=%d", $old_event_id),
+			ARRAY_A
+		);
+	}
+
+
+	/**
+	 * Inserts a 4.1 datetime given the 3.1 start_end db row and event_details row
+	 *
+	 * @param array $start_end_time_row
+	 * @param array $old_event_row
+	 * @param int   $new_cpt_id
+	 * @return int ID of new datetime
+	 */
+	private function _insert_new_datetime(array $start_end_time_row, array $old_event_row, int $new_cpt_id): int
+	{
+		global $wpdb;
+		$start_date         = $old_event_row['start_date'];
+		$start_time         = $this->get_migration_script()->convertTimeFromAMPM($start_end_time_row['start_time']);
+		$end_date           = $old_event_row['end_date'];
+		$end_time           = $this->get_migration_script()->convertTimeFromAMPM($start_end_time_row['end_time']);
+		$existing_datetimes = $this->_count_other_datetimes_exist_for_new_event($new_cpt_id);
+		$start_datetime_utc =
+			$this->get_migration_script()->convert_date_string_to_utc(
+				$this,
+				$start_end_time_row,
+				"$start_date $start_time:00",
+				$old_event_row['timezone_string']
+			);
+		$end_datetime_utc   =
+			$this->get_migration_script()->convert_date_string_to_utc(
+				$this,
+				$start_end_time_row,
+				"$end_date $end_time:00",
+				$old_event_row['timezone_string']
+			);
+		$cols_n_values      = [
+			'EVT_ID'        => $new_cpt_id,
+			// EVT_ID
+			'DTT_EVT_start' => $start_datetime_utc,
+			// DTT_EVT_start
+			'DTT_EVT_end'   => $end_datetime_utc,
+			// DTT_EVT_end
+			'DTT_reg_limit' => intval($start_end_time_row['reg_limit']) ? $start_end_time_row['reg_limit']
+				: $old_event_row['reg_limit'],
+			// DTT_reg_limit
+			'DTT_sold'      => 0,
+			// note: we will increment this as registrations are added during the migration
+			//          'DTT_is_primary'=> 0 == $existing_datetimes ,//DTT_is_primary... if count==0, then we'll call it the 'primary'
+			'DTT_order'     => $existing_datetimes,
+			// DTT_order, just give it the same order as the count of how many datetimes already exist
+			'DTT_parent'    => 0,
+			'DTT_deleted'   => false,
+		];
+		$data_types         = [
+			'%d',// EVT_Id
+			'%s',// DTT_EVT_start
+			'%s',// DTT_EVT_end
+			'%d',// DTT_reg_limit
+			'%d',// DTT_sold
+			//          '%d',//DTT_is_primary
+			'%d',// DTT_order
+			'%d',// DTT_parent
+			'%d',// DTT_deleted
+		];
+		$success            = $wpdb->insert($this->_new_datetime_table, $cols_n_values, $data_types);
+		if (! $success) {
+			$this->add_error(
+				$this->get_migration_script()->_create_error_message_for_db_insertion(
+					$this->_old_start_end_table,
+					array_merge($old_event_row, $start_end_time_row),
+					$this->_new_datetime_table,
+					$cols_n_values,
+					$data_types
+				)
+			);
+			return 0;
+		}
+		return $wpdb->insert_id;
+	}
+
+
+	/**
+	 * Checks if there's a 4.1 datetime for this event already. This is mostly only handy
+	 * when deciding whether a datetime we're about ot insert should be the 'primary' or not
+	 *
+	 * @param int   $cpt_event_id
+	 * @return int
+	 * @global wpdb $wpdb
+	 */
+	private function _count_other_datetimes_exist_for_new_event(int $cpt_event_id): int
+	{
+		global $wpdb;
+		return (int) $wpdb->get_var(
+			$wpdb->prepare(
+				"SELECT COUNT(*) FROM $this->_new_datetime_table WHERE EVT_ID=%d",
+				$cpt_event_id
+			)
+		);
+	}
 }

Spacing +143 added lines, -143 removed lines

@@ -189,11 +189,11 @@ 
     public function __construct()
     {
         global $wpdb;
-        $this->_old_table           = $wpdb->prefix . "events_detail";
-        $this->_old_start_end_table = $wpdb->prefix . "events_start_end";
-        $this->_new_table           = $wpdb->prefix . "posts";
-        $this->_new_meta_table      = $wpdb->prefix . "esp_event_meta";
-        $this->_new_datetime_table  = $wpdb->prefix . "esp_datetime";
+        $this->_old_table           = $wpdb->prefix."events_detail";
+        $this->_old_start_end_table = $wpdb->prefix."events_start_end";
+        $this->_new_table           = $wpdb->prefix."posts";
+        $this->_new_meta_table      = $wpdb->prefix."esp_event_meta";
+        $this->_new_datetime_table  = $wpdb->prefix."esp_datetime";
         $this->_pretty_name         = esc_html__("Events", "event_espresso");
         parent::__construct();
     }
@@ -207,7 +207,7 @@ 
     public function _count_records_to_migrate(): int
     {
         global $wpdb;
-        return (int) $wpdb->get_var("SELECT COUNT(*) FROM " . $this->_old_table . ' WHERE event_status !="D"');
+        return (int) $wpdb->get_var("SELECT COUNT(*) FROM ".$this->_old_table.' WHERE event_status !="D"');
     }
 
 
@@ -300,17 +300,17 @@ 
     private function _add_post_metas(array $old_event, int $post_id)
     {
         $event_meta = maybe_unserialize($old_event['event_meta']);
-        if (! $event_meta || ! is_array($event_meta)) {
+        if ( ! $event_meta || ! is_array($event_meta)) {
             return;
         }
-        unset($event_meta['date_submitted']);              // factored into CPT
-        unset($event_meta['additional_attendee_reg_info']);// factored into event meta table
-        unset($event_meta['default_payment_status']);      // dido
-        unset($event_meta['event_thumbnail_url']);         // used to find post featured image
+        unset($event_meta['date_submitted']); // factored into CPT
+        unset($event_meta['additional_attendee_reg_info']); // factored into event meta table
+        unset($event_meta['default_payment_status']); // dido
+        unset($event_meta['event_thumbnail_url']); // used to find post featured image
         foreach ($event_meta as $meta_key => $meta_value) {
             if ($meta_key) {// if the meta key is just an empty string, ignore it
                 $success = add_post_meta($post_id, $meta_key, $meta_value, true);
-                if (! $success) {
+                if ( ! $success) {
                     $this->add_error(
                         sprintf(
                             esc_html__(
@@ -412,63 +412,63 @@ 
             // @todo: is it ok to just mark secondary/waitlist events as DRAFTS?
             'D'  => 'trash',
         ];
-        $post_status        = $status_conversions[ $old_event['event_status'] ];
+        $post_status = $status_conversions[$old_event['event_status']];
         // check if we've sold out
         if (intval($old_event['reg_limit']) <= self::count_registrations($old_event['id'])) {
             $post_status = 'sold_out';
         }
         //      FYI postponed and cancelled don't exist in 3.1
-        $cols_n_values                      = [
-            'post_title'        => stripslashes($old_event['event_name']),// EVT_name
-            'post_content'      => stripslashes($old_event['event_desc']),// EVT_desc
+        $cols_n_values = [
+            'post_title'        => stripslashes($old_event['event_name']), // EVT_name
+            'post_content'      => stripslashes($old_event['event_desc']), // EVT_desc
             'post_name'         => $this->_find_unique_slug(
                 $old_event['event_name'],
                 $old_event['event_identifier'],
                 $post_status
-            ),// EVT_slug
-            'post_date'         => $old_event['submitted'],// EVT_created NOT
+            ), // EVT_slug
+            'post_date'         => $old_event['submitted'], // EVT_created NOT
             'post_date_gmt'     => get_gmt_from_date($old_event['submitted']),
-            'post_excerpt'      => '',// EVT_short_desc
-            'post_modified'     => $old_event['submitted'],// EVT_modified
+            'post_excerpt'      => '', // EVT_short_desc
+            'post_modified'     => $old_event['submitted'], // EVT_modified
             'post_modified_gmt' => get_gmt_from_date($old_event['submitted']),
-            'post_author'       => $old_event['wp_user'],// EVT_wp_user
-            'post_parent'       => 0,// parent maybe get this from some REM field?
-            'menu_order'        => 0,// EVT_order
-            'post_type'         => EspressoPostType::EVENTS,// post_type
-            'post_status'       => $post_status,// status
+            'post_author'       => $old_event['wp_user'], // EVT_wp_user
+            'post_parent'       => 0, // parent maybe get this from some REM field?
+            'menu_order'        => 0, // EVT_order
+            'post_type'         => EspressoPostType::EVENTS, // post_type
+            'post_status'       => $post_status, // status
         ];
         $cols_n_values_with_no_invalid_text = [];
         foreach ($cols_n_values as $col => $value) {
             $value_sans_invalid_chars = $wpdb->strip_invalid_text_for_column($this->_new_table, $col, $value);
-            if (! is_wp_error($value_sans_invalid_chars)) {
-                $cols_n_values_with_no_invalid_text[ $col ] = $value_sans_invalid_chars;
+            if ( ! is_wp_error($value_sans_invalid_chars)) {
+                $cols_n_values_with_no_invalid_text[$col] = $value_sans_invalid_chars;
             } else {
                 // otherwise leave it as-is. It will blow everything up and stop the migration
-                $cols_n_values_with_no_invalid_text[ $col ] = $value;
+                $cols_n_values_with_no_invalid_text[$col] = $value;
             }
         }
         $cols_n_values = $cols_n_values_with_no_invalid_text;
         $data_types    = [
-            '%s',// EVT_name
-            '%s',// EVT_desc
-            '%s',// EVT_slug
-            '%s',// EVT_created
+            '%s', // EVT_name
+            '%s', // EVT_desc
+            '%s', // EVT_slug
+            '%s', // EVT_created
             '%s',
-            '%s',// EVT_short_desc
-            '%s',// EVT_modified
+            '%s', // EVT_short_desc
+            '%s', // EVT_modified
             '%s',
-            '%s',// EVT_wp_user
-            '%d',// post_parent
-            '%d',// EVT_order
-            '%s',// post_type
-            '%s',// status
+            '%s', // EVT_wp_user
+            '%d', // post_parent
+            '%d', // EVT_order
+            '%s', // post_type
+            '%s', // status
         ];
-        $success       = $wpdb->insert(
+        $success = $wpdb->insert(
             $this->_new_table,
             $cols_n_values,
             $data_types
         );
-        if (! $success) {
+        if ( ! $success) {
             $this->add_error(
                 $this->get_migration_script()->_create_error_message_for_db_insertion(
                     $this->_old_table,
@@ -521,8 +521,8 @@ 
                 $event_meta['default_payment_status'] ?? '',
                 intval($old_event['require_pre_approval'])
             );
-        $cols_n_values      = [
-            'EVT_ID'                          => $new_cpt_id,// EVT_ID_fk
+        $cols_n_values = [
+            'EVT_ID'                          => $new_cpt_id, // EVT_ID_fk
             'EVT_display_desc'                => 'Y' == $old_event['display_desc'],
             'EVT_display_ticket_selector'     => 'Y' == $old_event['display_reg_form'],
             'EVT_visible_on'                  => $this->get_migration_script()->convert_date_string_to_utc(
@@ -532,7 +532,7 @@ 
                     'mysql'
                 ),
                 $old_event['timezone_string']
-            ),// don't use the old 'visible_on', as it wasn't ever used
+            ), // don't use the old 'visible_on', as it wasn't ever used
             'EVT_additional_limit'            => $old_event['allow_multiple'] == 'N' ? 1
                 : $old_event['additional_limit'],
             'EVT_default_registration_status' => $default_reg_status,
@@ -541,29 +541,29 @@ 
             'EVT_allow_overflow'              => 'Y' == $old_event['allow_overflow'],
             'EVT_timezone_string'             => $old_event['timezone_string'],
             'EVT_external_URL'                => $old_event['externalURL'],
-            'EVT_donations'                   => false,// doesn't exist in 3.1
+            'EVT_donations'                   => false, // doesn't exist in 3.1
 
         ];
-        $data_types         = [
-            '%s',// EVT_ID
-            '%d',// EVT_display_desc
-            '%d',// EVT_display_ticket_selector
-            '%s',// EVT_visible_on
-            '%d',// EVT_additional_limit
-            '%s',// EVT_default_registration_status
-            '%d',// EVT_member_only
-            '%s',// EVT_phone
-            '%d',// EVT_allow_overflow
-            '%s',// EVT_timezone_string
-            '%s',// EVT_external_URL
-            '%d',// EVT_donations
+        $data_types = [
+            '%s', // EVT_ID
+            '%d', // EVT_display_desc
+            '%d', // EVT_display_ticket_selector
+            '%s', // EVT_visible_on
+            '%d', // EVT_additional_limit
+            '%s', // EVT_default_registration_status
+            '%d', // EVT_member_only
+            '%s', // EVT_phone
+            '%d', // EVT_allow_overflow
+            '%s', // EVT_timezone_string
+            '%s', // EVT_external_URL
+            '%d', // EVT_donations
         ];
-        $success            = $wpdb->insert(
+        $success = $wpdb->insert(
             $this->_new_meta_table,
             $cols_n_values,
             $data_types
         );
-        if (! $success) {
+        if ( ! $success) {
             $this->add_error(
                 $this->get_migration_script()->_create_error_message_for_db_insertion(
                     $this->_old_table,
@@ -632,16 +632,16 @@ 
     private function _duplicate_venue_exists(array $old_event): int
     {
         global $wpdb;
-        $conditions     = [
+        $conditions = [
             'VNU_address'       => $old_event ['address'],
             'VNU_address2'      => $old_event['address2'],
             'VNU_city'          => $old_event['city'],
             'VNU_zip'           => $old_event['zip'],
             'post_title'        => $this->_get_venue_title_for_event($old_event),
-            'VNU_phone'         => $old_event['venue_phone'],// VNU_phone
-            'VNU_url'           => $old_event['venue_url'],// VNU_url
-            'VNU_virtual_phone' => $old_event['virtual_phone'],// VNU_virtual_phone
-            'VNU_virtual_url'   => $old_event['virtual_url'],// VNU_virtual_url
+            'VNU_phone'         => $old_event['venue_phone'], // VNU_phone
+            'VNU_url'           => $old_event['venue_url'], // VNU_url
+            'VNU_virtual_phone' => $old_event['virtual_phone'], // VNU_virtual_phone
+            'VNU_virtual_url'   => $old_event['virtual_url'], // VNU_virtual_url
         ];
         $sql_conditions = [];
         foreach ($conditions as $column => $value) {
@@ -651,7 +651,7 @@ 
 					FROM
 		$wpdb->posts as p INNER JOIN
 		{$wpdb->prefix}esp_venue_meta as v ON p.ID = v.VNU_ID
-			WHERE " . implode(" AND ", $sql_conditions) . " LIMIT 1";
+			WHERE ".implode(" AND ", $sql_conditions)." LIMIT 1";
         return (int) $wpdb->get_var($query);
     }
 
@@ -684,43 +684,43 @@ 
     private function _insert_venue_into_posts(array $old_event): int
     {
         global $wpdb;
-        $insertion_array  = [
-            'post_title'        => $this->_get_venue_title_for_event($old_event),// VNU_name
-            'post_content'      => '',// VNU_desc
+        $insertion_array = [
+            'post_title'        => $this->_get_venue_title_for_event($old_event), // VNU_name
+            'post_content'      => '', // VNU_desc
             'post_name'         => $this->_find_unique_slug(
                 $old_event['venue_title'],
-                sanitize_title('venue-of-' . $old_event['event_name'])
-            ),// VNU_identifier
-            'post_date'         => current_time('mysql'),// VNU_created
+                sanitize_title('venue-of-'.$old_event['event_name'])
+            ), // VNU_identifier
+            'post_date'         => current_time('mysql'), // VNU_created
             'post_date_gmt'     => get_gmt_from_date(current_time('mysql')),
-            'post_excerpt'      => '',// VNU_short_desc arbitrary only 50 characters
-            'post_modified'     => current_time('mysql'),// VNU_modified
+            'post_excerpt'      => '', // VNU_short_desc arbitrary only 50 characters
+            'post_modified'     => current_time('mysql'), // VNU_modified
             'post_modified_gmt' => get_gmt_from_date(current_time('mysql')),
-            'post_author'       => $old_event['wp_user'],// VNU_wp_user
-            'post_parent'       => 0,// parent
-            'menu_order'        => 0,// VNU_order
-            'post_type'         => EspressoPostType::VENUES,// post_type
+            'post_author'       => $old_event['wp_user'], // VNU_wp_user
+            'post_parent'       => 0, // parent
+            'menu_order'        => 0, // VNU_order
+            'post_type'         => EspressoPostType::VENUES, // post_type
         ];
         $data_types_array = [
-            '%s',// VNU_name
-            '%s',// VNU_desc
-            '%s',// VNU_identifier
-            '%s',// VNU_created
+            '%s', // VNU_name
+            '%s', // VNU_desc
+            '%s', // VNU_identifier
+            '%s', // VNU_created
             '%s',
-            '%s',// VNU_short_desc
-            '%s',// VNU_modified
+            '%s', // VNU_short_desc
+            '%s', // VNU_modified
             '%s',
-            '%d',// VNU_wp_user
-            '%d',// parent
-            '%d',// VNU_order
-            '%s',// post_type
+            '%d', // VNU_wp_user
+            '%d', // parent
+            '%d', // VNU_order
+            '%s', // post_type
         ];
-        $success          = $wpdb->insert(
+        $success = $wpdb->insert(
             $wpdb->posts,
             $insertion_array,
             $data_types_array
         );
-        if (! $success) {
+        if ( ! $success) {
             $this->add_error(
                 $this->get_migration_script()->_create_error_message_for_db_insertion(
                     $this->_old_table,
@@ -750,13 +750,13 @@ 
         // assume the country is the same as the organization's old settings
         $country_iso = $this->get_migration_script()->get_default_country_iso();
         // find the state from the venue, or the organization, or just guess california
-        if (! $old_event['state']) {
+        if ( ! $old_event['state']) {
             $old_org_options = get_option('events_organization_settings');
             $state_name      = stripslashes($old_org_options['organization_state']);
         } else {
             $state_name = $old_event['state'];
         }
-        if (! $state_name) {
+        if ( ! $state_name) {
             $state_name = 'CA';
         }
         // get a state ID with the same name, if possible
@@ -769,39 +769,39 @@ 
         }
         // now insert into meta table
         $insertion_array = [
-            'VNU_ID'              => $cpt_id,// VNU_ID_fk
-            'VNU_address'         => stripslashes($old_event['address']),// VNU_address
-            'VNU_address2'        => stripslashes($old_event['address2']),// VNU_address2
-            'VNU_city'            => stripslashes($old_event['city']),// VNU_city
-            'STA_ID'              => $state_id,// STA_ID
-            'CNT_ISO'             => $country_iso,// CNT_ISO
-            'VNU_zip'             => $old_event['zip'],// VNU_zip
-            'VNU_phone'           => $old_event['venue_phone'],// VNU_phone
-            'VNU_capacity'        => -1,// VNU_capacity
-            'VNU_url'             => $old_event['venue_url'],// VNU_url
-            'VNU_virtual_phone'   => $old_event['virtual_phone'],// VNU_virtual_phone
-            'VNU_virtual_url'     => $old_event['virtual_url'],// VNU_virtual_url
-            'VNU_google_map_link' => '',// VNU_google_map_link
+            'VNU_ID'              => $cpt_id, // VNU_ID_fk
+            'VNU_address'         => stripslashes($old_event['address']), // VNU_address
+            'VNU_address2'        => stripslashes($old_event['address2']), // VNU_address2
+            'VNU_city'            => stripslashes($old_event['city']), // VNU_city
+            'STA_ID'              => $state_id, // STA_ID
+            'CNT_ISO'             => $country_iso, // CNT_ISO
+            'VNU_zip'             => $old_event['zip'], // VNU_zip
+            'VNU_phone'           => $old_event['venue_phone'], // VNU_phone
+            'VNU_capacity'        => -1, // VNU_capacity
+            'VNU_url'             => $old_event['venue_url'], // VNU_url
+            'VNU_virtual_phone'   => $old_event['virtual_phone'], // VNU_virtual_phone
+            'VNU_virtual_url'     => $old_event['virtual_url'], // VNU_virtual_url
+            'VNU_google_map_link' => '', // VNU_google_map_link
             'VNU_enable_for_gmap' => true, // VNU_enable_for_gmap
         ];
-        $data_types      = [
-            '%d',// VNU_ID_fk
-            '%s',// VNU_address
-            '%s',// VNU_address2
-            '%s',// VNU_city
-            '%d',// STA_ID
-            '%s',// CNT_ISO
-            '%s',// VNU_zip
-            '%s',// VNU_phone
-            '%d',// VNU_capacity
-            '%s',// VNU_url
-            '%s',// VNU_virtual_phone
-            '%s',// VNU_virtual_url
-            '%s',// VNU_google_map_link
-            '%d',// VNU_enable_for_gmap
+        $data_types = [
+            '%d', // VNU_ID_fk
+            '%s', // VNU_address
+            '%s', // VNU_address2
+            '%s', // VNU_city
+            '%d', // STA_ID
+            '%s', // CNT_ISO
+            '%s', // VNU_zip
+            '%s', // VNU_phone
+            '%d', // VNU_capacity
+            '%s', // VNU_url
+            '%s', // VNU_virtual_phone
+            '%s', // VNU_virtual_url
+            '%s', // VNU_google_map_link
+            '%d', // VNU_enable_for_gmap
         ];
-        $success         = $wpdb->insert($wpdb->prefix . "esp_venue_meta", $insertion_array, $data_types);
-        if (! $success) {
+        $success = $wpdb->insert($wpdb->prefix."esp_venue_meta", $insertion_array, $data_types);
+        if ( ! $success) {
             $this->add_error(
                 $this->get_migration_script()->_create_error_message_for_db_insertion(
                     $this->_old_table,
@@ -823,13 +823,13 @@ 
     private function _insert_new_venue_to_event($new_event_id, $new_venue_id): void
     {
         global $wpdb;
-        if (! $new_event_id) {
+        if ( ! $new_event_id) {
             $this->add_error(
                 sprintf(esc_html__("Could not find 4.1 event id for 3.1 event #%d.", "event_espresso"), $new_event_id)
             );
             return;
         }
-        if (! $new_venue_id) {
+        if ( ! $new_venue_id) {
             $this->add_error(
                 sprintf(esc_html__("Could not find 4.1 venue id for 3.1 venue #%d.", "event_espresso"), $new_venue_id)
             );
@@ -840,13 +840,13 @@ 
             'VNU_ID'      => $new_venue_id,
             'EVV_primary' => true,
         ];
-        $data_types    = [
-            '%d',// EVT_ID
-            '%d',// VNU_ID
-            '%d',// EVT_primary
+        $data_types = [
+            '%d', // EVT_ID
+            '%d', // VNU_ID
+            '%d', // EVT_primary
         ];
-        $success       = $wpdb->insert($wpdb->prefix . "esp_event_venue", $cols_n_values, $data_types);
-        if (! $success) {
+        $success = $wpdb->insert($wpdb->prefix."esp_event_venue", $cols_n_values, $data_types);
+        if ( ! $success) {
             $this->add_error(
                 $this->get_migration_script()->_create_error_message_for_db_insertion(
                     $this->_old_table,
@@ -926,14 +926,14 @@ 
                 "$start_date $start_time:00",
                 $old_event_row['timezone_string']
             );
-        $end_datetime_utc   =
+        $end_datetime_utc =
             $this->get_migration_script()->convert_date_string_to_utc(
                 $this,
                 $start_end_time_row,
                 "$end_date $end_time:00",
                 $old_event_row['timezone_string']
             );
-        $cols_n_values      = [
+        $cols_n_values = [
             'EVT_ID'        => $new_cpt_id,
             // EVT_ID
             'DTT_EVT_start' => $start_datetime_utc,
@@ -951,19 +951,19 @@ 
             'DTT_parent'    => 0,
             'DTT_deleted'   => false,
         ];
-        $data_types         = [
-            '%d',// EVT_Id
-            '%s',// DTT_EVT_start
-            '%s',// DTT_EVT_end
-            '%d',// DTT_reg_limit
-            '%d',// DTT_sold
+        $data_types = [
+            '%d', // EVT_Id
+            '%s', // DTT_EVT_start
+            '%s', // DTT_EVT_end
+            '%d', // DTT_reg_limit
+            '%d', // DTT_sold
             //          '%d',//DTT_is_primary
-            '%d',// DTT_order
-            '%d',// DTT_parent
-            '%d',// DTT_deleted
+            '%d', // DTT_order
+            '%d', // DTT_parent
+            '%d', // DTT_deleted
         ];
-        $success            = $wpdb->insert($this->_new_datetime_table, $cols_n_values, $data_types);
-        if (! $success) {
+        $success = $wpdb->insert($this->_new_datetime_table, $cols_n_values, $data_types);
+        if ( ! $success) {
             $this->add_error(
                 $this->get_migration_script()->_create_error_message_for_db_insertion(
                     $this->_old_start_end_table,

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

Indentation +144 added lines, -144 removed lines

@@ -66,159 +66,159 @@
  */
 class EE_DMS_4_1_0_questions extends EE_Data_Migration_Script_Stage
 {
-    private string $_option_table;
+	private string $_option_table;
 
 
-    public function __construct()
-    {
-        global $wpdb;
-        $this->_pretty_name  = esc_html__("Questions", "event_espresso");
-        $this->_old_table    = $wpdb->prefix . "events_question";
-        $this->_new_table    = $wpdb->prefix . "esp_question";
-        $this->_option_table = $wpdb->prefix . "esp_question_option";
-        parent::__construct();
-    }
+	public function __construct()
+	{
+		global $wpdb;
+		$this->_pretty_name  = esc_html__("Questions", "event_espresso");
+		$this->_old_table    = $wpdb->prefix . "events_question";
+		$this->_new_table    = $wpdb->prefix . "esp_question";
+		$this->_option_table = $wpdb->prefix . "esp_question_option";
+		parent::__construct();
+	}
 
 
-    /**
-     * @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 $question_row) {
-            $new_id = $this->_insert_new_question($question_row);
-            $this->get_migration_script()->set_mapping(
-                $this->_old_table,
-                $question_row['id'],
-                $this->_new_table,
-                $new_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 $question_row) {
+			$new_id = $this->_insert_new_question($question_row);
+			$this->get_migration_script()->set_mapping(
+				$this->_old_table,
+				$question_row['id'],
+				$this->_new_table,
+				$new_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);
+	}
 
 
-    private function _insert_new_question($old_question): int
-    {
-        global $wpdb;
-        // if this pretends to be a 'system' question, check if we already have a
-        // system question for that string. If so, pretend THAT new question
-        // is what we just inserted
-        if ($old_question['system_name']) {
-            $id_of_new_system_question = intval(
-                $wpdb->get_var(
-                    $wpdb->prepare(
-                        "SELECT QST_ID FROM $this->_new_table WHERE QST_system = %s",
-                        $old_question['system_name']
-                    )
-                )
-            );
-            if ($id_of_new_system_question) {
-                return $id_of_new_system_question;
-            }
-            // ok so this must be the first one. Carry on.
-        }
+	private function _insert_new_question($old_question): int
+	{
+		global $wpdb;
+		// if this pretends to be a 'system' question, check if we already have a
+		// system question for that string. If so, pretend THAT new question
+		// is what we just inserted
+		if ($old_question['system_name']) {
+			$id_of_new_system_question = intval(
+				$wpdb->get_var(
+					$wpdb->prepare(
+						"SELECT QST_ID FROM $this->_new_table WHERE QST_system = %s",
+						$old_question['system_name']
+					)
+				)
+			);
+			if ($id_of_new_system_question) {
+				return $id_of_new_system_question;
+			}
+			// ok so this must be the first one. Carry on.
+		}
 
-        $cols_n_values = [
-            'QST_display_text'  => stripslashes($old_question['question']),
-            'QST_admin_label'   => sanitize_title($old_question['question'] ?: ''),
-            'QST_system'        => (string) $old_question['system_name'],
-            'QST_type'          => $old_question['question_type'],
-            'QST_required'      => 'Y' == $old_question['required'],
-            'QST_required_text' => stripslashes($old_question['required_text'] ?: ''),
-            'QST_order'         => $old_question['sequence'],
-            'QST_admin_only'    => 'Y' == $old_question['admin_only'],
-            'QST_wp_user'       => $old_question['wp_user'],
-            'QST_deleted'       => false,
-        ];
-        $data_types    = [
-            '%s',// QST_display_text
-            '%s',// QST-admin_label
-            '%s',// QST_system
-            '%s',// QST_type
-            '%d',// QST_required
-            '%s',// QST_required_text
-            '%d',// QST_order
-            '%d',// QST_admin_only
-            '%d',// QST_wp_user
-            '%d',// QST_deleted
-        ];
-        $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_question,
-                    $this->_new_table,
-                    $cols_n_values,
-                    $data_types
-                )
-            );
-            return 0;
-        }
-        $new_id = $wpdb->insert_id;
-        // now take care of possibly adding question options
-        if (in_array($old_question['question_type'], ['DROPDOWN', 'SINGLE', 'MULTIPLE'])) {
-            $options = explode(",", $old_question['response']);
-            foreach ($options as $option) {
-                $this->_insert_question_option($option, $new_id);
-            }
-        }
-        return $new_id;
-    }
+		$cols_n_values = [
+			'QST_display_text'  => stripslashes($old_question['question']),
+			'QST_admin_label'   => sanitize_title($old_question['question'] ?: ''),
+			'QST_system'        => (string) $old_question['system_name'],
+			'QST_type'          => $old_question['question_type'],
+			'QST_required'      => 'Y' == $old_question['required'],
+			'QST_required_text' => stripslashes($old_question['required_text'] ?: ''),
+			'QST_order'         => $old_question['sequence'],
+			'QST_admin_only'    => 'Y' == $old_question['admin_only'],
+			'QST_wp_user'       => $old_question['wp_user'],
+			'QST_deleted'       => false,
+		];
+		$data_types    = [
+			'%s',// QST_display_text
+			'%s',// QST-admin_label
+			'%s',// QST_system
+			'%s',// QST_type
+			'%d',// QST_required
+			'%s',// QST_required_text
+			'%d',// QST_order
+			'%d',// QST_admin_only
+			'%d',// QST_wp_user
+			'%d',// QST_deleted
+		];
+		$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_question,
+					$this->_new_table,
+					$cols_n_values,
+					$data_types
+				)
+			);
+			return 0;
+		}
+		$new_id = $wpdb->insert_id;
+		// now take care of possibly adding question options
+		if (in_array($old_question['question_type'], ['DROPDOWN', 'SINGLE', 'MULTIPLE'])) {
+			$options = explode(",", $old_question['response']);
+			foreach ($options as $option) {
+				$this->_insert_question_option($option, $new_id);
+			}
+		}
+		return $new_id;
+	}
 
 
-    /**
-     * Adds a question option to the db
-     *
-     * @param string $option
-     * @param int    $question_id
-     * @return void
-     * @global wpdb  $wpdb
-     */
-    private function _insert_question_option(string $option, int $question_id): void
-    {
-        $option = trim($option);
-        global $wpdb;
-        $cols_n_values = [
-            'QST_ID'      => $question_id,
-            'QSO_value'   => $option,
-            'QSO_deleted' => false,
-        ];
-        $data_types    = [
-            '%d',// QST_ID
-            '%s',// QSO_value
-            '%d',// QSO_deleted
-        ];
-        $success       = $wpdb->insert($this->_option_table, $cols_n_values, $data_types);
-        if (! $success) {
-            $this->add_error(
-                $this->get_migration_script()->_create_error_message_for_db_insertion(
-                    $this->_old_table,
-                    ['option' => $option, 'new_question_id' => $question_id],
-                    $this->_option_table,
-                    $cols_n_values,
-                    $data_types
-                )
-            );
-        }
-    }
+	/**
+	 * Adds a question option to the db
+	 *
+	 * @param string $option
+	 * @param int    $question_id
+	 * @return void
+	 * @global wpdb  $wpdb
+	 */
+	private function _insert_question_option(string $option, int $question_id): void
+	{
+		$option = trim($option);
+		global $wpdb;
+		$cols_n_values = [
+			'QST_ID'      => $question_id,
+			'QSO_value'   => $option,
+			'QSO_deleted' => false,
+		];
+		$data_types    = [
+			'%d',// QST_ID
+			'%s',// QSO_value
+			'%d',// QSO_deleted
+		];
+		$success       = $wpdb->insert($this->_option_table, $cols_n_values, $data_types);
+		if (! $success) {
+			$this->add_error(
+				$this->get_migration_script()->_create_error_message_for_db_insertion(
+					$this->_old_table,
+					['option' => $option, 'new_question_id' => $question_id],
+					$this->_option_table,
+					$cols_n_values,
+					$data_types
+				)
+			);
+		}
+	}
 }

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

Indentation +165 added lines, -165 removed lines

@@ -26,186 +26,186 @@
 
 class EE_DMS_4_1_0_checkins extends EE_Data_Migration_Script_Stage_Table
 {
-    public function __construct()
-    {
-        global $wpdb;
-        $this->_pretty_name      = esc_html__('Check-ins', '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__('Check-ins', '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_table        = $wpdb->prefix . "esp_checkin";
-        parent::__construct();
-    }
+		$this->_new_table        = $wpdb->prefix . "esp_checkin";
+		parent::__construct();
+	}
 
 
-    /**
-     * @throws EE_Error
-     */
-    protected function _migrate_old_row($old_row)
-    {
-        global $wpdb;
-        $new_reg_table = $wpdb->prefix . "esp_registration";
+	/**
+	 * @throws EE_Error
+	 */
+	protected function _migrate_old_row($old_row)
+	{
+		global $wpdb;
+		$new_reg_table = $wpdb->prefix . "esp_registration";
 
-        $num_to_checkin_at_this_time = max([intval($old_row['checked_in_quantity']), intval($old_row['checked_in'])]);
+		$num_to_checkin_at_this_time = max([intval($old_row['checked_in_quantity']), intval($old_row['checked_in'])]);
 
-        $new_registrations_for_attendee =
-            $this->get_migration_script()->get_mapping_new_pk($this->_old_table, $old_row['id'], $new_reg_table);
-        if (! $new_registrations_for_attendee) {
-            $new_registrations_for_attendee = [];
-        }
-        $new_datetime = $this->_try_to_find_datetime($old_row);
+		$new_registrations_for_attendee =
+			$this->get_migration_script()->get_mapping_new_pk($this->_old_table, $old_row['id'], $new_reg_table);
+		if (! $new_registrations_for_attendee) {
+			$new_registrations_for_attendee = [];
+		}
+		$new_datetime = $this->_try_to_find_datetime($old_row);
 
-        // make sure registrations array is numerically indexed starting at 0 (it probably already is)
-        $new_registrations_for_attendee = array_values($new_registrations_for_attendee);
-        $new_checkin_ids                = [];
-        for ($i = 0; $i < abs($num_to_checkin_at_this_time); $i++) {
-            $new_reg_id = $new_registrations_for_attendee[ $i ];
-            if (! $new_reg_id) {
-                $this->add_error(
-                    sprintf(
-                        esc_html__(
-                        /* translators: %1$s database row represented in JSON, %2$s number of registrations to check in
+		// make sure registrations array is numerically indexed starting at 0 (it probably already is)
+		$new_registrations_for_attendee = array_values($new_registrations_for_attendee);
+		$new_checkin_ids                = [];
+		for ($i = 0; $i < abs($num_to_checkin_at_this_time); $i++) {
+			$new_reg_id = $new_registrations_for_attendee[ $i ];
+			if (! $new_reg_id) {
+				$this->add_error(
+					sprintf(
+						esc_html__(
+						/* translators: %1$s database row represented in JSON, %2$s number of registrations to check in
                         *  %3$s number of registrations for the attendee, %4$s new registration rows represented in JSON
                         */
-                        // @codingStandardsIgnoreStart
-                            'It appears we wanted to check-in more registrations than actually exist. The old attendee record (%1$s) indicated we should check-in %2$d registrations, but there are only %3$d registrations for that attendee (%4$s)',
-                            // @codingStandardsIgnoreEnd
-                            'event_espresso'
-                        ),
-                        $this->_json_encode($old_row),
-                        abs($num_to_checkin_at_this_time),
-                        count($new_registrations_for_attendee),
-                        $this->_json_encode($new_registrations_for_attendee)
-                    )
-                );
-                break;
-            }
-            $existing_checkin_record = $wpdb->get_var(
-                $wpdb->prepare(
-                    "SELECT CHK_ID FROM $this->_new_table WHERE REG_ID = %d ORDER BY CHK_ID DESC LIMIT 1",
-                    $new_reg_id
-                )
-            );
-            if (! $existing_checkin_record) {
-                $new_id = $this->_insert_checkin_record($new_reg_id, $new_datetime);
-                if ($new_id) {
-                    $new_checkin_ids[] = $new_id;
-                }
-            }
-        }
-        if ($new_checkin_ids) {
-            $this->get_migration_script()->set_mapping(
-                $this->_old_table,
-                $old_row['id'],
-                $this->_new_table,
-                $new_checkin_ids
-            );
-        }
-    }
+						// @codingStandardsIgnoreStart
+							'It appears we wanted to check-in more registrations than actually exist. The old attendee record (%1$s) indicated we should check-in %2$d registrations, but there are only %3$d registrations for that attendee (%4$s)',
+							// @codingStandardsIgnoreEnd
+							'event_espresso'
+						),
+						$this->_json_encode($old_row),
+						abs($num_to_checkin_at_this_time),
+						count($new_registrations_for_attendee),
+						$this->_json_encode($new_registrations_for_attendee)
+					)
+				);
+				break;
+			}
+			$existing_checkin_record = $wpdb->get_var(
+				$wpdb->prepare(
+					"SELECT CHK_ID FROM $this->_new_table WHERE REG_ID = %d ORDER BY CHK_ID DESC LIMIT 1",
+					$new_reg_id
+				)
+			);
+			if (! $existing_checkin_record) {
+				$new_id = $this->_insert_checkin_record($new_reg_id, $new_datetime);
+				if ($new_id) {
+					$new_checkin_ids[] = $new_id;
+				}
+			}
+		}
+		if ($new_checkin_ids) {
+			$this->get_migration_script()->set_mapping(
+				$this->_old_table,
+				$old_row['id'],
+				$this->_new_table,
+				$new_checkin_ids
+			);
+		}
+	}
 
 
-    /**
-     * Tries to find the new datetime the Check-in was for, based on the attendee row
-     * (because we know the attendee was for an event as a specific time, and we know
-     * the event's OLD ID...)
-     *
-     * @param array $old_attendee
-     * @return array row of datetime from DB
-     * @throws EE_Error
-     * @global wpdb $wpdb
-     */
-    private function _try_to_find_datetime(array $old_attendee): array
-    {
-        global $wpdb;
+	/**
+	 * Tries to find the new datetime the Check-in was for, based on the attendee row
+	 * (because we know the attendee was for an event as a specific time, and we know
+	 * the event's OLD ID...)
+	 *
+	 * @param array $old_attendee
+	 * @return array row of datetime from DB
+	 * @throws EE_Error
+	 * @global wpdb $wpdb
+	 */
+	private function _try_to_find_datetime(array $old_attendee): array
+	{
+		global $wpdb;
 
-        $new_event_id =
-            $this->get_migration_script()->get_mapping_new_pk(
-                $wpdb->prefix . "events_detail",
-                $old_attendee['event_id'],
-                $wpdb->posts
-            );
-        if (! $new_event_id) {
-            $this->add_error(
-                sprintf(
-                    esc_html__(
-                    /* translators: 1: original event ID, 2: original attendee database row */
-                    // @codingStandardsIgnoreStart
-                        'Could not find new event ID with old event ID %1$d, on attendee row %2$s; and because of that couldn\'t find the correct datetime for Check-in',
-                        // @codingStandardsIgnoreEnd
-                        'event_espresso'
-                    ),
-                    $old_attendee['event_id'],
-                    $this->_json_encode($old_attendee)
-                )
-            );
-            return [];
-        }
-        $old_att_start_date = $old_attendee['start_date'];
-        $old_att_start_time = $this->get_migration_script()->convertTimeFromAMPM($old_attendee['event_time']);
-        $old_att_datetime   =
-            $this->get_migration_script()->convert_date_string_to_utc(
-                $this,
-                $old_attendee,
-                "$old_att_start_date $old_att_start_time:00"
-            );
+		$new_event_id =
+			$this->get_migration_script()->get_mapping_new_pk(
+				$wpdb->prefix . "events_detail",
+				$old_attendee['event_id'],
+				$wpdb->posts
+			);
+		if (! $new_event_id) {
+			$this->add_error(
+				sprintf(
+					esc_html__(
+					/* translators: 1: original event ID, 2: original attendee database row */
+					// @codingStandardsIgnoreStart
+						'Could not find new event ID with old event ID %1$d, on attendee row %2$s; and because of that couldn\'t find the correct datetime for Check-in',
+						// @codingStandardsIgnoreEnd
+						'event_espresso'
+					),
+					$old_attendee['event_id'],
+					$this->_json_encode($old_attendee)
+				)
+			);
+			return [];
+		}
+		$old_att_start_date = $old_attendee['start_date'];
+		$old_att_start_time = $this->get_migration_script()->convertTimeFromAMPM($old_attendee['event_time']);
+		$old_att_datetime   =
+			$this->get_migration_script()->convert_date_string_to_utc(
+				$this,
+				$old_attendee,
+				"$old_att_start_date $old_att_start_time:00"
+			);
 
-        $datetime_table = $wpdb->prefix . "esp_datetime";
-        // add all conditions to an array from which we can SHIFT conditions off in order to widen our search
-        // the most important condition should be last, as it will be array_shift'ed off last
-        $conditions = [
-            $wpdb->prepare("$datetime_table.DTT_EVT_start = %s", $old_att_datetime),// times match?
-            $wpdb->prepare("$datetime_table.EVT_ID = %d", $new_event_id),// events match?
-        ];
-        // start running queries, widening search each time by removing a condition
-        do {
-            $full_query     = "SELECT * FROM $datetime_table WHERE " . implode(" AND ", $conditions) . " LIMIT 1";
-            $datetime_found = $wpdb->get_row($full_query, ARRAY_A);
-            array_shift($conditions);
-        } while (! $datetime_found && $conditions);
-        return $datetime_found;
-    }
+		$datetime_table = $wpdb->prefix . "esp_datetime";
+		// add all conditions to an array from which we can SHIFT conditions off in order to widen our search
+		// the most important condition should be last, as it will be array_shift'ed off last
+		$conditions = [
+			$wpdb->prepare("$datetime_table.DTT_EVT_start = %s", $old_att_datetime),// times match?
+			$wpdb->prepare("$datetime_table.EVT_ID = %d", $new_event_id),// events match?
+		];
+		// start running queries, widening search each time by removing a condition
+		do {
+			$full_query     = "SELECT * FROM $datetime_table WHERE " . implode(" AND ", $conditions) . " LIMIT 1";
+			$datetime_found = $wpdb->get_row($full_query, ARRAY_A);
+			array_shift($conditions);
+		} while (! $datetime_found && $conditions);
+		return $datetime_found;
+	}
 
 
-    /**
-     * Adds a new Check-in/checkout record according to $new_reg_id,$new_datetime_id,$checking_in, and $timestamp
-     *
-     * @param int   $new_reg_id
-     * @param array $new_datetime
-     * @return int new Check-in id
-     */
-    private function _insert_checkin_record(int $new_reg_id, array $new_datetime): int
-    {
-        global $wpdb;
+	/**
+	 * Adds a new Check-in/checkout record according to $new_reg_id,$new_datetime_id,$checking_in, and $timestamp
+	 *
+	 * @param int   $new_reg_id
+	 * @param array $new_datetime
+	 * @return int new Check-in id
+	 */
+	private function _insert_checkin_record(int $new_reg_id, array $new_datetime): int
+	{
+		global $wpdb;
 
 
-        // ok we can actually do what we set out to do: add a checkin/checkout record
-        $cols_n_values = [
-            'REG_ID'        => $new_reg_id,
-            'DTT_ID'        => $new_datetime['DTT_ID'] ?? 0,
-            'CHK_in'        => true,
-            'CHK_timestamp' => $new_datetime['DTT_EVT_start'] ?? null,
-        ];
-        $data_types    = [
-            '%d',// REG_ID
-            '%d',// DTT_ID
-            '%d',// CHK_in
-            '%s',// CHK_timestamp
-        ];
-        $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,
-                    [],
-                    $this->_new_table,
-                    $cols_n_values,
-                    $data_types
-                )
-            );
-            return 0;
-        }
-        return $wpdb->insert_id;
-    }
+		// ok we can actually do what we set out to do: add a checkin/checkout record
+		$cols_n_values = [
+			'REG_ID'        => $new_reg_id,
+			'DTT_ID'        => $new_datetime['DTT_ID'] ?? 0,
+			'CHK_in'        => true,
+			'CHK_timestamp' => $new_datetime['DTT_EVT_start'] ?? null,
+		];
+		$data_types    = [
+			'%d',// REG_ID
+			'%d',// DTT_ID
+			'%d',// CHK_in
+			'%s',// CHK_timestamp
+		];
+		$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,
+					[],
+					$this->_new_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_event_question_group.dmsstage.php

Indentation +150 added lines, -150 removed lines

@@ -20,163 +20,163 @@
  */
 class EE_DMS_4_1_0_event_question_group extends EE_Data_Migration_Script_Stage_Table
 {
-    /**
-     * @throws EE_Error
-     */
-    public function _migrate_old_row($old_row)
-    {
-        //      $txn_id = $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
+	 */
+	public function _migrate_old_row($old_row)
+	{
+		//      $txn_id = $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);
 
-        $this->_insert_new_event_question_groups($old_row);
-    }
-    //  function _migration_step($num_items=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),ARRAY_A);
-    //      $items_actually_migrated = 0;
-    //      foreach($rows as $old_event){
-    //          $this->_insert_new_event_question_groups($old_event);
-    //          $items_actually_migrated++;
-    //      }
-    //      if($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()){
-    //          $this->set_completed();
-    //      }
-    //      return $items_actually_migrated;
-    //  }
-    //  function _count_records_to_migrate() {
-    //      global $wpdb;
-    //      $count = $wpdb->get_var("SELECT COUNT(id) FROM ".$this->_old_table);
-    //      return $count;
-    //  }
-    public function __construct()
-    {
-        global $wpdb;
-        $this->_old_table       = $wpdb->prefix . "events_detail";
-        $this->_extra_where_sql = 'WHERE event_status!="D"';
-        $this->_new_table       = $wpdb->prefix . "esp_event_question_group";
-        $this->_pretty_name     = esc_html__("Question Groups in each Event", "event_espresso");
-        parent::__construct();
-    }
+		$this->_insert_new_event_question_groups($old_row);
+	}
+	//  function _migration_step($num_items=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),ARRAY_A);
+	//      $items_actually_migrated = 0;
+	//      foreach($rows as $old_event){
+	//          $this->_insert_new_event_question_groups($old_event);
+	//          $items_actually_migrated++;
+	//      }
+	//      if($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()){
+	//          $this->set_completed();
+	//      }
+	//      return $items_actually_migrated;
+	//  }
+	//  function _count_records_to_migrate() {
+	//      global $wpdb;
+	//      $count = $wpdb->get_var("SELECT COUNT(id) FROM ".$this->_old_table);
+	//      return $count;
+	//  }
+	public function __construct()
+	{
+		global $wpdb;
+		$this->_old_table       = $wpdb->prefix . "events_detail";
+		$this->_extra_where_sql = 'WHERE event_status!="D"';
+		$this->_new_table       = $wpdb->prefix . "esp_event_question_group";
+		$this->_pretty_name     = esc_html__("Question Groups in each Event", "event_espresso");
+		parent::__construct();
+	}
 
 
-    /**
-     * Attempts to insert a new question group in the new format given an old one
-     *
-     * @param array $old_event
-     * @return void
-     * @throws EE_Error
-     * @global wpdb $wpdb
-     */
-    private function _insert_new_event_question_groups(array $old_event)
-    {
-        $new_event_question_group_ids = [];
-        $question_groups_for_primary  = maybe_unserialize($old_event['question_groups']);
-        if (is_array($question_groups_for_primary)) {
-            foreach ($question_groups_for_primary as $old_question_group_id) {
-                $new_id = $this->_insert_event_question_group(
-                    $old_event,
-                    (int) $old_question_group_id,
-                    true
-                );
-                if ($new_id) {
-                    $new_event_question_group_ids[] = $new_id;
-                }
-            }
-        }
-        $event_meta = maybe_unserialize($old_event['event_meta']);
-        if (isset($event_meta['add_attendee_question_groups'])) {
-            if (is_array($event_meta['add_attendee_question_groups'])) {
-                foreach ($event_meta['add_attendee_question_groups'] as $old_question_group_id) {
-                    $new_id = $this->_insert_event_question_group($old_event, $old_question_group_id, false);
-                    if ($new_id) {
-                        $new_event_question_group_ids[] = $new_id;
-                    }
-                }
-            }
-        }
+	/**
+	 * Attempts to insert a new question group in the new format given an old one
+	 *
+	 * @param array $old_event
+	 * @return void
+	 * @throws EE_Error
+	 * @global wpdb $wpdb
+	 */
+	private function _insert_new_event_question_groups(array $old_event)
+	{
+		$new_event_question_group_ids = [];
+		$question_groups_for_primary  = maybe_unserialize($old_event['question_groups']);
+		if (is_array($question_groups_for_primary)) {
+			foreach ($question_groups_for_primary as $old_question_group_id) {
+				$new_id = $this->_insert_event_question_group(
+					$old_event,
+					(int) $old_question_group_id,
+					true
+				);
+				if ($new_id) {
+					$new_event_question_group_ids[] = $new_id;
+				}
+			}
+		}
+		$event_meta = maybe_unserialize($old_event['event_meta']);
+		if (isset($event_meta['add_attendee_question_groups'])) {
+			if (is_array($event_meta['add_attendee_question_groups'])) {
+				foreach ($event_meta['add_attendee_question_groups'] as $old_question_group_id) {
+					$new_id = $this->_insert_event_question_group($old_event, $old_question_group_id, false);
+					if ($new_id) {
+						$new_event_question_group_ids[] = $new_id;
+					}
+				}
+			}
+		}
 
 
-        $this->get_migration_script()->set_mapping(
-            $this->_old_table,
-            $old_event['id'],
-            $this->_new_table,
-            $new_event_question_group_ids
-        );
-    }
+		$this->get_migration_script()->set_mapping(
+			$this->_old_table,
+			$old_event['id'],
+			$this->_new_table,
+			$new_event_question_group_ids
+		);
+	}
 
 
-    /**
-     * @throws EE_Error
-     */
-    private function _insert_event_question_group(
-        array $old_event,
-        int $old_question_group_id,
-        bool $primary
-    ): int {
-        global $wpdb;
-        $new_question_group_id = $this->get_migration_script()->get_mapping_new_pk(
-            $wpdb->prefix . "events_qst_group",
-            $old_question_group_id,
-            $wpdb->prefix . "esp_question_group"
-        );
+	/**
+	 * @throws EE_Error
+	 */
+	private function _insert_event_question_group(
+		array $old_event,
+		int $old_question_group_id,
+		bool $primary
+	): int {
+		global $wpdb;
+		$new_question_group_id = $this->get_migration_script()->get_mapping_new_pk(
+			$wpdb->prefix . "events_qst_group",
+			$old_question_group_id,
+			$wpdb->prefix . "esp_question_group"
+		);
 
-        if (! $new_question_group_id) {
-            $this->add_error(
-                sprintf(
-                // translators: %s question ID, %s event ID
-                    esc_html__("Could not find 4.1 question ID for 3.1 question id #%s on event $%s", "event_espresso"),
-                    $old_question_group_id,
-                    $old_event['id']
-                )
-            );
-            return 0;
-        }
-        $new_event_id = $this->get_migration_script()->get_mapping_new_pk(
-            $wpdb->prefix . "events_detail",
-            intval($old_event['id']),
-            $wpdb->posts
-        );
-        if (! $new_event_id) {
-            $this->add_error(
-                sprintf(
-                // translators: %s event ID
-                    esc_html__("Could not find 4.1 event 3.1 event id #%s", "event_espresso"),
-                    $old_event['id']
-                )
-            );
-            return 0;
-        }
-        $cols_n_values = [
-            'EVT_ID'      => $new_event_id,
-            'QSG_ID'      => $new_question_group_id,
-            'EQG_primary' => $primary,
-        ];
+		if (! $new_question_group_id) {
+			$this->add_error(
+				sprintf(
+				// translators: %s question ID, %s event ID
+					esc_html__("Could not find 4.1 question ID for 3.1 question id #%s on event $%s", "event_espresso"),
+					$old_question_group_id,
+					$old_event['id']
+				)
+			);
+			return 0;
+		}
+		$new_event_id = $this->get_migration_script()->get_mapping_new_pk(
+			$wpdb->prefix . "events_detail",
+			intval($old_event['id']),
+			$wpdb->posts
+		);
+		if (! $new_event_id) {
+			$this->add_error(
+				sprintf(
+				// translators: %s event ID
+					esc_html__("Could not find 4.1 event 3.1 event id #%s", "event_espresso"),
+					$old_event['id']
+				)
+			);
+			return 0;
+		}
+		$cols_n_values = [
+			'EVT_ID'      => $new_event_id,
+			'QSG_ID'      => $new_question_group_id,
+			'EQG_primary' => $primary,
+		];
 
-        $data_types = [
-            '%d',// EVT_ID
-            '%d',// QSG_ID
-            '%d',// EQG_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,
-                    $this->_new_table,
-                    $cols_n_values,
-                    $data_types
-                )
-            );
-            return 0;
-        }
-        return $wpdb->insert_id;
-    }
+		$data_types = [
+			'%d',// EVT_ID
+			'%d',// QSG_ID
+			'%d',// EQG_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,
+					$this->_new_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_attendees.dmsstage.php

Indentation +917 added lines, -917 removed lines

@@ -224,942 +224,942 @@
  */
 class EE_DMS_4_1_0_attendees extends EE_Data_Migration_Script_Stage_Table
 {
-    private string $_new_attendee_cpt_table;
+	private string $_new_attendee_cpt_table;
 
-    private string $_new_attendee_meta_table;
+	private string $_new_attendee_meta_table;
 
-    private string $_new_reg_table;
+	private string $_new_reg_table;
 
-    private string $_new_transaction_table;
+	private string $_new_transaction_table;
 
-    private string $_new_payment_table;
+	private string $_new_payment_table;
 
-    private string $_old_mer_table;
+	private string $_old_mer_table;
 
-    private string $_new_ticket_table;
+	private string $_new_ticket_table;
 
-    private string $_new_ticket_datetime_table;
+	private string $_new_ticket_datetime_table;
 
-    private string $_new_datetime_table;
+	private string $_new_datetime_table;
 
-    private string $_new_datetime_ticket_table;
+	private string $_new_datetime_ticket_table;
 
-    private string $_new_price_table;
+	private string $_new_price_table;
 
-    private string $_new_ticket_price_table;
+	private string $_new_ticket_price_table;
 
-    /**
-     * Remembers whether the mer table exists
-     *
-     * @var boolean
-     */
-    private ?bool $_mer_tables_exist = null;
+	/**
+	 * Remembers whether the mer table exists
+	 *
+	 * @var boolean
+	 */
+	private ?bool $_mer_tables_exist = null;
 
 
-    public function __construct()
-    {
-        global $wpdb;
-        $this->_pretty_name = esc_html__("Attendees", "event_espresso");
-        $this->_old_table   = $wpdb->prefix . "events_attendee";
-        // Only select the event status column from the event table.
-        $this->select_expression = 'att.*, e.event_status';
-        // Only select attendees for events that aren't deleted.
-        $this->_extra_where_sql           = 'AS att
+	public function __construct()
+	{
+		global $wpdb;
+		$this->_pretty_name = esc_html__("Attendees", "event_espresso");
+		$this->_old_table   = $wpdb->prefix . "events_attendee";
+		// Only select the event status column from the event table.
+		$this->select_expression = 'att.*, e.event_status';
+		// Only select attendees for events that aren't deleted.
+		$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->_old_mer_table             = $wpdb->prefix . "events_multi_event_registration_id_group";
-        $this->_new_attendee_cpt_table    = $wpdb->posts;
-        $this->_new_attendee_meta_table   = $wpdb->prefix . "esp_attendee_meta";
-        $this->_new_reg_table             = $wpdb->prefix . "esp_registration";
-        $this->_new_transaction_table     = $wpdb->prefix . "esp_transaction";
-        $this->_new_payment_table         = $wpdb->prefix . "esp_payment";
-        $this->_new_ticket_table          = $wpdb->prefix . "esp_ticket";
-        $this->_new_ticket_datetime_table = $wpdb->prefix . "esp_datetime_ticket";
-        $this->_new_datetime_table        = $wpdb->prefix . "esp_datetime";
-        $this->_new_datetime_ticket_table = $wpdb->prefix . "esp_datetime_ticket";
-        $this->_new_price_table           = $wpdb->prefix . "esp_price";
-        $this->_new_ticket_price_table    = $wpdb->prefix . "esp_ticket_price";
-        parent::__construct();
-    }
-
-
-    /**
-     * @throws EE_Error
-     */
-    protected function _migrate_old_row($old_row)
-    {
-        // first check if there's already a new attendee with similar characteristics
-        $new_att_id = $this->_find_attendee_cpt_matching($old_row);
-        if (! $new_att_id) {
-            $new_att_id = $this->_insert_new_attendee_cpt($old_row);
-            if (! $new_att_id) {
-                // if we couldn't even make an attendee, abandon all hope
-                return;
-            }
-            $new_att_meta_id = $this->_insert_attendee_meta_row($old_row, $new_att_id);
-            if ($new_att_meta_id) {
-                $this->get_migration_script()->set_mapping(
-                    $this->_old_table,
-                    $old_row['id'],
-                    $this->_new_attendee_meta_table,
-                    $new_att_meta_id
-                );
-            }
-        }
-        $this->get_migration_script()->set_mapping(
-            $this->_old_table,
-            $old_row['id'],
-            $this->_new_attendee_cpt_table,
-            $new_att_id
-        );
-
-        $txn_id = $this->_insert_new_transaction($old_row);
-        if (! $txn_id) {
-            // if we couldn't make the transaction, also abandon all hope
-            return;
-        }
-        $this->get_migration_script()->set_mapping(
-            $this->_old_table,
-            $old_row['id'],
-            $this->_new_transaction_table,
-            $txn_id
-        );
-        $pay_id = $this->_insert_new_payment($old_row, $txn_id);
-        if ($pay_id) {
-            $this->get_migration_script()->set_mapping(
-                $this->_old_table,
-                $old_row['id'],
-                $this->_new_payment_table,
-                $pay_id
-            );
-        }
-
-
-        // even if there was no payment, we can go ahead with adding the reg
-        $new_regs = $this->_insert_new_registrations($old_row, $new_att_id, $txn_id);
-        if ($new_regs) {
-            $this->get_migration_script()->set_mapping(
-                $this->_old_table,
-                $old_row['id'],
-                $this->_new_reg_table,
-                $new_regs
-            );
-        }
-    }
-
-
-    /**
-     * Checks if there's already an attendee CPT in the db that has the same
-     * first and last name, and email. If so, returns its ID as an int.
-     *
-     * @param array $old_attendee
-     * @return int
-     * @global wpdb $wpdb
-     */
-    private function _find_attendee_cpt_matching(array $old_attendee): int
-    {
-        global $wpdb;
-        $existing_attendee_id =
-            $wpdb->get_var(
-                $wpdb->prepare(
-                    "SELECT id FROM " .
-                    $this->_new_attendee_cpt_table .
-                    " AS cpt INNER JOIN " .
-                    $this->_new_attendee_meta_table .
-                    " AS meta ON cpt.ID = meta.ATT_ID WHERE meta.ATT_fname = %s AND meta.ATT_lname = %s AND meta.ATT_email = %s LIMIT 1",
-                    $old_attendee['fname'],
-                    $old_attendee['lname'],
-                    $old_attendee['email']
-                )
-            );
-        return intval($existing_attendee_id);
-    }
-
-
-    private function _insert_new_attendee_cpt($old_attendee): int
-    {
-        global $wpdb;
-        $cols_n_values = [
-            'post_title'    => stripslashes($old_attendee['fname'] . " " . $old_attendee['lname']),// ATT_full_name
-            'post_content'  => '',// ATT_bio
-            'post_name'     => sanitize_title($old_attendee['fname'] . "-" . $old_attendee['lname']),// ATT_slug
-            'post_date'     => $this->get_migration_script()->convert_date_string_to_utc(
-                $this,
-                $old_attendee,
-                $old_attendee['date']
-            ),// ATT_created
-            'post_excerpt'  => '',// ATT_short_bio
-            'post_modified' => $this->get_migration_script()->convert_date_string_to_utc(
-                $this,
-                $old_attendee,
-                $old_attendee['date']
-            ),// ATT_modified
-            'post_author'   => 0,// ATT_author
-            'post_parent'   => 0,// ATT_parent
-            'post_type'     => EspressoPostType::ATTENDEES,
-            'post_status'   => 'publish',// status
-        ];
-        $data_types    = [
-            '%s',// ATT_full_name
-            '%s',// ATT_bio
-            '%s',// ATT_slug
-            '%s',// ATT_created
-            '%s',// ATT_short_bio
-            '%s',// ATT_modified
-            '%d',// ATT_author
-            '%d',// ATT_parent
-            '%s',// post_type
-            '%s',// status
-        ];
-        $success       = $wpdb->insert($this->_new_attendee_cpt_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_attendee_cpt_table,
-                    $cols_n_values,
-                    $data_types
-                )
-            );
-            return 0;
-        }
-        return $wpdb->insert_id;
-    }
-
-
-    private function _insert_attendee_meta_row($old_attendee, $new_attendee_cpt_id): int
-    {
-        global $wpdb;
-        // get the state and country ids from the old row
-        try {
-            $new_country     =
-                $this->get_migration_script()->get_or_create_country(stripslashes($old_attendee['country_id']));
-            $new_country_iso = $new_country['CNT_ISO'];
-        } catch (EE_Error $exception) {
-            $new_country_iso = $this->get_migration_script()->get_default_country_iso();
-        }
-        try {
-            $new_state    =
-                $this->get_migration_script()->get_or_create_state(
-                    stripslashes($old_attendee['state']),
-                    $new_country_iso
-                );
-            $new_state_id = $new_state['STA_ID'];
-        } catch (EE_Error $exception) {
-            $new_state_id = 0;
-        }
-        $cols_n_values = [
-            'ATT_ID'       => $new_attendee_cpt_id,
-            'ATT_fname'    => stripslashes($old_attendee['fname']),
-            'ATT_lname'    => stripslashes($old_attendee['lname']),
-            'ATT_address'  => stripslashes($old_attendee['address']),
-            'ATT_address2' => stripslashes($old_attendee['address2']),
-            'ATT_city'     => stripslashes($old_attendee['city']),
-            'STA_ID'       => $new_state_id,
-            'CNT_ISO'      => $new_country_iso,
-            'ATT_zip'      => stripslashes($old_attendee['zip']),
-            'ATT_email'    => stripslashes($old_attendee['email']),
-            'ATT_phone'    => stripslashes($old_attendee['phone']),
-        ];
-        $data_types    = [
-            '%d',// ATT_ID
-            '%s',// ATT_fname
-            '%s',// ATT_lname
-            '%s',// ATT_address
-            '%s',// ATT_address2
-            '%s',// ATT_city
-            '%d',// STA_ID
-            '%s',// CNT_ISO
-            '%s',// ATT_zip
-            '%s',// ATT_email
-            '%s',// ATT_phone
-        ];
-        $success       = $wpdb->insert($this->_new_attendee_meta_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_attendee_meta_table,
-                    $cols_n_values,
-                    $data_types
-                )
-            );
-            return 0;
-        }
-        return $wpdb->insert_id;
-    }
-
-
-    /**
-     * Note: we don't necessarily create a new transaction for each attendee row.
-     * Only if the old attendee 'is_primary' is true; otherwise we find the old attendee row that
-     * 'is_primary' and has the same 'txn_id', then we return ITS new transaction id
-     *
-     * @param array $old_attendee
-     * @return int new transaction id
-     * @throws EE_Error
-     * @global wpdb $wpdb
-     */
-    private function _insert_new_transaction(array $old_attendee): int
-    {
-        global $wpdb;
-
-        // first: let's check for an existing transaction for this old attendee
-        if (intval($old_attendee['is_primary'])) {// primary attendee, so create txn
-            $txn_id =
-                $this->get_migration_script()->get_mapping_new_pk(
-                    $this->_old_table,
-                    intval($old_attendee['id']),
-                    $this->_new_transaction_table
-                );
-        } else { // non-primary attendee, so find its primary attendee's transaction
-            $primary_attendee_old_id =
-                $wpdb->get_var(
-                    $wpdb->prepare(
-                        "SELECT id FROM " . $this->_old_table . " WHERE is_primary=1 and registration_id=%s",
-                        $old_attendee['registration_id']
-                    )
-                );
-            if (! $primary_attendee_old_id) {
-                $primary_attendee        =
-                    $this->_find_mer_primary_attendee_using_mer_tables($old_attendee['registration_id']);
-                $primary_attendee_old_id = is_array($primary_attendee) ? $primary_attendee['id'] : null;
-            }
-            $txn_id =
-                $this->get_migration_script()->get_mapping_new_pk(
-                    $this->_old_table,
-                    intval($primary_attendee_old_id),
-                    $this->_new_transaction_table
-                );
-            if (! $txn_id) {
-                $this->add_error(
-                    sprintf(
-                        esc_html__(
-                            "Could not find primary attendee's new transaction. Current attendee is: %s, we think the 3.1 primary attendee for it has id %d, but there's no 4.1 transaction for that primary attendee id.",
-                            "event_espresso"
-                        ),
-                        $this->_json_encode($old_attendee),
-                        $primary_attendee_old_id
-                    )
-                );
-                $txn_id = 0;
-            }
-        }
-        // if there isn't yet a transaction row for this, create one
-        // (so even if it was a non-primary attendee with no EE3 primary attendee,
-        // it ought to have SOME transaction, so we'll make one)
-        if (! $txn_id) {
-            // maps 3.1 payment stati onto 4.1 transaction stati
-            $txn_status_mapping = [
-                'Completed'        => 'TCM',
-                'Pending'          => 'TIN',
-                'Payment Declined' => 'TIN',
-                'Incomplete'       => 'TIN',
-                'Not Completed'    => 'TIN',
-                'Cancelled'        => 'TIN',
-                'Declined'         => 'TIN',
-            ];
-            $STS_ID             = $txn_status_mapping[ $old_attendee['payment_status'] ] ?? 'TIN';
-            $cols_n_values      = [
-                'TXN_timestamp' => $this->get_migration_script()->convert_date_string_to_utc(
-                    $this,
-                    $old_attendee,
-                    $old_attendee['date']
-                ),
-                'TXN_total'     => floatval($old_attendee['total_cost']),
-                'TXN_paid'      => floatval($old_attendee['amount_pd']),
-                'STS_ID'        => $STS_ID,
-                'TXN_hash_salt' => $old_attendee['hashSalt'],
-            ];
-            $data_types         = [
-                '%s',// TXN_timestamp
-                '%f',// TXN_total
-                '%f',// TXN_paid
-                '%s',// STS_ID
-                '%s',// TXN_hash_salt
-            ];
-            $success            = $wpdb->insert($this->_new_transaction_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_transaction_table,
-                        $cols_n_values,
-                        $data_types
-                    )
-                );
-                return 0;
-            }
-            $txn_id = $wpdb->insert_id;
-        }
-
-        return $txn_id;
-    }
-
-
-    /**
-     * Detects if the MER tables exist
-     *
-     * @return boolean
-     * @global wpdb $wpdb
-     */
-    private function _mer_tables_exist(): ?bool
-    {
-        if ($this->_mer_tables_exist === null) {
-            global $wpdb;
-
-            if ($wpdb->get_var("SHOW TABLES LIKE '$this->_old_mer_table'") != $this->_old_mer_table) {
-                $this->_mer_tables_exist = false;
-            } else {
-                $this->_mer_tables_exist = true;
-            }
-        }
-        return $this->_mer_tables_exist;
-    }
-
-
-    /**
-     * Gets the 4.1 registration's status given the 3.1 attendee row. We consider
-     * whether the event required pre-approval or not,a dn the 4.1 payment status.
-     *
-     * @param array $old_attendee_row
-     * @return string
-     * @global wpdb $wpdb
-     */
-    private function _get_reg_status_for_old_payment_status(array $old_attendee_row): string
-    {
-        // need event default reg status and if pre_approval was required
-        global $wpdb;
-        $event_required_pre_approval =
-            $wpdb->get_var(
-                $wpdb->prepare(
-                    "SELECT require_pre_approval FROM " . $wpdb->prefix . "events_detail WHERE id = %d",
-                    $old_attendee_row['event_id']
-                )
-            );
-        return $this->get_migration_script()->convert_3_1_payment_status_to_4_1_STS_ID(
-            $old_attendee_row['payment_status'],
-            intval($event_required_pre_approval) && intval($old_attendee_row['pre_approve'])
-        );
-    }
-
-
-    /**
-     * Adds however many registrations are indicated by the old attendee's QUANTITY field,
-     * and returns an array of their IDs
-     *
-     * @param array $old_attendee
-     * @param int   $new_attendee_id
-     * @param int   $new_txn_id
-     * @return array of new registration ids
-     * @throws EE_Error
-     * @global wpdb $wpdb
-     */
-    private function _insert_new_registrations(array $old_attendee, int $new_attendee_id, int $new_txn_id): array
-    {
-        global $wpdb;
-
-        $STS_ID       = $this->_get_reg_status_for_old_payment_status($old_attendee);
-        $new_event_id =
-            $this->get_migration_script()->get_mapping_new_pk(
-                $wpdb->prefix . 'events_detail',
-                $old_attendee['event_id'],
-                $wpdb->posts
-            );
-        if (! $new_event_id) {
-            $this->add_error(
-                sprintf(
-                    esc_html__(
-                        "Could not find NEW event CPT ID for old event '%d' on old attendee %s",
-                        "event_espresso"
-                    ),
-                    $old_attendee['event_id'],
-                    $this->_json_encode($old_attendee)
-                )
-            );
-        }
-
-        $ticket_id = $this->_try_to_find_new_ticket_id($old_attendee, $new_event_id);
-        if (! $ticket_id) {
-            $ticket_id = $this->_insert_new_ticket_because_none_found($old_attendee, $new_event_id);
-            $this->add_error(
-                sprintf(
-                    esc_html__(
-                        'Could not find a ticket for old attendee with id %d for new event %d, so created a new ticket with id %d',
-                        'event_espresso'
-                    ),
-                    $old_attendee['id'],
-                    $new_event_id,
-                    $ticket_id
-                )
-            );
-        }
-        $regs_on_this_row = intval($old_attendee['quantity']);
-        $new_regs         = [];
-        // 4 cases we need to account for:
-        // 1 old attendee_details row with a quantity of X (no mer)
-        // Y old attendee_details rows with a quantity of 1 (no mer) joined by their common registration_id
-        // Y old attendee_details rows with a quantity of x (because of mer)
-        // Y old attendee_details rows with a quantity of 1 (because of mer) joined by wp_events_multi_event_registration_id_group
-        for ($count = 1; $count <= $regs_on_this_row; $count++) {
-            // sum regs on older rows
-            $regs_on_this_event_and_txn = $this->_sum_old_attendees_on_old_txn($old_attendee, true);
-            $cols_n_values              = [
-                'EVT_ID'           => $new_event_id,
-                'ATT_ID'           => $new_attendee_id,
-                'TXN_ID'           => $new_txn_id,
-                'TKT_ID'           => $ticket_id,
-                'STS_ID'           => $STS_ID,
-                'REG_date'         => $this->get_migration_script()->convert_date_string_to_utc(
-                    $this,
-                    $old_attendee,
-                    $old_attendee['date']
-                ),
-                'REG_final_price'  => $old_attendee['final_price'],
-                'REG_session'      => substr($old_attendee['attendee_session'], 0, 44),
-                'REG_code'         => sanitize_key($old_attendee['registration_id']),
-                'REG_url_link'     => sanitize_key($old_attendee['registration_id'] . '-' . $count),
-                'REG_count'        => $regs_on_this_event_and_txn + $count,
-                'REG_group_size'   => $this->_sum_old_attendees_on_old_txn($old_attendee),
-                'REG_att_is_going' => true,
-                'REG_deleted'      => false,
-            ];
-            $data_types                 = [
-                '%d',// EVT_ID
-                '%d',// ATT_ID
-                '%d',// TXN_ID
-                '%d',// TKT_ID
-                '%s',// STS_ID
-                '%s',// REG_date
-                '%f',// REG_final_price
-                '%s',// REG_session
-                '%s',// REG_code
-                '%s',// REG_url_link
-                '%d',// REG_count
-                '%d',// REG_group_size
-                '%d',// REG_att_is_going
-                '%d',// REG_deleted
-            ];
-            $success                    = $wpdb->insert($this->_new_reg_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 [];
-            }
-            $cols_n_values['REG_ID'] = $wpdb->insert_id;
-            $new_regs[]              = $wpdb->insert_id;
-        }
-        $this->_add_regs_to_ticket_and_datetimes($ticket_id, count($new_regs), $STS_ID);
-        return $new_regs;
-    }
-
-
-    /**
-     * Increments the sold values on the ticket and its related datetimes by the amount sold,
-     * which should be done directly after adding the rows. Yes this means we're constantly incrementing
-     * the sold amounts as we go, and is less efficient than a single big query,
-     * but it's safer because we KNOW these regs have been added, rather than inferring
-     * that they WILL be added (because the attendees stage runs nearly last during
-     * the migration script)
-     *
-     * @param int    $new_ticket_id
-     * @param int    $quantity_sold
-     * @param string $STS_ID
-     * @return boolean whether they were successfully updated or not
-     */
-    protected function _add_regs_to_ticket_and_datetimes(int $new_ticket_id, int $quantity_sold, string $STS_ID): bool
-    {
-        if ($STS_ID != 'RAP') {
-            return true;
-        }
-        global $wpdb;
-        $success =
-            $wpdb->query(
-                $wpdb->prepare(
-                    "UPDATE $this->_new_ticket_table SET TKT_sold=TKT_sold+%d WHERE TKT_ID=%d",
-                    $quantity_sold,
-                    $new_ticket_id
-                )
-            );
-        if ($success) {
-            // get the ticket's datetimes, and increment them too
-            $success_update_datetimes = $wpdb->query(
-                $wpdb->prepare(
-                    "UPDATE $this->_new_ticket_table TKT
+		$this->_old_mer_table             = $wpdb->prefix . "events_multi_event_registration_id_group";
+		$this->_new_attendee_cpt_table    = $wpdb->posts;
+		$this->_new_attendee_meta_table   = $wpdb->prefix . "esp_attendee_meta";
+		$this->_new_reg_table             = $wpdb->prefix . "esp_registration";
+		$this->_new_transaction_table     = $wpdb->prefix . "esp_transaction";
+		$this->_new_payment_table         = $wpdb->prefix . "esp_payment";
+		$this->_new_ticket_table          = $wpdb->prefix . "esp_ticket";
+		$this->_new_ticket_datetime_table = $wpdb->prefix . "esp_datetime_ticket";
+		$this->_new_datetime_table        = $wpdb->prefix . "esp_datetime";
+		$this->_new_datetime_ticket_table = $wpdb->prefix . "esp_datetime_ticket";
+		$this->_new_price_table           = $wpdb->prefix . "esp_price";
+		$this->_new_ticket_price_table    = $wpdb->prefix . "esp_ticket_price";
+		parent::__construct();
+	}
+
+
+	/**
+	 * @throws EE_Error
+	 */
+	protected function _migrate_old_row($old_row)
+	{
+		// first check if there's already a new attendee with similar characteristics
+		$new_att_id = $this->_find_attendee_cpt_matching($old_row);
+		if (! $new_att_id) {
+			$new_att_id = $this->_insert_new_attendee_cpt($old_row);
+			if (! $new_att_id) {
+				// if we couldn't even make an attendee, abandon all hope
+				return;
+			}
+			$new_att_meta_id = $this->_insert_attendee_meta_row($old_row, $new_att_id);
+			if ($new_att_meta_id) {
+				$this->get_migration_script()->set_mapping(
+					$this->_old_table,
+					$old_row['id'],
+					$this->_new_attendee_meta_table,
+					$new_att_meta_id
+				);
+			}
+		}
+		$this->get_migration_script()->set_mapping(
+			$this->_old_table,
+			$old_row['id'],
+			$this->_new_attendee_cpt_table,
+			$new_att_id
+		);
+
+		$txn_id = $this->_insert_new_transaction($old_row);
+		if (! $txn_id) {
+			// if we couldn't make the transaction, also abandon all hope
+			return;
+		}
+		$this->get_migration_script()->set_mapping(
+			$this->_old_table,
+			$old_row['id'],
+			$this->_new_transaction_table,
+			$txn_id
+		);
+		$pay_id = $this->_insert_new_payment($old_row, $txn_id);
+		if ($pay_id) {
+			$this->get_migration_script()->set_mapping(
+				$this->_old_table,
+				$old_row['id'],
+				$this->_new_payment_table,
+				$pay_id
+			);
+		}
+
+
+		// even if there was no payment, we can go ahead with adding the reg
+		$new_regs = $this->_insert_new_registrations($old_row, $new_att_id, $txn_id);
+		if ($new_regs) {
+			$this->get_migration_script()->set_mapping(
+				$this->_old_table,
+				$old_row['id'],
+				$this->_new_reg_table,
+				$new_regs
+			);
+		}
+	}
+
+
+	/**
+	 * Checks if there's already an attendee CPT in the db that has the same
+	 * first and last name, and email. If so, returns its ID as an int.
+	 *
+	 * @param array $old_attendee
+	 * @return int
+	 * @global wpdb $wpdb
+	 */
+	private function _find_attendee_cpt_matching(array $old_attendee): int
+	{
+		global $wpdb;
+		$existing_attendee_id =
+			$wpdb->get_var(
+				$wpdb->prepare(
+					"SELECT id FROM " .
+					$this->_new_attendee_cpt_table .
+					" AS cpt INNER JOIN " .
+					$this->_new_attendee_meta_table .
+					" AS meta ON cpt.ID = meta.ATT_ID WHERE meta.ATT_fname = %s AND meta.ATT_lname = %s AND meta.ATT_email = %s LIMIT 1",
+					$old_attendee['fname'],
+					$old_attendee['lname'],
+					$old_attendee['email']
+				)
+			);
+		return intval($existing_attendee_id);
+	}
+
+
+	private function _insert_new_attendee_cpt($old_attendee): int
+	{
+		global $wpdb;
+		$cols_n_values = [
+			'post_title'    => stripslashes($old_attendee['fname'] . " " . $old_attendee['lname']),// ATT_full_name
+			'post_content'  => '',// ATT_bio
+			'post_name'     => sanitize_title($old_attendee['fname'] . "-" . $old_attendee['lname']),// ATT_slug
+			'post_date'     => $this->get_migration_script()->convert_date_string_to_utc(
+				$this,
+				$old_attendee,
+				$old_attendee['date']
+			),// ATT_created
+			'post_excerpt'  => '',// ATT_short_bio
+			'post_modified' => $this->get_migration_script()->convert_date_string_to_utc(
+				$this,
+				$old_attendee,
+				$old_attendee['date']
+			),// ATT_modified
+			'post_author'   => 0,// ATT_author
+			'post_parent'   => 0,// ATT_parent
+			'post_type'     => EspressoPostType::ATTENDEES,
+			'post_status'   => 'publish',// status
+		];
+		$data_types    = [
+			'%s',// ATT_full_name
+			'%s',// ATT_bio
+			'%s',// ATT_slug
+			'%s',// ATT_created
+			'%s',// ATT_short_bio
+			'%s',// ATT_modified
+			'%d',// ATT_author
+			'%d',// ATT_parent
+			'%s',// post_type
+			'%s',// status
+		];
+		$success       = $wpdb->insert($this->_new_attendee_cpt_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_attendee_cpt_table,
+					$cols_n_values,
+					$data_types
+				)
+			);
+			return 0;
+		}
+		return $wpdb->insert_id;
+	}
+
+
+	private function _insert_attendee_meta_row($old_attendee, $new_attendee_cpt_id): int
+	{
+		global $wpdb;
+		// get the state and country ids from the old row
+		try {
+			$new_country     =
+				$this->get_migration_script()->get_or_create_country(stripslashes($old_attendee['country_id']));
+			$new_country_iso = $new_country['CNT_ISO'];
+		} catch (EE_Error $exception) {
+			$new_country_iso = $this->get_migration_script()->get_default_country_iso();
+		}
+		try {
+			$new_state    =
+				$this->get_migration_script()->get_or_create_state(
+					stripslashes($old_attendee['state']),
+					$new_country_iso
+				);
+			$new_state_id = $new_state['STA_ID'];
+		} catch (EE_Error $exception) {
+			$new_state_id = 0;
+		}
+		$cols_n_values = [
+			'ATT_ID'       => $new_attendee_cpt_id,
+			'ATT_fname'    => stripslashes($old_attendee['fname']),
+			'ATT_lname'    => stripslashes($old_attendee['lname']),
+			'ATT_address'  => stripslashes($old_attendee['address']),
+			'ATT_address2' => stripslashes($old_attendee['address2']),
+			'ATT_city'     => stripslashes($old_attendee['city']),
+			'STA_ID'       => $new_state_id,
+			'CNT_ISO'      => $new_country_iso,
+			'ATT_zip'      => stripslashes($old_attendee['zip']),
+			'ATT_email'    => stripslashes($old_attendee['email']),
+			'ATT_phone'    => stripslashes($old_attendee['phone']),
+		];
+		$data_types    = [
+			'%d',// ATT_ID
+			'%s',// ATT_fname
+			'%s',// ATT_lname
+			'%s',// ATT_address
+			'%s',// ATT_address2
+			'%s',// ATT_city
+			'%d',// STA_ID
+			'%s',// CNT_ISO
+			'%s',// ATT_zip
+			'%s',// ATT_email
+			'%s',// ATT_phone
+		];
+		$success       = $wpdb->insert($this->_new_attendee_meta_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_attendee_meta_table,
+					$cols_n_values,
+					$data_types
+				)
+			);
+			return 0;
+		}
+		return $wpdb->insert_id;
+	}
+
+
+	/**
+	 * Note: we don't necessarily create a new transaction for each attendee row.
+	 * Only if the old attendee 'is_primary' is true; otherwise we find the old attendee row that
+	 * 'is_primary' and has the same 'txn_id', then we return ITS new transaction id
+	 *
+	 * @param array $old_attendee
+	 * @return int new transaction id
+	 * @throws EE_Error
+	 * @global wpdb $wpdb
+	 */
+	private function _insert_new_transaction(array $old_attendee): int
+	{
+		global $wpdb;
+
+		// first: let's check for an existing transaction for this old attendee
+		if (intval($old_attendee['is_primary'])) {// primary attendee, so create txn
+			$txn_id =
+				$this->get_migration_script()->get_mapping_new_pk(
+					$this->_old_table,
+					intval($old_attendee['id']),
+					$this->_new_transaction_table
+				);
+		} else { // non-primary attendee, so find its primary attendee's transaction
+			$primary_attendee_old_id =
+				$wpdb->get_var(
+					$wpdb->prepare(
+						"SELECT id FROM " . $this->_old_table . " WHERE is_primary=1 and registration_id=%s",
+						$old_attendee['registration_id']
+					)
+				);
+			if (! $primary_attendee_old_id) {
+				$primary_attendee        =
+					$this->_find_mer_primary_attendee_using_mer_tables($old_attendee['registration_id']);
+				$primary_attendee_old_id = is_array($primary_attendee) ? $primary_attendee['id'] : null;
+			}
+			$txn_id =
+				$this->get_migration_script()->get_mapping_new_pk(
+					$this->_old_table,
+					intval($primary_attendee_old_id),
+					$this->_new_transaction_table
+				);
+			if (! $txn_id) {
+				$this->add_error(
+					sprintf(
+						esc_html__(
+							"Could not find primary attendee's new transaction. Current attendee is: %s, we think the 3.1 primary attendee for it has id %d, but there's no 4.1 transaction for that primary attendee id.",
+							"event_espresso"
+						),
+						$this->_json_encode($old_attendee),
+						$primary_attendee_old_id
+					)
+				);
+				$txn_id = 0;
+			}
+		}
+		// if there isn't yet a transaction row for this, create one
+		// (so even if it was a non-primary attendee with no EE3 primary attendee,
+		// it ought to have SOME transaction, so we'll make one)
+		if (! $txn_id) {
+			// maps 3.1 payment stati onto 4.1 transaction stati
+			$txn_status_mapping = [
+				'Completed'        => 'TCM',
+				'Pending'          => 'TIN',
+				'Payment Declined' => 'TIN',
+				'Incomplete'       => 'TIN',
+				'Not Completed'    => 'TIN',
+				'Cancelled'        => 'TIN',
+				'Declined'         => 'TIN',
+			];
+			$STS_ID             = $txn_status_mapping[ $old_attendee['payment_status'] ] ?? 'TIN';
+			$cols_n_values      = [
+				'TXN_timestamp' => $this->get_migration_script()->convert_date_string_to_utc(
+					$this,
+					$old_attendee,
+					$old_attendee['date']
+				),
+				'TXN_total'     => floatval($old_attendee['total_cost']),
+				'TXN_paid'      => floatval($old_attendee['amount_pd']),
+				'STS_ID'        => $STS_ID,
+				'TXN_hash_salt' => $old_attendee['hashSalt'],
+			];
+			$data_types         = [
+				'%s',// TXN_timestamp
+				'%f',// TXN_total
+				'%f',// TXN_paid
+				'%s',// STS_ID
+				'%s',// TXN_hash_salt
+			];
+			$success            = $wpdb->insert($this->_new_transaction_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_transaction_table,
+						$cols_n_values,
+						$data_types
+					)
+				);
+				return 0;
+			}
+			$txn_id = $wpdb->insert_id;
+		}
+
+		return $txn_id;
+	}
+
+
+	/**
+	 * Detects if the MER tables exist
+	 *
+	 * @return boolean
+	 * @global wpdb $wpdb
+	 */
+	private function _mer_tables_exist(): ?bool
+	{
+		if ($this->_mer_tables_exist === null) {
+			global $wpdb;
+
+			if ($wpdb->get_var("SHOW TABLES LIKE '$this->_old_mer_table'") != $this->_old_mer_table) {
+				$this->_mer_tables_exist = false;
+			} else {
+				$this->_mer_tables_exist = true;
+			}
+		}
+		return $this->_mer_tables_exist;
+	}
+
+
+	/**
+	 * Gets the 4.1 registration's status given the 3.1 attendee row. We consider
+	 * whether the event required pre-approval or not,a dn the 4.1 payment status.
+	 *
+	 * @param array $old_attendee_row
+	 * @return string
+	 * @global wpdb $wpdb
+	 */
+	private function _get_reg_status_for_old_payment_status(array $old_attendee_row): string
+	{
+		// need event default reg status and if pre_approval was required
+		global $wpdb;
+		$event_required_pre_approval =
+			$wpdb->get_var(
+				$wpdb->prepare(
+					"SELECT require_pre_approval FROM " . $wpdb->prefix . "events_detail WHERE id = %d",
+					$old_attendee_row['event_id']
+				)
+			);
+		return $this->get_migration_script()->convert_3_1_payment_status_to_4_1_STS_ID(
+			$old_attendee_row['payment_status'],
+			intval($event_required_pre_approval) && intval($old_attendee_row['pre_approve'])
+		);
+	}
+
+
+	/**
+	 * Adds however many registrations are indicated by the old attendee's QUANTITY field,
+	 * and returns an array of their IDs
+	 *
+	 * @param array $old_attendee
+	 * @param int   $new_attendee_id
+	 * @param int   $new_txn_id
+	 * @return array of new registration ids
+	 * @throws EE_Error
+	 * @global wpdb $wpdb
+	 */
+	private function _insert_new_registrations(array $old_attendee, int $new_attendee_id, int $new_txn_id): array
+	{
+		global $wpdb;
+
+		$STS_ID       = $this->_get_reg_status_for_old_payment_status($old_attendee);
+		$new_event_id =
+			$this->get_migration_script()->get_mapping_new_pk(
+				$wpdb->prefix . 'events_detail',
+				$old_attendee['event_id'],
+				$wpdb->posts
+			);
+		if (! $new_event_id) {
+			$this->add_error(
+				sprintf(
+					esc_html__(
+						"Could not find NEW event CPT ID for old event '%d' on old attendee %s",
+						"event_espresso"
+					),
+					$old_attendee['event_id'],
+					$this->_json_encode($old_attendee)
+				)
+			);
+		}
+
+		$ticket_id = $this->_try_to_find_new_ticket_id($old_attendee, $new_event_id);
+		if (! $ticket_id) {
+			$ticket_id = $this->_insert_new_ticket_because_none_found($old_attendee, $new_event_id);
+			$this->add_error(
+				sprintf(
+					esc_html__(
+						'Could not find a ticket for old attendee with id %d for new event %d, so created a new ticket with id %d',
+						'event_espresso'
+					),
+					$old_attendee['id'],
+					$new_event_id,
+					$ticket_id
+				)
+			);
+		}
+		$regs_on_this_row = intval($old_attendee['quantity']);
+		$new_regs         = [];
+		// 4 cases we need to account for:
+		// 1 old attendee_details row with a quantity of X (no mer)
+		// Y old attendee_details rows with a quantity of 1 (no mer) joined by their common registration_id
+		// Y old attendee_details rows with a quantity of x (because of mer)
+		// Y old attendee_details rows with a quantity of 1 (because of mer) joined by wp_events_multi_event_registration_id_group
+		for ($count = 1; $count <= $regs_on_this_row; $count++) {
+			// sum regs on older rows
+			$regs_on_this_event_and_txn = $this->_sum_old_attendees_on_old_txn($old_attendee, true);
+			$cols_n_values              = [
+				'EVT_ID'           => $new_event_id,
+				'ATT_ID'           => $new_attendee_id,
+				'TXN_ID'           => $new_txn_id,
+				'TKT_ID'           => $ticket_id,
+				'STS_ID'           => $STS_ID,
+				'REG_date'         => $this->get_migration_script()->convert_date_string_to_utc(
+					$this,
+					$old_attendee,
+					$old_attendee['date']
+				),
+				'REG_final_price'  => $old_attendee['final_price'],
+				'REG_session'      => substr($old_attendee['attendee_session'], 0, 44),
+				'REG_code'         => sanitize_key($old_attendee['registration_id']),
+				'REG_url_link'     => sanitize_key($old_attendee['registration_id'] . '-' . $count),
+				'REG_count'        => $regs_on_this_event_and_txn + $count,
+				'REG_group_size'   => $this->_sum_old_attendees_on_old_txn($old_attendee),
+				'REG_att_is_going' => true,
+				'REG_deleted'      => false,
+			];
+			$data_types                 = [
+				'%d',// EVT_ID
+				'%d',// ATT_ID
+				'%d',// TXN_ID
+				'%d',// TKT_ID
+				'%s',// STS_ID
+				'%s',// REG_date
+				'%f',// REG_final_price
+				'%s',// REG_session
+				'%s',// REG_code
+				'%s',// REG_url_link
+				'%d',// REG_count
+				'%d',// REG_group_size
+				'%d',// REG_att_is_going
+				'%d',// REG_deleted
+			];
+			$success                    = $wpdb->insert($this->_new_reg_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 [];
+			}
+			$cols_n_values['REG_ID'] = $wpdb->insert_id;
+			$new_regs[]              = $wpdb->insert_id;
+		}
+		$this->_add_regs_to_ticket_and_datetimes($ticket_id, count($new_regs), $STS_ID);
+		return $new_regs;
+	}
+
+
+	/**
+	 * Increments the sold values on the ticket and its related datetimes by the amount sold,
+	 * which should be done directly after adding the rows. Yes this means we're constantly incrementing
+	 * the sold amounts as we go, and is less efficient than a single big query,
+	 * but it's safer because we KNOW these regs have been added, rather than inferring
+	 * that they WILL be added (because the attendees stage runs nearly last during
+	 * the migration script)
+	 *
+	 * @param int    $new_ticket_id
+	 * @param int    $quantity_sold
+	 * @param string $STS_ID
+	 * @return boolean whether they were successfully updated or not
+	 */
+	protected function _add_regs_to_ticket_and_datetimes(int $new_ticket_id, int $quantity_sold, string $STS_ID): bool
+	{
+		if ($STS_ID != 'RAP') {
+			return true;
+		}
+		global $wpdb;
+		$success =
+			$wpdb->query(
+				$wpdb->prepare(
+					"UPDATE $this->_new_ticket_table SET TKT_sold=TKT_sold+%d WHERE TKT_ID=%d",
+					$quantity_sold,
+					$new_ticket_id
+				)
+			);
+		if ($success) {
+			// get the ticket's datetimes, and increment them too
+			$success_update_datetimes = $wpdb->query(
+				$wpdb->prepare(
+					"UPDATE $this->_new_ticket_table TKT
 				INNER JOIN $this->_new_ticket_datetime_table as DTK ON TKT.TKT_ID = DTK.TKT_ID
 				INNER JOIN $this->_new_datetime_table as DTT ON DTK.DTT_ID = DTT.DTT_ID
 				SET DTT.DTT_sold = DTT.DTT_sold + %d WHERE TKT.TKT_ID = %d",
-                    $quantity_sold,
-                    $new_ticket_id
-                )
-            );
-            if (! $success_update_datetimes) {
-                $this->add_error(
-                    sprintf(
-                        esc_html__(
-                            "Could not update datetimes related to ticket with ID %d's TKT_sold by %d because %s",
-                            "event_espresso"
-                        ),
-                        $new_ticket_id,
-                        $quantity_sold,
-                        $wpdb->last_error
-                    )
-                );
-            }
-        } else {
-            $this->add_error(
-                sprintf(
-                    esc_html__("Could not update ticket with ID %d's TKT_sold by %d because %s", "event_espresso"),
-                    $new_ticket_id,
-                    $quantity_sold,
-                    $wpdb->last_error
-                )
-            );
-        }
-        return true;
-    }
-
-
-    /**
-     * Makes a guess at which ticket is the one the attendee purchased.
-     * Obviously, the old attendee's event_id narrows it down quite a bit;
-     * then the old attendee's orig_price and event_time, and price_option can uniquely identify the ticket
-     * however, if we don't find an exact match, see if any of those conditions match;
-     * and lastly if none of that works, just use the first ticket for the event we find
-     *
-     * @param array $old_attendee
-     * @param       $new_event_id
-     * @return string|null
-     */
-    private function _try_to_find_new_ticket_id(array $old_attendee, $new_event_id): ?string
-    {
-        global $wpdb;
-        $tickets_table          = $this->_new_ticket_table;
-        $datetime_tickets_table = $this->_new_ticket_datetime_table;
-        $datetime_table         = $this->_new_datetime_table;
-
-        $old_att_price_option = $old_attendee['price_option'];
-        $old_att_price        = floatval($old_attendee['orig_price']);
-
-        $old_att_start_date = $old_attendee['start_date'];
-        $old_att_start_time = $this->get_migration_script()->convertTimeFromAMPM($old_attendee['event_time']);
-        $old_att_datetime   =
-            $this->get_migration_script()->convert_date_string_to_utc(
-                $this,
-                $old_attendee,
-                "$old_att_start_date $old_att_start_time:00"
-            );
-        // add all conditions to an array from which we can SHIFT conditions off in order to widen our search
-        // the most important condition should be last, as it will be array_shift'ed off last
-        $conditions           = [
-            $wpdb->prepare("$datetime_table.DTT_EVT_start = %s", $old_att_datetime),// times match?
-            $wpdb->prepare("$tickets_table.TKT_price = %f", $old_att_price),// prices match?
-            $wpdb->prepare("$tickets_table.TKT_name = %s", $old_att_price_option),// names match?
-            $wpdb->prepare("$datetime_table.EVT_ID = %d", $new_event_id),// events match?
-        ];
-        $select_and_join_part = "SELECT $tickets_table.TKT_ID FROM $tickets_table INNER JOIN
+					$quantity_sold,
+					$new_ticket_id
+				)
+			);
+			if (! $success_update_datetimes) {
+				$this->add_error(
+					sprintf(
+						esc_html__(
+							"Could not update datetimes related to ticket with ID %d's TKT_sold by %d because %s",
+							"event_espresso"
+						),
+						$new_ticket_id,
+						$quantity_sold,
+						$wpdb->last_error
+					)
+				);
+			}
+		} else {
+			$this->add_error(
+				sprintf(
+					esc_html__("Could not update ticket with ID %d's TKT_sold by %d because %s", "event_espresso"),
+					$new_ticket_id,
+					$quantity_sold,
+					$wpdb->last_error
+				)
+			);
+		}
+		return true;
+	}
+
+
+	/**
+	 * Makes a guess at which ticket is the one the attendee purchased.
+	 * Obviously, the old attendee's event_id narrows it down quite a bit;
+	 * then the old attendee's orig_price and event_time, and price_option can uniquely identify the ticket
+	 * however, if we don't find an exact match, see if any of those conditions match;
+	 * and lastly if none of that works, just use the first ticket for the event we find
+	 *
+	 * @param array $old_attendee
+	 * @param       $new_event_id
+	 * @return string|null
+	 */
+	private function _try_to_find_new_ticket_id(array $old_attendee, $new_event_id): ?string
+	{
+		global $wpdb;
+		$tickets_table          = $this->_new_ticket_table;
+		$datetime_tickets_table = $this->_new_ticket_datetime_table;
+		$datetime_table         = $this->_new_datetime_table;
+
+		$old_att_price_option = $old_attendee['price_option'];
+		$old_att_price        = floatval($old_attendee['orig_price']);
+
+		$old_att_start_date = $old_attendee['start_date'];
+		$old_att_start_time = $this->get_migration_script()->convertTimeFromAMPM($old_attendee['event_time']);
+		$old_att_datetime   =
+			$this->get_migration_script()->convert_date_string_to_utc(
+				$this,
+				$old_attendee,
+				"$old_att_start_date $old_att_start_time:00"
+			);
+		// add all conditions to an array from which we can SHIFT conditions off in order to widen our search
+		// the most important condition should be last, as it will be array_shift'ed off last
+		$conditions           = [
+			$wpdb->prepare("$datetime_table.DTT_EVT_start = %s", $old_att_datetime),// times match?
+			$wpdb->prepare("$tickets_table.TKT_price = %f", $old_att_price),// prices match?
+			$wpdb->prepare("$tickets_table.TKT_name = %s", $old_att_price_option),// names match?
+			$wpdb->prepare("$datetime_table.EVT_ID = %d", $new_event_id),// events match?
+		];
+		$select_and_join_part = "SELECT $tickets_table.TKT_ID FROM $tickets_table INNER JOIN
 			$datetime_tickets_table ON $tickets_table.TKT_ID = $datetime_tickets_table.TKT_ID INNER JOIN
 			$datetime_table ON $datetime_tickets_table.DTT_ID = $datetime_table.DTT_ID";
-        // start running queries, widening search each time by removing a condition
-        do {
-            $full_query      = $select_and_join_part . " WHERE " . implode(" AND ", $conditions) . " LIMIT 1";
-            $ticket_id_found = $wpdb->get_var($full_query);
-            array_shift($conditions);
-        } while (! $ticket_id_found && $conditions);
-        return $ticket_id_found;
-    }
-
-
-    /**
-     * If we couldn't find a 4.1 ticket for a 3.1 attendee row, this function creates one;
-     * and it also tries to find a datetime that works, and inserts a price, and associates
-     * the new ticket to that datetime and price.
-     *
-     * @return int ticket id
-     */
-    private function _insert_new_ticket_because_none_found($old_attendee, $new_event_id): int
-    {
-        global $wpdb;
-        $old_att_price_option = $old_attendee['price_option'];
-        $old_att_price        = floatval($old_attendee['orig_price']);
-
-        $old_att_start_date     = $old_attendee['start_date'];
-        $old_att_start_time     = $this->get_migration_script()->convertTimeFromAMPM(
-            $old_attendee['event_time']
-        );
-        $old_att_start_datetime =
-            $this->get_migration_script()->convert_date_string_to_utc(
-                $this,
-                $old_attendee,
-                "$old_att_start_date $old_att_start_time:00"
-            );
-        $old_att_end_datetime   = null;
-
-
-        // insert new datetime unless we find one
-        $datetime_id =
-            $wpdb->get_var(
-                $wpdb->prepare(
-                    "SELECT DTT_ID FROM " .
-                    $this->_new_datetime_table .
-                    " WHERE DTT_EVT_start=%s AND EVT_ID=%d LIMIT 1",
-                    $old_att_start_datetime,
-                    $new_event_id
-                ),
-                ARRAY_A
-            );
-        if (! $datetime_id) {
-            $old_att_end_date     = $old_attendee['start_date'];
-            $old_att_end_time     = $this->get_migration_script()->convertTimeFromAMPM(
-                $old_attendee['event_time']
-            );
-            $old_att_end_datetime = $this->get_migration_script()->convert_date_string_to_utc(
-                $this,
-                $old_attendee,
-                "$old_att_end_date $old_att_end_time:00"
-            );
-            $wpdb->insert(
-                $this->_new_datetime_table,
-                [
-                    'EVT_ID'        => $new_event_id,
-                    'DTT_EVT_start' => $old_att_start_datetime,
-                    'DTT_EVT_end'   => $old_att_end_datetime,
-                    'DTT_deleted'   => true,
-                ],
-                [
-                    '%d',// EVT_ID
-                    '%s',// DTT_EVT_start
-                    '%s',// DTT_EVT_end
-                    '%d',// DTT_deleted
-                ]
-            );
-            $datetime_id = $wpdb->insert_id;
-        }
-
-        // insert new ticket
-        $wpdb->insert(
-            $wpdb->prefix . 'esp_ticket',
-            [
-                'TKT_name'       => $old_att_price_option,
-                'TKT_qty'        => -1,
-                'TKT_price'      => $old_att_price,
-                'TKT_start_date' => $old_att_start_datetime,
-                // we really have no clue what the time should be, but at least it was available when they attended
-                'TKT_end_date'   => $old_att_end_datetime,
-
-            ],
-            [
-                '%s',// name
-                '%d',// qty
-                '%d',// price
-                '%s',// start_date
-                '%s',// end_date
-            ]
-        );
-        $ticket_id = $wpdb->insert_id;
-        // associate the ticket with the datetime we found earlier
-        $wpdb->insert(
-            $this->_new_datetime_ticket_table,
-            [
-                'DTT_ID' => $datetime_id,
-                'TKT_ID' => $ticket_id,
-            ],
-            [
-                '%d',// DTT_ID
-                '%d',// TKT_ID
-            ]
-        );
-        // insert new price
-        $wpdb->insert(
-            $this->_new_price_table,
-            [
-                'PRC_amount'  => $old_att_price,
-                'PRT_ID'      => EE_DMS_4_1_0_prices::price_type_base,
-                'PRC_name'    => $old_att_price_option,
-                'PRC_deleted' => true,
-            ],
-            [
-                '%d',// PRC_amount
-                '%d',// PRT_ID
-                '%s',// PRC_name
-                '%d',// PRC_deleted
-            ]
-        );
-        $price_id = $wpdb->insert_id;
-        // associate the price to the ticket
-        $wpdb->insert(
-            $this->_new_ticket_price_table,
-            [
-                'TKT_ID' => $ticket_id,
-                'PRC_ID' => $price_id,
-            ],
-            [
-                '%d',// TKT_ID
-                '%d',// PRC_ID
-            ]
-        );
-        return $ticket_id;
-    }
-
-
-    /**
-     * Counts all the registrations on this transaction. If $count_only_older is TRUE then returns the number added SO
-     * FAR (ie, only considers attendee rows with an ID less than this one's), but if $count_only_older is FALSe
-     * returns ALL
-     *
-     * @param array   $old_attendee_row
-     * @param boolean $count_only_older true if you want the running count (ie, the total up to this row), and false if
-     *                                  you want ALL
-     * @return int
-     * @global wpdb   $wpdb
-     */
-    private function _sum_old_attendees_on_old_txn(array $old_attendee_row, bool $count_only_older = false): int
-    {
-        global $wpdb;
-        $count_only_older_sql = $count_only_older ? $wpdb->prepare(" AND id<%d", $old_attendee_row['id']) : '';
-        $count                =
-            intval(
-                $wpdb->get_var(
-                    $wpdb->prepare(
-                        "SELECT SUM(quantity) FROM " .
-                        $this->_old_table .
-                        " WHERE registration_id=%s $count_only_older_sql",
-                        $old_attendee_row['registration_id']
-                    )
-                )
-            );
-
-        if ($this->_mer_tables_exist()) {
-            // if MER exists, then it's a little tricky.
-            // when users registered by adding items to the cart, and it was a
-            // group registration requiring additional attendee INFO, then the attendee rows
-            // DO NOT have the same registration_id (although they probably should have)
-            // they are related just like MER attendee rows are related, through the MER group table
-            // BUT we want to count all the MER attendee rows for the same registration
-            $primary_attendee =
-                $this->_find_mer_primary_attendee_using_mer_tables($old_attendee_row['registration_id']);
-
-            // No primary attendee to work with? Return the count.
-            if (is_null($primary_attendee)) {
-                return (int) $count;
-            }
-
-            $count_using_mer_table =
-                $wpdb->get_var(
-                    $wpdb->prepare(
-                        "SELECT SUM(quantity) FROM $this->_old_table att INNER JOIN $this->_old_mer_table mer ON att.registration_id = mer.registration_id WHERE att.event_id=%d AND mer.primary_registration_id = %s $count_only_older_sql",
-                        $old_attendee_row['event_id'],
-                        $primary_attendee['registration_id']
-                    )
-                );
-            $count                 = max($count_using_mer_table, $count);
-        }
-        return (int) $count;
-    }
-
-
-    private function _insert_new_payment($old_attendee, $new_txn_id): int
-    {
-        global $wpdb;
-        // Only add a payment for primary attendees. Important note: partial payments were marked as "Pending".
-        // Also, an offline payment had blank status (ie, "").
-        $old_pay_stati_indicating_no_payment = ['', 'Incomplete', 'Not Completed'];
-        // if this is for a primary 3.1 attendee which WASN'T free and has a completed, cancelled, or declined payment...
-        if (
-            intval($old_attendee['is_primary']) &&
-            floatval($old_attendee['total_cost']) &&
-            ! in_array($old_attendee['payment_status'], $old_pay_stati_indicating_no_payment)
-        ) {
-            $pay_status_mapping = [
-                'Completed'        => 'PAP',
-                'Payment Declined' => 'PDC',
-                'Cancelled'        => 'PCN',
-                'Declined'         => 'PDC',
-            ];
-
-            $by_admin = $old_attendee['payment'] == 'Admin';
-
-            // IE, if we don't recognize the status, assume payment failed
-            $STS_ID = $pay_status_mapping[ $old_attendee['payment_status'] ] ?? 'PFL';
-
-            $cols_n_values = [
-                'TXN_ID'               => $new_txn_id,
-                'STS_ID'               => $STS_ID,
-                'PAY_timestamp'        => $this->get_migration_script()->convert_date_string_to_utc(
-                    $this,
-                    $old_attendee,
-                    $old_attendee['date']
-                ),
-                'PAY_method'           => 'CART',
-                'PAY_amount'           => $old_attendee['amount_pd'],
-                // 'txn_type' was used both for the gateway's name, and for other payment notes.
-                'PAY_gateway'          => $old_attendee['txn_type'],
-                'PAY_extra_accntng'    => $old_attendee['txn_type'],
-                'PAY_gateway_response' => '',
-                'PAY_txn_id_chq_nmbr'  => substr($old_attendee['txn_id'], 0, 32),
-                'PAY_via_admin'        => $by_admin,
-                'PAY_details'          => $old_attendee['transaction_details'],
-            ];
-            $data_types    = [
-                '%d',// TXN_Id
-                '%s',// STS_ID
-                '%s',// PAY_timestamp
-                '%s',// PAY_method
-                '%f',// PAY_amount
-                '%s',// PAY_gateway
-                '%s',// PAY_gateway_response
-                '%s',// PAY_txn_id_chq_nmbr
-                '%d',// PAY_via_admin
-                '%s',// PAY_details
-            ];
-            $success       = $wpdb->insert($this->_new_payment_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_attendee_cpt_table,
-                        $cols_n_values,
-                        $data_types
-                    )
-                );
-                return 0;
-            }
-            return $wpdb->insert_id;
-        }
-        return 0;
-    }
-
-
-    /**
-     * If MER is active, if you want ot find the other registrations on that attendee row
-     *
-     * @param string   $old_registration_id
-     * @return array|null
-     * @global wpdb $wpdb
-     */
-    private function _find_mer_primary_attendee_using_mer_tables(string $old_registration_id): ?array
-    {
-        if (! $this->_mer_tables_exist()) {
-            return null;
-        }
-        global $wpdb;
-        return $wpdb->get_row(
-            $wpdb->prepare(
-                "SELECT * FROM $this->_old_mer_table AS mer INNER JOIN $this->_old_table AS att ON mer.primary_registration_id = att.registration_id WHERE mer.registration_id=%s LIMIT 1",
-                $old_registration_id
-            ),
-            ARRAY_A
-        );
-    }
+		// start running queries, widening search each time by removing a condition
+		do {
+			$full_query      = $select_and_join_part . " WHERE " . implode(" AND ", $conditions) . " LIMIT 1";
+			$ticket_id_found = $wpdb->get_var($full_query);
+			array_shift($conditions);
+		} while (! $ticket_id_found && $conditions);
+		return $ticket_id_found;
+	}
+
+
+	/**
+	 * If we couldn't find a 4.1 ticket for a 3.1 attendee row, this function creates one;
+	 * and it also tries to find a datetime that works, and inserts a price, and associates
+	 * the new ticket to that datetime and price.
+	 *
+	 * @return int ticket id
+	 */
+	private function _insert_new_ticket_because_none_found($old_attendee, $new_event_id): int
+	{
+		global $wpdb;
+		$old_att_price_option = $old_attendee['price_option'];
+		$old_att_price        = floatval($old_attendee['orig_price']);
+
+		$old_att_start_date     = $old_attendee['start_date'];
+		$old_att_start_time     = $this->get_migration_script()->convertTimeFromAMPM(
+			$old_attendee['event_time']
+		);
+		$old_att_start_datetime =
+			$this->get_migration_script()->convert_date_string_to_utc(
+				$this,
+				$old_attendee,
+				"$old_att_start_date $old_att_start_time:00"
+			);
+		$old_att_end_datetime   = null;
+
+
+		// insert new datetime unless we find one
+		$datetime_id =
+			$wpdb->get_var(
+				$wpdb->prepare(
+					"SELECT DTT_ID FROM " .
+					$this->_new_datetime_table .
+					" WHERE DTT_EVT_start=%s AND EVT_ID=%d LIMIT 1",
+					$old_att_start_datetime,
+					$new_event_id
+				),
+				ARRAY_A
+			);
+		if (! $datetime_id) {
+			$old_att_end_date     = $old_attendee['start_date'];
+			$old_att_end_time     = $this->get_migration_script()->convertTimeFromAMPM(
+				$old_attendee['event_time']
+			);
+			$old_att_end_datetime = $this->get_migration_script()->convert_date_string_to_utc(
+				$this,
+				$old_attendee,
+				"$old_att_end_date $old_att_end_time:00"
+			);
+			$wpdb->insert(
+				$this->_new_datetime_table,
+				[
+					'EVT_ID'        => $new_event_id,
+					'DTT_EVT_start' => $old_att_start_datetime,
+					'DTT_EVT_end'   => $old_att_end_datetime,
+					'DTT_deleted'   => true,
+				],
+				[
+					'%d',// EVT_ID
+					'%s',// DTT_EVT_start
+					'%s',// DTT_EVT_end
+					'%d',// DTT_deleted
+				]
+			);
+			$datetime_id = $wpdb->insert_id;
+		}
+
+		// insert new ticket
+		$wpdb->insert(
+			$wpdb->prefix . 'esp_ticket',
+			[
+				'TKT_name'       => $old_att_price_option,
+				'TKT_qty'        => -1,
+				'TKT_price'      => $old_att_price,
+				'TKT_start_date' => $old_att_start_datetime,
+				// we really have no clue what the time should be, but at least it was available when they attended
+				'TKT_end_date'   => $old_att_end_datetime,
+
+			],
+			[
+				'%s',// name
+				'%d',// qty
+				'%d',// price
+				'%s',// start_date
+				'%s',// end_date
+			]
+		);
+		$ticket_id = $wpdb->insert_id;
+		// associate the ticket with the datetime we found earlier
+		$wpdb->insert(
+			$this->_new_datetime_ticket_table,
+			[
+				'DTT_ID' => $datetime_id,
+				'TKT_ID' => $ticket_id,
+			],
+			[
+				'%d',// DTT_ID
+				'%d',// TKT_ID
+			]
+		);
+		// insert new price
+		$wpdb->insert(
+			$this->_new_price_table,
+			[
+				'PRC_amount'  => $old_att_price,
+				'PRT_ID'      => EE_DMS_4_1_0_prices::price_type_base,
+				'PRC_name'    => $old_att_price_option,
+				'PRC_deleted' => true,
+			],
+			[
+				'%d',// PRC_amount
+				'%d',// PRT_ID
+				'%s',// PRC_name
+				'%d',// PRC_deleted
+			]
+		);
+		$price_id = $wpdb->insert_id;
+		// associate the price to the ticket
+		$wpdb->insert(
+			$this->_new_ticket_price_table,
+			[
+				'TKT_ID' => $ticket_id,
+				'PRC_ID' => $price_id,
+			],
+			[
+				'%d',// TKT_ID
+				'%d',// PRC_ID
+			]
+		);
+		return $ticket_id;
+	}
+
+
+	/**
+	 * Counts all the registrations on this transaction. If $count_only_older is TRUE then returns the number added SO
+	 * FAR (ie, only considers attendee rows with an ID less than this one's), but if $count_only_older is FALSe
+	 * returns ALL
+	 *
+	 * @param array   $old_attendee_row
+	 * @param boolean $count_only_older true if you want the running count (ie, the total up to this row), and false if
+	 *                                  you want ALL
+	 * @return int
+	 * @global wpdb   $wpdb
+	 */
+	private function _sum_old_attendees_on_old_txn(array $old_attendee_row, bool $count_only_older = false): int
+	{
+		global $wpdb;
+		$count_only_older_sql = $count_only_older ? $wpdb->prepare(" AND id<%d", $old_attendee_row['id']) : '';
+		$count                =
+			intval(
+				$wpdb->get_var(
+					$wpdb->prepare(
+						"SELECT SUM(quantity) FROM " .
+						$this->_old_table .
+						" WHERE registration_id=%s $count_only_older_sql",
+						$old_attendee_row['registration_id']
+					)
+				)
+			);
+
+		if ($this->_mer_tables_exist()) {
+			// if MER exists, then it's a little tricky.
+			// when users registered by adding items to the cart, and it was a
+			// group registration requiring additional attendee INFO, then the attendee rows
+			// DO NOT have the same registration_id (although they probably should have)
+			// they are related just like MER attendee rows are related, through the MER group table
+			// BUT we want to count all the MER attendee rows for the same registration
+			$primary_attendee =
+				$this->_find_mer_primary_attendee_using_mer_tables($old_attendee_row['registration_id']);
+
+			// No primary attendee to work with? Return the count.
+			if (is_null($primary_attendee)) {
+				return (int) $count;
+			}
+
+			$count_using_mer_table =
+				$wpdb->get_var(
+					$wpdb->prepare(
+						"SELECT SUM(quantity) FROM $this->_old_table att INNER JOIN $this->_old_mer_table mer ON att.registration_id = mer.registration_id WHERE att.event_id=%d AND mer.primary_registration_id = %s $count_only_older_sql",
+						$old_attendee_row['event_id'],
+						$primary_attendee['registration_id']
+					)
+				);
+			$count                 = max($count_using_mer_table, $count);
+		}
+		return (int) $count;
+	}
+
+
+	private function _insert_new_payment($old_attendee, $new_txn_id): int
+	{
+		global $wpdb;
+		// Only add a payment for primary attendees. Important note: partial payments were marked as "Pending".
+		// Also, an offline payment had blank status (ie, "").
+		$old_pay_stati_indicating_no_payment = ['', 'Incomplete', 'Not Completed'];
+		// if this is for a primary 3.1 attendee which WASN'T free and has a completed, cancelled, or declined payment...
+		if (
+			intval($old_attendee['is_primary']) &&
+			floatval($old_attendee['total_cost']) &&
+			! in_array($old_attendee['payment_status'], $old_pay_stati_indicating_no_payment)
+		) {
+			$pay_status_mapping = [
+				'Completed'        => 'PAP',
+				'Payment Declined' => 'PDC',
+				'Cancelled'        => 'PCN',
+				'Declined'         => 'PDC',
+			];
+
+			$by_admin = $old_attendee['payment'] == 'Admin';
+
+			// IE, if we don't recognize the status, assume payment failed
+			$STS_ID = $pay_status_mapping[ $old_attendee['payment_status'] ] ?? 'PFL';
+
+			$cols_n_values = [
+				'TXN_ID'               => $new_txn_id,
+				'STS_ID'               => $STS_ID,
+				'PAY_timestamp'        => $this->get_migration_script()->convert_date_string_to_utc(
+					$this,
+					$old_attendee,
+					$old_attendee['date']
+				),
+				'PAY_method'           => 'CART',
+				'PAY_amount'           => $old_attendee['amount_pd'],
+				// 'txn_type' was used both for the gateway's name, and for other payment notes.
+				'PAY_gateway'          => $old_attendee['txn_type'],
+				'PAY_extra_accntng'    => $old_attendee['txn_type'],
+				'PAY_gateway_response' => '',
+				'PAY_txn_id_chq_nmbr'  => substr($old_attendee['txn_id'], 0, 32),
+				'PAY_via_admin'        => $by_admin,
+				'PAY_details'          => $old_attendee['transaction_details'],
+			];
+			$data_types    = [
+				'%d',// TXN_Id
+				'%s',// STS_ID
+				'%s',// PAY_timestamp
+				'%s',// PAY_method
+				'%f',// PAY_amount
+				'%s',// PAY_gateway
+				'%s',// PAY_gateway_response
+				'%s',// PAY_txn_id_chq_nmbr
+				'%d',// PAY_via_admin
+				'%s',// PAY_details
+			];
+			$success       = $wpdb->insert($this->_new_payment_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_attendee_cpt_table,
+						$cols_n_values,
+						$data_types
+					)
+				);
+				return 0;
+			}
+			return $wpdb->insert_id;
+		}
+		return 0;
+	}
+
+
+	/**
+	 * If MER is active, if you want ot find the other registrations on that attendee row
+	 *
+	 * @param string   $old_registration_id
+	 * @return array|null
+	 * @global wpdb $wpdb
+	 */
+	private function _find_mer_primary_attendee_using_mer_tables(string $old_registration_id): ?array
+	{
+		if (! $this->_mer_tables_exist()) {
+			return null;
+		}
+		global $wpdb;
+		return $wpdb->get_row(
+			$wpdb->prepare(
+				"SELECT * FROM $this->_old_mer_table AS mer INNER JOIN $this->_old_table AS att ON mer.primary_registration_id = att.registration_id WHERE mer.registration_id=%s LIMIT 1",
+				$old_registration_id
+			),
+			ARRAY_A
+		);
+	}
 }

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

Indentation +76 added lines, -76 removed lines

@@ -7,86 +7,86 @@
  */
 class EE_DMS_4_1_0_category_details extends EE_Data_Migration_Script_Stage
 {
-    private string $_new_term_table;
+	private string $_new_term_table;
 
 
-    /**
-     * @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 $category_detail_row) {
-            $term_and_taxonomy_ids = wp_insert_term(
-                stripslashes($category_detail_row['category_name']),
-                'espresso_event_categories',
-                [
-                    'description' => stripslashes($category_detail_row['category_desc']),
-                    'slug'        => $category_detail_row['category_identifier'],
-                ]
-            );
-            if ($term_and_taxonomy_ids instanceof WP_Error) {
-                $this->add_error(
-                    sprintf(
-                        esc_html__(
-                            "Could not create WP Term_Taxonomy from old category: %s. The Error was: %s",
-                            "event_espresso"
-                        ),
-                        $this->_json_encode($category_detail_row),
-                        $term_and_taxonomy_ids->get_error_message()
-                    )
-                );
-                $items_actually_migrated++;
-                continue;
-            }
-            $term_id          = $term_and_taxonomy_ids['term_id'];
-            $term_taxonomy_id = $term_and_taxonomy_ids['term_taxonomy_id'];
-            $this->get_migration_script()->set_mapping(
-                $this->_old_table,
-                $category_detail_row['id'],
-                $this->_new_term_table,
-                $term_id
-            );
-            $this->get_migration_script()->set_mapping(
-                $this->_old_table,
-                $category_detail_row['id'],
-                $this->_new_table,
-                $term_taxonomy_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 $category_detail_row) {
+			$term_and_taxonomy_ids = wp_insert_term(
+				stripslashes($category_detail_row['category_name']),
+				'espresso_event_categories',
+				[
+					'description' => stripslashes($category_detail_row['category_desc']),
+					'slug'        => $category_detail_row['category_identifier'],
+				]
+			);
+			if ($term_and_taxonomy_ids instanceof WP_Error) {
+				$this->add_error(
+					sprintf(
+						esc_html__(
+							"Could not create WP Term_Taxonomy from old category: %s. The Error was: %s",
+							"event_espresso"
+						),
+						$this->_json_encode($category_detail_row),
+						$term_and_taxonomy_ids->get_error_message()
+					)
+				);
+				$items_actually_migrated++;
+				continue;
+			}
+			$term_id          = $term_and_taxonomy_ids['term_id'];
+			$term_taxonomy_id = $term_and_taxonomy_ids['term_taxonomy_id'];
+			$this->get_migration_script()->set_mapping(
+				$this->_old_table,
+				$category_detail_row['id'],
+				$this->_new_term_table,
+				$term_id
+			);
+			$this->get_migration_script()->set_mapping(
+				$this->_old_table,
+				$category_detail_row['id'],
+				$this->_new_table,
+				$term_taxonomy_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()
-    {
-        $this->_pretty_name = esc_html__("Category Details", "event_espresso");
-        global $wpdb;
-        $this->_old_table      = $wpdb->prefix . "events_category_detail";
-        $this->_new_table      = $wpdb->prefix . "term_taxonomy";
-        $this->_new_term_table = $wpdb->prefix . "terms";
-        parent::__construct();
-    }
+	public function __construct()
+	{
+		$this->_pretty_name = esc_html__("Category Details", "event_espresso");
+		global $wpdb;
+		$this->_old_table      = $wpdb->prefix . "events_category_detail";
+		$this->_new_table      = $wpdb->prefix . "term_taxonomy";
+		$this->_new_term_table = $wpdb->prefix . "terms";
+		parent::__construct();
+	}
 }

core/data_migration_scripts/4_5_0_stages/EE_DMS_4_5_0_update_wp_user_for_question_groups.dmsstage.php

Indentation +42 added lines, -42 removed lines

@@ -10,48 +10,48 @@
  */
 class EE_DMS_4_5_0_update_wp_user_for_question_groups extends EE_Data_Migration_Script_Stage_Table
 {
-    public function __construct()
-    {
-        global $wpdb;
-        $this->_pretty_name = esc_html__("Question Groups", "event_espresso");
-        $this->_old_table   = $wpdb->prefix . "esp_question_group";
-        parent::__construct();
-    }
+	public function __construct()
+	{
+		global $wpdb;
+		$this->_pretty_name = esc_html__("Question Groups", "event_espresso");
+		$this->_old_table   = $wpdb->prefix . "esp_question_group";
+		parent::__construct();
+	}
 
 
-    /**
-     * @throws ReflectionException
-     * @throws EE_Error
-     */
-    protected function _migrate_old_row($old_row)
-    {
-        // foreach ticket row we add the id for the current logged in user.
-        global $wpdb;
-        $user_id = EEH_Activation::get_default_creator_id();
-        $user_id = $user_id ?: 0;
-        $updated = $wpdb->update(
-            $this->_old_table,
-            ['QSG_wp_user' => $user_id],
-            ['QSG_ID' => $old_row['QSG_ID']],
-            [
-                '%d',// QSG_wp_user
-            ],
-            [
-                '%d',// QSG_ID
-            ]
-        );
-        if (false === $updated) {
-            $this->add_error(
-                sprintf(
-                    esc_html__(
-                        "Error in updating table %s setting QSG_wp_user = %d where QSG_ID = %d",
-                        'event_espresso'
-                    ),
-                    $this->_old_table,
-                    $user_id,
-                    $old_row['QSG_ID']
-                )
-            );
-        }
-    }
+	/**
+	 * @throws ReflectionException
+	 * @throws EE_Error
+	 */
+	protected function _migrate_old_row($old_row)
+	{
+		// foreach ticket row we add the id for the current logged in user.
+		global $wpdb;
+		$user_id = EEH_Activation::get_default_creator_id();
+		$user_id = $user_id ?: 0;
+		$updated = $wpdb->update(
+			$this->_old_table,
+			['QSG_wp_user' => $user_id],
+			['QSG_ID' => $old_row['QSG_ID']],
+			[
+				'%d',// QSG_wp_user
+			],
+			[
+				'%d',// QSG_ID
+			]
+		);
+		if (false === $updated) {
+			$this->add_error(
+				sprintf(
+					esc_html__(
+						"Error in updating table %s setting QSG_wp_user = %d where QSG_ID = %d",
+						'event_espresso'
+					),
+					$this->_old_table,
+					$user_id,
+					$old_row['QSG_ID']
+				)
+			);
+		}
+	}
 }