connection.js
1.66 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
var env = process.env.NODE_ENV || 'development';
var cfg = require('../../config/config.js').get(env);
var stats = require('../helper/stats.js');
var request = require('request');
var messageSOAP = require('../helper/messageSOAP.js');
var connection = [];
connection.requestSoapToSPW = function (soap,cmd,myMethod) {
var params = {
url : cfg.service.SPW[myMethod+"_"+cmd+"_URL"],
body : messageSOAP.objectToSOAP(soap,cmd),
method : myMethod
}
return asyncRequest(params,cmd,cfg.service.SPW.Name);
};
connection.requestJsonToD01 = function (json,cmd,myMethod) {
var params = {
url : cfg.service.D01[myMethod+"_"+cmd+"_URL"],
body : JSON.stringify(json),
method : myMethod
}
return asyncRequest(params,cmd,cfg.service.D01.Name);
};
function asyncRequest (params = {},cmd,node) {
// console.log(params);
return new Promise((resolve, reject) => {
request(params, function (error, response, body) {
stats.sendRequest(node,cmd);
if (error) {
// console.log("error");
stats.reciveResponse(node,cmd,"Error");
resolve({
'body' : body,
'err' : error
});
} else {
// console.log("normal");
stats.reciveResponse(node,cmd,"Success");
resolve({
'body' : body,
'response' : response
});
}
});
});
};
module.exports = connection;