package com.battdata_rt;
|
|
import com.base.Com;
|
import com.sql.MysqlConnPool;
|
import com.sql.Sql_Mysql;
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.ArrayList;
|
import java.util.Date;
|
|
public class PowerData_RT_SQL {
|
public static void createBattData_RT_RamDB_Table(MysqlConnPool conn_pool, int bg_id, int batt_cnt) {
|
String tb_name = "`db_ram_batt_rt`.`tb_batt_rtdata_" + bg_id + "`";
|
String sql_str0 = "DELETE FROM " + tb_name + " WHERE " + tb_name + ".num>0";
|
String sql_str1 = "CREATE TABLE IF NOT EXISTS " + tb_name + " " + "( `num` BIGINT NOT NULL AUTO_INCREMENT, "
|
+ "`BattGroupId` INT NOT NULL DEFAULT 0, "
|
+ "`rec_datetime` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
|
+ "`mon_num` INT NOT NULL DEFAULT 0, " + "`mon_vol` FLOAT NOT NULL DEFAULT 0, "
|
+ "`mon_tmp` FLOAT NOT NULL DEFAULT 0, " + "`mon_res` FLOAT NOT NULL DEFAULT 0, "
|
+ "`mon_ser` FLOAT NOT NULL DEFAULT 0, " + "`mon_conn_res` FLOAT NOT NULL DEFAULT 0, "
|
+ "`mon_cap` FLOAT NOT NULL DEFAULT 0, " + "`batt_count` INT NOT NULL DEFAULT 0, "
|
+ "`online_vol` FLOAT NOT NULL DEFAULT 0, " + "`group_vol` FLOAT NOT NULL DEFAULT 0, "
|
+ "`group_tmp` FLOAT NOT NULL DEFAULT 0, " + "`group_curr` FLOAT NOT NULL DEFAULT 0, "
|
+ "`batt_state` INT NOT NULL DEFAULT 0, " + "`batt_test_type` INT NOT NULL DEFAULT 0, "
|
+ "`batt_test_starttime` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
|
+ "`batt_test_recordtime` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
|
+ "`batt_test_tlong` INT NOT NULL DEFAULT 0, " + "`batt_test_cap` FLOAT NOT NULL DEFAULT 0, "
|
+ "`batt_real_cap` FLOAT NOT NULL DEFAULT 0, " + "`batt_rest_cap` FLOAT NOT NULL DEFAULT 0, "
|
+ "`batt_rest_power1_time` INT NOT NULL DEFAULT 0, "
|
+ "`batt_rest_power2_time` INT NOT NULL DEFAULT 0, " + "INDEX index_BattGroupId (`BattGroupId`), "
|
+ "PRIMARY KEY (`num`)) " + "ENGINE=MEMORY DEFAULT CHARSET=utf8;";
|
|
String sql_str2 = "INSERT INTO " + tb_name + " " + "(BattGroupId," + "mon_num)" + " VALUES ";
|
int cnt = 0;
|
for (int mc = 0; mc < batt_cnt; mc++) {
|
if (cnt > 0) {
|
sql_str2 = sql_str2 + ",";
|
}
|
sql_str2 = sql_str2 + "(" + bg_id + "," + (mc + 1) + ")";
|
cnt++;
|
}
|
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try {
|
sql.sqlMysqlExecute(sql_str1);
|
ResultSet res_t = sql.sqlMysqlQuery("SELECT COUNT(*) FROM " + tb_name);
|
if (res_t.next()) {
|
int cnt_row = res_t.getInt(1);
|
if (cnt_row != batt_cnt) {
|
sql.sqlMysqlExecute(sql_str0);
|
sql.sqlMysqlExecute(sql_str2);
|
}
|
} else {
|
sql.sqlMysqlExecute(sql_str2);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
public static void updateBattState_RT_RamDB_Table(MysqlConnPool conn_pool, PowerData_RT bd_rt) {
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try {
|
Date dt_test_Start = new Date();
|
Date dt_record = new Date();
|
dt_test_Start.setTime(bd_rt.getTestStartTime());
|
dt_record.setTime(bd_rt.getTestRecordTime());
|
String sql_str = "UPDATE " + Sql_Mysql.Rt_State_Table + " SET record_time='"
|
+ Com.getDateTimeFormat(new Date(), "yyyy-MM-dd HH:mm:ss") + "'"
|
+ "," + " online_vol=" + bd_rt.getOnlineVol()
|
+ "," + " group_vol=" + bd_rt.getGroupVol()
|
+ "," + " group_tmp=" + bd_rt.getGroupTmp()
|
+ "," + " group_curr=" + bd_rt.getTestCurr()
|
+ "," + " batt_state=" + bd_rt.getNewBattState()
|
+ "," + " batt_test_type=" + bd_rt.getBattTestType()
|
// + "," + " batt_test_starttime='" + Com.getDateTimeFormat(dt_test_Start, "yyyy-MM-dd HH:mm:ss") + "'"
|
// + ","+ " batt_test_recordtime='" + Com.getDateTimeFormat(dt_record, "yyyy-MM-dd HH:mm:ss") + "'"
|
+ ","+ " batt_test_tlong=" + bd_rt.getTestTimeLong()
|
+ "," + " batt_test_cap=" + bd_rt.getTestCap()
|
+ "," + " batt_real_cap=" + bd_rt.getBattRealCap()
|
//+ "," + " batt_rest_cap=" + bd_rt.getBattRestCap()
|
// + "," + " batt_rest_power1_time=" + bd_rt.getBattRestTime()
|
+ " WHERE binf_id= " + bd_rt.BattGroupId;
|
sql.sqlMysqlExecute(sql_str);
|
bd_rt.mTestData.updateNewDataRCTime(new Date());
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
public static void updateBattData_RT_RamDB_Table(MysqlConnPool conn_pool, PowerData_RT bd_rt) {
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try {
|
String sql_str = "UPDATE " + Sql_Mysql.Rt_Data_Table + " SET record_time='"
|
+ Com.getDateTimeFormat(new Date(), "yyyy-MM-dd HH:mm:ss") + "'";
|
|
float tmp_dt = 0.0F;
|
String sql_str_vol = " ";
|
for (int n = 0; n < bd_rt.MonCount; n++) {
|
tmp_dt = ((MonVolData) bd_rt.al_MonVol.get(n)).monVol;
|
if (((MonVolData) bd_rt.al_MonVol_RtOld.get(n)).monVol != tmp_dt) {
|
((MonVolData) bd_rt.al_MonVol_RtOld.get(n)).monVol = tmp_dt;
|
sql_str_vol = sql_str_vol + " WHEN " + (n + 1) + " THEN "
|
+ String.format("%1.3f", new Object[] { Float.valueOf(tmp_dt) });
|
}
|
}
|
if (sql_str_vol.trim().length() > 1) {
|
sql_str_vol = ", mon_vol = CASE mon_num " + sql_str_vol + " ELSE mon_vol END ";
|
}
|
String sql_str_tmp = " ";
|
for (int n = 0; n < bd_rt.MonCount; n++) {
|
tmp_dt = ((MonVolData) bd_rt.al_MonVol.get(n)).monTmp;
|
if (((MonVolData) bd_rt.al_MonVol_RtOld.get(n)).monTmp != tmp_dt) {
|
((MonVolData) bd_rt.al_MonVol_RtOld.get(n)).monTmp = tmp_dt;
|
sql_str_tmp = sql_str_tmp + " WHEN " + (n + 1) + " THEN "
|
+ String.format("%1.3f", new Object[] { Float.valueOf(tmp_dt) });
|
}
|
}
|
if (sql_str_tmp.trim().length() > 1) {
|
sql_str_tmp = ", mon_tmp = CASE mon_num " + sql_str_tmp + " ELSE mon_tmp END ";
|
}
|
|
String sql_str_res = " ";
|
for (int n = 0; n < bd_rt.MonCount; n++) {
|
tmp_dt = ((MonVolData) bd_rt.al_MonVol.get(n)).monRes;
|
if (((MonVolData) bd_rt.al_MonVol_RtOld.get(n)).monRes != tmp_dt) {
|
((MonVolData) bd_rt.al_MonVol_RtOld.get(n)).monRes = tmp_dt;
|
sql_str_res = sql_str_res + " WHEN " + (n + 1) + " THEN "
|
+ String.format("%1.3f", new Object[] { Float.valueOf(tmp_dt) });
|
}
|
}
|
if (sql_str_res.trim().length() > 1) {
|
sql_str_res = ", mon_res = CASE mon_num " + sql_str_res + " ELSE mon_res END ";
|
}
|
|
String sql_str_ser = " ";
|
for (int n = 0; n < bd_rt.MonCount; n++) {
|
tmp_dt = ((MonVolData) bd_rt.al_MonVol.get(n)).monSer;
|
if (((MonVolData) bd_rt.al_MonVol_RtOld.get(n)).monSer != tmp_dt) {
|
((MonVolData) bd_rt.al_MonVol_RtOld.get(n)).monSer = tmp_dt;
|
sql_str_ser = sql_str_ser + " WHEN " + (n + 1) + " THEN "
|
+ String.format("%1.3f", new Object[] { Float.valueOf(tmp_dt) });
|
}
|
}
|
if (sql_str_ser.trim().length() > 1) {
|
sql_str_ser = ", mon_ser = CASE mon_num " + sql_str_ser + " ELSE mon_ser END ";
|
}
|
|
String sql_str_jh = " ";
|
for (int n = 0; n < bd_rt.MonCount; n++) {
|
tmp_dt = ((MonVolData) bd_rt.al_MonVol.get(n)).monJHcurr;
|
if (((MonVolData) bd_rt.al_MonVol_RtOld.get(n)).monJHcurr != tmp_dt) {
|
((MonVolData) bd_rt.al_MonVol_RtOld.get(n)).monJHcurr = tmp_dt;
|
sql_str_jh = sql_str_jh + " WHEN " + (n + 1) + " THEN "
|
+ String.format("%1.3f", new Object[] { Float.valueOf(tmp_dt) });
|
}
|
}
|
if (sql_str_jh.trim().length() > 1) {
|
sql_str_jh = ", mon_JH_curr = CASE mon_num " + sql_str_jh + " ELSE mon_JH_curr END ";
|
}
|
|
String sql_str_2 = sql_str_vol + sql_str_tmp + sql_str_res + sql_str_ser + sql_str_jh;
|
if (sql_str_2.trim().length() > 1) {
|
sql_str_2 = sql_str_2 + " WHERE binf_id=" + bd_rt.BattGroupId;
|
} else {
|
sql_str_2 = " WHERE binf_id=" + bd_rt.BattGroupId;
|
}
|
|
sql_str = sql_str + sql_str_2;
|
|
//System.out.println(sql_str);
|
sql.sqlMysqlExecute(sql_str);
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
public static void updateVersion_Infor_Table(MysqlConnPool conn_pool) {
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try {
|
String BMS = "BMS_FBS9600_DISPLAY";
|
String VER = "v1.101";
|
String sql_str = "UPDATE web_site.tb_process_survey SET ProcessTime='"
|
+ Com.getDateTimeFormat(new Date(), "yyyy-MM-dd HH:mm:ss") + "'," + " Process_starttime='"
|
+ Com.getDateTimeFormat(new Date(), "yyyy-MM-dd HH:mm:ss") + "'," + "ProcessVersion='" + VER + "'"
|
+ " WHERE ProcessName='" + BMS + "' AND ServerName='" + BMS + "'";
|
|
sql.sqlMysqlExecute(sql_str);
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
public static void updateThread_Time_Table(MysqlConnPool conn_pool) {
|
String BMS = "BMS_FBS9600_DISPLAY";
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try {
|
String sql_str = "UPDATE web_site.tb_process_survey SET ProcessTime='"
|
+ Com.getDateTimeFormat(new Date(), "yyyy-MM-dd HH:mm:ss") + "'" + "WHERE ProcessName='" + BMS
|
+ "'AND ServerName='" + BMS + "'";
|
sql.sqlMysqlExecute(sql_str);
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
public static String getCreateBattTestDataStr(String tb_name) {
|
String sql_str = "CREATE TABLE IF NOT EXISTS " + tb_name + " " + "( `num` BIGINT NOT NULL AUTO_INCREMENT, "
|
+ "`BattGroupId` INT NOT NULL DEFAULT 0, " + "`test_record_count` INT NOT NULL DEFAULT 0, "
|
+ "`test_type` INT NOT NULL DEFAULT 0, " + "`data_new` BOOLEAN NOT NULL DEFAULT false, "
|
+ "`data_available` BOOLEAN NOT NULL DEFAULT false, " + "`record_num` INT NOT NULL DEFAULT 0, "
|
+ "`test_starttime` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
|
+ "`record_time` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
|
+ "`test_timelong` INT NOT NULL DEFAULT 0, " + "`online_vol` FLOAT NOT NULL DEFAULT 0, "
|
+ "`group_vol` FLOAT NOT NULL DEFAULT 0, " + "`test_curr` FLOAT NOT NULL DEFAULT 0, "
|
+ "`test_cap` FLOAT NOT NULL DEFAULT 0, " + "`mon_num` INT NOT NULL DEFAULT 0, "
|
+ "`mon_vol` FLOAT NOT NULL DEFAULT 0, " + "`mon_tmp` FLOAT NOT NULL DEFAULT 0, "
|
+ "INDEX index_test_record_count (`test_record_count`), " + "PRIMARY KEY (`num`));";
|
return sql_str;
|
}
|
|
public static String getInsertBattTestDataStr(PowerData_RT rt_data) {
|
int mon_count = rt_data.MonCount;
|
BattStatData tmp_test_data = rt_data.mTestData.clone();
|
String sql_str = "INSERT INTO tb_BattTestData_" + rt_data.BattGroupId + " " + "(BattGroupId, "
|
+ "test_record_count, " + "test_type, " + "data_new, " + "data_available, " + "record_num, "
|
+ "test_starttime, " + "record_time, " + "test_timelong, " + "online_vol, " + "group_vol, "
|
+ "test_curr, " + "test_cap, " + "mon_num, " + "mon_vol, " + "mon_tmp)" + " VALUES ";
|
|
String sql_str_data = "";
|
for (int n = 0; n < mon_count; n++) {
|
if ((n <= 0) || (rt_data.is_al_MonVol_History_New(n)) || (tmp_test_data.recordNum <= 2)) {
|
if (n > 0) {
|
sql_str_data = sql_str_data + ", ";
|
}
|
sql_str_data = sql_str_data + "(" + rt_data.BattGroupId + ", " + tmp_test_data.testRecordCount + ", "
|
+ tmp_test_data.battTestType_For_DataSave + ", " + true + ", " + true + ", "
|
+ (tmp_test_data.recordNum + 1) + ", " + "'"
|
+ Com.getDateTimeFormat(tmp_test_data.startTestTime, "yyyy-MM-dd HH:mm:ss") + "', " + "'"
|
+ Com.getDateTimeFormat(tmp_test_data.recordTime, "yyyy-MM-dd HH:mm:ss") + "', "
|
+ tmp_test_data.testTimeLong + ", " + tmp_test_data.onlineVol + ", " + tmp_test_data.groupVol
|
+ ", " + tmp_test_data.testCurr + ", " + tmp_test_data.testCap + ", " + (n + 1) + ", "
|
+ rt_data.get_al_MonVol_History(n) + ", " + ((MonVolData) rt_data.al_MonVol.get(n)).monTmp
|
+ ")";
|
}
|
|
}
|
|
return sql_str + sql_str_data;
|
}
|
|
public static ArrayList<String> getInsertOrUpdateBattTestDataStopStr(PowerData_RT rt_data) {
|
ArrayList al_sql_str = new ArrayList();
|
int mon_count = rt_data.MonCount;
|
BattStatData tmp_test_data = rt_data.mTestData.clone();
|
ArrayList tmp_mon_vol = rt_data.al_MonVol_History;
|
|
rt_data.makeMaxMinMonVol(tmp_mon_vol);
|
if (!rt_data.MysqlDataResInfTable_Exist) {
|
String sql_str = "INSERT INTO tb_BattTestDataStop_" + rt_data.BattGroupId + " (BattGroupId, "
|
+ "test_record_count, " + "test_type, " + "data_new, " + "data_available, " + "record_num, "
|
+ "test_starttime, " + "record_time, " + "test_timelong, " + "group_vol, " + "test_curr, "
|
+ "test_cap, " + "mon_num, " + "mon_vol)" + " VALUES ";
|
for (int n = 0; n < mon_count; n++) {
|
if (n > 0) {
|
sql_str = sql_str + ", ";
|
}
|
sql_str = sql_str + "(" + rt_data.BattGroupId + ", " + tmp_test_data.testRecordCount + ", "
|
+ tmp_test_data.battTestType_For_DataSave + ", " + true + ", " + true + ", "
|
+ (tmp_test_data.recordNum + 1) + ", " + "'"
|
+ Com.getDateTimeFormat(tmp_test_data.startTestTime, "yyyy-MM-dd HH:mm:ss") + "', " + "'"
|
+ Com.getDateTimeFormat(tmp_test_data.recordTime, "yyyy-MM-dd HH:mm:ss") + "', "
|
+ tmp_test_data.testTimeLong + ", " + tmp_test_data.groupVol + ", " + tmp_test_data.testCurr
|
+ ", " + tmp_test_data.testCap + ", " + (n + 1) + ", "
|
+ ((MonVolData) tmp_mon_vol.get(n)).monVol + ")";
|
}
|
al_sql_str.add(sql_str);
|
} else {
|
String sql_str = "UPDATE tb_BattTestDataStop_" + rt_data.BattGroupId + " SET " + " data_new=" + true + ", "
|
+ "data_available=" + true + ", " + "record_num=" + (tmp_test_data.recordNum + 1) + ", "
|
+ "record_time='" + Com.getDateTimeFormat(tmp_test_data.recordTime, "yyyy-MM-dd HH:mm:ss") + "', "
|
+ "test_timelong=" + tmp_test_data.testTimeLong + ", " + "group_vol=" + tmp_test_data.groupVol
|
+ ", " + "test_curr=" + tmp_test_data.testCurrAbsMax + ", " + "test_cap=" + tmp_test_data.testCap
|
+ " " + " WHERE " + " BattGroupId=" + rt_data.BattGroupId + " AND " + " test_record_count="
|
+ tmp_test_data.testRecordCount;
|
al_sql_str.add(sql_str);
|
|
String temp_str = "";
|
sql_str = "UPDATE tb_BattTestDataStop_" + rt_data.BattGroupId + " SET " + " mon_vol = CASE mon_num";
|
for (int n = 0; n < mon_count; n++) {
|
if ((n <= 0) || (rt_data.is_al_MonVol_History_New(n)) || (tmp_test_data.recordNum <= 2)) {
|
if (n > 0) {
|
temp_str = temp_str + ",";
|
}
|
temp_str = temp_str + (n + 1);
|
|
sql_str = sql_str + " WHEN " + (n + 1) + " THEN " + rt_data.get_al_MonVol_History(n);
|
}
|
}
|
sql_str = sql_str + " END WHERE mon_num IN (" + temp_str + ")" + " AND BattGroupId=" + rt_data.BattGroupId
|
+ " AND " + " test_record_count=" + tmp_test_data.testRecordCount;
|
|
al_sql_str.add(sql_str);
|
}
|
|
return al_sql_str;
|
}
|
|
public static String getInsertOrUpdateBattTestDataInfStr(PowerData_RT rt_data, int test_stoptype_t) {
|
String sql_str = " ";
|
BattStatData tmp_test_data = rt_data.mTestData.clone();
|
tmp_test_data.test_stoptype = test_stoptype_t;
|
|
if (!rt_data.MysqlRecordInf_Exist) {
|
sql_str = "INSERT INTO `db_batt_testdata`.`tb_batttestdata_inf` (BattGroupId, test_record_count, test_type, record_time_interval, data_new, data_available, record_num, test_starttime, test_starttype, record_time, test_timelong, test_stoptype, group_vol, test_curr, test_cap, max_monnum, max_monvol, min_monnum, min_monvol) VALUES ("
|
+ rt_data.BattGroupId + ", " + tmp_test_data.testRecordCount + ", "
|
+ tmp_test_data.battTestType_For_DataSave + ", " + rt_data.mSaveDataTimeInterval + ", " + true
|
+ ", " + true + ", " + (tmp_test_data.recordNum + 1) + ", " + "'"
|
+ Com.getDateTimeFormat(tmp_test_data.startTestTime, "yyyy-MM-dd HH:mm:ss") + "', "
|
+ tmp_test_data.testLoaderType + ", " + "'"
|
+ Com.getDateTimeFormat(tmp_test_data.recordTime, "yyyy-MM-dd HH:mm:ss") + "', "
|
+ tmp_test_data.testTimeLong + ", " + tmp_test_data.test_stoptype + ", " + tmp_test_data.groupVol
|
+ ", " + tmp_test_data.testCurr + ", " + tmp_test_data.testCap + ", " + rt_data.mMaxMonNum + ", "
|
+ rt_data.mMaxMonVol + ", " + rt_data.mMinMonNum + ", " + rt_data.mMinMonVol + ") ";
|
} else {
|
sql_str = "UPDATE `db_batt_testdata`.`tb_batttestdata_inf` SET test_type="
|
+ tmp_test_data.battTestType_For_DataSave + ", " + "record_time_interval="
|
+ rt_data.mSaveDataTimeInterval + ", " + "data_new=" + true + ", " + "data_available=" + true + ", "
|
+ "record_num=" + (tmp_test_data.recordNum + 1) + ", " + "test_starttime='"
|
+ Com.getDateTimeFormat(tmp_test_data.startTestTime, "yyyy-MM-dd HH:mm:ss") + "', "
|
+ "test_starttype=" + tmp_test_data.testLoaderType + ", " + "record_time='"
|
+ Com.getDateTimeFormat(tmp_test_data.recordTime, "yyyy-MM-dd HH:mm:ss") + "', " + "test_timelong="
|
+ tmp_test_data.testTimeLong + ", " + "test_stoptype=" + tmp_test_data.test_stoptype + ", "
|
+ "group_vol=" + tmp_test_data.groupVol + ", " + "test_curr=" + tmp_test_data.testCurrAbsMax + ", "
|
+ "test_cap=" + tmp_test_data.testCap + ", " + "max_monnum=" + rt_data.mMaxMonNum + ", "
|
+ "max_monvol=" + rt_data.mMaxMonVol + ", " + "min_monnum=" + rt_data.mMinMonNum + ", "
|
+ "min_monvol=" + rt_data.mMinMonVol + " " + " WHERE " + " BattGroupId=" + rt_data.BattGroupId
|
+ " AND " + " test_record_count=" + tmp_test_data.testRecordCount;
|
}
|
|
return sql_str;
|
}
|
|
/************************************************************************************************/
|
public static int queryTestRecordCountMax_From_tb_batttestdata_inf(MysqlConnPool conn_pool, int bg_id)
|
{
|
int rec_count = 0;
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try
|
{
|
String sql_str = "SELECT MAX(test_record_count) FROM " + Sql_Mysql.Batt_Test_Inf_Table
|
+ " WHERE binf_id=" + bg_id;
|
//System.out.println(sql_str);
|
ResultSet rs_t = sql.sqlMysqlQuery(sql_str);
|
if(rs_t.next()) {
|
rec_count = rs_t.getInt(1);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
|
return rec_count;
|
}
|
|
public static ArrayList<String> getDeleteBattTestDataStr(PowerData_RT rt_data) {
|
ArrayList al_str = new ArrayList();
|
|
BattStatData tmp_test_data = rt_data.mTestData.clone();
|
|
String sql_str = "DELETE FROM tb_BattTestData_" + rt_data.BattGroupId + " WHERE test_record_count="
|
+ tmp_test_data.testRecordCount;
|
al_str.add(sql_str);
|
|
sql_str = "DELETE FROM tb_BattTestDataStop_" + rt_data.BattGroupId + " WHERE test_record_count="
|
+ tmp_test_data.testRecordCount;
|
al_str.add(sql_str);
|
|
sql_str = "DELETE FROM `db_batt_testdata`.`tb_batttestdata_inf` WHERE BattGroupId=" + rt_data.BattGroupId
|
+ " AND " + " test_record_count=" + tmp_test_data.testRecordCount;
|
al_str.add(sql_str);
|
|
return al_str;
|
}
|
|
public static void queryBattState_From_RT_Table(MysqlConnPool conn_pool, PowerData_RT rtdata) {
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try
|
{
|
String sql_str = "SELECT * FROM " + Sql_Mysql.Rt_State_Table + " WHERE BattGroupId=" + rtdata.BattGroupId;
|
//System.out.println(sql_str);
|
ResultSet rs_t = sql.sqlMysqlQuery(sql_str);
|
if(rs_t.next()) {
|
rtdata.mTestData.battTestState = rs_t.getByte("batt_test_type");
|
if((BattStatData.BATTDATA_DISCHARGE == rtdata.mTestData.battTestState)
|
|| (BattStatData.BATTDATA_CHARGE == rtdata.mTestData.battTestState)) {
|
rtdata.mTestData.battTestType_For_DataSave = rtdata.mTestData.battTestState;
|
|
rtdata.mTestData.testLoaderType = rs_t.getByte("test_loadertype");
|
rtdata.mTestData.recordNum = rs_t.getInt("test_recordnum");
|
|
rtdata.mTestData.onlineVol = rs_t.getFloat("online_vol");
|
rtdata.mTestData.groupVol = rs_t.getFloat("group_vol");
|
rtdata.mTestData.groupTmp = rs_t.getFloat("group_tmp");
|
|
rtdata.mTestData.testCurr = rs_t.getFloat("group_curr");
|
rtdata.mTestData.TestCurr_RT = rtdata.mTestData.testCurr;
|
|
rtdata.mTestData.battState = rs_t.getByte("batt_state");
|
rtdata.mTestData.startTestTime.setTime(rs_t.getTimestamp("batt_test_starttime").getTime());
|
rtdata.mTestData.recordTime.setTime(rs_t.getTimestamp("batt_test_recordtime").getTime());
|
rtdata.mTestData.testTimeLong = rs_t.getInt("batt_test_tlong");
|
rtdata.mTestData.testCap = rs_t.getFloat("batt_test_cap");
|
rtdata.mTestData.battRealCap = rs_t.getFloat("batt_real_cap");
|
rtdata.mTestData.battRestCap = rs_t.getFloat("batt_rest_cap");
|
rtdata.mTestData.battRestTime = rs_t.getInt("batt_rest_power1_time");
|
}
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ³õʼ»¯µç³Ø×éµ¥ÌåÊý¾Ý±í
|
* @param battGroupId
|
* @param monCount
|
* @param m_Conn_Pool
|
*/
|
public static void checkBattRtData(int battGroupId, int monCount, MysqlConnPool pool) {
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
ResultSet res = null;
|
try {
|
if(monCount > 0) {
|
//System.out.println("SELECT MAX(mon_num) as max_monnum FROM db_real_batt.rt_data WHERE binf_id = " + battGroupId);
|
res = sql.sqlMysqlQuery("SELECT MAX(mon_num) as max_monnum FROM db_real_batt.rt_data WHERE binf_id = " + battGroupId);
|
if(res.next()) {
|
//Êý¾Ý¿âÖÐÓмǼ
|
int max_monnum = res.getInt("max_monnum");
|
if(max_monnum > monCount) {
|
//ÐèҪɾ³ýÆäÖжàÓàµÄµ¥Ìå
|
sql.sqlMysqlExecute("delete from " + Sql_Mysql.Rt_Data_Table + " where binf_id = " + battGroupId + " AND mon_num > " + monCount);
|
} else if(max_monnum < monCount){
|
//ÐèÒªÌí¼Óеĵ¥Ìå
|
for(int n = max_monnum;n<monCount;n++) {
|
res = sql.sqlMysqlQuery("insert into " + Sql_Mysql.Rt_Data_Table + "(binf_id,mon_num,record_time) values (" + battGroupId + ", " + (n+1) + ",'2000-01-01 00:00:00');");
|
}
|
}
|
}else {
|
//Êý¾Ý¿âÖÐÒ»Ìõ¼Ç¼¶¼Ã»ÓÐ
|
for(int n = 0;n<monCount;n++) {
|
res = sql.sqlMysqlQuery("insert into " + Sql_Mysql.Rt_Data_Table + "(binf_id,mon_num,record_time) values (" + battGroupId + ", " + (n+1) + ",'2000-01-01 00:00:00');");
|
}
|
|
}
|
}else {
|
sql.sqlMysqlExecute("delete from " + Sql_Mysql.Rt_Data_Table + " where binf_id = " + battGroupId);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
if(null != res) {
|
try {
|
res.close();
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
}
|
sql.close_con();
|
}
|
|
}
|
|
public static void checkBattRSData(int battGroupId, int monCount, MysqlConnPool pool) {
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
ResultSet res = null;
|
try {
|
if(monCount > 0) {
|
|
} else {
|
sql.sqlMysqlExecute("delete from " + Sql_Mysql.Rt_State_Table + " where binf_id = " + battGroupId + ";");
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
if(null != res) {
|
try {
|
res.close();
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
}
|
sql.close_con();
|
}
|
|
}
|
|
|
|
// public static void get_MonData_From_BattData_RT_RamDB_Table(MysqlConnPool m_Conn_Pool, PowerData_RT rtdata) {
|
// // TODO Auto-generated method stub
|
//
|
// }
|
}
|
