设备通过DTU接入平台

YWJjZDEyMzQ1Njc4OTA=  base64 decode ---> abcd1234567890

{
  "version": "1.0",
  "properties": [
    {
      "id": "lac",
      "name": "地区区域码",
      "desc": "地区区域码",
      "required": true,
      "mode": "r",
      "define": {
        "type": "int",
        "unit": "",
        "step": "1",
        "min": "0",
        "max": "32",
        "start": "0"
      }
    },
    {
      "id": "cid",
      "name": "基站码",
      "desc": "基站码",
      "required": true,
      "mode": "r",
      "define": {
        "type": "int",
        "unit": "",
        "step": "1",
        "min": "0",
        "max": "32",
        "start": "0"
      }
    },
    {
      "id": "temperature",
      "name": "温度",
      "desc": "",
      "mode": "rw",
      "define": {
        "type": "float",
        "min": "0",
        "max": "100",
        "start": "0",
        "step": "1",
        "unit": "℃"
      },
      "required": false
    },
    {
      "id": "humidity",
      "name": "湿度",
      "desc": "",
      "mode": "rw",
      "define": {
        "type": "float",
        "min": "0",
        "max": "100",
        "start": "0",
        "step": "1",
        "unit": "%"
      },
      "required": false
    }
  ],
  "events": [],
  "actions": [],
  "profile": {
    "ProductId": "J6XJ01DT63",
    "CategoryId": "1"
  }
}

// 数据完整性检查
function checkCrc16(buffer) {
    let crc = 0xFFFF;
    let odd;
    for (let i = 0; i < buffer.length - 2; i++) {
        crc ^= buffer[i];
        for (let j = 0; j < 8; j++) {
            odd = crc & 0x0001;
            crc >>= 1;
            if (odd) {
                crc ^= 0xA001;
            }
        }
    }
    return (buffer[buffer.length - 1] << 8 | buffer[buffer.length - 2]) == crc;
}



// 上行数据解析函数，fPort为LoraWAN的端口号，这里可以不用关注。bytes：raw topic上报的裸数据
function RawToProtocol(fPort, bytes) {
    console.log(bytes);
    // 1. check crc16
    if (!checkCrc16(bytes)) {
        return {};
    }
    // 2. check is temp&RH 
    if (bytes[0] != 0x01 || bytes[1] != 0x03) {
        return {};
    }
    // 3. 构造数据模板的report消息
    let data = {
        "method": "report",
        "clientToken": new Date().getTime().toString(),
        "params": {}
    };
    // 4. 解析温湿度数据
    data.params.temperature = (bytes[5] << 8 | bytes[6]) / 10.0;
    data.params.humidity = (bytes[3] << 8 | bytes[4]) / 10.0;
    // 5. 返回构造好的数据到云平台
    return data;
}

// 生成CRC16校验码
function createCrc16(buffer) {
    let crc = 0xFFFF;
    let odd;
    for (let i = 0; i < buffer.length - 2; i++) {
        crc ^= buffer[i];
        for (let j = 0; j < 8; j++) {
            odd = crc & 0x0001;
            crc >>= 1;
            if (odd) {
                crc ^= 0xA001;
            }
        }
    }
    buffer[buffer.length - 2] = crc & 0xff;
    buffer[buffer.length - 1] = crc >> 8;
    return buffer;
}

// 下行测试数据，用于调试
const testControl= {
    "method": "control",
    "clientToken": "20a4ccfd-d308-11e9-86c6-5254008a4f10",
    "params": { "speed": 1, "a": 3, "dir": 0 }
}


// 下行数据解析函数
function ProtocolToRaw(obj) {
    // 通过DTU发送的电机控制数据
    let sendBytes = [0x01, 0x10, 0x00, 0xf6, 0x00, 0x03, 0x06, 0x00, 0x11, 0x00, 0x88, 0x00, 0x00, 0x7f, 0x75];
    if (obj.method == "control") {
        sendBytes[7] = obj.params.dir; // 电机方向
        sendBytes[8] = obj.params.a;   // 加速度
        sendBytes[9] = (obj.params.speed >> 8) & 0xff; // 速度
        sendBytes[10] = obj.params.speed & 0xff;
        createCrc16(sendBytes) // 生成CRC16校验数据
    }
    return sendBytes;
}


// 校验crc16是否正确
function checkCrc16(buffer) {
    let crc = 0xFFFF;
    let odd;
    for (let i = 0; i < buffer.length - 2; i++) {
        crc ^= buffer[i];
        for (let j = 0; j < 8; j++) {
            odd = crc & 0x0001;
            crc >>= 1;
            if (odd) {
                crc ^= 0xA001;
            }
        }
    }
    return (buffer[buffer.length - 1] << 8 | buffer[buffer.length - 2]) == crc;
}

// 测试数据
const testBytes = [1, 16, 0, 246, 0, 3, 96, 58];

// 上行数据解析
function RawToProtocol(fPort, bytes) {
    console.log(bytes);
    // 1. check crc16
    if (!checkCrc16(bytes)) {
        console.log("crc16 error");
        return {};
    }
    // 2. 这里只是对速度控制的上行数据做解析，如果有其他的上行数据 都可以在这里处理，如电机主动上报的一些数据，可以用report来解析上报
    if (bytes[0] != 0x01 || bytes[1] != 0x10) {
        return {};
    }
    let data = {
        "method": "control_reply", // 这里只是解析了速度控制的上行数据，构造了一条物模型数据
        "clientToken": new Date().getTime().toString(),
        "code": 0,
        "status": "success",
    };
    console.log(data)
    return data;
}