dd6ce15e
sumatek
add customer
|
1
2
3
4
5
|
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');
|
e2039477
Nattapon Wongpaet
update log
|
6
|
var connection = [];
|
479b9d98
sumatek
update use constants
|
7
|
|
afef30b0
Nattapon Wongpaet
fix bug detail lo...
|
8
|
connection.requestSoapToSPW = async function (soap,cmd,myMethod) {
|
787e24ad
sumatek
update async func...
|
9
|
|
dd6ce15e
sumatek
add customer
|
10
11
|
var params = {
url : cfg.service.SPW[myMethod+"_"+cmd+"_URL"],
|
787e24ad
sumatek
update async func...
|
12
|
body : messageSOAP.objectToSOAP(soap,cmd),
|
1b5ca11b
Nattapon Wongpaet
update vizcard
|
13
|
method : myMethod
|
c4a567d0
sumatek
merge
|
14
15
16
17
18
19
20
21
|
}
return asyncRequest(params,cmd,cfg.service.SPW.Name);
};
connection.requestJsonToD01 = async function (obj,cmd,myMethod) {
// JSON.stringify(json)
var params = {
|
1b5ca11b
Nattapon Wongpaet
update vizcard
|
22
|
url : cfg.service.D01[myMethod+"_"+cmd+"_URL"],
|
c4a567d0
sumatek
merge
|
23
24
25
26
|
body : obj,
method : myMethod
}
|
dd6ce15e
sumatek
add customer
|
27
|
if(params.method == "GET")
|
c4a567d0
sumatek
merge
|
28
|
{
|
b5fbb064
Nattapon Wongpaet
update log debug
|
29
|
var genUrl = getUrl(params);
|
c4a567d0
sumatek
merge
|
30
31
|
genUrl.push(genUrl[0]);
if(genUrl.length > 1)
|
60cef8c8
sumatek
update timeout
|
32
|
{
|
c4a567d0
sumatek
merge
|
33
34
35
36
37
|
// console.log("multi Send");
var multiSend = [];
var loopData = {};
for(var i=0;i<genUrl.length;i++)
{
|
72409a48
sumatek
update log
|
38
|
loopData.url = genUrl[i];
|
c4a567d0
sumatek
merge
|
39
40
|
loopData.method = params.method;
multiSend.push(loopData);
|
72409a48
sumatek
update log
|
41
42
43
44
|
// console.log("Url["+i+"] : "+loopData.url);
}
|
80e43dc0
sumatek
update soap connect
|
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
parallelRequest(multiSend,cmd,cfg.service.D01.Name);
var dataRes = {};
for(var i=0;i<multiSend.length;i++)
{
// console.log("start loop");
// var loopRes = await asyncRequest(multiSend[i],cmd,cfg.service.D01.Name);
// var loopRes = parallelRequest(multiSend[i],cmd,cfg.service.D01.Name);
if(loopRes.response)
{
var data = JSON.parse(loopRes.response.body);
dataRes[i] = {};
if(!data.resultCode)
dataRes[i].err = "Miss resultCode";
if(!data.resultDescription)
dataRes[i].err = "Miss resultDescription"
dataRes[i].data = data.resultData;
}
}
var result = {};
result.response = {};
result.response.resultData = [];
for (var i = 0; i < multiSend.length; i++) {
result.response.resultData = result.response.resultData.concat(dataRes[i].data);
if(dataRes[i].err)
result.err = dataRes[i].err;
}
if(!result.err)
{
result.response.resultCode = "20000";
result.response.developerMessage = "Success";
}
}else
|
72409a48
sumatek
update log
|
92
93
|
{
// console.log("single Send");
|
c4a567d0
sumatek
merge
|
94
|
params.url = genUrl[0];
|
dd6ce15e
sumatek
add customer
|
95
|
delete params.body;
|
b5fbb064
Nattapon Wongpaet
update log debug
|
96
|
|
c4a567d0
sumatek
merge
|
97
|
var result = await asyncRequest(params,cmd,cfg.service.D01.Name);
|
60cef8c8
sumatek
update timeout
|
98
|
|
72409a48
sumatek
update log
|
99
100
|
// console.log(result);
if(result.response)
|
60cef8c8
sumatek
update timeout
|
101
|
{
|
c4a567d0
sumatek
merge
|
102
103
|
var data = JSON.parse(result.response.body);
result.response = data;
|
e2039477
Nattapon Wongpaet
update log
|
104
|
|
c4a567d0
sumatek
merge
|
105
106
107
108
|
if(!data.resultCode)
result.err = "Miss resultCode";
if(!data.resultDescription)
|
50ad7d6d
Nattapon Wongpaet
update get vizcar...
|
109
|
result.err = "Miss resultDescription";
|
c4a567d0
sumatek
merge
|
110
|
}
|
dd6ce15e
sumatek
add customer
|
111
|
}
|
50ad7d6d
Nattapon Wongpaet
update get vizcar...
|
112
|
|
9d8ce483
Nattapon Wongpaet
update url put
|
113
|
|
c4a567d0
sumatek
merge
|
114
115
116
|
}else if(params.method == "POST")
{
params.body = JSON.stringify(params.body);
|
60cef8c8
sumatek
update timeout
|
117
|
}
|
afef30b0
Nattapon Wongpaet
fix bug detail lo...
|
118
119
120
|
delete result.body;
|
c4a567d0
sumatek
merge
|
121
122
123
124
|
// console.log(result);
return result;
|
60cef8c8
sumatek
update timeout
|
125
|
};
|
c4a567d0
sumatek
merge
|
126
127
128
129
|
function parallelRequest(multiParams,cmd,node)
{
|
dd6ce15e
sumatek
add customer
|
130
|
for(var i=0;i<multiParams.length;i++)
|
c4a567d0
sumatek
merge
|
131
132
133
134
135
136
137
|
{
stats.sendRequest(node,cmd);
console.log("Start "+i+" Url : "+multiParams[i].url);
console.log("Start "+i+"Time : "+new Date().toISOString());
request(multiParams[i], function (error, response, body) {
if (error) {
console.log("error");
|
b5fbb064
Nattapon Wongpaet
update log debug
|
138
|
console.log("End : "+new Date().toISOString());
|
c4a567d0
sumatek
merge
|
139
|
stats.reciveResponse(node,cmd,"Error");
|
60cef8c8
sumatek
update timeout
|
140
|
// resolve({
|
c4a567d0
sumatek
merge
|
141
|
// 'body' : body,
|
72409a48
sumatek
update log
|
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
|
// 'err' : error
// });
// console.log(error);
} else {
console.log("normal");
console.log("End "+i+" : "+new Date().toISOString());
// stats.reciveResponse(node,cmd,"Success");
// resolve({
// 'body' : body,
// 'response' : response
// });
// console.log(response);
}
});
}
}
function asyncRequest (params = {},cmd,node) {
// console.log(params);
console.log("Start : "+new Date().toISOString());
return new Promise((resolve, reject) => {
request(params, function (error, response, body) {
|
80e43dc0
sumatek
update soap connect
|
167
168
|
stats.sendRequest(node,cmd);
|
72409a48
sumatek
update log
|
169
170
171
172
173
174
175
176
177
178
179
|
if (error) {
// console.log("error");
console.log("Start : "+new Date());
stats.reciveResponse(node,cmd,"Error");
resolve({
'body' : body,
'err' : error
});
} else {
// console.log("normal");
console.log("End : "+new Date().toISOString());
|
80e43dc0
sumatek
update soap connect
|
180
181
|
// stats.reciveResponse(node,cmd,"Success");
resolve({
|
72409a48
sumatek
update log
|
182
183
184
185
186
|
'body' : body,
'response' : response
});
}
});
|
887b2ec5
Nattapon Wongpaet
update put customer
|
187
188
|
});
};
|
72409a48
sumatek
update log
|
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
|
function getUrl(params)
{
var returnData = [];
var url = params.url;
var fields = "";
var filter = "";
// console.log(params.body);
if(params.body)
{
var first = true;
for (key in params.body) {
if(key == "fields")
fields = getFields(params.body.fields,first);
else
filter = getfilter(filter,key,params.body[key]);
first = false;
}
|
887b2ec5
Nattapon Wongpaet
update put customer
|
210
211
212
213
214
215
216
217
218
219
220
|
}
if(filter != "")
{
var maxFilterLength = cfg.Uri_length - url.length - fields.length + "?filter=(&)".length;
if(maxFilterLength > filter.length)
{
returnData.push(url+"?filter=(&"+filter+")"+fields);
|
72409a48
sumatek
update log
|
221
222
|
}else
|
72409a48
sumatek
update log
|
223
224
225
226
|
{
// while(maxFilterLength < filter.length)
// {
|
887b2ec5
Nattapon Wongpaet
update put customer
|
227
|
// returnData.push(url+"?filter=(&"+filter+")"+fields);
|
72409a48
sumatek
update log
|
228
229
230
231
232
233
|
// }
}
}
|
887b2ec5
Nattapon Wongpaet
update put customer
|
234
|
|
72409a48
sumatek
update log
|
235
236
237
238
239
240
241
|
// console.log(url);
|
887b2ec5
Nattapon Wongpaet
update put customer
|
242
|
// console.log(filter);
|
72409a48
sumatek
update log
|
243
244
245
246
247
248
249
|
// console.log(fields);
return returnData;
}
function getFields(fields,first)
{
|
887b2ec5
Nattapon Wongpaet
update put customer
|
250
|
var returnData;
|
72409a48
sumatek
update log
|
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
|
var prefix;
if(first)
prefix = "?fields=";
else
prefix = "&fields=";
returnData = prefix+fields;
return returnData;
}
function getfilter(filter,key,newfilter)
{
var returnData;
returnData = filter+"("+key+"="+newfilter+")"
return returnData;
|
c4a567d0
sumatek
merge
|
267
|
}
|
a55a3d02
Nattapon Wongpaet
update post custo...
|
268
|
|
c4a567d0
sumatek
merge
|
269
|
module.exports = connection;
|
3cac9636
Nattapon Wongpaet
update post customer
|
|
|
c4a567d0
sumatek
merge
|
|
|
fbd30c50
sumatek
update fix bug ur...
|
|
|
9354f8c5
sumatek
fix bug
|
|
|
c4a567d0
sumatek
merge
|
|
|
b77690fa
Nattapon Wongpaet
update post custo...
|
|
|
c4a567d0
sumatek
merge
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
c4a567d0
sumatek
merge
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
c4a567d0
sumatek
merge
|
|
|
887b2ec5
Nattapon Wongpaet
update put customer
|
|
|
c4a567d0
sumatek
merge
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
c4a567d0
sumatek
merge
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
c4a567d0
sumatek
merge
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
c4a567d0
sumatek
merge
|
|
|
fbd30c50
sumatek
update fix bug ur...
|
|
|
c4a567d0
sumatek
merge
|
|
|
fbd30c50
sumatek
update fix bug ur...
|
|
|
b77690fa
Nattapon Wongpaet
update post custo...
|
|
|
c4a567d0
sumatek
merge
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
c4a567d0
sumatek
merge
|
|
|
fbd30c50
sumatek
update fix bug ur...
|
|
|
c4a567d0
sumatek
merge
|
|
|
fbd30c50
sumatek
update fix bug ur...
|
|
|
c4a567d0
sumatek
merge
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
c4a567d0
sumatek
merge
|
|
|
fbd30c50
sumatek
update fix bug ur...
|
|
|
c4a567d0
sumatek
merge
|
|
|
9354f8c5
sumatek
fix bug
|
|
|
c4a567d0
sumatek
merge
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
c4a567d0
sumatek
merge
|
|
|
72409a48
sumatek
update log
|
|
|
c4a567d0
sumatek
merge
|
|
|
72409a48
sumatek
update log
|
|
|
c4a567d0
sumatek
merge
|
|
|
72409a48
sumatek
update log
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
1f123eb1
Nattapon Wongpaet
update post membe...
|
|
|
afef30b0
Nattapon Wongpaet
fix bug detail lo...
|
|
|
1f123eb1
Nattapon Wongpaet
update post membe...
|
|
|
72409a48
sumatek
update log
|
|
|
1f123eb1
Nattapon Wongpaet
update post membe...
|
|
|
9d8ce483
Nattapon Wongpaet
update url put
|
|
|
1f123eb1
Nattapon Wongpaet
update post membe...
|
|
|
c4a567d0
sumatek
merge
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
72409a48
sumatek
update log
|
|
|
9d8ce483
Nattapon Wongpaet
update url put
|
|
|
72409a48
sumatek
update log
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
9354f8c5
sumatek
fix bug
|
|
|
f9d80b22
Nattapon Wongpaet
update header viz...
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
72409a48
sumatek
update log
|
|
|
3cac9636
Nattapon Wongpaet
update post customer
|
|
|
72409a48
sumatek
update log
|
|
|
5198016b
sumatek
update build message
|
|
|
9354f8c5
sumatek
fix bug
|
|
|
c4a567d0
sumatek
merge
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
c4a567d0
sumatek
merge
|
|
|
3cac9636
Nattapon Wongpaet
update post customer
|
|
|
c4a567d0
sumatek
merge
|
|
|
dd6ce15e
sumatek
add customer
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
479b9d98
sumatek
update use constants
|
|
|
60cef8c8
sumatek
update timeout
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
787e24ad
sumatek
update async func...
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
60cef8c8
sumatek
update timeout
|
|
|
787e24ad
sumatek
update async func...
|
|
|
60cef8c8
sumatek
update timeout
|
|
|
fbd30c50
sumatek
update fix bug ur...
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
60cef8c8
sumatek
update timeout
|
|
|
787e24ad
sumatek
update async func...
|
|
|
fbd30c50
sumatek
update fix bug ur...
|
|
|
787e24ad
sumatek
update async func...
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
60cef8c8
sumatek
update timeout
|
|
|
fbd30c50
sumatek
update fix bug ur...
|
|
|
dd6ce15e
sumatek
add customer
|
|
|
787e24ad
sumatek
update async func...
|
|
|
dd6ce15e
sumatek
add customer
|
|
|
fbd30c50
sumatek
update fix bug ur...
|
|
|
dd6ce15e
sumatek
add customer
|
|
|
60cef8c8
sumatek
update timeout
|
|
|
72409a48
sumatek
update log
|
|
|
787e24ad
sumatek
update async func...
|
|
|
60cef8c8
sumatek
update timeout
|
|
|
72409a48
sumatek
update log
|
|
|
dd6ce15e
sumatek
add customer
|
|
|
72409a48
sumatek
update log
|
|
|
887b2ec5
Nattapon Wongpaet
update put customer
|
|
|
72409a48
sumatek
update log
|
|
|
dd6ce15e
sumatek
add customer
|
|
|
9d8ce483
Nattapon Wongpaet
update url put
|
|
|
887b2ec5
Nattapon Wongpaet
update put customer
|
|
|
9d8ce483
Nattapon Wongpaet
update url put
|
|
|
887b2ec5
Nattapon Wongpaet
update put customer
|
|
|
9d8ce483
Nattapon Wongpaet
update url put
|
|
|
9d8ce483
Nattapon Wongpaet
update url put
|
|
|
5198016b
sumatek
update build message
|
|
|
81e85e64
sumatek
update customer
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
81e85e64
sumatek
update customer
|
|
|
5198016b
sumatek
update build message
|
|
|
d46c5802
sumatek
up date for conne...
|
|
|
03f3be38
Nattapon Wongpaet
fix bugs
|
|
|
84646faa
sumatek
update connection
|
|
|
03f3be38
Nattapon Wongpaet
fix bugs
|
|
|
81e85e64
sumatek
update customer
|
|
|
79d9e534
Nattapon Wongpaet
update post customer
|
|
|
81e85e64
sumatek
update customer
|
|
|
5198016b
sumatek
update build message
|
|
|
79d9e534
Nattapon Wongpaet
update post customer
|
|
|
5198016b
sumatek
update build message
|
|
|
79d9e534
Nattapon Wongpaet
update post customer
|
|
|
81e85e64
sumatek
update customer
|
|
|
81e85e64
sumatek
update customer
|
|
|
5198016b
sumatek
update build message
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
5198016b
sumatek
update build message
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
5198016b
sumatek
update build message
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
5198016b
sumatek
update build message
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
5198016b
sumatek
update build message
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
5198016b
sumatek
update build message
|
|
|
fbd30c50
sumatek
update fix bug ur...
|
|
|
5198016b
sumatek
update build message
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
5198016b
sumatek
update build message
|
|
|
81e85e64
sumatek
update customer
|
|
|
5198016b
sumatek
update build message
|
|
|
81e85e64
sumatek
update customer
|
|
|
fbd30c50
sumatek
update fix bug ur...
|
|
|
5198016b
sumatek
update build message
|
|
|
a1f044d9
sumatek
update parallel
|
|
|
81e85e64
sumatek
update customer
|
|
|
b77690fa
Nattapon Wongpaet
update post custo...
|
|
|
81e85e64
sumatek
update customer
|
|
|
dd6ce15e
sumatek
add customer
|
|
|
79d9e534
Nattapon Wongpaet
update post customer
|
|
|
81e85e64
sumatek
update customer
|
|
|
5198016b
sumatek
update build message
|
|
|
d46c5802
sumatek
up date for conne...
|
|
|
5198016b
sumatek
update build message
|
|
|
d46c5802
sumatek
up date for conne...
|
|
|
5198016b
sumatek
update build message
|
|
|
fbd30c50
sumatek
update fix bug ur...
|
|
|
5198016b
sumatek
update build message
|
|
|
3aa57883
Nattapon Wongpaet
fix bug
|
|
|
5198016b
sumatek
update build message
|
|
|
81e85e64
sumatek
update customer
|
|
|
dd6ce15e
sumatek
add customer
|
|
|
72409a48
sumatek
update log
|
|
|
479b9d98
sumatek
update use constants
|
|
|
dd6ce15e
sumatek
add customer
|
|
|