nodertprocessbean.java

OBPM是一个开源

package cn.myapps.core.workflow.storage.runtime.ejb;

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

import cn.myapps.base.dao.DAOFactory;
import cn.myapps.base.dao.IBaseDAO;
import cn.myapps.base.ejb.BaseProcessBean;
import cn.myapps.core.user.action.WebUser;
import cn.myapps.core.workflow.element.ManualNode;
import cn.myapps.core.workflow.element.Node;
import cn.myapps.core.workflow.storage.definition.ejb.BillDefiVO;
import cn.myapps.core.workflow.storage.runtime.dao.NodeRTDAO;
import cn.myapps.core.workflow.utility.NameList;
import cn.myapps.core.workflow.utility.NameNode;

public class NodeRTProcessBean extends BaseProcessBean implements
		NodeRTProcess {

	protected IBaseDAO getDAO() throws Exception {
		return DAOFactory.getDefaultDAO(NodeRT.class.getName());
	}

	public NodeRT doCreate(String docid, BillDefiVO flowVO ,Node node) throws Exception {
		if (node != null) {
			NodeRT nodert = new NodeRT(docid, flowVO.getId(), node);
			if (node instanceof ManualNode ) {
				// 创建当前节点所有角色
				ManualNode manualNode = (ManualNode)node;
				NameList nameList = NameList.parser(manualNode.namelist);
				Collection nameNodeList = nameList.toNameNodeCollection();
				for (Iterator iter = nameNodeList.iterator(); iter.hasNext();) {
					NameNode nameNode = (NameNode) iter.next();
					ActorRT actrt = new ActorRT(nameNode);
					nodert.getActorrts().add(actrt);
				}
			}
			super.doCreate(nodert);
			return nodert;
		}
		return null;
	}

	public NodeRT doCreate(String docid, BillDefiVO flowVO, Node node, WebUser webuser) throws Exception {
		NodeRT nodert = new NodeRT(docid, flowVO.getId(), node);
		
		ActorRT actrt = new ActorRT(webuser);
		nodert.getActorrts().add(actrt);
		
		super.doCreate(nodert);
		
		return nodert;
	}
	
	public Collection queryNodeRTByDocidAndFlowid(String docid, String flowid) throws Exception {
		return ((NodeRTDAO)getDAO()).queryNodeRTByDocidAndFlowid(docid,flowid);
	}

	public NodeRT doView(String docid, String flowid, WebUser user) throws Exception {
		return ((NodeRTDAO)getDAO()).findNodeRT(docid, flowid, user);
	}

	public Collection doQuery(String docid, String flowid) throws Exception {
		return ((NodeRTDAO)getDAO()).query(docid, flowid);
	}
	
}