+
Date: Tue, 13 Aug 2024 10:44:27 +0800
Subject: [PATCH 8/8] fix bug
---
.../service/impl/SysSmsServiceImpl.java | 37 +++++++++++++------
1 file changed, 26 insertions(+), 11 deletions(-)
diff --git a/sgzb-modules/sgzb-system/src/main/java/com/bonus/sgzb/system/service/impl/SysSmsServiceImpl.java b/sgzb-modules/sgzb-system/src/main/java/com/bonus/sgzb/system/service/impl/SysSmsServiceImpl.java
index afe1cd0..8e2b157 100644
--- a/sgzb-modules/sgzb-system/src/main/java/com/bonus/sgzb/system/service/impl/SysSmsServiceImpl.java
+++ b/sgzb-modules/sgzb-system/src/main/java/com/bonus/sgzb/system/service/impl/SysSmsServiceImpl.java
@@ -8,7 +8,9 @@ import com.bonus.sgzb.common.core.exception.ServiceException;
import com.bonus.sgzb.common.core.utils.GlobalConstants;
import com.bonus.sgzb.common.core.web.domain.AjaxResult;
import com.bonus.sgzb.common.redis.service.RedisService;
+import com.bonus.sgzb.system.api.domain.SysUser;
import com.bonus.sgzb.system.config.TencentSmsConfig;
+import com.bonus.sgzb.system.mapper.SysUserMapper;
import com.bonus.sgzb.system.service.ISysSmsService;
import com.tencentcloudapi.common.Credential;
import com.tencentcloudapi.common.exception.TencentCloudSDKException;
@@ -43,6 +45,8 @@ public class SysSmsServiceImpl implements ISysSmsService {
@Resource
private RedisService redisService;
+ @Resource
+ private SysUserMapper sysUserMapper;
@Resource
private TencentSmsConfig tencentSmsConfig;
@@ -55,6 +59,7 @@ public class SysSmsServiceImpl implements ISysSmsService {
/**
* 验收通知短信
+ *
* @param phone 手机号
* @param msg 内容
* @return
@@ -74,11 +79,12 @@ public class SysSmsServiceImpl implements ISysSmsService {
} catch (Exception e) {
return AjaxResult.error("发送失败:" + e.getMessage());
}*/
- return sendMsgByPhone( phone, msg);
+ return sendMsgByPhone(phone, msg);
}
/**
* 登录短信验证码
+ *
* @param phone 手机号
* @return
*/
@@ -96,12 +102,13 @@ public class SysSmsServiceImpl implements ISysSmsService {
} catch (Exception e) {
return AjaxResult.error("发送失败:" + e.getMessage());
}*/
- return sendCodeByPhone(phone,null);
+ return sendCodeByPhone(phone, null);
}
/**
* 发送消息msg到手机
+ *
* @param phone 手机号码
* @return AjaxResult对象
*/
@@ -128,6 +135,7 @@ public class SysSmsServiceImpl implements ISysSmsService {
/**
* 发送验证码到手机
+ *
* @param phone 手机号码
* @return AjaxResult对象
*/
@@ -136,6 +144,11 @@ public class SysSmsServiceImpl implements ISysSmsService {
if (phone == null || phone.length() != UserConstants.PHONE_DEFAULT_LENGTH_LOGIN) {
return AjaxResult.error("手机号格式错误，请输入11位数字号码");
}
+ // 校验是否存在该手机号
+ SysUser sysUser = sysUserMapper.checkPhoneUnique(phone);
+ if (sysUser == null) {
+ return AjaxResult.error("该手机号未绑定用户，请重新确认");
+ }
String code = getSixBitCode();
// 校验验证码
if (code.length() != UserConstants.CODE_MIN_LENGTH_LOGIN) {
@@ -151,7 +164,8 @@ public class SysSmsServiceImpl implements ISysSmsService {
}
// 存储验证码至Redis中，键值为：code_15588886157 , 有效期5，时间颗粒度为MINUTES:分钟
redisService.setCacheObject("code_" + phone, code, 5L, TimeUnit.MINUTES);
- return success("手机号：" + phone + "，用户登录验证码：" + code + "，返回结果：" + body);
+// return success("手机号：" + phone + "，用户登录验证码：" + code + "，返回结果：" + body);
+ return success("验证码发送成功:" + body);
} catch (Exception e) {
return AjaxResult.error("发送失败:" + e.getMessage());
}
@@ -195,15 +209,16 @@ public class SysSmsServiceImpl implements ISysSmsService {
/**
* 腾讯sms短信
+ *
* @param mobilePhone
* @param templateId
* @param args
* @return
* @throws Exception
*/
- public String sendMessageNew(String mobilePhone,String templateId, String... args) throws Exception {
+ public String sendMessageNew(String mobilePhone, String templateId, String... args) throws Exception {
- try{
+ try {
// 实例化一个认证对象，入参需要传入腾讯云账户secretId，secretKey,此处还需注意密钥对的保密
Credential cred = new Credential(tencentSmsConfig.getAccessKeyId(), tencentSmsConfig.getAccessKeySecret());
// 实例化一个http选项，可选的，没有特殊需求可以跳过
@@ -227,7 +242,7 @@ public class SysSmsServiceImpl implements ISysSmsService {
phoneNumberSet1[i] = "+86" + phoneNumberSet1[i];
}
req.setPhoneNumberSet(phoneNumberSet1);//发送的手机号
- if(null != args && args.length > 0 && Arrays.stream(args)
+ if (null != args && args.length > 0 && Arrays.stream(args)
.noneMatch(s -> s == null || s.trim().isEmpty())) {
String[] templateParamSet1 = args;//模板的参数
req.setTemplateParamSet(templateParamSet1);//发送验证码
@@ -239,19 +254,19 @@ public class SysSmsServiceImpl implements ISysSmsService {
log.info("腾讯云平台短信发送响应结果：{}", JSONObject.toJSONString(resp));
SendStatus[] sendStatusSet = resp.getSendStatusSet();
List sendStatuses = Arrays.asList(sendStatusSet);
- if (CollectionUtils.isNotEmpty(sendStatuses)){
+ if (CollectionUtils.isNotEmpty(sendStatuses)) {
for (SendStatus sendStatus : sendStatuses) {
- if (!"OK".equalsIgnoreCase(sendStatus.getCode())){
- throw new ServiceException(sendStatus.getMessage(),Integer.valueOf(sendStatus.getCode()));
+ if (!"OK".equalsIgnoreCase(sendStatus.getCode())) {
+ throw new ServiceException(sendStatus.getMessage(), Integer.valueOf(sendStatus.getCode()));
}
}
}
- return resp.getRequestId();
+ return resp.getRequestId();
} catch (TencentCloudSDKException e) {
e.printStackTrace();
log.error("短信发送失败：{}", e.getMessage());
- throw new ServiceException(e.getMessage(),Integer.valueOf(e.getErrorCode()));
+ throw new ServiceException(e.getMessage(), Integer.valueOf(e.getErrorCode()));
}
}
}