java工作流执行流程, 代码示例

Java工作流的执行流程需要使用特定的工作流引擎，常见的工作流引擎有Activiti、JBPM、Flowable等。这里以Activiti为例，给出代码示例。

1. 流程定义

流程定义是指对业务流程进行抽象和描述，通常使用BPMN2.0标准进行描述。下面是一个简单的请假流程的BPMN2.0定义：

<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://www.omg.org/spec/BPMN/20100524/MODEL BPMN20.xsd"
             id="Definition"
             targetNamespace="http://www.activiti.org/processdef">
    <process id="leaveProcess" name="请假流程">
        <startEvent id="start" name="开始"/>
        <userTask id="applyLeave" name="填写请假单" activiti:assignee="${applyUser}"/>
        <userTask id="approveLeave" name="审批请假单" activiti:assignee="${approveUser}"/>
        <endEvent id="end" name="结束"/>
        <sequenceFlow id="flow1" sourceRef="start" targetRef="applyLeave"/>
        <sequenceFlow id="flow2" sourceRef="applyLeave" targetRef="approveLeave"/>
        <sequenceFlow id="flow3" sourceRef="approveLeave" targetRef="end"/>
    </process>
</definitions>

2. 流程部署

将流程定义部署到Activiti引擎中，可以使用如下代码：

ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
RepositoryService repositoryService = processEngine.getRepositoryService();

DeploymentBuilder deploymentBuilder = repositoryService.createDeployment();
deploymentBuilder.addClasspathResource("leaveProcess.bpmn20.xml");
deploymentBuilder.deploy();

3. 流程实例化

根据流程定义创建流程实例，可以使用如下代码：

RuntimeService runtimeService = processEngine.getRuntimeService();
Map<String, Object> variables = new HashMap<>();
variables.put("applyUser", "user1");
variables.put("approveUser", "user2");
ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("leaveProcess", variables);

4. 任务分配和处理

根据任务定义，将任务分配给相应的处理人员，处理人员完成任务后，将任务提交给工作流引擎。可以使用如下代码：

TaskService taskService = processEngine.getTaskService();
// 查询某个用户的待办任务
List<Task> tasks = taskService.createTaskQuery().taskAssignee("user1").list();
// 完成任务
for (Task task : tasks) {
    Map<String, Object> taskVariables = new HashMap<>();
    taskVariables.put("approved", true);
    taskService.complete(task.getId(), taskVariables);
}

5. 流程监控

通过Activiti引擎提供的监控功能，可以查看流程的执行情况。可以使用如下代码：

HistoryService historyService = processEngine.getHistoryService();
// 查询某个流程实例的历史记录
List<HistoricActivityInstance> activities = historyService.createHistoricActivityInstanceQuery()
        .processInstanceId(processInstance.getId()).list();
// 查询某个任务的历史记录
List<HistoricTaskInstance> historicTaskInstances = historyService.createHistoricTaskInstanceQuery()
        .processInstanceId(processInstance.getId()).list();

以上是Activiti引擎的基本使用方法，Java工作流的执行流程需要根据具体业务需求进行定制。