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