From 95c0c2e94d390650d3954c30c6a7c805fe9c714c Mon Sep 17 00:00:00 2001
From: whyclj <1525436766@qq.com>
Date: 星期四, 15 十月 2020 18:23:18 +0800
Subject: [PATCH] 负载添加历史实时数据记录功能

---
 src/com/dev/base/data/Dynamicload_SocketClient_Thread.java |   29 ++++++++++++++++++++++++-----
 1 files changed, 24 insertions(+), 5 deletions(-)

diff --git a/src/com/dev/base/data/Dynamicload_SocketClient_Thread.java b/src/com/dev/base/data/Dynamicload_SocketClient_Thread.java
index 485cd41..24cbe4e 100644
--- a/src/com/dev/base/data/Dynamicload_SocketClient_Thread.java
+++ b/src/com/dev/base/data/Dynamicload_SocketClient_Thread.java
@@ -26,9 +26,13 @@
 		this.conn_pool = conn_pool;
 		this.dinf = dinf;
 
-		dbutton = new Dynamicload_button(dinf.getDev_id());
-		dcontrol = new Dynamicload_control(dinf.getDev_id(),dinf.getFZ_button_num());
-		dstate = new Dynamicload_state(dinf.getDev_id(),dinf.getFZ_button_num());
+		dbutton = dinf.button;
+		dcontrol = dinf.control;
+		dstate = dinf.state;
+		
+		//dbutton = new Dynamicload_button(dinf.getDev_id());
+		//dcontrol = new Dynamicload_control(dinf.getDev_id(),dinf.getFZ_button_num());
+		//dstate = new Dynamicload_state(dinf.getDev_id(),dinf.getFZ_button_num());
 		master = new MyModbusMaster(dinf.getDev_ip(), MyModbusMaster.SLAVEID_DEFAULT);
 		//System.out.println("master: "+master);
 	}
@@ -46,6 +50,19 @@
 					writeDynamicload_Control(master,dcontrol);
 					PowerArk_Task_SQL.update_Dynamicload_Control(conn_pool, dcontrol);
 				}*/
+				//控制页面
+				/*PowerArk_Task_SQL.queryDynamicload_Control(conn_pool, dcontrol);
+				{
+//					if(dcontrol.dev_id == 1001) {
+//						System.out.println(dcontrol.dev_id+"=="+dcontrol.control_en);
+//					}
+					if(dcontrol.control_en) {
+					
+						writeDynamicload_Control(master, dcontrol);
+						PowerArk_Task_SQL.update_Dynamicload_Control(conn_pool, dcontrol);
+					}
+				}*/
+				
 				if (runCount % 2 == 0) {
 					// *************************** 更新负载按钮信息******************************//*
 
@@ -66,6 +83,7 @@
 				//System.err.println(dinf.dev_id + "=====" + ((new Date()).getTime() - last.getTime()));
 				last = new Date();
 				PowerArk_Task_SQL.insertOrUpdateDeviceConnectState(conn_pool, dinf.dev_id, master);
+				dinf.conn_state = master.getConnectState();
 				if (runCount % 10 == 0) {
 					// 更新当前设备ip
 					master.setTarget_ip(dinf.dev_ip);
@@ -167,6 +185,7 @@
 			}
 		}
 		if(dcontrol.start_auto>0) {
+			//System.out.println("启动自动加减载");
 			MyModbusUtils.writeCoil(8, true, master);		
 		}
 		if(dcontrol.stop_auto>0) {
@@ -288,9 +307,9 @@
 	 */
 	public void readMutilElectrical_state(MyModbusMaster master, Dynamicload_state dstate) {
 		BatchRead<Integer> batch = dstate.createBatchRead(master,dstate.fz_button_num);	
-		//System.out.println("ip"+dinf.getDev_ip()+"  dstate: "+batch.toString());
+		//System.out.println("id"+dinf.getDev_id()+"  button_num"+dstate.fz_button_num);
 		BatchResults<Integer> res = MyModbusUtils.readMutilRegisters(batch, master);
-		dstate.putBatchResult(res);
+		dstate.putBatchResult(res,dstate.fz_button_num);
 	}
 	
 	/**

--
Gitblit v1.9.1