package com.fgkj.dao.impl;

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

import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.CallBack;
import com.fgkj.dao.DAOHelper;
import com.fgkj.db.DBUtil;
import com.fgkj.db.IDatabaseName;
import com.fgkj.dto.Battresdata_inf;
import com.fgkj.dto.Batttestdata_inf;
import com.fgkj.dto.Batttestdatastop;
import com.sun.org.apache.commons.logging.impl.NoOpLog;

public class Battresdata_infDAOImpl implements BaseDAO,CallBack{

	public List getResults(ResultSet rs) {
		List list=new ArrayList();
		try {
			while(rs.next()){
				Battresdata_inf b=new Battresdata_inf();
				b.setNum(rs.getInt("num"));
				b.setBattGroupId(rs.getInt("BattGroupId"));
				b.setTest_record_count(rs.getInt("test_record_count"));
				b.setTest_record_count_ex(rs.getInt("test_record_count_ex"));
				b.setTest_type(rs.getInt("test_type"));
				b.setData_new(rs.getFloat("data_new"));
				b.setData_available(rs.getInt("data_available"));
				b.setTest_starttime(rs.getTimestamp("test_starttime"));
				b.setTest_starttime_ex(rs.getTimestamp("test_starttime_ex"));
				b.setTest_devtype(rs.getInt("test_devtype"));
				b.setRecord_time(rs.getTimestamp("record_time"));
				b.setGroup_vol(rs.getFloat("group_vol"));
				b.setTest_curr(rs.getFloat("test_curr"));
				b.setUpload_usr_id(rs.getInt("upload_usr_id"));
				list.add(b);
				//System.out.println(b);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} 
		return list;
	}
	
	public boolean add(Object obj) {
		Battresdata_inf binf=(Battresdata_inf) obj;
		String sql="insert into db_batt_testdata.tb_battresdata_inf(BattGroupId,test_record_count,test_record_count_ex,test_type,data_new,data_available,test_starttime,test_starttime_ex,test_devtype,record_time,group_vol," +
				"test_curr,upload_usr_id) values(?,?,?,?,?,?,?,?,?,?,?,?,?)";
		Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{binf.getBattGroupId(),binf.getTest_record_count(),binf.getTest_record_count_ex(),
			binf.getTest_type(),binf.getData_new(),binf.getData_available(),binf.getTest_starttime(),binf.getTest_starttime_ex(),binf.getTest_devtype(),binf.getRecord_time(),binf.getGroup_vol(),
			binf.getTest_curr(),binf.getUpload_usr_id()});
		return bl;
	}

	public boolean update(Object obj) {
		Battresdata_inf binf=(Battresdata_inf) obj;
		String sql="update db_batt_testdata.tb_battresdata_inf set BattGroupId=?,test_record_count=?,test_record_count_ex=?,test_type=?,data_new=?,data_available=?,test_starttime=?,test_starttime_ex=?,test_devtype=?,record_time=?,group_vol=?," +
				"test_curr=?,upload_usr_id=? where num=?";
		Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{binf.getBattGroupId(),binf.getTest_record_count(),binf.getTest_record_count_ex(),
			binf.getTest_type(),binf.getData_new(),binf.getData_available(),binf.getTest_starttime(),binf.getTest_starttime_ex(),binf.getTest_devtype(),binf.getRecord_time(),binf.getGroup_vol(),
			binf.getTest_curr(),binf.getUpload_usr_id(),binf.getNum()});
		return bl;
	}

	//6.1电池充放电删除操作
	public boolean del(Object obj) {
		Battresdata_inf rinf=(Battresdata_inf) obj;
		String sql="delete from db_batt_testdata.tb_battresdata_inf where num=?";
		Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{rinf.getNum()});
		return bl;
	}
	//电池充/放电数据管理删除
	public String delPro(Object obj) {
		Battresdata_inf rinf=(Battresdata_inf) obj;
		String sql="delete from db_batt_testdata.tb_battresdata_inf where num="+rinf.getNum();
		return sql;
	}

	public List searchAll() {
		String sql="select * from db_batt_testdata.tb_battresdata_inf";
	//	System.out.println(sql);
		List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new Battresdata_infDAOImpl());
		return list;
	}
	//1.1测试battgroupid在battresdata_inf中是否存在
	public List judge(Object obj){
				Battresdata_inf bti=(Battresdata_inf)obj;
				String sql="select table_name from `INFORMATION_SCHEMA`.`TABLES` " +
						"where table_name ='tb_battresdata_"+bti.getBattGroupId()+"'and TABLE_SCHEMA='db_batt_testdata'";
				return DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
					
					public List getResults(ResultSet rs) {
						List list=new ArrayList();
						try {
							while(rs.next()){
								String name=rs.getString("table_name");
								list.add(name);
								//System.out.println(binf);	
							}
						} catch (SQLException e) {
							e.printStackTrace();
						}
						return list;
					}
				});
				
			}

	//battgroupid是不是存在battresdata_inf中
	public List serchByCondition(Object obj) {
			Battresdata_inf btd=(Battresdata_inf)obj;
				String sql="select num,BattGroupId,test_record_count,test_record_count_ex,test_type,data_new,data_available,test_starttime,test_starttime_ex,test_devtype,record_time,group_vol,test_curr,upload_usr_id from db_batt_testdata.tb_battresdata_inf" +
						" where battgroupid=?";
			//	System.out.println(sql);
				return DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{btd.getBattGroupId()}, new Battresdata_infDAOImpl());
				
		}

	//6.2根据battgroupi和test_starttime查test_record_count
	public List serchTest_record_count(Object obj) {
				Battresdata_inf rinf=(Battresdata_inf)obj;
				String sql="select test_record_count  " +
						"from db_batt_testdata.tb_battresdata_inf where BattGroupId=?  and (test_starttime)=(?) ";
				return DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{rinf.getBattGroupId(),rinf.getTest_starttime()}, new CallBack() {
					
					public List getResults(ResultSet rs) {
						List list=new ArrayList();
						try {
							while(rs.next()){
								Battresdata_inf rinf=new Battresdata_inf();
								
								rinf.setTest_record_count(rs.getInt("test_record_count"));
								list.add(rinf);
								//System.out.println(rinf);	
							}
						} catch (SQLException e) {
							e.printStackTrace();
						}
						return list;
					}
				});
			}

	//6.4.1根据条件查询符合条件的测试完成的电池组(蓄电池电导测试完成率)
		/*
		 * data_available 中存放层次
		 */
	public List serchComplete(Object obj){
		Battresdata_inf rinf=(Battresdata_inf) obj;
		String sql="";
		String baseSql="select distinct(tb_battresdata_inf.battgroupid)  from db_batt_testdata.tb_battresdata_inf,db_battinf.tb_battinf " +
				   "where  tb_battresdata_inf.BattGroupId=db_battinf.tb_battinf.BattGroupId " +
				   "and (test_starttime)>=(?) and (test_starttime)<=(?) ";
		//上传方式
		String usrSqlT="and upload_usr_id!=? " ;
		String usrSqlU="and upload_usr_id!=0 and upload_usr_id!=? " ;
		String usrSqlF="and upload_usr_id=? " ;
		if(rinf.getUpload_usr_id()==100){//全部
			baseSql+=usrSqlT;
		}else{
			if(rinf.getUpload_usr_id()==0){
				baseSql+=usrSqlF;
			}else{
				baseSql+=usrSqlU;
			}
		}
		String levelSql=" and db_battinf.tb_battinf.stationname4 like ? and db_battinf.tb_battinf.stationname3 like ? and db_battinf.tb_battinf.stationname2 like ? and db_battinf.tb_battinf.stationname1 like ?  ";//分组层次
		sql=baseSql+levelSql;
		
		//System.out.println(sql);
		List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{rinf.getTest_starttime(),rinf.getTest_starttime_ex(),rinf.getUpload_usr_id(),"%"+rinf.getStationname4()+"%","%"+rinf.getStationname3()+"%","%"+rinf.getStationname2()+"%","%"+rinf.getStationname1()+"%"}, new CallBack() {
			
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				try {
					while(rs.next()){
						Battresdata_inf rinf=new Battresdata_inf();
						rinf.setBattGroupId(rs.getInt("battGroupId"));
						list.add(rinf);
					}
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				return list;
			}
		});
		return list;
	}

	//6.4.3根据条件查询符合条件的测试完成的电池组(蓄电池电导合格率)
		/*
		 * data_available 中存放层次
		 */
	public List serchSer(Object obj){
		Battresdata_inf rinf=(Battresdata_inf) obj;
		String sql="";
		String baseSql="select distinct(tb_battresdata_inf.battgroupid),test_starttime,test_record_count  from db_batt_testdata.tb_battresdata_inf,db_battinf.tb_battinf " +
				   "where  tb_battresdata_inf.BattGroupId=db_battinf.tb_battinf.BattGroupId " +
				   //"and upload_usr_id=? "+
				   "and (test_starttime)>=(?) and (test_starttime)<=(?) ";
		//上传方式
		String usrSqlT=" and upload_usr_id!=? " ;
		String usrSqlU=" and upload_usr_id!=0 and  upload_usr_id!=? " ;
		String usrSqlF=" and upload_usr_id=? " ;
		if(rinf.getUpload_usr_id()==100){//全部
			baseSql+=usrSqlT;
		}else{
			if(rinf.getUpload_usr_id()==0){
				baseSql+=usrSqlF;
			}else{
				baseSql+=usrSqlU;
			}
		}
		String levelSql=" and db_battinf.tb_battinf.stationname4 like ? and db_battinf.tb_battinf.stationname3 like ? and db_battinf.tb_battinf.stationname2 like ? and db_battinf.tb_battinf.stationname1 like ?  ";//分组层次
		sql=baseSql+levelSql;
		
		String endSql=" order by tb_battresdata_inf.battgroupid asc,test_starttime desc ";
	    sql=sql+=endSql;
		//System.out.println(sql);
		List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{rinf.getTest_starttime(),rinf.getTest_starttime_ex(),rinf.getUpload_usr_id(),"%"+rinf.getStationname4()+"%","%"+rinf.getStationname3()+"%","%"+rinf.getStationname2()+"%","%"+rinf.getStationname1()+"%"}, new CallBack() {
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				int id=0;
					try {
						while(rs.next()){
							Battresdata_inf rinf=new Battresdata_inf();
							if(id==rs.getInt("battGroupId")){   //时间倒序取最近的一次
								continue;
							}else{
								rinf.setBattGroupId(rs.getInt("battGroupId"));
								id=rs.getInt("battGroupId");
							}	
							rinf.setTest_record_count(rs.getInt("test_record_count"));
							rinf.setTest_starttime(rs.getTimestamp("test_starttime"));
							list.add(rinf);
						}	
					} 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;
	}
	public static void main(String[] args) {
		Battresdata_infDAOImpl bstd=new Battresdata_infDAOImpl();
		Battresdata_inf bst=new Battresdata_inf();
		bst.setTest_record_count(1);
		List<Battresdata_inf> list=bstd.serchByCondition(bst);
		System.out.println(list.size());
		for(Battresdata_inf b:list){
			System.out.println(b);
		}
//		List<Battresdata_inf> list=bstd.searchAll();
//		for(Battresdata_inf b:list){
//			System.out.println(b);
//		}
	}

}