Flowable深入浅出-12 Flowable-BPMN操作流程之用户任务UserTask

package com.hyj.service.impl; import com.hyj.service.IFlowService; import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.lang3.StringUtils; import org.flowable.bpmn.converter.BpmnXMLConverter; import org.flowable.bpmn.model.BpmnModel; import org.flowable.bpmn.model.Process; import org.flowable.engine.RepositoryService; import org.flowable.engine.RuntimeService; import org.flowable.engine.repository.Deployment; import org.flowable.engine.repository.DeploymentBuilder; import org.flowable.engine.repository.ProcessDefinition; import org.flowable.engine.runtime.ProcessInstance; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Primary; import org.springframework.stereotype.Service; import javax.xml.stream.XMLInputFactory; import javax.xml.stream.XMLStreamException; import javax.xml.stream.XMLStreamReader; import java.io.File; import java.io.FileInputStream; import java.io.InputStream; import java.util.HashMap; import java.util.List; import java.util.Map; @Primary @Service public class FlowServiceImpl implements IFlowService { /** * 日志类 */ private static final Logger log = LoggerFactory.getLogger(FlowServiceImpl.class); /** * Flowable仓库时服务 */ @Autowired private RepositoryService repositoryService; /** * Flowable运行时服务 */ @Autowired private RuntimeService runtimeService; @Override public ProcessInstance strartFlow(String processKey, Map<String, Object> paras) { if (StringUtils.isEmpty(processKey)){ return null; } if (null == paras){ paras = new HashMap<>(); } List<Deployment> deployments = repositoryService.createDeploymentQuery().processDefinitionKey(processKey).list(); if (CollectionUtils.isEmpty(deployments) ){ log.error("没有该流程"); return null; } return runtimeService.startProcessInstanceByKey(processKey,paras); } @Override public Map<String,Object> createFlow(String filePath) { Map<String,Object> res = new HashMap<>(); //解析BPMN模型看是否成功 XMLStreamReader reader = null; InputStream inputStream = null; try { BpmnXMLConverter bpmnXMLConverter = new BpmnXMLConverter(); XMLInputFactory factory = XMLInputFactory.newInstance(); inputStream=new FileInputStream(new File(filePath)); reader = factory.createXMLStreamReader(inputStream); BpmnModel model = bpmnXMLConverter.convertToBpmnModel(reader); List<Process> processes = model.getProcesses(); Process curProcess = null; if (CollectionUtils.isEmpty(processes)) { log.error("BPMN模型没有配置流程"); return null; } res.put("processes",processes); curProcess = processes.get(0); inputStream=new FileInputStream(new File(filePath)); DeploymentBuilder deploymentBuilder = repositoryService.createDeployment().name("TEST_FLOW") .addInputStream(filePath,inputStream); Deployment deployment= deploymentBuilder.deploy(); res.put("deployment",deployment); log.warn("部署流程 name:"+curProcess.getName()+" key "+deployment.getKey() + " deploy "+deployment); return res; } catch (Exception e){ log.error("BPMN模型创建流程异常",e); return null; } finally { try { reader.close(); } catch (XMLStreamException e) { log.error("关闭异常",e); } } } }