org.activiti.engine.runtime.Job.getExecutionId()方法的使用及代码示例

x33g5p2x  于2022-01-22 转载在 其他  
字(5.3k)|赞(0)|评价(0)|浏览(75)

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

Job.getExecutionId介绍

[英]Returns the specific execution on which the job was created.
[中]返回创建作业的特定执行。

代码示例

代码示例来源:origin: Activiti/Activiti

public Object execute(CommandContext commandContext) {

  if (job == null) {
   throw new ActivitiIllegalArgumentException("job is null");
  }

  if (log.isDebugEnabled()) {
   log.debug("Executing lock exclusive job {} {}", job.getId(), job.getExecutionId());
  }

  if (job.isExclusive()) {
   if (job.getExecutionId() != null) {
    ExecutionEntity execution = commandContext.getExecutionEntityManager().findById(job.getExecutionId());
    if (execution != null) {
     commandContext.getExecutionEntityManager().updateProcessInstanceLockTime(execution.getProcessInstanceId());
    }
   }
  }

  return null;
 }
}

代码示例来源:origin: Activiti/Activiti

Object persistedObject = ((ActivitiEntityEvent) event).getEntity();
if (persistedObject instanceof Job) {
 event.setExecutionId(((Job) persistedObject).getExecutionId());
 event.setProcessInstanceId(((Job) persistedObject).getProcessInstanceId());
 event.setProcessDefinitionId(((Job) persistedObject).getProcessDefinitionId());

代码示例来源:origin: org.activiti/activiti-engine

public Object execute(CommandContext commandContext) {

  if (job == null) {
   throw new ActivitiIllegalArgumentException("job is null");
  }

  if (log.isDebugEnabled()) {
   log.debug("Executing lock exclusive job {} {}", job.getId(), job.getExecutionId());
  }

  if (job.isExclusive()) {
   if (job.getExecutionId() != null) {
    ExecutionEntity execution = commandContext.getExecutionEntityManager().findById(job.getExecutionId());
    if (execution != null) {
     commandContext.getExecutionEntityManager().updateProcessInstanceLockTime(execution.getProcessInstanceId());
    }
   }
  }

  return null;
 }
}

代码示例来源:origin: org.alfresco/alfresco-repository

private WorkflowTask getTaskForTimer(Job job, ProcessInstance processInstance, Execution jobExecution) 
{
  if (job instanceof TimerEntity) 
  {
    ReadOnlyProcessDefinition def = activitiUtil.getDeployedProcessDefinition(processInstance.getProcessDefinitionId());
    List<String> activeActivityIds = runtimeService.getActiveActivityIds(jobExecution.getId());
    
    if(activeActivityIds.size() == 1)
    {
      PvmActivity targetActivity = def.findActivity(activeActivityIds.get(0));
      if(targetActivity != null)
      {
        // Only get tasks of active activity is a user-task 
        String activityType = (String) targetActivity.getProperty(ActivitiConstants.NODE_TYPE);
        if(ActivitiConstants.USER_TASK_NODE_TYPE.equals(activityType))
        {
          Task task = taskService.createTaskQuery().executionId(job.getExecutionId()).singleResult();
          return typeConverter.convert(task);
        }
      }
    }
  }
  return null;
}

代码示例来源:origin: Alfresco/alfresco-repository

private WorkflowTask getTaskForTimer(Job job, ProcessInstance processInstance, Execution jobExecution) 
{
  if (job instanceof TimerEntity) 
  {
    ReadOnlyProcessDefinition def = activitiUtil.getDeployedProcessDefinition(processInstance.getProcessDefinitionId());
    List<String> activeActivityIds = runtimeService.getActiveActivityIds(jobExecution.getId());
    
    if(activeActivityIds.size() == 1)
    {
      PvmActivity targetActivity = def.findActivity(activeActivityIds.get(0));
      if(targetActivity != null)
      {
        // Only get tasks of active activity is a user-task 
        String activityType = (String) targetActivity.getProperty(ActivitiConstants.NODE_TYPE);
        if(ActivitiConstants.USER_TASK_NODE_TYPE.equals(activityType))
        {
          Task task = taskService.createTaskQuery().executionId(job.getExecutionId()).singleResult();
          return typeConverter.convert(task);
        }
      }
    }
  }
  return null;
}

代码示例来源:origin: org.alfresco/alfresco-repository

.executionId(job.getExecutionId()).singleResult();

代码示例来源:origin: Alfresco/alfresco-repository

.executionId(job.getExecutionId()).singleResult();

代码示例来源:origin: org.activiti/activiti-rest

public JobResponse createJobResponse(Job job, RestUrlBuilder urlBuilder) {
 JobResponse response = new JobResponse();
 response.setId(job.getId());
 response.setDueDate(job.getDuedate());
 response.setExceptionMessage(job.getExceptionMessage());
 response.setExecutionId(job.getExecutionId());
 response.setProcessDefinitionId(job.getProcessDefinitionId());
 response.setProcessInstanceId(job.getProcessInstanceId());
 response.setRetries(job.getRetries());
 response.setTenantId(job.getTenantId());
 response.setUrl(urlBuilder.buildUrl(RestUrls.URL_JOB, job.getId()));
 if (job.getProcessDefinitionId() != null) {
  response.setProcessDefinitionUrl(urlBuilder.buildUrl(RestUrls.URL_PROCESS_DEFINITION, job.getProcessDefinitionId()));
 }
 if (job.getProcessInstanceId() != null) {
  response.setProcessInstanceUrl(urlBuilder.buildUrl(RestUrls.URL_PROCESS_INSTANCE, job.getProcessInstanceId()));
 }
 if (job.getExecutionId() != null) {
  response.setExecutionUrl(urlBuilder.buildUrl(RestUrls.URL_EXECUTION, job.getExecutionId()));
 }
 return response;
}

代码示例来源:origin: Alfresco/alfresco-repository

String expectedTimerPathId = BPMEngineRegistry.createGlobalId(ActivitiConstants.ENGINE_ID, timerJob.getExecutionId());
assertNotNull(timer.getPath());
assertEquals(expectedTimerPathId, timer.getPath().getId());

代码示例来源:origin: org.activiti/activiti-engine

Object persistedObject = ((ActivitiEntityEvent) event).getEntity();
if (persistedObject instanceof Job) {
 event.setExecutionId(((Job) persistedObject).getExecutionId());
 event.setProcessInstanceId(((Job) persistedObject).getProcessInstanceId());
 event.setProcessDefinitionId(((Job) persistedObject).getProcessDefinitionId());

相关文章