Fluxul reparat

/**
 * TaxeUK — cautare dosar si identificare client
 * Intrare (body webhook): { name, birthdate, phone, client_code }
 * Iesire: { found, identity_match, client_id, leads_total,
 *           status_code, status_label, status_text }
 */

const B   = $input.first().json.body || {};
const CRM = 'https://crm.taxeuk.com/public/api';
const H   = { 'Content-Type':'application/json', 'X-Requested-With':'XMLHttpRequest' };

const post = async (cale, body, token) => this.helpers.httpRequest({
  method:'POST', url:`${CRM}/${cale}`,
  headers: token ? { ...H, Authorization:`Bearer ${token}` } : H,
  body, json:true, returnFullResponse:true, ignoreHttpStatusErrors:true,
});

const iesire = o => [{ json: {
  found:false, identity_match:false, client_id:null, leads_total:0,
  status_code:null, status_label:null, status_text:'', ...o } }];

/* ---------- normalizari ---------- */
const norm = s => (s||'').toString().toLowerCase()
  .normalize('NFD').replace(/[\u0300-\u036f]/g,'')
  .replace(/[^a-z]+/g,' ').trim();

const lev = (a,b) => {
  const d = Array.from({length:a.length+1}, (_,i)=>[i,...Array(b.length).fill(0)]);
  for (let j=0;j<=b.length;j++) d[0][j]=j;
  for (let i=1;i<=a.length;i++)
    for (let j=1;j<=b.length;j++)
      d[i][j] = Math.min(d[i-1][j]+1, d[i][j-1]+1,
                         d[i-1][j-1] + (a[i-1]===b[j-1] ? 0 : 1));
  return d[a.length][b.length];
};

// orice format de data -> AAAA-LL-ZZ, ca sa se poata compara
const zi = s => {
  const t = (s||'').toString().trim();
  let m = t.match(/^(\d{1,2})[\/.-](\d{1,2})[\/.-](\d{4})/);
  if (m) return `${m[3]}-${m[2].padStart(2,'0')}-${m[1].padStart(2,'0')}`;
  m = t.match(/^(\d{4})-(\d{2})-(\d{2})/);
  return m ? `${m[1]}-${m[2]}-${m[3]}` : null;
};

const tel9 = s => ((s||'').toString().replace(/\D/g,'').slice(-9)) || null;

// numele de familie apare in ce a dictat clientul, cu toleranta de 1-2 litere
const numeSePotriveste = (spus, client) => {
  const cuvinte = norm(spus).split(' ').filter(Boolean);
  const familie = norm(client.lastname).replace(/ /g,'');
  if (!familie || !cuvinte.length) return false;
  const prag = familie.length <= 4 ? 1 : 2;
  return cuvinte.some(c => lev(c, familie) <= prag);
};

/* ---------- 1. autentificare ---------- */
const login = await post('auth/login', {
  email: $env.TAXEUK_USER,
  password: $env.TAXEUK_PASS,
  password_confirmation: $env.TAXEUK_PASS,
});
const token = login.body?.access_token;
if (!token) return iesire({ status_text:'EROARE_AUTENTIFICARE' });

/* ---------- 2. gasirea clientului, in ordinea increderii ---------- */
let client = null, canal = null;
const dataCeruta = zi(B.birthdate);

// A — nume + data nasterii
if (B.name && dataCeruta) {
  const r = await post('get-client-by-name-birthdate',
    { name: B.name, birthdate: B.birthdate, ai_agent: 1 }, token);
  const lista = r.body?.clients ?? (r.body?.client ? [r.body.client] : []);
  // daca CRM intoarce mai multi, filtram noi: data exacta + nume tolerant
  const c = lista.find(x => zi(x.birthdate) === dataCeruta
                            && numeSePotriveste(B.name, x));
  if (c?.id) { client = c; canal = 'nume+data'; }
}

// B — cod de client + data nasterii
if (!client && B.client_code && dataCeruta) {
  const r = await post('get-client', {
    unique_id: B.client_code.toString().toUpperCase().replace(/\s/g,''),
    birthdate: B.birthdate, ai_agent: 1 }, token);
  const c = r.body?.client;
  if (c?.id && zi(c.birthdate) === dataCeruta) { client = c; canal = 'cod'; }
}

// C — telefon. Gaseste dosarul, dar NU dovedeste identitatea.
if (!client && tel9(B.phone)) {
  const r = await post('get-client-id-by-phone', { phone: B.phone }, token);
  const c = r.body?.client ?? r.body;
  if (c?.id) { client = c; canal = 'telefon'; }
}

if (!client) return iesire({ found:false });

/* ---------- 3. verificarea identitatii ---------- */
let identitate;
if (canal === 'nume+data' || canal === 'cod') {
  identitate = true;                       // dovedita de cautarea insasi
} else {
  // gasit dupa telefon: cerem nume tolerant + data EXACTA
  identitate = !!(B.name && dataCeruta
                  && zi(client.birthdate) === dataCeruta
                  && numeSePotriveste(B.name, client));
}

// exista un dosar pe numar, dar nu stim inca cine suna
if (!identitate) return iesire({ found:true, identity_match:false });

/* ---------- 4. toate dosarele clientului ---------- */
const rl = await post('get-leads-by-client', { client_id: client.id }, token);
let dosare = rl.body?.leads ?? rl.body?.lead ?? [];
if (!Array.isArray(dosare)) dosare = dosare ? [dosare] : [];

if (!dosare.length) return iesire({
  found:true, identity_match:true, client_id:client.id,
  status_text:'vă am în evidență, dar nu găsesc un dosar activ pe numele '
            + 'dumneavoastră. Transmit solicitarea unui coleg, care vă va contacta.',
});

/* ---------- 5. alegerea dosarului relevant ---------- */
const ETICHETA = { 0:'CANCELLED', 1:'NEW', 2:'TR/PARTIAL', 3:'MISSING INFO',
  4:'WAITING', 5:'PROCESSED', 6:'SENT', 7:'OUTSTANDING',
  8:'CHEQUE RECEIVED', 9:'TRANSFERRED' };
const DESCHISE = [1,2,3,4,5,6,7,8];

const deschise = dosare.filter(l => DESCHISE.includes(Number(l.status)));
const dosar = (deschise.length ? deschise : dosare)
  .sort((a,b) => new Date(b.created_at) - new Date(a.created_at))[0];

const total      = dosare.length;
const finalizate = dosare.filter(l => Number(l.status) === 9).length;
const cod        = Number(dosar.status);

/* ---------- 6. mesajul rostit ---------- */
const ro = d => { const x = new Date(d); return isNaN(x) ? null :
  `${String(x.getUTCDate()).padStart(2,'0')}.`
+ `${String(x.getUTCMonth()+1).padStart(2,'0')}.${x.getUTCFullYear()}`; };

const prenume  = (client.firstname||'').trim().split(/\s+/)[0];
const salut    = prenume ? `${prenume}, ` : '';
const areIban  = !!(client.iban || dosar.iban);
const trimisLa = ro(dosar.sent_date || dosar.created_at);
const termen   = ro(dosar.deadline);
const transfer = ro(dosar.last_transfer_date);

const MESAJ = {
 1:`dosarul dumneavoastră este înregistrat la noi și urmează să fie verificat de un coleg din departamentul de procesare.`,
 5:`dosarul dumneavoastră a fost procesat și este pregătit pentru trimitere către biroul de taxe. Nu mai este nevoie de nimic din partea dumneavoastră.`,
 6:`dosarul dumneavoastră a fost trimis către biroul de taxe din Marea Britanie${trimisLa?`, în data de ${trimisLa}`:''}, și se află în analiză la ei.`,
 4:`dosarul dumneavoastră este în lucru la biroul de taxe${termen?`, cu termen de răspuns până în ${termen}`:''}. Îl urmărim și vă anunțăm imediat ce apare o noutate.`,
 7:`termenul de răspuns pentru dosarul dumneavoastră a fost depășit. Colegii noștri iau legătura direct cu biroul de taxe și vă sunăm cu informațiile primite.`,
 3:`dosarul dumneavoastră nu este complet — mai avem nevoie de câteva documente. Un coleg vă va contacta să vă spună exact ce lipsește.`,
 8: areIban
   ? `cecul cu suma recuperată a ajuns la noi. Urmează să facem transferul în contul dumneavoastră, în maximum șapte zile lucrătoare.`
   : `cecul cu suma recuperată a ajuns la noi. Ca să putem face transferul, avem nevoie de contul dumneavoastră bancar.`,
 2:`am primit o parte din suma recuperată, pentru anii deja soluționați. Pentru ceilalți ani, dosarul este în continuare în analiză la biroul de taxe.`,
 9:`dosarul dumneavoastră a fost finalizat, iar suma recuperată a fost transferată${transfer?` în data de ${transfer}`:''} în contul indicat.`,
 0:`acest dosar figurează ca închis și nu mai este în lucru. Un coleg vă poate confirma motivul exact.`,
};

const corp = MESAJ[cod]
  ?? `în acest moment nu pot confirma cu exactitate stadiul dosarului dumneavoastră. `
   + `Transmit solicitarea unui coleg, care vă va contacta.`;

const prefix = total <= 1 ? ''
  : deschise.length
    ? `aveți ${total} dosare la noi, dintre care ${finalizate} finalizate. Despre cel aflat în lucru: `
    : `aveți ${total} dosare la noi, toate finalizate. Despre ultimul: `;

return iesire({
  found: true,
  identity_match: true,
  client_id: client.id,
  leads_total: total,
  status_code: Number.isFinite(cod) ? cod : null,
  status_label: ETICHETA[cod] ?? 'NECUNOSCUT',
  status_text: salut + prefix + corp,
});

{{ JSON.stringify($json) }}

phone            +40740779788     →  {{ $('CreareLead').item.json.body.phone }}
uuid             550e8400-…       →  {{ $execution.id }}-{{ $now.toMillis() }}
notes            "express daca…"  →  {{ $('CreareLead').item.json.body.notes }}
no_jobs          0                →  {{ $('CreareLead').item.json.body.no_jobs }}
next_leave       1                →  {{ $('CreareLead').item.json.body.next_leave }}
next_leave_date  0000-00-00       →  {{ $('CreareLead').item.json.body.next_leave_date }}
no_visits_…      0                →  {{ $('CreareLead').item.json.body.no_visits_for_taxes_request }}
postal_office…   0                →  {{ $('CreareLead').item.json.body.postal_office_send }}
language         1                →  ro
iban, sort_code, account_number, account_holder, signature, referral
                 sirul "null"     →  gol, prin nodul Set de mai jos

const curat = v => (v == null || v === 'null' || v === 'undefined' || v === '')
  ? null : v;

const b = $('CreareLead').first().json.body;
return [{ json: Object.fromEntries(
  Object.entries(b).map(([k,v]) => [k, curat(v)])
) }];