feat:BluetoothManager support ota

jason
1 parent 60a29b2c
Showing 5 changed files with 109 additions and 7 deletions
HDFwear/20240126ReadMe.md
HDFwear/OTA/LETransceiver.h
HDFwear/OTA/LETransceiver.m
HDFwear/Tools/BluetoothManager+OTA.swift
HDFwear/Tools/BluetoothManager.swift
@@ -143,3 +143,11 @@ BluetoothManager+Function
  
  
 接受数据类
+
+固件升级
+固件升级的文件在OTA文件之中
+OTAManager处理ota升级的设置与业务流程
+LETransceiver处理底层的数据的读写与相关设置
+OTAUpdateViewController展示页面处理相关交互
+在对外设peripheral的服务进行设置setNotifyValue会进入固件升级模式，在退出固件升级模式后，会重置该值并断开重连回到常规模式
+移除了mtk的底层代码，重做了BluetoothManager的reConnect，在BluetoothManager实例化CBCentralManager时会去尝试一次重连
@@ -17,7 +17,8 @@ NS_ASSUME_NONNULL_BEGIN
 #define KeyIndicateCharacteristicUUID   @"kIndicateCharacteristicUUID"
  
 @protocol LEConnctionDelegate <NSObject>
-- (void)onConnectedPeripheral:(CBPeripheral *) peripheral;
+// 当做完相关ota的连接动作后的回调，此时手表进入固件升级进度状态
+- (void)onPeripheralOtaConnected:(CBPeripheral *) peripheral;
 @end
  
 @interface LETransceiver : NSObject
@@ -133,8 +133,8 @@
         connectedPeripheral = peripheral;
         [connectTimer invalidate];
  
-        if(_connectionDelegate && [_connectionDelegate respondsToSelector:@selector(onConnectedPeripheral:)]) {
-            [_connectionDelegate onConnectedPeripheral:peripheral];
+        if(_connectionDelegate && [_connectionDelegate respondsToSelector:@selector(onPeripheralOtaConnected:)]) {
+            [_connectionDelegate onPeripheralOtaConnected:peripheral];
         }
     }
 }
@@ -6,3 +6,83 @@
 //
  
 import Foundation
+
+extension BluetoothManager {
+    // 开始ota需要做的几个动作
+    // 生成一个新的ota的页面，在该页面内做ota的相关行为，传入一些必要参数，当前的peripheral，otaManager，ota文件path，以及关闭页面的回调
+    // 设置isOTAUpdating，discoverServices扫描当前外设的服务，并在回调中进行设置，该动作触发手表进入固件升级状态
+    func startOtaUpdate() {
+        let a = OTAUpdateViewController(nibName: "OTAUpdateViewController", bundle: nil)
+        a.currentPeripheral = peripheral
+        a.otaManager = otaManager
+        a.closeBlock = {[weak self] in
+            self?.isOTAUpdating = false
+            self?.otaTransceiver.closeOTA()
+            self?.disconnect()
+            self?.reConnect()
+        }
+        let docPath = NSSearchPathForDirectoriesInDomains(.documentDirectory, .userDomainMask, true).first!
+        print("nick_path: \(docPath)")
+        let fullPath = (docPath as NSString).appendingPathComponent("QW230288A_HW_V1.5_0119.bin")
+        print(fullPath)
+        a.path = fullPath
+        getCurrentVC().navigationController?.pushViewController(a, animated: true)
+        
+        isOTAUpdating = true
+        peripheral?.discoverServices(nil)
+    }
+
+}
+
+extension BluetoothManager: LEConnctionDelegate {
+    func onPeripheralOtaConnected(_ peripheral: CBPeripheral) {
+        let nc = NotificationCenter.default
+        nc.post(name: Notification.Name("kMsgPeripheralConnected"), object: self, userInfo: nil)
+
+        let mtu = peripheral.maximumWriteValueLength(for: .withoutResponse)
+        print("mtu view:%d", mtu);
+        otaManager.setMaxMtu(mtu)
+    }
+}
+
+extension BluetoothManager: OTAManagerDelegate {
+    func send(_ data: Data) {
+        otaTransceiver.write(data)
+    }
+
+    func send(_ data: Data, index i: Int32) {
+        otaTransceiver.write(data)
+    }
+
+    func receiveAudioPSN(_ psn: Int, data: Data) {
+        print("nick_receiveAudioPSN")
+        var dic = [String: Any]()
+        dic["psn"] = psn
+        dic["data"] = data
+        NotificationCenter.default.post(name: NSNotification.Name(kMsgAudioPackageRecevied), object: self, userInfo: dic)
+    }
+
+    func receiveSpeed(_ speed: Int) {
+        var dic = [String: Any]()
+        dic["speed"] = speed
+        NotificationCenter.default.post(name: NSNotification.Name(kMsgAudioSpeedRecevied), object: self, userInfo: dic)
+    }
+
+    func receive(_ status: RemoteStatus) {
+        print("receiveRemoteStatus: \(status), \(String(describing: status.versionName)), \(String(describing: status.boardName))")
+        var dic = [String: Any]()
+        dic["status"] = status
+        NotificationCenter.default.post(name: NSNotification.Name(kMsgRemoteStatusRecevied), object: self, userInfo: dic)
+    }
+
+    func onStatus(_ state: OTAStatus) {
+        let dic = ["status": state.rawValue]
+        NotificationCenter.default.post(name: NSNotification.Name(kMsgOTAStatus), object: self, userInfo: dic)
+    }
+
+    func onError(_ errCode: Int) {
+        print("onError: \(errCode)")
+    }
+
+}
+
@@ -148,7 +148,7 @@ class BluetoothManager: NSObject {
  
     //ota
     var isOTAUpdating: Bool = false
-    var otaTransceiver : LETransceiver?
+    var otaTransceiver = LETransceiver()
     var otaManager = OTAManager()
  
     //mergeData
@@ -178,7 +178,8 @@ class BluetoothManager: NSObject {
 //        registerClientProfile()
 //        let options = ["CBCentralManagerOptionShowPowerAlertKey":false]
         centralManger = CBCentralManager(delegate: self, queue: .main)
-        
+        otaTransceiver.connectionDelegate = self
+        otaManager.delegate = self
     }
 //    private func setupManger(_ peripheral: CBPeripheral?) {
 //        if peripheral == nil  {
@@ -259,7 +260,7 @@ class BluetoothManager: NSObject {
         // 这里是根据名字来判断其平台类型
         platform = ._828
         if centralManger != nil {
-            centralManger!.connect(peripheral, options: nil)
+            centralManger!.connect(peripheral, options: [CBConnectPeripheralOptionNotifyOnConnectionKey:true])
         }
 //        registerClientProfile()
 //        manger?.connectPeripheral(peripheral)
@@ -1754,7 +1755,10 @@ extension BluetoothManager: CBCentralManagerDelegate {
     }
  
     func centralManager(_ central: CBCentralManager, didDisconnectPeripheral peripheral: CBPeripheral, error: Error?) {
-        
+        for delegate in delegateList {
+            delegate.didDisconnected()
+        }
+        print("断开连接")
     }
 }
  
@@ -1776,6 +1780,10 @@ extension BluetoothManager: CBPeripheralDelegate {
     }
  
     func peripheral(_ peripheral: CBPeripheral, didDiscoverCharacteristicsFor service: CBService, error: Error?) {
+        if isOTAUpdating {
+            otaTransceiver.peripheral(peripheral, didDiscoverCharacteristicsFor: service, error: error)
+            return
+        }
         print("jason_bluetooth_action_6:得到发现特征回调");
         if service.characteristics == nil {
             return
@@ -1803,6 +1811,11 @@ extension BluetoothManager: CBPeripheralDelegate {
         guard let data = characteristic.value, data.count >= 0 else {
             return
         }
+        if isOTAUpdating {
+            print("didUpdateValueForCharacteristic: %@  %@", characteristic.uuid.uuidString, characteristic.value ?? "")
+            otaManager.receive(data)
+            return
+        }
  
         switch characteristic.uuid.uuidString {
         case BLEConfig.MTKBasReadUUID: