Commit 2a434ffa90fb675f363eee964a4340bf91af8dba
1 parent
6cf2c9b2b4
Exists in
master
penananganan MAINTENANCE
Showing 1 changed file with 9 additions and 2 deletions Inline Diff
partner-trugee.js
1 | var http = require('http'); | 1 | var http = require('http'); |
2 | var url = require('url'); | 2 | var url = require('url'); |
3 | var math = require('mathjs'); | 3 | var math = require('mathjs'); |
4 | var xml = require('xml'); | 4 | var xml = require('xml'); |
5 | var xml2js = require('xml2js').parseString; | 5 | var xml2js = require('xml2js').parseString; |
6 | var strftime = require('strftime'); | 6 | var strftime = require('strftime'); |
7 | var xor = require('base64-xor'); | 7 | var xor = require('base64-xor'); |
8 | var request = require('request'); | 8 | var request = require('request'); |
9 | var winston = require('winston'); | 9 | var winston = require('winston'); |
10 | 10 | ||
11 | var config; | 11 | var config; |
12 | var callbackReport; | 12 | var callbackReport; |
13 | var aaa; | 13 | var aaa; |
14 | var logger; | 14 | var logger; |
15 | 15 | ||
16 | var max_retry = 2; | 16 | var max_retry = 2; |
17 | var sleep_before_retry = 2000; | 17 | var sleep_before_retry = 2000; |
18 | 18 | ||
19 | var trx_balances = {}; | 19 | var trx_balances = {}; |
20 | var trx_prices = {}; | 20 | var trx_prices = {}; |
21 | 21 | ||
22 | function calculateSignature(password, msisdn, timestamp) { | 22 | function calculateSignature(password, msisdn, timestamp) { |
23 | var a = timestamp + msisdn.substr(msisdn.length - 4); | 23 | var a = timestamp + msisdn.substr(msisdn.length - 4); |
24 | var b = msisdn.substr(msisdn.length - 4).split('').reverse().join('') + password; | 24 | var b = msisdn.substr(msisdn.length - 4).split('').reverse().join('') + password; |
25 | 25 | ||
26 | return xor.encode(a,b); | 26 | return xor.encode(a,b); |
27 | } | 27 | } |
28 | 28 | ||
29 | function createPayload(task) { | 29 | function createPayload(task) { |
30 | var timestamp = strftime('%H%M%S'); | 30 | var timestamp = strftime('%H%M%S'); |
31 | 31 | ||
32 | var payload = { | 32 | var payload = { |
33 | pulsamatic: [ | 33 | pulsamatic: [ |
34 | {command: 'TOPUP'}, | 34 | {command: 'TOPUP'}, |
35 | {vtype: task['remoteProduct']}, | 35 | {vtype: task['remoteProduct']}, |
36 | {userid: config.h2h_out.userid}, | 36 | {userid: config.h2h_out.userid}, |
37 | {time: timestamp}, | 37 | {time: timestamp}, |
38 | {msisdn: task['destination']}, | 38 | {msisdn: task['destination']}, |
39 | {trxid: task['requestId']}, | 39 | {trxid: task['requestId']}, |
40 | {sign: calculateSignature(config.h2h_out.password, task['destination'], timestamp)} | 40 | {sign: calculateSignature(config.h2h_out.password, task['destination'], timestamp)} |
41 | ] | 41 | ] |
42 | }; | 42 | }; |
43 | 43 | ||
44 | //console.log(payload); | 44 | //console.log(payload); |
45 | return "<?xml version=\"1.0\" ?>\n" + xml(payload); | 45 | return "<?xml version=\"1.0\" ?>\n" + xml(payload); |
46 | } | 46 | } |
47 | 47 | ||
48 | function topupRequest(task, retry) { | 48 | function topupRequest(task, retry) { |
49 | 49 | ||
50 | aaa.insertTaskToMongoDb(task); | 50 | aaa.insertTaskToMongoDb(task); |
51 | 51 | ||
52 | var payload_xml = createPayload(task); | 52 | var payload_xml = createPayload(task); |
53 | var partner = url.parse(config.h2h_out.partner); | 53 | var partner = url.parse(config.h2h_out.partner); |
54 | 54 | ||
55 | var request_options = { | 55 | var request_options = { |
56 | host: partner.hostname, | 56 | host: partner.hostname, |
57 | path: partner.path, | 57 | path: partner.path, |
58 | port: partner.port, | 58 | port: partner.port, |
59 | method: "POST", | 59 | method: "POST", |
60 | headers: { | 60 | headers: { |
61 | 'Content-Type': 'text/xml', | 61 | 'Content-Type': 'text/xml', |
62 | 'Content-Length': Buffer.byteLength(payload_xml) | 62 | 'Content-Length': Buffer.byteLength(payload_xml) |
63 | } | 63 | } |
64 | }; | 64 | }; |
65 | 65 | ||
66 | var buffer = ""; | 66 | var buffer = ""; |
67 | 67 | ||
68 | logger.info('Requesting to partner', {request_options: request_options}); | 68 | logger.info('Requesting to partner', {request_options: request_options}); |
69 | 69 | ||
70 | var req = http.request(request_options, function( res ) { | 70 | var req = http.request(request_options, function( res ) { |
71 | 71 | ||
72 | logger.info('Status code: ' + res.statusCode ); | 72 | logger.info('Status code: ' + res.statusCode ); |
73 | var buffer = ""; | 73 | var buffer = ""; |
74 | res.on( "data", function( data ) { buffer = buffer + data; } ); | 74 | res.on( "data", function( data ) { buffer = buffer + data; } ); |
75 | res.on( "end", function( data ) { | 75 | res.on( "end", function( data ) { |
76 | directResponseHandler(buffer, task['requestId']); | 76 | directResponseHandler(buffer, task['requestId']); |
77 | }); | 77 | }); |
78 | 78 | ||
79 | }); | 79 | }); |
80 | 80 | ||
81 | req.on('error', function(e) { | 81 | req.on('error', function(e) { |
82 | logger.warn('problem with request: ' + e.message); | 82 | logger.warn('problem with request: ' + e.message); |
83 | callbackReport(task['requestId'], '40', e.message); | 83 | callbackReport(task['requestId'], '40', e.message); |
84 | }); | 84 | }); |
85 | 85 | ||
86 | logger.verbose('Sending payload to partner', {payload: payload_xml}); | 86 | logger.verbose('Sending payload to partner', {payload: payload_xml}); |
87 | req.write( payload_xml ); | 87 | req.write( payload_xml ); |
88 | req.end(); | 88 | req.end(); |
89 | } | 89 | } |
90 | 90 | ||
91 | function directResponseHandler(body, request_id) { | 91 | function directResponseHandler(body, request_id) { |
92 | logger.info('Got direct response'); | 92 | logger.info('Got direct response'); |
93 | |||
93 | xml2js(body, function (err, result) { | 94 | xml2js(body, function (err, result) { |
94 | if (err) { | 95 | if (err) { |
95 | logger.warn('Error parsing xml', {err: err, body: body}); | 96 | |
96 | callbackReport(request_id, '40', 'Error parsing xml. ' + err); | 97 | if (body == 'Error: MAINTENANCE SYSTEM') { |
98 | callbackReport(request_id, '91', body); | ||
99 | } else { | ||
100 | logger.warn('Error parsing xml', {err: err, body: body}); | ||
101 | callbackReport(request_id, '40', 'Error parsing xml. ' + err); | ||
102 | } | ||
103 | |||
97 | return; | 104 | return; |
98 | } | 105 | } |
99 | 106 | ||
100 | logger.info('Direct response parsed', {result: result}); | 107 | logger.info('Direct response parsed', {result: result}); |
101 | 108 | ||
102 | var response_code = '68'; | 109 | var response_code = '68'; |
103 | 110 | ||
104 | var request_id = result.pulsamatic.partner_trxid[0].trim(); | 111 | var request_id = result.pulsamatic.partner_trxid[0].trim(); |
105 | var message = result.pulsamatic.message[0].trim(); | 112 | var message = result.pulsamatic.message[0].trim(); |
106 | var status = result.pulsamatic.result[0].trim(); | 113 | var status = result.pulsamatic.result[0].trim(); |
107 | 114 | ||
108 | if (status === 'failed') { | 115 | if (status === 'failed') { |
109 | response_code = '40'; | 116 | response_code = '40'; |
110 | 117 | ||
111 | var new_response_code = responseCodeFromMessage(message); | 118 | var new_response_code = responseCodeFromMessage(message); |
112 | if (new_response_code) { | 119 | if (new_response_code) { |
113 | response_code = new_response_code; | 120 | response_code = new_response_code; |
114 | } | 121 | } |
115 | 122 | ||
116 | } | 123 | } |
117 | 124 | ||
118 | callbackReport(request_id, response_code, message); | 125 | callbackReport(request_id, response_code, message); |
119 | }); | 126 | }); |
120 | } | 127 | } |
121 | 128 | ||
122 | function responseCodeFromMessage(message) { | 129 | function responseCodeFromMessage(message) { |
123 | if (message.indexOf('Jenis produk tidak cocok') >= 0) { | 130 | if (message.indexOf('Jenis produk tidak cocok') >= 0) { |
124 | return '14'; | 131 | return '14'; |
125 | } else if (message.indexOf('GAGAL. Nomor telp salah.') >= 0) { | 132 | } else if (message.indexOf('GAGAL. Nomor telp salah.') >= 0) { |
126 | return '14'; | 133 | return '14'; |
127 | } else if (message.indexOf('GAGAL. MSISDN tidak ditemukan') >= 0) { | 134 | } else if (message.indexOf('GAGAL. MSISDN tidak ditemukan') >= 0) { |
128 | return '14'; | 135 | return '14'; |
129 | } else if (message.indexOf('GAGAL. Jenis produk ini sedang gangguan.') >= 0) { | 136 | } else if (message.indexOf('GAGAL. Jenis produk ini sedang gangguan.') >= 0) { |
130 | return '13'; | 137 | return '13'; |
131 | } | 138 | } |
132 | return; | 139 | return; |
133 | } | 140 | } |
134 | 141 | ||
135 | function createServer() { | 142 | function createServer() { |
136 | 143 | ||
137 | var httpServer = http.createServer(function(req, res) { | 144 | var httpServer = http.createServer(function(req, res) { |
138 | //console.log('Got request from partner ("' + req.url + '")'); | 145 | //console.log('Got request from partner ("' + req.url + '")'); |
139 | 146 | ||
140 | res.end('OK'); | 147 | res.end('OK'); |
141 | 148 | ||
142 | var qs = url.parse(req.url, true).query; | 149 | var qs = url.parse(req.url, true).query; |
143 | logger.info('Reverse Report', {qs: qs}); | 150 | logger.info('Reverse Report', {qs: qs}); |
144 | 151 | ||
145 | var response_code = '68'; | 152 | var response_code = '68'; |
146 | var request_id = qs.pid; | 153 | var request_id = qs.pid; |
147 | var message = qs.msg; | 154 | var message = qs.msg; |
148 | 155 | ||
149 | if (qs.code == 2) { | 156 | if (qs.code == 2) { |
150 | // gagal | 157 | // gagal |
151 | response_code = '40'; | 158 | response_code = '40'; |
152 | } else if (qs.code == 3) { | 159 | } else if (qs.code == 3) { |
153 | // refund | 160 | // refund |
154 | response_code = '40'; | 161 | response_code = '40'; |
155 | } else if (qs.code == 4) { | 162 | } else if (qs.code == 4) { |
156 | response_code = '00'; | 163 | response_code = '00'; |
157 | message = 'SN=' + qs.sn + ';' + message; | 164 | message = 'SN=' + qs.sn + ';' + message; |
158 | } | 165 | } |
159 | 166 | ||
160 | if (response_code == '40') { | 167 | if (response_code == '40') { |
161 | var new_response_code = responseCodeFromMessage(message); | 168 | var new_response_code = responseCodeFromMessage(message); |
162 | if (new_response_code) { | 169 | if (new_response_code) { |
163 | response_code = new_response_code; | 170 | response_code = new_response_code; |
164 | } | 171 | } |
165 | } | 172 | } |
166 | 173 | ||
167 | callbackReport(request_id, response_code, message); | 174 | callbackReport(request_id, response_code, message); |
168 | }); | 175 | }); |
169 | 176 | ||
170 | httpServer.listen(config.h2h_out.listen_port, function() { | 177 | httpServer.listen(config.h2h_out.listen_port, function() { |
171 | logger.info('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port); | 178 | logger.info('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port); |
172 | }); | 179 | }); |
173 | } | 180 | } |
174 | 181 | ||
175 | function start(options) { | 182 | function start(options) { |
176 | if (!options) { | 183 | if (!options) { |
177 | console.log('Undefined options, terminating....'); | 184 | console.log('Undefined options, terminating....'); |
178 | process.exit(1); | 185 | process.exit(1); |
179 | } | 186 | } |
180 | 187 | ||
181 | if (options.config) { | 188 | if (options.config) { |
182 | config = options.config; | 189 | config = options.config; |
183 | } else { | 190 | } else { |
184 | console.log('Undefined options.config, terminating....') | 191 | console.log('Undefined options.config, terminating....') |
185 | process.exit(1); | 192 | process.exit(1); |
186 | } | 193 | } |
187 | 194 | ||
188 | if (options.aaa) { | 195 | if (options.aaa) { |
189 | aaa = options.aaa; | 196 | aaa = options.aaa; |
190 | callbackReport = options.aaa.callbackReportWithPushToMongoDb; | 197 | callbackReport = options.aaa.callbackReportWithPushToMongoDb; |
191 | } else { | 198 | } else { |
192 | console.log('Undefined options.aaa, terminating....') | 199 | console.log('Undefined options.aaa, terminating....') |
193 | process.exit(1); | 200 | process.exit(1); |
194 | } | 201 | } |
195 | 202 | ||
196 | if (options && options.logger) { | 203 | if (options && options.logger) { |
197 | logger = options.logger; | 204 | logger = options.logger; |
198 | } else { | 205 | } else { |
199 | logger = new winston.Logger({ | 206 | logger = new winston.Logger({ |
200 | transports: [ | 207 | transports: [ |
201 | new (winston.transports.Console)() | 208 | new (winston.transports.Console)() |
202 | ] | 209 | ] |
203 | }); | 210 | }); |
204 | } | 211 | } |
205 | 212 | ||
206 | createServer(); | 213 | createServer(); |
207 | } | 214 | } |
208 | 215 | ||
209 | exports.start = start; | 216 | exports.start = start; |
210 | exports.topupRequest = topupRequest; | 217 | exports.topupRequest = topupRequest; |
211 | exports.calculateSignature = calculateSignature; | 218 | exports.calculateSignature = calculateSignature; |
212 | 219 |