package com.dev.data;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.TimeZone;

import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPClientConfig;
import org.apache.commons.net.ftp.FTPReply;
import com.base.Com;
import com.config.AppConfig;

/**
 * 	¶ÁÈ¡ÅäÖÃÎļþ
 * @author LiJun
 *
 */
public class ReadConfigFile {
	//±¾µØÅäÖÃÎļþĿ¼[ΪÁ˽â¾ö¿Í»§¶ËÆô¶¯Ê±²»ÄÜÁ¬½Óµ½ftp·þÎñÆ÷ʱbug]
	public static String cfgpath = System.getProperty("user.dir") + File.separator + "config/RealList.txt";
	
	//ϵͳÀàÐÍ
	public static final int ZIZHAN_SYS_TYPE = 1;
	public static final int ZHONGDUAN_SYS_TYPE = 2;
	
	
	private static String FileRoot = "/config/";				//Êý¾Ý¸ùĿ¼
	public String battName = "";
	public FTPClient ftp;
	public String filename = "RealList.txt";
	public String server_ip = "192.168.7.130";		//É豸ipµØÖ·
	public String userNmae  = "ftp";				//ĬÈÏftpÓû§Ãû
	public String passWord  = "";					//ĬÈÏÓû§ÃÜÂë
	public int port = 21;							//ĬÈ϶˿Ú
	public Map<Integer, String> sysTypes = new HashMap<Integer, String>(){ 
		{ 
			put(ZIZHAN_SYS_TYPE,"×Óվϵͳ"); put(ZHONGDUAN_SYS_TYPE,"ÖÕ¶Ë");
		}
	};
	
	public ReadConfigFile() {
		
	} 
	
	public List readConfigData() {
		List configs = new ArrayList();
		boolean flag = false;
		try {
			System.out.println(cfgpath);
			if(ftpLogin(server_ip, port, userNmae, passWord)) {
				
				flag = true;
				judeFileExists(cfgpath);
				
				parseConfigFile(configs);
			}
			//System.err.println(configs.size());
			if(configs.size()<1){
				System.out.println("½âÎö±¾µØÅäÖÃÎļþ¡£¡£¡£");
				//µÇ½ftp·þÎñÆ÷ʧ°Ü,δ½âÎöµ½ÅäÖÃÎļþ,½âÎö±¾µØÎļþ
				parseLocalConfigFile(configs);
			}else {
				System.out.println("½âÎöÅäÖÃÎļþ³É¹¦"+configs.size());
			}
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			try {
				//½âÎöÍê³ÉÍ˳öftpÁ¬½Ó
				disConnection();
			} catch (IOException e) {
				e.printStackTrace();
			}
			if(flag) {
				System.out.println("µÇ½ftp·þÎñÆ÷³É¹¦ip:"+server_ip+";file:"+FileRoot+filename+";name:"+userNmae+";pass:"+passWord+";port:"+port+"; at "+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));				
			}else {
				System.out.println("µÇ½ftp·þÎñÆ÷ʧ°Üip:"+server_ip+";file:"+FileRoot+filename+";name:"+userNmae+";pass:"+passWord+";port:"+port+"; at "+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));				
			}
		}
		return configs;
	}
	
	/**
	 * 	¶ÁÈ¡FTPÅäÖÃÎļþ
	 * @param temp
	 */
	public void parseConfigFile(List temp) {
		if (FileRoot.startsWith("/") && FileRoot.endsWith("/")) {
            //¸ü»»Ä¿Â¼µ½µ±Ç°Ä¿Â¼
            StringBuilder stringBuilder;
            InputStream inputStream = null;
            OutputStream outputStream = null;
            BufferedReader bufferedReader = null;
            BufferedWriter bufferedWrite = null;
			try {
				this.ftp.changeWorkingDirectory(FileRoot);
				// ÐèÒª¼Ó´ËÅжϡ£·ñÔò£¬ftpĬÈϽ«¡®ÏîÄ¿ÎļþËùÔÚĿ¼֮ϵÄĿ¼£¨./£©¡¯Óë¡®ÏîÄ¿ÎļþËùÔÚĿ¼ÏòÉÏÒ»¼¶Ä¿Â¼ÏµÄĿ¼£¨../£©¡¯¶¼ÄÉÈëµÝ¹é£¬ÕâÑùÏÂÈ¥¾ÍÏÝÈëÒ»¸öËÀÑ­»·ÁË¡£Ð轫Æä¹ýÂ˵ô¡£
				inputStream = this.ftp.retrieveFileStream(filename);//¸ù¾ÝÖ¸¶¨Ãû³Æ»ñÈ¡Ö¸¶¨Îļþ
				bufferedReader = new BufferedReader(new InputStreamReader(inputStream,"GBK"));
				outputStream = new FileOutputStream(new File(cfgpath));
				bufferedWrite = new BufferedWriter(new OutputStreamWriter(outputStream,"GBK"));
				String line=null;
				stringBuilder = new StringBuilder(150);
				int count = 0;
				while ((line = bufferedReader.readLine()) != null)
				{
					bufferedWrite.write(line);
					bufferedWrite.newLine();
					bufferedWrite.flush();
				    stringBuilder.delete( 0, stringBuilder.length() );
				    stringBuilder.append(line);
				    readConfigTxt(stringBuilder,temp);
				}
			} catch (Exception e) {
				e.printStackTrace();
			} finally {
				try {
					if(bufferedReader != null) {
						bufferedReader.close();
					}
					if(inputStream != null) {
						inputStream.close();
					}
					if(bufferedWrite != null) {
						bufferedWrite.close();
					}
					if(outputStream != null) {
						outputStream.close();
					}
				} catch (IOException e) {
					e.printStackTrace();
				}
			}

        }
	}
	
	/**
	 * 	¶ÁÈ¡±¾µØÅäÖÃÎļþ
	 * @param temp
	 */
	public void parseLocalConfigFile(List temp) {
		File file = new File(cfgpath);
		System.out.println(cfgpath);
		if (file.exists()) {
            //¸ü»»Ä¿Â¼µ½µ±Ç°Ä¿Â¼
            StringBuilder stringBuilder;
            InputStream inputStream = null;
            BufferedReader bufferedReader = null;
			try {
				// ÐèÒª¼Ó´ËÅжϡ£·ñÔò£¬ftpĬÈϽ«¡®ÏîÄ¿ÎļþËùÔÚĿ¼֮ϵÄĿ¼£¨./£©¡¯Óë¡®ÏîÄ¿ÎļþËùÔÚĿ¼ÏòÉÏÒ»¼¶Ä¿Â¼ÏµÄĿ¼£¨../£©¡¯¶¼ÄÉÈëµÝ¹é£¬ÕâÑùÏÂÈ¥¾ÍÏÝÈëÒ»¸öËÀÑ­»·ÁË¡£Ð轫Æä¹ýÂ˵ô¡£
				inputStream = new FileInputStream(file);//¸ù¾ÝÖ¸¶¨Ãû³Æ»ñÈ¡Ö¸¶¨Îļþ
				bufferedReader = new BufferedReader(new InputStreamReader(inputStream,"GBK"));
				String line=null;
				stringBuilder = new StringBuilder(150);
				int count = 0;
				while ((line = bufferedReader.readLine()) != null)
				{
				    stringBuilder.delete( 0, stringBuilder.length() );
				    stringBuilder.append(line);
				    readConfigTxt(stringBuilder,temp);
				}
			} catch (IOException e) {
				e.printStackTrace();
			} finally {
				try {
					if(bufferedReader != null) {
						bufferedReader.close();
					}
					if(inputStream != null) {
						inputStream.close();
					}
				} catch (IOException e) {
					e.printStackTrace();
				}
			}

        }
	}
	
	/**
	 * ½âÎö×Ö·û´®ÖеÄÎļþÐÅÏ¢
	 * @param str
	 * @param devices
	 */
	public void readConfigTxt(StringBuilder str,List devices) {
		if(null != str) {
			 /* ÕÒ³öÖ¸¶¨µÄ2¸ö×Ö·ûÔÚ ¸Ã×Ö·û´®ÀïÃæµÄ λÖà */
	        int StartIndex = str.indexOf("@");
	        int EndIndex = str.lastIndexOf("$");
	        if(StartIndex >= 0 && EndIndex >=0 && str.length() > 18) {
	        	String[] s = str.substring(StartIndex+1,EndIndex).split(",");
	        	ConfigData temp = new ConfigData();
	        	temp.dev_number = Integer.parseInt(s[0].trim());	//Êý¾Ý±àºÅ
	        	temp.data_value = s[1].trim();						//Êý¾ÝÃû³Æ
	        	temp.unit = s[2].trim();							//µ¥Î»
	        	temp.value_min = Float.parseFloat(s[3]);			//×îСֵ
	        	temp.value_max = Float.parseFloat(s[4]);			//×î´óÖµ
	        	temp.dataacc = Float.parseFloat(s[5]);				//¾«¶È(1->ÕûÊý£»10->0.1;100->0.01)
	        	temp.alm_num1 = Integer.parseInt(s[6].trim());		//±¨¾¯1±àºÅ
	        	temp.alm_num1_value = Float.parseFloat(s[7]);		//±¨¾¯1¸æ¾¯Öµ
	        	temp.alm_num2 = Integer.parseInt(s[8].trim());		//±¨¾¯2±àºÅ	
	        	temp.alm_num2_value = Float.parseFloat(s[9]);		//±¨¾¯2¸æ¾¯Öµ
	        	temp.varname = s[10].trim();						//±äÁ¿Ãû³Æ
	        	//System.out.println(temp.dev_number+"====="+temp.varname);
	        	if(temp.varname.indexOf(":") >0) {
	        		temp.vname = temp.varname.substring(0, temp.varname.indexOf(":"));							//É豸±êʶ·û
	        	}
	        	temp.macsource = s[11].trim();						//ʵʱÊý¾Ý¿âËù´¦¼ÆËã»ú
	        	temp.datasource = s[12].trim();						//Êý¾ÝÔ´
	        	temp.dataaccess = s[13].trim();						//»ñȡ;¾¶
	        	temp.vartype = Integer.parseInt(s[14].trim());		//±äÁ¿ÀàÐÍ(1¡ª>Ä£ÄâÁ¿;2->¿ª¹ØÁ¿;3->״̬Á¿)
	        	temp.wanlogo = s[15].trim();						//ÒÔÌ«Íø±êʶ
	        	temp.frameposit = Integer.parseInt(s[16].trim());	//Ö¡ÖÐλÖÃ
	        	temp.defalutval = Float.parseFloat(s[17].trim());	//ĬÈÏÖµ
	        	temp.codename = s[18].trim();						//´úºÅ
	        	devices.add(temp);
	        	//System.out.println(temp);
	        }
		}
	}
	
	//·ÖÎöÅäÖÃÎļþÖеĽṹ
	public List<Device_inf> analyConfigFile(List<ConfigData> source,List<Device_inf> devices,List<ConfigData> cfgs) {
		//List<Device_inf> devices = new ArrayList<Device_inf>();
		boolean flag = false;
		int dev_id = 1001; 
		int sys_type = 1;
		System.out.println(source.size());
		for(int i = 0;i<source.size();i++) {
			flag = false;
			for(int j=0;j<devices.size();j++) {
				//×°Åä×ÓÕ¾Êý¾ÝÐÅÏ¢
				if(source.get(i).vname.equals(devices.get(j).dev_str) && devices.get(j).dev_id<2000){
					flag = true;
				}
				
				
				//×°Åä×ÓÕ¾Êý¾Ý
				if("6".equals(source.get(i).wanlogo) && devices.get(j).dev_id/100 == 40) {
					
					//System.out.println(source.get(i).wanlogo+"===="+source.get(i).dev_number);
					//1ºÅÆûÂÖ·¢µç»úÊý¾Ý
					if(devices.get(j).dev_id%4000 == 1 && ((source.get(i).data_value.indexOf("1ºÅ")==0) ||(source.get(i).data_value.indexOf("1#")==0))) {
						cfgs.add(source.get(i));
						flag = true;
					}
					//2ºÅÆûÂÖ·¢µç»úÊý¾Ý
					if(devices.get(j).dev_id%4000 == 2 && ((source.get(i).data_value.indexOf("2ºÅ")==0) ||(source.get(i).data_value.indexOf("2#")==0))) {
						cfgs.add(source.get(i));
						flag = true;
					}
				}
				if(flag) {
					if(source.get(i).vartype == Device_inf.ANALOG_DATATYPE) {
						devices.get(j).addAnalog_count();
					}else if(source.get(i).vartype == Device_inf.SWITCH_DATATYPE) {
						devices.get(j).addSwitch_count();
					}else if(source.get(i).vartype == Device_inf.STATE_DATATYPE) {
						devices.get(j).addState_count();
					}
					devices.get(j).cfgdatas.add(source.get(i));
					break;
				}
				
			}
			//ɸѡµôÖÕ¶ËÊý¾Ý
			if(!flag && !source.get(i).macsource.equals("ÖÕ¶Ë") && !source.get(i).macsource.contains("¿ØÖÆ°å")) {				
				//System.err.println(i+"======" + source.get(i).vname+"==="+source.get(i).macsource+"==="+source.get(i).data_value);
				
				//еÄÉ豸ÐͺÅ
				Device_inf device = new Device_inf();
				device.dev_id = dev_id++;
				device.dev_name = source.get(i).macsource;		//É豸Ãû³Æ
				if(source.get(i).vname.contains("SN")) {
					//×Óվϵͳ
					device.sys_type = ZIZHAN_SYS_TYPE;
					device.sys_name = sysTypes.get(ZIZHAN_SYS_TYPE); 
				}else if(source.get(i).vname.contains("0") || device.sys_name.equals("")) {
					device.sys_type = ZHONGDUAN_SYS_TYPE;
					device.sys_name = sysTypes.get(ZHONGDUAN_SYS_TYPE);
				}
				device.sys_ident= source.get(i).vname;			//ϵͳ±êʶ·û
				
				if(source.get(i).vartype == Device_inf.ANALOG_DATATYPE) {
					device.addAnalog_count();
				}else if(source.get(i).vartype == Device_inf.SWITCH_DATATYPE) {
					device.addSwitch_count();
				}else if(source.get(i).vartype == Device_inf.STATE_DATATYPE) {
					device.addState_count();
				}
				device.cfgdatas.add(source.get(i));
				devices.add(device);
			}
		}
		return devices;
	}
	
	
	
	/**
     * ÖØÔع¹Ô캯Êý
     *
     * @param isPrintCommmand ÊÇ·ñ´òÓ¡ÓëFTPServerµÄ½»»¥ÃüÁî
     */
    public ReadConfigFile(AppConfig config) {
    	server_ip = config.getEquie_device_ftp_ip();
    	port = config.getEquie_device_ftp_port();
    	userNmae = config.getEquie_device_ftp_username();
    	passWord = config.getEquie_device_ftp_password();
    	FileRoot = config.getEquie_device_ftp_file_path();
    	
    	ftp = new FTPClient();
    }

    /**
     * 	µÇ½FTP·þÎñÆ÷
     *
     * @param host     FTPServer IPµØÖ·
     * @param port     FTPServer ¶Ë¿Ú
     * @param username FTPServer µÇ½Óû§Ãû
     * @param password FTPServer µÇ½ÃÜÂë
     * @return ÊÇ·ñµÇ¼³É¹¦
     * @throws IOException
     */
    public boolean login(String host, int port, String username, String password) throws IOException {
        try {
			this.ftp.connect(host, port);
			if (FTPReply.isPositiveCompletion(this.ftp.getReplyCode())) {
			    if (this.ftp.login(username, password)) {
			        /**
				                        ÐèҪעÒâÕâ¾ä´úÂ룬Èç¹ûµ÷ÓÃList()·½·¨³öÏÖ£¬ÎļþµÄÎÞÏߵݹ飬ÓëÕæʵĿ¼½á¹¹²»Ò»ÖµÄʱºò£¬¿ÉÄܾÍÊÇÒòΪתÂëºó£¬¶Á³öÀ´µÄÎļþ¼ÐÓëÕýʽÎļþ¼Ð×Ö·û±àÂë²»Ò»ÖÂËùµ¼Ö¡£
				                        ÔòÐèÈ¥µôתÂ룬¾¡¹ÜµÝ¹éÊdzöÏÖÂÒÂ룬µ«¶Á³öµÄÎļþ¾ÍÊÇÕæʵµÄÎļþ£¬²»»áËÀµô¡£µÈ¶ÁÍêÖ®ºóÔÙ¸ù¾ÝÇé¿ö½øÐÐתÂë¡£
				                        Èç¹ûftp²¿ÊðÔÚwindowsÏ£¬Ôò£º
				         for (String arFile : f.arFiles) {
					         arFile = new String(arFile.getBytes("iso-8859-1"), "GBK");
					         logger.info(arFile);
				         }
			         */
			    	ftp.enterLocalPassiveMode();		//ÉèÖóɱ»¶¯Ä£Ê½
			        this.ftp.setControlEncoding("utf-8");
			        return true;
			    }
			}
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
//			if (this.ftp.isConnected()) {
//				this.ftp.disconnect();
//			}
		}
        return false;
    }

    /** 
     * @return ÅжÏÊÇ·ñµÇÈë³É¹¦ 
     * */  
    public boolean ftpLogin(String strIp,int intPorts,String username,String password) {
        boolean isLogin = false;
        FTPClientConfig ftpClientConfig = new FTPClientConfig();
        ftpClientConfig.setServerTimeZoneId(TimeZone.getDefault().getID());
        this.ftp.setControlEncoding("GBK");
        this.ftp.configure(ftpClientConfig);
        try {
            if (intPorts > 0) {
                this.ftp.connect(strIp, intPorts);
            }else {
                this.ftp.connect(strIp);
            }
            // FTP·þÎñÆ÷Á¬½Ó»Ø´ð  
            int reply = this.ftp.getReplyCode();
            if (!FTPReply.isPositiveCompletion(reply)) {
                this.ftp.disconnect();
                return isLogin;
            }
            this.ftp.login(username, password);
            // ÉèÖô«ÊäЭÒé  
            this.ftp.enterLocalPassiveMode();
            this.ftp.setFileType(FTPClient.BINARY_FILE_TYPE);
            
            //System.out.println(this.ftpClient.getSystemType());
            // »ñÈ¡µÇ¼ÐÅÏ¢
            //FTPClientConfig config = new FTPClientConfig(this.ftpClient.getSystemType().split(" ")[0]);
            FTPClientConfig config = new FTPClientConfig(FTPClientConfig.SYST_OS2);
            config.setServerLanguageCode("zh");
            this.ftp.configure(config);
            // ʹÓñ»¶¯Ä£Ê½ÉèΪĬÈÏ
            //this.ftpClient.enterLocalPassiveMode();
            //System.out.println("999999999999999");
            isLogin = true;
        }catch (Exception e) {
            isLogin = false;
        	e.printStackTrace();
        }
        //this.ftpClient.setBufferSize(1024 * 800);
        //this.ftpClient.setDataTimeout(120 * 1000);
        return isLogin;
    }
    
    /**
     * ¹Ø±ÕÊý¾ÝÁ´½Ó
     *
     * @throws IOException
     */
    public void disConnection() throws IOException {
        if (this.ftp.isConnected()) {
            this.ftp.disconnect();
        }
    }
    
    // ÅжÏÎļþÊÇ·ñ´æÔÚ
     public static void judeFileExists(String filepath) {
    	 File file = new File(filepath);
         if (file.exists()) {
             //ÎļþÒÑ´æÔÚ
         } else {
             //System.out.println("file not exists, create it ...");
             try {
            	 File fileParent = file.getParentFile();
            	 if(!fileParent.exists()){
            	     fileParent.mkdirs();
            	 }
                 file.createNewFile();
             } catch (IOException e) {
                // TODO Auto-generated catch block
                 e.printStackTrace();
             }
         } 
     }
   
	public static void main(String[] args) {
		//ReadConfigFile util = new ReadConfigFile();
		
		//util.readBattTestData("Default_Battery","F2017-01-14 18.40.44.FBO");
		

		
	}
}