Commit e3d5403e416bb4bf312581b8c12e9958f313ec84
1 parent
d7a34173c4
Exists in
master
fix typo resultCode on reverse report
Showing 1 changed file with 1 additions and 1 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 | callbackReport(task['requestId'], '40', body); | 236 | callbackReport(task['requestId'], '40', body); |
237 | } else { | 237 | } else { |
238 | var directResponse = result; | 238 | var directResponse = result; |
239 | logger.info(directResponse); | 239 | logger.info(directResponse); |
240 | 240 | ||
241 | saveTokenToMongoDb(directResponse.Result); | 241 | saveTokenToMongoDb(directResponse.Result); |
242 | 242 | ||
243 | try { | 243 | try { |
244 | var result_price; | 244 | var result_price; |
245 | try { | 245 | try { |
246 | result_price = directResponse.Result.Price[0].trim(); | 246 | result_price = directResponse.Result.Price[0].trim(); |
247 | } | 247 | } |
248 | catch(err) { | 248 | catch(err) { |
249 | result_price = 0; | 249 | result_price = 0; |
250 | } | 250 | } |
251 | 251 | ||
252 | var result_error_message; | 252 | var result_error_message; |
253 | try { | 253 | try { |
254 | result_error_message = directResponse.Result.ErrorMsg[0].trim(); | 254 | result_error_message = directResponse.Result.ErrorMsg[0].trim(); |
255 | } | 255 | } |
256 | catch(err) { | 256 | catch(err) { |
257 | result_error_message = ''; | 257 | result_error_message = ''; |
258 | } | 258 | } |
259 | 259 | ||
260 | var resultCode = directResponse.Result.ResultCode[0].trim(); | 260 | var resultCode = directResponse.Result.ResultCode[0].trim(); |
261 | 261 | ||
262 | responseMessage = | 262 | responseMessage = |
263 | 'ResultCode: ' + resultCode | 263 | 'ResultCode: ' + resultCode |
264 | + ' | ErrorMsg: ' + result_error_message | 264 | + ' | ErrorMsg: ' + result_error_message |
265 | + ' | DateTime: ' + directResponse.Result.DateTime[0].trim() | 265 | + ' | DateTime: ' + directResponse.Result.DateTime[0].trim() |
266 | + ' | nsm: ' + directResponse.Result.nsm[0].trim() | 266 | + ' | nsm: ' + directResponse.Result.nsm[0].trim() |
267 | + ' | idpel: ' + directResponse.Result.idpel[0].trim() | 267 | + ' | idpel: ' + directResponse.Result.idpel[0].trim() |
268 | + ' | reffid: ' + directResponse.Result.reffid[0].trim() | 268 | + ' | reffid: ' + directResponse.Result.reffid[0].trim() |
269 | + ' | TransID: ' + directResponse.Result.TransID[0].trim() | 269 | + ' | TransID: ' + directResponse.Result.TransID[0].trim() |
270 | + ' | reff_switching: ' + directResponse.Result.reff_switching[0].trim() | 270 | + ' | reff_switching: ' + directResponse.Result.reff_switching[0].trim() |
271 | + ' | amount_trx: ' + directResponse.Result.amount_trx[0].trim() | 271 | + ' | amount_trx: ' + directResponse.Result.amount_trx[0].trim() |
272 | + ' | token: ' + directResponse.Result.token[0].trim() | 272 | + ' | token: ' + directResponse.Result.token[0].trim() |
273 | + ' | PrevBalance: ' + directResponse.Result.PrevBalance[0].trim() | 273 | + ' | PrevBalance: ' + directResponse.Result.PrevBalance[0].trim() |
274 | + ' | Price: ' + result_price | 274 | + ' | Price: ' + result_price |
275 | + ' | EndBalance: ' + directResponse.Result.EndBalance[0].trim() | 275 | + ' | EndBalance: ' + directResponse.Result.EndBalance[0].trim() |
276 | ; | 276 | ; |
277 | 277 | ||
278 | logger.info('Response message: ' + responseMessage); | 278 | logger.info('Response message: ' + responseMessage); |
279 | 279 | ||
280 | if (aaa) { | 280 | if (aaa) { |
281 | // update balance | 281 | // update balance |
282 | aaa.updateBalance(directResponse.Result.EndBalance[0]); | 282 | aaa.updateBalance(directResponse.Result.EndBalance[0]); |
283 | } | 283 | } |
284 | 284 | ||
285 | if (resultCode == '0000') { | 285 | if (resultCode == '0000') { |
286 | var nama_pelanggan = directResponse.Result.nama_pel[0].trim(); | 286 | var nama_pelanggan = directResponse.Result.nama_pel[0].trim(); |
287 | nama_pelanggan = nama_pelanggan.replace(/-\/-/g, '-'); | 287 | 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(); | 288 | 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, '-'); | 289 | sn = sn.replace(/\s/g, '-'); |
290 | 290 | ||
291 | responseMessage = 'SN=' + sn + '; ' + responseMessage; | 291 | responseMessage = 'SN=' + sn + '; ' + responseMessage; |
292 | logger.info('New response message: ' + responseMessage); | 292 | logger.info('New response message: ' + responseMessage); |
293 | } | 293 | } |
294 | 294 | ||
295 | if (pendingResultCode.indexOf(resultCode) != -1) { | 295 | if (pendingResultCode.indexOf(resultCode) != -1) { |
296 | callbackReport(task['requestId'], '68', responseMessage); | 296 | callbackReport(task['requestId'], '68', responseMessage); |
297 | 297 | ||
298 | logger.info('Got pending status, requesting advice from webreport in ' + sleep_before_retry + 'ms'); | 298 | logger.info('Got pending status, requesting advice from webreport in ' + sleep_before_retry + 'ms'); |
299 | setTimeout(function () { | 299 | setTimeout(function () { |
300 | cekstatus.advice({trxid: directResponse.Result.TransID[0].trim()}, callbackFromWebReport); | 300 | cekstatus.advice({trxid: directResponse.Result.TransID[0].trim()}, callbackFromWebReport); |
301 | }, sleep_before_retry); | 301 | }, sleep_before_retry); |
302 | 302 | ||
303 | return; | 303 | return; |
304 | } | 304 | } |
305 | 305 | ||
306 | responseCode = resultCode.replace(/^00/, ""); | 306 | responseCode = resultCode.replace(/^00/, ""); |
307 | 307 | ||
308 | if (result_error_message == 'Inq - APLICATION SERVER RESPONSE TIMEOUT') { | 308 | if (result_error_message == 'Inq - APLICATION SERVER RESPONSE TIMEOUT') { |
309 | responseCode = '91'; | 309 | responseCode = '91'; |
310 | } | 310 | } |
311 | 311 | ||
312 | } | 312 | } |
313 | catch(err) { | 313 | catch(err) { |
314 | responseCode = '40'; | 314 | responseCode = '40'; |
315 | responseMessage = 'Invalid response from gateway'; | 315 | responseMessage = 'Invalid response from gateway'; |
316 | } | 316 | } |
317 | } | 317 | } |
318 | 318 | ||
319 | callbackReport(task['requestId'], responseCode, responseMessage); | 319 | callbackReport(task['requestId'], responseCode, responseMessage); |
320 | }); | 320 | }); |
321 | } | 321 | } |
322 | 322 | ||
323 | //callbackReport(task['requestId'], responseCode, responseMessage); | 323 | //callbackReport(task['requestId'], responseCode, responseMessage); |
324 | }); | 324 | }); |
325 | } | 325 | } |
326 | 326 | ||
327 | function callbackFromWebReport(status) { | 327 | function callbackFromWebReport(status) { |
328 | if (!status) { | 328 | if (!status) { |
329 | logger.warn('Advice from webreport return empty status'); | 329 | logger.warn('Advice from webreport return empty status'); |
330 | return; | 330 | return; |
331 | } | 331 | } |
332 | 332 | ||
333 | logger.info('Got advice result from webreport', {status: status}); | 333 | logger.info('Got advice result from webreport', {status: status}); |
334 | 334 | ||
335 | var responseCode = '68'; | 335 | var responseCode = '68'; |
336 | 336 | ||
337 | var result_price = 0; | 337 | var result_price = 0; |
338 | try { | 338 | try { |
339 | result_price = directResponse.Result.Price[0].trim(); | 339 | result_price = directResponse.Result.Price[0].trim(); |
340 | } | 340 | } |
341 | catch(err) {} | 341 | catch(err) {} |
342 | 342 | ||
343 | var errorMsg = ''; | 343 | var errorMsg = ''; |
344 | try { | 344 | try { |
345 | errorMsg = status.response.errormsg[0]; | 345 | errorMsg = status.response.errormsg[0]; |
346 | } | 346 | } |
347 | catch(err) {} | 347 | catch(err) {} |
348 | 348 | ||
349 | var responseMessage = ''; | 349 | var responseMessage = ''; |
350 | try { | 350 | try { |
351 | responseMessage = | 351 | responseMessage = |
352 | 'Hasil advice dari webreport ' | 352 | 'Hasil advice dari webreport ' |
353 | + 'ResultCode: ' + status.response.resultcode[0] | 353 | + 'ResultCode: ' + status.response.resultcode[0] |
354 | } | 354 | } |
355 | catch(err) { | 355 | catch(err) { |
356 | logger.warn('Error parsing ResultCode from webreport advice.', {err: err}); | 356 | logger.warn('Error parsing ResultCode from webreport advice.', {err: err}); |
357 | } | 357 | } |
358 | 358 | ||
359 | try { | 359 | try { |
360 | responseMessage = | 360 | responseMessage = |
361 | responseMessage | 361 | responseMessage |
362 | + ' | ErrorMsg: ' + errorMsg | 362 | + ' | ErrorMsg: ' + errorMsg |
363 | } | 363 | } |
364 | catch(err) { | 364 | catch(err) { |
365 | logger.warn('Error parsing ErrorMsg from webreport advice.', {err: err}); | 365 | logger.warn('Error parsing ErrorMsg from webreport advice.', {err: err}); |
366 | } | 366 | } |
367 | 367 | ||
368 | try { | 368 | try { |
369 | responseMessage = | 369 | responseMessage = |
370 | responseMessage | 370 | responseMessage |
371 | + ' | TrxDate: ' + status.trxDate; | 371 | + ' | TrxDate: ' + status.trxDate; |
372 | } | 372 | } |
373 | catch(err) { | 373 | catch(err) { |
374 | logger.warn('Error parsing TrxDate from webreport advice.', {err: err}); | 374 | logger.warn('Error parsing TrxDate from webreport advice.', {err: err}); |
375 | } | 375 | } |
376 | 376 | ||
377 | try { | 377 | try { |
378 | responseMessage = | 378 | responseMessage = |
379 | responseMessage | 379 | responseMessage |
380 | + ' | UpdateDate: ' + status.updateDate; | 380 | + ' | UpdateDate: ' + status.updateDate; |
381 | 381 | ||
382 | } | 382 | } |
383 | catch(err) { | 383 | catch(err) { |
384 | logger.warn('Error parsing UpdateDate from webreport advice.', {err: err}); | 384 | logger.warn('Error parsing UpdateDate from webreport advice.', {err: err}); |
385 | } | 385 | } |
386 | 386 | ||
387 | try { | 387 | try { |
388 | responseMessage = | 388 | responseMessage = |
389 | responseMessage | 389 | responseMessage |
390 | + ' | nsm: ' + status.response.nsm[0]; | 390 | + ' | nsm: ' + status.response.nsm[0]; |
391 | } | 391 | } |
392 | catch(err) { | 392 | catch(err) { |
393 | logger.warn('Error parsing nsm from webreport advice.', {err: err}); | 393 | logger.warn('Error parsing nsm from webreport advice.', {err: err}); |
394 | } | 394 | } |
395 | 395 | ||
396 | try { | 396 | try { |
397 | responseMessage = | 397 | responseMessage = |
398 | responseMessage | 398 | responseMessage |
399 | + ' | idpel: ' + status.response.idpel[0]; | 399 | + ' | idpel: ' + status.response.idpel[0]; |
400 | } | 400 | } |
401 | catch(err) { | 401 | catch(err) { |
402 | logger.warn('Error parsing idpel from webreport advice.', {err: err}); | 402 | logger.warn('Error parsing idpel from webreport advice.', {err: err}); |
403 | } | 403 | } |
404 | 404 | ||
405 | try { | 405 | try { |
406 | responseMessage = | 406 | responseMessage = |
407 | responseMessage | 407 | responseMessage |
408 | + ' | reffid: ' + status.response.reffid[0].trim(); | 408 | + ' | reffid: ' + status.response.reffid[0].trim(); |
409 | } | 409 | } |
410 | catch(err) { | 410 | catch(err) { |
411 | logger.warn('Error parsing reffid from webreport advice.', {err: err}); | 411 | logger.warn('Error parsing reffid from webreport advice.', {err: err}); |
412 | } | 412 | } |
413 | 413 | ||
414 | try { | 414 | try { |
415 | responseMessage = | 415 | responseMessage = |
416 | responseMessage | 416 | responseMessage |
417 | + ' | TransID: ' + status.response.transid[0].trim(); | 417 | + ' | TransID: ' + status.response.transid[0].trim(); |
418 | } | 418 | } |
419 | catch(err) { | 419 | catch(err) { |
420 | logger.warn('Error parsing TransID from webreport advice.', {err: err}); | 420 | logger.warn('Error parsing TransID from webreport advice.', {err: err}); |
421 | } | 421 | } |
422 | 422 | ||
423 | try { | 423 | try { |
424 | responseMessage = | 424 | responseMessage = |
425 | responseMessage | 425 | responseMessage |
426 | + ' | reff_switching: ' + status.response.reff_switching[0]; | 426 | + ' | reff_switching: ' + status.response.reff_switching[0]; |
427 | } | 427 | } |
428 | catch(err) { | 428 | catch(err) { |
429 | logger.warn('Error parsing reff_switching from webreport advice.', {err: err}); | 429 | logger.warn('Error parsing reff_switching from webreport advice.', {err: err}); |
430 | } | 430 | } |
431 | 431 | ||
432 | try { | 432 | try { |
433 | responseMessage = | 433 | responseMessage = |
434 | responseMessage | 434 | responseMessage |
435 | + ' | amount_trx: ' + status.response.amount_trx[0]; | 435 | + ' | amount_trx: ' + status.response.amount_trx[0]; |
436 | } | 436 | } |
437 | catch(err) { | 437 | catch(err) { |
438 | logger.warn('Error parsing amount_trx from webreport advice.', {err: err}); | 438 | logger.warn('Error parsing amount_trx from webreport advice.', {err: err}); |
439 | } | 439 | } |
440 | 440 | ||
441 | try { | 441 | try { |
442 | responseMessage = | 442 | responseMessage = |
443 | responseMessage | 443 | responseMessage |
444 | + ' | token: ' + status.response.token[0]; | 444 | + ' | token: ' + status.response.token[0]; |
445 | } | 445 | } |
446 | catch(err) { | 446 | catch(err) { |
447 | logger.warn('Error parsing token from webreport advice.', {err: err}); | 447 | logger.warn('Error parsing token from webreport advice.', {err: err}); |
448 | } | 448 | } |
449 | 449 | ||
450 | try { | 450 | try { |
451 | responseMessage = | 451 | responseMessage = |
452 | responseMessage | 452 | responseMessage |
453 | + ' | PrevBalance: ' + status.response.prevbalance[0]; | 453 | + ' | PrevBalance: ' + status.response.prevbalance[0]; |
454 | } | 454 | } |
455 | catch(err) { | 455 | catch(err) { |
456 | logger.warn('Error parsing PrevBalance from webreport advice.', {err: err}); | 456 | logger.warn('Error parsing PrevBalance from webreport advice.', {err: err}); |
457 | } | 457 | } |
458 | 458 | ||
459 | try { | 459 | try { |
460 | responseMessage = | 460 | responseMessage = |
461 | responseMessage | 461 | responseMessage |
462 | + ' | Price: ' + status.amount; | 462 | + ' | Price: ' + status.amount; |
463 | } | 463 | } |
464 | catch(err) { | 464 | catch(err) { |
465 | logger.warn('Error parsing Price from webreport advice.', {err: err}); | 465 | logger.warn('Error parsing Price from webreport advice.', {err: err}); |
466 | } | 466 | } |
467 | 467 | ||
468 | try { | 468 | try { |
469 | responseMessage = | 469 | responseMessage = |
470 | responseMessage | 470 | responseMessage |
471 | + ' | EndBalance: ' + status.response.endbalance[0]; | 471 | + ' | EndBalance: ' + status.response.endbalance[0]; |
472 | } | 472 | } |
473 | catch(err) { | 473 | catch(err) { |
474 | logger.warn('Error parsing EndBalance from webreport advice.', {err: err}); | 474 | logger.warn('Error parsing EndBalance from webreport advice.', {err: err}); |
475 | } | 475 | } |
476 | 476 | ||
477 | 477 | ||
478 | if ((status.status == 'S') && (status.response.resultcode[0] == '0000')) { | 478 | if ((status.status == 'S') && (status.response.resultcode[0] == '0000')) { |
479 | responseCode = '00'; | 479 | responseCode = '00'; |
480 | 480 | ||
481 | var nama_pelanggan = status.response.nama_pel[0] ; | 481 | var nama_pelanggan = status.response.nama_pel[0] ; |
482 | nama_pelanggan = nama_pelanggan.replace(/-\/-/g, '-'); | 482 | nama_pelanggan = nama_pelanggan.replace(/-\/-/g, '-'); |
483 | 483 | ||
484 | var sn = status.response.token[0] + '/' + nama_pelanggan + '/' + status.response.tarif[0] + 'VA/' + status.response.jml_daya[0]; | 484 | var sn = status.response.token[0] + '/' + nama_pelanggan + '/' + status.response.tarif[0] + 'VA/' + status.response.jml_daya[0]; |
485 | responseMessage = 'SN=' + sn + '; ' + responseMessage; | 485 | responseMessage = 'SN=' + sn + '; ' + responseMessage; |
486 | 486 | ||
487 | } else if ((status.status == 'P') || (status.status == 'W')) { | 487 | } else if ((status.status == 'P') || (status.status == 'W')) { |
488 | 488 | ||
489 | callbackReport(status.response.reffid[0].trim(), '68', responseMessage); | 489 | callbackReport(status.response.reffid[0].trim(), '68', responseMessage); |
490 | logger.info('Got pending status, requesting advice from webreport in ' + sleep_before_retry + 'ms'); | 490 | logger.info('Got pending status, requesting advice from webreport in ' + sleep_before_retry + 'ms'); |
491 | 491 | ||
492 | setTimeout(function () { | 492 | setTimeout(function () { |
493 | 493 | ||
494 | cekstatus.advice({trxid: status.trxId,}, callbackFromWebReport); | 494 | cekstatus.advice({trxid: status.trxId,}, callbackFromWebReport); |
495 | 495 | ||
496 | }, sleep_before_retry); | 496 | }, sleep_before_retry); |
497 | return; | 497 | return; |
498 | 498 | ||
499 | } else { | 499 | } else { |
500 | responseCode = status.response.resultcode[0].replace(/^00/, ""); | 500 | responseCode = status.response.resultcode[0].replace(/^00/, ""); |
501 | if (['00', '05', '12', '68', '90', '63', '18', '96'].indexOf(responseCode) >= 0) { | 501 | if (['00', '05', '12', '68', '90', '63', '18', '96'].indexOf(responseCode) >= 0) { |
502 | responseCode = '40'; | 502 | responseCode = '40'; |
503 | } | 503 | } |
504 | } | 504 | } |
505 | 505 | ||
506 | 506 | ||
507 | callbackReport(status.response.reffid[0].trim(), responseCode, responseMessage); | 507 | callbackReport(status.response.reffid[0].trim(), responseCode, responseMessage); |
508 | } | 508 | } |
509 | 509 | ||
510 | function createHttpReportServer() { | 510 | function createHttpReportServer() { |
511 | var httpServer = http.createServer(function(request, response) { | 511 | var httpServer = http.createServer(function(request, response) { |
512 | var qs = url.parse(request.url, true).query; | 512 | var qs = url.parse(request.url, true).query; |
513 | var path = url.parse(request.url).pathname; | 513 | var path = url.parse(request.url).pathname; |
514 | 514 | ||
515 | logger.info('Got reverse report from partner', {path: path, qs: qs}); | 515 | logger.info('Got reverse report from partner', {path: path, qs: qs}); |
516 | response.end('OK'); | 516 | response.end('OK'); |
517 | 517 | ||
518 | var requestId = qs.reffid; | 518 | var requestId = qs.reffid; |
519 | var resultCode = qs.rescode; | 519 | var resultCode = qs.rescode; |
520 | 520 | ||
521 | if (requestId && resultCode && resulCode != '0') { | 521 | if (requestId && resultCode && resultCode != '0') { |
522 | if (pendingResultCode.indexOf(resultCode) >= 0) { | 522 | if (pendingResultCode.indexOf(resultCode) >= 0) { |
523 | callbackReport(requestId, '68', 'Got reverse report: ' + qs.msg); | 523 | callbackReport(requestId, '68', 'Got reverse report: ' + qs.msg); |
524 | } else { | 524 | } else { |
525 | callbackReport(requestId, '40', 'Got reverse report: ' + qs.msg); | 525 | callbackReport(requestId, '40', 'Got reverse report: ' + qs.msg); |
526 | } | 526 | } |
527 | return; | 527 | return; |
528 | } | 528 | } |
529 | 529 | ||
530 | var trxid; | 530 | var trxid; |
531 | try { | 531 | try { |
532 | trxid = qs.transid; | 532 | trxid = qs.transid; |
533 | } | 533 | } |
534 | catch(err) { | 534 | catch(err) { |
535 | } | 535 | } |
536 | 536 | ||
537 | if (trxid) { | 537 | if (trxid) { |
538 | logger.info('Requesting advice from webreport', {trxid: trxid}) | 538 | logger.info('Requesting advice from webreport', {trxid: trxid}) |
539 | cekstatus.advice({trxid: trxid}, callbackFromWebReport); | 539 | cekstatus.advice({trxid: trxid}, callbackFromWebReport); |
540 | } | 540 | } |
541 | 541 | ||
542 | }); | 542 | }); |
543 | 543 | ||
544 | httpServer.listen(config.h2h_out.listen_port, function() { | 544 | httpServer.listen(config.h2h_out.listen_port, function() { |
545 | logger.info('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port); | 545 | logger.info('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port); |
546 | }); | 546 | }); |
547 | } | 547 | } |
548 | 548 | ||
549 | function start(options) { | 549 | function start(options) { |
550 | if (!options) { | 550 | if (!options) { |
551 | console.log('Undefined options, terminating....'); | 551 | console.log('Undefined options, terminating....'); |
552 | process.exit(1); | 552 | process.exit(1); |
553 | } | 553 | } |
554 | 554 | ||
555 | if (options.config) { | 555 | if (options.config) { |
556 | config = options.config; | 556 | config = options.config; |
557 | } else { | 557 | } else { |
558 | console.log('Undefined options.config, terminating....') | 558 | console.log('Undefined options.config, terminating....') |
559 | process.exit(1); | 559 | process.exit(1); |
560 | } | 560 | } |
561 | 561 | ||
562 | if (options.aaa) { | 562 | if (options.aaa) { |
563 | aaa = options.aaa; | 563 | aaa = options.aaa; |
564 | callbackReport = options.aaa.callbackReportWithPushToMongoDb; | 564 | callbackReport = options.aaa.callbackReportWithPushToMongoDb; |
565 | } else { | 565 | } else { |
566 | console.log('Undefined options.aaa, terminating....') | 566 | console.log('Undefined options.aaa, terminating....') |
567 | process.exit(1); | 567 | process.exit(1); |
568 | } | 568 | } |
569 | 569 | ||
570 | if (options && options.logger) { | 570 | if (options && options.logger) { |
571 | logger = options.logger; | 571 | logger = options.logger; |
572 | } else { | 572 | } else { |
573 | logger = new winston.Logger({ | 573 | logger = new winston.Logger({ |
574 | transports: [ | 574 | transports: [ |
575 | new (winston.transports.Console)() | 575 | new (winston.transports.Console)() |
576 | ] | 576 | ] |
577 | }); | 577 | }); |
578 | } | 578 | } |
579 | 579 | ||
580 | createHttpReportServer(); | 580 | createHttpReportServer(); |
581 | initMongoClient(); | 581 | initMongoClient(); |
582 | } | 582 | } |
583 | 583 | ||
584 | exports.start = start; | 584 | exports.start = start; |
585 | exports.topupRequest = topupRequest; | 585 | exports.topupRequest = topupRequest; |
586 | 586 |