package com.ruoyi.message.wechat.provider.xh;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.ruoyi.message.MessageChannel;
|
import com.ruoyi.message.SendResult;
|
import com.ruoyi.message.wechat.WechatMpConfig;
|
import com.ruoyi.message.wechat.WechatMpConfigProvider;
|
import com.ruoyi.message.wechat.WechatSendRequest;
|
import com.ruoyi.message.wechat.WechatSender;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.ObjectProvider;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Map;
|
|
/**
|
* 新华医院微信公众号发送方（{@code xh} 通道）。
|
* <p>
|
* 对接特征：POST JSON + {@code sign=MD5(appSecret+body)}，成功判定为返回 JSON 的 {@code succ == true}。
|
* <p>
|
* 站点差异（调用方需保留）：
|
* <ul>
|
* <li>需要机构级公众号配置（appid/appSecret/地址），配置不全时直接失败；</li>
|
* <li>要求 HIS 侧患者ID 非空。</li>
|
* </ul>
|
* 代码来源：{@code RyTask 公众号分支} + {@code RedisMqReceiver 公众号分支} +
|
* {@code ServiceSubtaskServiceImpl.wechatSubTask}（行为保持不变）。
|
*/
|
@Slf4j
|
@Component
|
public class XinHuaMpSender implements WechatSender {
|
|
/**
|
* 渠道 key，与 {@code spring.profiles.active=xh} 对应
|
*/
|
public static final String KEY = "xh";
|
|
private final ObjectProvider<WechatMpConfigProvider> configProvider;
|
|
private final XinHuaMpApi xinHuaMpApi;
|
|
public XinHuaMpSender(ObjectProvider<WechatMpConfigProvider> configProvider, XinHuaMpApi xinHuaMpApi) {
|
this.configProvider = configProvider;
|
this.xinHuaMpApi = xinHuaMpApi;
|
}
|
|
@Override
|
public String key() {
|
return KEY;
|
}
|
|
@Override
|
public String description() {
|
return "新华医院微信公众号（sign 签名，succ 判定）";
|
}
|
|
@Override
|
public SendResult send(WechatSendRequest request) {
|
if (request == null) {
|
return SendResult.fail(KEY, MessageChannel.WECHAT, "【公众号】请求参数为空", null);
|
}
|
|
WechatMpConfig config = resolveConfig(request.getOrgid());
|
if (config == null || !config.isComplete()) {
|
return SendResult.fail(KEY, MessageChannel.WECHAT,
|
"【公众号】该机构的公众号配置信息不全，无法通过公众号发送", null);
|
}
|
|
if (StringUtils.isEmpty(request.getPatidHis())) {
|
return SendResult.fail(KEY, MessageChannel.WECHAT,
|
"【公众号】公众号发送失败,his系统的患者id为空", null);
|
}
|
|
try {
|
String raw = xinHuaMpApi.sendMessage(
|
request.getIdCard(),
|
request.getUrl(),
|
request.getTitle(),
|
request.getContent(),
|
request.getPhone(),
|
request.getPatientName(),
|
request.getPatidHis(),
|
config,
|
request.isDisableHtmlEscaping());
|
|
Map map = JSONObject.parseObject(raw, Map.class);
|
boolean success = map != null && !map.isEmpty()
|
&& map.get("succ") != null
|
&& Boolean.parseBoolean(map.get("succ").toString());
|
if (success) {
|
return SendResult.success(KEY, MessageChannel.WECHAT, raw);
|
}
|
Object msg = map == null ? null : map.get("msg");
|
String message = msg == null ? "【公众号】公众号发送失败" : msg.toString();
|
log.error("【{}】公众号发送失败，错误信息：{}", KEY, message);
|
return SendResult.fail(KEY, MessageChannel.WECHAT, message, raw);
|
} catch (Exception e) {
|
log.error("【{}】公众号发送异常：{}", KEY, e.getMessage(), e);
|
return SendResult.fail(KEY, MessageChannel.WECHAT,
|
"【公众号】公众号发送失败，原因：" + e.getMessage(), null);
|
}
|
}
|
|
private WechatMpConfig resolveConfig(String orgid) {
|
WechatMpConfigProvider provider = configProvider.getIfAvailable();
|
if (provider == null) {
|
log.warn("【{}】未找到 WechatMpConfigProvider 实现，无法获取机构公众号配置", KEY);
|
return null;
|
}
|
return provider.getConfig(orgid);
|
}
|
}
|
