Commit eb07a30ad7d6d2c4e17fd7012ab3040306a30a57
1 parent
251e1dc345
Exists in
master
tangani undefined error
Showing 1 changed file with 4 additions and 0 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['remoteProduct'] | 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 | if (message == 'Undefined error') { | ||
78 | |||
79 | response_code = '40'; | ||
80 | |||
77 | } else if (message == "Phone number's not found") { | 81 | } else if (message == "Phone number's not found") { |
78 | 82 | ||
79 | response_code = '14'; | 83 | response_code = '14'; |
80 | 84 | ||
81 | } else if (message == "Duplicate transaction") { | 85 | } else if (message == "Duplicate transaction") { |
82 | 86 | ||
83 | response_code = '55'; | 87 | response_code = '55'; |
84 | 88 | ||
85 | } else if (message == "TRANSAKSI SUKSES !!!") { | 89 | } else if (message == "TRANSAKSI SUKSES !!!") { |
86 | var destination = result.trx_response.msisdn.join(' ').trim(); | 90 | var destination = result.trx_response.msisdn.join(' ').trim(); |
87 | var product = result.trx_response.product.join(' ').trim(); | 91 | var product = result.trx_response.product.join(' ').trim(); |
88 | var ref_num = result.trx_response.ref_num.join(' ').trim(); | 92 | var ref_num = result.trx_response.ref_num.join(' ').trim(); |
89 | var harga = result.trx_response.harga.join(' ').trim(); | 93 | var harga = result.trx_response.harga.join(' ').trim(); |
90 | var kode_voucher = result.trx_response.kode_voucher.join(' ').trim(); | 94 | var kode_voucher = result.trx_response.kode_voucher.join(' ').trim(); |
91 | var stocks = result.trx_response.stock.join(' ').trim(); | 95 | var stocks = result.trx_response.stock.join(' ').trim(); |
92 | var stock = parseStock(stocks, product); | 96 | var stock = parseStock(stocks, product); |
93 | 97 | ||
94 | if (stock == 0) { | 98 | if (stock == 0) { |
95 | console.log('OUT OF STOCK: ' + task['product']); | 99 | console.log('OUT OF STOCK: ' + task['product']); |
96 | config.globals.products = productsWithout(task['product']); | 100 | config.globals.products = productsWithout(task['product']); |
97 | } | 101 | } |
98 | 102 | ||
99 | response_code = '00'; | 103 | response_code = '00'; |
100 | 104 | ||
101 | message = 'SN=' + kode_voucher + '; ' + product + ' ' + destination + ' ' + harga + ' ref_num: ' + ref_num + ' kode_voucher: ' + kode_voucher + ' sisa stock: ' + stock + ' unit'; | 105 | message = 'SN=' + kode_voucher + '; ' + product + ' ' + destination + ' ' + harga + ' ref_num: ' + ref_num + ' kode_voucher: ' + kode_voucher + ' sisa stock: ' + stock + ' unit'; |
102 | } | 106 | } |
103 | 107 | ||
104 | console.log('Message to AAA: ' + message); | 108 | console.log('Message to AAA: ' + message); |
105 | callbackReport(task['requestId'], response_code, message); | 109 | callbackReport(task['requestId'], response_code, message); |
106 | }); | 110 | }); |
107 | }); | 111 | }); |
108 | } | 112 | } |
109 | 113 | ||
110 | function start(_config, _callbackReport) { | 114 | function start(_config, _callbackReport) { |
111 | config = _config; | 115 | config = _config; |
112 | callbackReport = _callbackReport | 116 | callbackReport = _callbackReport |
113 | } | 117 | } |
114 | 118 | ||
115 | function stockKeyword(product_desc) { | 119 | function stockKeyword(product_desc) { |
116 | var keywords = product_desc.match(/\s\d+K$/); | 120 | var keywords = product_desc.match(/\s\d+K$/); |
117 | if (!keywords) { | 121 | if (!keywords) { |
118 | return; | 122 | return; |
119 | } | 123 | } |
120 | 124 | ||
121 | if (keywords.length < 1) { | 125 | if (keywords.length < 1) { |
122 | return; | 126 | return; |
123 | } | 127 | } |
124 | 128 | ||
125 | return keywords[0].trim(); | 129 | return keywords[0].trim(); |
126 | } | 130 | } |
127 | 131 | ||
128 | function parseStock(stocks, product_desc) { | 132 | function parseStock(stocks, product_desc) { |
129 | product_keyword = stockKeyword(product_desc); | 133 | product_keyword = stockKeyword(product_desc); |
130 | 134 | ||
131 | var _stocks = stocks.split('; '); | 135 | var _stocks = stocks.split('; '); |
132 | count = _stocks.length; | 136 | count = _stocks.length; |
133 | for (var i = 0; i < count; i++) { | 137 | for (var i = 0; i < count; i++) { |
134 | var stock = _stocks[i].split(' = '); | 138 | var stock = _stocks[i].split(' = '); |
135 | if (stock.length < 2) { | 139 | if (stock.length < 2) { |
136 | continue; | 140 | continue; |
137 | } | 141 | } |
138 | 142 | ||
139 | if (stock[0] == product_keyword) { | 143 | if (stock[0] == product_keyword) { |
140 | return parseInt(stock[1]); | 144 | return parseInt(stock[1]); |
141 | } | 145 | } |
142 | } | 146 | } |
143 | 147 | ||
144 | return 0; | 148 | return 0; |
145 | } | 149 | } |
146 | 150 | ||
147 | function productsWithout(to_be_removed, products) { | 151 | function productsWithout(to_be_removed, products) { |
148 | if (products === undefined) { | 152 | if (products === undefined) { |
149 | products = config.globals.products; | 153 | products = config.globals.products; |
150 | } | 154 | } |
151 | 155 | ||
152 | if (products.search(/^,/) == -1) { | 156 | if (products.search(/^,/) == -1) { |
153 | products = ',' + products; | 157 | products = ',' + products; |
154 | } | 158 | } |
155 | 159 | ||
156 | 160 | ||
157 | if (products.search(/,$/) == -1) { | 161 | if (products.search(/,$/) == -1) { |
158 | products = products + ','; | 162 | products = products + ','; |
159 | } | 163 | } |
160 | 164 | ||
161 | products = products.replace(/\s+/, ''); | 165 | products = products.replace(/\s+/, ''); |
162 | products = products.replace(/,+/, ','); | 166 | products = products.replace(/,+/, ','); |
163 | products = products.replace(',' + to_be_removed + ',' , ','); | 167 | products = products.replace(',' + to_be_removed + ',' , ','); |
164 | products = products.replace(/^,/, ''); | 168 | products = products.replace(/^,/, ''); |
165 | products = products.replace(/,$/, ''); | 169 | products = products.replace(/,$/, ''); |
166 | 170 | ||
167 | return products; | 171 | return products; |
168 | } | 172 | } |
169 | 173 | ||
170 | exports.start = start; | 174 | exports.start = start; |
171 | exports.topupRequest = topupRequest; | 175 | exports.topupRequest = topupRequest; |
172 | exports.stockKeyword = stockKeyword; | 176 | exports.stockKeyword = stockKeyword; |
173 | exports.parseStock = parseStock; | 177 | exports.parseStock = parseStock; |
174 | exports.productsWithout = productsWithout; | 178 | exports.productsWithout = productsWithout; |
175 | 179 |