package com.data;

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

import com.base.ComFn;
import com.dev.base.data.Dynamicload_button;
import com.dev.base.data.Dynamicload_control;
import com.dev.base.data.Dynamicload_inf;
import com.dev.base.data.Dynamicload_state;
import com.modbus.util.BaseData;
import com.modbus.util.Modbus_ComBase;
import com.sql.MysqlConnPool;

public class PowerArk_SocketCliet_Thread implements Runnable{
	public static final int CONTROL_ON = 1;
	public static final int CONTROL_OFF = 0;
	
	private ByteBuffer bytebuffer_for_socket_RX = ByteBuffer.allocate(1500);
	public static int PowerArk_Port = 502;
	public String   dev_ip;
	public MysqlConnPool conn_pool;
	public Dynamicload_inf dyna_inf;
	public Dynamicload_button button;			//É豸°´Å¥
	public Dynamicload_control control;			//É豸¿ØÖÆ
	public Dynamicload_state state;				//É豸״̬
	public int connerrCount = 0;				//×Ü´íÎó¼ÆÊý		
	public int connCount = 0;					//×ÜͨѶ¼ÆÊý
	public int errCount = 0;					//Á¬Ðø´íÎóͨѶ¼ÆÊý
	public Socket socket;
	public BaseData basedata;
	
	
	public PowerArk_SocketCliet_Thread(MysqlConnPool conn_pool,Dynamicload_inf dyna_inf) {
		this.conn_pool = conn_pool;
		this.dyna_inf = dyna_inf;
		
		dev_ip = dyna_inf.dev_ip;
		button = dyna_inf.button;
		control = dyna_inf.control;
		state = dyna_inf.state;		
	}
	
	
	@Override
	public void run() {	
		int run_count = 0;
		while(true) {
			try {
				/******************************************  ¶Á״̬   **********************************************/
				/******************************************  ¶Á״̬   **********************************************/
				{
					if(run_count % 10 == 0) {					
						//¶ÁÈ¡·´À¡ÐÅÏ¢0x4013-0x4030ÐÅÏ¢
						basedata = new BaseData(Modbus_ComBase.READ_COIL_STATUS, Modbus_ComBase.OverTmp_Start_Addr, 18);
						if(SocketComm(basedata.createReadData(), socket)) {
							//¶ÁÈ¡·´À¡ÐÅÏ¢³É¹¦
							PowerArk_ServerSocket_Thread_SQL.updateDynamicload_StateTable(conn_pool, state);
						}
					}
					
					if(run_count % 9 == 0) {
						//¶Áȡ״̬ÐÅÏ¢      0x01-0x12
						basedata = new BaseData(Modbus_ComBase.READ_COIL_STATUS, Modbus_ComBase.AutoProcess1_Start_Addr, 12);
						if(SocketComm(basedata.createReadData(), socket)) {
							//MÇø״̬³É¹¦ 
							PowerArk_ServerSocket_Thread_SQL.updateDynamicload_StateTable(conn_pool, state);
						}
					}
					
					if(run_count % 8 == 0) {
						//¶Áȡ״̬ÐÅÏ¢      0x8000-8013
						basedata = new BaseData(Modbus_ComBase.READ_COIL_STATUS, Modbus_ComBase.ButtonOutPut_Start_Addr, 14);
						if(SocketComm(basedata.createReadData(), socket)) {
							//¶ÁÈ¡QÇø״̬³É¹¦ 
							PowerArk_ServerSocket_Thread_SQL.updateDynamicload_ButtonTable(conn_pool, button);
						}
					}
					
					if(run_count % 10 ==0 ) {
						//¶ÁÈ¡¸÷¸ö°´Å¥×´Ì¬  0x40-x0160
						basedata = new BaseData(Modbus_ComBase.READ_COIL_STATUS, Modbus_ComBase.LocalControl_Start_Addr, 121);
						if(SocketComm(basedata.createReadData(), socket)) {
							//¶ÁÈ¡QÇø״̬³É¹¦ 
							PowerArk_ServerSocket_Thread_SQL.updateDynamicload_ButtonTable(conn_pool, button);
						}
					}
					
					if(run_count % 10 ==0 ) {
						//¶ÁÈ¡VÇø¸÷¸ö°´Å¥×´Ì¬  0x02-x18
						basedata = new BaseData(Modbus_ComBase.READ_HOLDING_REGISTER, Modbus_ComBase.LocalControl_Start_Addr, 17);
						if(SocketComm(basedata.createReadData(), socket)) {
							//¶ÁÈ¡VÇø״̬³É¹¦ 
							PowerArk_ServerSocket_Thread_SQL.updateDynamicload_StateTable(conn_pool, state);
						}
					}
				}
				
				/******************************************  д״̬   **********************************************/
				{
					PowerArk_SocketClient_Thread_SQL.queryPowerArkControl(conn_pool, control);
					if(control.FZ_b1 >= CONTROL_ON) {
						//´ò¿ª°´Å¥1
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.Button_Start_Addr, 1);						
						control.FZ_b1 = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.FZ_b1)), socket);
					}
					
					if(control.FZ_b2 >= CONTROL_ON) {
						//´ò¿ª°´Å¥2
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.Button_Start_Addr+1, 1);						
						control.FZ_b2 = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.FZ_b2)), socket);
					}
					
					if(control.FZ_b3 >= CONTROL_ON) {
						//´ò¿ª°´Å¥3
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.Button_Start_Addr+2, 1);						
						control.FZ_b3 = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.FZ_b3)), socket);
					}
					
					if(control.FZ_b4 >= CONTROL_ON) {
						//´ò¿ª°´Å¥4
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.Button_Start_Addr+3, 1);						
						control.FZ_b4 = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.FZ_b4)), socket);
					}
					
					if(control.FZ_b5 >= CONTROL_ON) {
						//´ò¿ª°´Å¥5
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.Button_Start_Addr+4, 1);						
						control.FZ_b5 = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.FZ_b5)), socket);
					}
					
					if(control.FZ_b6 >= CONTROL_ON) {
						//´ò¿ª°´Å¥6
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.Button_Start_Addr+5, 1);						
						control.FZ_b6 = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.FZ_b6)), socket);
					}
					
					if(control.FZ_b7 >= CONTROL_ON) {
						//´ò¿ª°´Å¥7
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.Button_Start_Addr+6, 1);						
						control.FZ_b7 = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.FZ_b7)), socket);
					}
					
					if(control.FZ_b8 >= CONTROL_ON) {
						//´ò¿ª°´Å¥8
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.Button_Start_Addr+7, 1);						
						control.FZ_b8 = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.FZ_b8)), socket);
					}
					
					if(control.FZ_b9 >= CONTROL_ON) {
						//´ò¿ª°´Å¥9
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.Button_Start_Addr+8, 1);						
						control.FZ_b9 = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.FZ_b9)), socket);
					}
					
					if(control.FZ_b10 >= CONTROL_ON) {
						//´ò¿ª°´Å¥10
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.Button_Start_Addr+9, 1);						
						control.FZ_b10 = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.FZ_b10)), socket);
					}
					
					if(control.FZ_b11 >= CONTROL_ON) {
						//´ò¿ª°´Å¥11
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.Button_Start_Addr+10, 1);						
						control.FZ_b11 = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.FZ_b11)), socket);
					}
					
					if(control.start_auto >= CONTROL_ON) {
						//Æô¶¯×Ô¶¯¼ÓÔØ
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.StartAutoLoad_Start_Addr, 1);						
						control.start_auto = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.start_auto)), socket);
					}
					
					if(control.stop_auto >= CONTROL_ON) {
						//Í£Ö¹×Ô¶¯¼ÓÔØ
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.StopAutoLoad_Start_Addr, 1);						
						control.stop_auto = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.stop_auto)), socket);
					}
					
					if(control.sudden_crease >= CONTROL_ON) {
						//Í»¼Óͻж
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.SuddenCrease_Start_Addr, 1);						
						control.sudden_crease = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.sudden_crease)), socket);
					}
					
					if(control.all_open >= CONTROL_ON) {
						//È«²¿·ÖÕ¢
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.AllOpenBreak_Start_Addr, 1);						
						control.all_open = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.all_open)), socket);
					}
					
					if(control.FZ_autostate1 >= CONTROL_ON) {
						//FZ×Ô¶¯×´Ì¬1
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.AutoProcess1_Start_Addr, 1);						
						control.FZ_autostate1 = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.FZ_autostate1)), socket);
					}
					
					if(control.FZ_autostate2 >= CONTROL_ON) {
						//FZ×Ô¶¯×´Ì¬2
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.AutoProcess2_Start_Addr, 1);						
						control.FZ_autostate2 = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.FZ_autostate2)), socket);
					}
					
					if(control.FZ_autostate3 >= CONTROL_ON) {
						//FZ×Ô¶¯×´Ì¬3
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.AutoProcess3_Start_Addr, 1);						
						control.FZ_autostate3 = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.FZ_autostate3)), socket);
					}
					
					if(control.FZ_autostate4 >= CONTROL_ON) {
						//FZ×Ô¶¯×´Ì¬4
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.AutoProcess4_Start_Addr, 1);						
						control.FZ_autostate4 = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.FZ_autostate4)), socket);
					}
					
					if(control.FZ_autostate5 >= CONTROL_ON) {
						//FZ×Ô¶¯×´Ì¬5
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.AutoProcess5_Start_Addr, 1);						
						control.FZ_autostate5 = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.FZ_autostate5)), socket);
					}
					
					if(control.local_control >= CONTROL_ON) {
						//¾ÍµØ¿ØÖÆ
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.LocalControl_Start_Addr, 1);						
						control.local_control = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.local_control)), socket);
					}
					
					if(control.back_control >= CONTROL_ON) {
						//ºǫ́¿ØÖÆ
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.BackControl_Start_Addr, 1);						
						control.back_control = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.back_control)), socket);
					}
					
					if(control.central_control >= CONTROL_ON) {
						//ÖпؿØÖÆ
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.CenterControl_Start_Addr, 1);						
						control.central_control = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.central_control)), socket);
					}
					
					if(control.inter_volume_M200 >= CONTROL_ON) {
						//ÖпؿØÖÆ
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.Middle_Start_Addr, 1);						
						control.inter_volume_M200 = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.inter_volume_M200)), socket);
					}
					
					if(control.fan_button >= CONTROL_ON) {
						//·ç»ú°´Å¥
						basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL, Modbus_ComBase.Fan_Button_Start_Addr, 1);						
						control.fan_button = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createButtonByte(control.fan_button)), socket);
					}
					
					if(control.set_power >= CONTROL_ON) {
						//É趨¹¦ÂÊ
						basedata = new BaseData(Modbus_ComBase.WRITE_MULTIPLE_REGISTER, Modbus_ComBase.SetPower_Start_Addr, 1);						
						control.set_power = CONTROL_OFF;
						SocketComm(basedata.createWiriteData(BaseData.createFloatByte(control.set_power)), socket);
					}
					PowerArk_ServerSocket_Thread_SQL.updateDynamicload_ControlTable(conn_pool, control);					
				}
				
				if(connerrCount >89999999) {
					connerrCount = 0;
				}
				if(connCount > 8999999) {
					connCount = 0;
				}
				run_count ++;
				if(run_count > 8999999) {
					run_count = 0;
				}
				Thread.sleep(50);
			} catch (Exception e) {
				//e.printStackTrace();
			}
		}
	}
	
	public boolean SocketComm(byte[] bytedata,Socket socket) throws InterruptedException
    { 
		boolean res_t = false;
		try
		{
			reConnectClient();
	        if(socket != null)
	        {
	        	socket.setSoTimeout(3000);
	        	InputStream in = socket.getInputStream();
		        OutputStream out = socket.getOutputStream();
		        //----------------- clear rx buff for tcp resend packet ----------------//
		        byte[] rx_buf_t = new byte[1024];
		        //----------------------------------------------------------------------//
		        bytebuffer_for_socket_RX.order(ByteOrder.BIG_ENDIAN);
		        bytebuffer_for_socket_RX.clear();
		        //--------------------- socket write -----------------------------------//
		        //byte[] b = makeCommBuf(cmd, bf);
		        System.err.println(ComFn.bytesToHexString(bytedata, bytedata.length));
		        Date d1 = new Date();
		      
		        
		        int rx_read_time_out = 0; 
		        //int rx_len = 0;
		        //System.err.println("TX: " + ComFn.bytesToHexString(b, b.length));
		        out.write(bytedata);
		        out.flush();
		        while(true) {
		        	if(in.available() > 0) { 
		        		rx_read_time_out = 0; 
		        		int rx_len_t = in.read(rx_buf_t);
		        		if((bytebuffer_for_socket_RX.position()+rx_len_t) 
		        				< (bytebuffer_for_socket_RX.capacity()-1)) {
			        		bytebuffer_for_socket_RX.put(rx_buf_t, 0, rx_len_t);
		        		}
		        	} else { 
		        		rx_read_time_out++;
		        		if((bytebuffer_for_socket_RX.position()>8) && (rx_read_time_out>10)){
		        			break;
		        		}
		        		if(rx_read_time_out > 220) { 
		        			break; 
		        		} 
		        	}
		        	Thread.sleep(10);
		        }
		        bytebuffer_for_socket_RX.flip();
		        Date d2 = new Date();
		        long comm_tms = (d2.getTime() - d1.getTime());
		        if(comm_tms < 200) {
		        	Thread.sleep(200 - comm_tms);
		        }
		        byte[] buffer = new byte[bytebuffer_for_socket_RX.limit()];
		        bytebuffer_for_socket_RX.get(buffer);
		        if(true == getDataFromCommBuf(buffer)) {
		        	connCount ++;
		        	res_t = true;
		        } else {
		        	errCount ++;
		        	connerrCount ++;
		        	res_t = false;
		        }
	        }
	    } catch (IOException e) {
	        errCount++;
	        connerrCount++;
	    } finally {
	    	
	    }		
		return res_t;
    }
	
	public boolean getDataFromCommBuf(byte[] bytes) {
		boolean issuccess = false;
		ByteBuffer bf = ByteBuffer.allocate(bytes.length);
        bf.order(ByteOrder.BIG_ENDIAN);
        bf.put(bytes);
        bf.flip();
        BaseData baseData = new BaseData();
        if(baseData.putByteBuffer(bf)) {
        	//»ñÈ¡·µ»ØÊý¾Ý³É¹¦
        	if(baseData.funcode == Modbus_ComBase.READ_COIL_STATUS) {
        		//¶ÁÈ¡ÏßȦÊý¾Ý³É¹¦[4013-4030]
        		if(baseData.addrstart == Modbus_ComBase.OverTmp_Start_Addr) {
        			if(dyna_inf.putReadIBackByteBuffer(bf)) {
        				System.out.println("¶ÁÈ¡IÇøÊý¾Ý³É¹¦4013-4030");
        				issuccess = true;
        			} 			
        		}
        		
        		//¶ÁÈ¡MÇø״̬³É¹¦[01 - 12]
        		if(baseData.addrstart == Modbus_ComBase.AutoProcess1_Start_Addr) {
        			if(dyna_inf.putReadMBackByteBuffer(bf)) {
        				System.out.println("¶ÁÈ¡MÇøÊý¾Ý³É¹¦01-12");
        				issuccess = true;
        			} 
        		}
        	
        		//¶ÁÈ¡QÇø״̬³É¹¦[8000-8013]
        		if(baseData.addrstart == Modbus_ComBase.ButtonOutPut_Start_Addr) {
        			if(dyna_inf.putReadQBackByteBuffer(bf)) {
        				System.out.println("¶ÁÈ¡QÇøÊý¾Ý³É¹¦8000-8013");
        				issuccess = true;
        			} 
        		}
        		
        		//¶ÁÈ¡MÇø¸÷¸ö¿ØÖƵÄ״̬[0040-0160]
        		if(baseData.addrstart == Modbus_ComBase.LocalControl_Start_Addr) {
        			if(dyna_inf.putReadMControlStateByteBuffer(bf)) {
        				System.out.println("¶ÁÈ¡MÇøÊý¾Ý³É¹¦0040-0160");
        				issuccess = true;
        			} 
        		}
        		
        		
        		
        	}else if(baseData.funcode == Modbus_ComBase.READ_HOLDING_REGISTER) {
        		if(baseData.addrstart == Modbus_ComBase.ActualSetPower_Start_Addr) {
        			//¶ÁÈ¡VÇø¸÷¸öÊý¾Ý״̬[02-18]
        			if(dyna_inf.putReadVBackByteBuffer(bf)) {
        				System.out.println("¶ÁÈ¡VÇøÊý¾Ý³É¹¦02-18");
        				issuccess = true;
        			}
        		}
        		
        	}
        	
        	
        	
        }       
		return issuccess;
	}
	
	
	/**
	 * 	ÖØлñÈ¡Á¬½Ó¶ÔÏó
	 */
	public void reConnectClient() {
		try {
			if(socket == null || socket.isClosed() || errCount > 4) {
				if(socket != null) {
					socket.close();
				}
				socket = new Socket();
				socket.connect(new InetSocketAddress(dev_ip, PowerArk_Port), 5000);
				socket.setSoTimeout(5000);
				errCount = 0;
			}
		} catch (SocketException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}