SSH框架网站

package com.bunfly.web.action; import java.io.IOException; import java.util.Iterator; import java.util.List; import javax.servlet.http.Cookie; import org.apache.struts2.ServletActionContext; import org.hibernate.criterion.DetachedCriteria; import org.hibernate.criterion.Restrictions; import com.bunfly.domain.User; import com.bunfly.service.UserService; import com.bunfly.utils.CookieUtils; import com.opensymphony.xwork2.ActionContext; import com.opensymphony.xwork2.ActionSupport; import com.opensymphony.xwork2.ModelDriven; import com.opensymphony.xwork2.util.ValueStack; /** * 用户的控制器 * * @author Sherry * */ public class UserAction extends ActionSupport implements ModelDriven<User> { // 模型驱动 private User user = new User(); public User getModel() { return user; } // 注入UserService private UserService userService; public void setUserService(UserService userService) { this.userService = userService; } /** * 用户登录 * * @return */ public String login() { User existUser = userService.login(user); // 判断，登录名或者密码错误 if (existUser == null) { ServletActionContext.getRequest().setAttribute("msg", "用户名或密码错误。"); return LOGIN; } else { // 自动登录 if ("true".equals(ServletActionContext.getRequest().getParameter("autologin"))) { Cookie c = new Cookie("autoLogin", user.getUser_name() + "-" + user.getUser_password()); c.setPath(ServletActionContext.getRequest().getContextPath() + "/"); c.setMaxAge(3600 * 3); ServletActionContext.getResponse().addCookie(c); } // 请记住我 if ("true".equals(ServletActionContext.getRequest().getParameter("savename"))) { Cookie c = new Cookie("saveName", user.getUser_name()); c.setPath(ServletActionContext.getRequest().getContextPath() + "/"); c.setMaxAge(3600 * 3); ServletActionContext.getResponse().addCookie(c); } } ServletActionContext.getRequest().getSession().setAttribute("existUser", existUser); // 登录成功 return "loginOK"; } /** * ajax检查用户名是否存在 * * @return * @throws IOException */ public String checkUsername() throws IOException { User existUser = userService.checkUsername(user); if (existUser == null) { ServletActionContext.getResponse().getWriter().println("1"); } else { ServletActionContext.getResponse().getWriter().println("0"); } return NONE; } /** * ajax检查手机号是否存在 * * @return * @throws IOException */ public String checkPhone() throws IOException { User existUser = userService.checkPhone(user); if (existUser == null) { ServletActionContext.getResponse().getWriter().println("1"); } else { ServletActionContext.getResponse().getWriter().println("0"); } return NONE; } /** * 用户注册 * * @return */ public String register() { // 接受两个验证码 String rCode = ServletActionContext.getRequest().getParameter("checkcode"); String sCode = (String) ServletActionContext.getRequest().getSession().getAttribute("sessionCode"); // 移除session中的验证码 ServletActionContext.getRequest().getSession().removeAttribute("sessionCode"); // 判断验证码是否相同 if (!rCode.equalsIgnoreCase(sCode)) { ServletActionContext.getRequest().setAttribute("msg", "验证码错误，请重新输入。"); return "register"; } userService.register(user); ServletActionContext.getRequest().getSession().setAttribute("existUser", user); return "registerOK"; } /** * 找回密码 * * @return */ public String findPassword() { // 接受两个验证码 String rCode = ServletActionContext.getRequest().getParameter("checkcode"); String sCode = (String) ServletActionContext.getRequest().getSession().getAttribute("sessionCode"); // 移除session中的验证码 ServletActionContext.getRequest().getSession().removeAttribute("sessionCode"); // 判断验证码是否相同 if (!rCode.equalsIgnoreCase(sCode)) { ServletActionContext.getRequest().setAttribute("msg", "验证码错误，请重新输入。"); return "findpassword"; } User existUser = userService.findPassword(user); if (existUser == null) { ServletActionContext.getRequest().setAttribute("msg", "用户名或手机号错误。"); return "findpassword"; } else { ServletActionContext.getRequest().setAttribute("msg", "你的密码为:" + existUser.getUser_password()); return "findpassword"; } } /** * 重置密码 * * @return */ public String updatePassword() { // 接受两个验证码 String rCode = ServletActionContext.getRequest().getParameter("checkcode"); String sCode = (String) ServletActionContext.getRequest().getSession().getAttribute("sessionCode"); // 移除session中的验证码 ServletActionContext.getRequest().getSession().removeAttribute("sessionCode"); // 判断验证码是否相同 if (!rCode.equalsIgnoreCase(sCode)) { ServletActionContext.getRequest().setAttribute("msg", "验证码错误，请重新输入。"); return "updatepassword"; } User existUser = userService.login(user); if (existUser == null) { ServletActionContext.getRequest().setAttribute("msg", "旧密码输入错误。"); return "updatepassword"; } else { String newpassword = ServletActionContext.getRequest().getParameter("newpassword"); existUser.setUser_password(newpassword); userService.register(existUser); ServletActionContext.getRequest().getSession().removeAttribute("existUser"); return "updatepasswordOK"; } } /** * 用户退出 * * @return */ public String exit() { // 销毁session ServletActionContext.getRequest().getSession().removeAttribute("existUser"); // 销毁自动登录cookie Cookie c = CookieUtils.getCookieByName("autoLogin", ServletActionContext.getRequest().getCookies()); if (c != null) { c.setPath(ServletActionContext.getRequest().getContextPath() + "/"); c.setMaxAge(0); ServletActionContext.getResponse().addCookie(c); } return LOGIN; } /** * 用户列表 * * @return */ public String findAll() { List<User> list = userService.findAll(); for (User user : list) { user.setUser_password(user.getUser_password().substring(0,user.getUser_password().length()-4)+"****"); } ValueStack vs = ActionContext.getContext().getValueStack(); vs.set("list", list); return "userList"; } /** * 通过用户名模糊查询 * * @return */ public String findByUsername() { String input = ServletActionContext.getRequest().getParameter("input"); // 离线查询 DetachedCriteria criteria = DetachedCriteria.forClass(User.class); // 添加查询的条件 if (input != null && !input.trim().isEmpty()) { // 模糊查询 criteria.add(Restrictions.like("user_name", "%" + input + "%")); } List<User> list = userService.findByUsername(criteria); ValueStack vs = ActionContext.getContext().getValueStack(); vs.set("list", list); return "userList"; } /** * * 删除选中的用户 * * @return */ public String deleteUser() { String[] ids = ServletActionContext.getRequest().getParameterValues("uid"); for (String user_id : ids) { user = userService.findById(Integer.valueOf(user_id), user); userService.deleteUser(user); } List<User> list = userService.findAll(); ValueStack vs = ActionContext.getContext().getValueStack(); vs.set("list", list); vs.set("msg", "删除成功！"); return "userList"; } }