package com.ruoyi.message.sms.provider.nhfy;
|
|
import com.alibaba.fastjson2.JSON;
|
import com.ruoyi.message.config.MessageProperties;
|
import com.ruoyi.message.config.MtSmsConfig;
|
import com.ruoyi.message.config.RootMessageProperties;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.http.HttpEntity;
|
import org.springframework.http.HttpHeaders;
|
import org.springframework.http.MediaType;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.stereotype.Component;
|
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;
|
|
/**
|
* MT消息发送工具类（SP 向行业汇聚平台提交 MT 消息）。
|
* <p>
|
* 接口地址：{@code http://ip:port/submitsm}；编码：UTF-8；鉴权算法：MD5。
|
* <p>
|
* 迁移说明：原类为 {@code com.smartor.common.MtSubmitSmUtil}（{@code @Component} + {@code @Value} 注入），
|
* 迁移后配置改为从 {@link MessageProperties} 读取（底层仍是同一批 configuration key），行为不变。
|
*/
|
@Slf4j
|
@Component
|
public class MtSubmitSmUtil {
|
|
private static final RestTemplate REST_TEMPLATE = new RestTemplate();
|
|
private final MessageProperties properties;
|
|
public MtSubmitSmUtil(MessageProperties properties) {
|
this.properties = properties;
|
}
|
|
/**
|
* 发送 MT 消息
|
*
|
* @param destAddr 目标号码
|
* @param content 短信内容
|
* @return 响应结果
|
*/
|
public Map<String, Object> submitSm(String destAddr, String content) {
|
MtSmsConfig mt = properties.getSms().getMt();
|
try {
|
log.info("南华附一发送短信，destAddr：{}，content：{}", destAddr, content);
|
String date = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
|
String hashHex = buildHashHex(mt.getAccountName(), mt.getPassword(), date);
|
|
Map<String, Object> authMap = new HashMap<>();
|
authMap.put("Algorithm", "MD5");
|
authMap.put("Date", date);
|
authMap.put("HASHHEX", hashHex);
|
|
Map<String, Object> reqMap = new HashMap<>();
|
reqMap.put("accountName", mt.getAccountName());
|
reqMap.put("Authorization", authMap);
|
reqMap.put("DestAddr", destAddr);
|
reqMap.put("SourceAddr", mt.getSourceAddr());
|
reqMap.put("Content", mt.getFlag() + content);
|
reqMap.put("ServiceCode", mt.getServiceCode());
|
|
HttpHeaders headers = new HttpHeaders();
|
headers.setContentType(new MediaType("application", "json", StandardCharsets.UTF_8));
|
headers.set("Accept-Language", "UTF-8");
|
//TODO 待确认：原实现把 app-key 写死为 ak-BFq4NN0TMf92J7KAioNYGz74，
|
// 而 yml 里同时存在 sms_appkey 配置项却未被使用。这里为保持线上行为仍用原硬编码值，
|
// 建议改为读取 mt.getAppkey()（已支持）并确认哪个才是正确的 app-key。
|
headers.set("app-key", "ak-BFq4NN0TMf92J7KAioNYGz74");
|
|
HttpEntity<String> entity = new HttpEntity<>(JSON.toJSONString(reqMap), headers);
|
log.info("MtSubmitSm 请求地址：{}，请求参数：{}", mt.getUrl() + "/submitsm", JSON.toJSONString(reqMap));
|
|
ResponseEntity<String> response = REST_TEMPLATE.postForEntity(mt.getUrl(), entity, String.class);
|
log.info("MtSubmitSm 响应结果：{}", response.getBody());
|
|
return JSON.parseObject(response.getBody(), Map.class);
|
} catch (Exception e) {
|
log.error("MtSubmitSm 发送失败，url：{}，destAddr：{}，error：{}", mt.getUrl(), destAddr, e.getMessage(), e);
|
Map<String, Object> resp = new HashMap<>();
|
resp.put("code", -1);
|
resp.put("message", "发送异常：" + e.getMessage());
|
return resp;
|
}
|
}
|
|
/**
|
* 计算 HASHHEX：MD5(Algorithm:帐号名:密码:Date)
|
* <p>
|
* 例：{@code MD5:95555:12345:2016-10-09 16:19:43}
|
*/
|
private static String buildHashHex(String accountName, String password, String date) throws Exception {
|
String plain = "MD5:" + accountName + ":" + password + ":" + date;
|
MessageDigest md = MessageDigest.getInstance("MD5");
|
byte[] bytes = md.digest(plain.getBytes(StandardCharsets.UTF_8));
|
StringBuilder sb = new StringBuilder();
|
for (byte b : bytes) {
|
sb.append(String.format("%02x", b));
|
}
|
return sb.toString();
|
}
|
|
/**
|
* 判断 MT 响应是否成功（{@code result == "0"}）
|
*/
|
public static boolean isSuccess(Map<String, Object> resp) {
|
if (resp == null) {
|
return false;
|
}
|
Object result = resp.get("result");
|
return result != null && "0".equals(result.toString());
|
}
|
|
/**
|
* 判断响应的 result 字段是否为空
|
*/
|
public static boolean hasResult(Map<String, Object> resp) {
|
return resp != null && StringUtils.isNotEmpty(String.valueOf(resp.get("result")));
|
}
|
}
|
