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