Solution Comparison:
┌──────────────────┬───────────┬───────────┬────────────┐
│ Solution         │ Real-time │ Semantics │ Decisions  │
├──────────────────┼───────────┼───────────┼────────────┤
│ Point-to-Point   │ Medium    │ None      │ None       │
│ ESB Integration  │ Med-High  │ Weak      │ None       │
│ Data Warehouse   │ Low (T+1) │ Weak      │ Limited    │
│ Coomia DIP       │ High (sec)│ Strong    │ Built-in   │
└──────────────────┴───────────┴───────────┴────────────┘

ObjectType: Supplier
  description: "Core business entity"
  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: Contract
  description: "Supporting data entity"
  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: DeliveryPerformance
  description: "Process/event entity"
  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: QualityScore
  description: "Analysis/decision entity"
  properties:
    - id: string (PK)
    - analysis_type: string
    - input_data: dict
    - result: dict
    - confidence: float [0-1]
    - model_version: string
    - generated_at: datetime

ObjectType: RiskProfile
  description: "Association/tracking entity"
  properties:
    - id: string (PK)
    - source_id: string
    - target_id: string
    - relation_type: string
    - weight: float
    - evidence: list[string]
    - discovered_at: datetime

Relations:
  - Supplier -> generates -> Contract
    cardinality: 1:N
    description: "Core entity generates data records"

  - Supplier -> triggers -> DeliveryPerformance
    cardinality: 1:N
    description: "Core entity triggers processes/events"

  - Contract -> analyzedBy -> QualityScore
    cardinality: N:1
    description: "Data processed by analysis engine"

  - QualityScore -> impacts -> Supplier
    cardinality: N:M
    description: "Analysis results feed back to core entities"

  - Supplier -> linkedVia -> RiskProfile
    cardinality: N:M
    description: "Inter-entity association tracking"

  - DeliveryPerformance -> resolvedBy -> QualityScore
    cardinality: N:1
    description: "Events resolved through analysis"

┌───────────────────────────────────────────────────────┐
│                   Application Layer                    │
│  ┌───────────┐  ┌────────────┐  ┌───────────┐        │
│  │ Dashboard  │  │  Reports   │  │  Mobile   │        │
│  └────┬──────┘  └─────┬──────┘  └────┬──────┘        │
│       └───────────────┼──────────────┘                │
│                       │                                │
│  ┌────────────────────┴────────────────────┐          │
│  │          Ontology Semantic Layer          │          │
│  │   Supplier --- Contract --- DeliveryPerformance   │
│  │       |           |           |                     │
│  │   QualityScore ------- RiskProfile                │
│  │   Unified Model / Query / RBAC            │          │
│  └────────────────────┬────────────────────┘          │
│                       │                                │
│  ┌─────────┐  ┌──────┴───────┐  ┌───────────┐        │
│  │ Plane B │  │   Plane C    │  │  Plane D  │        │
│  │ Control │  │   Data       │  │ Reasoning │        │
│  └─────────┘  └──────────────┘  └───────────┘        │
│                       │                                │
│  ┌────────────────────┴────────────────────┐          │
│  │   Data Ingestion: CDC|API|Stream|Batch   │          │
│  └─────────────────────────────────────────┘          │
└───────────────────────────────────────────────────────┘

from ontology_sdk import OntoPlatform

platform = OntoPlatform()

# 1. Query high-priority entities with associations
entities = (
    platform.ontology
    .object_type("Supplier")
    .filter(status="Active")
    .filter(priority__in=["High", "Critical"])
    .include("Contract")
    .include("DeliveryPerformance")
    .order_by("updated_at", ascending=False)
    .limit(100)
    .execute()
)

for entity in entities:
    print(f"Entity: {entity.name} | Risk: {entity.risk_score}")

    bad_data = [d for d in entity.contracts
                if d.quality_flag == "Bad"]
    if len(bad_data) > 5:
        platform.actions.execute(
            "ExecuteQualityScore",
            target_id=entity.id,
            analysis_type="anomaly_detection",
            parameters={"window": "24h"}
        )

# 2. Subscribe to real-time events
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="DeliveryPerformance",
    events=["created", "severity_changed"],
    callback=on_event
)

# 3. What-if scenario analysis
scenario = platform.reasoning.what_if(
    base_state=platform.ontology.snapshot(),
    changes=[
        {"type": "modify", "entity": "Supplier",
          "id": "E001", "field": "status", "value": "Inactive"},
    ],
    evaluate=["impact_on_deliveryperformance", "cascade_effects"]
)
print(f"Impact scope: {scenario.affected_count} entities")

rules:
  - name: "High Risk Alert"
    trigger: Supplier.risk_score > 80
    actions:
      - alert: critical
      - action: Escalate(severity=Critical)

  - name: "Trend Deterioration"
    trigger: Supplier.trend == "Declining" AND priority in [High, Critical]
    actions:
      - alert: warning
      - action: ExecuteQualityScore(type=root_cause)

  - name: "Data Quality"
    trigger: Contract.quality_flag == "Bad" count > 10/hour
    actions:
      - alert: warning

  - name: "Auto-Escalation"
    trigger: DeliveryPerformance.severity == "Critical"
    actions:
      - action: Escalate(severity=Critical)
      - notification: sms -> on_call

Data Ingestion --> Rule Evaluation --> Decision --> Action Execution --> Feedback
  CDC              Plane D            ML/Rules    Auto/Manual          Tracking
  Stream           Ontology Query                 Notification         Model Update

Year 1 ROI = (340 - 83) / 83 * 100% = 310%
3-Year ROI = (340*3 - 83 - 20*2) / (83 + 20*2) * 100% = 729%