usermanagerimpl.java

这是一个jbpm的高级应用,是一个oa工作流的系统,里面用到了spring,hibernate技术等.实为学习jbpm的好资料!

package com.bjsxt.oa.managers.impl;

import java.util.List;

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

public class UserManagerImpl extends AbstractManager implements UserManager {

	public void addOrUpdateUserRole(int userId, int roleId, int orderNo) {
		//先查询，看是否已有关联
		UsersRoles ur = findUsersRoles(userId,roleId);
		
		//如果已存在关联对象，则更新关联对象
		if(ur != null){
			ur.setOrderNo(orderNo);
			getHibernateTemplate().update(ur);
			return;
		}
		
		//如果不存在关联，则新建关联对象
		ur = new UsersRoles();
		ur.setUser((User)getHibernateTemplate().load(User.class, userId));
		ur.setRole((Role)getHibernateTemplate().load(Role.class, roleId));
		ur.setOrderNo(orderNo);
		getHibernateTemplate().save(ur);
	}

	public void addUser(User user, int personId) {
		if(personId != 0){
			user.setPerson((Person)getHibernateTemplate().load(Person.class, personId));
		}
		getHibernateTemplate().save(user);
	}

	//TODO 这里可以包含对密码的加密与解密过程
	public void changePassword(int userId, String newPassword,
			String oldPassword) {
		User user = (User)getHibernateTemplate().load(User.class, userId);
		if(!oldPassword.equals(user.getPassword())){
			throw new SystemException("旧密码输入不正确");
		}
		user.setPassword(newPassword);
		getHibernateTemplate().update(user);
	}

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

	public void delUserRole(int userId, int roleId) {
		UsersRoles ur = findUsersRoles(userId,roleId);
		if(ur != null){
			getHibernateTemplate().delete(ur);
		}
	}

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

	public List searchUserRoles(int userId) {
		return getHibernateTemplate()
			.find(
					"select ur from UsersRoles ur where ur.user.id = ? " +
					"order by ur.orderNo"
					,userId
				);
	}
	
	/**
	 * 查询用户与角色之间的关联对象
	 * @param userId
	 * @param roleId
	 * @return 如果不存在关联，则返回null
	 */
	private UsersRoles findUsersRoles(int userId,int roleId){
		return 
		(UsersRoles)getSession()
		.createQuery(
				"select ur from UsersRoles ur where ur.user.id = ? " +
				"and ur.role.id = ?"
		)
		.setParameter(0, userId)
		.setParameter(1, roleId)
		.uniqueResult(); 
	}

	public User login(String username, String password) {
		
		User user = (User)getSession()
			.createQuery("select u from com.bjsxt.oa.model.User u where u.username = ?")
			.setParameter(0, username)
			.uniqueResult();
		if(user == null){
			throw new SystemException("不存在这个用户");
		}
		
		if(!user.getPassword().equals(password)){
			throw new SystemException("用户密码错误");
		}
		
		return user;
	}

}