jbpm的扩展源代码

package com.eway.framework.basecomponent.services.jbpm.services.process.impl; import junit.framework.Assert; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.jbpm.JbpmConfiguration; import org.jbpm.JbpmContext; import org.jbpm.context.exe.ContextInstance; import org.jbpm.db.GraphSession; import org.jbpm.db.TaskMgmtSession; import org.jbpm.graph.def.ProcessDefinition; import org.jbpm.graph.exe.ProcessInstance; import org.jbpm.taskmgmt.exe.TaskInstance; import java.util.Map; import com.eway.framework.basecomponent.services.jbpm.services.process.JbpmProcessInstanceService; /** * Created by IntelliJ IDEA. * Author: xinpeng * Date: 2008-10-20 * Time: 21:22:29 * To change this template use File | Settings | File Templates. */ public class JbpmProcessInstanceServiceImpl implements JbpmProcessInstanceService { private static final Log log = LogFactory.getLog(JbpmProcessInstanceServiceImpl.class); /** * 开始流程 * * @param userId * @param processName */ public void startProcess(String userId, String processName) { JbpmContext jbpmContext = null; try { JbpmConfiguration jbpmConfiguration = JbpmConfiguration.getInstance(); jbpmContext = jbpmConfiguration.createJbpmContext(); GraphSession graphSession = jbpmContext.getGraphSession(); //加载流程定义 ProcessDefinition processDefinition = graphSession.findLatestProcessDefinition(processName); log.info("name = " + processDefinition.getName()); // 创建流程实例：启动流程 ProcessInstance processInstance = new ProcessInstance(processDefinition); log.info("processInstanceId = " + processInstance.getId()); processInstance.signal(); jbpmContext.save(processInstance); } catch (Exception e) { e.printStackTrace(); } finally { if (jbpmContext != null) jbpmContext.close(); } } /** * 开始流程（流程名称，启动流程的参与者，流程变量MAP） * * @param userId * @param processName * @param processParameterMap */ public void startProcess(String userId, String processName, Map<String, Object> processParameterMap) { JbpmContext jbpmContext = null; try { JbpmConfiguration jbpmConfiguration = JbpmConfiguration.getInstance(); jbpmContext = jbpmConfiguration.createJbpmContext(); GraphSession graphSession = jbpmContext.getGraphSession(); //加载流程定义 ProcessDefinition processDefinition = graphSession.findLatestProcessDefinition(processName); ProcessInstance processInstance = new ProcessInstance(processDefinition); //设置流程变量 Assert.assertNotNull(processParameterMap); ContextInstance contextInstance = processInstance.getContextInstance(); for (String key : processParameterMap.keySet()) { Object value = processParameterMap.get(key); log.info("key:"+key+",value:"+value); contextInstance.setVariable(key, value); } log.info("expense_money======"+contextInstance.getVariable("expense_money")); processInstance.signal(); jbpmContext.save(processInstance); } catch (Exception e) { e.printStackTrace(); } finally { if (jbpmContext != null) jbpmContext.close(); } } /** * 已阅 * * @param taskInstanceId */ public void signInTaskInstance(long taskInstanceId) { JbpmContext jbpmContext = null; try { jbpmContext = JbpmConfiguration.getInstance().createJbpmContext(); TaskMgmtSession taskMgmtSession = jbpmContext.getTaskMgmtSession(); TaskInstance taskInstance = taskMgmtSession.loadTaskInstance(taskInstanceId); taskInstance.start(); jbpmContext.save(taskInstance); } catch (Exception e) { e.printStackTrace(); } finally { if (jbpmContext != null) jbpmContext.close(); } } /** * 完成任务实例 * * @param taskInstanceId */ public void completeTaskInstance(long taskInstanceId) { JbpmContext jbpmContext = null; try { jbpmContext = JbpmConfiguration.getInstance().createJbpmContext(); TaskMgmtSession taskMgmtSession = jbpmContext.getTaskMgmtSession(); TaskInstance taskInstance = taskMgmtSession.loadTaskInstance(taskInstanceId); taskInstance.end(); jbpmContext.save(taskInstance); } catch (Exception e) { e.printStackTrace(); } finally { if (jbpmContext != null) jbpmContext.close(); } } /** * 设置变量 * * @param processInstanceId * @param name * @param value */ public void setVariable(long processInstanceId, String name, Object value) { JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext(); ProcessInstance processInstance = jbpmContext.getProcessInstance(processInstanceId); ContextInstance contextInstance = processInstance.getContextInstance(); contextInstance.setVariable(name, value);//设置到了rootToken jbpmContext.save(processInstance); jbpmContext.close(); } /** * @param processInstanceId * @param variableMap */ public void setVariable(long processInstanceId, Map<String, Object> variableMap) { Assert.assertNotNull(variableMap); for (String varName : variableMap.keySet()) { Object varValue = variableMap.get(varName); setVariable(processInstanceId, varName, varValue); } } /** * 根据tokenid获取流程实例对象 * * @param rootTokenId * @return */ public ProcessInstance getProcessInstance(long rootTokenId) { JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext(); return jbpmContext.getToken(rootTokenId).getProcessInstance(); } /** * 回退 * * @param completedTaskInstanceId */ public void callbackTaskInstance(long completedTaskInstanceId) { } }