Eric Fernandez / websocketHO

Download as
Browse Code »

Commit ac5bd610792b81b38a243f426395031e3b1240c3

Authored by Eric Fernandez
1 parent 585189f639
Exists in master

console catch comprobantes2

Showing 2 changed files with 6 additions and 2 deletions   Show diff stats
rutas/comprobantes.js
Diff comments   View file @ ac5bd61
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, 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 => res.status(500).send(err)); 70 .catch(err => {
71 console.log(err);
72 console.log('error al guardar algo ruta comprobantes');
73 res.status(500).send(err)
74 });
71 75
72 }); 76 });
73 77
webSocketServer/index.js
Diff comments   View file @ ac5bd61
1 module.exports = function() { 1 module.exports = function() {
2 2
3 const webSocketServer = require('ws').Server; 3 const webSocketServer = require('ws').Server;
4 var clients = []; 4 var clients = [];
5 5
6 const objWs = {}; 6 const objWs = {};
7 7
8 objWs.wsServer = new webSocketServer({ 8 objWs.wsServer = new webSocketServer({
9 port: config.port 9 port: config.port
10 }); 10 });
11 11
12 objWs.wsServer.on('connection', function connection(ws) { 12 objWs.wsServer.on('connection', function connection(ws) {
13 13
14 console.log('open socket server'); 14 console.log('open socket server');
15 15
16 ws.on('message', function incoming(message) { 16 ws.on('message', function incoming(message) {
17 17
18 message = JSON.parse(message.toString('utf8')); 18 message = JSON.parse(message.toString('utf8'));
19 19
20 switch (message.action) { 20 switch (message.action) {
21 case 'gln': 21 case 'gln':
22 clients.push({ws: ws, gln: message.gln}); 22 clients.push({ws: ws, gln: message.gln});
23 break; 23 break;
24 default: 24 default:
25 // console.log(message.action); 25 // console.log(message.action);
26 } 26 }
27 }); 27 });
28 }); 28 });
29 29
30 objWs.getEntidad = function(gln, tableName, where, queryString) { 30 objWs.getEntidad = function(gln, tableName, where, queryString) {
31 31
32 return new Promise(function(resolve, reject) { 32 return new Promise(function(resolve, reject) {
33 33
34 var client = clients.filter(function(client) { 34 var client = clients.filter(function(client) {
35 return client.gln == gln 35 return client.gln == gln
36 })[0]; 36 })[0];
37 37
38 if (!client) { 38 if (!client) {
39 reject('No se encuentra el webSocket client'); 39 reject('No se encuentra el webSocket client');
40 } 40 }
41 41
42 var idSolicitud = Math.round(Math.random() * 1000); 42 var idSolicitud = Math.round(Math.random() * 1000);
43 43
44 var enviar = { 44 var enviar = {
45 action: 'getEntity', 45 action: 'getEntity',
46 idSolicitud: idSolicitud 46 idSolicitud: idSolicitud
47 }; 47 };
48 48
49 if (queryString) { 49 if (queryString) {
50 50
51 enviar.queryString = queryString; 51 enviar.queryString = queryString;
52 } else { 52 } else {
53 enviar.tableName = tableName; 53 enviar.tableName = tableName;
54 enviar.where = where || {}; 54 enviar.where = where || {};
55 } 55 }
56 56
57 client.ws.send(JSON.stringify(enviar)); 57 client.ws.send(JSON.stringify(enviar));
58 58
59 client.ws.on('message', function(message) { 59 client.ws.on('message', function(message) {
60 60
61 message = JSON.parse(message); 61 message = JSON.parse(message);
62 62
63 if (idSolicitud == message.idSolicitud) { 63 if (idSolicitud == message.idSolicitud) {
64 64
65 resolve(message.data); 65 resolve(message.data);
66 } 66 }
67 67
68 }); 68 });
69 }); 69 });
70 } 70 }
71 71
72 objWs.getClientGln = function(gln) { 72 objWs.getClientGln = function(gln) {
73 return clients.filter(function(client) { 73 return clients.filter(function(client) {
74 return client.gln = gln; 74 return client.gln = gln;
75 }); 75 });
76 } 76 }
77 77
78 objWs.guardarComprobante = function (cuerpo, gln) { 78 objWs.guardarComprobante = function (cuerpo, gln) {
79 79
80 return new Promise((resolve, reject) => { 80 return new Promise((resolve, reject) => {
81 81
82 var client = clients.filter(function(client) { 82 var client = clients.filter(function(client) {
83 return client.gln == gln 83 return client.gln == gln
84 })[0]; 84 })[0];
85 85
86 if (!client) { 86 if (!client) {
87 reject('No se encuentra el webSocket client'); 87 reject('No se encuentra el webSocket client');
88 console.log('No se encuentra el webSocket client'); 88 console.log('No se encuentra el webSocket client');
89 return; 89 return;
90 } 90 }
91 91
92 var idSolicitud = Math.round(Math.random() * 1000); 92 var idSolicitud = Math.round(Math.random() * 1000);
93 93
94 var enviar = { 94 var enviar = {
95 action: 'comprobante', 95 action: 'comprobante',
96 req: cuerpo 96 req: cuerpo.body
97 }; 97 };
98 98
99 console.log(`enviando comprobante a cliente`) 99 console.log(`enviando comprobante a cliente`)
100 console.log(client); 100 console.log(client);
101 console.log(cuerpo.body.cabecera); 101 console.log(cuerpo.body.cabecera);
102 102
103 client.ws.send(JSON.stringify(enviar)); 103 client.ws.send(JSON.stringify(enviar));
104 104
105 client.ws.on('message', function(message) { 105 client.ws.on('message', function(message) {
106 106
107 message = JSON.parse(message); 107 message = JSON.parse(message);
108 108
109 if (idSolicitud == message.idSolicitud) { 109 if (idSolicitud == message.idSolicitud) {
110 110
111 resolve(message.data); 111 resolve(message.data);
112 } 112 }
113 113
114 }); 114 });
115 115
116 }); 116 });
117 } 117 }
118 118
119 return objWs; 119 return objWs;
120 } 120 }
121 121