From 01218fde055b6fcd55f2820caa20cf9dd0c6d7e3 Mon Sep 17 00:00:00 2001
From: Administrator <1525436766@qq.com>
Date: 星期二, 09 八月 2022 14:31:02 +0800
Subject: [PATCH] V1.37 edit at date 2022-08-09 	1.默认创建'db_pwrdev_data_rt.tb_pwrdev_event'表用于记录山西61850设备的交流输入1/2的状态切换记录

---
 BattMonitor_DB_Builder/src/com/database_util/DB_Pwrdev_Data_Rt.java |   56 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 56 insertions(+), 0 deletions(-)

diff --git a/BattMonitor_DB_Builder/src/com/database_util/DB_Pwrdev_Data_Rt.java b/BattMonitor_DB_Builder/src/com/database_util/DB_Pwrdev_Data_Rt.java
index 08622dd..cb90000 100644
--- a/BattMonitor_DB_Builder/src/com/database_util/DB_Pwrdev_Data_Rt.java
+++ b/BattMonitor_DB_Builder/src/com/database_util/DB_Pwrdev_Data_Rt.java
@@ -15,6 +15,8 @@
 		createPwrdev_Acdcdata_Table(pool, recreate);
 		
 		createPwrdev_Dcdata_Table(pool, recreate);
+		
+		createPwrdev_Event_Table(pool,recreate);
 	}
 
 	/**
@@ -2111,6 +2113,30 @@
 				sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.Pwrdev_Acdcdata_Table 
 						+ " ADD COLUMN `acIn2_currC` float NOT NULL DEFAULT '0';");
 			}
+			
+			//添加acIn1_switch_st字段
+			res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
+					+ " WHERE table_schema='db_pwrdev_data_rt'"
+					+ " AND table_name='tb_pwrdev_acdcdata'"
+					+ " AND column_name='acIn1_switch_st'");
+			if(false == res.next()) {
+				sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.Pwrdev_Acdcdata_Table 
+						+ " ADD COLUMN `acIn1_switch_st` int(11) NOT NULL DEFAULT '0' COMMENT '交流输入1分合闸状态:0---未知(用于兼容以前的),1-分闸,2-合闸,3-脱扣',;");
+			}
+			
+			//添加acIn2_switch_st字段
+			res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
+					+ " WHERE table_schema='db_pwrdev_data_rt'"
+					+ " AND table_name='tb_pwrdev_acdcdata'"
+					+ " AND column_name='acIn2_switch_st'");
+			if(false == res.next()) {
+				sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.Pwrdev_Acdcdata_Table 
+						+ " ADD COLUMN `acIn2_switch_st` int(11) NOT NULL DEFAULT '0' COMMENT '交流输入2分合闸状态	:0---未知(用于兼容以前的),1-分闸,2-合闸,3-脱扣',;");
+			}
+		  
+
+			
+			
 		} catch (SQLException e) {
 			e.printStackTrace();
 		} finally {
@@ -2180,6 +2206,36 @@
 	}
 	
 	/**
+	 * 	创建   tb_pwrdev_event 表
+	 * @param pool
+	 * @param recreate
+	 */
+	public static void createPwrdev_Event_Table(MysqlConnPool pool, boolean recreate) {
+		String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Pwrdev_Event_Table;
+		String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Pwrdev_Event_Table + " (" + 
+				"  `num` bigint(20) NOT NULL AUTO_INCREMENT," + 
+				"  `power_device_id` int(11) NOT NULL DEFAULT '0' COMMENT '电源ID'," + 
+				"  `record_time` datetime NOT NULL DEFAULT '2000-01-01 00:00:00' COMMENT '记录事件'," + 
+				"  `now_state` int(11) NOT NULL DEFAULT '0' COMMENT '当前状态'," + 
+				"  `last_state` int(11) NOT NULL DEFAULT '0' COMMENT '上一次状态'," + 
+				"  `event_type` int(11) NOT NULL DEFAULT '0' COMMENT '事件类型'," + 
+				"  `event_txt` text NOT NULL COMMENT '事件描述'," + 
+				"  PRIMARY KEY (`num`)" + 
+				") ENGINE=InnoDB AUTO_INCREMENT=246 DEFAULT CHARSET=utf8;";
+		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();
+		}
+	}
+	
+	/**
 	 * 	创建   tb_pwrdev_acdata 表
 	 * @param pool
 	 * @param recreate

--
Gitblit v1.9.1