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/Sql_Mysql.java | 2
iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/FBS9100_ComBase.class | 0
iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/Sql_Mysql.class | 0
iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/BTS_61850_SocketClient.class | 0
iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_StatAndParam.java | 6 +
iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/FBS9100_StatAndParam.class | 0
iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_Task_Thread_SQL.java | 132 ++++++++++++++++++++++++++
iec61850_forFoShanAES_Model/src/com/dec/fbs9100/BTS_61850_SocketClient.java | 87 +++++++++++++++++
iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/FBS9100_Task_Thread_SQL.class | 0
iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_ComBase.java | 6 +
iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_AlarmParam.java | 58 +++++++++++
11 files changed, 291 insertions(+), 0 deletions(-)
diff --git a/iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/BTS_61850_SocketClient.class b/iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/BTS_61850_SocketClient.class
index 082a39c..795b1e8 100644
--- a/iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/BTS_61850_SocketClient.class
+++ b/iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/BTS_61850_SocketClient.class
Binary files differ
diff --git a/iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/FBS9100_ComBase.class b/iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/FBS9100_ComBase.class
index 9c93b8e..741a97f 100644
--- a/iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/FBS9100_ComBase.class
+++ b/iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/FBS9100_ComBase.class
Binary files differ
diff --git a/iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/FBS9100_StatAndParam.class b/iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/FBS9100_StatAndParam.class
index 78ed409..452e01b 100644
--- a/iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/FBS9100_StatAndParam.class
+++ b/iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/FBS9100_StatAndParam.class
Binary files differ
diff --git a/iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/FBS9100_Task_Thread_SQL.class b/iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/FBS9100_Task_Thread_SQL.class
index 8be8ce5..230091b 100644
--- a/iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/FBS9100_Task_Thread_SQL.class
+++ b/iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/FBS9100_Task_Thread_SQL.class
Binary files differ
diff --git a/iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/Sql_Mysql.class b/iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/Sql_Mysql.class
index 5f06baf..c13f7c6 100644
--- a/iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/Sql_Mysql.class
+++ b/iec61850_forFoShanAES_Model/bin/com/dec/fbs9100/Sql_Mysql.class
Binary files differ
diff --git a/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/BTS_61850_SocketClient.java b/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/BTS_61850_SocketClient.java
index ec0fd9c..6539d99 100644
--- a/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/BTS_61850_SocketClient.java
+++ b/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/BTS_61850_SocketClient.java
@@ -43,6 +43,11 @@
private FBS9100_VCData m_FBS_VCData = null;
private FBS9100_ParamDischarge m_FBS_DiscParam = null;
private FBS9100_ParamDischarge m_FBS_DiscParamFromDev = null;
+
+ private FBS9100_AlarmParam m_FBS_AlmParamFromDev = null;
+ private FBS9100_AlarmParam m_FBS_AlmParam = null;
+
+
private FBS9100_SysParam m_FBS_SysParam = null;
private FBS9100_StatAndParam m_StatAndParam = null;
FBS9100_JHPowerState fbs9100_jhpowerState = null;
@@ -84,6 +89,7 @@
private Logger logger = null;
+ private int bg_num = 1;
/*********************************************************************************************/
/*********************************************************************************************/
public BTS_61850_SocketClient(MysqlConnPool m_cp, FBS9100_StatAndParam stat_param,
@@ -96,6 +102,10 @@
m_FBS_VCData = m_StatAndParam.m_FBS_VCData;
m_FBS_DiscParam = m_StatAndParam.m_FBS_DiscParam;
m_FBS_DiscParamFromDev = m_StatAndParam.m_FBS_DiscParamFromDev;
+
+ m_FBS_AlmParamFromDev = m_StatAndParam.m_FBS_AlmParamFromDev;
+ m_FBS_AlmParam = m_StatAndParam.m_FBS_AlmParam;
+
fbs9100_jhpowerState = m_StatAndParam.fbs9100_jhpowerState;
cl_param = stat_param.clParam;
m_FBS_SysParam = stat_param.m_FBS_SysParam;
@@ -170,6 +180,10 @@
if(this.FBSDeviceName.indexOf("BTSE")>0) {
//閫傞厤鍚勪釜涓嶅悓鍗忚鍚嶇О鐨�61850璁惧閫氫俊[璇诲彇鏀剧數鍙傛暟鏃剁敤鍒癩
ZJDYCPSS = this.FBSDeviceName.replace("BTSE", "CPSS");
+ if(ZJDYCPSS.contains("2")) {
+ //鏍囪瘑绗簩缁�
+ bg_num = 2;
+ }
}
logger.debug("Successfully connected to ied server " + FBSDeviceIp + " " + FBSDeviceName + "\t CPSS:"+ZJDYCPSS);
@@ -206,6 +220,8 @@
FBS9100_Task_Thread_SQL.queryBTS61850OffLineyhPlanOnRam(m_ConnPool, m_StatAndParam);
+ FBS9100_Task_Thread_SQL.inseartDev_6185_AlmParam(m_ConnPool, m_StatAndParam.dev_id);
+
m_StatAndParam.keyID = readStringNodeData(FBSDeviceName+"/btgGGIO1.ukeyID.d",Fc.DC);
m_StatAndParam.serialNumber = readStringNodeData(FBSDeviceName+"/btgGGIO1.Bts_ID.d",Fc.DC); //鍞竴搴忓垪鍙�
BTS61850_Task_Thread_SQL.UpdateBattInfTable(m_ConnPool, m_StatAndParam); //鏇存柊褰撳墠鍙傛暟
@@ -228,6 +244,8 @@
FBS9100_Task_Thread_SQL.queryFbsCL9100SetParamBydev_id(m_ConnPool, m_StatAndParam); // 鏌ヨ绂荤嚎鍏绘姢鍙傛暟
FBS9100_Task_Thread_SQL.queryFBS9100SysParamBydev_id(m_ConnPool, m_StatAndParam); // 鏌ヨ绯荤粺鍙傛暟
+
+ FBS9100_Task_Thread_SQL.queryDev6185AlmParamBydev_id(m_ConnPool, m_StatAndParam); // 鏌ヨ鍛婅鍙傛暟
}
}
@@ -415,6 +433,28 @@
}
FBS9100_Task_Thread_SQL.updateCL9100SetParamCmdBydev_id(m_ConnPool, m_StatAndParam);
+ }
+
+ if (FBS9100_ComBase.CMD_NULL != m_FBS_AlmParam.op_cmd) {
+ if (FBS9100_ComBase.CMD_ReadAlarmParam == m_FBS_AlmParam.op_cmd) {
+ System.out.println("璇诲彇鍛婅鍙傛暟"+m_FBS_AlmParam.op_cmd);
+ //璇诲彇鍛婅鍙傛暟
+ if (true == BTS_IEC61850_SocketComm(FBS9100_ComBase.CMD_ReadAlarmParam)) {
+ m_StatAndParam.op_cmd = FBS9100_ComBase.CMD_ReadAlarmParam_ACK;
+
+ FBS9100_Task_Thread_SQL.UpdateDev61850AlmParam(m_ConnPool,m_StatAndParam.m_FBS_AlmParamFromDev, m_StatAndParam);
+ }else {
+ m_StatAndParam.op_cmd = FBS9100_ComBase.CMD_FAIL;
+ }
+ }else if(FBS9100_ComBase.CMD_WriteAlarmParam == m_FBS_AlmParam.op_cmd) {
+ //璁剧疆鍛婅鍙傛暟
+ if (true == BTS_IEC61850_SocketComm(FBS9100_ComBase.CMD_WriteAlarmParam)) {
+ m_StatAndParam.op_cmd = FBS9100_ComBase.CMD_WriteAlarmParam_ACK;
+ }else {
+ m_StatAndParam.op_cmd = FBS9100_ComBase.CMD_FAIL;
+ }
+ }
+ FBS9100_Task_Thread_SQL.updateDev61850AlmParamCmdBydev_id(m_ConnPool, m_StatAndParam);
}
// -----------------------------------------------------------------------------------//
// -----------------------------------------------------------------------------------//
@@ -1842,6 +1882,53 @@
if(!setBTSPublicKeyY(getUKEYRootDomStr(FBSDeviceName,sign_type)+"/ncdGGIO1.SysTime_SYS.setMag.i"));
comm_res = writeNodeData_Int64(FBSDeviceName + "/ncdGGIO1.SysTime_SYS.setMag.i", "SP",time_l);
logger.printf(Level.WARN, "DevIp:%s operate FBS9100_ComBase.CMD_UpdateXZTime , SetTime:"+Com.getDateTimeFormat(m_StatAndParam.m_FBS_DiscParam.OffLineYHstarttime, Com.DTFYMDhms), FBSDeviceIp);
+ }else if(FBS9100_ComBase.CMD_ReadAlarmParam == cmd) {
+
+ //璇诲彇鍛婅鍙傛暟
+ m_FBS_AlmParamFromDev.groupvol_high_val = readFloatNodeData(ZJDYCPSS + "/cheGGIO" + bg_num + ".Para1.setMag.f", Fc.SP);
+ m_FBS_AlmParamFromDev.groupvol_low_val = readFloatNodeData(ZJDYCPSS + "/cheGGIO" + bg_num + ".Para2.setMag.f", Fc.SP);
+ m_FBS_AlmParamFromDev.monvol_high_val = readFloatNodeData(ZJDYCPSS + "/cheGGIO" + bg_num + ".Para3.setMag.f", Fc.SP);
+ m_FBS_AlmParamFromDev.monvol_low_val = readFloatNodeData(ZJDYCPSS + "/cheGGIO" + bg_num + ".Para4.setMag.f", Fc.SP);
+ m_FBS_AlmParamFromDev.monres_high_val = readFloatNodeData(ZJDYCPSS + "/cheGGIO" + bg_num + ".Para5.setMag.f", Fc.SP);
+ m_FBS_AlmParamFromDev.monres_low_val = readFloatNodeData(ZJDYCPSS + "/cheGGIO" + bg_num + ".Para6.setMag.f", Fc.SP);
+ m_FBS_AlmParamFromDev.montmp_high_val = readFloatNodeData(ZJDYCPSS + "/cheGGIO" + bg_num + ".Para7.setMag.f", Fc.SP);
+ m_FBS_AlmParamFromDev.montmp_low_val = readFloatNodeData(ZJDYCPSS + "/cheGGIO" + bg_num + ".Para8.setMag.f", Fc.SP);
+ m_FBS_AlmParamFromDev.moncap_high_val = readFloatNodeData(ZJDYCPSS + "/cheGGIO" + bg_num + ".Para9.setMag.f", Fc.SP);
+ m_FBS_AlmParamFromDev.moncap_low_val = readFloatNodeData(ZJDYCPSS + "/cheGGIO" + bg_num + ".Para10.setMag.f", Fc.SP);
+ //System.out.println(m_FBS_AlmParamFromDev);
+ comm_res = true;
+ }else if(FBS9100_ComBase.CMD_WriteAlarmParam == cmd) {
+ //璁剧疆鍛婅鍙傛暟
+ if(!setBTSPublicKeyY("CPSS/cheGGIO" + bg_num + ".Para1.setMag.f"));
+ writeNodeData(ZJDYCPSS + "/cheGGIO" + bg_num + ".Para1.setMag.f", "SP", m_FBS_AlmParam.groupvol_high_val);
+
+ if(!setBTSPublicKeyY("CPSS/cheGGIO" + bg_num + ".Para2.setMag.f"));
+ writeNodeData(ZJDYCPSS + "/cheGGIO" + bg_num + ".Para2.setMag.f", "SP", m_FBS_AlmParam.groupvol_low_val);
+
+ if(!setBTSPublicKeyY("CPSS/cheGGIO" + bg_num + ".Para3.setMag.f"));
+ writeNodeData(ZJDYCPSS + "/cheGGIO" + bg_num + ".Para3.setMag.f", "SP", m_FBS_AlmParam.monvol_high_val);
+
+ if(!setBTSPublicKeyY("CPSS/cheGGIO" + bg_num + ".Para4.setMag.f"));
+ writeNodeData(ZJDYCPSS + "/cheGGIO" + bg_num + ".Para4.setMag.f", "SP", m_FBS_AlmParam.monvol_low_val);
+
+ if(!setBTSPublicKeyY("CPSS/cheGGIO" + bg_num + ".Para5.setMag.f"));
+ writeNodeData(ZJDYCPSS + "/cheGGIO" + bg_num + ".Para5.setMag.f", "SP", m_FBS_AlmParam.monres_high_val);
+
+ if(!setBTSPublicKeyY("CPSS/cheGGIO" + bg_num + ".Para6.setMag.f"));
+ writeNodeData(ZJDYCPSS + "/cheGGIO" + bg_num + ".Para6.setMag.f", "SP", m_FBS_AlmParam.monres_low_val);
+
+ if(!setBTSPublicKeyY("CPSS/cheGGIO" + bg_num + ".Para7.setMag.f"));
+ writeNodeData(ZJDYCPSS + "/cheGGIO" + bg_num + ".Para7.setMag.f", "SP", m_FBS_AlmParam.montmp_high_val);
+
+ if(!setBTSPublicKeyY("CPSS/cheGGIO" + bg_num + ".Para8.setMag.f"));
+ writeNodeData(ZJDYCPSS + "/cheGGIO" + bg_num + ".Para8.setMag.f", "SP", m_FBS_AlmParam.montmp_low_val);
+
+ if(!setBTSPublicKeyY("CPSS/cheGGIO" + bg_num + ".Para9.setMag.f"));
+ writeNodeData(ZJDYCPSS + "/cheGGIO" + bg_num + ".Para9.setMag.f", "SP", m_FBS_AlmParam.moncap_high_val);
+
+ if(!setBTSPublicKeyY("CPSS/cheGGIO" + bg_num + ".Para10.setMag.f"));
+ writeNodeData(ZJDYCPSS + "/cheGGIO" + bg_num + ".Para10.setMag.f", "SP", m_FBS_AlmParam.moncap_low_val);
+ comm_res = true;
}
//comm_res = true;
} catch (Exception e) {
diff --git a/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_AlarmParam.java b/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_AlarmParam.java
new file mode 100644
index 0000000..42b0f98
--- /dev/null
+++ b/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_AlarmParam.java
@@ -0,0 +1,58 @@
+package com.dec.fbs9100;
+
+public class FBS9100_AlarmParam implements Cloneable
+{
+ private final int BYTE_LEN = 44;
+
+ public int op_cmd;
+
+ public float groupvol_high_val; //'缁勭鐢靛帇楂橀槇鍊�',
+ public float groupvol_low_val; //'缁勭鐢靛帇浣庨槇鍊�',
+ public float monvol_high_val; //'鍗曚綋鐢靛帇楂橀槇鍊�',
+ public float monvol_low_val; //'鍗曚綋鐢靛帇浣庨槇鍊�',
+ public float montmp_high_val; //'鍗曚綋娓╁害楂橀槇鍊�',
+ public float montmp_low_val; //'鍗曚綋娓╁害浣庨槇鍊�',
+ public float monres_high_val; //'鍗曚綋鍐呴樆楂橀槇鍊�',
+ public float monres_low_val; //'鍗曚綋鍐呴樆浣庨槇鍊�',
+ public float moncap_high_val; //'鍗曚綋瀹归噺楂橀槇鍊�',
+ public float moncap_low_val; //'鍗曚綋瀹归噺浣庨槇鍊�',
+
+ public FBS9100_AlarmParam clone()
+ {
+ FBS9100_AlarmParam obj = null;
+ try
+ {
+ obj = (FBS9100_AlarmParam)super.clone();
+ }
+ catch(CloneNotSupportedException e)
+ {
+ e.printStackTrace();
+ }
+ return obj;
+ }
+
+ public void clear()
+ {
+ this.groupvol_high_val = 0; //'缁勭鐢靛帇楂橀槇鍊�',
+ this.groupvol_low_val = 0; //'缁勭鐢靛帇浣庨槇鍊�',
+ this.monvol_high_val = 0; //'鍗曚綋鐢靛帇楂橀槇鍊�',
+ this.monvol_low_val = 0; //'鍗曚綋鐢靛帇浣庨槇鍊�',
+ this.montmp_high_val = 0; //'鍗曚綋娓╁害楂橀槇鍊�',
+ this.montmp_low_val = 0; //'鍗曚綋娓╁害浣庨槇鍊�',
+ this.monres_high_val = 0; //'鍗曚綋鍐呴樆楂橀槇鍊�',
+ this.monres_low_val = 0; //'鍗曚綋鍐呴樆浣庨槇鍊�',
+ this.moncap_high_val = 0; //'鍗曚綋瀹归噺楂橀槇鍊�',
+ this.moncap_low_val = 0; //'鍗曚綋瀹归噺浣庨槇鍊�',
+ }
+
+ @Override
+ public String toString() {
+ return "FBS9100_ParamCharge [BYTE_LEN=" + BYTE_LEN + ", op_cmd=" + op_cmd + ", groupvol_high_val="
+ + groupvol_high_val + ", groupvol_low_val=" + groupvol_low_val + ", monvol_high_val=" + monvol_high_val
+ + ", monvol_low_val=" + monvol_low_val + ", montmp_high_val=" + montmp_high_val + ", montmp_low_val="
+ + montmp_low_val + ", monres_high_val=" + monres_high_val + ", monres_low_val=" + monres_low_val
+ + ", moncap_high_val=" + moncap_high_val + ", moncap_low_val=" + moncap_low_val + "]";
+ }
+
+
+}
\ No newline at end of file
diff --git a/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_ComBase.java b/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_ComBase.java
index 526a8fc..030e08b 100644
--- a/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_ComBase.java
+++ b/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_ComBase.java
@@ -107,6 +107,12 @@
public static final int CMD_SetJuHengParam = 0xC3; //璁剧疆鍧囪 鍙傛暟
public static final int CMD_SetJuHengParamAck = 0xC4; //璁剧疆鍧囪 鍙傛暟鎴愬姛
+ //------------- 鏍稿6185涓撳睘鍛婅鍙傛暟 -----------------------------------------------------------
+ public static final int CMD_ReadAlarmParam = 0xC5; //璇诲彇鍛婅
+ public static final int CMD_ReadAlarmParam_ACK = 0xC6; //璇诲彇鍛婅鎴愬姛
+ public static final int CMD_WriteAlarmParam = 0xC7; //璁剧疆鍛婅
+ public static final int CMD_WriteAlarmParam_ACK = 0xC8; //璁剧疆鍛婅鎴愬姛
+
public static final int CMD_UpdateXZTime = 0xD1; //璁剧疆鍗忚浆鏃堕棿
public static final int CMD_UpdateXZTimeAck = 0xD2; //璁剧疆鍗忚浆鏃堕棿鎴愬姛
//------------------------------------------------------------------------------
diff --git a/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_StatAndParam.java b/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_StatAndParam.java
index 639452c..1f8061d 100644
--- a/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_StatAndParam.java
+++ b/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_StatAndParam.java
@@ -21,6 +21,9 @@
public FBS9100_batt_testparam test_Param = null; //褰撳墠璁剧疆鎴愬姛鐨勫厖鏀剧數鍙傛暟
+ public FBS9100_AlarmParam m_FBS_AlmParamFromDev = null;
+ public FBS9100_AlarmParam m_FBS_AlmParam = null;
+
public String m_DevVersion = "";
public String publicKeyX="";
@@ -50,6 +53,9 @@
clParam = new CL_Param();
test_Param = new FBS9100_batt_testparam();
+
+ m_FBS_AlmParamFromDev = new FBS9100_AlarmParam();
+ m_FBS_AlmParam = new FBS9100_AlarmParam();
}
@Override
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();
+ }
+ }
}
diff --git a/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/Sql_Mysql.java b/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/Sql_Mysql.java
index fa59203..2b151a9 100644
--- a/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/Sql_Mysql.java
+++ b/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/Sql_Mysql.java
@@ -80,6 +80,8 @@
public final static String FBS9100_61850_jhstate_Table = DB_RamDB + ".`tb_61850_jhstate`";
public final static String FBS9100_offlineyhplan = DB_RamDB + ".tb_fbs9100_offlineyhplan"; //61850绂荤嚎鍏绘姢璁″垝鍙傛暟琛�
+
+ public final static String Dev_6185_AlmParam = DB_RamDB + ".tb_dev_6185_almparam";
//--------------------------------------------------------------------------------------------//
//--------------------------------------------------------------------------------------------//
public final static String AppSys_Table = DB_AppSys + ".`tb_app_sys`";
--
Gitblit v1.9.1