[ka6] snapshot pré-mission strathmore

Simon-Pierre Boucher committed 2 mo ago (Aug 30, 2026) parent 8f3441c Browse files

1 changed file +115 −4

modified jobka/connectors/richelieu.py +115 −4

+ # Job·Ka — Groupe KA
+ # Auteur  : Simon-Pierre Boucher
+ # Contact : contact@spboucher.ai
++# Fichier : jobka/connectors/richelieu.py
++# Rôle    : Connecteur Quincaillerie Richelieu — ADP WFN + repli « détail
++#           seulement » quand l'API liste échoue (maintenances nocturnes ADP)
++# Créé    : 2026-08-25   Modifié : 2026-08-30
+ # =============================================================================
++"""Quincaillerie Richelieu — ADP Workforce Now, avec repli de revalidation.
++
++Contexte (2026-08-28/29) : ADP Workforce Now a des fenêtres de maintenance
++nocturnes récurrentes (vendredi ET samedi soir ~22:00 → 02:00 ET) pendant
++lesquelles TOUT workforcenow.adp.com redirige vers sorry.adp.com — la liste
++job-requisitions renvoie alors du HTML, d'où le « Expecting value: line 1
++column 1 » du sync de 23:00 (29/08). Comme le cycle complet met ~3 h entre
++deux passages de la source, un seul passage raté pendant la fenêtre suffit à
++dépasser le seuil stale de 4 h.
++
++D'où le repli ci-dessous (même pattern que cultures_genv.py /
++groupe_nordik.py / h2o_innovation.py / mitsubishi_hc_capital.py /
++msi_gestion.py / ciena.py) : si la pagination liste échoue en 5xx ou en
++non-JSON, on revalide une à une les offres actives connues en base via l'API
++détail job-requisitions/<itemID> (qui renvoie la réquisition complète :
++titre, date, lieux, description). Aucune donnée inventée — tout vient de la
++réponse live. Une offre en 404 est considérée retirée. Si AUCUNE offre n'est
++validable (maintenance totale : le détail redirige aussi vers
++sorry.adp.com), l'erreur d'origine est propagée pour que le sync reste un
++échec (inventaire préservé). Limite assumée : le repli ne découvre pas les
++NOUVELLES offres — le chemin liste normal reprend seul au cycle suivant la
++fin de la maintenance.
++"""
++from __future__ import annotations
++
++import requests
++
++from ..schema import JobPosting, clean_html
++from .adp import _API, ADPWorkforceNowConnector
+ class RichelieuConnector(ADPWorkforceNowConnector):
+     EMPLOYER = "Quincaillerie Richelieu"
+     CID = "a43f2867-2f0c-434c-8680-d6c5543c4dc5"
+     CCID = "19000101_000001"
++
++    def fetch(self) -> list[JobPosting]:
++        try:
++            return super().fetch()
++        except (requests.RequestException, ValueError) as exc:
++            resp = getattr(exc, "response", None)
++            if resp is not None and resp.status_code < 500:
++                raise            # 4xx franc : pas une panne liste, ne pas masquer
++            jobs = self._fetch_known_jobs()
++            if jobs is None:
++                raise            # API détail cassée aussi : vraie panne totale
++            return jobs
++
++    def _known_ids(self) -> list[str]:
++        """itemID (external_id) des offres actives de la source en base."""
++        from .. import db
++        con = db.connect()
++        try:
++            rows = con.execute(
++                "SELECT external_id FROM jobs WHERE source=? AND active=1",
++                (self.source_id,)).fetchall()
++        finally:
++            con.close()
++        return [str(eid) for (eid,) in rows if eid]
++
++    def _fetch_known_jobs(self) -> list[JobPosting] | None:
++        """Repli sans liste : chaque offre connue est revalidée via l'API
++        détail (la réquisition complète, source de vérité de son existence).
++        Aucune donnée inventée — tout vient de la réponse du moment."""
++        out: list[JobPosting] = []
++        errors = 0
++        for iid in self._known_ids():
++            try:
++                r = self.get(f"{_API}/{iid}", params=self._params(),
++                             headers={"Accept": "application/json"}).json()
++            except requests.HTTPError as exc:
++                h = getattr(exc, "response", None)
++                if h is not None and h.status_code == 404:
++                    continue     # offre retirée chez l'employeur
++                errors += 1
++                continue
++            except (requests.RequestException, ValueError):
++                errors += 1      # non-JSON (maintenance) ou réseau
++                continue
++            if not (r or {}).get("requisitionTitle"):
++                errors += 1      # réponse inattendue : ne pas conclure au retrait
++                continue
++            locations = self._locations(r)
++            if not self._keep(locations):
++                continue
++            qc = next((l for l in locations
++                       if l["prov"].upper() == "QC"),
++                      locations[0] if locations else
++                      {"city": self.FORCE_CITY, "postal": "",
++                       "label": self.FORCE_CITY})
++            job = JobPosting(
++                source=self.source_id, external_id=iid,
++                url=("https://workforcenow.adp.com/mascsr/default/mdf/"
++                     f"recruitment/recruitment.html?cid={self.CID}"
++                     f"&ccId={self.CCID}&lang={self.LANG}&jobId={iid}"),
++                employer=self.EMPLOYER,
++                title=r.get("requisitionTitle") or "",
++                city=qc["city"], postal_code=qc["postal"],
++                location_label=qc["label"],
++                date_posted=r.get("postDate") or None,
++                ats=self.ats,
++            )
++            pay = r.get("payGradeRange") or {}
++            lo = (pay.get("minimumRate") or {}).get("amountValue")
++            hi = (pay.get("maximumRate") or {}).get("amountValue")
++            if lo:
++                job.salary_min = float(lo)
++                job.salary_max = float(hi) if hi else None
++                job.salary_unit = "year" if float(lo) > 5000 else "hour"
++            wl = (r.get("workLevelCode") or {}).get("shortName")
++            if wl:
++                job.details["employment_label"] = wl
++            job.description = clean_html(r.get("requisitionDescription") or "")
++            out.append(job)
++        if not out and errors:
++            return None          # rien de validable : laisser le sync échouer
++        return out

spb/job-ka

[ka6] snapshot pré-mission strathmore

Theme