| New file |
| | |
|---|
| | | package com.dec.fbs9100;
|
|---|
| | |
|
|---|
| | | import java.sql.ResultSet;
|
|---|
| | | import java.sql.SQLException;
|
|---|
| | | import java.util.Date;
|
|---|
| | |
|
|---|
| | | import com.base.AppConfig;
|
|---|
| | | import com.base.Com;
|
|---|
| | | import com.battdata_rt.BattData_RT;
|
|---|
| | | import com.battdata_rt.BattData_RT_Array;
|
|---|
| | | import com.battdata_rt.BattStatData;
|
|---|
| | |
|
|---|
| | | 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 = 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) {
|
|---|
| | | System.err.println("BattResStorePro_Thread.insertDataToResTable():" + e.toString());
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | 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);
|
|---|
| | | System.err.println("BattResStorePro_Thread.insertDataToResTable():" + e.toString());
|
|---|
| | | result = false;
|
|---|
| | | } finally {
|
|---|
| | | sql.mysql_con.setAutoCommit(true);
|
|---|
| | | if(true == result)
|
|---|
| | | {
|
|---|
| | | break;
|
|---|
| | | }
|
|---|
| | | else
|
|---|
| | | {
|
|---|
| | | try {
|
|---|
| | | Thread.sleep(500);
|
|---|
| | | } catch (InterruptedException e) {
|
|---|
| | | System.err.println("BattResStorePro_Thread.insertDataToResTable():" + e.toString());
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | } catch (SQLException e) {
|
|---|
| | | System.err.println("BattResStorePro_Thread.insertDataToResTable():" + e.toString());
|
|---|
| | | } 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) {
|
|---|
| | | System.err.println("BattResStorePro_Thread.insertDataToResTable():" + e.toString());
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | 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);
|
|---|
| | | System.err.println("BattResStorePro_Thread.insertDataToResTable():" + e.toString());
|
|---|
| | | result = false;
|
|---|
| | | } finally {
|
|---|
| | | sql.mysql_con.setAutoCommit(true);
|
|---|
| | | if(true == result)
|
|---|
| | | {
|
|---|
| | | break;
|
|---|
| | | }
|
|---|
| | | else
|
|---|
| | | {
|
|---|
| | | try {
|
|---|
| | | Thread.sleep(500);
|
|---|
| | | } catch (InterruptedException e) {
|
|---|
| | | System.err.println("BattResStorePro_Thread.insertDataToResTable():" + e.toString());
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | } catch (SQLException e) {
|
|---|
| | | System.err.println("BattResStorePro_Thread.insertDataToResTable():" + e.toString());
|
|---|
| | | } finally {
|
|---|
| | | sql.close_con();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | //-----------------------------------------------------------------------------//
|
|---|
| | | @Override
|
|---|
| | | public void run() {
|
|---|
| | | System.out.println("BattResStorePro_Thread Started ...");
|
|---|
| | | |
|---|
| | | try {
|
|---|
| | | for(int s=0; s<6; s++) {
|
|---|
| | | sleep(1000);
|
|---|
| | | }
|
|---|
| | | } catch (InterruptedException e) {
|
|---|
| | | System.err.println(e.toString());
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | 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寸显示屏
|
|---|
| | | {
|
|---|
| | | get_MonData_From_BattData_RT_RamDB_Table(m_Conn_Pool, rt_data);
|
|---|
| | | 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) {
|
|---|
| | | System.err.println(e.toString());
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | if(true == rt_data.getStoreBattRes_DataEnStat()) {
|
|---|
| | | System.out.println("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) {
|
|---|
| | | System.err.println(e.toString());
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | |
|---|
| | | public static void get_MonData_From_BattData_RT_RamDB_Table(MysqlConnPool conn_pool, BattData_RT bd_rt)
|
|---|
| | | {
|
|---|
| | | Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
|---|
| | | try {
|
|---|
| | | String sql_str = "SELECT mon_num,mon_vol,mon_tmp,mon_res,mon_ser,mon_conn_res FROM " + Sql_Mysql.BattRtData_Table
|
|---|
| | | + " WHERE BattGroupId=" + bd_rt.BattGroupId
|
|---|
| | | + " ORDER BY mon_num ASC";
|
|---|
| | | //System.out.println(sql_str);
|
|---|
| | | ResultSet res = sql.sqlMysqlQuery(sql_str);
|
|---|
| | | try {
|
|---|
| | | while(res.next()) {
|
|---|
| | | int mon_index = res.getInt("mon_num");
|
|---|
| | | if(mon_index > 0) {
|
|---|
| | | mon_index -= 1;
|
|---|
| | | }
|
|---|
| | | if(mon_index < bd_rt.al_MonVol.size()) {
|
|---|
| | | bd_rt.al_MonVol.get(mon_index).monVol = res.getFloat("mon_vol");
|
|---|
| | | bd_rt.al_MonVol.get(mon_index).monTmp = res.getFloat("mon_tmp");
|
|---|
| | | bd_rt.al_MonVol.get(mon_index).monRes = res.getFloat("mon_res");
|
|---|
| | | bd_rt.al_MonVol.get(mon_index).monSer = res.getFloat("mon_ser");
|
|---|
| | | bd_rt.al_MonVol.get(mon_index).connRes = res.getFloat("mon_conn_res");
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | System.err.println("InsertDataToMysql_Task_SQL.get_MonData_From_BattData_RT_RamDB_Table():" + e.toString());
|
|---|
| | | }
|
|---|
| | | res.close();
|
|---|
| | | } catch (SQLException e) {
|
|---|
| | | // TODO Auto-generated catch block
|
|---|
| | | System.err.println("InsertDataToMysql_Task_SQL.get_MonData_From_BattData_RT_RamDB_Table():" + e.toString());
|
|---|
| | | } finally {
|
|---|
| | | sql.close_con();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | |
|---|
| | | /************************************************************************************************/
|
|---|
| | | public static void get_ResTestState_From_FBS9100State_RT_RamDB_Table(MysqlConnPool conn_pool, BattData_RT bd_rt)
|
|---|
| | | {
|
|---|
| | | Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
|---|
| | | try {
|
|---|
| | | String sql_str = "SELECT dev_res_test_state,dev_restest_count FROM " + Sql_Mysql.FBS9100State_Table
|
|---|
| | | + " WHERE dev_id=" + bd_rt.FBSDeviceId;
|
|---|
| | | //System.out.println(sql_str);
|
|---|
| | | ResultSet res = sql.sqlMysqlQuery(sql_str);
|
|---|
| | | if(res.next()) {
|
|---|
| | | bd_rt.mTestData.batt_res_test_state = res.getInt("dev_res_test_state");
|
|---|
| | | bd_rt.mTestData.batt_res_test_cnt = res.getInt("dev_restest_count");
|
|---|
| | | }
|
|---|
| | | res.close();
|
|---|
| | | } catch (SQLException e) {
|
|---|
| | | // TODO Auto-generated catch block
|
|---|
| | | System.err.println("InsertDataToMysql_Task_SQL.get_ResTestState_From_FBS9100State_RT_RamDB_Table():" + e.toString());
|
|---|
| | | } finally {
|
|---|
| | | sql.close_con();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
