query($codequery); while($row = $result->fetch_assoc()) { $cid = $row; } //echo $cid['cnt']; if($cid['cnt'] > 1){ $codequery = "select count(id) as 'cnt' from xx_users where branch_code = '$data1' and last_assigned = 'Y' and role_id = '2' and active = 'Y'"; $result = $GLOBALS["link"]->query($codequery); while($row = $result->fetch_assoc()) { $id1 = $row; } if($id1['cnt'] > 1){ $codequery = "update xx_users set last_assigned = null where branch_code = '$data1' and last_assigned = 'Y' and role_id = '2' and active = 'Y'"; //echo $codequery; if ($GLOBALS["link"]->query($codequery) === TRUE) { //return 'Customer Record updated Succesfully'; }else{ //return 'error'; } $codequery = "update xx_users set last_assigned = 'Y' where branch_code = '$data1' and role_id = '2' and active = 'Y' ORDER BY id DESC LIMIT 1"; //echo $codequery; if ($GLOBALS["link"]->query($codequery) === TRUE) { //return 'Customer Record updated Succesfully'; }else{ //return 'error'; } } $codequery = "select * from xx_users where branch_code = '$data1' and role_id = '2' and active = 'Y' and id > (select id from xx_users where branch_code = '$data1' and last_assigned = 'Y' and role_id = '2' and active = 'Y') and role_id = '2' order by id asc limit 0,1"; $result = $GLOBALS["link"]->query($codequery); while($row = $result->fetch_assoc()) { $id = $row; } if(isset($id)){}else{ $codequery = "select * from xx_users where branch_code = '$data1' and role_id = '2' and active = 'Y' and id < (select id from xx_users where branch_code = '$data1' and last_assigned = 'Y' and role_id = '2' and active = 'Y') and role_id = '2' order by id asc limit 0,1"; $result = $GLOBALS["link"]->query($codequery); while($row = $result->fetch_assoc()) { $id = $row; } } $rid = $id['id']; $codequery = "update xx_users set last_assigned = null where last_assigned = 'Y' and branch_code = '$data1' and role_id = '2' and active = 'Y' "; //echo $codequery; if ($GLOBALS["link"]->query($codequery) === TRUE) { //return 'Customer Record updated Succesfully'; }else{ //return 'error'; } $codequery = "update xx_users set last_assigned = 'Y' where id = '$rid'"; //echo $codequery; if ($GLOBALS["link"]->query($codequery) === TRUE) { //return 'Customer Record updated Succesfully'; }else{ //return 'error'; } return $id; }else{ $codequery = "select * from xx_users where branch_code = '$data1' and role_id = '2' and active = 'Y'"; //echo $codequery; $result = $GLOBALS["link"]->query($codequery); while($row = $result->fetch_assoc()) { $id = $row; } $rid = $id['id']; $codequery = "update xx_users set last_assigned = 'Y' where id = '$rid'"; //echo $codequery; if ($GLOBALS["link"]->query($codequery) === TRUE) { //return 'Customer Record updated Succesfully'; }else{ //return 'error'; } return $id; } } function create_account($full_name,$mobile,$email,$city,$bank,$gender,$source,$campaign){ date_default_timezone_set('Asia/Riyadh'); $date = date("Y-m-d H:i:s"); $user_id = $_SESSION['user_id']; $user_id = "99"; $codequery = "insert into xx_accounts (full_name, mobile1, email_address, city_id, bank_id, gender_id, acc_source, acc_campaign, created_by_id, creation_date ) value ( '$full_name', '$mobile', '$email', '$city', '$bank', '$gender', '$source', '$campaign', '$user_id', '$date' )"; //echo $codequery; if ($GLOBALS["link"]->query($codequery) === TRUE) { $last_id = $GLOBALS["link"]->insert_id; return $last_id; }else{ return 'error'; } } function is_existing_account($data){ $codequery = "select acc_id from xx_accounts where mobile1 = '$data'"; //echo $codequery; $result = $GLOBALS["link"]->query($codequery); while($row = $result->fetch_assoc()) { $id = $row; } if($id['acc_id']==""){ return array("result"=>"0","acc_id"=>$id['acc_id']); }else{ return array("result"=>"1","acc_id"=>$id['acc_id']); } } function create_lead($acc_id,$voi,$branch,$expected_purchase_date,$preferred_call_time,$business_unit_id,$sales_agent_id,$confirmation_code,$source,$campaign,$landing_page_source,$salary){ date_default_timezone_set('Asia/Riyadh'); $date = date("Y-m-d H:i:s"); $user_id = $_SESSION['user_id']; $user_id = "47"; $codequery = "insert into xx_leads (acc_id, requested_voi, branch_id, expected_purchase_time_id, preferred_call_time_id, business_unit_id, opp_stage_id, sales_agent_id, confirmation_code, lead_source, lead_campaign, created_by_id, creation_date, landing_page_source, salary ) value ( '$acc_id', '$voi', '$branch', '$expected_purchase_date', '$preferred_call_time', '$business_unit_id', '1', '$sales_agent_id', '$confirmation_code', '$source', '$campaign', '$user_id', '$date', '$landing_page_source', '$salary' )"; //echo $codequery; if ($GLOBALS["link"]->query($codequery) === TRUE) { $last_id = $GLOBALS["link"]->insert_id; return $last_id; }else{ return 'error'; } } function send_sms_api ($to,$message){ $to="966".ltrim($to,"0"); $ch = curl_init(); curl_setopt($ch, CURLOPT_URL,"https://api.taqnyat.sa/v1/messages"); curl_setopt($ch, CURLOPT_POST, 1); curl_setopt($ch, CURLOPT_POSTFIELDS,' { "recipients": ['.$to.'], "body":"'.$message.'", "sender":"Taajeer" } '); $body = ' { "recipients": ['.$to.'], "body":"'.$message.'", "sender":"Taajeer" }'; /* set the content type json */ $headers = []; $headers[] = 'Content-Type:application/json'; $token = "a69f83df3e490a170905974ed3dcc9eb"; $headers[] = "Authorization: Bearer ".$token; curl_setopt($ch, CURLOPT_HTTPHEADER, $headers); // In real life you should use something like: // curl_setopt($ch, CURLOPT_POSTFIELDS, // http_build_query(array('postvar1' => 'value1'))); // Receive server response ... curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); $server_output = curl_exec($ch); print_r($server_output); //echo $body; curl_close($ch); // Further processing ... //if ($server_output == "OK") { ... } else { ... } } if($_POST['secretkey'] == 'Vision@2050'){ $is_existing = is_existing_account($mobile); if($is_existing['result'] == 1){ $ledid = create_lead($is_existing['acc_id'],$voi,$branch,$expected_purchase_date,$preferred_call_time,$business_unit_id,branch_round_assign($branch_code,'1')['id'],$confirmation_code,$source,$campaign,$landing_page_source,$salary); $leaddata = get_lead_detail($ledid); $leadvdata = get_leadv_ar_detail($ledid); $message ="شكرًا لاهتمامك بـ"; $message .=$leadvdata['requested_voi']; $message .=" سيتصل بك "; $message .=$leadvdata['sales_agent']; $message .=" من الفرع في "; $message .=$leadvdata['branch']; $message .="، ورقم هاتفه المحمول "; $message .=$leadvdata['sales_agent_mobile']; $message .="، خلال 24 ساعة. رقم الطلب الخاص بك هو "; $message .=$leadvdata['confirmation_code']; $message .=". يمكنك العثور على موقع "; $message .=" عبر الرابط التالي:"; $message .="\\n".$leadvdata['branch_location']; //echo $message; send_sms_api($mobile,$message); }else{ create_account($full_name,$mobile,$email,$city,$bank,$gender,$source,$campaign); $acc = is_existing_account($mobile); $ledid = create_lead($acc['acc_id'],$voi,$branch,$expected_purchase_date,$preferred_call_time,$business_unit_id,branch_round_assign($branch_code,'1')['id'],$confirmation_code,$source,$campaign,$landing_page_source,$salary); $leaddata = get_lead_detail($ledid); $leadvdata = get_leadv_ar_detail($ledid); $message ="شكرًا لاهتمامك بـ"; $message .=$leadvdata['requested_voi']; $message .=" سيتصل بك "; $message .=$leadvdata['sales_agent']; $message .=" من الفرع في "; $message .=$leadvdata['branch']; $message .="، ورقم هاتفه المحمول "; $message .=$leadvdata['sales_agent_mobile']; $message .="، خلال 24 ساعة. رقم الطلب الخاص بك هو "; $message .=$leadvdata['confirmation_code']; $message .=". يمكنك العثور على موقع "; $message .=" عبر الرابط التالي: "; $message .="\\n".$leadvdata['branch_location']; //echo $message; send_sms_api($mobile,$message); } }else echo "Incorrect Key"; ?>