Changeset 3426934

Timestamp:

12/24/2025 03:37:45 PM (8 weeks ago)

Author:

combustiongroup

Message:

Release 1.2.9: implement bulk pull contacts

Location:

happy-texting/trunk

Files:

• core/class-happy-texting.php (modified) (2 diffs)
• happy-texting.php (modified) (3 diffs)
• readme.txt (modified) (1 diff)

happy-texting/trunk/core/class-happy-texting.php

@@ -202 +202 @@
                     'permission_callback' => '__return_true'
                 ));
+            });
+
+            add_action('rest_api_init', function () {
+                register_rest_route('wc/v3', 'texting_webhook_bulk', [
+                    'methods'  => 'POST',
+                    'callback' => [$this, 'texting_webhook_bulk'],
+                    'permission_callback' => function () {
+                        if ( ! class_exists('WC_REST_Authentication') ) {
+                            return false;
+                        }
+            
+                        $auth = new WC_REST_Authentication();
+                        $user_id = $auth->authenticate(false);
+            
+                        if ( ! $user_id ) {
+                            return new WP_Error(
+                                'woocommerce_rest_authentication_error',
+                                'Invalid API credentials',
+                                ['status' => 401]
+                            );
+                        }
+            
+                        return true;
+                    }
+                ]);
             });
 
@@ -1434 +1459 @@
         function texting_webhook_auth_verify(){
             wp_send_json_success("Success", 200);
+        }
+
+        /**
+         * Process a single contact lookup and return customer data
+         * 
+         * @param string $search_term Email or mobile number to search for
+         * @param bool $include_last_order Whether to include last_order object in response (default: true for backward compatibility)
+         * @return array|null Customer data array on success, null if customer not found
+         */
+        private function process_single_contact($search_term, $include_last_order = true) {
+            $customer_id = NULL;
+            
+            $orders = wc_order_search($search_term);
+            if (!$orders) {
+                return null;
+            }
+            
+            $last_order_id = intval(end($orders));
+            $order = wc_get_order($last_order_id);
+            
+            // Validate that order exists (WC_Order_Refund extends WC_Order, so checking WC_Order covers both)
+            if (!$order || !is_a($order, 'WC_Order')) {
+                return null;
+            }
+            
+            // Check if this is a refund order
+            if (is_a($order, 'WC_Order_Refund')) {
+                // For refund orders, get the parent order
+                $parent_id = $order->get_parent_id();
+                if ($parent_id) {
+                    $parent_order = wc_get_order($parent_id);
+                    if ($parent_order && is_a($parent_order, 'WC_Order')) {
+                        $customer_id = $parent_order->get_customer_id();
+                        // Use parent order for subsequent operations
+                        $order = $parent_order;
+                    } else {
+                        return null;
+                    }
+                } else {
+                    return null;
+                }
+            } else {
+                // Regular order
+                $customer_id = $order->get_customer_id();
+            }
+            
+            if (!$customer_id) {
+                return null;
+            }
+            
+            $customer = new WC_Customer($customer_id);
+            $last_order = $customer->get_last_order();
+            
+            $locations_label = '' != get_option('orddd_location_field_label') ? get_option('orddd_location_field_label') : 'Pickup Location';
+            
+            if ($last_order && $last_order->get_data()) {
+                $last_order_date = $last_order->get_data()['date_created'];
+                $last_order_object = $include_last_order ? $last_order->get_data() : null;
+                $shipping_method = $order->get_shipping_method();
+                $pickup_location = NULL;
+                if ($shipping_method == "Local pickup") {
+                    $pickup_location = $order->get_meta("$locations_label");
+                }
+            } else {
+                $last_order_date = [
+                    "date" => date("Y-m-d H:i:s"),
+                    "timezone_type" => 1,
+                    "timezone" => "+00:00"
+                ];
+                $last_order_object = null;
+                $pickup_location = NULL;
+                $shipping_method = NULL;
+            }
+            
+            $api_key = Happy_Texting_Settings::get(Happy_Texting_Settings::OPTION_API_KEY);
+            $textword_id = Happy_Texting_Settings::get(Happy_Texting_Settings::OPTION_TEXTWORD_ID);
+            $orders_count = $customer->get_order_count();
+            $total_spent = $customer->get_total_spent();
+            
+            global $wpdb;
+            $status = "no subscription";
+            $auto_query = "SELECT autoship_status FROM {$wpdb->prefix}wc_autoship_schedules WHERE customer_id=" . intval($customer_id);
+            
+            try {
+                $schedules = $wpdb->get_results($auto_query, 'ARRAY_A');
+                
+                if (!empty($schedules)) {
+                    $status = "paused subscription";
+                    
+                    foreach ($schedules as $schedule) {
+                        if ($schedule['autoship_status'] == 1) {
+                            $status = "active subscription";
+                            break;
+                        }
+                    }
+                }
+            } catch (Exception $e) {
+                // Continue with default status
+            }
+            
+            $result = [
+                'api_key' => $api_key,
+                'text_word' => $textword_id,
+                'first_name' => $order->get_billing_first_name(),
+                'last_name' => $order->get_billing_last_name(),
+                'email' => $order->get_billing_email(),
+                'phone' => $order->get_billing_phone(),
+                'event' => 'checkout',
+                'last_order_total' => $order->get_total(),
+                'orders_count' => $orders_count,
+                'total_spent' => $total_spent,
+                'last_order_date' => $last_order_date,
+                'shipping_method' => $shipping_method,
+                'pickup_location' => $pickup_location,
+                'location_label' => $locations_label,
+                'subscription_status' => $status,
+            ];
+            
+            if ($include_last_order) {
+                $result['last_order'] = $last_order_object;
+            }
+            
+            return $result;
+        }
+
+        /**
+         * Bulk webhook endpoint to process multiple contacts in a single request
+         * 
+         * @param WP_REST_Request $request The REST request object
+         * @return WP_REST_Response|WP_Error
+         */
+        public function texting_webhook_bulk($request) {
+            // Get JSON body parameters
+            $params = $request->get_json_params();
+            
+            // Validate contacts array exists and is not empty
+            if (!isset($params['contacts']) || !is_array($params['contacts']) || empty($params['contacts'])) {
+                return new WP_Error(
+                    'missing_contacts',
+                    'contacts array is required and must not be empty',
+                    ['status' => 400]
+                );
+            }
+            
+            $contacts = $params['contacts'];
+            
+            // Validate maximum contacts limit (100)
+            if (count($contacts) > 100) {
+                return new WP_Error(
+                    'too_many_contacts',
+                    'Maximum 100 contacts allowed per request',
+                    ['status' => 400]
+                );
+            }
+            
+            // Validate each contact has at least mobile or email
+            foreach ($contacts as $index => $contact) {
+                if (!isset($contact['mobile']) && !isset($contact['email'])) {
+                    return new WP_Error(
+                        'invalid_contact',
+                        sprintf('Contact at index %d must have either mobile or email', $index),
+                        ['status' => 400]
+                    );
+                }
+            }
+            
+            // Process each contact
+            $results = [];
+            
+            foreach ($contacts as $contact) {
+                try {
+                    // Extract search term (email first, then mobile, same priority as existing endpoint)
+                    $search_term = '';
+                    if (isset($contact['email']) && !empty($contact['email'])) {
+                        $search_term = sanitize_text_field($contact['email']);
+                    } elseif (isset($contact['mobile']) && !empty($contact['mobile'])) {
+                        $search_term = sanitize_text_field($contact['mobile']);
+                    }
+                    
+                    // Process the contact
+                    $customer_data = $this->process_single_contact($search_term, false); // Don't include last_order
+                    
+                    if ($customer_data) {
+                        // Success - return customer data
+                        $results[] = array_merge(
+                            ['success' => true],
+                            $customer_data
+                        );
+                    } else {
+                        // Customer not found
+                        $results[] = [
+                            'success' => false,
+                            'error' => 'no customer for that search term',
+                            'mobile' => isset($contact['mobile']) ? $contact['mobile'] : null,
+                            'email' => isset($contact['email']) ? $contact['email'] : null,
+                        ];
+                    }
+                } catch (Exception $e) {
+                    // Handle any exceptions without stopping the batch
+                    $results[] = [
+                        'success' => false,
+                        'error' => 'Error processing contact: ' . $e->getMessage(),
+                        'mobile' => isset($contact['mobile']) ? $contact['mobile'] : null,
+                        'email' => isset($contact['email']) ? $contact['email'] : null,
+                    ];
+                }
+            }
+            
+            // Return response with success flag and results array
+            $response = [
+                'success' => true,
+                'results' => $results,
+            ];
+            
+            return rest_ensure_response($response);
         }
 

happy-texting/trunk/happy-texting.php

@@ -5 +5 @@
  * @package       HAPPYTEXTI
  * @author        Happy Texting
- * @version       1.2.8
+ * @version       1.2.9
  *
  * @wordpress-plugin
@@ -11 +11 @@
  * Plugin URI:    https://hapytexting.com
  * Description:   This plugin allows you to keep your customer list up to sync with www.happytexting.com
- * Version:       1.2.8
+ * Version:       1.2.9
  * Author:        Combustion Group
  * Author URI:    https://combustiongroup.com
@@ -27 +27 @@
 
 // Plugin version
-define( 'HAPPYTEXTI_VERSION',       '1.2.8' );
+define( 'HAPPYTEXTI_VERSION',       '1.2.9' );
 
 // Plugin Root File

happy-texting/trunk/readme.txt

@@ -3 +3 @@
 License URI: https://www.gnu.org/licenses/gpl-2.0.html
 Tested Up To: 6.6.1
-Stable tag: 1.2.8
+Stable tag: 1.2.9