From 9d2b5d9be3781e1f5b537afc5e5a289837bb4011 Mon Sep 17 00:00:00 2001 From: Daisy <> Date: Tue, 8 Aug 2023 16:30:53 +0800 Subject: [PATCH] =?UTF-8?q?1=EF=BC=8C=E8=A7=A3=E5=86=B3=E5=8F=91=E9=80=81?= =?UTF-8?q?=E5=88=86=E5=8C=85=E6=95=B0=E6=8D=AE=E9=87=8D=E5=A4=8D=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- star_lock/lib/blue/blue_manage.dart | 195 ++++++++++++---------------- 1 file changed, 80 insertions(+), 115 deletions(-) diff --git a/star_lock/lib/blue/blue_manage.dart b/star_lock/lib/blue/blue_manage.dart index 20ae7646..3a7ecf96 100644 --- a/star_lock/lib/blue/blue_manage.dart +++ b/star_lock/lib/blue/blue_manage.dart @@ -1,4 +1,6 @@ +import 'dart:async'; +import 'package:flutter/foundation.dart'; import 'package:flutter/material.dart'; import 'package:flutter_reactive_ble/flutter_reactive_ble.dart'; import 'package:star_lock/blue/sender_manage.dart'; @@ -9,7 +11,7 @@ import 'io_tool/manager_event_bus.dart'; typedef ScanResultCallBack = void Function(List devices); -class BlueManage{ +class BlueManage { FlutterReactiveBle? _flutterReactiveBle; List _scanDevices = []; QualifiedCharacteristic? qualifiedCharacteristic; @@ -21,8 +23,8 @@ class BlueManage{ static BlueManage? _manager; BlueManage._init(); - static BlueManage? shareManager(){ - _manager ??= BlueManage._init(); + static BlueManage? shareManager() { + _manager ??= BlueManage._init(); _manager!._initBlue(); return _manager; } @@ -30,7 +32,7 @@ class BlueManage{ factory BlueManage() => shareManager()!; BlueManage? get manager => shareManager(); - void _initBlue(){ + void _initBlue() { _flutterReactiveBle = FlutterReactiveBle(); } @@ -39,13 +41,17 @@ class BlueManage{ _scanDevices.clear(); _flutterReactiveBle!.scanForDevices(withServices: []).listen((device) { // 判断名字为空的直接剔除 - if(device.name.isEmpty){ + if (device.name.isEmpty) { return; } - if (((device.serviceUuids.isNotEmpty ? device.serviceUuids[0] : "").toString().contains("758824")) && (device.rssi >= -100)) { + if (((device.serviceUuids.isNotEmpty ? device.serviceUuids[0] : "") + .toString() + .contains("758824")) && + (device.rssi >= -100)) { // print("11111111111111111:${device}"); - final knownDeviceIndex = _scanDevices.indexWhere((d) => d.id == device.id); + final knownDeviceIndex = + _scanDevices.indexWhere((d) => d.id == device.id); if (knownDeviceIndex >= 0) { _scanDevices[knownDeviceIndex] = device; @@ -64,18 +70,20 @@ class BlueManage{ /// 连接监听状态 Future connect(String deviceMAC) async { print("connect:$deviceMAC"); - _flutterReactiveBle!.connectToDevice(id: deviceMAC).listen((connectionStateUpdate) { - print('ConnectionState for device $deviceMAC : ${connectionStateUpdate.connectionState}'); + _flutterReactiveBle!.connectToDevice(id: deviceMAC).listen( + (connectionStateUpdate) { + print( + 'ConnectionState for device $deviceMAC : ${connectionStateUpdate.connectionState}'); // EventBusManager().eventBusFir(connectionStateUpdate); - if(connectionStateUpdate.connectionState == DeviceConnectionState.connected){ + if (connectionStateUpdate.connectionState == + DeviceConnectionState.connected) { // getPublicKey(update.deviceId); // 如果状态是连接的开始发现服务 discoverServices(deviceMAC); } - }, onError: (Object e){ - print('Connecting to device $deviceMAC resulted in error $e'); - } - ); + }, onError: (Object e) { + print('Connecting to device $deviceMAC resulted in error $e'); + }); } Future disconnect(String deviceMAC) async { @@ -96,33 +104,44 @@ class BlueManage{ Future> discoverServices(String deviceId) async { try { print('Start discovering services for: $deviceId'); - List result = await _flutterReactiveBle!.discoverServices(deviceId); + List result = + await _flutterReactiveBle!.discoverServices(deviceId); print("mmmmmmmmm$result"); - if(result.isNotEmpty){ + if (result.isNotEmpty) { for (var i = 0; i < result.length; i++) { DiscoveredService discoveredService = result[i]; - print("objectdiscoveredService.serviceId.toString() ${discoveredService.serviceId.toString()}"); - if (discoveredService.serviceId.toString() == "fff0"){ + print( + "objectdiscoveredService.serviceId.toString() ${discoveredService.serviceId.toString()}"); + if (discoveredService.serviceId.toString() == "fff0") { // getDiscoveredService = discoveredService; for (var j = 0; j < discoveredService.characteristics.length; j++) { - DiscoveredCharacteristic discoveredCharacteristic = discoveredService.characteristics[j]; + DiscoveredCharacteristic discoveredCharacteristic = + discoveredService.characteristics[j]; // print("hhhhhhhhhh${result[i].characteristicIds[j].toString()}"); - if (discoveredCharacteristic.characteristicId.toString() == "fff1") { + if (discoveredCharacteristic.characteristicId.toString() == + "fff1") { // 订阅用 getDiscoveredCharacteristic = discoveredCharacteristic; // print("1111111111111111characteristicId:${result[i].characteristicIds[j].toString()} serviceId:${result[i].serviceId} deviceId:$deviceId"); } - if (discoveredCharacteristic.characteristicId.toString() == "fff2") { - - print("1111111111111111characteristicId:${discoveredCharacteristic.characteristicId} serviceId:${serviceId} deviceId:$deviceId"); - qualifiedCharacteristic = QualifiedCharacteristic(characteristicId: discoveredCharacteristic.characteristicId, serviceId:serviceId , deviceId: deviceId); + if (discoveredCharacteristic.characteristicId.toString() == + "fff2") { + print( + "1111111111111111characteristicId:${discoveredCharacteristic.characteristicId} serviceId:${serviceId} deviceId:$deviceId"); + qualifiedCharacteristic = QualifiedCharacteristic( + characteristicId: discoveredCharacteristic.characteristicId, + serviceId: serviceId, + deviceId: deviceId); } } } } } - subScribeToCharacteristic(QualifiedCharacteristic(characteristicId: getDiscoveredCharacteristic!.characteristicId, serviceId: Uuid.parse("fff0"), deviceId: deviceId)); + subScribeToCharacteristic(QualifiedCharacteristic( + characteristicId: getDiscoveredCharacteristic!.characteristicId, + serviceId: Uuid.parse("fff0"), + deviceId: deviceId)); print('Discovering services finished'); EventBusManager().eventBusFir(qualifiedCharacteristic); @@ -135,11 +154,13 @@ class BlueManage{ // 听上报来的数据,参数来自前面扫描到的结果 subScribeToCharacteristic(QualifiedCharacteristic characteristic) { - print('Subscribing to characteristicId: ${characteristic.characteristicId} serviceId:${characteristic.serviceId} deviceId:${characteristic.deviceId}'); - _flutterReactiveBle!.subscribeToCharacteristic(characteristic).listen((data) { + print( + 'Subscribing to characteristicId: ${characteristic.characteristicId} serviceId:${characteristic.serviceId} deviceId:${characteristic.deviceId}'); + _flutterReactiveBle!.subscribeToCharacteristic(characteristic).listen( + (data) { // code to handle incoming data - print("subscribeToCharacteristic: deviceId = ${characteristic.deviceId} characteristicId =${characteristic.characteristicId}---上报来的数据data = $data"); - + print( + "subscribeToCharacteristic: deviceId = ${characteristic.deviceId} characteristicId =${characteristic.characteristicId}---上报来的数据data = $data"); }, onError: (dynamic error) { print("subscribeToCharacteristic error:$error"); }); @@ -147,89 +168,31 @@ class BlueManage{ } // 写入 - Future writeCharacteristicWithResponse(QualifiedCharacteristic characteristic, List value) async { - print('Write with characteristicId：${characteristic.characteristicId} serviceId：${characteristic.serviceId} deviceId：${characteristic.deviceId} value : $value'); + Future writeCharacteristicWithResponse( + QualifiedCharacteristic characteristic, List value) async { + print( + 'Write with characteristicId：${characteristic.characteristicId} serviceId：${characteristic.serviceId} deviceId：${characteristic.deviceId} value : $value'); + try { - // await _flutterReactiveBle!.writeCharacteristicWithResponse(characteristic, value: value).onError((error, stackTrace){ - // print("writeCharacteristicWithResponse:$characteristic $value, error:$error stackTrace:$stackTrace}"); - // }); + List valueList = value; - List oneList = []; - List twoList = []; - List threeList = []; - int ctn = getPackageCount(value, averageLen: _limitLen); - for (int i = 1; i <= ctn; i++){ - List subData = getSubData(index: i, average: _limitLen, data: value); - print("i:$i ctn:$ctn subData:$subData"); - print('Write with characteristicId：${characteristic.characteristicId} serviceId：${characteristic.serviceId} deviceId：${characteristic.deviceId} value : $subData'); + List subData = splitList(valueList, _limitLen); + print('得到的分割数据:$subData'); - switch (i) { - case 1: - { - oneList.addAll(subData); - } - break; - case 2: - { - twoList.addAll(subData); - } - break; - case 3: - { - threeList.addAll(subData); - } - break; - default: - } - - // await Future.delayed(Duration( - // milliseconds: i == ctn ? 0 : _sleepTimes, - // ),(){ - // // i++; - // }); + for (int i = 0; i < subData.length; i++) { + await _flutterReactiveBle! + .writeCharacteristicWithResponse(characteristic, value: subData[i]) + .then((value) async { + await Future.delayed(const Duration(milliseconds: 1)) + .then((value) async { + print('成功了么'); + }); + }); } - - print("oneList:$oneList"); - _flutterReactiveBle!.writeCharacteristicWithResponse(characteristic, value: oneList).onError((error, stackTrace){ - // print("writeCharacteristicWithResponse:$characteristic $subData, error:$error stackTrace:$stackTrace}"); - }); - - await Future.delayed(const Duration(milliseconds: 100,),(){ - print("twoList:$twoList"); - _flutterReactiveBle!.writeCharacteristicWithResponse(characteristic, value: twoList).onError((error, stackTrace){ - // print("writeCharacteristicWithResponse:$characteristic $subData, error:$error stackTrace:$stackTrace}"); - }); - }); - - await Future.delayed(const Duration(milliseconds: 100,),(){ - print("threeList:$threeList"); - _flutterReactiveBle!.writeCharacteristicWithResponse(characteristic, value: threeList).onError((error, stackTrace){ - // print("writeCharacteristicWithResponse:$characteristic $subData, error:$error stackTrace:$stackTrace}"); - }); - }); - - // _flutterReactiveBle!.writeCharacteristicWithResponse(characteristic, value: subData).onError((error, stackTrace){ - // // print("writeCharacteristicWithResponse:$characteristic $subData, error:$error stackTrace:$stackTrace}"); - // }); - - // while(i <= ctn) { - // print("object$i "); - // List subData = getSubData(index: i, average: _limitLen, data: value); - // print('Write with characteristicId：${characteristic.characteristicId} serviceId：${characteristic.serviceId} deviceId：${characteristic.deviceId} value : $subData'); - // await _flutterReactiveBle!.writeCharacteristicWithResponse(characteristic, value: subData).onError((error, stackTrace){ - // // print("writeCharacteristicWithResponse:$characteristic $subData, error:$error stackTrace:$stackTrace}"); - // }); - // await Future.delayed(Duration( - // milliseconds: i == ctn ? 0 : _sleepTimes, - // ),(){ - // i++; - // }); - // } - // i = 1; - // await readCharacteristic(characteristic); - } on Exception catch (e, s) { - print('Error occurred when writing: $e',); + print( + 'Error occurred when writing: $e', + ); // ignore: avoid_print print(s); rethrow; @@ -237,28 +200,30 @@ class BlueManage{ } // 读取 - Future> readCharacteristic(QualifiedCharacteristic characteristic) async { + Future> readCharacteristic( + QualifiedCharacteristic characteristic) async { try { - final result = await _flutterReactiveBle!.readCharacteristic(characteristic); + final result = + await _flutterReactiveBle!.readCharacteristic(characteristic); print("readListresult$result"); return result; } on Exception catch (e, s) { - print('Error occurred when reading ${characteristic.characteristicId} : $e',); + print( + 'Error occurred when reading ${characteristic.characteristicId} : $e', + ); rethrow; } } - Future writeCharacteristicWithoutResponse( QualifiedCharacteristic characteristic, List value) async { try { - await _flutterReactiveBle!.writeCharacteristicWithoutResponse(characteristic, - value: value); + await _flutterReactiveBle! + .writeCharacteristicWithoutResponse(characteristic, value: value); } on Exception catch (e, s) { // ignore: avoid_print print(s); rethrow; } } - -} \ No newline at end of file +}