网络多媒体资源管理信息系统的开发(四)
return user;
}
/**
* 统计有多少数据
* @return count
*/
public static int queryUserInfoDTO() {
String sql = "select count(*) counts from t_user";
Connection conn = DBUtils.getConnection();
PreparedStatement pstm = null;
ResultSet set = null;
int count = 0;
try {
pstm = conn.prepareStatement(sql);
set = pstm.executeQuery();
if(set.next()) {
count = set.getInt("counts");
}
} catch (Exception e) {
e.printStackTrace();
} finally {
DBUtils.closeConnnection(conn);
}
if (count % SIZE != 0)
count = count / SIZE + 1;
else
count = count / SIZE;
return count;
}
/**
* 查询所有用户
* @param size
* @param pageNo
* @return userList
*/
public static List<UserDTO> queryBirthPlaceDTO(int size,int pageNo) {
List<UserDTO> userList = new ArrayList<UserDTO>();
StringBuffer sql = new StringBuffer();
sql.append("select top ");
sql.append(size);
sql.append(" * from t_user");
sql.append(" where user_id not in");
sql.append("(select top ");
sql.append(size * (pageNo - 1));
sql.append(" user_id from t_user order by user_id asc) order by user_id asc");
Connection conn = DBUtils.getConnection();
PreparedStatement pstm = null;
ResultSet set = null;
try {
pstm = conn.prepareStatement(sql.toString());
set = pstm.executeQuery();
while(set.next()) {
UserDTO user = new UserDTO();
user.setUserID(set.getInt("user_id"));
user.setUserName(set.getString("user_name"));
user.setRealName(set.getString("real_name")); user.setBirthPlace(BrithPlaceDAO.queryBirthPlaceDTOById(set.getInt("birthplace_id"))); user.setJob(JobDAO.queryJobDTOById(set.getInt("job_id")));
user.setRole(RoleDAO.queryRoleDTOById(set.getInt("role_id")));
user.setUserEmail(set.getString("user_email"));
user.setRegisterTime(set.getTimestamp("reg_date"));
user.setLastLogin(set.getTimestamp("last_login"));
user.setUserScore(set.getInt("user_score"));
user.setUserState(set.getInt("user_state"));
userList.add(user);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
DBUtils.closeConnnection(conn);
}
return userList;
}
/**
* 用户登录信息验证
* @param username
* @param password
* @return user
* @throws PasswordInvalidException
* @throws UsernameIsNotExistException
*/
public static UserDTO validate (String username, String password)
throws PasswordInvalidException,UsernameIsNotExistException{
UserDTO user = null;
Connection conn = DBUtils.getConnection();
String sql = "select * from t_user where user_name = ?";
PreparedStatement pstm = null;
ResultSet set = null;
try {
pstm = conn.prepareStatement(sql);
pstm.setString(1, username);
set = pstm.executeQuery();
if (set.next()) {
int id = set.getInt("user_id");
if (set.getString("user_password").equals(password)) {
user = new UserDTO();
user.setUserID(id);
user.setUserName(username);
user.setRole(RoleDAO.queryRoleDTOById(set.getInt("role_id")));
user.setLastLogin(set.getTimestamp("last_login"));
user.setUserScore(set.getInt("user_score"));
}else{
throw new PasswordInvalidException();
}
}else{
throw new UsernameIsNotExistException();
}
} catch (SQLException e) {
e.printStackTrace();
}finally{
DBUtils.closeConnnection(conn);
}
return user;
}
/**
* 判断注册时用户名是否可用
* 返回true表示用户名可用
* 返回false表示不可用
* @param userName
* @return
* @throws UserNameHasExistException
*/
public static boolean validate(String userName) throws UserNameHasExistException {
Connection conn = DBUtils.getConnection();
String sql = "select * from t_user where user_name = ?";
PreparedStatement pstm = null;
ResultSet set = null;
try {
pstm = conn.prepareStatement(sql);
pstm.setString(1, userName);
set = pstm.executeQuery();
if (set.next())
throw new UserNameHasExistException();
} catch (Exception e) {
e.printStackTrace();
throw new UserNameHasExistException();
}finally{
DBUtils.closeConnnection(conn);
}
return true;
}
/**
* 注册用户信息
* @param user
* @return void
*/
public static void addUserDTO(UserDTO user) {
Connection conn = DBUtils.getConnection();
String sql = "insert into t_user values(?,?,?,?,?,?,?,?,?,?,?,?)";
PreparedStatement pstm = null;
try {
pstm = conn.prepareStatement(sql);
pstm.setString(1, user.getUserName());
pstm.setString(2, user.getRealName());
pstm.setInt(3, user.getBirthPlace().getBirthPlaceId());
pstm.setInt(4, user.getJob().getJobId());
pstm.setInt(5, user.getRole().getRoleId());
pstm.setString(6, user.getUserPassword());
pstm.setString(7, user.getUserEmail());
pstm.setTimestamp(8, user.getRegisterTime());
pstm.setTimestamp(9, user.getLastLogin());
pstm.setInt(10, user.getUserState());
pstm.setInt(11, user.getUserScore());
pstm.setInt(12, user.getIsChecked());
pstm.executeUpdate();
} catch (Exception e) {
e.printStackTrace();
}finally{
DBUtils.closeConnnection(conn);
}
}
/**
* 更新角色
* @param roleId
* @param userName
* @return void
*/
public static void updateRole(int roleId,String userName){
Connection conn=DBUtils.getConnection();
String sql="update t_user set role_id=? where user_name=?";
PreparedStatement pstm=null;
try {
pstm=conn.prepareStatement(sql);
pstm.setInt(1, roleId);
pstm.setString(2, userName);
pstm.executeUpdate();
} catch (Exception e) {
e.printStackTrace();
}finally{
DBUtils.closeConnnection(conn);
}
}
/**
* 更新最近登录时间
* @param id
* @return void
*/
public static void updateUserLoginDate(int id) {
Connection conn = DBUtils.getConnection();
String sql = "update t_user set last_login=? where user_id = ?";
PreparedStatement pstm = null;
try {
pstm = conn.prepareStatement(sql);
pstm.setTimestamp(1,new Timestamp(new Date().getTime()));
pstm.setInt(2, id);
pstm.executeUpdate();
} catch (Exception e) {
e.printStackTrace();
}finally{
DBUtils.closeConnnection(conn);
}
}
/**
* 删除用户
* @param id
* @return void
*/
public static void delUserDTO(int id){
Connection conn=DBUtils.getConnection();
String sql="delete from t_user where user_id=?";
PreparedStatement pstm = null;
try {
pstm=conn.prepareStatement(sql);
pstm.setInt(1,id);
pstm.executeUpdate();
} catch (Exception e) {
e.printStackTrace();
}finally{
DBUtils.closeConnnection(conn);
}
}
}
4. VO
package com.icss.mms.vo;
import java.sql.Timestamp;
/**
* 用户信息表
* @author WangHui
*
*/
public class UserDTO {
public int getUserID() {
return userID;
}
public void setUserID(int userID) {
this.userID = userID;
}
public String getUserName() {
return userName;
}
public void setUserName(String userName) {
this.userName = userName;
}
public String getRealName() {
return realName;
}
public void setRealName(String realName) {
this.realName = realName;
}
public BirthPlaceDTO getBirthPlace() {
return birthPlace;
}
public void setBirthPlace(BirthPlaceDTO birthPlace) {
this.birthPlace = birthPlace;
}
public JobDTO getJob() {
return job;
}
public void setJob(JobDTO job) {
this.job = job;
}
public RoleDTO getRole() {
return role;
}
public void setRole(RoleDTO role) {
this.role = role;
}
public String getUserPassword() {
return userPassword;
}
public void setUserPassword(String userPassword) {
this.userPassword = userPassword;
}
public String getUserEmail() {
return userEmail;
}
public void setUserEmail(String userEmail) {
this.userEmail = userEmail;
}
public Timestamp getRegisterTime() {
return registerTime;
}
public void setRegisterTime(Timestamp registerTime) {
this.registerTime = registerTime;
}
public Timestamp getLastLogin() {
return lastLogin;
}
public void setLastLogin(Timestamp lastLogin) {
this.lastLogin = lastLogin;
}
public int getUserState() {
return userState;
}
public void setUserState(int userState) {
this.userState = userState;
}
public int getUserScore() {
return userScore;
}
public void setUserScore(int userScore) {
this.userScore = userScore;
}
public int getIsChecked() {
return isChecked;
}
public void setIsChecked(int isChecked) {
this.isChecked = isChecked;
}
private int userID;
private String userName;
private String realName;
private BirthPlaceDTO birthPlace;
private JobDTO job;
private RoleDTO role;
private String userPassword;
private String userEmail;
private Timestamp registerTime;
private Timestamp lastLogin;
private int userState;
private int userScore;
private int isChecked;
}
5. Servlet
package com.icss.mms.servlet;
/**
* io 包
*/
import java.io.IOException;
import java.io.PrintWriter;
/**
* servlet 包
*/
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
/**
* 自定义包
*/
import com.icss.mms.common.ErrorMsg;
import com.icss.mms.dao.UserDAO;
import com.icss.mms.exception.NullValidateCodeException;
import com.icss.mms.exception.ValidateCodeException;
import com.icss.mms.vo.UserDTO;
/**
* 登录
* @author WangHui
*
*/
public class LoginServlet extends HttpServlet {
private static final long serialVersionUID = -4696934057817858796L;
public void doGet(HttpServletRequest req, HttpServletResponse resp)
throws ServletException, IOException {
doPost(req, resp);
}
public void doPost(HttpServletRequest req, HttpServletResponse resp)
throws ServletException, IOException {
String username = req.getParameter("username");
String password = req.getParameter("password");
String vcode = req.getParameter("vcode");
HttpSession session = req.getSession();
String validateCode =(String) session.getAttribute("validateCode");
resp.setContentType("text/html;charset=GB18030");
PrintWriter out= resp.getWriter();
UserDTO userDTO = null;
try{
if (validateCode == null)
throw new NullValidateCodeException();
if (!validateCode.equals(vcode))
throw new ValidateCodeException();
userDTO = UserDAO.validate(username, password);
} catch(Exception e){
StringBuffer information = new StringBuffer();
information.append("dispatchServlet?path=login.jsp?username=");
information.append(username);
out.println(ErrorMsg.createErrorMsg(e, req, information));
out.close();
return;
}
UserDAO.updateUserLoginDate(userDTO.getUserID());
if(userDTO.getRole().getRoleName().equals("一级用户")||userDTO.getRole().getRoleName().equals("二级用户")||userDTO.getRole().getRoleName().equals("用户")){
session.setAttribute("userdto", userDTO);
req.getRequestDispatcher("userInfoServlet").forward(req, resp);
}
网络多媒体资源管理信息系统的开发(四)由毕业论文网（www.huoyuandh.com）会员上传。
