roleprocessbean.java

OBPM是一个开源

package cn.myapps.core.role.ejb;

import java.util.Collection;
import java.util.Iterator;

import org.apache.commons.beanutils.PropertyUtils;

import cn.myapps.base.dao.DAOFactory;
import cn.myapps.base.dao.IBaseDAO;
import cn.myapps.base.dao.PersistenceUtils;
import cn.myapps.base.dao.ValueObject;
import cn.myapps.base.ejb.BaseProcessBean;
import cn.myapps.core.department.ejb.DepartmentVO;
import cn.myapps.core.helper.dao.HelperDAO;
import cn.myapps.core.permission.ejb.PermissionPackage;
import cn.myapps.core.permission.ejb.PermissionProcess;
import cn.myapps.core.permission.ejb.PermissionVO;
import cn.myapps.core.role.dao.RoleDAO;
import cn.myapps.util.ProcessFactory;

public class RoleProcessBean extends BaseProcessBean implements RoleProcess {
	private static final long serialVersionUID = -6347281773885869778L;

	public void doCreate(ValueObject vo) throws Exception {
		super.doCreate(vo);
		PermissionPackage.clearCache();
	}
	
	public void doRemove(String pk) throws Exception {
		// 检查是否有下属用户
		RoleVO role = (RoleVO) getDAO().find(pk);
		if (role.getUsers() != null && !role.getUsers().isEmpty()) {
			throw new Exception("该用户组有下属用户, 不能删除");
		}

		try {
			PersistenceUtils.beginTransaction();
			getDAO().remove(pk);
			PersistenceUtils.commitTransaction();
		} catch (Exception e) {
			PersistenceUtils.rollbackTransaction();
		}

		PermissionPackage.clearCache();
	}

	public void doUpdate(ValueObject vo) throws Exception {
		try {
			PersistenceUtils.beginTransaction();

			RoleVO po = (RoleVO)getDAO().find(vo.getId());
			PermissionProcess pp = (PermissionProcess)ProcessFactory
			.createProcess(PermissionProcess.class);
			if (po!=null) {
				PropertyUtils.copyProperties(po,vo);				
				getDAO().update(po);
			}
			else {
				getDAO().update(vo);
			}
			
			PersistenceUtils.commitTransaction();
		} catch (Exception e) {
			e.printStackTrace();
			PersistenceUtils.rollbackTransaction();
		}
		PermissionPackage.clearCache();
	}
	
	protected IBaseDAO getDAO() throws Exception {
		return DAOFactory.getDefaultDAO(RoleVO.class.getName());
	}

	public Collection getRoleByName(String byName, String application) throws Exception {
	     return (((RoleDAO)getDAO())).getRoleByName(byName, application);
	}
}