package com.ruoyi.message.sms.provider.xh;
|
|
import com.ruoyi.common.utils.HttpUtil;
|
import com.ruoyi.common.utils.http.HttpUtils;
|
import com.ruoyi.message.MessageChannel;
|
import com.ruoyi.message.SendResult;
|
import com.ruoyi.message.config.MessageProperties;
|
import com.ruoyi.message.config.XhsmsConfig;
|
import com.ruoyi.message.config.RootMessageProperties;
|
import com.ruoyi.message.sms.AbstractSmsSender;
|
import com.ruoyi.message.sms.SmsSendRequest;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Component;
|
|
import java.net.URLEncoder;
|
import java.util.LinkedHashMap;
|
import java.util.Map;
|
|
/**
|
* 新华短信发送方（{@code xh} 通道，通用短信网关）。
|
* <p>
|
* 对接特征：HTTP POST 表单 {@code action/account/password/mobile/content/extno/rt}，无签名。
|
* <p>
|
* ⚠️ 现有三个入口对同一个网关的调用方式并不一致，且其中两个是坏的。为满足「按站点原样封装、
|
* 不改线上行为」的要求，这里把三种模式都保留为独立方法，由调用方按原站点选择：
|
* <ul>
|
* <li>{@link #sendJsonLegacy} —— 等价 {@code RyTask}：拼好表单参数却发送 {@code new Gson().toJson(req)}
|
* （{@code req} 是空 map，实际发出 {@code {}}），且把 {@code Boolean} 当 {@code String} 返回值，
|
* 必然触发 NPE 被异常分支吞掉。结果：**新华站点长期任务短信实际发不出去**；</li>
|
* <li>{@link #sendForm} —— 等价 {@code RedisMqReceiver}：发送 URL 编码后的表单字符串（正确），
|
* 但原实现忽略了返回值，代码里固定按成功处理；</li>
|
* <li>{@link #sendJson} —— 等价 {@code ServiceSubtaskServiceImpl.smsSubTask} / {@code SmsController}：
|
* 发送 {@code Gson.toJson(map)} 的 JSON。</li>
|
* </ul>
|
* TODO 待确认：以上三种写法哪一种才是新华网关真正接受的报文格式（很可能是 {@link #sendForm}），
|
* 确认后应统一为一种并删除其余两种。
|
*/
|
@Slf4j
|
@Component
|
public class XinHuaSmsSender extends AbstractSmsSender {
|
|
/**
|
* 渠道 key，与 {@code spring.profiles.active=xh} 对应
|
*/
|
public static final String KEY = "xh";
|
|
private final MessageProperties properties;
|
|
public XinHuaSmsSender(MessageProperties properties) {
|
this.properties = properties;
|
}
|
|
@Override
|
public String key() {
|
return KEY;
|
}
|
|
@Override
|
public String description() {
|
return "新华短信（通用网关，表单/JSON 两种报文）";
|
}
|
|
@Override
|
protected SendResult doSend(SmsSendRequest request) {
|
//默认按 RedisMqReceiver 的（正确）表单模式发送
|
return sendForm(request);
|
}
|
|
/**
|
* 模式一：表单字符串（等价 {@code RedisMqReceiver}，推荐）
|
*/
|
public SendResult sendForm(SmsSendRequest request) {
|
XhsmsConfig cfg = properties.getSms().getXhsms();
|
String encodedParams = buildEncodedParams(request, cfg);
|
log.info("【{}】新华短信发送（表单），地址：{}，参数：{}", KEY, cfg.getPath(), encodedParams);
|
HttpUtils.sendPost(cfg.getPath(), encodedParams);
|
//与线上行为一致：原实现未使用返回值，固定按成功处理
|
return SendResult.success(KEY, MessageChannel.SMS, encodedParams);
|
}
|
|
/**
|
* 模式二：JSON 报文（等价 {@code smsSubTask} / {@code SmsController}）
|
*/
|
public SendResult sendJson(SmsSendRequest request) {
|
XhsmsConfig cfg = properties.getSms().getXhsms();
|
Map<String, String> params = buildParams(request, cfg);
|
String json = com.alibaba.fastjson.JSON.toJSONString(params);
|
log.info("【{}】新华短信发送（JSON），地址：{}，参数：{}", KEY, cfg.getPath(), json);
|
Boolean ok = HttpUtil.postJsonRequest(cfg.getPath(), json);
|
if (Boolean.TRUE.equals(ok)) {
|
return SendResult.success(KEY, MessageChannel.SMS, json);
|
}
|
return SendResult.fail(KEY, MessageChannel.SMS, "短信发送失败", json);
|
}
|
|
/**
|
* 模式三：兼容 {@code RyTask} 的旧实现（发送空 JSON，必然失败）。
|
* <p>
|
* 保留此方法是为了让 {@code RyTask} 的改造可以做到「行为一字不差」；确认网关格式后应删除。
|
*/
|
public SendResult sendJsonLegacy(SmsSendRequest request) {
|
XhsmsConfig cfg = properties.getSms().getXhsms();
|
//原实现：Map<String,String> req = new HashMap<>(); ...(HttpUtils.sendPost(xhsmsPath, new Gson().toJson(req));
|
// Gson 序列化空 map 的结果即 "{}"
|
String emptyJson = "{}";
|
log.info("【{}】新华短信发送（RyTask 旧实现，发送空报文），地址：{}", KEY, cfg.getPath());
|
Boolean result = HttpUtils.sendPost(cfg.getPath(), emptyJson);
|
if (Boolean.TRUE.equals(result)) {
|
return SendResult.success(KEY, MessageChannel.SMS, emptyJson);
|
}
|
return SendResult.fail(KEY, MessageChannel.SMS, "短信发送失败", emptyJson);
|
}
|
|
private Map<String, String> buildParams(SmsSendRequest request, XhsmsConfig cfg) {
|
Map<String, String> params = new LinkedHashMap<>();
|
params.put("action", "send");
|
params.put("account", cfg.getAccount());
|
params.put("password", cfg.getPwd());
|
params.put("mobile", request.getPhone());
|
params.put("content", request.getContent());
|
params.put("extno", cfg.getExtno());
|
params.put("rt", "json");
|
return params;
|
}
|
|
private String buildEncodedParams(SmsSendRequest request, XhsmsConfig cfg) {
|
StringBuilder encodedParams = new StringBuilder();
|
for (Map.Entry<String, String> entry : buildParams(request, cfg).entrySet()) {
|
if (encodedParams.length() > 0) {
|
encodedParams.append("&");
|
}
|
encodedParams.append(encode(entry.getKey())).append("=").append(encode(entry.getValue()));
|
}
|
return encodedParams.toString();
|
}
|
|
private String encode(String value) {
|
try {
|
return URLEncoder.encode(value == null ? "" : value, "UTF-8");
|
} catch (Exception e) {
|
return value;
|
}
|
}
|
}
|
