解析蓝牙数据

star_lock/lib/blue/blue_manage.dart

@@ -6,6 +6,7 @@ import 'package:star_lock/blue/sender_manage.dart';
 import '../app_settings/app_settings.dart';
 import 'io_tool/io_tool.dart';
 import 'io_tool/manager_event_bus.dart';
+import 'reciver_data.dart';
 
 typedef ScanResultCallBack = void Function(List<DiscoveredDevice> devices);
 
@@ -16,7 +17,6 @@ class BlueManage{
   DiscoveredCharacteristic? getDiscoveredCharacteristic;
   Uuid serviceId = Uuid.parse('0000FFF0-0000-1000-8000-00805F9B34FB');
   final int _limitLen = 20;
-  final int _sleepTimes = AppPlatform.isAndroid ? 6 : 0;
 
   static BlueManage? _manager;
   BlueManage._init();
@@ -139,7 +139,7 @@ class BlueManage{
     _flutterReactiveBle!.subscribeToCharacteristic(characteristic).listen((data) {
       // code to handle incoming data
       print("subscribeToCharacteristic: deviceId = ${characteristic.deviceId} characteristicId =${characteristic.characteristicId}---上报来的数据data = $data");
-
+      CommandReciverManager.appDataReceive(data, "");
     }, onError: (dynamic error) {
       print("subscribeToCharacteristic error:$error");
     });

star_lock/lib/blue/io_protocol/io_getPrivateKey.dart

@@ -0,0 +1,41 @@
+
+import 'dart:convert';
+
+import 'io_reply.dart';
+import 'io_sender.dart';
+import 'io_type.dart';
+
+class GetPrivateKeyCommand extends SenderProtocol {
+
+  String? lockID;
+  GetPrivateKeyCommand({
+    this.lockID,
+  }) : super(CommandType.getLockPublicKey);
+
+  @override
+  List<int> messageDetail() {
+    List<int> data = [];
+    print("lockID：${lockID!} lockID.utf8.encode${utf8.encode(lockID!)}");
+    data.addAll(utf8.encode(lockID!));
+    for(int i = 0; i<24; i++){
+      data.add(0);
+    }
+    print("dataaaaaa:$data");
+    return data;
+  }
+}
+
+class GetPrivateKeyReply extends Reply {
+  GetPrivateKeyReply.parseData(CommandType commandType,  List<int> dataDetail)
+      : super.parseData(commandType, dataDetail) {
+    print('获取私钥');
+    int index = 0;
+    // while(index < endIndex){
+    //   commandKey = byteUInt8(dataDetail, index);
+    //   index += offset_1;
+    //   switch(commandKey){
+    //
+    //   }
+    // }
+  }
+}

star_lock/lib/blue/io_protocol/io_getPublicKey.dart

@@ -28,14 +28,24 @@ class GetPublicKeyCommand extends SenderProtocol {
 class GetPublicKeyReply extends Reply {
   GetPublicKeyReply.parseData(CommandType commandType,  List<int> dataDetail)
       : super.parseData(commandType, dataDetail) {
-    print('获取公钥');
+    // print('获取公钥');
-    int index = 0;
+    switch(dataDetail[0]){
-    // while(index < endIndex){
+      case 0x00:
-    //   commandKey = byteUInt8(dataDetail, index);
+        //成功
-    //   index += offset_1;
+        print('获取公钥');
-    //   switch(commandKey){
+        break;
-    //
+      case 0x07:
-    //   }
+        //无权限
-    // }
+
+        break;
+      case 0x0f:
+        //用户已存在
+
+        break;
+      default:
+        //失败
+
+        break;
+    }
   }
 }

star_lock/lib/blue/io_protocol/io_reply.dart

@@ -2,22 +2,21 @@ import 'io_type.dart';
 
 abstract class Reply{
   //value字节长度
-  int? offset_19 = 19; //基准源长度
+  int? packetHeader = 4; // 包头4个字节
-  int? offset_8 = 8; //草坪名称
+  int? packetType = 1; // 包类型1个字节
-  int? offset_6 = 6; //基准源识别码6个字节
+  int? packetNumber = 1; // 包序号
-  int? offset_4 = 4;
+  int? packetIdentifier = 1; // 包标识
-  int? offset_2 = 2;
+  int? packetLength = 4; // 包标识
-  int? offset_1 = 1;
   CommandType? commandType;
-  int? result = 1; //1是正常 0 是异常
+  int? packetMcrc = 2; // 校验位
 
   //command key flag
   int commandKey = 0;
 
   Reply.parseData(this.commandType, List<int> dataDetail);
-  Reply({this.result});
+  // Reply({this.result});
 
 
-  bool get isSuccessfully => result == 1;
+  // bool get isSuccessfully => packetHeader == EF01EE02;
 
 }

star_lock/lib/blue/io_tool/cbc.dart

@@ -0,0 +1,36 @@
+
+class cbc{
+   List<int> Sbox = [
+    0xd6, 0x90, 0xe9, 0xfe, 0xcc, 0xe1, 0x3d, 0xb7, 0x16, 0xb6, 0x14, 0xc2, 0x28, 0xfb, 0x2c, 0x05,
+    0x2b, 0x67, 0x9a, 0x76, 0x2a, 0xbe, 0x04, 0xc3, 0xaa, 0x44, 0x13, 0x26, 0x49, 0x86, 0x06, 0x99,
+    0x9c, 0x42, 0x50, 0xf4, 0x91, 0xef, 0x98, 0x7a, 0x33, 0x54, 0x0b, 0x43, 0xed, 0xcf, 0xac, 0x62,
+    0xe4, 0xb3, 0x1c, 0xa9, 0xc9, 0x08, 0xe8, 0x95, 0x80, 0xdf, 0x94, 0xfa, 0x75, 0x8f, 0x3f, 0xa6,
+    0x47, 0x07, 0xa7, 0xfc, 0xf3, 0x73, 0x17, 0xba, 0x83, 0x59, 0x3c, 0x19, 0xe6, 0x85, 0x4f, 0xa8,
+    0x68, 0x6b, 0x81, 0xb2, 0x71, 0x64, 0xda, 0x8b, 0xf8, 0xeb, 0x0f, 0x4b, 0x70, 0x56, 0x9d, 0x35,
+    0x1e, 0x24, 0x0e, 0x5e, 0x63, 0x58, 0xd1, 0xa2, 0x25, 0x22, 0x7c, 0x3b, 0x01, 0x21, 0x78, 0x87,
+    0xd4, 0x00, 0x46, 0x57, 0x9f, 0xd3, 0x27, 0x52, 0x4c, 0x36, 0x02, 0xe7, 0xa0, 0xc4, 0xc8, 0x9e,
+    0xea, 0xbf, 0x8a, 0xd2, 0x40, 0xc7, 0x38, 0xb5, 0xa3, 0xf7, 0xf2, 0xce, 0xf9, 0x61, 0x15, 0xa1,
+    0xe0, 0xae, 0x5d, 0xa4, 0x9b, 0x34, 0x1a, 0x55, 0xad, 0x93, 0x32, 0x30, 0xf5, 0x8c, 0xb1, 0xe3,
+    0x1d, 0xf6, 0xe2, 0x2e, 0x82, 0x66, 0xca, 0x60, 0xc0, 0x29, 0x23, 0xab, 0x0d, 0x53, 0x4e, 0x6f,
+    0xd5, 0xdb, 0x37, 0x45, 0xde, 0xfd, 0x8e, 0x2f, 0x03, 0xff, 0x6a, 0x72, 0x6d, 0x6c, 0x5b, 0x51,
+    0x8d, 0x1b, 0xaf, 0x92, 0xbb, 0xdd, 0xbc, 0x7f, 0x11, 0xd9, 0x5c, 0x41, 0x1f, 0x10, 0x5a, 0xd8,
+    0x0a, 0xc1, 0x31, 0x88, 0xa5, 0xcd, 0x7b, 0xbd, 0x2d, 0x74, 0xd0, 0x12, 0xb8, 0xe5, 0xb4, 0xb0,
+    0x89, 0x69, 0x97, 0x4a, 0x0c, 0x96, 0x77, 0x7e, 0x65, 0xb9, 0xf1, 0x09, 0xc5, 0x6e, 0xc6, 0x84,
+    0x18, 0xf0, 0x7d, 0xec, 0x3a, 0xdc, 0x4d, 0x20, 0x79, 0xee, 0x5f, 0x3e, 0xd7, 0xcb, 0x39, 0x48
+  ];
+
+   List<int> CK = [
+    0x00070e15, 0x1c232a31, 0x383f464d, 0x545b6269,
+    0x70777e85, 0x8c939aa1, 0xa8afb6bd, 0xc4cbd2d9,
+    0xe0e7eef5, 0xfc030a11, 0x181f262d, 0x343b4249,
+    0x50575e65, 0x6c737a81, 0x888f969d, 0xa4abb2b9,
+    0xc0c7ced5, 0xdce3eaf1, 0xf8ff060d, 0x141b2229,
+    0x30373e45, 0x4c535a61, 0x686f767d, 0x848b9299,
+    0xa0a7aeb5, 0xbcc3cad1, 0xd8dfe6ed, 0xf4fb0209,
+    0x10171e25, 0x2c333a41, 0x484f565d, 0x646b7279
+  ];
+
+   List<int> FK = [
+    0xa3b1bac6, 0x56aa3350, 0x677d9197, 0xb27022dc
+  ];
+}

star_lock/lib/blue/io_tool/io_tool.dart

@@ -2,12 +2,33 @@ import 'dart:convert';
 import 'dart:typed_data';
 
 import 'package:flutter/services.dart';
+import 'package:encrypt/encrypt.dart';
+
+ String getDNSAPIStr(List<int>data, String key, String value) {
+   final key = Key.fromBase64('BwwfHxgKDwcXAxkWDwEHDBseIREPIA4QDxYOEBIDIRY=');
+   final iv = IV.fromBase64('FxIOBAcEEhISHgICCRYhEA==');
+   final encrypter = Encrypter(AES(key, mode: AESMode.cbc, padding: ""));
+   final encrypted = encrypter.encrypt('hello world', iv: iv);
+
+   return encrypted.toString();
+}
+
+// static setDNSAPIStr(String value) {
+// final key = Key.fromUtf8(RKNetworkManager().mSeeSkyLocalPrivateKey);
+// final iv = IV.fromUtf8(RKNetworkManager().mSeeSkyLocalPrivateKey);
+// final encrypter = Encrypter(AES(key, mode: AESMode.cbc, padding: "PKCS7"));
+// final encrypt = encrypter.encrypt(value, iv: iv);
+//
+// setCacheString(RKEnum.CACHE_STRING_APISTRURL, encrypt.base16);
+// }
+
+
 
 //int ---> 指定长度的hex (如指定长度为6的情况,0x000001 0x001234, 0xefab23)
-String intToFormatHex(int num) {
+String intToFormatHex(int num, int length) {
   String hexString = num.toRadixString(16);
   print("hexString=$hexString");
-  String formatString = hexString.padLeft(6, "0");
+  String formatString = hexString.padLeft(length, "0");
   print("formatHexString=$formatString");
   return formatString;
 }

star_lock/lib/blue/reciver_data.dart

@@ -10,114 +10,97 @@ import 'io_tool/manager_event_bus.dart';
 
 class CommandReciverManager {
 
-  static Future<Reply?> parseRobot(List<int> data) async {
+  static void appDataReceive(List<int> data, String lockId) async {
-    int commandIdx = data[1];
-    int len = data.length;
-    var dataDetail = data.sublist(4,len -2);
-    int ioType = data[3];
-    CommandType commandType =  ExtensionCommandType.getCommandType(ioType);
-
-    int endIndex = dataDetail.length - 1;
-    var reply;
-    switch(commandType) {
-      case CommandType.getLockPublicKey:
-        {
-          reply = GetPublicKeyReply.parseData(commandType, dataDetail);
-        }
-        break;
-      case CommandType.addUser:
-        {
-          reply = AddUserReply.parseData(commandType, dataDetail);
-        }
-        break;
-      case CommandType.openDoor:
-        {
-          reply = OpenDoorReply.parseData(commandType, dataDetail);
-        }
-        break;
-    }
-    return reply;
-  }
-
-
-  static int _bufSize = 0;
-  static int _index = 0;
-  static int _remainSize = 0;
-  static int _maxBufferSize = 260;
-
-  static List<int> _buffer = [];
-
-  static void _clearBuffer(){
-    _buffer = [];
-    _index = 0;
-    _bufSize = 0;
-  }
-
-  static void appDataReceive(List<int> data,{bool clear = false}) async {
     ///解析数据
-    if(clear){
+    if(data.isEmpty){
-      _clearBuffer();
-    }
-    int data_size = data.length;
-    if(data_size > _maxBufferSize){
       return;
     }
-    if(_bufSize+data_size > _maxBufferSize){
+    int data_size = data.length;
-      _index = 0;
+    // 当小于包头加起来13个字节
-      _bufSize = 0;
+    if(data_size < 13){
+      return;
     }
-    if(_index+_bufSize+data_size > _maxBufferSize){
+    print("appDataReceiveData:$data");
-      _buffer = _buffer.sublist(_index,_index + _bufSize);
+    if((data[0] == 0xEF)&&(data[1] == 0x01)&&(data[2] == 0xEE)&&(data[3] == 0x02)&&(data[4] == 0x11)){
-      _index = 0;
+      var tmpType = (data[7] & 0x0f);// 包标识
-    }
+      print("temType:$tmpType");
-    _buffer.addAll(data);
+      var dataLen = data[8] * 256 + data[9];// 高16位用来指示后面数据块内容的长度
-    _bufSize += data.length;
+      var oriLen = data[10] * 256 + data[11];// 低16位用来指示数据加密前的原长度
-    int error;
+      List<int> dataList = [];
-    // print('✅  执行开始 _buffer:${_buffer.length}');
+      List<int> oriDataList = [];
-    do {
+      switch(tmpType){
-      error = await appCheckProtocol(_buffer.sublist(_index),_bufSize);
+        case 0: //不加密
-      // print('⚠️  $error');
+          for (var i = 0; i < oriLen ; i++) {
-      switch(error){
+            oriDataList.add(data[12 + i]);
-        case 0:
-          {
-            int protocolLen = _bufSize - _remainSize;
-            List<int> tempData = _buffer.sublist(_index,_index + protocolLen);
-            _index += (_bufSize - _remainSize);
-            _bufSize = _remainSize;
-            if(tempData.isNotEmpty){
-              parseRobot(tempData).then((value){
-                EventBusManager().eventBusFir(value);
-              });
-            }
           }
+          parseData(oriDataList).then((value) {
+            EventBusManager().eventBusFir(value);
+          });
           break;
-        case 1:
+        case 1: //AES128
           break;
-        case 2:
+        case 2: //SM4（事先约定密钥）
-          {
+          // for (var i = 0; i < dataLen ; i++) {
-            ++_index;
+          //   dataList.add(data[12 + i]);
-            --_bufSize;
+          // }
-          }
+          //console.log("currCommStru.pairedName = ", currCommStru.pairedName);
+          // var d_cbc = cbc.decrypt_ecb(dataView, currCommStru.pairLockID, true, "nobase64");
+          // console.log("d_cbc = ", d_cbc);
+          // console.log("oriLen = ", oriLen);
+          // for (var i = 0; i < oriLen ; i++) {
+          //   oriDataView[i] = d_cbc[i];
+          // }
+          // console.log("oriDataView = ", oriDataView);
           break;
-        default:
+        case 3: //SM4（设备指定密钥）
-          error = 1;
+          // for (var i = 0; i < dataLen ; i++) {
+          //   dataView[i] = uint8Recv[12 + i];
+          // }
+          // console.log("dataView.length = ", dataView.length);
+          // console.log("currCommStru.pairCommKey = ", currCommStru.pairCommKey);
+          // var commKey1 = base64js.toByteArray(currCommStru.pairCommKey);
+          // console.log("commKey1 = ", commKey1);
+          // var d_cbc = cbc.decrypt_ecb(dataView, commKey1, false, "nobase64");
+          // console.log("d_cbc = ", d_cbc);
+          // console.log("oriLen = ", oriLen);
+          // for (var i = 0; i < oriLen ; i++) {
+          //   oriDataView[i] = d_cbc[i];
+          // }
+          // console.log("oriDataView = ", oriDataView);
           break;
+
       }
-    }while(error != 1);
+    }
+
     // print('✅  执行结束 _buffer:${_buffer.length}');
   }
 
-  static Future<int> appCheckProtocol(List<int> data,int size) async{
+  static Future<Reply?> parseData(List<int> data) async {
-    if(size < 7) return 1;
+    if(data.isNotEmpty){
-    if(data[0] != 0xFA) return 2;
+      var cmd = data[0] * 256 + data[1];
-    int payloadSize = data[2];
+      CommandType commandType =  ExtensionCommandType.getCommandType(cmd);
-    if(payloadSize == 0) return 2;
+      data.removeRange(0, 2);
-    int protocolSize = payloadSize +5;
+      print("111111data:$data");
-    if(size < protocolSize) return 1;
+      var reply;
-    if(data[protocolSize-1] != 0xFF) return 2;
+      switch(commandType) {
-    if(data[protocolSize-2] != checkSum(data.sublist(0,protocolSize - 2))) return 2;
+        case CommandType.getLockPublicKey:
-    _remainSize = size - protocolSize;
+          {
-    return 0;
+            reply = GetPublicKeyReply.parseData(commandType, data);
-  }
+          }
+          break;
+        case CommandType.addUser:
+          {
+            reply = AddUserReply.parseData(commandType, data);
+          }
+          break;
+        case CommandType.openDoor:
+          {
+            reply = OpenDoorReply.parseData(commandType, data);
+          }
+          break;
+      }
+      return reply;
+    }
 
+  }
 }

star_lock/lib/mine/addLock/nearbyLock/nearbyLock_logic.dart

@@ -65,8 +65,8 @@ class NearbyLockLogic extends BaseGetXController{
     super.onReady();
     print("onReady()");
 
-    _initSendStreamSubscription();
     _startListenIO();
+    _initSendStreamSubscription();
   }
 
   @override

star_lock/pubspec.yaml

@@ -84,6 +84,8 @@ dependencies:
   azlistview: ^2.0.0
   common_utils: ^2.0.0
   lpinyin: ^2.0.3
+  #加密解密
+  encrypt: ^5.0.1
 
 dev_dependencies:
   flutter_test: