PALWPS相关文件提交
This commit is contained in:
parent
2f3c8ee063
commit
676e37ec9e
@ -0,0 +1,28 @@
|
||||
package com.actionsoft.apps.coe.pal.constant;
|
||||
|
||||
import com.actionsoft.sdk.local.SDK;
|
||||
|
||||
public class YiliWpsConst {
|
||||
public static final String APPID = "com.awspaas.user.apps.yiliwps";
|
||||
public static final String FILE_APPID = "com.actionsoft.apps.coe.pal";
|
||||
public static final String COE_UPFILE = "COE_Upfile";
|
||||
public static final String HOST = SDK.getAppAPI().getProperty(APPID,"host_config");
|
||||
public static final String CONTENT_TYPE = "application/json";
|
||||
public static final String AK = SDK.getAppAPI().getProperty(APPID,"AK");
|
||||
public static final String SK = SDK.getAppAPI().getProperty(APPID,"SK");
|
||||
|
||||
public static final String WPS_FILETYPE_W="w";
|
||||
public static final String WPS_FILETYPE_S="s";
|
||||
public static final String WPS_FILETYPE_P="p";
|
||||
public static final String WPS_FILETYPE_F="f";
|
||||
public static final String SUPPORTTYPE_W = "doc, dot, wps, wpt, docx, dotx, docm, dotm";
|
||||
public static final String SUPPORTTYPE_S = "xls, xlt, et, xlsx, xltx, csv, xlsm, xltm";
|
||||
public static final String SUPPORTTYPE_P = "ppt,pptx,pptm,ppsx,ppsm,pps,potx,potm,dpt,dps";
|
||||
public static final String SUPPORTTYPE_F = "pdf";
|
||||
|
||||
//bo相关
|
||||
public static final String BO_EU_SYSTEM_DEMO_FILE = "BO_EU_SYSTEM_DEMO_FILE";
|
||||
public static final String APP_ACT_COE_PAL_UPFILE = "APP_ACT_COE_PAL_UPFILE";
|
||||
|
||||
|
||||
}
|
||||
@ -0,0 +1,268 @@
|
||||
package com.actionsoft.apps.coe.pal.util;
|
||||
|
||||
import sun.misc.BASE64Decoder;
|
||||
import sun.misc.BASE64Encoder;
|
||||
|
||||
import javax.crypto.Cipher;
|
||||
import javax.crypto.Mac;
|
||||
import javax.crypto.spec.SecretKeySpec;
|
||||
import java.io.UnsupportedEncodingException;
|
||||
import java.math.BigInteger;
|
||||
import java.nio.charset.StandardCharsets;
|
||||
import java.security.MessageDigest;
|
||||
import java.security.NoSuchAlgorithmException;
|
||||
|
||||
public class EncryptionUtil {
|
||||
|
||||
/**
|
||||
* 加密算法
|
||||
*/
|
||||
private static final String ENCRY_ALGORITHM = "AES";
|
||||
|
||||
/**
|
||||
* 加密算法/加密模式/填充类型
|
||||
* 本例采用AES加密，ECB加密模式，PKCS5Padding填充
|
||||
*/
|
||||
private static final String CIPHER_MODE = "AES/ECB/PKCS5Padding";
|
||||
|
||||
|
||||
public static String md5(String plainText) {
|
||||
byte[] secretBytes = null;
|
||||
try {
|
||||
secretBytes = MessageDigest.getInstance("md5").digest(
|
||||
plainText.getBytes());
|
||||
} catch (NoSuchAlgorithmException e) {
|
||||
return null;
|
||||
}
|
||||
String md5code = new BigInteger(1, secretBytes).toString(16);
|
||||
for (int i = 0; i < 32 - md5code.length(); i++) {
|
||||
md5code = "0" + md5code;
|
||||
}
|
||||
return md5code;
|
||||
}
|
||||
|
||||
public static String HMACSHA256(String data, String key) throws Exception {
|
||||
Mac sha256HMAC = Mac.getInstance("HmacSHA256");
|
||||
SecretKeySpec secret_key = new SecretKeySpec(key.getBytes(StandardCharsets.UTF_8), "HmacSHA256");
|
||||
sha256HMAC.init(secret_key);
|
||||
byte[] array = sha256HMAC.doFinal(data.getBytes(StandardCharsets.UTF_8));
|
||||
StringBuilder sb = new StringBuilder();
|
||||
for (byte item : array) {
|
||||
sb.append(Integer.toHexString((item & 0xFF) |
|
||||
0x100).substring(1, 3));
|
||||
}
|
||||
return sb.toString();
|
||||
}
|
||||
|
||||
/**
|
||||
* 利用java原生的摘要实现SHA256加密
|
||||
*
|
||||
* @param str 加密后的报文
|
||||
* @return
|
||||
*/
|
||||
public static String getSHA256StrJava(byte[] str) {
|
||||
MessageDigest messageDigest;
|
||||
String encodeStr = "";
|
||||
try {
|
||||
messageDigest = MessageDigest.getInstance("SHA-256");
|
||||
messageDigest.update(str);
|
||||
encodeStr = byte2Hex(messageDigest.digest());
|
||||
} catch (NoSuchAlgorithmException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
return encodeStr;
|
||||
}
|
||||
|
||||
/**
|
||||
* 将
|
||||
* byte转为16进制
|
||||
*
|
||||
* @param bytes
|
||||
* @return
|
||||
*/
|
||||
private static String byte2Hex(byte[] bytes) {
|
||||
StringBuffer stringBuffer = new StringBuffer();
|
||||
String temp = null;
|
||||
for (int i = 0; i < bytes.length; i++) {
|
||||
temp = Integer.toHexString(bytes[i] & 0xFF);
|
||||
if (temp.length() == 1) {
|
||||
//1得到一位的进行补0操作
|
||||
stringBuffer.append("0");
|
||||
}
|
||||
stringBuffer.append(temp);
|
||||
}
|
||||
return stringBuffer.toString();
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 设置iv偏移量
|
||||
* 本例采用ECB加密模式，不需要设置iv偏移量
|
||||
*/
|
||||
private static final String IV_ = null;
|
||||
|
||||
/**
|
||||
* 设置加密字符集
|
||||
* 本例采用 UTF-8 字符集
|
||||
*/
|
||||
private static final String CHARACTER = "UTF-8";
|
||||
|
||||
/**
|
||||
* 设置加密密码处理长度。
|
||||
* 不足此长度补0；
|
||||
*/
|
||||
private static final int PWD_SIZE = 16;
|
||||
|
||||
/**
|
||||
* 密码处理方法
|
||||
* 如果加解密出问题，
|
||||
* 请先查看本方法，排除密码长度不足填充0字节,导致密码不一致
|
||||
* @param password 待处理的密码
|
||||
* @return
|
||||
* @throws UnsupportedEncodingException
|
||||
*/
|
||||
private static byte[] pwdHandler(String password) throws UnsupportedEncodingException {
|
||||
byte[] data = null;
|
||||
if (password != null) {
|
||||
byte[] bytes = password.getBytes(CHARACTER);
|
||||
if (password.length() < PWD_SIZE) {
|
||||
System.arraycopy(bytes, 0, data = new byte[PWD_SIZE], 0, bytes.length);
|
||||
} else {
|
||||
data = bytes;
|
||||
}
|
||||
}
|
||||
return data;
|
||||
}
|
||||
|
||||
//======================>原始加密<======================
|
||||
|
||||
/**
|
||||
* 原始加密
|
||||
* @param clearTextBytes 明文字节数组，待加密的字节数组
|
||||
* @param pwdBytes 加密密码字节数组
|
||||
* @return 返回加密后的密文字节数组，加密错误返回null
|
||||
*/
|
||||
public static byte[] encrypt(byte[] clearTextBytes, byte[] pwdBytes) {
|
||||
try {
|
||||
// 1 获取加密密钥
|
||||
SecretKeySpec keySpec = new SecretKeySpec(pwdBytes, ENCRY_ALGORITHM);
|
||||
|
||||
// 2 获取Cipher实例
|
||||
Cipher cipher = Cipher.getInstance(CIPHER_MODE);
|
||||
|
||||
// 查看数据块位数 默认为16（byte） * 8 =128 bit
|
||||
// System.out.println("数据块位数(byte)：" + cipher.getBlockSize());
|
||||
|
||||
// 3 初始化Cipher实例。设置执行模式以及加密密钥
|
||||
cipher.init(Cipher.ENCRYPT_MODE, keySpec);
|
||||
|
||||
// 4 执行
|
||||
byte[] cipherTextBytes = cipher.doFinal(clearTextBytes);
|
||||
|
||||
// 5 返回密文字符集
|
||||
return cipherTextBytes;
|
||||
|
||||
}catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
/**
|
||||
* 原始解密
|
||||
* @param cipherTextBytes 密文字节数组，待解密的字节数组
|
||||
* @param pwdBytes 解密密码字节数组
|
||||
* @return 返回解密后的明文字节数组，解密错误返回null
|
||||
*/
|
||||
public static byte[] decrypt(byte[] cipherTextBytes, byte[] pwdBytes) {
|
||||
|
||||
try {
|
||||
// 1 获取解密密钥
|
||||
SecretKeySpec keySpec = new SecretKeySpec(pwdBytes, ENCRY_ALGORITHM);
|
||||
|
||||
// 2 获取Cipher实例
|
||||
Cipher cipher = Cipher.getInstance(CIPHER_MODE);
|
||||
|
||||
// 查看数据块位数 默认为16（byte） * 8 =128 bit
|
||||
// System.out.println("数据块位数(byte)：" + cipher.getBlockSize());
|
||||
|
||||
// 3 初始化Cipher实例。设置执行模式以及加密密钥
|
||||
cipher.init(Cipher.DECRYPT_MODE, keySpec);
|
||||
|
||||
// 4 执行
|
||||
byte[] clearTextBytes = cipher.doFinal(cipherTextBytes);
|
||||
|
||||
// 5 返回明文字符集
|
||||
return clearTextBytes;
|
||||
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
// 解密错误 返回null
|
||||
return null;
|
||||
}
|
||||
|
||||
//======================>BASE64<======================
|
||||
|
||||
/**
|
||||
* BASE64加密
|
||||
* @param clearText 明文，待加密的内容
|
||||
* @param password 密码，加密的密码
|
||||
* @return 返回密文，加密后得到的内容。加密错误返回null
|
||||
*/
|
||||
public static String aesEncryptBase64(String clearText, String password) {
|
||||
try {
|
||||
// 1 获取加密密文字节数组
|
||||
byte[] cipherTextBytes = encrypt(clearText.getBytes(CHARACTER), pwdHandler(password));
|
||||
|
||||
// 2 对密文字节数组进行BASE64 encoder 得到 BASE6输出的密文
|
||||
BASE64Encoder base64Encoder = new BASE64Encoder();
|
||||
|
||||
// 3 返回BASE64输出的密文
|
||||
return base64Encoder.encode(cipherTextBytes);
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
// 加密错误 返回null
|
||||
return null;
|
||||
}
|
||||
|
||||
/**
|
||||
* BASE64解密
|
||||
* @param cipherText 密文，带解密的内容
|
||||
* @param password 密码，解密的密码
|
||||
* @return 返回明文，解密后得到的内容。解密错误返回null
|
||||
*/
|
||||
public static String aesDecryptBase64(String cipherText, String password) {
|
||||
try {
|
||||
// 1 对 BASE64输出的密文进行BASE64 decodebuffer 得到密文字节数组
|
||||
BASE64Decoder base64Decoder = new BASE64Decoder();
|
||||
byte[] cipherTextBytes = base64Decoder.decodeBuffer(cipherText);
|
||||
|
||||
// 2 对密文字节数组进行解密 得到明文字节数组
|
||||
byte[] clearTextBytes = decrypt(cipherTextBytes, pwdHandler(password));
|
||||
|
||||
// 3 根据 CHARACTER 转码，返回明文字符串
|
||||
return new String(clearTextBytes, CHARACTER);
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
// 解密错误返回null
|
||||
return null;
|
||||
}
|
||||
|
||||
public static void main(String[] args) throws Exception {
|
||||
// System.out.println(DigestUtils.sha256Hex("".getBytes()));
|
||||
// String result = getSHA256StrJava("".getBytes());
|
||||
// System.out.println(result);
|
||||
// String hamacstr = HMACSHA256("WPS-4POST/callback/path/demoapplication/jsonWed, 20 Apr 2022 01:33:07 GMTfc005f51a6e75586d2d5d078b657dxxxdf9c1dfa6a7c0c0ba38c715daeb6ede9","cc2e3878f68e003347da63f9dbaee5a8");
|
||||
// System.out.println(hamacstr);
|
||||
|
||||
//1.输出设置为base64时
|
||||
String encryptedStr = aesEncryptBase64("123", "XDWe0nNGxTg2yD8Gb3uUapkoA8XtKvq3");//参数：明文，加密字符串
|
||||
System.out.println("加密后的base64字符串为："+encryptedStr);
|
||||
String decrypt = aesDecryptBase64(encryptedStr,"XDWe0nNGxTg2yD8Gb3uUapkoA8XtKvq3");//参数：密文，加密字符串
|
||||
System.out.println("解密后的字符串为：" + decrypt);
|
||||
}
|
||||
}
|
||||
|
||||
@ -0,0 +1,305 @@
|
||||
package com.actionsoft.apps.coe.pal.util;
|
||||
|
||||
import com.alibaba.fastjson.JSON;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.apache.commons.lang3.tuple.Pair;
|
||||
import org.apache.http.HttpEntity;
|
||||
import org.apache.http.StatusLine;
|
||||
import org.apache.http.client.ClientProtocolException;
|
||||
import org.apache.http.client.config.AuthSchemes;
|
||||
import org.apache.http.client.config.CookieSpecs;
|
||||
import org.apache.http.client.config.RequestConfig;
|
||||
import org.apache.http.client.methods.*;
|
||||
import org.apache.http.config.Registry;
|
||||
import org.apache.http.config.RegistryBuilder;
|
||||
import org.apache.http.conn.socket.ConnectionSocketFactory;
|
||||
import org.apache.http.conn.socket.PlainConnectionSocketFactory;
|
||||
import org.apache.http.conn.ssl.NoopHostnameVerifier;
|
||||
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
|
||||
import org.apache.http.entity.BasicHttpEntity;
|
||||
import org.apache.http.entity.ContentType;
|
||||
import org.apache.http.entity.InputStreamEntity;
|
||||
import org.apache.http.entity.StringEntity;
|
||||
import org.apache.http.impl.client.CloseableHttpClient;
|
||||
import org.apache.http.impl.client.HttpClients;
|
||||
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
|
||||
import org.apache.http.util.EntityUtils;
|
||||
|
||||
import javax.net.ssl.SSLContext;
|
||||
import javax.net.ssl.TrustManager;
|
||||
import javax.net.ssl.X509TrustManager;
|
||||
import java.io.*;
|
||||
import java.nio.charset.StandardCharsets;
|
||||
import java.security.KeyManagementException;
|
||||
import java.security.NoSuchAlgorithmException;
|
||||
import java.security.cert.X509Certificate;
|
||||
import java.util.Arrays;
|
||||
import java.util.Map;
|
||||
|
||||
public class HttpPostUtil {
|
||||
/**
|
||||
* 下载请求
|
||||
*
|
||||
* @param url
|
||||
* @param headers
|
||||
* @return
|
||||
* @throws IOException
|
||||
*/
|
||||
public static void sendGetDownloadRequest(String url, Map<String, String> headers,String savePath) throws IOException {
|
||||
// 设置请求头
|
||||
HttpGet request = new HttpGet(url);
|
||||
if (null != headers) {
|
||||
for (Map.Entry<String, String> entry : headers.entrySet()) {
|
||||
request.addHeader(entry.getKey(), entry.getValue());
|
||||
}
|
||||
}
|
||||
|
||||
// 发送http请求
|
||||
try (CloseableHttpClient httpClient = HttpClients.createDefault();
|
||||
CloseableHttpResponse response = httpClient.execute(request)) {
|
||||
HttpEntity entity = response.getEntity();
|
||||
if (null != entity) {
|
||||
InputStream in = entity.getContent();
|
||||
File file = new File(savePath);//这里为存储路径/xx/xx..
|
||||
FileOutputStream fout = new FileOutputStream(file);
|
||||
int a = -1;
|
||||
byte[] tmp = new byte[1024];
|
||||
while ((a = in.read(tmp)) != -1) {
|
||||
fout.write(tmp, 0, a);
|
||||
}
|
||||
fout.flush();
|
||||
fout.close();
|
||||
in.close();
|
||||
httpClient.close();
|
||||
return;
|
||||
}
|
||||
throw new IOException("No response");
|
||||
} catch (IOException e) {
|
||||
throw e;
|
||||
}
|
||||
}
|
||||
/**
|
||||
* 发送Get请求(如果https请求需要忽略证书检测，需自己实现)
|
||||
*
|
||||
* @param url
|
||||
* @param headers
|
||||
* @return
|
||||
* @throws IOException
|
||||
*/
|
||||
public static String sendGetRequest(String url, Map<String, String> headers) throws IOException {
|
||||
// 设置请求头
|
||||
HttpGet request = new HttpGet(url);
|
||||
if (null != headers) {
|
||||
for (Map.Entry<String, String> entry : headers.entrySet()) {
|
||||
request.addHeader(entry.getKey(), entry.getValue());
|
||||
}
|
||||
}
|
||||
// 发送http请求
|
||||
try (CloseableHttpClient httpClient = HttpClients.createDefault();
|
||||
CloseableHttpResponse response = httpClient.execute(request)) {
|
||||
HttpEntity entity = response.getEntity();
|
||||
if (null != entity) {
|
||||
String content = EntityUtils.toString(entity, StandardCharsets.UTF_8);
|
||||
System.out.println(">>>输出"+content);
|
||||
EntityUtils.consume(entity); // 关闭content stream
|
||||
return content;
|
||||
}
|
||||
throw new IOException("No response");
|
||||
} catch (IOException e) {
|
||||
throw e;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 发送Get请求(如果https请求需要忽略证书检测，需自己实现)
|
||||
*/
|
||||
public static <T> T sendPostRequest(String url, String body, Map<String, String> headers,Class<T> classes) throws IOException {
|
||||
// 设置请求头
|
||||
HttpPost request = new HttpPost(url);
|
||||
if (headers != null) {
|
||||
for (Map.Entry<String, String> entry : headers.entrySet()) {
|
||||
request.addHeader(entry.getKey(), entry.getValue());
|
||||
}
|
||||
}
|
||||
// 设置请求body
|
||||
if (body != null) {
|
||||
request.setEntity(new StringEntity(body, StandardCharsets.UTF_8));
|
||||
}
|
||||
try {
|
||||
// 发送http请求
|
||||
CloseableHttpClient httpClient = HttpClients.createDefault();
|
||||
CloseableHttpResponse response = httpClient.execute(request);
|
||||
HttpEntity entity = response.getEntity();
|
||||
if (null != entity) {
|
||||
String content = EntityUtils.toString(entity);
|
||||
httpClient.close();
|
||||
response.close();
|
||||
return JSON.parseObject(content,classes);
|
||||
}
|
||||
return null;
|
||||
} catch (IOException e) {
|
||||
throw e;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 发送Put请求(如果https请求需要忽略证书检测，需自己实现)
|
||||
*
|
||||
* @param url
|
||||
* @param headers
|
||||
* @return
|
||||
* @throws IOException
|
||||
*/
|
||||
public static CloseableHttpResponse sendPutRequest(String url, InputStream body, Map<String, String> headers) throws IOException {
|
||||
// 设置请求头
|
||||
HttpPut request = new HttpPut(url);
|
||||
if (headers != null) {
|
||||
for (Map.Entry<String, String> entry : headers.entrySet()) {
|
||||
request.addHeader(entry.getKey(), entry.getValue());
|
||||
}
|
||||
}
|
||||
// 设置请求body
|
||||
if (body != null) {
|
||||
InputStreamEntity entity = new InputStreamEntity(body);
|
||||
entity.setContentType(ContentType.APPLICATION_OCTET_STREAM.toString());
|
||||
request.setEntity(entity);
|
||||
}
|
||||
|
||||
// 发送http请求
|
||||
try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
|
||||
return httpClient.execute(request);
|
||||
} catch (ClientProtocolException e) {
|
||||
throw e;
|
||||
} catch (IOException e) {
|
||||
throw e;
|
||||
}
|
||||
}
|
||||
|
||||
public static CloseableHttpResponse doPutUpload(String url, File file, Map<String, String> headers) {
|
||||
FileInputStream fileInputStream = null;
|
||||
CloseableHttpResponse response = null;
|
||||
try {
|
||||
// file
|
||||
fileInputStream = new FileInputStream(file);
|
||||
|
||||
HttpPut httpput = new HttpPut(url);
|
||||
addHeader(httpput, headers);
|
||||
|
||||
BasicHttpEntity basicHttpEntity = new BasicHttpEntity();
|
||||
basicHttpEntity.setChunked(false);
|
||||
basicHttpEntity.setContent(fileInputStream);
|
||||
basicHttpEntity.setContentLength(file.length());
|
||||
|
||||
httpput.setEntity(basicHttpEntity);
|
||||
response = executeRequest(url, httpput);
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
} finally {
|
||||
if (fileInputStream != null) {
|
||||
try {
|
||||
fileInputStream.close();
|
||||
}catch (Exception e1){
|
||||
e1.printStackTrace();
|
||||
}
|
||||
}
|
||||
}
|
||||
return response;
|
||||
}
|
||||
private static void addHeader(HttpRequestBase httpRequestBase, Map<String, String> header) {
|
||||
if (header != null && !header.isEmpty()) {
|
||||
for (Map.Entry<String, String> entry : header.entrySet()) {
|
||||
httpRequestBase.addHeader(entry.getKey(), entry.getValue());
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private static CloseableHttpResponse executeRequest(String url, HttpUriRequest request) throws Exception {
|
||||
return getInstance(url).execute(request);
|
||||
}
|
||||
|
||||
private static CloseableHttpClient getInstance(String url) {
|
||||
if (!StringUtils.isEmpty(url) && url.startsWith("https")) {
|
||||
return sslClient();
|
||||
} else {
|
||||
return HttpClients.createDefault();
|
||||
}
|
||||
}
|
||||
|
||||
private static CloseableHttpClient sslClient() {
|
||||
try {
|
||||
// 在调用SSL之前需要重写验证方法，取消检测SSL
|
||||
X509TrustManager trustManager = new X509TrustManager() {
|
||||
@Override
|
||||
public X509Certificate[] getAcceptedIssuers() {
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void checkClientTrusted(X509Certificate[] xcs, String str) {
|
||||
}
|
||||
|
||||
@Override
|
||||
public void checkServerTrusted(X509Certificate[] xcs, String str) {
|
||||
}
|
||||
};
|
||||
SSLContext ctx = SSLContext.getInstance(SSLConnectionSocketFactory.TLS);
|
||||
ctx.init(null, new TrustManager[]{trustManager}, null);
|
||||
SSLConnectionSocketFactory socketFactory = new SSLConnectionSocketFactory(ctx, NoopHostnameVerifier.INSTANCE);
|
||||
// 创建Registry
|
||||
RequestConfig requestConfig = RequestConfig.custom().setCookieSpec(CookieSpecs.STANDARD_STRICT)
|
||||
.setExpectContinueEnabled(Boolean.TRUE).setTargetPreferredAuthSchemes(Arrays.asList(AuthSchemes.NTLM, AuthSchemes.DIGEST))
|
||||
.setProxyPreferredAuthSchemes(Arrays.asList(AuthSchemes.BASIC)).build();
|
||||
Registry<ConnectionSocketFactory> socketFactoryRegistry = RegistryBuilder.<ConnectionSocketFactory>create()
|
||||
.register("http", PlainConnectionSocketFactory.INSTANCE)
|
||||
.register("https", socketFactory).build();
|
||||
// 创建ConnectionManager，添加Connection配置信息
|
||||
PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(socketFactoryRegistry);
|
||||
CloseableHttpClient closeableHttpClient = HttpClients.custom().setConnectionManager(connectionManager)
|
||||
.setDefaultRequestConfig(requestConfig).build();
|
||||
return closeableHttpClient;
|
||||
} catch (KeyManagementException ex) {
|
||||
throw new RuntimeException(ex);
|
||||
} catch (NoSuchAlgorithmException ex) {
|
||||
throw new RuntimeException(ex);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 发送Post请求(如果https请求需要忽略证书检测，需自己实现)
|
||||
*
|
||||
* @param url
|
||||
* @param headers
|
||||
* @return
|
||||
* @throws IOException
|
||||
*/
|
||||
public static Pair<StatusLine, String> sendPostRequest3(String url, String body, Map<String, String> headers) throws IOException {
|
||||
// 设置请求头
|
||||
HttpPost request = new HttpPost(url);
|
||||
if (headers != null) {
|
||||
for (Map.Entry<String, String> entry : headers.entrySet()) {
|
||||
request.addHeader(entry.getKey(), entry.getValue());
|
||||
}
|
||||
}
|
||||
// 设置请求body
|
||||
if (body != null) {
|
||||
request.setEntity(new StringEntity(body, StandardCharsets.UTF_8));
|
||||
}
|
||||
|
||||
// 发送http请求
|
||||
try (CloseableHttpClient httpClient = HttpClients.createDefault();
|
||||
CloseableHttpResponse response = httpClient.execute(request)) {
|
||||
HttpEntity entity = response.getEntity();
|
||||
if (null != entity) {
|
||||
String content = EntityUtils.toString(entity, StandardCharsets.UTF_8);
|
||||
EntityUtils.consume(entity); // 关闭content stream
|
||||
return Pair.of(response.getStatusLine(), content);
|
||||
}
|
||||
throw new IOException("No response");
|
||||
} catch (ClientProtocolException e) {
|
||||
throw e;
|
||||
} catch (IOException e) {
|
||||
throw e;
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,167 @@
|
||||
package com.actionsoft.apps.coe.pal.util;
|
||||
|
||||
import com.actionsoft.sdk.local.SDK;
|
||||
import com.actionsoft.sdk.local.api.LogAPI;
|
||||
import org.apache.commons.codec.digest.DigestUtils;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
|
||||
import java.text.SimpleDateFormat;
|
||||
import java.util.*;
|
||||
|
||||
public class WPS4Util {
|
||||
public final static LogAPI log =SDK.getLogAPI();
|
||||
public final static String HTTP_HEADER_WPS_DOCS_DATE = "Wps-Docs-Date";
|
||||
public final static String HTTP_HEADER_WPS_DOCS_AUTHORIZATION = "Wps-Docs-Authorization";
|
||||
public final static String HTTP_HEADER_CONTENT_TYPE = "Content-Type";
|
||||
public final static String WPS_SIGNATURE_VERSION = "WPS-4";
|
||||
|
||||
public final static String[] WORD_EXT = {"doc","dot","wps","wpt","docx","dotx","docm","dotm","rtf","txt"};
|
||||
public final static String[] EXCEL_EXT = {"xls","xlt","et","xlsx","xltx","xlsm","xltm","csv"};
|
||||
public final static String[] PPT_EXT = {"ppt","pptx","pptm","ppsx","ppsm","pps","potx","potm","dpt","dps"};
|
||||
public final static String[] PDF_EXT = {"pdf", "ofd"};
|
||||
|
||||
public final static String[] X_EXT = {"jpeg","jpg","png","gif","bmp","tif","tiff","svg","psd",
|
||||
"tar","zip","7z","gz","rar",
|
||||
"md",
|
||||
"c","cpp","java","js","css","lrc","h","asm","s","asp","bat","bas","prg","cmd","xml"};
|
||||
private static String appId; // 应用id
|
||||
private static String secretKey; // 应用秘钥
|
||||
|
||||
public static void initAppInfo(String appId, String secretKey) {
|
||||
WPS4Util.appId = appId;
|
||||
WPS4Util.secretKey = secretKey;
|
||||
}
|
||||
|
||||
/**
|
||||
* 根据文件名，获取文件类型
|
||||
* @param filename 文件名
|
||||
* @return 文件类型 w p s f
|
||||
*/
|
||||
public static String getFileType(String filename){
|
||||
if(StringUtils.isEmpty(filename)){
|
||||
return null;
|
||||
}
|
||||
int index = filename.lastIndexOf('.');
|
||||
if (index == -1){
|
||||
return null;
|
||||
}
|
||||
String ext = filename.substring(index+1);
|
||||
for (String element : WORD_EXT) {
|
||||
if (StringUtils.equalsIgnoreCase(ext, element)) {
|
||||
return "w";
|
||||
}
|
||||
}
|
||||
for (String item : EXCEL_EXT) {
|
||||
if (StringUtils.equalsIgnoreCase(ext, item)) {
|
||||
return "s";
|
||||
}
|
||||
}
|
||||
for (String value : PPT_EXT) {
|
||||
if (StringUtils.equalsIgnoreCase(ext, value)) {
|
||||
return "p";
|
||||
}
|
||||
}
|
||||
for (String s : PDF_EXT) {
|
||||
if (StringUtils.equalsIgnoreCase(ext, s)) {
|
||||
return "f";
|
||||
}
|
||||
}
|
||||
for (String s : X_EXT) {
|
||||
if (StringUtils.equalsIgnoreCase(ext, s)) {
|
||||
return "x";
|
||||
}
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取请求body MD5
|
||||
* @param content 请求body
|
||||
* @return
|
||||
*/
|
||||
private static String getContentSha256(String content) {
|
||||
if (StringUtils.isBlank(content)) {
|
||||
return "";
|
||||
} else {
|
||||
return DigestUtils.sha256Hex(content);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取日期字符串
|
||||
*
|
||||
* @param date
|
||||
* @return
|
||||
*/
|
||||
private static String getGMTDateString(Date date) {
|
||||
SimpleDateFormat format = new SimpleDateFormat("E, dd MMM yyyy HH:mm:ss [GMT]", Locale.US);
|
||||
format.setTimeZone(TimeZone.getTimeZone("GMT"));
|
||||
return format.format(date) + " GMT";
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取WPS Authorization
|
||||
* @param ver
|
||||
* @param httpMethod
|
||||
* @param uriWithQuerystring
|
||||
* @param contentSha256
|
||||
* @param dateString
|
||||
* @param contentType
|
||||
* @return
|
||||
*/
|
||||
private static String getWpsAuthorization(String ver,String httpMethod,String uriWithQuerystring, String contentSha256, String dateString, String contentType) throws Exception {
|
||||
String signatureStr = String.format("%s%s%s%s%s%s",ver,httpMethod,
|
||||
uriWithQuerystring,contentType,dateString,contentSha256);
|
||||
//log.info("要签名的值:{}",signatureStr);
|
||||
return String.format("WPS-4 %s:%s",appId,EncryptionUtil.HMACSHA256(signatureStr,secretKey));
|
||||
}
|
||||
|
||||
public static String getRfc1123Date() {
|
||||
SimpleDateFormat sdf4 = new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss 'GMT'", Locale.US);
|
||||
sdf4.setTimeZone(TimeZone.getTimeZone("GMT"));
|
||||
return sdf4.format(new Date());
|
||||
}
|
||||
|
||||
|
||||
public static Map<String, String> getSignatureHeaders(String uriWithQuerystring,String httpMethod, String content, String contentType) throws Exception {
|
||||
if (uriWithQuerystring == null) {
|
||||
uriWithQuerystring = "";
|
||||
}
|
||||
if (contentType == null) {
|
||||
contentType = "application/json";
|
||||
}
|
||||
String contentSha256 = getContentSha256(content);
|
||||
|
||||
String dateString = getRfc1123Date();//getGMTDateString(new Date());
|
||||
String authorization = getWpsAuthorization(WPS_SIGNATURE_VERSION,httpMethod,
|
||||
uriWithQuerystring,contentSha256, dateString, contentType);
|
||||
|
||||
Map<String, String> headers = new HashMap<>();
|
||||
headers.put(WPS4Util.HTTP_HEADER_WPS_DOCS_AUTHORIZATION, authorization);
|
||||
headers.put(WPS4Util.HTTP_HEADER_CONTENT_TYPE, contentType);
|
||||
headers.put(WPS4Util.HTTP_HEADER_WPS_DOCS_DATE, dateString);
|
||||
log.consoleInfo("签名结果: {} -> {}"+WPS4Util.HTTP_HEADER_WPS_DOCS_AUTHORIZATION+authorization);
|
||||
//log.info("签名结果: {} -> {}",WPS4Util.HTTP_HEADER_CONTENT_TYPE,contentType);
|
||||
//log.info("签名结果: {} -> {}",WPS4Util.HTTP_HEADER_WPS_DOCS_DATE,dateString);
|
||||
return headers;
|
||||
}
|
||||
|
||||
public static void main(String[] args) throws Exception {
|
||||
String contentType = "application/json";
|
||||
String uriWithQuerystring = "/api/edit/v1/files/1661841425405/link?type=w";
|
||||
String body = "";
|
||||
// 获取签名请求头
|
||||
String appId = "AKyAYlPgfRjnFBGV";
|
||||
String secretKey = "FPLVEBJfEsNVrBkBIShJAmwiufvJIqZy";
|
||||
WPS4Util.initAppInfo(appId, secretKey);
|
||||
Map<String, String> headers = WPS4Util.getSignatureHeaders(uriWithQuerystring, "GET",body, contentType);
|
||||
for (Map.Entry<String, String> entry : headers.entrySet()) {
|
||||
System.out.println(entry.getKey() + " = " + entry.getValue());
|
||||
}
|
||||
|
||||
SimpleDateFormat format = new SimpleDateFormat("E, dd MMM yyyy HH:mm:ss 'GMT'", Locale.US);
|
||||
format.setTimeZone(TimeZone.getTimeZone("GMT"));
|
||||
System.out.println(format.format(new Date()));
|
||||
}
|
||||
}
|
||||
|
||||
Loading…
Reference in New Issue
Block a user