From 2c3d7e9814a239af5cc0e96e757cf08168ec6f78 Mon Sep 17 00:00:00 2001
From: louispaulb <louis.targo@gmail.com>
Date: Sat, 6 Jun 2026 14:43:34 -0400
Subject: [PATCH] =?UTF-8?q?Pont=20legacy=20:=20coords=20GPS=20fiables=20(d?=
 =?UTF-8?q?elivery=E2=86=92SL=E2=86=92RQA=E2=86=92Mapbox)=20+=20routage=20?=
 =?UTF-8?q?routier=20r=C3=A9el=20(Mapbox=20Matrix)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Pont (legacy-dispatch-sync.js) :
- Import des coordonnées par job via cascade : table legacy `delivery` (point de service exact,
  JOIN ticket.delivery_id) > Service Location ERPNext > géocodage RQA > géocodage Mapbox.
  Validation bornes Québec (coord()). Couverture 153/172 (89%).
- Géocodage RQA corrigé : retrait du générique de voie (Rue/Rang/Chemin absent de
  odonyme_recompose_normal) + code postal non accolé au terme (sinon ilike ne matche jamais).
- Repli Mapbox geocoding pour rues trop récentes pour le RQA (MAPBOX_TOKEN).
- Backfill + UPGRADE : coords delivery écrasent des coords SL moins précises (jamais l'inverse).
- Comptabilité honnête : vérifie r.ok sur create/update (erp ne throw pas) → errors + error_samples.
- Verrou de sérialisation sync() : tick + runs manuels ne se chevauchent plus (frappe_pg).
- Subject tronqué à 140 (champ Data) → corrige CharacterLengthExceededError sur jobs sans SL.
- Observabilité : coord_src tally + error_samples dans le résumé.

Ops Planification (éditeur de journée) :
- travelBetween() consulte une matrice Mapbox Matrix chargée à l'ouverture (loadDayRoute) →
  temps de trajet ROUTIERS RÉELS ; réordonnancement instantané sans nouvelle requête.
  Repli haversine si Mapbox indispo. Indicateur 🚗 réel vs 📏 vol d'oiseau.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
---
 apps/ops/src/pages/PlanificationPage.vue      |  40 ++++-
 docs/features/legacy-dispatch-bridge.md       |  38 ++++-
 .../targo-hub/lib/legacy-dispatch-sync.js     | 144 ++++++++++++++++--
 3 files changed, 201 insertions(+), 21 deletions(-)

diff --git a/apps/ops/src/pages/PlanificationPage.vue b/apps/ops/src/pages/PlanificationPage.vue
index 73e2f60..a213a89 100644
--- a/apps/ops/src/pages/PlanificationPage.vue
+++ b/apps/ops/src/pages/PlanificationPage.vue
@@ -684,7 +684,7 @@
           <template v-for="(j, i) in dayEditor.list" :key="j.name">
             <!-- temps de transport estimé depuis le job précédent (l'espace entre 2 blocs) -->
             <div v-if="i > 0" class="de-travel">
-              <template v-if="travelBetween(dayEditor.list[i - 1], j)">🚗 ~{{ travelBetween(dayEditor.list[i - 1], j).min }} min · {{ travelBetween(dayEditor.list[i - 1], j).km }} km</template>
+              <template v-if="dayLeg(i)">{{ dayLeg(i).real ? '🚗' : '📏' }} {{ dayLeg(i).real ? '' : '~' }}{{ dayLeg(i).min }} min<template v-if="dayLeg(i).km != null"> · {{ dayLeg(i).km }} km</template><q-tooltip class="bg-grey-9" style="font-size:11px">{{ dayLeg(i).real ? 'Temps routier réel (routes Mapbox)' : 'Estimation à vol d’oiseau (coords approximatives ou Mapbox indisponible)' }}</q-tooltip></template>
               <template v-else>🚗 transport ? (adresse/coords manquantes)</template>
             </div>
             <div class="de-row" :class="{ 'de-drag': dayEditor.dragIdx === i }"
@@ -744,6 +744,7 @@ import { symOutlinedToolsLadder, symOutlinedHeadsetMic, symOutlinedHandyman } fr
 import { onBeforeRouteLeave, useRouter } from 'vue-router'
 import { useQuasar } from 'quasar'
 import * as roster from 'src/api/roster'
+import { MAPBOX_TOKEN } from 'src/config/erpnext' // routage routier réel (API Mapbox Matrix), déjà utilisé par le Dispatch
 import { legacyDeptColor } from 'src/composables/useHelpers' // coloriage par type « comme legacy » (partagé avec le board Dispatch)
 import TechSelect from 'src/components/shared/TechSelect.vue'
 import SkillSelect from 'src/components/shared/SkillSelect.vue'
@@ -1025,12 +1026,36 @@ function gotoDispatch (t, dateIso) {
 }
 // ── Éditeur de JOURNÉE (fenêtre contextuelle ciblée — clic sur le progressbar) ──
 // Garde le contexte de la grille derrière. Timeline + réordonnancement DRAG-DROP + retrait d'un job.
-const dayEditor = reactive({ open: false, tech: null, day: null, list: [], saving: false, dragIdx: null })
+const dayEditor = reactive({ open: false, tech: null, day: null, list: [], saving: false, dragIdx: null, travelMap: {}, routeReady: false })
 function openDayEditor (t, d) {
   dayEditor.tech = t; dayEditor.day = d
   // RDV confirmé (ou heure légacy précise) = heure FIXE → verrouillé ; sinon flexible (replanifiable par la tournée).
   dayEditor.list = cellJobs(t.id, d.iso).map(j => ({ ...j, locked: j.booking_status === 'Confirmé', showDetail: false }))
-  dayEditor.dragIdx = null; dayEditor.open = true
+  dayEditor.dragIdx = null; dayEditor.travelMap = {}; dayEditor.routeReady = false; dayEditor.open = true
+  loadDayRoute() // charge la matrice de temps routiers RÉELS (Mapbox) → packedDay les utilise dès l'arrivée (réactif)
+}
+// Matrice des temps de trajet ROUTIERS RÉELS entre tous les jobs du jour (Mapbox Matrix, 1 requête).
+// Indépendante de l'ordre → le réordonnancement réutilise la matrice SANS nouvelle requête (recalcul instantané).
+// Repli silencieux sur l'haversine si Mapbox indispo ou coords manquantes.
+async function loadDayRoute () {
+  const key = (dayEditor.tech && dayEditor.tech.id) + '|' + (dayEditor.day && dayEditor.day.iso)
+  const pts = dayEditor.list.filter(j => j.lat != null && j.lon != null && isFinite(+j.lat) && isFinite(+j.lon)).slice(0, 25) // Matrix = 25 coords max
+  if (pts.length < 2 || !MAPBOX_TOKEN) { dayEditor.travelMap = {}; dayEditor.routeReady = false; return }
+  const coords = pts.map(j => `${(+j.lon).toFixed(6)},${(+j.lat).toFixed(6)}`).join(';')
+  const url = `https://api.mapbox.com/directions-matrix/v1/mapbox/driving/${coords}?annotations=duration,distance&access_token=${MAPBOX_TOKEN}`
+  try {
+    const r = await fetch(url); if (!r.ok) throw new Error('matrix ' + r.status)
+    const d = await r.json(); const dur = d.durations || [], dist = d.distances || []
+    if (key !== ((dayEditor.tech && dayEditor.tech.id) + '|' + (dayEditor.day && dayEditor.day.iso))) return // l'éditeur a changé de cible entre-temps
+    const map = {}
+    for (let i = 0; i < pts.length; i++) for (let k = 0; k < pts.length; k++) {
+      if (i === k) continue
+      const sec = dur[i] && dur[i][k]; const m = dist[i] && dist[i][k]
+      if (sec == null) continue
+      map[pts[i].name + '>' + pts[k].name] = { min: Math.max(2, Math.round(sec / 60)), km: m != null ? Math.round(m / 100) / 10 : null, real: true }
+    }
+    dayEditor.travelMap = map; dayEditor.routeReady = true
+  } catch (e) { dayEditor.travelMap = {}; dayEditor.routeReady = false } // repli haversine
 }
 const dayOcc = () => (dayEditor.tech && dayEditor.day) ? cellOcc(dayEditor.tech.id, dayEditor.day.iso) : null
 const dayBands = () => (dayEditor.tech && dayEditor.day) ? cellBands(dayEditor.tech.id, dayEditor.day.iso) : []
@@ -1046,7 +1071,14 @@ function jobMinutes (j) { return Math.round((Number(j.dur) || 0) * 60) }
 function setJobMinutes (j, min) { const m = Math.max(5, Math.round((Number(min) || 0) / 5) * 5); j.dur = Math.round(m / 60 * 100) / 100 }
 // Temps de transport estimé entre 2 jobs (haversine via coords Service Location) — provisoire, en attendant la géoloc live (Capacitor)
 function haversineKm (la1, lo1, la2, lo2) { if ([la1, lo1, la2, lo2].some(v => v == null)) return null; const R = 6371; const r = x => x * Math.PI / 180; const dLa = r(la2 - la1); const dLo = r(lo2 - lo1); const s = Math.sin(dLa / 2) ** 2 + Math.cos(r(la1)) * Math.cos(r(la2)) * Math.sin(dLo / 2) ** 2; return 2 * R * Math.asin(Math.sqrt(s)) }
-function travelBetween (a, b) { const km = haversineKm(a && a.lat, a && a.lon, b && b.lat, b && b.lon); if (km == null) return null; return { km: Math.round(km * 10) / 10, min: Math.max(5, Math.round(km / 40 * 60) + 5) } } // 40 km/h + 5 min tampon
+function travelBetween (a, b) {
+  if (!a || !b) return null
+  const hit = dayEditor.travelMap && dayEditor.travelMap[a.name + '>' + b.name]
+  if (hit) return hit // temps routier RÉEL (Mapbox Matrix)
+  const km = haversineKm(a.lat, a.lon, b.lat, b.lon); if (km == null) return null
+  return { km: Math.round(km * 10) / 10, min: Math.max(5, Math.round(km / 40 * 60) + 5), real: false } // repli : 40 km/h + 5 min tampon (vol d'oiseau)
+}
+function dayLeg (i) { return i > 0 ? travelBetween(dayEditor.list[i - 1], dayEditor.list[i]) : null } // trajet vers le job i depuis le précédent
 const fmtHM = (h) => { if (h == null) return '—'; const m = Math.round(h * 60); const hh = Math.floor(m / 60), mm = m % 60; return String(hh).padStart(2, '0') + ':' + String(mm).padStart(2, '0') } // heure décimale → HH:MM (padded, pour start_time)
 function dayShiftStartH () { const t = dayEditor.tech, d = dayEditor.day; if (!t || !d) return 8; const w = winOf(t.id, d.iso, false); return w ? w.s : 8 }
 // PLANIFICATEUR DE TOURNÉE : recalcule les heures depuis l'ordre de la liste + durées + transport.
diff --git a/docs/features/legacy-dispatch-bridge.md b/docs/features/legacy-dispatch-bridge.md
index c66ef25..6f27c7f 100644
--- a/docs/features/legacy-dispatch-bridge.md
+++ b/docs/features/legacy-dispatch-bridge.md
@@ -66,8 +66,42 @@ Posé dans `/opt/targo-hub/.env`. ⚠️ Après modif de `.env`, **recréer** le
 70 tickets importés (0 erreur, 9 clients non matchés = comptes post-migration + 2 tickets internes
 « FORMATION EN HAUTEUR »). Récurrence active (15 min).
 
+## Coordonnées GPS & routage routier réel (2026-06-06 f)
+Le pont importe des **coordonnées fiables** par job (pour le routage routier réel dans l'éditeur de
+tournée). Cascade de sources, de la plus précise à la plus large :
+1. **`delivery` legacy** (point de service exact, via `ticket.delivery_id → delivery.latitude/longitude`)
+   — JOIN ajouté à `fetchTargoTickets`. Source de référence ; on préfère aussi l'**adresse de service**
+   (`delivery.address1/city/zip`) à l'adresse de facturation du compte.
+2. **Service Location ERPNext** (coords du client matché) — repli.
+3. **Géocodage RQA** (`address-search`/`address-validate`, Répertoire des adresses du Québec) — autoritaire
+   en rural. ⚠️ Le générique de voie (« Rue »/« Rang »/« Chemin ») est **retiré** du terme (absent de
+   `odonyme_recompose_normal` → sinon l'ilike ne matche jamais) et le **code postal n'est PAS accolé** au
+   terme (ses tokens seraient exigés dans le nom de rue).
+4. **Géocodage Mapbox** (`MAPBOX_TOKEN`, clé publique) — couvre les rues trop récentes pour le RQA.
+   Contraint au Québec (`country=ca` + proximity + bornes `coord()`).
+
+Validation `coord()` : bornes Québec (lat 44→63, lon −80→−57) → rejette 0/0 et placeholders. Backfill
+**+ UPGRADE** : sur un job existant, on remplit les coords absentes ET on **écrase** des coords Service
+Location moins précises par les coords `delivery` (point exact) — jamais l'inverse. Caches géocodage au
+niveau module (1 appel par adresse / vie du hub ; échecs mémorisés). Couverture mise en service :
+**153/172 jobs (89 %)** — `coord_src` : delivery 26 · SL 38 · RQA 17 · Mapbox 29 · aucune 15.
+
+**Routage routier réel (Ops → Planification → éditeur de journée)** : `loadDayRoute()` appelle l'**API
+Mapbox Matrix** une fois à l'ouverture (toutes les durées routières d'un coup) → `travelBetween()` retourne
+le temps RÉEL ; le réordonnancement réutilise la matrice **sans nouvelle requête**. Repli haversine
+(40 km/h) si Mapbox indispo. Indicateur 🚗 (réel) vs 📏 (vol d'oiseau).
+
+## Robustesse (2026-06-06 f)
+- **Comptabilité honnête** : `erp.create/update` ne *throw* pas (renvoient `{ok:false,error}`) → le pont
+  vérifie `r.ok` (sinon `errors++` + `error_samples` dans le résumé). Avant : creates échoués comptés réussis.
+- **Verrou de sérialisation** sur `sync()` : tick récurrent + runs manuels ne se chevauchent JAMAIS
+  (frappe_pg sans concurrence → sinon « socket hang up » + écritures perdues dans un rollback).
+- **Subject tronqué à 140** (champ `Data` Frappe) : les jobs sans Service Location ajoutaient l'adresse au
+  sujet → `CharacterLengthExceededError`. Détail complet conservé dans `legacy_detail`/coords.
+- Env : `MAPBOX_TOKEN` ajouté à `/opt/targo-hub/.env` (clé publique `pk.`) → recréer le conteneur.
+
 ## TODO / idées
-- Fermer/annuler le Dispatch Job quand le ticket legacy passe `closed` (v1 ne gère que open).
+- Matcher les clients non matchés (créer le Customer / enrichir `legacy_account_id`) → réduit les 15 « aucune coord ».
+- Géoloc live du tech (Capacitor `transistorsoft/capacitor-background-geolocation`) → 1er point de la tournée.
 - Filtrer les départements non-terrain (ToDo, Support Informatique, Conception…) si bruit.
-- Matcher les 9 clients manquants (créer le Customer ou enrichir `legacy_account_id`).
 - Écrire en retour le tech assigné / la date vers le legacy (bidirectionnel) — non fait (lecture seule legacy).
diff --git a/services/targo-hub/lib/legacy-dispatch-sync.js b/services/targo-hub/lib/legacy-dispatch-sync.js
index e083ef1..0547d0e 100644
--- a/services/targo-hub/lib/legacy-dispatch-sync.js
+++ b/services/targo-hub/lib/legacy-dispatch-sync.js
@@ -23,7 +23,9 @@
  */
 const erp = require('./erp')
 const cfg = require('./config')
-const { log, json } = require('./helpers')
+const { log, json, httpRequest } = require('./helpers')
+const { searchAddresses } = require('./address-search') // géocodeur RQA (Répertoire des adresses du Québec)
+const { scoreMatch } = require('./address-validate') // scoring de correspondance adresse↔RQA
 let mysql
 try { mysql = require('mysql2/promise') } catch { /* dépendance optionnelle */ }
 
@@ -51,6 +53,73 @@ function startTime (dueTime) {
 }
 const norm = (s) => (s || '').toLowerCase().normalize('NFD').replace(/[̀-ͯ]/g, '').trim()
 
+// Coords legacy = chaînes ("-73.5599440" / "45.2528570"). On parse + valide les bornes Québec
+// (lat 44→63, lon -80→-57) pour rejeter 0/0, placeholders et valeurs aberrantes → routage fiable.
+function coord (lat, lon) {
+  const la = parseFloat(lat), lo = parseFloat(lon)
+  if (!isFinite(la) || !isFinite(lo)) return null
+  if (la < 44 || la > 63 || lo < -80 || lo > -57) return null
+  return { lat: la, lon: lo }
+}
+
+// Géocodage de repli via RQA (Répertoire des adresses du Québec) — source autoritaire, fiable en
+// rural (vs Mapbox qui peut dévier de plusieurs km). Cache au niveau MODULE (persiste entre les ticks)
+// → chaque adresse n'est géocodée qu'une fois par cycle de vie du hub ; les échecs sont mémorisés
+// (valeur null) pour ne PAS marteler RQA à chaque cycle. N'accepte qu'une correspondance fiable (≥0.7).
+// Générique de voie (Rue/Rang/Chemin…) ABSENT de `odonyme_recompose_normal` côté RQA → on le retire
+// du terme de recherche, sinon l'ilike mot-à-mot ne matche jamais. (Le code postal NE doit PAS être
+// accolé au terme : ses tokens seraient exigés dans le nom de rue.)
+const ROAD_GENERIC_RE = /\b(rue|chemin|ch|rang|route|rte|avenue|av|ave|boul(?:evard)?|bd|mont[ée]e|c[ôo]te|place|pl|impasse|all[ée]e|terrasse|croissant|carr[ée]|cours|quai|ruelle|voie)\b\.?/gi
+const cleanRoadTerm = (s) => String(s || '').replace(ROAD_GENERIC_RE, ' ').replace(/\s+/g, ' ').trim()
+const _geoCache = new Map()
+async function geocodeRQA (addressLine, postalCode, city) {
+  const key = norm([addressLine, postalCode, city].filter(Boolean).join('|'))
+  if (!key || !addressLine) return null
+  if (_geoCache.has(key)) return _geoCache.get(key)
+  let res = null
+  try {
+    const term = cleanRoadTerm(addressLine) || addressLine // civique + rue sans le générique (PC NON accolé)
+    const rows = await searchAddresses(term, 15)
+    if (rows && rows.length) {
+      const best = rows
+        .map(r => ({ r, score: scoreMatch({ address_line: addressLine, postal_code: postalCode, city }, r) }))
+        .sort((a, b) => b.score - a.score)[0]
+      if (best && best.score >= 0.7) {
+        const c = coord(best.r.latitude, best.r.longitude)
+        if (c) res = c
+      }
+    }
+  } catch (e) { log('geocodeRQA error:', e.message) } // RQA indispo → pas de coords (échec mémorisé)
+  _geoCache.set(key, res)
+  return res
+}
+
+// Repli Mapbox (token public déjà utilisé par le Dispatch) pour les rues TROP RÉCENTES pour le RQA
+// (nouveaux développements absents du répertoire). Moins précis en rural que le RQA mais « une coord
+// vaut mieux que zéro » pour le routage. Contraint au Québec (country=ca + proximity Montérégie +
+// bornes coord()). Cache module. Désactivé si MAPBOX_TOKEN absent de l'env.
+const MAPBOX_TOKEN = process.env.MAPBOX_TOKEN || ''
+const _mbCache = new Map()
+async function geocodeMapbox (addressLine, city, postalCode) {
+  if (!MAPBOX_TOKEN || !addressLine) return null
+  const key = norm([addressLine, city, postalCode].filter(Boolean).join('|'))
+  if (_mbCache.has(key)) return _mbCache.get(key)
+  let res = null
+  try {
+    const q = [addressLine, city, 'Québec'].filter(Boolean).join(', ')
+    const url = `https://api.mapbox.com/geocoding/v5/mapbox.places/${encodeURIComponent(q)}.json` +
+      `?country=ca&proximity=-73.5,45.2&limit=1&types=address&language=fr&access_token=${MAPBOX_TOKEN}`
+    const r = await httpRequest(url, '', { timeout: 12000 })
+    const f = r && r.data && Array.isArray(r.data.features) && r.data.features[0]
+    if (f && Array.isArray(f.center) && (f.relevance == null || f.relevance >= 0.6)) {
+      const c = coord(f.center[1], f.center[0]) // Mapbox = [lon, lat]
+      if (c) res = c
+    }
+  } catch (e) { log('geocodeMapbox error:', e.message) }
+  _mbCache.set(key, res)
+  return res
+}
+
 let _pool
 function pool () {
   if (!mysql) return null
@@ -83,9 +152,10 @@ function stripHtml (html, max = 1500) {
 async function fetchTargoTickets () {
   const p = pool(); if (!p) throw new Error('mysql2 indisponible sur le hub')
   const [rows] = await p.query(
-    `SELECT t.id, t.subject, t.dept_id, dd.name AS dept, t.due_date, t.due_time, t.priority, t.bon_id, t.account_id,
+    `SELECT t.id, t.subject, t.dept_id, dd.name AS dept, t.due_date, t.due_time, t.priority, t.bon_id, t.account_id, t.delivery_id,
             t.date_create, t.last_update,
             a.first_name, a.last_name, a.company, a.address1, a.address2, a.city, a.state, a.zip,
+            dv.latitude AS dv_lat, dv.longitude AS dv_lon, dv.address1 AS dv_addr, dv.city AS dv_city, dv.zip AS dv_zip,
             (SELECT mm.msg FROM ticket_msg mm
               WHERE mm.ticket_id = t.id AND mm.msg LIKE '%connect_ministra%'
               ORDER BY mm.id DESC LIMIT 1) AS activation_msg,
@@ -94,6 +164,7 @@ async function fetchTargoTickets () {
        FROM ticket t
        LEFT JOIN ticket_dept dd ON dd.id = t.dept_id
        LEFT JOIN account a ON a.id = t.account_id
+       LEFT JOIN delivery dv ON dv.id = t.delivery_id
       WHERE t.status = 'open' AND t.assign_to = ?
       ORDER BY t.due_date DESC`,
     [TARGO_TECH_STAFF_ID],
@@ -133,10 +204,16 @@ async function buildJob (t) {
   const sl = cust ? await resolveServiceLocation(cust.name, t.city) : null
   const jt = jobType(t.dept_id)
   const cname = cust ? cust.customer_name : ([t.first_name, t.last_name].filter(Boolean).join(' ') || t.company || '')
-  const addr = [t.address1, t.address2, t.city, t.state, t.zip].filter(Boolean).join(', ')
+  // Coords : la table legacy `delivery` (point de service réel, via ticket.delivery_id) est la
+  // source la plus fiable (lat/long par adresse). On préfère donc l'adresse de service à l'adresse
+  // de facturation du compte, et les coords delivery aux coords Service Location ERPNext (placeholders).
+  const dc = coord(t.dv_lat, t.dv_lon)
+  const svcAddr = [t.dv_addr, t.dv_city, t.dv_zip].filter(Boolean).join(', ')
+  const billAddr = [t.address1, t.address2, t.city, t.state, t.zip].filter(Boolean).join(', ')
+  const addr = svcAddr || billAddr
   let subject = (t.subject || '').trim() || ([t.dept, cname].filter(Boolean).join(' — '))
   if (!sl && addr) subject = (subject + ' · ' + addr) // pas de Service Location → on garde l'adresse visible dans le sujet
-  subject = subject.slice(0, 250)
+  subject = subject.slice(0, 140) // Subject = champ Data Frappe (max 140 car.) ; le détail complet est dans legacy_detail/coords
 
   const payload = {
     ticket_id: 'LEG-' + t.id,
@@ -157,29 +234,53 @@ async function buildJob (t) {
   const sd = tzDate(t.due_date); if (sd) payload.scheduled_date = sd
   const st = startTime(t.due_time); if (st) payload.start_time = st
   if (cust) payload.customer = cust.name
+  let coordSrc = null
+  if (dc) { payload.latitude = dc.lat; payload.longitude = dc.lon; coordSrc = 'delivery' } // source fiable : point de service legacy
   if (sl) {
     payload.service_location = sl.name
-    if (sl.latitude != null && sl.latitude !== '') payload.latitude = sl.latitude
-    if (sl.longitude != null && sl.longitude !== '') payload.longitude = sl.longitude
+    if (!coordSrc) { const sc = coord(sl.latitude, sl.longitude); if (sc) { payload.latitude = sc.lat; payload.longitude = sc.lon; coordSrc = 'service_location' } } // repli si pas de delivery
   }
-  return { legacy_id: String(t.id), payload, matched: { customer: !!cust, service_location: !!sl, customer_name: cname }, dept: t.dept, addr }
+  if (!coordSrc && addr) { // replis géocodage sur l'adresse de service (sinon facturation) : RQA (autoritaire) puis Mapbox (couverture)
+    const useSvc = !!svcAddr
+    const line = useSvc ? t.dv_addr : t.address1
+    const zip = useSvc ? t.dv_zip : t.zip
+    const ci = useSvc ? t.dv_city : t.city
+    const g = await geocodeRQA(line, zip, ci)
+    if (g) { payload.latitude = g.lat; payload.longitude = g.lon; coordSrc = 'rqa_geocode' }
+    else { const mb = await geocodeMapbox(line, ci, zip); if (mb) { payload.latitude = mb.lat; payload.longitude = mb.lon; coordSrc = 'mapbox_geocode' } }
+  }
+  return { legacy_id: String(t.id), payload, matched: { customer: !!cust, service_location: !!sl, customer_name: cname, coords: !!coordSrc, coord_src: coordSrc, delivery_id: t.delivery_id || null }, dept: t.dept, addr }
 }
 
 async function findExisting (legacyId) {
-  const r = await erp.list('Dispatch Job', { filters: [['legacy_ticket_id', '=', legacyId]], fields: ['name', 'status', 'assigned_tech', 'scheduled_date', 'legacy_dept', 'legacy_activation_url', 'legacy_detail'], limit: 1 })
+  const r = await erp.list('Dispatch Job', { filters: [['legacy_ticket_id', '=', legacyId]], fields: ['name', 'status', 'assigned_tech', 'scheduled_date', 'legacy_dept', 'legacy_activation_url', 'legacy_detail', 'latitude', 'longitude', 'service_location'], limit: 1 })
   return (r && r[0]) || null
 }
 
+// VERROU de sérialisation : frappe_pg ne supporte pas la concurrence. Le tick récurrent ET les runs
+// manuels (preview/run) passent tous par `sync()` → on les met en FILE pour qu'ils ne se chevauchent
+// JAMAIS (sinon « socket hang up » + écritures perdues dans un rollback). Chaque appel attend le précédent.
+let _syncLock = Promise.resolve()
+function sync (opts = {}) {
+  const run = _syncLock.then(() => syncImpl(opts), () => syncImpl(opts))
+  _syncLock = run.then(() => {}, () => {}) // le suivant attend, quel que soit le résultat
+  return run
+}
+
 // Cœur : parcourt les tickets, crée/maj les Dispatch Jobs. SÉQUENTIEL (frappe_pg ne supporte pas la concurrence).
-async function sync ({ dryRun = false } = {}) {
+async function syncImpl ({ dryRun = false } = {}) {
   resetCaches()
   const tickets = await fetchTargoTickets()
-  let created = 0, updated = 0, skipped = 0, errors = 0, unmatched = 0
+  let created = 0, updated = 0, skipped = 0, errors = 0, unmatched = 0, coordsFilled = 0, noCoords = 0
+  const coordTally = {} // observabilité : répartition des sources de coords (delivery/service_location/rqa_geocode/none)
+  const errSamples = [] // observabilité : échantillon des erreurs create/update (« ne rien échapper »)
   const details = []
   for (const t of tickets) {
     try {
       const b = await buildJob(t)
       if (!b.matched.customer) unmatched++
+      coordTally[b.matched.coord_src || 'none'] = (coordTally[b.matched.coord_src || 'none'] || 0) + 1
+      if (!b.matched.coords) noCoords++ // ni delivery ni Service Location ni RQA → routage indisponible (à diagnostiquer)
       const ex = await findExisting(b.legacy_id)
       if (ex) {
         // Déjà importé. Backfill du département (métadonnée couleur, sans risque) + maj date SEULEMENT
@@ -188,14 +289,27 @@ async function sync ({ dryRun = false } = {}) {
         if (!ex.legacy_dept && b.payload.legacy_dept) patch.legacy_dept = b.payload.legacy_dept
         if (!ex.legacy_activation_url && b.payload.legacy_activation_url) patch.legacy_activation_url = b.payload.legacy_activation_url // backfill lien activation (sans risque)
         if (b.payload.legacy_detail && ex.legacy_detail !== b.payload.legacy_detail) patch.legacy_detail = b.payload.legacy_detail // (re)backfill description + dates (idempotent : ne réécrit que si différent)
+        // Coords (localisation, sans risque pour l'ordonnancement) : on remplit si absentes/0 côté ERPNext,
+        // ET on UPGRADE vers les coords `delivery` (point de service exact) si elles diffèrent des coords
+        // existantes (souvent issues du Service Location, moins précises). delivery écrase ; SL/RQA non.
+        const hasCoord = (v) => v != null && v !== '' && Math.abs(parseFloat(v)) > 0.0001
+        const exHas = hasCoord(ex.latitude) && hasCoord(ex.longitude)
+        const isDeliveryUpgrade = b.matched.coord_src === 'delivery' && exHas &&
+          (Math.abs(parseFloat(ex.latitude) - b.payload.latitude) > 1e-5 || Math.abs(parseFloat(ex.longitude) - b.payload.longitude) > 1e-5)
+        if (b.payload.latitude != null && (!exHas || isDeliveryUpgrade)) { patch.latitude = b.payload.latitude; patch.longitude = b.payload.longitude; coordsFilled++ }
+        if (!ex.service_location && b.payload.service_location) patch.service_location = b.payload.service_location // backfill lien Service Location
         if (ex.status === 'open' && !ex.assigned_tech && b.payload.scheduled_date && b.payload.scheduled_date !== ex.scheduled_date) patch.scheduled_date = b.payload.scheduled_date
-        if (!dryRun && Object.keys(patch).length) { await erp.update('Dispatch Job', ex.name, patch); updated++; details.push({ legacy_id: b.legacy_id, action: 'update', job: ex.name, patch }) }
-        else skipped++
+        if (!dryRun && Object.keys(patch).length) {
+          const r = await erp.update('Dispatch Job', ex.name, patch)
+          if (r && r.ok) { updated++; details.push({ legacy_id: b.legacy_id, action: 'update', job: ex.name, patch }) }
+          else { errors++; const msg = (r && r.error) || 'update failed'; errSamples.push({ legacy_id: b.legacy_id, action: 'update', error: String(msg).slice(0, 200) }); details.push({ legacy_id: b.legacy_id, action: 'update-failed', job: ex.name, error: msg }) }
+        } else skipped++
       } else if (dryRun) {
-        created++; details.push({ legacy_id: b.legacy_id, action: 'would-create', subject: b.payload.subject, job_type: b.payload.job_type, dept: b.dept, scheduled_date: b.payload.scheduled_date || null, start_time: b.payload.start_time || null, customer: b.matched.customer_name, customer_matched: b.matched.customer, sl_matched: b.matched.service_location, addr: b.addr })
+        created++; details.push({ legacy_id: b.legacy_id, action: 'would-create', subject: b.payload.subject, job_type: b.payload.job_type, dept: b.dept, scheduled_date: b.payload.scheduled_date || null, start_time: b.payload.start_time || null, customer: b.matched.customer_name, customer_matched: b.matched.customer, sl_matched: b.matched.service_location, coords: b.matched.coords, coord_src: b.matched.coord_src, delivery_id: b.matched.delivery_id, addr: b.addr })
       } else {
         const r = await erp.create('Dispatch Job', b.payload)
-        created++; details.push({ legacy_id: b.legacy_id, action: 'created', job: (r && r.name) || null, subject: b.payload.subject, customer_matched: b.matched.customer })
+        if (r && r.ok) { created++; details.push({ legacy_id: b.legacy_id, action: 'created', job: r.name, subject: b.payload.subject, customer_matched: b.matched.customer }) }
+        else { errors++; const msg = (r && r.error) || 'create failed'; errSamples.push({ legacy_id: b.legacy_id, action: 'create', error: String(msg).slice(0, 200) }); details.push({ legacy_id: b.legacy_id, action: 'create-failed', error: msg }) }
       }
     } catch (e) {
       errors++; details.push({ legacy_id: String(t.id), error: String((e && e.message) || e) })
@@ -203,7 +317,7 @@ async function sync ({ dryRun = false } = {}) {
   }
   let closedResolved = 0
   if (!dryRun) { try { const cr = await closeResolved(); closedResolved = cr.closed } catch (e) { log('closeResolved error:', e.message) } } // retire les DJ dont le ticket legacy est fermé
-  const summary = { ok: true, dryRun, tech_staff_id: TARGO_TECH_STAFF_ID, tickets: tickets.length, created, updated, skipped, errors, unmatched_customer: unmatched, closed: closedResolved }
+  const summary = { ok: true, dryRun, tech_staff_id: TARGO_TECH_STAFF_ID, tickets: tickets.length, created, updated, skipped, errors, unmatched_customer: unmatched, coords_filled: coordsFilled, no_coords: noCoords, coord_src: coordTally, error_samples: errSamples.slice(0, 6), closed: closedResolved }
   if (!dryRun) { _lastRun = { at: new Date().toISOString(), ...summary }; log(`legacy-dispatch-sync: ${JSON.stringify(summary)}`) } // heartbeat
   return { ...summary, details }
 }