From 9cf4fd8697365dfcf1809c0c5dd4a8c151a4f51e Mon Sep 17 00:00:00 2001
From: whyclj <1525436766@qq.com>
Date: 星期六, 19 九月 2020 13:50:29 +0800
Subject: [PATCH] 添加设备连接状态记录
---
ElectricalSystem_MonitorServer_4KW/src/com/electrical/FourKW/Electrical_Task_SQL.java | 34 ++++++++++++++++++++++++++++++++++
1 files changed, 34 insertions(+), 0 deletions(-)
diff --git a/ElectricalSystem_MonitorServer_4KW/src/com/electrical/FourKW/Electrical_Task_SQL.java b/ElectricalSystem_MonitorServer_4KW/src/com/electrical/FourKW/Electrical_Task_SQL.java
index ae7e7a1..a660587 100644
--- a/ElectricalSystem_MonitorServer_4KW/src/com/electrical/FourKW/Electrical_Task_SQL.java
+++ b/ElectricalSystem_MonitorServer_4KW/src/com/electrical/FourKW/Electrical_Task_SQL.java
@@ -8,6 +8,7 @@
import java.util.List;
import com.base.Com;
+import com.modbus.data.MyModbusMaster;
import com.mysql.jdbc.EscapeTokenizer;
import com.sql.MysqlConnPool;
import com.sql.Sql_Mysql;
@@ -893,4 +894,37 @@
sql.close_con();
}
}
+
+ /**
+ * 插入或更新当前设备的连接状态
+ * @param pool
+ * @param dev_id
+ * @param master
+ */
+ public static void insertOrUpdateDeviceConnectState(MysqlConnPool pool,int dev_id,MyModbusMaster master) {
+ String sql_str_sel = " SELECT * FROM "+Sql_Mysql.Tb_Device_ConnectState+" WHERE dev_id = " + dev_id;
+ String sql_str_ins = " INSERT INTO "+Sql_Mysql.Tb_Device_ConnectState+"(dev_id,connect_en,record_time) values("+dev_id+","+master.getConnectState()+",'"+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)+"');";
+ String sql_str_upd = " UPDATE "+Sql_Mysql.Tb_Device_ConnectState+" SET connect_en = "+master.getConnectState()+",record_time='"+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)+"' WHERE dev_id = " + dev_id;
+ Sql_Mysql sql = new Sql_Mysql(pool.getConn());
+ ResultSet res = null;
+ try {
+ res = sql.sqlMysqlQuery(sql_str_sel);
+ if(res.next()) {
+ sql.sqlMysqlExecute(sql_str_upd);
+ }else {
+ sql.sqlMysqlExecute(sql_str_ins);
+ }
+ } catch (SQLException e) {
+ e.printStackTrace();
+ } finally {
+ if(res != null) {
+ try {
+ res.close();
+ } catch (SQLException e) {
+ e.printStackTrace();
+ }
+ sql.close_con();
+ }
+ }
+ }
}
--
Gitblit v1.9.1