package com.dev.base.data;

import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.List;

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

public class Dynamicload_RealDataRecord_Thread implements Runnable{
	public static final int TESTDATA_RECORD_INTERVAL = 1;				//¼Ç¼Êý¾Ý¼ä¸ô
	public static final int MAX_SAVE_DAY_COUNT = 180;
	
	
	public MysqlConnPool pool;
	public List<TestData_Record_Thread> threads;
	public List<Dynamicload_inf> dinfs;
	
	public Dynamicload_RealDataRecord_Thread(MysqlConnPool pool,List<Dynamicload_inf> dinfs){
		this.pool = pool;
		this.dinfs = dinfs;
		threads = new ArrayList<>();
	}
	
	@Override
	public void run() {
		System.out.println("Dynamicload_RealDataRecord_Thread Start at "+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
		Date now = null;
		Date last = new Date(0);
		while(true) {
			try {
				now = new Date();
				
				for(int i=0;i<dinfs.size();i++) {
					boolean isExist = false;
					Dynamicload_inf dinf = dinfs.get(i);
					for(int k=0;k<threads.size();k++) {
						if(threads.get(k).dinf.dev_id == dinf.dev_id) {
							isExist = true;
							break;
						}
					}
					if(!isExist) {
						TestData_Record_Thread thread = new TestData_Record_Thread(pool, dinf);
						threads.add(thread);
						new Thread(thread).start();
					}
					
					//¹¹Ôì½ñÌìºÍÃ÷ÌìµÄÀúʷʵʱÊý¾Ý±í
					Dynamicload_Task_SQL.createTb_Dynamicload_realdata(pool, dinf.dev_id, now);
					Dynamicload_Task_SQL.createTb_Dynamicload_realdata(pool, dinf.dev_id, tomorrow(now));
				
				}
				Date del_time = getDateBefore(now,MAX_SAVE_DAY_COUNT);
				Dynamicload_Task_SQL.deleteHistoryData(pool, del_time);
				//System.out.println(Com.getDateTimeFormat(del_time, Com.DTF_YMDhms));
				Thread.sleep(3000);
			} catch (Exception e) {
				try {
					Thread.sleep(5000);
				} catch (InterruptedException e1) {
					e1.printStackTrace();
				}
				e.printStackTrace();
			}
		}
	
	}

	class TestData_Record_Thread implements Runnable{
		public MysqlConnPool pool;
		public Dynamicload_inf dinf;
		
		public TestData_Record_Thread(MysqlConnPool pool,Dynamicload_inf dinf) {
			this.pool = pool;
			this.dinf = dinf;
		}
		
		@Override
		public void run() {
			Date last = new Date(0);		//ÉÏÒ»´Î²âÊÔµÄʱ¼ä
			Date now = null;				//µ±Ç°Ê±¼ä
			
			while(true) {
				try {
					now = new Date();
					long timelong = (now.getTime()-last.getTime())/1000;
					//System.out.println(timelong);
					if(timelong >= TESTDATA_RECORD_INTERVAL) {
						if(dinf.conn_state == 1) {
							//ͨѶÕý³£
							Dynamicload_Task_SQL.insertTb_dynamicload_realdata(pool, dinf, now);
							last = now;
						}
					}					
					Thread.sleep(10);
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		}
	}
	
	/**
	 * 	·µ»ØÃ÷ÌìÈÕÆÚ
     * @param today
     * @return
     */
    public Date tomorrow(Date today) {
        Calendar calendar = Calendar.getInstance();
        calendar.setTime(today);
        calendar.set(Calendar.DATE, calendar.get(Calendar.DATE) + 1);
        return calendar.getTime();
    }
    
    /**
     * »ñÈ¡Ö¸¶¨Ê±¼ä֮ǰ¶àÉÙÌìµÄʱ¼ä
     * @param d
     * @param day
     * @return
     */
    public static Date getDateBefore(Date d,int day){
		Calendar now =Calendar.getInstance();
		now.setTime(d);
		now.set(Calendar.DATE,now.get(Calendar.DATE)-day);
		return now.getTime();
	}
}