From ca54e9252852984164ab30921f539cc3a026d041 Mon Sep 17 00:00:00 2001
From: Administrator <1525436766@qq.com>
Date: 星期二, 25 七月 2023 15:26:06 +0800
Subject: [PATCH] 3.'db_battinf.tb_station_inf'表新增标识同一机房标识 `together_flag` int(11) NOT NULL DEFAULT '0'
---
BattMonitor_DB_Builder/src/com/database_util/DB_Param.java | 141 +++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 141 insertions(+), 0 deletions(-)
diff --git a/BattMonitor_DB_Builder/src/com/database_util/DB_Param.java b/BattMonitor_DB_Builder/src/com/database_util/DB_Param.java
index ca9307a..6f2ad4e 100644
--- a/BattMonitor_DB_Builder/src/com/database_util/DB_Param.java
+++ b/BattMonitor_DB_Builder/src/com/database_util/DB_Param.java
@@ -20,6 +20,8 @@
createAlarm_Param_Table(pool, recreate);
+ createDev_AlmParam_Table(pool, recreate); //创建设备告警参数表
+
System.out.println(" db_param init end at " + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
}
@@ -187,6 +189,112 @@
sql.close_con();
}
}
+ /**
+ * 创建 tb_dev_almparam 表
+ * @param pool
+ * @param recreate
+ */
+ public static void createDev_AlmParam_Table(MysqlConnPool pool, boolean recreate) {
+ String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Dev_AlmParam_Table;
+ String sql_str02 = " CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Dev_AlmParam_Table + " (" +
+ " `num` bigint(20) NOT NULL AUTO_INCREMENT," +
+ " `alm_id` int(11) NOT NULL DEFAULT '119020' COMMENT '告警id'," +
+ " `alm_name` varchar(255) NOT NULL COMMENT '告警名称'," +
+ " `alm_type` int(11) NOT NULL DEFAULT '0' COMMENT '当前告警触发类型；0-boolean类型 1-阈值类型'," +
+ " `alm_limit_value` float NOT NULL DEFAULT '0' COMMENT '告警阈值'," +
+ " `alm_level` int(11) NOT NULL DEFAULT '4' COMMENT '告警等级'," +
+ " `alm_delay_time` int(11) NOT NULL DEFAULT '60' COMMENT '告警延迟触发时长[单位：秒]'," +
+ " `alm_severity` int(11) NOT NULL DEFAULT '0' COMMENT '告警重要等级[0:重要；1:紧急]'," +
+ " `alm_en` int(11) NOT NULL DEFAULT '1' COMMENT '告警使能：0-不触发 1-触发'," +
+ " PRIMARY KEY (`num`)" +
+ ") ENGINE=InnoDB AUTO_INCREMENT=17 DEFAULT CHARSET=utf8 COMMENT='设备告警参数表';";
+ Sql_Mysql sql = new Sql_Mysql(pool.getConn());
+ ResultSet res = null;
+ try {
+ if(true == recreate) {
+ sql.sqlMysqlExecute(sql_str01);
+ }
+ sql.sqlMysqlExecute(sql_str02);
+
+ //BTS通信故障 =========119020
+ if(!checkDevAlarmParamExists(pool, SqlsUtils.ALM_TYPE_FBS9100_CommError_ID)) {
+ sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.Dev_AlmParam_Table + "(alm_id,alm_name,alm_type,alm_limit_value,alm_level,alm_delay_time,alm_severity,alm_en) VALUES("+SqlsUtils.ALM_TYPE_OnlineVol_ID+",'通信故障超时长[秒]',1,180,1,60,1,1)");
+ }
+ //BTS续航告警=========119023
+ if(!checkDevAlarmParamExists(pool, SqlsUtils.ALM_TYPE_BTS_ENDURANCE_ID)) {
+ sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.Dev_AlmParam_Table + "(alm_id,alm_name,alm_type,alm_limit_value,alm_level,alm_delay_time,alm_severity,alm_en) VALUES("+SqlsUtils.ALM_TYPE_BTS_ENDURANCE_ID+",'续航不足告警',0,0,2,60,0,0)");
+ }
+ //机房停电告警=========119024
+ if(!checkDevAlarmParamExists(pool, SqlsUtils.ALM_TYPE_FBS9100_POWEROFF_ID)) {
+ sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.Dev_AlmParam_Table + "(alm_id,alm_name,alm_type,alm_limit_value,alm_level,alm_delay_time,alm_severity,alm_en) VALUES("+SqlsUtils.ALM_TYPE_FBS9100_POWEROFF_ID+",'机房停电告警',0,0,2,60,0,0)");
+ }
+ //机房发电告警=========119025
+ if(!checkDevAlarmParamExists(pool, SqlsUtils.ALM_TYPE_FBS9100_FADIAN_ID)) {
+ sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.Dev_AlmParam_Table + "(alm_id,alm_name,alm_type,alm_limit_value,alm_level,alm_delay_time,alm_severity,alm_en) VALUES("+SqlsUtils.ALM_TYPE_FBS9100_FADIAN_ID+",'机房发电告警',0,0,2,60,0,0)");
+ }
+ //机房掉站告警=========119026
+ if(!checkDevAlarmParamExists(pool, SqlsUtils.ALM_TYPE_FBS9100_DIAOZHAN_ID)) {
+ sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.Dev_AlmParam_Table + "(alm_id,alm_name,alm_type,alm_limit_value,alm_level,alm_delay_time,alm_severity,alm_en) VALUES("+SqlsUtils.ALM_TYPE_FBS9100_DIAOZHAN_ID+",'机房掉站告警',0,0,2,60,0,0)");
+ }
+ //机房开门告警=========119027
+ if(!checkDevAlarmParamExists(pool, SqlsUtils.ALM_TYPE_FBS9100_KAIMEN_ID)) {
+ sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.Dev_AlmParam_Table + "(alm_id,alm_name,alm_type,alm_limit_value,alm_level,alm_delay_time,alm_severity,alm_en) VALUES("+SqlsUtils.ALM_TYPE_FBS9100_KAIMEN_ID+",'机房开门告警',0,0,2,60,0,0)");
+ }
+ //设备高温告警=========119028
+ if(!checkDevAlarmParamExists(pool, SqlsUtils.ALM_TYPE_FBS9100_TMPHIGHT_ID)) {
+ sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.Dev_AlmParam_Table + "(alm_id,alm_name,alm_type,alm_limit_value,alm_level,alm_delay_time,alm_severity,alm_en) VALUES("+SqlsUtils.ALM_TYPE_FBS9100_TMPHIGHT_ID+",'设备高温告警',1,50,2,60,0,1)");
+ }
+ //设备SD卡故障=========119032
+ if(!checkDevAlarmParamExists(pool, SqlsUtils.ALM_TYPE_FBS9100_SDERROR_ID)) {
+ sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.Dev_AlmParam_Table + "(alm_id,alm_name,alm_type,alm_limit_value,alm_level,alm_delay_time,alm_severity,alm_en) VALUES("+SqlsUtils.ALM_TYPE_FBS9100_SDERROR_ID+",'设备SD卡故障',0,0,2,60,0,0)");
+ }
+ //采集线告警=========119033
+ if(!checkDevAlarmParamExists(pool, SqlsUtils.ALM_TYPE_FBS9100_COLLECTERROR_ID)) {
+ sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.Dev_AlmParam_Table + "(alm_id,alm_name,alm_type,alm_limit_value,alm_level,alm_delay_time,alm_severity,alm_en) VALUES("+SqlsUtils.ALM_TYPE_FBS9100_COLLECTERROR_ID+",'采集线告警',1,1.5,4,60,0,1)");
+ }
+ //停电电流均衡告警=========119034
+ if(!checkDevAlarmParamExists(pool, SqlsUtils.ALM_TYPE_FBS9100_CurrBalance_ID)) {
+ sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.Dev_AlmParam_Table + "(alm_id,alm_name,alm_type,alm_limit_value,alm_level,alm_delay_time,alm_severity,alm_en) VALUES("+SqlsUtils.ALM_TYPE_FBS9100_CurrBalance_ID+",'停电电流均衡告警',0,0,2,60,0,1)");
+ }
+ //继电器告警=========618501
+ if(!checkDevAlarmParamExists(pool, SqlsUtils.ALM_TYPE_BTS61850_RELAY_Error_ID)) {
+ sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.Dev_AlmParam_Table + "(alm_id,alm_name,alm_type,alm_limit_value,alm_level,alm_delay_time,alm_severity,alm_en) VALUES("+SqlsUtils.ALM_TYPE_BTS61850_RELAY_Error_ID+",'继电器告警',0,0,2,60,0,1)");
+ }
+ //通讯告警=========618502
+ if(!checkDevAlarmParamExists(pool, SqlsUtils.ALM_TYPE_BTS61850_CONNCET_Error_ID)) {
+ sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.Dev_AlmParam_Table + "(alm_id,alm_name,alm_type,alm_limit_value,alm_level,alm_delay_time,alm_severity,alm_en) VALUES("+SqlsUtils.ALM_TYPE_BTS61850_CONNCET_Error_ID+",'通讯故障',0,0,2,60,0,1)");
+ }
+ //设备过温告警=========618503
+ if(!checkDevAlarmParamExists(pool, SqlsUtils.ALM_TYPE_BTS61850_HIGTMP_Error_ID)) {
+ sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.Dev_AlmParam_Table + "(alm_id,alm_name,alm_type,alm_limit_value,alm_level,alm_delay_time,alm_severity,alm_en) VALUES("+SqlsUtils.ALM_TYPE_BTS61850_HIGTMP_Error_ID+",'设备过温告警',0,0,2,60,0,1)");
+ }
+ //二极管D1告警=========618504
+ if(!checkDevAlarmParamExists(pool, SqlsUtils.ALM_TYPE_BTS61850_DIODE_Error_ID)) {
+ sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.Dev_AlmParam_Table + "(alm_id,alm_name,alm_type,alm_limit_value,alm_level,alm_delay_time,alm_severity,alm_en) VALUES("+SqlsUtils.ALM_TYPE_BTS61850_DIODE_Error_ID+",'二极管D1告警',0,0,2,60,0,1)");
+ }
+ //干接点告警=========618505
+ if(!checkDevAlarmParamExists(pool, SqlsUtils.ALM_TYPE_BTS61850_DRYCONTACT_Error_ID)) {
+ sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.Dev_AlmParam_Table + "(alm_id,alm_name,alm_type,alm_limit_value,alm_level,alm_delay_time,alm_severity,alm_en) VALUES("+SqlsUtils.ALM_TYPE_BTS61850_DRYCONTACT_Error_ID+",'干接点告警',0,0,2,60,0,1)");
+ }
+ //测试异常停止=========618506
+ if(!checkDevAlarmParamExists(pool, SqlsUtils.ALM_TYPE_BTS61850_TEST_ERROR_ID)) {
+ sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.Dev_AlmParam_Table + "(alm_id,alm_name,alm_type,alm_limit_value,alm_level,alm_delay_time,alm_severity,alm_en) VALUES("+SqlsUtils.ALM_TYPE_BTS61850_TEST_ERROR_ID+",'测试异常停止',0,0,2,60,0,1)");
+ }
+
+
+ } catch (SQLException e) {
+ e.printStackTrace();
+ } finally {
+ if(null != res) {
+ try {
+ res.close();
+ } catch (SQLException e) {
+ e.printStackTrace();
+ }
+ }
+ sql.close_con();
+ }
+ }
/**
* 创建 tb_alarm_param 表
@@ -300,4 +408,37 @@
return isExists;
}
+
+ /**
+ * 检查db_param.tb_dev_almparam 表中alm记录是否存在
+ * @param pool
+ * @param alm_id
+ * @return
+ */
+ public static boolean checkDevAlarmParamExists(MysqlConnPool pool,int alm_id) {
+ boolean isExists = false;
+ String sql_str = "SELECT * FROM " + Sql_Mysql.Dev_AlmParam_Table + " WHERE alm_id = " + alm_id;
+ Sql_Mysql sql = new Sql_Mysql(pool.getConn());
+ ResultSet res = null;
+
+ try {
+ res = sql.sqlMysqlQuery(sql_str);
+ if(res.next()) {
+ isExists = true;
+ }
+ } catch (SQLException e) {
+ e.printStackTrace();
+ } finally {
+ if(null != res) {
+ try {
+ res.close();
+ } catch (SQLException e) {
+ e.printStackTrace();
+ }
+ }
+ sql.close_con();
+ }
+ return isExists;
+ }
+
}
--
Gitblit v1.9.1