package com.backup;

import java.io.File;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Comparator;
import java.util.Date;
import java.util.List;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

import com.base.Com;
import com.config.AppConfig;
import com.sql.MysqlConnPool;

import main.main_FBS9100S_DataBaseBackUp;

public class DataBaseBackUpThread extends Thread{
	public static final int REGULAR_BACKUP_MAXCOUNT = 3;								//¶¨Ê±±¸·Ý±ÊÊý
	public static final int INSTANT_BACKUP_MAXCOUNT = 10;								//˲¼ä±¸·Ý±ÊÊý
	public static final String REGULAR_BACKUP_PATHNAME = "REGULAR_BACKUP";				//¶¨ÆÚ±¸·ÝÎļþ¼ÐÃû³Æ
	public static final String INSTANT_BACKUP_PATHNAME = "INSTANT_BACKUP";				//˲¼ä±¸·ÝÎļþ¼ÐÃû³Æ
	
	private List<DatabaseTable> list = new ArrayList<DatabaseTable>();
	private MysqlConnPool pool;
	private String savePath = System.getProperty("user.dir")+ File.separator+"mysql_backup";			//±¸·ÝÊý¾Ý¿âµÄ¸ùĿ¼
	private MyRunTime runtime = null;
	private AppConfig appcfg;
	
	public DataBaseBackUpThread(MysqlConnPool conn_pool,AppConfig appcfg){
		this.pool = conn_pool;
		this.appcfg = appcfg;
		
		this.runtime = new MyRunTime(this.pool);
		
		DataBaseBackUpThread_SQL.createBackupTable(pool); 															//³õʼ»¯Êý¾Ý¿â±í
		
		this.list = DataBaseBackUpThread_SQL.searchAllDataBaseAndTable(pool);										//²éѯÊý¾Ý¿âÖеÄËùÓбí(³ýÈ¥mysqlÖÐ×Ô´øµÄÊý¾Ý¿â)
		
		DataBaseBackUpThread_SQL.inseartBackupTable(pool,list);														//²åÈëËùÓеÄÊý¾Ý¿â±í½á¹¹µ½Êý¾Ý¿âÖÐ	
	
		//DataBaseBackUpThread_SQL.DataBaseBackUp_StartTime(pool,main_FBS9100S_DataBaseBackUp.m_VersionNum);		//¼Ç¼µ±Ç°Ï̵߳İ汾ºÅºÍµ±Ç°Ï̵߳ÄÆô¶¯Ê±¼ä

	}
	
	
	
	
	@Override
	public void run() {		
		System.out.println(this.getName() + " - DataBaseBackUpThread  start at "+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
		Date lastRecodTime = new Date(2000,1,1);
		Date normTime = null;
		Date nowTime = null;
		while(true){
			try {
				nowTime = new Date();
				normTime = createNomalDate(nowTime);
				//System.out.println();
				
				//12µã59·Ö¿ªÊ¼±¸·ÝËùÓеÄÊý¾Ý¿â
				if(countTimeLong(nowTime, normTime)<30 || countTimeLong(lastRecodTime, nowTime) >= 7*24*60*60) {
					System.out.println("¿ªÊ¼±¸·ÝËùÓеÄÊý¾Ý¿â"+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
					this.list = DataBaseBackUpThread_SQL.searchAllDataBaseAndTable(pool);
					String path = savePath+File.separator+REGULAR_BACKUP_PATHNAME;
					deleteFileRoot(path,REGULAR_BACKUP_MAXCOUNT);							//ɾ³ý³¬¹ý¼Ç¼±ÊÊýµÄ±¸·Ý¼Ç¼(×î¶àÈý±Ê)
					path += File.separator+Com.getDateTimeFormat(nowTime, Com.DTF_YMD_h_m_s);
					for(int i=0;i<this.list.size();i++) {
						DatabaseTable table = list.get(i);
						if(DataBaseBackUpThread_SQL.isSpecialChar(table.getDatabase_name()) || DataBaseBackUpThread_SQL.isSpecialChar(table.getTable_name())) {
							continue;															//Ìø¹ýº¬ÓÐÌØÊâ×Ö·ûµÄÊý¾Ý¿âÃûºÍ±íÃû
						}
						String rootPath = path+File.separator+list.get(i).getDatabase_name();
						craeteFileRoot(rootPath);
						runtime.exec(list.get(i).getDatabase_name(), list.get(i).getTable_name(),rootPath);					//±¸·ÝÖ¸¶¨µÄÊý¾Ý¿â
					}					
					lastRecodTime = nowTime;
					DataBaseBackUpThread_SQL.inseartBackupTable(pool,list);
					
					ZipUtil zipUtil = new ZipUtil();
					String zipName = path+".zip";
					File zipFile = zipUtil.createZip(zipName, new File(path));	//ѹËõÊý¾Ý¿âÎļþ
					
					
					HzipSocket SocketClient = new HzipSocket(appcfg);
					SocketClient.init(zipName);							//·¢ËÍÊý¾Ý¿â±¸·ÝÎļþµ½Ô¶³Ì·þÎñÆ÷
					System.out.println("Ô¶³Ì±¸·ÝÊý¾Ý¿âÍê³É" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
					if(zipFile.exists() && zipFile.length() > 1*1024 && new File(path).exists()) {
						deleteDir(new File(path));
					}
				}
				
				//²éѯËùÓÐÐèÒª±¸·ÝÖ¸¶¨Êý¾Ý¿âµÄ¼Ç¼
				list = DataBaseBackUpThread_SQL.searAllTableState(pool);													//²éѯµ±Ç°ÐèÒª±¸·ÝµÄ±íµÄ¼Ç¼
				if(list.size() > 0){
					String root = savePath+File.separator+INSTANT_BACKUP_PATHNAME;
					String path = root + File.separator+Com.getDateTimeFormat(nowTime, Com.DTF_YMD_h_m_s);
					int count = 0;
					for(int i = 0 ; i < list.size() ; i++){
						DatabaseTable table = list.get(i);
						if(DataBaseBackUpThread_SQL.isSpecialChar(table.getDatabase_name()) || DataBaseBackUpThread_SQL.isSpecialChar(table.getTable_name())) {
							continue;
						}
						deleteFileRoot(root, INSTANT_BACKUP_MAXCOUNT);									//ɾ³ý³¬¹ý±¸·Ý±ÊÊýµÄ±¸·ÝÊý¾Ý
						count ++;
						String rootPath = path+File.separator+table.getDatabase_name();
						craeteFileRoot(rootPath);																			//´´½¨Ö¸¶¨µÄÎļþ¼Ð
						// System.out.println(rootPath);
						//Ö´Ðб¸·Ý
						boolean flag = runtime.exec(table.getDatabase_name(), table.getTable_name(),rootPath);
						// System.out.println("dbname:"+table.getDatabase_name()+"\t tname"+table.getTable_name()+"\ten="+flag);
						if(flag){
							//±¸·ÝÍê³ÉÖ®ºóÐ޸ļǼµÄ״̬
							table.setBack_en(DatabaseTable.MYSQL_BACKUP_OVER);										//±¸·ÝÍê³É
							DataBaseBackUpThread_SQL.UpdateDataBaseState(pool, table);
						}
					}					
					
					if( count > 0) {
						ZipUtil zipUtil = new ZipUtil();
						String zipName = path+".zip";
						File zipFile = zipUtil.createZip(zipName, new File(path));	//ѹËõÊý¾Ý¿âÎļþ
						if(zipFile.exists() && zipFile.length() > 1*1024 && new File(path).exists()) {
							deleteDir(new File(path));
						}
						System.out.println("¿ªÊ¼±¸·Ý"+count+"¸ö±í    at "+Com.getDateTimeFormat(nowTime, Com.DTF_YMD_h_m_s));
					}
				}				
				sleep(500);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}		
	}
	
	/**
	 * 	¹¹Ôì½ñÌìµÄ23:59:30
	 * @return
	 */
	public static Date createNomalDate(Date time) {
		String time_str = Com.getDateTimeFormat(time, Com.DTF_YMD) + " 23:59:30";
		//System.out.println(time_str);
		return Com.getDateTimeFromStr(time_str, Com.DTF_YMDhms);
	}
	
	/**
	 *	 ¼ÆËãÁ½¸öʱ¼äÖ®¼äµÄ¼ä¸ôÃëÊý
	 * @param start
	 * @param end
	 * @return
	 */
	public long countTimeLong(Date start,Date end){
		return (Math.abs(end.getTime()-start.getTime())/1000);
	}
	
	/**
	 * 	´´½¨Ö¸¶¨µÄÎļþ¼Ð
	 */
	public static void craeteFileRoot(String filepath) {
		File f = new File(filepath);
		if(!f.exists()) {
			f.mkdirs();
		}
	}
	
	/**
	 * ±£Áôµ±Ç°Ä¿Â¼ÖеÄÖ¸¶¨ÊýÄ¿µÄÎļþ¼Ð			(ɾ³ýµ±Ç°Îļþ¼ÐϵÄ×îÔç֮ǰµÄ±¸·ÝÊý¾Ý)
	 * @param filePath				ÐèÒª±¸·ÝÊý¾ÝµÄÎļþ¼Ð
	 * @param filecount				 ±¸·ÝÊý¾ÝµÄ±ÊÊý
	 */
	public static void deleteFileRoot(String filePath,int filecount) {
		File file = new File(filePath);
		if(file.exists()) {
			File[] files = file.listFiles();
			Arrays.sort(files, new CompratorByLastModified());
			if(files.length>=filecount && filecount>0) {
				//System.out.println("Îļþ¼Ð¸öÊý£º"+files.length + "\t ×î´ó±ÊÊý£º"+filecount);
				for(int i=(filecount-1);i<files.length;i++) {
					deleteDir(files[i]);
				}
			}
		}
	}
	
	
	
    
	public static void main(String[] args) {
		deleteFileRoot("d:/aaaa",6);
	}
	
	//±È½ÏÁ½¸öÎļþ¼ÐϵÄÎļþ
	static class CompratorByLastModified implements Comparator<File> {
		public int compare(File f1, File f2) {
			long diff = f1.lastModified() - f2.lastModified();
			if (diff > 0) {
				return -1;//µ¹ÐòÕýÐò¿ØÖÆ
			}else if (diff == 0) {
				return 0;
			}else {
				return 1;//µ¹ÐòÕýÐò¿ØÖÆ
			}
		}
	}
	
	/**
     * 	µÝ¹éɾ³ýĿ¼ÏµÄËùÓÐÎļþ¼°×ÓĿ¼ÏÂËùÓÐÎļþ
     * @param dir ½«ÒªÉ¾³ýµÄÎļþĿ¼
     * @return boolean Returns "true" if all deletions were successful.
     *                 If a deletion fails, the method stops attempting to
     *                 delete and returns "false".
     */
    private static boolean deleteDir(File dir) {
        if (dir.isDirectory()) {
            String[] children = dir.list();
            //µÝ¹éɾ³ýĿ¼ÖеÄ×ÓĿ¼ÏÂ
            for (int i=0; i<children.length; i++) {
                boolean success = deleteDir(new File(dir, children[i]));
                if (!success) {
                    return false;
                }
            }
        }
        // Ŀ¼´ËʱΪ¿Õ£¬¿ÉÒÔɾ³ý
        return dir.delete();
    }
}