<?
   include_once "IPSLogger.ips.php";

    define ("HEATING_DT_STRING",            '~String');
    define ("HEATING_DT_DEGREE",            'Heating_Temperature');
    define ("HEATING_DT_PRESSURE",        'Heating_Pressure');
    define ("HEATING_DT_PERCENT",        'Heating_Percent');

    if ($IPS_SENDER == 'Variable') {
    
       $data         = GetValue(33277 /*[System\eBus\eBusAdapter\Data]*/);  // $IPS_VALUE;
       $rootId       = IPS_GetParent($IPS_SELF);
       $dataSender   = substr($data,0,2);
       $dataReceiver = substr($data,2,2);
       $dataCommand  = substr($data,4,4);
       $dataLen      = substr($data,8,2);
       $dataVal      = substr($data,10,(int)$dataLen*2);

        // Vaillant B504 - 'Get Operational Data'
        if ($dataCommand=='B504') {
	
				$dataBlock      = substr($data,10,2);

				If ($dataBlock == "00") {
	            storeData('Data.B504.Datum Uhrzeit', substr($data,26,2).".".substr($data,28,2).".".substr($data,32,2)." ".substr($data,24,2).":".substr($data,22,2), $rootId, 10, HEATING_DT_STRING);
	            storeData('Data.B504.Außentemperatur', decodeDATA2b($data,18), $rootId, 10, HEATING_DT_DEGREE);
				} else {
	   	      storeData('Data.Unknown.'.$dataCommand.$dataBlock, $data,       $rootId, 40, HEATING_DT_STRING);
   	         IPSLogger_Inf(__file__, 'Unknown Command: '.$dataCommand.$dataBlock.', Data='.$data);
				};

        // Vaillant B505 - 'Burner Operational Data'
        } else if ($dataCommand=='B505') {
				SetValue(55340 /*[System\eBus\Test\B505]*/, $data);
   	      storeData('Data.B505.M5', substr($data,8,2)." / ".decodeDATA1c($data,5),       $rootId, 40, HEATING_DT_STRING);
   	      storeData('Data.B505.M6', substr($data,10,2)." / ".decodeDATA1c($data,6),       $rootId, 40, HEATING_DT_STRING);
   	      storeData('Data.B505.M7', substr($data,12,2)." / ".decodeDATA1c($data,7),       $rootId, 40, HEATING_DT_STRING);

        // Vaillant B510 - 'Operational Data from Room Controller to Burner Control Unit'
        } else if ($dataCommand=='B510') {
   	      storeData('Data.B510.M6', substr($data,10,2)." / ".decodeDATA1c($data,6),       $rootId, 40, HEATING_DT_STRING);
   	      storeData('Data.B510.M7', substr($data,12,2)." / ".decodeDATA1c($data,7),       $rootId, 40, HEATING_DT_STRING);
            storeData('Data.B510.Heizung Vorlauftemperatur',           decodeDATA1c($data,8),     $rootId, 20, HEATING_DT_DEGREE);
            storeData('Data.B510.WW-Solltemperatur',            decodeDATA1c($data,9),       $rootId, 30, HEATING_DT_DEGREE);
   	      storeData('Data.B510.M10', substr($data,18,2)." / ".decodeDATA1c($data,10),       $rootId, 40, HEATING_DT_STRING);
   	      storeData('Data.B510.M11', substr($data,20,2)." / ".decodeDATA1c($data,11),       $rootId, 40, HEATING_DT_STRING);
   	      storeData('Data.B510.M12', substr($data,22,2)." / ".decodeDATA1c($data,12),       $rootId, 40, HEATING_DT_STRING);
   	      storeData('Data.B510.M13', substr($data,24,2)." / ".decodeDATA1c($data,13),       $rootId, 40, HEATING_DT_STRING);
   	      storeData('Data.B510.M14', substr($data,26,2)." / ".decodeDATA1c($data,14),       $rootId, 40, HEATING_DT_STRING);
   	      storeData('Data.B510.M15', substr($data,28,2)." / ".decodeDATA1c($data,15),       $rootId, 40, HEATING_DT_STRING);

        // Vaillant B511 - 'Operational Data of Burner Control Unit to Room Control Unit'
        } else if ($dataCommand=='B511') {

				$dataBlock      = substr($data,10,2);

				If ($dataBlock == "01") {
   	         storeData('Data.B511-B1.Anlagentemperatur',           decodeDATA1c($data,10),     $rootId, 20, HEATING_DT_DEGREE);
      	      storeData('Data.B511-B1.Nachlauftemperatur',            decodeDATA1c($data,11),       $rootId, 30, HEATING_DT_DEGREE);
	            storeData('Data.B511-B1.WW-Auslauftemperatur',             decodeDATA1c($data,14),       $rootId, 40, HEATING_DT_DEGREE);
   	         storeData('Data.B511-B1.WW-Speichertemperatur',             decodeDATA1c($data,15),       $rootId, 40, HEATING_DT_DEGREE);
               $betrieb = substr($data,30,2);
      	      storeData('Data.B511-B1.Heating Service',                  $betrieb, $rootId, 50, HEATING_DT_STRING);
      	      SetValueInteger(31173 /*[System\eBus\Data\B511-B1\Betriebsstatus]*/, decodeSignedChar($betrieb,1));
   	         storeData('Data.B511-B1.S10', substr($data,32,2)." / ".decodeDATA1c($data,17),       $rootId, 40, HEATING_DT_STRING);
   	         storeData('Data.B511-B1.S11', substr($data,34,2)." / ".decodeDATA1c($data,18),       $rootId, 40, HEATING_DT_STRING);
   	         storeData('Data.B511-B1.S12', substr($data,36,2)." / ".decodeDATA1c($data,19),       $rootId, 40, HEATING_DT_STRING);
				} elseif ($dataBlock = '02') {
   	         storeData('Data.B511-B2.S3', substr($data,18,2)." / ".decodeDATA1c($data,10),       $rootId, 40, HEATING_DT_STRING);
   	         storeData('Data.B511-B2.S4', substr($data,20,2)." / ".decodeDATA1c($data,11),       $rootId, 40, HEATING_DT_STRING);
   	         storeData('Data.B511-B2.S5', substr($data,22,2)." / ".decodeDATA1c($data,12),       $rootId, 40, HEATING_DT_STRING);
   	         storeData('Data.B511-B2.S6', substr($data,24,2)." / ".decodeDATA1c($data,13),       $rootId, 40, HEATING_DT_STRING);
   	         storeData('Data.B511-B2.WW-Speichertemperatur',             decodeDATA1c($data,14),       $rootId, 40, HEATING_DT_DEGREE);
				};
				
        // Vaillant B512 - 'Unknown Command'
        } else if ($dataCommand=='B512') {
   	      storeData('Data.B512.M6', substr($data,10,2)." / ".decodeDATA1c($data,6),       $rootId, 40, HEATING_DT_STRING);
   	      storeData('Data.B512.M7', substr($data,12,2)." / ".decodeDATA1c($data,7),       $rootId, 40, HEATING_DT_STRING);

        // Vaillant B516 - 'Broadcast'
        } else if ($dataCommand=='B516') {
            // SetValue(40570 /*[Objekt #40570 existiert nicht]*/, $data);

        // Identification
        } else if ($dataCommand=='0704') {
        
        } else {
				if ($data != "00") {
	   	      storeData('Data.Unknown.'.$dataCommand, $data,       $rootId, 40, HEATING_DT_STRING);
   	         IPSLogger_Inf(__file__, 'Unknown Command: '.$dataCommand.', Data='.$data);
				}
        }
	}


    if ($IPS_SENDER == 'Execute') {
       // Testing ...
			$rootId	= IPS_GetParent($IPS_SELF);
			// $data		= GetValue(39524 /*[Objekt #39524 existiert nicht]*/);
//			echo decodeDATA1c("39",0);
			echo decodeSignedChar('27',1);
    }


    // ----------------------------------------------------------------------------------------------------------------
    function decodeSignedChar ($hexData, $byte) {
        $data     = substr(hexToStr($hexData), $byte-1,1);
       if (ord($data)== 0x80) {        //Ersatzwert
            $result = false;
       } else if ((ord($data) & 0x80) == 0x80) {        //Negativ
           $result = - ((~ ord($data)) & 0x000000ff);
       } else {
            $result = ord($data);
       }
       return $result;
    }

    // ----------------------------------------------------------------------------------------------------------------
    function decodeChar ($hexData, $byte) {
        $data     = substr(hexToStr($hexData), $byte-1,1);
       if (ord($data)== 0xFF) {        //Ersatzwert
            $result = false;
       } else {
          $result = ord($data);
       }
       return $result;
    }

    // ----------------------------------------------------------------------------------------------------------------
    function decodeByte ($hexData, $byte) {
       return decodeChar($hexData, $byte);
    }

    // ----------------------------------------------------------------------------------------------------------------
    function decodeData2b ($hexData, $byte) {     //data[0] = high, data[1]=low
        $data     = hexToStr($hexData);
       $lowByte  = substr($data, $byte-1,1);
       $highByte = substr($data, $byte,1);

       if (ord($highByte) == 0x80) {        //Ersatzwert
            $result = false;
       } else if ((ord($highByte) & 0x80) == 0x80) {        //high byte muss 0x80 sein
           $result = - (((~ ord($highByte)) & 0x000000ff) + ((((~ ord($lowByte)) & 0x000000ff) + 1) / 256));
       } else {
            $result = (ord($highByte))+ (ord($lowByte)/256) ; // High Byte plus (Low Byte / 256)
       }
       return $result;
    }

    // ----------------------------------------------------------------------------------------------------------------
    function decodeData1c ($hexData, $byte) {
       $data = substr($hexData, $byte*2-2,2);
       $value = ord(hexToStr($data))/2;
        return $value;
    }

    // ----------------------------------------------------------------------------------------------------------------
    function decodeData2c ($hexData, $byte) {
        $data     = hexToStr($hexData);
       $lowByte  = substr($data, $byte-1,1);
       $highByte = substr($data, $byte,1);

       if ((ord($data[0]) & 0x80) == 0x80) {
           $result = - ((((~ ord($highByte)) & 0x000000ff) * 16) + (((~ ord($lowByte)) & 0x000000f0) >> 4) + ((((~ ord($lowByte)) & 0x0000000f) + 1) / 16));
        } else {
           $result = (ord($highByte) * 16) + ((ord($lowByte) & 0xf0) >> 4) + ((ord($lowByte) & 0x0f) / 16);
        }
        return $result;
    }

    // ----------------------------------------------------------------------------------------------------------------
    function decodeData0507M6($hexData, $byte) {
       $data = substr($hexData, $byte*2-2,2);
        switch ($data) {
            case '00': $msg = 'Brenner ausschalten';  break;
            case '01': $msg = 'Keine Aktion';  break;
            case '55': $msg = 'Brauchwasserbereitung';  break;
          case 'AA': $msg = 'Heizbetrieb';  break;
         case 'CC': $msg = 'Emissionskontrolle';  break;
         case 'DD': $msg = 'TÜV-Funktion';  break;
         case 'EE': $msg = 'Reglerstop-Funktion';  break;
         case '66': $msg = 'Brauchwasserbereitung bei Reglerstop';  break;
         case 'BB': $msg = 'Brauchwasserbereitung bei Heizbetrieb';  break;
         case '44': $msg = 'Reglerstop-Funktion stufiger Betrieb';  break;
         default : $msg='-';
      }
      return $msg;
   }

    // ----------------------------------------------------------------------------------------------------------------
    function decodeData0507M7($hexData, $byte) {
       $data = substr($hexData, $byte*2-2,2);
        switch ($data) {
          case '00': $msg = 'Keine Aktion';  break;
         case '01': $msg = 'Ausschalten Kesselpumpe';  break;
         case '02': $msg = 'Einschalten Kesselpumpe';  break;
         case '03': $msg = 'Ausschalten variabler Verbraucher';  break;
         case '04': $msg = 'Einschalten variabler Verbraucher';  break;
         default : $msg='-';
      }
      return $msg;
   }


    // ----------------------------------------------------------------------------------------------------------------
    function storeData($path, $value, $rootId, $order, $dataType) {
       if ($value===false) {
          return; // Ersatzwert ...
       }
        $variableId = storeDataGetId($path, $rootId, $order, $dataType);
        switch ($dataType) {
           case HEATING_DT_DEGREE:
           case HEATING_DT_PERCENT:
           case HEATING_DT_PRESSURE:
              if (GetValue($variableId)<>$value) {
                    SetValueFloat($variableId, $value);
                }
              break;
            default:
              if (GetValue($variableId)<>$value) {
                    SetValue($variableId, $value);
                }
        }
    }

    // ----------------------------------------------------------------------------------------------------------------
    function storeDataGetId($path, $rootId, $order, $dataType) {
        $pathList   = explode('.',$path);
        $parentId = $rootId;
        foreach ($pathList as $idx=>$pathItem) {
           if ($idx == count($pathList)-1) {
               $variableId = @IPS_GetVariableIDByName($pathItem, $parentId);
               if ($variableId === false) {
                   $variableId = storeDataCreateVariable($pathItem, $parentId, $order, $dataType);
                }
            } else {
               $categoryId = @IPS_GetCategoryIDByName($pathItem, $parentId);
               if ($categoryId === false) {
                     $categoryId = IPS_CreateCategory();
                   IPS_SetName($categoryId, $pathItem);
                   IPS_SetParent($categoryId, $parentId);
                }
                $parentId = $categoryId;
            }
        }
        return $variableId;
    }

    // ----------------------------------------------------------------------------------------------------------------
    function storeDataCreateVariable($name, $parentId, $order, $dataType) {
        switch ($dataType) {
           case HEATING_DT_STRING:
                 $variableId = IPS_CreateVariable(3);
              break;
           case HEATING_DT_DEGREE:
           case HEATING_DT_PRESSURE:
           case HEATING_DT_PERCENT:
                 $variableId = IPS_CreateVariable(2);
                 storeDataCreateProfile($dataType);
              break;
            default:
               IPSLogger_Err(__file__, 'Unknown Datatype '.$dataType);
        }
       IPS_SetName($variableId, $name);
       IPS_SetParent($variableId, $parentId);
       IPS_SetPosition($variableId, $order);
          IPS_SetVariableCustomProfile($variableId, $dataType);

        return $variableId;
    }

    // ----------------------------------------------------------------------------------------------------------------
    function storeDataCreateProfile($dataType) {
        switch ($dataType) {
           case HEATING_DT_DEGREE:
                @IPS_CreateVariableProfile($dataType, 1);
                IPS_SetVariableProfileText($dataType, null, ' °C');
                IPS_SetVariableProfileIcon($dataType, 'Temperature');
              break;
           case HEATING_DT_PRESSURE:
                @IPS_CreateVariableProfile($dataType, 1);
                IPS_SetVariableProfileText($dataType, null, ' bar');
              break;
           case HEATING_DT_PERCENT:
                @IPS_CreateVariableProfile($dataType, 1);
                IPS_SetVariableProfileText($dataType, null, ' %');
              break;
            default:
        }
    }
    // ----------------------------------------------------------------------------------------------------------------
    function strToHex ($str) {
        $result = '';
        for ($i = 0; $i < strlen($str); $i++)
        {
            $result .= strtoupper(((strlen(dechex(ord($str[$i]))) < 2) ? '0' : '').dechex(ord($str[$i])));
        }
        return $result;
    }

    // ----------------------------------------------------------------------------------------------------------------
    function hexToStr($hex) {
        $string='';
        for ($i=0; $i < strlen($hex)-1; $i+=2)
        {
            $string .= chr(hexdec($hex[$i].$hex[$i+1]));
        }
        return $string;
    }

?>