Build you own webservice ~ Tech Blog

Wednesday, 3 June 2015

Build you own webservice

Build you own webservices in php using nusoap library.

<?php

ini_set("soap.wsdl_cache_enabled", "0");

require_once('./common.php');
require_once('./lib/nusoap.php');

$server = new soap_server;
global $common, $device_id, $start, $end;

$server->configureWSDL('trackn', 'urn:tracknwsdl');

$server->register('update_location',
    array(
  'device_number' => 'xsd:string', 
  'latitude' => 'xsd:string', 
  'longitude' => 'xsd:string', 
  'battery_status' => 'xsd:string',
  'speed' => 'xsd:string'),
    array('return' => 'xsd:boolean'),
    'urn:tracknwsdl',
    'urn:tracknwsdl#locate_device',
    'rpc',
    'encoded',
    'Find the location of device'
);
// Define the method as a PHP function
function update_location($device_number, $latitude, $longitude, $battery_status, $speed=0) {
 
 global $common;
 
 // Finding Entity Id from device number
 $sql = "select EntityId FROM jos_tbl_entity WHERE DeviceNumber='".$device_number."'";
 $rows = $common->get_result($sql);
 
 if($common->check_array($rows))
 {
  $entity_id = $rows[0]['EntityId'];
  
  $address = findAddress($latitude, $longitude);
  
  $arr = array(
     'EntityId'    => $entity_id,
     'Longitude'   => $longitude,
     'Latitude'   => $latitude,
     'address'   => $address,
     'Battery_status'  => $battery_status,
     'Speed'    => $speed,
     'bActive'   => '1'
    );
  $common->insert('jos_tbl_entity_position', $arr);
  
  return true;
 }
 else {
  return false;
 }
}

$server->register('user_action',
    array(
  'device_number' => 'xsd:string',
  'latitude' => 'xsd:string', 
  'longitude' => 'xsd:string', 
  'action_type' => 'xsd:string',
  'notes' => 'xsd:string'
  ),
    array('return' => 'xsd:boolean'),
    'urn:tracknwsdl',
    'urn:tracknwsdl#locate_device',
    'rpc',
    'encoded',
    'Find the location of device'
);
// Define the method as a PHP function
function user_action($device_number, $latitude, $longitude, $action_type, $notes='') {
 
 global $common, $device_id, $start, $end;

 /*
 $mtime = explode(" ", microtime());
 $start = doubleval($mtime[1]) + doubleval($mtime[0]); 
 
 $mtime = explode(" ", microtime());
 $end   = doubleval($mtime[1]) + doubleval($mtime[0]);
 $time_elapsed = round(number_format(abs($start - $end), 5, '.', ''));
 */

 $common->log_msg("User Action Method");
 
 // Finding Entity Id from device number
 $sql = "select EntityId FROM jos_tbl_entity WHERE DeviceNumber='".$device_number."'";
 $rows = $common->get_result($sql);
 
 if($common->check_array($rows)) {
  
  $entity_id = $rows[0]['EntityId'];
  
  // Finding previous status to stop
  $sql_find_status = "select * FROM jos_tbl_user_action WHERE EntityId=$entity_id order by UserActionId desc limit 0,1";
  $rows_find_status = $common->get_result($sql_find_status);
  
  $address = findAddress($latitude, $longitude);
  
  // changing the status of previous record to "stop"
  if($common->check_array($rows_find_status)) {
    
   $row = $rows_find_status[0];
   
   $prev_row = array(
    'EntityId'   => $entity_id,
    'ActionType'  => $row['ActionType'],
    'Latitude'   => $latitude,
    'Longitude'  => $longitude,
    'address'   => $address,
    'Notes'   => $notes
   );

   $common->insert('jos_tbl_user_action', $prev_row);

  }
  
  
  $arr = array(
    'EntityId'     => $entity_id,
    'ActionType'    => $action_type,
    'Latitude'    => $latitude,
    'Longitude'    => $longitude,
    'address'    => $address,
    'Notes'     => $notes,
    'Action_status'   => 1
   );
  $common->insert('jos_tbl_user_action', $arr);
  
  return true;
 }
 else {
  return false;
 }
}

$server->register('sos',
    array(
  'device_number' => 'xsd:string', 
  'latitude' => 'xsd:string', 
  'longitude' => 'xsd:string', 
  ),
    array('return' => 'xsd:boolean'),
    'urn:tracknwsdl',
    'urn:tracknwsdl#sos',
    'rpc',
    'encoded',
    'Sending sos message.'
);
function sos($device_number, $latitude, $longitude) {

 global $common;
 
 $sql = "select EntityId FROM jos_tbl_entity WHERE DeviceNumber='".$device_number."'";
 $rows = $common->get_result($sql);
 
 if($common->check_array($rows))
 {
  $entity_id = $rows[0]['EntityId'];
  
  $address = findAddress($latitude, $longitude);
  
  // Inserting data into sos table
  $arr = array(
   'EntityId'     => $entity_id,
   'Latitude'    => $latitude,
   'Longitude'    => $longitude,
   'address'    => $address
  );
  
  $common->insert('jos_tbl_send_sos', $arr);
  
  $rs = true;
 }
 else {
  $rs = false;
 }

 return $rs;
}

$server->wsdl->addComplexType(
    'entity_list',
    'complexType',
    'struct',
    'all',
    '',
    array(
         'device_number'  => array('name' => 'device_no',   'type' => 'xsd:string'),
         'user_name'   => array('name' => 'user_name',   'type' => 'xsd:string'),
         'longitude'   => array('name' => 'longitude',   'type' => 'xsd:string'),
         'latitude'    => array('name' => 'latitude',    'type' => 'xsd:string'),
         'address'    => array('name' => 'address',    'type' => 'xsd:string'),
         'battery_status'  => array('name' => 'battery_status', 'type' => 'xsd:string')
 )
);

$server->wsdl->addComplexType(
    'entity_list2',
    'complexType',
    'array',
    '',
    'SOAP-ENC:Array',
    array(),
    array(
  array('ref'=>'SOAP-ENC:arrayType',
  'wsdl:arrayType'=>'tns:entity_list[]')
 ),
 'tns:entity_list'
);

$server->register('user_entity_status',
    array('device_number' => 'xsd:string'),
    array('return' => 'tns:entity_list2'),
    'urn:tracknwsdl',
    'urn:tracknwsdl#user_entity_status',
    'rpc',
    'encoded',
    'User detials of a particular user.'
);
function user_entity_status($device_number) {

 global $common;
 $return = array();
 
 $common->log_msg("User_entity_status");

 $sql = "select UserId FROM jos_tbl_entity WHERE DeviceNumber='".$device_number."'";
 $rows = $common->get_result($sql);
 
 if($common->check_array($rows))
 {
  $user_id = $rows[0]['UserId'];
  
  // Searching for the child records
  $sql_child_users = "select EntityId, UserId, DeviceNumber, ObjectTypeId FROM jos_tbl_entity WHERE UserId='".$user_id."' and DeviceNumber != '".$device_number."'";

  $rows_child_users = $common->get_result($sql_child_users);
  
  if($common->check_array($rows_child_users)) {
   
   foreach ($rows_child_users as $row) {

    $arr = array();

    $object_type_key = $common->get_row("jos_tbl_object_type", $row['ObjectTypeId'], 'ObjectKey');
    
    $name='';
    switch($object_type_key) {
     case 'person':
      $name = $common->get_row("jos_tbl_person", $row['EntityId'], 'FirstName');
     break;

     case 'vehicle':
      $name = $common->get_row("jos_tbl_vehicle", $row['EntityId'], 'DriverName');
     break;

     case 'object':
      $name = $common->get_row("jos_tbl_object", $row['EntityId'], 'FirstName');
     break;
    }


    $sql_entity_pos = "select EntityPositionId, Longitude, Latitude, address, Battery_status FROM jos_tbl_entity_position WHERE EntityId='".$row['EntityId']."' order by EntityPositionId desc limit 0,1";
    $rows_entity_pos = $common->get_result($sql_entity_pos);
    $row_entity_pos = $rows_entity_pos[0];
    
    $arr['device_number']  = $row['DeviceNumber'];
    $arr['user_name']   = $name;
    $arr['longitude']   = $row_entity_pos['Longitude'];
    $arr['latitude']   = $row_entity_pos['Latitude'];
    $arr['address']   = $row_entity_pos['address'];
    $arr['battery_status']  = $row_entity_pos['Battery_status'];
  
    $return[] = $arr;
   }
  }
 }

 return $return;
}

function findAddress($Lat, $Lng) {
  
 $address = getGeoname($Lat, $Lng);
 if(empty($address)) {
  $address = getAddress($Lat, $Lng);
 }

 return $address;
}


function getAddress($Lat, $Lng) {

 $ch = curl_init();
 $url = "http://ws.geonames.org/findNearestAddress?lat=$Lat&lng=$Lng"; // For US Only
 curl_setopt($ch, CURLOPT_URL, $url);

 curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0);
 curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);
 //curl_setopt($ch, CURLOPT_POSTFIELDS, '');
 $temp = curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
 $returnData = curl_exec ($ch);
 $error = curl_error( $ch );
 if( !empty( $error )) {

  curl_close ($ch);
  $_SESSION['CURL_ERROR'] = true;
  $_SESSION['CURL_ERROR_TXT'] = $error;

  return "<br/><span class=\"message\"> CURL error: ".$error."</span>";
 }
 curl_close ($ch);

 $arr = xml2array($returnData);
 $arr_address = $arr['geonames']['address'];

 if( (is_array($arr_address)) && (count($arr_address) > 0) ) {

  $address = $arr_address['streetNumber']." ".$arr_address['street'].", ".$arr_address['placename'].", ".$arr_address['adminCode1']." ".$arr_address['postalcode'].", ".$arr_address['countryCode'];

 }
 else {
  $address = '';
 }

 return $address;
}


function getGeoname($Lat, $Lng) {

 $ch = curl_init();
 $url = "http://ws.geonames.org/extendedFindNearby?lat=$Lat&lng=$Lng";
 curl_setopt($ch, CURLOPT_URL, $url);

 curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0);
 curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);
 $temp = curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
 $returnData = curl_exec($ch);
 $error = curl_error( $ch );
 if( !empty( $error )) {

  curl_close ($ch);
  $_SESSION['CURL_ERROR'] = true;
  $_SESSION['CURL_ERROR_TXT'] = $error;

  return "<br/><span class=\"message\"> CURL error: ".$error."</span>";
 }
 curl_close ($ch);

 $arr = xml2array($returnData);
 $arr_address = $arr['geonames']['geoname'];

 if( (is_array($arr_address)) && (count($arr_address) > 0) ) {

  $address = $arr_address['4']['name'].", ".$arr_address['3']['name'].", ".$arr_address['3']['countryCode'];

 }
 else {
  $address = '';
 }

 return $address;
}

function xml2array($contents, $get_attributes=1, $priority = 'tag') {
 if(!$contents) return array();

 if(!function_exists('xml_parser_create')) {
  //print "'xml_parser_create()' function not found!";
  return array();
 }

 //Get the XML parser of PHP - PHP must have this module for the parser to work
 $parser = xml_parser_create('');
 xml_parser_set_option($parser, XML_OPTION_TARGET_ENCODING, "UTF-8"); # http://minutillo.com/steve/weblog/2004/6/17/php-xml-and-character-encodings-a-tale-of-sadness-rage-and-data-loss
 xml_parser_set_option($parser, XML_OPTION_CASE_FOLDING, 0);
 xml_parser_set_option($parser, XML_OPTION_SKIP_WHITE, 1);
 xml_parse_into_struct($parser, trim($contents), $xml_values);
 xml_parser_free($parser);

 if(!$xml_values) return;//Hmm...

 //Initializations
 $xml_array = array();
 $parents = array();
 $opened_tags = array();
 $arr = array();

 $current = &$xml_array; //Refference

 //Go through the tags.
 $repeated_tag_index = array();//Multiple tags with same name will be turned into an array
 foreach($xml_values as $data) {
  unset($attributes,$value);//Remove existing values, or there will be trouble

  //This command will extract these variables into the foreach scope
  // tag(string), type(string), level(int), attributes(array).
  extract($data);//We could use the array by itself, but this cooler.

  $result = array();
  $attributes_data = array();
  
  if(isset($value)) {
   if($priority == 'tag') $result = $value;
   else $result['value'] = $value; //Put the value in a assoc array if we are in the 'Attribute' mode
  }

  //Set the attributes too.
  if(isset($attributes) and $get_attributes) {
   foreach($attributes as $attr => $val) {
    if($priority == 'tag') $attributes_data[$attr] = $val;
    else $result['attr'][$attr] = $val; //Set all the attributes in a array called 'attr'
   }
  }

  //See tag status and do the needed.
  if($type == "open") {//The starting of the tag '<tag>'
   $parent[$level-1] = &$current;
   if(!is_array($current) or (!in_array($tag, array_keys($current)))) { //Insert New tag
    $current[$tag] = $result;
    if($attributes_data) $current[$tag. '_attr'] = $attributes_data;
    $repeated_tag_index[$tag.'_'.$level] = 1;

    $current = &$current[$tag];

   } else { //There was another element with the same tag name

    if(isset($current[$tag][0])) {//If there is a 0th element it is already an array
     $current[$tag][$repeated_tag_index[$tag.'_'.$level]] = $result;
     $repeated_tag_index[$tag.'_'.$level]++;
    } else {//This section will make the value an array if multiple tags with the same name appear together
     $current[$tag] = array($current[$tag],$result);//This will combine the existing item and the new item together to make an array
     $repeated_tag_index[$tag.'_'.$level] = 2;
     
     if(isset($current[$tag.'_attr'])) { //The attribute of the last(0th) tag must be moved as well
      $current[$tag]['0_attr'] = $current[$tag.'_attr'];
      unset($current[$tag.'_attr']);
     }

    }
    $last_item_index = $repeated_tag_index[$tag.'_'.$level]-1;
    $current = &$current[$tag][$last_item_index];
   }

  } elseif($type == "complete") { //Tags that ends in 1 line '<tag />'
   //See if the key is already taken.
   if(!isset($current[$tag])) { //New Key
    $current[$tag] = $result;
    $repeated_tag_index[$tag.'_'.$level] = 1;
    if($priority == 'tag' and $attributes_data) $current[$tag. '_attr'] = $attributes_data;

   } else { //If taken, put all things inside a list(array)
    if(isset($current[$tag][0]) and is_array($current[$tag])) {//If it is already an array...

     // ...push the new element into that array.
     $current[$tag][$repeated_tag_index[$tag.'_'.$level]] = $result;
     
     if($priority == 'tag' and $get_attributes and $attributes_data) {
      $current[$tag][$repeated_tag_index[$tag.'_'.$level] . '_attr'] = $attributes_data;
     }
     $repeated_tag_index[$tag.'_'.$level]++;

    } else { //If it is not an array...
     $current[$tag] = array($current[$tag],$result); //...Make it an array using using the existing value and the new value
     $repeated_tag_index[$tag.'_'.$level] = 1;
     if($priority == 'tag' and $get_attributes) {
      if(isset($current[$tag.'_attr'])) { //The attribute of the last(0th) tag must be moved as well
       
       $current[$tag]['0_attr'] = $current[$tag.'_attr'];
       unset($current[$tag.'_attr']);
      }
      
      if($attributes_data) {
       $current[$tag][$repeated_tag_index[$tag.'_'.$level] . '_attr'] = $attributes_data;
      }
     }
     $repeated_tag_index[$tag.'_'.$level]++; //0 and 1 index is already taken
    }
   }

  } elseif($type == 'close') { //End of tag '</tag>'
   $current = &$parent[$level-1];
  }
 }
 
 return($xml_array);
}





// Use the request to (try to) invoke the service
$HTTP_RAW_POST_DATA = isset($HTTP_RAW_POST_DATA) ? $HTTP_RAW_POST_DATA : '';
$server->service($HTTP_RAW_POST_DATA);
exit();

?>

Usage

Steps:
1. Download nusoap library from internet
2. Make Your own functions in this file and enjoy you own webservice.

Tech Blog

Wednesday, 3 June 2015

Build you own webservice

Usage

0 comments:

Post a Comment

Total Pageviews

Achievement

Live Traffic

Followers

About Me

I V RAMANA

Recent Comments

Categories

Popular Posts

Hot Topics

Video

News

Comments

Recent

Bottom Ad [Post Page]

Recent Posts

Mysql - How to reset the administrator password in ISPConfig 3

Socialize

Blog Archive

Search This Blog

Post Top Ad

Archive

Post Bottom Ad

Author Details

About Me

Tags

Full width home advertisement

Pages

Post Page Advertisement [Top]

Climb the mountains

Wednesday, 3 June 2015

Usage

0 comments:

Post a Comment

Total Pageviews

Achievement

Live Traffic

Subscribe To

Followers

About Me

I V RAMANA

Recent Comments

Categories

Popular Posts

Hot Topics

Video

News

Comments

Recent

Bottom Ad [Post Page]

Recent Posts

Mysql - How to reset the administrator password in ISPConfig 3

Socialize

Blog Archive

Search This Blog

Post Top Ad

Archive

Post Bottom Ad

Author Details

About Me

Tags

Full width home advertisement

Pages

Post Page Advertisement [Top]

Climb the mountains