## 注册成功发送阿里云短信;
This commit is contained in:
parent
bb0bf17c5b
commit
6b1e14e7c8
|
@ -18,4 +18,17 @@ public interface ISmsServiceApi {
|
||||||
*/
|
*/
|
||||||
R<String> sendAliSms(String phone, String code, EAliSmsTemplate aliSmsTemplate);
|
R<String> sendAliSms(String phone, String code, EAliSmsTemplate aliSmsTemplate);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 发送会员注册短信
|
||||||
|
*
|
||||||
|
* @param phone
|
||||||
|
* @param aliSmsTemplate
|
||||||
|
* @param memberCode
|
||||||
|
* @param loginPwd
|
||||||
|
* @param payPwd
|
||||||
|
* @return
|
||||||
|
*/
|
||||||
|
R<String> sendMemberRegister(String phone, EAliSmsTemplate aliSmsTemplate, String memberCode, String loginPwd, String payPwd);
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
@ -762,8 +762,9 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
|
||||||
// 推送秒结数据处理 -- 注册订单
|
// 推送秒结数据处理 -- 注册订单
|
||||||
rabbitTemplate.convertAndSend(RabbitMqConstants.ORDER_SECOND_EXCHANGE, RabbitMqConstants.ORDER_SECOND_KEY, saOrderExt);
|
rabbitTemplate.convertAndSend(RabbitMqConstants.ORDER_SECOND_EXCHANGE, RabbitMqConstants.ORDER_SECOND_KEY, saOrderExt);
|
||||||
|
|
||||||
|
// 发送会员注册成功短信
|
||||||
newCuMember.getMemberCode();
|
iSmsServiceApi.sendMemberRegister(newCuMember.getPhone(), EAliSmsTemplate.MEMBER_REGISTER,
|
||||||
|
newCuMember.getMemberCode(), newCuMember.getLoginPassword(), newCuMember.getPayPassword());
|
||||||
|
|
||||||
// if (EOrderType.REGISTER_ORDER.getValue() == saOrderExt.getOrderType()) {
|
// if (EOrderType.REGISTER_ORDER.getValue() == saOrderExt.getOrderType()) {
|
||||||
// // 推送会员续约处理MQ
|
// // 推送会员续约处理MQ
|
||||||
|
|
|
@ -20,6 +20,11 @@ public enum EAliSmsTemplate {
|
||||||
*/
|
*/
|
||||||
MEMBER_SMS("SMS_485350565"),
|
MEMBER_SMS("SMS_485350565"),
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 会员注册成功(尊敬的会员,您新注册的会员编号:${memberCode},登录密码:${loginPwd},支付密码:${payPwd},请妥善保管)
|
||||||
|
*/
|
||||||
|
MEMBER_REGISTER("SMS_491370028"),
|
||||||
|
|
||||||
;
|
;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
|
@ -21,12 +21,26 @@ public class SmsServiceProvider implements ISmsServiceApi {
|
||||||
if (null == str) {
|
if (null == str) {
|
||||||
return R.ok();
|
return R.ok();
|
||||||
}
|
}
|
||||||
log.error("发送阿里短信失败: {}", str);
|
log.error("发送短信验证码失败: {}", str);
|
||||||
return R.fail(str);
|
return R.fail(str);
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
log.error("发送阿里短信异常 phone: {}, code: {}", phone, code, e);
|
log.error("发送短信验证码异常 phone: {}, code: {}", phone, code, e);
|
||||||
return R.fail(e.getMessage());
|
return R.fail(e.getMessage());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public R<String> sendMemberRegister(String phone, EAliSmsTemplate aliSmsTemplate, String memberCode, String loginPwd, String payPwd) {
|
||||||
|
try {
|
||||||
|
String str = SmsUtil.sendMemberRegister(phone, aliSmsTemplate, memberCode, loginPwd, payPwd);
|
||||||
|
if (null == str) {
|
||||||
|
return R.ok();
|
||||||
|
}
|
||||||
|
log.error("发送会员注册短信失败: {}", str);
|
||||||
|
return R.fail(str);
|
||||||
|
} catch (Exception e) {
|
||||||
|
log.error("发送会员注册短信异常 phone: {}, memberCode: {}", phone, memberCode, e);
|
||||||
|
return R.fail(e.getMessage());
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -77,6 +77,48 @@ public class SmsUtil implements InitializingBean {
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public static String sendMemberRegister(String phone, EAliSmsTemplate aliSmsTemplate, String memberCode, String loginPwd, String payPwd) {
|
||||||
|
if (StringUtils.isAnyEmpty(phone)) {
|
||||||
|
return "手机号为空";
|
||||||
|
}
|
||||||
|
log.info("注册会员成功,发送手机号:{}, memberCode:{}", phone, memberCode);
|
||||||
|
if (smsConfig.isEnable()) {
|
||||||
|
// 只有当开启发送短信才进行发送
|
||||||
|
try {
|
||||||
|
Map<String, String> templateParam = new HashMap<>();
|
||||||
|
templateParam.put("memberCode", memberCode);
|
||||||
|
templateParam.put("loginPwd", loginPwd);
|
||||||
|
templateParam.put("payPwd", payPwd);
|
||||||
|
|
||||||
|
Client client = new Client(new Config()
|
||||||
|
.setAccessKeyId(smsConfig.getAliAccessKeyId())
|
||||||
|
.setAccessKeySecret(smsConfig.getAliAccessKeySecret())
|
||||||
|
// 短信发送域
|
||||||
|
.setEndpoint(smsConfig.getAliEndpoint()));
|
||||||
|
|
||||||
|
SendSmsRequest sendSmsRequest = new SendSmsRequest()
|
||||||
|
.setPhoneNumbers(phone)
|
||||||
|
// 短信签名
|
||||||
|
.setSignName(smsConfig.getAliSign())
|
||||||
|
// 短信模板
|
||||||
|
.setTemplateCode(aliSmsTemplate.getCode())
|
||||||
|
.setTemplateParam(JSONUtil.toJsonStr(templateParam));
|
||||||
|
|
||||||
|
SendSmsResponse sendSmsResponse = client.sendSms(sendSmsRequest);
|
||||||
|
|
||||||
|
if (Constants.SUCCESS.equals(sendSmsResponse.getStatusCode())) {
|
||||||
|
if ("OK".equals(sendSmsResponse.getBody().getCode())) {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
log.error("阿里云短信发送失败: {}", sendSmsResponse.getBody().getMessage());
|
||||||
|
}
|
||||||
|
} catch (Exception e) {
|
||||||
|
e.printStackTrace();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void afterPropertiesSet() {
|
public void afterPropertiesSet() {
|
||||||
smsConfig = SpringUtils.getBean(SmsConfig.class);
|
smsConfig = SpringUtils.getBean(SmsConfig.class);
|
||||||
|
|
Loading…
Reference in New Issue