Eric Fernandez / websocketBO

Download as
Browse Code »

Commit f48d28407636a877335ad07ce77e621167a67478

Authored by Eric Fernandez
1 parent 96432b4fe6
Exists in master

no recadv

Showing 1 changed file with 0 additions and 1 deletions   Show diff stats
1 module.exports = function(config) { 1 module.exports = function(config) {
2 2
3 return { 3 return {
4 getEntity: function (message) { 4 getEntity: function (message) {
5 5
6 return new Promise(function(resolve, reject) { 6 return new Promise(function(resolve, reject) {
7 7
8 var promise; 8 var promise;
9 9
10 if (message.queryString) { 10 if (message.queryString) {
11 11
12 promise = knex.schema.raw(message.queryString); 12 promise = knex.schema.raw(message.queryString);
13 } else { 13 } else {
14 14
15 promise = knex(message.tableName).where(message.where).select('*'); 15 promise = knex(message.tableName).where(message.where).select('*');
16 } 16 }
17 17
18 promise.then(function (data) { 18 promise.then(function (data) {
19 19
20 message.data = data[0]; 20 message.data = data[0];
21 resolve(message); 21 resolve(message);
22 }); 22 });
23 }); 23 });
24 }, 24 },
25 25
26 guardarComprobante: function (req) { 26 guardarComprobante: function (req) {
27 27
28 return new Promise((resolve, reject) => { 28 return new Promise((resolve, reject) => {
29 29
30 delete req.body.cabecera.idTransaccion; 30 delete req.body.cabecera.idTransaccion;
31 delete req.body.cabecera.GLN; 31 delete req.body.cabecera.GLN;
32 delete req.body.cabecera.C_HD2; 32 delete req.body.cabecera.C_HD2;
33 delete req.body.cabecera.E_HD2; 33 delete req.body.cabecera.E_HD2;
34 34
35 //smalldatetime 35 //smalldatetime
36 req.body.cabecera.FEC = new Date(req.body.cabecera.FEC).toISOString().slice(0, 19).replace('T', ' '); 36 req.body.cabecera.FEC = new Date(req.body.cabecera.FEC).toISOString().slice(0, 19).replace('T', ' ');
37 req.body.cabecera.FECCAI = new Date(req.body.cabecera.FECCAI).toISOString().slice(0, 19).replace('T', ' '); 37 req.body.cabecera.FECCAI = new Date(req.body.cabecera.FECCAI).toISOString().slice(0, 19).replace('T', ' ');
38 req.body.cabecera.FECVEN = new Date(req.body.cabecera.FECVEN).toISOString().slice(0, 19).replace('T', ' '); 38 req.body.cabecera.FECVEN = new Date(req.body.cabecera.FECVEN).toISOString().slice(0, 19).replace('T', ' ');
39 //datetime 39 //datetime
40 req.body.cabecera.FEV = moment(req.body.cabecera.FEV).format('YYYYMMDD'); 40 req.body.cabecera.FEV = moment(req.body.cabecera.FEV).format('YYYYMMDD');
41 req.body.cabecera.FEP = moment(req.body.cabecera.FEP).format('YYYYMMDD'); 41 req.body.cabecera.FEP = moment(req.body.cabecera.FEP).format('YYYYMMDD');
42 42
43 var promesas = [ 43 var promesas = [
44 recadv,
45 knex('PMAEFACT').insert(req.body.cabecera), 44 knex('PMAEFACT').insert(req.body.cabecera),
46 knex('PCOBYPAG').insert({ 45 knex('PCOBYPAG').insert({
47 COD: req.body.cabecera.COD, 46 COD: req.body.cabecera.COD,
48 FEP: req.body.cabecera.FEC, 47 FEP: req.body.cabecera.FEC,
49 TIP: req.body.cabecera.TIP, 48 TIP: req.body.cabecera.TIP,
50 TCO: req.body.cabecera.TCO, 49 TCO: req.body.cabecera.TCO,
51 SUC: req.body.cabecera.SUC, 50 SUC: req.body.cabecera.SUC,
52 NCO: req.body.cabecera.NCO, 51 NCO: req.body.cabecera.NCO,
53 IPA: req.body.cabecera.TOT, 52 IPA: req.body.cabecera.TOT,
54 SAL: 0, 53 SAL: 0,
55 TCA: 1, 54 TCA: 1,
56 ZONA: req.body.cabecera.ZON, 55 ZONA: req.body.cabecera.ZON,
57 FPA: req.body.cabecera.FPA, 56 FPA: req.body.cabecera.FPA,
58 REC: 0, 57 REC: 0,
59 FER: '19000101 00:00', 58 FER: '19000101 00:00',
60 PRO: '', 59 PRO: '',
61 FEV: req.body.cabecera.FEV, 60 FEV: req.body.cabecera.FEV,
62 ANU: '', 61 ANU: '',
63 PLA: 0, 62 PLA: 0,
64 LUG: 0, 63 LUG: 0,
65 RES: 0, 64 RES: 0,
66 CCU: 0, 65 CCU: 0,
67 UCU: 0, 66 UCU: 0,
68 HOS: '', 67 HOS: '',
69 E_HD: '', 68 E_HD: '',
70 C_HD: '' 69 C_HD: ''
71 }), 70 }),
72 ]; 71 ];
73 72
74 req.body.cuerpo.forEach(cuerpo => { 73 req.body.cuerpo.forEach(cuerpo => {
75 74
76 if (cuerpo.estado != 'rechazado' && !(cuerpo.COD == 0 && cuerpo.ART == 0)) { 75 if (cuerpo.estado != 'rechazado' && !(cuerpo.COD == 0 && cuerpo.ART == 0)) {
77 76
78 promesas.push(knex('AMOVSTOC').insert({ 77 promesas.push(knex('AMOVSTOC').insert({
79 SEC: cuerpo.COD, 78 SEC: cuerpo.COD,
80 ART: cuerpo.ART, 79 ART: cuerpo.ART,
81 FEC: req.body.cabecera.FEC, 80 FEC: req.body.cabecera.FEC,
82 CYV: 'C', 81 CYV: 'C',
83 TIP: req.body.cabecera.TIP, 82 TIP: req.body.cabecera.TIP,
84 TCO: req.body.cabecera.TCO, 83 TCO: req.body.cabecera.TCO,
85 PVE: req.body.cabecera.SUC, 84 PVE: req.body.cabecera.SUC,
86 NCO: req.body.cabecera.NCO, 85 NCO: req.body.cabecera.NCO,
87 ORD: cuerpo.ORD, 86 ORD: cuerpo.ORD,
88 CAN: cuerpo.cantidadRecibida, 87 CAN: cuerpo.cantidadRecibida,
89 PUN: cuerpo.PUN, 88 PUN: cuerpo.PUN,
90 COD: req.body.cabecera.COD, 89 COD: req.body.cabecera.COD,
91 DTO: cuerpo.DTO, 90 DTO: cuerpo.DTO,
92 IMI: cuerpo.IMI, 91 IMI: cuerpo.IMI,
93 PLA: 0, 92 PLA: 0,
94 LUG: 0, 93 LUG: 0,
95 ANU: '', 94 ANU: '',
96 TIM: 'Co', 95 TIM: 'Co',
97 OPE: -888, // <= TODO: Cuando se haga el login poner codigo operario 96 OPE: -888, // <= TODO: Cuando se haga el login poner codigo operario
98 IMI2: cuerpo.IMI2, 97 IMI2: cuerpo.IMI2,
99 E_HD: '', 98 E_HD: '',
100 C_HD: '', 99 C_HD: '',
101 JUS: 'PLANEX', 100 JUS: 'PLANEX',
102 NLC: 0, 101 NLC: 0,
103 IMI3: cuerpo.IMI3, 102 IMI3: cuerpo.IMI3,
104 JJN: '', 103 JJN: '',
105 JDJ: '', 104 JDJ: '',
106 ID_MOTIVO_NANB: 0 105 ID_MOTIVO_NANB: 0
107 })); 106 }));
108 }; 107 };
109 108
110 cuerpo.estado == 'rechazado' ? cuerpo.cantidadRecibida = 0 : false; 109 cuerpo.estado == 'rechazado' ? cuerpo.cantidadRecibida = 0 : false;
111 110
112 delete cuerpo.GLN; 111 delete cuerpo.GLN;
113 delete cuerpo.C_HD2; 112 delete cuerpo.C_HD2;
114 delete cuerpo.E_HD2; 113 delete cuerpo.E_HD2;
115 delete cuerpo.codigoBarras; 114 delete cuerpo.codigoBarras;
116 delete cuerpo.estado; 115 delete cuerpo.estado;
117 delete cuerpo.recibido; 116 delete cuerpo.recibido;
118 delete cuerpo.input; 117 delete cuerpo.input;
119 delete cuerpo.tempRecibido; 118 delete cuerpo.tempRecibido;
120 119
121 cuerpo.LI0 = cuerpo.LI0.slice(0, 29); 120 cuerpo.LI0 = cuerpo.LI0.slice(0, 29);
122 cuerpo.TIO = cuerpo.TIO.slice(0, 29); 121 cuerpo.TIO = cuerpo.TIO.slice(0, 29);
123 122
124 promesas.push(knex('PMOVFACT').insert(cuerpo)); 123 promesas.push(knex('PMOVFACT').insert(cuerpo));
125 124
126 }); 125 });
127 126
128 Promise.all(promesas) 127 Promise.all(promesas)
129 .then(function() { 128 .then(function() {
130 129
131 Promise.all([ 130 Promise.all([
132 knex('PMAEFACT_TEMP').where({ 131 knex('PMAEFACT_TEMP').where({
133 TIP: req.body.cabecera.TIP, 132 TIP: req.body.cabecera.TIP,
134 TCO: req.body.cabecera.TCO, 133 TCO: req.body.cabecera.TCO,
135 SUC: req.body.cabecera.SUC, 134 SUC: req.body.cabecera.SUC,
136 NCO: req.body.cabecera.NCO, 135 NCO: req.body.cabecera.NCO,
137 COD: req.body.cabecera.COD 136 COD: req.body.cabecera.COD
138 }) 137 })
139 .del(), 138 .del(),
140 knex('PMOVFACT_TEMP').where({ 139 knex('PMOVFACT_TEMP').where({
141 TIP: req.body.cabecera.TIP, 140 TIP: req.body.cabecera.TIP,
142 TCO: req.body.cabecera.TCO, 141 TCO: req.body.cabecera.TCO,
143 SUC: req.body.cabecera.SUC, 142 SUC: req.body.cabecera.SUC,
144 NCO: req.body.cabecera.NCO 143 NCO: req.body.cabecera.NCO
145 }) 144 })
146 .del() 145 .del()
147 ]).then(function() { 146 ]).then(function() {
148 147
149 console.log('comprobantes guardados con éxito'); 148 console.log('comprobantes guardados con éxito');
150 resolve(); 149 resolve();
151 }) 150 })
152 151
153 }) 152 })
154 .catch(function(e) { 153 .catch(function(e) {
155 console.log(e); 154 console.log(e);
156 reject('Ocurrió un error'); 155 reject('Ocurrió un error');
157 }); 156 });
158 }); 157 });
159 } 158 }
160 } 159 }
161 } 160 }
162 161