feat: implement automated procurement synchronization and API endpoints for supply chain management

sync/db.js

@@ -24,6 +24,10 @@ let pgPool = null;
 async function getMssql() {
   if (!mssqlPool) {
     mssqlPool = await sql.connect(mssqlConfig);
+    mssqlPool.on('error', (err) => {
+      console.error('[mssql] Pool error, reconnexion au prochain appel:', err.message);
+      mssqlPool = null;
+    });
   }
   return mssqlPool;
 }

sync/tables/appro.js

@@ -29,11 +29,11 @@ const PLAN_REAPPRO_COLS = [
 ];
 
 async function syncAppro(force) {
-  const ms = await getMssql();
-  const pg  = getPg();
+  const pg = getPg();
 
   // === COMMANDE_FOU (upsert delta) ===
   try {
+    const ms = await getMssql();
     const lastSync = force ? null : await getLastSync(pg, 'commande_fou');
     const where    = lastSync ? `WHERE SUIVIDATEMODIF > '${lastSync.toISOString()}'` : '';
 
@@ -72,6 +72,7 @@ async function syncAppro(force) {
 
   // === CDEFOU_LIGNE (upsert delta) ===
   try {
+    const ms = await getMssql();
     const lastSync = force ? null : await getLastSync(pg, 'cdefou_ligne');
     const where    = lastSync ? `WHERE SUIVIDATEMODIF > '${lastSync.toISOString()}'` : '';