dev
parent
5b0a9894f7
commit
8ca81101ab
|
|
@ -1,87 +0,0 @@
|
||||||
package org.qinan.safetyeval.start.sms;
|
|
||||||
|
|
||||||
import io.swagger.annotations.Api;
|
|
||||||
import io.swagger.annotations.ApiOperation;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.springframework.web.bind.annotation.GetMapping;
|
|
||||||
import org.springframework.web.bind.annotation.PostMapping;
|
|
||||||
import org.springframework.web.bind.annotation.RequestMapping;
|
|
||||||
import org.springframework.web.bind.annotation.RequestParam;
|
|
||||||
import org.springframework.web.bind.annotation.RestController;
|
|
||||||
|
|
||||||
import java.util.Map;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 助通短信平台测试控制器
|
|
||||||
*
|
|
||||||
* @author safety-eval
|
|
||||||
*/
|
|
||||||
@Slf4j
|
|
||||||
@Api(tags = "助通短信测试接口")
|
|
||||||
@RestController
|
|
||||||
@RequestMapping("/test/sms")
|
|
||||||
public class SmsTestController {
|
|
||||||
|
|
||||||
private final ZtSmsService ztSmsService;
|
|
||||||
|
|
||||||
public SmsTestController(ZtSmsService ztSmsService) {
|
|
||||||
this.ztSmsService = ztSmsService;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 发送验证码短信测试接口
|
|
||||||
*
|
|
||||||
* @param mobile 手机号
|
|
||||||
* @return 发送结果
|
|
||||||
*/
|
|
||||||
@ApiOperation("发送验证码短信")
|
|
||||||
@PostMapping("/sendCode")
|
|
||||||
public Map<String, Object> sendVerificationCode(@RequestParam String mobile) {
|
|
||||||
log.info("收到验证码发送请求，手机号: {}", mobile);
|
|
||||||
|
|
||||||
// 生成6位随机验证码
|
|
||||||
String validCode = ztSmsService.generateVerificationCode();
|
|
||||||
|
|
||||||
// 发送验证码短信
|
|
||||||
Map<String, Object> result = ztSmsService.sendVerificationCode(mobile, validCode);
|
|
||||||
|
|
||||||
// 返回验证码供测试验证
|
|
||||||
result.put("validCode", validCode);
|
|
||||||
result.put("templateId", "793059");
|
|
||||||
result.put("templateName", "安全评价监管服务系统注册验证码");
|
|
||||||
|
|
||||||
return result;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 发送自定义内容短信测试接口
|
|
||||||
*
|
|
||||||
* @param mobile 手机号
|
|
||||||
* @param content 短信内容
|
|
||||||
* @return 发送结果
|
|
||||||
*/
|
|
||||||
@ApiOperation("发送自定义短信")
|
|
||||||
@PostMapping("/sendCustom")
|
|
||||||
public Map<String, Object> sendCustomSms(@RequestParam String mobile, @RequestParam String content) {
|
|
||||||
log.info("收到自定义短信发送请求，手机号: {}, 内容: {}", mobile, content);
|
|
||||||
return ztSmsService.sendSms(mobile, content);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取短信配置信息
|
|
||||||
*
|
|
||||||
* @return 配置信息
|
|
||||||
*/
|
|
||||||
@ApiOperation("获取短信配置信息")
|
|
||||||
@GetMapping("/config")
|
|
||||||
public Map<String, Object> getConfig() {
|
|
||||||
Map<String, Object> config = new java.util.HashMap<>();
|
|
||||||
config.put("username", "qhdzyhy");
|
|
||||||
config.put("templateId", "793059");
|
|
||||||
config.put("templateName", "安全评价监管服务系统注册验证码");
|
|
||||||
config.put("templateContent", "[秦安安全]您正在注册本系统，验证码:{valid_code}，5分钟内有效，请勿泄露给他人，如非本人操作请忽略本条短信。");
|
|
||||||
config.put("templateVariable", "valid_code");
|
|
||||||
config.put("apiUrl", "http://www.ztsms.cn/sendNSms.do");
|
|
||||||
return config;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,41 +0,0 @@
|
||||||
package org.qinan.safetyeval.start.sms;
|
|
||||||
|
|
||||||
import lombok.Data;
|
|
||||||
import org.springframework.boot.context.properties.ConfigurationProperties;
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 助通短信平台配置属性
|
|
||||||
*
|
|
||||||
* @author safety-eval
|
|
||||||
*/
|
|
||||||
@Data
|
|
||||||
@Component
|
|
||||||
@ConfigurationProperties(prefix = "zt.sms")
|
|
||||||
public class ZtSmsProperties {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 助通短信平台用户名
|
|
||||||
*/
|
|
||||||
private String username = "qhdzyhy";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 助通短信平台密码
|
|
||||||
*/
|
|
||||||
private String password = "Zcloud@88888";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 助通短信平台接口地址
|
|
||||||
*/
|
|
||||||
private String apiUrl = "http://www.ztsms.cn/sendNSms.do";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 短信模板ID
|
|
||||||
*/
|
|
||||||
private String templateId = "793059";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 短信签名
|
|
||||||
*/
|
|
||||||
private String signature = "【秦安安全】";
|
|
||||||
}
|
|
||||||
|
|
@ -1,138 +0,0 @@
|
||||||
package org.qinan.safetyeval.start.sms;
|
|
||||||
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.springframework.http.HttpEntity;
|
|
||||||
import org.springframework.http.HttpHeaders;
|
|
||||||
import org.springframework.http.MediaType;
|
|
||||||
import org.springframework.http.ResponseEntity;
|
|
||||||
import org.springframework.stereotype.Service;
|
|
||||||
import org.springframework.util.LinkedMultiValueMap;
|
|
||||||
import org.springframework.util.MultiValueMap;
|
|
||||||
import org.springframework.web.client.RestTemplate;
|
|
||||||
|
|
||||||
import java.nio.charset.StandardCharsets;
|
|
||||||
import java.security.MessageDigest;
|
|
||||||
import java.text.SimpleDateFormat;
|
|
||||||
import java.util.Date;
|
|
||||||
import java.util.HashMap;
|
|
||||||
import java.util.Map;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 助通短信平台服务
|
|
||||||
* API文档参考: http://www.ztsms.cn
|
|
||||||
*
|
|
||||||
* @author safety-eval
|
|
||||||
*/
|
|
||||||
@Slf4j
|
|
||||||
@Service
|
|
||||||
public class ZtSmsService {
|
|
||||||
|
|
||||||
private final ZtSmsProperties ztSmsProperties;
|
|
||||||
private final RestTemplate restTemplate;
|
|
||||||
|
|
||||||
public ZtSmsService(ZtSmsProperties ztSmsProperties) {
|
|
||||||
this.ztSmsProperties = ztSmsProperties;
|
|
||||||
this.restTemplate = new RestTemplate();
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 发送验证码短信
|
|
||||||
*
|
|
||||||
* @param mobile 手机号
|
|
||||||
* @param validCode 验证码
|
|
||||||
* @return 发送结果
|
|
||||||
*/
|
|
||||||
public Map<String, Object> sendVerificationCode(String mobile, String validCode) {
|
|
||||||
// 构建短信内容：[秦安安全]您正在注册本系统，验证码:{valid_code}，5分钟内有效，请勿泄露给他人，如非本人操作请忽略本条短信。
|
|
||||||
String content = ztSmsProperties.getSignature() + "您正在注册本系统，验证码:" + validCode + "，5分钟内有效，请勿泄露给他人，如非本人操作请忽略本条短信。";
|
|
||||||
return sendSms(mobile, content);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 发送短信
|
|
||||||
*
|
|
||||||
* @param mobile 手机号
|
|
||||||
* @param content 短信内容
|
|
||||||
* @return 发送结果
|
|
||||||
*/
|
|
||||||
public Map<String, Object> sendSms(String mobile, String content) {
|
|
||||||
Map<String, Object> result = new HashMap<>();
|
|
||||||
try {
|
|
||||||
// 生成tkey：当前时间，格式yyyyMMddHHmmss
|
|
||||||
SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");
|
|
||||||
String tkey = sdf.format(new Date());
|
|
||||||
|
|
||||||
// 生成password：md5(md5(password) + tkey)
|
|
||||||
String md5Password = md5(ztSmsProperties.getPassword());
|
|
||||||
String finalPassword = md5(md5Password + tkey);
|
|
||||||
|
|
||||||
// 构建请求参数
|
|
||||||
MultiValueMap<String, String> params = new LinkedMultiValueMap<>();
|
|
||||||
params.add("username", ztSmsProperties.getUsername());
|
|
||||||
params.add("tkey", tkey);
|
|
||||||
params.add("password", finalPassword);
|
|
||||||
params.add("mobile", mobile);
|
|
||||||
params.add("content", content);
|
|
||||||
|
|
||||||
// 设置请求头
|
|
||||||
HttpHeaders headers = new HttpHeaders();
|
|
||||||
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
|
|
||||||
|
|
||||||
HttpEntity<MultiValueMap<String, String>> requestEntity = new HttpEntity<>(params, headers);
|
|
||||||
|
|
||||||
log.info("助通短信发送请求 - 手机号: {}, 内容: {}", mobile, content);
|
|
||||||
log.info("助通短信发送请求 - tkey: {}, password: {}", tkey, finalPassword);
|
|
||||||
|
|
||||||
// 发送请求
|
|
||||||
ResponseEntity<String> response = restTemplate.postForEntity(
|
|
||||||
ztSmsProperties.getApiUrl(),
|
|
||||||
requestEntity,
|
|
||||||
String.class
|
|
||||||
);
|
|
||||||
|
|
||||||
String responseBody = response.getBody();
|
|
||||||
log.info("助通短信发送响应: {}", responseBody);
|
|
||||||
|
|
||||||
result.put("success", true);
|
|
||||||
result.put("mobile", mobile);
|
|
||||||
result.put("response", responseBody);
|
|
||||||
result.put("message", "短信发送成功");
|
|
||||||
|
|
||||||
} catch (Exception e) {
|
|
||||||
log.error("助通短信发送失败", e);
|
|
||||||
result.put("success", false);
|
|
||||||
result.put("mobile", mobile);
|
|
||||||
result.put("message", "短信发送失败: " + e.getMessage());
|
|
||||||
}
|
|
||||||
return result;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* MD5加密
|
|
||||||
*
|
|
||||||
* @param input 待加密字符串
|
|
||||||
* @return 加密后的小写字符串
|
|
||||||
*/
|
|
||||||
private String md5(String input) {
|
|
||||||
try {
|
|
||||||
MessageDigest md = MessageDigest.getInstance("MD5");
|
|
||||||
byte[] digest = md.digest(input.getBytes(StandardCharsets.UTF_8));
|
|
||||||
StringBuilder sb = new StringBuilder();
|
|
||||||
for (byte b : digest) {
|
|
||||||
sb.append(String.format("%02x", b & 0xff));
|
|
||||||
}
|
|
||||||
return sb.toString();
|
|
||||||
} catch (Exception e) {
|
|
||||||
throw new RuntimeException("MD5加密失败", e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 生成6位随机验证码
|
|
||||||
*
|
|
||||||
* @return 6位验证码
|
|
||||||
*/
|
|
||||||
public String generateVerificationCode() {
|
|
||||||
return String.format("%06d", (int) (Math.random() * 1000000));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Loading…
Reference in New Issue