Merge remote-tracking branch 'origin/master'

jiangping

2024-11-30 d87b6ff6bf0681854bb431e8f8e93652a6540691

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
package cn.emay.sdk.util;
 
import java.util.HashMap;
import java.util.Map;
 
import cn.emay.sdk.common.CommonConstants;
import cn.emay.sdk.core.dto.sms.common.ResultModel;
import cn.emay.sdk.util.http.client.EmayHttpClient;
import cn.emay.sdk.util.http.common.EmayHttpResultCode;
import cn.emay.sdk.util.http.request.impl.EmayHttpRequestBytes;
import cn.emay.sdk.util.http.request.impl.EmayHttpRequestKV;
import cn.emay.sdk.util.http.response.impl.string.EmayHttpResponseBytes;
import cn.emay.sdk.util.http.response.impl.string.EmayHttpResponseBytesPraser;
import cn.emay.sdk.util.http.response.impl.string.EmayHttpResponseString;
import cn.emay.sdk.util.http.response.impl.string.EmayHttpResponseStringPraser;
import cn.emay.sdk.util.json.JsonHelper;
 
public class HttpUtil {
 
    private static String remoteSign = "SDK";
 
    public static <T> ResultModel<T> request(String appId, String secretKey, String url, Object object, Class<T> clazz) {
        String code = "SYSTEM";// 默认系统异常
        T result = null;
        EmayHttpRequestBytes request = null;
        try {
            Map<String, String> headers = new HashMap<String, String>();
            headers.put("appId", appId);
            headers.put("encode", "UTF-8");
            headers.put("gzip", "on");
            headers.put("remoteSign", remoteSign);
            byte[] bytes = JsonHelper.toJsonString(object).getBytes("UTF-8");
            bytes = GZIPUtils.compress(bytes);
            byte[] parambytes = AES.encrypt(bytes, secretKey.getBytes(), CommonConstants.algorithm);
            request = new EmayHttpRequestBytes(url, "UTF-8", "POST", headers, null, parambytes);
        } catch (Exception e) {
            e.printStackTrace();
            return new ResultModel<T>(code, result);
        }
        try {
            EmayHttpClient client = new EmayHttpClient();
            EmayHttpResponseBytes res = client.service(request, new EmayHttpResponseBytesPraser());
            if (res == null) {
                return new ResultModel<T>(code, result);
            }
            if (res.getResultCode().equals(EmayHttpResultCode.SUCCESS)) {
                if (res.getHttpCode() == 200) {
                    code = res.getHeaders().get("result");
                    if (code.equals("SUCCESS")) {
                        byte[] data = res.getResultBytes();
                        data = AES.decrypt(data, secretKey.getBytes(), CommonConstants.algorithm);
                        data = GZIPUtils.decompress(data);
                        String json = new String(data, "UTF-8");
                        result = JsonHelper.fromJson(clazz, json);
                    }
                } else {
                    return new ResultModel<T>(code, result);
                }
            } else {
                return new ResultModel<T>(code, result);
            }
        } catch (Exception e) {
            e.printStackTrace();
            return new ResultModel<T>(code, result);
        }
        return new ResultModel<T>(code, result);
    }
 
    public static <T> ResultModel<T> request(Map<String, String> params, String url, String encode, Class<T> clazz) {
        String code = "SYSTEM";// 默认系统异常
        T result = null;
        EmayHttpRequestKV request = new EmayHttpRequestKV(url, encode, "POST", null, null, params);
        EmayHttpClient client = new EmayHttpClient();
        String json = null;
        try {
            String mapst = "";
            for (String key : params.keySet()) {
                String value = params.get(key);
                mapst += key + "=" + value + "&";
            }
            mapst = mapst.substring(0, mapst.length() - 1);
            EmayHttpResponseString res = client.service(request, new EmayHttpResponseStringPraser());
            if (res == null) {
                return new ResultModel<T>(code, result);
            }
            if (res.getResultCode().equals(EmayHttpResultCode.SUCCESS)) {
                if (res.getHttpCode() == 200) {
                    code = res.getResultCode().getCode();
                    json = res.getResultString();
                    result = JsonHelper.fromJson(clazz, json);
                } else {
                    return new ResultModel<T>(code, result);
                }
            } else {
                return new ResultModel<T>(code, result);
            }
        } catch (Exception e) {
            return new ResultModel<T>(code, result);
        }
        return new ResultModel<T>(code, result);
    }
 
}