<?php
include "/var/www/rennergy/conf/con_conf.php";

error_reporting(E_ALL & ~E_NOTICE);

echo "TCP/IP Connection\n";

/* Get the port for the WWW service. */
//$service_port = getservbyname('www', 'tcp');
$service_port = "23";

/* Get the IP address for the target host. */
//$address = gethostbyname('www.example.com');
$address = "192.168.1.25";

/* Create a TCP/IP socket. */
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($socket === false) {
    echo "socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "\n";
} else {
    echo "OK.\n";
}

echo "Attempting to connect to '$address' on port '$service_port'...";
$result = socket_connect($socket, $address, $service_port);
if ($result === false) {
    echo "socket_connect() failed.\nReason: ($result) " . socket_strerror(socket_last_error($socket)) . "\n";
} else {
    echo "OK.\n";
}

//$in = "HEAD / HTTP/1.1\r\n";
//$in .= "Host: www.example.com\r\n";
//$in .= "Connection: Close\r\n\r\n";
$out = '';

//echo "Sending HTTP HEAD request...";
//socket_write($socket, $in, strlen($in));
//echo "OK.\n";

$anzwerte = "170";

while ($out = socket_read($socket, 2048)) {
	$values = explode(" ", $out);
//	print_r(array_values($values));
	$now = date("Y-m-d H:i:s");
	$replace_pm = array(0 => $now);
	$values = array_replace($values, $replace_pm);
	$leer = array_pop($values);

	$count = count($values);

        if ($count > "$anzwerte"){
                $count = count($values) -1;
//              echo "Eins abgezogen! $count \n";
        }
        elseif($count != "$anzwerte"){
//              echo "Count nicht $anzwerte \n";
        }

        $i = "163";
        if($count != $anzwerte){
//              echo "Schleife nicht ausführen Count nicht $anzwerte!!! \n";
                }
        else {
	        while($i <= $count){
        	        if ($count != "$anzwerte"){ echo "Nichts machen \n";}
                	else{
	                	$replace_fvalue = array($i => "unhex('$values[$i]')");
	        	        $values = array_replace($values, $replace_fvalue);
        	        	$i++;
	        	        }
			}
	}

	$fvalues = "DEFAULT, '";
	$fvalues .= implode("', '", $values);
//	$fvalues = substr($fvalues, 0, -4);
//	echo "$fields \n\n";
//	echo $fvalues;
//	print_r(array_values($values));
//	print_r($values); 
	$fvalues = str_replace("'unhex", "unhex", $fvalues);
	$fvalues = str_replace(")'", ")", $fvalues);
	$query = "insert into t_raw_data values ($fvalues);";
	$con->query($query);
/*
	if ($con->query($query) === TRUE){
//		echo "New Record created successfully!\n";
	} else{
		 echo "Error: " . $sql . "\n" . $conn->error;
		}
*/
	}

//$con->close();

echo "Closing socket...";
socket_close($socket);
echo "OK.\n\n";
?>