emis-frontend/src/utils/TanexPrinterSdk.js

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

  getPrinterList: 获取打印机列表
  getPrintTplList: 获取打印模版列表
  batchPrint:发送打印
  batchGetPDF:PDF预览和下载
  getPrinterVer:获取打印组件版本信息

  printerIsRead:打印机已经OK的信号

  updatePrintStatus: 打印状态更新


 */
import { getToken } from '@/utils/auth'

class TanexPrinterSdk {

    VERSION="1.0.0"
    MAX_SENT_RETRY_COUNT = 9;
    WS_URL = 'ws://'+process.env.VUE_APP_PRINTER_HOST+'/ws';
    HTTP_GET_PDF = 'http://'+process.env.VUE_APP_PRINTER_HOST+'/api/downPdfFile';

    // 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 =[];
    onBatchGetPDFCallback = [];

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

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

    // PDF文件缓存
    recievePdfFileList = []
    sendPdfFileListCount = 0
    pdfFileReceiveMap = new Map();
    recievePdfFileTimer = null;

    // 默认打印机
    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);
    }

    // 只支持一个事件响应
    setOnBatchGetPDF(callback){
      // this.onBatchGetPDFCallback.push(callback);
      this.onBatchGetPDFCallback=[];
      this.onBatchGetPDFCallback.push(callback);
    }

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

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

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

    // 获取pdf链接
    getPdfUrl(ydSn,tplName,printerName){
      return this.HTTP_GET_PDF + '?ydSn=' + ydSn+"&tplName="+tplName+"&printerName="+printerName;
    }

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


     // 批量获取PDF文件
     batchGetPDF(tplName,printerName,orderList,callback){
      if(tplName&&printerName&&orderList&&orderList.length>0){
        this.setOnBatchGetPDF(callback);
        // 超时计算

        this.sendBatchGetPDFCMD(tplName,printerName,orderList);
        this.recievePdfFileTimer = setTimeout(function(){
          if(this.onBatchGetPDFCallback){
            if(this.onBatchGetPDFCallback.length>0){
              this.onBatchGetPDFCallback.forEach(callback=>{
                if(callback!=null){
                  callback([],false,"打印超时");
                }
              })
            }
          }

          clearTimeout(this.recievePdfFileTimer);
        }, 6000)

      }
    }


    // 批量打印
    batchPrint(tplName,printerName,orderList){
      if(tplName&&printerName&&orderList&&orderList.length>0){
        this.sendBatchPrintCMD(tplName,printerName,orderList);
      }
    }


    //--内部方法--------------------------------------------------------------
    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);
      }
    }

    sendBatchGetPDFCMD(tplName,printerName,orderList){
      // {"CMD":"batchGetPDF","status":"1","Data":["DT20210901001","DT20210901002"]}
      var printCmd={};
      printCmd['CMD']="batchGetPDF";
      printCmd['Status']="1";
      if(orderList!=null && orderList.length>0){
        let printData={
           "tplName":tplName,
           "printerName":printerName,
           "orderList":orderList.toString()
        }

        this.recievePdfFileList = []
        this.sendPdfFileListCount = orderList.length;

        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=>{
                  if(callback!=null){
                    callback();
                  }
                })
              }
          }
          this.ws.onopen = () => {
              // console.log("ws onopen!");

              this.connected = true
              this.connectRetryCount = 0

              if(this.onOpenCallback.length>0){
                this.onOpenCallback.forEach(callback=>{
                  if(callback!=null){
                    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=>{
                if(callback!=null){
                  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=>{
                        if(callback!=null){
                          callback();
                        }
                      })
                    }

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


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


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

        } catch (ex) {
          // 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;
        })
      }
    }

    innerBatchGetPDF(msg){
      // console.log("innerBatchGetPDF")
      // console.log(msg)
      // 有出错，停止接收数据
      if(msg.Status!='2'){
        clearTimeout(this.recievePdfFileTimer);

        if(this.onBatchGetPDFCallback.length>0){
          this.onBatchGetPDFCallback.forEach(callback=>{
            if(callback!=null){
              callback([],false,msg.Data);
            }
          })
        }

        return;
      }


      if(this.recievePdfFileList.length<this.sendPdfFileListCount){
        if(msg){
          let ydSn=msg.Data.ydSn;
          if(ydSn in this.pdfFileReceiveMap){
            // 文件已存在则返回
            console.log(ydSn+"-PDF文件已存在");
            return;
          }

          this.recievePdfFileList.push(msg.Data.file);
          this.pdfFileReceiveMap[ydSn]=1;
        }
      }

      // 如果已相等则表示文件已接收完成
      if(this.recievePdfFileList.length >= this.sendPdfFileListCount){

        if(this.onBatchGetPDFCallback.length>0){
          this.onBatchGetPDFCallback.forEach(callback=>{
            if(callback!=null){
              clearTimeout(this.recievePdfFileTimer);
              // 把PDF文件传给终端处理
              callback(this.recievePdfFileList,true,"获取成功");

              // 发送完成后数据清空
              this.recievePdfFileList=[];
              this.pdfFileReceiveMap=new Map();
            }
          })
        }

        // console.log("文件已接收完成");
        return;
      }



    }




    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;