package com.fgkj.dao.impl;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
import com.fgkj.dao.BaseDAO;
|
import com.fgkj.dao.CallBack;
|
import com.fgkj.dao.DAOHelper;
|
import com.fgkj.db.DBUtil;
|
import com.fgkj.dto.BattInf;
|
import com.fgkj.dto.Batttestdata_inf;
|
|
public class Batttestdata_infImpl implements BaseDAO,CallBack{
|
|
@Override
|
public List getResults(ResultSet rs) {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
|
@Override
|
public boolean add(Object obj) {
|
// TODO Auto-generated method stub
|
return false;
|
}
|
|
@Override
|
public boolean update(Object obj) {
|
// TODO Auto-generated method stub
|
return false;
|
}
|
|
@Override
|
public boolean del(Object obj) {
|
// TODO Auto-generated method stub
|
return false;
|
}
|
@Override
|
public List searchAll() {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
//根据电池组id查询充放电数据
|
@Override
|
public List serchByCondition(Object obj) {
|
BattInf binf=(BattInf) obj;
|
String sql=" select * from db_batt_testdata.tb_batttestdata_inf where BattGroupId=? ";
|
//判断是充电还是放电
|
String chargeSqlT=" and test_type!=? ";
|
String chargeSqlF=" and test_type=?";
|
if(binf.getNum()==0){
|
sql+=chargeSqlT;
|
}else{
|
sql+=chargeSqlF;
|
}
|
String endsql="order by record_time desc";
|
sql+=endsql;
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{binf.getBattGroupId(),binf.getNum()}, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Batttestdata_inf tinf=new Batttestdata_inf();
|
tinf.setBattGroupId(rs.getInt("battGroupId"));
|
tinf.setTest_record_count(rs.getInt("test_record_count"));
|
tinf.setTest_type(rs.getInt("test_type"));
|
tinf.setRecord_time_interval(rs.getInt("record_time_interval"));
|
tinf.setRecord_num(rs.getInt("record_num"));
|
tinf.setTest_starttime(rs.getTimestamp("test_starttime"));
|
tinf.setTest_starttype(rs.getInt("test_starttype"));
|
tinf.setRecord_time(rs.getTimestamp("record_time"));
|
tinf.setTest_timelong(rs.getInt("test_timelong"));
|
tinf.setTest_stoptype(rs.getInt("test_stoptype"));
|
tinf.setGroup_vol(rs.getFloat("group_vol"));
|
tinf.setTest_curr(rs.getFloat("test_curr"));
|
tinf.setTest_cap(rs.getFloat("test_cap"));
|
tinf.setMax_monnum(rs.getInt("max_monnum"));
|
tinf.setMin_monnum(rs.getInt("min_monnum"));
|
tinf.setMax_monvol(rs.getFloat("max_monvol"));
|
tinf.setMin_monvol(rs.getFloat("min_monvol"));
|
list.add(tinf);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
@Override
|
public List serchByInfo(Object obj) {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
|
}
|
