package com.socket;
|
|
import android.database.Cursor;
|
import android.database.SQLException;
|
import android.database.sqlite.SQLiteDatabase;
|
import android.util.Log;
|
|
import com.concentrator.Concentrator_State;
|
import com.fgkj.dao.DBHelper;
|
import com.util.Com;
|
|
import java.util.Date;
|
|
/**
|
* 内阻数据记录线程
|
*/
|
public class BattResDataRecordThread extends Thread{
|
public static final String TAG = "BattResDataRecordThread";
|
|
public BattDataThread battData; //电池实时数据
|
public DBHelper dbHelper; //数据库对象
|
public int lastResTestCount = 0; //上一次内阻测试的次数
|
|
public BattResDataRecordThread(BattDataThread battData,DBHelper dbHelper){
|
this.battData = battData;
|
this.dbHelper = dbHelper;
|
|
dbHelper.Create_battresdata(dbHelper.getWritableDatabase(),battData.battIndex); //创建当前电池组的内阻数据表
|
}
|
|
@Override
|
public void run() {
|
Log.d(TAG, "run: BattResDataRecordThread start at" + Com.getDateTimeFormat(new Date(),Com.DTF_YMDhms));
|
|
|
while(true){
|
try {
|
//Log.e(TAG, "run: "+ battData.isOutTime+"\tlastResTestCount:"+lastResTestCount+"\t count:"+battData.state.getRestestcount());
|
if(!battData.isOutTime){
|
if(lastResTestCount != battData.state.getRestestcount()){
|
if(battData.state.monCount >0 && battData.state.mon_ress[battData.state.monCount-1] > 0){
|
//开始记录内阻历史数据
|
int max_test_record_count = queryMaxTestRecordCount(battData.battIndex,dbHelper); //查询当前电池组最大的记录笔数
|
Log.e(TAG, "run: MAXCOUNT:"+max_test_record_count );
|
//插入 tb_battresdata_inf 表中
|
insertBattResDataInf(battData.battIndex, battData.state,dbHelper,max_test_record_count);
|
|
//插入 tb_battresdata_id 表中
|
insertBattResDataID(battData.battIndex,battData.state,dbHelper,max_test_record_count);
|
//Log.e(TAG, "run: battindex:"+battData.battIndex+"记录历史数据成功 #############################");
|
lastResTestCount = battData.state.getRestestcount();
|
}
|
}
|
}
|
sleep(3000);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
public static void insertBattResDataID(int battgroupid,Concentrator_State state,DBHelper dbHelper,int test_record_count){
|
String sql_str_start = "INSERT INTO tb_battresdata_1(BattGroupId,test_record_count,test_type,test_starttime,group_vol,test_curr,mon_num,mon_vol,mon_tmp,mon_res) VALUES ";
|
String sql_str_base = "";
|
for(int i = 0;i<state.monCount;i++){
|
if(i != 0){
|
sql_str_base += ",";
|
}
|
sql_str_base += "("+battgroupid+","+test_record_count+","+BattDataThread.TESTTYPE_RESTEST+",'"+Com.getDateTimeFormat(new Date(),Com.DTF_YMDhms)+"',"+state.getGroupvol()+","+state.getGroupcurr()+","+(i+1)+","+state.mon_vols[i]+","+state.mon_tmps[i]+","+state.mon_ress[i]+")";
|
}
|
SQLiteDatabase db = dbHelper.getWritableDatabase();
|
//Log.e(TAG, "insertBattResDataID: "+sql_str_start+sql_str_base );
|
try {
|
db.execSQL(sql_str_start+sql_str_base);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally{
|
// if(db != null){
|
// db.close();
|
// }
|
}
|
}
|
|
/**
|
* 插入内阻数据进入inf表
|
* @param battgroupid
|
* @param state
|
* @param dbHelper
|
* @param test_record_count
|
*/
|
public static void insertBattResDataInf(int battgroupid, Concentrator_State state, DBHelper dbHelper, int test_record_count){
|
String sql_str = "INSERT INTO tb_battresdata_inf " +
|
"(BattGroupId,test_record_count,test_type,test_starttime,record_time,group_vol,test_curr) " +
|
"VALUES("
|
+ battgroupid+","
|
+ test_record_count+","
|
+ BattDataThread.TESTTYPE_RESTEST+",'"
|
+ Com.getDateTimeFormat(new Date(),Com.DTF_YMDhms)+"','"
|
+ Com.getDateTimeFormat(new Date(),Com.DTF_YMDhms)+"',"
|
+ state.getGroupvol()+ ","
|
+ state.getGroupcurr()+"" +
|
");";
|
SQLiteDatabase db = dbHelper.getWritableDatabase();
|
try {
|
//Log.d(TAG, "insertBattResDataInf: "+sql_str);
|
db.execSQL(sql_str);
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally{
|
// if(db != null){
|
// db.close();
|
// }
|
}
|
}
|
|
|
/**
|
* 查询数据库目前当前电池组的最大
|
* @param battgroupid
|
* @param dbHelper
|
* @return
|
*/
|
public static int queryMaxTestRecordCount(int battgroupid,DBHelper dbHelper){
|
int max_test_record_count = 1;
|
String sql_str = " SELECT max(test_record_count)as max_test_record_count FROM tb_battresdata_inf WHERE BattGroupId = " + battgroupid;
|
SQLiteDatabase db = dbHelper.getWritableDatabase();
|
try {
|
Cursor rs = db.rawQuery(sql_str,null);
|
if (rs.moveToNext()){
|
max_test_record_count = rs.getInt(rs.getColumnIndex("max_test_record_count"))+1;
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally{
|
// if(db != null){
|
// db.close();
|
// }
|
}
|
return max_test_record_count;
|
}
|
}
|
