<?

// Plugwise Skript Version 0.2
// Von: Axel Philippsn
// Datum: 04.03.2012
// Basiert auf der Vorarbeit von
// 1) Maarten Damen (http://www.maartendamen.com/wp-content/uploads/downloads/2010/08/Plugwise-unleashed-0.1.pdf) und
// 2) Jannis (http://www.ip-symcon.de/forum/f53/plugwise-ohne-server-direkt-auslesen-schalten-17348/)
// 3) Funktionen von Brownsons IPSInstaller (http://www.ip-symcon.de/forum/f74/ipsinstaller-einige-hilfreiche-scripts-autom-installation-13228/)

// Noch realisieren:
// Schalten über Variable statt WebFront
// Gesamtverbrauch?

// include("IPSInstaller.ips.php");

// Konfiguration
$REGVAR = 38691 /*[System\Plugwise\RegVar Plugwise]*/; // ID der Registervariable


// ab hier muß nicht geändert werden
$idCatCircles = CreateCategory("Circles",IPS_GetParent($IPS_SELF),0);
$NetworkID = GetValueString (CreateVariable("NetworkID", 3, IPS_GetParent($IPS_SELF) ,0,""));

Switch ($_IPS['SENDER'])
	{

	Case "Execute":

		// init
		SendPlugwiseCommand("000A",$REGVAR);

		// Kategorien für Circles Idents aus Beschreibung zuweisen (damit sie später über CircleID angesprochen werden können
		foreach(IPS_GetChildrenIDs($idCatCircles) as $item){
			$id_info = IPS_GetObject($item);
			IPS_SetIdent ($item, $NetworkID.$id_info['ObjectInfo']);
		}

		break;

	Case "Variable":
		break;

	Case "TimerEvent":

		// Alle Circles durchlaufen und Status lesen
		foreach(IPS_GetChildrenIDs($idCatCircles) as $item){   // alle Unterobjekte
		    $id_info = IPS_GetObject($item);
		    // PRINT $id_info['ObjectName']." - ".$id_info['ObjectType']." - ".$id_info['ObjectInfo']."\n\n";
		    SendPlugwiseCommand("0012".$NetworkID.$id_info['ObjectInfo'],$REGVAR);
		    // Sleep(2);
		    SendPlugwiseCommand("0023".$NetworkID.$id_info['ObjectInfo'],$REGVAR);
		    // Sleep(1);
		}
		break;

	Case "WebFront":
	   // Zum schalten im Webfront
	   $id = IPS_GetParent($_IPS['VARIABLE']);
		$id_info = IPS_GetObject($id);
		if ($_IPS['VALUE'] == 1) {$action = 1;} else {$action = 0;}
		$cmd = "0017".$NetworkID.$id_info['ObjectInfo']."0".$action;
	   SendPlugwiseCommand($cmd,$REGVAR);

		// Sofort Feedback geben - aber besser auskommentieren und auf Rückmeldung des Circles warten
	   // SetValueBoolean($_IPS['VARIABLE'], $_IPS['VALUE']);

		break;

	Case "RegisterVariable":
		$buf = $IPS_VALUE;
		switch ((substr($buf,0,4)))
			{
			case "0000":         //Befehl vom Stick empfangen
				switch ((substr($buf,8,4)))
				{
					case "00C1":  //Schauen ob alles empfangen wurde
		 				// print "Befehl von Stick empfangen";
						break;
					case "00D8":  //eingeschaltet
		 				// print "Eingeschaltet MAC".substr($buf,12,16);
						$myCat = IPS_GetObjectIDByIdent(substr($buf,12,16), $idCatCircles);
						SetValue(IPS_GetVariableIDByName ("State", $myCat),True);

						// Sofort Verbrauch abfragen
						// SendPlugwiseCommand(substr($buf,12,16),$REGVAR);

						break;
					case "00DE":  //ausgeschaltet
						// print "Ausgeschaltet MAC".substr($buf,12,16);
						$myCat = IPS_GetObjectIDByIdent(substr($buf,12,16), $idCatCircles);
						SetValue(IPS_GetVariableIDByName ("State", $myCat),False);

						// Sofort Verbrauch abfragen
						// SendPlugwiseCommand(substr($buf,12,16),$REGVAR);

						break;
					case "00E1":  //ausgeschaltet
						print "Achtung Befehl nicht vom Circle bestätigt: ".$buf;
						break;
					default:
						print "Fehler von Stick";  //bei allem anderen
				}
				break;

			case "0011":  // Init
				// print "Die Sequenznr: ".substr($buf,4,4)."\r\n";
				// print "MC Adresse: ".substr($buf,8,16);
				// MC Adresse: 000D6F0000C3CA8E
				// Stick: C3CE5C

				// Write NetworkID
				SetValueString(CreateVariable("NetworkID", 3, IPS_GetParent($IPS_SELF),0,""),substr($buf,8,10));
				
				// Kalibrierungsdaten aller Circles abrufen
				foreach(IPS_GetChildrenIDs($idCatCircles) as $item){   // alle Unterobjekte
				    $id_info = IPS_GetObject($item);
				    SendPlugwiseCommand("0026".$NetworkID.$id_info['ObjectInfo'],$REGVAR);
				}

				break;

			case "0013":   //Verbrauch
			   $mcID = substr($buf,8,16);
				$myCat = IPS_GetObjectIDByIdent($mcID, $idCatCircles);
				$pulse 	= substr($buf,28,4);

				If ($pulse == "FFFF") {
				   // Circle ausgeschaltet, meldet FFFF
					SetValue(CreateVariable("Watt", 2, $myCat, 0, "~Watt.3680", 0), 0);
				} else {

					// print IPS_GetName ($myCat)."\r\n";
					// print "Die Sequenznr: ".substr($buf,4,4)."\r\n";
					// print "MC Adresse: ".substr($buf,8,16)."\r\n";
					// print "Pulse/s : ".substr($buf,24,4)."\r\n";
					// print "Pulse/8s: ".substr($buf,28,4)."\r\n";
					// print "Pulse gesamt: ".substr($buf,32,8)."\r\n";

					$gaina	= GetValueFloat(IPS_GetVariableIDByName("gaina", $myCat));
					$gainb	= GetValueFloat(IPS_GetVariableIDByName("gainb", $myCat));
					$offTotal	= GetValueFloat(IPS_GetVariableIDByName("offTotal", $myCat));
					$offNoise	= GetValueFloat(IPS_GetVariableIDByName("offNoise", $myCat));

					// Aktueller Verbrauch in Watt ermitteln
					$value 	= hexdec($pulse)/8;
					$out 		= (pow(($value+$offNoise),2)*$gainb)+(($value+$offNoise)*$gaina)+$offTotal;
					$kw 		= (($out ) / 468.9385193)*1000;
					$kw 		= round($kw,1);

					SetValue(CreateVariable("Watt", 2, $myCat, 0, "~Watt.3680", 0), $kw);

					// Gesamtverbrauch in kWh
					$pulse 	= substr($buf,32,8);
					$value 	= hexdec($pulse);
					$out 		= (pow(($value+$offNoise),2)*$gainb)+(($value+$offNoise)*$gaina)+$offTotal;
					$kw 		= (($out ) / 468.9385193);
					$kw 		= round($kw,3);

					// SetValue(CreateVariable("Gesamtverbrauch", 2, $myCat, 0, "~Electricity", 0), $kw);

				}
				break;

			case "0019":   //Adressen abfragen
				print "Die Sequenznr: ".substr($buf,4,4)."\r\n";
				print "MC Circle+: ".substr($buf,8,16)."\r\n";
				print "MAC Circle : ".substr($buf,24,16)."\r\n";
				print "Node ID: ".substr($buf,40,2)."\r\n";

				break;
				
			case "0024":   //Info
			   $mcID = substr($buf,8,16);
				$myCat = IPS_GetObjectIDByIdent($mcID, $idCatCircles);
				// echo IPS_GetName ($myCat).": ".substr($buf,41,1);
				SetValue(CreateVariable("State", 0, $myCat, 0, "~Switch", $IPS_SELF), substr($buf,41,1));

				// print "Die Sequenznr: ".substr($buf,4,4)."\r\n";
				// print "MC Adresse: ".substr($buf,8,16)."\r\n";
				// print "Jahr : ".substr($buf,24,2)."\r\n";
				// print "Monat: ".substr($buf,26,2)."\r\n";
				// print "Minuten : ".substr($buf,28,4)."\r\n";
				// print "log Adresse: ".substr($buf,32,8)."\r\n";
				// print "An/aus: ".substr($buf,40,2)."\r\n";
				// print "Herz (85=50H): ".substr($buf,42,2)."\r\n";
				// print "Hardwareversion: ".substr($buf,44,12)."\r\n";
				// print "Softwareversion: ".substr($buf,56,8)."\r\n";
				// print "Stick 00,Cir+ 01 Cir 02: ".substr($buf,64,2)."\r\n";

				break;

			case "0027":   //Kalibrierung
				// print "Die Sequenznr: ".substr($buf,4,4)."\r\n";
				// print "MC Adresse: ".substr($buf,8,16)."\r\n";
				// print "gaina : ".substr($buf,24,8)."\r\n";
				// print "gainb: ".substr($buf,32,8)."\r\n";
				// print "offTotal : ".substr($buf,40,8)."\r\n";
				// print "offNoise: ".substr($buf,48,8)."\r\n";

				// SetValue(CreateVariable("Watt", 2, $myCat, 0, "~Watt.3680", 0), 0);

				$myCat = IPS_GetObjectIDByIdent(substr($buf,8,16), $idCatCircles);

				SetValueFloat(CreateVariable("gaina",2,$myCat,0,""),bintofloat(substr($buf,24,8)));
				SetValueFloat(CreateVariable("gainb",2,$myCat,0,""),bintofloat(substr($buf,32,8)));
				SetValueFloat(CreateVariable("offTotal",2,$myCat,0,""),bintofloat(substr($buf,40,8)));
				if (substr($buf,48,8)=="00000000")
					SetValueFloat(CreateVariable("offNoise",2,$myCat,0,""),0);
				else
					SetValueFloat(CreateVariable("offNoise",2,$myCat,0,""),bintofloat(substr($buf,48,8)));

				break;

			case "0049":
				break;

			}
	break;
	}

// this function is used to calculate the (common) crc16c for an entire buffer
function calculate_common_crc16c($buffer)
{
    $crc16c = 0x0000;  // the crc initial value laut www.maartendamen.com
    $buffer_length = strlen($buffer);
    for ($i = 0; $i < $buffer_length; $i++)
    {
        $ch = ord($buffer[$i]);
        $crc16c = update_common_crc16c($ch, $crc16c);
    }
    return $crc16c;
}
// this function is used to calculate the (common) crc16c byte by byte
// $ch is the next byte and $crc16c is the result from the last call, or 0xffff initially
function update_common_crc16c($ch, $crc16c)
{
    $crc16c_polynomial = 0x11021;   //auch laut maartendamen
    // This comment was in the code from
    // http://www.joegeluso.com/software/articles/ccitt.htm
    // Why are they shifting this byte left by 8 bits??
    // How do the low bits of the poly ever see it?
    $ch <<= 8;
    for($i = 0; $i < 8; $i++)
    {
        if (($crc16c ^ $ch) & 0x8000)
        {
            $xor_flag = true;
        }
        else
        {
            $xor_flag = false;
        }
        $crc16c = $crc16c << 1;
        if ($xor_flag)
        {
            $crc16c = $crc16c ^ $crc16c_polynomial;
        }
        $ch = $ch << 1;
    }
    // mask off (zero out) the upper two bytes
    $crc16c = $crc16c & 0x0000ffff;
    return $crc16c;
}

function bintofloat($in)
{
    $in=hexdec($in);
      $binary = str_pad(decbin($in),32,"0", STR_PAD_LEFT);
    $fb = $binary[0];
    $exp = bindec(substr($binary, 1, 8));
    $m = bindec(substr($binary, 9, 23));
    return pow(-1,$fb) * (1+$m/(pow(2,23))) * pow(2,$exp-127);
}

function CreateVariable ($Name, $Type, $Parent, $Position, $Profile, $Action=0, $ValueDefault='', $Icon="") {
   $VariableId = @IPS_GetVariableIDByName($Name, $Parent);
   if ($VariableId === false) {
		$VariableId = IPS_CreateVariable($Type);
		IPS_SetName($VariableId, $Name);
		IPS_SetParent($VariableId, $Parent);
		IPS_SetPosition($VariableId, $Position);
		IPS_SetVariableCustomProfile($VariableId, $Profile);
		IPS_SetVariableCustomAction($VariableId, $Action);
		IPS_SetIcon($VariableId, $Icon);
		SetValue($VariableId, $ValueDefault);
		echo 'Created VariableId '.$Name.'='.$VariableId."\n";
	}
	$VariableData = IPS_GetVariable ($VariableId);
	if ($VariableData['VariableCustomProfile'] <> $Profile) {
		echo "Set VariableProfile='$Profile' for Variable='$Name' \n";
		IPS_SetVariableCustomProfile($VariableId, $Profile);
	}
	if ($VariableData['VariableCustomAction'] <> $Action) {
		echo "Set VariableCustomAction='$Action' for Variable='$Name' \n";
		IPS_SetVariableCustomAction($VariableId, $Action);
	}
	UpdateObjectData($VariableId, $Position, $Icon);
	return $VariableId;
}

	function CreateCategory ($Name, $Parent, $Position, $Icon=null) {
	   $CategoryId = @IPS_GetCategoryIDByName($Name, $Parent);
	   if ($CategoryId === false) {
 			$CategoryId = IPS_CreateCategory();
   		IPS_SetName($CategoryId, $Name);
   		IPS_SetParent($CategoryId, $Parent);
   		if ($Position!==false) {
   			IPS_SetPosition($CategoryId, $Position);
			}
   		if ($Icon!==false) {
	   		IPS_SetIcon($CategoryId, $Icon);
			}
			echo 'Created Category '.$Name.'='.$CategoryId."\n";
	   }
		UpdateObjectData($CategoryId, $Position, $Icon);
		return $CategoryId;
	}

	function UpdateObjectData($ObjectId, $Position, $Icon="") {
		$ObjectData = IPS_GetObject ($ObjectId);
	   $ObjectPath = IPS_GetLocation($ObjectId);
		if ($ObjectData['ObjectPosition'] <> $Position and $Position!==false) {
			echo "Set ObjectPosition='$Position' for Object='$ObjectPath' \n";
   		IPS_SetPosition($ObjectId, $Position);
		}
		if ($ObjectData['ObjectIcon'] <> $Icon and $Icon!==false) {
			echo "Set ObjectIcon='$Icon' for Object='$ObjectPath' \n";
   		IPS_SetIcon($ObjectId, $Icon);
		}

	}

function SendPlugwiseCommand($cmd, $REGVAR)
{
	$ausgabe=dechex(calculate_common_crc16c($cmd));
	$ausgabe = str_pad($ausgabe, 4 ,'0', STR_PAD_LEFT); //mit nullen auffüllen
	$cmd.= $ausgabe;
	// PRINT $cmd;
	RegVar_SendText($REGVAR,"\x05\x05\x03\x03".$cmd."\x0D\x0A");
	Sleep(4);
}

?>