validaterepositoryprocessbean.java

来自「OBPM是一个开源」· Java 代码 · 共 79 行

package cn.myapps.core.validate.repository.ejb;

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

import org.apache.commons.beanutils.PropertyUtils;
import org.hibernate.StaleObjectStateException;

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.deploy.module.ejb.ModuleProcess;
import cn.myapps.core.deploy.module.ejb.ModuleVO;
import cn.myapps.core.validate.repository.dao.ValidateRepositoryDAO;
import cn.myapps.util.ProcessFactory;

public class ValidateRepositoryProcessBean extends BaseProcessBean implements ValidateRepositoryProcess{

	protected IBaseDAO getDAO() throws Exception {
		IBaseDAO dao = DAOFactory.getDefaultDAO(ValidateRepositoryVO.class.getName());
		return dao;
	}
	
	public void doUpdate(ValueObject vo) throws Exception {
		try {
			PersistenceUtils.beginTransaction();
			ValueObject po = getDAO().find(vo.getId());
			if(((ValidateRepositoryVO)vo).getVersion()!=((ValidateRepositoryVO)po).getVersion())
				throw new StaleObjectStateException(null,null);
			((ValidateRepositoryVO)vo).setVersion(((ValidateRepositoryVO)vo).getVersion()+1);
			if (po != null) {
				PropertyUtils.copyProperties(po, vo);
				getDAO().update(po);
			} else {
				getDAO().update(vo);
			}

			PersistenceUtils.commitTransaction();
		}catch(StaleObjectStateException e)
		{
			PersistenceUtils.rollbackTransaction();
			throw e;
		}
		catch (Exception e) {
			e.printStackTrace();
			PersistenceUtils.rollbackTransaction();
		}
	}
	
//	取得该模块及其下属模块,还有所属应用,还有不属于任何应用及模块的所有validate
	 public Collection  get_validate(String moduleid) throws Exception{
		 
		 
		 ModuleProcess mp = (ModuleProcess) ProcessFactory
			.createProcess(ModuleProcess.class);
		 
		 Collection rs=new HashSet();
		Collection coll=new HashSet();
		
		ModuleVO mv=(ModuleVO)mp.doView(moduleid);
		if(mv!=null){
		rs.addAll(((ValidateRepositoryDAO)getDAO()).getValidateRepositoryByApplication(mv.getApplication().getId(), mv.getApplicationid()));
		coll.add(mv.getId());
		while(mv.getSuperior()!=null){
			mv=mv.getSuperior();
			coll.add(mv.getId());
		}
		 for (Iterator iter = coll.iterator(); iter.hasNext();) {
			String id = (String) iter.next();
			rs.addAll(((ValidateRepositoryDAO)getDAO()).getValidateRepositoryByModule(id, mv.getApplicationid()));
		}
	 }
		return rs;
}
}