package com.dev.lock.history;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.ArrayList;
|
|
import com.dev.lock.data.ElectLock_Inf;
|
import com.dev.lock.data.ElectLock_RecordState;
|
import com.dev.lock.data.ElectLock_Report;
|
import com.sql.MysqlConnPool;
|
import com.sql.Sql_Mysql;
|
|
public class InsertDataToMysql_Task implements Runnable{
|
private ElectLock_Inf m_lock_rt = null;
|
private MysqlConnPool m_Conn_Pool;
|
|
|
public InsertDataToMysql_Task()
|
{
|
}
|
|
public InsertDataToMysql_Task(ElectLock_Inf rt_dat, MysqlConnPool pool) {
|
m_lock_rt = rt_dat;
|
m_Conn_Pool = pool;
|
|
}
|
@Override
|
public void run() {
|
Sql_Mysql sql = new Sql_Mysql(m_Conn_Pool.getConn());
|
try {
|
|
inserTestDataToDB(sql);
|
} catch (Exception e) {
|
sql.logger.error(e.toString(), e);
|
} finally {
|
sql.close_con();
|
m_lock_rt.clearStoreDataBusyTag();
|
}
|
}
|
|
|
private void inserTestDataToDB(Sql_Mysql sql_v) {
|
boolean result = true;
|
for(int c=0; c<3; c++) {
|
try {
|
sql_v.mysql_con.setAutoCommit(false);
|
//--------------------------------------------------------------//
|
if(m_lock_rt.lockRecordState.lock_state == ElectLock_RecordState.Lock_State_Open) {
|
//当前为开锁事件
|
m_lock_rt.lockReport.calNewOpenEvent(m_lock_rt.lockRecordState.record_time);
|
|
String sql_str = InsertDataToMysql_Task_SQL.getInsertLock_Report_TableDataStr(m_lock_rt.getLock_id(),m_lock_rt.lockReport);
|
|
sql_v.sqlMysqlExecute(sql_str);
|
}
|
|
|
String sql_str = InsertDataToMysql_Task_SQL.getInsertLock_His_TableDataStr(m_lock_rt.getLock_id(), m_lock_rt.lockRecordState);
|
//------------------------------------------------------------//
|
|
sql_v.sqlMysqlExecute(sql_str);
|
//------------------------------------------------------------//
|
sql_v.mysql_con.commit();
|
|
} catch (SQLException e) {
|
try {
|
sql_v.mysql_con.rollback();
|
} catch (SQLException e1) {
|
sql_v.logger.error("InsertDataToMysql_Task.inserTestDataToDB():" + e1.toString(), e1);
|
}
|
sql_v.logger.error("InsertDataToMysql_Task.-inserTestDataToDB():" + e.toString(), e);
|
result = false;
|
} finally {
|
|
if(true == result) {
|
m_lock_rt.lockRecordState.RecordHisOK();
|
break;
|
} else {
|
try {
|
Thread.sleep(1000);
|
} catch (Exception e) {
|
sql_v.logger.error("InsertDataToMysql_Task.inserTestDataToDB():" + e.toString(), e);
|
}
|
}
|
}
|
}
|
}
|
}
|
