module.exports = function(comprobante, cuerpos) {

  var idTransaccion = comprobante.idTransaccion;

  knex('planex_transacciones')
    .where({ id: idTransaccion } )
    .then(function(transax) {

      transax = transax[0];

      fs.readFile(config.dirDestino + '\\' + transax.archivoRecibido, 'utf8', function(err, fileString) {

        if (err) {
          console.log(err);
          return;
        }

        var planex = require('../planex')(fileString);

        var result = require('./todos')(planex, cuerpos, fileString, idTransaccion);

        var nombreRecadv = 'RECADV_' + planex.identificaxMensaje.idMensaje + '.txt';

        fs.writeFile(config.dirRecadv + '/' + nombreRecadv, result, function(err) {

          if (err) return console.log(err);

          knex('planex_transacciones')
            .where({ id: idTransaccion })
            .update({ archivoEnviado: nombreRecadv, estado: 1 })
            .then(function() {

              console.log('Archivo Pruebas guardado');
            });

        });

      });

    });
}