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);
|
}
|
}
|
}
|
