package com.ruoyi.common.utils;
|
|
import com.alibaba.fastjson2.JSON;
|
import com.alibaba.fastjson2.JSONObject;
|
import com.ruoyi.common.utils.http.HttpUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
import java.io.BufferedReader;
|
import java.io.IOException;
|
import java.io.InputStreamReader;
|
import java.io.OutputStream;
|
import java.net.HttpURLConnection;
|
import java.net.URL;
|
import java.nio.charset.StandardCharsets;
|
import java.security.MessageDigest;
|
import java.security.NoSuchAlgorithmException;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 短信发送工具类
|
* 参考PHP版本的SmsUtils实现
|
*
|
* @author ruoyi
|
* @date 2025-12-07
|
*/
|
public class SmsUtils {
|
|
private static final Logger log = LoggerFactory.getLogger(SmsUtils.class);
|
|
|
/**
|
* 发送 POST 请求
|
*
|
* @param url 服务器地址
|
* @param data 请求参数
|
* @return 响应内容
|
* @throws IOException
|
*/
|
public static String post(String url, String data) throws IOException {
|
HttpURLConnection connection = (HttpURLConnection) new URL(url).openConnection();
|
connection.setRequestMethod("POST");
|
connection.setRequestProperty("Content-Type", "application/json");
|
connection.setDoOutput(true);
|
try (OutputStream os = connection.getOutputStream()) {
|
os.write(data.getBytes(StandardCharsets.UTF_8));
|
os.flush();
|
}
|
StringBuilder response = new StringBuilder();
|
try (BufferedReader br = new BufferedReader(new InputStreamReader(connection.getInputStream(), StandardCharsets.UTF_8))) {
|
String line;
|
while ((line = br.readLine()) != null) {
|
response.append(line);
|
}
|
}
|
return response.toString();
|
}
|
|
/**
|
* 计算 MD5 值
|
*
|
* @param str 字符串
|
* @return MD5 值
|
* @throws NoSuchAlgorithmException
|
*/
|
public static String md5(String str) throws NoSuchAlgorithmException {
|
MessageDigest md = MessageDigest.getInstance("MD5");
|
byte[] array = md.digest(str.getBytes(StandardCharsets.UTF_8));
|
StringBuilder sb = new StringBuilder();
|
for (byte item : array) {
|
sb.append(Integer.toHexString((item & 0xFF) | 0x100).substring(1, 3));
|
}
|
return sb.toString();
|
}
|
|
/**
|
* 获取当前时间戳（毫秒）
|
*
|
* @return 时间戳字符串
|
*/
|
public static Long getTimestamp() {
|
return System.currentTimeMillis();
|
}
|
|
/**
|
* 生成签名
|
* 签名算法：MD5(userName + password + timestamp)
|
*
|
* @param userName 用户名
|
* @param password 密码
|
* @param timestamp 时间戳
|
* @return 签名字符串
|
*/
|
public static String generateSign(String userName, String password, Long timestamp) throws NoSuchAlgorithmException {
|
// 时间戳
|
|
|
// 计算 sign 参数
|
String sign = md5(userName + timestamp + md5(password));
|
return sign;
|
}
|
|
/**
|
* 发送HTTP POST请求
|
*
|
* @param url 请求地址
|
* @param data 请求数据
|
* @return 响应结果
|
*/
|
public static JSONObject sendPost(String url, Map<String, Object> data) {
|
try {
|
String jsonData = JSON.toJSONString(data);
|
log.debug("短信API请求，URL：{}，数据：{}", url, jsonData);
|
|
String response = post(url,jsonData);;//HttpUtils.sendPost(url, jsonData, "application/json");
|
log.debug("短信API响应：{}", response);
|
|
if (StringUtils.isNotEmpty(response)) {
|
return JSON.parseObject(response);
|
}
|
} catch (Exception e) {
|
log.error("短信API请求失败，URL：{}", url, e);
|
}
|
return null;
|
}
|
|
/**
|
* 群发短信
|
*
|
* @param address 短信服务地址
|
* @param userName 账号
|
* @param password 密码
|
* @param phoneList 手机号列表，多个用逗号分隔
|
* @param content 短信内容
|
* @return 发送结果
|
*/
|
public static JSONObject sendSmsMass(String address, String userName, String password,
|
String phoneList, String content) throws NoSuchAlgorithmException{
|
Long timestamp = getTimestamp();
|
String sign = generateSign(userName, password, timestamp);
|
String url = "http://" + address + "/sms/api/sendMessageMass";
|
|
Map<String, Object> data = new HashMap<>();
|
data.put("userName", userName);
|
data.put("content", content);
|
data.put("phoneList", phoneList);
|
data.put("timestamp", timestamp);
|
data.put("sign", sign);
|
data.put("sendTime", "");
|
data.put("extCode", "");
|
data.put("callData", "");
|
|
return sendPost(url, data);
|
}
|
|
/**
|
* 单条/点对点短信发送
|
*
|
* @param address 短信服务地址
|
* @param userName 账号
|
* @param password 密码
|
* @param messageList 消息列表 [{phone: "手机号", content: "内容"}, ...]
|
* @return 发送结果
|
*/
|
public static JSONObject sendSmsOne(String address, String userName, String password,
|
List<Map<String, String>> messageList) throws NoSuchAlgorithmException {
|
Long timestamp = getTimestamp();
|
String sign = generateSign(userName, password, timestamp);
|
String url = "http://" + address + "/sms/api/sendMessageOne";
|
|
Map<String, Object> data = new HashMap<>();
|
data.put("userName", userName);
|
data.put("timestamp", timestamp);
|
data.put("sign", sign);
|
data.put("messageList", messageList);
|
|
return sendPost(url, data);
|
}
|
|
/**
|
* 发送单条短信（简化方法）
|
*
|
* @param address 短信服务地址
|
* @param userName 账号
|
* @param password 密码
|
* @param phone 手机号
|
* @param content 短信内容
|
* @return 发送结果
|
*/
|
public static JSONObject sendSms(String address, String userName, String password,
|
String phone, String content) throws NoSuchAlgorithmException{
|
List<Map<String, String>> messageList = new ArrayList<>();
|
messageList.add(new HashMap<String, String>() {{
|
put("phone", phone);
|
put("content", content);
|
}});
|
return sendSmsOne(address, userName, password, messageList);
|
}
|
|
/**
|
* 查询账户余额
|
*
|
* @param address 短信服务地址
|
* @param userName 账号
|
* @param password 密码
|
* @return 余额信息
|
*/
|
public static JSONObject getBalance(String address, String userName, String password) throws NoSuchAlgorithmException {
|
Long timestamp = getTimestamp();
|
String sign = generateSign(userName, password, timestamp);
|
String url = "http://" + address + "/sms/api/getBalance";
|
|
Map<String, Object> data = new HashMap<>();
|
data.put("userName", userName);
|
data.put("timestamp", timestamp);
|
data.put("sign", sign);
|
|
return sendPost(url, data);
|
}
|
|
/**
|
* 获取发送报告
|
*
|
* @param address 短信服务地址
|
* @param userName 账号
|
* @param password 密码
|
* @return 发送报告
|
*/
|
public static JSONObject getReport(String address, String userName, String password) throws NoSuchAlgorithmException {
|
Long timestamp = getTimestamp();
|
String sign = generateSign(userName, password, timestamp);
|
String url = "http://" + address + "/sms/api/getReport";
|
|
Map<String, Object> data = new HashMap<>();
|
data.put("userName", userName);
|
data.put("timestamp", timestamp);
|
data.put("sign", sign);
|
|
return sendPost(url, data);
|
}
|
}
|
