package com.fgkj.dao.impl;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
import org.apache.commons.collections.functors.OnePredicate;
|
|
import com.fgkj.dao.BaseDAO;
|
import com.fgkj.dao.CallBack;
|
import com.fgkj.dao.DAOHelper;
|
import com.fgkj.db.DBUtil;
|
import com.fgkj.dto.Dev_param;
|
|
public class Dev_paramImpl implements BaseDAO,CallBack{
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Dev_param dparam=new Dev_param();
|
dparam.setNum(rs.getInt("num"));
|
dparam.setDev_id(rs.getInt("dev_id"));
|
dparam.setAlm_id(rs.getInt("alm_id"));
|
dparam.setAlm_name(rs.getString("alm_name"));
|
dparam.setAlm_high_coe(rs.getFloat("alm_high_coe"));
|
dparam.setAlm_low_coe(rs.getFloat("alm_low_coe"));
|
dparam.setAlm_high_level(rs.getInt("alm_high_level"));
|
dparam.setAlm_low_level(rs.getInt("alm_low_level"));
|
dparam.setAlm_high_en(rs.getInt("alm_high_en"));
|
dparam.setAlm_low_en(rs.getInt("alm_low_en"));
|
dparam.setNote(rs.getString("note"));
|
list.add(dparam);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
//给设备添加参数
|
public boolean add(Object obj) {
|
List<Dev_param> list=(List<Dev_param>) obj;
|
ArrayList sql_str=new ArrayList();
|
if(list!=null&&list.size()>0){
|
for (int i=0;i<list.size();i++) {
|
Dev_param dparam=list.get(i);
|
String sql="insert into db_param.tb_dev_param(dev_id,alm_id,alm_name,alm_high_coe,alm_low_coe,alm_high_level,alm_low_level,alm_high_en,alm_low_en) " +
|
" values("+dparam.getDev_id()+","+dparam.getAlm_id()+",'"+dparam.getAlm_name()+"',"+dparam.getAlm_high_coe()+","+dparam.getAlm_low_coe()+","+
|
dparam.getAlm_high_level()+","+dparam.getAlm_low_level()+","+dparam.getAlm_high_en()+","+dparam.getAlm_low_en()+")";
|
sql_str.add(sql);
|
}
|
}
|
boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);
|
return bl;
|
}
|
//修改设备参数(单个)
|
public boolean update(Object obj) {
|
Dev_param dparam=(Dev_param) obj;
|
String sql="update db_param.tb_dev_param set alm_high_coe=?,alm_low_coe=?,alm_high_level=?,alm_low_level=?" +
|
",alm_high_en=?,alm_low_en=? where dev_id=? and alm_id=?";
|
boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{dparam.getAlm_high_coe(),dparam.getAlm_low_coe(),
|
dparam.getAlm_high_level(),dparam.getAlm_low_level(),dparam.getAlm_high_en(),dparam.getAlm_low_en(),dparam.getDev_id(),
|
dparam.getAlm_id()});
|
return bl;
|
}
|
|
public boolean del(Object obj) {
|
// TODO Auto-generated method stub
|
return false;
|
}
|
//查询所有设备的所有的告警参数
|
public List searchAll() {
|
String sql=" select distinct(db_param.tb_dev_param.num),dev_id,alm_id,alm_name,alm_high_coe,alm_low_coe,alm_high_level," +
|
" alm_low_level,alm_high_en,alm_low_en," +
|
" db_battinf.tb_battinf.stationname " +
|
" from db_param.tb_dev_param,db_battinf.tb_battinf " +
|
" where db_param.tb_dev_param.dev_id=db_battinf.tb_battinf.FBSDeviceId " +
|
" order by db_param.tb_dev_param.num asc";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Dev_param dparam=new Dev_param();
|
dparam.setNum(rs.getInt("num"));
|
dparam.setDev_id(rs.getInt("dev_id"));
|
dparam.setAlm_id(rs.getInt("alm_id"));
|
dparam.setAlm_name(rs.getString("alm_name"));
|
dparam.setAlm_high_coe(rs.getFloat("alm_high_coe"));
|
dparam.setAlm_low_coe(rs.getFloat("alm_low_coe"));
|
dparam.setAlm_high_level(rs.getInt("alm_high_level"));
|
dparam.setAlm_low_level(rs.getInt("alm_low_level"));
|
dparam.setAlm_high_en(rs.getInt("alm_high_en"));
|
dparam.setAlm_low_en(rs.getInt("alm_low_en"));
|
dparam.setNote(rs.getString("stationname"));
|
list.add(dparam);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
//根据设备id和告警类型查设备告警参数
|
public List serchByCondition(Object obj) {
|
Dev_param dparam=(Dev_param) obj;
|
String sql="";
|
String baseSql=" select distinct(db_param.tb_dev_param.num),dev_id,alm_id,alm_name,alm_high_coe,alm_low_coe,alm_high_level," +
|
" alm_low_level,alm_high_en,alm_low_en," +
|
" db_battinf.tb_battinf.stationname " +
|
" from db_param.tb_dev_param,db_battinf.tb_battinf " +
|
" where db_param.tb_dev_param.dev_id=db_battinf.tb_battinf.FBSDeviceId " +
|
" and db_battinf.tb_battinf.StationName1 like ? and db_battinf.tb_battinf.StationName2 like ? and db_battinf.tb_battinf.StationName like ? and db_battinf.tb_battinf.StationName5 like ? " ;
|
//设备id条件
|
String devSqlT=" and dev_id=? ";
|
String devSqlF=" and dev_id!=? ";
|
if(dparam.getDev_id()!=0){
|
baseSql+=devSqlT;
|
}else{
|
baseSql+=devSqlF;
|
}
|
//告警参数类型
|
String almTypeSqlT=" and alm_id=? ";
|
String almTypeSqlF=" and alm_id!=? ";
|
if(dparam.getAlm_id()!=0){
|
baseSql+=almTypeSqlT;
|
}else{
|
baseSql+=almTypeSqlF;
|
}
|
String endSql=" order by db_param.tb_dev_param.num asc ";
|
//最终的SQl
|
sql=baseSql+endSql;
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{"%"+dparam.getStationName1()+"%","%"+dparam.getStationName2()+"%","%"+dparam.getStationName()+"%","%"+dparam.getStationName5()+"%",dparam.getDev_id(),dparam.getAlm_id()}, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Dev_param dparam=new Dev_param();
|
dparam.setNum(rs.getInt("num"));
|
dparam.setDev_id(rs.getInt("dev_id"));
|
dparam.setAlm_id(rs.getInt("alm_id"));
|
dparam.setAlm_name(rs.getString("alm_name"));
|
dparam.setAlm_high_coe(rs.getFloat("alm_high_coe"));
|
dparam.setAlm_low_coe(rs.getFloat("alm_low_coe"));
|
dparam.setAlm_high_level(rs.getInt("alm_high_level"));
|
dparam.setAlm_low_level(rs.getInt("alm_low_level"));
|
dparam.setAlm_high_en(rs.getInt("alm_high_en"));
|
dparam.setAlm_low_en(rs.getInt("alm_low_en"));
|
dparam.setNote(rs.getString("stationname"));
|
list.add(dparam);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
//查询所有存在设备告警参数的机房
|
public List serchAllDevId(){
|
String sql="select distinct(dev_id),db_battinf.tb_battinf.stationname " +
|
" from db_param.tb_dev_param,db_battinf.tb_battinf " +
|
" where db_param.tb_dev_param.dev_id=db_battinf.tb_battinf.FBSDeviceId " +
|
" order by dev_id asc ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Dev_param dparam=new Dev_param();
|
dparam.setDev_id(rs.getInt("dev_id"));
|
dparam.setNote(rs.getString("stationname"));
|
list.add(dparam);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
//根据设备id查询设备对应的告警参数种类
|
public List serchByInfo(Object obj) {
|
Dev_param dparam=(Dev_param) obj;
|
String sql="select distinct(alm_id) from db_param.tb_dev_param where dev_id=? ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{dparam.getDev_id()}, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
list.add(rs.getInt("alm_id"));
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
|
return list;
|
}
|
//根据设备id查询设备所有的参数
|
public List serchParamById(Object obj) {
|
Dev_param dparam=(Dev_param) obj;
|
String sql="";
|
String baseSql=" select distinct(db_param.tb_dev_param.num),dev_id,alm_id,alm_name,alm_high_coe,alm_low_coe,alm_high_level," +
|
" alm_low_level,alm_high_en,alm_low_en," +
|
" db_battinf.tb_battinf.stationname " +
|
" from db_param.tb_dev_param,db_battinf.tb_battinf " +
|
" where db_param.tb_dev_param.dev_id=db_battinf.tb_battinf.FBSDeviceId " ;
|
//设备id条件
|
String devSqlT=" and dev_id=? ";
|
String devSqlF=" and dev_id!=? ";
|
if(dparam.getDev_id()!=0){
|
baseSql+=devSqlT;
|
}else{
|
baseSql+=devSqlF;
|
}
|
String endSql=" order by db_param.tb_dev_param.num asc ";
|
//最终的SQl
|
sql=baseSql+endSql;
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{dparam.getDev_id()}, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Dev_param dparam=new Dev_param();
|
dparam.setNum(rs.getInt("num"));
|
dparam.setDev_id(rs.getInt("dev_id"));
|
dparam.setAlm_id(rs.getInt("alm_id"));
|
dparam.setAlm_name(rs.getString("alm_name"));
|
dparam.setAlm_high_coe(rs.getFloat("alm_high_coe"));
|
dparam.setAlm_low_coe(rs.getFloat("alm_low_coe"));
|
dparam.setAlm_high_level(rs.getInt("alm_high_level"));
|
dparam.setAlm_low_level(rs.getInt("alm_low_level"));
|
dparam.setAlm_high_en(rs.getInt("alm_high_en"));
|
dparam.setAlm_low_en(rs.getInt("alm_low_en"));
|
dparam.setNote(rs.getString("stationname"));
|
list.add(dparam);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
public static void main(String[] args) {
|
Dev_paramImpl impl=new Dev_paramImpl();
|
Dev_param dparam=new Dev_param();
|
dparam.setDev_id(618500001);
|
dparam.setAlm_id(0);
|
dparam.setStationName("城市-区县-武汉源暢实验室-61850设备");
|
dparam.setStationName1("");
|
dparam.setStationName2("");
|
List list=impl.serchByCondition(dparam);
|
System.out.println(list.size());
|
}
|
}
|
