dueros.zip

<?php require_once __DIR__.'/DiscoveryResponse.php'; require_once __DIR__.'/ControlResponse.php'; require_once __DIR__.'/QueryResponse.php'; $sqlFileName = "../sqldata.txt"; function device_discovery($messageId) { error_log('----device_discovery in----'); global $sqlFileName; if (($txtRes = fopen($sqlFileName, "r")) === false) { error_log('----gate_implement fopen failed----'); $ret = new DuerOS\DiscoveryResponse(true); $ret->header->putResponseMessageId($messageId); $retJson = json_encode($ret); return $retJson; } $str = fread($txtRes, filesize($sqlFileName)); error_log("str-->".$str); $obj = json_decode($str); $ret = new DuerOS\DiscoveryResponse(); $ret->header->putResponseMessageId($messageId); foreach ($obj->dev_array as $devElement) { error_log('entity_id-->'.$devElement->entity_id); switch ($devElement->device_type) { case 'ceiling_lamp': { $dev = new DuerOS\DiscoveryAppliances(); $dev->putResponseApplianceTypes("LIGHT"); $dev->putResponseDeviceInfo($devElement->entity_id, "展现给用户的详细介绍", "吸顶灯", "RT-home", "RT-CL0.1", "du0.001.00"); $dev->putResponseIsReachable(true); $dev->actions = array("turnOn", "turnOff", "setBrightnessPercentage", "setColor", "incrementBrightnessPercentage", "decrementBrightnessPercentage"); $dev->putResponseApplianceDetails(NULL); $att = new DuerOS\DiscoveryAttributes("name", "吸顶灯", "", 1496741861, 0); $dev->putResponseAttributes($att); $att = new DuerOS\DiscoveryAttributes("connectivity", "REACHABLE", "", 1496741861, 0); $dev->putResponseAttributes($att); $attcv = new DuerOS\DiscoveryAttributesColorValue(350.5, 0.7138, 0.6524); $att = new DuerOS\DiscoveryAttributes("color", $attcv, "", 1496741861, 10); $dev->putResponseAttributes($att); $brightnessWhite = ''; $brightnessYellow = ''; $powerstate = ''; foreach ($devElement->properties as $propertie) { if ($propertie->name =='brightness_w') { $brightnessWhite = $propertie->value; } elseif ($propertie->name =='brightness_y') { $brightnessYellow = $propertie->value; } elseif ($propertie->name =='powerstate') { $powerstate = strtoupper($propertie->value); } } $att = new DuerOS\DiscoveryAttributes("powerState", $powerstate, "", 1496741861, 0); $dev->putResponseAttributes($att); $brightness = ($brightnessWhite>$brightnessYellow)?$brightnessWhite:$brightnessYellow; $att = new DuerOS\DiscoveryAttributes("brightness", $brightness, "", 1496741861, 100); $dev->putResponseAttributes($att); $ret->payload->putResponseAppliances($dev); break; } } } $retJson = json_encode($ret); error_log('retJson-->'.$retJson); error_log('----device_discovery out----'); return $retJson; } function device_control($obj, $messageId) { error_log('----device_control in----'); global $sqlFileName; $applianceId = $obj->payload->appliance->applianceId; $action = $obj->header->name; $deviceType = '';//Customize device type $deviceType = device_id_to_type($applianceId); error_log("deviceType-->".$deviceType); error_log("action-->".$action); if ($action == "" || $deviceType == "") { error_log('----get_control_action failed----'); $ret = new DuerOS\ControlResponse(true); $ret->header->putResponseMessageId($messageId); $ret->payload->putResponseError("SERVICE_ERROR", "action or device not support,name:".$obj->header->name." device:".substr($applianceId,0,stripos($applianceId,"."))); $retJson = json_encode($ret); return $retJson; } $validArray = array ( "deviceId" => $applianceId, "deviceType" => $deviceType, "actionName" => $obj->header->name, "action" => $action ); //----------------------------------- if (($txtRes = fopen($sqlFileName, "r+")) === false) { error_log('----get_control fopen failed----'); $ret = new DuerOS\ControlResponse(true); $ret->header->putResponseMessageId($messageId); $ret->payload->putResponseError("SERVICE_ERROR", "CANNOT_OPEN"); $retJson = json_encode($ret); return $retJson; } $str = fread($txtRes, filesize($sqlFileName)); error_log("str-->".$str); $sqlObj = json_decode($str); foreach ($sqlObj->dev_array as $devElement) { error_log('entity_id-->'.$devElement->entity_id); if ($devElement->entity_id == $validArray['deviceId']) { switch ($devElement->device_type) { case 'ceiling_lamp': { switch ($validArray['action']) { case 'TurnOnRequest': { $ret = new DuerOS\ControlResponse(); $ret->header->putResponseMessageId($messageId); $ret->header->putResponseName("TurnOnConfirmation"); foreach ($devElement->properties as $propertie) { error_log('name-->'.$propertie->name); if ($propertie->name == "powerstate") { $propertie->value = "on"; break; } } break; } case 'TurnOffRequest': { $ret = new DuerOS\ControlResponse(); $ret->header->putResponseMessageId($messageId); $ret->header->putResponseName("TurnOffConfirmation"); foreach ($devElement->properties as $propertie) { error_log('name-->'.$propertie->name); if ($propertie->name == "powerstate") { $propertie->value = "off"; break; } } break; } case 'SetBrightnessPercentageRequest': { $preValue = 0; foreach ($devElement->properties as $propertie) { error_log('name-->'.$propertie->name); if ($propertie->name == "brightness_w" && $propertie->value != 0) { $preValue = ($propertie->value > $preValue)?$propertie->value:$preValue; $propertie->value = $obj->payload->brightness->value; } else if ($propertie->name == "brightness_y" && $propertie->value != 0) { $preValue = ($propertie->value > $preValue)?$propertie->value:$preValue; $propertie->value = $obj->payload->brightness->value; } } $ret = new DuerOS\ControlResponse(SetBrightnessPercentageRequest, $preValue, $obj->payload->brightness->value);