工作流SpringBoot2-Activiti-6.zip

package activiti.helloworld; import org.activiti.engine.*; import org.activiti.engine.form.FormProperty; import org.activiti.engine.form.TaskFormData; import org.activiti.engine.impl.form.DateFormType; import org.activiti.engine.impl.form.StringFormType; import org.activiti.engine.repository.Deployment; import org.activiti.engine.repository.DeploymentBuilder; import org.activiti.engine.repository.ProcessDefinition; import org.activiti.engine.runtime.ProcessInstance; import org.activiti.engine.task.Task; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.*; public class DemoMain { private static final Logger LOGGER = LoggerFactory.getLogger(DemoMain.class); public static void main(String[] args) throws ParseException { LOGGER.info("启动程序"); //创建流程引擎 ProcessEngine processEngine = getProcessEngine(); //部署流程定义文件 ProcessDefinition processDefinition = deployment(processEngine); //启动运行时流程 ProcessInstance processInstance = getProcessInstance(processDefinition, processEngine); //处理流程任务 processTask(processEngine, processInstance); LOGGER.info("结束程序"); } //处理流程任务 private static void processTask(ProcessEngine processEngine, ProcessInstance processInstance) throws ParseException { Scanner scanner = new Scanner(System.in); //判断流程实例是否结束 while (processInstance != null && !processInstance.isEnded()) { TaskService taskService = processEngine.getTaskService(); //列出需要处理的task任务 List<Task> list = taskService.createTaskQuery().list(); LOGGER.info("待处理任务数量{}", list.size()); for (Task task : list) { LOGGER.info("待处理任务{}", task.getName()); //提取数据，参数变量 Map<String, Object> variables = getMap(processEngine, scanner, task); //提交 taskService.complete(task.getId(),variables); //获取当前流程实例最新状态 processInstance = processEngine.getRuntimeService() .createProcessInstanceQuery() .processInstanceId(processInstance.getId()) .singleResult(); } } scanner.close(); } //提取数据，参数变量 private static Map<String, Object> getMap(ProcessEngine processEngine, Scanner scanner, Task task) throws ParseException { //通过FormService获取表单 FormService formService = processEngine.getFormService(); //通过taskId获取taskFormData表单任务对象 TaskFormData taskFormData = formService.getTaskFormData(task.getId()); //获取属性集合 List<FormProperty> formProperties = taskFormData.getFormProperties(); Map<String,Object> variables = new HashMap<String, Object>(); for (FormProperty formProperty : formProperties) { //获取输入内容 String line = null; //判断输入类型 if (StringFormType.class.isInstance(formProperty.getType())) { LOGGER.info("请输入{}？", formProperty.getName()); line = scanner.nextLine(); variables.put(formProperty.getId(),line); } else if (DateFormType.class.isInstance(formProperty.getType())) { //如果是日期类型需要做格式化，提示输入格式 LOGGER.info("请输入{}？格式(yyyy-MM-dd)", formProperty.getName()); line = scanner.nextLine(); SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd"); Date date = dateFormat.parse(line); variables.put(formProperty.getId(),date); } else { //如果是其他类型提示 LOGGER.info("类型暂时不支持{}", formProperty.getType()); } LOGGER.info("您输入的内容是{}",line); } return variables; } //启动运行流程 private static ProcessInstance getProcessInstance(ProcessDefinition processDefinition, ProcessEngine processEngine) { RuntimeService runtimeService = processEngine.getRuntimeService(); //通过id启动 ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinition.getId()); LOGGER.info("启动流程{}", processInstance.getProcessDefinitionKey()); return processInstance; } //部署流程定义文件，获取service private static ProcessDefinition deployment(ProcessEngine processEngine) { RepositoryService repositoryService = processEngine.getRepositoryService(); DeploymentBuilder deploymentBuilder = repositoryService.createDeployment(); deploymentBuilder.addClasspathResource("second_approver.bpmn20.xml"); Deployment deployment = deploymentBuilder.deploy(); String id = deployment.getId(); //获取流程定义对像 ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery() .deploymentId(id) .singleResult(); String processDefinitionId = processDefinition.getId(); String processDefinitionName = processDefinition.getName(); LOGGER.info("流程定义名称为{},id为{}",processDefinitionName,processDefinitionId); return processDefinition; } //创建流程引擎 private static ProcessEngine getProcessEngine() { //用activiti默认的方式创建ProcessEngineConfiguration ProcessEngineConfiguration cfg = ProcessEngineConfiguration.createStandaloneInMemProcessEngineConfiguration(); ProcessEngine processEngine = cfg.buildProcessEngine(); String name = processEngine.getName(); String version = ProcessEngine.VERSION; LOGGER.info("流程引擎名称{}，版本{}", name, version); return processEngine; } }