440 lines
14 KiB
Dart
440 lines
14 KiB
Dart
|
|
import 'dart:async';
|
|
import 'dart:convert';
|
|
|
|
import 'package:flutter_reactive_ble/flutter_reactive_ble.dart';
|
|
import 'package:star_lock/blue/io_protocol/io_editUser.dart';
|
|
import 'package:star_lock/blue/io_protocol/io_factoryDataReset.dart';
|
|
import 'package:star_lock/blue/io_protocol/io_getLockStatu.dart';
|
|
import 'package:star_lock/blue/io_type.dart';
|
|
|
|
import '../../../blue/blue_manage.dart';
|
|
import '../../../blue/io_protocol/io_openLock.dart';
|
|
import '../../../blue/io_reply.dart';
|
|
import '../../../blue/io_tool/io_manager.dart';
|
|
import '../../../blue/io_tool/io_tool.dart';
|
|
import '../../../blue/io_tool/manager_event_bus.dart';
|
|
import '../../../blue/sender_manage.dart';
|
|
import '../../../login/login/entity/LoginData.dart';
|
|
import '../../../login/login/entity/LoginEntity.dart';
|
|
import '../../../network/api_repository.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);
|
|
}
|
|
|
|
// 编辑锁用户
|
|
if(reply is EditUserReply){
|
|
_replyEditUserKey(reply);
|
|
}
|
|
|
|
// 恢复出厂设置
|
|
if(reply is FactoryDataResetReply){
|
|
_replyFactoryDataResetKey(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("${reply.commandType}数据解析成功");
|
|
|
|
break;
|
|
case 0x06:
|
|
//无权限
|
|
print("${reply.commandType}需要鉴权");
|
|
String? userId = '';
|
|
final data = await Storage.getString('userLoginData');
|
|
if (data != null && data.isNotEmpty) {
|
|
userId = LoginEntity.fromJson(jsonDecode(data)).data!.userid.toString();
|
|
}
|
|
|
|
IoSenderManage.senderOpenLock(
|
|
keyID: "1",
|
|
userID: await Storage.getUid(),
|
|
openMode: 1,
|
|
openTime: DateTime.now().millisecondsSinceEpoch,
|
|
token: tokenData,
|
|
needAuthor: 1,
|
|
signKey: signKeyDataList,
|
|
privateKey: getPrivateKeyList,
|
|
);
|
|
|
|
break;
|
|
case 0x07:
|
|
//无权限
|
|
print("${reply.commandType}用户无权限");
|
|
|
|
break;
|
|
case 0x09:
|
|
// 权限校验错误
|
|
print("${reply.commandType}校验错误");
|
|
|
|
break;
|
|
default:
|
|
//失败
|
|
print("${reply.commandType}失败");
|
|
|
|
break;
|
|
}
|
|
}
|
|
|
|
// 获取锁状态数据解析
|
|
Future<void> _replyGetLockStatus(Reply reply) async {
|
|
int status = reply.data[2];
|
|
switch(status){
|
|
case 0x00:
|
|
//成功
|
|
print("${reply.commandType}数据解析成功");
|
|
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");
|
|
|
|
break;
|
|
case 0x06:
|
|
//无权限
|
|
print("${reply.commandType}需要鉴权");
|
|
|
|
break;
|
|
case 0x07:
|
|
//无权限
|
|
print("${reply.commandType}用户无权限");
|
|
|
|
break;
|
|
case 0x09:
|
|
// 权限校验错误
|
|
print("${reply.commandType}权限校验错误");
|
|
|
|
break;
|
|
default:
|
|
//失败
|
|
print("${reply.commandType}失败");
|
|
|
|
break;
|
|
}
|
|
}
|
|
|
|
// 编辑用户数据解析
|
|
Future<void> _replyEditUserKey(Reply reply) async {
|
|
var token = reply.data.sublist(2, 6);
|
|
var saveStrList = changeIntListToStringList(token);
|
|
print("_replyEditUserKeyToken:$token");
|
|
Storage.setStringList(saveBlueToken, saveStrList);
|
|
|
|
int status = reply.data[6];
|
|
print("status:$status");
|
|
|
|
switch(status){
|
|
case 0x00:
|
|
//成功
|
|
print("${reply.commandType!.typeValue} 数据解析成功");
|
|
|
|
break;
|
|
case 0x06:
|
|
//无权限
|
|
print("${reply.commandType!.typeValue} 需要鉴权");
|
|
var privateKey = await Storage.getStringList(saveBluePrivateKey);
|
|
List<int> getPrivateKeyList = changeStringListToIntList(privateKey!);
|
|
|
|
var publicKey = await Storage.getStringList(saveBluePublicKey);
|
|
List<int> publicKeyDataList = changeStringListToIntList(publicKey!);
|
|
|
|
IoSenderManage.senderEditUser(
|
|
lockID:BlueManage().connectDeviceName,
|
|
authUserID:await Storage.getUid(),
|
|
keyID:"1",
|
|
userID:await Storage.getUid(),
|
|
openMode:1,
|
|
keyType:1,
|
|
startDate:0x11223344,
|
|
expireDate:0x11223344,
|
|
role:255,
|
|
password:"123456",
|
|
needAuthor:1,
|
|
publicKey:publicKeyDataList,
|
|
privateKey:getPrivateKeyList,
|
|
token: token
|
|
);
|
|
break;
|
|
case 0x07:
|
|
//无权限
|
|
print("${reply.commandType!.typeValue} 用户无权限");
|
|
|
|
break;
|
|
case 0x09:
|
|
// 权限校验错误
|
|
print("${reply.commandType!.typeValue} 权限校验错误");
|
|
|
|
break;
|
|
default:
|
|
//失败
|
|
print("${reply.commandType!.typeValue} 失败");
|
|
|
|
break;
|
|
}
|
|
}
|
|
|
|
// 恢复出厂设置数据解析
|
|
Future<void> _replyFactoryDataResetKey(Reply reply) async {
|
|
var token = reply.data.sublist(2, 6);
|
|
var saveStrList = changeIntListToStringList(token);
|
|
print("_replyFactoryDataResetKeyToken:$token");
|
|
Storage.setStringList(saveBlueToken, saveStrList);
|
|
|
|
int status = reply.data[6];
|
|
print("status:$status");
|
|
|
|
switch(status){
|
|
case 0x00:
|
|
//成功
|
|
print("${reply.commandType!.typeValue} 数据解析成功");
|
|
|
|
break;
|
|
case 0x06:
|
|
//无权限
|
|
print("${reply.commandType!.typeValue} 需要鉴权");
|
|
var privateKey = await Storage.getStringList(saveBluePrivateKey);
|
|
List<int> getPrivateKeyList = changeStringListToIntList(privateKey!);
|
|
|
|
var publicKey = await Storage.getStringList(saveBluePublicKey);
|
|
List<int> publicKeyDataList = changeStringListToIntList(publicKey!);
|
|
|
|
var token = await Storage.getStringList(saveBlueToken);
|
|
List<int> getTokenList = changeStringListToIntList(token!);
|
|
|
|
IoSenderManage.senderFactoryDataReset(
|
|
lockID:BlueManage().connectDeviceName,
|
|
userID:await Storage.getUid(),
|
|
keyID:"1",
|
|
needAuthor:1,
|
|
publicKey:publicKeyDataList,
|
|
privateKey:getPrivateKeyList,
|
|
token: getTokenList
|
|
);
|
|
break;
|
|
case 0x07:
|
|
//无权限
|
|
print("${reply.commandType!.typeValue} 用户无权限");
|
|
|
|
break;
|
|
case 0x09:
|
|
// 权限校验错误
|
|
print("${reply.commandType!.typeValue} 权限校验错误");
|
|
|
|
break;
|
|
default:
|
|
//失败
|
|
print("${reply.commandType!.typeValue} 失败");
|
|
|
|
break;
|
|
}
|
|
}
|
|
|
|
// 点击开门事件
|
|
Future<void> openDoorAction() async {
|
|
BlueManage().judgeReconnect(state.keyInfos.value.bluetooth!.bluetoothDeviceId!, state.keyInfos.value.bluetooth!.bluetoothDeviceName!, (DeviceConnectionState state) async {
|
|
if (state == DeviceConnectionState.connected){
|
|
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");
|
|
|
|
print("millisecondsSinceEpoch/1000:${DateTime.now().millisecondsSinceEpoch~/1000}");
|
|
IoSenderManage.senderOpenLock(
|
|
keyID: "1",
|
|
userID: await Storage.getUid(),
|
|
openMode: 1,
|
|
openTime: DateTime.now().millisecondsSinceEpoch~/1000,
|
|
token: getTokenList,
|
|
needAuthor: 1,
|
|
signKey: signKeyDataList,
|
|
privateKey: getPrivateKeyList,
|
|
);
|
|
}
|
|
});
|
|
}
|
|
|
|
// 编辑用户事件
|
|
Future<void> editLockUserAction() async {
|
|
BlueManage().judgeReconnect(BlueManage().connectDeviceMacAddress, BlueManage().connectDeviceName, (DeviceConnectionState state) async {
|
|
if (state == DeviceConnectionState.connected){
|
|
var publicKey = await Storage.getStringList(saveBluePublicKey);
|
|
List<int> publicKeyDataList = changeStringListToIntList(publicKey!);
|
|
|
|
var privateKey = await Storage.getStringList(saveBluePrivateKey);
|
|
List<int> getPrivateKeyList = changeStringListToIntList(privateKey!);
|
|
|
|
var token = await Storage.getStringList(saveBlueToken);
|
|
List<int> getTokenList = changeStringListToIntList(token!);
|
|
print("openDoorTokenPubToken:$getTokenList");
|
|
|
|
print("publicKey:$publicKey publicKeyDataList:$publicKeyDataList privateKey:$privateKey getPrivateKeyList:$getPrivateKeyList token:$token getTokenList:$getTokenList");
|
|
IoSenderManage.senderEditUser(
|
|
lockID:BlueManage().connectDeviceName,
|
|
authUserID:await Storage.getUid(),
|
|
keyID:"1",
|
|
userID:await Storage.getUid(),
|
|
openMode:1,
|
|
keyType:1,
|
|
startDate:0x11223344,
|
|
expireDate:0x11223344,
|
|
role:255,
|
|
password:"123456",
|
|
needAuthor:1,
|
|
publicKey:publicKeyDataList,
|
|
privateKey:getPrivateKeyList,
|
|
token: getTokenList
|
|
);
|
|
}
|
|
});
|
|
}
|
|
|
|
// 恢复出厂设置
|
|
Future<void> factoryDataResetAction() async {
|
|
BlueManage().judgeReconnect(BlueManage().connectDeviceMacAddress, BlueManage().connectDeviceName, (DeviceConnectionState state) async {
|
|
if (state == DeviceConnectionState.connected){
|
|
var privateKey = await Storage.getStringList(saveBluePrivateKey);
|
|
List<int> getPrivateKeyList = changeStringListToIntList(privateKey!);
|
|
|
|
var publicKey = await Storage.getStringList(saveBluePublicKey);
|
|
List<int> publicKeyDataList = changeStringListToIntList(publicKey!);
|
|
|
|
var token = await Storage.getStringList(saveBlueToken);
|
|
List<int> getTokenList = changeStringListToIntList(token!);
|
|
|
|
IoSenderManage.senderFactoryDataReset(
|
|
lockID:BlueManage().connectDeviceName,
|
|
userID:await Storage.getUid(),
|
|
keyID:"1",
|
|
needAuthor:1,
|
|
publicKey:publicKeyDataList,
|
|
privateKey:getPrivateKeyList,
|
|
token: getTokenList
|
|
);
|
|
}
|
|
});
|
|
}
|
|
|
|
// 备用逻辑，进入管理钥匙界面获取锁状态
|
|
Future<void> connectBlue() async {
|
|
// 进来之后首先连接
|
|
BlueManage().connect(state.keyInfos.value.bluetooth!.bluetoothDeviceId!, state.keyInfos.value.bluetooth!.bluetoothDeviceName!, connectStateCallBack: (DeviceConnectionState state) async {
|
|
if (state == DeviceConnectionState.connected){
|
|
var privateKey = await Storage.getStringList(saveBluePrivateKey);
|
|
List<int> getPrivateKeyList = changeStringListToIntList(privateKey!);
|
|
IoSenderManage.senderGetLockStatu(
|
|
lockID:BlueManage().connectDeviceName,
|
|
userID:await Storage.getUid(),
|
|
privateKey:getPrivateKeyList,
|
|
);
|
|
}
|
|
}, isShowLoading: false);
|
|
}
|
|
|
|
@override
|
|
void onReady() {
|
|
// TODO: implement onReady
|
|
super.onReady();
|
|
print("onReady()");
|
|
_initReplySubscription();
|
|
|
|
// BlueManage().startScan((v){
|
|
//
|
|
// });
|
|
}
|
|
|
|
@override
|
|
void onInit() {
|
|
// TODO: implement onInit
|
|
super.onInit();
|
|
print("lockDetail_onInit()");
|
|
|
|
// 进来获取锁状态
|
|
// connectBlue();
|
|
}
|
|
|
|
@override
|
|
void onClose() {
|
|
// TODO: implement onClose
|
|
_replySubscription.cancel();
|
|
}
|
|
} |