package com.test;


import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.Enumeration;
import java.util.TooManyListenersException;

import gnu.io.CommPortIdentifier;
import gnu.io.PortInUseException;
import gnu.io.SerialPort;
import gnu.io.SerialPortEvent;
import gnu.io.SerialPortEventListener;

/**
 * @項目名稱 :DSerialPort
 * @文件名稱 :SerialPort.java
 * @所在包 :org.serial
 * @功能描述 : 串口類
 * @修改記錄 :
 */
public class DSerialPort implements Runnable, SerialPortEventListener {

    private String appName = "串口通訊測試";
    private int timeout = 2000;// open 端口時的等待時間
    private int threadTime = 0;

    private CommPortIdentifier commPort;
    private SerialPort serialPort;
    private InputStream inputStream;
    private OutputStream outputStream;

    /**
     * @方法名稱 :listPort
     * @功能描述 :列出所有可用的串口
     * @返回值類型 :void
     */
    @SuppressWarnings("rawtypes")
    public void listPort() {
        CommPortIdentifier cpid;
        Enumeration en = CommPortIdentifier.getPortIdentifiers();

        System.out.println("now to list all Port of this PC：" + en);

        while (en.hasMoreElements()) {
            cpid = (CommPortIdentifier) en.nextElement();
            if (cpid.getPortType() == CommPortIdentifier.PORT_SERIAL) {
                System.out.println(cpid.getName() + ", " + cpid.getCurrentOwner());
            }
        }
    }

    /**
     * @方法名稱 :selectPort
     * @功能描述 :選擇一個端口，比如：COM1
     * @返回值類型 :void
     * @param portName
     */
    @SuppressWarnings("rawtypes")
    public void selectPort(String portName) {

        this.commPort = null;
        CommPortIdentifier cpid;
        Enumeration en = CommPortIdentifier.getPortIdentifiers();

        while (en.hasMoreElements()) {
            cpid = (CommPortIdentifier) en.nextElement();
            if (cpid.getPortType() == CommPortIdentifier.PORT_SERIAL && cpid.getName().equals(portName)) {
                this.commPort = cpid;
                break;
            }
        }

        openPort();
    }

    /**
     * @方法名稱 :openPort
     * @功能描述 :打開SerialPort
     * @返回值類型 :void
     */
    private void openPort() {
        if (commPort == null){
            log(String.format("無法找到名字為'%1$s'的串口！", commPort.getName()));}
        else {
            log("端口選擇成功，當(dāng)前端口：" + commPort.getName() + ",現(xiàn)在實例化 SerialPort:");

            try {
                serialPort = (SerialPort) commPort.open(appName, timeout);
                log("實例 SerialPort 成功！");
            } catch (PortInUseException e) {
                throw new RuntimeException(String.format("端口'%1$s'正在使用中！", commPort.getName()));
            }
        }
    }

    /**
     * @方法名稱 :checkPort
     * @功能描述 :檢查端口是否正確連接
     * @返回值類型 :void
     */
    private void checkPort() {
        if (commPort == null){
            throw new RuntimeException("沒有選擇端口，請使用 " + "selectPort(String portName) 方法選擇端口");}

        if (serialPort == null) {
            throw new RuntimeException("SerialPort 對象無效！");
        }
    }

    /**
     * @方法名稱 :write
     * @功能描述 :向端口發(fā)送數(shù)據(jù)，請在調(diào)用此方法前 先選擇端口，并確定SerialPort正常打開！
     * @返回值類型 :void
     * @param message
     */
    public void write(String message) {
        checkPort();

        try {
            outputStream = new BufferedOutputStream(serialPort.getOutputStream());
        } catch (IOException e) {
            throw new RuntimeException("獲取端口的OutputStream出錯：" + e.getMessage());
        }

        try {
            outputStream.write(message.getBytes("GBK"), 0, message.getBytes("GBK").length);
            //outputStream.write(message.getBytes());
            log("信息發(fā)送成功:"+new String(message.getBytes()));
        } catch (IOException e) {
            throw new RuntimeException("向端口發(fā)送信息時出錯：" + e.getMessage());
        } finally {
            try {
                outputStream.close();
            } catch (Exception e) {
            }
        }
    }

    /**
     * @方法名稱 :startRead
     * @功能描述 :開始監(jiān)聽從端口中接收的數(shù)據(jù)
     * @返回值類型 :void
     * @param time
     *            監(jiān)聽程序的存活時間，單位為秒，0 則是一直監(jiān)聽
     */
    public void startRead(int time) {
        checkPort();

        try {
            inputStream = new BufferedInputStream(serialPort.getInputStream());
        } catch (IOException e) {
            throw new RuntimeException("獲取端口的InputStream出錯：" + e.getMessage());
        }

        try {
            serialPort.addEventListener(this);
        } catch (TooManyListenersException e) {
            throw new RuntimeException(e.getMessage());
        }

        serialPort.notifyOnDataAvailable(true);

        log(String.format("開始監(jiān)聽來自'%1$s'的數(shù)據(jù)--------------", commPort.getName()));
        if (time > 0) {
            this.threadTime = time * 1000;
            Thread t = new Thread(this);
            t.start();
            log(String.format("監(jiān)聽程序?qū)⒃?1$d秒后關(guān)閉。。。。", threadTime));
        }
    }

    /**
     * @方法名稱 :close
     * @功能描述 :關(guān)閉 SerialPort
     * @返回值類型 :void
     */
    public void close() {
        serialPort.close();
        serialPort = null;
        commPort = null;
    }

    public void log(String msg) {
        System.out.println(appName + " --> " + msg);
    }

    /**
     * 數(shù)據(jù)接收的監(jiān)聽處理函數(shù)
     */
    @Override
    public void serialEvent(SerialPortEvent arg0) {
        switch (arg0.getEventType()) {
            case SerialPortEvent.BI:/* Break interrupt,通訊中斷 */
            case SerialPortEvent.OE:/* Overrun error，溢位錯誤 */
            case SerialPortEvent.FE:/* Framing error，傳幀錯誤 */
            case SerialPortEvent.PE:/* Parity error，校驗錯誤 */
            case SerialPortEvent.CD:/* Carrier detect，載波檢測 */
            case SerialPortEvent.CTS:/* Clear to send，清除發(fā)送 */
            case SerialPortEvent.DSR:/* Data set ready，數(shù)據(jù)設(shè)備就緒 */
            case SerialPortEvent.RI:/* Ring indicator，響鈴指示 */
            case SerialPortEvent.OUTPUT_BUFFER_EMPTY:/*
             * Output buffer is
             * empty，輸出緩沖區(qū)清空
             */
                break;
            case SerialPortEvent.DATA_AVAILABLE:/*
             * Data available at the serial
             * port，端口有可用數(shù)據(jù)。讀到緩沖數(shù)組，輸出到終端
             */
                byte[] readBuffer = new byte[1024];
                String readStr = "";
                String s2 = "";

                try {

                    while (inputStream.available() > 0) {
                        inputStream.read(readBuffer);
                        readStr += new String(readBuffer).trim();
                    }

                    s2 = new String(readBuffer).trim();

                    log("接收到端口返回數(shù)據(jù)(長度為" + readStr.length() + ")：" + readStr);
                    log(s2);
                } catch (IOException e) {
                }
        }
    }

    @Override
    public void run() {
        try {
            Thread.sleep(threadTime);
            serialPort.close();
            log(String.format("端口''監(jiān)聽關(guān)閉了！", commPort.getName()));
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        DSerialPort dp = new DSerialPort();
        dp.listPort();
        dp.selectPort("COM6");
        dp.write("tdgfg！");
        dp.startRead(30);


    }

}