@@ -1,6 +1,6 @@ discard block |
||
| 1 | 1 | <?php |
| 2 | 2 | |
| 3 | -if (!defined('EVENT_ESPRESSO_VERSION')) { |
|
| 3 | +if ( ! defined('EVENT_ESPRESSO_VERSION')) { |
|
| 4 | 4 | exit('No direct script access allowed'); |
| 5 | 5 | } |
| 6 | 6 | |
@@ -13,7 +13,7 @@ discard block |
||
| 13 | 13 | * @author Brent Christensen |
| 14 | 14 | * |
| 15 | 15 | */ |
| 16 | -class EE_DMS_4_6_0_state_system_question extends EE_Data_Migration_Script_Stage_Table{ |
|
| 16 | +class EE_DMS_4_6_0_state_system_question extends EE_Data_Migration_Script_Stage_Table { |
|
| 17 | 17 | |
| 18 | 18 | |
| 19 | 19 | |
@@ -24,7 +24,7 @@ discard block |
||
| 24 | 24 | */ |
| 25 | 25 | public function __construct() { |
| 26 | 26 | global $wpdb; |
| 27 | - $this->_pretty_name = __( 'State - System Question', 'event_espresso' ); |
|
| 27 | + $this->_pretty_name = __('State - System Question', 'event_espresso'); |
|
| 28 | 28 | $this->_old_table = $wpdb->prefix.'esp_question'; |
| 29 | 29 | $this->_extra_where_sql = "WHERE QST_system = 'state'"; |
| 30 | 30 | parent::__construct(); |
@@ -37,21 +37,21 @@ discard block |
||
| 37 | 37 | * @param array $question an associative array where keys are column names and values are their values. |
| 38 | 38 | * @return null |
| 39 | 39 | */ |
| 40 | - protected function _migrate_old_row( $question ) { |
|
| 41 | - if ( $question['QST_ID'] && $question['QST_system'] == 'state' ) { |
|
| 40 | + protected function _migrate_old_row($question) { |
|
| 41 | + if ($question['QST_ID'] && $question['QST_system'] == 'state') { |
|
| 42 | 42 | global $wpdb; |
| 43 | 43 | $success = $wpdb->update( |
| 44 | 44 | $this->_old_table, |
| 45 | - array( 'QST_type' => 'STATE' ), // data |
|
| 46 | - array( 'QST_ID' => $question['QST_ID'] ), // where |
|
| 47 | - array( '%s' ), // data format |
|
| 48 | - array( '%d' ) // where format |
|
| 45 | + array('QST_type' => 'STATE'), // data |
|
| 46 | + array('QST_ID' => $question['QST_ID']), // where |
|
| 47 | + array('%s'), // data format |
|
| 48 | + array('%d') // where format |
|
| 49 | 49 | ); |
| 50 | - if ( ! $success ) { |
|
| 50 | + if ( ! $success) { |
|
| 51 | 51 | $this->add_error( |
| 52 | 52 | sprintf( |
| 53 | - __( 'Could not update question system name "%1$s" for question ID=%2$d because "%3$s"', 'event_espresso' ), |
|
| 54 | - json_encode( $question['QST_system'] ), |
|
| 53 | + __('Could not update question system name "%1$s" for question ID=%2$d because "%3$s"', 'event_espresso'), |
|
| 54 | + json_encode($question['QST_system']), |
|
| 55 | 55 | $question['QST_ID'], |
| 56 | 56 | $wpdb->last_error |
| 57 | 57 | ) |
@@ -1,6 +1,6 @@ discard block |
||
| 1 | 1 | <?php |
| 2 | -if ( !defined( 'EVENT_ESPRESSO_VERSION' ) ) { |
|
| 3 | - exit( 'No direct script access allowed' ); |
|
| 2 | +if ( ! defined('EVENT_ESPRESSO_VERSION')) { |
|
| 3 | + exit('No direct script access allowed'); |
|
| 4 | 4 | } |
| 5 | 5 | |
| 6 | 6 | /** |
@@ -12,20 +12,20 @@ discard block |
||
| 12 | 12 | * @author Brent Christensen |
| 13 | 13 | * |
| 14 | 14 | */ |
| 15 | -class EE_DMS_4_7_0_Add_Taxes_To_REG_Final_Price extends EE_Data_Migration_Script_Stage_Table{ |
|
| 15 | +class EE_DMS_4_7_0_Add_Taxes_To_REG_Final_Price extends EE_Data_Migration_Script_Stage_Table { |
|
| 16 | 16 | |
| 17 | 17 | protected $_ticket_table; |
| 18 | 18 | |
| 19 | 19 | protected $_line_item_table; |
| 20 | 20 | |
| 21 | - function __construct(){ |
|
| 21 | + function __construct() { |
|
| 22 | 22 | /** @type WPDB $wpdb */ |
| 23 | 23 | global $wpdb; |
| 24 | - $this->_pretty_name = __( 'Registration Final Price Tax Calculations', 'event_espresso' ); |
|
| 24 | + $this->_pretty_name = __('Registration Final Price Tax Calculations', 'event_espresso'); |
|
| 25 | 25 | // define tables |
| 26 | - $this->_old_table = $wpdb->prefix . 'esp_registration'; |
|
| 27 | - $this->_ticket_table = $wpdb->prefix . 'esp_ticket'; |
|
| 28 | - $this->_line_item_table = $wpdb->prefix . 'esp_line_item'; |
|
| 26 | + $this->_old_table = $wpdb->prefix.'esp_registration'; |
|
| 27 | + $this->_ticket_table = $wpdb->prefix.'esp_ticket'; |
|
| 28 | + $this->_line_item_table = $wpdb->prefix.'esp_line_item'; |
|
| 29 | 29 | parent::__construct(); |
| 30 | 30 | } |
| 31 | 31 | |
@@ -55,7 +55,7 @@ discard block |
||
| 55 | 55 | global $wpdb; |
| 56 | 56 | $SQL = "SELECT count( reg.REG_ID ) "; |
| 57 | 57 | $SQL .= $this->_get_rest_of_sql_for_query(); |
| 58 | - $count = $wpdb->get_var( $SQL ); |
|
| 58 | + $count = $wpdb->get_var($SQL); |
|
| 59 | 59 | return $count; |
| 60 | 60 | } |
| 61 | 61 | |
@@ -67,13 +67,13 @@ discard block |
||
| 67 | 67 | * @param int $limit |
| 68 | 68 | * @return array of arrays like $wpdb->get_results($sql, ARRAY_A) |
| 69 | 69 | */ |
| 70 | - protected function _get_rows( $limit ) { |
|
| 70 | + protected function _get_rows($limit) { |
|
| 71 | 71 | /** @type WPDB $wpdb */ |
| 72 | 72 | global $wpdb; |
| 73 | 73 | $start_at_record = $this->count_records_migrated(); |
| 74 | 74 | $SQL = "SELECT reg.REG_ID, reg.REG_final_price, line.LIN_ID "; |
| 75 | 75 | $SQL .= $this->_get_rest_of_sql_for_query(); |
| 76 | - $SQL .= $wpdb->prepare( "LIMIT %d, %d", $start_at_record, $limit ); |
|
| 76 | + $SQL .= $wpdb->prepare("LIMIT %d, %d", $start_at_record, $limit); |
|
| 77 | 77 | |
| 78 | 78 | // produces something like: |
| 79 | 79 | /* |
@@ -93,7 +93,7 @@ discard block |
||
| 93 | 93 | LIMIT 1, 50 |
| 94 | 94 | */ |
| 95 | 95 | |
| 96 | - return $wpdb->get_results( $SQL, ARRAY_A ); |
|
| 96 | + return $wpdb->get_results($SQL, ARRAY_A); |
|
| 97 | 97 | } |
| 98 | 98 | |
| 99 | 99 | |
@@ -102,38 +102,38 @@ discard block |
||
| 102 | 102 | * @param array $row |
| 103 | 103 | * @return void |
| 104 | 104 | */ |
| 105 | - protected function _migrate_old_row( $row ) { |
|
| 105 | + protected function _migrate_old_row($row) { |
|
| 106 | 106 | /** @type WPDB $wpdb */ |
| 107 | 107 | global $wpdb; |
| 108 | 108 | // ensure all required values are present |
| 109 | - if ( ! isset( $row[ 'REG_ID' ], $row[ 'REG_final_price' ], $row[ 'LIN_ID' ] )) { |
|
| 109 | + if ( ! isset($row['REG_ID'], $row['REG_final_price'], $row['LIN_ID'])) { |
|
| 110 | 110 | $this->add_error( |
| 111 | 111 | sprintf( |
| 112 | - __( 'Invalid query results returned with the following data:%1$s REG_ID=%2$d, REG_final_price=%3$d, LIN_ID=%4$f. Error: "%5$s"', 'event_espresso' ), |
|
| 112 | + __('Invalid query results returned with the following data:%1$s REG_ID=%2$d, REG_final_price=%3$d, LIN_ID=%4$f. Error: "%5$s"', 'event_espresso'), |
|
| 113 | 113 | '<br />', |
| 114 | - isset( $row[ 'REG_ID' ] ) ? $row[ 'REG_ID' ] : '', |
|
| 115 | - isset( $row[ 'REG_final_price' ] ) ? $row[ 'REG_final_price' ] : '', |
|
| 116 | - isset( $row[ 'LIN_ID' ] ) ? $row[ 'LIN_ID' ] : '', |
|
| 114 | + isset($row['REG_ID']) ? $row['REG_ID'] : '', |
|
| 115 | + isset($row['REG_final_price']) ? $row['REG_final_price'] : '', |
|
| 116 | + isset($row['LIN_ID']) ? $row['LIN_ID'] : '', |
|
| 117 | 117 | $wpdb->last_error |
| 118 | 118 | ) |
| 119 | 119 | ); |
| 120 | 120 | return; |
| 121 | 121 | } |
| 122 | 122 | // get tax subtotal |
| 123 | - $tax_subtotal_line_item_ID = $this->_get_line_item_ID_for_tax_subtotal( $row['LIN_ID'] ); |
|
| 124 | - if ( ! $tax_subtotal_line_item_ID ) { |
|
| 123 | + $tax_subtotal_line_item_ID = $this->_get_line_item_ID_for_tax_subtotal($row['LIN_ID']); |
|
| 124 | + if ( ! $tax_subtotal_line_item_ID) { |
|
| 125 | 125 | $this->add_error( |
| 126 | 126 | sprintf( |
| 127 | - __( 'Invalid line item ID returned. Error: "%1$s"', 'event_espresso' ), |
|
| 127 | + __('Invalid line item ID returned. Error: "%1$s"', 'event_espresso'), |
|
| 128 | 128 | $wpdb->last_error |
| 129 | 129 | ) |
| 130 | 130 | ); |
| 131 | 131 | return; |
| 132 | 132 | } |
| 133 | 133 | // now get taxes |
| 134 | - $taxes = $this->_get_tax_amounts( $tax_subtotal_line_item_ID ); |
|
| 134 | + $taxes = $this->_get_tax_amounts($tax_subtotal_line_item_ID); |
|
| 135 | 135 | // apply taxes to registration final price |
| 136 | - $this->_apply_taxes( $row[ 'REG_ID' ], $row[ 'REG_final_price' ], $taxes ); |
|
| 136 | + $this->_apply_taxes($row['REG_ID'], $row['REG_final_price'], $taxes); |
|
| 137 | 137 | |
| 138 | 138 | } |
| 139 | 139 | |
@@ -145,14 +145,14 @@ discard block |
||
| 145 | 145 | * @param int $LIN_ID |
| 146 | 146 | * @return int |
| 147 | 147 | */ |
| 148 | - protected function _get_line_item_ID_for_tax_subtotal( $LIN_ID ) { |
|
| 148 | + protected function _get_line_item_ID_for_tax_subtotal($LIN_ID) { |
|
| 149 | 149 | /** @type WPDB $wpdb */ |
| 150 | 150 | global $wpdb; |
| 151 | 151 | $SQL = "SELECT LIN_ID "; |
| 152 | 152 | $SQL .= "FROM {$this->_line_item_table} "; |
| 153 | 153 | $SQL .= "WHERE LIN_parent = %d "; |
| 154 | 154 | $SQL .= "AND LIN_code = 'taxes'"; |
| 155 | - return $wpdb->get_var( $wpdb->prepare( $SQL, $LIN_ID ) ); |
|
| 155 | + return $wpdb->get_var($wpdb->prepare($SQL, $LIN_ID)); |
|
| 156 | 156 | } |
| 157 | 157 | |
| 158 | 158 | |
@@ -163,13 +163,13 @@ discard block |
||
| 163 | 163 | * @param int $LIN_ID |
| 164 | 164 | * @return array |
| 165 | 165 | */ |
| 166 | - protected function _get_tax_amounts( $LIN_ID ) { |
|
| 166 | + protected function _get_tax_amounts($LIN_ID) { |
|
| 167 | 167 | /** @type WPDB $wpdb */ |
| 168 | 168 | global $wpdb; |
| 169 | 169 | $SQL = "SELECT LIN_percent "; |
| 170 | 170 | $SQL .= "FROM {$this->_line_item_table} "; |
| 171 | 171 | $SQL .= "WHERE LIN_parent = %d"; |
| 172 | - return $wpdb->get_results( $wpdb->prepare( $SQL, $LIN_ID ), OBJECT_K ); |
|
| 172 | + return $wpdb->get_results($wpdb->prepare($SQL, $LIN_ID), OBJECT_K); |
|
| 173 | 173 | } |
| 174 | 174 | |
| 175 | 175 | |
@@ -182,14 +182,14 @@ discard block |
||
| 182 | 182 | * @param array $taxes |
| 183 | 183 | * @return void |
| 184 | 184 | */ |
| 185 | - protected function _apply_taxes( $REG_ID = 0, $final_price = 0.00, $taxes = array() ) { |
|
| 186 | - if ( is_array( $taxes ) && ! empty( $taxes ) ) { |
|
| 185 | + protected function _apply_taxes($REG_ID = 0, $final_price = 0.00, $taxes = array()) { |
|
| 186 | + if (is_array($taxes) && ! empty($taxes)) { |
|
| 187 | 187 | $total_taxes = 0; |
| 188 | - foreach ( $taxes as $tax ) { |
|
| 189 | - $total_taxes += $final_price * ( $tax->LIN_percent / 100 ); |
|
| 188 | + foreach ($taxes as $tax) { |
|
| 189 | + $total_taxes += $final_price * ($tax->LIN_percent / 100); |
|
| 190 | 190 | } |
| 191 | 191 | $final_price += $total_taxes; |
| 192 | - $this->_update_registration_final_price( $REG_ID, $final_price ); |
|
| 192 | + $this->_update_registration_final_price($REG_ID, $final_price); |
|
| 193 | 193 | } |
| 194 | 194 | } |
| 195 | 195 | |
@@ -202,20 +202,20 @@ discard block |
||
| 202 | 202 | * @param float $REG_final_price |
| 203 | 203 | * @return void |
| 204 | 204 | */ |
| 205 | - protected function _update_registration_final_price( $REG_ID = 0, $REG_final_price = 0.00 ) { |
|
| 205 | + protected function _update_registration_final_price($REG_ID = 0, $REG_final_price = 0.00) { |
|
| 206 | 206 | /** @type WPDB $wpdb */ |
| 207 | 207 | global $wpdb; |
| 208 | 208 | $success = $wpdb->update( |
| 209 | 209 | $this->_old_table, |
| 210 | - array( 'REG_final_price' => $REG_final_price ), // data |
|
| 211 | - array( 'REG_ID' => $REG_ID ), // where |
|
| 212 | - array( '%f' ), // data format |
|
| 213 | - array( '%d' ) // where format |
|
| 210 | + array('REG_final_price' => $REG_final_price), // data |
|
| 211 | + array('REG_ID' => $REG_ID), // where |
|
| 212 | + array('%f'), // data format |
|
| 213 | + array('%d') // where format |
|
| 214 | 214 | ); |
| 215 | - if ( $success === false ) { |
|
| 215 | + if ($success === false) { |
|
| 216 | 216 | $this->add_error( |
| 217 | 217 | sprintf( |
| 218 | - __( 'Could not update registration final price value for registration ID=%1$d because "%2$s"', 'event_espresso' ), |
|
| 218 | + __('Could not update registration final price value for registration ID=%1$d because "%2$s"', 'event_espresso'), |
|
| 219 | 219 | $REG_ID, |
| 220 | 220 | $wpdb->last_error |
| 221 | 221 | ) |
@@ -1,6 +1,6 @@ discard block |
||
| 1 | 1 | <?php |
| 2 | -if ( !defined( 'EVENT_ESPRESSO_VERSION' ) ) { |
|
| 3 | - exit( 'No direct script access allowed' ); |
|
| 2 | +if ( ! defined('EVENT_ESPRESSO_VERSION')) { |
|
| 3 | + exit('No direct script access allowed'); |
|
| 4 | 4 | } |
| 5 | 5 | |
| 6 | 6 | /** |
@@ -12,7 +12,7 @@ discard block |
||
| 12 | 12 | * @author Brent Christensen |
| 13 | 13 | * |
| 14 | 14 | */ |
| 15 | -class EE_DMS_4_7_0_Registration_Payments extends EE_Data_Migration_Script_Stage_Table{ |
|
| 15 | +class EE_DMS_4_7_0_Registration_Payments extends EE_Data_Migration_Script_Stage_Table { |
|
| 16 | 16 | |
| 17 | 17 | protected $_payment_table; |
| 18 | 18 | |
@@ -20,15 +20,15 @@ discard block |
||
| 20 | 20 | |
| 21 | 21 | protected $_registration_payment_table; |
| 22 | 22 | |
| 23 | - function __construct(){ |
|
| 23 | + function __construct() { |
|
| 24 | 24 | /** @type WPDB $wpdb */ |
| 25 | 25 | global $wpdb; |
| 26 | - $this->_pretty_name = __( 'Registration Payment Record Generation', 'event_espresso' ); |
|
| 26 | + $this->_pretty_name = __('Registration Payment Record Generation', 'event_espresso'); |
|
| 27 | 27 | // define tables |
| 28 | - $this->_old_table = $wpdb->prefix . 'esp_transaction'; |
|
| 29 | - $this->_payment_table = $wpdb->prefix . 'esp_payment'; |
|
| 30 | - $this->_registration_table = $wpdb->prefix . 'esp_registration'; |
|
| 31 | - $this->_registration_payment_table = $wpdb->prefix . 'esp_registration_payment'; |
|
| 28 | + $this->_old_table = $wpdb->prefix.'esp_transaction'; |
|
| 29 | + $this->_payment_table = $wpdb->prefix.'esp_payment'; |
|
| 30 | + $this->_registration_table = $wpdb->prefix.'esp_registration'; |
|
| 31 | + $this->_registration_payment_table = $wpdb->prefix.'esp_registration_payment'; |
|
| 32 | 32 | // build SQL WHERE clauses |
| 33 | 33 | $this->_extra_where_sql = "WHERE STS_ID IN ( 'TIN', 'TCM' ) AND TXN_Total != '0.000'"; |
| 34 | 34 | parent::__construct(); |
@@ -40,14 +40,14 @@ discard block |
||
| 40 | 40 | * @param array $transaction |
| 41 | 41 | * @return void |
| 42 | 42 | */ |
| 43 | - protected function _migrate_old_row( $transaction ) { |
|
| 43 | + protected function _migrate_old_row($transaction) { |
|
| 44 | 44 | /** @type WPDB $wpdb */ |
| 45 | 45 | global $wpdb; |
| 46 | - $TXN_ID = absint( $transaction[ 'TXN_ID' ] ); |
|
| 47 | - if ( ! $TXN_ID ) { |
|
| 46 | + $TXN_ID = absint($transaction['TXN_ID']); |
|
| 47 | + if ( ! $TXN_ID) { |
|
| 48 | 48 | $this->add_error( |
| 49 | 49 | sprintf( |
| 50 | - __( 'Invalid transaction with ID=%1$d. Error: "%2$s"', 'event_espresso' ), |
|
| 50 | + __('Invalid transaction with ID=%1$d. Error: "%2$s"', 'event_espresso'), |
|
| 51 | 51 | $TXN_ID, |
| 52 | 52 | $wpdb->last_error |
| 53 | 53 | ) |
@@ -55,19 +55,19 @@ discard block |
||
| 55 | 55 | return; |
| 56 | 56 | } |
| 57 | 57 | // get all payments for the TXN |
| 58 | - $payments = $this->_get_payments( $TXN_ID ); |
|
| 59 | - if ( empty( $payments ) ) { |
|
| 58 | + $payments = $this->_get_payments($TXN_ID); |
|
| 59 | + if (empty($payments)) { |
|
| 60 | 60 | return; |
| 61 | 61 | } |
| 62 | 62 | // then the registrants |
| 63 | - $registrations = $this->_get_registrations( $TXN_ID ); |
|
| 64 | - if ( empty( $registrations ) ) { |
|
| 63 | + $registrations = $this->_get_registrations($TXN_ID); |
|
| 64 | + if (empty($registrations)) { |
|
| 65 | 65 | return; |
| 66 | 66 | } |
| 67 | 67 | // now loop thru each payment and apply it to each of the registrations |
| 68 | - foreach ( $payments as $PAY_ID => $payment ) { |
|
| 69 | - if ( $payment->STS_ID === 'PAP' && $payment->PAY_amount > 0 ) { |
|
| 70 | - $this->_process_registration_payments( $payment, $registrations ); |
|
| 68 | + foreach ($payments as $PAY_ID => $payment) { |
|
| 69 | + if ($payment->STS_ID === 'PAP' && $payment->PAY_amount > 0) { |
|
| 70 | + $this->_process_registration_payments($payment, $registrations); |
|
| 71 | 71 | } |
| 72 | 72 | } |
| 73 | 73 | } |
@@ -80,11 +80,11 @@ discard block |
||
| 80 | 80 | * @param int $TXN_ID |
| 81 | 81 | * @return array |
| 82 | 82 | */ |
| 83 | - protected function _get_registrations( $TXN_ID ) { |
|
| 83 | + protected function _get_registrations($TXN_ID) { |
|
| 84 | 84 | /** @type WPDB $wpdb */ |
| 85 | 85 | global $wpdb; |
| 86 | 86 | $SQL = "SELECT * FROM {$this->_registration_table} WHERE TXN_ID = %d AND STS_ID IN ( 'RPP', 'RAP' )"; |
| 87 | - return $wpdb->get_results( $wpdb->prepare( $SQL, $TXN_ID ), OBJECT_K ); |
|
| 87 | + return $wpdb->get_results($wpdb->prepare($SQL, $TXN_ID), OBJECT_K); |
|
| 88 | 88 | } |
| 89 | 89 | |
| 90 | 90 | |
@@ -95,10 +95,10 @@ discard block |
||
| 95 | 95 | * @param int $TXN_ID |
| 96 | 96 | * @return array |
| 97 | 97 | */ |
| 98 | - protected function _get_payments( $TXN_ID ) { |
|
| 98 | + protected function _get_payments($TXN_ID) { |
|
| 99 | 99 | /** @type WPDB $wpdb */ |
| 100 | 100 | global $wpdb; |
| 101 | - return $wpdb->get_results( $wpdb->prepare( "SELECT * FROM {$this->_payment_table} WHERE TXN_ID = %d", $TXN_ID ), OBJECT_K ); |
|
| 101 | + return $wpdb->get_results($wpdb->prepare("SELECT * FROM {$this->_payment_table} WHERE TXN_ID = %d", $TXN_ID), OBJECT_K); |
|
| 102 | 102 | } |
| 103 | 103 | |
| 104 | 104 | |
@@ -109,10 +109,10 @@ discard block |
||
| 109 | 109 | * @param int $REG_ID |
| 110 | 110 | * @return array |
| 111 | 111 | */ |
| 112 | - protected function _get_possibly_updated_REG_paid( $REG_ID ) { |
|
| 112 | + protected function _get_possibly_updated_REG_paid($REG_ID) { |
|
| 113 | 113 | /** @type WPDB $wpdb */ |
| 114 | 114 | global $wpdb; |
| 115 | - return $wpdb->get_var( $wpdb->prepare( "SELECT REG_paid FROM {$this->_registration_table} WHERE REG_ID = %d", $REG_ID ) ); |
|
| 115 | + return $wpdb->get_var($wpdb->prepare("SELECT REG_paid FROM {$this->_registration_table} WHERE REG_ID = %d", $REG_ID)); |
|
| 116 | 116 | } |
| 117 | 117 | |
| 118 | 118 | |
@@ -127,40 +127,40 @@ discard block |
||
| 127 | 127 | * @param array $registrations |
| 128 | 128 | * @return bool |
| 129 | 129 | */ |
| 130 | - protected function _process_registration_payments( $payment, $registrations = array() ){ |
|
| 130 | + protected function _process_registration_payments($payment, $registrations = array()) { |
|
| 131 | 131 | // how much is available to apply to registrations? |
| 132 | 132 | $available_payment_amount = $payment->PAY_amount; |
| 133 | - foreach ( $registrations as $REG_ID => $registration ) { |
|
| 133 | + foreach ($registrations as $REG_ID => $registration) { |
|
| 134 | 134 | // nothing left, then we are done here? |
| 135 | - if ( ! $available_payment_amount > 0 ) { |
|
| 135 | + if ( ! $available_payment_amount > 0) { |
|
| 136 | 136 | break; |
| 137 | 137 | } |
| 138 | 138 | // ensure REG_final_price has a valid value, and skip if it turns out to be zero |
| 139 | - $registration->REG_final_price = ! empty( $registration->REG_final_price ) ? (float)$registration->REG_final_price : 0.00; |
|
| 140 | - if ( ! $registration->REG_final_price > 0 ) { |
|
| 139 | + $registration->REG_final_price = ! empty($registration->REG_final_price) ? (float) $registration->REG_final_price : 0.00; |
|
| 140 | + if ( ! $registration->REG_final_price > 0) { |
|
| 141 | 141 | continue; |
| 142 | 142 | } |
| 143 | 143 | // because REG_paid may have been updated by a previous payment, we need to retrieve the value from the db |
| 144 | - $possibly_updated_REG_paid = $this->_get_possibly_updated_REG_paid( $REG_ID ); |
|
| 145 | - if ( is_float( $possibly_updated_REG_paid ) ) { |
|
| 144 | + $possibly_updated_REG_paid = $this->_get_possibly_updated_REG_paid($REG_ID); |
|
| 145 | + if (is_float($possibly_updated_REG_paid)) { |
|
| 146 | 146 | $registration->REG_paid = $possibly_updated_REG_paid; |
| 147 | 147 | } |
| 148 | 148 | // and ensure REG_paid has a valid value |
| 149 | - $registration->REG_paid = ! empty( $registration->REG_paid ) ? (float)$registration->REG_paid : 0.00; |
|
| 149 | + $registration->REG_paid = ! empty($registration->REG_paid) ? (float) $registration->REG_paid : 0.00; |
|
| 150 | 150 | // calculate amount owing, and skip if it turns out to be zero |
| 151 | 151 | $owing = $registration->REG_final_price - $registration->REG_paid; |
| 152 | - if ( ! $owing > 0 ) { |
|
| 152 | + if ( ! $owing > 0) { |
|
| 153 | 153 | continue; |
| 154 | 154 | } |
| 155 | 155 | // don't allow payment amount to exceed the available payment amount, OR the amount owing |
| 156 | - $payment_amount = min( $available_payment_amount, $owing ); |
|
| 156 | + $payment_amount = min($available_payment_amount, $owing); |
|
| 157 | 157 | // update $available_payment_amount |
| 158 | 158 | $available_payment_amount = $available_payment_amount - $payment_amount; |
| 159 | 159 | // add relation between registration and payment and set amount |
| 160 | - if ( $this->_insert_registration_payment( $registration->REG_ID, $payment->PAY_ID, $payment_amount )) { |
|
| 160 | + if ($this->_insert_registration_payment($registration->REG_ID, $payment->PAY_ID, $payment_amount)) { |
|
| 161 | 161 | //calculate and set new REG_paid |
| 162 | 162 | $registration->REG_paid = $registration->REG_paid + $payment_amount; |
| 163 | - $this->_update_registration_paid( $registration->REG_ID, $registration->REG_paid ); |
|
| 163 | + $this->_update_registration_paid($registration->REG_ID, $registration->REG_paid); |
|
| 164 | 164 | } |
| 165 | 165 | } |
| 166 | 166 | } |
@@ -175,18 +175,18 @@ discard block |
||
| 175 | 175 | * @param float $PAY_amount |
| 176 | 176 | * @return bool |
| 177 | 177 | */ |
| 178 | - protected function _insert_registration_payment( $REG_ID = 0, $PAY_ID = 0, $PAY_amount = 0.00 ){ |
|
| 178 | + protected function _insert_registration_payment($REG_ID = 0, $PAY_ID = 0, $PAY_amount = 0.00) { |
|
| 179 | 179 | /** @type WPDB $wpdb */ |
| 180 | 180 | global $wpdb; |
| 181 | 181 | $success = $wpdb->insert( |
| 182 | 182 | $this->_registration_payment_table, |
| 183 | - array( 'REG_ID' => $REG_ID, 'PAY_ID' => $PAY_ID, 'RPY_amount' => $PAY_amount, ), // data |
|
| 184 | - array( '%f' ) // data format |
|
| 183 | + array('REG_ID' => $REG_ID, 'PAY_ID' => $PAY_ID, 'RPY_amount' => $PAY_amount,), // data |
|
| 184 | + array('%f') // data format |
|
| 185 | 185 | ); |
| 186 | - if ( $success === false ) { |
|
| 186 | + if ($success === false) { |
|
| 187 | 187 | $this->add_error( |
| 188 | 188 | sprintf( |
| 189 | - __( 'Could not update registration paid value for registration ID=%1$d because "%2$s"', 'event_espresso' ), |
|
| 189 | + __('Could not update registration paid value for registration ID=%1$d because "%2$s"', 'event_espresso'), |
|
| 190 | 190 | $REG_ID, |
| 191 | 191 | $wpdb->last_error |
| 192 | 192 | ) |
@@ -205,20 +205,20 @@ discard block |
||
| 205 | 205 | * @param float $REG_paid |
| 206 | 206 | * @return bool |
| 207 | 207 | */ |
| 208 | - protected function _update_registration_paid( $REG_ID = 0, $REG_paid = 0.00 ) { |
|
| 208 | + protected function _update_registration_paid($REG_ID = 0, $REG_paid = 0.00) { |
|
| 209 | 209 | /** @type WPDB $wpdb */ |
| 210 | 210 | global $wpdb; |
| 211 | 211 | $success = $wpdb->update( |
| 212 | 212 | $this->_registration_table, |
| 213 | - array( 'REG_paid' => $REG_paid ), // data |
|
| 214 | - array( 'REG_ID' => $REG_ID ), // where |
|
| 215 | - array( '%f' ), // data format |
|
| 216 | - array( '%d' ) // where format |
|
| 213 | + array('REG_paid' => $REG_paid), // data |
|
| 214 | + array('REG_ID' => $REG_ID), // where |
|
| 215 | + array('%f'), // data format |
|
| 216 | + array('%d') // where format |
|
| 217 | 217 | ); |
| 218 | - if ( $success === false ) { |
|
| 218 | + if ($success === false) { |
|
| 219 | 219 | $this->add_error( |
| 220 | 220 | sprintf( |
| 221 | - __( 'Could not update registration paid value for registration ID=%1$d because "%2$s"', 'event_espresso' ), |
|
| 221 | + __('Could not update registration paid value for registration ID=%1$d because "%2$s"', 'event_espresso'), |
|
| 222 | 222 | $REG_ID, |
| 223 | 223 | $wpdb->last_error |
| 224 | 224 | ) |
@@ -26,7 +26,7 @@ |
||
| 26 | 26 | * just checks the field isn't blank |
| 27 | 27 | * |
| 28 | 28 | * @param $normalized_value |
| 29 | - * @return bool |
|
| 29 | + * @return boolean|null |
|
| 30 | 30 | * @throws \EE_Validation_Error |
| 31 | 31 | */ |
| 32 | 32 | function validate($normalized_value) { |
@@ -1,5 +1,5 @@ discard block |
||
| 1 | 1 | <?php |
| 2 | -if (!defined('EVENT_ESPRESSO_VERSION')) { |
|
| 2 | +if ( ! defined('EVENT_ESPRESSO_VERSION')) { |
|
| 3 | 3 | exit('No direct script access allowed'); |
| 4 | 4 | } |
| 5 | 5 | |
@@ -13,7 +13,7 @@ discard block |
||
| 13 | 13 | * |
| 14 | 14 | * Migrates line items that used to have LIN_code="tickets" to "pre-tax-total" |
| 15 | 15 | */ |
| 16 | -class EE_DMS_4_8_0_pretax_totals extends EE_Data_Migration_Script_Stage{ |
|
| 16 | +class EE_DMS_4_8_0_pretax_totals extends EE_Data_Migration_Script_Stage { |
|
| 17 | 17 | |
| 18 | 18 | protected $_line_item_table_name; |
| 19 | 19 | |
@@ -53,10 +53,10 @@ discard block |
||
| 53 | 53 | global $wpdb; |
| 54 | 54 | $rows_updated = $wpdb->update( |
| 55 | 55 | $this->_line_item_table_name, |
| 56 | - array( 'LIN_code' => 'pre-tax-subtotal' ), |
|
| 57 | - array( 'LIN_code' => 'tickets' ), |
|
| 58 | - array( '%s' ), |
|
| 59 | - array( '%s' ) ); |
|
| 56 | + array('LIN_code' => 'pre-tax-subtotal'), |
|
| 57 | + array('LIN_code' => 'tickets'), |
|
| 58 | + array('%s'), |
|
| 59 | + array('%s') ); |
|
| 60 | 60 | $this->set_completed(); |
| 61 | 61 | return 1; |
| 62 | 62 | } |
@@ -11,18 +11,18 @@ discard block |
||
| 11 | 11 | //(all other times it gets resurrected from a wordpress option) |
| 12 | 12 | $stages = glob(EE_CORE.'data_migration_scripts/4_2_0_stages/*'); |
| 13 | 13 | $class_to_filepath = array(); |
| 14 | -if ( ! empty( $stages ) ) { |
|
| 15 | - foreach($stages as $filepath){ |
|
| 14 | +if ( ! empty($stages)) { |
|
| 15 | + foreach ($stages as $filepath) { |
|
| 16 | 16 | $matches = array(); |
| 17 | - preg_match('~4_2_0_stages/(.*).dmsstage.php~',$filepath,$matches); |
|
| 17 | + preg_match('~4_2_0_stages/(.*).dmsstage.php~', $filepath, $matches); |
|
| 18 | 18 | $class_to_filepath[$matches[1]] = $filepath; |
| 19 | 19 | } |
| 20 | 20 | } |
| 21 | 21 | //give addons a chance to autoload their stages too |
| 22 | -$class_to_filepath = apply_filters('FHEE__EE_DMS_4_2_0__autoloaded_stages',$class_to_filepath); |
|
| 22 | +$class_to_filepath = apply_filters('FHEE__EE_DMS_4_2_0__autoloaded_stages', $class_to_filepath); |
|
| 23 | 23 | EEH_Autoloader::register_autoloader($class_to_filepath); |
| 24 | 24 | |
| 25 | -class EE_DMS_Core_4_2_0 extends EE_Data_Migration_Script_Base{ |
|
| 25 | +class EE_DMS_Core_4_2_0 extends EE_Data_Migration_Script_Base { |
|
| 26 | 26 | |
| 27 | 27 | |
| 28 | 28 | |
@@ -37,15 +37,15 @@ discard block |
||
| 37 | 37 | } |
| 38 | 38 | public function can_migrate_from_version($version_array) { |
| 39 | 39 | $version_string = $version_array['Core']; |
| 40 | - if($version_string <= '4.2.0' && $version_string >= '4.1.0' ){ |
|
| 40 | + if ($version_string <= '4.2.0' && $version_string >= '4.1.0') { |
|
| 41 | 41 | // echo "$version_string can be migrated fro"; |
| 42 | 42 | return true; |
| 43 | - }elseif( ! $version_string ){ |
|
| 43 | + }elseif ( ! $version_string) { |
|
| 44 | 44 | // echo "no version string provided: $version_string"; |
| 45 | 45 | //no version string provided... this must be pre 4.1 |
| 46 | 46 | //because since 4.1 we're |
| 47 | - return false;//changed mind. dont want people thinking they should migrate yet because they cant |
|
| 48 | - }else{ |
|
| 47 | + return false; //changed mind. dont want people thinking they should migrate yet because they cant |
|
| 48 | + } else { |
|
| 49 | 49 | // echo "$version_string doesnt apply"; |
| 50 | 50 | return false; |
| 51 | 51 | } |
@@ -55,14 +55,14 @@ discard block |
||
| 55 | 55 | } |
| 56 | 56 | public function schema_changes_before_migration() { |
| 57 | 57 | //relies on 4.1's EEH_Activation::create_table |
| 58 | - require_once( EE_HELPERS . 'EEH_Activation.helper.php' ); |
|
| 59 | - $table_name='esp_answer'; |
|
| 60 | - $sql=" ANS_ID INT UNSIGNED NOT NULL AUTO_INCREMENT, |
|
| 58 | + require_once(EE_HELPERS.'EEH_Activation.helper.php'); |
|
| 59 | + $table_name = 'esp_answer'; |
|
| 60 | + $sql = " ANS_ID INT UNSIGNED NOT NULL AUTO_INCREMENT, |
|
| 61 | 61 | REG_ID INT UNSIGNED NOT NULL, |
| 62 | 62 | QST_ID INT UNSIGNED NOT NULL, |
| 63 | 63 | ANS_value TEXT NOT NULL, |
| 64 | 64 | PRIMARY KEY (ANS_ID)"; |
| 65 | - $this->_table_should_exist_previously($table_name,$sql, 'ENGINE=InnoDB'); |
|
| 65 | + $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 66 | 66 | |
| 67 | 67 | $table_name = 'esp_attendee_meta'; |
| 68 | 68 | $sql = "ATTM_ID INT(10) UNSIGNED NOT NULL AUTO_INCREMENT, |
@@ -102,7 +102,7 @@ discard block |
||
| 102 | 102 | CNT_is_EU TINYINT(1) DEFAULT '0', |
| 103 | 103 | CNT_active TINYINT(1) DEFAULT '0', |
| 104 | 104 | PRIMARY KEY (CNT_ISO)"; |
| 105 | - $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB' ); |
|
| 105 | + $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 106 | 106 | |
| 107 | 107 | |
| 108 | 108 | |
@@ -125,7 +125,7 @@ discard block |
||
| 125 | 125 | |
| 126 | 126 | |
| 127 | 127 | |
| 128 | - $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB' ); |
|
| 128 | + $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 129 | 129 | $table_name = 'esp_event_meta'; |
| 130 | 130 | $sql = " |
| 131 | 131 | EVTM_ID INT NOT NULL AUTO_INCREMENT, |
@@ -142,41 +142,41 @@ discard block |
||
| 142 | 142 | EVT_external_URL VARCHAR(200) NULL, |
| 143 | 143 | EVT_donations TINYINT(1) NULL, |
| 144 | 144 | PRIMARY KEY (EVTM_ID)"; |
| 145 | - $this->_table_should_exist_previously($table_name,$sql, 'ENGINE=InnoDB'); |
|
| 145 | + $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 146 | 146 | |
| 147 | 147 | |
| 148 | 148 | |
| 149 | - $table_name='esp_event_question_group'; |
|
| 150 | - $sql="EQG_ID INT UNSIGNED NOT NULL AUTO_INCREMENT, |
|
| 149 | + $table_name = 'esp_event_question_group'; |
|
| 150 | + $sql = "EQG_ID INT UNSIGNED NOT NULL AUTO_INCREMENT, |
|
| 151 | 151 | EVT_ID BIGINT(20) UNSIGNED NOT NULL, |
| 152 | 152 | QSG_ID INT UNSIGNED NOT NULL, |
| 153 | 153 | EQG_primary TINYINT(1) UNSIGNED NOT NULL DEFAULT 0, |
| 154 | 154 | PRIMARY KEY (EQG_ID)"; |
| 155 | - $this->_table_should_exist_previously($table_name,$sql, 'ENGINE=InnoDB'); |
|
| 155 | + $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 156 | 156 | |
| 157 | 157 | |
| 158 | 158 | |
| 159 | - $table_name='esp_event_venue'; |
|
| 160 | - $sql="EVV_ID INT(11) NOT NULL AUTO_INCREMENT, |
|
| 159 | + $table_name = 'esp_event_venue'; |
|
| 160 | + $sql = "EVV_ID INT(11) NOT NULL AUTO_INCREMENT, |
|
| 161 | 161 | EVT_ID BIGINT(20) UNSIGNED NOT NULL, |
| 162 | 162 | VNU_ID BIGINT(20) UNSIGNED NOT NULL, |
| 163 | 163 | EVV_primary TINYINT(1) UNSIGNED NOT NULL DEFAULT 0, |
| 164 | 164 | PRIMARY KEY (EVV_ID)"; |
| 165 | - $this->_table_should_exist_previously($table_name,$sql, 'ENGINE=InnoDB'); |
|
| 165 | + $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 166 | 166 | |
| 167 | 167 | |
| 168 | 168 | |
| 169 | - $table_name='esp_extra_meta'; |
|
| 170 | - $sql="EXM_ID INT(11) NOT NULL AUTO_INCREMENT, |
|
| 169 | + $table_name = 'esp_extra_meta'; |
|
| 170 | + $sql = "EXM_ID INT(11) NOT NULL AUTO_INCREMENT, |
|
| 171 | 171 | OBJ_ID INT(11) DEFAULT NULL, |
| 172 | 172 | EXM_type VARCHAR(45) DEFAULT NULL, |
| 173 | 173 | EXM_key VARCHAR(45) DEFAULT NULL, |
| 174 | 174 | EXM_value TEXT, |
| 175 | 175 | PRIMARY KEY (EXM_ID)"; |
| 176 | - $this->_table_should_exist_previously($table_name,$sql, 'ENGINE=InnoDB'); |
|
| 176 | + $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 177 | 177 | |
| 178 | - $table_name='esp_line_item'; |
|
| 179 | - $sql="LIN_ID INT(11) NOT NULL AUTO_INCREMENT, |
|
| 178 | + $table_name = 'esp_line_item'; |
|
| 179 | + $sql = "LIN_ID INT(11) NOT NULL AUTO_INCREMENT, |
|
| 180 | 180 | LIN_code VARCHAR(245) NOT NULL DEFAULT '', |
| 181 | 181 | TXN_ID INT(11) DEFAULT NULL, |
| 182 | 182 | LIN_name VARCHAR(245) NOT NULL DEFAULT '', |
@@ -192,7 +192,7 @@ discard block |
||
| 192 | 192 | OBJ_ID INT(11) DEFAULT NULL, |
| 193 | 193 | OBJ_type VARCHAR(45)DEFAULT NULL, |
| 194 | 194 | PRIMARY KEY (LIN_ID)"; |
| 195 | - $this->_table_should_exist_previously($table_name,$sql, 'ENGINE=InnoDB' ); |
|
| 195 | + $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 196 | 196 | |
| 197 | 197 | $table_name = 'esp_message_template'; |
| 198 | 198 | $sql = "MTP_ID INT(10) UNSIGNED NOT NULL AUTO_INCREMENT, |
@@ -219,7 +219,7 @@ discard block |
||
| 219 | 219 | PRIMARY KEY (GRP_ID), |
| 220 | 220 | KEY EVT_ID (EVT_ID), |
| 221 | 221 | KEY MTP_user_id (MTP_user_id)"; |
| 222 | - $this->_table_should_exist_previously( $table_name, $sql, 'ENGINE=InnoDB'); |
|
| 222 | + $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 223 | 223 | |
| 224 | 224 | |
| 225 | 225 | |
@@ -327,8 +327,8 @@ discard block |
||
| 327 | 327 | |
| 328 | 328 | |
| 329 | 329 | |
| 330 | - $table_name='esp_question'; |
|
| 331 | - $sql='QST_ID INT UNSIGNED NOT NULL AUTO_INCREMENT, |
|
| 330 | + $table_name = 'esp_question'; |
|
| 331 | + $sql = 'QST_ID INT UNSIGNED NOT NULL AUTO_INCREMENT, |
|
| 332 | 332 | QST_display_text TEXT NOT NULL, |
| 333 | 333 | QST_admin_label VARCHAR(255) NOT NULL, |
| 334 | 334 | QST_system VARCHAR(25) DEFAULT NULL, |
@@ -340,12 +340,12 @@ discard block |
||
| 340 | 340 | QST_wp_user BIGINT UNSIGNED NULL, |
| 341 | 341 | QST_deleted TINYINT UNSIGNED NOT NULL DEFAULT 0, |
| 342 | 342 | PRIMARY KEY (QST_ID)'; |
| 343 | - $this->_table_should_exist_previously($table_name,$sql, 'ENGINE=InnoDB'); |
|
| 343 | + $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 344 | 344 | |
| 345 | - EEH_Activation::drop_index( 'esp_question_group', 'QSG_identifier_UNIQUE' ); |
|
| 345 | + EEH_Activation::drop_index('esp_question_group', 'QSG_identifier_UNIQUE'); |
|
| 346 | 346 | |
| 347 | 347 | $table_name = 'esp_question_group'; |
| 348 | - $sql='QSG_ID INT UNSIGNED NOT NULL AUTO_INCREMENT, |
|
| 348 | + $sql = 'QSG_ID INT UNSIGNED NOT NULL AUTO_INCREMENT, |
|
| 349 | 349 | QSG_name VARCHAR(255) NOT NULL, |
| 350 | 350 | QSG_identifier VARCHAR(100) NOT NULL, |
| 351 | 351 | QSG_desc TEXT NULL, |
@@ -356,28 +356,28 @@ discard block |
||
| 356 | 356 | QSG_deleted TINYINT(1) UNSIGNED NOT NULL DEFAULT 0, |
| 357 | 357 | PRIMARY KEY (QSG_ID), |
| 358 | 358 | UNIQUE KEY QSG_identifier_UNIQUE (QSG_identifier ASC)'; |
| 359 | - $this->_table_should_exist_previously($table_name,$sql, 'ENGINE=InnoDB'); |
|
| 359 | + $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 360 | 360 | |
| 361 | 361 | |
| 362 | 362 | |
| 363 | - $table_name='esp_question_group_question'; |
|
| 364 | - $sql="QGQ_ID INT UNSIGNED NOT NULL AUTO_INCREMENT, |
|
| 363 | + $table_name = 'esp_question_group_question'; |
|
| 364 | + $sql = "QGQ_ID INT UNSIGNED NOT NULL AUTO_INCREMENT, |
|
| 365 | 365 | QSG_ID INT UNSIGNED NOT NULL, |
| 366 | 366 | QST_ID INT UNSIGNED NOT NULL, |
| 367 | 367 | QGQ_order INT UNSIGNED NOT NULL DEFAULT 0, |
| 368 | 368 | PRIMARY KEY (QGQ_ID) "; |
| 369 | - $this->_table_should_exist_previously($table_name,$sql, 'ENGINE=InnoDB'); |
|
| 369 | + $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 370 | 370 | |
| 371 | 371 | |
| 372 | 372 | |
| 373 | - $table_name='esp_question_option'; |
|
| 374 | - $sql="QSO_ID INT UNSIGNED NOT NULL AUTO_INCREMENT, |
|
| 373 | + $table_name = 'esp_question_option'; |
|
| 374 | + $sql = "QSO_ID INT UNSIGNED NOT NULL AUTO_INCREMENT, |
|
| 375 | 375 | QSO_value VARCHAR(255) NOT NULL, |
| 376 | 376 | QSO_desc TEXT NOT NULL, |
| 377 | 377 | QST_ID INT UNSIGNED NOT NULL, |
| 378 | 378 | QSO_deleted TINYINT(1) UNSIGNED NOT NULL DEFAULT 0, |
| 379 | 379 | PRIMARY KEY (QSO_ID)"; |
| 380 | - $this->_table_should_exist_previously($table_name,$sql, 'ENGINE=InnoDB'); |
|
| 380 | + $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 381 | 381 | |
| 382 | 382 | |
| 383 | 383 | |
@@ -410,8 +410,8 @@ discard block |
||
| 410 | 410 | |
| 411 | 411 | |
| 412 | 412 | |
| 413 | - $table_name='esp_checkin'; |
|
| 414 | - $sql="CHK_ID INT(10) UNSIGNED NOT NULL AUTO_INCREMENT, |
|
| 413 | + $table_name = 'esp_checkin'; |
|
| 414 | + $sql = "CHK_ID INT(10) UNSIGNED NOT NULL AUTO_INCREMENT, |
|
| 415 | 415 | REG_ID INT(10) UNSIGNED NOT NULL, |
| 416 | 416 | DTT_ID INT(10) UNSIGNED NOT NULL, |
| 417 | 417 | CHK_in TINYINT(1) UNSIGNED NOT NULL DEFAULT 1, |
@@ -485,7 +485,7 @@ discard block |
||
| 485 | 485 | $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB'); |
| 486 | 486 | |
| 487 | 487 | |
| 488 | - $script_with_defaults = EE_Registry::instance()->load_dms( 'Core_4_1_0' ); |
|
| 488 | + $script_with_defaults = EE_Registry::instance()->load_dms('Core_4_1_0'); |
|
| 489 | 489 | //setting up the DEFAULT stats and countries is also essential for the data migrations to run |
| 490 | 490 | //(because many need to convert old string states to foreign keys into the states table) |
| 491 | 491 | $script_with_defaults->insert_default_states(); |
@@ -507,7 +507,7 @@ discard block |
||
| 507 | 507 | return true; |
| 508 | 508 | } |
| 509 | 509 | |
| 510 | - public function migration_page_hooks(){ |
|
| 510 | + public function migration_page_hooks() { |
|
| 511 | 511 | |
| 512 | 512 | } |
| 513 | 513 | } |
@@ -65,11 +65,11 @@ |
||
| 65 | 65 | if( $version_string <= '4.8.0' && $version_string >= '4.7.0' ){ |
| 66 | 66 | // echo "$version_string can be migrated from"; |
| 67 | 67 | return true; |
| 68 | - }elseif( ! $version_string ){ |
|
| 68 | + } elseif( ! $version_string ){ |
|
| 69 | 69 | // echo "no version string provided: $version_string"; |
| 70 | 70 | //no version string provided... this must be pre 4.3 |
| 71 | 71 | return false;//changed mind. dont want people thinking they should migrate yet because they cant |
| 72 | - }else{ |
|
| 72 | + } else{ |
|
| 73 | 73 | // echo "$version_string doesnt apply"; |
| 74 | 74 | return false; |
| 75 | 75 | } |
@@ -65,11 +65,11 @@ |
||
| 65 | 65 | if( $version_string <= '4.8.0' && $version_string >= '4.7.0' ){ |
| 66 | 66 | // echo "$version_string can be migrated from"; |
| 67 | 67 | return true; |
| 68 | - }elseif( ! $version_string ){ |
|
| 68 | + } elseif( ! $version_string ){ |
|
| 69 | 69 | // echo "no version string provided: $version_string"; |
| 70 | 70 | //no version string provided... this must be pre 4.3 |
| 71 | 71 | return false;//changed mind. dont want people thinking they should migrate yet because they cant |
| 72 | - }else{ |
|
| 72 | + } else{ |
|
| 73 | 73 | // echo "$version_string doesnt apply"; |
| 74 | 74 | return false; |
| 75 | 75 | } |
@@ -715,7 +715,7 @@ |
||
| 715 | 715 | } |
| 716 | 716 | } |
| 717 | 717 | } |
| 718 | - } |
|
| 718 | + } |
|
| 719 | 719 | /** |
| 720 | 720 | * addresses https://events.codebasehq.com/projects/event-espresso/tickets/8731 |
| 721 | 721 | * which should just be a temporary issue for folks who installed 4.8.0-4.8.5; |
@@ -13,13 +13,13 @@ discard block |
||
| 13 | 13 | //(all other times it gets resurrected from a wordpress option) |
| 14 | 14 | $stages = glob(EE_CORE.'data_migration_scripts/4_8_0_stages/*'); |
| 15 | 15 | $class_to_filepath = array(); |
| 16 | -foreach($stages as $filepath){ |
|
| 16 | +foreach ($stages as $filepath) { |
|
| 17 | 17 | $matches = array(); |
| 18 | - preg_match('~4_8_0_stages/(.*).dmsstage.php~',$filepath,$matches); |
|
| 18 | + preg_match('~4_8_0_stages/(.*).dmsstage.php~', $filepath, $matches); |
|
| 19 | 19 | $class_to_filepath[$matches[1]] = $filepath; |
| 20 | 20 | } |
| 21 | 21 | //give addons a chance to autoload their stages too |
| 22 | -$class_to_filepath = apply_filters('FHEE__EE_DMS_4_8_0__autoloaded_stages',$class_to_filepath); |
|
| 22 | +$class_to_filepath = apply_filters('FHEE__EE_DMS_4_8_0__autoloaded_stages', $class_to_filepath); |
|
| 23 | 23 | EEH_Autoloader::register_autoloader($class_to_filepath); |
| 24 | 24 | |
| 25 | 25 | |
@@ -35,7 +35,7 @@ discard block |
||
| 35 | 35 | * @since 4.6.0 |
| 36 | 36 | * |
| 37 | 37 | */ |
| 38 | -class EE_DMS_Core_4_8_0 extends EE_Data_Migration_Script_Base{ |
|
| 38 | +class EE_DMS_Core_4_8_0 extends EE_Data_Migration_Script_Base { |
|
| 39 | 39 | |
| 40 | 40 | /** |
| 41 | 41 | * return EE_DMS_Core_4_8_0 |
@@ -62,14 +62,14 @@ discard block |
||
| 62 | 62 | */ |
| 63 | 63 | public function can_migrate_from_version($version_array) { |
| 64 | 64 | $version_string = $version_array['Core']; |
| 65 | - if( $version_string <= '4.8.0' && $version_string >= '4.7.0' ){ |
|
| 65 | + if ($version_string <= '4.8.0' && $version_string >= '4.7.0') { |
|
| 66 | 66 | // echo "$version_string can be migrated from"; |
| 67 | 67 | return true; |
| 68 | - }elseif( ! $version_string ){ |
|
| 68 | + }elseif ( ! $version_string) { |
|
| 69 | 69 | // echo "no version string provided: $version_string"; |
| 70 | 70 | //no version string provided... this must be pre 4.3 |
| 71 | - return false;//changed mind. dont want people thinking they should migrate yet because they cant |
|
| 72 | - }else{ |
|
| 71 | + return false; //changed mind. dont want people thinking they should migrate yet because they cant |
|
| 72 | + } else { |
|
| 73 | 73 | // echo "$version_string doesnt apply"; |
| 74 | 74 | return false; |
| 75 | 75 | } |
@@ -90,19 +90,19 @@ discard block |
||
| 90 | 90 | * @return bool |
| 91 | 91 | */ |
| 92 | 92 | public function schema_changes_before_migration() { |
| 93 | - require_once( EE_HELPERS . 'EEH_Activation.helper.php' ); |
|
| 94 | - $now_in_mysql = current_time( 'mysql', true ); |
|
| 93 | + require_once(EE_HELPERS.'EEH_Activation.helper.php'); |
|
| 94 | + $now_in_mysql = current_time('mysql', true); |
|
| 95 | 95 | |
| 96 | - require_once( EE_HELPERS . 'EEH_Activation.helper.php' ); |
|
| 97 | - $table_name='esp_answer'; |
|
| 98 | - $sql=" ANS_ID int(10) unsigned NOT NULL AUTO_INCREMENT, |
|
| 96 | + require_once(EE_HELPERS.'EEH_Activation.helper.php'); |
|
| 97 | + $table_name = 'esp_answer'; |
|
| 98 | + $sql = " ANS_ID int(10) unsigned NOT NULL AUTO_INCREMENT, |
|
| 99 | 99 | REG_ID int(10) unsigned NOT NULL, |
| 100 | 100 | QST_ID int(10) unsigned NOT NULL, |
| 101 | 101 | ANS_value text NOT NULL, |
| 102 | 102 | PRIMARY KEY (ANS_ID), |
| 103 | 103 | KEY REG_ID (REG_ID), |
| 104 | 104 | KEY QST_ID (QST_ID)"; |
| 105 | - $this->_table_is_changed_in_this_version($table_name,$sql, 'ENGINE=InnoDB'); |
|
| 105 | + $this->_table_is_changed_in_this_version($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 106 | 106 | |
| 107 | 107 | $table_name = 'esp_attendee_meta'; |
| 108 | 108 | $sql = "ATTM_ID int(10) unsigned NOT NULL AUTO_INCREMENT, |
@@ -142,7 +142,7 @@ discard block |
||
| 142 | 142 | CNT_is_EU tinyint(1) DEFAULT '0', |
| 143 | 143 | CNT_active tinyint(1) DEFAULT '0', |
| 144 | 144 | PRIMARY KEY (CNT_ISO)"; |
| 145 | - $this->_table_has_not_changed_since_previous($table_name, $sql, 'ENGINE=InnoDB' ); |
|
| 145 | + $this->_table_has_not_changed_since_previous($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 146 | 146 | |
| 147 | 147 | $table_name = 'esp_currency'; |
| 148 | 148 | $sql = "CUR_code varchar(6) collate utf8_bin NOT NULL, |
@@ -152,7 +152,7 @@ discard block |
||
| 152 | 152 | CUR_dec_plc varchar(1) collate utf8_bin NOT NULL DEFAULT '2', |
| 153 | 153 | CUR_active tinyint(1) DEFAULT '0', |
| 154 | 154 | PRIMARY KEY (CUR_code)"; |
| 155 | - $this->_table_has_not_changed_since_previous($table_name, $sql, 'ENGINE=InnoDB' ); |
|
| 155 | + $this->_table_has_not_changed_since_previous($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 156 | 156 | |
| 157 | 157 | |
| 158 | 158 | $table_name = 'esp_currency_payment_method'; |
@@ -182,7 +182,7 @@ discard block |
||
| 182 | 182 | KEY EVT_ID (EVT_ID), |
| 183 | 183 | KEY DTT_is_primary (DTT_is_primary)"; |
| 184 | 184 | |
| 185 | - $this->_table_is_changed_in_this_version($table_name, $sql, 'ENGINE=InnoDB' ); |
|
| 185 | + $this->_table_is_changed_in_this_version($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 186 | 186 | |
| 187 | 187 | $table_name = 'esp_event_meta'; |
| 188 | 188 | $sql = " |
@@ -201,41 +201,41 @@ discard block |
||
| 201 | 201 | EVT_donations tinyint(1) NULL, |
| 202 | 202 | PRIMARY KEY (EVTM_ID), |
| 203 | 203 | KEY EVT_ID (EVT_ID)"; |
| 204 | - $this->_table_is_changed_in_this_version($table_name,$sql, 'ENGINE=InnoDB'); |
|
| 204 | + $this->_table_is_changed_in_this_version($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 205 | 205 | |
| 206 | 206 | |
| 207 | 207 | |
| 208 | - $table_name='esp_event_question_group'; |
|
| 209 | - $sql="EQG_ID int(10) unsigned NOT NULL AUTO_INCREMENT, |
|
| 208 | + $table_name = 'esp_event_question_group'; |
|
| 209 | + $sql = "EQG_ID int(10) unsigned NOT NULL AUTO_INCREMENT, |
|
| 210 | 210 | EVT_ID bigint(20) unsigned NOT NULL, |
| 211 | 211 | QSG_ID int(10) unsigned NOT NULL, |
| 212 | 212 | EQG_primary tinyint(1) unsigned NOT NULL DEFAULT 0, |
| 213 | 213 | PRIMARY KEY (EQG_ID), |
| 214 | 214 | KEY EVT_ID (EVT_ID), |
| 215 | 215 | KEY QSG_ID (QSG_ID)"; |
| 216 | - $this->_table_is_changed_in_this_version($table_name,$sql, 'ENGINE=InnoDB'); |
|
| 216 | + $this->_table_is_changed_in_this_version($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 217 | 217 | |
| 218 | 218 | |
| 219 | 219 | |
| 220 | - $table_name='esp_event_venue'; |
|
| 221 | - $sql="EVV_ID int(11) NOT NULL AUTO_INCREMENT, |
|
| 220 | + $table_name = 'esp_event_venue'; |
|
| 221 | + $sql = "EVV_ID int(11) NOT NULL AUTO_INCREMENT, |
|
| 222 | 222 | EVT_ID bigint(20) unsigned NOT NULL, |
| 223 | 223 | VNU_ID bigint(20) unsigned NOT NULL, |
| 224 | 224 | EVV_primary tinyint(1) unsigned NOT NULL DEFAULT 0, |
| 225 | 225 | PRIMARY KEY (EVV_ID)"; |
| 226 | - $this->_table_has_not_changed_since_previous($table_name,$sql, 'ENGINE=InnoDB'); |
|
| 226 | + $this->_table_has_not_changed_since_previous($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 227 | 227 | |
| 228 | 228 | |
| 229 | 229 | |
| 230 | - $table_name='esp_extra_meta'; |
|
| 231 | - $sql="EXM_ID int(11) NOT NULL AUTO_INCREMENT, |
|
| 230 | + $table_name = 'esp_extra_meta'; |
|
| 231 | + $sql = "EXM_ID int(11) NOT NULL AUTO_INCREMENT, |
|
| 232 | 232 | OBJ_ID int(11) DEFAULT NULL, |
| 233 | 233 | EXM_type varchar(45) DEFAULT NULL, |
| 234 | 234 | EXM_key varchar(45) DEFAULT NULL, |
| 235 | 235 | EXM_value text, |
| 236 | 236 | PRIMARY KEY (EXM_ID), |
| 237 | 237 | KEY EXM_type (EXM_type,OBJ_ID,EXM_key)"; |
| 238 | - $this->_table_is_changed_in_this_version($table_name,$sql, 'ENGINE=InnoDB'); |
|
| 238 | + $this->_table_is_changed_in_this_version($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 239 | 239 | |
| 240 | 240 | $table_name = 'esp_extra_join'; |
| 241 | 241 | $sql = "EXJ_ID int(11) NOT NULL AUTO_INCREMENT, |
@@ -248,8 +248,8 @@ discard block |
||
| 248 | 248 | KEY second_model (EXJ_second_model_name,EXJ_second_model_id)"; |
| 249 | 249 | $this->_table_is_new_in_this_version($table_name, $sql, 'ENGINE=InnoDB '); |
| 250 | 250 | |
| 251 | - $table_name='esp_line_item'; |
|
| 252 | - $sql="LIN_ID int(11) NOT NULL AUTO_INCREMENT, |
|
| 251 | + $table_name = 'esp_line_item'; |
|
| 252 | + $sql = "LIN_ID int(11) NOT NULL AUTO_INCREMENT, |
|
| 253 | 253 | LIN_code varchar(245) NOT NULL DEFAULT '', |
| 254 | 254 | TXN_ID int(11) DEFAULT NULL, |
| 255 | 255 | LIN_name varchar(245) NOT NULL DEFAULT '', |
@@ -268,7 +268,7 @@ discard block |
||
| 268 | 268 | PRIMARY KEY (LIN_ID), |
| 269 | 269 | KEY LIN_code (LIN_code(191)), |
| 270 | 270 | KEY TXN_ID (TXN_ID)"; |
| 271 | - $this->_table_is_changed_in_this_version($table_name,$sql, 'ENGINE=InnoDB' ); |
|
| 271 | + $this->_table_is_changed_in_this_version($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 272 | 272 | |
| 273 | 273 | $table_name = 'esp_log'; |
| 274 | 274 | $sql = "LOG_ID int(11) NOT NULL AUTO_INCREMENT, |
@@ -307,7 +307,7 @@ discard block |
||
| 307 | 307 | MTP_is_active tinyint(1) NOT NULL DEFAULT '1', |
| 308 | 308 | PRIMARY KEY (GRP_ID), |
| 309 | 309 | KEY MTP_user_id (MTP_user_id)"; |
| 310 | - $this->_table_has_not_changed_since_previous( $table_name, $sql, 'ENGINE=InnoDB'); |
|
| 310 | + $this->_table_has_not_changed_since_previous($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 311 | 311 | |
| 312 | 312 | $table_name = 'esp_event_message_template'; |
| 313 | 313 | $sql = "EMT_ID bigint(20) unsigned NOT NULL AUTO_INCREMENT, |
@@ -316,7 +316,7 @@ discard block |
||
| 316 | 316 | PRIMARY KEY (EMT_ID), |
| 317 | 317 | KEY EVT_ID (EVT_ID), |
| 318 | 318 | KEY GRP_ID (GRP_ID)"; |
| 319 | - $this->_table_has_not_changed_since_previous( $table_name, $sql, 'ENGINE=InnoDB'); |
|
| 319 | + $this->_table_has_not_changed_since_previous($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 320 | 320 | |
| 321 | 321 | |
| 322 | 322 | $table_name = 'esp_payment'; |
@@ -389,8 +389,8 @@ discard block |
||
| 389 | 389 | PRIMARY KEY (TTM_ID)"; |
| 390 | 390 | $this->_table_has_not_changed_since_previous($table_name, $sql, 'ENGINE=InnoDB'); |
| 391 | 391 | |
| 392 | - $table_name='esp_question'; |
|
| 393 | - $sql='QST_ID int(10) unsigned NOT NULL AUTO_INCREMENT, |
|
| 392 | + $table_name = 'esp_question'; |
|
| 393 | + $sql = 'QST_ID int(10) unsigned NOT NULL AUTO_INCREMENT, |
|
| 394 | 394 | QST_display_text text NOT NULL, |
| 395 | 395 | QST_admin_label varchar(255) NOT NULL, |
| 396 | 396 | QST_system varchar(25) NOT NULL DEFAULT "", |
@@ -404,22 +404,22 @@ discard block |
||
| 404 | 404 | QST_deleted tinyint(2) unsigned NOT NULL DEFAULT 0, |
| 405 | 405 | PRIMARY KEY (QST_ID), |
| 406 | 406 | KEY QST_order (QST_order)'; |
| 407 | - $this->_table_is_changed_in_this_version($table_name,$sql, 'ENGINE=InnoDB'); |
|
| 407 | + $this->_table_is_changed_in_this_version($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 408 | 408 | |
| 409 | - $table_name='esp_question_group_question'; |
|
| 410 | - $sql="QGQ_ID int(10) unsigned NOT NULL AUTO_INCREMENT, |
|
| 409 | + $table_name = 'esp_question_group_question'; |
|
| 410 | + $sql = "QGQ_ID int(10) unsigned NOT NULL AUTO_INCREMENT, |
|
| 411 | 411 | QSG_ID int(10) unsigned NOT NULL, |
| 412 | 412 | QST_ID int(10) unsigned NOT NULL, |
| 413 | 413 | QGQ_order int(10) unsigned NOT NULL DEFAULT 0, |
| 414 | 414 | PRIMARY KEY (QGQ_ID), |
| 415 | 415 | KEY QST_ID (QST_ID), |
| 416 | 416 | KEY QSG_ID_order (QSG_ID,QGQ_order)"; |
| 417 | - $this->_table_is_changed_in_this_version($table_name,$sql, 'ENGINE=InnoDB'); |
|
| 417 | + $this->_table_is_changed_in_this_version($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 418 | 418 | |
| 419 | 419 | |
| 420 | 420 | |
| 421 | - $table_name='esp_question_option'; |
|
| 422 | - $sql="QSO_ID int(10) unsigned NOT NULL AUTO_INCREMENT, |
|
| 421 | + $table_name = 'esp_question_option'; |
|
| 422 | + $sql = "QSO_ID int(10) unsigned NOT NULL AUTO_INCREMENT, |
|
| 423 | 423 | QSO_value varchar(255) NOT NULL, |
| 424 | 424 | QSO_desc text NOT NULL, |
| 425 | 425 | QST_ID int(10) unsigned NOT NULL, |
@@ -429,7 +429,7 @@ discard block |
||
| 429 | 429 | PRIMARY KEY (QSO_ID), |
| 430 | 430 | KEY QST_ID (QST_ID), |
| 431 | 431 | KEY QSO_order (QSO_order)"; |
| 432 | - $this->_table_is_changed_in_this_version($table_name,$sql, 'ENGINE=InnoDB'); |
|
| 432 | + $this->_table_is_changed_in_this_version($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 433 | 433 | |
| 434 | 434 | |
| 435 | 435 | |
@@ -475,8 +475,8 @@ discard block |
||
| 475 | 475 | |
| 476 | 476 | |
| 477 | 477 | |
| 478 | - $table_name='esp_checkin'; |
|
| 479 | - $sql="CHK_ID int(10) unsigned NOT NULL AUTO_INCREMENT, |
|
| 478 | + $table_name = 'esp_checkin'; |
|
| 479 | + $sql = "CHK_ID int(10) unsigned NOT NULL AUTO_INCREMENT, |
|
| 480 | 480 | REG_ID int(10) unsigned NOT NULL, |
| 481 | 481 | DTT_ID int(10) unsigned NOT NULL, |
| 482 | 482 | CHK_in tinyint(1) unsigned NOT NULL DEFAULT 1, |
@@ -571,7 +571,7 @@ discard block |
||
| 571 | 571 | PRC_parent int(10) unsigned DEFAULT 0, |
| 572 | 572 | PRIMARY KEY (PRC_ID), |
| 573 | 573 | KEY PRT_ID (PRT_ID)"; |
| 574 | - $this->_table_is_changed_in_this_version($table_name,$sql, 'ENGINE=InnoDB'); |
|
| 574 | + $this->_table_is_changed_in_this_version($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 575 | 575 | |
| 576 | 576 | $table_name = "esp_price_type"; |
| 577 | 577 | $sql = "PRT_ID tinyint(3) unsigned NOT NULL AUTO_INCREMENT, |
@@ -609,10 +609,10 @@ discard block |
||
| 609 | 609 | TKT_deleted tinyint(1) NOT NULL DEFAULT '0', |
| 610 | 610 | PRIMARY KEY (TKT_ID), |
| 611 | 611 | KEY TKT_start_date (TKT_start_date)"; |
| 612 | - $this->_table_is_changed_in_this_version($table_name, $sql, 'ENGINE=InnoDB' ); |
|
| 612 | + $this->_table_is_changed_in_this_version($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 613 | 613 | |
| 614 | 614 | $table_name = 'esp_question_group'; |
| 615 | - $sql='QSG_ID int(10) unsigned NOT NULL AUTO_INCREMENT, |
|
| 615 | + $sql = 'QSG_ID int(10) unsigned NOT NULL AUTO_INCREMENT, |
|
| 616 | 616 | QSG_name varchar(255) NOT NULL, |
| 617 | 617 | QSG_identifier varchar(100) NOT NULL, |
| 618 | 618 | QSG_desc text NULL, |
@@ -625,7 +625,7 @@ discard block |
||
| 625 | 625 | PRIMARY KEY (QSG_ID), |
| 626 | 626 | UNIQUE KEY QSG_identifier_UNIQUE (QSG_identifier), |
| 627 | 627 | KEY QSG_order (QSG_order)'; |
| 628 | - $this->_table_is_changed_in_this_version($table_name, $sql, 'ENGINE=InnoDB' ); |
|
| 628 | + $this->_table_is_changed_in_this_version($table_name, $sql, 'ENGINE=InnoDB'); |
|
| 629 | 629 | |
| 630 | 630 | /** @var EE_DMS_Core_4_1_0 $script_4_1_defaults */ |
| 631 | 631 | $script_4_1_defaults = EE_Registry::instance()->load_dms('Core_4_1_0'); |
@@ -661,7 +661,7 @@ discard block |
||
| 661 | 661 | return $script_4_7_defaults->schema_changes_after_migration(); |
| 662 | 662 | } |
| 663 | 663 | |
| 664 | - public function migration_page_hooks(){ |
|
| 664 | + public function migration_page_hooks() { |
|
| 665 | 665 | |
| 666 | 666 | } |
| 667 | 667 | |
@@ -675,19 +675,19 @@ discard block |
||
| 675 | 675 | //CNT_ISO, CNT_ISO3, RGN_ID, CNT_name, CNT_cur_code, CNT_cur_single, CNT_cur_plural, CNT_cur_sign, CNT_cur_sign_b4, CNT_cur_dec_plc, CNT_tel_code, CNT_is_EU, CNT_active |
| 676 | 676 | //('AD', 'AND', 0, 'Andorra', 'EUR', 'Euro', 'Euros', '€', 1, 2, '+376', 0, 0), |
| 677 | 677 | $newer_countries = array( |
| 678 | - array( 'AX', 'ALA', 0, 'Alan Islands', 'EUR', 'Euro', 'Euros', '€', 1, 2, '+358', 1, 0 ), |
|
| 679 | - array( 'BL', 'BLM', 0, 'Saint Barthelemy', 'EUR', 'Euro', 'Euros', '€', 1, 2, '+590', 1, 0 ), |
|
| 680 | - array( 'CW', 'CUW', 0, 'Curacao', 'ANG', 'Guilder', 'Guilders', 'ƒ', 1, 2, '+599', 1, 0 ), |
|
| 681 | - array( 'GG', 'GGY', 0, 'Guernsey', 'EUR', 'Euro', 'Euros', '€', 1, 2, '+44', 0, 0 ), |
|
| 682 | - array( 'IM', 'IMN', 0, 'Isle of Man', 'GBP', 'Pound', 'Pounds', '£', 1, 2, '+44', 0, 0 ), |
|
| 683 | - array( 'JE', 'JEY', 0, 'Jersey', 'GBP', 'Pound', 'Pounds', '£', 1, 2, '+44', 0, 0 ), |
|
| 684 | - array( 'MF', 'MAF', 0, 'Saint Martin', 'EUR', 'Euro', 'Euros', '€', 1, 2, '+590', 1, 0 ), |
|
| 685 | - array( 'MN', 'MNE', 0, 'Montenegro', 'EUR', 'Euro', 'Euros', '€', 1, 2, '+382', 0, 0 ), |
|
| 686 | - array( 'RS', 'SRB', 0, 'Serbia', 'RSD', 'Dinar', 'Dinars', '', 0, 2, '+941', 1, 0 ), |
|
| 687 | - array( 'SS', 'SSD', 0, 'South Sudan', 'SSP', 'Pound', 'Pounds', '£', 1, 2, '+211', 0, 0 ), |
|
| 688 | - array( 'SX', 'SXM', 0, 'Sint Maarten', 'ANG', 'Guilder', 'Guilders', 'ƒ', 1, 2, '+1', 1, 0 ), |
|
| 689 | - array( 'XK', 'XKX', 0, 'Kosovo', 'EUR', 'Euro', 'Euros', '€', 1, 2, '+381', 0, 0 ), |
|
| 690 | - array( 'YT', 'MYT', 0, 'Mayotte', 'EUR', 'Euro', 'Euros', '€', 0, 2, '+262', 1, 0 ), |
|
| 678 | + array('AX', 'ALA', 0, 'Alan Islands', 'EUR', 'Euro', 'Euros', '€', 1, 2, '+358', 1, 0), |
|
| 679 | + array('BL', 'BLM', 0, 'Saint Barthelemy', 'EUR', 'Euro', 'Euros', '€', 1, 2, '+590', 1, 0), |
|
| 680 | + array('CW', 'CUW', 0, 'Curacao', 'ANG', 'Guilder', 'Guilders', 'ƒ', 1, 2, '+599', 1, 0), |
|
| 681 | + array('GG', 'GGY', 0, 'Guernsey', 'EUR', 'Euro', 'Euros', '€', 1, 2, '+44', 0, 0), |
|
| 682 | + array('IM', 'IMN', 0, 'Isle of Man', 'GBP', 'Pound', 'Pounds', '£', 1, 2, '+44', 0, 0), |
|
| 683 | + array('JE', 'JEY', 0, 'Jersey', 'GBP', 'Pound', 'Pounds', '£', 1, 2, '+44', 0, 0), |
|
| 684 | + array('MF', 'MAF', 0, 'Saint Martin', 'EUR', 'Euro', 'Euros', '€', 1, 2, '+590', 1, 0), |
|
| 685 | + array('MN', 'MNE', 0, 'Montenegro', 'EUR', 'Euro', 'Euros', '€', 1, 2, '+382', 0, 0), |
|
| 686 | + array('RS', 'SRB', 0, 'Serbia', 'RSD', 'Dinar', 'Dinars', '', 0, 2, '+941', 1, 0), |
|
| 687 | + array('SS', 'SSD', 0, 'South Sudan', 'SSP', 'Pound', 'Pounds', '£', 1, 2, '+211', 0, 0), |
|
| 688 | + array('SX', 'SXM', 0, 'Sint Maarten', 'ANG', 'Guilder', 'Guilders', 'ƒ', 1, 2, '+1', 1, 0), |
|
| 689 | + array('XK', 'XKX', 0, 'Kosovo', 'EUR', 'Euro', 'Euros', '€', 1, 2, '+381', 0, 0), |
|
| 690 | + array('YT', 'MYT', 0, 'Mayotte', 'EUR', 'Euro', 'Euros', '€', 0, 2, '+262', 1, 0), |
|
| 691 | 691 | ); |
| 692 | 692 | global $wpdb; |
| 693 | 693 | $country_table = $wpdb->prefix."esp_country"; |
@@ -706,14 +706,14 @@ discard block |
||
| 706 | 706 | "CNT_is_EU" => '%d', |
| 707 | 707 | "CNT_active" => '%d', |
| 708 | 708 | ); |
| 709 | - if ( EEH_Activation::table_exists( $country_table ) ) { |
|
| 710 | - foreach( $newer_countries as $country ) { |
|
| 711 | - $SQL = "SELECT COUNT('CNT_ISO') FROM {$country_table} WHERE CNT_ISO='{$country[0]}' LIMIT 1" ; |
|
| 709 | + if (EEH_Activation::table_exists($country_table)) { |
|
| 710 | + foreach ($newer_countries as $country) { |
|
| 711 | + $SQL = "SELECT COUNT('CNT_ISO') FROM {$country_table} WHERE CNT_ISO='{$country[0]}' LIMIT 1"; |
|
| 712 | 712 | $countries = $wpdb->get_var($SQL); |
| 713 | - if ( ! $countries ) { |
|
| 713 | + if ( ! $countries) { |
|
| 714 | 714 | |
| 715 | - $wpdb->insert( $country_table, |
|
| 716 | - array_combine( array_keys( $country_format), $country ), |
|
| 715 | + $wpdb->insert($country_table, |
|
| 716 | + array_combine(array_keys($country_format), $country), |
|
| 717 | 717 | $country_format |
| 718 | 718 | ); |
| 719 | 719 | } |
@@ -731,7 +731,7 @@ discard block |
||
| 731 | 731 | // CUR_code, CUR_single, CUR_plural, CUR_sign, CUR_dec_plc, CUR_active |
| 732 | 732 | //( 'EUR', 'Euro', 'Euros', '€', 2,1), |
| 733 | 733 | $newer_currencies = array( |
| 734 | - array( 'RSD', 'Dinar', 'Dinars', '', 3, 1 ), |
|
| 734 | + array('RSD', 'Dinar', 'Dinars', '', 3, 1), |
|
| 735 | 735 | ); |
| 736 | 736 | global $wpdb; |
| 737 | 737 | $currency_table = $wpdb->prefix."esp_currency"; |
@@ -743,14 +743,14 @@ discard block |
||
| 743 | 743 | "CUR_dec_plc" => '%d', |
| 744 | 744 | "CUR_active" => '%d', |
| 745 | 745 | ); |
| 746 | - if ( EEH_Activation::table_exists( $currency_table ) ) { |
|
| 747 | - foreach( $newer_currencies as $currency ) { |
|
| 748 | - $SQL = "SELECT COUNT('CUR_code') FROM {$currency_table} WHERE CUR_code='{$currency[0]}' LIMIT 1" ; |
|
| 746 | + if (EEH_Activation::table_exists($currency_table)) { |
|
| 747 | + foreach ($newer_currencies as $currency) { |
|
| 748 | + $SQL = "SELECT COUNT('CUR_code') FROM {$currency_table} WHERE CUR_code='{$currency[0]}' LIMIT 1"; |
|
| 749 | 749 | $countries = $wpdb->get_var($SQL); |
| 750 | - if ( ! $countries ) { |
|
| 750 | + if ( ! $countries) { |
|
| 751 | 751 | |
| 752 | - $wpdb->insert( $currency_table, |
|
| 753 | - array_combine( array_keys( $currency_format), $currency ), |
|
| 752 | + $wpdb->insert($currency_table, |
|
| 753 | + array_combine(array_keys($currency_format), $currency), |
|
| 754 | 754 | $currency_format |
| 755 | 755 | ); |
| 756 | 756 | } |
@@ -762,9 +762,9 @@ discard block |
||
| 762 | 762 | * which should just be a temporary issue for folks who installed 4.8.0-4.8.5; |
| 763 | 763 | * we should be able to stop doing this in 4.9 |
| 764 | 764 | */ |
| 765 | - public function fix_non_default_taxes(){ |
|
| 765 | + public function fix_non_default_taxes() { |
|
| 766 | 766 | global $wpdb; |
| 767 | - $query = $wpdb->prepare( "UPDATE |
|
| 767 | + $query = $wpdb->prepare("UPDATE |
|
| 768 | 768 | {$wpdb->prefix}esp_price p INNER JOIN |
| 769 | 769 | {$wpdb->prefix}esp_price_type pt ON p.PRT_ID = pt.PRT_ID |
| 770 | 770 | SET |
@@ -772,7 +772,7 @@ discard block |
||
| 772 | 772 | WHERE |
| 773 | 773 | p.PRC_is_default = 0 AND |
| 774 | 774 | pt.PBT_ID = %d |
| 775 | - ", EEM_Price_Type::base_type_tax ); |
|
| 776 | - $wpdb->query( $query ); |
|
| 775 | + ", EEM_Price_Type::base_type_tax); |
|
| 776 | + $wpdb->query($query); |
|
| 777 | 777 | } |
| 778 | 778 | } |
@@ -17,7 +17,7 @@ |
||
| 17 | 17 | */ |
| 18 | 18 | /** |
| 19 | 19 | */ |
| 20 | -class EE_DMS_Unknown_1_0_0 extends EE_Data_Migration_Script_Base{ |
|
| 20 | +class EE_DMS_Unknown_1_0_0 extends EE_Data_Migration_Script_Base { |
|
| 21 | 21 | |
| 22 | 22 | /** |
| 23 | 23 | * Returns whether or not this data migration script can operate on the given version of the database. |
@@ -306,7 +306,7 @@ discard block |
||
| 306 | 306 | $records_migrated_during_stage = $stage->migration_step($num_records_to_migrate_limit - $num_records_actually_migrated); |
| 307 | 307 | $num_records_actually_migrated += $records_migrated_during_stage; |
| 308 | 308 | $records_migrated_per_stage[$stage->pretty_name()] = $records_migrated_during_stage; |
| 309 | - }catch(Exception $e){ |
|
| 309 | + } catch(Exception $e){ |
|
| 310 | 310 | //yes if we catch an exception here, we consider that migration stage borked. |
| 311 | 311 | $stage->set_status(EE_Data_Migration_Manager::status_fatal_error); |
| 312 | 312 | $this->set_status(EE_Data_Migration_Manager::status_fatal_error); |
@@ -332,14 +332,14 @@ discard block |
||
| 332 | 332 | //this migration script apparently has NO stages... which is super weird, but whatever |
| 333 | 333 | $this->set_completed(); |
| 334 | 334 | $this->_maybe_do_schema_changes(false); |
| 335 | - }else if( $num_records_actually_migrated < $num_records_to_migrate_limit && ! $stage->has_more_to_do()){ |
|
| 335 | + } else if( $num_records_actually_migrated < $num_records_to_migrate_limit && ! $stage->has_more_to_do()){ |
|
| 336 | 336 | //apparently we're done, because we couldn't migrate the number we intended to |
| 337 | 337 | $this->set_completed(); |
| 338 | 338 | $this->_update_feedback_message(array_reverse($records_migrated_per_stage)); |
| 339 | 339 | //do schema changes for after the migration now |
| 340 | 340 | //first double-check we haven't already done this |
| 341 | 341 | $this->_maybe_do_schema_changes(false); |
| 342 | - }else{ |
|
| 342 | + } else{ |
|
| 343 | 343 | //update feedback message, keeping in mind that we show them with the most recent at the top |
| 344 | 344 | $this->_update_feedback_message(array_reverse($records_migrated_per_stage)); |
| 345 | 345 | } |
@@ -378,12 +378,12 @@ discard block |
||
| 378 | 378 | ob_start(); |
| 379 | 379 | if($before){ |
| 380 | 380 | $this->schema_changes_before_migration(); |
| 381 | - }else{ |
|
| 381 | + } else{ |
|
| 382 | 382 | $this->schema_changes_after_migration(); |
| 383 | 383 | } |
| 384 | 384 | $output = ob_get_contents(); |
| 385 | 385 | ob_end_clean(); |
| 386 | - }catch(Exception $e){ |
|
| 386 | + } catch(Exception $e){ |
|
| 387 | 387 | $this->set_status(EE_Data_Migration_Manager::status_fatal_error); |
| 388 | 388 | throw $e; |
| 389 | 389 | } |
@@ -511,13 +511,13 @@ discard block |
||
| 511 | 511 | if( $table_is_new ) { |
| 512 | 512 | if( $this->_get_req_type_for_plugin_corresponding_to_this_dms() == EE_System::req_type_new_activation || $this->_currently_migrating() ){ |
| 513 | 513 | return true; |
| 514 | - }else{ |
|
| 514 | + } else{ |
|
| 515 | 515 | return false; |
| 516 | 516 | } |
| 517 | - }else{ |
|
| 517 | + } else{ |
|
| 518 | 518 | if(in_array($this->_get_req_type_for_plugin_corresponding_to_this_dms(),array(EE_System::req_type_new_activation))){ |
| 519 | 519 | return true; |
| 520 | - }else{ |
|
| 520 | + } else{ |
|
| 521 | 521 | return false; |
| 522 | 522 | } |
| 523 | 523 | } |
@@ -534,7 +534,7 @@ discard block |
||
| 534 | 534 | EE_Registry::instance()->load_helper('Activation'); |
| 535 | 535 | try{ |
| 536 | 536 | EEH_Activation::create_table($table_name,$table_definition_sql, $engine_string, $drop_pre_existing_tables); |
| 537 | - }catch( EE_Error $e ) { |
|
| 537 | + } catch( EE_Error $e ) { |
|
| 538 | 538 | $message = $e->getMessage() . '<br>Stack Trace:' . $e->getTraceAsString(); |
| 539 | 539 | $this->add_error( $message ); |
| 540 | 540 | $this->_feedback_message .= $message; |
@@ -551,11 +551,11 @@ discard block |
||
| 551 | 551 | private function _get_req_type_for_plugin_corresponding_to_this_dms(){ |
| 552 | 552 | if($this->slug() == 'Core'){ |
| 553 | 553 | return EE_System::instance()->detect_req_type(); |
| 554 | - }else{//it must be for an addon |
|
| 554 | + } else{//it must be for an addon |
|
| 555 | 555 | $addon_name = $this->slug(); |
| 556 | 556 | if( EE_Registry::instance()->get_addon_by_name($addon_name)){ |
| 557 | 557 | return EE_Registry::instance()->get_addon_by_name($addon_name)->detect_req_type(); |
| 558 | - }else{ |
|
| 558 | + } else{ |
|
| 559 | 559 | throw new EE_Error(sprintf(__("The DMS slug '%s' should correspond to the addon's name, which should also be '%s', but no such addon was registered. These are the registered addons' names: %s", "event_espresso"),$this->slug(),$addon_name,implode(",",array_keys( EE_Registry::instance()->get_addons_by_name() ) ) ) ) ; |
| 560 | 560 | } |
| 561 | 561 | } |
@@ -117,9 +117,9 @@ discard block |
||
| 117 | 117 | * All children of this must call parent::__construct() at the end of their constructor or suffer the consequences! |
| 118 | 118 | */ |
| 119 | 119 | public function __construct() { |
| 120 | - $this->_migration_stages = apply_filters('FHEE__'.get_class($this).'__construct__migration_stages',$this->_migration_stages); |
|
| 121 | - foreach($this->_migration_stages as $migration_stage){ |
|
| 122 | - if ( $migration_stage instanceof EE_Data_Migration_Script_Stage ) { |
|
| 120 | + $this->_migration_stages = apply_filters('FHEE__'.get_class($this).'__construct__migration_stages', $this->_migration_stages); |
|
| 121 | + foreach ($this->_migration_stages as $migration_stage) { |
|
| 122 | + if ($migration_stage instanceof EE_Data_Migration_Script_Stage) { |
|
| 123 | 123 | $migration_stage->_construct_finalize($this); |
| 124 | 124 | } |
| 125 | 125 | } |
@@ -132,7 +132,7 @@ discard block |
||
| 132 | 132 | * Place to add hooks and filters for tweaking the migrations page, in order |
| 133 | 133 | * to customize it |
| 134 | 134 | */ |
| 135 | - public function migration_page_hooks(){ |
|
| 135 | + public function migration_page_hooks() { |
|
| 136 | 136 | //by default none are added because we normally like the default look of the migration page |
| 137 | 137 | } |
| 138 | 138 | |
@@ -147,9 +147,9 @@ discard block |
||
| 147 | 147 | * @param int|string $new_pk eg posts.ID |
| 148 | 148 | * @return void |
| 149 | 149 | */ |
| 150 | - public function set_mapping($old_table,$old_pk,$new_table,$new_pk){ |
|
| 150 | + public function set_mapping($old_table, $old_pk, $new_table, $new_pk) { |
|
| 151 | 151 | //make sure it has the needed keys |
| 152 | - if( ! isset($this->_mappings[$old_table]) || ! isset($this->_mappings[$old_table][$new_table])){ |
|
| 152 | + if ( ! isset($this->_mappings[$old_table]) || ! isset($this->_mappings[$old_table][$new_table])) { |
|
| 153 | 153 | $this->_mappings[$old_table][$new_table] = $this->_get_mapping_option($old_table, $new_table); |
| 154 | 154 | } |
| 155 | 155 | $this->_mappings[$old_table][$new_table][$old_pk] = $new_pk; |
@@ -165,9 +165,9 @@ discard block |
||
| 165 | 165 | * @param string $new_table with wpdb prefix (wp_). Eg: wp_posts |
| 166 | 166 | * @return mixed the primary key on the new table |
| 167 | 167 | */ |
| 168 | - public function get_mapping_new_pk($old_table,$old_pk,$new_table){ |
|
| 169 | - if( ! isset($this->_mappings[$old_table]) || |
|
| 170 | - ! isset($this->_mappings[$old_table][$new_table])){ |
|
| 168 | + public function get_mapping_new_pk($old_table, $old_pk, $new_table) { |
|
| 169 | + if ( ! isset($this->_mappings[$old_table]) || |
|
| 170 | + ! isset($this->_mappings[$old_table][$new_table])) { |
|
| 171 | 171 | //try fetching the option |
| 172 | 172 | $this->_mappings[$old_table][$new_table] = $this->_get_mapping_option($old_table, $new_table); |
| 173 | 173 | } |
@@ -184,15 +184,15 @@ discard block |
||
| 184 | 184 | * @param mixed $new_pk |
| 185 | 185 | * @return mixed |
| 186 | 186 | */ |
| 187 | - public function get_mapping_old_pk($old_table,$new_table,$new_pk){ |
|
| 188 | - if( ! isset($this->_mappings[$old_table]) || |
|
| 189 | - ! isset($this->_mappings[$old_table][$new_table])){ |
|
| 187 | + public function get_mapping_old_pk($old_table, $new_table, $new_pk) { |
|
| 188 | + if ( ! isset($this->_mappings[$old_table]) || |
|
| 189 | + ! isset($this->_mappings[$old_table][$new_table])) { |
|
| 190 | 190 | //try fetching the option |
| 191 | 191 | $this->_mappings[$old_table][$new_table] = $this->_get_mapping_option($old_table, $new_table); |
| 192 | 192 | } |
| 193 | - if(isset($this->_mappings[$old_table][$new_table])){ |
|
| 193 | + if (isset($this->_mappings[$old_table][$new_table])) { |
|
| 194 | 194 | $new_pk_to_old_pk = array_flip($this->_mappings[$old_table][$new_table]); |
| 195 | - if(isset($new_pk_to_old_pk[$new_pk])){ |
|
| 195 | + if (isset($new_pk_to_old_pk[$new_pk])) { |
|
| 196 | 196 | return $new_pk_to_old_pk[$new_pk]; |
| 197 | 197 | } |
| 198 | 198 | } |
@@ -207,8 +207,8 @@ discard block |
||
| 207 | 207 | * @param string $new_table_name |
| 208 | 208 | * @return array |
| 209 | 209 | */ |
| 210 | - protected function _get_mapping_option($old_table_name,$new_table_name){ |
|
| 211 | - $option = get_option($this->_get_mapping_option_name($old_table_name, $new_table_name),array()); |
|
| 210 | + protected function _get_mapping_option($old_table_name, $new_table_name) { |
|
| 211 | + $option = get_option($this->_get_mapping_option_name($old_table_name, $new_table_name), array()); |
|
| 212 | 212 | return $option; |
| 213 | 213 | } |
| 214 | 214 | |
@@ -221,9 +221,9 @@ discard block |
||
| 221 | 221 | * @param array $mapping_array |
| 222 | 222 | * @return boolean success of updating option |
| 223 | 223 | */ |
| 224 | - protected function _set_mapping_option($old_table_name,$new_table_name,$mapping_array){ |
|
| 224 | + protected function _set_mapping_option($old_table_name, $new_table_name, $mapping_array) { |
|
| 225 | 225 | // echo "set mapping for $old_table_name $new_table_name".count($mapping_array)."<br>"; |
| 226 | - $success = update_option($this->_get_mapping_option_name($old_table_name, $new_table_name),$mapping_array); |
|
| 226 | + $success = update_option($this->_get_mapping_option_name($old_table_name, $new_table_name), $mapping_array); |
|
| 227 | 227 | return $success; |
| 228 | 228 | } |
| 229 | 229 | |
@@ -235,12 +235,12 @@ discard block |
||
| 235 | 235 | * @param string $new_table_name |
| 236 | 236 | * @return string |
| 237 | 237 | */ |
| 238 | - protected function _get_mapping_option_name($old_table_name,$new_table_name){ |
|
| 238 | + protected function _get_mapping_option_name($old_table_name, $new_table_name) { |
|
| 239 | 239 | global $wpdb; |
| 240 | - $old_table_name_sans_wp = str_replace($wpdb->prefix,"",$old_table_name); |
|
| 241 | - $new_table_name_sans_wp = str_replace($wpdb->prefix,"",$new_table_name); |
|
| 240 | + $old_table_name_sans_wp = str_replace($wpdb->prefix, "", $old_table_name); |
|
| 241 | + $new_table_name_sans_wp = str_replace($wpdb->prefix, "", $new_table_name); |
|
| 242 | 242 | $migrates_to = EE_Data_Migration_Manager::instance()->script_migrates_to_version(get_class($this)); |
| 243 | - return substr( EE_Data_Migration_Manager::data_migration_script_mapping_option_prefix . $migrates_to [ 'slug' ] . '_' . $migrates_to[ 'version' ] . '_' . $old_table_name_sans_wp . '_' . $new_table_name_sans_wp, 0, 64 ); |
|
| 243 | + return substr(EE_Data_Migration_Manager::data_migration_script_mapping_option_prefix.$migrates_to ['slug'].'_'.$migrates_to['version'].'_'.$old_table_name_sans_wp.'_'.$new_table_name_sans_wp, 0, 64); |
|
| 244 | 244 | } |
| 245 | 245 | |
| 246 | 246 | |
@@ -257,10 +257,10 @@ discard block |
||
| 257 | 257 | * 99% until the function "migration_step" returns EE_Data_Migration_Script_Base::status_complete. |
| 258 | 258 | * @return int |
| 259 | 259 | */ |
| 260 | - protected function _count_records_to_migrate(){ |
|
| 260 | + protected function _count_records_to_migrate() { |
|
| 261 | 261 | $count = 0; |
| 262 | - foreach($this->stages() as $stage){ |
|
| 263 | - $count+= $stage->count_records_to_migrate(); |
|
| 262 | + foreach ($this->stages() as $stage) { |
|
| 263 | + $count += $stage->count_records_to_migrate(); |
|
| 264 | 264 | } |
| 265 | 265 | return $count; |
| 266 | 266 | } |
@@ -272,10 +272,10 @@ discard block |
||
| 272 | 272 | * by just setting a transient and updating it after each migration_step |
| 273 | 273 | * @return int |
| 274 | 274 | */ |
| 275 | - public function count_records_migrated(){ |
|
| 275 | + public function count_records_migrated() { |
|
| 276 | 276 | $count = 0; |
| 277 | - foreach($this->stages() as $stage){ |
|
| 278 | - $count+= $stage->count_records_migrated(); |
|
| 277 | + foreach ($this->stages() as $stage) { |
|
| 278 | + $count += $stage->count_records_migrated(); |
|
| 279 | 279 | } |
| 280 | 280 | $this->_records_migrated = $count; |
| 281 | 281 | return $count; |
@@ -289,24 +289,24 @@ discard block |
||
| 289 | 289 | * @throws EE_Error |
| 290 | 290 | * @throws Exception |
| 291 | 291 | */ |
| 292 | - public function migration_step($num_records_to_migrate_limit){ |
|
| 292 | + public function migration_step($num_records_to_migrate_limit) { |
|
| 293 | 293 | //reset the feedback message |
| 294 | 294 | $this->_feedback_message = ''; |
| 295 | 295 | //if we haven't yet done the 1st schema changes, do them now. buffer any output |
| 296 | 296 | $this->_maybe_do_schema_changes(true); |
| 297 | 297 | |
| 298 | - $num_records_actually_migrated =0; |
|
| 298 | + $num_records_actually_migrated = 0; |
|
| 299 | 299 | $records_migrated_per_stage = array(); |
| 300 | 300 | //setup the 'stage' variable, which should hold the last run stage of the migration (or none at all if nothing runs) |
| 301 | 301 | $stage = null; |
| 302 | 302 | //get the next stage that isn't complete |
| 303 | - foreach($this->stages() as $stage){ |
|
| 304 | - if( $stage->get_status() == EE_Data_Migration_Manager::status_continue){ |
|
| 305 | - try{ |
|
| 303 | + foreach ($this->stages() as $stage) { |
|
| 304 | + if ($stage->get_status() == EE_Data_Migration_Manager::status_continue) { |
|
| 305 | + try { |
|
| 306 | 306 | $records_migrated_during_stage = $stage->migration_step($num_records_to_migrate_limit - $num_records_actually_migrated); |
| 307 | 307 | $num_records_actually_migrated += $records_migrated_during_stage; |
| 308 | 308 | $records_migrated_per_stage[$stage->pretty_name()] = $records_migrated_during_stage; |
| 309 | - }catch(Exception $e){ |
|
| 309 | + } catch (Exception $e) { |
|
| 310 | 310 | //yes if we catch an exception here, we consider that migration stage borked. |
| 311 | 311 | $stage->set_status(EE_Data_Migration_Manager::status_fatal_error); |
| 312 | 312 | $this->set_status(EE_Data_Migration_Manager::status_fatal_error); |
@@ -314,7 +314,7 @@ discard block |
||
| 314 | 314 | throw $e; |
| 315 | 315 | } |
| 316 | 316 | //check that the migration stage didn't mark itself as having a fatal error |
| 317 | - if($stage->is_broken()){ |
|
| 317 | + if ($stage->is_broken()) { |
|
| 318 | 318 | $this->set_broken(); |
| 319 | 319 | throw new EE_Error($stage->get_last_error()); |
| 320 | 320 | } |
@@ -322,24 +322,24 @@ discard block |
||
| 322 | 322 | //once we've migrated all the number we intended to (possibly from different stages), stop migrating |
| 323 | 323 | //or if we had a fatal error |
| 324 | 324 | //or if the current script stopped early- its not done, but it's done all it thinks we should do on this step |
| 325 | - if ($num_records_actually_migrated >= $num_records_to_migrate_limit || $stage->is_broken() || $stage->has_more_to_do()){ |
|
| 325 | + if ($num_records_actually_migrated >= $num_records_to_migrate_limit || $stage->is_broken() || $stage->has_more_to_do()) { |
|
| 326 | 326 | break; |
| 327 | 327 | } |
| 328 | 328 | } |
| 329 | 329 | //check if we're all done this data migration... |
| 330 | 330 | //which is indicated by being done early AND the last stage claims to be done |
| 331 | - if($stage == NULL){ |
|
| 331 | + if ($stage == NULL) { |
|
| 332 | 332 | //this migration script apparently has NO stages... which is super weird, but whatever |
| 333 | 333 | $this->set_completed(); |
| 334 | 334 | $this->_maybe_do_schema_changes(false); |
| 335 | - }else if( $num_records_actually_migrated < $num_records_to_migrate_limit && ! $stage->has_more_to_do()){ |
|
| 335 | + } else if ($num_records_actually_migrated < $num_records_to_migrate_limit && ! $stage->has_more_to_do()) { |
|
| 336 | 336 | //apparently we're done, because we couldn't migrate the number we intended to |
| 337 | 337 | $this->set_completed(); |
| 338 | 338 | $this->_update_feedback_message(array_reverse($records_migrated_per_stage)); |
| 339 | 339 | //do schema changes for after the migration now |
| 340 | 340 | //first double-check we haven't already done this |
| 341 | 341 | $this->_maybe_do_schema_changes(false); |
| 342 | - }else{ |
|
| 342 | + } else { |
|
| 343 | 343 | //update feedback message, keeping in mind that we show them with the most recent at the top |
| 344 | 344 | $this->_update_feedback_message(array_reverse($records_migrated_per_stage)); |
| 345 | 345 | } |
@@ -353,12 +353,12 @@ discard block |
||
| 353 | 353 | * @param array $records_migrated_per_stage KEYS are pretty names for each stage; values are the count of records migrated from that stage |
| 354 | 354 | * @return void |
| 355 | 355 | */ |
| 356 | - private function _update_feedback_message($records_migrated_per_stage){ |
|
| 356 | + private function _update_feedback_message($records_migrated_per_stage) { |
|
| 357 | 357 | $feedback_message_array = array(); |
| 358 | - foreach($records_migrated_per_stage as $migration_stage_name => $num_records_migrated){ |
|
| 359 | - $feedback_message_array[] = sprintf(__("Migrated %d records successfully during %s", "event_espresso"),$num_records_migrated,$migration_stage_name) ; |
|
| 358 | + foreach ($records_migrated_per_stage as $migration_stage_name => $num_records_migrated) { |
|
| 359 | + $feedback_message_array[] = sprintf(__("Migrated %d records successfully during %s", "event_espresso"), $num_records_migrated, $migration_stage_name); |
|
| 360 | 360 | } |
| 361 | - $this->_feedback_message .= implode("<br>",$feedback_message_array); |
|
| 361 | + $this->_feedback_message .= implode("<br>", $feedback_message_array); |
|
| 362 | 362 | } |
| 363 | 363 | |
| 364 | 364 | |
@@ -370,27 +370,27 @@ discard block |
||
| 370 | 370 | * @throws Exception |
| 371 | 371 | * @return void |
| 372 | 372 | */ |
| 373 | - private function _maybe_do_schema_changes($before = true){ |
|
| 373 | + private function _maybe_do_schema_changes($before = true) { |
|
| 374 | 374 | //so this property will be either _schema_changes_after_migration_ran or _schema_changes_before_migration_ran |
| 375 | - $property_name = '_schema_changes_'. ($before ? 'before' : 'after').'_migration_ran'; |
|
| 376 | - if ( ! $this->{$property_name} ){ |
|
| 377 | - try{ |
|
| 375 | + $property_name = '_schema_changes_'.($before ? 'before' : 'after').'_migration_ran'; |
|
| 376 | + if ( ! $this->{$property_name} ) { |
|
| 377 | + try { |
|
| 378 | 378 | ob_start(); |
| 379 | - if($before){ |
|
| 379 | + if ($before) { |
|
| 380 | 380 | $this->schema_changes_before_migration(); |
| 381 | - }else{ |
|
| 381 | + } else { |
|
| 382 | 382 | $this->schema_changes_after_migration(); |
| 383 | 383 | } |
| 384 | 384 | $output = ob_get_contents(); |
| 385 | 385 | ob_end_clean(); |
| 386 | - }catch(Exception $e){ |
|
| 386 | + } catch (Exception $e) { |
|
| 387 | 387 | $this->set_status(EE_Data_Migration_Manager::status_fatal_error); |
| 388 | 388 | throw $e; |
| 389 | 389 | } |
| 390 | 390 | //record that we've done these schema changes |
| 391 | 391 | $this->{$property_name} = true; |
| 392 | 392 | //if there were any warnings etc, record them as non-fatal errors |
| 393 | - if( $output ){ |
|
| 393 | + if ($output) { |
|
| 394 | 394 | //there were some warnings |
| 395 | 395 | $this->_errors[] = $output; |
| 396 | 396 | } |
@@ -417,9 +417,9 @@ discard block |
||
| 417 | 417 | * @param string $table_definition_sql |
| 418 | 418 | * @param string $engine_string |
| 419 | 419 | */ |
| 420 | - protected function _table_is_new_in_this_version($table_name,$table_definition_sql,$engine_string='ENGINE=InnoDB '){ |
|
| 420 | + protected function _table_is_new_in_this_version($table_name, $table_definition_sql, $engine_string = 'ENGINE=InnoDB ') { |
|
| 421 | 421 | // EEH_Debug_Tools::instance()->start_timer( '_table_is_new_in_this_version_' . $table_name ); |
| 422 | - $this->_create_table_and_catch_errors($table_name, $table_definition_sql, $engine_string, $this->_pre_existing_table_should_be_dropped( true ) ); |
|
| 422 | + $this->_create_table_and_catch_errors($table_name, $table_definition_sql, $engine_string, $this->_pre_existing_table_should_be_dropped(true)); |
|
| 423 | 423 | // EEH_Debug_Tools::instance()->stop_timer( '_table_is_new_in_this_version_' . $table_name ); |
| 424 | 424 | } |
| 425 | 425 | |
@@ -433,9 +433,9 @@ discard block |
||
| 433 | 433 | * @param string $table_definition_sql |
| 434 | 434 | * @param string $engine_string |
| 435 | 435 | */ |
| 436 | - protected function _table_is_changed_in_this_version($table_name,$table_definition_sql,$engine_string = 'ENGINE=MyISAM'){ |
|
| 436 | + protected function _table_is_changed_in_this_version($table_name, $table_definition_sql, $engine_string = 'ENGINE=MyISAM') { |
|
| 437 | 437 | // EEH_Debug_Tools::instance()->start_timer( '_table_is_changed_in_this_version' . $table_name ); |
| 438 | - $this->_create_table_and_catch_errors($table_name, $table_definition_sql, $engine_string, $this->_pre_existing_table_should_be_dropped( false ) ); |
|
| 438 | + $this->_create_table_and_catch_errors($table_name, $table_definition_sql, $engine_string, $this->_pre_existing_table_should_be_dropped(false)); |
|
| 439 | 439 | // EEH_Debug_Tools::instance()->stop_timer( '_table_is_changed_in_this_version' . $table_name ); |
| 440 | 440 | } |
| 441 | 441 | |
@@ -446,8 +446,8 @@ discard block |
||
| 446 | 446 | * @param string $table_name |
| 447 | 447 | * @return boolean |
| 448 | 448 | */ |
| 449 | - protected function _old_table_exists( $table_name ) { |
|
| 450 | - return EEH_Activation::table_exists( $table_name ); |
|
| 449 | + protected function _old_table_exists($table_name) { |
|
| 450 | + return EEH_Activation::table_exists($table_name); |
|
| 451 | 451 | } |
| 452 | 452 | |
| 453 | 453 | |
@@ -457,8 +457,8 @@ discard block |
||
| 457 | 457 | * @param string $table_name |
| 458 | 458 | * @return boolean |
| 459 | 459 | */ |
| 460 | - protected function _delete_table_if_empty( $table_name ) { |
|
| 461 | - return EEH_Activation::delete_db_table_if_empty( $table_name ); |
|
| 460 | + protected function _delete_table_if_empty($table_name) { |
|
| 461 | + return EEH_Activation::delete_db_table_if_empty($table_name); |
|
| 462 | 462 | } |
| 463 | 463 | |
| 464 | 464 | |
@@ -477,9 +477,9 @@ discard block |
||
| 477 | 477 | * @param string $table_definition_sql |
| 478 | 478 | * @param string $engine_string |
| 479 | 479 | */ |
| 480 | - protected function _table_should_exist_previously($table_name,$table_definition_sql,$engine_string = 'ENGINE=MyISAM'){ |
|
| 480 | + protected function _table_should_exist_previously($table_name, $table_definition_sql, $engine_string = 'ENGINE=MyISAM') { |
|
| 481 | 481 | // EEH_Debug_Tools::instance()->start_timer( '_table_should_exist_previously' . $table_name ); |
| 482 | - $this->_create_table_and_catch_errors($table_name, $table_definition_sql, $engine_string, $this->_pre_existing_table_should_be_dropped( false ) ); |
|
| 482 | + $this->_create_table_and_catch_errors($table_name, $table_definition_sql, $engine_string, $this->_pre_existing_table_should_be_dropped(false)); |
|
| 483 | 483 | // EEH_Debug_Tools::instance()->stop_timer( '_table_should_exist_previously' . $table_name ); |
| 484 | 484 | } |
| 485 | 485 | |
@@ -494,13 +494,13 @@ discard block |
||
| 494 | 494 | * @param string $table_definition_sql |
| 495 | 495 | * @param string $engine_string |
| 496 | 496 | */ |
| 497 | - protected function _table_has_not_changed_since_previous( $table_name,$table_definition_sql,$engine_string = 'ENGINE=MyISAM'){ |
|
| 498 | - if( $this->_currently_migrating() ) { |
|
| 497 | + protected function _table_has_not_changed_since_previous($table_name, $table_definition_sql, $engine_string = 'ENGINE=MyISAM') { |
|
| 498 | + if ($this->_currently_migrating()) { |
|
| 499 | 499 | //if we're doing a migration, and this table apparently already exists, then we don't need do anything right? |
| 500 | 500 | // EEH_Debug_Tools::instance()->stop_timer( '_table_should_exist_previously' . $table_name ); |
| 501 | 501 | return; |
| 502 | 502 | } |
| 503 | - $this->_create_table_and_catch_errors($table_name, $table_definition_sql, $engine_string, $this->_pre_existing_table_should_be_dropped( false ) ); |
|
| 503 | + $this->_create_table_and_catch_errors($table_name, $table_definition_sql, $engine_string, $this->_pre_existing_table_should_be_dropped(false)); |
|
| 504 | 504 | } |
| 505 | 505 | |
| 506 | 506 | /** |
@@ -510,7 +510,7 @@ discard block |
||
| 510 | 510 | protected function _currently_migrating() { |
| 511 | 511 | //we want to know if we are currently performing a migration. We could just believe what was set on the _migrating property, but let's double-check (ie the script should apply and we should be in MM) |
| 512 | 512 | return $this->_migrating && |
| 513 | - $this->can_migrate_from_version( EE_Data_Migration_Manager::instance()->ensure_current_database_state_is_set() ) && |
|
| 513 | + $this->can_migrate_from_version(EE_Data_Migration_Manager::instance()->ensure_current_database_state_is_set()) && |
|
| 514 | 514 | EE_Maintenance_Mode::instance()->real_level() == EE_Maintenance_Mode::level_2_complete_maintenance; |
| 515 | 515 | } |
| 516 | 516 | |
@@ -521,17 +521,17 @@ discard block |
||
| 521 | 521 | * @param boolean $table_is_new |
| 522 | 522 | * @return boolean |
| 523 | 523 | */ |
| 524 | - protected function _pre_existing_table_should_be_dropped( $table_is_new ) { |
|
| 525 | - if( $table_is_new ) { |
|
| 526 | - if( $this->_get_req_type_for_plugin_corresponding_to_this_dms() == EE_System::req_type_new_activation || $this->_currently_migrating() ){ |
|
| 524 | + protected function _pre_existing_table_should_be_dropped($table_is_new) { |
|
| 525 | + if ($table_is_new) { |
|
| 526 | + if ($this->_get_req_type_for_plugin_corresponding_to_this_dms() == EE_System::req_type_new_activation || $this->_currently_migrating()) { |
|
| 527 | 527 | return true; |
| 528 | - }else{ |
|
| 528 | + } else { |
|
| 529 | 529 | return false; |
| 530 | 530 | } |
| 531 | - }else{ |
|
| 532 | - if(in_array($this->_get_req_type_for_plugin_corresponding_to_this_dms(),array(EE_System::req_type_new_activation))){ |
|
| 531 | + } else { |
|
| 532 | + if (in_array($this->_get_req_type_for_plugin_corresponding_to_this_dms(), array(EE_System::req_type_new_activation))) { |
|
| 533 | 533 | return true; |
| 534 | - }else{ |
|
| 534 | + } else { |
|
| 535 | 535 | return false; |
| 536 | 536 | } |
| 537 | 537 | } |
@@ -544,12 +544,12 @@ discard block |
||
| 544 | 544 | * @param string $engine_string |
| 545 | 545 | * @param boolean $drop_pre_existing_tables |
| 546 | 546 | */ |
| 547 | - private function _create_table_and_catch_errors( $table_name, $table_definition_sql, $engine_string = 'ENGINE=MyISAM', $drop_pre_existing_tables = FALSE ){ |
|
| 548 | - try{ |
|
| 549 | - EEH_Activation::create_table($table_name,$table_definition_sql, $engine_string, $drop_pre_existing_tables); |
|
| 550 | - }catch( EE_Error $e ) { |
|
| 551 | - $message = $e->getMessage() . '<br>Stack Trace:' . $e->getTraceAsString(); |
|
| 552 | - $this->add_error( $message ); |
|
| 547 | + private function _create_table_and_catch_errors($table_name, $table_definition_sql, $engine_string = 'ENGINE=MyISAM', $drop_pre_existing_tables = FALSE) { |
|
| 548 | + try { |
|
| 549 | + EEH_Activation::create_table($table_name, $table_definition_sql, $engine_string, $drop_pre_existing_tables); |
|
| 550 | + } catch (EE_Error $e) { |
|
| 551 | + $message = $e->getMessage().'<br>Stack Trace:'.$e->getTraceAsString(); |
|
| 552 | + $this->add_error($message); |
|
| 553 | 553 | $this->_feedback_message .= $message; |
| 554 | 554 | } |
| 555 | 555 | } |
@@ -561,15 +561,15 @@ discard block |
||
| 561 | 561 | * @return int one of EE_System::_req_type_* constants |
| 562 | 562 | * @throws EE_Error |
| 563 | 563 | */ |
| 564 | - private function _get_req_type_for_plugin_corresponding_to_this_dms(){ |
|
| 565 | - if($this->slug() == 'Core'){ |
|
| 564 | + private function _get_req_type_for_plugin_corresponding_to_this_dms() { |
|
| 565 | + if ($this->slug() == 'Core') { |
|
| 566 | 566 | return EE_System::instance()->detect_req_type(); |
| 567 | - }else{//it must be for an addon |
|
| 567 | + } else {//it must be for an addon |
|
| 568 | 568 | $addon_name = $this->slug(); |
| 569 | - if( EE_Registry::instance()->get_addon_by_name($addon_name)){ |
|
| 569 | + if (EE_Registry::instance()->get_addon_by_name($addon_name)) { |
|
| 570 | 570 | return EE_Registry::instance()->get_addon_by_name($addon_name)->detect_req_type(); |
| 571 | - }else{ |
|
| 572 | - throw new EE_Error(sprintf(__("The DMS slug '%s' should correspond to the addon's name, which should also be '%s', but no such addon was registered. These are the registered addons' names: %s", "event_espresso"),$this->slug(),$addon_name,implode(",",array_keys( EE_Registry::instance()->get_addons_by_name() ) ) ) ) ; |
|
| 571 | + } else { |
|
| 572 | + throw new EE_Error(sprintf(__("The DMS slug '%s' should correspond to the addon's name, which should also be '%s', but no such addon was registered. These are the registered addons' names: %s", "event_espresso"), $this->slug(), $addon_name, implode(",", array_keys(EE_Registry::instance()->get_addons_by_name())))); |
|
| 573 | 573 | } |
| 574 | 574 | } |
| 575 | 575 | } |
@@ -580,13 +580,13 @@ discard block |
||
| 580 | 580 | * returns an array of strings describing errors by all the script's stages |
| 581 | 581 | * @return array |
| 582 | 582 | */ |
| 583 | - public function get_errors(){ |
|
| 583 | + public function get_errors() { |
|
| 584 | 584 | $all_errors = $this->_errors; |
| 585 | - if( ! is_array($all_errors)){ |
|
| 585 | + if ( ! is_array($all_errors)) { |
|
| 586 | 586 | $all_errors = array(); |
| 587 | 587 | } |
| 588 | - foreach($this->stages() as $stage){ |
|
| 589 | - $all_errors = array_merge($stage->get_errors(),$all_errors); |
|
| 588 | + foreach ($this->stages() as $stage) { |
|
| 589 | + $all_errors = array_merge($stage->get_errors(), $all_errors); |
|
| 590 | 590 | } |
| 591 | 591 | return $all_errors; |
| 592 | 592 | } |
@@ -597,8 +597,8 @@ discard block |
||
| 597 | 597 | * Indicates whether or not this migration script should continue |
| 598 | 598 | * @return boolean |
| 599 | 599 | */ |
| 600 | - public function can_continue(){ |
|
| 601 | - return in_array($this->get_status(), EE_Data_Migration_Manager::instance()->stati_that_indicate_to_continue_single_migration_script); |
|
| 600 | + public function can_continue() { |
|
| 601 | + return in_array($this->get_status(), EE_Data_Migration_Manager::instance()->stati_that_indicate_to_continue_single_migration_script); |
|
| 602 | 602 | } |
| 603 | 603 | |
| 604 | 604 | |
@@ -610,8 +610,8 @@ discard block |
||
| 610 | 610 | * get ordered by the indexes |
| 611 | 611 | * @return EE_Data_Migration_Script_Stage[] |
| 612 | 612 | */ |
| 613 | - protected function stages(){ |
|
| 614 | - $stages = apply_filters( 'FHEE__'.get_class($this).'__stages',$this->_migration_stages ); |
|
| 613 | + protected function stages() { |
|
| 614 | + $stages = apply_filters('FHEE__'.get_class($this).'__stages', $this->_migration_stages); |
|
| 615 | 615 | ksort($stages); |
| 616 | 616 | return $stages; |
| 617 | 617 | } |
@@ -623,7 +623,7 @@ discard block |
||
| 623 | 623 | * can be displayed to the user |
| 624 | 624 | * @return string |
| 625 | 625 | */ |
| 626 | - public function get_feedback_message(){ |
|
| 626 | + public function get_feedback_message() { |
|
| 627 | 627 | return $this->_feedback_message; |
| 628 | 628 | } |
| 629 | 629 | |
@@ -635,16 +635,16 @@ discard block |
||
| 635 | 635 | * possible that this class is defined when it goes to sleep, but NOT available when it |
| 636 | 636 | * awakes (eg, this class is part of an addon that is deactivated at some point). |
| 637 | 637 | */ |
| 638 | - public function properties_as_array(){ |
|
| 638 | + public function properties_as_array() { |
|
| 639 | 639 | $properties = parent::properties_as_array(); |
| 640 | 640 | $properties['_migration_stages'] = array(); |
| 641 | - foreach($this->_migration_stages as $migration_stage_priority => $migration_stage_class){ |
|
| 641 | + foreach ($this->_migration_stages as $migration_stage_priority => $migration_stage_class) { |
|
| 642 | 642 | $properties['_migration_stages'][$migration_stage_priority] = $migration_stage_class->properties_as_array(); |
| 643 | 643 | } |
| 644 | 644 | unset($properties['_mappings']); |
| 645 | 645 | |
| 646 | - foreach($this->_mappings as $old_table_name => $mapping_to_new_table){ |
|
| 647 | - foreach($mapping_to_new_table as $new_table_name => $mapping){ |
|
| 646 | + foreach ($this->_mappings as $old_table_name => $mapping_to_new_table) { |
|
| 647 | + foreach ($mapping_to_new_table as $new_table_name => $mapping) { |
|
| 648 | 648 | $this->_set_mapping_option($old_table_name, $new_table_name, $mapping); |
| 649 | 649 | } |
| 650 | 650 | } |
@@ -659,19 +659,19 @@ discard block |
||
| 659 | 659 | * @param array $array_of_properties like what's produced from properties_as_array() method |
| 660 | 660 | * @return void |
| 661 | 661 | */ |
| 662 | - public function instantiate_from_array_of_properties($array_of_properties){ |
|
| 662 | + public function instantiate_from_array_of_properties($array_of_properties) { |
|
| 663 | 663 | $stages_properties_arrays = $array_of_properties['_migration_stages']; |
| 664 | 664 | unset($array_of_properties['_migration_stages']); |
| 665 | 665 | unset($array_of_properties['class']); |
| 666 | - foreach($array_of_properties as $property_name => $property_value){ |
|
| 666 | + foreach ($array_of_properties as $property_name => $property_value) { |
|
| 667 | 667 | $this->{$property_name} = $property_value; |
| 668 | 668 | } |
| 669 | 669 | //_migration_stages are already instantiated, but have only default data |
| 670 | - foreach($this->_migration_stages as $stage){ |
|
| 671 | - $stage_data = $this->_find_migration_stage_data_with_classname(get_class($stage),$stages_properties_arrays); |
|
| 670 | + foreach ($this->_migration_stages as $stage) { |
|
| 671 | + $stage_data = $this->_find_migration_stage_data_with_classname(get_class($stage), $stages_properties_arrays); |
|
| 672 | 672 | //SO, if we found the stage data that was saved, use it. Otherwise, I guess the stage is new? (maybe added by |
| 673 | 673 | //an addon? Unlikely... not sure why it wouldn't exist, but if it doesn't just treat it like it was never started yet) |
| 674 | - if($stage_data){ |
|
| 674 | + if ($stage_data) { |
|
| 675 | 675 | $stage->instantiate_from_array_of_properties($stage_data); |
| 676 | 676 | } |
| 677 | 677 | } |
@@ -687,9 +687,9 @@ discard block |
||
| 687 | 687 | * @param array $migration_stage_data_arrays |
| 688 | 688 | * @return null |
| 689 | 689 | */ |
| 690 | - private function _find_migration_stage_data_with_classname($classname,$migration_stage_data_arrays){ |
|
| 691 | - foreach($migration_stage_data_arrays as $migration_stage_data_array){ |
|
| 692 | - if(isset($migration_stage_data_array['class']) && $migration_stage_data_array['class'] == $classname){ |
|
| 690 | + private function _find_migration_stage_data_with_classname($classname, $migration_stage_data_arrays) { |
|
| 691 | + foreach ($migration_stage_data_arrays as $migration_stage_data_array) { |
|
| 692 | + if (isset($migration_stage_data_array['class']) && $migration_stage_data_array['class'] == $classname) { |
|
| 693 | 693 | return $migration_stage_data_array; |
| 694 | 694 | } |
| 695 | 695 | } |
@@ -705,8 +705,8 @@ discard block |
||
| 705 | 705 | * @return array where the first key is the plugin's slug, the 2nd is the version of that plugin |
| 706 | 706 | * that will be updated to. Eg array('Core','4.1.0') |
| 707 | 707 | */ |
| 708 | - public final function migrates_to_version(){ |
|
| 709 | - return EE_Data_Migration_Manager::instance()->script_migrates_to_version( get_class( $this ) ); |
|
| 708 | + public final function migrates_to_version() { |
|
| 709 | + return EE_Data_Migration_Manager::instance()->script_migrates_to_version(get_class($this)); |
|
| 710 | 710 | } |
| 711 | 711 | |
| 712 | 712 | |
@@ -718,10 +718,10 @@ discard block |
||
| 718 | 718 | * Or 'Core' for core (non-addon). |
| 719 | 719 | * @return string |
| 720 | 720 | */ |
| 721 | - public function slug(){ |
|
| 721 | + public function slug() { |
|
| 722 | 722 | $migrates_to_version_info = $this->migrates_to_version(); |
| 723 | 723 | //the slug is the first part of the array |
| 724 | - return $migrates_to_version_info[ 'slug' ]; |
|
| 724 | + return $migrates_to_version_info['slug']; |
|
| 725 | 725 | } |
| 726 | 726 | |
| 727 | 727 | |
@@ -735,7 +735,7 @@ discard block |
||
| 735 | 735 | * the database up so it can run), then you can set "A" to priority 3 or something. |
| 736 | 736 | * @return int |
| 737 | 737 | */ |
| 738 | - public function priority(){ |
|
| 738 | + public function priority() { |
|
| 739 | 739 | return $this->_priority; |
| 740 | 740 | } |
| 741 | 741 | |
@@ -748,18 +748,18 @@ discard block |
||
| 748 | 748 | * @param boolean $migrating |
| 749 | 749 | * @return void |
| 750 | 750 | */ |
| 751 | - public function set_migrating( $migrating = TRUE ){ |
|
| 751 | + public function set_migrating($migrating = TRUE) { |
|
| 752 | 752 | $this->_migrating = $migrating; |
| 753 | 753 | } |
| 754 | 754 | |
| 755 | 755 | /** |
| 756 | 756 | * Marks that we think this migration class can continue to migrate |
| 757 | 757 | */ |
| 758 | - public function reattempt(){ |
|
| 758 | + public function reattempt() { |
|
| 759 | 759 | parent::reattempt(); |
| 760 | 760 | //also, we want to reattempt any stages that were marked as borked |
| 761 | - foreach( $this->stages() as $stage ) { |
|
| 762 | - if( $stage->is_broken() ) { |
|
| 761 | + foreach ($this->stages() as $stage) { |
|
| 762 | + if ($stage->is_broken()) { |
|
| 763 | 763 | $stage->reattempt(); |
| 764 | 764 | } |
| 765 | 765 | } |
@@ -34,7 +34,7 @@ discard block |
||
| 34 | 34 | * _migration_step() (ie, it its a count of rows in the old attendees table in _count_records_to_migrate(), it should also be OLD attendee rows migrated |
| 35 | 35 | * on each call to _migration_step(). |
| 36 | 36 | */ |
| 37 | -abstract class EE_Data_Migration_Script_Stage extends EE_Data_Migration_Class_Base{ |
|
| 37 | +abstract class EE_Data_Migration_Script_Stage extends EE_Data_Migration_Class_Base { |
|
| 38 | 38 | /** |
| 39 | 39 | * The migration script this is a stage of |
| 40 | 40 | * @var EE_Data_Migration_Script_Base |
@@ -47,7 +47,7 @@ discard block |
||
| 47 | 47 | * called by EE_Data_Migration_Script_Base's __construct() method so children don't have to |
| 48 | 48 | * @param EE_Data_Migration_Script_Base $migration_script |
| 49 | 49 | */ |
| 50 | - public function _construct_finalize($migration_script){ |
|
| 50 | + public function _construct_finalize($migration_script) { |
|
| 51 | 51 | $this->_migration_script = $migration_script; |
| 52 | 52 | } |
| 53 | 53 | |
@@ -58,13 +58,13 @@ discard block |
||
| 58 | 58 | * @param int $num_items_to_migrate |
| 59 | 59 | * @return int |
| 60 | 60 | */ |
| 61 | - public function migration_step($num_items_to_migrate=50){ |
|
| 61 | + public function migration_step($num_items_to_migrate = 50) { |
|
| 62 | 62 | //before we run the migration step, we want ot take note of warnings that get outputted |
| 63 | 63 | ob_start(); |
| 64 | 64 | $items_migrated = $this->_migration_step($num_items_to_migrate); |
| 65 | 65 | $output = ob_get_contents(); |
| 66 | 66 | ob_end_clean(); |
| 67 | - if( $output ){ |
|
| 67 | + if ($output) { |
|
| 68 | 68 | $this->add_error($output); |
| 69 | 69 | } |
| 70 | 70 | $this->_records_migrated += $items_migrated; |
@@ -82,7 +82,7 @@ discard block |
||
| 82 | 82 | * @param int $num_items_to_migrate |
| 83 | 83 | * @return int number of items ACTUALLY migrated |
| 84 | 84 | */ |
| 85 | - abstract protected function _migration_step($num_items_to_migrate=50); |
|
| 85 | + abstract protected function _migration_step($num_items_to_migrate = 50); |
|
| 86 | 86 | |
| 87 | 87 | /** |
| 88 | 88 | * Counts the records that have been migrated so far |
@@ -96,7 +96,7 @@ discard block |
||
| 96 | 96 | * returns an array of strings describing errors |
| 97 | 97 | * @return array |
| 98 | 98 | */ |
| 99 | - public function get_errors(){ |
|
| 99 | + public function get_errors() { |
|
| 100 | 100 | return $this->_errors; |
| 101 | 101 | } |
| 102 | 102 | |
@@ -106,9 +106,9 @@ discard block |
||
| 106 | 106 | * to have been made from the properties_as_array() function. |
| 107 | 107 | * @param array $array_of_properties like what's produced from properties_as_array() method |
| 108 | 108 | */ |
| 109 | - public function instantiate_from_array_of_properties($array_of_properties){ |
|
| 109 | + public function instantiate_from_array_of_properties($array_of_properties) { |
|
| 110 | 110 | unset($array_of_properties['class']); |
| 111 | - foreach($array_of_properties as $property_name => $property_value){ |
|
| 111 | + foreach ($array_of_properties as $property_name => $property_value) { |
|
| 112 | 112 | $this->$property_name = $property_value; |
| 113 | 113 | } |
| 114 | 114 | } |
@@ -117,7 +117,7 @@ discard block |
||
| 117 | 117 | * Gets the script this is a stage of |
| 118 | 118 | * @return EE_Data_Migration_Script_Base |
| 119 | 119 | */ |
| 120 | - protected function get_migration_script(){ |
|
| 120 | + protected function get_migration_script() { |
|
| 121 | 121 | return $this->_migration_script; |
| 122 | 122 | } |
| 123 | 123 | } |