1 /**
2 * Copyright (C), 2015-2018, XXX有限公司
3 * FileName: DemoMain
4 * Author: happy
5 * Date: 2018/6/23 16:33
6 * Description:
7 * History:
8 * <author> <time> <version> <desc>
9 * 作者姓名 修改时间 版本号 描述
10 */
11 package com.imooc.activiti.helloworld;
12
13 import com.google.common.collect.Maps;
14 import org.activiti.engine.*;
15 import org.activiti.engine.form.FormProperty;
16 import org.activiti.engine.form.TaskFormData;
17 import org.activiti.engine.impl.form.DateFormType;
18 import org.activiti.engine.impl.form.StringFormType;
19 import org.activiti.engine.repository.Deployment;
20 import org.activiti.engine.repository.DeploymentBuilder;
21 import org.activiti.engine.repository.ProcessDefinition;
22 import org.activiti.engine.runtime.ProcessInstance;
23 import org.activiti.engine.task.Task;
24 import org.slf4j.Logger;
25 import org.slf4j.LoggerFactory;
26
27 import java.text.ParseException;
28 import java.text.SimpleDateFormat;
29 import java.util.Date;
30 import java.util.List;
31 import java.util.Map;
32 import java.util.Scanner;
33
34 /**
35 * 〈一句话功能简述〉<br>
36 * 〈〉
37 *
38 * @author happy
39 * @create 2018/6/23
40 * @since 1.0.0
41 */
42 public class DemoMain {
43
44 public static final Logger log = LoggerFactory.getLogger(DemoMain.class);
45
46 public static void main(String[] args) {
47
48 log.info("启动我们的程序");
49
50 //创建流程引擎
51 ProcessEngine processEngine = getProcessEngine();
52
53 //部署流程定义文件
54 ProcessDefinition processDefinition = getProcessDefinition(processEngine);
55
56 //启动运行流程
57 final ProcessInstance[] processInstance = {getProcessInstance(processEngine, processDefinition)};
58
59 //处理流程任务
60 Scanner scanner = new Scanner(System.in);
61
62 while (processInstance[0] != null && !processInstance[0].isEnded()) {
63
64 TaskService taskService = processEngine.getTaskService();
65 List<Task> taskList = taskService.createTaskQuery().list();
66 log.info("待处理任务数量 [{}]", taskList.size());
67 taskList.stream().forEach(task -> {
68 log.info("待处理任务 [{}]", task.getName());
69 FormService formService = processEngine.getFormService();
70 TaskFormData taskFormData = formService.getTaskFormData(task.getId());
71 List<FormProperty> formProperties = taskFormData.getFormProperties();
72 Map<String, Object> variables = Maps.newHashMap();
73 formProperties.stream().forEach(property -> {
74 String line = null;
75 if (StringFormType.class.isInstance(property.getType())) {
76 log.info("请输入 {} ？", property.getName());
77 line = scanner.nextLine();
78 variables.put(property.getId(), line);
79 } else if (DateFormType.class.isInstance(property.getType())) {
80 log.info("请输入 {} ？ 格式 （yyyy-MM-dd）", property.getName());
81 line = scanner.nextLine();
82 SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
83 Date date = null;
84 try {
85 date = dateFormat.parse(line);
86 } catch (ParseException e) {
87 e.printStackTrace();
88 }
89 variables.put(property.getId(), date);
90 } else {
91 log.info("类型暂不支持 {}", property.getType());
92 }
93 log.info("您输入的内容是 [{}]", line);
94 });
95 taskService.complete(task.getId(), variables);
96 //Variable used in lambda expression should be final or effectively final
//(解决参考 https://www.jianshu.com/p/d957dd5560e8)
97 processInstance[0] = processEngine.getRuntimeService().createProcessInstanceQuery().
98 processInstanceId(processInstance[0].getId()).singleResult();
99 });
100
101 }
102
103 log.info("结束我们的程序");
104
105 }
106
107 private static ProcessInstance getProcessInstance(ProcessEngine processEngine, ProcessDefinition processDefinition) {
108 RuntimeService runtimeService = processEngine.getRuntimeService();
109 ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinition.getId());
110 log.info("启动流程 {}", processInstance.getProcessDefinitionKey());
111 return processInstance;
112 }
113
114 private static ProcessDefinition getProcessDefinition(ProcessEngine processEngine) {
115 RepositoryService repositoryService = processEngine.getRepositoryService();
116 DeploymentBuilder deploymentBuilder = repositoryService.createDeployment();
117 deploymentBuilder.addClasspathResource("second_approve.bpmn20.xml");
118 Deployment deployment = deploymentBuilder.deploy();
119 String deploymentId = deployment.getId();
120 ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery()
121 .deploymentId(deploymentId)
122 .singleResult();
123
124 log.info("流程定义文件 {},id {}", processDefinition.getName(), processDefinition.getId());
125 return processDefinition;
126 }
127
128 private static ProcessEngine getProcessEngine() {
129 ProcessEngineConfiguration cfg = ProcessEngineConfiguration.createStandaloneInMemProcessEngineConfiguration();
130 ProcessEngine processEngine = cfg.buildProcessEngine();
131 String name = processEngine.getName();
132 String version = ProcessEngine.VERSION;
133
134 log.info("流程引擎的名称 {},版本号 {}", name, version);
135 return processEngine;
136 }
137
138 }
<?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" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/test">
<process id="second_approve" name="二级审批流程" isExecutable="true">
<startEvent id="startEvent" name="开始"></startEvent>
<userTask id="submitForm" name="填写审批信息">
<extensionElements>
<activiti:formProperty id="message" name="申请信息" type="string" required="true"></activiti:formProperty>
<activiti:formProperty id="name" name="申请人姓名" type="string" required="true"></activiti:formProperty>
<activiti:formProperty id="submitTime" name="提交时间" type="date" datePattern="yyyy-MM-dd" required="true"></activiti:formProperty>
<activiti:formProperty id="submitType" name="确认申请" type="string" required="true"></activiti:formProperty>
</extensionElements>
</userTask>
<sequenceFlow id="flow1" sourceRef="startEvent" targetRef="submitForm"></sequenceFlow>
<exclusiveGateway id="decideSubmit" name="提交or取消"></exclusiveGateway>
<sequenceFlow id="flow2" sourceRef="submitForm" targetRef="decideSubmit"></sequenceFlow>
<endEvent id="endEventCancle" name="结束"></endEvent>
<sequenceFlow id="flow3" sourceRef="decideSubmit" targetRef="endEventCancle">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${submitType=="N" || submitType=="n"}]]></conditionExpression>
</sequenceFlow>
<userTask id="tlApprove" name="主管审批">
<extensionElements>
<activiti:formProperty id="tlApprove" name="主管审批结果" type="string" required="true"></activiti:formProperty>
<activiti:formProperty id="tlMessage" name="主管备注" type="string" required="true"></activiti:formProperty>
</extensionElements>
</userTask>
<sequenceFlow id="flow4" sourceRef="decideSubmit" targetRef="tlApprove">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${submitType=="Y" || submitType=="y"}]]></conditionExpression>
</sequenceFlow>
<exclusiveGateway id="decideTlApprove" name="主管审批校验"></exclusiveGateway>
<sequenceFlow id="flow5" sourceRef="tlApprove" targetRef="decideTlApprove"></sequenceFlow>
<userTask id="hr_approve" name="人事审批">
<extensionElements>
<activiti:formProperty id="hrApprove" name="人事审批结果" type="string" required="true"></activiti:formProperty>
<activiti:formProperty id="hrMessage" name="人事审批备注" type="string" required="true"></activiti:formProperty>
</extensionElements>
</userTask>
<sequenceFlow id="flow6" sourceRef="decideTlApprove" targetRef="hr_approve">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${tlApprove=="Y" || tlApprove=="y"}]]></conditionExpression>
</sequenceFlow>
<sequenceFlow id="flow10" sourceRef="decideTlApprove" targetRef="submitForm">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${tlApprove=="N" || tlApprove=="n"}]]></conditionExpression>
</sequenceFlow>
<exclusiveGateway id="decideHrApprove" name="人事审批校验"></exclusiveGateway>
<sequenceFlow id="flow11" sourceRef="hr_approve" targetRef="decideHrApprove"></sequenceFlow>
<endEvent id="endEvent" name="结束"></endEvent>
<sequenceFlow id="flow12" sourceRef="decideHrApprove" targetRef="endEvent">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${hrApprove=="Y" ||hrApprove=="y"}]]></conditionExpression>
</sequenceFlow>
<sequenceFlow id="flow13" sourceRef="decideHrApprove" targetRef="submitForm">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${hrApprove=="N" ||hrApprove=="n"}]]></conditionExpression>
</sequenceFlow>
</process>
<bpmndi:BPMNDiagram id="BPMNDiagram_second_approve">
<bpmndi:BPMNPlane bpmnElement="second_approve" id="BPMNPlane_second_approve">
<bpmndi:BPMNShape bpmnElement="startEvent" id="BPMNShape_startEvent">
<omgdc:Bounds height="35.0" width="35.0" x="50.0" y="130.0"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="submitForm" id="BPMNShape_submitForm">
<omgdc:Bounds height="55.0" width="105.0" x="130.0" y="120.0"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="decideSubmit" id="BPMNShape_decideSubmit">
<omgdc:Bounds height="40.0" width="40.0" x="280.0" y="128.0"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="endEventCancle" id="BPMNShape_endEventCancle">
<omgdc:Bounds height="35.0" width="35.0" x="400.0" y="230.0"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="tlApprove" id="BPMNShape_tlApprove">
<omgdc:Bounds height="55.0" width="105.0" x="365.0" y="121.0"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="decideTlApprove" id="BPMNShape_decideTlApprove">
<omgdc:Bounds height="40.0" width="40.0" x="515.0" y="129.0"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="hr_approve" id="BPMNShape_hr_approve">
<omgdc:Bounds height="55.0" width="105.0" x="601.0" y="123.0"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="decideHrApprove" id="BPMNShape_decideHrApprove">
<omgdc:Bounds height="40.0" width="40.0" x="751.0" y="131.0"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="endEvent" id="BPMNShape_endEvent">
<omgdc:Bounds height="35.0" width="35.0" x="836.0" y="134.0"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNEdge bpmnElement="flow1" id="BPMNEdge_flow1">
<omgdi:waypoint x="85.0" y="147.0"></omgdi:waypoint>
<omgdi:waypoint x="130.0" y="147.0"></omgdi:waypoint>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow2" id="BPMNEdge_flow2">
<omgdi:waypoint x="235.0" y="147.0"></omgdi:waypoint>
<omgdi:waypoint x="280.0" y="148.0"></omgdi:waypoint>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow3" id="BPMNEdge_flow3">
<omgdi:waypoint x="300.0" y="168.0"></omgdi:waypoint>
<omgdi:waypoint x="299.0" y="247.0"></omgdi:waypoint>
<omgdi:waypoint x="400.0" y="247.0"></omgdi:waypoint>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow4" id="BPMNEdge_flow4">
<omgdi:waypoint x="320.0" y="148.0"></omgdi:waypoint>
<omgdi:waypoint x="365.0" y="148.0"></omgdi:waypoint>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow5" id="BPMNEdge_flow5">
<omgdi:waypoint x="470.0" y="148.0"></omgdi:waypoint>
<omgdi:waypoint x="515.0" y="149.0"></omgdi:waypoint>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow6" id="BPMNEdge_flow6">
<omgdi:waypoint x="555.0" y="149.0"></omgdi:waypoint>
<omgdi:waypoint x="601.0" y="150.0"></omgdi:waypoint>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow10" id="BPMNEdge_flow10">
<omgdi:waypoint x="535.0" y="169.0"></omgdi:waypoint>
<omgdi:waypoint x="535.0" y="296.0"></omgdi:waypoint>
<omgdi:waypoint x="182.0" y="296.0"></omgdi:waypoint>
<omgdi:waypoint x="182.0" y="175.0"></omgdi:waypoint>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow11" id="BPMNEdge_flow11">
<omgdi:waypoint x="706.0" y="150.0"></omgdi:waypoint>
<omgdi:waypoint x="751.0" y="151.0"></omgdi:waypoint>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow12" id="BPMNEdge_flow12">
<omgdi:waypoint x="791.0" y="151.0"></omgdi:waypoint>
<omgdi:waypoint x="836.0" y="151.0"></omgdi:waypoint>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow13" id="BPMNEdge_flow13">
<omgdi:waypoint x="771.0" y="131.0"></omgdi:waypoint>
<omgdi:waypoint x="770.0" y="50.0"></omgdi:waypoint>
<omgdi:waypoint x="182.0" y="50.0"></omgdi:waypoint>
<omgdi:waypoint x="182.0" y="120.0"></omgdi:waypoint>
</bpmndi:BPMNEdge>
</bpmndi:BPMNPlane>
</bpmndi:BPMNDiagram>
</definitions>