emis-frontend/src/utils/TanexPrinterSdk.js

'use strict'
import { download } from '@/utils/request'
/*
  TanexPrinterSdk

  getPrinterList: 获取打印机列表
  getPrintTplList: 获取打印模版列表
  batchPrint:发送打印
  getPrinterVer:获取打印组件版本信息

  printerIsRead:打印机已经OK的信号

  updatePrintStatus: 打印状态更新


 */
import { getToken } from '@/utils/auth'
import { forEach } from 'lodash';

class TanexPrinterSdk {

    VERSION="1.0.0"
    MAX_SENT_RETRY_COUNT = 9;
    // WS_URL = "ws://127.0.0.1:17080";
    // WS_URL = "ws://192.168.88.100:17080";
    WS_URL = "ws://192.168.88.100:17080/ws";
    HTTP_GET_PDF = "http://192.168.88.100:17080/api/downPdfFile";

    AUTH_TOKEN=null;

    WS_INIT = 0;
    WS_OPEN = 1;
    WS_CLOSING = 2;
    WS_CLOSE = 3;

    // 和服务端连接的socket对象
    ws = null;
    // WS 回调函数
    onOpenCallback =[];
    onCloseCallback=[];
    onErrorCallback =[];
    // onMessageCallback =[];

    onGetPrinterCallback =[];
    onGetPrintTplCallback =[];

    // 自定义 回调函数
    callbacks ={}

    // 打印机列表
    printerList = []
    // 打印模版列表
    printTplList = []

    // 默认打印机
    defaultPrinter = null;

    // 标识:是否连接成功 , 记录重试的次数,重新连接尝试的次数
    connected = false;
    printerIsRead = false;
    sendRetryCount = 0;
    connectRetryCount = 0;

    static instance = null;
    constructor() {
      this.instance = null
    }
    static getInstance() {
      if (!this.instance) {
          this.instance = new TanexPrinterSdk()
      }
      return this.instance
    }
    // 外部方法----------------------------------------------------------------
    init(onOpen,onClose,onError,onGetPrinter,onGetPrintTpl,OnGetPrintTpl){
      // 初始化参数建立连接
      this.token=getToken();
      this.connect();
      this.start();
    }

    setOnOpen(callback){
      this.onOpenCallback.push(callback);
    }

    setOnClose(callback){
      this.onCloseCallback.push(callback);
    }

    setOnError(callback){
      this.onErrorCallback.push(callback);
    }

    setOnGetPrinter(callback){
      this.onGetPrinterCallback.push(callback);
    }

    setOnGetPrintTpl(callback){
      this.onGetPrintTplCallback.push(callback);
    }

    // 获取打印机列表
    getPrinterTplList(){
      return this.printerList;
    }

    // 获取打印模版列表
    getPrintTplList(){
      return this.printTplList;
    }

    // 获取默认打印机
    getDefaultPrinter(){
      return this.defaultPrinter;
    }

    // 下载PDF文件
    downPdfFile(ydSn,tplName,printerName){
      let link = document.createElement('a');
      link.style.display = 'none';
      link.href = this.HTTP_GET_PDF + '?ydSn=' + ydSn+"&tplName="+tplName+"&printerName="+printerName;
      window.open(link.href, '_blank');
      // document.body.appendChild(link);
      // link.click();
    }


    //--内部方法--------------------------------------------------------------
    sendSetTokenCMD(){
      // {"CMD":"setToken","status":"1","Data":"token"}
      var printCmd={};
      printCmd['CMD']="setToken";
      printCmd['Status']="1";
      printCmd['Data']=getToken();
      console.log(JSON.stringify(printCmd));
      this.send(JSON.stringify(printCmd),null);
    }

    sendBatchPrintCMD(tplName,printerName,orderList){
      // {"CMD":"batchPrint","status":"1","Data":["DT20210901001","DT20210901002"]}
      var printCmd={};
      printCmd['CMD']="batchPrint";
      printCmd['Status']="1";
      if(orderList!=null && orderList.length>0){
        let printData={
           "tplName":tplName,
           "printerName":printerName,
           "orderList":orderList.toString()
        }
        printCmd['Data']=printData
        console.log(JSON.stringify(printCmd));
        this.send(JSON.stringify(printCmd),null);
      }
    }

    sendGetPrinterListCMD(){
      // {"CMD":"getPrinterList","status":"1","Data":""}
      var printCmd={};
      printCmd['CMD']="getPrinterList";
      printCmd['Status']="1";
      printCmd['Data']="";
      console.log(JSON.stringify(printCmd));
      this.send(JSON.stringify(printCmd),null);
    }

    sendGetPrintTplListCMD(){
      // {"CMD":"getPrintTplList","status":"1","Data":""}
      var printCmd={};
      printCmd['CMD']="getPrintTplList";
      printCmd['Status']="1";
      printCmd['Data']="";
      console.log(JSON.stringify(printCmd));
      this.send(JSON.stringify(printCmd),null);
    }


    // 连接服务器的方法
    connect() {
      // 连接服务器
      if (!window.WebSocket) {
          console.log('您的浏览器不支持WebSocket');
          return null;
      }

      if (!this.ws || this.getWSReadyState() === this.WS_CLOSING || this.getWSReadyState() === this.WS_CLOSE) {
        try {
          this.ws = new WebSocket(this.WS_URL);

          this.ws.onerror = () => {
              console.log("ws onerror!");
              if(this.onErrorCallback.length>0){
                this.onErrorCallback.forEach(callback=>{
                  callback();
                })
              }
          }
          this.ws.onopen = () => {
              console.log("ws onopen!");

              this.connected = true
              this.connectRetryCount = 0

              if(this.onOpenCallback.length>0){
                this.onOpenCallback.forEach(callback=>{
                  callback();
                })
              }

              this.sendSetTokenCMD();
              this.sendGetPrinterListCMD();
              this.sendGetPrintTplListCMD();
          };

          this.ws.onpong = () => {
            console.log("ws onpong!");
          }

          this.ws.onclose = () => {
            console.log("ws onclose!");

            this.connected = false;
            this.connectRetryCount++;

            if(this.onCloseCallback.length>0){
              this.onCloseCallback.forEach(callback=>{
                callback();
              })
            }

            setTimeout(() => {
               this.connect()
            }, 500 * this.connectRetryCount)
          };

          this.ws.onmessage = e => {
            console.log('ws onmessage:' + e.data)
            if (e.data.charAt(0) === "{") {
                var msg = this.jsonToObj(e.data);
                if(msg["CMD"]=='printerIsRead'){
                  printerIsRead=true;
                }
                else{

                  if(msg["CMD"]=='getPrinterList'){
                    this.innerGetPrinterList(msg)

                    if(this.onGetPrinterCallback.length>0){
                      this.onGetPrinterCallback.forEach(callback=>{
                        callback();
                      })
                    }

                  }
                  if(msg["CMD"]=='getPrintTplList'){
                    this.innerGetPrintTplList(msg)
                    if(this.onGetPrintTplCallback.length>0){
                      this.onGetPrintTplCallback.forEach(callback=>{
                        callback();
                      })
                    }
                  }


                  // 通知其他客户端
                  // if (this.callbacks[msg["CMD"]]) {
                  //   this.callbacks[msg["CMD"]](msg);
                  // }


              }
            } else {
                console.log("数据格式非法:" + e.data);
            }
          };

        } catch (ex) {
          debugger
          if (console && console.log) {
              console.log(ex);
          }

        }
      }

      return this.ws;
    }

    innerGetPrinterList(msg){
      console.log("innerGetPrinterList")
      if(msg){
        this.printerList=[];
        console.log(msg);

        msg.Data.printerList.forEach(item=>{
          let optionItem={
            label:item,
            value:item
          }
          this.printerList.push(optionItem);
          this.defaultPrinter=msg.Data.defaultPrinter;
        })
      }
    }

    innerGetPrintTplList(msg){
      console.log("innerGetPrintTplList")
      if(msg){
        this.printTplList=[];
        msg.Data.tplList.forEach(item=>{
          let optionItem={
            label:item,
            value:item
          }
          this.printTplList.push(optionItem);
          this.selTplName=this.printTplList[0].value;
        })
      }
    }


    jsonToObj(json){
      return JSON.parse(json)
    }

    objToJson(obj){
      return JSON.stringify(obj)
    }

    /**
     * readyState->0:尚未建立连接;1:已经建立连接;2:正在关闭;3:已经关闭或不可用
     * @param thisWs
     * @returns {*}
    */
    getWSReadyState() {
        if (this.ws.readyState !== undefined) {
            return this.ws.readyState;
        }
        return this.WS_INIT;
    };

    // 发送数据的方法
    send(data) {
        if (this.getWSReadyState()  === this.WS_OPEN ) {
            this.sendRetryCount = 0
            this.ws.send(data)
            return 1;
        } else {
            console.log("Ws is abnormal,send faild!!")
            return -1
        }
    }

    // 关闭socket连接
    close() {
        if (this.ws) {
            this.ws.close();
            this.connected = false; // 更新连接状态
            clearInterval(this.heartbeatInterval); // 清除心跳检测定时器
        }
    }
    // 开启心跳检测
    start() {
        this.heartbeatInterval = setInterval(() => {
            if (this.getWSReadyState()  === this.WS_OPEN ) {
              // this.ws.ping();
              this.ws.send(0x9);
            }
        }, 10000);
    }
}


export default TanexPrinterSdk;