diff --git a/service/csvService.js b/service/csvService.js index c970ddd..d2e6eb3 100644 --- a/service/csvService.js +++ b/service/csvService.js @@ -255,7 +255,7 @@ async function processCsvFile(jobId, inputPath, originalName) { const outputPath = path.join(__dirname, '..', 'outputs', outputFilename); const outStream = fs.createWriteStream(outputPath, { encoding: 'utf8' }); outStream.write('\uFEFF'); - outStream.write(['Distancia', 'Dedicado', 'Nao Dedicado', 'Erro', ...headers].join(';') + '\n'); + outStream.write(['Distancia', 'Dedicado', 'Nao Dedicado', 'Provedor', 'Erro', ...headers].join(';') + '\n'); for (const cols of rows.slice(headerRowIndex + 1)) { const geoPayload = buildGeoPayload(cols, indexes); @@ -267,14 +267,15 @@ async function processCsvFile(jobId, inputPath, originalName) { const distancia = viab.distancia ?? (viab.raw && (viab.raw.distancia || viab.raw.distance)) ?? ''; const dedicado = viab.dedicado ? 'Viavel' : 'Nao Viavel'; const naoDedicado = viab.naoDedicado ? 'Viavel' : 'Nao Viavel'; + const provedor = viab.provedor ?? (viab.raw && viab.raw.provedor) ?? ''; const error = viab.error ? cleanCsvValue(viab.error) : ''; - const outCols = [distancia, dedicado, naoDedicado, error, ...cols].map(cleanCsvValue); + const outCols = [distancia, dedicado, naoDedicado, provedor, error, ...cols].map(cleanCsvValue); outStream.write(outCols.join(';') + '\n'); incrementProcessed(jobId); } catch (err) { const errMsg = cleanCsvValue(formatApiErrorResponse(err)); - const outCols = ['', '', '', errMsg, ...cols].map(cleanCsvValue); + const outCols = ['', '', '', '', errMsg, ...cols].map(cleanCsvValue); outStream.write(outCols.join(';') + '\n'); incrementErrors(jobId); incrementProcessed(jobId);