package com.fgkj.dao.impl.Ld9;
|
|
import java.sql.Connection;
|
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.dao.LimitNumberFactory;
|
import com.fgkj.db.DBUtil;
|
import com.fgkj.dto.LD9_state;
|
import com.fgkj.dto.Page;
|
import com.fgkj.dto.ram.Fbs9100_state;
|
|
public class LD9_stateImpl implements BaseDAO,CallBack{
|
|
public List getResults(ResultSet rs) {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
|
public boolean add(Object obj) {
|
// TODO Auto-generated method stub
|
return false;
|
}
|
|
public boolean update(Object obj) {
|
// TODO Auto-generated method stub
|
return false;
|
}
|
|
public boolean del(Object obj) {
|
// TODO Auto-generated method stub
|
return false;
|
}
|
//查询所有LD9设备的实时数据
|
public List searchAll() {
|
String sql=" select num,dev_id,sys_state,sys_online_vol,sys_group_vol," +
|
" sys_now_battnum,sys_now_battstate,sys_now_battvol,sys_now_battcurr," +
|
" sys_now_battcap,sys_now_testtime,dev_commcount,dev_errcommcount " +
|
" from db_ram_db.tb_ld9_state " +
|
" order by sys_now_battnum";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
LD9_state ld9=new LD9_state();
|
ld9.setNum(rs.getInt("num"));
|
ld9.setDev_id(rs.getInt("dev_id"));
|
ld9.setSys_state(rs.getInt("sys_state"));
|
ld9.setSys_online_vol(rs.getShort("sys_online_vol"));
|
ld9.setSys_group_vol(rs.getFloat("sys_group_vol"));
|
ld9.setSys_now_battnum(rs.getInt("sys_now_battnum"));
|
ld9.setSys_now_battstate(rs.getInt("sys_now_battstate"));
|
ld9.setSys_now_battvol(rs.getFloat("sys_now_battvol"));
|
ld9.setSys_now_battcurr(rs.getFloat("sys_now_battcurr"));
|
ld9.setSys_now_battcap(rs.getFloat("sys_now_battcap"));
|
ld9.setSys_now_testtime(rs.getTimestamp("sys_now_testtime"));
|
ld9.setDev_commcount(rs.getInt("dev_commcount"));
|
ld9.setDev_errcommcount(rs.getInt("dev_errcommcount"));
|
list.add(ld9);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
//Ld9设备通信状态查询
|
/*
|
* Ld9：op_cmd:0:全部；1：fbs9100,2:fbs9600,3：ld9
|
* dev_errcommcount;0:通讯正常，1：通讯中断，100：全部
|
* */
|
public List serchByCondition(Object obj) {
|
LD9_state ld9=(LD9_state) obj;
|
Page page=ld9.getPage();
|
Connection conn=DBUtil.getConn();
|
String numberSql=" SELECT FOUND_ROWS() number";
|
String sql="";
|
String baseSql="select SQL_CALC_FOUND_ROWS distinct db_ram_db.tb_ld9_state.num,db_ram_db.tb_ld9_state.dev_ip,db_ram_db.tb_ld9_state.dev_id,db_ram_db.tb_ld9_state.dev_version," +
|
"db_ram_db.tb_ld9_state.sys_state,db_ram_db.tb_ld9_state.sys_stop_reason,db_ram_db.tb_ld9_state.dev_commcount,db_ram_db.tb_ld9_state.dev_errcommcount,db_ram_db.tb_ld9_state.timelong, " +
|
"db_battinf.tb_battinf.StationName,db_battinf.tb_battinf.FbsDeviceName," +
|
"COUNT(DISTINCT db_battinf.tb_battinf.BattGroupId) as cnt," +
|
"group_CONCAT(db_ram_db.tb_batt_rtstate.online_vol ORDER BY db_ram_db.tb_batt_rtstate.BattGroupId separator '/') as online_vols,group_CONCAT(db_ram_db.tb_batt_rtstate.group_vol ORDER BY db_ram_db.tb_batt_rtstate.BattGroupId separator '/') as group_vols,group_CONCAT(db_ram_db.tb_batt_rtstate.group_curr ORDER BY db_ram_db.tb_batt_rtstate.BattGroupId separator '/') as group_currs " +
|
"from db_ram_db.tb_ld9_state " +
|
"left outer join db_battinf.tb_battinf ON db_ram_db.tb_ld9_state.dev_id=db_battinf.tb_battinf.FBSDeviceId " +
|
"LEFT OUTER JOIN db_ram_db.tb_batt_rtstate ON db_battinf.tb_battinf.battgroupid=db_ram_db.tb_batt_rtstate.battgroupid ";
|
|
//通讯中断
|
String comSqlT=" where dev_errcommcount=0 ";
|
String comSqlF=" where dev_errcommcount>0 ";
|
String comSqlA=" where dev_errcommcount>-1 ";
|
if(ld9.getDev_errcommcount()==0){
|
baseSql+=comSqlT;
|
}else if(ld9.getDev_errcommcount()==1){
|
baseSql+=comSqlF;
|
}else{
|
baseSql+=comSqlA;
|
}
|
//判断是否为管理的机房
|
String stationSql=" and db_battinf.tb_battinf.StationId in(select distinct db_battinf.tb_battinf.StationId " +
|
" from db_battinf.tb_battinf,db_user.tb_user_battgroup_baojigroup_battgroup,db_user.tb_user_battgroup_baojigroup_usr,db_user.tb_user_inf " +
|
" where db_user.tb_user_battgroup_baojigroup_battgroup.BattGroupId=db_battinf.tb_battinf.BattGroupId " +
|
" and db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id " +
|
" and db_user.tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid " +
|
" and db_user.tb_user_inf.uid=? ) ";
|
baseSql+=stationSql;
|
//分组
|
String groupSql=" GROUP BY db_ram_db.tb_ld9_state.dev_id ";
|
//分页
|
String limitSql=" limit ?,? ";
|
//最后结果
|
sql=baseSql+groupSql+limitSql;
|
|
//System.out.println(sql);
|
List<Fbs9100_state> list=DAOHelper.executeQueryLimit(sql, conn, new Object[]{ld9.getNum(),(page.getPageCurr()-1)*page.getPageSize(),page.getPageSize()}, new CallBack() {
|
List list=new ArrayList();
|
public List getResults(ResultSet rs) {
|
try {
|
while(rs.next()){
|
Fbs9100_state fstate=new Fbs9100_state();
|
fstate.setNum(rs.getInt("cnt"));//关联电池组个数
|
fstate.setDev_ip(rs.getString("dev_ip"));
|
fstate.setDev_id(rs.getInt("dev_id"));
|
|
fstate.setDev_version(rs.getString("dev_version"));
|
fstate.setDev_testtype(rs.getInt("sys_state"));
|
fstate.setDev_alarmstate(rs.getInt("sys_stop_reason"));
|
fstate.setDev_commcount(rs.getInt("dev_commcount"));
|
fstate.setDev_errcommcount(rs.getInt("dev_errcommcount"));
|
|
fstate.setStationName(rs.getString("stationName"));
|
fstate.setDeviceName(rs.getString("FbsDeviceName"));
|
fstate.setOnline_vols(rs.getString("online_vols"));
|
fstate.setGroup_vols(rs.getString("group_vols"));
|
fstate.setGroup_currs(rs.getString("group_currs"));
|
fstate.setDev_captest_timelong(rs.getInt("timelong"));
|
//System.out.println(fstate);
|
list.add(fstate);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
//去掉limit条件后的总数
|
int number=LimitNumberFactory.GetLimtitNumber(conn, numberSql);
|
if(list!=null&&list.size()>0){
|
page.setPageAll(number);
|
list.get(list.size()-1).setPage(page);
|
}
|
return list;
|
}
|
|
public List serchByInfo(Object obj) {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
|
}
|
