This CodeLet allows you programatically import property to content type:
- Install module.
- Create content type with the fields to which you want to import.
- you have to update KEY/PASSWORD for Vebra API and URL of property on Vebra.
CodeLet
<?php
/**
* Implementation of hook_menu
*
* @author saru1683
*/
function vebra_import_menu() {
$item = array();
$item['vebra_import_property/%'] = array(
'type' => MENU_CALLBACK,
'page callback' => '_get_vebra_property_detail',
'page arguments' => array(1),
'access callback' => TRUE,
);
return $item;
}
/**
* menu callback
*/
function _get_vebra_property_detail($arg = NULL) {
//ADD VEBRA PROPERTY URL FOR IMPORT TO NODE
$url = 'http://webservices.vebra.com/export/APIKEY/v4/branch/BRANCHID/property/PROPERTYID';
$property_detail_xml = _get_response($url, false);
if($property_detail_xml) {
if(_xml_vebra_import_process($property_detail_xml)) {
//watchlog true;
}else {
//watchlog false;
}
}
drupal_goto('');
}
/**
* property import process
*/
function _xml_vebra_import_process($xml) {
$om__result = new StdClass();
$p = xml_parser_create();
xml_parse_into_struct($p, $xml, $vals, $index);
xml_parser_free($p);
$ar__index = $index;
$ar__value = $vals;
$om__result->field_property_id = isset($vals[0]['attributes']['ID']) ? $vals[0]['attributes']['ID'] : 0;
$om__result->field_rent_pm = isset($ar__value[$ar__index['PRICE'][0]]['value']) ? $ar__value[$ar__index['PRICE'][0]]['value'] : '';
$om__result->field_property_type = isset($ar__value[$ar__index['TYPE'][0]]['value']) ? $ar__value[$ar__index['TYPE'][0]]['value'] : '';
$ss__field_property_images = NULL;
// allow six files
$sn__property_file_count = isset($ar__index['FILE']) ? count($ar__index['FILE']) : 0;
if($sn__property_file_count > 10) {
$sn__property_file_count = 10;
}
//
for($i = 0; $i < $sn__property_file_count; $i++) {
$attr = isset($ar__value[$ar__index['FILE'][$i]]['attributes']) ? $ar__value[$ar__index['FILE'][$i]]['attributes'] : array();
if(!isset($attr) || !isset($attr['TYPE']) || $attr['TYPE'] != 9) {
$sn__url_index = isset($ar__index['URL'][$i]) ? $ar__index['URL'][$i] : '';
$sn__value_index = isset($sn__url_index) && isset($ar__value[$sn__url_index]['value']) ? $ar__value[$sn__url_index]['value'] : '';
if($sn__value_index != '') {
if (strpos($ar__value[$ar__index['URL'][$i]]['value'],'home/hip/') === false) {//check is not energy certificate
$ss__field_property_images .= $ar__value[$ar__index['URL'][$i]]['value'] . ', ';
}
}
}
}
$om__result->field_property_images = $ss__field_property_images;
$om__result->field_reference = isset($ar__value[$ar__index['AGENTS'][0]]['value']) ? $ar__value[$ar__index['AGENTS'][0]]['value'] : '';
$om__result->field_bedrooms = isset($ar__value[$ar__index['BEDROOMS'][0]]['value']) ? $ar__value[$ar__index['BEDROOMS'][0]]['value'] : '';
$om__result->field_description = isset($ar__value[$ar__index['DESCRIPTION'][0]]['value']) ? addslashes($ar__value[$ar__index['DESCRIPTION'][0]]['value']) : '';
$om__result->field_lat_long_lat = isset($ar__value[$ar__index['LATITUDE'][0]]['value']) ? $ar__value[$ar__index['LATITUDE'][0]]['value'] : '';
$om__result->field_lat_long_lon = isset($ar__value[$ar__index['LONGITUDE'][0]]['value']) ? $ar__value[$ar__index['LONGITUDE'][0]]['value'] : '';
$om__result->field_area = isset($ar__value[$ar__index['AREA'][0]]['value']) ? trim($ar__value[$ar__index['AREA'][0]]['value']) : '';
if(isset($ar__index['BULLET']) && !empty($ar__index['BULLET'])) {
$attr = isset($ar__value[$ar__index['BULLET'][0]]['attributes']) ? $ar__value[$ar__index['BULLET'][0]]['attributes'] : '';
if($attr && $attr['ID'] == 1)
$om__result->field_area = isset($ar__value[$ar__index['BULLET'][0]]['value']) ? $ar__value[$ar__index['BULLET'][0]]['value'] : $ss__field_area;
}
$ss__field_energy_certificate = NULL;
$ss__certificate = '';
$ar__index['FILE'] = isset($ar__index['FILE']) ? $ar__index['FILE'] : array();
for($i = 0; $i < count($ar__index['FILE']); $i++) {
$attr = isset($ar__value[$ar__index['FILE'][$i]]['attributes']) ? $ar__value[$ar__index['FILE'][$i]]['attributes'] : '';
if($attr && $attr['TYPE'] == 9) {
$ar__index_certificate = $ar__index['FILE'][$i] + 2;
$ss__certificate .= (trim($ar__value[$ar__index_certificate]['value']) ? trim($ar__value[$ar__index_certificate]['value']) : trim($ar__value[$ar__index_certificate+1]['value'])) . ',';
}
}
$om__result->field_energy_certificate = $ss__certificate;
$om__result->field_data_available = isset($ar__value[$ar__index['AVAILABLE'][0]]['value']) ? $ar__value[$ar__index['AVAILABLE'][0]]['value'] : '';
$om__result->field_facilities2 = NULL;
$ar__index['BULLET'] = isset($ar__index['BULLET']) ? $ar__index['BULLET'] : array();
for($i = 0; $i < count($ar__index['BULLET']); $i++) {
$ss__facility = isset($ar__value[$ar__index['BULLET'][$i]]['value']) ? $ar__value[$ar__index['BULLET'][$i]]['value'] : '' ;
$ss__field_facilities2 .= $ss__facility . '#|#';
}
$om__result->field_facilities2 = $ss__field_facilities2;
$om__result->field_city_or_town = isset($ar__value[$ar__index['TOWN'][0]]['value']) ? $ar__value[$ar__index['TOWN'][0]]['value'] : '';
$om__result->field_postcodeprop = isset($ar__value[$ar__index['STREET'][0]]['value']) ? $ar__value[$ar__index['STREET'][0]]['value'] : '';
$om__result->field_street = isset($ar__value[$ar__index['STREET'][0]]['value']) ? $ar__value[$ar__index['STREET'][0]]['value'] : '';
$om__result->field_property_name_or_number = isset($ar__value[$ar__index['NAME'][0]]['value']) ? $ar__value[$ar__index['NAME'][0]]['value'] : '';
$om__result->field_locality = isset($ar__value[$ar__index['LOCALITY'][0]]['value']) ? $ar__value[$ar__index['LOCALITY'][0]]['value'] : '';
$ss__field_map_from_address = NULL;
$ss_display = isset($ar__value[$ar__index['DISPLAY'][0]]['value']) ? $ar__value[$ar__index['DISPLAY'][0]]['value'] : '';
$om__result->title = $ss_title = $ss_display;
$om__result->field_display_title = $ss_display;
//Create node
$node = new StdClass();
$node->type = 'import';//content type
$node->uid = 1;
$node->title = $om__result->title;
$node->status = 1;
$node->language = 'und';
//price
$node->field_rent_pm['und']['0']['value'] = $om__result->field_rent_pm;
//property type
$node->field_property_type['und'][0]['value'] = $om__result->field_property_type;
$ss__destination = file_build_uri('csv_import_property');
$ss__pro_images = explode(',', $om__result->field_property_images);
if(count($ss__pro_images)) {
for($i = 0; $i < count($ss__pro_images); $i++) {
$file_url = trim($ss__pro_images[$i]);
if($file_url != '') {
$file = _save_property_images($file_url, 1,'properties');
$node->field_property_images['und'][$i] = (array)$file;
}
}
}
//reference
$node->field_reference['und']['0']['value'] = $om__result->field_reference;
//field_bedrooms
$node->field_bedrooms['und']['0']['value'] = $om__result->field_bedrooms;
//field_description
$node->field_description['und']['0']['value'] = $om__result->field_description;
//field_lat_long:lat
$node->field_lat_long['und'][0] = array(
'lat' => $om__result->field_lat_long_lat,
'lon' => $om__result->field_lat_long_lon,
);
//field_area
$node->field_area['und']['0']['value'] = $om__result->field_area;
//field_energy_certificate
$ss__certificate_images = explode(',', $om__result->field_energy_certificate);
if(count($ss__certificate_images)) {
//if (file_prepare_directory($ss__destination, FILE_CREATE_DIRECTORY)) {
for($i = 0; $i < count($ss__certificate_images); $i++) {
$file_url = trim($ss__certificate_images[$i]);
if($file_url != '') {
$file = _save_property_images($file_url);
$node->field_energy_certificate['und'][$i] = (array)$file;
}
}
//}
}
//field_data_available
$arr__data_available = explode('/',$om__result->field_data_available);
$sn__yy = $arr__data_available[2];
$sn__mm = $arr__data_available[1];
$sn__dd = $arr__data_available[0];
$node->field_data_available['und']['0']['value'] = $sn__yy . '-' . $sn__mm . '-' . $sn__dd .' 00:00:00';//str_replace('/', '-', $om__result->field_data_available);//date('Y-m-d H:i:s');
//field_facilities2
$ss__facilities = explode('#|#', $om__result->field_facilities2);
$jj = 0;
for($ii = 0; $ii < count($ss__facilities); $ii++) {
if(trim($ss__facilities[$ii])) {
$node->field_facilities2['und'][$jj]['value'] = $ss__facilities[$ii];
$jj++;
}
}
//field_city_or_town
$node->field_city_or_town['und']['0']['value'] = $om__result->field_city_or_town;
//field_postcodeprop
$node->field_postcodeprop['und']['0']['value'] = $om__result->field_postcodeprop;
//field_street
$node->field_street['und']['0']['value'] = $om__result->field_street;
//field_city_or_town
$node->field_property_name_or_number['und']['0']['value'] = $om__result->field_property_name_or_number;
$node->field_locality['und']['0']['value'] = $om__result->field_locality;
//field_map_from_address field not available on property listing content type
//field_display_title
$node->field_display_title['und']['0']['value'] = $om__result->field_display_title;
$node->field_property_id['und'][0]['value'] = $om__result->field_property_id;
// update existing property
$query = db_select('field_data_field_property_id', 'p');
$query->join('node', 'n', 'p.entity_id = n.nid');
$query->fields('n', array('nid'))
->condition('p.field_property_id_value', $om__result->field_property_id, '=')
->condition('p.bundle', 'property_listing', '=');
$result = $query->execute();
if($result->rowCount()) {
$record = $result->fetchAssoc();
if(!empty($record['nid']))
$node->nid = $record['nid'];
}
// end of update existing
node_submit($node);
$nid = node_save($node);
if($node->nid) {
drupal_set_message(t('@node has been created', array('@node' => $node->title)));
}else {
drupal_set_message('DB:Error ', 'error');
}
unset($node, $om__result, $r__result);
return true;
}
function _get_response($url = '', $request_token = false){
if($url == '')
return false;
$ss__token = variable_get('csv_import_token',0);
$username = 'XXXXXXXXXX';
$password = 'XXXXXXXXXX';
$ch = curl_init();
if(isset($_SESSION['VAR']) && $_SESSION['VAR'] > 3 ) {
drupal_set_message('We are failed to fetch Token please try after some times', 'error');
unset($_SESSION['VAR']);
watchdog('import', 'failed to fetch Token ',array(), WATCHDOG_NOTICE);
//drupal_goto('');
}
curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);
curl_setopt($ch, CURLOPT_HEADER, TRUE);
curl_setopt($ch, CURLOPT_URL, $url);
if($request_token == false ) {
watchdog('import property', 'Authorize using old token',array(), WATCHDOG_NOTICE);
curl_setopt($ch, CURLOPT_HTTPHEADER, array('Authorization: Basic '.base64_encode($ss__token) )); // I found this to be the only way of consistently authorising between user-password combo and using a token
}
else {
watchdog('csv_import', 'Authorize using User:Pass',array(), WATCHDOG_NOTICE);
curl_setopt($ch, CURLOPT_HTTPHEADER, array('Authorization: Basic '.base64_encode("$username:$password") )); // I found this to be the only way of consistently authorising between user-password combo and using a token
}
$response = curl_exec($ch);
list($headers, $body) = explode("\r\n\r\n", $response);
$headers = nl2br($headers);
$headers = explode('<br />', $headers);
$status = explode(' ', $headers[0]);
$status = $status[1];
if($status == '200'){
foreach($headers as $header) {
$components = explode(': ', trim($header));
$headers[$components[0]] = isset($components[1]) ? $components[1] : '';
}
$ss__token = isset($headers['Token']) ? $headers['Token'] : variable_get('csv_import_token', 0);
if(isset($headers['Token'])){
variable_set('csv_import_token', $ss__token);
watchdog('import', 'Token updated', array(), WATCHDOG_NOTICE);
}
return $body;
}
else if($status == '401') {
$_SESSION['VAR'] = isset($_SESSION['VAR']) ? ($_SESSION['VAR'] + 1) : 1;
return _get_response($url, true);
drupal_set_message('Unauthorized');
}
else if($status == '204') {
drupal_set_message('Import Property: Provided branch has no property list');
}
else if($status == '403') {
drupal_set_message('Import Property: Forbidden The access property that is not available to the client');
}
else if($status == '404') {
drupal_set_message('Import Property: incorrect URL');
}
else if($status == '410') {
drupal_set_message('Import Property: The property/branch has been deleted OR is not currently available');
}
else if($status == '500') {
drupal_set_message('Import Property: Something bad happened to the API');
}
else if($status == '501') {
drupal_set_message('Import Property: The API version in the request is not supported');
}
else
drupal_set_message('Import Property: Property Import fail');
}
?>Info file details