From 2b64a566f77f90fe47f62863b7a185b6e1c514b7 Mon Sep 17 00:00:00 2001
From: whyclj <1525436766@qq.com>
Date: 星期四, 24 九月 2020 09:49:22 +0800
Subject: [PATCH] 屏蔽打印错误日志
---
WaterSystem_MonitorServer/src/com/watersystem/monitor/Water_Task_SQL.java | 109 ++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 109 insertions(+), 0 deletions(-)
diff --git a/WaterSystem_MonitorServer/src/com/watersystem/monitor/Water_Task_SQL.java b/WaterSystem_MonitorServer/src/com/watersystem/monitor/Water_Task_SQL.java
index fc15b07..3bd1f65 100644
--- a/WaterSystem_MonitorServer/src/com/watersystem/monitor/Water_Task_SQL.java
+++ b/WaterSystem_MonitorServer/src/com/watersystem/monitor/Water_Task_SQL.java
@@ -3,8 +3,11 @@
import java.security.interfaces.RSAKey;
import java.sql.ResultSet;
import java.sql.SQLException;
+import java.util.Date;
import java.util.List;
+import com.base.Com;
+import com.modbus.data.MyModbusMaster;
import com.sql.MysqlConnPool;
import com.sql.Sql_Mysql;
@@ -204,6 +207,30 @@
sql.close_con();
}
}
+ //创建水冷故障表
+ public static void createTb_water_alarm(MysqlConnPool pool) {
+ String sql_str = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Tb_water_alarm + " (" +
+ " num bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键'," +
+ " water_id int(11) NOT NULL DEFAULT '5001' COMMENT '设备id'," +
+ " alarm_id int(11) NOT NULL DEFAULT '12930' COMMENT '告警id'," +
+ " alarm_starttime datetime NOT NULL DEFAULT '2000-01-01 00:00:00' COMMENT '告警开始时间'," +
+ " alarm_endtime datetime NOT NULL DEFAULT '2000-01-01 00:00:00' COMMENT '告警结束时间'," +
+ " alarm_confirm int(11) NOT NULL DEFAULT '0' COMMENT '告警确认'," +
+ " alarm_confirmtime datetime NOT NULL DEFAULT '2000-01-01 00:00:00' COMMENT '告警确认时间'," +
+ " note varchar(255) NOT NULL DEFAULT ''," +
+ " PRIMARY KEY (num),"+
+ " index water_id_key(water_id) " +
+ ") ENGINE=InnoDB DEFAULT CHARSET=utf8;";
+ Sql_Mysql sql = new Sql_Mysql(pool.getConn());
+ try {
+ sql.sqlMysqlExecute(sql_str);
+ } catch (SQLException e) {
+ e.printStackTrace();
+ } finally {
+ sql.close_con();
+ }
+ }
+
/**
* 初始化数据库表
* @param pool
@@ -218,6 +245,8 @@
createTb_water_brach(pool);
createTb_water_state(pool);
+
+ createTb_water_alarm(pool);
}
//插入或更新水冷系统实时信息表
@@ -262,4 +291,84 @@
sql.close_con();
}
}
+
+ /**
+ * 插入或更新电源故障
+ * @param conn_pool
+ * @param control
+ */
+ public static void insertOrUpdateWater_alarmTable(MysqlConnPool conn_pool,List<Water_alarm> list) {
+ if(list!=null&&list.size()>0) {
+ for (Water_alarm walarm : list) {
+ String sql_str_sel = " select * from " + Sql_Mysql.Tb_water_alarm + " where water_id = " + walarm.getWater_id()+" and alarm_id="+walarm.getAlarm_id();
+ String sql_str_ins = " INSERT INTO " + Sql_Mysql.Tb_water_alarm + "(water_id,alarm_id,alarm_starttime,alarm_endtime,alarm_confirm,alarm_confirmtime) "
+ +" VALUES("+walarm.water_id+","+walarm.alarm_id+",'"+Com.getDateTimeFormat(walarm.alarm_starttime, Com.DTF_YMDhms)+"','"+Com.getDateTimeFormat(walarm.alarm_endtime, Com.DTF_YMDhms)+"',"+walarm.alarm_confirm+",'"+Com.getDateTimeFormat(walarm.alarm_confirmtime, Com.DTF_YMDhms)+"');";
+ String sql_str_update= " update " + Sql_Mysql.Tb_water_alarm +
+ " set alarm_starttime='"+Com.getDateTimeFormat(walarm.alarm_starttime, Com.DTF_YMDhms)+
+ "',alarm_endtime='"+Com.getDateTimeFormat(walarm.alarm_endtime, Com.DTF_YMDhms)+
+ "',alarm_confirm="+walarm.alarm_confirm+
+ ",alarm_confirmtime='"+Com.getDateTimeFormat(walarm.alarm_confirmtime, Com.DTF_YMDhms)+
+ "' where water_id="+walarm.water_id+
+ " and alarm_id="+walarm.alarm_id;
+ ResultSet res = null;
+ Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
+ try {
+ res = sql.sqlMysqlQuery(sql_str_sel);
+ if(res.next()) {
+ //更新当前控制状态
+ sql.sqlMysqlExecute(sql_str_update);
+ }else {
+ sql.sqlMysqlExecute(sql_str_ins);
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ } finally {
+ if(res != null) {
+ try {
+ res.close();
+ } catch (SQLException e) {
+ e.printStackTrace();
+ }
+ }
+ sql.close_con();
+ }
+ }
+
+ }
+
+ }
+
+
+ /**
+ * 插入或更新当前设备的连接状态
+ * @param pool
+ * @param dev_id
+ * @param master
+ */
+ public static void insertOrUpdateDeviceConnectState(MysqlConnPool pool,int dev_id,MyModbusMaster master) {
+ String sql_str_sel = " SELECT * FROM "+Sql_Mysql.Tb_Device_ConnectState+" WHERE dev_id = " + dev_id;
+ String sql_str_ins = " INSERT INTO "+Sql_Mysql.Tb_Device_ConnectState+"(dev_id,connect_en,record_time) values("+dev_id+","+master.getConnectState()+",'"+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)+"');";
+ String sql_str_upd = " UPDATE "+Sql_Mysql.Tb_Device_ConnectState+" SET connect_en = "+master.getConnectState()+",record_time='"+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)+"' WHERE dev_id = " + dev_id;
+ Sql_Mysql sql = new Sql_Mysql(pool.getConn());
+ ResultSet res = null;
+ 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(res != null) {
+ try {
+ res.close();
+ } catch (SQLException e) {
+ e.printStackTrace();
+ }
+ sql.close_con();
+ }
+ }
+ }
}
--
Gitblit v1.9.1