mirror of
https://gitee.com/huangge1199_admin/vue-pro.git
synced 2024-11-22 15:21:53 +08:00
Merge branch 'develop' of https://gitee.com/scholarli/ruoyi-vue-pro_1 into develop
# Conflicts: # yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/framework/sms/core/client/impl/AliyunSmsClient.java
This commit is contained in:
commit
dc267ea568
@ -23,6 +23,8 @@ import cn.iocoder.yudao.module.system.framework.sms.core.property.SmsChannelProp
|
|||||||
import com.google.common.annotations.VisibleForTesting;
|
import com.google.common.annotations.VisibleForTesting;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
|
||||||
|
import java.io.UnsupportedEncodingException;
|
||||||
|
import java.net.URLEncoder;
|
||||||
import java.util.*;
|
import java.util.*;
|
||||||
import java.util.stream.Collectors;
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
@ -64,7 +66,7 @@ public class AliyunSmsClient extends AbstractSmsClient {
|
|||||||
queryParam.put("TemplateCode", apiTemplateId);
|
queryParam.put("TemplateCode", apiTemplateId);
|
||||||
queryParam.put("TemplateParam", JsonUtils.toJsonString(MapUtils.convertMap(templateParams)));
|
queryParam.put("TemplateParam", JsonUtils.toJsonString(MapUtils.convertMap(templateParams)));
|
||||||
queryParam.put("OutId", sendLogId);
|
queryParam.put("OutId", sendLogId);
|
||||||
JSONObject response = request("sendSms", queryParam);
|
JSONObject response = request("SendSms", queryParam);
|
||||||
|
|
||||||
// 2. 解析请求
|
// 2. 解析请求
|
||||||
return new SmsSendRespDTO()
|
return new SmsSendRespDTO()
|
||||||
@ -100,6 +102,8 @@ public class AliyunSmsClient extends AbstractSmsClient {
|
|||||||
queryParam.put("TemplateCode", apiTemplateId);
|
queryParam.put("TemplateCode", apiTemplateId);
|
||||||
JSONObject response = request("QuerySmsTemplate", queryParam);
|
JSONObject response = request("QuerySmsTemplate", queryParam);
|
||||||
|
|
||||||
|
System.out.println("getSmsTemplate response is =====" + response.toString());
|
||||||
|
|
||||||
// 2.1 请求失败
|
// 2.1 请求失败
|
||||||
String code = response.getStr("Code");
|
String code = response.getStr("Code");
|
||||||
if (ObjectUtil.notEqual(code, RESPONSE_CODE_SUCCESS)) {
|
if (ObjectUtil.notEqual(code, RESPONSE_CODE_SUCCESS)) {
|
||||||
@ -144,6 +148,7 @@ public class AliyunSmsClient extends AbstractSmsClient {
|
|||||||
headers.put("x-acs-action", apiName);
|
headers.put("x-acs-action", apiName);
|
||||||
headers.put("x-acs-date", FastDateFormat.getInstance("yyyy-MM-dd'T'HH:mm:ss'Z'", TimeZone.getTimeZone("GMT")).format(new Date()));
|
headers.put("x-acs-date", FastDateFormat.getInstance("yyyy-MM-dd'T'HH:mm:ss'Z'", TimeZone.getTimeZone("GMT")).format(new Date()));
|
||||||
headers.put("x-acs-signature-nonce", IdUtil.randomUUID());
|
headers.put("x-acs-signature-nonce", IdUtil.randomUUID());
|
||||||
|
|
||||||
// 2.2 构建签名 Header
|
// 2.2 构建签名 Header
|
||||||
StringBuilder canonicalHeaders = new StringBuilder(); // 构造请求头,多个规范化消息头,按照消息头名称(小写)的字符代码顺序以升序排列后拼接在一起
|
StringBuilder canonicalHeaders = new StringBuilder(); // 构造请求头,多个规范化消息头,按照消息头名称(小写)的字符代码顺序以升序排列后拼接在一起
|
||||||
StringBuilder signedHeadersBuilder = new StringBuilder(); // 已签名消息头列表,多个请求头名称(小写)按首字母升序排列并以英文分号(;)分隔
|
StringBuilder signedHeadersBuilder = new StringBuilder(); // 已签名消息头列表,多个请求头名称(小写)按首字母升序排列并以英文分号(;)分隔
|
||||||
@ -162,16 +167,18 @@ public class AliyunSmsClient extends AbstractSmsClient {
|
|||||||
String hashedRequestBody = DigestUtil.sha256Hex(requestBody);
|
String hashedRequestBody = DigestUtil.sha256Hex(requestBody);
|
||||||
|
|
||||||
// 4. 构建 Authorization 签名
|
// 4. 构建 Authorization 签名
|
||||||
String hashedCanonicalRequest = DigestUtil.sha256Hex("POST" // httpMethod
|
String canonicalRequest = "POST" + "\n" + "/" + "\n" + queryString + "\n" + canonicalHeaders + "\n" + signedHeaders + "\n" + hashedRequestBody;
|
||||||
+ "\n" + "/" // canonicalUri
|
String hashedCanonicalRequest = DigestUtil.sha256Hex(canonicalRequest);
|
||||||
+ "\n" + queryString + "\n" + canonicalHeaders + "\n" + signedHeaders + "\n" + hashedRequestBody);
|
|
||||||
String stringToSign = "ACS3-HMAC-SHA256" + "\n" + hashedCanonicalRequest;
|
String stringToSign = "ACS3-HMAC-SHA256" + "\n" + hashedCanonicalRequest;
|
||||||
String signature = SecureUtil.hmacSha256(properties.getApiSecret()).digestHex(stringToSign); // 计算签名
|
String signature = SecureUtil.hmacSha256(properties.getApiSecret()).digestHex(stringToSign); // 计算签名
|
||||||
headers.put("Authorization", "ACS3-HMAC-SHA256" + " " + "Credential=" + properties.getApiKey()
|
headers.put("Authorization", "ACS3-HMAC-SHA256" + " " + "Credential=" + properties.getApiKey()
|
||||||
+ ", " + "SignedHeaders=" + signedHeaders + ", " + "Signature=" + signature);
|
+ ", " + "SignedHeaders=" + signedHeaders + ", " + "Signature=" + signature);
|
||||||
|
|
||||||
// 5. 发起请求
|
// 5. 发起请求
|
||||||
String urlWithParams = URL + "?" + URLUtil.buildQuery(queryParams, null);
|
String urlWithParams = URL + "?" + queryString;
|
||||||
|
|
||||||
|
System.out.println("urlWithParams ======" + urlWithParams);
|
||||||
try (HttpResponse response = HttpRequest.post(urlWithParams).addHeaders(headers).body(requestBody).execute()) {
|
try (HttpResponse response = HttpRequest.post(urlWithParams).addHeaders(headers).body(requestBody).execute()) {
|
||||||
return JSONUtil.parseObj(response.body());
|
return JSONUtil.parseObj(response.body());
|
||||||
}
|
}
|
||||||
@ -183,12 +190,15 @@ public class AliyunSmsClient extends AbstractSmsClient {
|
|||||||
* @param str 需要进行URL编码的字符串
|
* @param str 需要进行URL编码的字符串
|
||||||
* @return 编码后的字符串
|
* @return 编码后的字符串
|
||||||
*/
|
*/
|
||||||
private static String percentCode(String str) {
|
public static String percentCode(String str) {
|
||||||
Assert.notNull(str, "str 不能为空");
|
if (str == null) {
|
||||||
return URLUtil.encode(str)
|
throw new IllegalArgumentException("输入字符串不可为null");
|
||||||
.replace("+", "%20") // 加号 "+" 被替换为 "%20"
|
}
|
||||||
.replace("*", "%2A") // 星号 "*" 被替换为 "%2A"
|
try {
|
||||||
.replace("%7E", "~"); // 波浪号 "%7E" 被替换为 "~"
|
return URLEncoder.encode(str, "UTF-8").replace("+", "%20").replace("*", "%2A").replace("%7E", "~");
|
||||||
|
} catch (UnsupportedEncodingException e) {
|
||||||
|
throw new RuntimeException("UTF-8编码不被支持", e);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
Loading…
Reference in New Issue
Block a user