Reload97 / sate24-to-simplepay-plnpre

Download as
Browse Code ยป

Commit 59b806630b1baa7a4135be253c95e56c0971b98c

Authored by Adhidarma Hadiwinoto
1 parent 60d4b3934e
Exists in master

reverse report post method

Showing 1 changed file with 52 additions and 4 deletions Inline Diff

partner-simplepay.js
Diff comments   View file @ 59b8066
1 "use strict"; 1 "use strict";
2 2
3 process.env.NODE_TLS_REJECT_UNAUTHORIZED = "0"; 3 process.env.NODE_TLS_REJECT_UNAUTHORIZED = "0";
4 4
5 const request = require('request'); 5 const request = require('request');
6 const crypto = require('crypto'); 6 const crypto = require('crypto');
7 const moment = require('moment'); 7 const moment = require('moment');
8 const URL = require('url'); 8 const URL = require('url');
9 9
10 10
11 const http = require('http'); 11 const http = require('http');
12 http.globalAgent.maxSockets = Infinity; 12 http.globalAgent.maxSockets = Infinity;
13 13
14 const seconds_to_wait_before_resend_on_pending = 4; 14 const seconds_to_wait_before_resend_on_pending = 4;
15 15
16 var config; 16 var config;
17 var aaa; 17 var aaa;
18 var logger; 18 var logger;
19 19
20 function start(options) { 20 function start(options) {
21 if (!options) { 21 if (!options) {
22 console.log('Undefined options, terminating....'); 22 console.log('Undefined options, terminating....');
23 process.exit(1); 23 process.exit(1);
24 } 24 }
25 25
26 if (options.config) { 26 if (options.config) {
27 config = options.config; 27 config = options.config;
28 } else { 28 } else {
29 console.log('Undefined options.config, terminating....') 29 console.log('Undefined options.config, terminating....')
30 process.exit(1); 30 process.exit(1);
31 } 31 }
32 32
33 if (options.aaa) { 33 if (options.aaa) {
34 aaa = options.aaa; 34 aaa = options.aaa;
35 } else { 35 } else {
36 console.log('Undefined options.aaa, terminating....') 36 console.log('Undefined options.aaa, terminating....')
37 process.exit(1); 37 process.exit(1);
38 } 38 }
39 39
40 if (options && options.logger) { 40 if (options && options.logger) {
41 logger = options.logger; 41 logger = options.logger;
42 } else { 42 } else {
43 console.log('Undefined options.logger, terminating....') 43 console.log('Undefined options.logger, terminating....')
44 process.exit(1); 44 process.exit(1);
45 } 45 }
46 46
47 createReverseHttpServer(); 47 createReverseHttpServer();
48 } 48 }
49 49
50 function callbackReport(requestId, rc, message, options) { 50 function callbackReport(requestId, rc, message, options) {
51 aaa.callbackReportWithPushToMongoDb(requestId, rc, message); 51 aaa.callbackReportWithPushToMongoDb(requestId, rc, message);
52 52
53 // resend trx as status check if rc 68 and task is defined 53 // resend trx as status check if rc 68 and task is defined
54 if (options && options.task && (rc == '68')) { 54 if (options && options.task && (rc == '68')) {
55 logger.verbose('Got pending trx, requesting in ' + seconds_to_wait_before_resend_on_pending + ' secs'); 55 logger.verbose('Got pending trx, requesting in ' + seconds_to_wait_before_resend_on_pending + ' secs');
56 setTimeout(function() { 56 setTimeout(function() {
57 checkStatus(options.task); 57 checkStatus(options.task);
58 }, seconds_to_wait_before_resend_on_pending * 1000) 58 }, seconds_to_wait_before_resend_on_pending * 1000)
59 } 59 }
60 } 60 }
61 61
62 function calculateSign(dt, trx_ref_id, cust_num, username, password) { 62 function calculateSign(dt, trx_ref_id, cust_num, username, password) {
63 const cryptoHashPassword = crypto.createHash('sha1'); 63 const cryptoHashPassword = crypto.createHash('sha1');
64 const cryptoHashUsernamePassword = crypto.createHash('sha1'); 64 const cryptoHashUsernamePassword = crypto.createHash('sha1');
65 const cryptoHashOutest = crypto.createHash('sha1'); 65 const cryptoHashOutest = crypto.createHash('sha1');
66 66
67 cryptoHashPassword.update(password); 67 cryptoHashPassword.update(password);
68 const hashPassword = cryptoHashPassword.digest('hex'); 68 const hashPassword = cryptoHashPassword.digest('hex');
69 69
70 cryptoHashUsernamePassword.update(username + hashPassword); 70 cryptoHashUsernamePassword.update(username + hashPassword);
71 const hashUsernamePassword = cryptoHashUsernamePassword.digest('hex'); 71 const hashUsernamePassword = cryptoHashUsernamePassword.digest('hex');
72 72
73 cryptoHashOutest.update(dt + trx_ref_id + cust_num + hashUsernamePassword); 73 cryptoHashOutest.update(dt + trx_ref_id + cust_num + hashUsernamePassword);
74 return cryptoHashOutest.digest('hex'); 74 return cryptoHashOutest.digest('hex');
75 } 75 }
76 76
77 function _decodeResponseBody(responseBody) { 77 function _decodeResponseBody(responseBody) {
78 let response; 78 let response;
79 79
80 try { 80 try {
81 response = JSON.parse(responseBody); 81 response = JSON.parse(responseBody);
82 } 82 }
83 catch(e) { 83 catch(e) {
84 logger.warn('Error parsing response body'); 84 logger.warn('Error parsing response body');
85 } 85 }
86 86
87 return response; 87 return response;
88 } 88 }
89 89
90 function _composeMessageFromResponseData(responseDataObj) { 90 function _composeMessageFromResponseData(responseDataObj) {
91 const diag = _getPropertyFromObjectSafe(responseDataObj, 'diag'); 91 const diag = _getPropertyFromObjectSafe(responseDataObj, 'diag');
92 const msg = _getPropertyFromObjectSafe(responseDataObj, 'message'); 92 const msg = _getPropertyFromObjectSafe(responseDataObj, 'message');
93 const balance = _getPropertyFromObjectSafe(responseDataObj, 'balance'); 93 const balance = _getPropertyFromObjectSafe(responseDataObj, 'balance');
94 const timestamp = _getPropertyFromObjectSafe(responseDataObj, 'timestamp'); 94 const timestamp = _getPropertyFromObjectSafe(responseDataObj, 'timestamp');
95 const price = _getPropertyFromObjectSafe(responseDataObj, 'harga'); 95 const price = _getPropertyFromObjectSafe(responseDataObj, 'harga');
96 96
97 let messages = []; 97 let messages = [];
98 98
99 if (timestamp) { 99 if (timestamp) {
100 messages.push(timestamp); 100 messages.push(timestamp);
101 } 101 }
102 102
103 if (diag) { 103 if (diag) {
104 messages.push(diag); 104 messages.push(diag);
105 } 105 }
106 106
107 if (msg) { 107 if (msg) {
108 messages.push(msg); 108 messages.push(msg);
109 } 109 }
110 110
111 if (balance) { 111 if (balance) {
112 messages.push('Balance: ' + balance); 112 messages.push('Balance: ' + balance);
113 } 113 }
114 114
115 if (price) { 115 if (price) {
116 messages.push('Price: ' + price); 116 messages.push('Price: ' + price);
117 } 117 }
118 118
119 return messages.join('. ') + '.'; 119 return messages.join('. ') + '.';
120 } 120 }
121 121
122 function _composeCompleteSn(responseDataObj) { 122 function _composeCompleteSn(responseDataObj) {
123 let serial = _getPropertyFromObjectSafe(responseDataObj, 'serial'); 123 let serial = _getPropertyFromObjectSafe(responseDataObj, 'serial');
124 const info = _getPropertyFromObjectSafe(responseDataObj, 'info'); 124 const info = _getPropertyFromObjectSafe(responseDataObj, 'info');
125 125
126 if (serial) { 126 if (serial) {
127 serial = serial.replace(/ /g, '-'); 127 serial = serial.replace(/ /g, '-');
128 } 128 }
129 129
130 if (!info) { 130 if (!info) {
131 //logger.warn('Undefined data.info on _composeCompleteSn'); 131 //logger.warn('Undefined data.info on _composeCompleteSn');
132 return serial; 132 return serial;
133 } 133 }
134 134
135 const cleanedData = { 135 const cleanedData = {
136 token: serial, 136 token: serial,
137 cust_name: _getPropertyFromObjectSafe(info, 'cust_name'), 137 cust_name: _getPropertyFromObjectSafe(info, 'cust_name'),
138 tariff: _getPropertyFromObjectSafe(info, 'kelas'), 138 tariff: _getPropertyFromObjectSafe(info, 'kelas'),
139 total_kwh: _getPropertyFromObjectSafe(info, 'size') 139 total_kwh: _getPropertyFromObjectSafe(info, 'size')
140 } 140 }
141 141
142 if (cleanedData && cleanedData.tariff && typeof cleanedData === 'string' && (cleanedData.tariff.search(/VA$/) < 0) ) { 142 if (cleanedData && cleanedData.tariff && typeof cleanedData === 'string' && (cleanedData.tariff.search(/VA$/) < 0) ) {
143 cleanedData.tariff += 'VA'; 143 cleanedData.tariff += 'VA';
144 144
145 } 145 }
146 146
147 if (cleanedData.cust_name) { 147 if (cleanedData.cust_name) {
148 cleanedData.cust_name = cleanedData.cust_name.replace(/\W+/g, '-').replace(/\W+/g, '-').replace(/-+$/, '').replace(/^-+/, '').toUpperCase(); 148 cleanedData.cust_name = cleanedData.cust_name.replace(/\W+/g, '-').replace(/\W+/g, '-').replace(/-+$/, '').replace(/^-+/, '').toUpperCase();
149 } 149 }
150 150
151 if (cleanedData.total_kwh) { 151 if (cleanedData.total_kwh) {
152 cleanedData.total_kwh = cleanedData.total_kwh.replace(/kWh\s*/g, ''); 152 cleanedData.total_kwh = cleanedData.total_kwh.replace(/kWh\s*/g, '');
153 } 153 }
154 154
155 155
156 logger.verbose('Detail token info extracted', {originalResponseInfo: info, cleanedData: cleanedData}); 156 logger.verbose('Detail token info extracted', {originalResponseInfo: info, cleanedData: cleanedData});
157 157
158 return [ 158 return [
159 cleanedData.token, cleanedData.cust_name, cleanedData.tariff, cleanedData.total_kwh 159 cleanedData.token, cleanedData.cust_name, cleanedData.tariff, cleanedData.total_kwh
160 ].join('/'); 160 ].join('/');
161 } 161 }
162 162
163 function _responseBodyHandler(responseBody, task) { 163 function _responseBodyHandler(responseBody, task) {
164 let rc = '68'; 164 let rc = '68';
165 let response = _decodeResponseBody(responseBody); 165 let response = _decodeResponseBody(responseBody);
166 166
167 logger.verbose('RESPONSE', {response: response}); 167 logger.verbose('RESPONSE', {response: response});
168 168
169 const responseStatus = _getPropertyFromObjectSafe(response, 'status'); 169 const responseStatus = _getPropertyFromObjectSafe(response, 'status');
170 const responseInfo = _getPropertyFromObjectSafe(response, 'info'); 170 const responseInfo = _getPropertyFromObjectSafe(response, 'info');
171 171
172 if (responseStatus == 'Error') { 172 if (responseStatus == 'Error') {
173 if (['insufficient balance', 'System Cut-Off'].indexOf(responseInfo) >= 0) { 173 if (['insufficient balance', 'System Cut-Off'].indexOf(responseInfo) >= 0) {
174 rc = '91'; 174 rc = '91';
175 } 175 }
176 callbackReport(task.requestId, '91', [responseStatus, responseInfo].join(': '), {task: task}); 176 callbackReport(task.requestId, '91', [responseStatus, responseInfo].join(': '), {task: task});
177 return; 177 return;
178 } 178 }
179 179
180 const requestId = _getPropertyFromObjectSafe(response.data, 'request_id'); 180 const requestId = _getPropertyFromObjectSafe(response.data, 'request_id');
181 const trxStatus = _getPropertyFromObjectSafe(response.data, 'trx_status'); 181 const trxStatus = _getPropertyFromObjectSafe(response.data, 'trx_status');
182 const diag = _getPropertyFromObjectSafe(response.data, 'diag'); 182 const diag = _getPropertyFromObjectSafe(response.data, 'diag');
183 let balance = _getPropertyFromObjectSafe(response.data, 'balance'); 183 let balance = _getPropertyFromObjectSafe(response.data, 'balance');
184 184
185 if ((typeof balance === 'string') && balance && aaa.updateBalance) { 185 if ((typeof balance === 'string') && balance && aaa.updateBalance) {
186 balance = balance.replace(/\D/g, ''); 186 balance = balance.replace(/\D/g, '');
187 if (balance) { 187 if (balance) {
188 aaa.updateBalance(balance); 188 aaa.updateBalance(balance);
189 } 189 }
190 } 190 }
191 191
192 let aaaMessage = _composeMessageFromResponseData(response.data); 192 let aaaMessage = _composeMessageFromResponseData(response.data);
193 if (!aaaMessage) { 193 if (!aaaMessage) {
194 aaaMessage = 'Transaksi sedang diproses'; 194 aaaMessage = 'Transaksi sedang diproses';
195 } 195 }
196 196
197 if (trxStatus == 'P') { 197 if (trxStatus == 'P') {
198 logger.verbose('Got pending trx response', {response: response.data}); 198 logger.verbose('Got pending trx response', {response: response.data});
199 rc = '68'; 199 rc = '68';
200 } 200 }
201 else if (trxStatus == 'S') { 201 else if (trxStatus == 'S') {
202 logger.verbose('Got succcess trx response', {response: response.data}); 202 logger.verbose('Got succcess trx response', {response: response.data});
203 203
204 rc = '00'; 204 rc = '00';
205 aaaMessage = 'SN=' + _composeCompleteSn(response.data) + '; ' + aaaMessage; 205 aaaMessage = 'SN=' + _composeCompleteSn(response.data) + '; ' + aaaMessage;
206 } 206 }
207 else if (trxStatus == 'R') { 207 else if (trxStatus == 'R') {
208 logger.verbose('Got rejected trx response', {response: response.data}); 208 logger.verbose('Got rejected trx response', {response: response.data});
209 209
210 const partnerRC = getPartnerRCFromDiagMessage(diag); 210 const partnerRC = getPartnerRCFromDiagMessage(diag);
211 if (partnerRC == '15') { 211 if (partnerRC == '15') {
212 rc = '14'; 212 rc = '14';
213 } 213 }
214 else { 214 else {
215 rc = '40'; 215 rc = '40';
216 } 216 }
217 } 217 }
218 218
219 callbackReport(requestId, rc, aaaMessage, {task: task}); 219 callbackReport(requestId, rc, aaaMessage, {task: task});
220 } 220 }
221 221
222 function getPartnerRCFromDiagMessage(diag) { 222 function getPartnerRCFromDiagMessage(diag) {
223 let matches = diag.match(/^\s*\[(.*)\]/); 223 let matches = diag.match(/^\s*\[(.*)\]/);
224 if (!matches || matches.length < 2) { 224 if (!matches || matches.length < 2) {
225 return; 225 return;
226 } 226 }
227 227
228 return matches[1]; 228 return matches[1];
229 } 229 }
230 230
231 function _hitTopup(task, isCheckStatus) { 231 function _hitTopup(task, isCheckStatus) {
232 232
233 const dt = moment().format('YYYY-MM-DD HH:mm:ss'); 233 const dt = moment().format('YYYY-MM-DD HH:mm:ss');
234 const username = config.h2h_out.username || config.h2h_out.userid; 234 const username = config.h2h_out.username || config.h2h_out.userid;
235 const password = config.h2h_out.password || config.h2h_out.pin; 235 const password = config.h2h_out.password || config.h2h_out.pin;
236 const sign = calculateSign(dt, task.requestId, task.destination, username, password); 236 const sign = calculateSign(dt, task.requestId, task.destination, username, password);
237 237
238 logger.verbose('Sign for ' + dt + ', ' + task.requestId + ', ' + task.destination + ', ' + username + ', ' + password + ' is ' + sign); 238 logger.verbose('Sign for ' + dt + ', ' + task.requestId + ', ' + task.destination + ', ' + username + ', ' + password + ' is ' + sign);
239 const requestOptions = { 239 const requestOptions = {
240 url: config.h2h_out.partner, 240 url: config.h2h_out.partner,
241 form: { 241 form: {
242 username: username, 242 username: username,
243 datetime: dt, 243 datetime: dt,
244 code: task.remoteProduct, 244 code: task.remoteProduct,
245 trx_ref_id: task.requestId, 245 trx_ref_id: task.requestId,
246 cust_num: task.destination, 246 cust_num: task.destination,
247 sign: sign 247 sign: sign
248 } 248 }
249 } 249 }
250 250
251 logger.verbose('Requesting to partner', {requestOptions: requestOptions}); 251 logger.verbose('Requesting to partner', {requestOptions: requestOptions});
252 252
253 request.post(requestOptions, function(error, response, body) { 253 request.post(requestOptions, function(error, response, body) {
254 if (error) { 254 if (error) {
255 let rc = '68'; 255 let rc = '68';
256 256
257 if (!isCheckStatus && (error.syscall == 'connect')) { 257 if (!isCheckStatus && (error.syscall == 'connect')) {
258 rc = '91'; 258 rc = '91';
259 } 259 }
260 260
261 logger.warn('Error requesting to partner', {task: task, rc: rc, error: error, isCheckStatus: isCheckStatus}); 261 logger.warn('Error requesting to partner', {task: task, rc: rc, error: error, isCheckStatus: isCheckStatus});
262 callbackReport(task.requestId, rc, 'Error requesting to partner. ' + error, {task: task}); 262 callbackReport(task.requestId, rc, 'Error requesting to partner. ' + error, {task: task});
263 return; 263 return;
264 } 264 }
265 265
266 if (response.statusCode != 200) { 266 if (response.statusCode != 200) {
267 let rc = '68'; 267 let rc = '68';
268 268
269 logger.warn('HTTP status code is not 200', {task: task, http_status_code: response.statusCode, isCheckStatus: isCheckStatus}); 269 logger.warn('HTTP status code is not 200', {task: task, http_status_code: response.statusCode, isCheckStatus: isCheckStatus});
270 callbackReport(task.requestId, rc, 'HTTP status code ' + response.statusCode, {task: task}); 270 callbackReport(task.requestId, rc, 'HTTP status code ' + response.statusCode, {task: task});
271 return; 271 return;
272 } 272 }
273 273
274 logger.info('Transaksi sedang diproses', {task: task, response_body: body}); 274 logger.info('Transaksi sedang diproses', {task: task, response_body: body});
275 275
276 _responseBodyHandler(body, task); 276 _responseBodyHandler(body, task);
277 277
278 }) 278 })
279 } 279 }
280 280
281 function _getPropertyFromObjectSafe(obj, property) { 281 function _getPropertyFromObjectSafe(obj, property) {
282 let retval; 282 let retval;
283 283
284 if (!obj) { 284 if (!obj) {
285 logger.warn('Invalid object') 285 logger.warn('Invalid object')
286 return; 286 return;
287 } 287 }
288 288
289 try { 289 try {
290 retval = obj[property]; 290 retval = obj[property];
291 } 291 }
292 catch(e) { 292 catch(e) {
293 logger.warn('Error getting ' + property + ' from object'); 293 logger.warn('Error getting ' + property + ' from object');
294 } 294 }
295 295
296 return retval; 296 return retval;
297 } 297 }
298 298
299 function topupRequest(task) { 299 function topupRequest(task) {
300 aaa.insertTaskToMongoDb(task); 300 aaa.insertTaskToMongoDb(task);
301 _hitTopup(task); 301 _hitTopup(task);
302 } 302 }
303 303
304 function checkStatus(task) { 304 function checkStatus(task) {
305 _hitTopup(task, true); 305 _hitTopup(task, true);
306 } 306 }
307 307
308 308
309 function reverseReportHandler(body) { 309 function reverseReportHandler(data) {
310 logger.info('Got reverse report', {body: body}); 310 //logger.info('Got reverse report', {body: body});
311
312 const qs = URL.parse(data, true).query;
313
314 if (!qs || !qs.request_id) {
315 return;
316 }
317
318 if ((typeof qs.balance === 'string') && qs.balance && aaa.updateBalance) {
319 const balance = qs.balance.replace(/\D/g, '');
320 if (balance) {
321 aaa.updateBalance(balance);
322 }
323 }
324
325
326 let rc = '68';
327 if (qs.trx_status === 'S') {
328 rc = '00';
329 }
330 else if (qs.trx_status === 'R') {
331 rc = '40';
332 }
333
334 if ((typeof qs.serial === 'string') && qs.serial) {
335 rc = '00';
336 }
337
338 const sn = (rc === '00') ? _createSnFromReverseReport(qs) : null;
339 let msg = [
340 'REVERSE REPORT',
341 'Diag: ' + (qs.diag + '-'),
342 'Message': + (qs.message || '-'),
343 'Status: ' + (qs.trx_status || '-'),
344 'Balance: ' + (qs.balance || '-'),
345 'Harga: ' + (qs.harga || '-')
346 ].join('. ');
347
348 if (sn) {
349 msg = 'SN=' + sn + '; ' + msg;
350 }
351
352 callbackReport(qs.request_id, rc, msg);
311 } 353 }
312 354
313 function _parseInfoFromReverseReport(info) { 355 function _parseInfoFromReverseReport(info) {
314 let result; 356 let result;
315 try { 357 try {
316 result = JSON.parse(info); 358 result = JSON.parse(info);
317 } 359 }
318 catch (e) { 360 catch (e) {
319 logger.warn('Exception on parsing qs info as JSON', {info: info}); 361 logger.warn('Exception on parsing qs info as JSON', {info: info});
320 } 362 }
321 363
322 return result; 364 return result;
323 } 365 }
324 366
325 function _createSnFromReverseReport(qs) { 367 function _createSnFromReverseReport(qs) {
326 let token = qs.serial; 368 let token = qs.serial;
327 if (token && typeof token === 'string') { 369 if (token && typeof token === 'string') {
328 token = token.replace(/\W+/g, '-'); 370 token = token.replace(/\W+/g, '-');
329 371
330 } 372 }
331 373
332 let sn = token || '-'; 374 let sn = token || '-';
333 375
334 const info = _parseInfoFromReverseReport(qs.info); 376 const info = _parseInfoFromReverseReport(qs.info);
335 if (info) { 377 if (info) {
336 const cust_name = (typeof info.cust_name === 'string') ? info.cust_name.replace(/\W+/g, '-').replace(/^\W+/, '').replace(/\W+$/, '') : '-'; 378 const cust_name = (typeof info.cust_name === 'string') ? info.cust_name.replace(/\W+/g, '-').replace(/^\W+/, '').replace(/\W+$/, '') : '-';
337 const kelas = (typeof info.kelas === 'string') ? info.kelas.replace(/\W+/g, '-').replace(/^\W+/, '').replace(/\W+$/, '') : '-'; 379 const kelas = (typeof info.kelas === 'string') ? info.kelas.replace(/\W+/g, '-').replace(/^\W+/, '').replace(/\W+$/, '') : '-';
338 const kwh = (typeof info.size === 'string') ? info.size.replace(/\W+/g, '-').replace(/^\W+/, '').replace(/\W+$/, '') : '-'; 380 const kwh = (typeof info.size === 'string') ? info.size.replace(/\W+/g, '-').replace(/^\W+/, '').replace(/\W+$/, '') : '-';
339 381
340 sn = [ 382 sn = [
341 token || '-', 383 token || '-',
342 cust_name || '-', 384 cust_name || '-',
343 kwh || '-' 385 kwh || '-'
344 ].join('/'); 386 ].join('/');
345 } 387 }
346 388
347 return sn; 389 return sn;
348 } 390 }
349 391
350 function createReverseHttpServer() { 392 function createReverseHttpServer() {
351 var httpServer = http.createServer(function(req, res) { 393 var httpServer = http.createServer(function(req, res) {
352 394
353 const qs = URL.parse(req.url, true).query;
354 logger.info('Got request from partner (reverse report)', {remote_address: req.connection.remoteAddress, url: req.url, qs: qs}); 395 logger.info('Got request from partner (reverse report)', {remote_address: req.connection.remoteAddress, url: req.url, qs: qs});
355 396
356 var body = ""; 397 var body = "";
357 req.on('data', function (chunk) { 398 req.on('data', function (chunk) {
358 body += chunk; 399 body += chunk;
359 }); 400 });
360 401
361 req.on('end', function () { 402 req.on('end', function () {
362 res.writeHead(200); 403 res.writeHead(200);
363 res.end('OK'); 404 res.end('OK');
364 405
365 reverseReportHandler(body); 406 logger.info('Got reverse report', {body: body});
407
408 reverseReportHandler('?' + body);
366 }); 409 });
367 410
411 return;
412
413 const qs = URL.parse(req.url, true).query;
414
415
368 if (!qs || !qs.request_id) { 416 if (!qs || !qs.request_id) {
369 return; 417 return;
370 } 418 }
371 419
372 let rc = '68'; 420 let rc = '68';
373 if (qs.trx_status === 'S') { 421 if (qs.trx_status === 'S') {
374 rc = '00'; 422 rc = '00';
375 } 423 }
376 else if (qs.trx_status === 'R') { 424 else if (qs.trx_status === 'R') {
377 rc = '40'; 425 rc = '40';
378 } 426 }
379 427
380 if ((typeof qs.balance === 'string') && qs.balance && aaa.updateBalance) { 428 if ((typeof qs.balance === 'string') && qs.balance && aaa.updateBalance) {
381 const balance = qs.balance.replace(/\D/g, ''); 429 const balance = qs.balance.replace(/\D/g, '');
382 if (balance) { 430 if (balance) {
383 aaa.updateBalance(balance); 431 aaa.updateBalance(balance);
384 } 432 }
385 } 433 }
386 434
387 const sn = (rc === '00') ? _createSnFromReverseReport(qs) : null; 435 const sn = (rc === '00') ? _createSnFromReverseReport(qs) : null;
388 let msg = [ 436 let msg = [
389 'REVERSE REPORT', 437 'REVERSE REPORT',
390 qs.diag, 438 qs.diag,
391 'Status: ' + (qs.trx_status || '-'), 439 'Status: ' + (qs.trx_status || '-'),
392 'Balance: ' + (qs.balance || '-'), 440 'Balance: ' + (qs.balance || '-'),
393 'Harga: ' + (qs.harga || '-') 441 'Harga: ' + (qs.harga || '-')
394 ].join('. '); 442 ].join('. ');
395 443
396 if (sn) { 444 if (sn) {
397 msg = 'SN=' + sn + '; ' + msg; 445 msg = 'SN=' + sn + '; ' + msg;
398 } 446 }
399 447
400 callbackReport(qs.request_id, rc, msg); 448 callbackReport(qs.request_id, rc, msg);
401 449
402 }); 450 });
403 451
404 httpServer.listen(config.h2h_out.listen_port, function() { 452 httpServer.listen(config.h2h_out.listen_port, function() {
405 logger.info('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port); 453 logger.info('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port);
406 }); 454 });
407 } 455 }
408 456
409 457
410 exports.calculateSign = calculateSign; 458 exports.calculateSign = calculateSign;
411 exports.start = start; 459 exports.start = start;
412 exports.topupRequest = topupRequest; 460 exports.topupRequest = topupRequest;
413 exports.checkStatus = checkStatus; 461 exports.checkStatus = checkStatus;