/********************************* head of file SocketClient.java ***********************************/
package com.dev.fbs9100;
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.nio.ByteOrder;
import com.dev.fbs9100.FBS9100_CapState;
import com.dev.fbs9100.FBS9100_ChargeState;
import com.dev.fbs9100.FBS9100_Cmd;
import com.dev.fbs9100.FBS9100_ComBase;
import com.dev.fbs9100.FBS9100_ComBuf;
import com.dev.fbs9100.FBS9100_ParamBatt;
import com.dev.fbs9100.FBS9100_ParamCharge;
import com.dev.fbs9100.FBS9100_ParamDischarge;
import com.dev.fbs9100.FBS9100_ParamSystem;
import com.dev.fbs9100.FBS9100_ResCapData;
import com.dev.fbs9100.FBS9100_ResState;
import com.dev.fbs9100.FBS9100_VCData;
/****************************************************************************************************/
public class FBS9100_SocketClient extends Thread
{
	private FBS9100_Cmd m_FBS_Cmd = new FBS9100_Cmd();
	private FBS9100_VCData m_FBS_VCData = null;
	private FBS9100_ParamBatt m_FBS_BattParam = new FBS9100_ParamBatt();
	private FBS9100_ParamSystem m_FBS_SystemParam = new FBS9100_ParamSystem();
	private FBS9100_ParamDischarge m_FBS_DiscParam = null;
	private FBS9100_ParamDischarge m_FBS_DiscParamFromDev = null;
	private FBS9100_ParamCharge m_FBS_ChargeParam = new FBS9100_ParamCharge();
	private FBS9100_ResState m_ResTestState = new FBS9100_ResState();
	private FBS9100_CapState m_CapTestState = new FBS9100_CapState();
	private FBS9100_ChargeState m_ChrTestState = new FBS9100_ChargeState();
	private FBS9100_ResCapData m_FBS_ResCapData = new FBS9100_ResCapData();
	
	private FBS9100_StatAndParam m_StatAndParam = null;
	private BattData_RT m_RTData = new BattData_RT();
	private String mDevIp = "192.168.0.18";
	private static final String TAG = "SocketClient_Thread";
	
	/*********************************************************************************************/
	public FBS9100_SocketClient(FBS9100_StatAndParam stat_param)
    {
		m_StatAndParam = stat_param;
		m_FBS_VCData = m_StatAndParam.m_FBS_VCData;
		m_FBS_DiscParam = m_StatAndParam.m_FBS_DiscParam;
		m_FBS_DiscParamFromDev = m_StatAndParam.m_FBS_DiscParamFromDev;
		
		mDevIp = m_StatAndParam.dev_ipaddr;
    }
	
	/*********************************************************************************************/
	public void run()
    {
		this.setName(TAG);
		System.out.println(this.getName() + " - FBS9100_SocketClientThread Started ...");
		while(true)
        {
			try {
				SocketComm(FBS9100_ComBase.CMD_GetVIData, ByteBuffer.allocate(0));
				sleep(200);
				
				if(FBS9100_ComBase.CMD_NULL == m_StatAndParam.op_cmd)
				{
					if(FBS9100_ComBase.CMD_SetDischargeParm == m_StatAndParam.m_FBS_DiscParam.op_cmd) {
						if(true == SocketComm(FBS9100_ComBase.CMD_SetDischargeParm , m_StatAndParam.m_FBS_DiscParam.getByteBuffer()))
						{
							m_StatAndParam.op_cmd = FBS9100_ComBase.CMD_SetDischargeParmAck;
						}
					} else if( FBS9100_ComBase.CMD_Start == m_FBS_DiscParam.op_cmd ) {
						int cmd = FBS9100_ComBase.CMD_StartDischarge;
						if(cmd != m_FBS_DiscParam.test_cmd) {
							cmd = FBS9100_ComBase.CMD_StartResDischarge;
						}
						if(true == SocketComm(cmd, ByteBuffer.allocate(0))) {
							m_StatAndParam.op_cmd = FBS9100_ComBase.CMD_StartAck;
						}
					} else if(FBS9100_ComBase.CMD_Stop == m_FBS_DiscParam.op_cmd) {
						if(true == SocketComm(FBS9100_ComBase.CMD_Stop, ByteBuffer.allocate(0))) {
							m_StatAndParam.op_cmd = FBS9100_ComBase.CMD_StopAck;
						}
					} else if(FBS9100_ComBase.CMD_GetDischargeParm == m_FBS_DiscParam.op_cmd) {
						if(true == SocketComm(FBS9100_ComBase.CMD_GetDischargeParm, ByteBuffer.allocate(0))) {
							m_StatAndParam.op_cmd = FBS9100_ComBase.CMD_GetDischargeParmAck;
						}
					}
				}
				
				//-----------------------------------------------------------------------------------//
				//-----------------------------------------------------------------------------------//
				if(FBS9100_ComBase.BattState_Discharge == m_FBS_VCData.m_SysState.WorkState)
				{
					//------------- Èç¹ûÊÇÄÚ×è²âÊÔ,Ôò×Ô¶¯¶ÁÈ¡Ò»´ÎFBS9100É豸ÉϵIJÎÊý -----------//
					if(FBS9100_ComBase.TestType_RES == m_FBS_VCData.m_SysState.TestType) {
						if ((FBS9100_ComBase.TestType_RES != m_StatAndParam.test_type)
							&& (FBS9100_ComBase.CMD_NULL == m_StatAndParam.op_cmd)) {
							if(true == SocketComm(FBS9100_ComBase.CMD_GetDischargeParm, ByteBuffer.allocate(0))) {
								m_StatAndParam.op_cmd = FBS9100_ComBase.CMD_GetDischargeParmAck;
								m_StatAndParam.test_type = FBS9100_ComBase.TestType_RES;
  							}
						}
					} else {//------ Èç¹ûÊÇÈÝÁ¿·Åµç²âÊÔ,Ôò×Ô¶¯¶ÁÈ¡Ò»´ÎFBS9100É豸ÉϵIJÎÊý ------//
						if ((FBS9100_ComBase.TestType_CAP != m_StatAndParam.test_type)
							&&(FBS9100_ComBase.CMD_NULL == m_StatAndParam.op_cmd)) {
							if(true == SocketComm(FBS9100_ComBase.CMD_GetDischargeParm, ByteBuffer.allocate(0))) {
								m_StatAndParam.op_cmd = FBS9100_ComBase.CMD_GetDischargeParmAck;
								m_StatAndParam.test_type = FBS9100_ComBase.TestType_CAP;
							}
						}
					}
				}
				
				sleep(100);
				SocketComm(FBS9100_ComBase.CMD_GetMonomerRES, ByteBuffer.allocate(0));
				sleep(200);
				SocketComm(FBS9100_ComBase.CMD_GetMonomerTMP, ByteBuffer.allocate(0));
				
				if(FBS9100_ComBase.TestType_RES == m_StatAndParam.test_type)
				{
					sleep(100);
					if(true == SocketComm(FBS9100_ComBase.CMD_GetResTestState, ByteBuffer.allocate(0)))
					{
						m_FBS_VCData.m_SysState.ResBattIndexMax = m_ResTestState.ResBattIndexMax;
						m_FBS_VCData.m_SysState.ResBattIndex = m_ResTestState.ResBattIndex;
					}
					
					//------ ÄÚ×è²âÊÔÍ£Ö¹µÄʱºò,×Ô¶¯¼Ç¼һ´ÎÄÚ×èÖµµ½Êý¾Ý¿â  ------//
					if(FBS9100_ComBase.TestType_RES != m_FBS_VCData.m_SysState.TestType)
					{
						m_StatAndParam.test_type = FBS9100_ComBase.TestType_NULL;
						/*
						int index = m_ResTestState.BattGroupNum - 1;
						if((index >= 0) && (index<m_RTData.length) && (null != m_RTData[index])) {
							m_RTData[index].setStoreBattRes_DataEnStat(true);
						}
						*/
					}
				} else if (FBS9100_ComBase.TestType_CAP == m_StatAndParam.test_type) {
					if(FBS9100_ComBase.TestType_CAP != m_FBS_VCData.m_SysState.TestType)
					{
						m_StatAndParam.test_type = FBS9100_ComBase.TestType_NULL;
					}
				}
				//-----------------------------------------------------------------------------------//
				//-----------------------------------------------------------------------------------//
				
				sleep(100);
				
			} catch (InterruptedException e) {
	            //e.printStackTrace();
	            try {
					sleep(2000);
				} catch (InterruptedException e1) {
					// TODO Auto-generated catch block
					//e1.printStackTrace();
				}
	        }
        }
    }
	/*********************************************************************************************/
	/*********************************************************************************************/
	/**
	 * ʹÓÃsocket Á¬½ÓÖ¸¶¨µÄipÉ豸µÄ9001¶Ë¿Ú²¢ÇÒ·¢ËÍÊý¾Ý£¬ÒÔ¼°½ÓÊÕÊý¾Ý
	 * @param cmd		
	 * @param bf
	 * @return
	 * @throws InterruptedException
	 */
	public boolean SocketComm(int cmd, ByteBuffer bf) throws InterruptedException
    {
		boolean res = false;
		try
		{
	        Socket socket = new Socket();
	        socket.connect(new InetSocketAddress(mDevIp, 9001), 3000);
	        if(socket.isConnected())
	        {
	        	InputStream in = socket.getInputStream();
		        OutputStream out = socket.getOutputStream();
		        
		        out.write(makeCommBuf(cmd, bf));
		        
		        for(int n=0; n<100; n++)
		        {
		        	sleep(10);
		        	int len1 = in.available();
		        	if(len1 <= 0)
		        		continue;
		        	
		        	sleep(10);
		        	
		        	if(in.available() == len1)
		        		break;
		        }
		        
		        byte[] buffer = new byte[in.available()];
		        in.read(buffer);
		        
		        getDataFromCommBuf(buffer);
		        
		        in.close();
		        socket.close();
		        res = true;
		        
		        if(buffer.length > 8) {
		        	m_FBS_VCData.m_SysState.setCommCountInc();
		        } else {
		        	m_FBS_VCData.m_SysState.setErrCommCountInc();
		        }
	        } else {
	        	m_FBS_VCData.m_SysState.setErrCommCountInc();
	        }
	    }
		catch (IOException e)
		{
	        //e.printStackTrace();
			m_FBS_VCData.m_SysState.setErrCommCountInc();
	    }
		
		return res;
    }
	/*********************************************************************************************/
	/*********************************************************************************************/
	public byte[] makeCommBuf(final int cmd, ByteBuffer bf)
  	{
  		return (FBS9100_ComBuf.makeFbs9100CommBuf(0, cmd, bf).array());
  	}
	/*********************************************************************************************/
	public String getDataFromCommBuf(final byte[] bytes)
  	{
		ByteBuffer bf = ByteBuffer.allocate(bytes.length);
        bf.order(ByteOrder.LITTLE_ENDIAN);
        bf.put(bytes);
        bf.flip();
		
		String msg = "";
		if(true == m_FBS_Cmd.putByteBuffer(bf))
        {
			//------------------- ¶ÁÈ¡FBS9100µçѹµçÁ÷Êý¾Ý --------------------
	        if(FBS9100_ComBase.CMD_GetVIData == m_FBS_Cmd.CMD)
	        {
	        	if(true == m_FBS_VCData.m_SysState.putByteBuffer(bf))
		        {
		        	if(true == m_FBS_VCData.putByteBuffer(bf))
		        	{
		        		getFBS9100MonVolData(m_FBS_VCData);
		        	}
		        }
	        }
	        //------------------- ¶ÁÈ¡FBS9100ÄÚ×è²âÊÔ״̬ -----------------------
	        if(FBS9100_ComBase.CMD_GetResTestState == m_FBS_Cmd.CMD)
	        {
	        	if(true == m_ResTestState.putByteBuffer(bf))
		        	msg = "Get ResTest State from FBS9100 OK!!!";
	        }
	        //------------------- ¶ÁÈ¡FBS9100ÈÝÁ¿²âÊÔ״̬ -----------------------
	        if(FBS9100_ComBase.CMD_GetDischargeState == m_FBS_Cmd.CMD)
	        {
	        	if(true == m_CapTestState.putByteBuffer(bf))
		        	msg = "Get CapTest State from FBS9100 OK!!!";
	        }
	        //------------------- ¶ÁÈ¡FBS9100³äµç²âÊÔ״̬ -----------------------
	        if(FBS9100_ComBase.CMD_GetChargeState == m_FBS_Cmd.CMD)
	        {
	        	if(true == m_ChrTestState.putByteBuffer(bf))
		        	msg = "Get ChrTest State from FBS9100 OK!!!";
	        }
	        //------------------- ¶ÁÈ¡FBS9100µç³Ø²ÎÊý -------------------------
	        else if(FBS9100_ComBase.CMD_GetBattParam == m_FBS_Cmd.CMD)
	        {
	        	if(true == m_FBS_BattParam.putByteBuffer(bf))
	        		msg = "Get battparam from FBS9100 OK!!!";
	        }
	        //------------------- ÉèÖÃFBS9100µç³Ø²ÎÊý -------------------------
	        else if(FBS9100_ComBase.CMD_SetBattParam == m_FBS_Cmd.CMD) {
	        	if(true == m_FBS_BattParam.putByteBuffer(bf))
	        		msg = "Set battparam to FBS9100 OK!!!";
	        }
	        //------------------- ¶ÁÈ¡FBS9100ϵͳ²ÎÊý -------------------------
	        else if(FBS9100_ComBase.CMD_GetSYSSetParam == m_FBS_Cmd.CMD)
	        {
	        	if(true == m_FBS_SystemParam.putByteBuffer(bf))
	        		msg = "Get sysparam from FBS9100 OK!!!";
	        }
	        //------------------- ÉèÖÃFBS9100ϵͳ²ÎÊý -------------------------
	        else if(FBS9100_ComBase.CMD_SetSYSSetParam == m_FBS_Cmd.CMD)
	        {
	        	if(true == m_FBS_SystemParam.putByteBuffer(bf))
	        		msg = "Set sysparam to FBS9100 OK!!!";
	        }
	        //------------------- ¶ÁÈ¡FBS9100·Åµç²ÎÊý -------------------------
	        else if(FBS9100_ComBase.CMD_GetDischargeParm == m_FBS_Cmd.CMD)
	        {
	        	if(true == m_FBS_DiscParamFromDev.putByteBuffer(bf))
	        		msg = "Get DischargeParm from FBS9100 OK!!!";
	        }
	        //------------------- ÉèÖÃFBS9100·Åµç²ÎÊý -------------------------
	        else if(FBS9100_ComBase.CMD_SetDischargeParm == m_FBS_Cmd.CMD)
	        {
	        	if(true == m_FBS_DiscParam.putByteBuffer(bf))
	        		msg = "Set DischargeParam to FBS9100 OK!!!";
	        }
	        //------------------- ¶ÁÈ¡FBS9100³äµç²ÎÊý -------------------------
	        else if(FBS9100_ComBase.CMD_GetChargeParm == m_FBS_Cmd.CMD)
	        {
	        	if(true == m_FBS_ChargeParam.putByteBuffer(bf))
	        		msg = "Get ChargeParam from FBS9100 OK!!!";
	        }
	        //------------------- ÉèÖÃFBS9100³äµç²ÎÊý -------------------------
	        else if(FBS9100_ComBase.CMD_SetChargeParm == m_FBS_Cmd.CMD)
	        {
	        	if(true == m_FBS_ChargeParam.putByteBuffer(bf))
	        		msg = "Set ChargeParam to FBS9100 OK!!!";
	        }
	        //------------------- ¶ÁÈ¡FBS9100ÈÝÁ¿ÄÚ×è²âÊÔÊý¾Ý ------------------
	        else if((FBS9100_ComBase.CMD_GetMonomerRES == m_FBS_Cmd.CMD)
	        		||(FBS9100_ComBase.CMD_GetMonomerTMP == m_FBS_Cmd.CMD)
	        		/*||(FBS_ComBase.CMD_GetMonomerCAP == m_FBS_Cmd.CMD)
	        		||(FBS_ComBase.CMD_GetMonomerChargeCAP == m_FBS_Cmd.CMD)*/)
	        {
	        	if(true == m_FBS_ResCapData.putByteBuffer(bf, m_FBS_Cmd.CMD))
	        	{
	        		getFBS9100MonResData(m_FBS_Cmd.CMD, m_FBS_ResCapData);
	        		//msg = "Get MonomerCAP or MonomerRES from FBS9100 OK!!!";
	        	}
	        }
        }
		
		return msg;
	}
	/*********************************************************************************************/
	private void getFBS9100MonVolData(FBS9100_VCData vc_data)
    {
    	int mon_index = 0;
    	for(int n=0; n<FBS9100_ComBase.BattGroupCountMax; n++)
    	{
    		if(null != m_RTData)
    		{
    			if(FBS9100_ComBase.BattState_Discharge == vc_data.battstate[n])
    			{
    				vc_data.battcurr[n] *= -1;
    			}
    			
    			m_RTData.mTestData.updateCurrFrom_FBSDev((float) vc_data.battcurr[n]);
    			m_RTData.mTestData.updateGroupVolFrom_FBSDev((float) vc_data.groupvol[n]);
    			for(int index=0; index<m_RTData.MonCount; index++)
    			{
    				if(mon_index >= FBS9100_ComBase.MonomerCountMax) {
    					break;
    				}
    				m_RTData.al_MonVol.get(index).monVol = (float) vc_data.vol[mon_index];
    				mon_index++;
    			}
    		}
    	}
    }
	/*********************************************************************************************/
	private void getFBS9100MonResData(int cmd, FBS9100_ResCapData res_data)
    {
    	int mon_index = 0;
    	for(int n=0; n<FBS9100_ComBase.BattGroupCountMax; n++)
    	{
    		if(null != m_RTData)
    		{
    			for(int index=0; index<m_RTData.MonCount; index++)
    			{
    				if(mon_index >= FBS9100_ComBase.MonomerCountMax)
    					break;
    				
    				if(FBS9100_ComBase.CMD_GetMonomerRES == cmd) {
    					m_RTData.al_MonVol.get(index).monRes = (float) res_data.m_DATA[mon_index];
    				} else if(FBS9100_ComBase.CMD_GetMonomerTMP == cmd) {
    					m_RTData.al_MonVol.get(index).monTmp = (float) res_data.m_DATA[mon_index];
    				}
    				
    				mon_index++;
    			}
    		}
    	}
    }
	/*********************************************************************************************/
}
/********************************* end of file SocketClient.java *************************************/