示例2: 审批场景的动作参考 [重要]

审批场景需要定制 StateController 和 StateRepository

public class OaActionDemo {
    WorkflowService workflow = WorkflowService.of(FlowEngine.newInstance(),
            new ActorStateController(),
            new InMemoryStateRepository());

    String instanceId = "i1"; //审批实例id

    //获取实例对应的流程图
    public Graph getGraph(String instanceId) {
        String graphJson = ""; //从持久层查询
        return Graph.fromText(graphJson);
    }

    //更新实例对应的流程图
    public void setGraph(String instanceId, Graph graph) {
        String graphJson = graph.toJson();
        //更新到持久层
    }

    //审批
    public void case1() throws Exception {
        Graph graph = getGraph(instanceId);

        FlowContext context = FlowContext.of(instanceId);
        context.put("actor", "A");
        Task task = workflow.getTask(graph, context);

        //展示界面，操作。然后：

        context.put("op", "审批");//作为状态的一部分
        workflow.postTask(graph, task.getNodeId(), TaskAction.FORWARD, context);
    }

    //回退
    public void case2() throws Exception {
        Graph graph = getGraph(instanceId);

        FlowContext context = FlowContext.of(instanceId);
        context.put("actor", "A");
        Task task = workflow.getTask(graph, context);

        context.put("op", "回退");//作为状态的一部分
        workflow.postTask(graph, task.getNodeId(), TaskAction.BACK, context);
    }

    //任意跳转（通过）
    public void case3_1() throws Exception {
        Graph graph = getGraph(instanceId);

        FlowContext context = FlowContext.of(instanceId);

        String nodeId = "demo1";

        workflow.postTask(graph, nodeId, TaskAction.FORWARD_JUMP, context);
        Task task = workflow.getTask(graph, context);
    }

    //任意跳转（退回）
    public void case3_2() throws Exception {
        Graph graph = getGraph(instanceId);

        FlowContext context = FlowContext.of(instanceId);

        String nodeId = "demo1";

        workflow.postTask(graph, nodeId, TaskAction.BACK_JUMP, context);
        Task task = workflow.getTask(graph, context);
    }

    //委派
    public void case4() throws Exception {
        Graph graph = getGraph(instanceId);

        FlowContext context = FlowContext.of(instanceId);
        context.put("actor", "A");
        context.put("delegate", "B"); //需要定制下状态操作员（用A检测，但留下B的状态记录）
        Task task = workflow.getTask(graph, context);

        context.put("op", "委派");//作为状态的一部分
        workflow.postTask(graph, task.getNodeId(), TaskAction.FORWARD, context);
    }

    //转办（与委派技术实现差不多）
    public void case5() throws Exception {
        Graph graph = getGraph(instanceId);

        FlowContext context = FlowContext.of(instanceId);
        context.put("actor", "A");
        context.put("transfer", "B"); //需要定制下状态操作员（用A检测，但留下B的状态记录）
        Task task = workflow.getTask(graph, context);

        context.put("op", "转办");//作为状态的一部分
        workflow.postTask(graph, task.getNodeId(), TaskAction.FORWARD, context);
    }

    //催办
    public void case6() throws Exception {
        Graph graph = getGraph(instanceId);

        FlowContext context = FlowContext.of(instanceId);
        Task task = workflow.getTask(graph, context);

        String actor = task.getNode().getMetaAs("actor");
        //发邮件（或通知）
    }

    //取回（技术上与回退差不多）
    public void case7() throws Exception {
        Graph graph = getGraph(instanceId);

        FlowContext context = FlowContext.of(instanceId);
        Task task = workflow.getTask(graph, context);

        //回退到顶（给发起人）；相当于重新开始走流程
        context.put("op", "取回");//作为状态的一部分
        workflow.postTask(graph, task.getNodeId(), TaskAction.RESTART, context);
    }

    //撤销（和回退没啥区别）
    public void case8() throws Exception {
        Graph graph = getGraph(instanceId);

        FlowContext context = FlowContext.of(instanceId);
        Task task = workflow.getTask(graph, context);

        context.put("op", "撤销");//作为状态的一部分
        workflow.postTask(graph, task.getNodeId(), TaskAction.BACK, context);
    }

    //中止
    public void case9() throws Exception {
        Graph graph = getGraph(instanceId);

        FlowContext context = FlowContext.of(instanceId);
        Task task = workflow.getTask(graph, context);

        context.put("op", "中止");//作为状态的一部分
        workflow.postTask(graph, task.getNodeId(), TaskAction.TERMINATE, context);
    }

    //抄送
    public void case10() throws Exception {
        Graph graph = getGraph(instanceId);

        FlowContext context = FlowContext.of(instanceId);
        Task task = workflow.getTask(graph, context);

        workflow.postTask(graph, task.getNodeId(), TaskAction.FORWARD, context);
        //提交后，会自动触发任务（如果有抄送配置，自动执行）
    }

    //加签
    public void case11() throws Exception {
        Graph graph = getGraph(instanceId);

        String gatewayId = "g1";
        Graph graphNew = Graph.copy(graph, spec -> {
            //添加节点
            spec.addActivity("a3").linkAdd("b2");
            //添加连接（加上 a3 节点）
            spec.getNode(gatewayId).linkAdd("a3");
        }); //复制

        //把新图，做为实例对应的流配置
        setGraph(instanceId, graphNew);
    }

    //减签
    public void case12() throws Exception {
        Graph graph = getGraph(instanceId);

        String gatewayId = "g1";
        Graph graphNew = Graph.copy(graph, spec -> {
            //添加节点
            spec.removeNode("a3");
            //添加连接（加上 a3 节点）
            spec.getNode(gatewayId).linkRemove("a3");
        }); //复制

        //把新图，做为实例对应的流配置
        setGraph(instanceId, graphNew);
    }

    //会签
    public void case13() throws Exception {
        //配置时，使用并行网关
    }

    //票签
    public void case15() throws Exception {
        //配置时，使用并行网关（收集投票）；加一个排他网关（判断票数）
    }

    //或签
    public void case16() throws Exception {
        //配置时，使用并行网关 //驱动定制时，如果元数据申明是或签：一个分支“完成”，另一分支自动为“完成”
    }

    //暂存
    public void case17() throws Exception {
        //不提交操作即可
    }
}