Eric Fernandez / websocketHO

Browse Code »

Commit c8ca8e879c2c7a9fed97df4ec5fd50f657782cbe

Authored by Eric Fernandez 2019-08-16 16:09:46 -0300

1 parent 4245e3200a

Exists in master

no tabla

Showing 2 changed files with 22 additions and 3 deletions Show diff stats

rutas/comprobantes.js

Diff comments View file @ c8ca8e8

 module.exports = router = express.Router();
 router.get('/comprobantes/:gln*?', function(req, res) {
   var cabecera = knex('PMAEFACT_TEMP')
     .where(function(qb) {
       if (req.params.gln) {
         qb.where({GLN: req.params.gln});
       }
     })
     .select('*');
   var cuerpo = knex('PMOVFACT_TEMP')
     .where(function(qb) {
       if (req.params.gln) {
         qb.where({GLN: req.params.gln});
       }
     })
     .select('*');
     Promise.all([cabecera, cuerpo]).then(function(data) {
       var result = [];
       data[0].forEach((cabecera) => {
         let idCabecera = cabecera.TIP + cabecera.TCO + cabecera.SUC + cabecera.NCO;
         var cuerpos = data[1].filter((cuerpo) => {
           let idCuerpo = cuerpo.TIP + cuerpo.TCO + cuerpo.SUC + cuerpo.NCO;
           return idCuerpo == idCabecera;
         });
         result.push({
           cabecera: cabecera,
           cuerpo: cuerpos
         });
       });
       res.status(200).send(result);
   });
 });
 router.post('/comprobante', function(req, res) {
   var recadv = require('../recadv')(JSON.parse(JSON.stringify(req.body.cabecera)),
     JSON.parse(JSON.stringify(req.body.cuerpo)));
   var guardar = wsServer.guardarComprobante(req, req.body.cabecera.GLN);
-  Promise.all([recadv, guardar])
+  Promise.all([
+      recadv,
+      guardar,
+      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
+      })])
     .then(() => {
       res.status(200).send('Comprobante guardado con éxito');
     })
-    .catch(() => res.status(500).send('Algo salió mal'));
+    .catch(err => res.status(500).send(err));
 });

webSocketServer/index.js

Diff comments View file @ c8ca8e8

 module.exports = function() {
   const webSocketServer = require('ws').Server;
   var clients = [];
   const objWs = {};
   objWs.wsServer = new webSocketServer({
     port: config.port
   });
   objWs.wsServer.on('connection', function connection(ws) {
     console.log('open socket server');
     ws.on('message', function incoming(message) {
       message = JSON.parse(message.toString('utf8'));
       switch (message.action) {
         case 'gln':
           clients.push({ws: ws, gln: message.gln});
           break;
         default:
           // console.log(message.action);
       }
     });
   });
   objWs.getEntidad = function(gln, tableName, where, queryString) {
     return new Promise(function(resolve, reject) {
       var client = clients.filter(function(client) {
         return client.gln == gln
       })[0];
       if (!client) {
         reject('No se encuentra el webSocket client');
       }
       var idSolicitud = Math.round(Math.random() * 1000);
       var enviar = {
         action: 'getEntity',
         idSolicitud: idSolicitud
       };
       if (queryString) {
         enviar.queryString = queryString;
       } else {
         enviar.tableName = tableName;
         enviar.where = where || {};
       }
       client.ws.send(JSON.stringify(enviar));
       client.ws.on('message', function(message) {
         message = JSON.parse(message);
         if (idSolicitud == message.idSolicitud) {
           resolve(message.data);
         }
       });
     });
   }
   objWs.getClientGln = function(gln) {
     return clients.filter(function(client) {
       return client.gln = gln;
     });
   }
   objWs.guardarComprobante = function (cuerpo, gln) {
     return new Promise((resolve, reject) => {
       var client = clients.filter(function(client) {
         return client.gln == gln
       })[0];
       if (!client) {
         reject('No se encuentra el webSocket client');
       }
       var idSolicitud = Math.round(Math.random() * 1000);
       var enviar = {
         action: 'comprobante',
         req: cuerpo
       };
-      console.log(`enviando comprobante a cliente ${client} y ${cuerpo}`);
+      console.log(`enviando comprobante a cliente`)
+      console.log(client);
+      console.log(cuerpo);
       client.ws.send(JSON.stringify(enviar));
       client.ws.on('message', function(message) {
         message = JSON.parse(message);
         if (idSolicitud == message.idSolicitud) {
           resolve(message.data);
         }
       });
     });
   }
   return objWs;
 }