From b471d645e91846f3c54f4f1b3bcbf0a6729ed847 Mon Sep 17 00:00:00 2001
From: 军 <军@hp-pc>
Date: 星期六, 29 九月 2018 10:27:19 +0800
Subject: [PATCH] 在9100_state表中添加停电时长,续航时长,停电次数和流量等列
---
BattMonitor_DB_Builder/src/com/dev/fbs9100/FBS9100_Task_Thread_SQL.java | 399 ++++++++++++++++++++++++++++----------------------------
1 files changed, 202 insertions(+), 197 deletions(-)
diff --git a/BattMonitor_DB_Builder/src/com/dev/fbs9100/FBS9100_Task_Thread_SQL.java b/BattMonitor_DB_Builder/src/com/dev/fbs9100/FBS9100_Task_Thread_SQL.java
index 8b8b8fc..eb9adcc 100644
--- a/BattMonitor_DB_Builder/src/com/dev/fbs9100/FBS9100_Task_Thread_SQL.java
+++ b/BattMonitor_DB_Builder/src/com/dev/fbs9100/FBS9100_Task_Thread_SQL.java
@@ -1,197 +1,202 @@
-package com.dev.fbs9100;
-
-import java.sql.SQLException;
-
-import com.sql.MysqlConnPool;
-import com.sql.Sql_Mysql;
-
-public class FBS9100_Task_Thread_SQL {
-
- /**
- * 创建 tb_fbs9100_state 表并且将设备id和设备hip插入到表中
- * @param con_pool
- * @param al_param
- */
- public static void createFBS9100StateTableOnRam(MysqlConnPool con_pool)
- {
- String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.FBS9100State_Table;
- String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.FBS9100State_Table
- + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
- + "`dev_ip` varchar(20) NOT NULL DEFAULT '127.0.0.0', "
- + "`dev_version` varchar(20) NOT NULL DEFAULT '0', "
- + "`dev_id` BIGINT NOT NULL DEFAULT 0, "
- + "`op_cmd` INT NOT NULL DEFAULT 0, "
- + "`record_datetime` varchar(20) NOT NULL DEFAULT '2015-12-02 12:10:00', "
- + "`dev_datetime` varchar(20) NOT NULL DEFAULT '2015-12-02 12:10:00', "
- + "`dev_testtype` INT NOT NULL DEFAULT 0, "
- + "`dev_testgroupnum` INT NOT NULL DEFAULT 0, "
- + "`dev_workstate` INT NOT NULL DEFAULT 0, "
- + "`dev_alarmstate` INT NOT NULL DEFAULT 0, "
- + "`dev_temp` float NOT NULL DEFAULT 0, "
- + "`dev_res_test_state` INT NOT NULL DEFAULT 0, " //内阻测试状态
- + "`dev_onlinevollow` BOOLEAN NOT NULL DEFAULT false, "
- + "`dev_eachgroup_battsum` INT NOT NULL DEFAULT 0, "
- + "`dev_captest_onlinevol` float NOT NULL DEFAULT 0, "
- + "`dev_captest_groupvol` float NOT NULL DEFAULT 0, "
- + "`dev_captest_curr` float NOT NULL DEFAULT 0, "
- + "`dev_captest_cap` float NOT NULL DEFAULT 0, "
- + "`dev_captest_timelong` INT NOT NULL DEFAULT 0, "
- + "`dev_restest_count` INT NOT NULL DEFAULT 0, "
- + "`dev_restest_moncount` INT NOT NULL DEFAULT 0, "
- + "`dev_restest_monindex` INT NOT NULL DEFAULT 0, "
- + "`dev_commcount` INT NOT NULL DEFAULT 0, "
- + "`dev_errcommcount` INT NOT NULL DEFAULT 0, "
- + "`dev_rxnullerrcount` INT NOT NULL DEFAULT 0, "
-
- + "`dev_last_captest_stop_type` INT NOT NULL DEFAULT 0, "
- + "`dev_concurr` float NOT NULL DEFAULT 0, "
- + "`dev_condvoldp` float NOT NULL DEFAULT 0, "
- + "`dev_conresist` float NOT NULL DEFAULT 0, "
- + "`dev_condcurr` float NOT NULL DEFAULT 0, "
- + "`dev_61850alarms` varchar(64) NOT NULL DEFAULT '', "
-
- + " UNIQUE INDEX index_dev_id_uniq (`dev_id`), "
- + " PRIMARY KEY (`num`) ) "
- + " ENGINE=InnoDB DEFAULT CHARSET=utf8";
- /*
- String str3 = "INSERT INTO " + Sql_Mysql.FBS9100State_Table + " (dev_ip, dev_id) ";
- str3 += " SELECT dev_ip, dev_id FROM " + Sql_Mysql.BattInf_Table;
- */
- Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
- try {
- sql.sqlMysqlExecute(str1);
- sql.sqlMysqlExecute(str2);
- //sql.sqlMysqlExecute(str3);
- } catch (SQLException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- } finally {
- sql.close_con();
- }
- }
-
- /**
- * 创建 tb_fbs9100s_dcdc_data 表并且将设备id和设备ip插入到表中
- * @param con_pool
- * @param al_param
- */
- public static void createFBS9100S_DCDC_DataTableOnRam(MysqlConnPool con_pool)
- {
- String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.FBS9100S_DcDcState_Table;
- String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.FBS9100S_DcDcState_Table
- + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
- + "`dev_id` BIGINT NOT NULL DEFAULT 0, "
- + "`dcdc_num` BIGINT NOT NULL DEFAULT 0, "
- + "`dcdc_Vsys` float NOT NULL DEFAULT 0, "
- + "`dcdc_Vout` float NOT NULL DEFAULT 0, "
- + "`dcdc_Vbat` float NOT NULL DEFAULT 0, "
- + "`dcdc_Iout` float NOT NULL DEFAULT 0, "
- + "`dcdc_Ibuck` float NOT NULL DEFAULT 0, "
- + "`dcdc_Tmp_Dis` float NOT NULL DEFAULT 0, "
- + "`dcdc_Tmp_Chr` float NOT NULL DEFAULT 0, "
- + "`dcdc_SMR_Alarm1` INT NOT NULL DEFAULT 0, "
- + "`dcdc_SMR_Alarm2` INT NOT NULL DEFAULT 0, "
- + "`dcdc_version` INT NOT NULL DEFAULT 0, "
- + "`dcdc_ModeSetComm` INT NOT NULL DEFAULT 0, "
- + "`dcdc_RunSetComm` INT NOT NULL DEFAULT 0, "
- + "`dcdc_BuckISet` float NOT NULL DEFAULT 0, "
- + "`dcdc_DisVolSet` float NOT NULL DEFAULT 0, "
- + "`dcdc_DisCurrSet` float NOT NULL DEFAULT 0, "
- + "`dcdc_CommTxCnt` INT NOT NULL DEFAULT 0, "
- + "`dcdc_CommRxCnt` INT NOT NULL DEFAULT 0, "
- + " UNIQUE INDEX index_dcdc_num_uniq (`dcdc_num`), "
- + " PRIMARY KEY (`num`) ) "
- + " ENGINE=MEMORY DEFAULT CHARSET=utf8";
-
- Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
- try {
- sql.sqlMysqlExecute(str1);
- sql.sqlMysqlExecute(str2);
- } catch (SQLException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- } finally {
- sql.close_con();
- }
- }
-
- /**
- * 创建 tb_fbs9100_setparam 表，并且将设备id和设备ip插入到表中
- * @param con_pool
- * @param al_param
- */
- public static void createFBS9100SetTestParamTableOnRam(MysqlConnPool con_pool)
- {
- String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.FBS9100SetParam_Table;
- String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.FBS9100SetParam_Table
- + " ( `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, "
- + "`TestCmd` INT NOT NULL DEFAULT 0, "
- + "`HourRate` INT NOT NULL DEFAULT 0, "
- + "`DisCurr` FLOAT NOT NULL DEFAULT 0, "
- + "`DisCap` FLOAT NOT NULL DEFAULT 0, "
- + "`DisTime` INT NOT NULL DEFAULT 0, "
- + "`GroupVol_LOW` FLOAT NOT NULL DEFAULT 0, "
- + "`MonomerVol_LOW` FLOAT NOT NULL DEFAULT 0, "
- + "`MonomerLowCount` INT NOT NULL DEFAULT 0, "
- + "`BattGroupNum` INT NOT NULL DEFAULT 0, "
- + "`OnlineVolLowAction` INT NOT NULL DEFAULT 0, "
- + "`DCVolHighLimit` FLOAT NOT NULL DEFAULT 0, "
- + "`ChargeCurrSet` FLOAT NOT NULL DEFAULT 0, "
- + "`MonomerTmp_High` FLOAT NOT NULL DEFAULT 0, "
- + "`AutoTestStartVol` float NOT NULL DEFAULT 0, " //起始电压
- + " UNIQUE INDEX index_dev_id_uniq (`dev_id`), "
- + " PRIMARY KEY (`num`) ) "
- + " ENGINE=MEMORY DEFAULT CHARSET=utf8";
-
- Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
- try {
- sql.sqlMysqlExecute(str1);
- sql.sqlMysqlExecute(str2);
- } catch (SQLException e) {
- e.printStackTrace();
- } finally {
- sql.close_con();
- }
- }
-
- /**
- * 创建 Sql_Mysql.RamDB_CMCC_POWER_Data 表并且将设备id插入到表中
- * @param con_pool
- * @param al_param
- */
- public static void createFBS9100CmccPowerDataOnRam(MysqlConnPool con_pool)
- {
- String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.RamDB_CMCC_POWER_Data;
- String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.RamDB_CMCC_POWER_Data
- + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
- + "`dev_id` BIGINT NOT NULL DEFAULT 0, "
- + "`vol1` float NOT NULL DEFAULT 0, "
- + "`vol2` float NOT NULL DEFAULT 0, "
- + "`vol3` float NOT NULL DEFAULT 0, "
- + "`vol4` float NOT NULL DEFAULT 0, "
- + "`vol5` float NOT NULL DEFAULT 0, "
- + "`curr1` float NOT NULL DEFAULT 0, "
- + "`curr2` float NOT NULL DEFAULT 0, "
- + "`curr3` float NOT NULL DEFAULT 0, "
- + "`curr4` float NOT NULL DEFAULT 0, "
- + "`curr5` float NOT NULL DEFAULT 0, "
- + " UNIQUE INDEX index_dev_id_uniq (`dev_id`), "
- + " PRIMARY KEY (`num`) ) "
- + " ENGINE=InnoDB DEFAULT CHARSET=utf8";
-
- Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
- try {
- sql.sqlMysqlExecute(str1);
- sql.sqlMysqlExecute(str2);
- } catch (SQLException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- } finally {
- sql.close_con();
- }
- }
- /***********************************************************************************/
-}
+package com.dev.fbs9100;
+
+import java.sql.SQLException;
+
+import com.sql.MysqlConnPool;
+import com.sql.Sql_Mysql;
+
+public class FBS9100_Task_Thread_SQL {
+
+ /**
+ * 创建 tb_fbs9100_state 表并且将设备id和设备hip插入到表中
+ * @param con_pool
+ * @param al_param
+ */
+ public static void createFBS9100StateTableOnRam(MysqlConnPool con_pool)
+ {
+ String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.FBS9100State_Table;
+ String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.FBS9100State_Table
+ + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
+ + "`dev_ip` varchar(20) NOT NULL DEFAULT '127.0.0.0', "
+ + "`dev_version` varchar(20) NOT NULL DEFAULT '0', "
+ + "`dev_id` BIGINT NOT NULL DEFAULT 0, "
+ + "`op_cmd` INT NOT NULL DEFAULT 0, "
+ + "`record_datetime` varchar(20) NOT NULL DEFAULT '2015-12-02 12:10:00', "
+ + "`dev_datetime` varchar(20) NOT NULL DEFAULT '2015-12-02 12:10:00', "
+ + "`dev_testtype` INT NOT NULL DEFAULT 0, "
+ + "`dev_testgroupnum` INT NOT NULL DEFAULT 0, "
+ + "`dev_workstate` INT NOT NULL DEFAULT 0, "
+ + "`dev_alarmstate` INT NOT NULL DEFAULT 0, "
+ + "`dev_temp` float NOT NULL DEFAULT 0, "
+ + "`dev_res_test_state` INT NOT NULL DEFAULT 0, " //内阻测试状态
+ + "`dev_onlinevollow` BOOLEAN NOT NULL DEFAULT false, "
+ + "`dev_eachgroup_battsum` INT NOT NULL DEFAULT 0, "
+ + "`dev_captest_onlinevol` float NOT NULL DEFAULT 0, "
+ + "`dev_captest_groupvol` float NOT NULL DEFAULT 0, "
+ + "`dev_captest_curr` float NOT NULL DEFAULT 0, "
+ + "`dev_captest_cap` float NOT NULL DEFAULT 0, "
+ + "`dev_captest_timelong` INT NOT NULL DEFAULT 0, "
+ + "`dev_restest_count` INT NOT NULL DEFAULT 0, "
+ + "`dev_restest_moncount` INT NOT NULL DEFAULT 0, "
+ + "`dev_restest_monindex` INT NOT NULL DEFAULT 0, "
+ + "`dev_commcount` INT NOT NULL DEFAULT 0, "
+ + "`dev_errcommcount` INT NOT NULL DEFAULT 0, "
+ + "`dev_rxnullerrcount` INT NOT NULL DEFAULT 0, "
+
+ + "`dev_last_captest_stop_type` INT NOT NULL DEFAULT 0, "
+ + "`dev_concurr` float NOT NULL DEFAULT 0, "
+ + "`dev_condvoldp` float NOT NULL DEFAULT 0, "
+ + "`dev_conresist` float NOT NULL DEFAULT 0, "
+ + "`dev_condcurr` float NOT NULL DEFAULT 0, "
+ + "`dev_61850alarms` varchar(64) NOT NULL DEFAULT '', "
+
+ + "`dev_batt_xuhang_tlong` INT NOT NULL DEFAULT 0, " //续航时长
+ + "`dev_station_poff_tlong` INT NOT NULL DEFAULT 0, " //停电时长
+ + "`dev_station_poff_cnt` INT NOT NULL DEFAULT 0, " //停电次数
+ + "`dev_data_flowsum` BIGINT NOT NULL DEFAULT 0, " //机房流量
+
+ + " UNIQUE INDEX index_dev_id_uniq (`dev_id`), "
+ + " PRIMARY KEY (`num`) ) "
+ + " ENGINE=InnoDB DEFAULT CHARSET=utf8";
+ /*
+ String str3 = "INSERT INTO " + Sql_Mysql.FBS9100State_Table + " (dev_ip, dev_id) ";
+ str3 += " SELECT dev_ip, dev_id FROM " + Sql_Mysql.BattInf_Table;
+ */
+ Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
+ try {
+ sql.sqlMysqlExecute(str1);
+ sql.sqlMysqlExecute(str2);
+ //sql.sqlMysqlExecute(str3);
+ } catch (SQLException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ } finally {
+ sql.close_con();
+ }
+ }
+
+ /**
+ * 创建 tb_fbs9100s_dcdc_data 表并且将设备id和设备ip插入到表中
+ * @param con_pool
+ * @param al_param
+ */
+ public static void createFBS9100S_DCDC_DataTableOnRam(MysqlConnPool con_pool)
+ {
+ String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.FBS9100S_DcDcState_Table;
+ String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.FBS9100S_DcDcState_Table
+ + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
+ + "`dev_id` BIGINT NOT NULL DEFAULT 0, "
+ + "`dcdc_num` BIGINT NOT NULL DEFAULT 0, "
+ + "`dcdc_Vsys` float NOT NULL DEFAULT 0, "
+ + "`dcdc_Vout` float NOT NULL DEFAULT 0, "
+ + "`dcdc_Vbat` float NOT NULL DEFAULT 0, "
+ + "`dcdc_Iout` float NOT NULL DEFAULT 0, "
+ + "`dcdc_Ibuck` float NOT NULL DEFAULT 0, "
+ + "`dcdc_Tmp_Dis` float NOT NULL DEFAULT 0, "
+ + "`dcdc_Tmp_Chr` float NOT NULL DEFAULT 0, "
+ + "`dcdc_SMR_Alarm1` INT NOT NULL DEFAULT 0, "
+ + "`dcdc_SMR_Alarm2` INT NOT NULL DEFAULT 0, "
+ + "`dcdc_version` INT NOT NULL DEFAULT 0, "
+ + "`dcdc_ModeSetComm` INT NOT NULL DEFAULT 0, "
+ + "`dcdc_RunSetComm` INT NOT NULL DEFAULT 0, "
+ + "`dcdc_BuckISet` float NOT NULL DEFAULT 0, "
+ + "`dcdc_DisVolSet` float NOT NULL DEFAULT 0, "
+ + "`dcdc_DisCurrSet` float NOT NULL DEFAULT 0, "
+ + "`dcdc_CommTxCnt` INT NOT NULL DEFAULT 0, "
+ + "`dcdc_CommRxCnt` INT NOT NULL DEFAULT 0, "
+ + " UNIQUE INDEX index_dcdc_num_uniq (`dcdc_num`), "
+ + " PRIMARY KEY (`num`) ) "
+ + " ENGINE=MEMORY DEFAULT CHARSET=utf8";
+
+ Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
+ try {
+ sql.sqlMysqlExecute(str1);
+ sql.sqlMysqlExecute(str2);
+ } catch (SQLException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ } finally {
+ sql.close_con();
+ }
+ }
+
+ /**
+ * 创建 tb_fbs9100_setparam 表，并且将设备id和设备ip插入到表中
+ * @param con_pool
+ * @param al_param
+ */
+ public static void createFBS9100SetTestParamTableOnRam(MysqlConnPool con_pool)
+ {
+ String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.FBS9100SetParam_Table;
+ String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.FBS9100SetParam_Table
+ + " ( `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, "
+ + "`TestCmd` INT NOT NULL DEFAULT 0, "
+ + "`HourRate` INT NOT NULL DEFAULT 0, "
+ + "`DisCurr` FLOAT NOT NULL DEFAULT 0, "
+ + "`DisCap` FLOAT NOT NULL DEFAULT 0, "
+ + "`DisTime` INT NOT NULL DEFAULT 0, "
+ + "`GroupVol_LOW` FLOAT NOT NULL DEFAULT 0, "
+ + "`MonomerVol_LOW` FLOAT NOT NULL DEFAULT 0, "
+ + "`MonomerLowCount` INT NOT NULL DEFAULT 0, "
+ + "`BattGroupNum` INT NOT NULL DEFAULT 0, "
+ + "`OnlineVolLowAction` INT NOT NULL DEFAULT 0, "
+ + "`DCVolHighLimit` FLOAT NOT NULL DEFAULT 0, "
+ + "`ChargeCurrSet` FLOAT NOT NULL DEFAULT 0, "
+ + "`MonomerTmp_High` FLOAT NOT NULL DEFAULT 0, "
+ + "`AutoTestStartVol` float NOT NULL DEFAULT 0, " //起始电压
+ + " UNIQUE INDEX index_dev_id_uniq (`dev_id`), "
+ + " PRIMARY KEY (`num`) ) "
+ + " ENGINE=MEMORY DEFAULT CHARSET=utf8";
+
+ Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
+ try {
+ sql.sqlMysqlExecute(str1);
+ sql.sqlMysqlExecute(str2);
+ } catch (SQLException e) {
+ e.printStackTrace();
+ } finally {
+ sql.close_con();
+ }
+ }
+
+ /**
+ * 创建 Sql_Mysql.RamDB_CMCC_POWER_Data 表并且将设备id插入到表中
+ * @param con_pool
+ * @param al_param
+ */
+ public static void createFBS9100CmccPowerDataOnRam(MysqlConnPool con_pool)
+ {
+ String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.RamDB_CMCC_POWER_Data;
+ String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.RamDB_CMCC_POWER_Data
+ + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
+ + "`dev_id` BIGINT NOT NULL DEFAULT 0, "
+ + "`vol1` float NOT NULL DEFAULT 0, "
+ + "`vol2` float NOT NULL DEFAULT 0, "
+ + "`vol3` float NOT NULL DEFAULT 0, "
+ + "`vol4` float NOT NULL DEFAULT 0, "
+ + "`vol5` float NOT NULL DEFAULT 0, "
+ + "`curr1` float NOT NULL DEFAULT 0, "
+ + "`curr2` float NOT NULL DEFAULT 0, "
+ + "`curr3` float NOT NULL DEFAULT 0, "
+ + "`curr4` float NOT NULL DEFAULT 0, "
+ + "`curr5` float NOT NULL DEFAULT 0, "
+ + " UNIQUE INDEX index_dev_id_uniq (`dev_id`), "
+ + " PRIMARY KEY (`num`) ) "
+ + " ENGINE=InnoDB DEFAULT CHARSET=utf8";
+
+ Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
+ try {
+ sql.sqlMysqlExecute(str1);
+ sql.sqlMysqlExecute(str2);
+ } catch (SQLException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ } finally {
+ sql.close_con();
+ }
+ }
+ /***********************************************************************************/
+}
--
Gitblit v1.9.1