From 993f8a639ce8eb9124da3a901065a87eea9f3994 Mon Sep 17 00:00:00 2001
From: Administrator <1525436766@qq.com>
Date: 星期二, 26 四月 2022 16:26:46 +0800
Subject: [PATCH] 二期修改提交数据
---
BattMonitor_FGCD-A059NT/src/com/dev/fgcd/comm/FGCD_Task_Thread_SQL.java | 75 +++++++++++++++++++++++++++++++++++++
1 files changed, 75 insertions(+), 0 deletions(-)
diff --git a/BattMonitor_FGCD-A059NT/src/com/dev/fgcd/comm/FGCD_Task_Thread_SQL.java b/BattMonitor_FGCD-A059NT/src/com/dev/fgcd/comm/FGCD_Task_Thread_SQL.java
index a951395..23c6871 100644
--- a/BattMonitor_FGCD-A059NT/src/com/dev/fgcd/comm/FGCD_Task_Thread_SQL.java
+++ b/BattMonitor_FGCD-A059NT/src/com/dev/fgcd/comm/FGCD_Task_Thread_SQL.java
@@ -10,6 +10,7 @@
import com.battmonitor.sql.MysqlConnPool;
import com.battmonitor.sql.Sql_Mysql;
import com.dev.fgcd.data.FGCD_ComBase;
+import com.dev.fgcd.data.FGCD_Station_inf;
import com.dev.fgcd.data.FGCD_TestFBOFile;
import com.dev.fgcd.data.FGCD_TestFBOFile.FBOFile;
import com.dev.fgcd.fbo.FboData;
@@ -425,4 +426,78 @@
sql.close_con();
}
}
+
+ /**
+ * 插入或更新当前设备的配置信息
+ * @param pool
+ */
+ public static void insertOrUpdateA059_Station_Inf_Table(MysqlConnPool pool,FGCD_Station_inf station) {
+ String sql_str_sel = " SELECT * FROM " + Sql_Mysql.A059_Station_Inf_Table +
+ "WHERE dev_num = '"+station.dev_num+"' ";
+ ResultSet res = null;
+ String sql_str_upd = "UPDATE " + Sql_Mysql.A059_Station_Inf_Table
+ + " SET station_province = '" + station.station_province +"'"
+ + ",station_city = '" + station.station_city +"'"
+ + ",station_county = '" + station.station_county +"'"
+ + ",station_name = '" + station.station_name + "'"
+ + ",station_name_ex = '" + station.station_name_ex + "'"
+ + ",dev_name = '" + station.dev_name + "'"
+ + ",batt_name = '" + station.batt_name + "'"
+ + ",mon_count = " + station.mon_count
+ + ",monStdCap = " + station.monStdCap
+ + ",monStdVol = " + station.monStdVol
+ + ",load_curr = " + station.load_curr
+ + ",video_url = '" + station.video_url + "'"
+ + ",dev_num = '" + station.dev_num + "'"
+ + ",last_update_time = '" + Com.getDateTimeFormat(station.getLast_update_time(), Com.DTF_YMDhms)+"'"
+ + " WHERE dev_num = '" + station.dev_num +"';";
+ String sql_str_ins = "INSERT INTO " + Sql_Mysql.A059_Station_Inf_Table + "(station_province,station_city,station_county,station_name,station_name_ex,dev_name,batt_name,mon_count,monStdCap,monStdVol,load_curr,video_url,dev_num,last_update_time) " +
+ "VALUES('"+station.station_province+"'"
+ + ",'" + station.station_city + "'"
+ + ",'" + station.station_county + "'"
+ + ",'" + station.station_name + "'"
+ + ",'" + station.station_name_ex + "'"
+ + ",'" + station.dev_name + "'"
+ + ",'" + station.batt_name + "'"
+ + "," + station.mon_count + ""
+ + "," + station.monStdCap + ""
+ + "," + station.monStdVol + ""
+ + "," + station.load_curr + ""
+ + ",'" + station.video_url + "'"
+ + ",'" + station.dev_num + "'"
+ + ",'" + Com.getDateTimeFormat(station.last_update_time, Com.DTF_YMDhms) + "'"
+ + ");";
+ Sql_Mysql sql = new Sql_Mysql(pool.getConn());
+ try {
+ res = sql.sqlMysqlQuery(sql_str_sel);
+ if(res.next()) {
+ //更新设备机房配置信息
+ System.out.println(sql_str_upd);
+ 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();
+ }
+ }
+
+
+// public static void main(String[] args) {
+// FGCD_Station_inf inf = new FGCD_Station_inf();
+// inf.dev_num = "9921";
+// inf.last_update_time = new Date();
+// MysqlConnPool pool = new MysqlConnPool("127.0.0.1", 3360, 5);
+// insertOrUpdateA059_Station_Inf_Table(pool, inf);
+// }
}
--
Gitblit v1.9.1