Reload97 / sate24-to-kospinjasa

Download as
Browse Code ยป

Commit 17d2372a28e6b919dc8af86e7b8bbc1482714085

Authored by Adhidarma Hadiwinoto
1 parent 23f8809e93
Exists in master

penyederhanaan kembali

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

partner-kospinjasa.js
Diff comments   View file @ 17d2372
1 var winston = require('winston'); 1 var winston = require('winston');
2 var soap = require('soap'); 2 var soap = require('soap');
3 var crypto = require('crypto'); 3 var crypto = require('crypto');
4 var strftime = require('strftime'); 4 var strftime = require('strftime');
5 5
6 var max_retry = 10; 6 var max_retry = 10;
7 var sleep_before_retry = 5000; 7 var sleep_before_retry = 5000;
8 8
9 var config; 9 var config;
10 var callbackReport; 10 var callbackReport;
11 var aaa; 11 var aaa;
12 var logger; 12 var logger;
13 var options; 13 var options;
14 14
15 function start(_config, _callbackReport, options) { 15 function start(_config, _callbackReport, options) {
16 config = _config; 16 config = _config;
17 callbackReport = _callbackReport 17 callbackReport = _callbackReport
18 18
19 if (options && options.aaa) { 19 if (options && options.aaa) {
20 aaa = options.aaa; 20 aaa = options.aaa;
21 } 21 }
22 22
23 if (options && options.logger) { 23 if (options && options.logger) {
24 logger = options.logger; 24 logger = options.logger;
25 } else { 25 } else {
26 logger = new winston.Logger({ 26 logger = new winston.Logger({
27 transports: [ 27 transports: [
28 new (winston.transports.Console)() 28 new (winston.transports.Console)()
29 ] 29 ]
30 }); 30 });
31 } 31 }
32 } 32 }
33 33
34 function topupRequest(task, retry) { 34 function topupRequest(task, retry) {
35 if (retry === undefined) { 35 if (retry === undefined) {
36 retry = max_retry; 36 retry = max_retry;
37 } 37 }
38 38
39 var remoteProduct = task.remoteProduct.split(','); 39 var remoteProduct = task.remoteProduct.split(',');
40 var params = { 40 var params = {
41 userName: config.h2h_out.userid, 41 userName: config.h2h_out.userid,
42 productCode: remoteProduct[0] , 42 productCode: remoteProduct[0] ,
43 terminal: 'terminal0', 43 terminal: 'terminal0',
44 transactionType: '50', 44 transactionType: '50',
45 billNumber: createBillNumber(task.destination), 45 billNumber: createBillNumber(task.destination),
46 amount: remoteProduct[1], 46 amount: remoteProduct[1],
47 bit61: createBillNumber(task.destination), 47 bit61: createBillNumber(task.destination),
48 reff: task.requestId, 48 reff: task.requestId,
49 timeStamp: strftime('%d-%m-%Y %H:%M:%S', new Date()) 49 timeStamp: strftime('%d-%m-%Y %H:%M:%S', new Date())
50 } 50 }
51 51
52 var signature = createSignature(params, config.h2h_out.password); 52 var signature = createSignature(params, config.h2h_out.password);
53 params.signature = signature; 53 params.signature = signature;
54 54
55 topupRequestSoap(task, params, retry); 55 topupRequestSoap(task, params, retry);
56 } 56 }
57 57
58 function topupRequestSoap(task, params, retry) { 58 function topupRequestSoap(task, params, retry) {
59 59
60 soap.createClient(config.h2h_out.partner, function(err, soapClient) { 60 soap.createClient(config.h2h_out.partner, function(err, soapClient) {
61 61
62 logger.info('Requesting to service', {url: config.h2h_out.partner, params: params}); 62 logger.info('Requesting to service', {url: config.h2h_out.partner, params: params});
63 63
64 soapClient.billpayment( 64 soapClient.billpayment({ inputCheck: params }, function(err, result) {
65 {
66 inputCheck: {
67 userName: params.userName,
68 signature: params.signature,
69 productCode: params.productCode,
70 terminal: params.terminal,
71 transactionType: params.transactionType,
72 billNumber: params.billNumber,
73 amount: params.amount,
74 bit61: params.bit61,
75 reff: params.reff,
76 timeStamp: params.timeStamp
77 }
78 },
79 function(err, result) {
80
81 if (err) { 65 if (err) {
82 logger.warn('Error requesting service', {err: err}); 66 logger.warn('Error requesting service', {err: err});
83 callbackReport(task.requestId, '68', 'something wrong'); 67 callbackReport(task.requestId, '68', 'something wrong');
84 return; 68 return;
85 } 69 }
86 70
87 var responseMessageToST24 = result.outputParameter.resultCode.$value + ' - ' + result.outputParameter.resultDesc.$value; 71 var responseMessageToST24 = result.outputParameter.resultCode.$value + ' - ' + result.outputParameter.resultDesc.$value;
88 72
89 logger.info('Got result: ' + responseMessageToST24, {result: result}); 73 logger.info('Got result: ' + responseMessageToST24, {result: result});
90 74
91 callbackReport(task.requestId, '68', responseMessageToST24); 75 callbackReport(task.requestId, '68', responseMessageToST24);
92 }); 76 });
93 }); 77 });
94 } 78 }
95 79
96 80
97 81
98 function createSignature(params, password) { 82 function createSignature(params, password) {
99 var passwordHash = crypto.createHash('sha256').update(password).digest().toString('hex'); 83 var passwordHash = crypto.createHash('sha256').update(password).digest().toString('hex');
100 84
101 var plain = 85 var plain =
102 params.userName 86 params.userName
103 + passwordHash 87 + passwordHash
104 + params.productCode 88 + params.productCode
105 + params.terminal 89 + params.terminal
106 + params.transactionType 90 + params.transactionType
107 + params.billNumber 91 + params.billNumber
108 + params.amount 92 + params.amount
109 + params.reff 93 + params.reff
110 + params.timeStamp; 94 + params.timeStamp;
111 95
112 var result = crypto.createHash('sha1').update(plain).digest().toString('hex'); 96 var result = crypto.createHash('sha1').update(plain).digest().toString('hex');
113 97
114 if (logger) { 98 if (logger) {
115 logger.verbose('Calculating signature', {plain: plain, result: result, params: params, password: password}); 99 logger.verbose('Calculating signature', {plain: plain, result: result, params: params, password: password});
116 } 100 }
117 101
118 return result; 102 return result;
119 } 103 }
120 104
121 function createBillNumber(destination) { 105 function createBillNumber(destination) {
122 return ("0000000000000" + destination).slice(-13); 106 return ("0000000000000" + destination).slice(-13);
123 } 107 }
124 108
125 exports.start = start; 109 exports.start = start;
126 exports.topupRequest = topupRequest; 110 exports.topupRequest = topupRequest;
127 exports.createSignature = createSignature; 111 exports.createSignature = createSignature;
128 exports.createBillNumber = createBillNumber; 112 exports.createBillNumber = createBillNumber;
129 113