| | |
| | | inserTestDataToDB(sql, m_batt_rt.mTestData.test_stoptype);
|
| | | }*/
|
| | | }
|
| | | /**
|
| | | * 清理数据
|
| | | */
|
| | | clearDisTestDataEndData(m_Conn_Pool,m_batt_rt.BattGroupId,m_batt_rt.mTestData.testRecordCount);
|
| | |
|
| | |
|
| | | if(m_batt_rt.mTestData.testTimeLong < m_batt_rt.mTestTimeLongMin) {
|
| | |
| | | sql.mysql_con.setAutoCommit(true);
|
| | | }
|
| | | }
|
| | | |
| | | /**
|
| | | * 清理数据
|
| | | */
|
| | | clearDisTestDataEndData(m_Conn_Pool,m_batt_rt.BattGroupId,m_batt_rt.mTestData.testRecordCount);
|
| | | }
|
| | | } catch (SQLException e) {
|
| | | sql.logger.error(e.toString(), e);
|
| | |
| | | //1.判断当前这一笔数据是否是放电数据=>结果可分析出平均电流
|
| | | BattStatData battStatData = queryTestDataInf(pool,BattGroupId,testRecordCount);
|
| | | if(battStatData.battTestType_For_DataSave == BattStatData.BATTSTATE_DISCHARGE && battStatData.testTimeLong > 0) {
|
| | | System.out.println("testCap:"+battStatData.testCap+"\ttestTimeLong:"+battStatData.testTimeLong);
|
| | | //System.out.println("testCap:"+battStatData.testCap+"\ttestTimeLong:"+battStatData.testTimeLong);
|
| | | float avg_curr = (float)Math.abs(battStatData.testCap*3600/(battStatData.testTimeLong))*0.8f;
|
| | | System.out.println("AvgCurr:" + avg_curr + "总记录数:" + battStatData.recordNum);
|
| | | //System.out.println("AvgCurr:" + avg_curr + "总记录数:" + battStatData.recordNum);
|
| | | //2.查询放电过程中最后一笔测试电流 绝对值>[平均电流*0.8],的位置=>record_num
|
| | | int max_record_num = queryMaxTestRecordNum(pool,BattGroupId,testRecordCount,avg_curr);
|
| | | System.out.println("需要删除的起始record_num:" + max_record_num);
|
| | | //System.out.println("需要删除的起始record_num:" + max_record_num);
|
| | | //3.删除记录中 > record_num 的数据结束
|
| | | if(max_record_num < battStatData.recordNum) {
|
| | | if(max_record_num <= battStatData.recordNum) {
|
| | | deleteData(pool,BattGroupId, testRecordCount,max_record_num);
|
| | | //4.同步 tb_batt_testdata_inf 和 tb_batt_testdata_id中的record_num
|
| | | synchTestDataRecordNum(pool, BattGroupId, testRecordCount, max_record_num);
|
| | |
| | | Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
| | | try {
|
| | | al_str.add(sql_str_ins);
|
| | | //al_str.add(sql_str_del);
|
| | | al_str.add(sql_str_del);
|
| | | sql.mysql_con.setAutoCommit(false);
|
| | | for(int n=0; n<al_str.size(); n++) {
|
| | | sql.sqlMysqlExecute(al_str.get(n));
|
| | | }
|
| | | sql.mysql_con.commit();
|
| | | System.out.println("清除成功。。。");
|
| | | sql.sqlMysqlExecute(sql_str_del);
|
| | | //System.out.println("清除成功。。。");
|
| | | //sql.sqlMysqlExecute(sql_str_del);
|
| | | } catch (SQLException e) {
|
| | | try {
|
| | | sql.mysql_con.rollback();
|