Merge branch 'master' of http://git.sourcecode.co.th/nattaponw/spw

Nattapon Wongpaet
2 parents d9ef9566 60cef8c8
Showing 1 changed file with 89 additions and 25 deletions Show diff stats
ais-structure/src/modules/helper/connection.js
@@ -10,17 +10,36 @@ var connection = [];
 connection.requestSoapToSACF = async function (soap,cmd,myMethod) {
+    var service = cfg.service.SACF;
+    var retry = service[myMethod+"_"+cmd+"_Retry"];    
+
     var params = {
-        url                 : cfg.service.SACF[myMethod+"_"+cmd+"_URL"],
+        url                 : service[myMethod+"_"+cmd+"_URL"],
         body                : messageSOAP.objectToSOAP(soap,cmd),
         method              : myMethod,
         timeout             : cfg.service.SACF[myMethod+"_"+cmd+"_Timeout"]*1000
     }
-    stats.sendSACFRequest(cfg.service.SACF.Name,cmd)
-    log.logDetail.addOutput(cfg.service.SACF.Name,cmd,"Request",params,soap);
+    if(!retry)                
+        retry = cfg.Default_Retry;
+
+    var objectData = {
+        maxRetry : retry,
+        curRetry : 1
+    }
+    
+    var funStats = function(){
+        stats.sendSACFRequest(service.Name,cmd);
+        log.logDetail.addOutput(service.Name,cmd,"Request",params,soap);
+    };
+    
+    var funStats = {
+        start : funStats,
+        error : function(response){log.addErrorSummary(service.Name,cmd,response);}
+    };
+
-    var result = await asyncRequest(params,cmd,cfg.service.SACF.Name);
+    var result = await asyncRequest(params,objectData,funStats);
     if(result.err)
     {
@@ -48,7 +67,16 @@ connection.requestSoapToSACF = async function (soap,cmd,myMethod) {
 connection.requestJsonToD01 = async function (obj,cmd,myMethod) {
-    var service = cfg.service.D01;
+    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"],
@@ -57,13 +85,23 @@ connection.requestJsonToD01 = async function (obj,cmd,myMethod) {
         timeout             : service[myMethod+"_"+cmd+"_Timeout"]*1000
     }
-    log.logDetail.addOutput(service.Name,cmd,"Request",params,params.body); 
+    var funStats = function(){
+        stats.sendRestRequest(service.Name,myMethod,cmd);
+        log.logDetail.addOutput(service.Name,cmd,"Request",params,obj);
+    };
+    
+    var funStats = {
+        start : funStats,
+        error : function(response){log.addErrorSummary(service.Name,cmd,response);}
+    };
+
+     
     var result = {};
     result.response = {};
     result.response.resultData = [];
-    stats.sendRestRequest(service.Name,myMethod,cmd);
+    
     if(params.method == "GET")
     {
@@ -76,7 +114,7 @@ connection.requestJsonToD01 = async function (obj,cmd,myMethod) {
             for(var i=0;i<genUrl.length;i++)
                 multiSend.push({url:genUrl[i],method:params.method});
-            var parallelRes = await parallelRequest(multiSend,cmd,cfg.service.D01.Name); 
+            var parallelRes = await parallelRequest(multiSend,objectData,funStats); 
             var dataRes = {};
             for(var i=0;i<multiSend.length;i++)
@@ -122,7 +160,7 @@ connection.requestJsonToD01 = async function (obj,cmd,myMethod) {
             params.url = genUrl[0];
             delete params.body;
-            var resultRes = await asyncRequest(params,cmd,service.Name);
+            var resultRes = await asyncRequest(params,objectData,funStats);
             // console.log(result);
             if(resultRes.response)
@@ -138,9 +176,10 @@ connection.requestJsonToD01 = async function (obj,cmd,myMethod) {
     {
         params.body = JSON.stringify(params.body);
-        var resultRes = await asyncRequest(params,cmd,service.Name);
+        var resultRes = await asyncRequest(params,objectData,funStats);
-        result.response = JSON.parse(resultRes.body);
+        if(resultRes.response)
+            result.response = JSON.parse(resultRes.body);
     }
@@ -193,40 +232,65 @@ connection.requestJsonToD01 = async function (obj,cmd,myMethod) {
 };
-async function parallelRequest(multiParams,cmd,node)
+async function parallelRequest(multiParams,objectData,funStat)
 {
     var promises = [];
     for(var i=0;i<multiParams.length;i++)
-        promises.push(asyncRequest (multiParams[i],cmd,node));
+        promises.push(asyncRequest (multiParams[i],objectData,funStat));
     var res = await Promise.all(promises);
-    for(var i=0;i<res.length;i++)
-    {
-        if(!res[i].err)
-            stats.receiveResponse(node,cmd,"Success");
+    // for(var i=0;i<res.length;i++)
+    // {
+    //     if(!res[i].err)
+    //         stats.receiveResponse(node,cmd,"Success");
-    }
+    // }
     return res;
 }
-function asyncRequest (params = {},cmd,node) {
+function asyncRequest (params = {},objectData,funStat) {
+
+    // console.log(objectData);  
+    funStat.start();
     // console.log("Start : "+new Date().toISOString());
     return new Promise((resolve, reject) => {
         request(params, function (error, response, body) {
             if (error) {
+
+                if( objectData.maxRetry == objectData.curRetry-1)
+                {
+                    resolve({
+                        'body'  : body,
+                        'err'   : error
+                    });
+                }else
+                {
+                    var errRes = {};
+                    if(error.code == 'ETIMEDOUT'){
+                        errRes.resultCode = "50003";
+                        errRes.resultDescription = "Timeout";
+                    } else if(error.code == 'ECONNREFUSED'){
+                        errRes.resultCode = "50002";
+                        errRes.resultDescription = "Reject";
+                    } else {
+                        errRes.resultCode = "50000";
+                        errRes.resultDescription = "System error";
+                    }
+
+                    // console.log("retry "+objectData.curRetry);
+                    funStat.error(errRes);                    
+                    objectData.curRetry++; 
+                    resolve(asyncRequest(params,objectData,funStat));
+                }
-                // console.log("End : "+new Date().toISOString());
-                console.log(error.code);
-                resolve({
-                    'body'  : body,
-                    'err'   : error
-                });
+                
+               
             } else {
                 // stats.receiveResponse(node,cmd,"Success");