package com.fgkj.dao.impl.Ld9;
|
|
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.BattInf;
|
import com.fgkj.dto.LD9;
|
import com.fgkj.dto.LD9_setparam;
|
import com.fgkj.dto.LD9_state;
|
import com.fgkj.dto.ram.FBS9100;
|
import com.fgkj.dto.ram.Fbs9100_setparam;
|
|
public class LD9_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) {
|
LD9_setparam ld9=(LD9_setparam) obj;
|
String sql="update db_ram_db.tb_LD9_setparam set param_teststart_batt_num=?,param_cap=?,param_discharge_curr=?" +
|
",param_mon_curr_high=?,param_charge_curr=?,param_mon_curr_low=?,param_online_vol=?,param_charge_curr_low=?" +
|
",param_charge_cap_low=?,param_online_vol_recover=?,param_junheng_model=?,param_cap_low=?,param_tmp_high=?,param_res_high=? where dev_id=? ";
|
boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{ld9.getParam_teststart_batt_num()
|
,ld9.getParam_cap(),ld9.getParam_discharge_curr(),ld9.getParam_mon_curr_high(),ld9.getParam_charge_curr(),ld9.getParam_mon_curr_low()
|
,ld9.getParam_online_vol(),ld9.getParam_charge_curr_low(),ld9.getParam_charge_cap_low(),ld9.getParam_online_vol_recover(),ld9.getParam_junheng_model()
|
,ld9.getParam_cap_low(),ld9.getParam_tmp_high(),ld9.getParam_res_high(),ld9.getDev_id()});
|
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_LD9_setparam.dev_id,db_ram_db.tb_LD9_setparam.op_cmd,db_ram_db.tb_LD9_setparam.param_teststart_batt_num,db_ram_db.tb_LD9_setparam.param_cap,param_discharge_curr" +
|
",db_ram_db.tb_LD9_setparam.param_mon_curr_high,db_ram_db.tb_LD9_setparam.param_charge_curr,db_ram_db.tb_LD9_setparam.param_mon_curr_low,db_ram_db.tb_LD9_setparam.param_online_vol" +
|
",db_ram_db.tb_LD9_setparam.param_charge_curr_low,db_ram_db.tb_LD9_setparam.param_charge_cap_low,db_ram_db.tb_LD9_setparam.param_online_vol_recover,db_ram_db.tb_LD9_setparam.param_module_address" +
|
",db_ram_db.tb_LD9_setparam.param_junheng_model" +
|
",db_ram_db.tb_LD9_state.sys_state,db_ram_db.tb_LD9_state.sys_online_vol,db_ram_db.tb_LD9_state.sys_group_vol,db_ram_db.tb_LD9_state.dev_commcount,db_ram_db.tb_LD9_state.timelong " +
|
" from db_battinf.tb_battinf " +
|
" LEFT OUTER JOIN db_ram_db.tb_LD9_setparam on db_ram_db.tb_LD9_setparam.dev_id=db_battinf.tb_battinf.FBSDeviceId " +
|
" LEFT OUTER JOIN db_ram_db.tb_LD9_state on db_ram_db.tb_LD9_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()){
|
LD9 ld9=new LD9();
|
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"));
|
ld9.setBinf(binf);
|
|
LD9_setparam ld9_param=new LD9_setparam();
|
ld9_param.setDev_id(rs.getInt("dev_id"));
|
ld9_param.setOp_cmd(rs.getInt("op_cmd"));
|
ld9_param.setParam_teststart_batt_num(rs.getInt("param_teststart_batt_num"));
|
ld9_param.setParam_cap(rs.getInt("param_cap"));
|
ld9_param.setParam_discharge_curr(rs.getFloat("param_discharge_curr"));
|
ld9_param.setParam_mon_curr_high(rs.getFloat("param_mon_curr_high"));
|
ld9_param.setParam_charge_curr(rs.getFloat("param_charge_curr"));
|
ld9_param.setParam_mon_curr_low(rs.getFloat("param_mon_curr_low"));
|
ld9_param.setParam_online_vol(rs.getFloat("param_online_vol"));
|
ld9_param.setParam_charge_curr_low(rs.getFloat("param_charge_curr_low"));
|
ld9_param.setParam_charge_cap_low(rs.getFloat("param_charge_cap_low"));
|
ld9_param.setParam_online_vol_recover(rs.getInt("param_online_vol_recover"));
|
ld9_param.setParam_module_address(rs.getInt("param_module_address"));
|
ld9_param.setParam_junheng_model(rs.getInt("param_junheng_model"));
|
ld9.setLd9_param(ld9_param);
|
|
LD9_state ld9_state=new LD9_state();
|
ld9_state.setSys_state(rs.getInt("sys_state"));
|
ld9_state.setSys_online_vol(rs.getFloat("sys_online_vol"));
|
ld9_state.setSys_group_vol(rs.getFloat("sys_group_vol"));
|
ld9_state.setDev_commcount(rs.getInt("dev_commcount"));
|
ld9_state.setTimelong(rs.getInt("timelong"));
|
list.add(ld9);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
//机房命令操作设备时的cmd和ack校验
|
public boolean sendCmdToLd9Dev(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;
|
case FBS9100_ComBase.CMD_SetDischargeParm: m_cmd_ack = FBS9100_ComBase.CMD_SetDischargeParmAck; break;
|
case FBS9100_ComBase.CMD_StartRES: m_cmd_ack = FBS9100_ComBase.CMD_StartRES_ACK; break;
|
case FBS9100_ComBase.CMD_GetDischargeParm: m_cmd_ack = FBS9100_ComBase.CMD_GetDischargeParmAck; break;
|
default: return false;
|
}
|
boolean res_exe = false;
|
String sql = "UPDATE db_ram_db.tb_LD9_setparam 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_ld9_setparam "+
|
" 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;
|
}
|
//根据dev_id查询弹出框中的数据
|
public List serchbyDev_id(Object obj) {
|
LD9_setparam ld9=(LD9_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_ram_db.tb_LD9_setparam.dev_id,db_ram_db.tb_LD9_setparam.op_cmd,db_ram_db.tb_LD9_setparam.param_teststart_batt_num,db_ram_db.tb_LD9_setparam.param_cap,param_discharge_curr" +
|
",db_ram_db.tb_LD9_setparam.param_mon_curr_high,db_ram_db.tb_LD9_setparam.param_charge_curr,db_ram_db.tb_LD9_setparam.param_mon_curr_low,db_ram_db.tb_LD9_setparam.param_online_vol" +
|
",db_ram_db.tb_LD9_setparam.param_charge_curr_low,db_ram_db.tb_LD9_setparam.param_charge_cap_low,db_ram_db.tb_LD9_setparam.param_online_vol_recover,db_ram_db.tb_LD9_setparam.param_module_address" +
|
",db_ram_db.tb_LD9_setparam.param_junheng_model,db_ram_db.tb_LD9_setparam.param_cap_low,db_ram_db.tb_LD9_setparam.param_datasource,db_ram_db.tb_LD9_setparam.param_res_args,db_ram_db.tb_LD9_setparam.param_tmp_high,db_ram_db.tb_LD9_setparam.param_res_high " +
|
" from db_battinf.tb_battinf " +
|
" LEFT OUTER JOIN db_ram_db.tb_LD9_setparam on db_ram_db.tb_LD9_setparam.dev_id=db_battinf.tb_battinf.FBSDeviceId " +
|
" where db_ram_db.tb_LD9_setparam.dev_id=? ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{ld9.getDev_id()}, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
LD9 ld9=new LD9();
|
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"));
|
ld9.setBinf(binf);
|
|
LD9_setparam ld9_param=new LD9_setparam();
|
ld9_param.setDev_id(rs.getInt("dev_id"));
|
ld9_param.setOp_cmd(rs.getInt("op_cmd"));
|
ld9_param.setParam_teststart_batt_num(rs.getInt("param_teststart_batt_num"));
|
ld9_param.setParam_cap(rs.getInt("param_cap"));
|
ld9_param.setParam_discharge_curr(rs.getFloat("param_discharge_curr"));
|
ld9_param.setParam_mon_curr_high(rs.getFloat("param_mon_curr_high"));
|
ld9_param.setParam_charge_curr(rs.getFloat("param_charge_curr"));
|
ld9_param.setParam_mon_curr_low(rs.getFloat("param_mon_curr_low"));
|
ld9_param.setParam_online_vol(rs.getFloat("param_online_vol"));
|
ld9_param.setParam_charge_curr_low(rs.getFloat("param_charge_curr_low"));
|
ld9_param.setParam_charge_cap_low(rs.getFloat("param_charge_cap_low"));
|
ld9_param.setParam_online_vol_recover(rs.getInt("param_online_vol_recover"));
|
ld9_param.setParam_module_address(rs.getInt("param_module_address"));
|
ld9_param.setParam_junheng_model(rs.getInt("param_junheng_model"));
|
ld9_param.setParam_cap_low(rs.getFloat("param_cap_low"));
|
ld9_param.setParam_datasource(rs.getInt("param_datasource"));
|
ld9_param.setParam_res_args(rs.getInt("param_res_args"));
|
ld9_param.setParam_tmp_high(rs.getFloat("param_tmp_high"));
|
ld9_param.setParam_res_high(rs.getFloat("param_res_high"));
|
ld9.setLd9_param(ld9_param);
|
|
list.add(ld9);
|
}
|
} 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;
|
}
|
|
}
|
