package com.fgkj.dao.impl;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
import com.fgkj.actions.ActionUtil;
|
import com.fgkj.dao.BaseDAO;
|
import com.fgkj.dao.CallBack;
|
import com.fgkj.dao.DAOHelper;
|
import com.fgkj.db.DBUtil;
|
import com.fgkj.dto.Batt_history;
|
import com.opensymphony.xwork2.Action;
|
|
public class Batt_historyImpl implements BaseDAO,CallBack{
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Batt_history batt_his=new Batt_history();
|
batt_his.setNum(rs.getInt("num"));
|
batt_his.setDev_id(rs.getInt("dev_id"));
|
batt_his.setBattGroupId(rs.getInt("battGroupId"));
|
batt_his.setBatt_count(rs.getInt("batt_count"));
|
batt_his.setBatt_state(rs.getInt("batt_state"));
|
batt_his.setRec_datetime(rs.getTimestamp("rec_datetime"));
|
batt_his.setOnline_vol(rs.getFloat("online_vol"));
|
batt_his.setGroup_vol(rs.getFloat("group_vol"));
|
batt_his.setGroup_tmp(rs.getFloat("group_tmp"));
|
batt_his.setGroup_curr(rs.getFloat("group_curr"));
|
batt_his.setMon_vols(rs.getString("mon_vols"));
|
batt_his.setMon_tmps(rs.getString("mon_tmps"));
|
batt_his.setMon_ress(rs.getString("mon_ress"));
|
batt_his.setMon_sers(rs.getString("mon_sers"));
|
batt_his.setMon_conn_ress(rs.getString("mon_conn_ress"));
|
batt_his.setMon_caps(rs.getString("mon_caps"));
|
batt_his.setNote(rs.getString("note"));
|
list.add(batt_his);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
|
public boolean add(Object obj) {
|
// TODO Auto-generated method stub
|
return false;
|
}
|
|
public boolean update(Object obj) {
|
// TODO Auto-generated method stub
|
return false;
|
}
|
|
public boolean del(Object obj) {
|
// TODO Auto-generated method stub
|
return false;
|
}
|
|
public List searchAll() {
|
String sql="select distinct(num),dev_id,battgroupid,batt_count,batt_state,rec_datetime" +
|
",online_vol,group_vol,group_tmp,group_curr,mon_vols,mon_tmps,mon_ress,mon_sers" +
|
",mon_conn_ress,mon_caps,note " +
|
" from db_batt_history.tb_batt_91000001_2017_12 " +
|
" order by rec_datetime asc";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Batt_history batt_his=new Batt_history();
|
batt_his.setNum(rs.getInt("num"));
|
batt_his.setDev_id(rs.getInt("dev_id"));
|
batt_his.setBattGroupId(rs.getInt("battGroupId"));
|
batt_his.setBatt_count(rs.getInt("batt_count"));
|
batt_his.setBatt_state(rs.getInt("batt_state"));
|
batt_his.setRec_datetime(rs.getTimestamp("rec_datetime"));
|
batt_his.setOnline_vol(rs.getFloat("online_vol"));
|
batt_his.setGroup_vol(rs.getFloat("group_vol"));
|
batt_his.setGroup_tmp(rs.getFloat("group_tmp"));
|
batt_his.setGroup_curr(rs.getFloat("group_curr"));
|
batt_his.setMon_vols(rs.getString("mon_vols"));
|
batt_his.setMon_tmps(rs.getString("mon_tmps"));
|
batt_his.setMon_ress(rs.getString("mon_ress"));
|
batt_his.setMon_sers(rs.getString("mon_sers"));
|
batt_his.setMon_conn_ress(rs.getString("mon_conn_ress"));
|
batt_his.setMon_caps(rs.getString("mon_caps"));
|
batt_his.setNote(rs.getString("note"));
|
list.add(batt_his);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
//查询所有的历史实时数据
|
public List serchByCondition(Object obj) {
|
Batt_history batt_his=(Batt_history) obj;
|
int year=ActionUtil.getDateYear(batt_his.getRec_datetime());
|
int month=ActionUtil.getDateMonth(batt_his.getRec_datetime());
|
String sql="";
|
String baseSql="select distinct(num),dev_id,battgroupid,batt_count,batt_state,rec_datetime" +
|
",online_vol,group_vol,group_tmp,group_curr,mon_vols,mon_tmps,mon_ress,mon_sers" +
|
",mon_conn_ress,mon_caps,note " +
|
" from db_batt_history.tb_batt_"+batt_his.getDev_id()+"_"+year+"_"+month+
|
" where battgroupid=? ";
|
//时间条件选择
|
String timeSql=" and rec_datetime>=? and rec_datetime<=? ";
|
//按照时间排序
|
String orderSql=" order by rec_datetime asc";
|
sql=baseSql+timeSql+orderSql;
|
//System.out.println(sql);
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{batt_his.getBattGroupId(),batt_his.getRec_datetime(),batt_his.getRec_datetime1()}, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Batt_history batt_his=new Batt_history();
|
batt_his.setNum(rs.getInt("num"));
|
batt_his.setDev_id(rs.getInt("dev_id"));
|
batt_his.setBattGroupId(rs.getInt("battGroupId"));
|
batt_his.setBatt_count(rs.getInt("batt_count"));
|
batt_his.setBatt_state(rs.getInt("batt_state"));
|
batt_his.setRec_datetime(rs.getTimestamp("rec_datetime"));
|
batt_his.setOnline_vol(rs.getFloat("online_vol"));
|
batt_his.setGroup_vol(rs.getFloat("group_vol"));
|
batt_his.setGroup_tmp(rs.getFloat("group_tmp"));
|
batt_his.setGroup_curr(rs.getFloat("group_curr"));
|
batt_his.setMon_vols(rs.getString("mon_vols"));
|
batt_his.setMon_tmps(rs.getString("mon_tmps"));
|
batt_his.setMon_ress(rs.getString("mon_ress"));
|
batt_his.setMon_sers(rs.getString("mon_sers"));
|
batt_his.setMon_conn_ress(rs.getString("mon_conn_ress"));
|
batt_his.setMon_caps(rs.getString("mon_caps"));
|
batt_his.setNote(rs.getString("note"));
|
list.add(batt_his);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
public List serchByInfo(Object obj) {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
|
}
|
