From 5b307df9695270ab0e12a4eb07e610708a785a08 Mon Sep 17 00:00:00 2001 From: "larry.liu" Date: Thu, 14 Nov 2019 19:30:33 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=BE=AE=E4=BF=A1=E8=AE=BE?= =?UTF-8?q?=E5=A4=87=E7=AE=A1=E7=90=86=201.=E8=AE=BE=E5=A4=87=E6=8E=88?= =?UTF-8?q?=E6=9D=83=E6=96=B9=E6=B3=95=202.=E8=8E=B7=E5=8F=96=E8=AE=BE?= =?UTF-8?q?=E5=A4=87=E4=BA=8C=E7=BB=B4=E7=A0=81=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- device/definitions.go | 95 +++++++++++++++++++++++++++++++++++++++++++ device/device.go | 87 +++++++++++++++++++++++++++++++++++++++ wechat.go | 6 +++ 3 files changed, 188 insertions(+) create mode 100644 device/definitions.go create mode 100644 device/device.go diff --git a/device/definitions.go b/device/definitions.go new file mode 100644 index 0000000..2bc1072 --- /dev/null +++ b/device/definitions.go @@ -0,0 +1,95 @@ +package device + +import "github.com/silenceper/wechat/util" + +const ( + //添加设备标识 + DEVICE_ADD = iota + //更新设备标识 + DEVCIE_UPGRADE +) +const ( + //android classic bluetooth + PROTOCOL_ANDROID_BLE = iota + //ios classic bluetooth + PROTOCOL_IOS_BLE + PROTOCOL_BLE + PROTOCOL_WIFI +) + +type reqDeviceAuthorize struct { + // 设备id的个数 + DeviceNum string `json:"device_num"` + // 设备id的列表，json的array格式，其size必须等于device_num + DeviceList []ReqDevice `json:"device_list"` + // 请求操作的类型，限定取值为：0：设备授权（缺省值为0） 1：设备更新（更新已授权设备的各属性值） + OpType string `json:"op_type,omitempty"` + // 设备的产品编号（由微信硬件平台分配）。可在公众号设备功能管理页面查询。 + //当 op_type 为‘0’，product_id 为‘1’时，不要填写 product_id 字段（会引起不必要错误）； + //当 op_typy 为‘0’，product_id 不为‘1’时，必须填写 product_id 字段； + //当 op_type 为 1 时，不要填写 product_id 字段。 + ProductId string `json:"product_id,omitempty"` +} + +type ReqDevice struct { + // 设备的 device id + Id string `json:"id"` + // 设备的mac地址 格式采用16进制串的方式（长度为12字节）， + // 不需要0X前缀，如： 1234567890AB + Mac string `json:"mac"` + // 支持以下四种连接协议： + // android classic bluetooth – 1 + // ios classic bluetooth – 2 + // ble – 3 + // wifi -- 4 + // 一个设备可以支持多种连接类型，用符号"|"做分割，客户端优先选择靠前的连接方式（优先级按|关系的排序依次降低），举例： + // 1：表示设备仅支持andiod classic bluetooth 1|2：表示设备支持andiod 和ios 两种classic bluetooth，但是客户端优先选择andriod classic bluetooth 协议，如果andriod classic bluetooth协议连接失败，再选择ios classic bluetooth协议进行连接 + // （注：安卓平台不同时支持BLE和classic类型） + ConnectProtocol string `json:"connect_protocol"` + //auth及通信的加密key，第三方需要将key烧制在设备上（128bit），格式采用16进制串的方式（长度为32字节），不需要0X前缀，如： 1234567890ABCDEF1234567890ABCDEF + AuthKey string `json:"auth_key"` + // 断开策略，目前支持： 1：退出公众号页面时即断开连接 2：退出公众号之后保持连接不断开 + CloseStrategy string `json:"close_strategy"` + //连接策略，32位整型，按bit位置位，目前仅第1bit和第3bit位有效（bit置0为无效，1为有效；第2bit已被废弃），且bit位可以按或置位（如1|4=5），各bit置位含义说明如下： + //1：（第1bit置位）在公众号对话页面，不停的尝试连接设备 + //4：（第3bit置位）处于非公众号页面（如主界面等），微信自动连接。当用户切换微信到前台时，可能尝试去连接设备，连上后一定时间会断开 + ConnStrategy string `json:"conn_strategy"` + // auth version，设备和微信进行auth时，会根据该版本号来确认auth buf和auth key的格式（各version对应的auth buf及key的具体格式可以参看“客户端蓝牙外设协议”），该字段目前支持取值： + // 0：不加密的version + // 1：version 1 + AuthVer string `json:"auth_ver"` + // 表示mac地址在厂商广播manufature data里含有mac地址的偏移，取值如下： + // -1：在尾部、 + // -2：表示不包含mac地址 其他：非法偏移 + ManuMacPos string `json:"manu_mac_pos"` + // 表示mac地址在厂商serial number里含有mac地址的偏移，取值如下： + // -1：表示在尾部 + // -2：表示不包含mac地址 其他：非法偏移 + SerMacPost string `json:"ser_mac_post"` + // 精简协议类型，取值如下：计步设备精简协议：1 （若该字段填1，connect_protocol 必须包括3。非精简协议设备切勿填写该字段） + BleSimpleProtocol string `json:"ble_simple_protocol,omitempty"` +} + +// 授权回调实体 +type resBaseInfo struct { + BaseInfo struct { + DeviceType string `json:"device_type"` + DeviceId string `json:"device_id"` + } `json:"base_info"` +} + +// 授权回调根信息 +type ResDeviceAuthorize struct { + util.CommonError + Resp []resBaseInfo `json:"resp"` +} + +type ResCreateQRCode struct { + util.CommonError + DeviceNum int `json:"device_num"` + CodeList []resQRCode `json:"code_list"` +} +type resQRCode struct { + DeviceId string `json:"device_id"` + Ticket string `json:"ticket"` +} diff --git a/device/device.go b/device/device.go new file mode 100644 index 0000000..91750b9 --- /dev/null +++ b/device/device.go @@ -0,0 +1,87 @@ +package device + +import ( + "encoding/json" + "fmt" + "github.com/silenceper/wechat/context" + "github.com/silenceper/wechat/util" +) + +const ( + deviceAuthorize = "https://api.weixin.qq.com/device/authorize_device" + deviceQRCode = "https://api.weixin.qq.com/device/create_qrcode" +) + +//Device struct +type Device struct { + *context.Context +} + +//NewDevice 实例 +func NewDevice(context *context.Context) *Device { + device := new(Device) + device.Context = context + return device +} + +// DeviceAuthorize 设备授权 +func (d *Device) DeviceAuthorize(devices []ReqDevice, opType int, productId string) (res []resBaseInfo, err error) { + var accessToken string + accessToken, err = d.GetAccessToken() + if err != nil { + return nil, err + } + + uri := fmt.Sprintf("%s?access_token=%s", deviceAuthorize, accessToken) + req := reqDeviceAuthorize{ + DeviceNum: fmt.Sprintf("%d", len(devices)), + DeviceList: devices, + OpType: fmt.Sprintf("%d", opType), + ProductId: productId, + } + response, err := util.PostJSON(uri, req) + if err != nil { + return nil, err + } + var result ResDeviceAuthorize + err = json.Unmarshal(response, &result) + if err != nil { + return + } + if result.ErrCode != 0 { + err = fmt.Errorf("DeviceAuthorize Error , errcode=%d , errmsg=%s", result.ErrCode, result.ErrMsg) + return + } + res = result.Resp + return +} + +// CreateQRCode 获取设备二维码 +func (d *Device) CreateQRCode(devices []string) (res []resQRCode, err error) { + var accessToken string + accessToken, err = d.GetAccessToken() + if err != nil { + return nil, err + } + uri := fmt.Sprintf("%s?access_token=%s", deviceQRCode, accessToken) + req := map[string]interface{}{ + "device_num": len(devices), + "device_id_list": devices, + } + fmt.Println(req) + response, err := util.PostJSON(uri, req) + if err != nil { + return + } + var result ResCreateQRCode + err = json.Unmarshal(response, &result) + if err != nil { + return + } + if result.ErrCode != 0 { + err = fmt.Errorf("CreateQRCode Error , errcode=%d , errmsg=%s", result.ErrCode, result.ErrMsg) + return + } + res = result.CodeList + return +} diff --git a/wechat.go b/wechat.go index f49ece9..6bbd9e8 100644 --- a/wechat.go +++ b/wechat.go @@ -1,6 +1,7 @@ package wechat import ( + "github.com/silenceper/wechat/device" "net/http" "sync" @@ -111,3 +112,8 @@ func (wc *Wechat) GetQR() *qr.QR { func (wc *Wechat) GetMiniProgram() *miniprogram.MiniProgram { return miniprogram.NewMiniProgram(wc.Context) } + +// GetDevice 获取智能设备的实例 +func (wc *Wechat) GetDevice() *device.Device { + return device.NewDevice(wc.Context) +}