连接蓝牙

连接到蓝牙

pages/index/index.js

@@ -1,8 +1,11 @@
 // index.js
 // 获取应用实例
 const getBle =  require("../../utils/ble");
+const handle = require("../../utils/handle");
+const sleep = require("../../utils/sleep");
 const app = getApp();
 const ble = getBle();
+
 const connectStateMap = {
   0: {text:'未连接',color:"red"},
   1:  {text:'扫描中',color:"greenYellow"},
@@ -15,6 +18,57 @@ const bleStateEnum = {
   connecting: 2,
   connected: 3,
 }
+
+const bleServerMap = {
+  control: {
+    uuid:'8000CC00-CC00-FFFF-FFFF-FFFFFFFFFFFF',
+    text: '摄像控制服务',
+    listen: {
+      controlTip: '0000CC01',
+      controlType: '0000CC02',
+    },
+    code:{
+
+    }
+  },
+  location : {
+    uuid:'8000DD00-DD00-FFFF-FFFF-FFFFFFFFFFFF',
+    text: '相机定位服务'
+  },
+  remote : {
+    uuid:'8000FF00-FF00-FFFF-FFFF-FFFFFFFFFFFF',
+    text: '摄像机远程控制服务',
+    code:{
+      hold:{
+        firstUuid: '0000FF01',
+        command: {
+          cmd1:'0106',//SHUTTER_RELEASED
+          cmd2:'0107',//PRESS_TO_FOCUS
+          cmd3:'0108',//HOLD_FOCUS
+          cmd4:'0109',//TAKE_PICTURE
+        }
+      }
+    }
+  },
+  pariring : {
+    uuid:'8000EE00-EE00-FFFF-FFFF-FFFFFFFFFFFF',
+    text: '相机配对服务',
+    code: {
+      pariring: {
+        firstUuid: '0000EE01',
+        command: {
+          // 配对
+          connect: '06 08 01 00 00 00',
+          // 取消配对
+          disConnect: '06 08 02 00 00 00',
+          // 关机
+          poweroff:'03 08 13'
+        }
+      }
+    }
+  },
+
+}
 Page({
   data: {
     connectStateMap,
@@ -61,6 +115,176 @@ Page({
         }
       })
     }
+  },
+  async holdFoucus(){
+    console.log("发送对焦命令");
+  },
+  async connectDev(e){
+    let devId = e.currentTarget.dataset.dev;
+    let dev = this.data.bleDevs.find(dev=>devId===dev.deviceId);
+    let err,res;
+    if(!dev){
+      return wx.showToast({
+        title: '数据库异常,无法找寻设备',
+      })
+    }
+    console.log(dev);
+    // 连接设备
+      this.setData({
+        ble: {...this.data.ble,state: bleStateEnum.connecting},
+      });
+      [err,res] = await handle(ble.stopSearch());
+      if(err){return wx.showToast({ title: '关闭微信失败', })}
+      wx.showToast({
+        title: `尝试${dev.name}中...`,
+      })
+      [err,res] = await handle(ble.connectDev(devId));
+      if(err){
+        return wx.showToast({
+          title: '连接失败'+err.errMsg,
+        })
+      }
+      console.log('设备连接成功');
+      console.log(res);
+      // 然后呢? 
+      this.setData({
+        ble:{...this.data.ble,state:bleStateEnum.connected}
+      });
+      // 获取服务与特征
+      [err,res] = await handle(ble.getBleServices(devId));
+      if(err){
+        wx.showToast({
+          title: '搜索蓝牙服务失败',
+        });
+        return console.log(err);
+      }
+      console.log(res);
+      res.forEach(async val=>{
+        console.log('******');
+        console.log(val.uuid);
+        let _err,_res;
+        if(val.uuid === bleServerMap.pariring.uuid ){
+          // 尝试直接向设备发起连接
+          console.log('设备配对服务');
+          // 获取特征值id
+          let code_pariring = bleServerMap.pariring.code.pariring
+          let characteristic = val.characteristics.find(c=>c.uuid.startsWith(code_pariring.firstUuid));
+          if(!characteristic){return console.log('无法配对')}
+          [_err,_res] = await handle(ble.sendData(
+            devId,
+            val.uuid,
+            characteristic.uuid,
+            code_pariring.command.connect.replace(/\s/g,'')
+            ));
+            if(_err){
+              wx.showToast({
+                title: 'Err:发送蓝牙数据失败??',
+              })
+              // 尝试关闭设备
+              setTimeout(async ()=>{
+                console.log('发送关机命令');
+                [_err,_res] = await handle(ble.sendData(
+                  devId,
+                  val.uuid,
+                  characteristic.uuid,
+                  code_pariring.command.disConnect.replace(/\s/g,'')
+                  ));
+                  if(_err){
+                    console.error(_err)
+                    wx.showToast({
+                      title: 'Err:发送设备关机命令失败??',
+                    })
+                  } else{
+                    wx.showToast({
+                      title: '发送关机命令成功??',
+                    });
+                  }
+              },10000);
+              
+               console.log(_err);
+            }
+            console.log(res);
+            wx.showToast({
+              title: '发送配对指令成功',
+            })
+        }else if(val.uuid === bleServerMap.control.uuid){
+          let listenCode = bleServerMap.control.listen;
+          // [_err,_res] = await handle(ble.listenData(devId,val.uuid,listenCode.controlTip));
+          // console.log(_res);
+          // [_err,_res] = await handle(ble.listenData(devId,val.uuid,listenCode.controlTip));
+          // console.log(_res);
+          // if(_err){
+          //   console.log('控制端口监听失败');
+          //   console.error(_err);
+          //   console.log('控制端口监听失败');
+          // }
+          // console.log('控制端口监听完成')
+        }else if(val.uuid === bleServerMap.pariring.uuid ){
+          // 尝试直接向设备发起连接
+          console.log('设备配对服务');
+          // 获取特征值id
+          let code = bleServerMap.remote.code.hold
+          let characteristic = val.characteristics.find(c=>c.uuid.startsWith(code.firstUuid));
+          if(!characteristic){return console.log('无法配对')}
+          [_err,_res] = await handle(ble.sendData(
+            devId,
+            val.uuid,
+            characteristic.uuid,
+            code.command.cmd3.replace(/\s/g,'')
+            ));
+            await sleep(10);
+            [_err,_res] = await handle(ble.sendData(
+              devId,
+              val.uuid,
+              characteristic.uuid,
+              code.command.cmd1.replace(/\s/g,'')
+              ));
+             
+            if(_err){
+              wx.showToast({
+                title: 'Err:发送快门控制命令失败',
+              })
+              // 尝试关闭设备
+              setTimeout(async ()=>{
+                console.log('发送释放快门命令');
+                [_err,_res] = await handle(ble.sendData(
+                  devId,
+                  val.uuid,
+                  characteristic.uuid,
+                  code.command.cmd2.replace(/\s/g,'')
+                  ));
+                  if(_err){
+                    console.error(_err)
+                    wx.showToast({
+                      title: 'Err:发送按住快门命令失败??',
+                    })
+                  } else{
+                    wx.showToast({
+                      title: '发送按住快门命令成功??',
+                    });
+                  }
+              },20000);
+              
+               console.log(_err);
+            }
+            console.log(res);
+            wx.showToast({
+              title: '发送按住快门指令成功',
+            })
+        }
+        console.log('******');
+        console.log(val.uuid);
+        val.characteristics.forEach(c=>{
+          console.log(c);
+        });
+        // 查看是否会有对应特征值
+        console.log('******');
+      })
+      wx.showToast({
+        title: '蓝牙服务搜索成功',
+      });
+    
+
   },
   // 事件处理函数
   bindViewTap() {
@@ -78,7 +302,7 @@ Page({
       }) 
     }
     this.setData({
-      ble: {...this.data.ble,state: 1},
+      ble: {...this.data.ble,state: bleStateEnum.searching},
     });
     ble.search(this.onSearchHandle);
   },
@@ -114,25 +338,4 @@ Page({
       })
     }
   },
-  getUserProfile(e) {
-    // 推荐使用wx.getUserProfile获取用户信息，开发者每次通过该接口获取用户个人信息均需用户确认，开发者妥善保管用户快速填写的头像昵称，避免重复弹窗
-    wx.getUserProfile({
-      desc: '展示用户信息', // 声明获取用户个人信息后的用途，后续会展示在弹窗中，请谨慎填写
-      success: (res) => {
-        console.log(res)
-        this.setData({
-          userInfo: res.userInfo,
-          hasUserInfo: true
-        })
-      }
-    })
-  },
-  getUserInfo(e) {
-    // 不推荐使用getUserInfo获取用户信息，预计自2021年4月13日起，getUserInfo将不再弹出弹窗，并直接返回匿名的用户个人信息
-    console.log(e)
-    this.setData({
-      userInfo: e.detail.userInfo,
-      hasUserInfo: true
-    })
-  }
 })

pages/index/index.wxml

@@ -28,11 +28,15 @@
           <view class="devId">{{item.deviceId}}</view>
         </view>
         <view class="option">
-          <view class="custom-info-btn">连接</view>
+          <view class="custom-info-btn" data-dev="{{item.deviceId}}" bindtap="connectDev">连接</view>
         </view>
       </view>
     </view>
   </view>
+
+  <view class="conetrol" wx:if="{{ble.state === bleStateEnum.connected}}">
+    <button bindtap="holdFoucus">对焦?</button>
+  </view>
   
   <view class="usermotto">
     <text class="user-motto">{{motto}}</text>

project.private.config.json

@@ -1,5 +1,5 @@
 {
-  "projectname": "sony%E9%81%A5%E6%8E%A7",
+  "projectname": "sonyble",
   "setting": {
     "compileHotReLoad": true
   },

utils/ble.js

@@ -1,5 +1,5 @@
 const handle = require("./handle");
-const {buf2hex} = require("./buffer");
+const {buf2hex, hex2ab} = require("./buffer");
 // 需要匹配的相机特征值列表
 const CAMERA_MANUFACTURER_LOOKUP = ["2d010300"];
 class BLE{
@@ -53,7 +53,6 @@ class BLE{
           }
         }
     });
-   
     wx.startBluetoothDevicesDiscovery({
       success(res) {
         console.log("开始搜索蓝牙：", res)
@@ -73,7 +72,143 @@ class BLE{
     }
     return res;
   }
+  connectDev(deviceId){
+    return new Promise((resolve,reject)=>{
+      console.log(`连接到:${deviceId}`);
+      wx.createBLEConnection({
+        deviceId:deviceId,
+        success:function(res){
+          resolve(res);
+        },
+        fail:function(err){
+            console.error(err);
+            reject(err);
+        }
+      })
+    })
+  }
+  // 获取蓝牙服务
+  getBleServices(devId){
+    let self = this;
+    return new Promise((resolve,reject)=>{
 
+      wx.getBLEDeviceServices({
+        //蓝牙设备ID
+        deviceId: devId,
+        success: async function (res) {
+          let services = res.services;
+          console.log(services)
+          for (let i = 0; i < services.length; i++) {
+            console.log(services[i].uuid);
+            let [err,res] = await handle(self.getServerCharacteristics(devId,services[i].uuid));
+            if(err){
+              console.log(`获取服务特征值失败 服务id:${services[i].uuid}`);
+              return reject(err);
+            }
+            services[i].characteristics = res;
+          }
+          console.log('--------');
+          resolve(services);
+         //获取蓝牙设备服务UUID成功
+        },
+        fail(res) {
+          //获取蓝牙设备服务失败
+          reject(res);
+        }
+    })
+    
+    })
+  }
+
+  // 获取蓝牙服务特征值
+  getServerCharacteristics(devId,bleServiceUUID){
+    let self = this;
+    return new Promise((resolve,reject)=>{
+      wx.getBLEDeviceCharacteristics({
+        //蓝牙设备ID
+        deviceId: devId,
+        //蓝牙服务ID
+        serviceId: bleServiceUUID,
+        success: function (res) {
+          console.log(res);
+          res.characteristics.forEach(async c=>{
+            // console.log(c);
+            if(c.properties.notify){
+              console.log(`监听${bleServiceUUID}的${c.uuid.substr(0,8)}`);
+              let [err,res] = await handle(self.listenData(devId,bleServiceUUID,c.uuid));
+              if(err){
+                console.error(err);
+                console.log(`添加监听${bleServiceUUID}的${c.uuid.substr(0,8)}失败`);
+              }
+              console.log(res);
+            }
+          })
+          resolve(res.characteristics);
+        },
+        fail(err){
+          reject(err);
+        }
+      });
+    });
+  }
+
+  // 向指定特征发送数据
+  sendData(devId,serviceId,characteristicId,hexStr){
+    console.log(hexStr);
+    hexStr = hex2ab(hexStr);
+    console.log(hexStr);
+    return new Promise((resolve,reject)=>{
+      wx.writeBLECharacteristicValue({
+          //蓝牙设备ID
+          deviceId: devId,
+          //蓝牙服务ID
+          serviceId: serviceId,
+          //写特征值ID
+          characteristicId: characteristicId,
+          //数据ArrayBuffer
+          value: hexStr,
+          success(res) {
+            //发送蓝牙数据成功
+            resolve(res);
+          },
+          fail(res) {
+            //发送蓝牙数据失败
+            reject(res);
+          }
+      })
+    })
+    
+  }
+  // 监听数据
+  listenData(devId,serviceId,uuid){
+    return new Promise((resolve,reject)=>{
+      wx.notifyBLECharacteristicValueChange({
+        state: true,
+        //蓝牙设备ID
+        deviceId: devId,
+        //蓝牙服务ID
+        serviceId: serviceId,
+        //特征值ID
+        characteristicId: uuid,
+        success: function (res) {
+          //开启通知成功
+          wx.onBLECharacteristicValueChange(function (res) {
+            //这里坐等数据过来,res.value
+            console.log('got data ');
+            console.log(res);
+            console.log(buf2hex(res.value));
+            console.log('got data ');
+          })
+          resolve(res);
+        },
+        fail: function (res) {
+          //开启通知失败
+          reject(res);
+        }
+      });
+    })
+  }
+  // 
 }
 
 

utils/buffer.js

@@ -4,4 +4,19 @@
                     .join('');
               }
 
-module.exports = {buf2hex}
+function hex2ab(hex){
+  let typedArray = new Uint8Array(hex.match(/[\da-f]{2}/gi).map(function (h) {
+    return parseInt(h, 16)
+  }))
+  let buffer = typedArray.buffer
+  return buffer
+}
+function hexStrToBuffer(str){
+  // 填充首位
+  if(str.length % 2){str=`0${str}`}
+  
+  for(let i=0;i<str.length;i+=2){
+    hex2ab
+  }
+}
+module.exports = {buf2hex,hex2ab}

utils/sleep.js

@@ -0,0 +1,5 @@
+module.exports = function (t){
+  return new Promise((resolve,reject)=>{
+    setTimeout(resolve,t)
+  })
+}