MQTT自定义透传_DTU毗连阿里云 - ToB企服应用市场:ToB评测及商务社交产业平台

var COMMAND_REPORT = 0x00;
var COMMAND_SET = 0x01;
var ALINK_PROP_REPORT_METHOD = 'thing.event.property.post'; //标准ALink JSON格式topic，设备上传属性数据到云端
var ALINK_PROP_SET_METHOD = 'thing.service.property.set'; //标准ALink JSON格式topic，云端下发属性控制指令到设备端
/**
* 将设备自定义topic数据转换为json格式数据, 设备上报数据到物联网平台时调用
* 入参：topic string 设备上报消息的topic
* 入参：rawData byte[]数组不能为空
* 出参：jsonObj JSON对象不能为空
*/
function transformPayload(topic, rawData) {
var jsonObj = {};
return jsonObj;
}
/**
* 将设备的自定义格式数据转换为Alink协议的数据，设备上报数据到物联网平台时调用
* 入参：bytes byte[]数组不能为空
* 出参：jsonMap Alink JSON对象不能为空
*/
function rawDataToProtocol(bytes) {
var uint8Array = new Uint8Array(bytes.length);
for (var i = 0; i < bytes.length; i++) {
uint8Array[i] = bytes[i] & 0xff;
}
var dataView = new DataView(uint8Array.buffer, 0);
var jsonMap = new Object();
var fHead = uint8Array[0];
if (fHead == COMMAND_REPORT) {
jsonMap['method'] = ALINK_PROP_REPORT_METHOD;
jsonMap['version'] = '1.0';
jsonMap['id'] = '' + dataView.getInt32(1);
var params = {};
params['LightVolt'] = dataView.getInt32(5);
params['PowerSwitch'] = uint8Array[9];
jsonMap['params'] = params;
}
return jsonMap;
}
/**
* 将Alink协议的数据转换为设备能识别的格式数据，物联网平台给设备下发数据时调用
* 入参：json Alink JSON对象不能为空
* 出参：payloadArray byte[]数组不能为空
*
*/
function protocolToRawData(json) {
var method = json['method'];
var id = json['id'];
var version = json['version'];
var payloadArray = [];
if (method == ALINK_PROP_SET_METHOD)
{
var params = json['params'];
var prop_int32 = params['LightVolt'];
var prop_bool = params['PowerSwitch'];
//按照自定义协议格式拼接 rawdata
payloadArray = payloadArray.concat(buffer_uint8(COMMAND_SET));
payloadArray = payloadArray.concat(buffer_int32(parseInt(id)));
payloadArray = payloadArray.concat(buffer_int32(parseInt(prop_int32)));
payloadArray = payloadArray.concat(buffer_uint8(prop_bool));
}
return payloadArray;
}
//以下是部分辅助函数
function buffer_uint8(value) {
var uint8Array = new Uint8Array(1);
var dv = new DataView(uint8Array.buffer, 0);
dv.setUint8(0, value);
return [].slice.call(uint8Array);
}
function buffer_int16(value) {
var uint8Array = new Uint8Array(2);
var dv = new DataView(uint8Array.buffer, 0);
dv.setInt16(0, value);
return [].slice.call(uint8Array);
}
function buffer_int32(value) {
var uint8Array = new Uint8Array(4);
var dv = new DataView(uint8Array.buffer, 0);
dv.setInt32(0, value);
return [].slice.call(uint8Array);
}
function buffer_float32(value) {
var uint8Array = new Uint8Array(4);
var dv = new DataView(uint8Array.buffer, 0);
dv.setFloat32(0, value);
return [].slice.call(uint8Array);
}
// 以下为脚本模版，您可以基于以下模版进行脚本编写
/**
* 将设备自定义topic数据转换为json格式数据, 设备上报数据到物联网平台时调用
* 入参：topic string 设备上报消息的topic
* 入参：rawData byte[]数组不能为空
* 出参：jsonObj JSON对象不能为空
*/
/* function transformPayload(topic, rawData) {
var jsonObj = {};
return jsonObj;
} */
/**
* 将设备的自定义格式数据转换为Alink协议的数据，设备上报数据到物联网平台时调用
* 入参：rawData byte[]数组不能为空
* 出参：jsonObj Alink JSON对象不能为空
*/
/* function rawDataToProtocol(rawData) {
var jsonObj = {};
return jsonObj;
} */
/**
* 将Alink协议的数据转换为设备能识别的格式数据，物联网平台给设备下发数据时调用
* 入参：jsonObj Alink JSON对象不能为空
* 出参：rawData byte[]数组不能为空
*
*/
/* function protocolToRawData(jsonObj) {
var rawdata = [];
return rawdata;
}
*/

复制代码