Browse Source

增加rediskey

master
zhangyuan 3 years ago
parent
commit
ed1f6f4ef6
  1. 12
      epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/redis/RedisKeys.java
  2. 47
      spring-boot-httpclient-starter/src/main/java/com/elink/esua/httpclient/HttpClientUtils.java

12
epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/redis/RedisKeys.java

@ -317,6 +317,18 @@ public class RedisKeys {
return rootPrefix.concat("gis:bssb"); return rootPrefix.concat("gis:bssb");
} }
/**
* 北上诉办公司信息key
*
* @param
* @return java.lang.String
* @author zhy
* @date 2022/9/4 17:25
*/
public static String getCompanyKey() {
return rootPrefix.concat("gis:company");
}
/** /**
* 三大诉求编码 * 三大诉求编码
* *

47
spring-boot-httpclient-starter/src/main/java/com/elink/esua/httpclient/HttpClientUtils.java

@ -184,12 +184,13 @@ public class HttpClientUtils {
} }
/** /**
* desc: 发送get请求 * 发送get请求
* param:url, params
* return: CallResult<String>
* date: 2019/2/21 9:16
* *
* @author: jianjun liu * @param url
* @param params
* @return com.elink.esua.httpclient.ResultDto
* @author zhy
* @date 2022/9/6 9:41
*/ */
public ResultDto sendGet(String url, Map<String, Object> params) { public ResultDto sendGet(String url, Map<String, Object> params) {
@ -202,23 +203,31 @@ public class HttpClientUtils {
} }
} }
HttpGet httpGet = new HttpGet(builder.build()); HttpGet httpGet = new HttpGet(builder.build());
httpGet.setConfig(requestConfig); httpGet.setConfig(REQUEST_CONFIG);
return getResult(client.execute(httpGet)); return getResult(client.execute(httpGet));
} catch (Exception e) { } catch (Exception e) {
return null; return null;
} }
} }
/**
* post json
*
* @param url
* @param jsonStrParam
* @param headerMap
* @return com.elink.esua.httpclient.ResultDto
* @author zhy
* @date 2022/9/6 9:41
*/
public ResultDto sendPostByJSONAndHeader(String url, String jsonStrParam,Map<String,String> headerMap) { public ResultDto sendPostByJSONAndHeader(String url, String jsonStrParam,Map<String,String> headerMap) {
try { try {
HttpPost httppost = new HttpPost(url); HttpPost httppost = new HttpPost(url);
httppost.setConfig(requestConfig); httppost.setConfig(REQUEST_CONFIG);
httppost.addHeader(HEADER_CONTENT_TYPE, HEADER_APPLICATION_JSON); httppost.addHeader(HEADER_CONTENT_TYPE, HEADER_APPLICATION_JSON);
if (null != headerMap){ if (null != headerMap){
headerMap.forEach((k,v) -> { headerMap.forEach(httppost::addHeader);
httppost.addHeader(k,v);
});
} }
if (!StringUtils.isEmpty(jsonStrParam)) { if (!StringUtils.isEmpty(jsonStrParam)) {
StringEntity se = new StringEntity(jsonStrParam, UTF8); StringEntity se = new StringEntity(jsonStrParam, UTF8);
@ -231,17 +240,25 @@ public class HttpClientUtils {
} }
/**
* post form
*
* @param url
* @param paramsMap
* @param headerMap
* @return com.elink.esua.httpclient.ResultDto
* @author zhy
* @date 2022/9/6 9:42
*/
public ResultDto sendPostAndHeader(String url, Map<String, Object> paramsMap, Map<String,String> headerMap) { public ResultDto sendPostAndHeader(String url, Map<String, Object> paramsMap, Map<String,String> headerMap) {
try { try {
HttpPost httppost = new HttpPost(url); HttpPost httppost = new HttpPost(url);
httppost.setConfig(requestConfig); httppost.setConfig(REQUEST_CONFIG);
httppost.addHeader(HEADER_CONTENT_TYPE, HEADER_APPLICATION_FORM_URL_ENCODED); httppost.addHeader(HEADER_CONTENT_TYPE, HEADER_APPLICATION_FORM_URL_ENCODED);
if (null != headerMap){ if (null != headerMap){
headerMap.forEach((k,v) -> { headerMap.forEach(httppost::addHeader);
httppost.addHeader(k,v);
});
} }
List<NameValuePair> list = new ArrayList<NameValuePair>(); List<NameValuePair> list = new ArrayList<NameValuePair>();
for (String key : paramsMap.keySet()) { for (String key : paramsMap.keySet()) {
@ -258,7 +275,7 @@ public class HttpClientUtils {
} }
/*** 超时设置 ****/ /*** 超时设置 ****/
private static RequestConfig requestConfig = RequestConfig.custom() private static final RequestConfig REQUEST_CONFIG = RequestConfig.custom()
.setSocketTimeout(soTimeout) .setSocketTimeout(soTimeout)
.setConnectTimeout(connectionTimeout) .setConnectTimeout(connectionTimeout)
.setConnectionRequestTimeout(soTimeout) .setConnectionRequestTimeout(soTimeout)

Loading…
Cancel
Save