Commit 023038490561a9b43067774c6bde2d7d87ffa52b
1 parent
e3d5403e41
Exists in
master
warning log jika gagal parsing xml direct response
Showing 1 changed file with 1 additions and 0 deletions Inline Diff
partner-sc.js
1 | var fs = require('fs'); | 1 | var fs = require('fs'); |
2 | var https = require('https'); | 2 | var https = require('https'); |
3 | var http = require('http'); | 3 | var http = require('http'); |
4 | var url = require('url'); | 4 | var url = require('url'); |
5 | var request = require('request'); | 5 | var request = require('request'); |
6 | var xml2js = require('xml2js').parseString; | 6 | var xml2js = require('xml2js').parseString; |
7 | var strftime = require('strftime'); | 7 | var strftime = require('strftime'); |
8 | var math = require('mathjs'); | 8 | var math = require('mathjs'); |
9 | var winston = require('winston'); | 9 | var winston = require('winston'); |
10 | var cekstatus = require('./cekstatus.js'); | 10 | var cekstatus = require('./cekstatus.js'); |
11 | var mongoClient = require('mongodb').MongoClient; | 11 | var mongoClient = require('mongodb').MongoClient; |
12 | var LRU = require('lru-cache'); | 12 | var LRU = require('lru-cache'); |
13 | 13 | ||
14 | var config; | 14 | var config; |
15 | var httpServer; | 15 | var httpServer; |
16 | var aaa; | 16 | var aaa; |
17 | var logger; | 17 | var logger; |
18 | var callbackReport; | 18 | var callbackReport; |
19 | var mongodb; | 19 | var mongodb; |
20 | 20 | ||
21 | var tasks = LRU(10000); | 21 | var tasks = LRU(10000); |
22 | 22 | ||
23 | process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0'; | 23 | process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0'; |
24 | 24 | ||
25 | var sleep_before_retry = 30000; | 25 | var sleep_before_retry = 30000; |
26 | var pendingResultCode = ['0005', '0012', '0068', '0090', '0063', '0018', '0096']; | 26 | var pendingResultCode = ['0005', '0012', '0068', '0090', '0063', '0018', '0096']; |
27 | 27 | ||
28 | var logTag = __filename.split('/').reverse()[0]; | 28 | var logTag = __filename.split('/').reverse()[0]; |
29 | 29 | ||
30 | function initMongoClient() { | 30 | function initMongoClient() { |
31 | if (!config.mongodbstruk || !config.mongodbstruk.url) { | 31 | if (!config.mongodbstruk || !config.mongodbstruk.url) { |
32 | return; | 32 | return; |
33 | } | 33 | } |
34 | 34 | ||
35 | try { | 35 | try { |
36 | var url = config.mongodbstruk.url; | 36 | var url = config.mongodbstruk.url; |
37 | 37 | ||
38 | mongoClient.connect(url, function(err, db) { | 38 | mongoClient.connect(url, function(err, db) { |
39 | if (err) { | 39 | if (err) { |
40 | logger.warn('Failed to connect to mongodb', {err: err}); | 40 | logger.warn('Failed to connect to mongodb', {err: err}); |
41 | return; | 41 | return; |
42 | } | 42 | } |
43 | mongodb = db; | 43 | mongodb = db; |
44 | logger.info('MongoDB connected'); | 44 | logger.info('MongoDB connected'); |
45 | }); | 45 | }); |
46 | } | 46 | } |
47 | catch(err) { | 47 | catch(err) { |
48 | logger.warn('Exception when connecting to mongodb', {err: err, url: url}); | 48 | logger.warn('Exception when connecting to mongodb', {err: err, url: url}); |
49 | } | 49 | } |
50 | 50 | ||
51 | } | 51 | } |
52 | 52 | ||
53 | function prepareResultData(result) { | 53 | function prepareResultData(result) { |
54 | var task; | 54 | var task; |
55 | 55 | ||
56 | var data = {}; | 56 | var data = {}; |
57 | data.gateway = config.globals.gateway_name; | 57 | data.gateway = config.globals.gateway_name; |
58 | 58 | ||
59 | try { | 59 | try { |
60 | data.requestId = result.reffid[0].trim(); | 60 | data.requestId = result.reffid[0].trim(); |
61 | 61 | ||
62 | var key = config.globals.gateway_name + '.rid:' + data.requestId; | 62 | var key = config.globals.gateway_name + '.rid:' + data.requestId; |
63 | task = tasks.get(key); | 63 | task = tasks.get(key); |
64 | } | 64 | } |
65 | catch(err) { data.requestId = null; } | 65 | catch(err) { data.requestId = null; } |
66 | 66 | ||
67 | try { | 67 | try { |
68 | data.status = result.ResultCode[0].trim(); | 68 | data.status = result.ResultCode[0].trim(); |
69 | } | 69 | } |
70 | catch(err) { data.status = '68' } | 70 | catch(err) { data.status = '68' } |
71 | 71 | ||
72 | try { | 72 | try { |
73 | data.rcmessage = result.ErrorMsg[0].trim(); | 73 | data.rcmessage = result.ErrorMsg[0].trim(); |
74 | } | 74 | } |
75 | catch(err) { data.rcmessage = ''; } | 75 | catch(err) { data.rcmessage = ''; } |
76 | 76 | ||
77 | try { | 77 | try { |
78 | data.resptext = ''; | 78 | data.resptext = ''; |
79 | } | 79 | } |
80 | catch(err) { data.resptext = ''; } | 80 | catch(err) { data.resptext = ''; } |
81 | 81 | ||
82 | try { | 82 | try { |
83 | var ts = moment(task.timestamp, 'YYYYMMDDHHmmss').format('YYYY-MM-DD HH:mm:ss') | 83 | var ts = moment(task.timestamp, 'YYYYMMDDHHmmss').format('YYYY-MM-DD HH:mm:ss') |
84 | data.dt = ts; | 84 | data.dt = ts; |
85 | } | 85 | } |
86 | catch(err) { | 86 | catch(err) { |
87 | logger.warn('Exception when getting timestamp data, using current timestamp', {err: err, result: result, task: task}); | 87 | logger.warn('Exception when getting timestamp data, using current timestamp', {err: err, result: result, task: task}); |
88 | data.dt = strftime('%Y-%m-%d %H:%M:%S', new Date()); | 88 | data.dt = strftime('%Y-%m-%d %H:%M:%S', new Date()); |
89 | } | 89 | } |
90 | 90 | ||
91 | try { | 91 | try { |
92 | data.namapel = result.nama_pel[0].trim(); | 92 | data.namapel = result.nama_pel[0].trim(); |
93 | } | 93 | } |
94 | catch(err) { data.namapel = 'UNKNOWN'; } | 94 | catch(err) { data.namapel = 'UNKNOWN'; } |
95 | 95 | ||
96 | try { | 96 | try { |
97 | data.msn = result.nsm[0].trim(); | 97 | data.msn = result.nsm[0].trim(); |
98 | } | 98 | } |
99 | catch(err) { data.msn = 'UNKNOWN'; } | 99 | catch(err) { data.msn = 'UNKNOWN'; } |
100 | 100 | ||
101 | try { | 101 | try { |
102 | data.idpel = result.idpel[0].trim(); | 102 | data.idpel = result.idpel[0].trim(); |
103 | } | 103 | } |
104 | catch(err) { data.idpel = 'UNKNOWN'; } | 104 | catch(err) { data.idpel = 'UNKNOWN'; } |
105 | 105 | ||
106 | try { | 106 | try { |
107 | data.tarifdaya = result.tarif[0].trim(); | 107 | data.tarifdaya = result.tarif[0].trim(); |
108 | } | 108 | } |
109 | catch(err) { data.tarifdaya = 'UNKNOWN'; } | 109 | catch(err) { data.tarifdaya = 'UNKNOWN'; } |
110 | 110 | ||
111 | try { | 111 | try { |
112 | data.admin = parseInt(result.adminfee[0].trim()); | 112 | data.admin = parseInt(result.adminfee[0].trim()); |
113 | } | 113 | } |
114 | catch(err) { data.admin = 0; } | 114 | catch(err) { data.admin = 0; } |
115 | 115 | ||
116 | try { | 116 | try { |
117 | data.adm = parseInt(result.admin_fee[0].trim()); | 117 | data.adm = parseInt(result.admin_fee[0].trim()); |
118 | } | 118 | } |
119 | catch(err) { data.adm = 0; } | 119 | catch(err) { data.adm = 0; } |
120 | 120 | ||
121 | try { | 121 | try { |
122 | data.hargapelanggan = parseInt(result.amount_trx[0].trim()); | 122 | data.hargapelanggan = parseInt(result.amount_trx[0].trim()); |
123 | } | 123 | } |
124 | catch(err) { data.hargapelanggan = 0; } | 124 | catch(err) { data.hargapelanggan = 0; } |
125 | 125 | ||
126 | try { | 126 | try { |
127 | data.jumlahkwh = result.jml_daya[0].trim(); | 127 | data.jumlahkwh = result.jml_daya[0].trim(); |
128 | } | 128 | } |
129 | catch(err) { data.jumlahkwh = 0; } | 129 | catch(err) { data.jumlahkwh = 0; } |
130 | 130 | ||
131 | try { | 131 | try { |
132 | data.token = result.token[0].trim(); | 132 | data.token = result.token[0].trim(); |
133 | } | 133 | } |
134 | catch(err) { data.token = 0; } | 134 | catch(err) { data.token = 0; } |
135 | 135 | ||
136 | try { | 136 | try { |
137 | data.ppn = result.ppn_fee[0].trim(); | 137 | data.ppn = result.ppn_fee[0].trim(); |
138 | } | 138 | } |
139 | catch(err) { data.ppn_fee = 0; } | 139 | catch(err) { data.ppn_fee = 0; } |
140 | 140 | ||
141 | try { | 141 | try { |
142 | data.ppj = result.ppj_fee[0].trim(); | 142 | data.ppj = result.ppj_fee[0].trim(); |
143 | } | 143 | } |
144 | catch(err) { data.ppj = 0; } | 144 | catch(err) { data.ppj = 0; } |
145 | 145 | ||
146 | try { | 146 | try { |
147 | data.angsuran = result.angsuran_fee[0].trim(); | 147 | data.angsuran = result.angsuran_fee[0].trim(); |
148 | } | 148 | } |
149 | catch(err) { data.angsuran = 0; } | 149 | catch(err) { data.angsuran = 0; } |
150 | 150 | ||
151 | try { | 151 | try { |
152 | data.meterai = result.materai_fee[0].trim(); | 152 | data.meterai = result.materai_fee[0].trim(); |
153 | } | 153 | } |
154 | catch(err) { data.materai_fee = 0; } | 154 | catch(err) { data.materai_fee = 0; } |
155 | 155 | ||
156 | return data; | 156 | return data; |
157 | } | 157 | } |
158 | 158 | ||
159 | function saveTokenToMongoDb(result) { | 159 | function saveTokenToMongoDb(result) { |
160 | if (!mongodb) { | 160 | if (!mongodb) { |
161 | return; | 161 | return; |
162 | } | 162 | } |
163 | 163 | ||
164 | if (!config.mongodbstruk) { | 164 | if (!config.mongodbstruk) { |
165 | return; | 165 | return; |
166 | } | 166 | } |
167 | 167 | ||
168 | if (!config.mongodbstruk.collection) { | 168 | if (!config.mongodbstruk.collection) { |
169 | return; | 169 | return; |
170 | } | 170 | } |
171 | 171 | ||
172 | data = prepareResultData(result); | 172 | data = prepareResultData(result); |
173 | 173 | ||
174 | try { | 174 | try { |
175 | mongodb.collection(config.mongodbstruk.collection).insertOne(data); | 175 | mongodb.collection(config.mongodbstruk.collection).insertOne(data); |
176 | } | 176 | } |
177 | catch(err) { | 177 | catch(err) { |
178 | logger.warn('Error when inserting data to mongodb', {err: err, data: data}); | 178 | logger.warn('Error when inserting data to mongodb', {err: err, data: data}); |
179 | } | 179 | } |
180 | } | 180 | } |
181 | 181 | ||
182 | function putTaskToCache(task) { | 182 | function putTaskToCache(task) { |
183 | var key = config.globals.gateway_name + '.rid:' + task.requestId; | 183 | var key = config.globals.gateway_name + '.rid:' + task.requestId; |
184 | 184 | ||
185 | try { | 185 | try { |
186 | tasks.set(key, task); | 186 | tasks.set(key, task); |
187 | } | 187 | } |
188 | catch(err) { | 188 | catch(err) { |
189 | logger.warn('Error writing to task to cache', {err: err, key: key, task: task}); | 189 | logger.warn('Error writing to task to cache', {err: err, key: key, task: task}); |
190 | } | 190 | } |
191 | } | 191 | } |
192 | 192 | ||
193 | function topupRequest(task) { | 193 | function topupRequest(task) { |
194 | aaa.insertTaskToMongoDb(task); | 194 | aaa.insertTaskToMongoDb(task); |
195 | putTaskToCache(task); | 195 | putTaskToCache(task); |
196 | 196 | ||
197 | var ts = strftime('%Y%m%d%H%M%S', new Date()); | 197 | var ts = strftime('%Y%m%d%H%M%S', new Date()); |
198 | 198 | ||
199 | var data = | 199 | var data = |
200 | config.h2h_out.userid | 200 | config.h2h_out.userid |
201 | + '|' + config.h2h_out.password | 201 | + '|' + config.h2h_out.password |
202 | + '|' + task['remoteProduct'] | 202 | + '|' + task['remoteProduct'] |
203 | + '|' + task['destination'] + '|0'; | 203 | + '|' + task['destination'] + '|0'; |
204 | 204 | ||
205 | var options = { | 205 | var options = { |
206 | url: config.h2h_out.partner, | 206 | url: config.h2h_out.partner, |
207 | qs: { | 207 | qs: { |
208 | ts: ts, | 208 | ts: ts, |
209 | data: data, | 209 | data: data, |
210 | reffid: task['requestId'] | 210 | reffid: task['requestId'] |
211 | } | 211 | } |
212 | }; | 212 | }; |
213 | logger.info('Creating http request', {options: options}); | 213 | logger.info('Creating http request', {options: options}); |
214 | 214 | ||
215 | request(options, function (error, response, body) { | 215 | request(options, function (error, response, body) { |
216 | var responseCode = '40'; | 216 | var responseCode = '40'; |
217 | var responseMessage = 'Gateway Error'; | 217 | var responseMessage = 'Gateway Error'; |
218 | 218 | ||
219 | if (error) { | 219 | if (error) { |
220 | 220 | ||
221 | logger.warn('HTTP REQUEST ERROR', error); | 221 | logger.warn('HTTP REQUEST ERROR', error); |
222 | callbackReport(task['requestId'], '89', 'HTTP REQUEST ERROR (' + error + ')'); | 222 | callbackReport(task['requestId'], '89', 'HTTP REQUEST ERROR (' + error + ')'); |
223 | 223 | ||
224 | } else if (response.statusCode != 200) { | 224 | } else if (response.statusCode != 200) { |
225 | 225 | ||
226 | var error_message = 'GATEWAY ERROR (HTTP RESPONSE CODE: ' + response.statusCode + ')'; | 226 | var error_message = 'GATEWAY ERROR (HTTP RESPONSE CODE: ' + response.statusCode + ')'; |
227 | logger.warn(error_message); | 227 | logger.warn(error_message); |
228 | callbackReport(task['requestId'], '91', error_message); | 228 | callbackReport(task['requestId'], '91', error_message); |
229 | 229 | ||
230 | } else { | 230 | } else { |
231 | 231 | ||
232 | logger.info('DIRECT RESPONSE', {body: body}); | 232 | logger.info('DIRECT RESPONSE', {body: body}); |
233 | 233 | ||
234 | xml2js(body, function (err, result) { | 234 | xml2js(body, function (err, result) { |
235 | if (err) { | 235 | if (err) { |
236 | logger.warn('Error parsing xml response', {requestId: task.requestId, err: err, body: body}); | ||
236 | callbackReport(task['requestId'], '40', body); | 237 | callbackReport(task['requestId'], '40', body); |
237 | } else { | 238 | } else { |
238 | var directResponse = result; | 239 | var directResponse = result; |
239 | logger.info(directResponse); | 240 | logger.info(directResponse); |
240 | 241 | ||
241 | saveTokenToMongoDb(directResponse.Result); | 242 | saveTokenToMongoDb(directResponse.Result); |
242 | 243 | ||
243 | try { | 244 | try { |
244 | var result_price; | 245 | var result_price; |
245 | try { | 246 | try { |
246 | result_price = directResponse.Result.Price[0].trim(); | 247 | result_price = directResponse.Result.Price[0].trim(); |
247 | } | 248 | } |
248 | catch(err) { | 249 | catch(err) { |
249 | result_price = 0; | 250 | result_price = 0; |
250 | } | 251 | } |
251 | 252 | ||
252 | var result_error_message; | 253 | var result_error_message; |
253 | try { | 254 | try { |
254 | result_error_message = directResponse.Result.ErrorMsg[0].trim(); | 255 | result_error_message = directResponse.Result.ErrorMsg[0].trim(); |
255 | } | 256 | } |
256 | catch(err) { | 257 | catch(err) { |
257 | result_error_message = ''; | 258 | result_error_message = ''; |
258 | } | 259 | } |
259 | 260 | ||
260 | var resultCode = directResponse.Result.ResultCode[0].trim(); | 261 | var resultCode = directResponse.Result.ResultCode[0].trim(); |
261 | 262 | ||
262 | responseMessage = | 263 | responseMessage = |
263 | 'ResultCode: ' + resultCode | 264 | 'ResultCode: ' + resultCode |
264 | + ' | ErrorMsg: ' + result_error_message | 265 | + ' | ErrorMsg: ' + result_error_message |
265 | + ' | DateTime: ' + directResponse.Result.DateTime[0].trim() | 266 | + ' | DateTime: ' + directResponse.Result.DateTime[0].trim() |
266 | + ' | nsm: ' + directResponse.Result.nsm[0].trim() | 267 | + ' | nsm: ' + directResponse.Result.nsm[0].trim() |
267 | + ' | idpel: ' + directResponse.Result.idpel[0].trim() | 268 | + ' | idpel: ' + directResponse.Result.idpel[0].trim() |
268 | + ' | reffid: ' + directResponse.Result.reffid[0].trim() | 269 | + ' | reffid: ' + directResponse.Result.reffid[0].trim() |
269 | + ' | TransID: ' + directResponse.Result.TransID[0].trim() | 270 | + ' | TransID: ' + directResponse.Result.TransID[0].trim() |
270 | + ' | reff_switching: ' + directResponse.Result.reff_switching[0].trim() | 271 | + ' | reff_switching: ' + directResponse.Result.reff_switching[0].trim() |
271 | + ' | amount_trx: ' + directResponse.Result.amount_trx[0].trim() | 272 | + ' | amount_trx: ' + directResponse.Result.amount_trx[0].trim() |
272 | + ' | token: ' + directResponse.Result.token[0].trim() | 273 | + ' | token: ' + directResponse.Result.token[0].trim() |
273 | + ' | PrevBalance: ' + directResponse.Result.PrevBalance[0].trim() | 274 | + ' | PrevBalance: ' + directResponse.Result.PrevBalance[0].trim() |
274 | + ' | Price: ' + result_price | 275 | + ' | Price: ' + result_price |
275 | + ' | EndBalance: ' + directResponse.Result.EndBalance[0].trim() | 276 | + ' | EndBalance: ' + directResponse.Result.EndBalance[0].trim() |
276 | ; | 277 | ; |
277 | 278 | ||
278 | logger.info('Response message: ' + responseMessage); | 279 | logger.info('Response message: ' + responseMessage); |
279 | 280 | ||
280 | if (aaa) { | 281 | if (aaa) { |
281 | // update balance | 282 | // update balance |
282 | aaa.updateBalance(directResponse.Result.EndBalance[0]); | 283 | aaa.updateBalance(directResponse.Result.EndBalance[0]); |
283 | } | 284 | } |
284 | 285 | ||
285 | if (resultCode == '0000') { | 286 | if (resultCode == '0000') { |
286 | var nama_pelanggan = directResponse.Result.nama_pel[0].trim(); | 287 | var nama_pelanggan = directResponse.Result.nama_pel[0].trim(); |
287 | nama_pelanggan = nama_pelanggan.replace(/-\/-/g, '-'); | 288 | nama_pelanggan = nama_pelanggan.replace(/-\/-/g, '-'); |
288 | var sn = directResponse.Result.token[0].trim() + '/' + nama_pelanggan + '/' + directResponse.Result.tarif[0].trim() + 'VA/' + directResponse.Result.jml_daya[0].trim(); | 289 | var sn = directResponse.Result.token[0].trim() + '/' + nama_pelanggan + '/' + directResponse.Result.tarif[0].trim() + 'VA/' + directResponse.Result.jml_daya[0].trim(); |
289 | sn = sn.replace(/\s/g, '-'); | 290 | sn = sn.replace(/\s/g, '-'); |
290 | 291 | ||
291 | responseMessage = 'SN=' + sn + '; ' + responseMessage; | 292 | responseMessage = 'SN=' + sn + '; ' + responseMessage; |
292 | logger.info('New response message: ' + responseMessage); | 293 | logger.info('New response message: ' + responseMessage); |
293 | } | 294 | } |
294 | 295 | ||
295 | if (pendingResultCode.indexOf(resultCode) != -1) { | 296 | if (pendingResultCode.indexOf(resultCode) != -1) { |
296 | callbackReport(task['requestId'], '68', responseMessage); | 297 | callbackReport(task['requestId'], '68', responseMessage); |
297 | 298 | ||
298 | logger.info('Got pending status, requesting advice from webreport in ' + sleep_before_retry + 'ms'); | 299 | logger.info('Got pending status, requesting advice from webreport in ' + sleep_before_retry + 'ms'); |
299 | setTimeout(function () { | 300 | setTimeout(function () { |
300 | cekstatus.advice({trxid: directResponse.Result.TransID[0].trim()}, callbackFromWebReport); | 301 | cekstatus.advice({trxid: directResponse.Result.TransID[0].trim()}, callbackFromWebReport); |
301 | }, sleep_before_retry); | 302 | }, sleep_before_retry); |
302 | 303 | ||
303 | return; | 304 | return; |
304 | } | 305 | } |
305 | 306 | ||
306 | responseCode = resultCode.replace(/^00/, ""); | 307 | responseCode = resultCode.replace(/^00/, ""); |
307 | 308 | ||
308 | if (result_error_message == 'Inq - APLICATION SERVER RESPONSE TIMEOUT') { | 309 | if (result_error_message == 'Inq - APLICATION SERVER RESPONSE TIMEOUT') { |
309 | responseCode = '91'; | 310 | responseCode = '91'; |
310 | } | 311 | } |
311 | 312 | ||
312 | } | 313 | } |
313 | catch(err) { | 314 | catch(err) { |
314 | responseCode = '40'; | 315 | responseCode = '40'; |
315 | responseMessage = 'Invalid response from gateway'; | 316 | responseMessage = 'Invalid response from gateway'; |
316 | } | 317 | } |
317 | } | 318 | } |
318 | 319 | ||
319 | callbackReport(task['requestId'], responseCode, responseMessage); | 320 | callbackReport(task['requestId'], responseCode, responseMessage); |
320 | }); | 321 | }); |
321 | } | 322 | } |
322 | 323 | ||
323 | //callbackReport(task['requestId'], responseCode, responseMessage); | 324 | //callbackReport(task['requestId'], responseCode, responseMessage); |
324 | }); | 325 | }); |
325 | } | 326 | } |
326 | 327 | ||
327 | function callbackFromWebReport(status) { | 328 | function callbackFromWebReport(status) { |
328 | if (!status) { | 329 | if (!status) { |
329 | logger.warn('Advice from webreport return empty status'); | 330 | logger.warn('Advice from webreport return empty status'); |
330 | return; | 331 | return; |
331 | } | 332 | } |
332 | 333 | ||
333 | logger.info('Got advice result from webreport', {status: status}); | 334 | logger.info('Got advice result from webreport', {status: status}); |
334 | 335 | ||
335 | var responseCode = '68'; | 336 | var responseCode = '68'; |
336 | 337 | ||
337 | var result_price = 0; | 338 | var result_price = 0; |
338 | try { | 339 | try { |
339 | result_price = directResponse.Result.Price[0].trim(); | 340 | result_price = directResponse.Result.Price[0].trim(); |
340 | } | 341 | } |
341 | catch(err) {} | 342 | catch(err) {} |
342 | 343 | ||
343 | var errorMsg = ''; | 344 | var errorMsg = ''; |
344 | try { | 345 | try { |
345 | errorMsg = status.response.errormsg[0]; | 346 | errorMsg = status.response.errormsg[0]; |
346 | } | 347 | } |
347 | catch(err) {} | 348 | catch(err) {} |
348 | 349 | ||
349 | var responseMessage = ''; | 350 | var responseMessage = ''; |
350 | try { | 351 | try { |
351 | responseMessage = | 352 | responseMessage = |
352 | 'Hasil advice dari webreport ' | 353 | 'Hasil advice dari webreport ' |
353 | + 'ResultCode: ' + status.response.resultcode[0] | 354 | + 'ResultCode: ' + status.response.resultcode[0] |
354 | } | 355 | } |
355 | catch(err) { | 356 | catch(err) { |
356 | logger.warn('Error parsing ResultCode from webreport advice.', {err: err}); | 357 | logger.warn('Error parsing ResultCode from webreport advice.', {err: err}); |
357 | } | 358 | } |
358 | 359 | ||
359 | try { | 360 | try { |
360 | responseMessage = | 361 | responseMessage = |
361 | responseMessage | 362 | responseMessage |
362 | + ' | ErrorMsg: ' + errorMsg | 363 | + ' | ErrorMsg: ' + errorMsg |
363 | } | 364 | } |
364 | catch(err) { | 365 | catch(err) { |
365 | logger.warn('Error parsing ErrorMsg from webreport advice.', {err: err}); | 366 | logger.warn('Error parsing ErrorMsg from webreport advice.', {err: err}); |
366 | } | 367 | } |
367 | 368 | ||
368 | try { | 369 | try { |
369 | responseMessage = | 370 | responseMessage = |
370 | responseMessage | 371 | responseMessage |
371 | + ' | TrxDate: ' + status.trxDate; | 372 | + ' | TrxDate: ' + status.trxDate; |
372 | } | 373 | } |
373 | catch(err) { | 374 | catch(err) { |
374 | logger.warn('Error parsing TrxDate from webreport advice.', {err: err}); | 375 | logger.warn('Error parsing TrxDate from webreport advice.', {err: err}); |
375 | } | 376 | } |
376 | 377 | ||
377 | try { | 378 | try { |
378 | responseMessage = | 379 | responseMessage = |
379 | responseMessage | 380 | responseMessage |
380 | + ' | UpdateDate: ' + status.updateDate; | 381 | + ' | UpdateDate: ' + status.updateDate; |
381 | 382 | ||
382 | } | 383 | } |
383 | catch(err) { | 384 | catch(err) { |
384 | logger.warn('Error parsing UpdateDate from webreport advice.', {err: err}); | 385 | logger.warn('Error parsing UpdateDate from webreport advice.', {err: err}); |
385 | } | 386 | } |
386 | 387 | ||
387 | try { | 388 | try { |
388 | responseMessage = | 389 | responseMessage = |
389 | responseMessage | 390 | responseMessage |
390 | + ' | nsm: ' + status.response.nsm[0]; | 391 | + ' | nsm: ' + status.response.nsm[0]; |
391 | } | 392 | } |
392 | catch(err) { | 393 | catch(err) { |
393 | logger.warn('Error parsing nsm from webreport advice.', {err: err}); | 394 | logger.warn('Error parsing nsm from webreport advice.', {err: err}); |
394 | } | 395 | } |
395 | 396 | ||
396 | try { | 397 | try { |
397 | responseMessage = | 398 | responseMessage = |
398 | responseMessage | 399 | responseMessage |
399 | + ' | idpel: ' + status.response.idpel[0]; | 400 | + ' | idpel: ' + status.response.idpel[0]; |
400 | } | 401 | } |
401 | catch(err) { | 402 | catch(err) { |
402 | logger.warn('Error parsing idpel from webreport advice.', {err: err}); | 403 | logger.warn('Error parsing idpel from webreport advice.', {err: err}); |
403 | } | 404 | } |
404 | 405 | ||
405 | try { | 406 | try { |
406 | responseMessage = | 407 | responseMessage = |
407 | responseMessage | 408 | responseMessage |
408 | + ' | reffid: ' + status.response.reffid[0].trim(); | 409 | + ' | reffid: ' + status.response.reffid[0].trim(); |
409 | } | 410 | } |
410 | catch(err) { | 411 | catch(err) { |
411 | logger.warn('Error parsing reffid from webreport advice.', {err: err}); | 412 | logger.warn('Error parsing reffid from webreport advice.', {err: err}); |
412 | } | 413 | } |
413 | 414 | ||
414 | try { | 415 | try { |
415 | responseMessage = | 416 | responseMessage = |
416 | responseMessage | 417 | responseMessage |
417 | + ' | TransID: ' + status.response.transid[0].trim(); | 418 | + ' | TransID: ' + status.response.transid[0].trim(); |
418 | } | 419 | } |
419 | catch(err) { | 420 | catch(err) { |
420 | logger.warn('Error parsing TransID from webreport advice.', {err: err}); | 421 | logger.warn('Error parsing TransID from webreport advice.', {err: err}); |
421 | } | 422 | } |
422 | 423 | ||
423 | try { | 424 | try { |
424 | responseMessage = | 425 | responseMessage = |
425 | responseMessage | 426 | responseMessage |
426 | + ' | reff_switching: ' + status.response.reff_switching[0]; | 427 | + ' | reff_switching: ' + status.response.reff_switching[0]; |
427 | } | 428 | } |
428 | catch(err) { | 429 | catch(err) { |
429 | logger.warn('Error parsing reff_switching from webreport advice.', {err: err}); | 430 | logger.warn('Error parsing reff_switching from webreport advice.', {err: err}); |
430 | } | 431 | } |
431 | 432 | ||
432 | try { | 433 | try { |
433 | responseMessage = | 434 | responseMessage = |
434 | responseMessage | 435 | responseMessage |
435 | + ' | amount_trx: ' + status.response.amount_trx[0]; | 436 | + ' | amount_trx: ' + status.response.amount_trx[0]; |
436 | } | 437 | } |
437 | catch(err) { | 438 | catch(err) { |
438 | logger.warn('Error parsing amount_trx from webreport advice.', {err: err}); | 439 | logger.warn('Error parsing amount_trx from webreport advice.', {err: err}); |
439 | } | 440 | } |
440 | 441 | ||
441 | try { | 442 | try { |
442 | responseMessage = | 443 | responseMessage = |
443 | responseMessage | 444 | responseMessage |
444 | + ' | token: ' + status.response.token[0]; | 445 | + ' | token: ' + status.response.token[0]; |
445 | } | 446 | } |
446 | catch(err) { | 447 | catch(err) { |
447 | logger.warn('Error parsing token from webreport advice.', {err: err}); | 448 | logger.warn('Error parsing token from webreport advice.', {err: err}); |
448 | } | 449 | } |
449 | 450 | ||
450 | try { | 451 | try { |
451 | responseMessage = | 452 | responseMessage = |
452 | responseMessage | 453 | responseMessage |
453 | + ' | PrevBalance: ' + status.response.prevbalance[0]; | 454 | + ' | PrevBalance: ' + status.response.prevbalance[0]; |
454 | } | 455 | } |
455 | catch(err) { | 456 | catch(err) { |
456 | logger.warn('Error parsing PrevBalance from webreport advice.', {err: err}); | 457 | logger.warn('Error parsing PrevBalance from webreport advice.', {err: err}); |
457 | } | 458 | } |
458 | 459 | ||
459 | try { | 460 | try { |
460 | responseMessage = | 461 | responseMessage = |
461 | responseMessage | 462 | responseMessage |
462 | + ' | Price: ' + status.amount; | 463 | + ' | Price: ' + status.amount; |
463 | } | 464 | } |
464 | catch(err) { | 465 | catch(err) { |
465 | logger.warn('Error parsing Price from webreport advice.', {err: err}); | 466 | logger.warn('Error parsing Price from webreport advice.', {err: err}); |
466 | } | 467 | } |
467 | 468 | ||
468 | try { | 469 | try { |
469 | responseMessage = | 470 | responseMessage = |
470 | responseMessage | 471 | responseMessage |
471 | + ' | EndBalance: ' + status.response.endbalance[0]; | 472 | + ' | EndBalance: ' + status.response.endbalance[0]; |
472 | } | 473 | } |
473 | catch(err) { | 474 | catch(err) { |
474 | logger.warn('Error parsing EndBalance from webreport advice.', {err: err}); | 475 | logger.warn('Error parsing EndBalance from webreport advice.', {err: err}); |
475 | } | 476 | } |
476 | 477 | ||
477 | 478 | ||
478 | if ((status.status == 'S') && (status.response.resultcode[0] == '0000')) { | 479 | if ((status.status == 'S') && (status.response.resultcode[0] == '0000')) { |
479 | responseCode = '00'; | 480 | responseCode = '00'; |
480 | 481 | ||
481 | var nama_pelanggan = status.response.nama_pel[0] ; | 482 | var nama_pelanggan = status.response.nama_pel[0] ; |
482 | nama_pelanggan = nama_pelanggan.replace(/-\/-/g, '-'); | 483 | nama_pelanggan = nama_pelanggan.replace(/-\/-/g, '-'); |
483 | 484 | ||
484 | var sn = status.response.token[0] + '/' + nama_pelanggan + '/' + status.response.tarif[0] + 'VA/' + status.response.jml_daya[0]; | 485 | var sn = status.response.token[0] + '/' + nama_pelanggan + '/' + status.response.tarif[0] + 'VA/' + status.response.jml_daya[0]; |
485 | responseMessage = 'SN=' + sn + '; ' + responseMessage; | 486 | responseMessage = 'SN=' + sn + '; ' + responseMessage; |
486 | 487 | ||
487 | } else if ((status.status == 'P') || (status.status == 'W')) { | 488 | } else if ((status.status == 'P') || (status.status == 'W')) { |
488 | 489 | ||
489 | callbackReport(status.response.reffid[0].trim(), '68', responseMessage); | 490 | callbackReport(status.response.reffid[0].trim(), '68', responseMessage); |
490 | logger.info('Got pending status, requesting advice from webreport in ' + sleep_before_retry + 'ms'); | 491 | logger.info('Got pending status, requesting advice from webreport in ' + sleep_before_retry + 'ms'); |
491 | 492 | ||
492 | setTimeout(function () { | 493 | setTimeout(function () { |
493 | 494 | ||
494 | cekstatus.advice({trxid: status.trxId,}, callbackFromWebReport); | 495 | cekstatus.advice({trxid: status.trxId,}, callbackFromWebReport); |
495 | 496 | ||
496 | }, sleep_before_retry); | 497 | }, sleep_before_retry); |
497 | return; | 498 | return; |
498 | 499 | ||
499 | } else { | 500 | } else { |
500 | responseCode = status.response.resultcode[0].replace(/^00/, ""); | 501 | responseCode = status.response.resultcode[0].replace(/^00/, ""); |
501 | if (['00', '05', '12', '68', '90', '63', '18', '96'].indexOf(responseCode) >= 0) { | 502 | if (['00', '05', '12', '68', '90', '63', '18', '96'].indexOf(responseCode) >= 0) { |
502 | responseCode = '40'; | 503 | responseCode = '40'; |
503 | } | 504 | } |
504 | } | 505 | } |
505 | 506 | ||
506 | 507 | ||
507 | callbackReport(status.response.reffid[0].trim(), responseCode, responseMessage); | 508 | callbackReport(status.response.reffid[0].trim(), responseCode, responseMessage); |
508 | } | 509 | } |
509 | 510 | ||
510 | function createHttpReportServer() { | 511 | function createHttpReportServer() { |
511 | var httpServer = http.createServer(function(request, response) { | 512 | var httpServer = http.createServer(function(request, response) { |
512 | var qs = url.parse(request.url, true).query; | 513 | var qs = url.parse(request.url, true).query; |
513 | var path = url.parse(request.url).pathname; | 514 | var path = url.parse(request.url).pathname; |
514 | 515 | ||
515 | logger.info('Got reverse report from partner', {path: path, qs: qs}); | 516 | logger.info('Got reverse report from partner', {path: path, qs: qs}); |
516 | response.end('OK'); | 517 | response.end('OK'); |
517 | 518 | ||
518 | var requestId = qs.reffid; | 519 | var requestId = qs.reffid; |
519 | var resultCode = qs.rescode; | 520 | var resultCode = qs.rescode; |
520 | 521 | ||
521 | if (requestId && resultCode && resultCode != '0') { | 522 | if (requestId && resultCode && resultCode != '0') { |
522 | if (pendingResultCode.indexOf(resultCode) >= 0) { | 523 | if (pendingResultCode.indexOf(resultCode) >= 0) { |
523 | callbackReport(requestId, '68', 'Got reverse report: ' + qs.msg); | 524 | callbackReport(requestId, '68', 'Got reverse report: ' + qs.msg); |
524 | } else { | 525 | } else { |
525 | callbackReport(requestId, '40', 'Got reverse report: ' + qs.msg); | 526 | callbackReport(requestId, '40', 'Got reverse report: ' + qs.msg); |
526 | } | 527 | } |
527 | return; | 528 | return; |
528 | } | 529 | } |
529 | 530 | ||
530 | var trxid; | 531 | var trxid; |
531 | try { | 532 | try { |
532 | trxid = qs.transid; | 533 | trxid = qs.transid; |
533 | } | 534 | } |
534 | catch(err) { | 535 | catch(err) { |
535 | } | 536 | } |
536 | 537 | ||
537 | if (trxid) { | 538 | if (trxid) { |
538 | logger.info('Requesting advice from webreport', {trxid: trxid}) | 539 | logger.info('Requesting advice from webreport', {trxid: trxid}) |
539 | cekstatus.advice({trxid: trxid}, callbackFromWebReport); | 540 | cekstatus.advice({trxid: trxid}, callbackFromWebReport); |
540 | } | 541 | } |
541 | 542 | ||
542 | }); | 543 | }); |
543 | 544 | ||
544 | httpServer.listen(config.h2h_out.listen_port, function() { | 545 | httpServer.listen(config.h2h_out.listen_port, function() { |
545 | logger.info('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port); | 546 | logger.info('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port); |
546 | }); | 547 | }); |
547 | } | 548 | } |
548 | 549 | ||
549 | function start(options) { | 550 | function start(options) { |
550 | if (!options) { | 551 | if (!options) { |
551 | console.log('Undefined options, terminating....'); | 552 | console.log('Undefined options, terminating....'); |
552 | process.exit(1); | 553 | process.exit(1); |
553 | } | 554 | } |
554 | 555 | ||
555 | if (options.config) { | 556 | if (options.config) { |
556 | config = options.config; | 557 | config = options.config; |
557 | } else { | 558 | } else { |
558 | console.log('Undefined options.config, terminating....') | 559 | console.log('Undefined options.config, terminating....') |
559 | process.exit(1); | 560 | process.exit(1); |
560 | } | 561 | } |
561 | 562 | ||
562 | if (options.aaa) { | 563 | if (options.aaa) { |
563 | aaa = options.aaa; | 564 | aaa = options.aaa; |
564 | callbackReport = options.aaa.callbackReportWithPushToMongoDb; | 565 | callbackReport = options.aaa.callbackReportWithPushToMongoDb; |
565 | } else { | 566 | } else { |
566 | console.log('Undefined options.aaa, terminating....') | 567 | console.log('Undefined options.aaa, terminating....') |
567 | process.exit(1); | 568 | process.exit(1); |
568 | } | 569 | } |
569 | 570 | ||
570 | if (options && options.logger) { | 571 | if (options && options.logger) { |
571 | logger = options.logger; | 572 | logger = options.logger; |
572 | } else { | 573 | } else { |
573 | logger = new winston.Logger({ | 574 | logger = new winston.Logger({ |
574 | transports: [ | 575 | transports: [ |
575 | new (winston.transports.Console)() | 576 | new (winston.transports.Console)() |
576 | ] | 577 | ] |
577 | }); | 578 | }); |
578 | } | 579 | } |
579 | 580 | ||
580 | createHttpReportServer(); | 581 | createHttpReportServer(); |
581 | initMongoClient(); | 582 | initMongoClient(); |
582 | } | 583 | } |
583 | 584 | ||
584 | exports.start = start; | 585 | exports.start = start; |
585 | exports.topupRequest = topupRequest; | 586 | exports.topupRequest = topupRequest; |
586 | 587 |