Nattapon Wongpaet / SPW

Download as
Browse Code ยป

Commit 1e90212475974126f478af191bae1f5d61d83ec9

Authored by Nattapon Wongpaet
2 parents b7bb79ef 80e43dc0
Exists in master and in 1 other branch dev

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

# Conflicts:
#	ais-structure/src/modules/helper/connection.js
Showing 1 changed file with 50 additions and 4 deletions   Show diff stats
ais-structure/src/modules/helper/connection.js
  Diff comments   View file @1e90212
... ... @@ -41,9 +41,53 @@ connection.requestSoapToSACF = async function (req,soap,cmd,myMethod) {
41 41 stats.sendSACFRequest(service.Name,cmd);
42 42 log.logDetail.addOutput(req,service.Name,myMethod+"_"+cmd,constants.REQUEST,params,soap);
43 43 },
44   - end : function(){
45   - // stats.sendSACFRequest(service.Name,cmd);
46   - // log.logDetail.addOutput(req,service.Name,myMethod+"_"+cmd,constants.REQUEST,params,soap);
  44 + end : function(resultObj){
  45 +
  46 + var returnData = {};
  47 +
  48 + if(resultObj.err)
  49 + {
  50 + //connect err => retry
  51 + var response = {};
  52 + if(resultObj.err.code == constants.RESPONSECONN.STATS.ETIMEDOUT){
  53 + response = constants.RESPONSECONN.MESSAGE.ETIMEDOUT;
  54 + } else if(resultObj.err.code == constants.RESPONSECONN.STATS.ECONNREFUSED){
  55 + response = constants.RESPONSECONN.MESSAGE.ECONNREFUSED;
  56 + } else if(resultObj.err.code == constants.RESPONSECONN.STATS.ESOCKETTIMEDOUT){
  57 + response = constants.RESPONSECONN.MESSAGE.ESOCKETTIMEDOUT;
  58 + }
  59 +
  60 + stats.receiveSACFResponse(service.Name,cmd,constants.ERROR);
  61 + log.logDetail.addInput(req,service.Name,myMethod+"_"+cmd,constants.RESPONSE,resultObj,response);
  62 + log.addErrorSummary(req,service.Name,myMethod+"_"+cmd,response.resultCode,response.resultDescription);
  63 +
  64 + returnData.retry = true;
  65 + returnData.response = response;
  66 + returnData.err = constants.RESPONSERESULT.ERROR.developerMessage;
  67 + }else
  68 + {
  69 + if(!resultObj.response)
  70 + {
  71 + //no response data => retry
  72 + var response = constants.RESPONSERESULT.ERROR;
  73 + stats.receiveSACFBadResponse(service.Name,cmd);
  74 + log.logDetail.addInput(req,service.Name,myMethod+"_"+cmd,constants.RESPONSE,resultObj,response);
  75 + log.addErrorSummary(req,service.Name,myMethod+"_"+cmd,response.resultCode,response.resultDescription);
  76 +
  77 + returnData.retry = true;
  78 + returnData.response = response;
  79 + returnData.err = constants.RESPONSERESULT.ERROR.developerMessage;
  80 + }else
  81 + {
  82 + returnData.retry = false;
  83 + returnData.response = resultObj;
  84 +
  85 +
  86 + }
  87 + }
  88 +
  89 + return returnData;
  90 +
47 91 },
48 92 // error : function(response){log.addErrorSummary(req,service.Name,myMethod+"_"+cmd,response.resultCode,response.resultDescription);}
49 93 };
... ... @@ -119,7 +163,8 @@ connection.requestJsonToD01 = async function (req,obj,cmd,myMethod,filter) {
119 163 log.addErrorSummary(req,service.Name,myMethod+"_"+cmd,response.resultCode,response.resultDescription);
120 164  
121 165 returnData.retry = true;
122   - returnData.response = constants.RESPONSECONN.MESSAGE.ERROR;
  166 + returnData.response = response;
  167 + returnData.err = constants.RESPONSERESULT.ERROR.developerMessage;
123 168 }else
124 169 {
125 170 if(!resultObj.response)
... ... @@ -132,6 +177,7 @@ connection.requestJsonToD01 = async function (req,obj,cmd,myMethod,filter) {
132 177  
133 178 returnData.retry = true;
134 179 returnData.response = response;
  180 + returnData.err = constants.RESPONSERESULT.ERROR.developerMessage;
135 181 }else
136 182 {
137 183 try
... ...