Commit 260ba40b995dd28cca6f7e97db40ae8fde9583df
1 parent
d03db4675b
Exists in
master
perbaikan ambil stock
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['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(' ').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 | response_code = '00'; | 94 | response_code = '00'; |
| 95 | 95 | ||
| 96 | message = 'SN=' + kode_voucher + '; ' + product + ' ' + destination + ' ' + harga + ' ref_num: ' + ref_num + ' kode_voucher: ' + kode_voucher + ' sisa stock: ' + stock + ' unit'; | 96 | message = 'SN=' + kode_voucher + '; ' + product + ' ' + destination + ' ' + harga + ' ref_num: ' + ref_num + ' kode_voucher: ' + kode_voucher + ' sisa stock: ' + stock + ' unit'; |
| 97 | } | 97 | } |
| 98 | 98 | ||
| 99 | callbackReport(task['requestId'], response_code, message); | 99 | callbackReport(task['requestId'], response_code, message); |
| 100 | }); | 100 | }); |
| 101 | }); | 101 | }); |
| 102 | } | 102 | } |
| 103 | 103 | ||
| 104 | function start(_config, _callbackReport) { | 104 | function start(_config, _callbackReport) { |
| 105 | config = _config; | 105 | config = _config; |
| 106 | callbackReport = _callbackReport | 106 | callbackReport = _callbackReport |
| 107 | } | 107 | } |
| 108 | 108 | ||
| 109 | function stockKeyword(product_desc) { | 109 | function stockKeyword(product_desc) { |
| 110 | var keywords = product_desc.match(/\s\d+K$/); | 110 | var keywords = product_desc.match(/\s\d+K$/); |
| 111 | if (!keywords) { | 111 | if (!keywords) { |
| 112 | return; | 112 | return; |
| 113 | } | 113 | } |
| 114 | 114 | ||
| 115 | if (keywords.length < 1) { | 115 | if (keywords.length < 1) { |
| 116 | return; | 116 | return; |
| 117 | } | 117 | } |
| 118 | 118 | ||
| 119 | return keywords[0].trim(); | 119 | return keywords[0].trim(); |
| 120 | } | 120 | } |
| 121 | 121 | ||
| 122 | function parseStock(stocks, product_desc) { | 122 | function parseStock(stocks, product_desc) { |
| 123 | product_keyword = stockKeyword(product_desc); | 123 | product_keyword = stockKeyword(product_desc); |
| 124 | 124 | ||
| 125 | var _stocks = stocks.split('; '); | 125 | var _stocks = stocks.split('; '); |
| 126 | count = _stocks.length; | 126 | count = _stocks.length; |
| 127 | for (var i = 0; i < count; i++) { | 127 | for (var i = 0; i < count; i++) { |
| 128 | var stock = _stocks[i].split(' = '); | 128 | var stock = _stocks[i].split(' = '); |
| 129 | if (stock.length < 2) { | 129 | if (stock.length < 2) { |
| 130 | continue; | 130 | continue; |
| 131 | } | 131 | } |
| 132 | 132 | ||
| 133 | if (stock[0] == product_keyword) { | 133 | if (stock[0] == product_keyword) { |
| 134 | return parseInt(stock[1]); | 134 | return parseInt(stock[1]); |
| 135 | } | 135 | } |
| 136 | } | 136 | } |
| 137 | 137 | ||
| 138 | return 0; | 138 | return 0; |
| 139 | } | 139 | } |
| 140 | 140 | ||
| 141 | exports.start = start; | 141 | exports.start = start; |
| 142 | exports.topupRequest = topupRequest; | 142 | exports.topupRequest = topupRequest; |
| 143 | exports.stockKeyword = stockKeyword; | 143 | exports.stockKeyword = stockKeyword; |
| 144 | exports.parseStock = parseStock; | 144 | exports.parseStock = parseStock; |
| 145 | 145 |