You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

kcService.js 13KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357
  1. "use strict";
  2. var _typeof = "function" == typeof Symbol && "symbol" == typeof Symbol.iterator ? function (e) {
  3. return typeof e
  4. }
  5. : function (e) {
  6. return e && "function" == typeof Symbol && e.constructor === Symbol && e !== Symbol.prototype ? "symbol" : typeof e
  7. }
  8. , _kcUtils = require("./kcUtils.js")
  9. , _kcUtils2 = _interopRequireDefault(_kcUtils);
  10. function _interopRequireDefault(e) {
  11. return e && e.__esModule ? e : {
  12. default: e
  13. }
  14. }
  15. var timeID, ListenFlag = void 0, DataListenerCallBack = void 0, connectedDeviceId = "", foundDevices = [], TAG_FUNCTION = "function", services = "", androidServices = "0000FEE7-0000-1000-8000-00805F9B34FB", iosServices = "FEE7", notifyServiceId = "", androidNotifyServiceId = "0000FEC8-0000-1000-8000-00805F9B34FB", iosNotifyServiceId = "FEC8", writeServiceId = "", androidWriteServiceId = "0000FEC7-0000-1000-8000-00805F9B34FB", iosWriteServiceId = "FEC7", readServiceId = "", androidReadServiceId = "0000FEC9-0000-1000-8000-00805F9B34FB", iosReadServiceId = "FEC9", device = {}, SetoutTimer = 0,
  16. unavailableServices = true;
  17. function reallyScanConnect(s) {
  18. wx.closeBluetoothAdapter(),
  19. _kcUtils2.default.showLog("/***********Runing :: Do reallyScanConnect() begin *************/"),
  20. foundDevices = [],
  21. wx.openBluetoothAdapter({
  22. success: function (e) {
  23. wx.startBluetoothDevicesDiscovery({
  24. services: [],
  25. success: function (e) {
  26. wx.onBluetoothDeviceFound(function (e) {
  27. for (var i = 0; i < e.devices.length; i++) {
  28. for (var c = !1, t = 0; t < foundDevices.length; t++)
  29. if (e.devices[i].deviceId == foundDevices[t].deviceId) {
  30. c = !0;
  31. break
  32. }
  33. if (_kcUtils2.default.showLog("connectedDeviceName", e.devices[i].name),
  34. 0 == c) {
  35. foundDevices.push(e.devices[i]);
  36. var n = e.devices[i].name || '';
  37. const isValidPrefix = _kcUtils2.default.isValidDevice(n);
  38. if (isValidPrefix) {
  39. connectedDeviceId = e.devices[i].deviceId,
  40. _kcUtils2.default.showLog("connectedDeviceId", e.devices);
  41. var o = {};
  42. o.device_name = n,
  43. o.device_id = connectedDeviceId,
  44. wx.stopBluetoothDevicesDiscovery({
  45. success: function (e) {
  46. _kcUtils2.default.showLog("停止扫描,开始连接"),
  47. reallyConnect(o, function (e) {
  48. (void 0 === s ? "undefined" : _typeof(s)) == TAG_FUNCTION && s(e)
  49. })
  50. },
  51. fail: function (e) {
  52. _kcUtils2.default.showError("stopBluetoothDevicesDiscovery fail", e)
  53. }
  54. });
  55. break
  56. }
  57. }
  58. }
  59. })
  60. },
  61. fail: function (e) {
  62. _kcUtils2.default.showError("startBluetoothDevicesDiscovery fail", e)
  63. }
  64. })
  65. },
  66. fail: function (e) {
  67. _kcUtils2.default.showError("openBluetoothAdapter fail", e)
  68. }
  69. }),
  70. wx.onBLEConnectionStateChange(function (e) {
  71. console.log(`[${new Date().toISOString()}] device ${e.deviceId} state has changed, connected: ${e.connected}`);
  72. 0 == e.connected && (wx.closeBLEConnection({
  73. deviceId: e.deviceId,
  74. success: function (e) {
  75. _kcUtils2.default.showLog("closeBLEConnection:", e)
  76. }
  77. }),
  78. wx.closeBluetoothAdapter({
  79. success: function (e) {
  80. _kcUtils2.default.showLog("closeBluetoothAdapter", e)
  81. }
  82. })),
  83. console.error("device " + e.deviceId + " state has changed, connected: " + e.connected)
  84. })
  85. }
  86. function reallyConnect(device, callback) {
  87. console.log("WeiXin ble SDK 20250804");
  88. var result = {
  89. code: -2,
  90. msg: '连接失败'
  91. };
  92. var deviceName = device.device_name;
  93. console.log("name", deviceName);
  94. // 验证设备名称前缀
  95. const isValidPrefix = _kcUtils2.default.isValidDevice(deviceName);
  96. if (isValidPrefix) {
  97. connectedDeviceId = device.device_id;
  98. wx.createBLEConnection({
  99. deviceId: connectedDeviceId,
  100. success: function (res) {
  101. // 设置MTU为23字节(BLE标准)
  102. // wx.setBLEMTU({
  103. // deviceId: connectedDeviceId,
  104. // mtu: 23,
  105. // success: () => console.log('MTU设置成功')
  106. // });
  107. console.log("已连接,开始使能服务", connectedDeviceId);
  108. _enableService(function (serviceResult) {
  109. console.log("serviceResult:", serviceResult);
  110. if (serviceResult.serviceCode === 0) {
  111. console.log("2.连接成功,并使能成功");
  112. result.code = 0;
  113. result.msg = "连接成功";
  114. } else {
  115. console.log("2.连接成功,但服务使能失败");
  116. }
  117. if (typeof callback === TAG_FUNCTION) callback(result);
  118. });
  119. },
  120. fail: function (err) {
  121. console.error("createBLEConnection fail", err);
  122. if (typeof callback === TAG_FUNCTION) callback(result);
  123. }
  124. });
  125. } else {
  126. result.msg = "设备验证失败";
  127. if (typeof callback === TAG_FUNCTION) callback(result);
  128. }
  129. }
  130. function _setPlatformServicesId() {
  131. const infoa = wx.getSystemInfoSync();
  132. console.log(`%cplatform ${JSON.stringify(infoa.platform, null, 2)}`, "color: green;");
  133. }
  134. function containsServiceInPrefix(serviceId) {
  135. var ret = false, serviceTemp;
  136. // 确保将字符串转换为大写,以避免大小写敏感问题
  137. serviceTemp = serviceId.toUpperCase();
  138. // 获取前4个字符和前8个字符
  139. const prefix4 = serviceTemp.substring(0, 4);
  140. const prefix8 = serviceTemp.substring(0, 8);
  141. // 判断是否包含 "FEE7"
  142. ret = prefix4.includes("FEE7") || prefix8.includes("FEE7");
  143. if (ret) {
  144. services = serviceId;
  145. }
  146. return ret;
  147. }
  148. function containsNotifyInPrefix(service) {
  149. var ret = false, serviceTemp;
  150. // 确保将字符串转换为大写,以避免大小写敏感问题
  151. serviceTemp = service.toUpperCase();
  152. // 获取前4个字符和前8个字符
  153. const prefix4 = serviceTemp.substring(0, 4);
  154. const prefix8 = serviceTemp.substring(0, 8);
  155. // 判断是否包含 "FEC8"
  156. ret = prefix4.includes("FEC8") || prefix8.includes("FEC8");
  157. if (ret) {
  158. notifyServiceId = service;
  159. }
  160. return ret;
  161. }
  162. function containsWriteInPrefix(service) {
  163. var ret = false, serviceTemp;
  164. // 确保将字符串转换为大写,以避免大小写敏感问题
  165. serviceTemp = service.toUpperCase();
  166. // 获取前4个字符和前8个字符
  167. const prefix4 = serviceTemp.substring(0, 4);
  168. const prefix8 = serviceTemp.substring(0, 8);
  169. // 判断是否包含 "FEC7"
  170. ret = prefix4.includes("FEC7") || prefix8.includes("FEC7");
  171. if (ret) {
  172. writeServiceId = service;
  173. }
  174. return ret;
  175. }
  176. function containsReadInPrefix(service) {
  177. var ret = false, serviceTemp;
  178. // 确保将字符串转换为大写,以避免大小写敏感问题
  179. serviceTemp = service.toUpperCase();
  180. // 获取前4个字符和前8个字符
  181. const prefix4 = serviceTemp.substring(0, 4);
  182. const prefix8 = serviceTemp.substring(0, 8);
  183. // 判断是否包含 "FEC9"
  184. ret = prefix4.includes("FEC9") || prefix8.includes("FEC9");
  185. if (ret) {
  186. readServiceId = service;
  187. }
  188. return ret;
  189. }
  190. function _enableService(callback) {
  191. var result = {};
  192. _setPlatformServicesId();
  193. wx.getBLEDeviceServices({
  194. deviceId: connectedDeviceId,
  195. success: function (res) {
  196. for (var i = 0; i < res.services.length; i++) {
  197. console.log(res.services[i]);
  198. var uuid = res.services[i].uuid;
  199. if (containsServiceInPrefix(uuid)) {
  200. wx.getBLEDeviceCharacteristics({
  201. deviceId: connectedDeviceId,
  202. serviceId: uuid,
  203. success: function (charRes) {
  204. var matchedChars = charRes.characteristics.filter(char => containsNotifyInPrefix(char.uuid) || containsWriteInPrefix(char.uuid)).length;
  205. if (matchedChars < 2) {
  206. result.serviceCode = -1;
  207. result.serviceInfo = "getBLEDeviceCharacteristics temp<2!";
  208. if (typeof callback === "function") callback(result);
  209. } else {
  210. wx.notifyBLECharacteristicValueChange({
  211. deviceId: connectedDeviceId,
  212. serviceId: services,
  213. characteristicId: notifyServiceId,
  214. state: true,
  215. success: function (res) {
  216. },
  217. fail: function (res) {
  218. },
  219. complete: function (res) {
  220. console.log("res:", res);
  221. if (res.errno === 0) {
  222. _onBLECharacteristicValueChange();
  223. result.serviceCode = 0;
  224. result.serviceInfo = "enable success!";
  225. } else {
  226. result.serviceCode = -2;
  227. result.serviceInfo = "notifyBLECharacteristicValueChange fail!";
  228. }
  229. if (typeof callback === "function") callback(result);
  230. }
  231. });
  232. }
  233. },
  234. fail: function () {
  235. console.error("getBLEDeviceCharacteristics fail");
  236. result.serviceCode = -3;
  237. result.serviceInfo = "getBLEDeviceCharacteristics fail!";
  238. if (typeof callback === "function") callback(result);
  239. }
  240. });
  241. unavailableServices = false;
  242. break;
  243. }
  244. }
  245. console.log("unavailableServices", unavailableServices);
  246. },
  247. fail: function () {
  248. result.serviceCode = -4;
  249. result.serviceInfo = "getBLEDeviceServices fail!";
  250. if (typeof callback === "function") callback(result);
  251. }
  252. });
  253. }
  254. function reallyDisConnect(callBack) {
  255. console.log("/***********Runing :: Do reallyDisConnect() begin *************/");
  256. var c = {
  257. code: 0,
  258. msg: '已断连'
  259. };
  260. wx.closeBLEConnection({
  261. deviceId: connectedDeviceId,
  262. success: function (e) {
  263. connectedDeviceId = "";
  264. console.log("closeBLEConnection success", e);
  265. },
  266. fail: function (e) {
  267. console.error("closeBLEConnection fail", e);
  268. },
  269. complete: function (e) {
  270. (void 0 === callBack ? "undefined" : _typeof(callBack)) == TAG_FUNCTION && callBack(c)
  271. }
  272. });
  273. }
  274. function _writeBLECharacteristicValue(e, i) {
  275. var c = {};
  276. wx.writeBLECharacteristicValue({
  277. deviceId: connectedDeviceId,
  278. serviceId: services,
  279. characteristicId: writeServiceId,
  280. value: e,
  281. success: function (e) {
  282. _kcUtils2.default.showLog("writeBLECharacteristicValue success", e.errMsg),
  283. c.serviceCode = 0,
  284. c.serviceInfo = e.errMsg,
  285. (void 0 === i ? "undefined" : _typeof(i)) == TAG_FUNCTION && i(c)
  286. }
  287. })
  288. }
  289. function _onBLECharacteristicValueChange() {
  290. wx.onBLECharacteristicValueChange(function (e) {
  291. _kcUtils2.default.showLog("有回复"),
  292. 1 == ListenFlag && (void 0 === DataListenerCallBack ? "undefined" : _typeof(DataListenerCallBack)) == TAG_FUNCTION && DataListenerCallBack(e.value)
  293. });
  294. }
  295. function _SetDataListenerCallBack(e, i) {
  296. 1 == e ? (ListenFlag = !0,
  297. DataListenerCallBack = i) : 0 == e && (ListenFlag = !1)
  298. }
  299. function disconnectDeviceBluetooth(callBack) {
  300. console.log("/***********Runing :: Do disconnectDeviceBluetooth() begin *************/");
  301. console.log("connectedDeviceId是空", connectedDeviceId == "");
  302. var c = {
  303. code: 0,
  304. msg: '已断开'
  305. };
  306. if (connectedDeviceId != "") {
  307. wx.closeBLEConnection({
  308. deviceId: connectedDeviceId,
  309. success: function (e) {
  310. connectedDeviceId = "";
  311. console.log("closeBLEConnection success", e);
  312. wx.closeBluetoothAdapter({
  313. success: function (e) {
  314. console.log("closeBluetoothAdapter success", e);
  315. },
  316. fail: function (e) {
  317. console.error("closeBluetoothAdapter fail", e);
  318. },
  319. complete: function (e) {
  320. (void 0 === callBack ? "undefined" : _typeof(callBack)) == TAG_FUNCTION && callBack(c)
  321. }
  322. });
  323. }
  324. });
  325. } else {
  326. wx.closeBluetoothAdapter({
  327. success: function (e) {
  328. console.log("closeBluetoothAdapter success", e);
  329. },
  330. fail: function (e) {
  331. console.error("closeBluetoothAdapter fail", e);
  332. },
  333. complete: function (e) {
  334. (void 0 === callBack ? "undefined" : _typeof(callBack)) == TAG_FUNCTION && callBack(c)
  335. }
  336. });
  337. }
  338. }
  339. module.exports = {
  340. reallyConnect: reallyConnect,
  341. reallyScanConnect: reallyScanConnect,
  342. reallyDisConnect: reallyDisConnect,
  343. _writeBLECharacteristicValue: _writeBLECharacteristicValue,
  344. _SetDataListenerCallBack: _SetDataListenerCallBack,
  345. disconnectDeviceBluetooth: disconnectDeviceBluetooth,
  346. };