| | |
| | | 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; |
| | |
| | | return list; |
| | | } |
| | | |
| | | |
| | | //设备实时数据显示(前100笔数据服务器的时间) |
| | | @Override |
| | | public List serchByInfo(Object obj) { |
| | | // TODO Auto-generated method stub |
| | | return null; |
| | | 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; |
| | | } |
| | | |
| | | } |