Blame view

ais-structure/src/modules/helper/connection.js 7.07 KB
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