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.stationName3,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,db_ram_db.tb_batt_rtstate.rec_datetime "
|
//+ ",(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.setStationName3(rs.getString("stationName3"));;
|
binf.setMonVolLowToAvg(rs.getFloat("group_vol"));
|
binf.setLoad_curr(rs.getFloat("group_curr"));
|
binf.setNum(rs.getInt("batt_state"));
|
binf.setBattInUseDate(rs.getTimestamp("rec_datetime"));
|
//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;
|
}
|
//根据设备id查询机房名称
|
public List serchByInfo(Object obj) {
|
BattInf binf=(BattInf) obj;
|
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 "
|
+ " where FBSDeviceId=? ";
|
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.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 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());
|
}
|
|
}
|
