WebSocket / websocketBO

Browse Code »

Commit 37266dcb05218f306dc226df7f6f07de8843fc45

Authored by Eric Fernandez 2019-08-16 16:47:39 -0300

1 parent da1dfc07cb

Exists in master

+console log

Showing 2 changed files with 8 additions and 5 deletions Show diff stats

data/index.js

Diff comments View file @ 37266dc

 module.exports = function(config) {
   return {
     getEntity: function (message) {
       return new Promise(function(resolve, reject) {
         var promise;
         if (message.queryString) {
           promise = knex.schema.raw(message.queryString);
         } else {
           promise = knex(message.tableName).where(message.where).select('*');
         }
         promise.then(function (data) {
           message.data = data[0];
           resolve(message);
         });
       });
     },
     guardarComprobante: function (body) {
+      console.log('recibo datos guardarComprobante en estación');
+      console.log(body);
       return new Promise((resolve, reject) => {
         delete body.cabecera.idTransaccion;
         delete body.cabecera.GLN;
         delete body.cabecera.C_HD2;
         delete body.cabecera.E_HD2;
         //smalldatetime
         body.cabecera.FEC = new Date(body.cabecera.FEC).toISOString().slice(0, 19).replace('T', ' ');
         body.cabecera.FECCAI = new Date(body.cabecera.FECCAI).toISOString().slice(0, 19).replace('T', ' ');
         body.cabecera.FECVEN = new Date(body.cabecera.FECVEN).toISOString().slice(0, 19).replace('T', ' ');
         //datetime
         body.cabecera.FEV = moment(body.cabecera.FEV).format('YYYYMMDD');
         body.cabecera.FEP = moment(body.cabecera.FEP).format('YYYYMMDD');
         var promesas = [
           knex('PMAEFACT').insert(body.cabecera),
           knex('PCOBYPAG').insert({
             COD: body.cabecera.COD,
             FEP: body.cabecera.FEC,
             TIP: body.cabecera.TIP,
             TCO: body.cabecera.TCO,
             SUC: body.cabecera.SUC,
             NCO: body.cabecera.NCO,
             IPA: body.cabecera.TOT,
             SAL: 0,
             TCA: 1,
             ZONA: body.cabecera.ZON,
             FPA: body.cabecera.FPA,
             REC: 0,
             FER: '19000101 00:00',
             PRO: '',
             FEV: body.cabecera.FEV,
             ANU: '',
             PLA: 0,
             LUG: 0,
             RES: 0,
             CCU: 0,
             UCU: 0,
             HOS: '',
             E_HD: '',
             C_HD: ''
           }),
         ];
         body.cuerpo.forEach(cuerpo => {
           if (cuerpo.estado != 'rechazado' && !(cuerpo.COD == 0 && cuerpo.ART == 0)) {
             promesas.push(knex('AMOVSTOC').insert({
               SEC: cuerpo.COD,
               ART: cuerpo.ART,
               FEC: body.cabecera.FEC,
               CYV: 'C',
               TIP: body.cabecera.TIP,
               TCO: body.cabecera.TCO,
               PVE: body.cabecera.SUC,
               NCO: body.cabecera.NCO,
               ORD: cuerpo.ORD,
               CAN: cuerpo.cantidadRecibida,
               PUN: cuerpo.PUN,
               COD: body.cabecera.COD,
               DTO: cuerpo.DTO,
               IMI: cuerpo.IMI,
               PLA: 0,
               LUG: 0,
               ANU: '',
               TIM: 'Co',
               OPE: -888, // <= TODO: Cuando se haga el login poner codigo operario
               IMI2: cuerpo.IMI2,
               E_HD: '',
               C_HD: '',
               JUS: 'PLANEX',
               NLC: 0,
               IMI3: cuerpo.IMI3,
               JJN: '',
               JDJ: '',
               ID_MOTIVO_NANB: 0
             }));
           };
           cuerpo.estado == 'rechazado' ? cuerpo.cantidadRecibida = 0 : false;
           delete cuerpo.GLN;
           delete cuerpo.C_HD2;
           delete cuerpo.E_HD2;
           delete cuerpo.codigoBarras;
           delete cuerpo.estado;
           delete cuerpo.recibido;
           delete cuerpo.input;
           delete cuerpo.tempRecibido;
           cuerpo.LI0 = cuerpo.LI0.slice(0, 29);
           cuerpo.TIO = cuerpo.TIO.slice(0, 29);
           promesas.push(knex('PMOVFACT').insert(cuerpo));
         });
         Promise.all(promesas)
           .then(function() {
             console.log('comprobantes guardados con éxito');
             resolve();
           })
           .catch(function(e) {
             console.log(e);
             reject('Ocurrió un error');
           });
       });
     }
   }
 }

index.js

Diff comments View file @ 37266dc

1	const WebSocketClient = require('ws');	1	const WebSocketClient = require('ws');
2	const config = require('./config/config.json');	2	const config = require('./config/config.json');
3	const data = require('./data/index')(config.bo);	3	const data = require('./data/index')(config.bo);
4	module.exports = knex = require('knex')(config.bo);	4	module.exports = knex = require('knex')(config.bo);
5		5
6	const client = new WebSocketClient(config.urlHO);	6	const client = new WebSocketClient(config.urlHO);
7		7
8	client.on('open', function open() {	8	client.on('open', function open() {
9	console.log('conection to socket ho is open');	9	console.log('conection to socket ho is open');
10		10
11	client.send(JSON.stringify({ gln: config.gln, action: 'gln'}));	11	client.send(JSON.stringify({ gln: config.gln, action: 'gln'}));
12		12
13	client.on('message', function incoming(message) {	13	client.on('message', function incoming(message) {
14		14
15	message = JSON.parse(message.toString('utf8'));	15	message = JSON.parse(message.toString('utf8'));
16	console.log(message);	16
17	switch (message.action) {	17	switch (message.action) {
18	case 'getEntity':	18	case 'getEntity':
19		19
20	data.getEntity(message).then(function(message) {	20	data.getEntity(message).then(function(message) {
21		21
22	client.send(JSON.stringify(message));	22	client.send(JSON.stringify(message));
23	});	23	});
24	break;	24	break;
25		25
26	case 'comprobante':	26	case 'comprobante':
27	console.log('recibiendo comprobante')	27	console.log('recibiendo comprobante')
28	data.guardarComprobante(message.req).then(() => {	28	data.guardarComprobante(message.req).then(() => {
29	console.log('se guardó');	29	console.log('se guardó');
30	client.send(JSON.stringify('ok'));	30	client.send(JSON.stringify('ok'));
31	}).catch(() => {	31	}).catch((ee) => {
32	console.log('no se guardó');	32	console.log('no se guardó' + ee);
33	client.send(JSON.stringify('bad'));	33	client.send(JSON.stringify('bad'));
34	});	34	});
35		35
36	break;	36	break;
37		37
38	default:	38	default:
39	break;	39	break;
40	}	40	}
41	});	41	});
42	});	42	});
43		43
44	client.on('error', function(e) {	44	client.on('error', function(e) {
45	console.log(e);	45	console.log(e);
46	})	46	})
47		47
48	console.log('Sevice connected to wsServer: ' + config.urlHO);	48	console.log('Sevice connected to wsServer: ' + config.urlHO);
49		49