bit-form / includes / Core / Integration / GoogleSheet / 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/GoogleSheet/RecordApiHelper.php

124 lines 4.2 KB

Raw Download Zip

1	<?php
2
3	/**
4	* ZohoRecruit Record Api
5	*
6	*/
7
8	namespace BitCode\BitForm\Core\Integration\GoogleSheet;
9
10	use BitCode\BitForm\Core\Database\FormEntryLogModel;
11	use BitCode\BitForm\Core\Integration\IntegrationHandler;
12	use BitCode\BitForm\Core\Util\ApiResponse as UtilApiResponse;
13	use BitCode\BitForm\Core\Util\HttpHelper;
14
15	/**
16	* Provide functionality for Record insert,upsert
17	*/
18	class RecordApiHelper
19	{
20	private $_defaultHeader;
21
22	private $_integrationID;
23
24	private $_logID;
25
26	private $_logResponse;
27
28	private $_entryID;
29
30	public function __construct($tokenDetails, $integId, $logID, $entryID)
31	{
32	$this->_defaultHeader['Authorization'] = "Bearer {$tokenDetails->access_token}";
33	$this->_defaultHeader['Content-Type'] = 'application/json';
34	$this->_integrationID = $integId;
35	$this->_logID = $logID;
36	$this->_logResponse = new UtilApiResponse();
37	$this->_entryID = $entryID;
38	}
39
40	public function insertRecord($spreadsheetsId, $worksheetName, $header, $headerRow, $data)
41	{
42	$insertRecordEndpoint = "https://sheets.googleapis.com/v4/spreadsheets/{$spreadsheetsId}/values/{$worksheetName}!{$headerRow}:append?valueInputOption=USER_ENTERED";
43	return HttpHelper::post($insertRecordEndpoint, $data, $this->_defaultHeader);
44	}
45
46	public function updateRecord($spreadsheetId, $worksheetInfo, $data)
47	{
48	$updateRecordEndpoint = "https://sheets.googleapis.com/v4/spreadsheets/{$spreadsheetId}/values/{$worksheetInfo}?valueInputOption=USER_ENTERED";
49	return HttpHelper::request($updateRecordEndpoint, 'put', $data, $this->_defaultHeader);
50	}
51
52	public function executeRecordApi($spreadsheetId, $worksheetName, $headerRow, $header, $actions, $defaultConf, $fieldValues, $fieldMap, $formId)
53	{
54	$fieldData = [];
55	$allHeaders = $defaultConf->headers->{$spreadsheetId}->{$worksheetName}->{$headerRow};
56	$formattedFieldValues = IntegrationHandler::formattedRepeaterValue($fieldValues, 'string');
57
58	foreach ($fieldMap as $fieldPair) {
59	if (!empty($fieldPair->googleSheetField)) {
60	if ('custom' === $fieldPair->formField && isset($fieldPair->customValue)) {
61	$fieldData[$fieldPair->googleSheetField] = $fieldPair->customValue;
62	} else {
63	$fieldData[$fieldPair->googleSheetField] = $formattedFieldValues[$fieldPair->formField];
64	}
65	}
66	}
67
68	$values = [];
69
70	foreach ($allHeaders as $googleSheetHeader) {
71	if (!empty($fieldData[$googleSheetHeader])) {
72	if ('array' === gettype($fieldData[$googleSheetHeader])) {
73	$values[] = implode(', ', $fieldData[$googleSheetHeader]);
74	} else {
75	$values[] = $fieldData[$googleSheetHeader];
76	}
77	} else {
78	$values[] = '';
79	}
80	}
81
82	$data = [];
83	$data['range'] = "{$worksheetName}!$headerRow";
84	$data['majorDimension'] = "{$header}";
85	$data['values'][] = $values;
86
87	$model = new FormEntryLogModel();
88	$recordApiResponse = null;
89	if ($this->_entryID) {
90	$result = $model->entryLogCheck($this->_entryID, $this->_integrationID);
91	if (!count($result) \|\| isset($result->errors['result_empty'])) {
92	$recordApiResponse = $this->insertRecord($spreadsheetId, $worksheetName, $header, $headerRow, wp_json_encode($data));
93	$type = 'insert';
94	} else {
95	$result = json_decode($result[0]->response_obj);
96
97	if (isset($result->updates)) {
98	$worksheetInfo = $result->updates->updatedRange;
99	} else {
100	$worksheetInfo = $result->updatedRange;
101	}
102	$spreadsheetId = $result->spreadsheetId;
103	unset($data['range']);
104	$recordApiResponse = $this->updateRecord($spreadsheetId, $worksheetInfo, wp_json_encode($data));
105	$type = 'update';
106	}
107
108	$entryDetails = [
109	'formId' => $formId,
110	'entryId' => $this->_entryID,
111	'fieldValues' => $fieldValues
112	];
113
114	if (isset($recordApiResponse->error)) {
115	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => $type], 'error', $recordApiResponse, $entryDetails);
116	} else {
117	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => $type], 'success', $recordApiResponse, $entryDetails);
118	}
119	}
120
121	return $recordApiResponse;
122	}
123	}
124