修改

81041

2019-12-27 557ffa1fcfa668043ad752c02c78f47547a50336

修改

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

@@ -1,176 +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.Page;



public class BattInfImpl 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 db_battinf.tb_battinf.BattGroupId,db_battinf.tb_battinf.BattGroupName,battProducer,monCount,monVolStd,monResStd,monCapStd,battModel  "

                + ",db_ram_db.tb_batt_rtstate.group_vol,db_ram_db.tb_batt_rtstate.group_curr,db_ram_db.tb_batt_rtstate.batt_state "

                + ",(case when db_alarm.tb_battalarm_data.alm_id  is null then 0 ELSE db_alarm.tb_battalarm_data.alm_id end) AS alm_id "

                + " FROM  db_battinf.tb_battinf "

                + " LEFT OUTER JOIN db_ram_db.tb_batt_rtstate on db_battinf.tb_battinf.BattGroupId=db_ram_db.tb_batt_rtstate.BattGroupId "

                + " LEFT OUTER JOIN db_alarm.tb_battalarm_data on db_battinf.tb_battinf.BattGroupId=db_alarm.tb_battalarm_data.BattGroupId ";

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

			
            @Override

            public List getResults(ResultSet rs) {

                List list=new ArrayList();

                try {

                    while(rs.next()){

                        BattInf binf=new BattInf();

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

                        binf.setBattGroupName(rs.getString("battGroupName"));

                        binf.setBattProducer(rs.getString("battProducer"));

                        binf.setMonCount(rs.getInt("monCount"));

                        binf.setMonVolStd(rs.getFloat("monVolStd"));

                        binf.setMonResStd(rs.getFloat("monResStd"));

                        binf.setMonCapStd(rs.getFloat("monCapStd"));

                        binf.setBattModel(rs.getString("battModel"));

						
                        binf.setMonVolLowToAvg(rs.getFloat("group_vol"));

                        binf.setLoad_curr(rs.getFloat("group_curr"));

                        binf.setNum(rs.getInt("batt_state"));

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

                        list.add(binf);

                    }

                } catch (SQLException e) {

                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

                return list;

            }

        });

        return list;

    }

    // 查询所有电池组的信息（包含充放电和告警情况）（分页）

    @Override

    public List serchByCondition(Object obj) {

        BattInf binf=(BattInf) obj;

        String sql="select db_battinf.tb_battinf.BattGroupId,db_battinf.tb_battinf.BattGroupName  "

                + ",db_ram_db.tb_batt_rtstate.group_vol,db_ram_db.tb_batt_rtstate.group_curr,db_ram_db.tb_batt_rtstate.batt_state "

                + ",(case when db_alarm.tb_battalarm_data.alm_signal_id  is null then 0 ELSE db_alarm.tb_battalarm_data.alm_id end) AS alm_signal_id "

                + " FROM  db_battinf.tb_battinf "

                + " LEFT OUTER JOIN db_ram_db.tb_batt_rtstate on db_battinf.tb_battinf.BattGroupId=db_ram_db.tb_batt_rtstate.BattGroupId "

                + " LEFT OUTER JOIN db_alarm.tb_battalarm_data on db_battinf.tb_battinf.BattGroupId=db_alarm.tb_battalarm_data.BattGroupId "

                + " where db_battinf.tb_battinf.FBSDeviceId=? "

                + " order by db_battinf.tb_battinf.BattGroupId asc ";

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

			
            @Override

            public List getResults(ResultSet rs) {

                List list=new ArrayList();

                try {

                    while(rs.next()){

                        BattInf binf=new BattInf();

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

                        binf.setBattGroupName(rs.getString("battGroupName"));

						
                        binf.setMonVolLowToAvg(rs.getFloat("group_vol"));

                        binf.setLoad_curr(rs.getFloat("group_curr"));

                        binf.setNum(rs.getInt("batt_state"));

                        //binf.setMonNum(rs.getInt("alm_signal_id"));

                        binf.setSignalName(AlarmDaoFactory.getAlarmName(rs.getInt("alm_signal_id")));

                        list.add(binf);

                    }

                } catch (SQLException e) {

                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

                return list;

            }

        });

        return list;

    }

  	
    //查询所有的设备

    public List serchDevice(){

        String sql="select distinct db_battinf.tb_battinf.FBSDeviceId,stationName3,stationName,FbsDeviceIp,db_battinf.tb_battinf.FBSDeviceName"

                + " ,battProducer,monCount,monVolStd,monResStd,monCapStd,battModel  "

                + " FROM  db_battinf.tb_battinf "

                + " order by FBSDeviceId asc ";

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

			
            @Override

            public List getResults(ResultSet rs) {

                List list=new ArrayList();

                try {

                    while(rs.next()){

                        BattInf binf=new BattInf();

                        binf.setStationName(rs.getString("stationName"));;

                        binf.setStationName3(rs.getString("stationName3"));

                        binf.setFBSDeviceId(rs.getInt("FBSDeviceId"));

                        binf.setFbsDeviceIp(rs.getString("FbsDeviceIp"));

                        binf.setFBSDeviceName(rs.getString("fBSDeviceName"));

                        binf.setBattProducer(rs.getString("battProducer"));

                        binf.setMonCount(rs.getInt("monCount"));

                        binf.setMonVolStd(rs.getFloat("monVolStd"));

                        binf.setMonResStd(rs.getFloat("monResStd"));

                        binf.setMonCapStd(rs.getFloat("monCapStd"));

                        binf.setBattModel(rs.getString("battModel"));

                        list.add(binf);

                    }

                } catch (SQLException e) {

                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

                return list;

            }

        });

        return list;

    }

     public List serchByInfo(Object obj) {

        return null;

    }

    public static void main(String[] args) {

        BattInfImpl bimpl=new BattInfImpl();

        Page p=new Page();

        p.setPageCurr(1);

        p.setPageSize(6);

        BattInf binf=new BattInf();

        binf.setFBSDeviceId(910000011);

        //List<BattInf> list=bimpl.serchByCondition(binf);

        List<BattInf> list=bimpl.serchDevice();

        for (BattInf b : list) {

            System.out.println(b);

        }

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

    }



}

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.Page;

public class BattInfImpl 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 db_battinf.tb_battinf.BattGroupId,db_battinf.tb_battinf.BattGroupName,battProducer,monCount,monVolStd,monResStd,monCapStd,battModel  "
                + ",db_ram_db.tb_batt_rtstate.group_vol,db_ram_db.tb_batt_rtstate.group_curr,db_ram_db.tb_batt_rtstate.batt_state "
                + ",(case when db_alarm.tb_battalarm_data.alm_id  is null then 0 ELSE db_alarm.tb_battalarm_data.alm_id end) AS alm_id "
                + " FROM  db_battinf.tb_battinf "
                + " LEFT OUTER JOIN db_ram_db.tb_batt_rtstate on db_battinf.tb_battinf.BattGroupId=db_ram_db.tb_batt_rtstate.BattGroupId "
                + " LEFT OUTER JOIN db_alarm.tb_battalarm_data on db_battinf.tb_battinf.BattGroupId=db_alarm.tb_battalarm_data.BattGroupId ";
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
			
            @Override
            public List getResults(ResultSet rs) {
                List list=new ArrayList();
                try {
                    while(rs.next()){
                        BattInf binf=new BattInf();
                        binf.setBattGroupId(rs.getInt("battGroupId"));
                        binf.setBattGroupName(rs.getString("battGroupName"));
                        binf.setBattProducer(rs.getString("battProducer"));
                        binf.setMonCount(rs.getInt("monCount"));
                        binf.setMonVolStd(rs.getFloat("monVolStd"));
                        binf.setMonResStd(rs.getFloat("monResStd"));
                        binf.setMonCapStd(rs.getFloat("monCapStd"));
                        binf.setBattModel(rs.getString("battModel"));
						
                        binf.setMonVolLowToAvg(rs.getFloat("group_vol"));
                        binf.setLoad_curr(rs.getFloat("group_curr"));
                        binf.setNum(rs.getInt("batt_state"));
                        binf.setMonNum(rs.getInt("alm_id"));
                        list.add(binf);
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return list;
            }
        });
        return list;
    }
    // 查询所有电池组的信息（包含充放电和告警情况）（分页）
    @Override
    public List serchByCondition(Object obj) {
        BattInf binf=(BattInf) obj;
        String sql="select distinct db_battinf.tb_battinf.BattGroupId,db_battinf.tb_battinf.BattGroupName  "
                + ",db_ram_db.tb_batt_rtstate.group_vol,db_ram_db.tb_batt_rtstate.group_curr,db_ram_db.tb_batt_rtstate.batt_state "
                + ",(case when db_alarm.tb_battalarm_data.alm_signal_id  is null then 0 ELSE db_alarm.tb_battalarm_data.alm_signal_id end) AS alm_signal_id "
                + " FROM  db_battinf.tb_battinf "
                + " LEFT OUTER JOIN db_ram_db.tb_batt_rtstate on db_battinf.tb_battinf.BattGroupId=db_ram_db.tb_batt_rtstate.BattGroupId "
                + " LEFT OUTER JOIN db_alarm.tb_battalarm_data on db_battinf.tb_battinf.BattGroupId=db_alarm.tb_battalarm_data.BattGroupId "
                + " where db_battinf.tb_battinf.FBSDeviceId=? "
                + " order by db_battinf.tb_battinf.BattGroupId asc ";
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{binf.getFBSDeviceId()}, new CallBack() {
			
            @Override
            public List getResults(ResultSet rs) {
                List list=new ArrayList();
                try {
                    while(rs.next()){
                        BattInf binf=new BattInf();
                        binf.setBattGroupId(rs.getInt("battGroupId"));
                        binf.setBattGroupName(rs.getString("battGroupName"));
						
                        binf.setMonVolLowToAvg(rs.getFloat("group_vol"));
                        binf.setLoad_curr(rs.getFloat("group_curr"));
                        binf.setNum(rs.getInt("batt_state"));
                        //binf.setMonNum(rs.getInt("alm_signal_id"));
                        binf.setSignalName(AlarmDaoFactory.getAlarmName(rs.getInt("alm_signal_id")));
                        list.add(binf);
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return list;
            }
        });
        return list;
    }
  	
    //查询所有的设备
    public List serchDevice(){
        String sql="select distinct db_battinf.tb_battinf.FBSDeviceId,stationName3,stationName,FbsDeviceIp,db_battinf.tb_battinf.FBSDeviceName"
                + " ,battProducer,monCount,monVolStd,monResStd,monCapStd,battModel  "
                + " FROM  db_battinf.tb_battinf "
                + " order by FBSDeviceId asc ";
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
			
            @Override
            public List getResults(ResultSet rs) {
                List list=new ArrayList();
                try {
                    while(rs.next()){
                        BattInf binf=new BattInf();
                        binf.setStationName(rs.getString("stationName"));;
                        binf.setStationName3(rs.getString("stationName3"));
                        binf.setFBSDeviceId(rs.getInt("FBSDeviceId"));
                        binf.setFbsDeviceIp(rs.getString("FbsDeviceIp"));
                        binf.setFBSDeviceName(rs.getString("fBSDeviceName"));
                        binf.setBattProducer(rs.getString("battProducer"));
                        binf.setMonCount(rs.getInt("monCount"));
                        binf.setMonVolStd(rs.getFloat("monVolStd"));
                        binf.setMonResStd(rs.getFloat("monResStd"));
                        binf.setMonCapStd(rs.getFloat("monCapStd"));
                        binf.setBattModel(rs.getString("battModel"));
                        list.add(binf);
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return list;
            }
        });
        return list;
    }
     public List serchByInfo(Object obj) {
        return null;
    }
    public static void main(String[] args) {
        BattInfImpl bimpl=new BattInfImpl();
        Page p=new Page();
        p.setPageCurr(1);
        p.setPageSize(6);
        BattInf binf=new BattInf();
        binf.setFBSDeviceId(910000011);
        //List<BattInf> list=bimpl.serchByCondition(binf);
        List<BattInf> list=bimpl.serchDevice();
        for (BattInf b : list) {
            System.out.println(b);
        }
        System.out.println(list.size());
    }

}