#!/usr/bin/php
<?
include "common.php";

$timezone = new DateTimeZone('Europe/Amsterdam');

//$time1 = strtotime("2024-10-26T22:00:00+00:00");
//$time2 = strtotime("2024-10-26T22:00:00");
//echo("time1=$time1 time2=$time2\n");
//echo("date1 ".date('Y-m-d H:i:s T', $time1)."\n");
//echo("date2 ".date('Y-m-d H:i:s T', $time2)."\n");
//echo("gmdate1 ".gmdate('Y-m-d\TH:i:sP', $time1)."\n");
//echo("gmdate2 ".gmdate('Y-m-d\TH:i:sP', $time2)."\n");
//echo("gmdate0 2024-10-26T22:00:00+00:00\n");
//echo("gmdateurl ".urlencode(gmdate('Y-m-d\TH:i:s.000\Z', $time1))."\n");
//echo("gmdateurl 2024-11-03T23%3A00%3A00.000Z\n");

$time_start = strtotime("today + 1 day");
$time_next = strtotime("today + 2 days");
//$time_start = strtotime("yesterday + 1 day");
//$time_next = strtotime("yesterday + 2 days");
//echo("date_start ".date('Y-m-d H:i:s T', $time_start)."\n");
//echo("gmdate_start ".gmdate('Y-m-d\TH:i:s.000\Z', $time_start)."\n");
$start = urlencode(gmdate('Y-m-d\TH:i:s.000\Z', $time_start));
//echo("date_next ".date('Y-m-d H:i:s T', $time_next)."\n");
//echo("gmdate_next ".gmdate('Y-m-d\TH:i:s.000\Z', $time_next)."\n");
$end = urlencode(gmdate('Y-m-d\TH:i:s.000\Z', $time_next));

$already = db_single_field("SELECT epex_id FROM epex WHERE epex_start = ?", $time_next - 60*60);
if ($already) {
	# this is fine, mail does not need to log it
	exit;
	# fatal("we have these values already");
}

//$url1 = "https://mijn.easyenergy.com/nl/api/tariff/getapxtariffs?startTimestamp=2024-11-02T23:00:00.000Z&endTimestamp=2024-11-03T23:00:00.000Z&grouping=";
//$url2 = "https://mijn.easyenergy.com/nl/api/tariff/getapxtariffs?startTimestamp=$start&endTimestamp=$end&grouping=";

$url = "https://mijn.easyenergy.com/nl/api/tariff/getapxtariffs?startTimestamp=$start&endTimestamp=$end&grouping=";
echo($url."\n");
$ch = curl_init($url);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);

$last_command_id = db_single_field("SELECT commands.command_id FROM commands LEFT JOIN commands AS next_commands ON commands.command_id = next_commands.prev_command_id WHERE next_commands.command_id IS NULL");
echo("last_command_id=$last_command_id\n");
$check = db_single_field("SELECT command_start FROM commands WHERE command_id = $last_command_id");
if ($check < $time_next) db_exec("INSERT INTO commands ( prev_command_id, command_start, command ) VALUES ( $last_command_id, $time_next, 'IDLE' )");
//exit;
//echo($url1."\n");
//echo($url2."\n");
//exit;
//$time = strtotime("2024-10-26T22:00:00+00:00");
//echo($time."\n");
//echo("date ".date('Y-m-d H:i:s T', $time)."\n");


$encoded = curl_exec($ch);
$json = json_decode($encoded);

if (!count($json)) fatal("no data yet");

foreach ($json as $elt) {
	print_r($elt);
	$time = strtotime($elt->Timestamp);
	echo("date ".date('Y-m-d H:i:s T', $time)."\n");
	echo("find epex_id with time=$time\n");
	$epex_id = db_single_field('SELECT epex_id FROM epex WHERE epex_start = ?', $time);
	echo("find prev epex_id= $time - 24*60*60\n");
	$prev_epex_id = db_single_field('SELECT epex_id FROM epex WHERE epex_start = ?',
		$time - 24*60*60);
	if (!$epex_id) {
		echo("insert\n");
		db_exec('INSERT INTO epex ( prev_epex_id, epex_start, epex_price ) VALUES ( ?, ?, ? )',
			$prev_epex_id?$prev_epex_id:NULL, $time, "{$elt->TariffReturn}");
		$epex_id = db_last_insert_id();
	} else {
		db_exec('UPDATE epex SET epex_price = ? WHERE epex_id = ?', "{$elt->TariffReturn}", $epex_id);
	}
	$next_epex_id = db_single_field('SELECT epex_id FROM epex WHERE epex_start = ?',
               	$time + 60*60);
	if (!$next_epex_id) db_exec('INSERT INTO epex ( prev_epex_id, epex_start ) VALUES ( ?, ? )', $epex_id, $time + 60*60);
	//echo($elt->Timestamp."\n");
	//exit;
}
//print_r($json);

//k
//db_exec("UPDATE commands SET command_start = $time_next WHERE command_id = $last_command_id");


?>