george/descarga_factura_transporte
1
0 Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

se migran los print de los módulos a logging con nivel explícito

Browse Source 
pipeline_utils.log pasa a usar logging (parámetro severity) y los print de
pipeline, sapb1_manager, hana_manager, outlook_utilities, email_utilities y
main pasan a logger.info/warning/error, de modo que LOG_LEVEL filtre por
severidad. El texto del log no cambia. Se mantienen los print de CLI en
sunat_schema (__main__), tools/ y tests/.

Co-Authored-By: Claude Sonnet 5.5 <noreply@anthropic.com>
This commit is contained in:
GeorgeandClaude Sonnet 5.5 committed 2026-10-20 22:03:38 -05:00
1 parent 5ef9c90fc0
commit 3fa26e3ef6
11 files changed
+109 -79
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

sapb1_manager.py
+29 -26
View File
@@ -1,4 +1,5 @@
import logging
import requests
import urllib3
import os
@@ -7,6 +8,8 @@ from typing import Optional, Dict, Any
from dotenv import load_dotenv
import hana_manager
logger = logging.getLogger(__name__)
# ============================================================================
# CONFIGURACIÓN
@@ -37,7 +40,7 @@ def login() -> dict:
"UserName": SAPB1_USER,
"Password": SAPB1_PASSWORD,
}
print("🔐 Iniciando sesión en SAP B1 Service Layer...")
logger.info("🔐 Iniciando sesión en SAP B1 Service Layer...")
resp = requests.post(
f"{SAPB1_URL}/Login",
json=payload,
@@ -55,7 +58,7 @@ def login() -> dict:
headers = {"Cookie": f"B1SESSION={b1session}; ROUTEID={routeid}"}
_sap_session.update({"headers": headers, "b1session": b1session, "routeid": routeid})
print(f"✅ Sesión SAP B1 establecida (B1SESSION: {b1session[:10]}...)")
logger.info(f"✅ Sesión SAP B1 establecida (B1SESSION: {b1session[:10]}...)")
return headers
@@ -64,9 +67,9 @@ def login() -> dict:
# ============================================================================
def logout() -> None:
if not _sap_session["b1session"]:
print("⚠️ No hay sesión activa para cerrar.")
logger.warning("⚠️ No hay sesión activa para cerrar.")
return
print("🔓 Cerrando sesión SAP B1...")
logger.info("🔓 Cerrando sesión SAP B1...")
try:
resp = requests.post(
f"{SAPB1_URL}/Logout",
@@ -75,11 +78,11 @@ def logout() -> None:
verify=SAPB1_VERIFY_SSL,
)
if resp.status_code == 200:
print("✅ Sesión SAP B1 cerrada correctamente.")
logger.info("✅ Sesión SAP B1 cerrada correctamente.")
else:
print(f"⚠️ Logout respondió HTTP {resp.status_code}")
logger.warning(f"⚠️ Logout respondió HTTP {resp.status_code}")
except Exception as exc:
print(f"❌ Error al cerrar sesión: {exc}")
logger.error(f"❌ Error al cerrar sesión: {exc}")
finally:
_sap_session.update({"headers": None, "b1session": None, "routeid": None})
@@ -102,9 +105,9 @@ def _log_response(method: str, endpoint: str, response: requests.Response, paylo
f" ({len(response.content)} bytes)"
)
if response.status_code >= 400:
print(f"⚠️ {log_line} - {response.text[:300]}")
logger.warning(f"⚠️ {log_line} - {response.text[:300]}")
else:
print(log_line)
logger.info(log_line)
# ============================================================================
@@ -133,7 +136,7 @@ def forward_to_sapb1(
if extra_headers:
req_headers.update(extra_headers)
print(f" ├── 🔄 [{method}] {endpoint_path}")
logger.info(f" ├── 🔄 [{method}] {endpoint_path}")
try:
resp = requests.request(
@@ -153,7 +156,7 @@ def forward_to_sapb1(
raise ConnectionError(f"Error en solicitud HTTP: {exc}")
if resp.status_code == 401:
print("⚠️ Sesión expirada (401). Reautenticando e intentando una vez...")
logger.warning("⚠️ Sesión expirada (401). Reautenticando e intentando una vez...")
req_headers["Cookie"] = login()["Cookie"]
resp = requests.request(
method=method,
@@ -191,7 +194,7 @@ def forward_to_sapb1(
def create_draft(payload: dict) -> dict:
resp = forward_to_sapb1("POST", "Drafts", json_data=payload)
result = resp.json()
print(f" ├── ✅ Draft creado DocEntry={result.get('DocEntry')}")
logger.info(f" ├── ✅ Draft creado DocEntry={result.get('DocEntry')}")
return result
@@ -201,7 +204,7 @@ def create_draft(payload: dict) -> dict:
def get_purchase_invoice(doc_entry: int) -> dict:
resp = forward_to_sapb1("GET", f"PurchaseInvoices({doc_entry})")
result = resp.json()
print(f" ├── ✅ PurchaseInvoices({doc_entry}) obtenida")
logger.info(f" ├── ✅ PurchaseInvoices({doc_entry}) obtenida")
return result
# ============================================================================
@@ -249,7 +252,7 @@ def get_delivery_notes(tipo: str, serie: str, numero: str) -> list:
entries = _get_delivery_entries(tipo, serie, numero)
if not entries:
print(f" │ ⚠️ Guía {codigo}: sin registros en SAP (SL + HANA)")
logger.warning(f" │ ⚠️ Guía {codigo}: sin registros en SAP (SL + HANA)")
return []
# ── Fase 2: Obtener documento completo por cada DocEntry ─────────────
@@ -260,20 +263,20 @@ def get_delivery_notes(tipo: str, serie: str, numero: str) -> list:
try:
resp = forward_to_sapb1("GET", f"{entidad}({doc_entry})")
doc = resp.json()
print(f" │ └─ {entidad}({doc_entry}) obtenido")
logger.info(f" │ └─ {entidad}({doc_entry}) obtenido")
if entidad == "StockTransfers":
num_ov = doc.get("U_IDC_NUMOV")
if not num_ov:
print(f" │ ⚠️ StockTransfers({doc_entry}) sin U_IDC_NUMOV: no se puede validar precios")
logger.warning(f" │ ⚠️ StockTransfers({doc_entry}) sin U_IDC_NUMOV: no se puede validar precios")
continue
resp_ov = forward_to_sapb1("GET", f"Orders({num_ov})")
doc = resp_ov.json()
print(f" │ └─ Orders({num_ov}) obtenido (Orden de Venta de StockTransfers({doc_entry}))")
logger.info(f" │ └─ Orders({num_ov}) obtenido (Orden de Venta de StockTransfers({doc_entry}))")
docs.append(doc)
except Exception as e:
print(f" │ ⚠️ Error obteniendo {entidad}({doc_entry}): {e}")
logger.warning(f" │ ⚠️ Error obteniendo {entidad}({doc_entry}): {e}")
return docs
@@ -302,13 +305,13 @@ def _get_delivery_entries(tipo: str, serie: str, numero: str) -> list:
if sl_entries:
for sl_entry in sl_entries:
sl_entry["Entidad"] = "DeliveryNotes"
print(f" │ 🔍 Guía {codigo}: SL → {len(sl_entries)} DocEntry encontrados")
logger.info(f" │ 🔍 Guía {codigo}: SL → {len(sl_entries)} DocEntry encontrados")
return sl_entries
print(f" │ 🔍 Guía {codigo}: SL → 0 resultados. Consultando HANA...")
logger.info(f" │ 🔍 Guía {codigo}: SL → 0 resultados. Consultando HANA...")
except Exception as e:
print(f" │ ⚠️ Guía {codigo}: SL falló ({e}). Consultando HANA...")
logger.warning(f" │ ⚠️ Guía {codigo}: SL falló ({e}). Consultando HANA...")
# ── Fallback a HANA ──────────────────────────────────────────────────
try:
@@ -318,11 +321,11 @@ def _get_delivery_entries(tipo: str, serie: str, numero: str) -> list:
hana_entry["Entidad"] = _TABLA_A_ENTIDAD_SL.get(
hana_entry.get("Tabla"), "DeliveryNotes"
)
print(f" │ 🔍 Guía {codigo}: HANA → {len(hana_entries)} DocEntry encontrados")
logger.info(f" │ 🔍 Guía {codigo}: HANA → {len(hana_entries)} DocEntry encontrados")
return hana_entries
print(f" │ 🔍 Guía {codigo}: HANA → 0 registros")
logger.info(f" │ 🔍 Guía {codigo}: HANA → 0 registros")
except Exception as e:
print(f" │ ⚠️ Guía {codigo}: HANA falló ({e})")
logger.warning(f" │ ⚠️ Guía {codigo}: HANA falló ({e})")
return []
@@ -361,7 +364,7 @@ def obtener_condicion_pago(card_code: str) -> dict | None:
"NumberOfAdditionalDays": terms.get("NumberOfAdditionalDays") or 0,
}
except Exception as e:
print(f" │ ⚠️ Error obteniendo condición de pago de {card_code}: {e}")
logger.warning(f" │ ⚠️ Error obteniendo condición de pago de {card_code}: {e}")
return None
# ============================================================================
@@ -394,5 +397,5 @@ def get_zonas() -> list:
)
result = resp.json()
value = result.get("value", [])
print(f" ├── ✅ U_IDC_ZONAS obtenida ({len(value)} registros)")
logger.info(f" ├── ✅ U_IDC_ZONAS obtenida ({len(value)} registros)")
return value