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

ObjectType: Product
  description: "产品实体"
  properties:
    - id: string (PK)
    - name: string
    - type: enum
    - status: enum [Active, Inactive, Pending, Archived]
    - priority: enum [Low, Normal, High, Critical]
    - metadata: dict
  computed_properties:
    - risk_score: float
    - health_index: float
    - trend: enum [Improving, Stable, Declining]

ObjectType: MaterialBatch
  description: "物料批次"
  properties:
    - id: string (PK)
    - source_system: string
    - timestamp: datetime
    - value: float
    - unit: string
    - quality_flag: enum [Good, Suspect, Bad]
  time_series: true
  retention: "365d"

ObjectType: ProcessStep
  description: "生产工序"
  properties:
    - id: string (PK)
    - type: enum
    - status: enum [Draft, Submitted, InReview, Approved, Rejected, Completed]
    - start_time: datetime
    - end_time: datetime
    - severity: enum [Low, Medium, High, Critical]

ObjectType: QualityEvent
  description: "质量事件"
  properties:
    - id: string (PK)
    - analysis_type: string
    - input_data: dict
    - result: dict
    - confidence: float [0-1]
    - model_version: string

ObjectType: LineageEdge
  description: "血缘关联边"
  properties:
    - id: string (PK)
    - source_id: string
    - target_id: string
    - relation_type: string
    - weight: float
    - evidence: list[string]

Relations:
  - Product -> generates -> MaterialBatch
    cardinality: 1:N
    description: "产品关联物料批次"

  - Product -> triggers -> ProcessStep
    cardinality: 1:N
    description: "产品经历生产工序"

  - MaterialBatch -> analyzedBy -> QualityEvent
    cardinality: N:1
    description: "物料批次被质量分析"

  - QualityEvent -> impacts -> Product
    cardinality: N:M
    description: "质量事件影响产品"

  - Product -> linkedVia -> LineageEdge
    cardinality: N:M
    description: "产品间的血缘追踪"

  - ProcessStep -> resolvedBy -> QualityEvent
    cardinality: N:1
    description: "工序问题通过质量分析解决"

┌──────────────────────────────────────────────────────┐
│                    应用层                              │
│  ┌──────────┐  ┌──────────┐  ┌──────────┐           │
│  │ 质量看板  │  │ 追溯报告  │  │ 移动端   │           │
│  └────┬─────┘  └────┬─────┘  └────┬─────┘           │
│       └─────────────┼─────────────┘                  │
│                     │                                 │
│  ┌──────────────────┴─────────────────────┐          │
│  │         Ontology 语义层                  │          │
│  │   Product --- MaterialBatch --- ProcessStep       │
│  │       |           |           |                    │
│  │   QualityEvent ------- LineageEdge                │
│  │   统一模型 / 统一查询 / 统一权限                      │
│  └──────────────────┬─────────────────────┘          │
│                     │                                 │
│  ┌──────────────────┴─────────────────────┐          │
│  │   数据接入： CDC | API | Stream | Batch  │          │
│  └────────────────────────────────────────┘          │
└──────────────────────────────────────────────────────┘

from ontology_sdk import OntoPlatform

platform = OntoPlatform()

# 全链路质量追溯：从产品追溯到原材料和工序
entities = (
    platform.ontology
    .object_type("Product")
    .filter(status="Active")
    .filter(priority__in=["High", "Critical"])
    .include("MaterialBatch")
    .include("ProcessStep")
    .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.materialbatchs
                  if d.quality_flag == "Bad"]
    if len(recent_bad) > 5:
        platform.actions.execute(
            "ExecuteQualityEvent",
            target_id=entity.id,
            analysis_type="root_cause_analysis",
            parameters={"window": "24h"}
        )

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

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

  - name: "物料批次异常"
    trigger: MaterialBatch.quality_flag == "Bad" count > 10/hour
    actions:
      - alert: warning

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

from intelligence_plane.models import PredictionModel
from datetime import timedelta

class QualityEventModel(PredictionModel):
    def __init__(self):
        super().__init__(
            name="qualityevent_v2",
            input_type="Product",
            output_type="QualityEvent"
        )

    def predict(self, entity, context):
        history = (
            context.ontology.object_type("MaterialBatch")
            .filter(source_id=entity.id)
            .filter(timestamp__gte=context.now - timedelta(days=90))
            .order_by("timestamp")
            .execute()
        )
        features = self.extract_features(history)
        prediction = self.model.predict(features)
        return {
            "level": prediction["level"],
            "confidence": prediction["confidence"],
            "factors": prediction["contributing_factors"],
            "actions": prediction["recommended_actions"]
        }

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