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

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

121 lines 5.7 KB

Raw Download Zip

1	<?php
2
3	/**
4	* ZohoRecruit Record Api
5	*
6	*/
7
8	namespace BitCode\BitForm\Core\Integration\ZohoSheet;
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 $_logID;
23	private $_integrationID;
24	private $_logResponse;
25
26	public function __construct($tokenDetails, $integId, $logID) {
27	$this->_defaultHeader['Authorization'] = "Zoho-oauthtoken {$tokenDetails->access_token}";
28	$this->_defaultHeader['Content-Type'] = 'application/json';
29	$this->_apiDomain = \urldecode($tokenDetails->api_domain);
30	$this->_tokenDetails = $tokenDetails;
31	$this->_integrationID = $integId;
32	$this->_logID = $logID;
33	$this->_logResponse = new UtilApiResponse();
34	}
35
36	public function insertRecord($workbook, $worksheet, $headerRow, $dataCenter, $data) {
37	$insertRecordEndpoint = "https://sheet.zoho.{$dataCenter}/api/v2/{$workbook}?method=worksheet.records.add&worksheet_name={$worksheet}&header_row={$headerRow}&json_data={$data}";
38
39	return HttpHelper::post($insertRecordEndpoint, null, $this->_defaultHeader);
40	}
41
42	public function updateRecord($workbook, $worksheet, $headerRow, $dataCenter, $criteria, $firstMatch, $data) {
43	$updateRecordEndpoint = "https://sheet.zoho.{$dataCenter}/api/v2/{$workbook}?method=worksheet.records.update&worksheet_name={$worksheet}&header_row={$headerRow}&first_match_only=" . json_encode($firstMatch) . "&data={$data}&criteria={$criteria}";
44
45	return HttpHelper::post($updateRecordEndpoint, $data, $this->_defaultHeader);
46	}
47
48	public function shareWorkbook($workbook, $dataCenter, $data) {
49	$insertRecordEndpoint = "https://sheet.zoho.{$dataCenter}/api/v2/share?method=workbook.share&resource_id={$workbook}&share_json={$data}";
50
51	return HttpHelper::post($insertRecordEndpoint, null, $this->_defaultHeader);
52	}
53
54	public function executeRecordApi($workbook, $worksheet, $headerRow, $dataCenter, $actions, $defaultConf, $fieldValues, $fieldMap) {
55	$fieldData = [];
56	foreach ($fieldMap as $fieldKey => $fieldPair) {
57	if (!empty($fieldPair->zohoFormField)) {
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	$fieldData = wp_json_encode($fieldData);
67	$newFieldData = '[' . $fieldData . ']';
68
69	if (isset($actions->update->criteria)) {
70	$recordApiResponse = $this->updateRecord($workbook, $worksheet, $headerRow, $dataCenter, $actions->update->criteria, $actions->update->firstMatch, $fieldData);
71	if (isset($recordApiResponse->error_message) \|\| 'failure' === $recordApiResponse->status \|\| 'error' === $recordApiResponse->status) {
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->no_of_affected_rows) {
78	$recordApiResponse = $this->insertRecord($workbook, $worksheet, $headerRow, $dataCenter, $newFieldData);
79	if (isset($recordApiResponse->error_message) \|\| 'failure' === $recordApiResponse->status \|\| 'error' === $recordApiResponse->status) {
80	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => 'insert'], 'error', $recordApiResponse);
81	} else {
82	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => 'insert'], 'success', $recordApiResponse);
83	}
84	}
85	} else {
86	$recordApiResponse = $this->insertRecord($workbook, $worksheet, $headerRow, $dataCenter, $newFieldData);
87	if (isset($recordApiResponse->error_message) \|\| 'failure' === $recordApiResponse->status \|\| 'error' === $recordApiResponse->status) {
88	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => 'insert'], 'error', $recordApiResponse);
89	} else {
90	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => 'insert'], 'success', $recordApiResponse);
91	}
92	}
93
94	if (isset($actions->share)) {
95	$share_json = [];
96	foreach ($actions->share as $user_share) {
97	if (!empty($user_share->email)) {
98	$emails = explode(',', $user_share->email);
99	foreach ($emails as $email) {
100	$email = FieldValueHandler::replaceFieldWithValue($email, $fieldValues);
101	if (is_email($email)) {
102	$share_json[] = [
103	'user_email' => $email,
104	'access_level' => $user_share->access
105	];
106	}
107	}
108	}
109	}
110	$shareApiResponse = $this->shareWorkbook($workbook, $dataCenter, wp_json_encode($share_json));
111	if (isset($shareApiResponse->error_message) \|\| 'failure' === $shareApiResponse->status \|\| 'error' === $shareApiResponse->status) {
112	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'share', 'type_name' => 'workbook'], 'error', $shareApiResponse);
113	} else {
114	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'share', 'type_name' => 'workbook'], 'success', $shareApiResponse);
115	}
116	}
117
118	return $recordApiResponse;
119	}
120	}
121