From 351bbd8738c89c0302465360c1ca0c92abd18eba Mon Sep 17 00:00:00 2001
From: DELL <1525436766@qq.com>
Date: 星期五, 07 二月 2025 13:34:35 +0800
Subject: [PATCH] 新增统计月份,季度,年度统计开锁次数

---
 ElectLock_Monitor/src/main/main_ElectLock_Monitor.java |   26 ++++++++++++++++----------
 1 files changed, 16 insertions(+), 10 deletions(-)

diff --git a/ElectLock_Monitor/src/main/main_ElectLock_Monitor.java b/ElectLock_Monitor/src/main/main_ElectLock_Monitor.java
index febf676..47163a2 100644
--- a/ElectLock_Monitor/src/main/main_ElectLock_Monitor.java
+++ b/ElectLock_Monitor/src/main/main_ElectLock_Monitor.java
@@ -4,7 +4,9 @@
 import com.config.AppConfig;
 import com.del.TmpFileUtil;
 import com.dev.lock.comm.Lock_ServerSocket_Thread;
+import com.dev.lock.comm.Lock_Task_SQL;
 import com.dev.lock.data.ElectLock_Array;
+import com.dev.lock.history.ElectLock_HistoryData_Record_Thread;
 import com.sql.MysqlConnPool;
 import java.sql.Connection;
 import java.sql.SQLException;
@@ -24,14 +26,13 @@
 	private static Logger logger;
 	private static ElectLock_Array GB_ElLock_Array;
 	
-
-	
-	
 	static {
 		System.setProperty("log4j.configurationFile", "log4j2_electlock_dev_x64.xml");
 	}
+	
 	public static void main(String[] args) {
 		TimeZone.setDefault(TimeZone.getTimeZone("GMT+8"));
+		
 		GB_ElLock_Array = new ElectLock_Array();
 		
 		logger = LogManager.getLogger(main_ElectLock_Monitor.class);
@@ -64,11 +65,17 @@
 		server_thread.start();
 
 		
+		{
+			ElectLock_HistoryData_Record_Thread record_thread = new ElectLock_HistoryData_Record_Thread(GB_ElLock_Array, GB_MysqlConnPool);
+			record_thread.start();
+		}
 		
-		//FBS9600_State_SQL.updateProcess_StartTime(GB_MysqlConnPool, m_VersionNum);
+		
+		Lock_Task_SQL.updateProcess_StartTime(GB_MysqlConnPool, m_VersionNum);
 		Date last_time = new Date(0);
 		while (true) {
 			try {
+				Thread.sleep(3000L);
 				
 				Date now = new Date();
 				long timelong = (now.getTime()-last_time.getTime())/1000;
@@ -77,9 +84,8 @@
 					TmpFileUtil.delTmpFile();
 					last_time = now;
 				}
-				Thread.sleep(3000L);
-				//FBS9600_State_SQL.updateProcess_ProcessTime(GB_MysqlConnPool);			
-			} catch (InterruptedException e) {
+				Lock_Task_SQL.updateProcess_ProcessTime(GB_MysqlConnPool);			
+			} catch (Exception e) {
 				e.printStackTrace();
 			}
 		}
@@ -104,15 +110,15 @@
 				try {
 					Thread.sleep(1000);
 				} catch (InterruptedException e1) {
-					e1.printStackTrace();
+					logger.error(e.toString(),e);
 				}
-				System.out.println(" MySQL not Start ... ");
+				System.out.println(" SQLDataBase Server not Start ... ");
 			} finally {
 				if(conn != null) {
 					try {
 						conn.close();
 					} catch (SQLException e) {
-						e.printStackTrace();
+						logger.error(e.toString(),e);
 					}
 				}
 			}

--
Gitblit v1.9.1