from fastapi import FastAPI, HTTPException, Header, Depends, Query
from fastapi.middleware.cors import CORSMiddleware
from pydantic import BaseModel, Field
from typing import Optional, List, Dict
from datetime import datetime, date
from enum import Enum
import uvicorn
import logging

from config import settings, validate_settings
from sage_connector import SageConnector

# =====================================================
# LOGGING
# =====================================================
logging.basicConfig(
    level=logging.INFO,
    format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
    handlers=[
        logging.FileHandler("sage_gateway.log"),
        logging.StreamHandler()
    ]
)
logger = logging.getLogger(__name__)

# =====================================================
# ENUMS
# =====================================================
class TypeDocument(int, Enum):
    DEVIS = 0
    BON_LIVRAISON = 1
    BON_RETOUR = 2
    COMMANDE = 3
    PREPARATION = 4
    FACTURE = 5

# =====================================================
# MODÈLES
# =====================================================
class FiltreRequest(BaseModel):
    filtre: Optional[str] = ""

class CodeRequest(BaseModel):
    code: str

class ChampLibreRequest(BaseModel):
    doc_id: str
    type_doc: int
    nom_champ: str
    valeur: str

class DevisRequest(BaseModel):
    client_id: str
    date_devis: Optional[date] = None
    lignes: List[Dict]  # Format: {article_code, quantite, prix_unitaire_ht, remise_pourcentage}

class TransformationRequest(BaseModel):
    numero_source: str
    type_source: int
    type_cible: int

class StatutRequest(BaseModel):
    nouveau_statut: int

# =====================================================
# SÉCURITÉ
# =====================================================
def verify_token(x_sage_token: str = Header(...)):
    """Vérification du token d'authentification"""
    if x_sage_token != settings.sage_gateway_token:
        logger.warning(f"❌ Token invalide reçu: {x_sage_token[:20]}...")
        raise HTTPException(401, "Token invalide")
    return True

# =====================================================
# APPLICATION
# =====================================================
app = FastAPI(
    title="Sage Gateway - Windows Server",
    version="1.0.0",
    description="Passerelle d'accès à Sage 100c pour VPS Linux"
)

app.add_middleware(
    CORSMiddleware,
    allow_origins=settings.cors_origins,
    allow_methods=["*"],
    allow_headers=["*"],
    allow_credentials=True
)

sage: Optional[SageConnector] = None

# =====================================================
# LIFECYCLE
# =====================================================
@app.on_event("startup")
def startup():
    global sage
    
    logger.info("🚀 Démarrage Sage Gateway Windows...")
    
    # Validation config
    try:
        validate_settings()
        logger.info("✅ Configuration validée")
    except ValueError as e:
        logger.error(f"❌ Configuration invalide: {e}")
        raise
    
    # Connexion Sage
    sage = SageConnector(
        settings.chemin_base,
        settings.utilisateur,
        settings.mot_de_passe
    )
    
    if not sage.connecter():
        raise RuntimeError("❌ Impossible de se connecter à Sage 100c")
    
    logger.info("✅ Sage Gateway démarré et connecté")

@app.on_event("shutdown")
def shutdown():
    if sage:
        sage.deconnecter()
    logger.info("👋 Sage Gateway arrêté")

# =====================================================
# ENDPOINTS - SYSTÈME
# =====================================================
@app.get("/health")
def health():
    """Health check"""
    return {
        "status": "ok",
        "sage_connected": sage is not None and sage.cial is not None,
        "cache_info": sage.get_cache_info() if sage else None,
        "timestamp": datetime.now().isoformat()
    }

# =====================================================
# ENDPOINTS - CLIENTS
# =====================================================
@app.post("/sage/clients/list", dependencies=[Depends(verify_token)])
def clients_list(req: FiltreRequest):
    """Liste des clients avec filtre optionnel"""
    try:
        clients = sage.lister_tous_clients(req.filtre)
        return {"success": True, "data": clients}
    except Exception as e:
        logger.error(f"Erreur liste clients: {e}")
        raise HTTPException(500, str(e))

@app.post("/sage/clients/get", dependencies=[Depends(verify_token)])
def client_get(req: CodeRequest):
    """Lecture d'un client par code"""
    try:
        client = sage.lire_client(req.code)
        if not client:
            raise HTTPException(404, f"Client {req.code} non trouvé")
        return {"success": True, "data": client}
    except HTTPException:
        raise
    except Exception as e:
        logger.error(f"Erreur lecture client: {e}")
        raise HTTPException(500, str(e))

# =====================================================
# ENDPOINTS - ARTICLES
# =====================================================
@app.post("/sage/articles/list", dependencies=[Depends(verify_token)])
def articles_list(req: FiltreRequest):
    """Liste des articles avec filtre optionnel"""
    try:
        articles = sage.lister_tous_articles(req.filtre)
        return {"success": True, "data": articles}
    except Exception as e:
        logger.error(f"Erreur liste articles: {e}")
        raise HTTPException(500, str(e))

@app.post("/sage/articles/get", dependencies=[Depends(verify_token)])
def article_get(req: CodeRequest):
    """Lecture d'un article par référence"""
    try:
        article = sage.lire_article(req.code)
        if not article:
            raise HTTPException(404, f"Article {req.code} non trouvé")
        return {"success": True, "data": article}
    except HTTPException:
        raise
    except Exception as e:
        logger.error(f"Erreur lecture article: {e}")
        raise HTTPException(500, str(e))

# =====================================================
# ENDPOINTS - DEVIS
# =====================================================
@app.post("/sage/devis/create", dependencies=[Depends(verify_token)])
def creer_devis(req: DevisRequest):
    """Création d'un devis"""
    try:
        # Transformer en format attendu par sage_connector
        devis_data = {
            "client": {"code": req.client_id, "intitule": ""},
            "date_devis": req.date_devis or date.today(),
            "lignes": req.lignes
        }
        
        resultat = sage.creer_devis_enrichi(devis_data)
        return {"success": True, "data": resultat}
    except Exception as e:
        logger.error(f"Erreur création devis: {e}")
        raise HTTPException(500, str(e))

@app.post("/sage/devis/get", dependencies=[Depends(verify_token)])
def lire_devis(req: CodeRequest):
    """Lecture d'un devis"""
    try:
        devis = sage.lire_devis(req.code)
        if not devis:
            raise HTTPException(404, f"Devis {req.code} non trouvé")
        return {"success": True, "data": devis}
    except HTTPException:
        raise
    except Exception as e:
        logger.error(f"Erreur lecture devis: {e}")
        raise HTTPException(500, str(e))

@app.post("/sage/devis/statut", dependencies=[Depends(verify_token)])
def changer_statut_devis(doc_id: str, req: StatutRequest):
    """Changement de statut d'un devis"""
    try:
        # Implémenter via sage_connector
        # (À ajouter dans sage_connector si manquant)
        return {"success": True, "message": "Statut mis à jour"}
    except Exception as e:
        logger.error(f"Erreur MAJ statut: {e}")
        raise HTTPException(500, str(e))

# =====================================================
# ENDPOINTS - DOCUMENTS
# =====================================================
@app.post("/sage/documents/get", dependencies=[Depends(verify_token)])
def lire_document(numero: str, type_doc: int):
    """Lecture d'un document (commande, facture, etc.)"""
    try:
        doc = sage.lire_document(numero, type_doc)
        if not doc:
            raise HTTPException(404, f"Document {numero} non trouvé")
        return {"success": True, "data": doc}
    except HTTPException:
        raise
    except Exception as e:
        logger.error(f"Erreur lecture document: {e}")
        raise HTTPException(500, str(e))

@app.post("/sage/documents/transform", dependencies=[Depends(verify_token)])
def transformer_document(req: TransformationRequest):
    """Transformation de document (devis → commande, etc.)"""
    try:
        resultat = sage.transformer_document(
            req.numero_source,
            req.type_source,
            req.type_cible
        )
        return {"success": True, "data": resultat}
    except Exception as e:
        logger.error(f"Erreur transformation: {e}")
        raise HTTPException(500, str(e))

@app.post("/sage/documents/champ-libre", dependencies=[Depends(verify_token)])
def maj_champ_libre(req: ChampLibreRequest):
    """Mise à jour d'un champ libre"""
    try:
        success = sage.mettre_a_jour_champ_libre(
            req.doc_id,
            req.type_doc,
            req.nom_champ,
            req.valeur
        )
        return {"success": success}
    except Exception as e:
        logger.error(f"Erreur MAJ champ libre: {e}")
        raise HTTPException(500, str(e))

# =====================================================
# ENDPOINTS - CONTACTS
# =====================================================
@app.post("/sage/contact/read", dependencies=[Depends(verify_token)])
def contact_read(req: CodeRequest):
    """Lecture du contact principal d'un client"""
    try:
        contact = sage.lire_contact_principal_client(req.code)
        if not contact:
            raise HTTPException(404, f"Contact non trouvé pour client {req.code}")
        return {"success": True, "data": contact}
    except HTTPException:
        raise
    except Exception as e:
        logger.error(f"Erreur lecture contact: {e}")
        raise HTTPException(500, str(e))

# =====================================================
# ENDPOINTS - ADMIN
# =====================================================
@app.post("/sage/cache/refresh", dependencies=[Depends(verify_token)])
def refresh_cache():
    """Force le rafraîchissement du cache"""
    try:
        sage.forcer_actualisation_cache()
        return {
            "success": True,
            "message": "Cache actualisé",
            "info": sage.get_cache_info()
        }
    except Exception as e:
        logger.error(f"Erreur refresh cache: {e}")
        raise HTTPException(500, str(e))

@app.get("/sage/cache/info", dependencies=[Depends(verify_token)])
def cache_info():
    """Informations sur le cache"""
    try:
        return {"success": True, "data": sage.get_cache_info()}
    except Exception as e:
        logger.error(f"Erreur info cache: {e}")
        raise HTTPException(500, str(e))

# =====================================================
# LANCEMENT
# =====================================================
if __name__ == "__main__":
    uvicorn.run(
        "main:app",
        host=settings.api_host,
        port=settings.api_port,
        reload=False,  # Pas de reload en production
        log_level="info"
    )