dc

application/controllers/Webservices.php

@@ -179,7 +179,6 @@ class Webservices extends CI_Controller {
     } else {
       print json_encode(array('status'=>'error','message'=>'You are not authorized to access the server', 
                               'error'=>'Authentication Failed'));
-
     }
   }
 
@@ -339,8 +338,8 @@ class Webservices extends CI_Controller {
       $request['auth'] = $auth;
       if(!empty($request) && isset($request['trip_type']) && !empty($request['trip_type']) && 
          isset($request['source_name']) && !empty($request['source_name']) && 
-         isset($request['destination_name']) && !empty($request['destination_name']) && 
          isset($request['source_latitude']) && !empty($request['source_latitude']) && 
+         isset($request['destination_name']) && !empty($request['destination_name']) && 
          isset($request['source_longitude']) && !empty($request['source_longitude']) && 
          isset($request['destination_latitude']) && !empty($request['destination_latitude']) && 
          isset($request['destination_longitude']) && !empty($request['destination_longitude'])){
@@ -507,4 +506,27 @@ class Webservices extends CI_Controller {
     }
   }
 
+  public function driverAssignCrone(){
+    $ride_data = $this->Webservice_model->driverAssignCrone();
+    if(empty($ride_data)){
+      return;
+    }
+
+    foreach ($ride_data AS $ride) {
+      if(empty($ride['pickup_lat']) || empty($ride['pickup_lng']) || 
+         empty($ride['appointment_time']) || $ride['appointment_time']<strtotime(date('Y-m-d H:i:s'))){
+        continue;
+      }
+
+      $driver_data = $this->Webservice_model->getAvailableDrivers($ride['pickup_lat'],$ride['pickup_lng'],$ride['appointment_time']);
+
+      if(!empty($driver_data) && !empty($driver_data['driver_id']) && 
+         !empty($driver_data['distance']) && !empty($driver_data['fcm_token'])){
+        $fcm_data = array('title'=>'Ride Request','message'=>'Emergency Ride Request',
+                          'request_id'=>$ride['transport_id']);
+        push_sent_cancel(1,$driver_data['fcm_token'],$fcm_data);
+      }
+    }
+  }
+
 }?>
\ No newline at end of file

application/controllers/Webservices_driver.php

@@ -704,7 +704,7 @@
 
                    $result = $this->Webservices_driver_model->history_trips_schedule($request);
                   
-                   if ($result) {
+                   if (!empty($result)) {
 
                          $total = COUNT($result);
 

application/helpers/generals_helper.php

@@ -133,4 +133,38 @@ function getLatLngFromLocation($location = ''){
 		return 0;
 	return $locArr;
 }
-?>
+
\ No newline at end of file
+function getSettings(){
+	$CI = & get_instance();
+	$settings = $CI->db->get('setting');
+	return (!empty($settings))?$settings->row_array():'';
+}
+
+function push_sent_cancel($type='1', $fcm_token='', $fcm_data=array()) {
+	$settings = getSettings();
+	$key = $settings['push_app_key'];
+
+	if(empty($key) || empty($fcm_token) || empty($fcm_data)){
+		return;
+	}
+
+	switch ($type) {
+		case '1':
+			$data = "{ \"notification\": { \"title\": \"".$fcm_data['title']."\", \"text\": \"".$fcm_data['message']."\", \"sound\": \"default\" }, \"time_to_live\": 60, \"data\" : {\"response\" : {\"status\" : \"success\", \"data\" : {\"request_id\" : \"".$fcm_data['request_id']."\", \"request_type\" : 0}}}, \"collapse_key\" : \"trip\", \"priority\":\"high\", \"to\" : \"".$fcm_token."\"}";
+			break;
+		// case '2':
+		// 	$data = "{ \"notification\": { \"title\": \"".$fcm_data['title']."\", \"text\": \"".$fcm_data['message']."\", \"sound\": \"default\" }, \"time_to_live\": 60, \"data\" : {\"response\" : {\"status\" : \"success\", \"data\" : {\"booking_id\" : \"".$fcm_data['id']."\", \"trip_status\" : 0}}}, \"collapse_key\" : \"trip\", \"priority\":\"high\", \"to\" : \"".$fcm_token."\"}";
+		// 	break;
+	}
+
+	$ch = curl_init("https://fcm.googleapis.com/fcm/send");
+	$header = array('Content-Type: application/json', 'Authorization: key='.$key);
+	curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
+	curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
+	curl_setopt($ch, CURLOPT_POST, 1);
+	curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
+
+	$out = curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
+	curl_exec($ch);
+	curl_close($ch);
+}?>
\ No newline at end of file

application/models/Webservice_model.php

- <?php
-
- class Webservice_model extends CI_Model {
+<?php
+class Webservice_model extends CI_Model {
    function __construct() {
       parent::__construct();
       date_default_timezone_set('Asia/Kolkata');
@@ -344,14 +343,14 @@
 
          $cusrimer_id = $rs->cust_id;
 
-                  $customerDetails = $data = "SELECT CONCAT(c.first_name,' ',c.last_name) AS patient_name,
+         $customerDetails = "SELECT CONCAT(c.first_name,' ',c.last_name) AS patient_name,
          cust_company_list.company_id AS company_id, c.phone FROM customers AS c 
          LEFT JOIN cust_company_list ON cust_company_list.user_id = c.customer_id 
          WHERE c.customer_id = '$cusrimer_id'";
 
          $result = $this->db->query($customerDetails)->row();
 
-                  $getDistance = $this->GetDrivingDistance($request['source_latitude'], $request['destination_latitude'], $request['source_longitude'], $request['destination_longitude']);
+         $getDistance = $this->GetDrivingDistance($request['source_latitude'], $request['destination_latitude'],$request['source_longitude'],$request['destination_longitude']);
 
          $distanceValue = $getDistance['distanceValue'] * 0.001;
 
@@ -372,9 +371,10 @@
                'drop_lat'=>$request['destination_latitude'],
                'drop_lng'=>$request['destination_longitude'],
                'request_type'=>$request['trip_type'],
+               'is_scheduled'=>2,
                'driver_assign_status'=>2,
                'payment_mode'=>0,
-                              'status'=>'3');
+               'status'=>'1');
             $this->db->insert('transport_details', $data);
             $last_id = $this->db->insert_id();
          }else{
@@ -775,5 +775,56 @@
 
       return $isAvailable;
    }
+
+   public function driverAssignCrone(){
+      $sql = "SELECT TD.transport_id,TD.appointment_time,TD.pickup_lat,TD.pickup_lng,TD.drop_lat, 
+               TD.drop_lng,TD.vehicle_type,TD.status,TD.is_scheduled,DR.request_time,DR.status
+           FROM transport_details AS TD
+           LEFT JOIN driver_request AS DR ON (TD.transport_id=DR.trip_id)
+           LEFT JOIN drivers AS DRV ON (DR.driver_id=DR.driver_id)
+           WHERE TD.status IN ('1','3','7') 
+           ORDER BY TD.transport_id DESC";
+      $ride_data = $this->db->query($sql);
+      if(empty($ride_data)){
+         return 0;
+      }
+      return $ride_data->result_array();
+   }
+
+   public function getAvailableDrivers($lat='',$lng='',$aTime=''){
+      if(empty($lat) || empty($lng) || empty($aTime)){
+         return;
+      }
+      $cTime = date('H:i');
+      $data = $this->db->query(
+                  "SELECT d.driver_id,d.fcm_token,
+                       (((acos(sin(($lat*pi()/180))*sin((lat_driver*pi()/180))+
+                       cos(($lat*pi()/180))*cos((lat_driver*pi()/180))*
+                       cos((($lng-lng_driver)*pi()/180))))*180/pi())*60*1.1515) as distance 
+                   FROM drivers AS d 
+                   WHERE d.status='1' AND d.online_start_time < '$cTime' AND d.online_end_time > '$cTime'
+                   HAVING distance<15
+                   ORDER BY distance DESC");
+
+      if(!empty($data) && !empty($driverData = $data->result_array())){
+         $key = '';
+         $startTime = strtotime(date('Y-m-d H:i:s')) - 1800;
+         $finishTime = strtotime(date('Y-m-d H:i:s')) + 1800;
+         foreach ($driverData AS $key => $driver) {
+            $driver_id = $driver['driver_id'];
+            $sql = "SELECT TD.driver_id
+                    FROM transport_details AS TD
+                    WHERE TD.status NOT IN ('4','5') AND TD.driver_id='$driver_id' AND 
+                          TD.appointment_time>$startTime AND TD.appointment_time<$finishTime";
+            $is_avail = $this->db->query($sql)->num_rows();
+
+            if($is_avail <= 0){
+               break;
+            }
+         }
+         return $driverData[$key];
+      }
+      return;
+   }
 }
 ?>
\ No newline at end of file

application/models/Webservices_driver_model.php

@@ -424,7 +424,7 @@ class Webservices_driver_model extends CI_Model {
 
                   $rand = rand(1111, 99999);
 
-                  $book_id = "$code"."$rand";
+                  $book_id = $code."$rand";
 
                   $driverDetails = $this->db->query("SELECT vehicle_id FROM `drivers` WHERE driver_id = '$rs->driver_id'")->row();
                   
@@ -520,7 +520,7 @@ class Webservices_driver_model extends CI_Model {
 
       public function status_driver($id) {
 
-            $data = $this->db->query("SELECT *  FROM `transport_details` WHERE transport_id = '$id'")->row();
+            $data = $this->db->query("SELECT *, car_arrival AS trip_status  FROM `transport_details` WHERE transport_id = '$id'")->row();
 
 
             if ($data->status == 6 && $data->cash_collection == 1) {
@@ -601,31 +601,32 @@ class Webservices_driver_model extends CI_Model {
       // *********************** EMERGENCY RIDE HISTORY ********************
 
        public function history_trips_schedule($request) {
-
-
             $query = $this->db->where('unique_id', $request['auth'])->get('driver_auth_table');
 
-            if ($query->num_rows() > 0) {
-
-                  $rs = $query->row();
-
-                  $driv_id = $rs->driver_id;
-
-                  $data = "SELECT t.transport_id AS id, customers.customer_id AS customer_id, CONCAT(customers.first_name,
-                  ' ',customers.last_name) AS customer_name, customers.profile_image AS customer_photo, t.pickup_location AS source_location, t.pickup_lng AS source_longitude, t.pickup_lat AS source_latitude, t.drop_location AS destination_location, t.drop_lat AS destination_latitude, t.drop_lng AS destination_longitude FROM transport_details AS t LEFT JOIN drivers AS d ON d.driver_id = t.driver_id LEFT JOIN customers ON t.customer_id = customers.customer_id WHERE t.driver_id = '$driv_id' AND request_type = 3 AND t.status = 6";  
+            if (!empty($query) && $query->num_rows() > 0 && !empty($rs = $query->row()) && 
+                !empty($driv_id = $rs->driver_id)) {
+
+                  $data = "SELECT TRNS.transport_id AS id, CUST.customer_id AS customer_id, 
+                           CONCAT(CUST.first_name,' ',CUST.last_name) AS customer_name, 
+                           TRNS.pickup_lng AS source_longitude, TRNS.pickup_lat AS source_latitude, 
+                           TRNS.drop_location AS destination_location, TRNS.drop_lat AS destination_latitude, 
+                           CUST.profile_image AS customer_photo, TRNS.pickup_location AS source_location, 
+                           TRNS.drop_lng AS destination_longitude, DR.status AS request_status, 
+                           TRNS.status AS ride_status,TRNS.trip_cost AS fare
+                           FROM transport_details AS TRNS 
+                           INNER JOIN driver_request AS DR ON DR.trip_id = TRNS.transport_id 
+                           INNER JOIN customers AS CUST ON TRNS.customer_id = CUST.customer_id
+                           WHERE DR.driver_id = '$driv_id' AND request_type = 3 AND 
+                                 TRNS.status IN (1,3,4,5,6,8)";
                   $result = $this->db->query($data)->result_array();  
-
-                  $result[0]['app_status'] = '1';
-
-                   $data1 = "SELECT t.transport_id AS id, customers.customer_id AS customer_id, CONCAT(customers.first_name,
-                  ' ',customers.last_name) AS customer_name, customers.profile_image AS customer_photo, t.pickup_location AS source_location, t.pickup_lng AS source_longitude, t.pickup_lat AS source_latitude, t.drop_location AS destination_location, t.drop_lat AS destination_latitude, t.drop_lng AS destination_longitude FROM transport_details AS t LEFT JOIN drivers AS d ON d.driver_id = t.driver_id LEFT JOIN customers ON t.customer_id = customers.customer_id WHERE t.driver_id = '$driv_id' AND request_type = 3 AND t.status = 3";  
-                  $result1 = $this->db->query($data1)->result_array(); 
-
-                  $result1[0]['app_status'] = '2';
-
-                  $resultArray = array_merge($result, $result1);
-                  
-                  return $resultArray;  
+                  foreach($result AS $key => $ride){
+                        $result[$key]['type'] = 1;
+                        if($ride['request_status'] == 1 && $ride['request_status'] == 6){
+                              $result[$key]['type'] = 2;
+                        }
+                        unset($result[$key]['request_status'],$result[$key]['ride_status']);
+                  }
+                  return $result;  
 
             } else {