gfwleak/k18-ntcs-web-ntc
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1.日志使用配置的接口调用工具2.特殊服务新增下拉过长会被遮挡改为无搜索框，页面显示调整

Browse Source
This commit is contained in:
zhanghongqing
2018-08-28 19:47:09 +08:00
parent 2674eedcb7
commit dc3fd4a739
3 changed files with 36 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

45
src/main/java/com/nis/util/httpclient/HttpClientUtil.java
View File

@@ -20,6 +20,10 @@ import java.util.Map.Entry;
import java.util.Set;
import javax.servlet.http.HttpServletRequest;
import javax.ws.rs.client.WebTarget;
import javax.ws.rs.client.Invocation.Builder;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
import org.apache.http.HttpStatus;
import org.apache.http.NameValuePair;
@@ -136,22 +140,36 @@ public class HttpClientUtil {
public static String getMsg(String destUrl, Map<String, Object> params, HttpServletRequest req) {
RequestContext requestContext = new RequestContext(req);
CloseableHttpResponse response = null;
// CloseableHttpResponse response = null;
String result = null;
String url = "";
try {
URIBuilder uriBuilder = new URIBuilder(destUrl);
for (String param : params.keySet()) {
uriBuilder.addParameter(param, params.get(param).toString());
}
HttpGet request = new HttpGet(uriBuilder.build());
request.setConfig(requestConfig);
URI uri = request.getURI();
logger.info(uri);
System.err.println(uri);
response = getHttpClient().execute(request);
int status = response.getStatusLine().getStatusCode();
System.err.println(uriBuilder);
url=uriBuilder.toString();
//创建连接
WebTarget wt = ClientUtil.getWebTarger(url);
logger.info("getId url:"+url);
//获取响应结果
Builder header = wt.request(MediaType.APPLICATION_JSON).header("Content-Type", MediaType.APPLICATION_JSON);
Response response= header.get();
// HttpGet request = new HttpGet(uriBuilder.build());
// request.setConfig(requestConfig);
// URI uri = request.getURI();
// logger.info(uri);
// System.err.println(uri);
// response = getHttpClient().execute(request);
// int status = response.getStatusLine().getStatusCode();
int status = response.getStatus();
if (status == HttpStatus.SC_OK) {
result = EntityUtils.toString(response.getEntity());
result= response.readEntity(String.class);
// result = EntityUtils.toString(response.getEntity());
//调用处理数据方法
result = galaxyMessageFormat(result);
logger.debug("获取消息成功，相应内容如下： " + result);
@@ -159,7 +177,7 @@ public class HttpClientUtil {
} else {
throw new MaatConvertException(status+"");
}
} catch (SocketTimeoutException e) {
} /*catch (SocketTimeoutException e) {
logger.error("获取消息失败 ", e);
throw new MaatConvertException(requestContext.getMessage("request_service_failed") + ":timeout");
} catch (MaatConvertException e) {
@@ -167,10 +185,11 @@ public class HttpClientUtil {
} catch (ConnectTimeoutException e) {
logger.error("获取消息失败 ", e);
throw new MaatConvertException(requestContext.getMessage("request_service_failed") + ":timeout");
} catch (Exception e) {
}*/ catch (Exception e) {
e.printStackTrace();
logger.error("获取消息失败 ", e);
throw new MaatConvertException(requestContext.getMessage("request_service_failed"));
} finally {
} /*finally {
try {
if (response != null) {
response.close();
@@ -178,7 +197,7 @@ public class HttpClientUtil {
} catch (IOException e) {
e.printStackTrace();
}
}
}*/
return result;
}