package com.batttest;
|
|
import java.sql.SQLException;
|
import java.util.Date;
|
|
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.Logger;
|
|
import com.battmonitor.base.Com;
|
import com.battmonitor.data.BattData_RT;
|
import com.battmonitor.data.BattData_RT_Array;
|
import com.battmonitor.data.BattStatData;
|
import com.battmonitor.data_store.InsertDataToMysql_Task_SQL;
|
import com.battmonitor.sql.MysqlConnPool;
|
import com.battmonitor.sql.Sql_Mysql;
|
import com.config.AppConfig;
|
|
public class BattResStorePro_Thread extends Thread {
|
|
private BattData_RT_Array m_Data;
|
private MysqlConnPool m_Conn_Pool;
|
|
private Logger logger = null;
|
//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)
|
{
|
logger = LogManager.getLogger(this.getClass());
|
|
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 = 0;//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) {
|
sql.logger.error("BattResStorePro_Thread.insertDataToResTable():" + e.toString(), e);
|
}
|
|
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);
|
sql.logger.error("BattResStorePro_Thread.insertDataToResTable():" + e.toString(), e);
|
result = false;
|
} finally {
|
sql.mysql_con.setAutoCommit(true);
|
if(true == result)
|
{
|
break;
|
}
|
else
|
{
|
try {
|
Thread.sleep(500);
|
} catch (InterruptedException e) {
|
sql.logger.error("BattResStorePro_Thread.insertDataToResTable():" + e.toString(), e);
|
}
|
}
|
}
|
}
|
} catch (SQLException e) {
|
sql.logger.error("BattResStorePro_Thread.insertDataToResTable():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
/**
|
*
|
* @lijun 2021-08-16 ÖØд¼Ç¼µ¥ÌåÄÚ×èÊý¾Ý·½·¨£¬Îª¼Ç¼·ÅµçÊý¾Ýʱ¼Ç¼µ±Ç°µ¥ÌåµÄÄÚ×èÊý¾Ý
|
*
|
* ´´½¨¼°Ìí¼ÓÊý¾Ýµ½tb_battresdata_id±í£»Ìí¼ÓÊý¾Ý£¬ÒÔ¼°¸üÐÂtb_battresdata_infÊý¾Ý±í£¬²¢ÇÒÏò±íÖÐÌí¼ÓÊý¾Ý
|
* @param conn_pool
|
* @param data_rt
|
* @param test_type
|
*/
|
public static void insertMonDataToResTable(MysqlConnPool conn_pool, BattData_RT data_rt,Date test_starttime, 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 = test_starttime;
|
|
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 = 0;//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) {
|
sql.logger.error("BattResStorePro_Thread.insertDataToResTable():" + e.toString(), e);
|
}
|
|
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(rc_time, 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(rc_time, 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);
|
sql.logger.error("BattResStorePro_Thread.insertDataToResTable():" + e.toString(), e);
|
result = false;
|
} finally {
|
sql.mysql_con.setAutoCommit(true);
|
if(true == result)
|
{
|
break;
|
}
|
else
|
{
|
try {
|
Thread.sleep(500);
|
} catch (InterruptedException e) {
|
sql.logger.error("BattResStorePro_Thread.insertDataToResTable():" + e.toString(), e);
|
}
|
}
|
}
|
}
|
} catch (SQLException e) {
|
sql.logger.error("BattResStorePro_Thread.insertDataToResTable():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
//-----------------------------------------------------------------------------//
|
@Override
|
public void run() {
|
logger.info("BattResStorePro_Thread Started ...");
|
|
try {
|
for(int s=0; s<6; s++) {
|
sleep(1000);
|
}
|
} catch (InterruptedException e) {
|
logger.error(e.toString(), e);
|
}
|
|
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/1000000) != 910)
|
&& ((rt_data.FBSDeviceId/1000000) != 911)
|
&& ((rt_data.FBSDeviceId/1000000) != 91)
|
&& ((rt_data.FBSDeviceId/10000) != 9600)
|
&& ((rt_data.FBSDeviceId/10000) != 9610)
|
&& ((rt_data.FBSDeviceId/100000) != 9616)
|
&& ((rt_data.FBSDeviceId/100000) != 3601)) //¼¼Êõ²¿7´çÏÔʾÆÁ
|
{
|
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.size() > 0) {
|
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) {
|
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) {
|
logger.error(e.toString(), e);
|
}
|
}
|
|
if(true == rt_data.getStoreBattRes_DataEnStat()) {
|
logger.info("dev_id:" + rt_data.FBSDeviceId + " bg_id:" + rt_data.BattGroupId
|
+ " Insert Batt Res Data Into DB");
|
|
insertDataToResTable(m_Conn_Pool, rt_data, BattStatData.BATTDATA_RES);
|
rt_data.setStoreBattRes_DataEnStat(false);
|
}
|
}
|
//------------------------------------------------------------------------//
|
} catch (InterruptedException e) {
|
logger.error(e.toString(), e);
|
}
|
}
|
}
|
}
|
