Skip to content

D
dcarfixers
Commit 52123e41 by Tobin
Options

DC WEB SERVICES

parent 9304bf2f
Showing with 663 additions and 1538 deletions
application/controllers/Webservices.php
......@@ -530,5 +530,484 @@ class Webservices extends CI_Controller {
}
echo json_encode($return_arr);exit;
}
/*****************************************************************************************/
/****************************************Mobile API's*************************************/
public function mobile_number_availability(){
header('Content-type: application/json');
$post = file_get_contents("php://input");
$postData = json_decode($post, true);
$respArr = array('status'=>'error','error'=>'901','message'=>'Something went wrong.');
if(!isset($postData['phone']) || empty($postData['phone'])){
$respArr = array('status'=>'0','error'=>'903','message'=>'Required Fields are empty.');
echo json_encode($respArr);exit;
}
$custResp = $this->Webservice_model->checkMobAvailability($postData);
if(!empty($custResp)){
$respArr = $custResp;
}
echo json_encode($respArr);exit;
}
public function user_login(){
header('Content-type: application/json');
$post = file_get_contents("php://input");
$postData = json_decode($post, true);
$respArr = array('status'=>'0','message'=>'Required Fields are empty.');
if(!isset($postData['email']) || empty($postData['email']) ||
!isset($postData['password']) || empty($postData['password'] = md5($postData['password']))){
echo json_encode($respArr);exit;
}
$custResp = $this->Webservice_model->checkCustomerLogin($postData);
if(empty($custResp) || !isset($custResp['status']) || empty($custResp['status'])){
echo json_encode($respArr);exit;
}
if($custResp['status'] == '1'){
$respArr['data'] = $custResp['data'];
$respArr['status'] = 'success';
$respArr['message'] = 'Success';
echo json_encode($respArr);exit;
}
if($custResp['status'] == '2'){
$respArr['status'] = 'error';
$respArr['message'] = 'Invalid Email Address';
echo json_encode($respArr);exit;
}
if($custResp['status'] == '3'){
$respArr['status'] = 'error';
$respArr['message'] = 'Invalid Password';
echo json_encode($respArr);exit;
}
echo json_encode($respArr); exit;
}
// customer_registration
public function user_registration(){
header('Content-type: application/json');
$post = file_get_contents("php://input");
$postData = json_decode($post, true);
$respArr = array('status'=>'0','message'=>'Something went wrong.');
if(empty($postData)){
echo json_encode($respArr);exit;
}
$err = 0;
$msg = '';
if(!isset($postData['email']) || empty($postData['email'])){
$err = 1;
$msg = 'Provide a valid Email ID';
}
else if(!isset($postData['password']) || empty($postData['password'] = md5($postData['password']))){
$err = 1;
$msg = 'Provide a Password';
}
else if(!isset($postData['name']) || empty($postData['name'])){
$err = 1;
$msg = 'Provide valid Name';
}
else if(!isset($postData['country_code']) || empty($postData['country_code'])){
$err = 1;
$msg = 'Provide a Country Code';
}
else if(!isset($postData['phone']) && empty($postData['phone'])){
$err = 1;
$msg = 'Provide a Phone Number';
}
if($err == 1){
$respArr['message'] = $msg;
echo json_encode($respArr);exit;
}
$custResp = $this->Webservice_model->createCustomer($postData);
if(empty($custResp)){
echo json_encode($respArr);exit;
}
if($custResp['status'] == '1'){
$respArr['data'] = $custResp['data'];
$respArr['status'] = 'success';
$respArr['message'] = 'Success';
echo json_encode($respArr);exit;
} else if($custResp['status'] == '2'){
$respArr['status'] = 'error';
$respArr['message'] = 'Email Address already in use';
echo json_encode($respArr);exit;
} else if($custResp['status'] == '3'){
$respArr['status'] = 'error';
$respArr['message'] = 'Phone already in use';
echo json_encode($respArr);exit;
}
echo json_encode($respArr); exit;
}
public function get_booked_services(){
header('Content-type: application/json');
$headers = apache_request_headers();
if(!isset($headers['Auth']) || empty($headers['Auth'])){
$respArr['status'] = '0';
$respArr['message'] = 'Authtoken is Required';
echo json_encode($respArr);exit;
}
$authRes = $this->Webservice_model->get_customer_authtoken($headers['Auth']);
if($authRes['status'] == 'error'){
echo json_encode($authRes);exit;
}
$bookData = $this->Webservice_model->getBookedService($authRes['data']['customer_id']);
echo json_encode($bookData);exit;
}
public function add_vehicle_details(){
header('Content-type: application/json');
$headers = apache_request_headers();
$post = file_get_contents("php://input");
$postData = json_decode($post, true);
if(!isset($headers['Auth']) || empty($headers['Auth'])){
$respArr['status'] = '0';
$respArr['message'] = 'Authtoken is Required';
echo json_encode($respArr);exit;
}
$authRes = $this->Webservice_model->get_customer_authtoken($headers['Auth']);
if($authRes['status'] == 'error'){
echo json_encode($authRes);exit;
}
$err = 0;
$msg = '';
if(empty($postData)){
$respArr = array('status'=>0,'error'=>'901','message'=>'All Field is Required');
echo json_encode($respArr);exit;
}
if(!isset($postData['vehicle_year']) || empty($postData['vehicle_year'])){
$err = 1;
$msg = 'Provide a Vehicle year';
}
else if(!isset($postData['vehicle_make']) || empty($postData['vehicle_make'])){
$err = 1;
$msg = 'Provide a Vehicle Make';
}
else if(!isset($postData['vehicle_model']) || empty($postData['vehicle_model'])){
$err = 1;
$msg = 'Provide a Vehicle Model';
}
else if(!isset($postData['engine_no']) || empty($postData['engine_no'])){
$err = 1;
$msg = 'Provide an Engine Number';
}
else if(!isset($postData['vehicle_trim']) && empty($postData['vehicle_trim'])){
$err = 1;
$msg = 'Provide a Vehicle Trim';
}
else if(!isset($postData['mileage']) && empty($postData['mileage'])){
$err = 1;
$msg = 'Provide a Mileage';
}
else if(!isset($postData['car_loc_lat']) && empty($postData['car_loc_lat'])){
$err = 1;
$msg = 'Car Location is Required';
}
else if(!isset($postData['car_loc_lng']) && empty($postData['car_loc_lng'])){
$err = 1;
$msg = 'Car Location is Required';
}
else if(!isset($postData['car_location']) && empty($postData['car_location'])){
$err = 1;
$msg = 'Car Location is Required';
}
if($err == 1){
$respArr['message'] = $msg;
echo json_encode($respArr);exit;
}
$respData = $this->Webservice_model->addVehicleDetails($postData,$authRes['data']['customer_id']);
echo json_encode($respData);exit;
}
public function get_services(){
header('Content-type: application/json');
$headers = apache_request_headers();
$postData = $_GET;
if(!isset($headers['Auth']) || empty($headers['Auth'])){
$respArr['status'] = '0';
$respArr['message'] = 'Authtoken is Required';
echo json_encode($respArr);exit;
}
$authRes = $this->Webservice_model->get_customer_authtoken($headers['Auth']);
if($authRes['status'] == 'error'){
echo json_encode($authRes);exit;
}
$currentpage = 0;
$start = 0;
$per_page = 10;
if(isset($postData['page']) && strlen(trim($postData['page']," ")) > 0 ) {
$currentpage = (int)$postData['page'];
$currentpage = $currentpage==0 ? $currentpage : $currentpage-1;
$start = $currentpage * $per_page;
}
$serviceresult = $this->Webservice_model->get_service_list($postData,0,0);
$serviceList = $this->Webservice_model->get_service_list($postData,$start,$per_page);
$service = array();
$total = 0;
if($serviceresult['status'] == 1){
$total = count($serviceresult['data']);
}
if($total >= $per_page){
$totalPages = (int)($total % $per_page ==0 ? $total / $per_page :($total / $per_page)+1);
}
else{
$totalPages = 1;
}
if($serviceList['status'] == '1'){
$respArr = array('status' => 'success',
'message'=>'success',
'data' => array(
'services' => $serviceList['data']
),
'meta' => array(
'total_pages' => $totalPages,
'total' => $total,
'current_page' => $currentpage+1,
'per_page' => $per_page)
);
}else{
$respArr = array('status' => 'error',
'message'=>'No data',
'data' => array(
'services' => []
),
'meta' => array(
'total_pages' => $totalPages,
'total' => $total,
'current_page' => $currentpage+1,
'per_page' => $per_page)
);
}
echo json_encode($respArr);exit;
}
public function get_vehicle_details(){
header('Content-type: application/json');
$headers = apache_request_headers();
$post = file_get_contents("php://input");
$postData = json_decode($post, true);
if(!isset($headers['Auth']) || empty($headers['Auth'])){
$respArr['status'] = '0';
$respArr['message'] = 'Authtoken is Required';
echo json_encode($respArr);exit;
}
$authRes = $this->Webservice_model->get_customer_authtoken($headers['Auth']);
if($authRes['status'] == 'error'){
echo json_encode($authRes);exit;
}
$respArr = array('status'=>'error','message'=>'Something Went Wrong.');
if(empty($postData)){
echo json_encode($respArr);exit;
}
else if(!isset($postData['bar_code']) && !empty($postData['bar_code'])){
$respArr['message'] = 'Barcode is Required.';
echo json_encode($respArr);exit;
}
$settings = getSettings();
$param = "?format=json&key=".urlencode($settings['vin_audit_api']).
"&vin=".urlencode($postData['bar_code']);
$vehData=file_get_contents("https://specifications.vinaudit.com/getspecifications.php".$param);
if(empty($vehData) || empty($vehData = json_decode($vehData,true))){
echo json_encode($respArr);exit;
}
if(!isset($vehData['success']) || empty($vehData['success']) || $vehData['success'] == false || !isset($vehData['attributes']) || empty($vehData['attributes'])){
$respArr['status'] = 'error';
$respArr['message'] = 'Invalid Vin Number.';
echo json_encode($respArr);exit;
}
$respArr['status'] = 'success';
$respArr['data'] = $vehData['attributes'];
$respArr['message'] = 'Success';
echo json_encode($respArr);exit;
}
public function search_sub_services(){
header('Content-type: application/json');
$headers = apache_request_headers();
$postData = $_GET;
if(!isset($headers['Auth']) || empty($headers['Auth'])){
$respArr['status'] = '0';
$respArr['message'] = 'Authtoken is Required';
echo json_encode($respArr);exit;
}
$authRes = $this->Webservice_model->get_customer_authtoken($headers['Auth']);
if($authRes['status'] == 'error'){
echo json_encode($authRes);exit;
}
$currentpage = 0;
$start = 0;
$per_page = 10;
if(isset($postData['page']) && strlen(trim($postData['page']," ")) > 0 ) {
$currentpage = (int)$postData['page'];
$currentpage = $currentpage==0 ? $currentpage : $currentpage-1;
$start = $currentpage * $per_page;
}
$subserviceresult = $this->Webservice_model->search_sub_services($postData,0,0);
$subserviceList = $this->Webservice_model->search_sub_services($postData,$start,$per_page);
$service = array();
$total = 0;
if($subserviceresult['status'] == 'success'){
$total = count($subserviceresult['data']);
}
if($total >= $per_page){
$totalPages = (int)($total % $per_page ==0 ? $total / $per_page :($total / $per_page)+1);
}
else{
$totalPages = 1;
}
if($subserviceList['status'] == 'success'){
$respArr = array('status' => 'success',
'message'=>'success',
'data' => array(
'sub_services' => $subserviceList['data']
),
'meta' => array(
'total_pages' => $totalPages,
'total' => $total,
'current_page' => $currentpage+1,
'per_page' => $per_page)
);
}else if($subserviceList['status'] == 'error'){
$respArr = array('status' => 'error',
'message'=>'No data',
'data' => array(
'sub_services' => []
),
'meta' => array(
'total_pages' => $totalPages,
'total' => $total,
'current_page' => $currentpage+1,
'per_page' => $per_page)
);
}else{
$respArr = $subserviceList;
$respArr['status'] = 'error';
}
echo json_encode($respArr);exit;
}
public function book_service(){
header('Content-type: application/json');
$headers = apache_request_headers();
$post = file_get_contents("php://input");
$postData = json_decode($post, true);
if(!isset($headers['Auth']) || empty($headers['Auth'])){
$respArr['status'] = '0';
$respArr['message'] = 'Authtoken is Required';
echo json_encode($respArr);exit;
}
$authRes = $this->Webservice_model->get_customer_authtoken($headers['Auth']);
if($authRes['status'] == 'error'){
echo json_encode($authRes);exit;
}
if(empty($postData)){
$respArr = array('status'=>'error','message'=>'All Field is Required');
echo json_encode($respArr);exit;
}
$err = 0;
if(!isset($postData['booking_id']) || empty($postData['booking_id'])){
$err = 1;
$msg = 'Booking Id is Required';
}
else if(!isset($postData['total_cost']) || empty($postData['total_cost'])){
$err = 1;
$msg = 'Total Cost is Required';
}
else if(!isset($postData['mechanic_id']) || empty($postData['mechanic_id'])){
$err = 1;
$msg = 'Mechanic Id is Required';
}
else if(!isset($postData['date']) || empty($postData['date'])){
$err = 1;
$msg = 'Date is Required';
}
else if(!isset($postData['time']) && empty($postData['time'])){
$err = 1;
$msg = 'Time is Required';
}
if($err == 1){
$respArr['message'] = $msg;
echo json_encode($respArr);exit;
}
$respData = $this->Webservice_model->book_service($postData);
echo json_encode($respData);exit;
}
}
?>
application/models/Webservice_model.php
......@@ -9,1635 +9,281 @@
}
public function join_has_driver($request){
$result = array('status' => 'error');
$query = $this->db->where('unique_id', $request['auth'])->get('auth_table');
if(empty($query)){
return $result;
}
if ($query->num_rows() <= 0) {
return $result;
}
$rs = $query->row();
$id = $rs->member_id;
$data = array('users_id' =>$id,
'profile_pic' =>$request['picture'],
'id_proof' =>$request['car_id'],
'car_front' =>$request['car_front'],
'car_back' =>$request['car_back']);
$res = $this->db->insert('drivers',$data);
if($res){
$result = array('status' => 'success');
} else {
$result = array('status' => 'error','message'=>'Already Exist');
}
return $result;
}
public function update_driver_location($request) {
$query = $this->db->where('unique_id', $request['auth'])->get('auth_table');
if ($query->num_rows() > 0) {
$rs = $query->row();
$id = $rs->member_id;
$data = array('driver_lat' => $request['latitude'],
'driver_lng' => $request['longitude']);
$result = $this->db->where('users_id', $id)->update('drivers', $data);
return $result;
} else {
return false;
}
}
public function registration($data) {
$num = $this->db->where('email_id', $data['email'])->get('users')->num_rows();
if($num > 0) {
$result = array('status' => 'error', 'message' => 'Email Already Exists');
}
else {
$unique_id = $this->generate_unique();
$this->db->insert('users', array('first_name' => $data['first_name'],
'surname' => $data['sur_name'],
'email_id' => $data['email'],
'password' => md5($data['password']),
'profile_image' => $data['profile_photo'],
'phone' => $data['phone'],
// 'is_phone_verified' => '1'
));
$user_id = $this->db->insert_id();
$phone_verified = array(
'phone_verified' => '1'
);
$this->db->where('users_id', $user_id);
$this->db->update('user_profile', $phone_verified);
$data2 = "SELECT * FROM users WHERE id = '$user_id'";
$query = $this->db->query($data2);
$rs2 = $query->row();
$data = array('user_id' => $user_id,
'first_name' =>$rs2->first_name,
'sur_name' =>$rs2->surname,
'phone' => $rs2->phone,
'email'=>$rs2->email_id,
'profile_photo'=>$rs2->profile_image);
$this->EncryptedPatientKey($user_id,$unique_id);
if ($user_id) {
$result = array('status' => 'success', 'user_id' => $user_id, 'auth_token' => $unique_id,'user' => $data,);
} else {
$result = array('status' => 'error');
}
}
return $result;
}
public function generate_unique() {
$unqe = md5(uniqid(time().mt_rand(), true));
return $unqe;
}
public function EncryptedPatientKey($user_id,$unique_id) {
$this->db->insert('auth_table', array('member_id' => $user_id, 'unique_id' => $unique_id));
}
public function check_email_availability($data){
$num = $this->db->where('email_id', $data['email'])->get('users')->num_rows();
$email = $data['email'];
if($num > 0){
$result = array('status' => 'success', 'data'=> array('email' => $email, 'is_email_avaliable'=>false));
}
else{
$result = array('status' => 'success', 'data'=> array('email' => $email, 'is_email_avaliable'=>true));
}
return $result;
}
public function check_phone_availability($data){
$num = $this->db->where('phone', $data['phone'])->get('users')->num_rows();
$phone = $data['phone'];
if($num > 0){
$result = array('status' => 'success', 'data'=> array('phone' => $phone, 'is_phone_avaliable'=>false));
}
else{
$result = array('status' => 'success', 'data'=> array('phone' => $phone, 'is_phone_avaliable'=>true));
}
return $result;
}
public function login($request){
$this->db->where('email_id', $request['email']);
$this->db->where('password', md5($request['password']));
$this->db->where('status', 1);
$query = $this->db->select('*')->from('users')->join('user_profile','user_profile.users_id = users.id')->get();
if ($query->num_rows() > 0) {
$unique_id = $this->generate_unique();
$rs = $query->row();
$is_phone_verified = $rs->phone_verified==1?'true':'false';
$is_driver_status = $rs->is_driver;
//$is_phone_verified = $is_phone==1?'true':'false';
$data = array('user_id' => $rs->id,
'first_name' =>$rs->first_name,
'sur_name' =>$rs->surname,
'phone' => $rs->phone,
'email'=>$rs->email_id,
'profile_photo'=>$rs->profile_image,
'is_driver' => $is_driver_status==1?'true':'false',
'is_phone_verified' => $is_phone_verified
);
$this->EncryptedPatientKey($rs->id,$unique_id);
$result = array('status' => 'success', 'auth_token' => $unique_id,'user' => $data);
} else {
$result = array('status' => 'error');
}
return $result;
}
public function forgot_password($data){
$this->db->where('email_id',$data['email']);
$query = $this->db->get('users');
$rs = $query->row();
if ($rs) {
$username = $query->first_name;
$this->load->helper('string');
$rand_pwd = random_string('alnum', 8);
$password = array(
'password' => md5($rand_pwd)
);
$this->db->where('email_id', $data['email']);
$query = $this->db->update('users', $password);
if ($query) {
$this->load->library('email');
$config = Array(
'protocol' => 'smtp',
'smtp_host' => 'mail.techlabz.in',
'smtp_port' => 587,
'smtp_user' => '[email protected]', // change it to yours
'smtp_pass' => 'k4$_a4%eD?Hi', // change it to yours
'smtp_timeout' => 20,
'mailtype' => 'html',
'charset' => 'iso-8859-1',
'wordwrap' => TRUE);
$this->email->initialize($config);
$subject = 'New Mail';
//$this->email->set_newline("\r\n");
$this->email->from('[email protected]', $settings->title);
$this->email->to($data->email);
$this->email->subject("Forget Password");
$this->email->message("New Password is:".$rand_pwd);
$this->email->send();
$rs = $this->email->print_debugger();
return "EmailSend";
}
}
else {
return false;
}
}
public function update_fcm_token($request) {
$query = $this->db->where('unique_id', $request['auth'])->get('auth_table');
if ($query->num_rows() > 0) {
$rs = $query->row();
$id = $rs->member_id;
$data = array('fcm_token' => $request['fcm_token']);
$result = $this->db->where('users_id', $id)->update('user_profile', $data);
return $result;
} else {
return false;
}
}
public function categories(){
$sql = "SELECT id AS category_id,cat_name as category_name,image AS category_image FROM category WHERE status = '1' ";
$query = $this->db->query($sql);
if ($query->num_rows() >= 0) {
$data = $query->result();
$result = array('status' => 'success','user' => $data);
}
else{
$result = array('status' => 'error');
}
return $result;
}
public function get_user_type($request){
$query = $this->db->where('unique_id', $request['auth'])->get('auth_table');
if ($query->num_rows() > 0) {
$rs = $query->row();
$driver_id = $rs->member_id;
$sql = "SELECT is_driver,driver_enabled FROM user_profile WHERE users_id = $driver_id";
$query = $this->db->query($sql);
// echo $this->db->last_query();
// die;
$data = $query->result();
$is_driver = $data[0]->is_driver;
$is_driver_enabled = $data[0]->driver_enabled;
if($is_driver=="1"){
$request['is_driver'] = "true";
}else{
$request['is_driver'] = "false";
}
if($is_driver_enabled=="1"){
$request['is_driver_enabled'] = "true";
}else{
$request['is_driver_enabled'] = "false";
}
$result = array('status' => 'success','data' => $request['is_driver'],'res'=>$request['is_driver_enabled']);
}else{
$result = array('status' => 'error');
}
return $result;
}
public function set_user_type($request){
//pr($request);
$query = $this->db->where('unique_id', $request['auth'])->get('auth_table');
if ($query->num_rows() > 0) {
$rs = $query->row();
$driver_id = $rs->member_id;
$data = array('is_driver'=>$request['is_driver']);
$this->db->where('users_id', $driver_id)->update('user_profile', $data);
$is_driver = $request['is_driver'];
if($is_driver=="1"){
$request['is_driver'] = "true";
}else{
$request['is_driver'] = "false";
}
$result = array('status' => 'success','data' => $request['is_driver']);
}else{
$result = array('status' => 'error');
}
return $result;
}
public function promotions(){
$sql = "SELECT id AS promotion_id,promotion_name,image as promotion_image FROM promotions WHERE status = '1' ";
$query = $this->db->query($sql);
if ($query->num_rows() >= 0) {
$data = $query->result();
// print_r($data);
// exit;
// for($i=0; $i<count($data);$i++)
// {
// $data[$i]->promotion_name = "promotion";
// }
$result = array('status' => 'success','promotions' => $data);
}
else{
$result = array('status' => 'error');
}
return $result;
}
public function popular(){
$sql = "SELECT category.id as popular_id,category.cat_name as popular_name,category.image as popular_image FROM popular JOIN category ON category.id = popular.cat_id WHERE category.status=1 ORDER BY popular.index_no ASC";
$query = $this->db->query($sql);
if ($query->num_rows() >= 0) {
$data = $query->result();
$result = array('status' => 'success','popular' => $data);
}
else{
$result = array('status' => 'error');
}
return $result;
}
public function update_password($request){
$query = $this->db->where('unique_id', $request['auth'])->get('auth_table');
if ($query->num_rows() > 0) {
$rs = $query->row();
$id = $rs->member_id;
$query = $this->db->query("SELECT * FROM users
WHERE id = '".$id."' AND
password ='".md5($request['old_password'])."'");
if(!empty($query)){
$rs = $query->row();
if($query->num_rows() <= 0){
return array('status' => 'error','message' => 'Password mismatch');
}
}
$query = $this->db->update('users', array('password'=>md5($request['new_password'])),
array('id'=>$id));
if($query){
return array('status' => 'success');
}
}
return array('status' => 'error','message' => 'No data');
}
public function update_phone($request){
$query = $this->db->where('unique_id', $request['auth'])->get('auth_table');
if ($query->num_rows() > 0) {
$rs = $query->row();
// print_r($rs);die();
$id = $rs->member_id;
$data = "SELECT * FROM users WHERE id = '$id'";
$query = $this->db->query($data);
$rs = $query->row();
if($query->num_rows() <= 0){
$result = array('status' => 'error','message' => 'No data');
}
else{
$phone = array(
'phone' => $request['phone']
);
$this->db->where('id', $id);
$query = $this->db->update('users', $phone);
$result = array('status' => 'success');
}
}else{
$result = array('status' => 'error','message' => 'No data');
}
return $result;
}
public function notification_update($request){
$query = $this->db->where('unique_id', $request['auth'])->get('auth_table');
if($query->num_rows() > 0){
$rs = $query->row();
$driver_id = $rs->member_id;
$data = array('notification'=>$request['notification_update']);
$this->db->where('id', $driver_id)->update('users', $data);
$result = array('status' => 'success','data' => $request['notification_update'],);
}
else{
$result = array('status' => 'error');
}
return $result;
}
public function get_user_info($request){
$result = array();
$query = $this->db->query("SELECT USR.id,USR.first_name,USR.surname,USR.phone,
USR.profile_image,USR.notification,USR.email_id,DRV.profile_pic,
DRV.earnings,UP.phone_verified,UP.email_verified,UP.driver_enabled,
UP.is_driver,UP.wallet,AP_RATE.rate AS appRate,
DRV_RATE.rate AS drvRate
FROM users AS USR
INNER JOIN auth_table AS AT ON (AT.member_id = USR.id)
INNER JOIN user_profile AS UP ON (UP.users_id = USR.id)
LEFT JOIN drivers AS DRV ON (DRV.users_id = USR.id AND DRV.status = '1')
LEFT JOIN app_rate AS AP_RATE ON (AP_RATE.users_id = USR.id)
LEFT JOIN driver_rate AS DRV_RATE ON (DRV_RATE.users_id = USR.id)
WHERE AT.unique_id = '".$request['auth']."' AND USR.status = '1'
GROUP BY USR.id");
if($query->num_rows() > 0){
$userData = $query->row_array();
$usrOdrCount = $this->db->query("SELECT COUNT(id)
FROM orders
WHERE status = '3' AND users_id = '".$userData."'
GROUP BY users_id");
$drvOdrCount = $this->db->query("SELECT COUNT(id)
FROM orders
WHERE status = '3' AND driver_id = '".$userData."'
GROUP BY status = '3' driver_id");
$usrOdrCount = (!empty($usrOdrCount))?$usrOdrCount->row_array():0;
$drvOdrCount = (!empty($drvOdrCount))?$drvOdrCount->row_array():0;
$userData['user_oder_count'] = (empty($usrOdrCount))?0:$usrOdrCount;
$userData['driver_oder_count'] = (empty($drvOdrCount))?0:$drvOdrCount;
$query = $this->db->select('AVG(NULLIF(rate,0)) as avg_rate')->where('users_id', $userData['id'])->get('user_rate');
if($query->num_rows() > 0){
$res = $query->result();
// pr($res[0]->avg_rate);
$userData['appRate'] = ceil($res[0]->avg_rate);
}
$query1 = $this->db->select('AVG(NULLIF(rate,0)) as avg_rate')->where('driver_id', $userData['id'])->get('driver_rate');
if($query1->num_rows() > 0){
$res = $query1->result();
// pr($res[0]->avg_rate);
$userData['drvRate'] = ceil($res[0]->avg_rate);
}
$respArr = array();
$respArr['is_driver'] = ($userData['is_driver'] == 1)?true:false;
$respArr['is_registered_as_driver'] = ($userData['driver_enabled'] == 1)?true:false;
$respArr['user']['user_id'] = $userData['id'];
$respArr['user']['first_name'] = $userData['first_name'];
$respArr['user']['sur_name'] = $userData['surname'];
$respArr['user']['phone'] = $userData['phone'];
$respArr['user']['email'] = $userData['email_id'];
$respArr['user']['rating'] = $userData['appRate'];
$respArr['user']['total_order'] = $userData['user_oder_count'];
$respArr['user']['wallet'] = $userData['wallet'];
$respArr['user']['notification'] = ($userData['notification'] == 1)?true:false;
$respArr['user']['profile_photo'] = $userData['profile_image'];
$respArr['driver'] = array();
if($userData['driver_enabled']){
$respArr['driver']['user_id'] = $userData['id'];
$respArr['driver']['first_name'] = $userData['first_name'];
$respArr['driver']['sur_name”'] = $userData['surname'];
$respArr['driver']['phone'] = $userData['phone'];
$respArr['driver']['email'] = $userData['email_id'];
$respArr['driver']['rating'] = $userData['drvRate'];
$respArr['driver']['total_order'] = $userData['driver_oder_count'];
$respArr['driver']['wallet'] = $userData['wallet'];
$respArr['driver']['earnings'] = $userData['earnings'];
$respArr['driver']['notification'] = ($userData['notification'] == 1)?true:false;
$respArr['driver']['profile_photo'] = $userData['profile_image'];
}
$result = array('status' => 'success', 'data' => $respArr);
}
else{
$result = array("status" => "error","error" => "No data","message" => "No data");
}
return $result;
}
public function profile_edit_update($request){
$query = $this->db->where('unique_id', $request['auth'])->get('auth_table');
if($query->num_rows() > 0){
$rs = $query->row();
$user_id = $rs->member_id;
$this->db->where('email_id',$request['email']);
$this->db->where('id!=',$user_id);
$res = $this->db->get('users');
if($res->num_rows() == 0){
$data = array('first_name'=>$request['first_name'],
'surname' =>$request['sur_name'],
'email_id' =>$request['email'],
'profile_image'=>$request['profile_photo']);
$this->db->where('id', $user_id)->update('users', $data);
$result = array('status' => 'success');
}else{
$result = array('status' => 'exists');
}
}else{
$result = array('status' => 'error');
}
return $result;
}
public function add_home_work($request){
$query = $this->db->where('unique_id',$request['auth'])->get('auth_table');
if($query->num_rows()>0){
$rs = $query->row();
if($request['type']==0){
$data = array('users_id'=>$rs->member_id,'location'=>$request['home'],'lat'=>$request['home_latitude'],'lng'=>$request['home_longitude'],'type'=>$request['type'],'status'=>'1');
}else{
$data = array('users_id'=>$rs->member_id,'location'=>$request['work'],'lat'=>$request['work_latitude'],'lng'=>$request['work_longitude'],'type'=>$request['type'],'status'=>'1');
}
$this->db->insert('user_address',$data);
return true;
}else{
return false;
}
}
public function location_details($request){
/*****************************************************************************************/
/****************************************Mobile API's*************************************/
$query = $this->db->where('unique_id',$request['auth'])->get('auth_table');
if($query->num_rows()>0){
$rs = $query->row();
$cust_id = $rs->member_id;
$data = "SELECT type,location,lat,lng FROM user_address WHERE users_id='$cust_id' AND status='1'";
$query = $this->db->query($data);
$home = $work = array();
$result = $query->result_array();
if(empty($result)){
return array('status' => 'success', 'data' => array('home' => $home, 'work' => $work));
}
foreach($result AS $address){
if($address['type'] == '0'){
$home[] = array('name' => $address['location'],
'latitude' =>$address['lat'],
'longitude' =>$address['lng']);
}else{
$work[] = array('name' => $address['location'],
'latitude' =>$address['lat'],
'longitude' =>$address['lng']);
}
}
if($result){
$result = array('status' => 'success', 'data' => array('home' => $home, 'work' => $work));
}else{
$result = array('status' => 'error');
}
return $result;
}else{
return false;
}
}
public function user_rating($request){
$query = $this->db->where('unique_id',$request['auth'])->get('auth_table');
if($query->num_rows()>0){
$rs = $query->row();
$cust_id = $rs->member_id;
$data = array('rate'=>$request['rating'],
'orders_id'=>$request['order_id'],
'users_id'=>$request['user_id'],
'driver_id'=>$cust_id);
$res = $this->db->insert('user_rate',$data);
if($res){
$result = array('status' => 'success');
}else{
$result = array('status' => 'error');
}
return $result;
}else{
return false;
}
}
public function driver_rating($request){
$query = $this->db->where('unique_id',$request['auth'])->get('auth_table');
if($query->num_rows()>0){
$rs = $query->row();
$cust_id = $rs->member_id;
$data = array('rate'=>$request['rating'],
'orders_id'=>$request['order_id'],
'driver_id'=>$request['driver_id'],
'users_id'=>$cust_id);
$res = $this->db->insert('driver_rate',$data);
if($res){
$result = array('status' => 'success');
}else{
$result = array('status' => 'error');
}
return $result;
}else{
return false;
}
}
public function app_rating($request){
$query = $this->db->where('unique_id',$request['auth'])->get('auth_table');
if($query->num_rows()>0){
$rs = $query->row();
$cust_id = $rs->member_id;
$data = array('rate'=>$request['rating'],
'comments'=>$request['feedback'],
'users_id'=>$cust_id);
$res = $this->db->insert('app_rate',$data);
if($res){
$result = array('status' => 'success');
}else{
$result = array('status' => 'error');
}
return $result;
}else{
return false;
}
}
function get_last_order($user_data = array()){
$result = array('status' => 'error');
if(empty($user_data)){
return $result;
}
$query = $this->db->where('unique_id',$user_data['auth'])->get('auth_table')->row();
if(empty($query)){
return $result;
}
$user_id = $query->member_id;
$query = $this->db->query("SELECT ODR.* ,DR_RATE.id AS rateId, USR.first_name,
USR.surname,USR.profile_image
FROM orders AS ODR
LEFT JOIN driver_rate AS DR_RATE ON (DR_RATE.orders_id = ODR.id)
INNER JOIN users AS USR ON (USR.id = ODR.driver_id)
WHERE ODR.status = '3' AND ODR.users_id = '".$user_id."'
ORDER BY ODR.id DESC LIMIT 1")->row_array();
if(empty($query)){
$result['message'] = 'No Data';
}
$orderData = array();
$orderData['status'] = 'success';
$orderData['data']['is_last_order_rated'] = (!empty($query['rateId']))?true:false;
$orderData['data']['order_id'] = $query['id'];
$orderData['data']['driver_id'] = $query['driver_id'];
$orderData['data']['driver_name'] = $query['first_name'].' '.$query['surname'];
$orderData['data']['amount'] = $query['amount'];
$orderData['data']['date'] = strtotime($query['date'].' '.$query['time']);
$orderData['data']['shop_name'] = $query['shop_name'];
$orderData['data']['driver_photo'] = $query['profile_image'];
$orderData['data']['item_name'] = $query['order_desc'];
$orderData['data']['item_quantity'] = '';
return $orderData;
}
function get_last_order_driver($user_data = array()){
$result = array('status' => 'error');
if(empty($user_data)){
return $result;
}
$query = $this->db->where('unique_id',$user_data['auth'])->get('auth_table')->row();
if(empty($query)){
return $result;
}
$user_id = $query->member_id;
$query = $this->db->query("SELECT ODR.* ,DR_RATE.id AS rateId, USR.first_name,
USR.surname,USR.profile_image
FROM orders AS ODR
LEFT JOIN driver_rate AS DR_RATE ON (DR_RATE.orders_id = ODR.id)
INNER JOIN users AS USR ON (USR.id = ODR.users_id)
WHERE ODR.status = '3' AND ODR.driver_id = '".$user_id."'
ORDER BY ODR.id DESC LIMIT 1")->row_array();
if(empty($query)){
$result['message'] = 'No Data';
}
$orderData = array();
$orderData['status'] = 'success';
$orderData['data']['is_last_order_rated'] = (!empty($query['rateId']))?true:false;
$orderData['data']['order_id'] = $query['id'];
$orderData['data']['driver_id'] = $query['driver_id'];
$orderData['data']['driver_name'] = $query['first_name'].' '.$query['surname'];
$orderData['data']['amount'] = $query['amount'];
$orderData['data']['date'] = strtotime($query['date'].' '.$query['time']);
$orderData['data']['shop_name'] = $query['shop_name'];
$orderData['data']['driver_photo'] = $query['profile_image'];
$orderData['data']['item_name'] = $query['order_desc'];
$orderData['data']['item_quantity'] = '';
return $orderData;
}
public function request_cancel($request = array()){
if(empty($request) || !isset($request['id'],$request['auth']) || empty($request['id']) || empty($request['auth'])){
return array('status'=>'error','message'=>'No data');
}
$user_id = $this->getUserId($request['auth']);
if(empty($user_id)){
return array('status'=>'error');
}
$query1 = $this->db->where('id',$request['id'])->get('orders')->row();
$request_id = $query1->req_id;
$update_request_status = $this->db->update('request',array('status'=>'2'),array('id'=>$request_id));
$query = $this->db->update('orders',array('status'=>'3'), array('id'=>$request['id']));
// $query = $this->db->update('request',array('status'=>'2'), array('id'=>$request['id']));
if ($query) {
return array('status' => 'success','message' => 'Successfully Cancelled..!!');
}
return array('status'=>'error');
}
public function request_status($request = array()){
if(empty($request) || !isset($request['id'],$request['auth']) || empty($request['id']) || empty($request['auth'])){
return array('status'=>'error','message'=>'No data');
}
$user_id = $this->getUserId($request['auth']);
if(empty($user_id)){
return array('status'=>'error');
}
$query = $this->db->query("SELECT ODR.delivery_fee,ODR.id,REQ.status
FROM request AS REQ
LEFT JOIN orders AS ODR ON (ODR.req_id = REQ.id)
WHERE REQ.id = '".$request['id']."'")->row_array();
if (empty($query)) {
return array('status' => 'error','message');
}
$status = $query['status'];
switch($status){
case 0:
return array("status"=>"success","data"=>array("request_status"=>"0"));
case 1:
return array("status"=>"success",
"data"=>array("request_status"=>"1",
"delivery_fee"=>$query['delivery_fee'],
"order_id"=>$query['id']));
case 2:
return array("status"=>"success","data"=>array("request_status"=>"2"));
}
}
function tracking_details($request = array()){
if(empty($request) || !isset($request['order_id'],$request['auth']) || empty($request['order_id']) || empty($request['auth'])){
return array('status'=>'error','message'=>'No data');
}
$user_id = $this->getUserId($request['auth']);
if(empty($user_id)){
return array('status'=>'error');
public function checkMobAvailability($data = array()){
$res = array('status'=>'success', 'message'=>'Mobile Number Available');
if(empty($data)){
$res = array('status'=>'error','error'=>'901','message'=>'Something went wrong.');
return $res;
}
$data = $this->db->query("SELECT ODR.*,ODR.delivery_lat AS lat,ODR.delivery_lng AS lng,
DRV.profile_pic,USR.phone,DRV.driver_lat,DRV.driver_lng
FROM orders AS ODR
INNER JOIN users AS USR ON (USR.id = ODR.driver_id)
INNER JOIN drivers AS DRV ON (DRV.users_id = ODR.driver_id)
WHERE ODR.id='".$request['order_id']."' AND USR.status = '1' AND DRV.status = '1'")->row_array();
if(!empty($data)){
return array('status'=>'success','orderData'=>$data);
}
return array('status'=>'error');
}
$result = $this->db->get_where('customers',array('phone'=>$data['phone']));
function getUserId($auth = ''){
if(empty($auth)){
return;
}
$query = $this->db->where('unique_id',$auth)->get('auth_table')->row();
if(empty($query)){
return;
if(!empty($result) && $result->num_rows() > 0){
$res=array('status'=>'error','error'=>'902','message'=>'Mobile number already in use.');
}
return $query->member_id;
}
function geySysSettings(){
$data = $this->db->get('setting')->row();
if(!empty($data)){
return $data;
return $res;
}
return 0;
}
function orders_list($request = array()){
$data = $this->geySysSettings();
$google_key = $data->google_api_key;
if(empty($request) || !isset($request['auth']) || empty($request['auth'])){
return array('status'=>'error','message'=>'No data');
function checkCustomerLogin($userLogData){
$respArr = array('status'=>0);
if(empty($userLogData)){
return $returnStatus;
}
$user_id = $this->getUserId($request['auth']);
if(empty($user_id)){
return array('status'=>'error');
}
$isDriver = $this->db->select('is_driver')->where(array('users_id'=>$user_id))->get('user_profile')->row_array();
$isDriver = (!empty($isDriver) && isset($isDriver['is_driver']))?$isDriver['is_driver']:'0';
$limit_offset = '10';
$page_no = (isset($request['page_no']) && !empty($request['page_no']))?$request['page_no']:1;
if($page_no != 1){
$limit_offset = ($page_no-1).'0,10';
$result = $this->db->get_where('customers',array('email'=>$userLogData['email'],'status'=>'1'));
if(empty($result) || $result->num_rows() < 1 || empty($custData = $result->row())){
$respArr['status'] = 2;
return $respArr;
}
$count = '';
$query = '';
if($isDriver == '0'){
$count = $this->db->get_where('orders',array('users_id'=>$user_id));
$count = (!empty($count))?$count->num_rows():0;
$query = $this->db->query("SELECT ODR.*,USR.first_name,USR.surname,USR.profile_image
FROM orders AS ODR
INNER JOIN users AS USR ON (USR.id = ODR.users_id)
WHERE ODR.users_id='".$user_id."' AND USR.status = '1' ORDER BY ODR.id DESC
LIMIT ".$limit_offset)->result_array();
} else {
$count = $this->db->get_where('orders',array('driver_id'=>$user_id));
$count = (!empty($count))?$count->num_rows():0;
$this->db->select("customer_id as id,is_otp_verified,phone as phone_number,TRIM(CONCAT(first_name,' ' ,IFNULL(last_name,''))) as user_name");
$result = $this->db->get_where('customers',array('email'=>$userLogData['email'],
'password'=>$userLogData['password'],
'status'=>'1'));
$respArr['status'] = 3;
if(!empty($result) && $result->num_rows() == 1 && !empty($custData = $result->row())){
$query = $this->db->query("SELECT ODR.*,USR.first_name,USR.surname,DRV.profile_pic AS profile_image
FROM orders AS ODR
INNER JOIN users AS USR ON (USR.id = ODR.driver_id)
INNER JOIN drivers AS DRV ON (DRV.users_id = ODR.driver_id)
WHERE ODR.driver_id='".$user_id."' AND USR.status = '1' AND DRV.status = '1'
ORDER BY ODR.id DESC LIMIT ".$limit_offset)->result_array();
$authdata = $this->insert_auth($custData->id);
if($authdata){
$custData->auth_token = $authdata;
}
$orderData = array();
foreach($query AS $order){
$shopData = file_get_contents("https://maps.googleapis.com/maps/api/geocode/json?place_id=".$order['shop_id']."&key=".$google_key);
if(empty($shopData)){
continue;
}
switch ($order['status']) {
case '1':
$order['status'] = '2';
break;
case '2':
$order['status'] = '3';
break;
case '3':
$order['status'] = '4';
break;
}
$shopData = json_decode($shopData,true);
$details['order_id'] = $order['id'];
$details['type'] = $isDriver;
$details['name'] = $order['first_name'].' '.$order['surname'];
$details['amount'] = $order['price'];
$details['delivery_mode'] = $order['delivery_mode'];
$details['date'] = strtotime($order['date'].' '.$order['time']);
$details['shop_name'] = $order['shop_name'];
$details['address'] = $shopData['results'][0]['formatted_address'];
$details['shop_subname'] = $order['shop_name'];
$details['photo'] = $order['profile_image'];
$details['order_status'] = $order['status'];
$details['receipt_amount'] = $order['receipt_amount'];
$details['total_amount'] = $order['amount'];
$details['delivery_charge'] = $order['delivery_fee'];
$details['item_name'] = $order['order_desc'];
$orderData[] = $details;
$respArr['data'] = $custData;
$respArr['status'] = 1;
return $respArr;
}
$tot_page = ceil($count/10);
return array('status'=>'success','data'=>array('orders_list'=>$orderData),'meta'=>array('total_pages'=>$tot_page,'total'=>$count,'current_page'=>$page_no,'per_page'=>'10'));
}
function issuing_receipt($request = array()){
if(empty($request) || !isset($request['auth']) || empty($request['auth'])){
return array('status'=>'error','message'=>'No data');
function insert_auth($id){
$static_string = time();
$authToken = 'Dcarfixs'.sha1($static_string);
$custData = $this->db->get_where('authtable',array('customer_id'=>$id));
if(!empty($custData) && $custData->num_rows() > 0){
$this->db->delete('authtable',array('customer_id'=>$id));
}
$user_id = $this->getUserId($request['auth']);
if(empty($user_id)){
return array('status'=>'error');
$this->db->insert('authtable',array('customer_id'=>$id,'authtoken'=>$authToken));
return $authToken;
}
$status = $this->db->update('orders', array('price'=>$request['receipt_amount'],'amount'=>$request['total_amount'],'delivery_fee'=>$request['delivery_fee'],'receipt_photo'=>$request['receipt_photo'],), array('id'=>$request['order_id']));
if($status){
return array('status'=>'success');
}
return array('status'=>'error');
}
function createCustomer($customer_data = array()){
$respArr = array('status'=>0);
function request_order($request = array()){
if(empty($request) || !isset($request['auth']) || empty($request['auth'])){
return array('status'=>'error','message'=>'No data');
if(empty($customer_data)){
$respArr['status'] = 0;
return $respArr;
}
$user_id = $this->getUserId($request['auth']);
if(empty($user_id)){
return array('status'=>'error');
}
$status = $this->db->insert('request',array('users_id'=>$user_id,'delivery_location'=>$request['location_name'],'delivery_lat'=>$request['delivery_latitude'],'delivery_lng'=>$request['delivery_longitude'],'shop_id'=>$request['shop_id'],'shop_name'=>$request['shop_name'],'item_name'=>$request['item_name'],'date'=>date('Y-m-d'),'time'=>date('h:i:s'),'delivery_mode'=>$request['delivery_mode'],'status'=>'0'));
$requested_id = $this->db->insert_id();
$order = $this->db->insert('orders',array('users_id'=>$user_id,'req_id'=>$requested_id,'delivery_location'=>$request['location_name'],'delivery_lat'=>$request['delivery_latitude'],'delivery_lng'=>$request['delivery_longitude'],'shop_id'=>$request['shop_id'],'shop_name'=>$request['shop_name'],'item_name'=>$request['item_name'],'date'=>date('Y-m-d'),'time'=>date('h:i:s'),'delivery_mode'=>$request['delivery_mode'],'status'=>'0'));
if($status){
return array('status'=>'success');
if(isset($customer_data['email']) && !empty($customer_data['email'])){
$emailChk = $this->db->get_where('customers',array('email'=>$customer_data['email'],'status !='=>'2'));
if(!empty($emailChk) && $emailChk->num_rows() > 0){
$respArr['status'] = 2;
return $respArr;
}
return array('status'=>'error');
}
public function chat_file_upload($request){
$query = $this->db->where('unique_id', $request['auth'])->get('auth_table');
if ($query->num_rows() > 0) {
$rs = $query->row();
$id = $rs->member_id;
$data = array('chat_list_id' => $request['chat_list_id'],
'chat_id' => $request['chat_id'],
'type' => $request['type'],
'file' => $request['doc']);
$this->db->insert('chat_history',$data);
$result = array('status' => 'success','data'=>array('chat_list_id'=>$request['chat_list_id'],'chat_id'=>$request['chat_id'],'file'=>$request['doc']));
} else{
$result = array('status' => 'error');
}
return $result;
}
function set_user_recent_chat($request = array()){
if(empty($request) || !isset($request['auth']) || empty($request['auth'])){
return array('status'=>'error','message'=>'No data');
}
$user_id = $this->getUserId($request['auth']);
if(empty($user_id)){
return array('status'=>'error');
if(isset($customer_data['phone']) && !empty($customer_data['phone'])){
$phoneChk = $this->db->get_where('customers',array('phone'=>$customer_data['phone'],'status !='=>'2'));
if(!empty($phoneChk) && $phoneChk->num_rows() > 0){
$respArr['status'] = 3;
return $respArr;
}
$status = $this->db->insert('chat',array('chat_list_id'=>$request['chat_list_id'],'user_id'=>$request['user_id'],'driver_id'=>$request['driver_id'],'sender_id'=>$request['sender_id'],'type'=>$request['type'],'message'=>$request['message'],'photo_url'=>$request['photo_url'],'video_url'=>$request['video_url'],'order_id'=>$request['order_id'],'time'=>$request['time']));
if($status){
return array('status'=>'success');
}
return array('status'=>'error');
}
function request_trigger(){
$data = $this->geySysSettings();
$google_key = $data->google_api_key;
$customer_data['first_name'] = $customer_data['name'];
unset($customer_data['name']);
$newTime = date("Y-m-d H:i:s",strtotime(date("Y-m-d H:i:s")." -1 minutes"));
if($this->db->insert('customers',$customer_data)){
$sql = "SELECT REQ.id FROM request AS REQ
LEFT JOIN rider_state AS RS ON (RS.req_id = REQ.id AND RS.assigned_time <= '".$newTime."')
WHERE REQ.status IN (0,2,3)";
$last_id = $this->db->insert_id();
$this->db->select("TRIM(CONCAT(first_name,' ' ,IFNULL(last_name,''))) as name,customer_id as user_id");
$custData = $this->db->get_where('customers',array('customer_id'=>$last_id))->row();
$data = $this->db->query($sql);
if(empty($data)){
return;
}
$data = $data->result_array();
$authdata = $this->insert_auth($last_id);
foreach($data as $id){
$reqData = $this->db->query("SELECT REQ.shop_id,GROUP_CONCAT(RS.driver_id) AS driver_id,
REQ.users_id
FROM request AS REQ
LEFT JOIN rider_state AS RS ON (RS.req_id = REQ.id)
WHERE REQ.id = '".$id['id']."'")->row_array();
$custData->auth_token = $authdata;
if(empty($reqData) || empty($reqData['shop_id'])){
continue;
$respArr['data'] = $custData;
$respArr['status'] = 1;
}
$shopData = file_get_contents("https://maps.googleapis.com/maps/api/geocode/json?place_id=".$reqData['shop_id']."&key=".$google_key);
if(empty($shopData)){
continue;
}
$shopData = json_decode($shopData,true);
$shopLoc = $shopData['results'][0]['geometry']['location'];
$user_id = (!empty($reqData['users_id']))?$reqData['users_id']:'';
$drvCond = (!empty($reqData['driver_id']))?' AND driver.users_id NOT IN ('.$reqData['driver_id'].','.$user_id.')':' AND driver.users_id NOT IN ('.$user_id.')';
$lat = $shopLoc['lat'];
$lng = $shopLoc['lng'];
$rideData = $this->db->query("SELECT driver.users_id, 3956 * 2 * ASIN(SQRT(POWER(SIN(($lat - driver.driver_lat) * pi()/180 / 2), 2)+ COS($lat * pi()/180 ) * COS(driver.driver_lat * pi()/180)* POWER(SIN(($lng - driver.driver_lng) * pi()/180 / 2), 2) )) as distance, UP.fcm_token AS fcm_token
FROM drivers AS driver
LEFT JOIN user_profile AS UP ON (UP.users_id = driver.users_id)
WHERE driver.status = '1' AND UP.driver_enabled = '1' AND
UP.is_driver = '1' $drvCond
GROUP BY driver.users_id HAVING distance < 25
ORDER BY distance ASC LIMIT 0,1")->row_array();
if(empty($rideData) || !isset($rideData['users_id']) || empty($rideData['users_id'])){
continue;
return $respArr;
}
$this->db->insert('rider_state', array('driver_id'=>$rideData['users_id'],'req_id'=>$id['id'],
'assigned_time'=>date('Y-m-d h:i:s')));
$fcm_data = array('id'=>$id['id'],'title'=>'WAAW','message'=>'Delivery Request');
$this->push_sent_cancel($rideData['fcm_token'], $fcm_data);
}
return;
}
public function get_customer_authtoken($auth = ''){
$respArr = array('status'=>0,'error'=>'901','message'=>'Something Went Wrong.');
function get_recent_chat_list($request = array()){
if(empty($request) || !isset($request['auth']) || empty($request['auth'])){
return array('status'=>'error','message'=>'No data');
}
$user_id = $this->getUserId($request['auth']);
if(empty($user_id)){
return array('status'=>'error');
}
$limit_offset = '10';
$page_no = (isset($request['page']) && !empty($request['page']))?$request['page']:1;
if($page_no != 1){
$limit_offset = ($page_no-1).'0,10';
}
// $resultData = $this->db->query("
// SELECT CH.*, ORD.status AS order_status FROM chat AS CH
// LEFT JOIN orders AS ORD ON (ORD.id = CH.order_id)
// WHERE CH.user_id = '".$user_id."' LIMIT ".$limit_offset)->result_array();
$resultData = $this->db->query("
SELECT CH.*, ORD.status AS order_status FROM chat AS CH
INNER JOIN orders AS ORD ON (ORD.id = CH.order_id)
WHERE ORD.status IN (1)
LIMIT ".$limit_offset)->result_array();
$chatData = array();
$user_data = array();
$chkUserData = 0;
foreach($resultData AS $data){
if($chkUserData == 0){
$user = $this->db->get_where('users',array('id'=>$data['user_id']))->row_array();
if(empty($user)){
continue;
if(empty($auth)){
return $respArr;
}
$user_data['user_name'] = $user['first_name'].' '.$user['surname'];
$user_data['user_photo'] = $user['profile_image'];
$user = $this->db->query("SELECT DRV.profile_pic,USR.first_name,USR.surname
FROM users AS USR
INNER JOIN drivers AS DRV ON (DRV.users_id = USR.id)
WHERE USR.id='".$data['driver_id']."'")->row_array();
if(empty($user)){
continue;
}
$user_data['driver_name'] = $user['first_name'].' '.$user['surname'];
$user_data['driver_photo'] = $user['profile_pic'];
$chkUserData = 1;
$auth = $this->db->get_where('authtable',array('authtoken'=>$auth));
if(!empty($auth) && $auth->num_rows() >= 1 && !empty($custAuth = $auth->row_array())){
$respArr['status'] = 'success';
$respArr['data'] = $custAuth;
}else{
$respArr['status'] = 'error';
$respArr['error'] = '902';
$respArr['message'] = 'Authtoken is not Valid';
}
$chatData['type'] = $data['type'];
$chatData['time'] = $data['time'];
$chatData['chat_id'] = $data['chat_id'];
$chatData['user_id'] = $data['user_id'];
$chatData['order_id'] = $data['order_id'];
$chatData['driver_id'] = $data['driver_id'];
$chatData['message'] = $data['message'];
$chatData['photo_url'] = $data['photo_url'];
$chatData['video_url'] = $data['video_url'];
$chatData['sender_id'] = $data['sender_id'];
$chatData['order_status'] = $data['order_status'];
$chatData['user_name'] = $user_data['user_name'];
$chatData['user_photo'] = $user_data['user_photo'];
$chatData['driver_name'] = $user_data['driver_name'];
$chatData['driver_photo'] = $user_data['driver_photo'];
return $respArr;
}
return array("status"=>"success","data"=>array('recent_chats'=>array($chatData)));
}
public function request_details($request){
$data = $this->geySysSettings();
$google_key = $data->google_api_key;
public function getBookedService($id = ''){
$respArr = array('status'=>'error','message'=>'Something Went Wrong.');
$rs2 = $this->db->query("SELECT REQ_TB.* ,USERS_TB.id AS userid, USERS_TB.profile_image AS user_photo,USERS_TB.first_name,USERS_TB.surname, USERS_TB.phone AS user_phone_number
FROM request AS REQ_TB
JOIN users AS USERS_TB ON (USERS_TB.id = REQ_TB.users_id)
WHERE REQ_TB.id = '".$request['request_id']."'")->row();
if(!empty($rs2)){
$shopData = file_get_contents("https://maps.googleapis.com/maps/api/geocode/json?place_id=".$rs2->shop_id."&key=".$google_key);
if(empty($shopData)){
return array('status'=>'error');
if(empty($id)){
return $respArr;
}
$shopData = json_decode($shopData,true);
// print_r($shopData);
// die();
$shopLoc = $shopData['results'][0]['geometry']['location'];
$shopAddress = $shopData['results'][0]['formatted_address'];
$milliseconds = round(microtime(true) * 1000);
$this->db->select('booking_id as id,scheduled_date as date,scheduled_time as time');
$bookData = $this->db->get_where('bookings',array('customer_id'=>$id))->result_array();
$data = array('request_id' => $rs2->id,
'shop_name' =>$rs2->shop_name,
'shop_address'=>$shopAddress,
'user_phone_number' =>$rs2->user_phone_number,
'user_photo' => $rs2->user_photo,
'shop_latitude' =>$shopLoc['lat'],
'shop_longitude' =>$lng = $shopLoc['lng'],
'delivery_latitude'=>$rs2->delivery_lat,
'delivery_longitude'=>$rs2->delivery_lng,
'request_time' => $milliseconds,
'user_id' => $rs2->users_id,
'user_name' => $rs2->first_name.' '.$rs2->surname);
$result = array('status' => 'success','user' => $data);
}
else{
$result = array('status' => 'error');
if(!empty($bookData) && (count($bookData) > 0)){
$respArr['status'] = 'success';
$respArr['data'] = $bookData;
$respArr['message'] = 'success';
}
return $result;
return $respArr;
}
public function order_status($request){
$data = $this->geySysSettings();
$google_key = $data->google_api_key;
$rs = $this->db->query("SELECT * FROM orders
WHERE id = '".$request['order_id']."'")->row();
public function addVehicleDetails($postData = array(),$customer_id = ''){
$respArr = array('status'=>'error','message'=>'Something Went Wrong.');
if(!empty($rs)){
$shopData = file_get_contents("https://maps.googleapis.com/maps/api/geocode/json?place_id=".$rs->shop_id."&key=".$google_key);
if(empty($shopData)){
return array('status'=>'error');
if(empty($postData)){
return $respArr;
}
$shopData = json_decode($shopData,true);
$shopAddress = $shopData['results'][0]['formatted_address'];
$data = array('order_status' => $rs->status,
'item_name' => $rs->item_name,
'amount' => $rs->amount,
'address'=>$shopAddress,
$car_name = $postData['vehicle_year'].' '.$postData['vehicle_make'].' '.$postData['vehicle_model'];
$vehJson = array('vehicle' => $car_name,
'attributes' =>
array(
'Year' => $postData['vehicle_year'],
'Make' => $postData['vehicle_make'],
'Trim' => $postData['vehicle_trim'],
'Model' => $postData['vehicle_model'],
'Engine' => $postData['engine_no'])
);
$result = array('status' => 'success','user' => $data);
}
else{
$result = array('status' => 'error');
}
return $result;
}
public function confirm_delivery($request){
$query = $this->db->where('unique_id', $request['auth'])->get('auth_table');
if ($query->num_rows() > 0) {
$rs = $query->row();
$insert_array = array('customer_id' => $customer_id,
'car_name' => $car_name,
'car_model' => $postData['vehicle_model'],
'car_maker' => $postData['vehicle_make'],
'car_loc_lat' => $postData['car_loc_lat'],
'car_loc_lng' => $postData['car_loc_lng'],
'car_location' => $postData['car_location'],
'vehicle_data' => json_encode($vehJson),
'car_model_year'=> $postData['vehicle_year'],
'status' => '3');
$id = $rs->member_id;
if($this->db->insert('customer_vehicle',$insert_array)){
$last_id = $this->db->insert_id();
$rs = $this->db->query("SELECT receipt_photo FROM orders
WHERE id = '".$request['order_id']."'")->row();
$book_data = array(
'mileage' => $postData['mileage'],
'customer_id' => $customer_id,
'customer_veh_id' => $last_id,
'status' => '5');
if($rs->receipt_photo != ''){
if($this->db->insert('bookings',$book_data)){
$book_id = $this->db->insert_id();
$data = array('status' => '2');
$this->db->where('users_id', $id);
$this->db->where('id', $request['order_id']);
$query = $this->db->update('orders', $data);
$result = array('status' => 'success');
return $result;
$respArr['status'] = 'success';
$respArr['message'] = 'success';
$respArr['data']['booking_id'] = $book_id;
return $respArr;
}
else{
$result = array('status' => 'error','message' => 'Please upload the receipt_photo');
return $result;
}
} else {
$result = array('status' => 'error','message' => 'Insufficient data');
return $result;
}
return $respArr;
}
public function order_accept_reject($request){
$order_status = $request['type'];
$order_id = $request['request_id'];
$query = $this->db->where('unique_id', $request['auth'])->get('auth_table');
if ($query->num_rows() > 0) {
$rs = $query->row();
$id = $rs->member_id;
$data1 = "SELECT id FROM orders WHERE req_id = $order_id";
$query1 = $this->db->query($data1);
$rs = $query1->row();
$ord_id = $rs->id;
if($order_status==0)
{
$data = array('status' => '1');
$data1 = array('driver_id' => $id,
'status' => '1'
);
$this->db->where('id', $request['request_id']);
$query = $this->db->update('request', $data);
// echo $this->db->last_query();
// die();
$this->db->where('req_id', $request['request_id']);
$query = $this->db->update('orders', $data1);
$result = array('status' => 'success','data'=> $ord_id);
$fcm_data = array('id'=>$order_id,'title'=>'WAAW','message'=>'Request Accepted');
public function get_service_list($postData = '',$start,$per_page){
$this->push_sent_cancel($rideData['fcm_token'], $fcm_data);
return $result;
$respArr = array('status'=>'error','message'=>'Something Went Wrong.');
$this->db->select("issue_id as id,issue as service_name,IF(issue_image != NULL OR issue_image != '' , concat('".base_url()."',issue_image) , '') as icon");
if(!empty($postData['query'])){
$where = "issue LIKE '".$postData['query']."%'";
$this->db->where($where);
}
if($order_status==1)
{
$data = array('status' => '2');
$this->db->where('id', $request['request_id']);
$query = $this->db->update('request', $data);
$result = array('status' => 'success','data'=> $ord_id);
$fcm_data = array('id'=>$order_id,'title'=>'WAAW','message'=>'Request Rejected');
$this->push_sent_cancel($rideData['fcm_token'], $fcm_data);
return $result;
$this->db->where('status','1');
if($start != 0 || $per_page != 0){
$this->db->limit($per_page,$start);
}
$service = $this->db->get('issues');
} else {
$result = array('status' => 'error');
return $result;
if(!empty($service) && !empty($serviceData = $service->result_array())){
$respArr['status'] = 'success';
$respArr['message'] = 'success';
$respArr['data']= $serviceData;
}
return $respArr;
}
function push_sent_cancel($fcm_token, $fcm_data) {
$data1 = "SELECT * FROM setting WHERE id = '1' ";
$query1 = $this->db->query($data1);
$rs = $query1->row();
$key = $rs->api_key;
$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['id']."\", \"trip_status\" : 0}}}, \"collapse_key\" : \"trip\", \"priority\":\"high\", \"to\" : \"".$fcm_token."\"}";
$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);
public function search_sub_services($postData = '',$start,$per_page){
curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
$respArr = array('status'=>'error','message'=>'Something Went Wrong.');
// curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
// curl_close($ch);
$out = curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_exec($ch);
curl_close($ch);
}
public function search($request){
$data = $this->geySysSettings();
$google_key = $data->google_api_key;
if(!isset($request['type']) || empty($request['type']) || !isset($request['latitude']) || empty($request['latitude']) || !isset($request['longitude']) || empty($request['longitude'])){
return array('status'=>'error');
}
if(isset($request['page_token']) && !empty($request['page_token'])){
$urlParams = '&pagetoken='.$request['page_token'];
} else {
$urlParams = "&location=".$request['latitude'].",".$request['longitude'];
$urlParams.= "&rankby=distance";
$urlParams.= "&type=".str_replace(',','|',trim($request['type']));
if(isset($request['query']) && !empty($request['query'])){
$urlParams.= "&keyword=".str_replace(',','|',trim($request['query']));
if(!isset($postData['service_id']) && empty($postData['service_id'])){
$respArr['status'] = 1;
$respArr['message'] = 'Service Id is Required';
return $respArr;
}
}
$searchData = file_get_contents("https://maps.googleapis.com/maps/api/place/nearbysearch/json?key=".$google_key.$urlParams);
if(empty($searchData)){
return array('status'=>'error');
$this->db->select("issue_cat_id as id,issue_category as sub_service_name,IF(issue_cat_image != NULL OR issue_cat_image != '' , concat('".base_url()."',issue_cat_image) , '') as icon");
if(!empty($postData['query'])){
$where = "issue_category LIKE '".$postData['query']."%'";
$this->db->where($where);
}
$searchData = json_decode($searchData,true);
if(empty($searchData) || $searchData['status']!='OK'){
return array('status'=>'error');
if($start != 0 || $per_page != 0){
$this->db->limit($per_page,$start);
}
$subservice = $this->db->get_where('issues_category',array('status'=>'1','issue_id'=>$postData['service_id']));
$deStores = array();
$resultData = $this->db->query("SELECT place_id FROM delisted_stores WHERE status = '1'");
if(!empty($resultData)){
$resultData = $resultData->result_array();
foreach ($resultData AS $place_id) {
$deStores[] = $place_id['place_id'];
if(!empty($subservice) && !empty($subserviceData = $subservice->result_array())){
$respArr['status'] = 'success';
$respArr['message'] = 'success';
$respArr['data']= $subserviceData;
}
return $respArr;
}
$i = 0;
$placelist = array();
public function book_service($postData){
$respArr = array('status'=>'error','message'=>'Something Went Wrong.');
$page_token = $searchData['next_page_token'];
$searchData = $searchData['results'];
foreach ($searchData AS $shopinfo) {
if(!isset($shopinfo['place_id']) || empty($shopinfo['place_id']) || (!empty($deStores) && in_array($shopinfo['place_id'],$deStores))){
continue;
if(empty($postData)){
$respArr['message'] = 'All Field is required';
return $respArr;
}
$shopLoc = $shopinfo['geometry']['location'];
$lat = $shopLoc['lat'];
$lng = $shopLoc['lng'];
$shopLoc = $shopinfo['geometry']['location'];
$insert_array = array('cost'=>$postData['total_cost'],'mechanic_id'=>$postData['mechanic_id'],'scheduled_date'=>$postData['date'],'scheduled_time'=>$postData['time']);
if( isset($shopinfo['opening_hour']) || isset($shopinfo['opening_hour']['open_now'])||($shopinfo['opening_hours']['open_now'] == 1) && isset($shopinfo['opening_hours']['open_now']))
$open_hotel = "true";
else
$open_hotel = "false";
if($this->db->update('bookings',$insert_array,array('booking_id'=>$postData['booking_id']))){
$this->db->select("bookings.scheduled_time,bookings.scheduled_date,customer_vehicle.car_model as vehicle_model,customer_vehicle.car_maker as vehicle_make,customer_vehicle.car_model_year as vehicle_year,customer_vehicle.vehicle_data,TRIM(concat(mechanic.first_name,' ',IFNULL(mechanic.last_name,''))) as mechanic_name,mechanic_shop.shop_name as mechanic_shop,mechanic.address,mechanic.phone,admin_users.profile_image as image,bookings.mileage,bookings.issues_selected");
$this->db->join('customer_vehicle','customer_vehicle.customer_veh_id = bookings.customer_veh_id');
$this->db->join('mechanic','bookings.mechanic_id = mechanic.mechanic_id');
$this->db->join('admin_users','admin_users.id = mechanic.mechanic_id');
$this->db->join('mechanic_shop','mechanic_shop.shop_id = mechanic.shop_id','left');
$mech_data = $this->db->get_where('bookings',array('booking_id'=>$postData['booking_id']));
$placelist[$i]['place_id'] = (isset($shopinfo['place_id']))?$shopinfo['place_id']:"null";
$placelist[$i]['name'] = (isset($shopinfo['name']))?$shopinfo['name']:"null";
$placelist[$i]['image'] = (isset($shopinfo['icon']))?$shopinfo['icon']:"null";
$placelist[$i]['rating'] = (isset($shopinfo['rating']))?$shopinfo['rating']:"null";
$placelist[$i]['latitude'] = (isset($lat))?$lat:"null";
$placelist[$i]['longitude'] = (isset($lng))?$lng:"null";
$placelist[$i]['is_opened'] = (isset($open_hotel))?$open_hotel:"null";
$placelist[$i]['address'] = (isset($shopinfo['vicinity']))?$shopinfo['vicinity']:"null";
if(!empty($mech_data) && !empty($mechanic_data = $mech_data->row_array())){
$i++;
$mech_veh_data = json_decode($mechanic_data['vehicle_data']);
$mechanic_data['engine_no'] = $mech_veh_data->attributes->Engine;
$mechanic_data['vehicle_trim'] = $mech_veh_data->attributes->Trim;
unset($mechanic_data['vehicle_data']);
$mechanic_data['services'] = json_decode($mechanic_data['issues_selected']);
unset($mechanic_data['issues_selected']);
$respArr['status'] = 'success';
$respArr['message'] = 'success';
$respArr['data'] = $mechanic_data;
}
$result = array('status' => 'success','data' =>array('places_list' => $placelist),'meta'=>array('page_token'=>$page_token));
return $result;
}
public function order_picked_up($request){
$query = $this->db->where('unique_id', $request['auth'])->get('auth_table');
if ($query->num_rows() > 0) {
$rs = $query->row();
$id = $rs->member_id;
$data = array('status' => '1');
$this->db->where('users_id', $id);
$this->db->where('id', $request['order_id']);
$query = $this->db->update('orders', $data);
$result = array('status' => 'success');
return $result;
} else {
$result = array('status' => 'error');
return $result;
$respArr['message'] = 'Booking Id does\'t Exist';
}
return $respArr;
}
}
?>
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment