package com.dev.fgcd.comm;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.nio.ByteBuffer;
import java.nio.ByteOrder;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Date;

import com.battmonitor.sql.MysqlConnPool;
import com.battmonitor.sql.Sql_Mysql;
import com.dev.btse.data.ComFn;
import com.dev.fgcd.data.FGCD_Cmd;
import com.dev.fgcd.data.FGCD_ComBase;
import com.dev.fgcd.data.FGCD_ComBuf;
import com.dev.fgcd.data.FGCD_Crc16;
import com.dev.fgcd.data.FGCD_TestFBOFile;
import com.dev.fgcd.data.FGCD_TestFBOFile.FBOFile;
import com.dev.fgcd.fbo.FboData;
import com.dev.fgcd.fbo.FboDataInf;
import com.dev.fgcd.fbo.FboTestTime;


public class FGCD_TestDataDownLoad {
	
	public static final int DownloadFlag_Fail			= -1;		//µ¼Èëʧ°Ü
	public static final int DownloadFlag_Null 			= 0;		//²»ÏÂÔØ
	public static final int DownloadFlag_Start 			= 1;		//ÐèÒªµ¼Èë
	public static final int DownloadFlag_Over 			= 2;		//ÏÂÔØÍê³É
	
	public static final int FialReason_DeFault		 	= 0;		//ÔÝÎÞ
	public static final int FialReason_FIleNotFound 	= 1;		//ÎļþδÕÒµ½
	public static final int FialReason_ParamError		= 2;		//²ÎÊý´íÎó
	public static final int FialReason_NetWorkError		= 3;		//ÍøÂçÒì³£´íÎó
	public static final int FialReason_UserCancel		= 4;		//Óû§È¡Ïû
	
	
	public static final int DownLoadState_ReadData 		= 1;		//ÏÂÔØÎļþ
	public static final int DownLoadState_CreateData	= 2;		//Éú³ÉÎļþ
	public static final int DownLoadState_ExportData	= 3;		//µ¼³öÊý¾Ý
	public static final int DownLoadState_ExportSucc	= 4;		//µ¼Èë³É¹¦
	public static final int DownLoadState_ExportFail	= 5;		//µ¼Èëʧ°Ü
	public static final int DownLoadState_UserCancel	= 6;		//Óû§È¡Ïû
	public static final int DownLoadState_DownLoadCancel	= 7;		//ÏÂÔØʧ°Ü
	
	
	private ByteBuffer bytebuffer_for_socket_RX = ByteBuffer.allocate(1200);
	
	private FGCD_TestFBOFile fbofile;
	private FGCD_Cmd m_FBS_Cmd = new FGCD_Cmd();
	private boolean ReadTestData = true;
    public byte[] filebyte;
	
    private MysqlConnPool pool;
	private Socket socket;
	private int ErrorCount = 0;			//´íÎó¼ÆÊý;Á¬Ðø3´ÎͨÐÅʧ°Ü¼´ÎªÍøÂçÒì³£½áÊø
	private String fileName;
	private FBOFile nowFbo;
	
	
	public FGCD_TestDataDownLoad(FGCD_TestFBOFile fbofile,Socket socket,MysqlConnPool pool) {
		this.fbofile = fbofile;
		this.socket = socket;
		this.pool = pool;
		
		filebyte = new byte[0];
		downLoadParamCheck();
	}
	

	/**
	 * 	ÏÂÔص±Ç°µç³Ø×éÊý¾Ý
	 * @param socket
	 */
	public void downLoadTestData() {
		int now_download_state = DownLoadState_ReadData;
		fbofile.initDownLoadState();//ÎļþÐÅÏ¢ÏÂÔسõʼ»¯
		for(int i=0;i<fbofile.files.length;i++) {
			//µ±Ç°ÏÂÔØÎļþ
			nowFbo = fbofile.files[i];
			int file_downloadNum=i;//ÉèÖõ±Ç°ÏÂÔØÎļþµÄË÷Òý
			if(now_download_state == DownLoadState_DownLoadCancel) {
				nowFbo.setDownload_state(DownLoadState_DownLoadCancel);
				nowFbo.setDownload_flag(DownloadFlag_Fail);
				continue;
			}
			if(nowFbo.download_flag != DownloadFlag_Start) {
				continue;
			}
			ReadTestData = true;
			nowFbo.setDownload_state(DownLoadState_ReadData);	
			while(ReadTestData) {
				try {
					queryDownLoadState(pool, fbofile);
					if(fbofile.op_cmd == FGCD_ComBase.CMD_DownLoadFBDFile_Over) {
						now_download_state = FGCD_ComBase.CMD_DownLoadFBDFile_Over;
						fbofile.setStop_reason(FialReason_UserCancel);
						//ÊÖ¶¯ÖÕÖ¹ÏÂÔØÃüÁî
						nowFbo.setDownload_flag(DownloadFlag_Fail);
						nowFbo.setDownload_state(DownLoadState_DownLoadCancel);
						fbofile.op_cmd = FGCD_ComBase.CMD_DownLoadFBDFile_Over_ACK;
						FGCD_Task_Thread_SQL.updateFgcd_Filedownload_TableCmdByDevId(pool, fbofile,file_downloadNum);
						continue;
					}					
					if(nowFbo.getDownload_state() == DownLoadState_ReadData) {	
						//System.out.println("¶ÁÈ¡²âÊÔÎļþÖÐ"+file);
						SocketComm(FGCD_ComBase.CMD_GETFILE,nowFbo.file_index,nowFbo.now_data_block);
						if(nowFbo.download_state == DownLoadState_CreateData) {
							//ÏÂÔØÊýÁ¿
							nowFbo.setNow_data_block(0);
							nowFbo.setTotal_data_block(0);
						}
						
						updateDownLoadProgressByOne(pool,fbofile,file_downloadNum);		//¸üе±Ç°ÏÂÔؽø¶È
						
					}
					if(nowFbo.getDownload_state() == DownLoadState_CreateData) {
						//Éú³Éµ±Ç°ÏÂÔصÄÊý¾ÝÎļþ
						if(createFBOFile(nowFbo)) {
							//Éú³ÉFBOÎļþ³É¹¦¹ý
							//System.err.println("Éú³ÉÎļþ³É¹¦");
							nowFbo.setDownload_state(DownLoadState_ExportData);
						}else{
							//Éú³ÉFBOÎļþʧ°Ü
							//System.err.println("Éú³ÉÎļþʧ°Ü");			
							nowFbo.setDownload_state(DownLoadState_ExportFail);
						}			
					}
					
					if(nowFbo.getDownload_state() == DownLoadState_ExportData) {
						//½âÎö±¾µØÊý¾ÝÎļþ²¢µ¼ÈëÊý¾Ý¿â
						/*boolean flag = readFBOFileData(file,pool);	
						if(flag) {
							nowFbo.setDownload_state(DownLoadState_ExportSucc);
						}else {
							nowFbo.setDownload_state(DownLoadState_ExportFail);
						}*/
						//¿ªÆôÐÂÏ̵߳¼ÈëÊý¾Ý¿â
						FGCD_Export_Thread_SQL export_Thread=new FGCD_Export_Thread_SQL(pool, nowFbo.clone(), fbofile.battgroupid,file_downloadNum);
						new Thread(export_Thread).start();
						ReadTestData = false;
					}
					//System.out.println("nowFbo.getDownload_state():"+nowFbo.getDownload_state());
//					if(nowFbo.getDownload_state() == DownLoadState_ExportFail
//						|| nowFbo.getDownload_state() == DownLoadState_ExportSucc) {
//						ReadTestData = false;
//					}
					//file.setDownload_state(nowFbo.getDownload_state());
					//updateDownLoadProgress(pool,fbofile);		//¸üе±Ç°ÏÂÔؽø¶È
					Thread.sleep(50);
				} catch(Exception e) {
					e.printStackTrace();
				}			
			}
			filebyte = new byte[0];			
			/*{
				if(nowFbo.getDownload_state() == DownLoadState_ExportSucc) {
					//System.out.println("µ¼³öÀúÊ··ÅµçÊý¾Ý³É¹¦");
					file.setDownload_flag(DownloadFlag_Over);
					fbofile.op_cmd = FGCD_ComBase.CMD_DownLoadFBDFile_ACK;
				}else {
					//System.out.println("µ¼³öÀúÊ··ÅµçÊý¾Ýʧ°Ü");
					file.setDownload_flag(DownloadFlag_Fail);
					fbofile.op_cmd = FGCD_ComBase.CMD_DownLoadFBDFile_Over;
				}
			}*/
			//FGCD_Task_Thread_SQL.updateFBOFIleExportFlag(pool,fbofile);		
		}	
		//FGCD_Task_Thread_SQL.updateFgcd_FiledownloadState_TableByDevId(pool, fbofile);
		/******************************** ×îºóÉèÖõ±Ç°µ¼³ö״̬ ********************************************/
	}
	
	/**
	 * 	½âÎöFBOÎļþ
	 * @param file
	 * @param pool
	 */
	 private boolean readFBOFileData(FBOFile file,MysqlConnPool pool) {
		 boolean flag = false;
		 FboDataInf data_inf = new FboDataInf();
		 ArrayList<FboData> al_fbo_data = new ArrayList<>();
		 File f = new File(file.filename);
		 if(file.test_timelong > 0) {
			 FboData.checkFboFile(f, data_inf, al_fbo_data);
			 
			 flag = FGCD_Task_Thread_SQL.insertFBODataIntoTable(pool, file, data_inf, al_fbo_data, fbofile.battgroupid);
			 flag = true;
		 }
		 if(f.exists()) {
			//ɾ³ýÏÂÔصÄFBOÎļþ
			//f.delete();
		 }	
		 return flag;		
	}





	/**
	  * ÏòÖ¸¶¨µÄsocketͨµÀ·¢ËÍÊý¾Ý½çÃæͬ²½ÇëÇó 
	  * @param cmd			¶ÁÈ¡Ö¸Áî
	  * @param rec_index	¶ÁÈ¡Ë÷Òý
	  * @return
	  */
    public boolean SocketComm(int cmd,int file_index,int rec_index)
    {
        boolean res_t = false;
        InputStream in = null;
        OutputStream out = null;
        try
        {
            if(null != this.socket && !this.socket.isClosed())
            {
                in = this.socket.getInputStream();
                out = this.socket.getOutputStream();
                //----------------- clear rx buff for tcp resend packet ----------------//
                byte[] rx_buf_t = new byte[1024];

                //----------------------------------------------------------------------//
                bytebuffer_for_socket_RX.order(ByteOrder.LITTLE_ENDIAN);
                bytebuffer_for_socket_RX.clear();
                //--------------------- socket write -----------------------------------//
                //--------------------- socket write -----------------------------------//
                boolean aes_en = false;
                byte[] plain_tx_t = makeCommBuf(cmd,file_index,rec_index);
                Date d1 = new Date();
                int rx_read_time_out = 0;
                //int rx_len = 0;
                //System.out.println("Êý¾Ý³¤¶È" + plain_tx_t.length + "\t·¢ËÍÊý¾Ý:" + ComFn.bytesToHexString(plain_tx_t, plain_tx_t.length));
                out.write(plain_tx_t);
                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);
                        }
                        //bytebuffer_for_socket_RX.put((byte)in.read());
                    } else {
                        rx_read_time_out++;
                        if((bytebuffer_for_socket_RX.position() >= 20) && (rx_read_time_out>10)){
                            //	res = true;
                            break;
                        }
                        if(rx_read_time_out > 300) {
                            break;
                        }
                    }
                    Thread.sleep(10);
                }
                Date d2 = new Date();
                long comm_tms = (d2.getTime() - d1.getTime());
                if(comm_tms < 200) {
                    Thread.sleep(200 - comm_tms);
                }

                bytebuffer_for_socket_RX.flip();

                byte[] cipher_buf = new byte[bytebuffer_for_socket_RX.limit()];
                bytebuffer_for_socket_RX.get(cipher_buf);
                
                //sysState.makeDevCommDataFlowSum(cipher_buf.length);
                
                //System.out.println("Êý¾Ý³¤¶È"+cipher_buf.length+"\t·µ»ØÊý¾Ý£º"+ ComFn.bytesToHexString(cipher_buf, cipher_buf.length));
                if(true == getDataFromCommBuf(cipher_buf)) {
                	res_t = true; 
                	ErrorCount = 0;
                } else {
                	ErrorCount ++;
                	res_t = false;
                }
            } else {
            	ReadTestData = false;
            }
        } catch (IOException | InterruptedException e) {
        	ErrorCount ++;
        } finally {
            if(ErrorCount > 5){
            	ReadTestData = false;
            }
        }
        return res_t;
    }
	
    public Boolean getDataFromCommBuf(final byte[] bytes)
    {
        boolean isSuccess = false;
        ByteBuffer bf = ByteBuffer.allocate(bytes.length);
        bf.order(ByteOrder.LITTLE_ENDIAN);
        bf.put(bytes);
        bf.flip();

        if(true == m_FBS_Cmd.putByteBuffer(bf))
        {
            //---------------------  ÐÄÌø°ü²âÊÔ    ----------------------------------
            if(FGCD_ComBase.CMD_GETFILE == m_FBS_Cmd.CMD) {
                if(FGCD_ComBase.RETURN_SUCCESS == m_FBS_Cmd.RecState) {  
                	this.nowFbo.total_data_block = m_FBS_Cmd.getTotalDownLoadBlock();
                	//System.out.println("Êý¾Ý°ü×ܳ¤¶È£º"+ this.fbofile.total_data_block+ m_FBS_Cmd);
                	if(m_FBS_Cmd.getNowDownLoadIndex() == nowFbo.now_data_block) { 
                		if(putFileData(bf,m_FBS_Cmd.ByteLen-18)) {
                			
                			nowFbo.now_data_block ++;
                			isSuccess = true;
                			System.out.println("¶ÁÈ¡µÚ"+m_FBS_Cmd.getNowDownLoadIndex()+"¸öÊý¾Ý°ü³É¹¦");
                			
                			if(nowFbo.now_data_block == nowFbo.total_data_block) {
                				//System.out.println("ÏÂÔØÀúÊ·Êý¾ÝÎļþÍê³É");
                				nowFbo.setDownload_state(DownLoadState_CreateData);
                			}
                		}                		
                	}
                }
            }         
        }
        return isSuccess;
    }
    
    public byte[] makeCommBuf(final int cmd,int file_index, int rec_index)
    {
    	FGCD_Cmd m_cmd = new FGCD_Cmd();
    	m_cmd.CMD = cmd;
    	m_cmd.Type 		= file_index%256;
    	m_cmd.RecState 	= file_index/256;
    	m_cmd.Alarm 	= rec_index%256;
    	m_cmd.WorkState = rec_index/256;
    	
        ByteBuffer bbf = FGCD_ComBuf.makeFGCDTestDataCommBuf(m_cmd);
        byte byte_rest[] = new byte[bbf.limit()];
        bbf.get(byte_rest);
        return byte_rest;
    }
    
    /**
     * 
     * @param bf
     * @param len	µ±Ç°buffµÄÓÐЧ³¤¶È
     * @return
     */
    public boolean putFileData(ByteBuffer bf,int len) {
    	 if(bf.limit() < 2) {
             return false;
         }
    	 //System.out.println("ÓÐЧ³¤¶È:"+len+"\t"+ComFn.bytesToHexString(bf.array(), len));
    	 ByteBuffer tmpbuf = bf;
         tmpbuf.position(0);
    	 int crc0 = tmpbuf.getShort(len-2) & 0xFFFF;
    	 //Ö»¼ÆËãÇ°1024¸ö×Ö½ÚµÄCRCÊý¾Ý
         int crc1 = FGCD_Crc16.CalCRC16(tmpbuf, len-2);
         if(crc0 != crc1) {
             System.err.println("FGCD_TestDataDownLoad.CRCУÑé:"+crc0+"==="+crc1);
             return false;
         }
         tmpbuf.position(0);
    	 int last = filebyte.length;
         byte[] tmp = new byte[last+len-2];
    	 System.arraycopy(filebyte, 0, tmp, 0, last);
    	 for(int i=0;i<len-2;i++) {
    		 tmp[last+i] = tmpbuf.get();
    	 }       
    	 this.filebyte = tmp;
         return true;
    }
    
    /**
     * 	ÀúÊ·ÎļþÏÂÔزÎÊýУÑé
     */
    private void downLoadParamCheck() {
		if(null != this.fbofile) {
			if(fbofile.battgroupid < 0 ||
				fbofile.file_index >= fbofile.file_total) {				
				fbofile.setStop_reason(FialReason_ParamError);	
				fbofile.op_cmd = FGCD_ComBase.CMD_DownLoadFBDFile_Over;		//ÏÂÔؽáÊø		
				ReadTestData = false;
			}else {
				fbofile.op_cmd = FGCD_ComBase.CMD_DownLoadFBDFile_ACK;				
			}			
		}    	
	}
    
    /**
     * 	¸üе±Ç°ÏÂÔØÎļþ״̬
     * @param pool
     * @param fbofile
     */
    public void updateDownLoadState(MysqlConnPool pool,FGCD_TestFBOFile fbofile) {
    	String sql_str = " UPDATE " + Sql_Mysql.Tb_Fgcd_Filedownload_Table +
    					 " SET op_cmd = " + fbofile.op_cmd +
    					 //Ìí¼Óʧ°ÜÔ­Òò×Ö¶ÎÐÞ¸Ä
    					 " WHERE dev_id = " + fbofile.dev_id;
    	Sql_Mysql sql = null;
    	try {
    		sql = new Sql_Mysql(pool);
			sql.sqlMysqlExecute(sql_str);
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			sql.close_con();
		}
    }
    
    /**
     * 	¸üе±Ç°É豸µÄÏÂÔؽø¶È
     * @param pool
     * @param fbofile
     */
    public void updateDownLoadProgress(MysqlConnPool pool,FGCD_TestFBOFile fbofile) {
    	String sql_str = " UPDATE " + Sql_Mysql.Tb_Fgcd_Filedownload_Table +
		    			 " SET ";
    	Sql_Mysql sql = new Sql_Mysql(pool);
    	String sql_str_end = " WHERE dev_id =  " + fbofile.dev_id;
    	for(int i=0;i<fbofile.files.length;i++) {
    		if(i>0) {
    			sql_str += ",";
    		}
    		sql_str += "download_state"+(i+1)+" = "+fbofile.files[i].getDownload_state()
    				+ ",now_data_block"+(i+1)+" = "+fbofile.files[i].getNow_data_block()
    		        + ",total_data_block"+(i+1)+" = "+fbofile.files[i].getTotal_data_block();
    	}
    	sql_str += sql_str_end;
    	try {
    		//System.out.println(sql_str);
			sql.sqlMysqlExecute(sql_str);
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			sql.close_con();
		}
    }
    /**
     * 	¸üе±Ç°É豸µÄÏÂÔؽø¶È
     * @param pool
     * @param fbofile
     */
    public void updateDownLoadProgressByOne(MysqlConnPool pool,FGCD_TestFBOFile fbofile,int file_downloadNum) {
    	String sql_str = " UPDATE " + Sql_Mysql.Tb_Fgcd_Filedownload_Table +
		    			 " SET ";
    	Sql_Mysql sql = new Sql_Mysql(pool);
    	String sql_str_end = " WHERE dev_id =  " + fbofile.dev_id;    	
		sql_str += "download_state"+(file_downloadNum+1)+" = "+fbofile.files[file_downloadNum].getDownload_state()
				+ ",now_data_block"+(file_downloadNum+1)+" = "+fbofile.files[file_downloadNum].getNow_data_block()
		        + ",total_data_block"+(file_downloadNum+1)+" = "+fbofile.files[file_downloadNum].getTotal_data_block();
    	sql_str += sql_str_end;
    	try {
    		//System.out.println(sql_str);
			sql.sqlMysqlExecute(sql_str);
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			sql.close_con();
		}
    }
    
    /**
     * 	²éѯµ±Ç°É豸µÄÏÂÔؽø¶È,±ÜÃâ³öÏÖÊÖ¶¯Í£Ö¹,¿É¼°Ê±Í£Ö¹´íÎóµÄµ¼Èë
     * @param pool
     * @param fbofile
     */
    public void queryDownLoadState(MysqlConnPool pool,FGCD_TestFBOFile fbofile) {
    	String sql_str = " SELECT * FROM " + Sql_Mysql.Tb_Fgcd_Filedownload_Table +
    					 " WHERE dev_id = " + fbofile.dev_id;
    	Sql_Mysql sql = new Sql_Mysql(pool);
    	ResultSet res = null;
    	try {
			res = sql.sqlMysqlQuery(sql_str);
			if(res.next()) {
				fbofile.op_cmd = res.getInt("op_cmd");
			}   		
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			if(null != res) {
				try {
					res.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
			}
			sql.close_con();
		}
    }
    
    
    /**
     * 	Éú³ÉFBOÀúÊ·Êý¾ÝÎļþ
     */
    public boolean createFBOFile(FBOFile file){
    	boolean flag = true;
    	//System.err.println("ÎļþÊý¾Ý£º"+ComFn.bytesToHexString(filebyte, filebyte.length));
    	if(filebyte.length <0) {
    		file.download_flag = DownloadFlag_Fail;
    		return false;
    	}
    	File root = new File(System.getProperty("user.dir")+File.separator+"fbofiles"+File.separator+fbofile.dev_id);
    	if(!root.exists()) {
    		root.mkdirs();
    	}
    	fileName = root.getAbsolutePath()+File.separator+(new Date()).getTime()+".FBO";
    	//System.out.println(fileName);
    	file.filename = fileName;
    	File f = new File(fileName);
    	FileOutputStream fos = null;
    	try {
			fos = new FileOutputStream(f);
			fos.write(filebyte);
			fos.flush();
		} catch (IOException e) {
			flag = false;
			e.printStackTrace();
		} finally {
			if(null != fos) {
				try {
					fos.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
		}   	
    	return flag;
    }
    	
    /**
     * 	½âÎöFBOÎļþÏß³Ì
     * @author LiJun
     *
     */
    public class ParseFboThread extends Thread{
    	public MysqlConnPool pool; 
    	public int port_index;
    	public FGCD_TestFBOFile fbofile;
    	
    	public ParseFboThread(MysqlConnPool pool,int index,FGCD_TestFBOFile fbofile){
    		this.pool = pool;
    		this.port_index = index;
    		this.fbofile = fbofile;
    	}
    	
    	@Override
    	public void run() {
    		
    	}
    	
    }
}