| | |
| | | |
| | | createTb_Alarm_Message(pool, recreate); |
| | | |
| | | createTb_Alarm_Detail_Table(pool, recreate); //创建告警详情 |
| | | |
| | | System.out.println(" db_alarm init end at " + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)); |
| | | } |
| | |
| | | public static void createTb_Alarm_Message(MysqlConnPool pool, boolean recreate) { |
| | | String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Tb_Alarm_Message; |
| | | String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Tb_Alarm_Message + " (" + |
| | | "`id` bigint(19) NOT NULL AUTO_INCREMENT,\n" + |
| | | " `phone` varchar(15) DEFAULT NULL COMMENT '短信发送至手机号',\n" + |
| | | " `full_device_name` varchar(255) DEFAULT NULL COMMENT '设备全名',\n" + |
| | | " `alarm_time_category` varchar(255) DEFAULT NULL COMMENT '告警时间段',\n" + |
| | | " `alarm_message` varchar(255) DEFAULT NULL COMMENT '告警信息',\n" + |
| | | " `alarm_ids` varchar(255) DEFAULT NULL COMMENT '短信对应的告警id',\n" + |
| | | " `create_time` datetime DEFAULT NULL,\n" + |
| | | " `update_time` datetime DEFAULT NULL COMMENT '记录更新时间',\n" + |
| | | " `status` tinyint(1) DEFAULT NULL COMMENT '发送状态,0-未发送,1-发送完成,2-发送失败',\n" + |
| | | "`id` bigint(19) NOT NULL AUTO_INCREMENT," + |
| | | " `phone` varchar(15) DEFAULT NULL COMMENT '短信发送至手机号'," + |
| | | " `full_device_name` varchar(255) DEFAULT NULL COMMENT '设备全名'," + |
| | | " `alarm_time_category` varchar(255) DEFAULT NULL COMMENT '告警时间段'," + |
| | | " `alarm_message` varchar(255) DEFAULT NULL COMMENT '告警信息'," + |
| | | " `alarm_ids` varchar(255) DEFAULT NULL COMMENT '短信对应的告警id'," + |
| | | " `create_time` datetime DEFAULT NULL," + |
| | | " `update_time` datetime DEFAULT NULL COMMENT '记录更新时间'," + |
| | | " `status` tinyint(1) DEFAULT NULL COMMENT '发送状态,0-未发送,1-发送完成,2-发送失败'," + |
| | | " PRIMARY KEY (`id`)" + |
| | | ") ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4 COMMENT='告警短信';"; |
| | | Sql_Mysql sql = new Sql_Mysql(pool.getConn()); |
| | |
| | | sql.close_con(); |
| | | } |
| | | } |
| | | /** |
| | | * |
| | | * @Title: createTb_Alarm_Message |
| | | * @Description: 告警短信 |
| | | * @param pool |
| | | * @param recreate |
| | | * @author author |
| | | * @date 2021年9月6日 |
| | | */ |
| | | public static void createTb_Alarm_Detail_Table(MysqlConnPool pool, boolean recreate) { |
| | | String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Tb_Alarm_Detail_Table; |
| | | String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Tb_Alarm_Detail_Table + " (" + |
| | | " `id` bigint(19) NOT NULL AUTO_INCREMENT," + |
| | | " `alm_id` varchar(15) DEFAULT NULL COMMENT '告警id'," + |
| | | " `alm_reason` text COMMENT '告警原因'," + |
| | | " `alm_advice` varchar(255) DEFAULT NULL COMMENT '告警建议'," + |
| | | " `alm_type` int(5) NOT NULL DEFAULT '0' COMMENT '告警来源:0电源,1设备,2电池'," + |
| | | " PRIMARY KEY (`id`)" + |
| | | ") ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4 COMMENT='告警详情';"; |
| | | Sql_Mysql sql = new Sql_Mysql(pool.getConn()); |
| | | try { |
| | | if(true == recreate) { |
| | | sql.sqlMysqlExecute(sql_str01); |
| | | } |
| | | sql.sqlMysqlExecute(sql_str02); |
| | | } catch (SQLException e) { |
| | | e.printStackTrace(); |
| | | } finally { |
| | | sql.close_con(); |
| | | } |
| | | } |
| | | |
| | | |
| | | } |