SSBG_PIPL.git - Gitblit

package com.common.core.utils;
 
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.http.*;
import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
import org.springframework.http.converter.StringHttpMessageConverter;
import org.springframework.web.client.RestTemplate;
 
import java.nio.charset.StandardCharsets;
import java.util.Iterator;
import java.util.Map;
import java.util.Optional;
 
 
@Slf4j
public class RestUtil {
 
    private static String domain = null;
 
 
    public static String getString(String s, String defval) {
        if (isEmpty(s)) {
            return (defval);
        }
        return (s.trim());
    }
 
    public static boolean isEmpty(Object object) {
        if (object == null) {
            return (true);
        }
        if ("".equals(object)) {
            return (true);
        }
        if ("null".equals(object)) {
            return (true);
        }
        return (false);
    }
 
    /**
     * RestAPI 调用器
     */
    private final static RestTemplate RT;
 
    static {
        HttpComponentsClientHttpRequestFactory requestFactory = new HttpComponentsClientHttpRequestFactory();
        requestFactory.setConnectTimeout(1000*60*5);
        requestFactory.setReadTimeout(1000*60*5);
        RT = new RestTemplate(requestFactory);
        // 解决乱码问题
        RT.getMessageConverters().set(1, new StringHttpMessageConverter(StandardCharsets.UTF_8));
    }
 
    public static RestTemplate getRestTemplate() {
        return RT;
    }
 
    /**
     * 发送 get 请求
     */
    public static JSONObject get(String url) {
        return getNative(url, null, null).getBody();
    }
 
    /**
     * 发送 get 请求
     */
    public static JSONObject get(String url, JSONObject variables) {
        return getNative(url, variables, null).getBody();
    }
 
    /**
     * 发送 get 请求
     */
    public static JSONObject get(String url, JSONObject variables, JSONObject params) {
        return getNative(url, variables, params).getBody();
    }
 
    /**
     * 发送 get 请求，返回原生 ResponseEntity 对象
     */
    public static ResponseEntity<JSONObject> getNative(String url, JSONObject variables, JSONObject params) {
        return request(url, HttpMethod.GET, variables, params);
    }
    public static ResponseEntity<JSONObject> getNative(String url, HttpHeaders headers) {
        return request(url, headers, HttpMethod.GET);
    }
 
    public static JSONObject get(String url, HttpHeaders headers) {
        return request(url, headers, HttpMethod.GET).getBody();
    }
 
    /**
     * 发送 Post 请求
     */
    public static JSONObject post(String url) {
        return postNative(url, null, new JSONObject()).getBody();
    }
 
    /**
     * 发送 Post 请求
     */
    public static JSONObject post(String url, JSONObject params) {
        return postNative(url, null, params).getBody();
    }
 
    /**
     * 发送 Post 请求
     */
    public static JSONObject post(String url, JSONObject variables, JSONObject params) {
        return postNative(url, variables, params).getBody();
    }
 
    public static JSONObject post(String url, HttpHeaders headers, JSONObject variables, Object params) {
        return request(url, headers, HttpMethod.POST, variables, params).getBody();
    }
 
    /**
     * 发送 POST 请求，返回原生 ResponseEntity 对象
     */
    public static ResponseEntity<JSONObject> postNative(String url, HttpHeaders headers, JSONObject variables, Object params) {
        return request(url, headers, HttpMethod.POST, variables, params);
    }
    public static ResponseEntity<JSONObject> postNative(String url, HttpHeaders headers, JSONObject variables, String params) {
        return request(url, headers, HttpMethod.POST, variables, params);
    }
 
    public static ResponseEntity<Object> postNativeObject(String url, HttpHeaders headers, JSONObject variables, String params) {
        return requestObject(url, headers, HttpMethod.POST, variables, params);
    }
    public static ResponseEntity<JSONObject> postNative(String url, JSONObject variables, JSONObject params) {
        return request(url, HttpMethod.POST, variables, params);
    }
 
    public static ResponseEntity<JSONObject> postNative(String url, JSONObject variables, JSONArray params) {
        return request(url, HttpMethod.POST, variables, params);
    }
 
    /**
     * 发送 PATCH 请求，返回原生 ResponseEntity 对象
     */
    public static ResponseEntity<JSONObject> patchNative(String url, HttpHeaders headers, JSONObject variables, String params) {
        return request(url, headers, HttpMethod.PATCH, variables, params);
    }
 
    /**
     * 发送 put 请求
     */
    public static JSONObject put(String url) {
        return putNative(url, null, null).getBody();
    }
 
    /**
     * 发送 put 请求
     */
    public static JSONObject put(String url, JSONObject params) {
        return putNative(url, null, params).getBody();
    }
 
    /**
     * 发送 put 请求
     */
    public static JSONObject put(String url, JSONObject variables, JSONObject params) {
        return putNative(url, variables, params).getBody();
    }
 
    /**
     * 发送 put 请求，返回原生 ResponseEntity 对象
     */
    public static ResponseEntity<JSONObject> putNative(String url, JSONObject variables, JSONObject params) {
        return request(url, HttpMethod.PUT, variables, params);
    }
 
    /**
     * 发送 delete 请求
     */
    public static JSONObject delete(String url) {
        return deleteNative(url, null, null).getBody();
    }
 
    /**
     * 发送 delete 请求
     */
    public static JSONObject delete(String url, JSONObject variables, JSONObject params) {
        return deleteNative(url, variables, params).getBody();
    }
 
    /**
     * 发送 delete 请求，返回原生 ResponseEntity 对象
     */
    public static ResponseEntity<JSONObject> deleteNative(String url, JSONObject variables, JSONObject params) {
        return request(url, HttpMethod.DELETE, null, variables, params, JSONObject.class);
    }
 
    /**
     * 发送请求
     */
    public static ResponseEntity<JSONObject> request(String url, HttpMethod method, JSONObject variables, JSONObject params) {
        return request(url, method, getHeaderApplicationJson(), variables, params, JSONObject.class);
    }
 
    public static ResponseEntity<JSONObject> request(String url, HttpMethod method, JSONObject variables, JSONArray params) {
        return request(url, method, getHeaderApplicationJson(), variables, params, JSONObject.class);
    }
 
 
    public static ResponseEntity<JSONObject> request(String url, HttpHeaders headers, HttpMethod method, JSONObject variables, Object params) {
        return request(url, method, headers, variables, params, JSONObject.class);
    }
 
    public static ResponseEntity<Object> requestObject(String url, HttpHeaders headers, HttpMethod method, JSONObject variables, Object params) {
        return request(url, method, headers, variables, params, Object.class);
    }
 
    public static ResponseEntity<JSONObject> request(String url, HttpHeaders headers,HttpMethod method) {
        return request(url, method, headers, null, null, JSONObject.class);
    }
 
    /**
     * 发送请求
     *
     * @param url          请求地址
     * @param method       请求方式
     * @param headers      请求头  可空
     * @param variables    请求url参数 可空
     * @param params       请求body参数 可空
     * @param responseType 返回类型
     * @return ResponseEntity<responseType>
     */
    public static <T> ResponseEntity<T> request(String url, HttpMethod method, HttpHeaders headers, JSONObject variables, Object params, Class<T> responseType) {
        log.info(" RestUtil  --- request ---  url = "+ url);
        if (StringUtils.isEmpty(url)) {
            throw new RuntimeException("url 不能为空");
        }
        if (method == null) {
            throw new RuntimeException("method 不能为空");
        }
        if (headers == null) {
            headers = new HttpHeaders();
        }
        // 请求体
        String body = "";
        if (params != null) {
            log.info(url+",json="+params.toString());
            if (params instanceof JSONObject) {
                body = ((JSONObject) params).toJSONString();
 
            } else {
                body = params.toString();
            }
        }
        // 拼接 url 参数
        if (variables != null) {
            log.info(url+",variables:"+asUrlVariables(variables));
            url += ("?" + asUrlVariables(variables));
        }
        // 发送请求
        HttpEntity<String> request = new HttpEntity<>(body, headers);
        ResponseEntity<T> resp = RT.exchange(url, method, request, responseType);
        Optional o = Optional.ofNullable(resp.getBody());
        if(o.isPresent()) {
            log.info(url + ": reponsebody=" + o.get());
        }
        return resp;
    }
 
    /**
     * 获取JSON请求头
     */
    public static HttpHeaders getHeaderApplicationJson() {
        return getHeader(MediaType.APPLICATION_JSON_UTF8_VALUE);
    }
 
    /**
     * 获取请求头
     */
    public static HttpHeaders getHeader(String mediaType) {
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.parseMediaType(mediaType));
        headers.add("Accept", mediaType);
        return headers;
    }
 
    /**
     * 将 JSONObject 转为 a=1&b=2&c=3...&n=n 的形式
     */
    public static String asUrlVariables(JSONObject variables) {
        Map<String, Object> source = variables.getInnerMap();
        Iterator<String> it = source.keySet().iterator();
        StringBuilder urlVariables = new StringBuilder();
        while (it.hasNext()) {
            String key = it.next();
            String value = "";
            Object object = source.get(key);
            if (object != null) {
                if (!StringUtils.isEmpty(object.toString())) {
                    value = object.toString();
                }
            }
            urlVariables.append("&").append(key).append("=").append(value);
        }
        // 去掉第一个&
        return urlVariables.substring(1);
    }
 
}