From 0c2a13425088177cda9f9c1caf5c99131645b74a Mon Sep 17 00:00:00 2001
From: DELL <1525436766@qq.com>
Date: 星期二, 02 七月 2024 16:42:43 +0800
Subject: [PATCH] 添加电池告警遥信遥调

---
 iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_Task_Thread_SQL.java |  132 ++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 132 insertions(+), 0 deletions(-)

diff --git a/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_Task_Thread_SQL.java b/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_Task_Thread_SQL.java
index c32b3d5..6c8d745 100644
--- a/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_Task_Thread_SQL.java
+++ b/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_Task_Thread_SQL.java
@@ -1331,6 +1331,13 @@
 		} catch (SQLException e) {
 			sql.logger.error("FBS9100_Task_Thread_SQL.queryFBS9100SysParamBydev_id():" + e.toString(), e);
 		} finally {
+			if(null != res) {
+				try {
+					res.close();
+				} catch (SQLException e) {
+					sql.logger.error("FBS9100_Task_Thread_SQL.queryFBS9100SysParamBydev_id():" + e.toString(), e);
+				}
+			}
 			sql.close_con();
 		}
 	}
@@ -1535,6 +1542,13 @@
 		} catch (SQLException e) {
 			sql.logger.error("FBS9100_Task_Thread_SQL.queryBTS61850OffLineyhPlanOnRam():" + e.toString(), e);
 		} finally {
+			if(null != res) {
+				try {
+					res.close();
+				} catch (SQLException e) {
+					sql.logger.error("FBS9100_Task_Thread_SQL.queryBTS61850OffLineyhPlanOnRam():" + e.toString(), e);
+				}
+			}
 			sql.close_con();
 		}
 	}
@@ -1707,4 +1721,122 @@
 		queryBTS61850OffLineyhPlanOnRam(pool, param);
 		
 	}
+
+	/**
+	 * 鏌ヨ璁惧鐨勫憡璀﹀弬鏁�
+	 * @param con_pool
+	 * @param param
+	 */
+	public static void queryDev6185AlmParamBydev_id(MysqlConnPool con_pool, FBS9100_StatAndParam param) {
+		String sql_str = "SELECT * FROM " + Sql_Mysql.Dev_6185_AlmParam + " where dev_id = " + param.dev_id;
+		Sql_Mysql sql = new Sql_Mysql(con_pool);
+		ResultSet res = sql.sqlMysqlQuery(sql_str);
+		try {
+			if(res.next())
+			{
+				if(null != param) {
+					param.m_FBS_AlmParam.op_cmd = res.getInt("op_cmd");
+					param.m_FBS_AlmParam.groupvol_high_val = res.getFloat("groupvol_high_val");;	//'缁勭鐢靛帇楂橀槇鍊�',
+					param.m_FBS_AlmParam.groupvol_low_val = res.getFloat("groupvol_low_val");		//'缁勭鐢靛帇浣庨槇鍊�',
+					param.m_FBS_AlmParam.monvol_high_val = res.getFloat("monvol_high_val");			//'鍗曚綋鐢靛帇楂橀槇鍊�',
+					param.m_FBS_AlmParam.monvol_low_val = res.getFloat("monvol_low_val");			//'鍗曚綋鐢靛帇浣庨槇鍊�',
+					param.m_FBS_AlmParam.montmp_high_val = res.getFloat("montmp_high_val");			//'鍗曚綋娓╁害楂橀槇鍊�',
+					param.m_FBS_AlmParam.montmp_low_val = res.getFloat("montmp_low_val");			//'鍗曚綋娓╁害浣庨槇鍊�',
+					param.m_FBS_AlmParam.monres_high_val = res.getFloat("monres_high_val");			//'鍗曚綋鍐呴樆楂橀槇鍊�',
+					param.m_FBS_AlmParam.monres_low_val = res.getFloat("monres_low_val");			//'鍗曚綋鍐呴樆浣庨槇鍊�',
+					param.m_FBS_AlmParam.moncap_high_val = res.getFloat("moncap_high_val");			//'鍗曚綋瀹归噺楂橀槇鍊�',
+					param.m_FBS_AlmParam.moncap_low_val = res.getFloat("moncap_low_val");			//'鍗曚綋瀹归噺浣庨槇鍊�',
+				}
+			}
+		} catch (SQLException e) {
+			sql.logger.error("FBS9100_Task_Thread_SQL.queryDev6185AlmParamBydev_id():" + e.toString(), e);
+		} finally {
+			if(null != res) {
+				try {
+					res.close();
+				} catch (SQLException e) {
+					sql.logger.error("FBS9100_Task_Thread_SQL.queryDev6185AlmParamBydev_id():" + e.toString(), e);
+				}
+			}
+			sql.close_con();
+		}
+	}
+
+	public static void UpdateDev61850AlmParam(MysqlConnPool con_pool,FBS9100_AlarmParam almparam,FBS9100_StatAndParam param){
+		String sql_str_base = Sql_Mysql.Dev_6185_AlmParam 
+				+ " SET "
+				+ "dev_id=" + param.dev_id + ", "
+				+ "groupvol_high_val=" + almparam.groupvol_high_val + ", "
+				+ "groupvol_low_val=" + almparam.groupvol_low_val + ", "
+				+ "monvol_high_val=" + almparam.monvol_high_val + ", "
+				+ "monvol_low_val=" + almparam.monvol_low_val + ", "
+				+ "montmp_high_val=" + almparam.montmp_high_val + ", "
+				+ "montmp_low_val=" + almparam.montmp_low_val + ", "
+				+ "monres_high_val=" + almparam.monres_high_val + ", "
+				+ "monres_low_val=" + almparam.monres_low_val + ", "
+				+ "moncap_high_val=" + almparam.moncap_high_val + ", "
+				+ "moncap_low_val=" + almparam.moncap_low_val ;
+		String sql_str_update = "UPDATE " + sql_str_base + " WHERE dev_id=" + param.dev_id;
+		
+		Sql_Mysql sql = new Sql_Mysql(con_pool);
+		try {
+			sql.sqlMysqlExecute(sql_str_update);
+		} catch (SQLException e) {
+			sql.logger.error("FBS9100_Task_Thread_SQL.inseartOrUpdateFBS9100SFODParam():" + e.toString(), e);
+		} finally {
+			sql.close_con();
+		}
+	}
+
+	public static void updateDev61850AlmParamCmdBydev_id(MysqlConnPool con_pool, FBS9100_StatAndParam param)
+	{
+		if((param.op_cmd == FBS9100_ComBase.CMD_ReadAlarmParam_ACK) 
+				|| (param.op_cmd == FBS9100_ComBase.CMD_FAIL)
+				|| (param.op_cmd == FBS9100_ComBase.CMD_WriteAlarmParam_ACK)) 
+		{
+			String sql_str_base = Sql_Mysql.Dev_6185_AlmParam + " SET "
+					+ " dev_id=" + param.dev_id + ", "
+					+ " op_cmd=" + param.op_cmd + " "
+					+ " where dev_id = "+param.dev_id;
+			String sql_str_update = "UPDATE " + sql_str_base;
+			Sql_Mysql sql = new Sql_Mysql(con_pool);
+			try {
+				sql.sqlMysqlExecute(sql_str_update);
+			} catch (SQLException e) {
+				sql.logger.error("FBS9100_Task_Thread_SQL.updateDev61850AlmParamCmdBydev_id():" + e.toString(), e);
+			} finally {
+				sql.close_con();
+			}
+			
+			param.m_FBS_AlmParam.op_cmd = param.op_cmd;
+			param.op_cmd = FBS9100_ComBase.CMD_NULL;
+		}
+	}
+
+	/****************************************************************************************************/
+	public static void inseartDev_6185_AlmParam(MysqlConnPool con_pool,int dev_id){
+		String sql_str_ins = " insert into " + Sql_Mysql.Dev_6185_AlmParam+ "(dev_id) values(" + dev_id +");";
+		
+		Sql_Mysql sql = new Sql_Mysql(con_pool);
+		ResultSet res = null;
+		try {
+			res = sql.sqlMysqlQuery("SELECT num FROM " + Sql_Mysql.Dev_6185_AlmParam 
+					+ " WHERE dev_id = " + dev_id);
+			
+			if(!res.next()) {
+				sql.sqlMysqlExecute(sql_str_ins);
+			}
+		} catch (SQLException e) {
+			sql.logger.error("FBS9100_Task_Thread_SQL.inseartDev_6185_AlmParam():" + e.toString(), e);
+		} finally {
+			if(null != res) {
+				try {
+					res.close();
+				} catch (SQLException e) {					
+					sql.logger.error("FBS9100_Task_Thread_SQL.inseartOrUpdateFBS9100SFODParam():" + e.toString(), e);
+				}
+			}
+			sql.close_con();
+		}
+	}
 }

--
Gitblit v1.9.1