From d8ebb73be7e75f4c995827e30edc76dcc823cc36 Mon Sep 17 00:00:00 2001
From: DELL <1525436766@qq.com>
Date: 星期五, 10 一月 2025 15:24:41 +0800
Subject: [PATCH] 3.新增控制时新增当前操作用户名,并且监控ID开锁状态

---
 ElectLock_Monitor/src/com/dev/lock/comm/Lock_Task_SQL.java |   50 +++++++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 47 insertions(+), 3 deletions(-)

diff --git a/ElectLock_Monitor/src/com/dev/lock/comm/Lock_Task_SQL.java b/ElectLock_Monitor/src/com/dev/lock/comm/Lock_Task_SQL.java
index 02ac300..5a70519 100644
--- a/ElectLock_Monitor/src/com/dev/lock/comm/Lock_Task_SQL.java
+++ b/ElectLock_Monitor/src/com/dev/lock/comm/Lock_Task_SQL.java
@@ -25,8 +25,12 @@
 		try {
 			res = sql.sqlMysqlQuery(sql_str_sel);
 			if(res.next()) {
+				
+				state.setLock_state(res.getInt("lock_state"));
+				
 				state.setComm_count(res.getInt("comm_count"));				//'閫氫俊璁℃暟',
 				state.setErr_tol_count(res.getInt("err_tol_count"));		//'鎬婚敊璇鏁�',
+				System.out.println("lock_state:" +state.getLock_state());
 			}else {
 				sql.sqlMysqlExecute(sql_str_ins);
 			}
@@ -101,7 +105,7 @@
 	 * @param param
 	 */
 	public static void queryElectLockControlCmd(MysqlConnPool pool,int lock_id,ElectLock_State param) {
-		String sql_str =  " SELECT op_cmd,id_card_set,lock_addr_set "
+		String sql_str =  " SELECT op_cmd,id_card_set,lock_addr_set,ctl_uname "
 						+ " FROM " + Sql_Mysql.Lock_Rt_Table + ""
 						+ " WHERE lock_id = " + lock_id;
 		Sql_Mysql sql = new Sql_Mysql(pool.getConn());
@@ -112,6 +116,7 @@
 				param.setOp_cmd(res.getInt("op_cmd"));
 				param.setId_card_set(res.getInt("id_card_set"));
 				param.setLock_addr_set(res.getInt("lock_addr_set"));
+				param.setCtl_uname(res.getString("ctl_uname"));
 				
 			}
 		} catch (SQLException e) {
@@ -158,12 +163,13 @@
 	 */
 	public static void insertLock_Ctl_Log_Table(MysqlConnPool pool,ElectLock_Ctl_Log log) {
 		String sql_str_ins = "INSERT INTO "  + Sql_Mysql.Lock_Ctl_Log_Table +  ""
-							+ "	(lock_id,ctl_type,ctl_result,ctl_time,ctl_id_card) VALUES("
+							+ "	(lock_id,ctl_type,ctl_result,ctl_time,ctl_id_card,ctl_uname) VALUES("
 							+ "" + log.lock_id
 							+ "," + log.ctl_type + ""
 							+ "," + log.ctl_result + ""
 							+ ",'" + Com.getDateTimeFormat(log.ctl_time, Com.DTF_YMDhms) + "'"
 							+ "," + log.ctl_id_card + ""
+							+ ",'" + log.ctl_uname + "'"
 							+ ");";
 		Sql_Mysql sql = new Sql_Mysql(pool.getConn());
 		try {
@@ -178,7 +184,7 @@
 
 	public static List<ElectLock_AuthIdcard> queryAuth_Idcard_Table(MysqlConnPool pool, int client_id) {
 		List<ElectLock_AuthIdcard> batch_auth = new ArrayList<>();
-		String sql_str = "SELECT DISTINCT(tb_key_inf.key_id),lock_id,state,tb_auth_idcard.create_time,key_number " + 
+		String sql_str = "SELECT DISTINCT(tb_key_inf.key_id),lock_id,state,tb_auth_idcard.create_time,key_number,ctl_uname " + 
 						" FROM " + Sql_Mysql.Key_Inf_Table + "," + Sql_Mysql.Auth_Idcard_Table +
 						" WHERE tb_key_inf.key_id = tb_auth_idcard.key_id AND lock_id = " + client_id + " AND key_type = 1 ";
 		Sql_Mysql sql = new Sql_Mysql(pool.getConn());
@@ -192,6 +198,8 @@
 				auth.state = res.getInt("state");					//'1:绉婚櫎id鍗�,2娣诲姞id鍗�,3宸插鐞�',
 				auth.create_time = res.getTimestamp("create_time");	//'鍒涘缓鏃堕棿'
 				auth.key_number = res.getString("key_number");		//ID鍗″彿
+
+				auth.ctl_uname = res.getString("ctl_uname");		//鎿嶄綔浜哄鍚�
 				
 				batch_auth.add(auth);
 			}
@@ -238,4 +246,40 @@
 			sql.close_con();
 		}
 	}
+
+
+	/**
+	 * 	鏌ヨID閽ュ寵鐨勫綊灞炰汉濮撳悕
+	 * @param pool
+	 * @param client_id
+	 * @param last_unlock_id
+	 * @return
+	 */
+	public static String queryKeyInfByKeyNumberTable(MysqlConnPool pool, int keyNumber) {
+		String uname = "";
+		String sql_str =  " SELECT * FROM " + Sql_Mysql.Key_Inf_Table
+						+ " WHERE key_number = " + keyNumber;
+		Sql_Mysql sql = new Sql_Mysql(pool.getConn());
+		ResultSet res = null;
+		try {
+			System.out.println("====="+sql_str);
+			res = sql.sqlMysqlQuery(sql_str);
+			if(res.next()) {
+				uname = res.getString("uname");
+				System.out.println("uname:" + uname);
+			}
+		} catch (SQLException e) {
+			sql.logger.error(e.toString(),e);
+		} finally {
+			if(null != res) {
+				try {
+					res.close();
+				} catch (SQLException e) {
+					sql.logger.error(e.toString(),e);
+				}
+			}
+			sql.close_con();
+		}
+		return uname;
+	}
 }

--
Gitblit v1.9.1