Commit 6c93818c by carrieyzzhang

get time out

parent 19c406e4
...@@ -1036,27 +1036,29 @@ public class ComplicatedEventsServiceImpl implements ComplicateEventsService{ ...@@ -1036,27 +1036,29 @@ public class ComplicatedEventsServiceImpl implements ComplicateEventsService{
//group by _cid or group by _campaignid //group by _cid or group by _campaignid
if (groupArray.toString().contains(FIELD_CID) || groupArray.toString().contains(FIELD_CAMPAIGN_ID)) { if (groupArray.toString().contains(FIELD_CID) || groupArray.toString().contains(FIELD_CAMPAIGN_ID)) {
Account account = accountRepository.findOne(accountId); Account account = accountRepository.findOne(accountId);
String url = Constant.trackingUrl + "/api/"+ app.getId() +"/channel/findchannelcamp4io?appkey=" + app.getAppkey() + "&email=" + account.getEmail(); try {
String response = HttpClientUtil.doHttpGetRequest(url, "io"); String url = Constant.trackingUrl + "/api/"+ app.getId() +"/channel/findchannelcamp4io?appkey=" + app.getAppkey() + "&email=" + account.getEmail();
if (!StringUtil.isEmpty(response)) { String response = HttpClientUtil.doHttpGetRequest(url, "io");
try { if (!StringUtil.isEmpty(response)) {
JSONObject ob = JSONObject.fromObject(response);
JSONObject content = ob.getJSONObject("content"); JSONObject ob = JSONObject.fromObject(response);
if (groupArray.toString().contains(FIELD_CID)) { JSONObject content = ob.getJSONObject("content");
JSONObject channelObject = content.getJSONObject("channel"); if (groupArray.toString().contains(FIELD_CID)) {
ObjectMapper mapper = new ObjectMapper(); JSONObject channelObject = content.getJSONObject("channel");
channelMap = mapper.readValue(channelObject.toString(), Map.class); ObjectMapper mapper = new ObjectMapper();
} channelMap = mapper.readValue(channelObject.toString(), Map.class);
if (groupArray.toString().contains(FIELD_CAMPAIGN_ID)) { }
JSONObject campObject = content.getJSONObject("campaign"); if (groupArray.toString().contains(FIELD_CAMPAIGN_ID)) {
ObjectMapper mapper = new ObjectMapper(); JSONObject campObject = content.getJSONObject("campaign");
campaignMap = mapper.readValue(campObject.toString(), Map.class); ObjectMapper mapper = new ObjectMapper();
} campaignMap = mapper.readValue(campObject.toString(), Map.class);
}
} catch (Exception e) {
logger.error("fail to get channel or campaign name");
}
}
} catch (Exception e) {
logger.error("fail to get channel or campaign name");
} }
} }
......
...@@ -24,7 +24,7 @@ public class HttpClientUtil { ...@@ -24,7 +24,7 @@ public class HttpClientUtil {
private static final Log log = LogFactory.getLog(HttpClientUtil.class); private static final Log log = LogFactory.getLog(HttpClientUtil.class);
// 读取超时 // 读取超时
private final static int SOCKET_TIMEOUT = 60000; private final static int SOCKET_TIMEOUT = 10000;
// 连接超时 // 连接超时
private final static int CONNECTION_TIMEOUT = 60000; private final static int CONNECTION_TIMEOUT = 60000;
// 每个HOST的最大连接数量 // 每个HOST的最大连接数量
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment