加入指定机房

81041

2020-01-06 dc4e90ff7d720a78dba3aa72d868b89f69eafff7

 Device_Manage/src/com/fgkj/dao/impl/Battalarm_data_historyImpl.java

@@ -1,174 +1,176 @@
package com.fgkj.dao.impl;



import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.ArrayList;

import java.util.List;



import com.fgkj.dao.AlarmDaoFactory;

import com.fgkj.dao.BaseDAO;

import com.fgkj.dao.CallBack;

import com.fgkj.dao.DAOHelper;

import com.fgkj.db.DBUtil;

import com.fgkj.dto.BattInf;

import com.fgkj.dto.Battalarm_data_history;

import com.fgkj.dto.Page;



public class Battalarm_data_historyImpl 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() {

      String sql="select  distinct(db_alarm.tb_battalarm_data_history.BattGroupId),db_alarm.tb_battalarm_data_history.num,alm_signal_id,db_alarm.tb_battalarm_data_history.monnum,alm_value,alm_level,alm_is_confirmed,alm_confirmed_time,alm_start_time,alm_end_time "

            + " ,FBSDeviceId,BattGroupName  "

            + " from db_alarm.tb_battalarm_data_history,db_battinf.tb_battinf"

            + " where db_alarm.tb_battalarm_data_history.battGroupId=db_battinf.tb_battinf.battGroupId  "

            + " order by db_alarm.tb_battalarm_data_history.BattGroupId asc,alm_start_time desc ";

      List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {

			
         @Override

         public List getResults(ResultSet rs) {

            List list=new ArrayList();

            try {

               while(rs.next()){

                  Battalarm_data_history adata_H = new Battalarm_data_history();

                  adata_H.setNum(rs.getInt("FBSDeviceId"));

                  adata_H.setBattGroupId(rs.getInt("battGroupId"));

                  adata_H.setAlm_signal_id(rs.getInt("alm_signal_id"));

                  adata_H.setMonNum(rs.getInt("monNum"));

                  adata_H.setAlm_value(rs.getFloat("alm_value"));

                  adata_H.setAlm_level(rs.getInt("alm_level"));

                  adata_H.setAlm_is_confirmed(rs.getInt("alm_is_confirmed"));

                  adata_H.setAlm_confirmed_time(rs.getTimestamp("alm_confirmed_time"));

                  adata_H.setAlm_start_time(rs.getTimestamp("alm_start_time"));

                  adata_H.setAlm_end_time(rs.getTimestamp("alm_end_time"));

                  adata_H.setNote(rs.getString("BattGroupName"));

                  list.add(adata_H);

               }

            } catch (SQLException e) {

               // TODO Auto-generated catch block

               e.printStackTrace();

            }

            return list;

         }

      });

      return list;

   }

   //查询所有的历史告警(分页)

   public List serchByInfo(Object obj) {

      Page page=(Page) obj;

      String sql="select  distinct(db_alarm.tb_battalarm_data_history.BattGroupId),db_alarm.tb_battalarm_data_history.num,alm_signal_id,db_alarm.tb_battalarm_data_history.monnum,alm_value,alm_level,alm_is_confirmed,alm_confirmed_time,alm_start_time,alm_end_time "

            + " ,FBSDeviceId,BattGroupName  "

            + " from db_alarm.tb_battalarm_data_history,db_battinf.tb_battinf"

            + " where db_alarm.tb_battalarm_data_history.battGroupId=db_battinf.tb_battinf.battGroupId  "

            + " order by db_alarm.tb_battalarm_data_history.BattGroupId asc,alm_start_time desc "

            + " limit ?,? ";

      List list=DAOHelper.executeQuery(sql, DBUtil.getConn(),  new Object[]{(page.getPageCurr()-1)*page.getPageSize(),page.getPageSize()}, new CallBack() {

			
         @Override

         public List getResults(ResultSet rs) {

            List list=new ArrayList();

            try {

               while(rs.next()){

                  Battalarm_data_history adata_H = new Battalarm_data_history();

                  adata_H.setNum(rs.getInt("FBSDeviceId"));

                  adata_H.setBattGroupId(rs.getInt("battGroupId"));

                  adata_H.setAlm_signal_id(rs.getInt("alm_signal_id"));

                  adata_H.setMonNum(rs.getInt("monNum"));

                  adata_H.setAlm_value(rs.getFloat("alm_value"));

                  adata_H.setAlm_level(rs.getInt("alm_level"));

                  adata_H.setAlm_is_confirmed(rs.getInt("alm_is_confirmed"));

                  adata_H.setAlm_confirmed_time(rs.getTimestamp("alm_confirmed_time"));

                  adata_H.setAlm_start_time(rs.getTimestamp("alm_start_time"));

                  adata_H.setAlm_end_time(rs.getTimestamp("alm_end_time"));

                  adata_H.setStationname(rs.getString("BattGroupName"));

                  adata_H.setNote(AlarmDaoFactory.getAlarmName(adata_H.getAlm_signal_id()));

                  list.add(adata_H);

               }

            } catch (SQLException e) {

               // TODO Auto-generated catch block

               e.printStackTrace();

            }

            return list;

         }

      });

      return list;

   }

    //根据电池组id查询

   @Override

   public List serchByCondition(Object obj) {

      BattInf binf=(BattInf) obj;

      String sql="select  distinct(db_alarm.tb_battalarm_data_history.BattGroupId),db_alarm.tb_battalarm_data_history.num,alm_signal_id,db_alarm.tb_battalarm_data_history.monnum,alm_value,alm_level,alm_is_confirmed,alm_confirmed_time,alm_start_time,alm_end_time "

            + " ,FBSDeviceId,BattGroupName "

            + " from db_alarm.tb_battalarm_data_history,db_battinf.tb_battinf  "

            + " where db_alarm.tb_battalarm_data_history.battGroupId=db_battinf.tb_battinf.battGroupId "

            + " and db_alarm.tb_battalarm_data_history.BattGroupId=? "

            + " order by db_alarm.tb_battalarm_data_history.BattGroupId asc,alm_start_time desc ";

      List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{binf.getBattGroupId()}, new CallBack() {

			
         @Override

         public List getResults(ResultSet rs) {

            List list=new ArrayList();

            try {

               while(rs.next()){

                  Battalarm_data_history adata_H = new Battalarm_data_history();

                  adata_H.setNum(rs.getInt("FBSDeviceId"));

                  adata_H.setBattGroupId(rs.getInt("battGroupId"));

                  adata_H.setAlm_signal_id(rs.getInt("alm_signal_id"));

                  adata_H.setMonNum(rs.getInt("monNum"));

                  adata_H.setAlm_value(rs.getFloat("alm_value"));

                  adata_H.setAlm_level(rs.getInt("alm_level"));

                  adata_H.setAlm_is_confirmed(rs.getInt("alm_is_confirmed"));

                  adata_H.setAlm_confirmed_time(rs.getTimestamp("alm_confirmed_time"));

                  adata_H.setAlm_start_time(rs.getTimestamp("alm_start_time"));

                  adata_H.setAlm_end_time(rs.getTimestamp("alm_end_time"));

                  adata_H.setNote(rs.getString("BattGroupName"));

                  list.add(adata_H);

               }

            } catch (SQLException e) {

               // TODO Auto-generated catch block

               e.printStackTrace();

            }

            return list;

         }

      });

      return list;

   }



	
   
   public static void main(String[] args) {

      Battalarm_data_historyImpl bimpl=new Battalarm_data_historyImpl();

      //List<Battalarm_data_history> list=bimpl.searchAll();

      Page p=new Page();

      p.setPageCurr(1);

      p.setPageSize(6);

      List<Battalarm_data_history> list=bimpl.serchByInfo(p);

      for (Battalarm_data_history b : list) {

         System.out.println(b);

      }

   }

}

package com.fgkj.dao.impl;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import com.fgkj.dao.AlarmDaoFactory;
import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.CallBack;
import com.fgkj.dao.DAOHelper;
import com.fgkj.db.DBUtil;
import com.fgkj.dto.BattInf;
import com.fgkj.dto.Battalarm_data_history;
import com.fgkj.dto.Page;

public class Battalarm_data_historyImpl 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() {
      String sql="select  distinct(db_alarm.tb_battalarm_data_history.BattGroupId),db_alarm.tb_battalarm_data_history.num,alm_signal_id,db_alarm.tb_battalarm_data_history.monnum,alm_value,alm_level,alm_is_confirmed,alm_confirmed_time,alm_start_time,alm_end_time "
            + " ,FBSDeviceId,BattGroupName  "
            + " from db_alarm.tb_battalarm_data_history,db_battinf.tb_battinf"
            + " where db_alarm.tb_battalarm_data_history.battGroupId=db_battinf.tb_battinf.battGroupId  "
            + " order by db_alarm.tb_battalarm_data_history.BattGroupId asc,alm_start_time desc ";
      List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
			
         @Override
         public List getResults(ResultSet rs) {
            List list=new ArrayList();
            try {
               while(rs.next()){
                  Battalarm_data_history adata_H = new Battalarm_data_history();
                  adata_H.setNum(rs.getInt("FBSDeviceId"));
                  adata_H.setBattGroupId(rs.getInt("battGroupId"));
                  adata_H.setAlm_signal_id(rs.getInt("alm_signal_id"));
                  adata_H.setMonNum(rs.getInt("monNum"));
                  adata_H.setAlm_value(rs.getFloat("alm_value"));
                  adata_H.setAlm_level(rs.getInt("alm_level"));
                  adata_H.setAlm_is_confirmed(rs.getInt("alm_is_confirmed"));
                  adata_H.setAlm_confirmed_time(rs.getTimestamp("alm_confirmed_time"));
                  adata_H.setAlm_start_time(rs.getTimestamp("alm_start_time"));
                  adata_H.setAlm_end_time(rs.getTimestamp("alm_end_time"));
                  adata_H.setNote(rs.getString("BattGroupName"));
                  list.add(adata_H);
               }
            } catch (SQLException e) {
               // TODO Auto-generated catch block
               e.printStackTrace();
            }
            return list;
         }
      });
      return list;
   }
   //查询所有的历史告警(分页)
   public List serchByInfo(Object obj) {
      BattInf binf=(BattInf) obj;
      Page page=binf.getPage();
      String sql="select  distinct(db_alarm.tb_battalarm_data_history.BattGroupId),db_alarm.tb_battalarm_data_history.num,alm_signal_id,db_alarm.tb_battalarm_data_history.monnum,alm_value,alm_level,alm_is_confirmed,alm_confirmed_time,alm_start_time,alm_end_time "
            + " ,FBSDeviceId,BattGroupName  "
            + " from db_alarm.tb_battalarm_data_history,db_battinf.tb_battinf"
            + " where db_alarm.tb_battalarm_data_history.battGroupId=db_battinf.tb_battinf.battGroupId  "
            + " and db_battinf.tb_battinf.FBSDeviceId=? "
            + " order by db_alarm.tb_battalarm_data_history.BattGroupId asc,alm_start_time desc "
            + " limit ?,? ";
      List list=DAOHelper.executeQuery(sql, DBUtil.getConn(),  new Object[]{binf.getFBSDeviceId(),(page.getPageCurr()-1)*page.getPageSize(),page.getPageSize()}, new CallBack() {
			
         @Override
         public List getResults(ResultSet rs) {
            List list=new ArrayList();
            try {
               while(rs.next()){
                  Battalarm_data_history adata_H = new Battalarm_data_history();
                  adata_H.setNum(rs.getInt("FBSDeviceId"));
                  adata_H.setBattGroupId(rs.getInt("battGroupId"));
                  adata_H.setAlm_signal_id(rs.getInt("alm_signal_id"));
                  adata_H.setMonNum(rs.getInt("monNum"));
                  adata_H.setAlm_value(rs.getFloat("alm_value"));
                  adata_H.setAlm_level(rs.getInt("alm_level"));
                  adata_H.setAlm_is_confirmed(rs.getInt("alm_is_confirmed"));
                  adata_H.setAlm_confirmed_time(rs.getTimestamp("alm_confirmed_time"));
                  adata_H.setAlm_start_time(rs.getTimestamp("alm_start_time"));
                  adata_H.setAlm_end_time(rs.getTimestamp("alm_end_time"));
                  adata_H.setStationname(rs.getString("BattGroupName"));
                  adata_H.setNote(AlarmDaoFactory.getAlarmName(adata_H.getAlm_signal_id()));
                  list.add(adata_H);
               }
            } catch (SQLException e) {
               // TODO Auto-generated catch block
               e.printStackTrace();
            }
            return list;
         }
      });
      return list;
   }
    //根据电池组id查询
   @Override
   public List serchByCondition(Object obj) {
      BattInf binf=(BattInf) obj;
      String sql="select  distinct(db_alarm.tb_battalarm_data_history.BattGroupId),db_alarm.tb_battalarm_data_history.num,alm_signal_id,db_alarm.tb_battalarm_data_history.monnum,alm_value,alm_level,alm_is_confirmed,alm_confirmed_time,alm_start_time,alm_end_time "
            + " ,FBSDeviceId,BattGroupName "
            + " from db_alarm.tb_battalarm_data_history,db_battinf.tb_battinf  "
            + " where db_alarm.tb_battalarm_data_history.battGroupId=db_battinf.tb_battinf.battGroupId "
            + " and db_alarm.tb_battalarm_data_history.BattGroupId=? "
            + " order by db_alarm.tb_battalarm_data_history.BattGroupId asc,alm_start_time desc ";
      List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{binf.getBattGroupId()}, new CallBack() {
			
         @Override
         public List getResults(ResultSet rs) {
            List list=new ArrayList();
            try {
               while(rs.next()){
                  Battalarm_data_history adata_H = new Battalarm_data_history();
                  adata_H.setNum(rs.getInt("FBSDeviceId"));
                  adata_H.setBattGroupId(rs.getInt("battGroupId"));
                  adata_H.setAlm_signal_id(rs.getInt("alm_signal_id"));
                  adata_H.setMonNum(rs.getInt("monNum"));
                  adata_H.setAlm_value(rs.getFloat("alm_value"));
                  adata_H.setAlm_level(rs.getInt("alm_level"));
                  adata_H.setAlm_is_confirmed(rs.getInt("alm_is_confirmed"));
                  adata_H.setAlm_confirmed_time(rs.getTimestamp("alm_confirmed_time"));
                  adata_H.setAlm_start_time(rs.getTimestamp("alm_start_time"));
                  adata_H.setAlm_end_time(rs.getTimestamp("alm_end_time"));
                  adata_H.setNote(rs.getString("BattGroupName"));
                  list.add(adata_H);
               }
            } catch (SQLException e) {
               // TODO Auto-generated catch block
               e.printStackTrace();
            }
            return list;
         }
      });
      return list;
   }

	
   
   public static void main(String[] args) {
      Battalarm_data_historyImpl bimpl=new Battalarm_data_historyImpl();
      //List<Battalarm_data_history> list=bimpl.searchAll();
      Page p=new Page();
      p.setPageCurr(1);
      p.setPageSize(6);
      List<Battalarm_data_history> list=bimpl.serchByInfo(p);
      for (Battalarm_data_history b : list) {
         System.out.println(b);
      }
   }
}