@@ -245,7 +245,6 @@ |
||
245 | 245 | /** |
246 | 246 | * Creates a 4.1 member price discount |
247 | 247 | * @global type $wpdb |
248 | - * @param type $old_price |
|
249 | 248 | * @return int |
250 | 249 | */ |
251 | 250 | private function _insert_new_global_surcharge_price($org_options){ |
@@ -191,7 +191,7 @@ |
||
191 | 191 | $c->organization->logo_url = $value;break; |
192 | 192 | case 'event_page_id': |
193 | 193 | |
194 | - //also, find that post, and changes the shortcode in it from ESPRESSO_PAYMENTS |
|
194 | + //also, find that post, and changes the shortcode in it from ESPRESSO_PAYMENTS |
|
195 | 195 | //to ESPRESSO_THANK_YOU |
196 | 196 | $reg_page_post = get_post($value); |
197 | 197 | $reg_page_post->post_content = str_replace("[ESPRESSO_EVENTS]","[ESPRESSO_CHECKOUT]",$reg_page_post->post_content); |
@@ -100,30 +100,30 @@ discard block |
||
100 | 100 | * |
101 | 101 | * @todo: inform clients that messages have COMPLETELY changed in 4.1; themeroller isn't in there; event list page is no more; |
102 | 102 | */ |
103 | -class EE_DMS_4_1_0_org_options extends EE_Data_Migration_Script_Stage{ |
|
103 | +class EE_DMS_4_1_0_org_options extends EE_Data_Migration_Script_Stage { |
|
104 | 104 | |
105 | - function _migration_step($num_items=50){ |
|
105 | + function _migration_step($num_items = 50) { |
|
106 | 106 | |
107 | 107 | $items_actually_migrated = 0; |
108 | 108 | $old_org_options = get_option('events_organization_settings'); |
109 | - foreach($this->_org_options_we_know_how_to_migrate as $option_name){ |
|
109 | + foreach ($this->_org_options_we_know_how_to_migrate as $option_name) { |
|
110 | 110 | //only bother migrating if there's a setting to migrate. Otherwise we'll just use the default |
111 | - if(isset($old_org_options[$option_name])){ |
|
111 | + if (isset($old_org_options[$option_name])) { |
|
112 | 112 | $this->_handle_org_option($option_name, $old_org_options[$option_name]); |
113 | 113 | } |
114 | - if($option_name=='surcharge'){ |
|
114 | + if ($option_name == 'surcharge') { |
|
115 | 115 | $this->_insert_new_global_surcharge_price($old_org_options); |
116 | 116 | } |
117 | 117 | $items_actually_migrated++; |
118 | 118 | } |
119 | 119 | |
120 | - $success = EE_Config::instance()->update_espresso_config(FALSE,TRUE); |
|
121 | - if( ! $success ) { |
|
122 | - $this->add_error( sprintf( __( 'Could not save EE Config during org options stage. Reason: %s', 'event_espresso' ), EE_Error::get_notices( FALSE )) ); |
|
120 | + $success = EE_Config::instance()->update_espresso_config(FALSE, TRUE); |
|
121 | + if ( ! $success) { |
|
122 | + $this->add_error(sprintf(__('Could not save EE Config during org options stage. Reason: %s', 'event_espresso'), EE_Error::get_notices(FALSE))); |
|
123 | 123 | EE_Error::overwrite_errors(); |
124 | 124 | } |
125 | - EE_Network_Config::instance()->update_config(FALSE,FALSE); |
|
126 | - if($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()){ |
|
125 | + EE_Network_Config::instance()->update_config(FALSE, FALSE); |
|
126 | + if ($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()) { |
|
127 | 127 | //we may have added new pages and this might be necessary |
128 | 128 | flush_rewrite_rules(); |
129 | 129 | $this->set_completed(); |
@@ -136,65 +136,65 @@ discard block |
||
136 | 136 | } |
137 | 137 | function __construct() { |
138 | 138 | $this->_pretty_name = __("Organization Options/Config", "event_espresso"); |
139 | - $this->_org_options_we_know_how_to_migrate = apply_filters( 'FHEE__EE_DMS_4_1_0_org_options__org_options_we_know_how_to_migrate',$this->_org_options_we_know_how_to_migrate ); |
|
139 | + $this->_org_options_we_know_how_to_migrate = apply_filters('FHEE__EE_DMS_4_1_0_org_options__org_options_we_know_how_to_migrate', $this->_org_options_we_know_how_to_migrate); |
|
140 | 140 | parent::__construct(); |
141 | 141 | } |
142 | 142 | |
143 | - private function _handle_org_option($option_name,$value){ |
|
143 | + private function _handle_org_option($option_name, $value) { |
|
144 | 144 | $c = EE_Config::instance(); |
145 | 145 | $cn = EE_Network_Config::instance(); |
146 | - switch($option_name){ |
|
146 | + switch ($option_name) { |
|
147 | 147 | case 'organization': |
148 | - $c->organization->name = $value;break; |
|
148 | + $c->organization->name = $value; break; |
|
149 | 149 | case 'organization_street1': |
150 | - $c->organization->address_1 = $value;break; |
|
150 | + $c->organization->address_1 = $value; break; |
|
151 | 151 | case 'organization_street2': |
152 | - $c->organization->address_2 = $value;break; |
|
152 | + $c->organization->address_2 = $value; break; |
|
153 | 153 | case 'organization_city': |
154 | - $c->organization->city = $value;break; |
|
154 | + $c->organization->city = $value; break; |
|
155 | 155 | case 'organization_state': |
156 | - try{ |
|
156 | + try { |
|
157 | 157 | $state = $this->get_migration_script()->get_or_create_state($value); |
158 | 158 | $state_id = $state['STA_ID']; |
159 | 159 | $c->organization->STA_ID = $state_id; |
160 | - }catch(EE_Error $e){}break; |
|
160 | + } catch (EE_Error $e) {}break; |
|
161 | 161 | case 'organization_zip': |
162 | - $c->organization->zip = $value;break; |
|
162 | + $c->organization->zip = $value; break; |
|
163 | 163 | case 'contact_email': |
164 | - $c->organization->email = $value;break; |
|
164 | + $c->organization->email = $value; break; |
|
165 | 165 | case 'default_payment_status': |
166 | - $c->registration->default_STS_ID = $this->get_migration_script()->convert_3_1_payment_status_to_4_1_STS_ID($value);break; |
|
166 | + $c->registration->default_STS_ID = $this->get_migration_script()->convert_3_1_payment_status_to_4_1_STS_ID($value); break; |
|
167 | 167 | case 'organization_country': |
168 | - $iso =$this->get_migration_script()->get_iso_from_3_1_country_id($value); |
|
168 | + $iso = $this->get_migration_script()->get_iso_from_3_1_country_id($value); |
|
169 | 169 | $c->organization->CNT_ISO = $iso; |
170 | 170 | $country_row = $this->get_migration_script()->get_or_create_country($iso); |
171 | - if( ! $country_row){ |
|
172 | - $this->add_error(sprintf(__("Could not set country's currency config because no country exists for ISO %s", "event_espresso"),$iso)); |
|
171 | + if ( ! $country_row) { |
|
172 | + $this->add_error(sprintf(__("Could not set country's currency config because no country exists for ISO %s", "event_espresso"), $iso)); |
|
173 | 173 | } |
174 | 174 | //can't use EE_Currency_Config's handy constructor because the models are off-limits right now (and it uses them) |
175 | - $c->currency->code = $country_row['CNT_cur_code']; // currency code: USD, CAD, EUR |
|
176 | - $c->currency->name = $country_row['CNT_cur_single']; // Dollar |
|
177 | - $c->currency->plural = $country_row['CNT_cur_plural']; // Dollars |
|
178 | - $c->currency->sign = $country_row['CNT_cur_sign']; // currency sign: $ |
|
179 | - $c->currency->sign_b4 = intval($country_row['CNT_cur_sign_b4']); // currency sign before or after: $TRUE or FALSE$ |
|
180 | - $c->currency->dec_plc = intval($country_row['CNT_cur_dec_plc']); // decimal places: 2 = 0.00 3 = 0.000 |
|
181 | - $c->currency->dec_mrk = $country_row['CNT_cur_dec_mrk']; // decimal mark: (comma) ',' = 0,01 or (decimal) '.' = 0.01 |
|
182 | - $c->currency->thsnds = $country_row['CNT_cur_thsnds']; // thousands separator: (comma) ',' = 1,000 or (decimal) '.' = 1.000 |
|
175 | + $c->currency->code = $country_row['CNT_cur_code']; // currency code: USD, CAD, EUR |
|
176 | + $c->currency->name = $country_row['CNT_cur_single']; // Dollar |
|
177 | + $c->currency->plural = $country_row['CNT_cur_plural']; // Dollars |
|
178 | + $c->currency->sign = $country_row['CNT_cur_sign']; // currency sign: $ |
|
179 | + $c->currency->sign_b4 = intval($country_row['CNT_cur_sign_b4']); // currency sign before or after: $TRUE or FALSE$ |
|
180 | + $c->currency->dec_plc = intval($country_row['CNT_cur_dec_plc']); // decimal places: 2 = 0.00 3 = 0.000 |
|
181 | + $c->currency->dec_mrk = $country_row['CNT_cur_dec_mrk']; // decimal mark: (comma) ',' = 0,01 or (decimal) '.' = 0.01 |
|
182 | + $c->currency->thsnds = $country_row['CNT_cur_thsnds']; // thousands separator: (comma) ',' = 1,000 or (decimal) '.' = 1.000 |
|
183 | 183 | // $c->currency = new EE_Currency_Config($c->organization->CNT_ISO);break; |
184 | 184 | // case 'currency_symbol': ignore the currency symbol. we'll just go by their country. |
185 | 185 | // $c->currency->sign = $value;break; |
186 | 186 | case 'show_pending_payment_options': |
187 | - $c->registration->show_pending_payment_options = ($value == 'Y');break; |
|
187 | + $c->registration->show_pending_payment_options = ($value == 'Y'); break; |
|
188 | 188 | case 'display_address_in_regform': |
189 | - $c->template_settings->display_address_in_regform = ($value == 'Y');break; |
|
189 | + $c->template_settings->display_address_in_regform = ($value == 'Y'); break; |
|
190 | 190 | case 'default_logo_url': |
191 | - $c->organization->logo_url = $value;break; |
|
191 | + $c->organization->logo_url = $value; break; |
|
192 | 192 | case 'event_page_id': |
193 | 193 | |
194 | 194 | //also, find that post, and changes the shortcode in it from ESPRESSO_PAYMENTS |
195 | 195 | //to ESPRESSO_THANK_YOU |
196 | 196 | $reg_page_post = get_post($value); |
197 | - $reg_page_post->post_content = str_replace("[ESPRESSO_EVENTS]","[ESPRESSO_CHECKOUT]",$reg_page_post->post_content); |
|
197 | + $reg_page_post->post_content = str_replace("[ESPRESSO_EVENTS]", "[ESPRESSO_CHECKOUT]", $reg_page_post->post_content); |
|
198 | 198 | wp_update_post($reg_page_post); |
199 | 199 | $c->core->reg_page_id = $value; |
200 | 200 | break; |
@@ -202,7 +202,7 @@ discard block |
||
202 | 202 | //also, find that post, and changes the shortcode in it from ESPRESSO_PAYMENTS |
203 | 203 | //to ESPRESSO_THANK_YOU |
204 | 204 | $thank_you_page_post = get_post($value); |
205 | - $thank_you_page_post->post_content = str_replace("[ESPRESSO_PAYMENTS]","[ESPRESSO_THANK_YOU]",$thank_you_page_post->post_content); |
|
205 | + $thank_you_page_post->post_content = str_replace("[ESPRESSO_PAYMENTS]", "[ESPRESSO_THANK_YOU]", $thank_you_page_post->post_content); |
|
206 | 206 | wp_update_post($thank_you_page_post); |
207 | 207 | $c->core->thank_you_page_id = $value; |
208 | 208 | break; |
@@ -216,15 +216,15 @@ discard block |
||
216 | 216 | case 'use_captcha': |
217 | 217 | $c->registration->use_captcha = ($value == 'Y'); break; |
218 | 218 | case 'recaptcha_publickey': |
219 | - $c->registration->recaptcha_publickey = $value;break; |
|
219 | + $c->registration->recaptcha_publickey = $value; break; |
|
220 | 220 | case 'recaptcha_privatekey': |
221 | - $c->registration->recaptcha_privatekey = $value;break; |
|
221 | + $c->registration->recaptcha_privatekey = $value; break; |
|
222 | 222 | case 'recaptcha_theme': |
223 | - $c->registration->recaptcha_theme = $value;break; |
|
223 | + $c->registration->recaptcha_theme = $value; break; |
|
224 | 224 | case 'recaptcha_width': |
225 | - $c->registration->recaptcha_width = $value;break; |
|
225 | + $c->registration->recaptcha_width = $value; break; |
|
226 | 226 | case 'recaptcha_language': |
227 | - $c->registration->recaptcha_language = $value;break; |
|
227 | + $c->registration->recaptcha_language = $value; break; |
|
228 | 228 | case 'espresso_dashboard_widget': |
229 | 229 | $c->admin->use_dashboard_widget = ($value == 'Y'); break; |
230 | 230 | case 'use_personnel_manager': |
@@ -232,13 +232,13 @@ discard block |
||
232 | 232 | case 'use_event_timezones': |
233 | 233 | $c->admin->use_event_timezones = ($value == 'Y'); break; |
234 | 234 | case 'full_logging': |
235 | - $c->admin->use_full_logging = ($value == 'Y');break; |
|
235 | + $c->admin->use_full_logging = ($value == 'Y'); break; |
|
236 | 236 | case 'affiliate_id': |
237 | - $c->admin->affiliate_id = $value;break; |
|
237 | + $c->admin->affiliate_id = $value; break; |
|
238 | 238 | case 'site_license_key': |
239 | - $cn->core->site_license_key = $value;break; |
|
239 | + $cn->core->site_license_key = $value; break; |
|
240 | 240 | default: |
241 | - do_action( 'AHEE__EE_DMS_4_1_0__handle_org_option',$option_name,$value ); |
|
241 | + do_action('AHEE__EE_DMS_4_1_0__handle_org_option', $option_name, $value); |
|
242 | 242 | } |
243 | 243 | } |
244 | 244 | |
@@ -248,15 +248,15 @@ discard block |
||
248 | 248 | * @param type $old_price |
249 | 249 | * @return int |
250 | 250 | */ |
251 | - private function _insert_new_global_surcharge_price($org_options){ |
|
251 | + private function _insert_new_global_surcharge_price($org_options) { |
|
252 | 252 | $amount = floatval($org_options['surcharge']); |
253 | 253 | //dont createa a price if the surcharge is 0 |
254 | - if($amount <=.01){ |
|
254 | + if ($amount <= .01) { |
|
255 | 255 | return 0; |
256 | 256 | } |
257 | - if($org_options['surcharge_type'] == 'flat_rate'){ |
|
257 | + if ($org_options['surcharge_type'] == 'flat_rate') { |
|
258 | 258 | $price_type = EE_DMS_4_1_0_prices::price_type_flat_surcharge; |
259 | - }else{ |
|
259 | + } else { |
|
260 | 260 | $price_type = EE_DMS_4_1_0_prices::price_type_percent_surcharge; |
261 | 261 | } |
262 | 262 | global $wpdb; |
@@ -272,18 +272,18 @@ discard block |
||
272 | 272 | |
273 | 273 | ); |
274 | 274 | $datatypes = array( |
275 | - '%d',//PRT_ID |
|
276 | - '%f',//PRT_amount |
|
277 | - '%s',//PRC_name |
|
278 | - '%d',//PRC_is_default |
|
279 | - '%d',//PRC_overrides |
|
280 | - '%d',//PRC_order |
|
281 | - '%d',//PRC_deleted |
|
282 | - '%d',//PRC_parent |
|
275 | + '%d', //PRT_ID |
|
276 | + '%f', //PRT_amount |
|
277 | + '%s', //PRC_name |
|
278 | + '%d', //PRC_is_default |
|
279 | + '%d', //PRC_overrides |
|
280 | + '%d', //PRC_order |
|
281 | + '%d', //PRC_deleted |
|
282 | + '%d', //PRC_parent |
|
283 | 283 | ); |
284 | 284 | $price_table = $wpdb->prefix."esp_price"; |
285 | - $success = $wpdb->insert($price_table,$cols_n_values,$datatypes); |
|
286 | - if ( ! $success){ |
|
285 | + $success = $wpdb->insert($price_table, $cols_n_values, $datatypes); |
|
286 | + if ( ! $success) { |
|
287 | 287 | $this->add_error($this->get_migration_script()->_create_error_message_for_db_insertion('org_options', |
288 | 288 | array( |
289 | 289 | 'surcharge'=>$org_options['surcharge'], |
@@ -308,8 +308,8 @@ discard block |
||
308 | 308 | 'payment_message', |
309 | 309 | 'message', |
310 | 310 | 'default_payment_status', |
311 | - 'surcharge',//unused? |
|
312 | - 'country_id',//unused? |
|
311 | + 'surcharge', //unused? |
|
312 | + 'country_id', //unused? |
|
313 | 313 | 'organization_country', |
314 | 314 | // 'currency_symbol', |
315 | 315 | 'expire_on_registration_end', |
@@ -321,13 +321,13 @@ discard block |
||
321 | 321 | 'show_pending_payment_options', |
322 | 322 | 'show_reg_footer', |
323 | 323 | 'skip_confirmation_page', |
324 | - 'allow_mer_discounts',//no equiv |
|
325 | - 'allow_mer_vouchers',//no equiv |
|
324 | + 'allow_mer_discounts', //no equiv |
|
325 | + 'allow_mer_vouchers', //no equiv |
|
326 | 326 | 'display_short_description_in_event_list', |
327 | 327 | 'display_description_on_multi_reg_page', |
328 | 328 | 'display_address_in_event_list', |
329 | 329 | 'display_address_in_regform', |
330 | - 'use_custom_post_types',//no equiv |
|
330 | + 'use_custom_post_types', //no equiv |
|
331 | 331 | 'display_ical_download', |
332 | 332 | 'display_featured_image', |
333 | 333 | 'themeroller', |
@@ -346,11 +346,11 @@ discard block |
||
346 | 346 | 'espresso_dashboard_widget', |
347 | 347 | 'time_reg_limit', |
348 | 348 | // 'use_attendee_pre_approval', removed in 4.1- instead this is factored into the default reg status |
349 | - 'use_personnel_manager',//no equiv |
|
349 | + 'use_personnel_manager', //no equiv |
|
350 | 350 | 'use_event_timezones', |
351 | 351 | 'full_logging', |
352 | - 'surcharge_type',//unused |
|
353 | - 'surcharge_text',//unused |
|
352 | + 'surcharge_type', //unused |
|
353 | + 'surcharge_text', //unused |
|
354 | 354 | 'affiliate_id', |
355 | 355 | 'site_license_key', |
356 | 356 | ); |
@@ -157,7 +157,7 @@ discard block |
||
157 | 157 | $state = $this->get_migration_script()->get_or_create_state($value); |
158 | 158 | $state_id = $state['STA_ID']; |
159 | 159 | $c->organization->STA_ID = $state_id; |
160 | - }catch(EE_Error $e){}break; |
|
160 | + } catch(EE_Error $e){}break; |
|
161 | 161 | case 'organization_zip': |
162 | 162 | $c->organization->zip = $value;break; |
163 | 163 | case 'contact_email': |
@@ -256,7 +256,7 @@ discard block |
||
256 | 256 | } |
257 | 257 | if($org_options['surcharge_type'] == 'flat_rate'){ |
258 | 258 | $price_type = EE_DMS_4_1_0_prices::price_type_flat_surcharge; |
259 | - }else{ |
|
259 | + } else{ |
|
260 | 260 | $price_type = EE_DMS_4_1_0_prices::price_type_percent_surcharge; |
261 | 261 | } |
262 | 262 | global $wpdb; |
@@ -345,8 +345,8 @@ discard block |
||
345 | 345 | /** |
346 | 346 | * Adds a join between a ticket and a price |
347 | 347 | * @global type $wpdb |
348 | - * @param type $new_ticket_id |
|
349 | - * @param type $new_price_id |
|
348 | + * @param integer $new_ticket_id |
|
349 | + * @param integer $new_price_id |
|
350 | 350 | * @return int |
351 | 351 | */ |
352 | 352 | private function _insert_ticket_price_relation($new_ticket_id,$new_price_id){ |
@@ -371,8 +371,7 @@ discard block |
||
371 | 371 | /** |
372 | 372 | * Adds a join between a ticket and a datetime |
373 | 373 | * @global type $wpdb |
374 | - * @param type $new_ticket_id |
|
375 | - * @param type $new_price_id |
|
374 | + * @param integer $new_ticket_id |
|
376 | 375 | * @return int |
377 | 376 | */ |
378 | 377 | private function _insert_datetime_ticket_relation($new_datetime_id,$new_ticket_id){ |
@@ -86,7 +86,7 @@ discard block |
||
86 | 86 | )); |
87 | 87 | */ |
88 | 88 | |
89 | -class EE_DMS_4_1_0_prices extends EE_Data_Migration_Script_Stage_Table{ |
|
89 | +class EE_DMS_4_1_0_prices extends EE_Data_Migration_Script_Stage_Table { |
|
90 | 90 | private $_new_price_table; |
91 | 91 | private $_new_ticket_table; |
92 | 92 | private $_new_ticket_price_table; |
@@ -122,10 +122,10 @@ discard block |
||
122 | 122 | // $member_price_discount_id = 0; |
123 | 123 | // } |
124 | 124 | //create the surcharge if there is any |
125 | - if(floatval($old_row['surcharge']) >= 0.01){ |
|
125 | + if (floatval($old_row['surcharge']) >= 0.01) { |
|
126 | 126 | $surcharge_price_id = $this->_insert_new_surcharge_price($old_row); |
127 | - $this->get_migration_script()->set_mapping($this->_old_table, $old_row['id'], $this->_new_price_table, array($new_price_id,$surcharge_price_id)); |
|
128 | - }else{ |
|
127 | + $this->get_migration_script()->set_mapping($this->_old_table, $old_row['id'], $this->_new_price_table, array($new_price_id, $surcharge_price_id)); |
|
128 | + } else { |
|
129 | 129 | $surcharge_price_id = 0; |
130 | 130 | $this->get_migration_script()->set_mapping($this->_old_table, $old_row['id'], $this->_new_price_table, array($new_price_id)); |
131 | 131 | } |
@@ -145,7 +145,7 @@ discard block |
||
145 | 145 | // } |
146 | 146 | //create a ticket for each old price -old datetime combo |
147 | 147 | $tickets_for_old_price = array(); |
148 | - foreach($this->_get_datetime_ids_for_old_event_id($old_row['event_id']) as $new_datetime_id){ |
|
148 | + foreach ($this->_get_datetime_ids_for_old_event_id($old_row['event_id']) as $new_datetime_id) { |
|
149 | 149 | $ticket_id = $this->_insert_new_ticket($old_row); |
150 | 150 | $tickets_for_old_price[] = $ticket_id; |
151 | 151 | //associate to old prices |
@@ -162,7 +162,7 @@ discard block |
||
162 | 162 | * @param type $old_price |
163 | 163 | * @return int |
164 | 164 | */ |
165 | - private function _insert_new_price($old_price){ |
|
165 | + private function _insert_new_price($old_price) { |
|
166 | 166 | global $wpdb; |
167 | 167 | $cols_n_values = array( |
168 | 168 | 'PRT_ID'=>self::price_type_base, |
@@ -176,17 +176,17 @@ discard block |
||
176 | 176 | |
177 | 177 | ); |
178 | 178 | $datatypes = array( |
179 | - '%d',//PRT_ID |
|
180 | - '%f',//PRT_amount |
|
181 | - '%s',//PRC_name |
|
182 | - '%d',//PRC_is_default |
|
183 | - '%d',//PRC_overrides |
|
184 | - '%d',//PRC_order |
|
185 | - '%d',//PRC_deleted |
|
186 | - '%d',//PRC_parent |
|
179 | + '%d', //PRT_ID |
|
180 | + '%f', //PRT_amount |
|
181 | + '%s', //PRC_name |
|
182 | + '%d', //PRC_is_default |
|
183 | + '%d', //PRC_overrides |
|
184 | + '%d', //PRC_order |
|
185 | + '%d', //PRC_deleted |
|
186 | + '%d', //PRC_parent |
|
187 | 187 | ); |
188 | - $success = $wpdb->insert($this->_new_price_table,$cols_n_values,$datatypes); |
|
189 | - if ( ! $success){ |
|
188 | + $success = $wpdb->insert($this->_new_price_table, $cols_n_values, $datatypes); |
|
189 | + if ( ! $success) { |
|
190 | 190 | $this->add_error($this->get_migration_script()->_create_error_message_for_db_insertion($this->_old_table, $old_price, $this->_new_price_table, $cols_n_values, $datatypes)); |
191 | 191 | return 0; |
192 | 192 | } |
@@ -237,11 +237,11 @@ discard block |
||
237 | 237 | * @param type $old_price |
238 | 238 | * @return int |
239 | 239 | */ |
240 | - private function _insert_new_surcharge_price($old_price){ |
|
240 | + private function _insert_new_surcharge_price($old_price) { |
|
241 | 241 | |
242 | - if($old_price['surcharge_type'] == 'flat_rate'){ |
|
242 | + if ($old_price['surcharge_type'] == 'flat_rate') { |
|
243 | 243 | $price_type = self::price_type_flat_surcharge; |
244 | - }else{ |
|
244 | + } else { |
|
245 | 245 | $price_type = self::price_type_percent_surcharge; |
246 | 246 | } |
247 | 247 | global $wpdb; |
@@ -257,17 +257,17 @@ discard block |
||
257 | 257 | |
258 | 258 | ); |
259 | 259 | $datatypes = array( |
260 | - '%d',//PRT_ID |
|
261 | - '%f',//PRT_amount |
|
262 | - '%s',//PRC_name |
|
263 | - '%d',//PRC_is_default |
|
264 | - '%d',//PRC_overrides |
|
265 | - '%d',//PRC_order |
|
266 | - '%d',//PRC_deleted |
|
267 | - '%d',//PRC_parent |
|
260 | + '%d', //PRT_ID |
|
261 | + '%f', //PRT_amount |
|
262 | + '%s', //PRC_name |
|
263 | + '%d', //PRC_is_default |
|
264 | + '%d', //PRC_overrides |
|
265 | + '%d', //PRC_order |
|
266 | + '%d', //PRC_deleted |
|
267 | + '%d', //PRC_parent |
|
268 | 268 | ); |
269 | - $success = $wpdb->insert($this->_new_price_table,$cols_n_values,$datatypes); |
|
270 | - if ( ! $success){ |
|
269 | + $success = $wpdb->insert($this->_new_price_table, $cols_n_values, $datatypes); |
|
270 | + if ( ! $success) { |
|
271 | 271 | $this->add_error($this->get_migration_script()->_create_error_message_for_db_insertion($this->_old_table, $old_price, $this->_new_price_table, $cols_n_values, $datatypes)); |
272 | 272 | return 0; |
273 | 273 | } |
@@ -282,18 +282,18 @@ discard block |
||
282 | 282 | * @param $new_surcharge_id int |
283 | 283 | * @return int new ticket id |
284 | 284 | */ |
285 | - private function _insert_new_ticket($old_price_row){ |
|
285 | + private function _insert_new_ticket($old_price_row) { |
|
286 | 286 | global $wpdb; |
287 | 287 | $event_row = $this->_get_event_row($old_price_row['event_id']); |
288 | - if($old_price_row['surcharge_type'] == 'flat_rate'){ |
|
288 | + if ($old_price_row['surcharge_type'] == 'flat_rate') { |
|
289 | 289 | $final_ticket_price = floatval($old_price_row['event_cost']) + floatval($old_price_row['surcharge']); |
290 | - }else{//percent surcharge |
|
291 | - $final_ticket_price = floatval($old_price_row['event_cost']) * (1 + floatval($old_price_row['surcharge'])/100); |
|
290 | + } else {//percent surcharge |
|
291 | + $final_ticket_price = floatval($old_price_row['event_cost']) * (1 + floatval($old_price_row['surcharge']) / 100); |
|
292 | 292 | } |
293 | 293 | $start_date = $event_row['registration_start']." ".$this->get_migration_script()->convertTimeFromAMPM($event_row['registration_startT']); |
294 | - $start_date_utc = $this->get_migration_script()->convert_date_string_to_utc($this,$old_price_row,$start_date,$event_row['timezone_string']); |
|
294 | + $start_date_utc = $this->get_migration_script()->convert_date_string_to_utc($this, $old_price_row, $start_date, $event_row['timezone_string']); |
|
295 | 295 | $end_date = $event_row['registration_end']." ".$this->get_migration_script()->convertTimeFromAMPM($event_row['registration_endT']); |
296 | - $end_date_utc = $this->get_migration_script()->convert_date_string_to_utc($this,$old_price_row,$end_date,$event_row['timezone_string']); |
|
296 | + $end_date_utc = $this->get_migration_script()->convert_date_string_to_utc($this, $old_price_row, $end_date, $event_row['timezone_string']); |
|
297 | 297 | $cols_n_values = array( |
298 | 298 | 'TTM_ID'=>0, |
299 | 299 | 'TKT_name'=>$old_price_row['price_type'], |
@@ -303,38 +303,38 @@ discard block |
||
303 | 303 | 'TKT_min'=>0, |
304 | 304 | 'TKT_max'=>-1, |
305 | 305 | 'TKT_price'=>$final_ticket_price, |
306 | - 'TKT_sold'=> 0,//note: this will get calculated as we actually add registrations during the migration |
|
306 | + 'TKT_sold'=> 0, //note: this will get calculated as we actually add registrations during the migration |
|
307 | 307 | 'TKT_qty'=> -1, |
308 | 308 | 'TKT_uses'=> 1, |
309 | - 'TKT_taxable'=>false,//so by default, old prices are NOT taxable. This way they don't suddenly have a sudden spike in prices |
|
309 | + 'TKT_taxable'=>false, //so by default, old prices are NOT taxable. This way they don't suddenly have a sudden spike in prices |
|
310 | 310 | 'TKT_is_default'=>false, |
311 | 311 | 'TKT_order'=>$this->_get_ticket_count(), |
312 | - 'TKT_row'=>0,//doesn't matter because UI reset this on first save anyways |
|
312 | + 'TKT_row'=>0, //doesn't matter because UI reset this on first save anyways |
|
313 | 313 | 'TKT_deleted'=>false, |
314 | 314 | 'TKT_parent'=>0 |
315 | 315 | |
316 | 316 | ); |
317 | 317 | $datatypes = array( |
318 | - '%d',//TTM_ID |
|
319 | - '%s',//TKT_name |
|
320 | - '%s',//TKT_description |
|
321 | - '%s',//TKT_start_date |
|
322 | - '%s',//TKT_end_date |
|
323 | - '%d',//TKT_min |
|
324 | - '%d',//TKT_max |
|
325 | - '%f',//TKT_price |
|
326 | - '%d',//TKT_sold |
|
327 | - '%d',//TKT_qty |
|
328 | - '%d',//TKT_uses |
|
329 | - '%d',//TKT_taxable |
|
330 | - '%d',//TKT_is_default |
|
331 | - '%d',//TKT_order |
|
332 | - '%d',//TKT_row |
|
333 | - '%d',//TKT_deleted |
|
334 | - '%d',//TKT_parent |
|
318 | + '%d', //TTM_ID |
|
319 | + '%s', //TKT_name |
|
320 | + '%s', //TKT_description |
|
321 | + '%s', //TKT_start_date |
|
322 | + '%s', //TKT_end_date |
|
323 | + '%d', //TKT_min |
|
324 | + '%d', //TKT_max |
|
325 | + '%f', //TKT_price |
|
326 | + '%d', //TKT_sold |
|
327 | + '%d', //TKT_qty |
|
328 | + '%d', //TKT_uses |
|
329 | + '%d', //TKT_taxable |
|
330 | + '%d', //TKT_is_default |
|
331 | + '%d', //TKT_order |
|
332 | + '%d', //TKT_row |
|
333 | + '%d', //TKT_deleted |
|
334 | + '%d', //TKT_parent |
|
335 | 335 | ); |
336 | - $success = $wpdb->insert($this->_new_ticket_table,$cols_n_values,$datatypes); |
|
337 | - if ( ! $success){ |
|
336 | + $success = $wpdb->insert($this->_new_ticket_table, $cols_n_values, $datatypes); |
|
337 | + if ( ! $success) { |
|
338 | 338 | $this->add_error($this->get_migration_script()->_create_error_message_for_db_insertion($this->_old_table, $old_price_row, $this->_new_ticket_table, $cols_n_values, $datatypes)); |
339 | 339 | return 0; |
340 | 340 | } |
@@ -349,19 +349,19 @@ discard block |
||
349 | 349 | * @param type $new_price_id |
350 | 350 | * @return int |
351 | 351 | */ |
352 | - private function _insert_ticket_price_relation($new_ticket_id,$new_price_id){ |
|
352 | + private function _insert_ticket_price_relation($new_ticket_id, $new_price_id) { |
|
353 | 353 | global $wpdb; |
354 | 354 | $cols_n_values = array( |
355 | 355 | 'TKT_ID'=>$new_ticket_id, |
356 | 356 | 'PRC_ID'=>$new_price_id, |
357 | 357 | ); |
358 | 358 | $datatypes = array( |
359 | - '%d',//TKT_ID |
|
360 | - '%d',//PRC_ID |
|
359 | + '%d', //TKT_ID |
|
360 | + '%d', //PRC_ID |
|
361 | 361 | ); |
362 | - $success = $wpdb->insert($this->_new_ticket_price_table,$cols_n_values,$datatypes); |
|
363 | - if ( ! $success){ |
|
364 | - $this->add_error($this->get_migration_script()->_create_error_message_for_db_insertion($this->_old_table, array('ticket id'=>$new_ticket_id,'price id'=>$new_price_id), $this->_new_ticket_price_table, $cols_n_values, $datatypes)); |
|
362 | + $success = $wpdb->insert($this->_new_ticket_price_table, $cols_n_values, $datatypes); |
|
363 | + if ( ! $success) { |
|
364 | + $this->add_error($this->get_migration_script()->_create_error_message_for_db_insertion($this->_old_table, array('ticket id'=>$new_ticket_id, 'price id'=>$new_price_id), $this->_new_ticket_price_table, $cols_n_values, $datatypes)); |
|
365 | 365 | return 0; |
366 | 366 | } |
367 | 367 | $new_id = $wpdb->insert_id; |
@@ -375,19 +375,19 @@ discard block |
||
375 | 375 | * @param type $new_price_id |
376 | 376 | * @return int |
377 | 377 | */ |
378 | - private function _insert_datetime_ticket_relation($new_datetime_id,$new_ticket_id){ |
|
378 | + private function _insert_datetime_ticket_relation($new_datetime_id, $new_ticket_id) { |
|
379 | 379 | global $wpdb; |
380 | 380 | $cols_n_values = array( |
381 | 381 | 'TKT_ID'=>$new_ticket_id, |
382 | 382 | 'DTT_ID'=>$new_datetime_id, |
383 | 383 | ); |
384 | 384 | $datatypes = array( |
385 | - '%d',//TKT_ID |
|
386 | - '%d',//DTT_ID |
|
385 | + '%d', //TKT_ID |
|
386 | + '%d', //DTT_ID |
|
387 | 387 | ); |
388 | - $success = $wpdb->insert($this->_new_datetime_ticket_table,$cols_n_values,$datatypes); |
|
389 | - if ( ! $success){ |
|
390 | - $this->add_error($this->get_migration_script()->_create_error_message_for_db_insertion($this->_old_table, array('ticket id'=>$new_ticket_id,'datetime id'=>$new_datetime_id), $this->_new_datetime_ticket_table, $cols_n_values, $datatypes)); |
|
388 | + $success = $wpdb->insert($this->_new_datetime_ticket_table, $cols_n_values, $datatypes); |
|
389 | + if ( ! $success) { |
|
390 | + $this->add_error($this->get_migration_script()->_create_error_message_for_db_insertion($this->_old_table, array('ticket id'=>$new_ticket_id, 'datetime id'=>$new_datetime_id), $this->_new_datetime_ticket_table, $cols_n_values, $datatypes)); |
|
391 | 391 | return 0; |
392 | 392 | } |
393 | 393 | $new_id = $wpdb->insert_id; |
@@ -400,17 +400,17 @@ discard block |
||
400 | 400 | * @param type $event_id |
401 | 401 | * @return array |
402 | 402 | */ |
403 | - private function _get_event_row($event_id){ |
|
403 | + private function _get_event_row($event_id) { |
|
404 | 404 | global $wpdb; |
405 | 405 | $old_event_table = $wpdb->prefix."events_detail"; |
406 | - return $wpdb->get_row($wpdb->prepare("SELECT * FROM $old_event_table WHERE id=%d",$event_id),ARRAY_A); |
|
406 | + return $wpdb->get_row($wpdb->prepare("SELECT * FROM $old_event_table WHERE id=%d", $event_id), ARRAY_A); |
|
407 | 407 | } |
408 | 408 | /** |
409 | 409 | * Gets a higher ticket count than last time it was called (and is persisted between HTTP requests). |
410 | 410 | * Yes we COULD run a query joining events->datetimes->ticket_datetimes->tickets, but this should work fine too |
411 | 411 | * @return int |
412 | 412 | */ |
413 | - private function _get_ticket_count(){ |
|
413 | + private function _get_ticket_count() { |
|
414 | 414 | return $this->_ticket_count++; |
415 | 415 | } |
416 | 416 | |
@@ -419,10 +419,10 @@ discard block |
||
419 | 419 | * @param int $old_event_id |
420 | 420 | * @return array where values are datetime ids |
421 | 421 | */ |
422 | - private function _get_datetime_ids_for_old_event_id($old_event_id){ |
|
422 | + private function _get_datetime_ids_for_old_event_id($old_event_id) { |
|
423 | 423 | global $wpdb; |
424 | 424 | $new_cpt_id = $this->get_migration_script()->get_mapping_new_pk($wpdb->prefix."events_detail", $old_event_id, $wpdb->posts); |
425 | - $datetime_ids = $wpdb->get_col($wpdb->prepare("SELECT DTT_ID FROM {$wpdb->prefix}esp_datetime WHERE EVT_ID=%d",$new_cpt_id)); |
|
425 | + $datetime_ids = $wpdb->get_col($wpdb->prepare("SELECT DTT_ID FROM {$wpdb->prefix}esp_datetime WHERE EVT_ID=%d", $new_cpt_id)); |
|
426 | 426 | return $datetime_ids; |
427 | 427 | } |
428 | 428 | } |
@@ -125,7 +125,7 @@ discard block |
||
125 | 125 | if(floatval($old_row['surcharge']) >= 0.01){ |
126 | 126 | $surcharge_price_id = $this->_insert_new_surcharge_price($old_row); |
127 | 127 | $this->get_migration_script()->set_mapping($this->_old_table, $old_row['id'], $this->_new_price_table, array($new_price_id,$surcharge_price_id)); |
128 | - }else{ |
|
128 | + } else{ |
|
129 | 129 | $surcharge_price_id = 0; |
130 | 130 | $this->get_migration_script()->set_mapping($this->_old_table, $old_row['id'], $this->_new_price_table, array($new_price_id)); |
131 | 131 | } |
@@ -241,7 +241,7 @@ discard block |
||
241 | 241 | |
242 | 242 | if($old_price['surcharge_type'] == 'flat_rate'){ |
243 | 243 | $price_type = self::price_type_flat_surcharge; |
244 | - }else{ |
|
244 | + } else{ |
|
245 | 245 | $price_type = self::price_type_percent_surcharge; |
246 | 246 | } |
247 | 247 | global $wpdb; |
@@ -287,7 +287,7 @@ discard block |
||
287 | 287 | $event_row = $this->_get_event_row($old_price_row['event_id']); |
288 | 288 | if($old_price_row['surcharge_type'] == 'flat_rate'){ |
289 | 289 | $final_ticket_price = floatval($old_price_row['event_cost']) + floatval($old_price_row['surcharge']); |
290 | - }else{//percent surcharge |
|
290 | + } else{//percent surcharge |
|
291 | 291 | $final_ticket_price = floatval($old_price_row['event_cost']) * (1 + floatval($old_price_row['surcharge'])/100); |
292 | 292 | } |
293 | 293 | $start_date = $event_row['registration_start']." ".$this->get_migration_script()->convertTimeFromAMPM($event_row['registration_startT']); |
@@ -126,7 +126,7 @@ |
||
126 | 126 | * being address info, and 0 being neither) |
127 | 127 | * @global type $wpdb |
128 | 128 | * @param type $new_question_group_id |
129 | - * @return boolean |
|
129 | + * @return integer |
|
130 | 130 | */ |
131 | 131 | private function _is_system_question_group($new_question_group_id){ |
132 | 132 | global $wpdb; |
@@ -12,8 +12,6 @@ |
||
12 | 12 | KEY `group_id` (`group_id`), |
13 | 13 | KEY `question_id` (`question_id`) |
14 | 14 | ) ENGINE=InnoDB AUTO_INCREMENT=19 DEFAULT CHARSET=utf8$$ |
15 | - |
|
16 | - |
|
17 | 15 | * 4.1 question group question model's tables and fields: |
18 | 16 | $this->_tables = array( |
19 | 17 | 'Question_Group_Question'=>new EE_Primary_Table('esp_question_group_question','QGQ_ID') |
@@ -27,20 +27,20 @@ discard block |
||
27 | 27 | ); |
28 | 28 | * |
29 | 29 | */ |
30 | -class EE_DMS_4_1_0_question_group_question extends EE_Data_Migration_Script_Stage{ |
|
30 | +class EE_DMS_4_1_0_question_group_question extends EE_Data_Migration_Script_Stage { |
|
31 | 31 | private $_old_table; |
32 | 32 | private $_new_table; |
33 | - function _migration_step($num_items=50){ |
|
33 | + function _migration_step($num_items = 50) { |
|
34 | 34 | |
35 | 35 | global $wpdb; |
36 | 36 | $start_at_record = $this->count_records_migrated(); |
37 | - $rows = $wpdb->get_results($wpdb->prepare("SELECT * FROM $this->_old_table LIMIT %d,%d",$start_at_record,$num_items),ARRAY_A); |
|
37 | + $rows = $wpdb->get_results($wpdb->prepare("SELECT * FROM $this->_old_table LIMIT %d,%d", $start_at_record, $num_items), ARRAY_A); |
|
38 | 38 | $items_actually_migrated = 0; |
39 | - foreach($rows as $question_group_question){ |
|
39 | + foreach ($rows as $question_group_question) { |
|
40 | 40 | $this->_insert_new_question_group_question($question_group_question); |
41 | 41 | $items_actually_migrated++; |
42 | 42 | } |
43 | - if($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()){ |
|
43 | + if ($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()) { |
|
44 | 44 | $this->set_completed(); |
45 | 45 | } |
46 | 46 | return $items_actually_migrated; |
@@ -64,39 +64,39 @@ discard block |
||
64 | 64 | * @param array $old_question_group_question |
65 | 65 | * @return int |
66 | 66 | */ |
67 | - private function _insert_new_question_group_question($old_question_group_question){ |
|
67 | + private function _insert_new_question_group_question($old_question_group_question) { |
|
68 | 68 | global $wpdb; |
69 | 69 | $new_question_id = $this->get_migration_script()->get_mapping_new_pk($wpdb->prefix."events_question", $old_question_group_question['question_id'], $wpdb->prefix."esp_question"); |
70 | 70 | $new_question_group_id = $this->get_migration_script()->get_mapping_new_pk($wpdb->prefix."events_qst_group", $old_question_group_question['group_id'], $wpdb->prefix."esp_question_group"); |
71 | - if( ! $new_question_id){ |
|
72 | - $this->add_error(sprintf(__("Could not find 4.1 question id for 3.1 question #%d.", "event_espresso"),$old_question_group_question['question_id'])); |
|
71 | + if ( ! $new_question_id) { |
|
72 | + $this->add_error(sprintf(__("Could not find 4.1 question id for 3.1 question #%d.", "event_espresso"), $old_question_group_question['question_id'])); |
|
73 | 73 | return 0; |
74 | 74 | } |
75 | - if( ! $new_question_group_id){ |
|
76 | - $this->add_error(sprintf(__("Could not find 4.1 question group id for 3.1 question group #%d.", "event_espresso"),$old_question_group_question['group_id'])); |
|
75 | + if ( ! $new_question_group_id) { |
|
76 | + $this->add_error(sprintf(__("Could not find 4.1 question group id for 3.1 question group #%d.", "event_espresso"), $old_question_group_question['group_id'])); |
|
77 | 77 | return 0; |
78 | 78 | } |
79 | 79 | //if it's a system question, it needs to be in the right system group. otherwise no dice! |
80 | - if( |
|
81 | - ($this->_is_system_question_group($new_question_group_id) == $this->_is_system_question_for_question_group($new_question_id) ) |
|
80 | + if ( |
|
81 | + ($this->_is_system_question_group($new_question_group_id) == $this->_is_system_question_for_question_group($new_question_id)) |
|
82 | 82 | || |
83 | 83 | ! $this->_is_system_question_for_question_group($new_question_id) |
84 | - ){ |
|
84 | + ) { |
|
85 | 85 | $cols_n_values = array( |
86 | 86 | 'QSG_ID'=>$new_question_group_id, |
87 | 87 | 'QST_ID'=>$new_question_id |
88 | 88 | ); |
89 | 89 | $datatypes = array( |
90 | - '%d',//QSG_ID |
|
91 | - '%d',//QST_ID |
|
90 | + '%d', //QSG_ID |
|
91 | + '%d', //QST_ID |
|
92 | 92 | ); |
93 | - $success = $wpdb->insert($this->_new_table,$cols_n_values,$datatypes); |
|
94 | - if ( ! $success){ |
|
93 | + $success = $wpdb->insert($this->_new_table, $cols_n_values, $datatypes); |
|
94 | + if ( ! $success) { |
|
95 | 95 | $this->add_error($this->get_migration_script()->_create_error_message_for_db_insertion($this->_old_table, $old_question_group_question, $this->_new_table, $cols_n_values, $datatypes)); |
96 | 96 | return 0; |
97 | 97 | } |
98 | 98 | return $wpdb->insert_id; |
99 | - }else{ |
|
99 | + } else { |
|
100 | 100 | return false; |
101 | 101 | } |
102 | 102 | |
@@ -109,14 +109,14 @@ discard block |
||
109 | 109 | * @param type $new_question_id |
110 | 110 | * @return int |
111 | 111 | */ |
112 | - private function _is_system_question_for_question_group($new_question_id){ |
|
112 | + private function _is_system_question_for_question_group($new_question_id) { |
|
113 | 113 | global $wpdb; |
114 | - $system_id = $wpdb->get_var($wpdb->prepare("SELECT QST_system FROM ".$wpdb->prefix."esp_question WHERE QST_ID=%d",$new_question_id)); |
|
115 | - if(in_array($system_id, array('fname','lname','email'))){ |
|
114 | + $system_id = $wpdb->get_var($wpdb->prepare("SELECT QST_system FROM ".$wpdb->prefix."esp_question WHERE QST_ID=%d", $new_question_id)); |
|
115 | + if (in_array($system_id, array('fname', 'lname', 'email'))) { |
|
116 | 116 | return 1; |
117 | - }elseif($system_id!='' && $system_id){ |
|
117 | + }elseif ($system_id != '' && $system_id) { |
|
118 | 118 | return 2; |
119 | - }else{ |
|
119 | + } else { |
|
120 | 120 | return 0; |
121 | 121 | } |
122 | 122 | } |
@@ -128,9 +128,9 @@ discard block |
||
128 | 128 | * @param type $new_question_group_id |
129 | 129 | * @return boolean |
130 | 130 | */ |
131 | - private function _is_system_question_group($new_question_group_id){ |
|
131 | + private function _is_system_question_group($new_question_group_id) { |
|
132 | 132 | global $wpdb; |
133 | - $system_id = $wpdb->get_var($wpdb->prepare("SELECT QSG_system FROM ".$wpdb->prefix."esp_question_group WHERE QSG_ID=%d",$new_question_group_id)); |
|
133 | + $system_id = $wpdb->get_var($wpdb->prepare("SELECT QSG_system FROM ".$wpdb->prefix."esp_question_group WHERE QSG_ID=%d", $new_question_group_id)); |
|
134 | 134 | return intval($system_id); |
135 | 135 | } |
136 | 136 |
@@ -96,7 +96,7 @@ discard block |
||
96 | 96 | return 0; |
97 | 97 | } |
98 | 98 | return $wpdb->insert_id; |
99 | - }else{ |
|
99 | + } else{ |
|
100 | 100 | return false; |
101 | 101 | } |
102 | 102 | |
@@ -114,9 +114,9 @@ discard block |
||
114 | 114 | $system_id = $wpdb->get_var($wpdb->prepare("SELECT QST_system FROM ".$wpdb->prefix."esp_question WHERE QST_ID=%d",$new_question_id)); |
115 | 115 | if(in_array($system_id, array('fname','lname','email'))){ |
116 | 116 | return 1; |
117 | - }elseif($system_id!='' && $system_id){ |
|
117 | + } elseif($system_id!='' && $system_id){ |
|
118 | 118 | return 2; |
119 | - }else{ |
|
119 | + } else{ |
|
120 | 120 | return 0; |
121 | 121 | } |
122 | 122 | } |
@@ -196,7 +196,7 @@ |
||
196 | 196 | |
197 | 197 | /** |
198 | 198 | * Inserts into the venue_meta table |
199 | - * @param type $cpt_id |
|
199 | + * @param integer $cpt_id |
|
200 | 200 | * @param type $old_venue |
201 | 201 | * @return int |
202 | 202 | */ |
@@ -206,7 +206,7 @@ discard block |
||
206 | 206 | try{ |
207 | 207 | $country = $this->get_migration_script()->get_or_create_country(stripslashes($old_venue['country'])); |
208 | 208 | $country_iso = $country['CNT_ISO']; |
209 | - }catch(EE_Error $e){ |
|
209 | + } catch(EE_Error $e){ |
|
210 | 210 | $this->add_error(sprintf(__("%s for venue %s", "event_espresso"),$e->getMessage(),$this->_json_encode($old_venue))); |
211 | 211 | $country_iso = null; |
212 | 212 | } |
@@ -214,7 +214,7 @@ discard block |
||
214 | 214 | try{ |
215 | 215 | $state = $this->get_migration_script()->get_or_create_state(stripslashes($old_venue['state']),isset($country['CNT_name']) ? $country['CNT_name'] : strip_tags($old_venue['country'])); |
216 | 216 | $state_id = $state['STA_ID']; |
217 | - }catch(EE_Error $e){ |
|
217 | + } catch(EE_Error $e){ |
|
218 | 218 | $this->add_error(sprintf(__("%s for venue %s", "event_espresso"),$e->getMessage(),$this->_json_encode($old_venue))); |
219 | 219 | $state_id = 0; |
220 | 220 | } |
@@ -61,44 +61,44 @@ discard block |
||
61 | 61 | // )); |
62 | 62 | * |
63 | 63 | */ |
64 | -class EE_DMS_4_1_0_venues extends EE_Data_Migration_Script_Stage{ |
|
64 | +class EE_DMS_4_1_0_venues extends EE_Data_Migration_Script_Stage { |
|
65 | 65 | private $_old_table; |
66 | 66 | private $_new_table; |
67 | 67 | private $_new_meta_table; |
68 | -function _migration_step($num_items=50){ |
|
68 | +function _migration_step($num_items = 50) { |
|
69 | 69 | global $wpdb; |
70 | 70 | $start_at_record = $this->count_records_migrated(); |
71 | - $rows = $wpdb->get_results($wpdb->prepare("SELECT * FROM ".$this->_old_table." LIMIT %d,%d",$start_at_record,$num_items),ARRAY_A); |
|
71 | + $rows = $wpdb->get_results($wpdb->prepare("SELECT * FROM ".$this->_old_table." LIMIT %d,%d", $start_at_record, $num_items), ARRAY_A); |
|
72 | 72 | $items_actually_migrated = 0; |
73 | - foreach($rows as $old_venue){ |
|
74 | - if ( ! $new_id = $this->_insert_into_posts($old_venue)){ |
|
73 | + foreach ($rows as $old_venue) { |
|
74 | + if ( ! $new_id = $this->_insert_into_posts($old_venue)) { |
|
75 | 75 | $items_actually_migrated++; |
76 | 76 | continue; |
77 | 77 | } |
78 | 78 | $this->get_migration_script()->set_mapping($this->_old_table, $old_venue['id'], $this->_new_table, $new_id); |
79 | - if( ! $new_meta_id = $this->_insert_into_meta_table($new_id,$old_venue)){ |
|
79 | + if ( ! $new_meta_id = $this->_insert_into_meta_table($new_id, $old_venue)) { |
|
80 | 80 | $items_actually_migrated++; |
81 | 81 | continue; |
82 | 82 | } |
83 | 83 | $this->get_migration_script()->set_mapping($this->_old_table, $old_venue['id'], $this->_new_meta_table, $new_meta_id); |
84 | 84 | //lastly, save the 'contact' as post meta, because it doesn't exist anywhere else but someone may still want it |
85 | 85 | $venue_meta = maybe_unserialize($old_venue['meta']); |
86 | - if(isset($venue_meta['contact']) && $venue_meta['contact']){ |
|
87 | - add_post_meta($new_id,'contact',$venue_meta['contact']); |
|
86 | + if (isset($venue_meta['contact']) && $venue_meta['contact']) { |
|
87 | + add_post_meta($new_id, 'contact', $venue_meta['contact']); |
|
88 | 88 | } |
89 | 89 | //is there an image on this venue? |
90 | 90 | $guid = isset($venue_meta['image']) && $venue_meta['image'] ? $venue_meta['image'] : NULL; |
91 | - if($guid){ |
|
92 | - $this->get_migration_script()->convert_image_url_to_attachment_and_attach_to_post($guid,$new_id,$this); |
|
91 | + if ($guid) { |
|
92 | + $this->get_migration_script()->convert_image_url_to_attachment_and_attach_to_post($guid, $new_id, $this); |
|
93 | 93 | } |
94 | 94 | $items_actually_migrated++; |
95 | - if($guid){ |
|
95 | + if ($guid) { |
|
96 | 96 | //if there was an image, we may have had to download it etc and it may have taken |
97 | 97 | //longer, then let's not bother migrating anymore on this step |
98 | 98 | break; |
99 | 99 | } |
100 | 100 | } |
101 | - if($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()){ |
|
101 | + if ($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()) { |
|
102 | 102 | $this->set_completed(); |
103 | 103 | } |
104 | 104 | return $items_actually_migrated; |
@@ -122,42 +122,42 @@ discard block |
||
122 | 122 | * @param array $old_venue keys are cols, values are col values |
123 | 123 | * @return int |
124 | 124 | */ |
125 | - private function _insert_into_posts($old_venue){ |
|
125 | + private function _insert_into_posts($old_venue) { |
|
126 | 126 | global $wpdb; |
127 | 127 | $meta = maybe_unserialize($old_venue['meta']); |
128 | - $slug = $this->_find_unique_slug( $old_venue[ 'name' ], $old_venue[ 'identifier' ] ); |
|
128 | + $slug = $this->_find_unique_slug($old_venue['name'], $old_venue['identifier']); |
|
129 | 129 | $insertion_array = array( |
130 | - 'post_title'=>stripslashes($old_venue['name']),//VNU_name |
|
131 | - 'post_content'=>isset($meta['description']) ? stripslashes(strip_tags($meta['description'])) : '',//VNU_desc |
|
132 | - 'post_name'=> $slug,//VNU_identifier |
|
133 | - 'post_date'=>current_time('mysql'),//VNU_created |
|
134 | - 'post_date_gmt'=> current_time('mysql',true), |
|
135 | - 'post_excerpt'=>'',//wp_trim_words($meta['description'] ? $meta['description'] : '',50),//VNU_short_desc arbitraty only 50 characters |
|
136 | - 'post_modified'=>current_time('mysql'),//VNU_modified |
|
137 | - 'post_modified_gmt'=>current_time('mysql',true), |
|
138 | - 'post_author'=>$old_venue['wp_user'],//VNU_wp_user |
|
139 | - 'post_parent'=>0,//parent |
|
140 | - 'menu_order'=>0,//VNU_order |
|
130 | + 'post_title'=>stripslashes($old_venue['name']), //VNU_name |
|
131 | + 'post_content'=>isset($meta['description']) ? stripslashes(strip_tags($meta['description'])) : '', //VNU_desc |
|
132 | + 'post_name'=> $slug, //VNU_identifier |
|
133 | + 'post_date'=>current_time('mysql'), //VNU_created |
|
134 | + 'post_date_gmt'=> current_time('mysql', true), |
|
135 | + 'post_excerpt'=>'', //wp_trim_words($meta['description'] ? $meta['description'] : '',50),//VNU_short_desc arbitraty only 50 characters |
|
136 | + 'post_modified'=>current_time('mysql'), //VNU_modified |
|
137 | + 'post_modified_gmt'=>current_time('mysql', true), |
|
138 | + 'post_author'=>$old_venue['wp_user'], //VNU_wp_user |
|
139 | + 'post_parent'=>0, //parent |
|
140 | + 'menu_order'=>0, //VNU_order |
|
141 | 141 | 'post_type'=>'espresso_venues'//post_type |
142 | 142 | ); |
143 | 143 | $datatypes_array = array( |
144 | - '%s',//VNU_name |
|
145 | - '%s',//VNU_desc |
|
146 | - '%s',//VNU_identifier |
|
147 | - '%s',//VNU_created |
|
144 | + '%s', //VNU_name |
|
145 | + '%s', //VNU_desc |
|
146 | + '%s', //VNU_identifier |
|
147 | + '%s', //VNU_created |
|
148 | 148 | '%s', |
149 | - '%s',//VNU_short_desc |
|
150 | - '%s',//VNU_modified |
|
149 | + '%s', //VNU_short_desc |
|
150 | + '%s', //VNU_modified |
|
151 | 151 | '%s', |
152 | - '%d',//VNU_wp_user |
|
153 | - '%d',//parent |
|
154 | - '%d',//VNU_order |
|
155 | - '%s',//post_type |
|
152 | + '%d', //VNU_wp_user |
|
153 | + '%d', //parent |
|
154 | + '%d', //VNU_order |
|
155 | + '%s', //post_type |
|
156 | 156 | ); |
157 | 157 | $success = $wpdb->insert($this->_new_table, |
158 | 158 | $insertion_array, |
159 | 159 | $datatypes_array); |
160 | - if( ! $success ){ |
|
160 | + if ( ! $success) { |
|
161 | 161 | $this->add_error($this->get_migration_script()->_create_error_message_for_db_insertion($this->_old_table, $old_venue, $this->_new_table, $insertion_array, $datatypes_array)); |
162 | 162 | return 0; |
163 | 163 | } |
@@ -171,11 +171,11 @@ discard block |
||
171 | 171 | * @param string $post_name |
172 | 172 | * @return string |
173 | 173 | */ |
174 | - private function _find_unique_slug($post_name, $old_identifier = '' ){ |
|
174 | + private function _find_unique_slug($post_name, $old_identifier = '') { |
|
175 | 175 | $count = 0; |
176 | - $original_name = $post_name ? sanitize_title( $post_name ) : $old_identifier; |
|
176 | + $original_name = $post_name ? sanitize_title($post_name) : $old_identifier; |
|
177 | 177 | $event_slug = $original_name; |
178 | - while( $this->_other_post_exists_with_that_slug($event_slug) && $count<50){ |
|
178 | + while ($this->_other_post_exists_with_that_slug($event_slug) && $count < 50) { |
|
179 | 179 | $event_slug = sanitize_title($original_name."-".++$count); |
180 | 180 | } |
181 | 181 | return $event_slug; |
@@ -187,11 +187,11 @@ discard block |
||
187 | 187 | * @param type $slug |
188 | 188 | * @return boolean |
189 | 189 | */ |
190 | - private function _other_post_exists_with_that_slug($slug){ |
|
190 | + private function _other_post_exists_with_that_slug($slug) { |
|
191 | 191 | global $wpdb; |
192 | - $query = $wpdb->prepare("SELECT COUNT(ID) FROM ".$this->_new_table." WHERE post_name = %s",$slug); |
|
192 | + $query = $wpdb->prepare("SELECT COUNT(ID) FROM ".$this->_new_table." WHERE post_name = %s", $slug); |
|
193 | 193 | $count = $wpdb->get_var($query); |
194 | - return (boolean)intval($count); |
|
194 | + return (boolean) intval($count); |
|
195 | 195 | } |
196 | 196 | |
197 | 197 | /** |
@@ -200,60 +200,60 @@ discard block |
||
200 | 200 | * @param type $old_venue |
201 | 201 | * @return int |
202 | 202 | */ |
203 | - private function _insert_into_meta_table($cpt_id,$old_venue){ |
|
203 | + private function _insert_into_meta_table($cpt_id, $old_venue) { |
|
204 | 204 | global $wpdb; |
205 | 205 | //get a country with the same name, or insert one |
206 | - try{ |
|
206 | + try { |
|
207 | 207 | $country = $this->get_migration_script()->get_or_create_country(stripslashes($old_venue['country'])); |
208 | 208 | $country_iso = $country['CNT_ISO']; |
209 | - }catch(EE_Error $e){ |
|
210 | - $this->add_error(sprintf(__("%s for venue %s", "event_espresso"),$e->getMessage(),$this->_json_encode($old_venue))); |
|
209 | + } catch (EE_Error $e) { |
|
210 | + $this->add_error(sprintf(__("%s for venue %s", "event_espresso"), $e->getMessage(), $this->_json_encode($old_venue))); |
|
211 | 211 | $country_iso = null; |
212 | 212 | } |
213 | 213 | //get a state with the same name, if possible |
214 | - try{ |
|
215 | - $state = $this->get_migration_script()->get_or_create_state(stripslashes($old_venue['state']),isset($country['CNT_name']) ? $country['CNT_name'] : strip_tags($old_venue['country'])); |
|
214 | + try { |
|
215 | + $state = $this->get_migration_script()->get_or_create_state(stripslashes($old_venue['state']), isset($country['CNT_name']) ? $country['CNT_name'] : strip_tags($old_venue['country'])); |
|
216 | 216 | $state_id = $state['STA_ID']; |
217 | - }catch(EE_Error $e){ |
|
218 | - $this->add_error(sprintf(__("%s for venue %s", "event_espresso"),$e->getMessage(),$this->_json_encode($old_venue))); |
|
217 | + } catch (EE_Error $e) { |
|
218 | + $this->add_error(sprintf(__("%s for venue %s", "event_espresso"), $e->getMessage(), $this->_json_encode($old_venue))); |
|
219 | 219 | $state_id = 0; |
220 | 220 | } |
221 | 221 | $meta = maybe_unserialize($old_venue['meta']); |
222 | 222 | //now insert into meta table |
223 | 223 | $insertion_array = array( |
224 | - 'VNU_ID'=>$cpt_id,//VNU_ID_fk |
|
225 | - 'VNU_address'=>stripslashes($old_venue['address']),//VNU_address |
|
226 | - 'VNU_address2'=>stripslashes($old_venue['address2']),//VNU_address2 |
|
227 | - 'VNU_city'=>stripslashes($old_venue['city']),//VNU_city |
|
228 | - 'STA_ID'=>$state_id,//STA_ID |
|
229 | - 'CNT_ISO'=>$country_iso,//CNT_ISO |
|
230 | - 'VNU_zip'=>stripslashes($old_venue['zip']),//VNU_zip |
|
231 | - 'VNU_phone'=>isset($meta['phone']) ? stripslashes($meta['phone']) : '',//VNU_phone |
|
232 | - 'VNU_capacity'=>-1,//VNU_capacity |
|
233 | - 'VNU_url'=>isset($meta['website']) ? stripslashes($meta['website']) : '',//VNU_url |
|
234 | - 'VNU_virtual_phone'=>'',//VNU_virtual_phone |
|
235 | - 'VNU_virtual_url'=>'',//VNU_virtual_url |
|
236 | - 'VNU_google_map_link'=>'',//VNU_google_map_link |
|
224 | + 'VNU_ID'=>$cpt_id, //VNU_ID_fk |
|
225 | + 'VNU_address'=>stripslashes($old_venue['address']), //VNU_address |
|
226 | + 'VNU_address2'=>stripslashes($old_venue['address2']), //VNU_address2 |
|
227 | + 'VNU_city'=>stripslashes($old_venue['city']), //VNU_city |
|
228 | + 'STA_ID'=>$state_id, //STA_ID |
|
229 | + 'CNT_ISO'=>$country_iso, //CNT_ISO |
|
230 | + 'VNU_zip'=>stripslashes($old_venue['zip']), //VNU_zip |
|
231 | + 'VNU_phone'=>isset($meta['phone']) ? stripslashes($meta['phone']) : '', //VNU_phone |
|
232 | + 'VNU_capacity'=>-1, //VNU_capacity |
|
233 | + 'VNU_url'=>isset($meta['website']) ? stripslashes($meta['website']) : '', //VNU_url |
|
234 | + 'VNU_virtual_phone'=>'', //VNU_virtual_phone |
|
235 | + 'VNU_virtual_url'=>'', //VNU_virtual_url |
|
236 | + 'VNU_google_map_link'=>'', //VNU_google_map_link |
|
237 | 237 | 'VNU_enable_for_gmap'=>true //VNU_enable_for_gmap |
238 | 238 | ); |
239 | 239 | $datatypes = array( |
240 | - '%d',//VNU_ID_fk |
|
241 | - '%s',//VNU_address |
|
242 | - '%s',//VNU_address2 |
|
243 | - '%s',//VNU_city |
|
244 | - '%d',//STA_ID |
|
245 | - '%s',//CNT_ISO |
|
246 | - '%s',//VNU_zip |
|
247 | - '%s',//VNU_phone |
|
248 | - '%d',//VNU_capacity |
|
249 | - '%s',//VNU_url |
|
250 | - '%s',//VNU_virtual_phone |
|
251 | - '%s',//VNU_virtual_url |
|
252 | - '%s',//VNU_google_map_link |
|
253 | - '%d',//VNU_enable_for_gmap |
|
240 | + '%d', //VNU_ID_fk |
|
241 | + '%s', //VNU_address |
|
242 | + '%s', //VNU_address2 |
|
243 | + '%s', //VNU_city |
|
244 | + '%d', //STA_ID |
|
245 | + '%s', //CNT_ISO |
|
246 | + '%s', //VNU_zip |
|
247 | + '%s', //VNU_phone |
|
248 | + '%d', //VNU_capacity |
|
249 | + '%s', //VNU_url |
|
250 | + '%s', //VNU_virtual_phone |
|
251 | + '%s', //VNU_virtual_url |
|
252 | + '%s', //VNU_google_map_link |
|
253 | + '%d', //VNU_enable_for_gmap |
|
254 | 254 | ); |
255 | - $success = $wpdb->insert($this->_new_meta_table,$insertion_array,$datatypes); |
|
256 | - if( ! $success ){ |
|
255 | + $success = $wpdb->insert($this->_new_meta_table, $insertion_array, $datatypes); |
|
256 | + if ( ! $success) { |
|
257 | 257 | $this->add_error($this->get_migration_script()->_create_error_message_for_db_insertion($this->_old_table, $old_venue, $this->_new_meta_table, $insertion_array, $datatypes)); |
258 | 258 | return 0; |
259 | 259 | } |
@@ -128,6 +128,9 @@ discard block |
||
128 | 128 | return $items_actually_migrated; |
129 | 129 | } |
130 | 130 | |
131 | + /** |
|
132 | + * @param integer $num_items_to_migrate |
|
133 | + */ |
|
131 | 134 | private function _gather_relations_to_add($num_items_to_migrate) { |
132 | 135 | $relations_to_add_this_step = array(); |
133 | 136 | $migrate_up_to_count = $this->count_records_migrated() + $num_items_to_migrate; |
@@ -158,8 +161,6 @@ discard block |
||
158 | 161 | |
159 | 162 | /** |
160 | 163 | * Adds teh relation between the payment method and the currencies it can be used for |
161 | - * @param int $id |
|
162 | - * @param string $gateway_slug |
|
163 | 164 | */ |
164 | 165 | private function _add_currency_relations($pm_id,$currency_code){ |
165 | 166 | global $wpdb; |
@@ -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 | |
@@ -14,7 +14,7 @@ discard block |
||
14 | 14 | * @deprecated in 4.9.40 because the currency payment method table has been deprecated |
15 | 15 | * |
16 | 16 | */ |
17 | -class EE_DMS_4_6_0_payment_method_currencies extends EE_Data_Migration_Script_Stage{ |
|
17 | +class EE_DMS_4_6_0_payment_method_currencies extends EE_Data_Migration_Script_Stage { |
|
18 | 18 | protected $_currency_table_name; |
19 | 19 | protected $_currency_payment_method_table_name; |
20 | 20 | protected $_payment_method_table_name; |
@@ -90,7 +90,7 @@ discard block |
||
90 | 90 | ); |
91 | 91 | public function __construct() { |
92 | 92 | global $wpdb; |
93 | - $this->_pretty_name = __( 'Payment Method Currencies', 'event_espresso' ); |
|
93 | + $this->_pretty_name = __('Payment Method Currencies', 'event_espresso'); |
|
94 | 94 | $this->_payment_method_table_name = $wpdb->prefix.'esp_payment_method'; |
95 | 95 | $this->_currency_payment_method_table_name = $wpdb->prefix.'esp_currency_payment_method'; |
96 | 96 | $this->_currency_table_name = $wpdb->prefix.'esp_currency'; |
@@ -99,8 +99,8 @@ discard block |
||
99 | 99 | |
100 | 100 | protected function _count_records_to_migrate() { |
101 | 101 | $count = 0; |
102 | - foreach($this->_gateway_currencies as $currencies){ |
|
103 | - if( $currencies == 'all'){ |
|
102 | + foreach ($this->_gateway_currencies as $currencies) { |
|
103 | + if ($currencies == 'all') { |
|
104 | 104 | $currencies = $this->_get_all_currencies(); |
105 | 105 | } |
106 | 106 | $count += count($currencies); |
@@ -110,20 +110,20 @@ discard block |
||
110 | 110 | |
111 | 111 | |
112 | 112 | |
113 | - protected function _migration_step( $num_items_to_migrate = 50 ) { |
|
113 | + protected function _migration_step($num_items_to_migrate = 50) { |
|
114 | 114 | $items_actually_migrated = 0; |
115 | 115 | $relations_to_add_this_step = $this->_gather_relations_to_add($num_items_to_migrate); |
116 | - foreach($relations_to_add_this_step as $pm_slug => $currencies){ |
|
116 | + foreach ($relations_to_add_this_step as $pm_slug => $currencies) { |
|
117 | 117 | |
118 | - $id = $this->get_migration_script()->get_mapping_new_pk( 'EE_Gateway_Config', $pm_slug, $this->_payment_method_table_name ); |
|
119 | - foreach( $currencies as $currency ){ |
|
120 | - if( $id ){ |
|
121 | - $this->_add_currency_relations( $id, $currency ); |
|
118 | + $id = $this->get_migration_script()->get_mapping_new_pk('EE_Gateway_Config', $pm_slug, $this->_payment_method_table_name); |
|
119 | + foreach ($currencies as $currency) { |
|
120 | + if ($id) { |
|
121 | + $this->_add_currency_relations($id, $currency); |
|
122 | 122 | } |
123 | 123 | $items_actually_migrated++; |
124 | 124 | } |
125 | 125 | } |
126 | - if($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()){ |
|
126 | + if ($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()) { |
|
127 | 127 | $this->set_completed(); |
128 | 128 | } |
129 | 129 | return $items_actually_migrated; |
@@ -133,14 +133,14 @@ discard block |
||
133 | 133 | $relations_to_add_this_step = array(); |
134 | 134 | $migrate_up_to_count = $this->count_records_migrated() + $num_items_to_migrate; |
135 | 135 | $iterator = 0; |
136 | - foreach($this->_gateway_currencies as $pm_slug => $currencies){ |
|
137 | - if( $currencies == 'all' ){ |
|
136 | + foreach ($this->_gateway_currencies as $pm_slug => $currencies) { |
|
137 | + if ($currencies == 'all') { |
|
138 | 138 | $currencies = $this->_get_all_currencies(); |
139 | 139 | } |
140 | - foreach($currencies as $currency_code){ |
|
141 | - if( $this->count_records_migrated() <= $iterator && |
|
142 | - $iterator < $migrate_up_to_count ){ |
|
143 | - $relations_to_add_this_step[ $pm_slug ] [] = $currency_code; |
|
140 | + foreach ($currencies as $currency_code) { |
|
141 | + if ($this->count_records_migrated() <= $iterator && |
|
142 | + $iterator < $migrate_up_to_count) { |
|
143 | + $relations_to_add_this_step[$pm_slug] [] = $currency_code; |
|
144 | 144 | } |
145 | 145 | $iterator++; |
146 | 146 | } |
@@ -151,7 +151,7 @@ discard block |
||
151 | 151 | * Gets all the currency codes in the database |
152 | 152 | * @return array |
153 | 153 | */ |
154 | - private function _get_all_currencies(){ |
|
154 | + private function _get_all_currencies() { |
|
155 | 155 | global $wpdb; |
156 | 156 | $currencies = $wpdb->get_col("SELECT CUR_code FROM {$this->_currency_table_name}"); |
157 | 157 | return $currencies; |
@@ -162,7 +162,7 @@ discard block |
||
162 | 162 | * @param int $id |
163 | 163 | * @param string $gateway_slug |
164 | 164 | */ |
165 | - private function _add_currency_relations($pm_id,$currency_code){ |
|
165 | + private function _add_currency_relations($pm_id, $currency_code) { |
|
166 | 166 | global $wpdb; |
167 | 167 | $cur_pm_relation = array( |
168 | 168 | 'CUR_code'=>$currency_code, |
@@ -171,11 +171,11 @@ discard block |
||
171 | 171 | $success = $wpdb->insert($this->_currency_payment_method_table_name, |
172 | 172 | $cur_pm_relation, |
173 | 173 | array( |
174 | - '%s',//CUR_code |
|
175 | - '%d',//PMD_ID |
|
174 | + '%s', //CUR_code |
|
175 | + '%d', //PMD_ID |
|
176 | 176 | )); |
177 | - if( ! $success ){ |
|
178 | - $this->add_error( sprintf( __( 'Could not add currency relation %s because %s', "event_espresso" ), wp_json_encode( $cur_pm_relation ), $wpdb->last_error ) ); |
|
177 | + if ( ! $success) { |
|
178 | + $this->add_error(sprintf(__('Could not add currency relation %s because %s', "event_espresso"), wp_json_encode($cur_pm_relation), $wpdb->last_error)); |
|
179 | 179 | } |
180 | 180 | } |
181 | 181 | } |
@@ -57,7 +57,6 @@ |
||
57 | 57 | 'IV'=> __("Invoice", 'event_espresso'), |
58 | 58 | 'MO'=> __("Money Order", 'event_espresso'), |
59 | 59 | * @global type $wpdb |
60 | - * @param int $id |
|
61 | 60 | * @return string |
62 | 61 | */ |
63 | 62 | protected function _get_payment_method_id_by_gateway_name( $gateway_name, $old_pay_method_column ){ |
@@ -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,37 +12,37 @@ discard block |
||
12 | 12 | * @author Mike Nelson |
13 | 13 | * |
14 | 14 | */ |
15 | -class EE_DMS_4_6_0_payments extends EE_Data_Migration_Script_Stage_Table{ |
|
15 | +class EE_DMS_4_6_0_payments extends EE_Data_Migration_Script_Stage_Table { |
|
16 | 16 | protected $_payment_method_table; |
17 | - function __construct(){ |
|
17 | + function __construct() { |
|
18 | 18 | global $wpdb; |
19 | - $this->_old_table = $wpdb->prefix . 'esp_payment'; |
|
20 | - $this->_payment_method_table = $wpdb->prefix . 'esp_payment_method'; |
|
19 | + $this->_old_table = $wpdb->prefix.'esp_payment'; |
|
20 | + $this->_payment_method_table = $wpdb->prefix.'esp_payment_method'; |
|
21 | 21 | $this->_pretty_name = __('Payment-Payment Method Relations', 'event_espresso'); |
22 | 22 | parent::__construct(); |
23 | 23 | } |
24 | - protected function _migrate_old_row( $payment_row ) { |
|
24 | + protected function _migrate_old_row($payment_row) { |
|
25 | 25 | global $wpdb; |
26 | 26 | //get the payment method's ID |
27 | - $PMD_ID = apply_filters( 'FHEE__EE_DMS_4_6_0_payments__migrate_old_row__PMD_ID', $this->_get_payment_method_id_by_gateway_name( $payment_row[ 'PAY_gateway' ], $payment_row[ 'PAY_method'] ) ); |
|
28 | - if( ! $PMD_ID ){ |
|
29 | - $this->add_error( sprintf( __( 'Could not find payment method with PMD_type = \'%1$s\' when migrating payment row %2$s so just assigned it an unknown payment method', 'event_espresso' ), $payment_row[ 'PAY_gateway' ], $this->_json_encode( $payment_row ) ) ); |
|
27 | + $PMD_ID = apply_filters('FHEE__EE_DMS_4_6_0_payments__migrate_old_row__PMD_ID', $this->_get_payment_method_id_by_gateway_name($payment_row['PAY_gateway'], $payment_row['PAY_method'])); |
|
28 | + if ( ! $PMD_ID) { |
|
29 | + $this->add_error(sprintf(__('Could not find payment method with PMD_type = \'%1$s\' when migrating payment row %2$s so just assigned it an unknown payment method', 'event_espresso'), $payment_row['PAY_gateway'], $this->_json_encode($payment_row))); |
|
30 | 30 | $PMD_ID = 0; |
31 | 31 | } |
32 | 32 | $new_values = array( |
33 | 33 | 'PMD_ID' => $PMD_ID, |
34 | - 'PAY_source' => ( $payment_row[ 'PAY_via_admin' ] ? 'ADMIN' : 'CART' ) ); |
|
35 | - $wheres = array( 'PAY_ID' => $payment_row[ 'PAY_ID' ] ); |
|
36 | - $new_value_datatypes = array( '%d', '%s' ); |
|
37 | - $where_datatypes = array( '%d' ); |
|
38 | - $success = $wpdb->update( $this->_old_table, |
|
34 | + 'PAY_source' => ($payment_row['PAY_via_admin'] ? 'ADMIN' : 'CART') ); |
|
35 | + $wheres = array('PAY_ID' => $payment_row['PAY_ID']); |
|
36 | + $new_value_datatypes = array('%d', '%s'); |
|
37 | + $where_datatypes = array('%d'); |
|
38 | + $success = $wpdb->update($this->_old_table, |
|
39 | 39 | $new_values, |
40 | 40 | $wheres, |
41 | 41 | $new_value_datatypes, |
42 | 42 | $where_datatypes |
43 | 43 | ); |
44 | - if( ! $success ){ |
|
45 | - $this->add_error( sprintf( __( 'Couldnt set %1$s row in table %2$s where %3$s', 'event_espresso' ), $this->_json_encode( $new_values ), $this->_old_table, $this->_json_encode( $wheres ) ) ); |
|
44 | + if ( ! $success) { |
|
45 | + $this->add_error(sprintf(__('Couldnt set %1$s row in table %2$s where %3$s', 'event_espresso'), $this->_json_encode($new_values), $this->_old_table, $this->_json_encode($wheres))); |
|
46 | 46 | } |
47 | 47 | } |
48 | 48 | /** |
@@ -60,11 +60,11 @@ discard block |
||
60 | 60 | * @param int $id |
61 | 61 | * @return string |
62 | 62 | */ |
63 | - protected function _get_payment_method_id_by_gateway_name( $gateway_name, $old_pay_method_column ){ |
|
63 | + protected function _get_payment_method_id_by_gateway_name($gateway_name, $old_pay_method_column) { |
|
64 | 64 | global $wpdb; |
65 | 65 | //convert from old known PAY_method values to their corresponding |
66 | 66 | //PMD_type or default PMD_name |
67 | - switch( $old_pay_method_column ) { |
|
67 | + switch ($old_pay_method_column) { |
|
68 | 68 | case 'PP': |
69 | 69 | $pmd_type = 'Paypal_Standard'; |
70 | 70 | break; |
@@ -92,8 +92,8 @@ discard block |
||
92 | 92 | default: |
93 | 93 | $pmd_type = $gateway_name; |
94 | 94 | } |
95 | - $pmd_name = str_replace( "_", " ", $pmd_type ); |
|
96 | - return $wpdb->get_var( $wpdb->prepare( "SELECT PMD_ID FROM " . $wpdb->prefix . "esp_payment_method WHERE PMD_type = %s OR PMD_name = %s", $pmd_type, $pmd_name ) ); |
|
95 | + $pmd_name = str_replace("_", " ", $pmd_type); |
|
96 | + return $wpdb->get_var($wpdb->prepare("SELECT PMD_ID FROM ".$wpdb->prefix."esp_payment_method WHERE PMD_type = %s OR PMD_name = %s", $pmd_type, $pmd_name)); |
|
97 | 97 | } |
98 | 98 | |
99 | 99 |
@@ -49,7 +49,6 @@ |
||
49 | 49 | /** |
50 | 50 | * |
51 | 51 | * @global type $wpdb |
52 | - * @param int $id |
|
53 | 52 | * @return string |
54 | 53 | */ |
55 | 54 | protected function _get_payment_method_id_by_gateway_name( $gateway_name ){ |
@@ -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,38 +12,38 @@ discard block |
||
12 | 12 | * @author Mike Nelson |
13 | 13 | * |
14 | 14 | */ |
15 | -class EE_DMS_4_6_0_transactions extends EE_Data_Migration_Script_Stage_Table{ |
|
15 | +class EE_DMS_4_6_0_transactions extends EE_Data_Migration_Script_Stage_Table { |
|
16 | 16 | protected $_transaction_table; |
17 | 17 | protected $_payment_method_table; |
18 | - function __construct(){ |
|
18 | + function __construct() { |
|
19 | 19 | global $wpdb; |
20 | - $this->_old_table = $wpdb->prefix . 'esp_extra_meta'; |
|
21 | - $this->_transaction_table = $wpdb->prefix . 'esp_transaction'; |
|
22 | - $this->_payment_method_table = $wpdb->prefix . 'esp_payment_method'; |
|
20 | + $this->_old_table = $wpdb->prefix.'esp_extra_meta'; |
|
21 | + $this->_transaction_table = $wpdb->prefix.'esp_transaction'; |
|
22 | + $this->_payment_method_table = $wpdb->prefix.'esp_payment_method'; |
|
23 | 23 | $this->_pretty_name = __('Transaction Payment Method Relations', 'event_espresso'); |
24 | 24 | $this->_extra_where_sql = "WHERE EXM_key = 'gateway' AND EXM_type = 'Transaction'"; |
25 | 25 | parent::__construct(); |
26 | 26 | } |
27 | - protected function _migrate_old_row( $extra_meta_row ) { |
|
27 | + protected function _migrate_old_row($extra_meta_row) { |
|
28 | 28 | global $wpdb; |
29 | 29 | //get the payment method's ID |
30 | - $PMD_ID = $this->_get_payment_method_id_by_gateway_name( $extra_meta_row[ 'EXM_value' ] ); |
|
31 | - if( ! $PMD_ID ){ |
|
32 | - $this->add_error( sprintf( __( 'Could not find payment method with PMD_type = \'%1$s\' when migrating extra meta row %2$s', 'event_espresso' ), $extra_meta_row[ 'EXM_value' ], $this->_json_encode( $extra_meta_row ) ) ); |
|
30 | + $PMD_ID = $this->_get_payment_method_id_by_gateway_name($extra_meta_row['EXM_value']); |
|
31 | + if ( ! $PMD_ID) { |
|
32 | + $this->add_error(sprintf(__('Could not find payment method with PMD_type = \'%1$s\' when migrating extra meta row %2$s', 'event_espresso'), $extra_meta_row['EXM_value'], $this->_json_encode($extra_meta_row))); |
|
33 | 33 | return; |
34 | 34 | } |
35 | - $new_values = array( 'PMD_ID' => $PMD_ID ); |
|
36 | - $wheres = array( 'TXN_ID' => $extra_meta_row[ 'OBJ_ID' ] ); |
|
37 | - $new_value_datatypes = array( '%d' ); |
|
38 | - $where_datatypes = array( '%d' ); |
|
39 | - $success = $wpdb->update( $this->_transaction_table, |
|
35 | + $new_values = array('PMD_ID' => $PMD_ID); |
|
36 | + $wheres = array('TXN_ID' => $extra_meta_row['OBJ_ID']); |
|
37 | + $new_value_datatypes = array('%d'); |
|
38 | + $where_datatypes = array('%d'); |
|
39 | + $success = $wpdb->update($this->_transaction_table, |
|
40 | 40 | $new_values, |
41 | 41 | $wheres, |
42 | 42 | $new_value_datatypes, |
43 | 43 | $where_datatypes |
44 | 44 | ); |
45 | - if( ! $success ){ |
|
46 | - $this->add_error( sprintf( __( 'Couldnt set %1$s row in table %2$s where %3$s', 'event_espresso' ), $this->_json_encode( $new_values ), $this->_transaction_table, $this->_json_encode( $wheres ) ) ); |
|
45 | + if ( ! $success) { |
|
46 | + $this->add_error(sprintf(__('Couldnt set %1$s row in table %2$s where %3$s', 'event_espresso'), $this->_json_encode($new_values), $this->_transaction_table, $this->_json_encode($wheres))); |
|
47 | 47 | } |
48 | 48 | } |
49 | 49 | /** |
@@ -52,9 +52,9 @@ discard block |
||
52 | 52 | * @param int $id |
53 | 53 | * @return string |
54 | 54 | */ |
55 | - protected function _get_payment_method_id_by_gateway_name( $gateway_name ){ |
|
55 | + protected function _get_payment_method_id_by_gateway_name($gateway_name) { |
|
56 | 56 | global $wpdb; |
57 | - return $wpdb->get_var( $wpdb->prepare( "SELECT PMD_ID FROM " . $wpdb->prefix . "esp_payment_method WHERE PMD_type = %s", $gateway_name ) ); |
|
57 | + return $wpdb->get_var($wpdb->prepare("SELECT PMD_ID FROM ".$wpdb->prefix."esp_payment_method WHERE PMD_type = %s", $gateway_name)); |
|
58 | 58 | } |
59 | 59 | |
60 | 60 |
@@ -125,7 +125,7 @@ |
||
125 | 125 | * |
126 | 126 | * @param stdClass $payment |
127 | 127 | * @param array $registrations |
128 | - * @return bool |
|
128 | + * @return boolean|null |
|
129 | 129 | */ |
130 | 130 | protected function _process_registration_payments( $payment, $registrations = array() ){ |
131 | 131 | // how much is available to apply to registrations? |
@@ -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 | ) |
@@ -234,7 +234,7 @@ |
||
234 | 234 | * @param array $old_row_as_array |
235 | 235 | * @param string $new_table |
236 | 236 | * @param array $new_row_as_array columns=>values like used in wpdb->insert |
237 | - * @param array $data_types numerically indexed |
|
237 | + * @param string[] $data_types numerically indexed |
|
238 | 238 | * @return string |
239 | 239 | */ |
240 | 240 | protected function _create_error_message_for_db_insertion($old_table, $old_row_as_array, $new_table, $new_row_as_array, $data_types){ |
@@ -264,9 +264,9 @@ |
||
264 | 264 | /** |
265 | 265 | * Same as json_encode, just avoids putting |
266 | 266 | * serialized arrays into the http build query, as that would |
267 | - * @param array $array_of_data |
|
268 | - * @return string |
|
269 | - */ |
|
267 | + * @param array $array_of_data |
|
268 | + * @return string |
|
269 | + */ |
|
270 | 270 | protected function _json_encode($array_of_data){ |
271 | 271 | //we'd rather NOT serialize the transaction details |
272 | 272 | $fields_to_include = array(); |
@@ -119,7 +119,7 @@ discard block |
||
119 | 119 | $errors = $this->get_errors(); |
120 | 120 | if($errors){ |
121 | 121 | return end($errors); |
122 | - }else{ |
|
122 | + } else{ |
|
123 | 123 | return null; |
124 | 124 | } |
125 | 125 | } |
@@ -131,7 +131,7 @@ discard block |
||
131 | 131 | public function add_error($error, $force = FALSE ){ |
132 | 132 | if( ! defined( 'EE_DMS_ERROR_LIMIT' ) ){ |
133 | 133 | $limit = 50; |
134 | - }else{ |
|
134 | + } else{ |
|
135 | 135 | $limit = EE_DMS_ERROR_LIMIT; |
136 | 136 | } |
137 | 137 | //make sure errors is an array, see ticket #8261 |
@@ -144,10 +144,10 @@ discard block |
||
144 | 144 | $this->_errors = array_slice( $this->_errors, $limit / 2, $limit / 2 ); |
145 | 145 | $this->_errors[] = "Limit reached; removed first half of errors to save space"; |
146 | 146 | $this->_errors[] = $error; |
147 | - }else{ |
|
147 | + } else{ |
|
148 | 148 | $this->_errors[ $limit ] = 'More, but limit reached...'; |
149 | 149 | } |
150 | - }else{ |
|
150 | + } else{ |
|
151 | 151 | $this->_errors[] = $error; |
152 | 152 | } |
153 | 153 | } |
@@ -20,7 +20,7 @@ discard block |
||
20 | 20 | |
21 | 21 | |
22 | 22 | |
23 | -abstract class EE_Data_Migration_Class_Base{ |
|
23 | +abstract class EE_Data_Migration_Class_Base { |
|
24 | 24 | |
25 | 25 | /** |
26 | 26 | * @var $records_to_migrate int count of all that have been migrated |
@@ -72,7 +72,7 @@ discard block |
||
72 | 72 | * @param TableManager $table_manager |
73 | 73 | * @param TableAnalysis $table_analysis |
74 | 74 | */ |
75 | - public function __construct( TableManager $table_manager = null, TableAnalysis $table_analysis = null ){ |
|
75 | + public function __construct(TableManager $table_manager = null, TableAnalysis $table_analysis = null) { |
|
76 | 76 | $this->_table_manager = $table_manager; |
77 | 77 | $this->_table_analysis = $table_analysis; |
78 | 78 | $this->set_status(EE_Data_Migration_Manager::status_continue); |
@@ -85,9 +85,9 @@ discard block |
||
85 | 85 | * @throws EE_Error |
86 | 86 | * @return string |
87 | 87 | */ |
88 | - public function pretty_name(){ |
|
89 | - if($this->_pretty_name === null){ |
|
90 | - throw new EE_Error(sprintf(__("Please give a pretty name to the migration script stage %s by assigning the property _pretty_name in the constructor", "event_espresso"),get_class($this))); |
|
88 | + public function pretty_name() { |
|
89 | + if ($this->_pretty_name === null) { |
|
90 | + throw new EE_Error(sprintf(__("Please give a pretty name to the migration script stage %s by assigning the property _pretty_name in the constructor", "event_espresso"), get_class($this))); |
|
91 | 91 | } |
92 | 92 | return $this->_pretty_name; |
93 | 93 | } |
@@ -95,8 +95,8 @@ discard block |
||
95 | 95 | * |
96 | 96 | * @return int |
97 | 97 | */ |
98 | - public function count_records_to_migrate(){ |
|
99 | - if( $this->_records_to_migrate == null){ |
|
98 | + public function count_records_to_migrate() { |
|
99 | + if ($this->_records_to_migrate == null) { |
|
100 | 100 | $this->_records_to_migrate = $this->_count_records_to_migrate(); |
101 | 101 | } |
102 | 102 | return $this->_records_to_migrate; |
@@ -116,9 +116,9 @@ discard block |
||
116 | 116 | * @return string one of EE_Data_Migration_Manager::status_* constants |
117 | 117 | * @throws EE_Error |
118 | 118 | */ |
119 | - public function get_status(){ |
|
120 | - if($this->_status === null){ |
|
121 | - throw new EE_Error(sprintf(__("Trying to get status of Migration class %s, but it has not been initialized yet. It should be set in the constructor.", "event_espresso"),get_class($this))); |
|
119 | + public function get_status() { |
|
120 | + if ($this->_status === null) { |
|
121 | + throw new EE_Error(sprintf(__("Trying to get status of Migration class %s, but it has not been initialized yet. It should be set in the constructor.", "event_espresso"), get_class($this))); |
|
122 | 122 | } |
123 | 123 | return $this->_status; |
124 | 124 | } |
@@ -127,7 +127,7 @@ discard block |
||
127 | 127 | * @param string $status |
128 | 128 | * @return void |
129 | 129 | */ |
130 | - protected function set_status($status){ |
|
130 | + protected function set_status($status) { |
|
131 | 131 | $this->_status = $status; |
132 | 132 | } |
133 | 133 | /** |
@@ -139,11 +139,11 @@ discard block |
||
139 | 139 | * Returns the last error that occurred. If none occurred, returns null |
140 | 140 | * @return string |
141 | 141 | */ |
142 | - public function get_last_error(){ |
|
142 | + public function get_last_error() { |
|
143 | 143 | $errors = $this->get_errors(); |
144 | - if($errors){ |
|
144 | + if ($errors) { |
|
145 | 145 | return end($errors); |
146 | - }else{ |
|
146 | + } else { |
|
147 | 147 | return null; |
148 | 148 | } |
149 | 149 | } |
@@ -152,26 +152,26 @@ discard block |
||
152 | 152 | * @param string $error a string describing the error that will be useful for debugging. Consider including all the data that led to the error, and a stack trace etc. |
153 | 153 | * @param boolean $force force the error to be added (because otherwise we have a limit). If forcing and errors are already at their limit, we will purposefully forget the first half |
154 | 154 | */ |
155 | - public function add_error($error, $force = FALSE ){ |
|
156 | - if( ! defined( 'EE_DMS_ERROR_LIMIT' ) ){ |
|
155 | + public function add_error($error, $force = FALSE) { |
|
156 | + if ( ! defined('EE_DMS_ERROR_LIMIT')) { |
|
157 | 157 | $limit = 50; |
158 | - }else{ |
|
158 | + } else { |
|
159 | 159 | $limit = EE_DMS_ERROR_LIMIT; |
160 | 160 | } |
161 | 161 | //make sure errors is an array, see ticket #8261 |
162 | - if( is_string( $this->_errors ) ){ |
|
163 | - $this->_errors = array( $this->_errors ); |
|
162 | + if (is_string($this->_errors)) { |
|
163 | + $this->_errors = array($this->_errors); |
|
164 | 164 | } |
165 | - if(count($this->_errors) >= $limit ){ |
|
166 | - if( $force ){ |
|
165 | + if (count($this->_errors) >= $limit) { |
|
166 | + if ($force) { |
|
167 | 167 | //get rid of the first half of the errors and any above the limit |
168 | - $this->_errors = array_slice( $this->_errors, $limit / 2, $limit / 2 ); |
|
168 | + $this->_errors = array_slice($this->_errors, $limit / 2, $limit / 2); |
|
169 | 169 | $this->_errors[] = "Limit reached; removed first half of errors to save space"; |
170 | 170 | $this->_errors[] = $error; |
171 | - }else{ |
|
172 | - $this->_errors[ $limit ] = 'More, but limit reached...'; |
|
171 | + } else { |
|
172 | + $this->_errors[$limit] = 'More, but limit reached...'; |
|
173 | 173 | } |
174 | - }else{ |
|
174 | + } else { |
|
175 | 175 | $this->_errors[] = $error; |
176 | 176 | } |
177 | 177 | } |
@@ -180,57 +180,57 @@ discard block |
||
180 | 180 | * Indicates there was a fatal error and the migration cannot possibly continue |
181 | 181 | * @return boolean |
182 | 182 | */ |
183 | - public function is_broken(){ |
|
183 | + public function is_broken() { |
|
184 | 184 | return $this->get_status() == EE_Data_Migration_Manager::status_fatal_error; |
185 | 185 | } |
186 | 186 | /** |
187 | 187 | * @deprecated since 4.6.12 |
188 | 188 | */ |
189 | - public function is_borked(){ |
|
190 | - EE_Error::doing_it_wrong('is_borked', __( 'The cheeky "is_borked" method had been replaced with the more proper "is_broken"', 'event_espresso' ), '4.6.12'); |
|
189 | + public function is_borked() { |
|
190 | + EE_Error::doing_it_wrong('is_borked', __('The cheeky "is_borked" method had been replaced with the more proper "is_broken"', 'event_espresso'), '4.6.12'); |
|
191 | 191 | return $this->is_broken(); |
192 | 192 | } |
193 | 193 | /** |
194 | 194 | * Sets the status to as having a fatal error |
195 | 195 | */ |
196 | - public function set_broken(){ |
|
196 | + public function set_broken() { |
|
197 | 197 | $this->_status = EE_Data_Migration_Manager::status_fatal_error; |
198 | 198 | } |
199 | 199 | /** |
200 | 200 | * |
201 | 201 | * @deprecated since 4.6.12 |
202 | 202 | */ |
203 | - public function set_borked(){ |
|
204 | - EE_Error::doing_it_wrong('is_borked', __( 'The cheeky "is_borked" method had been replaced with the more proper "is_broken"', 'event_espresso' ), '4.6.12'); |
|
203 | + public function set_borked() { |
|
204 | + EE_Error::doing_it_wrong('is_borked', __('The cheeky "is_borked" method had been replaced with the more proper "is_broken"', 'event_espresso'), '4.6.12'); |
|
205 | 205 | return $this->set_broken(); |
206 | 206 | } |
207 | 207 | /** |
208 | 208 | * Checks if this thing believes it is completed |
209 | 209 | * @return boolean |
210 | 210 | */ |
211 | - public function is_completed(){ |
|
211 | + public function is_completed() { |
|
212 | 212 | return $this->get_status() == EE_Data_Migration_Manager::status_completed; |
213 | 213 | } |
214 | 214 | /** |
215 | 215 | * Checks if the current script has more to do or not (ie, if it's status is CONTINUE) |
216 | 216 | * @return boolean |
217 | 217 | */ |
218 | - public function has_more_to_do(){ |
|
218 | + public function has_more_to_do() { |
|
219 | 219 | return $this->get_status() == EE_Data_Migration_Manager::status_continue; |
220 | 220 | } |
221 | 221 | /** |
222 | 222 | * Marks that we believe this migration thing is completed |
223 | 223 | */ |
224 | - public function set_completed(){ |
|
224 | + public function set_completed() { |
|
225 | 225 | $this->_status = EE_Data_Migration_Manager::status_completed; |
226 | 226 | } |
227 | 227 | |
228 | 228 | /** |
229 | 229 | * Marks that we think this migration class can continue to migrate |
230 | 230 | */ |
231 | - public function reattempt(){ |
|
231 | + public function reattempt() { |
|
232 | 232 | $this->_status = EE_Data_Migration_Manager::status_continue; |
233 | - $this->add_error( __( 'Reattempt migration', 'event_espresso' ), TRUE ); |
|
233 | + $this->add_error(__('Reattempt migration', 'event_espresso'), TRUE); |
|
234 | 234 | } |
235 | 235 | |
236 | 236 | /** |
@@ -239,8 +239,8 @@ discard block |
||
239 | 239 | * possible that this class is defined when it goes to sleep, but NOT available when it |
240 | 240 | * awakes (eg, this class is part of an addon that is deactivated at some point). |
241 | 241 | */ |
242 | - public function properties_as_array(){ |
|
243 | - $properties = get_object_vars($this); |
|
242 | + public function properties_as_array() { |
|
243 | + $properties = get_object_vars($this); |
|
244 | 244 | $properties['class'] = get_class($this); |
245 | 245 | unset($properties['_migration_script']); |
246 | 246 | return $properties; |
@@ -261,22 +261,22 @@ discard block |
||
261 | 261 | * @param array $data_types numerically indexed |
262 | 262 | * @return string |
263 | 263 | */ |
264 | - protected function _create_error_message_for_db_insertion($old_table, $old_row_as_array, $new_table, $new_row_as_array, $data_types){ |
|
264 | + protected function _create_error_message_for_db_insertion($old_table, $old_row_as_array, $new_table, $new_row_as_array, $data_types) { |
|
265 | 265 | global $wpdb; |
266 | 266 | $old_columns_and_values_for_string = array(); |
267 | - foreach($old_row_as_array as $column => $value){ |
|
267 | + foreach ($old_row_as_array as $column => $value) { |
|
268 | 268 | $old_columns_and_values_for_string[] = "$column => $value"; |
269 | 269 | } |
270 | 270 | $new_columns_and_values_for_string = array(); |
271 | 271 | $count = 0; |
272 | - foreach($new_row_as_array as $column => $value){ |
|
272 | + foreach ($new_row_as_array as $column => $value) { |
|
273 | 273 | $new_columns_and_values_for_string[] = " $column => $value (".$data_types[$count++].")"; |
274 | 274 | } |
275 | 275 | return sprintf( |
276 | 276 | __('Received error "%6$s" inserting row %5$s %1$s %5$s into table %2$s.%5$s Data used was %5$s %3$s %5$s from table %4%s.', "event_espresso"), |
277 | - implode(", ",$new_columns_and_values_for_string), |
|
277 | + implode(", ", $new_columns_and_values_for_string), |
|
278 | 278 | $new_table, |
279 | - implode(", ",$old_columns_and_values_for_string), |
|
279 | + implode(", ", $old_columns_and_values_for_string), |
|
280 | 280 | $old_table, |
281 | 281 | '<br/>', |
282 | 282 | $wpdb->last_error |
@@ -291,12 +291,12 @@ discard block |
||
291 | 291 | * @param array $array_of_data |
292 | 292 | * @return string |
293 | 293 | */ |
294 | - protected function _json_encode($array_of_data){ |
|
294 | + protected function _json_encode($array_of_data) { |
|
295 | 295 | //we'd rather NOT serialize the transaction details |
296 | 296 | $fields_to_include = array(); |
297 | - foreach($array_of_data as $name => $value){ |
|
297 | + foreach ($array_of_data as $name => $value) { |
|
298 | 298 | $unserialized_data = @unserialize($value); |
299 | - if($unserialized_data === FALSE){ |
|
299 | + if ($unserialized_data === FALSE) { |
|
300 | 300 | $fields_to_include[$name] = $value; |
301 | 301 | } |
302 | 302 | } |
@@ -309,13 +309,13 @@ discard block |
||
309 | 309 | * @throws EE_Error |
310 | 310 | */ |
311 | 311 | protected function _get_table_manager() { |
312 | - if( $this->_table_manager instanceof TableManager ) { |
|
312 | + if ($this->_table_manager instanceof TableManager) { |
|
313 | 313 | return $this->_table_manager; |
314 | 314 | } else { |
315 | 315 | throw new EE_Error( |
316 | 316 | sprintf( |
317 | - __( 'Table manager on migration class %1$s is not set properly.', 'event_espresso'), |
|
318 | - get_class( $this ) |
|
317 | + __('Table manager on migration class %1$s is not set properly.', 'event_espresso'), |
|
318 | + get_class($this) |
|
319 | 319 | ) |
320 | 320 | ); |
321 | 321 | } |
@@ -327,13 +327,13 @@ discard block |
||
327 | 327 | * @throws EE_Error |
328 | 328 | */ |
329 | 329 | protected function _get_table_analysis() { |
330 | - if( $this->_table_analysis instanceof TableAnalysis ) { |
|
330 | + if ($this->_table_analysis instanceof TableAnalysis) { |
|
331 | 331 | return $this->_table_analysis; |
332 | 332 | } else { |
333 | 333 | throw new EE_Error( |
334 | 334 | sprintf( |
335 | - __( 'Table analysis class on migration class %1$s is not set properly.', 'event_espresso'), |
|
336 | - get_class( $this ) |
|
335 | + __('Table analysis class on migration class %1$s is not set properly.', 'event_espresso'), |
|
336 | + get_class($this) |
|
337 | 337 | ) |
338 | 338 | ); |
339 | 339 | } |