<?php
$port = 51239;

$socket = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
socket_bind($socket, '0.0.0.0', $port);


//CSV出力先
$output[0] = "/www/upfile/SEADOM7/1.csv";
$output[1] = "/www/upfile/SEADOM7/2.csv";
$output[2] = "/www/upfile/SEADOM7/3.csv";

$log_output_dir = "/www/upfile/SEADOM7/log/";

for (;;) {
    socket_recvfrom($socket, $buf, 1024, 0, $remoteAddr, $remotePort);

	$buf = str_replace(array("\r\n", "\r", "\n"), '',  $buf);
	$data_split = explode(",",$buf);
	$buf2 = $data_split[0] ."," .$data_split[1] ."," .$data_split[2] ."," .$data_split[3] ."," .$data_split[4] ."," .$data_split[5] ."," .$data_split[6];
	$buf3 = $data_split[0] ."," .$data_split[7] ."," .$data_split[8] ."," .$data_split[9] ."," .$data_split[4] ."," .$data_split[5] ."," .$data_split[6];

	$fp1 = fopen($output[0],"w");
	fwrite($fp1,$buf);
	fclose($fp1);
	
	$fp2 = fopen($output[1],"w");
	fwrite($fp2,$buf2);
	fclose($fp2);
	
	$fp3 = fopen($output[2],"w");
	fwrite($fp3,$buf3);
	fclose($fp3);

	//1時間ごとにログを保存
	$unix_time = strtotime($data_split[0]);
	$log_file_name = date("YmdH" ,$unix_time) .".csv";
	$log_output_path = $log_output_dir .$log_file_name;
	
	if (file_exists($log_output_path))
	{
		$fp_log = fopen($log_output_path,"a");
		fwrite($fp_log,$buf ."\n");
		fclose($fp_log);
	}
	else
	{
		$fp_log = fopen($log_output_path,"w");
		fwrite($fp_log,$buf ."\n");
		fclose($fp_log);
	}

}

//nohup php ./udp.php < /dev/null > batchout.log 2> batcherr.log &
?>