package com.fgkj.dao.impl;

import java.math.BigDecimal;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.text.ParseException;
import java.util.ArrayList;
import java.util.List;

import com.fgkj.dao.AlarmDaoFactory;
import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.BattCapFactory;
import com.fgkj.dao.BattTestData;
import com.fgkj.dao.CallBack;
import com.fgkj.dao.DAOHelper;
import com.fgkj.db.DBUtil;
import com.fgkj.db.IDatabaseName;
import com.fgkj.dto.Alarm_param;
import com.fgkj.dto.BattInf;
import com.fgkj.dto.BattInf_Rebuild;
import com.fgkj.dto.Batt_Maint_Dealarm;
import com.fgkj.dto.Batttestdata;
import com.fgkj.dto.Batttestdata_inf;
import com.fgkj.dto.Batttestdatastop;
import com.fgkj.test.Mon_vols;

public class BatttestdatastopDAOImpl implements BaseDAO,CallBack{

	public boolean add(Object obj) {
		List<Batttestdata> list=(List<Batttestdata>) obj;
		ArrayList<String> sql_str=new ArrayList();
		if(list!=null&&list.size()>0){
			for (int i = 0; i < list.size(); i++) {
				Batttestdata b=list.get(i);
				String sql="insert into db_batt_testdata.tb_batttestdatastop_"+b.getBattGroupId()+"(BattGroupId,test_record_count,test_type,data_new,data_available,record_num,test_starttime,record_time,test_timelong,online_vol,group_vol,test_curr,test_cap,mon_num,mon_vol,mon_tmp) " +
						"   values("+b.getBattGroupId()+","+b.getTest_record_count()+","+b.getTest_type()+","+b.getData_new()+","+b.getData_available()+","+b.getRecord_num()+",'"+DAOHelper.sdf.format(b.getTest_starttime())+"','"+DAOHelper.sdf.format(b.getRecord_time())+"',"+b.getTest_timelong()+","+b.getOnline_vol()+","+b.getGroup_vol()+","+b.getTest_curr()+","+b.getTest_cap()+","+b.getMon_num()+","+b.getMon_vol()+","+b.getMon_tmp()+")";
			    sql_str.add(sql);
			}
		}
		boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);
		return  bl;
	}
	public boolean updatenew(Object obj) {
		Batttestdata b=(Batttestdata) obj;
		String sql="update db_batt_testdata.tb_batttestdatastop_"+b.getBattGroupId()+" set mon_tmp=? where mon_num=? and record_num=?";
		boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{b.getMon_tmp(),b.getMon_num(),b.getRecord_num()});
		return bl;
	}
	
	public boolean update(Object obj) {
		Mon_vols ms=(Mon_vols) obj;
		String sql="update db_batt_testdata.tb_batttestdatastop_"+ms.getBattggroupid()+" set online_vol=? ,group_vol=? where record_num=?";
		boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{ms.getMon_vols(),ms.getMon_vols(),ms.getRecord_num()});
		return bl;
	}

	//6.1电池充放电管理删除操作
	public boolean del(Object obj) {
		Batttestdatastop tstop = (Batttestdatastop) obj;
		String sql = "delete from db_batt_testdata.tb_batttestdatastop_" + tstop.getBattGroupId()
				+ " where battgroupid=?  and test_record_count=? ";
		Boolean bl = DAOHelper.executeUpdate(
				DBUtil.getConn(), sql,
				new Object[] { tstop.getBattGroupId(),tstop.getTest_record_count() });
		return bl;
	}


	public List searchAll() {
		return null;
	}
    //历史监测单体电压折线图
	public List serchByCondition(Object obj) {
		Batttestdatastop btd=(Batttestdatastop)obj;
		//System.out.println(btd);
		String sql="select num,BattGroupId,test_record_count,test_type,data_new,data_available,record_num,test_starttime,record_time,test_timelong,group_vol,test_curr,test_cap,mon_num,mon_vol from db_batt_testdata.tb_batttestdatastop_"+btd.getBattGroupId()+"" +
				" where test_record_count=?";
		//System.out.println(sql);
		return DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{btd.getTest_record_count()}, new BatttestdatastopDAOImpl());
	}

	public List serchByInfo(Object obj) {
		return null;
	}

	public List getResults(ResultSet rs) {
		List list=new ArrayList();
		try {
			while(rs.next()){
				Batttestdatastop bs=new Batttestdatastop();
				bs.setNum(rs.getInt("num"));
				bs.setBattGroupId(rs.getInt("BattGroupId"));
				bs.setTest_record_count(rs.getInt("test_record_count"));
				bs.setTest_type(rs.getInt("test_type"));
				bs.setData_new(rs.getInt("data_new"));						
				bs.setData_available(rs.getInt("data_available"));
				bs.setRecord_num(rs.getInt("record_num"));
				bs.setTest_starttime(rs.getTimestamp("test_starttime"));
				bs.setRecord_time(rs.getTimestamp("record_time"));
				bs.setTest_timelong(rs.getInt("test_timelong"));
				bs.setGroup_vol(rs.getFloat("group_vol"));
				bs.setTest_curr(rs.getFloat("test_curr"));
				bs.setTest_cap(rs.getFloat("test_cap"));
				bs.setMon_num(rs.getInt("mon_num"));
				bs.setMon_vol(rs.getFloat("mon_vol"));
				list.add(bs);
				//System.out.println(b);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} 
		return list;
	}
	
	//3根据battgroupid和mon_num(电池编号)查测试信息
	public List serchByMonNum(Object obj) {
		Batttestdatastop btd=(Batttestdatastop)obj;
		String sql=null;
		List list=new ArrayList();
		if(btd.getMon_num()==0){
			sql="select num,BattGroupId,test_record_count,test_type,data_new,data_available,record_num,test_starttime,record_time,test_timelong,group_vol," +
					"test_curr,test_cap,mon_num,mon_vol from db_batt_testdata.tb_batttestdatastop_"+btd.getBattGroupId()+"" +
		  		" where battgroupid=? and mon_num!=?  and test_record_count=?  " +
		  		" and db_batt_testdata.tb_batttestdatastop_"+btd.getBattGroupId()+".data_available=1 ";
			
		}else{
	    sql="select num,BattGroupId,test_record_count,test_type,data_new,data_available,record_num,test_starttime,record_time,test_timelong,group_vol," +
				" test_curr,test_cap,mon_num,mon_vol from db_batt_testdata.tb_batttestdatastop_"+btd.getBattGroupId()+"" +
				" where battgroupid=? and mon_num=?  and test_record_count=? " +
				" and db_batt_testdata.tb_batttestdatastop_"+btd.getBattGroupId()+".data_available=1 ";
		}
		list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{btd.getBattGroupId(),btd.getMon_num(),btd.getTest_record_count()}, new BatttestdatastopDAOImpl());
		return list;
	}

	//1根据与阈值比较得到最新落后信息
	public List serchByLowNew(Object obj) {
		Batttestdatastop btd=(Batttestdatastop)obj;
		//	System.out.println(btd); 
			String sql="select battgroupid,mon_num,mon_vol from db_batt_testdata.tb_batttestdatastop_"+btd.getBattGroupId()+" where mon_vol<=? *(select avg(mon_vol) from db_batt_testdata.tb_batttestdatastop_"+btd.getBattGroupId()+" where battgroupid=?) and data_new=1 " +
					" and db_batt_testdata.tb_batttestdatastop_"+btd.getBattGroupId()+".data_available=1 and test_cap<? order by battgroupid ";
			//System.out.println(sql);
			return DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{btd.getLowV(),btd.getBattGroupId(),btd.getLowC()}, new CallBack() {
				public List getResults(ResultSet rs) {
					List list=new ArrayList();
					try {
						while(rs.next()){
							Batttestdatastop bs=new Batttestdatastop();
							bs.setBattGroupId(rs.getInt("BattGroupId"));
							bs.setMon_num(rs.getInt("mon_num"));
							bs.setMon_vol(rs.getFloat("mon_vol"));
							list.add(bs);
							//System.out.println(b);
						}
					} catch (SQLException e) {
						e.printStackTrace();
					}
					return list;
				}
				});
	}
		
	//根据与电容阈值比较得到数据是否有效
	public List serchByType(Object obj) {
		Batttestdatastop btd=(Batttestdatastop)obj;
	      //  System.out.println(btd.getBattGroupId()+"   "+btd.getLowC()); 
			String sql="select battgroupid,mon_num,mon_vol from db_batt_testdata.tb_batttestdatastop_"+btd.getBattGroupId()+" where test_cap>? " +
				   	" and db_batt_testdata.tb_batttestdatastop_"+btd.getBattGroupId()+".data_available=1 order by battgroupid";
			//System.out.println(sql);
			return DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{btd.getLowC()}, new CallBack() {
				public List getResults(ResultSet rs) {
					List list=new ArrayList();
					try {
						while(rs.next()){
							Batttestdatastop bs=new Batttestdatastop();
							bs.setBattGroupId(rs.getInt("BattGroupId"));
							bs.setMon_num(rs.getInt("mon_num"));
							bs.setMon_vol(rs.getFloat("mon_vol"));
							list.add(bs);
							//System.out.println(b);
						}
					} catch (SQLException e) {
						e.printStackTrace();
					}
					return list;
				}
				});
	}
	//2根据落后的数据（数量，编号，电压）
	public List serchByLow(Object obj){
			Batttestdatastop btd=(Batttestdatastop)obj;
			String sql="select distinct battGroupId,test_curr,test_cap,mon_num,mon_vol " +
	 				"from db_batt_testdata.tb_batttestdatastop_"+btd.getBattGroupId()+" where test_record_count=?  " +
	 				" and db_batt_testdata.tb_batttestdatastop_"+btd.getBattGroupId()+".data_available=1 ";
	 		List<Batttestdatastop> list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{btd.getTest_record_count()}, new CallBack() {
				public List getResults(ResultSet rs) {
					List list=new ArrayList();
					try {
						while(rs.next()){
							Batttestdatastop bstop=new Batttestdatastop();
							bstop.setTest_curr(rs.getFloat("test_curr"));
							bstop.setTest_cap(rs.getFloat("test_cap"));
							bstop.setBattGroupId(rs.getInt("battGroupId"));
							bstop.setMon_vol(rs.getFloat("mon_vol"));
							bstop.setMon_num(rs.getInt("mon_num"));
							list.add(bstop);
						}
					} catch (SQLException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
					return list;
				}
			});
	 		double realCap=0;//实际容量
	    	double STDAH=0;//标存容量
	 		int hourRate=0;//小时率
	    	double current=0;//当前电流
	    	double SumAH=0;//测试容量
	    	double MaxMonomerVol=0;//最大电压
			double MonomerVol=0; //最小电压
			double MonomerVolType=0;//电池电压类型
			int flag=1;//电池单体告警标识
			float sumVol=0;//一组电池电压总值
			List listB=new ArrayList();//存放落后单体
	 		if(list!=null && list.size()>0){
	 			for(int i=0;i<list.size();i++){
	 				STDAH = btd.getTest_curr();//标称电容
	    			MonomerVolType=btd.getTest_cap();//电压类型
	    			current=list.get(i).getTest_curr();
	    			SumAH=list.get(i).getTest_cap();
	    			MaxMonomerVol=btd.getMon_max();//最大电压
	    			MonomerVol=list.get(i).getMon_vol();
	    			sumVol+=MonomerVol;//总电压值
	    			hourRate=BattCapFactory.GetHourRate(STDAH, current);
	    			realCap=BattCapFactory.GetMonomerCap(STDAH, hourRate, SumAH, MaxMonomerVol, MonomerVol, MonomerVolType, BattCapFactory.CapType_Real);
	    	        flag=BattCapFactory.JudgeAlarm(realCap, btd.getLowC(),btd.getLowV(), STDAH);
	    	        if(flag!=1){
	    	        	list.get(i).setGroup_vol(sumVol);
	    				listB.add(list.get(i));
	    			}else{
	    				continue;
	    			}
	    			flag=1;
	 			}
	 		}
			return listB;
		}
	//根据截止平均电压值
	public List serch(Object obj){
			Batttestdatastop btd=(Batttestdatastop)obj;
		      //  System.out.println(btd.getBattGroupId()+"   "+btd.getLowC()); 
			String sql="select  avg(binary mon_vol) as mon_avg from db_batt_testdata.tb_batttestdatastop_"+btd.getBattGroupId()+" where test_record_count=?  " +
					  " and db_batt_testdata.tb_batttestdatastop_"+btd.getBattGroupId()+".data_available=1 " +
					  "order by battgroupid";
				
			return DAOHelper.executeQuery(sql, DBUtil.getConn(),new Object[]{btd.getTest_record_count()}, new CallBack() {
					public List getResults(ResultSet rs) {
						List list=new ArrayList();
						try {
							while(rs.next()){
								Batttestdatastop bs=new Batttestdatastop();
								bs.setMon_avg(rs.getFloat("mon_avg"));
								list.add(bs);
								//System.out.println(b);
							}
						} catch (SQLException e) {
							e.printStackTrace();
						}
						return list;
					}
					});
		}

	//1.4得到历史最高电容/平均电容/最低电容/
	public List serchByCap(Object obj){
		Batttestdatastop btd=(Batttestdatastop)obj;
		String sql="select battgroupid,max(test_cap) as max,min(test_cap) as min,avg(test_cap) as avg,test_cap from db_batt_testdata.tb_batttestdatastop_"+btd.getBattGroupId()+" " +
				" where db_batt_testdata.tb_batttestdatastop_"+btd.getBattGroupId()+".data_available=1" +
				" order by test_starttime desc" ;
		List list=DAOHelper.executeQuery(sql,  DBUtil.getConn(), null, new CallBack() {
			
			public List getResults(ResultSet rs){
				List list=new ArrayList();
				try {
					while(rs.next()){
						Batttestdatastop bs=new Batttestdatastop();
						bs.setBattGroupId(rs.getInt("battGroupId"));
						bs.setMon_avg(rs.getFloat("avg"));
						bs.setMon_min(rs.getFloat("min"));
						bs.setMon_max(rs.getFloat("max"));
						bs.setTest_cap(rs.getFloat("test_cap"));
						list.add(bs);
						//System.out.println(b);
					}
				} catch (SQLException e) {
					e.printStackTrace();
				}
				return list;
			}
		});
		return list;
	}	

	//7.1选出落后单体
 	public List serchBadBatt(Object obj){
	 		Batt_Maint_Dealarm bmd=(Batt_Maint_Dealarm) obj;
	 		BattInf binf=bmd.getBinf();
	 		Batttestdata_inf tdata=bmd.getTdata();
	 		//System.out.println("binf:"+binf+"  tdata: "+tdata);
	 		Batttestdatastop sdata=new Batttestdatastop();
	 		String sql="select num,BattGroupId,test_record_count,test_type,data_new,data_available,record_num,test_starttime,record_time,test_timelong,group_vol," +
					" test_curr,test_cap,mon_num,mon_vol " +
	 				" from db_batt_testdata.tb_batttestdatastop_"+tdata.getBattGroupId()+" " +
					" where " +
					"test_record_count=?  and record_time=?  " +
					" and db_batt_testdata.tb_batttestdatastop_"+tdata.getBattGroupId()+".data_available=1 ";//tb_batttestdatastop_id表中筛选出实际电压>标存电压*0.9的时的那笔数据,new Object[]{tdata.getTest_record_count(),tdata.getRecord_time()}
	 		       //System.out.println(sql);
	 		
			List<Batt_Maint_Dealarm> list=DAOHelper.executeQuery(sql, DBUtil.getConn(),new Object[]{tdata.getTest_record_count(),tdata.getRecord_time()}, new CallBack() {
				
				public List getResults(ResultSet rs) {
					List<Batt_Maint_Dealarm> list=new ArrayList<Batt_Maint_Dealarm>();
					try {
						while(rs.next()){
							Batt_Maint_Dealarm bmd=new Batt_Maint_Dealarm();
							BattInf binf=new BattInf();
							Batttestdatastop sdata=new Batttestdatastop();
							sdata.setNum(rs.getInt("num"));
							sdata.setBattGroupId(rs.getInt("BattGroupId"));
							sdata.setTest_record_count(rs.getInt("test_record_count"));
							sdata.setTest_type(rs.getInt("test_type"));
							sdata.setData_new(rs.getInt("data_new"));						
							sdata.setData_available(rs.getInt("data_available"));
							sdata.setRecord_num(rs.getInt("record_num"));
							sdata.setTest_starttime(rs.getTimestamp("test_starttime"));
							sdata.setRecord_time(rs.getTimestamp("record_time"));
							sdata.setTest_timelong(rs.getInt("test_timelong"));
							sdata.setGroup_vol(rs.getFloat("group_vol"));
							sdata.setTest_curr(rs.getFloat("test_curr"));
							sdata.setTest_cap(rs.getFloat("test_cap"));
							sdata.setMon_num(rs.getInt("mon_num"));
							sdata.setMon_vol(rs.getFloat("mon_vol"));
							bmd.setBinf(binf);
							bmd.setSdata(sdata);
							list.add(bmd);

						}
					} catch (SQLException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
					return list;
				}
			});
	 		//System.out.println(list.size());
		    
	 		double realCap=0;//实际容量
	 		float param=0;//容量告警参数
	 		int Caplevel=0;
	 		int Changelevel=0;//告警等级
	 		Alarm_param aparam=new Alarm_param();
	 		aparam.setAlm_id(AlarmDaoFactory.Alarm_CapAlarm);
	 		List<Alarm_param> listA=(new Alarm_paramImpl()).serchByCondition(aparam);
	 		if(listA!=null&&listA.size()>0){
	 			param=listA.get(listA.size()-1).getAlm_low_coe();
	 			Caplevel=listA.get(listA.size()-1).getAlm_low_level();
	 		}
	 		float Cparam=0;//容量更换告警参数
	 		aparam.setAlm_id(AlarmDaoFactory.Alarm_CapChange);
	 		List<Alarm_param> listC=(new Alarm_paramImpl()).serchByCondition(aparam);
	 		if(listC!=null&&listA.size()>0){
	 			Cparam=listC.get(listC.size()-1).getAlm_low_coe();
	 			Changelevel=listC.get(listC.size()-1).getAlm_low_level();
	 		}
	 		//System.out.println("param:"+param);
	    	double STDAH=0;//标存容量
	 		int hourRate=0;//小时率
	    	double current=0;//当前电流
	    	double SumAH=0;//测试容量
	    	double MaxMonomerVol=0;//最大电压
			double MonomerVol=0; //最小电压
			double MonomerVolType=0;//电池电压类型
			int flag=1;//电池单体告警标识
			List listB=new ArrayList();//存放落后单体
			if(list!=null&&list.size()>0){
	    		for(int i=0;i<list.size();i++){
	    			STDAH=binf.getMonCapStd();
	    			MonomerVolType=binf.getMonVolStd();
	    			
	    			current=list.get(i).getSdata().getTest_curr();
	    			SumAH=list.get(i).getSdata().getTest_cap();
	    			MaxMonomerVol=tdata.getMax_monvol();
	    			MonomerVol=list.get(i).getSdata().getMon_vol();
	    			hourRate=BattCapFactory.GetHourRate(STDAH, current);
	    			if(list.get(i).getSdata().getMon_vol()>binf.getMonVolStd()*BattTestData.test_stop){
	        			realCap=BattCapFactory.GetMonomerCap(STDAH, hourRate, SumAH, MaxMonomerVol, MonomerVol, MonomerVolType, BattCapFactory.CapType_Real);
	    			}else{
	    				list.get(i).getSdata().setMon_vol(binf.getMonVolStd()*BattTestData.test_stop);
	    				realCap=(new BatttestdataDAOImpl()).serchRealCap(list.get(i).getSdata());
	    			}
	    	        flag=BattCapFactory.JudgeAlarm(realCap, param,Cparam, STDAH);
	    			if(flag!=1){
	    				list.get(i).getSdata().setNum(flag);
	    				list.get(i).setBinf(binf); //将电池组信息设置进去
	    				if(flag==AlarmDaoFactory.Alarm_CapAlarm){
	    				    list.get(i).getSdata().setData_available(Caplevel);//存放告警等级
	    				    list.get(i).getSdata().setTest_type(AlarmDaoFactory.Alarm_IGNAL_ID_CapAlarmLow);//存放alm_signal_id
	    				    list.get(i).getSdata().setTest_cap(Float.parseFloat(String.valueOf(realCap)));
	    				}else if(flag==AlarmDaoFactory.Alarm_CapChange){
	    					list.get(i).getSdata().setData_available(Changelevel);//存放告警等级
	    					list.get(i).getSdata().setTest_type(AlarmDaoFactory.Alarm_IGNAL_ID_CapChangeLow);//存放alm_signal_id
	    					list.get(i).getSdata().setTest_cap(Float.parseFloat(String.valueOf(realCap)));
	    				}
	    				listB.add(list.get(i));
	    			}else{
	    				continue;
	    			}
	    			flag=1;
	    		}
			}
	 		return listB;
	 	}
 	//电池配组管理(重要)
 	public List serchMakeGroup(Object obj1,Object obj2){
 		    BattInf binf=(BattInf) obj1;
 		    List listr=(List) binf.getObj();
	 		Batttestdata_inf tinf=(Batttestdata_inf) obj2;
	 		String sql="select num,BattGroupId,test_record_count,test_type,data_new,data_available,record_num,test_starttime,record_time,test_timelong,group_vol," +
					" test_curr,test_cap,mon_num,mon_vol " +
	 				" from db_batt_testdata.tb_batttestdatastop_"+tinf.getBattGroupId()+" " +
					" where " +
					"test_record_count=?  and record_time=?  " +
					" and db_batt_testdata.tb_batttestdatastop_"+tinf.getBattGroupId()+".data_available=1 ";//tb_batttestdatastop_id表中筛选出实际电压>标存电压*0.9的时的那笔数据,new Object[]{tdata.getTest_record_count(),tdata.getRecord_time()}
	 		
			List<Batttestdatastop> list=DAOHelper.executeQuery(sql, DBUtil.getConn(),new Object[]{tinf.getTest_record_count(),tinf.getRecord_time()}, new CallBack() {
				
				public List getResults(ResultSet rs) {
					List<Batttestdatastop> list=new ArrayList<Batttestdatastop>();
					try {
						while(rs.next()){
							Batttestdatastop sdata=new Batttestdatastop();
							sdata.setNum(rs.getInt("num"));
							sdata.setBattGroupId(rs.getInt("BattGroupId"));
							sdata.setTest_record_count(rs.getInt("test_record_count"));
							sdata.setTest_type(rs.getInt("test_type"));
							sdata.setData_new(rs.getInt("data_new"));						
							sdata.setData_available(rs.getInt("data_available"));
							sdata.setRecord_num(rs.getInt("record_num"));
							sdata.setTest_starttime(rs.getTimestamp("test_starttime"));
							sdata.setRecord_time(rs.getTimestamp("record_time"));
							sdata.setTest_timelong(rs.getInt("test_timelong"));
							sdata.setGroup_vol(rs.getFloat("group_vol"));
							sdata.setTest_curr(rs.getFloat("test_curr"));
							sdata.setTest_cap(rs.getFloat("test_cap"));
							sdata.setMon_num(rs.getInt("mon_num"));
							sdata.setMon_vol(rs.getFloat("mon_vol"));
							list.add(sdata);

						}
					} catch (SQLException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
					return list;
				}
			});
	 		double realCap=0;//实际容量
	    	double STDAH=0;//标存容量
	 		int hourRate=0;//小时率
	    	double current=0;//当前电流
	    	double SumAH=0;//测试容量
	    	double MaxMonomerVol=0;//最大电压
			double MonomerVol=0; //最小电压
			double MonomerVolType=0;//电池电压类型
			int flag=1;//电池单体告警标识
			if(list!=null&&list.size()>0){
	    		for(int i=0;i<list.size();i++){
	    			Batttestdatastop sdata=list.get(i);
	    			sdata.setNote(binf.getBattProducer());
	    			for (int j = 0; j < listr.size(); j++) {
	    				BattInf_Rebuild brinf=(BattInf_Rebuild) listr.get(j);
						if(sdata.getMon_num()==brinf.getOld_monum()&&sdata.getBattGroupId()==brinf.getOld_battgroupid()){
							sdata.setMon_num(-1);
							break;
						}
						if(sdata.getMon_num()==brinf.getNew_monum()&&sdata.getBattGroupId()==brinf.getNew_battgroupid()){
							sdata.setNote(brinf.getOld_battproducer());
							break;
						}
					}
	    			STDAH=binf.getMonCapStd();
	    			MonomerVolType=binf.getMonVolStd();
	    			
	    			current=sdata.getTest_curr();
	    			SumAH=sdata.getTest_cap();
	    			MaxMonomerVol=tinf.getMax_monvol();
	    			MonomerVol=sdata.getMon_vol();
	    			hourRate=BattCapFactory.GetHourRate(STDAH, current);
	    			if(sdata.getMon_vol()>binf.getMonVolStd()*BattTestData.test_stop){
	        			realCap=BattCapFactory.GetMonomerCap(STDAH, hourRate, SumAH, MaxMonomerVol, MonomerVol, MonomerVolType, BattCapFactory.CapType_Real);
	    			}else{
	    				sdata.setMon_vol(binf.getMonVolStd()*BattTestData.test_stop);
	    				realCap=(new BatttestdataDAOImpl()).serchRealCap(sdata);
	    			}
	    			sdata.setTest_cap((float)realCap);
	    			sdata.setPercent((float)(realCap/STDAH));
	    		}
			}
	 		return list;
	 	}
 	 //查询指定电池组指定单体的实际容量
	public double serchRealCapByMon_num(Object obj) {
 		BattInf binf=(BattInf) obj;
 		String sql="select " +
 				" db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".battgroupid" +
 				",db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".test_curr" +
 				",db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".test_cap" +
 				",db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".mon_vol" +
 				",db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".test_record_count " +
 				",db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".mon_num" +
 				",db_batt_testdata.tb_batttestdata_inf.max_monvol " +
 				" from db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+",db_batt_testdata.tb_batttestdata_inf  " +
 				" where db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".BattGroupId=db_batt_testdata.tb_batttestdata_inf.BattGroupId" +
 				" and db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".test_starttime=db_batt_testdata.tb_batttestdata_inf.test_starttime" +
 				" and db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".mon_num=? " +
 				" and db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".data_available=1 " +
 				" and db_batt_testdata.tb_batttestdata_inf.test_type=3  " +
 				" order by db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".test_starttime desc " +
 				" limit 1 ";
 		//System.out.println("sql:"+sql);
		List<Batttestdatastop> list=DAOHelper.executeQuery(sql, DBUtil.getConn(),new Object[]{binf.getMonNum()} , new CallBack() {
			
			public List getResults(ResultSet rs) {
				List<Batttestdatastop> list=new ArrayList<Batttestdatastop>();
				try {
					while(rs.next()){
						Batttestdatastop sdata=new Batttestdatastop();
						sdata.setBattGroupId(rs.getInt("battGroupId"));
						sdata.setTest_record_count(rs.getInt("test_record_count"));
						sdata.setMon_num(rs.getInt("mon_num"));
						sdata.setTest_curr(rs.getFloat("test_curr"));
						sdata.setTest_cap(rs.getFloat("test_cap"));
						sdata.setMon_vol(rs.getFloat("mon_vol"));
                        sdata.setGroup_vol(rs.getFloat("max_monvol"));
						list.add(sdata);
					}
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				return list;
			}
		});
 		
 		double realCap=0f;//实际容量
    	double STDAH=0;//标存容量
 		int hourRate=0;//小时率
    	double current=0;//当前电流
    	double SumAH=0;//测试容量
    	double MaxMonomerVol=0;//最大电压
		double MonomerVol=0; //最小电压
		double MonomerVolType=0;//电池电压类型(标存电压)
		int flag=1;//电池单体告警标识
		if(list!=null&&list.size()>0){
    		for(int i=0;i<list.size();i++){
    			STDAH=binf.getMonCapStd();
    			MonomerVolType=binf.getMonVolStd();
    			
    			current=list.get(i).getTest_curr();
    			SumAH=list.get(i).getTest_cap();
    			MaxMonomerVol=list.get(i).getGroup_vol();
    			MonomerVol=list.get(i).getMon_vol();
    			hourRate=BattCapFactory.GetHourRate(STDAH, current);
    			if(list.get(i).getMon_vol()>binf.getMonVolStd()*BattTestData.test_stop){
        			realCap=BattCapFactory.GetMonomerCap(STDAH, hourRate, SumAH, MaxMonomerVol, MonomerVol, MonomerVolType, BattCapFactory.CapType_Real);
    			}else{
    				list.get(i).setMon_vol(binf.getMonVolStd()*BattTestData.test_stop);
    				realCap=(new BatttestdataDAOImpl()).serchRealCap(list.get(i));
    			}
    		}
		}
 		return realCap;
	}

	public static void main(String[] args) {
		Batttestdatastop btds=new Batttestdatastop();
		btds.setBattGroupId(1000001);
		btds.setTest_record_count(1);
		BatttestdatastopDAOImpl bi=new BatttestdatastopDAOImpl();
		//List<Batttestdatastop> list=bi.serch(btds);
		List<Batttestdatastop> list=bi.serchByCap(btds);
		for(Batttestdatastop b:list){
			System.out.println(b);
		}
		//System.out.println(new BatttestdatastopDAOImpl().serchByCondition(btds));
	}
}