com.evolveum.midpoint.task.api.Task.getWorkflowContext()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(8.1k)|赞(0)|评价(0)|浏览(71)

本文整理了Java中com.evolveum.midpoint.task.api.Task.getWorkflowContext()方法的一些代码示例,展示了Task.getWorkflowContext()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Task.getWorkflowContext()方法的具体详情如下:
包路径:com.evolveum.midpoint.task.api.Task
类名称:Task
方法名:getWorkflowContext

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
  }
}

相关文章

微信公众号

最新文章

更多