/*
|
* Copyright (c) 2018-2028, Chill Zhuang All rights reserved.
|
*
|
* Redistribution and use in source and binary forms, with or without
|
* modification, are permitted provided that the following conditions are met:
|
*
|
* Redistributions of source code must retain the above copyright notice,
|
* this list of conditions and the following disclaimer.
|
* Redistributions in binary form must reproduce the above copyright
|
* notice, this list of conditions and the following disclaimer in the
|
* documentation and/or other materials provided with the distribution.
|
* Neither the name of the dreamlu.net developer nor the names of its
|
* contributors may be used to endorse or promote products derived from
|
* this software without specific prior written permission.
|
* Author: Chill 庄骞 (smallchill@163.com)
|
*/
|
package org.springblade.modules.sms.service.impl;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springblade.common.config.SmsConfig;
|
import org.springblade.common.utils.HttpClientUtils;
|
import org.springblade.common.utils.UtilRandom;
|
import org.springblade.common.utils.sms.AlipaySignature;
|
import org.springblade.core.redis.cache.BladeRedis;
|
import org.springblade.modules.resource.entity.Sms;
|
import org.springblade.modules.resource.service.ISmsService;
|
import org.springblade.modules.sms.entity.SmsTemplateEntity;
|
import org.springblade.modules.sms.mapper.SmsTemplateMapper;
|
import org.springblade.modules.sms.service.ISmsSendService;
|
import org.springblade.modules.sms.service.ISmsTemplateService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.io.UnsupportedEncodingException;
|
import java.net.URLEncoder;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
import java.util.concurrent.TimeUnit;
|
|
/**
|
* 短信模版表 服务实现类
|
*
|
* @author BladeX
|
* @since 2024-03-06
|
*/
|
@Service
|
public class SmsSendServiceImpl extends ServiceImpl<SmsTemplateMapper, SmsTemplateEntity> implements ISmsSendService {
|
@Autowired
|
private BladeRedis redisTemplate;
|
private static Logger logger = LoggerFactory.getLogger(SmsSendServiceImpl.class);
|
// 确保这些字符串被适当地定义和管理
|
public static final String SMS_VALIDATE_PHONE = "sms:validate:code:";
|
public static final String SMS_VALIDATE_PHONE_NUM = "sms:validate:phone:";
|
private static final String SMS_SEND_FAILED = "短信发送失败！";
|
private static final String MESSAGE_SOP_EQUALS_MES_RESPONSE_CODE = "message_sop_equalsMes_response";
|
private static final String SEND_TIME_FORMAT = "yyyy-MM-dd HH:mm:ss";
|
|
|
@Autowired
|
private ISmsService iSmsService;
|
|
@Autowired
|
private ISmsTemplateService iSmsTemplateService;
|
|
@Override
|
public Boolean smsSend(String phone) {
|
|
Sms serviceOne = iSmsService.getOne(Wrappers.<Sms>lambdaQuery().eq(Sms::getStatus, 2));
|
if (serviceOne == null) {
|
logger.error("未找到状态为2的Sms服务");
|
return false;
|
}
|
SmsTemplateEntity smsTemplateEntity = iSmsTemplateService.getOne(Wrappers.<SmsTemplateEntity>lambdaQuery()
|
.eq(SmsTemplateEntity::getId, serviceOne.getTemplateId()));
|
if (smsTemplateEntity == null) {
|
logger.error("未找到对应的短信模板");
|
return false;
|
}
|
|
//发送的手机号
|
List<Map> phonesList = new ArrayList<>();
|
|
Map phoneMap = new HashMap();
|
phoneMap.put("phone", phone);
|
|
List<String> varList = new ArrayList<>();
|
Integer code = UtilRandom.randomCount(111111, 999999);
|
|
varList.add(code.toString());
|
phoneMap.put("varList", varList);
|
|
phonesList.add(phoneMap);
|
//短信主题
|
String subject = "对外接口不同内容发送-动态模板";
|
//短信内容
|
String content = smsTemplateEntity.getContent();
|
//短信模板
|
String template_id = null;
|
//发送时间
|
SimpleDateFormat df = new SimpleDateFormat(SEND_TIME_FORMAT);
|
String send_time = df.format(new Date());
|
//优先级，高级=5，中级=3，低级=1
|
String priority = "1";
|
//不同内容发送类型,1=动态模板发送，2=文件内容发送
|
String type = "1";
|
Map params = new HashMap();
|
params.put("phones", phonesList);
|
params.put("subject", subject);
|
params.put("content", content);
|
params.put("template_id", template_id);
|
params.put("send_time", send_time);
|
params.put("priority", priority);
|
params.put("type", type);
|
//创建人主键
|
params.put("sop_create_by", serviceOne.getSmsCode());
|
String s = null;
|
try {
|
s = testGet(params, "message.sop.differentMes", serviceOne);
|
JSONObject jsonObject = JSON.parseObject(s);
|
JSONObject messageSopEqualsMesResponse = (JSONObject) jsonObject.get(MESSAGE_SOP_EQUALS_MES_RESPONSE_CODE);
|
if (messageSopEqualsMesResponse.get("code").equals(200)) {
|
// 将验证码存入redis
|
redisTemplate.setEx(SMS_VALIDATE_PHONE + phone, code, 300L);
|
redisTemplate.setEx(SMS_VALIDATE_PHONE_NUM + phone, 1, 60L);
|
return true;
|
}
|
} catch (Exception e) {
|
logger.error(SMS_SEND_FAILED, e);
|
throw new RuntimeException(e);
|
}
|
return false;
|
}
|
|
public String testGet(Object bizContent, String method, Sms serviceOne) throws Exception {
|
|
// 公共请求参数
|
Map<String, String> params = new HashMap<String, String>();
|
params.put("app_id", serviceOne.getAccessKey());
|
params.put("method", method);
|
params.put("format", "json");
|
params.put("charset", "utf-8");
|
params.put("sign_type", "RSA2");
|
params.put("timestamp", new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
|
params.put("version", "1.0");
|
|
// 业务参数
|
params.put("biz_content", JSON.toJSONString(bizContent));
|
String content = AlipaySignature.getSignContent(params);
|
String sign = AlipaySignature.rsa256Sign(content, serviceOne.getSecretKey(), "utf-8");
|
params.put("sign", sign);
|
|
System.out.println("----------- 请求信息 -----------");
|
System.out.println("请求参数：" + buildParamQuery(params));
|
System.out.println("商户秘钥：" + serviceOne.getSecretKey());
|
System.out.println("待签名内容：" + content);
|
System.out.println("签名(sign)：" + sign);
|
System.out.println("URL参数：" + buildUrlQuery(params));
|
|
System.out.println("----------- 返回结果 -----------");
|
String responseData = HttpClientUtils.doGet(serviceOne.getRemark(), params);// 发送请求
|
System.out.println("返回数据" + responseData);
|
return responseData;
|
}
|
|
protected static String buildParamQuery(Map<String, String> params) {
|
StringBuilder sb = new StringBuilder();
|
for (Map.Entry<String, String> entry : params.entrySet()) {
|
sb.append("&").append(entry.getKey()).append("=").append(entry.getValue());
|
}
|
return sb.toString().substring(1);
|
}
|
|
protected static String buildUrlQuery(Map<String, String> params) {
|
StringBuilder sb = new StringBuilder();
|
for (Map.Entry<String, String> entry : params.entrySet()) {
|
try {
|
sb.append("&").append(entry.getKey()).append("=").append(URLEncoder.encode(entry.getValue(), "UTF-8"));
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
}
|
return sb.toString().substring(1);
|
}
|
}
|
