本文整理了Java中org.activiti.bpmn.model.Process.getFlowElements()
方法的一些代码示例,展示了Process.getFlowElements()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Process.getFlowElements()
方法的具体详情如下:
包路径:org.activiti.bpmn.model.Process
类名称:Process
方法名:getFlowElements
暂无
代码示例来源:origin: Activiti/Activiti
/**
* Since subprocesses are autolayouted independently (see {@link #handleSubProcess(FlowElement)}), the elements have x and y coordinates relative to the bounds of the subprocess (thinking the
* subprocess is on (0,0). This however, does not work for nested subprocesses, as they need to take in account the x and y coordinates for each of the parent subproceses.
*
* This method is to be called after fully layouting one process, since ALL elements need to have x and y.
*/
protected void translateNestedSubprocesses(Process process) {
for (FlowElement flowElement : process.getFlowElements()) {
if (flowElement instanceof SubProcess) {
translateNestedSubprocessElements((SubProcess) flowElement);
}
}
}
代码示例来源:origin: Activiti/Activiti
@Override
protected void executeValidation(BpmnModel bpmnModel, Process process, List<ValidationError> errors) {
for (FlowElement flowElement : process.getFlowElements()) {
if (flowElement instanceof Activity) {
Activity activity = (Activity) flowElement;
handleConstraints(process, activity, errors);
handleMultiInstanceLoopCharacteristics(process, activity, errors);
handleDataAssociations(process, activity, errors);
}
}
}
代码示例来源:origin: Activiti/Activiti
protected void addMessageEventSubscriptions(ProcessDefinitionEntity processDefinition,
Process process,
BpmnModel bpmnModel) {
if (CollectionUtil.isNotEmpty(process.getFlowElements())) {
for (FlowElement element : process.getFlowElements()) {
if (element instanceof StartEvent) {
StartEvent startEvent = (StartEvent) element;
if (CollectionUtil.isNotEmpty(startEvent.getEventDefinitions())) {
EventDefinition eventDefinition = startEvent.getEventDefinitions().get(0);
if (eventDefinition instanceof MessageEventDefinition) {
MessageEventDefinition messageEventDefinition = (MessageEventDefinition) eventDefinition;
insertMessageEvent(messageEventDefinition,
startEvent,
processDefinition,
bpmnModel);
}
}
}
}
}
}
代码示例来源:origin: Activiti/Activiti
@Override
protected void executeValidation(BpmnModel bpmnModel, Process process, List<ValidationError> errors) {
validateListeners(process, process, process.getExecutionListeners(), errors);
for (FlowElement flowElement : process.getFlowElements()) {
validateListeners(process, flowElement, flowElement.getExecutionListeners(), errors);
}
}
代码示例来源:origin: Activiti/Activiti
Collection<FlowElement> flowElements = model.getMainProcess().getFlowElements();
Map<String, GraphicInfo> locations = new HashMap<String, GraphicInfo>();
Map<String, List<GraphicInfo>> flowLocations = new HashMap<String, List<GraphicInfo>>();
代码示例来源:origin: Activiti/Activiti
if (process.getFlowElements().isEmpty() && process.getLanes().isEmpty()) {
for (FlowElement flowElement : process.getFlowElements()) {
createXML(flowElement, model, xtw);
代码示例来源:origin: Activiti/Activiti
newMainProcess.getFlowElements().addAll(subFlowElements);
newMainProcess.getArtifacts().addAll(((SubProcess)subElement).getArtifacts());
subModel.addProcess(newMainProcess);
代码示例来源:origin: Activiti/Activiti
processFlowElements(process.getFlowElements(), process);
代码示例来源:origin: Activiti/Activiti
if (process.getFlowElements().isEmpty() && process.getLanes().isEmpty()) {
for (FlowElement flowElement : process.getFlowElements()) {
createXML(flowElement, model, xtw);
代码示例来源:origin: Activiti/Activiti
public void parse(XMLStreamReader xtr, BpmnModel model) throws Exception {
String resourceId = xtr.getAttributeValue(null, ATTRIBUTE_ID);
String resourceName = xtr.getAttributeValue(null, ATTRIBUTE_NAME);
Resource resource;
if (model.containsResourceId(resourceId)) {
resource = model.getResource(resourceId);
resource.setName(resourceName);
for (org.activiti.bpmn.model.Process process : model.getProcesses()) {
for (FlowElement fe : process.getFlowElements()) {
if (fe instanceof UserTask
&& ((UserTask) fe).getCandidateGroups().contains(resourceId)) {
((UserTask) fe).getCandidateGroups().remove(resourceId);
((UserTask) fe).getCandidateGroups().add(resourceName);
}
}
}
} else {
resource = new Resource(resourceId, resourceName);
model.addResource(resource);
}
BpmnXMLUtil.addXMLLocation(resource, xtr);
}
}
代码示例来源:origin: Activiti/Activiti
protected List<TimerJobEntity> getTimerDeclarations(ProcessDefinitionEntity processDefinition, Process process) {
JobManager jobManager = Context.getCommandContext().getJobManager();
List<TimerJobEntity> timers = new ArrayList<TimerJobEntity>();
if (CollectionUtil.isNotEmpty(process.getFlowElements())) {
for (FlowElement element : process.getFlowElements()) {
if (element instanceof StartEvent) {
StartEvent startEvent = (StartEvent) element;
代码示例来源:origin: Activiti/Activiti
process);
process.setDataObjects(dataObjects);
process.getFlowElements().addAll(dataObjects);
process.getFlowElements(),
edgeMap,
bpmnModel,
代码示例来源:origin: Activiti/Activiti
public ProcessInstance createAndStartProcessInstanceByMessage(ProcessDefinition processDefinition, String messageName,
Map<String, Object> variables, Map<String, Object> transientVariables) {
CommandContext commandContext = Context.getCommandContext();
// Do not start process a process instance if the process definition is suspended
if (ProcessDefinitionUtil.isProcessDefinitionSuspended(processDefinition.getId())) {
throw new ActivitiException("Cannot start process instance. Process definition " + processDefinition.getName() + " (id = " + processDefinition.getId() + ") is suspended");
}
// Get model from cache
Process process = ProcessDefinitionUtil.getProcess(processDefinition.getId());
if (process == null) {
throw new ActivitiException("Cannot start process instance. Process model " + processDefinition.getName() + " (id = " + processDefinition.getId() + ") could not be found");
}
FlowElement initialFlowElement = null;
for (FlowElement flowElement : process.getFlowElements()) {
if (flowElement instanceof StartEvent) {
StartEvent startEvent = (StartEvent) flowElement;
if (CollectionUtil.isNotEmpty(startEvent.getEventDefinitions()) && startEvent.getEventDefinitions().get(0) instanceof MessageEventDefinition) {
MessageEventDefinition messageEventDefinition = (MessageEventDefinition) startEvent.getEventDefinitions().get(0);
if (messageEventDefinition.getMessageRef().equals(messageName)) {
initialFlowElement = flowElement;
break;
}
}
}
}
if (initialFlowElement == null) {
throw new ActivitiException("No message start event found for process definition " + processDefinition.getId() + " and message name " + messageName);
}
return createAndStartProcessInstanceWithInitialFlowElement(processDefinition, null, null, initialFlowElement, process, variables, transientVariables, true);
}
代码示例来源:origin: Activiti/Activiti
for (FlowElement flowElement : process.getFlowElements()) {
代码示例来源:origin: Activiti/Activiti
boolean isFlowElementLocalizationChanged = localizeFlowElements(process.getFlowElements(),
infoNode);
boolean isDataObjectLocalizationChanged = localizeDataObjectElements(process.getDataObjects(),
代码示例来源:origin: Activiti/Activiti
if (CollectionUtil.isNotEmpty(previousProcess.getFlowElements())) {
代码示例来源:origin: Activiti/Activiti
Process process,
BpmnModel bpmnModel) {
if (CollectionUtil.isNotEmpty(process.getFlowElements())) {
for (FlowElement element : process.getFlowElements()) {
if (element instanceof StartEvent) {
StartEvent startEvent = (StartEvent) element;
代码示例来源:origin: Activiti/Activiti
protected ProcessDefinitionEntity transformProcess(BpmnParse bpmnParse, Process process) {
ProcessDefinitionEntity currentProcessDefinition = Context.getCommandContext().getProcessDefinitionEntityManager().create();
bpmnParse.setCurrentProcessDefinition(currentProcessDefinition);
/*
* Mapping object model - bpmn xml: processDefinition.id -> generated by activiti engine processDefinition.key -> bpmn id (required) processDefinition.name -> bpmn name (optional)
*/
currentProcessDefinition.setKey(process.getId());
currentProcessDefinition.setName(process.getName());
currentProcessDefinition.setCategory(bpmnParse.getBpmnModel().getTargetNamespace());
currentProcessDefinition.setDescription(process.getDocumentation());
currentProcessDefinition.setDeploymentId(bpmnParse.getDeployment().getId());
if (bpmnParse.getDeployment().getEngineVersion() != null) {
currentProcessDefinition.setEngineVersion(bpmnParse.getDeployment().getEngineVersion());
}
createEventListeners(bpmnParse, process.getEventListeners());
if (LOGGER.isDebugEnabled()) {
LOGGER.debug("Parsing process {}", currentProcessDefinition.getKey());
}
bpmnParse.processFlowElements(process.getFlowElements());
processArtifacts(bpmnParse, process.getArtifacts());
return currentProcessDefinition;
}
代码示例来源:origin: Activiti/Activiti
for (FlowElement flowElement : process.getFlowElements()) {
if (flowElement instanceof EventSubProcess) {
EventSubProcess eventSubProcess = (EventSubProcess) flowElement;
代码示例来源:origin: org.activiti/activiti-process-validation
@Override
protected void executeValidation(BpmnModel bpmnModel, Process process, List<ValidationError> errors) {
validateListeners(process, process, process.getExecutionListeners(), errors);
for (FlowElement flowElement : process.getFlowElements()) {
validateListeners(process, flowElement, flowElement.getExecutionListeners(), errors);
}
}
内容来源于网络,如有侵权,请联系作者删除!