From 4cd59fd51eac6243ffee0d24caced655c6c7e06b Mon Sep 17 00:00:00 2001 From: pravesh-8541 Date: Mon, 13 Jul 2020 17:50:39 +0530 Subject: [PATCH] Supported process key in request body for record operations. --- src/crm/api/handler/EntityAPIHandler.php | 12 +++++++++--- src/crm/api/handler/MassEntityAPIHandler.php | 15 ++++++++++++--- src/crm/crud/ZCRMModule.php | 12 ++++++------ src/crm/crud/ZCRMRecord.php | 8 ++++---- 4 files changed, 31 insertions(+), 16 deletions(-) diff --git a/src/crm/api/handler/EntityAPIHandler.php b/src/crm/api/handler/EntityAPIHandler.php index 105012d5..901f2090 100644 --- a/src/crm/api/handler/EntityAPIHandler.php +++ b/src/crm/api/handler/EntityAPIHandler.php @@ -40,6 +40,7 @@ public function getRecord($param_map=array(),$header_map=array()) foreach ($header_map as $key => $value) { if($value!==null)$this->addHeader($key, $value); } + $this->addHeader("Content-Type", "application/json"); $responseInstance = APIRequest::getInstance($this)->getAPIResponse(); $recordDetails = $responseInstance->getResponseJSON()['data']; @@ -52,7 +53,7 @@ public function getRecord($param_map=array(),$header_map=array()) } } - public function createRecord($trigger, $lar_id) + public function createRecord($trigger, $lar_id,$process) { try { if ($this->record->getEntityId() != NULL) { @@ -71,6 +72,9 @@ public function createRecord($trigger, $lar_id) if ($lar_id !== null) { $requestBodyObj["lar_id"] = $lar_id; } + if($process !== null && is_array($process) ){ + $requestBodyObj["process"] =$process; + } $this->requestBody = json_encode($requestBodyObj); @@ -90,7 +94,7 @@ public function createRecord($trigger, $lar_id) } } - public function updateRecord($trigger) + public function updateRecord($trigger,$process) { try { if ($this->record->getEntityId() == NULL) { @@ -106,7 +110,9 @@ public function updateRecord($trigger) if ($trigger !== null && is_array($trigger)) { $requestBodyObj["trigger"] = $trigger; } - + if($process !== null && is_array($process) ){ + $requestBodyObj["process"] =$process; + } $this->requestBody =json_encode( $requestBodyObj); $responseInstance = APIRequest::getInstance($this)->getAPIResponse(); diff --git a/src/crm/api/handler/MassEntityAPIHandler.php b/src/crm/api/handler/MassEntityAPIHandler.php index 74288279..9fde6e79 100644 --- a/src/crm/api/handler/MassEntityAPIHandler.php +++ b/src/crm/api/handler/MassEntityAPIHandler.php @@ -24,7 +24,7 @@ public static function getInstance($moduleInstance) return new MassEntityAPIHandler($moduleInstance); } - public function createRecords($records, $trigger,$lar_id) + public function createRecords($records, $trigger,$lar_id,$process) { if (sizeof($records) > 100) { throw new ZCRMException(APIConstants::API_MAX_RECORDS_MSG, APIConstants::RESPONSECODE_BAD_REQUEST); @@ -49,6 +49,9 @@ public function createRecords($records, $trigger,$lar_id) if ($lar_id !== null) { $requestBodyObj["lar_id"] = $lar_id; } + if($process !== null && is_array($process) ){ + $requestBodyObj["process"] =$process; + } $this->requestBody = $requestBodyObj; @@ -77,7 +80,7 @@ public function createRecords($records, $trigger,$lar_id) } } - public function upsertRecords($records, $trigger,$lar_id,$duplicate_check_fields) + public function upsertRecords($records, $trigger,$lar_id,$duplicate_check_fields,$process) { if (sizeof($records) > 100) { throw new ZCRMException(APIConstants::API_MAX_RECORDS_MSG, APIConstants::RESPONSECODE_BAD_REQUEST); @@ -106,6 +109,9 @@ public function upsertRecords($records, $trigger,$lar_id,$duplicate_check_fields if ($lar_id !== null) { $requestBodyObj["lar_id"] = $lar_id; } + if($process !== null && is_array($process) ){ + $requestBodyObj["process"] =$process; + } $this->requestBody = $requestBodyObj; // Fire Request @@ -133,7 +139,7 @@ public function upsertRecords($records, $trigger,$lar_id,$duplicate_check_fields } } - public function updateRecords($records, $trigger) + public function updateRecords($records, $trigger,$process) { if (sizeof($records) > 100) { throw new ZCRMException(APIConstants::API_MAX_RECORDS_MSG, APIConstants::RESPONSECODE_BAD_REQUEST); @@ -155,6 +161,9 @@ public function updateRecords($records, $trigger) if ($trigger !== null && is_array($trigger)) { $requestBodyObj["trigger"] = $trigger; } + if($process !== null && is_array($process) ){ + $requestBodyObj["process"] =$process; + } $this->requestBody = $requestBodyObj; diff --git a/src/crm/crud/ZCRMModule.php b/src/crm/crud/ZCRMModule.php index 64ec698a..6cdcadbe 100644 --- a/src/crm/crud/ZCRMModule.php +++ b/src/crm/crud/ZCRMModule.php @@ -1152,9 +1152,9 @@ public function massUpdateRecords($entityIds, $fieldApiName, $value) * @param string $lar_id lead assignment rule id * @return BulkAPIResponse instance of the BulkAPIResponse class which holds the Bulk API response. */ - public function updateRecords($records, $trigger = null) + public function updateRecords($records, $trigger = null,$process = null) { - return MassEntityAPIHandler::getInstance($this)->updateRecords($records, $trigger); + return MassEntityAPIHandler::getInstance($this)->updateRecords($records, $trigger,$process); } /** @@ -1165,9 +1165,9 @@ public function updateRecords($records, $trigger = null) * @param string $lar_id lead assignment rule id * @return BulkAPIResponse instance of the BulkAPIResponse class which holds the Bulk API response. */ - public function createRecords($records, $trigger = null,$lar_id = null) + public function createRecords($records, $trigger = null,$lar_id = null,$process = null) { - return MassEntityAPIHandler::getInstance($this)->createRecords($records, $trigger,$lar_id); + return MassEntityAPIHandler::getInstance($this)->createRecords($records, $trigger,$lar_id,$process); } /** @@ -1178,9 +1178,9 @@ public function createRecords($records, $trigger = null,$lar_id = null) * @param string $lar_id lead assignment rule id * @return BulkAPIResponse instance of the BulkAPIResponse class which holds the Bulk API response. */ - public function upsertRecords($records, $trigger = null,$lar_id = null,$duplicate_check_fields=null) + public function upsertRecords($records, $trigger = null,$lar_id = null,$duplicate_check_fields=null,$process = null) { - return MassEntityAPIHandler::getInstance($this)->upsertRecords($records, $trigger,$lar_id,$duplicate_check_fields); + return MassEntityAPIHandler::getInstance($this)->upsertRecords($records, $trigger,$lar_id,$duplicate_check_fields,$process); } /** diff --git a/src/crm/crud/ZCRMRecord.php b/src/crm/crud/ZCRMRecord.php index fb7498b6..0c9d0b3e 100644 --- a/src/crm/crud/ZCRMRecord.php +++ b/src/crm/crud/ZCRMRecord.php @@ -588,14 +588,14 @@ public function getRecordRowNumber() * @return APIResponse instance of the APIResponse class which holds the API response. * */ - public function create( $trigger = null,$lar_id = null) + public function create( $trigger = null,$lar_id = null,$process = null) { if (self::getEntityId() != null) { $exception = new ZCRMException("Entity ID MUST be null for create operation.", APIConstants::RESPONSECODE_BAD_REQUEST); $exception->setExceptionCode("ID EXIST"); throw $exception; } - return EntityAPIHandler::getInstance($this)->createRecord($trigger ,$lar_id); + return EntityAPIHandler::getInstance($this)->createRecord($trigger ,$lar_id,$process); } /** @@ -605,14 +605,14 @@ public function create( $trigger = null,$lar_id = null) * @throws ZCRMException if Entity ID of the record is NULL * @return APIResponse instance of the APIResponse class which holds the API response. */ - public function update( $trigger = null) + public function update( $trigger = null,$process = null) { if (self::getEntityId() == null) { $exception = new ZCRMException("Entity ID MUST NOT be null for update operation.", APIConstants::RESPONSECODE_BAD_REQUEST); $exception->setExceptionCode("ID MISSING"); throw $exception; } - return EntityAPIHandler::getInstance($this)->updateRecord($trigger ); + return EntityAPIHandler::getInstance($this)->updateRecord($trigger,$process); } /**