From 85ca7d73f45872d708c25b33eb44ded56f9922bd Mon Sep 17 00:00:00 2001
From: whyclj <1525436766@qq.com>
Date: 星期一, 07 十二月 2020 15:02:26 +0800
Subject: [PATCH] 增加控制以及实时记录
---
Central_Monitor/src/com/data/Comm/Central_Data_SocketClient_Thread.java | 70 ++++++++++++++++++++++++++++++++++-
1 files changed, 68 insertions(+), 2 deletions(-)
diff --git a/Central_Monitor/src/com/data/Comm/Central_Data_SocketClient_Thread.java b/Central_Monitor/src/com/data/Comm/Central_Data_SocketClient_Thread.java
index c78d234..6182490 100644
--- a/Central_Monitor/src/com/data/Comm/Central_Data_SocketClient_Thread.java
+++ b/Central_Monitor/src/com/data/Comm/Central_Data_SocketClient_Thread.java
@@ -1,5 +1,6 @@
package com.data.Comm;
+import com.data.Central_Control;
import com.data.Central_RT_Data;
import com.data.Central_ST_Data;
import com.data.Motor_inf;
@@ -41,8 +42,12 @@
}
}
-
-
+ Central_DataParsing_Thread_SQL.queryTb_Central_Monitor_Sys_Control(pool, motor.control);
+ if(motor.control.control_en) {
+ writeControlInf(motor.control);
+
+ Central_DataParsing_Thread_SQL.updateTb_Central_Monitor_Sys_Control(pool,motor.control);
+ }
motor.conn_state = master.getConnectState();
if(run_count > 999909) {
@@ -57,6 +62,67 @@
}
/**
+ * 控制指定的节点
+ * @param control
+ */
+ private void writeControlInf(Central_Control control) {
+
+ switch(control.getOp_cmd()) {
+ case Central_Data_ComBase.CMD_SwitchClose_1st:{
+ //
+ if(MyModbusUtils.writeCoil(1, true, master)) {
+ control.setOp_cmd(Central_Data_ComBase.CMD_SwitchClose_1st_ACK);
+ }
+ }break;
+ case Central_Data_ComBase.CMD_SwitchOpen_1st:{
+ if(MyModbusUtils.writeCoil(2, true, master)) {
+ control.setOp_cmd(Central_Data_ComBase.CMD_SwitchOpen_1st_ACK);
+ }
+ }break;
+ case Central_Data_ComBase.CMD_SwitchClose_2st:{
+ if(MyModbusUtils.writeCoil(3, true, master)) {
+ control.setOp_cmd(Central_Data_ComBase.CMD_SwitchClose_2st_ACK);
+ }
+ }break;
+ case Central_Data_ComBase.CMD_SwitchOpen_2st:{
+ if(MyModbusUtils.writeCoil(4, true, master)) {
+ control.setOp_cmd(Central_Data_ComBase.CMD_SwitchOpen_2st_ACK);
+ }
+ }break;
+ case Central_Data_ComBase.CMD_SwitchClose_3st:{
+ if(MyModbusUtils.writeCoil(5, true, master)) {
+ control.setOp_cmd(Central_Data_ComBase.CMD_SwitchClose_3st);
+ }
+ }break;
+ case Central_Data_ComBase.CMD_SwitchOpen_3st:{
+ if(MyModbusUtils.writeCoil(6, true, master)) {
+ control.setOp_cmd(Central_Data_ComBase.CMD_SwitchOpen_3st_ACK);
+ }
+ }break;
+ case Central_Data_ComBase.CMD_SwitchClose_4st:{
+ if(MyModbusUtils.writeCoil(7, true, master)) {
+ control.setOp_cmd(Central_Data_ComBase.CMD_SwitchClose_4st_ACK);
+ }
+ }break;
+ case Central_Data_ComBase.CMD_SwitchOpen_4st:{
+ if(MyModbusUtils.writeCoil(8, true, master)) {
+ control.setOp_cmd(Central_Data_ComBase.CMD_SwitchOpen_4st_ACK);
+ }
+ }break;
+ case Central_Data_ComBase.CMD_SwitchClose_5st:{
+ if(MyModbusUtils.writeCoil(9, true, master)) {
+ control.setOp_cmd(Central_Data_ComBase.CMD_SwitchClose_5st_ACK);
+ }
+ }break;
+ case Central_Data_ComBase.CMD_SwitchOpen_5st:{
+ if(MyModbusUtils.writeCoil(10, true, master)) {
+ control.setOp_cmd(Central_Data_ComBase.CMD_SwitchOpen_5st_ACK);
+ }
+ }break;
+ }
+ }
+
+ /**
* 读取直流主配信息
* @param stdata
*/
--
Gitblit v1.9.1