增加功能调用

simulator/scripts/demo-device.js

@@ -11,10 +11,10 @@ var events = {
     reportProperty: function (index, session) {
         var deviceId = devicePrefix + index;
         var topic = "/report-property";
-        var json =    JSON.stringify({
+        var json = JSON.stringify({
             "deviceId": deviceId,
             "success": true,
-            "timestamp":new Date().getTime(),
+            "timestamp": new Date().getTime(),
             properties: {"temperature": java.util.concurrent.ThreadLocalRandom.current().nextInt(20, 30)},
         });
         session.sendMessage(topic, json)
@@ -22,7 +22,7 @@ var events = {
     fireAlarm: function (index, session) {
         var deviceId = devicePrefix + index;
         var topic = "/fire_alarm/department/1/area/1/dev/" + deviceId;
-        var json =    JSON.stringify({
+        var json = JSON.stringify({
             "deviceId": deviceId, // 设备编号 "pid": "TBS-110", // 设备编号
             "a_name": "商务大厦", // 区域名称 "bid": 2, // 建筑 ID
             "b_name": "C2 栋", // 建筑名称
@@ -30,17 +30,17 @@ var events = {
             "timestamp": new Date().getTime() // 消息时间
         });
 
-        session.sendMessage(topic,json )
+        session.sendMessage(topic, json)
     }
 };
 
 //事件上报
 simulator.onEvent(function (index, session) {
     //上报属性
-   events.reportProperty(index, session);
+    events.reportProperty(index, session);
 
     //上报火警
-   events.fireAlarm(index,session);
+    events.fireAlarm(index, session);
 });
 
 simulator.bindHandler("/read-property", function (message, session) {
@@ -54,9 +54,20 @@ simulator.bindHandler("/read-property", function (message, session) {
     }));
 });
 
+simulator.bindHandler("/invoke-function", function (message, session) {
+    _logger.info("调用功能:[{}]", message);
+    session.sendMessage("/invoke-function", JSON.stringify({
+        messageId: message.messageId,
+        deviceId: message.deviceId,
+        timestamp: new Date().getTime(),
+        output: "ok", //返回结果
+        success: true
+    }));
+});
+
 
 simulator.onConnect(function (session) {
-   // _logger.info("[{}]:连接成功", session.auth.clientId);
+    // _logger.info("[{}]:连接成功", session.auth.clientId);
 });
 
 simulator.onAuth(function (index, auth) {