diff --git a/ais-structure/src/modules/helper/connection.js b/ais-structure/src/modules/helper/connection.js index f36f433..3224adf 100644 --- a/ais-structure/src/modules/helper/connection.js +++ b/ais-structure/src/modules/helper/connection.js @@ -98,9 +98,7 @@ connection.requestJsonToD01 = async function (req,obj,cmd,myMethod,filter) { var result = {}; result.response = {}; - result.response.resultData = []; - - + var resultData = []; if(params.method == constants.METHOD.GET) { @@ -132,7 +130,9 @@ connection.requestJsonToD01 = async function (req,obj,cmd,myMethod,filter) { dataRes[i].err = "Miss resultDescription" + dataRes[i].data = data.resultData; + // console.log(dataRes[i].data); } @@ -140,19 +140,21 @@ connection.requestJsonToD01 = async function (req,obj,cmd,myMethod,filter) { for (var i = 0; i < multiSend.length; i++) { - result.response.resultData = result.response.resultData.concat(dataRes[i].data); + resultData = resultData.concat(dataRes[i].data); if(dataRes[i].err) result.err = dataRes[i].err; + + } if(!result.err) { result.response = constants.RESPONSECONN.MESSAGE.SUCCESS; + result.response.resultData = resultData; // result.response.resultCode = "20000"; // result.response.developerMessage = "Success"; } - }else { // console.log("single Send"); @@ -237,10 +239,15 @@ async function parallelRequest(multiParams,objectData,funStat) // for(var i=0;i { request(params, function (error, response, body) { + funStat.start(); + log.log("URL : "+params.url); + if (error) { if( objectData.maxRetry == objectData.curRetry-1) @@ -287,6 +297,7 @@ function asyncRequest (params = {},objectData,funStat) { } else { // stats.receiveResponse(node,cmd,"Success"); + log.log("Response : "+body); resolve({ 'body' : body, 'response' : response @@ -326,7 +337,7 @@ function getUrl(params,limit) }; - // params.body = {}; + params.body = {}; // params.body.a = "aaa"; // params.body.b = "bbb"; // params.body.papa = []; @@ -343,7 +354,9 @@ function getUrl(params,limit) // params.body.commandId.push("8"); // params.body.c = "ccc"; // params.body.fields = "a,b,c,d"; - // console.log(params.body); + 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) { var first = true; @@ -382,7 +395,7 @@ function getUrl(params,limit) } - var myUrl = url+"?filter=("+filter.base+")"+fields; + var myUrl = url+"?filter=:"+filter.base+":"+fields; var freeSpace = cfg.Uri_length - myUrl.length; @@ -413,8 +426,8 @@ function getUrl(params,limit) // console.log(filter); // console.log(fields); - for(var i=0;i