@chinh/vrp-tools/optimize_test/index.js

/* 
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */
"use strict";

var http = require('http');
var _ = require('lodash');
var fs = require("fs");


/**
 * optimize problem 
 * 
 */
function sendDataToServer(user,pwd,host,noOfCust,threads) {
  var user_data = JSON.stringify({
    "username": user,
  "password": pwd,
  });
  var token = '';
  var options = {
    host: host,
    path: '/',
    port: '80',
    method: 'POST',
    headers: {
      'Content-Type': 'application/json',
      'Content-Length': '0'
    }
  };
  //http call to login and retrieve token
  _httpCall({
    path: '/cvrp/rest/login', headers: {
      'Content-Length': Buffer.byteLength(user_data), 'Content-Type': 'application/json'
    }
  }, user_data, _loginCallBack);
  function _httpCall(inputs, inputData, callBack) {
    options = _.extend(options, inputs);
    var req = http.request(options, function (response) {
      var str = '';
      response.on('data', function (chunk) {
        console.log("data");
        str += chunk;
      });
      response.on('error', function (data) {
        console.log("daerrta");
        callBack(data);
      });
      response.on('end', function () {
        console.log("end");
        callBack(str);
      });
    });
    if (inputData !== "")
      req.write(inputData);
    req.end();
  }
  /**
   * login API callback
   * @param {type} data
   * 
   */
  function _loginCallBack(data) {
    // console.log("data recieved  :"+data);
    var out = JSON.parse(data);
    token = out.token;

    console.log("data recieved for user :" + out.token);
    //var noOfCust = 100;
   // noOfCust = getArg("n");
    var profileFileName = "./optimize_test/samples/problem_" + noOfCust + ".json";
    if (fs.existsSync(profileFileName)) {
      var problem = JSON.parse(fs.readFileSync(profileFileName));
      var d = new Date();
      var n = d.getMilliseconds();
      problem["_id"] = problem["_id"] + "_" + n;
      problem["name"] = problem["name"] + "_" + n;
      var out = JSON.stringify(problem);

      _httpCall({
        path: '/cvrp/rest/problem', headers: {
          'Content-Length': Buffer.byteLength(out), 'Content-Type': 'application/json',
          'x-access-token': token
        }
      }, out, _createProblemCallback);

    } else {
      console.warn(profileFileName + " does not exist");
    }

  }
  /**
   * CreateProblem API callback
   * @param {type} data
   * 
   */
  function _createProblemCallback(data) {
    console.log("prob call back  :");
    var out = JSON.parse(data);
    var prob_Id = out["_id"];

    console.log("prob id  :" + prob_Id);
    var path = '/cvrp/rest/geocode_problem/' + prob_Id;
    _httpCall({
      path: '/cvrp/rest/geocode_problem/' + prob_Id, method: 'GET', headers: {
        'x-access-token': token
      }
    }, "", _geocodeCallBack);
  }

  /**
   * Geocode API callback
   * @param {type} data
   * 
   */
  function _geocodeCallBack(data) {
    var out = JSON.parse(data);
    var prob_Id = out["_id"];

    console.log("prob id after geo code  :" + prob_Id);

    var out = JSON.stringify({
      "engine": "siwei",
      "solutionId": "test_01",
      "maxIterations": 300,
	  "nThreads": threads,
      "constraints": "capacity_timeWindow_restrictJobsToSpecificVehicles_priorityJob"
    });

    _httpCall({
      path: '/cvrp/rest/optimize_problem/' + prob_Id, method: 'POST', headers: {
        'Content-Length': Buffer.byteLength(out), 'Content-Type': 'application/json',
        'x-access-token': token
      }
    }, out, function (data) {
      var out = JSON.parse(data);
      var duration = out["calc_duration"];

      console.log("completed optimization in :" + duration);
    });
  }
}

function getArg(key) {
  if (process.argv.indexOf("-" + key) !== -1) {
    return process.argv[process.argv.indexOf("-" + key) + 1];
  }
}
exports.optimize = function(user,pwd,host,noOfCust,threads){
	console.log("data"+threads);
	sendDataToServer(user,pwd,host,noOfCust,threads);
};