package com.fgkj.dao.impl;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.text.ParseException;
|
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.db.IDatabaseName;
|
import com.fgkj.dto.BattInf;
|
import com.fgkj.dto.Battresdata;
|
import com.fgkj.dto.Batttestdatastop;
|
|
public class BattresdataDAOImpl implements BaseDAO, CallBack {
|
|
public List getResults(ResultSet rs) {
|
List list = new ArrayList();
|
try {
|
while (rs.next()) {
|
Battresdata br = new Battresdata();
|
br.setNum(rs.getInt("num"));
|
br.setBattGroupId(rs.getInt("BattGroupId"));
|
br.setTest_record_count(rs.getInt("test_record_count"));
|
br.setTest_type(rs.getInt("test_type"));
|
br.setData_new(rs.getInt("data_new"));
|
br.setData_available(rs.getInt("data_available"));
|
br.setTest_starttime(rs.getTimestamp("test_starttime"));
|
br.setGroup_vol(rs.getFloat("group_vol"));
|
br.setTest_curr(rs.getFloat("test_curr"));
|
br.setMon_num(rs.getInt("mon_num"));
|
br.setMon_vol(rs.getFloat("mon_vol"));
|
br.setMon_tmp(rs.getFloat("mon_tmp"));
|
br.setMon_res(rs.getFloat("mon_res"));
|
br.setMon_ser(rs.getFloat("mon_ser"));
|
br.setConn_res(rs.getFloat("conn_res"));
|
list.add(br);
|
// System.out.println(b);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
return list;
|
}
|
|
public boolean add(Object obj) {
|
Battresdata btd = (Battresdata) obj;
|
String sql = "inset into db_batt_testdata.tb_battresdata_"
|
+ btd.getBattGroupId()
|
+ "(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(?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
|
Boolean bl = DAOHelper.executeUpdate(
|
DBUtil.getConn(),
|
sql,
|
new Object[] { btd.getBattGroupId(),
|
btd.getTest_record_count(), btd.getTest_type(),
|
btd.getData_new(), btd.getData_available(),
|
btd.getTest_starttime(), btd.getGroup_vol(),
|
btd.getTest_curr(), btd.getMon_num(), btd.getMon_vol(),
|
btd.getMon_tmp(), btd.getMon_res(), btd.getMon_ser(),
|
btd.getConn_res() });
|
return bl;
|
}
|
|
public boolean update(Object obj) {
|
Battresdata btd = (Battresdata) obj;
|
String sql = "update db_batt_testdata.tb_battresdata_"
|
+ btd.getBattGroupId()
|
+ "set 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=? where num=?";
|
Boolean bl = DAOHelper.executeUpdate(
|
DBUtil.getConn(),
|
sql,
|
new Object[] { btd.getBattGroupId(),
|
btd.getTest_record_count(), btd.getTest_type(),
|
btd.getData_new(), btd.getData_available(),
|
btd.getTest_starttime(), btd.getGroup_vol(),
|
btd.getTest_curr(), btd.getMon_num(), btd.getMon_vol(),
|
btd.getMon_tmp(), btd.getMon_res(), btd.getMon_ser(),
|
btd.getConn_res(), btd.getNum() });
|
return bl;
|
}
|
|
//6.1电池充放电管理删除操作
|
public boolean del(Object obj) {
|
Battresdata rdata = (Battresdata) obj;
|
String sql = "delete from db_batt_testdata.tb_battresdata_" + rdata.getBattGroupId()
|
+ " where battgroupid=? and test_record_count=? ";
|
Boolean bl = DAOHelper.executeUpdate(
|
DBUtil.getConn(), sql,
|
new Object[] { rdata.getBattGroupId(),rdata.getTest_record_count() });
|
return bl;
|
}
|
|
//电池充/放电数据管理删除
|
public String delPro(Object obj) {
|
Battresdata btd = (Battresdata) obj;
|
String sql = "delete from db_batt_testdata.tb_battresdata_" + btd.getBattGroupId()
|
+ " where test_record_count="+btd.getTest_record_count();
|
return sql;
|
}
|
public List searchAll(Object obj) {
|
Battresdata btd = (Battresdata) obj;
|
String sql = "select * from db_batt_testdata.tb_battresdata_" + btd.getBattGroupId()
|
+ "";
|
List list = DAOHelper.executeQuery(sql,
|
DBUtil.getConn(), null,
|
new BattresdataDAOImpl());
|
return list;
|
}
|
|
public List serchByCondition(Object obj) {
|
Battresdata btd = (Battresdata) obj;
|
String sql = "select num,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 from db_batt_testdata.tb_battresdata_"
|
+ btd.getBattGroupId() + "" + " where test_record_count=?";
|
return DAOHelper.executeQuery(sql,
|
DBUtil.getConn(),
|
new Object[] { btd.getTest_record_count() },
|
new BattresdataDAOImpl());
|
|
}
|
//根据电池组id和单体id查询内阻历史信息
|
public List serchByMonHistory(Object obj){
|
BattInf binf=(BattInf) obj;
|
String sql="select num,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 " +
|
" from db_batt_testdata.tb_battresdata_"+ binf.getBattGroupId() + " "
|
+ " where mon_num=?";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(),new Object[]{binf.getMonNum()}, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list = new ArrayList();
|
try {
|
while (rs.next()) {
|
Battresdata br = new Battresdata();
|
br.setNum(rs.getInt("num"));
|
br.setBattGroupId(rs.getInt("BattGroupId"));
|
br.setTest_record_count(rs.getInt("test_record_count"));
|
br.setTest_type(rs.getInt("test_type"));
|
br.setData_new(rs.getInt("data_new"));
|
br.setData_available(rs.getInt("data_available"));
|
br.setTest_starttime(rs.getTimestamp("test_starttime"));
|
br.setGroup_vol(rs.getFloat("group_vol"));
|
br.setTest_curr(rs.getFloat("test_curr"));
|
br.setMon_num(rs.getInt("mon_num"));
|
br.setMon_vol(rs.getFloat("mon_vol"));
|
br.setMon_tmp(rs.getFloat("mon_tmp"));
|
br.setMon_res(rs.getFloat("mon_res"));
|
br.setMon_ser(rs.getFloat("mon_ser"));
|
br.setConn_res(rs.getFloat("conn_res"));
|
list.add(br);
|
// System.out.println(b);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
|
return list;
|
}
|
|
//得到电阻/内阻测试信息
|
public List serchByMonNum(Object obj) {
|
Battresdata btd = (Battresdata) obj;
|
String sql=null;
|
if(btd.getMon_num()==0){
|
sql = "select num,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 from db_batt_testdata.tb_battresdata_"
|
+ btd.getBattGroupId() + "" + " where battgroupid=? and mon_num!=?";
|
}else{
|
sql = "select num,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 from db_batt_testdata.tb_battresdata_"
|
+ btd.getBattGroupId() + "" + " where battgroupid=? and mon_num=?";
|
}
|
return DAOHelper.executeQuery(sql,
|
DBUtil.getConn(),
|
new Object[] { btd.getBattGroupId(),btd.getMon_num() },
|
new BattresdataDAOImpl());
|
|
}
|
|
//1.3求电导平均值
|
public List serchByInfo(Object obj) {
|
Battresdata btd = (Battresdata) obj;
|
//System.out.println(btd);
|
String sql = "select avg(mon_ser) as mon_avg from db_batt_testdata.tb_battresdata_"
|
+ btd.getBattGroupId()+ " where battgroupid=? and test_record_count=?";
|
|
return DAOHelper.executeQuery(sql,
|
DBUtil.getConn(),
|
new Object[] { btd.getBattGroupId(),btd.getTest_record_count() },
|
new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Battresdata br = new Battresdata();
|
br.setMon_avg(rs.getFloat("mon_avg"));
|
list.add(br);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
}
|
|
|
|
//截止平均电压值
|
public List serch(Object obj){
|
Battresdata btd=(Battresdata)obj;
|
// System.out.println(btd.getBattGroupId()+" "+btd.getLowC());
|
String sql="select avg(binary mon_vol) as mon_avg from db_batt_testdata.tb_battresdata_"+btd.getBattGroupId()+" where test_record_count=? order by battgroupid";
|
//System.out.println(sql);
|
return DAOHelper.executeQuery(sql, DBUtil.getConn(),new Object[]{btd.getTest_record_count()}, new CallBack() {
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Battresdata bs=new Battresdata();
|
bs.setMon_avg(rs.getFloat("mon_avg"));
|
list.add(bs);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
}
|
|
//最低单体电压和编号
|
public List serchNum(Object obj){
|
Battresdata btd=(Battresdata)obj;
|
// System.out.println(btd.getBattGroupId()+" "+btd.getLowC());
|
String sql="select distinct(mon_num),mon_vol from db_batt_testdata.tb_battresdata_"+btd.getBattGroupId()+" where mon_vol=(select min(mon_vol) from db_batt_testdata.tb_battresdata_"+btd.getBattGroupId()+" where test_record_count=? ) ";
|
//System.out.println(sql);
|
return DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{btd.getTest_record_count()}, new CallBack() {
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Battresdata bs=new Battresdata();
|
bs.setMon_num(rs.getInt("mon_num"));
|
bs.setMon_vol(rs.getFloat("mon_vol"));
|
list.add(bs);
|
//System.out.println(b);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
}
|
|
//6.4.3根据条件查询符合条件的测试完成的电池组(蓄电池电导合格率)
|
public List serchSer(Object obj){
|
Battresdata rdata=(Battresdata)obj;
|
String sql="select mon_num from db_batt_testdata.tb_battresdata_"+rdata.getBattGroupId()+" where test_starttime=? and test_record_count=? and mon_ser>=?";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{rdata.getTest_starttime(),rdata.getTest_record_count(),rdata.getMon_ser()}, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Battresdata rdata=new Battresdata();
|
rdata.setMon_num(rs.getInt("mon_num"));
|
list.add(rdata);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
public static void main(String[] args) {
|
BattresdataDAOImpl bstd = new BattresdataDAOImpl();
|
Battresdata bst = new Battresdata();
|
bst.setBattGroupId(1001795);
|
/* bst.setTest_record_count(2); */
|
/*
|
* List<Battresdata> list=bstd.serchByCondition(bst); for(Battresdata
|
* b:list){ System.out.println(b); }
|
*/
|
//List<Battresdata> list = bstd.searchAll(bst);
|
BattInf binf=new BattInf();
|
binf.setBattGroupId(100000);
|
binf.setMonNum(1);
|
List<Battresdata> list = bstd.serchByMonHistory(binf);
|
for (Battresdata b : list) {
|
System.out.println(b);
|
}
|
}
|
|
public List searchAll() {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
|
}
|
