From fef1dfc2595e45ff0db365efd087f9232639eaab Mon Sep 17 00:00:00 2001 From: wanggeng <450292408@qq.com> Date: Thu, 7 Jul 2022 09:26:54 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E7=9B=B4=E6=8E=A5=E5=8F=91?= =?UTF-8?q?=E7=9F=AD=E4=BF=A1=E7=9A=84=E5=8A=9F=E8=83=BD=E5=92=8C=E5=AE=8C?= =?UTF-8?q?=E5=96=84=E8=85=BE=E8=AE=AF=E5=8F=91=E7=9F=AD=E4=BF=A1=E5=8A=9F?= =?UTF-8?q?=E8=83=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../factory/sms/impl/TencentSmsSendImpl.java | 50 ++++++++++++++++++- .../module/sms/service/sms/ISmsService.java | 16 ++++++ .../sms/service/sms/impl/SmsServiceImpl.java | 41 +++++++++++++++ 3 files changed, 106 insertions(+), 1 deletion(-) diff --git a/module-sms/src/main/java/ink/wgink/module/sms/factory/sms/impl/TencentSmsSendImpl.java b/module-sms/src/main/java/ink/wgink/module/sms/factory/sms/impl/TencentSmsSendImpl.java index 944070b8..e1c390fe 100644 --- a/module-sms/src/main/java/ink/wgink/module/sms/factory/sms/impl/TencentSmsSendImpl.java +++ b/module-sms/src/main/java/ink/wgink/module/sms/factory/sms/impl/TencentSmsSendImpl.java @@ -5,9 +5,11 @@ import com.tencentcloudapi.common.exception.TencentCloudSDKException; import com.tencentcloudapi.sms.v20210111.SmsClient; import com.tencentcloudapi.sms.v20210111.models.SendSmsRequest; import com.tencentcloudapi.sms.v20210111.models.SendSmsResponse; +import ink.wgink.exceptions.ParamsException; import ink.wgink.exceptions.base.SystemException; import ink.wgink.module.sms.factory.sms.ISmsSend; import ink.wgink.properties.sms.SmsTencentProperties; +import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -59,6 +61,52 @@ public class TencentSmsSendImpl implements ISmsSend { @Override public void content(String phone, String content) { - throw new SystemException("短信发送失败，腾讯短信未实现该功能"); + String[] contentArray = content.split(":"); + String templateId; + String params = ""; + if (contentArray.length == 2) { + templateId = contentArray[0]; + params = contentArray[1]; + } else { + templateId = contentArray[0]; + } + if (StringUtils.isBlank(templateId)) { + throw new ParamsException("内容格式异常：templateId:param1,param2"); + } + String[] paramArray = StringUtils.isBlank(params) ? new String[0] : params.split(","); + content(templateId, phone, paramArray); + } + + /** + * 发送短息 + * + * @param templateId + * @param phone + * @param templateParams + */ + private void content(String templateId, String phone, String... templateParams) { + try { + Credential credential = new Credential(smsTencentProperties.getSecretId(), smsTencentProperties.getSecretKey()); + SmsClient client = new SmsClient(credential, "ap-guangzhou"); + SendSmsRequest sendSmsRequest = new SendSmsRequest(); + // 设置短信应用ID + sendSmsRequest.setSmsSdkAppId(smsTencentProperties.getSdkAppId()); + // 设置签名 + sendSmsRequest.setSignName(smsTencentProperties.getSignName()); + // 设置短信模板ID + sendSmsRequest.setTemplateId(templateId); + // 设置模板参数 + String[] templateParamSet = templateParams; + sendSmsRequest.setTemplateParamSet(templateParamSet); + // 设置接受猴急 + String[] phoneNumberSet = {"+86" + phone}; + sendSmsRequest.setPhoneNumberSet(phoneNumberSet); + SendSmsResponse response = client.SendSms(sendSmsRequest); + // 获取返回结果 + String responseJsonString = SendSmsResponse.toJsonString(response); + LOG.debug("Tencent sms response: {}", responseJsonString); + } catch (TencentCloudSDKException e) { + throw new SystemException(String.format("ErrorCode: %s, Message: %s", e.getErrorCode(), e.getMessage()), e); + } } } diff --git a/module-sms/src/main/java/ink/wgink/module/sms/service/sms/ISmsService.java b/module-sms/src/main/java/ink/wgink/module/sms/service/sms/ISmsService.java index 6fc38105..f4690c66 100644 --- a/module-sms/src/main/java/ink/wgink/module/sms/service/sms/ISmsService.java +++ b/module-sms/src/main/java/ink/wgink/module/sms/service/sms/ISmsService.java @@ -97,6 +97,14 @@ public interface ISmsService extends ISmsBaseService { */ void sendContentByUserIdAndPhoneAndUserName(String userId, String phone, String userName, String content); + /** + * 直接发送短信，不查询用户 + * + * @param phone + * @param content + */ + void sendContentDirectlyByPhone(String phone, String content); + /** * 发送验证码 * @@ -118,6 +126,14 @@ public interface ISmsService extends ISmsBaseService { */ void sendByPhones(SmsPhoneSendVO smsPhoneSendVO); + /** + * 直接发送短信，不查询用户 + * 如果使用的是 腾讯短信 content格式：templateId:param1,param2，当没有参数时，templateId:即可，但content不能为空 + * + * @param smsPhoneSendVO + */ + void sendDirectlyByPhones(SmsPhoneSendVO smsPhoneSendVO); + /** * 发送短信列表 * diff --git a/module-sms/src/main/java/ink/wgink/module/sms/service/sms/impl/SmsServiceImpl.java b/module-sms/src/main/java/ink/wgink/module/sms/service/sms/impl/SmsServiceImpl.java index aaf51077..0f5d11e1 100644 --- a/module-sms/src/main/java/ink/wgink/module/sms/service/sms/impl/SmsServiceImpl.java +++ b/module-sms/src/main/java/ink/wgink/module/sms/service/sms/impl/SmsServiceImpl.java @@ -131,6 +131,27 @@ public class SmsServiceImpl extends DefaultBaseService implements ISmsService { } } + @Override + public void sendContentDirectlyByPhone(String phone, String content) { + SmsVO smsVO = new SmsVO(); + smsVO.setUserId(phone); + smsVO.setUserName(phone); + smsVO.setPhone(phone); + smsVO.setContent(content); + try { + LOG.info(">>>>> 向手机号：{}，发送内容：{}", phone, content); + SmsSendFactory.getSendSms(smsProperties, smsCustomSend).content(phone, content); + smsVO.setSendStatus(1); + } catch (Exception e) { + String errorMessage = e.getMessage(); + smsVO.setSendStatus(0); + smsVO.setErrorMessage(errorMessage); + throw new SystemException("短信发送失败"); + } finally { + save(smsVO); + } + } + @Override public void sendVerifyCode(String phone) { VerifyCodeManager verifyCodeManager = VerifyCodeManager.getInstance(); @@ -183,6 +204,26 @@ public class SmsServiceImpl extends DefaultBaseService implements ISmsService { }, 3, TimeUnit.SECONDS); } + @Override + public void sendDirectlyByPhones(SmsPhoneSendVO smsPhoneSendVO) { + List phones = new ArrayList<>(smsPhoneSendVO.getPhones()); + for (int i = 0; i < phones.size(); i++) { + if (!RegexUtil.isPhone(phones.get(i))) { + phones.remove(i); + i--; + continue; + } + } + if (phones.isEmpty()) { + return; + } + scheduledExecutorService.schedule(() -> { + phones.forEach(phone -> { + sendContentDirectlyByPhone(phone, smsPhoneSendVO.getContent()); + }); + }, 3, TimeUnit.SECONDS); + } + /** * 发送短信 * 如果用户设置手机号，并且手机号格式正确，用手机号发送，如果格式错误，判断用户名