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();
            }
        })
    }
}