package com.dec.fbs9100;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;

import org.apache.logging.log4j.core.Logger;


public class Sql_Mysql {
	//--------------------------------------------------------------------------------------------//
	final public static String DB_AppSys = "`db_app_sys`";
	final public static String DB_BATT_INF = "`db_battinf`";
	final public static String DB_BATT_TESTDATA = "`db_batt_testdata`";
	final public static String DB_PARAM = "`db_param`";
	final public static String DB_ALARM = "`db_alarm`";
	final public static String DB_USER = "`db_user`";
	final public static String DB_RamDB = "`db_ram_db`";
	final public static String DB_RamDB_BATT_RT = "`db_ram_batt_rt`";
	
	final public static String WEB_Site = "web_site";
	final public static String DB_BATT_HISTORY = "`db_batt_history`";
	
	final public static String DB_DEV_TESTPARAM = "`db_dev_testparam`";
	final public static String DB_IED_SCOUT = "`db_ied_scout`";
	//--------------------------------------------------------------------------------------------//
	public final static String TB_HardDevSmsState = "tb_hard_dev_sms_state";
	//--------------------------------------------------------------------------------------------//
	public final static String TB_AppSys = "tb_app_sys";
	
	public final static String TB_BattTestDataInf = "tb_batttestdata_inf";
	
	public final static String TB_UserInf = "tb_user_inf";
	public final static String TB_UserLog = "tb_user_log";
	public final static String TB_UserBattGroup_BaoJiGroup = "tb_user_battgroup_baojigroup";
	public final static String TB_UserBattGroup_BaoJiGroup_BattGroup = "tb_user_battgroup_baojigroup_battgroup";
	public final static String TB_UserBattGroup_BaoJiGroup_Usr = "tb_user_battgroup_baojigroup_usr";
	public final static String TB_UserTaskTemplate = "tb_user_task_batt_template";
	public final static String TB_UserTask = "tb_user_task";
	public final static String TB_UserPaiXiu = "tb_user_paixiu";
	public final static String TB_UserListForTask = "tb_user_task_user_list";
	public final static String TB_UserTaskParam = "tb_user_task_param";
	public final static String TB_UserBattCkeckTask = "tb_user_task_batt_check";
	public final static String TB_UserBattTestTask = "tb_user_task_batt_test";
	public final static String TB_UserBattTaskChange = "tb_user_task_change";
	public final static String TB_UserSms = "tb_user_sms";
	public final static String TB_UserSmsFormat = "tb_user_sms_format";
	public final static String TB_UserPermitGroup = "tb_user_permitgroup";
	public final static String TB_UserPermitGroupData = "tb_user_permitgroup_data";
	public final static String TB_UserJieJiaRi = "tb_user_jiejiari";
	//--------------------------------------------------------------------------------------------//
	//--------------------------------------------------------------------------------------------//
	public final static String ServerState_Table = DB_RamDB + ".`tb_server_state`";
	public final static String BattRtData_Table = DB_RamDB + ".`tb_batt_rtdata`";
	public final static String BattRtState_Table = DB_RamDB + ".`tb_batt_rtstate`";
	
	public final static String BattRtAlarm_Table = DB_RamDB + ".`tb_batt_rtalarm`";
	public final static String BattRsAlarm_Table = DB_RamDB + ".`tb_batt_rsalarm`";
	
	public final static String CInterfaceState_Table = DB_RamDB + ".`tb_cinterface_state`";
	
	public final static String HardDevSmsState_Table = DB_RamDB + ".`tb_hard_dev_sms_state`";
	public final static String FBS9100State_Table = DB_RamDB + ".`tb_fbs9100_state`";
	public final static String FBS9100S_DcDcState_Table = DB_RamDB + ".`tb_fbs9100s_dcdc_state`";
	public final static String FBS9100SetParam_Table = DB_RamDB + ".`tb_fbs9100_setparam`";
	public final static String FBS9100SysParam_Table = DB_RamDB + ".`tb_fbs9100_sysparam`";					//绯荤粺鍙傛暟琛�
	public final static String FBS9100SetDLParam_Table = DB_RamDB + ".`tb_fbs9100s_fod_param`";
	public final static String FBS9100sFodState_Table = DB_RamDB + ".`tb_fbs9100s_fod_state`";
	public final static String FBS9100S_DFUState_Table = DB_RamDB + ".`tb_fbs9100s_DFU_state`";
	
	public final static String BMP7100State_Table = DB_RamDB + ".`tb_bpm7100_state`";
	
	public final static String FBS9600State_Table = DB_RamDB + ".`tb_fbs9600_state`";
	public final static String FBS9600SetParam_Table = DB_RamDB + ".`tb_fbs9600_setparam`";
	//public final static String FBS9600Param_Table = DB_RamDB + ".`tb_fbs9600_param`";
	public final static String SocketClientStateTable = DB_RamDB + ".`tb_socketclient_state`";
	public final static String RamDB_CMCC_POWER_Data = DB_RamDB + ".`cmcc_power_data`";
	
	public final static String FBS9100_61850_jhstate_Table = DB_RamDB + ".`tb_61850_jhstate`";
	
	public final static String FBS9100_offlineyhplan = DB_RamDB + ".tb_fbs9100_offlineyhplan";						//61850离线养护计划参数表

	public final static String Dev_6185_AlmParam = DB_RamDB + ".tb_dev_6185_almparam";
	//--------------------------------------------------------------------------------------------//
	//--------------------------------------------------------------------------------------------//
	public final static String AppSys_Table = DB_AppSys + ".`tb_app_sys`";
	public final static String FBSDevStateChangeInf_Table = DB_AppSys + ".`tb_fbsdev_statechange_inf`";
	public final static String AppDevBattGroup_Table = DB_AppSys + ".`tb_app_bts_battgroup`";
	public final static String BattInf_Table = DB_BATT_INF + ".`tb_battinf`";
	public final static String BattCurrInf_Table = DB_BATT_INF + ".`tb_battcurr_inf`";
	public final static String BattMainInf_Table = DB_BATT_INF + ".`tb_batt_maint_inf`";
	public final static String BattMainProcess_Table = DB_BATT_INF + ".`tb_batt_maint_process`";
	
	
	public final static String BattTestDataInf_Table = DB_BATT_TESTDATA + ".`tb_batttestdata_inf`";
	public final static String BattResData_Table = DB_BATT_TESTDATA + ".`tb_BattResData`";
	public final static String BattResDataInf_Table = DB_BATT_TESTDATA + ".`tb_battresdata_inf`";
	
	public final static String UserInfTable = DB_USER + ".`tb_user_inf`";
	public final static String UserLogTable = DB_USER + ".`tb_user_log`";
	public final static String UserBattGroup_BaoJiGroup_Table = DB_USER + ".`tb_user_battgroup_baojigroup`";
	public final static String UserBattGroup_BaoJiGroup_BattGroupTable = DB_USER + ".`tb_user_battgroup_baojigroup_battgroup`";
	public final static String UserBattGroup_BaoJiGroup_UsrTable = DB_USER + ".`tb_user_battgroup_baojigroup_usr`";
	public final static String UserTaskTemplateTable = DB_USER + ".`tb_user_task_batt_template`";
	public final static String UserTaskTable = DB_USER + ".`tb_user_task`";
	public final static String UserPaiXiuTable = DB_USER + ".`tb_user_paixiu`";
	public final static String UserListForTaskTable = DB_USER + ".`tb_user_task_user_list`";
	public final static String UserTaskParamTable = DB_USER + ".`tb_user_task_param`";
	public final static String UserBattCheckTaskTable = DB_USER + ".`tb_user_task_batt_check`";
	public final static String UserBattTestTaskTable = DB_USER + ".`tb_user_task_batt_test`";
	
	public final static String UserBattTaskChangeTable = DB_USER + ".`tb_user_task_change`";
	
	public final static String UsrBattMaintCheck_Table = DB_USER + ".`tb_user_battmaint_check`";
	public final static String UsrBattMaintCheckProcess_Table = DB_USER + ".`tb_user_battmaint_check_process`";
	
	public final static String UserSmsTable = DB_USER + ".`tb_user_sms`";
	public final static String UserSmsFormatTable = DB_USER + ".`tb_user_sms_format`";
	public final static String UserPermitGroupTable = DB_USER + ".`tb_user_permitgroup`";
	public final static String UserPermitGroupDataTable = DB_USER + ".`tb_user_permitgroup_data`";
	public final static String UserJieJiaRiTable = DB_USER + ".`tb_user_jiejiari`";
	//--------------------------------------------------------------------------------------------//
	public final static String Tb_BattDischarge_ParamTable = WEB_Site+".tb_battdischarge_param";			//电池放电参数
	public final static String Tb_BattMap_InformationTable = WEB_Site+".tb_battmap_information";			//机房定位信息表
	public final static String Tb_Batt_DevDischargeTable = WEB_Site+".tb_batt_devdischarge";				//设备用电量记录表
	public final static String Tb_BattDischarge_PlanTable = WEB_Site+".tb_battdischarge_plan";				//放电计划表
	public final static String Tb_Batt_ElectricityTable = WEB_Site+".tb_batt_electricity";					//设备三大运营商的用电量记录表
	public final static String Tb_Batt_Devdischarge_ParamTable = WEB_Site+".tb_batt_devdischarge_param";	//放电计划参数表
	public final static String Tb_Batt_Devdischarge_CMTable = WEB_Site+".tb_batt_devdischarge_CM";			//移动用电量统计
	public final static String Tb_Batt_Devdischarge_CTTable = WEB_Site+".tb_batt_devdischarge_CT";			//联通用电量统计
	public final static String Tb_Batt_Devdischarge_CUTable = WEB_Site+".tb_batt_devdischarge_CU";			//电信用电量统计
	public final static String Tb_CustomPageTable = WEB_Site+".tb_custompage";								//界面导航数据表
	public final static String Tb_Vip_UserTable = WEB_Site+".tb_vip_user";									//vip用户表
	public final static String Tb_Batt_Param_LowTable = WEB_Site+".tb_batt_param_low";						//电池下限表
	public final static String Tb_AnnounceTable = WEB_Site+".tb_announce";									//平台公告表
	//------------------------------------- -------------------------------------------------------//
	//------------------------------------- -------------------------------------------------------//
	public final static String App_Param_Table = DB_PARAM + ".`tb_app_param`";
	//------------------------------------- -------------------------------------------------------//
	public final static String Tb_BtsStateChange_inf = DB_BATT_HISTORY + ".`tb_btsstaechange_inf`";			//设备状态变换记录表
	public final static String Tb_Batt_RealData = DB_BATT_HISTORY + ".tb_batt_realdata_";					//电池实时数据记录表
	
	/***************************** db_dev_testparam 数据库  **********************************/
	public final static String Batt_TestParam_Table = DB_DEV_TESTPARAM + ".tb_batt_testparam_";

	/***************************** DB_IED_SCOUT 数据库  **********************************/
	public final static String Connect_Inf_Table = DB_IED_SCOUT + ".tb_connect_inf";						//IED连接信息表
	public final static String Ied_NodeState_Table = DB_IED_SCOUT + ".tb_ied_nodestate";					//设备信息表
	
	public Connection mysql_con;
	public Logger logger = null;
	
	public Sql_Mysql(MysqlConnPool conn_t)
	{
		mysql_con = conn_t.getConn();
		logger = (Logger) conn_t.logger;
	}
	/**
	 * 锟斤拷锟斤拷锟斤拷tb锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟�
	 * @param tb
	 * @return
	 * @throws SQLException
	 */
	public boolean sqlMysqlCheckIfTableExist(String tb) throws SQLException
	{
		String sql_str = "SHOW TABLES LIKE '" + tb + "'";
		ResultSet res = sqlMysqlQuery(sql_str);
		boolean exist = false;
		while(res.next())
		{
			exist = true;
			break;
		}
		
		return exist;
	}
	
	//锟斤拷锟斤拷锟斤拷sql锟斤拷锟斤拷锟斤拷
	public void sqlMysqlExecute(String sql_str) throws SQLException
	{
		Statement sql = mysql_con.createStatement();
		sql.setQueryTimeout(30);
		sql.execute(sql_str);
	}
	//锟斤拷锟斤拷锟斤拷sql锟斤拷锟斤拷锟斤拷
	public void sqlMysqlTotalExecute(String sql_str) throws SQLException
	{
		Statement sql = mysql_con.createStatement();
		sql.setQueryTimeout(60*10);
		sql.execute(sql_str);
	}
	
	//锟斤拷锟斤拷锟斤拷db锟斤拷锟斤拷锟斤拷锟斤拷锟�
	public void sqlMysqlUseDB(String db) throws SQLException
	{
		sqlMysqlExecute("use " + db);
	}
	
	//锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷sql锟斤拷锟斤拷锟斤拷
	public boolean makeManualCommit(ArrayList<String> al_sql_strs) 
	{
		boolean exe_res = true;
		try {
			mysql_con.setAutoCommit(false);
			
			for(int n=0; n<al_sql_strs.size(); n++) {
				sqlMysqlExecute(al_sql_strs.get(n));
			}
			
			if(true == exe_res) {
				mysql_con.commit();
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			logger.error(e.toString(), e);
			exe_res = false;
		} finally {
			try {
				if(false == exe_res) {
					mysql_con.rollback();
				}
				mysql_con.setAutoCommit(true);
			} catch (SQLException e1) {
				// TODO Auto-generated catch block
				logger.error(e1.toString(), e1);
			}
		}		
		return exe_res;
	}
	
	//锟斤拷锟斤拷锟斤拷sql锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷sql锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷
	
	public ResultSet sqlMysqlQuery(String sql_str)
	{
		ResultSet res = null;
		try {
			Statement sql = mysql_con.createStatement();
			sql.setQueryTimeout(30);
			String query = sql_str;
			res =  sql.executeQuery(query);			
    	} catch(SQLException ex) {
			logger.error(ex.toString(), ex);
		}
		return res;
	}
	public ResultSet sqlMysqlTotalQuery(String sql_str)
	{
		ResultSet res = null;
		try {
			Statement sql = mysql_con.createStatement();
			sql.setQueryTimeout(60*10);
			String query = sql_str;
			res =  sql.executeQuery(query);			
		} catch(SQLException ex) {
			logger.error(ex.toString(), ex);
		}
		return res;
	}

	//锟斤拷锟斤拷锟斤拷sql锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷sql锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷
	public void sqlMysqlUpdate(String sql_str)
	{
		try {
			Statement sql = mysql_con.createStatement();
			sql.setQueryTimeout(30);
			String query = sql_str;
			sql.execute(query);
			//sql.close();
    	} catch(SQLException ex) {
			logger.error(ex.toString(), ex);
		}
	}
	
	public void close_con()
	{
		try {
			mysql_con.close();
		} catch (SQLException e) {
			logger.error(e.toString(), e);
		}
	}
	
	public int getBattTestRecordCountNew(int bg_id, String table)
	{
		int count = 0;
		boolean res_exe = true;
		String sql_str0 = "SELECT test_record_count_ex FROM " + table 
							+ " WHERE BattGroupId=" + bg_id  + " FOR UPDATE";
		String sql_str1 = "UPDATE " + table + " SET test_record_count_ex=test_record_count+1"
							+ " WHERE BattGroupId=" + bg_id;
		String sql_str2 = "SELECT MAX(test_record_count_ex) FROM " + table 
							+ " WHERE BattGroupId=" + bg_id;
		String sql_str3 = "INSERT INTO " + table + " (BattGroupId,test_record_count, test_record_count_ex) "
							+ " VALUES (" + bg_id + "," + 1 + "," + 1 + ")";
		try {
			mysql_con.setAutoCommit(false);
			ResultSet res = sqlMysqlQuery(sql_str0);
			if(res.next()) {
				sqlMysqlExecute(sql_str1);
				res = sqlMysqlQuery(sql_str2);
				if(res.next()) {
					count = res.getInt(1);
				}
			} else {
				count = 1;
				sqlMysqlExecute(sql_str3);
			}
			
			mysql_con.commit();
		} catch (SQLException e) {
			logger.error(e.toString(), e);
			res_exe = false;
		} finally {
			if(false == res_exe) {
				try {
					mysql_con.rollback();
					mysql_con.setAutoCommit(true);
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					logger.error(e.toString(), e);
				}
			}
		}
		
		return count;
	}
}