package com.batttest;
|
|
import java.sql.SQLException;
|
import java.util.Date;
|
|
import com.base.Com;
|
import com.battdata_rt.BattData_RT;
|
import com.battdata_rt.BattData_RT_Array;
|
import com.battdata_rt.BattStatData;
|
import com.battmonitor.data_store.InsertDataToMysql_Task_SQL;
|
import com.config.AppConfig;
|
import com.sql.MysqlConnPool;
|
import com.sql.Sql_Mysql;
|
|
public class BattResStorePro_Thread extends Thread {
|
|
private BattData_RT_Array m_Data;
|
private MysqlConnPool m_Conn_Pool;
|
//private int battResStoreDelayForTestManual = 1200;
|
//private int mSaveBattResDayInterval = 7;
|
|
//private Main_Com_Data m_Main_Com_Data = null;
|
|
public BattResStorePro_Thread(MysqlConnPool pool, AppConfig cfg, BattData_RT_Array data)
|
{
|
m_Conn_Pool = pool;
|
m_Data = data;
|
|
//battResStoreDelayForTestManual = cfg.getBattResStoreDelayForTestManual();
|
//mSaveBattResDayInterval = cfg.getBattResStoreDayInterval();
|
|
//m_Main_Com_Data = Com_Data;
|
}
|
|
/**
|
* 创建及添加数据到tb_battresdata_id表；添加数据，以及更新tb_battresdata_inf数据表，并且向表中添加数据
|
* @param conn_pool
|
* @param data_rt
|
* @param test_type
|
*/
|
public static void insertDataToResTable(MysqlConnPool conn_pool, BattData_RT data_rt, int test_type)
|
{
|
int mon_count = data_rt.MonCount;
|
if(mon_count < 1)
|
return;
|
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
String sql_str = null;
|
try {
|
sql.sqlMysqlUseDB(Sql_Mysql.DB_BATT_TESTDATA);
|
|
boolean result = true;
|
Date rc_time = new Date();
|
|
String tb_name = "tb_BattResData_" + data_rt.BattGroupId;
|
if(false == sql.sqlMysqlCheckIfTableExist(tb_name))
|
{
|
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, "
|
+ "`test_starttime` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
|
+ "`group_vol` FLOAT NOT NULL DEFAULT 0, "
|
+ "`test_curr` 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, "
|
+ "`mon_res` FLOAT NOT NULL DEFAULT 0, "
|
+ "`mon_ser` FLOAT NOT NULL DEFAULT 0, "
|
+ "`conn_res` FLOAT NOT NULL DEFAULT 0, "
|
+ "INDEX index_test_record_count (`test_record_count`), "
|
+ "PRIMARY KEY (`num`));";
|
//System.out.println(sql_str);
|
sql.sqlMysqlExecute(sql_str);
|
}
|
|
int mtest_record_count = sql.getBattTestRecordCountNew(data_rt.BattGroupId, Sql_Mysql.BattResDataInf_Table);
|
|
for(int c=0; c<3; c++)
|
{
|
try {
|
sql_str = "INSERT INTO " + tb_name + " "
|
+ " (BattGroupId, "
|
+ "test_record_count, "
|
+ "test_type, "
|
+ "data_new, "
|
+ "data_available, "
|
+ "test_starttime, "
|
+ "group_vol, "
|
+ "test_curr, "
|
+ "mon_num, "
|
+ "mon_vol,"
|
+ "mon_tmp,"
|
+ "mon_res,"
|
+ "mon_ser,"
|
+ "conn_res)"
|
+ " VALUES ";
|
try {
|
for(int n=0; n<mon_count; n++) {
|
String tmp_sql_str = "("
|
+ data_rt.BattGroupId + ", "
|
+ mtest_record_count + ", "
|
+ test_type + ", "
|
+ true + ", "
|
+ true + ", "
|
+ "'" + Com.getDateTimeFormat(rc_time, Com.DTF_YMDhms) + "', "
|
+ data_rt.mTestData.groupVol + ", "
|
+ data_rt.mTestData.testCurr + ", "
|
+ ((n+1)*10 + 1) + ", "
|
+ data_rt.al_MonVol.get(n).monVol + ","
|
+ data_rt.al_MonVol.get(n).monTmp + ","
|
+ data_rt.al_MonVol.get(n).monRes + ","
|
+ data_rt.al_MonVol.get(n).monSer + ","
|
+ data_rt.al_MonVol.get(n).connRes
|
+ ")";
|
if(n > 0) {
|
sql_str += ", ";
|
}
|
sql_str += tmp_sql_str;
|
}
|
} catch (Exception e) {
|
System.err.println("BattResStorePro_Thread.insertDataToResTable():" + e.getMessage());
|
}
|
|
String sql_str2 = "INSERT INTO " + Sql_Mysql.BattResDataInf_Table
|
+ " (BattGroupId, "
|
+ "test_record_count, "
|
+ "test_type, "
|
+ "data_new, "
|
+ "data_available, "
|
+ "test_starttime, "
|
+ "test_devtype, "
|
+ "record_time, "
|
+ "group_vol, "
|
+ "test_curr, "
|
+ "upload_usr_id) "
|
+ " VALUES "
|
+ "("+ data_rt.BattGroupId + ", "
|
+ mtest_record_count + ", "
|
+ test_type + ", "
|
+ true + ", "
|
+ true + ", "
|
+ "'" + Com.getDateTimeFormat(rc_time, Com.DTF_YMDhms) + "', "
|
+ 0 + ", "
|
+ "'" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms) + "', "
|
+ 0 + ", "
|
+ 0 + ", "
|
+ 0 + ") ";
|
if(1 == mtest_record_count) {
|
sql_str2 = "UPDATE " + Sql_Mysql.BattResDataInf_Table + " SET "
|
+ "test_type=" + test_type + ", "
|
+ "data_new=" + true + ", "
|
+ "data_available=" + true + ", "
|
+ "test_starttime='" + Com.getDateTimeFormat(rc_time, Com.DTF_YMDhms) + "', "
|
+ "test_devtype=" + 0 + ", "
|
+ "record_time='" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms) + "', "
|
+ "group_vol=" + 0 + ", "
|
+ "test_curr=" + 0 + ", "
|
+ "upload_usr_id=" + 0 + " "
|
+ " WHERE BattGroupId=" + data_rt.BattGroupId
|
+ " AND test_record_count=" + mtest_record_count;
|
}
|
//System.out.println(sql_str);
|
//System.out.println(sql_str2);
|
sql.mysql_con.setAutoCommit(false);
|
sql.sqlMysqlExecute(sql_str);
|
sql.sqlMysqlExecute(sql_str2);
|
sql.mysql_con.commit();
|
} catch (SQLException e) {
|
sql.mysql_con.rollback();
|
//System.out.println(sql_str);
|
e.printStackTrace();
|
result = false;
|
} finally {
|
sql.mysql_con.setAutoCommit(true);
|
if(true == result)
|
{
|
break;
|
}
|
else
|
{
|
try {
|
Thread.sleep(500);
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
}
|
} catch (SQLException e) {
|
System.out.println(e.getMessage());
|
}
|
finally
|
{
|
sql.close_con();
|
}
|
}
|
//-----------------------------------------------------------------------------//
|
@Override
|
public void run() {
|
|
System.out.println(this.getName() + " - BattResStorePro_Thread Started ...");
|
|
try {
|
for(int s=0; s<6; s++)
|
{
|
sleep(1000);
|
}
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
|
while(true) {
|
try {
|
sleep(2000);
|
|
for(int n=0; n<m_Data.getItemCount(); n++) {
|
BattData_RT rt_data = m_Data.getItem(n);
|
if(((rt_data.FBSDeviceId/100000) == 9605)) {
|
//InsertDataToMysql_Task_SQL.get_MonData_From_BattData_RT_RamDB_Table(m_Conn_Pool, rt_data);
|
//InsertDataToMysql_Task_SQL.get_ResTestState_From_FBS9100State_RT_RamDB_Table(m_Conn_Pool, rt_data);
|
}
|
|
if(0x00 == rt_data.mTestData.batt_res_test_state) {
|
try {
|
if(rt_data.al_MonVol.get(0).monRes > 0) {
|
|
if(rt_data.mTestData.batt_res_test_cnt_last != rt_data.mTestData.batt_res_test_cnt) {
|
//System.out.println(rt_data.BattGroupId+"===="+rt_data.mTestData.batt_res_test_cnt);
|
rt_data.mTestData.batt_res_test_cnt_last = rt_data.mTestData.batt_res_test_cnt;
|
if(rt_data.mTestData.batt_res_test_cnt > 0) {
|
rt_data.setStoreBattRes_DataEnStat(true);
|
}
|
}
|
}
|
} catch (Exception e) {
|
System.err.println("BattResStorePro_Thread.run():" + e.getMessage());
|
}
|
}
|
|
if(true == rt_data.getStoreBattRes_DataEnStat()) {
|
System.out.println(this.getName() + " - BattResStorePro_Thread: "
|
+ "dev_id:" + rt_data.FBSDeviceId + " bg_id:" + rt_data.BattGroupId
|
+ " Insert Batt Res Data Into DB - "
|
+ Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
|
|
insertDataToResTable(m_Conn_Pool, rt_data, BattStatData.BATTDATA_RES);
|
rt_data.setStoreBattRes_DataEnStat(false);
|
}
|
}
|
//------------------------------------------------------------------------//
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
}
|
