diff --git a/rutas/comprobantes.js b/rutas/comprobantes.js index fd17259..035019b 100644 --- a/rutas/comprobantes.js +++ b/rutas/comprobantes.js @@ -42,27 +42,34 @@ router.get('/comprobantes/:gln*?', function(req, res) { router.post('/comprobante', function(req, res) { - // var recadv = require('../recadv')(JSON.parse(JSON.stringify(req.body.cabecera)), - // JSON.parse(JSON.stringify(req.body.cuerpo))); + let recadv = require('../recadv')(JSON.parse(JSON.stringify(req.body.cabecera)), + JSON.parse(JSON.stringify(req.body.cuerpo))); + + let cabecera = knex('PMAEFACT_TEMP') + .where({ + TIP: req.body.cabecera.TIP, + TCO: req.body.cabecera.TCO, + SUC: req.body.cabecera.SUC, + NCO: req.body.cabecera.NCO, + COD: req.body.cabecera.COD + }) + .del(); + + let cuerpo = knex('PMOVFACT_TEMP') + .where({ + TIP: req.body.cabecera.TIP, + TCO: req.body.cabecera.TCO, + SUC: req.body.cabecera.SUC, + NCO: req.body.cabecera.NCO + }) + .del() wsServer.guardarComprobante(req.body, req.body.cabecera.GLN).then(() => { Promise.all([ - knex('PMAEFACT_TEMP').where({ - TIP: req.body.cabecera.TIP, - TCO: req.body.cabecera.TCO, - SUC: req.body.cabecera.SUC, - NCO: req.body.cabecera.NCO, - COD: req.body.cabecera.COD - }) - .del(), - knex('PMOVFACT_TEMP').where({ - TIP: req.body.cabecera.TIP, - TCO: req.body.cabecera.TCO, - SUC: req.body.cabecera.SUC, - NCO: req.body.cabecera.NCO - }) - .del() + recadv, + cabecera, + cuerpo ]) .then(() => { res.status(200).send({data: 'Comprobante guardado con éxito'}); @@ -72,6 +79,12 @@ router.post('/comprobante', function(req, res) { res.status(500).send(err); }); }) - .catch((err) => res.status(500).send(err)); + .catch((err) => { + + Promise.all([cabecera, cuerpo]).then(() => { + + res.status(err).send(err) + }) + }); }); diff --git a/webSocketServer/index.js b/webSocketServer/index.js index 5e5890b..321c4c5 100644 --- a/webSocketServer/index.js +++ b/webSocketServer/index.js @@ -130,7 +130,7 @@ module.exports = function() { resolve(); } else { - reject(); + reject(message.code); } }