Ať vás lidé najdou.
A poptávky mají
své místo.

/**
 * SCORPYNEX / Prémiové čištění — integrační vzor, 15. 10. 2026.
 * Vyžaduje CRM endpoint podle smlouvy popsané v HTML průvodci.
 * Toto není připojení k existujícímu CRM. Výchozí režim nic neodesílá.
 * Script Properties: SPREADSHEET_ID, SHEET_NAME, CRM_IMPORT_URL,
 * CRM_IMPORT_TOKEN, DRY_RUN (výchozí true; pro ostrý import false).
 * Během ostrého přenosu tabulku neupravujte ani neřaďte.
 */
const IMPORT_INPUT = ['ZdrojoveID','Jmeno','Telefon','Email','Sluzba','Obec',
  'PlochaOd','PlochaDo','Poznamka','OdkazNaFotografie'];
const IMPORT_OUTPUT = ['CRM_ID','ImportHash','ImportStav','ImportCas'];

function onOpen() {
  SpreadsheetApp.getUi().createMenu('Scorpynex → CRM')
    .addItem('Zkontrolovat data (bez odeslání)', 'kontrolaImportu')
    .addItem('Spustit přenos podle nastavení', 'importDoCRM')
    .addToUi();
}

function nastaveniImportu_() {
  const props = PropertiesService.getScriptProperties();
  const id = props.getProperty('SPREADSHEET_ID');
  const name = props.getProperty('SHEET_NAME') || 'Poptavky';
  if (!id) throw new Error('Nastavte SPREADSHEET_ID ve vlastnostech skriptu.');
  const sheet = SpreadsheetApp.openById(id).getSheetByName(name);
  if (!sheet) throw new Error('List ' + name + ' neexistuje.');
  const headers = sheet.getRange(1,1,1,sheet.getLastColumn()).getDisplayValues()[0].map(v=>v.trim());
  const map = {};
  headers.forEach((v,i)=>{
    if (!v) return;
    if (Object.prototype.hasOwnProperty.call(map,v)) throw new Error('Duplicitní sloupec: '+v);
    map[v]=i;
  });
  IMPORT_INPUT.concat(IMPORT_OUTPUT).forEach(v=>{
    if (!(v in map)) throw new Error('Chybí sloupec: '+v);
  });
  return {props,sheet,map,id,name};
}

function otisk_(value) {
  return Utilities.computeDigest(Utilities.DigestAlgorithm.SHA_256,value,Utilities.Charset.UTF_8)
    .map(b=>('0'+(b&255).toString(16)).slice(-2)).join('');
}

function cisloPlochy_(text) {
  const s=String(text||'').trim().replace(/\s/g,'').replace(',','.');
  if (!s) return null;
  if (!/^\d+(\.\d+)?$/.test(s)) throw new Error('Plocha musí být číslo, nebo prázdná buňka.');
  const n=Number(s);
  if (!Number.isFinite(n)||n<=0||n>1000000) throw new Error('Zkontrolujte výměru.');
  return n;
}

function zaznam_(row,map) {
  const val=k=>String(row[map[k]]||'').trim();
  if (!val('Sluzba')||!val('Obec')) throw new Error('Doplňte službu a obec.');
  if (!val('Telefon')&&!val('Email')) throw new Error('Doplňte telefon nebo e-mail; neúplné kontakty dořešte ručně.');
  const email=val('Email').toLowerCase();
  if (email&&!/^[^\s@]+@[^\s@]+\.[^\s@]+$/.test(email)) throw new Error('Zkontrolujte e-mail.');
  const phone=val('Telefon').replace(/[\s()\-]/g,'');
  if (phone&&!/^\+?\d{9,15}$/.test(phone)) throw new Error('Zkontrolujte telefon včetně předvolby.');
  const min=cisloPlochy_(val('PlochaOd')),max=cisloPlochy_(val('PlochaDo'));
  if ((min===null)!==(max===null)) throw new Error('Vyplňte obě hranice plochy, nebo obě ponechte prázdné.');
  if (min!==null&&max<min) throw new Error('PlochaDo nesmí být menší než PlochaOd.');
  const photo=val('OdkazNaFotografie');
  if (photo&&!/^https:\/\/[^\s]+$/i.test(photo)) throw new Error('Odkaz na fotografie musí začínat https://.');
  const result={name:val('Jmeno'),phone,email,service:val('Sluzba'),city:val('Obec'),
    areaMinM2:min,areaMaxM2:max,areaStatus:min===null?'unknown':'customer_estimate',
    note:val('Poznamka'),photoReference:photo};
  if (JSON.stringify(result).length>20000) throw new Error('Záznam je příliš dlouhý; zkraťte poznámku.');
  return result;
}

function radky_(cfg) {
  const count=cfg.sheet.getLastRow()-1;
  if (count<=0) return [];
  if (count>5000) throw new Error('Nad 5000 řádků použijte dávkový import připravený vývojářem.');
  const rows=cfg.sheet.getRange(2,1,count,cfg.sheet.getLastColumn()).getDisplayValues();
  const seen=new Set();
  rows.forEach(row=>{
    const id=String(row[cfg.map.ZdrojoveID]||'').trim();
    if (!id) return;
    if (!/^[a-zA-Z0-9_-]{1,100}$/.test(id)) throw new Error('ZdrojoveID obsahuje nepovolené znaky.');
    if (seen.has(id)) throw new Error('Duplicitní ZdrojoveID: přenos zastaven před odesláním.');
    seen.add(id);
  });
  return rows;
}

function prazdny_(row,map) {
  return IMPORT_INPUT.filter(k=>k!=='ZdrojoveID').every(k=>!String(row[map[k]]||'').trim());
}

function kontrolaImportu() {
  const cfg=nastaveniImportu_(), rows=radky_(cfg);
  let valid=0; const errors=[];
  rows.forEach((row,i)=>{
    if (prazdny_(row,cfg.map)) return;
    try { zaznam_(row,cfg.map);valid++; }
    catch(e) { errors.push('Řádek '+(i+2)+': '+e.message); }
  });
  const result={platne:valid,chyby:errors,pocetRadku:rows.length,odeslano:0};
  console.log(JSON.stringify(result)); // Jen počty a chyby, nikoli kontakty či token.
  return result;
}

function odeslat_(url,token,payload,key) {
  for (let attempt=0;attempt<3;attempt++) {
    let response;
    try {
      response=UrlFetchApp.fetch(url,{method:'post',contentType:'application/json',
        headers:{Authorization:'Bearer '+token,'Idempotency-Key':key},
        payload:JSON.stringify(payload),muteHttpExceptions:true,followRedirects:false});
    } catch(e) {
      if (attempt===2) throw new Error('Síťová chyba; výsledek ověří další běh se stejným klíčem.');
      Utilities.sleep(500*Math.pow(2,attempt));continue;
    }
    const code=response.getResponseCode();
    if (code>=200&&code<300) {
      let data;
      try {data=JSON.parse(response.getContentText());} catch(e){throw new Error('CRM nevrátilo platné JSON potvrzení.');}
      // HTTP 202 / přijetí do fronty se samo o sobě nepovažuje za uložený záznam.
      if (data.status!=='applied'||typeof data.recordId!=='string'||
          !/^[a-zA-Z0-9_-]{1,100}$/.test(data.recordId)) throw new Error('Chybí potvrzení skutečného uložení do CRM.');
      return data;
    }
    if ((code===429||code>=500)&&attempt<2) {Utilities.sleep(500*Math.pow(2,attempt));continue;}
    const error=new Error('CRM HTTP '+code+'; záznam nebyl označen jako přenesený.');
    error.stop=code===401||code===403||code===429;
    throw error;
  }
  throw new Error('Přenos se nepodařilo potvrdit.');
}

function importDoCRM() {
  const cfg=nastaveniImportu_();
  // Bez výslovného false zůstává zapnutá kontrola bez zápisu a bez sítě.
  if (cfg.props.getProperty('DRY_RUN')!=='false') return kontrolaImportu();
  const url=cfg.props.getProperty('CRM_IMPORT_URL')||'';
  const token=cfg.props.getProperty('CRM_IMPORT_TOKEN')||'';
  if (!/^https:\/\/[^\s?#@]+\/api\/imports\/google-sheets$/.test(url)||url.includes('.example')||!token)
    throw new Error('Vývojář musí nastavit skutečnou HTTPS adresu CRM a omezený importní token.');
  const lock=LockService.getScriptLock();
  if (!lock.tryLock(1000)) return {preskoceno:'Jiný běh právě importuje.'};
  let applied=0,skipped=0,errors=0,stop=false;
  const start=Date.now();
  try {
    const rows=radky_(cfg);if (!rows.length) return {applied,skipped,errors};
    const cursorKey='CURSOR_'+cfg.sheet.getSheetId();
    let cursor=Number(cfg.props.getProperty(cursorKey)||0);
    if (!Number.isInteger(cursor)||cursor<0) cursor=0;
    cursor%=rows.length;
    let visited=0;
    while (visited<rows.length&&applied+errors<25&&Date.now()-start<240000&&!stop) {
      const index=(cursor+visited)%rows.length, rowNumber=index+2, row=rows[index];visited++;
      if (prazdny_(row,cfg.map)) continue;
      const write=(key,value)=>cfg.sheet.getRange(rowNumber,cfg.map[key]+1).setValue(value);
      try {
        const snapshot=zaznam_(row,cfg.map),hash=otisk_(JSON.stringify(snapshot));
        let sourceId=String(row[cfg.map.ZdrojoveID]||'').trim();
        if (row[cfg.map.CRM_ID]&&!sourceId) throw new Error('U přeneseného řádku chybí ZdrojoveID. Obnovte původní ID, nevytvářejte nové.');
        if (row[cfg.map.ImportHash]===hash&&row[cfg.map.CRM_ID]) {skipped++;continue;}
        if (!sourceId) {sourceId=Utilities.getUuid();write('ZdrojoveID',sourceId);SpreadsheetApp.flush();}
        const externalId=cfg.id+':'+cfg.sheet.getSheetId()+':'+sourceId;
        const payload={schemaVersion:1,mode:'import_draft',source:'google_sheets',externalId,
          revision:hash,sourceRow:rowNumber,sourceSnapshot:snapshot};
        const result=odeslat_(url,token,payload,otisk_(externalId+':'+hash));
        const current=cfg.sheet.getRange(rowNumber,1,1,cfg.sheet.getLastColumn()).getDisplayValues()[0];
        if (String(current[cfg.map.ZdrojoveID]).trim()!==sourceId)
          throw Object.assign(new Error('Během přenosu se přesunuly řádky. Zastaveno; zkontrolujte evidenci.'),{stop:true,noJournal:true});
        // CRM ukládá importní návrh. Upravená tabulka vyvolá další revizi při příštím běhu.
        write('CRM_ID',result.recordId);write('ImportHash',hash);
        write('ImportStav','Přeneseno do návrhu CRM');write('ImportCas',new Date().toISOString());applied++;
      } catch(e) {
        errors++;stop=!!e.stop;
        if (!e.noJournal) write('ImportStav','Chyba: '+e.message);
      }
    }
    cfg.props.setProperty(cursorKey,String((cursor+visited)%rows.length));
    SpreadsheetApp.flush();
  } finally {lock.releaseLock();}
  console.log(JSON.stringify({applied,skipped,errors}));
  if (errors) throw new Error('Import: '+errors+' chyb. Podrobnosti jsou ve sloupci ImportStav.');
  return {applied,skipped,errors};
}

function zapnoutPravidelnyImport() {
  // Spusťte jen jednou pod určeným firemním účtem, až po úspěšném pilotu.
  const cfg=nastaveniImportu_();
  if (cfg.props.getProperty('DRY_RUN')!=='false') throw new Error('Nejdřív schvalte pilot a nastavte DRY_RUN=false.');
  const exists=ScriptApp.getProjectTriggers().some(t=>t.getHandlerFunction()==='importDoCRM');
  if (!exists) ScriptApp.newTrigger('importDoCRM').timeBased().everyMinutes(5).create();
}

function vypnoutPravidelnyImport() {
  ScriptApp.getProjectTriggers().filter(t=>t.getHandlerFunction()==='importDoCRM').forEach(t=>ScriptApp.deleteTrigger(t));
}