package sp_comm;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.nio.ByteBuffer;
import java.util.Date;
import java.util.Enumeration;

import gnu.io.CommPortIdentifier;
import gnu.io.PortInUseException;
import gnu.io.SerialPort;
import gnu.io.UnsupportedCommOperationException;

import javax.swing.JComboBox;

import org.apache.logging.log4j.Logger;

import main.page_debug_inf;

import com.Com;
import com.ComFn;

public class CommSerialPort {
	public static int mutycomm_Type_Samd09	=	0;
	public static int mutycomm_Type_Msp430	=	1;
	public static int mutycomm_Type_SWM	=	2;
	// ¼ì²âϵͳÖпÉÓõÄͨѶ¶Ë¿ÚÀà
	private CommPortIdentifier portId;
	private Enumeration<CommPortIdentifier> portList;
	// RS-232µÄ´®ÐпÚ
	public SerialPort serialPort;
	public InputStream inputStream;
	public OutputStream outputStream;
	
	private int comm_bautrate = 9600;
	private Logger m_Log;
	
	public CommSerialPort(int bitrate, Logger log) {
		comm_bautrate = bitrate;
		m_Log = log;
	}
	
	public static void searchCommPort(JComboBox<String> cb_comm) {
		cb_comm.removeAllItems();
		@SuppressWarnings("unchecked")
		Enumeration<CommPortIdentifier> pl = CommPortIdentifier.getPortIdentifiers();
		while (pl.hasMoreElements()) {
			CommPortIdentifier port_id = pl.nextElement();
			if (port_id.getPortType() == CommPortIdentifier.PORT_SERIAL) {
				cb_comm.addItem(port_id.getName());
			}
		}
	}
	
	public void setCommBautrate(int bt_rate) {
		try {
			comm_bautrate = bt_rate;
			serialPort.setSerialPortParams(comm_bautrate, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE);
		} catch (UnsupportedCommOperationException e) {
			// TODO Auto-generated catch block
			//e.printStackTrace();
			m_Log.error(e.toString(), e);
		}
	}
	
	//³õʼ»¯´®¿Ú
	@SuppressWarnings("unchecked")
	public boolean OpenCommPort(String comm_name) {
		portList = CommPortIdentifier.getPortIdentifiers();
		while (portList.hasMoreElements()) {
			portId = portList.nextElement();
			if (portId.getPortType() == CommPortIdentifier.PORT_SERIAL) {
				if (portId.getName().equals(comm_name)) {
					try {
						serialPort = (SerialPort) portId.open("SerialPort-Test", 2000);
						//serialPort.addEventListener(new SPComm());
						serialPort.notifyOnDataAvailable(true);
						/* ÉèÖô®¿ÚͨѶ²ÎÊý */
						serialPort.setSerialPortParams(comm_bautrate, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE);
						outputStream = serialPort.getOutputStream();
						inputStream = serialPort.getInputStream();
					} catch (PortInUseException | UnsupportedCommOperationException | IOException e) {
						//e.printStackTrace();
						m_Log.error(e.toString(), e);
					} 
				}
			}
		}
		
		if(null == serialPort) {
			m_Log.info(comm_name + "²»´æÔÚ»òÕýÔÚʹÓÃÖÐ!");
			return false;
		} else {
			return true;
		}
	}
	
	/*********************************************************************************************/
	//Ïò´®¿Ú·¢ËÍÐÅÏ¢·½·¨
	private void sendMsg(ByteBuffer bbf_tx, int multy_comm_type,
						page_debug_inf dt_debug_inf, boolean printdat) throws IOException {
		byte[] bt_addr = new byte[1];
		if(mutycomm_Type_Msp430 == multy_comm_type) {
			bt_addr[0] = bbf_tx.get();
		}
		
		byte[] bt_dat = new byte[bbf_tx.remaining()];
		for(int n=0; n<bt_dat.length; n++) {
			bt_dat[n] = bbf_tx.get();
		}
		
		dt_debug_inf.addDebugInf(Com.get_DTF(new Date(), Com.DTF_YMDhms_S) + " TX: ");
		if(mutycomm_Type_SWM == multy_comm_type) {
			try {
				serialPort.setSerialPortParams(comm_bautrate, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_MARK);
			} catch (UnsupportedCommOperationException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		
		if(mutycomm_Type_Msp430 == multy_comm_type) {
			try {
				serialPort.setSerialPortParams(comm_bautrate, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_MARK);
			} catch (UnsupportedCommOperationException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			
			if(true == printdat) {
				dt_debug_inf.addDebugInf(ComFn.bytesToHexString(bt_addr, bt_addr.length));
			}
			outputStream.write(bt_addr);
			outputStream.flush();
			try {
				Thread.sleep(10);
			} catch (InterruptedException e1) {
				// TODO Auto-generated catch block
				e1.printStackTrace();
			}
			
			try {
				serialPort.setSerialPortParams(comm_bautrate, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_SPACE);
			} catch (UnsupportedCommOperationException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		
		if(true == printdat) {
			dt_debug_inf.addDebugInf(ComFn.bytesToHexString(bt_dat, bt_dat.length) + "\n");
		} else {
			dt_debug_inf.addDebugInf("******\n");
		}
		outputStream.write(bt_dat);
		outputStream.flush();
	}
	/*********************************************************************************************/
	private void readMsg(ByteBuffer bbf_rx, page_debug_inf dt_debug_inf, 
							boolean printdat) throws IOException, InterruptedException {
		bbf_rx.clear();
		int time_out = 0;
		byte[] rx_buf_t = new byte[2048];
		Date rx_time = null;
		while(true) {
			if(inputStream.available() > 0) {
				time_out = 0;
				int rx_cnt_t = inputStream.read(rx_buf_t);
				if((bbf_rx.position()+rx_cnt_t) < (bbf_rx.capacity()-1)) {
					bbf_rx.put(rx_buf_t, 0, rx_cnt_t);
					if(null == rx_time) {
						rx_time = new Date();
					}
				} else {
					break;
				}
			} else {
				Thread.sleep(1);
				time_out++;
				if(0 == bbf_rx.position()) {
					if(time_out > 500) {
						break;
					}
				} else {
					if(time_out >= 100) {
						break;
					}
				}
			}
		}
		bbf_rx.flip();
		
		byte[] bt_t_rx = new byte[bbf_rx.limit()];
		bbf_rx.get(bt_t_rx);
		if(null == rx_time) {
			rx_time = new Date();
		}
		if(true == printdat) {
			dt_debug_inf.addDebugInf(Com.get_DTF(rx_time, Com.DTF_YMDhms_S) 
					+ " RX: " + ComFn.bytesToHexString(bt_t_rx, bt_t_rx.length) + "\n");
		} else {
			dt_debug_inf.addDebugInf(Com.get_DTF(rx_time, Com.DTF_YMDhms_S) + " RX: ******\n");
		}
		bbf_rx.position(0);
	}
	/*********************************************************************************************/
	public void SP_Comm(ByteBuffer bbf_tx, ByteBuffer bbf_rx, int multy_comm,
							page_debug_inf dt_debug_inf, boolean printdat) {
		try {
			sendMsg(bbf_tx, multy_comm, dt_debug_inf, printdat);
			readMsg(bbf_rx, dt_debug_inf, printdat);
		} catch (IOException | InterruptedException e) {
			// TODO Auto-generated catch block
			//e.printStackTrace();
			m_Log.error(e.toString(), e);
		}
    }
	/*********************************************************************************************/
}