22

✏️ Editing: lead_api.php

<?php

// Report all errors
error_reporting(E_ALL);

// Same as error_reporting(E_ALL);
ini_set("error_reporting", E_ALL);

//echo $_SERVER['DOCUMENT_ROOT'];
include './../api.php';

$full_name = $_POST['full_name'];
$mobile = $_POST['mobile'];
$email = $_POST['email'];
$city = get_city_lookup($_POST['city'])['id'];
$voi = $_POST['voi'];
$bank = get_bank_lookup($_POST['bank'])['id'];
$branch = get_branch_lookup($_POST['branch'])['id'];
$expected_purchase_date = get_expected_purchase_lookup($_POST['expected_purchase_date'])['id'];
$preferred_call_time = get_pref_time_lookup($_POST['preferred_call_time'])['id'];
$gender = get_gender_lookup($_POST['gender'])['id'];
$business_unit_id = get_branch_lookup($_POST['branch'])['business_unit_id'];
$branch_code = get_branch_lookup($_POST['branch'])['branch_code'];
$confirmation_code = get_random_number(4);
$campaign = $_POST['campaign'];
$source = $_POST['source'];
$landing_page_source = $_POST['landing_page_source'];
$salary = $_POST['salary'];

function branch_round_assign($data1,$data2){
    
$codequery = "select count(id) as 'cnt' from xx_users where branch_code = '$data1' and role_id = '2' and active = 'Y'";

$result = $GLOBALS["link"]->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);

//echo $message;

send_sms_api($mobile,$message);
    
}

}else echo "Incorrect Key";

MR SKB