package com.fgkj.dao.impl;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
import com.fgkj.actions.ActionUtil;
|
import com.fgkj.dao.BaseDAO;
|
import com.fgkj.dao.CallBack;
|
import com.fgkj.dao.DAOHelper;
|
import com.fgkj.db.DBUtil;
|
import com.fgkj.dto.User_inf;
|
|
public class User_infImpl implements BaseDAO, CallBack {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
//添加用户
|
@Override
|
public boolean add(Object obj) {
|
User_inf uinf=(User_inf) obj;
|
String sql=" insert into db_user.tb_user_inf(USnId,UName,Upassword) values(?,?,?) ";
|
boolean bl=DAOHelper.executeUpdate( DBUtil.getConn(), sql, new Object[]{uinf.getUSnId(),uinf.getUName(),ActionUtil.EncryptionBase64(uinf.getUSnId())});
|
return bl;
|
}
|
//修改用户密码
|
@Override
|
public boolean update(Object obj) {
|
User_inf uinf=(User_inf) obj;
|
String sql=" update db_user.tb_user_inf set USnId=?,Upassword=? where uid=? ";
|
boolean bl=DAOHelper.executeUpdate( DBUtil.getConn(), sql, new Object[]{uinf.getUSnId(),ActionUtil.EncryptionBase64(uinf.getUSnId()),uinf.getUId()});
|
return bl;
|
}
|
//删除用户
|
@Override
|
public boolean del(Object obj) {
|
User_inf uinf=(User_inf) obj;
|
String sql="delete from db_user.tb_user_inf where uid=? ";
|
boolean bl=DAOHelper.executeUpdate( DBUtil.getConn(), sql, new Object[]{uinf.getUId()});
|
return bl;
|
}
|
//查询所有的用户(不含密码)
|
@Override
|
public List searchAll() {
|
String sql=" select distinct uid,UName from db_user.tb_user_inf ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
|
|
@Override
|
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;
|
}
|
//根据输入的用户名查询存在数据库中的用户名和加密密码
|
@Override
|
public List serchByCondition(Object obj) {
|
User_inf uinf=(User_inf) obj;
|
String sql = "select tb_user_inf.uid,uname,upassword,unote,IFNULL(db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id,0) as baoji_group_id from db_user.tb_user_inf "
|
+ " left join db_user.tb_user_battgroup_baojigroup_usr on tb_user_inf.uid=tb_user_battgroup_baojigroup_usr.uid"
|
+ " where uname=? ";
|
List list = DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{uinf.getUName()},
|
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.setUNote(rs.getString("baoji_group_id"));
|
uinf.setUpassword(rs.getString("upassword"));
|
list.add(uinf);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
@Override
|
public List serchByInfo(Object obj) {
|
return null;
|
}
|
//权限管理——————查出所有的用户标识是否有权限
|
public List serchUserByGroup() {
|
String sql=" select distinct tb_user_inf.uid,uname,IFNULL(tb_user_battgroup_baojigroup_usr.baoji_group_id,0) as permit_id from tb_user_inf "
|
+ " LEFT JOIN tb_user_battgroup_baojigroup_usr on tb_user_inf.uid=tb_user_battgroup_baojigroup_usr.uId "
|
+ " order by tb_user_inf.uid asc ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[] {}, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()) {
|
User_inf u=new User_inf();
|
u.setUId(rs.getInt("uid"));
|
u.setUName(rs.getString("uname"));
|
u.setUNote(rs.getString("permit_id"));
|
list.add(u);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
|
|
}
|