100J增加蓝牙封装,在api层直接优先蓝牙拦截逻辑-待验证

api/100J/HBY100-J.js

@@ -1,4 +1,137 @@
 import request from '@/utils/request'
+
+// ================== 蓝牙协议封装类 ==================
+class HBY100JProtocol {
+    constructor() {
+        this.deviceId = ''; // 4G 接口所需的 deviceId
+        this.isBleConnected = false;
+        this.bleDeviceId = ''; // 小程序/APP中连接蓝牙的 deviceId
+        
+        // 蓝牙服务与特征值 UUID
+        this.SERVICE_UUID = '0000AE30-0000-1000-8000-00805F9B34FB'; // 0xAE30
+        this.WRITE_UUID = '0000AE03-0000-1000-8000-00805F9B34FB';   // 0xAE03
+        this.NOTIFY_UUID = '0000AE02-0000-1000-8000-00805F9B34FB';  // 0xAE02
+        
+        this.onNotifyCallback = null;
+    }
+
+    setBleConnectionStatus(status, bleDeviceId = '') {
+        this.isBleConnected = status;
+        if (bleDeviceId) {
+            this.bleDeviceId = bleDeviceId;
+        }
+    }
+
+    onNotify(callback) {
+        this.onNotifyCallback = callback;
+    }
+
+    parseBleData(buffer) {
+        const view = new Uint8Array(buffer);
+        if (view.length < 3) return null;
+        
+        const header = view[0];
+        const tail = view[view.length - 1];
+        if (header !== 0xFB || tail !== 0xFF) return null; // 校验头尾
+        
+        const funcCode = view[1];
+        const data = view.slice(2, view.length - 1);
+        
+        let result = { funcCode, rawData: data };
+        
+        switch (funcCode) {
+            case 0x01: result.resetType = data[0]; break;
+            case 0x02: break;
+            case 0x03: break;
+            case 0x04: result.batteryPercentage = data[16]; break;
+            case 0x06: result.voiceBroadcast = data[0]; break;
+            case 0x09: result.volume = data[0]; break;
+            case 0x0A: 
+                result.strobeEnable = data[0];
+                result.strobeMode = data[1];
+                break;
+            case 0x0B: result.strobeFrequency = data[0]; break;
+            case 0x0C: 
+                result.alarmEnable = data[0];
+                result.alarmMode = data[1];
+                break;
+            case 0x0D: 
+                result.redBrightness = data[0];
+                result.blueBrightness = data[1];
+                result.yellowBrightness = data[2];
+                break;
+            case 0x0E: 
+                result.voiceBroadcast = data[0];
+                result.alarmEnable = data[1];
+                result.alarmMode = data[2];
+                result.strobeEnable = data[3];
+                result.strobeMode = data[4];
+                result.strobeFrequency = data[5];
+                result.volume = data[6];
+                result.redBrightness = data[7];
+                result.blueBrightness = data[8];
+                result.yellowBrightness = data[9];
+                break;
+        }
+        
+        if (this.onNotifyCallback) {
+            this.onNotifyCallback(result);
+        }
+        return result;
+    }
+
+    sendBleData(funcCode, dataBytes = []) {
+        return new Promise((resolve, reject) => {
+            if (!this.isBleConnected || !this.bleDeviceId) {
+                return reject(new Error('蓝牙未连接'));
+            }
+            
+            const buffer = new ArrayBuffer(dataBytes.length + 3);
+            const view = new Uint8Array(buffer);
+            view[0] = 0xFA; // 数据头
+            view[1] = funcCode; // 功能码
+            for (let i = 0; i < dataBytes.length; i++) {
+                view[2 + i] = dataBytes[i];
+            }
+            view[view.length - 1] = 0xFF; // 结尾
+            
+            // 使用项目中统一的 BleHelper 发送数据
+            import('@/utils/BleHelper.js').then(module => {
+                const bleTool = module.default.getBleTool();
+                bleTool.sendData(this.bleDeviceId, buffer, this.SERVICE_UUID, this.WRITE_UUID)
+                    .then(res => resolve(res))
+                    .catch(err => reject(err));
+            });
+        });
+    }
+
+    // 纯蓝牙指令发送方法
+    deviceReset(type = 0) { return this.sendBleData(0x01, [type]); }
+    setVoiceBroadcast(enable) { return this.sendBleData(0x06, [enable]); }
+    setVolume(volume) { return this.sendBleData(0x09, [volume]); }
+    setStrobeMode(enable, mode) { return this.sendBleData(0x0A, [enable, mode]); }
+    setStrobeFrequency(frequency) { return this.sendBleData(0x0B, [frequency]); }
+    setForceAlarm(enable, mode) { return this.sendBleData(0x0C, [enable, mode]); }
+    setLightBrightness(red, blue = 0, yellow = 0) { return this.sendBleData(0x0D, [red, blue, yellow]); }
+    getCurrentWorkMode() { return this.sendBleData(0x0E, []); }
+}
+
+// ================== 全局单例与状态管理 ==================
+const protocolInstance = new HBY100JProtocol();
+
+// 暴露给页面：更新蓝牙连接状态
+export function updateBleStatus(isConnected, bleDeviceId, deviceId) {
+    protocolInstance.setBleConnectionStatus(isConnected, bleDeviceId);
+    protocolInstance.deviceId = deviceId;
+}
+
+// 暴露给页面：解析蓝牙接收到的数据
+export function parseBleData(buffer) {
+    return protocolInstance.parseBleData(buffer);
+}
+
+// ================== API 接口 (拦截层) ==================
+
 // 获取语音管理列表
 export function deviceVoliceList(params) {
   return request({
@@ -39,8 +172,14 @@ export function deviceDetail(id) {
     method: 'get',
   })
 }
+
 // 爆闪模式
 export function deviceStrobeMode(data) {
+  if (protocolInstance.isBleConnected) {
+      return protocolInstance.setStrobeMode(data.enable, data.mode).then(res => {
+          return { code: 200, msg: '操作成功(蓝牙)' };
+      });
+  }
   return request({
     url: `/app/hby100j/device/strobeMode`,
     method: 'post',
@@ -50,22 +189,39 @@ export function deviceStrobeMode(data) {
 
 // 强制报警
 export function deviceForceAlarmActivation(data) {
+  if (protocolInstance.isBleConnected) {
+      return protocolInstance.setForceAlarm(data.voiceStrobeAlarm, data.mode).then(res => {
+          return { code: 200, msg: '操作成功(蓝牙)' };
+      });
+  }
   return request({
     url: `/app/hby100j/device/forceAlarmActivation`,
     method: 'post',
 	data:data
   })
 }
+
 // 爆闪频率
 export function deviceStrobeFrequency(data) {
+  if (protocolInstance.isBleConnected) {
+      return protocolInstance.setStrobeFrequency(data.frequency).then(res => {
+          return { code: 200, msg: '操作成功(蓝牙)' };
+      });
+  }
   return request({
     url: `/app/hby100j/device/strobeFrequency`,
     method: 'post',
 	data:data
   })
 }
+
 // 灯光调节亮度
 export function deviceLightAdjustment(data) {
+  if (protocolInstance.isBleConnected) {
+      return protocolInstance.setLightBrightness(data.brightness, data.brightness, data.brightness).then(res => {
+          return { code: 200, msg: '操作成功(蓝牙)' };
+      });
+  }
   return request({
     url: `/app/hby100j/device/lightAdjustment`,
     method: 'post',
@@ -75,14 +231,25 @@ export function deviceLightAdjustment(data) {
 
 // 调节音量
 export function deviceUpdateVolume(data) {
+  if (protocolInstance.isBleConnected) {
+      return protocolInstance.setVolume(data.volume).then(res => {
+          return { code: 200, msg: '操作成功(蓝牙)' };
+      });
+  }
   return request({
     url: `/app/hby100j/device/updateVolume`,
     method: 'post',
 	data:data
   })
 }
+
 // 语音播放
 export function deviceVoiceBroadcast(data) {
+  if (protocolInstance.isBleConnected) {
+      return protocolInstance.setVoiceBroadcast(data.voiceBroadcast).then(res => {
+          return { code: 200, msg: '操作成功(蓝牙)' };
+      });
+  }
   return request({
     url: `/app/hby100j/device/voiceBroadcast`,
     method: 'post',

pages/100J/HBY100-J.vue

@@ -229,8 +229,12 @@
 		deviceStrobeFrequency,
 		deviceLightAdjustment,
 		deviceUpdateVolume,
-		deviceVoiceBroadcast
+		deviceVoiceBroadcast,
+		updateBleStatus,
+		parseBleData
 	} from '@/api/100J/HBY100-J.js'
+	import BleHelper from '@/utils/BleHelper.js';
+	var bleTool = BleHelper.getBleTool();
 	var these = null;
 	import Common from '@/utils/Common.js'
 	const pagePath = "/pages/100/HBY100";
@@ -592,10 +596,36 @@
 			});
 			this.createThrottledFunctions();
 			
+			// 注册蓝牙相关事件
+			bleTool.addReceiveCallback(this.bleValueNotify, "HBY100J");
+			bleTool.addDisposeCallback(this.bleStateBreak, "HBY100J");
+			bleTool.addRecoveryCallback(this.bleStateRecovry, "HBY100J");
+			bleTool.addStateBreakCallback(this.bleStateBreak, "HBY100J");
+			bleTool.addStateRecoveryCallback(this.bleStateRecovry, "HBY100J");
+			
+			// 尝试连接蓝牙
+			if (data.data.deviceMac) {
+				// 假设 deviceMac 是蓝牙的 deviceId
+				bleTool.LinkBlue(data.data.deviceMac).then(() => {
+					console.log("100J 蓝牙连接成功");
+					this.bleStateRecovry({deviceId: data.data.deviceMac});
+				}).catch(err => {
+					console.log("100J 蓝牙连接失败，将使用4G", err);
+				});
+			}
+
 		},
 		onHide: function() {
 			this.Status.pageHide = true;
 		},
+		onUnload() {
+			// 移除蓝牙事件监听
+			bleTool.removeReceiveCallback("HBY100J");
+			bleTool.removeDisposeCallback("HBY100J");
+			bleTool.removeRecoveryCallback("HBY100J");
+			bleTool.removeStateBreakCallback("HBY100J");
+			bleTool.removeStateRecoveryCallback("HBY100J");
+		},
 		onShow() {
 			this.Status.pageHide = false;
 		},
@@ -949,13 +979,26 @@
 
 			deviceRecovry(res) {},
 			deviceDispose(res) {},
-			bleStateBreak() {},
+			bleStateBreak() {
-			bleStateRecovry() {},
+				updateBleStatus(false, '', this.deviceInfo.deviceId);
+			},
+			bleStateRecovry(res) {
+				let bleDeviceId = res ? res.deviceId : '';
+				updateBleStatus(true, bleDeviceId, this.deviceInfo.deviceId);
+			},
 			previewImg(img) {},
 			bleValueNotify: function(receive, device, path, recArr) { //订阅消息
-				if (receive.deviceId !== this.formData.deviceId) {
+				// 注意：这里 receive.deviceId 是蓝牙的 MAC 地址，而 this.formData.deviceId 是 4G 的 ID
-					return;
+				// 所以这里需要修改判断逻辑，或者不判断直接解析
+				
+				// 尝试解析蓝牙上报的数据
+				if (receive.bytes) {
+					const parsedData = parseBleData(receive.bytes);
+					if (parsedData && parsedData.batteryPercentage !== undefined) {
+						this.deviceInfo.batteryPercentage = parsedData.batteryPercentage;
 					}
+				}
+
 				if (this.deviceInfo.batteryPercentage <= 20) {
 					this.showMsg("设备电量低");
 				}