daily commit
Showing
application/controllers/Webservices.php
0 → 100644
application/models/Webservice_model.php
0 → 100644
| <?php | ||
| class Webservice_model extends CI_Model { | ||
| function __construct() { | ||
| parent::__construct(); | ||
| date_default_timezone_set('Asia/Kolkata'); | ||
| } | ||
| 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){ | ||
| $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'); | ||
| } | ||
| $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'); | ||
| } | ||
| function getUserId($auth = ''){ | ||
| if(empty($auth)){ | ||
| return; | ||
| } | ||
| $query = $this->db->where('unique_id',$auth)->get('auth_table')->row(); | ||
| if(empty($query)){ | ||
| return; | ||
| } | ||
| return $query->member_id; | ||
| } | ||
| function geySysSettings(){ | ||
| $data = $this->db->get('setting')->row(); | ||
| if(!empty($data)){ | ||
| return $data; | ||
| } | ||
| 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'); | ||
| } | ||
| $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'; | ||
| } | ||
| $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; | ||
| $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(); | ||
| } | ||
| $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; | ||
| } | ||
| $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'); | ||
| } | ||
| $user_id = $this->getUserId($request['auth']); | ||
| if(empty($user_id)){ | ||
| return array('status'=>'error'); | ||
| } | ||
| $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 request_order($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'); | ||
| } | ||
| $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'); | ||
| } | ||
| 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'); | ||
| } | ||
| $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; | ||
| $newTime = date("Y-m-d H:i:s",strtotime(date("Y-m-d H:i:s")." -1 minutes")); | ||
| $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)"; | ||
| $data = $this->db->query($sql); | ||
| if(empty($data)){ | ||
| return; | ||
| } | ||
| $data = $data->result_array(); | ||
| 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(); | ||
| if(empty($reqData) || empty($reqData['shop_id'])){ | ||
| continue; | ||
| } | ||
| $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; | ||
| } | ||
| $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; | ||
| } | ||
| 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; | ||
| } | ||
| $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; | ||
| } | ||
| $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 array("status"=>"success","data"=>array('recent_chats'=>array($chatData))); | ||
| } | ||
| public function request_details($request){ | ||
| $data = $this->geySysSettings(); | ||
| $google_key = $data->google_api_key; | ||
| $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'); | ||
| } | ||
| $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); | ||
| $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'); | ||
| } | ||
| return $result; | ||
| } | ||
| 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(); | ||
| 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'); | ||
| } | ||
| $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, | ||
| ); | ||
| $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(); | ||
| $id = $rs->member_id; | ||
| $rs = $this->db->query("SELECT receipt_photo FROM orders | ||
| WHERE id = '".$request['order_id']."'")->row(); | ||
| if($rs->receipt_photo != ''){ | ||
| $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; | ||
| } | ||
| else{ | ||
| $result = array('status' => 'error','message' => 'Please upload the receipt_photo'); | ||
| return $result; | ||
| } | ||
| } else { | ||
| $result = array('status' => 'error','message' => 'Insufficient data'); | ||
| return $result; | ||
| } | ||
| } | ||
| 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'); | ||
| $this->push_sent_cancel($rideData['fcm_token'], $fcm_data); | ||
| return $result; | ||
| } | ||
| 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; | ||
| } | ||
| } else { | ||
| $result = array('status' => 'error'); | ||
| return $result; | ||
| } | ||
| } | ||
| 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); | ||
| curl_setopt($ch, CURLOPT_POSTFIELDS, $data); | ||
| // 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'])); | ||
| } | ||
| } | ||
| $searchData = file_get_contents("https://maps.googleapis.com/maps/api/place/nearbysearch/json?key=".$google_key.$urlParams); | ||
| if(empty($searchData)){ | ||
| return array('status'=>'error'); | ||
| } | ||
| $searchData = json_decode($searchData,true); | ||
| if(empty($searchData) || $searchData['status']!='OK'){ | ||
| return array('status'=>'error'); | ||
| } | ||
| $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']; | ||
| } | ||
| } | ||
| $i = 0; | ||
| $placelist = array(); | ||
| $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; | ||
| } | ||
| $shopLoc = $shopinfo['geometry']['location']; | ||
| $lat = $shopLoc['lat']; | ||
| $lng = $shopLoc['lng']; | ||
| $shopLoc = $shopinfo['geometry']['location']; | ||
| 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"; | ||
| $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"; | ||
| $i++; | ||
| } | ||
| $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; | ||
| } | ||
| } | ||
| } | ||
| ?> |
| ... | ... | @@ -3,7 +3,7 @@ |
| -- https://www.phpmyadmin.net/ | ||
| -- | ||
| -- Host: db | ||
| -- Generation Time: Dec 21, 2018 at 12:57 PM | ||
| -- Generation Time: Dec 28, 2018 at 12:21 PM | ||
| -- Server version: 5.6.41 | ||
| -- PHP Version: 7.2.8 | ||
| ... | ... | @@ -74,7 +74,7 @@ CREATE TABLE `customers` ( |
| INSERT INTO `customers` (`customer_id`, `first_name`, `last_name`, `phone`, `email`, `address`, `profile_image`, `password`, `date_of_birth`, `status`) VALUES | ||
| (1, 'Tobin', 'Thomas', '9995559194', '[email protected]', 'Techware', 'assets/uploads/services/1544417044_sniper.jpg', NULL, '05/05/1994', 1), | ||
| (2, 'Tobin', 'Thomas', '99955752194', '[email protected]', 'Techware', 'assets/uploads/services/1545036793_car1.jpg', NULL, '12/20/2018', 1), | ||
| (3, 'Tobin', 'Thomas', '9993242394', 'tobin[email protected]', 'Techware', 'assets/uploads/services/1545037023_images.jpg', NULL, '12/11/2018', 1); | ||
| (3, 'Tobin', 'Thomas', '9993242394', 'tobin@gmail.com', 'Techware', 'assets/uploads/services/1545037023_images.jpg', 'e10adc3949ba59abbe56e057f20f883e', '12/11/2018', 1); | ||
| -- -------------------------------------------------------- | ||
| ... | ... | @@ -135,7 +135,9 @@ CREATE TABLE `issues` ( |
| INSERT INTO `issues` (`issue_id`, `issue`, `issue_image`, `status`) VALUES | ||
| (9, 'Wheel Maintenance', 'assets/uploads/services/images8.jpg', 1), | ||
| (10, 'AC Maintenance', 'assets/uploads/services/car_ac.jpg', 1); | ||
| (10, 'AC Maintenance', 'assets/uploads/services/car_ac.jpg', 1), | ||
| (11, 'Oil Change and General Service', 'assets/uploads/services/images9.jpg', 1), | ||
| (12, 'General Service', 'assets/uploads/services/Twitch_KingpinSkin_old2_HD1.jpg', 1); | ||
| -- -------------------------------------------------------- | ||
| ... | ... | @@ -158,10 +160,10 @@ CREATE TABLE `issues_category` ( |
| -- | ||
| INSERT INTO `issues_category` (`issue_cat_id`, `issue_id`, `issue_category`, `issue_cat_image`, `default_service_fee`, `default_description`, `status`) VALUES | ||
| (3, 9, 'Wheel Checking', 'assets/uploads/services/images7.jpg', 500, 'Wheel Checking Edit Issue Update Issue Data. Wheel Checking Edit Issue Update Issue Data. Wheel Checking Edit Issue Update Issue Data. Wheel Checking Edit Issue Update Issue Data. Wheel Checking Edit Issue Update Issue Data. Wheel Checking Edit Issue Update Issue Data. Wheel Checking Edit Issue Update Issue Data. Wheel Checking Edit Issue Update Issue Data. Wheel Checking Edit Issue Update Issue Data. Wheel Checking Edit Issue Update Issue Data. Wheel Checking Edit Issue Update Issue Data. Wheel Checking Edit Issue Update Issue Data. ', 1), | ||
| (4, 9, 'Wheel Alignment', 'assets/uploads/services/images7.jpg', 1000, 'Wheel Alignment Wheel Checking Edit Issue Update Issue Data. Wheel Alignment Wheel Checking Edit Issue Update Issue Data. Wheel Alignment Wheel Checking Edit Issue Update Issue Data. Wheel Alignment Wheel Checking Edit Issue Update Issue Data. Wheel Alignment Wheel Checking Edit Issue Update Issue Data. Wheel Alignment Wheel Checking Edit Issue Update Issue Data. Wheel Alignment Wheel Checking Edit Issue Update Issue Data. Wheel Alignment Wheel Checking Edit Issue Update Issue Data. Wheel Alignment Wheel Checking Edit Issue Update Issue Data. Wheel Alignment Wheel Checking Edit Issue Update Issue Data. Wheel Alignment Wheel Checking Edit Issue Update Issue Data. Wheel Alignment Wheel Checking Edit Issue Update Issue Data. Wheel Alignment Wheel Checking Edit Issue Update Issue Data. Wheel Alignment Wheel Checking Edit Issue Update Issue Data. ', 1), | ||
| (5, 10, 'AC Checking', 'assets/uploads/services/sniper.jpg', 1500, 'AC Maintenance, AC Checking. AC Maintenance, AC Checking. AC Maintenance, AC Checking. AC Maintenance, AC Checking. AC Maintenance, AC Checking. AC Maintenance, AC Checking. AC Maintenance, AC Checking. AC Maintenance, AC Checking. ', 1), | ||
| (6, 10, 'AC Cleaning', 'assets/uploads/services/Himalayan.jpg', 2500, 'AC Maintenance, AC Cleaning. AC Maintenance, AC Cleaning. AC Maintenance, AC Cleaning. AC Maintenance, AC Cleaning. AC Maintenance, AC Cleaning. AC Maintenance, AC Cleaning. AC Maintenance, AC Cleaning. ', 1); | ||
| (7, 11, 'Oil Change', 'assets/uploads/services/Twitch_KingpinSkin_old2_HD.jpg', 1500, 'Oil Change and general service with free water service. Oil Change and general service with free water service. Oil Change and general service with free water service. ', 1), | ||
| (8, 11, 'Oil Top Up ', 'assets/uploads/services/Himalayan1.jpg', 500, 'Oil Top Up and general service with free water service. ', 1), | ||
| (9, 12, 'General Service L:0', 'assets/uploads/services/park-512.png', 700, 'With out Water Service and Polishing. With out Water Service and Polishing. With out Water Service and Polishing. With out Water Service and Polishing. ', 1), | ||
| (10, 12, 'General Service L:1', 'assets/uploads/services/car.jpg', 700, 'Free Water Service and Polishing. Free Water Service and Polishing. Free Water Service and Polishing. Free Water Service and Polishing. ', 1); | ||
| -- -------------------------------------------------------- | ||
| ... | ... | @@ -217,9 +219,13 @@ CREATE TABLE `mechanic_issues` ( |
| -- | ||
| INSERT INTO `mechanic_issues` (`id`, `issue_id`, `issue_cat_id`, `mechanic_id`, `custom_description`, `custom_service_fee`, `status`) VALUES | ||
| (11, 9, NULL, 2, NULL, 0, 1), | ||
| (17, 10, 5, 2, '555555 AC Maintenance, AC Checking. AC Maintenance, AC Checking. AC Maintenance, AC Checking. AC Maintenance, AC Checking. AC Maintenance, AC Checking. AC Maintenance, AC Checking. AC Maintenance, AC Checking. AC Maintenance, AC Checking. ', 1500, 1), | ||
| (18, 10, 6, 2, '6666666 AC Maintenance, AC Cleaning. AC Maintenance, AC Cleaning. AC Maintenance, AC Cleaning. AC Maintenance, AC Cleaning. AC Maintenance, AC Cleaning. AC Maintenance, AC Cleaning. AC Maintenance, AC Cleaning. ', 2500, 1); | ||
| (20, 9, NULL, 2, NULL, 0, 2), | ||
| (21, 11, NULL, 2, NULL, 0, 2), | ||
| (22, 11, NULL, 2, NULL, 0, 2), | ||
| (23, 10, NULL, 2, NULL, 0, 2), | ||
| (24, 11, 7, 2, '!@#$%^ N Oil Change and general service with free water service. Oil Change and general service with free water service. Oil Change and general service with free water service. ', 400, 2), | ||
| (25, 11, 8, 2, '!@#$%^ N Oil Top Up and general service with free water service. ', 400, 2), | ||
| (26, 11, NULL, 2, NULL, 0, 1); | ||
| -- -------------------------------------------------------- | ||
| ... | ... | @@ -242,7 +248,7 @@ CREATE TABLE `mechanic_shop` ( |
| INSERT INTO `mechanic_shop` (`shop_id`, `shop_name`, `address`, `phone`, `email_id`, `status`) VALUES | ||
| (1, 'Mechanic Shop', 'Kakkanad', '9995559194', '[email protected]', 1), | ||
| (2, 'New Shop 1', 'Techware', '9995559194', '[email protected]', 0); | ||
| (2, 'New Shop 1', 'Techware', '9995559194', '[email protected]', 1); | ||
| -- -------------------------------------------------------- | ||
| ... | ... | @@ -357,13 +363,13 @@ ALTER TABLE `customer_vehicle` |
| -- AUTO_INCREMENT for table `issues` | ||
| -- | ||
| ALTER TABLE `issues` | ||
| MODIFY `issue_id` int(11) NOT NULL AUTO_INCREMENT, AUTO_INCREMENT=11; | ||
| MODIFY `issue_id` int(11) NOT NULL AUTO_INCREMENT, AUTO_INCREMENT=13; | ||
| -- | ||
| -- AUTO_INCREMENT for table `issues_category` | ||
| -- | ||
| ALTER TABLE `issues_category` | ||
| MODIFY `issue_cat_id` int(11) NOT NULL AUTO_INCREMENT, AUTO_INCREMENT=7; | ||
| MODIFY `issue_cat_id` int(11) NOT NULL AUTO_INCREMENT, AUTO_INCREMENT=11; | ||
| -- | ||
| -- AUTO_INCREMENT for table `mechanic` | ||
| ... | ... | @@ -375,7 +381,7 @@ ALTER TABLE `mechanic` |
| -- AUTO_INCREMENT for table `mechanic_issues` | ||
| -- | ||
| ALTER TABLE `mechanic_issues` | ||
| MODIFY `id` int(11) NOT NULL AUTO_INCREMENT, AUTO_INCREMENT=19; | ||
| MODIFY `id` int(11) NOT NULL AUTO_INCREMENT, AUTO_INCREMENT=27; | ||
| -- | ||
| -- AUTO_INCREMENT for table `mechanic_shop` | ||
| ... | ... |
Please
register
or
sign in
to comment