fdp
1 year ago
10 changed files with 578 additions and 424 deletions
@ -1,116 +0,0 @@ |
|||
package com.yunqiinnovation.ble_service |
|||
import io.flutter.embedding.engine.plugins.FlutterPlugin |
|||
import io.flutter.plugin.common.EventChannel |
|||
import io.flutter.plugin.common.MethodCall |
|||
import io.flutter.plugin.common.MethodChannel |
|||
import io.flutter.plugin.common.MethodChannel.MethodCallHandler |
|||
import io.flutter.plugin.common.MethodChannel.Result |
|||
import android.bluetooth.BluetoothDevice |
|||
import android.bluetooth.BluetoothGatt |
|||
import android.bluetooth.BluetoothProfile |
|||
import android.content.Context |
|||
import com.jieli.jl_bt_ota.constant.ErrorCode; |
|||
import com.jieli.jl_bt_ota.constant.StateCode; |
|||
import com.jieli.jl_bt_ota.impl.BluetoothOTAManager; |
|||
import com.jieli.jl_bt_ota.interfaces.BtEventCallback; |
|||
import com.jieli.jl_bt_ota.interfaces.IActionCallback; |
|||
import com.jieli.jl_bt_ota.interfaces.IUpgradeCallback; |
|||
import com.jieli.jl_bt_ota.model.BluetoothOTAConfigure; |
|||
import com.jieli.jl_bt_ota.model.base.BaseError; |
|||
import com.jieli.jl_bt_ota.model.response.TargetInfoResponse; |
|||
import android.util.Log |
|||
import java.util.* |
|||
class CustomUpdateCallback( |
|||
val context: Context, |
|||
val device: BluetoothDevice? |
|||
) : IUpgradeCallback { |
|||
companion object { |
|||
private const val TAG = "JlOtaPlugin" |
|||
private const val CHANNEL_NAME = "com.yunqiinnovation.jl_ota" |
|||
private const val EVENT_CHANNEL_NAME = "com.yunqiinnovation.jl_ota/events" |
|||
|
|||
} |
|||
|
|||
override fun onStartOTA() { |
|||
Log.d(TAG, "onStartOTA开始升级") |
|||
// viewModel.otaStateMLD.value = OTAStart(device) |
|||
} |
|||
|
|||
override fun onNeedReconnect(addr: String?, isNewReconnectWay: Boolean) { |
|||
Log.d(TAG, "onNeedReconnect需要重新链接") |
|||
|
|||
} |
|||
|
|||
override fun onProgress(type: Int, progress: Float) { |
|||
Log.d(TAG, "onProgress正在进展") |
|||
//viewModel.otaStateMLD.value = OTAWorking(device, type, progress) |
|||
} |
|||
|
|||
override fun onStopOTA() { |
|||
Log.d(TAG, "onStartOTA停止升级") |
|||
|
|||
} |
|||
|
|||
override fun onCancelOTA() { |
|||
Log.d(TAG, "onCancelOTA取消升级") |
|||
|
|||
} |
|||
|
|||
override fun onError(error: BaseError?) { |
|||
val errorMessage = error?.message ?: "Unknown error" |
|||
Log.e(TAG, "升级失败: ${error?.message ?: "未知错误"}") |
|||
|
|||
// 如果需要打印完整错误对象信息（假设BaseError有重写toString()） |
|||
Log.d(TAG, "完整错误对象: ${error ?: "null"}") |
|||
} |
|||
} |
|||
|
|||
class OTAManager(context: Context) : BluetoothOTAManager(context) { |
|||
|
|||
|
|||
// 定义回调接口 |
|||
interface DataCallback { |
|||
fun onDataReceived(device: BluetoothDevice?, data: ByteArray?) |
|||
} |
|||
// 保存回调的实例 |
|||
private var dataCallback: DataCallback? = null |
|||
|
|||
// 设置回调的方法 |
|||
fun setDataCallback(callback: DataCallback) { |
|||
this.dataCallback = callback |
|||
} |
|||
override fun getConnectedDevice(): BluetoothDevice? { |
|||
// 这里可以添加空实现的注释说明 |
|||
Log.i(TAG, "ota数据发送getConnectedDevice") |
|||
return null |
|||
} |
|||
|
|||
override fun getConnectedBluetoothGatt(): BluetoothGatt? { |
|||
// 这里可以添加空实现的注释说明 |
|||
Log.i(TAG, "ota数据发送getConnectedBluetoothGatt") |
|||
return null |
|||
} |
|||
|
|||
override fun connectBluetoothDevice(bluetoothDevice: BluetoothDevice?) { |
|||
// 这里可以添加空实现的注释说明 |
|||
Log.i(TAG, "ota数据发送connectBluetoothDevice") |
|||
} |
|||
|
|||
override fun disconnectBluetoothDevice(bluetoothDevice: BluetoothDevice?) { |
|||
// 这里可以添加空实现的注释说明 |
|||
Log.i(TAG, "ota数据发送disconnectBluetoothDevice") |
|||
} |
|||
|
|||
/** 数据发送方法（协议无关） */ |
|||
override fun sendDataToDevice( |
|||
bluetoothDevice: BluetoothDevice?, |
|||
bytes: ByteArray? |
|||
): Boolean { |
|||
Log.i(TAG, "ota数据发送${bluetoothDevice},${bytes?.size}") |
|||
// 触发回调，将数据回传给调用者 |
|||
dataCallback?.onDataReceived(bluetoothDevice, bytes) |
|||
// context.onReceiveDeviceData(device, data); |
|||
return true |
|||
} |
|||
} |
|||
|
|||
@ -1,19 +1,148 @@ |
|||
import 'ota_platform_interface.dart'; |
|||
import 'dart:async'; |
|||
import 'dart:typed_data'; |
|||
import 'package:flutter/services.dart'; |
|||
import 'package:get/get.dart'; |
|||
|
|||
class OtaEvent { |
|||
static final int NOT_STARTED = -1; // 未开始 |
|||
static final int VALIDATION_FILE = 0; // 验证文件 |
|||
static final int ONUPGRADE = 1; // 升级中 |
|||
static final int START_UPGRADING = 2; // 开始升级 |
|||
static final int UPGRADE_SUCCESS = 3; // 升级成功 |
|||
static final int UPGRADE_FAILED = 4; // 升级失败 |
|||
static final int CONNECTION_DISCONNECTION = 5; // 连接断开 |
|||
static final int CONNECTION_SUCCESS = 6; // 连接成功 |
|||
|
|||
/// 事件类型 |
|||
final String event; |
|||
|
|||
/// 输出升级状态 |
|||
final int? type; |
|||
|
|||
/// 输出升级进度 |
|||
final double? progress; |
|||
|
|||
/// 错误码 (仅在发生错误时有效) |
|||
final int? code; |
|||
|
|||
/// 错误信息 (仅在发生错误时有效) |
|||
final String? message; |
|||
|
|||
/// 构造函数 |
|||
OtaEvent({ |
|||
required this.event, |
|||
this.type, |
|||
this.progress, |
|||
this.code, |
|||
this.message, |
|||
}); |
|||
|
|||
/// 从Map构造对象 |
|||
factory OtaEvent.fromMap(Map<dynamic, dynamic> map) { |
|||
return OtaEvent( |
|||
event: map['event'], |
|||
type: map['type'], |
|||
progress: map['progress'], |
|||
code: map['code'], |
|||
message: map['message'], |
|||
); |
|||
} |
|||
} |
|||
|
|||
class Ota { |
|||
Future<String?> getPlatformVersion() { |
|||
return OtaPlatform.instance.getPlatformVersion(); |
|||
// 单例实例 |
|||
static final Ota _instance = Ota._internal(); |
|||
|
|||
// 私有构造函数 |
|||
Ota._internal() { |
|||
// 初始化时设置事件监听 |
|||
_setupEventListener(); |
|||
} |
|||
|
|||
Future<String?> searchDevices() { |
|||
return OtaPlatform.instance.searchDevices(); |
|||
// 公共访问点 |
|||
static Ota get instance => _instance; |
|||
|
|||
static const EventChannel _eventChannel = EventChannel( |
|||
'com.example.ota/events', |
|||
); |
|||
final RxDouble progress = 0.0.obs; |
|||
final RxInt type = OtaEvent.NOT_STARTED.obs; |
|||
final RxBool isUpgrade = false.obs; |
|||
|
|||
/// 事件流 |
|||
Stream<OtaEvent>? _eventStream; |
|||
bool _isEventListenerSet = false; // 防止重复监听 |
|||
|
|||
/// 获取事件流 |
|||
Stream<OtaEvent> get eventStream { |
|||
_eventStream ??= _eventChannel.receiveBroadcastStream().map((event) { |
|||
if (event is Map) { |
|||
return OtaEvent.fromMap(event); |
|||
} |
|||
throw PlatformException(code: 'INVALID_EVENT', message: '无效的事件数据'); |
|||
}); |
|||
return _eventStream!; |
|||
} |
|||
|
|||
/// 释放资源 |
|||
void onClose() { |
|||
onOtaClose(); |
|||
// 停止事件监听 |
|||
_eventStream = null; |
|||
_isEventListenerSet = false; |
|||
|
|||
// 清理 Rx 对象 |
|||
progress.close(); |
|||
type.close(); |
|||
isUpgrade.value = false; |
|||
print("Ota 对象资源已释放"); |
|||
} |
|||
|
|||
/// 内部设置事件监听（只执行一次） |
|||
void _setupEventListener() { |
|||
if (_isEventListenerSet) return; |
|||
|
|||
eventStream.listen((event) { |
|||
if (event.event == 'onProgress' && |
|||
event.type != null && |
|||
event.progress != null) { |
|||
print("flutter 收到数据${event.progress}type=${type.value}"); |
|||
progress.value = event.progress!; |
|||
type.value = event.type!; |
|||
} |
|||
if (event.event == 'onStartOTA') { |
|||
type.value = OtaEvent.START_UPGRADING; |
|||
isUpgrade.value = true; // 开始升级 |
|||
} |
|||
if (event.event == 'onStopOTA') { |
|||
type.value = OtaEvent.UPGRADE_SUCCESS; |
|||
isUpgrade.value = false; |
|||
} |
|||
if (event.event == 'onError' && |
|||
event.code != null && |
|||
event.message != null) { |
|||
print("flutter onError${event.code}type=${event.message}"); |
|||
type.value = OtaEvent.UPGRADE_FAILED; |
|||
isUpgrade.value = false; |
|||
} |
|||
if (event.event == 'NOCONNECTION') { |
|||
type.value = OtaEvent.CONNECTION_DISCONNECTION; |
|||
isUpgrade.value = false; |
|||
} |
|||
if (event.event == 'CONNECTION_SUCCESS') { |
|||
type.value = OtaEvent.CONNECTION_SUCCESS; |
|||
} |
|||
}); |
|||
|
|||
_isEventListenerSet = true; |
|||
} |
|||
|
|||
Future<String?> connectDevice() { |
|||
return OtaPlatform.instance.connectDevice(); |
|||
Future<String?> searchDevices(String? filePath) { |
|||
return OtaPlatform.instance.searchDevices(filePath); |
|||
} |
|||
|
|||
Future<String?> startUpgrade() { |
|||
return OtaPlatform.instance.startUpgrade(); |
|||
Future<String?> onOtaClose() { |
|||
return OtaPlatform.instance.onOtaClose(); |
|||
} |
|||
} |
|||
|
|||
Loading…
Reference in new issue