diff --git a/tests/kilometrage/run.mjs b/tests/kilometrage/run.mjs index ddca4e6..c255e54 100644 --- a/tests/kilometrage/run.mjs +++ b/tests/kilometrage/run.mjs @@ -3,7 +3,7 @@ // node tests/kilometrage/run.mjs --vues -> vues SQL, dans une transaction // ANNULEE (a lancer dans le // conteneur d'historisation) -import { lireReleves, ajouterReleve, creerSchemaKm } from '../../tools/kilometrage.mjs'; +import { lireReleves, ajouterReleve, creerSchemaKm, ingererJeep, JEEP } from '../../tools/kilometrage.mjs'; let ok = 0, ko = 0; const eq = (nom, a, b) => { @@ -31,6 +31,39 @@ eq('255 car max', b.length <= 255, true); eq('dernier garde', JSON.parse(b).at(-1)[1], 112703); eq('helper corrompu repart a vide', JSON.parse(ajouterReleve('pas du json', { vehicule: 'VW', km: 5, niveau: null, ts: new Date(T * 1000), source: 'ha' })).length, 1); +// --- ingererJeep : base simulee en memoire (04/10/2026) +{ + const base = { releves: [], niveaux: [], branche: new Date('2026-10-04T11:28:00Z') }; + const sql = async (q, v) => { + if (q.includes('INSERT INTO releve_km')) { base.releves.push({ ts: v[0], km: v[1], niveau: v[2] }); return { rowCount: 1 }; } + if (q.includes('INSERT INTO niveau_saisi')) { base.niveaux.push({ saisi_a: v[0], niveau: v[1] }); return { rowCount: 1 }; } + return { rowCount: 1 }; + }; + const lire = async (q, v) => { + if (q.includes('FROM releve_km')) { const r = [...base.releves].sort((a, b) => b.ts - a.ts); return { rows: r.length ? [{ km: r[0].km, ts: r[0].ts }] : [] }; } + if (q.includes('FROM evenement')) return { rows: [{ t: base.branche }] }; + if (q.includes('FROM niveau_saisi')) return { rows: base.niveaux.filter(n => n.saisi_a >= v[0]) }; + return { rows: [] }; + }; + const journ = async () => {}; + const etat = (km, niv, maj, branchee = 'on', borne = 'on') => new Map([ + [JEEP.odometre, { state: String(km) }], [JEEP.niveau, { state: String(niv) }], [JEEP.majA, { state: maj }], + [JEEP.branchee, { state: branchee }], ['binary_sensor.victron_evcs_vehicle_connected', { state: borne }], + ['input_number.victron_evcs_capacity_jeep_kwh', { state: '8.7' }], ['input_number.victron_evcs_autonomie_jeep_km', { state: '50' }]]); + await ingererJeep(sql, lire, etat(112716, 46, '2026-10-04T11:28:39+00:00'), journ); + eq('jeep : premier releve + niveau au branchement', [base.releves.length, base.niveaux.length, base.niveaux[0]?.niveau], [1, 1, 46]); + await ingererJeep(sql, lire, etat(112716, 60, '2026-10-04T11:58:39+00:00'), journ); + eq('jeep : compteur immobile et 2e maj du branchement -> rien', [base.releves.length, base.niveaux.length], [1, 1]); + base.branche = new Date('2026-10-05T16:00:00Z'); + await ingererJeep(sql, lire, etat(112760, 30, '2026-10-05T17:00:00+00:00'), journ); + eq('jeep : trajet -> releve ; maj 1 h apres le branchement -> pas de niveau', [base.releves.length, base.releves[1]?.km, base.niveaux.length], [2, 112760, 1]); + await ingererJeep(sql, lire, etat(112700, 30, '2026-10-05T18:00:00+00:00'), journ); + eq('jeep : compteur en baisse refuse', base.releves.length, 2); + base.branche = new Date('2026-10-06T16:00:00Z'); + await ingererJeep(sql, lire, etat(112800, 25, '2026-10-06T16:05:00+00:00', 'on', 'off'), journ); + eq('jeep : borne debranchee -> releve oui, niveau au branchement non', [base.releves.length, base.niveaux.length], [3, 1]); +} + if (process.argv.includes('--vues')) { const pg = (await import('pg')).default; const c = new pg.Client(); await c.connect(); diff --git a/tools/historise-evcs.mjs b/tools/historise-evcs.mjs index 1c95f08..22df8f4 100644 --- a/tools/historise-evcs.mjs +++ b/tools/historise-evcs.mjs @@ -29,7 +29,7 @@ import fs from 'node:fs'; import path from 'node:path'; import { fileURLToPath } from 'node:url'; import pg from 'pg'; -import { creerSchemaKm, ingererReleves, ingererNiveauSaisi } from './kilometrage.mjs'; +import { creerSchemaKm, ingererReleves, ingererNiveauSaisi, ingererJeep } from './kilometrage.mjs'; import { texteRapport, envoyer, donneesNuit, texteDepuis } from './rapport-nuit.mjs'; import { diagnosticPv, etatCellules, productionJour, chargeSolaire, bilanNuit, etatReseau, importJour, minuitLocal, COMPTEURS_IMPORT, COMPTEUR_EDF, consoJour, COMPTEURS_CONSO, projectionSoir, previsionNuit, vrmVersCourbes, nuitMaisonPrevue } from './diagnostics-agent.mjs'; @@ -93,6 +93,10 @@ const MESURES = [ // compteur de la borne, pour tracer « donne depuis 01:24 » contre le budget. 'input_number.evcs_balance_night_vehicle_budget_kwh', 'sensor.evcs_hq2239dnt7p_total_energy', + // Jeep lue par Uconnect (04/10/2026) + 'sensor.jeep_renegade_phev_odometer', + 'sensor.jeep_renegade_phev_hvbattery_charge', + 'sensor.jeep_renegade_phev_extrapolated_battery', ]; // --------------------------------------------------------------------- @@ -2136,6 +2140,8 @@ async function cycle(client) { console.error(`releves km en echec : ${e.message}`); return 0; }) + await ingererNiveauSaisi(sql, st).catch((e) => { console.error(`niveau saisi en echec : ${e.message}`); return 0; + }) + await ingererJeep(sql, (q, v) => client.query(q, v), st, journaliser).catch((e) => { + console.error(`jeep uconnect en echec : ${e.message}`); return 0; }), pvDiagnostic: DRY ? 0 : await publierDiagnosticPv(st).catch((e) => { console.error(`diagnostic PV en echec : ${e.message}`); return 0; diff --git a/tools/kilometrage.mjs b/tools/kilometrage.mjs index f29173c..c6bd21f 100644 --- a/tools/kilometrage.mjs +++ b/tools/kilometrage.mjs @@ -245,7 +245,9 @@ const rejetsJournalises = new Set(); export async function ingererNiveauSaisi(sql, st) { // L'attribut `timestamp` d'un input_datetime est en secondes epoch : pas de // fuseau a deviner (l'etat, lui, est une heure locale sans decalage). - const at = Number(st.get(NIVEAU_AT_ENTITY)?.attributes?.timestamp) * 1000; + // A la SECONDE : un redemarrage de HA restaure l'horodatage sans ses + // millisecondes, et la meme saisie revenait en double (04/10). + const at = Math.floor(Number(st.get(NIVEAU_AT_ENTITY)?.attributes?.timestamp)) * 1000; const niveau = Number(st.get(NIVEAU_ENTITY)?.state); const ref = Number(st.get(NIVEAU_REF_ENTITY)?.state); if (!Number.isFinite(at) || !Number.isInteger(niveau) || !Number.isFinite(ref) || ref <= 0) return 0; @@ -254,3 +256,70 @@ export async function ingererNiveauSaisi(sql, st) { [new Date(at), niveau, ref]); return r?.rowCount || 0; } + +// --------------------------------------------------------------------- +// JEEP LUE DIRECTEMENT (04/10/2026) : integration HACS hass-uconnect (API +// Stellantis non officielle, compte du proprietaire, intervalle 15 min, sans +// PIN ni entites de commande). La voiture publie un etat a chaque evenement +// (arret, branchement) : `last_info_update_at` date les valeurs. +// - RELEVE : un par changement d'odometre (fin de trajet), date de la mise a +// jour, avec le niveau HV a cet instant. Le compteur immobile ne produit rien. +// - NIVEAU AU BRANCHEMENT : la premiere mise a jour dans les 30 min apres le +// branchement de la borne, si la Jeep se dit branchee -> niveau_saisi +// (source uconnect). Une saisie humaine posterieure reste prioritaire (la +// vue prend la derniere saisie du branchement). +// --------------------------------------------------------------------- +export const JEEP = { + odometre: 'sensor.jeep_renegade_phev_odometer', + niveau: 'sensor.jeep_renegade_phev_hvbattery_charge', + majA: 'sensor.jeep_renegade_phev_last_info_update_at', + branchee: 'binary_sensor.jeep_renegade_phev_ev_charger', +}; + +export async function ingererJeep(sql, lire, st, journaliser) { + const km = Number(st.get(JEEP.odometre)?.state); + const niv = Number(st.get(JEEP.niveau)?.state); + const t = Date.parse(st.get(JEEP.majA)?.state ?? ''); + if (!Number.isFinite(t) || !Number.isInteger(km) || km <= 0) return 0; + const niveau = Number.isFinite(niv) && niv >= 0 && niv <= 100 ? Math.round(niv) : null; + const ts = new Date(t); + let n = 0; + const { rows: der } = await lire( + "SELECT km, ts FROM releve_km WHERE vehicule = 'JEEP' ORDER BY ts DESC LIMIT 1", []); + if (!der.length || (Number(der[0].km) !== km && ts > der[0].ts)) { + if (der.length && km < Number(der[0].km)) return 0; // compteur en baisse : on ne croit pas + const cap = Number(st.get('input_number.victron_evcs_capacity_jeep_kwh')?.state); + const auto = Number(st.get('input_number.victron_evcs_autonomie_jeep_km')?.state); + const r = await sql( + `INSERT INTO releve_km (vehicule, ts, km, niveau_pct, source, capacite_kwh, autonomie_ref_km, tout_electrique) + VALUES ('JEEP',$1,$2,$3,'uconnect',$4,$5,false) ON CONFLICT DO NOTHING`, + [ts, km, niveau, cap > 0 ? cap : null, auto > 0 ? auto : null]); + if (r?.rowCount) { + n++; + await journaliser(sql, 'vehicule', `Releve km JEEP ${km} km` + (niveau === null ? '' : `, niveau ${niveau} %`) + ' (lu par Uconnect)', + { vehicule: 'JEEP', km, niveau, ts: ts.toISOString(), source: 'uconnect' }); + } + } + if (niveau !== null && st.get(JEEP.branchee)?.state === 'on' + && st.get('binary_sensor.victron_evcs_vehicle_connected')?.state === 'on') { + const { rows: b } = await lire( + `SELECT max(ts) AS t FROM evenement WHERE genre = 'vehicule' + AND detail->>'entite' = 'binary_sensor.victron_evcs_vehicle_connected' AND detail->>'apres' = 'on'`, []); + const branche = b[0]?.t; + if (branche && ts >= new Date(branche.getTime() - 5 * 60000) && ts <= new Date(branche.getTime() + 30 * 60000)) { + const { rows: deja } = await lire( + "SELECT 1 FROM niveau_saisi WHERE source = 'uconnect' AND saisi_a >= $1", [new Date(branche.getTime() - 5 * 60000)]); + if (!deja.length) { + const r = await sql( + "INSERT INTO niveau_saisi (saisi_a, niveau_pct, ref_kwh, source) VALUES ($1,$2,NULL,'uconnect') ON CONFLICT DO NOTHING", + [ts, niveau]); + if (r?.rowCount) { + n++; + await journaliser(sql, 'vehicule', `Niveau JEEP au branchement : ${niveau} % (lu par Uconnect)`, + { niveau, ts: ts.toISOString(), branchement: branche.toISOString() }); + } + } + } + } + return n; +}