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 sun.security.jca.GetInstance;

import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.BattinfGroupFactory;
import com.fgkj.dao.CallBack;
import com.fgkj.dao.DAOHelper;
import com.fgkj.dao.FBS9100_ComBase;
import com.fgkj.dao.UinfDaoFactory;
import com.fgkj.db.DBUtil;
import com.fgkj.db.IDatabaseName;
import com.fgkj.dto.BattInf;
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.Fbs9100_sysparam;
import com.fgkj.services.User_logService;

public class Fbs9100_setparamImpl implements BaseDAO,CallBack{

	public List getResults(ResultSet rs) {
		List list=new ArrayList();
		try {
			while(rs.next()){
				Fbs9100_setparam fsetparam=new Fbs9100_setparam();
				fsetparam.setNum(rs.getInt("num"));
				fsetparam.setDev_ip(rs.getString("dev_ip"));
				fsetparam.setDev_id(rs.getInt("dev_id"));
				fsetparam.setOp_cmd(rs.getInt("op_cmd"));
				fsetparam.setTestCmd(rs.getInt("testCmd"));
				fsetparam.setHourRate(rs.getInt("HourRate"));
				fsetparam.setDisCurr(rs.getFloat("DisCurr"));
				fsetparam.setDisCap(rs.getFloat("DisCap"));
				fsetparam.setDisTime(rs.getInt("DisTime"));
				fsetparam.setGroupVol_Low(rs.getFloat("groupVol_Low"));
				fsetparam.setMonomerVol_Low(rs.getFloat("monomerVol_Low"));
				fsetparam.setMonomerLowCount(rs.getInt("monomerLowCount"));
			    fsetparam.setBattGroupNum(rs.getInt("battGroupNum"));
			    fsetparam.setOnlineLowAction(rs.getInt("onlineLowAction"));
			    fsetparam.setDCVolHighLimit(rs.getFloat("dCVolHighLimit"));
			    fsetparam.setChargeCurrSet(rs.getFloat("chargeCurrSet"));
			    list.add(fsetparam);
			    
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return list;
	}
   
	//将需要放电的数据添加放电参数表中
	public boolean add(Object obj) {
		Fbs9100_setparam fsparam=(Fbs9100_setparam) obj;
		String sql="insert into db_ram_db.tb_Fbs9100_setparam(dev_ip,dev_id,op_cmd,testCmd,HourRate," +
				"DisCurr,DisCap,DisTime,groupVol_Low,monomerVol_Low,monomerLowCount,battGroupNum," +
				"onlineLowAction,dCVolHighLimit,chargeCurrSet) values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
		Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{fsparam.getDev_ip(),
				fsparam.getDev_id(),fsparam.getOp_cmd(),fsparam.getTestCmd(),fsparam.getHourRate(),fsparam.getDisCurr(),fsparam.getDisCap(),fsparam.getDisTime(),
				fsparam.getGroupVol_Low(),fsparam.getMonomerVol_Low(),fsparam.getMonomerLowCount(),fsparam.getBattGroupNum(),fsparam.getOnlineLowAction(),
				fsparam.getDCVolHighLimit(),fsparam.getChargeCurrSet()});
	    
		return bl;
	}
	
	//修改放电参数表中
	public boolean update(Object obj) {
		Fbs9100_setparam fs=(Fbs9100_setparam) obj;
		String sql="update db_ram_db.tb_Fbs9100_setparam set testCmd=?,HourRate=?," +
				"DisCurr=?,DisCap=?,DisTime=?,groupVol_Low=?,monomerVol_Low=?,monomerLowCount=?,battGroupNum=?," +
				"onlineVolLowAction=?,dCVolHighLimit=?,chargeCurrSet=?,MonomerTmp_High=? where dev_id=?";
		Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{
			fs.getTestCmd(),fs.getHourRate(),fs.getDisCurr(),fs.getDisCap(),fs.getDisTime(),
			fs.getGroupVol_Low(),fs.getMonomerVol_Low(),fs.getMonomerLowCount(),fs.getBattGroupNum(),fs.getOnlineLowAction(),
			fs.getDCVolHighLimit(),fs.getChargeCurrSet(),fs.getMonomerTmp_High(),fs.getDev_id()});
		return bl;
	}
	//批量设置放电参数
	public boolean updatePro(Object obj) {
		List<Fbs9100_setparam> list=(List<Fbs9100_setparam>) obj;
		ArrayList sql_str=new ArrayList();
		List<User_log> listU=new ArrayList<User_log>();//存放user_log
		if(list!=null&&list.size()>0){
			for (int i = 0; i < list.size(); i++) {
				Fbs9100_setparam fs=list.get(i);
				String sql="update db_ram_db.tb_Fbs9100_setparam set op_cmd="+fs.getOp_cmd()+",testCmd="+fs.getTestCmd()+",HourRate="+fs.getHourRate()+"," +
						"DisCurr="+fs.getDisCurr()+",DisCap="+fs.getDisCap()+",DisTime="+fs.getDisTime()+",groupVol_Low="+fs.getGroupVol_Low()+",monomerVol_Low="+fs.getMonomerVol_Low()+","
					  + "monomerLowCount="+fs.getMonomerLowCount()+",battGroupNum="+fs.getBattGroupNum()+"," +
						"onlineVolLowAction="+fs.getOnlineLowAction()+",dCVolHighLimit="+fs.getDCVolHighLimit()+",chargeCurrSet="+fs.getChargeCurrSet()+",MonomerTmp_High="+fs.getMonomerTmp_High()+" where dev_id="+fs.getDev_id();
				sql_str.add(sql);
				{
					String msg="修改"+fs.getDev_id()+"机房放电参数";
					User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Alter, msg);
					listU.add(ulog);
				 }
			}
		}
		
		Boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);
		(new User_logService()).addPro(listU);//将用户的操作记录下来
		return bl;
	}
	//批量放电
	public boolean updatePro_dis(Object obj) {
		List<Fbs9100_setparam> list=(List<Fbs9100_setparam>) obj;
		ArrayList sql_str=new ArrayList();
		List<User_log> listU=new ArrayList<User_log>();//存放user_log
		if(list!=null&&list.size()>0){
			for (int i = 0; i < list.size(); i++) {
				Fbs9100_setparam fs=list.get(i);
				String sql="UPDATE db_ram_db.tb_fbs9100_setparam  SET "
						+ " op_cmd="+fs.getOp_cmd()+ ",TestCmd="+fs.getTestCmd()+ " WHERE dev_id= "+fs.getDev_id();
				sql_str.add(sql);
				{
					String msg="启动"+fs.getDev_id()+"机房放电";
					User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Alter, msg);
					listU.add(ulog);
				 }
			}
		}
		
		Boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);
		(new User_logService()).addPro(listU);//将用户的操作记录下来
		return bl;
	}
	//批量重启
	public boolean restartPL_FBS(Object obj) {
		List<Fbs9100_sysparam> list=(List<Fbs9100_sysparam>) obj;
		ArrayList sql_str=new ArrayList();
		List<User_log> listU=new ArrayList<User_log>();//存放user_log
		if(list!=null&&list.size()>0){
			for (int i = 0; i < list.size(); i++) {
				Fbs9100_sysparam fs=list.get(i);
				String sql="UPDATE db_ram_db.tb_fbs9100_setparam  SET "
						+ " op_cmd="+fs.getOp_cmd()+ " WHERE dev_id= "+fs.getDev_id();
				sql_str.add(sql);
				{
					String msg="重启"+fs.getDev_id()+"机房";
					User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Alter, msg);
					listU.add(ulog);
				 }
			}
		}
		
		Boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);
		(new User_logService()).addPro(listU);//将用户的操作记录下来
		return bl;
	}
	//修改放电参数表中ld6
	public boolean updateld6Param(Object obj) {
		Fbs9100_setparam fs=(Fbs9100_setparam) obj;
		String sql="update db_ram_db.tb_Fbs9100_setparam set testCmd=?,GroupVol_LOW=?," +
				"MonomerVol_LOW=?,MonomerLowCount=?,MonomerTmp_High=?,DisTime=?,DisCap=?,AutoTestStartVol=?" +
				" where dev_id=?";
		Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{
			fs.getTestCmd(),fs.getGroupVol_Low(),fs.getMonomerVol_Low(),fs.getMonomerLowCount(),
			fs.getMonomerTmp_High(),fs.getDisTime(),fs.getDisCap(),fs.getAutoTestStartVol(),
			fs.getDev_id()});
		return bl;
	}
	
	//修改61850的放电参数
	public boolean update61850Param(Object obj) {
		Fbs9100_setparam fs=(Fbs9100_setparam) obj;
		String sql="update db_ram_db.tb_Fbs9100_setparam set testCmd=?," +
				"DisCurr=?,DisCap=?,DisTime=?,MonomerTmp_High=?,groupVol_Low=?,monomerVol_Low=? " +
				"where dev_id=?";
		Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{
			fs.getTestCmd(),fs.getDisCurr(),fs.getDisCap(),fs.getDisTime(),fs.getMonomerTmp_High(),fs.getGroupVol_Low(),fs.getMonomerVol_Low(),fs.getDev_id()});
		return bl;
	}

   
	public boolean del(Object obj) {
		Fbs9100_setparam fs=(Fbs9100_setparam) obj;
		String sql="delete from db_ram_db.tb_Fbs9100_setparam where num=?";
		Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{fs.getNum()});
		return bl;
	}
   
	public List searchAll() {
		String sql="select * from db_ram_db.tb_Fbs9100_setparam";
		List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new Fbs9100_setparamImpl());
		return list;
	}
	//判断该机房是不是以前有过记录
	public int judgeSatationInParam(int dev_id) {
		String sql=" SELECT count(num) as nums from db_ram_db.tb_Fbs9100_setparam where dev_id=? LIMIT 1 ";
		List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{dev_id}, new CallBack() {
			
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				try {
					while(rs.next()){
						int nums=rs.getInt("nums");
						list.add(nums);
					}
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				return list;
			}
		});
		int flag=0;//返回的标识符
		if(list!=null&&list.size()>0){
			int nums=(Integer) list.get(list.size()-1);
			if(nums>0){
				flag=1;
			}else{
				flag=0;
			}
		}
		return flag;
	}
	
	//根据机房编号和维护区查询放电机房的信息和放电参数
	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.StationName5,db_battinf.tb_battinf.FBSDeviceId,db_battinf.tb_battinf.FBSDeviceIp,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_fbs9100_setparam.HourRate,db_ram_db.tb_fbs9100_setparam.DisCurr,db_ram_db.tb_fbs9100_setparam.DisCap" +
				",db_ram_db.tb_fbs9100_setparam.DisTime,db_ram_db.tb_fbs9100_setparam.GroupVol_LOW,db_ram_db.tb_fbs9100_setparam.MonomerVol_LOW" +
				",db_ram_db.tb_fbs9100_setparam.MonomerLowCount,db_ram_db.tb_fbs9100_setparam.OnlineVolLowAction" +
				",db_ram_db.tb_fbs9100_setparam.dCVolHighLimit,db_ram_db.tb_fbs9100_setparam.chargeCurrSet"+
				",db_ram_db.tb_fbs9100_setparam.battgroupnum,db_ram_db.tb_fbs9100_setparam.testcmd,db_ram_db.tb_fbs9100_setparam.MonomerTmp_High,db_ram_db.tb_fbs9100_setparam.AutoTestStartVol  " +
				",db_ram_db.tb_fbs9100_state.dev_testtype,db_ram_db.tb_fbs9100_state.dev_alarmstate,db_ram_db.tb_fbs9100_state.dev_captest_cap" +
				",db_ram_db.tb_fbs9100_state.dev_captest_curr,db_ram_db.tb_fbs9100_state.dev_captest_groupvol,db_ram_db.tb_fbs9100_state.dev_captest_onlinevol " +
				",db_ram_db.tb_fbs9100_state.dev_captest_timelong,db_ram_db.tb_fbs9100_state.dev_commcount,db_ram_db.tb_fbs9100_state.dev_testgroupnum  " +
				",db_ram_db.tb_fbs9100_state.dev_conresist,db_ram_db.tb_fbs9100_state.dev_concurr,db_ram_db.tb_fbs9100_state.dev_condvoldp,db_ram_db.tb_fbs9100_state.dev_condcurr" +
				",db_ram_db.tb_fbs9100_state.dev_61850alarms" +
				" FROM db_battinf.tb_battinf " +
				" LEFT OUTER JOIN db_ram_db.tb_fbs9100_setparam on db_ram_db.tb_fbs9100_setparam.dev_id=db_battinf.tb_battinf.FBSDeviceId " +
				" LEFT OUTER JOIN db_ram_db.tb_fbs9100_state  on db_ram_db.tb_fbs9100_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()){
						FBS9100 fbs9100=new FBS9100();
						BattInf binf=new BattInf();
						binf.setBattGroupId(rs.getInt("battGroupId"));
						binf.setStationName(rs.getString("stationName"));
						binf.setStationName5(rs.getString("stationName5"));
						binf.setFBSDeviceId(rs.getInt("fBSDeviceId"));
						binf.setFbsDeviceIp(rs.getString("fbsDeviceIp"));
						binf.setBattGroupName(rs.getString("battGroupName"));
						binf.setGroupIndexInFBSDevice(rs.getInt("groupIndexInFBSDevice"));
						binf.setMonCount(rs.getInt("monCount"));
						binf.setMonVolStd(rs.getFloat("monVolStd"));
						binf.setMonCapStd(rs.getFloat("monCapStd"));
						fbs9100.setBinf(binf);
						
						Fbs9100_setparam fsparam=new Fbs9100_setparam();
						fsparam.setHourRate(rs.getInt("hourRate"));
						fsparam.setDisCurr(rs.getFloat("disCurr"));
						fsparam.setDisCap(rs.getFloat("disCap"));
						fsparam.setDisTime(rs.getInt("disTime"));
						fsparam.setGroupVol_Low(rs.getFloat("groupVol_Low"));
						fsparam.setMonomerVol_Low(rs.getFloat("monomerVol_Low"));
						fsparam.setMonomerLowCount(rs.getInt("monomerLowCount"));
						fsparam.setOnlineLowAction(rs.getInt("onlineVolLowAction"));
						fsparam.setDCVolHighLimit(rs.getFloat("dCVolHighLimit"));
						fsparam.setChargeCurrSet(rs.getFloat("chargeCurrSet"));
					    fsparam.setBattGroupNum(rs.getInt("battGroupNum"));
					    fsparam.setTestCmd(rs.getInt("testCmd"));
					    fsparam.setMonomerTmp_High(rs.getFloat("monomerTmp_High"));
					    fsparam.setAutoTestStartVol(rs.getFloat("autoTestStartVol"));
						fbs9100.setFsparam(fsparam);
					    
					    Fbs9100_state fstate=new Fbs9100_state();
					    fstate.setDev_testtype(rs.getInt("dev_testtype"));
					    fstate.setDev_alarmstate(rs.getInt("dev_alarmstate"));
					    fstate.setDev_captest_cap(rs.getFloat("dev_captest_cap"));
					    fstate.setDev_captest_curr(rs.getFloat("dev_captest_curr"));
					    fstate.setDev_captest_groupvol(rs.getFloat("dev_captest_groupvol"));
					    fstate.setDev_captest_onlinevol(rs.getFloat("dev_captest_onlinevol"));
					    fstate.setDev_captest_timelong(rs.getInt("dev_captest_timelong"));
					    fstate.setDev_commcount(rs.getInt("dev_commcount"));
					    fstate.setDev_testgroupnum(rs.getInt("dev_testgroupnum"));
					    fstate.setDev_conresist(rs.getFloat("dev_conresist"));
						fstate.setDev_concurr(rs.getFloat("dev_concurr"));
						fstate.setDev_condcurr(rs.getFloat("dev_condcurr"));
						fstate.setDev_condcurr(rs.getFloat("dev_condcurr"));
						fstate.setDev_61850alarms(rs.getString("dev_61850alarms"));
					   
					    fbs9100.setFstate(fstate);
					    list.add(fbs9100);
					}
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				return list;
			}
		});
		return list;
	}
   
	//机房命令操作设备时的cmd和ack校验		test_type  -->默认启动测试的类型
	public boolean sendCmdToFBS9100Dev(int cmd,int test_type,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_GetDischargeParm: m_cmd_ack = FBS9100_ComBase.CMD_GetDischargeParmAck; break;
			case FBS9100_ComBase.CMd_SetIp_Tem: m_cmd_ack = FBS9100_ComBase.CMd_SetIpAck; break;
			case FBS9100_ComBase.CMd_SetIp_Per: m_cmd_ack = FBS9100_ComBase.CMd_SetIpAck; break;
			case FBS9100_ComBase.CMD_ResetSystem: m_cmd_ack = FBS9100_ComBase.CMD_ResetSystemAck; break;
			case FBS9100_ComBase.CMD_READGPRS_BTS_TASK_INF: m_cmd_ack = FBS9100_ComBase.CMD_READGPRS_BTS_TASK_INFACK; break;
			default: return false;
		}
		String sql_end = "";
		if(test_type > 0 && cmd == FBS9100_ComBase.CMD_Start){					//启动测试时未点击设定参数按钮，会出现启动内阻测试bug修复
			sql_end = ",TestCmd="+test_type;
		}
		boolean res_exe = false;
		String sql = "UPDATE db_ram_db.tb_fbs9100_setparam  SET "
						+ " op_cmd=? " + sql_end
						+ " 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_fbs9100_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;
	}
	//批量设置成功后读取命令的ACK
	public boolean getCmdAck(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_GetDischargeParm: m_cmd_ack = FBS9100_ComBase.CMD_GetDischargeParmAck; break;
			case FBS9100_ComBase.CMd_SetIp_Tem: m_cmd_ack = FBS9100_ComBase.CMd_SetIpAck; break;
			case FBS9100_ComBase.CMd_SetIp_Per: m_cmd_ack = FBS9100_ComBase.CMd_SetIpAck; break;
			case FBS9100_ComBase.CMD_ResetSystem: m_cmd_ack = FBS9100_ComBase.CMD_ResetSystemAck; break;
			case FBS9100_ComBase.CMD_READGPRS_BTS_TASK_INF: m_cmd_ack = FBS9100_ComBase.CMD_READGPRS_BTS_TASK_INFACK; break;
			default: return false;
		}
		String sql = "SELECT op_cmd FROM db_ram_db.tb_fbs9100_setparam "+
				" WHERE dev_id="+dev_id;
		Connection conn=DBUtil.getConn();
		PreparedStatement ps = null;
		ResultSet rs = null;
		boolean res_exe=false;
		try {
			ps = conn.prepareStatement(sql);
			rs=ps.executeQuery();
			if(rs.next())
			{
				if(rs.getInt("op_cmd") == m_cmd_ack)
				{
					res_exe = true;
				}
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		DBUtil.close(rs, ps, conn);
		return res_exe;
	}
	//根据dev_id查询弹出框中的数据
	public List serchbyDev_id(Object obj) {
		Fbs9100_setparam fsparam=(Fbs9100_setparam) obj;
		String sql=" select db_battinf.tb_battinf.StationName,db_battinf.tb_battinf.FBSDeviceId,db_battinf.tb_battinf.FBSDeviceIp,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_battinf.tb_battinf.charge_curr_max" +
				",db_ram_db.tb_fbs9100_setparam.HourRate,db_ram_db.tb_fbs9100_setparam.DisCurr,db_ram_db.tb_fbs9100_setparam.DisCap" +
				",db_ram_db.tb_fbs9100_setparam.DisTime,db_ram_db.tb_fbs9100_setparam.GroupVol_LOW,db_ram_db.tb_fbs9100_setparam.MonomerVol_LOW" +
				",db_ram_db.tb_fbs9100_setparam.MonomerLowCount,db_ram_db.tb_fbs9100_setparam.OnlineVolLowAction" +
				",db_ram_db.tb_fbs9100_setparam.dCVolHighLimit,db_ram_db.tb_fbs9100_setparam.chargeCurrSet,db_ram_db.tb_fbs9100_setparam.battgroupnum" +
				",db_ram_db.tb_fbs9100_setparam.testcmd,db_ram_db.tb_fbs9100_setparam.testcmd,db_ram_db.tb_fbs9100_setparam.MonomerTmp_High" +
				",db_ram_db.tb_fbs9100_setparam.AutoTestStartVol   " +
				" FROM db_battinf.tb_battinf " +
				" LEFT OUTER JOIN db_ram_db.tb_fbs9100_setparam on db_ram_db.tb_fbs9100_setparam.dev_id=db_battinf.tb_battinf.FBSDeviceId  " +
				" WHERE db_battinf.tb_battinf.FBSDeviceId=? limit 1";
		
		List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{fsparam.getDev_id()}, new CallBack() {
			
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				try {
					while(rs.next()){
						FBS9100 fbs9100=new FBS9100();
						BattInf binf=new BattInf();
						binf.setStationName(rs.getString("stationName"));
						binf.setFBSDeviceId(rs.getInt("fBSDeviceId"));
						binf.setFbsDeviceIp(rs.getString("fbsDeviceIp"));
						binf.setBattGroupName(rs.getString("battGroupName"));
						binf.setGroupIndexInFBSDevice(rs.getInt("groupIndexInFBSDevice"));
						binf.setMonCount(rs.getInt("monCount"));
						binf.setMonVolStd(rs.getFloat("monVolStd"));
						binf.setMonCapStd(rs.getFloat("monCapStd"));
						binf.setCharge_curr_max(rs.getFloat("charge_curr_max"));
						fbs9100.setBinf(binf);
						
						Fbs9100_setparam fsparam=new Fbs9100_setparam();
						fsparam.setHourRate(rs.getInt("hourRate"));
						fsparam.setDisCurr(rs.getFloat("disCurr"));
						fsparam.setDisCap(rs.getFloat("disCap"));
						fsparam.setDisTime(rs.getInt("disTime"));
						fsparam.setGroupVol_Low(rs.getFloat("groupVol_Low"));
						fsparam.setMonomerVol_Low(rs.getFloat("monomerVol_Low"));
						fsparam.setMonomerLowCount(rs.getInt("monomerLowCount"));
						fsparam.setOnlineLowAction(rs.getInt("onlineVolLowAction"));
					    fsparam.setDCVolHighLimit(rs.getFloat("dCVolHighLimit"));
					    fsparam.setChargeCurrSet(rs.getFloat("chargeCurrSet"));
						fsparam.setBattGroupNum(rs.getInt("battGroupNum"));
						fsparam.setTestCmd(rs.getInt("testCmd"));
						fsparam.setMonomerTmp_High(rs.getFloat("monomerTmp_High"));
						fsparam.setAutoTestStartVol(rs.getFloat("autoTestStartVol"));
					    fbs9100.setFsparam(fsparam);
					    
					    list.add(fbs9100);
					}
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				return list;
			}
		});
		return list;
	}

	//实时刷新放电表格的电池组状态(集合)
	public List serchByInfo(Object obj) {
		List<BattInf> listB=(List<BattInf>) obj;
		List listAll=new ArrayList();//存放最后的结果
		if(listB!=null&&listB.size()>0){
			for (int i=0;i<listB.size();i++) {
				BattInf b=listB.get(i);
				Connection conn=DBUtil.getConn();
				PreparedStatement ps = null;
				ResultSet rs = null;
				String sql="";
				String FBS9100sql="select DISTINCT 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.GroupIndexInFBSDevice,db_battinf.tb_battinf.MonCount,db_battinf.tb_battinf.MonVolStd,db_battinf.tb_battinf.MonCapStd" +
						",db_ram_db.tb_fbs9100_state.dev_testtype,db_ram_db.tb_fbs9100_state.dev_alarmstate,db_ram_db.tb_fbs9100_state.dev_captest_cap" +
						",db_ram_db.tb_fbs9100_state.dev_captest_curr,db_ram_db.tb_fbs9100_state.dev_captest_groupvol,db_ram_db.tb_fbs9100_state.dev_captest_onlinevol" +
						",db_ram_db.tb_fbs9100_state.dev_captest_timelong,db_ram_db.tb_fbs9100_state.dev_commcount,db_ram_db.tb_fbs9100_state.dev_testgroupnum " +
						",db_ram_db.tb_fbs9100_state.dev_restest_moncount,db_ram_db.tb_fbs9100_state.dev_restest_monindex,db_ram_db.tb_fbs9100_state.dev_workstate,db_ram_db.tb_fbs9100_state.dev_res_test_state,db_ram_db.tb_fbs9100_state.num" +
						",db_ram_db.tb_fbs9100_state.dev_61850alarms " +
						" FROM db_battinf.tb_battinf " +
						" LEFT OUTER JOIN db_ram_db.tb_fbs9100_state  on db_ram_db.tb_fbs9100_state.dev_id=db_battinf.tb_battinf.FBSDeviceId " +
						" where db_battinf.tb_battinf.FBSDeviceId="+b.getFBSDeviceId()+" and db_battinf.tb_battinf.battgroupid="+b.getBattGroupId()+"  limit 1";
				
				String BTS61850sql="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_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" +
						",db_ram_db.tb_bts_61850_state.alam_tmp,db_ram_db.tb_bts_61850_state.alam_relay,db_ram_db.tb_bts_61850_state.alam_comm   " +
						" from db_battinf.tb_battinf " +
						" 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.FBSDeviceId="+b.getFBSDeviceId()+" and db_battinf.tb_battinf.battgroupid="+b.getBattGroupId()+"  limit 1";
			     
				String LD9sql="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_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,db_ram_db.tb_ld9_state.sys_stop_reason " +
						" from db_battinf.tb_battinf " +
						" 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.FBSDeviceId="+b.getFBSDeviceId()+" and db_battinf.tb_battinf.battgroupid="+b.getBattGroupId()+"  limit 1";
				String FBS9600sql="select db_battinf.tb_battinf.battgroupid,db_battinf.tb_battinf.StationName,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.FBSDeviceId="+b.getFBSDeviceId()+" and db_battinf.tb_battinf.battgroupid="+b.getBattGroupId()+"  limit 1";
				//System.out.println(b.getFBSDeviceId()+"  111");
				if(b.getFBSDeviceId()/100000==9100||b.getFBSDeviceId()/100000==910||b.getFBSDeviceId()/100000==4016){
					sql=FBS9100sql;
				}else if(b.getFBSDeviceId()/100000==6185){
					//sql=BTS61850sql;
					sql=FBS9100sql;
				}else if(b.getFBSDeviceId()/100000==4019){
					sql=LD9sql;
				}else if(b.getFBSDeviceId()/100000==9611||b.getFBSDeviceId()/100000==9600||b.getFBSDeviceId()/100000==9616){
					sql=FBS9600sql;
				}
				try {
					//System.out.println(sql);					
					ps = conn.prepareStatement(sql);
					ps.setQueryTimeout(600);
					rs=ps.executeQuery();
					while(rs.next()){
						FBS9100 fbs9100=new FBS9100();						
						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.setGroupIndexInFBSDevice(rs.getInt("groupIndexInFBSDevice"));
						binf.setMonCount(rs.getInt("monCount"));
						binf.setMonVolStd(rs.getFloat("monVolStd"));
						binf.setMonCapStd(rs.getFloat("monCapStd"));
						fbs9100.setBinf(binf);
						
					    Fbs9100_state fstate=new Fbs9100_state();
					    if(binf.getFBSDeviceId()/100000==9100||binf.getFBSDeviceId()/100000==910||b.getFBSDeviceId()/100000==4016){
					    	fstate.setNum(rs.getInt("num"));
						    fstate.setDev_testtype(rs.getInt("dev_testtype"));
						    fstate.setDev_workstate(rs.getInt("dev_workstate"));
						    fstate.setDev_alarmstate(rs.getInt("dev_alarmstate"));
						    fstate.setDev_res_test_state(rs.getInt("dev_res_test_state"));
						    fstate.setDev_captest_cap(rs.getFloat("dev_captest_cap"));
						    fstate.setDev_captest_curr(rs.getFloat("dev_captest_curr"));
						    fstate.setDev_captest_groupvol(rs.getFloat("dev_captest_groupvol"));
						    fstate.setDev_captest_onlinevol(rs.getFloat("dev_captest_onlinevol"));
						    fstate.setDev_captest_timelong(rs.getInt("dev_captest_timelong"));
						    fstate.setDev_commcount(rs.getInt("dev_commcount"));
						    fstate.setDev_testgroupnum(rs.getInt("dev_testgroupnum"));
						    fstate.setDev_restest_moncount(rs.getInt("dev_restest_moncount"));
						    fstate.setDev_restest_monindex(rs.getInt("dev_restest_monindex"));
						    
						}else if(binf.getFBSDeviceId()/100000==6185){
							
						    fstate.setDev_alarmstate(rs.getInt("dev_alarmstate"));
						    fstate.setDev_workstate(rs.getInt("dev_workstate"));
					    	fstate.setDev_captest_groupvol(rs.getFloat("dev_captest_groupvol"));
						    fstate.setDev_captest_onlinevol(rs.getFloat("dev_captest_onlinevol"));
						    fstate.setDev_captest_timelong(rs.getInt("dev_captest_timelong"));
						    fstate.setDev_commcount(rs.getInt("dev_commcount"));
						    fstate.setNote("");
						    fstate.setDev_61850alarms(rs.getString("dev_61850alarms"));
						    fstate.setDev_captest_curr(rs.getFloat("dev_captest_curr"));
						    /*String alarmstr="";
							if(rs.getInt("alam_tmp")==1){
								if(alarmstr.length()>0){
									alarmstr+="/";
								}
								alarmstr+="设备过温告警";
							};
							if(rs.getInt("alam_relay")==1){
								if(alarmstr.length()>0){
									alarmstr+="/";
								}
								alarmstr+="继电器K1告警";
							};
							if(rs.getInt("alam_comm")==1){
								if(alarmstr.length()>0){
									alarmstr+="/";
								}
								alarmstr+="通讯告警";
							};
							fstate.setDev_workstate(rs.getInt("stc_workstate"));
					    	fstate.setDev_captest_groupvol(rs.getFloat("dev_captest_groupvol"));
						    fstate.setDev_captest_onlinevol(rs.getFloat("dev_captest_online"));
						    fstate.setDev_captest_timelong(rs.getInt("timelong"));
						    fstate.setDev_commcount(rs.getInt("dev_commcount"));
						    fstate.setNote(alarmstr);*/
						}else if(binf.getFBSDeviceId()/100000==4019){
							fstate.setDev_workstate(rs.getInt("sys_state"));
					    	fstate.setDev_captest_groupvol(rs.getFloat("sys_group_vol"));
						    fstate.setDev_captest_onlinevol(rs.getFloat("sys_online_vol"));
						    fstate.setDev_captest_timelong(rs.getInt("timelong"));
						    fstate.setDev_commcount(rs.getInt("dev_commcount"));
						    fstate.setDev_alarmstate(rs.getInt("sys_stop_reason"));
						}else if(binf.getFBSDeviceId()/100000==9611){
							fstate.setDev_commcount(rs.getInt("dev_commcount"));
						}
					    fbs9100.setFstate(fstate);
					    listAll.add(fbs9100);
					}
					
				} catch (SQLException e) {
					e.printStackTrace();
				}
				DBUtil.close(rs, ps, conn);
			}
			
		}
		return listAll;
	}

	public static void main(String[] args) {
	    Fbs9100_setparamImpl fi=new Fbs9100_setparamImpl();
	  
	    BattInf binf=new BattInf();
	    binf.setStationName("");
	    binf.setStationName1("");
	    binf.setBattGroupId(1000011);
	    List<FBS9100> list=fi.serchByCondition(binf);
		System.out.println(list.size());
		for(FBS9100 f:list){
			System.out.println(f);
		}
	}
	

}