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

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

125 lines 5.4 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	private $_defaultHeader;
19	private $_apiDomain;
20	private $_tokenDetails;
21
22	private $_integrationID;
23	private $_logID;
24	private $_logResponse;
25
26	public function __construct($tokenDetails, $integId, $logID) {
27	$this->_defaultHeader['Authorization'] = "Zoho-oauthtoken {$tokenDetails->access_token}";
28	$this->_apiDomain = \urldecode($tokenDetails->api_domain);
29	$this->_tokenDetails = $tokenDetails;
30	$this->_integrationID = $integId;
31	$this->_logID = $logID;
32	$this->_logResponse = new UtilApiResponse();
33	}
34
35	public function insertRecord($workspace, $table, $ownerEmail, $dataCenter, $data) {
36	$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";
37	return HttpHelper::post($insertRecordEndpoint, $data, $this->_defaultHeader);
38	}
39
40	public function updateRecord($workspace, $table, $ownerEmail, $dataCenter, $criteria, $data) {
41	$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}";
42
43	return HttpHelper::post($updateRecordEndpoint, $data, $this->_defaultHeader);
44	}
45
46	public function shareTable($dataCenter, $ownerEmail, $workspace, $table, $data) {
47	$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&";
48
49	$shareTableEndpoint .= build_query($data);
50
51	return HttpHelper::post($shareTableEndpoint, null, $this->_defaultHeader);
52	}
53
54	public function executeRecordApi($workspace, $table, $ownerEmail, $dataCenter, $actions, $defaultConf, $fieldValues, $fieldMap) {
55	$fieldData = [];
56	foreach ($fieldMap as $fieldKey => $fieldPair) {
57	if (!empty($fieldPair->zohoFormField) && !empty($fieldPair->formField)) {
58	if ('custom' === $fieldPair->formField && isset($fieldPair->customValue)) {
59	$fieldData[$fieldPair->zohoFormField] = $fieldPair->customValue;
60	} else {
61	$fieldData[$fieldPair->zohoFormField] = $fieldValues[$fieldPair->formField];
62	}
63	}
64	}
65
66	if (isset($actions->update->criteria)) {
67	$recordApiResponse = $this->updateRecord($workspace, $table, $ownerEmail, $dataCenter, $actions->update->criteria, $fieldData);
68
69	$recordApiResponse = json_decode(preg_replace("/\\\'/", "'", $recordApiResponse));
70
71	if (isset($recordApiResponse->response->error)) {
72	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => 'update'], 'error', $recordApiResponse);
73	} else {
74	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => 'update'], 'success', $recordApiResponse);
75	}
76
77	if ($actions->update->insert && '0' === $recordApiResponse->response->result->updatedRows) {
78	$recordApiResponse = $this->insertRecord($workspace, $table, $ownerEmail, $dataCenter, $fieldData);
79
80	if (isset($recordApiResponse->response->error)) {
81	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => 'insert'], 'error', $recordApiResponse);
82	} else {
83	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => 'insert'], 'success', $recordApiResponse);
84	}
85	}
86	} else {
87	$recordApiResponse = $this->insertRecord($workspace, $table, $ownerEmail, $dataCenter, $fieldData);
88	if (isset($recordApiResponse->response->error)) {
89	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => 'insert'], 'error', $recordApiResponse);
90	} else {
91	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => 'insert'], 'success', $recordApiResponse);
92	}
93	}
94
95	if (isset($actions->share)) {
96	$share_arr = [];
97
98	if (!empty($actions->share->email)) {
99	$share_arr['ZOHO_EMAILS'] = FieldValueHandler::replaceFieldWithValue($actions->share->email, $fieldValues);
100	}
101
102	if (isset($actions->share->permissions)) {
103	$permissions = $actions->share->permissions;
104
105	foreach ($permissions as $permission) {
106	foreach ($permission as $perm) {
107	$share_arr[$perm] = 'true';
108	}
109	}
110	}
111
112	if (!empty($share_arr['ZOHO_EMAILS'])) {
113	$recordApiResponse = $this->shareTable($dataCenter, $ownerEmail, $workspace, $table, $share_arr);
114	if (isset($recordApiResponse->response->error)) {
115	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'share', 'type_name' => $table], 'error', $recordApiResponse);
116	} else {
117	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => $table], 'success', $recordApiResponse);
118	}
119	}
120	}
121
122	return $recordApiResponse;
123	}
124	}
125