package com.fgkj.dao.impl.ram;
|
|
import java.sql.Connection;
|
import java.sql.PreparedStatement;
|
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.FBS9100_ComBase;
|
import com.fgkj.dao.LimitNumberFactory;
|
import com.fgkj.dao.UinfDaoFactory;
|
import com.fgkj.db.DBUtil;
|
import com.fgkj.db.IDatabaseName;
|
import com.fgkj.dto.BattInf;
|
import com.fgkj.dto.Page;
|
import com.fgkj.dto.User;
|
import com.fgkj.dto.User_inf;
|
import com.fgkj.dto.User_log;
|
import com.fgkj.dto.ram.FBS9100;
|
import com.fgkj.dto.ram.Fbs9100_setparam;
|
import com.fgkj.dto.ram.Fbs9100_state;
|
import com.fgkj.dto.ram.Fbs9600_state;
|
import com.fgkj.services.User_logService;
|
|
public class Fbs9600_stateImpl implements BaseDAO,CallBack{
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Fbs9600_state fstate=new Fbs9600_state();
|
fstate.setNum(rs.getInt("num"));
|
fstate.setDev_ip(rs.getString("dev_ip"));
|
fstate.setDev_id(rs.getInt("dev_id"));
|
fstate.setOp_cmd(rs.getInt("op_cmd"));
|
fstate.setDev_workstate(rs.getInt("dev_workstate"));
|
fstate.setDev_alarmstate(rs.getInt("dev_alarmstate"));
|
fstate.setDev_commcount(rs.getInt("dev_commcount"));
|
fstate.setDev_errcommcount(rs.getInt("dev_errcommcount"));
|
list.add(fstate);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
|
public boolean add(Object obj) {
|
Fbs9600_state fs=(Fbs9600_state) obj;
|
String sql="insert into db_ram_db.tb_Fbs9600_state(dev_ip,dev_id,op_cmd,dev_workstate,dev_alarmstate,dev_commcount," +
|
"dev_errcommcount) values(?,?,?,?,?,?,?)";
|
Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{fs.getDev_ip(),fs.getDev_id(),
|
fs.getOp_cmd(),fs.getDev_workstate(),fs.getDev_alarmstate(),fs.getDev_commcount(),fs.getDev_errcommcount()});
|
return bl;
|
}
|
//fbs显示屏启动放电
|
public boolean update(Object obj) {
|
Fbs9600_state fs=(Fbs9600_state) obj;
|
String sql="update db_ram_db.tb_Fbs9600_state set op_cmd=? " +
|
" where dev_id=?";
|
Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{
|
fs.getOp_cmd(),fs.getDev_id()});
|
return bl;
|
}
|
//fbs9600设备内阻测试
|
public boolean updatePro(Object obj) {
|
List<Fbs9600_state> list=(List<Fbs9600_state>) obj;
|
ArrayList sql_str=new ArrayList();
|
List<User_log> listU=new ArrayList<User_log>();//存放user_log
|
for (Fbs9600_state fstate : list) {
|
if(fstate.getOp_cmd()==FBS9100_ComBase.CMD_9600_Start){
|
String sql="update db_ram_db.tb_Fbs9600_state set op_cmd="+fstate.getOp_cmd()+" " +
|
" where dev_id="+fstate.getDev_id();
|
sql_str.add(sql);
|
}
|
{
|
String msg="启动"+fstate.getDev_id()+"的设备内阻测试";
|
User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Increase, msg);
|
listU.add(ulog);
|
}
|
|
}
|
boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);
|
(new User_logService()).addPro(listU);//将用户的操作记录下来
|
return bl;
|
}
|
|
public boolean del(Object obj) {
|
Fbs9600_state fs=(Fbs9600_state) obj;
|
String sql="delete from db_ram_db.tb_Fbs9600_state where num=?";
|
Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{fs.getNum()});
|
return bl;
|
}
|
//FBS9600设备内阻测试显示全部9600设备的信息
|
public List searchByUid(Object obj) {
|
User_inf uinf=(User_inf) obj;
|
String sql="";
|
String baseSql="select distinct tb_Fbs9600_state.num,dev_ip,dev_id,op_cmd,dev_workstate,dev_alarmstate,dev_commcount,dev_errcommcount, " +
|
" db_battinf.tb_battinf.StationName,db_battinf.tb_battinf.FbsDeviceName " +
|
" from db_ram_db.tb_Fbs9600_state " +
|
" left outer join db_battinf.tb_battinf ON tb_fbs9600_state.dev_id=db_battinf.tb_battinf.FBSDeviceId " +
|
" where tb_fbs9600_state.dev_id in(select distinct db_battinf.tb_battinf.FBSDeviceId " +
|
" 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=? ) ";
|
String F9600sql=" and tb_fbs9600_state.dev_id like '%9600%'";//支持9600设备
|
String F9616sql=" or tb_fbs9600_state.dev_id like '%9616%'";//支持9600设备
|
sql=baseSql+F9600sql+F9616sql;
|
//System.out.println(sql);
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{uinf.getUId()}, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Fbs9600_state fstate=new Fbs9600_state();
|
fstate.setNum(rs.getInt("num"));
|
fstate.setDev_ip(rs.getString("dev_ip"));
|
fstate.setDev_id(rs.getInt("dev_id"));
|
fstate.setOp_cmd(rs.getInt("op_cmd"));
|
fstate.setDev_workstate(rs.getInt("dev_workstate"));
|
fstate.setDev_alarmstate(rs.getInt("dev_alarmstate"));
|
fstate.setDev_commcount(rs.getInt("dev_commcount"));
|
fstate.setDev_errcommcount(rs.getInt("dev_errcommcount"));
|
|
fstate.setStationName(rs.getString("stationName"));
|
fstate.setDeviceName("FBS9600");
|
list.add(fstate);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
//11.1FBS9100设备通信状态查询
|
/*
|
* fbs9100：op_cmd:0:全部；1：fbs9100,2:fbs9600
|
* dev_errcommcount;0:通讯正常，1：通讯中断，100：全部*/
|
public List serchByCondition(Object obj) {
|
Fbs9600_state fs=(Fbs9600_state) obj;
|
Page page=fs.getPage();
|
Connection conn=DBUtil.getConn();
|
String numberSql=" SELECT FOUND_ROWS() number";
|
String sql="";
|
String baseSql="select SQL_CALC_FOUND_ROWS distinct tb_Fbs9600_state.num,dev_ip,dev_id,op_cmd,dev_workstate,dev_alarmstate,dev_commcount,dev_errcommcount, " +
|
"db_battinf.tb_battinf.StationName,db_battinf.tb_battinf.FbsDeviceName," +
|
"COUNT(DISTINCT BattGroupId) as cnt " +
|
"from db_ram_db.tb_Fbs9600_state " +
|
"left outer join db_battinf.tb_battinf ON tb_fbs9600_state.dev_id=db_battinf.tb_battinf.FBSDeviceId " +
|
"where ";
|
//通讯中断
|
String comSqlT=" dev_errcommcount=0 ";
|
String comSqlF=" dev_errcommcount>0 ";
|
String comSqlA=" dev_errcommcount>=0 ";
|
if(fs.getDev_errcommcount()==0){
|
baseSql+=comSqlT;
|
}else if(fs.getDev_errcommcount()==1){
|
baseSql+=comSqlF;
|
}else if(fs.getDev_errcommcount()==100){
|
baseSql+=comSqlA;
|
}
|
//判断是否为管理的机房
|
String stationSql=" and dev_id in(select distinct db_battinf.tb_battinf.FBSDeviceId " +
|
" 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 tb_fbs9600_state.dev_id ";
|
//分页
|
String limitSql=" limit ?,? ";
|
//最后结果
|
sql=baseSql+groupSql+limitSql;
|
//System.out.println(sql);
|
List<Fbs9600_state> list=DAOHelper.executeQueryLimit(sql, conn, new Object[]{fs.getNum(),(page.getPageCurr()-1)*page.getPageSize(),page.getPageSize()}, new CallBack() {
|
List list=new ArrayList();
|
public List getResults(ResultSet rs) {
|
try {
|
while(rs.next()){
|
Fbs9600_state fstate=new Fbs9600_state();
|
|
fstate.setNum(rs.getInt("cnt")); //关联电池组
|
fstate.setDev_ip(rs.getString("dev_ip"));
|
fstate.setDev_id(rs.getInt("dev_id"));
|
fstate.setOp_cmd(rs.getInt("op_cmd"));
|
fstate.setDev_workstate(rs.getInt("dev_workstate"));
|
fstate.setDev_alarmstate(rs.getInt("dev_alarmstate"));
|
fstate.setDev_commcount(rs.getInt("dev_commcount"));
|
fstate.setDev_errcommcount(rs.getInt("dev_errcommcount"));
|
|
fstate.setStationName(rs.getString("stationName"));
|
fstate.setDeviceName("FBS9600");
|
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;
|
}
|
|
//机房命令操作设备时的cmd和ack校验
|
public boolean sendCmdToFBS9600Dev(int cmd,int dev_id)
|
{
|
int m_cmd = cmd;
|
int m_cmd_ack = cmd;
|
switch(m_cmd) {
|
case FBS9100_ComBase.CMD_Start: m_cmd_ack = FBS9100_ComBase.CMD_StartAck; break;
|
case FBS9100_ComBase.CMD_Stop: m_cmd_ack = FBS9100_ComBase.CMD_StopAck; break;
|
default: return false;
|
}
|
boolean res_exe = false;
|
String sql = "UPDATE db_ram_db.tb_fbs9600_state SET "
|
+ " op_cmd=? "
|
+ " WHERE dev_id=? ";
|
Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{m_cmd,dev_id});
|
if(true == bl)
|
{
|
sql = "SELECT op_cmd FROM db_ram_db.tb_fbs9600_state "+
|
" WHERE dev_id="+dev_id;
|
Connection conn=DBUtil.getConn();
|
PreparedStatement ps = null;
|
ResultSet rs = null;
|
for(int n=0; n<20; n++)
|
{
|
try {
|
ps = conn.prepareStatement(sql);
|
rs=ps.executeQuery();
|
if(rs.next())
|
{
|
if(rs.getInt("op_cmd") == m_cmd_ack)
|
{
|
res_exe = true;
|
break;
|
}
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
|
try {
|
Thread.sleep(250);
|
} catch (InterruptedException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
}
|
DBUtil.close(rs, ps, conn);
|
}
|
return res_exe;
|
}
|
|
//放电测试添加fbs9600设备的添加电池组的操作
|
public List serchByInfo(Object obj) {
|
BattInf binf=(BattInf) obj;
|
String sql="select db_battinf.tb_battinf.battgroupid,db_battinf.tb_battinf.StationName,db_battinf.tb_battinf.StationName5,db_battinf.tb_battinf.FBSDeviceId,db_battinf.tb_battinf.FBSDeviceIp,FbsDeviceName,db_battinf.tb_battinf.BattGroupName" +
|
",db_battinf.tb_battinf.GroupIndexInFBSDevice,db_battinf.tb_battinf.MonCount,db_battinf.tb_battinf.MonVolStd,db_battinf.tb_battinf.MonCapStd" +
|
",db_ram_db.tb_fbs9600_state.dev_ip,db_ram_db.tb_fbs9600_state.dev_id,db_ram_db.tb_fbs9600_state.op_cmd" +
|
",db_ram_db.tb_fbs9600_state.dev_commcount,db_ram_db.tb_fbs9600_state.dev_errcommcount " +
|
" FROM db_battinf.tb_battinf " +
|
" LEFT OUTER JOIN db_ram_db.tb_fbs9600_state on db_ram_db.tb_fbs9600_state.dev_id=db_battinf.tb_battinf.FBSDeviceId " +
|
" where db_battinf.tb_battinf.StationName1 like ? and db_battinf.tb_battinf.StationName LIKE ? " +
|
" and db_battinf.tb_battinf.battgroupid=? ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{"%"+binf.getStationName1()+"%","%"+binf.getStationName()+"%",binf.getBattGroupId()}, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Fbs9600_state fstate=new Fbs9600_state();
|
fstate.setBattgroupid(rs.getInt("battgroupid"));
|
fstate.setDev_ip(rs.getString("dev_ip"));
|
fstate.setDev_id(rs.getInt("dev_id"));
|
fstate.setOp_cmd(rs.getInt("op_cmd"));
|
fstate.setDev_commcount(rs.getInt("dev_commcount"));
|
fstate.setDev_errcommcount(rs.getInt("dev_errcommcount"));
|
fstate.setStationName(rs.getString("stationName"));
|
fstate.setStationName5(rs.getString("stationName5"));
|
fstate.setDeviceName(rs.getString("FbsDeviceName"));
|
fstate.setBattgroupName(rs.getString("battgroupName"));
|
fstate.setGroupIndexInFBSDevice(rs.getInt("groupIndexInFBSDevice"));
|
list.add(fstate);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
public static void main(String[] args) {
|
Fbs9600_stateImpl fi=new Fbs9600_stateImpl();
|
/*Fbs9600_state fs=new Fbs9600_state();
|
fs.setNum(5)*/;
|
|
Fbs9100_state fs=new Fbs9100_state();
|
fs.setNum(5);
|
fs.setDev_errcommcount(0);
|
|
/*List<Fbs9600_state> list=fi.serchByCondition(fs);
|
System.out.println(list.size());
|
for(Fbs9600_state f:list){
|
System.out.println(f);
|
}*/
|
User_inf uinf=new User_inf();
|
uinf.setUId(1002);
|
List<Fbs9600_state> list=fi.searchByUid(uinf);
|
System.out.println(list.size());
|
for(Fbs9600_state f:list){
|
System.out.println(f);
|
}
|
}
|
|
public List searchAll() {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
|
}
|
