<?php
$data = isset($_GET["dt"]) ? htmlspecialchars($_GET["dt"]) : "";
if (strcmp($data, "") == 0)
	exit(1);

$fp = fopen("./log/log.txt", "a");
fwrite($fp, ">". $data. "\n");
fclose($fp);

$conn = pg_connect("
host	=	192.168.100.153
dbname	=	cnbs
user	=	postgres
password=	am#71ZJ*
");
if (!$conn)
	exit(1);
$rows = explode("~", $data);
$datacnt = count($rows) - 1;
for($i = 0; $i < $datacnt; $i++)
{
	if (strlen($rows[$i]) == 18)
	{
		$tagid = substr($rows[$i], 0, 7);
		$state = substr($rows[$i], 7, 1);
		$recvid = substr($rows[$i], 8, 2);
		$rssi = substr($rows[$i], 10, 2);
		
		if (strcmp($state, "0") == 0 || strcmp($state, "4") == 0 || strcmp($state, "8") == 0 || strcmp($state, "F") == 0)
		{
			$selectTag = "SELECT tagid FROM nakagusuku.worker_position WHERE tagid='". $tagid. "';";
			$response = pg_query($conn, $selectTag);
			if (pg_num_rows($response) > 0)
			{
				$updateTag = "UPDATE nakagusuku.worker_position SET state='". $state. "', recvid='". $recvid. "',update=current_timestamp WHERE tagid='". $tagid. "';";
				$response = pg_query($conn, $updateTag);
			}
			else
			{
				$insertTag = "INSERT INTO nakagusuku.worker_position (dispno, tagid, state, recvid, update, regdate) VALUES (DEFAULT, '". $tagid. "','". $state. "','". $recvid. "',current_timestamp, current_timestamp);";
				$response = pg_query($conn, $insertTag);
			}
		}
		$loginsert = "INSERT INTO nakagusuku.worker_log (tagid, state, recvid, rssi, regdate) VALUES ('". $tagid. "','". $state. "','". $recvid. "','". $rssi. "',current_timestamp);";
		$response = pg_query($conn, $loginsert);
	}
}
pg_close($conn);
?>