feat: implement Purchase Order (OC) monitoring and real-time market monitor UI

backend/app/main.py

@@ -4,11 +4,12 @@ sys.path.append(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
 
 from fastapi import FastAPI
 from fastapi.middleware.cors import CORSMiddleware
-from app.routers import analysis, company, health, tenders, documents
+from app.routers import analysis, company, health, tenders, documents, oc
 from app.database import engine, Base, SessionLocal
 from app.models.tender import TenderModel
 from app.models.analysis import AnalysisHistoryModel
 from app.models.company import CompanyProfileModel
+from app.models.oc import OCModel
 from app.config import settings
 from datetime import datetime, timedelta
 import json
@@ -32,6 +33,7 @@ app.include_router(tenders.router, prefix="/api", tags=["Tenders"])
 app.include_router(analysis.router, prefix="/api", tags=["Analysis"])
 app.include_router(company.router, prefix="/api", tags=["Company"])
 app.include_router(documents.router, prefix="/api", tags=["Documents"])
+app.include_router(oc.router, prefix="/api", tags=["Purchase Orders"])
 
 @app.on_event("startup")
 async def startup_event():

backend/app/models/oc.py

@@ -0,0 +1,24 @@
+from sqlalchemy import Column, String, Float, DateTime, Text, JSON
+from app.database import Base
+from datetime import datetime
+
+class OCModel(Base):
+    __tablename__ = "purchase_orders"
+
+    code = Column(String(50), primary_key=True, index=True)
+    name = Column(String(255), index=True)
+    status = Column(String(100))
+    status_code = Column(String(10), nullable=True)
+    buyer = Column(String(255), index=True)
+    buyer_rut = Column(String(20), nullable=True)
+    provider = Column(String(255), index=True)
+    provider_rut = Column(String(20), nullable=True)
+    date_creation = Column(DateTime, nullable=True)
+    total_amount = Column(Float, nullable=True)
+    currency = Column(String(10), nullable=True)
+    type = Column(String(50), nullable=True)
+    
+    items = Column(JSON, nullable=True)
+    raw_data = Column(JSON, nullable=True)
+    
+    last_updated = Column(DateTime, default=datetime.utcnow, onupdate=datetime.utcnow)

backend/app/routers/oc.py

@@ -0,0 +1,30 @@
+from typing import List, Optional
+from fastapi import APIRouter, Query, Depends
+from sqlalchemy.orm import Session
+from app.schemas.oc import PurchaseOrder
+from app.database import get_db
+from app.models.oc import OCModel
+from app.services.mercado_publico_oc import get_ocs_by_date, get_oc_by_code
+
+router = APIRouter()
+
+@router.get("/purchase-orders", response_model=List[PurchaseOrder])
+async def list_purchase_orders(
+    date: Optional[str] = None,
+    status: str = "todos",
+    db: Session = Depends(get_db)
+):
+    """
+    List purchase orders for a specific date (ddmmaaaa).
+    """
+    if not date:
+        from datetime import datetime
+        date = datetime.now().strftime("%d%m%Y")
+    
+    # Check if we have them in DB first? 
+    # For now, let's just fetch from API as a real-time monitor
+    return await get_ocs_by_date(date, status)
+
+@router.get("/purchase-orders/{code}", response_model=Optional[PurchaseOrder])
+async def get_purchase_order(code: str):
+    return await get_oc_by_code(code)

backend/app/schemas/oc.py

@@ -0,0 +1,31 @@
+from pydantic import BaseModel, ConfigDict
+from typing import List, Optional, Union
+from datetime import datetime
+
+class OCItem(BaseModel):
+    correlative: Optional[int] = None
+    product_code: Optional[str] = None
+    name: str
+    description: Optional[str] = None
+    quantity: float
+    unit: str
+    price: Optional[float] = None
+    total: Optional[float] = None
+
+class PurchaseOrder(BaseModel):
+    model_config = ConfigDict(from_attributes=True)
+    
+    code: str
+    name: str
+    status: str
+    status_code: Optional[str] = None
+    buyer: str
+    buyer_rut: Optional[str] = None
+    provider: str
+    provider_rut: Optional[str] = None
+    date_creation: Union[str, datetime, None] = None
+    total_amount: Optional[float] = None
+    currency: Optional[str] = None
+    type: Optional[str] = None
+    items: List[OCItem] = []
+    raw_data: Optional[dict] = None

backend/app/services/mercado_publico_oc.py

@@ -0,0 +1,106 @@
+import httpx
+from typing import List, Optional, Dict, Any
+from app.config import settings
+from app.schemas.oc import PurchaseOrder, OCItem
+from datetime import datetime
+
+API_BASE_OC = "https://api.mercadopublico.cl/servicios/v1/publico/ordenesdecompra.json"
+
+OC_STATUS_CODES = {
+    "4": "Enviada a Proveedor",
+    "5": "En proceso",
+    "6": "Aceptada",
+    "9": "Cancelada",
+    "12": "Recepción Conforme",
+    "13": "Pendiente de Recepcionar",
+    "14": "Recepcionada Parcialmente",
+    "15": "Recepcion Conforme Incompleta"
+}
+
+OC_TYPES = {
+    "1": "OC Automática",
+    "2": "D1 - Proveedor Único",
+    "3": "C1 - Emergencia/Urgencia",
+    "4": "F3 - Confidencialidad",
+    "5": "G1 - Naturaleza de negociación",
+    "6": "R1 - Menor a 3UTM",
+    "7": "CA - Sin resolución",
+    "8": "SE - Sin emisión automática",
+    "9": "CM - Convenio Marco",
+    "10": "FG - Trato Directo (Art. 8 f y g)",
+    "12": "MC - Microcompra",
+    "13": "AG - Compra Ágil",
+    "14": "CC - Compra Coordinada"
+}
+
+def map_raw_to_oc(item: Dict[str, Any]) -> PurchaseOrder:
+    # Handle items
+    items_list = []
+    raw_items = item.get("Items", {})
+    if isinstance(raw_items, dict) and "Listado" in raw_items:
+        for i in raw_items["Listado"]:
+            items_list.append(OCItem(
+                correlative=i.get("Correlativo"),
+                product_code=str(i.get("CodigoProducto", "")),
+                name=i.get("Nombre", ""),
+                description=i.get("EspecificacionComprador"),
+                quantity=float(i.get("Cantidad", 0)),
+                unit=i.get("Unidad"),
+                price=float(i.get("PrecioNeto", 0)),
+                total=float(i.get("TotalNeto", 0))
+            ))
+
+    def parse_dt(dt_str):
+        if not dt_str: return None
+        try:
+            return datetime.fromisoformat(dt_str.replace("Z", "").split(".")[0])
+        except:
+            return None
+
+    return PurchaseOrder(
+        code=item.get("Codigo", ""),
+        name=item.get("Nombre", ""),
+        status=item.get("Estado", "Desconocido"),
+        status_code=str(item.get("CodigoEstado", "")),
+        buyer=item.get("Comprador", {}).get("NombreOrganismo", "Unknown"),
+        buyer_rut=item.get("Comprador", {}).get("RutUnidad"),
+        provider=item.get("Proveedor", {}).get("Nombre", "Unknown"),
+        provider_rut=item.get("Proveedor", {}).get("Rut", ""),
+        date_creation=parse_dt(item.get("Fechas", {}).get("FechaCreacion")),
+        total_amount=float(item.get("Total", 0)),
+        currency=item.get("Moneda"),
+        type=item.get("Tipo"),
+        items=items_list,
+        raw_data=item
+    )
+
+async def _fetch_oc(params: Dict[str, str]) -> List[PurchaseOrder]:
+    if not settings.mercado_publico_ticket:
+        return []
+    
+    params["ticket"] = settings.mercado_publico_ticket
+    
+    try:
+        async with httpx.AsyncClient(timeout=45.0) as client:
+            response = await client.get(API_BASE_OC, params=params)
+            response.raise_for_status()
+            data = response.json()
+            
+            raw_list = data.get("Listado", [])
+            if not raw_list:
+                return []
+            
+            return [map_raw_to_oc(item) for item in raw_list]
+    except Exception as e:
+        print(f"❌ OC API Error: {e}")
+        return []
+
+async def get_oc_by_code(code: str) -> Optional[PurchaseOrder]:
+    results = await _fetch_oc({"codigo": code})
+    return results[0] if results else None
+
+async def get_ocs_by_date(date: str, status: str = "todos") -> List[PurchaseOrder]:
+    return await _fetch_oc({"fecha": date, "estado": status})
+
+async def get_ocs_by_provider(provider_code: str, date: str) -> List[PurchaseOrder]:
+    return await _fetch_oc({"CodigoProveedor": provider_code, "fecha": date})

backend/scratch_test_oc.py

@@ -0,0 +1,45 @@
+import httpx
+import asyncio
+import json
+import os
+from dotenv import load_dotenv
+
+load_dotenv()
+
+async def test_oc_api():
+    ticket = os.getenv("MERCADO_PUBLICO_TICKET")
+    if not ticket:
+        print("No ticket found in .env")
+        return
+
+    # 1. Fetch today's OCs
+    url_list = f"https://api.mercadopublico.cl/servicios/v1/publico/ordenesdecompra.json?ticket={ticket}"
+    print(f"Fetching OCs: {url_list}")
+    
+    async with httpx.AsyncClient(timeout=30) as client:
+        try:
+            resp = await client.get(url_list)
+            data = resp.json()
+            items = data.get("Listado", [])
+            print(f"Found {len(items)} OCs today.")
+            
+            if items:
+                code = items[0].get("Codigo")
+                print(f"Fetching details for OC code: {code}")
+                
+                url_detail = f"https://api.mercadopublico.cl/servicios/v1/publico/ordenesdecompra.json?codigo={code}&ticket={ticket}"
+                resp_detail = await client.get(url_detail)
+                detail_data = resp_detail.json()
+                
+                print("OC Detail sample:")
+                # print(json.dumps(detail_data, indent=2))
+                
+                with open("oc_sample_detail.json", "w") as f:
+                    json.dump(detail_data, f, indent=2)
+                print("Saved to oc_sample_detail.json")
+                    
+        except Exception as e:
+            print(f"Error: {e}")
+
+if __name__ == "__main__":
+    asyncio.run(test_oc_api())

frontend/app/page.tsx

@@ -10,6 +10,7 @@ import Reports from "../components/Reports";
 import Sidebar from "../components/Sidebar";
 import AnalysisHistory from "../components/AnalysisHistory";
 import GlobalSync from "../components/GlobalSync";
+import MarketMonitor from "../components/MarketMonitor";
 import SystemInfo from "../components/SystemInfo";
 import { analyzeTender, fetchAnalysisHistory, fetchCompanyProfile, healthCheck, saveCompanyProfile, searchTenders } from "../lib/api";
 import type { AnalysisHistoryItem, AnalysisResult, CompanyProfile as CompanyProfileType, Tender } from "../lib/types";
@@ -19,6 +20,7 @@ const tabs = [
   "Dashboard",
   "Tender Search",
   "My Portfolio",
+  "Market Monitor",
   "Company Profile",
   "Agent Analysis",
   "Proposal Draft",
@@ -256,6 +258,7 @@ export default function HomePage() {
                 lang={lang}
               />
             )}
+            {activeTab === "Market Monitor" && <MarketMonitor />}
             {activeTab === "Company Profile" && (
               <CompanyProfile profile={companyProfile} onSave={handleProfileSave} />
             )}

frontend/components/MarketMonitor.tsx

@@ -0,0 +1,138 @@
+"use client";
+
+import { useEffect, useState } from "react";
+import { fetchPurchaseOrders } from "../lib/api";
+import { PurchaseOrder } from "../lib/types";
+import BrandLoader from "./BrandLoader";
+
+export default function MarketMonitor() {
+  const [ocs, setOcs] = useState<PurchaseOrder[]>([]);
+  const [isLoading, setIsLoading] = useState(true);
+  const [filter, setFilter] = useState("todos");
+
+  useEffect(() => {
+    loadOcs();
+  }, [filter]);
+
+  async function loadOcs() {
+    setIsLoading(true);
+    try {
+      const data = await fetchPurchaseOrders(undefined, filter);
+      setOcs(data);
+    } catch (e) {
+      console.error(e);
+    } finally {
+      setIsLoading(false);
+    }
+  }
+
+  const formatCurrency = (amount: number | null, currency: string | null) => {
+    if (amount === null) return "---";
+    return new Intl.NumberFormat("es-CL", {
+      style: "currency",
+      currency: currency || "CLP",
+      maximumFractionDigits: 0
+    }).format(amount);
+  };
+
+  return (
+    <div className="space-y-8 animate-in fade-in duration-700">
+      <div className="flex flex-col md:flex-row md:items-center justify-between gap-6">
+        <div>
+          <p className="text-[10px] uppercase tracking-[0.4em] text-cyan/60 font-black mb-2">Real-Time Intelligence</p>
+          <h2 className="text-4xl font-black text-white tracking-tight">Market Monitor</h2>
+          <p className="text-slate-400 text-sm mt-2 max-w-xl">
+            Monitor real-time Purchase Orders (OCs) issued by public organizations. 
+            Identify high-velocity buying patterns and competitive wins.
+          </p>
+        </div>
+
+        <div className="flex bg-slate-900/50 p-1 rounded-2xl border border-white/5 backdrop-blur-xl">
+          {["todos", "aceptada", "enviadaproveedor"].map((f) => (
+            <button
+              key={f}
+              onClick={() => setFilter(f)}
+              className={`px-6 py-2.5 rounded-xl text-[10px] uppercase font-black tracking-widest transition-all ${
+                filter === f ? "bg-cyan text-slate-950 shadow-lg shadow-cyan/20" : "text-slate-500 hover:text-white"
+              }`}
+            >
+              {f === "todos" ? "Live Stream" : f}
+            </button>
+          ))}
+        </div>
+      </div>
+
+      <div className="grid gap-6">
+        {isLoading ? (
+          <div className="py-20">
+            <BrandLoader />
+          </div>
+        ) : ocs.length > 0 ? (
+          <div className="glass-card rounded-[2rem] overflow-hidden border border-white/5">
+            <div className="overflow-x-auto custom-scrollbar">
+              <table className="w-full text-left text-xs border-collapse">
+                <thead>
+                  <tr className="bg-white/5 text-slate-500 uppercase font-black tracking-tighter border-b border-white/5">
+                    <th className="px-6 py-5">Issue Date</th>
+                    <th className="px-6 py-5">Order ID / Description</th>
+                    <th className="px-6 py-5">Buyer Organism</th>
+                    <th className="px-6 py-5">Vendor (Winner)</th>
+                    <th className="px-6 py-5 text-right">Total Amount</th>
+                  </tr>
+                </thead>
+                <tbody className="divide-y divide-white/5">
+                  {ocs.map((oc) => (
+                    <tr key={oc.code} className="hover:bg-white/[0.03] transition-colors group">
+                      <td className="px-6 py-5 whitespace-nowrap">
+                        <div className="text-slate-300 font-mono">
+                          {oc.date_creation ? new Date(oc.date_creation).toLocaleTimeString([], { hour: '2-digit', minute: '2-digit' }) : '---'}
+                        </div>
+                        <div className="text-[10px] text-slate-600">
+                           {oc.date_creation ? new Date(oc.date_creation).toLocaleDateString() : 'Today'}
+                        </div>
+                      </td>
+                      <td className="px-6 py-5 max-w-md">
+                        <div className="flex items-center gap-2 mb-1">
+                          <span className="text-cyan font-bold font-mono text-[10px] bg-cyan/5 px-2 py-0.5 rounded border border-cyan/10">
+                            {oc.code}
+                          </span>
+                          {oc.type && (
+                            <span className="text-[8px] bg-white/5 text-slate-500 px-1.5 py-0.5 rounded uppercase font-black">
+                              {oc.type}
+                            </span>
+                          )}
+                        </div>
+                        <div className="text-white font-bold truncate group-hover:text-cyan transition-colors">
+                          {oc.name || "Orden de Compra"}
+                        </div>
+                      </td>
+                      <td className="px-6 py-5">
+                        <div className="text-slate-300 font-medium truncate max-w-[200px]">{oc.buyer}</div>
+                        <div className="text-[10px] text-slate-600">{oc.buyer_rut}</div>
+                      </td>
+                      <td className="px-6 py-5">
+                        <div className="text-sky-400 font-bold truncate max-w-[200px]">{oc.provider}</div>
+                        <div className="text-[10px] text-slate-600">{oc.provider_rut}</div>
+                      </td>
+                      <td className="px-6 py-5 text-right">
+                        <div className="text-white font-black text-sm">
+                          {formatCurrency(oc.total_amount, oc.currency)}
+                        </div>
+                        <div className="text-[10px] text-slate-500 uppercase font-bold">{oc.currency}</div>
+                      </td>
+                    </tr>
+                  ))}
+                </tbody>
+              </table>
+            </div>
+          </div>
+        ) : (
+          <div className="py-40 text-center glass-card rounded-[2rem] border border-white/5">
+            <div className="text-4xl mb-4">🛒</div>
+            <p className="text-slate-500 font-medium italic">No purchase orders detected in the last hour.</p>
+          </div>
+        )}
+      </div>
+    </div>
+  );
+}

frontend/components/Sidebar.tsx

@@ -7,6 +7,7 @@ type SidebarTab =
   | "Dashboard"
   | "Tender Search"
   | "My Portfolio"
+  | "Market Monitor"
   | "Company Profile"
   | "Agent Analysis"
   | "Proposal Draft"
@@ -33,6 +34,7 @@ export default function Sidebar({ tabs, activeTab, onTabSelect, status, lang, fo
       case "Dashboard": return { label: t.dashboard, icon: "📊" };
       case "Tender Search": return { label: t.tenderSearch, icon: "📡" };
       case "My Portfolio": return { label: t.myPortfolio, icon: "★" };
+      case "Market Monitor": return { label: "Market Monitor", icon: "🛒" };
       case "Company Profile": return { label: t.companyProfile, icon: "🏢" };
       case "Agent Analysis": return { label: t.agentAnalysis, icon: "🤖" };
       case "Proposal Draft": return { label: t.proposalDraft, icon: "✍️" };

frontend/lib/api.ts

@@ -122,3 +122,15 @@ export async function scrapeTenders(keyword: string): Promise<Tender[]> {
   }
   return res.json();
 }
+
+export async function fetchPurchaseOrders(date?: string, status: string = "todos"): Promise<PurchaseOrder[]> {
+  const query = new URLSearchParams();
+  if (date) query.append("date", date);
+  query.append("status", status);
+  
+  const res = await fetch(`${API_BASE}/api/purchase-orders?${query.toString()}`);
+  if (!res.ok) {
+    throw new Error("Error fetching purchase orders");
+  }
+  return res.json();
+}

frontend/lib/types.ts

@@ -70,6 +70,33 @@ export type AnalysisResult = {
   audit_log: string[];
 };
 
+export type OCItem = {
+  correlative?: number;
+  product_code?: string;
+  name: string;
+  description?: string;
+  quantity: number;
+  unit: string;
+  price?: number;
+  total?: number;
+};
+
+export type PurchaseOrder = {
+  code: string;
+  name: string;
+  status: string;
+  status_code?: string;
+  buyer: string;
+  buyer_rut?: string;
+  provider: string;
+  provider_rut?: string;
+  date_creation: string | null;
+  total_amount: number | null;
+  currency: string | null;
+  type?: string;
+  items?: OCItem[];
+};
+
 export type AnalysisHistoryItem = {
   tender_code: string;
   tender_name: string;