import org.activiti.engine.impl.bpmn.behavior.SubProcessActivityBehavior; //导入依赖的package包/类
/**
 * Parses a subprocess (formely known as an embedded subprocess): a subprocess
 * defined withing another process definition.
 * 
 * @param subProcessElement
 *          The XML element corresponding with the subprocess definition
 * @param scope
 *          The current scope on which the subprocess is defined.
 */
public ActivityImpl parseSubProcess(Element subProcessElement, ScopeImpl scope) {
  ActivityImpl activity = createActivityOnScope(subProcessElement, scope);
  
  String async = subProcessElement.attributeNS(BpmnParser.ACTIVITI_BPMN_EXTENSIONS_NS, "async");
  activity.setAsync("true".equals(async));
  
  activity.setScope(true);
  activity.setActivityBehavior(new SubProcessActivityBehavior());
  parseScope(subProcessElement, activity);

  for (BpmnParseListener parseListener : parseListeners) {
    parseListener.parseSubProcess(subProcessElement, scope, activity);
  }
  return activity;
}
 

import org.activiti.engine.impl.bpmn.behavior.SubProcessActivityBehavior; //导入依赖的package包/类
/**
 * Parses a subprocess (formally known as an embedded subprocess): a subprocess
 * defined within another process definition.
 * 
 * @param subProcessElement
 *          The XML element corresponding with the subprocess definition
 * @param scope
 *          The current scope on which the subprocess is defined.
 */
public ActivityImpl parseSubProcess(Element subProcessElement, ScopeImpl scope) {
  ActivityImpl activity = createActivityOnScope(subProcessElement, scope);
  
  activity.setAsync(isAsync(subProcessElement));
  activity.setExclusive(isExclusive(subProcessElement));

  Boolean isTriggeredByEvent = parseBooleanAttribute(subProcessElement.attribute("triggeredByEvent"), false);
  activity.setProperty("triggeredByEvent", isTriggeredByEvent);
  
  // event subprocesses are not scopes
  activity.setScope(!isTriggeredByEvent);
  activity.setActivityBehavior(new SubProcessActivityBehavior());
  parseScope(subProcessElement, activity);

  for (BpmnParseListener parseListener : parseListeners) {
    parseListener.parseSubProcess(subProcessElement, scope, activity);
  }
  return activity;
}
 

import org.activiti.engine.impl.bpmn.behavior.SubProcessActivityBehavior; //导入依赖的package包/类
@Override
public SubProcessActivityBehavior createSubprocActivityBehavior(SubProcess subProcess) {
    return wrappedActivityBehaviorFactory.createSubprocActivityBehavior(subProcess);
}
 

import org.activiti.engine.impl.bpmn.behavior.SubProcessActivityBehavior; //导入依赖的package包/类
@Override
public SubProcessActivityBehavior createSubprocActivityBehavior(SubProcess subProcess) {
    return new SubProcessActivityBehavior();
}
 

import org.activiti.engine.impl.bpmn.behavior.SubProcessActivityBehavior; //导入依赖的package包/类
/**
 * 读取跟踪数据
 *
 * @param executionId
 * @return
 * @throws Exception
 */
@RequestMapping(value = "trace/data/{executionId}")
@ResponseBody
public List<Map<String, Object>> readActivityDatas(@PathVariable("executionId") String executionId) throws Exception {
    ExecutionEntity executionEntity = (ExecutionEntity) runtimeService.createExecutionQuery().executionId(executionId).singleResult();
    List<String> activeActivityIds = runtimeService.getActiveActivityIds(executionId);

    RepositoryServiceImpl repositoryServiceImpl = (RepositoryServiceImpl) repositoryService;
    ReadOnlyProcessDefinition deployedProcessDefinition = repositoryServiceImpl
            .getDeployedProcessDefinition(executionEntity.getProcessDefinitionId());

    ProcessDefinitionEntity processDefinition = (ProcessDefinitionEntity) deployedProcessDefinition;
    List<ActivityImpl> activitiList = processDefinition.getActivities();//获得当前任务的所有节点

    List<Map<String, Object>> activityInfos = new ArrayList<Map<String, Object>>();
    for (ActivityImpl activity : activitiList) {

        ActivityBehavior activityBehavior = activity.getActivityBehavior();

        boolean currentActiviti = false;
        // 当前节点
        String activityId = activity.getId();
        if (activeActivityIds.contains(activityId)) {
            currentActiviti = true;
        }
        Map<String, Object> activityImageInfo = packageSingleActivitiInfo(activity, executionEntity.getId(), currentActiviti);
        activityInfos.add(activityImageInfo);

        // 处理子流程
        if (activityBehavior instanceof SubProcessActivityBehavior) {
            List<ActivityImpl> innerActivityList = activity.getActivities();
            for (ActivityImpl innerActivity : innerActivityList) {
                String innerActivityId = innerActivity.getId();
                if (activeActivityIds.contains(innerActivityId)) {
                    currentActiviti = true;
                } else {
                    currentActiviti = false;
                }
                activityImageInfo = packageSingleActivitiInfo(innerActivity, executionEntity.getId(), currentActiviti);
                activityInfos.add(activityImageInfo);
            }
        }

    }

    return activityInfos;
}
 

import org.activiti.engine.impl.bpmn.behavior.SubProcessActivityBehavior; //导入依赖的package包/类
public SubProcessActivityBehavior createSubprocActivityBehavior(SubProcess subProcess) {
  return new SubProcessActivityBehavior();
}
 

import org.activiti.engine.impl.bpmn.behavior.SubProcessActivityBehavior; //导入依赖的package包/类
public abstract SubProcessActivityBehavior createSubprocActivityBehavior(SubProcess subProcess);