package com.power.spcomm;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.nio.ByteBuffer;
import java.util.ArrayList;
import java.util.Date;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import com.power.alarm.Alarm_Config;
import com.power.alarm.Alarm_Config_SQL;
import com.power.mysql.MysqlConnPool;

public class SocketClientComm_Thread extends Thread {
	
	Logger logger = LogManager.getLogger(SPCommModule.class);
	
	private Socket socketClient;
	private InputStream inData;
	private OutputStream outData;
	
	private MysqlConnPool m_Conn_Pool;
	
	private int Alarm_way;
	
	private Alarm_Config Alarm_config;
	
	private boolean socketCommOK = false;
	
	private ByteBuffer CommRxBuffer = ByteBuffer.allocate(512); 
	
	private ArrayList<String> phoneNumList = new ArrayList<String>();
	private ArrayList<Integer> devIdList = new ArrayList<Integer>();
	
	
	public Date last_Alarm_Time = null; 
	public Date sms_AlarmCheck_Time = null;
	
	
	public SocketClientComm_Thread(MysqlConnPool pool,int alarm_way) {
		m_Conn_Pool = pool;
		
		Alarm_way = alarm_way;
		
	}
	
	public void readMsg(ByteBuffer bbf_rx) {
		
		if(false == socketCommOK)
			return;
		
		bbf_rx.clear();
		int time_out = 0;
		byte[] rx_buf_t = new byte[512];
		
		try {
			while(true) {
				if(inData.available() > 0) {
					time_out = 0;
					int rx_cnt_t = inData.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);
					} else {
						break;
					}
				} else {
					sleep(5);
					time_out++;
					if(0 == bbf_rx.position()) {
						if(time_out >= 2000) {
							break;
						}
					} else {
						if(time_out >= 5) {
							break;
						}
					}
				}
			}
			
			bbf_rx.flip();
		}
		catch(Exception e)  {
			logger.error(e.toString(), e);
			
			try {
				inData.close();
				outData.close();
				socketClient.close();
			}catch(Exception e1) {
				logger.error(e1.toString(), e1);
			}
			
			socketCommOK = false;
		}
	}
	
	private boolean sendShortMessage(String phonenumber) {
		
		logger.info("****************** sendShortMessage ***********");
		
		boolean send_success = false;
		
		if(false == socketCommOK)
			return send_success;
		
		String msg_str = "86" + phonenumber + ":0:" + Alarm_config.SMS_Alarm_Text;
		
		try {
			outData.write(msg_str.getBytes("GBK"),0,msg_str.getBytes("GBK").length);
			outData.flush();
		}catch (Exception e) {
			logger.error(e.toString(), e);
			
			try {
				inData.close();
				outData.close();
				socketClient.close();
			}catch(Exception e1) {
				logger.error(e1.toString(), e1);
			}
			
			socketCommOK = false;
		}
		
		readMsg(CommRxBuffer);
		
		String rx_str = null;
		
		CommRxBuffer.position(0);
		
		byte[] bt_dat = new byte[CommRxBuffer.remaining()];
		
		for(int n=0; n<bt_dat.length; n++) {
			bt_dat[n] = CommRxBuffer.get();	
		}
		
		rx_str = new String(bt_dat);
			
		//logger.info("Recv Message: " + rx_str);

		if(rx_str.contains("SMS_SEND_SUCESS")) {
			send_success = true;
			logger.info("SMS_SEND_SUCESS");
		}
		else if(rx_str.contains("SMS_SEND_FAIL")) {
			logger.info("SMS_SEND_FAIL");
		}
		else {
			logger.info("Unkwon return text...");
		}
		
		return send_success;
	}
	
	private void buzzerBeepAndLedOn() { //´ò¿ª µÆ ºÍ  ÉùÒô
		byte[] bt_dat = new byte[8];
		
		bt_dat[0] = 0x7E;
		bt_dat[1] = (byte)0xFF;
		bt_dat[2] = 0x06;
		bt_dat[3] = 0x3A;
		bt_dat[4] = 0x00;
		
		bt_dat[5] = 0x01;
		bt_dat[6] = 0x00;
		
		bt_dat[7] = (byte)0xEF;
		
		try {
			outData.write(bt_dat,0,8);
			outData.flush();
		}catch (Exception e) {
			logger.error(e.toString(), e);
			
			try {
				inData.close();
				outData.close();
				socketClient.close();
			}catch(Exception e1) {
				logger.error(e1.toString(), e1);
			}
			
			socketCommOK = false;
		}
	}
	
	private void turnOffBuzzerBeep() { //¹Ø±Õ  ÉùÒô£¬ ±£Áô  µÆ
		byte[] bt_dat = new byte[8];
		
		bt_dat[0] = 0x7E;
		bt_dat[1] = (byte)0xFF;
		bt_dat[2] = 0x06;
		bt_dat[3] = 0x3A;
		bt_dat[4] = 0x00;
		
		bt_dat[5] = 0x00;
		bt_dat[6] = 0x00;
		
		bt_dat[7] = (byte)0xEF;
		
		try {
			outData.write(bt_dat,0,8);
			outData.flush();
		}catch (Exception e) {
			logger.error(e.toString(), e);
			
			try {
				inData.close();
				outData.close();
				socketClient.close();
			}catch(Exception e1) {
				logger.error(e1.toString(), e1);
			}
			
			socketCommOK = false;
		}		
	}
	
	private void turnOffBuzzerAndLed() {  //¹Ø±Õ  ÉùÒô ºÍ µÆ
		byte[] bt_dat = new byte[8];
		
		bt_dat[0] = 0x7E;
		bt_dat[1] = (byte)0xFF;
		bt_dat[2] = 0x06;
		bt_dat[3] = 0x3A;
		bt_dat[4] = 0x00;
		
		bt_dat[5] = 0x00;
		bt_dat[6] = 0x01;
		
		bt_dat[7] = (byte)0xEF;
		
		try {
			outData.write(bt_dat,0,8);
			outData.flush();
		}catch (Exception e) {
			logger.error(e.toString(), e);
			
			try {
				inData.close();
				outData.close();
				socketClient.close();
			}catch(Exception e1) {
				logger.error(e1.toString(), e1);
			}
			
			socketCommOK = false;
		}	
	}
	
	private void query_phone_number() {
		//String ph = "18627009360";
		
		//phoneNumList.clear();
		
		//phoneNumList.add(ph);
		
		Alarm_Config_SQL.query_phonenumber_SQL(m_Conn_Pool, devIdList, phoneNumList);
	}
	
	@Override
	public void run() {
		
		socketCommOK = false;
		
		last_Alarm_Time = new Date();
		sms_AlarmCheck_Time = new Date();
		
		for(int i=0;i<60;i++) {
			try {
				Thread.sleep(1000);
			} catch (InterruptedException e) {
				logger.error(e.toString(), e);
			}
		}
		
		if(Alarm_Config.ALARM_WAY_BEEPER==Alarm_way) {
			logger.info("Beeper Alarm Thread Start....");
		}
		else {
			logger.info("SMS Alarm Thread Start....");
		}
		
		if(Alarm_Config.ALARM_WAY_SMS == Alarm_way) {
			
			boolean new_alarm_exists = false;
			
			while(true) {
				long timelong =((new Date()).getTime()-sms_AlarmCheck_Time.getTime())/1000;
				
				if(timelong >= 60) { //60 seconds
					
					sms_AlarmCheck_Time = new Date();
					
					new_alarm_exists = Alarm_Config_SQL.check_if_new_alarm(m_Conn_Pool, last_Alarm_Time,devIdList);
				}
				
				if(new_alarm_exists) {
					
					Alarm_config = Alarm_Config_SQL.query_alarm_config(m_Conn_Pool);
					
					if(Alarm_config.SMS_Alarm_EN>0) {
						
						if(false == socketCommOK) {
							
							try {
								socketClient = new Socket();
								socketClient.connect(new InetSocketAddress(Alarm_config.AlarmDevIP, Alarm_config.SMS_Alarm_ipPort), 3000);
							
								if(socketClient.isConnected()) {
									
						        	inData = socketClient.getInputStream();
							        outData = socketClient.getOutputStream();
							        
							        socketCommOK = true;
								}
							}catch (IOException e) {
								logger.error("SMS socket error...");
							}
						}
						
						if(socketCommOK) {
							
							last_Alarm_Time = new Date();
							new_alarm_exists = false;
							
							query_phone_number();
							
							for(int i=0;i<phoneNumList.size();i++) {
								if(sendShortMessage(phoneNumList.get(i)) == false) {
									try {
										Thread.sleep(20000); //·¢ËͶÌÐÅʧ°Ü£¬20SºóÔÙ¼ÌÐø
									} catch (InterruptedException e) {
										logger.error(e.toString(), e);
									}
									
									sendShortMessage(phoneNumList.get(i));
								}
								
								if(false == socketCommOK)
									break;
							}
						}
					}
				}
				
				try {
					Thread.sleep(1000);
				} catch (InterruptedException e) {
					logger.error(e.toString(), e);
				}	
			}
		}
		else if(Alarm_Config.ALARM_WAY_BEEPER == Alarm_way) {
			
			boolean alarm_exists = false;
			
			while(true) {
				
				alarm_exists = Alarm_Config_SQL.check_if_alarm_exists(m_Conn_Pool);
				
				
				Alarm_config = Alarm_Config_SQL.query_alarm_config(m_Conn_Pool);
				
				//logger.info("Alarm_config.AlarmDevIP, Alarm_config.Beeper_Alarm_ipPort"+Alarm_config.AlarmDevIP+"---"+ Alarm_config.Beeper_Alarm_ipPort);
				
				/*if(alarm_exists)*/ {
					
					if(false == socketCommOK) {
						
						try {
							socketClient = new Socket();
							socketClient.connect(new InetSocketAddress(Alarm_config.AlarmDevIP, Alarm_config.Beeper_Alarm_ipPort), 3000);
						
							//logger.info("Alarm_config.AlarmDevIP, Alarm_config.Beeper_Alarm_ipPort"+Alarm_config.AlarmDevIP+"---"+ Alarm_config.Beeper_Alarm_ipPort);

							
							if(socketClient.isConnected()) {
								
					        	inData = socketClient.getInputStream();
						        outData = socketClient.getOutputStream();
						        
						        socketCommOK = true;
							}
						}catch (IOException e) {
							logger.error("Beeper socket error...");
						}
					}
					
					//Alarm_config = Alarm_Config_SQL.query_alarm_config(m_Conn_Pool);
				
					if(Alarm_config.Beeper_Alarm_EN>0) {
					
						/*
						if(false == socketCommOK) {
								
							try {
								socketClient = new Socket();
								socketClient.connect(new InetSocketAddress(Alarm_config.AlarmDevIP, Alarm_config.Beeper_Alarm_ipPort), 3000);
							
								if(socketClient.isConnected()) {
									
						        	inData = socketClient.getInputStream();
							        outData = socketClient.getOutputStream();
							        
							        socketCommOK = true;
								}
							}catch (IOException e) {
								logger.error("Beeper socket error...");
							}
						}
						*/
						
						if(socketCommOK) {
							
							if(alarm_exists) {
								if(Alarm_config.Beeper_Sound_OFF>0) {
									//¹Ø±ÕÉùÒô£¬±£ÁôµÆ
									turnOffBuzzerBeep();
								}
								else {
									//´ò¿ªÉùÒôºÍµÆ
									buzzerBeepAndLedOn();
								}
							}
							else {
								turnOffBuzzerAndLed();
							}
						}
					}
					else {
						if(socketCommOK) {
							//¹Ø±ÕÉùÒôºÍµÆ
							turnOffBuzzerAndLed();
						}
					}
				}
				
				try {
					Thread.sleep(5000);
				} catch (InterruptedException e) {
					logger.error(e.toString(), e);
				}
			}
		}
		
		
	}
}