方案对比：
┌────────────────┬──────────┬──────────┬──────────┐
│ 方案           │ 实时性    │ 语义理解  │ 决策能力  │
├────────────────┼──────────┼──────────┼──────────┤
│ 点对点接口      │ 中        │ 无       │ 无       │
│ ESB 集成       │ 中-高     │ 弱       │ 无       │
│ 数据仓库       │ 低 (T+1)  │ 弱       │ 有限     │
│ Coomia DIP     │ 高 （秒级） │ 强       │ 内建     │
└────────────────┴──────────┴──────────┴──────────┘

ObjectType: Supplier
  description: "核心业务实体"
  properties:
    - id: string (PK)
    - name: string
    - type: enum
    - status: enum [Active, Inactive, Pending, Archived]
    - created_at: datetime
    - updated_at: datetime
    - created_by: string
    - priority: enum [Low, Normal, High, Critical]
    - metadata: dict
  computed_properties:
    - risk_score: float
    - health_index: float
    - trend: enum [Improving, Stable, Declining]

ObjectType: PurchaseOrder
  description: "辅助数据实体"
  properties:
    - id: string (PK)
    - source_system: string
    - timestamp: datetime
    - value: float
    - unit: string
    - quality_flag: enum [Good, Suspect, Bad]
    - dimensions: dict
  time_series: true
  retention: "365d"

ObjectType: Shipment
  description: "流程/事件实体"
  properties:
    - id: string (PK)
    - type: enum
    - status: enum [Draft, Submitted, InReview, Approved, Rejected, Completed]
    - requester: string
    - start_time: datetime
    - end_time: datetime
    - result: string
    - severity: enum [Low, Medium, High, Critical]

ObjectType: Warehouse
  description: "分析/决策实体"
  properties:
    - id: string (PK)
    - analysis_type: string
    - input_data: dict
    - result: dict
    - confidence: float [0-1]
    - model_version: string
    - generated_at: datetime

ObjectType: DemandForecast
  description: "关联/追踪实体"
  properties:
    - id: string (PK)
    - source_id: string
    - target_id: string
    - relation_type: string
    - weight: float
    - evidence: list[string]
    - discovered_at: datetime

Relations:
  - Supplier -> generates -> PurchaseOrder
    cardinality: 1:N
    description: "核心实体产生数据记录"

  - Supplier -> triggers -> Shipment
    cardinality: 1:N
    description: "核心实体触发流程/事件"

  - PurchaseOrder -> analyzedBy -> Warehouse
    cardinality: N:1
    description: "数据被分析引擎处理"

  - Warehouse -> impacts -> Supplier
    cardinality: N:M
    description: "分析结果反馈到核心实体"

  - Supplier -> linkedVia -> DemandForecast
    cardinality: N:M
    description: "实体间的关联追踪"

  - Shipment -> resolvedBy -> Warehouse
    cardinality: N:1
    description: "事件通过分析得到解决方案"

┌──────────────────────────────────────────────────────┐
│                    应用层                              │
│  ┌──────────┐  ┌──────────┐  ┌──────────┐           │
│  │ 业务看板  │  │ 分析报告  │  │ 移动端   │           │
│  └────┬─────┘  └────┬─────┘  └────┬─────┘           │
│       └─────────────┼─────────────┘                  │
│                     │                                 │
│  ┌──────────────────┴─────────────────────┐          │
│  │         Ontology 语义层                  │          │
│  │   Supplier --- PurchaseOrder --- Shipment         │
│  │       |           |           |                    │
│  │   Warehouse ------- DemandForecast                │
│  │   统一模型 / 统一查询 / 统一权限            │          │
│  └──────────────────┬─────────────────────┘          │
│                     │                                 │
│  ┌────────┐  ┌─────┴──────┐  ┌──────────┐           │
│  │Plane B │  │  Plane C   │  │ Plane D  │           │
│  │Control │  │  Data      │  │Reasoning │           │
│  └────────┘  └────────────┘  └──────────┘           │
│                     │                                 │
│  ┌──────────────────┴─────────────────────┐          │
│  │   数据接入： CDC | API | Stream | Batch  │          │
│  └────────────────────────────────────────┘          │
└──────────────────────────────────────────────────────┘

from ontology_sdk import OntoPlatform

platform = OntoPlatform()

# 1. 查询高优先级实体及关联数据
entities = (
    platform.ontology
    .object_type("Supplier")
    .filter(status="Active")
    .filter(priority__in=["High", "Critical"])
    .include("PurchaseOrder")
    .include("Shipment")
    .order_by("updated_at", ascending=False)
    .limit(100)
    .execute()
)

for entity in entities:
    print(f"实体： {entity.name} | 风险： {entity.risk_score}")

    # 检查异常数据
    recent_bad = [d for d in entity.purchaseorders
                  if d.quality_flag == "Bad"]
    if len(recent_bad) > 5:
        platform.actions.execute(
            "ExecuteWarehouse",
            target_id=entity.id,
            analysis_type="anomaly_detection",
            parameters={"window": "24h"}
        )

# 2. 订阅实时事件
def on_event(event):
    if event.severity == "Critical":
        platform.actions.execute(
            "Escalate",
            issue_id=event.entity_id,
            severity="Critical",
            escalate_to="on_call_manager"
        )

platform.subscribe(
    object_type="Shipment",
    events=["created", "severity_changed"],
    callback=on_event
)

# 3. What-if 场景分析
scenario = platform.reasoning.what_if(
    base_state=platform.ontology.snapshot(),
    changes=[
        {"type": "modify", "entity": "Supplier",
          "id": "E001", "field": "status", "value": "Inactive"},
    ],
    evaluate=["impact_on_shipment", "cascade_effects"]
)
print(f"影响范围： {scenario.affected_count} 个实体")

rules:
  - name: "高风险告警"
    trigger: Supplier.risk_score > 80
    actions:
      - alert: critical
      - action: Escalate(severity=Critical)

  - name: "趋势恶化"
    trigger: Supplier.trend == "Declining" AND priority in [High, Critical]
    actions:
      - alert: warning
      - action: ExecuteWarehouse(type=root_cause)

  - name: "数据质量"
    trigger: PurchaseOrder.quality_flag == "Bad" count > 10/hour
    actions:
      - alert: warning

  - name: "事件自动升级"
    trigger: Shipment.severity == "Critical"
    actions:
      - action: Escalate(severity=Critical)
      - notification: sms -> on_call

数据采集 --> 规则评估 --> 决策生成 --> Action执行 --> 反馈闭环
  CDC        Plane D     ML/Rules    自动/人工     效果追踪
  Stream     Ontology查询            通知/告警     模型更新

首年 ROI = (220 - 55) / 55 * 100% = 300%
三年 ROI = (220*3 - 55 - 15*2) / (55 + 15*2) * 100% = 676%