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_DataParsing_Thread_SQL.java | 127 +++++++++++++++++++++++++++++++++++++++++-
1 files changed, 123 insertions(+), 4 deletions(-)
diff --git a/Central_Monitor/src/com/data/Comm/Central_DataParsing_Thread_SQL.java b/Central_Monitor/src/com/data/Comm/Central_DataParsing_Thread_SQL.java
index aec9fb2..0dc9d4b 100644
--- a/Central_Monitor/src/com/data/Comm/Central_DataParsing_Thread_SQL.java
+++ b/Central_Monitor/src/com/data/Comm/Central_DataParsing_Thread_SQL.java
@@ -5,6 +5,7 @@
import java.util.Date;
import java.util.List;
import com.base.Com;
+import com.data.Central_Control;
import com.data.Central_RT_Data;
import com.data.Central_ST_Data;
import com.data.Motor_inf;
@@ -12,6 +13,56 @@
import com.sql.Sql_Mysql;
public class Central_DataParsing_Thread_SQL {
+
+ /**
+ * 插入或更新设备通讯状态
+ * @param pool
+ * @param motor
+ */
+ public static void insertOrUpdateTb_Device_StateTable(MysqlConnPool pool,Motor_inf motor) {
+ String sql_str_sel = " Select dev_id from " + Sql_Mysql.Tb_Device_State + " Where dev_id = " + motor.getDev_id();
+ String sql_str_upd = " UPDATE " + Sql_Mysql.Tb_Device_State + " SET comm_status = " + motor.conn_state + " WHERE dev_id = " + motor.getDev_id();
+ String sql_str_ins = " INSERT INTO "+Sql_Mysql.Tb_Device_State+"(dev_id,comm_status) VALUES("+motor.getDev_id()+","+motor.conn_state+");";
+ ResultSet res = null;
+ Sql_Mysql sql = new Sql_Mysql(pool.getConn());
+ try {
+ res = sql.sqlMysqlQuery(sql_str_sel);
+ if(res.next()) {
+ sql.sqlMysqlExecute(sql_str_upd);
+ }else {
+ sql.sqlMysqlExecute(sql_str_ins);
+ }
+ } catch (SQLException e) {
+ e.printStackTrace();
+ } finally {
+ if(null != res) {
+ try {
+ res.close();
+ } catch (SQLException e) {
+ e.printStackTrace();
+ }
+ }
+ sql.close_con();
+ }
+ }
+
+ /**
+ * 更新设备的通讯状态
+ * @param pool
+ * @param motor
+ */
+ public static void updateTb_Device_StateTable(MysqlConnPool pool,Motor_inf motor) {
+ String sql_str = " UPDATE "+Sql_Mysql.Tb_Device_State+" SET comm_status = "+motor.conn_state+",record_time='"+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)+"' WHERE dev_id = "+motor.getDev_id();
+ Sql_Mysql sql = new Sql_Mysql(pool.getConn());
+ try {
+ sql.sqlMysqlExecute(sql_str);
+ } catch (SQLException e) {
+ e.printStackTrace();
+ } finally {
+ sql.close_con();
+ }
+ }
+
/**
* 加载集中监控平台设备设备信息
@@ -54,9 +105,9 @@
*/
public static void insertOrUpdateTb_Central_Monitor_Sys_St(MysqlConnPool pool,Central_ST_Data stdata) {
String sql_str_sel = " select dev_id from " + Sql_Mysql.Tb_Central_Monitor_Sys_St + " where dev_id = " + stdata.getDev_id();
- String sql_str_ins = " intsert into " + Sql_Mysql.Tb_Central_Monitor_Sys_St + "(dev_id) values("+stdata.getDev_id()+")";
+ String sql_str_ins = " insert into " + Sql_Mysql.Tb_Central_Monitor_Sys_St + "(dev_id) values("+stdata.getDev_id()+")";
String sql_str_upd = " update " + Sql_Mysql.Tb_Central_Monitor_Sys_St + ""
- + " SET record_time '" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)
+ + " SET record_time = '" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)
+ "',switch_close_1st_2500A = " + stdata.getSwitch_close_1st_2500A()
+ ",switch_open_1st_2500A = " + stdata.getSwitch_open_1st_2500A()
+ ",switch_fault_1st_2500A = " + stdata.getSwitch_fault_1st_2500A()
@@ -107,9 +158,9 @@
*/
public static void insertOrUpdateTb_Central_Monitor_Sys_Rt(MysqlConnPool pool,Central_RT_Data rtdata) {
String sql_str_sel = " select dev_id from " + Sql_Mysql.Tb_Central_Monitor_Sys_Rt + " where dev_id = " + rtdata.getDev_id();
- String sql_str_ins = " intsert into " + Sql_Mysql.Tb_Central_Monitor_Sys_Rt + "(dev_id) values("+rtdata.getDev_id()+")";
+ String sql_str_ins = " insert into " + Sql_Mysql.Tb_Central_Monitor_Sys_Rt + "(dev_id) values("+rtdata.getDev_id()+")";
String sql_str_upd = " update " + Sql_Mysql.Tb_Central_Monitor_Sys_Rt + ""
- + " SET record_time '" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)
+ + " SET record_time = '" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)
+ "',switch_close = " + rtdata.getSwitch_close()
+ ",switch_open = " + rtdata.getSwitch_open()
+ ",switch_fault = " + rtdata.getSwitch_fault()
@@ -139,4 +190,72 @@
}
}
+ /**
+ * 查询集中监控系统控制表
+ * @param pool
+ * @param control
+ */
+ public static void queryTb_Central_Monitor_Sys_Control(MysqlConnPool pool,Central_Control control) {
+ String sql_str = " SELECT * FROM "+Sql_Mysql.Tb_Central_Monitor_Sys_Control+" WHERE dev_id = " + control.getDev_id();
+ Sql_Mysql sql = new Sql_Mysql(pool.getConn());
+ ResultSet res = null;
+ try {
+ res = sql.sqlMysqlQuery(sql_str);
+ if(res.next()) {
+ control.setOp_cmd(res.getInt("op_cmd"));
+ control.setSwitch_close_1st_2500A(res.getInt("switch_close_1st_2500A"));
+ control.setSwitch_close_1st_2500A_load(res.getInt("switch_close_1st_2500A_load"));
+ control.setSwitch_close_2st_2500A(res.getInt("switch_close_2st_2500A"));
+ control.setSwitch_close_2st_2500A_load(res.getInt("switch_close_2st_2500A_load"));
+ control.setSwitch_close_bus_screen(res.getInt("switch_close_bus_screen"));
+ control.setSwitch_open_bus_screen(res.getInt("switch_open_bus_screen"));
+ control.setSwitch_open_1st_2500A(res.getInt("switch_open_1st_2500A"));
+ control.setSwitch_open_1st_2500A_load(res.getInt("switch_open_1st_2500A_load"));
+ control.setSwitch_open_2st_2500A(res.getInt("switch_open_2st_2500A"));
+ control.setSwitch_open_2st_2500A_load(res.getInt("switch_open_2st_2500A_load"));
+ }
+ } catch (Exception e) {
+ sql.logger.error(e.toString(),e);
+ } finally {
+ if(null != res) {
+ try {
+ res.close();
+ } catch (SQLException e) {
+ sql.logger.error(e.toString(),e);
+ }
+ }
+ sql.close_con();
+ }
+ }
+
+
+ /**
+ * 查询集中监控系统控制表
+ * @param pool
+ * @param control
+ */
+ public static void updateTb_Central_Monitor_Sys_Control(MysqlConnPool pool,Central_Control control) {
+ if(control.getOp_cmd() == Central_Data_ComBase.CMD_SwitchClose_1st_ACK ||
+ control.getOp_cmd() == Central_Data_ComBase.CMD_SwitchOpen_1st_ACK ||
+ control.getOp_cmd() == Central_Data_ComBase.CMD_SwitchClose_2st_ACK ||
+ control.getOp_cmd() == Central_Data_ComBase.CMD_SwitchOpen_2st_ACK ||
+ control.getOp_cmd() == Central_Data_ComBase.CMD_SwitchClose_3st_ACK ||
+ control.getOp_cmd() == Central_Data_ComBase.CMD_SwitchOpen_3st_ACK ||
+ control.getOp_cmd() == Central_Data_ComBase.CMD_SwitchClose_4st_ACK ||
+ control.getOp_cmd() == Central_Data_ComBase.CMD_SwitchOpen_4st_ACK ||
+ control.getOp_cmd() == Central_Data_ComBase.CMD_SwitchClose_5st_ACK ||
+ control.getOp_cmd() == Central_Data_ComBase.CMD_SwitchOpen_5st_ACK ) {
+ String sql_str = " UPDATE "+Sql_Mysql.Tb_Central_Monitor_Sys_Control+" SET op_cmd = "+control.getOp_cmd()+" WHERE dev_id = " + control.getDev_id();
+ Sql_Mysql sql = new Sql_Mysql(pool.getConn());
+ try {
+ sql.sqlMysqlExecute(sql_str);
+ } catch (Exception e) {
+ sql.logger.error(e.toString(),e);
+ } finally {
+ sql.close_con();
+ }
+ }else {
+ control.setOp_cmd(Central_Data_ComBase.CMD_Null);
+ }
+ }
}
--
Gitblit v1.9.1