@@ -767,7 +767,7 @@ |
||
| 767 | 767 | * Takes care of setting up the addressee object(s) for the primary attendee. |
| 768 | 768 | * |
| 769 | 769 | * @access protected |
| 770 | - * @return array of EE_Addressee objects |
|
| 770 | + * @return EE_Messages_Addressee[] of EE_Addressee objects |
|
| 771 | 771 | */ |
| 772 | 772 | protected function _primary_attendee_addressees() { |
| 773 | 773 | $aee = $this->_default_addressee_data; |
@@ -864,8 +864,8 @@ |
||
| 864 | 864 | //set the attendee array to blank on each loop; |
| 865 | 865 | $aee = array(); |
| 866 | 866 | if ( isset( $this->_data->reg_obj ) |
| 867 | - && ( $this->_data->reg_obj->attendee_ID() != $att_id ) |
|
| 868 | - && $this->_single_message |
|
| 867 | + && ( $this->_data->reg_obj->attendee_ID() != $att_id ) |
|
| 868 | + && $this->_single_message |
|
| 869 | 869 | ) { |
| 870 | 870 | continue; |
| 871 | 871 | } |
@@ -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 | |
@@ -279,7 +279,7 @@ discard block |
||
| 279 | 279 | * EE_Base_Class_Object |
| 280 | 280 | * @return mixed ( EE_Base_Class||EE_Base_Class[] ) |
| 281 | 281 | */ |
| 282 | - abstract protected function _get_data_for_context( $context, EE_Registration $registration, $id ); |
|
| 282 | + abstract protected function _get_data_for_context($context, EE_Registration $registration, $id); |
|
| 283 | 283 | |
| 284 | 284 | |
| 285 | 285 | |
@@ -306,7 +306,7 @@ discard block |
||
| 306 | 306 | * @deprecated 4.9.0 |
| 307 | 307 | * @return int |
| 308 | 308 | */ |
| 309 | - protected function _get_id_for_msg_url( $context, EE_Registration $registration ) { |
|
| 309 | + protected function _get_id_for_msg_url($context, EE_Registration $registration) { |
|
| 310 | 310 | return 0; |
| 311 | 311 | } |
| 312 | 312 | |
@@ -335,7 +335,7 @@ discard block |
||
| 335 | 335 | * sending. |
| 336 | 336 | * @since 4.9.0 |
| 337 | 337 | */ |
| 338 | - public function do_messenger_hooks( $messenger = null ) { |
|
| 338 | + public function do_messenger_hooks($messenger = null) { |
|
| 339 | 339 | $this->_active_messenger = $messenger; |
| 340 | 340 | $this->_do_messenger_hooks(); |
| 341 | 341 | } |
@@ -384,10 +384,10 @@ discard block |
||
| 384 | 384 | * @param mixed $data This sets the data property for the message type with the incoming data used for generating. |
| 385 | 385 | * @return string (the reference for the data handler) (will be an empty string if could not be determined). |
| 386 | 386 | */ |
| 387 | - public function get_data_handler( $data ) { |
|
| 387 | + public function get_data_handler($data) { |
|
| 388 | 388 | $this->_data = $data; |
| 389 | 389 | $this->_set_data_handler(); |
| 390 | - return apply_filters( 'FHEE__EE_message_type__get_data_handler', $this->_data_handler, $this ); |
|
| 390 | + return apply_filters('FHEE__EE_message_type__get_data_handler', $this->_data_handler, $this); |
|
| 391 | 391 | } |
| 392 | 392 | |
| 393 | 393 | |
@@ -424,26 +424,26 @@ discard block |
||
| 424 | 424 | * @deprecated 4.9.0 Likely 4.9.10 or 4.10.0 will remove this method completely |
| 425 | 425 | * @return string generated url |
| 426 | 426 | */ |
| 427 | - public function get_url_trigger( $context, $sending_messenger, EE_Registration $registration ) { |
|
| 427 | + public function get_url_trigger($context, $sending_messenger, EE_Registration $registration) { |
|
| 428 | 428 | //validate context |
| 429 | 429 | //valid context? |
| 430 | - if ( ! isset( $this->_contexts[ $context ] ) ) { |
|
| 430 | + if ( ! isset($this->_contexts[$context])) { |
|
| 431 | 431 | throw new EE_Error( |
| 432 | 432 | sprintf( |
| 433 | - __( 'The context %s is not a valid context for %s.', 'event_espresso' ), |
|
| 433 | + __('The context %s is not a valid context for %s.', 'event_espresso'), |
|
| 434 | 434 | $context, |
| 435 | - get_class( $this ) |
|
| 435 | + get_class($this) |
|
| 436 | 436 | ) |
| 437 | 437 | ); |
| 438 | 438 | } |
| 439 | 439 | //valid sending_messenger? |
| 440 | 440 | $not_valid_msgr = false; |
| 441 | - foreach ( $this->_with_messengers as $generating => $sendings ) { |
|
| 442 | - if ( empty( $sendings ) || array_search( $sending_messenger, $sendings ) === false ) { |
|
| 441 | + foreach ($this->_with_messengers as $generating => $sendings) { |
|
| 442 | + if (empty($sendings) || array_search($sending_messenger, $sendings) === false) { |
|
| 443 | 443 | $not_valid_msgr = true; |
| 444 | 444 | } |
| 445 | 445 | } |
| 446 | - if ( $not_valid_msgr ) { |
|
| 446 | + if ($not_valid_msgr) { |
|
| 447 | 447 | throw new EE_Error( |
| 448 | 448 | sprintf( |
| 449 | 449 | __( |
@@ -451,7 +451,7 @@ discard block |
||
| 451 | 451 | 'event_espresso' |
| 452 | 452 | ), |
| 453 | 453 | $sending_messenger, |
| 454 | - get_class( $this ) |
|
| 454 | + get_class($this) |
|
| 455 | 455 | ) |
| 456 | 456 | ); |
| 457 | 457 | } |
@@ -462,7 +462,7 @@ discard block |
||
| 462 | 462 | $this->name, |
| 463 | 463 | $registration, |
| 464 | 464 | $this->_GRP_ID, |
| 465 | - $this->_get_id_for_msg_url( $context, $registration ) |
|
| 465 | + $this->_get_id_for_msg_url($context, $registration) |
|
| 466 | 466 | ); |
| 467 | 467 | } |
| 468 | 468 | |
@@ -481,26 +481,26 @@ discard block |
||
| 481 | 481 | * EE_Base_Class_Object |
| 482 | 482 | * @return mixed (EE_Base_Class||EE_Base_Class[]) |
| 483 | 483 | */ |
| 484 | - public function get_data_for_context( $context, EE_Registration $registration, $id = 0 ) { |
|
| 484 | + public function get_data_for_context($context, EE_Registration $registration, $id = 0) { |
|
| 485 | 485 | //valid context? |
| 486 | - if ( ! isset( $this->_contexts[ $context ] ) ) { |
|
| 486 | + if ( ! isset($this->_contexts[$context])) { |
|
| 487 | 487 | throw new EE_Error( |
| 488 | 488 | sprintf( |
| 489 | - __( 'The context %s is not a valid context for %s.', 'event_espresso' ), |
|
| 489 | + __('The context %s is not a valid context for %s.', 'event_espresso'), |
|
| 490 | 490 | $context, |
| 491 | - get_class( $this ) |
|
| 491 | + get_class($this) |
|
| 492 | 492 | ) |
| 493 | 493 | ); |
| 494 | 494 | } |
| 495 | 495 | //get data and apply global and class specific filters on it. |
| 496 | 496 | $data = apply_filters( |
| 497 | 497 | 'FHEE__EE_message_type__get_data_for_context__data', |
| 498 | - $this->_get_data_for_context( $context, $registration, $id ), |
|
| 498 | + $this->_get_data_for_context($context, $registration, $id), |
|
| 499 | 499 | $this |
| 500 | 500 | ); |
| 501 | - $data = apply_filters( 'FHEE__' . get_class( $this ) . '__get_data_for_context__data', $data, $this ); |
|
| 501 | + $data = apply_filters('FHEE__'.get_class($this).'__get_data_for_context__data', $data, $this); |
|
| 502 | 502 | //if empty then something went wrong! |
| 503 | - if ( empty( $data ) ) { |
|
| 503 | + if (empty($data)) { |
|
| 504 | 504 | throw new EE_Error( |
| 505 | 505 | sprintf( |
| 506 | 506 | __( |
@@ -544,7 +544,7 @@ discard block |
||
| 544 | 544 | */ |
| 545 | 545 | protected function _set_with_messengers() { |
| 546 | 546 | $this->_with_messengers = array( |
| 547 | - 'email' => array( 'html' ), |
|
| 547 | + 'email' => array('html'), |
|
| 548 | 548 | ); |
| 549 | 549 | } |
| 550 | 550 | |
@@ -558,7 +558,7 @@ discard block |
||
| 558 | 558 | */ |
| 559 | 559 | public function with_messengers() { |
| 560 | 560 | return apply_filters( |
| 561 | - 'FHEE__EE_message_type__get_with_messengers__with_messengers__' . get_class( $this ), |
|
| 561 | + 'FHEE__EE_message_type__get_with_messengers__with_messengers__'.get_class($this), |
|
| 562 | 562 | $this->_with_messengers |
| 563 | 563 | ); |
| 564 | 564 | } |
@@ -585,7 +585,7 @@ discard block |
||
| 585 | 585 | $messengers = array() |
| 586 | 586 | ) { |
| 587 | 587 | //we can also further refine the context by action (if present). |
| 588 | - return $this->_get_admin_page_content( $page, $action, $extra, $messengers ); |
|
| 588 | + return $this->_get_admin_page_content($page, $action, $extra, $messengers); |
|
| 589 | 589 | } |
| 590 | 590 | |
| 591 | 591 | |
@@ -620,10 +620,10 @@ discard block |
||
| 620 | 620 | public function get_master_templates() { |
| 621 | 621 | //first class specific filter then filter that by the global filter. |
| 622 | 622 | $master_templates = apply_filters( |
| 623 | - 'FHEE__' . get_class( $this ) . '__get_master_templates', |
|
| 623 | + 'FHEE__'.get_class($this).'__get_master_templates', |
|
| 624 | 624 | $this->_master_templates |
| 625 | 625 | ); |
| 626 | - return apply_filters( 'FHEE__EE_message_type__get_master_templates', $master_templates, $this ); |
|
| 626 | + return apply_filters('FHEE__EE_message_type__get_master_templates', $master_templates, $this); |
|
| 627 | 627 | } |
| 628 | 628 | |
| 629 | 629 | |
@@ -637,20 +637,20 @@ discard block |
||
| 637 | 637 | * @return array An array indexed by context where each context is an array of EE_Messages_Addressee objects for |
| 638 | 638 | * that context |
| 639 | 639 | */ |
| 640 | - public function get_addressees( EE_Messages_incoming_data $data, $context = '' ) { |
|
| 640 | + public function get_addressees(EE_Messages_incoming_data $data, $context = '') { |
|
| 641 | 641 | //override _data |
| 642 | 642 | $this->_data = $data; |
| 643 | 643 | $addressees = array(); |
| 644 | 644 | //if incoming context then limit to that context |
| 645 | - if ( ! empty( $context ) ) { |
|
| 646 | - $cntxt = ! empty( $this->_contexts[ $context ] ) ? $this->_contexts[ $context ] : ''; |
|
| 647 | - if ( ! empty( $cntxt ) ) { |
|
| 645 | + if ( ! empty($context)) { |
|
| 646 | + $cntxt = ! empty($this->_contexts[$context]) ? $this->_contexts[$context] : ''; |
|
| 647 | + if ( ! empty($cntxt)) { |
|
| 648 | 648 | $this->_contexts = array(); |
| 649 | - $this->_contexts[ $context ] = $cntxt; |
|
| 649 | + $this->_contexts[$context] = $cntxt; |
|
| 650 | 650 | } |
| 651 | 651 | } |
| 652 | 652 | $this->_set_default_addressee_data(); |
| 653 | - if ( $this->_process_data() ) { |
|
| 653 | + if ($this->_process_data()) { |
|
| 654 | 654 | $addressees = $this->_addressees; |
| 655 | 655 | } |
| 656 | 656 | return $addressees; |
@@ -666,14 +666,14 @@ discard block |
||
| 666 | 666 | */ |
| 667 | 667 | protected function _process_data() { |
| 668 | 668 | //at a minimum, we NEED EE_Attendee objects. |
| 669 | - if ( empty( $this->_data->attendees ) ) { |
|
| 670 | - return false; //there's no data to process! |
|
| 669 | + if (empty($this->_data->attendees)) { |
|
| 670 | + return false; //there's no data to process! |
|
| 671 | 671 | } |
| 672 | 672 | // process addressees for each context. Child classes will have to have methods for |
| 673 | 673 | // each context defined to handle the processing of the data object within them |
| 674 | - foreach ( $this->_contexts as $context => $details ) { |
|
| 675 | - $xpctd_method = '_' . $context . '_addressees'; |
|
| 676 | - if ( ! method_exists( $this, $xpctd_method ) ) { |
|
| 674 | + foreach ($this->_contexts as $context => $details) { |
|
| 675 | + $xpctd_method = '_'.$context.'_addressees'; |
|
| 676 | + if ( ! method_exists($this, $xpctd_method)) { |
|
| 677 | 677 | throw new EE_Error( |
| 678 | 678 | sprintf( |
| 679 | 679 | __( |
@@ -685,7 +685,7 @@ discard block |
||
| 685 | 685 | ) |
| 686 | 686 | ); |
| 687 | 687 | } |
| 688 | - $this->_addressees[ $context ] = call_user_func( array( $this, $xpctd_method ) ); |
|
| 688 | + $this->_addressees[$context] = call_user_func(array($this, $xpctd_method)); |
|
| 689 | 689 | } |
| 690 | 690 | return true; //data was processed successfully. |
| 691 | 691 | } |
@@ -707,7 +707,7 @@ discard block |
||
| 707 | 707 | 'grand_total_line_item' => $this->_data->grand_total_line_item, |
| 708 | 708 | 'txn' => $this->_data->txn, |
| 709 | 709 | 'payments' => $this->_data->payments, |
| 710 | - 'payment' => isset( $this->_data->payment ) && $this->_data->payment instanceof EE_Payment |
|
| 710 | + 'payment' => isset($this->_data->payment) && $this->_data->payment instanceof EE_Payment |
|
| 711 | 711 | ? $this->_data->payment |
| 712 | 712 | : null, |
| 713 | 713 | 'reg_objs' => $this->_data->reg_objs, |
@@ -720,7 +720,7 @@ discard block |
||
| 720 | 720 | 'txn_status' => $this->_data->txn_status, |
| 721 | 721 | 'total_ticket_count' => $this->_data->total_ticket_count, |
| 722 | 722 | ); |
| 723 | - if ( is_array( $this->_data->primary_attendee_data ) ) { |
|
| 723 | + if (is_array($this->_data->primary_attendee_data)) { |
|
| 724 | 724 | $this->_default_addressee_data = array_merge( |
| 725 | 725 | $this->_default_addressee_data, |
| 726 | 726 | $this->_data->primary_attendee_data |
@@ -764,24 +764,24 @@ discard block |
||
| 764 | 764 | 'messenger', |
| 765 | 765 | ); |
| 766 | 766 | $contexts = $this->get_contexts(); |
| 767 | - foreach ( $contexts as $context => $details ) { |
|
| 768 | - $this->_valid_shortcodes[ $context ] = $all_shortcodes; |
|
| 767 | + foreach ($contexts as $context => $details) { |
|
| 768 | + $this->_valid_shortcodes[$context] = $all_shortcodes; |
|
| 769 | 769 | //make sure non admin context does not include the event_author shortcodes |
| 770 | - if ( $context != 'admin' ) { |
|
| 771 | - if ( ( $key = array_search( 'event_author', $this->_valid_shortcodes[ $context ] ) ) !== false ) { |
|
| 772 | - unset( $this->_valid_shortcodes[ $context ][ $key ] ); |
|
| 770 | + if ($context != 'admin') { |
|
| 771 | + if (($key = array_search('event_author', $this->_valid_shortcodes[$context])) !== false) { |
|
| 772 | + unset($this->_valid_shortcodes[$context][$key]); |
|
| 773 | 773 | } |
| 774 | 774 | } |
| 775 | 775 | } |
| 776 | 776 | // make sure admin context does not include the recipient_details shortcodes |
| 777 | 777 | // IF we have admin context hooked in message types might not have that context. |
| 778 | - if ( ! empty( $this->_valid_shortcodes['admin'] ) ) { |
|
| 779 | - if ( ( $key = array_search( 'recipient_details', $this->_valid_shortcodes['admin'] ) ) !== false ) { |
|
| 780 | - unset( $this->_valid_shortcodes['admin'][ $key ] ); |
|
| 778 | + if ( ! empty($this->_valid_shortcodes['admin'])) { |
|
| 779 | + if (($key = array_search('recipient_details', $this->_valid_shortcodes['admin'])) !== false) { |
|
| 780 | + unset($this->_valid_shortcodes['admin'][$key]); |
|
| 781 | 781 | } |
| 782 | 782 | //make sure admin context does not include the recipient_details shortcodes |
| 783 | - if ( ( $key = array_search( 'recipient_list', $this->_valid_shortcodes['admin'] ) ) !== false ) { |
|
| 784 | - unset( $this->_valid_shortcodes['admin'][ $key ] ); |
|
| 783 | + if (($key = array_search('recipient_list', $this->_valid_shortcodes['admin'])) !== false) { |
|
| 784 | + unset($this->_valid_shortcodes['admin'][$key]); |
|
| 785 | 785 | } |
| 786 | 786 | } |
| 787 | 787 | } |
@@ -794,9 +794,9 @@ discard block |
||
| 794 | 794 | * @param array $new_config array of valid shortcodes (by context) |
| 795 | 795 | * @return void sets valid_shortcodes property |
| 796 | 796 | */ |
| 797 | - public function reset_valid_shortcodes_config( $new_config ) { |
|
| 798 | - foreach ( $new_config as $context => $shortcodes ) { |
|
| 799 | - $this->_valid_shortcodes[ $context ] = $shortcodes; |
|
| 797 | + public function reset_valid_shortcodes_config($new_config) { |
|
| 798 | + foreach ($new_config as $context => $shortcodes) { |
|
| 799 | + $this->_valid_shortcodes[$context] = $shortcodes; |
|
| 800 | 800 | } |
| 801 | 801 | } |
| 802 | 802 | |
@@ -813,13 +813,13 @@ discard block |
||
| 813 | 813 | $addressees = array(); |
| 814 | 814 | // first we need to get the event admin user id for all the events |
| 815 | 815 | // and setup an addressee object for each unique admin user. |
| 816 | - foreach ( $this->_data->events as $line_ref => $event ) { |
|
| 817 | - $admin_id = $this->_get_event_admin_id( $event['ID'] ); |
|
| 816 | + foreach ($this->_data->events as $line_ref => $event) { |
|
| 817 | + $admin_id = $this->_get_event_admin_id($event['ID']); |
|
| 818 | 818 | //make sure we are just including the events that belong to this admin! |
| 819 | - $admin_events[ $admin_id ][ $line_ref ] = $event; |
|
| 819 | + $admin_events[$admin_id][$line_ref] = $event; |
|
| 820 | 820 | } |
| 821 | 821 | //k now we can loop through the event_admins and setup the addressee data. |
| 822 | - foreach ( $admin_events as $admin_id => $event_details ) { |
|
| 822 | + foreach ($admin_events as $admin_id => $event_details) { |
|
| 823 | 823 | $aee = array( |
| 824 | 824 | 'user_id' => $admin_id, |
| 825 | 825 | 'events' => $event_details, |
@@ -827,8 +827,8 @@ discard block |
||
| 827 | 827 | 'recipient_id' => $admin_id, |
| 828 | 828 | 'recipient_type' => 'WP_User', |
| 829 | 829 | ); |
| 830 | - $aee = array_merge( $this->_default_addressee_data, $aee ); |
|
| 831 | - $addressees[] = new EE_Messages_Addressee( $aee ); |
|
| 830 | + $aee = array_merge($this->_default_addressee_data, $aee); |
|
| 831 | + $addressees[] = new EE_Messages_Addressee($aee); |
|
| 832 | 832 | } |
| 833 | 833 | return $addressees; |
| 834 | 834 | } |
@@ -848,7 +848,7 @@ discard block |
||
| 848 | 848 | $aee['recipient_id'] = $aee['primary_att_obj'] instanceof EE_Attendee ? $aee['primary_att_obj']->ID() : 0; |
| 849 | 849 | $aee['recipient_type'] = 'Attendee'; |
| 850 | 850 | //great now we can instantiate the $addressee object and return (as an array); |
| 851 | - $add[] = new EE_Messages_Addressee( $aee ); |
|
| 851 | + $add[] = new EE_Messages_Addressee($aee); |
|
| 852 | 852 | return $add; |
| 853 | 853 | } |
| 854 | 854 | |
@@ -865,25 +865,25 @@ discard block |
||
| 865 | 865 | //we just have to loop through the attendees. We'll also set the attached events for each attendee. |
| 866 | 866 | //use to verify unique attendee emails... we don't want to sent multiple copies to the same attendee do we? |
| 867 | 867 | $already_processed = array(); |
| 868 | - foreach ( $this->_data->attendees as $att_id => $details ) { |
|
| 868 | + foreach ($this->_data->attendees as $att_id => $details) { |
|
| 869 | 869 | //set the attendee array to blank on each loop; |
| 870 | 870 | $aee = array(); |
| 871 | - if ( isset( $this->_data->reg_obj ) |
|
| 872 | - && ( $this->_data->reg_obj->attendee_ID() != $att_id ) |
|
| 871 | + if (isset($this->_data->reg_obj) |
|
| 872 | + && ($this->_data->reg_obj->attendee_ID() != $att_id) |
|
| 873 | 873 | && $this->_single_message |
| 874 | 874 | ) { |
| 875 | 875 | continue; |
| 876 | 876 | } |
| 877 | 877 | // is $this->_regs_for_sending present? |
| 878 | 878 | // If so, let's make sure we ONLY generate addressee for registrations in that array. |
| 879 | - if ( ! empty( $this->_regs_for_sending ) && is_array( $this->_regs_for_sending ) ) { |
|
| 880 | - $regs_allowed = array_intersect_key( array_flip( $this->_regs_for_sending ), $details['reg_objs'] ); |
|
| 881 | - if ( empty( $regs_allowed ) ) { |
|
| 879 | + if ( ! empty($this->_regs_for_sending) && is_array($this->_regs_for_sending)) { |
|
| 880 | + $regs_allowed = array_intersect_key(array_flip($this->_regs_for_sending), $details['reg_objs']); |
|
| 881 | + if (empty($regs_allowed)) { |
|
| 882 | 882 | continue; |
| 883 | 883 | } |
| 884 | 884 | } |
| 885 | 885 | if ( |
| 886 | - in_array( $details['attendee_email'], $already_processed ) |
|
| 886 | + in_array($details['attendee_email'], $already_processed) |
|
| 887 | 887 | && apply_filters( |
| 888 | 888 | 'FHEE__EE_message_type___attendee_addressees__prevent_duplicate_email_sends', |
| 889 | 889 | true, |
@@ -894,14 +894,14 @@ discard block |
||
| 894 | 894 | continue; |
| 895 | 895 | } |
| 896 | 896 | $already_processed[] = $details['attendee_email']; |
| 897 | - foreach ( $details as $item => $value ) { |
|
| 898 | - $aee[ $item ] = $value; |
|
| 899 | - if ( $item == 'line_ref' ) { |
|
| 900 | - foreach ( $value as $event_id ) { |
|
| 901 | - $aee['events'][ $event_id ] = $this->_data->events[ $event_id ]; |
|
| 897 | + foreach ($details as $item => $value) { |
|
| 898 | + $aee[$item] = $value; |
|
| 899 | + if ($item == 'line_ref') { |
|
| 900 | + foreach ($value as $event_id) { |
|
| 901 | + $aee['events'][$event_id] = $this->_data->events[$event_id]; |
|
| 902 | 902 | } |
| 903 | 903 | } |
| 904 | - if ( $item == 'attendee_email' ) { |
|
| 904 | + if ($item == 'attendee_email') { |
|
| 905 | 905 | $aee['attendee_email'] = $value; |
| 906 | 906 | } |
| 907 | 907 | /*if ( $item == 'registration_id' ) { |
@@ -910,13 +910,13 @@ discard block |
||
| 910 | 910 | } |
| 911 | 911 | // note the FIRST reg object in this array is the one |
| 912 | 912 | // we'll use for this attendee as the primary registration for this attendee. |
| 913 | - $aee['reg_obj'] = reset( $this->_data->attendees[ $att_id ]['reg_objs'] ); |
|
| 913 | + $aee['reg_obj'] = reset($this->_data->attendees[$att_id]['reg_objs']); |
|
| 914 | 914 | $aee['attendees'] = $this->_data->attendees; |
| 915 | 915 | $aee['recipient_id'] = $att_id; |
| 916 | 916 | $aee['recipient_type'] = 'Attendee'; |
| 917 | 917 | //merge in the primary attendee data |
| 918 | - $aee = array_merge( $this->_default_addressee_data, $aee ); |
|
| 919 | - $add[] = new EE_Messages_Addressee( $aee ); |
|
| 918 | + $aee = array_merge($this->_default_addressee_data, $aee); |
|
| 919 | + $add[] = new EE_Messages_Addressee($aee); |
|
| 920 | 920 | } |
| 921 | 921 | return $add; |
| 922 | 922 | } |
@@ -927,8 +927,8 @@ discard block |
||
| 927 | 927 | * @param $event_id |
| 928 | 928 | * @return int |
| 929 | 929 | */ |
| 930 | - protected function _get_event_admin_id( $event_id ) { |
|
| 931 | - $event = EEM_Event::instance()->get_one_by_ID( $event_id ); |
|
| 930 | + protected function _get_event_admin_id($event_id) { |
|
| 931 | + $event = EEM_Event::instance()->get_one_by_ID($event_id); |
|
| 932 | 932 | return $event instanceof EE_Event ? $event->wp_user() : 0; |
| 933 | 933 | } |
| 934 | 934 | |
@@ -410,7 +410,7 @@ |
||
| 410 | 410 | /** |
| 411 | 411 | * This simply loops through all active messengers and takes care of setting up the |
| 412 | 412 | * EE_Message_To_Generate objects. |
| 413 | - * @param $message_type |
|
| 413 | + * @param string $message_type |
|
| 414 | 414 | * @param $data |
| 415 | 415 | * |
| 416 | 416 | * @return EE_Message_To_Generate[] |
@@ -35,7 +35,7 @@ discard block |
||
| 35 | 35 | * |
| 36 | 36 | * @param EE_Message_Resource_Manager $message_resource_manager |
| 37 | 37 | */ |
| 38 | - public function __construct( EE_Message_Resource_Manager $message_resource_manager ) { |
|
| 38 | + public function __construct(EE_Message_Resource_Manager $message_resource_manager) { |
|
| 39 | 39 | $this->_message_resource_manager = $message_resource_manager; |
| 40 | 40 | $this->_init_queue_and_generator(); |
| 41 | 41 | } |
@@ -50,7 +50,7 @@ discard block |
||
| 50 | 50 | * - $_generator = holds the messages generator |
| 51 | 51 | */ |
| 52 | 52 | protected function _init_queue_and_generator() { |
| 53 | - $this->_generator = EE_Registry::factory( 'EE_Messages_Generator' ); |
|
| 53 | + $this->_generator = EE_Registry::factory('EE_Messages_Generator'); |
|
| 54 | 54 | $this->_queue = $this->_generator->generation_queue(); |
| 55 | 55 | } |
| 56 | 56 | |
@@ -75,31 +75,31 @@ discard block |
||
| 75 | 75 | * @param EE_Messages_Queue $queue_to_process |
| 76 | 76 | * @return bool true for success false for error. |
| 77 | 77 | */ |
| 78 | - public function process_immediately_from_queue( EE_Messages_Queue $queue_to_process ) { |
|
| 78 | + public function process_immediately_from_queue(EE_Messages_Queue $queue_to_process) { |
|
| 79 | 79 | $success = false; |
| 80 | 80 | $messages_to_send = array(); |
| 81 | 81 | $messages_to_generate = array(); |
| 82 | 82 | //loop through and setup the various messages from the queue so we know what is being processed |
| 83 | 83 | $queue_to_process->get_message_repository()->rewind(); |
| 84 | - foreach ( $queue_to_process->get_message_repository() as $message ) { |
|
| 85 | - if ( $message->STS_ID() === EEM_Message::status_incomplete ) { |
|
| 84 | + foreach ($queue_to_process->get_message_repository() as $message) { |
|
| 85 | + if ($message->STS_ID() === EEM_Message::status_incomplete) { |
|
| 86 | 86 | $messages_to_generate[] = $message; |
| 87 | 87 | continue; |
| 88 | 88 | } |
| 89 | 89 | |
| 90 | - if ( in_array( $message->STS_ID(), EEM_Message::instance()->stati_indicating_to_send() ) ) { |
|
| 90 | + if (in_array($message->STS_ID(), EEM_Message::instance()->stati_indicating_to_send())) { |
|
| 91 | 91 | $messages_to_send[] = $message; |
| 92 | 92 | continue; |
| 93 | 93 | } |
| 94 | 94 | } |
| 95 | 95 | |
| 96 | 96 | //do generation/sends |
| 97 | - if ( $messages_to_generate ) { |
|
| 98 | - $success = $this->batch_generate_from_queue( $messages_to_generate, true ); |
|
| 97 | + if ($messages_to_generate) { |
|
| 98 | + $success = $this->batch_generate_from_queue($messages_to_generate, true); |
|
| 99 | 99 | } |
| 100 | 100 | |
| 101 | - if ( $messages_to_send ) { |
|
| 102 | - $sent = $this->batch_send_from_queue( $messages_to_send, true ); |
|
| 101 | + if ($messages_to_send) { |
|
| 102 | + $sent = $this->batch_send_from_queue($messages_to_send, true); |
|
| 103 | 103 | //if there was messages to generate and it failed, then we override any success value for the sending process |
| 104 | 104 | //otherwise we just use the return from batch send. The intent is that there is a simple response for success/fail. |
| 105 | 105 | //Either everything was successful or we consider it a fail. To be clear, this is a limitation of doing |
@@ -119,13 +119,13 @@ discard block |
||
| 119 | 119 | * @return bool|EE_Messages_Queue return false if nothing generated. This returns a new EE_Message_Queue with |
| 120 | 120 | * generated messages. |
| 121 | 121 | */ |
| 122 | - public function batch_generate_from_queue( $messages = array(), $clear_queue = false ) { |
|
| 123 | - if ( $this->_build_queue_for_generation( $messages, $clear_queue ) ) { |
|
| 122 | + public function batch_generate_from_queue($messages = array(), $clear_queue = false) { |
|
| 123 | + if ($this->_build_queue_for_generation($messages, $clear_queue)) { |
|
| 124 | 124 | $new_queue = $this->_generator->generate(); |
| 125 | - if ( $new_queue instanceof EE_Messages_Queue ) { |
|
| 125 | + if ($new_queue instanceof EE_Messages_Queue) { |
|
| 126 | 126 | //unlock queue |
| 127 | 127 | $this->_queue->unlock_queue(); |
| 128 | - $new_queue->initiate_request_by_priority( 'send' ); |
|
| 128 | + $new_queue->initiate_request_by_priority('send'); |
|
| 129 | 129 | return $new_queue; |
| 130 | 130 | } |
| 131 | 131 | } |
@@ -146,24 +146,24 @@ discard block |
||
| 146 | 146 | * |
| 147 | 147 | * @return bool true means queue prepped, false means there was a lock so no generation please. |
| 148 | 148 | */ |
| 149 | - protected function _build_queue_for_generation( $messages = array(), $clear_queue = false ) { |
|
| 149 | + protected function _build_queue_for_generation($messages = array(), $clear_queue = false) { |
|
| 150 | 150 | |
| 151 | - if ( $clear_queue ) { |
|
| 151 | + if ($clear_queue) { |
|
| 152 | 152 | $this->_init_queue_and_generator(); |
| 153 | 153 | } |
| 154 | 154 | |
| 155 | - if ( $messages ) { |
|
| 155 | + if ($messages) { |
|
| 156 | 156 | //if generation is locked then get out now because that means processing is already happening. |
| 157 | - if ( $this->_queue->is_locked() ) { |
|
| 157 | + if ($this->_queue->is_locked()) { |
|
| 158 | 158 | return false; |
| 159 | 159 | } |
| 160 | 160 | |
| 161 | 161 | $this->_queue->lock_queue(); |
| 162 | - $messages = is_array( $messages ) ? $messages : array( $messages ); |
|
| 163 | - foreach ( $messages as $message ) { |
|
| 164 | - if ( $message instanceof EE_Message ) { |
|
| 162 | + $messages = is_array($messages) ? $messages : array($messages); |
|
| 163 | + foreach ($messages as $message) { |
|
| 164 | + if ($message instanceof EE_Message) { |
|
| 165 | 165 | $data = $message->all_extra_meta_array(); |
| 166 | - $this->_queue->add( $message, $data ); |
|
| 166 | + $this->_queue->add($message, $data); |
|
| 167 | 167 | } |
| 168 | 168 | } |
| 169 | 169 | return true; |
@@ -181,22 +181,22 @@ discard block |
||
| 181 | 181 | * |
| 182 | 182 | * @return bool true means queue prepped, false means there was a lock so no queue prepped. |
| 183 | 183 | */ |
| 184 | - protected function _build_queue_for_sending( $messages, $clear_queue = false ) { |
|
| 184 | + protected function _build_queue_for_sending($messages, $clear_queue = false) { |
|
| 185 | 185 | //if sending is locked then get out now because that means processing is already happening. |
| 186 | - if ( $this->_queue->is_locked( EE_Messages_Queue::action_sending ) ) { |
|
| 186 | + if ($this->_queue->is_locked(EE_Messages_Queue::action_sending)) { |
|
| 187 | 187 | return false; |
| 188 | 188 | } |
| 189 | 189 | |
| 190 | - $this->_queue->lock_queue( EE_Messages_Queue::action_sending ); |
|
| 190 | + $this->_queue->lock_queue(EE_Messages_Queue::action_sending); |
|
| 191 | 191 | |
| 192 | - if ( $clear_queue ) { |
|
| 192 | + if ($clear_queue) { |
|
| 193 | 193 | $this->_init_queue_and_generator(); |
| 194 | 194 | } |
| 195 | 195 | |
| 196 | - $messages = is_array( $messages ) ? $messages : array( $messages ); |
|
| 196 | + $messages = is_array($messages) ? $messages : array($messages); |
|
| 197 | 197 | |
| 198 | - foreach ( $messages as $message ) { |
|
| 199 | - $this->_queue->add( $message ); |
|
| 198 | + foreach ($messages as $message) { |
|
| 199 | + $this->_queue->add($message); |
|
| 200 | 200 | } |
| 201 | 201 | return true; |
| 202 | 202 | } |
@@ -212,11 +212,11 @@ discard block |
||
| 212 | 212 | * |
| 213 | 213 | * @return EE_Messages_Queue |
| 214 | 214 | */ |
| 215 | - public function batch_send_from_queue( $messages = array(), $clear_queue = false ) { |
|
| 215 | + public function batch_send_from_queue($messages = array(), $clear_queue = false) { |
|
| 216 | 216 | |
| 217 | - if ( $messages && $this->_build_queue_for_sending( $messages, $clear_queue ) ) { |
|
| 217 | + if ($messages && $this->_build_queue_for_sending($messages, $clear_queue)) { |
|
| 218 | 218 | $this->_queue->execute(); |
| 219 | - $this->_queue->unlock_queue( EE_Messages_Queue::action_sending ); |
|
| 219 | + $this->_queue->unlock_queue(EE_Messages_Queue::action_sending); |
|
| 220 | 220 | } else { |
| 221 | 221 | //get messages to send and execute. |
| 222 | 222 | $this->_queue->get_to_send_batch_and_send(); |
@@ -239,10 +239,10 @@ discard block |
||
| 239 | 239 | * @param EE_Message_To_Generate[] $messages_to_generate |
| 240 | 240 | * @return EE_Messages_Queue |
| 241 | 241 | */ |
| 242 | - public function generate_and_return( $messages_to_generate ) { |
|
| 242 | + public function generate_and_return($messages_to_generate) { |
|
| 243 | 243 | $this->_init_queue_and_generator(); |
| 244 | - $this->_queue_for_generation_loop( $messages_to_generate ); |
|
| 245 | - return $this->_generator->generate( false ); |
|
| 244 | + $this->_queue_for_generation_loop($messages_to_generate); |
|
| 245 | + return $this->_generator->generate(false); |
|
| 246 | 246 | } |
| 247 | 247 | |
| 248 | 248 | |
@@ -253,8 +253,8 @@ discard block |
||
| 253 | 253 | * @param bool $persist Indicate whether to instruct the generator to persist the generated queue (true) or not (false). |
| 254 | 254 | * @return EE_Messages_Queue |
| 255 | 255 | */ |
| 256 | - public function generate_queue( $persist = true ) { |
|
| 257 | - return $this->_generator->generate( $persist ); |
|
| 256 | + public function generate_queue($persist = true) { |
|
| 257 | + return $this->_generator->generate($persist); |
|
| 258 | 258 | } |
| 259 | 259 | |
| 260 | 260 | |
@@ -267,9 +267,9 @@ discard block |
||
| 267 | 267 | * @param bool $test_send Whether this item is for a test send or not. |
| 268 | 268 | * @return EE_Messages_Queue |
| 269 | 269 | */ |
| 270 | - public function queue_for_generation( EE_Message_To_Generate $message_to_generate, $test_send = false ) { |
|
| 271 | - if ( $message_to_generate->valid() ) { |
|
| 272 | - $this->_generator->create_and_add_message_to_queue( $message_to_generate, $test_send ); |
|
| 270 | + public function queue_for_generation(EE_Message_To_Generate $message_to_generate, $test_send = false) { |
|
| 271 | + if ($message_to_generate->valid()) { |
|
| 272 | + $this->_generator->create_and_add_message_to_queue($message_to_generate, $test_send); |
|
| 273 | 273 | } |
| 274 | 274 | } |
| 275 | 275 | |
@@ -285,9 +285,9 @@ discard block |
||
| 285 | 285 | * |
| 286 | 286 | * @param EE_Message_To_Generate[] $messages_to_generate |
| 287 | 287 | */ |
| 288 | - public function batch_queue_for_generation_and_persist( $messages_to_generate ) { |
|
| 288 | + public function batch_queue_for_generation_and_persist($messages_to_generate) { |
|
| 289 | 289 | $this->_init_queue_and_generator(); |
| 290 | - $this->_queue_for_generation_loop( $messages_to_generate ); |
|
| 290 | + $this->_queue_for_generation_loop($messages_to_generate); |
|
| 291 | 291 | $this->_queue->save(); |
| 292 | 292 | } |
| 293 | 293 | |
@@ -303,9 +303,9 @@ discard block |
||
| 303 | 303 | * |
| 304 | 304 | * @param EE_Message_To_Generate[] $messages_to_generate |
| 305 | 305 | */ |
| 306 | - public function batch_queue_for_generation_no_persist( $messages_to_generate ) { |
|
| 306 | + public function batch_queue_for_generation_no_persist($messages_to_generate) { |
|
| 307 | 307 | $this->_init_queue_and_generator(); |
| 308 | - $this->_queue_for_generation_loop( $messages_to_generate ); |
|
| 308 | + $this->_queue_for_generation_loop($messages_to_generate); |
|
| 309 | 309 | } |
| 310 | 310 | |
| 311 | 311 | |
@@ -317,15 +317,15 @@ discard block |
||
| 317 | 317 | * |
| 318 | 318 | * @param EE_Message_To_Generate[] $messages_to_generate |
| 319 | 319 | */ |
| 320 | - protected function _queue_for_generation_loop( $messages_to_generate ) { |
|
| 320 | + protected function _queue_for_generation_loop($messages_to_generate) { |
|
| 321 | 321 | //make sure is in an array. |
| 322 | - if ( ! is_array( $messages_to_generate ) ) { |
|
| 323 | - $messages_to_generate = array( $messages_to_generate ); |
|
| 322 | + if ( ! is_array($messages_to_generate)) { |
|
| 323 | + $messages_to_generate = array($messages_to_generate); |
|
| 324 | 324 | } |
| 325 | 325 | |
| 326 | - foreach ( $messages_to_generate as $message_to_generate ) { |
|
| 327 | - if ( $message_to_generate instanceof EE_Message_To_Generate && $message_to_generate->valid() ) { |
|
| 328 | - $this->queue_for_generation( $message_to_generate ); |
|
| 326 | + foreach ($messages_to_generate as $message_to_generate) { |
|
| 327 | + if ($message_to_generate instanceof EE_Message_To_Generate && $message_to_generate->valid()) { |
|
| 328 | + $this->queue_for_generation($message_to_generate); |
|
| 329 | 329 | } |
| 330 | 330 | } |
| 331 | 331 | } |
@@ -340,10 +340,10 @@ discard block |
||
| 340 | 340 | * @param EE_Message_To_Generate[] |
| 341 | 341 | * @return EE_Messages_Queue |
| 342 | 342 | */ |
| 343 | - public function generate_and_queue_for_sending( $messages_to_generate ) { |
|
| 343 | + public function generate_and_queue_for_sending($messages_to_generate) { |
|
| 344 | 344 | $this->_init_queue_and_generator(); |
| 345 | - $this->_queue_for_generation_loop( $messages_to_generate ); |
|
| 346 | - return $this->_generator->generate( true ); |
|
| 345 | + $this->_queue_for_generation_loop($messages_to_generate); |
|
| 346 | + return $this->_generator->generate(true); |
|
| 347 | 347 | } |
| 348 | 348 | |
| 349 | 349 | |
@@ -357,10 +357,10 @@ discard block |
||
| 357 | 357 | * @param bool $test_send Whether this is a test send or not. |
| 358 | 358 | * @return EE_Messages_Queue | bool false if unable to generate otherwise the generated queue. |
| 359 | 359 | */ |
| 360 | - public function generate_for_preview( EE_Message_To_Generate $message_to_generate, $test_send = false ) { |
|
| 361 | - if ( ! $message_to_generate->valid() ) { |
|
| 360 | + public function generate_for_preview(EE_Message_To_Generate $message_to_generate, $test_send = false) { |
|
| 361 | + if ( ! $message_to_generate->valid()) { |
|
| 362 | 362 | EE_Error::add_error( |
| 363 | - __( 'Unable to generate preview because of invalid data', 'event_espresso' ), |
|
| 363 | + __('Unable to generate preview because of invalid data', 'event_espresso'), |
|
| 364 | 364 | __FILE__, |
| 365 | 365 | __FUNCTION__, |
| 366 | 366 | __LINE__ |
@@ -368,14 +368,14 @@ discard block |
||
| 368 | 368 | return false; |
| 369 | 369 | } |
| 370 | 370 | //just make sure preview is set on the $message_to_generate (in case client forgot) |
| 371 | - $message_to_generate->set_preview( true ); |
|
| 371 | + $message_to_generate->set_preview(true); |
|
| 372 | 372 | $this->_init_queue_and_generator(); |
| 373 | - $this->queue_for_generation( $message_to_generate, $test_send ); |
|
| 374 | - $generated_queue = $this->_generator->generate( false ); |
|
| 375 | - if ( $generated_queue->execute( false ) ) { |
|
| 373 | + $this->queue_for_generation($message_to_generate, $test_send); |
|
| 374 | + $generated_queue = $this->_generator->generate(false); |
|
| 375 | + if ($generated_queue->execute(false)) { |
|
| 376 | 376 | //the first queue item should be the preview |
| 377 | 377 | $generated_queue->get_message_repository()->rewind(); |
| 378 | - if ( ! $generated_queue->get_message_repository()->valid() ) { |
|
| 378 | + if ( ! $generated_queue->get_message_repository()->valid()) { |
|
| 379 | 379 | return $generated_queue; |
| 380 | 380 | } |
| 381 | 381 | return $generated_queue->get_message_repository()->is_test_send() ? true : $generated_queue; |
@@ -392,15 +392,15 @@ discard block |
||
| 392 | 392 | * @param EE_Message_To_Generate $message_to_generate |
| 393 | 393 | * @return bool true or false for success. |
| 394 | 394 | */ |
| 395 | - public function queue_for_sending( EE_Message_To_Generate $message_to_generate ) { |
|
| 396 | - if ( ! $message_to_generate->valid() ) { |
|
| 395 | + public function queue_for_sending(EE_Message_To_Generate $message_to_generate) { |
|
| 396 | + if ( ! $message_to_generate->valid()) { |
|
| 397 | 397 | return false; |
| 398 | 398 | } |
| 399 | 399 | $this->_init_queue_and_generator(); |
| 400 | 400 | $message = $message_to_generate->get_EE_Message(); |
| 401 | - $this->_queue->add( $message ); |
|
| 402 | - if ( $message->send_now() ) { |
|
| 403 | - $this->_queue->execute( false ); |
|
| 401 | + $this->_queue->add($message); |
|
| 402 | + if ($message->send_now()) { |
|
| 403 | + $this->_queue->execute(false); |
|
| 404 | 404 | } else { |
| 405 | 405 | $this->_queue->save(); |
| 406 | 406 | } |
@@ -413,12 +413,12 @@ discard block |
||
| 413 | 413 | * @param EE_Message_To_Generate $message_to_generate |
| 414 | 414 | * @return EE_Messages_Queue | null |
| 415 | 415 | */ |
| 416 | - public function generate_and_send_now( EE_Message_To_Generate $message_to_generate ) { |
|
| 417 | - if ( ! $message_to_generate->valid() ) { |
|
| 416 | + public function generate_and_send_now(EE_Message_To_Generate $message_to_generate) { |
|
| 417 | + if ( ! $message_to_generate->valid()) { |
|
| 418 | 418 | return null; |
| 419 | 419 | } |
| 420 | 420 | // is there supposed to be a sending messenger for this message? |
| 421 | - if ( $message_to_generate instanceof EEI_Has_Sending_Messenger ) { |
|
| 421 | + if ($message_to_generate instanceof EEI_Has_Sending_Messenger) { |
|
| 422 | 422 | // make sure it's valid, but if it's not, |
| 423 | 423 | // then set the value of $sending_messenger to an EE_Error object |
| 424 | 424 | // so that downstream code can easily see that things went wrong. |
@@ -434,14 +434,14 @@ discard block |
||
| 434 | 434 | $sending_messenger = null; |
| 435 | 435 | } |
| 436 | 436 | |
| 437 | - if ( $message_to_generate->get_EE_Message()->STS_ID() === EEM_Message::status_idle ) { |
|
| 437 | + if ($message_to_generate->get_EE_Message()->STS_ID() === EEM_Message::status_idle) { |
|
| 438 | 438 | $this->_init_queue_and_generator(); |
| 439 | - $this->_queue->add( $message_to_generate->get_EE_Message() ); |
|
| 440 | - $this->_queue->execute( false, $sending_messenger ); |
|
| 439 | + $this->_queue->add($message_to_generate->get_EE_Message()); |
|
| 440 | + $this->_queue->execute(false, $sending_messenger); |
|
| 441 | 441 | return $this->_queue; |
| 442 | - } elseif ( $message_to_generate->get_EE_Message()->STS_ID() === EEM_Message::status_incomplete ) { |
|
| 443 | - $generated_queue = $this->generate_and_return( array( $message_to_generate ) ); |
|
| 444 | - $generated_queue->execute( false, $sending_messenger ); |
|
| 442 | + } elseif ($message_to_generate->get_EE_Message()->STS_ID() === EEM_Message::status_incomplete) { |
|
| 443 | + $generated_queue = $this->generate_and_return(array($message_to_generate)); |
|
| 444 | + $generated_queue->execute(false, $sending_messenger); |
|
| 445 | 445 | return $generated_queue; |
| 446 | 446 | } |
| 447 | 447 | return null; |
@@ -458,13 +458,13 @@ discard block |
||
| 458 | 458 | * @param mixed $data The data being used for generation. |
| 459 | 459 | * @param bool $persist Whether to persist the queued messages to the db or not. |
| 460 | 460 | */ |
| 461 | - public function generate_for_all_active_messengers( $message_type, $data, $persist = true ) { |
|
| 462 | - $messages_to_generate = $this->setup_mtgs_for_all_active_messengers( $message_type, $data ); |
|
| 463 | - if ( $persist ) { |
|
| 464 | - $this->batch_queue_for_generation_and_persist( $messages_to_generate ); |
|
| 461 | + public function generate_for_all_active_messengers($message_type, $data, $persist = true) { |
|
| 462 | + $messages_to_generate = $this->setup_mtgs_for_all_active_messengers($message_type, $data); |
|
| 463 | + if ($persist) { |
|
| 464 | + $this->batch_queue_for_generation_and_persist($messages_to_generate); |
|
| 465 | 465 | $this->_queue->initiate_request_by_priority(); |
| 466 | 466 | } else { |
| 467 | - $this->batch_queue_for_generation_no_persist( $messages_to_generate ); |
|
| 467 | + $this->batch_queue_for_generation_no_persist($messages_to_generate); |
|
| 468 | 468 | } |
| 469 | 469 | } |
| 470 | 470 | |
@@ -479,11 +479,11 @@ discard block |
||
| 479 | 479 | * |
| 480 | 480 | * @return EE_Message_To_Generate[] |
| 481 | 481 | */ |
| 482 | - public function setup_mtgs_for_all_active_messengers( $message_type, $data ) { |
|
| 482 | + public function setup_mtgs_for_all_active_messengers($message_type, $data) { |
|
| 483 | 483 | $messages_to_generate = array(); |
| 484 | - foreach ( $this->_message_resource_manager->active_messengers() as $messenger_slug => $messenger_object ) { |
|
| 485 | - $message_to_generate = new EE_Message_To_Generate( $messenger_slug, $message_type, $data ); |
|
| 486 | - if ( $message_to_generate->valid() ) { |
|
| 484 | + foreach ($this->_message_resource_manager->active_messengers() as $messenger_slug => $messenger_object) { |
|
| 485 | + $message_to_generate = new EE_Message_To_Generate($messenger_slug, $message_type, $data); |
|
| 486 | + if ($message_to_generate->valid()) { |
|
| 487 | 487 | $messages_to_generate[] = $message_to_generate; |
| 488 | 488 | } |
| 489 | 489 | } |
@@ -498,29 +498,29 @@ discard block |
||
| 498 | 498 | * and send. |
| 499 | 499 | * @param array $message_ids |
| 500 | 500 | */ |
| 501 | - public function setup_messages_from_ids_and_send( $message_ids ) { |
|
| 501 | + public function setup_messages_from_ids_and_send($message_ids) { |
|
| 502 | 502 | $this->_init_queue_and_generator(); |
| 503 | - $messages = EEM_Message::instance()->get_all( array( |
|
| 503 | + $messages = EEM_Message::instance()->get_all(array( |
|
| 504 | 504 | array( |
| 505 | - 'MSG_ID' => array( 'IN', $message_ids ), |
|
| 505 | + 'MSG_ID' => array('IN', $message_ids), |
|
| 506 | 506 | 'STS_ID' => array( |
| 507 | 507 | 'IN', |
| 508 | 508 | array_merge( |
| 509 | 509 | EEM_Message::instance()->stati_indicating_sent(), |
| 510 | - array( EEM_Message::status_retry ) |
|
| 510 | + array(EEM_Message::status_retry) |
|
| 511 | 511 | ), |
| 512 | 512 | ), |
| 513 | 513 | ), |
| 514 | 514 | )); |
| 515 | 515 | //set the Messages to resend. |
| 516 | - foreach ( $messages as $message ) { |
|
| 517 | - if ( $message instanceof EE_Message ) { |
|
| 518 | - $message->set_STS_ID( EEM_Message::status_resend ); |
|
| 519 | - $this->_queue->add( $message ); |
|
| 516 | + foreach ($messages as $message) { |
|
| 517 | + if ($message instanceof EE_Message) { |
|
| 518 | + $message->set_STS_ID(EEM_Message::status_resend); |
|
| 519 | + $this->_queue->add($message); |
|
| 520 | 520 | } |
| 521 | 521 | } |
| 522 | 522 | |
| 523 | - $this->_queue->initiate_request_by_priority( 'send' ); |
|
| 523 | + $this->_queue->initiate_request_by_priority('send'); |
|
| 524 | 524 | } |
| 525 | 525 | |
| 526 | 526 | |
@@ -534,23 +534,23 @@ discard block |
||
| 534 | 534 | * |
| 535 | 535 | * @return EE_Message_To_Generate[] |
| 536 | 536 | */ |
| 537 | - public function setup_messages_to_generate_from_registration_ids_in_request( $registration_ids_key = '_REG_ID' ) { |
|
| 538 | - EE_Registry::instance()->load_core( 'Request_Handler' ); |
|
| 539 | - EE_Registry::instance()->load_helper( 'MSG_Template' ); |
|
| 537 | + public function setup_messages_to_generate_from_registration_ids_in_request($registration_ids_key = '_REG_ID') { |
|
| 538 | + EE_Registry::instance()->load_core('Request_Handler'); |
|
| 539 | + EE_Registry::instance()->load_helper('MSG_Template'); |
|
| 540 | 540 | $regs_to_send = array(); |
| 541 | - $regIDs = EE_Registry::instance()->REQ->get( $registration_ids_key ); |
|
| 542 | - if ( empty( $regIDs ) ) { |
|
| 543 | - EE_Error::add_error( __('Something went wrong because we\'re missing the registration ID', 'event_espresso'), __FILE__, __FUNCTION__, __LINE__ ); |
|
| 541 | + $regIDs = EE_Registry::instance()->REQ->get($registration_ids_key); |
|
| 542 | + if (empty($regIDs)) { |
|
| 543 | + EE_Error::add_error(__('Something went wrong because we\'re missing the registration ID', 'event_espresso'), __FILE__, __FUNCTION__, __LINE__); |
|
| 544 | 544 | return false; |
| 545 | 545 | } |
| 546 | 546 | |
| 547 | 547 | //make sure is an array |
| 548 | - $regIDs = is_array( $regIDs ) ? $regIDs : array( $regIDs ); |
|
| 548 | + $regIDs = is_array($regIDs) ? $regIDs : array($regIDs); |
|
| 549 | 549 | |
| 550 | - foreach( $regIDs as $regID ) { |
|
| 551 | - $reg = EEM_Registration::instance()->get_one_by_ID( $regID ); |
|
| 552 | - if ( ! $reg instanceof EE_Registration ) { |
|
| 553 | - EE_Error::add_error( sprintf( __('Unable to retrieve a registration object for the given reg id (%s)', 'event_espresso'), $regID ) ); |
|
| 550 | + foreach ($regIDs as $regID) { |
|
| 551 | + $reg = EEM_Registration::instance()->get_one_by_ID($regID); |
|
| 552 | + if ( ! $reg instanceof EE_Registration) { |
|
| 553 | + EE_Error::add_error(sprintf(__('Unable to retrieve a registration object for the given reg id (%s)', 'event_espresso'), $regID)); |
|
| 554 | 554 | return false; |
| 555 | 555 | } |
| 556 | 556 | $regs_to_send[$reg->transaction_ID()][$reg->status_ID()][] = $reg; |
@@ -558,13 +558,13 @@ discard block |
||
| 558 | 558 | |
| 559 | 559 | $messages_to_generate = array(); |
| 560 | 560 | |
| 561 | - foreach ( $regs_to_send as $status_group ) { |
|
| 562 | - foreach ( $status_group as $status_id => $registrations ) { |
|
| 561 | + foreach ($regs_to_send as $status_group) { |
|
| 562 | + foreach ($status_group as $status_id => $registrations) { |
|
| 563 | 563 | $messages_to_generate = array_merge( |
| 564 | 564 | $messages_to_generate, |
| 565 | 565 | $this->setup_mtgs_for_all_active_messengers( |
| 566 | - EEH_MSG_Template::convert_reg_status_to_message_type( $status_id ), |
|
| 567 | - array( $registrations, $status_id ) |
|
| 566 | + EEH_MSG_Template::convert_reg_status_to_message_type($status_id), |
|
| 567 | + array($registrations, $status_id) |
|
| 568 | 568 | ) |
| 569 | 569 | ); |
| 570 | 570 | } |
@@ -33,7 +33,7 @@ discard block |
||
| 33 | 33 | 0 => array( |
| 34 | 34 | 'content_id' => 'attendee-column-tip', |
| 35 | 35 | 'target' => '.column-attendees .dashicons-groups', |
| 36 | - 'content' => sprintf( __('%s Registrations', 'event_espresso'), EEH_Template::pretty_status(EEM_Registration::status_id_approved, FALSE, 'sentence') ), |
|
| 36 | + 'content' => sprintf(__('%s Registrations', 'event_espresso'), EEH_Template::pretty_status(EEM_Registration::status_id_approved, FALSE, 'sentence')), |
|
| 37 | 37 | 'options' => array( |
| 38 | 38 | 'position' => array( |
| 39 | 39 | 'my' => 'bottom left', |
@@ -124,7 +124,7 @@ discard block |
||
| 124 | 124 | * @param EE_Datetime constant $status What status is set (by class) |
| 125 | 125 | * @return string The status legend with the related status highlighted |
| 126 | 126 | */ |
| 127 | - private function _event_status_legend( $status ) { |
|
| 127 | + private function _event_status_legend($status) { |
|
| 128 | 128 | |
| 129 | 129 | $status_array = array( |
| 130 | 130 | 'active_status' => EE_Datetime::active, |
@@ -136,7 +136,7 @@ discard block |
||
| 136 | 136 | 'inactive_status' => EE_Datetime::inactive |
| 137 | 137 | ); |
| 138 | 138 | |
| 139 | - return EEH_Template::status_legend( $status_array, $status ); |
|
| 139 | + return EEH_Template::status_legend($status_array, $status); |
|
| 140 | 140 | } |
| 141 | 141 | |
| 142 | 142 | } |
| 143 | 143 | \ No newline at end of file |
@@ -92,7 +92,7 @@ discard block |
||
| 92 | 92 | |
| 93 | 93 | |
| 94 | 94 | private function _registration_trash_message() { |
| 95 | - return '<p>' . __('This lock-icon means that this registration cannot be trashed. Registrations that belong to a transaction that has payments cannot be trashed. If you wish to trash this registration then you must delete all payments attached to the related transaction first.', 'event_espresso') . '</p>'; |
|
| 95 | + return '<p>'.__('This lock-icon means that this registration cannot be trashed. Registrations that belong to a transaction that has payments cannot be trashed. If you wish to trash this registration then you must delete all payments attached to the related transaction first.', 'event_espresso').'</p>'; |
|
| 96 | 96 | } |
| 97 | 97 | |
| 98 | 98 | |
@@ -104,7 +104,7 @@ discard block |
||
| 104 | 104 | * @param EEM_Registration constant $status What status is set (by class) |
| 105 | 105 | * @return string The status legend with the related status highlighted |
| 106 | 106 | */ |
| 107 | - private function _registration_status_legend( $status ) { |
|
| 107 | + private function _registration_status_legend($status) { |
|
| 108 | 108 | |
| 109 | 109 | $status_array = array( |
| 110 | 110 | 'approved_status' => EEM_Registration::status_id_approved, |
@@ -114,6 +114,6 @@ discard block |
||
| 114 | 114 | 'cancelled_status' => EEM_Registration::status_id_cancelled |
| 115 | 115 | ); |
| 116 | 116 | |
| 117 | - return EEH_Template::status_legend( $status_array, $status ); |
|
| 117 | + return EEH_Template::status_legend($status_array, $status); |
|
| 118 | 118 | } |
| 119 | 119 | } |
| 120 | 120 | \ No newline at end of file |
@@ -32,16 +32,16 @@ discard block |
||
| 32 | 32 | */ |
| 33 | 33 | public function __construct() { |
| 34 | 34 | |
| 35 | - do_action( 'AHEE_log', __FILE__, __FUNCTION__, '' ); |
|
| 36 | - if ( ! defined( 'TXN_PG_SLUG' ) ) { |
|
| 37 | - define( 'TXN_PG_SLUG', 'espresso_transactions' ); |
|
| 38 | - define( 'TXN_PG_NAME', ucwords( str_replace( '_', '', TXN_PG_SLUG ) ) ); |
|
| 39 | - define( 'TXN_ADMIN', EE_ADMIN_PAGES . 'transactions' . DS ); |
|
| 40 | - define( 'TXN_ADMIN_URL', admin_url( 'admin.php?page=' . TXN_PG_SLUG ) ); |
|
| 41 | - define( 'TXN_ASSETS_PATH', TXN_ADMIN . 'assets' . DS ); |
|
| 42 | - define( 'TXN_ASSETS_URL', str_replace( '\\', '/', EE_ADMIN_PAGES_URL . 'transactions/assets' . DS ) ); |
|
| 43 | - define( 'TXN_TEMPLATE_PATH', TXN_ADMIN . 'templates' . DS ); |
|
| 44 | - define( 'TXN_TEMPLATE_URL', str_replace( '\\', '/', EE_ADMIN_PAGES_URL . 'transactions/templates' . DS ) ); |
|
| 35 | + do_action('AHEE_log', __FILE__, __FUNCTION__, ''); |
|
| 36 | + if ( ! defined('TXN_PG_SLUG')) { |
|
| 37 | + define('TXN_PG_SLUG', 'espresso_transactions'); |
|
| 38 | + define('TXN_PG_NAME', ucwords(str_replace('_', '', TXN_PG_SLUG))); |
|
| 39 | + define('TXN_ADMIN', EE_ADMIN_PAGES.'transactions'.DS); |
|
| 40 | + define('TXN_ADMIN_URL', admin_url('admin.php?page='.TXN_PG_SLUG)); |
|
| 41 | + define('TXN_ASSETS_PATH', TXN_ADMIN.'assets'.DS); |
|
| 42 | + define('TXN_ASSETS_URL', str_replace('\\', '/', EE_ADMIN_PAGES_URL.'transactions/assets'.DS)); |
|
| 43 | + define('TXN_TEMPLATE_PATH', TXN_ADMIN.'templates'.DS); |
|
| 44 | + define('TXN_TEMPLATE_URL', str_replace('\\', '/', EE_ADMIN_PAGES_URL.'transactions/templates'.DS)); |
|
| 45 | 45 | } |
| 46 | 46 | parent::__construct(); |
| 47 | 47 | } |
@@ -63,7 +63,7 @@ discard block |
||
| 63 | 63 | * @return void |
| 64 | 64 | */ |
| 65 | 65 | protected function _set_menu_map() { |
| 66 | - $this->_menu_map = new EE_Admin_Page_Sub_Menu( array( |
|
| 66 | + $this->_menu_map = new EE_Admin_Page_Sub_Menu(array( |
|
| 67 | 67 | 'menu_group' => 'main', |
| 68 | 68 | 'menu_order' => 50, |
| 69 | 69 | 'show_on_menu' => EE_Admin_Page_Menu_Map::BLOG_ADMIN_ONLY, |
@@ -1,4 +1,6 @@ |
||
| 1 | -<?php if ( ! defined('EVENT_ESPRESSO_VERSION')) exit('No direct script access allowed'); |
|
| 1 | +<?php if ( ! defined('EVENT_ESPRESSO_VERSION')) { |
|
| 2 | + exit('No direct script access allowed'); |
|
| 3 | +} |
|
| 2 | 4 | /** |
| 3 | 5 | * Event Espresso |
| 4 | 6 | * |
@@ -83,7 +83,7 @@ discard block |
||
| 83 | 83 | * @param EEM_Transaction constant $status What status is set (by class) |
| 84 | 84 | * @return string The status legend with the related status highlighted |
| 85 | 85 | */ |
| 86 | - private function _transaction_status_legend( $status ) { |
|
| 86 | + private function _transaction_status_legend($status) { |
|
| 87 | 87 | |
| 88 | 88 | $status_array = array( |
| 89 | 89 | 'overpaid' => EEM_Transaction::overpaid_status_code, |
@@ -92,6 +92,6 @@ discard block |
||
| 92 | 92 | 'failed' => EEM_Transaction::failed_status_code, |
| 93 | 93 | ); |
| 94 | 94 | |
| 95 | - return EEH_Template::status_legend( $status_array, $status ); |
|
| 95 | + return EEH_Template::status_legend($status_array, $status); |
|
| 96 | 96 | } |
| 97 | 97 | } |
| 98 | 98 | \ No newline at end of file |
@@ -55,21 +55,21 @@ discard block |
||
| 55 | 55 | 'QSO_deleted'=>new EE_Trashed_Flag_Field('QSO_deleted', __('Flag indicating Option was trashed','event_espresso'), false, false) |
| 56 | 56 | ) |
| 57 | 57 | */ |
| 58 | -class EE_DMS_4_1_0_questions extends EE_Data_Migration_Script_Stage{ |
|
| 58 | +class EE_DMS_4_1_0_questions extends EE_Data_Migration_Script_Stage { |
|
| 59 | 59 | private $_old_table; |
| 60 | 60 | private $_new_table; |
| 61 | 61 | private $_option_table; |
| 62 | - function _migration_step($num_items=50){ |
|
| 62 | + function _migration_step($num_items = 50) { |
|
| 63 | 63 | global $wpdb; |
| 64 | 64 | $start_at_record = $this->count_records_migrated(); |
| 65 | - $rows = $wpdb->get_results($wpdb->prepare("SELECT * FROM $this->_old_table LIMIT %d,%d",$start_at_record,$num_items),ARRAY_A); |
|
| 65 | + $rows = $wpdb->get_results($wpdb->prepare("SELECT * FROM $this->_old_table LIMIT %d,%d", $start_at_record, $num_items), ARRAY_A); |
|
| 66 | 66 | $items_actually_migrated = 0; |
| 67 | - foreach($rows as $question_row){ |
|
| 67 | + foreach ($rows as $question_row) { |
|
| 68 | 68 | $new_id = $this->_insert_new_question($question_row); |
| 69 | 69 | $this->get_migration_script()->set_mapping($this->_old_table, $question_row['id'], $this->_new_table, $new_id); |
| 70 | 70 | $items_actually_migrated++; |
| 71 | 71 | } |
| 72 | - if($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()){ |
|
| 72 | + if ($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()) { |
|
| 73 | 73 | $this->set_completed(); |
| 74 | 74 | } |
| 75 | 75 | return $items_actually_migrated; |
@@ -87,14 +87,14 @@ discard block |
||
| 87 | 87 | $this->_option_table = $wpdb->prefix."esp_question_option"; |
| 88 | 88 | parent::__construct(); |
| 89 | 89 | } |
| 90 | - private function _insert_new_question($old_question){ |
|
| 90 | + private function _insert_new_question($old_question) { |
|
| 91 | 91 | global $wpdb; |
| 92 | 92 | //if this pretends to be a 'system' question, check if we already have a |
| 93 | 93 | //system question for that string. If so, pretend THAT new question |
| 94 | 94 | //is what we just isnerted |
| 95 | - if($old_question['system_name']){ |
|
| 96 | - $id_of_new_system_question = intval($wpdb->get_var($wpdb->prepare("SELECT QST_ID FROM {$this->_new_table} WHERE QST_system = %s",$old_question['system_name']))); |
|
| 97 | - if($id_of_new_system_question){ |
|
| 95 | + if ($old_question['system_name']) { |
|
| 96 | + $id_of_new_system_question = intval($wpdb->get_var($wpdb->prepare("SELECT QST_ID FROM {$this->_new_table} WHERE QST_system = %s", $old_question['system_name']))); |
|
| 97 | + if ($id_of_new_system_question) { |
|
| 98 | 98 | return $id_of_new_system_question; |
| 99 | 99 | } |
| 100 | 100 | //ok so this must be the first one. Carry on. |
@@ -113,27 +113,27 @@ discard block |
||
| 113 | 113 | 'QST_deleted'=>false |
| 114 | 114 | ); |
| 115 | 115 | $datatypes = array( |
| 116 | - '%s',//QST_display_text |
|
| 117 | - '%s',//QST-admin_label |
|
| 118 | - '%s',//QST_system |
|
| 119 | - '%s',//QST_type |
|
| 120 | - '%d',//QST_required |
|
| 121 | - '%s',//QST_required_text |
|
| 122 | - '%d',//QST_order |
|
| 123 | - '%d',//QST_admin_only |
|
| 124 | - '%d',//QST_wp_user |
|
| 125 | - '%d',//QST_deleted |
|
| 116 | + '%s', //QST_display_text |
|
| 117 | + '%s', //QST-admin_label |
|
| 118 | + '%s', //QST_system |
|
| 119 | + '%s', //QST_type |
|
| 120 | + '%d', //QST_required |
|
| 121 | + '%s', //QST_required_text |
|
| 122 | + '%d', //QST_order |
|
| 123 | + '%d', //QST_admin_only |
|
| 124 | + '%d', //QST_wp_user |
|
| 125 | + '%d', //QST_deleted |
|
| 126 | 126 | ); |
| 127 | - $success = $wpdb->insert($this->_new_table,$cols_n_values,$datatypes); |
|
| 128 | - if ( ! $success){ |
|
| 127 | + $success = $wpdb->insert($this->_new_table, $cols_n_values, $datatypes); |
|
| 128 | + if ( ! $success) { |
|
| 129 | 129 | $this->add_error($this->get_migration_script()->_create_error_message_for_db_insertion($this->_old_table, $old_question, $this->_new_table, $cols_n_values, $datatypes)); |
| 130 | 130 | return 0; |
| 131 | 131 | } |
| 132 | 132 | $new_id = $wpdb->insert_id; |
| 133 | 133 | //now take care of posisbly adding question options |
| 134 | - if(in_array($old_question['question_type'],array('DROPDOWN','SINGLE','MULTIPLE'))){ |
|
| 135 | - $options = explode(",",$old_question['response']); |
|
| 136 | - foreach($options as $option){ |
|
| 134 | + if (in_array($old_question['question_type'], array('DROPDOWN', 'SINGLE', 'MULTIPLE'))) { |
|
| 135 | + $options = explode(",", $old_question['response']); |
|
| 136 | + foreach ($options as $option) { |
|
| 137 | 137 | $this->_insert_question_option($option, $new_id); |
| 138 | 138 | } |
| 139 | 139 | } |
@@ -146,7 +146,7 @@ discard block |
||
| 146 | 146 | * @param int $question_id |
| 147 | 147 | * @return int |
| 148 | 148 | */ |
| 149 | - private function _insert_question_option($option,$question_id){ |
|
| 149 | + private function _insert_question_option($option, $question_id) { |
|
| 150 | 150 | $option = trim($option); |
| 151 | 151 | global $wpdb; |
| 152 | 152 | $cols_n_values = array( |
@@ -154,14 +154,14 @@ discard block |
||
| 154 | 154 | 'QSO_value'=>$option, |
| 155 | 155 | 'QSO_deleted'=>false |
| 156 | 156 | ); |
| 157 | - $datatypes= array( |
|
| 158 | - '%d',//QST_ID |
|
| 159 | - '%s',//QSO_value |
|
| 160 | - '%d',//QSO_deleted |
|
| 157 | + $datatypes = array( |
|
| 158 | + '%d', //QST_ID |
|
| 159 | + '%s', //QSO_value |
|
| 160 | + '%d', //QSO_deleted |
|
| 161 | 161 | ); |
| 162 | - $success = $wpdb->insert($this->_option_table,$cols_n_values,$datatypes); |
|
| 163 | - if ( ! $success ){ |
|
| 164 | - $this->add_error($this->get_migration_script()->_create_error_message_for_db_insertion($this->_old_table, array('option'=>$option,'new_question_id'=>$question_id), $this->_option_table, $cols_n_values, $datatypes)); |
|
| 162 | + $success = $wpdb->insert($this->_option_table, $cols_n_values, $datatypes); |
|
| 163 | + if ( ! $success) { |
|
| 164 | + $this->add_error($this->get_migration_script()->_create_error_message_for_db_insertion($this->_old_table, array('option'=>$option, 'new_question_id'=>$question_id), $this->_option_table, $cols_n_values, $datatypes)); |
|
| 165 | 165 | return 0; |
| 166 | 166 | } |
| 167 | 167 | return $wpdb->insert_id; |
@@ -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,68 +12,68 @@ discard block |
||
| 12 | 12 | * @author Mike Nelson |
| 13 | 13 | * |
| 14 | 14 | */ |
| 15 | -class EE_DMS_4_8_0_event_subtotals extends EE_Data_Migration_Script_Stage_Table{ |
|
| 16 | - function __construct(){ |
|
| 15 | +class EE_DMS_4_8_0_event_subtotals extends EE_Data_Migration_Script_Stage_Table { |
|
| 16 | + function __construct() { |
|
| 17 | 17 | global $wpdb; |
| 18 | - $this->_old_table = $wpdb->prefix . 'esp_line_item'; |
|
| 18 | + $this->_old_table = $wpdb->prefix.'esp_line_item'; |
|
| 19 | 19 | $this->_extra_where_sql = ' WHERE LIN_type="sub-total" AND LIN_code="pre-tax-subtotal"'; |
| 20 | 20 | $this->_pretty_name = __('Event Sub-total line items', 'event_espresso'); |
| 21 | 21 | parent::__construct(); |
| 22 | 22 | } |
| 23 | - protected function _migrate_old_row( $line_item_row ) { |
|
| 23 | + protected function _migrate_old_row($line_item_row) { |
|
| 24 | 24 | global $wpdb; |
| 25 | 25 | //what event is this line item for? this can be found by looking at its transaction's registration's EVT_ID |
| 26 | - $event_id = $wpdb->get_var( $wpdb->prepare( 'SELECT EVT_ID FROM ' . $wpdb->prefix . 'esp_registration WHERE TXN_ID=%d LIMIT 1', $line_item_row[ 'TXN_ID' ] ) ); |
|
| 26 | + $event_id = $wpdb->get_var($wpdb->prepare('SELECT EVT_ID FROM '.$wpdb->prefix.'esp_registration WHERE TXN_ID=%d LIMIT 1', $line_item_row['TXN_ID'])); |
|
| 27 | 27 | $new_line_item_data = array( |
| 28 | - 'LIN_code' => 'event-' . $event_id, |
|
| 29 | - 'TXN_ID' => $line_item_row[ 'TXN_ID' ], |
|
| 30 | - 'LIN_name' => __( 'Event', 'event_espresso' ), |
|
| 31 | - 'LIN_desc' => $line_item_row[ 'LIN_desc' ], |
|
| 32 | - 'LIN_unit_price' => $line_item_row[ 'LIN_unit_price' ], |
|
| 33 | - 'LIN_percent' => $line_item_row[ 'LIN_percent' ], |
|
| 34 | - 'LIN_is_taxable' => $line_item_row[ 'LIN_is_taxable' ], |
|
| 35 | - 'LIN_order' => $line_item_row[ 'LIN_order' ], |
|
| 36 | - 'LIN_total' => $line_item_row[ 'LIN_total' ], |
|
| 37 | - 'LIN_quantity' => $line_item_row[ 'LIN_quantity' ], |
|
| 38 | - 'LIN_parent' => $line_item_row[ 'LIN_ID'], |
|
| 28 | + 'LIN_code' => 'event-'.$event_id, |
|
| 29 | + 'TXN_ID' => $line_item_row['TXN_ID'], |
|
| 30 | + 'LIN_name' => __('Event', 'event_espresso'), |
|
| 31 | + 'LIN_desc' => $line_item_row['LIN_desc'], |
|
| 32 | + 'LIN_unit_price' => $line_item_row['LIN_unit_price'], |
|
| 33 | + 'LIN_percent' => $line_item_row['LIN_percent'], |
|
| 34 | + 'LIN_is_taxable' => $line_item_row['LIN_is_taxable'], |
|
| 35 | + 'LIN_order' => $line_item_row['LIN_order'], |
|
| 36 | + 'LIN_total' => $line_item_row['LIN_total'], |
|
| 37 | + 'LIN_quantity' => $line_item_row['LIN_quantity'], |
|
| 38 | + 'LIN_parent' => $line_item_row['LIN_ID'], |
|
| 39 | 39 | 'LIN_type' => 'sub-total', |
| 40 | 40 | 'OBJ_type' => 'Event', |
| 41 | 41 | 'OBJ_ID' => $event_id, |
| 42 | 42 | ); |
| 43 | 43 | $new_line_item_datatypes = array( |
| 44 | - '%s',//LIN_code |
|
| 45 | - '%d',//TXN_ID |
|
| 46 | - '%s',//LIN_name |
|
| 47 | - '%s',//LIN_desc |
|
| 48 | - '%f',//LIN_unit_price |
|
| 49 | - '%f',//LIN_percent |
|
| 50 | - '%d',//LIN_is_taxable |
|
| 51 | - '%d',//LIN_order |
|
| 52 | - '%f',//LIN_total |
|
| 53 | - '%d',//LIN_quantity |
|
| 54 | - '%d',//LIN_parent |
|
| 55 | - '%s',//LIN_type |
|
| 56 | - '%s',//OBJ_type |
|
| 57 | - '%d',//OBJ_ID |
|
| 44 | + '%s', //LIN_code |
|
| 45 | + '%d', //TXN_ID |
|
| 46 | + '%s', //LIN_name |
|
| 47 | + '%s', //LIN_desc |
|
| 48 | + '%f', //LIN_unit_price |
|
| 49 | + '%f', //LIN_percent |
|
| 50 | + '%d', //LIN_is_taxable |
|
| 51 | + '%d', //LIN_order |
|
| 52 | + '%f', //LIN_total |
|
| 53 | + '%d', //LIN_quantity |
|
| 54 | + '%d', //LIN_parent |
|
| 55 | + '%s', //LIN_type |
|
| 56 | + '%s', //OBJ_type |
|
| 57 | + '%d', //OBJ_ID |
|
| 58 | 58 | ); |
| 59 | 59 | //insert the new event subtotal line item, pointing to this line item |
| 60 | - $success = $wpdb->insert( $this->_old_table, $new_line_item_data, $new_line_item_datatypes ); |
|
| 61 | - if( ! $success ) { |
|
| 62 | - $this->add_error( $this->_create_error_message_for_db_insertion( $this->_old_table, $line_item_row, $this->_old_table, $new_line_item_data, $new_line_item_datatypes ) ); |
|
| 60 | + $success = $wpdb->insert($this->_old_table, $new_line_item_data, $new_line_item_datatypes); |
|
| 61 | + if ( ! $success) { |
|
| 62 | + $this->add_error($this->_create_error_message_for_db_insertion($this->_old_table, $line_item_row, $this->_old_table, $new_line_item_data, $new_line_item_datatypes)); |
|
| 63 | 63 | } |
| 64 | 64 | $new_line_item_id = $wpdb->insert_id; |
| 65 | - $this->get_migration_script()->set_mapping($this->_old_table, $line_item_row[ 'LIN_ID' ], $this->_old_table, $new_line_item_id ); |
|
| 65 | + $this->get_migration_script()->set_mapping($this->_old_table, $line_item_row['LIN_ID'], $this->_old_table, $new_line_item_id); |
|
| 66 | 66 | $query = $wpdb->prepare( |
| 67 | 67 | "UPDATE {$this->_old_table} SET LIN_parent=%d WHERE LIN_parent = %d AND LIN_ID != %d LIMIT 100", |
| 68 | 68 | $new_line_item_id, |
| 69 | - $line_item_row[ 'LIN_ID' ], |
|
| 69 | + $line_item_row['LIN_ID'], |
|
| 70 | 70 | $new_line_item_id ); |
| 71 | - $success = $wpdb->query( $query ); |
|
| 72 | - if( $success === false ) { |
|
| 71 | + $success = $wpdb->query($query); |
|
| 72 | + if ($success === false) { |
|
| 73 | 73 | $this->add_error( |
| 74 | - sprintf( __( 'Error updating rows to new event subtotal %1$s from %2$s. Error was: %3$s, while using query %4$s which had a result of %5$s', 'event_espresso' ), |
|
| 74 | + sprintf(__('Error updating rows to new event subtotal %1$s from %2$s. Error was: %3$s, while using query %4$s which had a result of %5$s', 'event_espresso'), |
|
| 75 | 75 | $new_line_item_id, |
| 76 | - $line_item_row[ 'LIN_ID' ], |
|
| 76 | + $line_item_row['LIN_ID'], |
|
| 77 | 77 | $wpdb->last_error, |
| 78 | 78 | $query, |
| 79 | 79 | $success) ); |
@@ -1,5 +1,5 @@ discard block |
||
| 1 | -<?php if ( !defined( 'EVENT_ESPRESSO_VERSION' ) ) { |
|
| 2 | - exit( 'No direct script access allowed' ); |
|
| 1 | +<?php if ( ! defined('EVENT_ESPRESSO_VERSION')) { |
|
| 2 | + exit('No direct script access allowed'); |
|
| 3 | 3 | } |
| 4 | 4 | /** |
| 5 | 5 | * EE_WP_User class |
@@ -22,9 +22,9 @@ discard block |
||
| 22 | 22 | * @param array $props_n_values |
| 23 | 23 | * @return EE_WP_User|mixed |
| 24 | 24 | */ |
| 25 | - public static function new_instance( $props_n_values = array() ) { |
|
| 26 | - $has_object = parent::_check_for_object( $props_n_values, __CLASS__ ); |
|
| 27 | - return $has_object ? $has_object : new self( $props_n_values ); |
|
| 25 | + public static function new_instance($props_n_values = array()) { |
|
| 26 | + $has_object = parent::_check_for_object($props_n_values, __CLASS__); |
|
| 27 | + return $has_object ? $has_object : new self($props_n_values); |
|
| 28 | 28 | } |
| 29 | 29 | |
| 30 | 30 | |
@@ -33,8 +33,8 @@ discard block |
||
| 33 | 33 | * @param array $props_n_values |
| 34 | 34 | * @return EE_WP_User |
| 35 | 35 | */ |
| 36 | - public static function new_instance_from_db( $props_n_values = array() ) { |
|
| 37 | - return new self( $props_n_values, TRUE ); |
|
| 36 | + public static function new_instance_from_db($props_n_values = array()) { |
|
| 37 | + return new self($props_n_values, TRUE); |
|
| 38 | 38 | } |
| 39 | 39 | |
| 40 | 40 | /** |
@@ -42,8 +42,8 @@ discard block |
||
| 42 | 42 | * @return WP_User |
| 43 | 43 | */ |
| 44 | 44 | public function wp_user_obj() { |
| 45 | - if( ! $this->_wp_user_obj ) { |
|
| 46 | - $this->_wp_user_obj = get_user_by('ID', $this->ID() ); |
|
| 45 | + if ( ! $this->_wp_user_obj) { |
|
| 46 | + $this->_wp_user_obj = get_user_by('ID', $this->ID()); |
|
| 47 | 47 | } |
| 48 | 48 | return $this->_wp_user_obj; |
| 49 | 49 | } |
@@ -69,7 +69,7 @@ discard block |
||
| 69 | 69 | $_SERVER['REQUEST_URI'] |
| 70 | 70 | ) |
| 71 | 71 | ), |
| 72 | - get_edit_user_link( $this->ID() ) |
|
| 72 | + get_edit_user_link($this->ID()) |
|
| 73 | 73 | ) |
| 74 | 74 | ); |
| 75 | 75 | } |
@@ -87,7 +87,7 @@ discard block |
||
| 87 | 87 | * @return string |
| 88 | 88 | */ |
| 89 | 89 | public function get_admin_overview_link() { |
| 90 | - return admin_url( 'users.php' ); |
|
| 90 | + return admin_url('users.php'); |
|
| 91 | 91 | } |
| 92 | 92 | |
| 93 | 93 | |
@@ -20,7 +20,7 @@ |
||
| 20 | 20 | |
| 21 | 21 | /** |
| 22 | 22 | * @param array $props_n_values |
| 23 | - * @return EE_WP_User|mixed |
|
| 23 | + * @return EE_Base_Class |
|
| 24 | 24 | */ |
| 25 | 25 | public static function new_instance( $props_n_values = array() ) { |
| 26 | 26 | $has_object = parent::_check_for_object( $props_n_values, __CLASS__ ); |