package com.fgkj.dao.impl;

import java.sql.ResultSet;
import java.sql.SQLException;
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.BattInf;
import com.fgkj.dto.User_battgroup_baojigroup;
import com.fgkj.dto.User_inf;
import com.sun.org.apache.xerces.internal.impl.dv.dtd.IDDatatypeValidator;

public class User_battgroup_baojigroupImpl implements BaseDAO, CallBack {

	public List getResults(ResultSet rs) {
		List list = new ArrayList();
		try {
			while (rs.next()) {
				User_battgroup_baojigroup userbaojigroup = new User_battgroup_baojigroup();

				userbaojigroup.setBaoji_group_id(rs.getInt("baoji_group_id"));

				userbaojigroup.setBaoji_group_name(rs
						.getString("baoji_group_name"));

				list.add(userbaojigroup);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return list;
	}

	//5.3添加新包机组
	public boolean add(Object obj) {
		User_battgroup_baojigroup ubao=(User_battgroup_baojigroup) obj;
		String sql="insert into db_user.tb_user_battgroup_baojigroup(baoji_group_name) values(?)";
		Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql,new Object[]{ubao.getBaoji_group_name()});
		return bl;
	}
    //5.3修改包机组名
	public boolean update(Object obj) {
		User_battgroup_baojigroup ubao=(User_battgroup_baojigroup) obj;
		String sql="update db_user.tb_user_battgroup_baojigroup set baoji_group_name=? where baoji_group_id=?";
		Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql,new Object[]{ubao.getBaoji_group_name(),ubao.getBaoji_group_id()});
		return bl;
	}
	
	//5.3删除包机组
	public boolean del(Object obj) {
		User_battgroup_baojigroup ubao=(User_battgroup_baojigroup) obj;
		String sql="delete db_user.tb_user_battgroup_baojigroup from db_user.tb_user_battgroup_baojigroup where baoji_group_id=?";
		Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql,new Object[]{ubao.getBaoji_group_id()});
		return bl;
	}

	//5.3删除包机组(多表删除事务回滚)
	public String delPro(Object obj) {
		User_battgroup_baojigroup ubao=(User_battgroup_baojigroup) obj;
		String sql="delete db_user.tb_user_battgroup_baojigroup from db_user.tb_user_battgroup_baojigroup where baoji_group_id="+ubao.getBaoji_group_id();
		return sql;
	}

	//5.3查所有包机组
	public List searchAll() {
		String sql = "select baoji_group_id,baoji_group_name from db_user.tb_user_battgroup_baojigroup";
		List list= DAOHelper.executeQuery(sql,
				DBUtil.getConn(), null,
				new User_battgroup_baojigroupImpl());
		return list;
	}

	//5.3根据包机组id查包机组对应的用户
	public List serchByCondition(Object obj) {
		User_battgroup_baojigroup ubao=(User_battgroup_baojigroup) obj;
		String sql="select  distinct(db_user.tb_user_inf.uid) ,db_user.tb_user_inf.uName,db_user.tb_user_battgroup_baojigroup_usr.num " +
				"from db_user.tb_user_inf,db_user.tb_user_battgroup_baojigroup,db_user.tb_user_battgroup_baojigroup_usr " +
				"where db_user.tb_user_battgroup_baojigroup.baoji_group_id=db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id  " +
				"and db_user.tb_user_battgroup_baojigroup_usr.uId=db_user.tb_user_inf.uId " +
				"and db_user.tb_user_battgroup_baojigroup.baoji_group_id=? " +
				"order by db_user.tb_user_inf.uid";
		List list= DAOHelper.executeQuery(sql,
				DBUtil.getConn(), new Object[]{ubao.getBaoji_group_id()},
				new CallBack() {
					
					public List getResults(ResultSet rs) {
						List list=new ArrayList();
						try {
							while(rs.next()){
								User_inf uinf=new User_inf();
								uinf.setUId(rs.getInt("uId"));
								uinf.setUName(rs.getString("uName"));
								uinf.setUBaojiusr(rs.getInt("num"));
								list.add(uinf);
							}
						} catch (SQLException e) {
							// TODO Auto-generated catch block
							e.printStackTrace();
						}
						return list;
					}
				});
		return list;
	}

	//5.3根据包机组id查对应的机房和电池组
	public List serchByInfo(Object obj) {
		User_battgroup_baojigroup ubao=(User_battgroup_baojigroup) obj;
		String sql="select  distinct(db_battinf.tb_battinf.BattGroupId)" +
				",db_battinf.tb_battinf.stationid,db_battinf.tb_battinf.BattGroupId,db_battinf.tb_battinf.StationName,db_battinf.tb_battinf.BattGroupName " +
				"from db_battinf.tb_battinf,db_user.tb_user_battgroup_baojigroup,db_user.tb_user_battgroup_baojigroup_battgroup " +
				"where  db_user.tb_user_battgroup_baojigroup.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id " +
				"and db_user.tb_user_battgroup_baojigroup_battgroup.stationid=db_battinf.tb_battinf.stationid " +
				"and db_user.tb_user_battgroup_baojigroup.baoji_group_id=?  and db_user.tb_user_battgroup_baojigroup_battgroup.BattGroupId = db_battinf.tb_battinf.BattGroupId " +
				"order by db_battinf.tb_battinf.BattGroupId";
		List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{ubao.getBaoji_group_id()}, new CallBack() {
			
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				try {
					while(rs.next()){
						BattInf binf=new BattInf();
						
						binf.setBattGroupId(rs.getInt("battGroupId"));
						binf.setStationName(rs.getString("stationName"));
						binf.setStationId(rs.getString("stationid"));
						binf.setBattGroupName(rs.getString("battGroupName"));
						list.add(binf);
					}
				} catch (SQLException e) {
					e.printStackTrace();
				}
				return list;
			}
		});
		return list;
	}

	public static void main(String[] args) {
		
		User_battgroup_baojigroupImpl ub= new User_battgroup_baojigroupImpl();
		/*List<User_battgroup_baojigroup> list =ub.searchAll();
		for (User_battgroup_baojigroup u : list) {
			System.out.println(u);
		}*/
		/*User_battgroup_baojigroup u=new User_battgroup_baojigroup();
		u.setBaoji_group_id(100001);
		List<User_inf> list =ub.serchByCondition(u);
		for (User_inf uu : list) {
			System.out.println(uu);
		}*/
		User_battgroup_baojigroup u=new User_battgroup_baojigroup();
		u.setBaoji_group_id(100001);
		List<BattInf> list =ub.serchByInfo(u);
		for (BattInf b : list) {
			System.out.println(b);
		}
	}
}