ver：0.0.5

desc：noble version
poster:张晓宇

package.json

@@ -55,7 +55,6 @@
   },
   "dependencies": {
     "axios": "^0.18.0",
-    "bleno": "^0.5.0",
     "bufferutil": "^4.0.1",
     "echarts": "^4.7.0",
     "element-ui": "^2.13.1",

src/renderer/components/LandingPage.vue

@@ -45,6 +45,14 @@
 </template>
 
 <script>
+  function toArrayBuffer(buf) {
+      var ab = new ArrayBuffer(buf.length);
+      var view = new Uint8Array(ab);
+      for (var i = 0; i < buf.length; ++i) {
+          view[i] = buf[i];
+      }
+      return ab;
+  }
   import h337 from "heatmap.js";
   import {mapState, mapGetters} from "vuex";
   export default {
@@ -106,6 +114,10 @@
             });
             this.h337 = heatmap;
         },1000)
+//        var buf = Buffer.from('ab1c')
+//        console.log(buf.toString('hex'))
+//        console.log(toArrayBuffer(buf))
+
     },
     computed:{
         ...mapGetters([

src/renderer/components/ble/bleIndex.vue

@@ -0,0 +1,187 @@
+<template>
+  <div class="bluetoothContent">
+
+    <el-button @click="toIndex">返回首页</el-button>
+    <el-button @click="search">搜索</el-button>
+    <el-button @click="connect">连接</el-button>
+    <br/>
+    <div  v-loading="scanLoading" element-loading-text="searching...">
+    <!--<el-select v-model="choseDeviceIndex" placeholder="请选择">-->
+        <!--<el-option-->
+                <!--v-for="(item,index) in blueDeviceList"-->
+                <!--:key="'select'+ index"-->
+                <!--:label="item.localName"-->
+                <!--:value="index">-->
+        <!--</el-option>-->
+      <!--</el-select>-->
+      <el-table
+              :data="blueDeviceList"
+              style="width: 100%">
+        <el-table-column
+                prop="localName"
+                label="localName"
+                width="280">
+        </el-table-column>
+        <el-table-column
+                prop="address"
+                label="address"
+                width="280">
+        </el-table-column>
+        <el-table-column
+                prop="option"
+                label="操作">
+          <template slot-scope="scope">
+            <!--<el-button size='small' type="primary" v-on:click="goCompanyPayDetail(scope.row.company_importantinfo_id)">查看</el-button>
+            <el-button size='small' type="primary" v-on:click="deleteCompanyPay(scope.row.company_importantinfo_id)">删除</el-button>-->
+            <el-button type="default" size="mini"  @click="connect(scope.row)">connect</el-button>
+          </template>
+        </el-table-column>
+      </el-table>
+
+
+      <!--<el-table-->
+              <!--:data="characteristicsList"-->
+              <!--style="width: 100%;padding-top: 50px">-->
+        <!--<el-table-column-->
+                <!--prop="id"-->
+                <!--label="id"-->
+                <!--width="150">-->
+        <!--</el-table-column>-->
+        <!--<el-table-column-->
+                <!--prop="uuid"-->
+                <!--label="seviceUUid"-->
+                <!--width="90">-->
+        <!--</el-table-column>-->
+        <!--<el-table-column-->
+                <!--prop="name"-->
+                <!--label="name"-->
+                <!--width="130">-->
+          <!--<template slot-scope="scope">-->
+            <!--<span>{{scope.row.name == null?'Unknown Service':scope.row.name}}</span>-->
+          <!--</template>-->
+        <!--</el-table-column>-->
+        <!--<el-table-column-->
+                <!--prop="name"-->
+                <!--label="characteristicServiceUUid"-->
+                <!--width="180">-->
+          <!--<template slot-scope="scope">-->
+            <!--<span>{{scope.row.characteristic.uuid}}</span>-->
+          <!--</template>-->
+        <!--</el-table-column>-->
+        <!--<el-table-column-->
+                <!--prop="name"-->
+                <!--label="properties"-->
+                <!--width="180">-->
+          <!--<template slot-scope="scope">-->
+            <!--<span v-for="item in scope.row.characteristic.properties">{{item + '、'}}</span>-->
+          <!--</template>-->
+        <!--</el-table-column>-->
+        <!--<el-table-column-->
+                <!--prop="name"-->
+                <!--label="options"-->
+                <!--width="180">-->
+          <!--<template slot-scope="scope">-->
+            <!--<el-button  :disabled ="!canConnect(scope.row.characteristic.properties)"  @click="connect(scope.row)">connect</el-button>-->
+          <!--</template>-->
+        <!--</el-table-column>-->
+
+      <!--</el-table>-->
+
+    </div>
+
+
+
+
+  </div>
+
+</template>
+
+<script>
+
+  import {mapGetters} from "vuex"
+  export default {
+    name: "rt_ble",
+    data() {
+      return {
+        choseBlueDeviceId: undefined,
+        choseDeviceIndex:-1,
+        characteristicsList:[],
+        row:{}
+      }
+    },
+    created() {
+        this.search()
+        this.$store.dispatch('resetDisConnectBlueStatus')
+    },
+    watch:{
+        blueDeviceList:function (val) {
+            if(val.length >0) {
+                console.log(val)
+                this.choseDeviceIndex = 0
+                this.characteristicsList = this.blueDeviceList[0].characteristics
+            }
+        },
+        choseDeviceIndex:function (val) {
+            this.characteristicsList = this.blueDeviceList[val].characteristics
+        },
+        blueDeviceConnectStatus:function (val) {
+            if(val == 1) {
+                this.successNotify('成功连接蓝牙设备！')
+                this.$router.push({ path: '/char_server', query: {localName:this.row.localName}})
+            } else {
+                this.errorNotify('连接蓝牙设备失败！')
+            }
+        }
+    },
+    methods: {
+      toIndex() {
+          this.$router.push('/')
+      },
+      search() {
+          this.$socket.emit('ble', {cmd: 'scan'})
+          this.$store.dispatch('resetBlueDeviceList')
+      },
+      connect(row) {
+         //  console.log(row)
+          let  args = {
+              id: row.id,
+          }
+          this.row = row
+          this.$socket.emit('ble', {cmd: 'connectDevice', args: args})
+      },
+      errorNotify(msg) {
+          this.$notify({
+              title: '提示',
+              message: msg,
+              duration: 4500
+          });
+      },
+      successNotify(successMessage) {
+          this.$notify({
+              title: '提示',
+              message: successMessage,
+              duration: 3500
+          });
+      },
+//      connect(row) {
+//          let connectArgsObj = {
+//              id:row.id,
+//              server_uuid:row.uuid,
+//              characteristic_uuid : row.characteristic.uuid
+//          }
+//          this.$socket.emit('ble', {cmd: 'connect', args: connectArgsObj})
+//      }
+    },
+    computed: {
+      ...mapGetters([
+        'blueDeviceList',
+        'scanLoading',
+        'blueDeviceConnectStatus'
+      ]),
+    },
+  }
+</script>
+
+<style scoped>
+
+</style>

src/renderer/components/ble/characteristicsServers.vue

@@ -0,0 +1,236 @@
+<template>
+  <div class="bluetoothContent">
+    <el-popover
+            placement="top"
+            trigger="click"
+            :ref="`popover`"
+            width="160"
+           >
+      <p >返回会断开蓝牙连接请确认</p>
+      <div style="text-align: right; margin: 0">
+        <el-button size="mini" type="text" @click="cancel">取消</el-button>
+        <el-button type="primary" size="mini" @click="confirmDisConnect" >确定</el-button>
+      </div>
+      <el-button   slot="reference"  >返回蓝牙首页</el-button>
+    </el-popover>
+    {{localName}}
+    <br/>
+      <el-table
+              :data="characteristicServiceList"
+              style="width: 100%;padding-top: 50px">
+        <el-table-column
+                prop="id"
+                label="id"
+                width="150">
+        </el-table-column>
+        <el-table-column
+                prop="uuid"
+                label="seviceUUid"
+                width="90">
+        </el-table-column>
+        <el-table-column
+                prop="name"
+                label="name"
+                width="130">
+          <template slot-scope="scope">
+            <span>{{scope.row.name == null?'Unknown Service':scope.row.name}}</span>
+          </template>
+        </el-table-column>
+        <el-table-column
+                prop="name"
+                label="characteristicServiceUUid"
+                width="180">
+          <template slot-scope="scope">
+            <span>{{scope.row.characteristic.uuid}}</span>
+          </template>
+        </el-table-column>
+        <el-table-column
+                prop="name"
+                label="properties"
+                width="180">
+          <template slot-scope="scope">
+            <span v-for="item in scope.row.characteristic.properties">{{item + '、'}}</span>
+          </template>
+        </el-table-column>
+        <el-table-column
+                prop="name"
+                label="options"
+                width="180">
+          <template slot-scope="scope">
+            <el-button  :disabled ="!canConnect(scope.row.characteristic.properties)"  @click="writeAndRead(scope.row)">write/read</el-button>
+          </template>
+        </el-table-column>
+      </el-table>
+
+    <el-dialog title="添加小程序模板" width="80%"
+               :close-on-click-modal="false"
+               :visible.sync="validate"
+               :modal-append-to-body="false"
+               :append-to-body="true"
+               :show-close="false"
+    >
+      <div style="text-align: center">
+        <div class="head_tip">
+        </div>
+        <div style="padding-bottom: 20px">
+            <!--发送数据：-->
+          <!--<el-input v-model="sendData"></el-input> <br/>-->
+          <el-button @click="startSetZero">开始取零</el-button>
+          <el-button @click="stopSetZero">停止取零</el-button>
+          <el-button @click="startCollection">开始采集</el-button>
+          <el-button @click="stopCollection">停止采集</el-button>
+          <el-button @click="resetDevice">复位</el-button>
+        </div>
+
+        <div style="padding-bottom: 20px">
+          <div style="width:140px;height:140px;position:relative;margin-top:30px" >
+            <div ref="heatsample" style="width:540px;height:540px;position:absolute;top:0;left:0" />
+            <chart id="heatmap" style="width:540px;height:540px;position:absolute;top:0"  ref="heatmap"></chart>
+          </div>
+        </div>
+      </div>
+      <div slot="footer" class="dialog-footer">
+        <el-button @click="closeDialog">关闭dialog</el-button>
+      </div>
+    </el-dialog>
+
+
+  </div>
+
+</template>
+
+<script>
+  import h337 from "heatmap.js";
+  import {mapGetters} from "vuex"
+  export default {
+    name: "char_server",
+    data() {
+      return {
+          localName:typeof (this.$route.query.localName) =='undefined' ?'N/A':this.$route.query.localName,
+          validate:false,
+          sendData:'',
+      }
+    },
+    created() {
+        // 获取characteristicServer List
+        this.getCharacteristicServerList()
+        this.$store.dispatch('resetCharacteristicServerList')
+
+    },
+    watch:{
+        blueDeviceDisConnectStatus:function (val) {
+            if(val == 1) {
+                this.$router.push('/rt_ble')
+            } else {
+                this.errorNotify('关闭蓝牙设备连接失败！')
+            }
+        },
+        pressureData:function (val) {
+            if(this.h337 != null) {
+                this.h337.setData({
+                    max: 255,
+                    data: val
+                });
+            }
+        },
+    },
+    methods: {
+        getCharacteristicServerList() {
+            this.$socket.emit('ble', {cmd: 'getCharServiceList'})
+        },
+        cancel() {
+            this.$refs[`popover`].doClose()
+        },
+        confirmDisConnect() {
+            this.$socket.emit('ble', {cmd: 'disConnectDevice'})
+            this.$router.push('/rt_ble')
+            this.$store.dispatch('resetConnectBlueStatus')
+          //  this.$refs[`popover`].doClose()
+        },
+
+        errorNotify(msg) {
+            this.$notify({
+                title: '提示',
+                message: msg,
+                duration: 4500
+            });
+        },
+        successNotify(successMessage) {
+            this.$notify({
+                title: '提示',
+                message: successMessage,
+                duration: 3500
+            });
+        },
+        canConnect(properties) {
+            let bRes = false
+            let flag = -1
+            for(let j of properties) {
+                if (j=='write'||j=='read') {
+                    flag ++
+                }
+            }
+            if(flag == 1) {
+                bRes = true
+            }
+            return bRes
+        },
+        writeAndRead(row) {
+            this.$socket.emit('ble', {cmd: 'setup',data:row})
+            this.validate = true
+            this.$store.dispatch('resetBlueToothData')
+            if(this.h337 !=null) {
+                this.h337.setData({
+                    max: 255,
+                    data: []
+                });
+            }
+            setTimeout(()=>{
+                var gradient = require('../../assets/heatmap_gradient.json')
+                var dst = this.$refs.heatsample;
+                var heatmap = h337.create({
+                    container: dst,
+                    radius:6,
+                    blur:0.7,
+                    gradient: gradient
+                });
+                this.h337 = heatmap;
+            },1000)
+        },
+        closeDialog() {
+            this.$socket.emit('ble', {cmd: 'closeSetUp'})
+            this.validate = false
+        },
+        startSetZero(){
+            this.$socket.emit('sendBleData', {type: 'setZero'})
+        },
+        stopSetZero() {
+            this.$socket.emit('sendBleData', {type: 'stopSetZero'})
+        },
+        startCollection() {
+            this.$socket.emit('sendBleData', {type: 'startCollection'})
+        },
+        stopCollection() {
+            this.$socket.emit('sendBleData', {type: 'stopCollection'})
+        },
+        resetDevice() {
+            this.$socket.emit('sendBleData', {type: 'resetDevice'})
+        }
+
+
+    },
+    computed: {
+      ...mapGetters([
+        'blueDeviceList',
+        'scanLoading',
+        'blueDeviceDisConnectStatus',
+        'characteristicServiceList',
+        'pressureData'
+      ]),
+    },
+  }
+</script>
+
+<style scoped>
+
+</style>

src/renderer/components/ble/rt_ble.vue

@@ -1,155 +0,0 @@
-<template>
-  <div class="bluetoothContent">
-
-    <el-button @click="toIndex">返回首页</el-button>
-    <el-button @click="search">搜索</el-button>
-    <el-button @click="connect">连接</el-button>
-    <el-button @click="send">发送</el-button>
-    <br/>
-    <el-select v-model="choseDeviceIndex" placeholder="请选择">
-        <el-option
-                v-for="(item,index) in blueDeviceList"
-                :key="'select'+ index"
-                :label="item.localName"
-                :value="index">
-        </el-option>
-      </el-select>
-    <div >
-      <el-table
-              :data="characteristicsList"
-              style="width: 100%;padding-top: 50px">
-        <el-table-column
-                prop="id"
-                label="id"
-                width="150">
-        </el-table-column>
-        <el-table-column
-                prop="uuid"
-                label="seviceUUid"
-                width="90">
-        </el-table-column>
-        <el-table-column
-                prop="name"
-                label="name"
-                width="130">
-          <template slot-scope="scope">
-            <span>{{scope.row.name == null?'未知name':scope.row.name}}</span>
-          </template>
-        </el-table-column>
-        <el-table-column
-                prop="name"
-                label="characteristicServiceUUid"
-                width="180">
-          <template slot-scope="scope">
-            <span>{{scope.row.characteristic.uuid}}</span>
-          </template>
-        </el-table-column>
-        <el-table-column
-                prop="name"
-                label="properties"
-                width="180">
-          <template slot-scope="scope">
-            <span v-for="item in scope.row.characteristic.properties">{{item + '、'}}</span>
-          </template>
-        </el-table-column>
-        <el-table-column
-                prop="name"
-                label="options"
-                width="180">
-          <template slot-scope="scope">
-            <el-button  :disabled ="!canConnect(scope.row.characteristic.properties)"  @click="connect(scope.row)">connect</el-button>
-          </template>
-        </el-table-column>
-
-      </el-table>
-
-    </div>
-
-
-
-
-  </div>
-
-</template>
-
-<script>
-
-  import {mapGetters} from "vuex"
-  export default {
-    name: "rt_ble",
-    data() {
-      return {
-        choseBlueDeviceId: undefined,
-        choseDeviceIndex:-1,
-        characteristicsList:[],
-      }
-    },
-    created() {
-      this.search()
-    },
-    watch:{
-        blueDeviceList:function (val) {
-            if(val.length >0) {
-                console.log(val)
-                this.choseDeviceIndex = 0
-                this.characteristicsList = this.blueDeviceList[0].characteristics
-            }
-        },
-        choseDeviceIndex:function (val) {
-            this.characteristicsList = this.blueDeviceList[val].characteristics
-        }
-    },
-    methods: {
-      toIndex() {
-        this.$router.push('/')
-        console.log(this.blueDeviceList)
-      },
-      search() {
-        this.$socket.emit('ble', {cmd: 'scan'})
-      },
-      connect() {
-        this.$socket.emit('ble', {cmd: 'connect', args: {id: this.choseBlueDeviceId}})
-      },
-      send() {
-        this.$socket.emit('ble', {cmd: 'send', args: {msg: '0123'}})
-      },
-      canConnect(properties) {
-        let bRes = false
-        for(let j of properties) {
-          if (j=='write'||j=='read'||j=='notify') {
-              bRes = true
-          }
-          break;
-        }
-        return bRes
-
-      },
-      connect(row) {
-          let connectArgsObj = {
-              id:row.id,
-              server_uuid:row.uuid,
-              characteristic_uuid : row.characteristic.uuid
-          }
-          this.$socket.emit('ble', {cmd: 'connect', args: connectArgsObj})
-      }
-    },
-    computed: {
-      ...mapGetters([
-        'blueDeviceList'
-      ]),
-      computedDevice :{
-          get:function () {
-
-
-          },
-          set:function (val) {
-
-          }
-      }
-    },
-  }
-</script>
-
-<style scoped>
-
-</style>

src/renderer/router/index.js

@@ -27,7 +27,12 @@ export default new Router({
     {
         path: '/rt_ble',
         name: 'rt_ble',
-        component: require('@/components/ble/rt_ble').default
+        component: require('@/components/ble/bleIndex').default
+    },
+    {
+        path: '/char_server',
+        name: 'char_server',
+        component: require('@/components/ble/characteristicsServers').default
     },
 
   ]

src/renderer/store/modules/socket.js

@@ -6,12 +6,33 @@ const state = {
     blueToothDevice:'',
     deviceStatus:'',
     blueSendData:'',
+    blueDeviceList: [],
+    scanLoading:false,
+    blueDeviceConnectStatus:-1,  //蓝牙连接状态  1 成功 0失败 -1初始值
+    blueDeviceDisConnectStatus:-1,  //蓝牙断开状态  1 成功 0失败 -1初始值
+    characteristicServiceList:[],
 
-    blueDeviceList: []
 }
 
 const actions = {
-
+    resetBlueDeviceList({commit}) {
+        commit('resetBlueDeviceList')
+    },
+    resetConnectBlueStatus({commit}) {
+        commit('resetConnectBlueStatus')
+    },
+    resetDisConnectBlueStatus({commit}){
+        commit('resetDisConnectBlueStatus')
+    },
+    resetCharacteristicServiceList({commit}){
+        commit('resetDisConnectBlueStatus')
+    },
+    resetCharacteristicServerList({commit}) {
+        commit('resetCharacteristicServerList')
+    },
+    resetBlueToothData({commit}) {
+        commit('resetBlueToothData')
+    }
 
 }
 const mutations = {
@@ -42,28 +63,70 @@ const mutations = {
         state.blueSendData = func.buf2hex(data)
     },
     SOCKET_blueDeviceList(state, resp) {
+        state.scanLoading = false
         if (resp.ok) {
             state.blueDeviceList = resp.data;
         } else {
             console.log(resp)
         }
+    },
+    // 连接蓝牙设备返回
+    SOCKET_connectDeviceBack(state, resp) {
+        if (resp.ok) {
+            state.blueDeviceConnectStatus = 1
+        } else {
+            state.blueDeviceConnectStatus = 0
+        }
+    },
+    // 断开蓝牙设备返回
+    SOCKET_disConnectDeviceBack(state, resp) {
+        if (resp.ok) {
+            state.blueDeviceDisConnectStatus = 1
+        } else {
+            state.blueDeviceDisConnectStatus = 0
+        }
+    },
+    SOCKET_pushCharacteristicServerList(state,info) {
+        state.characteristicServiceList.push(info)
+    },
+    resetBlueDeviceList(state) {
+        state.blueDeviceList = []
+        state.scanLoading = true
+    },
+    // 重置蓝牙连接转态 （蓝牙服务页面返回蓝牙index 页面调用）
+    resetConnectBlueStatus(state) {
+        state.blueDeviceConnectStatus = -1
+    },
+    // 重置断开蓝牙连接转态 （蓝牙index页面加载时调用
+    resetDisConnectBlueStatus(state) {
+        state.blueDeviceDisConnectStatus = -1
+    },
+    // 重置characteristicServerList
+    resetCharacteristicServerList(state) {
+        state.characteristicServiceList = []
+    },
+    resetBlueToothData(state) {
+        state.blueToothData = ''
     }
 }
 
 const getters = {
+    blueDeviceConnectStatus:state=>state.blueDeviceConnectStatus,
+    blueDeviceDisConnectStatus:state=>state.blueDeviceDisConnectStatus,
     hasConnectCount:state=>state.hasConnectCount,
     pressureData:state=>state.pressureData,
     blueToothDevice:state=>state.blueToothDevice,
     deviceStatus:state=>state.deviceStatus,
     blueSendData:state=>state.blueSendData,
-
+    scanLoading:state=>state.scanLoading,
     blueDeviceList:state=>state.blueDeviceList,
+    characteristicServiceList:state=>state.characteristicServiceList,
 }
 
 
-export default {
+    export default {
     state,
     actions,
     mutations,
     getters,
-}
+    }

src/renderer/utils/FunctionSet.js

@@ -56,7 +56,6 @@ module.exports = {
             // push to array
             hexParts.push(paddedHex);
         }
-
         // join all the hex values of the elements into a single string
         return hexParts.join('');
     },
@@ -69,6 +68,16 @@ module.exports = {
             hexCharCode.push((str.charCodeAt(i)).toString(16));
         }
         return hexCharCode;
+    },
+    // array 转string
+    ab2Ascii(buffer) {
+        var str = Array.prototype.map.call(
+            new Uint8Array(buffer),
+            function (bit) {
+                return String.fromCharCode(bit);
+            }
+        )
+        return str.join('');
     }
 
 }

static/server/app.js

@@ -19,6 +19,9 @@ let socketEvent = null;
 var connectCount = 0;
 var lastBuffer = null;
 
+var nowConnectedBlueDeviceId = ''
+
+
 io.sockets.on('connection', function (socket) {
     // 取零
     socket.on('startSetZero', function () {
@@ -161,31 +164,112 @@ io.sockets.on('connection', function (socket) {
     })
     // 蓝牙获取wifi账号密码
     socket.on('getServerIp',function (sendData) {
-        let data = sendProtocal.blueToothSendCommand(
-            sendData,'serverIp','get')
+        let data = sendProtocal.blueToothSendCommand(sendData,'serverIp','get')
         blueTouth.sendData(data)
     })
-
     socket.on('ble', function(request) {
         if (request.cmd === 'scan') {
             nobleWrapper.scan(function(resp) {
                 io.sockets.emit('blueDeviceList', resp)
             })
-        } else if (request.cmd === 'connect') {
-            let on_data_cb  = function (buffer) {
-                console.log('Received: "' + buffer.length + '"');
+        }  else if(request.cmd === 'connectDevice') {
+            // 连接蓝牙设备
+            request.args.on_data_cb =  function (data) {
+                // 接收数据！
+                if (lastBuffer !== null) {
+                    data = Buffer.concat([lastBuffer, data]);
+                }
+                let flag = 1;
+                while(flag){
+                    if (data.length < frame_header_and_size_bytes) {
+                        lastBuffer = data;
+                        break;
+                    }
+                    let dataLength = data.readUIntLE(1, 2)
+                    let frameLength = frame_header_and_size_bytes + dataLength
+
+                    if(data.length > frameLength) {
+                        let frame = data.slice(0, frameLength);
+                        setAllCommand(frame)
+                        lastBuffer = data.slice(frameLength)
+
+                        if(lastBuffer.length >= frame_header_and_size_bytes) {
+                            data = lastBuffer
+                            continue;
+                        }
+                    } else if(data.length === frameLength) {
+                        setAllCommand(data)
+                        lastBuffer = null;
+                    } else {
+                        lastBuffer = data;
+                    }
+                    flag = 0;
+                }
+                // io.sockets.emit('blueToothData', buffer)
+            }
+            nobleWrapper.connectDevice(request.args,function(resp) {
+                io.sockets.emit('connectDeviceBack', resp)
+                if(resp.ok) {
+                    nowConnectedBlueDeviceId  = request.args.id
+                } else {
+                    if(resp.msg == 'connectError') {
+                        // 连接错误
+                        console.log('server connectError')
+                    }
+                }
+                //io.sockets.emit('blueDeviceList', resp)
+            })
+           // nobleWrapper.connectDevice(request.args, request.args.successCallBack, request.args.errorCallBack);
+        } else if (request.cmd ==='disConnectDevice') {
+            // 断开蓝牙设备
+            if(nowConnectedBlueDeviceId !='') {
+                nobleWrapper.disConnectDevice(nowConnectedBlueDeviceId,function (resp) {
+                    io.sockets.emit('disConnectDeviceBack', resp)
+                })
+            }
+        } else if(request.cmd ==='getCharServiceList') {
+            // 获取CharServiceList
+            if(nowConnectedBlueDeviceId !='') {
+                nobleWrapper.getCharList(nowConnectedBlueDeviceId,function (info) {
+                    io.sockets.emit('pushCharacteristicServerList', info)
+                })
             }
-            let resp_cb =  function(resp) {
-                io.sockets.emit('blueConnect', resp)
+        } else if(request.cmd == 'setup') {
+            if(nowConnectedBlueDeviceId !='') {
+                nobleWrapper.setUp(request.data)
             }
-            nobleWrapper.connect(request.args, on_data_cb, resp_cb);
-        } else if (request.cmd === 'send') {
-            nobleWrapper.write(request.args.msg, function(resp) {
-                io.sockets.emit('blueSend', resp)
-            });
+        } else if(request.cmd == 'closeSetUp') {
+            // 用户关闭dialog  并把CharacteristicServer 取消订阅 unsubscribe
+            console.log('close')
+            nobleWrapper.disSetUp()
         }
     });
 
+    socket.on('sendBleData',function (data) {
+        let sendData = ''
+        switch (data.type) {
+            case 'setZero' :
+                sendData = sendProtocal.beginSetZero()
+                break;
+            case 'stopSetZero':
+                sendData = sendProtocal.endSetZero()
+                break;
+            case 'startCollection':
+                sendData = sendProtocal.startCollection()
+                break;
+            case 'stopCollection':
+                sendData = sendProtocal.endCollection()
+                break;
+            case 'resetDevice':
+                sendData = sendProtocal.resetDevice()
+                break;
+        }
+        nobleWrapper.write(sendData,function (res) {
+            console.log(res)
+        })
+    })
+
+
 })
 
 const frame_header_and_size_bytes = 1 + 2;
@@ -206,14 +290,12 @@ socketServer.on('connection',(socket)=>{
         if (lastBuffer !== null) {
             data = Buffer.concat([lastBuffer, data]);
         }
-
         let flag = 1;
         while(flag){
             if (data.length < frame_header_and_size_bytes) {
                 lastBuffer = data;
                 break;
             }
-
             let dataLength = data.readUIntLE(1, 2)
             let frameLength = frame_header_and_size_bytes + dataLength
 

static/server/ble/nobleWrapper.js

@@ -26,92 +26,30 @@ noble.on('discover', function (peripheral) {
     'rssi': peripheral.rssi,
   }
   blueDeviceList.push(blueDevice)
-  explore(peripheral)
-});
-
-
-function explore(peripheral) {
-  peripheral.connect(error => {
-    peripheral.discoverServices([], function (error, services) {
-      for (let serviceIndex = 0; serviceIndex < services.length; serviceIndex++) {
-        (function (service) {
-          service.discoverCharacteristics([], function (error, characteristics) {
-            for (let charIndex = 0; charIndex < characteristics.length; charIndex++) {
-              let c = characteristics[charIndex];
-              let info = {
-                id: peripheral.id,
-                uuid: service.uuid,
-                name: service.name,
-                characteristic: {
-                  'uuid': c.uuid,
-                  'properties': c.properties
-                }
-              }
-              blueCharacteristics.push(info)
-            }
-          })
-        })(services[serviceIndex])
 
-      }
-      setTimeout(function () {
-        peripheral.disconnect()
-      }, 1000)
-    })
-  })
-}
-
-function merge_scan_result() {
-  for (let i = 0; i < blueDeviceList.length; i++) {
-    let device = blueDeviceList[i]
-    device.characteristics = []
-    for (let j = 0; j < blueCharacteristics.length; j++) {
-      let character = blueCharacteristics[j]
-      if (device.id == character.id) {
-          console.log(character)
-          device.characteristics.push(character)
-      }
-    }
-  }
- // console.log(blueDeviceList)
-  return blueDeviceList
-}
-
-function connectAndSetUp(peripheral,server_uuid,characteristic_uuid) {
-    peripheral.connect(error => {
-    console.log('Connected to', peripheral.id);
-    // specify the services and characteristics to discover
-    const serviceUUIDs = [server_uuid];
-    const characteristicUUIDs = [characteristic_uuid];
-    peripheral.discoverSomeServicesAndCharacteristics(
-      serviceUUIDs,
-      characteristicUUIDs,
-      onServicesAndCharacteristicsDiscovered
-    );
-  });
+});
 
-  peripheral.on('disconnect', () => console.log('disconnected'));
-}
 
 function onServicesAndCharacteristicsDiscovered(error, services, characteristics) {
-  console.log('Discovered services and characteristics');
-  const echoCharacteristic = characteristics[0];
-
-  // data callback receives notifications
-  echoCharacteristic.on('data', (data, isNotification) => {
-    if (on_data_callback) {
-      on_data_callback(data)
-    }
-  });
-
-  // subscribe to be notified whenever the peripheral update the characteristic
-  echoCharacteristic.subscribe(error => {
-    if (error) {
-      console.error('Error subscribing to echoCharacteristic');
-    } else {
-      console.log('Subscribed for echoCharacteristic notifications');
+    if(connectedCharacteristic ==null) {
+        console.log('Discovered services and characteristics');
+        const echoCharacteristic = characteristics[0];
+        // data callback receives notifications
+        echoCharacteristic.on('data', (data, isNotification) => {
+            if (on_data_callback) {
+                on_data_callback(data)
+            }
+        });
+        // subscribe to be notified whenever the peripheral update the characteristic
+        echoCharacteristic.subscribe(error => {
+            if (error) {
+                console.error('Error subscribing to echoCharacteristic');
+            } else {
+                console.log('Subscribed for echoCharacteristic notifications');
+            }
+        });
+        connectedCharacteristic = echoCharacteristic
     }
-  });
-  connectedCharacteristic = echoCharacteristic
 }
 
 module.exports = {
@@ -121,23 +59,89 @@ module.exports = {
       blueCharacteristics = []
       setTimeout(() => {
         noble.stopScanning()
-        resp_callback(resp.ok_resp(merge_scan_result()))
+        resp_callback(resp.ok_resp(blueDeviceList))
       }, 3000);
       noble.startScanning()
     } catch (e) {
       resp_callback(resp.fail_resp(e.message))
     }
   },
-  connect: function (args, on_data_cb, resp_callback) {
-    on_data_callback = on_data_cb;
-    connectAndSetUp(inRange[args.id].peripheral,args.server_uuid,args.characteristic_uuid)
+  // 连接蓝牙设备
+  connectDevice:function (args,callBack) {
+      let peripheral = inRange[args.id].peripheral
+      on_data_callback = args.on_data_cb;
+      peripheral.connect(error => {
+          if(error == null) {
+              callBack(resp.ok_resp('success'))
+          } else {
+              callBack(resp.fail_resp('error'))
+          }
+      })
+      peripheral.on('disconnect', () => {
+            console.log('disconnect')
+          // callBack(resp.fail_resp('connectError'))
+      });
+  },
+  // 断开蓝牙设备
+  disConnectDevice:function (id,callBack) {
+      let peripheral = inRange[id].peripheral
+      peripheral.disconnect(error=>{
+          if(error == null) {
+            callBack(resp.ok_resp('success'))
+          } else {
+            callBack(resp.fail_resp('error'))
+          }
+      })
+  },
+  getCharList:function (id,callBack) {
+      let peripheral = inRange[id].peripheral
+      peripheral.discoverServices([], function (error, services) {
+          for (let serviceIndex = 0; serviceIndex < services.length; serviceIndex++) {
+              (function (service) {
+                  service.discoverCharacteristics([], function (error, characteristics) {
+                      for (let charIndex = 0; charIndex < characteristics.length; charIndex++) {
+                          let c = characteristics[charIndex];
+                          let info = {
+                              id: peripheral.id,
+                              uuid: service.uuid,
+                              name: service.name,
+                              characteristic: {
+                                  'uuid': c.uuid,
+                                  'properties': c.properties
+                              }
+                          }
+                          callBack(info)
+                      }
+                  })
+              })(services[serviceIndex])
+          }
+      })
   },
+  setUp:function (row) {
+      const serviceUUIDs = [row.uuid];
+      const characteristicUUIDs = [row.characteristic.uuid];
+      let peripheral = inRange[row.id].peripheral
+      peripheral.discoverSomeServicesAndCharacteristics(
+          serviceUUIDs,
+          characteristicUUIDs,
+          onServicesAndCharacteristicsDiscovered
+      );
+  },
+  disSetUp:function () {
+      if(connectedCharacteristic != null) {
+          connectedCharacteristic.unsubscribe(error =>{
+              console.log(error)
+              if(error ==null) {
+                  console.log('unsubscribe,success!')
+                  connectedCharacteristic = null
+              }
+          })
+      }
+  },
+
   write: function (msg, resp_callback) {
     try {
-      const buffer = new Buffer(msg, 'utf-8');
-      if (connectedCharacteristic) {
-        connectedCharacteristic.write(buffer);
-      }
+        connectedCharacteristic.write(msg);
     } catch (e) {
       resp_callback(resp.fail_resp(e.message))
     }

static/server/protocal/commonFunction.js

@@ -35,8 +35,18 @@ module.exports = {
                 }
             }
         }
-        return pressureDataProcess(dataAll,2.5,4)
+        return pressureDataProcess(dataAll,1,4)
     },
+    // arrayBuffer 转string
+    ab2Ascii(buffer) {
+        var str = Array.prototype.map.call(
+            new Uint8Array(buffer),
+            function (bit) {
+                return String.fromCharCode(bit);
+            }
+        )
+        return str.join('');
+    }
 }
 
 function pressureDataProcess(a,scale,size) {