在ThingsBoard中注册Mokosmart LoRaWAN设备和网关

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
var数据 = decodeToJson(载荷);

var deviceName = 数据.end_device_ids.device_id;
var deviceType = 数据.end_device_ids.application_ids.application_id;

// 若需对上行数据做解析，可在此函数中添加代码。
// input: bytes
// expected output:
// {
//"属性": {"attributeKey":"attributeValue"},
//"遥测": {"telemetryKey":"telemetryValue"}
// }
// 默认功能：将字节转为十六进制字符串，遥测键为 "HEX_bytes"
function decodeFrmPayload(input) {
 var output = { 属性:{}, 遥测: {} };
 // --- Decoding code --- //

 output.遥测.HEX_bytes = bytesToHex(input);

 // --- Decoding code --- //
 return output;
}

// --- 属性与遥测对象 ---
var遥测 = {};
var属性 = {};
// --- 属性与遥测对象 ---

// --- Timestamp parsing
var incomingDateString = 数据.uplink_message.received_at;
var dateString = incomingDateString.substring(0, incomingDateString.lastIndexOf(".")+3) +"Z";
var timestamp = new Date(dateString).getTime();
// --- Timestamp parsing

// 可手动向属性或遥测添加部分键
属性.f_port = 数据.uplink_message.f_port;
属性.设置 = 数据.uplink_message.设置;
// 将 correlation ids 保存为单一对象，故从属性解析中排除并在此手动添加
属性.correlation_ids = 数据.correlation_ids;

// 可从结果中排除部分键
var excludeFromAttributesList = ["device_id","application_id","uplink_message","correlation_ids"];
var excludeFromTelemetryList = ["uplink_token","gateway_id","设置"];

// 消息解析
// 为避免解码对象中出现路径，将 pathInKey 参数传为 false。
// 注意：pathInKey 可能导致已存在字段被最后一次找到的值覆盖，例如 uplink_message 的 receive_at 会写入根节点的 receive_at。
var telemetryData = toFlatMap(数据.uplink_message, excludeFromTelemetryList, false);
var attributesData = toFlatMap(数据, excludeFromAttributesList, false);

// 将上行字节传入 decodeFrmPayload 函数以得到自定义解码结果
var customDecoding = {};
if (数据.uplink_message.get("frm_payload") != null) {
 customDecoding = decodeFrmPayload(base64ToBytes(数据.uplink_message.frm_payload));
}

// 将数据汇总到结果
if (customDecoding.?遥测.size() > 0) {
 遥测.putAll(customDecoding.遥测);
}

if (customDecoding.?属性.size() > 0) {
 属性.putAll(customDecoding.属性);
}

遥测.putAll(telemetryData);
属性.putAll(attributesData);

var result = {
 deviceName: deviceName,
 deviceType: deviceType,
 遥测: {
 ts: timestamp,
 values: 遥测
 },
 属性: 属性
};

return result;