org.kie.api.task.model.Task.getId()方法的使用及代码示例

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

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

Task.getId介绍

暂无

代码示例

代码示例来源：origin: kiegroup/jbpm

public List<TaskVariable> index(Task task, String variableName, Object variable) {
  for (TaskVariableIndexer indexer : indexers) {
    if (indexer.accept(variable)) {
      List<TaskVariable> indexed = indexer.index(variableName, variable);
      
      if (indexed != null) {
                        // populate all indexed variables with task information
        for (TaskVariable taskVariable : indexed) {
          taskVariable.setTaskId(task.getId());
          taskVariable.setTaskId(task.getId());
          taskVariable.setProcessInstanceId(task.getTaskData().getProcessInstanceId());
          taskVariable.setProcessId(task.getTaskData().getProcessId());
          taskVariable.setModificationDate(new Date());
        }
        
        return indexed;
      }
    }
  }
  
  return null;
}

代码示例来源：origin: kiegroup/jbpm

protected AuditTaskImpl createAuditTask(Task ti, Date date) {
  AuditTaskImpl auditTaskImpl = new AuditTaskImpl(
      ti.getId(),
      ti.getName(),
      ti.getTaskData().getStatus().name(),
      ti.getTaskData().getActivationTime(),
      (ti.getTaskData().getActualOwner() != null) ? ti.getTaskData().getActualOwner().getId() : "",
      ti.getDescription(),
      ti.getPriority(),
      (ti.getTaskData().getCreatedBy() != null) ? ti.getTaskData().getCreatedBy().getId() : "",
      ti.getTaskData().getCreatedOn(),
      ti.getTaskData().getExpirationTime(),
      ti.getTaskData().getProcessInstanceId(),
      ti.getTaskData().getProcessId(),
      ti.getTaskData().getProcessSessionId(),
      ti.getTaskData().getDeploymentId(),
      ti.getTaskData().getParentId(),
      ti.getTaskData().getWorkItemId(),
      date
    );
  
  return auditTaskImpl;
}

代码示例来源：origin: kiegroup/jbpm

@Override
public void afterTaskStartedEvent(TaskEvent event) {
  String userId = event.getTaskContext().getUserId();
  Task ti = event.getTask();
  
  TaskEventImpl taskEvent = new TaskEventImpl(ti.getId(), org.kie.internal.task.api.model.TaskEvent.TaskEventType.STARTED, ti.getTaskData().getProcessInstanceId(), ti.getTaskData().getWorkItemId(), userId );                     
  AuditTaskImpl auditTaskImpl = createAuditTask(ti, event.getEventDate());         
  auditTaskImpl.setStatus(ti.getTaskData().getStatus().name());
  auditTaskImpl.setActualOwner(getActualOwner(ti));
  auditTaskImpl.setLastModificationDate(event.getEventDate());
  
  sendMessage(new AuditTaskData(auditTaskImpl, taskEvent), 5);
}

代码示例来源：origin: kiegroup/jbpm

@Override
public void beforeTaskReleasedEvent(TaskEvent event) {
  String userId = event.getTaskContext().getUserId();
  Task ti = event.getTask();
  TaskEventImpl taskEvent = new TaskEventImpl(ti.getId(), org.kie.internal.task.api.model.TaskEvent.TaskEventType.RELEASED, ti.getTaskData().getProcessInstanceId(), ti.getTaskData().getWorkItemId(), userId);
  sendMessage(new AuditTaskData(null, taskEvent), 7);
}

代码示例来源：origin: kiegroup/jbpm

Status status = newStatus != null ? newStatus : ti.getTaskData().getStatus();
                        persistenceContext.addParametersToMap("taskId", ti.getId()), 
                        BAMTaskSummaryImpl.class);
  logger.warn("Unable find bam task entry for task id {} '{}', skipping bam task update", ti.getId(), ti.getName());
  return null;
if (ti.getTaskData().getActualOwner() != null) {
  result.setUserId(ti.getTaskData().getActualOwner().getId());

代码示例来源：origin: kiegroup/jbpm

@Override
public void afterTaskAddedEvent(TaskEvent event) {
  String userId = event.getTaskContext().getUserId();
  Task ti = event.getTask();   
  if(ti.getTaskData().getProcessId() != null){
    userId = ti.getTaskData().getProcessId();
  }
  AuditTaskImpl auditTask = createAuditTask(ti, event.getEventDate());            
  TaskEventImpl taskEvent = new TaskEventImpl(ti.getId(), org.kie.internal.task.api.model.TaskEvent.TaskEventType.ADDED, ti.getTaskData().getProcessInstanceId(), ti.getTaskData().getWorkItemId(), userId);
  sendMessage(new AuditTaskData(auditTask, taskEvent), 9);
}

代码示例来源：origin: kiegroup/jbpm

@Override
public void afterTaskForwardedEvent(TaskEvent event) {
  String userId = event.getTaskContext().getUserId();
  Task ti = event.getTask();
  StringBuilder message = new StringBuilder();
  String entitiesAsString = (ti.getPeopleAssignments().getPotentialOwners()).stream().map(oe -> oe.getId()).collect(Collectors.joining(","));
  message.append("Forward to [" + entitiesAsString + "]");
  TaskEventImpl taskEvent = new TaskEventImpl(ti.getId(), org.kie.internal.task.api.model.TaskEvent.TaskEventType.FORWARDED, ti.getTaskData().getProcessInstanceId(), ti.getTaskData().getWorkItemId(), userId, message.toString());
  AuditTaskImpl auditTaskImpl = createAuditTask(ti, event.getEventDate());
  auditTaskImpl.setDescription(ti.getDescription());
  auditTaskImpl.setName(ti.getName());
  auditTaskImpl.setActivationTime(ti.getTaskData().getActivationTime());
  auditTaskImpl.setPriority(ti.getPriority());
  auditTaskImpl.setDueDate(ti.getTaskData().getExpirationTime());
  auditTaskImpl.setStatus(ti.getTaskData().getStatus().name());
  auditTaskImpl.setActualOwner(getActualOwner(ti));
  auditTaskImpl.setLastModificationDate(event.getEventDate());
  sendMessage(new AuditTaskData(auditTaskImpl, taskEvent), 4);
}

代码示例来源：origin: kiegroup/jbpm

protected void completeTask(Task task) {
  taskService.start(task.getId(), task.getTaskData().getActualOwner().getId());
  taskService.complete(task.getId(), task.getTaskData().getActualOwner().getId(), new HashMap<String,Object>());
}

代码示例来源：origin: kiegroup/jbpm

@Override
public void afterTaskCompletedEvent(TaskEvent event) {
  String userId = event.getTaskContext().getUserId();
  Task ti = event.getTask();
  TaskEventImpl taskEvent = new TaskEventImpl(ti.getId(), org.kie.internal.task.api.model.TaskEvent.TaskEventType.COMPLETED, ti.getTaskData().getProcessInstanceId(), ti.getTaskData().getWorkItemId(), userId);
  AuditTaskImpl auditTaskImpl = createAuditTask(ti, event.getEventDate());
  auditTaskImpl.setStatus(ti.getTaskData().getStatus().name());
  auditTaskImpl.setActualOwner(getActualOwner(ti));
  auditTaskImpl.setLastModificationDate(event.getEventDate());
  sendMessage(new AuditTaskData(auditTaskImpl, taskEvent), 2);
}

代码示例来源：origin: kiegroup/jbpm

@Override
public void beforeTaskReleasedEvent(TaskEvent event) {
  String userId = event.getTaskContext().getUserId();
  Task ti = event.getTask();
  TaskPersistenceContext persistenceContext = getPersistenceContext(((TaskContext)event.getTaskContext()).getPersistenceContext());
  try {            
    persistenceContext.persist(new TaskEventImpl(ti.getId(), org.kie.internal.task.api.model.TaskEvent.TaskEventType.RELEASED, ti.getTaskData().getProcessInstanceId(), ti.getTaskData().getWorkItemId(), userId));
   
  } finally {
    cleanup(persistenceContext);
  }
  
}

代码示例来源：origin: kiegroup/jbpm

@Override
public void afterTaskFailedEvent(TaskEvent event) {
  String userId = event.getTaskContext().getUserId();
  Task ti = event.getTask();
  TaskEventImpl taskEvent = new TaskEventImpl(ti.getId(), org.kie.internal.task.api.model.TaskEvent.TaskEventType.FAILED, ti.getTaskData().getProcessInstanceId(), ti.getTaskData().getWorkItemId(), userId);
  AuditTaskImpl auditTaskImpl = createAuditTask(ti, event.getEventDate());
  auditTaskImpl.setStatus(ti.getTaskData().getStatus().name());
  auditTaskImpl.setActualOwner(getActualOwner(ti));
  auditTaskImpl.setLastModificationDate(event.getEventDate());
  sendMessage(new AuditTaskData(auditTaskImpl, taskEvent), 2);
}

代码示例来源：origin: kiegroup/jbpm

@Override
public void afterTaskOutputVariableChangedEvent(TaskEvent event, Map<String, Object> variables) {
  String userId = event.getTaskContext().getUserId();
  Task task = event.getTask();        
  if (variables == null || variables.isEmpty()) {
    return;
  }
  
  List<TaskVariableImpl> taskVariables = indexVariables(task, variables, VariableType.OUTPUT);
  String message = "Task output data updated";
  TaskEventImpl taskEvent = new TaskEventImpl(task.getId(), 
                         org.kie.internal.task.api.model.TaskEvent.TaskEventType.UPDATED, 
                         task.getTaskData().getProcessInstanceId(), 
                         task.getTaskData().getWorkItemId(), 
                         userId, message);
  AuditTaskImpl auditTaskImpl = createAuditTask(task, event.getEventDate());
  auditTaskImpl.setLastModificationDate(event.getEventDate());
  
  sendMessage(new AuditTaskData(auditTaskImpl, Collections.singletonList(taskEvent), null, taskVariables), 2);
}

代码示例来源：origin: kiegroup/jbpm

@Override
public void afterTaskFailedEvent(TaskEvent event) {
  String userId = event.getTaskContext().getUserId();
  Task ti = event.getTask();
  TaskPersistenceContext persistenceContext = getPersistenceContext(((TaskContext)event.getTaskContext()).getPersistenceContext());
  try {            
    persistenceContext.persist(new TaskEventImpl(ti.getId(), org.kie.internal.task.api.model.TaskEvent.TaskEventType.FAILED, ti.getTaskData().getProcessInstanceId(), ti.getTaskData().getWorkItemId(), userId));
    
    AuditTaskImpl auditTaskImpl = getAuditTask(event, persistenceContext, ti);
    if (auditTaskImpl == null) {
      logger.warn("Unable find audit task entry for task id {} '{}', skipping audit task update", ti.getId(), ti.getName());
      return;
    }
    auditTaskImpl.setStatus(ti.getTaskData().getStatus().name());
    auditTaskImpl.setActualOwner(getActualOwner(ti));
    auditTaskImpl.setLastModificationDate(event.getEventDate());
    persistenceContext.merge(auditTaskImpl);
  } finally {
    cleanup(persistenceContext);
  }
}

代码示例来源：origin: kiegroup/jbpm

private TaskImpl addTask( long workItemId, long procInstId, String busAdmin, String potOwner, String name, String deploymentId) { 
    String str = "(with (new Task()) { priority = 55, taskData = (with( new TaskData()) { } ), ";
    
    String potOwnerType = potOwner.equals("Hideo") ? "User" : "Group";
    str += "peopleAssignments = (with ( new PeopleAssignments() ) { "
        + "taskStakeholders = [new User('" + stakeHolder + "')],"
        + "businessAdministrators = [new User('" + busAdmin + "')],"
        + "potentialOwners = [new " + potOwnerType + "('" + potOwner + "')]"
        + " }),";
    str += "name =  '" + name + "' })";
    Task taskImpl = TaskFactory.evalTask(new StringReader(str));
    ((InternalTaskData) taskImpl.getTaskData()).setWorkItemId(workItemId);
    ((InternalTaskData) taskImpl.getTaskData()).setProcessInstanceId(procInstId);
    ((InternalTaskData) taskImpl.getTaskData()).setDeploymentId(deploymentId);
    taskService.addTask(taskImpl, new HashMap<String, Object>());
    assertNotNull( "Null task id", taskImpl.getId());
    return (TaskImpl) taskImpl;
  }
}

代码示例来源：origin: kiegroup/jbpm

@Override
public void afterTaskCompletedEvent(TaskEvent event) {
  String userId = event.getTaskContext().getUserId();
  Task ti = event.getTask();
  TaskPersistenceContext persistenceContext = getPersistenceContext(((TaskContext)event.getTaskContext()).getPersistenceContext());
  try {            
    persistenceContext.persist(new TaskEventImpl(ti.getId(), org.kie.internal.task.api.model.TaskEvent.TaskEventType.COMPLETED, ti.getTaskData().getProcessInstanceId(), ti.getTaskData().getWorkItemId(), userId));    
    
    AuditTaskImpl auditTaskImpl = getAuditTask(event, persistenceContext, ti);
    if (auditTaskImpl == null) {
      logger.warn("Unable find audit task entry for task id {} '{}', skipping audit task update", ti.getId(), ti.getName());
      return;
    }
    auditTaskImpl.setStatus(ti.getTaskData().getStatus().name());
    auditTaskImpl.setActualOwner(getActualOwner(ti));
    auditTaskImpl.setLastModificationDate(event.getEventDate());
    persistenceContext.merge(auditTaskImpl);
  } finally {
    cleanup(persistenceContext);
  }
}

代码示例来源：origin: kiegroup/jbpm

private TaskImpl addTask( long workItemId, long procInstId, String busAdmin, String potOwner, String name, String deploymentId) {
  String str = "(with (new Task()) { priority = 55, taskData = (with( new TaskData()) { } ), ";
  str += "peopleAssignments = (with ( new PeopleAssignments() ) { "
      + "taskStakeholders = [new User('" + stakeHolder + "')],"
      + "businessAdministrators = [new User('" + busAdmin + "')],"
      + "potentialOwners = [new User('" + potOwner + "')]"
      + " }),";
  str += "name =  '" + name + "' })";
  Task taskImpl = TaskFactory.evalTask(new StringReader(str));
  ((InternalTaskData) taskImpl.getTaskData()).setWorkItemId(workItemId);
  ((InternalTaskData) taskImpl.getTaskData()).setProcessInstanceId(procInstId);
  ((InternalTaskData) taskImpl.getTaskData()).setDeploymentId(deploymentId);
  taskService.addTask(taskImpl, new HashMap<String, Object>());
  assertNotNull( "Null task id", taskImpl.getId());
  return (TaskImpl) taskImpl;
}

代码示例来源：origin: kiegroup/jbpm

@Override
public void afterTaskActivatedEvent(TaskEvent event) {
  String userId = event.getTaskContext().getUserId();
  Task ti = event.getTask();
  TaskEventImpl taskEvent = new TaskEventImpl(ti.getId(), org.kie.internal.task.api.model.TaskEvent.TaskEventType.ACTIVATED, ti.getTaskData().getProcessInstanceId(), ti.getTaskData().getWorkItemId(), userId);
       
  AuditTaskImpl auditTaskImpl = createAuditTask(ti, event.getEventDate());    
  auditTaskImpl.setStatus(ti.getTaskData().getStatus().name());
  auditTaskImpl.setActualOwner(getActualOwner(ti));
  auditTaskImpl.setDescription(ti.getDescription());    
  auditTaskImpl.setLastModificationDate(event.getEventDate());
    sendMessage(new AuditTaskData(auditTaskImpl, taskEvent), 8);
}

代码示例来源：origin: kiegroup/jbpm

private void testDueDateUpdate(Date oldDate,
                Date newDate,
                boolean changeExpected,
                String expectedMessage) {
  Task task = new TaskFluent()
      .setDueDate(oldDate)
      .setAdminUser("Administrator")
      .getTask();
  taskService.addTask(task, new HashMap<String, Object>());
  long taskId = task.getId();
  taskService.setExpirationDate(taskId, newDate);
  task = taskService.getTaskById(taskId);
  Assertions.assertThat(task.getTaskData().getExpirationTime()).isEqualTo(newDate);
  List<AuditTask> auditTasks = taskAuditService.getAllAuditTasks(new QueryFilter());
  Assertions.assertThat(auditTasks).hasSize(1);
  Assertions.assertThat(auditTasks.get(0).getDueDate()).isEqualTo(newDate);
  List<TaskEvent> taskEvents = taskAuditService.getAllTaskEvents(taskId, new QueryFilter());
  if (changeExpected) {
    Assertions.assertThat(taskEvents).hasSize(2);
    Assertions.assertThat(taskEvents.get(1).getMessage()).isEqualTo(expectedMessage);
  } else {
    Assertions.assertThat(taskEvents).hasSize(1);
  }
}

代码示例来源：origin: kiegroup/jbpm

@Override
public void afterTaskSkippedEvent(TaskEvent event) {
  String userId = event.getTaskContext().getUserId();
  Task ti = event.getTask();
  TaskEventImpl taskEvent = new TaskEventImpl(ti.getId(), org.kie.internal.task.api.model.TaskEvent.TaskEventType.SKIPPED, ti.getTaskData().getProcessInstanceId(), ti.getTaskData().getWorkItemId(), userId);
  AuditTaskImpl auditTaskImpl = createAuditTask(ti, event.getEventDate());
  auditTaskImpl.setStatus(ti.getTaskData().getStatus().name());
  auditTaskImpl.setActualOwner(getActualOwner(ti));
  auditTaskImpl.setDescription(ti.getDescription());
  auditTaskImpl.setLastModificationDate(event.getEventDate());
  sendMessage(new AuditTaskData(auditTaskImpl, taskEvent), 2);
}

代码示例来源：origin: kiegroup/jbpm

protected long createAndAssertTask(TaskFluent tf, String expectedOwner) {
  Task task = tf.getTask();
  taskService.addTask(task, data);
  long taskId = task.getId();
  assertEquals("Owner mismatch",expectedOwner,taskService.getTaskById(taskId).getTaskData().getActualOwner().getId());
  return taskId;
}

内容来源于网络，如有侵权，请联系作者删除！

task

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com