本文整理了Java中com.evolveum.midpoint.task.api.Task.getWorkflowContext()
方法的一些代码示例,展示了Task.getWorkflowContext()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Task.getWorkflowContext()
方法的具体详情如下:
包路径:com.evolveum.midpoint.task.api.Task
类名称:Task
方法名:getWorkflowContext
暂无
代码示例来源:origin: Evolveum/midpoint
public static WfContextType getWorkflowContextChecked(Task task) {
if (task == null) {
throw new IllegalStateException("No task");
} else if (task.getWorkflowContext() == null) {
throw new IllegalStateException("No workflow context in " + task);
} else {
return task.getWorkflowContext();
}
}
代码示例来源:origin: Evolveum/midpoint
@NotNull
public static WfContextType getWorkflowContext(Task wfTask) {
if (wfTask == null) {
throw new IllegalArgumentException("No task");
} else if (wfTask.getWorkflowContext() == null) {
throw new IllegalArgumentException("No workflow context in task " + wfTask);
} else {
return wfTask.getWorkflowContext();
}
}
代码示例来源:origin: Evolveum/midpoint
public String getProcessId(Task task) {
if (task.getWorkflowContext() != null) {
return task.getWorkflowContext().getProcessInstanceId();
} else {
return null;
}
}
代码示例来源:origin: Evolveum/midpoint
public String getOutcome() {
return task.getWorkflowContext() != null ? task.getWorkflowContext().getOutcome() : null;
}
代码示例来源:origin: Evolveum/midpoint
public String getProcessInstanceName() {
return task.getWorkflowContext() != null ? task.getWorkflowContext().getProcessInstanceName() : null;
}
代码示例来源:origin: Evolveum/midpoint
public boolean isProcessInstanceFinished(Task task) {
return task.getWorkflowContext() != null && task.getWorkflowContext().getEndTimestamp() != null;
}
代码示例来源:origin: Evolveum/midpoint
@NotNull
public ChangeProcessor getChangeProcessor(Task task) {
String processorClassName = task.getWorkflowContext() != null ? task.getWorkflowContext().getChangeProcessor() : null;
if (processorClassName == null) {
throw new IllegalStateException("No change processor defined in task " + task);
}
return wfConfiguration.findChangeProcessor(processorClassName);
}
代码示例来源:origin: Evolveum/midpoint
public String getRootTaskOid(Task task) {
ObjectReferenceType ref = task.getWorkflowContext() != null ? task.getWorkflowContext().getRootTaskRef() : null;
return ref != null ? ref.getOid() : null;
}
代码示例来源:origin: Evolveum/midpoint
public WorkflowProcessEvent(LightweightIdentifierGenerator lightweightIdentifierGenerator, ChangeType changeType, Task wfTask) {
super(lightweightIdentifierGenerator, changeType, wfTask.getWorkflowContext(), wfTask.getTaskType(), null);
}
代码示例来源:origin: Evolveum/midpoint
public String getCompleteStageInfo() {
return WfContextUtil.getCompleteStageInfo(task.getWorkflowContext());
}
代码示例来源:origin: Evolveum/midpoint
@SuppressWarnings("unchecked")
public PrismObject<UserType> getRequesterIfExists(OperationResult result) {
if (task.getWorkflowContext() == null || task.getWorkflowContext().getRequesterRef() == null) {
return null;
}
ObjectReferenceType requesterRef = task.getWorkflowContext().getRequesterRef();
return (PrismObject<UserType>) wfTaskController.getMiscDataUtil().resolveAndStoreObjectReference(requesterRef, result);
}
代码示例来源:origin: Evolveum/midpoint
public ExpressionVariables getDefaultVariables(@Nullable DelegateExecution execution, Task wfTask, OperationResult result)
throws SchemaException, ObjectNotFoundException {
ExpressionVariables variables = getDefaultVariables(wfTask.getWorkflowContext(), wfTask.getChannel(), result);
// Activiti process instance variables (use with care)
if (execution != null) {
execution.getVariables().forEach((key, value) -> variables.addVariableDefinition(new QName("_" + key), value));
}
return variables;
}
代码示例来源:origin: Evolveum/midpoint
private void onWorkItemAllocationModifyDelete(ObjectReferenceType currentActor, @NotNull WorkItemType workItem,
@Nullable WorkItemOperationInfo operationInfo, @Nullable WorkItemOperationSourceInfo sourceInfo,
Duration timeBefore, Task task, OperationResult result) {
WorkItemAllocationEvent event = new WorkItemAllocationEvent(identifierGenerator,
timeBefore != null ? ChangeType.MODIFY : ChangeType.DELETE, workItem,
SimpleObjectRefImpl.create(functions, currentActor),
getInitiator(sourceInfo), operationInfo, sourceInfo,
task.getWorkflowContext(), task.getTaskType(), timeBefore);
initializeWorkflowEvent(event, task);
processEvent(event, result);
}
//endregion
代码示例来源:origin: Evolveum/midpoint
private void onWorkItemAllocationAdd(ObjectReferenceType newActor, @NotNull WorkItemType workItem,
@Nullable WorkItemOperationInfo operationInfo, @Nullable WorkItemOperationSourceInfo sourceInfo,
Task task, OperationResult result) {
WorkItemAllocationEvent event = new WorkItemAllocationEvent(identifierGenerator, ChangeType.ADD, workItem,
SimpleObjectRefImpl.create(functions, newActor),
getInitiator(sourceInfo), operationInfo, sourceInfo,
task.getWorkflowContext(), task.getTaskType(), null);
initializeWorkflowEvent(event, task);
processEvent(event, result);
}
代码示例来源:origin: Evolveum/midpoint
@Override
public void onWorkItemCreation(ObjectReferenceType assignee, @NotNull WorkItemType workItem,
Task wfTask, OperationResult result) {
WorkItemEvent event = new WorkItemLifecycleEvent(identifierGenerator, ChangeType.ADD, workItem,
SimpleObjectRefImpl.create(functions, assignee), null, null, null,
wfTask.getWorkflowContext(), wfTask.getTaskType());
initializeWorkflowEvent(event, wfTask);
processEvent(event, result);
}
代码示例来源:origin: Evolveum/midpoint
@Override
public void onWorkItemDeletion(ObjectReferenceType assignee, @NotNull WorkItemType workItem,
WorkItemOperationInfo operationInfo, WorkItemOperationSourceInfo sourceInfo,
Task wfTask, OperationResult result) {
WorkItemEvent event = new WorkItemLifecycleEvent(identifierGenerator, ChangeType.DELETE, workItem,
SimpleObjectRefImpl.create(functions, assignee),
getInitiator(sourceInfo), operationInfo, sourceInfo, wfTask.getWorkflowContext(), wfTask.getTaskType());
initializeWorkflowEvent(event, wfTask);
processEvent(event, result);
}
代码示例来源:origin: Evolveum/midpoint
@Override
public void onWorkItemCustomEvent(ObjectReferenceType assignee, @NotNull WorkItemType workItem,
@NotNull WorkItemNotificationActionType notificationAction, WorkItemEventCauseInformationType cause, Task wfTask,
OperationResult result) {
WorkItemEvent event = new WorkItemCustomEvent(identifierGenerator, ChangeType.ADD, workItem,
SimpleObjectRefImpl.create(functions, assignee),
new WorkItemOperationSourceInfo(null, cause, notificationAction),
wfTask.getWorkflowContext(), wfTask.getTaskType(), notificationAction.getHandler());
initializeWorkflowEvent(event, wfTask);
processEvent(event, result);
}
代码示例来源:origin: Evolveum/midpoint
@Override
public List<ObjectReferenceType> prepareApprovedBy(ProcessEvent event, PcpWfTask job, OperationResult result) {
WfContextType wfc = job.getTask().getWorkflowContext();
List<ObjectReferenceType> rv = new ArrayList<>();
if (!ApprovalUtils.isApprovedFromUri(event.getOutcome())) { // wfc.approved is not filled in yet
return rv;
}
for (WorkItemCompletionEventType completionEvent : WfContextUtil.getEvents(wfc, WorkItemCompletionEventType.class)) {
if (ApprovalUtils.isApproved(completionEvent.getOutput()) && completionEvent.getInitiatorRef() != null) {
rv.add(completionEvent.getInitiatorRef().clone());
}
}
return rv;
}
代码示例来源:origin: Evolveum/midpoint
private void initializeWorkflowEvent(WorkflowEvent event, Task wfTask) {
WfContextType wfc = wfTask.getWorkflowContext();
event.setRequester(SimpleObjectRefImpl.create(functions, wfc.getRequesterRef()));
event.setRequestee(SimpleObjectRefImpl.create(functions, wfc.getObjectRef()));
// TODO what if requestee is yet to be created?
}
代码示例来源:origin: Evolveum/midpoint
public void storeResultingDeltas(ObjectTreeDeltas deltas, Task task) throws SchemaException {
ObjectTreeDeltasType deltasType = ObjectTreeDeltas.toObjectTreeDeltasType(deltas);
if (task.getWorkflowContext().getProcessorSpecificState() == null) {
throw new IllegalStateException("No processor specific state in task " + task);
}
ItemDefinition<?> def = prismContext.getSchemaRegistry()
.findContainerDefinitionByCompileTimeClass(WfPrimaryChangeProcessorStateType.class)
.findPropertyDefinition(F_RESULTING_DELTAS);
ItemPath path = ItemPath.create(F_WORKFLOW_CONTEXT, F_PROCESSOR_SPECIFIC_STATE, F_RESULTING_DELTAS);
task.addModification(prismContext.deltaFor(TaskType.class)
.item(path, def).replace(deltasType)
.asItemDelta());
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Stored deltas into task {}:\n{}", task, deltas); // TODO debug dump
}
}
内容来源于网络,如有侵权,请联系作者删除!