Commit 07ecd503186ab18adad163051aca101f4f5fcd2d
1 parent
b559dae410
Exists in
master
remote product
Showing 1 changed file with 1 additions and 1 deletions Inline Diff
partner-scrappingkisel.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 | 9 | ||
10 | var config; | 10 | var config; |
11 | var httpServer; | 11 | var httpServer; |
12 | 12 | ||
13 | process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0'; | 13 | process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0'; |
14 | 14 | ||
15 | var logTag = __filename.split('/').reverse()[0]; | 15 | var logTag = __filename.split('/').reverse()[0]; |
16 | 16 | ||
17 | function topupRequest(task) { | 17 | function topupRequest(task) { |
18 | if (config.globals.requests_count == undefined) { | 18 | if (config.globals.requests_count == undefined) { |
19 | config.globals.requests_count = 1; | 19 | config.globals.requests_count = 1; |
20 | } else { | 20 | } else { |
21 | config.globals.requests_count++; | 21 | config.globals.requests_count++; |
22 | } | 22 | } |
23 | 23 | ||
24 | if (config.globals.active_requests_count == undefined) { | 24 | if (config.globals.active_requests_count == undefined) { |
25 | config.globals.active_requests_count = 1; | 25 | config.globals.active_requests_count = 1; |
26 | } else { | 26 | } else { |
27 | config.globals.active_requests_count++; | 27 | config.globals.active_requests_count++; |
28 | } | 28 | } |
29 | 29 | ||
30 | if (config.globals.max_active_requests_count == undefined) { | 30 | if (config.globals.max_active_requests_count == undefined) { |
31 | config.globals.max_active_requests_count = config.globals.active_requests_count; | 31 | config.globals.max_active_requests_count = config.globals.active_requests_count; |
32 | } else { | 32 | } else { |
33 | config.globals.max_active_requests_count = math.max(config.globals.max_active_requests_count, config.globals.active_requests_count); | 33 | config.globals.max_active_requests_count = math.max(config.globals.max_active_requests_count, config.globals.active_requests_count); |
34 | } | 34 | } |
35 | 35 | ||
36 | var options = { | 36 | var options = { |
37 | url: config.h2h_out.partner, | 37 | url: config.h2h_out.partner, |
38 | qs: { | 38 | qs: { |
39 | reqid: task['requestId'], | 39 | reqid: task['requestId'], |
40 | msisdn: task['destination'], | 40 | msisdn: task['destination'], |
41 | product: task['product'] | 41 | product: task['remoteProduct'] |
42 | } | 42 | } |
43 | }; | 43 | }; |
44 | console.log(options); | 44 | console.log(options); |
45 | 45 | ||
46 | request(options, function (error, response, body) { | 46 | request(options, function (error, response, body) { |
47 | if (config.globals.active_requests_count == undefined) { | 47 | if (config.globals.active_requests_count == undefined) { |
48 | config.globals.active_requests_count = 0; | 48 | config.globals.active_requests_count = 0; |
49 | } else { | 49 | } else { |
50 | config.globals.active_requests_count--; | 50 | config.globals.active_requests_count--; |
51 | } | 51 | } |
52 | 52 | ||
53 | if (error || response.statusCode != 200) { | 53 | if (error || response.statusCode != 200) { |
54 | console.log(logTag + ': Gateway Error'); | 54 | console.log(logTag + ': Gateway Error'); |
55 | callbackReport(task['requestId'], '40', 'Gateway Error'); | 55 | callbackReport(task['requestId'], '40', 'Gateway Error'); |
56 | return; | 56 | return; |
57 | } | 57 | } |
58 | 58 | ||
59 | console.log(logTag + ': Supplier response:'); | 59 | console.log(logTag + ': Supplier response:'); |
60 | console.log(body); | 60 | console.log(body); |
61 | 61 | ||
62 | xml2js(body, function (err, result) { | 62 | xml2js(body, function (err, result) { |
63 | if (err) { | 63 | if (err) { |
64 | callbackReport(task['requestId'], '40', body); | 64 | callbackReport(task['requestId'], '40', body); |
65 | return; | 65 | return; |
66 | } | 66 | } |
67 | 67 | ||
68 | console.log(result); | 68 | console.log(result); |
69 | 69 | ||
70 | var response_code = '68'; | 70 | var response_code = '68'; |
71 | var message = result.trx_response.info[0].trim(); | 71 | var message = result.trx_response.info[0].trim(); |
72 | 72 | ||
73 | if (message == 'Error Parsing') { | 73 | if (message == 'Error Parsing') { |
74 | 74 | ||
75 | response_code = '40'; | 75 | response_code = '40'; |
76 | 76 | ||
77 | } else if (message == "Phone number's not found") { | 77 | } else if (message == "Phone number's not found") { |
78 | 78 | ||
79 | response_code = '14'; | 79 | response_code = '14'; |
80 | 80 | ||
81 | } else if (message == "TRANSAKSI SUKSES !!!") { | 81 | } else if (message == "TRANSAKSI SUKSES !!!") { |
82 | var destination = result.trx_response.msisdn.join(' ').trim(); | 82 | var destination = result.trx_response.msisdn.join(' ').trim(); |
83 | var product = result.trx_response.product.join(' ').trim(); | 83 | var product = result.trx_response.product.join(' ').trim(); |
84 | var ref_num = result.trx_response.ref_num.join(' ').trim(); | 84 | var ref_num = result.trx_response.ref_num.join(' ').trim(); |
85 | var harga = result.trx_response.harga.join(' ').trim(); | 85 | var harga = result.trx_response.harga.join(' ').trim(); |
86 | var kode_voucher = result.trx_response.kode_voucher.join(' ').trim(); | 86 | var kode_voucher = result.trx_response.kode_voucher.join(' ').trim(); |
87 | 87 | ||
88 | response_code = '00'; | 88 | response_code = '00'; |
89 | 89 | ||
90 | message = 'SN=' + ref_num + '; ' + product + ' ' + destination + ' ' + harga + ' ref_num: ' + ref_num + ' kode_voucher: ' + kode_voucher; | 90 | message = 'SN=' + ref_num + '; ' + product + ' ' + destination + ' ' + harga + ' ref_num: ' + ref_num + ' kode_voucher: ' + kode_voucher; |
91 | } | 91 | } |
92 | 92 | ||
93 | callbackReport(task['requestId'], response_code, message); | 93 | callbackReport(task['requestId'], response_code, message); |
94 | }); | 94 | }); |
95 | }); | 95 | }); |
96 | } | 96 | } |
97 | 97 | ||
98 | function start(_config, _callbackReport) { | 98 | function start(_config, _callbackReport) { |
99 | config = _config; | 99 | config = _config; |
100 | callbackReport = _callbackReport | 100 | callbackReport = _callbackReport |
101 | } | 101 | } |
102 | 102 | ||
103 | exports.start = start; | 103 | exports.start = start; |
104 | exports.topupRequest = topupRequest; | 104 | exports.topupRequest = topupRequest; |
105 | 105 |