银尔达DTU配置

创建阿里云产品与设备

选择4G联网，数据格式为透传

产品创建好后，选择动态注册，选择这个是在银尔达DTU平台配置好参数后，阿里云会自动创建一个IMEI的设备，点击查看能看到ProductKey和ProductSecret

点击实例详情，可以看到银尔达DTU管理平台所需要的实例ID，点击查看开发配置，这里对应的是服务器地址

目前和银尔达官方资料是一样的，但他们给出的资料只是串口的发送接收，并不是物模型的上报数据和订阅消息，因此要上报数据的话，我们需要在产品中选择Topic类列表中选择物模型通信Topic，复制透传上行的发布于透传下行的订阅，粘贴到银尔达DTU管理平台的发布主题消息和订阅主题消息，注意 需要将deviceName改为IMEI，阿里云才能正确识别并动态注册设备

目前配置好后，可以看到设备自动创建了一个名为IMEI号的设备

点击产品，选中创建的产品，功能定义，前往编辑草稿，添加自定义功能，配置好后，选择发布上线

消息解析

点击消息解析

将下面代码复制粘贴

var COMMAND_REPORT = 0x00; //属性上报
var COMMAND_SET = 0x01; //属性设置
var COMMAND_REPORT_REPLY = 0x02; //上报数据返回结果
var COMMAND_SET_REPLY = 0x03; //属性设置设备返回结果
var COMMAD_UNKOWN = 0xff;    //未知的命令
var ALINK_PROP_REPORT_METHOD = 'thing.event.property.post';         //物联网平台Topic， 设备上传属性数据到云端
var ALINK_PROP_SET_METHOD = 'thing.service.property.set';           //物联网平台Topic， 云端下发属性控制指令到设备端
var ALINK_PROP_SET_REPLY_METHOD = 'thing.service.property.set';     //物联网平台Topic, 设备上报属性设置的结果到云端
function transformPayload(topic, rawData) {
    var jsonObj = {}
    return jsonObj;
}


/**
 * 将设备的自定义格式数据转换为Alink协议的数据，设备上报数据到物联网平台时调用
 * 入参：rawData byte[]数组     不能为空
 * 出参：jsonObj 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 = {
        'method': ALINK_PROP_REPORT_METHOD,
        'version': '1.0',
        'id': '' + dataView.getUint8(0), // 使用设备地址作为id
        'params': {
            // 数据从索引3开始，每个值2字节（大端）
            'temperature':(dataView.getUint8(3)*256+dataView.getUint8(4))/10,
            'humidity': (dataView.getUint8(5)*256+dataView.getUint8(6))/10,
            'co2': (dataView.getUint8(7)*256+dataView.getUint8(8)),
            'co': (dataView.getUint8(9)*256+dataView.getUint8(10)),
            'TVOC':(dataView.getUint8(11)*256+dataView.getUint8(12)),
            'PM2_5':(dataView.getUint8(13)*256+dataView.getUint8(14)),
            'CH2O':(dataView.getUint8(15)*256+dataView.getUint8(16)),
            'TCO2':(dataView.getUint8(17)*256+dataView.getUint8(18)),
            'PM10':(dataView.getUint8(19)*256+dataView.getUint8(20)),
            'NH3':(dataView.getUint8(21)*256+dataView.getUint8(22)),
            'O3':(dataView.getUint8(23)*256+dataView.getUint8(24)),
            'H2S':(dataView.getUint8(25)*256+dataView.getUint8(26))
        }
    };
    return jsonMap;
}

/**
 *  将Alink协议的数据转换为设备能识别的格式数据，物联网平台给设备下发数据时调用
 *  入参：jsonObj Alink JSON对象  不能为空
 *  出参：rawData 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 temperature= params['temperature'];
        var humidity= params['humidity'];
        var co2 = params['co2'];
        var co = params['co'];
        var TVOC = params['TVOC'];
        var PM2_5 = params['PM2_5'];
        var CH2O = params['CH2O'];
        var TCO2 = params['TCO2'];
        var PM10 = params['PM10'];
        var NH3 = params['NH3'];
        var O3 = params['O3'];
        var H2S = params['H2S'];

        //按照自定义协议格式拼接 rawData
        payloadArray = payloadArray.concat(buffer_uint8(COMMAND_SET));              // command字段
        payloadArray = payloadArray.concat(buffer_int8(parseInt(id)));             // ALink JSON格式 'id'，将Json格式id转为字符串
        payloadArray = payloadArray.concat(buffer_int8(temperature));      // 属性'FuelTankLiquidLevel'的值，要注意数据类型
        payloadArray = payloadArray.concat(buffer_int8(humidity));
        payloadArray = payloadArray.concat(buffer_int8(co2));
        payloadArray = payloadArray.concat(buffer_int8(co));
        payloadArray = payloadArray.concat(buffer_int8(TVOC));
        payloadArray = payloadArray.concat(buffer_int8(PM2_5));
        payloadArray = payloadArray.concat(buffer_int8(CH2O));
        payloadArray = payloadArray.concat(buffer_int8(TCO2));
        payloadArray = payloadArray.concat(buffer_int8(PM10));
        payloadArray = payloadArray.concat(buffer_int8(NH3));
        payloadArray = payloadArray.concat(buffer_int8(O3));
        payloadArray = payloadArray.concat(buffer_int8(H2S));
    } else if (method ==  ALINK_PROP_REPORT_METHOD) { //设备上报数据返回结果
        var code = json['code'];
        payloadArray = payloadArray.concat(buffer_uint8(COMMAND_REPORT_REPLY)); //command字段
        payloadArray = payloadArray.concat(buffer_int32(parseInt(id)));         // ALink JSON格式 'id'
        payloadArray = payloadArray.concat(buffer_uint8(code));
    } else { //未知命令，对于有些命令不做处理
        var code = json['code'];
        payloadArray = payloadArray.concat(buffer_uint8(COMMAD_UNKOWN));        //command字段
        payloadArray = payloadArray.concat(buffer_int32(parseInt(id)));         // ALink JSON格式 'id'
        payloadArray = payloadArray.concat(buffer_uint8(code));
    }
    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);
}

此外，粘贴完代码点击保存只是存在了消息解析草稿中，还需要使用数据来模拟输入，可以使用modbus poll 来进行测试，将RX信息粘贴到消息解析框中（请注意，阿里云平台模拟输入的十六进制消息必须是紧挨的 中间不能有空格 '0x' 否则会将其解析为十六进制，导致数据错乱）点击执行，可以看到数据正常解析。此时，提交按钮亮起，点击提交便可上传到正式版本中

目前已成功接收消息，如果数据不显示，可以去设备中的日志服务中查看错误码，并询问相关客服

这里可以讲一下我遇到的错误

消息解析失败 错误码26002

是银尔达DTU管理平台的modbus问询帧出现错误