Reload97 / sate24-to-masterpulsa-voucher

Download as
Browse Code ยป

Commit 40a722140b68202739805e221793165d0d8f2818

Authored by Adhidarma Hadiwinoto
1 parent ce8b66daa4
Exists in master

hapus keyword var

Showing 1 changed file with 2 additions and 1 deletions Inline Diff

partner-masterpulsa-voucher.js
Diff comments   View file @ 40a7221
1 var winston = require('winston'); 1 var winston = require('winston');
2 var request = require('request'); 2 var request = require('request');
3 var strftime = require('strftime'); 3 var strftime = require('strftime');
4 var crypto = require('crypto'); 4 var crypto = require('crypto');
5 var redis = require('redis'); 5 var redis = require('redis');
6 6
7 var config; 7 var config;
8 var callbackReport; 8 var callbackReport;
9 var aaa; 9 var aaa;
10 var logger; 10 var logger;
11 var options; 11 var options;
12 var redisClient; 12 var redisClient;
13 13
14 var adviceDelay = 10000; 14 var adviceDelay = 10000;
15 15
16 function createRedisClient() { 16 function createRedisClient() {
17 redisClient = redis.createClient(config.globals.redis_port, config.globals.redis_host); 17 redisClient = redis.createClient(config.globals.redis_port, config.globals.redis_host);
18 } 18 }
19 19
20 function start(_config, _callbackReport, options) { 20 function start(_config, _callbackReport, options) {
21 config = _config; 21 config = _config;
22 callbackReport = _callbackReport 22 callbackReport = _callbackReport
23 23
24 if (options && options.aaa) { 24 if (options && options.aaa) {
25 aaa = options.aaa; 25 aaa = options.aaa;
26 } 26 }
27 27
28 if (options && options.logger) { 28 if (options && options.logger) {
29 logger = options.logger; 29 logger = options.logger;
30 } else { 30 } else {
31 logger = new winston.Logger({ 31 logger = new winston.Logger({
32 transports: [ 32 transports: [
33 new (winston.transports.Console)() 33 new (winston.transports.Console)()
34 ] 34 ]
35 }); 35 });
36 } 36 }
37 37
38 createRedisClient(); 38 createRedisClient();
39 } 39 }
40 40
41 function getRedisKey(task) { 41 function getRedisKey(task) {
42 return config.globals.gateway_name + '.tid:' + task.requestId; 42 return config.globals.gateway_name + '.tid:' + task.requestId;
43 } 43 }
44 44
45 function putTaskToRedis(task) { 45 function putTaskToRedis(task) {
46 var redisKey = getRedisKey(task); 46 var redisKey = getRedisKey(task);
47 var taskInJSON = JSON.stringify(task); 47 var taskInJSON = JSON.stringify(task);
48 48
49 redisClient.set(redisKey, taskInJSON); 49 redisClient.set(redisKey, taskInJSON);
50 redisClient.expire(redisKey, 3600*24*7); 50 redisClient.expire(redisKey, 3600*24*7);
51 } 51 }
52 52
53 function topupRequest(task, retry) { 53 function topupRequest(task, retry) {
54 var redisKey = getRedisKey(task); 54 var redisKey = getRedisKey(task);
55 55
56 redisClient.get(redisKey, function(err, result) { 56 redisClient.get(redisKey, function(err, result) {
57 if (err || !result) { 57 if (err || !result) {
58 58
59 //logger.info('Redis error or not found', {redisKey: redisKey, error: err, result: result}); 59 //logger.info('Redis error or not found', {redisKey: redisKey, error: err, result: result});
60 putTaskToRedis(task); 60 putTaskToRedis(task);
61 voucherPay(task); 61 voucherPay(task);
62 62
63 } else { 63 } else {
64 advice(task); 64 advice(task);
65 } 65 }
66 }); 66 });
67 } 67 }
68 68
69 function calculateSignature(cid, secret, dt) { 69 function calculateSignature(cid, secret, dt) {
70 return crypto.createHash('sha256').update(cid + dt + secret).digest().toString('hex'); 70 return crypto.createHash('sha256').update(cid + dt + secret).digest().toString('hex');
71 } 71 }
72 72
73 function parsePaymentResponse(message) { 73 function parsePaymentResponse(message) {
74 var data = message.split('#'); 74 var data = message.split('#');
75 var retval = {};
75 76
76 if (data[0] == 'ERROR') { 77 if (data[0] == 'ERROR') {
77 retval = { 78 retval = {
78 status: data[0], 79 status: data[0],
79 rc: data[1], 80 rc: data[1],
80 rcmessage: data[2], 81 rcmessage: data[2],
81 } 82 }
82 83
83 } else { 84 } else {
84 85
85 var i = 0; 86 var i = 0;
86 retval = { 87 retval = {
87 status: data[i++], 88 status: data[i++],
88 rc: data[i++], 89 rc: data[i++],
89 rcmessage: data[i++], 90 rcmessage: data[i++],
90 resptext: data[i++], 91 resptext: data[i++],
91 dt: data[i++], 92 dt: data[i++],
92 refnum: data[i++], 93 refnum: data[i++],
93 voucherid: data[i++], 94 voucherid: data[i++],
94 nominal: data[i++] 95 nominal: data[i++]
95 } 96 }
96 } 97 }
97 98
98 var retval.raw = message; 99 retval.raw = message;
99 100
100 return retval; 101 return retval;
101 } 102 }
102 103
103 function reportPaymentSuccess(task, response) { 104 function reportPaymentSuccess(task, response) {
104 var message = 'SN=' + response.refnum + '; ' + response.raw; 105 var message = 'SN=' + response.refnum + '; ' + response.raw;
105 106
106 logger.info('Report payment success to ST24', {task: task, response: response}); 107 logger.info('Report payment success to ST24', {task: task, response: response});
107 108
108 callbackReport(task.requestId, '00', message); 109 callbackReport(task.requestId, '00', message);
109 } 110 }
110 111
111 function reportPaymentError(task, response) { 112 function reportPaymentError(task, response) {
112 var errorCode = getErrorCode(response.rcmessage); 113 var errorCode = getErrorCode(response.rcmessage);
113 var st24rc = getST24ResponseCode(errorCode); 114 var st24rc = getST24ResponseCode(errorCode);
114 115
115 if (st24rc == '68') { 116 if (st24rc == '68') {
116 logger.info('Got pending response, requesting advice in ' + adviceDelay + 'ms', {task: task, response: response}); 117 logger.info('Got pending response, requesting advice in ' + adviceDelay + 'ms', {task: task, response: response});
117 setTimeout(advice, adviceDelay, task); 118 setTimeout(advice, adviceDelay, task);
118 } 119 }
119 120
120 logger.info('Report payment error/pending to ST24', {supplier_rc: errorCode, st24_rc: st24rc, task: task, response: response}); 121 logger.info('Report payment error/pending to ST24', {supplier_rc: errorCode, st24_rc: st24rc, task: task, response: response});
121 122
122 callbackReport( 123 callbackReport(
123 task.requestId, 124 task.requestId,
124 getST24ResponseCode(errorCode), 125 getST24ResponseCode(errorCode),
125 response.raw 126 response.raw
126 ); 127 );
127 } 128 }
128 129
129 function getST24ResponseCode(supplierResponseCode) { 130 function getST24ResponseCode(supplierResponseCode) {
130 var st24rc = '40'; 131 var st24rc = '40';
131 132
132 if (supplierResponseCode.length == 1) { 133 if (supplierResponseCode.length == 1) {
133 supplierResponseCode = '0' + supplierResponseCode; 134 supplierResponseCode = '0' + supplierResponseCode;
134 } 135 }
135 136
136 if (['00', '13', '14', '47', '68'].indexOf(supplierResponseCode) >= 0) { 137 if (['00', '13', '14', '47', '68'].indexOf(supplierResponseCode) >= 0) {
137 st24rc = supplierResponseCode; 138 st24rc = supplierResponseCode;
138 } 139 }
139 else if (supplierResponseCode == '15') { 140 else if (supplierResponseCode == '15') {
140 st24rc = '14'; 141 st24rc = '14';
141 } 142 }
142 else if (['05', '18', '63', '68'].indexOf(supplierResponseCode) >= 0) { 143 else if (['05', '18', '63', '68'].indexOf(supplierResponseCode) >= 0) {
143 st24rc = '68'; 144 st24rc = '68';
144 } 145 }
145 else if (supplierResponseCode == '67') { 146 else if (supplierResponseCode == '67') {
146 st24rc = '91' 147 st24rc = '91'
147 } 148 }
148 else if (supplierResponseCode == '46') { 149 else if (supplierResponseCode == '46') {
149 st24rc = '40' 150 st24rc = '40'
150 151
151 if (aaa && config && config.globals && config.globals.pause_on_not_enough_balance 152 if (aaa && config && config.globals && config.globals.pause_on_not_enough_balance
152 && (config.globals.pause_on_not_enough_balance == '1')) { 153 && (config.globals.pause_on_not_enough_balance == '1')) {
153 154
154 logger.warn('Not enough balance detected. Going to pause the system.'); 155 logger.warn('Not enough balance detected. Going to pause the system.');
155 aaa.pause(); 156 aaa.pause();
156 } 157 }
157 } 158 }
158 159
159 return st24rc; 160 return st24rc;
160 } 161 }
161 162
162 function getErrorCode(rcmessage) { 163 function getErrorCode(rcmessage) {
163 try { 164 try {
164 var errorCode = rcmessage.match(/\[(\d+)\]/); 165 var errorCode = rcmessage.match(/\[(\d+)\]/);
165 return errorCode[1]; 166 return errorCode[1];
166 } 167 }
167 catch(err) { 168 catch(err) {
168 logger.warn('Empty RCMESSAGE, returning 68 as RC for safety'); 169 logger.warn('Empty RCMESSAGE, returning 68 as RC for safety');
169 return '68'; 170 return '68';
170 } 171 }
171 } 172 }
172 173
173 function generateDt(taskTimestamp) { 174 function generateDt(taskTimestamp) {
174 if (!taskTimestamp) { 175 if (!taskTimestamp) {
175 return strftime('%Y%m%d', new Date()); 176 return strftime('%Y%m%d', new Date());
176 } 177 }
177 178
178 return taskTimestamp.slice(0, 8); 179 return taskTimestamp.slice(0, 8);
179 } 180 }
180 181
181 function generateRequestOptions(userid, password, partnerUrl, task) { 182 function generateRequestOptions(userid, password, partnerUrl, task) {
182 var dt = generateDt(task.timestamp); 183 var dt = generateDt(task.timestamp);
183 var sign = calculateSignature(userid, password, dt); 184 var sign = calculateSignature(userid, password, dt);
184 185
185 var requestOptions = { 186 var requestOptions = {
186 method: 'GET', 187 method: 'GET',
187 url: partnerUrl, 188 url: partnerUrl,
188 qs: { 189 qs: {
189 modul: '', 190 modul: '',
190 command: '', 191 command: '',
191 tujuan: task['destination'], 192 tujuan: task['destination'],
192 voucherid: task['remoteProduct'], 193 voucherid: task['remoteProduct'],
193 cid: userid, 194 cid: userid,
194 dt: dt, 195 dt: dt,
195 hc: sign, 196 hc: sign,
196 trxid: task['requestId'], 197 trxid: task['requestId'],
197 } 198 }
198 } 199 }
199 200
200 return requestOptions; 201 return requestOptions;
201 } 202 }
202 203
203 function advice(task, retry) { 204 function advice(task, retry) {
204 205
205 if (retry === null || retry === undefined) { 206 if (retry === null || retry === undefined) {
206 retry = 10; 207 retry = 10;
207 } 208 }
208 209
209 var requestOptions = generateRequestOptions(config.h2h_out.userid, config.h2h_out.password, config.h2h_out.partner, task); 210 var requestOptions = generateRequestOptions(config.h2h_out.userid, config.h2h_out.password, config.h2h_out.partner, task);
210 211
211 requestOptions.qs.modul = 'ISI'; 212 requestOptions.qs.modul = 'ISI';
212 requestOptions.qs.command = 'ADV'; 213 requestOptions.qs.command = 'ADV';
213 214
214 logger.info('Requesting advice to supplier', {requestOptions: requestOptions}); 215 logger.info('Requesting advice to supplier', {requestOptions: requestOptions});
215 request(requestOptions, function(requestError, requestResponse, requestResponseBody) { 216 request(requestOptions, function(requestError, requestResponse, requestResponseBody) {
216 if (requestError || requestResponse.statusCode != 200) { 217 if (requestError || requestResponse.statusCode != 200) {
217 logger.warn('Advice error', {error: request_error, http_response: requestResponse.statusCode}); 218 logger.warn('Advice error', {error: request_error, http_response: requestResponse.statusCode});
218 219
219 if (retry > 0) { 220 if (retry > 0) {
220 logger.warn('Going to retry advice in ' + adviceDelay + 'ms', {task: task, retry: retry}); 221 logger.warn('Going to retry advice in ' + adviceDelay + 'ms', {task: task, retry: retry});
221 setTimeout(advice, adviceDelay, task, --retry); 222 setTimeout(advice, adviceDelay, task, --retry);
222 } 223 }
223 224
224 return; 225 return;
225 } 226 }
226 227
227 var paymentResponse = parsePaymentResponse(requestResponseBody); 228 var paymentResponse = parsePaymentResponse(requestResponseBody);
228 logger.info('Got advice payment response', {paymentResponse: paymentResponse}); 229 logger.info('Got advice payment response', {paymentResponse: paymentResponse});
229 230
230 if (paymentResponse.status == 'SUCCESS') { 231 if (paymentResponse.status == 'SUCCESS') {
231 reportPaymentSuccess(task, paymentResponse); 232 reportPaymentSuccess(task, paymentResponse);
232 } 233 }
233 else { 234 else {
234 reportPaymentError(task, paymentResponse); 235 reportPaymentError(task, paymentResponse);
235 } 236 }
236 }); 237 });
237 238
238 } 239 }
239 240
240 function voucherPay(task) { 241 function voucherPay(task) {
241 var requestOptions = generateRequestOptions(config.h2h_out.userid, config.h2h_out.password, config.h2h_out.partner, task); 242 var requestOptions = generateRequestOptions(config.h2h_out.userid, config.h2h_out.password, config.h2h_out.partner, task);
242 243
243 requestOptions.qs.modul = 'ISI'; 244 requestOptions.qs.modul = 'ISI';
244 requestOptions.qs.command = 'PAY'; 245 requestOptions.qs.command = 'PAY';
245 246
246 logger.info('Requesting auto payment to supplier', {requestOptions: requestOptions}); 247 logger.info('Requesting auto payment to supplier', {requestOptions: requestOptions});
247 request(requestOptions, function(requestError, requestResponse, requestResponseBody) { 248 request(requestOptions, function(requestError, requestResponse, requestResponseBody) {
248 if (requestError) { 249 if (requestError) {
249 logger.warn('Request error', {error: requestError}); 250 logger.warn('Request error', {error: requestError});
250 251
251 setTimeout(advice, adviceDelay, task); 252 setTimeout(advice, adviceDelay, task);
252 return; 253 return;
253 } 254 }
254 255
255 if (requestResponse.statusCode != 200) { 256 if (requestResponse.statusCode != 200) {
256 logger.warn('HTTP response status code is not 200', {http_response: requestResponse.statusCode}); 257 logger.warn('HTTP response status code is not 200', {http_response: requestResponse.statusCode});
257 258
258 setTimeout(advice, adviceDelay, task); 259 setTimeout(advice, adviceDelay, task);
259 return; 260 return;
260 } 261 }
261 262
262 logger.info('Supplier response: ' + requestResponseBody); 263 logger.info('Supplier response: ' + requestResponseBody);
263 264
264 var paymentResponse = parsePaymentResponse(requestResponseBody); 265 var paymentResponse = parsePaymentResponse(requestResponseBody);
265 logger.info('Got payment response', {paymentResponse: paymentResponse}); 266 logger.info('Got payment response', {paymentResponse: paymentResponse});
266 267
267 if (paymentResponse.status == 'SUCCESS') { 268 if (paymentResponse.status == 'SUCCESS') {
268 reportPaymentSuccess(task, paymentResponse); 269 reportPaymentSuccess(task, paymentResponse);
269 } 270 }
270 else { 271 else {
271 reportPaymentError(task, paymentResponse); 272 reportPaymentError(task, paymentResponse);
272 } 273 }
273 }); 274 });
274 } 275 }
275 276
276 exports.start = start; 277 exports.start = start;
277 exports.topupRequest = topupRequest; 278 exports.topupRequest = topupRequest;
278 exports.calculateSignature = calculateSignature; 279 exports.calculateSignature = calculateSignature;
279 exports.parsePaymentResponse = parsePaymentResponse; 280 exports.parsePaymentResponse = parsePaymentResponse;
280 exports.getErrorCode = getErrorCode; 281 exports.getErrorCode = getErrorCode;
281 exports.getST24ResponseCode = getST24ResponseCode; 282 exports.getST24ResponseCode = getST24ResponseCode;
282 exports.generateDt = generateDt; 283 exports.generateDt = generateDt;
283 284