package com.fgkj.dao.impl;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.text.DecimalFormat;
import java.util.ArrayList;
import java.util.List;

import com.fgkj.dao.BaseDAO;
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.BattInf;
import com.fgkj.dto.Batt_rtdata;

public class Batt_rtdataDAOImpl implements BaseDAO{

	public boolean add(Object obj) {
		return false;
	}

	public boolean update(Object obj) {
		return false;
	}

	public boolean del(Object obj) {
		return false;
	}

	public List searchAll() {
		return null;
	}
    //实时监测
	public List serchByCondition(Object obj) {
		Batt_rtdata br=(Batt_rtdata)obj;
		String sql="select num,BattGroupId,rec_datetime,mon_num,mon_vol,mon_tmp,mon_res,mon_ser,mon_conn_res,mon_cap,mon_JH_curr from db_ram_db.tb_batt_rtdata where BattGroupId=?  order by mon_num";
		return DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{br.getBattGroupId()}, new CallBack() {
			
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				try {
					while(rs.next()){
						Batt_rtdata rtdata=new Batt_rtdata();
						rtdata.setNum(rs.getInt("num"));
						rtdata.setBattGroupId(rs.getInt("BattGroupId"));
						rtdata.setRec_datetime(rs.getDate("rec_datetime"));
						rtdata.setMon_num(rs.getInt("mon_num"));
						rtdata.setMon_vol(rs.getFloat("mon_vol"));
						rtdata.setMon_tmp(rs.getFloat("mon_tmp"));
						rtdata.setMon_res(rs.getFloat("mon_res"));
						rtdata.setMon_ser(rs.getFloat("mon_ser"));
						rtdata.setMon_conn_res(rs.getFloat("mon_conn_res"));
						rtdata.setMon_cap(rs.getFloat("mon_cap"));
						rtdata.setMon_JH_curr(rs.getFloat("mon_JH_curr"));
						//System.out.println(rtdata);
						list.add(rtdata);
					}
				} catch (SQLException e) {
					e.printStackTrace();
				}
			
				return list;
			}
		});
	}
	//实时监测<-------跨域----------->
	public List serchByCondition_ky(Object obj) {
		Batt_rtdata br=(Batt_rtdata)obj;
		String sql="select num,BattGroupId,rec_datetime,mon_num,mon_vol,mon_tmp,mon_res,mon_ser,mon_conn_res,mon_cap,mon_JH_curr from db_ram_db.tb_batt_rtdata where BattGroupId=?  order by mon_num";
		return DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{br.getBattGroupId()}, new CallBack() {
			
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				try {
					while(rs.next()){
						Batt_rtdata rtdata=new Batt_rtdata();
						rtdata.setNum(rs.getInt("num"));
						rtdata.setBattGroupId(rs.getInt("BattGroupId"));
						rtdata.setRec_datetime(rs.getDate("rec_datetime"));
						rtdata.setMon_num(rs.getInt("mon_num"));
						rtdata.setMon_vol(rs.getFloat("mon_vol"));
						rtdata.setMon_tmp(rs.getFloat("mon_tmp"));
						rtdata.setMon_res(rs.getFloat("mon_res"));
						rtdata.setMon_ser(rs.getFloat("mon_ser"));
						rtdata.setMon_conn_res(rs.getFloat("mon_conn_res"));
						rtdata.setMon_cap(rs.getFloat("mon_cap"));
						rtdata.setMon_JH_curr(rs.getFloat("mon_JH_curr"));
						//System.out.println(rtdata);
						list.add(rtdata);
					}
				} catch (SQLException e) {
					e.printStackTrace();
				}
			
				return list;
			}
		});
	}
    // 电池组单体最大值和最小值
	public List serchByInfo(Object obj) {
		BattInf binf=(BattInf)obj;
		String sql=" SELECT battgroupid,max(binary tb_batt_rtdata.mon_vol) as maxmonvol,min(binary tb_batt_rtdata.mon_vol) as minmonvol from db_ram_db.tb_batt_rtdata where BattGroupId=?  limit 1 ";
		List list= DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{binf.getBattGroupId()}, new CallBack() {
			
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				try {
					while(rs.next()){
						Batt_rtdata rtdata=new Batt_rtdata();
						
						rtdata.setBattGroupId(rs.getInt("BattGroupId"));
						
						rtdata.setMon_vol(rs.getFloat("maxmonvol"));
						rtdata.setMon_tmp(rs.getFloat("minmonvol"));
						
						
						list.add(rtdata);
					}
				} catch (SQLException e) {
					e.printStackTrace();
				}
			
				return list;
			}
		});
	
		return list;
	}
    //根据电池组id查询电池组内前三的内阻数据
	public List serchByThirdBatt(Object obj){
		BattInf binf=(BattInf)obj;
		String sql="select db_ram_db.tb_batt_rtdata.battgroupid,mon_num,mon_vol,mon_tmp,mon_res,mon_ser,mon_conn_res,mon_cap " +
				" from db_ram_db.tb_batt_rtdata,db_battinf.tb_battinf  " +
				" where db_ram_db.tb_batt_rtdata.BattGroupId=db_battinf.tb_battinf.battgroupid " +
				" and db_battinf.tb_battinf.fbsdeviceid=? and groupindexinfbsdevice=? " +
				" order by mon_res desc limit 0,"+BattTestData.mon_res_num;
		//System.out.println(sql);
		List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{binf.getFBSDeviceId(),binf.getGroupIndexInFBSDevice()}, new CallBack() {
			
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				//int num=0;//计数取前五
				try {
					while(rs.next()){
/*						if(num>=BattTestData.mon_res_num){
							break;
						}
*/						Batt_rtdata rtdata=new Batt_rtdata();
						rtdata.setBattGroupId(rs.getInt("battGroupId"));
						rtdata.setMon_num(rs.getInt("mon_num"));
						rtdata.setMon_vol(rs.getFloat("mon_vol"));
						rtdata.setMon_tmp(rs.getFloat("mon_tmp"));
						rtdata.setMon_res(rs.getFloat("mon_res"));
						rtdata.setMon_ser(rs.getFloat("mon_ser"));
						rtdata.setMon_conn_res(rs.getFloat("mon_conn_res"));
						rtdata.setMon_cap(rs.getFloat("mon_cap"));
						list.add(rtdata);
						//num++;
					}
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				return list;
			}
		});
		return list;
	}
	//历史监测中查询出电池组的实时内阻并将其导出报表
	public List serchResById(Object obj) {
		Batt_rtdata br=(Batt_rtdata)obj;
		String sql="select BattGroupId,mon_num,mon_res  from db_ram_db.tb_batt_rtdata where BattGroupId=?  order by mon_num";
		List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{br.getBattGroupId()}, new CallBack() {
			
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				try {
					while(rs.next()){
						Batt_rtdata rtdata=new Batt_rtdata();
						rtdata.setBattGroupId(rs.getInt("BattGroupId"));
						rtdata.setMon_num(rs.getInt("mon_num"));
						rtdata.setMon_res(rs.getFloat("mon_res"));
						list.add(rtdata);
					}
				} catch (SQLException e) {
					e.printStackTrace();
				}
			
				return list;
			}
		});
		return list;
	}

	public static void main(String[] args) {
		Batt_rtdataDAOImpl bimpl=new Batt_rtdataDAOImpl();
		BattInf binf=new BattInf();
		//binf.setBattGroupId(1000007);
		binf.setFBSDeviceId(910000001);
		binf.setGroupIndexInFBSDevice(0);
		/*List<Batt_rtdata> list=bimpl.serchByThirdBatt(binf);
		for (Batt_rtdata b : list) {
			System.out.println(b);
		}*/
		Batt_rtdata br=new Batt_rtdata();
		br.setBattGroupId(1002101);
		List<Batt_rtdata> list=bimpl.serchByCondition_ky(br);
		for (Batt_rtdata b : list) {
			System.out.println(b);
		}
	}
}