JangoEye - מבנה בסיס הנתונים

erDiagram
    networks {
        bigint id PK
        text name UK
        text deals_sheet_id
        timestamptz created_at
    }
    agents {
        bigint id PK
        text name
        timestamptz created_at
    }
    agent_accounts {
        bigint id PK
        bigint agent_id FK
        bigint network_id FK
        bigint telegram_user_id UK
        text phone_number
        text display_name
        text session_status
        timestamptz last_heartbeat
        timestamptz created_at
    }
    groups {
        bigint id PK
        bigint telegram_chat_id UK
        text name
        bigint network_id FK
        bigint company_id FK
        text category
        text folder_name
        int total_messages
        int outgoing_messages
        timestamptz last_message_at
    }
    messages {
        bigint id PK
        bigint telegram_message_id
        bigint chat_id
        bigint sender_id
        text direction
        text chat_type
        text text
        timestamptz timestamp
        bigint agent_account_id FK
        bigint attributed_group_id FK
        text attribution_method
    }
    group_members {
        bigint id PK
        bigint group_id FK
        bigint telegram_user_id
        boolean is_active
    }
    ingestion_health {
        bigint id PK
        bigint agent_account_id FK
        text event
        timestamptz timestamp
        jsonb details
    }
    daily_scores {
        bigint id PK
        bigint group_id FK
        date date
        int score
        text summary
    }
    weekly_reports {
        bigint id PK
        bigint agent_id FK
        date week_start
        date week_end
        text report_text
        jsonb highlights
        jsonb follow_ups
        jsonb concerns
    }
    companies {
        bigint id PK
        text name
        text_arr aliases
        text source
    }
    contacts {
        bigint id PK
        bigint company_id FK
        bigint telegram_user_id UK
        text display_name
    }
    deals {
        bigint id PK
        bigint network_id FK
        bigint agent_id FK
        bigint company_id FK
        text brand_name_raw
        numeric buy_price
        numeric sell_price
        numeric profit
    }
    group_assignments {
        bigint id PK
        bigint group_id FK
        bigint agent_id FK
    }

    agents ||--o{ agent_accounts : "has accounts"
    networks ||--o{ agent_accounts : "belongs to"
    agent_accounts ||--o{ messages : "captures"
    agent_accounts ||--o{ ingestion_health : "monitors"
    groups ||--o{ messages : "attributed to"
    groups ||--o{ group_members : "has members"
    groups ||--o{ daily_scores : "scored daily"
    networks ||--o{ groups : "organizes"
    companies ||--o{ groups : "owns"
    agents ||--o{ weekly_reports : "receives"
    agents ||--o{ deals : "closes"
    networks ||--o{ deals : "tracks"
    companies ||--o{ deals : "for"
    companies ||--o{ contacts : "employs"
    agents ||--o{ group_assignments : "assigned"
    groups ||--o{ group_assignments : "assigned to"
      

flowchart LR
    subgraph Telegram["Telegram"]
        TG["קבוצות והודעות פרטיות"]
    end

    subgraph Listener["listener.py\n(VPS ווינדוס)"]
        L1["קליטה בזמן אמת"]
        L2["מעקב עריכה/מחיקה"]
        L3["Heartbeat"]
    end

    subgraph Supabase["Supabase PostgreSQL"]
        M["messages\n317K"]
        G["groups\n837"]
        GM["group_members\n35"]
        IH["ingestion_health\n60K"]
    end

    subgraph DailyCron["קרונים יומיים"]
        FS["folder_sync.py\nסיווג תיקיות"]
        SC["score_conversations.py\nניקוד שיחות"]
    end

    subgraph WeeklyCron["קרון שבועי"]
        WR["generate_weekly_report.py\nדוח LLM"]
    end

    subgraph Analytics["טבלאות אנליטיקס"]
        DS["daily_scores\n580"]
        WRT["weekly_reports\n5"]
    end

    subgraph Dashboard["דשבורד אדמין\n(Vercel)"]
        D1["scores.html"]
        D2["status.html"]
        D3["progress.html"]
    end

    TG --> L1
    L1 --> M
    L1 --> G
    L1 --> GM
    L3 --> IH
    FS --> G
    SC --> DS
    M --> SC
    DS --> WR
    WR --> WRT
    M --> Dashboard
    DS --> D1
    IH --> D2
    WRT --> Dashboard