bit-form / includes / Core / Integration / MailChimp / RecordApiHelper.php

RecordApiHelper.php in Bit Form – Contact Form, Payment Forms, Multi Step Forms, Calculator & Custom Form Builder 2.21.13, at includes/Core/Integration/MailChimp/RecordApiHelper.php

156 lines 5.6 KB

Raw Download Zip

1	<?php
2
3	/**
4	* MailChimp Record Api
5	*
6	*/
7
8	namespace BitCode\BitForm\Core\Integration\MailChimp;
9
10	use BitCode\BitForm\Core\Database\FormEntryLogModel;
11	use BitCode\BitForm\Core\Util\ApiResponse;
12	use BitCode\BitForm\Core\Util\HttpHelper;
13
14	/**
15	* Provide functionality for Record insert,upsert
16	*/
17	class RecordApiHelper
18	{
19	private $_defaultHeader;
20	private $_tokenDetails;
21	private $_integrationID;
22	private $_logID;
23	private $_logResponse;
24	private $_entryID;
25
26	public function __construct($tokenDetails, $integId, $logID, $entryID)
27	{
28	$this->_defaultHeader['Authorization'] = "Bearer {$tokenDetails->access_token}";
29	$this->_defaultHeader['Content-Type'] = 'application/json';
30	$this->_tokenDetails = $tokenDetails;
31	$this->_integrationID = $integId;
32	$this->_logID = $logID;
33	$this->_logResponse = new ApiResponse();
34	$this->_entryID = $entryID;
35	}
36
37	private function _apiEndPoint()
38	{
39	return "https://{$this->_tokenDetails->dc}.api.mailchimp.com/3.0";
40	}
41
42	public function insertRecord($listId, $data)
43	{
44	$insertRecordEndpoint = $this->_apiEndPoint() . "/lists/{$listId}/members";
45	return HttpHelper::post($insertRecordEndpoint, $data, $this->_defaultHeader);
46	}
47
48	public function updateRecord($listId, $subscriberHash, $jsonData)
49	{
50	$updateRecordEndpoint = $this->_apiEndPoint() . "/lists/{$listId}/members/{$subscriberHash}";
51	$response = HttpHelper::request($updateRecordEndpoint, 'PUT', $jsonData, $this->_defaultHeader);
52	return $response;
53	}
54
55	public function existContact($listId, $queryParam)
56	{
57	$existSearchEnpoint = $this->_apiEndPoint() . "/search-members?query={$queryParam}&list_id={$listId}";
58	return HttpHelper::get($existSearchEnpoint, $queryParam, $this->_defaultHeader);
59	}
60
61	public function executeRecordApi($listId, $tags, $defaultConf, $fieldValues, $fieldMap, $actions, $addressFields, $formId)
62	{
63	$fieldData = [];
64	$mergeFields = [];
65	foreach ($fieldMap as $fieldPair) {
66	if (!empty($fieldPair->mailChimpField)) {
67	if ('email_address' === $fieldPair->mailChimpField) {
68	$fieldData['email_address'] = $fieldValues[$fieldPair->formField];
69	} elseif ('custom' === $fieldPair->formField && isset($fieldPair->customValue)) {
70	$mergeFields[$fieldPair->mailChimpField] = $fieldPair->customValue;
71	} elseif ('BIRTHDAY' === $fieldPair->mailChimpField) {
72	$mergeFields[$fieldPair->mailChimpField] = !empty($fieldValues[$fieldPair->formField]) ? gmdate('m/d', strtotime($fieldValues[$fieldPair->formField])) : '';
73	} else {
74	$mergeFields[$fieldPair->mailChimpField] = $fieldValues[$fieldPair->formField];
75	}
76	}
77	}
78
79	$doubleOptIn = !empty($actions->double_opt_in) && $actions->double_opt_in ? true : false;
80
81	$fieldData['merge_fields'] = (object) $mergeFields;
82	$fieldData['email_type'] = 'text';
83	$fieldData['tags'] = !empty($tags) ? $tags : [];
84	$fieldData['status'] = $doubleOptIn ? 'pending' : 'subscribed';
85	$fieldData['double_optin'] = $doubleOptIn;
86
87	$contactEmail = $fieldData['email_address'];
88	$subscriberHash = md5(strtolower($contactEmail));
89
90	$model = new FormEntryLogModel();
91
92	$recordApiResponse = null;
93	if ($this->_entryID) {
94	$result = $model->entryLogCheck($this->_entryID, $this->_integrationID);
95	if (!count($result) \|\| isset($result->errors['result_empty'])) {
96	if (!empty($actions->address)) {
97	$fvalue = [];
98	foreach ($addressFields as $key) {
99	foreach ($fieldValues as $k => $v) {
100	if ($key->formField === $k) {
101	$fvalue[$key->mailChimpAddressField] = $v;
102	}
103	}
104	}
105	$fieldData['merge_fields']->ADDRESS = (object) $fvalue;
106	}
107
108	$recordApiResponse = $this->insertRecord($listId, wp_json_encode($fieldData));
109	$type = 'insert';
110
111	if (!empty($actions->update) && !empty($recordApiResponse->title) && 'Member Exists' === $recordApiResponse->title) {
112	$foundContact = $this->existContact($listId, $contactEmail);
113	if (count($foundContact->exact_matches->members)) {
114	$recordApiResponse = $this->updateRecord($listId, $subscriberHash, wp_json_encode($fieldData));
115	$type = 'update';
116	}
117	}
118	} else {
119	if (!empty($actions->address)) {
120	$fvalue = [];
121	foreach ($addressFields as $key) {
122	foreach ($fieldValues as $k => $v) {
123	if ($key->formField === $k) {
124	$fvalue[$key->mailChimpAddressField] = $v;
125	}
126	}
127	}
128	$fieldData['merge_fields']->ADDRESS = (object) $fvalue;
129	}
130	$recordApiResponse = $this->updateRecord($listId, $subscriberHash, wp_json_encode($fieldData));
131	$type = 'update';
132	}
133
134	$entryDetails = [
135	'formId' => $formId,
136	'entryId' => $this->_entryID,
137	'fieldValues' => $fieldValues
138	];
139
140	if (400 === $recordApiResponse->status) {
141	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => $type], 'error', $recordApiResponse, $entryDetails);
142	} else {
143	$responseInfo = (object) [
144	'success' => true,
145	'id' => $recordApiResponse->id,
146	'status' => $recordApiResponse->status,
147	'email_address' => $recordApiResponse->email_address,
148	];
149	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => $type], 'success', $responseInfo, $entryDetails);
150	}
151	}
152
153	return $recordApiResponse;
154	}
155	}
156