class SerialReader {
|
port;//串口
|
reader;//读取
|
inputDone;
|
|
constructor() {
|
if (!("serial" in navigator)) {
|
alert('当前浏览器不支持串口');
|
return;
|
}
|
this.filtersSweep = [
|
{ usbVendorId: 0x2341, usbProductId: 0x0043 },//指定显示的设备ID，好像只有USB接口才有
|
];//串口识别码-扫码机
|
}
|
|
//初始化
|
initSweepPrinter = async (baudRate, dataBits, stopBits, parity) => {
|
let requestOptions = { filters: this.filtersSweep };
|
|
this.port = await navigator.serial.requestPort(requestOptions);
|
|
await this.port.open({
|
baudRate: baudRate,// 一个正的、非零的值，表示串口通信应该建立的波特率
|
dataBits: dataBits,// 7或8的整数值，表示每帧的数据位数。默认值为8
|
stopBits: stopBits,// 1或2的整数值，表示帧结束时的停止位数。默认值为1。
|
parity: parity,// 奇偶校验模式为“none”、“偶”或“奇”。默认值为none。
|
bufferSize: 255, // 一个无符号长整数，指示要建立的读和写缓冲区的大小。如果未通过，默认值为255。
|
flowControl: 'none', // 流控制类型，“none”或“hardware”。默认值为none。
|
});
|
|
const decoder = new TextDecoderStream();
|
this.inputDone = this.port.readable.pipeTo(decoder.writable);
|
// this.reader = decoder.readable.pipeThrough(new TransformStream(new LineBreakTransformer())).getReader();//USB好像需要特殊处理,没有测试过
|
this.reader = decoder.readable.getReader();//显示器接头直接返回数据
|
|
console.log('连接成功');
|
|
return new Promise(async (resolve, reject) => {
|
while (true) {
|
const { value, done } = await this.reader.read();
|
if (value) {
|
$('#myForm').find("textarea[name='getMessageArea']").append(value)
|
console.log('扫码机数据 = ', value);
|
resolve(value);
|
}
|
if (done) {
|
this.reader.releaseLock();
|
break;
|
}
|
}
|
})
|
}
|
|
//断开
|
disconnect = async () => {
|
return new Promise(async (resolve, reject) => {
|
if (this.reader && this.port && this.inputDone) {
|
await this.reader.cancel();
|
await this.inputDone.catch(() => { });
|
this.reader = null;
|
this.inputDone = null;
|
await this.port.close();
|
this.port = null;
|
resolve();
|
}
|
})
|
}
|
}
|
