From 422d605116ab7dad69a295e23cb132d5e3684b24 Mon Sep 17 00:00:00 2001
From: Administrator <1525436766@qq.com>
Date: 星期二, 14 十二月 2021 09:26:38 +0800
Subject: [PATCH] 升级log4j开源包
---
Central_Monitor/src/com/data/Comm/Central_Data_SocketClient_Thread.java | 76 ++++++++++++++++++++++++++++++++++++-
1 files changed, 73 insertions(+), 3 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..d2c8e10 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;
@@ -27,6 +28,7 @@
@Override
public void run() {
int run_count = 0;
+ Central_DataParsing_Thread_SQL.insertOrUpdateTb_Device_StateTable(pool, motor);
while(true) {
try {
if(run_count % 2 == 0) {
@@ -41,10 +43,17 @@
}
}
-
-
-
+ 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%5 == 0) {
+ Central_DataParsing_Thread_SQL.updateTb_Device_StateTable(pool, motor);
+ }
+
if(run_count > 999909) {
run_count = 0;
}
@@ -57,6 +66,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