优化代码

This commit is contained in:
阿沐 2022-08-20 22:39:21 +08:00
parent 29cfc30459
commit a40c0e273d
4 changed files with 79 additions and 79 deletions

View File

@ -18,7 +18,7 @@ public enum SmsPlatformEnum {
/** /**
* 腾讯云 * 腾讯云
*/ */
QCLOUD(1), TENCENT(1),
/** /**
* 七牛云 * 七牛云
*/ */

View File

@ -17,8 +17,8 @@ public class SmsContext {
public SmsContext(SmsConfig config) { public SmsContext(SmsConfig config) {
if (config.getPlatform() == SmsPlatformEnum.ALIYUN.getValue()) { if (config.getPlatform() == SmsPlatformEnum.ALIYUN.getValue()) {
this.smsStrategy = new AliyunSmsStrategy(config); this.smsStrategy = new AliyunSmsStrategy(config);
} else if (config.getPlatform() == SmsPlatformEnum.QCLOUD.getValue()) { } else if (config.getPlatform() == SmsPlatformEnum.TENCENT.getValue()) {
this.smsStrategy = new QcloudSmsStrategy(config); this.smsStrategy = new TencentSmsStrategy(config);
} else if (config.getPlatform() == SmsPlatformEnum.QINIU.getValue()) { } else if (config.getPlatform() == SmsPlatformEnum.QINIU.getValue()) {
this.smsStrategy = new QiniuSmsStrategy(config); this.smsStrategy = new QiniuSmsStrategy(config);
} else if (config.getPlatform() == SmsPlatformEnum.HUAWEI.getValue()) { } else if (config.getPlatform() == SmsPlatformEnum.HUAWEI.getValue()) {

View File

@ -5,8 +5,8 @@ import com.tencentcloudapi.common.Credential;
import com.tencentcloudapi.common.profile.ClientProfile; import com.tencentcloudapi.common.profile.ClientProfile;
import com.tencentcloudapi.common.profile.HttpProfile; import com.tencentcloudapi.common.profile.HttpProfile;
import com.tencentcloudapi.sms.v20210111.SmsClient; import com.tencentcloudapi.sms.v20210111.SmsClient;
import com.tencentcloudapi.sms.v20210111.models.SendSmsResponse;
import com.tencentcloudapi.sms.v20210111.models.SendSmsRequest; import com.tencentcloudapi.sms.v20210111.models.SendSmsRequest;
import com.tencentcloudapi.sms.v20210111.models.SendSmsResponse;
import com.tencentcloudapi.sms.v20210111.models.SendStatus; import com.tencentcloudapi.sms.v20210111.models.SendStatus;
import net.maku.framework.common.constant.Constant; import net.maku.framework.common.constant.Constant;
import net.maku.framework.common.exception.FastException; import net.maku.framework.common.exception.FastException;
@ -19,11 +19,11 @@ import java.util.Map;
* *
* @author 阿沐 babamu@126.com * @author 阿沐 babamu@126.com
*/ */
public class QcloudSmsStrategy implements SmsStrategy { public class TencentSmsStrategy implements SmsStrategy {
private final SmsConfig smsConfig; private final SmsConfig smsConfig;
private SmsClient client; private SmsClient client;
public QcloudSmsStrategy(SmsConfig smsConfig){ public TencentSmsStrategy(SmsConfig smsConfig) {
this.smsConfig = smsConfig; this.smsConfig = smsConfig;
try { try {
@ -36,7 +36,7 @@ public class QcloudSmsStrategy implements SmsStrategy {
Credential cred = new Credential(smsConfig.getAccessKey(), smsConfig.getSecretKey()); Credential cred = new Credential(smsConfig.getAccessKey(), smsConfig.getSecretKey());
this.client = new SmsClient(cred, "ap-guangzhou", clientProfile); this.client = new SmsClient(cred, "ap-guangzhou", clientProfile);
}catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
} }
@ -49,12 +49,12 @@ public class QcloudSmsStrategy implements SmsStrategy {
request.setTemplateId(smsConfig.getTemplateId()); request.setTemplateId(smsConfig.getTemplateId());
// 有参数则设置 // 有参数则设置
if(MapUtil.isNotEmpty(params)){ if (MapUtil.isNotEmpty(params)) {
request.setTemplateParamSet(params.values().toArray(new String[0])); request.setTemplateParamSet(params.values().toArray(new String[0]));
} }
// 手机号 // 手机号
String[] phoneNumberSet = { "+86" + mobile }; String[] phoneNumberSet = {"+86" + mobile};
request.setPhoneNumberSet(phoneNumberSet); request.setPhoneNumberSet(phoneNumberSet);
// 国际港澳台短信需要添加SenderId国内短信填空默认未开通 // 国际港澳台短信需要添加SenderId国内短信填空默认未开通
@ -66,7 +66,7 @@ public class QcloudSmsStrategy implements SmsStrategy {
SendStatus sendStatus = response.getSendStatusSet()[0]; SendStatus sendStatus = response.getSendStatusSet()[0];
// 发送失败 // 发送失败
if(!Constant.OK.equalsIgnoreCase(sendStatus.getCode())) { if (!Constant.OK.equalsIgnoreCase(sendStatus.getCode())) {
throw new FastException(sendStatus.getMessage()); throw new FastException(sendStatus.getMessage());
} }
} catch (Exception e) { } catch (Exception e) {