加入指定机房

81041

2020-01-06 dc4e90ff7d720a78dba3aa72d868b89f69eafff7

加入指定机房

 Device_Manage/src/com/fgkj/actions/Batt_rtstateAction.java

@@ -1,39 +1,40 @@
package com.fgkj.actions;



import com.fgkj.dto.BattInf;

import com.fgkj.dto.ServiceModel;

import com.fgkj.services.Batt_rtstateService;



public class Batt_rtstateAction extends ActionUtil{

    private Batt_rtstateService service=new Batt_rtstateService();

    private String result;

    private String json;

	
	
     //根据电池组信息查询组端信息

    public String serchByCondition() {

        BattInf binf=getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, BattInf.class);

        ServiceModel model=service.serchByCondition(binf);

        result=tojson(model);

        return SUCCESS;

    }

    //查看实时充放电信息

    public String serchByInfo() {

        BattInf binf=getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, BattInf.class);

        ServiceModel model=service.serchByInfo(binf);

        result=tojson(model);

        return SUCCESS;

    }

    //实时查询充放电统计

    public String serchDisOrChargrNew() {

        ServiceModel model=service.serchDisOrChargrNew();

        result=tojson(model);

        return SUCCESS;

    }

    public String getResult() {

        return result;

    }

    public void setJson(String json) {

        this.json = json;

    }

}

package com.fgkj.actions;

import com.fgkj.dto.BattInf;
import com.fgkj.dto.ServiceModel;
import com.fgkj.services.Batt_rtstateService;

public class Batt_rtstateAction extends ActionUtil{
    private Batt_rtstateService service=new Batt_rtstateService();
    private String result;
    private String json;
	
	
     //根据电池组信息查询组端信息
    public String serchByCondition() {
        BattInf binf=getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, BattInf.class);
        ServiceModel model=service.serchByCondition(binf);
        result=tojson(model);
        return SUCCESS;
    }
    //查看实时充放电信息
    public String serchByInfo() {
        BattInf binf=getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, BattInf.class);
        ServiceModel model=service.serchByInfo(binf);
        result=tojson(model);
        return SUCCESS;
    }
    //实时查询充放电统计
    public String serchDisOrChargrNew() {
        BattInf binf=getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, BattInf.class);
        ServiceModel model=service.serchDisOrChargrNew(binf);
        result=tojson(model);
        return SUCCESS;
    }
    public String getResult() {
        return result;
    }
    public void setJson(String json) {
        this.json = json;
    }
}

 Device_Manage/src/com/fgkj/actions/Battalarm_dataAction.java

@@ -1,47 +1,48 @@
package com.fgkj.actions;



import com.fgkj.dto.BattInf;

import com.fgkj.dto.Page;

import com.fgkj.dto.ServiceModel;

import com.fgkj.services.Battalarm_dataService;



public class Battalarm_dataAction extends ActionUtil{

    private Battalarm_dataService service=new Battalarm_dataService();

    private String result;

    private String json;

	
	
    //根据电池组id查询告警信息

    public String searchAll() {

        ServiceModel model=service.searchAll();

        result=tojson(model);

        return SUCCESS;

    }

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

    public String serchByInfo() {

        Page page=getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, Page.class);

        ServiceModel model=service.serchByInfo(page);

        result=tojson(model);

        return SUCCESS;

    }

	
     //根据电池组id查询电池告警的详细情况

    public String serchByCondition() {

        BattInf binf=getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, BattInf.class);

        ServiceModel model=service.serchByCondition(binf);

        result=tojson(model);

        return SUCCESS;

    }

    //查询实时告警的总数

    public String searchAlarmNum() {

        ServiceModel model=service.searchAlarmNum();

        result=tojson(model);

        return SUCCESS;

    }

    public String getResult() {

        return result;

    }

    public void setJson(String json) {

        this.json = json;

    }

}

package com.fgkj.actions;

import com.fgkj.dto.BattInf;
import com.fgkj.dto.Page;
import com.fgkj.dto.ServiceModel;
import com.fgkj.services.Battalarm_dataService;

public class Battalarm_dataAction extends ActionUtil{
    private Battalarm_dataService service=new Battalarm_dataService();
    private String result;
    private String json;
	
	
    //根据电池组id查询告警信息
    public String searchAll() {
        ServiceModel model=service.searchAll();
        result=tojson(model);
        return SUCCESS;
    }
    //查询实时告警（分页）
    public String serchByInfo() {
        BattInf binf=getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, BattInf.class);Page page=getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, Page.class);
        ServiceModel model=service.serchByInfo(binf);
        result=tojson(model);
        return SUCCESS;
    }
	
     //根据电池组id查询电池告警的详细情况
    public String serchByCondition() {
        BattInf binf=getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, BattInf.class);
        ServiceModel model=service.serchByCondition(binf);
        result=tojson(model);
        return SUCCESS;
    }
    //查询实时告警的总数
    public String searchAlarmNum() {
        BattInf binf=getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, BattInf.class);
        ServiceModel model=service.searchAlarmNum(binf);
        result=tojson(model);
        return SUCCESS;
    }
    public String getResult() {
        return result;
    }
    public void setJson(String json) {
        this.json = json;
    }
}

 Device_Manage/src/com/fgkj/actions/Battalarm_data_historyAction.java

@@ -1,40 +1,40 @@
package com.fgkj.actions;



import com.fgkj.dto.BattInf;

import com.fgkj.dto.Page;

import com.fgkj.dto.ServiceModel;

import com.fgkj.services.Battalarm_data_historyService;



public class Battalarm_data_historyAction extends ActionUtil{

    private Battalarm_data_historyService service=new Battalarm_data_historyService();

    private String result;

    private String json;

	
	
    //查询所有的历史告警

    public String searchAll() {

        ServiceModel model=service.searchAll();

        result=tojson(model);

        return SUCCESS;

    }

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

    public String serchByInfo() {

        Page page=getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, Page.class);

        ServiceModel model=service.serchByInfo(page);

        result=tojson(model);

        return SUCCESS;

    }

     //根据电池组id查询电池告警的详细情况

    public String serchByCondition() {

        BattInf binf=getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, BattInf.class);

        ServiceModel model=service.serchByCondition(binf);

        result=tojson(model);

        return SUCCESS;

    }

    public String getResult() {

        return result;

    }

    public void setJson(String json) {

        this.json = json;

    }

}

package com.fgkj.actions;

import com.fgkj.dto.BattInf;
import com.fgkj.dto.Page;
import com.fgkj.dto.ServiceModel;
import com.fgkj.services.Battalarm_data_historyService;

public class Battalarm_data_historyAction extends ActionUtil{
    private Battalarm_data_historyService service=new Battalarm_data_historyService();
    private String result;
    private String json;
	
	
    //查询所有的历史告警
    public String searchAll() {
        ServiceModel model=service.searchAll();
        result=tojson(model);
        return SUCCESS;
    }
    //查询所有的历史告警(分页)
    public String serchByInfo() {
        BattInf binf=getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, BattInf.class);
        ServiceModel model=service.serchByInfo(binf);
        result=tojson(model);
        return SUCCESS;
    }
     //根据电池组id查询电池告警的详细情况
    public String serchByCondition() {
        BattInf binf=getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, BattInf.class);
        ServiceModel model=service.serchByCondition(binf);
        result=tojson(model);
        return SUCCESS;
    }
    public String getResult() {
        return result;
    }
    public void setJson(String json) {
        this.json = json;
    }
}

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

@@ -1,179 +1,185 @@
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.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.Batt_rtstate;



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

        // TODO Auto-generated method stub

        return null;

    }

    //根据电池组信息查询组端信息

    @Override

    public List serchByCondition(Object obj) {

        BattInf binf=(BattInf) obj;

        String sql=" select * from db_ram_db.tb_batt_rtstate where BattGroupId=? ";

        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()){

                        Batt_rtstate rt=new Batt_rtstate();

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

                        rt.setBatt_count(rs.getInt("batt_count"));

                        rt.setRec_datetime(rs.getTimestamp("rec_datetime"));

                        rt.setOnline_vol(rs.getFloat("online_vol"));

                        rt.setGroup_vol(rs.getFloat("group_vol"));

                        rt.setGroup_curr(rs.getFloat("group_curr"));

                        rt.setBatt_state(rs.getInt("batt_state"));

                        rt.setBatt_test_type(rs.getInt("batt_test_type"));

                        rt.setBatt_test_starttime(rs.getTimestamp("batt_test_starttime"));

                        rt.setBatt_test_recordtime(rs.getTimestamp("batt_test_recordtime"));

                        rt.setBatt_test_tlong(rs.getInt("batt_test_tlong"));

                        rt.setBatt_test_cap(rs.getFloat("batt_test_cap"));

                        rt.setBatt_real_cap(rs.getFloat("batt_real_cap"));

                        rt.setBatt_rest_cap(rs.getFloat("batt_rest_cap"));

                        list.add(rt);

                    }

                } catch (SQLException e) {

                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

                return list;

            }

        });

        return list;

    }

     //测试数据——实时查询充放电统计

    public List serchDisOrChargrNew(){

        String sql=" select sum(if(batt_test_type=2,1,0)) as charge,sum(if(batt_test_type=3,1,0)) as discharge  from db_ram_db.tb_batt_rtstate where batt_test_type IN(2,3)  "

                + "  GROUP BY batt_test_type  ";

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

			
            public List getResults(ResultSet rs) {

                List list=new ArrayList();

                int charge=0;

                int dischar=0;

                try {

                    while(rs.next()){

                        if(rs.getInt("charge")!=0){

                            charge=rs.getInt("charge");

                        }

                        if(rs.getInt("discharge")!=0){

                            dischar=rs.getInt("discharge");

                        }

                    }

                } catch (SQLException e) {

                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

                list.add(charge);

                list.add(dischar);

                return list;

            }

        });

        return list;

    }

    //查看实时充放电信息

    @Override

    public List serchByInfo(Object obj) {

        BattInf binf=(BattInf) obj;

        String sql=" select db_ram_db.tb_batt_rtstate.battGroupId,batt_count,rec_datetime,online_vol,group_vol,group_curr"

                + " ,batt_state,batt_test_type,batt_test_starttime,batt_test_recordtime,batt_test_tlong,batt_test_cap,batt_real_cap,batt_rest_cap"

                + " ,FBSDeviceId,BattGroupName "

                + " from db_ram_db.tb_batt_rtstate,db_battinf.tb_battinf "

                + " where  db_ram_db.tb_batt_rtstate.battGroupId=db_battinf.tb_battinf.battGroupId ";

        //判断是充电还是放电

        String chargeSqlT="  and batt_state!=? ";

        String chargeSqlF="  and batt_state=? ";

        if(binf.getNum()==100){

            sql+=chargeSqlT;

        }else{

            sql+=chargeSqlF;

        }

        String endsql=" order by batt_test_starttime desc";

        sql+=endsql;

        //System.out.println(sql);

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

			
            @Override

            public List getResults(ResultSet rs) {

                List list=new ArrayList();

                try {

                    while(rs.next()){

                        Batt_rtstate rt=new Batt_rtstate();

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

                        rt.setBatt_count(rs.getInt("batt_count"));

                        rt.setRec_datetime(rs.getTimestamp("rec_datetime"));

                        rt.setOnline_vol(rs.getFloat("online_vol"));

                        rt.setGroup_vol(rs.getFloat("group_vol"));

                        rt.setGroup_curr(rs.getFloat("group_curr"));

                        rt.setBatt_state(rs.getInt("batt_state"));

                        rt.setBatt_test_type(rs.getInt("batt_test_type"));

                        rt.setBatt_test_starttime(rs.getTimestamp("batt_test_starttime"));

                        rt.setBatt_test_recordtime(rs.getTimestamp("batt_test_recordtime"));

                        rt.setBatt_test_tlong(rs.getInt("batt_test_tlong"));

                        rt.setBatt_test_cap(rs.getFloat("batt_test_cap"));

                        rt.setBatt_real_cap(rs.getFloat("batt_real_cap"));

                        rt.setBatt_rest_cap(rs.getFloat("batt_rest_cap"));

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

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

                        list.add(rt);

                    }

                } catch (SQLException e) {

                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

                return list;

            }

        });

        return list;

    }

    
    public static void main(String[] args) {

        Batt_rtstateImpl bimpl=new Batt_rtstateImpl();

        BattInf binf=new BattInf();

        binf.setNum(100);

        List<Integer> list=bimpl.serchDisOrChargrNew();

        for (Integer num : list) {

            System.out.println(num);

        }

    }

}

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

public class Batt_rtstateImpl 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() {
        // TODO Auto-generated method stub
        return null;
    }
    //根据电池组信息查询组端信息
    @Override
    public List serchByCondition(Object obj) {
        BattInf binf=(BattInf) obj;
        String sql=" select * from db_ram_db.tb_batt_rtstate where BattGroupId=? ";
        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()){
                        Batt_rtstate rt=new Batt_rtstate();
                        rt.setBattGroupId(rs.getInt("battGroupId"));
                        rt.setBatt_count(rs.getInt("batt_count"));
                        rt.setRec_datetime(rs.getTimestamp("rec_datetime"));
                        rt.setOnline_vol(rs.getFloat("online_vol"));
                        rt.setGroup_vol(rs.getFloat("group_vol"));
                        rt.setGroup_curr(rs.getFloat("group_curr"));
                        rt.setBatt_state(rs.getInt("batt_state"));
                        rt.setBatt_test_type(rs.getInt("batt_test_type"));
                        rt.setBatt_test_starttime(rs.getTimestamp("batt_test_starttime"));
                        rt.setBatt_test_recordtime(rs.getTimestamp("batt_test_recordtime"));
                        rt.setBatt_test_tlong(rs.getInt("batt_test_tlong"));
                        rt.setBatt_test_cap(rs.getFloat("batt_test_cap"));
                        rt.setBatt_real_cap(rs.getFloat("batt_real_cap"));
                        rt.setBatt_rest_cap(rs.getFloat("batt_rest_cap"));
                        list.add(rt);
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return list;
            }
        });
        return list;
    }
     //测试数据——实时查询充放电统计
    public List serchDisOrChargrNew(Object obj){
        BattInf binf=(BattInf) obj;
        String sql=" select sum(if(batt_test_type=2,1,0)) as charge,sum(if(batt_test_type=3,1,0)) as discharge  "
                + "  from db_ram_db.tb_batt_rtstate,db_battinf.tb_battinf "
                + "  where db_alarm.tb_battalarm_data.battGroupId=db_battinf.tb_battinf.battGroupId  "
                + "  and batt_test_type IN(2,3)  "
                + "  and db_battinf.tb_battinf.FBSDeviceId=? "
                + "  GROUP BY batt_test_type  ";
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(),new Object[]{binf.getFBSDeviceId()}, new CallBack() {
			
            public List getResults(ResultSet rs) {
                List list=new ArrayList();
                int charge=0;
                int dischar=0;
                try {
                    while(rs.next()){
                        if(rs.getInt("charge")!=0){
                            charge=rs.getInt("charge");
                        }
                        if(rs.getInt("discharge")!=0){
                            dischar=rs.getInt("discharge");
                        }
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                list.add(charge);
                list.add(dischar);
                return list;
            }
        });
        return list;
    }
    //查看实时充放电信息
    @Override
    public List serchByInfo(Object obj) {
        BattInf binf=(BattInf) obj;
        String sql=" select db_ram_db.tb_batt_rtstate.battGroupId,batt_count,rec_datetime,online_vol,group_vol,group_curr"
                + " ,batt_state,batt_test_type,batt_test_starttime,batt_test_recordtime,batt_test_tlong,batt_test_cap,batt_real_cap,batt_rest_cap"
                + " ,FBSDeviceId,BattGroupName "
                + " from db_ram_db.tb_batt_rtstate,db_battinf.tb_battinf "
                + " where  db_ram_db.tb_batt_rtstate.battGroupId=db_battinf.tb_battinf.battGroupId "
                + " and db_battinf.tb_battinf.FBSDeviceId=?  ";
        //判断是充电还是放电
        String chargeSqlT="  and batt_state!=? ";
        String chargeSqlF="  and batt_state=? ";
        if(binf.getNum()==100){
            sql+=chargeSqlT;
        }else{
            sql+=chargeSqlF;
        }
        String endsql=" order by batt_test_starttime desc";
        sql+=endsql;
        //System.out.println(sql);
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{binf.getFBSDeviceId(),binf.getNum()}, new CallBack() {
			
            @Override
            public List getResults(ResultSet rs) {
                List list=new ArrayList();
                try {
                    while(rs.next()){
                        Batt_rtstate rt=new Batt_rtstate();
                        rt.setBattGroupId(rs.getInt("battGroupId"));
                        rt.setBatt_count(rs.getInt("batt_count"));
                        rt.setRec_datetime(rs.getTimestamp("rec_datetime"));
                        rt.setOnline_vol(rs.getFloat("online_vol"));
                        rt.setGroup_vol(rs.getFloat("group_vol"));
                        rt.setGroup_curr(rs.getFloat("group_curr"));
                        rt.setBatt_state(rs.getInt("batt_state"));
                        rt.setBatt_test_type(rs.getInt("batt_test_type"));
                        rt.setBatt_test_starttime(rs.getTimestamp("batt_test_starttime"));
                        rt.setBatt_test_recordtime(rs.getTimestamp("batt_test_recordtime"));
                        rt.setBatt_test_tlong(rs.getInt("batt_test_tlong"));
                        rt.setBatt_test_cap(rs.getFloat("batt_test_cap"));
                        rt.setBatt_real_cap(rs.getFloat("batt_real_cap"));
                        rt.setBatt_rest_cap(rs.getFloat("batt_rest_cap"));
                        rt.setNum(rs.getInt("FBSDeviceId"));
                        rt.setNote(rs.getString("BattGroupName"));
                        list.add(rt);
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return list;
            }
        });
        return list;
    }
    
    public static void main(String[] args) {
        Batt_rtstateImpl bimpl=new Batt_rtstateImpl();
        BattInf binf=new BattInf();
        binf.setNum(100);
        List<Integer> list=bimpl.serchDisOrChargrNew(binf);
        for (Integer num : list) {
            System.out.println(num);
        }
    }
}

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

@@ -74,14 +74,16 @@
    //查询实时告警（分页）
        @Override
    public List serchByInfo(Object obj) {
        Page page=(Page) obj;
        BattInf binf=(BattInf) obj;
        Page page=binf.getPage();
        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  "
                + "  and db_battinf.tb_battinf.FBSDeviceId=? "
                + "  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() {
        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) {
@@ -148,11 +150,13 @@
        return list;
    }
    //查询实时告警的总数
    public List searchAlarmNum(){
    public List searchAlarmNum(Object obj){
        BattInf binf=(BattInf) obj;
        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() {
                + "  where db_alarm.tb_battalarm_data.battGroupId=db_battinf.tb_battinf.battGroupId  "
                + "   and db_battinf.tb_battinf.FBSDeviceId=? ";
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{binf.getFBSDeviceId()}, new CallBack() {
            
            @Override
            public List getResults(ResultSet rs) {

 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);
        }
    }
}

 Device_Manage/src/com/fgkj/services/Batt_rtstateService.java

@@ -1,59 +1,59 @@
package com.fgkj.services;



import java.util.List;



import com.fgkj.dao.BaseDAO;

import com.fgkj.dao.BaseDAOFactory;

import com.fgkj.dao.impl.Batt_rtstateImpl;

import com.fgkj.dto.ServiceModel;



public class Batt_rtstateService {

    private ServiceModel model;

    private BaseDAO dao;

	
    public Batt_rtstateService() {

        model=new ServiceModel();

        dao=BaseDAOFactory.getBaseDAO(BaseDAO.BATT_RTSTATE);

    }

	


    //根据电池组信息查询组端信息

    public ServiceModel serchByCondition(Object obj) {

        List list=dao.serchByCondition(obj);

        if(list!=null&&list.size()>0){

            model.setCode(1);

            model.setData(list);

            model.setMsg("查询成功");

        }else{

            model.setCode(0);

            model.setMsg("查询失败");

        }

        return model;

    }

    //查看实时充放电信息

    public ServiceModel serchByInfo(Object obj) {

        List list=dao.serchByInfo(obj);

        if(list!=null&&list.size()>0){

            model.setCode(1);

            model.setData(list);

            model.setMsg("查询成功");

        }else{

            model.setCode(0);

            model.setMsg("查询失败");

        }

        return model;

    }

     //实时查询充放电统计

    public ServiceModel serchDisOrChargrNew() {

        List list=((Batt_rtstateImpl)dao).serchDisOrChargrNew();

        if(list!=null&&list.size()>0){

            model.setCode(1);

            model.setData(list);

            model.setMsg("查询成功");

        }else{

            model.setCode(0);

            model.setMsg("查询失败");

        }

        return model;

    }

}

package com.fgkj.services;

import java.util.List;

import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.BaseDAOFactory;
import com.fgkj.dao.impl.Batt_rtstateImpl;
import com.fgkj.dto.ServiceModel;

public class Batt_rtstateService {
    private ServiceModel model;
    private BaseDAO dao;
	
    public Batt_rtstateService() {
        model=new ServiceModel();
        dao=BaseDAOFactory.getBaseDAO(BaseDAO.BATT_RTSTATE);
    }
	

    //根据电池组信息查询组端信息
    public ServiceModel serchByCondition(Object obj) {
        List list=dao.serchByCondition(obj);
        if(list!=null&&list.size()>0){
            model.setCode(1);
            model.setData(list);
            model.setMsg("查询成功");
        }else{
            model.setCode(0);
            model.setMsg("查询失败");
        }
        return model;
    }
    //查看实时充放电信息
    public ServiceModel serchByInfo(Object obj) {
        List list=dao.serchByInfo(obj);
        if(list!=null&&list.size()>0){
            model.setCode(1);
            model.setData(list);
            model.setMsg("查询成功");
        }else{
            model.setCode(0);
            model.setMsg("查询失败");
        }
        return model;
    }
     //实时查询充放电统计
    public ServiceModel serchDisOrChargrNew(Object obj) {
        List list=((Batt_rtstateImpl)dao).serchDisOrChargrNew(obj);
        if(list!=null&&list.size()>0){
            model.setCode(1);
            model.setData(list);
            model.setMsg("查询成功");
        }else{
            model.setCode(0);
            model.setMsg("查询失败");
        }
        return model;
    }
}

 Device_Manage/src/com/fgkj/services/Battalarm_dataService.java

@@ -1,71 +1,71 @@
package com.fgkj.services;



import java.util.List;



import com.fgkj.dao.BaseDAO;

import com.fgkj.dao.BaseDAOFactory;

import com.fgkj.dao.impl.Battalarm_dataImpl;

import com.fgkj.dto.ServiceModel;



public class Battalarm_dataService {

    private ServiceModel model;

    private BaseDAO dao;

	
    public Battalarm_dataService() {

        model=new ServiceModel();

        dao=BaseDAOFactory.getBaseDAO(BaseDAO.BATTALARM_DATA);

    }

	
     //根据电池组id查询告警信息

    public ServiceModel searchAll() {

        List list=dao.searchAll();

        if(list!=null&&list.size()>0){

            model.setCode(1);

            model.setData(list);

            model.setMsg("查询成功");

        }else{

            model.setCode(0);

            model.setMsg("查询失败");

        }

        return model;

    }

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

    public ServiceModel serchByInfo(Object obj) {

        List list=dao.serchByInfo(obj);

        if(list!=null&&list.size()>0){

            model.setCode(1);

            model.setData(list);

            model.setMsg("查询成功");

        }else{

            model.setCode(0);

            model.setMsg("查询失败");

        }

        return model;

    }

     //根据电池组id查询电池告警的详细情况

    public ServiceModel serchByCondition(Object obj) {

        List list=dao.serchByCondition(obj);

        if(list!=null&&list.size()>0){

            model.setCode(1);

            model.setData(list);

            model.setMsg("查询成功");

        }else{

            model.setCode(0);

            model.setMsg("查询失败");

        }

        return model;

    }

    //查询实时告警的总数

    public ServiceModel searchAlarmNum() {

        List list=((Battalarm_dataImpl)dao).searchAlarmNum();

        if(list!=null&&list.size()>0){

            model.setCode(1);

            model.setData(list);

            model.setMsg("查询成功");

        }else{

            model.setCode(0);

            model.setMsg("查询失败");

        }

        return model;

    }

}

package com.fgkj.services;

import java.util.List;

import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.BaseDAOFactory;
import com.fgkj.dao.impl.Battalarm_dataImpl;
import com.fgkj.dto.ServiceModel;

public class Battalarm_dataService {
    private ServiceModel model;
    private BaseDAO dao;
	
    public Battalarm_dataService() {
        model=new ServiceModel();
        dao=BaseDAOFactory.getBaseDAO(BaseDAO.BATTALARM_DATA);
    }
	
     //根据电池组id查询告警信息
    public ServiceModel searchAll() {
        List list=dao.searchAll();
        if(list!=null&&list.size()>0){
            model.setCode(1);
            model.setData(list);
            model.setMsg("查询成功");
        }else{
            model.setCode(0);
            model.setMsg("查询失败");
        }
        return model;
    }
    //查询实时告警（分页）
    public ServiceModel serchByInfo(Object obj) {
        List list=dao.serchByInfo(obj);
        if(list!=null&&list.size()>0){
            model.setCode(1);
            model.setData(list);
            model.setMsg("查询成功");
        }else{
            model.setCode(0);
            model.setMsg("查询失败");
        }
        return model;
    }
     //根据电池组id查询电池告警的详细情况
    public ServiceModel serchByCondition(Object obj) {
        List list=dao.serchByCondition(obj);
        if(list!=null&&list.size()>0){
            model.setCode(1);
            model.setData(list);
            model.setMsg("查询成功");
        }else{
            model.setCode(0);
            model.setMsg("查询失败");
        }
        return model;
    }
    //查询实时告警的总数
    public ServiceModel searchAlarmNum(Object obj) {
        List list=((Battalarm_dataImpl)dao).searchAlarmNum(obj);
        if(list!=null&&list.size()>0){
            model.setCode(1);
            model.setData(list);
            model.setMsg("查询成功");
        }else{
            model.setCode(0);
            model.setMsg("查询失败");
        }
        return model;
    }
}