package com.fgkj.dao.impl;

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

import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.CallBack;
import com.fgkj.dao.DAOHelper;
import com.fgkj.dao.UinfDaoFactory;
import com.fgkj.db.DBUtil;
import com.fgkj.db.IDatabaseName;
import com.fgkj.dto.User_battgroup_baojigroup;
import com.fgkj.dto.User_battgroup_baojigroup_usr;
import com.fgkj.dto.User_inf;
import com.fgkj.dto.User_log;
import com.fgkj.services.User_logService;

public class User_battgroup_baojigroup_usrImpl implements BaseDAO, CallBack {

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

				userbaojigroupusr
						.setNum(rs.getInt("num"));

				userbaojigroupusr.setBaoji_group_id(Integer.parseInt(rs
						.getString("baoji_group_id")));
				userbaojigroupusr
						.setuId(rs.getInt("uId"));
				
				list.add(userbaojigroupusr);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return list;
	}
    //5.3添加(包机组中添加用户)
	public boolean add(Object obj) {
		User_battgroup_baojigroup_usr uusr = (User_battgroup_baojigroup_usr) obj;
		String sql = "insert into db_user.tb_user_battgroup_baojigroup_usr(baoji_group_id,Uid) values(?,?)";
		Boolean bl = DAOHelper.executeUpdate(
				DBUtil.getConn(), sql, new Object[] {uusr.getBaoji_group_id(),uusr.getuId()});
		return bl;
	}
	 //5.3添加(包机组中添加用户)(多条记录)
	public boolean addPro(Object obj) {
		List<User_battgroup_baojigroup_usr> list=(List) obj;
		List<User_log> listU=new ArrayList<User_log>();//存放user_log
		ArrayList sql_strs=new ArrayList();
		if(list!=null&&list.size()>0){
			for (User_battgroup_baojigroup_usr uusr : list) {
				String sql = "insert into db_user.tb_user_battgroup_baojigroup_usr(baoji_group_id,Uid) values("+uusr.getBaoji_group_id()+","+uusr.getuId()+")";
				sql_strs.add(sql);
				{
					String msg="添加"+uusr.getUname()+"用户至"+uusr.getBaoji_group_name()+"包机组中";
					User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Increase, msg);
					listU.add(ulog);
				 }
			}
		}
		boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_strs);
		(new User_logService()).addPro(listU);//将用户的操作记录下来
		return bl;
	}

	public boolean update(Object obj) {
		User_battgroup_baojigroup_usr uusr = (User_battgroup_baojigroup_usr) obj;
		String sql = "update db_user.tb_user_battgroup_baojigroup_usr set baoji_group_id=?,Uid=? where num=?";
		Boolean bl = DAOHelper.executeUpdate(
				DBUtil.getConn(), sql, new Object[] {uusr.getBaoji_group_id(),uusr.getuId(),uusr.getNum()});
		return bl;
	}
    //5.3删除(删除包机组中的用户)
	public boolean del(Object obj) {
		User_battgroup_baojigroup_usr uusr = (User_battgroup_baojigroup_usr) obj;
		String sql = "delete from db_user.tb_user_battgroup_baojigroup_usr where num=?";
		Boolean bl = DAOHelper.executeUpdate(
				DBUtil.getConn(), sql, new Object[] {uusr.getNum()});
		return bl;
	}
	
	//5.3删除(删除指定包机组下所有用户)
	public String delAll(Object obj) {
			User_battgroup_baojigroup ubao=(User_battgroup_baojigroup) obj;
			String sql = "delete from db_user.tb_user_battgroup_baojigroup_usr where baoji_group_id="+ubao.getBaoji_group_id();
			return sql;
		}
	public List searchAll() {
		String sql = "select * from db_user.tb_user_battgroup_baojigroup_usr";
		List list = DAOHelper.executeQuery(sql,
				DBUtil.getConn(), null,
				new User_battgroup_baojigroup_usrImpl());
		return list;
	}

	public List serchByCondition(Object obj) {
		User_battgroup_baojigroup_usr uusr = (User_battgroup_baojigroup_usr) obj;
		String sql = "select * from db_user.tb_user_battgroup_baojigroup_usr where num=?";
		List list = DAOHelper.executeQuery(sql,
				DBUtil.getConn(), new Object[] {uusr.getNum()},
				new User_battgroup_baojigroup_usrImpl());
		return list;
	}

	 //5.3查询不在某包机组下的用户
	public List serchByInfo(Object obj) {
		User_battgroup_baojigroup_usr uusr=(User_battgroup_baojigroup_usr) obj;
		String sql="select uid,uname from db_user.tb_user_inf where uid not in(select uid from db_user.tb_User_battgroup_baojigroup_usr where baoji_group_id=?)";
		List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{uusr.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"));
						list.add(uinf);
					}
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				return list;
			}
		});
		return list;
	}


	public static void main(String[] args) {
		
		User_battgroup_baojigroup_usrImpl uu= new User_battgroup_baojigroup_usrImpl();
		/*List<User_battgroup_baojigroup_usr> list =uu.searchAll();
		for (User_battgroup_baojigroup_usr u : list) {
			System.out.println(u);
		}*/
		User_battgroup_baojigroup_usr u=new User_battgroup_baojigroup_usr();
		u.setNum(6);
		List<User_battgroup_baojigroup_usr> list =uu.searchAll();
		for (User_battgroup_baojigroup_usr uuu : list) {
			System.out.println(uuu);
		}
	}
}