Data Model

Tenant
└── Pipeline
    └── Segment
        ├── Test Station
        ├── Rectifier
        └── Equipment

class Tenant:
    id: UUID
    name: str
    domain: str
    settings: dict
    created_at: datetime

class Pipeline:
    id: UUID
    tenant_id: UUID
    name: str
    external_id: str  # GIS system reference
    operator: str
    product_type: str  # gas, oil, water
    geometry: LineString  # PostGIS geometry
    attributes: dict

class Segment:
    id: UUID
    pipeline_id: UUID
    name: str
    external_id: str
    start_mp: float  # Mile post start
    end_mp: float    # Mile post end
    diameter_inches: float
    wall_thickness: float
    material: str
    coating_type: str
    install_date: date
    geometry: LineString
    attributes: dict

class TestStation:
    id: UUID
    segment_id: UUID
    name: str
    external_id: str
    station_type: str  # standard, reference, gradient
    mile_post: float
    geometry: Point
    attributes: dict

class Rectifier:
    id: UUID
    segment_id: UUID
    name: str
    external_id: str
    manufacturer: str
    model: str
    rated_output_amps: float
    rated_output_volts: float
    install_date: date
    geometry: Point
    attributes: dict

class Measurement:
    id: UUID
    asset_id: UUID
    asset_type: str
    measurement_type: str
    value: float
    unit: str
    recorded_at: datetime
    recorded_by: UUID
    source: str  # manual, automated, import
    quality: str  # good, suspect, bad
    metadata: dict

// Protection relationship
(rectifier:Asset)-[:PROTECTS]->(segment:Asset)

// Monitoring relationship
(test_station:Asset)-[:MONITORS]->(segment:Asset)

// Location relationship
(segment:Asset)-[:PART_OF]->(pipeline:Asset)

// Interference relationship
(segment:Asset)-[:INTERFERES_WITH]->(other_segment:Asset)

MATCH (a:Asset)-[:PROTECTS]->(s:Asset {id: $segment_id})
RETURN a

MATCH (r:Asset {id: $rectifier_id})-[:PROTECTS*1..3]->(affected:Asset)
RETURN affected

class Event:
    id: UUID
    asset_id: UUID
    event_type: str
    severity: str  # info, warning, critical
    title: str
    description: str
    occurred_at: datetime
    resolved_at: datetime
    metadata: dict

class SoilChemistry:
    asset_id: UUID
    ph: float
    chloride_ppm: float
    sulfate_ppm: float
    resistivity: float
    moisture_percent: float
    redox_potential: float
    sample_date: date
    sample_location: Point

class GeologyFactor:
    asset_id: UUID
    soil_type: str
    corrosivity_class: str
    drainage_rating: str
    rock_presence: bool
    groundwater_depth: float

class InterferenceFactor:
    asset_id: UUID
    interference_type: str  # AC, DC, telluric
    source_description: str
    distance_to_source: float
    measured_current: float
    mitigation_installed: bool