sky/app-starlock
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

调试开锁协议、获取锁状态协议

Browse Source
This commit is contained in:
魏少阳 2023-08-16 18:21:42 +08:00
parent 796cd3a0f6
commit 9cfa39bd5e
16 changed files with 608 additions and 147 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
star_lock/lib/blue/blue_manage.dart
View File

@ -1,10 +1,14 @@
import 'dart:async';
import 'package:flutter/material.dart'; import 'package:flutter/material.dart';
import 'package:flutter_reactive_ble/flutter_reactive_ble.dart'; import 'package:flutter_reactive_ble/flutter_reactive_ble.dart';
import 'package:star_lock/blue/sender_manage.dart'; import 'package:star_lock/blue/sender_manage.dart';
import '../app_settings/app_settings.dart'; import '../app_settings/app_settings.dart';
import '../tools/storage.dart';
import 'io_tool/io_manager.dart'; import 'io_tool/io_manager.dart';
import 'io_tool/io_model.dart';
import 'io_tool/io_tool.dart'; import 'io_tool/io_tool.dart';
import 'io_tool/manager_event_bus.dart'; import 'io_tool/manager_event_bus.dart';
import 'reciver_data.dart'; import 'reciver_data.dart';
@ -19,6 +23,11 @@ class BlueManage{
Uuid serviceId = Uuid.parse('0000FFF0-0000-1000-8000-00805F9B34FB'); Uuid serviceId = Uuid.parse('0000FFF0-0000-1000-8000-00805F9B34FB');
final int _limitLen = 20; final int _limitLen = 20;
// 监听发送事件
StreamSubscription<EventSendModel>? _sendStreamSubscription;
// 监听蓝牙连接状态
DeviceConnectionState? deviceConnectionState;
static BlueManage? _manager; static BlueManage? _manager;
BlueManage._init(); BlueManage._init();
@ -33,6 +42,22 @@ class BlueManage{
void _initBlue(){ void _initBlue(){
_flutterReactiveBle = FlutterReactiveBle(); _flutterReactiveBle = FlutterReactiveBle();
_initSendStreamSubscription();
}
void _initSendStreamSubscription() {
_sendStreamSubscription = EventBusManager().eventBus!.on<EventSendModel>().listen((
EventSendModel model) {
if (model.sendChannel == DataChannel.ble) {
// managerAppWriteData(model.data);
writeCharacteristicWithResponse(QualifiedCharacteristic(
deviceId:qualifiedCharacteristic!.deviceId,
characteristicId: qualifiedCharacteristic!.characteristicId,
serviceId: serviceId),
model.data);
}
});
} }
/// 开始扫描蓝牙设备 /// 开始扫描蓝牙设备
@ -64,15 +89,16 @@ class BlueManage{
/// 连接监听状态 /// 连接监听状态
Future<void> connect(String deviceMAC, String deviceName) async { Future<void> connect(String deviceMAC, String deviceName) async {
print("connect:$deviceMAC"); print("connect:$deviceMAC");
_flutterReactiveBle!.connectToDevice(id: deviceMAC).listen((connectionStateUpdate) { _flutterReactiveBle!.connectToDevice(id: deviceMAC).listen((connectionStateUpdate) async {
print('ConnectionState for device $deviceMAC : ${connectionStateUpdate.connectionState}'); print('ConnectionState for device $deviceMAC : ${connectionStateUpdate.connectionState}');
// EventBusManager().eventBusFir(connectionStateUpdate); // EventBusManager().eventBusFir(connectionStateUpdate);
deviceConnectionState = connectionStateUpdate.connectionState;
if(connectionStateUpdate.connectionState == DeviceConnectionState.connected){ if(connectionStateUpdate.connectionState == DeviceConnectionState.connected){
// getPublicKey(update.deviceId); // getPublicKey(update.deviceId);
// 先配置lockId // 先配置lockId
IoManager().configCurrentDeviceLockId(deviceName); IoManager().configCurrentDeviceLockId(deviceName);
// 如果状态是连接的开始发现服务 // 如果状态是连接的开始发现服务
discoverServices(deviceMAC); await discoverServices(deviceMAC);
} }
}, onError: (Object e){ }, onError: (Object e){
print('Connecting to device $deviceMAC resulted in error $e'); print('Connecting to device $deviceMAC resulted in error $e');
@ -170,8 +196,6 @@ class BlueManage{
} }
} }
// 读取 // 读取
Future<List<int>> readCharacteristic(QualifiedCharacteristic characteristic) async { Future<List<int>> readCharacteristic(QualifiedCharacteristic characteristic) async {
try { try {
@ -197,4 +221,7 @@ class BlueManage{
} }
} }
disposed(){
_sendStreamSubscription?.cancel();
}
} }

34
star_lock/lib/blue/io_protocol/io_addUser.dart
View File

@ -1,8 +1,6 @@
import 'dart:convert'; import 'dart:convert';
import '../../tools/storage.dart';
import '../io_tool/io_manager.dart';
import '../io_tool/io_tool.dart'; import '../io_tool/io_tool.dart';
import '../sm4Encipher/sm4.dart'; import '../sm4Encipher/sm4.dart';
import 'io_reply.dart'; import 'io_reply.dart';
@ -59,23 +57,27 @@ class AddUserCommand extends SenderProtocol {
// 锁id 40 // 锁id 40
int lockIDLength = utf8.encode(lockID!).length; int lockIDLength = utf8.encode(lockID!).length;
print("addUserLockIDLength:$lockIDLength utf8.encode(lockID!)${utf8.encode(lockID!)}");
data.addAll(utf8.encode(lockID!)); data.addAll(utf8.encode(lockID!));
data = getFixedLengthList(data, 40 - lockIDLength); data = getFixedLengthList(data, 40 - lockIDLength);
//authUserID 20 //authUserID 20
int authUserIDLength = utf8.encode(authUserID!).length; int authUserIDLength = utf8.encode(authUserID!).length;
print("authUserIDLength:$authUserIDLength utf8.encode(authUserID!)${utf8.encode(authUserID!)}");
data.addAll(utf8.encode(authUserID!)); data.addAll(utf8.encode(authUserID!));
data = getFixedLengthList(data, 20 - authUserIDLength); data = getFixedLengthList(data, 20 - authUserIDLength);
//KeyID 40 //KeyID 40
int keyIDLength = utf8.encode(keyID!).length; int keyIDLength = utf8.encode(keyID!).length;
print("keyIDLength:$keyIDLength utf8.encode(keyID!)${utf8.encode(keyID!)}");
data.addAll(utf8.encode(keyID!)); data.addAll(utf8.encode(keyID!));
data = getFixedLengthList(data, 40 - keyIDLength); data = getFixedLengthList(data, 40 - keyIDLength);
//userID 要接受钥匙的用户的useid 20 //userID 要接受钥匙的用户的useid 20
int userIDLength = utf8.encode(authUserID!).length; int userIDLength = utf8.encode(userID!).length;
data.addAll(utf8.encode(authUserID!)); print("userIDLength:$userIDLength utf8.encode(userID!)${utf8.encode(userID!)}");
data = getFixedLengthList(data, 20 - authUserIDLength); data.addAll(utf8.encode(userID!));
data = getFixedLengthList(data, 20 - userIDLength);
// openModel // openModel
data.add(openMode!); data.add(openMode!);
@ -112,30 +114,30 @@ class AddUserCommand extends SenderProtocol {
data.addAll(utf8.encode(password!)); data.addAll(utf8.encode(password!));
data = getFixedLengthList(data, 20 - passwordLength); data = getFixedLengthList(data, 20 - passwordLength);
if(needAuthor == 0){ // token 长度4 首次请求 Token 填 0，如果锁需要鉴权 操作者身份，则会分配动态口令并在应答消息中返回，二次请求时带上。 当token失效或者第一次发送的时候token为0
// 当token失效或者第一次发送的时候token为0 data.addAll(token!);
//Token 4 print("pubToken:$token");
data.addAll(token!);
if(needAuthor == 0){
//AuthCodeLen 1 //AuthCodeLen 1
data.add(0); data.add(0);
} else { } else {
// token 长度4 首次请求 Token 填 0，如果锁需要鉴权 操作者身份，则会分配动态口令并在应答消息中返回，二次请求时带上。
data.addAll(token!);
List<int> authCodeData = []; List<int> authCodeData = [];
//KeyID
authCodeData.addAll(utf8.encode(keyID!));
//authUserID //authUserID
authCodeData.addAll(utf8.encode(authUserID!)); authCodeData.addAll(utf8.encode(authUserID!));
//KeyID
authCodeData.addAll(utf8.encode(keyID!));
//token 4 首次请求 Token 填 0，如果锁需要鉴权操作者身份，则会分配动态口令并在应答消息中返回，二次请求时带上。 //token 4 首次请求 Token 填 0，如果锁需要鉴权操作者身份，则会分配动态口令并在应答消息中返回，二次请求时带上。
data.addAll([0, 0, 0, 0]); print("token!.reversed.toList():${token!.reversed.toList()}");
authCodeData.addAll(token!);
authCodeData.addAll(publicKey!); authCodeData.addAll(publicKey!);
print("addUser-authCodeData:$authCodeData");
// 把KeyID、authUserID、时间戳、公钥通过md5加密之后就是authCode // 把KeyID、authUserID、时间戳、公钥通过md5加密之后就是authCode
var authCode = crypto.md5.convert(authCodeData); var authCode = crypto.md5.convert(authCodeData);

65
star_lock/lib/blue/io_protocol/io_getLockStatu.dart Normal file
View File

@ -0,0 +1,65 @@
//TODO:获取锁状态
import 'dart:convert';
import '../io_tool/io_tool.dart';
import '../sm4Encipher/sm4.dart';
import 'io_reply.dart';
import 'io_sender.dart';
import 'io_type.dart';
class GetLockStatuCommand extends SenderProtocol {
String? lockID;
String? userID;
List<int>? privateKey;
GetLockStatuCommand({
this.lockID,
this.userID,
this.privateKey
}) : super(CommandType.readLockStatusInfo);
@override
List<int> messageDetail() {
List<int> data = [];
List<int> ebcData = [];
// 指令类型
int type = commandType!.typeValue;
double typeDouble = type / 256;
int type1 = typeDouble.toInt();
int type2 = type % 256;
data.add(type1);
data.add(type2);
// 锁id 40
int lockIDLength = utf8.encode(lockID!).length;
print("addUserLockIDLength:$lockIDLength utf8.encode(lockID!)${utf8.encode(lockID!)}");
data.addAll(utf8.encode(lockID!));
data = getFixedLengthList(data, 40 - lockIDLength);
//userID 要接受钥匙的用户的useid 20
int userIDLength = utf8.encode(userID!).length;
print("userIDLength:$userIDLength utf8.encode(userID!)${utf8.encode(userID!)}");
data.addAll(utf8.encode(userID!));
data = getFixedLengthList(data, 20 - userIDLength);
if ((data.length % 16) != 0) {
int add = (16 - data.length % 16);
for (int i = 0; i < add; i++) {
data.add(0);
}
}
print("addUserSM4Data:$data");
// 拿到数据之后通过LockId进行SM4 ECB加密 key:544d485f633335373034383064613864
ebcData = SM4.encrypt(data, key: privateKey, mode: SM4CryptoMode.ECB);
return ebcData;
}
}
class GetLockStatuReply extends Reply {
GetLockStatuReply.parseData(CommandType commandType, List<int> dataDetail)
: super.parseData(commandType, dataDetail) {
data = dataDetail;
}
}

6
star_lock/lib/blue/io_protocol/io_getPrivateKey.dart
View File

@ -77,12 +77,12 @@ class GetPrivateKeyCommand extends SenderProtocol {
} else { } else {
List<int> authCodeData = []; List<int> authCodeData = [];
//KeyID
authCodeData.addAll(utf8.encode(keyID!));
//authUserID //authUserID
authCodeData.addAll(utf8.encode(authUserID!)); authCodeData.addAll(utf8.encode(authUserID!));
//KeyID
authCodeData.addAll(utf8.encode(keyID!));
//NowTime 4 //NowTime 4
// DateTime now = DateTime.now(); // DateTime now = DateTime.now();
// int timestamp = now.millisecondsSinceEpoch; // int timestamp = now.millisecondsSinceEpoch;

53
star_lock/lib/blue/io_protocol/io_openDoor.dart
View File

@ -1,53 +0,0 @@
import 'dart:convert';
import '../io_tool/io_tool.dart';
import 'io_reply.dart';
import 'io_sender.dart';
import 'io_type.dart';
//TODO:开门
class OpenDoorCommand extends SenderProtocol {
int? cmdID;
String? keyID;
String? userID;
int? openMode;
int? openTime;
int? token;
int? authCodeLen;
String? authCode;
OpenDoorCommand({
this.cmdID,
this.keyID,
this.userID,
this.openMode,
this.openTime,
this.token,
this.authCodeLen,
this.authCode,
}) : super(CommandType.openDoor);
@override
List<int> messageDetail() {
List<int> data = [];
data.addAll(intToInt8List(cmdID!));
data.addAll(utf8.encode(keyID!));
data.addAll(utf8.encode(userID!));
data.addAll(intToInt8List(openMode!));
data.addAll(intToInt8List(openTime!));
data.addAll(intToInt8List(token!));
data.addAll(intToInt8List(authCodeLen!));
data.addAll(utf8.encode(authCode!));
return data;
}
}
class OpenDoorReply extends Reply {
OpenDoorReply.parseData(CommandType commandType, List<int> dataDetail)
: super.parseData(commandType, dataDetail) {
int index = 0;
}
}

110
star_lock/lib/blue/io_protocol/io_openLock.dart Normal file
View File

@ -0,0 +1,110 @@
import 'dart:convert';
import '../io_tool/io_tool.dart';
import '../sm4Encipher/sm4.dart';
import 'io_reply.dart';
import 'io_sender.dart';
import 'io_type.dart';
import 'package:crypto/crypto.dart' as crypto;
//TODO:开门
class OpenLockCommand extends SenderProtocol {
String? keyID;
String? userID;
int? openMode;
int? openTime;
List<int>? token;
int? needAuthor;
List<int>? signKey;
List<int>? privateKey;
OpenLockCommand({
this.keyID,
this.userID,
this.openMode,
this.openTime,
this.token,
this.needAuthor,
this.signKey,
this.privateKey
}) : super(CommandType.openLock);
@override
List<int> messageDetail() {
List<int> data = [];
List<int> ebcData = [];
// 指令类型
int type = commandType!.typeValue;
double typeDouble = type / 256;
int type1 = typeDouble.toInt();
int type2 = type % 256;
data.add(type1);
data.add(type2);
//KeyID 40
int keyIDLength = utf8.encode(keyID!).length;
data.addAll(utf8.encode(keyID!));
data = getFixedLengthList(data, 40 - keyIDLength);
//userID 要接受钥匙的用户的useid 20
int userIDLength = utf8.encode(userID!).length;
print("openDoorUserId:${utf8.encode(userID!)} utf8.encode(userID!).length:${utf8.encode(userID!).length}");
data.addAll(utf8.encode(userID!));
data = getFixedLengthList(data, 20 - userIDLength);
// openModel
data.add(openMode!);
// OpenTime 4
int? d1 = openTime;
data.add((d1! & 0xff000000) >> 24);
data.add((d1 & 0xff0000) >> 16);
data.add((d1 & 0xff00) >> 8);
data.add((d1 & 0xff));
// token 长度4 首次请求 Token 填 0，如果锁需要鉴权 操作者身份，则会分配动态口令并在应答消息中返回，二次请求时带上。 当token失效或者第一次发送的时候token为0
data.addAll(token!);
print("pubToken:$token");
if(needAuthor == 0){
//AuthCodeLen 1
data.add(0);
} else {
List<int> authCodeData = [];
//KeyID
authCodeData.addAll(utf8.encode(keyID!));
//UserID
authCodeData.addAll(utf8.encode(userID!));
//token 4 首次请求 Token 填 0，如果锁需要鉴权操作者身份，则会分配动态口令并在应答消息中返回，二次请求时带上。
authCodeData.addAll(token!);
authCodeData.addAll(signKey!);
// 把KeyID、authUserID、时间戳、公钥通过md5加密之后就是authCode
var authCode = crypto.md5.convert(authCodeData);
data.add(authCode.bytes.length);
data.addAll(authCode.bytes);
}
if ((data.length % 16) != 0) {
int add = (16 - data.length % 16);
for (int i = 0; i < add; i++) {
data.add(0);
}
}
print("addUserSM4Data:$data");
// 拿到数据之后通过LockId进行SM4 ECB加密 key:544d485f633335373034383064613864
ebcData = SM4.encrypt(data, key: privateKey, mode: SM4CryptoMode.ECB);
return ebcData;
}
}
class OpenDoorReply extends Reply {
OpenDoorReply.parseData(CommandType commandType, List<int> dataDetail)
: super.parseData(commandType, dataDetail) {
data = dataDetail;
}
}

6
star_lock/lib/blue/io_protocol/io_type.dart
View File

@ -6,7 +6,7 @@ enum CommandType {
deletUser , //删除用户 = 0x3002 deletUser , //删除用户 = 0x3002
modifyingUser , //修改用户 = 0x3003 modifyingUser , //修改用户 = 0x3003
factoryDataReset , //恢复出厂设置 = 0x3004 factoryDataReset , //恢复出厂设置 = 0x3004
openDoor , //开门 = 0x3005 openLock , //开门 = 0x3005
readLockStatusInfo, //读取锁状态信息 = 0x300A readLockStatusInfo, //读取锁状态信息 = 0x300A
transferPermissions, //转移权限 = 0x300B transferPermissions, //转移权限 = 0x300B
reportDoorOpenRecord, //开门记录上报 = 0x3020 reportDoorOpenRecord, //开门记录上报 = 0x3020
@ -47,7 +47,7 @@ extension ExtensionCommandType on CommandType {
break; break;
case 0x3005: case 0x3005:
{ {
type = CommandType.openDoor; type = CommandType.openLock;
} }
break; break;
case 0x300A: case 0x300A:
@ -124,7 +124,7 @@ extension ExtensionCommandType on CommandType {
case CommandType.factoryDataReset: case CommandType.factoryDataReset:
type = 0x3004; type = 0x3004;
break; break;
case CommandType.openDoor: case CommandType.openLock:
type = 0x3005; type = 0x3005;
break; break;
case CommandType.readLockStatusInfo: case CommandType.readLockStatusInfo:

2
star_lock/lib/blue/io_tool/io_manager.dart
View File

@ -6,7 +6,7 @@ enum DataTransmissionMode {
const saveBluePublicKey = "BluePublicKey"; const saveBluePublicKey = "BluePublicKey";
const saveBluePrivateKey = "BluePrivateKey"; const saveBluePrivateKey = "BluePrivateKey";
const saveBlueSignKey = "BlueSignKey"; const saveBlueSignKey = "BlueSignKey";
const saveBlueToken = "BlueToken"; const saveBlueToken = "BlueGetToken";
class IoManager { class IoManager {

12
star_lock/lib/blue/reciver_data.dart
View File

@ -2,11 +2,13 @@
import 'dart:convert'; import 'dart:convert';
import 'package:star_lock/blue/io_protocol/io_getLockStatu.dart';
import '../tools/storage.dart'; import '../tools/storage.dart';
import 'io_protocol/io_addUser.dart'; import 'io_protocol/io_addUser.dart';
import 'io_protocol/io_getPrivateKey.dart'; import 'io_protocol/io_getPrivateKey.dart';
import 'io_protocol/io_getPublicKey.dart'; import 'io_protocol/io_getPublicKey.dart';
import 'io_protocol/io_openDoor.dart'; import 'io_protocol/io_openLock.dart';
import 'io_protocol/io_reply.dart'; import 'io_protocol/io_reply.dart';
import 'io_protocol/io_type.dart'; import 'io_protocol/io_type.dart';
import 'io_tool/io_manager.dart'; import 'io_tool/io_manager.dart';
@ -64,6 +66,7 @@ class CommandReciverManager {
var res = await Storage.getStringList(saveBluePrivateKey); var res = await Storage.getStringList(saveBluePrivateKey);
List<int> getPrivateKeyList = changeStringListToIntList(res!); List<int> getPrivateKeyList = changeStringListToIntList(res!);
print("getPrivateKeyList$getPrivateKeyList");
// 解密 // 解密
// String key = SM4.createHexKey(key: radixHex16String(getPrivateKeyList!)); // String key = SM4.createHexKey(key: radixHex16String(getPrivateKeyList!));
@ -104,11 +107,16 @@ class CommandReciverManager {
reply = AddUserReply.parseData(commandType, data); reply = AddUserReply.parseData(commandType, data);
} }
break; break;
case CommandType.openDoor: case CommandType.openLock:
{ {
reply = OpenDoorReply.parseData(commandType, data); reply = OpenDoorReply.parseData(commandType, data);
} }
break; break;
case CommandType.readLockStatusInfo:
{
reply = GetLockStatuReply.parseData(commandType, data);
}
break;
} }
return reply; return reply;
} }

16
star_lock/lib/blue/sender_data.dart
View File

@ -29,16 +29,16 @@ class CommandSenderManager {
CommandSendCallBack? callBack}) async { CommandSendCallBack? callBack}) async {
if (callBack != null) { if (callBack != null) {
// if (!BluetoothManager().connected) { // if (!BluetoothManager().connected) {
print('❌ 蓝牙断开了'); print('❌ 蓝牙断开了');
if (callBack != null) { if (callBack != null) {
print('managerSendData ❌ callBack'); print('managerSendData ❌ callBack');
// EasyLoading.dismiss(); // EasyLoading.dismiss();
callBack(ErrorType.notConnected); callBack(ErrorType.notConnected);
}
return;
} }
return;
}
List<int> value = await command.packageData(); List<int> value = command.packageData();
// print("sendData:${value}"); // print("sendData:${value}");
_sendNormalData(value); _sendNormalData(value);
} }

53
star_lock/lib/blue/sender_manage.dart
View File

@ -1,8 +1,10 @@
import 'package:star_lock/blue/io_protocol/io_getLockStatu.dart';
import 'io_protocol/io_addUser.dart'; import 'io_protocol/io_addUser.dart';
import 'io_protocol/io_getPrivateKey.dart'; import 'io_protocol/io_getPrivateKey.dart';
import 'io_protocol/io_getPublicKey.dart'; import 'io_protocol/io_getPublicKey.dart';
import 'io_protocol/io_openDoor.dart'; import 'io_protocol/io_openLock.dart';
import 'sender_data.dart'; import 'sender_data.dart';
class IoSenderManage { class IoSenderManage {
@ -70,17 +72,40 @@ class IoSenderManage {
} }
//todo:开锁 //todo:开锁
// static void senderOpenDoor({CommandSendCallBack? callBack}) { static void senderOpenLock({
// CommandSenderManager().managerSendData( String? keyID,
// command: OpenDoorCommand( String? userID,
// cmdID: 0, int? openMode,
// keyID: "", int? openTime,
// userID: "", List<int>? token,
// openMode: 0, int? needAuthor,
// openTime: 0, List<int>? signKey,
// token: 0, List<int>? privateKey,
// authCodeLen: 0, CommandSendCallBack? callBack}) {
// authCode: "", CommandSenderManager().managerSendData(
// ), callBack:callBack); command: OpenLockCommand(
// } keyID: keyID,
userID: userID,
openMode: openMode,
openTime: openTime,
token: token,
needAuthor: needAuthor,
signKey: signKey,
privateKey: privateKey,
), callBack:callBack);
}
//todo:获取锁状态
static void senderGetLockStatu({
String? lockID,
String? userID,
List<int>? privateKey,
CommandSendCallBack? callBack}) {
CommandSenderManager().managerSendData(
command: GetLockStatuCommand(
lockID: lockID,
userID: userID,
privateKey: privateKey,
), callBack:callBack);
}
} }

232
star_lock/lib/main/lockDetail/lockDetail/lockDetail_logic.dart Normal file
View File

@ -0,0 +1,232 @@
import 'dart:async';
import 'package:flutter_reactive_ble/flutter_reactive_ble.dart';
import 'package:star_lock/blue/io_protocol/io_getLockStatu.dart';
import '../../../blue/blue_manage.dart';
import '../../../blue/io_protocol/io_openLock.dart';
import '../../../blue/io_protocol/io_reply.dart';
import '../../../blue/io_tool/io_manager.dart';
import '../../../blue/io_tool/io_model.dart';
import '../../../blue/io_tool/io_tool.dart';
import '../../../blue/io_tool/manager_event_bus.dart';
import '../../../blue/sender_manage.dart';
import '../../../tools/baseGetXController.dart';
import '../../../tools/storage.dart';
import 'lockDetail_state.dart';
class LockDetailLogic extends BaseGetXController{
final LockDetailState state = LockDetailState();
late StreamSubscription<Reply> _replySubscription;
void _initReplySubscription() {
_replySubscription = EventBusManager().eventBus!.on<Reply>().listen((reply) async {
if(reply is OpenDoorReply) {
_replyOpenLock(reply);
}
if(reply is GetLockStatuReply) {
_replyGetLockStatus(reply);
}
});
}
Future<void> _replyOpenLock(Reply reply) async {
var privateKey = await Storage.getStringList(saveBluePrivateKey);
List<int> getPrivateKeyList = changeStringListToIntList(privateKey!);
var signKey = await Storage.getStringList(saveBlueSignKey);
List<int> signKeyDataList = changeStringListToIntList(signKey!);
var tokenData = reply.data.sublist(2, 6);
var saveStrList = changeIntListToStringList(tokenData);
print("openDoorToken:$tokenData");
Storage.setStringList(saveBlueToken, saveStrList);
// 电量
int power = reply.data[7];
int status = reply.data[6];
print("status:$status");
switch(status){
case 0x00:
//成功
print("开锁数据解析成功");
break;
case 0x06:
//无权限
print("开锁需要鉴权");
IoSenderManage.senderOpenLock(
keyID: "1",
userID: "100001",
openMode: 1,
openTime: 0x11223344,
token: tokenData,
needAuthor: 1,
signKey: signKeyDataList,
privateKey: getPrivateKeyList,
);
break;
case 0x07:
//无权限
print("开锁用户无权限");
break;
case 0x09:
// 权限校验错误
print("开锁权限校验错误");
break;
default:
//失败
print("开锁协议领锁失败");
break;
}
}
Future<void> _replyGetLockStatus(Reply reply) async {
var softVersion = reply.data.sublist(3, 7);
print("softVersion:$softVersion");
var power = reply.data[7];
print("power:$power");
// APP 用户数量
var appUserCount = reply.data.sublist(50, 53);
print("appUserCount:$appUserCount");
// 黑名单用户数量
var blacklistCount = reply.data[53];
print("blacklistCount:$blacklistCount");
// 蓝牙钥匙数量
var bleKeyCount = reply.data[54];
print("bleKeyCount:$bleKeyCount");
// 剩余可添加用户数量
var remainCount = reply.data.sublist(54, 56);
print("remainCount:$remainCount");
// 未上传开锁记录数量
var notUploadCount = reply.data.sublist(56, 58);
print("notUploadCount:$notUploadCount");
// 已设置开门密码数量
var pwdCount = reply.data[58];
print("pwdCount:$pwdCount");
// 已设置开门指纹数量
var fingerprintCount = reply.data[59];
print("fingerprintCount:$fingerprintCount");
// 锁当前时间
var lockTime = reply.data.sublist(60, 64);
print("lockTime:$lockTime");
// 硬件版本信息，为固件升级提供判断依据
var hardVersion = reply.data.sublist(64, 68);
print("hardVersion:$hardVersion");
int status = reply.data[2];
switch(status){
case 0x00:
//成功
print("获取锁状态数据解析成功");
break;
case 0x06:
//无权限
print("获取锁状态需要鉴权");
break;
case 0x07:
//无权限
print("获取锁状态用户无权限");
break;
case 0x09:
// 权限校验错误
print("获取锁状态权限校验错误");
break;
default:
//失败
print("获取锁状态领锁失败");
break;
}
}
Future<void> openDoorAction() async {
var privateKey = await Storage.getStringList(saveBluePrivateKey);
List<int> getPrivateKeyList = changeStringListToIntList(privateKey!);
IoSenderManage.senderGetLockStatu(
lockID:IoManager().getCurrentDeviceLockId,
userID:"100001",
privateKey:getPrivateKeyList,
);
// var privateKey = await Storage.getStringList(saveBluePrivateKey);
// List<int> getPrivateKeyList = changeStringListToIntList(privateKey!);
//
// var signKey = await Storage.getStringList(saveBlueSignKey);
// List<int> signKeyDataList = changeStringListToIntList(signKey!);
//
// var token = await Storage.getStringList(saveBlueToken);
// List<int> getTokenList = changeStringListToIntList(token!);
// print("openDoorTokenPubToken:$getTokenList");
//
// IoSenderManage.senderOpenLock(
// keyID: "1",
// userID: "100001",
// openMode: 1,
// openTime: 0x11223344,
// token: getTokenList,
// needAuthor: 1,
// signKey: signKeyDataList,
// privateKey: getPrivateKeyList,
// );
}
Future<void> connectBlue() async {
await BlueManage().connect("AD01447A-30B5-A780-E778-DED3BDCB613E", "TMH_c3570480da8d");
// var privateKey = await Storage.getStringList(saveBluePrivateKey);
// List<int> getPrivateKeyList = changeStringListToIntList(privateKey!);
// IoSenderManage.senderGetLockStatu(
// lockID:IoManager().getCurrentDeviceLockId,
// userID:"100001",
// privateKey:getPrivateKeyList,
// );
}
@override
void onReady() {
// TODO: implement onReady
super.onReady();
print("onReady()");
// _initSendStreamSubscription();
_initReplySubscription();
}
@override
void onInit() {
// TODO: implement onInit
super.onInit();
print("onInit()");
// 进来第一步开始扫描
connectBlue();
}
@override
void onClose() {
// TODO: implement onClose
// _sendStreamSubscription.cancel();
_replySubscription.cancel();
}
}

13
star_lock/lib/main/lockDetail/lockDetail/lockDetail_page.dart
View File

@ -6,6 +6,7 @@ import '../../../appRouters.dart';
import '../../../app_settings/app_colors.dart'; import '../../../app_settings/app_colors.dart';
import '../../../tools/titleAppBar.dart'; import '../../../tools/titleAppBar.dart';
import '../../../translations/trans_lib.dart'; import '../../../translations/trans_lib.dart';
import 'lockDetail_logic.dart';
class LockDetailPage extends StatefulWidget { class LockDetailPage extends StatefulWidget {
const LockDetailPage({Key? key}) : super(key: key); const LockDetailPage({Key? key}) : super(key: key);
@ -15,6 +16,9 @@ class LockDetailPage extends StatefulWidget {
} }
class _LockDetailPageState extends State<LockDetailPage> { class _LockDetailPageState extends State<LockDetailPage> {
final logic = Get.put(LockDetailLogic());
final state = Get.find<LockDetailLogic>().state;
@override @override
Widget build(BuildContext context) { Widget build(BuildContext context) {
return Scaffold( return Scaffold(
@ -70,8 +74,13 @@ class _LockDetailPageState extends State<LockDetailPage> {
child: Stack( child: Stack(
children: [ children: [
Center( Center(
child: Image.asset('images/main/icon_main_openLockBtn.png', child: GestureDetector(
width: 268.w, height: 268.w)), onTap: (){
logic.openDoorAction();
},
child: Image.asset('images/main/icon_main_openLockBtn.png',
width: 268.w, height: 268.w),
)),
Align( Align(
alignment: const Alignment(0.6, 1), alignment: const Alignment(0.6, 1),
child: Image.asset( child: Image.asset(

5
star_lock/lib/main/lockDetail/lockDetail/lockDetail_state.dart Normal file
View File

@ -0,0 +1,5 @@
class LockDetailState {
}

112
star_lock/lib/mine/addLock/nearbyLock/nearbyLock_logic.dart
View File

@ -27,7 +27,7 @@ class NearbyLockLogic extends BaseGetXController{
BlueManage().connect(lockId, deviceName); BlueManage().connect(lockId, deviceName);
} }
// 监听蓝牙连接的状态 // 监听获取的特征值
late StreamSubscription _streamSubscription; late StreamSubscription _streamSubscription;
void _startListenIO(){ void _startListenIO(){
_streamSubscription = EventBusManager().eventBus!.on<QualifiedCharacteristic>().listen((event) async { _streamSubscription = EventBusManager().eventBus!.on<QualifiedCharacteristic>().listen((event) async {
@ -42,20 +42,20 @@ class NearbyLockLogic extends BaseGetXController{
// } // }
// 组装好数据后监听要发送消息的事件 // 组装好数据后监听要发送消息的事件
late StreamSubscription<EventSendModel> _sendStreamSubscription; // late StreamSubscription<EventSendModel> _sendStreamSubscription;
void _initSendStreamSubscription() { // void _initSendStreamSubscription() {
_sendStreamSubscription = EventBusManager().eventBus!.on<EventSendModel>().listen(( // _sendStreamSubscription = EventBusManager().eventBus!.on<EventSendModel>().listen((
EventSendModel model) { // EventSendModel model) {
if (model.sendChannel == DataChannel.ble) { // if (model.sendChannel == DataChannel.ble) {
// print("fsdfgsdfgsdfgsdfgsdfgsdfg:${BlueManage().qualifiedCharacteristic}"); // // print("fsdfgsdfgsdfgsdfgsdfgsdfg:${BlueManage().qualifiedCharacteristic}");
BlueManage().writeCharacteristicWithResponse(QualifiedCharacteristic( // BlueManage().writeCharacteristicWithResponse(QualifiedCharacteristic(
deviceId:BlueManage().qualifiedCharacteristic!.deviceId, // deviceId:BlueManage().qualifiedCharacteristic!.deviceId,
characteristicId: BlueManage().qualifiedCharacteristic!.characteristicId, // characteristicId: BlueManage().qualifiedCharacteristic!.characteristicId,
serviceId: BlueManage().serviceId), // serviceId: BlueManage().serviceId),
model.data); // model.data);
} // }
}); // });
} // }
late StreamSubscription<Reply> _replySubscription; late StreamSubscription<Reply> _replySubscription;
void _initReplySubscription() { void _initReplySubscription() {
@ -79,34 +79,36 @@ class NearbyLockLogic extends BaseGetXController{
switch(reply.status){ switch(reply.status){
case 0x00: case 0x00:
//成功 //成功
print("获取公钥成功");
// 储存公钥 // 储存公钥
var tokenData = reply.data.sublist(3); var tokenData = reply.data.sublist(3);
var saveStrList = changeIntListToStringList(tokenData); var saveStrList = changeIntListToStringList(tokenData);
Storage.setStringList(saveBluePublicKey, saveStrList); Storage.setStringList(saveBluePublicKey, saveStrList);
IoSenderManage.getPrivateKey(
lockId:IoManager().getCurrentDeviceLockId, IoSenderManage.getPrivateKey(
keyID:"1", lockId:IoManager().getCurrentDeviceLockId,
authUserID:"1", keyID:"1",
nowTime:1, authUserID:"1",
publicKeyData:tokenData, nowTime:1,
needAuthor:1); publicKeyData:tokenData,
needAuthor:1);
break; break;
case 0x07: case 0x07:
//无权限 //无权限
print("获取公钥无权限");
break; break;
case 0x0f: case 0x0f:
//用户已存在 //用户已存在
print("获取公钥用户已存在");
break; break;
default: default:
//失败 //失败
print("获取公钥失败");
break; break;
} }
} }
void _replyGetPrivateKeyKey(Reply reply){ Future<void> _replyGetPrivateKeyKey(Reply reply) async {
switch(reply.status){ switch(reply.status){
case 0x00: case 0x00:
//成功 //成功
@ -123,6 +125,12 @@ class NearbyLockLogic extends BaseGetXController{
var savesignKeyList = changeIntListToStringList(signKey); var savesignKeyList = changeIntListToStringList(signKey);
Storage.setStringList(saveBlueSignKey, savesignKeyList); Storage.setStringList(saveBlueSignKey, savesignKeyList);
var token = await Storage.getStringList(saveBlueToken);
List<int> getTokenList = [0,0,0,0];
if(token != null){
getTokenList = changeStringListToIntList(token);
}
print("privateKey:$privateKey signKey:$signKey"); print("privateKey:$privateKey signKey:$signKey");
IoSenderManage.senderAddUser( IoSenderManage.senderAddUser(
lockID:IoManager().getCurrentDeviceLockId, lockID:IoManager().getCurrentDeviceLockId,
@ -138,7 +146,7 @@ class NearbyLockLogic extends BaseGetXController{
needAuthor:1, needAuthor:1,
publicKey:publicKeyDataList, publicKey:publicKeyDataList,
privateKey:privateKey, privateKey:privateKey,
token: [0,0,0,0] token: getTokenList
); );
break; break;
case 0x07: case 0x07:
@ -147,37 +155,59 @@ class NearbyLockLogic extends BaseGetXController{
break; break;
case 0x0f: case 0x0f:
//用户已存在 //用户已存在
print('获取私钥：用户已存在'); print('获取私钥：用户已存在');
break; break;
default: default:
//失败 //失败
print('获取私钥失败'); print('获取私钥失败');
break; break;
} }
} }
void _replyAddUserKey(Reply reply){ Future<void> _replyAddUserKey(Reply reply) async {
var lockId = reply.data.sublist(2, 42); var lockId = reply.data.sublist(2, 42);
print("lockId:$lockId"); print("lockId:$lockId");
var token = reply.data.sublist(42, 46); var token = reply.data.sublist(42, 46);
List<String> strTokenList = changeIntListToStringList(token); List<String> strTokenList = changeIntListToStringList(token);
Storage.setStringList(saveBlueToken, strTokenList); Storage.setStringList(saveBlueToken, strTokenList);
print("token:$token"); print("token:$token");
int status = reply.data[46]; int status = reply.data[46];
print("status:$status"); print("status:$status");
switch(status){ switch(status){
case 0x00: case 0x00:
//成功 //成功
print("添加用户数据解析成功"); print("添加用户数据解析成功");
break; break;
case 0x06: case 0x06:
//无权限 //无权限
print("需要鉴权"); print("需要鉴权");
var privateKey = await Storage.getStringList(saveBluePrivateKey);
List<int> getPrivateKeyList = changeStringListToIntList(privateKey!);
var publicKey = await Storage.getStringList(saveBluePublicKey);
List<int> publicKeyDataList = changeStringListToIntList(publicKey!);
IoSenderManage.senderAddUser(
lockID:IoManager().getCurrentDeviceLockId,
authUserID:"100001",
keyID:"1",
userID:"100001",
openMode:1,
keyType:1,
startDate:0x11223344,
expireDate:0x11223344,
role:255,
password:"123456",
needAuthor:1,
publicKey:publicKeyDataList,
privateKey:getPrivateKeyList,
token: token
);
break; break;
case 0x07: case 0x07:
//无权限 //无权限
@ -186,7 +216,7 @@ class NearbyLockLogic extends BaseGetXController{
break; break;
case 0x09: case 0x09:
// 权限校验错误 // 权限校验错误
print("权限校验错误"); print("添加用户权限校验错误");
break; break;
default: default:
@ -204,7 +234,7 @@ class NearbyLockLogic extends BaseGetXController{
print("onReady()"); print("onReady()");
_startListenIO(); _startListenIO();
_initSendStreamSubscription(); // _initSendStreamSubscription();
_initReplySubscription(); _initReplySubscription();
} }
@ -226,7 +256,7 @@ class NearbyLockLogic extends BaseGetXController{
// TODO: implement onClose // TODO: implement onClose
super.onClose(); super.onClose();
_streamSubscription.cancel(); _streamSubscription.cancel();
_sendStreamSubscription.cancel(); // _sendStreamSubscription.cancel();
_replySubscription.cancel(); _replySubscription.cancel();
} }

1
star_lock/lib/mine/addLock/nearbyLock/nearbyLock_page.dart
View File

@ -61,6 +61,7 @@ class _NearbyLockPageState extends State<NearbyLockPage> {
// Navigator.pushNamed(context, Routers.lockAddressPage); // Navigator.pushNamed(context, Routers.lockAddressPage);
// logic.getPublicKey(state.devices[index].serviceUuids[0].toString()); // logic.getPublicKey(state.devices[index].serviceUuids[0].toString());
state.seletLockName.value = state.devices[index].name; state.seletLockName.value = state.devices[index].name;
print("connect-lockId:${state.devices[index].id} deviceName:${state.devices[index].name}");
logic.connect(state.devices[index].id, state.devices[index].name); logic.connect(state.devices[index].id, state.devices[index].name);
}); });
}, },