usermanagerimpl.java

这个主要是办公自动化系统的源代码

package com.ygp.oa.managers.impl;

import java.util.Calendar;
import java.util.Date;
import java.util.List;

import com.ygp.oa.managers.SystemException;
import com.ygp.oa.managers.UserManager;
import com.ygp.oa.model.Person;
import com.ygp.oa.model.Role;
import com.ygp.oa.model.User;
import com.ygp.oa.model.UsersRoles;

public class UserManagerImpl extends AbstractManager implements UserManager {

	public void addOrUpdateUserRole(int userId, int roleId, int orderNo) {
		//根据userId和roleId查找UserRoles对象
		UsersRoles ur=(UsersRoles)findUsersRoles(userId ,roleId);
//		通过私有方法，将方法统一调用
//		UsersRoles ur=(UsersRoles)getSession().createQuery(
//				"select ur from UsersRoles ur where ur.role.id=? and ur.user.id=?")
//				.setParameter(0, userId)
//				.setParameter(1, roleId)
//				.uniqueResult();
		if (ur==null){
			ur=new UsersRoles();
			ur.setOrderNo(orderNo);
			ur.setRole((Role)getHibernateTemplate().load(Role.class, roleId));
			ur.setUser((User)getHibernateTemplate().load(User.class, userId));
			getHibernateTemplate().save(ur);
			return;
		}
		//
		ur.setOrderNo(orderNo);
		getHibernateTemplate().update(ur);

	}

	public void addUser(User user, int personId) {
		if(personId==0){
			throw new SystemException("必须选择相应的人员");
		}
		user.setPerson((Person)getHibernateTemplate().load(Person.class, personId));
		//设置创建时间
		user.setCreateTime(new Date());
		getHibernateTemplate().save(user);
	}

	public void delUser(int userId) {
		getHibernateTemplate().delete(getHibernateTemplate().load(User.class, userId));

	}

	public void delUserRole(int userId, int roleId) {
		getHibernateTemplate().delete(findUsersRoles(userId ,roleId));
//		将方法统一调用	
//		UsersRoles ur=(UsersRoles)getSession().createQuery(
//				"select ur from UsersRoles ur where ur.role.id=? and ur.user.id=?")
//				.setParameter(0, userId)
//				.setParameter(1, roleId)
//				.uniqueResult();

	}

	public User findUser(int userId) {
		
		return (User)getHibernateTemplate().load(User.class, userId);
	}

	public User login(String username, String password) {
		User user=(User)getSession().createQuery("select u from User u where u.username=?")
				.setParameter(0, username)
				.uniqueResult();
		
		if(user==null){
			throw new SystemException("用户不存在");
		}
		
		if (!user.getPassword().equals(password)){
			throw new SystemException("密码错误");
		}
		
		if(user.getCreateTime()!=null){
			//现在时间
			Calendar now=Calendar.getInstance();
			
			//失效时间
			Calendar expireTime=Calendar.getInstance();
			expireTime.setTime(user.getExpireTime());
			
			//已失效
			if(now.after(expireTime)){
				throw new SystemException("用户已失效");
			}
		}
		
		return user;
	}

	public List searchUserRoles(int userId) {
		return getHibernateTemplate().find("select ur from UsersRoles ur where ur.user.id=",userId);
	}

	public void updateUser(User user, int personId) {
		if(personId==0){
			throw new SystemException("必须选择相应的人员");
		}
		user.setPerson((Person)getHibernateTemplate().load(Person.class, personId));
		getHibernateTemplate().update(user);
	}
	
	private UsersRoles findUsersRoles(int userId ,int roleId){
		return (UsersRoles)getSession().createQuery(
		"select ur from UsersRoles ur where ur.role.id=? and ur.user.id=?")
		.setParameter(0, userId)
		.setParameter(1, roleId)
		.uniqueResult();
	}

}