JSON Editors

（11）香橙派+apache2与php+天猫精灵=自建平台语音支持--天猫精灵对接6

导航链接

（1）香橙派+apache2与php+天猫精灵=自建平台语音支持--前言

（2）香橙派+apache2与php+天猫精灵=自建平台语音支持--香橙派操作系统安装

（3）香橙派+apache2与php+天猫精灵=自建平台语音支持--香橙派环境配置

（4）香橙派+apache2与php+天猫精灵=自建平台语音支持--apache2与php

（5）香橙派+apache2与php+天猫精灵=自建平台语音支持--MariaDB的安装

（6）香橙派+apache2与php+天猫精灵=自建平台语音支持--天猫精灵对接1

（7）香橙派+apache2与php+天猫精灵=自建平台语音支持--天猫精灵对接2

（8）香橙派+apache2与php+天猫精灵=自建平台语音支持--天猫精灵对接3

（9）香橙派+apache2与php+天猫精灵=自建平台语音支持--天猫精灵对接4

（10）香橙派+apache2与php+天猫精灵=自建平台语音支持--天猫精灵对接5

（11）香橙派+apache2与php+天猫精灵=自建平台语音支持--天猫精灵对接6

（12）香橙派+apache2与php+天猫精灵=自建平台语音支持--天猫精灵对接7

设备查询

还是先上个时序图，看图基本功能也就都知道了。

下图为设备响应指令的详细协议以及协议的解析和响应
 

  1.     case 'AliGenie.Iot.Device.Query': {
  2.         error_log('----case in Query----');
  3.         $result = device_status($obj, $messageId);
  4.         break;
  5.     }

协议的解析和设备控制协议的解析采用的思想差不多，只不过查询和控制这两个过程是正好相反的。过程控制是主动存储数据，然后又硬件设备读取，查询是硬件设备返回数据存储到服务器上在查询的时候读取。就这样，具体的代码看aligenies_handle.php中的内容吧，这里会调用存储读取的具体PHP。

  1. function device_status($obj, $messageId)
  2. {
  3.     error_log('----device_status in----');
  4.         global $sqlFileName;
  5.     
  6.     $deviceId = $obj->payload->deviceId;
  7.     $action = '';
  8.     $deviceType = check_type_from_id($deviceId);
  9.     
  10.     switch ($obj->header->name) {
  11.     case 'QueryPowerState':
  12.         $action = 'powerstate';
  13.         break;
  14.     case 'QueryColor':
  15.         $action = 'color';
  16.         break;
  17.     case "QueryTemperature":
  18.         $action = "temperature";
  19.         break;
  20.     case "QueryWindspeed":
  21.         $action = "windspeed";
  22.         break;
  23.     case "QueryBrightness":
  24.         $action = "brightness";
  25.         break;
  26.     case "QueryFog":
  27.         $action = "fog";
  28.         break;
  29.     case "QueryHumidity":
  30.         $action = "humidity";
  31.         break;
  32.     case "QueryPm25":
  33.         $action = "pm25";
  34.         break;
  35.     case "QueryChannel":
  36.         $action = "channel";
  37.         break;
  38.     case "QueryNumber":
  39.         $action = "number";
  40.         break;
  41.     case "QueryDirection":
  42.         $action = "direction";
  43.         break;
  44.     case "QueryAngle":
  45.         $action = "angle";
  46.         break;
  47.     case "QueryAnion":
  48.         $action = "anion";
  49.         break;
  50.     case "QueryEffluent":
  51.         $action = "effluent";
  52.         break;
  53.     case "QueryMode":
  54.         $action = "mode";
  55.         break;
  56.     case "QueryLeftTime":
  57.         $action = "lefttime";
  58.         break;
  59.     case "QueryRemoteStatus":
  60.         $action = "remotestatus";
  61.         break;
  62.     case "QueryOnlineState":
  63.         $action = "onlinestate";
  64.         break;
  65.     case "QueryColorTemperature":
  66.         $action = "colorTemperature";
  67.         break;
  68.     case "Query":
  69.         $action = "all";
  70.         break;
  71.     default:
  72.         $action = "";
  73.     }    
  74.     if ($action == "" || $deviceType == "") {
  75.         $ret = new AliGenie\QueryResponse(true);
  76.         $ret->header->putResponseMessageId($messageId);
  77.         $ret->payload->putResponseDeviceId($deviceId);
  78.         $ret->payload->putResponseError("DEVICE_NOT_SUPPORT_FUNCTION");
  79.         $retJson = json_encode($ret);
  80.         return $retJson;
  81.     }
  82.  
  83.     $properties = array();
  84.     $findDevice = false;
  85.     $queryValue = '';
  86.  
  87.     if (($txtRes = fopen($sqlFileName, "r")) === false) {
  88.         error_log('----get_control fopen failed----');
  89.         $ret = new AliGenie\QueryResponse(true);
  90.         $ret->header->putResponseMessageId($messageId);
  91.         $ret->payload->putResponseDeviceId($deviceId);
  92.         $ret->payload->putResponseError("SERVICE_ERROR", "CANNOT_OPEN");
  93.         $retJson = json_encode($ret);
  94.         return $retJson;
  95.     }
  96.     $str = fread($txtRes, filesize($sqlFileName));
  97.     $sqlObj = json_decode($str);
  98.     $devArray = $sqlObj->dev_array;
  99.     
  100.     $ret = new AliGenie\QueryResponse();
  101.     $ret->header->putResponseName($obj->header->name);
  102.     $ret->header->putResponseMessageId($messageId);
  103.     $ret->payload->putResponseDeviceId($deviceId);
  104.     
  105.     foreach ($devArray as $data) {
  106.         error_log('entity_id-->'.$data->entity_id);
  107.         error_log('device_type-->'.$data->device_type);
  108.         if ($data->entity_id == $deviceId) {
  109.             $findDevice = true;
  110.             switch ($data->device_type) {
  111.                 case 'ceiling_lamp': {
  112.                     $brightnessWhite = '';
  113.                     $brightnessYellow = '';
  114.                     foreach ($data->properties as $element) {
  115.                         error_log('name-->'.$element->name);
  116.                         error_log('value-->'.$element->value);
  117.                         if ($element->name =='brightness_w') {
  118.                             $brightnessWhite = $element->value;
  119.                         } elseif ($element->name =='brightness_y') {
  120.                             $brightnessYellow = $element->value;
  121.                         } else {
  122.                             $properties[$element->name] = $element->value;
  123.                         }
  124.                     }
  125.                     $properties['brightness'] = ($brightnessWhite>$brightnessYellow)?$brightnessWhite:$brightnessYellow;
  126.                     if ($brightnessWhite != 0 && $brightnessYellow == 0) {
  127.                         $properties['color'] = 'White';
  128.                     } elseif ($brightnessWhite == 0 && $brightnessYellow != 0) {
  129.                         $properties['color'] = 'Yellow';
  130.                     } elseif ($brightnessWhite == $brightnessYellow && $brightnessYellow != 0) {
  131.                         $properties['mode'] = '自然模式';
  132.                     }
  133.                     break;
  134.                 }
  135.             }
  136.         }
  137.     }
  138.     fclose($txtRes);
  139.     if ($action != 'all') {
  140.         $queryValue = $properties[$obj->header->name];
  141.         array_splice($properties, 0);
  142.         $properties[$obj->header->name] = $queryValue;
  143.     }
  144.     foreach ($properties as $name => $value) {
  145.         $pro = new AliGenie\QueryPropertie($name, $value);
  146.         $ret->properties[] = $pro;
  147.     }
  148.  
  149.     if ($findDevice == false) {
  150.         $ret = new AliGenie\QueryResponse(true);
  151.         $ret->header->putResponseMessageId($messageId);
  152.         $ret->payload->putResponseDeviceId($deviceId);
  153.         $ret->payload->putResponseError("DEVICE_IS_NOT_EXIST");
  154.         $retJson = json_encode($ret);
  155.         return $retJson;
  156.     } else if ($queryValue == '' && $action != 'all') {
  157.         $ret = new AliGenie\QueryResponse(true);
  158.         $ret->header->putResponseMessageId($messageId);
  159.         $ret->payload->putResponseDeviceId($deviceId);
  160.         $ret->payload->putResponseError("INVALIDATE_PARAMS");
  161.         $retJson = json_encode($ret);
  162.         return $retJson;
  163.     }
  164.     
  165.     $retJson = json_encode($ret);
  166.     error_log('----device_status out----');
  167.     return $retJson;
  168. }

到这里所有的文件部署完毕，我们现在天猫精灵上新建一个智能家居，用于真机测试。

下面是

aligenies_gate.php和aligenies_handle.php完整文件的代码。

aligenies_gate.php

  1. <?php
  2. error_log('----aligenies_gate.php in----');
  3. require_once __DIR__.'/aligenies_handle.php';
  4.  
  5. $chars = md5(uniqid(mt_rand(), true));
  6. $uuid  = substr($chars,0,8) . '-';
  7. $uuid .= substr($chars,8,4) . '-';
  8. $uuid .= substr($chars,12,4) . '-';
  9. $uuid .= substr($chars,16,4) . '-';
  10. $uuid .= substr($chars,20,12);
  11.  
  12. $postStr = file_get_contents("php://input");
  13. $obj = json_decode($postStr);
  14. $messageId = $uuid;
  15. error_log('get-request->'.$postStr);
  16. switch ($obj->header->namespace) {
  17.     case 'AliGenie.Iot.Device.Discovery': {
  18.         error_log('----case in Discovery----');
  19.         $result = device_discovery($messageId);
  20.         break;
  21.     }
  22.     case 'AliGenie.Iot.Device.Control': {
  23.         error_log('----case in Control----');
  24.         $result = device_control($obj, $messageId);
  25.         break;
  26.     }
  27.     case 'AliGenie.Iot.Device.Query': {
  28.         error_log('----case in Query----');
  29.         $result = device_status($obj, $messageId);
  30.         break;
  31.     }
  32.     default: {
  33.         $result='Nothing return,there is an error~!!';
  34.     }
  35. }
  36. echo($result);
  37. error_log('----reseponse----');
  38. error_log($result);
  39. error_log('----aligenies_gate.php out----');
  40. ?>
  41.

aligenies_handle.php

  1. <?php
  2. require_once __DIR__.'/DiscoveryResponse.php';
  3. require_once __DIR__.'/ControlResponse.php';
  4. require_once __DIR__.'/QueryResponse.php';
  5.  
  6. $sqlFileName = "../sqldata.txt";
  7.  
  8. function device_discovery($messageId)
  9. {
  10.     error_log('----device_discovery in----');
  11.     global $sqlFileName;
  12.  
  13.     if (($txtRes = fopen($sqlFileName, "r")) === false) {
  14.         error_log('----gate_implement fopen failed----');
  15.         $ret = new AliGenie\DiscoveryResponse(true);
  16.         $ret->header->putResponseMessageId($messageId);
  17.         $ret->payload->putResponseError("SERVICE_ERROR", "CANNOT_OPEN");
  18.         $retJson = json_encode($ret);
  19.         return $retJson;
  20.     }
  21.     $str = fread($txtRes, filesize($sqlFileName));
  22.     error_log("str-->".$str);
  23.     $obj = json_decode($str);
  24.  
  25.     $ret = new AliGenie\DiscoveryResponse();
  26.     $ret->header->putResponseMessageId($messageId);
  27.  
  28.     foreach ($obj->dev_array as $devElement) {
  29.         error_log('entity_id-->'.$devElement->entity_id);
  30.         
  31.         switch ($devElement->device_type) {
  32.             case 'ceiling_lamp': {
  33.                 $dev = new AliGenie\DiscoveryDevice();
  34.                 $dev->putResponseDeviceInfo($devElement->entity_id, "吸顶灯", device_id_to_devicetype($devElement->entity_id), 
  35.                         "https://www.rtplay.cn/icon/td.png");
  36.                 $dev->actions = array("TurnOn",
  37.                                       "TurnOff",
  38.                                       "SetBrightness",
  39.                                       "SetColor",
  40.                                       "AdjustUpBrightness",
  41.                                       "AdjustDownBrightness",
  42.                                       "QueryBrightness",
  43.                                       "QueryPowerState",
  44.                                       "QueryColor",
  45.                                       "Query");
  46.                 $brightnessWhite = '';
  47.                 $brightnessYellow = '';
  48.                 foreach ($devElement->properties as $propertie) {
  49.                     if ($propertie->name =='brightness_w') {
  50.                         $brightnessWhite = $propertie->value;
  51.                     } elseif ($propertie->name =='brightness_y') {
  52.                         $brightnessYellow = $propertie->value;
  53.                     } else {
  54.                         $pro = new AliGenie\DiscoveryPropertie($propertie->name, $propertie->value);
  55.                         $dev->putResponseProperties($pro);
  56.                     }
  57.                 }
  58.                 $brightness = ($brightnessWhite>$brightnessYellow)?$brightnessWhite:$brightnessYellow;
  59.                 $pro = new AliGenie\DiscoveryPropertie("brightness", $brightness);
  60.                 $dev->putResponseProperties($pro);
  61.                 if ($brightnessWhite == 100 && $brightnessYellow == 0) {
  62.                     $pro = new AliGenie\DiscoveryPropertie("color", "White");
  63.                     $dev->putResponseProperties($pro);
  64.                 } elseif ($brightnessWhite == 0 && $brightnessYellow == 100) {
  65.                     $pro = new AliGenie\DiscoveryPropertie("color", "Yellow");
  66.                     $dev->putResponseProperties($pro);
  67.                 } elseif ($brightnessWhite == $brightnessYellow && $brightnessYellow != 0) {
  68.                     $pro = new AliGenie\DiscoveryPropertie("mode", "自然模式");
  69.                     $dev->putResponseProperties($pro);
  70.                 }
  71.                 $ext = new AliGenie\DiscoveryExtension();
  72.                 $dev->putResponseExtensions($ext);
  73.                 $ret->payload->putResponseDevices($dev);
  74.                 break;
  75.             }
  76.             case 'gateway_switch': {
  77.                 $dev = new AliGenie\DiscoveryDevice();
  78.                 $dev->putResponseDeviceInfo($devElement->entity_id, "插排", device_id_to_devicetype($devElement->entity_id), 
  79.                         "https://www.rtplay.cn/icon/cz.png");
  80.                 $dev->actions = array("TurnOn",
  81.                                       "TurnOff",
  82.                                       "QueryPowerState",
  83.                                       "Query");
  84.                 foreach ($devElement->properties as $propertie) {
  85.                     $pro = new AliGenie\DiscoveryPropertie($propertie->name, $propertie->value);
  86.                     $dev->putResponseProperties($pro);
  87.                 }
  88.                 $ext = new AliGenie\DiscoveryExtension();
  89.                 $dev->putResponseExtensions($ext);
  90.                 $ret->payload->putResponseDevices($dev);
  91.                 break;
  92.             }
  93.         }
  94.     }
  95.  
  96.     $retJson = json_encode($ret);
  97.     error_log('retJson-->'.$retJson);
  98.  
  99.     error_log('----device_discovery out----');
  100.     return $retJson;
  101. }
  102.  
  103. function device_status($obj, $messageId)
  104. {
  105.     error_log('----device_status in----');
  106.         global $sqlFileName;
  107.     
  108.     $deviceId = $obj->payload->deviceId;
  109.     $action = '';
  110.     $deviceType = check_type_from_id($deviceId);
  111.     
  112.     switch ($obj->header->name) {
  113.     case 'QueryPowerState':
  114.         $action = 'powerstate';
  115.         break;
  116.     case 'QueryColor':
  117.         $action = 'color';
  118.         break;
  119.     case "QueryTemperature":
  120.         $action = "temperature";
  121.         break;
  122.     case "QueryWindspeed":
  123.         $action = "windspeed";
  124.         break;
  125.     case "QueryBrightness":
  126.         $action = "brightness";
  127.         break;
  128.     case "QueryFog":
  129.         $action = "fog";
  130.         break;
  131.     case "QueryHumidity":
  132.         $action = "humidity";
  133.         break;
  134.     case "QueryPm25":
  135.         $action = "pm25";
  136.         break;
  137.     case "QueryChannel":
  138.         $action = "channel";
  139.         break;
  140.     case "QueryNumber":
  141.         $action = "number";
  142.         break;
  143.     case "QueryDirection":
  144.         $action = "direction";
  145.         break;
  146.     case "QueryAngle":
  147.         $action = "angle";
  148.         break;
  149.     case "QueryAnion":
  150.         $action = "anion";
  151.         break;
  152.     case "QueryEffluent":
  153.         $action = "effluent";
  154.         break;
  155.     case "QueryMode":
  156.         $action = "mode";
  157.         break;
  158.     case "QueryLeftTime":
  159.         $action = "lefttime";
  160.         break;
  161.     case "QueryRemoteStatus":
  162.         $action = "remotestatus";
  163.         break;
  164.     case "QueryOnlineState":
  165.         $action = "onlinestate";
  166.         break;
  167.     case "QueryColorTemperature":
  168.         $action = "colorTemperature";
  169.         break;
  170.     case "Query":
  171.         $action = "all";
  172.         break;
  173.     default:
  174.         $action = "";
  175.     }    
  176.     if ($action == "" || $deviceType == "") {
  177.         $ret = new AliGenie\QueryResponse(true);
  178.         $ret->header->putResponseMessageId($messageId);
  179.         $ret->payload->putResponseDeviceId($deviceId);
  180.         $ret->payload->putResponseError("DEVICE_NOT_SUPPORT_FUNCTION");
  181.         $retJson = json_encode($ret);
  182.         return $retJson;
  183.     }
  184.  
  185.     $properties = array();
  186.     $findDevice = false;
  187.     $queryValue = '';
  188.  
  189.     if (($txtRes = fopen($sqlFileName, "r")) === false) {
  190.         error_log('----get_control fopen failed----');
  191.         $ret = new AliGenie\QueryResponse(true);
  192.         $ret->header->putResponseMessageId($messageId);
  193.         $ret->payload->putResponseDeviceId($deviceId);
  194.         $ret->payload->putResponseError("SERVICE_ERROR", "CANNOT_OPEN");
  195.         $retJson = json_encode($ret);
  196.         return $retJson;
  197.     }
  198.     $str = fread($txtRes, filesize($sqlFileName));
  199.     $sqlObj = json_decode($str);
  200.     $devArray = $sqlObj->dev_array;
  201.     
  202.     $ret = new AliGenie\QueryResponse();
  203.     $ret->header->putResponseName($obj->header->name);
  204.     $ret->header->putResponseMessageId($messageId);
  205.     $ret->payload->putResponseDeviceId($deviceId);
  206.     
  207.     foreach ($devArray as $data) {
  208.         error_log('entity_id-->'.$data->entity_id);
  209.         error_log('device_type-->'.$data->device_type);
  210.         if ($data->entity_id == $deviceId) {
  211.             $findDevice = true;
  212.             switch ($data->device_type) {
  213.                 case 'ceiling_lamp': {
  214.                     $brightnessWhite = '';
  215.                     $brightnessYellow = '';
  216.                     foreach ($data->properties as $element) {
  217.                         error_log('name-->'.$element->name);
  218.                         error_log('value-->'.$element->value);
  219.                         if ($element->name =='brightness_w') {
  220.                             $brightnessWhite = $element->value;
  221.                         } elseif ($element->name =='brightness_y') {
  222.                             $brightnessYellow = $element->value;
  223.                         } else {
  224.                             $properties[$element->name] = $element->value;
  225.                         }
  226.                     }
  227.                     $properties['brightness'] = ($brightnessWhite>$brightnessYellow)?$brightnessWhite:$brightnessYellow;
  228.                     if ($brightnessWhite != 0 && $brightnessYellow == 0) {
  229.                         $properties['color'] = 'White';
  230.                     } elseif ($brightnessWhite == 0 && $brightnessYellow != 0) {
  231.                         $properties['color'] = 'Yellow';
  232.                     } elseif ($brightnessWhite == $brightnessYellow && $brightnessYellow != 0) {
  233.                         $properties['mode'] = '自然模式';
  234.                     }
  235.                     break;
  236.                 }
  237.             }
  238.         }
  239.     }
  240.     fclose($txtRes);
  241.     if ($action != 'all') {
  242.         $queryValue = $properties[$obj->header->name];
  243.         array_splice($properties, 0);
  244.         $properties[$obj->header->name] = $queryValue;
  245.     }
  246.     foreach ($properties as $name => $value) {
  247.         $pro = new AliGenie\QueryPropertie($name, $value);
  248.         $ret->properties[] = $pro;
  249.     }
  250.  
  251.     if ($findDevice == false) {
  252.         $ret = new AliGenie\QueryResponse(true);
  253.         $ret->header->putResponseMessageId($messageId);
  254.         $ret->payload->putResponseDeviceId($deviceId);
  255.         $ret->payload->putResponseError("DEVICE_IS_NOT_EXIST");
  256.         $retJson = json_encode($ret);
  257.         return $retJson;
  258.     } else if ($queryValue == '' && $action != 'all') {
  259.         $ret = new AliGenie\QueryResponse(true);
  260.         $ret->header->putResponseMessageId($messageId);
  261.         $ret->payload->putResponseDeviceId($deviceId);
  262.         $ret->payload->putResponseError("INVALIDATE_PARAMS");
  263.         $retJson = json_encode($ret);
  264.         return $retJson;
  265.     }
  266.     
  267.     $retJson = json_encode($ret);
  268.     error_log('----device_status out----');
  269.     return $retJson;
  270. }
  271.  
  272. function device_control($obj, $messageId)
  273. {
  274.     error_log('----device_control in----');
  275.         global $sqlFileName;
  276.  
  277.     $deviceId = $obj->payload->deviceId;
  278.     $action = '';
  279.     $deviceType = '';//Customize device type
  280.     $deviceType = device_id_to_type($deviceId);
  281.     error_log("deviceType-->".$deviceType);
  282.     $action = get_control_action($obj->header->name);
  283.     error_log("action-->".$action);
  284.     if ($action == "" || $deviceType == "") {
  285.         error_log('----get_control_action failed----');
  286.         $ret = new AliGenie\ControlResponse(true);
  287.         $ret->header->putResponseMessageId($messageId);
  288.         $ret->payload->putResponseError("SERVICE_ERROR", 
  289.                                         "action or device not support,name:".$obj->header->name." device:".substr($deviceId,0,stripos($deviceId,".")));
  290.         $retJson = json_encode($ret);
  291.         return $retJson;
  292.     }
  293.  
  294.     $validArray = array (
  295.         "deviceId" => $deviceId,
  296.         "deviceType" => $deviceType,
  297.         "actionName" => $obj->header->name,
  298.         "action" => $action,
  299.         "attribute" => $obj->payload->attribute,
  300.         "value" => $obj->payload->value
  301.     );
  302.     
  303.     $checkResult = control_checker($validArray);
  304.     if ($checkResult != 'succeed') {
  305.         error_log('----control_checker failed----');
  306.         $ret = new AliGenie\ControlResponse(true);
  307.         $ret->header->putResponseMessageId($messageId);
  308.         $ret->payload->putResponseError("DEVICE_NOT_SUPPORT_FUNCTION");
  309.         $retJson = json_encode($ret);
  310.         return $retJson;
  311.     }
  312.     //-----------------------------------
  313.     if (($txtRes = fopen($sqlFileName, "r+")) === false) {
  314.         error_log('----get_control fopen failed----');
  315.         $ret = new AliGenie\ControlResponse(true);
  316.         $ret->header->putResponseMessageId($messageId);
  317.         $ret->payload->putResponseError("SERVICE_ERROR", "CANNOT_OPEN");
  318.         $retJson = json_encode($ret);
  319.         return $retJson;
  320.     }
  321.     $str = fread($txtRes, filesize($sqlFileName));
  322.     error_log("str-->".$str);
  323.     $sqlObj = json_decode($str);
  324.     //error_log("sqlObj-->".print_r($sqlObj, true));
  325.     $ret = new AliGenie\ControlResponse();
  326.     $ret->header->putResponseMessageId($messageId);
  327.     $ret->header->putResponseName($obj->header->name);
  328.     $ret->payload->putResponseDeviceId($obj->payload->deviceId);
  329.     
  330.     foreach ($sqlObj->dev_array as $devElement) {
  331.         error_log('entity_id-->'.$devElement->entity_id);
  332.         if ($devElement->entity_id == $validArray['deviceId']) {
  333.             $ret->payload->putResponseDeviceId($devElement->entity_id);
  334.             switch ($devElement->device_type) {
  335.                 case 'ceiling_lamp': {
  336.                     switch ($validArray['action']) {
  337.                         case 'turn_on': {
  338.                             foreach ($devElement->properties as $propertie) {
  339.                                 error_log('name-->'.$propertie->name);
  340.                                 if ($propertie->name == "powerstate") {
  341.                                         $propertie->value = "on";
  342.                                         break;
  343.                                 }
  344.                             }
  345.                             break;
  346.                         }
  347.                         case 'turn_off': {
  348.                             foreach ($devElement->properties as $propertie) {
  349.                                 error_log('name-->'.$propertie->name);
  350.                                 if ($propertie->name == "powerstate") {
  351.                                         $propertie->value = "off";
  352.                                         break;
  353.                                 }
  354.                             }
  355.                             break;
  356.                         }
  357.                         case 'bright_set': {
  358.                             foreach ($devElement->properties as $propertie) {
  359.                                 error_log('name-->'.$propertie->name);
  360.                                 if ($propertie->name == "brightness_w" && $propertie->value != 0) {
  361.                                     $propertie->value = $validArray['value'];
  362.                                 } else if ($propertie->name == "brightness_y" && $propertie->value != 0) {
  363.                                     $propertie->value = $validArray['value'];
  364.                                 }
  365.                             }
  366.                             break;
  367.                         }
  368.                         case 'bright_up': {
  369.                             foreach ($devElement->properties as $propertie) {
  370.                                 error_log('name-->'.$propertie->name);
  371.                                 if ($propertie->name == "brightness_w" && $propertie->value != 0) {
  372.                                     $propertie->value += $validArray['value'];
  373.                                     if ($propertie->value > 100) {
  374.                                         $propertie->value = 100;
  375.                                     }
  376.                                 } else if ($propertie->name == "brightness_y" && $propertie->value != 0) {
  377.                                     $propertie->value += $validArray['value'];
  378.                                     if ($propertie->value > 100) {
  379.                                         $propertie->value = 100;
  380.                                     }
  381.                                 }
  382.                                 if ($propertie->name == "powerstate") {
  383.                                     $propertie->value = "on";
  384.                                     break;
  385.                                 }
  386.                             }
  387.                             break;
  388.                         }
  389.                         case 'bright_down': {
  390.                             $brightnessWhite = '10';
  391.                             $brightnessYellow = '10';
  392.                             foreach ($devElement->properties as $propertie) {
  393.                                 error_log('name-->'.$propertie->name);
  394.                                 if ($propertie->name == "brightness_w" && $propertie->value != 0) {
  395.                                     $propertie->value -= $validArray['value'];
  396.                                     if ($propertie->value < 0) {
  397.                                         $propertie->value = 0;
  398.                                     }
  399.                                     $brightnessWhite = $propertie->value;
  400.                                 } else if ($propertie->name == "brightness_y" && $propertie->value != 0) {
  401.                                     $propertie->value -= $validArray['value'];
  402.                                     if ($propertie->value < 0) {
  403.                                         $propertie->value = 0;
  404.                                     }
  405.                                     $brightnessYellow = $propertie->value;
  406.                                 }
  407.                                 if ($brightnessWhite == 0 && $brightnessYellow == 0) {
  408.                                     foreach ($devElement->properties as $propertie) {
  409.                                         error_log('name-->'.$propertie->name);
  410.                                         if ($propertie->name == "powerstate") {
  411.                                                 $propertie->value = "off";
  412.                                                 break;
  413.                                         }
  414.                                     }
  415.                                 }
  416.                             }
  417.                             break;
  418.                         }
  419.                         case 'mode_set': {
  420.                             $brightnessWhite = '0';
  421.                             $brightnessYellow = '0';
  422.                             foreach ($devElement->properties as $propertie) {
  423.                                 error_log('name-->'.$propertie->name);
  424.                                 if ($propertie->name == "brightness_w") {
  425.                                     $brightnessWhite = $propertie->value;
  426.                                 } else if ($propertie->name == "brightness_y") {
  427.                                     $brightnessYellow = $propertie->value;
  428.                                 }
  429.                             }
  430.                             $brightness = ($brightnessWhite>$brightnessYellow)?$brightnessWhite:$brightnessYellow;
  431.                             foreach ($devElement->properties as $propertie) {
  432.                                 error_log('name-->'.$propertie->name);
  433.                                 if ($propertie->name == "brightness_w" || $propertie->name == "brightness_y") {
  434.                                     $propertie->value = $brightness;
  435.                                 }
  436.                             }
  437.                             break;
  438.                         }
  439.                         case 'color_set': {
  440.                             if ($validArray['value'] == 'White') {
  441.                                 foreach ($devElement->properties as $propertie) {
  442.                                     error_log('name-->'.$propertie->name);
  443.                                     if ($propertie->name == "brightness_w") {
  444.                                         $propertie->value = 100;
  445.                                     } else if ($propertie->name == "brightness_y") {
  446.                                         $propertie->value = 0;
  447.                                     }
  448.                                 }
  449.                             } else if ($validArray['value'] == 'Yellow') {
  450.                                 foreach ($devElement->properties as $propertie) {
  451.                                     error_log('name-->'.$propertie->name);
  452.                                     if ($propertie->name == "brightness_w") {
  453.                                         $propertie->value = 0;
  454.                                     } else if ($propertie->name == "brightness_y") {
  455.                                         $propertie->value = 100;
  456.                                     }
  457.                                 }
  458.                             }
  459.                             break;
  460.                         }
  461.                     }
  462.                     break;
  463.                 }
  464.             }
  465.         }
  466.     }
  467.     
  468.     $jsonData = json_encode($sqlObj);
  469.     error_log('jsonData-->'.$jsonData);
  470.     fclose($txtRes);
  471.     
  472.     if (($txtRes = fopen($sqlFileName, "w+")) === false) {
  473.         error_log('----get_control fopen failed----');
  474.         $ret = new AliGenie\ControlResponse(true);
  475.         $ret->header->putResponseMessageId($messageId);
  476.         $ret->payload->putResponseError("SERVICE_ERROR", "CANNOT_OPEN");
  477.         $retJson = json_encode($ret);
  478.         return $retJson;
  479.     }
  480.     if (!fwrite($txtRes, $jsonData)) {
  481.         fclose($txtRes);
  482.         error_log('----get_control fwrite failed----');
  483.         $ret = new AliGenie\ControlResponse(true);
  484.         $ret->header->putResponseMessageId($messageId);
  485.         $ret->payload->putResponseError("SERVICE_ERROR", "CANNOT_WRITE");
  486.         $retJson = json_encode($ret);
  487.         return $retJson;
  488.     }
  489.     fclose($txtRes);
  490.  
  491.     $retJson = json_encode($ret);
  492.     error_log('----device_control out----');
  493.     return $retJson;
  494. }
  495.  
  496. function check_type_from_id($deviceId)
  497. {
  498.     $deviceType = device_id_to_type($deviceId);
  499.     if ($deviceType != 'ceiling_lamp' && $deviceType != 'gateway_switch') {
  500.         $deviceType = "";
  501.     }
  502.     return $deviceType;
  503. }
  504.  
  505. function get_control_action($controlName)
  506. {
  507.     $action = "";
  508.     switch ($controlName) {
  509.     case 'TurnOn':
  510.         $action = 'turn_on';
  511.         break;
  512.     case 'TurnOff':
  513.         $action = 'turn_off';
  514.         break;
  515.     case 'SelectChannel':
  516.         $action = 'channel_set';
  517.         break;
  518.     case 'AdjustUpChannel':
  519.         $action = 'channel_up';
  520.         break;
  521.     case 'AdjustDownChannel':
  522.         $action = 'channel_down';
  523.         break;
  524.     case 'AdjustUpVolume':
  525.         $action = 'volume_up';
  526.         break;
  527.     case 'AdjustDownVolume':
  528.         $action = 'volume_down';
  529.         break;
  530.     case 'SetVolume':
  531.         $action = 'volume_set';
  532.         break;
  533.     case 'SetMute':
  534.         $action = 'mute_set';
  535.         break;
  536.     case 'CancelMute':
  537.         $action = 'mute_cancel';
  538.         break;
  539.     case 'Play':
  540.         $action = 'play';
  541.         break;
  542.     case 'Pause':
  543.         $action = 'pause';
  544.         break;
  545.     case 'Continue':
  546.         $action = 'continue';
  547.         break;
  548.     case 'Next':
  549.         $action = 'next';
  550.         break;
  551.     case 'Previous':
  552.         $action = 'previous';
  553.         break;
  554.     case 'SetBrightness':
  555.         $action = 'bright_set';
  556.         break;
  557.     case 'AdjustUpBrightness':
  558.         $action = 'bright_up';
  559.         break;
  560.     case 'AdjustDownBrightness':
  561.         $action = 'bright_down';
  562.         break;
  563.     case 'SetTemperature':
  564.         $action = 'temperature_set';
  565.         break;
  566.     case 'AdjustUpTemperature':
  567.         $action = 'temperature_up';
  568.         break;
  569.     case 'AdjustDownTemperature':
  570.         $action = 'temperature_down';
  571.         break;
  572.     case 'SetWindSpeed':
  573.         $action = 'windspeed_set';
  574.         break;
  575.     case 'AdjustUpWindSpeed':
  576.         $action = 'WindSpeed_up';
  577.         break;
  578.     case 'AdjustDownWindSpeed':
  579.         $action = 'WindSpeed_down';
  580.         break;
  581.     case 'SetMode':
  582.         $action = 'mode_set';
  583.         break;
  584.     case 'SetColor':
  585.         $action = 'color_set';
  586.         break;
  587.     case 'OpenFunction':
  588.         $action = 'function_open';
  589.         break;
  590.     case 'CloseFunction':
  591.         $action = 'function_close';
  592.         break;
  593.     case 'Cancel':
  594.         $action = 'cancel';
  595.         break;
  596.     case 'CancelMode':
  597.         $action = 'mode_cancel';
  598.         break;
  599.     default:
  600.         break;
  601.     }
  602.     return $action;
  603. }
  604.  
  605. function device_id_to_type($deviceId)
  606. {
  607.     $deviceType = "";
  608.     $deviceArray = [];
  609.     $deviceArray = explode('.', $deviceId);
  610.     $deviceType = $deviceArray[1];
  611.     return $deviceType;
  612. }
  613.  
  614. function device_id_to_devicetype($deviceId)
  615. {
  616.     $deviceType = "";
  617.     $deviceArray = [];
  618.     $deviceArray = explode('.', $deviceId);
  619.     $deviceType = $deviceArray[0];
  620.     return $deviceType;
  621. }
  622.  
  623. function control_checker($arrayData)
  624. {
  625.     error_log('----control_checker in----');
  626.     if (empty($arrayData)) {
  627.         return "jsonData null";
  628.     }
  629.  
  630.     switch ($arrayData['deviceType']) {
  631.     case 'ceiling_lamp': {
  632.         if ($arrayData['attribute'] == 'powerstate' || 
  633.             $arrayData['attribute'] == 'brightnessStep' || 
  634.             $arrayData['attribute'] == 'brightness' ) {//Full Support Request Action
  635.             return 'succeed';
  636.         }
  637.         if ($arrayData['attribute'] == 'mode' && $arrayData['value'] == '自然模式') {
  638.             return 'succeed';
  639.         }
  640.         if ($arrayData['attribute'] == 'color' && ($arrayData['value'] == 'White' || $arrayData['value'] == 'Yellow')) {
  641.             return 'succeed';
  642.         }
  643.         return 'failed';
  644.     }
  645.         break;
  646.     case 'gateway_switch': {
  647.     }
  648.         break;
  649.     default:
  650.         break;
  651.     }
  652.     error_log('----control_checker out----');
  653. }
  654.  
  655. ?>

 

相关工具

JSON格式化

在线JSON格式化工具，支持压缩和美化

JSON验证

验证JSON格式是否正确

JSON转换

JSON转XML、CSV等格式

JSON美化

美化JSON数据，提高可读性