whyclxw
2020-11-02 f8b7ca9bc6b51c137053f16c1c7150a11aba13c4
DyEnvir_system/src/com/fgkj/partinsystem/impl/Dc25v_battImpl.java
@@ -3,6 +3,7 @@
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;
@@ -82,11 +83,84 @@
      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;
   }
}