开发者社区> 阿提说说No.1> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

真实项目,用微信小程序开门编码实现(完结)

简介: 真实项目,用微信小程序开门编码实现(完结)
+关注继续查看
大家好,欢迎来到:clap:阿提说说:clap:博客
在前面的文章《微信小程序实现蓝牙开门(一)》中我们已经做好了详细技术设计,现在这篇文章主要就是讲如何进行编码实现了。
如果读者想要知道小程序是如何调用蓝牙开门的部分,可以直接点击[小程序功能实现]跳转。

作为一个前后端都要自己写的软件,我习惯于先从后端开始,后端先从数据库开始。

创建表结构

对于Mysql数据库,我选择了之前已经安装好的云上数据库,你也可以在本地安装,安装教程请参考其他文档。
在这里插入图片描述
创建数据库的时候,选择编码为utf8mb4,因为这个编码能够保存一些特殊的表情字符。
要让这个编码能正常起作用,首先通过SHOW VARIABLES LIKE '%char%';检查character_set_server是否是utf8mb4,如果不是需要修改my.cnf配置文件,命令修改无效。

由于上一篇中已经设计好了表结构,这里就不再重复,如下是创建完毕的表。

在这里插入图片描述

创建后端服务

由于本软件在使用的时候,对后端要求不是很高,只需要对账户进行鉴权,因此SpringBoot单体应用就已经足够。

使用Spring Initializr 创建一个Spring Boot应用

在这里插入图片描述
代码目录结构
admin - 管理后台相关接口服务
api - 小程序前端调用相关接口服务
common - 公共工具类、常量等
config - Web相关的配置文件,Shiro、FreeMarker等

在这里插入图片描述

管理后台功能实现

在介绍具体功能前,有必要介绍一下几个公共的重要类:
pom.xml:maven配置
BaseController:公共的Controller,内置一些公共方法

为了篇幅,在介绍功能编码实现时,我将自行选择重要的部分进行介绍,未介绍到的部分请下载源码查看

pom.xml配置

为了读者能够容易理解,这里展示了完成后的pom配置。

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.3.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <groupId>com.mini</groupId>
    <artifactId>bluetooth</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>bluetooth-admin</name>
    <description>微信小程序后端</description>

    <properties>
        <java.version>11</java.version>
        <shiro.version>1.3.2</shiro.version>
        <mysql.version>8.0.11</mysql.version>
        <fastjson.version>1.2.58</fastjson.version>
        <druid.version>1.1.9</druid.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-freemarker</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-aop</artifactId>
        </dependency>
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>1.3.1</version>
        </dependency>

        <dependency>
            <groupId>com.github.pagehelper</groupId>
            <artifactId>pagehelper-spring-boot-starter</artifactId>
            <version>1.2.3</version>
            <exclusions>
                <exclusion>
                    <groupId>org.mybatis.spring.boot</groupId>
                    <artifactId>mybatis-spring-boot-starter</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>

        <dependency>
            <groupId>org.apache.shiro</groupId>
            <artifactId>shiro-core</artifactId>
            <version>${shiro.version}</version>
        </dependency>

        <dependency>
            <groupId>org.apache.shiro</groupId>
            <artifactId>shiro-spring</artifactId>
            <version>${shiro.version}</version>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>${mysql.version}</version>
        </dependency>

        <dependency>
            <groupId>net.178le</groupId>
            <artifactId>shiro-freemarker-tags</artifactId>
            <version>1.0.0</version>
        </dependency>

        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>${druid.version}</version>
        </dependency>

        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>${fastjson.version}</version>
        </dependency>

        <dependency>
            <groupId>commons-io</groupId>
            <artifactId>commons-io</artifactId>
            <version>1.3.2</version>
        </dependency>

        <dependency>
            <groupId>commons-fileupload</groupId>
            <artifactId>commons-fileupload</artifactId>
            <version>1.2.1</version>
        </dependency>

        <dependency>
            <groupId>com.xiaoleilu</groupId>
            <artifactId>hutool-all</artifactId>
            <version>3.0.7</version>
        </dependency>

    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <excludes>
                        <exclude>
                            <groupId>org.projectlombok</groupId>
                            <artifactId>lombok</artifactId>
                        </exclude>
                    </excludes>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>

spring-boot-starter-freemarker:freemarker依赖
spring-boot-starter-web:web依赖
spring-boot-starter-aop:aop依赖,日志记录的时候用到
pagehelper-spring-boot-starter:分页插件,内部已经包含了mybatis依赖
shiro-core、shiro-spring:shiro的依赖
mysql-connector-java:mysql依赖
shiro-freemarker-tags:shiro的freemarker标签依赖,可以在页面使用shiro标签,以便控制权限
druid:数据库连接池依赖
fastjson:json依赖
hutool-all:工具包依赖

BaseController

/**
 * 基础类,所以controller都应该继承这个类
 * 
 */
public class BaseController {

    /**
     * 定义了一些请求头格式
     */
    public static final String TEXT_UTF8 = "text/html;charset=UTF-8";
    public static final String JSON_UTF8 = "application/json;charset=UTF-8";
    public static final String XML_UTF8 = "application/xml;charset=UTF-8";

    /**
     * 定义了常用的请求方法名,便于一些统一操作
     */
    public static final String LIST = "list";
    public static final String VIEW = "view";
    public static final String ADD = "add";
    public static final String SAVE = "save";
    public static final String EDIT = "edit";
    public static final String UPDATE = "update";
    public static final String DELETE = "delete";
    public static final String PAGE = "page";


    @Autowired
    protected HttpServletRequest request;

    @Autowired
    protected HttpSession session;

    protected UserVO currentUser(){
        //用SecurityUtils.getSubject().getSession()也能获取到session
        UserVO userVO = (UserVO) session.getAttribute(Constants.SESSION_KEY);
        return userVO;
    }

    public static String redirect(String format, Object... arguments) {
        return new StringBuffer("redirect:").append(MessageFormat.format(format, arguments)).toString();
    }
}

这里定义了常用的请求格式、常用用请求方法名,便于统一操作,比如拦截、一个获取当前用户名的方法;跳转字符串拼接方法
特别的:获取当前用户的方法,这里是通过HttpSession来获取,也可以用SecurityUtils.getSubject().getSession()获取到session

登录登出功能

用户输入http://host/adminhttp://host/admin/login后都可以跳转到登录页面。
登录的时候,账户密码错误,需提示:用户名或密码不正确或已被禁用,不提示具体的错误,防止被穷举猜测。
登出的时候,需清空用户登录信息,并能跳转到登录页

@RestController
@RequestMapping("/admin/")
public class IndexController extends BaseController {


    @Autowired
    private ResourceService resourceService;

    @Autowired
    private UserService userService;

    /**
     * 登录页面跳转
     */
    @GetMapping("")
    public void index(){

    }

    /**
     * 登录页面跳转
     */
    @GetMapping(value="login")
    public void login(){
    }

    /**
     * 登录接口
     * @param userVO
     * @return
     */
    @PostMapping(value="login")
    public Result<String> loginSubmit(UserVO userVO) {
        Subject subject = SecurityUtils.getSubject();
        userVO.setPassword(userVO.getPassword());
        UsernamePasswordToken token = new UsernamePasswordToken(userVO.getUsername(), userVO.getPassword());
        try {
            //调用shiro登录
            subject.login(token);
            //对shiro的异常进行处理,前端显示不同异常
        }catch (UnknownAccountException e) {
            return new Result<>(ResultEnum.USERNAME_PASSWORD_ERROR);
        } catch (IncorrectCredentialsException e) {
            return new Result<>(ResultEnum.USERNAME_PASSWORD_ERROR);
        }catch (LockedAccountException e){
            return new Result<>(ResultEnum.USER_HAS_LOCKER);
        }catch (AuthenticationException e) {
            return new Result<>(ResultEnum.OTHER_ERROR);
        }
        //登录成功后跳转到首页
        userVO.setLastLoginTime(new Date());
        userVO.setLoginIp(subject.getSession().getHost());
        userService.updateByUserName(userVO);

        return new Result<>("/admin/index");
    }


    /**
     * 首页
     * @param modelMap
     * @return
     */
    @GetMapping(value = "index")
    public String index(ModelMap modelMap) {
        UserVO userVO = currentUser();
        String resourceId = userVO.getResourceIds();
        List<ResourceVO> result = resourceService.findById(resourceId);
        modelMap.put("list",result);
        modelMap.put("bean",userVO);
        return "admin/index";
    }


    /**
     * 退出
     * @return
     */
    @GetMapping(value = "logout")
    public String logout() {
        Subject subject = SecurityUtils.getSubject();
        subject.logout();
        return "admin/login";
    }

}

@GetMapping("")
只输入http://host/admin的情况下通过该接口跳转,freemark默认会跳转到admin/index路径,该路径的方法检测到没有登录就会跳转到login登录页

@GetMapping(value="login")
输入http://host/admin/login后跳转到登录页,freemark会自动定位到login.ftl页面

@PostMapping(value="login")
这里有几个步骤说明一下:

  • 输入用户名和密码后点击登录,前端请求该接口
  • 前端需要将密码MD5加密后传输到后端,通过用户名和密码创建一个UsernamePasswordToken令牌,将令牌传入SecurityUtils.getSubject()获取的Subject的login方法
  • 该方法会抛出AuthenticationException身份认证异常,捕获对应的异常,并转换为自定义异常反馈给前端
  • Subject的login方法处理成功后,将登录时间,登录ip更新到用户信息中
  • 返回跳转后台首页地址

@GetMapping(value = "index")
后台首页地址,该方法将获取当前登录用户信息和用户具有的权限,存入ModelMap中,供前端显示

@GetMapping(value = "logout")
后台登出接口,该方法将清除当前登录用户的状态信息,并跳转到登录页

PM: 2022年6月30日01:01:41

shiro对于登录的身份认证管理,有一个重要的类UserRealm,它负责用户的权限和身份校验功能。

/**
 * 认证
 */
@Component
public class UserRealm extends AuthorizingRealm {

    @Autowired
    private UserService userService;

    @Override
    protected AuthorizationInfo doGetAuthorizationInfo(PrincipalCollection principals) {
        String username = (String)principals.getPrimaryPrincipal();
        SimpleAuthorizationInfo authorizationInfo = new SimpleAuthorizationInfo();
        Session session = SecurityUtils.getSubject().getSession();
        UserVO userVO = (UserVO) session.getAttribute(Constants.SESSION_KEY);
        authorizationInfo.setRoles(userVO.getRoles());
        Set<String> permissions = userVO.getPermissions();
        if (username.equals("admin")){
            permissions.add("*:*");
        }
        authorizationInfo.setStringPermissions(permissions);
        return authorizationInfo;
    }

    @Override
    protected AuthenticationInfo doGetAuthenticationInfo(AuthenticationToken authenticationToken) throws AuthenticationException {

        String userno = (String) authenticationToken.getPrincipal();

        String password = new String((char[]) authenticationToken.getCredentials());

        Result<UserVO> result =  userService.login(userno, password);

        if (result.isSuccess()){

            UserVO userVO = result.getData();

            Session session = SecurityUtils.getSubject().getSession();

            session.setAttribute(Constants.SESSION_KEY,userVO);

            return new SimpleAuthenticationInfo(userVO.getUsername(), userVO.getPassword() ,getName());
        }
        return null;
    }


}

两个重要的方法:
doGetAuthorizationInfo:用于控制登录用户的权限,对于admin用户进行了特殊处理,赋予*:*
全部权限
doGetAuthenticationInfo:用于登录时,对用户进行账户密码的检验,登录成功将用户信息,以Constants.SESSION_KEY作为key存入session中,这样随时随地可以从session中取出用户信息(PS:如果是分布式项目,也可以将该用户信息转json后,存在redis中,可以网上自行搜索相关文章:shiro分布式存储session)

日志管理

日志管理使用AOP来实现,代码如下:

/**
 * 日志采集
 */
@Slf4j
@Aspect
@Component
public class LogAop {

    @Autowired
    private LogService logService;

    private static final String SAVE_TPL = "用户名:{0},修改数据,提交参数:{1}";

    private static final String USER_LOGIN_TPL = "用户:{0}登录管理后台,{1}";


    @AfterReturning(value = "execution(* com.mini.admin.controller.*.*save(..))", returning = "result")
    public void afterSaveReturn(JoinPoint joinPoint, Object result) {

        try {
            Subject subject = SecurityUtils.getSubject();

            Session session = subject.getSession();

            UserVO userVO = (UserVO) session.getAttribute(Constants.SESSION_KEY);

            LogVO logVO = new LogVO();

            logVO.setUsername(userVO.getUsername());
            logVO.setRemark(JSON.toJSONString(joinPoint.getArgs()));
            logVO.setLoginIp(session.getHost());
            logVO.setGmtCreate(new Date());

            String editAccountStr = MessageFormat.format(SAVE_TPL, logVO.getUsername(), logVO.getRemark());

            logVO.setRemark(editAccountStr);
            logService.insert(logVO);
        } catch (Exception ex) {
            log.warn("日志采集发生异常:{}", ex.getMessage(), ex);
        }
    }


    @SuppressWarnings("unchecked")
    @AfterReturning(value = "execution(* com.mini.admin.controller.IndexController.loginSubmit(..))", returning = "result")
    public void afterLoginReturn(JoinPoint joinPoint, Object result) {

        try {
            Subject subject = SecurityUtils.getSubject();

            Session session = subject.getSession();

            Result<String> stringResult = (Result<String>) result;

            Object[] methodArgs = joinPoint.getArgs();

            UserVO userVO = (UserVO) methodArgs[0];

            LogVO logVO = new LogVO();
            logVO.setUsername(userVO.getUsername());
            logVO.setRemark(JSON.toJSONString(methodArgs));
            logVO.setLoginIp(session.getHost());
            logVO.setGmtCreate(new Date());

            String loginStatus = "";

            if (stringResult.isSuccess()){
                loginStatus = "成功";
            }else {
                loginStatus = "失败,提交参数:"+ logVO.getRemark();
            }
            String str = MessageFormat.format(USER_LOGIN_TPL,logVO.getUsername(),loginStatus);
            logVO.setRemark(str);

            logService.insert(logVO);
        } catch (Exception ex) {
            log.warn("日志采集发生异常:{}", ex.getMessage(), ex);
        }

    }
}

这里主要对Controller的save相关方法和登录操作进行了捕获,并记录了提交的参数。这样谁登录了,用户的什么账户密码都被记录的一清二楚。

idusernamelogin_ipgmt_createremark
2351admin0:0:0:0:0:0:0:12022-06-30 23:57:47.0用户:admin登录管理后台,失败,提交参数:[{"length":10,"password":"14e1b600b1fd579f47433b88e8d85291","start":1,"username":"admin"}]

大家可以思考下,如果在写入日志表的时候发生异常,又没有try catch,原来的调用方法会回滚数据吗?

资源管理

省略,见源码,不懂的联系我,免费提供支持

角色管理

账户管理

机构管理

数据字典

附件管理

小程序管理-用户管理

小程序功能实现

蓝牙开门前端

<view class='container'>
  <view class="flex-grow-1 flex-x-center flex-row home-class">
    <label class="loginLab">蓝牙状态:{{blueStatus}}</label>
  </view> 
<view class="flex-grow-1 flex-x-center flex-row">
    <label class="loginLab"><text class="{{isOpening?'ds':'df'}}">{{doorStatusTxt}}</text></label>
</view>
  <view class="openBtnView flex-grow-1 flex-x-center flex-row {{isClick?'view2':'view1'}}" bindtap="{{isOpening?'openDoorNo':'openDoor'}}">
    <!--<button class="openBtn" bindtap='openDoor' type="primary">开门</button> -->
    <text class='openBtnText'>开门按钮</text>
  </view>
</view>  
  • blueStatus、doorStatusTxt是一个变量
  • 开门按钮的样式,通过{{isClick?'view2':'view1'}}控制,如果是按下状态,使用view2样式,否则使用view1样式
  • {{isOpening?'openDoorNo':'openDoor'}}绑定了不同开门状态下,执行的函数

下面来看下JS实现部分

蓝牙开门代码实现

openDoor函数

  openDoor: function() {
    var that = this;
    that.setData({ isOpen:false, isOpening: true, isClick: true, blueStatus: "未连接", doorStatusTxt: "开门中" });
    this.createBLEConnection(function() {
      console.log("第一次开门...");
      that.writeBLECharacteristicValue();
    });    
  }

首先开门的时候会赋值相关变量,用于前端页面显示,isOpen:是否开门,isOpening:是否正在开门,isClick:是否点击了按钮,blueStatus:前端页面状态显示为“未连接”,doorStatusTxt: 显示开门状态文本。

重点:
writeBLECharacteristicValue:向蓝牙发送开门请求

openDoorNo函数

  openDoorNo: function() {
    console.log("正在开门,请勿重复点击");
  }

这是一个空函数,该函数用于控制多次点击的时候,不会重复执行

writeBLECharacteristicValue写入蓝牙数据

writeBLECharacteristicValue() {
    var that = this;
    // 向蓝牙设备发送一个0x00的16进制数据
    let buffer = new ArrayBuffer(16)
    let dataView = new DataView(buffer)
    let data = new Array();
    if(this.data.userInfo.address) {
      data =  this.data.userInfo.address.split(",");
    }
    console.log(data);
    dataView.setUint16(0, data[0]);
    dataView.setUint16(2, data[1]);
    dataView.setUint16(4, data[2]);

    wx.writeBLECharacteristicValue({
      deviceId: this._deviceId,
      serviceId: this._serviceId,
      characteristicId: this._characteristicId,
      value: buffer,
      success: (res) => {
        console.log("写入成功")
        util.sleep(1000);
        if(!that.data.isOpen) {
          that.setData({ isClick: false, isOpening: false, doorStatusTxt: "开门失败" });
          that.closeBLEConnection();
        }
      },
      fail: (res) => {
        console.log("写入失败") 
        util.sleep(1000);
        if(!that.data.isOpen) {
          that.setData({ isClick: false, isOpening: false, doorStatusTxt: "开门失败" });
          that.closeBLEConnection();
        }
      },
    })
    
  }

data = this.data.userInfo.address.split(",");这里会将从后端获取的用户房屋地址信息分割,写入dataView.setUint16(0, data[0]);
一般业主可能会有多套房,需要将他们所有的房子写入蓝牙,这样业主用同一个微信就能开多个单元蓝牙门禁
这一部分就是蓝牙开门的代码,执行这的前提是蓝牙已经连接成功,下面来看看其他部分的代码实现,我已经在代码中进行了注解。

//index.js
//获取应用实例
const app = getApp()
var util = require('../../../utils/util.js');


function inArray(arr, key, val) {
  for (let i = 0; i < arr.length; i++) {
    if (arr[i][key] === val) {
      return i;
    }
  }
  return -1;
}

// ArrayBuffer转16进度字符串示例
function ab2hex(buffer) {
  var hexArr = Array.prototype.map.call(
    new Uint8Array(buffer),
    function (bit) {
      return ('00' + bit.toString(16)).slice(-2)
    }
  )
  return hexArr.join('');
}

// 字符串转byte
function stringToBytes(str) {
  var array = new Uint8Array(str.length);
  for (var i = 0, l = str.length; i < l; i++) {
    array[i] = str.charCodeAt(i);
  }
  console.log(array);
  return array.buffer;
}

Page({
  data: {
    userInfo: null,
    devices: [],
    connected: false,
    chs: [],
    blueStatus: "未连接",
    doorStatusTxt: "未开门",
    isOpen: false,
    isOpening: false,
    isClick: false,
    intervalId: 0,
    isIOS: 0
  },
  onLoad: function () {
    var userInfo = wx.getStorageSync("userInfo");
    var that = this;
    if(!userInfo){
      wx.redirectTo({
        url: '/pages/me/login/login',
      })
    }else{
      that.setData({userInfo: userInfo});
      setTimeout(function () {
        that.openBluetoothAdapter();
      }, 300);
    };
    wx.getSystemInfo({
      success: function(res) {
        if(res.platform == 'ios') {
          that.setData({isIOS: 1});
        }
      },
    })
  },

  onShow: function() {
    var userInfo = this.data.userInfo;
    var that = this;
    if (!userInfo) {
      wx.redirectTo({
        url: '/pages/me/login/login',
      })
      return;
    }
    // 判断用户是否被后台禁用
    that.userIsDisable(userInfo.userId);

    this.setData({ doorStatusTxt: "未开门", isOpen: false});

    wx.onAccelerometerChange(function (res) {
      //console.log(res.x + " /" + res.y + " /" + res.z);
      if (res.x > 0.3 && res.y > 0.6) {
        var isOpening = that.data.isOpening;
        if(!isOpening) {
          wx.showToast({
            title: '摇一摇成功',
            duration: 2000
          })
          wx.vibrateLong();
          that.openDoor();
        }
      }
    });

   if(this.data.isIOS == 1) {
     var intervalId = setInterval(this.getBluetooth, 1000);
     this.setData({ intervalId: intervalId });
   }
  },
  
  onUnload: function() {
    var userInfo = this.data.userInfo;
    if(userInfo){
      this.closeBLEConnection();
    }
  },

  //转发
  onShareAppMessage: function () {
    wx.showShareMenu({
      withShareTicket: true
    });
    var option = {
      title: '蓝牙门禁',
      path: '/pages/home/index/index',
      success: function (res) {
      }
    }
    return option;
  },

  userIsDisable: function(userId) {
    var data = {
      userId:userId
    };
    var url = app.globalData.gwapi + "user/getUserInfo";
    util.sendPost(url,data,function(res){
      if(res.code == 0){
          //账号已被停用
          if(!res.data) {
            wx.removeStorageSync("userInfo");
            wx.redirectTo({
              url: '/pages/me/login/login',
            })
          }
      }
    });
  },

  openDoorNo: function() {
    console.log("正在开门,请勿重复点击");
  },

  openDoor: function() {
    var that = this;
    that.setData({ isOpen:false, isOpening: true, isClick: true, blueStatus: "未连接", doorStatusTxt: "开门中" });
    this.createBLEConnection(function() {
      console.log("第一次开门...");
      that.writeBLECharacteristicValue();
    });    
  },

  openBluetoothAdapter() {
    var that = this;
    wx.openBluetoothAdapter({
      success: (res) => {
        console.log('openBluetoothAdapter success', res)
        that.startBluetoothDevicesDiscovery();
        this.setData({
          blueStatus: "蓝牙已打开"
        })
      },
      fail: (res) => {
        if (res.errCode === 10001) {
          this.setData({
            blueStatus: "蓝牙未打开"
          })
          wx.onBluetoothAdapterStateChange(function (res) {
            console.log('onBluetoothAdapterStateChange', res)
            if (res.available) {
              that.setData({
                blueStatus: "蓝牙已打开"
              })
            }
          })
        }
      }
    })
  },


  //创建蓝牙连接
  createBLEConnection(fc) {
    console.log("创建蓝牙连接")
    const deviceId = this.data.userInfo.bluetoothCode;
    wx.createBLEConnection({
      deviceId,
      timeout: 2000,
      success: (res) => {
        this.setData({
          blueStatus: "已连接",
        })
        this.getBLEDeviceServices(deviceId, fc)
      },
      fail: (res) => {
        this.setData({ isOpening: false, isClick: false, blueStatus: "连接失败", doorStatusTxt: "未开门" });
      }

    })
      
  },

  //关闭蓝牙连接
  closeBLEConnection() {
    var deviceId = this.data.userInfo.bluetoothCode;
    console.log("关闭蓝牙连接")
    wx.closeBLEConnection({
      deviceId: deviceId
    })
    this.setData({
      connected: false,
      chs: [],
      canWrite: false,
      blueStatus: "未连接"
    })
  },

  getBluetooth() {
    var that = this;
    wx.getBluetoothDevices({
      success: function (res) {
        that.setData({
          devices: res.devices
        });
        let deviceList = that.data.devices;
        for (var i = 0; i < deviceList.length; i++) {
          if (deviceList[i].advertisData != null) {
            //重点 根据advertisData 取出mac进行拼接
            let bf = deviceList[i].advertisData.slice(4, 10);
            let mac = ab2hex(bf).toUpperCase();
            console.log("mac: "+mac);
            var deviceId = that.data.userInfo.bluetoothCode.replace(/:/g,"");
            console.log("deviceId: " + deviceId);
            if (mac == deviceId) {
              that.data.userInfo.bluetoothCode = deviceList[i].deviceId;
              that.stopBluetoothDevicesDiscovery();
            }
          }
        }
        clearInterval(that.data.intervalId);
      },
      fail: function (res) { },
      complete: function (res) { },
    })
  },

  //获取蓝牙设备所有服务
  getBLEDeviceServices(deviceId, fc) {
    console.log("获取蓝牙服务")
    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, fc)
            return
          }
        }
      }
    })
  },

  //获取蓝牙设备某个服务中所有特征值
  getBLEDeviceCharacteristics(deviceId, serviceId, fc) {
    wx.getBLEDeviceCharacteristics({
      deviceId,
      serviceId,
      success: (res) => {
        console.log('getBLEDeviceCharacteristics success', res.characteristics)
        for (let i = 0; i < 1; i++) {
          let item = res.characteristics[i]
          if (item.properties.write) {
            this._deviceId = deviceId
            this._serviceId = serviceId
            this._characteristicId = item.uuid
            console.log(serviceId);
            //this.writeBLECharacteristicValue()
          }
          if (item.properties.notify || item.properties.indicate) {
            wx.notifyBLECharacteristicValueChange({
              deviceId,
              serviceId,
              characteristicId: item.uuid,
              state: true,
              success: (res) => {
                console.log(res.errMsg)
                this.onBLECharacteristicValueChange()
              },
              fail: (res) => {
                console.log(res.errMsg)
              }
            })
          }
        }
        //回调
        fc();
      },
      fail(res) {
        console.error('getBLEDeviceCharacteristics', res)
      }
    })

  },

  // 操作之前先监听,保证第一时间获取数据
  onBLECharacteristicValueChange() {
    wx.onBLECharacteristicValueChange((characteristic) => {
      const idx = inArray(this.data.chs, 'uuid', characteristic.characteristicId)
      console.log(ab2hex(characteristic.value));
      var data = ab2hex(characteristic.value);
      console.log(data);
      if (data = 'cc'){
        this.setData({ doorStatusTxt: "已开门", isOpen: true, isClick: false, isOpening:false});
        this.closeBLEConnection();
        wx.vibrateLong();
      }
    })
  },

  writeBLECharacteristicValue() {
    var that = this;
    // 向蓝牙设备发送一个0x00的16进制数据
    let buffer = new ArrayBuffer(16)
    let dataView = new DataView(buffer)
    let data = new Array();
    if(this.data.userInfo.address) {
      data =  this.data.userInfo.address.split(",");
    }
    console.log(data);
    dataView.setUint16(0, data[0]);
    dataView.setUint16(2, data[1]);
    dataView.setUint16(4, data[2]);

    wx.writeBLECharacteristicValue({
      deviceId: this._deviceId,
      serviceId: this._serviceId,
      characteristicId: this._characteristicId,
      value: buffer,
      success: (res) => {
        console.log("写入成功")
        util.sleep(1000);
        if(!that.data.isOpen) {
          that.setData({ isClick: false, isOpening: false, doorStatusTxt: "开门失败" });
          that.closeBLEConnection();
        }
      },
      fail: (res) => {
        console.log("写入失败") 
        util.sleep(1000);
        if(!that.data.isOpen) {
          that.setData({ isClick: false, isOpening: false, doorStatusTxt: "开门失败" });
          that.closeBLEConnection();
        }
      },
    })
    
  },

  closeBluetoothAdapter() {
    wx.closeBluetoothAdapter()
    this._discoveryStarted = false
  },

  //获取本机蓝牙适配器状态
  getBluetoothAdapterState() {
    wx.getBluetoothAdapterState({
      success: (res) => {
        console.log('getBluetoothAdapterState', res)
        if (res.discovering) {
          this.onBluetoothDeviceFound()
        } else if (res.available) {
          this.startBluetoothDevicesDiscovery()
        }
      }
    })
  },

  //开始搜索蓝牙
  startBluetoothDevicesDiscovery() {
    if (this._discoveryStarted) {
      return
    }
    this._discoveryStarted = true
    wx.startBluetoothDevicesDiscovery({
      success: (res) => {
        console.log('startBluetoothDevicesDiscovery success', res)
        this.onBluetoothDeviceFound()
      },
    })
  },

  //结束搜索蓝牙
  stopBluetoothDevicesDiscovery() {
    wx.stopBluetoothDevicesDiscovery()
  },

  //找到新蓝牙事件
  onBluetoothDeviceFound() {
    wx.onBluetoothDeviceFound((res) => {
      console.log(res.devices);
    })
  },

})

有人可能会问,你的util是什么,util是我自己封装的请求get、post的简易方法,还有格式化时间方法。
到这里,我们《微信小程序实现蓝牙开门》已经全部完成了,让我们看看完整的效果。小程序源码私信获取。

在这里插入图片描述
在这里插入图片描述

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
微信小程序实现图书管理系统
系统使用SSM框架开发图书管理的后台管理接口功能,小程序通过接口进行调用显示,并提供给客户相应的处理操作功能,主要包括图书的增删改查功能 运行环境 Jdk8+tomcat8+mysql5.7+eclipse或IDEA+微信小程序 项目技术(必填) spring+spring mvc+mybatis+微信小程序
20 0
【小程序】一文带你了解微信小程序开发(小程序注册/开发工具的下载)
文章目录 什么是小程序? 小程序可以干什么? 小程序注册 小程序开发工具下载
14 0
☀️苏州程序大白一文教你学会微信小程序开发☀️《❤️记得收藏❤️》
☀️苏州程序大白一文教你学会微信小程序开发☀️《❤️记得收藏❤️》
40 0
1.3【微信小程序全栈开发课程】小程序账号注册、开发工具下载安装
1、注册小程序 (1)注册小程序账号 点击下面注册地址开始注册 https://mp.weixin.qq.com/wxopen/waregister?action=step1 第一步:完善账号信息,选择一个自己的邮箱注册 第二步:进行邮箱激活,登录邮箱,点击激活链接 第三步:用户信息登记,确认主体类型,我选择的是「个人」类型 66
17 0
【愚公系列】2022年04月 微信小程序-image图片
【愚公系列】2022年04月 微信小程序-image图片
19 0
【愚公系列】2022年04月 微信小程序-项目篇(祝福语)-01 首页页面设计
【愚公系列】2022年04月 微信小程序-项目篇(祝福语)-01 首页页面设计
34 0
飞猪微信小程序建设总结
飞猪对小程序业务的尝试是比较早的,随着支付宝小程序的出现飞猪的各条业务线都在不断尝试小程序化以更好的在支付宝端获客、触达、留存,但是因为众所周知的原因飞猪一直没有尝试过微信小程序。随着21年反垄断的风越吹越盛,阿里的一些业务开始在微信领域伸出了触角,飞猪也随势而动尝试开垦“微信小程序”这块对我们来说是“处女地”的地方。
227 0
Python编程:Built-in Functions内建函数小结
Python编程:Built-in Functions内建函数小结
73 0
微信小程序源码
内带scroll滚动轮播:如图:           微信小程序开发工具:微信开发工具; 文件目录:     images:小程序的图标 pages:小程序页面 utils:方法js git地址:https://github.
1060 0
+关注
阿提说说No.1
一年太久,只争朝夕,在这里分享技术干货和灵感、推荐新书和好玩的项目、分享Java面试题,好书分享,WX公众号【阿提说说】同名博客,WX:stars12388。
73
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载