ble_manager.js 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666
  1. // 引入必要的微信小程序 API
  2. // const wx = require('wx');
  3. class bleManager {
  4. constructor() {
  5. var that = this;
  6. that.isAvailable = false;
  7. that.hasPermission = false;
  8. that.scanDevices = [];
  9. that.publicDevice = null;
  10. that.compareList = [];
  11. that.connectWillDevice = null;
  12. that.callBackConnect = null;
  13. that.requestBlueTime = 0;
  14. ///正在执行扫描中
  15. that.doStartScaning = false;
  16. }
  17. ///获取比较的数据
  18. getCompareList() {
  19. return this.compareList;
  20. }
  21. setConnectWillDevice(connectWillDevice) {
  22. this.connectWillDevice = connectWillDevice;
  23. }
  24. getCallBackConnect() {
  25. return this.callBackConnect;
  26. }
  27. setCallBackConnect(callBackConnect) {
  28. this.callBackConnect = callBackConnect;
  29. }
  30. /// 监控蓝牙打开状态
  31. initBluetoothAdapter() {
  32. var that = this;
  33. wx.openBluetoothAdapter({
  34. success: (res) => {
  35. that.isAvailable = true;
  36. },
  37. fail: (err) => {
  38. that.isAvailable = false;
  39. }
  40. });
  41. wx.onBluetoothAdapterStateChange(function (res) {
  42. that.isAvailable = res.available;
  43. })
  44. }
  45. ///监听搜索设备列表
  46. getBluetoothDevices() {
  47. var that = this;
  48. wx.onBluetoothDeviceFound(function (res) {
  49. ///第一种情况
  50. if (res.deviceId) {
  51. if (that.callBackConnect != null) {
  52. if (that.connectWillDevice != null && res.name == that.connectWillDevice.clientType) {
  53. res.mac = res.advertisData ? that.buf2hex(res.advertisData) : '';
  54. if (that.callBackConnect != null) {
  55. that.callBackConnect(res);
  56. }
  57. }
  58. } else {
  59. if (res.name != "") {
  60. if (that.compareList.length > 0) {
  61. var has = false;
  62. for (var i = 0; i < that.compareList.length; i++) {
  63. if (res.deviceId == that.compareList[i].deviceId) {
  64. has = true;
  65. break;
  66. }
  67. }
  68. if (!has) {
  69. that.compareList.push(res);
  70. }
  71. } else {
  72. that.compareList.push(res);
  73. }
  74. }
  75. }
  76. }
  77. ///第二种情况
  78. else if (res.devices) {
  79. if (that.callBackConnect != null) {
  80. for (var i = 0; i < res.devices.length; i++) {
  81. var temp = res.devices[i];
  82. if (that.connectWillDevice != null && temp.name == that.connectWillDevice.clientType) {
  83. temp.mac = temp.advertisData ? that.buf2hex(temp.advertisData) : '';
  84. if (that.callBackConnect != null) {
  85. that.callBackConnect(temp);
  86. }
  87. break;
  88. }
  89. }
  90. } else {
  91. for (var i = 0; i < res.devices.length; i++) {
  92. if (that.compareList.length > 0) {
  93. var has = false;
  94. for (var j = 0; j < that.compareList.length; j++) {
  95. if (res.devices[i].name != "") {
  96. if (res.devices[i].deviceId == that.compareList[j].deviceId) {
  97. has = true;
  98. break;
  99. }
  100. }
  101. }
  102. if (!has) {
  103. that.compareList.push(res.devices[i]);
  104. }
  105. } else {
  106. that.compareList.push(res.devices[i]);
  107. }
  108. }
  109. }
  110. }
  111. ///第三种情况
  112. else if (res[0]) {
  113. if (that.callBackConnect != null) {
  114. if (that.connectWillDevice != null && res[0].name == that.connectWillDevice.clientType) {
  115. res[0].mac = res[0].advertisData ? that.buf2hex(res[0].advertisData) : '';
  116. if (that.callBackConnect != null) {
  117. that.callBackConnect(res[0]);
  118. }
  119. }
  120. } else {
  121. if (res[0].name != "") {
  122. if (that.compareList.length > 0) {
  123. var has = false;
  124. for (var i = 0; i < that.compareList.length; i++) {
  125. if (res[0].deviceId == that.compareList[i].deviceId) {
  126. has = true;
  127. break;
  128. }
  129. }
  130. if (!has) {
  131. that.compareList.push(res[0]);
  132. }
  133. } else {
  134. that.compareList.push(res[0]);
  135. }
  136. }
  137. }
  138. }
  139. });
  140. }
  141. ///获取已连接的设备
  142. getConnectedDevices() {
  143. var that = this;
  144. wx.getBluetoothDevices({
  145. success: (res) => {
  146. if (that.callBackConnect != null) {
  147. for (var i = 0; i < res.devices.length; i++) {
  148. var temp = res.devices[i];
  149. if (that.connectWillDevice != null && temp.name == that.connectWillDevice.clientType) {
  150. temp.mac = temp.advertisData ? that.buf2hex(temp.advertisData) : '';
  151. if (that.callBackConnect != null) {
  152. that.callBackConnect(temp);
  153. }
  154. break;
  155. }
  156. }
  157. } else {
  158. for (var i = 0; i < res.devices.length; i++) {
  159. if (that.compareList.length > 0) {
  160. var has = false;
  161. for (var j = 0; j < that.compareList.length; j++) {
  162. if (res.devices[i].name != "") {
  163. if (res.devices[i].deviceId == that.compareList[j].deviceId) {
  164. has = true;
  165. break;
  166. }
  167. }
  168. }
  169. if (!has) {
  170. that.compareList.push(res.devices[i]);
  171. }
  172. } else {
  173. that.compareList.push(res.devices[i]);
  174. }
  175. }
  176. }
  177. },
  178. fail: (err) => {
  179. console.error('获取蓝牙设备列表失败', err);
  180. }
  181. });
  182. }
  183. ///获取数据
  184. buf2hex(buffer) {
  185. return Array.prototype.map.call(new Uint8Array(buffer), x => ('00' + x.toString(16)).slice(-2)).join('');
  186. }
  187. ///获取毫秒
  188. getCurrentMills() {
  189. var currentDate = new Date();
  190. var currentTimeMillis = currentDate.getTime();
  191. // return Math.floor(currentTimeMillis / 1000);
  192. return currentTimeMillis;
  193. }
  194. // 等待多少秒
  195. delay(ms) {
  196. return new Promise(resolve => setTimeout(resolve, ms));
  197. }
  198. // 开始搜索蓝牙设备
  199. async startScan(connectWillDevice, boolean, callBackConnect) {
  200. var that = this;
  201. const route_util = require('../utils/route_util');
  202. const route_constant = require('../utils/route_constant');
  203. const indexRoot = route_constant.indexRoot;
  204. const connectBleRoot = route_constant.connectBleRoot;
  205. var lastPageRoute = route_util.getLastPageRoute();
  206. if (lastPageRoute != indexRoot && lastPageRoute != connectBleRoot) {
  207. return;
  208. }
  209. ///蓝牙连接 做限制
  210. if (lastPageRoute == indexRoot) {
  211. if (that.doStartScaning == true) {
  212. return;
  213. }
  214. }
  215. that.doStartScaning = true;
  216. var currentMill = that.getCurrentMills();
  217. var waitMills = 0;
  218. var reduce = currentMill - that.requestBlueTime;
  219. const delayMiliis = 5 * 1000;
  220. if (reduce > 0 && reduce < delayMiliis) {
  221. waitMills = delayMiliis - reduce;
  222. }
  223. if (waitMills > 0) {
  224. await that.delay(waitMills);
  225. }
  226. if (callBackConnect == null && lastPageRoute == connectBleRoot) {
  227. that.doStartScaning = false;
  228. return;
  229. }
  230. wx.openBluetoothAdapter({
  231. success: function (res) {
  232. wx.stopBluetoothDevicesDiscovery({
  233. success: (res) => {
  234. that.search(connectWillDevice, boolean, callBackConnect);
  235. },
  236. fail: (err) => {
  237. that.doStartScaning = false;
  238. that.requestBlueTime = that.getCurrentMills();
  239. if (boolean != null) {
  240. boolean(false);
  241. }
  242. }
  243. });
  244. },
  245. fail: function (res) {
  246. // wx.showModal({
  247. // title: '提示',
  248. // content: '请检查手机蓝牙是否打开',
  249. // showCancel: false,
  250. // success: function (res) {}
  251. // });
  252. that.doStartScaning = false;
  253. that.requestBlueTime = that.getCurrentMills();
  254. if (boolean != null) {
  255. boolean(false);
  256. }
  257. }
  258. })
  259. }
  260. search(connectWillDevice, boolean, callBackConnect) {
  261. var that = this;
  262. wx.startBluetoothDevicesDiscovery({
  263. allowDuplicatesKey: true,
  264. success: function (res) {
  265. that.getConnectedDevices();
  266. that.doStartScaning = false;
  267. that.requestBlueTime = that.getCurrentMills();
  268. if (boolean != null) {
  269. boolean(true);
  270. }
  271. that.setConnectWillDevice(connectWillDevice);
  272. that.setCallBackConnect(callBackConnect);
  273. that.compareList = [];
  274. },
  275. fail(err) {
  276. that.doStartScaning = false;
  277. that.requestBlueTime = that.getCurrentMills();
  278. if (boolean != null) {
  279. boolean(false);
  280. }
  281. },
  282. })
  283. }
  284. // 停止搜索
  285. stopSearch() {
  286. var that = this;
  287. that.setCallBackConnect(null);
  288. that.setConnectWillDevice(null);
  289. return new Promise((resolve, reject) => {
  290. wx.stopBluetoothDevicesDiscovery({
  291. success: (res) => {
  292. resolve(res);
  293. },
  294. fail: (err) => {
  295. reject(new Error('停止搜索失败'));
  296. }
  297. });
  298. });
  299. }
  300. closeBle() {
  301. console.log('关闭蓝牙了')
  302. closeBluetoothAdapter();
  303. }
  304. // 断开与指定设备的连接
  305. disconnect() {
  306. var that = this;
  307. let device = that.publicDevice ?? {};
  308. let deviceId = device.deviceId ?? ""
  309. if (deviceId.length === 0) {
  310. return;
  311. }
  312. return new Promise((resolve, reject) => {
  313. wx.closeBLEConnection({
  314. deviceId: that.publicDevice.deviceId ?? "",
  315. success: (res) => {
  316. that.publicDevice = null;
  317. console.log('断开连接成功:', res);
  318. resolve(res);
  319. },
  320. fail: (err) => {
  321. console.error('断开连接失败:', err);
  322. reject(new Error('断开连接失败'));
  323. }
  324. });
  325. });
  326. }
  327. // 发送数据到指定设备
  328. async sendData(data) {
  329. var that = this
  330. return new Promise((resolve, reject) => {
  331. var buffer = null;
  332. // todo 判断是否是buffer
  333. // if (Buffer.isBuffer(data)) {
  334. // buffer = data;
  335. // } else {
  336. buffer = new ArrayBuffer(data.length);
  337. // 下面是赋值,不能删
  338. const dataView = new DataView(buffer);
  339. data.forEach((value, index) => {
  340. dataView.setUint8(index, value); // 将每个16进制数值写入到 buffer 中
  341. });
  342. // }
  343. console.log('开始发送数据:', data, buffer);
  344. wx.writeBLECharacteristicValue({
  345. deviceId: that.publicDevice.deviceId,
  346. serviceId: that.publicDevice.serviceId,
  347. characteristicId: that.publicDevice.characteristicId,
  348. value: buffer,
  349. success: (res) => {
  350. // console.log('数据发送成功:');
  351. resolve(res);
  352. },
  353. fail: (err) => {
  354. console.error('数据发送失败:', err);
  355. reject(new Error('数据发送失败'));
  356. }
  357. });
  358. });
  359. }
  360. ab2hex(buffer) {
  361. var hexArr = Array.prototype.map.call(
  362. new Uint8Array(buffer),
  363. function (bit) {
  364. return ('00' + bit.toString(16)).slice(-2)
  365. }
  366. )
  367. return hexArr.join(':');
  368. }
  369. fiterDevice(res) {
  370. var that = this;
  371. var devices = res.devices.filter(device => {
  372. const name = device.name || '';
  373. const localName = device.localName || '';
  374. let isNot = that.isNotEmpty(name) || that.isNotEmpty(localName);
  375. if (isNot) {
  376. // console.log('是猫王设备名称:', device.advertisData, device.serviceData)
  377. let mac = that.ab2hex(device.advertisData)
  378. // console.log(mac)
  379. device.mac = mac
  380. }
  381. return isNot
  382. });
  383. let newDevices = devices.map((device) => {
  384. let uuid = device.advertisServiceUUIDs[0] ?? ""
  385. return {
  386. deviceId: device.deviceId,
  387. name: device.name,
  388. localName: device.localName,
  389. uuid: uuid,
  390. mac: device.mac,
  391. connectable: device.connectable
  392. }
  393. });
  394. return newDevices
  395. }
  396. isNotEmpty(name) {
  397. let isNot = (name !== '' &&
  398. (name.startsWith("MW_") ||
  399. name.startsWith("MW-") ||
  400. // name.startsWith("猫王") ||
  401. // name.startsWith("妙播") ||
  402. // name.startsWith("AirSmart") ||
  403. name === "le")
  404. )
  405. // if (!isNot && name !== '') {
  406. // console.log('不是猫王设备名称:', name)
  407. // }
  408. return isNot;
  409. }
  410. // 连接到指定设备
  411. async connectToDevice(device) {
  412. var that = this;
  413. return new Promise((resolve, reject) => {
  414. console.log("开始连接蓝牙:", device.deviceId)
  415. wx.createBLEConnection({
  416. deviceId: device.deviceId,
  417. success: (res) => {
  418. that.publicDevice = device
  419. console.log('连接成功:', res);
  420. resolve(true);
  421. },
  422. fail: (err) => {
  423. that.publicDevice = null
  424. console.error('连接失败:', err);
  425. resolve(false);
  426. }
  427. });
  428. });
  429. }
  430. // 发现服务
  431. discoverServices(deviceId) {
  432. var that = this;
  433. console.log('发现服务:', deviceId);
  434. return new Promise((resolve, reject) => {
  435. wx.getBLEDeviceServices({
  436. deviceId: deviceId,
  437. success: (res) => {
  438. // that.publicDevice .services = res.services;
  439. let service_id = "";
  440. for (let i = 0; i < res.services.length; i++) {
  441. if (res.services[i].uuid.toUpperCase().indexOf("AB00") != -1 ||
  442. res.services[i].uuid.toUpperCase().indexOf("FFC0") != -1
  443. // res.services[i].uuid.toUpperCase().indexOf("ae800") != -1
  444. ) {
  445. service_id = res.services[i].uuid;
  446. break;
  447. }
  448. console.log('发现服务1:', service_id);
  449. service_id = res.services[i].uuid;
  450. }
  451. that.publicDevice.serviceId = service_id;
  452. console.log('发现服务2:', service_id);
  453. resolve(service_id);
  454. // resolve(res.services);
  455. },
  456. fail: (err) => {
  457. that.publicDevice.serviceId = null;
  458. console.error('发现服务失败:', err);
  459. reject([]);
  460. }
  461. });
  462. });
  463. }
  464. // 发现特征值 read / write
  465. discoverCharacteristics(deviceId, serviceId) {
  466. var that = this;
  467. console.log('发现特征值:' + deviceId + " , " + serviceId);
  468. // if (deviceId !== that.publicDevice .deviceId) {
  469. // console.log('设备id不匹配')
  470. // return false
  471. // }
  472. return new Promise((resolve, reject) => {
  473. wx.getBLEDeviceCharacteristics({
  474. deviceId: deviceId,
  475. serviceId: serviceId,
  476. success: (res) => {
  477. // that.characteristics[serviceId] = res.characteristics;
  478. console.log('发现特征值2:', res);
  479. // that.publicDevice .characteristics = res.characteristics;
  480. resolve(res.characteristics);
  481. },
  482. fail: (err) => {
  483. that.publicDevice.characteristics = null;
  484. console.error('发现特征值失败:', err);
  485. reject("");
  486. }
  487. });
  488. });
  489. }
  490. // 读取特征值
  491. readCharacteristicValue(characteristicId) {
  492. var that = ths;
  493. console.log('开始读取特征值', characteristicId)
  494. return new Promise((resolve, reject) => {
  495. wx.readBLECharacteristicValue({
  496. deviceId: that.publicDevice.deviceId,
  497. serviceId: that.publicDevice.serviceId,
  498. characteristicId: characteristicId,
  499. success: (res) => {
  500. const name = that.parseBLEValue(res.value); // 解析读取到的值
  501. console.log('读取特征值成功:', name, res);
  502. resolve(res);
  503. },
  504. fail: (err) => {
  505. console.error('读取特征值失败:', err);
  506. reject("");
  507. }
  508. });
  509. });
  510. }
  511. // 解析读取到的设备名称
  512. parseBLEValue(buffer) {
  513. return String.fromCharCode.apply(null, new Uint8Array(buffer));
  514. }
  515. // 监听特征值变化
  516. notifyCharacteristicValueChange(characteristicId, callback) {
  517. var that = this;
  518. console.log('监听特征值变化:', characteristicId, that.publicDevice.deviceId, that.publicDevice.serviceId);
  519. wx.notifyBLECharacteristicValueChange({
  520. deviceId: that.publicDevice.deviceId, //设备mac IOS和安卓系统不一样
  521. serviceId: that.publicDevice.serviceId, //服务通道,这里主要是notify
  522. characteristicId: characteristicId, //notify uuid
  523. state: true,
  524. success: function (res) {
  525. console.log("开启notify 成功")
  526. //TODO onBLECharacteristicValueChange 监听特征值 设备的数据在这里获取到
  527. wx.onBLECharacteristicValueChange(function (characteristic) {
  528. let buffer = characteristic.value
  529. let dataView = new DataView(buffer)
  530. let dataResult = []
  531. for (let i = 0; i < dataView.byteLength; i++) {
  532. // console.log("0x" + dataView.getUint8(i).toString(16))
  533. // dataResult.push("0x" + dataView.getUint8(i).toString(16))
  534. dataResult.push(dataView.getUint8(i))
  535. }
  536. const result = dataResult
  537. console.log("拿到的数据:", result)
  538. if (callback) {
  539. callback(result)
  540. }
  541. })
  542. },
  543. fail: function (res) {
  544. console.log("订阅特征失败:", res)
  545. }
  546. })
  547. }
  548. setWrite(wirte, characteristicId) {
  549. var that = this;
  550. console.log('写入特征值:', characteristicId)
  551. // that.publicDevice .wirte = wirte
  552. that.publicDevice.characteristicId = characteristicId;
  553. }
  554. }
  555. // const ble = new bleManager();
  556. // 导出 bleManager 类
  557. module.exports = bleManager;
  558. // wx.getSetting({
  559. // success(res) {
  560. // if (res.authSetting["scope.userFuzzyLocation"]) {
  561. // // 成功
  562. // // that.getBluetoothStatus();
  563. // console.log("有定位权限")
  564. // resolve(true);
  565. // } else if (res.authSetting["scope.userFuzzyLocation"] === undefined) {
  566. // wx.authorize({
  567. // scope: "scope.userFuzzyLocation",
  568. // success() {
  569. // console.log("再次获取定位权限")
  570. // resolve(that.getSetting());
  571. // }
  572. // });
  573. // } else {
  574. // wx.showModal({
  575. // title: '请打开系统位置获取定位权限',
  576. // success(res) {
  577. // if (res.confirm) {
  578. // console.log('用户点击确定')
  579. // wx.openSetting({
  580. // complete() {
  581. // // that.getSetting();
  582. // // resolve(that.getSetting());
  583. // }
  584. // })
  585. // } else if (res.cancel) {
  586. // console.log('用户点击取消');
  587. // }
  588. // }
  589. // })
  590. // console.log("没有有定位权限")
  591. // reject(false);
  592. // }
  593. // }
  594. // })
  595. // // 获取已连接的蓝牙设备
  596. // getConnectedDevices() {
  597. // var that = this;
  598. // if (!that.isAvailable && !that.hasPermission) {
  599. // return [];
  600. // }
  601. // return new Promise((resolve, reject) => {
  602. // wx.getConnectedBluetoothDevices({
  603. // // services: ["FFC0", "ffc0", "FFC1", "FFC2", "ffc1", "ffc2", "AB00", "ab00", "AB01", "AB02", "FFF1", "fff1", "FFE2", "FFE5",],
  604. // // services: ["ab00", "ffe5", "1111", "FFC0", "FFC1", "FFF1", ],
  605. // // services: [],
  606. // // services: [
  607. // // "0000ab00-0000-1000-8000-00805f9b34fb",
  608. // // "0000ffc0-0000-1000-8000-00805f9b34fb",
  609. // // "0000FFF0-0000-1000-8000-00805F9B34FB",
  610. // // "0000FFF1-0000-1000-8000-00805F9B34FB",
  611. // // "0000FFE5-0000-1000-8000-00805F9B34FB",
  612. // // ],
  613. // success: (res) => {
  614. // console.log('已连接的蓝牙设备==11==:', newDevices);
  615. // let newDevices = that.fiterDevice(res)
  616. // console.log('已连接的蓝牙设备==22==:', newDevices);
  617. // resolve(newDevices);
  618. // },
  619. // fail: (err) => {
  620. // console.error('获取已连接的蓝牙设备失败:', err);
  621. // reject([]);
  622. // }
  623. // });
  624. // });
  625. // }