WebSocket / websocketHO

Browse Code »

Commit 7747a5a7ba47f13d952b7d88d3efb7449a199b1e

Authored by Eric Fernandez 2019-08-16 16:36:50 -0300

1 parent 0f8c933f54

Exists in master

bodyÇ

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

rutas/comprobantes.js

Diff comments View file @ 7747a5a

1	module.exports = router = express.Router();	1	module.exports = router = express.Router();
2		2
3	router.get('/comprobantes/:gln*?', function(req, res) {	3	router.get('/comprobantes/:gln*?', function(req, res) {
4		4
5	var cabecera = knex('PMAEFACT_TEMP')	5	var cabecera = knex('PMAEFACT_TEMP')
6	.where(function(qb) {	6	.where(function(qb) {
7	if (req.params.gln) {	7	if (req.params.gln) {
8	qb.where({GLN: req.params.gln});	8	qb.where({GLN: req.params.gln});
9	}	9	}
10	})	10	})
11	.select('*');	11	.select('*');
12		12
13	var cuerpo = knex('PMOVFACT_TEMP')	13	var cuerpo = knex('PMOVFACT_TEMP')
14	.where(function(qb) {	14	.where(function(qb) {
15	if (req.params.gln) {	15	if (req.params.gln) {
16	qb.where({GLN: req.params.gln});	16	qb.where({GLN: req.params.gln});
17	}	17	}
18	})	18	})
19	.select('*');	19	.select('*');
20		20
21	Promise.all([cabecera, cuerpo]).then(function(data) {	21	Promise.all([cabecera, cuerpo]).then(function(data) {
22		22
23	var result = [];	23	var result = [];
24	data[0].forEach((cabecera) => {	24	data[0].forEach((cabecera) => {
25		25
26	let idCabecera = cabecera.TIP + cabecera.TCO + cabecera.SUC + cabecera.NCO;	26	let idCabecera = cabecera.TIP + cabecera.TCO + cabecera.SUC + cabecera.NCO;
27		27
28	var cuerpos = data[1].filter((cuerpo) => {	28	var cuerpos = data[1].filter((cuerpo) => {
29	let idCuerpo = cuerpo.TIP + cuerpo.TCO + cuerpo.SUC + cuerpo.NCO;	29	let idCuerpo = cuerpo.TIP + cuerpo.TCO + cuerpo.SUC + cuerpo.NCO;
30	return idCuerpo == idCabecera;	30	return idCuerpo == idCabecera;
31	});	31	});
32		32
33	result.push({	33	result.push({
34	cabecera: cabecera,	34	cabecera: cabecera,
35	cuerpo: cuerpos	35	cuerpo: cuerpos
36	});	36	});
37	});	37	});
38		38
39	res.status(200).send(result);	39	res.status(200).send(result);
40	});	40	});
41	});	41	});
42		42
43	router.post('/comprobante', function(req, res) {	43	router.post('/comprobante', function(req, res) {
44		44
45	var recadv = require('../recadv')(JSON.parse(JSON.stringify(req.body.cabecera)),	45	var recadv = require('../recadv')(JSON.parse(JSON.stringify(req.body.cabecera)),
46	JSON.parse(JSON.stringify(req.body.cuerpo)));	46	JSON.parse(JSON.stringify(req.body.cuerpo)));
47		47
48	var guardar = wsServer.guardarComprobante(req, req.body.cabecera.GLN);	48	var guardar = wsServer.guardarComprobante(req.body, req.body.cabecera.GLN);
49		49
50	Promise.all([	50	Promise.all([
51	recadv,	51	recadv,
52	guardar,	52	guardar,
53	knex('PMAEFACT_TEMP').where({	53	knex('PMAEFACT_TEMP').where({
54	TIP: req.body.cabecera.TIP,	54	TIP: req.body.cabecera.TIP,
55	TCO: req.body.cabecera.TCO,	55	TCO: req.body.cabecera.TCO,
56	SUC: req.body.cabecera.SUC,	56	SUC: req.body.cabecera.SUC,
57	NCO: req.body.cabecera.NCO,	57	NCO: req.body.cabecera.NCO,
58	COD: req.body.cabecera.COD	58	COD: req.body.cabecera.COD
59	})	59	})
60	.del(),	60	.del(),
61	knex('PMOVFACT_TEMP').where({	61	knex('PMOVFACT_TEMP').where({
62	TIP: req.body.cabecera.TIP,	62	TIP: req.body.cabecera.TIP,
63	TCO: req.body.cabecera.TCO,	63	TCO: req.body.cabecera.TCO,
64	SUC: req.body.cabecera.SUC,	64	SUC: req.body.cabecera.SUC,
65	NCO: req.body.cabecera.NCO	65	NCO: req.body.cabecera.NCO
66	})])	66	})])
67	.then(() => {	67	.then(() => {
68	res.status(200).send('Comprobante guardado con éxito');	68	res.status(200).send('Comprobante guardado con éxito');
69	})	69	})
70	.catch(err => {	70	.catch(err => {
71	console.log(err);	71	console.log(err);
72	console.log('error al guardar algo ruta comprobantes');	72	console.log('error al guardar algo ruta comprobantes');
73	res.status(500).send(err)	73	res.status(500).send(err)
74	});	74	});
75		75
76	});	76	});
77		77

webSocketServer/index.js

Diff comments View file @ 7747a5a

 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');
         console.log('No se encuentra el webSocket client');
         return;
       }
       var idSolicitud = Math.round(Math.random() * 1000);
       var enviar = {
         action: 'comprobante',
         req: cuerpo
       };
       console.log(`enviando comprobante a cliente`)
-      console.log(client);
+      console.log(cuerpo.cabecera);
-      console.log(cuerpo.body.cabecera);
       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;
 }