get-contacts-by-list.php — OttoKit: All-in-One Automation Platform 1.1.32

suretriggers / src / Integrations / mailerpress / actions / get-contacts-by-list.php

suretriggers / src / Integrations / mailerpress / actions Last commit date

add-contact-to-list.php 7 months ago add-tag-to-contact.php 7 months ago create-list.php 7 months ago create-tag.php 7 months ago delete-contact.php 7 months ago delete-list.php 7 months ago delete-tag.php 7 months ago get-all-lists.php 7 months ago get-all-segments.php 7 months ago get-all-tags.php 7 months ago get-contact-by-email.php 7 months ago get-contacts-by-list.php 7 months ago get-contacts-by-tag.php 7 months ago remove-contact-from-list.php 7 months ago remove-tag-from-contact.php 7 months ago

get-contacts-by-list.php

174 lines

1	<?php
2	/**
3	* GetContactsByList.
4	* php version 5.6
5	*
6	* @category GetContactsByList
7	* @package SureTriggers
8	* @author BSF <username@example.com>
9	* @license https://www.gnu.org/licenses/gpl-3.0.html GPLv3
10	* @link https://www.brainstormforce.com/
11	* @since 1.0.0
12	*/
13
14	namespace SureTriggers\Integrations\MailerPress\Actions;
15
16	use Exception;
17	use SureTriggers\Integrations\AutomateAction;
18	use SureTriggers\Traits\SingletonLoader;
19
20	/**
21	* GetContactsByList
22	*
23	* @category GetContactsByList
24	* @package SureTriggers
25	* @author BSF <username@example.com>
26	* @license https://www.gnu.org/licenses/gpl-3.0.html GPLv3
27	* @link https://www.brainstormforce.com/
28	* @since 1.0.0
29	*/
30	class GetContactsByList extends AutomateAction {
31
32	/**
33	* Integration type.
34	*
35	* @var string
36	*/
37	public $integration = 'MailerPress';
38
39	/**
40	* Action name.
41	*
42	* @var string
43	*/
44	public $action = 'get_contacts_by_list';
45
46	use SingletonLoader;
47
48	/**
49	* Register a action.
50	*
51	* @param array $actions actions.
52	*
53	* @return array
54	*/
55	public function register( $actions ) {
56	$actions[ $this->integration ][ $this->action ] = [
57	'label' => __( 'Get contacts by list', 'suretriggers' ),
58	'action' => $this->action,
59	'function' => [ $this, 'action_listener' ],
60	];
61	return $actions;
62	}
63
64	/**
65	* Action listener.
66	*
67	* @param int $user_id user_id.
68	* @param int $automation_id automation_id.
69	* @param array $fields fields.
70	* @param array $selected_options selectedOptions.
71	* @return array\|void
72	* @throws Exception Exception.
73	*/
74	public function _action_listener( $user_id, $automation_id, $fields, $selected_options ) {
75	// Get required parameters.
76	$list_id = isset( $selected_options['list_id'] ) ? absint( $selected_options['list_id'] ) : 0;
77	$limit = isset( $selected_options['limit'] ) ? absint( $selected_options['limit'] ) : 10;
78
79	if ( empty( $list_id ) ) {
80	return [
81	'status' => 'error',
82	'message' => 'List ID is required.',
83	];
84	}
85
86	try {
87	global $wpdb;
88
89	// Check if list exists.
90	$existing_list = $wpdb->get_row(
91	$wpdb->prepare(
92	"SELECT list_id, name, description FROM {$wpdb->prefix}mailerpress_lists WHERE list_id = %d",
93	$list_id
94	)
95	);
96
97	if ( ! $existing_list ) {
98	return [
99	'status' => 'error',
100	'message' => 'List not found with the provided ID.',
101	];
102	}
103
104	$contacts_table = $wpdb->prefix . 'mailerpress_contact';
105	$contact_lists_table = $wpdb->prefix . 'mailerpress_contact_lists';
106
107	// Get contacts by list.
108	if ( $limit > 0 ) {
109	$contacts = $wpdb->get_results(
110	$wpdb->prepare(
111	'SELECT DISTINCT c.contact_id, c.email, c.first_name, c.last_name, c.subscription_status, c.created_at, c.updated_at FROM `' . esc_sql( $contacts_table ) . '` c INNER JOIN `' . esc_sql( $contact_lists_table ) . '` cl ON c.contact_id = cl.contact_id WHERE cl.list_id = %d ORDER BY c.email ASC LIMIT %d',
112	$list_id,
113	$limit
114	)
115	);
116	} else {
117	$contacts = $wpdb->get_results(
118	$wpdb->prepare(
119	'SELECT DISTINCT c.contact_id, c.email, c.first_name, c.last_name, c.subscription_status, c.created_at, c.updated_at FROM `' . esc_sql( $contacts_table ) . '` c INNER JOIN `' . esc_sql( $contact_lists_table ) . '` cl ON c.contact_id = cl.contact_id WHERE cl.list_id = %d ORDER BY c.email ASC',
120	$list_id
121	)
122	);
123	}
124
125	if ( $wpdb->last_error ) {
126	throw new Exception( 'Database error: ' . $wpdb->last_error );
127	}
128
129	// Format contacts data.
130	$formatted_contacts = [];
131	if ( $contacts ) {
132	foreach ( $contacts as $contact ) {
133	$formatted_contacts[] = [
134	'contact_id' => (int) $contact->contact_id,
135	'email' => $contact->email,
136	'first_name' => $contact->first_name,
137	'last_name' => $contact->last_name,
138	'subscription_status' => $contact->subscription_status,
139	'created_at' => $contact->created_at,
140	'updated_at' => $contact->updated_at,
141	];
142	}
143	}
144
145	// Get total count.
146	$total_count = (int) $wpdb->get_var(
147	$wpdb->prepare(
148	'SELECT COUNT(DISTINCT c.contact_id) FROM `' . esc_sql( $contacts_table ) . '` c INNER JOIN `' . esc_sql( $contact_lists_table ) . '` cl ON c.contact_id = cl.contact_id WHERE cl.list_id = %d',
149	$list_id
150	)
151	);
152
153	return [
154	'list_id' => $list_id,
155	'list_name' => $existing_list->name,
156	'list_description' => $existing_list->description,
157	'contacts' => $formatted_contacts,
158	'total_count' => $total_count,
159	'returned' => count( $formatted_contacts ),
160	'limit' => $limit,
161	'success' => true,
162	];
163
164	} catch ( Exception $e ) {
165	return [
166	'status' => 'error',
167	'message' => $e->getMessage(),
168	];
169	}
170	}
171	}
172
173	GetContactsByList::get_instance();
174