package com.table.alarm;

import java.sql.Connection;
import java.util.Date;
import java.util.List;

import com.mysql_param.Alarm_Delparam;
import com.mysql_param.Mysql_database_param;
import com.table.badbatt.BadBatt_thread;
import com.table_sql.MySqlPool;

public class Alarm_thread extends Thread{
	private MySqlPool m_ConnPool = null;
	private Connection conn=null;
	private String deleteSql="";
	
	public Alarm_thread(MySqlPool m_ConnPool) {
		super();
		this.m_ConnPool = m_ConnPool;
	}
	public boolean timedeleteSql(int timelong,MySqlPool m_ConnPool_){
		String sql="delete from  "+Mysql_database_param.db_alarm+Mysql_database_param.tb_battalarm_data_history+" "
				+ " where DATEDIFF(curdate(),alm_start_time)>="+timelong;
		Connection conn=m_ConnPool_.getConn();
		boolean bl=m_ConnPool_.sqlMysqlUpdate(conn, sql);
		return bl;
	}
	//Ð޸Ľø³Ì¼à¿Ø±íÖеÄʵʱʱ¼ä
	public boolean processupdateSql(Date nowdate,String ProcessName,MySqlPool m_ConnPool_){
		String sql=" update  "+Mysql_database_param.web_site+Mysql_database_param.tb_Process_survey+" "
				+" set ProcessTime='"+BadBatt_thread.sdf.format(nowdate)
				+"' where ProcessName='"+ProcessName+"'";
		Connection conn=m_ConnPool_.getConn();
		//System.out.println(sql);
		boolean bl=m_ConnPool_.sqlMysqlUpdate(conn, sql);
		return bl;
	}
	//ɾ³ýµç³Ø¸æ¾¯±íÖÐÓëÏÖÔÚʱ¼äÏà±È£¬²î¾àΪn¸öÔµÄÊý¾Ý
	public void run() {
		System.out.println("Æô¶¯µç³Ø¸æ¾¯±í¶¨Ê±É¾³ý!------alarm_threadÆô¶¯");
		//deleteSql=this.timedeleteSql(Alarm_Delparam.delete_time);
		//System.out.println(deleteSql);
		boolean flag=true;
		while(flag){
			try {
				boolean bl=timedeleteSql(Alarm_Delparam.delete_time, m_ConnPool);
				System.out.println("¸æ¾¯Ị̈߳º"+BadBatt_thread.sdf.format(new Date())+"    alarm_thread:"+bl);
				//Ð޸Ľø³Ì¼à¿Ø±íÖеÄʵʱʱ¼ä
				boolean b=processupdateSql(new Date(),Mysql_database_param.BMS_FBSDEV_BADBATT_CAP, m_ConnPool);
				Thread.sleep(1000*60);
			} catch (InterruptedException e) {
				e.printStackTrace();
				flag=false;
			}
		}
		//System.out.println("thread stop!");
	 }
	public static void main(String[] args) {
		MySqlPool mPool=new MySqlPool();
		Connection conn=mPool.getConn();
		Alarm_thread alarm_t=new Alarm_thread(mPool);
		//alarm_t.deleteSql=alarm_t.timedeleteSql(Alarm_param.delete_time);
		alarm_t.start();
	}
}