From fb323fb880c57f6572c6290a59d90feb213b93a1 Mon Sep 17 00:00:00 2001
From: Administrator <1525436766@qq.com>
Date: 星期四, 29 四月 2021 14:39:46 +0800
Subject: [PATCH] 修改
---
BattFBS9600XSP2/src/com/dev/fbs9600/FBS9600_State_SQL.java | 160 +++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 160 insertions(+), 0 deletions(-)
diff --git a/BattFBS9600XSP2/src/com/dev/fbs9600/FBS9600_State_SQL.java b/BattFBS9600XSP2/src/com/dev/fbs9600/FBS9600_State_SQL.java
index 7a00186..6b77118 100644
--- a/BattFBS9600XSP2/src/com/dev/fbs9600/FBS9600_State_SQL.java
+++ b/BattFBS9600XSP2/src/com/dev/fbs9600/FBS9600_State_SQL.java
@@ -9,6 +9,105 @@
import java.util.Date;
public class FBS9600_State_SQL {
+
+
+ /**
+ * 鏌ヨ褰撳墠鏄惁鏈夋帶鍒舵搷浣�
+ * @param pool
+ * @param state
+ */
+ public static void queryFBS9100SetParamTable(MysqlConnPool pool,FBS9600_State state) {
+ String sql_str = " SELECT op_cmd,BattGroupNum FROM db_ram_db.tb_fbs9100_setparam WHERE dev_id = " + state.dev_id;
+ Sql_Mysql sql = new Sql_Mysql(pool.getConn());
+ ResultSet res = null;
+ try {
+ res = sql.sqlMysqlQuery(sql_str);
+ if(res.next()) {
+ state.setFBS9600Cmd(res.getInt("op_cmd"));
+ state.BattGroupNum = res.getInt("BattGroupNum");
+ }
+ } catch (SQLException e) {
+ e.printStackTrace();
+ } finally {
+ if(null != res) {
+ try {
+ res.close();
+ } catch (SQLException e) {
+ e.printStackTrace();
+ }
+ }
+ sql.close_con();
+ }
+ }
+
+ /**
+ * 鏇存柊褰撳墠鎿嶄綔杩斿洖鐘舵��
+ * @param pool
+ * @param state
+ */
+ public static void updateFBS9100SetParamTable(MysqlConnPool pool,FBS9600_State state) {
+ String sql_str = " UPDATE db_ram_db.tb_fbs9100_setparam SET op_cmd = "+state.getFBS9600Cmd()+" WHERE dev_id = " + state.dev_id;
+ Sql_Mysql sql = new Sql_Mysql(pool.getConn());
+ try {
+ sql.sqlMysqlExecute(sql_str);
+ } catch (SQLException e) {
+ e.printStackTrace();
+ } finally {
+ sql.close_con();
+ }
+ }
+
+ /**
+ *
+ * @param pool
+ * @param state
+ */
+ public static void insertFBS9100SetParam_Table(MysqlConnPool pool,FBS9600_State state) {
+ String sql_str_sel = " SELECT op_cmd FROM db_ram_db.tb_fbs9100_setparam WHERE dev_id = " + state.dev_id;
+ String sql_str_ins = " INSERT INTO db_ram_db.tb_fbs9100_setparam(dev_id,op_cmd) VALUES("+state.dev_id+",0);";
+ 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_ins);
+ }
+ } catch (SQLException e) {
+ e.printStackTrace();
+ } finally {
+ sql.close_con();
+ }
+ }
+
+ /**
+ * 鎻掑叆璁惧鐘舵�佽〃
+ * @param pool
+ * @param state
+ */
+ public static void insertFBS9100State_Table(MysqlConnPool pool,FBS9600_State state) {
+ String sql_str_sel = " SELECT op_cmd FROM db_ram_db.tb_fbs9100_setparam WHERE dev_id = " + state.dev_id;
+ String sql_str_ins = " INSERT INTO db_ram_db.tb_fbs9100_setparam(dev_id,dev_ip) VALUES("+state.dev_id+",0);";
+ 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_ins);
+ }
+ } catch (SQLException e) {
+ e.printStackTrace();
+ } finally {
+ if(null != res) {
+ try {
+ res.close();
+ } catch (SQLException e) {
+ e.printStackTrace();
+ }
+ }
+ sql.close_con();
+ }
+ }
+
public static void createFBS9600StateTableOnRam(MysqlConnPool con_pool, ArrayList<FBS9600_State> al_stat) {
String str1 = "DROP TABLE IF EXISTS `db_ram_db`.`tb_fbs9600_state`";
String str2 = "CREATE TABLE IF NOT EXISTS `db_ram_db`.`tb_fbs9600_state` ( `num` BIGINT NOT NULL AUTO_INCREMENT, `dev_ip` varchar(20) NOT NULL DEFAULT '127.0.0.0', `dev_id` BIGINT NOT NULL DEFAULT 0, `op_cmd` INT NOT NULL DEFAULT 0, `dev_workstate` INT NOT NULL DEFAULT 0, `dev_alarmstate` INT NOT NULL DEFAULT 0, `dev_commcount` INT NOT NULL DEFAULT 0, `dev_errcommcount` INT NOT NULL DEFAULT 0, PRIMARY KEY (`num`) ) ENGINE=MEMORY DEFAULT CHARSET=utf8";
@@ -217,4 +316,65 @@
sql.close_con();
}
}
+
+ public static void updateFBS9100State_Table(MysqlConnPool pool, FBS9600_State state) {
+ String sql_str = "UPDATE db_ram_db.tb_fbs9100_state "
+ + " SET record_datetime = '"+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)+"',"
+ + " dev_workstate = "+state.getWorkState()+","
+ + " dev_captest_groupvol="+state.dev_groupvols[0]+","
+ + " dev_captest_curr = "+state.dev_currs[0]+","
+ + " dev_commcount = "+state.com_count+","
+ + " dev_errcommcount= "+state.com_err_count
+ + " WHERE dev_id= " + state.dev_id;
+ Sql_Mysql sql = new Sql_Mysql(pool.getConn());
+ try {
+ sql.sqlMysqlExecute(sql_str);
+ } catch (SQLException e) {
+ e.printStackTrace();
+ } finally {
+ sql.close_con();
+ }
+ }
+
+ /**
+ * 鏇存柊绋嬪簭鍚姩鏃堕棿浠ュ強瀵瑰簲绋嬪簭鐨勭増鏈彿
+ * @param pool
+ * @param version
+ */
+ public static void updateProcess_StartTime(MysqlConnPool pool,double version) {
+ String sql_str = " UPDATE " + Sql_Mysql.Tb_Process_SurveyTable
+ + " SET Process_starttime='"+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)+"'"
+ + " ,ProcessTime='"+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)+"'"
+ + " ,ProcessVersion='V"+version+"' "
+ + " WHERE ProcessId = 11010";
+
+ Sql_Mysql sql = new Sql_Mysql(pool.getConn());
+ try {
+ sql.sqlMysqlExecute(sql_str);
+ } catch (SQLException e) {
+ e.printStackTrace();
+ } finally {
+ sql.close_con();
+ }
+ }
+
+ /**
+ * 鏇存柊绋嬪簭鍚姩鏃堕棿浠ュ強瀵瑰簲绋嬪簭鐨勭増鏈彿
+ * @param pool
+ * @param version
+ */
+ public static void updateProcess_ProcessTime(MysqlConnPool pool) {
+ String sql_str = " UPDATE " + Sql_Mysql.Tb_Process_SurveyTable
+ + " SET ProcessTime='"+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)+"'"
+ + " WHERE ProcessId = 11010 ";
+ Sql_Mysql sql = new Sql_Mysql(pool.getConn());
+ try {
+ sql.sqlMysqlExecute(sql_str);
+ } catch (SQLException e) {
+ e.printStackTrace();
+ } finally {
+ sql.close_con();
+ }
+ }
+
}
--
Gitblit v1.9.1