<?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)) {
	$value = explode(" ", $out);
//	print_r(array_values($value));
	$now = date("Y-m-d H:i:s");
	$replace_pm = array(0 => $now);
	$value = array_replace($value, $replace_pm);
	$leer = array_pop($value);

	$count = count($value);

        if ($count > "$anzwerte"){
                $count = count($value) -1;
//              echo "Eins abgezogen! $count \n";
        }
        elseif($count != "$anzwerte"){
//              echo "Count nicht $anzwerte \n";
        }
//      echo "nach abzug -1: $count \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(''$value[$i]')");
        	        $values = array_replace($value, $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_short_data values (DEFAULT, '$value[0]', '$value[1]', '$value[2]', '$value[3]', '$value[4]', '$value[5]', '$value[6]', '$value[7]', '$value[8]', '$value[12]', '$value[13]', '$value[17]', '$value[18]', '$value[19]', '$value[20]', '$value[21]', '$value[24]', '$value[26]', '$value[50]', '$value[60]' );";
//	echo $query;
	$con->query($query);
/**
	if ($con->query($query) === TRUE){
		echo "New Record created successfully!\n";
	} else{
		 echo "Error: " . $con . "\n" . $con->error;
		}
**/
	}
//$con->close();

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