Struts2+Spring+Hibernate+Ehcache+AJAX+JQuery+Oracle 框架集成用户登录注册De...

package com.han.service; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import javax.annotation.Resource; import org.springframework.stereotype.Component; import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.CollectionUtils; import com.googlecode.ehcache.annotations.Cacheable; import com.googlecode.ehcache.annotations.TriggersRemove; import com.han.common.CommonConstant; import com.han.common.PageBean; import com.han.dao.LoginLogDao; import com.han.dao.UserDao; import com.han.model.LoginLog; import com.han.model.User; @Component("userManager") public class UserManager{ @Resource private UserDao userDao; @Resource private LoginLogDao loginLogDao; /** * 将查询的所有用户放入cacheMAP */ @Transactional(propagation = Propagation.REQUIRED, readOnly = true) @Cacheable(cacheName="userCache") public int queryAllUsersMap() { List<User> list = userDao.getAllUser(); int count = 0; Map<Integer, User> userMap = null; if (!CollectionUtils.isEmpty(list)) { userMap = new HashMap<Integer, User>(); for (User user : list) { userMap.put(user.getUserId(), user); } count = userMap.size(); } return count; } /** * 分页查询所有用户 * @param page 当前页 * @return 封装了分页信息的bean */ @Transactional(propagation = Propagation.REQUIRED, readOnly = true) public PageBean queryAllUsers(int page) { PageBean pageBean = new PageBean(); pageBean = userDao.getAllUserByPage(page); return pageBean; } /** * 查询用户是否存在 */ @Transactional(propagation = Propagation.REQUIRED, readOnly = true) public User exists(String username) throws Exception { return userDao.getUserByName(username); } /** * 新增用户 */ @Transactional(propagation = Propagation.REQUIRED, readOnly = false) @TriggersRemove(cacheName="userCache",removeAll=true) public void add(User user) throws Exception { userDao.saveUser(user); // 记录登录日志 LoginLog loginLog = new LoginLog(); loginLog.setUserid(user.getUserId()); loginLog.setIp(user.getLastIp()); loginLog.setLoginDate(new Date()); loginLogDao.saveLoginLog(loginLog); } /** * 登陆成功 */ @Transactional(propagation = Propagation.REQUIRED, readOnly = false) public void loginSuccess(User user) { // 登录积分奖励 user.setCredit(CommonConstant.LOGIN_CREDIT + user.getCredit()); // 记录登录日志 LoginLog loginLog = new LoginLog(); loginLog.setUserid(user.getUserId()); loginLog.setIp(user.getLastIp()); loginLog.setLoginDate(new Date()); userDao.updateUser(user); loginLogDao.saveLoginLog(loginLog); } /** * 将用户锁定，锁定的用户不能够登录 */ @Transactional(propagation = Propagation.REQUIRED, readOnly = false) public void lockUser(String userName) { User user = userDao.getUserByName(userName); user.setLocked(CommonConstant.USER_LOCK); userDao.updateUser(user); } /** * 解除用户的锁定 */ @Transactional(propagation = Propagation.REQUIRED, readOnly = false) public void unlockUser(String userName) { User user = userDao.getUserByName(userName); user.setLocked(CommonConstant.USER_UNLOCK); userDao.updateUser(user); } }