Reload97 / sate24-to-kisel

Browse Code »

Commit d927538f2bc028da88fdd7370c1e2bb9726e5543

Authored by Adhidarma Hadiwinoto 10 years ago

1 parent 08a7fd23ee

Exists in master

out of stock detection

Showing 2 changed files with 43 additions and 1 deletions Inline Diff

partner-scrappingkisel.js
test.js

partner-scrappingkisel.js

Diff comments View file @ d927538

 var fs = require('fs');
 var https = require('https');
 var http = require('http');
 var url = require('url');
 var request = require('request');
 var xml2js = require('xml2js').parseString;
 var strftime = require('strftime');
 var math = require('mathjs');
 var config;
 var httpServer;
 process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0';
 var logTag = __filename.split('/').reverse()[0];
 function topupRequest(task) {
     if (config.globals.requests_count == undefined) {
         config.globals.requests_count = 1;
     } else {
         config.globals.requests_count++;
     }
     if (config.globals.active_requests_count == undefined) {
         config.globals.active_requests_count = 1;
     } else {
         config.globals.active_requests_count++;
     }
     if (config.globals.max_active_requests_count == undefined) {
         config.globals.max_active_requests_count = config.globals.active_requests_count;
     } else {
         config.globals.max_active_requests_count = math.max(config.globals.max_active_requests_count, config.globals.active_requests_count);
     }
     var options = {
         url: config.h2h_out.partner,
         qs: {
             reqid: task['requestId'],
             msisdn: task['destination'],
             product: task['remoteProduct']
         }
     };
     console.log(options);
     request(options, function (error, response, body) {
         if (config.globals.active_requests_count == undefined) {
             config.globals.active_requests_count = 0;
         } else {
             config.globals.active_requests_count--;
         }
         if (error || response.statusCode != 200) {
             console.log(logTag + ': Gateway Error');
             callbackReport(task['requestId'], '40', 'Gateway Error');
             return;
         }
         console.log(logTag + ': Supplier response:');
         console.log(body);
         xml2js(body, function (err, result) {
             if (err) {
                 callbackReport(task['requestId'], '40', body);
                 return;
             }
             console.log(result);
             var response_code = '68';
             var message = result.trx_response.info[0].trim();
             if (message == 'Error Parsing') {
                 response_code = '40';
             } else if (message == "Phone number's not found") {
                 response_code = '14';
             } else if (message == "Duplicate transaction") {
                 response_code = '55';
             } else if (message == "TRANSAKSI SUKSES !!!") {
                 var destination = result.trx_response.msisdn.join(' ').trim();
                 var product = result.trx_response.product.join(' ').trim();
                 var ref_num = result.trx_response.ref_num.join(' ').trim();
                 var harga = result.trx_response.harga.join(' ').trim();
                 var kode_voucher = result.trx_response.kode_voucher.join(' ').trim();
                 var stocks = result.trx_response.stock.join(' ').trim();
                 var stock = parseStock(stocks, product);
+                if (stock == 0) {
+                    console.log('OUT OF STOCK: ' + task['product']);
+                    config.globals.products = productsWithout(task['product']);
+                }
                 response_code = '00';
                 message = 'SN=' + kode_voucher + '; ' + product + ' ' + destination + ' ' + harga + ' ref_num: ' + ref_num + ' kode_voucher: ' + kode_voucher + ' sisa stock: ' + stock + ' unit';
             }
             console.log('Message to AAA: ' + message);
             callbackReport(task['requestId'], response_code, message);
         });
     });
 }
 function start(_config, _callbackReport) {
     config = _config;
     callbackReport = _callbackReport
 }
 function stockKeyword(product_desc) {
     var keywords = product_desc.match(/\s\d+K$/);
     if (!keywords) {
         return;
     }
     if (keywords.length < 1) {
         return;
     }
     return keywords[0].trim();
 }
 function parseStock(stocks, product_desc) {
     product_keyword = stockKeyword(product_desc);
     var _stocks = stocks.split('; ');
     count = _stocks.length;
     for (var i = 0; i < count; i++) {
         var stock = _stocks[i].split(' = ');
         if (stock.length < 2) {
             continue;
         }
         if (stock[0] == product_keyword) {
             return parseInt(stock[1]);
         }
     }
     return 0;
 }
+function productsWithout(to_be_removed, products) {
+    if (products === undefined) {
+        products = config.globals.products;
+    }
+    if (products.search(/,$/) == -1) {
+        products = products + ',';
+    }
+    products = products.replace(/\s+/, '');
+    products = products.replace(to_be_removed + ',' , '');
+    products = products.replace(/,$/, '');
+    return products;
+}
 exports.start = start;
 exports.topupRequest = topupRequest;
 exports.stockKeyword = stockKeyword;
 exports.parseStock = parseStock;
+exports.productsWithout = productsWithout;

test.js

Diff comments View file @ d927538

 var assert = require("assert");
 describe('aaa', function() {
     var aaa = require('./aaa');
     describe("#unaliasResponseCode()", function() {
         it('should return 68', function() {
             assert.equal('68', aaa.unaliasResponseCode('01', '01:68'));
         });
         it('should return 68', function() {
             assert.equal('68', aaa.unaliasResponseCode('68', '01:68'));
         });
         it('should return 00', function() {
             assert.equal('00', aaa.unaliasResponseCode('00', '01:68'));
         });
         it('should return 40', function() {
             assert.equal('40', aaa.unaliasResponseCode('40', ''));
         });
         it('should return 40', function() {
             assert.equal('40', aaa.unaliasResponseCode('40', ''));
         });
         it('should return 40', function() {
             assert.equal('40', aaa.unaliasResponseCode('40'));
         });
     });
 });
-describe('aaa', function() {
+describe('partner', function() {
     var partner = require('./partner-scrappingkisel');
     describe("#stockKeyword", function() {
         it('should return 10K', function() {
             assert.equal('10K', partner.stockKeyword('Telkomsel 10K'));
         });
         it('should return 20K', function() {
             assert.equal('20K', partner.stockKeyword('Telkomsel 20K'));
         });
         it('should return 25K', function() {
             assert.equal('25K', partner.stockKeyword('Telkomsel 25K'));
         });
         it('should return 50K', function() {
             assert.equal('50K', partner.stockKeyword('Telkomsel 50K'));
         });
         it('should return 100K', function() {
             assert.equal('100K', partner.stockKeyword('Telkomsel 100K'));
         });
     });
     describe("#parseStock", function() {
         it('should return 476', function() {
             assert.equal(476, partner.parseStock('10K = 476; 20K = 598; 25K = 600; 50K = 700; 100K = 400; 150K = 0; 200K = 0; 300K = 0; 500K = 0', 'Telkomsel 10K'));
         });
         it('should return 598', function() {
             assert.equal(598, partner.parseStock('10K = 476; 20K = 598; 25K = 600; 50K = 700; 100K = 400; 150K = 0; 200K = 0; 300K = 0; 500K = 0', 'Telkomsel 20K'));
         });
         it('should return 0', function() {
             assert.equal(0, partner.parseStock('10K = 476; 20K = 598; 25K = 600; 50K = 700; 100K = 400; 150K = 0; 200K = 0; 300K = 0; 500K = 0', 'Telkomsel 200K'));
         });
         it('should return 0', function() {
             assert.equal(0, partner.parseStock('10K = 476; 20K = 598; 25K = 600; 50K = 700; 100K = 400; 150K = 0; 200K = 0; 300K = 0; 500K = 0', 'Telkomsel 2000K'));
         });
         it('should return 0', function() {
             assert.equal(0, partner.parseStock('10K = 476; 20K = 598; 25K = 600; 50K = 700; 100K = 400; 150K = 0; 200K = 0; 300K = 0; 500K = 0', 'Telkomsel 2000'));
         });
         it('should return 0', function() {
             assert.equal(0, partner.parseStock('', 'Telkomsel 2000'));
         });
         it('should return 0', function() {
             assert.equal(0, partner.parseStock('10K = 476; 20K = 598; 25K = 600; 50K = 700; 100K = 400; 150K = 0; 200K = 0; 300K = 0; 500K = 0', ''));
         });
     });
+    describe('#productsWithout', function () {
+        it('should return S10,S20,S50,S100', function() {
+            assert.equal('S10,S20,S50,S100', partner.productsWithout('S25', 'S10,S20,S25,S50,S100'));
+        });
+        it('should return S10,S20,S25,S50', function() {
+            assert.equal('S10,S20,S25,S50', partner.productsWithout('S100', 'S10,S20,S25,S50,S100'));
+        });
+        it('should return S20,S25,S50,S100', function() {
+            assert.equal('S20,S25,S50,S100', partner.productsWithout('S10', 'S10,S20,S25,S50,S100'));
+        });
+        it('should return S10,S20,S25,S50', function() {
+            assert.equal('S10,S20,S25,S50', partner.productsWithout('S100', 'S10,S20,S25,S50'));
+        });
+    });
 });