// Drools: 规则定义
rule "High-Risk Transaction Alert"
    when
        $t : Transaction(amount > 100000)
        $c : Customer(customerId == $t.customerId, creditScore < 600)
    then
        insert(new Alert("HIGH_RISK", $t.getTransactionId(),
            "Large transaction from low-credit customer"));
        $t.setRiskLevel("HIGH");
        update($t);
end

# coomia-dip: 规则作为 Ontology Action
@action(
    name="high_risk_transaction_alert",
    object_type="Transaction",
    trigger="on_create",
)
async def high_risk_alert(transaction: Transaction, ctx: ActionContext) -> None:
    """High-risk transaction alert — data directly from Ontology."""
    if transaction.amount > 100000:
        # 直接通过 Ontology 关系获取客户数据，无需手动传入
        customer = await ctx.ontology.get_linked(
            transaction, "belongs_to", "Customer"
        )
        if customer.credit_score < 600:
            await ctx.ontology.create("Alert", {
                "level": "HIGH_RISK",
                "transaction_id": transaction.id,
                "message": "Large transaction from low-credit customer",
            })
            await ctx.ontology.update(transaction, {"risk_level": "HIGH"})

<!-- Camunda: BPMN 流程定义（XML） -->
<process id="order-process" name="Order Processing">
    <startEvent id="start"/>
    <serviceTask id="validate" name="Validate Order"/>
    <exclusiveGateway id="decision"/>
    <serviceTask id="approve" name="Auto Approve"/>
    <userTask id="manual-review" name="Manual Review"/>
    <serviceTask id="fulfill" name="Fulfill Order"/>
    <endEvent id="end"/>

    <sequenceFlow sourceRef="start" targetRef="validate"/>
    <sequenceFlow sourceRef="validate" targetRef="decision"/>
    <sequenceFlow sourceRef="decision" targetRef="approve">
        <conditionExpression>${amount &lt; 10000}</conditionExpression>
    </sequenceFlow>
    <sequenceFlow sourceRef="decision" targetRef="manual-review">
        <conditionExpression>${amount >= 10000}</conditionExpression>
    </sequenceFlow>
</process>

# coomia-dip: 状态机 + Saga（代码 + 声明式）
order_state_machine = StateMachineDefinition(
    object_type="Order",
    initial_state="created",
    states=[
        State("created", "已创建", "", is_initial=True),
        State("validating", "验证中", ""),
        State("pending_approval", "待审批", ""),
        State("approved", "已批准", ""),
        State("fulfilling", "履行中", ""),
        State("completed", "已完成", "", is_terminal=True),
        State("rejected", "已拒绝", "", is_terminal=True),
    ],
    transitions=[
        Transition("validate", "created", "validating", "submit",
                   side_effects=["validate_order"]),
        Transition("auto_approve", "validating", "approved", "auto_approve",
                   guard="amount_below_threshold"),
        Transition("request_review", "validating", "pending_approval", "request_review",
                   guard="amount_above_threshold"),
        Transition("approve", "pending_approval", "approved", "approve",
                   required_permissions=["order.approve"]),
        Transition("reject", "pending_approval", "rejected", "reject"),
        Transition("fulfill", "approved", "fulfilling", "fulfill",
                   side_effects=["trigger_fulfillment_saga"]),
        Transition("complete", "fulfilling", "completed", "complete"),
    ],
)

Drools/Camunda 集成链路：
应用代码 → 数据查询 → 数据转换 → 传入引擎 → 执行规则 → 获取结果 → 写回数据库

coomia-dip 执行链路：
Ontology Action 触发 → 规则引擎自动获取 Ontology 数据 → 执行 → 结果自动写入

可以将 Drools/Camunda 作为 coomia-dip Intelligence Layer 的执行后端：
coomia-dip Ontology Action → Intelligence Layer → Drools 执行复杂规则
coomia-dip 状态机 Side Effect → Camunda 执行 BPMN 流程