Solon v3.4.2

flow - 流上下文的作用（FlowContext）

</> markdown

作用1：数据输入输出

对应字段或方法描述
context.model()提供多数据输入输出支持（在脚本中，可直接使用字段）
context.put(key, value)model 的快捷方法
context.putIfAbsent(key, value)model 的快捷方法
context.putAll(map)model 的快捷方法
context.computeIfAbsent(key, mappingFunction)model 的快捷方法
context.get(key)model 的快捷方法
context.getOrDefault(key, def)model 的快捷方法
context.remove(key)model 的快捷方法
context.incrAdd(key, delta)model 的快捷方法（增量添加）。v3.4.1 后支持
context.incrGet(key)model 的快捷方法（增量获取）。v3.4.1 后支持
context.result提供单数据输出支持

作用：

  • 给流处理输入变量
  • 在节点处理之间传递变量（例如：一个节点的处理结果作为变量，后一个节点可使用）

应用示例1：（给流处理输入变量）

#c1.chain.yml
id: c1
layout:
  - task: 'if(a > 0){context.result=1;}'

FlowContext context = new FlowContext();
context.put("a",2);

flowEngine.eval(c1,context);
System.out.println(context.result); //打印执行结果

应用示例2：（在节点处理之间传递变量）

#c1.chain.yml
id: c1
layout:
  - task: |
      context.put("a", 1); context.put("b", 2);
  - task: |
      context.put("c", (a + b)); //可以直接使用变量，可者通过 (int)context.get("a") 获取

作用2：中断控制（阻断当前分支，或停止）

带状态的业务场景中，根据状态中断流的驱动。比如，业务审批。

对应字段或方法描述
context.isInterrupted()是否已阻断
context.interrupt()阻断（当前分支不再后流）
context.isStopped()是否已停止
context.stop()停止（整个流不再后流）
context.manualNext(node)手动下一步（一般用不到）

应用示例（一般，用于驱动或任务定制）：

@Component
public class ApproveFlowDriver extends SimpleFlowDriver implements FlowDriver{
    @Inject
    FlowService flowService;
    
    @Override
    public void handleTask(FlowContext context, Task task) throws Throwable {
        String instance_id = context.get("instance_id");
        String task_id = task.node().id();

        //获取任务状态
        TaskState taskState = flowService.getState(instance_id, task_id);

        if (taskState == null) {
            //没有状态，说明未完成；；；等待人工审批完成
            context.interrupt();
            //发送电子邮件催办
            flowService.sendEmail();
        }
    }
}

作用3：广播事件（基于大米事件总线 - DamiBus）

（v3.1.3 后支持）基于流上下文（FlowContext）的事件总线。可以在流执行中广播事件

对应字段或方法描述
context.eventBus()事件总线
context.<String,String>eventBus()支持泛型（类型按需指定，不指定时为 object）

流配置中的应用示例:

id: event1
layout:
  - task: '@DemoCom'
  - task: 'context.<String,String>eventBus().send("demo.topic", "hello");'

代码执行中的应用示例：

public class DemoController {
    ...
    public void test(){
        FlowContext context = new FlowContext();
        context.<String,String>eventBus().listen("demo.topic", event -> {
            System.out.println(event.getContent());
        });

        flowEngine.eval("event1", context);
    }
}

 @Component
public static class DemoCom implements TaskComponent {

    @Override
    public void run(FlowContext context, Node node) throws Throwable {
        context.<String, String>eventBus().send("demo.topic", "hello-com");
    }
}

作用4：脚本运行和任务运行

对应字段或方法描述
context.runScript(script)动态运行脚本
context.runTask(node, description)运行动态任务描述（与配置格式保持一致）

应用示例（可在脚本里，再动态运行脚本）：

#c1.chain.yml
id: c1
layout:
  - meta.script: "1+1"
    task: 'context.runScript(node.meta("script"))' #执行 meta.script 声明的脚本