码迷，mamicode.com
首页 > 其他好文 > 详细

工作流学习之入门demo

时间：2018-06-24 00:49:15      阅读：171      评论：0      收藏：0      [点我收藏+]

标签：eve   reac   point   roc   校验   www   lse   ==   info   

  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>

 

 

工作流学习之入门demo

标签：eve   reac   point   roc   校验   www   lse   ==   info   

原文地址：https://www.cnblogs.com/java-le/p/9219191.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！