Nattapon Wongpaet / SPW

Blame view

ais-structure/src/modules/helper/connection.js 23.7 KB
Edit Raw Normal View History
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 log = require('../helper/log.js');
479b9d98   sumatek   update use constants 
7
 
var constants = require('../helper/constants.js');
afef30b0   Nattapon Wongpaet   fix bug detail lo... 
8
 
var moment = require('moment');
787e24ad   sumatek   update async func... 
9
dd6ce15e   sumatek   add customer 
10
11
 
var connection = [];
787e24ad   sumatek   update async func... 
12
1b5ca11b   Nattapon Wongpaet   update vizcard 
13
 
connection.requestSoapToSACF = async function (req,soap,cmd,myMethod) {
c4a567d0   sumatek   merge 
14
15
16
17
18
19
20
21
 
    try {
        log.log("Connect to SACF")

        var service = cfg.service.SACF;
        var retry = service[myMethod+"_"+cmd+"_Retry"];    

        var params = {
            url                 : service[myMethod+"_"+cmd+"_URL"],
1b5ca11b   Nattapon Wongpaet   update vizcard 
22
 
            body                : messageSOAP.objectToSOAP(soap,cmd),
c4a567d0   sumatek   merge 
23
24
25
26
 
            method              : myMethod,
            timeout             : cfg.service.SACF[myMethod+"_"+cmd+"_Timeout"]*1000
        }
dd6ce15e   sumatek   add customer 
27
 
        log.log("requestData : "+JSON.stringify(params))
c4a567d0   sumatek   merge 
28
b5fbb064   Nattapon Wongpaet   update log debug 
29
 
        if(!retry)
c4a567d0   sumatek   merge 
30
31
 
            retry = cfg.Default_Retry;
60cef8c8   sumatek   update timeout 
32
 
        var objectData = {
c4a567d0   sumatek   merge 
33
34
35
36
37
 
            maxRetry : retry,
            curRetry : 1
        }
72409a48   sumatek   update log 
38
c4a567d0   sumatek   merge 
39
40
 
        var funStats = {
            start : function(){
72409a48   sumatek   update log 
41
42
43
44
 
                stats.sendSACFRequest(service.Name,cmd);
                log.logDetail.addOutput(req,service.Name,myMethod+"_"+cmd,constants.REQUEST,params,soap);
            },
            end :  function(){
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
 
                // stats.sendSACFRequest(service.Name,cmd);
                // log.logDetail.addOutput(req,service.Name,myMethod+"_"+cmd,constants.REQUEST,params,soap);
            },
            // error : function(response){log.addErrorSummary(req,service.Name,myMethod+"_"+cmd,response.resultCode,response.resultDescription);}
        };


        var result = await asyncRequest(params,objectData,funStats);

        // return checkResponse(result,funStats);
        return result;
    }
    catch(err) {
        log.log(err);

        var result = {
            response : constants.RESPONSECONN.MESSAGE.ERROR
        };
        return result;

    }
};

connection.requestJsonToD01 = async function (req,obj,cmd,myMethod,filter) {
    try {
    
        log.log("Connect to D01")

        if(myMethod === constants.METHOD.POST)
            obj.dateCreate = moment().format("YYYY-MM-DDTHH:mm:ss+0700");

        var service = cfg.service.D01;    
        var retry = service[myMethod+"_"+cmd+"_Retry"];
        if(!retry)                
            retry = cfg.Default_Retry;

        var objectData = {
            maxRetry : retry,
            curRetry : 1
        }

        // JSON.stringify(json)
        var params = {
            url                 : service[myMethod+"_"+cmd+"_URL"],
            body                : obj,
            method              : myMethod,
            timeout             : service[myMethod+"_"+cmd+"_Timeout"]*1000
72409a48   sumatek   update log 
92
93
 
        }
c4a567d0   sumatek   merge 
94
 
        log.log("requestData : "+JSON.stringify(params))
dd6ce15e   sumatek   add customer 
95
b5fbb064   Nattapon Wongpaet   update log debug 
96
 
        var funStats = {
c4a567d0   sumatek   merge 
97
 
            start : function(){
60cef8c8   sumatek   update timeout 
98
 
                stats.sendRestRequest(service.Name,myMethod,cmd);
72409a48   sumatek   update log 
99
100
 
                log.logDetail.addOutput(req,service.Name,myMethod+"_"+cmd,constants.REQUEST,params,obj);
            },
60cef8c8   sumatek   update timeout 
101
 
            end : function(resultObj){
c4a567d0   sumatek   merge 
102
103
 

                var returnData = {};
e2039477   Nattapon Wongpaet   update log 
104
c4a567d0   sumatek   merge 
105
106
107
108
 
                if(resultObj.err)
                {
                    //connect err => retry
                    var response = {};
50ad7d6d   Nattapon Wongpaet   update get vizcar... 
109
 
                    if(resultObj.err.code == constants.RESPONSECONN.STATS.ETIMEDOUT){
c4a567d0   sumatek   merge 
110
 
                        response = constants.RESPONSECONN.MESSAGE.ETIMEDOUT;
dd6ce15e   sumatek   add customer 
111
 
                    } else if(resultObj.err.code == constants.RESPONSECONN.STATS.ECONNREFUSED){
50ad7d6d   Nattapon Wongpaet   update get vizcar... 
112
 
                        response = constants.RESPONSECONN.MESSAGE.ECONNREFUSED;
9d8ce483   Nattapon Wongpaet   update url put 
113
 
                    } else if(resultObj.err.code == constants.RESPONSECONN.STATS.ESOCKETTIMEDOUT){
c4a567d0   sumatek   merge 
114
115
116
 
                        response = constants.RESPONSECONN.MESSAGE.ESOCKETTIMEDOUT;
                    }
60cef8c8   sumatek   update timeout 
117
 
                    stats.receiveRestResponse(service.Name,myMethod,cmd,constants.ERROR);
afef30b0   Nattapon Wongpaet   fix bug detail lo... 
118
119
120
 
                    log.logDetail.addInput(req,service.Name,myMethod+"_"+cmd,constants.RESPONSE,resultObj,response);
                    log.addErrorSummary(req,service.Name,myMethod+"_"+cmd,response.resultCode,response.resultDescription);
c4a567d0   sumatek   merge 
121
122
123
124
 
                    returnData.retry = true;
                }else
                {
                    if(!resultObj.response)
60cef8c8   sumatek   update timeout 
125
 
                    {
c4a567d0   sumatek   merge 
126
127
128
129
 
                        //no response data => retry
                        var response = constants.RESPONSERESULT.ERROR;
                        stats.receiveBadRestResponse(service.Name,myMethod,cmd);                    
                        log.logDetail.addInput(req,service.Name,myMethod+"_"+cmd,constants.RESPONSE,resultObj,response);
dd6ce15e   sumatek   add customer 
130
 
                        log.addErrorSummary(req,service.Name,myMethod+"_"+cmd,response.resultCode,response.resultDescription);
c4a567d0   sumatek   merge 
131
132
133
134
135
136
137
 

                        returnData.retry = true;
                    }else
                    {
                        try
                        {
                            var result = JSON.parse(resultObj.body);
b5fbb064   Nattapon Wongpaet   update log debug 
138
c4a567d0   sumatek   merge 
139
 
                            log.log('ResponseData : ' + resultObj.body);
60cef8c8   sumatek   update timeout 
140
c4a567d0   sumatek   merge 
141
 
                            if(!result.resultCode || !result.resultDescription)
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
 
                            {
                                //Missing resultCode or resultDescription => retry
                                log.log("Missing resultCode or resultDescription");
                                var response = result;
                                stats.receiveBadRestResponse(service.Name,myMethod,cmd);                    
                                log.logDetail.addInput(req,service.Name,myMethod+"_"+cmd,constants.RESPONSE,resultObj,response);
                                log.addErrorSummary(req,service.Name,myMethod+"_"+cmd,response.resultCode,response.resultDescription);

                                returnData.retry = true;
                                returnData.response = response;
                                returnData.err =  constants.RESPONSERESULT.MISSING_INVALID.developerMessage;
                            
                            }else
                            {
                                //check normal
                                var response = result;
                                log.logDetail.addInput(req,service.Name,myMethod+"_"+cmd,constants.RESPONSE,resultObj,result);
                                if(result.resultCode.startsWith("2"))
                                {
                                    if(myMethod == constants.METHOD.GET){
                                        if(result.resultData && result.resultData.length>0)
                                        {
                                            stats.receiveRestResponse(service.Name,myMethod,cmd,constants.SUCCESS);
                                            log.addSuccessSummary(req,service.Name,myMethod+"_"+cmd,result.resultCode,constants.SUCCESS);
                                        }else
80e43dc0   sumatek   update soap connect 
167
168
 
                                        {
                                            stats.receiveRestResponse(service.Name,myMethod,cmd,constants.RESPONSERESULT.DATA_NOT_FOUND.developerMessage);
72409a48   sumatek   update log 
169
170
171
172
173
174
175
176
177
178
179
 
                                            log.addErrorSummary(req,service.Name,myMethod+"_"+cmd,constants.RESPONSERESULT.DATA_NOT_FOUND.resultCode,constants.RESPONSERESULT.DATA_NOT_FOUND.developerMessage);
                                        }
                                    } else {
                                        stats.receiveRestResponse(service.Name,myMethod,cmd,constants.SUCCESS);
                                        log.addSuccessSummary(req,service.Name,myMethod+"_"+cmd,result.resultCode,constants.SUCCESS);
                                    }

                                    returnData.retry = false;
                                    returnData.response = response;
                                    // returnData.err =  response.resultDescription;
                                } else if(result.resultCode.startsWith("404")){
80e43dc0   sumatek   update soap connect 
180
181
 
                                    stats.receiveRestResponse(service.Name,myMethod,cmd,constants.RESPONSERESULT.DATA_NOT_FOUND.developerMessage);
                                    log.addErrorSummary(req,service.Name,myMethod+"_"+cmd,result.resultCode,result.developerMessage);
72409a48   sumatek   update log 
182
183
184
185
186
 

                                    returnData.retry = false;
                                    returnData.response = response;
                                    // returnData.err =  response.resultDescription;
                                } else if(result.resultCode.startsWith("5")){
887b2ec5   Nattapon Wongpaet   update put customer 
187
188
 
                                    stats.receiveRestResponse(service.Name,myMethod,cmd,constants.ERROR);
                                    log.addErrorSummary(req,service.Name,myMethod+"_"+cmd,result.resultCode,result.developerMessage);
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
 
                                    //retry

                                    returnData.retry = true;
                                    returnData.response = response;
                                    // returnData.err =  response.resultDescription;
                                } else {
                                    stats.receiveRestResponse(service.Name,myMethod,cmd,constants.ERROR);
                                    log.addErrorSummary(req,service.Name,myMethod+"_"+cmd,result.resultCode,result.developerMessage);
                                    //retry
                                    
                                    returnData.retry = true;
                                    returnData.response = response;
                                    // returnData.err =  response.resultDescription;
                                }
                            }
                        }catch(err) {

                            // returnData.response = constants.RESPONSERESULT.ERROR;
                            returnData.err =  constants.RESPONSERESULT.ERROR;
                            returnData.retry = true;
887b2ec5   Nattapon Wongpaet   update put customer 
210
211
212
213
214
215
216
217
218
219
220
 
                        }

                    }
                }

                return returnData;

            }
        };
72409a48   sumatek   update log 
221
222
 

        var result = {};
72409a48   sumatek   update log 
223
224
225
226
 
        result.response = {};
        var resultData = [];        

        if(params.method == constants.METHOD.GET)
887b2ec5   Nattapon Wongpaet   update put customer 
227
 
        {
72409a48   sumatek   update log 
228
229
230
231
232
233
 
            if(filter && filter == "or"){
                var genUrl = getOrUrl(params);
            }
            else{
                var genUrl = getUrl(params,service["searchRecordLimit"]);   
            }
887b2ec5   Nattapon Wongpaet   update put customer 
234
72409a48   sumatek   update log 
235
236
237
238
239
240
241
 
            if(genUrl.length > 1)
            {
                console.log("multi Send");
                var multiSend = [];
                for(var i=0;i<genUrl.length;i++)
                    multiSend.push({url:genUrl[i],method:params.method});
887b2ec5   Nattapon Wongpaet   update put customer 
242
 
                var parallelRes = await parallelRequest(multiSend,objectData,funStats);
72409a48   sumatek   update log 
243
244
245
246
247
248
249
 

                var dataRes = {};
                for(var i=0;i<multiSend.length;i++)
                {
                    // console.log("start loop");
                    var loopRes = parallelRes[i];
887b2ec5   Nattapon Wongpaet   update put customer 
250
 
                    if(loopRes.response)
72409a48   sumatek   update log 
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
 
                    {
                        // var data = JSON.parse(loopRes.response);
                        var data = loopRes.response;
                        dataRes[i] = {};

                        if(!data.resultCode)
                            dataRes[i].err = "Miss resultCode";

                        if(!data.resultDescription)
                            dataRes[i].err = "Miss resultDescription"

                        
                           
                        dataRes[i].data = data.resultData;
                        // console.log(dataRes[i].data);
c4a567d0   sumatek   merge 
267
 
                    }
a55a3d02   Nattapon Wongpaet   update post custo... 
268
c4a567d0   sumatek   merge 
269
 
                }
3cac9636   Nattapon Wongpaet   update post customer 
270
c4a567d0   sumatek   merge 
271
272
 
                for (var i = 0; i < multiSend.length; i++) {
fbd30c50   sumatek   update fix bug ur... 
273
 
                    resultData = resultData.concat(dataRes[i].data);
9354f8c5   sumatek   fix bug 
274
 
                    if(dataRes[i].err)
c4a567d0   sumatek   merge 
275
276
 
                        result.err = dataRes[i].err;
b77690fa   Nattapon Wongpaet   update post custo... 
277
278
279
280
281
282
283
 
                        
                }

                if(!result.err)
                {
                    result.response = constants.RESPONSECONN.MESSAGE.SUCCESS;
                    result.response.resultData = resultData;
c4a567d0   sumatek   merge 
284
 
                    // result.response.resultCode = "20000";
a1f044d9   sumatek   update parallel 
285
 
                    // result.response.developerMessage = "Success";
c4a567d0   sumatek   merge 
286
287
288
289
290
291
292
293
294
 
                }

            }else
            {
                // console.log("single Send");
                params.url = genUrl[0];
                delete params.body;

                result = await asyncRequest(params,objectData,funStats);
a1f044d9   sumatek   update parallel 
295
 
                // var resultRes = await asyncRequest(params,objectData,funStats);
c4a567d0   sumatek   merge 
296
297
298
299
300
 

                // // console.log(resultRes);
                // if(resultRes.response)
                // {
                //     var data = JSON.parse(resultRes.response.body);
887b2ec5   Nattapon Wongpaet   update put customer 
301
302
 
                //     result.response = data;
c4a567d0   sumatek   merge 
303
 
                // } else {
a1f044d9   sumatek   update parallel 
304
 
                //     result = resultRes;
c4a567d0   sumatek   merge 
305
306
 
                // }
            }
a1f044d9   sumatek   update parallel 
307
c4a567d0   sumatek   merge 
308
309
 
            
        } else if(params.method == constants.METHOD.POST) {
a1f044d9   sumatek   update parallel 
310
c4a567d0   sumatek   merge 
311
 
            params.body = JSON.stringify(params.body);
fbd30c50   sumatek   update fix bug ur... 
312
 
            result = await asyncRequest(params,objectData,funStats);
c4a567d0   sumatek   merge 
313
 
            // var resultRes = await asyncRequest(params,objectData,funStats);
fbd30c50   sumatek   update fix bug ur... 
314
b77690fa   Nattapon Wongpaet   update post custo... 
315
 
            // if(resultRes.response){
c4a567d0   sumatek   merge 
316
317
 
            //     result.response = JSON.parse(resultRes.body);
            // } else {
a1f044d9   sumatek   update parallel 
318
319
 
            //     result = resultRes;
            // }
c4a567d0   sumatek   merge 
320
321
 
        } else if(params.method == constants.METHOD.PUT) {
fbd30c50   sumatek   update fix bug ur... 
322
 
            params.url = getUrlFilter(params.url,filter);
c4a567d0   sumatek   merge 
323
324
 

            params.body = JSON.stringify(params.body);
fbd30c50   sumatek   update fix bug ur... 
325
326
c4a567d0   sumatek   merge 
327
 
            result = await asyncRequest(params,objectData,funStats);
a1f044d9   sumatek   update parallel 
328
c4a567d0   sumatek   merge 
329
330
331
 
            // var resultRes = await asyncRequest(params,objectData,funStats);
            
            // if(resultRes.response){
fbd30c50   sumatek   update fix bug ur... 
332
 
            //     result.response = JSON.parse(resultRes.body);
c4a567d0   sumatek   merge 
333
334
335
 
            // } else {
            //     result = resultRes;
            // }
9354f8c5   sumatek   fix bug 
336
 
        }
c4a567d0   sumatek   merge 
337
a1f044d9   sumatek   update parallel 
338
 
        console.log(result);
c4a567d0   sumatek   merge 
339
340
341
342
 
        
        // if(result.response)
        // {
        //     if(!result.response.resultCode){
72409a48   sumatek   update log 
343
344
 
        //         result.err = "Missing resultCode";
        //     } else if(!result.response.resultDescription){
c4a567d0   sumatek   merge 
345
 
        //         result.err = "Missing resultDescription";
72409a48   sumatek   update log 
346
347
348
349
350
 
        //     }
        // }

        // return checkResponse(result,funStats);
c4a567d0   sumatek   merge 
351
 
        return result;
72409a48   sumatek   update log 
352
353
354
 

    }
    catch(err) {
a1f044d9   sumatek   update parallel 
355
356
357
 
        log.log(err);

        var result = {
1f123eb1   Nattapon Wongpaet   update post membe... 
358
 
            response : constants.RESPONSECONN.MESSAGE.ERROR
afef30b0   Nattapon Wongpaet   fix bug detail lo... 
359
 
        };
1f123eb1   Nattapon Wongpaet   update post membe... 
360
 
        return result;
72409a48   sumatek   update log 
361
362
363
364
365
366
367
368
 

    }
};



async function parallelRequest(multiParams,objectData,funStat)
{
1f123eb1   Nattapon Wongpaet   update post membe... 
369
370
 
   
    var promises = [];
9d8ce483   Nattapon Wongpaet   update url put 
371
1f123eb1   Nattapon Wongpaet   update post membe... 
372
 
    for(var i=0;i<multiParams.length;i++)
c4a567d0   sumatek   merge 
373
 
        promises.push(asyncRequest (multiParams[i],objectData,funStat));
a1f044d9   sumatek   update parallel 
374
72409a48   sumatek   update log 
375
376
377
378
 
    var res = await Promise.all(promises);
    // for(var i=0;i<res.length;i++)
    // {
    //     if(!res[i].err)
9d8ce483   Nattapon Wongpaet   update url put 
379
 
    //     {
72409a48   sumatek   update log 
380
381
382
383
384
 
    //         console.log(res[i].body);
    //     }
    //     // stats.receiveResponse(node,cmd,"Success");
a1f044d9   sumatek   update parallel 
385
 
    // }
9354f8c5   sumatek   fix bug 
386
f9d80b22   Nattapon Wongpaet   update header viz... 
387
a1f044d9   sumatek   update parallel 
388
72409a48   sumatek   update log 
389
390
391
392
393
394
395
396
 
    return res;
}

function asyncRequest (params = {},objectData,funStat) {

    // console.log(objectData);
3cac9636   Nattapon Wongpaet   update post customer 
397
 
    // console.log("Start : "+new Date().toISOString());
72409a48   sumatek   update log 
398
399
400
 
    return new Promise((resolve, reject) => {
        request(params, function (error, response, body) {
5198016b   sumatek   update build message 
401
 
            funStat.start();
9354f8c5   sumatek   fix bug 
402
 
            log.log("URL : "+params.url);
c4a567d0   sumatek   merge 
403
404
 

            if (error) {
a1f044d9   sumatek   update parallel 
405
c4a567d0   sumatek   merge 
406
407
408
409
 
                // if(objectData.maxRetry == objectData.curRetry-1)
                // {
                    
                //     resolve({
3cac9636   Nattapon Wongpaet   update post customer 
410
 
                //         'body'  : body,
c4a567d0   sumatek   merge 
411
 
                //         'err'   : error
dd6ce15e   sumatek   add customer 
412
413
 
                //     });
                // }else
a1f044d9   sumatek   update parallel 
414
 
                // {
479b9d98   sumatek   update use constants 
415
 
                //     var responseObj = {
60cef8c8   sumatek   update timeout 
416
 
                //         'body'  : body,
a1f044d9   sumatek   update parallel 
417
 
                //         'err'   : error
787e24ad   sumatek   update async func... 
418
419
420
 
                //     };
a1f044d9   sumatek   update parallel 
421
 
                //     if(funStat.end(responseObj))
60cef8c8   sumatek   update timeout 
422
 
                //     {
787e24ad   sumatek   update async func... 
423
424
 
                //         objectData.curRetry++; 
                //         resolve(asyncRequest(params,objectData,funStat));
60cef8c8   sumatek   update timeout 
425
426
427
 
                //     }
                    
                // }
fbd30c50   sumatek   update fix bug ur... 
428
429
430
431
432
 
                
                
               
            } else {
a1f044d9   sumatek   update parallel 
433
60cef8c8   sumatek   update timeout 
434
 
                // var responseObj = {
787e24ad   sumatek   update async func... 
435
 
                //     'body'  : body,
fbd30c50   sumatek   update fix bug ur... 
436
 
                //     'response'   : response
787e24ad   sumatek   update async func... 
437
438
 
                // };
                // resolve(funStat.end(responseObj));
a1f044d9   sumatek   update parallel 
439
440
 
            }
60cef8c8   sumatek   update timeout 
441
442
443
 
            var responseObj = {
                'body'  : body,
                'response'   : response,
fbd30c50   sumatek   update fix bug ur... 
444
 
                'err'   : error
dd6ce15e   sumatek   add customer 
445
 
            };
787e24ad   sumatek   update async func... 
446
dd6ce15e   sumatek   add customer 
447
448
449
 
            var result = funStat.end(responseObj);

            if(result.retry)
fbd30c50   sumatek   update fix bug ur... 
450
451
452
 
            {
                if(objectData.maxRetry == objectData.curRetry-1)
                    resolve(result);
dd6ce15e   sumatek   add customer 
453
 
                else
60cef8c8   sumatek   update timeout 
454
 
                {
72409a48   sumatek   update log 
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
 
                    objectData.curRetry++;
                    resolve(asyncRequest(params,objectData,funStat));
                }
                    
            }else
                resolve(result);
            
        });
    });
};

function getUrlFilter(url,filter){
    var returnData = [];
    var myfilter = ""

    for(var i in filter){
        myfilter += "("+i+"="+filter[i]+")"
    }

    var myUrl = url+"?filter=(&"+myfilter+")"
    
    // var myUrl = url+"?filter=("+filter.base+")";
787e24ad   sumatek   update async func... 
477
60cef8c8   sumatek   update timeout 
478
479
 
    returnData.push(myUrl);
72409a48   sumatek   update log 
480
481
482
483
484
485
486
487
 
    return myUrl;
}

function getUrl(params,limit)
{
    var returnData = [];
    var url = params.url;
    var fields = "";
dd6ce15e   sumatek   add customer 
488
 
    var filter = {
72409a48   sumatek   update log 
489
490
491
492
493
494
 
        base : "",
        multi : []
    };
    
    
    // params.body = {};
887b2ec5   Nattapon Wongpaet   update put customer 
495
 
    // params.body.a = "aaa";
72409a48   sumatek   update log 
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
 
    // params.body.b = "bbb";
    // params.body.papa = [];
    // params.body.papa.push("1");
    // params.body.papa.push("2");
    // params.body.commandId = [];
    // params.body.commandId.push("1");
    // params.body.commandId.push("2");
    // params.body.commandId.push("3");
    // params.body.commandId.push("4");
    // params.body.commandId.push("5");
    // params.body.commandId.push("6");
    // params.body.commandId.push("7");
    // params.body.commandId.push("8");    
    // params.body.c = "ccc";
    // params.body.fields = "a,b,c,d";
dd6ce15e   sumatek   add customer 
511
512
513
514
 
    // params.body.customerId = ["1b6a768e52e9a1e11518a1c6","1b6a768e52e9a1e11518a1c6","1b6a768e52e9a1e11518a1c6","1b6a768e52e9a1e11518a1c6","1b6a768e52e9a1e11518a1c6","1b6a768e52e9a1e11518a1c6","1b6a768e52e9a1e11518a1c6","1b6a768e52e9a1e11518a1c6","1b6a768e52e9a1e11518a1c6","1b6a768e52e9a1e11518a1c6","1b6a768e52e9a1e11518a1c6","1b6a768e52e9a1e11518a1c6","1b6a768e52e9a1e11518a1c6","1b6a768e52e9a1e11518a1c6","1b6a768e52e9a1e11518a1c6","1b6a768e52e9a1e11518a1c6","1b6a768e52e9a1e11518a1c6","1b6a768e52e9a1e11518a1c6","1b6a768e52e9a1e11518a1c6","1b6a768e52e9a1e11518a1c6","1b6a768e52e9a1e11518a1c6"];
    // limit = 100;
    // console.log(params.body);  
    if(params.body)
9d8ce483   Nattapon Wongpaet   update url put 
515
516
517
518
519
 
    {
        var first = true;
        for (key in params.body) {

            if(key == "fields")
887b2ec5   Nattapon Wongpaet   update put customer 
520
 
                fields = getFields(params.body.fields,first);
9d8ce483   Nattapon Wongpaet   update url put 
521
522
 
            else
                filter = getFilter(filter,key,params.body[key]);
887b2ec5   Nattapon Wongpaet   update put customer 
523
9d8ce483   Nattapon Wongpaet   update url put 
524
525
526
527
 
            first = false;
        }

        if(first)
9d8ce483   Nattapon Wongpaet   update url put 
528
529
530
531
 
            fields += "?limit="+limit;
        else
            fields += "&limit="+limit;
5198016b   sumatek   update build message 
532
 
    }
81e85e64   sumatek   update customer 
533
a1f044d9   sumatek   update parallel 
534
 
    if(filter.multi.length > 0)
81e85e64   sumatek   update customer 
535
536
 
    {
        //have multi
5198016b   sumatek   update build message 
537
538
539
540
541
 

        var careData = filter.multi[0];
        // console.log(freeSpace);

        for(var i=0;i<filter.multi.length;i++)
d46c5802   sumatek   up date for conne... 
542
 
        {
03f3be38   Nattapon Wongpaet   fix bugs 
543
 
            if(filter.multi[i].length > careData.length)
84646faa   sumatek   update connection 
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
 
            {
                filter.base = filter.base+"(|"+careData.data+")";
                careData = filter.multi[i];
                
            }
        }


        var myUrl = url+"?filter=:"+filter.base+":"+fields;
        var freeSpace = cfg.Uri_length - myUrl.length;
        

        var arr = careData.data.split(")(");
            
        for(var j=0;j<arr.length;j++)
        {
03f3be38   Nattapon Wongpaet   fix bugs 
560
561
562
 
            if(j==0)
                arr[j] = arr[j].substring(1);
            if(j==arr.length-1)
81e85e64   sumatek   update customer 
563
564
565
566
567
568
569
570
 
                arr[j] = arr[j].substring(0,arr[j].length-1);

            arr[j] = "("+arr[j]+")";
                // returnData.push(url+"?filter=("+newBasefilter+"(|"+arr[j]+")"+fields);
        }

        returnData = arrayUrl(returnData,url,filter.base,fields,freeSpace,arr);
79d9e534   Nattapon Wongpaet   update post customer 
571
81e85e64   sumatek   update customer 
572
573
574
 

    }else
    {
5198016b   sumatek   update build message 
575
576
 
        var myUrl = url+"?filter=("+filter.base+")"+fields;
        returnData.push(myUrl);
79d9e534   Nattapon Wongpaet   update post customer 
577
 
    }
5198016b   sumatek   update build message 
578
79d9e534   Nattapon Wongpaet   update post customer 
579
 
    // console.log(url);
81e85e64   sumatek   update customer 
580
 
    // console.log(filter);
81e85e64   sumatek   update customer 
581
582
 
    // console.log(fields);
5198016b   sumatek   update build message 
583
 
    // for(var i=0;i<returnData.length;i++)
a1f044d9   sumatek   update parallel 
584
 
    //     log.log("URL "+[i+1]+" : "+returnData[i]);
5198016b   sumatek   update build message 
585
a1f044d9   sumatek   update parallel 
586
 
    return returnData;
5198016b   sumatek   update build message 
587
588
 
}
a1f044d9   sumatek   update parallel 
589
 
function getOrUrl(params){
5198016b   sumatek   update build message 
590
 
    var returnData = [];
a1f044d9   sumatek   update parallel 
591
 
    var url = params.url;
5198016b   sumatek   update build message 
592
593
594
595
596
597
 
    var filter = "";

    for(var i in params.body){
        filter = filter + "(" +i+ "=" +params.body[i]+ ")"
    }
a1f044d9   sumatek   update parallel 
598
 
    url = url + "filter(|" + filter + ")";
5198016b   sumatek   update build message 
599
600
 

    returnData.push(url);
fbd30c50   sumatek   update fix bug ur... 
601
5198016b   sumatek   update build message 
602
 
    return returnData;
a1f044d9   sumatek   update parallel 
603
 
}
a1f044d9   sumatek   update parallel 
604
5198016b   sumatek   update build message 
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
 
function getFields(fields,first)
{
    var returnData;
    var prefix;
    if(first)
        prefix = "?fields=";
    else
        prefix = "&fields=";

    returnData = prefix+fields;

    return returnData;
}

function getFilter(filter,key,data)
{
   
    // console.log(key);
    // console.log(newfilter);
    if(!Array.isArray(data))
    {
81e85e64   sumatek   update customer 
627
628
 
        // var newfilter = {
        //     data : "("+key+"="+data+")",
5198016b   sumatek   update build message 
629
 
        //     type : "single",
81e85e64   sumatek   update customer 
630
631
 
        //     length : ("("+key+"="+data+")").length
        // };
fbd30c50   sumatek   update fix bug ur... 
632
633
 

        if(filter.base != "")
5198016b   sumatek   update build message 
634
 
            filter.base = filter.base+"("+key+"="+data+")";
a1f044d9   sumatek   update parallel 
635
 
        else
81e85e64   sumatek   update customer 
636
637
 
            filter.base = "&"+filter.base+"("+key+"="+data+")";
    }else
b77690fa   Nattapon Wongpaet   update post custo... 
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
 
    {
        var line = "";
        for(var i=0;i<data.length;i++)
        {
            line += "("+key+"="+data[i]+")";
        }

        var newfilter = {
            data : line,
            length : line.length
        };
    }

    if(newfilter)
        filter.multi.push(newfilter);
    return filter;
81e85e64   sumatek   update customer 
654
655
656
657
658
659
660
661
662
663
664
665
666
 
}

function arrayUrl(arrUrl,url,filter,fields,freeSpace,arrData)
{
    var loopUrl = "";
    var loopSpace = freeSpace;
    for(var i=0;i<arrData.length;i++)
    {
        if(loopSpace > (arrData[i].length+3))
        {
            loopUrl = loopUrl + arrData[i];
            loopSpace = loopSpace - arrData[i].length;
        }else
dd6ce15e   sumatek   add customer 
667
 
        {
79d9e534   Nattapon Wongpaet   update post customer 
668
 
            if(loopUrl != "")
81e85e64   sumatek   update customer 
669
 
            {
5198016b   sumatek   update build message 
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
 
                arrUrl.push(url+"?filter=("+filter+"(|"+loopUrl+"))"+fields);

                loopUrl = arrData[i];
                loopSpace = freeSpace - arrData[i].length;
            }
            
        }

    }

    if(loopUrl != "")
        arrUrl.push(url+"?filter=("+filter+"(|"+loopUrl+"))"+fields);
    return arrUrl;
}

// function checkResponse(result,funStats)
d46c5802   sumatek   up date for conne... 
686
687
 
// {
//     if(result.err)
5198016b   sumatek   update build message 
688
689
690
691
692
693
694
695
696
697
 
//     {
//         log.log("Final Response : "+result.err,'error');
//         if(result.err.code == constants.RESPONSECONN.STATS.ETIMEDOUT){
//             result.response = constants.RESPONSECONN.MESSAGE.ETIMEDOUT;
//         } else if(result.err.code == constants.RESPONSECONN.STATS.ECONNREFUSED){
//             result.response = constants.RESPONSECONN.MESSAGE.ECONNREFUSED;
//         } else if(result.err.code == constants.RESPONSECONN.STATS.ESOCKETTIMEDOUT){
//             result.response = constants.RESPONSECONN.MESSAGE.ESOCKETTIMEDOUT;
//         } else {
//             if(result.err.resultDescription && result.err.resultDescription.indexOf(constants.RESPONSECONN.STATS.MISSING) != -1){
d46c5802   sumatek   up date for conne... 
698
 
//                 result.response.resultCode = constants.RESPONSERESULT.MISSING_INVALID.resultCode;
5198016b   sumatek   update build message 
699
700
701
702
703
704
705
706
707
708
709
710
711
 
//                 result.response.resultDescription = result.err;
//             } else {
//                 result.response = constants.RESPONSECONN.MESSAGE.ERROR;
//             }
//         }
//         funStats.error(result.response)
//     }else
//        log.log("Final Response : "+JSON.stringify(result));

//     return result;
// }

module.exports = connection;
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