package com.fgkj.partinsystem.impl;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.ArrayList;
|
import java.util.Date;
|
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.partinsystem.dto.Dc230v_batt;
|
import com.fgkj.partinsystem.dto.Dc25v_batt;
|
|
public class Dc25v_battImpl 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查询设备的实时信息
|
public List serchByCondition(Object obj) {
|
Dc25v_batt dc=(Dc25v_batt) obj;
|
String sql=" select * from db_partinsystem.dc25v_batt where dev_id=? ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{dc.getDev_id()}, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Dc25v_batt d=new Dc25v_batt();
|
d.setDev_id(rs.getInt("dev_id"));
|
d.setRecord_time(rs.getTimestamp("record_time"));
|
d.setOutput_vol(rs.getFloat("output_vol"));
|
d.setOutput_curr(rs.getFloat("output_curr"));
|
d.setInput_vol(rs.getFloat("input_vol"));
|
d.setInput_curr(rs.getFloat("input_curr"));
|
d.setWork_state(rs.getInt("work_state"));
|
d.setUnder_vol_alarm(rs.getInt("under_vol_alarm"));
|
d.setOver_vol_alarm(rs.getInt("over_vol_alarm"));
|
d.setOver_load_alarm(rs.getInt("over_load_alarm"));
|
d.setOver_tmp_alarm(rs.getInt("over_tmp_alarm"));
|
d.setShort_out_alarm(rs.getInt("short_out_alarm"));
|
|
|
list.add(d);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
//设备实时数据显示（前100笔数据服务器的时间）
|
@Override
|
public List serchByInfo(Object obj) {
|
Dc25v_batt dc=(Dc25v_batt) obj;
|
Date date=new Date();
|
String table=DAOHelper.sdf_withOut.format(date);
|
String sql=" select * from db_partinsystem_history.dc25v_batt_"+dc.getDev_id()+"_"+table+" where dev_id=? ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{dc.getDev_id()}, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Dc25v_batt d=new Dc25v_batt();
|
d.setDev_id(rs.getInt("dev_id"));
|
d.setRecord_time(rs.getTimestamp("record_time"));
|
d.setOutput_vol(rs.getFloat("output_vol"));
|
d.setOutput_curr(rs.getFloat("output_curr"));
|
d.setInput_vol(rs.getFloat("input_vol"));
|
d.setInput_curr(rs.getFloat("input_curr"));
|
d.setWork_state(rs.getInt("work_state"));
|
d.setUnder_vol_alarm(rs.getInt("under_vol_alarm"));
|
d.setOver_vol_alarm(rs.getInt("over_vol_alarm"));
|
d.setOver_load_alarm(rs.getInt("over_load_alarm"));
|
d.setOver_tmp_alarm(rs.getInt("over_tmp_alarm"));
|
d.setShort_out_alarm(rs.getInt("short_out_alarm"));
|
|
|
list.add(d);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
//设备历史数据查询
|
public List serchHistory(Object obj) {
|
Dc25v_batt dc=(Dc25v_batt) obj;
|
String table=DAOHelper.sdf_withOut.format(dc.getRecord_time());
|
String sql=" select * from db_partinsystem_history.dc25v_batt_"+dc.getDev_id()+"_"+table+" "
|
+ " where dev_id=? and record_time >= ? and record_time <= ? order by record_time asc ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{dc.getDev_id(),dc.getRecord_time(),dc.getRecord_time1()}, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Dc25v_batt d=new Dc25v_batt();
|
d.setDev_id(rs.getInt("dev_id"));
|
d.setRecord_time(rs.getTimestamp("record_time"));
|
d.setOutput_vol(rs.getFloat("output_vol"));
|
d.setOutput_curr(rs.getFloat("output_curr"));
|
d.setInput_vol(rs.getFloat("input_vol"));
|
d.setInput_curr(rs.getFloat("input_curr"));
|
d.setWork_state(rs.getInt("work_state"));
|
d.setUnder_vol_alarm(rs.getInt("under_vol_alarm"));
|
d.setOver_vol_alarm(rs.getInt("over_vol_alarm"));
|
d.setOver_load_alarm(rs.getInt("over_load_alarm"));
|
d.setOver_tmp_alarm(rs.getInt("over_tmp_alarm"));
|
d.setShort_out_alarm(rs.getInt("short_out_alarm"));
|
|
|
list.add(d);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
}
|
