Examples of ProcessNode

cn.com.manager.tasks.node.ProcessNode
@author kete
com.catify.processengine.core.data.model.entities.ProcessNode
The ProcessNode holds all flow elements of a bpmn process. A ProcessNode has an incoming relationship from either the {@link RunningNode} or the {@link ArchiveNode} and outgoing relationships to its{@link FlowNodes}.

Level 1 of the database process representation. @author christopher köster

Examples of cn.com.manager.tasks.node.ProcessNode

     * @param task
     */
    public static void registTask(Task task) {
        TaskNode currentNode = OperatFactory.getServiceObject(TaskService.class, DataProviderModel.FILE).getTaskNode(task.getNode());
        String nodeName = currentNode.getCurrentNode();
        ProcessNode processNode = new ProcessNode();
        Node n = OperatFactory.getServiceObject(NodeService.class, DataProviderModel.FILE).getNode(nodeName);
        processNode.setAutoFlag(n.isAutoFlag());
        processNode.setNodeName(n.getNodeName());
        processNode.setNodeDesc(n.getNodeDesc());
        processNode.setNodeStatus(n.getNodeStatus());
        task.setProcessNode(processNode);
        task.setDisplay(processNode.getNodeDesc());
        task.setStatus(processNode.getNodeStatus());
        InitiationTaskInfo.initNextProcessNode(processNode);
        BricksCacheManager.INSTANCE.addCacheElement(_CACHE_NAME, task.getTaskid(), task);
    }

View Full Code Here

Examples of cn.com.manager.tasks.node.ProcessNode

            Node node = null;
            // 依次设定下一节点
            String nodeName = currentNode.getNextNode();
            if (!StringUtil.isEmpty(nodeName) ) {
                node = OperatFactory.getServiceObject(NodeService.class, DataProviderModel.FILE).getNode(nodeName);
                ProcessNode subNode = new ProcessNode();
                subNode.setAutoFlag(node.isAutoFlag());
                subNode.setNodeName(node.getNodeName());
                subNode.setNodeDesc(node.getNodeDesc());
                subNode.setNodeStatus(node.getNodeStatus());
                processNode.setNext(subNode);
            }
            nodeName = currentNode.getParentNode();
            // 依次设定父节点
            if (!StringUtil.isEmpty(nodeName)) {
                node = OperatFactory.getServiceObject(NodeService.class, DataProviderModel.FILE).getNode(nodeName);
                ProcessNode parentNode = new ProcessNode();
                parentNode.setAutoFlag(node.isAutoFlag());
                parentNode.setNodeName(node.getNodeName());
                parentNode.setNodeDesc(node.getNodeDesc());
                parentNode.setNodeStatus(node.getNodeStatus());
                processNode.setParent(parentNode);
            }
        }
    }

View Full Code Here

Examples of cn.com.manager.tasks.node.ProcessNode

     * 任务节点的流转
     * @param state
     */
    public void change() {
        // 保存Task操作记录
        ProcessNode current = task.getProcessNode();
        if (current.getNext() == null) {
            task.setStatus(_STATUS_END);
            // 应该清空缓存中的任务
            TasksController.removeTask(task);
            task.setProcessNode(null);
            return;
        }
        task.setDisplay(current.getNext().getNodeDesc());
        task.setStatus(current.getNext().getNodeStatus());
        task.setProcessNode(current.getNext());
        task.setNode(current.getNext().getNodeName());
        InitiationTaskInfo.initNextProcessNode(current.getNext());
    }

View Full Code Here

Examples of cn.com.manager.tasks.node.ProcessNode

     *
     * @return
     */
    public static <T> List<Result> approveProcess(String taskId, T data) {
        Task task = TasksController.getTask(taskId);
        ProcessNode node = task.getProcessNode();
        List<Result> rs = new ArrayList<Result>(3);
        String returnedValue = null;
        Throwable exception = null;
        ProcessData datas = new ProcessData(task, data);
        String nodeName = null;
        do {
            try {
                if (node != null) {
                    nodeName = node.getNodeName();
                    //节点处理类
                    Process nodeProcess = ProcessFactory.getProcess(nodeName);
                    returnedValue = nodeProcess.execute(datas);
                }
                node = task.getProcessNode();
            } catch (AppException ex) {
                exception = ex;
                node = null;
            }
            rs.add(new Result(returnedValue, nodeName, taskId, exception));
            //自动流转节点系统自动完成
            if (node!=null &&!node.isAutoFlag()) {
                break;
            }
        } while (node != null);
        return rs;
    }

View Full Code Here

Examples of com.catify.processengine.core.data.model.entities.ProcessNode

   * @see com.catify.processengine.core.data.services.ProcessRepositoryService#getOrCreateProcessNode(com.catify.processengine.core.data.model.entities.ProcessNode)
   */
  @Override
  public ProcessNode getOrCreateProcessNode(ProcessNode proposedProcessNode) {
    
    ProcessNode existingProcess = findByUniqueProcessId(proposedProcessNode.getUniqueProcessId());
    
    if (existingProcess == null) {
      return this.save(proposedProcessNode);
    }

View Full Code Here

Examples of com.catify.processengine.core.data.model.entities.ProcessNode

  /* (non-Javadoc)
   * @see com.catify.processengine.core.data.services.ProcessRepositoryService#delete(java.lang.String)
   */
  @Override
  public boolean delete(String uniqueProcessId) {
    ProcessNode process = findByUniqueProcessId(uniqueProcessId);


    if (process != null) {
      processRepository.delete(process);
      return true;
    } else {

View Full Code Here

Examples of com.catify.processengine.core.data.model.entities.ProcessNode

      FlowNode archivedFlowNode = flowNodeRepositoryService.findArchivedByRunningUniqueFlowNodeId(flowNodeId);
      flowNodeInstance.moveToArchive(archivedFlowNode, processInstanceId);
    }
    
    // save the process instance node to the archived process node 
    ProcessNode archivedProcessNode = processRepositoryService.findArchivedByRunningUniqueProcessId(uniqueProcessId);
    ProcessInstanceNode processInstanceNode = loadProcessInstanceNode(uniqueProcessId, processInstanceId);


    processInstanceNode.moveInstanceToArchive(archivedProcessNode, processInstanceId);
    
    processInstanceNode.setProcessInstanceEndTime(endTime);

View Full Code Here

Examples of com.catify.processengine.core.data.model.entities.ProcessNode


    // create the client context
    ClientNode clientNode = this.createClientContext(clientId);


    // create the running process node or get it from the db (eg. restart of the process engine)
    ProcessNode runningProcess = this.createRunningProcessNode(clientId, clientNode, processJaxb);
    
    // create the archived process node or get it from the db (eg. restart of the process engine)
    ProcessNode archivedProcess = this.createArchivedProcessNode(clientId, clientNode, processJaxb);


    // create the flow nodes (database and runtime)
    this.createFlowNodes(clientId, processJaxb, new ArrayList<TSubProcess>(), flowNodesJaxb, sequenceFlowsJaxb, runningProcess,
        archivedProcess);

View Full Code Here

Examples of com.catify.processengine.core.data.model.entities.ProcessNode

    LOG.debug(String.format("Added %s with grapId: %s to neo4j db",
        runningNode, runningNode.getGraphId()));
    
    // create the running process node or get it from the db (eg. restart of
    // the process engine)
    ProcessNode runningProcess = processRepositoryService
        .getOrCreateProcessNode(new ProcessNode(
            IdService.getUniqueProcessId(clientId, processJaxb), 
            processJaxb.getId(),
            processJaxb.getName(), 
            ExtensionService.getTVersion(processJaxb).getVersion()));
    
    runningNode.addRelationshipToProcessNode(runningProcess);
    runningNodeRepositoryService.save(runningNode);
    
    LOG.debug(String.format("Added %s with grapId: %s to neo4j db",
        runningProcess, runningProcess.getGraphId()));
    
    return runningProcess;
  }

View Full Code Here

Examples of com.catify.processengine.core.data.model.entities.ProcessNode

    LOG.debug(String.format("Added %s with grapId: %s to neo4j db",
        archiveNode, archiveNode.getGraphId()));
    
    // create the archived process node or get it from the db (eg. restart of
    // the process engine)
    ProcessNode archivedProcess = processRepositoryService
        .getOrCreateProcessNode(new ProcessNode(
            IdService.ARCHIVEPREFIX + IdService.getUniqueProcessId(clientId, processJaxb), 
            processJaxb.getId(),
            processJaxb.getName(), 
            ExtensionService.getTVersion(processJaxb).getVersion()));
    
    archiveNode.addRelationshipToProcessNode(archivedProcess);
    archivedNodeRepositoryService.save(archiveNode);
    
    LOG.debug(String.format("Added %s with grapId: %s to neo4j db",
        archivedProcess, archivedProcess.getGraphId()));
    
    return archivedProcess;
  }

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.