340 lines
No EOL
11 KiB
Python
340 lines
No EOL
11 KiB
Python
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"
|
|
) |