retrieve-contact-by-segment.php — OttoKit: All-in-One Automation Platform 1.1.36

suretriggers / src / Integrations / fluentcrm / actions / retrieve-contact-by-segment.php

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

retrieve-contact-by-segment.php

179 lines

1	<?php
2	/**
3	* RetrieveContactBySegment.
4	* php version 5.6
5	*
6	* @category RetrieveContactBySegment
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\FluentCRM\Actions;
15
16	use Exception;
17	use SureTriggers\Integrations\AutomateAction;
18	use SureTriggers\Traits\SingletonLoader;
19
20	/**
21	* RetrieveContactBySegment
22	*
23	* @category RetrieveContactBySegment
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 RetrieveContactBySegment extends AutomateAction {
31
32
33	/**
34	* Integration type.
35	*
36	* @var string
37	*/
38	public $integration = 'FluentCRM';
39
40	/**
41	* Action name.
42	*
43	* @var string
44	*/
45	public $action = 'fluentcrm_retrieve_contact_by_segment';
46
47	use SingletonLoader;
48
49	/**
50	* Register a action.
51	*
52	* @param array $actions actions.
53	* @return array
54	*/
55	public function register( $actions ) {
56
57	$actions[ $this->integration ][ $this->action ] = [
58	'label' => __( 'Retrieve Contact By Segment', 'suretriggers' ),
59	'action' => $this->action,
60	'function' => [ $this, 'action_listener' ],
61	];
62	return $actions;
63	}
64
65	/**
66	* Action listener.
67	*
68	* @param int $user_id user_id.
69	* @param int $automation_id automation_id.
70	* @param array $fields fields.
71	* @param array $selected_options selectedOptions.
72	* @return array
73	* @throws Exception Exception.
74	*/
75	public function _action_listener( $user_id, $automation_id, $fields, $selected_options ) {
76	if ( ! function_exists( 'FluentCrmApi' ) ) {
77	return [
78	'status' => 'error',
79	'message' => __( 'FluentCRM is not active.', 'suretriggers' ),
80
81	];
82	}
83
84	$segment_id = isset( $selected_options['segment_id'] ) ? sanitize_text_field( $selected_options['segment_id'] ) : '';
85
86	$segments = apply_filters( 'fluentcrm_dynamic_segments', [] );
87	$segment_type = 'custom_segment';
88
89	foreach ( $segments as $segment ) {
90	if ( isset( $segment['id'] ) && $segment['id'] == $segment_id ) {
91	$segment_type = $segment['slug'];
92	break;
93	}
94	}
95
96	$segment = apply_filters(
97	"fluentcrm_dynamic_segment_{$segment_type}",
98	[],
99	$segment_id,
100	[
101	'subscribers' => true,
102	'with' => [ 'tags', 'lists' ],
103	]
104	);
105
106	if ( empty( $segment ) \|\| empty( $segment['subscribers'] ) ) {
107	return [
108	'message' => __( 'No contacts found or segment does not exist', 'suretriggers' ),
109	'status' => 'false',
110	'user_exists' => 'false',
111	];
112	}
113
114	$contacts = $segment['subscribers'];
115
116	if ( is_object( $contacts ) ) {
117	if ( method_exists( $contacts, 'toArray' ) ) {
118	$contacts = $contacts->toArray();
119	} else {
120	$contacts = (array) $contacts;
121	}
122	}
123
124	if ( empty( $contacts ) ) {
125	return [
126	'message' => __( 'No contacts found', 'suretriggers' ),
127	'status' => 'false',
128	'user_exists' => 'false',
129	];
130	}
131
132	$context = [];
133
134	if ( is_array( $contacts ) ) {
135	foreach ( $contacts as $key => $contact ) {
136	$standard_fields = [
137	'id',
138	'user_id',
139	'full_name',
140	'first_name',
141	'last_name',
142	'contact_owner',
143	'company_id',
144	'email',
145	'address_line_1',
146	'address_line_2',
147	'postal_code',
148	'city',
149	'state',
150	'country',
151	'phone',
152	'status',
153	'contact_type',
154	'source',
155	'date_of_birth',
156	'tags',
157	'lists',
158	];
159
160	foreach ( $standard_fields as $field ) {
161	$context['contact'][ $key ][ $field ] = isset( $contact[ $field ] ) ? $contact[ $field ] : '';
162	}
163
164	if ( ! empty( $contact['custom_fields'] ) && is_array( $contact['custom_fields'] ) ) {
165	foreach ( $contact['custom_fields'] as $custom_key => $custom_value ) {
166	$context['contact'][ $key ][ $custom_key ] = is_array( $custom_value )
167	? implode( ',', $custom_value )
168	: $custom_value;
169	}
170	}
171	}
172	}
173
174	return $context;
175	}
176	}
177
178	RetrieveContactBySegment::get_instance();
179