'9') || ($data[$ch] < '0')){
unset($ch,$data);
die();
}
}
//バス停番号
$bus=0;
//現在のスケジュール
$now_schedule = rtrim(file_get_contents("./maintenance/data/location/time_schedule".$data[0].$data[1].".txt", FILE_IGNORE_NEW_LINES));
//$now_schedule = file_get_contents("./data/time_schedule".$data[0].$data[1].".txt", FILE_IGNORE_NEW_LINES);
//始発と終点の抽出
$max_bin=1;//配列の添え字を便番号に合わせるために1を加算
$fileName = "./maintenance/data/location/bin_data".$data[0].$data[1].".txt";
//$fileName = "./data/bin_data".$data[0].$data[1].".txt";
$file = fopen($fileName, "r");
while (!feof($file)) {
$str = fgets($file);
$str = trim($str);
$data_array = explode(",", $str);
$r_id[$max_bin]=$data_array[0];
$now_bin[$max_bin]=$data_array[1];
$start_bus[$max_bin]=$data_array[2];
$end_bus[$max_bin]=$data_array[3];
$bus_time[$max_bin]=intval(str_replace(":","",$data_array[4]));
if($_GET['debug']==1){
echo "便：".$max_bin."
";
echo "次の便の始発：".$start_bus[$max_bin]."
";
echo "路線番号：".$r_id[$max_bin]."
";
echo "便番号：".$now_bin[$max_bin]."
";
echo "終点：".$end_bus[$max_bin]."
";
echo "運行開始時刻：".$bus_time[$max_bin]."
";
echo "
";
}
$max_bin++;
}
fclose($file);
$max_bin--;//加算した分を減算
unset($fileName,$file,$str,$data_array);
//各ルートの運行状態(0:運行終了,1:運行中,2:運行準備,3:点検など,4:運休)
$status = rtrim(file_get_contents("./maintenance/data/location/status0".$r_id[$now_schedule].".txt", FILE_IGNORE_NEW_LINES));
//$status = file_get_contents("./data/status0".$r_id[$now_schedule].".txt", FILE_IGNORE_NEW_LINES);
//現在のバス停通過番号
$now_pass = rtrim(file_get_contents("./maintenance/data/location/pass_bus0".$r_id[$now_schedule].".txt", FILE_IGNORE_NEW_LINES));
//$now_pass = file_get_contents("./data/pass_bus0".$r_id[$now_schedule].".txt", FILE_IGNORE_NEW_LINES);
//現在の便データ
$bin_data = rtrim(file_get_contents("./maintenance/data/location/bin0".$r_id[$now_schedule].".txt", FILE_IGNORE_NEW_LINES));
//$bin_data = file_get_contents("./data/bin0".$r_id[$now_schedule].".txt", FILE_IGNORE_NEW_LINES);
//if($bin_data!=$now_bin[$now_schedule]){
// die("スケジュールと異なっている");
//}
if($_GET['debug']==2){
/*---------送信されたデータを出力-------*/
print('
'.' 現在のスケジュール番号:'.$now_schedule.'
');
print('
'.' 現在の路線番号:'.$r_id[$now_schedule].'
');
print('
'.' 現在の運行状況:'.$status.'
');
print('
'.' 現在の便番号:'.$now_bin[$now_schedule].'
');
print('
'.' 現在の便データ:'.$bin_data.'
');
print('
'.' 現在のバス停通過番号:'.$now_pass.'
');
/*------------------------------------------*/
}
/*---------送信されたデータを整理する-------*/
$day = date("md");
//$r_id=$data[0].$data[1];
$lat=$data[8].$data[9].".".$data[10].$data[11].$data[12].$data[13].$data[14].$data[15];
$lng=$data[16].$data[17].$data[18].".".$data[19].$data[20].$data[21].$data[22].$data[23].$data[24];
$time = $data[2].$data[3].$data[4].$data[5].$data[6].$data[7];
$cal_time = intval(date($data[2].$data[3].$data[4].$data[5]));//<-何時何分までの時刻を取り出す
/*------------------------------------------*/
/*------------通過情報のチェック------------*/
$con=@mysql_connect("localhost","event","L523GpA");
if(!$con){
unset($con,$data,$r_id,$lat,$lng,$time,$day);
die("DB接続エラー");
}
$select_db=@mysql_select_db("eventdb");
if(!$select_db){
unset($con,$select_db,$r_id,$lat,$lng,$time,$day);
die ("DB選択エラー");
}
@mysql_query("set names utf8");
//$sql="select busstop_id,bus_name,stop_lat,stop_lng from nbus_master inner join nbus_view using(r_id,busstop_id) where r_id=".$r_id." and view_bin=".$now_bin." and busstop_id >= ".$now_pass." and view_fg=1 group by bus_name order by busstop_id asc";
//現在通過したバス停とこれから向かうバス停をunionで連結して表示させる
$sql="select busstop_id,bus_name,stop_lat,stop_lng from nbus_master where r_id=".$r_id[$now_schedule]." and busstop_id = ".$now_pass."
union
select busstop_id,bus_name,stop_lat,stop_lng from nbus_master inner join nbus_view using(r_id,busstop_id) where r_id=".$r_id[$now_schedule]." and view_bin=".$now_bin[$now_schedule]." and busstop_id > ".$now_pass." and view_fg=1 group by bus_name order by busstop_id asc";
$res = mysql_query($sql);
if($now_pass==0){
$check_bus=1;
}else{
$check_bus=0;
}
for($i = $check_bus;$row = mysql_fetch_array($res);$i++){
$stop_id[$i]=intval($row['busstop_id']);
$stop_name[$i]=$row['bus_name'];
$stop_lat[$i] = $row['stop_lat'];
$stop_lng[$i] = $row['stop_lng'];
if($_GET['debug']==1){
echo $stop_id[$i].",".$stop_name[$i].",".$stop_lat[$i].",".$stop_lng[$i]."
";
}
}
mysql_free_result($res);
$close=@mysql_close($con);
if(!$close){
unset($con,$select_db,$res,$sql,$row,$close,$r_id,$lat,$lng,$time,$day);
die("DB切断エラー");
}
unset($con,$select_db,$res,$sql,$row,$close);
//バス停範囲にいるかどうか判断(約20m四方)
//$pass_fg (1:次のバス停，0:それ以外)
$pass_fg=0;
$cr = array(" 着"," 発");
/*--------------------------次に向かうバス停かを判別----------------------*/
for($j=1;$j>=0;$j--){
if($status==1 && ($lat<$stop_lat[$j]+0.000264)&&($lng<$stop_lng[$j]+0.000264) && ($lat>$stop_lat[$j]-0.000264)&&($lng>$stop_lng[$j]-0.000264)){
if($_GET['debug']==2){
echo "次に向かうバス停
";
}
$bus = $stop_id[$j];
$filepath = "./maintenance/data/location/pass_bus0".$r_id[$now_schedule].".txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,$bus,strlen($bus));//通過バス停情報を書き込む
}
fclose($fp);
$pass_fg=1;
break;
}
}
/*----------------------------------------------------------------------------*/
/*--------------------------通過情報に抜けがあった場合の更新処理----------------------*/
if($pass_fg==0){
for($j = 0;$j < $i;$j++){
if(($lat<$stop_lat[$j]+0.000264)&&($lng<$stop_lng[$j]+0.000264) && ($lat>$stop_lat[$j]-0.000264)&&($lng>$stop_lng[$j]-0.000264)){
$array_key=array_search($now_pass,$stop_id);
if($status==1&&(strpos(str_replace($cr,"",$stop_name[$j]),str_replace($cr,"",$stop_name[$array_key]))===false)){
$bus = $stop_id[$j];
echo $stop_name[$j].":".$stop_name[1]."
";
echo $bus-$stop_id[1]."
";
if(($bus-$stop_id[1])>=1){//何個抜けから許可するかを設定
if($_GET['debug']==2){
echo "それ以外の更新
";
}
$filepath = "./maintenance/data/location/pass_bus0".$r_id[$now_schedule].".txt";
//$filepath = "./data/pass_bus0".$r_id[$now_schedule].".txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,$bus,strlen($bus));//通過バス停情報を書き込む
}
fclose($fp);
}
break;
}
}
}
}
/*-----------------------------------------------------------------------------*/
/*-------------------DBの更新---------------*/
$con=@mysql_connect("localhost","event","L523GpA");
if(!$con){
unset($data,$r_id,$lat,$lng,$time,$day);
die("DB接続エラー");
}
$select_db=@mysql_select_db("eventdb");
if(!$select_db){
unset($con,$select_db,$r_id,$lat,$lng,$time,$day);
die ("DB選択エラー");
}
@mysql_query("set names utf8");
//echo "update nbus_log set log_lat='".$lat."',log_lng='".$lng."',log_time='".$time."',log_day='".$day."' where r_id=".$r_id;
$res= mysql_query("update nbus_log set log_lat ='".$lat."',log_lng ='".$lng."',log_time='".$time."',log_day='".$day."' where r_id=".$r_id[$now_schedule]." and busstop_id=".$bus);
if($res === true){
mysql_query("commit");
}else{
mysql_query("rollback");
}
$close=@mysql_close($con);
if(!$close){
unset($con,$select_db,$res,$sql,$row,$close,$r_id,$lat,$lng,$time,$day);
die("DB切断エラー");
}
/*------------------------------------------*/
/*--------------------運行状況の更新-------------------*/
if($bus>=$end_bus[$now_schedule] && $status==1){
if($_GET['debug']==2){
echo "便番号の更新
";
}
if($now_schedule==$max_bin){
if($_GET['debug']==2){
echo "運行終了
";
}
$status=0;
$filepath = "./maintenance/data/location/status0".$r_id[$now_schedule].".txt";
//$filepath = "./data/status0".$r_id[$now_schedule].".txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,$status,strlen($status));//運行状況の書き込み
}
fclose($fp);
}else{
if($_GET['debug']==2){
echo "運行準備
";
}
$status=2;
$filepath = "./maintenance/data/location/status0".$r_id[$now_schedule].".txt";
//$filepath = "./data/status0".$r_id[$now_schedule].".txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,$status,strlen($status));//運行状況の書き込み
}
fclose($fp);
$filepath = "./maintenance/data/location/bin0".$r_id[$now_schedule].".txt";
//$filepath = "./data/bin0".$r_id[$now_schedule].".txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,($now_bin[$now_schedule]+1),strlen(($now_bin[$now_schedule]+1)));//便情報を書き込む
}
fclose($fp);
$filepath = "./maintenance/data/location/pass_bus0".$r_id[$now_schedule].".txt";
//$filepath = "./data/pass_bus0".$r_id[$now_schedule].".txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,$start_bus[$now_schedule]);
//@fwrite($fp,0);
}
fclose($fp);
$now_schedule++;
$filepath = "./maintenance/data/location/time_schedule".$data[0].$data[1].".txt";
//$filepath = "./data/time_schedule".$data[0].$data[1].".txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,$now_schedule,strlen($now_schedule));//運行状況の書き込み
}
fclose($fp);
}
}else if($status==2 && $now_pass!=0){//始発のバス停に到着時に運行準備から運行中への移行
if($_GET['debug']==2){
echo $cal_time.":".$bus_time[$now_schedule]."
";
}
if($cal_time>=$bus_time[$now_schedule]){
if($_GET['debug']==2){
echo $r_id[$now_schedule].":".$now_bin[$now_schedule]."便 運行開始
";
}
$status=1;
$filepath = "./maintenance/data/location/status0".$r_id[$now_schedule].".txt";
//$filepath = "./data/status0".$r_id[$now_schedule].".txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,$status,strlen($status));//運行状況の書き込み
}
fclose($fp);
}
}else if($status==0){
if($cal_time<=$bus_time[1]){//第1便の運行時刻前の信号をリセット信号とする
if($_GET['debug']==2){
echo "運行状況のリセット
";
}
$status=2;
$now_schedule=1;
$filepath = "./maintenance/data/location/time_schedule05.txt";
//$filepath = "./data/time_schedule05.txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,$now_schedule,strlen($now_schedule));//運行状況の書き込み
}
fclose($fp);
$filepath = "./maintenance/data/location/time_schedule06.txt";
//$filepath = "./data/time_schedule06.txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,$now_schedule,strlen($now_schedule));//運行状況の書き込み
}
fclose($fp);
$filepath = "./maintenance/data/location/bin03.txt";
//$filepath = "./data/bin05.txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,1);//便情報を書き込む
}
fclose($fp);
$filepath = "./maintenance/data/location/bin04.txt";
//$filepath = "./data/bin05.txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,1);//便情報を書き込む
}
fclose($fp);
$filepath = "./maintenance/data/location/bin05.txt";
//$filepath = "./data/bin05.txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,1);//便情報を書き込む
}
fclose($fp);
$filepath = "./maintenance/data/location/bin06.txt";
//$filepath = "./data/bin06.txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,1);//便情報を書き込む
}
fclose($fp);
$filepath = "./maintenance/data/location/pass_bus03.txt";
//$filepath = "./data/pass_bus06.txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,1);
}
fclose($fp);
$filepath = "./maintenance/data/location/pass_bus04.txt";
//$filepath = "./data/pass_bus06.txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,1);
}
fclose($fp);
$filepath = "./maintenance/data/location/pass_bus05.txt";
//$filepath = "./data/pass_bus05.txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,22);
}
fclose($fp);
$filepath = "./maintenance/data/location/pass_bus06.txt";
//$filepath = "./data/pass_bus06.txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,3);
}
fclose($fp);
$filepath = "./maintenance/data/location/status03.txt";
//$filepath = "./data/status03.txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,$status,strlen($status));//運行状況の書き込み
}
fclose($fp);
$filepath = "./maintenance/data/location/status04.txt";
//$filepath = "./data/status04.txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,$status,strlen($status));//運行状況の書き込み
}
fclose($fp);
$filepath = "./maintenance/data/location/status05.txt";
//$filepath = "./data/status05.txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,$status,strlen($status));//運行状況の書き込み
}
fclose($fp);
$filepath = "./maintenance/data/location/status06.txt";
//$filepath = "./data/status06.txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,$status,strlen($status));//運行状況の書き込み
}
fclose($fp);
}
}
/*-----------------------------------------------------*/
/*----------------運行状況の更新(休憩や給油などの特殊パターン)---------------*/
$bin_cd_fg=0;
if((($lat<36.595389+0.000264)&&($lng<136.914085+0.000264) && ($lat>36.595389-0.000264)&&($lng>136.914085-0.000264)) && $status==1){
$bin_cd_fg=1;
}else if((($lat<36.587233+0.000264)&&($lng<136.919088+0.000264) && ($lat>36.587233-0.000264)&&($lng>136.919088-0.000264)) && $status==1){
$bin_cd_fg=1;
}
if($bin_cd_fg==1){
if($_GET['debug']==2){
echo "便番号の更新2
";
}
if($now_schedule==$max_bin){
if($_GET['debug']==2){
echo "運行終了2
";
}
$status=0;
$filepath = "./maintenance/data/location/status0".$r_id[$now_schedule].".txt";
//$filepath = "./data/status0".$r_id[$now_schedule].".txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,$status,strlen($status));//運行状況の書き込み
}
fclose($fp);
}else{
if($_GET['debug']==2){
echo "運行準備
";
}
$status=2;
$filepath = "./maintenance/data/location/status0".$r_id[$now_schedule].".txt";
//$filepath = "./data/status0".$r_id[$now_schedule].".txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,$status,strlen($status));//運行状況の書き込み
}
fclose($fp);
$filepath = "./maintenance/data/location/bin0".$r_id[$now_schedule].".txt";
//$filepath = "./data/bin0".$r_id[$now_schedule].".txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,($now_bin[$now_schedule]+1),strlen(($now_bin[$now_schedule]+1)));//便情報を書き込む
}
fclose($fp);
$filepath = "./maintenance/data/location/pass_bus0".$r_id[$now_schedule].".txt";
//$filepath = "./data/pass_bus0".$r_id[$now_schedule].".txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,$start_bus[$now_schedule]);
//@fwrite($fp,0);
}
fclose($fp);
$now_schedule++;
$filepath = "./maintenance/data/location/time_schedule".$data[0].$data[1].".txt";
//$filepath = "./data/time_schedule".$data[0].$data[1].".txt";
$fp = fopen($filepath, "w");
if(flock($fp,LOCK_EX)){
ftruncate($fp,0);
@fwrite($fp,$now_schedule,strlen($now_schedule));//運行状況の書き込み
}
fclose($fp);
}
}
/*-----------------------------------------------------*/
if($_GET['debug']==2){
/*---------送信されたデータを出力-------*/
print('
送信データについて
');
print('
'.' 路線番号:'.$r_id[$now_schedule].'
');
print('
'.' 緯度:'.$lat.'
');
print('
'.' 経度:'.$lng.'
');
print('
'.' 日付:'.$day.'
');
print('
'.' 時刻:'.$time.'
');
print('
'.' 通過バス停:'.$bus.'番
');
print('
'.' 最新の運行状況:'.$status.'
');
print('
'.' 最新の便番号:'.$now_bin[$now_schedule].'
');
print('
'.' 最終の便番号:'.$max_bin.'
');
print('
');
/*------------------------------------------*/
}
/*---------送信ログデータを出力(csv形式)-------*/
$filepath = "./maintenance/data/".$day."_log".$r_id[$now_schedule].".csv";
//$filepath = "./data/".$day."_log".$r_id[$now_schedule].".csv";
$data=$r_id[$now_schedule].",".$bus.",".$lat.",".$lng.",".$day.",".$time."\n";
//echo $data;
if (!file_exists($filepath)) {
$fp = fopen($filepath, "w");
chmod($filepath,0666);
}else{
$fp = fopen($filepath, "a");
}
if(flock($fp,LOCK_EX)){
@fwrite($fp, $data);//通過バス停情報を書き込む
}
fclose($fp);
/*------------------------------------------*/
unset($stop_name,$stop_id,$stop_lat,$stop_lng);
unset($status,$filepath,$fp,$start_bus,$end_bus,$max_bin,$now_bin,$now_pass,$cal_time,$bus_time,$pass_fg,$cr);
unset($con,$select_db,$res,$sql,$row,$close,$lat,$time,$day,$r_id,$bus,$data,$now_schedule,$bin_cd_fg);
?>