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