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_inf;
import com.fgkj.dto.User_log;
import com.fgkj.dto.User_permitgroup;
import com.fgkj.dto.User_permitgroup_data;
import com.fgkj.services.User_logService;

public class User_permitgroup_dataImpl implements BaseDAO,CallBack{

	public List getResults(ResultSet rs) {
		List list=new ArrayList();
		try {
			while(rs.next()){
				User_permitgroup_data udata=new User_permitgroup_data();
				udata.setNum(rs.getInt("num"));
				udata.setPermit_group_id(rs.getInt("permit_group_id"));
				udata.setuId(rs.getInt("uId"));
				list.add(udata);
				
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return list;
	}
    //5.2添加(给权限组添加用户)
	public boolean add(Object obj) {
		User_permitgroup_data udata=(User_permitgroup_data) obj;
		String sql="insert into db_user.tb_user_permitgroup_data(permit_group_id,uId) values(?,?)";
		Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{udata.getPermit_group_id(),udata.getuId()});
		return bl;
	}
	//5.2添加(给权限组添加用户)(多用户)
	public boolean addPro(Object obj) {
		List<User_permitgroup_data> 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_permitgroup_data udata : list) {
				String sql="insert into db_user.tb_user_permitgroup_data(permit_group_id,uId) values("+udata.getPermit_group_id()+","+udata.getuId()+")";
			    sql_strs.add(sql);
			    {
					String msg="添加"+udata.getUname()+"用户至"+udata.getPermit_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_permitgroup_data udata=(User_permitgroup_data) obj;
		String sql="update db_user.tb_user_permitgroup_data set permit_group_id=?,uId=? where num=?";
		Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{udata.getPermit_group_id(),udata.getuId(),udata.getNum()});
		return bl;
	}
    //5.2删除(给权限组删除用户)
	public boolean del(Object obj) {
		User_permitgroup_data udata=(User_permitgroup_data) obj;
		String sql="delete from db_user.tb_user_permitgroup_data where num=? ";
		Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{udata.getNum()});
		return bl;
	}
	//5.2删除(删除权限组时将在tb_user_permitgroup_data表中所有permit_group_id删除)
		public boolean delPermitId(Object obj) {
			User_permitgroup ugroup=(User_permitgroup) obj;
			String sql="delete from db_user.tb_user_permitgroup_data where permit_group_id=?";
			Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{ugroup.getPermit_group_id()});
			return bl;
		}
	public List searchAll() {
		String sql="select * from db_user.tb_user_permitgroup_data";
		List list=DAOHelper.executeQuery(sql, DBUtil.getConn(),null, new User_permitgroup_dataImpl());
		return list;
	}

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

	 //5.2查询不存在权限组中的用户
	public List serchByInfo(Object obj) {
		User_permitgroup_data udata=(User_permitgroup_data) obj;
		String sql="select distinct(tb_user_inf.uid),tb_user_inf.uname from db_user.tb_user_inf,db_user.tb_user_permitgroup_data  " +
				"where tb_user_inf.uid not in(select distinct(db_user.tb_user_permitgroup_data.uid) from db_user.tb_user_permitgroup_data where tb_user_permitgroup_data.permit_group_id=?) " +
				"and tb_user_inf.uid!=1002 ";
		List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{udata.getPermit_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_permitgroup_dataImpl ud=new User_permitgroup_dataImpl();
		/*List<User_permitgroup_data>list=ud.searchAll();
		for(User_permitgroup_data u:list){
			System.out.println(u);
		}*/
		User_permitgroup_data u=new User_permitgroup_data();
		u.setPermit_group_id(100001);
		u.setNum(4);
		//List<User_permitgroup_data>list=ud.serchByCondition(u);
		
		List<User_inf>list=ud.serchByInfo(u);
		for(User_inf uu:list){
			System.out.println(uu);
		}
	}
}