package com.fgkj.dao.impl.bts61850;
|
|
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.db.DBUtil;
|
import com.fgkj.dto.BTS_61850;
|
import com.fgkj.dto.BTS_61850_setparam;
|
import com.fgkj.dto.BTS_61850_state;
|
import com.fgkj.dto.BattInf;
|
|
public class BTS_61850_setparamImpl 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;
|
}
|
//根据设备id修改参数
|
public boolean update(Object obj) {
|
BTS_61850_setparam bts=(BTS_61850_setparam) obj;
|
String sql="update db_ram_db.tb_bts_61850_setparm set set_discurr=?,set_distime=?" +
|
",set_discap=?,set_tep_dis=?,set_groupvol_low=?,set_monvollow=?,testcmd=? " +
|
" where FBSDeviceId=? ";
|
boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{
|
bts.getSet_discurr(),bts.getSet_distime(),bts.getSet_discap(),bts.getSet_tep_dis(),bts.getSet_groupvol_low()
|
,bts.getSet_monvollow(),bts.getTestcmd(),bts.getFBSDeviceId()});
|
return bl;
|
}
|
public boolean del(Object obj) {
|
// TODO Auto-generated method stub
|
return false;
|
}
|
|
public List searchAll() {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
|
//根据机房信息查询参数
|
public List serchByCondition(Object obj) {
|
BattInf binf=(BattInf) obj;
|
String sql="select db_battinf.tb_battinf.battgroupid,db_battinf.tb_battinf.StationName,db_battinf.tb_battinf.FBSDeviceId,db_battinf.tb_battinf.FBSDeviceIp,db_battinf.tb_battinf.BattGroupName" +
|
",db_battinf.tb_battinf.MonCount,db_battinf.tb_battinf.MonVolStd,db_battinf.tb_battinf.MonCapStd,db_battinf.tb_battinf.GroupIndexInFBSDevice " +
|
",db_ram_db.tb_bts_61850_setparm.FBSDeviceId,db_ram_db.tb_bts_61850_setparm.batt_test,db_ram_db.tb_bts_61850_setparm.set_time,db_ram_db.tb_bts_61850_setparm.set_discurr,db_ram_db.tb_bts_61850_setparm.set_distime" +
|
",db_ram_db.tb_bts_61850_setparm.set_discap,db_ram_db.tb_bts_61850_setparm.set_tep_dis,db_ram_db.tb_bts_61850_setparm.set_groupvol_low,db_ram_db.tb_bts_61850_setparm.set_monvollow,db_ram_db.tb_bts_61850_setparm.testcmd" +
|
",db_ram_db.tb_bts_61850_state.stc_workstate,db_ram_db.tb_bts_61850_state.dev_captest_online,db_ram_db.tb_bts_61850_state.dev_captest_groupvol,db_ram_db.tb_bts_61850_state.dev_commcount,db_ram_db.tb_bts_61850_state.timelong " +
|
" from db_battinf.tb_battinf " +
|
" LEFT OUTER JOIN db_ram_db.tb_bts_61850_setparm on db_ram_db.tb_bts_61850_setparm.FBSDeviceId=db_battinf.tb_battinf.FBSDeviceId " +
|
" LEFT OUTER JOIN db_ram_db.tb_bts_61850_state on db_ram_db.tb_bts_61850_state.FBSDeviceId=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()){
|
BTS_61850 bts=new BTS_61850();
|
BattInf binf=new BattInf();
|
binf.setBattGroupId(rs.getInt("battGroupId"));
|
binf.setStationName(rs.getString("stationName"));
|
binf.setFBSDeviceId(rs.getInt("fBSDeviceId"));
|
binf.setFbsDeviceIp(rs.getString("fbsDeviceIp"));
|
binf.setBattGroupName(rs.getString("battGroupName"));
|
binf.setMonCount(rs.getInt("monCount"));
|
binf.setMonVolStd(rs.getFloat("monVolStd"));
|
binf.setMonCapStd(rs.getFloat("monCapStd"));
|
binf.setGroupIndexInFBSDevice(rs.getInt("groupIndexInFBSDevice"));
|
bts.setBinf(binf);
|
|
BTS_61850_setparam bts_param=new BTS_61850_setparam();
|
bts_param.setFBSDeviceId(rs.getInt("FBSDeviceId"));
|
bts_param.setBatt_test(rs.getInt("batt_test"));
|
bts_param.setSet_time(rs.getTimestamp("set_time"));
|
bts_param.setSet_discurr(rs.getFloat("set_discurr"));
|
bts_param.setSet_distime(rs.getFloat("set_distime"));
|
bts_param.setSet_discap(rs.getFloat("set_discap"));
|
bts_param.setSet_tep_dis(rs.getFloat("set_tep_dis"));
|
bts_param.setSet_groupvol_low(rs.getFloat("set_groupvol_low"));
|
bts_param.setSet_monvollow(rs.getFloat("set_monvollow"));
|
bts_param.setTestcmd(rs.getInt("testcmd"));
|
bts.setBts_param(bts_param);
|
|
BTS_61850_state bts_state=new BTS_61850_state();
|
bts_state.setStc_workstate(rs.getInt("stc_workstate"));
|
bts_state.setDev_captest_online(rs.getFloat("dev_captest_online"));
|
bts_state.setDev_captest_groupvol(rs.getFloat("dev_captest_groupvol"));
|
bts_state.setDev_commcount(rs.getInt("dev_commcount"));
|
bts_state.setTimelong(rs.getInt("timelong"));
|
bts.setBts_state(bts_state);
|
|
list.add(bts);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
//机房命令操作设备时的cmd和ack校验
|
public boolean sendCmdTo61850Dev(int cmd,int dev_id)
|
{
|
int m_cmd = cmd;
|
int m_cmd_ack = cmd;
|
switch(m_cmd) {
|
case FBS9100_ComBase.CMD_61850_START_HR: m_cmd_ack = FBS9100_ComBase.CMD_61850_START_ACK; break;
|
case FBS9100_ComBase.CMD_61850_START_RES: m_cmd_ack = FBS9100_ComBase.CMD_61850_START_ACK; break;
|
case FBS9100_ComBase.CMD_61850_STOP: m_cmd_ack = FBS9100_ComBase.CMD_61850_STOP_ACK; break;
|
default: return false;
|
}
|
boolean res_exe = false;
|
String sql = "UPDATE db_ram_db.tb_bts_61850_setparm SET "
|
+ " batt_test=? "
|
+ " WHERE FBSDeviceId=? ";
|
Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{m_cmd,dev_id});
|
if(true == bl)
|
{
|
sql = "SELECT batt_test FROM db_ram_db.tb_bts_61850_setparm "+
|
" WHERE FBSDeviceId="+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("batt_test") == 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;
|
}
|
//根据dev_id查询弹出框中的数据
|
public List serchbyDev_id(Object obj) {
|
BTS_61850_setparam bts_setparam=(BTS_61850_setparam) obj;
|
String sql="select db_battinf.tb_battinf.battgroupid,db_battinf.tb_battinf.StationName,db_battinf.tb_battinf.FBSDeviceId,db_battinf.tb_battinf.FBSDeviceIp,db_battinf.tb_battinf.BattGroupName" +
|
",db_battinf.tb_battinf.MonCount,db_battinf.tb_battinf.MonVolStd,db_battinf.tb_battinf.MonCapStd,db_battinf.tb_battinf.GroupIndexInFBSDevice " +
|
",db_ram_db.tb_bts_61850_setparm.FBSDeviceId,db_ram_db.tb_bts_61850_setparm.batt_test,db_ram_db.tb_bts_61850_setparm.set_time,db_ram_db.tb_bts_61850_setparm.set_discurr,db_ram_db.tb_bts_61850_setparm.set_distime" +
|
",db_ram_db.tb_bts_61850_setparm.set_discap,db_ram_db.tb_bts_61850_setparm.set_tep_dis,db_ram_db.tb_bts_61850_setparm.set_groupvol_low,db_ram_db.tb_bts_61850_setparm.set_monvollow,db_ram_db.tb_bts_61850_setparm.testcmd" +
|
" from db_battinf.tb_battinf " +
|
" LEFT OUTER JOIN db_ram_db.tb_bts_61850_setparm on db_ram_db.tb_bts_61850_setparm.FBSDeviceId=db_battinf.tb_battinf.FBSDeviceId " +
|
" where db_ram_db.tb_bts_61850_setparm.FBSDeviceId=? ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{bts_setparam.getFBSDeviceId()}, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
BTS_61850 bts=new BTS_61850();
|
BattInf binf=new BattInf();
|
binf.setBattGroupId(rs.getInt("battGroupId"));
|
binf.setStationName(rs.getString("stationName"));
|
binf.setFBSDeviceId(rs.getInt("fBSDeviceId"));
|
binf.setFbsDeviceIp(rs.getString("fbsDeviceIp"));
|
binf.setBattGroupName(rs.getString("battGroupName"));
|
binf.setMonCount(rs.getInt("monCount"));
|
binf.setMonVolStd(rs.getFloat("monVolStd"));
|
binf.setMonCapStd(rs.getFloat("monCapStd"));
|
binf.setGroupIndexInFBSDevice(rs.getInt("groupIndexInFBSDevice"));
|
bts.setBinf(binf);
|
|
BTS_61850_setparam bts_param=new BTS_61850_setparam();
|
bts_param.setFBSDeviceId(rs.getInt("FBSDeviceId"));
|
bts_param.setBatt_test(rs.getInt("batt_test"));
|
bts_param.setSet_time(rs.getTimestamp("set_time"));
|
bts_param.setSet_discurr(rs.getFloat("set_discurr"));
|
bts_param.setSet_distime(rs.getFloat("set_distime"));
|
bts_param.setSet_discap(rs.getFloat("set_discap"));
|
bts_param.setSet_tep_dis(rs.getFloat("set_tep_dis"));
|
bts_param.setSet_groupvol_low(rs.getFloat("set_groupvol_low"));
|
bts_param.setSet_monvollow(rs.getFloat("set_monvollow"));
|
bts_param.setTestcmd(rs.getInt("testcmd"));
|
bts.setBts_param(bts_param);
|
|
list.add(bts);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
public List serchByInfo(Object obj) {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
|
}
|
