wangli/msg-center-plat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

短信流控告警降级

Browse Source
This commit is contained in:
yanglin 2024-04-23 18:08:21 +08:00
parent d4708909ca
commit f7be92e74f
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
msg-notices/msg-notices-integration/src/main/java/cn/axzo/msg/center/notices/integration/client/impl/AliYunSmsClientImpl.java
View File

@ -12,9 +12,14 @@ import cn.axzo.msg.center.notices.integration.dto.response.SendSmsCommonResponse
import cn.azxo.framework.common.utils.LogUtil;
import com.alibaba.fastjson.JSON;
import com.aliyun.dysmsapi20170525.Client;
import com.aliyun.dysmsapi20170525.models.*;
import com.aliyun.dysmsapi20170525.models.QuerySendDetailsRequest;
import com.aliyun.dysmsapi20170525.models.QuerySendDetailsResponse;
import com.aliyun.dysmsapi20170525.models.QuerySendDetailsResponseBody;
import com.aliyun.dysmsapi20170525.models.QuerySendDetailsResponseBody.QuerySendDetailsResponseBodySmsSendDetailDTOs;
import com.aliyun.dysmsapi20170525.models.QuerySendDetailsResponseBody.QuerySendDetailsResponseBodySmsSendDetailDTOsSmsSendDetailDTO;
import com.aliyun.dysmsapi20170525.models.SendSmsRequest;
import com.aliyun.dysmsapi20170525.models.SendSmsResponse;
import com.aliyun.dysmsapi20170525.models.SendSmsResponseBody;
import com.aliyun.teautil.models.RuntimeOptions;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.CollectionUtils;
@ -177,7 +182,7 @@ public class AliYunSmsClientImpl implements AliYunSmsClient {
}
if (!AliyunConstants.SUCCESS_CODE.equals(responseBody.getCode())) {
String message = responseBody.getMessage();
boolean isRateLimited = message != null && message.contains("触发号码天级流控");
boolean isRateLimited = message != null && message.contains("触发") && message.contains("流控");
log.warn("AliyunSmsService#checkResponse is fail, error message : {}", message);
if (!isRateLimited)
throw new BizException(ReturnCodeEnum.SYSTEM_ERROR, message);