网络多媒体资源管理信息系统的开发

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

首页上一页 1 2 3 4 5 下一页尾页 4/5/5

网络多媒体资源管理信息系统的开发(四)