Update app.py

app.py

@@ -1,254 +1,584 @@
+# app.py
 import gradio as gr
 import sqlite3
+import json
 import pandas as pd
 from datetime import datetime
+import os
+import random
 
 DB_FILE = "cases.db"
+STANDARD_COMPOUND_CENTS = 30000  # RM300.00 stored as cents
 
-# ------------------ DB Setup ------------------
+# ------------------ DB Setup & Schema ------------------
 def init_db():
     conn = sqlite3.connect(DB_FILE)
     c = conn.cursor()
+    # summons_cases
     c.execute("""
-        CREATE TABLE IF NOT EXISTS cases (
-            id INTEGER PRIMARY KEY AUTOINCREMENT,
-            citizen_name TEXT,
-            fine_amount REAL,
-            description TEXT,
-            police_evidence TEXT,
-            citizen_appeal TEXT,
-            citizen_evidence TEXT,
-            status TEXT,
-            created_at TEXT
-        )
+    CREATE TABLE IF NOT EXISTS summons_cases (
+      id INTEGER PRIMARY KEY AUTOINCREMENT,
+      summons_no TEXT UNIQUE,
+      issuing_agency TEXT,
+      rta_section TEXT,
+      offender_name TEXT,
+      offender_ic TEXT,
+      offender_address TEXT,
+      vehicle_plate TEXT,
+      vehicle_type TEXT,
+      offence_code TEXT,
+      offence_desc_en TEXT,
+      offence_desc_ms TEXT,
+      offence_desc_zh TEXT,
+      offence_datetime TEXT,
+      offence_location TEXT,
+      district TEXT,
+      evidence_media TEXT,
+      base_fine_cents INTEGER,
+      payable_fine_cents INTEGER,
+      due_date TEXT,
+      status TEXT,
+      created_at TEXT,
+      updated_at TEXT
+    )
+    """)
+    # appeals
+    c.execute("""
+    CREATE TABLE IF NOT EXISTS appeals (
+      id INTEGER PRIMARY KEY AUTOINCREMENT,
+      case_id INTEGER,
+      appeal_text_en TEXT,
+      appeal_text_ms TEXT,
+      appeal_text_zh TEXT,
+      attachments TEXT,
+      submitted_at TEXT
+    )
+    """)
+    # judge_reviews
+    c.execute("""
+    CREATE TABLE IF NOT EXISTS judge_reviews (
+      id INTEGER PRIMARY KEY AUTOINCREMENT,
+      case_id INTEGER,
+      reviewer_type TEXT,
+      reviewer_id TEXT,
+      decision TEXT,
+      reduced_fine_cents INTEGER,
+      rationale TEXT,
+      decided_at TEXT,
+      authority_consent TEXT
+    )
+    """)
+    # pdrm_reviews
+    c.execute("""
+    CREATE TABLE IF NOT EXISTS pdrm_reviews (
+      id INTEGER PRIMARY KEY AUTOINCREMENT,
+      case_id INTEGER,
+      decision TEXT,
+      reduced_fine_cents INTEGER,
+      alasan TEXT,
+      reviewer_id TEXT,
+      decided_at TEXT
+    )
+    """)
+    # payments
+    c.execute("""
+    CREATE TABLE IF NOT EXISTS payments (
+      id INTEGER PRIMARY KEY AUTOINCREMENT,
+      case_id INTEGER,
+      channel TEXT,
+      amount_cents INTEGER,
+      currency TEXT,
+      provider_ref TEXT,
+      status TEXT,
+      paid_at TEXT
+    )
+    """)
+    # receipts
+    c.execute("""
+    CREATE TABLE IF NOT EXISTS receipts (
+      id INTEGER PRIMARY KEY AUTOINCREMENT,
+      payment_id INTEGER,
+      case_id INTEGER,
+      receipt_no TEXT,
+      issued_at TEXT
+    )
+    """)
+    # audit_logs
+    c.execute("""
+    CREATE TABLE IF NOT EXISTS audit_logs (
+      id INTEGER PRIMARY KEY AUTOINCREMENT,
+      case_id INTEGER,
+      actor TEXT,
+      action TEXT,
+      details TEXT,
+      created_at TEXT
+    )
     """)
     conn.commit()
     conn.close()
 
+# ------------------ Seeding multilingual demo cases ------------------
 def seed_mock_data():
     conn = sqlite3.connect(DB_FILE)
     c = conn.cursor()
-    c.execute("SELECT COUNT(*) FROM cases")
+    c.execute("SELECT COUNT(*) FROM summons_cases")
     count = c.fetchone()[0]
-
-    if count == 0:  # Seed only when DB is empty
+    if count == 0:
+        now = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
         cases = [
+            # Ali (ISSUED)
             (
-                "Ali",
-                100.0,
-                "Speeding in a 50 km/h zone / Memandu laju di zon 50 km/j / 在限速50公里的区域超速",
-                "evidence_photo_speed.png",
-                None,
-                None,
-                "Pending Payment",
-                datetime.now().strftime("%Y-%m-%d %H:%M:%S")
+                "K250901234", "PDRM", "APJ 1987",
+                "Ali", "900101-01-0001", "12, Jalan Kenanga 3, Taman Seri, 75450 Melaka",
+                "VDD8821", "Pick-up", "LORONG-001",
+                "Not obeying correct lane usage",
+                "Tidak mematuhi lorong yang betul",
+                "未按规定车道行驶",
+                "2025-07-22T05:33:00+08:00", "Jalan Lembongan", "Melaka Tengah",
+                json.dumps(["uploads/kes1-plate.jpg"]),
+                300, 300, "2025-09-22", "ISSUED", now, now
             ),
+            # Ah Kow (APPEAL_PENDING)
             (
-                "Ah Kow",
-                250.0,
-                "Running a red light / Melanggar lampu merah / 闯红灯",
-                "evidence_redlight_cam.jpg",
-                "I crossed on yellow, not red / Saya lintas pada lampu kuning, bukan merah / 我是在黄灯时通过，不是红灯",
-                "appeal_photo.jpg",
-                "Appealed",
-                datetime.now().strftime("%Y-%m-%d %H:%M:%S")
+                "K250901235", "PDRM", "APJ 1987",
+                "Ah Kow", "881212-02-2222", "45, Taman Melur, 75400 Melaka",
+                "MCD3210", "Car", "REDLIGHT-01",
+                "Running a red light",
+                "Melanggar lampu merah",
+                "闯红灯",
+                "2025-08-01T18:12:00+08:00", "Persiaran Bukit Baru", "Melaka Tengah",
+                json.dumps(["uploads/kes2-camera.jpg"]),
+                300, 300, "2025-10-01", "APPEAL_PENDING", now, now
             ),
+            # Muthu (APPEAL_APPROVED_REDUCED)
             (
-                "Muthu",
-                75.0,
-                "Illegal parking / Letak kereta haram / 非法停车",
-                "evidence_parking.jpg",
-                None,
-                None,
-                "Fine Paid",
-                datetime.now().strftime("%Y-%m-%d %H:%M:%S")
+                "K250901236", "PDRM", "APJ 1987",
+                "Muthu", "850505-03-3333", "25, Jalan Seri Indah, 75410 Melaka",
+                "VDL5500", "Motorcycle", "PARK-001",
+                "Illegal parking",
+                "Letak kereta haram",
+                "非法停车",
+                "2025-07-30T09:45:00+08:00", "Jalan Merdeka", "Melaka Tengah",
+                json.dumps(["uploads/kes3-park.jpg"]),
+                300, 100, "2025-09-30", "APPEAL_APPROVED_REDUCED", now, now
             ),
         ]
         c.executemany("""
-            INSERT INTO cases (
-                citizen_name, fine_amount, description, police_evidence,
-                citizen_appeal, citizen_evidence, status, created_at
-            ) VALUES (?, ?, ?, ?, ?, ?, ?, ?)
+            INSERT INTO summons_cases (
+              summons_no, issuing_agency, rta_section,
+              offender_name, offender_ic, offender_address,
+              vehicle_plate, vehicle_type, offence_code,
+              offence_desc_en, offence_desc_ms, offence_desc_zh,
+              offence_datetime, offence_location, district,
+              evidence_media, base_fine_cents, payable_fine_cents,
+              due_date, status, created_at, updated_at
+            ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
         """, cases)
         conn.commit()
+        # Add an appeal row for case 2 (Ah Kow)
+        c.execute("SELECT id FROM summons_cases WHERE summons_no=?", ("K250901235",))
+        row = c.fetchone()
+        if row:
+            case2_id = row[0]
+            c.execute("""
+            INSERT INTO appeals (case_id, appeal_text_en, appeal_text_ms, appeal_text_zh, attachments, submitted_at)
+            VALUES (?, ?, ?, ?, ?, ?)
+            """, (
+                case2_id,
+                "I crossed on yellow, not red",
+                "Saya lintas pada lampu kuning, bukan merah",
+                "我是在黄灯时通过，不是红灯",
+                json.dumps(["uploads/appeal2-dashcam.mp4"]),
+                now
+            ))
+            conn.commit()
+            # audit log for appeal submitted
+            write_audit(case2_id, "citizen", "APPEAL_SUBMITTED", "Appeal submitted by citizen (seed).")
     conn.close()
 
-init_db()
-seed_mock_data()
+# ------------------ Utility helpers ------------------
+def now_ts():
+    return datetime.now().strftime("%Y-%m-%d %H:%M:%S")
 
-# ------------------ Functions ------------------
-def police_create_case(citizen_name, fine_amount, description, police_evidence):
+def write_audit(case_id, actor, action, details):
+    # For PDRM actions, ensure details are in Bahasa Melayu when actor==police or action starts with PDRM_
     conn = sqlite3.connect(DB_FILE)
     c = conn.cursor()
+    if actor == "police" or action.startswith("PDRM_") or action.startswith("PDRMDECISION") or action.startswith("PAYMENT_PDRM"):
+        # Expect details in BM already from callers; but if not, wrap generically
+        details_text = details
+        # If it's a dict, dump directly
+        if isinstance(details, dict):
+            details_text = json.dumps(details, ensure_ascii=False)
+    else:
+        details_text = details if isinstance(details, str) else json.dumps(details, ensure_ascii=False)
     c.execute("""
-        INSERT INTO cases (citizen_name, fine_amount, description, police_evidence, status, created_at)
-        VALUES (?, ?, ?, ?, ?, ?)
+      INSERT INTO audit_logs (case_id, actor, action, details, created_at)
+      VALUES (?, ?, ?, ?, ?)
+    """, (case_id, actor, action, details_text, now_ts()))
+    conn.commit()
+    conn.close()
+
+def generate_receipt_no():
+    return f"RCP{datetime.now().strftime('%Y%m%d')}-{random.randint(1000,9999)}"
+
+# ------------------ Core Operations ------------------
+
+# Police: create case (BM-only response)
+def police_create_case(citizen_name, citizen_ic, citizen_address, vehicle_plate, vehicle_type,
+                       offence_code, offence_desc_ms, offence_desc_en, offence_desc_zh,
+                       offence_datetime, offence_location, district, evidence_file):
+    conn = sqlite3.connect(DB_FILE)
+    c = conn.cursor()
+    summons_no = f"K{datetime.now().strftime('%y%m%d')}{random.randint(1000,9999)}"
+    created = now_ts()
+    base_cents = STANDARD_COMPOUND_CENTS
+    payable_cents = base_cents
+    c.execute("""
+      INSERT INTO summons_cases (
+        summons_no, issuing_agency, rta_section,
+        offender_name, offender_ic, offender_address,
+        vehicle_plate, vehicle_type, offence_code,
+        offence_desc_en, offence_desc_ms, offence_desc_zh,
+        offence_datetime, offence_location, district,
+        evidence_media, base_fine_cents, payable_fine_cents,
+        due_date, status, created_at, updated_at
+      ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
     """, (
-        citizen_name, fine_amount, description,
-        police_evidence if police_evidence else None,
-        "Pending Payment",
-        datetime.now().strftime("%Y-%m-%d %H:%M:%S")
+        summons_no, "PDRM", "APJ 1987",
+        citizen_name, citizen_ic, citizen_address,
+        vehicle_plate, vehicle_type, offence_code,
+        offence_desc_en, offence_desc_ms, offence_desc_zh,
+        offence_datetime, offence_location, district,
+        json.dumps([evidence_file]) if evidence_file else json.dumps([]),
+        base_cents, payable_cents, (datetime.now().replace(year=datetime.now().year+1)).strftime("%Y-%m-%d"),
+        "ISSUED", created, created
     ))
     conn.commit()
     case_id = c.lastrowid
     conn.close()
-    return f"✅ Kes telah dicipta dengan ID: {case_id}"  # Malay only
+    # Audit log in BM
+    write_audit(case_id, "police", "CASE_CREATED",
+                f"Kes saman telah dikeluarkan oleh PDRM, nombor saman {summons_no}, pegawai membuat rekod.")
+    return f"✅ Kes dicipta (ID dalaman: {case_id}) — Nombor Saman: {summons_no}"
 
+# Citizen: view case (multilingual output)
 def citizen_view_case(case_id):
+    try:
+        cid = int(case_id)
+    except:
+        return "❌ Invalid Case ID / ID Kes tidak sah / 无效的案件编号"
     conn = sqlite3.connect(DB_FILE)
     c = conn.cursor()
-    c.execute("SELECT * FROM cases WHERE id=?", (case_id,))
+    c.execute("SELECT * FROM summons_cases WHERE id=?", (cid,))
     row = c.fetchone()
     conn.close()
     if not row:
         return "❌ Case not found / Kes tidak dijumpai / 案件未找到"
-    return pd.DataFrame([row], columns=[
-        "ID", "Citizen", "Fine", "Description", "Police Evidence",
-        "Citizen Appeal", "Citizen Evidence", "Status", "Created At"
-    ])
+    cols = [d[0] for d in c.description] if False else [
+        "id","summons_no","issuing_agency","rta_section","offender_name","offender_ic","offender_address",
+        "vehicle_plate","vehicle_type","offence_code","offence_desc_en","offence_desc_ms","offence_desc_zh",
+        "offence_datetime","offence_location","district","evidence_media","base_fine_cents","payable_fine_cents",
+        "due_date","status","created_at","updated_at"
+    ]
+    # Build display dict with trilingual description
+    display = {
+        "ID": row[0],
+        "Summons No": row[1],
+        "Offender": row[4],
+        "IC": row[5],
+        "Address": row[6],
+        "Vehicle Plate": row[7],
+        "Vehicle Type": row[8],
+        "Offence (EN / BM / ZH)": f"{row[10]} / {row[11]} / {row[12]}",
+        "DateTime": row[13],
+        "Location": row[14],
+        "District": row[15],
+        "Evidence (files)": json.loads(row[16]) if row[16] else [],
+        "Base Fine (RM)": f"{row[17]/100:.2f}",
+        "Payable (RM)": f"{row[18]/100:.2f}",
+        "Due Date": row[19],
+        "Status": row[20],
+        "Created At": row[21]
+    }
+    return pd.DataFrame([display])
 
-def citizen_pay_fine(case_id):
+# Citizen: submit appeal to magistrate (judicial appeal)
+def citizen_submit_judicial_appeal(case_id, appeal_text_en, appeal_text_ms, appeal_text_zh, appeal_files):
+    try:
+        cid = int(case_id)
+    except:
+        return "❌ Invalid Case ID / ID Kes tidak sah / 无效的案件编号"
     conn = sqlite3.connect(DB_FILE)
     c = conn.cursor()
-    c.execute("UPDATE cases SET status=? WHERE id=?", ("Fine Paid", case_id))
+    c.execute("INSERT INTO appeals (case_id, appeal_text_en, appeal_text_ms, appeal_text_zh, attachments, submitted_at) VALUES (?, ?, ?, ?, ?, ?)",
+              (cid, appeal_text_en, appeal_text_ms, appeal_text_zh,
+               json.dumps([appeal_files]) if appeal_files else json.dumps([]),
+               now_ts()))
+    c.execute("UPDATE summons_cases SET status=?, updated_at=? WHERE id=?", ("APPEAL_PENDING", now_ts(), cid))
     conn.commit()
     conn.close()
-    return f"💰 Fine for case {case_id} marked as paid. / Kes {case_id} ditandakan telah dibayar. / 案件 {case_id} 已缴清罚款。"
+    write_audit(cid, "citizen", "APPEAL_SUBMITTED", "Rayuan ke mahkamah telah dihantar oleh pengguna.")
+    return f"📤 Rayuan ke mahkamah telah dihantar untuk kes {case_id} / Appeal submitted."
 
-def citizen_appeal(case_id, appeal_text, evidence_file):
+# Citizen: submit appeal to PDRM (compound appeal) before paying
+def citizen_submit_pdrm_appeal(case_id, appeal_text_ms, appeal_files):
+    try:
+        cid = int(case_id)
+    except:
+        return "❌ Invalid Case ID / ID Kes tidak sah / 无效的案件编号"
+    # For PDRM appeals we store in appeals table as well (tri-lingual fields optional)
     conn = sqlite3.connect(DB_FILE)
     c = conn.cursor()
-    c.execute("""
-        UPDATE cases 
-        SET citizen_appeal=?, citizen_evidence=?, status=? 
-        WHERE id=?
-    """, (
-        appeal_text, evidence_file if evidence_file else None,
-        "Appealed", case_id
-    ))
+    c.execute("INSERT INTO appeals (case_id, appeal_text_en, appeal_text_ms, appeal_text_zh, attachments, submitted_at) VALUES (?, ?, ?, ?, ?, ?)",
+              (cid, "", appeal_text_ms, "", json.dumps([appeal_files]) if appeal_files else json.dumps([]), now_ts()))
+    # mark status to PDRM_APPEAL_PENDING
+    c.execute("UPDATE summons_cases SET status=?, updated_at=? WHERE id=?", ("PDRM_APPEAL_PENDING", now_ts(), cid))
+    conn.commit()
+    conn.close()
+    write_audit(cid, "citizen", "APPEAL_PDRM_SUBMITTED", "Rayuan kompaun telah dihantar oleh pengguna ke PDRM.")
+    return f"📤 Rayuan kompaun (PDRM) telah dihantar untuk kes {case_id}."
+
+# PDRM officer: review PDRM appeals in police portal (BM only)
+def police_list_pdrm_appeals():
+    conn = sqlite3.connect(DB_FILE)
+    c = conn.cursor()
+    c.execute("SELECT id, summons_no, offender_name, payable_fine_cents, status FROM summons_cases WHERE status IN ('PDRM_APPEAL_PENDING','ISSUED')")
+    rows = c.fetchall()
+    conn.close()
+    if not rows:
+        return "Tiada rayuan PDRM yang sedang menunggu / No PDRM appeals pending"
+    df = pd.DataFrame(rows, columns=["CaseID","SummonsNo","Offender","PayableCents","Status"])
+    df["PayableRM"] = df["PayableCents"].apply(lambda x: f"RM{x/100:.2f}")
+    return df
+
+def police_decide_pdrm(case_id, decision_choice, reduced_amount_rm, officer_id, alasan_ms):
+    # decision_choice: "tolak" or "dikurangkan"
+    try:
+        cid = int(case_id)
+    except:
+        return "❌ ID Kes tidak sah"
+    conn = sqlite3.connect(DB_FILE)
+    c = conn.cursor()
+    if decision_choice == "tolak":
+        # keep payable as base; set status to ISSUED (or PDRM_REJECTED)
+        c.execute("SELECT base_fine_cents, summons_no FROM summons_cases WHERE id=?", (cid,))
+        row = c.fetchone()
+        if not row:
+            conn.close()
+            return "Kes tidak dijumpai"
+        base = row[0]
+        c.execute("UPDATE summons_cases SET payable_fine_cents=?, status=?, updated_at=? WHERE id=?", (base, "ISSUED", now_ts(), cid))
+        c.execute("INSERT INTO pdrm_reviews (case_id, decision, reduced_fine_cents, alasan, reviewer_id, decided_at) VALUES (?, ?, ?, ?, ?, ?)",
+                  (cid, "ditolak", None, alasan_ms, officer_id, now_ts()))
+        conn.commit()
+        conn.close()
+        write_audit(cid, "police", "PDRM_DECISION",
+                    f"Rayuan kompaun ditolak oleh pegawai {officer_id}.")
+        return f"🛑 Rayuan ditolak. Jumlah kompaun kekal RM{base/100:.2f}"
+    else:
+        # dikurangkan
+        reduced_cents = int(float(reduced_amount_rm) * 100)
+        c.execute("UPDATE summons_cases SET payable_fine_cents=?, status=?, updated_at=? WHERE id=?", (reduced_cents, "ISSUED", now_ts(), cid))
+        c.execute("INSERT INTO pdrm_reviews (case_id, decision, reduced_fine_cents, alasan, reviewer_id, decided_at) VALUES (?, ?, ?, ?, ?, ?)",
+                  (cid, "dikurangkan", reduced_cents, alasan_ms, officer_id, now_ts()))
+        conn.commit()
+        conn.close()
+        write_audit(cid, "police", "PDRM_DECISION",
+                    f"Rayuan kompaun diluluskan; jumlah dikurangkan kepada RM{reduced_cents/100:.2f} oleh pegawai {officer_id}.")
+        return f"✅ Rayuan diluluskan. Jumlah kompaun kini RM{reduced_cents/100:.2f}"
+
+# Citizen: pay now (to PDRM) - simulated payment
+def citizen_pay_now(case_id, pay_channel="PDRM_GATEWAY"):
+    try:
+        cid = int(case_id)
+    except:
+        return "❌ Invalid Case ID / ID Kes tidak sah"
+    conn = sqlite3.connect(DB_FILE)
+    c = conn.cursor()
+    c.execute("SELECT payable_fine_cents, summons_no FROM summons_cases WHERE id=?", (cid,))
+    r = c.fetchone()
+    if not r:
+        conn.close()
+        return "❌ Case not found / Kes tidak dijumpai"
+    amount = r[0]
+    if amount <= 0:
+        conn.close()
+        return "Tiada bayaran diperlukan / No payment required"
+    # Simulate payment success
+    provider_ref = f"TX{datetime.now().strftime('%Y%m%d%H%M%S')}{random.randint(100,999)}"
+    paid_at = now_ts()
+    c.execute("INSERT INTO payments (case_id, channel, amount_cents, currency, provider_ref, status, paid_at) VALUES (?, ?, ?, ?, ?, ?, ?)",
+              (cid, pay_channel, amount, "MYR", provider_ref, "success", paid_at))
+    payment_id = c.lastrowid
+    # Create receipt if channel is PDRM_GATEWAY
+    receipt_no = generate_receipt_no()
+    c.execute("INSERT INTO receipts (payment_id, case_id, receipt_no, issued_at) VALUES (?, ?, ?, ?)",
+              (payment_id, cid, receipt_no, now_ts()))
+    # Update case status to PAID -> CLOSED
+    c.execute("UPDATE summons_cases SET status=?, updated_at=? WHERE id=?", ("PAID", now_ts(), cid))
     conn.commit()
     conn.close()
-    return f"📤 Appeal submitted for case {case_id} / Rayuan dihantar untuk kes {case_id} / 案件 {case_id} 已提交申诉"
+    # Audit logs in BM for payments to PDRM
+    write_audit(cid, "police", "PAYMENT_PDRM", f"Pembayaran berjaya dibuat kepada PDRM, jumlah RM{amount/100:.2f}, resit nombor {receipt_no}.")
+    return f"💳 Pembayaran berjaya (RM{amount/100:.2f}). Resit: {receipt_no}"
 
-def magistrate_dashboard():
+# Magistrate: list appealed cases
+def magistrate_list_appeals():
     conn = sqlite3.connect(DB_FILE)
     c = conn.cursor()
-    c.execute("SELECT * FROM cases WHERE status='Appealed'")
+    c.execute("SELECT id, summons_no, offender_name, payable_fine_cents, status FROM summons_cases WHERE status IN ('APPEAL_PENDING','UNDER_REVIEW')")
     rows = c.fetchall()
     conn.close()
     if not rows:
-        return "No appealed cases. / Tiada kes rayuan. / 没有申诉案件"
-    return pd.DataFrame(rows, columns=[
-        "ID", "Citizen", "Fine", "Description", "Police Evidence",
-        "Citizen Appeal", "Citizen Evidence", "Status", "Created At"
-    ])
-
-def magistrate_decide(case_id, decision):
-    new_status = {
-        "Approve Appeal": "Appeal Approved",
-        "Reject Appeal": "Appeal Rejected",
-        "Escalate Hearing": "Hearing Scheduled"
-    }[decision]
+        return "No appealed cases."
+    df = pd.DataFrame(rows, columns=["CaseID","SummonsNo","Offender","PayableCents","Status"])
+    df["PayableRM"] = df["PayableCents"].apply(lambda x: f"RM{x/100:.2f}")
+    return df
+
+# Magistrate: decide (human or AI)
+def magistrate_decide(case_id, reviewer_type, reviewer_id, decision_choice, reduced_amount_rm, rationale, authority_consent):
+    try:
+        cid = int(case_id)
+    except:
+        return "❌ Invalid Case ID"
     conn = sqlite3.connect(DB_FILE)
     c = conn.cursor()
-    c.execute("UPDATE cases SET status=? WHERE id=?", (new_status, case_id))
+    # Map decision_choice to DB-friendly
+    if decision_choice == "Approve No Fine":
+        new_status = "APPEAL_APPROVED_NO_FINE"
+        reduced_cents = 0
+    elif decision_choice == "Approve Reduced Fine":
+        reduced_cents = int(float(reduced_amount_rm) * 100)
+        new_status = "APPEAL_APPROVED_REDUCED"
+    else:
+        # Reject
+        c.execute("SELECT base_fine_cents FROM summons_cases WHERE id=?", (cid,))
+        r = c.fetchone()
+        if not r:
+            conn.close()
+            return "Kes tidak dijumpai"
+        reduced_cents = r[0]
+        new_status = "APPEAL_REJECTED"
+    # Insert judge review
+    c.execute("""INSERT INTO judge_reviews (case_id, reviewer_type, reviewer_id, decision, reduced_fine_cents, rationale, decided_at, authority_consent)
+                 VALUES (?, ?, ?, ?, ?, ?, ?, ?)""",
+              (cid, reviewer_type, reviewer_id, decision_choice.lower().replace(" ", "_"), reduced_cents, rationale, now_ts(), authority_consent))
+    # Update case payable and status
+    c.execute("UPDATE summons_cases SET payable_fine_cents=?, status=?, updated_at=? WHERE id=?", (reduced_cents, new_status, now_ts(), cid))
     conn.commit()
     conn.close()
-    return f"⚖️ Case {case_id} updated: {new_status}"
+    write_audit(cid, "judge", "DECISION_MADE", f"Keputusan oleh {reviewer_type} ({reviewer_id}): {decision_choice}. Rationale: {rationale}")
+    return f"⚖️ Keputusan dicatat untuk kes {case_id}: {decision_choice}. Jumlah kini RM{reduced_cents/100:.2f}"
+
+# Utility: show audit logs (BM for police actions)
+def show_audit_logs(case_id):
+    try:
+        cid = int(case_id)
+    except:
+        return "❌ Invalid Case ID"
+    conn = sqlite3.connect(DB_FILE)
+    df = pd.read_sql_query("SELECT created_at, actor, action, details FROM audit_logs WHERE case_id=? ORDER BY id ASC", conn, params=(cid,))
+    conn.close()
+    if df.empty:
+        return "No logs found."
+    return df
 
 # ------------------ Gradio UI ------------------
-with gr.Blocks() as demo:
-    gr.Markdown("# 🚦 SwiftCase.ai – Smart Traffic Justice Platform")
+init_db()
+seed_mock_data()
 
-    # Citizen Portal (All languages shown at once)
+with gr.Blocks() as demo:
+    gr.Markdown("# 🚦 SwiftCase.ai – Real-world Traffic Offence MVP")
     with gr.Tab("Citizen Portal / Portal Warga / 市民入口"):
-        case_id_input = gr.Number(
-            label="Enter Case ID / Masukkan ID Kes / 输入案件编号", precision=0
-        )
+        gr.Markdown("**Semua label & arahan dipaparkan dalam 3 bahasa untuk kemudahan pengguna.**")
+        case_id_input = gr.Number(label="Enter Case ID / Masukkan ID Kes / 输入案件编号", precision=0)
         view_btn = gr.Button("View Case / Lihat Kes / 查看案件")
         case_output = gr.Dataframe()
         view_btn.click(citizen_view_case, inputs=case_id_input, outputs=case_output)
 
         with gr.Row():
-            pay_btn = gr.Button("Pay Fine / Bayar Saman / 缴纳罚款")
-            appeal_text = gr.Textbox(label="Appeal Text / Teks Rayuan / 申诉内容")
-            appeal_file = gr.File(
-                label="Upload Appeal Evidence / Muat Naik Bukti Rayuan / 上传申诉证据",
-                type="filepath"
-            )
-            appeal_btn = gr.Button("Submit Appeal / Hantar Rayuan / 提交申诉")
-
-        pay_result = gr.Textbox(
-            label="Result / Keputusan / 结果"
-        )
-        appeal_result = gr.Textbox(
-            label="Appeal Result / Keputusan Rayuan / 申诉结果"
-        )
-
-        pay_btn.click(citizen_pay_fine, inputs=case_id_input, outputs=pay_result)
-        appeal_btn.click(
-            citizen_appeal, inputs=[case_id_input, appeal_text, appeal_file],
-            outputs=appeal_result
-        )
-
-    # Police Portal (Bahasa Melayu only)
-    with gr.Tab("Portal Polis Trafik"):
-        gr.Markdown("## Portal Polis Trafik (Bahasa Melayu Sahaja)")
-
-        citizen_name = gr.Textbox(label="Nama Warga")
-        fine_amount = gr.Number(label="Jumlah Saman")
-        description = gr.Textbox(label="Huraian")
-        police_file = gr.File(label="Muat Naik Bukti", type="filepath")
-        create_case_btn = gr.Button("Cipta Kes")
-        police_result = gr.Textbox(label="Keputusan")
-        create_case_btn.click(
-            police_create_case,
-            inputs=[citizen_name, fine_amount, description, police_file],
-            outputs=police_result
-        )
-
-    # Magistrate Portal (English + Malay via dropdown)
+            pay_now_btn = gr.Button("Pay Compound Now (Bayar Kompaun) / 缴纳罚款")
+            appeal_pdrm_btn = gr.Button("Appeal to PDRM (Rayuan Kompaun) / 向PDRM申诉")
+            appeal_mag_btn = gr.Button("Appeal to Magistrate (Rayuan ke Mahkamah) / 向法官申诉")
+        # PDRM appeal inputs
+        appeal_pdrm_text = gr.Textbox(label="Alasan Rayuan (BM) / Appeal Reason (BM) / 申诉理由（马）")
+        appeal_pdrm_file = gr.File(label="Upload Evidence (filepath)", type="filepath")
+        # Judicial appeal inputs
+        appeal_jud_en = gr.Textbox(label="Appeal Text (EN) / 申诉（英）")
+        appeal_jud_ms = gr.Textbox(label="Appeal Text (BM) / 申诉（马）")
+        appeal_jud_zh = gr.Textbox(label="Appeal Text (ZH) / 申诉（中）")
+        appeal_jud_file = gr.File(label="Upload Evidence for Judicial Appeal", type="filepath")
+
+        pay_result = gr.Textbox(label="Result / Keputusan / 结果")
+        pdrm_appeal_result = gr.Textbox(label="PDRM Appeal Result / Keputusan Rayuan PDRM")
+        jud_appeal_result = gr.Textbox(label="Judicial Appeal Result / Keputusan Rayuan Mahkamah")
+
+        pay_now_btn.click(citizen_pay_now, inputs=case_id_input, outputs=pay_result)
+        appeal_pdrm_btn.click(citizen_submit_pdrm_appeal, inputs=[case_id_input, appeal_pdrm_text, appeal_pdrm_file], outputs=pdrm_appeal_result)
+        appeal_mag_btn.click(citizen_submit_judicial_appeal, inputs=[case_id_input, appeal_jud_en, appeal_jud_ms, appeal_jud_zh, appeal_jud_file], outputs=jud_appeal_result)
+
+        with gr.Accordion("View Audit Logs / Lihat Log / 查看日志", open=False):
+            audit_out = gr.Dataframe()
+            show_audit_btn = gr.Button("Show Logs / Tunjuk Log / 显示日志")
+            show_audit_btn.click(show_audit_logs, inputs=case_id_input, outputs=audit_out)
+
+    with gr.Tab("Portal Polis Trafik (Bahasa Melayu sahaja)"):
+        gr.Markdown("**Portal untuk PDRM: muat naik saman, semak rayuan kompaun, buat keputusan. Semua log PDRM dalam Bahasa Melayu.**")
+        # Create case
+        pol_name = gr.Textbox(label="Nama Warga (Nama penuh)")
+        pol_ic = gr.Textbox(label="No KP")
+        pol_addr = gr.Textbox(label="Alamat")
+        pol_plate = gr.Textbox(label="Nombor Plat")
+        pol_vtype = gr.Textbox(label="Jenis Kenderaan")
+        pol_off_code = gr.Textbox(label="Kod Kesalahan")
+        pol_off_desc_ms = gr.Textbox(label="Huraian Kesalahan (BM)")
+        pol_off_desc_en = gr.Textbox(label="Offence Description (EN) - optional")
+        pol_off_desc_zh = gr.Textbox(label="Offence Description (ZH) - optional")
+        pol_datetime = gr.Textbox(label="Tarikh/Masa (ISO) - e.g. 2025-07-22T05:33:00+08:00")
+        pol_location = gr.Textbox(label="Lokasi")
+        pol_district = gr.Textbox(label="Daerah")
+        pol_evidence = gr.File(label="Muat Naik Bukti (filepath)", type="filepath")
+        create_pol_btn = gr.Button("Cipta Kes (Cipta Saman)")
+        pol_create_result = gr.Textbox(label="Keputusan")
+        create_pol_btn.click(police_create_case, inputs=[pol_name, pol_ic, pol_addr, pol_plate, pol_vtype, pol_off_code,
+                                                         pol_off_desc_ms, pol_off_desc_en, pol_off_desc_zh,
+                                                         pol_datetime, pol_location, pol_district, pol_evidence],
+                             outputs=pol_create_result)
+
+        gr.Markdown("### Senarai rayuan kompaun / PDRM appeals waiting")
+        list_pdrm_btn = gr.Button("Semak Rayuan PDRM")
+        pdrm_list_out = gr.Dataframe()
+        list_pdrm_btn.click(police_list_pdrm_appeals, outputs=pdrm_list_out)
+
+        # Police decision inputs
+        pol_dec_caseid = gr.Number(label="Case ID untuk keputusan", precision=0)
+        pol_dec_choice = gr.Radio(["tolak","dikurangkan"], label="Keputusan (tolak / dikurangkan)")
+        pol_reduced_rm = gr.Number(label="Jumlah dikurangkan (RM) - jika dikurangkan", value=150)
+        pol_officer_id = gr.Textbox(label="ID Pegawai")
+        pol_alasan = gr.Textbox(label="Alasan (BM) untuk keputusan")
+        pol_decide_btn = gr.Button("Hantar Keputusan PDRM")
+        pol_decide_out = gr.Textbox(label="Keputusan PDRM")
+        pol_decide_btn.click(police_decide_pdrm, inputs=[pol_dec_caseid, pol_dec_choice, pol_reduced_rm, pol_officer_id, pol_alasan], outputs=pol_decide_out)
+
     with gr.Tab("Magistrate Portal / Portal Majistret"):
-        lang_mag = gr.Dropdown(
-            ["English", "Bahasa Melayu"], value="English",
-            label="Language / Bahasa"
-        )
-
-        dashboard_btn = gr.Button("Refresh Appeals Dashboard")
-        dashboard_output = gr.Dataframe()
-        dashboard_btn.click(magistrate_dashboard, outputs=dashboard_output)
-
-        case_id_mag = gr.Number(label="Case ID", precision=0)
-        decision = gr.Dropdown(
-            ["Approve Appeal", "Reject Appeal", "Escalate Hearing"],
-            label="Decision"
-        )
-        decide_btn = gr.Button("Submit Decision")
-        decision_result = gr.Textbox(label="Decision Result")
-        decide_btn.click(
-            magistrate_decide, inputs=[case_id_mag, decision], outputs=decision_result
-        )
-
-        def update_mag_labels(lang):
-            if lang == "English":
-                return (
-                    "Refresh Appeals Dashboard",
-                    "Case ID",
-                    "Decision",
-                    "Submit Decision"
-                )
-            else:
-                return (
-                    "Segarkan Papan Pemuka Rayuan",
-                    "ID Kes",
-                    "Keputusan",
-                    "Hantar Keputusan"
-                )
-
-        lang_mag.change(
-            update_mag_labels, inputs=lang_mag,
-            outputs=[dashboard_btn, case_id_mag, decision, decide_btn]
-        )
+        gr.Markdown("Magistrate / Judge portal: review judicial appeals.")
+        mag_list_btn = gr.Button("Refresh Appeals Dashboard")
+        mag_list_out = gr.Dataframe()
+        mag_list_btn.click(magistrate_list_appeals, outputs=mag_list_out)
+
+        mag_case_id = gr.Number(label="Case ID", precision=0)
+        mag_reviewer_type = gr.Radio(["human_judge", "ai_agent"], label="Reviewer Type")
+        mag_reviewer_id = gr.Textbox(label="Reviewer ID / Model")
+        mag_decision = gr.Radio(["Approve No Fine", "Approve Reduced Fine", "Reject"], label="Decision")
+        mag_reduced_rm = gr.Number(label="Reduced Amount (RM) if applicable", value=100)
+        mag_rationale = gr.Textbox(label="Rationale / Sebab")
+        mag_authority = gr.Textbox(label="Authority Consent (e.g., AGC-ID) if AI used")
+        mag_decide_btn = gr.Button("Record Decision")
+        mag_decide_out = gr.Textbox(label="Decision Result")
+        mag_decide_btn.click(magistrate_decide, inputs=[mag_case_id, mag_reviewer_type, mag_reviewer_id, mag_decision, mag_reduced_rm, mag_rationale, mag_authority], outputs=mag_decide_out)
+
+    gr.Markdown("-----\n**Notes:** This is an MVP prototype. Payments are simulated. All PDRM logs/actions are recorded in Bahasa Melayu for auditability.")
 
 demo.launch()
 
@@ -258,3 +588,4 @@ demo.launch()
 
 
 
+