<?php

//Der Awattar Strompreis Tarif 'Hourly' wird per API auf bis zu 24 Std in die Zukunft ausgelesen
# (man schaut <= 24 Std in die Zukunft )

$archiveID=IPS_GetInstanceListByModuleID("{43192F0B-135B-4CE7-A0A7-1475603F3060}");
#print_r($archiveID);
# wenn nicht vorhanden Variable anlegen und Status 'Loging' setzen ...
$ID_Boersenpreis_netto_Cent = CreateVariableByIdent($_IPS['SELF'], "Awattar_Hourly_Boersenpreis_netto_in_Cent", "Awattar Hourly Börsenpreis netto in Cent", 2,$archiveID);
#echo "ID_Boersenpreis_netto_Cent: ".$ID_Boersenpreis_netto_Cent."\n";
$ID_Strompreis_brutto = CreateVariableByIdent($_IPS['SELF'], "Awattar_Hourly_Strompreis_brutto_in_Euro", "Awattar Hourly Strompreis brutto in Euro", 2,$archiveID);
#echo "ID_Strompreis_brutto_Euro: ".$ID_Strompreis_brutto."\n";
$ID_Strompreis_brutto_Cent = CreateVariableByIdent($_IPS['SELF'], "Awattar_Hourly_Strompreis_brutto_in_Cent", "Awattar Hourly Strompreis brutto in Cent", 2,$archiveID);
#echo "ID_Strompreis_brutto_Cent: ".$ID_Strompreis_brutto_Cent."\n";
#... und Status 'Loging' setzen
#AC_SetLoggingStatus($archiveID[0], $ID_Boersenpreis_netto_Cent, true);
#AC_SetLoggingStatus($archiveID[0], $ID_Strompreis_brutto, true);
#AC_SetLoggingStatus($archiveID[0], $ID_Strompreis_brutto_Cent, true);

$Grundpreis = GetValue(41715); #hier wird eine Float Variable abgefragt, Angabe in Cent
#echo "Grundpreis: ".$Grundpreis."   ".$Grundpreis1."\n";
$out = "https://api.awattar.de/v1/marketdata";
$ch = curl_init($out);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
$ergebnis = curl_exec($ch);
$fehler = curl_error($ch);
curl_close($ch);
$awattar = json_decode($ergebnis,true);
#print_r($awattar);
#echo "Ergebnis: ".$ergebnis."\n";
#echo "awattar Count: ".count($awattar['data'])."\n";
if($ergebnis === false){
    echo 'Curl-Fehler: ' . curl_error($ch);
    echo $fehler;
}else{
    #geloggte Werte löschen
    AC_DeleteVariableData($archiveID[0], $ID_Boersenpreis_netto_Cent, time()-48*60*60, time());
    AC_DeleteVariableData($archiveID[0], $ID_Strompreis_brutto, time()-48*60*60, time());
    AC_DeleteVariableData($archiveID[0], $ID_Strompreis_brutto_Cent, time()-48*60*60, time());
    $n=0;
    do {
        $awattar_hourly[date("H",$awattar['data'][$n]['start_timestamp']/1000)] = (floatval($awattar['data'][$n]['marketprice'])*1.19/10);
        #echo " Timestamp: ".(time()-(24-$n)*60*60)." Value: ".$awattar_hourly[date('H',time()+$n*60*60)]." Std: ".date("H",$awattar['data'][$n]['start_timestamp']/1000)." Börse Netto: ".(($awattar['data'][$n]['marketprice'])/10)." Börse Brutto: ".(($awattar['data'][$n]['marketprice'])/10*1.19)." Strompreis (brutto) Euro: ".((($awattar['data'][$n]['marketprice'])*1.19/10+$Grundpreis)/100)." n: ".$n."\n";
        AC_AddLoggedValues($archiveID[0], $ID_Boersenpreis_netto_Cent, [['TimeStamp' => time()-(24-$n)*60*60,'Value' => $awattar_hourly[date('H',time()+$n*60*60)]],]);
        AC_AddLoggedValues($archiveID[0], $ID_Strompreis_brutto, [['TimeStamp' => time()-(24-$n)*60*60,'Value' => ($awattar_hourly[date('H',time()+$n*60*60)]+$Grundpreis)/100],]);
        AC_AddLoggedValues($archiveID[0], $ID_Strompreis_brutto_Cent, [['TimeStamp' => time()-(24-$n)*60*60,'Value' => ($awattar_hourly[date('H',time()+$n*60*60)]+$Grundpreis)],]);
        $n=$n+1;
        } while($n < count($awattar['data']));
    #print_r($awattar_hourly);
    #...und reagregieren
    AC_ReAggregateVariable($archiveID[0], $ID_Boersenpreis_netto_Cent);
    AC_ReAggregateVariable($archiveID[0], $ID_Strompreis_brutto);
    AC_ReAggregateVariable($archiveID[0], $ID_Strompreis_brutto_Cent);

}
function CreateVariableByIdent($id, $ident, $name, $type, $archiveID)
{
	$vid = @IPS_GetObjectIDByIdent($ident, $id);
	if($vid === false) {
		$vid = IPS_CreateVariable($type);
		IPS_SetParent($vid, $id);
		IPS_SetName($vid, $name);
		IPS_SetIdent($vid, $ident);
        AC_SetLoggingStatus($archiveID[0], $vid, true);
	}
	return $vid;
}