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

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

144 lines 5.8 KB

Raw Download Zip

1	<?php
2
3	/**
4	* ZohoRecruit Record Api
5	*
6	*/
7
8	namespace BitCode\BitForm\Core\Integration\ZohoAnalytics;
9
10	use BitCode\BitForm\Core\Util\ApiResponse as UtilApiResponse;
11	use BitCode\BitForm\Core\Util\FieldValueHandler;
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 $_apiDomain;
21	private $_tokenDetails;
22
23	private $_integrationID;
24	private $_logID;
25	private $_logResponse;
26
27	private $_formId;
28
29	private $_entryId;
30
31	public function __construct($tokenDetails, $integId, $logID, $formId, $entryId)
32	{
33	$this->_defaultHeader['Authorization'] = "Zoho-oauthtoken {$tokenDetails->access_token}";
34	$this->_apiDomain = \urldecode($tokenDetails->api_domain);
35	$this->_tokenDetails = $tokenDetails;
36	$this->_integrationID = $integId;
37	$this->_logID = $logID;
38	$this->_logResponse = new UtilApiResponse();
39
40	$this->_formId = $formId;
41	$this->_entryId = $entryId;
42	}
43
44	public function insertRecord($workspace, $table, $ownerEmail, $dataCenter, $data)
45	{
46	$insertRecordEndpoint = "https://analyticsapi.zoho.{$dataCenter}/api/{$ownerEmail}/{$workspace}/{$table}?ZOHO_ACTION=ADDROW&ZOHO_OUTPUT_FORMAT=JSON&ZOHO_ERROR_FORMAT=JSON&ZOHO_API_VERSION=1.0";
47	return HttpHelper::post($insertRecordEndpoint, $data, $this->_defaultHeader);
48	}
49
50	public function updateRecord($workspace, $table, $ownerEmail, $dataCenter, $criteria, $data)
51	{
52	$updateRecordEndpoint = "https://analyticsapi.zoho.{$dataCenter}/api/{$ownerEmail}/{$workspace}/{$table}?ZOHO_ACTION=UPDATE&ZOHO_OUTPUT_FORMAT=JSON&ZOHO_ERROR_FORMAT=JSON&ZOHO_API_VERSION=1.0&ZOHO_CRITERIA={$criteria}";
53
54	return HttpHelper::post($updateRecordEndpoint, $data, $this->_defaultHeader);
55	}
56
57	public function shareTable($dataCenter, $ownerEmail, $workspace, $table, $data)
58	{
59	$shareTableEndpoint = "https://analyticsapi.zoho.{$dataCenter}/api/{$ownerEmail}/{$workspace}/?ZOHO_VIEWS={$table}&ZOHO_ACTION=SHARE&ZOHO_OUTPUT_FORMAT=JSON&ZOHO_ERROR_FORMAT=JSON&ZOHO_API_VERSION=1.0&";
60
61	$shareTableEndpoint .= build_query($data);
62
63	return HttpHelper::post($shareTableEndpoint, null, $this->_defaultHeader);
64	}
65
66	public function executeRecordApi($workspace, $table, $ownerEmail, $dataCenter, $actions, $defaultConf, $fieldValues, $fieldMap)
67	{
68	$fieldData = [];
69	foreach ($fieldMap as $fieldKey => $fieldPair) {
70	if (!empty($fieldPair->zohoFormField) && !empty($fieldPair->formField)) {
71	if ('custom' === $fieldPair->formField && isset($fieldPair->customValue)) {
72	$fieldData[$fieldPair->zohoFormField] = $fieldPair->customValue;
73	} else {
74	$fieldData[$fieldPair->zohoFormField] = $fieldValues[$fieldPair->formField];
75	}
76	}
77	}
78
79	$entryDetails = [
80	'formId' => $this->_formId,
81	'entryId' => $this->_entryId,
82	'fieldValues' => $fieldValues
83	];
84
85	if (isset($actions->update->criteria)) {
86	$recordApiResponse = $this->updateRecord($workspace, $table, $ownerEmail, $dataCenter, $actions->update->criteria, $fieldData);
87
88	$recordApiResponse = json_decode(preg_replace("/\\\'/", "'", $recordApiResponse));
89
90	if (isset($recordApiResponse->response->error)) {
91	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => 'update'], 'error', $recordApiResponse, $entryDetails);
92	} else {
93	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => 'update'], 'success', $recordApiResponse, $entryDetails);
94	}
95
96	if ($actions->update->insert && '0' === $recordApiResponse->response->result->updatedRows) {
97	$recordApiResponse = $this->insertRecord($workspace, $table, $ownerEmail, $dataCenter, $fieldData);
98
99	if (isset($recordApiResponse->response->error)) {
100	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => 'insert'], 'error', $recordApiResponse, $entryDetails);
101	} else {
102	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => 'insert'], 'success', $recordApiResponse, $entryDetails);
103	}
104	}
105	} else {
106	$recordApiResponse = $this->insertRecord($workspace, $table, $ownerEmail, $dataCenter, $fieldData);
107	if (isset($recordApiResponse->response->error)) {
108	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => 'insert'], 'error', $recordApiResponse, $entryDetails);
109	} else {
110	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => 'insert'], 'success', $recordApiResponse, $entryDetails);
111	}
112	}
113
114	if (isset($actions->share)) {
115	$share_arr = [];
116
117	if (!empty($actions->share->email)) {
118	$share_arr['ZOHO_EMAILS'] = FieldValueHandler::replaceFieldWithValue($actions->share->email, $fieldValues);
119	}
120
121	if (isset($actions->share->permissions)) {
122	$permissions = $actions->share->permissions;
123
124	foreach ($permissions as $permission) {
125	foreach ($permission as $perm) {
126	$share_arr[$perm] = 'true';
127	}
128	}
129	}
130
131	if (!empty($share_arr['ZOHO_EMAILS'])) {
132	$recordApiResponse = $this->shareTable($dataCenter, $ownerEmail, $workspace, $table, $share_arr);
133	if (isset($recordApiResponse->response->error)) {
134	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'share', 'type_name' => $table], 'error', $recordApiResponse, $entryDetails);
135	} else {
136	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => $table], 'success', $recordApiResponse, $entryDetails);
137	}
138	}
139	}
140
141	return $recordApiResponse;
142	}
143	}
144