package main;

import java.sql.Connection;
import java.util.ArrayList;
import java.util.Date;
import java.util.TimeZone;

import com.mysql_param.Mysql_database_param;
import com.table.alarm.AlarmDaoFactory;
import com.table.alarm.Alarm_thread;
import com.table.badbatt.BadBatt_thread2;
import com.table.badbatt.BadBatt_thread;
import com.table_sql.MySqlPool;

public class MainTable {
	private static MySqlPool mpool;
	private static Connection conn;
	//´´½¨Âäºóµ¥Ìå±í
	public static	void createbadbatt(MySqlPool m_ConnPool){
		//´´½¨Êý¾Ý±í
		String createbadbatt_monSql="CREATE TABLE IF NOT EXISTS web_site.tb_badbatt_mon "
				+ "("
				+ "`num` int(11) NOT NULL AUTO_INCREMENT,"
				+ "`battgroupid` int NOT NULL DEFAULT '0',"
				+ " `mon_num` int NOT NULL DEFAULT '0',"
				+ "`record_num` int NOT NULL DEFAULT '0',"
				+ "`test_starttime` datetime NOT NULL DEFAULT '1982-01-01 00:00:00',"
				+ "`group_vol` float NOT NULL DEFAULT '0',"
				+ "`test_curr` float NOT NULL DEFAULT '0',"
				+ "`mon_vol` float NOT NULL DEFAULT '0',"
				+ "`real_cap` float NOT NULL DEFAULT '0',"
				+ "`stdcap` float NOT NULL DEFAULT '0',"
				+ "`note` varchar(64) COLLATE utf8_unicode_ci NOT NULL DEFAULT ' ',"
				+ "PRIMARY KEY (`num`),"
				+ "KEY `index_num` (`battgroupid`)"
				+ ")";
		ArrayList<String> sql_str=new ArrayList();
		sql_str.add(createbadbatt_monSql);
		boolean bl=MySqlPool.makeManualCommit(m_ConnPool.getConn(), sql_str);
	}
	//Âäºóµ¥Ìå·þÎñÆô¶¯,Çå¿ÕÂäºóµ¥Ìå±íÖÐÊý¾ÝÖØÐÂÆô¶¯
	private static void deletebadbatt(MySqlPool m_ConnPool) {
		//ɾ³ýÊý¾Ý±í
		String deletebadbatt_monSql="DELETE FROM web_site.tb_badbatt_mon WHERE num>0 ";//truncate table ....
		ArrayList<String> sql_str=new ArrayList();
		sql_str.add(deletebadbatt_monSql);
		boolean bl=MySqlPool.makeManualCommit(m_ConnPool.getConn(), sql_str);	
	}
	//Âäºóµ¥Ìå·þÎñÆô¶¯,½«¹ØÓÚÈÝÁ¿¸æ¾¯µÄʵʱÊý¾Ý¸ÄΪÀúÊ·
	private static void updatealarmcap(MySqlPool m_ConnPool) {
		String updatealarmcapSql="update db_alarm.tb_battalarm_data set alm_cleared_type=1 where alm_id in("+AlarmDaoFactory.Alarm_CapAlarm+","+AlarmDaoFactory.Alarm_CapChange+") and alm_cleared_type=0";//truncate table ....
		ArrayList<String> sql_str=new ArrayList();
		sql_str.add(updatealarmcapSql);
		boolean bl=MySqlPool.makeManualCommit(m_ConnPool.getConn(), sql_str);	
	}
	//·þÎñÆô¶¯£¬¼Ç¼·þÎñÆô¶¯µÄ³õʼʱ¼ä
	public static void serverstartSql(Date nowdate,String serverName,String version,MySqlPool m_ConnPool_){
		String sql=" update  "+Mysql_database_param.web_site+Mysql_database_param.tb_Process_survey+" "
				+" set Process_starttime='"+BadBatt_thread.sdf.format(nowdate)
				+"',ProcessVersion='"+version
				+"' where ServerName='"+serverName+"'";
		Connection conn=m_ConnPool_.getConn();
		//System.out.println(sql);
		boolean bl=m_ConnPool_.sqlMysqlUpdate(conn, sql);
	}
	public static void main(String[] args) {
		TimeZone.setDefault(TimeZone.getTimeZone("GMT+8"));
		mpool=new MySqlPool();
		try {
			Thread.sleep(30*1000);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		//·þÎñÆô¶¯£¬Èç¹ûûÓÐÂäºóµ¥Ìå±íÔò´´½¨Âäºóµ¥Ìå±í
		System.out.println("tb_badbatt_mon±íн¨!");
		createbadbatt(mpool);
		//Âäºóµ¥Ìå·þÎñÆô¶¯ºó,Çå¿ÕÂäºóµ¥Ìå±íÖÐÊý¾ÝÖØÐÂÆô¶¯
		System.out.println("tb_badbatt_mon±íÖØÆôÈ¥³ý¾ÍÊý¾Ý!");
		deletebadbatt(mpool);
		//Âäºóµ¥Ìå·þÎñÆô¶¯,½«¹ØÓÚÈÝÁ¿¸æ¾¯µÄʵʱÊý¾Ý¸ÄΪÀúÊ·
		System.out.println("Âäºóµ¥Ìå·þÎñÆô¶¯,ÈÝÁ¿¸æ¾¯µÄʵʱÊý¾Ý¸ÄΪÀúÊ·!");
		updatealarmcap(mpool);
		//·þÎñÆô¶¯£¬¼Ç¼·þÎñÆô¶¯µÄ³õʼʱ¼ä
		System.out.println("·þÎñÆô¶¯£¬¼Ç¼·þÎñÆô¶¯µÄ³õʼʱ¼ä!");
		serverstartSql(new Date(), Mysql_database_param.BMS_FBSDEV_BADBATT,Mysql_database_param.VERSION, mpool);
		//alarm_threadÏß³ÌÆô¶¯
		Alarm_thread alarm_t=new Alarm_thread(mpool);
		alarm_t.start();
		//badbatt_threadÏß³ÌÆô¶¯
		BadBatt_thread bd_t=new BadBatt_thread(mpool);
		bd_t.start();
	}
}