From 8e3ad5a29a5b9e583eeb6e50d41c4b4c9e2a4c0b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=AD=8F=E5=B0=91=E9=98=B3?= <786612630@qq.com> Date: Wed, 9 Aug 2023 09:32:09 +0800 Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E6=9E=90=E8=93=9D=E7=89=99=E6=95=B0?= =?UTF-8?q?=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- star_lock/lib/blue/blue_manage.dart | 4 +- .../blue/io_protocol/io_getPrivateKey.dart | 41 ++++ .../lib/blue/io_protocol/io_getPublicKey.dart | 28 ++- star_lock/lib/blue/io_protocol/io_reply.dart | 17 +- star_lock/lib/blue/io_tool/cbc.dart | 36 ++++ star_lock/lib/blue/io_tool/io_tool.dart | 25 ++- star_lock/lib/blue/reciver_data.dart | 175 ++++++++---------- .../addLock/nearbyLock/nearbyLock_logic.dart | 2 +- star_lock/pubspec.yaml | 2 + 9 files changed, 211 insertions(+), 119 deletions(-) create mode 100644 star_lock/lib/blue/io_protocol/io_getPrivateKey.dart create mode 100644 star_lock/lib/blue/io_tool/cbc.dart diff --git a/star_lock/lib/blue/blue_manage.dart b/star_lock/lib/blue/blue_manage.dart index 20ae7646..f79b695d 100644 --- a/star_lock/lib/blue/blue_manage.dart +++ b/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 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"); }); diff --git a/star_lock/lib/blue/io_protocol/io_getPrivateKey.dart b/star_lock/lib/blue/io_protocol/io_getPrivateKey.dart new file mode 100644 index 00000000..59ce2aac --- /dev/null +++ b/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 messageDetail() { + List 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 dataDetail) + : super.parseData(commandType, dataDetail) { + print('获取私钥'); + int index = 0; + // while(index < endIndex){ + // commandKey = byteUInt8(dataDetail, index); + // index += offset_1; + // switch(commandKey){ + // + // } + // } + } +} \ No newline at end of file diff --git a/star_lock/lib/blue/io_protocol/io_getPublicKey.dart b/star_lock/lib/blue/io_protocol/io_getPublicKey.dart index 524321e1..0ff0226e 100644 --- a/star_lock/lib/blue/io_protocol/io_getPublicKey.dart +++ b/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 dataDetail) : super.parseData(commandType, dataDetail) { - print('获取公钥'); - int index = 0; - // while(index < endIndex){ - // commandKey = byteUInt8(dataDetail, index); - // index += offset_1; - // switch(commandKey){ - // - // } - // } + // print('获取公钥'); + switch(dataDetail[0]){ + case 0x00: + //成功 + print('获取公钥'); + break; + case 0x07: + //无权限 + + break; + case 0x0f: + //用户已存在 + + break; + default: + //失败 + + break; + } } } \ No newline at end of file diff --git a/star_lock/lib/blue/io_protocol/io_reply.dart b/star_lock/lib/blue/io_protocol/io_reply.dart index 02c7d482..540c13fa 100644 --- a/star_lock/lib/blue/io_protocol/io_reply.dart +++ b/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? offset_8 = 8; //草坪名称 - int? offset_6 = 6; //基准源识别码6个字节 - int? offset_4 = 4; - int? offset_2 = 2; - int? offset_1 = 1; + int? packetHeader = 4; // 包头4个字节 + int? packetType = 1; // 包类型1个字节 + int? packetNumber = 1; // 包序号 + int? packetIdentifier = 1; // 包标识 + int? packetLength = 4; // 包标识 CommandType? commandType; - int? result = 1; //1是正常 0 是异常 + int? packetMcrc = 2; // 校验位 //command key flag int commandKey = 0; Reply.parseData(this.commandType, List dataDetail); - Reply({this.result}); + // Reply({this.result}); - bool get isSuccessfully => result == 1; + // bool get isSuccessfully => packetHeader == EF01EE02; } \ No newline at end of file diff --git a/star_lock/lib/blue/io_tool/cbc.dart b/star_lock/lib/blue/io_tool/cbc.dart new file mode 100644 index 00000000..372bd823 --- /dev/null +++ b/star_lock/lib/blue/io_tool/cbc.dart @@ -0,0 +1,36 @@ + +class cbc{ + List 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 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 FK = [ + 0xa3b1bac6, 0x56aa3350, 0x677d9197, 0xb27022dc + ]; +} diff --git a/star_lock/lib/blue/io_tool/io_tool.dart b/star_lock/lib/blue/io_tool/io_tool.dart index 45e2a442..270962dc 100644 --- a/star_lock/lib/blue/io_tool/io_tool.dart +++ b/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(Listdata, 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; } diff --git a/star_lock/lib/blue/reciver_data.dart b/star_lock/lib/blue/reciver_data.dart index 5c101747..0d3f1f8b 100644 --- a/star_lock/lib/blue/reciver_data.dart +++ b/star_lock/lib/blue/reciver_data.dart @@ -10,114 +10,97 @@ import 'io_tool/manager_event_bus.dart'; class CommandReciverManager { - static Future parseRobot(List data) 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 _buffer = []; - - static void _clearBuffer(){ - _buffer = []; - _index = 0; - _bufSize = 0; - } - - static void appDataReceive(List data,{bool clear = false}) async { + static void appDataReceive(List data, String lockId) async { ///解析数据 - if(clear){ - _clearBuffer(); - } - int data_size = data.length; - if(data_size > _maxBufferSize){ + if(data.isEmpty){ return; } - if(_bufSize+data_size > _maxBufferSize){ - _index = 0; - _bufSize = 0; + int data_size = data.length; + // 当小于包头加起来13个字节 + if(data_size < 13){ + return; } - if(_index+_bufSize+data_size > _maxBufferSize){ - _buffer = _buffer.sublist(_index,_index + _bufSize); - _index = 0; - } - _buffer.addAll(data); - _bufSize += data.length; - int error; - // print('✅ 执行开始 _buffer:${_buffer.length}'); - do { - error = await appCheckProtocol(_buffer.sublist(_index),_bufSize); - // print('⚠️ $error'); - switch(error){ - case 0: - { - int protocolLen = _bufSize - _remainSize; - List tempData = _buffer.sublist(_index,_index + protocolLen); - _index += (_bufSize - _remainSize); - _bufSize = _remainSize; - if(tempData.isNotEmpty){ - parseRobot(tempData).then((value){ - EventBusManager().eventBusFir(value); - }); - } + print("appDataReceiveData:$data"); + if((data[0] == 0xEF)&&(data[1] == 0x01)&&(data[2] == 0xEE)&&(data[3] == 0x02)&&(data[4] == 0x11)){ + var tmpType = (data[7] & 0x0f);// 包标识 + print("temType:$tmpType"); + var dataLen = data[8] * 256 + data[9];// 高16位用来指示后面数据块内容的长度 + var oriLen = data[10] * 256 + data[11];// 低16位用来指示数据加密前的原长度 + List dataList = []; + List oriDataList = []; + switch(tmpType){ + case 0: //不加密 + for (var i = 0; i < oriLen ; i++) { + oriDataList.add(data[12 + i]); } + parseData(oriDataList).then((value) { + EventBusManager().eventBusFir(value); + }); break; - case 1: + case 1: //AES128 break; - case 2: - { - ++_index; - --_bufSize; - } + case 2: //SM4（事先约定密钥） + // for (var i = 0; i < dataLen ; i++) { + // dataList.add(data[12 + i]); + // } + //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: - error = 1; + case 3: //SM4（设备指定密钥） + // 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 appCheckProtocol(List data,int size) async{ - if(size < 7) return 1; - if(data[0] != 0xFA) return 2; - int payloadSize = data[2]; - if(payloadSize == 0) return 2; - int protocolSize = payloadSize +5; - if(size < protocolSize) return 1; - if(data[protocolSize-1] != 0xFF) return 2; - if(data[protocolSize-2] != checkSum(data.sublist(0,protocolSize - 2))) return 2; - _remainSize = size - protocolSize; - return 0; - } + static Future parseData(List data) async { + if(data.isNotEmpty){ + var cmd = data[0] * 256 + data[1]; + CommandType commandType = ExtensionCommandType.getCommandType(cmd); + data.removeRange(0, 2); + print("111111data:$data"); + var reply; + switch(commandType) { + case CommandType.getLockPublicKey: + { + 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; + } + } } \ No newline at end of file diff --git a/star_lock/lib/mine/addLock/nearbyLock/nearbyLock_logic.dart b/star_lock/lib/mine/addLock/nearbyLock/nearbyLock_logic.dart index 3d3df89f..a2f2ccc2 100644 --- a/star_lock/lib/mine/addLock/nearbyLock/nearbyLock_logic.dart +++ b/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 diff --git a/star_lock/pubspec.yaml b/star_lock/pubspec.yaml index 96444c9f..cab500e5 100644 --- a/star_lock/pubspec.yaml +++ b/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: