<!-- pom.xml 依賴(lài) -->
<dependencies>
    <dependency>
        <groupId>com.yomahub</groupId>
        <artifactId>liteflow-spring-boot-starter</artifactId>
        <version>2.11.4.2</version>
    </dependency>
</dependencies>

// 普通組件示例
@Component("paymentAction")
public class PaymentAction extends NodeComponent {
    @Override
    public void process() {
        PaymentContext context = this.getContextBean(PaymentContext.class);
        // 執(zhí)行支付邏輯
        System.out.println("處理支付, 訂單:" + context.getOrderId());
    }
}

???????// 條件組件示例（用于分支判斷）
@Component("userCheck")
public class UserCheck extends NodeComponent {
    @Override
    public void process() {
        UserContext context = this.getContextBean(UserContext.class);
        if(context.isVip()) {
            this.setIsEnd(true);  // 終止流程
        }
    }
}

liteflow:
  rule-source: config/flow.el.xml

<?xml version="1.0" encoding="UTF-8"?>
<flow>
    <chain name="orderProcess">
        THEN(
            initOrder, 
            WHEN(
                checkInventory, 
                checkUserCredit
            ),
            SWITCH(choosePayWay).TO(
                CASE(aliPay).DO(aliPayAction),
                CASE(wechatPay).DO(wechatPayAction)
            ),
            AFTER(paymentAction).WHEN(userCheck)
        );
    </chain>
</flow>

@RestController
public class OrderController {

    @Resource
    private FlowExecutor flowExecutor;

    @PostMapping("/submitOrder")
    public String submitOrder(@RequestBody OrderDTO order) {
        OrderContext context = new OrderContext();
        context.setOrderId(order.getId());
        context.setAmount(order.getAmount());
        
        LiteflowResponse response = flowExecutor.execute2Resp(
            "orderProcess", 
            context, 
            OrderContext.class
        );
        
        return response.isSuccess() ? "訂單成功" : "流程失敗";
    }
}

<!-- 配置并行節(jié)點(diǎn) -->
<chain name="parallelChain">
    THEN(
        a, 
        WHEN(b, c, d),  <!-- b,c,d并行執(zhí)行 -->
        e
    );
</chain>

<chain name="mainFlow">
    THEN(prepare, SUB(orderProcess), notify);
</chain>

@Component("paymentAction")
public class PaymentAction extends NodeComponent {
    @Override
    public void process() {...}
    
    @Override
    public void onError() {
        // 支付失敗時(shí)執(zhí)行補(bǔ)償邏輯
        fallbackService.compensate();
    }
}

// 動(dòng)態(tài)添加規(guī)則
FlowBus.addChain("newChain", "THEN(a,b,c)");

// 監(jiān)聽(tīng)規(guī)則變化
@Data
@Configuration
public class FlowConfig {
    @Bean
    public CommandLineRunner reloadRunner() {
        return args -> {
            FileWatcher.watch(Paths.get("config/flow"), 
                () -> FlowBus.reloadRule());
        };
    }
}

LiteflowResponse response = flowExecutor.execute2Resp(
    "orderProcess", 
    context, 
    OrderContext.class,
    // 開(kāi)啟執(zhí)行鏈路跟蹤
    SlotCallbackBuilder.builder().build()
);
System.out.println(response.getExecuteStepStr());

liteflow:
  monitor:
    enable-log: true
    queue-limit: 200
    delay: 30
    period: 120

// 從數(shù)據(jù)庫(kù)加載規(guī)則
@Component
public class DBRuleLoader implements RuleSource {
    @Override
    public String loadRules() {
        return ruleMapper.selectByApp("order-service");
    }
}