V2.10 edit at date 2025-03-18 1.新增东峰系统对接bms实时数据表'db_ram_db.tb_dfxt_bms_state'

DELL

2025-03-18 6ffac77ff7d9d0f1be85a67dcece6d05b3a3d5c3

 BattMonitor_DB_Builder/src/com/sql/Sql_Mysql.java

@@ -41,6 +41,10 @@

   final public static String DB_UPSPWRDEV_ALARM = "`db_upspwrdev_alarm`";                  //UPS告警数据库
   final public static String DB_UPSPWRDEV_DATA_HISTORY = "`db_upspwrdev_data_history`";      //UPS历史实时数据库

   final public static String DB_IED_SCOUT     = "`db_ied_scout`";                     //UPS历史实时数据库
   final public static String DB_NJ_MEASUREMENT = "`db_nj_measurement`";                  //南京首页属性信息配置表
   final public static String DB_CIRCLE = "`db_circle`";                              //动环数据库
   //--------------------------------------------------------------------------------------------//
   public final static String TB_HardDevSmsState = "tb_hard_dev_sms_state";
   //--------------------------------------------------------------------------------------------//
@@ -74,6 +78,7 @@
   public final static String CInterfaceState_Table = DB_RamDB + ".`tb_cinterface_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 FBS9600Param_Table = DB_RamDB + ".`tb_fbs9600_param`";
   
   //--------------------------------------------------------------------------------------------//
@@ -171,6 +176,17 @@
   public final static String FBS9140_Topology_State = DB_RamDB + ".tb_fbs9140_topology_state";               //并联BTS拓扑状态信息
   public final static String FBS9149_SetParam = DB_RamDB + ".tb_fbs9149_setparam";                        //并联BTS9组参数表
   public final static String Check_Dialog_Table = DB_RamDB + ".tb_check_dialog";                           //充放电一体机离线检测表
   public final static String IntelligentBusbar_State_Table = DB_RamDB + ".tb_intelligentbusbar_state";         //充放电一体机离线检测表

   public final static String Dev_6185_AlmpPram_Table = DB_RamDB + ".tb_dev_6185_almparam";                  //BTS61850告警参数表

   public final static String Dev6159_Power_Yc_Table = DB_RamDB + ".tb_dev6159_power_yc";                     //BTS61850告警参数表
   public final static String Dev6159_Power_Yx_Table = DB_RamDB + ".tb_dev6159_power_yx";                     //BTS61850告警参数表

   public final static String Acdc_Secuity_Table = DB_RamDB + ".tb_acdc_secuity";
   //交直流监控屏实时数据表
	
   public final static String Dfxt_Bms_State_Table = DB_RamDB + ".tb_dfxt_bms_state";                        //东峰BMS实时数据表

   
   /**************************** db_user数据库 ***************************************************/
@@ -251,6 +267,9 @@
   public static final String Tb_Fault_Upload_Table = WEB_Site +".`tb_fault_upload`";                     //故障隐患上传表,用于故障隐患考核
   public static final String Tb_Fbs9100_SetParam_Temp_Table = WEB_Site +".`tb_fbs9100_setparam_temp`";      //本年度二次核容放电参数考核
   public static final String Tb_Fault_Upload_Application_Table = WEB_Site +".`tb_fault_upload_application`";   //故障隐患上传表,用于故障隐患考核
   public static final String Tb_Resset_Station_Table = WEB_Site +".`tb_resset_station`";                  //机房内阻测试计划表
   public static final String Tb_Badld9_Mon_Table = WEB_Site +".`tb_badld9_mon`";                  //机房内阻测试计划表
   public static final String Tb_Mac_Ukey_Table = WEB_Site +".`tb_mac_ukey`";                  //机房内阻测试计划表
                                                          
   /***************************** db_battinf数据库  ***************************************/
   public final static String BattInf_Table = DB_BATT_INF + ".`tb_battinf`";
@@ -377,6 +396,18 @@
   public final static String UPSpwrdev_Alarm_Table = DB_UPSPWRDEV_ALARM + ".tb_upspwrdev_alarm";               //UPS设备实时告警记录表
   public final static String UPSpwrdev_Alarm_History_Table = DB_DEV_TESTPARAM + ".tb_upspwrdev_alarm_history";   //UPS设备历史告警记录表
      
   /***************************** 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";   //ied状态信息表

   /***************************** db_nj_measurement 数据库  **********************************/
   public final static String Njhome_Config_Table = DB_NJ_MEASUREMENT + ".tb_njhome_config";   //首页属性信息配置表
   public final static String Njhome_Station_Table = DB_NJ_MEASUREMENT + ".tb_njhome_station";   //首页机房信息配置表
	
   /***************************** db_circle 数据库  **********************************/
   public final static String Circle_Inf_Table = DB_CIRCLE + ".tb_circle_inf";	
   public final static String Sub_Inf_Table = DB_CIRCLE + ".tb_sub_inf";	

   //--------------------------------------------------------------------------------------------//
   //--------------------------------------------------------------------------------------------//
   public Connection mysql_con;
@@ -400,7 +431,9 @@
   public void close_con()
   {
      try {
         mysql_con.close();
         if(null != mysql_con) {				
            mysql_con.close();
         }
      } catch (SQLException e) {
         e.printStackTrace();
      }
@@ -1266,14 +1299,14 @@
   public void sqlMysqlExecute(String sql_str) throws SQLException
   {
      Statement sql = mysql_con.createStatement();
      sql.setQueryTimeout(60);
      sql.setQueryTimeout(5*60);
      sql.execute(sql_str);
   }
   //执行sql语句
   public void sqlMysqlTotalExecute(String sql_str) throws SQLException
   {
      Statement sql = mysql_con.createStatement();
      sql.setQueryTimeout(5*60);
      sql.setQueryTimeout(10*60);
      sql.execute(sql_str);
   }
   
@@ -1335,7 +1368,7 @@
      try
       {
         Statement sql = mysql_con.createStatement();
         sql.setQueryTimeout(5*60);
         sql.setQueryTimeout(10*60);
         String query = sql_str;
         res =  sql.executeQuery(query);
       }