:カスタムデータの解析に使用する JavaScript コードのサンプル

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'; // デバイスがプロパティデータを IoT Platform に送信するために使用する Topic。
var ALINK_PROP_SET_METHOD = 'thing.service.property.set'; // IoT Platform がデバイスにプロパティ設定コマンドを送信するために使用する Topic。
var ALINK_PROP_SET_REPLY_METHOD = 'thing.service.property.set'; // デバイスがプロパティ設定結果を IoT Platform に送信するために使用する Topic。
var SELF_DEFINE_TOPIC_UPDATE_FLAG = '/user/update'  // 次のカスタム Topic を定義します。/user/update。
var SELF_DEFINE_TOPIC_ERROR_FLAG = '/user/update/error' // 次のカスタム Topic を定義します。/user/update/error。
/*
サンプルデータ：
プロパティデータの送信
入力：
    0x000000000100320100000000
出力：
    {"method":"thing.event.property.post","id":"1","params":{"prop_float":0,"prop_int16":50,"prop_bool":1},"version":"1.0"}

プロパティ設定の結果
入力：
    0x0300223344c8
出力：
    {"code":"200","data":{},"id":"2241348","version":"1.0"}
*/
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; // プロパティを送信するために使用される Topic。データ形式：Alink JSON。
        jsonMap['version'] = '1.0'; // プロトコルのバージョン。この値は固定です。データ形式：Alink JSON。
        jsonMap['id'] = '' + dataView.getInt32(1); // リクエストの ID。データ形式：Alink JSON。
        var params = {};
        params['prop_int16'] = dataView.getInt16(5); // プロダクトの prop_int16 プロパティの値。
        params['prop_bool'] = uint8Array[7]; // プロダクトの prop_bool プロパティの値。
        params['prop_float'] = dataView.getFloat32(8); // プロダクトの prop_float プロパティの値。
        jsonMap['params'] = params; // params フィールド。データ形式：Alink JSON。
    } else if(fHead == COMMAND_SET_REPLY) {
        jsonMap['version'] = '1.0'; // プロトコルのバージョン。この値は固定です。データ形式：Alink JSON。
        jsonMap['id'] = '' + dataView.getInt32(1); // リクエストの ID。データ形式：Alink JSON。
        jsonMap['code'] = ''+ dataView.getUint8(5);
        jsonMap['data'] = {};
    }

    return jsonMap;
}
/*
サンプルデータ：
デバイスプロパティを設定するためのダウンストリームコマンドの送信
入力：
    {"method":"thing.service.property.set","id":"12345","version":"1.0","params":{"prop_float":123.452, "prop_int16":333, "prop_bool":1}}
出力：
    0x0100003039014d0142f6e76d

データ送信の結果
入力：
    {"method":"thing.event.property.post","id":"12345","version":"1.0","code":200,"data":{}}
出力：
    0x0200003039c8
*/
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_float = params['prop_float'];
        var prop_int16 = params['prop_int16'];
        var prop_bool = params['prop_bool'];
        // カスタムプロトコル形式に基づいて生データを連結します。
        payloadArray = payloadArray.concat(buffer_uint8(COMMAND_SET)); // コマンドフィールド。
        payloadArray = payloadArray.concat(buffer_int32(parseInt(id))); // リクエストの ID。データ形式：Alink JSON。
        payloadArray = payloadArray.concat(buffer_int16(prop_int16)); // prop_int16 プロパティの値。
        payloadArray = payloadArray.concat(buffer_uint8(prop_bool)); // prop_bool プロパティの値。
        payloadArray = payloadArray.concat(buffer_float32(prop_float)); // prop_float プロパティの値。
    } else if (method == ALINK_PROP_REPORT_METHOD) { // 応答。
        var code = json['code'];
        payloadArray = payloadArray.concat(buffer_uint8(COMMAND_REPORT_REPLY)); // コマンドフィールド。
        payloadArray = payloadArray.concat(buffer_int32(parseInt(id))); // リクエストの ID。データ形式：Alink JSON。
        payloadArray = payloadArray.concat(buffer_uint8(code));
    } else { // 不明なコマンド。これらのコマンドは処理されません。
        var code = json['code'];
        payloadArray = payloadArray.concat(buffer_uint8(COMMAND_UNKOWN)); // コマンドフィールド。
        payloadArray = payloadArray.concat(buffer_int32(parseInt(id))); // リクエストの ID。データ形式：Alink JSON。
        payloadArray = payloadArray.concat(buffer_uint8(code));
    }
    return payloadArray;
}

/*
  サンプルデータ
  次のカスタム Topic を使用してデータを送信します。
     /user/update。
  入力：
     Topic：/{productKey}/{deviceName}/user/update
     bytes：0x000000000100320100000000
  出力：
  {
     "prop_float": 0,
     "prop_int16": 50,
     "prop_bool": 1,
     "topic": "/{productKey}/{deviceName}/user/update"
   }
 */
function transformPayload(topic, 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 = {};

    if(topic.includes(SELF_DEFINE_TOPIC_ERROR_FLAG)) {
        jsonMap['topic'] = topic;
        jsonMap['errorCode'] = dataView.getInt8(0)
    } else if (topic.includes(SELF_DEFINE_TOPIC_UPDATE_FLAG)) {
        jsonMap['topic'] = topic;
        jsonMap['prop_int16'] = dataView.getInt16(5);
        jsonMap['prop_bool'] = uint8Array[7];
        jsonMap['prop_float'] = dataView.getFloat32(8);
    }

    return jsonMap;
}

// 次のコードはヘルパー関数を示しています。
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);
}