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.9.1, at includes/Core/Integration/GoogleSheet/RecordApiHelper.php

115 lines 3.9 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\Util\ApiResponse as UtilApiResponse;
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
21	private $_integrationID;
22
23	private $_logID;
24
25	private $_logResponse;
26
27	private $_entryID;
28
29	public function __construct($tokenDetails, $integId, $logID, $entryID)
30	{
31	$this->_defaultHeader['Authorization'] = "Bearer {$tokenDetails->access_token}";
32	$this->_defaultHeader['Content-Type'] = 'application/json';
33	$this->_integrationID = $integId;
34	$this->_logID = $logID;
35	$this->_logResponse = new UtilApiResponse();
36	$this->_entryID = $entryID;
37	}
38
39	public function insertRecord($spreadsheetsId, $worksheetName, $header, $headerRow, $data)
40	{
41	$insertRecordEndpoint = "https://sheets.googleapis.com/v4/spreadsheets/{$spreadsheetsId}/values/{$worksheetName}!{$headerRow}:append?valueInputOption=USER_ENTERED";
42	return HttpHelper::post($insertRecordEndpoint, $data, $this->_defaultHeader);
43	}
44
45	public function updateRecord($spreadsheetId, $worksheetInfo, $data)
46	{
47	$updateRecordEndpoint = "https://sheets.googleapis.com/v4/spreadsheets/{$spreadsheetId}/values/{$worksheetInfo}?valueInputOption=USER_ENTERED";
48	return HttpHelper::request($updateRecordEndpoint, 'put', $data, $this->_defaultHeader);
49	}
50
51	public function executeRecordApi($spreadsheetId, $worksheetName, $headerRow, $header, $actions, $defaultConf, $fieldValues, $fieldMap)
52	{
53	$fieldData = [];
54	$allHeaders = $defaultConf->headers->{$spreadsheetId}->{$worksheetName}->{$headerRow};
55
56	foreach ($fieldMap as $fieldPair) {
57	if (!empty($fieldPair->googleSheetField)) {
58	if ('custom' === $fieldPair->formField && isset($fieldPair->customValue)) {
59	$fieldData[$fieldPair->googleSheetField] = $fieldPair->customValue;
60	} else {
61	$fieldData[$fieldPair->googleSheetField] = $fieldValues[$fieldPair->formField];
62	}
63	}
64	}
65
66	$values = [];
67
68	foreach ($allHeaders as $googleSheetHeader) {
69	if (!empty($fieldData[$googleSheetHeader])) {
70	if ('array' === gettype($fieldData[$googleSheetHeader])) {
71	$values[] = implode(', ', $fieldData[$googleSheetHeader]);
72	} else {
73	$values[] = $fieldData[$googleSheetHeader];
74	}
75	} else {
76	$values[] = '';
77	}
78	}
79
80	$data = [];
81	$data['range'] = "{$worksheetName}!$headerRow";
82	$data['majorDimension'] = "{$header}";
83	$data['values'][] = $values;
84
85	$model = new FormEntryLogModel();
86	$recordApiResponse = null;
87	if ($this->_entryID) {
88	$result = $model->entryLogCheck($this->_entryID, $this->_integrationID);
89	if (!count($result) \|\| isset($result->errors['result_empty'])) {
90	$recordApiResponse = $this->insertRecord($spreadsheetId, $worksheetName, $header, $headerRow, wp_json_encode($data));
91	$type = 'insert';
92	} else {
93	$result = json_decode($result[0]->response_obj);
94
95	if (isset($result->updates)) {
96	$worksheetInfo = $result->updates->updatedRange;
97	} else {
98	$worksheetInfo = $result->updatedRange;
99	}
100	$spreadsheetId = $result->spreadsheetId;
101	unset($data['range']);
102	$recordApiResponse = $this->updateRecord($spreadsheetId, $worksheetInfo, wp_json_encode($data));
103	$type = 'update';
104	}
105	if (isset($recordApiResponse->error)) {
106	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => $type], 'error', $recordApiResponse);
107	} else {
108	$this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'record', 'type_name' => $type], 'success', $recordApiResponse);
109	}
110	}
111
112	return $recordApiResponse;
113	}
114	}
115