| | |
|---|
| | | 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;
|
|---|
| | |
|---|
| | | @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) {
|
|---|
| | |
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | 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;
|
|---|
| | | }
|
|---|
| | |
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 控制指定的节点
|
|---|
| | | * @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
|
|---|
| | | */
|
|---|
