Michael/CollectFlow
1
0 Fork 0
mirror of https://github.com/R0m1k3/CollectFlow.git synced 2026-10-22 22:48:08 +02:00
Code Issues Packages Projects Releases Wiki Activity

feat: implement PostgreSQL client to replace per-article HTTP API calls with bulk SQL queries for FF Nancy data.

Browse Source
This commit is contained in:
Michael committed 2026-03-20 13:31:19 +01:00
1 parent dd846247c9
commit 4996e126b3
1 file changed
+6 -3
Download Patch File Download Diff File Expand all files Collapse all files
src/lib/pg-ff-client.ts
+6 -3
View File
@@ -73,10 +73,11 @@ export interface PgRankingRow {
export async function pgGetFournisseurs(search?: string): Promise<{ code: string; nom: string }[]> { export async function pgGetFournisseurs(search?: string): Promise<{ code: string; nom: string }[]> {
try { try {
const result = await db.execute(sql` const result = await db.execute(sql`
SELECT SELECT DISTINCT
fi.code, fi.code,
fi.nom fi.nom
FROM fouident fi FROM fouident fi
INNER JOIN artfou1 af ON af.code = fi.code
WHERE fi.actif = true WHERE fi.actif = true
AND fi.suspendu = false AND fi.suspendu = false
AND fi.code IS NOT NULL AND fi.code IS NOT NULL
@@ -84,9 +85,10 @@ export async function pgGetFournisseurs(search?: string): Promise<{ code: string
${search ? sql`AND (fi.nom ILIKE ${'%' + search + '%'} OR fi.code ILIKE ${'%' + search + '%'})` : sql``} ${search ? sql`AND (fi.nom ILIKE ${'%' + search + '%'} OR fi.code ILIKE ${'%' + search + '%'})` : sql``}
ORDER BY fi.nom ORDER BY fi.nom
`); `);
console.log(`[pg-ff] pgGetFournisseurs (fouident): ${result.rows.length} fournisseurs`);
return (result.rows as unknown as { code: string; nom: string }[]).filter(r => r.code && r.nom); return (result.rows as unknown as { code: string; nom: string }[]).filter(r => r.code && r.nom);
} catch (e) { } catch (e) {
console.error("[pg-ff] pgGetFournisseurs error:", e); console.error("[pg-ff] pgGetFournisseurs fouident error:", (e as Error).message?.slice(0, 200));
// Fallback : fouident inaccessible → fouadr1 avec artfou1 // Fallback : fouident inaccessible → fouadr1 avec artfou1
try { try {
const fallback = await db.execute(sql` const fallback = await db.execute(sql`
@@ -194,7 +196,8 @@ export async function pgGetMensuelByFournisseur(
-- qte_vendue nette = SUM(-qtemvt) : ventes moins retours -- qte_vendue nette = SUM(-qtemvt) : ventes moins retours
SUM(CASE WHEN m.genremvt = 3 THEN -m.qtemvt ELSE 0 END)::float AS qte_vendue, SUM(CASE WHEN m.genremvt = 3 THEN -m.qtemvt ELSE 0 END)::float AS qte_vendue,
SUM(CASE WHEN m.genremvt = 3 THEN -m.mntmvtttc ELSE 0 END)::float AS ca_ht, SUM(CASE WHEN m.genremvt = 3 THEN -m.mntmvtttc ELSE 0 END)::float AS ca_ht,
SUM(CASE WHEN m.genremvt = 3 THEN -m.margemvt ELSE 0 END)::float AS marge, -- margemvt est positif pour les ventes (pas de négation)
SUM(CASE WHEN m.genremvt = 3 THEN m.margemvt ELSE 0 END)::float AS marge,
MAX(m.qtestock)::float AS stock_fin_mois, MAX(m.qtestock)::float AS stock_fin_mois,
SUM(CASE WHEN m.genremvt IN (1, 2) THEN -m.qtemvt ELSE 0 END)::float AS qte_recue SUM(CASE WHEN m.genremvt IN (1, 2) THEN -m.qtemvt ELSE 0 END)::float AS qte_recue
FROM mvtart m FROM mvtart m