修改

81041

2020-01-02 444e8b94737097acf75a89b8f06451d8d8af69c3

修改

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

@@ -1,193 +1,193 @@
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;

import com.fgkj.dto.Page;



public class Battalarm_dataImpl 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.battgroupid,alm_start_time"

                + "  ,FBSDeviceId,BattGroupName "

                + "  from db_alarm.tb_battalarm_data,db_battinf.tb_battinf "

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

                + "  order by alm_start_time desc ";

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

			
            @Override

            public List getResults(ResultSet rs) {

                // TODO Auto-generated method stub

                List list=new ArrayList();

                try {

                    while(rs.next()){

                        Battalarm_data adata=new Battalarm_data();

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

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

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

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

                        list.add(adata);

                    }

                } catch (SQLException e) {

                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

                return list;

            }

        });

        return list;

    }

    //查询实时告警（分页）

        @Override

    public List serchByInfo(Object obj) {

        Page page=(Page) obj;

        String sql=" select distinct db_alarm.tb_battalarm_data.battgroupid,alm_start_time,alm_id,db_alarm.tb_battalarm_data.monnum,alm_signal_id,alm_level  "

                + "  ,FBSDeviceId,BattGroupName "

                + "  from db_alarm.tb_battalarm_data,db_battinf.tb_battinf "

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

                + "  order by db_alarm.tb_battalarm_data.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) {

                // TODO Auto-generated method stub

                List list=new ArrayList();

                try {

                    while(rs.next()){

                        Battalarm_data adata=new Battalarm_data();

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

                        adata.setAlm_id(rs.getInt("alm_id"));

                        adata.setMonNum(rs.getInt("monnum"));

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

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

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

                        adata.setBattGroupName(rs.getString("BattGroupName"));

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

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

                        list.add(adata);

                    }

                } 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 num,battGroupId,MonNum,Record_Id,alm_id,alm_signal_id,alm_value,alm_level,alm_is_confirmed,alm_confirmed_time,alm_start_time,alm_end_time  from  db_alarm.tb_battalarm_data  where battGroupId=?  order by alm_start_timedesc";

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

			
            @Override

            public List getResults(ResultSet rs) {

                // TODO Auto-generated method stub

                List list=new ArrayList();

                try {

                    while(rs.next()){

                        Battalarm_data adata=new Battalarm_data();

                        adata.setNum(rs.getInt("num"));

                        adata.setBattGroupId(rs.getInt("BattGroupId"));

                        adata.setMonNum(rs.getInt("MonNum"));

                        adata.setRecord_Id(rs.getLong("Record_Id"));

                        adata.setMonNum(rs.getInt("alm_id"));

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

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

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

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

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

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

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

                        list.add(adata);

                    }

                } catch (SQLException e) {

                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

                return list;

            }

        });

        return list;

    }

    //查询实时告警的总数

    public List searchAlarmNum(){

        String sql=" select count(db_alarm.tb_battalarm_data.num) as number,db_alarm.tb_battalarm_data.battGroupId,alm_id,db_alarm.tb_battalarm_data.monnum  "

                + "  from db_alarm.tb_battalarm_data,db_battinf.tb_battinf "

                + "  where db_alarm.tb_battalarm_data.battGroupId=db_battinf.tb_battinf.battGroupId  ";

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

			
            @Override

            public List getResults(ResultSet rs) {

                // TODO Auto-generated method stub

                List list=new ArrayList();

                int number=0;

                try {

                    while(rs.next()){

                        number=rs.getInt("number");

                        list.add(number);

                    }

                } catch (SQLException e) {

                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

                return list;

            }

        });

        return list;

    }

	
    public static void main(String[] args) {

        Battalarm_dataImpl bimpl=new Battalarm_dataImpl();

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

        Page p=new Page();

        p.setPageCurr(1);

        p.setPageSize(6);

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

        for (Battalarm_data b : list) {

            System.out.println(b);

        }

        System.out.println(list.size());

        /*List<Integer> list=bimpl.searchAlarmNum();

        for (Integer number : list) {

            System.out.println(number);

        }*/

    }

}

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;
import com.fgkj.dto.Page;

public class Battalarm_dataImpl 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.battgroupid,alm_start_time"
                + "  ,FBSDeviceId,BattGroupName "
                + "  from db_alarm.tb_battalarm_data,db_battinf.tb_battinf "
                + "  where db_alarm.tb_battalarm_data.battGroupId=db_battinf.tb_battinf.battGroupId  "
                + "  order by alm_start_time desc ";
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
			
            @Override
            public List getResults(ResultSet rs) {
                // TODO Auto-generated method stub
                List list=new ArrayList();
                try {
                    while(rs.next()){
                        Battalarm_data adata=new Battalarm_data();
                        adata.setBattGroupId(rs.getInt("battGroupId"));
                        adata.setAlm_start_time(rs.getTimestamp("alm_start_time"));
                        adata.setNum(rs.getInt("FBSDeviceId"));
                        adata.setNote(rs.getString("BattGroupName"));
                        list.add(adata);
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return list;
            }
        });
        return list;
    }
    //查询实时告警（分页）
        @Override
    public List serchByInfo(Object obj) {
        Page page=(Page) obj;
        String sql=" select distinct db_alarm.tb_battalarm_data.battgroupid,alm_start_time,alm_id,db_alarm.tb_battalarm_data.monnum,alm_signal_id,alm_level  "
                + "  ,FBSDeviceId,BattGroupName "
                + "  from db_alarm.tb_battalarm_data,db_battinf.tb_battinf "
                + "  where db_alarm.tb_battalarm_data.battGroupId=db_battinf.tb_battinf.battGroupId  "
                + "  order by db_alarm.tb_battalarm_data.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) {
                // TODO Auto-generated method stub
                List list=new ArrayList();
                try {
                    while(rs.next()){
                        Battalarm_data adata=new Battalarm_data();
                        adata.setBattGroupId(rs.getInt("battGroupId"));
                        adata.setAlm_id(rs.getInt("alm_id"));
                        adata.setMonNum(rs.getInt("monnum"));
                        adata.setAlm_level(rs.getInt("alm_level"));
                        adata.setAlm_start_time(rs.getTimestamp("alm_start_time"));
                        adata.setNum(rs.getInt("FBSDeviceId"));
                        adata.setBattGroupName(rs.getString("BattGroupName"));
                        adata.setAlm_signal_id(rs.getInt("alm_signal_id"));
                        adata.setNote(AlarmDaoFactory.getAlarmName(adata.getAlm_signal_id()));
                        list.add(adata);
                    }
                } 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 num,battGroupId,MonNum,Record_Id,alm_id,alm_signal_id,alm_value,alm_level,alm_is_confirmed,alm_confirmed_time,alm_start_time,alm_end_time  from  db_alarm.tb_battalarm_data  where battGroupId=?  order by alm_start_timedesc";
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{binf.getBattGroupId()}, new CallBack() {
			
            @Override
            public List getResults(ResultSet rs) {
                // TODO Auto-generated method stub
                List list=new ArrayList();
                try {
                    while(rs.next()){
                        Battalarm_data adata=new Battalarm_data();
                        adata.setNum(rs.getInt("num"));
                        adata.setBattGroupId(rs.getInt("BattGroupId"));
                        adata.setMonNum(rs.getInt("MonNum"));
                        adata.setRecord_Id(rs.getLong("Record_Id"));
                        adata.setMonNum(rs.getInt("alm_id"));
                        adata.setAlm_signal_id(rs.getInt("alm_signal_id"));
                        adata.setAlm_level(rs.getInt("alm_level"));
                        adata.setAlm_start_time(rs.getTimestamp("alm_start_time"));
                        adata.setAlm_end_time(rs.getTimestamp("alm_end_time"));
                        adata.setAlm_value(rs.getFloat("alm_value"));
                        adata.setAlm_is_confirmed(rs.getInt("alm_is_confirmed"));
                        adata.setAlm_confirmed_time(rs.getTimestamp("alm_confirmed_time"));
                        list.add(adata);
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return list;
            }
        });
        return list;
    }
    //查询实时告警的总数
    public List searchAlarmNum(){
        String sql=" select count(db_alarm.tb_battalarm_data.num) as number   "
                + "  from db_alarm.tb_battalarm_data,db_battinf.tb_battinf "
                + "  where db_alarm.tb_battalarm_data.battGroupId=db_battinf.tb_battinf.battGroupId  ";
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
			
            @Override
            public List getResults(ResultSet rs) {
                // TODO Auto-generated method stub
                List list=new ArrayList();
                int number=0;
                try {
                    while(rs.next()){
                        number=rs.getInt("number");
                        list.add(number);
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return list;
            }
        });
        return list;
    }
	
    public static void main(String[] args) {
        Battalarm_dataImpl bimpl=new Battalarm_dataImpl();
        /*List<Battalarm_data> list=bimpl.searchAll();*/
        Page p=new Page();
        p.setPageCurr(1);
        p.setPageSize(6);
        List<Battalarm_data> list=bimpl.serchByInfo(p);
        for (Battalarm_data b : list) {
            System.out.println(b);
        }
        System.out.println(list.size());
        /*List<Integer> list=bimpl.searchAlarmNum();
        for (Integer number : list) {
            System.out.println(number);
        }*/
    }
}