LoRaWAN协议

┌────────┐ ┌─────────┐ ┌────────────────┐ ┌───────────┐ │ Device │ -- │ Gateway │ -- │ Network Server │ --MQTT-- │ Acrel IoT │ └────────┘ └─────────┘ └────────────────┘ └───────────┘

/** * 上行解码器脚本 */ function uplinkDeviceDecode(bytes, input) { var decoded = {}; decoded.devEUI = LoRaObject.devEUI; decoded.rssi = LoRaObject.rxInfo[0].rssi; decoded.snr = LoRaObject.rxInfo[0].loRaSNR; decoded.fPort = LoRaObject.fPort; //原始数据，0x90透传报文需要用到 decoded.data = LoRaObject.data; //中台以此区分报文是否是经过脚本解析，默认置为true // true-未解析过的16进制报文 // false-解析为JSON报文 decoded.original = true; //中台产品型号productKey，联系中台研发获取 decoded.productKey = "ODAzMTU1MDA1ODcyMDc0NzUy"; //中台产品名称，联系中台研发获取 decoded.productName = "ADL200-NK"; var payload = {}; // 命令字91代表实时数据， if (bytes[3] === 0x91) { // 91报文是解析过的，这里修改标识 decoded.original = false; /* === START 需要修改的主要逻辑，依次解析电参量值 START === */ // 仪表地址，中台根据此地址生成拓扑 decoded.addr = bytes[4]; // modbus地址 decoded.MeterAddr = bytes[4]; // 仪表状态，0-offline 1-online decoded.MeterState = bytes[6]; decoded.EPI = bytesToFloat(bytes.slice(7, 11),2); decoded.EPIJ = bytesToFloat(bytes.slice(11, 15),2); decoded.EPIF = bytesToFloat(bytes.slice(15, 19),2); decoded.EPIP = bytesToFloat(bytes.slice(19, 23),2); decoded.EPIG = bytesToFloat(bytes.slice(23, 27),2); decoded.U = bytesToFloat(bytes.slice(27, 31),1); decoded.I = bytesToFloat(bytes.slice(31, 35),1); decoded.P = bytesToFloat(bytes.slice(35, 39),3); decoded.Q = bytesToFloat(bytes.slice(39, 43),1); decoded.S = bytesToFloat(bytes.slice(43, 47),1); decoded.PF = bytesToFloat(bytes.slice(47, 51),1); decoded.EPE = bytesToFloat(bytes.slice(51, 55),2); decoded.AlarmA = bytesToFloat(bytes.slice(55, 59),1); decoded.AlarmB = bytesToFloat(bytes.slice(59, 63),1); decoded.PowerLimit = bytesToFloat(bytes.slice(63, 67),2); decoded.BuyTimes = bytesToFloat(bytes.slice(67, 71),0); decoded.Balance = bytesToFloat(bytes.slice(71, 75),2); decoded.PriceSharp = bytesToFloat(bytes.slice(75, 79),2); decoded.PricePeak = bytesToFloat(bytes.slice(79, 83),2); decoded.PriceFlat = bytesToFloat(bytes.slice(83, 87),2); decoded.PriceVally = bytesToFloat(bytes.slice(87, 91),2); decoded.AlarmPower = bytesToFloat(bytes.slice(91, 95),2); decoded.PRESTATE = bytesToFloat(bytes.slice(95, 99),0); /* === END 需要修改的主要逻辑，依次解析电参量值 END === */ payload.data = decoded; return payload; } } // Chirpstack v4 使用的函数 function decodeUplink(input) { var decoded = uplinkDeviceDecode(input.bytes, input); return { data: decoded }; } // Chirpstack v3 使用的函数 function Decode(fPort, bytes) { return uplinkDeviceDecode(bytes); } // The Things Network 使用的函数 function Decoder(bytes, port) { return uplinkDeviceDecode(bytes); } /* ****************************************** * bytes to number ******************************************* */ function bytesToFloat(bytes, id, scale) { id = (id - 1) * 4; var buff = bytes.slice(7 + id, 7 + id + 4); var bits = (buff[0] << 24) | (buff[1] << 16) | (buff[2] << 8) | buff[3]; var sign = bits >>> 31 === 0 ? 1.0 : -1.0; var e = (bits >>> 23) & 0xff; var m = e === 0 ? (bits & 0x7fffff) << 1 : (bits & 0x7fffff) | 0x800000; var f = sign * m * Math.pow(2, e - 150); f = parseFloat(f.toFixed(scale)); return f; }

透传下发：7b 7b 10 90 01 03 00 00 00 10 44 06 9D 9F 7d 7d 包头：7b 7b 包长：10（总字节数，此处为 7b 7b 10 90 01 03 00 00 00 10 44 06 9D 9F 7d 7d 的字节数，共 16 字节，转换为 16 进制为 0x10） 功能码：90 数据体： 01 03 00 00 00 10 44 06（自定义输入，内容是通过 485 发送给电表的实际报文） CRC：9D 9F（10 90 01 03 00 00 00 10 44 06 部分做 CRC 校验，此处结果为 9D 9F） 固定包尾：7d 7d