program/src/utils/bluetooth.js

import game_store from "../store/game";
import ble_store from "../store/bluetooth";
import bluetooth from "../store/bluetooth";

export default {
  // 发送开启脑电数据包指令
  sendOpen(deviceId, serviceId, Cid) {
    // 向蓝牙设备发送一个0x00的16进制数据

    // 玩具对应指令数组
    let CheckSum = ((0x03 + 0x00 + 0x00 + 0x00 + 0xff) ^ 0xffffffff) & 0xff;
    let $CheckSum = "0x" + CheckSum.toString(16);

    let buffer = new ArrayBuffer(8);
    let dataView = new DataView(buffer);
    dataView.setUint8(0, "0xaa");
    dataView.setUint8(1, "0xcc");
    dataView.setUint8(2, "0x03");
    dataView.setUint8(3, "0x00");
    dataView.setUint8(4, "0x00");
    dataView.setUint8(5, "0x00");
    dataView.setUint8(6, "0xff");
    dataView.setUint8(7, $CheckSum);
    // 向低功耗蓝牙设备特征值中写入二进制数据

    wx.writeBLECharacteristicValue({
      deviceId: deviceId,
      serviceId: serviceId,
      characteristicId: Cid,
      value: buffer,
      success: function (res) {
        // console.log('开启脑电数据包成功')
        // console.log(res)
      },
      fail: function (err) {
        console.log("开启脑电数据包失败");
        console.log(err);
      },
    });
  },
  // 发送开启教具脑控指令
  sendControl(deviceId, serviceId, Cid) {
    const that = this;

    // 玩具对应指令数组
    let CheckSum = ((0x03 + 0x00 + 0x00 + 0x00 + 0x07) ^ 0xffffffff) & 0xff;
    let $CheckSum = "0x" + CheckSum.toString(16);
    // 向蓝牙设备发送一个0x00的16进制数据
    let buffer = new ArrayBuffer(8);
    let dataView = new DataView(buffer);
    dataView.setUint8(0, "0xaa");
    dataView.setUint8(1, "0xcc");
    dataView.setUint8(2, "0x03");
    dataView.setUint8(3, "0x00");
    dataView.setUint8(4, "0x00");
    dataView.setUint8(5, "0x00");
    dataView.setUint8(6, "0x07");
    dataView.setUint8(7, $CheckSum);
    // 向低功耗蓝牙设备特征值中写入二进制数据

    wx.writeBLECharacteristicValue({
      deviceId: deviceId,
      serviceId: serviceId,
      characteristicId: Cid,
      value: buffer,
      success: function (res) {
        // console.log('开启教具脑控成功')
        // that.sendOpen()
        // console.log(res)
      },
      fail: function (err) {
        console.log("开启教具脑控失败");
        console.log(err);
      },
    });
  },
  // 发送连接玩具指令
  sendConnect($hex, deviceId, serviceId, Cid, Toast, $this) {
    //获取最后两个字节
    const that = this;
    // 玩具对应指令数组
    let arr = [
      "0x01",
      "0x02",
      "0x03",
      "0x04",
      "0x05",
      "0x06",
      "0x07",
      "0x08",
      "0x09",
      "0x0a",
      "0x0b",
    ];
    let arr1 = [
      0x01,
      0x02,
      0x03,
      0x04,
      0x05,
      0x06,
      0x07,
      0x08,
      0x09,
      0x0a,
      0x0b,
    ];
    let $index = arr.indexOf($hex);
    let CheckSum =
      ((0x03 + 0x00 + arr1[$index] + 0x00 + 0x0a) ^ 0xffffffff) & 0xff;
    let $CheckSum = "0x" + CheckSum.toString(16);

    // 向蓝牙设备发送指令
    let buffer = new ArrayBuffer(8);
    let dataView = new DataView(buffer);
    dataView.setUint8(0, "0xaa");
    dataView.setUint8(1, "0xcc");
    dataView.setUint8(2, "0x03");
    dataView.setUint8(3, "0x00");
    dataView.setUint8(4, arr[$index]);
    dataView.setUint8(5, "0x00");
    dataView.setUint8(6, "0x0a");
    dataView.setUint8(7, $CheckSum);
    // 向低功耗蓝牙设备特征值中写入二进制数据

    wx.writeBLECharacteristicValue({
      deviceId: deviceId,
      serviceId: serviceId,
      characteristicId: Cid,
      value: buffer,
      success: function (res) {
        console.log("发送连接玩具指令成功");
        // wx.showLoading({
        //   title: '正在创建连接',
        // })
        that.watching_toy($this, deviceId, serviceId, Cid, Toast);

        let $game_status = game_store.getters.getGameStatus();
        if ($game_status == 1) {
          Toast.loading({
            duration: 0,
            message: "正在创建连接",
            forbidClick: true,
          });
        }
      },
      fail: function (err) {
        console.log("发送连接玩具指令失败");
        Toast.fail({
          message: "玩具连接失败",
        });
        console.log(err);
      },
    });
  },
  //发送断开玩具的指令
  sendEnd(deviceId, serviceId, Cid) {
    //AA CC 03 00 00 00 09 F3

    // 玩具对应指令数组
    let CheckSum = ((0x03 + 0x00 + 0x00 + 0x00 + 0x09) ^ 0xffffffff) & 0xff;
    let $CheckSum = "0x" + CheckSum.toString(16);

    let buffer = new ArrayBuffer(8);
    let dataView = new DataView(buffer);
    dataView.setUint8(0, "0xaa");
    dataView.setUint8(1, "0xcc");
    dataView.setUint8(2, "0x03");
    dataView.setUint8(3, "0x00");
    dataView.setUint8(4, "0x00");
    dataView.setUint8(5, "0x00");
    dataView.setUint8(6, "0x09");
    dataView.setUint8(7, $CheckSum);
    // 向低功耗蓝牙设备特征值中写入二进制数据

    wx.writeBLECharacteristicValue({
      deviceId: deviceId,
      serviceId: serviceId,
      characteristicId: Cid,
      value: buffer,
      success: function (res) {
        console.log("断开玩具成功");
        // that.sendOpen()
        console.log(res);
      },
      fail: function (err) {
        console.log("断开玩具失败");
        console.log(err);
      },
    });
  },
  // 发送停止发送脑电数据包指令
  sendPause(deviceId, serviceId, Cid) {
    let that = this;
    // 玩具对应指令数组
    let CheckSum = ((0x03 + 0x00 + 0x00 + 0x00 + 0x08) ^ 0xffffffff) & 0xff;
    let $CheckSum = "0x" + CheckSum.toString(16);
    // 向蓝牙设备发送一个0x00的16进制数据
    let buffer = new ArrayBuffer(8);
    let dataView = new DataView(buffer);
    dataView.setUint8(0, "0xaa");
    dataView.setUint8(1, "0xcc");
    dataView.setUint8(2, "0x03");
    dataView.setUint8(3, "0x00");
    dataView.setUint8(4, "0x00");
    dataView.setUint8(5, "0x00");
    dataView.setUint8(6, "0x08");
    dataView.setUint8(7, $CheckSum);
    // 向低功耗蓝牙设备特征值中写入二进制数据

    wx.writeBLECharacteristicValue({
      deviceId: deviceId,
      serviceId: serviceId,
      characteristicId: Cid,
      value: buffer,
      success: function (res) {
        console.log("停止数据发送成功");
        console.log(res);
      },
      fail: function (err) {
        console.log("停止数据发送失败");
        console.log(err);
      },
    });
  },
  // 通过字节码获取玩具
  connect_toy(hexStr, deviceId, serviceId, Cid, Toast) {
    console.log("开始连接玩具");
    let $flag = "";
    let $toys = [
      {
        id: 1,
        hex: "aadd0a0000",
        msg: "无连接设备",
        flag: false,
      },
      {
        id: 1,
        hex: "aadd0a0001",
        msg: "已连接到智脑水舞",
        flag: true,
      },
      {
        id: 2,
        hex: "aadd0a0002",
        msg: "已连接到智脑恐龙",
        flag: true,
      },
      {
        id: 3,
        hex: "aadd0a0003",
        msg: "已连接到喷雾恐龙（小)",
        flag: true,
      },
      {
        id: 4,
        hex: "aadd0a0004",
        msg: "已连接到智脑赛车",
        flag: true,
      },
      {
        id: 5,
        hex: "aadd0a0005",
        msg: "已连接到智脑碰碰车",
        flag: true,
      },
      {
        id: 6,
        hex: "aadd0a0006",
        msg: "已连接到智脑SUV赛车",
        flag: true,
      },
      {
        id: 7,
        hex: "aadd0a0007",
        msg: "已连接到小车（中）",
        flag: true,
      },
      {
        id: 8,
        hex: "aadd0a0008",
        msg: "已连接到小车（小）",
        flag: true,
      },
      {
        id: 9,
        hex: "aadd0a0009",
        msg: "已连接到智脑无人机",
        flag: true,
      },
      {
        id: 10,
        hex: "aadd0a000a",
        msg: "已连接到飞行器（小）",
        flag: true,
      },
      {
        id: 11,
        hex: "aadd0a000b",
        msg: "已连接到水母灯",
        flag: true,
      },
      {
        id: 12,
        hex: "aadd070000",
        msg: "无连接设备",
        flag: false,
      },
    ];

    $toys.forEach(($val, $index) => {
      if (hexStr.substring(0, 10) == $val["hex"]) {
        Toast.clear();
        if ($val["flag"]) {
          Toast.success($val["msg"]);
          let $game_status = game_store.getters.getGameStatus();
          if ($game_status == 1) {
            this.sendControl(deviceId, serviceId, Cid);
          }
        } else {
          if ($val["hex"] == "aadd070000") {
            this.sendOpen(deviceId, serviceId, Cid);
          } else {
            Toast.fail($val["msg"]);
          }
        }
        $flag = $val["flag"];
      }
    });
    return $flag;
  },

  //  获取大包数据 进行绘制图表
  get_big_data(hex) {
    if (hex.substr(0, 6) != "555520") {
      return false;
    }
    //当s1为 00时 数据有效
    let $s1 = hex.substr(8, 2);
    if ($s1 != "00") {
      return false;
    }

    //专注度数据
    let $att = parseInt("0x" + hex.substr(12, 2));
    //放松度数据
    let $med = parseInt("0x" + hex.substr(16, 2));

    //Delta数据
    let $delta_1 = hex.substr(hex.indexOf("0418") + 4, 2);
    let $delta_2 = hex.substr(hex.indexOf("0418") + 6, 2);
    let $delta_3 = hex.substr(hex.indexOf("0418") + 8, 2);
    let $delta = parseInt(
      (("0x" + $delta_1) << 16) | (("0x" + $delta_2) << 8) | ("0x" + $delta_3),
      16
    );

    //Theta数据
    let $theta_1 = hex.substr(hex.indexOf("0418") + 10, 2);
    let $theta_2 = hex.substr(hex.indexOf("0418") + 12, 2);
    let $theta_3 = hex.substr(hex.indexOf("0418") + 14, 2);
    let $theta = parseInt(
      (("0x" + $theta_1) << 16) | (("0x" + $theta_2) << 8) | ("0x" + $theta_3),
      16
    );

    //low_Alpha
    let $low_alpha_1 = hex.substr(hex.indexOf("0418") + 16, 2);
    let $low_alpha_2 = hex.substr(hex.indexOf("0418") + 18, 2);
    let $low_alpha_3 = hex.substr(hex.indexOf("0418") + 20, 2);
    let $low_alpha =
      (("0x" + $low_alpha_1) << 16) |
      (("0x" + $low_alpha_2) << 8) |
      ("0x" + $low_alpha_3);
    //high_Alpha
    let $high_alpha_1 = hex.substr(hex.indexOf("0418") + 22, 2);
    let $high_alpha_2 = hex.substr(hex.indexOf("0418") + 24, 2);
    let $high_alpha_3 = hex.substr(hex.indexOf("0418") + 26, 2);
    let $high_alpha =
      (("0x" + $high_alpha_1) << 16) |
      (("0x" + $high_alpha_2) << 8) |
      ("0x" + $high_alpha_3);
    let $alpha = parseInt(($high_alpha << 8) | $low_alpha, 16);

    //low_beta
    let $low_beta_1 = hex.substr(hex.indexOf("0418") + 28, 2);
    let $low_beta_2 = hex.substr(hex.indexOf("0418") + 30, 2);
    let $low_beta_3 = hex.substr(hex.indexOf("0418") + 32, 2);
    let $low_beta =
      (("0x" + $low_beta_1) << 16) |
      (("0x" + $low_beta_2) << 8) |
      ("0x" + $low_beta_3);
    //high_beta
    let $high_beta_1 = hex.substr(hex.indexOf("0418") + 34, 2);
    let $high_beta_2 = hex.substr(hex.indexOf("0418") + 36, 2);
    let $high_beta_3 = hex.substr(hex.indexOf("0418") + 38, 2);
    let $high_beta =
      (("0x" + $low_beta_1) << 16) |
      (("0x" + $low_beta_2) << 8) |
      ("0x" + $low_beta_3);
    //Beta数据
    let $beta = parseInt(($high_beta << 8) | $low_beta, 16);
    return {
      att: $att,
      med: $med,
      delta: $delta,
      theta: $theta,
      alpha: $alpha,
      beta: $beta,
    };
  },
  //获取设备电量
  get_device_elc(hex) {
    if (hex.substr(0, 8) != "55550203") {
      return false;
    }
    let $power = parseInt("0x" + hex.substr(8, 2));
    return $power;
  },

  //  监听蓝牙连接状态
  watch_bluetooth_status($that) {
    let that = this;
    // 微信自身监听低功耗蓝牙连接状态的改变事件
    wx.onBLEConnectionStateChange((res) => {
      // 该方法回调中可以用于处理连接意外断开等异常情况
      ble_store.setters.setBluetoothLinkStatus(res.connected);
      if (res.connected == false) {
        //断开玩具连接
        try {
          $that.change_toy_connect_status(0);
          //断开蓝牙连接
          $that.change_device_status(0);
        } catch (e) {
          console.log("方法不存在");
        }

        //判断游戏是否游戏中
        let $game_status = game_store.getters.getGameStatus();
        if ($game_status == 1) {
          $that.game_finished();
        }
      }
    });
  },

  //获取蓝牙设备服务
  getBLEDeviceServices(deviceId) {
    const $this = this;

    wx.getBLEDeviceServices({
      deviceId,
      success: (res) => {
        for (let i = 0; i < res.services.length; i++) {
          if (res.services[i].isPrimary) {
            $this.getBLEDeviceCharacteristics(deviceId, res.services[i].uuid);
            return;
          }
        }
      },
      fail(res) {
        console.log("连接蓝牙成功,获取服务失败");
      },
    });
  },

  //获取蓝牙设备某个服务中所有特征值
  getBLEDeviceCharacteristics(deviceId, serviceId) {
    const $this = this;
    wx.getBLEDeviceCharacteristics({
      deviceId,
      serviceId,
      success: (res) => {
        console.log("getBLEDeviceCharacteristics success", res.characteristics);
        for (let i = 0; i < res.characteristics.length; i++) {
          let item = res.characteristics[i];
          if (item.properties.read) {
            wx.readBLECharacteristicValue({
              deviceId,
              serviceId,
              characteristicId: item.uuid,
            });
          }
          if (item.properties.write) {
            $this.deviceId = deviceId;
            $this.serviceId = serviceId;
            $this.cid = item.uuid;
            game_store.setters.setDeviceId(deviceId);
            game_store.setters.setServiceId(serviceId);
            game_store.setters.setCid(item.uuid);
            //打开数据帧
            $this.sendOpen(deviceId, serviceId, item.uuid);
            // $this.sendPause(deviceId, serviceId, item.uuid)
            //获取玩具的值
            // bluetooth.sendConnect($this.toy_hex, deviceId, serviceId, item.uuid)
          }

          if (item.properties.notify || item.properties.indicate) {
            wx.notifyBLECharacteristicValueChange({
              deviceId,
              serviceId,
              characteristicId: item.uuid,
              state: true,
            });
          }
        }
      },
      fail(res) {
        console.error("getBLEDeviceCharacteristics", res);
      },
    });
  },
  //监听玩具得状态
  watching_toy($this, deviceId, serviceId, Cid, Toast) {
    Toast.loading({
      forbidClick: false,
      message: "正在创建连接",
    });
    let that = this;
    let $count = 0;
    //关闭核销选项窗口
    // $this.pay_window = false
    wx.onBLECharacteristicValueChange((characteristic) => {
      try {
        let hexStr = that.ab2hex(characteristic.value);
        //连接玩具
        let $flag = that.connect_toy(hexStr, deviceId, serviceId, Cid, Toast);
        //连接不上设备
        if ($flag) {
          //连接成功 打开核销窗口
          // $this.pay_window = true
          $this.change_toy_connect_status(2);
          let $game_status = game_store.getters.getGameStatus();
          if ($game_status == 1) {
            $this.change_toy_connect_status(4);
          }
          wx.offBLECharacteristicValueChange();
          that.watchingDevice($this);
        } else {
          $count++;
          if ($count == 10) {
            $this.change_toy_connect_status(3);
            wx.offBLECharacteristicValueChange();
            that.watchingDevice($this);
          }
        }
        // 取消监听低功耗蓝牙设备
      } catch (e) {
        wx.offBLECharacteristicValueChange();
        that.watchingDevice($this);
      }
    });
  },

  //  获取当前连接得玩具
  getConnectedToy(deviceId, serviceId, Cid) {
    let that = this;
    // 玩具对应指令数组
    let CheckSum = ((0x03 + 0x00 + 0x00 + 0x00 + 0x06) ^ 0xffffffff) & 0xff;
    let $CheckSum = "0x" + CheckSum.toString(16);
    // 向蓝牙设备发送一个0x00的16进制数据
    let buffer = new ArrayBuffer(8);
    let dataView = new DataView(buffer);
    dataView.setUint8(0, "0xaa");
    dataView.setUint8(1, "0xcc");
    dataView.setUint8(2, "0x03");
    dataView.setUint8(3, "0x00");
    dataView.setUint8(4, "0x00");
    dataView.setUint8(5, "0x00");
    dataView.setUint8(6, "0x06");
    dataView.setUint8(7, $CheckSum);
    // 向低功耗蓝牙设备特征值中写入二进制数据

    wx.writeBLECharacteristicValue({
      deviceId: deviceId,
      serviceId: serviceId,
      characteristicId: Cid,
      value: buffer,
      success: function (res) {
        console.log("获取当前连接的玩具类型");
        console.log(res);
      },
      fail: function (err) {
        console.log("获取当前连接的玩具类型失败");
        console.log(err);
      },
    });
  },
  // ArrayBuffer转16进度字符串示例
  ab2hex(buffer) {
    var hexArr = Array.prototype.map.call(
      new Uint8Array(buffer),
      function (bit) {
        return ("00" + bit.toString(16)).slice(-2);
      }
    );
    return hexArr.join("");
  },
  //断开发送数据
  shutdownSendControl(deviceId, serviceId, Cid) {
    let that = this;
    let CheckSum = ((0x03 + 0x00 + 0x00 + 0x00 + 0x0a) ^ 0xffffffff) & 0xff;
    let $CheckSum = "0x" + CheckSum.toString(16);

    // 向蓝牙设备发送指令
    let buffer = new ArrayBuffer(8);
    let dataView = new DataView(buffer);
    dataView.setUint8(0, "0xaa");
    dataView.setUint8(1, "0xcc");
    dataView.setUint8(2, "0x03");
    dataView.setUint8(3, "0x00");
    dataView.setUint8(4, "0x00");
    dataView.setUint8(5, "0x00");
    dataView.setUint8(6, "0x0a");
    dataView.setUint8(7, $CheckSum);
    // 向低功耗蓝牙设备特征值中写入二进制数据

    wx.writeBLECharacteristicValue({
      deviceId: deviceId,
      serviceId: serviceId,
      characteristicId: Cid,
      value: buffer,
      success: function (res) {
        console.log("断开连接玩具指令成功");
      },
      fail: function (err) {
        console.log("发送连接玩具指令失败");
        console.log(err);
      },
    });
  },

  // 监听脑环是否带正
  watchingDevice($this) {
    const that = this;
    wx.onBLECharacteristicValueChange((characteristic) => {
      let hexStr = that.ab2hex(characteristic.value);
      let $data = that.get_big_data(hexStr);
      wx.getBLEDeviceRSSI({
        deviceId: characteristic.deviceId,
        success(res) {
          $this.rssi = Math.abs(res["RSSI"]);
        },
      });
      if (hexStr.substr(0, 6) == "555520") {
        //当s1为 00时 数据有效
        let $s1 = hexStr.substr(8, 2);
        // console.log("监听脑环是否带正：", $s1 == '00')

        $this.device_bg = $s1 == "00";
      }

      //  监听脑环电量
      let $power = that.get_device_elc(hexStr);
      if ($power) {
        // console.log("当前脑环电量:", $power)
        $this.device_power = $power;
      }
      if ($power < 10 && $power > 0) {
        wx.showToast({
          title: "脑环电量不足",
          icon: "none",
          success() {
            $this.change_device_status(0);
          },
        });
      }

      let $game_status = game_store.getters.getGameStatus();
      if ($game_status == 1 && $data) {
        try {
          if ($this.played_time > 0) {
            //自定义定时器
            $this.played_time -= 1;
            console.log('时间自定义每秒减少1~~~ played_time',$this.played_time )
            game_store.setters.setPlayedTime($this.played_time)
            $this.played_time_text = that.formatPlaySeconds($this.played_time);
            $this.do_datas($data);
          }
          if ($this.played_time == 0) {   
            //判断是否隐藏 隐藏则不绘画
            that.shutdownSendControl(
              characteristic.deviceId,
              $this._serviceId,
              $this._characteristicId
            );
            let $hide_status = game_store.getters.getHideStatus();
            if (!$hide_status) {
              $this.game_finished();
            }
          }
        } catch (e) {
          console.log("调用方法失败", e);
        }
      }
    });
  },
  // 游玩时间倒计时 
  formatPlaySeconds(value) {
        console.log('剩余可游玩时间',value)
    // 字符串转数字
    var secondTime = parseInt(value); // 秒
    var minuteTime = 0; // 分
    if (secondTime > 60) {
      //如果秒数大于60，将秒数转换成整数
      //获取分钟，除以60取整数，得到整数分钟
      minuteTime = parseInt(secondTime / 60);
      //获取秒数，秒数取佘，得到整数秒数
      secondTime = parseInt(secondTime % 60);
      //如果分钟大于60，将分钟转换成小时
    }
    var result = "" + parseInt(secondTime);

    if (minuteTime > 0) {
      if (result.length == 1) {
        result = "0" + result;
      }
      if (parseInt(minuteTime).toString().length == 1) {
        minuteTime = "0" + parseInt(minuteTime);
      }
      result = "" + minuteTime + ":" + result;
    } else {
      result = "00:" + result;
    }
    return result;
  },
};