package com.battdata_rt;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.ArrayList;
|
import java.util.Date;
|
|
import com.base.Com;
|
import com.dec.fbs9100.MysqlConnPool;
|
import com.dec.fbs9100.Sql_Mysql;
|
|
public class BattData_RT_SQL {
|
|
/**
|
* ������������tb_batt_rtdata����������������������������bd_al�����������������������������������������id������mon_num ��
|
* @param conn_pool
|
* @param bd_al
|
*/
|
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 += "(" + 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 BattData_RT selectRT_BttInf_Table(MysqlConnPool conn_pool,BattData_RT bd_rt){
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
ResultSet res = null;
|
String sql_str = "SELECT * FROM " + Sql_Mysql.BattInf_Table
|
+ " WHERE "
|
+ " FBSDeviceId= " + bd_rt.FBSDeviceId;
|
res = sql.sqlMysqlQuery(sql_str);
|
try {
|
while(res.next()) {
|
bd_rt.FBSDeviceIp = res.getString("FBSDeviceIp");
|
bd_rt.FBSDeviceIp_WG = res.getString("FBSDeviceIp_WG");
|
bd_rt.FBSDeviceIp_YM = res.getString("FBSDeviceIp_YM");
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
return bd_rt;
|
}
|
/************************************************************************************************/
|
public static void updateBattState_RT_RamDB_Table(MysqlConnPool conn_pool, BattData_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());
|
|
//System.out.println("bd_rt.getBattRestCap():"+bd_rt.getBattRestCap());
|
String sql_str = "UPDATE " + Sql_Mysql.BattRtState_Table
|
+ " SET "
|
+ " rec_datetime='" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms) + "',"
|
+ " batt_count=" + bd_rt.MonCount + ","
|
+ " online_vol=" + bd_rt.getOnlineVol() + ","
|
+ " group_vol=" + bd_rt.getGroupVol() + ","
|
+ " group_tmp=" + bd_rt.getGroupTmp() + ","
|
+ " group_curr=" + bd_rt.getGroupCurr() + ","
|
+ " batt_state=" + bd_rt.getBattState() + ","
|
+ " batt_test_type=" + bd_rt.getBattTestType() + ","
|
+ " batt_test_starttime='" + Com.getDateTimeFormat(dt_test_Start, Com.DTF_YMDhms) + "',"
|
+ " batt_test_recordtime='" + Com.getDateTimeFormat(dt_record, Com.DTF_YMDhms) + "',"
|
+ " 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 BattGroupId=" + bd_rt.BattGroupId;
|
|
//System.out.println(sql_str);
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
/************************************************************************************************/
|
/**
|
* ������������tb_batt_rtdata��������������������������
|
* @param conn_pool
|
* @param bd_al
|
*/
|
public static void updateBattData_RT_RamDB_Table(MysqlConnPool conn_pool, BattData_RT bd_rt)
|
{
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try
|
{
|
String sql_str = "UPDATE " + Sql_Mysql.BattRtData_Table
|
+ " SET "
|
+ " rec_datetime='" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms) + "'";
|
|
float tmp_dt = 0;
|
String sql_str_vol = " ";
|
for(int n=0; n<bd_rt.MonCount; n++) {
|
tmp_dt = bd_rt.al_MonVol.get(n).monVol;
|
if(bd_rt.al_MonVol_RtOld.get(n).monVol != tmp_dt) {
|
bd_rt.al_MonVol_RtOld.get(n).monVol = tmp_dt;
|
sql_str_vol += " WHEN " + (n+1) + " THEN " + String.format("%1.3f", 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 = bd_rt.al_MonVol.get(n).monTmp;
|
if(bd_rt.al_MonVol_RtOld.get(n).monTmp != tmp_dt) {
|
bd_rt.al_MonVol_RtOld.get(n).monTmp = tmp_dt;
|
sql_str_tmp += " WHEN " + (n+1) + " THEN " + String.format("%1.3f", 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 = bd_rt.al_MonVol.get(n).monRes;
|
if(bd_rt.al_MonVol_RtOld.get(n).monRes != tmp_dt) {
|
bd_rt.al_MonVol_RtOld.get(n).monRes = tmp_dt;
|
sql_str_res += " WHEN " + (n+1) + " THEN " + String.format("%1.3f", 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 = bd_rt.al_MonVol.get(n).monSer;
|
if(bd_rt.al_MonVol_RtOld.get(n).monSer != tmp_dt) {
|
bd_rt.al_MonVol_RtOld.get(n).monSer = tmp_dt;
|
sql_str_ser += " WHEN " + (n+1) + " THEN " + String.format("%1.3f", 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 = bd_rt.al_MonVol.get(n).mon_JH_curr;
|
//if(bd_rt.al_MonVol_RtOld.get(n).mon_JH_curr != tmp_dt) {
|
bd_rt.al_MonVol_RtOld.get(n).mon_JH_curr = tmp_dt;
|
sql_str_JH += " WHEN " + (n+1) + " THEN " + String.format("%1.3f", 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 += " WHERE BattGroupId=" + bd_rt.BattGroupId;
|
/*
|
+ " AND mon_num IN (";
|
for(int n=0; n<brt.MonCount; n++) {
|
if(n > 0) {
|
sql_str_2 += ",";
|
}
|
sql_str_2 += (n+1);
|
}
|
sql_str_2 += ")";
|
*/
|
} else {
|
sql_str_2 = " WHERE BattGroupId=" + bd_rt.BattGroupId;
|
}
|
|
sql_str += sql_str_2;
|
//System.out.println(bd_rt.MonCount);
|
//System.out.println(sql_str);
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
/************************************************************************************************/
|
/**
|
* �������������������������������������������������������������
|
* @param tb_name
|
* @return
|
*/
|
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;
|
}
|
|
|
/**
|
* ������tb_batttestdata_id�������������������������������������������������
|
* @param rt_data
|
* @return
|
*/
|
public static String getInsertBattTestDataStr(BattData_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) && (false == rt_data.is_al_MonVol_History_New(n)) && (tmp_test_data.recordNum > 2))
|
continue;
|
|
if(n > 0)
|
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, Com.DTF_YMDhms) + "', "
|
+ "'" + Com.getDateTimeFormat(tmp_test_data.recordTime, Com.DTF_YMDhms) + "', "
|
+ rt_data.getTestTimeLong() + ", "
|
+ 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) + ", "
|
+ rt_data.al_MonVol.get(n).monTmp + ")";
|
}
|
/*
|
//--------------- ������BPM7100����������������� ----------------//
|
if(main_MonitorServer_FBS9100S.is_app_for_bpm7100_only) {
|
if(sql_str_data.trim().length() > 0) {
|
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, Com.DTF_YMDhms) + "', "
|
+ "'" + Com.getDateTimeFormat(tmp_test_data.recordTime, Com.DTF_YMDhms) + "', "
|
+ tmp_test_data.testTimeLong + ", "
|
+ tmp_test_data.onlineVol + ", "
|
+ tmp_test_data.groupVol + ", "
|
+ tmp_test_data.testCurr + ", "
|
+ tmp_test_data.testCap + ", "
|
+ (100010) + ", "
|
+ tmp_test_data.groupTmp + ")";
|
}
|
*/
|
return (sql_str + sql_str_data);
|
}
|
|
/**
|
* ������tb_batttestdatastop_id�������������������������������������������������������������
|
* @param rt_data
|
* @return
|
*/
|
public static ArrayList<String> getInsertOrUpdateBattTestDataStopStr(BattData_RT rt_data)
|
{
|
ArrayList<String> al_sql_str = new ArrayList<String>();
|
int mon_count = rt_data.MonCount;
|
BattStatData tmp_test_data = rt_data.mTestData.clone();
|
ArrayList<MonVolData> tmp_mon_vol = rt_data.al_MonVol_History;
|
|
rt_data.makeMaxMinMonVol(tmp_mon_vol);
|
if(false == 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, "
|
//+ "online_vol, "
|
+ "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 += "("+ 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, Com.DTF_YMDhms) + "', "
|
+ "'" + Com.getDateTimeFormat(tmp_test_data.recordTime, Com.DTF_YMDhms) + "', "
|
+ tmp_test_data.testTimeLong + ", "
|
//+ tmp_test_data.onlineVol + ", "
|
+ tmp_test_data.groupVol + ", "
|
+ tmp_test_data.testCurr + ", "
|
+ tmp_test_data.testCap + ", "
|
+ (n+1) + ", "
|
+ 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, Com.DTF_YMDhms) + "', "
|
+ "test_timelong=" + tmp_test_data.testTimeLong + ", "
|
//+ "online_vol=" + tmp_test_data.onlineVol + ", "
|
+ "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) && (false == rt_data.is_al_MonVol_History_New(n)) && (tmp_test_data.recordNum > 2))
|
continue;
|
|
if(n > 0)
|
{
|
temp_str += ",";
|
}
|
temp_str += (n+1);
|
|
sql_str += " WHEN " + (n+1) + " THEN " + rt_data.get_al_MonVol_History(n);
|
}
|
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;
|
}
|
|
|
/**
|
* ������tb_batttestdata_inf�������������������������������������������������������������
|
* @param rt_data
|
* @return
|
*/
|
public static String getInsertOrUpdateBattTestDataInfStr(BattData_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(false == rt_data.MysqlRecordInf_Exist)
|
{
|
sql_str = "INSERT INTO " + Sql_Mysql.BattTestDataInf_Table
|
+ " (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, Com.DTF_YMDhms) + "', "
|
+ tmp_test_data.testLoaderType + ", "
|
+ "'" + Com.getDateTimeFormat(tmp_test_data.recordTime, Com.DTF_YMDhms) + "', "
|
+ 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 " + Sql_Mysql.BattTestDataInf_Table
|
+ " 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, Com.DTF_YMDhms) + "', "
|
+ "test_starttype=" + tmp_test_data.testLoaderType + ", "
|
+ "record_time='" + Com.getDateTimeFormat(tmp_test_data.recordTime, Com.DTF_YMDhms) + "', "
|
+ "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;
|
}
|
//System.out.println(sql_str);
|
return sql_str;
|
}
|
|
|
/**
|
* ��������������������rt_data����������������������������������������tb_batttestdata_id,tb_testdatastop_id,tb_batttestdata_inf��������������������������SQL���������������
|
* @param rt_data
|
* @return
|
*/
|
public static ArrayList<String> getDeleteBattTestDataStr(BattData_RT rt_data)
|
{
|
ArrayList<String> al_str = new ArrayList<String>();
|
|
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 " + Sql_Mysql.BattTestDataInf_Table
|
+ " WHERE "
|
+ " BattGroupId=" + rt_data.BattGroupId
|
+ " AND "
|
+ " test_record_count=" + tmp_test_data.testRecordCount;
|
al_str.add(sql_str);
|
|
return al_str;
|
}
|
}
|
