Create Bulk Read job (Bulk Export)

Copied//Get instance of BulkReadOperations Class
$bulkReadOperations = new BulkReadOperations();
//Get instance of RequestWrapper Class that will contain the request body
$requestWrapper = new RequestWrapper();
//Get instance of CallBack Class
$callback = new CallBack();
// To set valid callback URL.
$callback->setUrl("https://www.example.com/callback");
//To set the HTTP method of the callback URL. The allowed value is post.
$callback->setMethod(new Choice("post"));
//The Bulkread Job's details is posted to this URL on successful completion / failure of job.
$requestWrapper->setCallback($callback);
//Get instance of Query Class
$query = new Query();
$module = new Module();
$module->setAPIName($moduleAPIName);
//Specifies the API Name of the module to be read.
$query->setModule($module);
//Specifies the unique ID of the custom view whose records you want to export.
$query->setCvid("34770610087501");
// List of Field API Names
$fieldAPINames = array();
array_push($fieldAPINames, "Last_Name");
//Specifies the API Name of the fields to be fetched.
$query->setFields($fieldAPINames);
//To set page value, By default value is 1.
$query->setPage(1);
//Get instance of Criteria Class
$criteria = new Criteria();
$criteria->setGroupOperator(new Choice("or"));
$criteriaList = array();
$group11 = new Criteria();
$group11->setGroupOperator(new Choice("and"));
$groupList11 = array();
$group111 = new Criteria();
$field = new Field();
$field->setAPIName("Last_Name");
$group111->setField($field);
$group111->setComparator(new Choice("equal"));
$group111->setValue("TestPHPSDK");
array_push($groupList11, $group111);
$group112 = new Criteria();
$field = new Field();
$field->setAPIName("Owner");
$group112->setField($field);
$group112->setComparator(new Choice("in"));
$owner = array("34770610173021");
$group112->setValue($owner);
array_push($groupList11, $group112);
$group11->setGroup($groupList11);
array_push($criteriaList, $group11);
$group12 = new Criteria();
$group12->setGroupOperator(new Choice("or"));
$groupList12 = array();
$group121 = new Criteria();
$field = new Field();
$field->setAPIName("Company");
$group121->setField($field);
$group121->setComparator(new Choice("equal"));
$group121->setValue("KK");
array_push($groupList12, $group121);
$group122 = new Criteria();
$field = new Field();
$field->setAPIName("Created_Time");
// To set API name of a field.
$group122->setField($field);
// To set comparator(eg: equal, greater_than.).
$group122->setComparator(new Choice("between"));
$createdTime = array(date_create("2020-07-15T17:58:47+05:30")->setTimezone(new \DateTimeZone(date_default_timezone_get())), date_create("2020-10-15T17:58:47+05:30")->setTimezone(new \DateTimeZone(date_default_timezone_get())));
// To set the value to be compare.
$group122->setValue($createdTime);
array_push($groupList12, $group122);
$group12->setGroup($groupList12);
array_push($criteriaList, $group12);
$criteria->setGroup($criteriaList);
//To filter the records to be exported.
$query->setCriteria($criteria);
//To set query JSON object.
$requestWrapper->setQuery($query);
//Specify the value for this key as "ics" to export all records in the Events module as an ICS file.
// $requestWrapper->setFileType(new Choice("ics"));
//Call createBulkReadJob method that takes RequestWrapper instance as parameter
$response = $bulkReadOperations->createBulkReadJob($requestWrapper);

Copied<?php

class CreateBulkReadjob
{
	public function execute(){
        $curl_pointer = curl_init();
        
        $curl_options = array();
        $curl_options[CURLOPT_URL] = "https://www.zohoapis.com/crm/bulk/v2.1/read";
        $curl_options[CURLOPT_RETURNTRANSFER] = true; 
        $curl_options[CURLOPT_HEADER] = 1;
        $curl_options[CURLOPT_CUSTOMREQUEST] = "POST";
        $requestBody=array();
        $query=array();
        $query["cvid"]="4150868000000087501";
        $criteria=array();
        $criteria["group_operator"]="and";
        $group=array();
        $groupObject1=array();
        $groupObject1["comparator"]="equal";
        $field=array();
        $field["api_name"]="Last_Name";
        $groupObject1["field"]=$field;
        $groupObject1["value"]="Patricia";
        array_push($group,$groupObject1);
        $groupObject2=array();
        $groupObject2["comparator"]="equal";
        $field=array();
        $field["api_name"]="Email";
        $groupObject2["field"]=$field;
        $groupObject2["value"]="patricia.b@zylker.com";
        array_push($group,$groupObject2);
        $criteria["group"]=$group;
        $query["criteria"]=$criteria;
        $module=array();
        $module["api_name"]="Leads";
        $query["module"]=$module;
        $fields=array();
        array_push($fields,"Last_Name");
        array_push($fields,"Owner");
        array_push($fields,"Owner.last_name");
        array_push($fields,"$converted");
        array_push($fields,"Lead_Source");
        array_push($fields,"Lead_Status");
        array_push($fields,"Company");
        array_push($fields,"Email");
        array_push($fields,"Mobile");
        array_push($fields,"Created_Time");
        $query["fields"]=$fields;
        $requestBody["query"]=$query;
        $callback=array();
        $callback["method"]="post";
        $callback["url"]="https://www.example.com/callback";
        $requestBody["callback"]=$callback;


        $headersArray = array();

        $headersArray[] = "Authorization". ":" . "Zoho-oauthtoken " . "1000.30f3a589XXXXXXXXXXXXXXXXXXX4077.dc5XXXXXXXXXXXXXXXXXXXee9e7c171c";
        $headersArray[] = "Content-Type".":"."application/json";
        $curl_options[CURLOPT_HTTPHEADER]=$headersArray;
        
        curl_setopt_array($curl_pointer, $curl_options);

        $result = curl_exec($curl_pointer);
        $responseInfo = curl_getinfo($curl_pointer);
        curl_close($curl_pointer);
        list ($headers, $content) = explode("\r\n\r\n", $result, 2);
        if(strpos($headers," 100 Continue")!==false){
            list( $headers, $content) = explode( "\r\n\r\n", $content , 2);
        }
        $headerArray = (explode("\r\n", $headers, 50));
        $headerMap = array();
        foreach ($headerArray as $key) {
            if (strpos($key, ":") != false) {
                $firstHalf = substr($key, 0, strpos($key, ":"));
                $secondHalf = substr($key, strpos($key, ":") + 1);
                $headerMap[$firstHalf] = trim($secondHalf);
            }
        }
        $jsonResponse = json_decode($content, true);
        if ($jsonResponse == null && $responseInfo['http_code'] != 204) {
            list ($headers, $content) = explode("\r\n\r\n", $content, 2);
            $jsonResponse = json_decode($content, true);
        }
        var_dump($headerMap);
        var_dump($jsonResponse);
        var_dump($responseInfo['http_code']);
       
    }
    
}
(new CreateBulkReadjob())->execute();