admin/sms4j
1
0
Fork 0
mirror of https://gitee.com/dromara/sms4j.git synced 2025-12-06 17:08:40 +08:00
Code Issues Packages Projects Releases Wiki Activity

修改抛错导致无限循环问题

Browse Source
This commit is contained in:
Sh1yu 2023-11-23 15:00:07 +08:00
parent 714e85fac0
commit a998b96ff6
1 changed files with 24 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
sms4j-provider/src/main/java/org/dromara/sms4j/cloopen/util/CloopenHelper.java
View File

@ -34,27 +34,32 @@ public class CloopenHelper {
this.http = http; this.http = http;
} }
public SmsResponse smsResponse(Map<String, Object> paramMap){ public SmsResponse smsResponse(Map<String, Object> paramMap) {
try {
String timestamp = DateUtil.format(new Date(), DatePattern.PURE_DATETIME_PATTERN);
String url = String.format("%s/Accounts/%s/SMS/TemplateSMS?sig=%s", String timestamp = DateUtil.format(new Date(), DatePattern.PURE_DATETIME_PATTERN);
config.getBaseUrl(),
config.getAccessKeyId(), String url = String.format("%s/Accounts/%s/SMS/TemplateSMS?sig=%s",
this.generateSign(config.getAccessKeyId(), config.getAccessKeySecret(), timestamp)); config.getBaseUrl(),
Map<String, String> headers = new LinkedHashMap<>(3); config.getAccessKeyId(),
headers.put("Accept", Constant.ACCEPT); this.generateSign(config.getAccessKeyId(), config.getAccessKeySecret(), timestamp));
headers.put("Content-Type", Constant.APPLICATION_JSON_UTF8); Map<String, String> headers = new LinkedHashMap<>(3);
headers.put("Authorization", this.generateAuthorization(config.getAccessKeyId(), timestamp)); headers.put("Accept", Constant.ACCEPT);
SmsResponse smsResponse = getResponse(http.postJson(url, headers, paramMap)); headers.put("Content-Type", Constant.APPLICATION_JSON_UTF8);
if(smsResponse.isSuccess() || retry == config.getMaxRetries()){ headers.put("Authorization", this.generateAuthorization(config.getAccessKeyId(), timestamp));
retry = 0; SmsResponse smsResponse = null;
return smsResponse; try {
} smsResponse = getResponse(http.postJson(url, headers, paramMap));
return requestRetry(paramMap); } catch (SmsBlendException e) {
}catch (SmsBlendException e){ smsResponse = new SmsResponse();
return requestRetry(paramMap); smsResponse.setSuccess(false);
smsResponse.setData(e.getMessage());
} }
if (smsResponse.isSuccess() || retry == config.getMaxRetries()) {
retry = 0;
return smsResponse;
}
return requestRetry(paramMap);
} }
private SmsResponse requestRetry(Map<String, Object> paramMap) { private SmsResponse requestRetry(Map<String, Object> paramMap) {