|
|
@@ -13,6 +13,7 @@ import cn.iocoder.yudao.module.system.framework.sms.core.client.dto.SmsSendRespD
|
|
|
import cn.iocoder.yudao.module.system.framework.sms.core.client.dto.SmsTemplateRespDTO;
|
|
|
import cn.iocoder.yudao.module.system.framework.sms.core.enums.SmsTemplateAuditStatusEnum;
|
|
|
import cn.iocoder.yudao.module.system.framework.sms.core.property.SmsChannelProperties;
|
|
|
+import cn.iocoder.yudao.module.system.service.sms.SmsTemplateService;
|
|
|
import com.fasterxml.jackson.annotation.JsonFormat;
|
|
|
import com.fasterxml.jackson.annotation.JsonProperty;
|
|
|
import lombok.Data;
|
|
|
@@ -141,6 +142,88 @@ public class HuaweiSmsClient extends AbstractSmsClient {
|
|
|
return new SmsSendRespDTO().setSuccess(Objects.equals(response.getStatusLine().getReasonPhrase(), API_CODE_SUCCESS)).setSerialNo(Integer.toString(response.getStatusLine().getStatusCode()))
|
|
|
.setApiRequestId(null).setApiCode(null).setApiMsg(null);
|
|
|
}
|
|
|
+ @Override
|
|
|
+ public SmsSendRespDTO sendSmsLsq(Long sendLogId, String mobile, String apiTemplateId,
|
|
|
+ List<KeyValue<String, Object>> templateParams, SmsTemplateService smsTemplateService) throws Throwable {
|
|
|
+ // TODO @scholar：https://smsapi.cn-north-4.myhuaweicloud.com:443 是不是枚举成静态变量
|
|
|
+ String url = "https://smsapi.cn-north-4.myhuaweicloud.com:443/sms/batchSendSms/v1"; //APP接入地址+接口访问URI
|
|
|
+ // 相比较阿里短信，华为短信发送的时候需要额外的参数“通道号”，考虑到不破坏原有的的结构
|
|
|
+ // 所以将 通道号 拼接到 apiTemplateId 字段中，格式为 "apiTemplateId 通道号"。空格为分隔符。
|
|
|
+ // TODO @scholar：暂时只考虑中国大陆，所以不需要 sender 哈
|
|
|
+ String sender = StrUtil.subAfter(apiTemplateId, " ", true); //中国大陆短信签名通道号或全球短信通道号
|
|
|
+ String templateId = StrUtil.subBefore(apiTemplateId, " ", true); //模板ID
|
|
|
+
|
|
|
+ // 选填,短信状态报告接收地址,推荐使用域名,为空或者不填表示不接收状态报告
|
|
|
+ String statusCallBack = properties.getCallbackUrl();
|
|
|
+
|
|
|
+ // TODO @scholar：1）是不是用 LocalDateTimeUtil.format()；这样 3 行变成一行
|
|
|
+ // TODO @scholar：singerDate 叫 sdkDate 会更合适哈，这样理解起来简单。另外，singer 应该是 signed 么？
|
|
|
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd'T'HHmmss'Z'", Locale.ENGLISH);
|
|
|
+ sdf.setTimeZone(TimeZone.getTimeZone("UTC"));
|
|
|
+ String singerDate = sdf.format(new Date());
|
|
|
+
|
|
|
+ // TODO @scholar：整个处理加密的过程，是不是应该抽成一个 private 方法哈。这样整个调用的主干更清晰。
|
|
|
+ // ************* 步骤 1：拼接规范请求串 *************
|
|
|
+ String httpRequestMethod = "POST";
|
|
|
+ String canonicalUri = "/sms/batchSendSms/v1/";
|
|
|
+ String canonicalQueryString = ""; // 查询参数为空
|
|
|
+ String canonicalHeaders = "content-type:application/x-www-form-urlencoded\n"
|
|
|
+ + "host:smsapi.cn-north-4.myhuaweicloud.com:443\n"
|
|
|
+ + "x-sdk-date:" + singerDate + "\n";
|
|
|
+ // TODO @scholar：静态枚举了
|
|
|
+ String signedHeaders = "content-type;host;x-sdk-date";
|
|
|
+ // TODO @scholar：下面的注释，可以考虑去掉
|
|
|
+ /*
|
|
|
+ * 选填,使用无变量模板时请赋空值 String templateParas = "";
|
|
|
+ * 单变量模板示例:模板内容为"您的验证码是${NUM_6}"时,templateParas可填写为"[\"111111\"]"
|
|
|
+ * 双变量模板示例:模板内容为"您有${NUM_2}件快递请到${TXT_20}领取"时,templateParas可填写为"[\"3\",\"人民公园正门\"]"
|
|
|
+ */
|
|
|
+ // TODO @scholar：CollectionUtils.convertList 可以把 4 行变成 1 行。
|
|
|
+ // TODO @scholar：templateParams 拼写错误哈
|
|
|
+ List<String> templateParas = new ArrayList<>();
|
|
|
+ for (KeyValue<String, Object> kv : templateParams) {
|
|
|
+ templateParas.add(String.valueOf(kv.getValue()));
|
|
|
+ }
|
|
|
+
|
|
|
+ // 请求Body,不携带签名名称时,signature请填null
|
|
|
+ String body = buildRequestBody(sender, mobile, templateId, templateParas, statusCallBack, null);
|
|
|
+ // TODO @scholar：Assert 断言，抛出异常
|
|
|
+ if (null == body || body.isEmpty()) {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ String hashedRequestBody = HexUtil.encodeHexStr(DigestUtil.sha256(body));
|
|
|
+ String canonicalRequest = httpRequestMethod + "\n" + canonicalUri + "\n" + canonicalQueryString + "\n"
|
|
|
+ + canonicalHeaders + "\n" + signedHeaders + "\n" + hashedRequestBody;
|
|
|
+
|
|
|
+ // ************* 步骤 2：拼接待签名字符串 *************
|
|
|
+ // TODO @scholar：sha256Hex 是不是更简洁哈
|
|
|
+ String hashedCanonicalRequest = HexUtil.encodeHexStr(DigestUtil.sha256(canonicalRequest));
|
|
|
+ String stringToSign = "SDK-HMAC-SHA256" + "\n" + singerDate + "\n" + hashedCanonicalRequest;
|
|
|
+
|
|
|
+ // ************* 步骤 3：计算签名 *************
|
|
|
+ String signature = SecureUtil.hmacSha256(properties.getApiSecret()).digestHex(stringToSign);
|
|
|
+
|
|
|
+ // ************* 步骤 4：拼接 Authorization *************
|
|
|
+ String authorization = "SDK-HMAC-SHA256" + " " + "Access=" + properties.getApiKey() + ", "
|
|
|
+ + "SignedHeaders=" + signedHeaders + ", " + "Signature=" + signature;
|
|
|
+
|
|
|
+ // ************* 步骤 5：构造HttpRequest 并执行request请求，获得response *************
|
|
|
+ // TODO @scholar：考虑了下，还是换 hutool 的 httpUtils。因为未来 httpclient 我们可能会移除掉
|
|
|
+ HttpUriRequest postMethod = RequestBuilder.post()
|
|
|
+ .setUri(url)
|
|
|
+ .setEntity(new StringEntity(body, StandardCharsets.UTF_8))
|
|
|
+ .setHeader("Content-Type","application/x-www-form-urlencoded")
|
|
|
+ .setHeader("X-Sdk-Date", singerDate)
|
|
|
+ .setHeader("Authorization", authorization)
|
|
|
+ .build();
|
|
|
+ // TODO @scholar：这种不太适合一直 new 的哈
|
|
|
+ CloseableHttpClient client = HttpClientBuilder.create().build();
|
|
|
+ HttpResponse response = client.execute(postMethod);
|
|
|
+ // TODO @scholar：失败的情况下的处理
|
|
|
+ // TODO @scholar：setSerialNo(Integer.toString(response.getStatusLine().getStatusCode())) 这部分，空一行。一行代码太多了，阅读性不太好哈
|
|
|
+ return new SmsSendRespDTO().setSuccess(Objects.equals(response.getStatusLine().getReasonPhrase(), API_CODE_SUCCESS)).setSerialNo(Integer.toString(response.getStatusLine().getStatusCode()))
|
|
|
+ .setApiRequestId(null).setApiCode(null).setApiMsg(null);
|
|
|
+ }
|
|
|
|
|
|
static String buildRequestBody(String sender, String receiver, String templateId, List<String> templateParas,
|
|
|
String statusCallBack, @SuppressWarnings("SameParameterValue") String signature) throws UnsupportedEncodingException {
|
