814 lines
21 KiB
JavaScript
814 lines
21 KiB
JavaScript
|
// index.js
|
|||
|
|
// 获取应用实例\
|
|||
|
|
|
|||
|
|
|
|||
|
|
import Dialog from '@vant/weapp/dialog/dialog';
|
|||
|
|
import Notify from '@vant/weapp/notify/notify';
|
|||
|
|
import util from '../../utils/util.js';
|
|||
|
|
// const imgd=require('./imgd.js')
|
|||
|
|
|
|||
|
|
const printerJobs = require("../../printer/printerjobs")
|
|||
|
|
const printerUtil = require("../../printer/printerutil")
|
|||
|
|
const toArrayBuffer = require("to-array-buffer")
|
|||
|
|
const {
|
|||
|
|
Buffer
|
|||
|
|
} = require("buffer")
|
|||
|
|
|
|||
|
|
let jobIdx = 0
|
|||
|
|
|
|||
|
|
const app = getApp()
|
|||
|
|
let readyJobs=[]
|
|||
|
|
|
|||
|
|
let firstOpenLoad = true
|
|||
|
|
Page({
|
|||
|
|
data: {
|
|||
|
|
dpr:1,
|
|||
|
|
// 打印图片配置
|
|||
|
|
printerImageConfig:{
|
|||
|
|
width:200,
|
|||
|
|
height:200,
|
|||
|
|
},
|
|||
|
|
// 是否连接
|
|||
|
|
isConnect: false,
|
|||
|
|
// 小程序版本
|
|||
|
|
version: "",
|
|||
|
|
// 设备列表
|
|||
|
|
deviceList: [
|
|||
|
|
// {
|
|||
|
|
// name: "MP00",
|
|||
|
|
// deviceId: "86:67:7A:66:88:81",
|
|||
|
|
// RSSI: -99
|
|||
|
|
// }
|
|||
|
|
],
|
|||
|
|
// 连接的设备 service
|
|||
|
|
inactive: [],
|
|||
|
|
// 连接的设备id
|
|||
|
|
id: "",
|
|||
|
|
// 连接的设备id
|
|||
|
|
connectId: "",
|
|||
|
|
// 历史打印
|
|||
|
|
printDataList: [],
|
|||
|
|
// 当前选择的打印数据
|
|||
|
|
currentChosePaper: {
|
|||
|
|
|
|||
|
|
},
|
|||
|
|
// 请求地址
|
|||
|
|
baseUrl: "https://amdog.github.io",
|
|||
|
|
// 是否正在打印
|
|||
|
|
isPrinting: false
|
|||
|
|
},
|
|||
|
|
onHide() {
|
|||
|
|
this.focusDisDevice(() => {
|
|||
|
|
|
|||
|
|
});
|
|||
|
|
},
|
|||
|
|
onShow() {
|
|||
|
|
if (!this.data.id || (this.data.inactive.length == 0)) {
|
|||
|
|
this.queryDeviceList(true);
|
|||
|
|
}
|
|||
|
|
},
|
|||
|
|
|
|||
|
|
onLoad(options) {
|
|||
|
|
|
|||
|
|
// 设置小程序版本
|
|||
|
|
let miniInfo = wx.getAccountInfoSync()
|
|||
|
|
console.log(miniInfo.miniProgram.version, "小程序版本")
|
|||
|
|
this.setData({
|
|||
|
|
version: miniInfo.miniProgram.version || "未知版本"
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
let id = '1111111111'
|
|||
|
|
if (options && options.id) {
|
|||
|
|
id = options.id
|
|||
|
|
}
|
|||
|
|
if (id) {
|
|||
|
|
this.loadBizPaper(id)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
let paperList = wx.getStorageSync("printerHistoryLocalPaper") || []
|
|||
|
|
this.setData({
|
|||
|
|
printDataList: paperList
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
},
|
|||
|
|
|
|||
|
|
|
|||
|
|
//加载短链接的打印任务
|
|||
|
|
loadBizPaper(id) {
|
|||
|
|
|
|||
|
|
let that = this
|
|||
|
|
// 我用的是测试地址
|
|||
|
|
wx.request({
|
|||
|
|
url: this.data.baseUrl+"/public/test-printer-response.json?v",
|
|||
|
|
method: "get",
|
|||
|
|
success(res) {
|
|||
|
|
// 如果我的链接失效了 返回error 那就看这个目录下的test-response.json文件
|
|||
|
|
console.log("获取打印数据上下文==>", res.data)
|
|||
|
|
// 更新打印历史
|
|||
|
|
let list = that.data.printDataList
|
|||
|
|
list = list.filter(it => {
|
|||
|
|
return it && it.name != res.data.name
|
|||
|
|
})
|
|||
|
|
list.unshift(res.data)
|
|||
|
|
that.setData({
|
|||
|
|
printDataList: list
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
wx.setStorageSync("printerHistoryLocalPaper", list.slice(0, 20))
|
|||
|
|
|
|||
|
|
that.previewPrintPaper({}, res.data)
|
|||
|
|
that.setData({
|
|||
|
|
currentChosePaper:res.data
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
},
|
|||
|
|
fail(err) {
|
|||
|
|
|
|||
|
|
Dialog.alert({
|
|||
|
|
message: '错误码:[10001];获取打印任务失败了,' + JSON.stringify(err),
|
|||
|
|
})
|
|||
|
|
console.log(err);
|
|||
|
|
}
|
|||
|
|
})
|
|||
|
|
},
|
|||
|
|
// 预览打印单 如果没有val 那就是点击触发的
|
|||
|
|
async previewPrintPaper(event, val) {
|
|||
|
|
if (!val) {
|
|||
|
|
val = event.currentTarget.dataset.val
|
|||
|
|
};
|
|||
|
|
await new Promise(res => {
|
|||
|
|
setTimeout(() => {
|
|||
|
|
res(1)
|
|||
|
|
}, 500);
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
this.setData({
|
|||
|
|
currentChosePaper: val,
|
|||
|
|
showPreview: true
|
|||
|
|
})
|
|||
|
|
},
|
|||
|
|
|
|||
|
|
// 切换
|
|||
|
|
closePaperPreview() {
|
|||
|
|
this.setData({
|
|||
|
|
showPreview: false
|
|||
|
|
})
|
|||
|
|
},
|
|||
|
|
|
|||
|
|
// 解析指令 返回解析完成的单子 buffer
|
|||
|
|
async compileContextToBuffer() {
|
|||
|
|
|
|||
|
|
// =>PRINT_TEXT_CENTER_LARGE_BOLD=打印文本 居中 大号字体 加粗字体
|
|||
|
|
// =>PRINT_TEXT_CENTER=
|
|||
|
|
// =>PRINT_IMG_BASE64_URL=打印图片地址 必须为base64 并且直接返回
|
|||
|
|
|
|||
|
|
|
|||
|
|
let util = {
|
|||
|
|
job: null,
|
|||
|
|
setAlign(cmd) {
|
|||
|
|
if (cmd.indexOf("CENTER") > -1) {
|
|||
|
|
return this.job.setAlign("CT")
|
|||
|
|
}
|
|||
|
|
if (cmd.indexOf("LEFT") > -1) {
|
|||
|
|
return this.job.setAlign("LT")
|
|||
|
|
}
|
|||
|
|
if (cmd.indexOf("RIGHT") > -1) {
|
|||
|
|
return this.job.setAlign("RT")
|
|||
|
|
}
|
|||
|
|
return this.job.setAlign("CT")
|
|||
|
|
},
|
|||
|
|
setSize(cmd) {
|
|||
|
|
if (cmd.indexOf("LARGE") > -1) {
|
|||
|
|
return this.job.setSize(2, 2)
|
|||
|
|
}
|
|||
|
|
return this.job.setSize(1, 1)
|
|||
|
|
},
|
|||
|
|
setBold(cmd) {
|
|||
|
|
if (cmd.indexOf("BOLD") > -1) {
|
|||
|
|
return this.job.setBold(true)
|
|||
|
|
}
|
|||
|
|
return this.job.setBold(false)
|
|||
|
|
},
|
|||
|
|
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 在这里拿到我的打印逻辑指令
|
|||
|
|
let template =this.data.currentChosePaper.ext_print_template
|
|||
|
|
|
|||
|
|
// 去除空行
|
|||
|
|
let templates = template.split("\n")
|
|||
|
|
// 解析为对象
|
|||
|
|
.map(v => {
|
|||
|
|
let cmds = v.match(/=>([\s\S]*?)->/g);
|
|||
|
|
return {
|
|||
|
|
cmds: (cmds || [])[0],
|
|||
|
|
content: v.split(cmds || "")[1]
|
|||
|
|
}
|
|||
|
|
}).filter(v => {
|
|||
|
|
return v.cmds;
|
|||
|
|
})
|
|||
|
|
console.log("解析后指令=>", templates)
|
|||
|
|
|
|||
|
|
for (const val of templates) {
|
|||
|
|
// 这是文字打印
|
|||
|
|
if (val.cmds.indexOf("TEXT") > -1) {
|
|||
|
|
console.log("文字打印指令",val)
|
|||
|
|
util.job = new printerJobs();
|
|||
|
|
util.setSize(val.cmds)
|
|||
|
|
util.setAlign(val.cmds)
|
|||
|
|
util.setBold(val.cmds)
|
|||
|
|
util.job.print(printerUtil.fillAround(val.content, ""))
|
|||
|
|
let textBuffer=util.job.buffer();
|
|||
|
|
for (let i = 0; i < textBuffer.byteLength; i = i + 20) { //限制输入数据
|
|||
|
|
// 把解析到一行的指令写到任务里面
|
|||
|
|
readyJobs.push(textBuffer.slice(i, i + 20));
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
// 这是图片打印
|
|||
|
|
if (val.cmds.indexOf("PRINT_IMAGE_DATA_URL") > -1) {
|
|||
|
|
console.log("读取到打印base64图片" + val.content)
|
|||
|
|
// 使用正则表达式解析高度和宽度
|
|||
|
|
const regex = /H(\d+)_W(\d+)/;
|
|||
|
|
const match = val.cmds.match(regex);
|
|||
|
|
|
|||
|
|
let height = 200; // 高度
|
|||
|
|
let width = 200; // 宽度
|
|||
|
|
|
|||
|
|
if (match) {
|
|||
|
|
height = parseInt(match[1]) ; // 高度
|
|||
|
|
width = parseInt(match[2]); // 宽度
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 把宽高丢给全局
|
|||
|
|
let config=this.data.printerImageConfig
|
|||
|
|
config.width=width
|
|||
|
|
config.height=height
|
|||
|
|
|
|||
|
|
this.setData({
|
|||
|
|
printerImageConfig:config
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
|
|||
|
|
// 这这里就重要了 获取图片的imagedata 对象
|
|||
|
|
// imagedata 就是图片的rgba序列 四个代表一个像素 例如[244,211,23,255,r.....g.....b.....a]
|
|||
|
|
let imageDataArr = await this.loadImageData(val.content)
|
|||
|
|
// 等待打印图片
|
|||
|
|
|
|||
|
|
|
|||
|
|
// 获取图片居中方式
|
|||
|
|
let align="RIGHT"
|
|||
|
|
//
|
|||
|
|
if(val.cmds.indexOf("RIGHT") > -1){
|
|||
|
|
align="RIGHT"
|
|||
|
|
}
|
|||
|
|
if(val.cmds.indexOf("LEFT") > -1){
|
|||
|
|
align="LEFT"
|
|||
|
|
}
|
|||
|
|
if(val.cmds.indexOf("CENTER") > -1){
|
|||
|
|
align="CENTER"
|
|||
|
|
}
|
|||
|
|
// 把imagedata对象解析为arraybuffer可打印指令
|
|||
|
|
await this.imageDataPrintBuffer(imageDataArr, width, height,align);
|
|||
|
|
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
},
|
|||
|
|
// 加载图片
|
|||
|
|
loadImageData(url) {
|
|||
|
|
return new Promise(next => {
|
|||
|
|
wx.request({
|
|||
|
|
url: this.data.baseUrl + url,
|
|||
|
|
method: "get",
|
|||
|
|
success(res) {
|
|||
|
|
if (res.data) {
|
|||
|
|
// console.log("加载图片响应==>" + res.data)
|
|||
|
|
|
|||
|
|
// 这里返回的是imagedata 对象
|
|||
|
|
// 老办法是用微信小程序canvas对象把图片渲染上去然后再用getimagedata取出来，但是这个方法要折腾canvas 小程序太shi了，图片渲染上去会错位之类的跟取出来的图片不一致
|
|||
|
|
// 打印时候就会又黑边
|
|||
|
|
// 如果你也一样用spring 这是获取二维码 并转为imagedata的代码
|
|||
|
|
/*
|
|||
|
|
@GetMapping ("/makeQrcodeImageDataJSONArray")
|
|||
|
|
@Anonymous
|
|||
|
|
public JSONArray makeQrcodeImageDataJSONArray(@RequestParam(required = true) String url,
|
|||
|
|
@RequestParam(required = false) int width,
|
|||
|
|
@RequestParam(required = false) int height) throws IOException {
|
|||
|
|
try{
|
|||
|
|
Map<EncodeHintType, Object> hints = new HashMap<>();
|
|||
|
|
hints.put(EncodeHintType.CHARACTER_SET, "UTF-8");
|
|||
|
|
BitMatrix bitMatrix = new QRCodeWriter().encode(url, BarcodeFormat.QR_CODE, width, height, hints);
|
|||
|
|
// 将 BitMatrix 转换为 BufferedImage
|
|||
|
|
BufferedImage image = MatrixToImageWriter.toBufferedImage(bitMatrix);
|
|||
|
|
// 获取图像的宽度和高度
|
|||
|
|
int imageWidth = image.getWidth();
|
|||
|
|
int imageHeight = image.getHeight();
|
|||
|
|
// 遍历图像的所有像素点，并获取它们的 RGBA 值
|
|||
|
|
List<Object> rgbaValues = new ArrayList<>();
|
|||
|
|
for (int y = 0; y < imageHeight; y++) {
|
|||
|
|
for (int x = 0; x < imageWidth; x++) {
|
|||
|
|
int rgb = image.getRGB(x, y);
|
|||
|
|
int alpha = (rgb >> 24) & 0xFF; // 获取 alpha 值
|
|||
|
|
int red = (rgb >> 16) & 0xFF;
|
|||
|
|
int green = (rgb >> 8) & 0xFF;
|
|||
|
|
int blue = rgb & 0xFF;
|
|||
|
|
rgbaValues.add(red);
|
|||
|
|
rgbaValues.add(green);
|
|||
|
|
rgbaValues.add(blue);
|
|||
|
|
rgbaValues.add(alpha);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return new JSONArray(rgbaValues);
|
|||
|
|
}catch(Exception e){
|
|||
|
|
return new JSONArray();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
*/
|
|||
|
|
|
|||
|
|
next(res.data)
|
|||
|
|
|
|||
|
|
} else {
|
|||
|
|
Dialog.alert({
|
|||
|
|
message: '错误码:[28001];尝试获取图片编码失败了',
|
|||
|
|
}).then(() => {
|
|||
|
|
// on close
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
},
|
|||
|
|
fail(err) {
|
|||
|
|
|
|||
|
|
Dialog.alert({
|
|||
|
|
message: '错误码:[18001];尝试获取图片编码失败了,' + JSON.stringify(err),
|
|||
|
|
})
|
|||
|
|
console.log(err);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
|
|||
|
|
})
|
|||
|
|
},
|
|||
|
|
|
|||
|
|
|
|||
|
|
/*
|
|||
|
|
!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
|
|||
|
|
!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
|
|||
|
|
!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
|
|||
|
|
!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
|
|||
|
|
!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
|
|||
|
|
最主要的打印逻辑在这里 主要的逻辑
|
|||
|
|
|
|||
|
|
*/
|
|||
|
|
// 开始打印单据
|
|||
|
|
async toWriteSqPrint() {
|
|||
|
|
if (this.data.isPrinting) {
|
|||
|
|
return Notify({
|
|||
|
|
type: 'warning',
|
|||
|
|
message: '操作频繁'
|
|||
|
|
});;
|
|||
|
|
}
|
|||
|
|
this.setData({
|
|||
|
|
isPrinting: true
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
setTimeout(() => {
|
|||
|
|
this.setData({
|
|||
|
|
isPrinting: false
|
|||
|
|
})
|
|||
|
|
}, 2000);
|
|||
|
|
|
|||
|
|
wx.showLoading({
|
|||
|
|
title: '正在编译打印机指令...',
|
|||
|
|
})
|
|||
|
|
// 这个全局变量是用来收集打印指令buffer的 每个元素都是arraybuffer类型 且不大于20字节
|
|||
|
|
readyJobs=[];
|
|||
|
|
// 编译打印指令 语法是我自己编的 图一乐就好 这个方法就是吧单据数据中的 ext_print_template 字段也就是我编的指令解析为可以直接打印的buffer 并存到readyJobs中
|
|||
|
|
await this.compileContextToBuffer();
|
|||
|
|
// 遍历处理
|
|||
|
|
console.log("打印任务==>",readyJobs)
|
|||
|
|
|
|||
|
|
// 当前打印到哪里了
|
|||
|
|
jobIdx=0;
|
|||
|
|
// 开始去打印
|
|||
|
|
await this.beforePrintClock()
|
|||
|
|
wx.hideLoading()
|
|||
|
|
console.log("结束=>",jobIdx)
|
|||
|
|
|
|||
|
|
},
|
|||
|
|
// 处理图片
|
|||
|
|
async imageDataPrintBuffer(imageDataArr, width, height,align) {
|
|||
|
|
// 这里注释的 是我用的老方法 我打算用base64 直接获取imagedata对象 但是太难了 没有用这种方式
|
|||
|
|
// const binaryString = this.baseAtob(imageDataArring.split(",")[1]);
|
|||
|
|
// const byteArray = new Uint8ClampedArray(binaryString.length);
|
|||
|
|
// for (let i = 0; i < binaryString.length; i++) {
|
|||
|
|
// byteArray[i] = binaryString.charCodeAt(i);
|
|||
|
|
// }
|
|||
|
|
// const imgData = new ImageData(byteArray, width, height);
|
|||
|
|
// // console.log("base64转为Unit8",byteArray);
|
|||
|
|
// //
|
|||
|
|
|
|||
|
|
// imagedata 数组转为unit8array
|
|||
|
|
const byteArray = new Uint8ClampedArray(imageDataArr.length);
|
|||
|
|
for (let i = 0; i < imageDataArr.length; i++) {
|
|||
|
|
byteArray[i] = imageDataArr[i];
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 黑白处理之类的 不用管
|
|||
|
|
let arr = this.convert4to2(byteArray);
|
|||
|
|
let data = this.convert8to1(arr);
|
|||
|
|
|
|||
|
|
|
|||
|
|
// 除以8 具体看网上解释
|
|||
|
|
let xl = width / 8
|
|||
|
|
let xh = height
|
|||
|
|
console.log("xl，xh",xl,xh)
|
|||
|
|
|
|||
|
|
// 居中指令合集
|
|||
|
|
let printAlignCommand = {
|
|||
|
|
LEFT: [27, 97, 0], //居左
|
|||
|
|
CENTER: [27, 97, 1], //居中
|
|||
|
|
RIGHT: [27, 97, 2], //居右
|
|||
|
|
};
|
|||
|
|
// [27, 64] 代表初始化打印机 [29, 118, 48, 0, xl, 0, xh, 0]预先设置好 要给纸张留的空间 因为要放图片是吧
|
|||
|
|
let beforeCmd= toArrayBuffer(Buffer.from([].concat([27, 64],printAlignCommand[align], [29, 118, 48, 0, xl, 0, xh, 0]), 'gb2312'))
|
|||
|
|
// 打印结束后的指令
|
|||
|
|
let afterCmd= toArrayBuffer(Buffer.from([].concat([27, 74, 3]), 'gb2312'))
|
|||
|
|
|
|||
|
|
|
|||
|
|
const cmds = [].concat(data);
|
|||
|
|
const buffer = toArrayBuffer(Buffer.from(cmds, 'gb2312'));
|
|||
|
|
|
|||
|
|
// console.log("打印图片最终buffer后==>",buffer);
|
|||
|
|
|
|||
|
|
|
|||
|
|
// 先给全局readyJobs 添加开始打印图片指令再添加 20字节一段的图片数据 再添加结束打印指令
|
|||
|
|
readyJobs.push(util.sendDirective([0x1B, 0x40]));
|
|||
|
|
readyJobs.push(beforeCmd);
|
|||
|
|
// 限制20字节
|
|||
|
|
for (let i = 0; i < buffer.byteLength; i = i + 20) { //限制输入数据
|
|||
|
|
readyJobs.push(buffer.slice(i, i + 20));
|
|||
|
|
}
|
|||
|
|
readyJobs.push(afterCmd);
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
},
|
|||
|
|
|
|||
|
|
// 异步打印 把数据按照切割好 异步发送
|
|||
|
|
async beforePrintClock() {
|
|||
|
|
|
|||
|
|
let that = this;
|
|||
|
|
// 必须要异步， 我看其它博主用的settimeout + for 循环最后发现其实就是同步的， 不用异步会断纸 因为打印机有缓存区 满了就断 不会打印了
|
|||
|
|
for (const iterator of readyJobs) {
|
|||
|
|
await new Promise(y=>{
|
|||
|
|
// 把打印指令发到打印机
|
|||
|
|
that.printBuffer(iterator,y)
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
},
|
|||
|
|
|
|||
|
|
|
|||
|
|
// 打印内容
|
|||
|
|
printBuffer(buffer,next) {
|
|||
|
|
console.log('任务索引',jobIdx)
|
|||
|
|
|
|||
|
|
// console.log("打印buffer size",buffer.byteLength)
|
|||
|
|
if (this.data.inactive.length == 0) {
|
|||
|
|
next(++jobIdx);
|
|||
|
|
return Dialog.alert({
|
|||
|
|
message: '当前并无连接打印机',
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
let {
|
|||
|
|
deviceId,
|
|||
|
|
serviceId,
|
|||
|
|
characteristicId
|
|||
|
|
} = this.data.inactive[0]
|
|||
|
|
wx.writeBLECharacteristicValue({
|
|||
|
|
deviceId: deviceId,
|
|||
|
|
serviceId: serviceId,
|
|||
|
|
characteristicId: characteristicId,
|
|||
|
|
value: buffer,
|
|||
|
|
success(res) {
|
|||
|
|
next(++jobIdx)
|
|||
|
|
},
|
|||
|
|
fail(err) {
|
|||
|
|
Dialog.alert({
|
|||
|
|
message: '错误码:[12550];蓝牙设备数据写入失败,' + JSON.stringify(err),
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
})
|
|||
|
|
},
|
|||
|
|
|
|||
|
|
// 转为黑白
|
|||
|
|
convert4to2(res) {
|
|||
|
|
let arr = []
|
|||
|
|
for (let i = 0; i < res.length; i++) {
|
|||
|
|
if (i % 4 == 0) {
|
|||
|
|
let rule = 0.29900 * res[i] + 0.58700 * res[i + 1] + 0.11400 * res[i + 2];
|
|||
|
|
if (rule > 200) {
|
|||
|
|
res[i] = 0;
|
|||
|
|
} else {
|
|||
|
|
res[i] = 1;
|
|||
|
|
}
|
|||
|
|
arr.push(res[i]);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return arr;
|
|||
|
|
},
|
|||
|
|
//8合1
|
|||
|
|
convert8to1(arr) {
|
|||
|
|
let data = [];
|
|||
|
|
for (let k = 0; k < arr.length; k += 8) {
|
|||
|
|
let temp = arr[k] * 128 + arr[k + 1] * 64 + arr[k + 2] * 32 + arr[k + 3] * 16 + arr[k + 4] * 8 + arr[k + 5] * 4 + arr[k + 6] * 2 + arr[k + 7] * 1
|
|||
|
|
data.push(temp);
|
|||
|
|
}
|
|||
|
|
return data;
|
|||
|
|
},
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
/*
|
|||
|
|
* 以下这些是连接打印机逻辑
|
|||
|
|
*
|
|||
|
|
*
|
|||
|
|
*
|
|||
|
|
*
|
|||
|
|
*/
|
|||
|
|
|
|||
|
|
// 打开蓝牙
|
|||
|
|
queryDeviceList(isShowEmit) {
|
|||
|
|
let that = this;
|
|||
|
|
// 先将设备断开
|
|||
|
|
this.focusDisDevice(() => {
|
|||
|
|
wx.openBluetoothAdapter({
|
|||
|
|
mode: "central",
|
|||
|
|
success(res) {
|
|||
|
|
console.log(res, "openBluetoothAdapter success");
|
|||
|
|
|
|||
|
|
that.reflush(isShowEmit)
|
|||
|
|
|
|||
|
|
},
|
|||
|
|
fail(err) {
|
|||
|
|
|
|||
|
|
Dialog.alert({
|
|||
|
|
message: '错误码:[10012];蓝牙适配器打开失败了,' + JSON.stringify(err),
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
|
|||
|
|
},
|
|||
|
|
})
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
|
|||
|
|
},
|
|||
|
|
// 断开设备
|
|||
|
|
disDevice() {
|
|||
|
|
Dialog.confirm({
|
|||
|
|
title: '提示',
|
|||
|
|
message: '你确定要断开该设备连接吗？',
|
|||
|
|
confirmButtonText: "断开"
|
|||
|
|
})
|
|||
|
|
.then(() => {
|
|||
|
|
this.focusDisDevice(() => {
|
|||
|
|
this.queryDeviceList()
|
|||
|
|
})
|
|||
|
|
})
|
|||
|
|
.catch(() => {});
|
|||
|
|
},
|
|||
|
|
//强制断开设备
|
|||
|
|
focusDisDevice(callback) {
|
|||
|
|
let that = this
|
|||
|
|
wx.closeBluetoothAdapter({
|
|||
|
|
success(closres) {
|
|||
|
|
console.log(closres, "closeBluetoothAdapter success");
|
|||
|
|
Notify({
|
|||
|
|
type: 'danger',
|
|||
|
|
message: '设备已断开'
|
|||
|
|
});
|
|||
|
|
that.setData({
|
|||
|
|
id: "",
|
|||
|
|
inactive: [],
|
|||
|
|
connectId: "",
|
|||
|
|
isConnect: false
|
|||
|
|
})
|
|||
|
|
if (callback) {
|
|||
|
|
callback()
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
},
|
|||
|
|
fail(err) {
|
|||
|
|
if (callback) {
|
|||
|
|
callback()
|
|||
|
|
}
|
|||
|
|
},
|
|||
|
|
complete() {
|
|||
|
|
console.log("closeBluetoothAdapter complete");
|
|||
|
|
}
|
|||
|
|
})
|
|||
|
|
},
|
|||
|
|
// 搜索设备，刷新列表
|
|||
|
|
reflush(isShowEmit) {
|
|||
|
|
console.log("搜索设备")
|
|||
|
|
let that = this
|
|||
|
|
wx.startBluetoothDevicesDiscovery({
|
|||
|
|
success(res) {
|
|||
|
|
if (firstOpenLoad || isShowEmit) {
|
|||
|
|
let history = wx.getStorageSync('historyLocalDevice')
|
|||
|
|
|
|||
|
|
if (history) {
|
|||
|
|
Notify({
|
|||
|
|
type: 'warning',
|
|||
|
|
message: '尝试重新连接设备'
|
|||
|
|
});
|
|||
|
|
that.setData({
|
|||
|
|
deviceList: [history]
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
that.concatDevice({}, history)
|
|||
|
|
} else {
|
|||
|
|
that.setData({
|
|||
|
|
deviceList: []
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
firstOpenLoad = false;
|
|||
|
|
}
|
|||
|
|
that.listennerNewDevice()
|
|||
|
|
},
|
|||
|
|
fail(res) {
|
|||
|
|
Dialog.alert({
|
|||
|
|
message: '错误码:[10173];蓝牙设备搜索失败了,' + JSON.stringify(err),
|
|||
|
|
})
|
|||
|
|
console.log("startBluetoothDevicesDiscovery失败", res)
|
|||
|
|
}
|
|||
|
|
})
|
|||
|
|
},
|
|||
|
|
//监听新设备
|
|||
|
|
listennerNewDevice() {
|
|||
|
|
let that = this
|
|||
|
|
wx.onBluetoothDeviceFound(function (res) {
|
|||
|
|
let devices = res.devices;
|
|||
|
|
console.log(res, "搜索设备")
|
|||
|
|
if (devices[0].name != '') {
|
|||
|
|
let list = that.data.deviceList
|
|||
|
|
// 当前设备在设备列表中是否存在 如果不存在则添加，存在则修改
|
|||
|
|
let idx = list.findIndex(de => {
|
|||
|
|
return de.deviceId == devices[0].deviceId
|
|||
|
|
})
|
|||
|
|
if (idx >= 0) {
|
|||
|
|
list[idx] = devices[0]
|
|||
|
|
} else {
|
|||
|
|
list.push(devices[0])
|
|||
|
|
}
|
|||
|
|
that.setData({
|
|||
|
|
deviceList: list,
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
})
|
|||
|
|
},
|
|||
|
|
// 连接设备
|
|||
|
|
concatDevice(item, history) {
|
|||
|
|
let that = this
|
|||
|
|
let device
|
|||
|
|
if (history) {
|
|||
|
|
device = history
|
|||
|
|
} else {
|
|||
|
|
device = item.currentTarget.dataset.item
|
|||
|
|
}
|
|||
|
|
wx.setStorageSync('historyLocalDevice', {
|
|||
|
|
...device
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
this.setData({
|
|||
|
|
connectId: device.deviceId,
|
|||
|
|
isConnect: true
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
wx.createBLEConnection({
|
|||
|
|
deviceId: device.deviceId,
|
|||
|
|
timeout: 4000,
|
|||
|
|
success(rse1) {
|
|||
|
|
wx.getBLEDeviceServices({
|
|||
|
|
deviceId: device.deviceId,
|
|||
|
|
complete(rse2) {
|
|||
|
|
if (rse2.errCode != 0) {
|
|||
|
|
|
|||
|
|
if (rse2.errCode == 10012) {
|
|||
|
|
Dialog.alert({
|
|||
|
|
message: '错误码:[18332];连接蓝牙超时,' + JSON.stringify(rse2),
|
|||
|
|
})
|
|||
|
|
that.setData({
|
|||
|
|
isConnect: false
|
|||
|
|
})
|
|||
|
|
} else {
|
|||
|
|
Dialog.alert({
|
|||
|
|
message: '错误码:[13332];连接蓝牙异常,' + JSON.stringify(rse2),
|
|||
|
|
})
|
|||
|
|
that.setData({
|
|||
|
|
isConnect: false
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
//查询特征值
|
|||
|
|
that.setData({
|
|||
|
|
inactive: []
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
for (let i in rse2.services) {
|
|||
|
|
wx.getBLEDeviceCharacteristics({
|
|||
|
|
deviceId: device.deviceId,
|
|||
|
|
serviceId: rse2.services[i].uuid,
|
|||
|
|
complete(rse3) {
|
|||
|
|
let arrService = []
|
|||
|
|
for (let j in rse3.characteristics) {
|
|||
|
|
if (rse3.characteristics[j].properties.write) {
|
|||
|
|
arrService.push({
|
|||
|
|
deviceId: device.deviceId,
|
|||
|
|
serviceId: rse2.services[i].uuid,
|
|||
|
|
characteristicId: rse3.characteristics[j].uuid,
|
|||
|
|
name: device.name
|
|||
|
|
})
|
|||
|
|
that.setData({
|
|||
|
|
inactive: arrService,
|
|||
|
|
id: device.deviceId,
|
|||
|
|
isConnect: false
|
|||
|
|
})
|
|||
|
|
Notify({
|
|||
|
|
type: 'success',
|
|||
|
|
message: '蓝牙连接成功'
|
|||
|
|
});
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
},
|
|||
|
|
fail(err) {
|
|||
|
|
Dialog.alert({
|
|||
|
|
message: '错误码:[11254];获取蓝牙设备特征值失败了,' + JSON.stringify(err),
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
},
|
|||
|
|
fail(err) {
|
|||
|
|
Dialog.alert({
|
|||
|
|
message: '错误码:[10288];获取蓝牙服务列表失败了,' + JSON.stringify(err),
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
})
|
|||
|
|
},
|
|||
|
|
fail(err) {
|
|||
|
|
|
|||
|
|
Dialog.alert({
|
|||
|
|
message: '错误码:[10233];与蓝牙设备创建连接失败了,' + JSON.stringify(err),
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
that.setData({
|
|||
|
|
isConnect: false
|
|||
|
|
})
|
|||
|
|
},
|
|||
|
|
complete() {
|
|||
|
|
// 停止搜索
|
|||
|
|
wx.stopBluetoothDevicesDiscovery({
|
|||
|
|
success() {}
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
})
|
|||
|
|
},
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
})
|