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