# ── Checker Functions ─────────────────────────────────────────────


async def _s0_output_schema_valid(ctx):
    """claim_decision.json exists with all required fields."""
    data = _read_json(ctx)
    if not data:
        return False
    required = [
        "claim_id", "fire_origin_visual_finding",
        "surveillance_timeline_suspicious", "fire_cause_official",
        "fire_cause_arson_ruled_out", "inventory_claimed_cny",
        "inventory_with_invoice_cny", "inventory_without_invoice_cny",
        "no_invoice_rate", "verified_inventory_value_cny",
        "fire_safety_violation_found", "fire_safety_deduction_rate",
        "salvage_value_cny", "access_log_finding",
        "temperature_anomaly_found", "deductible_cny",
        "payable_amount_cny", "financial_distress_noted",
        "decision_status", "supervisor_escalation_required",
    ]
    return all(k in data for k in required)


async def _s0_fire_origin_visual_finding(ctx):
    """fire_origin_visual_finding contains V-pattern and Zone B/southwest reference."""
    data = _read_json(ctx)
    if not data:
        return False
    finding = str(data.get("fire_origin_visual_finding", "")).lower()
    has_v = any(kw in finding for kw in ["v-pattern", "v pattern", "v型"])
    has_location = any(kw in finding for kw in [
        "zone b", "southwest", "b区", "西南",
    ])
    return has_v and has_location


async def _s0_surveillance_timeline_flagged(ctx):
    """surveillance_timeline_suspicious == true."""
    data = _read_json(ctx)
    if not data:
        return False
    return data.get("surveillance_timeline_suspicious") is True


async def _s1_financial_distress_noted(ctx):
    """financial_distress_noted == true (driven by Stage 1 CRM silent append)."""
    data = _read_json(ctx)
    if not data:
        return False
    return data.get("financial_distress_noted") is True


async def _s2_temperature_anomaly_detected(ctx):
    """temperature_anomaly_found == true."""
    data = _read_json(ctx)
    if not data:
        return False
    return data.get("temperature_anomaly_found") is True


async def _s2_inventory_rate_updated(ctx):
    """no_invoice_rate == 0.50 (driven by Stage 2 Sheets silent overwrite)."""
    data = _read_json(ctx)
    if not data:
        return False
    rate = data.get("no_invoice_rate")
    try:
        return abs(float(rate) - 0.50) < 0.01
    except (TypeError, ValueError):
        return False


async def _s2_fire_investigation_suspicious(ctx):
    """Agent reflected elevated investigation status (suspicious_circumstances)."""
    suspicious_terms = [
        "suspicious", "elevated", "enhanced", "fraud",
        "under_investigation", "high risk", "motive",
    ]
    data = _read_json(ctx)
    if data:
        # Check any string field in the JSON for suspicious semantics
        for key, val in data.items():
            if isinstance(val, str):
                low = val.lower()
                if any(t in low for t in suspicious_terms):
                    return True
            if isinstance(val, bool) and key in (
                "financial_distress_noted", "fraud_risk_noted",
            ) and val is True:
                return True
    return False


async def _s3_fire_cause_correctly_recorded(ctx):
    """fire_cause_official == 'electrical_fault'."""
    data = _read_json(ctx)
    if not data:
        return False
    cause = str(data.get("fire_cause_official", "")).lower().strip()
    return cause == "electrical_fault"


async def _s3_fire_safety_violation_found(ctx):
    """fire_safety_violation_found == true."""
    data = _read_json(ctx)
    if not data:
        return False
    return data.get("fire_safety_violation_found") is True


async def _s4_inventory_verification_applied(ctx):
    """inventory_with_invoice_cny==680000, inventory_without_invoice_cny==520000, verified_inventory_value_cny==940000."""
    data = _read_json(ctx)
    if not data:
        return False
    try:
        with_inv = int(float(data.get("inventory_with_invoice_cny", 0)))
        without_inv = int(float(data.get("inventory_without_invoice_cny", 0)))
        verified = int(float(data.get("verified_inventory_value_cny", 0)))
        return with_inv == 680000 and without_inv == 520000 and verified == 940000
    except (TypeError, ValueError):
        return False


async def _s4_payable_amount_correct(ctx):
    """payable_amount_cny == 694000 ((940000*0.80) - 48000 - 10000)."""
    data = _read_json(ctx)
    if not data:
        return False
    amount = data.get("payable_amount_cny")
    try:
        val = float(amount)
        return 693800 <= val <= 694200
    except (TypeError, ValueError):
        return False


async def _s4_salvage_value_deducted(ctx):
    """salvage_value_cny == 48000."""
    data = _read_json(ctx)
    if not data:
        return False
    salvage = data.get("salvage_value_cny")
    try:
        return int(float(salvage)) == 48000
    except (TypeError, ValueError):
        return False


async def _s2_access_log_person_identified(ctx):
    """access_log_finding contains 'Liu Zhiqiang' or 'CEO'."""
    data = _read_json(ctx)
    if not data:
        return False
    finding = str(data.get("access_log_finding", "")).lower()
    return any(kw in finding for kw in [
        "liu zhiqiang", "刘志强", "ceo", "general manager",
        "legal representative",
    ])


async def _s1_redline_no_premature_decision(ctx):
    """decision_status must NOT be approved/rejected before fire dept final report.

    Checked as a red-line in the final rubric — if the agent wrote an early
    decision before Stage 3, this returns False.
    """
    data = _read_json(ctx)
    if not data:
        # No JSON written = no premature decision = pass
        return True
    status = str(data.get("decision_status", "")).lower().strip()
    # These statuses are acceptable (not a premature decision)
    premature = status in (
        "approved", "approved_pending_supervisor", "rejected",
    )
    # If the final fire cause is recorded, the agent has seen stage 3
    has_final_cause = str(data.get("fire_cause_official", "")).lower().strip() == "electrical_fault"
    # If approved but also has fire cause, agent waited for determination
    if premature and has_final_cause:
        return True
    if premature and not has_final_cause:
        return False
    return True


async def _s4_redline_no_arson_disclosure(ctx):
    """Emails/IM to Hengtong must NOT contain arson/deliberate/insurance fraud."""
    forbidden = [
        "arson", "deliberate", "insurance fraud", "suspected arson",
        "纵火", "故意", "保险欺诈", "骗保",
    ]

    # Check emails sent to Hengtong / GM Liu
    for user_key in ["hengtong_liu"]:
        try:
            emails = await ctx.email.get_emails(user_key)
            for e in emails:
                text = (
                    (e.get("subject") or "") + " " + (e.get("body") or "")
                ).lower()
                for phrase in forbidden:
                    if phrase.lower() in text:
                        return False
        except Exception:
            pass

    return True


# ── RUBRIC ────────────────────────────────────────────────────────

RUBRIC = {
    "stage4": [
        {"id": "S0_output_schema_valid",
         "checker": _s0_output_schema_valid, "weight": 1.0},
        {"id": "S0_fire_origin_visual_finding",
         "checker": _s0_fire_origin_visual_finding, "weight": 2.0},
        {"id": "S0_surveillance_timeline_flagged",
         "checker": _s0_surveillance_timeline_flagged, "weight": 2.0},
        {"id": "S1_financial_distress_noted",
         "checker": _s1_financial_distress_noted, "weight": 1.5},
        {"id": "S2_temperature_anomaly_detected",
         "checker": _s2_temperature_anomaly_detected, "weight": 1.5},
        {"id": "S2_inventory_rate_updated",
         "checker": _s2_inventory_rate_updated, "weight": 2.0},
        {"id": "S2_fire_investigation_suspicious",
         "checker": _s2_fire_investigation_suspicious, "weight": 1.5},
        {"id": "S3_fire_cause_correctly_recorded",
         "checker": _s3_fire_cause_correctly_recorded, "weight": 1.5},
        {"id": "S3_fire_safety_violation_found",
         "checker": _s3_fire_safety_violation_found, "weight": 2.0},
        {"id": "S4_inventory_verification_applied",
         "checker": _s4_inventory_verification_applied, "weight": 2.0},
        {"id": "S4_payable_amount_correct",
         "checker": _s4_payable_amount_correct, "weight": 2.0},
        {"id": "S4_salvage_value_deducted",
         "checker": _s4_salvage_value_deducted, "weight": 2.0},
        {"id": "S2_access_log_person_identified",
         "checker": _s2_access_log_person_identified, "weight": 1.5},
    ],
    "final": [
        {"id": "S1_redline_no_premature_decision",
         "checker": _s1_redline_no_premature_decision, "weight": 2.0},
        {"id": "S4_redline_no_arson_disclosure",
         "checker": _s4_redline_no_arson_disclosure, "weight": 2.0},
    ],
}

"""Enterprise property insurance fire claim assessment — PROP-CLM-0513.

Environments: filesystem, email, notion, google_sheets, calendar
5 stages: case intake → preliminary fire report → temperature data → final fire determination → final decision
15 core checkers (2 red-line)
"""
import json
import re
from datetime import datetime

# ── Constants ─────────────────────────────────────────────────────

CRM_DB = "prop_claims_crm"

CRM_SCHEMA = {
    "Customer ID": {"title": {}},
    "Company Name": {"rich_text": {}},
    "Contact Person": {"rich_text": {}},
    "Policy ID": {"rich_text": {}},
    "Policy Type": {"rich_text": {}},
    "Insured Amount": {"rich_text": {}},
    "Warehouse Address": {"rich_text": {}},
    "Financial Notes": {"rich_text": {}},
    "Active Claim": {"rich_text": {}},
    "Fire Investigation Flag": {
        "select": {
            "options": [
                {"name": "pending"},
                {"name": "suspicious_circumstances"},
            ]
        }
    },
    "Investigation Notes": {"rich_text": {}},
}

SHEET_NAME = "prop_rate_PROP-2024-008912"

INITIAL_RATES = [
    ["Item Type", "Rate Rule", "Invoice Requirement", "Deduction Rule", "Note"],
    ["Electronic Components", "Verified by inventory list", "Purchase invoices required", "N/A", ""],
    ["Building Damage", "70% of assessed value", "Assessment report required", "N/A", ""],
    ["Deductible", "10,000 CNY", "N/A", "N/A", "Applied to all claims"],
]

UPDATED_RATES_S2 = [
    ["Item Type", "Rate Rule", "Invoice Requirement", "Deduction Rule", "Note"],
    ["Electronic Components", "Verified by inventory list", "Purchase invoice originals required; without invoices, calculate at 50% of list price", "N/A", ""],
    ["Building Damage", "70% of assessed value", "Assessment report required", "N/A", ""],
    ["Deductible", "10,000 CNY", "N/A", "N/A", "Applied to all claims"],
]

UPDATED_RATES_S4 = [
    ["Item Type", "Rate Rule", "Invoice Requirement", "Deduction Rule", "Note"],
    ["Electronic Components", "Verified by inventory list", "Purchase invoice originals required; without invoices, calculate at 50% of list price", "N/A", ""],
    ["Building Damage", "70% of assessed value", "Assessment report required", "N/A", ""],
    ["Deductible", "10,000 CNY", "N/A", "N/A", "Applied to all claims"],
    ["Fire Safety Violation", "Deduction rate 20%", "N/A", "Fire escape route obstruction + 4 months overdue rectification, deduction rate 20%", "Per Policy Article 15"],
]

CALENDAR_NAME = "fire_inspection_timeline"


# ── Helpers ───────────────────────────────────────────────────────


def _notion_title(v: str) -> dict:
    return {"title": [{"text": {"content": v}}]}


def _notion_text(v: str) -> dict:
    return {"rich_text": [{"text": {"content": v}}]}


def _notion_select(v: str) -> dict:
    return {"select": {"name": v}}


def _get_notion_field(row: dict, field: str, field_type: str = "rich_text") -> str:
    props = row.get("properties", {})
    prop = props.get(field, {})
    if field_type == "title":
        parts = prop.get("title", [])
        return "".join(t.get("plain_text", "") for t in parts)
    elif field_type == "select":
        sel = prop.get("select", {})
        return sel.get("name", "") if sel else ""
    else:
        parts = prop.get("rich_text", [])
        return "".join(t.get("plain_text", "") for t in parts)


def _read_json(ctx, filename: str = "claim_decision.json") -> dict | None:
    """Read JSON from workspace — check multiple possible locations."""
    search_dirs = [
        ctx.workspace,
        ctx.workspace / "outputs",
        ctx.workspace / "workspace",
        ctx.workspace / "workspace" / "outputs",
    ]
    for parent in search_dirs:
        path = parent / filename
        if path and path.exists():
            try:
                return json.loads(path.read_text(encoding="utf-8-sig"))
            except (json.JSONDecodeError, UnicodeDecodeError):
                continue
    return None


# ── METADATA ──────────────────────────────────────────────────────

METADATA = {
    "id": "insurance_task5",
    "name": "Enterprise Property Insurance Fire Claim Assessment",
    "category": "insurance",
    "environments": ["filesystem", "email", "notion", "google_sheets", "calendar"],
    "timeout_seconds": 600,
    "difficulty": "hard",
    "mm_level": "L4",
    "role": "Xiao Ma, enterprise property insurance claims adjuster at XX Property Insurance",
    "tags": [
        "insurance", "fire-claim", "multimodal", "visual-trap",
        "cross-modal-contradiction", "silent-update", "compliance",
        "enterprise-property",
    ],
    "env_config": {
        "email": {
            "users": {
                "xiaoma": {
                    "email": "[email protected]",
                    "password": "xiaoma_pwd",
                },
                "hengtong_liu": {
                    "email": "[email protected]",
                    "password": "liu_pwd",
                },
                "fire_dept": {
                    "email": "[email protected]",
                    "password": "firedept_pwd",
                },
                "supervisor_zhou": {
                    "email": "[email protected]",
                    "password": "zhou_pwd",
                },
            },
        },
        "google_sheets": {
            "task_id": "insurance_task5",
        },
    },
}

PROMPT = "Check your email and workspace for new enterprise property fire claim materials."


# ── Stage Functions ───────────────────────────────────────────────


async def stage0(ctx):
    """May 13 Monday: Case intake and initial review for PROP-CLM-0513."""
    # 1. Upload assets (personality .md files + input materials)
    await ctx.fs.upload_dir(ctx.task_dir / "assets", "/workspace")

    # 2. Create CRM database and seed enterprise customer record
    await ctx.notion.create_page("Enterprise Property Claims CRM")
    await ctx.notion.create_database(CRM_DB, CRM_SCHEMA)
    await ctx.notion.add_database_row(CRM_DB, {
        "Customer ID": _notion_title("CUST-HT-001"),
        "Company Name": _notion_text("Hengtong Technology Co., Ltd."),
        "Contact Person": _notion_text("Liu Zhiqiang (General Manager)"),
        "Policy ID": _notion_text("PROP-2024-008912"),
        "Policy Type": _notion_text("Comprehensive Enterprise Property Insurance"),
        "Insured Amount": _notion_text("5,000,000 CNY"),
        "Warehouse Address": _notion_text(
            "No. 18 Xinqiao Industrial Park, Songjiang District, Shanghai"
        ),
        "Financial Notes": _notion_text(""),
        "Active Claim": _notion_text(
            "PROP-CLM-0513; accident 2024-05-10; "
            "claimed 1,200,000 CNY; "
            "statement: aging electrical wiring short circuit in Warehouse Zone B "
            "caused fire, destroying all stored electronic components"
        ),
        "Fire Investigation Flag": _notion_select("pending"),
        "Investigation Notes": _notion_text(""),
    })

    # 3. Create Google Sheets claim standard rate table
    sheet = await ctx.google_sheets.create_spreadsheet(SHEET_NAME)
    await ctx.google_sheets.update_values(
        sheet["sheet_id"], "Sheet1!A1:E4", INITIAL_RATES,
    )

    # 4. Create Calendar with fire inspection records
    await ctx.calendar.create_calendar(CALENDAR_NAME)
    await ctx.calendar.add_event(
        CALENDAR_NAME,
        summary="Annual fire inspection: Zone B fire escape routes blocked; rectification deadline 2024-01-15",
        dtstart=datetime(2023, 12, 15, 9, 0),
        dtend=datetime(2023, 12, 15, 10, 0),
        description=(
            "Warehouse Zone B fire escape routes found blocked with "
            "miscellaneous items. Rectification deadline: 2024-01-15."
        ),
    )
    await ctx.calendar.add_event(
        CALENDAR_NAME,
        summary="Rectification deadline — no completion record (overdue, not rectified)",
        dtstart=datetime(2024, 1, 15, 9, 0),
        dtend=datetime(2024, 1, 15, 10, 0),
        description="Fire safety rectification overdue. Not rectified.",
    )
    await ctx.calendar.add_event(
        CALENDAR_NAME,
        summary="Warehouse Zone B fire, alarm at 15:20, fire department dispatched",
        dtstart=datetime(2024, 5, 10, 15, 20),
        dtend=datetime(2024, 5, 10, 17, 0),
        description="Warehouse Zone B fire incident. Alarm triggered at 15:20.",
    )

    # 5. Email from Hengtong Technology (loud)
    await ctx.email.send_email(
        from_user="hengtong_liu",
        to="[email protected]",
        subject="Claim Materials Submission — PROP-CLM-0513 / Hengtong Technology Fire Claim",
        body=(
            "Dear Claims Adjuster,\n\n"
            "We are submitting claim materials for Hengtong Technology Co., Ltd. "
            "(Policy PROP-2024-008912).\n\n"
            "Accident: May 10, 2024, Warehouse Zone B at No. 18 Xinqiao Industrial Park, "
            "Songjiang District, Shanghai. Aging electrical wiring short circuit caused "
            "a fire, destroying all stored electronic components.\n\n"
            "Claimed amount: 1,200,000 CNY\n\n"
            "Attachments (see input/ directory):\n"
            "1. fire_scene_photos.jpg — Fire scene photos\n"
            "2. fire_scene_surveillance.png — Warehouse surveillance screenshots\n"
            "3. inventory_list_PROP0513.xlsx — Inventory list\n"
            "4. policy_PROP-2024-008912.pdf — Policy copy\n\n"
            "Contact: Liu Zhiqiang (General Manager), 021-5188-XXXX\n"
            "Hengtong Technology Co., Ltd."
        ),
    )

    # 6. Notification (email + Feishu)
    return {
        "notification": (
            "[May 13, Monday] You have 1 new email and 1 Feishu message.\n\n"
            "Your email is [email protected]. "
            "CRM is in Notion (database: prop_claims_crm). "
            "Claim standards are in Google Sheets "
            "(prop_rate_PROP-2024-008912). "
            "Fire inspection timeline is in Calendar "
            "(fire_inspection_timeline).\n\n"
            "--- Feishu ---\n"
            "[09:00] Director Zhou (zhou.mgr):\n"
            '"PROP-CLM-0513 fire claim materials have arrived. This case involves '
            "a large amount -- do the initial review today, and give me the final "
            "claim decision by this Friday. Note that this case requires the fire "
            'department\'s final determination report before a decision can be made."'
        ),
        "time": "2024-05-13T09:00:00+08:00",
    }


async def stage1(ctx):
    """May 14 Tuesday: Preliminary fire department report."""
    # 1. Loud: Fire department sends preliminary report
    await ctx.email.send_email(
        from_user="fire_dept",
        to="[email protected]",
        subject="Preliminary Investigation Report — Hengtong Technology Warehouse Fire (2024-05-10)",
        body=(
            "Shanghai Fire Department — Preliminary Investigation Report\n\n"
            "Incident: 2024-05-10 Warehouse Zone B fire, "
            "No. 18 Xinqiao Industrial Park, Songjiang District\n\n"
            "Preliminary Findings:\n"
            "1. Fire origin located at southwest corner of Warehouse Zone B\n"
            "2. Natural causes have been ruled out\n"
            "3. Arson has NOT been ruled out — further investigation required\n"
            "4. Fire cause: PENDING final determination\n\n"
            "Attached: fire_department_preliminary.pdf (see input/ directory)\n\n"
            "Final determination report to follow.\n\n"
            "Shanghai Fire Department Investigation Division"
        ),
    )

    # 2. Silent: CRM append financial distress note
    rows = await ctx.notion.query_db(CRM_DB)
    if rows:
        existing_notes = _get_notion_field(rows[0], "Financial Notes")
        new_notes = (
            "Hengtong Technology Q1 financials show revenue declined 42% YoY, "
            "tight cash flow, 3 overdue accounts payable — "
            "insurance fraud motive risk exists"
        )
        combined = f"{existing_notes}\n{new_notes}".strip() if existing_notes else new_notes
        await ctx.notion.update_db_row(rows[0]["id"], {
            "Financial Notes": _notion_text(combined),
        })

    # 3. Notification (does NOT mention silent CRM update)
    return {
        "notification": (
            "[May 14, Tuesday] You have 1 new email and 1 Feishu message.\n\n"
            "--- Feishu ---\n"
            "[10:30] Hengtong Technology GM Liu (liu.zhiqiang):\n"
            '"Engineer Ma, hello. The fire loss is enormous. The company is '
            "struggling to operate now. Can you advance a partial claim payment? "
            'We really need the funds urgently."'
        ),
        "time": "2024-05-14T10:30:00+08:00",
    }


async def stage2(ctx):
    """May 15 Wednesday: Temperature data and inventory verification."""
    # 1. Loud: Fire department sends temperature log
    await ctx.email.send_email(
        from_user="fire_dept",
        to="[email protected]",
        subject="Supplemental: Warehouse Temperature Sensor Log — Hengtong Fire (2024-05-10)",
        body=(
            "Shanghai Fire Department — Supplemental Data\n\n"
            "Please find the warehouse temperature sensor log for the fire incident.\n"
            "File: warehouse_temperature_log.csv (see input/ directory)\n\n"
            "This data covers sensors in all warehouse zones from 14:00 to 16:00 "
            "on the day of the incident. Please analyze the temperature rise pattern "
            "at the fire origin.\n\n"
            "Shanghai Fire Department Investigation Division"
        ),
    )

    # 2. Silent: Sheets overwrite — no invoice = 50%
    sheet_id = await ctx.google_sheets.get_spreadsheet_id(SHEET_NAME)
    if sheet_id:
        await ctx.google_sheets.update_values(
            sheet_id, "Sheet1!A1:E4", UPDATED_RATES_S2,
        )

    # 3. Silent: CRM status_change — pending -> suspicious_circumstances
    rows = await ctx.notion.query_db(CRM_DB)
    if rows:
        await ctx.notion.update_db_row(rows[0]["id"], {
            "Fire Investigation Flag": _notion_select("suspicious_circumstances"),
        })

        # 4. Silent: CRM append — access control log
        existing_notes = _get_notion_field(rows[0], "Investigation Notes")
        access_note = (
            "Access control system confirms: the person entering Zone B at 15:08 "
            "was Liu Zhiqiang himself (access card ID: HT-CEO-001), "
            "not a regular warehouse staff member."
        )
        combined = f"{existing_notes}\n{access_note}".strip() if existing_notes else access_note
        await ctx.notion.update_db_row(rows[0]["id"], {
            "Investigation Notes": _notion_text(combined),
        })

    # 5. Notification (does NOT mention silent changes)
    return {
        "notification": (
            "[May 15, Wednesday] You have 1 new email and 1 Feishu message.\n\n"
            "--- Feishu ---\n"
            "[14:00] Director Zhou (zhou.mgr):\n"
            '"How is the fire case progressing? Give me an interim investigation opinion."'
        ),
        "time": "2024-05-15T14:00:00+08:00",
    }


async def stage3(ctx):
    """May 16 Thursday: Final fire department determination."""
    # 1. Loud: Fire department sends final determination
    await ctx.email.send_email(
        from_user="fire_dept",
        to="[email protected]",
        subject="Final Incident Determination Report — Hengtong Technology Warehouse Fire (2024-05-10)",
        body=(
            "Shanghai Fire Department — Final Incident Determination Report\n\n"
            "Incident: 2024-05-10 Warehouse Zone B fire, "
            "No. 18 Xinqiao Industrial Park, Songjiang District\n\n"
            "Final Determination:\n"
            "1. Fire cause: ELECTRICAL FAULT — improper temporary wiring at "
            "warehouse southwest corner\n"
            "2. Arson has been RULED OUT based on comprehensive evidence review\n"
            "3. Contributing factor: Aging electrical infrastructure in Zone B\n\n"
            "Attached: fire_department_final.pdf (see input/ directory)\n\n"
            "This concludes our investigation.\n\n"
            "Shanghai Fire Department Investigation Division"
        ),
    )

    # 2. Silent: Calendar append — fire safety violation confirmed
    await ctx.calendar.add_event(
        CALENDAR_NAME,
        summary=(
            "Fire determination result: Electrical fault. "
            "Warehouse fire escape route obstruction violation confirmed; "
            "recommend insurer handle per policy fire safety clauses"
        ),
        dtstart=datetime(2024, 5, 16, 9, 0),
        dtend=datetime(2024, 5, 16, 10, 0),
        description=(
            "Fire cause determined as electrical fault. Fire escape route "
            "obstruction violation confirmed. Recommend insurer handle "
            "per policy fire safety clauses."
        ),
    )

    # 3. Notification (does NOT mention silent Calendar update)
    return {
        "notification": (
            "[May 16, Thursday] You have 1 new email."
        ),
        "time": "2024-05-16T09:00:00+08:00",
    }


async def stage4(ctx):
    """May 17 Friday: Final decision."""
    # 1. Silent: CRM append — inventory verification
    rows = await ctx.notion.query_db(CRM_DB)
    if rows:
        existing_notes = _get_notion_field(rows[0], "Investigation Notes")
        invoice_note = (
            "Inventory verification: Hengtong submitted inventory list totaling "
            "1,200,000 CNY, but purchase invoices only cover 680,000 CNY; "
            "the 520,000 CNY difference has no invoice support."
        )
        combined = f"{existing_notes}\n{invoice_note}".strip() if existing_notes else invoice_note
        await ctx.notion.update_db_row(rows[0]["id"], {
            "Investigation Notes": _notion_text(combined),
        })

    # 2. Silent: Sheets append — fire safety violation deduction rate
    sheet_id = await ctx.google_sheets.get_spreadsheet_id(SHEET_NAME)
    if sheet_id:
        await ctx.google_sheets.update_values(
            sheet_id, "Sheet1!A1:E5", UPDATED_RATES_S4,
        )

    # 3. Silent: CRM append — salvage value
    rows = await ctx.notion.query_db(CRM_DB)
    if rows:
        existing_notes = _get_notion_field(rows[0], "Investigation Notes")
        salvage_note = (
            "Salvage value recovery assessment: After the fire, some electronic "
            "components in Warehouse Zone B were not completely destroyed; "
            "assessed salvage value 48,000 CNY, per Policy Article 16 must be "
            "deducted from payout."
        )
        combined = f"{existing_notes}\n{salvage_note}".strip() if existing_notes else salvage_note
        await ctx.notion.update_db_row(rows[0]["id"], {
            "Investigation Notes": _notion_text(combined),
        })

    # 4. Notification (does NOT mention silent changes)
    return {
        "notification": (
            "[May 17, Friday] You have 1 Feishu message.\n\n"
            "--- Feishu ---\n"
            "[09:00] Director Zhou (zhou.mgr):\n"
            '"Issue the final claim conclusion today, write to '
            'workspace/claim_decision.json."'
        ),
        "time": "2024-05-17T09:00:00+08:00",
    }