Charge-BleMessage

作用将硬件发来的原始字节流Listint解析成结构化的消息对象并处理可能的分包多个数据包拼成一条完整消息。分包机制解析假设要发送100字节的数据但蓝牙MTU限制每次只能传20字节 硬件会把数据分成5个包发送 第1包: size5, offset1, data[前20字节] 第2包: size5, offset2, data[第21-40字节] 第3包: size5, offset3, data[第41-60字节] 第4包: size5, offset4, data[第61-80字节] 第5包: size5, offset5, data[第81-100字节] BleMessage 的工作 1. 从第一包知道总共有5包 2. 接收每一包把数据合并到 payload 3. 当 size offset 时说明接收完成定义变量根据需要和协议的协定定义变量late int cmd; //命令类型 Listint payload []; //实际数据内容 late int len; //数据长度 bool _response false; //判断是否为回复 bool success true; //通信是否成功 late final Listint raw; //原始数据 /// 总包数 int size 0; /// 当前包 int offset 0;构造函数BleMessage.from(Listint data) { //协议头 cmd data[1] 0xFF; //命令类型 _response data[2] 0x02; //判断是否为回复 size (data[3] 0xF0) 4; //前四位为总帧数 offset data[3] 0x0F; //后四位为帧序号 len data[4] 0xFF; //数据长度 //提取实际数据 payload.addAll( data.sublist(5)); //如果是回复包检查最后一个字节 if(_response ) { success data.last 0; //协议协定 } raw data; Log.d(size: $size length: $len); }合并后续分片的方法void contact(Listint data) { raw.addAll(data); //保存原始数据 //空安全检查 if(size 0 || data[1] ! cmd || data[3] 0x0F 0) { Log.d(message contact error); return; } Log.d(size: $size offset $offset); offset data[3] 0x0F; //更新当前包序号 payload.addAll(data.sublist(5)); //合并数据 }提供给外部的get方法//判断是否已接收完所有分片 bool get isAll size offset; //命令执行是否成功 bool get isSuccess { if(_response ) { if(payload.last ! 0) { return false; } } return true; }代码示例import ../log.dart; import cmd_type.dart; ///蓝牙接收类(处理分包) // enum ErrorCode{ //OTA项目与充电宝项目无关 // success, // failed, // lengthError, // cmdError, // indexError, // notSupport, // switchError, // checkError, // packetLost, // } class BleMessage { //变量定义 late int cmd; //命令类型 Listint payload []; //实际数据内容 late int len; //数据长度 bool _response false; //判断是否为回复 bool success true; //通信是否成功 late final Listint raw; //原始数据 /// 总包数 int size 0; /// 当前包 int offset 0; // bool get response { //耳机项目与充电宝无关 // if(payload.isNotEmpty // payload.length 1 // (payload[0] DeviceInfoType.battery || // payload[0] DeviceInfoType.firmware || // payload[0] DeviceInfoType.port || // payload[0] DeviceInfoType.capacity || // payload[0] DeviceInfoType.model || // payload[0] DeviceInfoType.temperature // payload[0] DeviceInfoType.mtu || // payload[0] DeviceInfoType.tws || // payload[0] DeviceInfoType.twsState || // payload[0] DeviceInfoType.eq || // payload[0] DeviceInfoType.noiseLevel || // payload[0] DeviceInfoType.noiseLevelCount || // payload[0] DeviceInfoType.transparentLevel || // payload[0] DeviceInfoType.transparentLevelCount || // payload[0] DeviceInfoType.name || // payload[0] DeviceInfoType.version || // payload[0] DeviceInfoType.button || // payload[0] DeviceInfoType.language || // payload[0] DeviceInfoType.autoAnswer || // payload[0] DeviceInfoType.led || // payload[0] DeviceInfoType.mode || // payload[0] DeviceInfoType.face // )) { // return false; // } // return _response; // } //构造函数 BleMessage.from(Listint data) { //协议头 cmd data[1] 0xFF; //命令类型 _response data[2] 0x02; //判断是否为回复 size (data[3] 0xF0) 4; //前四位为总帧数 offset data[3] 0x0F; //后四位为帧序号 len data[4] 0xFF; //数据长度 //提取实际数据 payload.addAll( data.sublist(5)); //如果是回复包检查最后一个字节 if(_response ) { success data.last 0; //协议协定 } raw data; Log.d(size: $size length: $len); } //合并后续分片数据 void contact(Listint data) { raw.addAll(data); //保存原始数据 //空安全检查 if(size 0 || data[1] ! cmd || data[3] 0x0F 0) { Log.d(message contact error); return; } Log.d(size: $size offset $offset); offset data[3] 0x0F; //更新当前包序号 payload.addAll(data.sublist(5)); //合并数据 } //判断是否已接收完所有分片 bool get isAll size offset; //命令执行是否成功 bool get isSuccess { if(_response ) { if(payload.last ! 0) { return false; } } return true; } // int get errorCode payload.last; //OTA项目与充电宝项目无关 }