<?php

include "db_connect.php";
// Set the ip and port we will listen on
//$address = '192.168.100.100';
$address = '103.105.54.165';
$port = 2525;
//$port = 8000;
$cek_sms =0;

		error_reporting(E_ALL);
		set_time_limit(0);

ob_implicit_flush();

// Create a TCP Stream socket
//$sock = socket_create(AF_INET, SOCK_STREAM, 0);
$sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);

 echo "sock=".$sock;
// Bind the socket to an address/port
//tidak perlu
//socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1)	or die("socket_option() failed");

socket_bind($sock, $address, $port) or die('Could not bind to address');

// Start listening for connections
socket_listen($sock,20);
echo "listen socket\n";

// Non block socket type
socket_set_nonblock($sock);
echo "socket_set_nonblock\n";

// Clients
$clients = array();
$ip_nya = array();
$my_id= array();

function init_socket()
{
echo "init socket\n";
 
//$address = '192.168.100.100';
//$address = '103.105.54.165';
//$port = 25003;          //lokal
//$port = 2525;
//$port = 100;            //public
$cek_sms =0;

error_reporting(E_ALL);
set_time_limit(0);

ob_implicit_flush();

// Create a TCP Stream socket
//$sock = socket_create(AF_INET, SOCK_STREAM, 0);
$sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);

 echo "sock=".$sock;
// Bind the socket to an address/port
socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1)	or die("socket_option() failed");

socket_bind($sock, $address, $port) or die('Could not bind to address');

// Start listening for connections
socket_listen($sock,20);
echo "listen socket\n";

// Non block socket type
socket_set_nonblock($sock);
echo "socket_set_nonblock\n";
}

//telegram
//$bot="1509994205:AAH68vbyOJ_-qiNBw2B2PhWbhEpAaJeRHc8";		//server sby
$bot="1639175888:AAF4oyjGx4fbzAfZCK3wJJSz7Hr1heaGfPM";      //server pugeran
//$chat ="1479183196";
//$chat ="1479183197";

function sendMessage($chatID, $messaggio, $token) 
{
    echo "sending message to " . $chatID . "\n";

    $url = "https://api.telegram.org/bot" . $token . "/sendMessage?chat_id=" . $chatID;
    $url = $url . "&text=" . urlencode($messaggio);
    $ch = curl_init();
    $optArray = array(
            CURLOPT_URL => $url,
            CURLOPT_RETURNTRANSFER => true
    );
    curl_setopt_array($ch, $optArray);
    $result = curl_exec($ch);
    curl_close($ch);
    return $result;
}

function Broadcast_Sms($db, $no_hp, $string)
{
echo "func Broadcast_SMS\n";
   $hp_dest = [];
   $sql = "select hp_dest from user where no_hp='$no_hp' and hp_dest != '' ";
// echo $sql;

      //       print_r($db);
   $query=mysqli_query($db,$sql )or die (mysqli_error());
   $jumlah = mysqli_num_rows($query);
   echo "jum=".$jumlah."\n";
   if($jumlah >0)
   {
    $row=mysqli_fetch_array($query);
    $hp_dest = explode(",",$row[0]);
    foreach ($hp_dest AS $key => $value)
    {
        $sql = "INSERT INTO outbox_int(id_dest, text) VALUES ('$value', '$string')";
//        echo "sql=".$sql."\n";
        $query=mysqli_query($db, $sql);
    }
   }
   else
     echo "Tidak Braodcast SMS\n";

}

function Insert_Data($db,$string, $clients,$ip_nya,$tot_sms)
{
 global $cek_sms;
// $bot="1509994205:AAH68vbyOJ_-qiNBw2B2PhWbhEpAaJeRHc8";			//tes surabaya
 $bot="1639175888:AAF4oyjGx4fbzAfZCK3wJJSz7Hr1heaGfPM";      //server pugeran
 
 $datanya = substr($string,1,strlen($string));
 $cek_sms=1;
 //echo "function insert_data= ".$cek_sms." total sms=".$tot_sms."\n";
// list($dt,$no_hp,$datetime,$datanya) = explode(",",$string);
 
// $datanya =substr($string,0,strlen($string));
// echo "count=".count(explode(",",$datanya))."=".$datanya;

	list($no_id, $lokasi, $info, $airlevel, $accu, $signal, $offset, $sensor, $alts, $alarmlevel,$temp) = explode(",",$datanya);
	
 $lokasi_table = check_lokasi($db,$no_id);
// echo "insert data ".$no_id."->".$lokasi_table."=".$datanya;

		if($airlevel >= $alarmlevel)
			$AF='1';
		else
			$AF='0';
				
    if($lokasi_table == "banjir")
    {
//			$sql = "INSERT INTO `banjir`(`no_id`,`lokasi`, `info`,`airlevel`,`accu`,`signal`,`offset`,`sensor`,`alts`,`alarmlevel`,`date`,`temp`)
//			VALUES ('$no_id','$lokasi','$info','$airlevel','$accu','$signal','$offset','$sensor','$alts','$alarmlevel',now(),'$temp')";
			$sql = "INSERT INTO `banjir`(`no_hp`,`lokasi`, `info`,`DTlevel`,`Accu`,`mifi`,`Alts`,`Alarmlevel`,`date`,`temp`,`AF`,`WF`,`asal`)
			VALUES ('$no_id','$lokasi','$info','$airlevel','$accu','$signal','$alts','$alarmlevel',now(),'$temp','$AF','0','INT')";

//    echo $sql."\n";
      $query=mysqli_query($db, $sql);

//broadcast telegram

	if(check_telegram($db,$no_id) == '1')
	{
/*
		$ssql = "select level,range_min,alts,status1,status2 from setting where no_id='$no_id'";
		$squery=mysqli_query($db, $ssql);
		
		if(mysqli_num_rows($squery)>0)
		{
			$srow=mysqli_fetch_array($squery);
			if($airlevel >= $srow['level'] && $airlevel <= $srow['status1'])
				$status_ews="Siaga Kuning";
			else if($airlevel >= $srow['status1'] && $airlevel <= $srow['status2'])
				$status_ews="Siaga Merah";
			else if( $airlevel >= $srow['status2'] && $airlevel <= ($srow['alts']-$row['range_min']) )
				$status_ews="Bahaya";
			else
				$status_ews="Normal";				
		}
		else
			$status_ews="Normal";
*/
		$tsql = "select id_user from telegram_int where no_id='$no_id'";
		$tquery=mysqli_query($db, $tsql);
		$tjumlah = mysqli_num_rows($tquery);

		if($tjumlah >0)
		{
			while ($trow=mysqli_fetch_array($tquery))
			{		 
				$message = "Data EWS $lokasi\n";
				$message .= "Status : ";
				if($AF == '1')
					$status_ews="Warning";
				else	
					$status_ews="Normal";					
				$message .= $status_ews."\n";
				$message .= "Tegangan Aki : $accu V\n";
				$message .= "Tinggi Air : $airlevel m\n";
				$message .= "Batas Normal : $alarmlevel m\n";
				$message .= "Suhu Alat : $temp C\n";
				sendMessage($trow['id_user'], $message, $bot);
//				echo $message;
			}
		}
	}		 

      if($info == "Warning..!")
      {
       $datanya = substr($datanya,0,strlen($datanya)-2);
       Broadcast_Sms($db, $no_hp, $datanya);
      }
    }
    else if($lokasi_table == "longsor")
    {/*
     list($dt1, $dt2, $dt3, $dt4, $dt5) = explode(",", $datanya);

 //    echo "dt2=".count(explode(":",$dt2));
     if(count(explode(":",$dt2)) > 2)
     {
      list($dt21, $dt22, $dt23) = explode(":", $dt2);
     $dt2_1=$dt22;  //Info+Range   >> selftest+info+range
     $dt2_2=substr($dt23,6,strlen($dt23)-6);
     }
     else
     {
      list($dt2_1, $dt2) = explode(":", $dt2);
//     $dt2_1=substr($dt2,0,8);  //Info+Range   >> selftest+info+range
//      $dt2_2=substr($dt2,15,strlen($dt2));
      $dt2_2=substr($dt2,6,strlen($dt2)-6);
     }
     $dt3=preg_replace("/[^0-9\.]/","",$dt3);  //Alarm
     $dt4=preg_replace("/[^0-9\.]/","",$dt4);  //Accu
     $dt5=preg_replace("/[^0-9\.]/","",$dt5);  //Warning

     $sql = "INSERT INTO longsor(lokasi, info, Rangeku,Alarm,Accu,Warning,no_hp,date) VALUES ('$dt1', '$dt2_1', '$dt2_2','$dt3','$dt4',
    '$dt5','$no_hp','$datetime')";
      $query=mysqli_query($db, $sql);

      $cek_sms=0;
 //broadcast sms
      if($info == "Warning..!@LONG002")
      {
       $datanya = substr($datanya,0,strlen($datanya)-2);
       Broadcast_Sms($db, $no_hp, $datanya);
      }

    */}
    else if($lokasi_table == "tsunami")
    {/*
     list($dt1, $dt2, $dt3, $dt4, $dt5, $dt6, $dt7, $dt8) = explode(",", $datanya);
     $dt3=preg_replace("/[^0-9\.]/","",$dt3);  //Accu
     $dt4=preg_replace("/[^0-9\.]/","",$dt4);  //PaCurr
     $dt5=preg_replace("/[^0-9\.]/","",$dt5);  //PaVcc
     $dt6=preg_replace("/[^0-9\.]/","",$dt6);  //PaVo
     $dt7=preg_replace("/[^0-9\.]/","",$dt7);  //HornZ
     $dt8=preg_replace("/[^0-9\.]/","",$dt8);  //PaPwr

//     echo "len=".strlen($dt8)."=".$tes."\n";
//     echo "saya2=".$dt3."=".$dt4."=".$dt5."=".$dt6."=".$dt7."=".$dt8."=".$no_hp."=".$datetime."\n";

     $sql2 = "INSERT INTO tsunami(lokasi, info, Accu,PaCurr,PaVcc,PaVo,HornZ,PaPwr,no_hp,date) VALUES";
     $sql3=" ('$dt1','$dt2','$dt3','$dt4','$dt5','$dt6','$dt7','$dt8','$no_hp','$datetime')";
 //    echo "dataku=".$sql2.$sql3;
      $query=mysqli_query($db, $sql2.$sql3);

      $cek_sms=0;
//      echo "info=".$dt2."\n";
    */}
    else
    {
        Insert_Inbox($db, $string);
        echo "error system=".$string."\n";
     }
//    echo $sql."\n";;

}

function Insert_DataCek($db,$string, $clients,$ip_nya,$tot_sms)
{

 global $cek_sms;
// $bot="1509994205:AAH68vbyOJ_-qiNBw2B2PhWbhEpAaJeRHc8";			//server sby
 $bot="1639175888:AAF4oyjGx4fbzAfZCK3wJJSz7Hr1heaGfPM";      //server pugeran

 $datanya = substr($string,1,strlen($string));
 $cek_sms=1;
 //echo "function insert_data= ".$cek_sms." total sms=".$tot_sms."\n";
// list($dt,$no_hp,$datetime,$datanya) = explode(",",$string);
 
// $datanya =substr($string,0,strlen($string));
// echo "count=".count(explode(",",$datanya))."=".$datanya;

	list($no_id, $lokasi, $info, $airlevel, $accu, $signal, $offset, $sensor, $alts, $alarmlevel,$temp,$idchat) = explode(",",$datanya);
	
 $lokasi_table = check_lokasi($db,$no_id);
// echo "insert data ".$no_id."->".$lokasi_table."=".$datanya;
		if($airlevel >= $alarmlevel)
			$AF='1';
		else
			$AF='0';

    if($lokasi_table == "banjir")
    {
//			$sql = "INSERT INTO `banjir`(`no_id`,`lokasi`, `info`,`airlevel`,`accu`,`signal`,`offset`,`sensor`,`alts`,`alarmlevel`,`date`,`temp`) 
//			VALUES ('$no_id','$lokasi','$info','$airlevel','$accu','$signal','$offset','$sensor','$alts','$alarmlevel',now(),'$temp')";
			$sql = "INSERT INTO `banjir`(`no_hp`,`lokasi`, `info`,`DTlevel`,`Accu`,`mifi`,`Alts`,`Alarmlevel`,`date`,`temp`,`AF`,`WF`,`asal`)
			VALUES ('$no_id','$lokasi','$info','$airlevel','$accu','$signal','$alts','$alarmlevel',now(),'$temp','$AF','0','INT')";

//    echo $sql."\n";
      $query=mysqli_query($db, $sql);

//broadcast telegram
			if(check_telegram($db,$no_id) == '1' && $idchat !="")
			{
/*
				$ssql = "select level,range_min,alts,status1,status2 from setting where no_id='$no_id'";
				$squery=mysqli_query($db, $ssql);
				
				if(mysqli_num_rows($squery)>0)
				{
					$srow=mysqli_fetch_array($squery);
					if($airlevel >= $srow['level'] && $airlevel <= $srow['status1'])
						$status_ews="Siaga Kuning";
					else if($airlevel >= $srow['status1'] && $airlevel <= $srow['status2'])
						$status_ews="Siaga Merah";
					else if( $airlevel >= $srow['status2'] && $airlevel <= ($srow['alts']-$row['range_min']) )
						$status_ews="Bahaya";
					else
						$status_ews="Normal";				
				}
				else
					$status_ews="Normal";
*/			
				$message = "Data EWS $lokasi\n";
				$message .= "Status : ";
				if($AF == '1')
					$status_ews="Warning";
				else	
					$status_ews="Normal";					
				$message .= $status_ews."\n";
				$message .= "Tegangan Aki : $accu V\n";
				$message .= "Tinggi Air : $airlevel m\n";
				$message .= "Batas Normal : $alarmlevel m\n";
				$message .= "Suhu Alat : $temp C\n";
//				sendMessage($idchat, $message, $bot);
//				echo $message;
			}		 
    }
    else if($lokasi_table == "longsor")
    {/*
     list($dt1, $dt2, $dt3, $dt4, $dt5) = explode(",", $datanya);

 //    echo "dt2=".count(explode(":",$dt2));
     if(count(explode(":",$dt2)) > 2)
     {
      list($dt21, $dt22, $dt23) = explode(":", $dt2);
     $dt2_1=$dt22;  //Info+Range   >> selftest+info+range
     $dt2_2=substr($dt23,6,strlen($dt23)-6);
     }
     else
     {
      list($dt2_1, $dt2) = explode(":", $dt2);
//     $dt2_1=substr($dt2,0,8);  //Info+Range   >> selftest+info+range
//      $dt2_2=substr($dt2,15,strlen($dt2));
      $dt2_2=substr($dt2,6,strlen($dt2)-6);
     }
     $dt3=preg_replace("/[^0-9\.]/","",$dt3);  //Alarm
     $dt4=preg_replace("/[^0-9\.]/","",$dt4);  //Accu
     $dt5=preg_replace("/[^0-9\.]/","",$dt5);  //Warning

     $sql = "INSERT INTO longsor(lokasi, info, Rangeku,Alarm,Accu,Warning,no_hp,date) VALUES ('$dt1', '$dt2_1', '$dt2_2','$dt3','$dt4',
    '$dt5','$no_hp','$datetime')";
      $query=mysqli_query($db, $sql);

      $cek_sms=0;
 //broadcast sms
      if($info == "Warning..!@LONG002")
      {
       $datanya = substr($datanya,0,strlen($datanya)-2);
       Broadcast_Sms($db, $no_hp, $datanya);
      }

    */}
    else if($lokasi_table == "tsunami")
    {/*
     list($dt1, $dt2, $dt3, $dt4, $dt5, $dt6, $dt7, $dt8) = explode(",", $datanya);
     $dt3=preg_replace("/[^0-9\.]/","",$dt3);  //Accu
     $dt4=preg_replace("/[^0-9\.]/","",$dt4);  //PaCurr
     $dt5=preg_replace("/[^0-9\.]/","",$dt5);  //PaVcc
     $dt6=preg_replace("/[^0-9\.]/","",$dt6);  //PaVo
     $dt7=preg_replace("/[^0-9\.]/","",$dt7);  //HornZ
     $dt8=preg_replace("/[^0-9\.]/","",$dt8);  //PaPwr

//     echo "len=".strlen($dt8)."=".$tes."\n";
//     echo "saya2=".$dt3."=".$dt4."=".$dt5."=".$dt6."=".$dt7."=".$dt8."=".$no_hp."=".$datetime."\n";

     $sql2 = "INSERT INTO tsunami(lokasi, info, Accu,PaCurr,PaVcc,PaVo,HornZ,PaPwr,no_hp,date) VALUES";
     $sql3=" ('$dt1','$dt2','$dt3','$dt4','$dt5','$dt6','$dt7','$dt8','$no_hp','$datetime')";
 //    echo "dataku=".$sql2.$sql3;
      $query=mysqli_query($db, $sql2.$sql3);

      $cek_sms=0;
//      echo "info=".$dt2."\n";
    */}
    else
    {
        Insert_Inbox($db, $string);
        echo "error system=".$string."\n";
     }
//    echo $sql."\n";;
}

function check_lokasi($db,$no_id)
{
//echo "awal=".$no_hp;
/*
 if($no_hp[0] == '+')
 {
   $no_hp = '0'.substr($no_hp,3, strlen($no_hp));
 }
*/ 
   $sql = "select table_name from user where no_id='$no_id' ";
// echo $sql;
      //       print_r($db);
   $query=mysqli_query($db,$sql )or die (mysqli_error());
   $jumlah = mysqli_num_rows($query);
   $row=mysqli_fetch_array($query);

//   echo "data lokasi=".$row[0]."\n";
   if($jumlah>0)
     return $row[0];
   else
     return "";
}

function check_telegram($db,$no_id)
{
//echo "awal=".$no_hp;
   $sql = "select telegram from user where no_id='$no_id' ";
// echo $sql;
      //       print_r($db);
   $query=mysqli_query($db,$sql )or die (mysqli_error());
   $jumlah = mysqli_num_rows($query);
   $row=mysqli_fetch_array($query);

//   echo "data lokasi=".$row[0]."\n";
   if($jumlah>0)
     return $row[0];
   else
     return "";
}

function Insert_Outbox($db,$string)
{
 $data = $string;
 list($dt1, $dt2, $dt3) = explode(",", $string);

    $sql = "INSERT INTO outbox_int(id_dest, text) VALUES ('$dt2', '$dt3')";
    $query=mysqli_query($db, $sql);
//    echo $sql;
}

function cekOutbox2SendSMS($db, $clients, $ip_nya, $my_id)
{
	global $my_id;
 $query = "select id_dest from outbox_int";
 $query=mysqli_query ($db,$query )or die (mysqli_error());
 $jumlah = mysqli_num_rows($query);
// $row=mysqli_fetch_array($query);

// echo "outbox=".$jumlah."\n";
 $string_sms="";
 if($jumlah >0)
 {
// echo "cekOutbox2SendSMS\n";
   $query = "select no,id_dest,text from outbox_int limit 1";
   $query=mysqli_query ($db,$query )or die (mysqli_error());
// $jumlah = mysqli_num_rows($query);
   $row=mysqli_fetch_array($query);

//   $row_sms[2]="Dt:";
	$string_sms=$row['text'];
	
//	print_r($my_id);
// echo "cekOutbox2SendSMS=".$row['id_dest']."\n";
	
	if( ($send_id=get_resid($row['id_dest'],$clients,$my_id)) !== false)
	{
//		echo "lik=".$row['id_dest']."=".$row['text'];
		socket_write($send_id,$string_sms,strlen($string_sms)) or die("Could not write output\n");	
	}
	else
		echo "resource ID tidak konek\n";
/*
   if(strlen($row_sms[2]) > 30)
   {
    $string_sms= "$".$row_sms[0]."*".$row_sms[1]."*".$row_sms[2]."\0";
   }
   else
    $string_sms= "#".$row_sms[0].",".$row_sms[1].",".$row_sms[2]."\0";
//   echo $string_sms."\n";
   
//   print_r($ip_nya);
//   if(in_array("192.168.100.99",$ip_nya))
   {
//connect arduino server
     $socket = socket_create(AF_INET, SOCK_STREAM, 0);
     echo "send 2 server=".$string_sms."len=".strlen($string_sms)."id=".$socket."\n";
//     $result = socket_connect($socket,"192.168.100.99","25004");
     if( ($result = socket_connect($socket,"192.168.100.99","25004")) === false )
    {
      echo "socket_connect() failed: reason: " . socket_strerror(socket_last_error($socket)) . "\n";
 //      throw new Exception( sprintf( "Unable to write to socket: %s", socket_strerror( socket_last_error() ) ) );
    }

     socket_write($socket,$string_sms,strlen($string_sms)) or die("Could not write output\n");
     socket_close($socket);

   }
*/
   $query = "DELETE FROM outbox_int WHERE no = $row[0]";
//   echo $query."\n";
   mysqli_query($db, $query);
   $string_sms="";
 }
 else
     {
     $string_sms="";
     }
}

function Insert_Inbox($db,$string)
{
    $sql = "INSERT INTO inbox(date, info) VALUES (now(), '$string')";
    $query=mysqli_query($db, $sql);
 //   echo $sql;
}


function check_pesan($string)
{
$state_string = array("SELFTEST","WARNING","@LONG002","@BNJR","TEST","Warning..!@LONG002");

$hasil = 0;

$jml_kata = count($state_string);

for ($i=0;$i<$jml_kata;$i++)
{
// echo "llik=".$state_string[$i]."=".strtoupper($string)."\n";
// if (stristr(strtoupper($teks),$state_string[$i]))
  if(preg_match("/$state_string[$i]/i", strtoupper($string)))
 { $hasil=1;
//   break;
  }
}
return $hasil;
}

function check_at_command($string)
{
$state_string = array("F=1","AT+","OK","DEL ALL");

$hasil = 0;

$jml_kata = count($state_string);
//echo "jum=".$jml_kata;
for ($i=0;$i<$jml_kata;$i++)
{
// echo "llik=".$state_string[$i]."=".strtoupper($string)."\n";
// if (stristr(strtoupper($teks),$state_string[$i]))
  if(preg_match("/$state_string[$i]/i", $string))
 { $hasil=1;
//   break;
  }
}
return $hasil;
}

//get id socket
function get_resid($id,$clients,$my_id)
{
//	global $clients,$my_id;
	global $ip_nya;
	
//	print_r($ip_nya);	
//	print_r($clients);
//	print_r($my_id);
	
	$idku = array_search($id, $my_id);
	
//	echo "idku=".$idku."\n";
	if( $idku !== false)
	{
//	echo "get_resid=".$idku;
	if(count($clients)>0)
		$res_id = $clients[$idku];	
//	echo "dat lilik=".$idku."=".$res_id;
		return $res_id;
	}
	else
		return false;
}

function Insert_Setting($db,$datanya)
{
	echo "Insert_Setting\n";
//*RungkutBarata*70.0*120.0*5.0*3.5*10.0*5*2*30*0*0*111111*0.0*0*	
//	user,levela,levelb,altsa,altsb,spana,spanb,accua,accub,
//	range_mina,range_minb,range_p,attack,lmenit,ljam,lmenit2,id,offseta,offsetb,serial)
/*
    data = String("#")+id+String(",")+user+String(",")+level+String(",")+alts+String(",")+span+String(",") + accu+String(",") + range_min
    +String(",") + range_p+String(",")+attack+String(",")+lmenit+String(",")+ljam+String(",")+lmenit2+String(",")+offset+String(",")+serial;
*/	
	list($no_id,$user, $level, $alts, $span, $accu, $range_min, $range_p, $attack, $menit, $jam_send,$menit_send,$offset,$serial) = explode(",",$datanya);

	$sql = "select no_id from setting where no_id ='$no_id'";
	$query=mysqli_query($db,$sql )or die (mysqli_error());
	$jumlah = mysqli_num_rows($query);

	if($jumlah >0)
	{
		$sql = "UPDATE `setting` SET
		`no_id`='$no_id',`user`='$user',`level`='$level',`alts`='$alts',`span`='$span',`accu`='$accu',`range_min`='$range_min',`range_p`='$range_p',`attack`='$attack',
		`offset`='$offset',`serial`='$serial',`menit`='$menit',`jam_send`='$jam_send',`menit_send`='$menit_send' WHERE `no_id`='$no_id'";
		$query=mysqli_query($db, $sql); 

		$sql = "UPDATE `user` SET `lokasi`='$user' WHERE `no_id`='$no_id'";
		$query=mysqli_query($db, $sql); 

	}
	else
	{	
		$sql = "INSERT INTO `setting`(`no_id`,`user`, `level`, `alts`,`span`,`accu`,`range_min`,`range_p`,`attack`,`offset`,`serial`,`menit`,`jam_send`,
		`menit_send`,`date`) 
		VALUES ('$no_id','$user','$level','$alts','$span','$accu','$range_min','$range_p','$attack','$offset','$serial','$menit','$jam_send'
		,'$menit_send',now())";
		$query=mysqli_query($db, $sql); 
	}
//	echo "sql=".$sql."\n";
}

// loop continuously============================================================================
$awal=0;
$tot_sms=0;
$tes=0;
$broadcast_status=0;
while (true) {
    // Accept new connections
    if ($newsock = socket_accept($sock))
    {
       echo "accept\n";
        if (is_resource($newsock))
        {
              socket_set_nonblock($newsock);
//                socket_set_block($newsock);
            // Do something on the server side
            echo "New client connected\n";
            // Append the new connection to the clients array
 //           $clients[] = $newsock;
            socket_getpeername($newsock,$ip);
			
			if(count($ip_nya) >0)
			{
				
				if (($key = array_search($ip, $ip_nya)) !== false) 
				{
					
					unset($ip_nya[$key]);
					unset($clients[$key]);
//					unset($my_id[$key]);
				}
			}
//			array_diff($ip_nya,$ip);
//            echo "ip=".$ip;

            $ip_nya[] = $ip;
//get key id socket			
//			if(count($clients)>0)
			echo "count=".count($ip_nya);
			if(count($ip_nya)>0)
				$key= end(array_keys($ip_nya));
//			else
//                $key=0;
//				$key= end($ip_nya);
				
			$tes=1;	
			$clients[$key] = $newsock;
// 			echo "last key=". $key;
//print_r($ip_nya);
//print_r($clients);  
        }
    }

    // Polling for new messages
//    print_r($clients);
//    print_r($ip_nya);
      if(count($clients) == count($ip_nya))
        $jumku = count($clients);
      else
         $jumku=0;

//    echo "jumku=".count($clients)."\n";
	if($broadcast_status ==1)	
    	cekOutbox2SendSMS($db,$clients,$ip_nya,$my_id);
      
     if ($jumku>0)
    {
/*
		++$tes;
		
		if($tes==200)
		{
			$tes=0;
			$string_sms="test connection from server id=".$id."\n";
//			$tes_id =get_resid("123456",$clients,$my_id);
//			socket_write($tes_id,$string_sms,strlen($string_sms)) or die("Could not write output\n");		
		}
*/		
//       print_r($clients);
        foreach ($clients AS $k => $v)
        {
            // Check for new messages
//            echo "read=".$v."\n";

//cek outbox_int table to send sms and delete
/*
            if(in_array("192.168.100.99",$ip_nya) && $awal==0)
            {
            echo "cek outbox_int awal\n";
              $awal=1;
             cekOutbox2SendSMS($db,$clients,$ip_nya,$my_id);
            }
*/
            $string = "";
/*
            if ($char = socket_read($v, 1024)) 
			{
                $string .= $char;
            }
*/
     if( ($char = socket_read($v, 1024)) === false )
    {
         if( socket_last_error($v) == 10054)
              exit();
//      echo "socket_read() failed: reason: " . socket_strerror(socket_last_error($v)) . "\n";
//		init_socket();
 //      throw new Exception( sprintf( "Unable to write to socket: %s", socket_strerror( socket_last_error() ) ) );
    }
	else
		$string .= $char;

            // receive data socket
            if ($string)
            {
                echo "standby=".$k.":".trim($string)."=".strlen($string)."=".Date("H:i:s").">id=".$clients[$k]." ip=".$ip_nya[$k]."\n";
                
//				$string_sms="reply from server\n";
//				socket_write($v,$string_sms,strlen($string_sms)) or die("Could not write output\n");
//get id
				$id=substr($string,1,6);
//				echo "idnya=".$id;					

//id ews		
//			echo "tes=".$tes."\n";		
			if($tes==1)
			{	
				if (($key_id = array_search($id, $my_id)) !== false) 
				{
					echo "delete id_no=".$id." ke=".$key_id."\n";
					unset($my_id[$key_id]);
					$my_id[$key]=$id;
				}
				else
				$my_id[$key]=$id;

				$broadcast_status=1;
//				echo "lilik=".get_resid($id);
				$tes=0;
			}
//				$string_sms="reply from server id=".$id."\n";
//				$tes_id =get_resid($id,$clients,$my_id);
//				socket_write($tes_id,$string_sms,strlen($string_sms)) or die("Could not write output\n");
								
							if($string == "lagi" && $awal==1)
							{
				//                echo "cek outbox_int lagi\n";
							 cekOutbox2SendSMS($db,$clients,$ip_nya);
							}
							else if(trim($string) == "rst" && $string[0] != '#' )
							{
				//               print_r($client);
								echo "client socket close key=".$k."id=".$clients[$k]."ip=".$ip_nya[$k]."\n";
								socket_close($clients[$k]);
								unset($clients[$k]);
								unset($ip_nya[$k]);
				//                 print_r($client);
							 echo "client end socket close\n";
							}
							else if($string[0] == '#' )
							{
				//					echo "disini";
								$datanya = substr($string,1,strlen($string));
								Insert_Setting($db,$datanya);
				
							}
							else if($string[0] == '*')
							{
								$awal=0;
								Insert_Data($db,$string, $clients,$ip_nya,$tot_sms);
							}
							else if($string[0] == '&')
							{
								$awal=0;
								Insert_DataCek($db,$string, $clients,$ip_nya,$tot_sms);
							}
							else if($string[0] == '>')
							{
								if(count($clients) == count($ip_nya))
								$jumku = count($clients);
								else
								 $jumku=0;
								
								$id=substr($string,1,strlen($string));
							//					echo "idnya=".$my_id;					
							}
               else{}
            } else
            {
            }
        }
    }

    sleep(1);
}

// Close the master sockets
socket_close($sock);