package com.dev.nrf_lora_tester;

import gnu.io.SerialPort;
import gnu.io.UnsupportedCommOperationException;

import java.nio.ByteBuffer;
import java.nio.ByteOrder;
import java.util.ArrayList;
import java.util.Date;

import javax.swing.JOptionPane;

import org.apache.logging.log4j.Logger;

import sp_comm.CommSerialPort;
import sp_comm.Comm_Socket;
import main.page_debug_inf;

import com.Com;
import com.dev.ntm.cmd.NTM_Crc16;

public class SPCommLora implements Runnable/*, SerialPortEventListener*/ {
	public static final int COMM_PORT_TYPE_Serial = 0;
	public static final int COMM_PORT_TYPE_Socket = 1;
	
	public static final short CMD_Read_Data = 0x00A0;
	public static final short CMD_Set_ID = 0x00A2;
	public static final short CMD_Get_Ver = 0x00A4;
	public static final short CMD_Set_RFCH = 0x00A8;
	public static final short CMD_Cal_VolOffset = 0x00B1;
	public static final short CMD_Cal_VolSlope = 0x00B2;
	
	private CommSerialPort m_SP_Comm = null;
	private Comm_Socket m_SocketComm = null;
	public ArrayList<LoraModuleData> alLoraData = new ArrayList<LoraModuleData>(0);
	public int[] m_SetModuleRFCH = new int[300];
	public boolean CommThreadRunning = false;
	private ByteBuffer CommRxBuffer = null; 
	private ByteBuffer CommTxBuffer = null;
	
	public short comm_tx_cnt = 0;
	public short comm_rx_cnt = 0;
	
	public int dt_target_addr = 0;
	public int dt_target_ver = 0;
	public int dt_target_ver2 = 0;
	public int dt_target_ver3 = 0;
	
	public int lora_start_addr = 1;
	public int lora_module_cnt = 2;
	public int lora_rf_ch_start = 0x17;
	public int lora_rf_ch = lora_rf_ch_start;
	public int lora_comm_time = 200;
	private int lora_comm_time_origin = 200;
	private int m_comm_error_count = 0;
	
	private short dt_usr_cmd = 0;
	private short dt_usr_cmd_data = 0;
	
	private boolean dt_normal_comm_en = true;
	int dt_multy_comm_type = CommSerialPort.mutycomm_Type_Samd09;
	
	private page_debug_inf dt_debug_inf;
	private int m_COMM_PORT_TYPE = 0;
	
	private Logger m_Log = null;
	
	public SPCommLora(int startaddr_t, int module_cnt, int rf_ch, int comm_time,
						int bitrate, int multy_com_type, page_debug_inf debug, Logger log) {
		
		lora_start_addr = startaddr_t & 0xFFFF;
		dt_target_addr = lora_start_addr;
		lora_module_cnt = module_cnt;
		lora_rf_ch_start = rf_ch;
		lora_comm_time = comm_time/module_cnt;
		if(lora_comm_time < 50) {
			lora_comm_time = 50;
		}
		lora_comm_time_origin = lora_comm_time;
		
		dt_multy_comm_type = multy_com_type;
		dt_debug_inf = debug;
		
		if(lora_module_cnt < 1) {
			lora_module_cnt = 1;
		}
		if(lora_module_cnt > 80) {
			lora_module_cnt = 80;
		}
		for(int n=0; n<(lora_module_cnt+2); n++) {
			alLoraData.add(new LoraModuleData());
		}
		
		m_Log = log;
	}
	
	public void clearSetModuleRFCH() {
		for(int n=0; n<m_SetModuleRFCH.length; n++) {
			m_SetModuleRFCH[n] = 0;
		}
	}
	
	public void setCommBautrate(int bt_rate) {
		if(COMM_PORT_TYPE_Serial != m_COMM_PORT_TYPE) {
			return;
		}
		
		try {
			m_SP_Comm.serialPort.setSerialPortParams(bt_rate, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE);
		} catch (UnsupportedCommOperationException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
	//³õʼ»¯´®¿Ú
	public boolean OpenCommPort(int comm_port_type, String comm_name_or_ip, int bitrate_or_comm_port) {
		boolean res = false;
		m_COMM_PORT_TYPE = comm_port_type;
		if(COMM_PORT_TYPE_Serial == m_COMM_PORT_TYPE) {
			m_SP_Comm = new CommSerialPort(bitrate_or_comm_port, m_Log);
			res = m_SP_Comm.OpenCommPort(comm_name_or_ip);
		} else {
			m_SocketComm = new Comm_Socket(comm_name_or_ip, bitrate_or_comm_port);
			res = true;
		}
		
		if(true == res) {
			CommTxBuffer = ByteBuffer.allocate(120);
			CommRxBuffer = ByteBuffer.allocate(120);
			CommTxBuffer.order(ByteOrder.LITTLE_ENDIAN);
			CommRxBuffer.order(ByteOrder.LITTLE_ENDIAN);
			
			comm_tx_cnt = 0;
			comm_rx_cnt = 0;
			CommThreadRunning = true;
		}
		
		return res;
	}
	
	public void setCommErrCnt(int val) {
		m_comm_error_count = val;
	}
	public int getCommErrCnt() {
		return m_comm_error_count;
	}
	
	public void setModuleCommTimeout(int t_out) {
		lora_comm_time = t_out;
		if(lora_comm_time < 50) {
			lora_comm_time = 50;
		}
	}
	public void setModuleCommTimeoutToOrigin() {
		lora_comm_time = lora_comm_time_origin;
	}
	
	private int makeCommTxData() {
		int a_tar_addr = 0;
		CommTxBuffer.clear();
		
		ByteBuffer tmp_bf = ByteBuffer.allocate(64);
		tmp_bf.order(ByteOrder.LITTLE_ENDIAN);
		
		{
			a_tar_addr = dt_target_addr;
			dt_target_addr += 1;
			if(dt_target_addr >= (lora_module_cnt+lora_start_addr)) {
				dt_target_addr = lora_start_addr;
			}
			
			CommTxBuffer.put((byte) ((a_tar_addr>>8)&0xFF));
			CommTxBuffer.put((byte) (a_tar_addr&0xFF));
			lora_rf_ch = a_tar_addr+lora_rf_ch_start;
			if(lora_rf_ch > 0) {
				lora_rf_ch -= 1;
			}
			CommTxBuffer.put((byte) (lora_rf_ch&0xFF));
			
			int index = a_tar_addr-lora_start_addr;
    		if(index < 0) {
    			index = 0;
    		}
			LoraModuleData lrData = alLoraData.get(index%alLoraData.size());
			lrData.tx_cnt += 1;
			
			short cmd = CMD_Read_Data;
			if(0 == dt_target_ver) {
				cmd = CMD_Get_Ver;
			}
			if(dt_usr_cmd > CMD_Read_Data) {
				cmd = dt_usr_cmd;
				dt_usr_cmd = CMD_Read_Data;
			}
			
			tmp_bf.put((byte) 0xAB);
			tmp_bf.put((byte) 0xCD);
			tmp_bf.put((byte) 0x52);//ÉÏλ»úµ÷ÊÔÈí¼þ¹Ì¶¨ÎªµÚ82 loraÐŵÀ
			tmp_bf.put((byte) 0xF0);
			tmp_bf.putShort(cmd);
			
			if((CMD_Read_Data==cmd) || (CMD_Get_Ver==cmd)) {
				for(int n=0; n<4; n++) {
					tmp_bf.putShort((short) 0x00);
				}
			} else {
				switch(cmd) {
					case CMD_Set_ID:
					case CMD_Set_RFCH: {
						tmp_bf.putShort((short) 0xCDAB);
						tmp_bf.putShort((short) ((dt_usr_cmd_data<<8) | (dt_usr_cmd_data>>8)));
						tmp_bf.putShort((short) 0x00);
						tmp_bf.putShort((short) 0x00);
					}
					break;
					
					case CMD_Cal_VolOffset:
					case CMD_Cal_VolSlope: {
						tmp_bf.putShort((short) (dt_usr_cmd_data));
						tmp_bf.putShort((short) 0x00);
						tmp_bf.putShort((short) 0x00);
						tmp_bf.putShort((short) 0x00);
					}
					break;
				}
			}
		} 
		
		int crc = NTM_Crc16.CalCRC16(tmp_bf, tmp_bf.position()) & 0xFFFF;
		tmp_bf.putShort((short)crc);
		tmp_bf.flip();
		CommTxBuffer.put(tmp_bf);
		
		CommTxBuffer.flip();
		
		return a_tar_addr;
	}
	
	private boolean checkCommBuf(ByteBuffer buf_t) {
		boolean res = false;
		if(buf_t.limit() >= 5) {
			buf_t.position(buf_t.limit()-2);
			int crc = buf_t.getShort() & 0xFFFF;
			//crc = ((crc>>8)|(crc<<8)) & 0xFFFF;
			int crc_cal = NTM_Crc16.CalCRC16(buf_t, buf_t.limit()-2) & 0xFFFF;
			
			/*************************************************/
			if(crc_cal == crc) {
				res = true;
			}
			/*************************************************/
		} else {
			res = false;
		}
		
		return res;
	}
	
	public void tr_Msg(ByteBuffer bbf_tx, ByteBuffer bbf_rx, boolean showdat) {
		if(++comm_tx_cnt > 32500) {
	    	comm_tx_cnt = 0;
	    }
		if(COMM_PORT_TYPE_Serial == m_COMM_PORT_TYPE) {
			m_SP_Comm.SP_Comm(bbf_tx, bbf_rx, dt_multy_comm_type, dt_debug_inf, showdat);
		} else {
			m_SocketComm.SocketComm(bbf_tx, bbf_rx, dt_debug_inf, showdat);
		}
	}
	
	private void closeCommPort() {
		if(COMM_PORT_TYPE_Serial == m_COMM_PORT_TYPE) {
			m_SP_Comm.serialPort.close();
		} else {
			m_SocketComm.socketClose();
		}
	}
	
	public void exitCommPortThread() {
		CommThreadRunning = false;
	}
	
	public void setCommCmd(short cmd, short cmd_data) {
		dt_usr_cmd = cmd;
		dt_usr_cmd_data = cmd_data;
	}
	
	public void setNormalCommState(boolean stat) {
		dt_normal_comm_en = stat;
	}
	
	public void setModule_Addr_Count(int addr, int rfch, int cnt) {
		lora_start_addr = addr & 0xFFFF;
		dt_target_addr = lora_start_addr;
		
		lora_rf_ch_start = rfch;
		lora_rf_ch = lora_rf_ch_start;
		
		lora_module_cnt = cnt;
	}
	
	private void processRxData(ByteBuffer bbf_rx, int start_addr, int soruce_addr) {
		if(false == checkCommBuf(bbf_rx)) {
			if(m_comm_error_count < 100) {
				m_comm_error_count += 1;
			}
			if((1==lora_module_cnt) && (m_comm_error_count>=3)) {
				dt_target_ver = 0;
			}
			
			return;
		}
		@SuppressWarnings("unused")
		byte ab,cd;
		if(bbf_rx.limit() > 12) {
			bbf_rx.position(0);
			ab = bbf_rx.get();
    		cd = bbf_rx.get();
    		short addr = (short) (bbf_rx.getShort()&0xFFFF);
    		addr = (short) ((addr>>8) | (addr<<8));
    		short cmd = (short) (bbf_rx.getShort()&0xFFFF);
    		
    		int index = addr-start_addr;
    		if(index >= 0) {
    			LoraModuleData lrData = alLoraData.get(index%alLoraData.size());
        		if((SPCommLora.CMD_Read_Data == cmd) && (soruce_addr == addr)) {
            		for(int n=0; n<4; n++) {
            			int dat = bbf_rx.getShort()&0xFFFF;
            			//dat = (short) ((dat>>8)|(dat<<8));
            			lrData.vol[n] = ((float)(dat&0xFFFF)) / 1000;
            		}
            		lrData.rx_cnt += 1;
        		} else if((SPCommLora.CMD_Get_Ver == cmd) && (soruce_addr == addr)) {
        			dt_target_ver = bbf_rx.getShort()&0xFFFF;
        			dt_target_ver2 = bbf_rx.getShort()&0xFFFF;
        			dt_target_ver3 = bbf_rx.getShort()&0xFFFF;
        			lrData.rx_cnt += 1;
        		}
    		}
    		
    		if(SPCommLora.CMD_Set_RFCH == cmd) {
    			m_SetModuleRFCH[addr] = SPCommLora.CMD_Set_RFCH;
    		} else if(SPCommLora.CMD_Set_ID == cmd) {
    			m_SetModuleRFCH[0] = SPCommLora.CMD_Set_ID;
    		}
    		
    		if(++comm_rx_cnt > 32500) {
		    	comm_rx_cnt = 0;
		    }
    		m_comm_error_count = 0;
		}
	}
	
	public void run() {
		while(true == CommThreadRunning) {
			try {
				if(false == dt_normal_comm_en) {
					Thread.sleep(100);
					continue;
				}
				
				//---------------------- make tx data --------------------------//
				int tar_addr = makeCommTxData();
				//----------------------- tx rx data ---------------------------//
				tr_Msg(CommTxBuffer, CommRxBuffer, true);
				//----------------------- process data -------------------------//
				processRxData(CommRxBuffer, lora_start_addr, tar_addr);
				//-------------------------------------------------------------//
				
	    		Thread.sleep(lora_comm_time);
	    	} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
				exitCommPortThread();
				JOptionPane.showMessageDialog(null, "Monomer CommPort ´®¿ÚÒì³£: " + e.getMessage());
			}
		}
		/******************************************************************************/
		closeCommPort();
		/******************************************************************************/
		dt_debug_inf.addDebugInf(Com.get_DTF(new Date(), Com.DTF_YMDhms_S) 
									+ " CommPort is quit"
									+ ", COMM_PORT_TYPE: " + m_COMM_PORT_TYPE + "\n");
		/******************************************************************************/
    }
}