package com.ruoyi.web.controller.yuncang.utils;
|
|
|
import com.ruoyi.web.controller.yuncang.utils.WebUtils;
|
|
import java.io.ByteArrayOutputStream;
|
import java.io.IOException;
|
import java.io.PrintStream;
|
import java.security.GeneralSecurityException;
|
import java.security.MessageDigest;
|
import java.util.Arrays;
|
import java.util.Map;
|
|
public class WdtClient {
|
|
private String appkey;
|
private String appsecret;
|
private String sid;
|
private String baseUrl;
|
|
private int connectTimeout = 3000;//3秒
|
private int readTimeout = 15000;//15秒
|
|
public WdtClient(String sid, String appkey, String appsecret, String baseUrl)
|
{
|
this.sid = sid;
|
this.appkey = appkey;
|
this.appsecret = appsecret;
|
this.baseUrl = baseUrl;
|
|
if(!this.baseUrl.endsWith("/"))
|
this.baseUrl = this.baseUrl+"/";
|
}
|
|
public void setTimeout(int connectTimeout, int readTimeout)
|
{
|
this.connectTimeout = connectTimeout;
|
this.readTimeout = readTimeout;
|
}
|
|
private static String getStringFromException(Throwable e) {
|
String result = "";
|
ByteArrayOutputStream bos = new ByteArrayOutputStream();
|
PrintStream ps = new PrintStream(bos);
|
e.printStackTrace(ps);
|
try {
|
result = bos.toString("UTF-8");
|
} catch (IOException ioe) {
|
}
|
return result;
|
}
|
|
private static byte[] encryptMD5(String data) throws IOException {
|
byte[] bytes = null;
|
try {
|
MessageDigest md = MessageDigest.getInstance("MD5");
|
bytes = md.digest(data.getBytes("UTF-8"));
|
} catch (GeneralSecurityException gse) {
|
String msg = getStringFromException(gse);
|
throw new IOException(msg);
|
}
|
return bytes;
|
}
|
|
private static String byte2hex(byte[] bytes) {
|
StringBuilder sign = new StringBuilder();
|
for (int i = 0; i < bytes.length; i++) {
|
String hex = Integer.toHexString(bytes[i] & 0xFF);
|
if (hex.length() == 1) {
|
//保证所有的16进制都是两位：00-ff，其中[80~ff]代表[-128,-1]
|
sign.append("0");
|
}
|
sign.append(hex);
|
}
|
return sign.toString();
|
}
|
|
/**
|
* 给TOP请求签名。
|
*
|
* @param params 所有字符型的TOP请求参数
|
* @param appsecret 签名密钥
|
* @return 签名
|
* @throws IOException
|
*/
|
public static String signRequest(Map<String, String> params, String appsecret) throws IOException {
|
// 第一步：检查参数是否已经排序
|
String[] keys = params.keySet().toArray(new String[0]);
|
Arrays.sort(keys);
|
|
// 第二步：把所有参数名和参数值串在一起
|
StringBuilder query = new StringBuilder();
|
for (String key : keys) {
|
if("sign".equals(key))
|
continue;
|
|
if(query.length() > 0)
|
query.append(';');
|
|
int len = key.length();
|
query.append(String.format("%02d", len)).append('-').append(key).append(':');
|
|
String value = params.get(key);
|
|
len = value.length();
|
query.append(String.format("%04d", len)).append('-').append(value);
|
|
}
|
|
query.append(appsecret);
|
|
// 第三步：使用MD5加密
|
byte[] bytes = encryptMD5(query.toString());
|
|
// 第四步：把二进制转化为大写的十六进制
|
return byte2hex(bytes);
|
}
|
|
public String execute(String relativeUrl, Map<String, String> params) throws IOException {
|
params.put("appkey", this.appkey);
|
params.put("sid", this.sid);
|
params.put("timestamp", Long.toString(System.currentTimeMillis()/1000));
|
params.put("sign", signRequest(params, this.appsecret));
|
return WebUtils.doPost(this.baseUrl + relativeUrl, params, "UTF-8", connectTimeout, readTimeout, null);
|
|
}
|
}
|
