1
0
forked from dyf/APP

Compare commits

...

4 Commits

Author SHA1 Message Date
793fe7132b 添加全局蓝牙监听 2025-08-18 16:33:06 +08:00
585bd76a0a 添加全局蓝牙监听 2025-08-18 16:32:25 +08:00
96acaa5d94 添加全局蓝牙监听 2025-08-18 16:31:41 +08:00
5e5bde6934 添加全局蓝牙消息监听 2025-08-18 16:30:44 +08:00
8 changed files with 447 additions and 227 deletions

View File

@ -311,6 +311,7 @@
methods: {
getDevice: function() {
console.log("LinkedList=", ble.data.LinkedList);
console.log("formData=", these.formData);
let f = ble.data.LinkedList.find((v) => {
return v.deviceId == these.formData.deviceId;
});

View File

@ -167,13 +167,16 @@
<script>
import gbk from '@/utils/gbk.js'
import BleTool from '@/utils/BleHelper.js'
import BleReceive from '@/utils/BleReceive';
import {
showLoading,
hideLoading,
updateLoading
} from '@/utils/loading.js'
const pagePath = "pages/650/HBY650";
var ble = null;
var these = null;
var recei = null;
export default {
data() {
return {
@ -265,10 +268,11 @@
onUnload() {
console.log("页面卸载,释放资源");
ble.removeReceiveCallback(this);
ble.removeReceiveCallback(pagePath);
},
onLoad: function() {
these = this;
recei = BleReceive.getBleReceive();
ble = BleTool.getBleTool();
ble.addReceiveCallback(these.bleValueNotify);
let eventChannel = this.getOpenerEventChannel();
@ -309,7 +313,7 @@
these.formData.deviceName = device.deviceName;
these.formData.img = device.devicePic;
these.formData.id = device.id;
these.formData.deviceId=f.deviceId;
these.formData.deviceId = f.deviceId;
ble.LinkBlue(f.deviceId, f.writeServiceId, f.wirteCharactId, f.notifyCharactId);
these.setBleFormData();
@ -322,7 +326,7 @@
},
onBackPress(e) {
ble.removeReceiveCallback();
ble.removeReceiveCallback(pagePath);
},
computed: {
RSSIRemark: function() {
@ -372,123 +376,44 @@
return className;
},
bleValueNotify: function(receive) { //订阅消息
console.log("收到订阅消息", receive);
var parseData = () => {
let bytes = receive.bytes;
if (bytes[0] == 0x55) {
try {
let staticLevelByte = bytes[1];
let staticLevelText = '未知';
let modeCurr = "";
switch (staticLevelByte) {
case 0x65:
staticLevelText = '高档';
modeCurr = "hight";
break;
case 0x66:
staticLevelText = '中档';
modeCurr = "center";
break;
case 0x67:
staticLevelText = '低档';
modeCurr = "low";
break;
case 0x68:
staticLevelText = '关闭';
modeCurr = "close";
break;
}
// 解析照明档位
let lightingLevelByte = bytes[2];
let lightingLevelText = lightingLevelByte === 0x6e ? '开启' : '关闭';
// 解析剩余照明时间(第三和第四字节,大端序)
let lightingTime = (bytes[3] << 8) | bytes[4];
let hours = Math.floor(lightingTime / 60);
let remainingMinutes = lightingTime % 60;
let xuhang = '0分';
// 处理不同情况的显示
if (hours === 0) {
xuhang = `${remainingMinutes}`;
} else if (remainingMinutes === 0) {
xuhang = `${hours}小时`;
} else {
xuhang = `${hours}小时${remainingMinutes}`;
}
// 解析剩余电量
let batteryLevelByte = bytes[5];
// 电量百分比范围检查
let batteryLevel = Math.max(0, Math.min(100, batteryLevelByte));
let iswarn = false;
let warn = bytes[6];
if (warn == 0x00) {
warn = '无预警';
} else if (warn == 0x01) {
warn = '弱预警';
} else if (warn == 0x02) {
iswarn = true;
warn = '中预警';
} else if (warn == 0x03) {
iswarn = true;
warn = '强预警';
} else if (warn == 0x04) {
iswarn = true;
warn = '非常强预警';
}
these.formData.battary = batteryLevel;
these.formData.xuhang = xuhang;
these.formData.cMode = lightingLevelByte === 0x6e;
these.formData.modeCurr = modeCurr;
these.formData.warnLevel = warn;
these.formData.iswarn = iswarn;
these.setBleFormData();
if (iswarn) {
these.showPop({
message: "环境存在漏电电源",
iconUrl: "/static/images/6155/DeviceDetail/warnning.png",
borderColor: "#e034344d",
buttonBgColor: "#E03434",
});
}
} catch (error) {
console.error('数据解析错误:', error);
}
bleValueNotify: function(receive, device, path) { //订阅消息
let data = recei.ReceiveData(receive, device, pagePath);
if (data) {
console.log("收到订阅消息", receive);
let keys = Object.keys(data);
for (var i = 0; i < keys.length; i++) {
let key = keys[i];
these.formData[key] = data[key];
}
if (receive.str) {
try {
let str = receive.str;
if (str.indexOf('mac address:') == 0) {
these.formData.macAddress = str.split(':')[1];
console.log("收到mac地址:", )
} else {
console.log("收到无法解析的字符串:", str)
}
} catch (ex) {
console.log("将数据转文本失败", ex);
}
if (these.formData.iswarn) {
these.showPop({
message: "环境存在漏电电源",
iconUrl: "/static/images/6155/DeviceDetail/warnning.png",
borderColor: "#e034344d",
buttonBgColor: "#E03434",
});
}
these.setBleFormData();
}
// 转换为字节数组
const bytes = receive.bytes;
parseData(bytes);
// // 转换为字节数组
// const bytes = receive.bytes;
// parseData(bytes);
},
getDevice: function() {
console.log("LinkedList=",ble.data.LinkedList);
console.log("formData=",these.formData);
console.log("LinkedList=", ble.data.LinkedList);
console.log("formData=", these.formData);
let f = ble.data.LinkedList.find((v) => {
return v.deviceId == these.formData.deviceId;
});

View File

@ -5,6 +5,9 @@
<image src="/static/images/BLEAdd/addBleDevice.png" class="titleIco" mode="aspectFit">
</image>
</view>
<view class="deviceName">
蓝牙名:{{device.name}}
</view>
<view class="deviceName">
设备名:{{device.deviceName}}
</view>
@ -19,21 +22,24 @@
连接
</view>
<global-loading ref="loading" />
<global-loading ref="loading" />
</view>
</template>
<script>
import request from '@/utils/request.js';
import bleTool from '@/utils/BleHelper.js'
import {
showLoading,
hideLoading,
updateLoading
} from '@/utils/loading.js'
import bleTool from '@/utils/BleHelper.js';
import {
showLoading,
hideLoading,
updateLoading
} from '@/utils/loading.js';
const pagePath="pages/common/addBLE/LinkBle";
var these = null;
var eventChannel = null;
var ble=null;
var ble = null;
export default {
data() {
return {
@ -66,57 +72,113 @@
}
}
},
onBackPress() {
console.log("返回时断开蓝牙连接,取消订阅");
ble.disconnectDevice(these.device.deviceId);
ble.removeReceiveCallback(pagePath);
},
onUnload() {
ble.removeReceiveCallback(pagePath);
},
onLoad(option) {
these = this;
ble=bleTool.getBleTool();
ble = bleTool.getBleTool();
ble.addReceiveCallback((receive,f,path) => {
console.log("收到设备消息,", receive);
if (these.device.deviceId == receive.deviceId) {
console.log("11111");
if (receive.bytes[0] == 0xFC || receive.str.indexOf('mac address:') == 0) {
if (f && f.macAddress) {
these.device.macAddress = f.macAddress;
console.log("222222");
these.initDevice();
}
}
}
},pagePath);
eventChannel = this.getOpenerEventChannel();
eventChannel.on('LinkItem', function(data) {
let f=ble.data.LinkedList.find((v)=>{
return v.deviceId=data.deviceId;
let f = ble.data.LinkedList.find((v) => {
return v.deviceId = data.deviceId;
});
if(f){
these.device = f;
console.log("获取到设备",f);
these.initDevice();
}else{
if (f) {
these.device = Object.assign({}, these.device, f);
console.log("获取到设备", f);
} else {
console.log("未获取到设备");
}
})
},
methods: {
initDevice: function() {
showLoading(these, {
text: '正在获取设备信息'
});
request({
url: 'app/device/getDeviceInfoByDeviceMac',
url: '/app/device/getDeviceInfoByDeviceMac',
method: 'GET',
data: {
data: {
deviceMac: these.device.macAddress
}
}).then(res=>{
console.log("获取设备信息",res);
}).catch((ex)=>{
console.log("获取设备出现异常:",ex);
}).then(res => {
console.log("获取设备信息", res);
if (res && res.code == 200) {
let data = res.data;
if (data) {
let keys = Object.keys(data);
ble.data.LinkedList.find((v) => {
if(v.deviceId = these.device.deviceId){
for (var i = 0; i < keys.length; i++) {
let key = keys[i];
v[key] = data[key];
console.log("key="+key);
console.log("value="+data[key]);
these.$set(these.device, key, data[key]);
}
ble.setBleData();
}
});
console.log("device=",these.device);
console.log("LinkedList=",ble.data.LinkedList);
}
}
}).catch((ex) => {
console.log("获取设备出现异常:", ex);
}).finally(() => {
hideLoading(these);
});
},
Link() {
// 调用绑定设备接口
let f=ble.data.LinkedList.find((v)=>{
return v.deviceId=these.device.deviceId;
let f = ble.data.LinkedList.find((v) => {
return v.deviceId = these.device.deviceId;
});
if(!f){
if (!f) {
these.Statu.bound = false;
these.Statu.boundRemark = "蓝牙连接不成功";
these.Statu.boundRemark = "蓝牙连接不成功";
return;
}
if(!f.macAddress){
if (!f.macAddress) {
these.Statu.bound = false;
these.Statu.boundRemark = "获取设备Mac地址异常";
these.Statu.boundRemark = "设备上报Mac地址异常";
return;
}
these.Statu.bound = null;
these.Statu.boundRemark = "";
showLoading(these,{
showLoading(these, {
text: "连接中..."
})
let promise = request({
@ -130,15 +192,17 @@
});
promise.then((res) => {
console.log("1111" + JSON.stringify(res));
if (res.code == 200) {
if (res.code == 200) {
these.Statu.bound = true;
these.Statu.boundRemark = "设备绑定成功!";
uni.$emit("refreshDeviceList");
setTimeout(()=>{
uni.switchTab({
url:"/pages/common/index/index"
});
},500);
setTimeout(() => {
uni.switchTab({
url: "/pages/common/index/index"
});
}, 500);
} else {
these.Statu.bound = false;
these.Statu.boundRemark = res.msg;

View File

@ -94,7 +94,7 @@
hideLoading,
updateLoading
} from '@/utils/loading.js'
const pagePath="pages/common/addBLE/addEquip";
var ble = null;
var these = null;
export default {
@ -136,17 +136,23 @@
},
onHide: function() {
ble.StopSearch();
ble.removeReceiveCallback(pagePath);
},
onBackPress: (e) => {
ble.StopSearch();
ble.removeDeviceFound();
ble.removeReceiveCallback();
ble.removeDeviceFound(pagePath);
ble.removeReceiveCallback(pagePath);
},
onUnload(){
ble.StopSearch();
ble.removeDeviceFound(pagePath);
ble.removeReceiveCallback(pagePath);
},
onLoad() {
these = this;
ble = bleTool.getBleTool();
ble.addDeviceFound((arr) => {
console.log("发现新设备"+JSON.stringify(arr));
arr = arr.devices;
for (var i = 0; i < arr.length; i++) {
@ -164,29 +170,30 @@
} else {
}
}
});
ble.addReceiveCallback((receivData) => {
console.log("收到数据了:", receivData);//数据格式:{bytes:[109,97],str:"",hexs:"FA 01"}
console.log("LinkedList=",ble.data.LinkedList);
let data=uni.getStorageSync(ble.StorageKey);
console.log("data=",data);
});
},pagePath);
},
onShow: function() {
console.log("222222");
this.EquipMents=[];
this.PairEquip=[];
ble.StartSearch().catch((ex) => {
if (ex.code == 10001) {
these.showOpenSetting();
}
});
ble.addReceiveCallback((receivData) => {
console.log("收到数据了:", receivData);//数据格式:{bytes:[109,97],str:"",hexs:"FA 01"}
console.log("LinkedList=",ble.data.LinkedList);
let data=uni.getStorageSync(ble.StorageKey);
console.log("data=",data);
},pagePath);
},
methods: {
@ -207,30 +214,7 @@
}
return src;
},
alert: function(title, content, callback) {
if (!title) {
title = '提示'
}
if (!content) {
content = title;
}
uni.showModal({
title: title,
content: content,
success: function(res) {
if (res.confirm) {
console.log('用户点击确定');
} else if (res.cancel) {
console.log('用户点击取消');
}
if (callback) {
callback(res);
}
}
});
},
showOpenSetting: function() {
this.Status.BottomMenu.show = true;
@ -257,13 +241,15 @@
these.PairEquip.push(item);
}
ble.removeReceiveCallback(pagePath);
uni.navigateTo({
url:"/pages/common/addBLE/LinkBle",
events:{
},
success(res) {
res.eventChannel.emit('LinkItem', item)
res.eventChannel.emit('LinkItem', item);
}
});

View File

@ -1,6 +1,9 @@
import receivTool from "@/utils/BleReceive.js"
var recei = null;
class BleHelper {
constructor() {
this.StorageKey = "linkedDevices";
recei = receivTool.getBleReceive();
this.init();
}
@ -37,7 +40,9 @@ class BleHelper {
onDeviceFound: [], //发现新设备的事件
receivDataCallback: [] //接收到数据的事件
}
this.addReceiveCallback((a,b,c)=>{
recei.ReceiveData(a,b,c);
}, "BleReceiveData");
this.dic = {
errRemarks: [{
key: '10000',
@ -128,8 +133,8 @@ class BleHelper {
}
//设置发现新设备的回调
addDeviceFound(callback,currKey) {
let key =currKey?currKey:this.getCurrentPagePath();
addDeviceFound(callback, currKey) {
let key = currKey ? currKey : this.getCurrentPagePath();
if (!key) {
key = new Date().getTime();
}
@ -151,7 +156,7 @@ class BleHelper {
//移除发现新设备的回调
removeDeviceFound(currKey) {
let key =currKey?currKey: this.getCurrentPagePath();
let key = currKey ? currKey : this.getCurrentPagePath();
if (key) {
console.log("key=" + key);
@ -170,12 +175,13 @@ class BleHelper {
}
//添加接收到数据的回调
addReceiveCallback(callback,currKey) {
let key =currKey?currKey: this.getCurrentPagePath();
addReceiveCallback(callback, currKey) {
let key = currKey ? currKey : this.getCurrentPagePath();
if (!key) {
key = new Date().getTime();
}
if (key) {
console.log("订阅消息回调,key=" + key);
let f = this.cfg.receivDataCallback.findIndex((v) => {
return v.key == key;
});
@ -193,10 +199,10 @@ class BleHelper {
//设置接收到数据的回调
removeReceiveCallback(ev,currKey) {
let key =currKey?currKey: this.getCurrentPagePath();
removeReceiveCallback(currKey) {
let key = currKey ? currKey : this.getCurrentPagePath();
if (key) {
console.log("key=" + key);
console.log("移除消息回调:" + key);
let f = this.cfg.receivDataCallback.findIndex((v) => {
return v.key == key;
});
@ -426,8 +432,10 @@ class BleHelper {
});
uni.onBLECharacteristicValueChange((receive) => {
//订阅消息
let f=this.data.LinkedList.find((v) => {
return v.deviceId == receive.deviceId;
})
let dataView = new DataView(receive.value);
// 转换为字节数组
@ -453,21 +461,23 @@ class BleHelper {
.deviceId) {
v.macAddress = str.replace(
header, "");
console.log("收到mac地址:", str)
// console.log("收到mac地址:", str)
}
});
uni.setStorageSync(this.StorageKey, this.data
.LinkedList);
}
if (bytes[0] == 0xFC) { //6155以0xFC开头代表mac地址
if (arr.length >= 7) {
let mac = arr.slice(1, 7).join(":");
}
if (bytes[0] == 0xFC) { //6155以0xFC开头代表mac地址
// console.log("收到mac地址:", bytes)
if (bytes.length >= 7) {
let mac = hexs.slice(1, 7).join(":")
.toUpperCase();
this.data.LinkedList.find((v) => {
if (v.deviceId == receive
.deviceId) {
v.macAddress = mac;
console.log("收到mac地址:", str)
// console.log("收到mac地址:", str)
}
});
uni.setStorageSync(this.StorageKey, this
@ -478,19 +488,31 @@ class BleHelper {
////console.log("将数据转文本失败", ex);
}
let recData = {
deviceId: receive.deviceId,
serviceId: receive.serviceId,
characteristicId: receive.characteristicId,
bytes: bytes,
str: str,
hexs: hexs
};
console.log("监听到特征值:" + JSON.stringify(recData));
if (this.cfg.receivDataCallback) {
if (this.cfg.receivDataCallback.length > 0) {
let path = this.getCurrentPagePath();
this.cfg.receivDataCallback.forEach((rec) => {
rec.callback(recData);
if (rec.callback) {
}
rec.callback(recData, f, path);
})
}
} else {
console.log("无任何人订阅receivDataCallback,不处理数据");
console.log("无人订阅receivDataCallback,不处理数据");
}
});
@ -986,9 +1008,16 @@ class BleHelper {
}).then((res) => {
////console.log("11111111");
if (res) { //新连接
console.log("开始获取服务", targetServiceId)
return this.getService(deviceId, targetServiceId, writeCharId,
if (fIndex == -1) {
console.log("开始获取服务", targetServiceId)
return this.getService(deviceId, targetServiceId, writeCharId,
notifyCharId); //获取服务
} else {
if (!f.notifyState) {
this.subScribe(deviceId, true);
}
return Promise.resolve(true);
}
} else { //已连接过,直接订阅消息
if (fIndex > -1 && f && !f.notifyState) {
@ -1196,25 +1225,31 @@ class BleHelper {
//将点阵数据转换成RGB565
convertToRGB565(pixels, type) {
if (!type) {
type = 'rgb';
}
const result = new Uint16Array(pixels.length / 4);
let index = 0;
for (let i = 0; i < pixels.length; i += 4) {
let r = pixels[i];
let g = pixels[i + 1];
let b = pixels[i + 2];
let a = pixels[i + 3];
let rgb565 = ((r & 0xF8) << 8) | ((g & 0xFC) << 3) | (b >> 3);
let bgr565 = (b >> 3) | ((g & 0xFC) << 3) | ((r & 0xF8) << 8);
if (type == 'bgr') {
result[index++] = bgr565;
result[index++] = (b >> 3) | ((g & 0xFC) << 3) | ((r & 0xF8) << 8);
} else {
result[index++] = rgb565;
result[index++] = ((r & 0xF8) << 8) | ((g & 0xFC) << 3) | (b >> 3);
}
}
return result;
}
setBleData() {
uni.setStorageSync(this.StorageKey, this.data.LinkedList);
}
}
let instance = null;

View File

@ -1,21 +1,225 @@
class BleReceive {
class BleReceive {
constructor() {
this.StorageKey = "linkedDevices";
}
}
getCurrentPagePath() {
const pages = getCurrentPages();
if (pages.length === 0) {
console.log("pages.length=0");
return "";
}
const currentPage = pages[pages.length - 1];
console.log("currentPage=", currentPage.route);
return currentPage.route;
}
setBleFormData(data,f) {
if(data){
let linkedList=uni.getStorageSync(this.StorageKey);
linkedList.find((v)=>{
if(f.deviceId==v.deviceId){
let keys=Object.keys(data);
keys.forEach((key)=>{
if(!v.formData){
v.formData={};
}
if(!f.formData){
f.formData={};
}
v.formData[key]=data[key];
f.formData[key]=data[key];
});
uni.setStorageSync(this.StorageKey,linkedList);
}
});
}
}
ReceiveData(receive,f,path) {
if(f && f.macAddress && f.id){
if(f.detailPageUrl=='/pages/6155/deviceDetail'){
console.log("该设备是6155");
return this.Receive_6155(receive,f,path);
}
if(f.detailPageUrl=='/pages/650/HBY650'){
console.log("该设备是650");
return this.Receive_650(receive,f,path);
}
}
console.log("已收到该消息,但无法处理",f);
}
Receive_650(receive,f,path) {
console.log("通用程序正在处理650的数据");
var parseData = () => {
let bytes = receive.bytes;
if (bytes[0] == 0x55) {
try {
let staticLevelByte = bytes[1];
let staticLevelText = '未知';
let modeCurr = "";
switch (staticLevelByte) {
case 0x65:
staticLevelText = '高档';
modeCurr = "hight";
break;
case 0x66:
staticLevelText = '中档';
modeCurr = "center";
break;
case 0x67:
staticLevelText = '低档';
modeCurr = "low";
break;
case 0x68:
staticLevelText = '关闭';
modeCurr = "close";
break;
}
// 解析照明档位
let lightingLevelByte = bytes[2];
let lightingLevelText = lightingLevelByte === 0x6e ? '开启' : '关闭';
// 解析剩余照明时间(第三和第四字节,大端序)
let lightingTime = (bytes[3] << 8) | bytes[4];
let hours = Math.floor(lightingTime / 60);
let remainingMinutes = lightingTime % 60;
let xuhang = '0分';
// 处理不同情况的显示
if (hours === 0) {
xuhang = `${remainingMinutes}`;
} else if (remainingMinutes === 0) {
xuhang = `${hours}小时`;
} else {
xuhang = `${hours}小时${remainingMinutes}`;
}
// 解析剩余电量
let batteryLevelByte = bytes[5];
// 电量百分比范围检查
let batteryLevel = Math.max(0, Math.min(100, batteryLevelByte));
let iswarn = false;
let warn = bytes[6];
if (warn == 0x00) {
warn = '无预警';
} else if (warn == 0x01) {
warn = '弱预警';
} else if (warn == 0x02) {
iswarn = true;
warn = '中预警';
} else if (warn == 0x03) {
iswarn = true;
warn = '强预警';
} else if (warn == 0x04) {
iswarn = true;
warn = '非常强预警';
}
let formData={};
formData.battary = batteryLevel;
formData.xuhang = xuhang;
formData.cMode = lightingLevelByte === 0x6e;
formData.modeCurr = modeCurr;
formData.warnLevel = warn;
formData.iswarn = iswarn;
this.setBleFormData(formData,f);
let route=this.getCurrentPagePath();
console.log("f=",f);
console.log("route="+route);
if (iswarn && f.detailPageUrl.indexOf(route)==-1 ) {
uni.showModal({
content:"环境存在漏电电源",
title:"警告",
success(res){
if(res.confirm){
if(f){
uni.navigateTo({
url: f.detailPageUrl,
events: {
ack: function(data) {}
},
success: (res) => {
res.eventChannel.emit('detailData', {
data: f,
deviceType: '',
apiType: 'listA'
});
}
});
}
}
}
})
}else{
console.log("当前全局不处理此消息");
}
return formData;
} catch (error) {
return null;
}
}
if (receive.str) {
try {
let str = receive.str;
if (str.indexOf('mac address:') == 0) {
let formData={};
formData.macAddress = str.split(':')[1];
this.setBleFormData(formData,f);
return formData;
}
return null;
} catch (ex) {
return null;
}
}
}
let data=parseData();
return data;
}
Receive_6155() {
console.log("通用程序正在处理6155的数据");
}
}
let instance = null;
let receiveInstance = null;
export default {
getBleReceive: function(found, receive) {
if (!instance) {
instance = new BleReceive();
}
return instance;
if (!receiveInstance) {
receiveInstance = new BleReceive();
}
return receiveInstance;
}
}

View File

@ -25,8 +25,7 @@ export const hideLoading = (ev) => {
if(!ev){
return;
}
console.log("hide.....")
}
ev.$refs.loading.hide();

View File

@ -5,7 +5,13 @@ const request = (options) => {
console.log("options"+JSON.stringify(options),BASE.BASE_URL)
return new Promise((resolve, reject) => {
// 处理GET请求参数
let url = BASE.BASE_URL + options.url;
let url =options.url;
if(url.indexOf('http://')===0 || url.indexOf('https://')===0){
url=url;
}else{
url=BASE.BASE_URL + url;
}
console.log("url"+url)
if (options.method === 'GET' && options.data) {
// 使用qs序列化参数